baoshi-was/app/Services/OrderService.php

<?php

namespace App\Services;

use App\Commodity;
use App\Feature;
use App\Jobs\OrderCreateInstantBill;
use App\Jobs\OrderCreateWaybill;
use App\Jobs\OrderFreeze;
use App\Logistic;
use App\OracleActAllocationDetails;
use App\OracleDOCASNHeader;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderCommodity;
use App\OrderIssue;
use App\Owner;
use App\OwnerFeeDetail;
use App\OwnerFeeDetailLogistic;
use App\OwnerReport;
use App\Province;
use App\RejectedBill;
use App\Services\common\BatchUpdateService;
use App\Services\common\DataHandlerService;
use App\Shop;
use App\Traits\ModelSearchWay;
use App\ValueStore;
use App\Warehouse;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use App\Traits\ServiceAppAop;


class OrderService
{
    use ServiceAppAop;
    use ModelSearchWay;
    protected $modelClass=Order::class;
    /**
     * @var OracleDOCOrderHeaderService $oracleDOCOrderHeaderService
     * @var OrderPackageService $packageService
     * @var OrderCommodityService $orderCommodityService
     * @var BatchService $batchService
     */
    private $oracleDOCOrderHeaderService;
    private $packageService;
    private $orderCommodityService;
    private $batchService;

    public function __construct()
    {
        $this->oracleDOCOrderHeaderService = app('OracleDocOrderHeaderService');
        $this->packageService = app('OrderPackageService');
        $this->orderCommodityService = app('OrderCommodityService');
        $this->batchService = app('BatchService');
    }

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


    private function preciseQuery(array $params,$sql){
        $orderdate_start=$params["orderdate_start"] ?? null;
        $orderdate_end=$params["orderdate_end"] ?? null;
        $customerid=$params["customerid"] ?? null;
        $orderno=$params["orderno"] ?? null;
        $soreference5=$params["soreference5"] ?? null;
        $codename_c=$params["codename_c"] ?? null;
        $codename_c_end=$params["codename_c_end"] ?? null;
        $carriername=$params["carriername"] ?? null;
        $soreference1=$params["soreference1"] ?? null;
        $issuepartyname=$params["issuepartyname"] ?? null;
        $notes=$params["notes"] ?? null;
        $addtime=$params["addtime"] ?? null;
        $waveno=$params["waveno"] ?? null;
        $alternate_sku1=$params["alternate_sku1"] ?? null;
        $c_contact = $params["c_contact"] ?? null;
        $c_tel2 = $params["c_tel2"] ?? null;
        $c_province = $params["c_province"] ?? null;
        $c_city = $params["c_city"] ?? null;
        $c_district = $params["c_district"] ?? null;
        $releasestatus = $params["releasestatus"] ?? null;
        $ordernos = $params["ordernos"] ?? null;
        $edisendflag2=$params["edisendflag2"] ?? null;
        $edisendflag=$params["edisendflag"] ?? null;
        $checkAllSign = $params['checkAllSign'] ?? null;
        if ($ordernos){
            $sql .= " AND orderno IN ".$ordernos;
        }
        if ($c_contact)$sql=$this->sqlSearchWay($sql,$c_contact,'c_contact');
        if ($c_tel2){
            $c_tel2 = str_replace("'",'"',$c_tel2);
            $sql .= " AND (c_tel2 like '".$c_tel2."' OR c_tel1 like '".$c_tel2."')";
        }
        if ($c_province){
            $c_province = str_replace("'",'"',$c_province);
            if ($c_province=='空')$sql .= " AND c_province is null";
            else$sql .= " AND c_province like '".$c_province."'";
        }
        if ($c_city){
            $c_city = str_replace("'",'"',$c_city);
            if ($c_city=='空')$sql .= " AND c_city is null";
            else$sql .= " AND c_city like '".$c_city."'";
        }
        if ($c_district){
            $c_district = str_replace("'",'"',$c_district);
            if ($c_district=='空')$sql .= " AND c_district is null";
            else$sql .= " AND c_district like '".$c_district."'";
        }
        if ($releasestatus){
            $releasestatus = str_replace("'",'"',$releasestatus);
            $sql .= " AND releasestatus = '".$releasestatus."'";
        }
        if ($alternate_sku1){
            $alternate_sku1 = str_replace("'",'"',$alternate_sku1);
            if ($checkAllSign) $detailsOrderno = $this->getOrdersNo($alternate_sku1,false);
            else $detailsOrderno = $this->getOrdersNo($alternate_sku1,true, $params['page'] ?? 1, $params['paginate'] ?? 50);
            if (count($detailsOrderno)>0){
                $sql.=' AND orderno IN (';
                foreach ($detailsOrderno as $index => $no){
                    if ($index==0){
                        $sql.="'".$no."'";
                        continue;
                    }
                    $sql.=",'".$no."'";
                }
                $sql.=')';
            }else{
                $sql .= 'AND orderno IS NULL ';
            }
        }
        if ($orderdate_start && $orderdate_end && $addtime){
            $orderdate_start=null;
            $orderdate_end=null;
        }
        if ($orderdate_start){
            if (strlen($orderdate_start)<11)$orderdate_start .= ' 00:00';
            $sql.=" and addtime>=to_date('".$orderdate_start.":00','yyyy-mm-dd hh24:mi:ss')";
        }
        if ($orderdate_end){
            if (strlen($orderdate_end)<11)$orderdate_end .= ' 23:59 ';
            $sql.=" and addtime<=to_date('".$orderdate_end.":59','yyyy-mm-dd hh24:mi:ss')";
        }
        if ($customerid){
            if (!is_array($customerid))$arr = explode(',',$customerid);
            else $arr = $customerid;
            if (count($arr)>0) {
                $sql.=" and customerid in (";
                foreach ($arr as $index=>$str){
                    if ($index==0){
                        $sql.="'".$str."'";
                        continue;
                    }
                    $sql.=",'".$str."'";
                }
                $sql.=")";
            }
        }
        if ($orderno)$sql=$this->sqlSearchWay($sql,$orderno,'orderno');
        if ($codename_c&&$codename_c_end)$sql.=" and sostatus between '".$codename_c."' and '".$codename_c_end."'";
        if ($codename_c&&!$codename_c_end)$sql.=" and sostatus = '".$codename_c."'";
        if (!$codename_c&&$codename_c_end)$sql.=" and sostatus = '".$codename_c_end."'";
        if ($carriername){
            if (!is_array($carriername))$arr = explode(',',$carriername);
            else $arr = $carriername;
            if (count($arr)>0) {
                $sql.=" and carriername in (";
                foreach ($arr as $index=>$str){
                    if ($index==0){
                        $sql.="'".$str."'";
                        continue;
                    }
                    $sql.=",'".$str."'";
                }
                $sql.=")";
            }
        }
        if ($waveno)$sql=$this->sqlSearchWay($sql,$waveno,'WaveNo');
        if ($issuepartyname)$sql.=" and issuepartyname like '".$issuepartyname."%'";
        if ($notes){
            if ($addtime&&$addtime!=0)$sql.=" and addtime >= to_date('".date('Y-m-d H:i:s',strtotime("-".$addtime." day"))."','yyyy-mm-dd hh24:mi:ss')";
            $sql.=" and notes like '%".$notes."%'";
        }
        if ($soreference5){
            $soreference5 = str_replace("'",'"',$soreference5);
            $arr=array_values(array_filter(preg_split('/[,， ]+/is', $soreference5)));
            if (count($arr)>0){
                $sql.=" and (soreference5 in (";
                foreach ($arr as $index=>$str){
                    if ($index==0){
                        $sql.="'".$str."'";
                        continue;
                    }
                    $sql.=",'".$str."'";
                }
                $sql.=") ";
                /*分箱号*/
                $oracleActAllocationDetails=DB::connection('oracle')->table('ACT_ALLOCATION_DETAILS')->whereIn('picktotraceid',$arr)->get();
                $picktotraceids=array_unique(array_column($oracleActAllocationDetails->toArray(),'orderno'));
                if (count($picktotraceids)>0){
                    $sql.='OR orderno IN (';
                    foreach ($picktotraceids as $index=>$str){
                        if ($index==0){
                            $sql.="'".$str."'";
                            continue;
                        }
                        $sql.=",'".$str."'";
                    }
                    $sql.=") ";
                }
                $sql.=")";
            }
        }
        if ($edisendflag2) $sql.=" and edisendflag2 like '".$edisendflag2."%'";
        if ($edisendflag) $sql.=" and edisendflag like '".$edisendflag."%'";
        if ($soreference1){
            $arr=array_values(array_filter(preg_split('/[,， ]+/is', $soreference1)));
            if (count($arr)==1){
                $sql.=" and soreference1 like '".$soreference1."%'";
            }
            if (count($arr)>1 && !strpos($soreference1,'%')){
                $sql.=" and soreference1 in (";
                foreach ($arr as $index=>$str){
                    if ($index==0){
                        $sql.="'".$str."'";
                        continue;
                    }
                    $sql.=",'".$str."'";
                }
                $sql.=")";
            }
            if ($params['soreference']) $sql.=" and soreference1 like '".$params['soreference']."'";
        }
        return $sql;
    }

