<?php

namespace App\Service;

use App\Model\ApplyOrder;
use App\Model\ApplyOrderForYy;
use App\Model\Box;
use App\Model\BoxDetail;
use App\Model\CommandList;
use App\Model\Dispatch;
use App\Model\DispatchEmpSub;
use App\Model\DispatchSub;
use App\Model\Orders;
use App\Model\OrdersProduct;
use App\Model\OrdersProductBom;
use App\Model\OrdersProductMain;
use App\Model\OrdersProductProcess;
use App\Model\Process;
use App\Model\SaleOrdersProduct;
use App\Service\Box\BoxService;
use Illuminate\Support\Facades\DB;

class DeleteOrderService extends Service
{
    public function del($data){
        if($this->isEmpty($data,'id')) return [false,'数据必须选择！'];
        if($this->isEmpty($data,'type')) return [false,'单据类型不能为空！'];

        switch ($data['type']){
            case 1:
                list($status,$msg) = $this->delSaleOrdersProduct($data['id']);
                break;
            case 2:
                list($status,$msg) = $this->delOrdersProduct($data['id']);
                break;
            case 3:
                list($status,$msg) = $this->delDispatch($data['id']);
                break;
            case 4:
//                list($status,$msg) = $this->delFinished($data['id']);
                list($status,$msg) = [false,'删除失败！'];
            case 5:
                list($status,$msg) = $this->delBox($data['id']);
                break;
            default:
                list($status,$msg) = [false,'删除失败！'];
        }

        return [$status,$msg];
    }

