From 0a1f000d5031c090059d5ae960019825196d4ba9 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期五, 10 四月 2026 17:46:19 +0800
Subject: [PATCH] fix: BOM导入验证产品、工序是否存在
---
src/main/java/com/ruoyi/production/service/impl/ProductBomServiceImpl.java | 137 ++++++++++++++++++++++++++++++---------------
1 files changed, 92 insertions(+), 45 deletions(-)
diff --git a/src/main/java/com/ruoyi/production/service/impl/ProductBomServiceImpl.java b/src/main/java/com/ruoyi/production/service/impl/ProductBomServiceImpl.java
index 9659cdd..1315d5c 100644
--- a/src/main/java/com/ruoyi/production/service/impl/ProductBomServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/ProductBomServiceImpl.java
@@ -109,18 +109,48 @@
return AjaxResult.error("鏁版嵁涓虹┖");
}
- // 澶勭悊宸ュ簭
list.forEach(dto -> {
dto.setParentName(clean(dto.getParentName()));
dto.setParentSpec(clean(dto.getParentSpec()));
dto.setChildName(clean(dto.getChildName()));
dto.setChildSpec(clean(dto.getChildSpec()));
+ dto.setProcess(clean(dto.getProcess()));
});
- handleProcess(list);
- Map<String, Long> processMap = productProcessService.list().stream()
- .collect(Collectors.toMap(ProductProcess::getName, ProductProcess::getId, (k1, k2) -> k1));
- // 鍒涘缓 BOM 鏁版嵁
+ Set<String> processNames = list.stream()
+ .map(BomImportDto::getProcess)
+ .filter(StringUtils::isNotBlank)
+ .collect(Collectors.toSet());
+
+ Map<String, Long> processMap = new HashMap<>();
+ if (!processNames.isEmpty()) {
+ List<ProductProcess> exists = productProcessService.list(
+ new LambdaQueryWrapper<ProductProcess>().in(ProductProcess::getName, processNames)
+ );
+ processMap = exists.stream().collect(Collectors.toMap(ProductProcess::getName, ProductProcess::getId, (k1, k2) -> k1));
+
+ Map<String, Long> finalProcessMap = processMap;
+ List<String> missingProcesses = processNames.stream()
+ .filter(n -> !finalProcessMap.containsKey(n))
+ .collect(Collectors.toList());
+
+ if (!missingProcesses.isEmpty()) {
+ throw new ServiceException("瀵煎叆澶辫触锛屼互涓嬪伐搴忎笉瀛樺湪锛�" + String.join(", ", missingProcesses));
+ }
+ }
+
+ Set<String> materialKeys = new HashSet<>();
+ for (BomImportDto dto : list) {
+ if (StringUtils.isNotBlank(dto.getParentName())) {
+ materialKeys.add(dto.getParentName() + "|" + (dto.getParentSpec() == null ? "" : dto.getParentSpec()));
+ }
+ if (StringUtils.isNotBlank(dto.getChildName())) {
+ materialKeys.add(dto.getChildName() + "|" + (dto.getChildSpec() == null ? "" : dto.getChildSpec()));
+ }
+ }
+
+ Map<String, ProductMaterialSku> skuMap = validateAndGetSkuMap(materialKeys);
+
ProductBom bom = new ProductBom();
bom.setDictCode(dictCode);
bom.setVersion("1.0");
@@ -128,7 +158,7 @@
bom.setBomNo("BM." + String.format("%05d", bom.getId()));
productBomMapper.updateById(bom);
- // 璁板綍宸茬粡鎻掑叆缁撴瀯鐨勮妭鐐癸細Key = "鍚嶇О+瑙勬牸", Value = structure_id
+ // 璁板綍宸茬粡鎻掑叆缁撴瀯鐨勮妭鐐癸細Key = "鍚嶇О+瑙勬牸", Value = structure_id
Map<String, Long> treePathMap = new HashMap<>();
for (BomImportDto dto : list) {
@@ -143,7 +173,7 @@
// 澶勭悊椤剁骇鑺傜偣 (瀛愰」鍙婂叾瑙勬牸鍧囦负绌哄綋浣滈《绾ц妭鐐瑰畾涔�)
if (StringUtils.isBlank(childName) && StringUtils.isBlank(childSpec)) {
if (!treePathMap.containsKey(parentKey)) {
- ProductMaterialSku model = findModel(parentName, parentSpec);
+ ProductMaterialSku model = skuMap.get(parentKey);
ProductStructure node = saveStructure(bom.getId(), null, model, dto.getUnitQty(), null);
treePathMap.put(parentKey, node.getId());
} else {
@@ -162,14 +192,14 @@
Long parentStructureId = treePathMap.get(parentKey);
if (parentStructureId == null) {
// 濡傛灉 Map 閲屾壘涓嶅埌鐖惰妭鐐癸紝瑙嗕负椤剁骇鐖惰妭鐐�
- ProductMaterialSku parentModel = findModel(parentName, parentSpec);
+ ProductMaterialSku parentModel = skuMap.get(parentKey);
ProductStructure parentNode = saveStructure(bom.getId(), null, parentModel, BigDecimal.ONE, null);
parentStructureId = parentNode.getId();
treePathMap.put(parentKey, parentStructureId);
}
// 鑾峰彇瀛愰」妯″瀷淇℃伅
- ProductMaterialSku childModel = findModel(childName, childSpec);
+ ProductMaterialSku childModel = skuMap.get(childKey);
Long processId = null;
if (StringUtils.isNotBlank(dto.getProcess())) {
processId = processMap.get(dto.getProcess());
@@ -285,51 +315,68 @@
}
}
- private ProductMaterialSku findModel(String name, String spec) {
- ProductMaterial product = productMaterialService.getOne(new LambdaQueryWrapper<ProductMaterial>()
- .eq(ProductMaterial::getProductName, name).last("limit 1"));
- if (product == null) throw new ServiceException("浜у搧鏈淮鎶わ細" + name);
- ProductMaterialSku model = productMaterialSkuService.getOne(new LambdaQueryWrapper<ProductMaterialSku>()
- .eq(ProductMaterialSku::getProductId, product.getId())
- .eq(ProductMaterialSku::getModel, spec).last("limit 1"));
- if (model == null) throw new ServiceException("瑙勬牸鏈淮鎶わ細" + name + "[" + spec + "]");
- return model;
- }
-
- private void handleProcess(List<BomImportDto> list) {
-
- Set<String> processNames = list.stream()
- .map(BomImportDto::getProcess)
- .filter(StringUtils::isNotBlank)
- .collect(Collectors.toSet());
-
- if (processNames.isEmpty()) {
- return;
+ /**
+ * 鎵归噺楠岃瘉骞惰幏鍙栦骇鍝丼KU淇℃伅
+ */
+ private Map<String, ProductMaterialSku> validateAndGetSkuMap(Set<String> materialKeys) {
+ if (materialKeys == null || materialKeys.isEmpty()) {
+ return Collections.emptyMap();
}
- List<ProductProcess> exists = productProcessService.list(
- new LambdaQueryWrapper<ProductProcess>().in(ProductProcess::getName, processNames)
- );
-
- Set<String> existNames = exists.stream()
- .map(ProductProcess::getName)
+ // 1. 鑾峰彇鎵�鏈変骇鍝佸悕绉板苟鏌ヨ
+ Set<String> productNames = materialKeys.stream()
+ .map(k -> k.split("\\|")[0])
.collect(Collectors.toSet());
- List<ProductProcess> needSave = processNames.stream()
- .filter(n -> !existNames.contains(n))
- .map(n -> {
- ProductProcess p = new ProductProcess();
- p.setName(n);
- return p;
+ List<ProductMaterial> products = productMaterialService.list(
+ new LambdaQueryWrapper<ProductMaterial>().in(ProductMaterial::getProductName, productNames)
+ );
+ Map<String, ProductMaterial> productMap = products.stream()
+ .collect(Collectors.toMap(ProductMaterial::getProductName, p -> p, (k1, k2) -> k1));
+
+ // 妫�鏌ョ己澶辩殑浜у搧
+ List<String> missingProducts = productNames.stream()
+ .filter(n -> !productMap.containsKey(n))
+ .collect(Collectors.toList());
+ if (!missingProducts.isEmpty()) {
+ throw new ServiceException("瀵煎叆澶辫触锛屼互涓嬩骇鍝佹湭缁存姢锛�" + String.join(", ", missingProducts));
+ }
+
+ // 2. 鏌ヨ鎵�鏈夌浉鍏崇殑 SKU
+ // 鏋勯�犳煡璇細(productId = ? AND model = ?) OR (productId = ? AND model = ?) ...
+ // 鐢变簬 MyBatis Plus 鐨� Or 宓屽鍙兘杈冩參涓旀澶勬暟閲忛�氬父鍙帶锛屾垜浠彲浠ュ厛鏌ュ嚭鎵�鏈夎繖浜� Product 鐨勬墍鏈� SKU
+ List<Long> productIds = products.stream().map(ProductMaterial::getId).collect(Collectors.toList());
+ List<ProductMaterialSku> skus = productMaterialSkuService.list(
+ new LambdaQueryWrapper<ProductMaterialSku>().in(ProductMaterialSku::getProductId, productIds)
+ );
+
+ // 鏋勫缓 Map: "浜у搧鍚嶇О|瑙勬牸" -> Sku
+ Map<String, ProductMaterialSku> skuMap = new HashMap<>();
+ for (ProductMaterialSku sku : skus) {
+ ProductMaterial p = productMap.values().stream()
+ .filter(pm -> pm.getId().equals(sku.getProductId()))
+ .findFirst().orElse(null);
+ if (p != null) {
+ String key = p.getProductName() + "|" + (sku.getModel() == null ? "" : sku.getModel());
+ skuMap.put(key, sku);
+ }
+ }
+
+ // 妫�鏌ョ己澶辩殑瑙勬牸
+ List<String> missingSkus = materialKeys.stream()
+ .filter(k -> !skuMap.containsKey(k))
+ .map(k -> {
+ String[] parts = k.split("\\|");
+ return parts[0] + "[" + (parts.length > 1 ? parts[1] : "") + "]";
})
.collect(Collectors.toList());
- if (!needSave.isEmpty()) {
- productProcessService.saveBatch(needSave);
- needSave.forEach(p -> p.setNo("GX" + String.format("%08d", p.getId())));
- productProcessService.updateBatchById(needSave);
+ if (!missingSkus.isEmpty()) {
+ throw new ServiceException("瀵煎叆澶辫触锛屼互涓嬩骇鍝佽鏍兼湭缁存姢锛�" + String.join(", ", missingSkus));
}
+
+ return skuMap;
}
private String clean(String s) {
--
Gitblit v1.9.3