hcsl/app/Service/Box/BoxService.php

<?php

namespace App\Service\Box;

use App\Jobs\BoxAddJob;
use App\Model\ApplyOrder;
use App\Model\ApplyOrderForYy;
use App\Model\Box;
use App\Model\BoxDetail;
use App\Model\DispatchSub;
use App\Model\EmployeeTeamPermission;
use App\Model\Header_ext;
use App\Model\OrdersProduct;
use App\Model\OrdersProductProcess;
use App\Model\ReportWorking;
use App\Model\ReportWorkingDetail;
use App\Model\SaleOrdersProduct;
use App\Model\ScrappCount;
use App\Model\Setting;
use App\Model\Team;
use App\Service\ApplyOrderService;
use App\Service\EmployeeService;
use App\Service\FinishedOrderService;
use App\Service\FyyOrderService;
use App\Service\FyySqlServerService;
use App\Service\Service;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * 包装相关
 * @package App\Models
 */
class BoxService extends Service
{

    protected static $instance;
    protected static $box_header;
    protected static $box_detail_header;
    protected static $box_hook;
    public $lock_key = 'hc_box_new_add';

    public function __construct()
    {
        self::$box_header = Header_ext::where('type', 'box')->pluck('value', 'key')->toArray();
        self::$box_detail_header = Header_ext::where('type', 'box_detail')->pluck('value', 'key')->toArray();
        self::$box_hook = BoxHookService::getInstance();
    }

    public function boxIn($data,$user)
    {
        list($status, $msg) = $this->boxInRule($data, $user);
        if(! $status) return [false, $msg];

        $data['zt'] = Request()->header('zt');
//list($status, $msg) = $this->boxInSettle($data,$user);dd($status,$msg);
        //限制频率
        $limit_key = $this->lock_key;
        list($status,$msg) = $this->limitingSendRequestBackgNeed($limit_key);
        if(! $status) return [false, '请稍后操作'];

        $job = BoxAddJob::dispatch($data,$user)->onQueue(BoxAddJob::job);
        if(! $job) {
            $this->dellimitingSendRequestBackgNeed($limit_key);
            return [false,'任务未进入后台队列，请联系管理员'];
        }

        return [true, ''];
    }

    public function boxInRule($data,$user)
    {
        try{
            $ids = [];
            $sale_ids = [];
            $data = $data['param'];
            $key_list = [];
            foreach ($data as $v) {
                if($v['id'] < 0)  $sale_ids[] = -$v['id'];
                else $ids[] = $v['id'];
                if($v['id'] < 0) $v['id'] = -$v['id'];
                $total = 0;
                foreach ($v['params'] as $vv) {
                    $total += $vv;
                }
                $key_list[$v['id']] = [
                    'detail' => $v['params'],
                    'total' => $total,
                    'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
                ];
            }

            //数据获取
            $product_list = OrdersProduct::wherein('id', $ids)->get()->toArray();

            //校验
            $flag = "";
            foreach ($product_list as $value){
                $key = $value['out_order_no'] . $value['product_no'] . $value['technology_name'];
                if(! empty($flag)){
                    if($flag != $key) return [false , "一次包装只允许包一种产品的一种颜色！"];
                }else{
                    $flag = $key;
                }
                $num_list = $key_list[$value['id']];
                $total = $num_list['total'];
                $un_box_num = bcsub($value['dispatch_complete_quantity'] , $value['box_num'],3);
                if ($total > $un_box_num) return [false, $value['product_title'] . ' ' . $value['technology_name'] . ' 可包装的数量不足'];
            }

            return [true, ''];
        }catch (\Throwable $e){
            return [false,$e->getFile() . '|' . $e->getLine(). '|' .$e->getMessage()];
        }
    }

    public function boxInSettle($data, $user){
        //设置数据库连接
        $this->setConnect($data);
        $zt = $data['zt'] ?? "";

        $ids = [];
        $sale_ids = [];
        $top_order_no = $data['order_no'];
        $box_no = isset($data['box_no']) ? $data['box_no'] : '';
        $transport_no = isset($data['transport_no']) ? $data['transport_no'] : '';
        $data = $data['param'];
        $key_list = [];
        foreach ($data as $v) {
            if($v['id'] < 0)  $sale_ids[] = -$v['id'];
            else $ids[] = $v['id'];
            if($v['id'] < 0) $v['id'] = -$v['id'];
            $total = 0;

            foreach ($v['params'] as $vv) {
                $total += $vv;
            }
            $key_list[$v['id']] = [
                'detail' => $v['params'],
                'total' => $total,
                'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
            ];
        }
        $insert = [];

        //锁
        $limit_key = $this->lock_key;
        try{
            DB::beginTransaction();

            //数据获取
            $product_list = OrdersProduct::whereIn('id', $ids)->get()->toArray();
            $sale_product_list = SaleOrdersProduct::whereIn('id', $sale_ids)->get()->toArray();

            //生产订单包装----------------
            $box_insert = [];
            foreach ($product_list as $v) {
                $num_list = $key_list[$v['id']];
                $total = $num_list['total'];
                $detail = $num_list['detail'];
                $team_id = $num_list['team_id'];

                $ext_1 = $v['product_no'];//产品编号
                $ext_2 = $v['technology_material']; //工艺材质 废弃
                $ext_3 = $v['technology_name'];//工艺名称 改为颜色
                $ext_4 = $v['wood_name'];//木皮 废弃
                $ext_5 = $v['process_mark'];//工艺备注 废弃
                $ext_8 = $v['product_title'];//产品名称

                $out_order_no = $insert['out_order_no'] = $v['out_order_no'];
                $top_id = $v['sale_orders_product_id'];
                foreach ($detail as $vv){
                    $box_insert[] = [
                        'out_order_no' => $out_order_no,
                        'top_id' => $top_id,
                        'orders_product_id' => $v['id'],
                        'ext_1' => $ext_1,//产品编号
                        'ext_2' => $ext_2,
                        'ext_3' => $ext_3,//颜色
                        'ext_4' => $ext_4,
                        'ext_5' => $ext_5,
                        'ext_8' => $ext_8,//产品名称
                        'num' => $vv,
                        'price' => $v['price'],
                        'box_type' => 1,
                        'team_id' => $team_id,
                        'shipment_order_no' => $transport_no,
                    ];
                }
                //修改销售订单  生产订单 包装数量
                SaleOrdersProduct::where('id',$v['sale_orders_product_id'])->update([
                    'box_num' => DB::raw('box_num + '.$total),
                ]);
                OrdersProduct::where('id',$v['id'])->update([
                    'box_num' => DB::raw('box_num + '.$total),
                ]);
            }

            //客户名称
            $ext_1 = "";
            if(empty($ext_1) && isset($sale_product_list[0]['customer_name'])) $ext_1 = $sale_product_list[0]['customer_name'];
            if(empty($ext_1) && isset($product_list[0]['customer_name'])) $ext_1 = $product_list[0]['customer_name'];
            $insert['ext_1'] = $ext_1;
            $insert['detail'] = $box_insert;
            $insert['top_order_no'] = $top_order_no;
            $insert['order_no'] = $box_no;
            $insert['shipment_order_no'] = $transport_no;
            //生成包装单
            list($status,$msg) = self::$box_hook->boxInsert($insert,$user);
            if(! $status) {
                $this->dellimitingSendRequestBackgNeed($limit_key);
                DB::rollBack();
                return [false, $msg];
            }

            //反写数量
            $em = new EmployeeService();
            $auto = $em->is_auto($user, "bzwg_auto");
            if($auto){
                list($status, $msg1) = $this->updateFinishNew($product_list,$key_list,$user);
                if(! $status) {
                    $this->dellimitingSendRequestBackgNeed($limit_key);
                    DB::rollBack();
                    return [false, $msg1];
                }
            }

            //包装单
            $package_data = $msg->toArray();
            //包装单产品
            $boxDetail = new BoxDetail(['channel'=>$package_data['top_order_no']]);
            $boxDetail = $boxDetail->where('del_time',0)
                ->where('order_no',$package_data['order_no'])
                ->select('ext_1 as product_no', 'ext_3 as technology_name', 'ext_8 as product_title', 'ext_9 as product_size', 'num as quantity')
                ->get()->toArray();

            //生成包装领料申请单
            list($status, $msg1) = $this->createllSQ($package_data,$boxDetail, $user);
            if(! $status) {
                $this->dellimitingSendRequestBackgNeed($limit_key);
                DB::rollBack();
                return [false, $msg1];
            }

            //生成包装入库申请单
            list($status, $msg) = $this->createBZSQ($package_data,$boxDetail, $user);
            if(! $status) {
                $this->dellimitingSendRequestBackgNeed($limit_key);
                DB::rollBack();
                return [false, $msg];
            }

            //是否自动审核  包装入库申请单 如果是测试的不写用友
            $auto = $em->is_auto($user,"bzsq_auto");
            if(! empty($package_data) && $auto && $zt != 'cs') {
                //用友 ------产成品入库
                $service = new FinishedOrderService();
                list($status,$msg) = $service->U8Rdrecord10Save($package_data,$user);
                if(! $status) {
                    $this->dellimitingSendRequestBackgNeed($limit_key);
                    DB::rollBack();
                    return [false, $msg];
                }
            }

            DB::commit();

            $this->dellimitingSendRequestBackgNeed($limit_key);

            return [true, ['package_data' => $package_data]];
        }catch (\Throwable $e){
            DB::rollBack();
            $this->dellimitingSendRequestBackgNeed($limit_key);
            if (str_contains($e->getMessage(), '1062') || str_contains($e->getMessage(), 'Duplicate entry')) {
                return [false, '网络波动，请重新操作！'];
            }
            return [false, $e->getFile(). '|' .$e->getLine().'|'.$e->getMessage()];
        }
    }

