<?php

namespace App\Http\Controllers;

use App\OracleBasCustomer;
use App\OracleDOCOrderHeader;
use App\OracleDOCWaveDetails;
use App\OrderIssueType;
use App\Services\LogService;
use App\Services\OrderService;
use App\Services\RejectedBillItemService;
use App\Services\RejectedBillService;
use Exception;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Http;

class OrderController extends Controller
{
    public function delivering(Request $request){
        if(!Gate::allows('订单管理-查询')){ return view('order/index');  }
        /** @var OrderService $orderService */
        $orderService = app('orderService');
        $request = $request->input();
        $result = $orderService->paginate($request);
        $picktotraceids = $result['picktotraceids'];
        $orders = $result['orders'];
        $commodities = $result['commodities'];
        $customers=OracleBasCustomer::query()->select('customerid','descr_c')->where('customer_type','OW')->where('active_flag','Y')->get();
        $page = $request["page"] ?? 1;
        $codes=DB::connection('oracle')->table('BAS_CODES')->select('code','codename_c')->where('codeid','SO_STS')->orderBy('code','asc')->get();
        $orderIssueType = OrderIssueType::all();
        return view('order/index/delivering',compact('orders','customers','request','codes','commodities','page','picktotraceids','orderIssueType'));
    }

    //导出
    public function export(Request $request){
        $is_merge = $request->is_merge ?? false;
        /** @var OrderService $orderService */
        $orderService = app('orderService');
        $req = ['type'=>'order'];
        if ($is_merge && $is_merge == 'true')$req["createFormat"] = "merge";
        if ($request->data){
            $req["sql"] = $orderService->getSql(['data'=>$request->data]);
        }else{
            $req["sql"] = $orderService->getSql($request->input());
        }
        $post = Http::post(config('go.export.url'),$req);
        if ($post->status() == 500){
            throw new Exception($post->header("Msg"));
        }
        return response($post,200, [
            "Content-type"=>"application/octet-stream",
            "Content-Disposition"=>"attachment; filename=订单记录-".date('ymdHis').'.xlsx',
        ]);
    }

    public function createRejectedBill(Request $request){
        if(!Gate::allows('订单管理-订单-生成退货单')){ return ['success'=>false,'data'=>'您无权操作！'];  }
        /** @var OrderService $orderService */
        $orderService = app('orderService');
        $result = $orderService->get(['data' => $request->data]);

        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app('rejectedBillService');

        /** @var RejectedBillItemService $rejectedBillItemService */
        $rejectedBillItemService = app('rejectedBillItemService');

        $commodities = $result['commodities'];
        $rejectedBillItems = [];
        foreach ($result['orders'] as $order){
            $owner = app('ownerService')->firstOrCreate(['name' => $order->customer_descr_c],
                ['name' => $order->customer_descr_c, 'code' => $order->customer_descr_c]);
            $logistic = app('logisticService')->firstOrCreate(['name' => $order->carriername],
                ['name' => $order->carriername, 'code' => $order->carriername]);
            $rejectedBill = $rejectedBillService->create([
                'id_owner' => $owner->id,
                'sender' => $order->c_contact,
                'logistic_number_return' => $order->soreference5,
                'id_logistic_return' => $logistic->id,
                'order_number' => $order->orderno,
                'mobile_sender' => $order->c_tel2,
                'logistic_number' => '原单退回',//$order->soreference1
                'remark' => $order->notes,
                'is_loaded' =>0,
            ]);
            LogService::log(__METHOD__,"生成退货单",json_encode($order),Auth::user()['id']);
            if ($commodities[$order->orderno] ?? false){
                foreach ($commodities[$order->orderno] as $orderCommodities){
                    array_push($rejectedBillItems,[
                        'id_rejected_bill' => $rejectedBill->id,
                        'barcode_goods' => $orderCommodities['alternate_sku1'],
                        'name_goods' => $orderCommodities['descr_c'],
                        'amount' => $orderCommodities['qtyordered'],
                        'id_quality_label' => 1,
                        'created_at' => date('Y-m-d H:i:s'),
                    ]);
                }
            }
        }
        $rejectedBillItemService->insert($rejectedBillItems);
        LogService::log(__METHOD__,"批量生成退货单详情",json_encode($rejectedBillItems),Auth::user()['id']);
        return ['success'=>true];
    }

    public function isRejectedBillExist(Request $request){
        if(!Gate::allows('订单管理-订单-生成退货单')){ return redirect(url('/'));  }
        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app('rejectedBillService');
        $rejectedBills = $rejectedBillService->get(['order_number' => $request->data]);
        if (count($rejectedBills) == 0)return ['success'=>true];
        return ['success'=>false, 'data'=>json_encode(array_column($rejectedBills->toArray(),'order_number'))];
    }

