From 666dddac6724361f31d640435ea23b84ca1539f9 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期四, 12 三月 2026 17:09:42 +0800
Subject: [PATCH] fix: 移除生产计划多余字段

---
 src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java |  136 ++++++++++++++++++++++++++++++--------------
 1 files changed, 92 insertions(+), 44 deletions(-)

diff --git a/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java b/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
index cb916e9..e2c41db 100644
--- a/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
+++ b/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
@@ -15,7 +15,11 @@
 import com.ruoyi.common.utils.http.HttpUtils;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.framework.config.AliDingConfig;
+import com.ruoyi.production.pojo.ProductMaterial;
+import com.ruoyi.production.pojo.ProductMaterialSku;
 import com.ruoyi.production.pojo.ProductOrder;
+import com.ruoyi.production.service.ProductMaterialService;
+import com.ruoyi.production.service.ProductMaterialSkuService;
 import com.ruoyi.production.service.ProductOrderService;
 import com.ruoyi.productionPlan.dto.ProductionPlanDto;
 import com.ruoyi.productionPlan.dto.ProductionPlanImportDto;
@@ -69,6 +73,12 @@
     @Autowired
     private ProductOrderPlanMapper productOrderPlanMapper;
 
+    @Autowired
+    private ProductMaterialSkuService productMaterialSkuService;
+
+    @Autowired
+    private ProductMaterialService productMaterialService;
+
     /**
      * 鍚屾閿侊紝纭繚鎵嬪姩鍜屽畾鏃朵换鍔′笉鍚屾椂鎵ц
      */
@@ -106,7 +116,7 @@
         }
 
         //  鏌ヨ涓荤敓浜ц鍒�
-        List<ProductionPlan> plans = productionPlanMapper.selectBatchIds(productionPlanDto.getIds());
+        List<ProductionPlanDto> plans = productionPlanMapper.selectWithMaterialByIds(productionPlanDto.getIds());
 
         //  鏍¢獙鏄惁瀛樺湪涓嶅悓鐨勪骇鍝佸悕绉�
         String firstProductName = plans.get(0).getProductName();
@@ -115,43 +125,19 @@
         }
 
         // 鏍¢獙鏄惁瀛樺湪涓嶅悓鐨勪骇鍝佽鏍�
