<?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\ReceiveRecord;
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);
    }
    public function test(Request $request)
    {
        return view('equipment.index');
        //return response()->json(["info"=>["id"=>1,"name"=>2]]);
        return response()->json(["info"=>["id"=>1,"name"=>2]]);
        dd(time());
        ini_set('max_execution_time',-1);
        $worker = new Worker('tcp://0.0.0.0:9865');

        $worker->onConnect = function ($conn) {
            echo '新的连接来了';
        };
        $worker->onClose = function ($conn) {
            echo '连接断开了';
        };
        $worker->onMessage = function ($conn, $message) {
            $http_resonse = "HTTP/1.1 200 OK\r\n";
            $http_resonse .= "Connection: keep-alive\r\n";
            $http_resonse .= "Server: php socket server\r\n";
            $http_resonse .= "Content-length: 11\r\n\r\n";
            $http_resonse .= "hello world";
            fwrite($conn, $http_resonse);
        };

        $worker->run();
        return;
        $service = new LogisticService();
        foreach (ReceiveRecord::query()->where("logistic_id",0)->get() as $receive){
            $name = $service->assertExpressCompany($receive->logistic_number);
            if ($name){
                $logistic = Logistic::query()->select("id","name")
                    ->where("name","like","%{$name}%")->first();
                $logisticId = $logistic ? $logistic->id : 0;
            } else $logisticId = 0;
            if ($logisticId!=0)$receive->update(["logistic_id"=>$logisticId]);
        }
        dd(ReceiveRecord::query()->where("logistic_id",0)->count());
        $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 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);
    }


}
class Worker{
    //监听socket
    protected $socket = NULL;

    //所有的socket连接
    protected $allSockets = array();

    //连接事件回调
    public $onConnect = NULL;

    //断线事件回调
    public $onClose = NULL;

    //接收消息事件回调
    public $onMessage = NULL;

    public function __construct($socket_address) {
        //创建一个socket监听
        $this->socket = stream_socket_server($socket_address);

        //设置为非阻塞
        stream_set_blocking($this->socket, 0);

        //将socket监听加入allSockets
        $this->allSockets[(int)$this->socket] = $this->socket;
    }

    public function run() {
        while(true) {
            //不监听可写事件与带外数据事件
            $write = $except = array();
            //监听所有的socket事件
            $read = $this->allSockets;
            //整个进程阻塞在这里，持续监听可读事件
            //此处参数均为引用传递，在函数中会改变传值
            stream_select($read, $write, $except, 60);

            //处理所有可读事件
            foreach ($read as $index => $socket) {
                //如果是监听socket，此处表示有新的连接
                if ($socket === $this->socket) {
                    //通过stream_socket_accept获取新的连接
                    $new_conn_socket = stream_socket_accept($socket);

                    if ($this->onConnect) {
                        //触发连接事件的回调,并将当前连接传递给回掉函数
                        call_user_func($this->onConnect, $socket);
                    }
                    //记录此socket连接,以便于sream_select监听可读事件
                    $this->allSockets[(int)$new_conn_socket] = $new_conn_socket;
                } else
                    //如果可读事件不为监听socket，则表示对应客户端有数据发过来
                {
                    //从连接中读取数据
                    $buffer = fread($socket, 65535);
                    //如果数据为空，表示客户端已经断开连接
                    if ('' === $buffer || false === $buffer) {
                        //尝试触发onClose回调
                        if ($this->onClose) {
                            call_user_func($this->onClose, $socket);
                        }
                        fclose($socket);
                        //关闭socket连接并从allSockets中删除
                        unset($this->allSockets[(int)$socket]);
                        continue;
                    }
                    //表示一个正常的连接，已经读取到消息，交给回掉函数处理
                    if ($this->onMessage) {
                        call_user_func($this->onMessage, $socket, $buffer);
                    }
                }
            }
        }
    }
}