baoshi-was/app/Http/Controllers/OrderController.php

<?php

namespace App\Http\Controllers;

use App\Components\Database;
use App\Http\Requests\OrderDelivering;
use App\OracleActAllocationDetails;
use App\OracleDOCOrderHeader;
use App\OracleDOCWaveDetails;
use App\OrderIssueType;
use App\OrderPackage;
use App\Services\LogisticService;
use App\Services\LogService;
use App\Services\OrderPackageService;
use App\Services\OrderService;
use App\Services\RejectedBillItemService;
use App\Services\RejectedBillService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Gate;
use Oursdreams\Export\Export;
use function DeepCopy\deep_copy;

class OrderController extends Controller
{
    use Database;

    public function delivering(OrderDelivering $request){
        /** @var OrderService $orderService */
        $orderService = app('OrderService');
        $request = $request->input();
        $owners = app('OwnerService')->getIntersectPermitting(['id','code']);
        $service=app(LogisticService::class);
        $logistics=$service->getSelection(['id','name']);
        $codes = array_column($owners->toArray(),'code');
        if ($request['customerid'] ?? false){
            $arr = explode(',',$request['customerid']);
            $request['customerid'] = [];
            foreach ($arr as $value){
                if (in_array($value,$codes))$request['customerid'][] = $value;
            }
            if (count($request['customerid']) < 1)$request['customerid'] = [''];
        }else $request['customerid'] = $codes;

        $result = $orderService->paginate($request);
        $picktotraceids = $result['picktotraceids'];
        $orders = $result['orders'];
        $orderService->tagOrderByOrderIssue($orders);
        app('WorkOrderService')->tagWorkOrder($orders);
        $commodities = $result['commodities'];
        $customers=app('OracleBasCustomerService')->getCustomers($codes);
        $page = $request["page"] ?? 1;
        $codes=DB::connection('oracle')->table('BAS_CODES')->select('code','codename_c')->where('codeid','SO_STS')->orderBy('code','asc')->get();
        $orderIssueType = OrderIssueType::all();
        return view('order/index/delivering',compact('orders','customers','request','codes','commodities','page','picktotraceids','orderIssueType','logistics'));
    }

    //导出
    public function export(Request $request){
        $is_merge = $request->is_merge ?? false;
        /** @var OrderService $orderService */
        $orderService = app('OrderService');
        $req = ['type'=>'order'];
        if ($is_merge && $is_merge == 'true')$req["createFormat"] = "merge";
        if ($request->data){
            $req["sql"] = $orderService->getSql(['data'=>$request->data]);
        }else{
            $req["sql"] = $orderService->getSql($request->input());
        }
        $e = new Export();
        $e->setOracleConnection(config('database.connections.oracle.host'),
            config('database.connections.oracle.port'),config('database.connections.oracle.database')
        ,config('database.connections.oracle.username'),config('database.connections.oracle.password'));
        if ($is_merge && $is_merge == 'true'){
            $e->setMergeFormat([
                "A","B","C","D","E","F","G","H","I","J","K","L","M","N","O","P",
                "Q","R","S","Z","AA","AB","AC","AD"
            ]);
            $e->setDatum("ORDERNO");
        } else $e->setWarpTextFormat();
        $e->setFileName("订单记录-".date('ymdHis'));
        return $e->sql($req["sql"],[
            "ORDERNO"=>"编号","ORDERCODENAME"=>"订单状态",
            "NOTES"=>"备注","ADDTIME"=>"接口下发时间",
            "ISSUEPARTYNAME"=>"店铺名称","CUSTOMER_DESCR_C"=>"客户",
            "SOREFERENCE1"=>"客户订单号","CARRIERNAME"=>"承运人",
            "SOREFERENCE5"=>"快递单号","C_CONTACT"=>"收货人名称","C_TEL2"=>"收货人电话",
            "C_PROVINCE"=> "省","C_CITY"=>"市","C_DISTRICT"=>"区","C_ADDRESS1"=>"收货人地址",
            "WAVENO"=>"波次编号","WAREHOUSEID"=>"仓库","EDISENDFLAG2"=>"快递获取标记","EDISENDTIME2"=>"快递获取时间",
            "SKU"=>"产品代码","ALTERNATE_SKU1"=>"产品条码","ORDERDETAILCODENAME"=>"明细状态","DESCR_C"=> "产品名称",
            "QTYORDERED"=>"订单数量","CHECKTIME"=>"复核时间","ERPCANCELFLAG"=>"接口取消标记",
            "PICKING_PRINT_FLAG"=>"拣货单打印标记","EDISENDFLAG"=>"接口回传标记","EDIREMARKS2"=>"接口回传异常备注",
            "RELEASESTATUS"=>"订单冻结"],["ADDTIME"=>"date","EDISENDTIME2"=>"date"])->direct();
    }

