baoshi-was/app/Services/OrderTrackingService.php

<?php

namespace App\Services;

use App\Exports\Export;
use App\OracleDOCOrderHeader;
use App\OrderPackageCommodities;
use App\OrderTracking;
use App\Services\common\BatchUpdateService;
use App\Services\common\QueryService;
use Illuminate\Support\Facades\Auth;
use Maatwebsite\Excel\Facades\Excel;

class OrderTrackingService
{
    public function insert($params){
        return OrderTracking::query()->insert($params);
    }

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

    public function getQuery($params)
    {
        $user = Auth::user();
        $owner_ids = $user ? $user->getPermittingOwnerIdsAttribute() : [];
        if ($params['owner_id'] ?? false) {
            $ownerids = explode(",", $params['owner_id']);
            $owner_ids = array_intersect($owner_ids, $ownerids);
        }
        $query = OrderTracking::query()->with(['owner', 'commodities' => function ($query) {
            $query->with(['commodity', 'package.order.logistic']);
        },])->whereHas('owner', function ($query) use ($owner_ids) {
            $query->whereIn('id', $owner_ids); //货主
        })->orderByDesc('created_at');

        $queryParam = [
            'start_at' => ['alias' => 'pick_up_at', 'startDate' => ' 00:00:00'],
            'end_at' => ['alias' => 'pick_up_at', 'endDate' => ' 23:59:59'],
        ];
        $param = [
            'start_at' => $params['start_at'] ?? '',
            'end_at' => $params['end_at'] ?? '',
        ];

        $query = app(QueryService::class)->query($param, $query, $queryParam);
        return $query;
    }

    public function getConditionQuery($params)
    {
        $query = $this->getQuery($params);

        if (isset($params['client_code'])|| isset($params['logistic_id'])){     // client_code logistic
            $query->whereHas('commodities.package.order', function ($query) use ($params) {
                if($params['client_code'] ?? false){
                    $query->where('client_code','like', $params['client_code']);
                }
                if(isset($params['logistic_id']) ){
                    $query->where('logistic_id',$params['logistic_id']);
                }
            });
        }

        if ($params['client'] ?? false)  // 客户
            $query->where('client', 'like', $params['client']);

        if ($params['sku'] ?? false) {
            $query->whereHas('commodities.commodity', function ($query) use ($params) {
                $query->where('sku', $params['sku']);
            });
        }  // sku

        if ($params['logistic_number'] ?? false) {
            $query->whereHas('commodities.package', function ($query) use ($params) {
                $query->where('logistic_number', $params['logistic_number']);
            });
        }// 运输单号（快递单号）

        if ($params['ids'] ?? false) {
            $ids = explode(',', $params['ids']);
            $query->whereIn('id', $ids);
        }

        return $query;
    }

    public function paginate($params)
    {
        return $this->getConditionQuery($params)->paginate($params['paginate'] ?? 50);
    }

    public function export($params)
    {
        if ($params['data'] ?? false) { // 按id
            $trackOrders = $this->getConditionQuery($params);
        } else {
            $trackOrders = $this->getConditionQuery($params);
        }
        return $this->downLoadAsExec($trackOrders->get());
    }

    public function 根据设置从WMS同步追踪货主的订单($startDate)
    {
        $this->根据设置从WMS追踪货主的生成订单($startDate);
        $this->根据设置从该时间段内获取WMS更新的订单($startDate);

    }

    public function 根据设置从WMS追踪货主的生成订单($startDate)
    {
        /** @var OrderService $orderService */
        $orderService = app('orderService');
        $params = $orderService->根据设置从WMS获取跟踪的订单($startDate);
        $orders = $params['orders'];
        $orderHeaders = $params['orderHeaders'];
        $this->根据订单生成订单跟踪($orderHeaders, $orders);

    }

    public function 根据设置从该时间段内获取WMS更新的订单($startDate)
    {
        /** @var OrderService $orderService */
        $orderService = app('orderService');
        $params = $orderService->根据设置从WMS同步该时间段内更新的订单($startDate);
        $orderPackageCommodities = $params['orderPackageCommodities'];
        $orderHeaders = $params['orderHeaders'];
        $this->更新创建的WAS订单商品跟踪($orderPackageCommodities, $orderHeaders);
    }

