OrderPackageCommoditiesService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577
  1. <?php
  2. namespace App\Services;
  3. use App\Commodity;
  4. use App\OracleActAllocationDetails;
  5. use App\OracleBasSKU;
  6. use App\OracleDOCOrderDetail;
  7. use App\OracleDOCOrderHeader;
  8. use App\Order;
  9. use App\OrderPackage;
  10. use App\OrderPackageCommodities;
  11. use App\Owner;
  12. use App\Services\common\BatchUpdateService;
  13. use App\Services\common\DataHandlerService;
  14. use Carbon\Carbon;
  15. use Illuminate\Support\Collection;
  16. class OrderPackageCommoditiesService
  17. {
  18. public function insert(array $params){
  19. return OrderPackageCommodities::query()->insert($params);
  20. }
  21. public function batchUpdate($params){
  22. return app(BatchUpdateService::class)->batchUpdate('order_package_commodities',$params);
  23. }
  24. public function basedOnOracleDetailsStore($orderNo, $orderPackage)
  25. {
  26. $details = OracleDOCOrderDetail::query()->where('orderNo', $orderNo)->get();
  27. $orderPackageCommodities = OrderPackageCommodities::query()->where('order_package_id',$orderPackage['id'])->get();
  28. $this->根据详情更新OrderPackage下的商品信息($orderPackage,$orderPackageCommodities,$details,'qtyordered');
  29. unset($details,$orderPackageCommodities);
  30. }
  31. public function basedOnActAllocationDetailsStoreByOrderNo($orderNo,$orderPackage){
  32. $details = OracleActAllocationDetails::query()->where('orderno', $orderNo)->get();
  33. $orderPackageCommodities = OrderPackageCommodities::query()->where('order_package_id',$orderPackage['id'])->get();
  34. $this->根据详情更新OrderPackage下的商品信息($orderPackage,$orderPackageCommodities,$details,'qty_each');
  35. unset($details,$orderPackageCommodities);
  36. }
  37. public function 根据详情更新OrderPackage下的商品信息($orderPackage,$orderPackageCommodities,$details,$key){
  38. $newItems = [];
  39. foreach ($details as $detail) {
  40. $owner = Owner::query()->where(['code' => $detail['customerid']])->first(); // 货主
  41. $sku = $detail->sku; // sku
  42. $owner_id = $owner->id; // 货主id
  43. $commodity = Commodity::query()->where(['sku' => $sku, 'owner_id' => $owner_id])->first(); // 商品
  44. if ($commodity == null) {
  45. $basSku = OracleBasSKU::query()->where(['sku' => $sku, 'customerid' => $detail->customerid])->first(); // 没有找到对应的商品信息
  46. $commodity = Commodity::query()->create(['sku' => $sku, 'owner_id' => $owner_id, 'name' => $basSku->descr_c]);
  47. }
  48. $data = ['order_package_id' => $orderPackage['id'], 'commodity_id' => $commodity['id'], 'amount' => $detail[$key]];
  49. array_push($newItems,$data);
  50. }
  51. $diffarr = [];
  52. foreach ($newItems as $newItem) {
  53. $packageCommodity = $orderPackageCommodities->where('order_package_id',$newItem['order_package_id'])->where('commodity_id',$newItem['commodity_id'])->first();
  54. if($packageCommodity!=null){
  55. if($packageCommodity['amount'] != $newItem['amount']){
  56. $packageCommodity->update(['amount'=>intval($newItem['amount'])]);
  57. }
  58. $orderPackageCommodities = $orderPackageCommodities->filter(function ($item) use ($packageCommodity){
  59. if($item['id'] == $packageCommodity['id']){
  60. return false;
  61. }
  62. return true;
  63. });
  64. array_push($diffarr,$newItem);
  65. }
  66. }
  67. if($orderPackageCommodities->count() > 0){
  68. foreach ($orderPackageCommodities as $orderPackageCommodity) {
  69. $id = $orderPackageCommodity['id'];
  70. OrderPackageCommodities::destroy($id);
  71. }
  72. }
  73. $newItems = array_filter($newItems,function($newItem) use ($diffarr){
  74. foreach ($diffarr as $item) {
  75. if($item['order_package_id'] == $newItem['order_package_id'] &&
  76. $item['commodity_id'] == $newItem['commodity_id'] &&
  77. $item['amount'] == $newItem['amount']){
  78. return false;
  79. }
  80. }
  81. return true;
  82. });
  83. try {
  84. if(count($newItems) > 0 ){
  85. OrderPackageCommodities::query()->insert($newItems);
  86. LogService::log(__METHOD__,__FUNCTION__,'添加包裹商品信息'.json_encode($newItems));
  87. }
  88. } catch (\Exception $e) {
  89. LogService::log(__METHOD__,__FUNCTION__,'添加包裹商品信息异常'.json_encode($newItems).$e->getMessage(),$e->getTraceAsString());
  90. } finally {
  91. unset($newItems,$orderPackageCommodities);
  92. }
  93. }
  94. public function basedOnActAllocationDetailsStore($orderPackage)
  95. {
  96. $details = OracleActAllocationDetails::query()->where('picktotraceid', $orderPackage->logistic_number)->get();
  97. $orderPackageCommodities = OrderPackageCommodities::query()->where('order_package_id',$orderPackage['id'])->get();
  98. $this->根据详情更新OrderPackage下的商品信息($orderPackage,$orderPackageCommodities,$details,'qty_each');
  99. unset($details,$orderPackageCommodities);
  100. }
  101. public function basedOnActAllocationDetail(Order $order, OracleDOCOrderHeader $header, array $details)
  102. {
  103. foreach ($details as $detail) {
  104. $logistic_number = $details['picktotraceid'];
  105. if ($logistic_number == '*' || $logistic_number == null || $logistic_number == '') {
  106. $logistic_number = $header['soreference5'];
  107. if ($logistic_number == '*' || $logistic_number == null || $logistic_number == '') {
  108. continue;
  109. }
  110. }
  111. $orderPackage = OrderPackage::query()->firstOrCreate(['order_id'=>$order['id'],'logistic_number',$details]);
  112. $this->createByActAllocationDetail($detail, $orderPackage);
  113. }
  114. }
  115. private function createByActAllocationDetail($detail,$orderPackage)
  116. {
  117. $owner = Owner::query()->where(['code' => $detail->customerid])->first(); // 货主
  118. $sku = $detail->sku;
  119. $owner_id = $owner['id'];
  120. $commodity = Commodity::query()->where(['sku' => $sku, 'owner_id' => $owner_id])->first();
  121. if ($commodity == null) {
  122. $basSku = OracleBasSKU::query()->where(['sku' => $sku, 'customerid' => $detail->customerid])->first();
  123. $commodity = Commodity::query()->create(['sku' => $sku, 'owner_id' => $owner_id, 'name' => $basSku->descr_c]);
  124. }
  125. try {
  126. $count = OrderPackageCommodities::query()->where(['order_package_id' => $orderPackage['id'], 'commodity_id' => $commodity['id'], 'amount' => $detail['qty_each']])->count();
  127. if($count == 0){
  128. $orderPackageCommodities = OrderPackageCommodities::query()->firstOrCreate(['order_package_id' => $orderPackage['id'], 'commodity_id' => $commodity['id'], 'amount' => $detail['qty_each']]);
  129. LogService::log(__METHOD__,__FUNCTION__,'创建订单包裹详情'.json_encode($orderPackageCommodities));
  130. }
  131. } catch (\Exception $e) {
  132. LogService::log(__METHOD__,__FUNCTION__,'创建订单包裹失败'.$e->getMessage().$e->getTraceAsString());
  133. } finally {
  134. return $orderPackageCommodities ?? null;
  135. }
  136. }
  137. public function createByWmsOrder($orderHeaders)
  138. {
  139. if(!$orderHeaders){ return [];}
  140. /** @var DataHandlerService $dataHandlerService */
  141. $dataHandlerService = app(DataHandlerService::class);
  142. $order_packages = app(OrderPackageService::class)->getByWmsOrders($orderHeaders);
  143. $order_packages_logistic_number_map = $dataHandlerService->dataHeader(['logistic_number'],$order_packages);
  144. $commodities = app(CommodityService::class)->getByWmsOrders($orderHeaders);
  145. $commodity_owner_id_sku_map = $dataHandlerService->dataHeader(['owner_id','sku'],$commodities);
  146. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  147. $owner_code_map = $dataHandlerService->dataHeader(['code'],$owners);
  148. $order_packages_commodities = $this->getByWmsOrder($orderHeaders);
  149. $map = [];
  150. foreach ($order_packages_commodities as $item) {
  151. $key = ' commodity_id='.$item->commodity_id.' order_package_id'.$item->order_package_id.' amount='.$item->amount;
  152. $map[$key][] = $item;
  153. }
  154. $insert_params = [];
  155. foreach ($orderHeaders as $orderHeader) {
  156. $actAllocationDetails = $orderHeader->actAllocationDetails;
  157. $logistic_numbers = array_diff(array_unique(data_get($actAllocationDetails,'*.picktotraceid')),['*','',null]);
  158. if(count($logistic_numbers) > 0){
  159. $params = $this->getParamsByActAllocationDetails($actAllocationDetails,
  160. $order_packages_logistic_number_map,
  161. $owner_code_map,
  162. $commodity_owner_id_sku_map,
  163. $logistic_numbers);
  164. foreach ($params as $key =>$param) {
  165. $mapkey = ' commodity_id='.($param['commodity_id'] ?? '').' order_package_id'.($param['order_package_id'] ?? '').' amount='.($param['amount'] ?? '');
  166. if(($map[$mapkey] ?? false) && count($map[$mapkey]) >0){
  167. array_shift($map[$mapkey]);
  168. unset($params[$key]);
  169. }
  170. }
  171. $insert_params = array_merge($insert_params,$params);
  172. unset($params);
  173. }
  174. }
  175. if(count($insert_params) > 0){
  176. $this->create($insert_params);
  177. }
  178. unset($orderHeaders,$order_packages,$owner_code_map,$commodities,$insert_params);
  179. }
  180. public function getParamsByActAllocationDetails($details,array $order_packages_logistic_number_map,array $owner_code_map,array $commodity_owner_id_sku_map,array $logistic_numbers){
  181. /** @var DataHandlerService $dataHandlerService */
  182. $dataHandlerService = app(DataHandlerService::class);
  183. if(!$details)return [];
  184. $params = [];
  185. $create_at = Carbon::now()->format('Y-m-d H:i:s');
  186. $updated_at = Carbon::now()->format('Y-m-d H:i:s');
  187. foreach ($details as $actAllocationDetail) {
  188. $pickToTraceID = $actAllocationDetail->picktotraceid;
  189. if(in_array($pickToTraceID,$logistic_numbers)){
  190. $orderPackage = $dataHandlerService->getKeyValue(['logistic_number'=>$pickToTraceID],$order_packages_logistic_number_map);
  191. if(!$orderPackage)continue;
  192. $owner = $dataHandlerService->getKeyValue(['code'=>$actAllocationDetail->customerid],$owner_code_map);
  193. if(!$owner)continue;
  194. $commodity = $dataHandlerService->getKeyValue(['owner_id'=>$owner->id,'sku'=>$actAllocationDetail->sku],$commodity_owner_id_sku_map);
  195. if(!$commodity)continue;
  196. $params[] = [
  197. 'commodity_id' =>$commodity->id,
  198. 'order_package_id' =>$orderPackage->id,
  199. 'amount' => $actAllocationDetail->qty_each,
  200. 'created_at' => $create_at
  201. ];
  202. }
  203. }
  204. unset($details,$order_packages_logistic_number_map,$owner_code_map,$commodity_owner_id_sku_map,$logistic_numbers);
  205. return $params;
  206. }
  207. public function create(array $params){
  208. if(!$params){return [];}
  209. try {
  210. $this->insert($params);
  211. LogService::log(__METHOD__,__FUNCTION__,'批量创建 OrderPackageCommodities'.count($params).json_encode($params));
  212. } catch (\Exception $e) {
  213. LogService::log(__METHOD__,__FUNCTION__,'批量创建 OrderPackageCommodities error'.json_encode($params)."||".$e->getMessage().'||'.$e->getTraceAsString());
  214. } finally {
  215. $order_package_ids = array_unique(data_get($params,'*.order_package_id'));
  216. unset($params);
  217. return OrderPackageCommodities::query()
  218. ->with('commodity')
  219. ->whereIn('order_package_id',$order_package_ids)
  220. ->get();
  221. }
  222. }
  223. public function updateByWmsOrder($orderHeaders){
  224. if(!$orderHeaders){return ;}
  225. /** @var DataHandlerService $dataHandlerService*/
  226. $dataHandlerService = app(DataHandlerService::class);
  227. $commodities = app(CommodityService::class)->getByWmsOrders($orderHeaders);
  228. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  229. $owners_id_map = $dataHandlerService->dataHeader(['id'],$owners);
  230. $owner_code_map = $dataHandlerService->dataHeader(['code'],$owners);
  231. $commodity_owner_id_sku_map = $dataHandlerService->dataHeader(['owner_id','sku'],$commodities);
  232. $commodities_owner_code_code_map = [];
  233. foreach ($commodities as $commodity) {
  234. $owner = $dataHandlerService->getKeyValue(['id'=>$commodity->owner_id],$owners_id_map);
  235. $commodities_owner_code_code_map[' owner_code='.$owner->code.' code='.$commodity->code] = $commodity;
  236. }
  237. $order_nos = data_get($orderHeaders,'*.orderno');
  238. $order_package_commodities = OrderPackageCommodities::query()->with('package.order','commodity')
  239. ->whereHas('package.order',function($query) use ($order_nos){
  240. $query->whereIn('code',$order_nos);
  241. })->get();
  242. $order_packages = OrderPackage::query()->with('order')->whereHas('order',function($query) use ($order_nos){
  243. $query->whereIn('code',$order_nos);
  244. })->get();
  245. $order_package_logistic_numbers_map = $dataHandlerService->dataHeader(['logistic_number'],$order_packages);
  246. $order_no_map = [];
  247. foreach ($order_package_commodities as $order_package_commodity) {
  248. $order = $order_package_commodity->package->order;
  249. $order_no_map[$order->code][] = $order_package_commodity;
  250. }
  251. $insertParams = [];
  252. $updateParams = [['id','order_package_id'.'commodity_id','amount','updated_at']];
  253. $updated_at = Carbon::now()->toDateTimeString();
  254. $created_at = Carbon::now()->toDateTimeString();
  255. foreach ($orderHeaders as $orderHeader) {
  256. $order_package_commodities = $order_no_map[$orderHeader->orderno] ?? false;
  257. $actAllocationDetails = $orderHeader->actAllocationDetails;
  258. $logistic_numbers = array_unique(array_diff(data_get($actAllocationDetails,'*.picktotraceid'),['','*',null])) ;
  259. if(!$order_package_commodities){
  260. $params = $this->getParamsByActAllocationDetails($actAllocationDetails,$order_package_logistic_numbers_map, $owner_code_map, $commodity_owner_id_sku_map, $logistic_numbers);
  261. foreach ($params as $param) {
  262. $insertParams[] = $param;
  263. }
  264. continue;
  265. }
  266. if($actAllocationDetails->count() > count($order_package_commodities)){
  267. $deleteKey = [];
  268. foreach ($actAllocationDetails as $key1=>$actAllocationDetail) {
  269. foreach ( $order_package_commodities as $key=>$item) {
  270. $commodity = $item->commodity;
  271. if($actAllocationDetail->sku == $commodity->sku && $item->amount == $actAllocationDetail->qty_each){
  272. unset($order_package_commodities[$key]);
  273. unset($actAllocationDetails[$key1]);
  274. $deleteKey[] = $key1;
  275. break;
  276. }else if($item ->sku == $commodity->sku && $item->amount != $actAllocationDetail->qty_each){
  277. $updateParams[] = [
  278. 'id' => $item->id,
  279. 'commodity_id' => $commodity->id,
  280. 'amount' => $actAllocationDetail->qty_each,
  281. 'updated_at' => $updated_at
  282. ];
  283. $deleteKey[] = $key1;
  284. unset($actAllocationDetails[$key1]);
  285. }
  286. }
  287. }
  288. $actAllocationDetails =$actAllocationDetails->filter(function ($value, $key) use($deleteKey) {
  289. return !in_array($key, $deleteKey);
  290. });
  291. $params = $this->getParamsByActAllocationDetails($actAllocationDetails,$order_package_logistic_numbers_map, $owner_code_map, $commodity_owner_id_sku_map, $logistic_numbers);
  292. foreach ($params as $param) {
  293. $insertParams[] = $param;
  294. }
  295. continue;
  296. }
  297. }
  298. if(count($updateParams) > 0){
  299. $this->batchUpdate($updateParams);
  300. }
  301. if(count($insertParams) > 0){
  302. try {
  303. $this->insert($insertParams);
  304. LogService::log(__METHOD__,__FUNCTION__,'批量添加 OrderPackageCommodities '. count($insertParams) .json_encode($insertParams));
  305. } catch (\Exception $e) {
  306. LogService::log(__METHOD__,__FUNCTION__,'批量添加 OrderPackageCommodities error'.json_encode($insertParams)."||".$e->getMessage().'||'.$e->getTraceAsString());
  307. }
  308. }
  309. }
  310. public function getByWmsOrder($orderHeaders){
  311. $order_no = data_get($orderHeaders,'*.orderno');
  312. return OrderPackageCommodities::query()
  313. ->with('package.order')
  314. ->whereHas('package.order',function($query) use ($order_no){
  315. $query->whereIn('code',$order_no);
  316. })->get();
  317. }
  318. public function batchUpdateItself($column, array $params)
  319. {
  320. return app(BatchUpdateService::class)->batchUpdateItself('order_package_commodities', $column, $params);
  321. }
  322. /**
  323. * @param array $logistic_numbers
  324. * @return array|mixed
  325. */
  326. public function 删除包裹商品信息_根据快递单号($logistic_numbers)
  327. {
  328. $orderPackageCommodities = OrderPackageCommodities::query()->with('package')->whereHas('package',function($query)use($logistic_numbers){
  329. $query->whereIn('logistic_number',$logistic_numbers);
  330. })->get();
  331. $ids = data_get($orderPackageCommodities, '*.id');
  332. if(count($ids) == 0){return [];}
  333. try {
  334. OrderPackageCommodities::query()->whereIn('id', $ids)->delete();
  335. LogService::log(__METHOD__,__FUNCTION__,'删除多余OrderPackageCommodities '.$orderPackageCommodities->count().json_encode($orderPackageCommodities),null);
  336. } catch (\Exception $e) {
  337. LogService::log(__METHOD__,__FUNCTION__,'删除多余OrderPackageCommodities error'.$orderPackageCommodities->count().json_encode($orderPackageCommodities).$e->getMessage().$e->getTraceAsString(),null);
  338. return [];
  339. }
  340. return $ids;
  341. }
  342. /**
  343. * @param array $orderNos
  344. * @return \Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection
  345. */
  346. public function getByOrderNos($orderNos)
  347. {
  348. return OrderPackageCommodities::query()->with('package.order','commodity')
  349. ->whereHas('package.order',function($query) use ($orderNos){
  350. $query->whereIn('code',$orderNos);
  351. })->get();
  352. }
  353. /**
  354. * @param Collection $orders
  355. * @return \Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection
  356. */
  357. public function getByOrders($orders)
  358. {
  359. return $this->getByOrderNos(data_get($orders,'*.code'));
  360. }
  361. /**
  362. * @param OracleDOCOrderHeader $orderHeader
  363. * @param Order $order
  364. * @return array|Collection|\Tightenco\Collect\Support\Collection
  365. */
  366. public function 返回创建数组($orderHeader,$order)
  367. {
  368. /** @var DataHandlerService $dataHandlerService */
  369. $dataHandlerService = app(DataHandlerService::class);
  370. if($orderHeader->sostatus == 90){return [];}
  371. $actAllocationDetails = $orderHeader->actAllocationDetails->collect();
  372. $orderPackages = $dataHandlerService->dataHeader(['logistic_number'],$order->packages);
  373. $innerParams = collect();
  374. $actAllocationDetails->each(function($detail)use($orderPackages,$dataHandlerService,$innerParams){
  375. $orderPackage = $dataHandlerService->getKeyValue(['logistic_number'=>$detail->picktotraceid],$orderPackages);
  376. $sku = $detail->sku;
  377. $amount = $detail->qty_each;
  378. $order_package_id = $orderPackage->id;
  379. $logistic_number = $orderPackage->logistic_number;
  380. $params = [
  381. 'ownerCode' > $detail->customerid,
  382. 'orderNo' => $detail->orderno,
  383. 'sku' => $sku,
  384. 'amount' => $amount,
  385. 'order_package_id' => $order_package_id,
  386. 'logistic_number' => $logistic_number,
  387. ];
  388. $innerParam = $innerParams->where('order_package_id',$orderPackage->id)->where('sku',$sku)->first();
  389. if(!$innerParam){
  390. $innerParams->push($params);
  391. }else{
  392. $innerParam['amount'] += $amount;
  393. }
  394. });
  395. return $innerParams;
  396. }
  397. /**
  398. * @param array $innerParams
  399. * @param OracleDOCOrderHeader $orderHeaders
  400. * @return array
  401. */
  402. public function 生成OrderPackageCommodities_基于创建数组($innerParams,$orderHeaders)
  403. {
  404. /** @var DataHandlerService $dataHandlerService */
  405. $dataHandlerService = app(DataHandlerService::class);
  406. $commodities = app(CommodityService::class)->getByWmsOrder($orderHeaders);
  407. $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
  408. $owner_id_map = $dataHandlerService->dataHeader(['id'],$owners);
  409. $commodities_owner_code_sku_map = [];
  410. foreach ($commodities as $commodity) {
  411. $owner_code = $dataHandlerService->getKeyValue(['id'=>$commodity->owner_id],$owner_id_map);
  412. $key = ' owner_code='.$owner_code.' sku='.$commodity->sku;
  413. $commodities_owner_code_sku_map[$key] = $commodity;
  414. }
  415. $dataTime = Carbon::now()->format('Y-m-d H:i:s');
  416. $createParams = [];
  417. foreach ($innerParams as $innerParam) {
  418. $key = ' owner_code='.$innerParam['ownerCode'].' sku='.$innerParam['sku'];
  419. $commodity = $commodities_owner_code_sku_map[$key] ?? null;
  420. $createParams[] = [
  421. 'order_package_id' => $innerParam['order_package_id'],
  422. 'commodity_id' => $commodity->id ?? null,
  423. 'amount' => $innerParam['amount'],
  424. 'created_at' => $dataTime,
  425. 'updated_at' => $dataTime,
  426. ];
  427. }
  428. return $createParams;
  429. }
  430. /**
  431. * @param OrderPackageCommodities $orderPackageCommodities
  432. * @return Collection|\Tightenco\Collect\Support\Collection
  433. */
  434. public function 将orderPackageCommodity抽象成数组($orderPackageCommodities)
  435. {
  436. /** @var DataHandlerService $dataHandlerService */
  437. $dataHandlerService = app(DataHandlerService::class);
  438. $collect = collect();
  439. $ownerIds = array_unique(data_get($orderPackageCommodities,'*.commodity.owner_id'));
  440. $owners = Owner::query()->whereIn('id',$ownerIds)->get();
  441. $owner_id_map = $dataHandlerService->dataHeader(['id'],$owners);
  442. foreach ($orderPackageCommodities as $orderPackageCommodity) {
  443. $owner = $dataHandlerService->getKeyValue(['id'=>$orderPackageCommodity->commodity->owner_id],$owner_id_map);
  444. $params = [
  445. 'id' => $orderPackageCommodity->id,
  446. 'ownerCode' => $owner->code,
  447. 'orderNo' => $orderPackageCommodity->package->order->code,
  448. 'sku' => $orderPackageCommodity->commodity->sku,
  449. 'amount' => $orderPackageCommodity->amount,
  450. 'order_package_id' => $orderPackageCommodity->package->id,
  451. 'logistic_number' => $orderPackageCommodity->package->logistic_number,
  452. ];
  453. $collect->push($params);
  454. }
  455. return $collect;
  456. }
  457. public function 数据重组(&$orderPackageCommoditiesCollect,&$params)
  458. {
  459. $collect_map = [];$params_map = [];$order_no_map = [];
  460. foreach ($orderPackageCommoditiesCollect as $item) {
  461. $orderNo = $item['orderNo'];
  462. if(!isset($collect_map[$orderNo])){$collect_map[$orderNo] = collect();}
  463. $collect_map[$orderNo]->push($item);
  464. }
  465. foreach ($params as $param) {
  466. $orderNo = $param['orderNo'];
  467. if(isset($params_map[$orderNo])){$params_map[$orderNo] = collect();}
  468. $order_no_map[] = $orderNo;
  469. $params_map[$orderNo]->push($param);
  470. }
  471. $order_no_map = array_unique($order_no_map);
  472. $orderPackageCommoditiesCollect = $collect_map;
  473. $params = $params_map;
  474. return $order_no_map;
  475. }
  476. /**
  477. * @param Collection $OPCCollects
  478. * @param array $paramsCollect
  479. */
  480. public function 删选出能保留的OrderPackageCommodities(&$OPCCollects,&$paramsCollect,$orderMap)
  481. {
  482. $retains = collect();
  483. foreach ($orderMap as $orderNo) {
  484. $OPCCollect = $OPCCollects[$orderNo];
  485. $params = $paramsCollect[$orderNo];
  486. }
  487. }
  488. public function 删选可以保留的OrderPackageCommodities(&$OPCCollect,&$params)
  489. {
  490. $retain = collect();
  491. $map = [];
  492. foreach ($params as $param) {
  493. $key = ' logistic_number='.$param['logistic_number'].' sku='.$param['sku'].' amount='.$param['amount'];
  494. if(!$map[$key] ?? false){
  495. $map[$key] = [];
  496. }
  497. $map[$key][] = $param;
  498. }
  499. foreach ($OPCCollect as $item) {
  500. $key = ' logistic_number='.$item['logistic_number'].' sku='.$item['sku'].' amount='.$item['amount'];
  501. if(isset($map[$key])){
  502. $value = $map[$key][0];
  503. array_shift($map);
  504. $params->filter(function($param)use($value){
  505. return count(array_diff_assoc($param,$value)) != 0 ;
  506. });
  507. $retain->push($value);
  508. }
  509. }
  510. return $retain;
  511. }
  512. //
  513. // public function 删选需要修改的OrderPackageCommodities(&$OPCCollect,&$params)
  514. // {
  515. // $update = collect();
  516. // $map = [];
  517. // foreach ($OPCCollect as $item) {
  518. // $key = ' logistic_number='.$item['logistic_number'].' sku='.$item['sku'];
  519. // if(!isset($map[$key])){
  520. // $map[$key] = [];
  521. // }
  522. // $map[$key][] = $item;
  523. // }
  524. //
  525. // foreach ($params as $param) {
  526. // $key = ' logistic_number='.$param['logistic_number'].' sku='.$param['sku'];
  527. // if(isset($map[$key])){
  528. //
  529. // }
  530. // }
  531. // }
  532. }