baoshi-was/app/Services/OrderPackageCommoditiesService.php

<?php

namespace App\Services;

use App\Commodity;
use App\OracleActAllocationDetails;
use App\OracleBasSKU;
use App\OracleDOCOrderDetail;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderPackage;
use App\OrderPackageCommodities;
use App\OrderTracking;
use App\Owner;
use App\Services\common\BatchUpdateService;
use App\Services\common\DataHandlerService;
use Carbon\Carbon;
use Illuminate\Support\Collection;

class OrderPackageCommoditiesService
{
    public function insert(array $params){
        return OrderPackageCommodities::query()->insert($params);
    }

    public function batchUpdate($params){
        return app(BatchUpdateService::class)->batchUpdate('order_package_commodities',$params);
    }

    public function create(array $params){
        if(!$params){return [];}
        try {
            $this->insert($params);
            app('LogService')->log(__METHOD__,__FUNCTION__,'批量创建 OrderPackageCommodities'.count($params).json_encode($params));
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__,__FUNCTION__,'批量创建 OrderPackageCommodities error'.json_encode($params)."||".$e->getMessage().'||'.$e->getTraceAsString());
        } finally {
            $order_package_ids = array_unique(data_get($params,'*.order_package_id'));
            unset($params);
            return OrderPackageCommodities::query()
                ->with('commodity')
                ->whereIn('order_package_id',$order_package_ids)
                ->get();
        }
    }

    public function getByWmsOrder($orderHeaders){
        $order_no =  data_get($orderHeaders,'*.orderno');
        return OrderPackageCommodities::query()
            ->with('package.order','commodity')
            ->whereIn('order_package_id',function($query) use ($order_no){
                $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($order_no){
                    $query->from('orders')->select('id')->whereIn('code',$order_no);
                });
            })->get();
    }

    public function batchUpdateItself($column, array $params)
    {
        return app(BatchUpdateService::class)->batchUpdateItself('order_package_commodities', $column, $params);
    }

    public function getByOrderNos($orderNos)
    {
        return OrderPackageCommodities::query()->with('package.order','commodity')
            ->whereIn('order_package_id',function($query) use ($orderNos){
                $query->from('order_packages')->select('id')->whereIn('order_id',function($query)use($orderNos){
                    $query->from('orders')->select('id')->whereIn('code',$orderNos);
                });
            })->get();
    }

    public function syncOrderPackageCommodities($orderHeaders)
    {
        $this->syncOrderPackageCommoditiesByOrderHeaders($orderHeaders);
    }

    public function syncOrderPackageCommoditiesByOrderHeaders(&$orderHeaders)
    {
        /**
         * @var DataHandlerService $dataHandService
         * @var CommodityService $commodityService
         * @var OrderPackageService $orderPackageService
         * @var OwnerService $ownerService
         */
        $dataHandService = app('DataHandlerService');
        $commodityService = app('CommodityService');
        $orderPackageService  = app( 'OrderPackageService');
        $ownerService  = app( 'OwnerService');
        if(!$orderHeaders)return ;

        $owner_codes = [];$sku_codes = [];$map = [];
        foreach ($orderHeaders as $orderHeader) {
            $Order_Details = $orderHeader->oracleDOCOrderDetails;
            $Order_Details->each(function($item)use(&$owner_codes,&$sku_codes,&$map){
                $owner_codes[$item['customerid']] = $item['customerid'];
                $sku_codes[$item['sku']] = $item['sku'];
                $value = [
                    'owner_code'=> $item['customerid'],
                    'sku' => $item['sku']
                ];
                $key = json_encode($value);
                $map[$key] = $value;
            });
        }
        if(count($owner_codes) ==0 || count($sku_codes) == 0)return ;
        $owners = $ownerService->getOwnerByCodes($owner_codes);
        $commodities = $commodityService->getCommoditiesByMaps($map);   // 预先处理     3s
        $orderPackages = $orderPackageService->getByWmsOrders($orderHeaders);
        $orderCommodities = $this->getByWmsOrder($orderHeaders);
        $owner_id_map=[];
        foreach ($owners as $owner) {
            $owner_id_map[$owner['id']] = $owner;
        }

        $package_map = $dataHandService->dataHeader(['logistic_number'],$orderPackages);

        $orderCommodities = $this->regroupOrderCommodities($orderCommodities);

        $orderAllocationDetails = $this->regroupWmsOrderAllocationDetails($orderHeaders);
        $del_orderCommodities  =[];

        $update_params =$this->filterUpdateParams($orderAllocationDetails,$orderCommodities,$del_orderCommodities);                  // 修改

        $inner_params = $this->filterInnerParams($orderAllocationDetails,$orderCommodities);                                            // 创建

        $delete_params = $this->filterDeleteParams($orderAllocationDetails,$orderCommodities);                                           // 删除
        unset($orderAllocationDetails,$orderCommodities);
        if(count($inner_params)>0)
            $this->createOrderCommodities($inner_params,$package_map,$commodities,$owner_id_map);  // 创建 3s
        unset($inner_params,$package_map,$commodities,$owner_id_map);
        if(count($update_params)>0)
            $this->updateOrderCommodities($update_params);              // 更新
        unset($update_params);
        if(count($delete_params)>0)
            $this->deleteOrderCommodities($delete_params);              // 删除
        unset($delete_params);
        if(count($del_orderCommodities)>0)
            $this->deleteOrderCommodities($del_orderCommodities);       // 删除
        unset($del_orderCommodities);
    }

    public function regroupOrderCommodities(&$orderCommodities)
    {
        $params = [];
        $orderCommodities->each(function($orderCommodity)use(&$params){
            $order_no = $orderCommodity->package->order->code ?? '';
            $logistic_number = $orderCommodity->package->logistic_number ?? '';
            $sku = $orderCommodity->commodity->sku ?? '';
            $key = ' orderno='.$order_no.' logsitic_number='.$logistic_number.' sku='.$sku.' ';
            $params[$key][] = [
                'id' =>$orderCommodity->id,
                'orderno'=>$order_no,
                'logistic_number'=>$logistic_number,
                'sku' => $sku,
                'amount' => $orderCommodity->amount,
                'order_package_id'=>$orderCommodity->package->id ?? '',
                'commodity_id'=>$orderCommodity->commodity->id ?? '',
            ];
        });
        return $params;
    }

    public function regroupWmsOrderAllocationDetails(&$orderHeaders)
    {
        /**
         * @var OracleDOCOrderHeader $orderHeader
         */
        $params =[];
        foreach ($orderHeaders as $orderHeader) {
            $order_no = $orderHeader->orderno;
            $actAllocationDetails = $orderHeader->actAllocationDetails ?? [];
            $actAllocationDetails->each(function($item)use(&$params,$order_no){
                $logistic_number = $item->picktotraceid;
                $sku = $item->sku;
                $key = ' orderno='.$order_no.' logsitic_number='.$logistic_number.' sku='.$sku.' ';
                if(isset($params[$key])){
                    $params[$key]['amount']+= $item->qty_each;
                }else{
                    $params[$key] = [
                        'orderno'=>$item->orderno,
                        'logistic_number'=>$item->picktotraceid,
                        'sku' => $sku,
                        'amount' => $item->qty_each,
                        'owner_code' => $item->customerid
                    ];
                }
            });
        }
        return $params;
    }

    public function filterUpdateParams(&$orderAllocationDetails,&$orderCommodities,&$del_orderCommodities)
    {
        $update_params = [];
        foreach ($orderCommodities as $key=>$orderCommodity) {
            if(isset($orderAllocationDetails[$key])){
                if(count($orderCommodity) == 1  && $orderAllocationDetails[$key]['amount'] != $orderCommodity[0]['amount']){
                    $update_params[$key] = $orderCommodity[0];
                    $update_params[$key]['amount'] = $orderAllocationDetails[$key]['amount'];
                }elseif(count($orderCommodity)>1){
                    $update_params[$key] = array_shift($orderCommodity);
                    $update_params[$key][0]['amount'] = $orderAllocationDetails[$key]['amount'];
                    collect($orderCommodity)->each(function($item)use(&$del_orderCommodities){
                        $del_orderCommodities[] = $item;
                    });
                }
                unset($orderCommodities[$key],$orderAllocationDetails[$key]);
            }
        }
        return $update_params;
    }

    public function filterInnerParams(&$orderAllocationDetails,&$orderCommodities)
    {
        $inner_params = [];
        foreach ($orderAllocationDetails as $key=>$orderAllocationDetail) {
            if(!($orderCommodities[$key] ?? false)){
                $inner_params[] = $orderAllocationDetail;
                unset($orderCommodities[$key],$orderAllocationDetail);
            }
        }
        return $inner_params;
    }

    public function filterDeleteParams(&$orderAllocationDetails,&$orderCommodities)
    {
        $del_params = [];
        foreach ($orderCommodities as $key => $orderCommodity) {
            if(!isset($orderAllocationDetails[$key])){
                collect($orderCommodity)->each(function ($item)use(&$del_params){
                    $del_params[] = $item;
                });
                unset($orderCommodities[$key]);
            }
        }
        return $del_params;
    }

    public function createOrderCommodities(&$inner_params,&$package_map,&$commodities,&$owner_id_map)
    {
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService  = app('DataHandlerService');
        $commodity_map = (function()use(&$commodities,&$owner_id_map){
            $map = [];
            foreach ($commodities as $commodity) {
                $owner = $owner_id_map[$commodity['owner_id']] ;
                $key = ' owner='.$owner->code.' sku='.$commodity->sku;
                $map[$key] = $commodity;
            }
            return $map;
        })();
        $create_params =[];
        $date = Carbon::now();
        foreach ($inner_params as $inner_param) {
            if($inner_param['logistic_number'] === '*' || $inner_param['logistic_number'] === ' ')continue;
            $package = $dataHandlerService->getKeyValue(['logistic_number'=>$inner_param['logistic_number']],$package_map);
            if(!$package)continue;
            $commodity = $commodity_map[' owner='.$inner_param['owner_code'].' sku='.$inner_param['sku']] ?? null;
            $create_params[] = [
                'order_package_id'=>$package->id,
                'commodity_id'=>$commodity->id ?? null,
                'amount' => $inner_param['amount'],
                'created_at' => $date,
                'updated_at' => $date
            ];
        }
        if(count($create_params)>0){
            $inner_array = array_chunk($create_params,5000);
            foreach ($inner_array as $item) {
                try {
                    $bool = $this->insert($item);
                    LogService::log(__METHOD__, __FUNCTION__, '批量添加 orderCommodity ' . ($bool > 0 ? 'SUCCESS' : 'FAULT') . " || " . count($item) . ' || ' . json_encode($create_params));
                } catch (\Exception $e) {
                    LogService::log(__METHOD__,__FUNCTION__.'error','批量添加 orderCommodity ERROR'." || ".count($item).' || '.json_encode($item). ' || '.json_encode($e->getMessage()). ' || '.json_encode($e->getTraceAsString()));
                }
            }
        }
        unset($create_params,$commodity_map);
    }

    public function updateOrderCommodities(&$orderCommodities)
    {
        if(!$orderCommodities)return ;
        $updated_at = Carbon::now();
        $update_params = [['id','order_package_id','commodity_id','amount','updated_at']];
        foreach ($orderCommodities as $orderCommodity) {
            $update_params[] = [
                'id' => $orderCommodity['id'] ?? '',
                'order_package_id'=>$orderCommodity['order_package_id'] ?? '',
                'commodity_id'=>$orderCommodity['commodity_id'] ?? '',
                'amount' => $orderCommodity['amount'],
                'updated_at' => $updated_at
            ];
        }
        if(count($update_params)>1)
            $this->batchUpdate($update_params);

        unset($update_params);
    }

    public function deleteOrderCommodities(&$orderCommodities){
        /** @var OrderTrackingService $orderTrackingService */
        $orderTrackingService = app('OrderTrackingService');
        if(!$orderCommodities)return;
        if(count($orderCommodities)==0)return;
        try {
            $ids = data_get($orderCommodities, '*.id');
            if(count($ids) >0){
                $bool = OrderPackageCommodities::query()->whereIn('id', $ids)->delete();
                $orderTrackings = OrderTracking::query()->whereIn('order_package_commodity_id',$ids)->get();
                $orderTrackingService->deleteOrderTracings($orderTrackings);
                LogService::log(__METHOD__, __FUNCTION__, '批量删除 OrderCommodity '  . ($bool > 0 ? 'SUCCESS' : 'FAULT') .'||' .count($orderCommodities)  . ' || ' . json_encode($orderCommodities));
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__.' error', '批量删除 OrderCommodity Error' . ' || ' . json_encode($e->getMessage()) . ' || ' . json_encode($e->getTraceAsString()));
        }
        unset($orderCommodities);
    }
}