OrderTrackingService.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558
  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. $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateCreate($startData);
  141. app(OrderService::class)->syncOrderByWMSOrderHeaders($orderHeaders);
  142. app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
  143. app('OrderPackageService')->syncOrderPackage($orderHeaders);
  144. app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
  145. $this->createByWmsOrderHeader($orderHeaders);
  146. }
  147. public function trackingWmsOrderOnEdit($startData)
  148. {
  149. $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateEdit($startData);
  150. app(OrderService::class)->syncOrderByWMSOrderHeaders($orderHeaders);
  151. app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
  152. app('OrderPackageService')->syncOrderPackage($orderHeaders);
  153. app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
  154. $this->updateByWmsOrderHeaders($orderHeaders);
  155. }
  156. public function updateOrderTracingAndSyc($id,$param,$value){
  157. $order_tracking = OrderTracking::query()->with('commodities.package.order')->where('id', $id)->first();
  158. $order_id = $order_tracking->commodities->package->order->id ?? false;
  159. if(!isset($order_id)){ return ['success'=> false];}
  160. return $this->updateOrderTracingsByOrderIds($order_id,$param,$value);
  161. }
  162. public function updateOrderTracingsByOrderIds($orderId,$param,$value)
  163. {
  164. $bool = null;
  165. try {
  166. $update = [$param => $value];
  167. if($param == 'planning_sent_at'){
  168. $update= [$param => $value, 'signed_at' => $value];
  169. }
  170. $bool = OrderTracking::query()->whereHas('commodities.package.order', function ($query) use ($orderId) {
  171. $query->where('id', $orderId);
  172. })->update($update);
  173. return['success'=> $bool > 0];
  174. } catch (\Exception $e) {
  175. app('LogService')->log(__METHOD__,__FUNCTION__,'修改追踪件'.json_encode($orderId,$param,$value).json_encode($e->getMessage()).json_encode($e->getTraceAsString()));
  176. return['success'=> false,'fail_info'=>$e->getMessage()];
  177. }
  178. }
  179. public function createByWmsOrderHeader($orderHeaders)
  180. {
  181. if(!$orderHeaders){return;}
  182. /** @var DataHandlerService $dataService */
  183. $dataService = app(DataHandlerService::class);
  184. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  185. $owner_id_map = $basSKUs_data = $dataService->dataHeader(['id'],$owners);
  186. $BasSKUs = app(OracleBasSkuService::class)->获取BasSKu_通过WMSOrderHeaders($orderHeaders);
  187. $BasSKUs_code_sku_map = $dataService->dataHeader(['customerid','sku'],$BasSKUs);
  188. $order_nos = data_get($orderHeaders,'*.orderno');
  189. $order_package_commodities = OrderPackageCommodities::query()->with(['package.order','commodity'])
  190. ->whereIn('order_package_id',function($query)use($order_nos){
  191. $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($order_nos){
  192. $query->from('orders')->select('id')->whereIn('code',$order_nos);
  193. });
  194. })
  195. ->get();
  196. $order_package_commodities_ids = data_get($order_package_commodities,'*.id');
  197. $order_trackings = OrderTracking::query()->whereIn('order_package_commodity_id',$order_package_commodities_ids)->get();
  198. $is_exist_ids = data_get($order_trackings,'*.order_package_commodity_id');
  199. $order_package_commodities = $order_package_commodities->filter(function($item) use ($is_exist_ids){
  200. $id = $item->id;
  201. return !in_array($id,$is_exist_ids);
  202. });
  203. if($order_package_commodities->count() == 0){return ;}
  204. $order_headers_map = [];
  205. foreach ($orderHeaders as $item) {
  206. $order_headers_map[$item->orderno] = $item;
  207. }
  208. $params = [];
  209. foreach ($order_package_commodities as $item) {
  210. $order = $item->package->order;
  211. if(!$order){continue ;}
  212. $order_header = $order_headers_map[$order->code];
  213. if(!$order_header){continue ;}
  214. if($order_header->sostatus == 90){continue;}
  215. $web_order_number = null;
  216. if(preg_match('/^O[\d]/',$order_header['soreference1'] ?? '') > 0){
  217. $web_order_number = $order_header['soreference1'];
  218. }
  219. $param = $this->getParamsByOrderHeaderAndOrder($order_header,$order);
  220. $owner = $dataService->getKeyValue(['id'=>$order->owner_id],$owner_id_map);
  221. $basSkU = $dataService->getKeyValue(['customerid'=>$owner->code,'sku'=>$item->commodity->sku],$BasSKUs_code_sku_map);
  222. $gross_weight = round($basSkU->grossweight * $item->amount, 2);
  223. $bulk = round($basSkU->cube * $item->amount, 2);
  224. $order_client_code = $order->client_code;
  225. if($param['client']=='天猫'){
  226. $order_client_code = $this->get_d_edit_03($order_header,$item) ;
  227. }
  228. $params[] =[
  229. 'order_package_commodity_id' => $item->id,
  230. 'owner_id' => $order->owner_id,
  231. 'logistic_id' => $param['logistic_id'],
  232. 'order_client_code' =>$order_client_code,
  233. 'sale' => $param['sale'],
  234. 'client' => $param['client'],
  235. 'created_at' => $order->created_at,
  236. 'order_remark' => $param['order_remark'],
  237. 'pick_up_at' => $order_header->lastshipmenttime, // 提货时间,
  238. 'web_order_number' => $web_order_number,
  239. 'gross_weight'=> $gross_weight,
  240. 'bulk'=> $bulk,
  241. 'is_on_duty_shift'=> $param['is_on_duty_shift'],
  242. 'planning_sent_at' => $param['planning_sent_at'] ?? ''
  243. ];
  244. }
  245. try {
  246. if (count($params) > 0) {
  247. $this->insert($params);
  248. app('LogService')->log(__METHOD__, __FUNCTION__, '批量添加 orderTracking' . json_encode($params),null);
  249. }
  250. } catch (\Exception $e) {
  251. app('LogService')->log(__METHOD__, __FUNCTION__, '批量添加 orderTracking error' . json_encode($params).$e->getMessage().$e->getTraceAsString(),null);
  252. }
  253. }
  254. public function get_d_edit_03($orderHeader,$orderPackageCommodity){
  255. $sku_line_no = null;
  256. foreach ($orderHeader->actAllocationDetails as $actAllocationDetail) {
  257. if($actAllocationDetail->picktotraceid == $orderPackageCommodity->package->logistic_number
  258. && $orderPackageCommodity->commodity->sku == $actAllocationDetail->sku){
  259. $sku_line_no = $actAllocationDetail->skulineno;
  260. break;
  261. }
  262. }
  263. if($sku_line_no==null)return null;
  264. foreach ($orderHeader->oracleDOCOrderDetails as $oracleDOCOrderDetail) {
  265. if($oracleDOCOrderDetail->orderlineno == $sku_line_no) {
  266. return $oracleDOCOrderDetail['d_edi_03'];
  267. }
  268. }
  269. return null;
  270. }
  271. public function updateByWmsOrderHeaders($orderHeaders)
  272. {
  273. if(!$orderHeaders){return ;}
  274. /** @var DataHandlerService $dataService */
  275. $dataService = app(DataHandlerService::class);
  276. $order_nos = data_get($orderHeaders,'*.orderno');
  277. $order_package_commodities = OrderPackageCommodities::query()
  278. ->with(['package.order','commodity'])
  279. ->whereIn('order_package_id',function($query)use($order_nos){
  280. $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($order_nos){
  281. $query->from('orders')->select('id')->whereIn('code',$order_nos);
  282. });
  283. })->get();
  284. $orderTrackings = OrderTracking::query()->whereIn('order_package_commodity_id',data_get($order_package_commodities,'*.id'))->get();
  285. $order_tracking_id_map = [];
  286. foreach ($orderTrackings as $orderTracking) {
  287. $order_tracking_id_map[$orderTracking->order_package_commodity_id] = $orderTracking;
  288. }
  289. $order_package_commodity_order_code_map = [];
  290. $order_code_map = [];
  291. foreach ($order_package_commodities as $order_package_commodity) {
  292. $order =$order_package_commodity->package->order;
  293. if(!$order){continue;}
  294. $order_code_map[$order->code] = $order;
  295. $order_package_commodity_order_code_map[$order->code][] = $order_package_commodity;
  296. }
  297. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  298. $owner_code_map = $basSKUs_data = $dataService->dataHeader(['code'],$owners);
  299. $BasSKUs = app(OracleBasSkuService::class)->获取BasSKu_通过WMSOrderHeaders($orderHeaders);
  300. $BasSKUs_code_sku_map = $dataService->dataHeader(['customerid','sku'],$BasSKUs);
  301. $update_params = [];
  302. $update_params[0] =['id','client','pick_up_at','order_remark','gross_weight','bulk','planning_sent_at'];
  303. foreach ($orderHeaders as $orderHeader) {
  304. if($orderHeader->sostatus == '90'){continue;}
  305. $order_package_commodity_list = $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
  306. if(!$order_package_commodity_list){continue;}
  307. $order = $order_code_map[$orderHeader->orderno];
  308. foreach ($order_package_commodity_list as $order_package_commodity) {
  309. $order_tracking = $order_tracking_id_map[$order_package_commodity->id]??false;
  310. if(!$order_tracking){continue;}
  311. $params = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
  312. $owner = $dataService->getKeyValue(['code'=>$orderHeader->customerid],$owner_code_map);
  313. $basSku = $dataService->getKeyValue(['customerid'=>$owner->code,'sku'=>$order_package_commodity->commodity->sku],$BasSKUs_code_sku_map);
  314. $gross_weight = round($basSku->grossweight * $order_package_commodity->amount,2) ;
  315. $bulk = round($basSku->cube * $order_package_commodity->amount,2) ;
  316. if($order_tracking->owner_id != $params['owner_id'] ||
  317. $order_tracking->client !=$params['client'] ||
  318. $order_tracking->order_remark != $params['order_remark'] ||
  319. $order_tracking->pick_up_at != $params['pick_up_at'] ||
  320. $order_tracking->gross_weight != $gross_weight ||
  321. $order_tracking->bulk != $bulk){
  322. $update_params[] = [
  323. 'id' => $order_tracking->id,
  324. 'client' => $params['client'],
  325. 'pick_up_at' => $params['pick_up_at'],
  326. 'order_remark' => $params['order_remark'],
  327. 'web_order_number' => $params['web_order_number'],
  328. 'gross_weight' => $gross_weight,
  329. 'bulk' => $bulk,
  330. 'planning_sent_at' => $params['planning_sent_at']
  331. ];
  332. }
  333. }
  334. }
  335. if(count($update_params) > 1){
  336. $this->batchUpdate($update_params);
  337. }
  338. $insert_params = [];
  339. foreach ($orderHeaders as $orderHeader) {
  340. $order_package_commodity_list= $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
  341. if(!$order_package_commodity_list)continue;
  342. foreach ($order_package_commodity_list as $item) {
  343. $order_tracking = $order_tracking_id_map[$item->id] ?? false;
  344. if(!$order_tracking){
  345. $order = $order_code_map[$orderHeader->orderno] ?? false;
  346. if(!$order) continue;
  347. $basSkU = $dataService->getKeyValue(['customerid'=>$orderHeader->customerid,'sku'=>$item->commodity->sku],$BasSKUs_code_sku_map);
  348. $gross_weight = round($basSkU->grossweight * $item->amount, 2);
  349. $bulk = round($basSkU->cube * $item->amount, 2);
  350. $param = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
  351. $param['order_package_commodity_id'] =$item->id;
  352. $param['order_client_code'] = $order->client_code;
  353. $param['gross_weight'] = $gross_weight;
  354. $param['bulk'] = $bulk;
  355. $insert_params[] =$param;
  356. }
  357. }
  358. }
  359. if(count($insert_params) > 0){
  360. try {
  361. $this->insert($insert_params);
  362. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking '.count($insert_params).json_encode($insert_params));
  363. } catch (\Exception $e) {
  364. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking error'.json_encode($insert_params) .'||'.$e->getMessage(),'||'.$e->getTraceAsString());
  365. }
  366. }
  367. $this->删除订单追踪_订单取消($orderHeaders);
  368. }
  369. /**
  370. * @param OracleDOCOrderHeader $orderHeader
  371. * @param Order $order
  372. * @return array
  373. */
  374. public function getParamsByOrderHeaderAndOrder($orderHeader,$order)
  375. {
  376. /** @var LogisticService $logisticService */
  377. $logisticService = app('LogisticService');
  378. $client = $orderHeader['issuepartyname'] ?? '';
  379. $order_remark = $orderHeader['notes'] ?? '';
  380. $web_order_number = null;
  381. if(preg_match('/^O[\d]/',$orderHeader['soreference1'] ?? '') > 0){
  382. $web_order_number = $orderHeader['soreference1'];
  383. }
  384. $pick_up_at = $orderHeader->lastshipmenttime;
  385. $planning_sent_at = null;
  386. // 快递方式
  387. $logistic = $logisticService->getLogisticByCode($orderHeader['userdefine1']);
  388. if($orderHeader['userdefine1'] =='ZT') $logistic = $logisticService->getLogisticByCode('XJWL'); // 自提转新杰物流
  389. if(isset($pick_up_at)){
  390. $logisticTiming = app(LogisticTimingService::class)->findByParams($orderHeader['c_city']??'',$orderHeader['c_province']??'',$logistic['id']);
  391. if($logisticTiming)$planning_sent_at = Carbon::parse((string)$pick_up_at)->addDays($logisticTiming->days_at_working); // 预期到货时间
  392. }
  393. if(stristr($order_remark,'[')){
  394. $items = [];
  395. preg_match_all('/^(.*?)(\\[)(.*?)(\\])(.*?)$/u',$order_remark,$items);
  396. $client = $items[1][0];
  397. $order_remark = $items[3][0];
  398. }
  399. if(mb_strpos($client,'天猫')!=false)$client='天猫';
  400. if(mb_strpos($client,'京东')!=false)$client='京东';
  401. return [
  402. 'owner_id' => $order->owner_id,
  403. 'logistic_id' => $logistic['id'],
  404. 'client' => $client,
  405. 'sale' => $orderHeader['issuepartyname'] ?? '',
  406. 'created_at' => $order->created_at,
  407. 'order_remark' => $order_remark,
  408. 'pick_up_at' => $orderHeader['lastshipmenttime'] ?? '', // 提货时间
  409. 'web_order_number' =>$web_order_number,
  410. 'is_on_duty_shift'=>$planning_sent_at?'是':null,
  411. 'planning_sent_at' => (string)$planning_sent_at
  412. ];
  413. }
  414. /**
  415. * @param Collection $orderHeaders
  416. */
  417. public function 删除订单追踪_订单取消($orderHeaders)
  418. {
  419. $cancelledOrderHeaders = $orderHeaders->where('sostatus','90');
  420. $orderTracking = $this->getOrderTracingByWmsOrder($cancelledOrderHeaders);
  421. $this->deleteOrderTracings($orderTracking);
  422. }
  423. /**
  424. * @param Collection $orderHeaders
  425. * @return \Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|Collection|\Tightenco\Collect\Support\Collection
  426. */
  427. public function getOrderTracingByWmsOrder($orderHeaders)
  428. {
  429. if($orderHeaders->count() == 0){return collect();}
  430. $orderNos = data_get($orderHeaders,'*.orderno');
  431. return OrderPackageCommodities::query()
  432. ->with('commodities.package.order')
  433. ->whereIn('order_package_commodity_id',function($query)use($orderNos){
  434. $query->from('order_package_commodities')->select('id')->whereIn('order_package_id',function($query)use($orderNos) {
  435. $query->from('order_packages')->select('id')->whereIn('order_id', function ($query) use ($orderNos) {
  436. $query->from('orders')->select('id')->whereIn('code', $orderNos);
  437. });
  438. });
  439. })->get();
  440. }
  441. /**
  442. * @param Collection $orderTracking
  443. */
  444. public function deleteOrderTracings($orderTracking)
  445. {
  446. if($orderTracking->count() == 0){return;}
  447. try {
  448. OrderTracking::query()->whereIn('id', data_get($orderTracking,'*.id'))->delete();
  449. app('LogService')->log(__METHOD__,__FUNCTION__,'删除OrderTracking '.$orderTracking->count().json_encode($orderTracking),null);
  450. } catch (\Exception $e) {
  451. app('LogService')->log(__METHOD__,__FUNCTION__,'删除OrderTracking error'.$orderTracking->count().json_encode($orderTracking).$e->getMessage().$e->getTraceAsString(),null);
  452. }
  453. }
  454. /**
  455. * @param OracleBasSKU $basSkU
  456. * @param OrderPackageCommodities $orderPackageCommodity
  457. * @return array
  458. */
  459. public function getGrossWeightAndBulk($basSkU,$orderPackageCommodity)
  460. {
  461. return [
  462. 'gross_weight' =>round($basSkU->grossweight * $orderPackageCommodity->amount, 2),
  463. 'bulk' =>round($basSkU->cube * $orderPackageCommodity->amount, 2),
  464. ];
  465. }
  466. public function fillInOrderTracking($orderTracking = null)
  467. {
  468. $orderTrackingIds = [];
  469. try {
  470. $date = new Carbon();
  471. if($orderTracking==null){
  472. $orderTracking = OrderTracking::query()
  473. ->where('created_at', '!=', '0000-00-00 00:00:00')
  474. ->where('planning_sent_at', '!=', '0000-00-00 00:00:00')
  475. ->whereNull('signed_at')
  476. ->where('planning_sent_at','<',$date)
  477. ->get();
  478. }
  479. if(count($orderTracking)==0)return;
  480. $update_params = [['id','signed_at']];
  481. $orderTracking = $orderTracking->where('created_at', '!=', '0000-00-00 00:00:00')
  482. ->where('planning_sent_at', '!=', '0000-00-00 00:00:00')
  483. ->whereNull('signed_at')
  484. ->where('planning_sent_at','<',$date);
  485. $orderTracking->each(function($item)use(&$update_params){
  486. $update_params[] = [
  487. 'id' => $item->id,
  488. 'signed_at' => $item->planning_sent_at
  489. ];
  490. });
  491. if(count($update_params) > 0) $this->batchUpdate($update_params);
  492. $orderTrackingIds = data_get($orderTracking, '*.id');
  493. OrderTracking::query()->whereIn('id', $orderTrackingIds)
  494. ->whereNull('is_on_duty_shift')
  495. ->whereNull('is_arrival')
  496. ->update(['is_on_duty_shift' => '是', 'is_arrival' => '是']);
  497. app('LogService')->log(__METHOD__,__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况'.json_encode($orderTrackingIds));
  498. } catch (\Exception $e) {
  499. app('LogService')->log(__METHOD__,'ERROR '.__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况 ERROR'.json_encode($orderTrackingIds).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
  500. }
  501. }
  502. }