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

<?php

namespace App\Http\Controllers;

use App\Authority;
use App\Batch;
use App\Commodity;
use App\CommodityBarcode;
use App\CommodityMaterialBoxModel;
use App\Components\AsyncResponse;
use App\Components\Database;
use App\Components\ErrorPush;
use App\ErrorTemp;
use App\Feature;
use App\Http\ApiControllers\LoginController;
use App\Http\Controllers\api\thirdPart\haochuang\SortingController;
use App\Http\Controllers\api\thirdPart\syrius\beans\StorageTypeCell;
use App\Http\Controllers\api\thirdPart\syrius\beans\StorageTypeRelation;
use App\Http\Controllers\api\thirdPart\syrius\beans\Task;
use App\Http\Controllers\api\thirdPart\syrius\beans\TaskItem;
use App\Http\Controllers\api\thirdPart\syrius\producer\StorageTypeController;
use App\Http\Controllers\api\thirdPart\syrius\units\Signature;
use App\Http\Controllers\api\thirdPart\syrius\units\StorageTypeAttribute;
use App\Http\Requests\AndroidGateRequest;
use App\Http\Requests\OrderDelivering;
use App\Jobs\BatchTaskJob;
use App\Jobs\BroadcastBatchToZhengCangJob;
use App\Jobs\CacheShelfTaskJob;
use App\Jobs\OrderCreateInstantBill;
use App\Jobs\OrderCreateWaybill;
use App\Jobs\SettlementBillReportJob;
use App\Jobs\StoreCreateInstantBill;
use App\Jobs\TestJob;
use App\Jobs\WeightUpdateInstantBill;
use App\LaborCompanyDispatch;
use App\LaborReport;
use App\LaborReportStatus;
use App\Logistic;
use App\MaterialBox;
use App\MaterialBoxModel;
use App\Notifications\RoutineNotification;
use App\OracleDOCASNDetail;
use App\OracleDOCASNHeader;
use App\OracleDOCOrderHeader;
use App\OracleDocOrderPackingSummary;
use App\OracleDOCWaveDetails;
use App\Order;
use App\OrderBin;
use App\OrderCommodity;
use App\OrderIssue;
use App\OrderIssueProcessLog;
use App\OrderPackage;
use App\Owner;
use App\OwnerAreaReport;
use App\OwnerBillReport;
use App\OwnerFeeDetail;
use App\OwnerFeeDetailLogistic;
use App\OwnerFeeExpress;
use App\OwnerFeeLogistic;
use App\OwnerFeeOperation;
use App\OwnerFeeOperationDetail;
use App\OwnerFeeStorage;
use App\OwnerPriceExpress;
use App\OwnerPriceOperation;
use App\OrderPackageCountingRecord;
use App\OwnerReport;
use App\ProcurementCheckSheet;
use App\RejectedBill;
use App\SeeLog;
use App\Services\AuthorityService;
use App\Services\BatchService;
use App\Services\CacheShelfService;
use App\Services\common\BatchUpdateService;
use App\Services\ForeignHaiRoboticsService;
use App\Services\ForeignZhenCangService;
use App\Services\LogisticService;
use App\Services\LogService;
use App\Services\MenuService;
use App\Services\NotificationService;
use App\Services\OracleDOCOrderHeaderService;
use App\Services\OrderPackageCommoditiesService;
use App\Services\OrderPackageReceivedSyncService;
use App\Services\OrderPackageService;
use App\Services\OrderService;
use App\Services\OwnerFeeTotalService;
use App\Services\OwnerLogisticFeeReportService;
use App\Services\OwnerPriceOperationService;
use App\Services\OwnerService;
use App\Services\OwnerStoreFeeReportService;
use App\Services\OwnerStoreOutFeeReportService;
use App\Services\ReplenishmentService;
use App\Services\ReviewService;
use App\Services\StationService;
use App\Services\StorageService;
use App\Services\StoreService;
use App\Services\SyriusTaskService;
use App\Services\WorkOrderService;
use App\SortingStation;
use App\Station;
use App\StationTask;
use App\StationTaskMaterialBox;
use App\Store;
use App\StoreItem;
use App\TaskTransaction;
use App\Unit;
use App\User;
use App\UserDetail;
use App\UserDutyCheck;
use App\ValueStore;
use App\Waybill;
use App\WorkOrder;
use App\WorkOrderCommodities;
use App\WorkOrderDetail;
use App\WorkOrderImage;
use App\WorkOrderLog;
use Carbon\Carbon;
use Carbon\CarbonPeriod;
use Decimal\Decimal;
use Doctrine\DBAL\Driver\AbstractDB2Driver;
use Doctrine\DBAL\Exception;
use Firebase\JWT\ExpiredException;
use Firebase\JWT\JWT;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\HigherOrderBuilderProxy;
use Illuminate\Database\QueryException;
use Illuminate\Foundation\Http\FormRequest;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Broadcast;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cookie;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Notification;
use Illuminate\Support\Facades\URL;
use Illuminate\Support\Facades\Validator;
use Illuminate\Support\Str;
use Laravel\Horizon\Events\JobFailed;
use Monolog\Handler\IFTTTHandler;
use phpDocumentor\Reflection\Types\Resource_;
use PhpOffice\PhpSpreadsheet\Calculation\Web\Service;
use PhpParser\Node\Stmt\DeclareDeclare;
use Ramsey\Uuid\Uuid;
use Symfony\Component\ErrorHandler\Error\FatalError;