    //  XXX 代码逻辑有待纠正
    public function 更新创建的WAS订单商品跟踪($updateOrderPackageCommodities, $updateOrderHeader)
    {
        if ($updateOrderPackageCommodities == null || $updateOrderPackageCommodities->count() == 0) {
            return;
        }
        if ($updateOrderHeader == null || count($updateOrderHeader) == 0) {
            return;
        }
        $ids = data_get($updateOrderPackageCommodities, '*.id');

        $orderTrackings = OrderTracking::query()->whereIn('order_package_commodity_id', $ids)->get();


        $this->updateOrderTracking($orderTrackings, $updateOrderPackageCommodities); // 更新

        unset($updateOrderPackageCommodities, $updateOrderHeader);
    }

    public function 根据订单生成订单跟踪($orderHeaders, $orders)

    {
        $orderPackages = [];
        $orderPackageCommodities = [];
        $ordersList = [];
        $fillables = [];
        if($orders == null){
            return;
        }else if($orderHeaders == null){
            return ;
        }

        foreach ($orders as $order) {
            $ordersList[$order['id']] = $order;
            foreach ($order['packages'] as $packages) {
                $orderPackages[$packages['id']] = $packages;
                foreach ($packages['commodities'] as $item) {
                    $orderPackageCommodities[] = $item;
                }
            }
        }
        if (count($orderPackageCommodities) == 0) {
            return;
        }

        foreach ($orderPackageCommodities as $key=>$orderPackageCommodity) {
            $order_package_id = $orderPackageCommodity['order_package_id'];
            $orderPackage = $orderPackages[$order_package_id];
            $order_id = $orderPackage['order_id'] ?? '';
            $order = $ordersList[$order_id] ?? '';
            $orderHeader = $orderHeaders[$order['code']];
            $pick_up_at = $orderHeader['lastshipmenttime'] ?? null; // 提货时间

            $client = null;
            $order_remark = null;

            if ($orderHeader['notes'] ?? false) {
                $notes = $orderHeader['notes'];
//                $notes = str_replace('【','[',$notes);
                if (strpos($notes, '[')) {
                    $arr= str_split($notes,strpos($notes,'['));
                    $client = $arr[0] ?? '';
                    $order_remark = $arr[1] ?? '';
                    $order_remark = str_replace(['[',']'],'',$order_remark);
                }
            }

            $fillable = [
                'order_package_commodity_id' => $orderPackageCommodity['id'],
                'owner_id' => $order['owner_id'],
                'client' => $client,
                'created_at' => $order['created_at'],
                'order_remark' => $order_remark,
                'pick_up_at' => $pick_up_at, // 提货时间
            ];

            $fillables[] = $fillable;
         }
        try {
            if (count($fillables) > 0) {
                OrderTracking::query()->insert($fillables);
                LogService::log(__METHOD__, __FUNCTION__, '批量创建订单跟踪成功' . count($fillables) . json_encode($fillables));
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__, '批量创建订单跟踪失败' . $e->getMessage() . $e->getTraceAsString());
        } finally {
            unset($fillables, $orderHeaders, $orders,$orderPackageCommodities);
        }
    }

    private function downLoadAsExec($trackOrders)
    {
        $row = [[
            'owner_name' => '公司', 'order_client_code' => '订单号', 'web_order_number' => 'WEB+订单号', 'pick_up_at' => '提货日期', 'sale' => '销售',
            'client' => '客户', 'sku' => 'sku', 'sku_name' => '物料描述', 'sku_amount' => '数量', 'order_remark' => '订单备注',
            'package_weight' => '重量', 'package_bulk' => '体积', 'pallet_total' => '托盘合计', 'package_logistic' => '运输方式', 'package_logistic_number' => '运输单号',
            'order_city' => '到达城市', 'planning_sent_at' => '应送达时间', 'is_on_duty_shift' => '是否赶上卡班', 'is_arrival' => '到货情况', 'signed_at' => '签收日期',
            'receive_bill_status' => '签收单情况', 'remark' => '备注']];

        $list = [];
        $i = 0;

        foreach ($trackOrders as $trackOrder) {
            $list[$i]['owner_name'] = $trackOrder['owner']['name'] ?? '';
            $list[$i]['order_client_code'] = $trackOrder['commodities']['package']['order']['client_code'] ?? '';
            $list[$i]['web_order_number'] = $trackOrder['web_order_number'] ?? '';
            $list[$i]['pick_up_at'] = $trackOrder['pick_up_at'] ?? '';
            $list[$i]['sale'] = $trackOrder['sale'] ?? '';
            $list[$i]['client'] = $trackOrder['client'] ?? '';
            $list[$i]['sku'] = $trackOrder['commodities']['commodity']['sku'];
            $list[$i]['sku_name'] = $trackOrder['commodities']['commodity']['name'];
            $list[$i]['sku_amount'] = $trackOrder['commodities']['amount'];
            $list[$i]['order_remark'] = $trackOrder['order_remark'];
            $list[$i]['package_weight'] = $trackOrder['commodities']['package']['weight'];
            $list[$i]['package_bulk'] = $trackOrder['commodities']['package']['bulk'];
            $list[$i]['pallet_total'] = $trackOrder['commodities']['package']['pallet_total'];
            $list[$i]['package_logistic'] = $trackOrder['commodities']['package']['order']['logistic']['name'];
            $list[$i]['package_logistic_number'] = $trackOrder['commodities']['package']['logistic_number'];
            $list[$i]['order_city'] = $trackOrder['commodities']['package']['order']['city'];
            $list[$i]['planning_sent_at'] = $trackOrder['planning_sent_at'];
            $list[$i]['is_on_duty_shift'] = $trackOrder['is_on_duty_shift'];
            $list[$i]['is_arrival'] = $trackOrder['is_arrival'];
            $list[$i]['signed_at'] = $trackOrder['signed_at'];
            $list[$i]['receive_bill_status'] = $trackOrder['receive_bill_status'];
            $list[$i]['remark'] = $trackOrder['remark'];
            $i++;
        }

        return Excel::download(new Export($row, $list), date('YmdHis', time()) . '-订单跟踪.xlsx');
    }

