OrderTrackingService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567
  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','web_order_number','order_client_code'];
  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. $order_client_code = $order->client_code;
  318. if($params['client']=='天猫'){
  319. $order_client_code = $this->get_d_edit_03($orderHeader,$order_package_commodity) ;
  320. }
  321. if($order_tracking->owner_id != $params['owner_id'] ||
  322. $order_tracking->client !=$params['client'] ||
  323. $order_tracking->order_remark != $params['order_remark'] ||
  324. $order_tracking->pick_up_at != $params['pick_up_at'] ||
  325. $order_tracking->gross_weight != $gross_weight ||
  326. $order_tracking->bulk != $bulk ||
  327. $order_tracking->client != $order_client_code){
  328. $update_params[] = [
  329. 'id' => $order_tracking->id,
  330. 'client' => $params['client'],
  331. 'order_client_code' => $order_client_code,
  332. 'pick_up_at' => $params['pick_up_at'],
  333. 'order_remark' => $params['order_remark'],
  334. 'web_order_number' => $params['web_order_number'],
  335. 'gross_weight' => $gross_weight,
  336. 'bulk' => $bulk,
  337. 'planning_sent_at' => $params['planning_sent_at']
  338. ];
  339. }
  340. }
  341. }
  342. if(count($update_params) > 1){
  343. $this->batchUpdate($update_params);
  344. }
  345. $insert_params = [];
  346. foreach ($orderHeaders as $orderHeader) {
  347. $order_package_commodity_list= $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
  348. if(!$order_package_commodity_list)continue;
  349. foreach ($order_package_commodity_list as $item) {
  350. $order_tracking = $order_tracking_id_map[$item->id] ?? false;
  351. if(!$order_tracking){
  352. $order = $order_code_map[$orderHeader->orderno] ?? false;
  353. if(!$order) continue;
  354. $basSkU = $dataService->getKeyValue(['customerid'=>$orderHeader->customerid,'sku'=>$item->commodity->sku],$BasSKUs_code_sku_map);
  355. $gross_weight = round($basSkU->grossweight * $item->amount, 2);
  356. $bulk = round($basSkU->cube * $item->amount, 2);
  357. $param = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
  358. $param['order_package_commodity_id'] =$item->id;
  359. $param['order_client_code'] = $order->client_code;
  360. $param['gross_weight'] = $gross_weight;
  361. $param['bulk'] = $bulk;
  362. $insert_params[] =$param;
  363. }
  364. }
  365. }
  366. if(count($insert_params) > 0){
  367. try {
  368. $this->insert($insert_params);
  369. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking '.count($insert_params).json_encode($insert_params));
  370. } catch (\Exception $e) {
  371. app('LogService')->log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking error'.json_encode($insert_params) .'||'.$e->getMessage(),'||'.$e->getTraceAsString());
  372. }
  373. }
  374. $this->删除订单追踪_订单取消($orderHeaders);
  375. }
  376. /**
  377. * @param OracleDOCOrderHeader $orderHeader
  378. * @param Order $order
  379. * @return array
  380. */
  381. public function getParamsByOrderHeaderAndOrder($orderHeader,$order)
  382. {
  383. /** @var LogisticService $logisticService */
  384. $logisticService = app('LogisticService');
  385. $client = $orderHeader['issuepartyname'] ?? '';
  386. $order_remark = $orderHeader['notes'] ?? '';
  387. $web_order_number = null;
  388. if(preg_match('/^O[\d]/',$orderHeader['soreference1'] ?? '') > 0){
  389. $web_order_number = $orderHeader['soreference1'];
  390. }
  391. $pick_up_at = $orderHeader->lastshipmenttime;
  392. $planning_sent_at = null;
  393. // 快递方式
  394. $logistic = $logisticService->getLogisticByCode($orderHeader['userdefine1']);
  395. if($orderHeader['userdefine1'] =='ZT') $logistic = $logisticService->getLogisticByCode('XJWL'); // 自提转新杰物流
  396. if(isset($pick_up_at)){
  397. $logisticTiming = app(LogisticTimingService::class)->findByParams($orderHeader['c_city']??'',$orderHeader['c_province']??'',$logistic['id']);
  398. if($logisticTiming)$planning_sent_at = Carbon::parse((string)$pick_up_at)->addDays($logisticTiming->days_at_working); // 预期到货时间
  399. }
  400. if(stristr($order_remark,'[')){
  401. $items = [];
  402. preg_match_all('/^(.*?)(\\[)(.*?)(\\])(.*?)$/u',$order_remark,$items);
  403. $client = $items[1][0];
  404. $order_remark = $items[3][0];
  405. }
  406. if(mb_stristr($client,'天猫')!=false)$client='天猫';
  407. if(mb_stristr($client,'京东')!=false)$client='京东';
  408. return [
  409. 'owner_id' => $order->owner_id,
  410. 'logistic_id' => $logistic['id'],
  411. 'client' => $client,
  412. 'sale' => $orderHeader['issuepartyname'] ?? '',
  413. 'created_at' => $order->created_at,
  414. 'order_remark' => $order_remark,
  415. 'pick_up_at' => $orderHeader['lastshipmenttime'] ?? '', // 提货时间
  416. 'web_order_number' =>$web_order_number,
  417. 'is_on_duty_shift'=>$planning_sent_at?'是':null,
  418. 'planning_sent_at' => (string)$planning_sent_at
  419. ];
  420. }
  421. /**
  422. * @param Collection $orderHeaders
  423. */
  424. public function 删除订单追踪_订单取消($orderHeaders)
  425. {
  426. $cancelledOrderHeaders = $orderHeaders->where('sostatus','90');
  427. $orderTracking = $this->getOrderTracingByWmsOrder($cancelledOrderHeaders);
  428. $this->deleteOrderTracings($orderTracking);
  429. }
  430. /**
  431. * @param Collection $orderHeaders
  432. * @return \Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|Collection|\Tightenco\Collect\Support\Collection
  433. */
  434. public function getOrderTracingByWmsOrder($orderHeaders)
  435. {
  436. if($orderHeaders->count() == 0){return collect();}
  437. $orderNos = data_get($orderHeaders,'*.orderno');
  438. return OrderTracking::query()
  439. ->with('commodities.package.order')
  440. ->whereIn('order_package_commodity_id',function($query)use($orderNos){
  441. $query->from('order_package_commodities')->select('id')->whereIn('order_package_id',function($query)use($orderNos) {
  442. $query->from('order_packages')->select('id')->whereIn('order_id', function ($query) use ($orderNos) {
  443. $query->from('orders')->select('id')->whereIn('code', $orderNos);
  444. });
  445. });
  446. })->get();
  447. }
  448. /**
  449. * @param Collection $orderTracking
  450. */
  451. public function deleteOrderTracings($orderTracking)
  452. {
  453. if($orderTracking->count() == 0){return;}
  454. try {
  455. OrderTracking::query()->whereIn('id', data_get($orderTracking,'*.id'))->delete();
  456. app('LogService')->log(__METHOD__,__FUNCTION__,'删除OrderTracking '.$orderTracking->count().json_encode($orderTracking),null);
  457. } catch (\Exception $e) {
  458. app('LogService')->log(__METHOD__,__FUNCTION__,'删除OrderTracking error'.$orderTracking->count().json_encode($orderTracking).$e->getMessage().$e->getTraceAsString(),null);
  459. }
  460. }
  461. /**
  462. * @param OracleBasSKU $basSkU
  463. * @param OrderPackageCommodities $orderPackageCommodity
  464. * @return array
  465. */
  466. public function getGrossWeightAndBulk($basSkU,$orderPackageCommodity)
  467. {
  468. return [
  469. 'gross_weight' =>round($basSkU->grossweight * $orderPackageCommodity->amount, 2),
  470. 'bulk' =>round($basSkU->cube * $orderPackageCommodity->amount, 2),
  471. ];
  472. }
  473. public function fillInOrderTracking($orderTracking = null)
  474. {
  475. $orderTrackingIds = [];
  476. try {
  477. $date = new Carbon();
  478. if($orderTracking==null){
  479. $orderTracking = OrderTracking::query()
  480. ->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. ->get();
  485. }
  486. if(count($orderTracking)==0)return;
  487. $update_params = [['id','signed_at']];
  488. $orderTracking = $orderTracking->where('created_at', '!=', '0000-00-00 00:00:00')
  489. ->where('planning_sent_at', '!=', '0000-00-00 00:00:00')
  490. ->whereNull('signed_at')
  491. ->where('planning_sent_at','<',$date);
  492. $orderTracking->each(function($item)use(&$update_params){
  493. $update_params[] = [
  494. 'id' => $item->id,
  495. 'signed_at' => $item->planning_sent_at
  496. ];
  497. });
  498. if(count($update_params) > 0) $this->batchUpdate($update_params);
  499. $orderTrackingIds = data_get($orderTracking, '*.id');
  500. OrderTracking::query()->whereIn('id', $orderTrackingIds)
  501. ->whereNull('is_on_duty_shift')
  502. ->whereNull('is_arrival')
  503. ->update(['is_on_duty_shift' => '是', 'is_arrival' => '是']);
  504. app('LogService')->log(__METHOD__,__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况'.json_encode($orderTrackingIds));
  505. } catch (\Exception $e) {
  506. app('LogService')->log(__METHOD__,'ERROR '.__FUNCTION__,'修改签收日期 是否赶上卡班 到货情况 ERROR'.json_encode($orderTrackingIds).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
  507. }
  508. }
  509. }