<?php

namespace App\Http\Controllers;


use App\Authority;
use App\Commodity;
use App\CommodityBarcode;
use App\Customer;
use App\Feature;
use App\Log;
use App\Logistic;
use App\OracleActAllocationDetails;
use App\OracleDOCOrderHeader;
use App\OracleDocOrderPackingSummary;
use App\OracleDOCWaveDetails;
use App\Order;
use App\OrderIssue;
use App\OrderPackage;
use App\Owner;
use App\Package;
use App\Process;
use App\ProcessDaily;
use App\ProcessStatistic;
use App\RejectedBill;
use App\RejectedBillItem;
use App\Services\CacheService;
use App\Services\common\DataHandlerService;
use App\Services\InventoryCompareService;
use App\Services\OracleDOCOrderHeaderService;
use App\Services\OrderPackageService;
use App\Services\OrderService;
use App\Services\OrderTrackingOwnerService;
use App\Services\OrderTrackingService;
use App\Services\OwnerPriceOperationService;
use App\Unit;
use App\User;
use App\Warehouse;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cache;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Str;
use Ramsey\Collection\Collection;
use Ramsey\Uuid\Uuid;
use Zttp\Zttp;

class TestController extends Controller
{
    const ASNREFERENCE_2 = 'ASNREFERENCE2';
    private $data = [];

    public function __construct()
    {
        $this->data["active_test"] = "active";
    }

    public function method(Request $request, $method)
    {
        return call_user_func([$this, $method], $request);
    }