    public function createRejectedBill(Request $request){
        if(!Gate::allows('订单管理-订单-生成退货单')){ return ['success'=>false,'data'=>'您无权操作！'];  }
        /** @var OrderService $orderService */
        $orderService = app('OrderService');
        $result = $orderService->get(['data' => $request->data]);

        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app('RejectedBillService');

        /** @var RejectedBillItemService $rejectedBillItemService */
        $rejectedBillItemService = app('RejectedBillItemService');

        $commodities = $result['commodities'];
        $rejectedBillItems = [];
        //分箱号
        $picktotraceids = json_decode($result['picktotraceids'],true);
        $rejectedBill_collect = collect();// 保存生成的rejectedBill
        foreach ($result['orders'] as $order){
            $blacklist = ["00","10","20","30","90"/*,"99"*/];
            if (array_search($order->sostatus,$blacklist) !== false)return ['success'=>false,'data'=>'“'.$order->orderno."”状态异常，无法操作"];
        }
        foreach ($result['orders'] as $order){
            //不存在时将当前快递单号视为分箱号
            if (!($picktotraceids[$order->orderno] ?? false))$picktotraceids[$order->orderno] = [$order->soreference5];
            //获取货主与快递方
            $owner = app('OwnerService')->firstOrCreate(['name' => $order->customer_descr_c],
                ['name' => $order->customer_descr_c, 'code' => $order->customer_descr_c]);
            $logistic = app('LogisticService')->firstOrCreate(['name' => $order->carriername],
                ['name' => $order->carriername, 'code' => $order->carriername]);
            foreach ($picktotraceids[$order->orderno] as $orderno){
                $rejectedBill = $rejectedBillService->create([
                    'id_owner' => $owner->id,
                    'sender' => $order->c_contact,
                    'logistic_number_return' => $orderno,
                    'id_logistic_return' => $logistic->id,
                    'order_number' => $order->soreference1,
                    'mobile_sender' => empty($order->c_tel2)?$order->c_tel1:$order->c_tel2,
                    'logistic_number' => '原单退回',//$order->soreference1
                    'remark' => $order->notes,
                    'is_loaded' =>0,
                    "id_operator" => Auth::id(),
                ]);
                $rejectedBill_collect->push($rejectedBill);// 保存生成的rejectedBill
                LogService::log(__METHOD__,"生成退货单",json_encode($order),Auth::user()['id']);
                $cms = $commodities[$order->orderno] ?? [];
                if (count($picktotraceids[$order->orderno]) > 0 && $cms){
                    $sql = <<<sql
 SELECT sum(QTY) qty,sku FROM ACT_ALLOCATION_DETAILS where ORDERNO = ? and PICKTOTRACEID = ? GROUP BY sku
sql;
                    $acts = DB::connection("oracle")->select(DB::raw($sql),[$order->orderno,$orderno]);
                    $skus = array_column($acts,"sku");
                    foreach ($cms as $orderCommodities){
                        $index = array_search($orderCommodities["sku"],$skus);
                        if ($index === false)continue;
                        array_push($rejectedBillItems,[
                            'id_rejected_bill' => $rejectedBill->id,
                            'barcode_goods' => $orderCommodities['alternate_sku1'],
                            'name_goods' => $orderCommodities['descr_c'],
                            'amount' => $acts[$index]->qty,//$orderCommodities['qtyordered'],
                            'id_quality_label' => 1,
                            'created_at' => date('Y-m-d H:i:s'),
                        ]);
                    }
                }
            }
        }
        $rejectedBillItemService->insert($rejectedBillItems);
        LogService::log(__METHOD__,"批量生成退货单详情",json_encode($rejectedBillItems),Auth::user()['id']);
        $rejectedBill_collect->each(function($rejectedBill)use($rejectedBillService){
            $rejectedBillService->joinOrderIssue($rejectedBill);
            $rejectedBillService->syncOrderIssue($rejectedBill);
        });
        return ['success'=>true];
    }

