$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();
}
}
// //统计产品信息数据
// $mongo = \think\Db::connect('mongodb');
// // 获取成品入仓表数据
// $mongo_products = $mongo
// ->name('finished_products')
// ->field('成品名称, jjcp_cpdh, 订单编号, jjcp_gdbh, jjcp_sl')
// ->order('UniqId','desc')
// ->where('jjcp_smb','末 板')
// ->limit(1,50)
// ->select();
//
// $grouped_products = [];
// foreach ($mongo_products as $item) {
// $group_key = $item['订单编号'] . '_' . $item['jjcp_gdbh'];
// if (!isset($grouped_products[$group_key])) {
// $grouped_products[$group_key] = [
// 'order_ddbh' => $item['订单编号'],
// 'gdbh' => $item['jjcp_gdbh'],
// 'cpmc' => $item['成品名称'],
//// 'cpdh' => $item['jjcp_cpdh'],
// 'ruku_sl' => 0, // 入库数量
// 'remain_stock' => 0, // 剩余库存
// 'sl' => 0
// ];
// }
// // 累加入库数量
// $grouped_products[$group_key]['ruku_sl'] += (int)$item['jjcp_sl'];
// }
// // 查询库存表并计算
// foreach ($grouped_products as $group_key => &$prod) {
// $where = [
// 'order_ddbh' => $prod['order_ddbh'],
// 'gdbh' => $prod['gdbh'],
// 'cpmc' => $prod['cpmc'],
// ];
//
// $inventory = $mongo->name('inventory_summary')->where($where)->find();
// $prod['remaining_quantity'] = $inventory ? (int)$inventory['remaining_quantity'] : 0;
// $prod['sl'] = $prod['remaining_quantity'] > 0 ? $prod['remaining_quantity'] : $prod['ruku_sl'];
// }
// unset($prod);
// $matched_products = array_values($grouped_products);
// $this->view->assign('product', $matched_products);
return $this->view->fetch();
}
/**
* 获取产品信息
* 查询入仓表【finished_products】
*/
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 = ['jjcp_cpdh' => ['in', $gdbhList],'jjcp_gdbh' => ['in', $Gd_gdbhList], 'jjcp_smb' => '末 板'];
if (!empty($params['search'])) {
$where['jjcp_cpdh|成品名称|jjcp_gdbh|订单编号'] = new \MongoDB\BSON\Regex($params['search'], 'i');
}
// 1. 查询所有符合条件的成品数据（不分页）
$all_products = $mongo->name('finished_products')
->where($where)
->order('UniqId', 'desc')
->select();
// 2. 按订单编号 + 工单编号分组聚合
$grouped_products = [];
foreach ($all_products as $item) {
$group_key = $item['订单编号'] . '_' . $item['jjcp_gdbh'];
if (!isset($grouped_products[$group_key])) {
$grouped_products[$group_key] = [
'order_ddbh' => $item['订单编号'],
'gdbh' => $item['jjcp_gdbh'],
'cpmc' => $item['成品名称'],
'ruku_sl' => 0,
'remain_stock' => 0,
'sl' => 0
];
}
$grouped_products[$group_key]['sl'] += (int)$item['jjcp_sl'];
}
// 3. 将聚合后结果分页（稳定分页）
$all_grouped = array_values($grouped_products);
$total = count($all_grouped);
$paged_grouped = array_slice($all_grouped, $offset, $limit);
// 4. 获取库存数据
foreach ($paged_grouped as &$prod) {
$inventory = $mongo->name('inventory_summary')->where([
'order_ddbh' => $prod['order_ddbh'],
'gdbh' => $prod['gdbh'],
'cpmc' => $prod['cpmc'],
])->find();
// $prod['remaining_quantity'] = $inventory ? (int)$inventory['remaining_quantity'] : 0;
// $prod['sl'] = $prod['remaining_quantity'] > 0 ? $prod['remaining_quantity'] : $prod['ruku_sl'];
}
unset($prod);
return json([
'code' => 1,
'data' => $paged_grouped,
'total' => $total,
'page' => $page,
'limit' => $limit
]);
}
// public function product()
// {
//
// $db3 = Db::connect(config('database.db3'));
// $query = $db3->query("SELECT * FROM `工单_基本资料` WHERE `Gd_客户代号` = ?", ['J0031']);
//
// echo "";
// print_r($query);
// echo "
";
// die;
//
// $params = input('');
// $page = max(1, (int)$params['page']);
// $limit = max(1, (int)$params['limit']);
// $offset = ($page - 1) * $limit;
//
// $mongo = \think\Db::connect('mongodb');
// $where = [];
// if (!empty($params['search'])) {
// // 使用正则表达式来实现模糊匹配，'i' 表示忽略大小写
// $where['jjcp_cpdh|成品名称|jjcp_gdbh|订单编号'] = new \MongoDB\BSON\Regex($params['search'], 'i');
// }
//// if (!empty($where)) {
//// $mongo_products = $mongo->name('finished_products')
//// ->where($where)
//// ->limit($offset, $limit)
//// ->order('UniqId','desc')
//// ->where('jjcp_smb','末 板')
//// ->select();
//// } else {
//// // 如果没有条件，仍然执行查询，避免错误
//// $mongo_products = $mongo->name('finished_products')
//// ->limit(1, 10)
//// ->order('UniqId','desc')
//// ->where('jjcp_smb','末 板')
//// ->select();
//// }
//
//
//
//
// $mongo_products = $mongo->name('finished_products')
// ->where($where)
// ->limit($offset, $limit)
// ->order('UniqId','desc')
// ->where('jjcp_smb','末 板')
// ->select();
// echo "";
// print_r($mongo_products);
// echo "";die;
//
// //计算【订单编号】【jjcp_gdbh】相同的数据进行统计汇总累加入库数量【jjcp_sl】
// $grouped_products = [];
// foreach ($mongo_products as $item) {
// $group_key = $item['订单编号'] . '_' . $item['jjcp_gdbh'];
// if (!isset($grouped_products[$group_key])) {
// $grouped_products[$group_key] = [
// 'order_ddbh' => $item['订单编号'],
// 'gdbh' => $item['jjcp_gdbh'],
// 'cpmc' => $item['成品名称'],
//// 'cpdh' => $item['jjcp_cpdh'],
// 'ruku_sl' => 0, // 入库数量
// 'remain_stock' => 0, // 剩余库存
// 'sl' => 0
// ];
// }
// $grouped_products[$group_key]['ruku_sl'] += (int)$item['jjcp_sl'];
// }
// // 查询库存表并计算
// foreach ($grouped_products as $group_key => &$prod) {
// $where = [
// 'order_ddbh' => $prod['order_ddbh'],
// 'gdbh' => $prod['gdbh'],
// 'cpmc' => $prod['cpmc'],
// ];
// $inventory = $mongo->name('inventory_summary')->where($where)->find();
// $prod['remaining_quantity'] = $inventory ? (int)$inventory['remaining_quantity'] : 0;
// $prod['sl'] = $prod['remaining_quantity'] > 0 ? $prod['remaining_quantity'] : $prod['ruku_sl'];
// }
// unset($prod);
// $matched_products = array_values($grouped_products);
//
// // 获取总数
// $total = $mongo->name('finished_products')
// ->where($where)
// ->count();
//
// return json([
// 'code' => 1,
// 'data' => $matched_products,
// 'total' => $total,
// 'page' => $page,
// 'limit' => $limit
// ]);
// }
// public function product(){
// $QcodeProduct = new QcodeProduct();
// $ResetFlow = new ResetFlow();
// $userinfo = Session::get('admin');
// if ($this->request->isAjax() === false){
// $this->error('请求错误');
// }
// $product_code = input('product_code');
//
// if (empty($product_code)){
// $this->error('参数错误');
// }
// $product = $QcodeProduct->where('product_code',$product_code)->find();
// if (empty($product)){
// $this->error('未找到该产品信息');
// }
//
// $flow = $ResetFlow->name($userinfo['company'].'_'."reset_flow")->where('product_id',substr(json_encode($product['_id']),9,-2))->find();
// $row = [
// 'temple' => $product['temple'],
// 'flow' => isset($flow['l_flow'])?(int)$flow['l_flow']+1:'',
// 'bach' => isset($flow['bach_num'])?(int)$flow['bach_num']+1:'',
// ];
// if (!empty($flow)){
// $row['flow'] = $flow['l_flow']+1;
// $row['bach'] = $flow['bach_num']+1;
// }
//
// return json(['code'=>1,'data'=>$row]);
// }
/**
* 增加新批次
*/
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'],
// 'cpdh' => $data['cpdh'],
'cpmc' => $data['cpmc'],
];
//插入字段
$insertData = [
'gdbh' => $data['gdbh'],
'order_ddbh' => $data['order_ddbh'],
// 'cpdh' => $data['cpdh'],
'cpmc' => $data['cpmc'],
'total_ru_quantity' => $data['sl'],//入库数量
'total_chu_quantity' => $data['number'],//出库数量
'remaining_quantity' => $data['sl'] - $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) {
// 如果数据存在，更新库存汇总记录
$ru = $list['total_ru_quantity'] + $data['sl'];//累计入库数量
$chu = $list['total_chu_quantity'] + $data['sl'];//累计出库数量
$jiecun = $data['sl'] - $data['number'];//剩余结存数量
$updateResult = $mongo->name('inventory_summary')
->where($where)
->update([
'total_ru_quantity' => $ru,
'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;
if ($data['danwei'] == 1){
$num = $data['number'];
$tray_num = $data['tray_num'];
$tray_num1 = $data['tray_num'];
$box_number = $data['box_number'];
//$small_num = (int)ceil((int)总数量(张/个)/(int)张数);
$small_num = (int)ceil((int)$data['number']/(int)$data['box_number']);
$large_num = (int)ceil($small_num/$tray_num);
}else{
$num = 0;
$tray_num = $data['volume_num'];
$small_num = $data['small_num'];
$large_num = (int)ceil($small_num/$tray_num);
$box_number = 1;
$tray_num1 = 1;
}
$userinfo = Session::get('admin');//获取用户信息
$arr = [
'batch' => $data['batch'],
'create_time' => time(),
'delect_time' => '',
'sync_flag' => 0,
];
$productres = $QcodeCompany->save($arr);
if ($productres === 0){
$this->error('添加失败');
}
$batchList = [
'userid' => $userinfo['id'],
'supplier_id' => $userinfo['id'],
'supplier_code' => $userinfo['printer_code'],
'supplier_name' => $data['company_name'],//公司名称
'matter_name' => $data['cpmc'],//产品名称
'matter_no' => $data['batch'],//生产批次号
'order_ddbh' => $data['order_ddbh'],//销售订单号
'matter_id' => $data['batch'],
// 'matter_type' => $data['temple'],
'matter_type' => '01',
'manufacture_date' => (int)date('ymd',strtotime($data['manufacture_date'])),//生产日期
'print_date' => (int)date('ymd',strtotime($data['print_date'])),//打码日期
'danwei' => $data['danwei'],//单位
'num' => $num,//总数量(张/个)
'tray_num' => $tray_num1,//每层箱数
'box_num' => $box_number,//每托层数
'total_boxes' => $data['total_boxes'],//每托盘箱数
'small_num' => $small_num,//每托盘箱数
'pallet_height' => $data['pallet_height'],//每托高度
'pallet_length' => $data['pallet_length'],//托盘规格
'pallet_width' => $data['pallet_width'],//托盘规格
'larger_num' => $large_num,//大件（总托数）
'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['batch'],
'large_endnum' => $data['big_liushui'] + $data['box_num'] -1,
'create_time' => time(),//新增时间
];
$res = $bach->save($batchList);
if ($res === 0){
$this->error('添加失败');
}
$flow = [
'l_flow' => (int)$batchList['large_endnum'],
'bach_num' => $batchList['bach_num'],
];
if ($resetFlow->name($userinfo['company'].'_'."reset_flow")->where('product_id',$batchList['matter_id'])->find()){
$resetFlow->name($userinfo['company'].'_'."reset_flow")->where('product_id',$batchList['matter_id'])->update($flow);
}else{
$flow['product_id'] = $batchList['matter_id'];
$resetFlow->save($flow);
}
$last_id = $bach->getLastInsID();
if ($last_id){
//插入大小二维码数据
//二维码数据不变区域
// echo "";
// print_r($batchList);
// echo "";
// die;
// echo "";
// print_r($batchList['matter_type']);
// echo "";
// echo "";
// print_r($batchList['supplier_code']);
// echo "";
// echo "";
// print_r('9');
// echo "";
// echo "";
// print_r($batchList['matter_no']);
// echo "";
// echo "";
// print_r($batchList['manufacture_date']);
// echo "";
// echo "";
// print_r($batchList['print_date']);
// echo "";die;
$fixed_code = '';
$fixed_code.=$this->intTochar($batchList['matter_type'],2);//2位 辅料种类编码
// $fixed_code .= substr($this->intTochar($batchList['supplier_code'], 12), 1);//12位 供应商编码 // 去掉第一位0
$fixed_code .= $this->intTochar($batchList['supplier_code'], 21);//21位 供应商编码
$fixed_code .= '9'; // 补0一位
$fixed_code.=$this->intTochar($batchList['matter_no'],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<$batchList['larger_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['bach_num'],10);
$l_reservation = $l_reservation.'0000000000';
$remainder = $batchList['small_num'] - $batchList['tray_num'] * $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 = 0;
if ($data['danwei'] == 1){
//以箱为单位时
$l_num = $small_n * $batchList['box_num'];
}
//大件二维码数据
$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<$tray_num and ($j+$i*$tray_num)<$batchList['small_num'];$j++){
$small = new QcodeSmall();
$s_flow = $this->intTochar($batchList['s_flow']+$j+$i*$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('添加失败');
}
$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;
}
}