baoshi-was/app/Services/OrderPackageService.php

<?php

namespace App\Services;

use App\OracleActAllocationDetails;
use App\OracleDOCOrderDetail;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderPackage;
use App\OrderPackageCommodities;
use App\Services\common\BatchUpdateService;
use Carbon\Carbon;

class OrderPackageService
{

    public function createdByOrder($order)
    {
        /** @var OrderPackageCommoditiesService $orderPackageCommoditiesService */
        $orderPackageCommoditiesService = app('orderPackageCommoditiesService');
        $oracleActAllocationDetails = OracleActAllocationDetails::query()->where('OrderNo', $order['code'])->get();
        $orderHeader = OracleDOCOrderHeader::query()->where('OrderNo', $order['code'])->first();
        $oracleDOCOrderDetail = OracleDOCOrderDetail::query()->where('OrderNo', $order['code'])->get();
        $logistic_number = null;
        if ($oracleActAllocationDetails->count() == 0) {  // 通过oracle Order Detail
            $logistic_number = $orderHeader['soreference5'];
            if ($oracleDOCOrderDetail->count() == 0) {
                return null;
            }
            if ($logistic_number == null || $logistic_number == '*') {
                return null;
            }
            try {
                $orderPackage = OrderPackage::query()->firstOrCreate(['order_id' => $order['id'], 'logistic_number' => $logistic_number]);
                $orderPackageCommoditiesService->basedOnOracleDetailsStore($orderHeader['orderno'], $orderPackage);
                LogService::log(__METHOD__, __FUNCTION__, '创建订单包裹orderPackage' . json_encode($orderPackage));
            } catch (\Exception $e) {
                LogService::log(__METHOD__, __FUNCTION__, '创建订单包裹orderPackage失败' . $e->getMessage() . $e->getTraceAsString());
            }
        } else if ($oracleActAllocationDetails->count() > 0) {
            $count = $oracleActAllocationDetails->where('OrderNo', $order['code'])->whereNull('picktotraceid')->count();
            if ($count > 0) {   // 快递单号为空
                if (($orderHeader['soreference5'] ?? false) && $orderHeader['soreference5'] == '*') {
                    return null;
                }
                $logistic_number = $orderHeader['soreference5'];

                try {
                    $orderPackage = OrderPackage::query()->firstOrCreate(['order_id' => $order['id'], 'logistic_number' => $logistic_number]);
                    $orderPackageCommoditiesService->basedOnOracleDetailsStore($order, $orderPackage);
                    LogService::log(__METHOD__, __FUNCTION__, '创建订单包裹orderPackage' . json_encode($orderPackage));
                } catch (\Exception $e) {
                    LogService::log(__METHOD__, __FUNCTION__, '创建订单包裹orderPackage失败' . $e->getMessage() . $e->getTraceAsString());
                }
            } else {
                $ActAllocationDetails = $oracleActAllocationDetails->where('orderno', $order['code']);
                $picktotraceids = data_get($ActAllocationDetails,'*.picktotraceid');
                $picktotraceids = array_unique($picktotraceids);
                foreach ($picktotraceids as $picktotraceid) {
                    $logistic_number = $picktotraceid;
                    if ($logistic_number == null || $logistic_number == '*') {
                        $logistic_number = $orderHeader['soreference5'];
                        if ($logistic_number == null || $logistic_number == '*') {
                            return null;
                        }
                        $orderPackage = OrderPackage::query()->where(['order_id' => $order['id'], 'logistic_number' => $logistic_number])->first();
                        if ($orderPackage) {
                            $orderPackageCommoditiesService->basedOnActAllocationDetailsStoreByOrderNo($order['code'], $orderPackage);
                            continue;
                        }
                        try {
                            $orderPackage = OrderPackage::query()->create(['order_id' => $order['id'], 'logistic_number' => $logistic_number]);
                            $orderPackageCommoditiesService->basedOnActAllocationDetailsStoreByOrderNo($order['code'], $orderPackage);
                            LogService::log(__METHOD__, __FUNCTION__, '创建订单orderPackage' . json_encode($orderPackage));
                        } catch (\Exception $e) {
                            LogService::log(__METHOD__, __FUNCTION__, '创建订单orderPackage失败' . json_encode($e->getMessage()) . json_encode($e->getTraceAsString()));
                        }
                        continue;
                    }
                    $orderPackage = OrderPackage::query()->where('order_id', $order['id'])->where('logistic_number', $logistic_number)->first();
                    if ($orderPackage) {
                        $orderPackageCommoditiesService->basedOnActAllocationDetailsStore($orderPackage);
                        continue;
                    }
                    try {
                        $orderPackage = OrderPackage::query()->create(['order_id' => $order['id'], 'logistic_number' => $logistic_number]);
                        $orderPackageCommoditiesService->basedOnActAllocationDetailsStore($orderPackage);
                        LogService::log(__METHOD__, __FUNCTION__, '创建订单' . json_encode($orderPackage));
                    } catch (\Exception $e) {
                        LogService::log(__METHOD__, __FUNCTION__, '创建订单orderPackage失败' . json_encode($e->getMessage()) . json_encode($e->getTraceAsString()));
                    }
                }
            }
        }
        unset($oracleActAllocationDetails,$oracleDOCOrderDetail);
    }

