<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\Construction;
use App\Model\ConstructionInfo;
use App\Model\ConstructionProductInfo;
use App\Model\Customer;
use App\Model\Depart;
use App\Model\Employee;
use App\Model\SalesOrder;
use App\Model\SalesOrderProductInfo;
use App\Model\SeeRange;
use App\Model\Storehouse;
use Illuminate\Support\Facades\DB;

/**
 * 施工订单
 */
class ConstructionService extends Service
{
    /**
     * 施工订单编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function constructionEdit($data,$user){
        list($status,$msg) = $this->constructionRule($data, $user, false);
        if(!$status) return [$status,$msg];

        $params = $this->getDataFile($data);
        (new OperationLogService())->setOperationList($params,$user,2);

        try {
            DB::beginTransaction();

            $model = Construction::where('id', $data['id'])->first();
            $model->model_type = $data['model_type'];
            $model->order_number = $data['order_number'];
            $model->title = $data['title'] ?? '';
            $model->customer_id = $data['customer_id'] ?? 0;
            $model->customer_contact_id = $data['customer_contact_id'] ?? 0;
            $model->install_method = $data['install_method'] ?? 0;
            $model->install_position = $data['install_position'] ?? 0;
            $model->sales_order_id = $data['sales_order_id'] ?? 0;
            $model->construction_fee = $data['construction_fee'] ?? 0;
            $model->service_price = $data['service_price'] ?? 0;
            $model->construction_time = $data['construction_time'] ?? 0;
            $model->handover_time = $data['handover_time'] ?? 0;
            $model->urgency = $data['urgency'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->address1 = ! empty($data['address1']) ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->introduction = $data['introduction'] ?? '';
            $model->storehouse_id = $data['storehouse_id'] ?? 0;
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->save();
            $time = time();

            ConstructionInfo::where('del_time',0)
                ->where('construction_id',$data['id'])
                ->update(['del_time' => $time]);
            ConstructionProductInfo::where('del_time',0)
                ->where('construction_id',$data['id'])
                ->update(['del_time' => $time]);

            if(! empty($data['construction_contact'])){
                $insert = [];
                foreach ($data['construction_contact'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'contact_type' => $value['id'],
                        'contact_info' => $value['info'],
                        'type' => ConstructionInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                ConstructionInfo::insert($insert);
            }

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'employee_id' => $value,
                        'type' => ConstructionInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                ConstructionInfo::insert($insert);
            }

            if(! empty($data['product'])){
                $insert = [];
                foreach ($data['product'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'cost' => $value['cost'] ?? 0,
                        'retail_price' => $value['retail_price'] ?? 0,
                        'mark' => $value['mark'] ?? '',
                        'crt_time' => $time,
                        'storehouse_id' => $data['storehouse_id'] ?? 0,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                        'final_amount' => $value['final_amount'] ?? 0,
                    ];
                }
                ConstructionProductInfo::insert($insert);

                //锁定库存
                ProductInventoryService::changeLockNumber($user,$msg[0],$msg[1]);
            }

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

        return [true,''];
    }

    /**
     * 施工订单新增
     * @param $data
     * @param $user
     * @return array
     */
    public function constructionAdd($data,$user){
        list($status,$msg) = $this->constructionRule($data,$user);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = new Construction();
            $model->model_type = $data['model_type'];
            $model->order_number = $data['order_number'];
            $model->title = $data['title'] ?? '';
            $model->customer_id = $data['customer_id'] ?? 0;
            $model->customer_contact_id = $data['customer_contact_id'] ?? 0;
            $model->install_method = $data['install_method'] ?? 0;
            $model->install_position = $data['install_position'] ?? 0;
            $model->sales_order_id = $data['sales_order_id'] ?? 0;
            $model->construction_fee = $data['construction_fee'] ?? 0;
            $model->service_price = $data['service_price'] ?? 0;
            $model->construction_time = $data['construction_time'] ?? 0;
            $model->handover_time = $data['handover_time'] ?? 0;
            $model->urgency = $data['urgency'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->address1 = ! empty($data['address1']) ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->introduction = $data['introduction'] ?? '';
            $model->crt_id = $user['id'];
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->storehouse_id = $data['storehouse_id'] ?? 0;
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->save();
            $time = time();

            if(! empty($data['construction_contact'])){
                $insert = [];
                foreach ($data['construction_contact'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'contact_type' => $value['id'],
                        'contact_info' => $value['info'],
                        'type' => ConstructionInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                ConstructionInfo::insert($insert);
            }

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'employee_id' => $value,
                        'type' => ConstructionInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                ConstructionInfo::insert($insert);
            }

            if(! empty($data['product'])){
                $insert = [];
                foreach ($data['product'] as $value){
                    $insert[] = [
                        'construction_id' => $model->id,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'cost' => $value['cost'] ?? 0,
                        'retail_price' => $value['retail_price'] ?? 0,
                        'mark' => $value['mark'] ?? '',
                        'crt_time' => $time,
                        'storehouse_id' => $data['storehouse_id'] ?? 0,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                        'final_amount' => $value['final_amount'] ?? 0,
                    ];
                }
                ConstructionProductInfo::insert($insert);

                //锁定库存
                ProductInventoryService::changeLockNumber($user,$msg[0],[]);
            }

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }
        (new OperationLogService())->setOperationList($data,$user);

        return [true,''];
    }

    /**
     * 施工订单删除
     * @param $data
     * @return array
     */
    public function constructionDel($data,$user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $construction = Construction::where('del_time',0)->where('id',$data['id'])->first();
        if(empty($construction)) return [false,'施工单不存在或已被删除'];
        $construction = $construction->toArray();
        if($construction['state'] > Construction::STATE_ZERO) return [false,'请确认施工单状态,操作失败'];

        $product_save = $this->getSaveDetail($data['id']);
        try {
            DB::beginTransaction();

            Construction::where('id',$data['id'])->update([
                'del_time'=> time()
            ]);
            ConstructionInfo::where('del_time',0)
                ->where('construction_id',$data['id'])
                ->update(['del_time' => time()]);
            ConstructionProductInfo::where('del_time',0)
                ->where('construction_id',$data['id'])
                ->update(['del_time' => time()]);
            (new RangeService())->RangeDelete($data['id'],SeeRange::type_two);

            //锁定库存释放
            ProductInventoryService::changeLockNumber($user,[],$product_save);

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

        return [true,''];
    }

    /**
     * 施工订单详情
     * @param $data
     * @return array
     */
    public function detail($data){
        if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据！'];

        if(! empty($data['id'])){
            $construction = Construction::where('del_time',0)
                ->where('id',$data['id'])
                ->first();
        }else{
            $construction = Construction::where('del_time',0)
                ->where('order_number',$data['order_number'])
                ->first();
            $data['id'] = empty($construction->id) ? 0 : $construction->id;
        }
        if(empty($construction)) return [false,'施工订单不存在或已被删除'];
        $construction = $construction->toArray();
        $address = '';
        if(! empty($construction['address1'])) {
            $tmp = json_decode($construction['address1'],true);
            $construction['address1'] = $tmp;
            $tmp = implode(' ',$tmp);
            $tmp .= ' ' . $construction['address2'];
            $address = $tmp;
        }
        $construction['address'] = $address;
        $start_time = $construction['start_time'] ? date("Y-m-d H:i",$construction['start_time']) : '';
        $end_time = $construction['end_time'] ? date("Y-m-d H:i",$construction['end_time']) : '';
        $construction['construction_period'] = $start_time . '——' . $end_time;
        $sales = SalesOrder::where('id',$construction['sales_order_id'])->value('order_number');
        $construction['sales_order_number'] = $sales;
        $customer_title = Customer::where('id',$construction['customer_id'])->value('title');
        $construction['customer_title'] = $customer_title ?? "";
        $construction['storehouse_title'] = Storehouse::where('id',$construction['storehouse_id'])->value('title');
        $emp_title = Employee::where('id',$construction['customer_contact_id'])->value('emp_name');
        $construction['customer_contact_title'] = $emp_title;
        $construction['employee_one'] = $construction['construction_contact'] = $construction['product'] = [];
        $array = [
            $construction['install_method'],
            $construction['install_position'],
            $construction['urgency'],
        ];
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $construction = [$construction];
        foreach ($construction as $key => $value){
            $construction[$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
            $construction[$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
            $construction[$key]['urgency_title'] = $basic_map[$value['urgency']] ?? '';
        }
        $construction = $construction[0];

        $construction_info = ConstructionInfo::where('del_time',0)
            ->where('construction_id',$construction['id'])
            ->select('id','construction_id','employee_id','type','contact_type','contact_info')
            ->get()->toArray();
        $emp_map = Employee::whereIn('id',array_unique(array_merge_recursive([$construction['crt_id']],array_column($construction_info,'employee_id'))))
            ->pluck('emp_name','id')
            ->toArray();
        $basic_map2 = BasicType::whereIn('id',array_unique(array_column($construction_info,'contact_type')))
            ->pluck('title','id')
            ->toArray();
        foreach ($construction_info as $value){
            if($value['type'] == ConstructionInfo::type_one){
                $tmp = [
                    'id' => $value['contact_type'],
                    'title' => $basic_map2[$value['contact_type']] ?? '',
                    'info' => $value['contact_info']
                ];
                $construction['construction_contact'][] = $tmp;
            }elseif ($value['type'] == ConstructionInfo::type_two){
                $tmp = [
                    'id' => $value['employee_id'],
                    'name' => $emp_map[$value['employee_id']] ?? '',
                ];
                $construction['employee_one'][] = $tmp;
            }
        }

        $p_info = ConstructionProductInfo::where('del_time',0)
            ->where('construction_id',$construction['id'])
            ->get()->toArray();
        $basic_price = BasicType::whereIn('id',array_unique(array_column($p_info,'basic_type_id')))->pluck('title','id')->toArray();
        $map = (new ProductService())->getProductDetail(array_column($p_info,'product_id'));
        foreach ($p_info as $value){
            $tmp = $map[$value['product_id']] ?? [];
            $value['title'] = $tmp['title'] ?? "";
            $value['code'] = $tmp['code'] ?? "";
            $value['size'] = $tmp['size'] ?? "";
            $value['unit'] = $tmp['unit'] ?? "";
            $value['bar_code'] = $tmp['bar_code'] ?? "";
            $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
            $construction['product'][] = $value;
        }
        $construction['crt_name'] = $emp_map[$construction['crt_id']] ?? '';
        $construction['crt_time'] = $construction['crt_time'] ? date("Y-m-d H:i:s",$construction['crt_time']): '';

        //可见范围
        $return = (new RangeService())->RangeDetail($data['id'],SeeRange::type_two);
        $construction['depart'] = $return[0] ?? [];
        $construction['employee'] = $return[1] ?? [];

        return [true, $construction];
    }

    /**
     * 施工订单列表
     * @param $data
     * @param $user
     * @return array
     */
    public function constructionList($data,$user){
        $model = Construction::Clear($user,$data);
        $model = $model->where('del_time',0)
            ->select('title','id','model_type','order_number','customer_id','customer_contact_id','install_method','install_position','sales_order_id','construction_fee','construction_time','handover_time','urgency','crt_id','crt_time','mark','state','address1','address2','introduction','service_price','storehouse_id','start_time','end_time')
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['model_type'])) $model->where('model_type',$data['model_type']);
        if(! empty($data['time_type'])) {
            if($data['time_type'] == 1) {
                $start = strtotime('today');
                $end = strtotime('tomorrow') - 1;
            }elseif ($data['time_type'] == 2){
                $start = strtotime('this week',strtotime('today'));
                $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
            }
            if(! empty($start) && ! empty($end)) {
                $model->where('crt_time','>=',$start);
                $model->where('crt_time','<=',$end);
            }
        }
        if(! empty($data['construction_period'][0]) && ! empty($data['construction_period'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['construction_period']);
            $model->where('start_time','>=',$return[0]);
            $model->where('end_time','<=',$return[1]);
        }
        if(! empty($data['sale_order'])){
            $model2 = SalesOrder::Clear($user,$data);
            $sale = $model2->where('del_time',0)
                ->where('order_number', 'LIKE', '%'.$data['sale_order'].'%')
                ->select('id')
                ->get()->toArray();
            $model->whereIn('sales_order_id',array_unique(array_column($sale,'id')));
        }

        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list);

        return [true, $list];
    }

    /**
     * 参数规则
     * @param $data
     * @param $user
     * @param $is_add
     * @return array
     */
    public function constructionRule(&$data, $user, $is_add = true){
        if(empty($data['model_type'])) return [false,'工单模板类型不能为空'];
        if(! in_array($data['model_type'],Construction::$model_type)) return [false,'工单模板类型错误'];
        if(empty($data['order_number'])) return [false,'工单编号不能为空'];
        if(empty($data['storehouse_id'])) return [false,'请选择仓库'];
        if(empty($data['sales_order_id'])) return [false,'请选择合同'];
        $sale = SalesOrder::where('del_time',0)->where('id',$data['sales_order_id'])->first();
        if(empty($sale)) return [false,'合同不存在或已被删除'];
        if($sale['state'] < SalesOrder::State_two) return [false,'合同未派单，不允许新建施工单'];
        $sale = $sale->toArray();
        if(empty($data['product'])) return [false,'请选择产品'];
        if(empty($data['construction_period'][0]) || empty($data['construction_period'][1])) return [false,'请填写施工时间范围'];
        $data['start_time'] = $this->changeDateToDateMin($data['construction_period'][0]);
        $data['end_time'] = $this->changeDateToDateMin($data['construction_period'][1]);

        if(! empty($data['construction_fee'])){
            $res = $this->checkNumber($data['construction_fee']);
            if(! $res) return [false,'施工费用请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['service_price'])){
            $res = $this->checkNumber($data['service_price']);
            if(! $res) return [false,'服务价格请输入不超过两位小数并且大于0的数值'];
            if(! $res) return [false,'服务价格请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['construction_time'])) $data['construction_time'] = $this->changeDateToDateMin($data['construction_time']);
        if(! empty($data['handover_time'])) $data['handover_time'] = $this->changeDateToDateMin($data['handover_time']);

        if($data['model_type'] == Construction::Model_type_one){
//            if(empty($data['install_method'])) return [false,'安装方式不能为空'];
//            if(empty($data['install_position'])) return [false,'安装地点不能为空'];
        }else{
//            if(empty($data['construction_contact'])) return [false,'联系方式不能为空'];
//            if(empty($data['address1']) || empty($data['address2'])) return [false,'地址不能为空'];
        }
        //所属部门 以及  顶级部门
        if(empty($data['depart_id'])) {
            $data['depart_id'] = $this->getDepart($user);
            $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
        }

        $product_submit = $product_id = [];
        foreach ($data['product'] as $value){
            if(empty($value['number'])) return [false,'产品数量不能为空'];
            $res = $this->checkNumber($value['number']);
            if(! $res) return [false,'请输入正确的产品数量'];

            $key = $value['product_id'] . ',' .$data['storehouse_id'];
            if(isset($product_submit[$key])){
                $product_submit[$key] += $value['number'];
            }else{
                $product_submit[$key] = $value['number'];
            }
            $product_id[] = $value['product_id'];
        }

        //剩余能施工
        $id = $data['id'] ?? 0;
        $s_product = $this->getSaveReturnCompareMessage($id, $data['sales_order_id']);

        //比较
        foreach ($product_submit as $pro => $number){
            $tmp = explode(',',$pro);
            $p = $tmp[0];
            if(! isset($s_product[$p])) return [false,'施工产品错误,合同中不存在该产品'];
            $s_number = $s_product[$p];

            if($number > $s_number) return [false,'施工产品数量不能超过合同产品数据'];
        }

        $id = $data['id'] ?? 0;
        $product_save = $this->getSaveDetail($id);

        //是否校验库存
        ProductInventoryService::is_check($user,$data);

        list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit, $product_save);
        if(! $status) return [false, $msg];

        $start_time = date("Y-m-d H:i",$data['start_time']);
        $end_time = date("Y-m-d H:i",$data['end_time']);
        if($is_add){
            $bool = Construction::where('del_time',0)
                ->where('order_number',$data['order_number'])
                ->exists();
            if($bool) return [false,'工单编号已存在，请重新获取'];
            $bool = Construction::where('del_time',0)
                ->where('sales_order_id',$data['sales_order_id'])
                ->where('start_time', '<=', $data['end_time'])
                ->where('end_time', '>=', $data['start_time'])
                ->exists();
            if($bool)  return [false,'合同：' . $sale['order_number'] . '在' . $start_time . '——' . $end_time . '已下施工单'];
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = Construction::where('del_time',0)
                ->where('id','<>',$data['id'])
                ->where('sales_order_id',$data['sales_order_id'])
                ->where('start_time', '<=', $data['end_time'])
                ->where('end_time', '>=', $data['start_time'])
                ->exists();
            if($bool)  return [false,'合同：' . $sale['order_number'] . '在' . $start_time . '——' . $end_time . '已下施工单'];
        }

        return [true, [$product_submit, $product_save]];
    }

    /**
     * 数据拼接
     * @param $data
     * @return array
     */
    public function fillData($data){
        if(empty($data['data'])) return $data;

        $array = array_unique(array_merge_recursive(array_column($data['data'],'install_method'),array_column($data['data'],'urgency'),array_column($data['data'],'install_position')));
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $emp = Employee::whereIn('id',array_unique(array_merge_recursive(array_column($data['data'],'crt_id'),array_column($data['data'],'customer_contact_id'))))
            ->pluck('emp_name','id')
            ->toArray();
        $customer = Customer::whereIn('id',array_unique(array_column($data['data'],'customer_id')))
            ->pluck('title','id')
            ->toArray();
        $sales = SalesOrder::whereIn('id',array_unique(array_column($data['data'],'sales_order_id')))->pluck('order_number','id')->toArray();
        $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
            ->pluck('title','id')
            ->toArray();

        //分派的总社或分社
        $dispatch = $this->getDispatchData($data['data']);

        foreach ($data['data'] as $key => $value){
            $address = '';
            if(! empty($value['address1'])) {
                $tmp = json_decode($value['address1'],true);
                $tmp = implode(' ',$tmp);
                $tmp .= ' ' . $value['address2'];
                $address = $tmp;
            }
            $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
            $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
            $data['data'][$key]['construction_period'] = $start_time . '——' . $end_time;
            $data['data'][$key]['address'] = $address;
            $data['data'][$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
            $data['data'][$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
            $data['data'][$key]['urgency_title'] = $basic_map[$value['urgency']] ?? '';
            $data['data'][$key]['customer_title'] = $customer[$value['customer_id']] ?? '';
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['customer_contact_title'] = $emp[$value['customer_contact_id']] ?? '';
            $data['data'][$key]['state_title'] = Construction::$name[$value['state']] ?? '';
            $data['data'][$key]['sales_order_number'] = $sales[$value['sales_order_id']] ?? '';
            $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
            $data['data'][$key]['dispatch_company'] = $dispatch[$value['sales_order_id']] ?? '';
        }

        return $data;
    }

    public function getDispatchData($data){
        $search_id = [];
        foreach ($data as $value){
            $search_id[] = $value['sales_order_id'];
        }
        if(empty($search_id)) return [];

        $see = SeeRange::where('del_time',0)
            ->whereIn('data_id',$search_id)
            ->where('data_type',SeeRange::type_seven)
            ->where('type',SeeRange::data_three)
            ->select('data_id','param_id')
            ->get()->toArray();
        $map = Depart::whereIn('id',array_unique(array_column($see,'param_id')))
            ->pluck('title','id')
            ->toArray();
        $see_array = [];
        foreach ($see as $value){
            $see_array[$value['data_id']] = $map[$value['param_id']] ?? "";
        }

        return $see_array;
    }

    /**
     * 获取施工单号
     * @param $data
     * @return array
     */
    public function constructionGet($data){
        if(empty($data['model_type'])) return [false,'工单模板类型不能为空'];
        if(! isset(Construction::$prefix[$data['model_type']])) return [false,'工单模板类型错误'];
        $prefix = Construction::$prefix[$data['model_type']];
        $order_number = OrderNoService::createConstructionOrderNumber($prefix);
        if(! $order_number) return [false,'工单编号生成失败！'];

        return [true,['order_number' => $order_number]];
    }

    /**
     * 获取保存详情
     * @param $id
     * @return array
     */
    public function getSaveDetail($id){
        $product_save = [];
        if(empty($id)) return $product_save;

        $sub = ConstructionProductInfo::where('construction_id',$id)
            ->where('del_time',0)
            ->get()->toArray();
        foreach ($sub as $value){
            $key = $value['product_id'] . ',' . $value['storehouse_id'];
            if(isset($product_save[$key])){
                $product_save[$key] += $value['number'];
            }else{
                $product_save[$key] = $value['number'];
            }
        }

        return $product_save;
    }

    public function getSaveReturnCompareMessage($id = 0, $sales_order_id = 0){
        $construction = Construction::where('del_time',0)
            ->where('sales_order_id',$sales_order_id)
            ->select('id')->get()->toArray();
        $construction_id = array_column($construction,'id');

        $product_save = [];
        $sub = ConstructionProductInfo::where('del_time',0)
            ->whereIn('construction_id',$construction_id)
            ->when(! empty($id), function ($query) use ($id) {
                return $query->where('construction_id', '<>',$id);
            })
            ->get()->toArray();
        foreach ($sub as $value){
            if(isset($product_save[$value['product_id']])){
                $product_save[$value['product_id']] += $value['number'];
            }else{
                $product_save[$value['product_id']] = $value['number'];
            }
        }

        $sales_order_product = [];
        $sales_product = SalesOrderProductInfo::where('del_time',0)
            ->where('sales_order_id',$sales_order_id)
            ->get()->toArray();
        foreach ($sales_product as $value){
            $product_save_tmp = $product_save[$value['product_id']] ?? 0;
            if(isset($sales_order_product[$value['product_id']])){
                $sales_order_product[$value['product_id']] += $value['number'];
            }else{
                $sales_order_product[$value['product_id']] = $value['number'] - $product_save_tmp;
            }
        }

        return $sales_order_product;
    }
}