baoshi-was/app/Services/OrderTrackingService.php

<?php

namespace App\Services;

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

class OrderTrackingService
{

    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', $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,$updateOrderHeader); // 更新

        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,$orderHeaders)
    {
        $multipleData = [['id', 'owner_id', 'client', 'pick_up_at','order_remark']];
        $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 = $orderHeaders[$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);
                    }
                }

                $data = [
                    'id' => $orderTracking['id'],
                    'owner_id' => $order['owner_id'] ?? '',
                    'client' => $client,
                    'pick_up_at' => $pick_up_at ?? null, // 提货时间
                    'order_remark' => $order_remark,
                ];

                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']
                ) {
                    $multipleData[] = $data;
                }
            }
        }

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

    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];
    }
}