OrderController.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Exports\Export;
  4. use App\OracleBasCustomer;
  5. use App\OracleDOCOrderHeader;
  6. use App\OracleDOCWaveDetails;
  7. use Doctrine\DBAL\Schema\AbstractAsset;
  8. use Illuminate\Database\Eloquent\Collection;
  9. use Illuminate\Http\Request;
  10. use Illuminate\Support\Facades\Auth;
  11. use Illuminate\Support\Facades\DB;
  12. use Illuminate\Support\Facades\Gate;
  13. use Maatwebsite\Excel\Facades\Excel;
  14. class OrderController extends Controller
  15. {
  16. private function preciseQuery(Request $request,$sql){
  17. $orderdate_start=$request->input('orderdate_start');
  18. $orderdate_end=$request->input('orderdate_end');
  19. $ordertime_start=$request->input('ordertime_start');
  20. $ordertime_end=$request->input('ordertime_end');
  21. $customerid=$request->input('customerid');
  22. $orderno=$request->input('orderno');
  23. $soreference5=$request->input('soreference5');
  24. $codename_c=$request->input('codename_c');
  25. $carriername=$request->input('carriername');
  26. $soreference1=$request->input('soreference1');
  27. $issuepartyname=$request->input('issuepartyname');
  28. $notes=$request->input('notes');
  29. $addtime=$request->input('addtime');
  30. $waveno=$request->input('waveno');
  31. $edisendflag2=$request->edisendflag2;
  32. if ($orderdate_start){
  33. $sql.=" and ordertime>='".$orderdate_start;
  34. if ($ordertime_start)$sql.=" ".$ordertime_start.":00'";
  35. else $sql.=" 00:00:00'";
  36. }
  37. if ($orderdate_end){
  38. $sql.=" and ordertime<='".$orderdate_end;
  39. if ($ordertime_end)$sql.=" ".$ordertime_end.":59' ";
  40. else $sql.=" 23:59:59' ";
  41. }
  42. if ($customerid)$sql.=" and customerid='".$customerid."'";
  43. if ($orderno)$sql.=" and orderno like '".$orderno."%'";
  44. if ($codename_c)$sql.=" and sostatus = '".$codename_c."'";
  45. if ($carriername)$sql.=" and carriername like '".$carriername."%'";
  46. if ($soreference1){
  47. $arr=array_filter(preg_split('/[,, ]+/is', $soreference1));
  48. if (count($arr)>0){
  49. $sql.=" and soreference1 in (";
  50. foreach ($arr as $index=>$str){
  51. if ($index==0){
  52. $sql.="'".$str."'";
  53. continue;
  54. }
  55. $sql.=",'".$str."'";
  56. }
  57. $sql.=")";
  58. }
  59. }
  60. if ($waveno)$sql.=" and WaveNo like '".$waveno."%'";
  61. if ($issuepartyname)$sql.=" and issuepartyname like '".$issuepartyname."%'";
  62. if ($notes){
  63. if ($addtime&&$addtime!=0)$sql.=" and addtime >= '".date('Y-m-d H:i:s',strtotime("-".$addtime." day"))."'";
  64. $sql.=" and notes like '%".$notes."%'";
  65. }else unset($request->input()['addtime']);
  66. if ($soreference5){
  67. $arr=array_filter(preg_split('/[,, ]+/is', $soreference5));
  68. if (count($arr)>0){
  69. $sql.=" and (soreference5 in (";
  70. foreach ($arr as $index=>$str){
  71. if ($index==0){
  72. $sql.="'".$str."'";
  73. continue;
  74. }
  75. $sql.=",'".$str."'";
  76. }
  77. $sql.=") ";
  78. /*分箱号*/
  79. $oracleActAllocationDetails=DB::connection('oracle')->table('ACT_ALLOCATION_DETAILS')->whereIn('picktotraceid',$arr)->get();
  80. $picktotraceids=array_unique(array_column($oracleActAllocationDetails->toArray(),'orderno'));
  81. if (count($picktotraceids)>0){
  82. $sql.='OR orderno IN (';
  83. foreach ($picktotraceids as $index=>$str){
  84. if ($index==0){
  85. $sql.="'".$str."'";
  86. continue;
  87. }
  88. $sql.=",'".$str."'";
  89. }
  90. $sql.=") ";
  91. }
  92. $sql.=")";
  93. }
  94. }
  95. if ($edisendflag2){
  96. $sql.=" and edisendflag2 = '".$edisendflag2."'";
  97. }
  98. return $sql;
  99. }
  100. public function delivering(Request $request){
  101. if(!Gate::allows('订单管理-查询')){ return redirect(url('/')); }
  102. $paginate=$request->input('paginate')??50;
  103. $page=$request->input('page')??1;
  104. $checkData=$request->input('checkData');
  105. $alternate_sku1=$request->input('alternate_sku1');
  106. $export=$request->input('export');
  107. $sql="select ACT_ALLOCATION_DETAILS_temp.picktotraceid,ACT_ALLOCATION_DETAILS.CHECKTIME,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,DOC_ORDER_HEADER.CustomerID
  108. ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
  109. DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
  110. ,DOC_ORDER_HEADER.soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
  111. DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
  112. ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime,DOC_Order_Details.CustomerID,
  113. DOC_Order_Details.SKU,DOC_Order_Details.QtyOrdered,DOC_Order_Details.OrderLineNo,BAS_Codes.codename_c,BAS_Customer.descr_c as customer_descr_c,
  114. BAS_SKU.Alternate_SKU1,BAS_SKU.Descr_C,(select count(*) from DOC_ORDER_HEADER WHERE 1=1";
  115. $sql=$this->preciseQuery($request,$sql);
  116. ;$sql.=" ) as counted from (";
  117. if (!$request->input('export')&&!$request->input('export'))$sql.=" select * from (";
  118. $sql.=" select ROWNUM as rn,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,DOC_ORDER_HEADER.CustomerID
  119. ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
  120. DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
  121. ,DOC_ORDER_HEADER.soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
  122. DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
  123. ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime from (select * from DOC_ORDER_HEADER order by ADDTIME desc )DOC_ORDER_HEADER where 1=1 ";
  124. $sql=$this->preciseQuery($request,$sql);
  125. if ($checkData){
  126. $checkData=explode(',',$checkData);
  127. if (count($checkData)>0){
  128. $sql.=" and orderno in (";
  129. foreach ($checkData as $index=>$str){
  130. if ($index==0){
  131. $sql.="'".$str."'";
  132. continue;
  133. }
  134. $sql.=",'".$str."'";
  135. }
  136. $sql.=")";
  137. }
  138. }
  139. if (!$request->input('export')&&!$request->input('export'))$sql.=" and ROWNUM<='".$page*$paginate."')";
  140. if (!$request->input('export')&&!$request->input('export'))$sql.=" header where header.rn>'".($page-1)*$paginate."' ";
  141. $sql.=")DOC_ORDER_HEADER left join DOC_ORDER_DETAILS on DOC_ORDER_DETAILS.ORDERNO=DOC_ORDER_HEADER.ORDERNO
  142. left join BAS_CODES on BAS_CODES.CODE=DOC_ORDER_HEADER.sostatus and BAS_CODES.codeid='SO_STS'
  143. left join BAS_Customer on BAS_Customer.customerid=DOC_ORDER_HEADER.customerid
  144. left join BAS_SKU on DOC_Order_Details.CustomerID=BAS_SKU.CustomerID and DOC_Order_Details.SKU=BAS_SKU.SKU
  145. left join ACT_ALLOCATION_DETAILS on DOC_Order_Details.orderno=ACT_ALLOCATION_DETAILS.orderno and DOC_Order_Details.orderlineno=ACT_ALLOCATION_DETAILS.orderlineno
  146. LEFT JOIN (select XMLAGG(XMLPARSE(CONTENT picktotraceid || ',' WELLFORMED) ORDER BY ORDERNO).GETCLOBVAL() as picktotraceid,
  147. ORDERNO from ACT_ALLOCATION_DETAILS group by ORDERNO)ACT_ALLOCATION_DETAILS_temp
  148. ON DOC_ORDER_HEADER.orderno = ACT_ALLOCATION_DETAILS_temp.orderno";
  149. if ($alternate_sku1)$sql.=" where BAS_SKU.Alternate_SKU1 like '".$alternate_sku1."%'";
  150. $orders=DB::connection('oracle')->select(DB::raw($sql));
  151. $commodities=[];
  152. foreach ($orders as $index=>$order){
  153. if ($order->picktotraceid){
  154. $order->picktotraceid=rtrim($order->picktotraceid, ',');
  155. $picktotraceid=array_unique(explode(',',$order->picktotraceid));
  156. $order->picktotraceid=$picktotraceid;
  157. }
  158. if (isset($commodities[$order->orderno])){
  159. array_push($commodities[$order->orderno],
  160. ["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,"descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered
  161. ,"checktime"=>$order->checktime]);
  162. unset($orders[$index]);
  163. continue;
  164. }
  165. $commodities[$order->orderno]=[["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,
  166. "descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered,"checktime"=>$order->checktime]];
  167. }
  168. $orders=array_values($orders);
  169. $orders = new Collection($orders);
  170. $commodities=new Collection($commodities);
  171. if ($checkData || $export)return $this->export($orders,$commodities);
  172. $customers=OracleBasCustomer::select('customerid','descr_c')->where('customer_type','OW')->where('active_flag','Y')->get();
  173. $request=$request->input();
  174. $codes=DB::connection('oracle')->table('BAS_CODES')->select('code','codename_c')->where('codeid','SO_STS')->get();
  175. return view('order/index/delivering',compact('orders','customers','request','codes','commodities','page'));
  176. }
  177. //批量备注追加
  178. public function batchComments(Request $request){
  179. if(!Gate::allows('订单管理-批量备注')){ return redirect(url('/')); }
  180. $checkData=$request->input('checkData');
  181. $content=$request->input('content');
  182. $ordersNotNull=OracleDOCOrderHeader::select('OrderNo','Notes')->whereIn('orderno',$checkData)
  183. ->whereNotNull('notes')->get();
  184. OracleDOCOrderHeader::select('OrderNo','Notes')->whereIn('orderno',$checkData)
  185. ->whereNull('notes')->update(['notes'=>$content]);
  186. $ordersNotNullArr=array_column($ordersNotNull->toArray(),'orderno');
  187. $ordersNullArr=array_diff($checkData,$ordersNotNullArr);
  188. $data=[];
  189. foreach ($ordersNotNull as $order){
  190. OracleDOCOrderHeader::where('orderno',$order->orderno)->update(["notes"=>($order->notes).",".$content]);
  191. $this->log(__METHOD__,'批量备注追加修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  192. $order->notes=($order->notes).",".$content;
  193. array_push($data,$order);
  194. }
  195. foreach ($ordersNullArr as $order){
  196. array_push($data,["orderno"=>$order,'notes'=>$content]);
  197. }
  198. return $data;
  199. }
  200. //批量冻结
  201. public function freezeAll(Request $request){
  202. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  203. $checkData=$request->input('checkData')??'';
  204. //冻结条件只局限于 分配完成sostatus=40 创建订单sostatus=00 拣货完成sostatus=60 播种完成sostatus=61
  205. $sostatus=['40','00','60','61'];
  206. $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
  207. if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可冻结订单"];
  208. foreach ($orders as $order){
  209. $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
  210. if ($waveno && $waveno!='*'){
  211. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
  212. $this->log(__METHOD__,'批量冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  213. }
  214. $is_freeze=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
  215. $this->log(__METHOD__,'批量冻结修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  216. if (!$is_freeze)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
  217. }
  218. return ['success'=>true];
  219. }
  220. //批量取消分配
  221. public function deAllocationAll(Request $request){
  222. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  223. $checkData=$request->input('checkData')??'';
  224. //取消分配条件只局限于 分配完成sostatus=40 和 部分分配sostatus=30
  225. $sostatus=['30','40'];
  226. // $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->where(function($query){
  227. // $query->orWhere('SoStatus','30')->orWhere('SoStatus','40');
  228. // })->toSql();
  229. $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
  230. if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可取消分配订单"];
  231. foreach ($orders as $order){
  232. $is_deAllocation=$this->isDeAllocation($order->orderno);
  233. $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
  234. if ($waveno && $waveno!='*'){
  235. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
  236. $this->log(__METHOD__,'批量取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  237. }
  238. $deAllocation=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['sostatus'=>'00','waveno'=>'*']);
  239. $this->log(__METHOD__,'批量取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  240. if (!$is_deAllocation||!$deAllocation)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
  241. }
  242. return ['success'=>true];
  243. }
  244. //冻结
  245. public function freeze(Request $request){
  246. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  247. $orderno=$request->input('orderno');
  248. $waveno=$request->input('waveno');
  249. // $order=OracleDOCOrderHeader::where('orderno',$orderno)->first();
  250. // if(!($order['codename_c']==='创建订单'||$order['codename_c']==='分配完成'||$order['codename_c']==='拣货完成'||$order['codename_c']==='播种完成')){
  251. // return ['success'=>false];
  252. // }
  253. if ($waveno && $waveno!='*'){
  254. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
  255. $this->log(__METHOD__,'冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  256. }
  257. OracleDOCOrderHeader::where('orderno',$orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
  258. $this->log(__METHOD__,'冻结'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  259. return ['success'=>true];
  260. }
  261. public function thaw(Request $request){
  262. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  263. $orderno=$request->input('orderno');
  264. OracleDOCOrderHeader::where('orderno',$orderno)->update(['releasestatus'=>'N']);
  265. $this->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  266. return ['success'=>true];
  267. }
  268. function export($orders,$commodities){
  269. if(!Gate::allows('订单管理')){ return redirect(url('/')); }
  270. ini_set('max_execution_time',3500);
  271. ini_set('memory_limit','3526M');
  272. $row=[[
  273. 'orderno'=>'编号',
  274. 'sostatus'=>'订单状态',
  275. 'notes'=>'备注',
  276. 'addtime'=>'接口下发时间',
  277. 'issuepartyname'=>'店铺名称',
  278. 'oracleBASCustomer_descr_c'=>'客户',
  279. 'soreference1'=>'客户订单号',
  280. 'carriername'=>'承运人',
  281. 'soreference5'=>'快递单号',
  282. 'c_contact'=>'收货人名称',
  283. 'c_tel2'=>'收货人电话',
  284. 'c_province'=>'省',
  285. 'c_city'=>'市',
  286. 'c_district'=>'区',
  287. 'c_address1'=>'收货人地址',
  288. 'waveno'=>'波次编号',
  289. 'warehouseid'=>'仓库',
  290. 'edisendflag2'=>'快递获取标记',
  291. 'edisendtime2'=>'快递获取时间',
  292. 'sku'=>'产品代码',
  293. 'alternate_sku1'=>'产品条码',
  294. 'descr_c'=>'产品名称',
  295. 'qtyordered'=>'订单数量',
  296. 'erpcancelflag'=>'接口取消标记',
  297. 'picking_print_flag'=>'拣货单打印标记',
  298. 'edisendflag'=>'接口回传标记',
  299. 'releasestatus'=>'订单冻结',
  300. ]];
  301. $list=[];
  302. $sign=[];
  303. $mergeCell=[];
  304. foreach ($orders as $order){
  305. $data=[
  306. 'orderno'=>$order->orderno,
  307. 'addtime'=>$order->addtime,
  308. 'sostatus'=>$order->codename_c,
  309. 'warehouseid'=>$order->warehouseid,
  310. 'oracleBASCustomer_descr_c'=>$order->customer_descr_c,
  311. 'c_contact'=>$order->c_contact,
  312. 'c_tel2'=>$order->c_tel2,
  313. 'c_province'=>$order->c_province,
  314. 'c_city'=>$order->c_city,
  315. 'c_district'=>$order->c_district,
  316. 'carriername'=>$order->carriername,
  317. 'issuepartyname'=>$order->issuepartyname,
  318. 'waveno'=>$order->waveno,
  319. 'soreference1'=>$order->soreference1,
  320. 'soreference5'=>$order->soreference5,
  321. 'edisendflag2'=>$order->edisendflag2,
  322. 'edisendtime2'=>$order->edisendtime2,
  323. 'notes'=>$order->notes,
  324. 'erpcancelflag'=>$order->erpcancelflag,
  325. 'picking_print_flag'=>$order->picking_print_flag,
  326. 'edisendflag'=>$order->edisendflag,
  327. 'releasestatus'=>$order->releasestatus,
  328. 'c_address1'=>$order->c_address1,
  329. ];
  330. if (count($commodities[$order->orderno])<1){
  331. $data['sku']='';
  332. $data['alternate_sku1']='';
  333. $data['descr_c']='';
  334. $data['qtyordered']='';
  335. array_push($list,$data);
  336. continue;
  337. }
  338. foreach ($commodities[$order->orderno] as $oracleDOCOrderDetail){
  339. $data['sku']=$oracleDOCOrderDetail['sku'];
  340. $data['alternate_sku1']=$oracleDOCOrderDetail['alternate_sku1'];
  341. $data['descr_c']=$oracleDOCOrderDetail['descr_c'];
  342. $data['qtyordered']=$oracleDOCOrderDetail['qtyordered'];
  343. if (isset($sign[$order->orderno])){
  344. $data['orderno']='';$data['sostatus']='';$data['warehouseid']='';$data['oracleBASCustomer_descr_c']='';$data['c_contact']='';$data['addtime']='';
  345. $data['c_tel2']='';$data['carriername']='';$data['issuepartyname']='';$data['waveno']='';$data['soreference1']='';$data['soreference5']='';
  346. $data['edisendflag2']='';$data['edisendtime2']='';$data['notes']='';$data['erpcancelflag']='';$data['picking_print_flag']='';$data['edisendflag']='';
  347. $data['releasestatus']='';$data['c_address1']='';$data['c_province']='';$data['c_city']='';$data['c_district']='';
  348. array_push($list,$data);
  349. continue;
  350. }
  351. array_push($list,$data);
  352. $sign[$order->orderno]=count($list)+1;
  353. }
  354. if (count($commodities[$order->orderno])>1){
  355. $mergeCell[$sign[$order->orderno]]=$sign[$order->orderno]+(count($commodities[$order->orderno])-1);
  356. }
  357. }
  358. $columnName=["A","B","C","D","E","F","G","H","I","J","K","L","M","N","O","P","Q","R","S","X","Y","Z","AA"];
  359. return Excel::download(new Export($row,$list,$mergeCell,$columnName),date('YmdHis', time()).'-出库发运单.xlsx');
  360. }
  361. //取消分配
  362. public function deAllocation(Request $request){
  363. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  364. $orderno=$request->input('orderno');
  365. $waveno=$request->input('waveno');
  366. if ($waveno && $waveno!='*'){
  367. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
  368. $this->log(__METHOD__,'取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  369. }
  370. OracleDOCOrderHeader::where('orderno',$orderno)->update(['sostatus'=>'00','waveno'=>'*']);
  371. $this->log(__METHOD__,'取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  372. $is_deAllocation=$this->isDeAllocation($orderno);
  373. if($is_deAllocation) return ['success'=>true];
  374. }
  375. //调用sp取消选中订单的分配
  376. public function isDeAllocation($orderno){
  377. $username=config('database.connections.oracle.username');
  378. $password=config('database.connections.oracle.password');
  379. $host=config('database.connections.oracle.host');
  380. $service_name=config('database.connections.oracle.service_name');
  381. $conn=oci_connect($username,$password,$host.'/'.$service_name); //连接oracle数据库
  382. $IN_Warehouse='';
  383. $IN_Process_Action_C='' ;
  384. $IN_Process_By_C='By OrderNO';
  385. $IN_WaveNO_C='';
  386. $IN_OrderNO_C=$orderno;
  387. $IN_OrderLineNO_C='';
  388. $IN_AllocationDetailsID='';
  389. $IN_Language='';
  390. $IN_UserID='';
  391. $OUT_Return_Code='';
  392. $sql_sp="begin SPSO_DEALLOCATION_PROCESS(:IN_Warehouse,:IN_Process_Action_C,:IN_Process_By_C,
  393. :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
  394. $stmt = oci_parse($conn, $sql_sp);
  395. oci_bind_by_name($stmt,':IN_Warehouse',$IN_Process_Action_C);
  396. oci_bind_by_name($stmt,':IN_Process_Action_C',$IN_Warehouse);
  397. oci_bind_by_name($stmt,':IN_Process_By_C',$IN_Process_By_C);
  398. oci_bind_by_name($stmt,':IN_WaveNO_C',$IN_WaveNO_C);
  399. oci_bind_by_name($stmt,':IN_OrderNO_C',$IN_OrderNO_C);
  400. oci_bind_by_name($stmt,':IN_OrderLineNO_C',$IN_OrderLineNO_C);
  401. oci_bind_by_name($stmt,':IN_AllocationDetailsID',$IN_AllocationDetailsID);
  402. oci_bind_by_name($stmt,':IN_Language',$IN_Language);
  403. oci_bind_by_name($stmt,':IN_UserID',$IN_UserID);
  404. oci_bind_by_name($stmt,':OUT_Return_Code',$OUT_Return_Code);
  405. $this->log(__METHOD__,'调用sp根据订单取消分配'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
  406. return oci_execute($stmt);
  407. }
  408. }