    public function getSql($params, $page = null, $paginate = null){
        $checktime_start = $params['checktime_start'] ?? null;
        $checktime_end = $params['checktime_end'] ?? null;
        $checkData = $params['data'] ?? null;
        if ($checktime_start || $checktime_end){
            /** @var  OracleActAllocationDetailService */
            $ordernos = app('OracleActAllocationDetailService')
                ->getOrderno(['checktime_start'=>$checktime_start,'checktime_end'=>$checktime_end,
                    'paginate'=>$paginate,'page'=>$page]);
            if ($ordernos)$params['ordernos'] = $ordernos;
            else return null;
        }
        $sql="SELECT * FROM (select ACT_ALLOCATION_DETAILS.CHECKTIME,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,DOC_ORDER_HEADER.CustomerID as header_customer_id
        ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.C_Tel1,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,DOC_ORDER_HEADER.EDIREMARKS2,
       DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
        ,NVL(ACT_ALLOCATION_DETAILS.PICKTOTRACEID,DOC_ORDER_HEADER.soreference5) as soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
       DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
        ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime,DOC_Order_Details.CustomerID,
       DOC_Order_Details.SKU,DOC_Order_Details.QtyOrdered,DOC_Order_Details.LOTNUM,DOC_Order_Details.LineStatus,DOC_Order_Details.OrderLineNo,order_code.codename_c as orderCodeName,
       order_detail_code.codename_c as orderDetailCodeName,BAS_Customer.descr_c as customer_descr_c,
       BAS_SKU.Alternate_SKU1,BAS_SKU.Descr_C,(select count(*) from DOC_ORDER_HEADER WHERE 1=1";
        $sql=$this->preciseQuery($params,$sql);
        ;$sql.=" ) as counted from (";
        if ($paginate && $page)$sql.=" select * from (";
        $sql.=" select ROWNUM as rn,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,DOC_ORDER_HEADER.CustomerID
                          ,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.C_Tel1,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
                         DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1
                          ,DOC_ORDER_HEADER.soreference5,DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
                         DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG
                          ,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,DOC_ORDER_HEADER.OrderTime,DOC_ORDER_HEADER.EDIREMARKS2 from (select * from DOC_ORDER_HEADER  order by ADDTIME desc )DOC_ORDER_HEADER where 1=1 ";
        $sql=$this->preciseQuery($params,$sql);
        if ($checkData){
            if (!is_array($checkData)) $checkData=explode(',',$checkData);
            if (count($checkData)>0){
                $sql.=" and orderno in (";
                foreach ($checkData as $index=>$str){
                    if ($index==0){
                        $sql.="'".$str."'";
                        continue;
                    }
                    $sql.=",'".$str."'";
                }
                $sql.=")";
            }
        }
        if (isset($params["alternate_sku1"]))$page = 1;
        if ($paginate && $page)$sql.=" and ROWNUM<='".$page*$paginate."')";
        if ($paginate && $page)$sql.=" header where header.rn>'".($page-1)*$paginate."' ";
        $sql.=")DOC_ORDER_HEADER left join DOC_ORDER_DETAILS on DOC_ORDER_DETAILS.ORDERNO=DOC_ORDER_HEADER.ORDERNO
                      left join BAS_CODES  order_code on order_code.CODE=DOC_ORDER_HEADER.sostatus and order_code.codeid='SO_STS'
                      left join BAS_CODES  order_detail_code on order_detail_code.CODE=DOC_ORDER_DETAILS.linestatus and order_detail_code.codeid='SO_STS'
                      left join BAS_Customer on BAS_Customer.customerid=DOC_ORDER_HEADER.customerid
                      left join  BAS_SKU on DOC_Order_Details.CustomerID=BAS_SKU.CustomerID and DOC_Order_Details.SKU=BAS_SKU.SKU
                      left join  ACT_ALLOCATION_DETAILS on DOC_Order_Details.orderno = ACT_ALLOCATION_DETAILS.orderno
                      and DOC_Order_Details.ORDERLINENO = ACT_ALLOCATION_DETAILS.ORDERLINENO
                      GROUP BY ACT_ALLOCATION_DETAILS.CHECKTIME,DOC_ORDER_HEADER.addtime,DOC_ORDER_HEADER.C_PROVINCE,DOC_ORDER_HEADER.C_CITY,
                      DOC_ORDER_HEADER.C_DISTRICT,DOC_ORDER_HEADER.C_CONTACT,DOC_ORDER_HEADER.OrderNo,DOC_ORDER_HEADER.SOStatus,DOC_ORDER_HEADER.WAREHOUSEID,
                      DOC_ORDER_HEADER.CustomerID,DOC_ORDER_HEADER.C_Tel2,DOC_ORDER_HEADER.C_Tel1,DOC_ORDER_HEADER.CarrierName,DOC_ORDER_HEADER.IssuePartyName,
                      DOC_ORDER_HEADER.EDIREMARKS2,DOC_ORDER_HEADER.WaveNo,DOC_ORDER_HEADER.SOReference1, NVL(ACT_ALLOCATION_DETAILS.PICKTOTRACEID,DOC_ORDER_HEADER.soreference5),
                      DOC_ORDER_HEADER.EDISENDFLAG2,DOC_ORDER_HEADER.EDISendTime2,DOC_ORDER_HEADER.Notes,DOC_ORDER_HEADER.ERPCANCELFLAG,
                      DOC_ORDER_HEADER.Picking_Print_Flag,DOC_ORDER_HEADER.EDISENDFLAG,DOC_ORDER_HEADER.ReleaseStatus,DOC_ORDER_HEADER.C_Address1,
                      DOC_ORDER_HEADER.OrderTime,DOC_Order_Details.CustomerID,DOC_Order_Details.SKU,DOC_Order_Details.QtyOrdered,DOC_Order_Details.LOTNUM,
                      DOC_Order_Details.LineStatus,DOC_Order_Details.OrderLineNo,order_code.codename_c,order_detail_code.codename_c,BAS_Customer.descr_c,
                      BAS_SKU.Alternate_SKU1,BAS_SKU.Descr_C ORDER BY DOC_ORDER_HEADER.ADDTIME desc)";
        return $sql;
    }

    //通过商品条码获取订单编号
    public function getOrdersNo($alternate_sku1, $isPaging = true, $page = 1, $paginate = 50){
        if ($isPaging){
            $sql = "SELECT RESULT.ORDERNO FROM
                        (SELECT ROWNUM rn,DETAIL.ORDERNO as ORDERNO FROM
                            (SELECT ORDERNO FROM DOC_ORDER_DETAILS WHERE SKU LIKE '".$alternate_sku1."' GROUP BY ORDERNO ORDER BY ORDERNO DESC)DETAIL
                        WHERE ROWNUM<='".$page*$paginate."')RESULT
                    WHERE RESULT.rn>'".($page-1)*$paginate."'";
        }else {
            $sql = "SELECT ORDERNO FROM DOC_ORDER_DETAILS WHERE SKU LIKE '".$alternate_sku1."' GROUP BY ORDERNO ORDER BY ORDERNO DESC";
        }
        $orderDetails = DB::connection('oracle')->select(DB::raw($sql));
        return array_column($orderDetails,'orderno');
    }

