<?php

namespace App\Http\Controllers;

use App\Components\AsyncResponse;
use App\Components\ErrorPush;
use App\ErrorTemp;
use App\Events\SettlementBillCreateEvent;
use App\Feature;
use App\MaterialBoxModel;
use App\Owner;
use App\OwnerFeeDetail;
use App\OwnerLogisticFeeDetail;
use App\OwnerMaterial;
use App\OwnerPriceOperation;
use App\RejectedBill;
use App\Unit;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Http;

class TestController extends Controller
{
    use AsyncResponse,ErrorPush;
    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 lightUp()
    {
        app("CacheShelfService")->lightUp('HAIB1-02-02','3','2');
    }
    public function lightOff()
    {
        $params = [
            "areaCode" => "1004",
            'locCode' => "HAIB1-02-02",
            'PTLAction' => 0,
        ];
        $response = Http::post(config('api.haiq.storage.light'), $params);
        return json_decode($response->body());
    }
    public function test()
    {
        dd(!!Unit::query()->first());
    }

    public function deleteRepetitionSku()
    {
        $Commodities = Commodity::query()->selectRaw('owner_id,sku,count(1) as counts ')->whereNotNull(['owner_id', 'sku'])->groupBy('owner_id', 'sku')->having('counts', '>', '1')->get();
        $CommodityItems = $Commodities->chunk(200);
        foreach ($CommodityItems as $items) {
            $Commodities = Commodity::query()->whereIn('owner_id', data_get($items, '*.owner_id'))->whereIn('sku', data_get($items, '*.sku'))->get();
            $arr = collect($Commodities->toArray());
            $arr = $arr->groupBy(['owner_id', 'sku']);
            foreach ($arr as $item) {
                foreach ($item as $value) {
                    if (count($value) <= 1) continue;
                    dispatch(new DeleteRepetitionSkuItem($value));
                }
            }
        }
    }
    public function order_packages_exception_type_sync()
    {
        $count = OrderPackage::query()->where('status', '派送异常')->update(['exception_type' => '派件异常', 'exception' => '是']);
        dump('更新了： ' . $count);
    }

    public function order_packages_exception_type_and_exception_update()
    {
        $count_1 = OrderPackage::query()
            ->whereIn('exception_type', ['疑似库内丢件', '揽件异常'])
            ->whereNotNull('transfer_status')
            ->update(['exception_type' => '无', 'exception' => '否']);
        $count_2 = OrderPackage::query()
            ->where('status', '已收件')
            ->update(['exception_type' => '无', 'exception' => '否']);
        dump('更新了： ' . ($count_1 + $count_2));
    }


    public function pushToWmsWeight()
    {
        $orderPackages = OrderPackage::query()->where('measuring_machine_id', 12)->where('uploaded_to_wms', '!=', '是')->whereNotNull('weight')->get();
        $packageController = new WeightBaseController();
        foreach ($orderPackages as $orderPackage) {
            $packageController->activityWaveNoProcessing($orderPackage);
        }
    }


    public function syncOrderTracking()
    {
        $orderNos = ['OSSO21040013', 'OSSO21040012'];
        $service = new OrderTrackingService();
        $orderHeaderService = new OracleDOCOrderHeaderService();
        $orderHeaders = $orderHeaderService->getQuery()->whereIn('DOC_Order_Header.SoReference1', $orderNos)->get();
        $service->createByWmsOrderHeader($orderHeaders);
        $service->updateByWmsOrderHeaders($orderHeaders);
    }

    public function addHaiBox(Request $request)
    {
        echo <<<TEXT
    <form>
    <textarea name="boxes">

</textarea>
<input type="submit"/>
</form>
TEXT;
        $input = $request->input('boxes');
        if ($input) {
            $input = preg_replace('/[\n\r]/', ',', trim($input));
            $boxes = explode(',', $input);
            dd($boxes);
        }
    }