    public function updateOrderPackageInfo(Order $order)
    {
        $orderHeader = OracleDOCOrderHeader::where('orderNo', $order['code'])->first();
        if ($orderHeader['oracleBASCode_codename_c'] == $order['wam_status']) {
            return;
        }
        $orderPackages = OrderPackage::where('order_id', $order['id'])->get();
        $orderPackageCommodities = OrderPackageCommodities::with('commodity')->whereIn('order_package_id', data_get($orderPackages, '*.id'))->get();
        $actAllocationDetails = OracleActAllocationDetails::where('orderNo', $order['client_code'])->get();
        if (count($orderPackageCommodities) < count($actAllocationDetails)) {
            $actAllocationDetails = $actAllocationDetails->reject(function ($value, $key) use (&$orderPackageCommodities) {
                $bool = false;
                $count = 0;
                $orderPackageCommodities->reject(function ($value1, $key1) use ($value, &$bool, $count) {
                    if ($count > 0) {
                        return false;
                    }
                    if ($value1->commodity['sku'] == $value['sku'] && $value1['amount'] == intval($value['qty'])) {
                        $bool = true;
                        $count++;
                        return true;
                    } else {
                        return false;
                    }
                });
                return $bool;
            });
        }
        $orderPackageCommoditiesService = app('orderPackageCommoditiesService');
        $orderPackageCommoditiesService->basedOnActAllocationDetail($order, $orderHeader, $actAllocationDetails);
        $order['wam_status'] = $orderHeader['oracleBASCode_codename_c'];
        $order->save();
    }
    /**
     * @param string $logistic_number
     * @param array $values
     * @return OrderPackage $package
     */
    public function firstOrCreate($logistic_number, array $values){
        /** @var $package OrderPackage  */
        $package = OrderPackage::query()->where('logistic_number',$logistic_number)->first();
        if ($package)return $package;

        /** @var OrderService */
        $order = app('orderService')->logisticNumberCreateOrder($logistic_number);
        if ($order) $values["order_id"] = $order->id;

        $values["logistic_number"] = $logistic_number;
        /** @var OrderPackage $package */
        $package = OrderPackage::query()->create($values);
        return $package;
    }


    public function createExceptionPaginate($paginate)
    {
        return OrderPackage::query()->select('id', 'status', 'logistic_number', 'measuring_machine_id', 'weighed_at', 'weight', 'length', 'width', 'height', 'bulk', 'paper_box_id')
            ->where('status', '上传异常')->orWhere('status', '测量异常')->orderBy('created_at', 'DESC')
            ->paginate($paginate);
    }

    public function issueExceptionPaginate($paginate)
    {
        return OrderPackage::query()->select('id', 'logistic_number', 'created_at', 'batch_number', 'batch_rule')
            ->where('status', '下发异常')->orWhere('status', '记录异常')
            ->orWhere('status', '已上传异常')->orderBy('created_at', 'DESC')
            ->paginate($paginate);
    }


    public function 根据WMS订单创建WAS包裹($orderHeaders, $orders)
    {
        $orderPackagesFillables = [];
        foreach ($orders as $order) {
            $orderHeader = $orderHeaders[strval($order['code'])] ?? false;
            if(!$orderHeader){
                continue;
            }
            $fillables = $this->根据WMS订单生成包裹信息($orderHeader, $order);
            foreach ($fillables as $fillable) {
                $orderPackagesFillables[] = $fillable;
            }
        }
        try {
            if(count($orderPackagesFillables) > 0){
                OrderPackage::query()->insert($orderPackagesFillables);
                LogService::log(__METHOD__, __FUNCTION__, '批量订单包裹信息' .count($orderPackagesFillables). json_encode($orderPackagesFillables) );
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__, '批量订单包裹信息 error' .json_encode($orderPackagesFillables) .  $e->getMessage().$e->getTraceAsString());
        } finally {
            $order_ids = data_get($orders,'*.id');
            unset($orderPackagesFillables,$orders,$fillables);
            return Order::query()->with('packages')->whereIn('id',$order_ids)->get();
        }
    }