    public function paginate(array $params){
        if (($params['is_display_all'] ?? false) && !($params['codename_c'] ?? false) && !($params['codename_c_end'] ?? false)){
            $params['codename_c'] = "00";
            $params['codename_c_end'] = "62";
        }

        if ($params['soreference1']??false){
            $arr=array_values(array_filter(preg_split('/[,， ]+/is', $params['soreference1'])));
            if (count($arr)==1){
                $params['soreference']='';$sql = $this->getSql($params,$params['page'] ?? 1, $params['paginate'] ?? 50);
            }
            if (count($arr)>1 && !strpos($params['soreference1'],'%')){
                $params['soreference']='';$sql = $this->getSql($params,$params['page'] ?? 1, $params['paginate'] ?? 50);
            }
            if (count($arr)>1 && strpos($params['soreference1'],'%')){
                foreach ($arr as $index=>$str){
                    if ($index==0){
                        $params['soreference']=$str; $sql=$this->getSql($params,$params['page'] ?? 1, $params['paginate'] ?? 50); continue;
                    }
                    $params['soreference']=$str;
                    $sql.=" union ".$this->getSql($params,$params['page'] ?? 1, $params['paginate'] ?? 50);
                }
            }
        }else{
            $params['soreference']='';
            $sql = $this->getSql($params,$params['page'] ?? 1, $params['paginate'] ?? 50);
        }

        if ($sql)$orders=DB::connection('oracle')->select(DB::raw($sql));
        else $orders = [];
        return $this->orderFormat($orders);
    }

    public function get(array $params){
        $sql = $this->getSql($params);
        if ($sql)$orders=DB::connection('oracle')->select(DB::raw($sql));
        else $orders = [];
        return $this->orderFormat($orders);
    }

    private function orderFormat($orders){
        $commodities=[];
        $orderNos = "(''";
        $picktotraceids=[];
        $count = 1;
        /*
         * 第二种扁平化方式(节省空间)： 使用快慢指针，因拿到数据正常为顺序数据,自下标1开始与上一条对比orderno唯一标识，不同则更新慢指针下标，
         *  相同则为指定下标map类型数组追加一个键值对属性来记录同类数量,如N条，每次追加属性时先看属性是否存在，存在+1
         * */
        foreach ($orders as $index=>$order){
            $key = $order->orderno;
            if (isset($commodities[$key])){
                if (!isset($signs[$order->orderlineno])){
                    $signs[$order->orderlineno] = true;
                    array_push($commodities[$key],
                        ["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,"descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered
                            ,"lotnum"=>$order->lotnum,"checktime"=>$order->checktime,"orderdetailcodename"=>$order->orderdetailcodename]);
                }
                unset($orders[$index]);
                continue;
            }
            $signs=[];
            $signs[$order->orderlineno] = true;
            $commodities[$key]=[["sku"=>$order->sku,"alternate_sku1"=>$order->alternate_sku1,
                "descr_c"=>$order->descr_c,"qtyordered"=>$order->qtyordered,"lotnum"=>$order->lotnum,"checktime"=>$order->checktime,"orderdetailcodename"=>$order->orderdetailcodename]];
            $orderNos .= ",'".$order->orderno."'";
            if ($count % 500 == 0){
                $orderNos .= ")";
                $allocations = DB::connection("oracle")->select(DB::raw("SELECT DROPID,ORDERNO FROM ACT_ALLOCATION_DETAILS WHERE orderno IN ".$orderNos." GROUP BY (DROPID,ORDERNO)"));
                foreach ($allocations as $allocation){
                    if (isset($picktotraceids[$allocation->orderno])) $picktotraceids[$allocation->orderno][] = $allocation->dropid;
                    else $picktotraceids[$allocation->orderno] = [$allocation->dropid];
                }
                $orderNos = "(''";
            }
            $count++;
        }
        if ($orderNos !== "(''"){
            $orderNos .= ")";
            $allocations = DB::connection("oracle")->select(DB::raw("SELECT DROPID,ORDERNO FROM ACT_ALLOCATION_DETAILS WHERE orderno IN ".$orderNos." GROUP BY (DROPID,ORDERNO)"));
            foreach ($allocations as $allocation){
                if (isset($picktotraceids[$allocation->orderno])) $picktotraceids[$allocation->orderno][] = $allocation->dropid;
                else $picktotraceids[$allocation->orderno] = [$allocation->dropid];
            }
        }
        $picktotraceids=json_encode($picktotraceids);
        $orders=array_values($orders);
        $orders = new Collection($orders);
        $commodities=new Collection($commodities);
        return ['picktotraceids'=>$picktotraceids,'orders'=>$orders,'commodities'=>$commodities];
    }

    public function findOrCreateByClientCode($clientCode)
    {
        /** @var OracleDOCOrderHeaderService $orderHeaderService */
        $orderHeaderService = app('OracleDocOrderHeaderService');
        $orderHeaders = $orderHeaderService->getQuery()->where('SOReference1',$clientCode)->get();
        $this->syncOrderInfo($orderHeaders,false);
        return Order::with(['packages.commodities.commodity','logistic'])->where('client_code', $clientCode)->first();
    }

    public function getRejectedBillOfClientCode($clientCode)
    {
        $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();
        if (!$orderHeader) {
            return null;
        }
        $ASNHeader = OracleDOCASNHeader::query()->where('ASNReference2', $orderHeader->soreference2)->first();
        if (!$ASNHeader) {
            return null;
        }
        return RejectedBill::query()->with(['owner', 'logistic', 'items'])->where('logistic_number_return', $ASNHeader->asnreference2)->first();
    }