    public function testProcurement()
    {
        $procurementTotals = ProcurementTotalBill::query()
            ->where('status', 1)
            ->where('counting_month', '2021-04-01')
            ->get();
        foreach ($procurementTotals as $procurementTotalBill) {
            /** @var  ProcurementTotalBill $procurementTotalBill */
            $procurementTotalBill->setCurrentMothProcurements();
            if (isset($procurementTotalBill->procurementCheckSheets)) {
                $procurementCheckSheets = $procurementTotalBill->procurementCheckSheets;
                foreach ($procurementCheckSheets as $procurementCheckSheet) {
                    $procurementCheckSheet->update(['status' => 2]);//2 已出账
                }
            }
        }
    }

    public function testHttp()
    {
        return view('httpTest');
    }

    public function orderPackageUnique()
    {
        /** @var OrderService $orderService */
        /** @var OracleDOCOrderHeaderService $orderHeaderService */
        $orderService = app(OrderService::class);
        $orderHeaderService = app(OracleDOCOrderHeaderService::class);

        $orderPackages = OrderPackage::query()->selectRaw('count(1) counts,logistic_number')->where('created_at', '>=', '2020-01-01')->groupBy('logistic_number')->having('counts', '>', '1')->get();

        $updateParams = [];
        $deleteParams = [];
        foreach ($orderPackages as $orderPackage) {
            $items = OrderPackage::query()->with('order')->where('logistic_number', $orderPackage['logistic_number'])->with('order')->get();
            $actAllocationDetails = OracleActAllocationDetails::query()->selectRaw('orderno')->where('PICKTOTRACEID', $orderPackage['logistic_number'])->get();

            $oracleOrderNos = array_unique(data_get($actAllocationDetails, '*.orderno'));
            $diffOrderNos = array_diff($oracleOrderNos, data_get($items, '*.order.code'));
            if (count($diffOrderNos) != 0) {
                $orderHeaders = $orderHeaderService->getQuery()->whereIn('DOC_Order_Header.OrderNo', $diffOrderNos)->get();
                $orderService->syncOrderInfo($orderHeaders);
            }

            $items = OrderPackage::query()->with('order')->where('logistic_number', $orderPackage['logistic_number'])->with('order')->get();
            if ($order = Order::query()->whereIn('id', data_get($items, '*.id'))->where('wms_status', '!=', '订单取消')->first()) {
                $saveOrderPackage = OrderPackage::query()->where('order_id', $order['id'])->where('logistic_number', $orderPackage['logistic_number'])->first();
            } else {
                $saveOrderPackage = $items->first();
            }

            foreach ($items as $item) {
                $saveOrderPackage['batch_number'] = $item['batch_number'] ?? $saveOrderPackage['batch_number'];
                $saveOrderPackage['batch_rule'] = $item['batch_rule'] ?? $saveOrderPackage['batch_rule'];
                $saveOrderPackage['bulk'] = $item['bulk'] ?? $saveOrderPackage['bulk'];
                $saveOrderPackage['weight'] = $item['weight'] ?? $saveOrderPackage['weight'];
                $saveOrderPackage['weighed_at'] = $item['weighed_at'] ?? $saveOrderPackage['weighed_at'];
                $saveOrderPackage['length'] = $item['length'] ?? $saveOrderPackage['length'];
                $saveOrderPackage['width'] = $item['width'] ?? $saveOrderPackage['width'];
                $saveOrderPackage['height'] = $item['height'] ?? $saveOrderPackage['height'];
                $saveOrderPackage['measuring_machine_id'] = $item['measuring_machine_id'] ?? $saveOrderPackage['measuring_machine_id'];
                $saveOrderPackage['owner_id'] = $item['owner_id'] ?? $saveOrderPackage['owner_id'];
                $saveOrderPackage['received_at'] = $item['received_at'] ?? $saveOrderPackage['received_at'];
                $saveOrderPackage['transfer_status'] = $item['transfer_status'] ?? $saveOrderPackage['transfer_status'];
                $saveOrderPackage['status'] = $item['status'] != '无' ? $item['status'] : $saveOrderPackage['transfer_status'];
                $saveOrderPackage['uploaded_to_wms'] = $item['uploaded_to_wms'] != '否' ? $item['uploaded_to_wms'] : $saveOrderPackage['uploaded_to_wms'];
            }
            $orderPackages_filter = $items->filter(function ($item) use ($saveOrderPackage) {
                if ($saveOrderPackage['id'] === $item['id']) return false;
                return true;
            });
            $ids = $orderPackages_filter->map(function ($item) {
                return $item['id'];
            });
            LogService::log('order_packages', 'order_packages_logistic_number_unique_delete', json_encode($orderPackages_filter));
            OrderPackage::query()->whereIn('id', $ids)->delete();
            $updateParams[] = $saveOrderPackage;
            $deleteParams[] = $orderPackages_filter;
            $saveOrderPackage->save();
        }
        dd('任务完成');
        dd($updateParams, $deleteParams);
    }