    public function 根据WMS订单生成包裹信息($orderHeader, $order)
    {

        $soReference5 = $orderHeader['soreference5'];
        $orderPackages= [];
        $logistic_numbers = [];

        foreach ($orderHeader['actAllocationDetails'] as $actAllocationDetail) {
            $logistic_numbers[]  =$actAllocationDetail->picktotraceid;
            array_push($logistic_numbers,$actAllocationDetail['picktotraceid']);
        }

        $logistic_numbers = array_unique($logistic_numbers);
        $logistic_numbers = array_diff($logistic_numbers,['','*',null]);

        $logistic_numbers = count($logistic_numbers) == 0 ? ($soReference5 != '*' ? [$soReference5] : []) : $logistic_numbers;
        $logistic_numbers = array_diff($logistic_numbers,['','*',null]);

        if(count($logistic_numbers) == 0 ){ return  [];}

        if (count($logistic_numbers) != 0) {
            foreach ($logistic_numbers as $logistic_number) {
                $fillable = [
                    'order_id' => $order['id'],
                    'logistic_number' => $logistic_number,
                ];
                $orderPackages[] = $fillable;
            }
        }
        return $orderPackages;
    }

    public function 更新WAS订单的包裹的重量和体积($orderHeaders,$orderPackages)
    {

        /** @var CommodityService $commodityService */
        $commodityService = app('commodityService');
        $commodities = $commodityService->getWASCommoditiesByWMSOrderHeaders($orderHeaders); // 商品


        $multipleData = [['id','weight','bulk']];
        $noAttributeCommodity = [];

        $commodity_map = [];
        foreach ($commodities as $commodity) {
            $key = ' id='.$commodity->id;
            $commodity_map[$key] = $commodity;
        }
        foreach ($orderPackages as $packages) {
            foreach ($packages as $package) {

                if($package == null){
                    continue;
                }
                $orderPackageCommodities = $package['commodities'] ?? [];
                $updateArr = [
                    'id' => $package['id'],
                    'weight' => 0,
                    'bulk' => 0,
                ];
                foreach ($orderPackageCommodities as $packageCommodity) {
                    $commodity =  $commodity_map[' id='.$packageCommodity->commodity_id];
                    if($commodity['weight'] == 0  || !$commodity['bulk'] == 0 ){
                        array_push($noAttributeCommodity,$commodity);
                    }
                    $updateArr['weight'] += bcmul($commodity['weight'], $packageCommodity['amount'],5);
                    $updateArr['bulk'] += bcmul($commodity['bulk'], $packageCommodity['amount'],5);
                    //$updateArr['weight'] +=(intval($commodity['weight'] ?? 0) )  * ( intval($packageCommodity['amount'] ?? 0) );
                    //$updateArr['bulk'] += (intval($commodity['bulk']  ?? 0)) * (intval($packageCommodity['amount'] ?? 0) );
                }
                if($package['weight'] == $updateArr['weight'] && $package['bulk'] == $updateArr['bulk']){
                    continue;
                }
                // 订单同步步时 重量 体积不覆盖已有值
                if($packages['weight'] ?? false){
                    $updateArr['weight'] = $packages['weight'];
                }
                if($packages['bulk'] ?? false){
                    $updateArr['bulk'] = $packages['bulk'];
                }
                $multipleData[] = $updateArr;
            }
        }
        if(count($multipleData) > 1){
            /** @var BatchUpdateService $batchUpdateService */
            $batchUpdateService = app('batchUpdateService');
            $batchUpdateService->batchUpdate('order_packages',$multipleData);
        }
        array_unique($noAttributeCommodity);
        if(count($noAttributeCommodity) > 1){
            $commodityService->syncCommodityAttribute($noAttributeCommodity);
        }
        unset($multipleData,$noAttributeCommodity,$commodities);
    }

    public function 更新WAS订单快递单号信息($orderHeaders,$orders)
    {

        $fillables = [];
        $orders_map = [];
        $orders_package_map = [];
        foreach ($orders as $order){
            $key = $order['code'];
            $orders_map[$key] = $order;
            foreach ($order['packages'] as $package) {
                $logistic_numbers = $package['logistic_number'];
                $orders_package_map[$key][$logistic_numbers] =$package;
            }
        }

        foreach ($orderHeaders as $key=>$orderHeader) {
            $order = $orders[$key] ?? false;
            if(!$order){
                continue;
            }
            $packages = $orders_package_map[$key] ?? false;
            $pickToTraceIds = [];
            foreach ($orderHeader->actAllocationDetails as $actAllocationDetail) {
                $pickToTraceIds[] = $actAllocationDetail['picktotraceid'];
            }
            $pickToTraceIds = array_unique(array_diff($pickToTraceIds,['','*',null]));

            foreach ($pickToTraceIds as $pickToTraceId) {
                if(!$packages || !($orders_package_map[$key][$pickToTraceId] ?? false)){
                    $fillables[] = [
                        'order_id' => $order->id,
                        'logistic_number' => $pickToTraceId
                    ];
                }
            }
        }

        try {
            if(count($fillables)>0){
                OrderPackage::query()->insert($fillables);
                LogService::log(__METHOD__,__FUNCTION__,'创建orderPackage:'.json_encode($fillables));
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,'创建orderPackage 失败:'.json_encode($fillables).$e->getMessage().$e->getTraceAsString());
        } finally {
            unset($fillables);
        }
    }

}