drb/app/Service/SalesOrderService.php

<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\BookingList;
use App\Model\Construction;
use App\Model\Customer;
use App\Model\CustomerInfo;
use App\Model\Depart;
use App\Model\Employee;
use App\Model\FollowUpRecord;
use App\Model\InvoiceOrder;
use App\Model\OrderOperation;
use App\Model\OutBoundOrderInfo;
use App\Model\PaymentReceipt;
use App\Model\PaymentReceiptInfo;
use App\Model\Product;
use App\Model\ProductCategory;
use App\Model\ProductSnInfo;
use App\Model\PurchaseOrder;
use App\Model\ReturnExchangeOrder;
use App\Model\ReturnExchangeOrderProductInfo;
use App\Model\SalesOrder;
use App\Model\SalesOrderInfo;
use App\Model\SalesOrderOtherFee;
use App\Model\SalesOrderProductInfo;
use App\Model\SeeRange;
use App\Model\SportsBag;
use App\Model\SportsBagProductInfo;
use App\Model\Storehouse;
use App\Model\U8Job;
use App\Model\WxEmployee;
use App\Service\Weixin\WxSendMessageService;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Facades\DB;

/**
 * 订单管理
 */
class SalesOrderService extends Service
{
    public function refundOption($data, $user){
        if(empty($data['sales_order_ids'])) return [false, 'sales_order_ids参数不能为空'];

        SalesOrder::whereIn('id',$data['sales_order_ids'])
            ->update(['is_refund' => 1]);

        return [true, ''];
    }