    public function findOrCreteByLogisticNumberReturn($logisticNumberReturn)
    {
        $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1',function($query)use($logisticNumberReturn){
            $query->from('Doc_ASN_Header')->select('ASNReference2')->where('ASNReference3', $logisticNumberReturn);
        })->first();
        if(!$orderHeader)return null;
        return $this->findOrCreateByClientCode($orderHeader['soreference1']);
    }

    public function first(array $params)
    {
        $order = Order::query();
        foreach ($params as $column => $value) {
            $order->where($column, $value);
        }
        return $order->first();
    }

    public function logisticNumberFirstOrCreateOrder($logistic_number)
    {
        /**
         * @var OracleActAllocationDetailService
         * @var OracleActAllocationDetails $actAllocationDetail
         */
        $actAllocationDetail = app('OracleActAllocationDetailService')->first(['picktotraceid' => $logistic_number]);
        if ($actAllocationDetail) {
            $order = $this->first(['code' => $actAllocationDetail->orderno]);
            if ($order) return $order;

            $actAllocationDetail->load(['oracleDocOrderHeader' => function ($query) {
                $query->with('oracleBASCode');
            }]);
            $orderHeader = $actAllocationDetail->oracleDocOrderHeader ?? null;
        } else {
            $orderHeader = app('OracleDocOrderHeaderService')->first(['soreference5' => $logistic_number]);
        }
        if ($orderHeader == null) return null;
        $order = $this->first(['code'=>$orderHeader->orderno]);
        if ($order) return $order;
        /** @var OwnerService */
        $owner = app('OwnerService')->first(['code' => $orderHeader->customerid]);
        if (!$owner) {
            $orderHeader->load('oracleBASCustomer');
            $customer_name = $orderHeader->oracleBASCustomer ? $orderHeader->oracleBASCustomer->descr_c : null;
            /** @var OwnerService */
            if ($customer_name) $owner = app('OwnerService')->create(['code' => $orderHeader->customerid, 'name' => $customer_name]);
        }

        $shop = null;
        $shop_name = $orderHeader->issuepartyname;
        if ($shop_name && $owner) {
            /** @var ShopService */
            $shop = app('ShopService')->firstOrCreate(['name' => $shop_name, 'owner_id' => $owner->id]);
        }
        $logistics = app('LogisticService')->firstOrCreate(['code' => $orderHeader->userdefine1],
            ['code' => $orderHeader->userdefine1, 'name' => $orderHeader->carriername]);
        $wareHouse = Warehouse::query()->firstOrCreate(['code'=>$orderHeader->warehouseid],
            ['name'=>$orderHeader->warehouseid,'code'=>$orderHeader->warehouseid]);

        try{
            $order =  Order::query()->create([
                'warehouse_id'=> $wareHouse->id ?? '',
                'code' => $orderHeader->orderno,
                'owner_id' => $owner ? $owner->id : null,
                'wms_status' => $orderHeader->oracleBASCode ? $orderHeader->oracleBASCode->codename_c : null,
                'created_at' => $orderHeader->addtime,
                'logistic_id' => $logistics ? $logistics->id : null,
                'shop_id' => $shop ? $shop->id : null,
                'consignee_name' => $orderHeader->c_contact,
                'consignee_phone' => empty($orderHeader->c_tel2)?$orderHeader->c_tel1:$orderHeader->c_tel2,
                'province' => $orderHeader->c_province,
                'city' => $orderHeader->c_city,
                'district' => $orderHeader->c_district,
                'address' => $orderHeader->c_address1,
                'client_code' => $orderHeader->soreference1,
            ]);
        }catch (\Exception $e){
            return $this->first(['code'=>$orderHeader->orderno]);
        }
        app('LogService')->log(__METHOD__,__FUNCTION__,'创建 Order '.json_encode($order));
        return $order;
    }

    public function create(array $params){
        if(count($params) == 0) return [];
        try {
            $this->insert($params);
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__,__FUNCTION__,'批量创建 order '.json_encode($params).'||'.$e->getMessage().'||'.$e->getTraceAsString());
        } finally{
            return Order::query()->whereIn('code',data_get($params,'*.code'))->get();
        }
    }

    public function getByWmsOrders($orderHeaders){
        if(!$orderHeaders){return null;}
        $order_nos = data_get($orderHeaders,'*.orderno');
        return Order::query()->with('packages.commodities')->whereIn('code',$order_nos)->get();
    }

    public function 返回有问题件的订单号($orders)
    {
        if(!isset($orders)){return [];}
        $orderNo =  data_get($orders,'*.orderno');
        $orderIssues = OrderIssue::query()->with('order')
            ->whereIn('order_id',function($query)use($orderNo){
                $query->from('orders')->select('id')->whereIn('code',$orderNo);
            })->get();
        return $orderIssues->map(function($orderIssue){
            return $orderIssue->order->code;
        });
    }

    public function getParamByOrderHeader($orderHeader)
    {
        $logistic = Logistic::query()->where('code',$orderHeader->userdefine1)->first();
        $owner = Owner::query()->where('code',$orderHeader->customerid ?? '')->first();
        $shop = Shop::query()->where('name',$orderHeader->issuepartyname)->where('owner_id',$owner->id)->first();
        $warehouse = app('WarehouseService')->firstOrCreate(["code"=>$orderHeader->warehouseid],["code"=>$orderHeader->warehouseid,"name"=>$orderHeader->warehouseid]);
        return [
            'code' =>$orderHeader->orderno,
            'owner_id' =>$owner->id ?? '',
            'shop_id' =>$shop->id ?? '',
            'logistic_id' => $logistic->id ??'',
            'consignee_name' =>  $orderHeader->c_contact,
            'consignee_phone' =>  empty($orderHeader->c_tel2)?$orderHeader->c_tel1:$orderHeader->c_tel2,
            'province' =>$orderHeader->c_province,
            'city' => $orderHeader->c_city,
            'district' =>$orderHeader->c_district,
            'address' =>$orderHeader->c_address1,
            'client_code' =>$orderHeader->soreference1,
            'wms_edittime' => $orderHeader->edittime,
            'wms_status' => $orderHeader->oracleBASCode_codename_c ?? '',
            'updated_at' => (string)Carbon::now()->format('Y-m-d H:i:s'),
            'created_at' => $orderHeader->addtime,
            'warehouse_id' => $warehouse->id ?? ''
        ];
    }