    public function endStationTask()
    {
        $stationTask = StationTask::query()->where('id', 711)->first();
        $stationTask->update(['status' => '完成']);
    }

    public function order_package_exception_type_counting_record_init()
    {
        /**
         * @var $service OrderPackageExceptionTypeCountingRecordService
         */
        $service = app('OrderPackageExceptionTypeCountingRecordService');
        $service->updateOrCreate(30);
    }

    public function testForeignZhenCang($batches)
    {

        $batches = Batch::query()
            ->with(['orders.orderCommodities.commodity.barcodes'])
            ->find(111953);
        $body = [];
        $body['id'] = $batches->code;
        $body['orders'] = [];
        foreach ($batches->orders as $order) {
            $orderArr = [];
            $orderArr['id'] = $order->code ?? '';
            $orderArr['createdAt'] = Carbon::parse($order->created_at)->toDateTimeString() ?? '';
            $orderArr['barcodes'] = [];
            foreach ($order->orderCommodities as $orderCommodity) {
                $barcode = [];
                $barcode['id'] = $orderCommodity->id;
                $barcode['barcode'] = $orderCommodity->commodity ? ($orderCommodity->commodity->barcodes ? $orderCommodity->commodity->barcodes->first()['code'] : '') : '';
                $barcode['name'] = $orderCommodity->commodity->name ?? '';
                $barcode['sku'] = $orderCommodity->commodity->sku ?? '';
                $barcode['amount'] = $orderCommodity->amount ?? '';
                $barcode['location'] = $orderCommodity->location ?? '';
                $orderArr['barcodes'][] = $barcode;
            }
            $body['orders'][] = $orderArr;
        }
        $response = Http::withHeaders([
            'Host' => 'zc-it.com',
        ])->post('http://1.116.164.201:8080/api/createBatch', $body);
        dd(json_decode($response->body()));
    }

    public function updateBulk()
    {
        $orderPackages = OrderPackage::query()->where('measuring_machine_id', 16)->get();
        foreach ($orderPackages as $orderPackage) {
            $orderPackage->update([
                'bulk' => $orderPackage['length'] * $orderPackage['width'] * $orderPackage['height']
            ]);
        }
    }

    public function testPrint(Request $request)
    {
        return (new PrintPartController())->print($request);
    }

    public function testSendCon(Request $request)
    {
        $content = [
            "type" => "getClients",
            "aliasName" => "test",
            "printerName" => "打印机5",
        ];
        $post = Http::post("http://127.0.0.1:3000", $content);
        $body = json_decode($post->body(), true);
        $body['msg'] = json_decode($body['msg'], true);
        dd(json_decode($post->body()), $post->body(), $body);
    }


    public function zop_test(Request $request)
    {
        $logistic_number = $request->logistic_number;
        \App\Jobs\LogisticZopSync::dispatchNow($logistic_number);
    }