    private function updateOrderTracking($orderTrackings, $orderPackagesCommodities)
    {
        $multipleData = [['id', 'owner_id', 'client', 'pick_up_at','web_order_number']];
        $orderTrackings_list = [];

        foreach ($orderPackagesCommodities as $item) {
            $orderTrackings_list[$item['order_package_commodity_id']] = $item;
        }

        foreach ($orderTrackings as $orderTracking) {
            $Commodities = $orderTrackings_list[$orderTracking['order_package_commodity_id']] ?? false;
            $order = $Commodities['package']['order'] ?? '';

            if ($order ?? false) {
                $code = $order['code'];
                $orderHeader = $orderPackagesCommodities[$code] ?? '';
                $pick_up_at = $orderHeader['lastshipmenttime'] ?? null; // 提货时间

                $client = null;
                $order_remark = null;

                if ($orderHeader['notes'] ?? false) {
                    $notes = $orderHeader['notes'];
//                $notes = str_replace('【','[',$notes);
                    if (strpos($notes, '[')) {
                        $arr= str_split($notes,strpos($notes,'['));
                        $client = $arr[0] ?? '';
                        $order_remark = $arr[1] ?? '';
                        $order_remark = str_replace(['[',']'],'',$order_remark);
                    }
                }
                $web_order_number = null;
                if(preg_match('/^O[\d]/',$orderHeader['orderno'] ?? '') > 0){
                    $web_order_number = $orderHeader['soreference1'];
                }
                $data = [
                    'id' => $orderTracking['id'],
                    'owner_id' => $order['owner_id'] ?? '',
                    'client' => $client,
                    'pick_up_at' => $pick_up_at ?? null, // 提货时间
                    'order_remark' => $order_remark,
                    'web_order_number' => $web_order_number,
                ];

                if ($data['owner_id'] !== $orderTracking['owner_id'] ||
                    $data['client'] !== $orderTracking['client'] ||
                    $data['pick_up_at'] !== $orderTracking['pick_up_at'] ||
                    $data['order_remark'] !== $orderTracking['order_remark'] ||
                    $data['web_order_number'] !==  $orderTracking['web_order_number']
                ) {
                    $multipleData[] = $data;
                }
            }
        }

        if (count($multipleData) > 1) {
            /** @var BatchUpdateService $batchUpdateService */
            $batchUpdateService = app('batchUpdateService');
            $batchUpdateService->batchUpdate('order_trackings', $multipleData);
        }
    }


    /**
     * @param $startData
     */
    public function trackingWmsOrder($startData){
        $this->trackingWmsOrderOnCreate($startData);
        $this->trackingWmsOrderOnEdit($startData);
    }

    public function trackingWmsOrderOnCreate($startData){
        /** @var OrderService $orderSerivce */
        $orderService = app(OrderService::class);
        /** @var OracleDOCOrderHeader $orderHeaders */
        $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateCreate($startData);
        $orderService->createByWmsOrder($orderHeaders);
        $this->createByWmsOrderHeader($orderHeaders);
    }