//    /**
//     * @param App/Order $order
//     * @param App/OracleDOCOrderHeader $orderHeader
//     */
//    public function updateOrderByOrderHeader($order,$orderHeader)
//    {
//        if(!$orderHeader){return ;}
//        if($orderHeader->orderno == $order->code){
//            return ;
//        }else if($orderHeader->soreference1 != $order->client_code){
//            return ;
//        }
//        $params = $this->getParamByOrderHeader($orderHeader);
//
//        $data = [
//                'code'=>$order->code ?? $params['code'],
//                'owner_id'=>$order->code ?? $params['owner_id'],
//                'shop_id'=>$order->code ?? $params['shop_id'],
//                'logistic_id'=>$order->code ?? $params['logistic_id'],
//                'consignee_name'=>$order->code ?? $params['consignee_name'],
//                'province'=>$order->code ?? $params['province'],
//                'city'=>$order->code ?? $params['city'],
//                'district'=>$order->code ?? $params['district'],
//                'address'=>$order->code ?? $params['address'],
//                'wms_edittime'=>$order->code ?? $params['wms_edittime'],
//                'wms_status'=>$order->code ?? $params['wms_status'],
//        ];
//        Order::query()->where('id',$order->id)->update($data);
//    }

    public function getOrderByLogisticNumber($logisticNumber)
    {
        /** @var OracleDOCOrderHeaderService $orderHeaderService */
        $orderHeaderService = app('OracleDocOrderHeaderService');
        $orderHeaders = $orderHeaderService->getQuery()->whereIn('OrderNo',function($query)use($logisticNumber){
            $query->from('Act_Allocation_Details')->select('OrderNo')->where('picktotraceid',$logisticNumber);
        })->first();
        if(!$orderHeaders) return null;
        $this->syncOrderInfo($orderHeaders);
        $code = $orderHeaders->first()->code;
        return $order = Order::query()->with('packages.commodities.commodity')->where('code',$code)->first();
    }

    /**
     * 同步 Order信息
     *
     * @param array $orderHeaders
     * @param bool $syncOrderCommodity
     * @param bool $syncOrderPackage
     * @param bool $syncOrderPackageCommodity
     */
    public function syncOrderInfo($orderHeaders,$syncOrderCommodity = true,$syncOrderPackage = true,$syncOrderPackageCommodity = true){
        $this->syncOrderByWMSOrderHeaders($orderHeaders);
        if($syncOrderCommodity)app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
        if($syncOrderPackage)app('OrderPackageService')->syncOrderPackage($orderHeaders);
        if($syncOrderPackageCommodity)app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
    }

    public function syncOrder(&$orderHeaders)
    {
        $this->syncOrderByWMSOrderHeaders($orderHeaders);
        app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
        app('OrderPackageService')->syncOrderPackage($orderHeaders);
        app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
        $this->pushQueue($orderHeaders);
        unset($orderHeaders);
    }

    public function pushQueue($orderHeaders){
        $orders = Order::query()->with(["logistic","packages.commodities.commodity"])->where('wms_status','订单完成')->whereIn('code',data_get($orderHeaders,'*.orderno'))->get();
        foreach ($orders->chunk(50) as $or){
            dispatch(new OrderCreateInstantBill($or));
        }
    }

    public function syncOrderByWMSOrderHeaders(&$orderHeaders)
    {
        if($orderHeaders->isEmpty())return;
        /**
         * @var OwnerService $ownerService
         * @var LogisticService $logisticService
         * @var ShopService $shopService
         * @var WarehouseService $warehouseService
         */
        $ownerService = app("OwnerService");
        $logisticService = app("LogisticService");
        $shopService = app('ShopService');
        $warehouseService = app('WarehouseService');

        $owner_codes = [];$logistic_codes = [];$warehouse_codes = [];$shop_names = [];$batch_codes = [];
        foreach ($orderHeaders as $orderHeader) {
            if(!empty($orderHeader['waveno']))
                $batch_codes[$orderHeader['waveno']] = $orderHeader['waveno'];
            if(!empty($orderHeader['customerid']))
                $owner_codes[$orderHeader['customerid']] = $orderHeader['customerid'];
            if(!empty($orderHeader['warehouseid']))
                $warehouse_codes[$orderHeader['warehouseid']] = $orderHeader['warehouseid'];
            if(!empty($orderHeader['userdefine1']))
                $logistic_codes[$orderHeader['userdefine1']] = $orderHeader['userdefine1'];
            if(!empty($orderHeader['issuepartyname']) && !empty($orderHeader['customerid'])){
                // 商品换行符处理
                $shop_name = str_replace("\n",' ',$orderHeader['issuepartyname']);
                $value = ['owner_code'=>$orderHeader['customerid'],'issuepartyname'=>$shop_name];
                $key = "owner_code_{$orderHeader['customerid']}_issuepartyname_{$shop_name}";
                $shop_names[$key] = $value;
            }
        }

        $owners = $ownerService->getOwnerByCodes($owner_codes);
        $logistics = $logisticService->getLogisticByCodes($logistic_codes);
        $shops = $shopService->getShopByCodeMap($shop_names);
        $warehouses = $warehouseService->getWareHouseByCodes($warehouse_codes);
        $batches = $this->batchService->getBatchByCodes($batch_codes);

        unset($owner_codes,$logistic_codes,$shop_names,$warehouse_codes);

        $orders = $this->getByWmsOrders($orderHeaders);

        $created_params = $this->getCreateOrderModelsByWMSOrderHeaders($orderHeaders,$orders,$warehouses,$owners,$logistics,$shops,$batches); //3s

        $update_order = $this->getUpdateOrderModelByWMSOrderHeaders($orderHeaders,$orders,$warehouses,$owners,$logistics,$shops,$batches);

        unset($owners,$logistics,$shops,$warehouses,$batches);

        foreach ($update_order as $item) {
            if($item['batch_id'] == null){
                LogService::log(__METHOD__,'batch_id is null',json_encode($batch_codes).$item['code']);
                break;
            }
        }

        unset($batch_codes);

        // 转换插入 3s
        $this->pushOrderCreatedCountCache($created_params);
        if(count($created_params) > 0){
            collect($created_params)->chunk(1000)->each(function($inner_params){
                $arr = $inner_params->toArray();
                $this->insert($arr,false,false,false);
                dispatch(new OrderFreeze($arr));
                //dispatch(new OrderCreateWaybill($arr));
            });
        }
        unset($created_params);
        $update_params = [
            ['id','code','warehouse_id','owner_id','batch_id','shop_id','logistic_id','consignee_name','consignee_phone','province','city','district','address','client_code','wms_status','created_at','updated_at','wms_edittime','order_type','frozen']
        ];
        $update_order->each(function($item)use(&$update_params){
            $update_params[] = $item->toArray();
        });
        unset($update_order);
        if(count($update_params)==0)return;
        $this->pushOrderUpdatedCountCache($orders,$update_params);
        $this->batchUpdate($update_params);
        dispatch(new OrderFreeze($update_params));
        unset($update_params);
    }

    public function getCreateOrderModelsByWMSOrderHeaders(&$orderHeaders,&$orders,&$warehouses,&$owners,&$logistics,&$shops,&$batches)
    {
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService = app('DataHandlerService');

        $warehouse_map = $dataHandlerService->dataHeader(['code'],$warehouses);
        $owner_map = $dataHandlerService->dataHeader(['code'],$owners);
        $logistic_map = $dataHandlerService->dataHeader(['code'],$logistics);
        $shop_map = $dataHandlerService->dataHeader(['name','owner_id'],$shops);
        $order_map = $dataHandlerService->dataHeader(['code'],$orders);
        $batch_map = $dataHandlerService->dataHeader(['code'],$batches);
        $inner_params  = [];
        $date = (string)Carbon::now();
        foreach ($orderHeaders as $orderHeader) {
            $order_no = $orderHeader->orderno;
            $order = $dataHandlerService->getKeyValue(['code'=>$order_no],$order_map);
            if(isset($order))continue;
            $order_model = $this->getCreateOrderModels($orderHeader,$warehouse_map,$owner_map,$logistic_map,$shop_map,$batch_map,$date);
            $inner_params[] = $order_model;
        }
        return $inner_params;
    }

    public function getUpdateOrderModelByWMSOrderHeaders(&$orderHeaders,&$orders,&$warehouses,&$owners,&$logistics,&$shops,&$batches)
    {
        /**
         * @var DataHandlerService $dataHandlerService
         * @var Order $order
         */
        $dataHandlerService = app('DataHandlerService');
        $orderHeader_map = $dataHandlerService->dataHeader(['orderno'],$orderHeaders);
        $warehouse_map = $dataHandlerService->dataHeader(['code'],$warehouses);
        $owner_map = $dataHandlerService->dataHeader(['code'],$owners);
        $logistic_map = $dataHandlerService->dataHeader(['code'],$logistics);
        $shop_map = $dataHandlerService->dataHeader(['name','owner_id'],$shops);
        $batch_map = $dataHandlerService->dataHeader(['code'],$batches);
        $collect = collect();
        $date = (string)Carbon::now();
        foreach ($orders as $order) {
            $orderHeader = $dataHandlerService->getKeyValue(['orderno'=>$order->code],$orderHeader_map);
            if(!$orderHeader)continue;
            $order_model = $this->getCreateOrderModels($orderHeader,$warehouse_map,$owner_map,$logistic_map,$shop_map,$batch_map,$date);
            if(!$order->isEquals($order_model)){
                $order->assignValueByOrder($order_model);
                $collect->push($order);
            }
        }
        return $collect;
    }

    public function getCreateOrderModels(&$orderHeader,&$warehouse_map,&$owner_map,&$logistic_map,&$shop_map,&$batch_map,$date)
    {
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService = app('DataHandlerService');
        $warehouse = $dataHandlerService->getKeyValue(['code'=>$orderHeader->warehouseid],$warehouse_map);
        $owner = $dataHandlerService->getKeyValue(['code'=>$orderHeader->customerid],$owner_map);
        $logistic = $dataHandlerService->getKeyValue(['code'=>$orderHeader->userdefine1],$logistic_map);
        $batch = $dataHandlerService->getKeyValue(['code'=>$orderHeader->waveno],$batch_map);
        $shop['id'] = null;
        if($orderHeader->issuepartyname != null && $orderHeader->issuepartyname != '' ){
            // 商品换行符处理
            $shop_name = str_replace("\n",' ',$orderHeader['issuepartyname']);
            $shop = $dataHandlerService->getKeyValue(['name'=>$shop_name ?? '','owner_id'=>$owner->id??''],$shop_map);
        }
        if(!$batch['id']&&!($orderHeader['status']==90||$orderHeader['status']==00)&&$orderHeader['wave_no']!='*'){
            LogService::log(__METHOD__,__FUNCTION__,'波次为空: code='.$orderHeader['orderno']);
        }
        return [
            'code'=>$orderHeader['orderno'],
            'batch_id' =>$batch['id'] ?? null,
            'warehouse_id' => $warehouse['id'] ?? null,
            'owner_id' => $owner['id'] ?? null,
            'shop_id' => $shop['id'] ?? null,
            'logistic_id' =>$logistic['id'] ?? null,
            'consignee_name' =>  $orderHeader['c_contact'],
            'consignee_phone' => $orderHeader['c_tel2'] ?? $orderHeader['c_tel1'],
            'province' => $orderHeader['c_province'],
            'city' =>  $orderHeader['c_city'],
            'district' => $orderHeader['c_district'],
            'address' => $orderHeader['c_address1'],
            'client_code' => $orderHeader['soreference1'],
            'wms_edittime' => $orderHeader['edittime'],
            'wms_status' => $orderHeader->oracleBASCode->codename_c??'',
            'order_type' => $orderHeader->orderType->codename_c??'',
            'frozen' => Order::getFrozen($orderHeader->releasestatus),
            'updated_at' => $date,
            'created_at' => $orderHeader['addtime']
        ];
    }

    public function createOrFindOrder($orderHeader)
    {
        $order = Order::query()->where('code',$orderHeader->orderno)->first();
        if($order)return $order;
        $create_params = $this->getParamByOrderHeader($orderHeader);
        try {
            $order = Order::query()->create($create_params);
            app('LogService')->log(__METHOD__, __FUNCTION__, '创建 Order' . json_encode($order));
            return $order;
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__, 'Error'.__FUNCTION__, '创建 Order Error' .' || '. json_encode($order).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
            return null;
        }
    }

    public function createOrFindOrderInfo($orderHeader)
    {
        /**
         * @var OrderPackageService $orderPackageService
         * @var OrderPackageCommoditiesService $orderPackageCommoditiesService
         */
        $orderPackageService = app('OrderPackageService');
        $orderPackageCommoditiesService = app('OrderPackageCommoditiesService');
        $orderHeaders = collect();
        $orderHeaders->push($orderHeader);
        try {
            $this->syncOrderByWMSOrderHeaders($orderHeaders);
            $orderPackageService->syncPackageByOrderHeaders($orderHeaders);
            $orderPackageCommoditiesService->syncOrderPackageCommodities($orderHeaders);
            return  Order::query()->with('packages.commodities')->where('code',$orderHeader->orderno)->first();
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__, 'Error'.__FUNCTION__, '创建 Order Error' .' || '. json_encode($orderHeader).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
            return null;
        }
    }

    public function setOrderSyncAt($key,$date,$bool=true){
        if($bool){
            ValueStore::query()->where('name',$key)->update(['value'=>Carbon::parse($date)->subSeconds(1)]);
        } else {
            ValueStore::query()->where('name',$key)->update(['value'=>$date]);
        }
    }

    public function getOrderSyncAt($key,$type='newest'){
        $keyValue = ValueStore::query()->where('name',$key)->first();
        if($keyValue->value)return $keyValue->value;
        if($type == 'newest') $order = Order::query()->orderByDesc('Created_At')->first();
        else $order = Order::query()->orderByDesc('Wms_EditTime')->first();
        if($order)return $order->created_at;
        return Carbon::now()->subSeconds(65);
    }

    public function pushOrderCache($orderHeaders,$prefixKey,$hasKey,$list_key){
        $list = [];
        try {
            Cache::get($hasKey);
            collect($orderHeaders)->each(function($item)use(&$list,$prefixKey){
                $list[] =$item->orderno;
                Cache::put($prefixKey.$item->orderno,true);
            });
            if(count($orderHeaders) > 0){
                Cache::put($list_key,$list);
                Cache::put($hasKey,true);
            }
        } catch (\Exception $e) {

        }
    }

    public function filterOrderByCache($orderHeaders,$key)
    {
        /**
         * @var OracleDOCOrderHeader $item
         */
        if(!$orderHeaders)return $orderHeaders;
        if(!$key)return $orderHeaders;
        try {
            Cache::get($key);
            return array_filter($orderHeaders,function($item)use($key){
                $bool = Cache::get($key.$item->orderno);
                return !$bool;
            });
        } catch (\Exception $e) {
            return $orderHeaders;
        }
    }

    public function cancelOrderCache($key,string $prefix)
    {
        try {
            Cache::get($prefix);
            $list = Cache::get($key);
            collect($list)->each(function ($item)use($prefix) {
                Cache::forget($prefix.$item);
            });
            Cache::put($key,[]);
        } catch (\Exception $e) {
        }
    }

    public function syncCreatedOrder(){
        /**
         * @var OracleDOCOrderHeaderService $oracleDOCOrderHeaderService
         * @var OrderService $orderService
         */
        $newest         = config('sync.order_sync.cache_prefix.created_at');
        $have_task_is_running_key  = config('sync.order_sync.cache_prefix.newest_is_running');
        $newest_list    = config('sync.order_sync.cache_prefix.newest_list');
        $hasKey         = config('sync.order_sync.cache_prefix.newest_has');
        $prefixKey      = config('sync.order_sync.cache_prefix.newest');

        $have_task_is_running = Cache::get($have_task_is_running_key);
        if($have_task_is_running)return;
        Cache::remember($have_task_is_running_key,config('cache.expirations.forever'),function (){
            return true;
        });

        ini_set('memory_limit', '512M');
        $orderService = app('OrderService');
        $oracleDOCOrderHeaderService = app('OracleDocOrderHeaderService');

        $last_date = $orderService->getOrderSyncAt($newest,'newest');                             // 获取时间点

        $orderHeaders = $oracleDOCOrderHeaderService->getWMSOrderOnStartDate($last_date);               // WMS订单
        if($orderHeaders->count()==0)return;
        $last_order = $orderHeaders->first();                                                           // 时间点靠后的
        $newest_orders = $orderHeaders->where('addtime',$last_order->addtime);

        $orderHeaders = $orderService->filterOrderByCache($orderHeaders,$newest_list);                  // 对比缓存

        if(count($newest_orders)>0 && count($orderHeaders) >0){

            $orderService->syncOrder($orderHeaders);                                                //  同步订单
            $orderService->cancelOrderCache($newest_list,$prefixKey);                                   //  清除缓存
            $orderService->pushOrderCache($newest_orders,$prefixKey,$hasKey,$newest_list);              //  添加缓存
            $orderService->setOrderSyncAt($newest,$last_order->addtime,count($orderHeaders)>0);   //  更新时间
        }

        Cache::remember($have_task_is_running_key,config('cache.expirations.forever'),function (){
            return false;
        });
    }

    public function syncUpdatedOrder(){
        /**
         * @var OracleDOCOrderHeaderService $oracleDOCOrderHeaderService
         * @var OrderService $orderService
         */
        $renewal        = config('sync.order_sync.cache_prefix.updated_at');
        $have_task_is_running_key  = config('sync.order_sync.cache_prefix.renewal_is_running');
        $renewal_list   = config('sync.order_sync.cache_prefix.renewal_list');
        $hasKey         = config('sync.order_sync.cache_prefix.renewal_has');
        $prefixKey      = config('sync.order_sync.cache_prefix.renewal');

        $have_task_is_running = Cache::get($have_task_is_running_key);
        if($have_task_is_running)return;
        Cache::remember($have_task_is_running_key,config('cache.expirations.forever'),function (){
            return true;
        });

        ini_set('memory_limit', '512M');

        $orderService = app('OrderService');
        $oracleDOCOrderHeaderService = app('OracleDocOrderHeaderService');

        $last_date = $orderService->getOrderSyncAt($renewal,'renewal');                               // 获取时间点


        $orderHeaders = $oracleDOCOrderHeaderService->getWMSOrderOnEditDate($last_date);                   // WMS订单

        if($orderHeaders->count()==0)return;
        $renewal_order = $orderHeaders->first();                                                            // 时间点靠后的
        $renewal_orders =  $orderHeaders->where('edittime',$renewal_order->edittime);

        $orderHeaders = $orderService->filterOrderByCache($orderHeaders,$renewal_list);                     // 对比缓存

        if(count($renewal_orders)>0 && count($orderHeaders)>0){

            $orderService->syncOrder($orderHeaders);                                                    // 同步订单
            $orderService->cancelOrderCache($renewal_list,$prefixKey);                                      // 清除缓存
            $orderService->pushOrderCache($renewal_orders,$prefixKey,$hasKey,$renewal_list);                // 添加缓存
            $orderService->setOrderSyncAt($renewal,$renewal_order->edittime,count($orderHeaders)>0);   // 更新时间
        }

        Cache::remember($have_task_is_running_key,config('cache.expirations.forever'),function (){
            return false;
        });
    }

    /**
     * 根据 订单号集合 OrderNo 同步订单
     * @param array $orderNos
     */
    public function syncOrderInfoByWmsOrderNos($orderNos)
    {
        if(empty($orderNos))return ;
        if(count($orderNos)==0)return;
        $orderHeaders = app('OracleDocOrderHeaderService')->getOrderInfoByOrderNos($orderNos);
        $this->syncOrderInfoByWMSOrderHeaders($orderHeaders);
    }

    /**
     * 根据表头信息 OrderHeader 集合 同步订单
     * @param array $orderHeaders
     */
    public function syncOrderInfoByWMSOrderHeaders($orderHeaders){
        if(empty($orderHeaders))return ;
        if(count($orderHeaders)==0)return;
        $orderHeaders = app('OracleDocOrderHeaderService')->loadMissing($orderHeaders);
        $this->syncOrderByWMSOrderHeaders($orderHeaders);
        app('OrderPackageService')->syncOrderPackage($orderHeaders);
        app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
    }

    public function update(array $params, array $values)
    {
        $query = Order::query();
        foreach ($params as $column=>$param){
            if (is_array($param))$query->whereIn($column,$param);
            else $query->where($column,$param);
        }
        return $query->update($values);
    }

    /**
     * 直接生成order
     *
     * @param array $values
     * @return Model
     */
    public function createOrder(array $values)
    {
        return Order::query()->create($values);
    }

    /**
     * 订单量丢失补偿逻辑
     *
     * @param int $owner
     * @param array|null $logistics
     */
    private function orderQuantityCompensationLogic($owner, $logistics = null)
    {
        if (!$logistics)$logistics = app("OwnerPriceExpressService")->getBuildLogistic($owner);
        $query = DB::raw(<<<sql
SELECT COUNT(1) count,logistic_id FROM orders WHERE wms_status = '订单完成'
AND owner_id = ?
AND wms_edittime like ? GROUP BY logistic_id
sql
        );
        $statistics = DB::select($query,[$owner,date("Y-m")."%"]);
        $toB = 0;
        $toC = 0;
        foreach ($statistics as $statistic){
            if (array_search($statistic->logistic_id,$logistics)===false)$toB += $statistic->count;
            else $toC += $statistic->count;
        }
        Cache::put(date("Y-m")."|B|".$owner,$toB,2764800);
        Cache::put(date("Y-m")."|C|".$owner,$toC,2764800);
    }

    /**
     * 设置订单量
     *
     * @param int $owner
     * @param int $logistic
     */
    public function setOrderQuantity(int $owner, int $logistic)
    {
        $logistics = app("OwnerPriceExpressService")->getBuildLogistic($owner);
        $date = date("Y-m");
        if (array_search($logistic,$logistics)===false)$type = "|B|";
        else $type = "|C|";
        if (!Cache::has($date.$type.$owner)){
            //补偿逻辑
            $this->orderQuantityCompensationLogic($owner,$logistics);
        }
        Cache::increment($date.$type.$owner);
        $key = $date."|D|".$owner;
        if (!Cache::has($key) || time()-Cache::get($key)>60){
            //向数据库持久化
            OwnerReport::query()->where("owner_id",$owner)
                ->where("counting_month","like",$date."%")
                ->update(["to_business_quantity"=>Cache::get($date."|B|".$owner),"to_customer_quantity"=>Cache::get($date."|C|".$owner)]);
        }
        Cache::put($key,time());
    }

    /**
     * 获取货主下有效订单量 对C端
     *
     * @param int $owner
     * @param bool $isToB
     *
     * @return int
     */
    public function getOrderQuantity(int $owner, bool $isToB = false):int
    {
        $date = date("Y-m");
        if ($isToB)$type = "|B|";
        else $type = "|C|";
        if (!Cache::has($date.$type.$owner))$this->orderQuantityCompensationLogic($owner);
        return Cache::get($date.$type.$owner);
    }

    /**
     * 获取物流费用信息
     *
     * @param Order|\stdClass $order
     *
     * @return array
     */
    public function getLogisticFeeInfo(Order $order):array
    {
        //预定义返回参数
        $result = [
            "amount" => 0, "logisticBill" => null, "volume" => 0,
            "weight" => 0, "logisticFee" => null, "logisticTaxFee" => null,
            "items" => [],
        ];
        if (!$order->logistic)return $result;
        //获取城市
        $province = app("ProvinceService")->getProvince($order->province);
        $unit = app("UnitService")->getUnit();
        $city = app("CityService")->getCity($order->city);
        $isBunched = $order->logistic->is_bunched=='Y';
        $exe = function ($type,$ownerId,$logisticId,$amount,$weight)use($province, $unit, $city){
            switch ($type){
                case "快递":
                    /** @var OwnerPriceExpressService $service */
                    $service = app("OwnerPriceExpressService");
                    return $service->matching($weight,$ownerId,$logisticId,$province->id);
                default:
                    /** @var OwnerPriceLogisticService $service */
                    $service = app("OwnerPriceLogisticService");
                    return $service->matching($amount,$ownerId,$logisticId,$unit->id,$province->id,$city->id);
            }
        };
        foreach ($order->packages as &$package){
            $tax = $fee = null;
            $result["logisticBill"] .= $package->logistic_number.",";
            $result["volume"] += $package->bulk;
            $result["weight"] += $package->weight;
            $partAmount = 0;
            foreach($package->commodities as $commodity)$partAmount += $commodity->amount;
            $result["amount"] += $partAmount;

            if ($province && !$isBunched){
                list($fee,$tax) = $exe($order->logistic->type,$order->owner_id, $order->logistic_id, $partAmount, $package->weight);
                $result["logisticFee"] += $fee;
                $result["logisticTaxFee"] += $tax;
            }
            $result["items"][] = [
                "amount" => $partAmount,
                "logistic_bill" => $package->logistic_number,
                "volume"=>$package->bulk,
                "weight"=>$package->weight,
                "logistic_fee" => $fee,
                "tax_fee" => $tax,
            ];
        }
        /* 为子母单 且 重量与省份完整 且 重量大于0 且 省份存在 进入子母单计算 */
        if ($province && $isBunched)list($result["logisticFee"],$result["logisticTaxFee"]) =
            $exe($order->logistic->type,$order->owner_id, $order->logistic_id, $result["amount"], $result["weight"]);
        if ($result["logisticFee"]<0)$result["logisticFee"] = null;
        if ($result["logisticTaxFee"]<0)$result["logisticTaxFee"] = null;
        $result["logisticBill"] = rtrim($result["logisticBill"],",");
        return $result;
    }
    /**
     * 生成即时账单
     *
     * @param Order $order
     * @return bool
     */
    public function createInstantBill(Order $order):bool
    {
        /** @var \stdClass $order */
        //检查订单对象
        if (!$order || $order->wms_status != "订单完成")return true;
        //防重推标记
        if (Cache::has("owner_fee_details:orders_".$order->id))return true;
        //加载所需数据
        $order->loadMissing(["logistic","shop","packages.commodities.commodity","batch"]);
        //获取运输费
        $logisticInfo = $this->getLogisticFeeInfo($order);

        //获取作业费
        /** @var OwnerPriceOperationService $service */
        $service = app("OwnerPriceOperationService");
        list($id,$money,$workTaxFee) = $service->matching($order,Feature::MAPPING["order"],$order->owner_id);

        //数据组装
        $detail = OwnerFeeDetail::query()->create([
            "owner_id"          => $order->owner_id,
            "worked_at"         => $order->wms_edittime ?? $order->updated_at,
            "type"              => "发货",
            "shop_id"           => $order->shop_id,
            "operation_bill"    => $order->code,
            "province"          => $order->province,
            "consignee_name"    => $order->consignee_name,
            "consignee_phone"   => $order->consignee_phone,
            "commodity_amount"  => $logisticInfo["amount"],
            "logistic_bill"     => $logisticInfo["logisticBill"],
            "volume"            => $logisticInfo["volume"],
            "weight"            => $logisticInfo["weight"],
            "logistic_id"       => $order->logistic_id,
            "work_fee"          => $money,
            "owner_price_operation_id"  => $id,
            "logistic_fee"      => $logisticInfo["logisticFee"],
            "created_at"        => date('Y-m-d H:i:s'),
            "outer_id"          => $order->id,
            "outer_table_name"  => "orders",
            "work_tax_fee"      => $workTaxFee,
            "logistic_tax_fee"  => $logisticInfo["logisticTaxFee"],
        ]);
        //后续处理
        foreach ($logisticInfo["items"] as &$item)$item["owner_fee_detail_id"] = $detail->id;
        if (count($logisticInfo["items"])>1)OwnerFeeDetailLogistic::query()->insert($logisticInfo["items"]);
        $this->setOrderQuantity($order->owner_id,$order->logistic_id);
        Cache::put("owner_fee_details:orders_".$order->id,1,86400);
        return true;
    }

    public function getMonthTotal($ownerId = null, $month = null)
    {
        if (!$month)$month = date("Y-m");
        $day = date("t",strtotime($month));
        $whereSql = $ownerId ? "and owner_id = ? " : " ";
        $count = DB::selectOne(DB::raw("SELECT count(*) c from orders where wms_status ='订单完成' {$whereSql} and wms_edittime BETWEEN '{$month}-01 00:00:00' and '{$month}-{$day} 23:59:59';"));
        return $count->c;
    }

    public function pushOrderUpdatedCountCache($orders,$update_params)
    {
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService =  app(DataHandlerService::class);
        $order_map = $dataHandlerService->dataHeader(['code'],$orders);
        $owner_map = [];
        $month_begin =date('Y-m-01 00:00:00');
        foreach ($update_params as $update_param) {
            if(!($update_param['wms_status'] ?? false) || $update_param['wms_status']!='订单完成')continue;
            $wms_EditTime = \Illuminate\Support\Carbon::parse($update_param['wms_edittime']);
            if($wms_EditTime->isBefore($month_begin))continue;
            $owner_id = $update_param['owner_id'] ?? false;
            if(!$owner_id)continue;
            $order = $dataHandlerService->getKeyValue(['code'=>$update_param['code']],$order_map);
            if(!$order)continue;
            if($order['wms_status'] ==='订单完成')continue;
            if(!array_key_exists($owner_id,$owner_map))$owner_map[$owner_id]=1;
            else $owner_map[$owner_id]+=1;
        }
        foreach ($owner_map as $owner_id=>$count) {
            $this->setCurrentFinishedOrders_byOwnerId($owner_id,$count);
        }
    }

    public function pushOrderCreatedCountCache($created_params)
    {
        $owner_map=[];
        $month_begin =date('Y-m-01 00:00:00');
        foreach ($created_params as $created_param) {
            $owner_id = $created_param['owner_id'] ?? false;
            $wms_EditTime = \Illuminate\Support\Carbon::parse($created_param['wms_edittime']);
            if($wms_EditTime->isBefore($month_begin))continue;
            if(!$owner_id)continue;
            if($created_param['wms_status']!=='订单完成')continue;
            if(!array_key_exists($owner_id,$owner_map)) $owner_map[$owner_id]=1;
            else  $owner_map[$owner_id]+=1;
        }
        foreach ($owner_map as $owner_id=>$count) {
            $this->setCurrentFinishedOrders_byOwnerId($owner_id,$count);
        }
    }

    private function setCurrentFinishedOrders_byOwnerId($id,$count,$cancelCount = 0)
    {
        $sum = Cache::get("order_count_ownerId_{$id}",function()use($id){
            return Order::query()
                ->where('owner_id',$id)
                ->where('wms_status','订单完成')
                ->where('wms_edittime','>=',date('Y-m-01 00:00:00'))->count();
        });
        $sum += $count;
        $sum -= $cancelCount;
        Cache::put("order_count_ownerId_{$id}",$sum,date('Y-m-t 23:59:59'));
    }

    public function getCurrentFinishedOrders_byOwnerId($id): int
    {
        return Cache::get("order_count_ownerId_{$id}",function()use($id){
            return Order::query()->where('owner_id',$id)
                ->where('wms_status','订单完成')
                ->where('wms_edittime','>=',date('Y-m-01 00:00:00'))
                ->count();
        });
    }
    /**
     * 校正运输费
     *
     * @param Order $order
     *
     * @return bool
     */
    public function reviseLogisticFee(Order $order):bool
    {
        /** @var \stdClass $order */
        if (!$order || $order->wms_status != '订单完成')return false; //订单不存在或状态不为完成
        $feeBill = OwnerFeeDetail::query()->where("outer_table_name","orders")
            ->where("outer_id",$order->id)->whereNull("logistic_fee")->first();
        if (!$feeBill)return false; //是否已有即时账单，没有跳出
        $order->loadMissing("packages","owner");//加载包裹
        if (!$order->packages->count() || !$order->owner)return false;

        foreach ($order->packages as $package)if (!$package->weight)return false; //包裹存在且全部存在数量

        $logistic_fee = 0;
        $volume = 0;
        $weight = 0;
        $isBunched = false;
        if (!$order->logistic || $order->logistic->type != "快递")$logistic_fee = null;
        else $isBunched = $order->logistic->is_bunched=='Y';
        $weightExceptionMark = false;
        $provinceId = null;
        $taxFee = 0;
        foreach ($order->packages as $package){
            $tax = 0;

            $volume += $package->bulk;
            $weight += $package->weight;
            if (!$weightExceptionMark && (!$package->weight || $package->weight<0))$weightExceptionMark = true;
            $fee = null;

            $provinceName = mb_substr($order->province,0,2);
            $province = app(CacheService::class)->getOrExecute("province_".$provinceName,function ()use($provinceName){
                return Province::query()->where("name","like",$provinceName."%")->first();
            },86400);
            $fee = null;
            if ($province){
                if (!$provinceId)$provinceId = $province->id;
                else if ($provinceId!=$province->id)$weightExceptionMark = true;
                if (!$isBunched)list($fee,$tax) = app("OwnerPriceExpressService")->matching($package->weight, $order->owner_id, $order->logistic_id, $province->id);
            }else $logistic_fee = null;

            OwnerFeeDetailLogistic::query()->where("owner_fee_detail_id",$feeBill->id)->where("logistic_bill",$package->logistic_number)->update([
                "volume"=>$package->bulk,
                "weight"=>$package->weight,
                "logistic_fee" => $fee,
            ]);
            if ($logistic_fee!==null){
                if ($fee<0)$logistic_fee = null;
                else $logistic_fee += $fee;
            }
            $taxFee += $tax;
        }
        if ($isBunched && !$weightExceptionMark && $weight>0 && $provinceId)list($logistic_fee,$taxFee) = app("OwnerPriceExpressService")->matching($weight, $order->owner_id, $order->logistic_id, $provinceId);
        $feeBill->update(["logistic_fee"=>$logistic_fee,"volume"=>$volume,"weight"=>$weight,"logistic_tax_fee"=>$taxFee]);
        return true;
    }

    public function freezeRemoveWave($orders, $isSql = false)
    {
        if (!$isSql && !is_array($orders))$orders = [$orders];
        if (!$isSql){
            $where = "''";
            foreach ($orders as $f)$where .= ",'{$f}'";
            $orders = $where;
        }
        $sql = <<<sql
    DELETE FROM DOC_WAVE_DETAILS WHERE (WAVENO,ORDERNO) IN (SELECT DOC_ORDER_HEADER.WAVENO,DOC_ORDER_HEADER.ORDERNO FROM DOC_ORDER_HEADER LEFT JOIN DOC_WAVE_DETAILS ON DOC_ORDER_HEADER.WAVENO = DOC_WAVE_DETAILS.WAVENO
    AND DOC_ORDER_HEADER.ORDERNO = DOC_WAVE_DETAILS.ORDERNO WHERE DOC_ORDER_HEADER.orderno IN ({$orders}) AND DOC_ORDER_HEADER.WAVENO != '*' AND DOC_ORDER_HEADER.WAVENO IS NOT NULL)
sql;
        $result = DB::connection("oracle")->delete(DB::raw("$sql"));
        LogService::log(__METHOD__,"删除波次详情",$sql);
        return $result;
    }

    /**
     * 恢复不存在商品订单
     *
     * @param Order|\stdClass $order
     */
    public function notExistToRecover(Order $order)
    {
        $sql = <<<sql
SELECT customerid,orderno,sku,orderlineno,qty_each FROM ACT_ALLOCATION_DETAILS WHERE orderno = ?
sql;

        $allocations = DB::connection("oracle")->select(DB::raw($sql),[$order->code]);
        if (!$allocations)return;
        $insert[] = [];
        $sku = array_column($allocations,"sku");
        app("CommodityService")->notExistToCreate($order->owner_id,$sku);
        $commodities = Commodity::query()->where("owner_id",$order->owner_id)->whereIn("sku",$sku)->get();
        $commodityMap = [];
        foreach ($commodities as $commodity)$commodityMap[$commodity->sku] = $commodity->id;
        foreach ($allocations as $allocation){
            if (!($commodityMap[$allocation->sku] ?? false))LogService::log(__CLASS__,"ERROR-SKU对应商品在FLUX不存在",json_encode($allocation,JSON_UNESCAPED_UNICODE));
            $insert[] = [
                'order_id'      => $order->id,
                'commodity_id'  => $commodityMap[$allocation->sku] ?? null,
                'amount'        => $allocation->qty_each,
                'location'      => $allocation->location,
            ];
        }
        OrderCommodity::query()->insert($insert);
    }

}