baoshi-was/app/Services/OrderService.php

<?php

namespace App\Services;

use App\Logistic;
use App\OracleActAllocationDetails;
use App\OracleDOCASNHeader;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderIssue;
use App\Owner;
use App\OwnerPriceExpress;
use App\OwnerPriceLogistic;
use App\RejectedBill;
use App\Services\common\BatchUpdateService;
use App\Services\common\DataHandlerService;
use App\Shop;
use App\ValueStore;
use App\Warehouse;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

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

    public function insert(array $params)
    {
        if (!$params) return true;
        if (count($params) == 0) return true;
        try {
            $bool = Order::query()->insert($params);
            if ($bool) app('LogService')->log(__METHOD__, __FUNCTION__, '批量创建 Order' . json_encode($params));
            else app('LogService')->log(__METHOD__, 'ERROR' . __FUNCTION__, '批量创建 Order ERROR' . json_encode($params));
            return $bool;
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__, 'ERROR' . __FUNCTION__, '批量创建 Order ERROR' . json_encode($params) . json_encode($e->getMessage()) . json_encode($e->getTraceAsString()));
            return false;
        }
    }

    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 .= " AND c_contact like '" . $c_contact . "'";
        }
        if ($c_tel2) {
            $sql .= " AND (c_tel2 like '" . $c_tel2 . "' OR c_tel1 like '" . $c_tel2 . "')";
        }
        if ($c_province) {
            $sql .= " AND c_province like '" . $c_province . "'";
        }
        if ($c_city) {
            $sql .= " AND c_city like '" . $c_city . "'";
        }
        if ($c_district) {
            $sql .= " AND c_district like '" . $c_district . "'";
        }
        if ($releasestatus) {
            $sql .= " AND releasestatus = '" . $releasestatus . "'";
        }
        if ($alternate_sku1) {
            if ($checkAllSign) $detailsOrderno = $this->getOrdersNo($alternate_sku1, false);
            else $detailsOrderno = $this->getOrdersNo($alternate_sku1, true, $request->page ?? 1, $request->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 .= " and orderno like '" . $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) $sql .= " and carriername like '" . $carriername . "%'";
        if ($soreference1) {
            $arr = array_values(array_filter(preg_split('/[,， ]+/is', $soreference1)));
            if (count($arr) == 1) {
                $sql .= " and soreference1 like '" . $soreference1 . "%'";
            }
            if (count($arr) > 1) {
                $sql .= " and soreference1 in (";
                foreach ($arr as $index => $str) {
                    if ($index == 0) {
                        $sql .= "'" . $str . "'";
                        continue;
                    }
                    $sql .= ",'" . $str . "'";
                }
                $sql .= ")";
            }
        }
        if ($waveno) $sql .= " and WaveNo like '" . $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) {
            $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 . "%'";
        }
        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;
        }
        $sql = "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
        ,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
        ,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.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 ($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, 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.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";
        }

        $sql = $this->getSql($params, $params['page'] ?? 1, $params['paginate'] ?? 50);
        $orders = DB::connection('oracle')->select(DB::raw($sql));
        return $this->orderFormat($orders);
    }

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

    private function orderFormat($orders)
    {
        $commodities = [];
        $orderNos = "(''";
        $picktotraceids = [];
        /*
         * 第二种扁平化方式(节省空间)： 使用快慢指针，因拿到数据正常为顺序数据,自下标1开始与上一条对比orderno唯一标识，不同则更新慢指针下标，
         *  相同则为指定下标map类型数组追加一个键值对属性来记录同类数量,如N条，每次追加属性时先看属性是否存在，存在+1
         * */
        foreach ($orders as $index => $order) {
            if (isset($commodities[$order->orderno])) {
                array_push($commodities[$order->orderno],
                    ["sku" => $order->sku, "alternate_sku1" => $order->alternate_sku1, "descr_c" => $order->descr_c, "qtyordered" => $order->qtyordered
                        , "checktime" => $order->checktime, "orderdetailcodename" => $order->orderdetailcodename]);
                unset($orders[$index]);
                continue;
            }
            $commodities[$order->orderno] = [["sku" => $order->sku, "alternate_sku1" => $order->alternate_sku1,
                "descr_c" => $order->descr_c, "qtyordered" => $order->qtyordered, "checktime" => $order->checktime, "orderdetailcodename" => $order->orderdetailcodename]];
            $orderNos .= ",'" . $order->orderno . "'";
        }
        $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 OrderPackageService $orderPackageService */
        $orderPackageService = app('OrderPackageService');
        $order = Order::query()->where('client_code', $clientCode)->first();

        $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();

        if ($orderHeader == null) {
            return null;
        }
        $orderHeadAttr = $orderHeader->toArray();
        if ($order == null) {
            $customer_name = $orderHeadAttr['oracleBASCustomer_descr_c'];
            $owner = Owner::query()->where('code', $orderHeadAttr['customerid'])->first();
            if (!$owner) {
                try {
                    $owner = Owner::query()->create(['code' => $orderHeadAttr['customerid'], 'name' => $customer_name]);
                    app('LogService')->log(__METHOD__, __FUNCTION__, '创建货主' . json_encode($owner));
                } catch (\Exception $e) {
                    app('LogService')->log(__METHOD__, __FUNCTION__, '创建货主失败' . $e->getMessage() . $e->getTraceAsString());
                }
            }
            $owner_id = $owner['id'];
            $shop_name = $orderHeadAttr['issuepartyname'];
            $shop_Id = null;
            if ($shop_name) {
                $shop = Shop::query()->firstOrCreate(['name' => $shop_name, 'owner_id' => $owner_id]);
                $shop_Id = $shop['id'];
            }
            $logistics = Logistic::query()->where(['code' => $orderHeadAttr['userdefine1']])->first();
            $logistics_id = null;
            if ($logistics) {
                $logistics_id = $logistics['id'];
            } else {
                try {
                    $logistics = Logistic::query()->create(['name' => $orderHeadAttr['carriername'], 'code' => $orderHeadAttr['userdefine1']]);
                    $logistics_id = $logistics['id'];
                    app('LogService')->log(__METHOD__, __FUNCTION__, '创建承运商' . json_encode($logistics));
                } catch (\Exception $e) {
                    app('LogService')->log(__METHOD__, __FUNCTION__, '创建承运商失败' . $e->getMessage() . $e->getTraceAsString());
                }
            }
            $warehouse = Warehouse::query()->where('code', $orderHeadAttr['warehouseid'])->first();
            $arr = [
                'warehouse_id' => $warehouse->id ?? '',
                'code' => $orderHeadAttr['orderno'],
                'owner_id' => $owner_id,
                'wms_status' => $orderHeadAttr['oracleBASCode_codename_c'],
                'created_at' => $orderHeadAttr['addtime'],
                'logistic_id' => $logistics_id,
                'shop_id' => $shop_Id,
                'consignee_name' => $orderHeadAttr['c_contact'],
                'consignee_phone' => empty($orderHeadAttr['c_tel2']) ? $orderHeadAttr['c_tel1'] : $orderHeadAttr['c_tel2'],
                'province' => $orderHeadAttr['c_province'],
                'city' => $orderHeadAttr['c_city'],
                'district' => $orderHeadAttr['c_district'],
                'address' => $orderHeadAttr['c_address1'],
                'client_code' => $orderHeadAttr['soreference1'],
            ];
            $order = Order::query()->create($arr);
            app('LogService')->log(__METHOD__, __FUNCTION__, '创建 Order ' . json_encode($order));
            unset($arr, $orderHeadAttr, $owner);
        } else {
            $this->updateOrderByOrderHeader($order, $orderHeader);
        }
        $orderPackageService->createdByOrder($order);
        unset($order);
        return Order::with('packages.commodities.commodity')->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)
    {
        $ASNHeader = OracleDOCASNHeader::query()->where('ASNReference3', $logisticNumberReturn)->first();
        if (!$ASNHeader) {
            return null;
        }
        $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $ASNHeader->ASNReference2);
        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;
    }

    /**
     * @param $orderHeaders
     * @return \Illuminate\Database\Eloquent\Builder[]|Collection|null
     */
    public function createByWmsOrder($orderHeaders)
    {
        if ($orderHeaders->isEmpty()) return null;
        /**
         * @var OwnerService $ownerService
         * @var WarehouseService $warehouseService
         * @var LogisticService $logisticService
         * @var ShopService $shopService
         * @var OrderPackageService $orderPackageService
         */
        $warehouseService = app(WarehouseService::class);
        $ownerService = app(OwnerService::class);
        $logisticService = app(LogisticService::class);
        $shopService = app(ShopService::class);
        $orderPackageService = app(OrderPackageService::class);

        $owners_code_map = [];
        $logistics_code_map = [];
        $shop_name_map = [];
        $owners_id_map = [];
        $warehouses_code_map = [];

        $owners = $ownerService->getByWmsOrders($orderHeaders);
        $logistics = $logisticService->getByWmsOrders($orderHeaders);
        $shops = $shopService->getByWmsOrders($orderHeaders);
        $warehouses = $warehouseService->getByWmsOrders($orderHeaders);


        foreach ($owners as $owner) {
            $owners_code_map[$owner->code] = $owner;
            $owners_id_map[$owner->id] = $owner;
        }
        foreach ($logistics as $logistic) {
            $logistics_code_map[$logistic->code] = $logistic;
        }

        foreach ($shops as $shop) {
            $owner_code = $owners_id_map[$shop->owner_id] ? $owners_id_map[$shop->owner_id]['code'] : '';
            $key = ' owner_code=' . $owner_code . ' name=' . $shop->name;
            $shop_name_map[$key] = $shop;
        }

        foreach ($warehouses as $warehouse) {
            $warehouses_code_map[$warehouse->code] = $warehouse;
        }

        $insert_params = $this->getParamsByOrderHeader($orderHeaders, $owners_code_map, $logistics_code_map, $shop_name_map, $warehouses_code_map);
        $update_params = $this->getUpdateParams($orderHeaders, $owners_code_map, $logistics_code_map, $shop_name_map, $warehouses_code_map);
        if (count($insert_params) > 0) {
            $this->insert($insert_params);
        }
        if (count($update_params) > 1) {
            $this->batchUpdate($update_params);
        }
        $orderPackageService->createByWmsOrder($orderHeaders);
        $order_nos = data_get($orderHeaders, '*.orderno');
        unset($orderHeaders_map, $orders_code_map, $shop_name_map, $logistics_code_map, $owners_code_map);
        return Order::query()->whereIn('code', $order_nos)->get();
    }

    public function getParamsByOrderHeader($orderHeaders_map, $owners_code_map, $logistics_code_map, $shop_name_map, $warehouses_code_map)
    {
        $params = [];
        $orders = Order::query()->whereIn('code', data_get($orderHeaders_map, '*.orderno'))->get();
        $order_code_map = [];
        foreach ($orders as $order) {
            $order_code_map[$order->code] = $order;
        }
        $date = Carbon::now()->format('Y-m-d H:i:s');
        foreach ($orderHeaders_map as $orderHeader) {
            if ($order_code_map[$orderHeader->orderno] ?? false) continue;
            $owner = $owners_code_map[$orderHeader->customerid] ?? null;
            $logistic = $logistics_code_map[$orderHeader->userdefine1] ?? null;
            $warehouse = $warehouses_code_map[$orderHeader->warehouseid] ?? null;
            $key = ' owner_code=' . $orderHeader->customerid . ' name=' . $orderHeader->issuepartyname ?? '';
            $shop = $shop_name_map[$key] ?? '';
            $params[] = [
                'code' => $orderHeader->orderno,
                'owner_id' => $owner->id ?? null,
                'wms_status' => $orderHeader->oracleBASCode ? $orderHeader->oracleBASCode->codename_c : null,
                'created_at' => $orderHeader->addtime,
                'updated_at' => $date,
                'logistic_id' => $logistic->id ?? null,
                'shop_id' => $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,
                'wms_edittime' => $orderHeader->edittime,
                'warehouse_id' => $warehouse->id ?? ''
            ];
        }
        return $params;
    }

    public function getUpdateParams($orderHeaders, $owners_code_map, $logistics_code_map, $shop_name_map, $warehouses_code_map)
    {
        if (!$orderHeaders) {
            [];
        }
        $orders = Order::query()->whereIn('code', data_get($orderHeaders, '*.orderno'))->get();
        $update_params = [[
            'id', 'owner_id', 'wms_status', 'logistic_id', 'shop_id', 'consignee_name', 'consignee_phone', 'province', 'city', 'district', 'address', 'client_code', 'updated_at', 'wms_edittime', 'warehouse_id'
        ]];
        $orderHeaders_map = [];
        foreach ($orderHeaders as $orderHeader) {
            $orderHeaders_map[$orderHeader->orderno] = $orderHeader;
        }
        $updated_at = Carbon::now()->toDateTimeString();
        $orders->each(function ($order) use ($orderHeaders_map, &$owners_code_map, &$logistics_code_map, &$shop_name_map, &$warehouses_code_map, &$update_params, $updated_at) {
            $order_header = $orderHeaders_map[$order->code] ?? null;
            if (isset($order_header)) {
                $owner = $owners_code_map[$order_header->customerid] ?? null;
                $logistic = $logistics_code_map[$order_header->userdefine1] ?? null;
                $warehouse = $warehouses_code_map[$order_header->warehouseid] ?? null;
                $key = ' owner_code=' . $order_header->customerid . ' name=' . $order_header->issuepartyname ?? null;
                $shop = $shop_name_map[$key] ?? null;
                $this->UpdateOrderParamBy($shop, $logistic, $owner, $warehouse, $order, $order_header, $updated_at, $update_params);
            }
        });
        return $update_params;
    }

    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 updateByWmsOrders($orderHeaders)
    {
        if (!$orderHeaders) {
            return null;
        }
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService = app(DataHandlerService::class);
        /** @var OrderPackageService $orderPackageService */
        $orderPackageService = app(OrderPackageService::class);
        if (!$orderHeaders || $orderHeaders->count() == 0) {
            return null;
        }
        $orders = $this->getByWmsOrders($orderHeaders);
        $orders_code_map = $dataHandlerService->dataHeader(['code'], $orders);
        $owners = app(OwnerService::class)->getByWmsOrders($orderHeaders);
        $owner_code_map = $dataHandlerService->dataHeader(['code'], $owners);

        $logistics = app(LogisticService::class)->getByWmsOrders($orderHeaders);
        $logistics_code_map = $dataHandlerService->dataHeader(['code'], $logistics);

        $shops = app(ShopService::class)->getByWmsOrders($orderHeaders);
        $shops_map = $dataHandlerService->dataHeader(['owner_id', 'name'], $shops);

        $warehouses = app(WarehouseService::class)->getByWmsOrders($orderHeaders);
        $warehouses_map = $dataHandlerService->dataHeader(['code'], $warehouses);
        $updateParams = [[
            'id', 'owner_id', 'wms_status', 'logistic_id', 'shop_id', 'consignee_name', 'consignee_phone', 'province', 'city', 'district', 'address', 'client_code', 'updated_at', 'wms_edittime', 'warehouse_id', 'created_at'
        ]];
        $updated_at = Carbon::now()->toDateTimeString();
        foreach ($orderHeaders as $orderHeader) {
            $order = $dataHandlerService->getKeyValue(['code' => $orderHeader->orderno], $orders_code_map);
            if (!$order) continue;
            $logistic = $dataHandlerService->getKeyValue(['code' => $orderHeader->userdefine1], $logistics_code_map);
            $owner = $dataHandlerService->getKeyValue(['code' => $orderHeader->customerid], $owner_code_map);
            $shop = $dataHandlerService->getKeyValue(['owner_id' => $owner->id ?? '', 'name' => $orderHeader->issuepartyname], $shops_map);
            $warehouse = $dataHandlerService->getKeyValue(['code' => $orderHeader->warehouseid], $warehouses_map);
            $this->UpdateOrderParamBy($shop, $logistic, $owner, $warehouse, $order, $orderHeader, $updated_at, $updateParams);
        }
        if (count($updateParams) > 1) {
            $this->batchUpdate($updateParams);
        }
        $this->createByWmsOrder($orderHeaders);
        $orderPackageService->updateOrderPackageByWmsOrder($orderHeaders);
        unset($updateParams, $orderHeaders);
    }

    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')
            ->whereHas('order', function ($query) use ($orderNo) {
                $query->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)
    {
        $order = Order::query()->with('packages.commodities.commodity')
            ->whereHas('packages', function ($query) use ($logisticNumber) {
                $query->where('logistic_number', $logisticNumber);
            })->first();
        if ($order) {
            $orderHeader = OracleDOCOrderHeader::query()->where('soreference1', $order->client_no)->first();
            $this->updateOrderByOrderHeader($order, $orderHeader);
            return $order;
        }
        $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])
            ->whereHas('actAllocationDetails', function ($query) use ($logisticNumber) {
                $query->where('picktotraceid', $logisticNumber);
            })->get();
        app(CommodityService::class)->getByWmsOrders($orderHeaders);
        $orders = $this->createByWmsOrder($orderHeaders);
        return $orders ? $orders->first() : null;
    }

    public function syncOrder(&$orderHeaders)
    {
        /**
         * @var OrderPackageService $packageService
         * @var OrderCommodityService $orderCommodityService
         */
        $packageService = app("OrderPackageService");
        $orderCommodityService = app("OrderCommodityService");

        $this->syncOrderByWMSOrderHeaders($orderHeaders);

        $orderCommodityService->syncOrderCommodities($orderHeaders);

        $packageService->syncOrderPackage($orderHeaders);
    }

    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 = [];
        foreach ($orderHeaders as $orderHeader) {
            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'])){
                $value = ['owner_code'=>$orderHeader['customerid'],'issuepartyname'=>$orderHeader['issuepartyname']];
                $key = "owner_code_{$orderHeader['customerid']}_issuepartyname_{$orderHeader['issuepartyname']}";
                $shop_names[$key] = $value;
            }
        }
        $owners = $ownerService->getOwnerByCodes($owner_codes);
        $logistics = $logisticService->getLogisticByCodes($logistic_codes);
        $shops = $shopService->getShopByCodeMap($shop_names);
        $warehouses = $warehouseService->getWareHouseByCode($warehouse_codes);

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

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

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


        // 转换插入 3s
        if(count($created_params) > 0){
            collect($created_params)->chunk(3500)->each(function($inner_params){
                $this->insert($inner_params->toArray());
            });
        }
        $update_params = [
            ['id','code','warehouse_id','owner_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']
        ];

        $update_order->each(function($item)use(&$update_params){
            $update_params[] = $item->toArray();
        });
        if(count($update_order)==0)return;

        $this->batchUpdate($update_params);
    }

    public function getCreateOrderModelsByWMSOrderHeaders(&$orderHeaders,&$orders,&$warehouses,&$owners,&$logistics,&$shops)
    {
        /** @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);

        $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, $date);
            $inner_params[] = $order_model;
        }
        return $inner_params;
    }

    public function getUpdateOrderModelByWMSOrderHeaders(&$orderHeaders,&$orders,&$warehouses,&$owners,&$logistics,&$shops)
    {
        /**
         * @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);
        $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, $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,$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);
        $shop['id'] = null;
        if ($orderHeader->issuepartyname != null && $orderHeader->issuepartyname != '') {
            $shop = $dataHandlerService->getKeyValue(['name' => $orderHeader->issuepartyname ?? '', 'owner_id' => $owner->id ?? ''], $shop_map);
        }
        return [
            'code' => $orderHeader['orderno'],
            '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??'',
            'updated_at' => $date,
            'created_at' => $orderHeader['addtime']
        ];
    }

    /**
     * @param $shop
     * @param $logistic
     * @param $owner
     * @param $warehouse
     * @param $order
     * @param $orderHeader
     * @param string $updated_at
     * @param $updateParams
     * @return mixed
     */
    public function UpdateOrderParamBy(&$shop, &$logistic, &$owner, &$warehouse, &$order, &$orderHeader, string &$updated_at, &$updateParams)
    {
        $shop_id = $shop->id ?? null;
        $logistic_id = $logistic->id ?? null;
        $owner_id = $owner->id ?? null;
        $warehouse_id = $warehouse->id ?? null;

        if (($order->wms_status !== $orderHeader->oracleBASCode_codename_c) ||
            ($order->logistic_id !== $logistic_id) ||
            ($order->shop_id !== $shop_id) ||
            ($order->owner_id !== $owner_id) ||
            ($order->consignee_name !== $orderHeader->c_contact) ||
            $order->consignee_phone !== (empty($orderHeader->c_tel2) ? $orderHeader->c_tel1 : $orderHeader->c_tel2) ||
            $order->province !== ($orderHeader->c_province) ||
            $order->city !== ($orderHeader->c_city) ||
            $order->district !== ($orderHeader->c_district) ||
            $order->address !== ($orderHeader->c_address1) ||
            $order->client_code !== ($orderHeader->soreference1) ||
            ($order->wms_edittime !== $orderHeader->edittime) ||
            ($order->warehouse_id !== $warehouse_id)) {
            $updateParams[] = ['id' => $order->id,
                'owner_id' => $owner_id,
                'wms_status' => $orderHeader->oracleBASCode_codename_c ?? '',
                'logistic_id' => $logistic_id,
                'shop_id' => $shop_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,
                'updated_at' => $updated_at,
                'created_at' => $orderHeader->addtime,
                'wms_edittime' => $orderHeader->edittime,
                'order_type' => $orderHeader->orderType->codename_c??'',
                'warehouse_id' => $warehouse_id];
        }
    }

    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 = [];
        if (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);
            }
        }
    }

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

    public function cancelOrderCache($key,string $prefix)
    {

        try {
            Redis::LLEN($key);
            $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');
        $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');

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

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

        $last_order = $orderHeaders->first();                                                           // 时间点靠后的
        $renewal_orders = $orderHeaders->where('addTime', $last_order->addtime);

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

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

    public function syncUpdatedOrder(){
        /**
         * @var OracleDOCOrderHeaderService $oracleDOCOrderHeaderService
         * @var OrderService $orderService
         */
        $renewal = config('sync.order_sync.cache_prefix.updated_at');
        $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');

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

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

        $renewal_order = $orderHeaders->first();                                                            // 时间点靠后的
        $renewal_orders = $orderHeaders->where('addTime', $renewal_order->addtime);

        $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->addTime,count($orderHeaders)>0);   // 更新时间
        }
    }

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

    public function createInstantBill(Order $order):bool
    {
        //检查订单对象
        if (!$order || $order->wms_status != "订单完成")return false;
        $order->loadMissing(["logistic","packages.commodities.commodity"]);

        /** @var OwnerPriceExpressService $service */
        $service = app("OwnerPriceExpressService");
        $logistic_fee = 0;
        $commodities = [];
        $amount = 0;
        $volume = 0;
        $weight = 0;
        $logistic_bill = "";

        if (!$order->logistic || $order->logistic->type != "快递")$logistic_fee = null;

        foreach ($order->packages as &$package){
            $logistic_bill .= $package->logistic_number.",";
            $volume += $package->bulk;
            $weight += $package->weight;

            // 四维转二维
            foreach($package->commodities as &$commodity){
                $commodity["commodity_name"] = $commodity->commodity ? $commodity->commodity->name : '';
                $commodity["sku"] = $commodity->commodity ? $commodity->commodity->sku : '';
                $amount += $commodity->amount;
            }
            $commodities = array_merge($commodities,$package->commodities->toArray());

            if ($logistic_fee!==null){
                $provinceName = $order->province;
                $province = app(CacheService::class)->getOrExecute("province_".$provinceName,function ()use($provinceName){
                    return app("ProvinceService")->first(["name"=>$provinceName]);
                },60);
                if (!$province)$logistic_fee = null;

                $fee = $service->matching($package->weight, $order->owner_id, $order->logistic_id, $province->id);
                if ($fee<0)$logistic_fee = null;

                $logistic_fee += $fee;
            }
        }
        if ($logistic_fee!==null && $logistic_fee<0)$logistic_fee = null;

        $object = ["commodities"=>$commodities,"logistic_name"=>($order->logistic ? $order->logistic->name : ''),"shop_name"=>($order->shop ? $order->shop->name : ''),"order_type"=>$order->order_type];
        $mapping = ["packages"=>"commodities","商品名称"=>"commodity_name","承运商"=>"logistic_name","店铺类型"=>"shop_name","订单类型"=>"order_type"];

        /** @var OwnerPriceOperationService $service */
        $service = app("OwnerPriceOperationService");
        $work_fee = $service->matchRule($object,$mapping,$order->owner_id,"出库");
        if ($work_fee < 0)$work_fee = null;

       if (app("OwnerFeeDetailService")->create([
            "owner_id"          => $order->owner_id,
            "worked_at"         => $order->wms_edittime,
            "type"              => "发货",
            "shop_id"           => $order->shop_id,
            "operation_bill"    => $order->code,
            "consignee_name"    => $order->consignee_name,
            "consignee_phone"   => $order->consignee_phone,
            "commodity_amount"  => $amount,
            "logistic_bill"     => rtrim($logistic_bill,","),
            "volume"            => $volume,
            "weight"            => $weight,
            "logistic_id"       => $order->logistic_id,
            "work_fee"          => $work_fee,
            "logistic_fee"      => $logistic_fee,
            "created_at"        => date('Y-m-d H:i:s'),
            "outer_id"          => $order->id,
            "outer_table_name"  => "orders",
        ]))return true;
       return false;
    }
}