class TestController extends Controller
{
    use AsyncResponse, ErrorPush, Database;

    const ASNREFERENCE_2 = 'ASNREFERENCE2';

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

    public function method(Request $request, $method)
    {
        try {
            return call_user_func([$this, $method], $request);
        }catch (\BadMethodCallException $e){
            dd("方法不存在");
        }
    }

    public function format(array $arr,$newRes):array
    {
        $result = [];
        foreach ($arr as $index=>$item){
            if (isset($result[$item["sku_name"]])){
                if (array_search($item["self_uid"],$result[$item["sku_name"]])!==false){
                    $result[$item["sku_name"]][] = $item["next_uid"];
                }else $result[$index] = $index;
            }else $result[$item["sku_name"]] = [$item["self_uid"],$item["next_uid"]];
        }
        $recursion = [];
        foreach ($result as $item){
            if (is_array($item))$newRes[] = $item;
            else $recursion[$item] = $arr[$item];
        }
        if (count($recursion)>0)$newRes = $this->format($recursion,$newRes);
        return $newRes;
    }
    public function socket(){
        set_time_limit(0);
        $ip = '127.0.0.1';
        $port = 1935;
        if(($sock = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0) {
            echo "socket_create() 失败的原因是:".socket_strerror($sock)."\n";
        }
        if(($ret = socket_bind($sock,$ip,$port)) < 0) {
            echo "socket_bind() 失败的原因是:".socket_strerror($ret)."\n";
        }
        if(($ret = socket_listen($sock,4)) < 0) {
            echo "socket_listen() 失败的原因是:".socket_strerror($ret)."\n";
        }
        $count = 0;
        do {
            if (($msgsock = socket_accept($sock)) < 0) {
                echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";
                break;
            } else {
                $msg ="测试成功！\n";
                socket_write($msgsock, $msg, strlen($msg));
                echo "测试成功了啊\n";
                $buf = socket_read($msgsock,8192);
                $talkback = "收到的信息:$buf\n";
                echo $talkback;
                if(++$count >= 5){break;}
            }
            socket_close($msgsock);
        }while (true);
        socket_close($sock);
    }
    private static $delayedHour = 48;
    public function test(Request $request)
    {
        /**
         * Execute the console command.
         *
         */
        $delayedDateTime = Carbon::now()->subHours(self::$delayedHour)->toDateTimeString();
        dd($delayedDateTime);
        dd(\App\ReceiveRecord::query()
            ->where("record_at",">",$delayedDateTime)
            ->where("delayed",0)
            ->whereIn("logistic_number",RejectedBill::query()->select("logistic_number_return")
                ->where("created_at",">",$delayedDateTime)->whereIn("logistic_number_return",
                    \App\ReceiveRecord::query()->select("logistic_number")
                        ->where("record_at",">",$delayedDateTime)
                        ->where("delayed",0)))->get());
        dd(1);
        $path = '';
        $id = 115;

        $file = fopen($path, "r");
        $user=array();
        $i=0;
        //输出文本中所有的行，直到文件结束为止。
        while(! feof($file)){
            $user[$i]= trim(fgets($file));//fgets()函数从文件指针中读取一行
            $i++;
        }
        fclose($file);
        foreach ($user as $item){
            $arr = explode(",",$item);
            if (count($arr)!=2){
                dump($item);
                continue;
            }
            DB::table("details")->insert([
                "name" => $arr[0],
                "size" => $arr[1],
                "created_at" => date("Y-m-d H:i:s"),
                "updated_at" => date("Y-m-d H:i:s"),
                "header_id" => $id
            ]);
        }
    }
    public function test1()
    {
        $a = new \App\Http\Controllers\api\thirdPart\syrius\producer\OrderController();
        dd($a->createOrder($this->t2())->body());
    }


    public function init_labor_company_dispatch()
    {
        $dispatches = LaborCompanyDispatch::all();
        foreach ($dispatches as $dispatch) {
            $dispatch->warehouse_id = $dispatch->laborCompany->warehouse_id ?? null;
            $dispatch->save();
        }
    }

    private function t2()
    {
        $task = new Task();
        $task->id = "TEST0004";
        #$task->batchId = "WTEST0001";
        $task->warehouseId = "101";
        $task->type = Task::PUTAWAY;
        $task->attributes = [
            "customer" => "幼岚",
        ];
        $task->storages = [["serialNo"=>"1635055429594424"]];
        $task->items = [
            $this->p1(),
            $this->p2(),
        ];
        return $task->get();
    }
    private function p1()
    {
        $taskItem = new TaskItem();
        $taskItem->name = "测试衣服商品名2";
        $taskItem->barcode = "TEST-013";
        $taskItem->quantity = (int)1;
        $taskItem->binLocations = [
            "G11-133-1",
        ];
        $taskItem->attributes = [
            "storageSerialNo"=>"1635055429594424",
            "orderLineNo" => "1",
            "skuLineNo"   => "1",
            "sku"         => "TEST1",
            "lotNum"      => "LOT179201",
            "logisticNumber"=> "圆通",
        ];
        return (array)$taskItem->get();
    }
    private function p2()
    {
        $taskItem = new TaskItem();
        $taskItem->name = "测试衣服  商品名";
        $taskItem->barcode = "TEST-012";
        $taskItem->quantity = (int)1;
        $taskItem->binLocations = [
            "G11-099-1",
        ];
        $taskItem->attributes = [
            "storageSerialNo"=>"1635055429594424",
            "orderLineNo" => "1",
            "skuLineNo"   => "1",
            "sku"         => "TEST",
            "lotNum"      => "LOT17920",
            "logisticNumber"=> "顺丰",
        ];
        return (array)$taskItem->get();
    }


    public function update_order_packages_is_manual_update()
    {
        $descriptions = Log::query()
            ->select('description')
            ->whereBetween('created_at', ['2021-08-31 10:30:00', '2021-08-31 10:35:00'])
            ->where('class', 'like', 'https://was.baoshi56.com/package/logistic/batchUpdate%')->pluck('description');
        foreach ($descriptions as $description) {
            $description = substr($description, 9);
            $description = \Illuminate\Support\Str::before($description, "}");
            $obj = json_decode($description . '}', true);
            OrderPackage::query()
                ->whereIn('logistic_number', $obj['logistic_numbers'])
                ->update([
                    'status' => '无',
                    'is_manual_update' => false,
                ]);
        }
    }

    public function testUpdateInv()
    {
        ini_set('max_execution_time', 0);
        ini_set('memory_limit', '4096M');
        $sql = <<<sql
select FMLOTNUM,FMLOCATION,PLANTOLOCATION,CREATE_TRANSACTIONID,SKU,CUSTOMERID from TSK_TASKLISTS
where CUSTOMERID=?
  AND FMLOCATION= ?
  AND OPENWHO = ?
  AND TASKPROCESS = ?
  AND DOCTYPE = ?
  AND TASKTYPE = ?
  AND LOTATT05=?
  AND LOTATT08=?
  AND PLANTOID = ?
  and OPENTIME>=TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')
  and OPENTIME<=TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')
sql;
        $CUSTOMERID = 'JIANSHANG';
        $FMLOCATION = 'STAGEWH02';
        $OPENWHO = 'WCS';
        $TASKPROCESS = '00';
        $DOCTYPE = 'ASN';
        $TASKTYPE = 'PA';
        $LOTATT05 = 'MJ-CP';
        $LOTATT08 = 'ZP';
        $PLANTOID = '*';
        $traceid = 'JIANSHANG03';
        $start = '2021-09-02 23:59:59';
        $end = '2021-09-03 11:10:00';
        $res = DB::connection("oracle")->select(DB::raw($sql),
            [$CUSTOMERID, $FMLOCATION, $OPENWHO, $TASKPROCESS, $DOCTYPE, $TASKTYPE, $LOTATT05, $LOTATT08, $PLANTOID, $start, $end]);
        $resItems = array_chunk($res, 200);
        foreach ($resItems as $res) {
            DB::connection("oracle")->beginTransaction();
            try {
                foreach ($res as $re) {
                    DB::connection("oracle")->table('INV_LOT_LOC_ID')
                        ->where([
                            'LOTNUM' => $re->fmlotnum,
                            'LOCATIONID' => $re->fmlocation,
                            'CUSTOMERID' => $re->customerid,
                            'sku' => $re->sku,
                            'TRACEID' => '*',
                        ])
                        ->update([
                            'TRACEID' => $traceid,
                            'EDITWHO' => 'WCS_',
                        ]);
                    if ($re->fmlocation != $re->plantolocation) {
                        DB::connection("oracle")->table('INV_LOT_LOC_ID')
                            ->where([
                                'LOTNUM' => $re->fmlotnum,
                                'LOCATIONID' => $re->plantolocation,
                                'CUSTOMERID' => $re->customerid,
                                'sku' => $re->sku,
                                'TRACEID' => '*',
                            ])
                            ->update([
                                'TRACEID' => $traceid,
                                'EDITWHO' => 'WCS_',
                            ]);
                    }
                    DB::connection("oracle")->commit();
                }
                dd(true);
            } catch (\Exception $e) {
                DB::connection("oracle")->rollBack();
                dd($e->getMessage());
            }
        }
    }

    /**
     * 重置15天内的数据
     */
    public function order_packages_init()
    {
        OrderPackage::query()
            ->whereBetween('created_at', [now()->subDays(15), now()])
            ->update([
                'is_delay_deliver' => 0,
                'sync_routes_flag' => 0,
                'status' => 1,
                'exception_status' => 0,
            ]);
        OrderPackage::query()
            ->whereBetween('created_at', [now()->subDays(15), now()])
            ->whereNotNull('received_at')
            ->update([
                'status' => 7,
            ]);
    }

    public function syncOrderPackage(){
        ini_set('memory_limit','500M');
        ini_set('max_execution_time', 0);
        $orderPackingSummary = OracleDocOrderPackingSummary::query()
            ->where('editTime','>=','2021-09-11 12:00:00')
            ->where('editTime','<=','2021-09-12 12:40:00')
            ->get();

        $orderPackingSummary_chunk = $orderPackingSummary->chunk(200);
        foreach ($orderPackingSummary_chunk as $orderPackingSummarys) {
            foreach ($orderPackingSummarys as $orderPackingSummary) {
                $orderPackage = OrderPackage::query()->where('logistic_number',$orderPackingSummary->traceid)->first();
                $orderPackage->update([
                    'uploaded_to_wms'=> true,
                    'weight'=>$orderPackingSummary->grossweight,
                    'length'=>$orderPackingSummary->length,
                    'width'=>$orderPackingSummary->width,
                    'height'=>$orderPackingSummary->height,
                    'weighed_at'=>$orderPackingSummary->edittime
                ]);
                dispatch(new WeightUpdateInstantBill($orderPackage));
            }
        }
        return ['success' => true];
    }

    public function collectUpload()
    {
        /** @var OrderPackageService $service */
        $service = app('OrderPackageService');
       return $service->collectUpload([
           '75601803541125'
        ]);
    }

    public function init_在途异常()
    {
        $logistic_numbers = OrderPackage::query()
            ->select('logistic_number')
            ->where('exception_status', 5)
            ->where('created_at', '>=', now()->subDays(20)->toDateTimeString())
            ->pluck('logistic_number');
        /** @var OrderPackageReceivedSyncService $service */
        $service = app('OrderPackageReceivedSyncService');
        $service->syncLogisticRoute(false, $logistic_numbers);


//        $logistic_numbers = OrderPackage::query()
//            ->select(['logistic_number', 'order_id', 'id'])
//            ->whereIn('order_id', function ($query) {
//                $query->from('orders')->selectRaw('id')->whereIn('logistic_id', function ($builder) {
//                    $builder->from('logistics')->selectRaw('id')->where('type', '=', '快递')->whereNotIn('belong_company', ['顺丰', '中通', '韵达', '圆通', '京东']);
//                });
//            })
//            ->where('exception_status', 5)
//            ->where('created_at', '>=', now()->subDays(20)->toDateTimeString())
//            ->pluck('logistic_number');
//        $service->syncLogisticRouteByAliJiSu($logistic_numbers);
    }

    public function store()
    {
        ini_set('max_execution_time', 0);
        ini_set('memory_limit', '1024M');
//        $now = Carbon::now();
//        $startDate = $this->getDate();
        $startDate = '2021-09-25 13:23:14';
        $diffDay = 1; // 天数
        for($i = 0;$i<=$diffDay;$i++){
            $endDate = Carbon::parse($startDate)->addDays(1)->toDateTimeString();
            $doc_asn_headers = $this->getDocAsnHeader($startDate,$endDate);
//            if (count($doc_asn_headers)>0){
//                $this->syncStores($doc_asn_headers);
//                $this->syncDate($endDate);
//            }
            dump($startDate,$endDate);
            $startDate = $endDate;
        }
        $this->clearCache();
//        ValueStore::query()->updateOrCreate([
//            'name' => 'last_asn_sync_task_end_at',
//        ], [
//            'name' => 'last_asn_sync_task_end_at',
//            'value' => $now,
//        ]);
    }



    public function getDocAsnHeader($startDate,$endDate)
    {
        return OracleDOCASNHeader::query()
            ->with(['asnType', 'asnStatus'])
            ->select('asnno','asnstatus','asntype','addtime','edittime','customerid','notes','warehouseid','asnreference3','asnreference2')
            ->where('EditTime', '>=', $startDate)
            ->where('EditTime', '<=', $endDate)
            ->whereColumn('EditTime', '<>', 'addTime')
            ->orderByDesc('EditTime')
            ->get();
    }

    public function getDate(){
        return ValueStore::query()->where('name','asn_last_updated_sync_at')->value('value');
    }

    public function syncStores($doc_asn_headers){
        $service = new StoreService();
        $service->createStore($doc_asn_headers,"update");
        $service->updateStore($doc_asn_headers);
        $service->createStoreRejected($doc_asn_headers);
        unset($doc_asn_headers);
    }

    public function syncDate($date)
    {
        // 同步更新时间
        ValueStore::query()->updateOrCreate([
            'name' => 'asn_last_updated_sync_at',
        ], [
            'name' => 'asn_last_updated_sync_at',
            'value' => $date,
        ]);
    }
    public function clearCache()
    {
        $service = new StoreService();
        $update_set = config('sync.asn_sync.cache_prefix.update_set');
        $update_keys = config('sync.asn_sync.cache_prefix.update_keys');
        $service->deleteCacheKey($update_set, $update_keys);
        // 清空保存 ans  号的栈
        // 清除 更新时间 开始 结束
    }
    public function updateStoreItem()
    {
        ini_set('max_execution_time', 0);
        ini_set('memory_limit', '1024M');
        $storeIds = Store::query()
            ->where('updated_at', '>=', '2021-09-25 13:21:26')
            ->whereColumn('updated_at', '<>', 'created_at')
            ->pluck('id');

        $storeItemMaxIds = StoreItem::query()
            ->selectRaw('max(id) as max_id')
            ->whereIn('store_id', $storeIds)
            ->groupBy(['store_id', 'asn_line_code'])
            ->get();
//        dd($storeItemMaxIds->count());
        $storeItems = StoreItem::query()
            ->whereIn('store_id', $storeIds)
            ->whereNotIn('id', $storeItemMaxIds)
            ->delete();
    }

    public function init_SettlementBillReportTask()
    {
        $this->dispatch(new SettlementBillReportJob('2021-09-01',[]));
    }
    public function test2(){
        $source_file ="E:\OneDrive\桌面\工作目录\文件库\\5.jpg";

        $img = ImageCreateFromJpeg($source_file);
        imagecolortransparent($img);//将某个颜色设置成透明色
        imagecolorstotal($img);
        header('Content-type:image/jpeg');
        imagejpeg($img);
        //dd($this->run('E:\OneDrive\桌面\工作目录\文件库\5.jpg', 'E:\OneDrive\桌面\工作目录\文件库\6.jpg'));
    }


    const FILE_NOT_FOUND = '-1';
    const FILE_EXTNAME_ILLEGAL = '-2';

    public function run($src1, $src2) {
        if(!is_file($src1) || !is_file($src2)) exit(self::FILE_NOT_FOUND);
        $hash1 = $this->getHashValue($src1);
        $hash2 = $this->getHashValue($src2);
        if(strlen($hash1) !== strlen($hash2)) return false;
        $count = 0;
        $len = strlen($hash1);
        for($i = 0; $i < $len; $i++) if($hash1[$i] !== $hash2[$i]){
            $count++;
        }
        dd($count);
        return $count <= 10 ? true : false;
    }

    public function getImage($file) {
        $extname = pathinfo($file, PATHINFO_EXTENSION);
        if(!in_array($extname, ['jpg','jpeg','png','gif'])) exit(self::FILE_EXTNAME_ILLEGAL);
        $img = call_user_func('imagecreatefrom'. ( $extname == 'jpg' ? 'jpeg' : $extname ) , $file);
        return $img;
    }
    public function getHashValue($file) {
        $w = 32;
        $h = 32;
        $img = imagecreatetruecolor($w, $h);
        list($src_w, $src_h) = getimagesize($file);
        $src = $this->getImage($file);
        imagecopyresampled($img, $src, 0, 0, 0, 0, $w, $h, $src_w, $src_h);
        imagedestroy($src);
        $total = 0;
        $array = array();
        for( $y = 0; $y < $h; $y++) {
            for ($x = 0; $x < $w; $x++) {
                $rgb = imagecolorat($img, $x, $y);
                $gray = $rgb & 0xFF;
                /*dump([
                    ($rgb >> 8) & 0xFF,
                    ($rgb >> 16) & 0xFF,
                    $rgb & 0xFF,
                ]);*/
                if(!isset($array[$y])) $array[$y] = array();
                $array[$y][$x] = $gray;
                $total += $gray;
            }
        }
        imagedestroy($img);
        $average = intval($total / ($w * $h * 2));
        $hash = '';
        for($y = 0; $y < $h; $y++) {
            for($x = 0; $x < $w; $x++) {
                $hash .= ($array[$y][$x] >= $average) ? '1' : '0';
            }
        }
        dump($hash);
        return $hash;
    }

    public function sortTransferStatus()
    {
        $orderPackage = OrderPackage::query()->where('logistic_number','75601831068018')->first();
        app('OrderPackageService')->sortOrderPackageTransferStatus($orderPackage);
        dd($orderPackage);
    }

    public function clear_work_space()
    {
        \App\LaborApply::query()->truncate();

        LaborCompanyDispatch::query()->truncate();

        \App\LaborCompanyDispatchDetail::query()->truncate();
    }

    public function testChange()
    {
        $last_start_key = config('sync.order_sync.cache_prefix.last_start_at');
        $last_end_key = config('sync.order_sync.cache_prefix.last_end_at');
        Cache::put($last_start_key,Carbon::make('2021-10-12 06:23:37'));
        Cache::put($last_end_key,Carbon::make('2021-10-12 06:23:38'));
        ValueStore::query()->where('name','order_last_created_sync_at')->update(['value' => '2021-10-12 06:23:37']);
        ValueStore::query()->where('name','order_last_updated_sync_at')->update(['value' => '2021-10-12 06:23:37']);
        ValueStore::query()->where('name','last_order_sync_task_start_at')->update(['value' => '2021-10-12 06:23:37']);
        ValueStore::query()->where('name','last_order_sync_task_end_at')->update(['value' => '2021-10-12 06:23:38']);
    }

    public function test3()
    {
        foreach (Batch::query()->where("updated_at",">=","2021-11-22 09:00:00")->get() as $batch){
            try {
                $this->assignBatch($batch->code);
            }catch (\Exception $e){
                continue;
            }
        }
    }

    public function assignBatch($code)
    {
        $batches = Batch::query()->where("code",$code)->get();
        if (!$batches->count()){
            $wave = DB::connection("oracle")->selectOne(DB::raw("select * from DOC_WAVE_HEADER where WAVENO = ?"),[$code]);
            if (!$wave){
                dd("FLUX无波次");
            }
            $owner = app("OwnerService")->codeGetOwner($wave->customerid);
            $obj = [
                "wms_status" => $this->wms_status($wave),
                "wms_type"=>$wave->descr,
                "created_at"=>date("Y-m-d H:i:s"),
                "wms_created_at"=>$wave->addtime,
                "updated_at"=>$wave->edittime,
                "owner_id"=>$owner->id,
            ];
            $wave = Batch::query()->where("code",$code)->first();
            if (!$wave){
                $obj["code"] = $code;
                $wave = Batch::query()->create($obj);
            }else{
                Batch::query()->where("code",$code)->update($obj);
            }
            $ordernos = array_column(DB::connection("oracle")->select(DB::raw("select orderno from DOC_WAVE_DETAILS where WAVENO = ?"),[$code]),"orderno");
            Order::query()->whereIn("code",$ordernos)->update([
                "batch_id"=>$wave->id
            ]);
            Order::query()->with(["batch","bin"])->whereIn("code",$ordernos)->get()->each(function ($order){
                if (!$order->bin){
                    $bin = DB::connection("oracle")->selectOne(DB::raw("select seqno from DOC_WAVE_DETAILS where waveno = ? and orderno = ?"),[$order->batch->code,$order->code]);
                    if ($bin){
                        OrderBin::query()->create([
                            'order_id' => $order->id,
                            'number' => $bin->seqno,
                        ]);
                    }
                }
            });
            $batches = Batch::query()->where("code",$code)->get();
        }
        app("BatchService")->assignTasks($batches);
    }


    public function syncOrder()
    {
        $code = \request("code");
        $service = new OracleDOCOrderHeaderService();
        $orderService = new OrderService();
        $orderHeaders = $service->getQuery()->where('DOC_Order_Header.WaveNo',$code)->get();
        $orderService->syncOrderByWMSOrderHeaders($orderHeaders);
        app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
        dd('同步完成');
    }

    public function test_sddgdfg()
    {
        /** @var OwnerStoreOutFeeReportService $service */
        $service = app('OwnerStoreOutFeeReportService');
        $service->recordReport(null, [2]);
    }

    public function testZhenCang()
    {
//        $batches=Batch::query()->where('id',161071)->get();
//        BroadcastBatchToZhengCangJob::dispatch($batches);
//        $sql = <<<sql
//select department_id,obligation_id,owner_id,max(valid_time) from department_obligation_owner group by obligation_id,owner_id,department_id
//sql;
//        $info = DB::select(DB::raw($sql));
//        dd($info);
//        $owner=Owner::query()->with(['departmentObligationOwner'])->find(403);
//        dd($owner);
//        $a=app('ObligationService')->recombineCodeIdArr();
        $now=Carbon::now()->subMonths(-1)->startOfMonth()->startOfDay()->toDateTimeString();
        dd($now);
    }

    public function syncOrderIssue()
    {
        /** @var OrderIssue $orderIssue */
        $orderIssue = OrderIssue::query()->find('48798');
        $orderIssue->syncRejectingStatus();
    }

    public function test123()
    {
        $user = User::query()->where('name','yanyuanmin')->first();
        Auth::setUser($user);
        dd(Auth::user());
        return ;
        $reflection = new \ReflectionClass(new OrderIssue());
        dump($reflection->getMethods());
        dump($reflection->getConstants());
        dump($reflection->getInterfaces());
    }

    public function syncWorkOrder()
    {
        $workOrders = WorkOrder::query()->with('order')->get();
        foreach ($workOrders as $workOrder) {
            $workOrder->owner_id = $workOrder->order->owner_id;
            $workOrder->logistic_id = $workOrder->order->logistic_id;
            if ($workOrder->review_at){
                $workOrder->status = 5;
            }
            $workOrder->save();
        }
    }

    public function SyncOrder11(){
        WorkOrder::query()->whereIn('id',['3420','3421','3422'])->update(['status'=>'3']);
        WorkOrder::query()->whereIn('id',['3423','3424','3425'])->update(['status'=>'3']);
    }

    public function workOrderChangeVersion()
    {
        $workOrders = WorkOrder::query()->with('details')->get();
        $workOrderDetails = $this->groupByWorkOrderId(WorkOrderDetail::query()->get());
        $WorkOrderLogs = $this->groupByWorkOrderId(WorkOrderLog::query()->get());
        $workOrderImages = $this->groupByWorkOrderId(WorkOrderImage::query()->get());
        $workOrderCommodities = $this->groupByWorkOrderId(WorkOrderCommodities::query()->get());
        $workOrderLogUpDateParams = [['id','tag','work_order_detail_id']];
        $workOrderImagesUpDateParams = [['id','tag','work_order_detail_id']];
        $workOrderCommoditiesUpDateParams = [['id','tag','work_order_detail_id']];
        foreach ($workOrders as $workOrder) {
            $detail =  $workOrderDetails[$workOrder->id][0] ?? null;
            if (!$detail){
                $detail = new WorkOrderDetail([
                    'work_order_id' => $workOrder->id,
                    'order_issue_type_id' => $workOrder->order_issue_type_id ?? '',
                    'remark' => $workOrder->remark,
                    'status' => $workOrder->status,
                ]);
                if ($detail->status == '完结'){$detail->tag = 1;}
                else {$detail->tag = 0;}
                $detail->status = $workOrder->status;
                $detail->save();
            } else {
                $detail->order_issue_type_id = $workOrder->order_issue_type_id ?? '';
                $detail->remark = $workOrder->remark ?? '';
                $detail->status = $workOrder->status;
                $detail->update();
            }
            if ($WorkOrderLogs[$workOrder->id]??false){
                $arrays = $this->getUpdateParams($workOrder,$detail,$WorkOrderLogs[$workOrder->id] ?? null);
                array_push($workOrderLogUpDateParams,$arrays);
            }
            if ($workOrderImages[$workOrder->id]??false){
                $arrays = $this->getUpdateParams($workOrder,$detail,$workOrderImages[$workOrder->id] ?? null);
                array_push($workOrderImagesUpDateParams,$arrays);
            }
            if (  $workOrderCommodities[$workOrder->id]??false){
                $arrays = $this->getUpdateParams($workOrder,$detail,$workOrderCommodities[$workOrder->id] ?? null);
                array_push($workOrderCommoditiesUpDateParams,$arrays);
            }
        }

        $service = new BatchUpdateService();
        if (count($workOrderLogUpDateParams) > 1) $service->batchUpdate('work_order_logs',$workOrderLogUpDateParams);
        if (count($workOrderImagesUpDateParams) > 1) $service->batchUpdate('work_order_images',$workOrderImagesUpDateParams);
        if (count($workOrderCommoditiesUpDateParams) > 1) $service->batchUpdate('work_order_commodities',$workOrderCommoditiesUpDateParams);
    }

    public function getUpdateParams($workOrder,$detail,$items):array
    {
        $array = [];
        $tag = $detail->status == '完成' ? 1 : 0;
        foreach ($items as $item){
            $item = ['id' => $item->id,'tag' => $tag,'work_order_detail_id' => $detail->id];
            $array[] = $item;
        }
        return $array;
    }

    public function groupByWorkOrderId($items): array
    {
        $array = [];
        foreach ($items as $item) {
            if (in_array($item->id,$array)){
                $array[$item->work_order_id][] = $item;
            } else {
                $array[$item->work_order_id] = [$item];
            }
        }
        return $array;
    }

    public function  workOrder(){
        dd(route('workOrder.damage.storeApi'));
    }
}