    public function test4(){
        $a = DB::connection("oracle")->select(DB::raw("select * from INV_LOT_LOC_ID where sku in ('6936352541219',
                                                                                   '6971503541571','A1BY1453R3S','A1BY1453R4S','A1FC0811C2090','AB11A4044C5100',
                                                                                   'AB11A4044D4090','AB11A4044E5100','AB11A4044M5090','AB11A4044M5100','AE02B3014C019120',
                                                                                   'AE02B3014E013100','AG01B1023C005110','AG01B1023F002090','AG08B3037C017120','AG08B3037G028110',
                                                                                   'AG08B3070R082100','AG14B3058J006002','AG22B1027R006120','AG22B1027R054120',
                                                                                   'AG22B1027R058100','AG22B3001R084090','AG22B3001R084100','AG22B3001R084110',
                                                                                   'AG22B3001R084130','AG22B3001R085100','AG22B3001R085140','AG22B3001R086120',
                                                                                   'AG22B3001R087090','AG22B3001R087110','AG22B3001R087120','AG22B3001R088090','AG22B3001R088100',
                                                                                   'AG22B3001R088110','AG22B3001R088120','AG22B3001R089100','AG22B3001R089110','AG22B3001R094090',
                                                                                   'AG22B3001R094100','AG22B3001R094110','AG22B3001R094130',
                                                                                   'AG22B3002A009090','AG22B3002A009100','AG22B3002A009110',
                                                                                   'AG22B3002A009120','AG22B3002A009130','AG22B3002A009150',
                                                                                   'AG22B3002R097100','AG22B3002R097110','AG22B3002R097120',
                                                                                   'AG22B3002R097130','AG22B3002R100090','AG22B3002R100100',
                                                                                   'AG22B3002R100110','AG22B3002R100120','AG22B3002R100140',
                                                                                   'AG22B3002R111120','AG22B3002R111130','AG22B3002R111140','AG22B3002R111150','AG22B3002R113120','AG22B3002R114090','AG22B3002R114100','AG22B3002R114110','AG22B3002R114120','AG22B3002R114130','AG22B3002R114140','AG22B3002R115090','AG22B3002R115120','AG22B3002R115130','AG22B3002R115140','AH08A4009D4100','AH08B4026B001110','AH08B4026B001120','AH08B4026D011100','AH08B4026G027090','AH08B4026G027120','AH08B4026G027130','AH08B4026G027140','AH08B4026G027150','AH08B4026H005110','AH08B4026H005150','AH08B4026J016090','AH08B4026J016100','AH08B4026J016110','AH08B4026J016120','AH08B4026J017100','AH08B4026J017110','AH08B4026J017120','AH08B4026J017150','AH08B4026M002100','AH08B4026M002110','AH08B4026M002120','AH08B4026M002130','AH08B4026M002150','AH08B4027B001090','AH08B4027G027150','AH08B4027M002090','AH08B4027M002150','AH08B4063B001090','AH08B4066D016140','AJ08B3035C017110','AJ08B3035C017120','AJ08B3035C017130','AJ08B3035J006090','AJ08B3035M002090','AJ08B3074R091090','AJ08B3074R091120','AK01B2001A004120','AK01B2001A004140','AK01B2001R045100','AK08B1018R012090','AK08B1018R012100','AP03B3041B002110','AP03B3041B002120','AP03B3041B002130','AP03B3041B002150','AP03B3041C021090','AP03B3041C021100','AP03B3041C021110','AP03B3041C021120','AP03B3041C021130','AP03B3041C021140','AP03B3041C021150','AP03B3041E020100','AP03B3041E020110','AP03B3041E020120','AP03B3041E020130','AP03B3041E020140','AP03B3041E020150','AP03B3041F016090','AP03B3041F016100','AP03B3041F016110','AP03B3041F016120','AP03B3041F016130','AP03B3041G031100','AP03B3041G031110','AP03B3041G031120','AP03B3041G031130','AP03B3041G031140','AP03B3041H004090','AP03B3041H004100','AP03B3041H004110','AP03B3041H004120','AP03B3041H004130','AP03B3041H004140','AP03B3041H004150','AP03B3041J009110','AP03B3041J009120','AP03B3041J009130','AP03B3041J009150','AP04A3014J1110','AP04A3015G1100','AP04A3015H2100','AP04A3015H2110','AP05A4021C6090','AP05A4021C6100','AP05A4021C6110','AP05A4021C6120','AP05A4021C6140','AP05A4021F4100','AP05A4021F4110','AP05A4021F4120','AP05A4021F4140','AP05A4021H4110','AP05A4021H4120','AP05A4021J3100','AP05A4021J3110','AP05A4027E8100','AP05A4084B4120','AP06A4029CB100','AP06A4029CB110','AP06A4029D5100','AP06A4029D5120','AP06A4102QN100','AP07A4022C6090','AP07B3040C021100','AP07B3040C021120','AP07B3040C021140','AP07B3040E020110','AP07B3040F016100','AP07B3040H004110','AP07B3040H004120','AP07B3040H004130','AP07B3040J009110','AP07B3040J009120','AVA00109P10','AVA00109P12','AY11A3034C1100','AY11A3035J2100','AY11B1044E002090','AY11B1044E002120','AY11B1044E002130','AY11B1044F005110','AY11B1044G007110','AY11B3024Q010090','AY11B3024Q010100','AY11B3024Q010110','AY11B3024Q010120','AY11B3024Q010130','AY11B3024Q010140','AY11B3024Q010150','AY11B3024Q017090','AY11B3024Q017100','AY11B3024Q017110','AY11B3024Q017140','AY11B3024Q017150','AY11B3024Q018100','AY11B3024Q018110','AY11B3024Q018120','AY11B3024Q018130','AY11B3076R073090','AY14A3054C1001','BB03B4010A013130','BB03B4010D014090','BB07B3030C019090','BB07B3030C019110','BB07B3030C019120','BB07B3030C019130','BB07B3030E008110','BB07B3030E008120','BB07B3030E015090','BB07B3030E015100','BB07B3030N006100','BB07B3030N006120','BB11A4048E5090','BB11B3029C019090','BB11B3029C019110','BB11B3029C019140','BB11B3029E008110','BB11B3029E008120','BB11B3029E015090','BB11B3029E015100','BB11B3029E016130','BB11B3029E016140','BB11B3029E016150','BB11B3029N006130','BB25B3068C019000','BB25B3068E008000','BB25B3068E015000','BB25B3068N006000','BD08B3048G014090','BD08B3048G014100','BD08B3048G014110','BD08B3048G014120','BD08B3048G014130','BD08B3048G014140','BD08B3049G014120','BD08B4031J007090','BD08B4031J007100','BD08B4031J007110','BD08B4031J007120','BD08B4031J007130','BE02A3020J6110','BF08A3005D3110','BF08A3005D3130','BF08A3005F4110','BG01B1026A001140','BG01B1026C004140','BG01B1026F001140','BG01B1026N003100','BG02B1003E003100','BG02B3008C015110','BG02B3008C015140','BG02B3008C015150','BG02B3008D008090','BG02B3008D008100','BG02B3008D008120','BG02B3008D013100','BG02B3008D013110','BG02B3008D013120','BG02B3008D013150','BG02B3008F010090','BG02B3008G025130','BG02B3008G025150','BG02B3013Q013110','BG02B3013Q016120','BG13B1008F005130','BG14B3059E017001','BG21B1017F004110','BH08B4025G003130','BH08B4025J020120','BH08B4029D011100','BH08B4029D011110','BH08B4029D011130','BH08B4029E021100','BH08B4029E021120','BH08B4029E021130','BH08B4029E021140','BH08B4029J016110','BH08B4038B004090','BH08B4038B004100','BH08B4038B004110','BH08B4038B004120','BH08B4038B004130','BH08B4038G003100','BH08B4038G003110','BH08B4038G003130','BH08B4038G003140','BH08B4038G003150','BH08B4038J020090','BH08B4038J020100','BH08B4038J020110','BH08B4038J020120','BI03B3032J013090','BI03B3032J013100','BI03B3032J013110','BI03B3032J013140','BI03B3032J014090','BI03B3032J014100','BI03B3032J014140','BI03B3032K005150','BI03B4011C024120','BI03B4011C024130','BI03B4011C024140','BI03B4011D018090','BI03B4011D018110','BI03B4011G037100','BI03B4011G037110','BI03B4011G037120','BI11A4046D5100','BI11B4001J019110','BI11B4002N008130','BI11B4003D011100','BI11B4003D011110','BI11B4003D011120','BI11B4003D011130','BI11B4003N009100','BI11B4003N009110','BI11B4003N009120','BI11B4003N009130','BI11B4004T001090','BI11B4004T001110','BI11B4004T001130','BI11B4004T001140','BI11B4006L011090','BI11B4006L011100','BI11B4006L011120','BI11B4008S030110','BI11B4008S030130','BJ03A3013H2120','BJ03B4042C023100','BJ03B4042C023110','BJ03B4042C023120','BJ03B4042C023140','BJ03B4042E023090','BJ03B4042E023110','BJ03B4042E023130','BJ03B4042G036100','BJ03B4042G036110','BJ03B4042G036120','BJ03B4042G036130','BJ08A4007D4090','BJ08A4007FE100','BJ08A4007FE130','BJ13B3080R070100','BK01B2006A006100','BK01B2006R043100','BL01B2013Q011110','BL18B2028N004130','BM25B2024R040000','BP03B3046C017110','BP03B3046C017120','BP03B3046C017140','BP03B3046C017150','BP03B3046E018090','BP03B3046E018100','BP03B3046E018110','BP03B3046E018120','BP03B3046E018130','BP03B3046E018140','BP03B3046E018150','BP03B3046G026100','BP03B3046G026120','BP03B3046G026130','BP03B3046G026140','BP03B3046N005090','BP03B3046N005100','BP03B3046N005110','BP03B3046N005120','BP03B3046N005150','BP03B4034D015090','BP03B4034D015100','BP03B4034D015110','BP03B4034D015130','BP03B4034D015140','BP03B4034M011130','BP05B3088B001110','BP05B3088C022100','BP05B3088C022120','BP05B3088C022130','BP05B3088D008090','BP05B3088D008110','BP05B3088D008130','BP05B3088D008140','BP05B3088D008150','BP05B3088G007110','BP05B3089S026110','BP05B3089S026120','BP05B3089S026130','BP05B4014B001100','BP05B4014B001110','BP05B4014B001130','BP05B4014D008100','BP05B4014D008110','BP05B4014D008120','BP05B4014D008130','BP05B4014D008150','BP05B4035B001090','BP05B4035B001100','BP05B4035B001110','BP05B4035B001120','BP05B4035B001130','BP05B4035B001140','BP05B4035B001150','BP05B4035D008090','BP05B4035D008100','BP05B4035D008110','BP05B4035D008120','BP05B4035D008130','BP05B4035D008150','BP06A4028E9110','BP06A4028FC100','BP06A4028FC110','BP06A4028FC120','BP06B4017D015090','BP06B4017D015100','BP07B4015C022110','BP07B4015D008100','BP07B4015D008120','BP07B4015D008130','BP07B4015D008140','BP07B4015G007110','BP07B4015G007120','BP07B4015G007140','BP07B4018F012090','BP08B4056D016090','BP08B4056D016120','BP08B4056G041100','BP08B4056G041120','BP08B4056G041150','BP08B4056J017090','BP08B4056J017120','BP08B4056J017130','BP08B4056J018090','BP08B4056J018110','BP08B4056J018130','BP08B4056J018150','BY11B1046Q002110','BY14B1072S007002','BY25B3027G019001','CC08B3051E021110','CC08B3051E021120','CC08B3051E021140','CC08B3051F011090','CC08B3051J010090','CC08B3051J010100','CC08B3051J010110','CC08B3051J010120','CC08B3051J010130','CC08B3051L008100','CC08B3051L008110','CC08B3051L008120','CC08B3051L008140','CC08B3051L008150','CE02A3024D1100','CF18A4015D6110','CI03B4007D011090','CI03B4007D011100','CI03B4007D011110','CI03B4007L010110','CJ03A4130R4100','CJ03A4130R5100','CJ03B3090E013090','CJ08A4124T4090','CJ13A4126CC100','CJ13A4126EF100','CK01B2086S012110','CK32B1019E004110','CL09B2021R036120','CN03A4033SA110','CN03A4033SA120','CN03A4034D4110','CN03A4034D4120','CN03A4034D4140','CP03B1048S003110','CP08B4032G036120','CP13A4086L4110','CP13A4086L4130','CY06A4105D5090','CY06A4105D5120','CY08B3039S021001','CY11A4003M1090','CY11A4003M1100','CY11B4037C017001','CY11B4037C017002','CY11B4037D011001','CY11B4037D011002','CY11B4037G039001','CY11B4037G039002','DAW08568P11','DAW08568P19','DB11A4044E5160','DD10B2042G018120','DG02B3013Q013160','DG22B3001R065160','DP03B3041J009155','DP03B3041J009160','DP03B3046N005155','DP05B3088B001155','DP05B3088B001160','DP05B3088G007155','DP05B4014B001160','DP05B4014D008160','EA25B1073A011000','EA25B1073A015000','EF08A3061K1110','EF08A3061L3110','EK01B2094C011110','EVA05127P19','EVA05136P10','EVA05136P13','EVA051B27P19','EVA051B36P12','EVA051B36P13','EVA05356P19','EVA05615P11','EVA05615P12','EVA05637P11','EVA05637P19','EVA05966P50',
                                                                                   'HP03B3041B002175','HP03B3041J009170','HP03B3041J009175',
                                                                                   'HP03B3046G026170','QTCM0055','QTCM0082')
                                                                       and CUSTOMERID = 'ALLBLU'
                                                                       and TRACEID like '1605%' and addtime > to_date('2020-11-20 00:00:00','yyyy-mm-dd hh24:mi:ss')
                                                                       and addtime < to_date('2020-11-21 13:41:00','yyyy-mm-dd hh24:mi:ss')"));
        $map = [];
        $o = [];
        foreach ($a as $b){
            if (isset($map[$b->lotnum."_".$b->locationid."_".$b->customerid."_".$b->sku])){
                $o[] = "'".$b->traceid."'";
            }else{
                $map[$b->lotnum."_".$b->locationid."_".$b->customerid."_".$b->sku] = $b->traceid;
            };
        }
        dd(implode(',',$o));
        $model1 = factory(Feature::class,2)->create([[
            "type" => "商品名称",
            "logic" => "包含",
            "describe"=>"衣服",
        ],[
            "type" => "订单类型",
            "logic" => "不包含",
            "describe"=>"创建",
        ]]);
        dd($model1);
    }

    public function test2(){
        $b = Logistic::query()->first();
        $a = OrderPackage::query()->with("order")->first();
        $a->bulk = 521;
        $a->save();
        if (!$a->order) $a->order = new Order();
        dd($a);
        if (!$a->order->logistic)$a->order->logistic = $b;
        dd($a->order->logistic);
        dd($a);
        $a->save();
        dd($a);
    }

    function packageFromLog(Request $request)
    { //x        $packagesBatch=Package::where('batch_number',$batch_number)->first();
        ini_set('max_execution_time', 2500);
        ini_set('memory_limit', '1526M');
        $uploaded = 0;
        $count = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-08 15:46:00")
            ->where('created_at', '<', "2020-06-08 15:47:00")
            ->where('type', "request_new_")
            ->count();
        $requests = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-08 15:46:00")
            ->where('created_at', '<', "2020-06-08 15:47:00")
            ->where('type', "request_new_")
            ->get();
        $requests->each(function ($request) use (&$uploaded) {
            $requestJson = json_decode($request->description, true);
            $response = Zttp::withHeaders(['content-type' => 'application/json',
            ])->post('https://was.baoshi56.com/api/thirdPart/flux/package/new',
                $requestJson
            );
            if ($response->json() && $response->json()['response'] && $response->json()['response']['flag'] == 'Y')
                $uploaded += 1;
        });
        dd($uploaded . '/' . $count);
    }

    function wmsSql()
    {
        $owner=Owner::first();
//        $owner['phone_number'] ?? $owner['phone_number'] = '31115';
//        $owner->update();
        dd($owner);
    }
    function issues()
    {
        /** @var OrderPackageService $orderPackageService */
        $orderPackageService = app('OrderPackageService');
        $ids = [741, 739, 738, 736, 735, 733, 732, 731, 730, 729, 728, 725, 724, 723, 721, 720, 719, 718, 717, 715, 714, 713, 712, 711, 710, 705, 703, 702, 701, 700, 699, 698, 696, 694, 693, 692, 691, 690];
        $orderIssues = OrderIssue::query()->whereIn('id', $ids)->get();
        $order_ids = data_get($orderIssues, '*.order_id');
        $orders = Order::query()->whereIn('id', $order_ids)->get();
        foreach ($orders as $item) {
            $orderPackageService->createdByOrder($item);
        }
    }

    function t2(Request $request)
    { //x        $packagesBatch=Package::where('batch_number',$batch_number)->first();


        $inventoryCompareService = new InventoryCompareService();
        echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
        echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
        echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
        echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
    }

    function tlog(Request $request)
    {
        app('LogService')->log(__METHOD__,'cczdelme'.__FUNCTION__,json_encode($request->all()),null);
    }
    function setCache(Request $request)
    {
        $today = now();
        Cache::put('storedTest', $today);
        return "cacheing:'$today'<script>localStorage.setItem('storedTest','{$today}')</script>";
    }

    function getCache(Request $request)
    {
        $cache = Cache::get('storedTest');
        return "cacheing get:'$cache'<script>document.write('<br>localStorage:'+localStorage.getItem('storedTest'))</script>";
    }

    function t1(Request $request)
    {
        {
            $username = config('database.connections.oracle.username');
            $password = config('database.connections.oracle.password');
            $host = config('database.connections.oracle.host');
            $service_name = config('database.connections.oracle.service_name');
            $conn = oci_connect($username, $password, $host . '/' . $service_name); //连接oracle数据库
            $IN_WarehouseID = '';
            $IN_TraceID = '';
            $IN_WavenNo = '';
            $IN_UserID = '';
            $IN_Language = '';
            $OUT_Return_Code = '';
            $sql_sp = "begin SPCUS_EDI_WCS001(:IN_WarehouseID,:IN_Process_Action_C,:IN_Process_By_C,
        :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
            $stmt = oci_parse($conn, $sql_sp);
            oci_bind_by_name($stmt, ':IN_Warehouse', $IN_WarehouseID);
            oci_bind_by_name($stmt, ':IN_TraceID', $IN_TraceID);
            oci_bind_by_name($stmt, ':IN_WavenNo', $IN_WavenNo);
            oci_bind_by_name($stmt, ':IN_Language', $IN_Language);
            oci_bind_by_name($stmt, ':IN_UserID', $IN_UserID);
            oci_bind_by_name($stmt, ':OUT_Return_Code', $OUT_Return_Code);
            return oci_execute($stmt);

        }


    }


    function packageT(Request $request)
    {
        $package = Package::where('created_at', '<', '2020-07-08')->whereNotNull('logistic_number')->first();
        $package->fetchLogistic();
    }

    function injectJS(Request $request)
    {
        $items = RejectedBillItem::whereHas('rejectedBill', function ($query) {
            return $query->where('id_owner', 2);
        })->where('created_at', '>', '2019-12-23 18:11:00')->where('created_at', '<', '2019-12-24 11:25:00')->get();
        (new RejectedBillItemController())->collectionsToPackConfirm($items);
    }

    public function tj2(Request $request)
    {
        $numbersesOfBatch = OracleDOCWaveDetails::select('picktotraceid as logistic_number', 'act_allocation_details.orderno')->where('doc_wave_details.waveno', 'W190630000042')
            ->leftJoin('act_allocation_details', 'doc_wave_details.orderno', 'act_allocation_details.orderno')->get();

        $oneIdxAsrsReceive = OracleDocOrderPackingSummary::where('traceid', $numbersesOfBatch[0]['logistic_number'])->first();
        if (!$oneIdxAsrsReceive) {
            $inserts = '';
            $values = [];
            foreach ($numbersesOfBatch as $numbers) {
                $inserts .= " into doc_order_packing_summary (traceid,orderno,grossweight,addwho,addtime,editwho,edittime)values(?,?,?,?,?,?,?) ";
                $values[] = $numbers['logistic_number'] ?? '';
                $values[] = $numbers['orderno'] ?? '';
                $values[] = 12;
                $values[] = 'WAS';
                $values[] = Carbon::now();
                $values[] = 'WAS';
                $values[] = Carbon::now();
            }
            DB::connection('oracle')->insert("insert all {$inserts} select * from dual", $values);
        } else {
            $logisticNumbers = $numbersesOfBatch->map(function ($numbers) {
                return $numbers['logistic_number'];
            });
            OracleDocOrderPackingSummary::whereIn('traceid', $logisticNumbers)->update(['grossweight' => 32]);
        }
    }

    public function delme()
    {
        $fields = [
            'doc_order_header.userdefine1',
            'doc_order_header.userdefine2',
            'doc_order_header.SOReference5',
            'doc_order_header.waveno',
            'doc_order_header.orderno',
            'doc_order_header.customerid',
            'doc_order_header.Consigneename'
        ];
        if ('') {
            $resultOracleObj = OracleDOCOrderHeader::select($fields)->where('orderno', 'SO200603004708');
        } else {
            $resultOracleObj = OracleActAllocationDetails::select($fields);
            $resultOracleObj->where('picktotraceid', '546152742096');
            $resultOracleObj->leftJoin('DOC_Order_Header', 'act_allocation_details.orderno', 'doc_order_header.orderno');
        }
        $_temOracleInfo = $resultOracleObj->first();

        dd($_temOracleInfo);
    }

    public function mergerPackageData()
    {
        ini_set('max_execution_time', 36000);
        ini_set('memory_limit', '1526M');
        $number = 3000;
        $start_at = 1;
        $sum = Package::query()->where('id', '>', $start_at)->count();
        $len = ceil($sum / $number);
        $id = $start_at;
        for ($i = 1; $i <= $len; $i++) {
            $packages = Package::query()->orderBy('id')->where('id', '>', $id)->limit($number)->get();
            $error = [];
            foreach ($packages as $package) {
                /** @var $service OrderPackageService */
                $service = app('OrderPackageService');
                $orderPackage = $service->firstOrCreate($package->logistic_number,
                    ['batch_number' => $package->batch_number,
                        'batch_rule' => $package->batch_rule,
                        'bulk' => $package->bulk,
                        'weight' => $package->weight,
                        'length' => $package->length,
                        'width' => $package->width,
                        'height' => $package->height,
                        'paper_box_id' => $package->paper_box_id,
                        'measuring_machine_id' => $package->measuring_machine_id,
                        'weighed_at' => $package->weighed_at,
                        'status' => $package->status]);
                if (!$orderPackage) array_push($error, $package->id);
            }
            app('LogService')->log(__METHOD__, "同步时WMS中未找到这些订单", json_encode($error));
            $id = $packages[count($packages) - 1]->id;
            echo $number . ' a bunch done at:' . now()->toFormattedDateString() . '<br>';
        }
    }

    public function excelIt()
    {
        $excel = new ExcelController();
        return $excel->makeExcel();
    }

    public function featureIt()
    {
        LogisticNumberFeatureController::loadRecentRejectedsToFeatures(5, 2500);
    }

    public function newSku()
    {
        $url = 'http://bswcs/api/sorting/flux/newSku';
        $response = Zttp::post($url, [
            'request' => [
                [
                    "SKU" => "1234567890",
                    "NAME" => "瑞士莲**巧克力",
                    "Alternate_SKU1" => "1122334455",
                    "GrossWeight" => "1.2",
                    "Cube" => "0.75",
                    "SKULength" => "0.25",
                    "SKUWidth" => "0.15",
                    "SKUHigh" => "0.05"
                ],
                [
                    "SKU" => "1234567892",
                    "NAME" => "跳跳饼",
                    "Alternate_SKU1" => "",
                    "GrossWeight" => "1.3",
                    "Cube" => "0.75",
                    "SKULength" => "0.25",
                    "SKUWidth" => "0.15",
                    "SKUHigh" => "0.25"
                ],
            ]
        ]);
        return $response->json();
    }

    public function changePackage()
    {
        $packages = Package::where('delivery_number', '<>', null)->where('logistic_id', null)->get();
        $packages = Package::whereRaw('delivery_number IS NOT NULL AND logistic_id IS NULL')->get();
        $logistics = Logistic::get();
        $packages->each(function ($package) use ($logistics) {
            $logistics->each(function ($logistic) use ($package) {
                if ($package->WMSReflectPackage->CarrierID == $logistic->code) {
                    $package->logistic_id = $logistic->id;
                    return;
                }
            });
        });
        return "OK";
    }

    public function tNull()
    {
        User::query()->get()->toArray();
        User::query()->get()->toJson();
    }

    public function deletePackageAuthority()
    {
        $authorities = Authority::where('name', 'like', '%包裹信息%')->get();
        $authorities->each(function ($authority) {
            $authority->delete();
        });
    }

    function test()
    {
        $ids = [];
        $logs = Log::query()->select('description')->where('type', '同步时WMS中未找到这些订单')->get();
        foreach ($logs as $log) {
            $arr = [];
            eval("\$arr = " . $log->description . '; ');
            if (count($arr) < 1) continue;
            $ids = array_merge($ids, $arr);
        }
        $ids = array_unique($ids);
        $error = [];
        foreach ($ids as $id) {
            $package = Package::query()->find($id);
            /** @var OrderPackageService */
            $orderPackage = app('OrderPackageService')->firstOrCreate($package->logistic_number,
                ['batch_number' => $package->batch_number,
                    'batch_rule' => $package->batch_rule,
                    'bulk' => $package->bulk,
                    'weight' => $package->weight,
                    'length' => $package->length,
                    'width' => $package->width,
                    'height' => $package->height,
                    'paper_box_id' => $package->paper_box_id,
                    'measuring_machine_id' => $package->measuring_machine_id,
                    'weighed_at' => $package->weighed_at,
                    'status' => $package->status]);
            if (!$orderPackage) array_push($error, $package->id);
        }
        if (count($error) > 0) app('LogService')->log(__METHOD__, "同步时WMS中未找到这些订单_two", json_encode($error));
    }

    function test1()
    {
        $statistics = ProcessStatistic::query()->whereNull('revenue')->get();
        $id = array_column($statistics->toArray(), 'process_id');
        $processes = Process::query()->where(function (Builder $query) {
            $query->where('status', '待交接')->orWhere('status', '交接完成');
        })->whereIn('id', $id)->get();
        $sign_end = true;
        foreach ($processes as $process) {
            if (count($process->processDailies) > 0) {
                $completed_amount = 0;
                foreach ($process->processDailies as $processDaily) {
                    $completed_amount = $completed_amount + ($processDaily->output);
                }
                $process->completed_amount = $completed_amount;
            }
            //统计：
            $revenue = ($process->unit_price) * ($process->completed_amount);   //收入合计
            $processDailies = ProcessDaily::with('processDailyParticipants')->where('process_id', $process->id)->where('output', '>', 0)->get();
            $duration_days = count($processDailies);      //完成天数
            $duration_man_hours = 0;      //总工时
            $total_cost = 0;              //合计成本
            foreach ($processDailies as $processDailyOne) {
                foreach ($processDailyOne->processDailyParticipants as $processDailyParticipant) {
                    if (!$processDailyParticipant->unit_price && !$processDailyParticipant->hour_price) continue;
                    $duration_man_hours += $processDailyParticipant->hour_count;
                    if ($processDailyParticipant->unit_count) {
                        $total_cost += ($processDailyParticipant->unit_count) * ($processDailyParticipant->unit_price);
                        continue;
                    }
                    $total_cost += ($processDailyParticipant->hour_count) * ($processDailyParticipant->hour_price);
                }
            };
            $processStatistic = ProcessStatistic::query()->find($process->id);
            $processStatistic->revenue = $revenue;
            $processStatistic->duration_days = $duration_days;
            $processStatistic->duration_man_hours = $duration_man_hours;
            if ($sign_end) $processStatistic->ended_at = date('Y-m-d H:i:s');
            if (!$revenue || !$total_cost) {
                $processStatistic->update();
                continue;
            }
            $gross_profit = $revenue - $total_cost; //毛利润
            if ($gross_profit != 0) $gross_profit_rate = $gross_profit / $revenue;  //毛利率;
            else $gross_profit_rate = 0;
            $processStatistic->total_cost = $total_cost;
            $processStatistic->gross_profit = $gross_profit;
            $processStatistic->gross_profit_rate = $gross_profit_rate;
            $processStatistic->update();
            app('LogService')->log(__METHOD__, "修改二次加工单统计单_" . __FUNCTION__, json_encode($processStatistic), Auth::user()['id']);
        }
    }

    public function test5(){
        ini_set('max_execution_time',2500);
        ini_set('memory_limit','1526M');
        //清理冗余条码
//        $this->cleanBarcode();

        while(true){
            $toDay = Carbon::now();
            $skus = DB::select(DB::raw('select sku from commodities group by sku,owner_id having count(*)>1 limit 500 '));
            $skus = array_column($skus,'sku');

            $commodities = Commodity::query()->with('barcodes')->whereNotNull('owner_id')->whereIn('sku',$skus)->get();


            if (count($commodities) < 1)return "SUCCESS";
            $commodityMap = [];
            $commodityDel = [];
            $commodityTag = [];
            $commodityBar = [];
            $createBarcodes = [];
            $logs = [];
            foreach ($commodities as $commodity){
                if ($commodityMap[$commodity->sku.'_'.$commodity->owner_id] ?? false){
                    $codes = $commodity->barcodes ? array_column($commodity->barcodes->toArray(),'code') : [];
                    $logs[] = [
                        'id' => $commodity->id,
                        'sku' => $commodity->sku,
                        'owner_id'=>$commodity->owner_id,
                        'code'=>$codes,
                    ];
                    $commodityDel[] = $commodity->id;
                    $commodityTag[$commodity->id] = $commodityMap[$commodity->sku.'_'.$commodity->owner_id];

                    $arr = array_diff($codes,$commodityBar[$commodity->sku.'_'.$commodity->owner_id]);
                    foreach ($arr as $code){
                        if (!$code)continue;
                        $createBarcodes[] = [
                            'code' => $code,
                            'commodity_id' => $commodityMap[$commodity->sku.'_'.$commodity->owner_id],
                            'created_at' => $toDay,
                        ];
                    }
                }else{
                    $commodityMap[$commodity->sku.'_'.$commodity->owner_id] = $commodity->id;
                    $commodityBar[$commodity->sku.'_'.$commodity->owner_id] = $commodity->barcodes ? array_column($commodity->barcodes->toArray(),'code') : [];
                }
            }
            dd($commodityMap,$commodityDel,$commodityTag);
            app('LogService')->log(__METHOD__,'清理商品',json_encode($logs,JSON_UNESCAPED_UNICODE));
            app('LogService')->log(__METHOD__,'重新分配商品',json_encode($commodityTag,JSON_UNESCAPED_UNICODE));

            app('InventoryAccountMissionService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新库存盘点任务
            app('InventoryCompareService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新库存对比
            app('InventoryDailyLogService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新库存每日记录
            app('ProcessesContentService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新二次加工内容单
            app('StoreCheckingReceiveItemService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新入库盘收一体
            app('OrderPackageCommoditiesService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新订单商品

            app('LogService')->log(__METHOD__,'删除商品与对应条码',json_encode($commodityDel,JSON_UNESCAPED_UNICODE));
            CommodityBarcode::query()->whereIn('commodity_id',$commodityDel)->delete();
            Commodity::destroy($commodityDel);
        }
    }

    private function cleanBarcode(){

        $logCommodityBarcodes = CommodityBarcode::query()->where('code', "")->get();
        if (count($logCommodityBarcodes) > 0) app('LogService')->log(__METHOD__, "纠正商品-删除空条码", json_encode($logCommodityBarcodes, JSON_UNESCAPED_UNICODE));

        CommodityBarcode::query()->where('code', "")->delete();
        $barcodes = DB::select(DB::raw('select * from commodity_barcodes c
where (c.code,c.commodity_id) in (select code,commodity_id from commodity_barcodes group by code,commodity_id having count(*) > 1) order by commodity_id'));
        $barcodeMap = [];
        $barcodeDelete = [];
        foreach ($barcodes as $barcode) {
            if (isset($barcodeMap[$barcode->code . '_' . $barcode->commodity_id])) $barcodeDelete[] = $barcode->id;
            else $barcodeMap[$barcode->code . '_' . $barcode->commodity_id] = $barcode->id;
        }

        $logCommodityBarcodes = CommodityBarcode::query()->whereIn('id', $barcodeDelete)->get();
        if (count($logCommodityBarcodes) > 0) app('LogService')->log(__METHOD__, "纠正商品-删除重复条码", json_encode($logCommodityBarcodes, JSON_UNESCAPED_UNICODE));

        CommodityBarcode::destroy($barcodeDelete);
    }

    public function correctCommodity()
    {
        ini_set('max_execution_time', 2500);
        ini_set('memory_limit', '1526M');
        //清理冗余条码
        //$this->cleanBarcode();

        //获取重复条码
        $commodities = DB::select(DB::raw('select commodities.name,commodities.sku,commodities.owner_id,commodity_barcodes.id as barcode_id,commodity_barcodes.code as barcode_code,commodity_barcodes.commodity_id from commodities LEFT JOIN commodity_barcodes on commodities.id = commodity_barcodes.commodity_id
where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owner_id,commodity_barcodes.code from commodities LEFT JOIN commodity_barcodes on commodities.id = commodity_barcodes.commodity_id group by commodities.owner_id,commodity_barcodes.code having count(*) > 1) order by commodities.owner_id,commodity_barcodes.code'));

        //对比map池
        $commodityMap = [];
        //需要删除项
        $commodityDelete = [];
        foreach ($commodities as $index => $commodity) {
            $commodity->barcode_code = strtolower(trim($commodity->barcode_code));
            //货主+条码 为唯一key值 设想正常数据下同货主不应该有同条码
            $key = $commodity->owner_id . '_' . $commodity->barcode_code;
            //使用map池对比为重复数据
            if (isset($commodityMap[$key])) {
                //获取下标指针指向的源数据
                $c = $commodities[$commodityMap[$key]];
                //源数据不符合规范，当前数据替换掉它
                if (($c->sku == null || $c->sku == "") && ($commodity->sku != null && $commodity->sku != "")) {
                    $commodityDelete[] = $commodityMap[$key];
                    $commodityMap[$key] = $index;
                } else {
                    //当前数据比源数据更符合预期，替换掉
                    if (($c->sku == $commodity->sku) && (strlen($c->name) < strlen($commodity->name))) {
                        $commodityDelete[] = $commodityMap[$key];
                        $commodityMap[$key] = $index;
                    } else {
                        //扔进处理池
                        $commodityDelete[] = $index;
                    }
                }
                //第一次出现的新数据,val为下标，当作指针指向源数据
            } else $commodityMap[$key] = $index;
        }
        $createBarcodes = []; //批量生成条码
        $deleteCommodities = []; //批量删除商品及商品条码

        $updateCommodities = [];
        foreach ($commodityDelete as $index) {
            //获取到被处理数据 与 目标数据
            $del = $commodities[$index];
            $target = $commodities[$commodityMap[$del->owner_id . '_' . $del->barcode_code]];

            //记录ID删除商品与条码
            $deleteCommodities[] = $del->commodity_id;

            //有效条码合并
            $barcodes = DB::select(DB::raw("select * from
            (select * from commodity_barcodes where commodity_id = " . $del->commodity_id . ")a
            where (select count(1) as num from commodity_barcodes b
            where commodity_id = " . $target->commodity_id . " and b.code = a.code) = 0"));
            if (count($barcodes) > 0) {
                foreach ($barcodes as $barcode) {
                    $createBarcodes[] = ['code' => $barcode->code, 'commodity_id' => $target->commodity_id];
                }
            }
            $updateCommodities[$del->commodity_id] = $target->commodity_id;
        }
        if (count($updateCommodities) > 0){
            app('InventoryAccountMissionService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存盘点任务
            app('InventoryCompareService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存对比
            app('InventoryDailyLogService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存每日记录
            app('ProcessesContentService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新二次加工内容单
            app('StoreCheckingReceiveItemService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新入库盘收一体
            app('OrderPackageCommoditiesService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新订单商品
        }

        if (count($createBarcodes) > 0) app('LogService')->log(__METHOD__, "纠正商品-录入合并条码", json_encode(data_get($createBarcodes, '*.id'), JSON_UNESCAPED_UNICODE));

        CommodityBarcode::query()->insert($createBarcodes);
        $logCommodityBarcodes = CommodityBarcode::query()->whereIn('commodity_id', $deleteCommodities)->get();
        if (count($logCommodityBarcodes) > 0) app('LogService')->log(__METHOD__, "纠正商品-删除无用商品条码", json_encode(data_get($logCommodityBarcodes, '*.id'), JSON_UNESCAPED_UNICODE));

        CommodityBarcode::query()->whereIn('commodity_id', $deleteCommodities)->delete();

//        $logCommodities = Commodity::query()->whereIn('id',$deleteCommodities)->get();
        if (count($deleteCommodities) > 0) app('LogService')->log(__METHOD__, "纠正商品-删除无用商品", json_encode($deleteCommodities, JSON_UNESCAPED_UNICODE));

        Commodity::destroy($deleteCommodities);
    }

    /*1*/
    function socket(Request $request)
    {/**/
        $a = microtime(true);
        error_reporting(E_ALL);
        set_time_limit(0);
        echo "<h2>TCP/IP Connection</h2>\n";

        $port = 8091;
        $ip = "127.0.0.1";
        /*
         +-------------------------------
         *    @socket连接整个过程
         +-------------------------------
         *    @socket_create
         *    @socket_connect
         *    @socket_write
         *    @socket_read
         *    @socket_close
         +--------------------------------
         */

        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if ($socket < 0) {
            echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n";
        } else {
            echo "OK.\n";
        }

        echo "试图连接 '$ip' 端口 '$port'...\n";
        $result = socket_connect($socket, $ip, $port);
        if ($result < 0) {
            echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";
        } else {
            echo "连接OK\n";
        }
        $b = microtime(true);
        echo "连接耗时：" . ($b - $a) . "\n";
        $content = Commodity::query()->limit(200)->get();

        $c = microtime(true);
        echo "查询数据耗时：" . ($c - $b) . "\n";
        $content->toArray();
        /*$chunks=$content->chunk(100);
        foreach ($chunks as $chunk){
            $chunk->toJson();
            var_dump(mb_strlen($chunk->toJson()));
            //socket_write($socket, $chunk->toJson(), mb_strlen($chunk->toJson()));
        }*/
        $d = microtime(true);
        echo "发送数据耗时：" . ($d - $c) . "\n";
        socket_close($socket);
        $e = microtime(true);
        echo "共耗时：" . ($e - $a) . "\n";
    }


    public function test3()
    {
        /** @var OrderTrackingService $orderTrackingService */
        $orderTrackingService = app('OrderTrackingService');
        /** @var OrderService $orderService */
        $orderService = app(OrderService::class);
        $owners = app(OrderTrackingOwnerService::class)->getTrackingOrderOwner();
        $startDate = \Illuminate\Support\Carbon::parse('2020-10-28 00:00:00')->toDateTimeString();
        $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])
            ->where('addTime', '>=', $startDate)
            ->whereIn('customerID', data_get($owners, '*.code'))
            ->get();
        $orderService->updateByWmsOrders($orderHeaders);
        $orderTrackingService->updateByWmsOrderHeaders($orderHeaders);
    }

    public function test11()
    {
        $rejectedBills = RejectedBill::query()
            ->where('created_at','>=','2020-11-10 18:00:22')
            ->where('created_at','<=','2020-11-11 00:00:00')
            ->get();
        $update = [['id','logistic_number']];
        $rejectedBills->each(function ($rejectedBill)use(&$update){
            if($rejectedBill->logistic_number == '原单退回'){
                $details = OracleActAllocationDetails::query()->with('oracleDocOrderHeader')->whereHas('oracleDocOrderHeader',function($query)use($rejectedBill){
                    $query->where('SOReference1',$rejectedBill->order_number);
                })->get()->groupBy('picktotraceid');
                if($details->count() == 1){
                    $update[] = ['id'=> $rejectedBill->id ,'logistic_number'=>$rejectedBill->logistic_number_return];
                }
            }
        });
        app('RejectedBillService')->batchUpdate($update);
    }

    public function output()
    {
        /** @var CacheService $cacheService */
        $cacheService = app('CacheService');
        $authorities=$cacheService->getOrExecute('userxx',function (){
            return Authority::with('roles')->get();
        });
        dd($authorities);
    }
    public function output2()
    {
        dump(Cache::get('aa'));
        Cache::put('aa', '2223', 5);
    }
    public function usage()
    {
        dd(Request::all());
    }
    public function relating()
    {
        dd(OrderIssue::query()->where('id',182)->paginate()->total());
    }

    public function updateOrdersWarehouse()
    {
        /**
         * @var DataHandlerService $dataHandlerService
         * @var OrderService $orderService
         */
        $dataHandlerService = app(DataHandlerService::class);
        $orderService = app(OrderService::class);
        $page = 500;
        $count = Order::query()->count();
        $warehouse = Warehouse::query()->get();
        $warehouse_map = $dataHandlerService->dataHeader(['code'], $warehouse);
        for ($i = 0; $i < $count; $i += $page) {
            $min = $i;$max = $i + $page;
            $orders = Order::query()->where('id', '>=', $min)->where('id', '<=', $max)->get();
            $orderNos = array_diff(array_unique(data_get($orders, '*.code')), ['', ' ', '*', null]);
            if (count($orderNos)==0) continue;
            /** @var Collection $orderHeaders */
            $orderHeaders = OracleDOCOrderHeader::query()->whereIn('orderno', $orderNos)->get();
            if ($orderHeaders->count() == 0) continue;
            $orderHeader_map = $dataHandlerService->dataHeader(['orderno'], $orderHeaders);
            $update_params = [];
            $update_params[] = ['id', 'warehouse_id'];
            foreach ($orders as $order) {
                $orderHeader = $dataHandlerService->getKeyValue(['orderno' => $order->code], $orderHeader_map);
                if ($orderHeader == null) continue;
                $warehouse = $dataHandlerService->getKeyValue(['code' => $orderHeader->warehouseid], $warehouse_map);
                if ($warehouse == null) continue;
                $update_params[] = [
                    'id' => $order->id,
                    'warehouse_id' => $warehouse->id
                ];
            }
            $orderService->batchUpdate($update_params);
            unset($orders, $orderHeaders, $update_params);
        }
        unset($warehouse);
    }

    public function syncSendOrder()
    {
        $order_issues = OrderIssue::query()->whereNotNull('second_client_no')->get();
        $client_nos = data_get($order_issues,'*.second_client_no');
        $orderHeaders = OracleDOCOrderHeader::query()->selectRaw(implode(',',OracleDOCOrderHeaderService::$columns))
            ->whereIn('SOReference1',$client_nos)
            ->with(['oracleBASCustomer'=>function($query){
                $query->selectRaw('BAS_CUSTOMER.CustomerID,BAS_CUSTOMER.Customer_Type,BAS_CUSTOMER.Descr_C,BAS_CUSTOMER.Active_Flag');
            },'oracleDOCOrderDetails'=>function($query){
                $query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered');
            }, 'actAllocationDetails'=>function($query){
                $query->selectRaw('ACT_Allocation_Details.AllocationDetailsID,ACT_Allocation_Details.OrderNo,ACT_Allocation_Details.Qty_Each,ACT_Allocation_Details.PickToTraceID,ACT_Allocation_Details.CustomerID');
            },'oracleBASCode'=>function($query){
                $query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
            }])
            ->get();
        $service = app('OrderIssueService');
        $service->updateByWmsOrders($orderHeaders);
    }

    public function changeOrderIssue()
    {
        // $ids = [5419,5404,5402,5401,5400,5398,5397,5395,5388,5387,5383,5382,5379,5373,5370,5353,5329,5327];

        // OrderIssue::query()->whereIn('id',$ids)->update(['is_new_rejecting'=>'无','rejecting_status'=>'未退回']);
    }

}