-        String firstProductSpec = plans.get(0).getProductSpec();
-        if (plans.stream().anyMatch(p -> !p.getProductSpec().equals(firstProductSpec))) {
+        String firstProductSpec = plans.get(0).getSpecification();
+        if (plans.stream().anyMatch(p -> !p.getSpecification().equals(firstProductSpec))) {
             throw new BaseException("鍚堝苟澶辫触锛屽瓨鍦ㄤ笉鍚岀殑浜у搧瑙勬牸");
         }
 
-
-        // 鍙犲姞鏂规暟
-        BigDecimal totalVolume = plans.stream()
-                .map(ProductionPlan::getVolume)
+        // 鍙犲姞鍓╀綑鏂规暟
+        BigDecimal totalRemainingVolume = plans.stream()
+                .map(ProductionPlan::getRemainingVolume)
                 .filter(v -> v != null)
                 .reduce(BigDecimal.ZERO, BigDecimal::add);
-        // 鍒ゆ柇涓嬪彂鏁伴噺鏄惁澶т簬绛変簬鏂规暟
-        if (productionPlanDto.getTotalAssignedQuantity().compareTo(totalVolume) > 0) {
-
-            log.warn("鎿嶄綔澶辫触锛屼笅鍙戞暟閲忎笉鑳藉ぇ浜庢柟鏁�");
-            return false;
-        }
-
-        // 鏍规嵁涓嬪彂鏁伴噺锛屼粠绗竴涓敓浜ц鍒掑紑濮嬪垎閰嶆柟鏁�
-        BigDecimal assignedVolume = BigDecimal.ZERO;
-        for (ProductionPlan plan : plans) {
-            BigDecimal volume = plan.getVolume();
-            if (volume == null) {
-                continue;
-            }
-
-            if (assignedVolume.add(volume).compareTo(productionPlanDto.getTotalAssignedQuantity()) >= 0) {
-                // 鏈�鍚庝竴涓鍒掞紝鍒嗛厤鍓╀綑鏂规暟
-                plan.setAssignedQuantity(productionPlanDto.getTotalAssignedQuantity().subtract(assignedVolume));
-                productionPlanMapper.updateById(plan);
-                break;
-            }
-
-            // 鍒嗛厤褰撳墠璁″垝鏂规暟
-            plan.setAssignedQuantity(volume);
-            productionPlanMapper.updateById(plan);
-            assignedVolume = assignedVolume.add(volume);
+        // 鍒ゆ柇涓嬪彂鏁伴噺鏄惁澶т簬绛変簬鍓╀綑鏂规暟
+        if (productionPlanDto.getTotalAssignedQuantity().compareTo(totalRemainingVolume) > 0) {
+            throw new BaseException("鎿嶄綔澶辫触锛屼笅鍙戞暟閲忎笉鑳藉ぇ浜庡墿浣欐柟鏁�");
         }
 
         // 鍒涘缓鐢熶骇璁㈠崟
@@ -160,11 +146,41 @@
         productOrder.setPlanCompleteTime(productionPlanDto.getPlanCompleteTime());
         productOrderService.addProductOrder(productOrder);
 
-        for (Long planId : productionPlanDto.getIds()) {
+        // 鏍规嵁涓嬪彂鏁伴噺锛屼粠绗竴涓敓浜ц鍒掑紑濮嬪垎閰嶆柟鏁�
+        BigDecimal assignedVolume = BigDecimal.ZERO;
+        for (ProductionPlan plan : plans) {
+            BigDecimal volume = plan.getVolume();
+            if (volume == null) {
+                continue;
+            }
+            // 璁$畻鍓╀綑鏂规暟
+            BigDecimal remainingVolume = plan.getRemainingVolume();
+            if (remainingVolume.compareTo(BigDecimal.ZERO) <= 0) {
+                continue;
+            }
+
             ProductOrderPlan productOrderPlan = new ProductOrderPlan();
             productOrderPlan.setProductOrderId(productOrder.getId());
-            productOrderPlan.setProductionPlanId(planId);
+            productOrderPlan.setProductionPlanId(plan.getId());
+
+            if (assignedVolume.add(remainingVolume).compareTo(productionPlanDto.getTotalAssignedQuantity()) >= 0) {
+                // 鏈�鍚庝竴涓鍒掞紝鍒嗛厤鍓╀綑鏂规暟
+                BigDecimal lastRemainingVolume = productionPlanDto.getTotalAssignedQuantity().subtract(assignedVolume);
+                plan.setAssignedQuantity(plan.getAssignedQuantity().add(lastRemainingVolume));
+                productOrderPlan.setAssignedQuantity(lastRemainingVolume);
+                productionPlanMapper.updateById(plan);
+                productOrderPlanMapper.insert(productOrderPlan);
+                break;
+            }
+
+            // 鍒嗛厤褰撳墠璁″垝鏂规暟
+            plan.setAssignedQuantity(plan.getAssignedQuantity().add(remainingVolume));
+            productOrderPlan.setAssignedQuantity(remainingVolume);
+            // 鏇存柊鐢熶骇璁″垝
+            productionPlanMapper.updateById(plan);
+            // 鍒涘缓鍏宠仈鍏崇郴
             productOrderPlanMapper.insert(productOrderPlan);
+            assignedVolume = assignedVolume.add(remainingVolume);
         }
         return true;
     }
@@ -306,9 +322,23 @@
         searchParam.put("appType", aliDingConfig.getAppType());
         searchParam.put("systemToken", aliDingConfig.getSystemToken());
         searchParam.put("userId", aliDingConfig.getUserId());
-        searchParam.put("formUuid", aliDingConfig.getFormUuid());
+        searchParam.put("formUuid", aliDingConfig.getProducePlanFormUuid());
+        searchParam.put("currentPage", pageNumber);
         searchParam.put("pageSize", pageSize);
-        searchParam.put("pageNumber", pageNumber);
+
+        JSONArray searchConditions = new JSONArray();
+        JSONObject condition = new JSONObject();
+        condition.put("key", "processApprovedResult");
+        JSONArray valueArray = new JSONArray();
+        valueArray.add("agree");
+
+        condition.put("value", valueArray);
+        condition.put("type", "ARRAY");
+        condition.put("operator", "in");
+        condition.put("componentName", "SelectField");
+        searchConditions.add(condition);
+
+        searchParam.put("searchFieldJson", searchConditions.toJSONString());
 
         // 榛樿鎸変慨鏀规椂闂村崌搴忔帓搴忥紝纭繚鍒嗛〉鎷夊彇鏁版嵁鐨勮繛缁��
         // "+" 琛ㄧず鍗囧簭锛�"gmt_modified" 鏄畼鏂瑰唴缃瓧娈�
@@ -358,9 +388,17 @@
                 plan.setApplyNo(formData.getString("textField_l7fytfco"));
                 plan.setCustomerName(formData.getString("textField_lbkozohg"));
 
-                plan.setMaterialCode(row.getString("textField_l9xo62q5"));
-                plan.setProductName(row.getString("textField_l9xo62q7"));
-                plan.setProductSpec(row.getString("textField_l9xo62q8"));
+                String materialCode = row.getString("textField_l9xo62q5");
+                // 鏍规嵁鐗╂枡缂栫爜鏌ヨ鐗╂枡淇℃伅琛紝鍏宠仈鐗╂枡ID
+                if (StringUtils.isNotEmpty(materialCode)) {
+                    LambdaQueryWrapper<ProductMaterialSku> skuQueryWrapper = new LambdaQueryWrapper<>();
+                    skuQueryWrapper.eq(ProductMaterialSku::getMaterialCode, materialCode);
+                    ProductMaterialSku sku = productMaterialSkuService.getOne(skuQueryWrapper);
+                    if (sku != null) {
+                        plan.setProductMaterialSkuId(sku.getId());
+                    }
+                }
+
                 plan.setLength(row.getInteger("numberField_lb7lgatg_value"));
                 plan.setWidth(row.getInteger("numberField_lb7lgath_value"));
                 plan.setHeight(row.getInteger("numberField_lb7lgati_value"));
@@ -434,19 +472,19 @@
         //  Map (formInstanceId + materialCode)
         Map<String, ProductionPlan> existMap = new HashMap<>();
         for (ProductionPlan p : existList) {
-            String key = p.getFormInstanceId() + "_" + p.getMaterialCode();
+            String key = p.getFormInstanceId() + "_" + p.getProductMaterialSkuId();
             existMap.put(key, p);
         }
 
         //  閬嶅巻鍚屾鏁版嵁
         for (ProductionPlan plan : list) {
-            String key = plan.getFormInstanceId() + "_" + plan.getMaterialCode();
+            String key = plan.getFormInstanceId() + "_" + plan.getProductMaterialSkuId();
             ProductionPlan exist = existMap.get(key);
             if (exist == null) {
                 // 鏂板
                 this.save(plan);
                 affected++;
-                log.info("鏂板鏁版嵁 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getMaterialCode());
+                log.info("鏂板鏁版嵁 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getProductMaterialSkuId());
             } else {
                 // 鍒ゆ柇鏄惁闇�瑕佹洿鏂�
                 if (exist.getFormModifiedTime() == null || !exist.getFormModifiedTime().equals(plan.getFormModifiedTime())) {
@@ -454,7 +492,7 @@
                     plan.setCreateTime(exist.getCreateTime());
                     this.updateById(plan);
                     affected++;
-                    log.info("鏇存柊鏁版嵁 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getMaterialCode());
+                    log.info("鏇存柊鏁版嵁 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getProductMaterialSkuId());
                 }
             }
         }
@@ -508,6 +546,16 @@
             entity.setDataSourceType(2);
             entity.setDataSyncType(1);
 
+            // 鏍规嵁鐗╂枡缂栫爜濉厖鍏宠仈ID
+            if (StringUtils.isNotEmpty(dto.getMaterialCode())) {
+                LambdaQueryWrapper<ProductMaterialSku> skuQueryWrapper = new LambdaQueryWrapper<>();
+                skuQueryWrapper.eq(ProductMaterialSku::getMaterialCode, dto.getMaterialCode());
+                ProductMaterialSku sku = productMaterialSkuService.getOne(skuQueryWrapper);
+                if (sku != null) {
+                    entity.setProductMaterialSkuId(sku.getId());
+                }
+            }
+
             entityList.add(entity);
         }
         this.saveBatch(entityList);

--
Gitblit v1.9.3