Merge remote-tracking branch 'origin/master_merge_0523' into master_merge_0523

This commit is contained in:
2026-08-14 17:43:00 +08:00
3 changed files with 55 additions and 24 deletions

View File

@@ -1,10 +1,10 @@
package org.nl.wms.st.levelchange.service; package org.nl.wms.st.levelchange.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.nl.b_lms.pdm.bi.slittingproductionplan.service.dao.PdmBiSlittingproductionplan; import org.nl.b_lms.pdm.bi.slittingproductionplan.service.dao.PdmBiSlittingproductionplan;
import org.nl.common.domain.query.PageQuery; import org.nl.common.domain.query.PageQuery;
import org.nl.wms.st.levelchange.dao.StIvtLevelchangedtl; import org.nl.wms.st.levelchange.dao.StIvtLevelchangedtl;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
@@ -19,7 +19,7 @@ public interface IStIvtLevelchangedtlService {
/** /**
* 分页查询 * 分页查询
*/ */
List<StIvtLevelchangedtl> queryAll(Map whereJson, PageQuery page); IPage<StIvtLevelchangedtl> queryAll(Map whereJson, PageQuery page);
/** /**
* 新增 * 新增

View File

@@ -1,7 +1,9 @@
package org.nl.wms.st.levelchange.service.impl; package org.nl.wms.st.levelchange.service.impl;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -11,6 +13,7 @@ import lombok.extern.slf4j.Slf4j;
import org.nl.common.domain.query.PageQuery; import org.nl.common.domain.query.PageQuery;
import org.nl.common.utils.SecurityUtils; import org.nl.common.utils.SecurityUtils;
import org.nl.modules.common.exception.BadRequestException; import org.nl.modules.common.exception.BadRequestException;
import org.nl.modules.common.utils.StringUtils;
import org.nl.modules.wql.core.bean.WQLObject; import org.nl.modules.wql.core.bean.WQLObject;
import org.nl.wms.st.instor.service.HandMoveStorService; import org.nl.wms.st.instor.service.HandMoveStorService;
import org.nl.wms.st.levelchange.dao.StIvtLevelchangedtl; import org.nl.wms.st.levelchange.dao.StIvtLevelchangedtl;
@@ -45,15 +48,36 @@ public class StIvtLevelchangedtlServiceImpl implements IStIvtLevelchangedtlServi
@Override @Override
public List<StIvtLevelchangedtl> queryAll(Map whereJson, PageQuery page) { public IPage<StIvtLevelchangedtl> queryAll(Map whereJson, PageQuery page) {
LambdaQueryWrapper<StIvtLevelchangedtl> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<StIvtLevelchangedtl> wrapper = new LambdaQueryWrapper<>();
// 根据 whereJson 动态添加查询条件,可按需扩展 // 根据 whereJson 动态添加查询条件,可按需扩展
wrapper.eq(StIvtLevelchangedtl::getIs_delete, "0"); wrapper.eq(StIvtLevelchangedtl::getIs_delete, "0");
String move_bill_code = MapUtil.getStr(whereJson, "move_bill_code");
String status = MapUtil.getStr(whereJson, "status");
String container_name = MapUtil.getStr(whereJson, "container_name");
String begin_time = MapUtil.getStr(whereJson, "begin_time");
String end_time = MapUtil.getStr(whereJson, "end_time");
if(StrUtil.isNotBlank(move_bill_code)){
wrapper.eq(StIvtLevelchangedtl::getMove_bill_code, move_bill_code);
}
if(StrUtil.isNotBlank(status)){
wrapper.eq(StIvtLevelchangedtl::getStatus, status);
}
if(StrUtil.isNotBlank(container_name)){
wrapper.like(StIvtLevelchangedtl::getContainer_name, container_name);
}
if(StrUtil.isNotBlank(begin_time)){
wrapper.ge(StIvtLevelchangedtl::getCreate_time, begin_time);
}
if(StrUtil.isNotBlank(end_time)){
wrapper.le(StIvtLevelchangedtl::getCreate_time, end_time);
}
wrapper.orderByDesc(StIvtLevelchangedtl::getCreate_time); wrapper.orderByDesc(StIvtLevelchangedtl::getCreate_time);
IPage<StIvtLevelchangedtl> iPage = new Page<>(page.getPage(), page.getSize()); IPage<StIvtLevelchangedtl> iPage = new Page<>(page.getPage()+1, page.getSize());
levelchangedtlMapper.selectPage(iPage, wrapper); levelchangedtlMapper.selectPage(iPage, wrapper);
return iPage.getRecords(); return iPage;
} }
@Override @Override
@@ -119,8 +143,15 @@ public class StIvtLevelchangedtlServiceImpl implements IStIvtLevelchangedtlServi
try{ try{
//判断卷原来的级别是不是管制卷,如果不是,不走移库操作。 //判断卷原来的级别是不是管制卷,如果不是,不走移库操作。
if(!"6".equals(oldLevel)){ if(!"6".equals(oldLevel)){
log.info("非管制卷改级,不需要进行实物移库!"); log.info("非管制卷改级,不需要进行实物移库!containerName={}, newLevel={}, oldLevel={}, newResult={}, oldResult={}",
throw new BadRequestException("非管制卷改级,不需要进行实物移库!!"); containerName, newLevel, oldLevel, newResult, oldResult);
return;
}
//判断新的级别是否是 A- A A+ 3 2 1
if(!"3".equals(newLevel) && !"2".equals(newLevel) && !"1".equals(newLevel)){
log.info("非A-/A/A+改级不需要进行实物移库containerName={}, newLevel={}, oldLevel={}, newResult={}, oldResult={}",
containerName, newLevel, oldLevel, newResult, oldResult);
return;
} }
List<Map<String,Object>> packages = levelchangedtlMapper.selectPackageInfoByContainerName(containerName); List<Map<String,Object>> packages = levelchangedtlMapper.selectPackageInfoByContainerName(containerName);
if(ObjectUtil.isEmpty(packages)){ if(ObjectUtil.isEmpty(packages)){

View File

@@ -757,18 +757,18 @@
LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name
LEFT JOIN (SELECT LEFT JOIN (SELECT
container_name, container_name,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管' WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管'
WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管' WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管'
END AS paper_tube_or_FRP, END) AS paper_tube_or_FRP,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material
END AS paper_tube_material, END) AS paper_tube_material,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description
END AS paper_tube_description, END) AS paper_tube_description,
MAX(parent_container_name) AS parent_container_name, MAX(parent_container_name) AS parent_container_name,
MAX(restruct_container_name) AS restruct_container_name, MAX(restruct_container_name) AS restruct_container_name,
MAX(foil_container_name) AS foil_container_name MAX(foil_container_name) AS foil_container_name
@@ -1106,18 +1106,18 @@
LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name
LEFT JOIN (SELECT LEFT JOIN (SELECT
container_name, container_name,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管' WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管'
WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管' WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管'
END AS paper_tube_or_FRP, END) AS paper_tube_or_FRP,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material
END AS paper_tube_material, END) AS paper_tube_material,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description
END AS paper_tube_description, END) AS paper_tube_description,
MAX(parent_container_name) AS parent_container_name, MAX(parent_container_name) AS parent_container_name,
MAX(restruct_container_name) AS restruct_container_name, MAX(restruct_container_name) AS restruct_container_name,
MAX(foil_container_name) AS foil_container_name MAX(foil_container_name) AS foil_container_name
@@ -1575,15 +1575,15 @@
LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name LEFT JOIN md_cs_customerbase cust ON cust.cust_code = sub.customer_name
LEFT JOIN (SELECT LEFT JOIN (SELECT
container_name, container_name,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管' WHEN plan1.paper_tube_or_FRP = '1' THEN '纸管'
WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管' WHEN plan1.paper_tube_or_FRP = '2' THEN 'FRP管'
END AS paper_tube_or_FRP, END) AS paper_tube_or_FRP,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_material
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_material
END AS paper_tube_material, END) AS paper_tube_material,
CASE MAX(CASE
WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description WHEN plan1.paper_tube_or_FRP = '1' THEN plan1.paper_tube_description
WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description WHEN plan1.paper_tube_or_FRP = '2' THEN plan1.FRP_description
END AS paper_tube_description, END AS paper_tube_description,