";
//print_r($insertData);
//echo "
";die;
//            $mongo->name($collection)->insertAll($insertData);
//            $mongo->name($bachsummary)->insert($insertData_bachsummary);
//
//
//        foreach ($data['products'] as $product) {
//            $where = [
//                'gdbh' => $product['gdbh'],
//                'order_ddbh' => $product['order_ddbh'],
//                'cpmc' => $product['cpmc'],
//            ];
//
//            // 实际出库数量
//            $actual_quantity = isset($product['actual_quantity']) ? (int)$product['actual_quantity'] : 0;
//            $remaining_quantity = isset($product['remaining_quantity']) ? (int)$product['remaining_quantity'] : 0;
//
//            // 插入/更新字段
//            $insertData = [
//                'gdbh'                => $product['gdbh'],
//                'order_ddbh'          => $product['order_ddbh'],
//                'cpbm'                => $product['cpbm'],
//                'cpmc'                => $product['cpmc'],
//                'total_ru_quantity'   => $remaining_quantity,            // 入库数来自当前剩余
//                'total_chu_quantity'  => $actual_quantity,              // 本次出库数
//                'remaining_quantity'  => $remaining_quantity - $actual_quantity, // 计算结存
//                'created_at'          => date('Y-m-d H:i:s'),
//                'updated_at'          => '',
//                'mod_rq'              => '',
//                'company'             => $data['company_name'] ?? '',
//            ];
//
//            // 查询是否已存在
//            $existing = $mongo->name('inventory_summary')->where($where)->find();
//
//            if ($existing) {
//                // 累加更新
//                $new_chu = (int)$existing['total_chu_quantity'] + $actual_quantity;
//                $new_remaining = (int)$existing['remaining_quantity'] - $actual_quantity;
//
//                $mongo->name('inventory_summary')
//                    ->where($where)
//                    ->update([
//                        'total_ru_quantity'   => (int)$existing['total_ru_quantity'], // 保持不变或你可定义逻辑
//                        'total_chu_quantity' => $new_chu,
//                        'remaining_quantity'  => $new_remaining,
//                        'updated_at'          => date('Y-m-d H:i:s'),
//                    ]);
//            } else {
//                // 插入新记录
//                $mongo->name('inventory_summary')->insert($insertData);
//            }
//
//            // 插入库存明细记录
//            $mongo->name('inventory_records')->insert($insertData);
//        }
//        $this->success('添加成功');
//
//    }



    /**
     * 增加新批次
     */
    public function add()
    {
        $product = new QcodeProduct();
        $bach = new QcodeBach();
        $large = new QcodeLarge();
        $small = new QcodeSmall();
        $liushui = new QcodeLiushui();
        $resetFlow = new ResetFlow();
        $QcodeCompany = new QcodeCompany();

        if ($this->request->isAjax() === false){
            $this->error('请求错误');
        }
        $rows = input('row');
        if (empty($rows)){
            $this->error('参数错误');
        }
        $rows = json_decode($rows);

        $data = [];
        foreach ($rows as $value){
            foreach ($value as $k=>$v){
                $data[$k] = $v;
            }
        }
//        echo "接口获取";echo "
";print_r($data);echo "
";die;

        //记录库存操作
        $mongo = \think\Db::connect('mongodb');
        $where = [
            'gdbh' => $data['gdbh'],
            'order_ddbh' => $data['order_ddbh'],
            'cpmc' => $data['cpmc'],
        ];
        //插入字段[inventory_summaryk库存明细]
        $insertData = [
            'gdbh'             => $data['gdbh'],
            'order_ddbh'             => $data['order_ddbh'],
            'cpbm'             => $data['cpbm'],
            'cpmc'             => $data['cpmc'],
            'total_ru_quantity'   => $data['sl'],//入库数
            'total_chu_quantity' => $data['number'],//出库数
            'remaining_quantity'  => $data['remaining_quantity'] - $data['number'],//剩余数
            'created_at'       => date('Y-m-d H:i:s'),
            'updated_at'       => '',
            'mod_rq'           => '',
            'company'          => '',
        ];
        // 查询库存汇总表数据是否存在记录
        $list = $mongo->name('inventory_summary')->where($where)->find();
        if ($list) {
            // 如果数据存在，更新库存汇总记录
            $chu = $list['total_chu_quantity'] + $data['number'];//累计出库数量
            $jiecun  = $list['remaining_quantity'] - $data['number'];//剩余结存数量
            $updateResult = $mongo->name('inventory_summary')
                ->where($where)
                ->update([
                    'total_ru_quantity'   => $data['sl'],
                    'total_chu_quantity' => $chu,
                    'remaining_quantity'  => $jiecun,
                    'updated_at'       => date('Y-m-d H:i:s'),
                ]);
        } else {
            // 数据不存在则插入新记录
            $mongo->name('inventory_summary')->insert($insertData);
        }
        //记录库存明细
        $mongo->name('inventory_records')->insert($insertData);

//        // 调试输出
//        echo "
"; print_r($list); echo "
";die;


        switch ($data['danwei']) {
            case 1:
                $danwei = '个';
                break;
            case 2:
                $danwei = '套';
                break;
            case 3:
                $danwei = '张';
                break;
            default:
                $danwei = '';
                break;
        }

        $userinfo = Session::get('admin');//获取用户信息
        $arr = [
            'batch' => $data['gdbh'],
            'create_time' => time(),
            'delect_time' => '',
            'sync_flag' => 0,
        ];
        $productres = $QcodeCompany->save($arr);
        if ($productres === 0){
            $this->error('添加失败');
        }


        $batchList = [
            'userid' => $userinfo['id'],//登录用户id
            'supplier_id' => $userinfo['id'],//登录用户id
            'supplier_code' => $userinfo['printer_code'],

            'supplier_name' => $data['company_name'],//公司名称
            'cpbm' => $data['cpbm'],//成品编码
            'matter_name' => $data['cpmc'],//成品名称
            'matter_no' => $data['gdbh'],//生产批次号-工单编号
            'order_ddbh' => $data['order_ddbh'],//销售订单号
            'matter_id' => $data['gdbh'],
            'matter_type' => '01',
            'manufacture_date' => (int)date('ymd',strtotime($data['manufacture_date'])),//生产日期
            'print_date' => (int)date('ymd',strtotime($data['print_date'])),//打码日期

            'num_danwei' => $data['danwei'],//单位
            'danwei' => $danwei,//单位
            'num' => $data['number'],//总数量(张/个)
            'small_num' => $data['box_number'],//每一箱数量
            'tray_num' => $data['tray_num'],//每层箱数【箱/层】
            'box_num' => $data['tray_number'],//每托层数【 层/托】
            'total_boxes' => $data['total_boxes'],//每托盘箱数【箱/托】
            'large_num' => $data['box_num'],//本次打包托盘数
            'larger_num' => $data['small_num'],//总箱数
            'pallet_height' => $data['pallet_height'],//每托高度
            'pallet_length' => $data['pallet_length'],//托盘规格
            'pallet_width' => $data['pallet_width'],//托盘规格

            'l_reservation' => '',
            // 处理可能为空的流水/重量字段
            'l_flow' => $data['big_liushui'],//大件流水
            'l_weight' => $data['big_weight'],//大件重量
            's_flow' => $data['small_start_liushui'],//小件流水
            's_weight' => $data['small_weight'],//小件重量
            's_reservation' => '',
            'bach_status' => 0,
            'bach_num' => $data['gdbh'],//生产批次号-工单编号
            'large_endnum' => $data['big_liushui'] + $data['box_num'] -1,
            'create_time' => time(),//新增时间
            'delect_time' => '',//删除时间
        ];

        $res = $bach->save($batchList);
        if ($res === 0){
            $this->error('添加失败');
        }

        $flow = [
            'l_flow' => (int)$batchList['large_num'],
            'bach_num' => $batchList['matter_no'],
        ];
        if ($resetFlow->name($userinfo['company'].'_'."reset_flow")->where('product_id',$batchList['matter_no'])->find()){
            $resetFlow->name($userinfo['company'].'_'."reset_flow")->where('product_id',$batchList['matter_no'])->update($flow);
        }else{
            $flow['product_id'] = $batchList['matter_no'];
            $resetFlow->save($flow);
        }

        $last_id = $bach->getLastInsID();
        if ($last_id){
            //插入大小二维码数据 二维码数据不变区域
//            echo "
";print_r($batchList);echo "
";die;

            $fixed_code = '';
            $fixed_code.=$this->intTochar($batchList['matter_type'],2);//2位  辅料种类编码
            $fixed_code .= $this->intTochar($batchList['supplier_code'], 21);//21位  供应商编码
            $fixed_code .= '9'; // 补0一位
            $fixed_code.=$this->intTochar($batchList['cpbm'],10);//10位  辅料编码
            $fixed_code.=$batchList['manufacture_date'];//6位  生产日期
            $print_code=$batchList['print_date'];//6位  打码日期

            $small_liushui = [
                'onlycode' => 'AB92'.$fixed_code.$print_code,
                'last_num' => 0,
                'user_id' => $userinfo['company'],
                'stype' => 2,
                'dateTime' => time(),
            ];

            $whereSmall = [
                'onlycode' => $small_liushui['onlycode'],
                'user_id' => $userinfo['company'],
            ];

            if ($liushui->name($userinfo['company'].'_'.'qcode_liushui')->where($whereSmall)->find()){
                //小件二维码存在，更新小件二维码最后流水号
                $lastNum = $liushui->name($userinfo['company'].'_'.'qcode_liushui')->where($whereSmall)->find();
            }else{
                //小件二维码不存在，新增记录
                $liushui->save($small_liushui);
                $lastNum['last_num'] = 0;
            }

            //循环插入大件二维码数据
            for ($i=0;$i<$data['box_num'];$i++){
                $large = new QcodeLarge();
                $l_flow = $this->intTochar($batchList['l_flow']+$i,6);
                $l_weight = $this->intTochar($batchList['l_weight']*100,6);
                $l_reservation = $this->intTochar($batchList['matter_no'],10);
                $l_reservation = $l_reservation.'0000000000';
                $remainder = $batchList['num'] - $batchList['total_boxes'] * $i;//最后一托盘小件数量

                if ($remainder < $batchList['tray_num']){
                    $small_n = $this->intTochar($remainder,3);//3位小件数量，不足补0
                }else{
                    $small_n = $this->intTochar($batchList['tray_num'],3);
                }

//                $l_num = $small_n * $batchList['box_num'];
                $l_num = 0;


                //大件二维码数据
                $code_data = $this->CodeData('AB92',$fixed_code,$small_n,$print_code,$l_flow,$l_weight,'2',$l_reservation);

                //大码数据信息
                $l_data = [
                    'bach_id' => $last_id,
                    'code' => $code_data['code'],
                    'code_cp1' => $code_data['code_cp1'],
                    'code_cp2' => $code_data['code_cp2'],
                    'print_date' => $print_code,
                    'create_time' => time(),
                    'p_nums' => 0,
                    'userid' =>$userinfo['id'],
                    'l_weight' =>$batchList['l_weight']*100,
                    'l_num' =>$l_num,
                    'l_status' => 0,
                    'l_print' => 0
                ];

                $l_res = $large->save($l_data);
                if ($l_res === 0){
                    $this->error('大件码插入失败');
                }
                $large_id = $large->getLastInsID();
                if ($large_id){
//                    //小件码循环插入
//                    for ($j=0;$j<$data['tray_num'] and ($j+$i*$data['tray_num'])<$batchList['small_num'];$j++){
                    for ($j=0;$j<$data['total_boxes'] and ($j+$i*$data['total_boxes'])<$batchList['total_boxes'];$j++){
                        $small = new QcodeSmall();
                        $s_flow = $this->intTochar($batchList['s_flow']+$j+$i*$data['tray_num']+$lastNum['last_num'],6);//小件码序号从1开始
                        $s_weight = $this->intTochar($batchList['s_weight'],6);
                        $small_sign = '000';
                        $s_reservation = $this->intTochar($batchList['bach_num'],10);
                        $s_reservation = $s_reservation . '0000000000';
                        //生成小件码
                        $small_code_data = $this->CodeData('AB92',$fixed_code,$small_sign,$print_code,$s_flow,$s_weight,'1',$s_reservation);
                        //小码数据
                        $s_data = [
                            'large_id'=>$large_id,
                            'bach_id'=>$last_id,
                            'code'=>$small_code_data['code'],
                            'code_cp1'=>$small_code_data['code_cp1'],
                            'code_cp2'=>$small_code_data['code_cp2'],
                            'l_flow'=>$j+1,
                            'print_date'=>$print_code,
                            'create_time'=>time(),
                            'p_nums'=>0,
                            'userid'=>$userinfo['id'],//小码绑定用户id
                            's_weight'=>$batchList['s_weight'],//单个小件重量
                            'status' => 0,
                        ];
                        $s_res = $small->save($s_data);
                        if ($s_res === 0){
                            $this->error('小件码插入失败');
                        }
                    }
                }else{
                    $this->error('添加失败');
                }

            }
        }
        $liushui_res = $liushui->name($userinfo['id'].'_'.'qcode_liushui')->where($whereSmall)->update(['last_num'=>$batchList['small_num']]);
        if ($liushui_res === false){
            $this->error('添加失败');
        }
        return json(['code' => 1, 'msg' => '成功', 'data' => '']);
//        $this->success('成功');
    }

    /**
     * 编码补位
     * @param $num
     * @param $len
     * @return string
     */
    function intTochar($num=0,$len){
        //规定的不足的时候自动补足零
        $code=(string)$num;
        $buwei='';
        if(strlen($code)<$len){
            for($i=strlen($code);$i<$len;$i++){
                $buwei.='0';
            }
        }
        return $buwei.$code;
    }

    /**
     * 二维码编码生成
     * @param $sign
     * @param $fixed_code
     * @param $small_num
     * @param $print_date
     * @param $flow
     * @param $weight
     * @param $large_sign
     * @param $reservation
     * @return array
     */
    function CodeData($sign,$fixed_code,$small_num,$print_date,$flow,$weight,$large_sign,$reservation){
        $code=$sign;//4 位固定标志位
        $code.=$fixed_code; // 固定字符串
        $code.=$small_num;//3位 小件数量
        $code.=$print_date;//6 位 日期
        $code.=$flow;//6位打印流水号
        $code.=$weight;//6位辅料重量
        $code.=$large_sign;//大小件标示位

        $code.=$reservation;//20 位 预留号

        //大码数据信息
        $data=[
            'code'=>str_replace(" ","",$code),
            'code_cp1'=>$print_date.$flow,
            'code_cp2'=>$weight.$reservation,//20位补充
            'print_date'=>time(),
            'p_nums'=>0,
        ];
        return $data;
    }
}