    public function trackingWmsOrderOnEdit($startData){
        /** @var OrderService $orderService */
        $orderService = app(OrderService::class);
        /** @var OracleDOCOrderHeader $orderHeaders */
        $orderHeaders = app(OracleDOCOrderHeaderService::class)->getWmsOrderOnStartDateEdit($startData);
        $orderService->updateByWmsOrders($orderHeaders);
        $this->updateByWmsOrderHeaders($orderHeaders);
    }

    public function updateOrderTracingAndSyc($id,$param,$value){
        $order_tracking = OrderTracking::query()
            ->with('commodities.package.order')
            ->where('id', $id)
            ->first();
        $order_id = $order_tracking->commodities->package->order->id ?? false;
        if(!$order_id){return ['success'=> false];}
        $bool= OrderTracking::query()
            ->whereHas('commodities.package.order', function ($query) use ($order_id) {
                $query->where('id', $order_id);
            })->update([$param=>$value]);
        return ['success'=> $bool];
    }

    public function createByWmsOrderHeader($orderHeaders)
    {
        if(!$orderHeaders){return;}
        $order_nos = data_get($orderHeaders,'*.orderno');
        $order_package_commodities  = OrderPackageCommodities::query()
            ->with('package.order')
            ->whereHas('package.order',function($query) use ($order_nos){
                $query->whereIn('code',$order_nos);
            })->get();
        $order_package_commodities_ids = data_get($order_package_commodities,'*.id');
        $order_trackings = OrderTracking::query()->whereIn('order_package_commodity_id',$order_package_commodities_ids)->get();
        $is_exist_ids = data_get($order_trackings,'*.order_package_commodity_id');

        $order_package_commodities = $order_package_commodities->filter(function($item) use ($is_exist_ids){
            $id = $item->id;
            return !in_array($id,$is_exist_ids);
        });

        if($order_package_commodities->count() == 0){return ;}

        $order_headers_map = [];
        foreach ($orderHeaders as $item) {
            $order_headers_map[$item->orderno] = $item;
        }

        $params = [];
        foreach ($order_package_commodities as $item) {
            $order = $item->package->order;
            if(!$order){continue ;}
            $order_header = $order_headers_map[$order->code];
            if(!$order_header){continue ;}

            $client = null;
            $order_remark = null;
            if ($order_header['notes'] ?? false) {
                $notes = $order_header->notes;
                if (strpos($notes, '[')) {
                    $arr= str_split($notes,strpos($notes,'['));
                    $client = $arr[0] ?? '';
                    $order_remark = $arr[1] ?? '';
                    $order_remark = str_replace(['[',']'],'',$order_remark);
                }
            }
            $web_order_number = null;
            if(preg_match('/^O[\d]/',$order_header['soreference1'] ?? '') > 0){
                $web_order_number = $order_header['soreference1'];
            }

            $params[] =[
                'order_package_commodity_id' => $item->id,
                'owner_id' => $order->owner_id,
                'client' => $client,
                'created_at' => $order->created_at,
                'order_remark' => $order_remark,
                'pick_up_at' => $order_header->lastshipmenttime, // 提货时间,
                'web_order_number' => $web_order_number
            ];
        }

        try {
            if (count($params) > 0) {
                OrderTracking::query()->insert($params);
                LogService::log(__METHOD__, __FUNCTION__, '批量添加 orderTracking' . json_encode($params),null);
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__, '批量添加 orderTracking' . json_encode($params).$e->getMessage().$e->getTraceAsString(),null);
        }
    }