    private function setConnect($data){
        $storeCode = $data['zt'] ?? '';
        $connectionName = "mysql";
        if($storeCode == 'cs') $connectionName = "mysql_" . $storeCode;

        if (in_array($connectionName, array_keys(config('database.connections')))) {
            // 切换默认数据库连接
            config(['database.default' => $connectionName]);

            // 重新解析 DB Facade 使用新的连接
            app()->forgetInstance('db');
            $db = app('db');

            // 如果用到了模型，还要重置模型连接
            \Illuminate\Database\Eloquent\Model::setConnectionResolver($db);
        }
    }

    public function createllSQ($package_data, $insert_id, $user){
        //是否自动审核  包装领料申请单
        $em = new EmployeeService();
        $auto = $em->is_auto($user,"bzllsq_auto");

        $return = [];
        $product_no = array_unique(array_column($insert_id,'product_no'));
        //获取包装原料
        $service = new FyyOrderService();
        list($status, $msg) = $service->getProductBzDataFromSqlServer(['product_no' => $product_no], $user);
        if($status) $return = $msg;

        //组织包装原材料写入数据
        $insert = [];
        $box_id = $package_data['id'] ?? 0;
        foreach ($insert_id as $value){
            $t = $return[$value['product_no']] ?? [];
            $tmp = [
                'id' => $box_id,
                'quantity' => $value['quantity'] ?? 0,
                'product_no' => "",
                'product_title' => "",
                'product_size' => "",
                'product_unit' => "",
                'top_product_no' => $value['product_no'],
                'top_product_title' => $value['product_title'],
                'technology_name' => $value['technology_name'],
            ];
            if(! empty($t)){
                foreach ($t as $v){
                    $tmp['product_no'] = $v['product_no'];
                    $tmp['product_title'] = $v['product_title'];
                    $tmp['product_size'] = $v['product_size'];
                    $tmp['product_unit'] = $v['product_unit'];
                    $insert[] = $tmp;
                }
            }else{
                $tmp['quantity'] = 0;
                $insert[] = $tmp;
            }
        }

        try {
            DB::beginTransaction();

            //生成申请单
            $service = new ApplyOrderService();
            list($status, $msg) = $service->createSQ($insert, $user, ApplyOrder::type_four, $auto);
            if(! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            if($auto) {
                //生成流水
                list($status, $msg) = $service->createRecord($msg);
                if(! $status) {
                    DB::rollBack();
                    return [false, $msg];
                }
            }

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

        return [true, ''];
    }

    public function createBZSQ($package_data, $insert_id, $user){
        //是否自动审核  包装入库申请单
        $em = new EmployeeService();
        $auto = $em->is_auto($user,"bzsq_auto");

        try {
            DB::beginTransaction();

            $box_id = $package_data['id'] ?? 0;
            foreach ($insert_id as $key => $value){
                $insert_id[$key]['id'] = $box_id;
            }

            //生成申请单
            $service = new ApplyOrderService();
            list($status, $msg) = $service->createSQ($insert_id, $user, ApplyOrder::type_three, $auto);
            if(! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            //用友写入数据信息
            $apply_order_id = $msg;
            ApplyOrderForYy::insert([
                'apply_order_id' => $apply_order_id,
                'crt_time' => time(),
                'post' => json_encode($package_data),
            ]);

            if($auto) {
                //生成流水
                list($status, $msg) = $service->createRecord($msg);
                if(! $status) {
                    DB::rollBack();
                    return [false, $msg];
                }
            }

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

        return [true, ''];
    }

    public function delBoxLock(){
        $this->dellimitingSendRequestBackgNeed($this->lock_key);
    }

    //新的完工
    public function updateFinishNew($production_list = [], $map, $user){
        if(empty($production_list)) return [true, ''];

        $order_product_id = array_column($production_list,'id');
        $order = OrdersProduct::where('del_time',0)
            ->where('id', $order_product_id)
            ->select('id', 'process_id')
            ->get()->toArray();
        $order_map = [];
        //生产订单 =》 工序
        foreach ($order as $value){
            $order_map[$value['id']] = explode(',', $value['process_id']);
        }

        //组织派工数据
        $dispatch = DispatchSub::where('del_time',0)
            ->whereIn('order_product_id', array_column($production_list,'id'))
            ->get()->toArray();
        if(empty($dispatch)) return [true,''];
        $sale_order_id = array_unique(array_column($dispatch,'sale_orders_product_id'));
        $dispatch_map = [];
        foreach ($dispatch as $value){
            $key = $value['order_product_id'] . '|' .  $value['crt_time']; //同一次下的派工单
            $dispatch_map[$key][] = $value;
        }
        $result = []; $tmp = [];
        foreach ($dispatch_map as $key => $value){
            $dispatch_quantity = array_sum(array_column($value, 'dispatch_quantity'));
            $finished_num = array_sum(array_column($value, 'finished_num'));
            //同一批派工 且 全部完工的 跳过
            if($dispatch_quantity == $finished_num) continue;
            $order_id = explode('|', $key)[0];
            // 生产订单id存在 跳过（原因 同一个生产订单可能下多次派工，那么这一次包装数量只需要一次派工的数据）
            if(in_array($order_id, $tmp)) continue;
            foreach ($value as $val){
                $num = bcadd($val['finished_num'], $val['waste_num'], 3);
                if($num >= $val['dispatch_quantity']) continue; //某一个工序完工
                //包装数量
                $tmp_num = $map[$val['order_product_id']]['total'] ?? 0;
                if($tmp_num <= 0) continue;
                $tmp_num2 = bcsub($val['dispatch_quantity'] , $val['finished_num'],3);
                if($tmp_num2 >= $tmp_num){
                    $val['quantity'] = $tmp_num;
                }else{
                    $val['quantity'] = $tmp_num2;
                }
                $result[] = $val;
                $tmp[] = $order_id;
            }
        }
        if(empty($result)) return [true,''];

        try {
            DB::beginTransaction();

            //班组下的人
            $team_man = [];
            $team_array = EmployeeTeamPermission::select('employee_id','team_id')->get()->toArray();
            foreach ($team_array as $value){
                //拿班组里的一个人
                if(! isset($team_man[$value['team_id']]))  $team_man[$value['team_id']] = $value['employee_id'];
            }
            //工序 班组
            $process_map = [
                12 => 65,
                11 => 66,
                15 => 69,
                14 => 67,
                13 => 68,
            ];

            $service = new FinishedOrderService();
            $service1 = new ApplyOrderService();
            $dispatch_time = $c_time = $result[0]['crt_time']; //派工单创建时间
            $date = date("Ymd", $c_time);
//            //派工和包装不在同一天 质检单日期加一天
//            if($date != date("Ymd")){
//                $c_time = strtotime("+1 day", strtotime($date));
//                $date = date("Ymd", $c_time);
//            }
            $max_id = $service1->getDailyId($c_time);

            //是否需要质检
            list($status, $return) = $service->isNeedZJ($sale_order_id);
            $flag = $return;
            //根据派工数据组织
            $last_update = $last_update2 = $str_tmp = $insert = $get_order_number = [];
            foreach ($result as $value){
                $need_zj_process = $flag[$value['sale_orders_product_id']] ?? 0;
                $bad_quantity = $scrapp_id = $for_r = 0;
                $warehouse_no = $warehouse_title = "";
                if(! empty($need_zj_process) && $value['process_id'] == $need_zj_process){
                    $numbers = [0.08, 0.09, 0.1, 0.11, 0.12];
                    $bad_quantity = $numbers[array_rand($numbers)];
                    $flag[$value['sale_orders_product_id']] = 0;
                    if($need_zj_process == 12){
                        $scrapp_id = 19;
                        $for_r = ReportWorking::type_two;
                        $warehouse_no = "005";
                        $warehouse_title = "报废仓";
                    }else{
                        $scrapp_id = mt_rand(10, 18);
                        $for_r = ReportWorking::type_one;
                    }
                }
                $quantity = bcsub($value['quantity'], $bad_quantity, 3);

                //质检
                $max_id += 1;
                $order_number = $date . str_pad($max_id,3,'0',STR_PAD_LEFT);
                $get_order_number[] = $order_number;
                $insert[] = [
                    'sale_orders_product_id' => $value['sale_orders_product_id'],
                    'order_product_id' => $value['order_product_id'],
                    'dispatch_sub_id' => $value['id'],
                    'out_order_no' => $value['out_order_no'],
                    'order_no' => $value['order_no'],
                    'customer_no' => $value['customer_no'],
                    'customer_name' => $value['customer_name'],
                    'product_no' => $value['product_no'],
                    'product_title' => $value['product_title'],
                    'product_size' => $value['product_size'],
                    'product_unit' => $value['product_unit'],
                    'technology_material' => $value['technology_material'],
                    'technology_name' => $value['technology_name'],
                    'wood_name' => $value['wood_name'],
                    'price' => $value['price'],
                    'process_mark' => $value['process_mark'],
                    'table_body_mark' => $value['table_body_mark'],
                    'table_header_mark' => $value['table_header_mark'],
                    'crt_id' => $user['id'],
                    'crt_time' => $c_time,
                    'scrapp_num' => $bad_quantity,
                    'scrapp_id' => $scrapp_id,
                    'team_id' => 73,
                    'finished_id' => $user['id'],
                    'equipment_id' => $value['device_id'],
                    'order_number' => $order_number,
                    'process_id' => $value['process_id'],
                    'quantity' => $quantity,
                    'report_id' => 0,
                    'result' => $for_r,
                    'warehouse_no' => $warehouse_no,
                    'warehouse_title' => $warehouse_title,
                    'daily_id' => $max_id,
                ];

                $tmp = [
                    'id' => $value['id'],
                    'quantity' => $value['quantity'],
                    'product_no' => $value['product_no'] ?? "",
                    'product_title' => $value['product_title'] ?? "",
                    'product_size' => $value['product_size'] ?? "",
                    'product_unit' => $value['product_unit'] ?? "",
                ];
                $str = $value['order_product_id'] . $value['crt_time'] . $value['product_no'] . $value['technology_name'];
                if(! in_array($str, $str_tmp)){
                    $last_update[] = $tmp;
                    $str_tmp[] = $str;
                }

                $tmp['process_id'] = $value['process_id'];
                $tmp['quantity'] = $quantity;
                $team_tmp = $process_map[$value['process_id']] ?? 0; // 班组
                $t_m = $team_man[$team_tmp] ?? 0; //班组下的人
                $tmp['finished_id'] = $t_m;
                $tmp['team_id'] = $team_tmp;
                $last_update2[] = $tmp;
            }

            //生成报工单
            list($status, $msg) = $this->createbg($last_update2, $user,$dispatch_time);
            if(! $status) return [false, $msg];
            //报工单id数组
            list($report_id, $report_order_number) = $msg;
            if(empty($report_id)) return [false, '报工单返回信息异常'];
            //根据报工单创建质检单
            list($status,$msg) = $service->createZJFirst($report_id, $insert);
            if(! $status) return [false, $msg];
            //生成因为有不良品需要的返工的业务单据
            list($status, $msg) = $service->createZJSecond($get_order_number, $user, $dispatch_time, $c_time,$max_id,$team_man,$report_order_number);
            if(! $status) return [false, $msg];
            $get_order_number_result = $msg;
            //生成完工入库申请单
            list($status, $msg) = $this->createWGSQ($last_update, $user, $c_time);
            if(! $status) return [false, $msg];

            //反写 根据质检单上的派工单id 反写上游单据
            $this->writeDispatchQuantity($get_order_number_result);

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

        return [true, ''];
    }

    public function createbg($insert, $user,$dispatch_time = 0, $order_number = ""){
        //报工单
        $em = new EmployeeService();
        $auto = $em->is_auto($user, "wgbg_auto");

        if(empty($order_number)){
            $order_number = (new ApplyOrderService())->setOrderNO2($dispatch_time);
            if(empty($order_number)) return [false, '报工单编号生成失败'];
            $is_first = true;
        }else{
            $is_first = false;
        }

        try {
            DB::beginTransaction();

            if(empty($dispatch_time)){
                $time = time();
            }else{
                $time = $dispatch_time;
            }

            $prefix = substr($order_number, 0, -3);// "20250611"
            $startNum = (int)substr($order_number, -3); // 7
            $return = $get_order_number = [];
            foreach ($insert as $v){
                if(! $is_first){
                    $startNum += 1;
                    $number = str_pad($startNum,3,'0',STR_PAD_LEFT);
                    $number = $prefix . $number;
                    $dispatch_no_t = $number;
                }else{
                    $dispatch_no_t = $order_number;
                    $is_first = false;
                }
                $get_order_number[] = $dispatch_no_t;
                $model = new ReportWorking();
                $model->order_number = $dispatch_no_t;
                $model->report_time = $time;
                $model->crt_id = $user['id'];
                $model->status = $auto;
                $model->save();
                $id = $model->id;

                ReportWorkingDetail::insert([
                    'report_working_id' => $id,
                    'data_id' => $v['id'],
                    'quantity' => $v['quantity'] ?? 0,
                    'finished_id' => $v['finished_id'] ?? 0,
                    'process_id' => $v['process_id'] ?? 0,
                    'team_id' => $v['team_id'] ?? 0,
                    'crt_time' => $time,
                ]);

                $return[$v['id']] = $id;
            }

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

        return [true, [$return, $get_order_number]];
    }

    //反写
    public function writeDispatchQuantity($get_order_number_result){
        $result = ScrappCount::whereIn('order_number',$get_order_number_result)
            ->select('dispatch_sub_id','quantity','scrapp_num as num','crt_time','process_id','order_product_id')
            ->get()->toArray();

        //是否最后一道工序
        $orders = OrdersProduct::whereIn('id', array_unique(array_column($result, 'order_product_id')))
            ->select('id','process_id')
            ->get()->toArray();
        $map = [];
        foreach ($orders as $value){
            $p = explode(",", $value['process_id']);
            $lastElement = end($p);
            $map[$value['id']] = $lastElement;
        }

        //汇总这个派工单一共质检良品数量 但是同一时间下的 只取一次
        $update = $flag = $need_update = [];
        foreach ($result as $value){
            if(isset($map[$value['order_product_id']]) && $map[$value['order_product_id']] == $value['process_id'] && ! in_array($value['order_product_id'], $need_update)){
                $need_update[] = [
                    'order_product_id' => $value['order_product_id'],
                    'process_id' => $value['process_id'],
                ];
            }
            $key = $value['dispatch_sub_id'] . $value['crt_time'];
            if(isset($flag[$key])) continue;

            if(isset($update[$value['dispatch_sub_id']])){
                $tmp = bcadd($value['quantity'], $update[$value['dispatch_sub_id']]['finished_num'], 3);
                $tmp1 = bcadd($value['num'], $update[$value['dispatch_sub_id']]['waste_num'], 3);
                $update[$value['dispatch_sub_id']] = [
                    'finished_num' => $tmp,
                    'waste_num' => $tmp1,
                ];
            }else{
                $update[$value['dispatch_sub_id']] = [
                    'finished_num' => $value['quantity'],
                    'waste_num' => $value['num'],
                ];
            }
            $flag[$key] = 1;
        }
        unset($flag);

        //更新派工单完工数量----------------------------------------------------
        foreach ($update as $id => $value){
            DispatchSub::where('id', $id)->update([
                'finished_num' => DB::raw('finished_num + '.$value['finished_num']),
                'waste_num' => DB::raw('waste_num + '.$value['waste_num']),
            ]);
        }

        if(! empty($need_update)){
            //更新生产订单的完工数量--------------------------------------------------
            $list = DispatchSub::where("del_time",0)
                ->when(! empty($need_update), function ($query) use ($need_update) {
                    return $query->where(function ($q) use ($need_update) {
                        foreach ($need_update as $value) {
                            $order_product_id = $value['order_product_id'];
                            $process_id = $value['process_id'];
                            $q->orWhere(function ($subQ) use ($order_product_id, $process_id) {
                                $subQ->where('order_product_id', $order_product_id)
                                    ->where('process_id', $process_id);
                            });
                        }
                    });
                })
                ->select('order_product_id', 'finished_num', 'sale_orders_product_id')
                ->get()->toArray();
            $map2 = [];
            foreach ($list as $value){
                if(isset($map2[$value['order_product_id']])){
                    $tmp = bcadd($map2[$value['order_product_id']], $value['finished_num'], 3);
                    $map2[$value['order_product_id']] = $tmp;
                }else{
                    $map2[$value['order_product_id']] = $value['finished_num'];
                }
            }
            foreach ($map2 as $id => $num){
                OrdersProduct::where('id', $id)->update([
                    'finished_num' => $num
                ]);
            }

            //更新销售订单完工数量-------------------------------------------------------
            $list2 = OrdersProduct::where('del_time',0)
                ->whereIn('sale_orders_product_id', array_unique(array_column($list, 'sale_orders_product_id')))
                ->select('finished_num','sale_orders_product_id')
                ->get()->toArray();
            $map3 = [];
            foreach ($list2 as $value){
                if(isset($map3[$value['sale_orders_product_id']])){
                    $tmp = bcadd($map3[$value['sale_orders_product_id']], $value['finished_num'], 3);
                    $map3[$value['sale_orders_product_id']] = $tmp;
                }else{
                    $map3[$value['sale_orders_product_id']] = $value['finished_num'];
                }
            }
            foreach ($map3 as $id => $num){
                SaleOrdersProduct::where('id', $id)->update([
                    'finished_num' => $num
                ]);
            }
        }
    }

    //旧的完工
    public function updateFinish($production_list = [], $map,$user){
        if(empty($production_list)) return [true,''];

        $order_product_id = array_column($production_list,'id');
        $order = OrdersProduct::where('del_time',0)
            ->where('id', $order_product_id)
            ->select('id', 'process_id')
            ->get()->toArray();
        $order_map = [];
        foreach ($order as $value){
            $order_map[$value['id']] = explode(',', $value['process_id']);
        }

        //组织派工数据
        $dispatch = DispatchSub::where('del_time',0)
            ->whereIn('order_product_id', array_column($production_list,'id'))
            ->get()->toArray();
        if(empty($dispatch)) return [true,''];
        $dispatch_map = [];
        foreach ($dispatch as $value){
            $key = $value['order_product_id'] . '|' .  $value['crt_time']; //同一次下的派工单
            $dispatch_map[$key][] = $value;
        }
        $result = []; $tmp = [];
        foreach ($dispatch_map as $key => $value){
            $dispatch_quantity = array_sum(array_column($value, 'dispatch_quantity'));
            $finished_num = array_sum(array_column($value, 'finished_num'));
            if($dispatch_quantity == $finished_num) continue; //同一批派工 且 全部完工的 跳过
            $order_id = explode('|', $key)[0];
            if(in_array($order_id, $tmp)) continue;// 生产订单id存在 跳过
            foreach ($value as $val){
                if($val['dispatch_quantity'] <= $val['finished_num']) continue; //某一个工序完工
                //包装数量
                $tmp_num = $map[$val['order_product_id']]['total'] ?? 0;
                if($tmp_num <= 0) continue;
                $tmp_num2 = bcsub($val['dispatch_quantity'] , $val['finished_num'],3);
                if($tmp_num2 >= $tmp_num){
                    $val['quantity'] = $tmp_num;
                }else{
                    $val['quantity'] = $tmp_num2;
                }
                $result[] = $val;
                $tmp[] = $order_id;
            }
        }
        if(empty($result)) return [true,''];
        $time = time();

        try {
            DB::beginTransaction();

            //班组下的人
            $team_man = [];
            $team_array = EmployeeTeamPermission::select('employee_id','team_id')->get()->toArray();
            foreach ($team_array as $value){
                $team_man[$value['team_id']][] = $value['employee_id'];
            }
            //工序 班组
            $process_map = [
                12 => 65,
                11 => 66,
                15 => 69,
                14 => 67,
                13 => 68,
            ];

            //根据派工数据回写
            $last_update = $last_update2 = $str_tmp = [];
            foreach ($result as $value){
                $finished_num = $value['quantity'] + $value['finished_num'];

                DispatchSub::where('id',$value['id'])->update([
                    'finished_num' => $finished_num,
                    'wg_status' => 1,
                ]);

                $tmp = [
                    'id' => $value['id'],
                    'quantity' => $value['quantity'],
                    'product_no' => $value['product_no'] ?? "",
                    'product_title' => $value['product_title'] ?? "",
                    'product_size' => $value['product_size'] ?? "",
                    'product_unit' => $value['product_unit'] ?? "",
                ];
                $str = $value['order_product_id'] . $value['crt_time'] . $value['product_no'] . $value['technology_name'];
                if(! in_array($str, $str_tmp)){
                    $last_update[] = $tmp;
                    $str_tmp[] = $str;
                }

                $tmp['process_id'] = $value['process_id'];
                $team_tmp = $process_map[$value['process_id']] ?? 0; // 班组
                if(empty($team_tmp)){
                    $tmp['finished_id'] = 0;
                    $tmp['team_id'] = 0;
                    $last_update2[] = $tmp;
                }else{
                    $t_m = $team_man[$team_tmp] ?? []; //班组下的人
                    if(empty($t_m)) {
                        $tmp['finished_id'] = 0;
                        $tmp['team_id'] = $team_tmp;
                        $last_update2[] = $tmp;
                    }else{
                        foreach ($t_m as $m_v){
                            $tmp['finished_id'] = $m_v;
                            $tmp['team_id'] = $team_tmp;
                            $last_update2[] = $tmp;
                        }
                    }
                }

                $quantity = $value['quantity'] * 1000;
                //工序表
                $process_model = new OrdersProductProcess(['channel' => date("Ymd",$value['out_order_no_time'])]);
                $process_model->where('order_product_id',$value['order_product_id'])
                    ->where('process_id',$value['process_id'])
                    ->where('dispatch_no',$value['dispatch_no'])
                    ->where('status', 1)
                    ->take($quantity)
                    ->update([
                        'finished_time' => $time,
                        'status' => 2,
                        'finished_id' => 1,
                        'team_id' => $team_tmp,
                        'equipment_id' => 13,
                    ]);
            }

            $service = new FinishedOrderService();
            //反写数量
            //生产订单
            $id = array_column($result,'order_product_id');
            $service->writeFinishedQuantityByOrdersProductId($id);
            //销售订单
            $service->writeFinishedQuantity($id);

            //生成完工入库申请单
            list($status, $msg) = $this->createWGSQ($last_update, $user);
            if(! $status) return [false, $msg];

            //生成报工单
            $service = new FinishedOrderService();
            list($status, $msg) = $service->createbg($last_update2, $user);
            if(! $status) return [false, $msg];

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

        return [true, ''];
    }

    public function createWGSQ($insert_id, $user, $time = 0){
        //完工入库申请单自动审核并同步用友
        $em = new EmployeeService();
        $auto = $em->is_auto($user, "wgsq_auto");

        try {
            DB::beginTransaction();

            //生成申请单
            $service = new ApplyOrderService();
            list($status, $msg) = $service->createSQ($insert_id, $user, ApplyOrder::type_two, $auto, $time);
            if(! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            if($auto) {
                //生成流水
                list($status, $msg) = $service->createRecord($msg);
                if(! $status) {
                    DB::rollBack();
                    return [false, $msg];
                }
            }

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

        return [true, ''];
    }

    public function saveOutOrder($data,$user){
        list($status,$msg) = $this->saveOutOrderRule($data,$user);
        if(! $status) return [false, $msg];

        $limit_key = "saveOutOrder" . $user['id'];
        list($status,$msg) = $this->limitingSendRequestBackgNeed($limit_key);
        if(! $status) return [false, '正在生成销售出库订单数据,请稍后尝试!'];

        //不超时
        ini_set('max_execution_time', 0);

        try {
            DB::beginTransaction();
            //组织数据
            $yongyou_data = $update = [];
            foreach ($data['out_data'] as $value){
                $pro_tmp = [];
                foreach ($value['product'] as $p){
                    $t_k = $p['cinvcode'] . $p['cfree1'];
                    $pro_tmp[$t_k] = [
                        'cinvcode' => $p['cinvcode'],
                        'cfree1' => $p['cfree1'],
                        'iquantity' => $p['iquantity'],
                        'line' => $p['line'],
                    ];
                }

                if(isset($yongyou_data[$value['customer_code']])){
                    $yongyou_data[$value['customer_code']]['cdlcode_string'] .= ',' . $value['cdlcode'];
                    foreach ($pro_tmp as $k => $v){
                        if(isset($yongyou_data[$value['customer_code']]['product'][$k])){
                            $yongyou_data[$value['customer_code']]['product'][$k]['iquantity'] += $v['iquantity'];
                        }else{
                            $yongyou_data[$value['customer_code']]['product'][$k] = $v;
                        }
                    }
                }else{
                    $yongyou_data[$value['customer_code']] = [
                        'customer_code' => $value['customer_code'],
                        'cdlcode_string' => $value['cdlcode'],
                        'product' => $pro_tmp
                    ];
                }

                foreach ($value['box_no'] as $box_no){
                    $update[$box_no] = $value['cdlcode'];
                }
            }
            if(empty($yongyou_data)) {
                $this->dellimitingSendRequestBackgNeed($limit_key);
                return [false, '暂无写入用友发货出库数据！'];
            }

            //用友 ------发货出库
            $service = new FinishedOrderService();
            list($status,$msg) = $service->U8Rdrecord32Save($yongyou_data,$user);
            if(! $status) {
                $this->dellimitingSendRequestBackgNeed($limit_key);
                return [false, $msg];
            }

            //本地数据更新
            if(! empty($update)){
                foreach ($update as $key => $value){
                    Box::where('order_no', $key)->update([
                        'shipment_order_no' => $value
                    ]);
                }
            }

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

        return [true, ''];
    }

    public function saveOutOrderRule($data,$user){
        if(empty($data['out_data'])) return [false, '未获取到发货数据，操作失败!'];

        Log::channel('sendData')->info('发货:提交包装单数据', ["param" => $data]);

        //客户校验
        $customer_code = array_column($data['out_data'],'customer_code');
        $isAllSame = count(array_unique($customer_code)) === 1;
        if(! $isAllSame) return [false, '发货出库，请选择同一个客户的订单！'];
        $box_no = array_column($data['out_data'],'box_no');
        if(empty($box_no)) return [false, '包装单信息不能为空'];
        $box_arr = [];
        foreach ($box_no as $value){
            foreach ($value as $val){
                $box_arr[] = $val;
            }
        }
        $box_map = Box::where('del_time',0)
            ->whereIn('order_no',$box_arr)
            ->pluck('shipment_order_no', "order_no")
            ->toArray();
        foreach ($box_arr as $value){
            $tmp = $box_map[$value] ?? "";
            if($tmp != "") return [false, "包装单:" . $value . "已在发货单(" . $tmp .")中发出!"];
        }

        //用友发货数据查询
        $cdlcode = array_column($data['out_data'],'cdlcode');
        $service = new FyySqlServerService($user);
        if($service->error) return [false, $service->error];
        $out_data_map = $service->getDataFromDispatchListForCheck(['cdlcode' => $cdlcode]);
        if(empty($out_data_map)) return [false, '未在用友发货数据中查找到相关数据！'];

        //数据校验
        foreach ($data['out_data'] as $value){
            if(empty($value['cdlcode'])) return [false, '发货单号不能为空！'];
            if(! isset($out_data_map[$value['cdlcode']])) return [false, '发货单号:' . $value['cdlcode'] . '不存在或已被删除！'];
            $tmp = $out_data_map[$value['cdlcode']];
            if(empty($value['customer_code'])) return [false, '客户编码不能为空！'];
            if($tmp['customer_code'] != $value['customer_code']) return [false, '客户编码与用友数据中不一致！'];
            if(empty($tmp['product'])) return [false, '发货单号:' . $value['cdlcode'] . '未查找到用友的发货产品数据！'];
            $tmp_pro = [];
            foreach ($tmp['product'] as $t){
                $t_k = $t['cinvcode'] . $t['cfree1'];
                $tmp_pro[$t_k] = bcsub($t['iquantity'] , $t['out_quantity'],3);//未发货数量
            }
            if(empty($value['product'])) return [false, '发货产品不能为空！'];
            foreach ($value['product'] as $p){
                if(empty($p['line'])) return [false, '存货行号不能为空！'];
                if(empty($p['cinvcode'])) return [false, '存货编码不能为空！'];
                if(empty($p['cfree1'])) return [false, '存货颜色不能为空！'];
                $p_k = $p['cinvcode'] . $p['cfree1'];
                if(! isset($tmp_pro[$p_k])) return [false, '发货单号:' . $value['cdlcode'] . '下无该发货产品:编码为' . $p['cinvcode'] . ',颜色为:' . $p['cfree1']];
                if(empty($p['iquantity']) || $p['iquantity'] <= 0) return [false, '发货数量不能为空！'];
                $last = $tmp_pro[$p_k];
                if($p['iquantity'] > $last) return [false, '发货单号:' . $value['cdlcode'] . '下的发货产品:编码为' . $p['cinvcode'] . ',颜色为' . $p['cfree1'] . '的未发货数量为' . $last];
            }
        }

        return [true, ''];
    }

    /**
     * 根据发货单包装（恒成塑业不需要 如果有调用 直接返回）
     * @param $data
     * @return array
     */
    public function transportBoxIn($data)
    {
        return [true,''];
        $param = $data['params'];
        $shipment_order_no = $data['transport_no'];
        $sale_order_nos = [];
        $key_list = [];
        foreach ($param as $v){
            if(!in_array($v['order_no'],$sale_order_nos)) $sale_order_nos[] = $v['order_no'];
            $key = $this->getKey($v);
            $key_list[$key] = [
                'num' => $v['num'],
                'order_no' => $v['order_no'],
                'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
            ];
        }
        $sale_order_product_list = SaleOrdersProduct::wherein('out_order_no',$sale_order_nos)->get()->toArray();
        $sale_order_product_key_list = [];
        foreach ($sale_order_product_list as $v){
            $key = $this->getKey($v);
            $sale_order_product_key_list[$key] = $v['id'];
        }

        $param = [];
        foreach ($key_list as $k=>$v){
            if(!isset($sale_order_product_key_list[$k])) return [false,$k.' 不存在！'];
            $param[$v['order_no']][] = [
                'id' => -(intval($sale_order_product_key_list[$k])),
                'team_id' => $v['team_id'],
                'params' => [$v['num']]
            ];

        }

//        $box_no = self::$box_hook->setOrderNo(); todo
        foreach ($param as $k=>$v){
            $top_order_no = SaleOrdersProduct::where('out_order_no',$k)->value('order_no');
            $postParam = [
                'order_no' => $top_order_no,
                'param' => $v,
                'box_no' => $box_no,
                'transport_no' => $shipment_order_no,
            ];
            $this->boxIn($postParam);
        }

        return [true,''];
    }

    protected function getKey($data){
        return $data['product_no'].'_'.$data['technology_material'].'_'.$data['technology_name'].'_'.$data['wood_name'].'_'.$data['process_mark'];
    }

    /**
     * 包装详情1用于包装前
     * @param $data
     * @return array
     */
    public function boxDetail($data)
    {
        list($status, $data) = self::$box_hook->boxDetail($data);
        if (!$status) return [false, $data];
        $return = [];
        foreach ($data as $v){
            $key = $v['ext_1'] . $v['ext_3'];
            if(! isset($return[$key])){
                $return[$key] = $v;
            }else{
                $return[$key]['num'] += $v['num'];
            }
        }
        $sale_orders_product_ids = array_unique(array_column($data,'top_id'));
        $list = SaleOrdersProduct::wherein('id',$sale_orders_product_ids)->get()->toArray();
        $key_list = [];
        foreach ($list as $v){
            $key_list[$v['id']] = $v;
        }

        foreach ($return as &$v){
            $detail =  $key_list[$v['top_id']];
            $v['customer_no'] = $detail['customer_no'];
            $v['customer_name'] = $detail['customer_name'];
        }
        return [true, array_values($return)];
    }

    public function boxProductList($data){
        if(empty($data['id']) && empty($data['out_order_no'])) return [false,'请选择数据！'];
        if(! empty($data['id'])){
            $sale_order_ids = $data['id'];
        }else{
            $ids = SaleOrdersProduct::where('del_time',0)
                ->where('out_order_no','Like','%'. $data['out_order_no'] . '%')
                ->select('id')
                ->get()->toArray();
            $sale_order_ids = array_column($ids,'id');
            if(empty($sale_order_ids)) return [false, '暂无数据！'];
        }

        $model = SaleOrdersProduct::where('del_time',0)
            ->whereIn('id',$sale_order_ids)
            ->select('id','out_order_no','order_no','customer_no','customer_name','product_no','product_title','product_size','crt_time as production_time','id as sale_orders_product_id','finished_num as dispatch_complete_quantity','box_num','technology_name','wood_name','crt_time','order_quantity','technology_material','technology_name','wood_name','process_mark')
            ->orderBy('id','desc')
            ->get()->toArray();
        //原先按照完工数量 未包装 = 完工数量 - 已包数量
        $product_list = ordersProduct::where('del_time',0)
            ->whereIn('sale_orders_product_id',$sale_order_ids)->select('id','out_order_no','customer_no','customer_name','product_no','sale_orders_product_id','product_title','product_size','box_num','technology_name','wood_name','crt_time','production_quantity','dispatch_complete_quantity','technology_material','technology_name','wood_name','process_mark',"production_no")
            ->get()->toArray();
        $model_key_list = [];
        foreach ($model as $v){
            $model_key_list[$v['id']] = $v;
        }
        $model = [];

        //存在生产订单，组织数据
        if(! empty($product_list)){
            $product_key_num_list = [];
            foreach ($product_list as $v){
                //下派工数量 就是 能包的数量 相等以后 踢掉数据
                if($v['dispatch_complete_quantity'] == $v['box_num']) continue;
                if(!isset($product_key_num_list[$v['sale_orders_product_id']][$v['id']])) {
                    $product_key_num_list[$v['sale_orders_product_id']][$v['id']] = [
                        'product_num' => 0 ,
                        'box_num' => 0 ,
                    ];
                }
                $product_key_num_list[$v['sale_orders_product_id']][$v['id']]['product_num'] += $v['production_quantity'];
                $product_key_num_list[$v['sale_orders_product_id']][$v['id']]['box_num'] += $v['box_num'];
                $detail = $model_key_list[$v['sale_orders_product_id']];
                $detail['box_type'] = 1;
                $detail['id'] = $v['id'];
                $detail['box_num'] = $v['box_num'];
                $detail['dispatch_complete_quantity'] = $v['dispatch_complete_quantity'];
                $detail['un_box_num'] = bcsub($v['dispatch_complete_quantity'] , $v['box_num'],3);
                $detail['type'] = 1;
                $detail['production_no'] = $v['production_no'];
                $detail['production_quantity'] = $v['production_quantity'];
                $model[] = $detail;
            }
        }

        $return = [];
        foreach ($model as $v){
            if(!isset($v['box_type'])) {continue; //没有销售订单直接包了。
                $product_num = 0;
                $box_num = 0;
                if(isset($product_key_num_list[$v['id']])){
                    foreach ($product_key_num_list[$v['id']] as $vv){
                        $product_num += $vv['product_num'];
                        $box_num += $vv['box_num'];
                    }
                }
                if(($v['order_quantity'] - $product_num) === 0) continue;
                $product_key_list[$v['sale_orders_product_id']] = [
                    'out_order_no' => $v['out_order_no'],
                    'order_no' => $v['order_no'],
                    'production_no' => "",
                    'production_time' => '未下生产',
                    'customer_no' => $v['customer_no'],
                    'customer_name' => $v['customer_name'],
                    'product_no' => $v['product_no'],
                    'product_title' => $v['product_title'],
                    'product_size' => $v['product_size'],
                    'id' => -$v['sale_orders_product_id'],
                    'technology_material' => $v['technology_material'],
                    'technology_name' => $v['technology_name'],
                    'wood_name' => $v['wood_name'],
                    'process_mark' => $v['process_mark'],
                    'type' => '2',
                    'is_box_num' => $v['box_num'] - $box_num,
                    'un_box_num' => $v['order_quantity'] - ($v['box_num'] - $box_num) - $product_num,
                    'sale_num' => $v['order_quantity'],
                ];
            }else{
                $return[] = [
                    'id' => $v['id'],
                    'technology_material' => $v['technology_material'],
                    'technology_name' => $v['technology_name'],
                    'wood_name' => $v['wood_name'],
                    'order_no' => $v['order_no'],
                    'production_no' => $v['production_no'],
                    'process_mark' => $v['process_mark'],
                    'out_order_no' => $v['out_order_no'],
                    'production_time' => date('Y-m-d',$v['crt_time']),
                    'customer_no' => $v['customer_no'],
                    'customer_name' => $v['customer_name'],
                    'product_no' => $v['product_no'],
                    'product_title' => $v['product_title'],
                    'product_size' => $v['product_size'],
                    'type' => '1',
                    'is_box_num' => $v['box_num'],
                    'un_box_num' => $v['un_box_num'],
                    'sale_num' => $v['order_quantity'],
                    'production_num' => $v['production_quantity'],
                    'dispatch_complete_quantity' => $v['dispatch_complete_quantity']
                ];
            }
        }

        return [true,$return];
    }

    /**
     * 包装详情2用于包装后
     * @param $data
     * @return array
     */
    public function boxOrderDetail($data)
    {
        list($status, $data) = self::$box_hook->boxDetail($data);
        $sale_orders_product_ids = [];
        foreach ($data as $v){
            $sale_orders_product_ids[] = $v['top_id'];
        }
        $list = SaleOrdersProduct::wherein('id',$sale_orders_product_ids)->get()->toArray();
        $key_list = [];
        foreach ($list as $v){
            $key_list[$v['id']] = $v;
        }
        foreach ($data as &$v){
            $v['ext_3'] = $key_list[$v['top_id']]['product_no'];
            $v['wood_name'] = $key_list[$v['top_id']]['wood_name'];
            $v['technology_name'] = $key_list[$v['top_id']]['technology_name'];
            $v['process_mark'] = $key_list[$v['top_id']]['process_mark'];
            $v['technology_material'] = $key_list[$v['top_id']]['technology_material'];
        }
        if (!$status) return [false, $data];
        return [true, $data];
    }

    /**
     * 通过销售单号获取包装单
     * @param $data
     * @return array
     */
    public function boxOrderDetailByTop($data){

        $list = new Box();
        if(isset($data['top_order_no'])&&!empty($data['top_order_no'])) $list = $list->wherein('top_order_no',$data['top_order_no']);
        if(isset($data['transport_no'])&&!empty($data['transport_no'])) $list = $list->wherein('shipment_order_no',$data['transport_no']);
//        if(isset($data['top_order_no'])) $list = $list->wherein('top_order_no',$data['top_order_no']);
//        if(isset($data['transport_no'])) $list = $list->wherein('shipment_order_no',$data['transport_no']);
        $list = $list->select('top_order_no','order_no','crt_time')->where('del_time',0)->groupBy('order_no')->get()->toArray();


        return [true,$list];
    }

    /**
     * 通过包装单获取包装详情
     * @param $data
     * @return array
     */
    public function boxOrderDetailByOrderNo($data){
        $order_nos = $data['order_nos'];
        $order_nos = array_unique($order_nos);
        $list = Box::where('del_time',0)->wherein('order_no',$order_nos)->select('order_no','out_order_no','top_order_no','shipment_order_no as transport_no')->get()->toArray();
        $detail_list = [];
        foreach ($list as $v){
            $model = new BoxDetail(['channel'=>$v['top_order_no']]);
            $detail_list = array_merge($detail_list,$model->where('order_no',$v['order_no'])->where('top_order_no',$v['top_order_no'])->get()->toArray());
        }
        $list = $detail_list;

        $ids = [];
        foreach ($list as $v){
            $ids[] = $v['top_id'];
        }
        $sale_orders_product = SaleOrdersProduct::wherein('id',$ids)->get()->toArray();
        $sale_orders_key_product = [];
        foreach ($sale_orders_product as $v){
            $sale_orders_key_product[$v['id']] = $v;
        }
        $team_key_list = Team::pluck('title','id')->toArray();
        foreach ($list as &$v){
            $detail = $sale_orders_key_product[$v['top_id']];
            $v['customer_name'] = $detail['customer_name'];
            $v['table_body_mark'] = $detail['table_body_mark'];
            $v['ext_4'] = $detail['product_title'];
            $v['ext_5'] = $detail['product_size'];
            $v['customer_name'] = $detail['customer_name'];
            $v['technology_material'] = $detail['technology_material'];
            $v['transport_no'] = $v['shipment_order_no'];
            $v['wood_name'] = $detail['wood_name'];
            $v['team_name'] = isset($team_key_list[$v['team_id']]) ? $team_key_list[$v['team_id']] : '' ;
        }

        return [true,$list];
    }

    public function boxOrderGroup($data){
        $list = new Box();
        if(empty($data['top_order_no']) && empty($data['transport_no'])) return [false,'请输入单号！'];

        if(! empty($data['top_order_no'])) $list = $list->whereIn('top_order_no',$data['top_order_no']);
        if(! empty($data['transport_no'])) {
            if(is_array($data['transport_no'])){
                $list = $list->whereIn('shipment_order_no',$data['transport_no']);
            }else{
                $list = $list->where('shipment_order_no','Like','%'. $data['transport_no'] . '%');
            }
        }

        $list = $list->select('top_order_no','order_no as box_no','crt_time','shipment_order_no','out_order_no')->where('del_time',0)
            ->get()->toArray();

        foreach ($list as $key => $value){
            $model = new BoxDetail(['channel'=> $value['top_order_no']]);
            $tmp = $model->where('del_time',0)
                ->where('order_no',$value['box_no'])
                ->where('out_order_no',$value['out_order_no'])
                ->select('order_no','out_order_no','orders_product_id')
                ->first();
            $production_no = "";
            if(! empty($tmp)){
                $production_no = OrdersProduct::where('id',$tmp->orders_product_id)->select('production_no')->pluck('production_no')->toArray();
                $production_no = $production_no[0];
            }

            $list[$key]['production_no'] = $production_no;
            $list[$key]['crt_time'] = date('Y-m-d H:i:s',$value['crt_time']);
        }

        return [true,$list];
    }

    public function boxOrderGroupGwp($data){
        $out_order_no = $data['out_order_no'] ?? "";
        $model = Box::where('del_time',0)
            ->when(! empty($out_order_no), function ($query) use ($out_order_no) {
            return $query->where('out_order_no','Like','%'. $out_order_no . '%');
        })
            ->select('out_order_no','ext_1','top_order_no','order_no','crt_time','shipment_order_no',DB::raw("count(id) as package_num"))
            ->groupBy('out_order_no');

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

        return [true, $list];
    }

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

        foreach ($data['data'] as $key => $value){
            $model = new BoxDetail(['channel'=> $value['top_order_no']]);
            $tmp = $model->where('del_time',0)
                ->where('out_order_no',$value['out_order_no'])
                ->select('num')
                ->get()->toArray();
            $data['data'][$key]['num'] = $this->getTotal($tmp, 'num');
        }

        return $data;
    }

    public function boxOrderGroupGwpDetail($data){
        if(empty($data['top_order_no']) || empty($data['out_order_no'])) return [false, '请选择数据！'];
        $top_order_no = $data['top_order_no'];
        $model = new BoxDetail(['channel'=> $top_order_no]);
        $detail_list = $model->where('del_time',0)
            ->where('out_order_no',$data['out_order_no'])
            ->get()->toArray();
        $map = Box::whereIn('order_no',array_unique(array_column($detail_list,'order_no')))
            ->pluck('ext_1','order_no')
            ->toArray();

        $return = [];
        foreach ($detail_list as $value){
            //销售订单号  包装单号  产品编码  颜色
            $key = $value['out_order_no'] . $value['order_no'] . $value['ext_1'] . $value['ext_3'];
            if(isset($return[$key])){
                $return[$key]['num'] += $value['num'];
            }else{
                $return[$key] = [
                    'box_no' => $value['order_no'],
                    'out_order_no' =>  $value['out_order_no'],
                    'ext_8' =>  $value['ext_8'],
                    'ext_3' =>  $value['ext_3'],
                    'num' =>  $value['num'],
                    'crt_time' => date("Y-m-d",$value['crt_time']),
                    'top_order_no' => $value['top_order_no'],
                    'customer_name' => $map[$value['order_no']] ?? "",
                ];
            }
        }

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

    public function transportNo(){
        $list = Box::where('del_time',0)->where('shipment_order_no','<>','')->groupBy('shipment_order_no')->pluck('shipment_order_no')->toArray();

        return [true,$list];
    }

    public function delBoxDetail($data){
        if(empty($data['order_nos'])) return [false, '请选择包装单！'];
        $order_nos = $data['order_nos'];
        try {
            DB::beginTransaction();

            //更新销售订单 生产订单数据
            $orders_product_id_map = [];
            foreach ($order_nos as $v){
                $list = self::$box_hook->delBox($v);
                if(empty($list)) continue;
                foreach ($list as $vv){
                    SaleOrdersProduct::where('id',$vv['top_id'])->update([
                        'box_num' => DB::raw('box_num - '.$vv['num']),
                        'finished_num' => DB::raw('finished_num - '.$vv['num'])
                    ]);

                    OrdersProduct::where('id',$vv['orders_product_id'])->update([
                        'box_num' => DB::raw('box_num - '.$vv['num']),
                        'finished_num' => DB::raw('finished_num - '.$vv['num'])
                    ]);

                    if(isset($orders_product_id_map[$vv['orders_product_id']])){
                        $num = bcadd($orders_product_id_map[$vv['orders_product_id']], $vv['num'],3);
                        $orders_product_id_map[$vv['orders_product_id']] = $num;
                    }else{
                        $orders_product_id_map[$vv['orders_product_id']] = $vv['num'];
                    }
                }
            }

            //更新完工数据 和 底表数据
            list($status,$msg) = $this->updateFinishDel($orders_product_id_map);
            if(! $status) return [false, $msg];

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

        return [true, ''];
    }

    public function updateFinishDel($orders_product_id_map){
        if(empty($orders_product_id_map)) return [true,''];
        $production_list = array_keys($orders_product_id_map);

        $dispatch = $this->getDispatch($production_list, $orders_product_id_map);
        if(empty($dispatch)) return [true,''];

        try {
            DB::beginTransaction();

            //根据派工数据回写
            foreach ($dispatch as $value){
                $finished_num = bcsub($value['finished_num'], $value['out_number'],3);

                DispatchSub::where('id',$value['id'])->update([
                    'finished_num' => $finished_num
                ]);

                $quantity = $value['out_number'] * 1000;
                //工序表
                $process_model = new OrdersProductProcess(['channel' => date("Ymd",$value['out_order_no_time'])]);
                $process_model->where('order_product_id',$value['order_product_id'])
                    ->where('process_id',$value['process_id'])
                    ->where('dispatch_no',$value['dispatch_no'])
                    ->where('status', 2)
                    ->take($quantity)
                    ->update([
                        'finished_time' => 0,
                        'status' => 1,
                        'finished_id' => 0,
                        'team_id' => 0,
                        'equipment_id' => 0,
                    ]);
            }

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

        return [true, ''];
    }

    public function getDispatch($order_product_id,$map){
        $order = OrdersProduct::where('del_time',0)
            ->where('id', $order_product_id)
            ->select('id', 'process_id')
            ->get()->toArray();
        $order_map = [];
        foreach ($order as $value){
            $order_map[$value['id']] = explode(',', $value['process_id']);
        }

        //组织派工数据
        $dispatch = DispatchSub::where('del_time',0)
            ->whereIn('order_product_id', $order_product_id)
            ->where('finished_num','>',0)
            ->get()->toArray();
        if(empty($dispatch)) return [];
        $dispatch_map = [];
        foreach ($dispatch as $value){
            $key = $value['order_product_id'] . '|' .  $value['crt_time']; //同一次下的派工单
            $dispatch_map[$key][] = $value;
        }

        $result = []; $tmp = [];
        foreach ($dispatch_map as $key => $value){
            foreach ($value as $v){
                $process = $order_map[$v['order_product_id']] ?? [];
                $num = $map[$v['order_product_id']];

                if(in_array($v['process_id'], $process)){
                    $str = $v['order_product_id'] . $v['process_id'];
                    $tmp_v = $tmp[$str] ?? 0;
                    $num = bcsub($num, $tmp_v,3);
                    if($num <= 0) continue;

                    if($v['finished_num'] >= $num){
                        $v['out_number'] = $num;
                        $result[] = $v;
                    }else{
                        $v['out_number'] = $v['finished_num'];
                        $result[] = $v;
                    }

                    if(isset($tmp[$str])){
                        $num = bcadd($tmp[$str], $v['out_number'],3);
                        $tmp[$str] = $num;
                    }else{
                        $tmp[$str] = $v['out_number'];
                    }
                }
            }
        }unset($tmp);

        return $result;
    }

    public function boxAdd($data)
    {
        list($status,$msg) = $this->boxAddRule($data);
        if(! $status) return [false,$msg];

        try{
            DB::beginTransaction();
            $box = new Box();
            $box->order_no = $msg['order_no'];
            $box->save();

            DB::table('box_detail')->insert($msg['detail']);

            DB::commit();
            return [true,''];
        }catch (\Exception $e){

            DB::rollBack();
            return [false,$e->getLine().':'.$e->getMessage()];
        }
    }

    public function boxAddRule($data)
    {
        if(empty($data['param'])) return [false,'请选择包装数据'];
//        $order_no = (new BoxHookService())->setOrderNo();
        $order_no = "";
        if(empty($order_no)) return [false,'包装单号不能为空'];
        $detail = [];
        foreach ($data['param'] as $value) {
            $key = $this->lock_key.'_'.$value['idlsid'];
            list($status,$msg) = $this->limitingSendRequestBackg($key);
            if(! $status) return [false,$msg];

//            if(empty($value['submit_quantity']) || ! is_numeric($value['submit_quantity']) || $value['submit_quantity'] > $value['quantity']) return [false,'包装数量错误'];
            if(empty($value['team_id'])) return [false,'班组必须选择'];

            $tmp = $value;
            $tmp['iquantity'] = $value['submit_quantity'];
            $detail[] = [
                'order_no' => $order_no,
                'out_order_no' => $value['csocode']??'',
                'crt_time' => time(),
                'upd_time' => time(),
                'type' => 1,
                'ext_1' => $value['cinvcode'],
                'ext_2' => $value['technology_material'],
                'ext_3' => $value['cfree1'] ?? "",
                'ext_4' => $value['cfree2'] ?? "",
                'ext_5' => $value['process_mark'],
                'ext_6' => $value['customer_name'] ?? "",
                'ext_7' => $value['cuscode'] ?? "",
                'ext_8' => $value['product_title'],
                'ext_9' => $value['product_size'],
                'ext_10' => $value['table_header_mark'],
                'ext_11' => $value['table_body_mark'],
                'top_id' => $value['idlsid'],
                'state' => 0,
                'num' => $value['submit_quantity'],
                'box_type' => 2,
                'team_id' => $value['team_id'],
                'shipment_order_no' => $value['cdlcode'],
                'post' => json_encode($tmp),
            ];
        }

        return [true,['order_no' => $order_no, 'detail' => $detail]];
    }

    public function boxFhDetail($data){
        if(empty($data['idlsid'])) return [false,'请选择数据'];

        $result = DB::table('box_detail')->where('del_time',0)
            ->where('top_id',$data['idlsid'])
            ->select('order_no','ext_6','ext_7','ext_1','ext_8','ext_9','num','ext_2','ext_3','ext_4','ext_5','ext_10','ext_11')
            ->get()->toArray();
        if(! empty($result)){
            foreach ($result as $key => $value){
                $result[$key] = (array)$value;
            }
        }

        return [true,$result];
    }

    public function boxFhDel($data){
        if(empty($data['order_nos'])) return [false,'包装单号不能为空'];

        $box = Box::whereIn('order_no',$data['order_nos'])->update(['del_time' => time()]);

        DB::table('box_detail')->whereIn('order_no',$data['order_nos'])->where('del_time',0)->update([
            'del_time' => time()
        ]);
        return [true,''];
    }

    public function transportDetail($data){
        if(empty($data['order_nos'])) return [false,'包装单号不能为空'];
        $order_nos = $data['order_nos'];
        $list = BoxDetail::wherein('order_no',$order_nos)->select('ext_1','ext_2','ext_3','ext_4','ext_5','ext_6','ext_7','ext_8','ext_9','num','order_no','shipment_order_no','post')->get()->toArray();
        foreach ($list as &$v){
            $v['product_no'] = $v['ext_1'];
            $v['technology_material'] = $v['ext_2'];
            $v['technology_name'] = $v['ext_3'];
            $v['wood_name'] = $v['ext_4'];
            $v['process_mark'] = $v['ext_5'];
            $v['customer_no'] = $v['ext_6'];
            $v['customer_name'] = $v['ext_7'];
            $v['product_title'] = $v['ext_8'];
            $v['product_size'] = $v['ext_9'];
            $v['post'] = json_decode($v['post'],true);
        }
        return [200,$list];

    }

    public function boxFhBzDetail($data){
        if(empty($data['order_no'])) return [false,'请选择包装单数据'];

        $result = DB::table('box_detail')->where('del_time',0)
            ->whereIn('order_no',$data['order_no'])
            ->select('order_no','ext_6','ext_7','ext_1','ext_8','ext_9','num','ext_2','ext_3','ext_4','ext_5','shipment_order_no','crt_time','team_id','ext_10','ext_11')
            ->get()->toArray();
        if(! empty($result)){
            foreach ($result as $key => $value){
                $result[$key] = (array)$value;
            }
            $map = Team::where('id',array_unique(array_column($result,'team_id')))->pluck('title','id')->toArray();
            foreach ($result as $key => $value){
                $result[$key]['team_name'] = $map[$value['team_id']] ?? '';
            }
        }

        return [true,$result];
    }

    public function boxFhBzList($data){
        if(empty($data['shipment_order_no'])) return [false, '请输入发货单号'];
        $model = DB::table('box_detail')->where('del_time',0)
            ->where('shipment_order_no','LIKE', '%'.$data['shipment_order_no'].'%')
            ->select('order_no','crt_time','shipment_order_no');

        $return = [];
        $result = $model->get()->toArray();
        if(! empty($result)){
            foreach ($result as $value){
                $return[$value->order_no] = [
                    'order_no' => $value->order_no,
                    'shipment_order_no' => $value->shipment_order_no,
                    'crt_time' => date("Y-m-d H:i:s",$value->crt_time)
                ];
            }
        }

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

    public function boxOrderDetailByOrderNoNew($data){
        if(empty($data['order_nos'])) return [false, '包装单号不能为空'];
        $order_nos = $data['order_nos'];
        $order_nos = array_unique($order_nos);

        Log::channel('sendData')->info('发货:扫码包装单数据', ["param" => $order_nos]);

        $list = Box::where('del_time',0)
            ->whereIn('order_no',$order_nos)
            ->where('shipment_order_no','')
            ->select('order_no','out_order_no','top_order_no','shipment_order_no as transport_no','upd_time')
            ->get()->toArray();
        $detail_list = [];
        foreach ($list as $v){
//            if(! empty($v['transport_no'])) return [false, "包装单号:" . $v['order_no'] . "已在发货单(" . $v['transport_no'] .")中发出!"];
            $model = new BoxDetail(['channel'=>$v['top_order_no']]);
            $detail_list = array_merge($detail_list,$model->where('order_no',$v['order_no'])->where('top_order_no',$v['top_order_no'])->get()->toArray());
        }

        $return = [];
        foreach ($detail_list as $value){
            //销售订单号  产品编码  颜色
            $return[] = [
                'ext_1' =>  $value['ext_1'],
                'ext_3' =>  $value['ext_3'],
                'ext_8' =>  $value['ext_8'],
                'num' =>  $value['num'],
                'out_order_no' => $value['out_order_no'],
                'box_no' => $value['order_no']
            ];
        }

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

    public function boxList($data,$user){
        $model = Box::where('del_time',0)
            ->select('id','order_no','out_order_no','top_order_no','crt_time','status','shipment_order_no')
            ->orderBy('id','desc');

        if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
        if(! empty($data['shipment_order_no'])) $model->where('shipment_order_no', 'LIKE', '%'.$data['shipment_order_no'].'%');
        if(! empty($data['out_order_no'])) $model->where('out_order_no', 'LIKE', '%'.$data['out_order_no'].'%');
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) $model->whereBetween('crt_time',[$data['crt_time'][0],$data['crt_time'][1]]);
        if(isset($data['status'])) $model->where('status',$data['status']);

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

        return [true, $list];
    }

    public function fillBoxListData($data, $erg,$user){
        if(empty($data['data'])) return $data;

        $product = $material = [];
        if(! empty($erg['box'])){
            //获取包装单里的产品
            $id = array_column($data['data'], 'id');
            list($product,$product_no) = $this->getBoxDetail($id);
            if(! empty($erg['box_material'])){
                //产品的包装材料
                $service = new FyyOrderService();
                list($status, $msg) = $service->getProductBzDataFromSqlServer(['product_no' => $product_no], $user);
                if($status) $material = $msg;
            }
        }

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['status_title'] = Box::$status_name[$value['status']] ?? "";
            $p = $product[$value['id']] ?? [];
            if(! empty($p)){
                foreach ($p as $k => $v){
                    $p[$k]['box_material'] = $material[$v['product_no']] ?? [];
                }
            }
            $data['data'][$key]['product'] = $p;
        }

        return $data;
    }

    public function getBoxDetail($id = []){
        $return = $product_no= [];
        if(empty($id)) return [$return,$product_no];

        $box = Box::where('del_time',0)
            ->whereIn('id', $id)
            ->select('id', 'order_no','top_order_no')
            ->get()->toArray();
        if (empty($box)) return [$return,$product_no];
        $map = array_column($box,'id','order_no');

        $result = [];
        foreach ($box as $v){
            $model = new BoxDetail(['channel'=>$v['top_order_no']]);
            $result = array_merge($result,$model->where('del_time',0)
                ->where('order_no',$v['order_no'])
                ->select('order_no', 'ext_1 as product_no', 'ext_8 as product_title', 'ext_9 as product_size','num as quantity','ext_3 as technology_name')->get()->toArray());

        }

        foreach ($result as $value){
            $value['id'] = $map[$value['order_no']] ?? 0;
            $value['product_unit'] = "吨";
            $return[$value['id']][] = $value;
            if(! in_array($value['product_no'], $product_no)) $product_no[] = $value['product_no'];
        }

        return [$return, $product_no];
    }

    public function searchDetail($data){
        $out_order_no = $data['out_order_no'] ?? '';
        $box = Box::where('del_time',0)
            ->where('out_order_no', 'LIKE', '%'. $out_order_no .'%')
            ->select('top_order_no')
            ->get()->toArray();
        if(empty($box)) return [];

        $order_no = [];
        foreach ($box as $value){
            $model = new BoxDetail(['channel'=> $value['top_order_no']]);
            $result = $model->where('del_time',0)
                ->where('order_no',$box['order_no'])
                ->select('order_no')
                ->get()->toArray();
            $detail_list = array_merge($order_no, array_column($result, 'order_no'));

        }
        $result = BoxDetail::where('del_time',0)
            ->when(! empty($out_order_no), function ($query) use ($out_order_no) {
                return $query->where('out_order_no', 'LIKE', '%'. $out_order_no .'%');
            })
            ->when(! empty($shipment_order_no), function ($query) use ($shipment_order_no) {
                return $query->where('shipment_order_no', 'LIKE', '%'. $shipment_order_no .'%');
            })
            ->select('order_no')
            ->get()->toArray();

        return array_unique(array_column($result,'order_no'));
    }

    public function boxFhDetailNew($data){
        if(empty($data['id'])) return [false,'请选择数据'];

        $box = Box::where('id', $data['id'])->where('del_time',0)->first();
        if(empty($box)) return [false, '包装单不存在或已被删除'];
        $box = $box->toArray();

        $model = new BoxDetail(['channel'=>$box['top_order_no']]);
        $result = $model->where('del_time',0)
            ->where('order_no',$box['order_no'])
            ->select('order_no', 'ext_1 as product_no', 'ext_8 as product_title', 'ext_9 as product_size','num as quantity','ext_3 as technology_name','out_order_no')->get()->toArray();

        foreach ($result as $key => $value){
            $result[$key]['product_unit'] = "吨";
        }

        return [true,$result];
    }
}