feat(WmsCoilAbnormal): 添加钢卷ID集合批量查询功能
- 在WmsCoilAbnormalBo中新增coilIds字段用于批量查询 - 实现逗号分隔的coilIds批量查询逻辑 - 使用Stream API处理字符串分割和类型转换 - 添加空值过滤确保查询条件的有效性 - 集成到现有的查询条件构建流程中
This commit is contained in:
@@ -30,6 +30,11 @@ public class WmsCoilAbnormalBo extends BaseEntity {
|
||||
*/
|
||||
private Long coilId;
|
||||
|
||||
/**
|
||||
* 钢卷ID集合(逗号分隔,用于批量查询)
|
||||
*/
|
||||
private String coilIds;
|
||||
|
||||
/**
|
||||
* 产线名称
|
||||
*/
|
||||
|
||||
@@ -20,6 +20,8 @@ import java.util.Date;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Collection;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.Arrays;
|
||||
|
||||
/**
|
||||
* 钢卷异常信息Service业务层处理
|
||||
@@ -64,6 +66,17 @@ public class WmsCoilAbnormalServiceImpl implements IWmsCoilAbnormalService {
|
||||
Map<String, Object> params = bo.getParams();
|
||||
LambdaQueryWrapper<WmsCoilAbnormal> lqw = Wrappers.lambdaQuery();
|
||||
lqw.eq(bo.getCoilId() != null, WmsCoilAbnormal::getCoilId, bo.getCoilId());
|
||||
// 逗号分隔的 coilIds 批量查询
|
||||
if (StringUtils.isNotBlank(bo.getCoilIds())) {
|
||||
List<Long> ids = Arrays.stream(bo.getCoilIds().split(","))
|
||||
.map(String::trim)
|
||||
.filter(s -> !s.isEmpty())
|
||||
.map(Long::valueOf)
|
||||
.collect(Collectors.toList());
|
||||
if (!ids.isEmpty()) {
|
||||
lqw.in(WmsCoilAbnormal::getCoilId, ids);
|
||||
}
|
||||
}
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getProductionLine()), WmsCoilAbnormal::getProductionLine, bo.getProductionLine());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getPosition()), WmsCoilAbnormal::getPosition, bo.getPosition());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getPlateSurface()), WmsCoilAbnormal::getPlateSurface, bo.getPlateSurface());
|
||||
|
||||
Reference in New Issue
Block a user