OrderTrackingService.php 26 KB

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