    public function updateByWmsOrderHeaders($orderHeaders)
    {
        if(!$orderHeaders){return ;}
        $order_nos = data_get($orderHeaders,'*.orderno');
        $order_package_commodities = OrderPackageCommodities::query()
            ->with('package.order')
            ->whereHas('package.order',function($query) use ($order_nos){
                $query->whereIn('code',$order_nos);
            })->get();
        $orderTrackings = OrderTracking::query()->whereIn('order_package_commodity_id',data_get($order_package_commodities,'*.id'))->get();
        $order_tracking_id_map = [];
        foreach ($orderTrackings as $orderTracking) {
            $order_tracking_id_map[$orderTracking->order_package_commodity_id] = $orderTracking;
        }
//        $is_exist_ids = data_get($orderTrackings,'*.order_package_commodity_id');
//        $order_package_commodities = $order_package_commodities->filter(function($order_package_commodity) use($is_exist_ids){
//           return !in_array($order_package_commodity->id,$is_exist_ids);
//        });
        $order_package_commodity_order_code_map = [];
        $order_code_map = [];
        foreach ($order_package_commodities as $order_package_commodity) {
            $order =$order_package_commodity->package->order;
            if(!$order){continue;}
            $order_code_map[$order->code] = $order;
            $order_package_commodity_order_code_map[$order->code][] = $order_package_commodity;
        }

//        $insert_params = [];
//        foreach ($orderHeaders as $orderHeader) {
//            $order_package_commodity_list = $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
//            if(!$order_package_commodity_list){continue;}
//            $order = $order_code_map[$orderHeader->orderno];
//            $params = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
//            foreach ($order_package_commodity_list as $item) {
//                $params['order_package_commodity_id'] = $item->id;
//                $insert_params = $params;
//            }
//        }
        $update_params = [];
        $update_params[0] =['id','client','pick_up_at','order_remark'];
        foreach ($orderHeaders as $orderHeader) {
            $order_package_commodity_list = $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;

            if(!$order_package_commodity_list){continue;}
            $order = $order_code_map[$orderHeader->orderno];

            foreach ($order_package_commodity_list as $order_package_commodity) {
                $order_tracking = $order_tracking_id_map[$order_package_commodity->id]??false;
                if(!$order_tracking){continue;}

                $params = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);

                if($order_tracking->owner_id != $params['owner_id'] ||
                    $order_tracking->client !=$params['client'] ||
                    $order_tracking->order_remark != $params['order_remark'] ||
                    $order_tracking->pick_up_at != $params['pick_up_at']){
                    $update_params[] = [
                        'id' => $order_tracking->id,
                        'client' => $params['client'],
                        'pick_up_at' => $params['pick_up_at'],
                        'order_remark' => $params['order_remark'],
                        'web_order_number' => $params['web_order_number'],
                    ];
                }
            }
        }

        if(count($update_params) > 1){
            $this->batchUpdate($update_params);
        }

        $is_exist_ids = data_get($orderTrackings,'*.order_package_commodity_id');
        $order_package_commodities = $order_package_commodities->filter(function($order_package_commodity) use($is_exist_ids){
            return !in_array($order_package_commodity->id,$is_exist_ids);
        });
        $order_package_commodity_order_code_map = [];
        $order_code_map = [];
        foreach ($order_package_commodities as $order_package_commodity) {
            $order =$order_package_commodity->package->order;
            if(!$order){continue;}
            $order_code_map[$order->code] = $order;
            $order_package_commodity_order_code_map[$order->code][] = $order_package_commodity;
        }
        $insert_params = [];
        foreach ($orderHeaders as $orderHeader) {
            $order_package_commodity_list = $order_package_commodity_order_code_map[$orderHeader->orderno] ?? false;
            if(!$order_package_commodity_list){continue;}
            $order = $order_code_map[$orderHeader->orderno];
            $params = $this->getParamsByOrderHeaderAndOrder($orderHeader,$order);
            foreach ($order_package_commodity_list as $item) {
                $params['order_package_commodity_id'] = $item->id;
                $insert_params[] = $params;
            }
        }
        if(count($insert_params) > 0){
            try {
                $this->insert($insert_params);
                LogService::log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking '.count($insert_params).json_encode($insert_params));
            } catch (\Exception $e) {
                LogService::log(__METHOD__,__FUNCTION__,'批量添加 OrderTracking error'.json_encode($insert_params) .'||'.$e->getMessage(),'||'.$e->getTraceAsString());
            }
        }
    }

    public function getParamsByOrderHeaderAndOrder($orderHeader,$order){

        $client = null;
        $order_remark = null;
        if ($orderHeader['notes'] ?? false) {
            $notes = $orderHeader->notes;
            if (strpos($notes, '[')) {
                $index = strpos($notes, '[');
                $client = substr($notes,0,$index);
                $order_remark = substr($notes,$index);
                $order_remark = ltrim($order_remark,'[');
                $order_remark = rtrim($order_remark,']');
            }
        }
        $web_order_number = null;
        if(preg_match('/^O[\d]/',$order_header['soreference1'] ?? '') > 0){
            $web_order_number = $order_header['soreference1'];
        }
        return [
            'owner_id' => $order->owner_id,
            'client' => $client,
            'created_at' => $order->created_at,
            'order_remark' => $order_remark,
            'pick_up_at' => $orderHeader->lastshipmenttime, // 提货时间
            'web_order_number' =>$web_order_number
        ];
    }


}