OrderTrackingService.php 26 KB

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