From f7559a0880080f0aaaac59867606daad656b280a Mon Sep 17 00:00:00 2001
From: liyong <18434998025@163.com>
Date: 星期三, 14 一月 2026 14:04:10 +0800
Subject: [PATCH] feat(product): 添加产品规格ID字段并实现库存检查功能

---
 src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java |   35 +++++++++++++++++++++++++----------
 1 files changed, 25 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java b/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java
index a8abbf7..046f8c4 100644
--- a/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java
@@ -2,6 +2,7 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -12,6 +13,7 @@
 import com.ruoyi.basic.pojo.ProductModel;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.bean.BeanUtils;
+import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.production.controller.ProductWorkOrderController;
 import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.production.dto.ProductionProductMainDto;
@@ -33,6 +35,7 @@
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -71,6 +74,8 @@
     private ProductOrderMapper productOrderMapper;
 
     private SalesLedgerProductionAccountingMapper salesLedgerProductionAccountingMapper;
+
+    private StockUtils stockUtils;
 
 
     @Override
@@ -138,12 +143,13 @@
 
         //鏇存柊宸ュ崟
         if (insert > 0) {
-            UpdateWrapper<ProductWorkOrder> wrapper = new UpdateWrapper<>();
-            wrapper.set("report_work", true)
-                    .set("quantity", dto.getQuantity())
-                    .set("product_main_id", productionProductMain.getId())
-                    .eq("id", dto.getWorkOrderId());
-            productWorkOrderMapper.update(null, wrapper);
+            Map<String, Object> params = new HashMap<>();
+            params.put("quantity", dto.getQuantity());
+            params.put("productMainId", productionProductMain.getId());
+            params.put("workOrderId", dto.getWorkOrderId());
+            params.put("deductQuantity", dto.getQuantity());
+
+            productWorkOrderMapper.updatePlanQuantity(params);
         }
         ProductProcess productProcess = productProcessMapper.selectById(productProcessRouteItem.getProcessId());
         ProductModel productModel = productProcessRouteItem.getProductModelId() != null ?
@@ -163,6 +169,7 @@
             qualityInspect.setInspectState(0);
             qualityInspect.setInspectType(inspectType);
             qualityInspect.setProductMainId(productionProductMain.getId());
+            qualityInspect.setProductModelId(productModel.getId());
             qualityInspectMapper.insert(qualityInspect);
 
             qualityTestStandardMapper.selectList(
@@ -180,9 +187,15 @@
         if (productModel != null) {
             List<ProductStructureDto> productStructureDtos = productStructureMapper.listByproductModelId(productModel.getId());
             for (ProductStructureDto productStructureDto : productStructureDtos) {
+                ProductModel productModel1 = productModelMapper.selectById(productStructureDto.getProductModelId());
+
+                BigDecimal stockQuantity = stockUtils.getStockQuantity(productModel1.getId());
+                if (!(stockQuantity.compareTo(BigDecimal.ZERO) > 0)) {
+                    throw new RuntimeException("搴撳瓨涓嶈冻");
+                }
                 ProductionProductInput productionProductInput = new ProductionProductInput();
                 productionProductInput.setProductModelId(productStructureDto.getProductModelId());
-                productionProductInput.setQuantity(productStructureDto.getUnitQuantity());
+                productionProductInput.setQuantity(productStructureDto.getUnitQuantity().multiply(dto.getQuantity()));
                 productionProductInput.setProductMainId(productionProductMain.getId());
                 productionProductInputMapper.insert(productionProductInput);
             }
@@ -225,6 +238,8 @@
     public Boolean removeProductMain(ProductionProductMainDto dto) {
         Long id = dto.getId();
 
+        // 鏇存柊宸ュ崟
+        productWorkOrderMapper.rollbackPlanQuantity(id);
         // 鍒犻櫎璐ㄦ鍙傛暟鍜岃川妫�璁板綍
         qualityInspectMapper.selectList(
                 new LambdaQueryWrapper<QualityInspect>()
@@ -243,9 +258,9 @@
 
         // 鍒犻櫎鍏宠仈鐨勬牳绠楁暟鎹�
         salesLedgerProductionAccountingMapper.delete(
-                        new LambdaQueryWrapper<SalesLedgerProductionAccounting>()
-                                .eq(SalesLedgerProductionAccounting::getSalesLedgerWorkId, id)
-                );
+                new LambdaQueryWrapper<SalesLedgerProductionAccounting>()
+                        .eq(SalesLedgerProductionAccounting::getSalesLedgerWorkId, id)
+        );
 
         // 鍒犻櫎涓昏〃
         return productionProductMainMapper.deleteById(id) > 0;

--
Gitblit v1.9.3