    public function isRejectedBillExist(Request $request){
        if(!Gate::allows('订单管理-订单-生成退货单')){ return redirect(url('/'));  }
        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app('RejectedBillService');
        $rejectedBills = $rejectedBillService->get(['order_number' => $request->data]);
        if (count($rejectedBills) == 0)return ['success'=>true];
        return ['success'=>false, 'data'=>json_encode(array_column($rejectedBills->toArray(),'order_number'))];
    }

    //批量备注追加
    public function batchComments(Request $request){
        if(!Gate::allows('订单管理-批量备注')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData');
        $content=$request->input('content');
        $ordersNotNull=OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
            ->whereNotNull('notes')->get();
        OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
            ->whereNull('notes')->update(['notes'=>$content]);
        $ordersNotNullArr=array_column($ordersNotNull->toArray(),'orderno');
        $ordersNullArr=array_diff($checkData,$ordersNotNullArr);
        $data=[];
        foreach ($ordersNotNull as $order){
            OracleDOCOrderHeader::query()->where('orderno',$order->orderno)->update(["notes"=>($order->notes).",".$content]);
            app('LogService')->log(__METHOD__,'批量备注追加修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            $order->notes=($order->notes).",".$content;
            array_push($data,$order);
        }
        foreach ($ordersNullArr as $order){
            array_push($data,["orderno"=>$order,'notes'=>$content]);
        }
        return $data;
    }
    //批量冻结
    public function freezeAll(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData')??'';
        //冻结条件只局限于 分配完成sostatus=40  创建订单sostatus=00  拣货完成sostatus=60  播种完成sostatus=61
        $sostatus=['40','00','60','61'];
        $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
        if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可冻结订单"];
        foreach ($orders as $order){
            $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
            if ($waveno && $waveno!='*'){
                OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
                app('LogService')->log(__METHOD__,'批量冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            }
            $is_freeze=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
            app('LogService')->log(__METHOD__,'批量冻结修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            if (!$is_freeze)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
        }
        return ['success'=>true];
    }
    //批量取消分配
    public function deAllocationAll(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData')??'';
        //取消分配条件只局限于 分配完成sostatus=40 和 部分分配sostatus=30
        $sostatus=['30','40'];
        $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
        if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可取消分配订单"];
        foreach ($orders as $order){
            $is_deAllocation=$this->isDeAllocation($order->orderno);
            $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
            if ($waveno && $waveno!='*'){
                OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
                app('LogService')->log(__METHOD__,'批量取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            }
            $deAllocation=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['sostatus'=>'00','waveno'=>'*']);
            app('LogService')->log(__METHOD__,'批量取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            if (!$is_deAllocation||!$deAllocation)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
        }
        return ['success'=>true];
    }
    //冻结
    public function freeze(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->input('orderno');
        $waveno=$request->input('waveno');
        if ($waveno && $waveno!='*'){
            OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
            app('LogService')->log(__METHOD__,'冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        }
        OracleDOCOrderHeader::where('orderno',$orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
        app('LogService')->log(__METHOD__,'冻结'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        return ['success'=>true];
    }
    public function thaw(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno = $request->orderno;
        if (!is_array($orderno)) {
            $orderno = [$orderno];
        }
        OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->update(['releasestatus'=>'N']);
        app('LogService')->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        return ['success'=>true];
    }

    //重置快递获取标记
    public function resetLogisticsGetMark(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->orderno;
        OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->where('edisendflag2','W')->update(['edisendflag2'=>'N']);
        app('LogService')->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
        return ['success'=>true];
    }

    //取消分配
    public function deAllocation(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->input('orderno');
        $waveno=$request->input('waveno');
        if ($waveno && $waveno!='*'){
            OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
            app('LogService')->log(__METHOD__,'取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        }
        OracleDOCOrderHeader::where('orderno',$orderno)->update(['sostatus'=>'00','waveno'=>'*']);
        app('LogService')->log(__METHOD__,'取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        $is_deAllocation=$this->isDeAllocation($orderno);
        if($is_deAllocation) return ['success'=>true];

    }
    //调用sp取消选中订单的分配
    public function isDeAllocation($orderno){
        $username=config('database.connections.oracle.username');
        $password=config('database.connections.oracle.password');
        $host=config('database.connections.oracle.host');
        $service_name=config('database.connections.oracle.service_name');
        $conn=oci_connect($username,$password,$host.'/'.$service_name,'utf8'); //连接oracle数据库
        $IN_Warehouse='';
        $IN_Process_Action_C='' ;
        $IN_Process_By_C='By OrderNO';
        $IN_WaveNO_C='';
        $IN_OrderNO_C=$orderno;
        $IN_OrderLineNO_C='';
        $IN_AllocationDetailsID='';
        $IN_Language='';
        $IN_UserID='';
        $OUT_Return_Code='';
        $sql_sp="begin SPSO_DEALLOCATION_PROCESS(:IN_Warehouse,:IN_Process_Action_C,:IN_Process_By_C,
        :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
        $stmt = oci_parse($conn, $sql_sp);
        oci_bind_by_name($stmt,':IN_Warehouse',$IN_Process_Action_C);
        oci_bind_by_name($stmt,':IN_Process_Action_C',$IN_Warehouse);
        oci_bind_by_name($stmt,':IN_Process_By_C',$IN_Process_By_C);
        oci_bind_by_name($stmt,':IN_WaveNO_C',$IN_WaveNO_C);
        oci_bind_by_name($stmt,':IN_OrderNO_C',$IN_OrderNO_C);
        oci_bind_by_name($stmt,':IN_OrderLineNO_C',$IN_OrderLineNO_C);
        oci_bind_by_name($stmt,':IN_AllocationDetailsID',$IN_AllocationDetailsID);
        oci_bind_by_name($stmt,':IN_Language',$IN_Language);
        oci_bind_by_name($stmt,':IN_UserID',$IN_UserID);
        oci_bind_by_name($stmt,':OUT_Return_Code',$OUT_Return_Code,300);
        oci_execute($stmt);
        if (substr($OUT_Return_Code,0,3) != '000'){
            app('LogService')->log(__METHOD__,'调用sp根据订单取消分配失败'.__FUNCTION__,"ORDERNO:".$orderno."ERROR：".$OUT_Return_Code);
            return false;
        }
        oci_close($conn);
        return true;
    }

    public function resetInterfaceReturnMark(Request $request)
    {
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->orderno;
        $oldIds =OracleDOCOrderHeader::query()
            ->whereIn('orderno', $orderno)
            ->where('edisendflag', 'N')->pluck('orderno')->toArray();

        OracleDOCOrderHeader::query()
            ->whereIn('orderno',$orderno)
            ->where('sostatus','99')
            ->whereIn('edisendflag',['R','W'])
            ->where('addwho','EDI')
            ->update(['edisendflag'=>'N']);

        $failedOrdernos =OracleDOCOrderHeader::query()
            ->whereIn('orderno', $orderno)
                ->where('edisendflag', '!=', 'N')->pluck('orderno');

        $successedOrdernos =OracleDOCOrderHeader::query()
            ->whereIn('orderno', array_diff($orderno,$oldIds))
            ->where('edisendflag', 'N')->pluck('orderno');

        app('LogService')->log(__METHOD__,'重置接口回传标记'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
        if (count($failedOrdernos)==0) {
            return ['success'=>true];
        } else {
            return ['success'=>false,'fail_info'=>"数据 {$failedOrdernos} 更新失败,数据{$successedOrdernos}更新成功"];
        }
    }

    /**
     * @param Request $request
     * @return array
     * 一键回传功能
     */
    public function manualBack(Request $request): array
    {
        if(!Gate::allows('订单管理-订单-一键回传'))return["success"=>false,"data"=>"无权操作"];
        /** @var OrderService $orderService */
        $orderService=app(OrderService::class);
        $orderNos=$request->input('ordernos');
        $failNo=array();
        $successNo=array();
        $docOrders=OracleDOCOrderHeader::query()
            ->whereIn('orderno',$orderNos)
            ->get();
        /** @var OrderService $service */
        $service=app("OrderService");
        foreach ($docOrders as $order){
            if ($order->sostatus=='00' || $order->sostatus=='10' || $order->sostatus=='20'){
                $res = $service->allocation($order->orderno,null,$order->warehouseid);
                if (mb_substr($res,0,3)!='000') {
                    array_push($failNo,$order->orderno);
                    app('LogService')->log(__METHOD__,'手动回传分配失败'.__FUNCTION__,json_encode($order->orderno),Auth::user()['id']);
                }
            }
        }
        foreach ($orderNos as $no){
            $res=$orderService->manualBack($no);
            if (!$res){
                array_push($failNo,$no);
                app('LogService')->log(__METHOD__,'人工回传失败'.__FUNCTION__,json_encode($no),Auth::user()['id']);
            }else{
                array_push($successNo,$no);
            }
        }
        if (count($orderNos)>=count($failNo))return ["success"=>true,"successNo"=>$orderNos,"failNo"=>$failNo];
        else return ["success"=>false,"failNo"=>$failNo];
    }

    public function allocation(Request $request):array
    {
        if(!Gate::allows('订单管理-编辑'))return["status"=>'fail',"msg"=>"无权操作"];
        $list = $request->input("list",[]);
        $error = [];
        /** @var OrderService $service */
        $service=app("OrderService");
        $conn = null;
        foreach ($list as $item){
            if (!$item["number"]){
                $error[] = "'{$item["code"]}'尚未获取快递单号";
                continue;
            }
            if ((int)$item["status"]>30){
                $error[] = "'{$item["code"]}'已被分配";
                continue;
            }
            if (!$conn)$conn = $this->getFluxConnection();
            $res = $service->allocation($item["code"],null,$item["warehouse"],$conn);
            if (mb_substr($res,0,3)=='000')continue;
            $error[] = "'{$item["code"]}'{$res}";
        }
        if ($conn)$this->releaseFluxConnection($conn);
        if (!$error)return["status"=>'success'];
        $txt = implode(",",$error);
        return["status"=>'part',"msg"=>$txt];
    }

    /**
     * 一键揽收分配
     * @param Request $request
     * @return array
     */
    public function collectUpload(Request $request): array
    {
        $inOrderno = $request->orderno;
        $strict = $request->strict;
        if (empty($inOrderno)) return ['success' => false, 'message' => '选择为空'];
        $orderno = deep_copy($inOrderno);

        /**
         * 是否是严格模式
         * 是
         *          根据筛选条件
         *           1. 状态 61 81
         *           2. 承运商是中通
         *           3. 有单号
         *           4. 有复核，
         *           5. 没揽收
         * 否
         * 筛选出快递单号
         * 将快递单号调用一键揽收
         *      如果返回异常，记录异常
         * 调用分配
         * 将入参与过滤结果取差集合，结果就是不复核的单号，作为错误提示返回
         */
        //严格模式，校验订单与包裹状态
        if ($strict) {
            $logisticNums = OracleActAllocationDetails::query()
                ->select('picktotraceid')
                ->whereIn('orderno', $orderno)
                ->whereNotNull('picktotraceid')//有单号
                ->whereNotNull('checktime')//有复核
                ->whereIn('orderno', function (Builder $query) use ($orderno) {
                    $query->from('doc_order_header')
                        ->select('orderno')
                        ->whereIn('orderno', $orderno)
                        ->whereIn('carriername', ['中通（轻小包裹）', '中通', '中通速递']) // 承运商是中通
                        ->whereBetween('sostatus', [61, 81]); //状态 61 81
                })
                ->pluck('picktotraceid');
            $logisticNums = OrderPackage::query()
                ->select('logistic_number')
                ->whereIn('logistic_number', $logisticNums)
                ->whereNull('transfer_status')
                ->pluck('logistic_number');
        }else{
            //非严格模式 不进行任何校验
            $logisticNums = OracleActAllocationDetails::query()
                ->select('picktotraceid')
                ->whereIn('orderno', $orderno)
                ->pluck('picktotraceid');
        }

        //调用一键揽收
        /** @var OrderPackageService $orderPackageService */
        $orderPackageService = app('OrderPackageService');
        $collectUpLoadResult = $orderPackageService->collectUpload($logisticNums->toArray());
        $error = [];
        //揽收有异常记录
        if (!$collectUpLoadResult['success']) {
            $error['collectUpload'] = $collectUpLoadResult['message'];
        }
        /** @var OrderService $orderService */
        $orderService = app('OrderService');
        //根据快递单号查询orderno
        $allocationOrdernos = OrderPackage::query()
            ->whereIn('logistic_number', $logisticNums)
            ->leftJoin('orders', 'order_id', '=', 'orders.id')
            ->select('orders.code')
            ->pluck('code');
        //调用分配接口
        $allocationOrdernos->each(function ($orderno) use ($orderService) {
            $orderService->allocation($orderno);
        });
        if ($strict) {
            //输入的orderno与最终可以一键揽收的orderno取差集合
            $errorOrderno =  array_diff($inOrderno, $allocationOrdernos->toArray());
        }

        $result = [];
        if (!empty($error)) {
            $result['success'] = false;
            $result['error_message'] = $error;
        }else if(!empty($errorOrderno)){
            $result['success'] = false;
            $result['error_message'][] = $error;
        }
        else {
            $result['success']=true;
            $result['message']='一键揽收分配完成';
        }
        return $result;
    }

}