    /**
     * 订单编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function salesOrderEdit($data,$user){
        list($status,$msg) = $this->salesOrderRule($data, $user, false);
        if(!$status) return [$status,$msg];

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

        try {
            DB::beginTransaction();

            $model = SalesOrder::where('id', $data['id'])->first();
            $model->sales_order_type = $data['sales_order_type'];
            $model->model_type = $data['model_type'];
            $model->order_number = $data['order_number'];
            $model->selling_price = $data['selling_price'] ?? 0;
            $model->vin_no = $data['vin_no'] ?? '';
            $model->plat_type = $data['plat_type'] ?? 0;
            $model->plat_order = $data['plat_order'] ?? '';
            $model->order_type = $data['order_type'] ?? 0;
            $model->install_method = $data['install_method'] ?? 0;
            $model->install_position = $data['install_position'] ?? 0;
            $model->customer_id = $data['customer_id'] ?? 0;
            $model->customer_short_name = $data['customer_short_name'] ?? 0;
            $model->customer_contact = $data['customer_contact'] ?? "";
            $model->sign_time = $data['sign_time'] ?? 0;
            $model->product_total = $data['product_total'] ?? 0;
            $model->rate = $data['rate'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->construction_time = $data['construction_time'] ?? 0;
            $model->handover_time = $data['handover_time'] ?? 0;
            $model->other_fee = $data['other_fee'] ?? 0;
            $model->discount_fee = $data['discount_fee'] ?? 0;
            $model->contract_fee = $data['contract_fee'] ?? 0;
            $model->pay_way = $data['pay_way'] ?? 0;
            $model->car_type = $data['car_type'] ?? 0;
            $model->year = $data['year'] ?? '';
            $model->mileage = $data['mileage'] ?? '';
            $model->color = $data['color'] ?? '';
            $model->original_set = $data['original_set'] ?? '';
            $model->processing = $data['processing'] ?? '';
            $model->cdefine29 = $data['cdefine29'] ?? "";//分社施工
            $model->cdefine32 = $data['cdefine32'] ?? "";//达人昵称
            $model->cdefine30 = $data['cdefine30'] ?? "";//业务员
            $model->save();
            $time = time();

            SalesOrderInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => $time]);
            SalesOrderProductInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => $time]);

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

            if(! empty($data['employee_two'])){
                $insert = [];
                foreach ($data['employee_two'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

            if(! empty($data['employee_three'])){
                $insert = [];
                foreach ($data['employee_three'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_three,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

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

//            $new = [];
//            if(! empty($data['file'])){
//                $insert = [];
//                foreach ($data['file'] as $value){
//                    $insert[] = [
//                        'sales_order_id' => $model->id,
//                        'file' => $value['url'],
//                        'name' => $value['name'],
//                        'type' => SalesOrderInfo::type_four,
//                        'crt_time' => $time,
//                    ];
//                    $new[] = $value['url'];
//                }
//                SalesOrderInfo::insert($insert);
//            }

//            $new = $old = [];
//            $order = PaymentReceipt::where('del_time',0)
//                ->where('crt_time',$model->crt_time)
//                ->where('data_order_no',$data['order_number'])
//                ->first();
//            if(! empty($order)){
//                $old = PaymentReceiptInfo::where('del_time',0)
//                    ->where('payment_receipt_id',$order->id)
//                    ->whereIn('type',[PaymentReceiptInfo::type_one])
//                    ->select('file')
//                    ->get()->toArray();
//                $old = array_column($old,'file');
//            }
//
//            //收付款信息
//            if(! empty($data['payment_receipt'])){
//                if(empty($order)){
//                    $this->savePaymentReceiptOrder($data,$user,$time);
//                }else{
//                    PaymentReceiptInfo::where('del_time',0)
//                        ->where('payment_receipt_id',$order->id)
//                        ->update(['del_time' => $time]);
//                    $this->savePaymentReceiptOrder($data,$user,$time,$order);
//                }
//            }

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

//        $this->delStorageFile($old, $new);

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $data['id'],
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::eight,
                "menu_id" => $data['menu_id']
            ],$user);
            if(! $status) return [true, '保存成功，合同确认失败，异常信息：' . $msg];
        }

        return [true,''];
    }

    /**
     * 产品新增
     * @param $data
     * @param $user
     * @return array
     */
    public function salesOrderAdd($data,$user){
        list($status,$msg) = $this->salesOrderRule($data,$user);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $time = time();

            $model = new SalesOrder();
            $model->sales_order_type = $data['sales_order_type'];
            $model->model_type = $data['model_type'];
            $model->order_number = $data['order_number'];
            $model->selling_price = $data['selling_price'] ?? 0;
            $model->vin_no = $data['vin_no'] ?? '';
            $model->plat_type = $data['plat_type'] ?? 0;
            $model->plat_order = $data['plat_order'] ?? '';
            $model->order_type = $data['order_type'] ?? 0;
            $model->install_method = $data['install_method'] ?? 0;
            $model->install_position = $data['install_position'] ?? 0;
            $model->customer_id = $data['customer_id'] ?? 0;
            $model->customer_short_name = $data['customer_short_name'] ?? 0;
            $model->customer_contact = $data['customer_contact'] ?? "";
            $model->sign_time = $data['sign_time'] ?? 0;
            $model->product_total = $data['product_total'] ?? 0;
            $model->rate = $data['rate'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->construction_time = $data['construction_time'] ?? 0;
            $model->handover_time = $data['handover_time'] ?? 0;
            $model->other_fee = $data['other_fee'] ?? 0;
            $model->discount_fee = $data['discount_fee'] ?? 0;
            $model->contract_fee = $data['contract_fee'] ?? 0;
            $model->pay_way = $data['pay_way'] ?? 0;
            $model->car_type = $data['car_type'] ?? 0;
            $model->year = $data['year'] ?? '';
            $model->mileage = $data['mileage'] ?? '';
            $model->color = $data['color'] ?? '';
            $model->original_set = $data['original_set'] ?? '';
            $model->processing = $data['processing'] ?? '';
            $model->cdefine29 = $data['cdefine29'] ?? "";//分社施工
            $model->cdefine32 = $data['cdefine32'] ?? "";//达人昵称
            $model->cdefine30 = $data['cdefine30'] ?? "";//业务员
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->crt_id = $user['id'];
            $model->crt_time = $time;
            $model->save();

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

            if(! empty($data['employee_two'])){
                $insert = [];
                foreach ($data['employee_two'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

            if(! empty($data['employee_three'])){
                $insert = [];
                foreach ($data['employee_three'] as $value){
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'data_id' => $value,
                        'type' => SalesOrderInfo::type_three,
                        'crt_time' => $time,
                    ];
                }
                SalesOrderInfo::insert($insert);
            }

//            if(! empty($data['file'])){
//                $insert = [];
//                foreach ($data['file'] as $value){
//                    $insert[] = [
//                        'sales_order_id' => $model->id,
//                        'file' => $value['url'],
//                        'name' => $value['name'],
//                        'type' => SalesOrderInfo::type_four,
//                        'crt_time' => $time,
//                    ];
//                }
//                SalesOrderInfo::insert($insert);
//            }
            if(! empty($data['product'])){
                $insert = [];
                foreach ($data['product'] as $value){
                    $sports_bag_product_info_id = 0;
                    if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];;
                    $insert[] = [
                        'sales_order_id' => $model->id,
                        'product_id' => $value['product_id'] ?? 0,
                        'number' => $value['number'] ?? 0,
                        'cost' => $value['cost'] ?? 0,
                        'retail_price' => $value['retail_price'] ?? 0,
                        'mark' => $value['mark'] ?? '',
                        'crt_time' => $time,
                        'basic_type_id' => $value['basic_type_id'] ?? 0,
                        'price' => $value['price'] ?? 0,
                        'final_amount' => $value['final_amount'] ?? 0,
                        'sports_bag_id' => $value['sports_bag_id'] ?? 0,
                        'sports_bag_product_info_id' => $sports_bag_product_info_id,
                        'rate' => $value['rate'] ?? 0,
                    ];
                }
                SalesOrderProductInfo::insert($insert);
            }

            //收付款信息
            if(! empty($data['payment_receipt']['order_number'])) $this->savePaymentReceiptOrder($data,$user,$time);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
                return [false, '合同编号或收付款单编号已存在，请重新获取！'];
            }
            return [false,$exception->getLine().':'.$exception->getMessage()];
        }

        (new OperationLogService())->setOperationList($data,$user);

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $model->id,
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::eight,
                "menu_id" => $data['menu_id']
            ],$user);
            if(! $status) return [true, '保存成功，合同确认失败，异常信息：' . $msg];
        }

        return [true,''];
    }

    public function savePaymentReceiptOrder($data,$user,$time,$orders = null){
        $order = $data['payment_receipt'];

        if(empty($orders)){
            $model = new PaymentReceipt();
            $model->order_number = $order['order_number'];
//            $model->data_order_no = $data['order_number'];
            $model->data_type = $order['data_type'];
            $model->type = $order['type'];
            $model->account = $order['account'] ?? 0;
            $model->pay_way = $order['pay_way'] ?? 0;
//            $model->amount = $order['amount'] ?? 0;
            $model->mark = $order['mark'] ?? '';
            $model->crt_id = $user['id'];
            $model->depart_id = $data['depart_id'];
            $model->top_depart_id = $data['top_depart_id'];
            $model->payment_receipt_date = $order['payment_receipt_date'] ?? 0;
            $model->crt_time = $time;
            $model->save();

            $new = [];
            if(! empty($order['file'])){
                $insert = [];
                foreach ($order['file'] as $value){
                    $insert[] = [
                        'payment_receipt_id' => $model->id,
                        'file' => $value['url'],
                        'type' => PaymentReceiptInfo::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    if(! empty($value['url'])) $new[] = $value['url'];
                }
                PaymentReceiptInfo::insert($insert);
            }

            if(! empty($order['employee_one'])){
                $insert = [];
                foreach ($order['employee_one'] as $value){
                    $insert[] = [
                        'payment_receipt_id' => $model->id,
                        'data_id' => $value,
                        'type' => PaymentReceiptInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                PaymentReceiptInfo::insert($insert);
            }
            $insert = [];
            $insert[] = [
                'payment_receipt_id' => $model->id,
                'data_type' => $order['type'],
                'data_order_no' => $data['order_number'],
                'data_order_type' => $order['data_type'],
                'amount' => $order['amount'],
                'type' => PaymentReceiptInfo::type_three,
                'crt_time' => $time,
            ];
            PaymentReceiptInfo::insert($insert);

            if(! empty($new)) (new FileUploadService())->createOssUpload($new);
        }else{
            $order = $data['payment_receipt'];
            $orders->type = $order['type'];
            $orders->account = $order['account'] ?? 0;
            $orders->pay_way = $order['pay_way'] ?? 0;
            $orders->amount = $order['amount'] ?? 0;
            $orders->mark = $order['mark'] ?? '';
            $orders->payment_receipt_date = $order['payment_receipt_date'] ?? 0;
            $orders->save();
            if(! empty($order['file'])){
                $insert = [];
                foreach ($order['file'] as $value){
                    $insert[] = [
                        'payment_receipt_id' => $orders->id,
                        'file' => $value['url'],
                        'type' => PaymentReceiptInfo::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    $new[] = $value['url'];
                }
                PaymentReceiptInfo::insert($insert);
            }
            if(! empty($order['employee_one'])){
                $insert = [];
                foreach ($order['employee_one'] as $value){
                    $insert[] = [
                        'payment_receipt_id' => $orders->id,
                        'data_id' => $value,
                        'type' => PaymentReceiptInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                PaymentReceiptInfo::insert($insert);
            }
        }
    }

    /**
     * 订单删除
     * @param $data
     * @return array
     */
    public function salesOrderDel($data){
        if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据！'];
        if(! empty($data['id'])){
            $sale_order = SalesOrder::where('del_time',0)
                ->where('id',$data['id'])
                ->first();
        }else{
            $sale_order = SalesOrder::where('del_time',0)
                ->where('order_number',$data['order_number'])
                ->first();
            $data['id'] = empty($sale_order->id) ? 0 : $sale_order->id;
        }

        if(empty($sale_order)) return [false,'合同不存在或已被删除'];
        $sale_order = $sale_order->toArray();
        if($sale_order['state'] > 0) return [false,'请确认合同状态,删除失败'];

        $bool = PaymentReceiptInfo::where('del_time',0)
            ->where('type',PaymentReceiptInfo::type_three)
            ->where('data_order_no', $sale_order['order_number'])
            ->exists();
        if($bool) return [false, '合同已存在收付款单记录，请先删除收付款单据！'];

        try {
            DB::beginTransaction();

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

//            $old = SalesOrderInfo::where('del_time',0)
//                ->where('sales_order_id',$data['id'])
//                ->whereIn('type',[SalesOrderInfo::type_four])
//                ->select('file')
//                ->get()->toArray();
//            $old = array_column($old,'file');

            SalesOrderInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => time()]);
            SalesOrderProductInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => time()]);
            SalesOrderOtherFee::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => time()]);
            (new RangeService())->RangeDelete($data['id'],SeeRange::type_seven);

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

//        $this->delStorageFile($old);

        return [true,''];
    }

    /**
     * 订单详情
     * @param $data
     * @return array
     */
    public function detail($data,$user){
        if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据！'];
        $is_flag = isset($data['invoice_state']) ? 1 : 0;

        if(! empty($data['id'])){
            $sales = SalesOrder::where('del_time',0)
                ->where('id',$data['id'])
                ->first();
        }else{
            $sales = SalesOrder::where('del_time',0)
                ->where('order_number',$data['order_number'])
                ->first();
            $data['id'] = empty($sales->id) ? 0 : $sales->id;
        }

        if(empty($sales)) return [false,'合同不存在或已被删除'];
        $sales = $sales->toArray();
        if($is_flag && $sales['invoice_state']) return [false, '合同已发货'];

        $take_address = $take_man = $take_phone = "";
        $purchase = PurchaseOrder::where('del_time',0)
            ->where('order_number',$sales['contact_order_no'])
            ->first();
        if(! empty($purchase)){
            $purchase = $purchase->toArray();
            $depart = Depart::where('id', $purchase['top_depart_id'])->first();
            if(! empty($depart)) {
                $depart = $depart->toArray();
                $take_address = $depart['title'];
                $employee = Employee::where('id', $depart['notify_id'])->first();
                if(! empty($employee)){
                    $employee = $employee->toArray();
                    $take_man = $employee['emp_name'];
                    $take_phone = $employee['mobile'];
                }
            }
        }
        $sales['take_address'] = $take_address;
        $sales['take_man'] = $take_man;
        $sales['take_phone'] = $take_phone;
        if($sales['dispatch_time_second'] > 0){
            $see = SeeRange::where('del_time',0)
                ->where('data_id',$sales['id'])
                ->where('data_type',SeeRange::type_seven)
                ->where('type',SeeRange::data_three)
                ->select('param_id')
                ->first();
            $top_depart_id = $see->param_id ?? 0;
            $sales['storehouse_id'] = Storehouse::where('del_time', 0)->where('top_depart_id', $top_depart_id)->value('id') ?? 0;
        }else{
            $sales['storehouse_id'] = Storehouse::where('del_time', 0)->where('top_depart_id', $sales['top_depart_id'])->value('id') ?? 0;
        }

        $is_add_construction = 0;
        if($sales['top_depart_id'] == $user['head']['id']){
            if($sales['state'] >= SalesOrder::State_four && $sales['state'] < SalesOrder::State_seven) $is_add_construction = 1;
        }else{
            if($sales['state'] >= SalesOrder::State_two && $sales['state'] < SalesOrder::State_seven) $is_add_construction = 1;
        }
        $sales['add_construction'] = $is_add_construction;

        $customer = Customer::where('id',$sales['customer_id'])->value('title');
        $sales['customer_title'] = $customer ?? '';
        $customer_contact_id = $contact_type_id = 0;
        $customer_contact = CustomerInfo::where('del_time',0)
            ->where('customer_id',$sales['customer_id'])
            ->where('contact_info', $sales['customer_contact'])
            ->where('type',CustomerInfo::type_one)
            ->first();
        if(! empty($customer_contact)){
            $customer_contact = $customer_contact->toArray();
            $customer_contact_id = $customer_contact['id'];
            $contact_type_id = $customer_contact['contact_type'];
        }
        $sales['customer_contact_id'] = $customer_contact_id;
        $sales['contact_type_id'] = $contact_type_id;
        $sales['contact_type_title'] = BasicType::where('id',$contact_type_id)->value('title');

        $sales['sales_order_type_title'] = SalesOrder::$order_type[$sales['sales_order_type']] ?? '';

        $sales['type_title'] = SalesOrder::$build_state[$sales['type']] ?? '';
        $sales['is_dispatch'] = $sales['dispatch_time_second'] ? 1 : 0;
        $sales['activity_product'] = $sales['file'] = $sales['employee_one'] = $sales['employee_two'] = $sales['employee_three'] = $sales['product'] = $sales['dispatch_depart_one'] = $sales['dispatch_employee'] = $sales['dispatch_depart_two'] = [];
        $array = [
            $sales['plat_type'],
            $sales['order_type'],
            $sales['car_type'],
            $sales['pay_way'],
            $sales['install_method'],
            $sales['install_position'],
            $sales['customer_short_name'],
        ];
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $sales['crt_name'] = Employee::where('id',$sales['crt_id'])->value('emp_name');
        $sales = [$sales];

        //订单状态数据组织
        $state_array = $this->getStateMake($sales);

        //分派的总社或分社
        $dispatch = $this->getDispatchData($sales);

        foreach ($sales as $key => $value){
            $sales[$key]['state_title'] = $this->makeState($value, $state_array);
            $sales[$key]['plat_type_title'] = $basic_map[$value['plat_type']] ?? '';
            $sales[$key]['order_type_title'] = $basic_map[$value['order_type']] ?? '';
            $sales[$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
            $sales[$key]['pay_way_title'] = $basic_map[$value['pay_way']] ?? '';
            $sales[$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
            $sales[$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
            $sales[$key]['customer_short_name_title'] = $basic_map[$value['customer_short_name']] ?? '';
        }
        $sales = $sales[0];

        $show = "";
        $dispatch_company = $dispatch[$sales['id']] ?? '';
        if($dispatch_company){
            if($sales['is_confirm']){
                $show = $dispatch_company . '已接收';
            }else{
                $show = '待' . $dispatch_company . '接收';
            }
        }

        $sales['wx_show'] = $show;

        $sales_info = SalesOrderInfo::where('del_time',0)
            ->where('sales_order_id',$sales['id'])
            ->get()->toArray();
        $emp_id = [];
        foreach ($sales_info as $value){
            if(in_array($value['type'],SalesOrderInfo::$man)){
                $emp_id[] = $value['data_id'];
            }
        }

        $emp_map = Employee::whereIn('id',array_unique($emp_id))
            ->pluck('emp_name','id')
            ->toArray();
        foreach ($sales_info as $value){
            if(in_array($value['type'],SalesOrderInfo::$man)){
                $tt = $emp_map[$value['data_id']] ?? '';
                if(! empty($tt)){
                    $tmp = [
                        'id' => $value['data_id'],
                        'name' => $emp_map[$value['data_id']] ?? '',
                    ];
                    if($value['type'] == SalesOrderInfo::type_one){
                        $sales['employee_one'][] = $tmp;
                    }elseif ($value['type'] == SalesOrderInfo::type_two){
                        $sales['employee_two'][] = $tmp;
                    }elseif ($value['type'] == SalesOrderInfo::type_three){
                        $sales['employee_three'][] = $tmp;
                    }
                }
            } elseif ($value['type'] == SalesOrderInfo::type_four){
                $sales['file'][] = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                ];
            }
        }

        // 填充产品
        list($product, $activity_product) = $this->salesFillDetailProduct($sales);
        $sales['product'] = $product;
        $sales['activity_product'] = $activity_product;

        $sales['crt_time'] = $sales['crt_time'] ? date("Y-m-d H:i:s",$sales['crt_time']): '';
        $sales['dispatch_time_first'] = $sales['dispatch_time_first'] ? date("Y-m-d H:i:s",$sales['dispatch_time_first']): '';
        $sales['dispatch_time_second'] = $sales['dispatch_time_second'] ? date("Y-m-d H:i:s",$sales['dispatch_time_second']): '';

        //派单后数据 也就是可见范围
        $return = (new RangeService())->RangeDetail($sales['id'],SeeRange::type_seven);
        $sales['dispatch_depart_one'] = $return[0] ?? [];
        $sales['dispatch_employee'] = $return[1] ?? [];
        $sales['dispatch_depart_two'] = $return[2] ?? [];

        //回款单信息 审核过的
        $this->salesFillDetailPayment($sales);

        return [true, $sales];
    }

    public function salesFillDetailProduct($sales){
        $product = $activity_product = [];

        $sales_p_info = SalesOrderProductInfo::where('del_time',0)
            ->where('sales_order_id',$sales['id'])
            ->get()->toArray();
        $bag = SportsBag::whereIn('id',array_unique(array_column($sales_p_info,'sports_bag_id')))->get()->toArray();
        $bag_pro = SportsBagProductInfo::where('del_time',0)->whereIn('sports_bag_id',array_unique(array_column($sales_p_info,'sports_bag_id')))
            ->get()->toArray();
        $bag_map = array_column($bag,null,'id');
        $bag_pro_map = [];
        foreach ($bag_pro as $value){
            $bag_pro_map[$value['sports_bag_id']][] = $value;
        }

        $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))
            ->orWhere('type',20)
            ->pluck('title','id')
            ->toArray();
        $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
        $sports_bag_arr = [];
        $sports_bag_pro = [];
        foreach ($sales_p_info as $value){
            $tmp = $map[$value['product_id']] ?? [];
            if(! empty($value['sports_bag_id'])){
                $bag_tmp = $bag_map[$value['sports_bag_id']] ?? [];
                if(! isset($sports_bag_arr[$value['sports_bag_id']])) $sports_bag_arr[$value['sports_bag_id']] = $bag_tmp;
                $bag_pro_tmp = $bag_pro_map[$value['sports_bag_id']] ?? [];
                foreach ($bag_pro_tmp as $k => $v){
                    if($v['product_id'] != $value['product_id']) continue;
                    $is_choose = false;
                    $final_amount = 0;
                    $number = $v['number'];
                    $mark = "";
                    if($v['id'] == $value['sports_bag_product_info_id']){
                        $is_choose = true;
                        $final_amount = $value['final_amount'];
                        $number = $value['number'];
                        $mark = $value['mark'];
                    }
                    $bag_pro_tmp[$k]['is_choose'] = $is_choose;
                    $bag_pro_tmp[$k]['final_amount'] = $final_amount;
                    $bag_pro_tmp[$k]['number'] = $number;
                    $bag_pro_tmp[$k]['title'] = $tmp['title'] ?? "";
                    $bag_pro_tmp[$k]['code'] = $tmp['code'] ?? "";
                    $bag_pro_tmp[$k]['size'] = $tmp['size'] ?? "";
                    $bag_pro_tmp[$k]['unit'] = $tmp['unit'] ?? "";
                    $bag_pro_tmp[$k]['unit'] = $basic_price[$value['unit']] ?? "";
                    $bag_pro_tmp[$k]['bar_code'] = $tmp['bar_code'] ?? "";
                    $bag_pro_tmp[$k]['mark'] = $mark ?? "";
                    $sports_bag_pro[$value['sports_bag_id']][] = $bag_pro_tmp[$k];
                }
            }else{
                $value['title'] = $tmp['title'] ?? "";
                $value['code'] = $tmp['code'] ?? "";
                $value['size'] = $tmp['size'] ?? "";
                $value['unit'] = $tmp['unit'] ?? "";
                $value['unit_title'] = $basic_price[$value['unit']] ?? "";
                $value['bar_code'] = $tmp['bar_code'] ?? "";
                $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
                $product[] = $value;
            }
        }
        foreach ($sports_bag_arr as $key => $value){
            $value['product'] = $sports_bag_pro[$key] ?? [];
            $activity_product[] = $value;
        }

        return [$product, $activity_product];
    }

    public function salesFillDetailPayment(&$sales){
        //退换货信息
        $sales['return_exchange'] = (new ReturnExchangeOrderService())->getDifferentAmount($sales['id']);
        $sales['return_exchange_amount'] = 0;
        foreach ($sales['return_exchange'] as $value){
            if($value['state'] == ReturnExchangeOrder::State_two)  $sales['return_exchange_amount'] += $value['difference_amount'];
        }

        //回款单信息 审核过的
        $sales['payment_receipt_list'] = (new PaymentReceiptService())->getPaymentReceiptDataList($sales, PaymentReceipt::data_type_one);
        //坏账金额 = 已审核退货退款金额 - 红冲金额
        $sales['payment_receipt_list']['bad_amount'] = bcsub($sales['return_exchange_amount'], $sales['payment_receipt_list']['red_amount'],2);
        //未回款金额 = 总金额 - 已回款金额 - 坏账金额 - 红冲
        $sales['payment_receipt_list']['not_receipt_amount'] = bcsub(bcsub(bcsub($sales['contract_fee'], $sales['payment_receipt_list']['receipt_amount'],2), $sales['payment_receipt_list']['bad_amount'], 2),$sales['payment_receipt_list']['red_amount'],2);
        //回款单信息 审核过的

        $sales['not_payment_receipt_amount'] = bcsub($sales['contract_fee'],$sales['payment_receipt_list']['not_confirm_receipt_amount'],2);
    }

    public function salesOrderCommon($data,$user, $field = []){
        if(empty($field)) $field = SalesOrder::$field;

        $model = SalesOrder::Clear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field);

        if(! empty($data['order_list'])){
            if($data['order_list'] == 1){
                $model = $model->orderby('id','desc');
                //订单合同 安装件合同 状态未指派总社分社的 或者 快递件合同
//                $model->where('dispatch_time_second', 0);
//                $model->where('state', '<=', SalesOrder::State_three);
            }elseif($data['order_list'] == 2){
                $model = $model->orderby('dispatch_time_second','desc');
                //派单合同 安装件合同 状态已指派总社分社的
                $model = $model->where('dispatch_time_second', '>', 0);
//                $model->where('state', '>=', SalesOrder::State_four);
            }
        }else{
            $model = $model->orderby('id', 'desc');
        }
        if(isset($data['out_state'])) $model->where('out_state', $data['out_state']);

        $is_dispatch = -1;
        if(isset($data['is_dispatch'])) {
            if($data['is_dispatch'] == 0){
                //订单合同 安装件合同 状态未指派总社分社的 或者 快递件合同
                $model->where('dispatch_time_second', 0);
                $is_dispatch = 0;
            }else{
                //派单合同 安装件合同 状态已指派总社分社的
                $model->where('dispatch_time_second', '>', 0);
                $is_dispatch = 1;
            }
        }
        if(! empty($data['belong_top_depart_title'])){
            list($id, $depart_id) = $this->searchSalesDepart($data['belong_top_depart_title']);
            if($is_dispatch < 0){
                $model->whereIn('id', $id)
                    ->orWhereIn('top_depart_id', $depart_id);
            }elseif ($is_dispatch > 0){
                $model->whereIn('id', $id);
            }else{
                $model->where('top_depart_id', $depart_id);
            }
        }
        if(! empty($data['customer_contact'])) $model->where('customer_contact','LIKE', '%'.$data['customer_contact'].'%');
        if(! empty($data['order_number'])) $model->where('order_number','LIKE', '%'.$data['order_number'].'%');
        if(! empty($data['order_numbers'])) {
            $order_numbers = explode(',',$data['order_numbers']);
            $model->whereIn('order_number',$order_numbers);
        }
        if(! empty($data['sales_order_type'])) $model->where('sales_order_type',$data['sales_order_type']);
        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['add_construction'])) {
            //能下施工单的合同状态
            $model->where('state','>=',SalesOrder::State_two);
            $model->where('state','<',SalesOrder::State_seven);
        }
        if(! empty($data['add_return'])) {
            //能下退换货单的合同状态
            $search = "(sales_order_type = " . SalesOrder::Order_type_one ." and state >= " . SalesOrder::State_two.") or sales_order_type = " . SalesOrder::Order_type_two;
            $model->whereRaw("($search)");
//            $model->where('state','<',SalesOrder::State_seven);
        }
        if(! empty($data['sales_order_id'])) $model->where('id',$data['sales_order_id']);
        if(isset($data['state'])) {
            if($data['state'] == SalesOrder::special_status){
                $model->whereRaw(SalesOrder::search1);
            }else{
                if($data['state'] == SalesOrder::State_three) $model->where('dispatch_time_first','>',0);
                $model->where('state', $data['state']);
            }
        }
        if(isset($data['invoice_state'])) $model->where('invoice_state',$data['invoice_state']);
        if(isset($data['is_confirm'])) $model->where('is_confirm',$data['is_confirm']);
        if(isset($data['is_refund'])) $model->where('is_refund',$data['is_refund']);
        if(! empty($data['order_type'])) $model->where('order_type',$data['order_type']);
        if(! empty($data['plat_type'])) $model->where('plat_type',$data['plat_type']);
        if(! empty($data['plat_type_title'])) {
            $id = (new BasicTypeService())->basicTypeSearch($data['plat_type_title']);
            $model->whereIn('plat_type',$id);
        }
        if(! empty($data['plat_order'])) $model->where('plat_order','LIKE', '%'.$data['plat_order'].'%');
        if(! empty($data['customer'])) {
            $customer_id = (new CustomerService())->titleSearch($user, $data, $data['customer']);
            $model->whereIn('customer_id',$customer_id);
        }
        if(! empty($data['customer_id'])) $model->where('customer_id',$data['customer_id']);
        if(! empty($data['sign_time'][0]) && ! empty($data['sign_time'][1])){
            $return = $this->changeDateToTimeStampAboutRange($data['sign_time']);
            $model->where('sign_time','>=',$return[0]);
            $model->where('sign_time','<=',$return[1]);
        }
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('crt_time','>=',$return[0]);
            $model->where('crt_time','<=',$return[1]);
        }
        if(! empty($data['qd']) || ! empty($data['fz'])){
            $sale_order_id = (new RangeService())->salesOrderSearch($data);
            $model->whereIn('id',$sale_order_id);
        }
        if(! empty($data['zp'])){
            $sale_order_id = (new RangeService())->salesOrderZpSearch($data);
            $model->whereIn('id',$sale_order_id);
        }
        if(! empty($data['purchase_order_number'])) $model->where('contact_order_no','LIKE', '%'.$data['purchase_order_number'].'%');
        if(! empty($data['contact_info'])){
            $customer_id = (new CustomerService())->contactSearch($data['contact_info']);
            $model->whereIn('customer_id',$customer_id);
        }
        if(! empty($data['customer_crt_name'])){
            $customer_id = (new RangeService())->salesOrderCustomerCrtSearch($user,$data);
            $model->whereIn('customer_id',$customer_id);
        }
        if(! empty($data['dispatch_time_second'][0]) && ! empty($data['dispatch_time_second'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['dispatch_time_second']);
            $model->where('dispatch_time_second','>=',$return[0]);
            $model->where('dispatch_time_second','<=',$return[1]);
        }
        if(! empty($data['customer_from'])){
            $id = (new CustomerService())->searchBy($data,$user);
            $model->whereIn('customer_id', $id);
        }
        if(isset($data['construction_state'])){
            $for_search = [
                'state' => $data['construction_state'],
                'select_field' => true,
            ];
            $service = new ConstructionService();
            $return = $service->constructionList($for_search,$user);
            $model->whereIn('id', array_unique(array_column($return,'sales_order_id')));
        }
        if(! empty($data['smart_search'])){
            $service = new CustomerService();
            $customer_id = $service->contactSearch($data['smart_search']);
            $customer_id_2 = $service->titleSearch($user, $data, $data['smart_search']);
            $customer_id = array_unique(array_merge_recursive($customer_id,$customer_id_2));

            $model->where(function (Builder $query) use ($data, $customer_id) {
                $query->where('order_number', 'LIKE', '%' . $data['smart_search'] . '%')
                    ->orWhereIn('customer_id', $customer_id);
            });
        }
        if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
            $model->where('crt_time','>=',$data['wx_crt_time'][0]);
            $model->where('crt_time','<=',$data['wx_crt_time'][1]);
        }

        return $model;
    }

    public function orderNumberSearch($user, $data, $message){
        $model2 = SalesOrder::Clear($user,$data);
        $sale = $model2->where('del_time',0)
            ->where('order_number', 'LIKE', '%'.$message.'%')
            ->select('id')
            ->get()->toArray();

        return array_column($sale,'id');
    }

    //门店搜索
    public function searchSalesDepart($depart_title = ""){
        $sales_id = [];
        if(empty($depart_title)) return $sales_id;

        $depart_id = Depart::where('del_time', 0)
            ->where('parent_id', 0)
            ->where('title', 'LIKE', '%'. $depart_title .'%')
            ->select('id')->get()->toArray();
        $depart_id = array_column($depart_id, 'id');
        if(empty($depart_id)) return [$sales_id, $depart_id];

        $sales_id = SeeRange::where('del_time',0)
            ->whereIn('param_id', $depart_id)
            ->where('data_type',SeeRange::type_seven)
            ->where('type',SeeRange::data_three)
            ->select('data_id as sale_id')
            ->get()->toArray();
        $sales_id = array_column($sales_id, 'sale_id');

        return [$sales_id, $depart_id];
    }

    /**
     * 订单列表
     * @param $data
     * @param $user
     * @return array
     */
    public function salesOrderList($data,$user){
        $model = $this->salesOrderCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list,$data);

        $count = $this->countData("crt_time", $data, $user);
        $list['today'] = $count[0] ?? 0;
        $list['yesterday'] = $count[1] ?? 0;

        return [true, $list];
    }

    function createTempTableIfNotExists($ids, &$model)
    {
        if (empty($ids)) {
            $model->whereIn('id', []);
            return;
        }

        // 使用事务
        DB::beginTransaction();

        try {
            // 先删除已有的临时表
            DB::unprepared('DROP TEMPORARY TABLE IF EXISTS temp_ids');

            // 创建临时表
            DB::unprepared('CREATE TEMPORARY TABLE temp_ids (id INT)');

            // 插入数据
            foreach (array_chunk($ids, 1000) as $chunk) {
                DB::table('temp_ids')->insert(array_map(function ($id) {
                    return ['id' => $id];
                }, $chunk));
            }

            // 使用临时表
            $model->whereIn('id', function ($query) {
                $query->select('id')->from('temp_ids');
            });

            // 提交事务
            DB::commit();
        } catch (\Exception $e) {
            // 回滚事务
            DB::rollBack();
        }
    }

    public function salesOrderClose($data,$user){
        if(empty($data['id'])) return [false, '请选择合同'];
        $sale_order = SalesOrder::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($sale_order)) return [false, '合同不存在或已被删除'];
        $sale_order = $sale_order->toArray();
        if($sale_order['model_type'] != SalesOrder::Model_type_four) return [false, '非线上订单'];

        $bool = ReturnExchangeOrder::where('del_time',0)
            ->where('data_id', $sale_order['id'])
            ->where('type',ReturnExchangeOrder::Order_type)
            ->exists();
        if($bool) return [false, '合同已存在退换货单'];

        $bool = PaymentReceipt::where('del_time',0)
            ->where('data_order_no', $sale_order['order_number'])
            ->where('data_type',PaymentReceipt::data_type_one)
            ->exists();
        if($bool) return [false, '合同已存在收付款单'];

        $bool = PurchaseOrder::where('del_time',0)
            ->where('sales_order_id', $sale_order['id'])
            ->exists();
        if($bool) return [false, '合同已存在采购订单'];

        $bool = Construction::where('del_time',0)
            ->where('sales_order_id', $sale_order['id'])
            ->exists();
        if($bool) return [false, '合同已存在施工单'];

        try {
            DB::beginTransaction();
            $del_time = 1234;
            SalesOrder::where('id', $data['id'])
                ->update(['del_time' => $del_time]);

            SalesOrderInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => $del_time]);
            SalesOrderProductInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => $del_time]);
            SalesOrderOtherFee::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->update(['del_time' => $del_time]);
            (new RangeService())->RangeDelete($data['id'],SeeRange::type_seven);
            DB::commit();
        }catch (\Throwable $exception){
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, ''];
    }

    /**
     * 订单参数规则
     * @param $data
     * @param $user
     * @param $is_add
     * @return array
     */
    public function salesOrderRule(&$data, $user, $is_add = true){
        if(empty($data['model_type'])) return [false,'销售类型不能为空'];
        if(! in_array($data['model_type'],SalesOrder::$model_type)) return [false,'销售类型错误'];
        if(empty($data['sales_order_type'])) return [false,'产品类型不能为空'];
        if(empty($data['order_number'])) return [false,'合同编号不能为空'];
//        if(empty($data['customer_id'])) return [false,'请选择客户'];
//        if(empty($data['employee_one'])) return [false,'请选择签订人'];
        if(! empty($data['sign_time'])) $data['sign_time'] = $this->changeDateToDateMin($data['sign_time']);
        if(! empty($data['expire_time'])) $data['expire_time'] = $this->changeDateToDateMin($data['expire_time']);
//        if(empty($data['employee_two'])) return [false,'请选择负责人'];
//        if(empty($data['product'])) return [false,'请选择产品'];
        if(empty($data['menu_id'])) return [false, '菜单信息不能为空'];
        //限制频率
        list($status,$msg) = $this->limitingSendRequestBackgExpire("saleOrder" . $data['order_number']);
        if(! $status) return [false, $msg];

        $sports_bag_id = [];
        if(! empty($data['product'])){
            foreach ($data['product'] as $value){
                if(empty($value['number'])) return [false,'产品数量不能为空'];
                $res = $this->checkNumber($value['number']);
                if(! $res) return [false,'请输入正确的产品数量'];
                if(! empty($value['sports_bag_id']) && ! in_array($value['sports_bag_id'], $sports_bag_id)) $sports_bag_id[] = $value['sports_bag_id'];
            }
        }
        if(! empty($sports_bag_id)) return [false, '销售订单活动包暂未开放'];

        if(! empty($data['contract_fee'])){
            $res = $this->checkNumber($data['contract_fee']);
            if(! $res) return [false, '合同金额请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['other_fee'])){
            $res = $this->checkNumber($data['other_fee']);
            if(! $res) return [false, '其它费用请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['discount_fee'])){
            $res = $this->checkNumber($data['discount_fee']);
            if(! $res) return [false, '优惠金额请输入不超过两位小数并且大于0的数值'];
        }
        //所属部门 以及  顶级部门
        if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
        $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;

        //是否总部
        $is_head_now = 0;
        if($data['top_depart_id'] == $user['head']['id']) $is_head_now = 1;

        if($data['model_type'] == SalesOrder::Model_type_one){
            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(empty($data['plat_type'])) return [false,'平台类型不能为空'];
            if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
        }elseif($data['model_type'] == SalesOrder::Model_type_two){

        }elseif($data['model_type'] == SalesOrder::Model_type_three){

        }elseif($data['model_type'] == SalesOrder::Model_type_four){
            if($is_head_now){
                if(empty($data['plat_type'])) return [false,'平台类型不能为空'];
                if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
            }
        }elseif($data['model_type'] == SalesOrder::Model_type_five){
            if($is_head_now){
                if(empty($data['plat_type'])) return [false,'平台类型不能为空'];
                if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
            }
        }elseif($data['model_type'] == SalesOrder::Model_type_six){

        }

        //收付款信息
        if(! empty($data['payment_receipt']['order_number'])){
            if(! isset($data['contract_fee'])) return [false, '合同金额不能为空'];
            if(empty($data['payment_receipt']['data_type'])) $data['payment_receipt']['data_type'] = PaymentReceipt::data_type_one;
            if(empty($data['payment_receipt']['data_order_no'])) $data['payment_receipt']['data_order_no'] = $data['payment_receipt']['order_number'];
            if(empty($data['payment_receipt']['type'])) return [false,'金额类型不能为空'];
            if(empty($data['payment_receipt']['amount'])) return [false,'回款金额不能为空'];
            $res = $this->checkNumber($data['payment_receipt']['amount']);
            if(! $res) return [false, '回款金额请输入不超过两位小数并且大于0的数值'];
            if($data['contract_fee'] < $data['payment_receipt']['amount']) return [false, '回款金额不能大于合同金额'];
            if(! empty($data['payment_receipt']['payment_receipt_date'])) $data['payment_receipt']['payment_receipt_date'] = $this->changeDateToDate($data['payment_receipt']['payment_receipt_date']);
        }

        if($is_add){
            $bool = SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])->exists();
            if($bool) return [false,'合同编号已存在，请重新获取'];

            $check_id = $sports_bag_id;
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $order = SalesOrder::where('del_time',0)->where('id',$data['id'])->first();
            if(empty($order)) return [false,'合同不存在或已被删除'];
            $order = $order->toArray();
            if(! in_array($order['state'], [SalesOrder::State_minus_one,SalesOrder::State_zero])) return [false, '请确认合同状态，编辑失败'];
            //订单编辑提交限制
            $current_top_depart_id = $this->getMyTopDepart($user);
            list($status, $msg) = $this->returnOrderEditErrorCommon($current_top_depart_id, $order['top_depart_id']);
            if(! $status) return [false, $msg];

            $sports_bag_id_save = SalesOrderProductInfo::where('del_time',0)
                ->where('sales_order_id',$data['id'])
                ->where('sports_bag_id','>',0)
                ->select('sports_bag_id')
                ->get()->toArray();
            $sports_bag_id_save = array_unique(array_column($sports_bag_id_save,'sports_bag_id'));
            $check_id = array_values(array_diff($sports_bag_id, $sports_bag_id_save));
        }

        //校验活动包有效性
        $service = new SportsBagService();
        list($status, $msg) = $service->checkSportsBag($check_id);
        if(! $status) return [false, $msg];

        return [true, $data];
    }

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

        $data_id = array_column($data['data'],'id');
        $array = array_unique(array_merge_recursive(array_column($data['data'],'order_type'),array_column($data['data'],'car_type'),array_column($data['data'],'pay_way'),array_column($data['data'],'install_position'),array_column($data['data'],'install_method'),array_column($data['data'],'plat_type')));
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
            ->pluck('emp_name','id')
            ->toArray();
        $customer = Customer::whereIn('id',array_unique(array_column($data['data'],'customer_id')))
            ->pluck('title','id')
            ->toArray();

        $product = $employee_two = $purchase = [];
        //获取合同下的产品
        if(! empty($ergs['product'])) $product = $this->getSalesOrderProduct($data_id);
        if(! empty($ergs['employee_two'])){
            //单据中选择的负责人
            $sales_order = SalesOrderInfo::where('del_time',0)
                ->where('type',SalesOrderInfo::type_two)
                ->whereIn('sales_order_id',$data_id)
                ->select('sales_order_id','data_id')
                ->get()->toArray();
            $empList = Employee::whereIn('id', array_unique(array_column($sales_order,'data_id')))
                ->pluck('emp_name','id')
                ->toArray();
            foreach ($sales_order as $value){
                $str = $empList[$value['data_id']] ?? "";
                if(! $str) continue;
                if(isset($employee_two[$value['sales_order_id']])){
                    $employee_two[$value['sales_order_id']] .= ',' . $str;
                }else{
                    $employee_two[$value['sales_order_id']] = $str;
                }
            }
        }
        if(! empty($ergs['purchase'])){
            $order = PurchaseOrder::where('del_time',0)
                ->whereIn('sales_order_id',$data_id)
                ->select('sales_order_id','order_number')
                ->get()->toArray();
            foreach ($order as $value){
                if(isset($purchase[$value['sales_order_id']])){
                    $purchase[$value['sales_order_id']] .= ',' . $value['order_number'];
                }else{
                    $purchase[$value['sales_order_id']] = $value['order_number'];
                }
            }
        }

        list($for_amount_list, $for_amount_list1) = (new PaymentReceiptService())->getPaymentReceiptDataCountList(array_column($data['data'],'order_number'));
        list($getDifferentAmountALL,$getDifferentAmountALL1) = (new ReturnExchangeOrderService())->getDifferentAmountALLNew($data_id);

        //获取分社订货合同关联的发货单
        $invoiceData = $this->getInvoiceOrderData($data['data']);

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

        //指派金额
        $fee = $this->getOtherMoney($data['data']);

        //订单状态数据组织
        $state_array = $this->getStateMake($data['data']);

        //同步用友信息
        $u8 = $this->getMessage($data_id,U8Job::two);

        //关联施工单号
        $construction_array = $this->getConstruction($data_id);

        //跟进记录
        $record_array = (new FollowUpRecordService())->getVisitDataOfTime($data_id, FollowUpRecord::type_two);

        //获取客户的信息
        $customer_id = array_column($data['data'],'customer_id');
        $customer_map = $this->getCustomer($customer_id);

        $array2 = array_unique(array_column($data['data'],'top_depart_id'));
        $depart = Depart::whereIn('id',$array2)->pluck('title','id')->toArray();

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['construction_model_type'] = SalesOrder::$build_for_con[$value['type']] ?? 1;
            $data['data'][$key]['type_title'] = SalesOrder::$build_state[$value['type']] ?? '';
            $data['data'][$key]['plat_type_title'] = $basic_map[$value['plat_type']] ?? '';
            $data['data'][$key]['sales_order_type_title'] = SalesOrder::$order_type[$value['sales_order_type']] ?? '';
            $data['data'][$key]['model_type_title'] = SalesOrder::$model_type_title[$value['model_type']] ?? '';
            $data['data'][$key]['order_type_title'] = $basic_map[$value['order_type']] ?? '';
            $data['data'][$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
            $data['data'][$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
            $data['data'][$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
            $data['data'][$key]['pay_way_title'] = $basic_map[$value['pay_way']] ?? '';
            $data['data'][$key]['customer_title'] = $customer[$value['customer_id']] ?? '';
            $c_tmp = $customer_map[$value['customer_id'] . $value['customer_contact']] ?? [];
            $data['data'][$key]['customer_contact_id'] = $c_tmp['customer_contact_id'] ?? '';
            $data['data'][$key]['contact_type_id'] = $c_tmp['contact_type_id'] ?? '';
            $data['data'][$key]['contact_type_title'] = $c_tmp['contact_type_title'] ?? '';
            $data['data'][$key]['sign_time'] = $value['sign_time'] ? date('Y-m-d',$value['sign_time']) : '';
            $data['data'][$key]['construction_time'] = $value['construction_time'] ? date('Y-m-d H:i:s',$value['construction_time']) : '';
            $data['data'][$key]['handover_time'] = $value['handover_time'] ? date('Y-m-d H:i:s',$value['handover_time']) : '';
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['is_dispatch'] = $value['dispatch_time_second'] ? 1 : 0;
            $data['data'][$key]['is_dispatch_title'] = $value['dispatch_time_second'] ? "已派单" : "未派单";
            $data['data'][$key]['is_refund_title'] = $value['is_refund'] ? "已返款" : "未返款";
            $data['data'][$key]['dispatch_time_second_time'] = $value['dispatch_time_second'] ? date('Y-m-d H:i:s',$value['dispatch_time_second']) : '';
            $crt_name = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['crt_name'] = $crt_name;
            $data['data'][$key]['product'] = $product[$value['id']] ?? [];
            $data['data'][$key]['employee_two_title'] = $employee_two[$value['id']] ?? "";
            $data['data'][$key]['purchase'] = $purchase[$value['id']] ?? "";
            $data['data'][$key]['fee'] = $fee[$value['id']] ?? "";
            $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
            $data['data'][$key]['invoice_state_name'] = SalesOrder::$invoice_state[$value['invoice_state']] ?? '';
            $data['data'][$key]['is_confirm_title'] = $value['is_confirm'] ? "已接收" : "未接收" ;
            $tmp = $invoiceData[$value['id']] ?? [];
            $data['data'][$key]['invoice_arr'] = implode(',', $tmp);
            $dispatch_company = $dispatch[$value['id']] ?? '';
            $data['data'][$key]['dispatch_company'] = $dispatch_company;
            if($value['dispatch_time_second'] > 0) {
                //分配过所属门店是分配门店
                $data['data'][$key]['belong_top_depart_title'] = $dispatch_company;
            }else{
                //没分配过所属门店是创建门店
                $data['data'][$key]['belong_top_depart_title'] = $depart[$value['top_depart_id']] ?? "";
            }
            $data['data'][$key]['u8_message'] = $u8[$value['id']] ?? '';
            $data['data'][$key]['construction_no'] = $construction_array[$value['id']] ?? '';
            if($value['is_confirm']){
                $show = $dispatch_company . '已接收';
            }else{
                $show = '待' . $dispatch_company . '接收';
            }
            $data['data'][$key]['wx_show'] = $show;

            //用于计算--------
            //已收（审核后）
            $one1 = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
            $data['data'][$key]['checked_payment_receipt_amount'] = $one1;
            //已收
            $one = $for_amount_list[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
            $data['data'][$key]['payment_receipt_amount'] = $one;
            //已红冲
            $three = $for_amount_list[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
            $data['data'][$key]['red_amount'] = $three;
            //已退货退款
            $return_exchange_amount = $getDifferentAmountALL[$value['id']] ?? 0;
            $data['data'][$key]['return_exchange_amount'] = $return_exchange_amount;
            //用于计算--------

            //用于统计--------
            $red = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
            $return_exchange_amount1 = $getDifferentAmountALL1[$value['id']] ?? 0;
            $bad = bcsub($return_exchange_amount1 ,$red,2);
            //已收金额
            $fee1 = bcsub($one1 ,$red,2);
            $data['data'][$key]['fee1'] = $fee1;
            //未收金额
            $fee2 = bcsub(bcsub(bcsub($value['contract_fee'], $fee1,2), $bad, 2),$red,2);
            $data['data'][$key]['fee2'] = $fee2;
            //红冲金额
            $data['data'][$key]['fee3'] = $red;
            //坏账金额
            $data['data'][$key]['fee4'] = $bad;
            //用于统计--------

            $record_tmp = $record_array[$value['id']] ?? "";
            $data['data'][$key]['has_record'] = $record_tmp ? "查看" : "无记录";
            $data['data'][$key]['follow_record'] = $record_array[$value['id']] ?? "";
        }

        return $data;
    }

    public function getMessage($id,$type){
        $result = U8Job::where('del_time',0)
            ->whereIn('data',$id)
            ->where('data_type',$type)
            ->select('data','state','crt_time','msg')
            ->get()->toArray();
        $return = [];
        foreach ($result as $value){
            if($value['state'] == 1){
                $return[$value['data']] = '同步成功';
            }else{
                $return[$value['data']] = '同步失败:' . $value['msg'];
            }
        }

        return $return;
    }

    public function getCustomer($customer_id){
        $customer_contact_map = [];
        $contact_type_id = [];
        $customer_contact = CustomerInfo::where('del_time',0)
            ->whereIn('customer_id', $customer_id)
            ->where('type',CustomerInfo::type_one)
            ->select('customer_id','contact_info','contact_type','id')
            ->get()->toArray();
        if(! empty($customer_contact)){
            foreach ($customer_contact as $value){
                if(! empty($value['customer_id']) && ! empty($value['contact_info'])){
                    $customer_contact_map[$value['customer_id'] . $value['contact_info']] = [
                        'customer_contact_id' => $value['id'],
                        'contact_type_id' => $value['contact_type'],
                    ];
                    $contact_type_id[] = $value['contact_type'];
                }
            }
        }
        $contact_type_title = BasicType::whereIn('id', $contact_type_id)->pluck('title','id')->toArray();
        foreach ($customer_contact_map as $key => $value){
            $customer_contact_map[$key]['contact_type_title'] = $contact_type_title[$value['contact_type_id']] ?? "";
        }

        return $customer_contact_map;
    }

    public function countData($column = "", $data, $user){
        if(empty($column) || empty($data['from_wx'])) return [0, 0];


        // 获取今天的开始和结束时间戳
        $todayStart = Carbon::today()->startOfDay()->timestamp;
        $todayEnd = Carbon::today()->endOfDay()->timestamp;

        // 获取昨天的开始和结束时间戳
        $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
        $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;

        $data['wx_' . $column] = [$todayStart, $todayEnd];
        $model = $this->salesOrderCommon($data, $user);
        // 查询今天的数据条数
        $todayCount = $model->count();

        $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
        $model = $this->salesOrderCommon($data, $user);
        // 查询昨天的数据条数
        $yesterdayCount = $model->count();

        return [$todayCount, $yesterdayCount];
    }

    public function getSalesOrderProduct($data_id)
    {
        $product = [];
        if(empty($data_id)) return $product;
        $sales_p_info = SalesOrderProductInfo::where('del_time',0)
            ->whereIn('sales_order_id',$data_id)
            ->get()->toArray();
        $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))->pluck('title','id')->toArray();
        $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));

        foreach ($sales_p_info as $value){
            $tmp = $map[$value['product_id']] ?? [];
            $value['title'] = $tmp['title'] ?? "";
            $value['is_edit_unit_price'] = $tmp['is_edit_unit_price'] ?? 0;
            $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']] ?? "";
            $value['install_time'] = $tmp['install_time'] ?? 0;
            $product[$value['sales_order_id']][] = $value;
        }

        return $product;
    }

    public function salesOrderGet($data){
        if(empty($data['model_type'])) return [false,'销售类型不能为空'];
        if(! isset(SalesOrder::$prefix[$data['model_type']])) return [false,'销售类型错误'];
        $prefix = SalesOrder::$prefix[$data['model_type']];
        $order_number = OrderNoService::createSalesOrderNumber($prefix);
        if(! $order_number) return [false,'合同编号生成失败！'];

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

    /**
     * 订单推送
     * @param $data
     * @return array
     */
    public function salesOrderDispatchSale($data, $user){
        list($status,$msg) = $this->salesOrderDispatchSaleRule($data, $user);
        if(! $status) return [false,$msg];

        try {
            DB::beginTransaction();
            $time = time();

            SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
                'state' => SalesOrder::State_three,
                'dispatch_time_first' => $time,
            ]);

            SeeRange::where('del_time',0)
                ->where('data_id',$msg['id'])
                ->where('data_type',SeeRange::type_seven)
                ->whereIn('type',[SeeRange::data_one, SeeRange::data_two])
                ->update(['del_time' => $time]);

            if(! empty($data['dispatch_depart_one'])){
                $insert = [];
                foreach ($data['dispatch_depart_one'] as $value){
                    $insert[] = [
                        'data_id' => $msg['id'],
                        'data_type' => SeeRange::type_seven,
                        'param_id' => $value,
                        'type' => SeeRange::data_one,
                        'crt_time' => $time,
                    ];
                }
                SeeRange::insert($insert);
            }

            if(! empty($data['dispatch_employee'])){
                $insert = [];
                foreach ($data['dispatch_employee'] as $value){
                    $insert[] = [
                        'data_id' => $msg['id'],
                        'data_type' => SeeRange::type_seven,
                        'param_id' => $value,
                        'type' => SeeRange::data_two,
                        'crt_time' => $time,
                    ];
                }
                SeeRange::insert($insert);
            }

            (new OrderOperationService())->add([
                'order_number' => $msg['order_number'],
                'msg' => OrderOperation::$type[OrderOperation::one],
                'type' => OrderOperation::one
            ],$user);

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

        return [true,''];
    }

    /**
     * 订单推送规则
     * @param $data
     * @return array
     */
    public function salesOrderDispatchSaleRule(&$data, $user){
        if(empty($data['id'])) return [false,'请选择合同派单'];
        $sale = SalesOrder::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($sale)) return [false,'合同不存在或已被删除'];
        $sale = $sale->toArray();
        if($sale['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同，操作失败'];
        if(! in_array($sale['model_type'],[SalesOrder::Model_type_four,SalesOrder::Model_type_seven])) return [false,'非线上订单/补贴订单，线上派单操作失败'];
        if($sale['state'] < SalesOrder::State_two) return [false,'合同还未确认，操作失败'];
        if($sale['state'] > SalesOrder::State_three) return [false,'请确认合同状态，操作失败'];
        $bool = SalesOrderProductInfo::where('del_time',0)
            ->where('sales_order_id',$data['id'])
            ->exists();
        if(! $bool) return [false,'合同产品不能为空'];
        if(empty($data['dispatch_depart_one']) && empty($data['dispatch_employee'])) return [false, '请指派部门或人员'];

        return [true, $sale];
    }

    /**
     * 订单推送公司
     * @param $data
     * @return array
     */
    public function salesOrderDispatchCompany($data,$user){
        list($status,$msg) = $this->salesOrderDispatchCompanyRule($data,$user);
        if(! $status) return [false,$msg];

        try {
            DB::beginTransaction();
            $time = time();
            SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
                'state' => SalesOrder::State_four,
                'dispatch_time_second' => $time,
                'dispatch_time_second_id' => $user['id'],
                'type' => $data['type']
            ]);

            SeeRange::where('del_time',0)
                ->where('data_id',$msg['id'])
                ->where('data_type',SeeRange::type_seven)
                ->where('type',SeeRange::data_three)
                ->update(['del_time' => $time]);
            SalesOrderOtherFee::where('del_time',0)
                ->where('sales_order_id',$msg['id'])
                ->update(['del_time' => $time]);
            if(! empty($data['dispatch_depart_two'])){
                $insert = [];
                foreach ($data['dispatch_depart_two'] as $value){
                    $insert[] = [
                        'data_id' => $msg['id'],
                        'data_type' => SeeRange::type_seven,
                        'param_id' => $value,
                        'type' => SeeRange::data_three,
                        'crt_time' => $time,
                    ];
                }
                SeeRange::insert($insert);
            }

            if(! empty($data['other_fee_1'])){
                $model = new SalesOrderOtherFee();
                $model->sales_order_id = $msg['id'];
                $model->other_fee_1 = $data['other_fee_1'] ?? 0;
                $model->type = $data['type'] ?? 0;
                $model->save();
            }

            if(isset($data['notify_id'])){
                SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
                    'dispatch_time_first' => $time, // 第一次派单时间也记录
                ]);

                if(! empty($data['notify_id'])){ //门店负责人不为空
                    $insert[] = [
                        'data_id' => $msg['id'],
                        'data_type' => SeeRange::type_seven,
                        'param_id' => $data['notify_id'],
                        'type' => SeeRange::data_two,
                        'crt_time' => $time,
                    ];
                    SeeRange::insert($insert);
                }
            }

            (new OrderOperationService())->add([
                'order_number' => $msg['order_number'],
                'msg' => OrderOperation::$type[OrderOperation::two],
                'type' => OrderOperation::two
            ],$user);

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

        $depart_id = $data['dispatch_depart_two'][0] ?? 0;
        if(! empty($depart_id) && $depart_id != $msg['top_depart_id']){
           //发送消息
           $notify_id = Depart::where('id',$depart_id)->value('notify_id');
           if(! empty($notify_id)){
               $emp_name = Employee::whereIn('id',[$msg['crt_id'], $notify_id])->pluck('emp_name','id')->toArray();
               $send_data[] = [
                   'employee_id' => $notify_id,
                   'type' => 1,
                   'state' => 1,
                   'menu_id' => 37,
                   'order_number' => $msg['order_number'],
                   'tmp_data' => [
                       $msg['order_number'],
                       $emp_name[$msg['crt_id']] ?? "",
                       $emp_name[$notify_id] ?? "" . "(派单通知)",
                       date('Y-m-d H:i:s'),
                   ],
               ];
               (new OaService())->sendWxOaCheckMessage($send_data);
           }
        }else{
             //直接确认
            SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
                'is_confirm' => 1,
            ]);
        }

        return [true,''];
    }

    /**
     * 订单推送公司规则
     * @param $data
     * @return array
     */
    public function salesOrderDispatchCompanyRule(&$data,$user){
        if(empty($data['id'])) return [false,'请选择合同派单'];
        if(empty($data['dispatch_depart_two'])) return [false, '请指派总社或分社'];
        $depart_id = $data['dispatch_depart_two'][0];

        if(! isset($data['other_fee_1'])) return [false,'分社安装金额不存在'];
        $res = $this->checkNumber($data['other_fee_1']);
        if(! isset($data['type']) || ! isset(SalesOrder::$build_state[$data['type']])) return [false, '合同安装类型不存在'];
        if($data['type'] <= 0) $data['type'] = SalesOrder::build_zero;
        if(! $res) return [false,'价格请输入不超过两位小数并且大于等于0的数值'];

        $sale = SalesOrder::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($sale)) return [false,'合同不存在或已被删除'];
        $sale = $sale->toArray();
        if($sale['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同，操作失败'];
        if($sale['state'] > SalesOrder::State_four) return [false,'请确认合同状态，操作失败'];
        if($sale['state'] < SalesOrder::State_two) return [false, '合同未审核通过，操作失败'];
        if($sale['state'] < SalesOrder::State_three) {
            //如果没有派销售过 找到门店负责人
            $data['notify_id'] = Depart::where('id', $depart_id)->value('notify_id');
        }

        $product = SalesOrderProductInfo::where('del_time',0)
            ->where('sales_order_id',$data['id'])
            ->select('product_id','number')
            ->get()->toArray();
        if(empty($product)) return [false,'合同产品不能为空'];

        $bool = Construction::where('del_time',0)
            ->where('sales_order_id',$data['id'])
            ->exists();
        if($bool) return [false,'合同已生成施工单，操作失败'];

        $product_id = array_unique(array_column($product,'product_id'));
        $return = RangeService::productNotSeeRange($product_id);

        //产品信息
        $product_array = Product::whereIn('id',$product_id)->select('title','id','build_fee')->get()->toArray();
        $map = [];
        foreach ($product_array as $value){
            $map[$value['id']] = $value['title'];
        }
        if(! empty($return)){
            foreach ($data['dispatch_depart_two'] as $value){
                foreach ($return as $key => $values){
                    $tmp = $map[$key] ?? "";
                    if(in_array($value, $values)) return [false,'产品'. $tmp .'对于该总社或分社不可见'];
                }
            }
        }

        return [true, $sale];
    }

    public function salesOrderListsalesOrderWxList($data,$user){
        $field = SalesOrder::$field;
        $model = SalesOrder::where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc')
            ->orderby('dispatch_time_second','desc');

        if(! empty($data['openid'])){
            $mobile = WxEmployee::where('openid',$data['openid'])->select('mobile')->get()->toArray();
            $mobile = array_column($mobile,'mobile');
            $customer_id = CustomerInfo::where('del_time',0)
                ->where('type',CustomerInfo::type_one)
                ->whereIn('contact_info',$mobile)
                ->select('customer_id')
                ->get()->toArray();
            $customer_id = array_column($customer_id,'customer_id');
            $model->whereIn('customer_id',$customer_id);
        }
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');

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

        return [true, $list];
    }

    public function getInvoiceOrderData($data){
        //分社订货模板
        $search_id = [];
        foreach ($data as $value){
            if(! empty($value['invoice_state'])) $search_id[] = $value['id'];
        }
        if(empty($search_id)) return [];

        $invoice = InvoiceOrder::where('del_time',0)
            ->whereIn('sales_order_id',$search_id)
            ->select('sales_order_id','order_number','logistics_number')
            ->get()->toArray();
        $invoice_array = [];
        foreach ($invoice as $value){
            $invoice_array[$value['sales_order_id']][] = $value['logistics_number'];
        }

        return $invoice_array;
    }

    public function getDispatchData($data){
        //分社订货模板
        $search_id = [];
        foreach ($data as $value){
            if($value['state'] >= SalesOrder::State_four) $search_id[] = $value['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;
    }

    public function getOtherMoney($data){
        $fee = [];
        $sales_o_info = SalesOrderOtherFee::where('del_time',0)
            ->whereIn('sales_order_id',array_column($data,'id'))
            ->get()->toArray();
        foreach ($sales_o_info as $value){
            $fee[$value['sales_order_id']] = $value['other_fee_1'];
        }

        return $fee;
    }

    public function getStateMake($data){
        if(empty($data)) return [];

        $order_no = [];
        foreach ($data as $value){
            if(! in_array($value['state'], [SalesOrder::State_minus_one,SalesOrder::State_one])) continue;
            $order_no[] = $value['order_number'];
        }

        return (new OaService())->getOaTeamDetailList($order_no);
    }

    public function makeState($value, $state_array){
        if($value['sales_order_type'] == SalesOrder::Order_type_one){
            //安装件
            if(! empty($state_array[$value['order_number']])){
                $return = $state_array[$value['order_number']];
                if($value['state'] == SalesOrder::State_minus_one){
                    $state = "驳回:" . $return;
                }else{
                    $state = "待" . $return . "审核";
                }
            }elseif($value['state'] == SalesOrder::State_zero){
                $state = "待" . $value['crt_name'] . "提交";
            }elseif($value['state'] == SalesOrder::State_three && ! in_array($value['model_type'], [SalesOrder::Model_type_four,SalesOrder::Model_type_seven])){
                // 除线上订单 补贴订单 外 3状态即使审核通过（本来3是指派销售 除了线上订单 补贴订单 其它不需要）
                $state = SalesOrder::$state[SalesOrder::State_two] ?? '';
            }else{
                $state = SalesOrder::$state[$value['state']] ?? '';
            }
        }else{
            //快递件
            $state = SalesOrder::$state2[$value['state']] ?? '';
        }

        return $state;
    }

    public function getConstruction($sale_order_id){
        if(empty($sale_order_id)) return [];

        $result = Construction::where('del_time',0)
            ->whereIn('sales_order_id',$sale_order_id)
            ->select('order_number','sales_order_id','state','crt_id','start_time')
            ->get()->toArray();
        $emp = Employee::whereIn('crt_id',array_unique(array_column($result,'crt_id')))
            ->pluck('emp_name','id')
            ->toArray();
        $service = new ConstructionService();
        //订单状态数据组织
        $state_array = $service->getStateMake($result);

        $return = [];
        foreach ($result as $value){
            $value['crt_name'] = $emp[$value['crt_id']] ?? "";
            $state_title = $service->makeState($value, $state_array);
            $string = $value['order_number'] . " : " . $state_title;
            if(isset($return[$value['sales_order_id']])){
                $return[$value['sales_order_id']] .= ',' . $string;
            }else{
                $return[$value['sales_order_id']] = $string;
            }
        }

        return $return;
    }

    public function batchConfirm($data,$user){
        if(empty($data['order_number']) || ! is_array($data['order_number'])) return [false, '批量确认数据不正确'];

        $result = SalesOrder::where('del_time',0)
            ->whereIn('order_number',$data['order_number'])
            ->select('state','order_number','model_type')
            ->get()->toArray();
        if(empty($result)) return [false, '未找到数据'];
        $result = array_column($result,null,'order_number');

        foreach ($data['order_number'] as $value){
            if(! isset($result[$value])) return [false, $value . '不存在或已被删除'];
            $tmp =  $result[$value];
            if(! in_array($tmp['model_type'], [SalesOrder::Model_type_four,SalesOrder::Model_type_seven])) return [false, '单据'. $value . '非线上订单/补贴订单，操作失败'];
            if(! in_array($tmp['state'] , [SalesOrder::State_zero,SalesOrder::State_minus_one])) return [false, '请确认单据'. $value . '的状态，操作失败'];
        }

        SalesOrder::whereIn('order_number',$data['order_number'])->update(['state' => SalesOrder::State_two]);

        (new OrderOperationService())->batchAdd([
            'order_number' => $data['order_number'],
            'msg' => OrderOperation::$type[OrderOperation::twenty_five],
            'type' => OrderOperation::twenty_five
        ],$user);

        return [true, ''];
    }

    /**
     * 批量推送公司
     * @param $data
     * @return array
     */
    public function salesOrderBatchDispatchCompany($data,$user){
        list($status,$msg) = $this->salesOrderBatchDispatchCompanyRule($data,$user);
        if(! $status) return [false,$msg];

        try {
            $time = time();
            DB::beginTransaction();

            $sales = $msg;
            $sales_id = array_column($sales, 'id');

            SeeRange::where('del_time',0)
                ->whereIn('data_id', $sales_id)
                ->where('data_type',SeeRange::type_seven)
                ->where('type',SeeRange::data_three)
                ->update(['del_time' => $time]);
            SalesOrderOtherFee::where('del_time',0)
                ->whereIn('sales_order_id',$sales_id)
                ->update(['del_time' => $time]);
            if(! empty($data['dispatch_depart_two'])){
                $insert = [];
                foreach ($data['dispatch_depart_two'] as $value){
                    foreach ($sales_id as $v){
                        $insert[] = [
                            'data_id' => $v,
                            'data_type' => SeeRange::type_seven,
                            'param_id' => $value,
                            'type' => SeeRange::data_three,
                            'crt_time' => $time,
                        ];
                    }
                }
                SeeRange::insert($insert);
            }

            $other_fee = $notify_id = [];
            foreach ($sales as $value){
                SalesOrder::where('del_time',0)->where('id', $value['id'])->update([
                    'state' => SalesOrder::State_four,
                    'dispatch_time_second' => $time,
                    'dispatch_time_second_id' => $user['id'],
                    'type' => $value['type']
                ]);

                $other_fee[] = [
                    'sales_order_id' => $value['id'],
                    'other_fee_1' => $value['other_fee_1'],
                    'type' => $value['type'],
                ];

                if(! empty($value['notify_id'])){
                    //门店负责人不为空
                    $notify_id[] = [
                        'data_id' => $value['id'],
                        'data_type' => SeeRange::type_seven,
                        'param_id' => $value['notify_id'],
                        'type' => SeeRange::data_two,
                        'crt_time' => $time,
                    ];
                }

                if(isset($value['notify_id']) && empty($value['dispatch_time_first'])){
                    SalesOrder::where('del_time',0)->where('id',$value['id'])->update([
                        'dispatch_time_first' => $time, // 第一次派单时间记录
                    ]);
                }
            }
            if(! empty($other_fee)) SalesOrderOtherFee::insert($other_fee);
            if(! empty($notify_id)) SeeRange::insert($notify_id);

            (new OrderOperationService())->batchAdd([
                'order_number' => array_column($sales, 'order_number'),
                'msg' => OrderOperation::$type[OrderOperation::thirty_one],
                'type' => OrderOperation::thirty_one
            ],$user);

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

        $depart_id = $data['dispatch_depart_two'][0] ?? 0;
        $notify_id = Depart::where('id',$depart_id)->value('notify_id');
        $crt_id = array_column($sales,'crt_id');
        if($notify_id) $crt_id[] = $notify_id;
        $emp_name = Employee::whereIn('id',$crt_id)->pluck('emp_name','id')->toArray();
        foreach ($sales as $value){
            if(! empty($depart_id) && $depart_id != $value['top_depart_id']){
                //发送消息
                if(! empty($notify_id)){
                    $send_data[] = [
                        'employee_id' => $notify_id,
                        'type' => 1,
                        'state' => 1,
                        'menu_id' => 37,
                        'order_number' => $value['order_number'],
                        'tmp_data' => [
                            $value['order_number'],
                            $emp_name[$value['crt_id']] ?? "",
                            $emp_name[$notify_id] ?? "" . "(派单通知)",
                            date('Y-m-d H:i:s'),
                        ],
                    ];
                    (new OaService())->sendWxOaCheckMessage($send_data);
                }
            }else{
                //直接确认
                SalesOrder::where('del_time',0)->where('id',$value['id'])->update([
                    'is_confirm' => 1,
                ]);
            }
        }

        return [true,''];
    }

    /**
     * 批量推送公司规则
     * @param $data
     * @return array
     */
    public function salesOrderBatchDispatchCompanyRule(&$data,$user){
        //是总社还是分社
        if(empty($data['dispatch_depart_two'])) return [false, '请指派总社或分社'];
        $depart_id = $data['dispatch_depart_two'][0];

        //前端传参
        if(empty($data['data'])) return [false,'请选择合同派单'];

        $other_fee_1_map = [];
        foreach ($data['data'] as $value){
            if(empty($value['id'])) return [false, '合同ID不能为空'];
            if(! isset($value['type']) || ! isset(SalesOrder::$build_state[$value['type']])) return [false, '合同安装类型不存在'];
            $type = $value['type'];
            if($type <= 0) $type = SalesOrder::build_zero;
            if(! isset($value['other_fee_1'])) return [false, '合同安装金额不存在'];
            $res = $this->checkNumber($value['other_fee_1']);
            if(! $res) return [false,'金额请输入不超过两位小数并且大于等于0的数值'];
            $other_fee_1_map[$value['id']] = [
                'other_fee_1' => $value['other_fee_1'],
                'type' => $type,
            ];
        }

        //合同信息
        $sale_id = array_column($data['data'], 'id');
        $sale = SalesOrder::where('del_time',0)
            ->whereIn('id', $sale_id)
            ->get()->toArray();
        if(empty($sale)) return [false,'合同不存在或已被删除'];
        $notify_id = Depart::where('id', $depart_id)->value('notify_id');

        //组织合同数据
        foreach ($sale as $key => $value){
            if($value['del_time'] > 0) return [false,'合同:' . $value['order_number'] . '不存在或已被删除'];
            if($value['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同，操作失败'];
            if($value['state'] > SalesOrder::State_four) return [false,'请确认合同状态，操作失败'];
            if($value['state'] < SalesOrder::State_three) {
                //如果没有派销售过 找到门店负责人
                $sale[$key]['notify_id'] = $notify_id;
            }

            //合同派单信息
            $other_fee_1 = $other_fee_1_map[$value['id']] ?? [];
            $sale[$key]['other_fee_1'] = $other_fee_1['other_fee_1'];
            $sale[$key]['type'] = $other_fee_1['type'];
        }

        //校验产品
        $p_id_map = array_column($sale, 'order_number', 'id');
        $product = SalesOrderProductInfo::where('del_time',0)
            ->whereIn('sales_order_id', $sale_id)
            ->select('product_id','sales_order_id')
            ->get()->toArray();
        if(empty($product)) return [false,'合同产品不能为空'];
        $p_map = array_column($product, null, 'sales_order_id');
        foreach ($data['data'] as $value){
            if(empty($p_map[$value['id']])){
                $order_number = $p_id_map[$value['id']] ?? "";
                return [false, '合同' . $order_number . '产品不能为空'];
            }
        }

        //校验施工
        $bool = Construction::where('del_time',0)
            ->whereIn('sales_order_id', $sale_id)
            ->exists();
        if($bool) return [false,'合同已生成施工单，操作失败'];

        //产品不可见
        $product_id = array_unique(array_column($product,'product_id'));
        $return = RangeService::productNotSeeRange($product_id);

        //产品信息
        $product_array = Product::whereIn('id',$product_id)->select('title','id','build_fee')->get()->toArray();
        $map = [];
        foreach ($product_array as $value){
            $map[$value['id']] = $value['title'];
        }
        if(! empty($return)){
            foreach ($data['dispatch_depart_two'] as $value){
                foreach ($return as $key => $values){
                    $tmp = $map[$key] ?? "";
                    if(in_array($value, $values)) return [false,'产品'. $tmp .'对于该总社或分社不可见'];
                }
            }
        }

        return [true, $sale];
    }

    /**
     * 获取安装价格
     * @param $data
     * @param $user
     * @return array
     */
    public function salesOrderGetBuildFee($data,$user){
        if(empty($data['id'])) return [false,'请选择合同派单'];
        if(empty($data['top_depart_id'])) return [false,'请选择派单分社'];
        $depart = Depart::where('del_time',0)->where('id', $data['top_depart_id'])->first();
        if(empty($depart)) return [false, '分社不存在或已被删除'];
        $depart = $depart->toArray();

        $sale = SalesOrder::where('del_time',0)
            ->whereIn('id', $data['id'])
            ->get()->toArray();
        if(empty($sale)) return [false,'合同不存在或已被删除'];
        $product = SalesOrderProductInfo::where('del_time',0)
            ->whereIn('sales_order_id',$data['id'])
            ->select('product_id','number','sales_order_id')
            ->get()->toArray();
        if(empty($product)) return [false,'合同产品不能为空'];
        $product_array = Product::whereIn('id',array_unique(array_column($product, 'product_id')))
            ->select('title','id','build_fee')
            ->get()->toArray();
        $map2 = [];
        foreach ($product_array as $value){
            $map2[$value['id']] = $value['build_fee'];
        }
        // 实时 带货安装包安装
        $count = [];
        $other_fee_1 = 0;
        foreach ($product as $value){
            $build_fee = $map2[$value['product_id']] ?? 0;
            $fee = bcmul($value['number'],$build_fee,2);
            $other_fee_1 = bcadd($other_fee_1,$fee,2);

            if(isset($count[$value['sales_order_id']])){
                $tmp = bcadd($count[$value['sales_order_id']], $other_fee_1,2);
                $count[$value['sales_order_id']] = $tmp;
            }else{
                $count[$value['sales_order_id']] = $other_fee_1;
            }
        }

        $product_map = array_column($product,null,'sales_order_id');

        $return_map = [];
        foreach ($sale as $value){
            if(! isset($product_map[$value['id']])) return [false, "合同:" . $value['order_number'] . '下没有产品信息'];
            foreach (SalesOrder::$build_state as $key => $value_v){
                if($key == SalesOrder::build_minus) continue;
                if($key == SalesOrder::build_zero){
                    $rate = bcdiv($depart['rate'], 100,2);
                    $other_fee_1 = bcmul($value['contract_fee'], $rate,2);
                }elseif($key == SalesOrder::build_one){
                    $other_fee_1 = $count[$value['id']] ?? "0.00";
                }else{
                    $other_fee_1 = "0.00";
                }
                $return_map[$value['id']][$key] = [
                    'id' => $value['id'],
                    'order_number' => $value['order_number'],
                    'type' => $key,
                    'other_fee_1' => $other_fee_1,
                    'is_choose' => 0,
                ];
            }
        }

        // 已保存的
        $save = SalesOrderOtherFee::where('del_time',0)
            ->whereIn('sales_order_id', $data['id'])
            ->pluck('other_fee_1','sales_order_id')
            ->toArray();

        foreach ($sale as $value){// 填充已保存的
            if(isset($save[$value['id']][$value['type']])){
                $other_fee_1 = $save[$value['id']];
                $return_map[$value['id']][$value['type']]['other_fee_1'] = $other_fee_1;
                $return_map[$value['id']][$value['type']]['is_choose'] = 1;
            }
        }

        $return = [];
        foreach ($return_map as $value){
            foreach ($value as $v){
                $tmp = [
                    'type' => $v['type'],
                    'other_fee_1' => $v['other_fee_1'],
                    'is_choose' => $v['is_choose'],
                ];
                if(isset($return[$v['id']])){
                    $return[$v['id']]['data'][] = $tmp;
                }else{
                    $return[$v['id']] = [
                        'id' => $v['id'],
                        'order_number' => $v['order_number'],
                        'data' => [$tmp]
                    ];
                }
            }
        }

        return [true, array_values($return)];
    }

    //申请出库
    public function salesClickOut($data, $user){
        if(empty($data['id'])) return [false, '合同ID不能为空'];

        $sales = SalesOrder::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($sales)) return [false, '合同不存在或已被删除'];
        $sales = $sales->toArray();
        if($sales['state'] < SalesOrder::State_two) return [false, '合同未审核通过'];
        if($sales['out_state'] > SalesOrder::out_zero) return [false, '合同已出库'];

        try {
            DB::beginTransaction();

            SalesOrder::where('id',$sales['id'])->update(['out_state' => SalesOrder::out_one]);

            (new OrderOperationService())->add([
                'order_number' => $sales['order_number'],
                'msg' => OrderOperation::$type[OrderOperation::thirty_two],
                'type' => OrderOperation::thirty_two
            ],$user);

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

        return [true, ''];
    }

    public function salesOrderPdf($data, $user){
        list($status, $msg) = $this->detail($data, $user);
        if(! $status) return [false, $msg];
        $order = $msg;
        $num = $total = 0;
        foreach (array_column($order['product'], 'number') as $value) {
            $num = bcadd($num, $value, 2);
        }
        foreach (array_column($order['product'], 'final_amount') as $value) {
            $total = bcadd($total, $value, 2);
        }
        $order['product_sum'] = [
            'num' => $num,
            'total' => $total,
        ];

        $num = $total = 0;
        foreach (array_column($order['activity_product'], 'number') as $value) {
            $num = bcadd($num, $value, 2);
        }
        foreach (array_column($order['activity_product'], 'final_amount') as $value) {
            $total = bcadd($total, $value, 2);
        }
        $order['activity_product_sum'] = [
            'num' => $num,
            'total' => $total,
        ];

        $pdf = app('dompdf.wrapper')->loadView('pdf.salesOrder', ['order' => $order]);
        $file_name = time().rand(1000,9999);
        $filename =  '合同_' . $file_name.'.' . 'pdf';
        $pdf->save(storage_path('app/public/export/' . $filename));

        return [true, ['file' => $filename]];
    }

    public function getSalesProductCK($sales_id = []){
        if(empty($sales_id)) return [];

        $sales_id = SalesOrder::whereIn('id',$sales_id)
            ->where('out_state',SalesOrder::out_one)
            ->select('id')
            ->get()->toArray();
        $sales_id = array_column($sales_id,'id');

        //销售订单对应产品总数
        $product = SalesOrderProductInfo::where('del_time',0)
            ->where('sales_order_id', $sales_id)
            ->select('number', 'sales_order_id')
            ->get()->toArray();
        $product_sale_map = [];
        foreach ($product as $value){
            $key = $value['sales_order_id'];
            if(isset($product_sale_map[$key])){
                $number = bcadd($value['number'], $product_sale_map[$key],2);
                $product_sale_map[$key] = $number;
            }else{
                $product_sale_map[$key] = $value['number'];
            }
        }

        //合同出库产品总数
        $product_map = [];
        $save = OutBoundOrderInfo::where('del_time',0)
            ->where('type', OutBoundOrderInfo::type_one)
            ->where('data_id', $sales_id)
            ->select('number', 'data_id as sales_order_id','return_number')
            ->get()->toArray();
        foreach ($save as $value){
            $key = $value['sales_order_id'];
            if(isset($product_map[$key])){
                $number = bcadd($value['number'], $product_map[$key]['number'],2);
                $return_number = bcadd($value['return_number'], $product_map[$key]['return_number'],2);
                $product_map[$key]['number'] = $number;
                $product_map[$key]['return_number'] = $return_number;
            }else{
                $product_map[$key]['number'] = $value['number'];
                $product_map[$key]['return_number'] = $value['return_number'];
            }
        }

        //合同退货产品
        $product_map2 = [];
        $return_id = ReturnExchangeOrder::where('del_time',0)
            ->where('type', ReturnExchangeOrder::Order_type)
            ->where('model_type', ReturnExchangeOrder::Model_type_one)
            ->whereIn('data_id', $sales_id)
            ->select('id','data_id as sales_order_id')
            ->get()->toArray();
        $return_map = array_column($return_id,'sales_order_id','id');
        $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
            ->whereIn('return_exchange_id', array_column($return_id,'id'))
            ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
            ->select('number', 'return_exchange_id')
            ->get()->toArray();
        foreach ($save2 as $value){
            $sales_order_tmp = $return_map[$value['return_exchange_id']] ?? 0;
            if(! $sales_order_tmp) continue;

            $key = $sales_order_tmp;
            if(isset($product_map2[$key])){
                $number = bcadd($value['number'], $product_map2[$key],2);
                $product_map2[$key] = $number;
            }else{
                $product_map2[$key] = $value['number'];
            }
        }

        $return = [];
        //未出库 0 未完全出库 1 已完全出库 2
        foreach ($product_sale_map as $key => $value){
            //合同出库产品总数
            $p1 = $product_map[$key] ?? [];
            //合同出库产品数量
            $p1_number = $p1['number'] ?? 0;
            //合同出库后退货产品数量
            $p1_return_number = $p1['return_number'] ?? 0;
            //出库数量 - 退货数量 = 已出数量
            $p_re = bcsub($p1_number,$p1_return_number,2);

            //合同退货产品
            $p2 = $product_map2[$key] ?? 0;
            $p2_re = bcsub($p2,$p1_return_number,2);
            //合同 - 已出 - 退货 = 剩余能出
            $number = bcsub(bcsub($value['number'], $p_re,2), $p2_re,2);

            if($p_re > 0) {
                if($number <= 0){
                    $return_id[$value['sales_order_id']] = "已出库";
                }else{
                    $return_id[$value['sales_order_id']] = "未完全出库";
                }
            }else{
                if($number <= 0){
                    $return_id[$value['sales_order_id']] = "已退货";
                }else{
                    $return_id[$value['sales_order_id']] = "未出库";
                }
            }

            if(! $p1){
                $return_id[$value['sales_order_id']] = "未出库";
            }elseif($p1 == $value['number']){
                $return_id[$value['sales_order_id']] = "已完全出库";
            }elseif($p1 < $value['number']){
                $number = bcsub(bcsub($value['number'], $p1,2), $p2,2);
                if($number <= 0) {
                    $return_id[$value['sales_order_id']] = "已完全出库";
                }else{
                    $return_id[$value['sales_order_id']] = "未完全出库";
                }
            }else{
                $return_id[$value['sales_order_id']] = "已完全出库";
            }
        }

        return $return;
    }

    public function getSalesProductForWarranty($sales_id = 0){
        if(empty($sales_id)) return [];

        //销售订单对应产品总数
        $product = SalesOrderProductInfo::from('sales_order_product_info as a')
            ->join('product as b','a.product_id','b.id')
            ->where('a.del_time',0)
            ->where('a.sales_order_id', $sales_id)
            ->where('b.warranty_time', '>', 0)
            ->select('a.number','a.product_id','b.code','b.product_category','b.title','b.warranty_time')
            ->get()->toArray();
        if(empty($product)) return [];
        $product_id = array_column($product,'product_id');

        //合同质保产品
        $sn_product = ProductSnInfo::where("del_time",0)
            ->where('data_id', $sales_id)
            ->where('type',ProductSnInfo::type_two)
            ->whereIn('product_id',$product_id)
            ->select('product_id')
            ->get()->toArray();
        $product_map1 = [];
        foreach ($sn_product as $value){
            $key = $value['product_id'];
            if(isset($product_map1[$key])){
                $number = bcadd(1, $product_map1[$key],2);
                $product_map1[$key] = $number;
            }else{
                $product_map1[$key] = 1;
            }
        }

        //合同退货产品
        $product_map2 = [];
        $return_id = ReturnExchangeOrder::where('del_time',0)
            ->where('type', ReturnExchangeOrder::Order_type)
            ->where('model_type', ReturnExchangeOrder::Model_type_one)
            ->where('data_id', $sales_id)
            ->select('id')
            ->get()->toArray();
        $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
            ->whereIn('return_exchange_id', array_column($return_id,'id'))
            ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
            ->select('number', 'return_exchange_id','product_id')
            ->get()->toArray();
        foreach ($save2 as $value){
            $key = $value['product_id'];
            if(isset($product_map2[$key])){
                $number = bcadd($value['number'], $product_map2[$key],2);
                $product_map2[$key] = $number;
            }else{
                $product_map2[$key] = $value['number'];
            }
        }

        $return = [];
        $service = new DataSyncToU8Service();
        foreach ($product as $key => $value){
            $bool = $service->forCheck($value['product_category']);
            //车窗膜不管数量算一个
            if($bool) $value['number'] = 1;

            $sn_tmp = $product_map1[$value['product_id']] ?? 0;
            $return_tmp = $product_map2[$value['product_id']] ?? 0;

            $number = bcsub($value['number'], $sn_tmp,2);
            $number = bcsub($number, $return_tmp,2);
            if($number <= 0) unset($product[$key]);

            $return[$value['product_id']] = $value;
            $return[$value['product_id']]['number'] = $number;
        }

        return $return;
    }
}