$userinfo['company_name'], 'postcode' => $userinfo['postcode'], 'mobile' => $userinfo['mobile'], 'printer_code' => $userinfo['printer_code'], 'company_address' => $userinfo['company_address'] ]; $this->view->assign('row',$data); //将对此账号创建公司唯一id,进行创建公司对应公司表名company id $user_company_value = Db::name('admin')->where('id', $userinfo['id'])->value('company'); if (empty($user_company_value)) { $max_company = Db::name('admin')->max('company'); $new_company_value = $max_company ? ($max_company + 1) : 1; Db::name('admin')->where('id', $userinfo['id'])->update(['company' => $new_company_value]); } else { $new_company_value = $user_company_value; } $tableNames = [ $new_company_value . '_qcode_bach', $new_company_value . '_qcode_company', $new_company_value . '_qcode_large', $new_company_value . '_qcode_liushui', $new_company_value . '_qcode_small', $new_company_value . '_reset_flow', ]; foreach ($tableNames as $tableName) { try { Db::connect('mongodb')->name($tableName)->insert(['init' => 1]); // 删除测试数据(可选,如果不想保留这个测试数据) Db::connect('mongodb')->name($tableName)->where('init', 1)->delete(); } catch (\Exception $e) { echo "创建集合 {$tableName} 失败:" . $e->getMessage(); } } return $this->view->fetch(); } /** * 获取产品信息 */ public function product(){ $params = input(''); $page = max(1, (int)$params['page']); $limit = max(1, (int)$params['limit']); $offset = ($page - 1) * $limit; // 获取工单编号列表 $db3 = Db::connect(config('database.db3')); $gdRows = $db3->query("SELECT DISTINCT `Gd_gdbh`, `Gd_客户代号`, `Gd_cpdh` FROM `工单_基本资料` WHERE `Gd_客户代号` = ?", ['J0031']); $Gd_gdbhList = array_column($gdRows, 'Gd_gdbh'); $gdbhList = array_column($gdRows, 'Gd_cpdh'); if (empty($gdbhList)) { $this->assign([ 'data' => '', 'total' => '', ]); } // Mongo 查询 $mongo = \think\Db::connect('mongodb'); $where = ['成品编码' => ['in', $gdbhList],'jjcp_gdbh' => ['in', $Gd_gdbhList], 'jjcp_smb' => '末 板']; // $where = ['成品编码' => ['in', $gdbhList], 'jjcp_smb' => '末 板']; if (!empty($params['search'])) { $where['成品编码|成品名称|jjcp_gdbh|订单编号'] = new \MongoDB\BSON\Regex($params['search'], 'i'); } // 查询符合条件的成品数据 $al_products = $mongo->name('finished_products') ->where($where) ->order('Sys_rq', 'desc') ->select(); // 查询 texts = 新增产品 的数据 $xz_products = $mongo->name('finished_products') ->where('texts', '新增产品') ->order('Sys_rq', 'desc') ->select(); // 合并数据 $all_products = array_merge($al_products, $xz_products); // 分组聚合处理 $grouped_products = []; foreach ($all_products as $item) { // 转换日期格式(如果是 d/m/Y H:i:s) $date = \DateTime::createFromFormat('d/m/Y H:i:s', $item['Sys_rq']); $item['Sys_rq'] = $date ? $date->format('Y-m-d H:i:s') : $item['Sys_rq']; $group_key = $item['订单编号'] . '_' . $item['jjcp_gdbh']; if (!isset($grouped_products[$group_key])) { $grouped_products[$group_key] = [ 'Sys_rq' => $item['Sys_rq'], 'order_ddbh' => $item['订单编号'], 'gdbh' => $item['jjcp_gdbh'], 'cpbm' => $item['成品编码'], 'cpmc' => $item['成品名称'], 'sl' => 0, 'cpdh_list' => [], 'cpbm_list' => [] ]; } $grouped_products[$group_key]['sl'] += (int)$item['jjcp_sl']; if (!in_array($item['jjcp_cpdh'], $grouped_products[$group_key]['cpdh_list'])) { $grouped_products[$group_key]['cpdh_list'][] = $item['jjcp_cpdh']; } if (!in_array($item['成品编码'], $grouped_products[$group_key]['cpbm_list'])) { $grouped_products[$group_key]['cpbm_list'][] = $item['成品编码']; } } // 格式化列表字符串 foreach ($grouped_products as &$group) { $group['cpdh'] = implode(',', $group['cpdh_list']); $group['cpbm'] = implode(',', $group['cpbm_list']); unset($group['cpdh_list'], $group['cpbm_list']); } // 聚合结果排序(按时间降序) $all_grouped = array_values($grouped_products); usort($all_grouped, function ($a, $b) { $timeA = strtotime($a['Sys_rq']) ?: 0; $timeB = strtotime($b['Sys_rq']) ?: 0; return $timeB <=> $timeA; }); // 再分页 $total = count($all_grouped); $paged_grouped = array_slice($all_grouped, $offset, $limit); // 查询库存并计算剩余数 foreach ($paged_grouped as &$prod) { $inventory = $mongo->name('inventory_summary')->where([ 'order_ddbh' => $prod['order_ddbh'], 'gdbh' => $prod['gdbh'], 'cpmc' => $prod['cpmc'], ])->find(); $total_chu_quantity = isset($inventory['total_chu_quantity']) ? (int)$inventory['total_chu_quantity'] : 0; $prod['total_chu_quantity'] = $total_chu_quantity; $prod['remaining_quantity'] = $prod['sl'] - $total_chu_quantity; } unset($prod); return json([ 'code' => 1, 'data' => $paged_grouped, 'total' => $total, 'page' => $page, 'limit' => $limit ]); } /** * 添加批次功能 * * 功能说明: * 1. 处理AJAX请求,创建产品批次 * 2. 自动计算托盘分配(完整托盘和不完整托盘) * 3. 生成批次号和相关统计信息 * 4. 更新库存记录 * 5. 支持多种托盘配置(18箱/24箱/36箱) */ // public function add_bach() // { // if (!$this->request->isAjax()) { // $this->error('非法请求,必须使用AJAX方式提交'); // } // $data = input('row'); // 获取原始数据 // if (empty($data)) { // $this->error('请求参数不能为空'); // } // $data = json_decode($data, true); // if (json_last_error() !== JSON_ERROR_NONE) { // $this->error('JSON数据解析失败:' . json_last_error_msg()); // } // if (empty($data['products']) || !is_array($data['products'])) { // $this->error('产品数据不能为空且必须是数组'); // } // $userinfo = Session::get('admin'); // if (empty($userinfo) || !isset($userinfo['company'])) { // $this->error('获取用户信息失败,请重新登录'); // } // //连接MongoDB // $mongo = \think\Db::connect('mongodb'); // //动态生成集合名称(基于公司名称) // $collection = $userinfo['company'] . '_qcode_bach'; // 主表 // $bachdetails = $userinfo['company'] . '_qcode_bachdetails'; // 托盘明细表 // $bachsummary = $userinfo['company'] . '_qcode_bachsummary'; // 批次汇总表 // // $currentDate = date('Y-m-d'); // $currentDateTime = date('Y-m-d H:i:s'); // $timestamp = time(); // $bachNum = 'BACH' . date('YmdHis') . mt_rand(1000, 9999); // // $batchStats = [ // 'total_quantity' => 0, // 总产品数量 // 'total_boxes' => 0, // 总箱数 // 'total_pallets' => 0, // 总托盘数 // 'full_pallets' => 0, // 完整托盘数 // 'partial_pallets' => 0, // 不完整托盘数 // 'product_varieties' => count($data['products']) // 产品种类数 // ]; // // $productDetails = []; // 产品主表数据 // $palletDetails = []; // 托盘明细数据 // $currentPalletNo = 1; // 托盘编号计数器 // // /** // * 处理完整托盘 // * 先分配完整托盘 // */ // foreach ($data['products'] as $product) { // // 6.1 动态获取托盘配置 // $tray_count = $product['tray_count'] ?? 18; // 默认18箱/托盘 // // // 6.2 根据托盘配置确定层数和每层箱数 // if ($tray_count == 18) { // $box_num = 3; // 3层 // $per_box = 6; // 每层6箱 // } elseif ($tray_count == 24) { // $box_num = 4; // 4层 // $per_box = 6; // 每层6箱 // } elseif ($tray_count == 36) { // $box_num = 4; // 4层 // $per_box = 9; // 每层9箱 // } else { // $this->error('不支持的托盘配置:' . $tray_count); // } // // $boxes_per_pallet = $per_box * $box_num; // 每托盘总箱数 // $small_num = $product['items_per_box'] ?? 20; // 每箱数量,默认20 // $default_layer_height = $product['default_layer_height'] ?? '1.35'; // 默认层高 // // // 6.3 计算实际发货数量(不超过剩余数量) // $remaining = (int)$product['remaining_quantity']; // $actual = isset($product['actual_quantity']) ? // min((int)$product['actual_quantity'], $remaining) : $remaining; // // // 6.4 计算托盘分配 // $total_boxes = ceil($actual / $small_num); // 总箱数 // $full_pallets = floor($total_boxes / $boxes_per_pallet); // 完整托盘数 // $remaining_boxes = $total_boxes % $boxes_per_pallet; // 剩余箱数 // // // 6.5 构建产品基础信息 // $baseInfo = [ // 'bach_ids' => $bachNum, // 'userid' => $userinfo['id'], // 'gdbh' => $product['gdbh'], // 'order_ddbh' => $product['order_ddbh'], // 'cpbm' => $product['cpbm'], // 'cpmc' => $product['cpmc'], // 'matter_name' => $product['cpmc'], // 'remark' => $product['remark'] ?? '', // 'small_num' => $small_num, // 'unit' => $product['unit'] ?? '套', // 'tray_num' => $per_box, // 'box_num' => $box_num, // 'tray_count' => $tray_count, // 'layer_height' => $product['layer_height'] ?? $default_layer_height, // 'pallet_length' => $product['pallet_length'] ?? '0.9', // 'pallet_width' => $product['pallet_width'] ?? '1.2', // 'bach_status' => 0, // 状态(0:未处理) // 'sys_rq' => $currentDate, // 'created_at' => $currentDateTime, // 'create_time' => $timestamp, // 'delete_time' => '' // ]; // // // 6.6 处理完整托盘 // if ($full_pallets > 0) { // $full_qty = $full_pallets * $boxes_per_pallet * $small_num; // $endNo = $currentPalletNo + $full_pallets - 1; // // $productDetails[] = array_merge($baseInfo, [ // 'actual_quantity' => $full_qty, // 'total_boxes' => $full_pallets * $boxes_per_pallet, // 'pallet_count' => $full_pallets, // 'pallet_type' => 'full', // 'pallet_range' => "$currentPalletNo-$endNo", // 'start_pallet_no' => $currentPalletNo, // 'end_pallet_no' => $endNo // ]); // // // 生成托盘明细记录 // for ($i = 0; $i < $full_pallets; $i++) { // $palletDetails[] = [ // 'bach_ids' => $bachNum, // 'product_id' => $product['gdbh'], // 'pallet_no' => $currentPalletNo + $i, // 'pallet_no_display' => $currentPalletNo + $i, // 'pallet_type' => 'full', // 'quantity' => $boxes_per_pallet * $small_num, // 'box_count' => $boxes_per_pallet, // 'layer_count' => $box_num, // 'bach_status' => 0, // 'created_at' => $currentDateTime, // 'delete_time' => '' // ]; // } // // // 更新统计信息 // $batchStats['full_pallets'] += $full_pallets; // $batchStats['total_quantity'] += $full_qty; // $batchStats['total_boxes'] += $full_pallets * $boxes_per_pallet; // $currentPalletNo += $full_pallets; // $batchStats['total_pallets'] += $full_pallets; // } // } // // /** // * 处理不完整托盘 // * 分配剩余不能组成完整托盘的部分 // */ // foreach ($data['products'] as $product) { // // 同上获取托盘配置 // $tray_count = $product['tray_count'] ?? 18; // // if ($tray_count == 18) { // $box_num = 3; // $per_box = 6; // } elseif ($tray_count == 24) { // $box_num = 4; // $per_box = 6; // } elseif ($tray_count == 36) { // $box_num = 4; // $per_box = 9; // } else { // continue; // 已在前阶段验证过,这里跳过 // } // // $boxes_per_pallet = $per_box * $box_num; // $small_num = $product['items_per_box'] ?? 20; // $default_layer_height = $product['default_layer_height'] ?? '1.35'; // // $remaining = (int)$product['remaining_quantity']; // $actual = isset($product['actual_quantity']) ? // min((int)$product['actual_quantity'], $remaining) : $remaining; // // $total_boxes = ceil($actual / $small_num); // $full_pallets = floor($total_boxes / $boxes_per_pallet); // $remaining_boxes = $total_boxes % $boxes_per_pallet; // // $baseInfo = [ // 'bach_ids' => $bachNum, // 'userid' => $userinfo['id'], // 'gdbh' => $product['gdbh'], // 'order_ddbh' => $product['order_ddbh'], // 'cpbm' => $product['cpbm'], // 'cpmc' => $product['cpmc'], // 'matter_name' => $product['cpmc'], // 'remark' => $product['remark'] ?? '', // 'small_num' => $small_num, // 'unit' => $product['unit'] ?? '套', // 'tray_num' => $per_box, // 'box_num' => $box_num, // 'tray_count' => $tray_count, // 'layer_height' => $product['layer_height'] ?? $default_layer_height, // 'pallet_length' => $product['pallet_length'] ?? '0.9', // 'pallet_width' => $product['pallet_width'] ?? '1.2', // 'bach_status' => 0, // 'sys_rq' => $currentDate, // 'created_at' => $currentDateTime, // 'create_time' => $timestamp, // 'delete_time' => '' // ]; // // // 处理不完整托盘 // if ($remaining_boxes > 0) { // $partial_qty = $remaining_boxes * $small_num; // // $productDetails[] = array_merge($baseInfo, [ // 'actual_quantity' => $partial_qty, // 'total_boxes' => $remaining_boxes, // 'pallet_count' => 1, // 'pallet_type' => 'partial', // 'pallet_range' => (string)$currentPalletNo, // 'start_pallet_no' => $currentPalletNo, // 'end_pallet_no' => $currentPalletNo // ]); // // $palletDetails[] = [ // 'bach_ids' => $bachNum, // 'product_id' => $product['gdbh'], // 'pallet_no' => $currentPalletNo, // 'pallet_no_display' => $currentPalletNo, // 'pallet_type' => 'partial', // 'quantity' => $partial_qty, // 'box_count' => $remaining_boxes, // 'layer_count' => ceil($remaining_boxes / $per_box), // 'bach_status' => 0, // 'created_at' => $currentDateTime, // 'delete_time' => '' // ]; // // // 更新统计信息 // $batchStats['partial_pallets']++; // $batchStats['total_quantity'] += $partial_qty; // $batchStats['total_boxes'] += $remaining_boxes; // $currentPalletNo++; // $batchStats['total_pallets']++; // } // } // // $summaryData = [ // 'bach_ids' => $bachNum, // 'userid' => $userinfo['id'], // 'total_quantity' => $batchStats['total_quantity'], // 'total_boxes' => $batchStats['total_boxes'], // 'total_pallets' => $batchStats['total_pallets'], // 'product_count' => $batchStats['product_varieties'], // 'full_pallets' => $batchStats['full_pallets'], // 'partial_pallets' => $batchStats['partial_pallets'], // 'bach_status' => 0, // 'sys_rq' => $currentDate, // 'created_at' => $currentDateTime, // 'create_time' => $timestamp, // 'delete_time' => '' // ]; // // // // 写入产品主表 // $mongo->name($collection)->insertAll($productDetails); // // // 写入托盘明细表 // $mongo->name($bachdetails)->insertAll($palletDetails); // // // 写入批次汇总表 // $mongo->name($bachsummary)->insert($summaryData); // // // foreach ($data['products'] as $product) { // $where = [ // 'gdbh' => $product['gdbh'], // 'order_ddbh' => $product['order_ddbh'], // 'cpmc' => $product['cpmc'], // ]; // // $actual = (int)($product['actual_quantity'] ?? 0); // $remaining = (int)$product['remaining_quantity']; // // // 查询现有库存记录 // $existing = $mongo->name('inventory_summary')->where($where)->find(); // // if ($existing) { // // 处理查询结果 // if (is_object($existing)) { // $existing = (array)$existing; // } // if (isset($existing[0])) { // $existing = $existing[0]; // } // // // 更新库存 // $mongo->name('inventory_summary') // ->where($where) // ->update([ // 'total_chu_quantity' => ($existing['total_chu_quantity'] ?? 0) + $actual, // 'remaining_quantity' => ($existing['remaining_quantity'] ?? 0) - $actual, // 'updated_at' => $currentDateTime, // ]); // } else { // // 新增库存记录 // $mongo->name('inventory_summary')->insert([ // 'gdbh' => $product['gdbh'], // 'order_ddbh' => $product['order_ddbh'], // 'cpbm' => $product['cpbm'], // 'cpmc' => $product['cpmc'], // 'total_ru_quantity' => $remaining, // 'total_chu_quantity' => $actual, // 'remaining_quantity' => $remaining - $actual, // 'created_at' => $currentDateTime, // 'company' => $data['company_name'] ?? '', // ]); // } // // // 添加库存记录 // $mongo->name('inventory_records')->insert([ // 'gdbh' => $product['gdbh'], // 'order_ddbh' => $product['order_ddbh'], // 'cpbm' => $product['cpbm'], // 'cpmc' => $product['cpmc'], // 'operation_type' => 'outbound', // 'quantity' => $actual, // 'remaining_quantity' => $remaining - $actual, // 'operator' => $userinfo['id'], // 'created_at' => $currentDateTime, // 'batch_number' => $bachNum, // 'company' => $data['company_name'] ?? '', // ]); // } // $this->success('批次创建成功'); // } public function add_bach() { if (!$this->request->isAjax()) { $this->error('非法请求,必须使用AJAX方式提交'); } $data = input('row'); if (empty($data)) { $this->error('请求参数不能为空'); } $data = json_decode($data, true); if (json_last_error() !== JSON_ERROR_NONE) { $this->error('JSON数据解析失败:' . json_last_error_msg()); } if (empty($data['products']) || !is_array($data['products'])) { $this->error('产品数据不能为空且必须是数组'); } $userinfo = Session::get('admin'); if (empty($userinfo) || !isset($userinfo['company'])) { $this->error('获取用户信息失败,请重新登录'); } $mongo = \think\Db::connect('mongodb'); $collection = $userinfo['company'] . '_qcode_bach'; $bachdetails = $userinfo['company'] . '_qcode_bachdetails'; $bachsummary = $userinfo['company'] . '_qcode_bachsummary'; $currentDate = date('Y-m-d'); $currentDateTime = date('Y-m-d H:i:s'); $timestamp = time(); $bachNum = 'BACH' . date('YmdHis') . mt_rand(1000, 9999); $batchStats = [ 'total_quantity' => 0, 'total_boxes' => 0, 'total_pallets' => 0, 'full_pallets' => 0, 'partial_pallets' => 0, 'product_varieties' => count($data['products']) ]; $productDetails = []; $palletDetails = []; $currentPalletNo = 1; foreach ($data['products'] as $product) { $tray_count = $product['tray_count'] ?? 18; if ($tray_count == 18) { $box_num = 3; $per_box = 6; } elseif ($tray_count == 24) { $box_num = 4; $per_box = 6; } elseif ($tray_count == 36) { $box_num = 4; $per_box = 9; } else { $this->error('不支持的托盘配置:' . $tray_count); } $boxes_per_pallet = $per_box * $box_num; $small_num = $product['items_per_box'] ?? 20; $default_layer_height = $product['default_layer_height'] ?? '1.35'; $remaining = (int)$product['remaining_quantity']; $actual = isset($product['actual_quantity']) ? min((int)$product['actual_quantity'], $remaining) : $remaining; $full_pallets = floor($actual / ($boxes_per_pallet * $small_num)); $full_qty = $full_pallets * $boxes_per_pallet * $small_num; $partial_qty = $actual - $full_qty; $remaining_boxes = ceil($partial_qty / $small_num); $baseInfo = [ 'bach_ids' => $bachNum, 'userid' => $userinfo['id'], 'gdbh' => $product['gdbh'], 'order_ddbh' => $product['order_ddbh'], 'cpbm' => $product['cpbm'], 'cpmc' => $product['cpmc'], 'matter_name' => $product['cpmc'], 'remark' => $product['remark'] ?? '', 'small_num' => $small_num, 'unit' => $product['unit'] ?? '套', 'tray_num' => $per_box, 'box_num' => $box_num, 'tray_count' => $tray_count, 'layer_height' => $product['layer_height'] ?? $default_layer_height, 'pallet_length' => $product['pallet_length'] ?? '0.9', 'pallet_width' => $product['pallet_width'] ?? '1.2', 'bach_status' => 0, 'sys_rq' => $currentDate, 'created_at' => $currentDateTime, 'create_time' => $timestamp, 'delete_time' => '' ]; if ($full_pallets > 0) { $endNo = $currentPalletNo + $full_pallets - 1; $productDetails[] = array_merge($baseInfo, [ 'actual_quantity' => $full_qty, 'total_boxes' => $full_pallets * $boxes_per_pallet, 'pallet_count' => $full_pallets, 'pallet_type' => 'full', 'pallet_range' => "$currentPalletNo-$endNo", 'start_pallet_no' => $currentPalletNo, 'end_pallet_no' => $endNo ]); for ($i = 0; $i < $full_pallets; $i++) { $palletDetails[] = [ 'bach_ids' => $bachNum, 'code' => 'AB92' . $userinfo['printer_code'] . $product['cpbm'] . '0000000000' . date('Ymd') . $product['gdbh'] . date('Ymd') . '00000000000', 'product_id' => $product['gdbh'], 'pallet_no' => $currentPalletNo + $i, 'pallet_no_display' => $currentPalletNo + $i, 'pallet_type' => 'full', 'quantity' => $boxes_per_pallet * $small_num, 'box_count' => $boxes_per_pallet, 'per_box' => $per_box, 'box_num' => $box_num, 'bach_status' => 0, 'created_time' => $currentDate, 'created_at' => $currentDateTime, 'delete_time' => '' ]; } $batchStats['full_pallets'] += $full_pallets; $batchStats['total_quantity'] += $full_qty; $batchStats['total_boxes'] += $full_pallets * $boxes_per_pallet; $currentPalletNo += $full_pallets; $batchStats['total_pallets'] += $full_pallets; } if ($partial_qty > 0) { $productDetails[] = array_merge($baseInfo, [ 'actual_quantity' => $partial_qty, 'total_boxes' => $remaining_boxes, 'pallet_count' => 1, 'pallet_type' => 'partial', 'pallet_range' => (string)$currentPalletNo, 'start_pallet_no' => $currentPalletNo, 'end_pallet_no' => $currentPalletNo ]); $palletDetails[] = [ 'bach_ids' => $bachNum, 'code' => 'AB92' . $userinfo['printer_code'] . $product['cpbm'] . '0000000000' . date('Ymd') . $product['gdbh'] . date('Ymd') . '00000000000', 'product_id' => $product['gdbh'], 'pallet_no' => $currentPalletNo, 'pallet_no_display' => $currentPalletNo, 'pallet_type' => 'partial', 'quantity' => $partial_qty, 'box_count' => $remaining_boxes, 'per_box' => $per_box, 'box_num' => $box_num, 'bach_status' => 0, 'created_time' => $currentDate, 'created_at' => $currentDateTime, 'delete_time' => '' ]; $batchStats['partial_pallets']++; $batchStats['total_quantity'] += $partial_qty; $batchStats['total_boxes'] += $remaining_boxes; $currentPalletNo++; $batchStats['total_pallets']++; } } $summaryData = [ 'bach_ids' => $bachNum, 'userid' => $userinfo['id'], 'total_quantity' => $batchStats['total_quantity'], 'total_boxes' => $batchStats['total_boxes'], 'total_pallets' => $batchStats['total_pallets'], 'product_count' => $batchStats['product_varieties'], 'full_pallets' => $batchStats['full_pallets'], 'partial_pallets' => $batchStats['partial_pallets'], 'bach_status' => 0, 'sys_rq' => $currentDate, 'created_at' => $currentDateTime, 'create_time' => $timestamp, 'delete_time' => '' ]; $mongo->name($collection)->insertAll($productDetails); $mongo->name($bachdetails)->insertAll($palletDetails); $mongo->name($bachsummary)->insert($summaryData); // 库存更新部分(未改动) foreach ($data['products'] as $product) { $where = [ 'gdbh' => $product['gdbh'], 'order_ddbh' => $product['order_ddbh'], 'cpmc' => $product['cpmc'], ]; $actual = (int)($product['actual_quantity'] ?? 0); $remaining = (int)$product['remaining_quantity']; $existing = $mongo->name('inventory_summary')->where($where)->find(); if ($existing) { if (is_object($existing)) $existing = (array)$existing; if (isset($existing[0])) $existing = $existing[0]; $mongo->name('inventory_summary') ->where($where) ->update([ 'total_chu_quantity' => ($existing['total_chu_quantity'] ?? 0) + $actual, 'remaining_quantity' => ($existing['remaining_quantity'] ?? 0) - $actual, 'updated_at' => $currentDateTime, ]); } else { $mongo->name('inventory_summary')->insert([ 'gdbh' => $product['gdbh'], 'order_ddbh' => $product['order_ddbh'], 'cpbm' => $product['cpbm'], 'cpmc' => $product['cpmc'], 'total_ru_quantity' => $remaining, 'total_chu_quantity' => $actual, 'remaining_quantity' => $remaining - $actual, 'created_at' => $currentDateTime, 'company' => $data['company_name'] ?? '', ]); } $mongo->name('inventory_records')->insert([ 'gdbh' => $product['gdbh'], 'order_ddbh' => $product['order_ddbh'], 'cpbm' => $product['cpbm'], 'cpmc' => $product['cpmc'], 'operation_type' => 'outbound', 'total_ru_quantity' => $remaining, 'total_chu_quantity' => $actual, 'remaining_quantity' => $remaining - $actual, 'operator' => $userinfo['id'], 'created_at' => $currentDateTime, 'batch_number' => $bachNum, 'company' => $data['company_name'] ?? '', ]); } $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;
}
}