    //销售订单删除
    public function delSaleOrdersProduct($id){
        $bool = OrdersProduct::where('del_time',0)
            ->whereIn('sale_orders_product_id',$id)
            ->exists();
        if($bool) return [false,'销售订单已生成生产订单，删除失败！'];

        try {
            DB::beginTransaction();

            //销售订单
            SaleOrdersProduct::whereIn('id',$id)->update([
                'del_time' => time()
            ]);

            //内部订单号与销售订单关联表
            $subquery = DB::table('sale_orders_product')
                ->select('order_no')
                ->whereIn('id',$id);
            $order_no = DB::table('sale_orders_product')
                ->select('sale_orders_product.order_no','sale_orders_product.del_time')
                ->joinSub($subquery, 'sub', function ($join) {
                    $join->on('sale_orders_product.order_no', '=', 'sub.order_no');
                })->get()->toArray();
            $update_order = [];
            if(! empty($order_no)){
                $tmp = [];
                foreach ($order_no as $value){
                    $value = (array)$value;
                    if($value['del_time'] == 0){
                        $tmp[] = $value['order_no'];
                    }else{
                        $update_order[] = $value['order_no'];
                    }
                }
                $tmp = array_unique($tmp);
                $update_order = array_unique($update_order);
                $update_order = array_diff($update_order, $tmp);
            }
            if(! empty($update_order)) Orders::whereIn('order_no',$update_order)->update(['del_time' => time()]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    //生产订单删除
    public function delOrdersProduct($id){
        $bool = DispatchSub::where('del_time',0)
            ->whereIn('order_product_id',$id)
            ->exists();
        if($bool) return [false,'生产订单已生成派工单，删除失败！'];

        $bool = OrdersProduct::whereIn('id', $id)
            ->where('status','>',OrdersProduct::status_zero)
            ->exists();
        if($bool) return [false,'生产订单已审核，删除失败！'];

        try {
            DB::beginTransaction();

            //生产订单
            OrdersProduct::whereIn('id',$id)->update([
                'del_time' => time()
            ]);

            //生产订单主表
            $subquery = DB::table('orders_product')
                ->select('production_no')
                ->whereIn('id',$id);
            $order_no = DB::table('orders_product')
                ->select('orders_product.production_no','orders_product.del_time')
                ->joinSub($subquery, 'sub', function ($join) {
                    $join->on('orders_product.production_no', '=', 'sub.production_no');
                })->get()->toArray();
            $update_order = [];
            if(! empty($order_no)){
                $tmp = [];
                foreach ($order_no as $value){
                    $value = (array)$value;
                    if($value['del_time'] == 0){
                        $tmp[] = $value['production_no'];
                    }else{
                        $update_order[] = $value['production_no'];
                    }
                }
                $tmp = array_unique($tmp);
                $update_order = array_unique($update_order);
                $update_order = array_diff($update_order, $tmp);
            }
            if(! empty($update_order)) OrdersProductMain::whereIn('production_no',$update_order)->update(['del_time' => time()]);

            //生产订单子表
            $message = OrdersProduct::whereIn('id',$id)->select('out_order_no_time','sale_orders_product_id')->get()->toArray();
            $time = array_unique(array_column($message,'out_order_no_time'));
            $arr_time = [];
            if(! empty($time)){
                foreach ($time as $value){
                    $time_tmp = date("Ymd", $value);
                    if(! in_array($time_tmp,$arr_time)) $arr_time[] = $time_tmp;
                }
            }
            if(! empty($arr_time)){
                foreach ($arr_time as $value){
                    $modelBom = new OrdersProductBom(['channel'=> $value]);
                    $modelBom->whereIn('order_product_id',$id)->update(['del_time' => time()]);

                    $modelProcess = new OrdersProductProcess(['channel' => $value]);
                    $modelProcess->whereIn('order_product_id',$id)->update(['del_time' => time()]);
                }
            }

            //销售订单里的已生产数量
            (new ProductionOrderService())->writeProductionQuantityDEL(array_column($message,'sale_orders_product_id'));

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    //派工单删除
    public function delDispatch($id){
        $bool = DispatchSub::whereIn('id', $id)
            ->where('status','>',DispatchSub::status_zero)
            ->exists();
        if($bool) return [false,'工序派工单已审核，删除失败！'];

        //校验工序派工单是否完工
        $dispatch = DispatchSub::where('del_time',0)
            ->whereIn('id',$id)
            ->select('id','dispatch_no','process_id','order_product_id','crt_time','finished_num')
            ->get()
            ->toArray();
        $process_map = Process::whereIn('id',array_unique(array_column($dispatch,'process_id')))->pluck('title','id')->toArray();
        $search = "";
        foreach ($dispatch as $value){
            $tmp_process = $process_map[$value['process_id']] ?? "";
            if($value['finished_num'] > 0) return [false,'派工单号:' . $value['dispatch_no']. '的工序:' . $tmp_process .'已存在完工操作，删除失败！'];
            $search .= "(order_product_id = {$value['order_product_id']} and crt_time = {$value['crt_time']}) OR ";
        }

        //校验同一批工序派工单是否完工
        $search = rtrim($search,'OR ');
        $search = "($search)";
        $dispatch = DispatchSub::where('del_time',0)
            ->whereRaw($search)
            ->select('id','dispatch_no','process_id','order_product_id','crt_time','finished_num','out_order_no_time','sale_orders_product_id','dispatch_no','dispatch_quantity','order_product_id')
            ->get()
            ->toArray();
        $process_map = Process::whereIn('id',array_unique(array_column($dispatch,'process_id')))->pluck('title','id')->toArray();
        foreach ($dispatch as $value){
            $tmp_process = $process_map[$value['process_id']] ?? "";
            if($value['finished_num'] > 0) return [false,'派工单号:' . $value['dispatch_no']. '的工序:' . $tmp_process .'已存在完工操作，删除失败！'];
        }

        $new_del_id = array_column($dispatch,'id');
        try {
            DB::beginTransaction();

            //工序派工单
            DispatchSub::whereIn('id',$new_del_id)->update([
                'del_time' => time()
            ]);

            //工序派工单主表
            $subquery = DB::table('dispatch_sub')
                ->select('dispatch_no')
                ->whereIn('id',$new_del_id);
            $order_no = DB::table('dispatch_sub')
                ->select('dispatch_sub.dispatch_no','dispatch_sub.del_time')
                ->joinSub($subquery, 'sub', function ($join) {
                    $join->on('dispatch_sub.dispatch_no', '=', 'sub.dispatch_no');
                })->get()->toArray();
            $update_order = [];
            if(! empty($order_no)){
                $tmp = [];
                foreach ($order_no as $value){
                    $value = (array)$value;
                    if($value['del_time'] == 0){
                        $tmp[] = $value['dispatch_no'];
                    }else{
                        $update_order[] = $value['dispatch_no'];
                    }
                }
                $tmp = array_unique($tmp);
                $update_order = array_unique($update_order);
                $update_order = array_diff($update_order, $tmp);
            }
            if(! empty($update_order)) Dispatch::whereIn('dispatch_no',$update_order)->update(['del_time' => time()]);

            //工序表
            $message = $dispatch;
            if(! empty($message)){
                foreach ($message as $value){
                    $tmp_time = date('Ymd',$value['out_order_no_time']);
                    $modelProcess = new OrdersProductProcess(['channel' => $tmp_time]);
                    $modelProcess->where('order_product_id',$value['order_product_id'])
                        ->where('process_id',$value['process_id'])
                        ->where('dispatch_no',$value['dispatch_no'])
                        ->take($value['dispatch_quantity'])
                        ->update([
                            'dispatch_no' => '',
                            'status' => 0
                        ]);
                }
            }

            //已派工数量
            (new DispatchService())->writeDispatchQuantityDEL(array_column($message,'order_product_id'));

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    //完工单删除
    public function delFinished($id){
        $result = DispatchSub::whereIn('id',$id)
            ->select('id','finished_num','dispatch_quantity','out_order_no_time','process_id','dispatch_no','order_product_id','sale_orders_product_id','order_no','product_no','product_title','price')
            ->orderBy('id','desc')
            ->get()->toArray();

        try {
            DB::beginTransaction();

            foreach ($result as $key => $value){
                SaleOrdersProduct::where('id',$value['sale_orders_product_id'])->decrement('finished_num', $value['finished_num']);

                $process_model = new OrdersProductProcess(['channel' => date("Ymd",$value['out_order_no_time'])]);

                $process_model->where('order_product_id',$value['order_product_id'])
                    ->where('process_id',$value['process_id'])
                    ->where('dispatch_no',$value['dispatch_no'])
                    ->take($value['finished_num'])
                    ->update([
                        'finished_time' => 0,
                        'status' => 1,
                        'finished_id' => 0,
                        'team_id' => 0,
                        'equipment_id' => 0
                    ]);
//                $process_model->where('order_product_id',$value['order_product_id'])
//                    ->where('process_id',$value['process_id'])
//                    ->where('dispatch_no',$value['dispatch_no'])
//                    ->where('status',4)
//                    ->update([
//                        'del_time' => time()
//                    ]);

                $result[$key]['quantity'] = $value['finished_num'];
            }

            DispatchSub::whereIn('id',$id)->update([
                'finished_num' => 0,
                'waste_num' => 0
            ]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    //包装单删除
    public function delBox($id){
        $box = Box::whereIn('id', $id)->get()->toArray();

        try {
            DB::beginTransaction();

            $order_no = [];
            foreach ($box as $value){
                if($value['status'] > Box::status_zero) return [false, '包装单已审核,删除失败'];
                $order_no[] = $value['order_no'];
            }
            $service = new BoxService();
            list($status, $msg) = $service->delBoxDetail(['order_nos' => $order_no]);
            if(! $status) return [false, $msg];

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function checkOrders($data,$user){
        if($this->isEmpty($data,'id')) return [false,'数据必须选择！'];
        if($this->isEmpty($data,'type')) return [false,'单据类型不能为空！'];
        if($this->isEmpty($data,'check')) return [false,'审核操作数值不能为空！'];

        switch ($data['type']){
            case 1:
                list($status,$msg) = $this->checkOrdersProduct($data);
                break;
            case 2:
                list($status,$msg) = $this->checkDispatch($data);
                break;
            case 3:
                list($status,$msg) = $this->checkFinish($data);
                break;
            case 4:
                list($status,$msg) = $this->checkBox($data);
                break;
            case 5:
                list($status,$msg) = $this->checkSP($data,$user);
                break;
            default:
                list($status,$msg) = [false,'审核失败'];
        }

        return [$status,$msg];
    }

    public function checkOrdersProduct($data){
        $order = OrdersProduct::where('del_time',0)
            ->whereIn('id',$data['id'])
            ->get()->toArray();

        $check = $data['check'];// 1 通过  2 弃审
        if($check == 1){
            $status = 1;
        }else{
            $status = 0;
        }

        try {
            DB::beginTransaction();

            foreach ($order as $value){
                if($check == 1 && $value['status'] > OrdersProduct::status_zero) return [false, '生产订单已审核，操作失败'];
                if($check == 2 && $value['status'] < OrdersProduct::status_one) return [false, '生产订单未审核，操作失败'];
            }

            //生产订单
            OrdersProduct::whereIn('id',$data['id'])->update([
                'status' => $status
            ]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function checkDispatch($data){
        $order = DispatchSub::where('del_time',0)
            ->whereIn('id',$data['id'])
            ->get()->toArray();

        $check = $data['check'];// 1 通过  2 弃审
        if($check == 1){
            $status = 1;
        }else{
            $status = 0;
        }

        try {
            DB::beginTransaction();

            foreach ($order as $value){
                if($check == 1 && $value['status'] > DispatchSub::status_zero) return [false, '派工单已审核，操作失败'];
                if($check == 2 && $value['status'] < DispatchSub::status_one) return [false, '派工单未审核，操作失败'];
            }

            DispatchSub::whereIn('id',$data['id'])->update([
                'status' => $status
            ]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function checkFinish($data){
        $order = DispatchSub::where('del_time',0)
            ->whereIn('id',$data['id'])
            ->get()->toArray();

        $check = $data['check'];// 1 通过  2 弃审
        if($check == 1){
            $status = 1;
        }else{
            $status = 0;
        }

        try {
            DB::beginTransaction();

            foreach ($order as $value){
                if($check == 1 && $value['wg_status'] > DispatchSub::status_zero) return [false, '完工单已审核，操作失败'];
                if($check == 2 && $value['wg_status'] < DispatchSub::status_one) return [false, '完工单未审核，操作失败'];
            }

            DispatchSub::whereIn('id',$data['id'])->update([
                'wg_status' => $status
            ]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function checkBox($data){
        $order = Box::where('del_time',0)
            ->whereIn('id',$data['id'])
            ->get()->toArray();

        $check = $data['check'];// 1 通过  2 弃审
        if($check == 1){
            $status = 1;
        }else{
            $status = 0;
        }

        try {
            DB::beginTransaction();

            foreach ($order as $value){
                if($check == 1 && $value['status'] > Box::status_zero) return [false, '包装单已审核，操作失败'];
                if($check == 2 && $value['status'] < Box::status_one) return [false, '包装单未审核，操作失败'];
            }

            Box::whereIn('id',$data['id'])->update([
                'status' => $status
            ]);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function checkSP($data,$user){
        $order = ApplyOrder::where('del_time',0)
            ->whereIn('id',$data['id'])
            ->get()->toArray();

        $check = $data['check'];// 1 通过  2 弃审
        if($check == 1){
            $status = 1;
        }else{
            $status = 0;
        }

        try {
            DB::beginTransaction();

            foreach ($order as $value){
                if($check == 1 && $value['status'] > ApplyOrder::state_zero) return [false, '申请单已审核，操作失败'];
                if($check == 2 && $value['status'] < ApplyOrder::state_one) return [false, '申请单未审核，操作失败'];
            }

            ApplyOrder::whereIn('id',$data['id'])->update([
                'status' => $status
            ]);

            DB::commit();

            if($check == 1){
                $result = ApplyOrderForYy::whereIn('apply_order_id', $data['id'])->get()->toArray();

                if(! empty($result)){
                    $service = new FinishedOrderService();
                    foreach ($result as $value){
                        list($status, $msg) = $service->insertYy($value,$user);
                    }
                }
            }
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }
}