    public function laborReportsCountingRecordsCacheClear()
    {
        $dayClears = now()->subYear()->daysUntil(now());
        $monthClears = now()->subYear()->monthsUntil(now());
        foreach ($dayClears as $day) {
            $key = 'laborReportsCountingRecords_' . $day->toDateString() . '_日';
            Cache::forget($key);
        }
        foreach ($monthClears as $month) {
            $key = 'laborReportsCountingRecords_' . $month->format('Y-m') . '_月';
            Cache::forget($key);
        }
        Cache::forget('laborReportsCountingRecords_2020_年');
        Cache::forget('laborReportsCountingRecords_2021_年');
    }
    public function testApi()
    {
        $headers = array();
        array_push($headers, "Authorization:APPCODE " . 20202020);
        //根据API的要求，定义相对应的Content-Type
        array_push($headers, "Content-Type".":"."application/json; charset=UTF-8");
        dd($headers);
    }


    public function ownerLogisticFeeDetailService_getDetails()
    {
        /**
         * @var $services OwnerLogisticFeeDetailService
         */
        $services = app('OwnerLogisticFeeDetailService');
        $result = $services->getDetails('12', '2021-05-30', '2021-05-31', 50);
        dd($result);
    }

    public function order_counting_records_cache_clear()
    {
        $owner_ids = Owner::query()->select('id')->pluck('id');
        $dayClears = now()->subYear()->daysUntil(now());
        foreach ($dayClears as $day) {
            foreach ($owner_ids as $owner_id) {
                $key = "order_counting_records_{$day->toDateString()}_{$owner_id}_日";
                Cache::forget($key);
            }
        }
    }

    public function order_counting_records_init()
    {
        \App\OrderCountingRecord::query()->truncate();
        $start = now()->subMonths(1)->toDateString();
        $end = now()->subDay()->toDateString();
        $service = app('NewOrderCountingRecordService');
        $service->recordByDay($start, $end, '日');
    }

    public function OwnerLogisticFeeReportService_test()
    {
        /* @var $service OwnerLogisticFeeReportService */
        $service = app('OwnerLogisticFeeReportService');
        $result=  $service->get(['owner_id' =>3,'date'=>'2021-05-01']);
        dd($result);
    }

    public function createProcurementTotalBill()
    {
        $date='2021-05';
        $procurementCheckSheets=ProcurementCheckSheet::query()
            ->selectRaw('procurements.supplier_id supplier_id,procurement_check_sheets.created_at created_at,procurement_check_sheets.status status,SUM(procurement_check_sheets.account_payable) account_payable')
            ->leftJoin('procurement_deliveries','procurement_check_sheets.procurement_delivery_id','procurement_deliveries.id')
            ->leftJoin('procurements','procurement_deliveries.procurement_id','procurements.id')
            ->where('procurement_check_sheets.created_at','like',$date."%")
            ->groupBy('supplier_id')->where('procurements.supplier_id',84)
            ->get();
        $totalBill=[];
        foreach ($procurementCheckSheets as $procurementCheckSheet){
            if ($procurementCheckSheet->account_payable<1) continue;
            $totalBill[]=[
                'counting_month'=>$date.'-01',
                'supplier_id'=>$procurementCheckSheet->supplier_id,
                'total_payable'=>$procurementCheckSheet->account_payable,
                'status'=>$procurementCheckSheet->status,
                'created_at'=>date('2021-06-01 00:00:00'),
                'updated_at'=>date('2021-06-01 00:00:00'),
            ];
        }
        if (count($totalBill)>0){
            DB::table("procurement_total_bills")->insert($totalBill);
            app('LogService')->log(__METHOD__,"采购管理-生成月账单报表",json_encode($totalBill));
        }
    }

    public function uuid()
    {
        dd(md5( date("Y-m-d H:i:s")));
    }

    public function settlement_bill_create_event_test()
    {
        $arr = [
            'owner_fee_detail_id'=>2313213, //
            'logistic_bill'=>'14546465',//快递单号
            'initial_weight'=>'1',//首重
            'initial_weight_price'=>'2',//首重价格
            'additional_weight'=>'3',//续重
            'additional_price'=>'5',//续重价格
            'logistic_id'=>'7',//承运商
            'owner_id'=>'1',//货主
            'additional_weigh_weight'=>'11',//续重重量
            'tax_fee'=>'11',//税费
            'fee'=>'11111'//费用
        ];
        event(new SettlementBillCreateEvent($arr,OwnerLogisticFeeDetail::class));
    }
}