<?php

namespace App\Http\Controllers;

use App\Batch;
use App\CommodityBarcode;
use App\Components\AsyncResponse;
use App\Components\Database;
use App\Components\ErrorPush;
use App\Exceptions\Exception;
use App\OracleDOCWaveDetails;
use App\Order;
use App\OrderBin;
use App\OrderCommodity;
use App\Rejected;
use App\RejectedBill;
use App\RejectedBillItem;
use App\Services\LogService;
use App\Services\OracleDOCOrderHeaderService;
use App\Services\OrderCommodityService;
use App\Services\OrderService;
use App\Services\WaveService;
use App\Services\WaybillService;
use App\SortingStation;
use App\User;
use App\UserToken;
use App\Waybill;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Str;
use Zttp\Zttp;

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 a1(){
        dd(phpinfo());
        dd(DB::table('BAS_CODES')->select('code', 'codename_c')->where('codeid', 'SO_STS')->orderBy('code', 'asc')->sql());
        $response = Http::post("https://api.baoshi56.com/api/flux/getList", [
            "sql" => "SELECT * FROM BAS_CODES WHERE CODEID = 'ABC'"
        ]);
        dd(json_decode($response->body(), true)->data);
    }
    public function test(Request $request)
    {
        dd(Hash::make("zhao123456"));
    }

    public function syncOrder($code)
    {
        $orderHeaders = app(OracleDOCOrderHeaderService::class)->getQuery()->where('DOC_Order_Header.WaveNo',$code)->get();
        app(OrderService::class)->syncOrderByWMSOrderHeaders($orderHeaders);
        app(OrderCommodityService::class)->syncOrderCommodity($orderHeaders);
        $this->syncOrderBin($code);
    }
    public function syncOrderBin($code)
    {
        $wave = DB::connection("oracle")->selectOne(DB::raw("select * from DOC_WAVE_HEADER where WAVENO = ?"), [$code]);
        if (!$wave) return;
        $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,
        ];
        $batch = Batch::query()->where("code", $code)->first();
        if (!$batch) {
            $obj["code"] = $code;
            $batch = Batch::query()->create($obj);
        } else {
            Batch::query()->where("code", $code)->update($obj);
        }
        $order_nos = array_column(DB::connection("oracle")->select(DB::raw("select orderno from DOC_WAVE_DETAILS where WAVENO = ?"), [$code]), "orderno");

        Order::query()->whereIn("code", $order_nos)->update(["batch_id" => $batch->id]);

        Order::query()->with(["batch", "bin"])->whereIn("code", $order_nos)->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,
                    ]);
                }
            }
        });
    }
}