OrderTrackingService.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572
  1. <?php
  2. namespace App\Services;
  3. use App\Exports\Export;
  4. use App\OracleBasSKU;
  5. use App\OracleDOCOrderHeader;
  6. use App\Order;
  7. use App\OrderPackageCommodities;
  8. use App\OrderTracking;
  9. use App\Services\common\BatchUpdateService;
  10. use App\Services\common\DataHandlerService;
  11. use App\Services\common\QueryService;
  12. use Illuminate\Support\Carbon;
  13. use Illuminate\Support\Collection;
  14. use Illuminate\Support\Facades\Auth;
  15. class OrderTrackingService
  16. {
  17. public function insert($params){
  18. return OrderTracking::query()->insert($params);
  19. }
  20. public function batchUpdate($params){
  21. return app(BatchUpdateService::class)->batchUpdate('order_trackings',$params);
  22. }
  23. public function getQuery($params)
  24. {
  25. $user = Auth::user();
  26. $owner_ids = $user ? app('UserService')->getPermittingOwnerIds($user) : [];
  27. if ($params['owner_id'] ?? false) {
  28. $ownerids = explode(",", $params['owner_id']);
  29. $owner_ids = array_intersect($owner_ids, $ownerids);
  30. }
  31. $query = OrderTracking::query()->with(['logistic','owner','uploadFile', 'commodities' => function ($query) {
  32. $query->with(['commodity'=>function($query){
  33. $query->with('barcodes');
  34. }, 'package.order']);
  35. },])->whereHas('owner', function ($query) use ($owner_ids) {
  36. $query->whereIn('id', $owner_ids); //货主
  37. });
  38. $queryParam = [
  39. 'start_at' => ['alias' => 'pick_up_at', 'startDate' => ' 00:00:00'],
  40. 'end_at' => ['alias' => 'pick_up_at', 'endDate' => ' 23:59:59'],
  41. 'start_planning_sent_at' => ['alias' => 'planning_sent_at', 'startDate' => ' 00:00:00'],
  42. 'end_planning_sent_at' => ['alias' => 'planning_sent_at', 'endDate' => ' 23:59:59'],
  43. ];
  44. $param = [
  45. 'start_at' => $params['start_at'] ?? '',
  46. 'end_at' => $params['end_at'] ?? '',
  47. 'start_planning_sent_at' => $params['start_planning_sent_at'] ?? '',
  48. 'end_planning_sent_at' => $params['end_planning_sent_at'] ?? '',
  49. ];
  50. $query = app(QueryService::class)->query($param, $query, $queryParam);
  51. return $query;
  52. }
  53. public function getConditionQuery($params)
  54. {
  55. $query = $this->getQuery($params);
  56. if (isset($params['client_code'])|| isset($params['logistic_id'])){ // client_code logistic
  57. $query->whereHas('commodities.package.order', function ($query) use ($params) {
  58. if($params['client_code'] ?? false){
  59. $query->where('client_code','like', $params['client_code']);
  60. }
  61. });
  62. }
  63. if(isset($params['logistic_id']))$query->where('logistic_id',$params['logistic_id']); // 快递
  64. if ($params['client'] ?? false) $query->where('client', 'like', $params['client']); // 客户
  65. if(!empty($params['web_order_number'])) $query->where('web_order_number', 'like', $params['web_order_number'].'%'); // web+订单好
  66. if ($params['sku'] ?? false) {
  67. $query->whereHas('commodities.commodity', function ($query) use ($params) {
  68. $query->where('sku', $params['sku']);
  69. });
  70. } // sku
  71. if ($params['logistic_number'] ?? false) {
  72. $query->whereHas('commodities.package', function ($query) use ($params) {
  73. $query->where('logistic_number', $params['logistic_number']);
  74. });
  75. }// 运输单号(快递单号)
  76. if(isset($params['remark'])){
  77. $query->where('remark','like','%'.$params['remark'].'%');
  78. if(isset($params['remark_addtime'])){
  79. $query->where('created_at','>',Carbon::now()->subDays($params['remark_addtime']));
  80. }else{
  81. $query->where('created_at','>=',Carbon::now()->subDays(15));
  82. }
  83. }
  84. if ($params['ids'] ?? false) {
  85. $ids = explode(',', $params['ids']);
  86. $query->whereIn('order_trackings.id', $ids);
  87. }
  88. return $query;
  89. }
  90. public function paginate($params)
  91. {
  92. return $this->getConditionQuery($params)
  93. ->orderByDesc('order_trackings.pick_up_at')
  94. ->orderBy('order_trackings.order_client_code')
  95. ->paginate($params['paginate'] ?? 50);
  96. }
  97. public function getSql($params)
  98. {
  99. if($params['data'] ?? false){
  100. $params['ids'] = $params['data'];
  101. }
  102. $order_tracking_colnums = "case order_trackings.order_client_code when order_trackings.web_order_number then '' when order_trackings.order_client_code then order_trackings.order_client_code end order_client_code,";
  103. $order_tracking_colnums .= 'order_trackings.web_order_number,order_trackings.pick_up_at,order_trackings.sale,order_trackings.client,order_trackings.order_remark,order_trackings.gross_weight,order_trackings.bulk,';
  104. $order_tracking_colnums .= "case order_trackings.planning_sent_at when '0000-00-00 00:00:00' then null else order_trackings.planning_sent_at end planning_sent_at,";
  105. $order_tracking_colnums .= 'order_trackings.pallet_total,order_trackings.is_on_duty_shift,order_trackings.is_arrival,order_trackings.signed_at,order_trackings.receive_bill_status,order_trackings.remark';
  106. return $this->getConditionQuery($params)
  107. ->orderBy('order_trackings.order_client_code')
  108. ->orderByDesc('order_trackings.pick_up_at')
  109. ->selectRaw($order_tracking_colnums)
  110. ->leftJoin('order_package_commodities','order_trackings.order_package_commodity_id','order_package_commodities.id')
  111. ->selectRaw('order_package_commodities.amount amount')
  112. ->leftJoin('order_packages','order_package_commodities.order_package_id','order_packages.id')
  113. ->selectRaw('order_packages.logistic_number logistic_number')
  114. ->leftJoin('orders','order_packages.order_id','orders.id')
  115. ->selectRaw('orders.city city')
  116. ->leftJoin('logistics','orders.logistic_id','logistics.id')
  117. ->selectRaw("case logistics.code when 'ZT' then '新杰物流' else logistics.name end logistic_name")
  118. ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
  119. ->selectRaw('commodities.sku sku,commodities.name sku_name')
  120. ->leftJoin('owners','orders.owner_id','owners.id')
  121. ->selectRaw('owners.name owners_name')
  122. ->sql();
  123. }
  124. public function getOrderTrackings($params)
  125. {
  126. if($params['data'] ?? false){
  127. $params['ids'] = $params['data'];
  128. }
  129. return $this->getConditionQuery($params)
  130. ->orderByDesc('order_trackings.pick_up_at')->orderBy('order_trackings.order_client_code')->get();
  131. }
  132. /**
  133. * @param $startData
  134. */
  135. public function trackingWmsOrder($startData){
  136. $this->trackingWmsOrderOnCreate($startData);
  137. $this->trackingWmsOrderOnEdit($startData);
  138. }
  139. public function trackingWmsOrderOnCreate($startData){
  140. /** @var OrderService $orderSerivce */
  141. $orderService = app(OrderService::class);
  142. /** @var Collection $orderHeaders */
  143. $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateCreate($startData);
  144. // $this->customizedOperation($orderHeaders);
  145. $orderService->createByWmsOrder($orderHeaders);
  146. $this->createByWmsOrderHeader($orderHeaders);
  147. }
  148. public function trackingWmsOrderOnEdit($startData){
  149. /** @var OrderService $orderService */
  150. $orderService = app(OrderService::class);
  151. /** @var Collection $orderHeaders */
  152. $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateEdit($startData);
  153. // $this->customizedOperation($orderHeaders);
  154. $orderService->updateByWmsOrders($orderHeaders);
  155. $this->updateByWmsOrderHeaders($orderHeaders);
  156. }
  157. public function updateOrderTracingAndSyc($id,$param,$value){
  158. $order_tracking = OrderTracking::query()->with('commodities.package.order')->where('id', $id)->first();
  159. $order_id = $order_tracking->commodities->package->order->id ?? false;
  160. if(!isset($order_id)){ return ['success'=> false];}
  161. return $this->updateOrderTracingsByOrderIds($order_id,$param,$value);
  162. }
  163. /**
  164. * @param Collection $orderHeaders
  165. */
  166. public function customizedOperation(&$orderHeaders) // 对追踪件的特定操作
  167. {
  168. $orderHeaders->each(function ($orderHeader) {
  169. if($orderHeader->userdefine1 ==='ZT'){
  170. $orderHeader->userdefine1 = 'XJWL';
  171. }
  172. });
  173. }
  174. public function updateOrderTracingsByOrderIds($orderId,$param,$value)
  175. {
  176. $bool = null;
  177. try {
  178. $update = [$param => $value];
  179. if($param == 'planning_sent_at'){
  180. $update= [$param => $value, 'signed_at' => $value];
  181. }
  182. $bool = OrderTracking::query()->whereHas('commodities.package.order', function ($query) use ($orderId) {
  183. $query->where('id', $orderId);
  184. })->update($update);
  185. return['success'=> $bool > 0];
  186. } catch (\Exception $e) {
  187. app('LogService')->log(__METHOD__,__FUNCTION__,'修改追踪件'.json_encode($orderId,$param,$value).json_encode($e->getMessage()).json_encode($e->getTraceAsString()));
  188. return['success'=> false,'fail_info'=>$e->getMessage()];
  189. }
  190. }
  191. public function createByWmsOrderHeader($orderHeaders)
  192. {
  193. if(!$orderHeaders){return;}
  194. /** @var DataHandlerService $dataService */
  195. $dataService = app(DataHandlerService::class);
  196. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  197. $owner_id_map = $basSKUs_data = $dataService->dataHeader(['id'],$owners);
  198. $BasSKUs = app(OracleBasSkuService::class)->获取BasSKu_通过WMSOrderHeaders($orderHeaders);
  199. $BasSKUs_code_sku_map = $dataService->dataHeader(['customerid','sku'],$BasSKUs);
  200. $order_nos = data_get($orderHeaders,'*.orderno');
  201. $order_package_commodities = OrderPackageCommodities::query()->with(['package.order','commodity'])
  202. ->whereIn('order_package_id',function($query)use($order_nos){
  203. $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($order_nos){
  204. $query->from('orders')->select('id')->whereIn('code',$order_nos);
  205. });
  206. })
  207. ->get();
  208. $order_package_commodities_ids = data_get($order_package_commodities,'*.id');
  209. $order_trackings = OrderTracking::query()->whereIn('order_package_commodity_id',$order_package_commodities_ids)->get();
  210. $is_exist_ids = data_get($order_trackings,'*.order_package_commodity_id');
  211. $order_package_commodities = $order_package_commodities->filter(function($item) use ($is_exist_ids){
  212. $id = $item->id;
  213. return !in_array($id,$is_exist_ids);
  214. });
  215. if($order_package_commodities->count() == 0){return ;}
  216. $order_headers_map = [];
  217. foreach ($orderHeaders as $item) {
  218. $order_headers_map[$item->orderno] = $item;
  219. }
  220. $params = [];
  221. foreach ($order_package_commodities as $item) {
  222. $order = $item->package->order;
  223. if(!$order){continue ;}
  224. $order_header = $order_headers_map[$order->code];
  225. if(!$order_header){continue ;}
  226. if($order_header->sostatus == 90){continue;}
  227. $web_order_number = null;
  228. if(preg_match('/^O[\d]/',$order_header['soreference1'] ?? '') > 0){
  229. $web_order_number = $order_header['soreference1'];
  230. }
  231. $param = $this->getParamsByOrderHeaderAndOrder($order_header,$order);
  232. $owner = $dataService->getKeyValue(['id'=>$order->owner_id],$owner_id_map);
  233. $basSkU = $dataService->getKeyValue(['customerid'=>$owner->code,'sku'=>$item->commodity->sku],$BasSKUs_code_sku_map);
  234. $gross_weight = round($basSkU->grossweight * $item->amount, 2);
  235. $bulk = round($basSkU->cube * $item->amount, 2);
  236. $order_client_code = $order->client_code;
  237. if($param['client']=='天猫'){
  238. $order_client_code = $this->get_d_edit_03($order_header,$item) ;
  239. }
  240. $params[] =[
  241. 'order_package_commodity_id' => $item->id,
  242. 'owner_id' => $order->owner_id,
  243. 'order_client_code' =>$order_client_code,
  244. 'sale' => $param['sale'],
  245. 'client' => $param['client'],
  246. 'created_at' => $order->created_at,
  247. 'order_remark' => $param['order_remark'],
  248. 'pick_up_at' => $order_header->lastshipmenttime, // 提货时间,
  249. 'web_order_number' => $web_order_number,
  250. 'gross_weight'=> $gross_weight,
  251. 'bulk'=> $bulk,
  252. 'is_on_duty_shift'=> $param['is_on_duty_shift'],
  253. 'planning_sent_at' => $param['planning_sent_at'] ?? ''
  254. ];
  255. }
  256. try {
  257. if (count($params) > 0) {
  258. $this->insert($params);
  259. app('LogService')->log(__METHOD__, __FUNCTION__, '批量添加 orderTracking' . json_encode($params),null);
  260. }
  261. } catch (\Exception $e) {
  262. app('LogService')->log(__METHOD__, __FUNCTION__, '批量添加 orderTracking error' . json_encode($params).$e->getMessage().$e->getTraceAsString(),null);
  263. }
  264. }
  265. public function get_d_edit_03($orderHeader,$orderPackageCommodity){
  266. $sku_line_no = null;
  267. foreach ($orderHeader->actAllocationDetails as $actAllocationDetail) {
  268. if($actAllocationDetail->picktotraceid == $orderPackageCommodity->package->logistic_number
  269. && $orderPackageCommodity->commodity->sku == $actAllocationDetail->sku){
  270. $sku_line_no = $actAllocationDetail->skulineno;
  271. break;
  272. }
  273. }
  274. if($sku_line_no==null)return null;
  275. foreach ($orderHeader->oracleDOCOrderDetails as $oracleDOCOrderDetail) {
  276. if($oracleDOCOrderDetail->orderlineno == $sku_line_no) {
  277. return $oracleDOCOrderDetail['d_edi_03'];
  278. }
  279. }
  280. return null;
  281. }
  282. public function updateByWmsOrderHeaders($orderHeaders)
  283. {
  284. if(!$orderHeaders){return ;}
  285. /** @var DataHandlerService $dataService */
  286. $dataService = app(DataHandlerService::class);
  287. $order_nos = data_get($orderHeaders,'*.orderno');
  288. $order_package_commodities = OrderPackageCommodities::query()
  289. ->with(['package.order','commodity'])
  290. ->whereIn('order_package_id',function($query)use($order_nos){
  291. $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($order_nos){
  292. $query->from('orders')->select('id')->whereIn('code',$order_nos);
  293. });
  294. })->get();
  295. $orderTrackings = OrderTracking::query()->whereIn('order_package_commodity_id',data_get($order_package_commodities,'*.id'))->get();
  296. $order_tracking_id_map = [];
  297. foreach ($orderTrackings as $orderTracking) {
  298. $order_tracking_id_map[$orderTracking->order_package_commodity_id] = $orderTracking;
  299. }
  300. $order_package_commodity_order_code_map = [];
  301. $order_code_map = [];
  302. foreach ($order_package_commodities as $order_package_commodity) {
  303. $order =$order_package_commodity->package->order;
  304. if(!$order){continue;}
  305. $order_code_map[$order->code] = $order;
  306. $order_package_commodity_order_code_map[$order->code][] = $order_package_commodity;
  307. }
  308. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  309. $owner_code_map = $basSKUs_data = $dataService->dataHeader(['code'],$owners);
  310. $BasSKUs = app(OracleBasSkuService::class)->获取BasSKu_通过WMSOrderHeaders($orderHeaders);
  311. $BasSKUs_code_sku_map = $dataService->dataHeader(['customerid','sku'],$BasSKUs);
  312. $update_params = [];
  313. $update_params[0] =['id','client','pick_up_at','order_remark','gross_weight','bulk','planning_sent_at'];
  314. foreach ($orderHeaders as $orderHeader) {
  315. if($orderHeader->sostatus == '90'){continue;}
  316. $order_package_commodity_list = $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
  317. if(!$order_package_commodity_list){continue;}
  318. $order = $order_code_map[$orderHeader->orderno];
  319. foreach ($order_package_commodity_list as $order_package_commodity) {
  320. $order_tracking = $order_tracking_id_map[$order_package_commodity->id]??false;
  321. if(!$order_tracking){continue;}
  322. $params = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
  323. $owner = $dataService->getKeyValue(['code'=>$orderHeader->customerid],$owner_code_map);
  324. $basSku = $dataService->getKeyValue(['customerid'=>$owner->code,'sku'=>$order_package_commodity->commodity->sku],$BasSKUs_code_sku_map);
  325. $gross_weight = round($basSku->grossweight * $order_package_commodity->amount,2) ;
  326. $bulk = round($basSku->cube * $order_package_commodity->amount,2) ;
  327. if($order_tracking->owner_id != $params['owner_id'] ||
  328. $order_tracking->client !=$params['client'] ||
  329. $order_tracking->order_remark != $params['order_remark'] ||
  330. $order_tracking->pick_up_at != $params['pick_up_at'] ||
  331. $order_tracking->gross_weight != $gross_weight ||
  332. $order_tracking->bulk != $bulk){
  333. $update_params[] = [
  334. 'id' => $order_tracking->id,
  335. 'client' => $params['client'],
  336. 'pick_up_at' => $params['pick_up_at'],
  337. 'order_remark' => $params['order_remark'],
  338. 'web_order_number' => $params['web_order_number'],
  339. 'gross_weight' => $gross_weight,
  340. 'bulk' => $bulk,
  341. 'planning_sent_at' => $params['planning_sent_at']
  342. ];
  343. }
  344. }
  345. }
  346. if(count($update_params) > 1){
  347. $this->batchUpdate($update_params);
  348. }
  349. $insert_params = [];
  350. foreach ($orderHeaders as $orderHeader) {
  351. $order_package_commodity_list= $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
  352. if(!$order_package_commodity_list)continue;
  353. foreach ($order_package_commodity_list as $item) {
  354. $order_tracking = $order_tracking_id_map[$item->id] ?? false;
  355. if(!$order_tracking){
  356. $order = $order_code_map[$orderHeader->orderno] ?? false;
  357. if(!$order) continue;
  358. $basSkU = $dataService->getKeyValue(['customerid'=>$orderHeader->customerid,'sku'=>$item->commodity->sku],$BasSKUs_code_sku_map);
  359. $gross_weight = round($basSkU->grossweight * $item->amount, 2);
  360. $bulk = round($basSkU->cube * $item->amount, 2);
  361. $param = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
  362. $param['order_package_commodity_id'] =$item->id;
  363. $param['order_client_code'] = $order->client_code;
  364. $param['gross_weight'] = $gross_weight;
  365. $param['bulk'] = $bulk;
  366. $insert_params[] =$param;
  367. }
  368. }
  369. }
  370. if(count($insert_params) > 0){
  371. try {
  372. $this->insert($insert_params);
  373. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking '.count($insert_params).json_encode($insert_params));
  374. } catch (\Exception $e) {
  375. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking error'.json_encode($insert_params) .'||'.$e->getMessage(),'||'.$e->getTraceAsString());
  376. }
  377. }
  378. $this->删除订单追踪_订单取消($orderHeaders);
  379. }
  380. /**
  381. * @param OracleDOCOrderHeader $orderHeader
  382. * @param Order $order
  383. * @return array
  384. */
  385. public function getParamsByOrderHeaderAndOrder($orderHeader,$order)
  386. {
  387. /** @var LogisticService $logisticService */
  388. $logisticService = app('LogisticService');
  389. $client = $orderHeader['issuepartyname'] ?? '';
  390. $order_remark = $orderHeader['notes'] ?? '';
  391. $web_order_number = null;
  392. if(preg_match('/^O[\d]/',$orderHeader['soreference1'] ?? '') > 0){
  393. $web_order_number = $orderHeader['soreference1'];
  394. }
  395. $pick_up_at = $orderHeader->lastshipmenttime;
  396. $planning_sent_at = null;
  397. // 快递方式
  398. $logistic = $logisticService->getLogisticByCode($orderHeader['userdefine1']);
  399. if($orderHeader['userdefine1'] =='自提') $logistic = $logisticService->getLogisticByCode('XJWL'); // 自提转新杰物流
  400. if(isset($pick_up_at)){
  401. $logisticTiming = app(LogisticTimingService::class)->findByParams($orderHeader['c_city']??'',$orderHeader['c_province']??'',$logistic['id']);
  402. if($logisticTiming)$planning_sent_at = Carbon::parse((string)$pick_up_at)->addDays($logisticTiming->days_at_working); // 预期到货时间
  403. }
  404. if(stristr($order_remark,'[')){
  405. $items = [];
  406. preg_match_all('/^(.*?)(\\[)(.*?)(\\])(.*?)$/u',$order_remark,$items);
  407. $client = $items[1][0];
  408. $order_remark = $items[3][0];
  409. }
  410. if(mb_strpos($client,'天猫')!=false)$client='天猫';
  411. if(mb_strpos($client,'京东')!=false)$client='京东';
  412. return [
  413. 'owner_id' => $order->owner_id,
  414. 'logistic_id' => $logistic['id'],
  415. 'client' => $client,
  416. 'sale' => $orderHeader['issuepartyname'] ?? '',
  417. 'created_at' => $order->created_at,
  418. 'order_remark' => $order_remark,
  419. 'pick_up_at' => $orderHeader['lastshipmenttime'] ?? '', // 提货时间
  420. 'web_order_number' =>$web_order_number,
  421. 'is_on_duty_shift'=>$planning_sent_at?'是':null,
  422. 'planning_sent_at' => (string)$planning_sent_at
  423. ];
  424. }
  425. /**
  426. * @param Collection $orderHeaders
  427. */
  428. public function 删除订单追踪_订单取消($orderHeaders)
  429. {
  430. $cancelledOrderHeaders = $orderHeaders->where('sostatus','90');
  431. $orderTracking = $this->getOrderTracingByWmsOrder($cancelledOrderHeaders);
  432. $this->deleteOrderTracings($orderTracking);
  433. }
  434. /**
  435. * @param Collection $orderHeaders
  436. * @return \Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|Collection|\Tightenco\Collect\Support\Collection
  437. */
  438. public function getOrderTracingByWmsOrder($orderHeaders)
  439. {
  440. if($orderHeaders->count() == 0){return collect();}
  441. $orderNos = data_get($orderHeaders,'*.orderno');
  442. return OrderPackageCommodities::query()
  443. ->with('commodities.package.order')
  444. ->whereIn('order_package_commodity_id',function($query)use($orderNos){
  445. $query->from('order_package_commodities')->select('id')->whereIn('order_package_id',function($query)use($orderNos) {
  446. $query->from('order_packages')->select('id')->whereIn('order_id', function ($query) use ($orderNos) {
  447. $query->from('orders')->select('id')->whereIn('code', $orderNos);
  448. });
  449. });
  450. })->get();
  451. }
  452. /**
  453. * @param Collection $orderTracking
  454. */
  455. public function deleteOrderTracings($orderTracking)
  456. {
  457. if($orderTracking->count() == 0){return;}
  458. try {
  459. OrderTracking::query()->whereIn('id', data_get($orderTracking,'*.id'))->delete();
  460. app('LogService')->log(__METHOD__,__FUNCTION__,'删除订单取消的OrderTracking '.$orderTracking->count().json_encode($orderTracking),null);
  461. } catch (\Exception $e) {
  462. app('LogService')->log(__METHOD__,__FUNCTION__,'删除订单取消的OrderTracking error'.$orderTracking->count().json_encode($orderTracking).$e->getMessage().$e->getTraceAsString(),null);
  463. }
  464. }
  465. /**
  466. * @param OracleBasSKU $basSkU
  467. * @param OrderPackageCommodities $orderPackageCommodity
  468. * @return array
  469. */
  470. public function getGrossWeightAndBulk($basSkU,$orderPackageCommodity)
  471. {
  472. return [
  473. 'gross_weight' =>round($basSkU->grossweight * $orderPackageCommodity->amount, 2),
  474. 'bulk' =>round($basSkU->cube * $orderPackageCommodity->amount, 2),
  475. ];
  476. }
  477. public function fillInOrderTracking($orderTracking = null)
  478. {
  479. $orderTrackingIds = [];
  480. try {
  481. $date = new Carbon();
  482. if($orderTracking==null){
  483. $orderTracking = OrderTracking::query()
  484. ->where('created_at', '!=', '0000-00-00 00:00:00')
  485. ->where('planning_sent_at', '!=', '0000-00-00 00:00:00')
  486. ->whereNull('signed_at')
  487. ->where('planning_sent_at','<',$date)
  488. ->get();
  489. }
  490. if(count($orderTracking)==0)return;
  491. $update_params = [['id','signed_at']];
  492. $orderTracking = $orderTracking->where('created_at', '!=', '0000-00-00 00:00:00')
  493. ->where('planning_sent_at', '!=', '0000-00-00 00:00:00')
  494. ->whereNull('signed_at')
  495. ->where('planning_sent_at','<',$date);
  496. $orderTracking->each(function($item)use(&$update_params){
  497. $update_params[] = [
  498. 'id' => $item->id,
  499. 'signed_at' => $item->planning_sent_at
  500. ];
  501. });
  502. if(count($update_params) > 0) $this->batchUpdate($update_params);
  503. $orderTrackingIds = data_get($orderTracking, '*.id');
  504. OrderTracking::query()->whereIn('id', $orderTrackingIds)
  505. ->whereNull('is_on_duty_shift')
  506. ->whereNull('is_arrival')
  507. ->update(['is_on_duty_shift' => '是', 'is_arrival' => '是']);
  508. app('LogService')->log(__METHOD__,__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况'.json_encode($orderTrackingIds));
  509. } catch (\Exception $e) {
  510. app('LogService')->log(__METHOD__,'ERROR '.__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况 ERROR'.json_encode($orderTrackingIds).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
  511. }
  512. }
  513. }