OrderController.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553
  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 App\OrderIssueType;
  8. use Exception;
  9. use Illuminate\Database\Eloquent\Collection;
  10. use Illuminate\Http\Request;
  11. use Illuminate\Support\Facades\Auth;
  12. use Illuminate\Support\Facades\DB;
  13. use Illuminate\Support\Facades\Gate;
  14. use Illuminate\Support\Facades\Http;
  15. use Maatwebsite\Excel\Facades\Excel;
  16. class OrderController extends Controller
  17. {
  18. private function preciseQuery(Request $request,$sql){
  19. $orderdate_start=$request->input('orderdate_start');
  20. $orderdate_end=$request->input('orderdate_end');
  21. $customerid=$request->input('customerid');
  22. $orderno=$request->input('orderno');
  23. $soreference5=$request->input('soreference5');
  24. $codename_c=$request->input('codename_c');
  25. $codename_c_end=$request->input('codename_c_end');
  26. $carriername=$request->input('carriername');
  27. $soreference1=$request->input('soreference1');
  28. $issuepartyname=$request->input('issuepartyname');
  29. $notes=$request->input('notes');
  30. $addtime=$request->input('addtime');
  31. $waveno=$request->input('waveno');
  32. $alternate_sku1=$request->input('alternate_sku1');
  33. $c_contact = $request->input('c_contact');
  34. $c_tel2 = $request->input('c_tel2');
  35. $c_province = $request->input('c_province');
  36. $c_city = $request->input('c_city');
  37. $c_district = $request->input('c_district');
  38. $releasestatus = $request->input('releasestatus');
  39. $ordernos = $request->input('ordernos');
  40. $edisendflag2=$request->edisendflag2;
  41. $edisendflag=$request->edisendflag;
  42. if ($ordernos){
  43. $sql .= " AND orderno IN ".$ordernos;
  44. }
  45. if ($c_contact){
  46. $sql .= " AND c_contact like '".$c_contact."'";
  47. }
  48. if ($c_tel2){
  49. $sql .= " AND c_tel2 like '".$c_tel2."'";
  50. }
  51. if ($c_province){
  52. $sql .= " AND c_province like '".$c_province."'";
  53. }
  54. if ($c_city){
  55. $sql .= " AND c_city like '".$c_city."'";
  56. }
  57. if ($c_district){
  58. $sql .= " AND c_district like '".$c_district."'";
  59. }
  60. if ($releasestatus){
  61. $sql .= " AND releasestatus = '".$releasestatus."'";
  62. }
  63. if ($alternate_sku1){
  64. if ($request->checkAllSign) $detailsOrderno = $this->getOrdersNo($alternate_sku1,false);
  65. else $detailsOrderno = $this->getOrdersNo($alternate_sku1,true, $request->page ?? 1, $request->paginate ?? 50);
  66. if (count($detailsOrderno)>0){
  67. $sql.=' AND orderno IN (';
  68. foreach ($detailsOrderno as $index => $no){
  69. if ($index==0){
  70. $sql.="'".$no."'";
  71. continue;
  72. }
  73. $sql.=",'".$no."'";
  74. }
  75. $sql.=')';
  76. }else{
  77. $sql .= 'AND orderno IS NULL ';
  78. }
  79. }
  80. if ($orderdate_start && $orderdate_end && $addtime){
  81. $request->offsetUnset('orderdate_start');$request->offsetUnset('orderdate_end');
  82. $orderdate_start=null;
  83. $orderdate_end=null;
  84. }
  85. if ($orderdate_start){
  86. if (strlen($orderdate_start)<11)$orderdate_start .= ' 00:00';
  87. $sql.=" and addtime>='".$orderdate_start.":00'";
  88. }
  89. if ($orderdate_end){
  90. if (strlen($orderdate_end)<11)$orderdate_end .= ' 23:59 ';
  91. $sql.=" and addtime<='".$orderdate_end.":59' ";
  92. }
  93. if ($customerid){
  94. $arr = explode(',',$customerid);
  95. if (count($arr)>0) {
  96. $sql.=" and customerid in (";
  97. foreach ($arr as $index=>$str){
  98. if ($index==0){
  99. $sql.="'".$str."'";
  100. continue;
  101. }
  102. $sql.=",'".$str."'";
  103. }
  104. $sql.=")";
  105. }
  106. }
  107. if ($orderno)$sql.=" and orderno like '".$orderno."%'";
  108. if ($codename_c&&$codename_c_end)$sql.=" and sostatus between '".$codename_c."' and '".$codename_c_end."'";
  109. if ($codename_c&&!$codename_c_end)$sql.=" and sostatus = '".$codename_c."'";
  110. if (!$codename_c&&$codename_c_end)$sql.=" and sostatus = '".$codename_c_end."'";
  111. if ($carriername)$sql.=" and carriername like '".$carriername."%'";
  112. if ($soreference1){
  113. $arr=array_filter(preg_split('/[,, ]+/is', $soreference1));
  114. if (count($arr)==1){
  115. $sql.=" and soreference1 like '".$soreference1."%'";
  116. }
  117. if (count($arr)>1){
  118. $sql.=" and soreference1 in (";
  119. foreach ($arr as $index=>$str){
  120. if ($index==0){
  121. $sql.="'".$str."'";
  122. continue;
  123. }
  124. $sql.=",'".$str."'";
  125. }
  126. $sql.=")";
  127. }
  128. }
  129. if ($waveno)$sql.=" and WaveNo like '".$waveno."%'";
  130. if ($issuepartyname)$sql.=" and issuepartyname like '".$issuepartyname."%'";
  131. if ($notes){
  132. if ($addtime&&$addtime!=0)$sql.=" and addtime >= '".date('Y-m-d H:i:s',strtotime("-".$addtime." day"))."'";
  133. $sql.=" and notes like '%".$notes."%'";
  134. }else $request->offsetUnset('addtime');
  135. if ($soreference5){
  136. $arr=array_filter(preg_split('/[,, ]+/is', $soreference5));
  137. if (count($arr)>0){
  138. $sql.=" and (soreference5 in (";
  139. foreach ($arr as $index=>$str){
  140. if ($index==0){
  141. $sql.="'".$str."'";
  142. continue;
  143. }
  144. $sql.=",'".$str."'";
  145. }
  146. $sql.=") ";
  147. /*分箱号*/
  148. $oracleActAllocationDetails=DB::connection('oracle')->table('ACT_ALLOCATION_DETAILS')->whereIn('picktotraceid',$arr)->get();
  149. $picktotraceids=array_unique(array_column($oracleActAllocationDetails->toArray(),'orderno'));
  150. if (count($picktotraceids)>0){
  151. $sql.='OR orderno IN (';
  152. foreach ($picktotraceids as $index=>$str){
  153. if ($index==0){
  154. $sql.="'".$str."'";
  155. continue;
  156. }
  157. $sql.=",'".$str."'";
  158. }
  159. $sql.=") ";
  160. }
  161. $sql.=")";
  162. }
  163. }
  164. if ($edisendflag2){
  165. $sql.=" and edisendflag2 like '".$edisendflag2."%'";
  166. }
  167. if ($edisendflag){
  168. $sql.=" and edisendflag like '".$edisendflag."%'";
  169. }
  170. return $sql;
  171. }
  172. public function delivering(Request $request){
  173. if(!Gate::allows('订单管理-查询')){ return redirect(url('/')); }
  174. $paginate=$request->input('paginate')??50;
  175. $page=$request->input('page')??1;
  176. if ($request->alternate_sku1){
  177. $page = 1;$paginate=50;
  178. }
  179. if ($request->checktime_start || $request->checktime_end){
  180. $ordernos = app('oracleActAllocationDetailService')
  181. ->getOrderno(['checktime_start'=>$request->checktime_start,'checktime_end'=>$request->checktime_end,
  182. 'paginate'=>$request->paginate,'page'=>$request->page]);
  183. $request->offsetSet('ordernos',$ordernos);
  184. }
  185. $checkData=$request->input('data');
  186. $export=$request->input('checkAllSign');
  187. $sql="select ACT_ALLOCATION_DETAILS.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
  188. ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,DOC_ORDER_HEADER.EDIREMARKS2,
  189. DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
  190. ,DOC_ORDER_HEADER.soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
  191. DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
  192. ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime,DOC_Order_Details.CustomerID,
  193. DOC_Order_Details.SKU,DOC_Order_Details.QtyOrdered,DOC_Order_Details.LineStatus,DOC_Order_Details.OrderLineNo,order_code.codename_c as orderCodeName,
  194. order_detail_code.codename_c as orderDetailCodeName,BAS_Customer.descr_c as customer_descr_c,
  195. BAS_SKU.Alternate_SKU1,BAS_SKU.Descr_C,(select count(*) from DOC_ORDER_HEADER WHERE 1=1";
  196. $sql=$this->preciseQuery($request,$sql);
  197. ;$sql.=" ) as counted from (";
  198. if (!$export)$sql.=" select * from (";
  199. $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
  200. ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
  201. DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
  202. ,DOC_ORDER_HEADER.soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
  203. DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
  204. ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime,DOC_ORDER_HEADER.EDIREMARKS2 from (select * from DOC_ORDER_HEADER order by ADDTIME desc )DOC_ORDER_HEADER where 1=1 ";
  205. $sql=$this->preciseQuery($request,$sql);
  206. if ($checkData){
  207. $checkData=explode(',',$checkData);
  208. if (count($checkData)>0){
  209. $sql.=" and orderno in (";
  210. foreach ($checkData as $index=>$str){
  211. if ($index==0){
  212. $sql.="'".$str."'";
  213. continue;
  214. }
  215. $sql.=",'".$str."'";
  216. }
  217. $sql.=")";
  218. }
  219. }
  220. if (!$export)$sql.=" and ROWNUM<='".$page*$paginate."')";
  221. if (!$export)$sql.=" header where header.rn>'".($page-1)*$paginate."' ";
  222. $sql.=")DOC_ORDER_HEADER left join DOC_ORDER_DETAILS on DOC_ORDER_DETAILS.ORDERNO=DOC_ORDER_HEADER.ORDERNO
  223. left join BAS_CODES order_code on order_code.CODE=DOC_ORDER_HEADER.sostatus and order_code.codeid='SO_STS'
  224. left join BAS_CODES order_detail_code on order_detail_code.CODE=DOC_ORDER_DETAILS.linestatus and order_detail_code.codeid='SO_STS'
  225. left join BAS_Customer on BAS_Customer.customerid=DOC_ORDER_HEADER.customerid
  226. left join BAS_SKU on DOC_Order_Details.CustomerID=BAS_SKU.CustomerID and DOC_Order_Details.SKU=BAS_SKU.SKU
  227. left join ACT_ALLOCATION_DETAILS on DOC_Order_Details.orderno=ACT_ALLOCATION_DETAILS.orderno and
  228. DOC_Order_Details.orderlineno=ACT_ALLOCATION_DETAILS.orderlineno GROUP BY ACT_ALLOCATION_DETAILS.picktotraceid,
  229. ACT_ALLOCATION_DETAILS.CHECKTIME,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,
  230. DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,
  231. DOC_ORDER_HEADER.CustomerID,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
  232. DOC_ORDER_HEADER.EDIREMARKS2,DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1, DOC_ORDER_HEADER.soreference5,
  233. DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
  234. DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,
  235. DOC_ORDER_HEADER.OrderTime,DOC_Order_Details.CustomerID,DOC_Order_Details.SKU,DOC_Order_Details.QtyOrdered,
  236. DOC_Order_Details.LineStatus,DOC_Order_Details.OrderLineNo,order_code.codename_c,order_detail_code.codename_c,BAS_Customer.descr_c,
  237. BAS_SKU.Alternate_SKU1,BAS_SKU.Descr_C";
  238. //转导出
  239. if ($checkData || $export){
  240. $post = Http::post(config('go.export.url'),['type'=>'order','sql'=>$sql]);
  241. if ($post->status() == 500){
  242. throw new Exception($post->header("Msg"));
  243. }
  244. return response($post,200, [
  245. "Content-type"=>"application/octet-stream",
  246. "Content-Disposition"=>"attachment; filename=订单记录-".date('ymdHis').'.xlsx',
  247. ]);
  248. }
  249. $orders=DB::connection('oracle')->select(DB::raw($sql));
  250. $commodities=[];
  251. $picktotraceids=[];
  252. /*
  253. * 第二种扁平化方式(节省空间): 使用快慢指针,因拿到数据正常为顺序数据,自下标1开始与上一条对比orderno唯一标识,不同则更新慢指针下标,
  254. * 相同则为指定下标map类型数组追加一个键值对属性来记录同类数量,如N条,每次追加属性时先看属性是否存在,存在+1
  255. * */
  256. foreach ($orders as $index=>$order){
  257. if ($order->picktotraceid){
  258. if (array_key_exists($order->orderno,$picktotraceids)){
  259. if (!in_array($order->picktotraceid,$picktotraceids[$order->orderno],true)){
  260. array_push($picktotraceids[$order->orderno],$order->picktotraceid);
  261. };
  262. }else $picktotraceids[$order->orderno] = [$order->picktotraceid];
  263. }
  264. if (isset($commodities[$order->orderno])){
  265. array_push($commodities[$order->orderno],
  266. ["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,"descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered
  267. ,"checktime"=>$order->checktime,"orderdetailcodename"=>$order->orderdetailcodename]);
  268. unset($orders[$index]);
  269. continue;
  270. }
  271. $commodities[$order->orderno]=[["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,
  272. "descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered,"checktime"=>$order->checktime,"orderdetailcodename"=>$order->orderdetailcodename]];
  273. }
  274. $picktotraceids=json_encode($picktotraceids);
  275. $orders=array_values($orders);
  276. $orders = new Collection($orders);
  277. $commodities=new Collection($commodities);
  278. if ($checkData || $export)return $this->export($orders,$commodities);
  279. $customers=OracleBasCustomer::query()->select('customerid','descr_c')->where('customer_type','OW')->where('active_flag','Y')->get();
  280. $page = $request->page ?? 1;
  281. $request=$request->input();
  282. $codes=DB::connection('oracle')->table('BAS_CODES')->select('code','codename_c')->where('codeid','SO_STS')->orderBy('code','asc')->get();
  283. $orderIssueType = OrderIssueType::all();
  284. return view('order/index/delivering',compact('orders','customers','request','codes','commodities','page','picktotraceids','orderIssueType'));
  285. }
  286. //通过商品条码获取订单编号
  287. public function getOrdersNo($alternate_sku1, $isPaging = true, $page = 1, $paginate = 50){
  288. if ($isPaging){
  289. $sql = "SELECT RESULT.ORDERNO FROM
  290. (SELECT ROWNUM rn,DETAIL.ORDERNO as ORDERNO FROM
  291. (SELECT ORDERNO FROM DOC_ORDER_DETAILS WHERE SKU LIKE '".$alternate_sku1."' GROUP BY ORDERNO ORDER BY ORDERNO DESC)DETAIL
  292. WHERE ROWNUM<='".$page*$paginate."')RESULT
  293. WHERE RESULT.rn>'".($page-1)*$paginate."'";
  294. }else {
  295. $sql = "SELECT ORDERNO FROM DOC_ORDER_DETAILS WHERE SKU LIKE '".$alternate_sku1."' GROUP BY ORDERNO ORDER BY ORDERNO DESC";
  296. }
  297. $orderDetails = DB::connection('oracle')->select(DB::raw($sql));
  298. return array_column($orderDetails,'orderno');
  299. }
  300. //批量备注追加
  301. public function batchComments(Request $request){
  302. if(!Gate::allows('订单管理-批量备注')){ return redirect(url('/')); }
  303. $checkData=$request->input('checkData');
  304. $content=$request->input('content');
  305. $ordersNotNull=OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
  306. ->whereNotNull('notes')->get();
  307. OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
  308. ->whereNull('notes')->update(['notes'=>$content]);
  309. $ordersNotNullArr=array_column($ordersNotNull->toArray(),'orderno');
  310. $ordersNullArr=array_diff($checkData,$ordersNotNullArr);
  311. $data=[];
  312. foreach ($ordersNotNull as $order){
  313. OracleDOCOrderHeader::query()->where('orderno',$order->orderno)->update(["notes"=>($order->notes).",".$content]);
  314. $this->log(__METHOD__,'批量备注追加修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  315. $order->notes=($order->notes).",".$content;
  316. array_push($data,$order);
  317. }
  318. foreach ($ordersNullArr as $order){
  319. array_push($data,["orderno"=>$order,'notes'=>$content]);
  320. }
  321. return $data;
  322. }
  323. //批量冻结
  324. public function freezeAll(Request $request){
  325. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  326. $checkData=$request->input('checkData')??'';
  327. //冻结条件只局限于 分配完成sostatus=40 创建订单sostatus=00 拣货完成sostatus=60 播种完成sostatus=61
  328. $sostatus=['40','00','60','61'];
  329. $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
  330. if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可冻结订单"];
  331. foreach ($orders as $order){
  332. $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
  333. if ($waveno && $waveno!='*'){
  334. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
  335. $this->log(__METHOD__,'批量冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  336. }
  337. $is_freeze=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
  338. $this->log(__METHOD__,'批量冻结修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  339. if (!$is_freeze)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
  340. }
  341. return ['success'=>true];
  342. }
  343. //批量取消分配
  344. public function deAllocationAll(Request $request){
  345. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  346. $checkData=$request->input('checkData')??'';
  347. //取消分配条件只局限于 分配完成sostatus=40 和 部分分配sostatus=30
  348. $sostatus=['30','40'];
  349. $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
  350. if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可取消分配订单"];
  351. foreach ($orders as $order){
  352. $is_deAllocation=$this->isDeAllocation($order->orderno);
  353. $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
  354. if ($waveno && $waveno!='*'){
  355. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
  356. $this->log(__METHOD__,'批量取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  357. }
  358. $deAllocation=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['sostatus'=>'00','waveno'=>'*']);
  359. $this->log(__METHOD__,'批量取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  360. if (!$is_deAllocation||!$deAllocation)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
  361. }
  362. return ['success'=>true];
  363. }
  364. //冻结
  365. public function freeze(Request $request){
  366. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  367. $orderno=$request->input('orderno');
  368. $waveno=$request->input('waveno');
  369. if ($waveno && $waveno!='*'){
  370. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
  371. $this->log(__METHOD__,'冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  372. }
  373. OracleDOCOrderHeader::where('orderno',$orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
  374. $this->log(__METHOD__,'冻结'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  375. return ['success'=>true];
  376. }
  377. public function thaw(Request $request){
  378. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  379. $orderno = $request->orderno;
  380. if (!is_array($orderno)) {
  381. $orderno = [$orderno];
  382. }
  383. OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->update(['releasestatus'=>'N']);
  384. $this->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  385. return ['success'=>true];
  386. }
  387. //重置快递获取标记
  388. public function resetLogisticsGetMark(Request $request){
  389. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  390. $orderno=$request->orderno;
  391. OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->where('edisendflag2','W')->update(['edisendflag2'=>'N']);
  392. $this->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
  393. return ['success'=>true];
  394. }
  395. function export($orders,$commodities){
  396. if(!Gate::allows('订单管理')){ return redirect(url('/')); }
  397. ini_set('max_execution_time',3500);
  398. ini_set('memory_limit','3526M');
  399. $row=[[
  400. 'orderno'=>'编号',
  401. 'sostatus'=>'订单状态',
  402. 'notes'=>'备注',
  403. 'addtime'=>'接口下发时间',
  404. 'issuepartyname'=>'店铺名称',
  405. 'oracleBASCustomer_descr_c'=>'客户',
  406. 'soreference1'=>'客户订单号',
  407. 'carriername'=>'承运人',
  408. 'soreference5'=>'快递单号',
  409. 'c_contact'=>'收货人名称',
  410. 'c_tel2'=>'收货人电话',
  411. 'c_province'=>'省',
  412. 'c_city'=>'市',
  413. 'c_district'=>'区',
  414. 'c_address1'=>'收货人地址',
  415. 'waveno'=>'波次编号',
  416. 'warehouseid'=>'仓库',
  417. 'edisendflag2'=>'快递获取标记',
  418. 'edisendtime2'=>'快递获取时间',
  419. 'sku'=>'产品代码',
  420. 'alternate_sku1'=>'产品条码',
  421. 'orderdetailcodename'=>'明细状态',
  422. 'descr_c'=>'产品名称',
  423. 'qtyordered'=>'订单数量',
  424. 'checktime'=>'复核时间',
  425. 'erpcancelflag'=>'接口取消标记',
  426. 'picking_print_flag'=>'拣货单打印标记',
  427. 'edisendflag'=>'接口回传标记',
  428. 'ediremarks2'=>'接口回传异常备注',
  429. 'releasestatus'=>'订单冻结',
  430. ]];
  431. $list=[];
  432. $sign=[];
  433. $mergeCell=[];
  434. foreach ($orders as $order){
  435. $data=[
  436. 'orderno'=>$order->orderno,
  437. 'addtime'=>$order->addtime,
  438. 'sostatus'=>$order->ordercodename,
  439. 'warehouseid'=>$order->warehouseid,
  440. 'oracleBASCustomer_descr_c'=>$order->customer_descr_c,
  441. 'c_contact'=>$order->c_contact,
  442. 'c_tel2'=>$order->c_tel2,
  443. 'c_province'=>$order->c_province,
  444. 'c_city'=>$order->c_city,
  445. 'c_district'=>$order->c_district,
  446. 'carriername'=>$order->carriername,
  447. 'issuepartyname'=>$order->issuepartyname,
  448. 'waveno'=>$order->waveno,
  449. 'soreference1'=>$order->soreference1,
  450. 'soreference5'=>$order->soreference5,
  451. 'edisendflag2'=>$order->edisendflag2,
  452. 'edisendtime2'=>$order->edisendtime2,
  453. 'notes'=>$order->notes,
  454. 'erpcancelflag'=>$order->erpcancelflag,
  455. 'ediremarks2'=>$order->ediremarks2,
  456. 'picking_print_flag'=>$order->picking_print_flag,
  457. 'edisendflag'=>$order->edisendflag,
  458. 'releasestatus'=>$order->releasestatus,
  459. 'c_address1'=>$order->c_address1,
  460. ];
  461. if (count($commodities[$order->orderno])<1){
  462. $data['sku']='';
  463. $data['alternate_sku1']='';
  464. $data['descr_c']='';
  465. $data['qtyordered']='';
  466. $data['checktime']='';
  467. $data['orderdetailcodename']='';
  468. array_push($list,$data);
  469. continue;
  470. }
  471. foreach ($commodities[$order->orderno] as $oracleDOCOrderDetail){
  472. $data['sku']=$oracleDOCOrderDetail['sku'];
  473. $data['alternate_sku1']=$oracleDOCOrderDetail['alternate_sku1'];
  474. $data['descr_c']=$oracleDOCOrderDetail['descr_c'];
  475. $data['qtyordered']=$oracleDOCOrderDetail['qtyordered'];
  476. $data['checktime']=$oracleDOCOrderDetail['checktime'];
  477. $data['orderdetailcodename']=$oracleDOCOrderDetail['orderdetailcodename'];
  478. if (isset($sign[$order->orderno])){
  479. $data['orderno']='';$data['sostatus']='';$data['warehouseid']='';$data['oracleBASCustomer_descr_c']='';$data['c_contact']='';$data['addtime']='';
  480. $data['c_tel2']='';$data['carriername']='';$data['issuepartyname']='';$data['waveno']='';$data['soreference1']='';$data['soreference5']='';
  481. $data['edisendflag2']='';$data['edisendtime2']='';$data['notes']='';$data['erpcancelflag']='';$data['picking_print_flag']='';$data['edisendflag']='';
  482. $data['releasestatus']='';$data['c_address1']='';$data['c_province']='';$data['c_city']='';$data['c_district']='';
  483. array_push($list,$data);
  484. continue;
  485. }
  486. array_push($list,$data);
  487. $sign[$order->orderno]=count($list)+1;
  488. }
  489. if (count($commodities[$order->orderno])>1){
  490. $mergeCell[$sign[$order->orderno]]=$sign[$order->orderno]+(count($commodities[$order->orderno])-1);
  491. }
  492. }
  493. $columnName=["A","B","C","D","E","F","G","H","I","J","K","L","M","N","O","P","Q","R","S","X","Y","Z","AA"];
  494. return Excel::download(new Export($row,$list,$mergeCell,$columnName),date('YmdHis', time()).'-出库发运单.xlsx');
  495. }
  496. //取消分配
  497. public function deAllocation(Request $request){
  498. if(!Gate::allows('订单管理-编辑')){ return redirect(url('/')); }
  499. $orderno=$request->input('orderno');
  500. $waveno=$request->input('waveno');
  501. if ($waveno && $waveno!='*'){
  502. OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
  503. $this->log(__METHOD__,'取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  504. }
  505. OracleDOCOrderHeader::where('orderno',$orderno)->update(['sostatus'=>'00','waveno'=>'*']);
  506. $this->log(__METHOD__,'取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
  507. $is_deAllocation=$this->isDeAllocation($orderno);
  508. if($is_deAllocation) return ['success'=>true];
  509. }
  510. //调用sp取消选中订单的分配
  511. public function isDeAllocation($orderno){
  512. $username=config('database.connections.oracle.username');
  513. $password=config('database.connections.oracle.password');
  514. $host=config('database.connections.oracle.host');
  515. $service_name=config('database.connections.oracle.service_name');
  516. $conn=oci_connect($username,$password,$host.'/'.$service_name); //连接oracle数据库
  517. $IN_Warehouse='';
  518. $IN_Process_Action_C='' ;
  519. $IN_Process_By_C='By OrderNO';
  520. $IN_WaveNO_C='';
  521. $IN_OrderNO_C=$orderno;
  522. $IN_OrderLineNO_C='';
  523. $IN_AllocationDetailsID='';
  524. $IN_Language='';
  525. $IN_UserID='';
  526. $OUT_Return_Code='';
  527. $sql_sp="begin SPSO_DEALLOCATION_PROCESS(:IN_Warehouse,:IN_Process_Action_C,:IN_Process_By_C,
  528. :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
  529. $stmt = oci_parse($conn, $sql_sp);
  530. oci_bind_by_name($stmt,':IN_Warehouse',$IN_Process_Action_C);
  531. oci_bind_by_name($stmt,':IN_Process_Action_C',$IN_Warehouse);
  532. oci_bind_by_name($stmt,':IN_Process_By_C',$IN_Process_By_C);
  533. oci_bind_by_name($stmt,':IN_WaveNO_C',$IN_WaveNO_C);
  534. oci_bind_by_name($stmt,':IN_OrderNO_C',$IN_OrderNO_C);
  535. oci_bind_by_name($stmt,':IN_OrderLineNO_C',$IN_OrderLineNO_C);
  536. oci_bind_by_name($stmt,':IN_AllocationDetailsID',$IN_AllocationDetailsID);
  537. oci_bind_by_name($stmt,':IN_Language',$IN_Language);
  538. oci_bind_by_name($stmt,':IN_UserID',$IN_UserID);
  539. oci_bind_by_name($stmt,':OUT_Return_Code',$OUT_Return_Code);
  540. $this->log(__METHOD__,'调用sp根据订单取消分配'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
  541. return oci_execute($stmt);
  542. }
  543. }