    //批量备注追加
    public function batchComments(Request $request){
        if(!Gate::allows('订单管理-批量备注')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData');
        $content=$request->input('content');
        $ordersNotNull=OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
            ->whereNotNull('notes')->get();
        OracleDOCOrderHeader::query()->select('OrderNo','Notes')->whereIn('orderno',$checkData)
            ->whereNull('notes')->update(['notes'=>$content]);
        $ordersNotNullArr=array_column($ordersNotNull->toArray(),'orderno');
        $ordersNullArr=array_diff($checkData,$ordersNotNullArr);
        $data=[];
        foreach ($ordersNotNull as $order){
            OracleDOCOrderHeader::query()->where('orderno',$order->orderno)->update(["notes"=>($order->notes).",".$content]);
            $this->log(__METHOD__,'批量备注追加修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            $order->notes=($order->notes).",".$content;
            array_push($data,$order);
        }
        foreach ($ordersNullArr as $order){
            array_push($data,["orderno"=>$order,'notes'=>$content]);
        }
        return $data;
    }
    //批量冻结
    public function freezeAll(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData')??'';
        //冻结条件只局限于 分配完成sostatus=40  创建订单sostatus=00  拣货完成sostatus=60  播种完成sostatus=61
        $sostatus=['40','00','60','61'];
        $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
        if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可冻结订单"];
        foreach ($orders as $order){
            $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
            if ($waveno && $waveno!='*'){
                OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
                $this->log(__METHOD__,'批量冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            }
            $is_freeze=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
            $this->log(__METHOD__,'批量冻结修改'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            if (!$is_freeze)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
        }
        return ['success'=>true];
    }
    //批量取消分配
    public function deAllocationAll(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $checkData=$request->input('checkData')??'';
        //取消分配条件只局限于 分配完成sostatus=40 和 部分分配sostatus=30
        $sostatus=['30','40'];
        $orders=OracleDOCOrderHeader::select('OrderNo','SoStatus')->whereIn('orderno',$checkData)->whereIn('SoStatus',$sostatus)->get();
        if(count($checkData)!=count($orders))return ['success'=>false,'fail_info'=>"勾选订单有不可取消分配订单"];
        foreach ($orders as $order){
            $is_deAllocation=$this->isDeAllocation($order->orderno);
            $waveno=OracleDOCOrderHeader::where('orderno',$order->orderno)->value('waveno');
            if ($waveno && $waveno!='*'){
                OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$order->orderno)->delete();
                $this->log(__METHOD__,'批量取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            }
            $deAllocation=OracleDOCOrderHeader::where('orderno',$order->orderno)->update(['sostatus'=>'00','waveno'=>'*']);
            $this->log(__METHOD__,'批量取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
            if (!$is_deAllocation||!$deAllocation)return ['success'=>false,'fail_info'=>"数据 {$order['orderno']} 更新失败"];
        }
        return ['success'=>true];
    }
    //冻结
    public function freeze(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->input('orderno');
        $waveno=$request->input('waveno');
        if ($waveno && $waveno!='*'){
            OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
            $this->log(__METHOD__,'冻结删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        }
        OracleDOCOrderHeader::where('orderno',$orderno)->update(['releasestatus'=>'H','waveno'=>'*']);
        $this->log(__METHOD__,'冻结'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        return ['success'=>true];
    }
    public function thaw(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno = $request->orderno;
        if (!is_array($orderno)) {
            $orderno = [$orderno];
        }
        OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->update(['releasestatus'=>'N']);
        $this->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        return ['success'=>true];
    }

    //重置快递获取标记
    public function resetLogisticsGetMark(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->orderno;
        OracleDOCOrderHeader::query()->whereIn('orderno',$orderno)->where('edisendflag2','W')->update(['edisendflag2'=>'N']);
        $this->log(__METHOD__,'解冻'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
        return ['success'=>true];
    }

    //取消分配
    public function deAllocation(Request $request){
        if(!Gate::allows('订单管理-编辑')){ return redirect(url('/'));  }
        $orderno=$request->input('orderno');
        $waveno=$request->input('waveno');
        if ($waveno && $waveno!='*'){
            OracleDOCWaveDetails::where('waveno',$waveno)->where('orderno',$orderno)->delete();
            $this->log(__METHOD__,'取消分配删除波次号'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        }
        OracleDOCOrderHeader::where('orderno',$orderno)->update(['sostatus'=>'00','waveno'=>'*']);
        $this->log(__METHOD__,'取消分配'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        $is_deAllocation=$this->isDeAllocation($orderno);
        if($is_deAllocation) return ['success'=>true];

    }
    //调用sp取消选中订单的分配
    public function isDeAllocation($orderno){
        $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_Warehouse='';
        $IN_Process_Action_C='' ;
        $IN_Process_By_C='By OrderNO';
        $IN_WaveNO_C='';
        $IN_OrderNO_C=$orderno;
        $IN_OrderLineNO_C='';
        $IN_AllocationDetailsID='';
        $IN_Language='';
        $IN_UserID='';
        $OUT_Return_Code='';
        $sql_sp="begin SPSO_DEALLOCATION_PROCESS(:IN_Warehouse,: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_Process_Action_C);
        oci_bind_by_name($stmt,':IN_Process_Action_C',$IN_Warehouse);
        oci_bind_by_name($stmt,':IN_Process_By_C',$IN_Process_By_C);
        oci_bind_by_name($stmt,':IN_WaveNO_C',$IN_WaveNO_C);
        oci_bind_by_name($stmt,':IN_OrderNO_C',$IN_OrderNO_C);
        oci_bind_by_name($stmt,':IN_OrderLineNO_C',$IN_OrderLineNO_C);
        oci_bind_by_name($stmt,':IN_AllocationDetailsID',$IN_AllocationDetailsID);
        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);
        $this->log(__METHOD__,'调用sp根据订单取消分配'.__FUNCTION__,json_encode($orderno),Auth::user()['id']);
        return oci_execute($stmt);
    }

}