查询优化,新增酸连轧页面
This commit is contained in:
@@ -51,6 +51,10 @@ public class WmsProductController extends BaseController {
|
||||
*/
|
||||
@GetMapping("/listWithBom")
|
||||
public TableDataInfo<WmsProductVo> listWithBom(WmsProductBo bo, PageQuery pageQuery) {
|
||||
// 限制最大 pageSize 为 1000,防止查询过多数据导致性能问题
|
||||
if (pageQuery.getPageSize() != null && pageQuery.getPageSize() > 1000) {
|
||||
pageQuery.setPageSize(1000);
|
||||
}
|
||||
return iWmsProductService.queryPageListWithBom(bo, pageQuery);
|
||||
}
|
||||
|
||||
|
||||
@@ -50,6 +50,10 @@ public class WmsRawMaterialController extends BaseController {
|
||||
*/
|
||||
@GetMapping("/listWithBom")
|
||||
public TableDataInfo<WmsRawMaterialVo> listWithBom(WmsRawMaterialBo bo, PageQuery pageQuery) {
|
||||
// 限制最大 pageSize 为 1000,防止查询过多数据导致性能问题
|
||||
if (pageQuery.getPageSize() != null && pageQuery.getPageSize() > 1000) {
|
||||
pageQuery.setPageSize(1000);
|
||||
}
|
||||
return iWmsRawMaterialService.queryPageListWithBom(bo, pageQuery);
|
||||
}
|
||||
|
||||
|
||||
@@ -211,6 +211,82 @@ public class WmsMaterialCoilVo extends BaseEntity {
|
||||
*/
|
||||
private String packagingRequirement;
|
||||
|
||||
// ========== 联查临时字段(用于优化查询性能,避免单独查询) ==========
|
||||
|
||||
/**
|
||||
* 原材料ID(联查字段)
|
||||
*/
|
||||
private Long rawMaterialId;
|
||||
|
||||
/**
|
||||
* 原材料编号(联查字段)
|
||||
*/
|
||||
private String rawMaterialCode;
|
||||
|
||||
/**
|
||||
* 原材料名称(联查字段)
|
||||
*/
|
||||
private String rawMaterialName;
|
||||
|
||||
/**
|
||||
* 原材料规格(联查字段)
|
||||
*/
|
||||
private String rawMaterialSpecification;
|
||||
|
||||
/**
|
||||
* 原材料钢种(联查字段)
|
||||
*/
|
||||
private String rawMaterialSteelGrade;
|
||||
|
||||
/**
|
||||
* 原材料厚度(联查字段)
|
||||
*/
|
||||
private BigDecimal rawMaterialThickness;
|
||||
|
||||
/**
|
||||
* 原材料宽度(联查字段)
|
||||
*/
|
||||
private BigDecimal rawMaterialWidth;
|
||||
|
||||
/**
|
||||
* 原材料BOM ID(联查字段)
|
||||
*/
|
||||
private Long rawMaterialBomId;
|
||||
|
||||
/**
|
||||
* 产品ID(联查字段)
|
||||
*/
|
||||
private Long productId;
|
||||
|
||||
/**
|
||||
* 产品编号(联查字段)
|
||||
*/
|
||||
private String productCode;
|
||||
|
||||
/**
|
||||
* 产品名称(联查字段)
|
||||
*/
|
||||
private String productName;
|
||||
|
||||
/**
|
||||
* 产品规格(联查字段)
|
||||
*/
|
||||
private String productSpecification;
|
||||
|
||||
/**
|
||||
* 产品厚度(联查字段)
|
||||
*/
|
||||
private BigDecimal productThickness;
|
||||
|
||||
/**
|
||||
* 产品宽度(联查字段)
|
||||
*/
|
||||
private BigDecimal productWidth;
|
||||
|
||||
/**
|
||||
* 产品BOM ID(联查字段)
|
||||
*/
|
||||
private Long productBomId;
|
||||
|
||||
}
|
||||
|
||||
|
||||
@@ -26,6 +26,7 @@ import com.klp.domain.bo.WmsStockBo;
|
||||
import com.klp.domain.vo.WmsStockVo;
|
||||
import com.klp.mapper.WmsMaterialCoilMapper;
|
||||
import com.klp.mapper.WmsStockMapper;
|
||||
import com.klp.mapper.WmsGenerateRecordMapper;
|
||||
import com.klp.service.IWmsMaterialCoilService;
|
||||
import com.klp.service.IWmsStockService;
|
||||
import com.klp.service.IWmsGenerateRecordService;
|
||||
@@ -61,6 +62,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
private final WmsMaterialCoilMapper baseMapper;
|
||||
private final IWmsStockService stockService;
|
||||
private final IWmsGenerateRecordService generateRecordService;
|
||||
private final WmsGenerateRecordMapper generateRecordMapper;
|
||||
private final IWmsWarehouseService warehouseService;
|
||||
private final IWmsActualWarehouseService actualWarehouseService;
|
||||
private final IWmsRawMaterialService rawMaterialService;
|
||||
@@ -84,7 +86,153 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
}
|
||||
|
||||
/**
|
||||
* 填充关联对象信息
|
||||
* 批量填充关联对象信息(优化版本,避免N+1查询)
|
||||
*/
|
||||
private void fillRelatedObjectsBatch(List<WmsMaterialCoilVo> voList) {
|
||||
if (voList == null || voList.isEmpty()) {
|
||||
return;
|
||||
}
|
||||
|
||||
// 收集所有需要查询的ID
|
||||
Set<Long> warehouseIds = new HashSet<>();
|
||||
Set<Long> nextWarehouseIds = new HashSet<>();
|
||||
Set<Long> actualWarehouseIds = new HashSet<>();
|
||||
Set<Long> qrcodeRecordIds = new HashSet<>();
|
||||
Set<Long> rawMaterialIds = new HashSet<>();
|
||||
Set<Long> productIds = new HashSet<>();
|
||||
Set<Long> bomIds = new HashSet<>();
|
||||
|
||||
for (WmsMaterialCoilVo vo : voList) {
|
||||
if (vo.getWarehouseId() != null) warehouseIds.add(vo.getWarehouseId());
|
||||
if (vo.getNextWarehouseId() != null) nextWarehouseIds.add(vo.getNextWarehouseId());
|
||||
if (vo.getActualWarehouseId() != null) actualWarehouseIds.add(vo.getActualWarehouseId());
|
||||
if (vo.getQrcodeRecordId() != null) qrcodeRecordIds.add(vo.getQrcodeRecordId());
|
||||
if ("raw_material".equals(vo.getItemType()) && vo.getItemId() != null) {
|
||||
rawMaterialIds.add(vo.getItemId());
|
||||
}
|
||||
if ("product".equals(vo.getItemType()) && vo.getItemId() != null) {
|
||||
productIds.add(vo.getItemId());
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询库区信息
|
||||
Map<Long, WmsWarehouseVo> warehouseMap = new HashMap<>();
|
||||
if (!warehouseIds.isEmpty()) {
|
||||
for (Long id : warehouseIds) {
|
||||
WmsWarehouseVo warehouse = warehouseService.queryById(id);
|
||||
if (warehouse != null) {
|
||||
warehouseMap.put(id, warehouse);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (!nextWarehouseIds.isEmpty()) {
|
||||
for (Long id : nextWarehouseIds) {
|
||||
if (!warehouseMap.containsKey(id)) {
|
||||
WmsWarehouseVo warehouse = warehouseService.queryById(id);
|
||||
if (warehouse != null) {
|
||||
warehouseMap.put(id, warehouse);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询实际库区信息
|
||||
Map<Long, WmsActualWarehouseVo> actualWarehouseMap = new HashMap<>();
|
||||
if (!actualWarehouseIds.isEmpty()) {
|
||||
for (Long id : actualWarehouseIds) {
|
||||
WmsActualWarehouseVo actualWarehouse = actualWarehouseService.queryById(id);
|
||||
if (actualWarehouse != null) {
|
||||
actualWarehouseMap.put(id, actualWarehouse);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询二维码信息
|
||||
Map<Long, WmsGenerateRecordVo> qrcodeMap = new HashMap<>();
|
||||
if (!qrcodeRecordIds.isEmpty()) {
|
||||
for (Long id : qrcodeRecordIds) {
|
||||
WmsGenerateRecordVo qrcode = generateRecordService.queryById(id);
|
||||
if (qrcode != null) {
|
||||
qrcodeMap.put(id, qrcode);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询原材料信息
|
||||
Map<Long, WmsRawMaterialVo> rawMaterialMap = new HashMap<>();
|
||||
if (!rawMaterialIds.isEmpty()) {
|
||||
for (Long id : rawMaterialIds) {
|
||||
WmsRawMaterialVo rawMaterial = rawMaterialService.queryById(id);
|
||||
if (rawMaterial != null) {
|
||||
rawMaterialMap.put(id, rawMaterial);
|
||||
if (rawMaterial.getBomId() != null) {
|
||||
bomIds.add(rawMaterial.getBomId());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询产品信息
|
||||
Map<Long, WmsProductVo> productMap = new HashMap<>();
|
||||
if (!productIds.isEmpty()) {
|
||||
for (Long id : productIds) {
|
||||
WmsProductVo product = productService.queryById(id);
|
||||
if (product != null) {
|
||||
productMap.put(id, product);
|
||||
if (product.getBomId() != null) {
|
||||
bomIds.add(product.getBomId());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 批量查询BOM信息
|
||||
Map<Long, List<WmsBomItemVo>> bomItemMap = new HashMap<>();
|
||||
if (!bomIds.isEmpty()) {
|
||||
for (Long bomId : bomIds) {
|
||||
WmsBomItemBo bomItemBo = new WmsBomItemBo();
|
||||
bomItemBo.setBomId(bomId);
|
||||
List<WmsBomItemVo> bomItemList = bomItemService.queryList(bomItemBo);
|
||||
if (bomItemList != null && !bomItemList.isEmpty()) {
|
||||
bomItemMap.put(bomId, bomItemList);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 填充到VO对象中
|
||||
for (WmsMaterialCoilVo vo : voList) {
|
||||
if (vo.getWarehouseId() != null && warehouseMap.containsKey(vo.getWarehouseId())) {
|
||||
vo.setWarehouse(warehouseMap.get(vo.getWarehouseId()));
|
||||
}
|
||||
if (vo.getNextWarehouseId() != null && warehouseMap.containsKey(vo.getNextWarehouseId())) {
|
||||
vo.setNextWarehouse(warehouseMap.get(vo.getNextWarehouseId()));
|
||||
}
|
||||
if (vo.getActualWarehouseId() != null && actualWarehouseMap.containsKey(vo.getActualWarehouseId())) {
|
||||
WmsActualWarehouseVo actualWarehouse = actualWarehouseMap.get(vo.getActualWarehouseId());
|
||||
vo.setActualWarehouseName(actualWarehouse.getActualWarehouseName());
|
||||
}
|
||||
if (vo.getQrcodeRecordId() != null && qrcodeMap.containsKey(vo.getQrcodeRecordId())) {
|
||||
vo.setQrcodeRecord(qrcodeMap.get(vo.getQrcodeRecordId()));
|
||||
}
|
||||
if ("raw_material".equals(vo.getItemType()) && vo.getItemId() != null && rawMaterialMap.containsKey(vo.getItemId())) {
|
||||
WmsRawMaterialVo rawMaterial = rawMaterialMap.get(vo.getItemId());
|
||||
vo.setRawMaterial(rawMaterial);
|
||||
if (rawMaterial.getBomId() != null && bomItemMap.containsKey(rawMaterial.getBomId())) {
|
||||
vo.setBomItemList(bomItemMap.get(rawMaterial.getBomId()));
|
||||
}
|
||||
}
|
||||
if ("product".equals(vo.getItemType()) && vo.getItemId() != null && productMap.containsKey(vo.getItemId())) {
|
||||
WmsProductVo product = productMap.get(vo.getItemId());
|
||||
vo.setProduct(product);
|
||||
if (product.getBomId() != null && bomItemMap.containsKey(product.getBomId())) {
|
||||
vo.setBomItemList(bomItemMap.get(product.getBomId()));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 填充关联对象信息(单个对象,保留用于兼容性)
|
||||
*/
|
||||
private void fillRelatedObjects(WmsMaterialCoilVo vo) {
|
||||
// 查询所在库区信息
|
||||
@@ -150,9 +298,9 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
QueryWrapper<WmsMaterialCoil> qw = buildQueryWrapperPlus(bo);
|
||||
Page<WmsMaterialCoilVo> result = baseMapper.selectVoPagePlus(pageQuery.build(), qw);
|
||||
|
||||
// 填充每个记录的产品或原材料对象
|
||||
// 从联查结果中构建产品和原材料对象(避免单独查询)
|
||||
for (WmsMaterialCoilVo vo : result.getRecords()) {
|
||||
fillItemObject(vo);
|
||||
buildItemObjectFromJoin(vo);
|
||||
}
|
||||
|
||||
return TableDataInfo.build(result);
|
||||
@@ -211,16 +359,53 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
QueryWrapper<WmsMaterialCoil> lqw = buildQueryWrapperPlus(bo);
|
||||
List<WmsMaterialCoilVo> list = baseMapper.selectVoListWithDynamicJoin(lqw);
|
||||
|
||||
// 填充每个记录的产品或原材料对象
|
||||
// 从联查结果中构建产品和原材料对象(避免单独查询)
|
||||
for (WmsMaterialCoilVo vo : list) {
|
||||
fillItemObject(vo);
|
||||
buildItemObjectFromJoin(vo);
|
||||
}
|
||||
|
||||
return list;
|
||||
}
|
||||
|
||||
/**
|
||||
* 填充物品对象(产品或原材料)
|
||||
* 从联查结果中构建物品对象(产品或原材料)
|
||||
* 直接从VO的临时字段中获取数据构建对象,避免单独查询数据库
|
||||
*/
|
||||
private void buildItemObjectFromJoin(WmsMaterialCoilVo vo) {
|
||||
if (vo.getItemId() == null || vo.getItemType() == null) {
|
||||
return;
|
||||
}
|
||||
|
||||
// 构建原材料对象
|
||||
if ("raw_material".equals(vo.getItemType()) && vo.getRawMaterialId() != null) {
|
||||
WmsRawMaterialVo rawMaterial = new WmsRawMaterialVo();
|
||||
rawMaterial.setRawMaterialId(vo.getRawMaterialId());
|
||||
rawMaterial.setRawMaterialCode(vo.getRawMaterialCode());
|
||||
rawMaterial.setRawMaterialName(vo.getRawMaterialName());
|
||||
rawMaterial.setSpecification(vo.getRawMaterialSpecification());
|
||||
rawMaterial.setSteelGrade(vo.getRawMaterialSteelGrade());
|
||||
rawMaterial.setThickness(vo.getRawMaterialThickness());
|
||||
rawMaterial.setWidth(vo.getRawMaterialWidth());
|
||||
rawMaterial.setBomId(vo.getRawMaterialBomId());
|
||||
vo.setRawMaterial(rawMaterial);
|
||||
}
|
||||
|
||||
// 构建产品对象
|
||||
if ("product".equals(vo.getItemType()) && vo.getProductId() != null) {
|
||||
WmsProductVo product = new WmsProductVo();
|
||||
product.setProductId(vo.getProductId());
|
||||
product.setProductCode(vo.getProductCode());
|
||||
product.setProductName(vo.getProductName());
|
||||
product.setSpecification(vo.getProductSpecification());
|
||||
product.setThickness(vo.getProductThickness());
|
||||
product.setWidth(vo.getProductWidth());
|
||||
product.setBomId(vo.getProductBomId());
|
||||
vo.setProduct(product);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 填充物品对象(产品或原材料)- 保留作为备用方法
|
||||
*/
|
||||
private void fillItemObject(WmsMaterialCoilVo vo) {
|
||||
if (vo.getItemId() == null || vo.getItemType() == null) {
|
||||
@@ -1034,7 +1219,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
@Override
|
||||
public Map<String, Object> queryTrace(String enterCoilNo, String currentCoilNo) {
|
||||
try {
|
||||
// 1. 查询所有相关的二维码记录(包括分卷后的独立二维码)
|
||||
// 优化1: 使用LIKE查询替代查询所有记录,大幅提升性能
|
||||
List<WmsGenerateRecordVo> allQrRecords = new ArrayList<>();
|
||||
|
||||
// 首先查询主二维码(以入场钢卷号为序列号的)
|
||||
@@ -1043,14 +1228,21 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
List<WmsGenerateRecordVo> mainQrRecords = generateRecordService.queryList(qrBo);
|
||||
allQrRecords.addAll(mainQrRecords);
|
||||
|
||||
// 然后查询所有以该入场钢卷号开头的二维码(分卷后的二维码)
|
||||
WmsGenerateRecordBo splitQrBo = new WmsGenerateRecordBo();
|
||||
List<WmsGenerateRecordVo> allRecords = generateRecordService.queryList(splitQrBo);
|
||||
for (WmsGenerateRecordVo record : allRecords) {
|
||||
if (record.getSerialNumber() != null &&
|
||||
record.getSerialNumber().startsWith(enterCoilNo + "-") &&
|
||||
!allQrRecords.contains(record)) {
|
||||
// 优化:使用LIKE查询所有以该入场钢卷号开头的二维码(分卷后的二维码)
|
||||
// 而不是查询所有记录然后在内存中过滤
|
||||
LambdaQueryWrapper<com.klp.domain.WmsGenerateRecord> splitWrapper = Wrappers.lambdaQuery();
|
||||
splitWrapper.like(com.klp.domain.WmsGenerateRecord::getSerialNumber, enterCoilNo + "-");
|
||||
List<WmsGenerateRecordVo> splitRecords = generateRecordMapper.selectVoList(splitWrapper);
|
||||
|
||||
// 去重:使用recordId作为唯一标识
|
||||
Set<Long> existingRecordIds = allQrRecords.stream()
|
||||
.map(WmsGenerateRecordVo::getRecordId)
|
||||
.collect(Collectors.toSet());
|
||||
|
||||
for (WmsGenerateRecordVo record : splitRecords) {
|
||||
if (record.getRecordId() != null && !existingRecordIds.contains(record.getRecordId())) {
|
||||
allQrRecords.add(record);
|
||||
existingRecordIds.add(record.getRecordId());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1058,14 +1250,16 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
throw new RuntimeException("未找到对应的二维码记录");
|
||||
}
|
||||
|
||||
// 优化2: ObjectMapper在循环外创建,避免重复创建
|
||||
ObjectMapper objectMapper = new ObjectMapper();
|
||||
|
||||
// 2. 合并所有二维码的steps信息,去重并重新编号
|
||||
Map<String, Map<String, Object>> uniqueSteps = new HashMap<>(); // 用于去重
|
||||
Set<String> allCoilNos = new HashSet<>();
|
||||
|
||||
for (WmsGenerateRecordVo qrRecord : allQrRecords) {
|
||||
ObjectMapper objectMapper = new ObjectMapper();
|
||||
@SuppressWarnings("unchecked")
|
||||
Map<String, Object> contentMap = objectMapper.readValue(qrRecord.getContent(), Map.class);
|
||||
Map<String, Object> contentMap = (Map<String, Object>) objectMapper.readValue(qrRecord.getContent(), Map.class);
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
List<Map<String, Object>> steps = (List<Map<String, Object>>) contentMap.get("steps");
|
||||
@@ -1125,32 +1319,41 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
.collect(Collectors.toSet());
|
||||
}
|
||||
|
||||
// 优化3: 使用IN查询替代多个OR条件,提升查询性能
|
||||
// 4. 根据提取的钢卷号反向查询数据库
|
||||
List<WmsMaterialCoilVo> result = new ArrayList<>();
|
||||
if (!filteredCoilNos.isEmpty()) {
|
||||
LambdaQueryWrapper<WmsMaterialCoil> lqw = Wrappers.lambdaQuery();
|
||||
lqw.eq(WmsMaterialCoil::getEnterCoilNo, enterCoilNo);
|
||||
|
||||
// 查询包含提取出的钢卷号的记录
|
||||
final Set<String> finalCoilNos = filteredCoilNos;
|
||||
lqw.and(wrapper -> {
|
||||
int count = 0;
|
||||
for (String coilNo : finalCoilNos) {
|
||||
if (count == 0) {
|
||||
wrapper.eq(WmsMaterialCoil::getCurrentCoilNo, coilNo);
|
||||
} else {
|
||||
wrapper.or().eq(WmsMaterialCoil::getCurrentCoilNo, coilNo);
|
||||
}
|
||||
count++;
|
||||
// 优化:使用IN查询替代多个OR条件(当钢卷号数量较少时)
|
||||
// 如果数量太多(>1000),分批查询避免SQL过长
|
||||
List<String> coilNoList = new ArrayList<>(filteredCoilNos);
|
||||
if (coilNoList.size() <= 1000) {
|
||||
lqw.in(WmsMaterialCoil::getCurrentCoilNo, coilNoList);
|
||||
} else {
|
||||
// 分批查询
|
||||
int batchSize = 1000;
|
||||
for (int i = 0; i < coilNoList.size(); i += batchSize) {
|
||||
int end = Math.min(i + batchSize, coilNoList.size());
|
||||
List<String> batch = coilNoList.subList(i, end);
|
||||
LambdaQueryWrapper<WmsMaterialCoil> batchLqw = Wrappers.lambdaQuery();
|
||||
batchLqw.eq(WmsMaterialCoil::getEnterCoilNo, enterCoilNo);
|
||||
batchLqw.in(WmsMaterialCoil::getCurrentCoilNo, batch);
|
||||
batchLqw.orderByAsc(WmsMaterialCoil::getCreateTime);
|
||||
List<WmsMaterialCoilVo> batchResult = baseMapper.selectVoList(batchLqw);
|
||||
result.addAll(batchResult);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
lqw.orderByAsc(WmsMaterialCoil::getCreateTime);
|
||||
result = baseMapper.selectVoList(lqw);
|
||||
if (coilNoList.size() <= 1000) {
|
||||
lqw.orderByAsc(WmsMaterialCoil::getCreateTime);
|
||||
result = baseMapper.selectVoList(lqw);
|
||||
}
|
||||
|
||||
// 填充每个记录的关联对象信息(如库区)
|
||||
for (WmsMaterialCoilVo vo : result) {
|
||||
fillRelatedObjects(vo);
|
||||
// 优化4: 批量填充关联对象,避免N+1查询
|
||||
if (!result.isEmpty()) {
|
||||
fillRelatedObjectsBatch(result);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1161,9 +1364,9 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService {
|
||||
lqw.orderByAsc(WmsMaterialCoil::getCreateTime);
|
||||
result = baseMapper.selectVoList(lqw);
|
||||
|
||||
// 填充每个记录的关联对象信息
|
||||
for (WmsMaterialCoilVo vo : result) {
|
||||
fillRelatedObjects(vo);
|
||||
// 优化:批量填充关联对象
|
||||
if (!result.isEmpty()) {
|
||||
fillRelatedObjectsBatch(result);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -92,7 +92,24 @@ public class WmsProductServiceImpl implements IWmsProductService {
|
||||
Map<String, Object> params = bo.getParams();
|
||||
LambdaQueryWrapper<WmsProduct> lqw = Wrappers.lambdaQuery();
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getProductCode()), WmsProduct::getProductCode, bo.getProductCode());
|
||||
lqw.like(StringUtils.isNotBlank(bo.getProductName()), WmsProduct::getProductName, bo.getProductName());
|
||||
|
||||
// 如果同时传入了名称和规格,且值相同(搜索关键词),使用 OR 条件
|
||||
boolean hasName = StringUtils.isNotBlank(bo.getProductName());
|
||||
boolean hasSpec = StringUtils.isNotBlank(bo.getSpecification());
|
||||
if (hasName && hasSpec && bo.getProductName().equals(bo.getSpecification())) {
|
||||
// 搜索关键词:匹配名称或规格
|
||||
String searchKey = bo.getProductName();
|
||||
lqw.and(wrapper -> wrapper
|
||||
.like(WmsProduct::getProductName, searchKey)
|
||||
.or()
|
||||
.like(WmsProduct::getSpecification, searchKey)
|
||||
);
|
||||
} else {
|
||||
// 分别处理名称和规格
|
||||
lqw.like(hasName, WmsProduct::getProductName, bo.getProductName());
|
||||
lqw.like(hasSpec, WmsProduct::getSpecification, bo.getSpecification());
|
||||
}
|
||||
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getOwner()), WmsProduct::getOwner, bo.getOwner());
|
||||
lqw.eq(bo.getBaseMaterialId() != null, WmsProduct::getBaseMaterialId, bo.getBaseMaterialId());
|
||||
lqw.eq(bo.getSurfaceTreatmentId() != null, WmsProduct::getSurfaceTreatmentId, bo.getSurfaceTreatmentId());
|
||||
@@ -104,8 +121,6 @@ public class WmsProductServiceImpl implements IWmsProductService {
|
||||
lqw.eq(bo.getIsEnabled() != null, WmsProduct::getIsEnabled, bo.getIsEnabled());
|
||||
lqw.eq(bo.getBomId() != null, WmsProduct::getBomId, bo.getBomId());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getType()), WmsProduct::getType, bo.getType());
|
||||
//规格模糊匹配
|
||||
lqw.like(StringUtils.isNotBlank(bo.getSpecification()), WmsProduct::getSpecification, bo.getSpecification());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getMaterial()), WmsProduct::getMaterial, bo.getMaterial());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getSurfaceTreatmentDesc()), WmsProduct::getSurfaceTreatmentDesc, bo.getSurfaceTreatmentDesc());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getManufacturer()), WmsProduct::getManufacturer, bo.getManufacturer());
|
||||
|
||||
@@ -184,7 +184,24 @@ public class WmsRawMaterialServiceImpl implements IWmsRawMaterialService {
|
||||
Map<String, Object> params = bo.getParams();
|
||||
LambdaQueryWrapper<WmsRawMaterial> lqw = Wrappers.lambdaQuery();
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getRawMaterialCode()), WmsRawMaterial::getRawMaterialCode, bo.getRawMaterialCode());
|
||||
lqw.like(StringUtils.isNotBlank(bo.getRawMaterialName()), WmsRawMaterial::getRawMaterialName, bo.getRawMaterialName());
|
||||
|
||||
// 如果同时传入了名称和规格,且值相同(搜索关键词),使用 OR 条件
|
||||
boolean hasName = StringUtils.isNotBlank(bo.getRawMaterialName());
|
||||
boolean hasSpec = StringUtils.isNotBlank(bo.getSpecification());
|
||||
if (hasName && hasSpec && bo.getRawMaterialName().equals(bo.getSpecification())) {
|
||||
// 搜索关键词:匹配名称或规格
|
||||
String searchKey = bo.getRawMaterialName();
|
||||
lqw.and(wrapper -> wrapper
|
||||
.like(WmsRawMaterial::getRawMaterialName, searchKey)
|
||||
.or()
|
||||
.like(WmsRawMaterial::getSpecification, searchKey)
|
||||
);
|
||||
} else {
|
||||
// 分别处理名称和规格
|
||||
lqw.like(hasName, WmsRawMaterial::getRawMaterialName, bo.getRawMaterialName());
|
||||
lqw.like(hasSpec, WmsRawMaterial::getSpecification, bo.getSpecification());
|
||||
}
|
||||
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getSteelGrade()), WmsRawMaterial::getSteelGrade, bo.getSteelGrade());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getTargetColdGrade()), WmsRawMaterial::getTargetColdGrade, bo.getTargetColdGrade());
|
||||
lqw.eq(bo.getBaseMaterialId() != null, WmsRawMaterial::getBaseMaterialId, bo.getBaseMaterialId());
|
||||
@@ -206,8 +223,6 @@ public class WmsRawMaterialServiceImpl implements IWmsRawMaterialService {
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getInspectionResult()), WmsRawMaterial::getInspectionResult, bo.getInspectionResult());
|
||||
lqw.eq(bo.getIsEnabled() != null, WmsRawMaterial::getIsEnabled, bo.getIsEnabled());
|
||||
lqw.eq(bo.getBomId() != null, WmsRawMaterial::getBomId, bo.getBomId());
|
||||
//规格模糊匹配
|
||||
lqw.like(StringUtils.isNotBlank(bo.getSpecification()), WmsRawMaterial::getSpecification, bo.getSpecification());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getMaterial()), WmsRawMaterial::getMaterial, bo.getMaterial());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getSurfaceTreatmentDesc()), WmsRawMaterial::getSurfaceTreatmentDesc, bo.getSurfaceTreatmentDesc());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getManufacturer()), WmsRawMaterial::getManufacturer, bo.getManufacturer());
|
||||
|
||||
Reference in New Issue
Block a user