From 94a273ee58ec05890d7401d27cc98d72867dfe7f Mon Sep 17 00:00:00 2001
From: zss <zss@example.com>
Date: 星期二, 27 一月 2026 15:55:55 +0800
Subject: [PATCH] 生产报工优化

---
 src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java |  195 +++++++++++++++++++++++-------------------------
 1 files changed, 93 insertions(+), 102 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 67d8bba..804c630 100644
--- a/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/ProductionProductMainServiceImpl.java
@@ -2,8 +2,6 @@
 
 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.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -13,12 +11,10 @@
 import com.ruoyi.basic.mapper.ProductModelMapper;
 import com.ruoyi.basic.pojo.Product;
 import com.ruoyi.basic.pojo.ProductModel;
-import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.enums.StockQualifiedRecordTypeEnum;
+import com.ruoyi.common.enums.StockUnQualifiedRecordTypeEnum;
 import com.ruoyi.common.utils.bean.BeanUtils;
-import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;
-import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;
 import com.ruoyi.procurementrecord.utils.StockUtils;
-import com.ruoyi.production.controller.ProductWorkOrderController;
 import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.production.dto.ProductionProductMainDto;
 import com.ruoyi.production.mapper.*;
@@ -28,19 +24,15 @@
 import com.ruoyi.project.system.mapper.SysUserMapper;
 import com.ruoyi.quality.mapper.*;
 import com.ruoyi.quality.pojo.*;
-import io.swagger.models.auth.In;
 import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import com.ruoyi.production.mapper.ProductionProductMainMapper;
-import oshi.driver.mac.net.NetStat;
 
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
-import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -49,10 +41,8 @@
 @Transactional(rollbackFor = Exception.class)
 public class ProductionProductMainServiceImpl extends ServiceImpl<ProductionProductMainMapper, ProductionProductMain> implements ProductionProductMainService {
 
-    private final ProcurementRecordOutMapper procurementRecordOutMapper;
     private ProductionProductMainMapper productionProductMainMapper;
 
-    private ProductWorkOrderController productWorkOrderController;
 
     private ProductWorkOrderMapper productWorkOrderMapper;
 
@@ -61,7 +51,6 @@
 
     private ProductionProductOutputMapper productionProductOutputMapper;
 
-    private ProcessRouteItemMapper processRouteItemMapper;
 
     private ProductModelMapper productModelMapper;
 
@@ -74,7 +63,7 @@
 
 
     private QualityTestStandardParamMapper qualityTestStandardParamMapper;
-    private QualityTestStandardBindingMapper qualityTestStandardBindingMapper;
+    private QualityTestStandardMapper qualityTestStandardMapper;
 
     private QualityInspectParamMapper qualityInspectParamMapper;
 
@@ -167,100 +156,100 @@
             productionProductInput.setQuantity(productStructureDto.getUnitQuantity().multiply(dto.getQuantity()));
             productionProductInput.setProductMainId(productionProductMain.getId());
             productionProductInputMapper.insert(productionProductInput);
-            //瀵瑰簲鐨勫簱瀛樺嚭搴�
-            DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyyMMdd");
-            LocalDate now = LocalDate.now();
-            ProcurementRecordOut procurementRecordOut1 = procurementRecordOutMapper.selectCode(dateFormat.format(now));
-            Long aLong = procurementRecordOut1 == null ? 1L : Long.valueOf(procurementRecordOut1.getCode().split("LS" + dateFormat.format(now))[1]);
-            ProcurementRecordOut.ProcurementRecordOutBuilder procurementRecordOut = ProcurementRecordOut.builder()
-                    .procurementRecordStorageId(0)
-                    .code("LS" + dateFormat.format(now) + String.format("%03d", aLong + 1))
-                    .salesLedgerProductId(productionProductMain.getId())//鍏宠仈鎶ュ伐浜у嚭
-                    .inboundBatches(aLong.equals(0L) ? "绗�1鎵规" : "绗�" + (aLong + 1) + "鎵规")
-                    .inboundNum(productionProductInput.getQuantity())
-                    .type(4)
-                    .createBy(user.getNickName())
-                    .productModelId(productModel1.getId());
-            procurementRecordOutMapper.insert(procurementRecordOut.build());
+            stockUtils.substractStock(productStructureDto.getProductModelId(), productionProductInput.getQuantity(), StockQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_OUT.getCode(), productionProductMain.getId());
+
         }
         /*鏂板鎶ュ伐浜у嚭琛�*/
         ProductionProductOutput productionProductOutput = new ProductionProductOutput();
         productionProductOutput.setProductMainId(productionProductMain.getId());
         productionProductOutput.setProductModelId(productProcessRouteItem.getProductModelId());
         productionProductOutput.setQuantity(dto.getQuantity() != null ? dto.getQuantity() : BigDecimal.ZERO);
+        productionProductOutput.setScrapQty(dto.getScrapQty() != null ? dto.getScrapQty() : BigDecimal.ZERO);
         productionProductOutputMapper.insert(productionProductOutput);
-        //瀵瑰簲鐨勮繃绋嬫鎴栬�呭嚭鍘傛
-        List<ProductProcessRouteItem> productProcessRouteItems = productProcessRouteItemMapper.selectList(Wrappers.<ProductProcessRouteItem>lambdaQuery().eq(ProductProcessRouteItem::getProductRouteId, productProcessRouteItem.getProductRouteId()));
-        int inspectType = 1;
-        if (productProcessRouteItem.getDragSort()==productProcessRouteItems.size()){
-            //鏈�鍚庝竴閬撳伐搴忕敓鎴愬嚭鍘傛
-            inspectType = 2;
-        }
-        Product product = productMapper.selectById(productModel.getProductId());
-        QualityInspect qualityInspect = new QualityInspect();
-        qualityInspect.setProductId(product.getId());
-        qualityInspect.setProductName(product.getProductName());
-        qualityInspect.setModel(productModel.getModel());
-        qualityInspect.setUnit(productModel.getUnit());
-        qualityInspect.setQuantity(dto.getQuantity());
-        qualityInspect.setProcess(productProcess.getName());
-        qualityInspect.setInspectState(0);
-        qualityInspect.setInspectType(inspectType);
-        qualityInspect.setProductMainId(productionProductMain.getId());
-        qualityInspect.setProductModelId(productModel.getId());
-        qualityInspectMapper.insert(qualityInspect);
-        List<QualityTestStandardBinding> qualityTestStandardBindings = qualityTestStandardBindingMapper.selectList(
-                new LambdaQueryWrapper<QualityTestStandardBinding>()
-                        .eq(QualityTestStandardBinding::getProductId, product.getId()));
-        if (qualityTestStandardBindings.size()>0){
-            qualityTestStandardParamMapper.selectList(Wrappers.<QualityTestStandardParam>lambdaQuery()
-                    .eq(QualityTestStandardParam::getTestStandardId,qualityTestStandardBindings.get(0).getTestStandardId()))
-                    .forEach(qualityTestStandardParam -> {
-                QualityInspectParam param = new QualityInspectParam();
-                BeanUtils.copyProperties(qualityTestStandardParam, param);
-                param.setId(null);
-                param.setInspectId(qualityInspect.getId());
-                qualityInspectParamMapper.insert(param);
-            });
-        }
-        /*鏇存柊宸ュ崟鍜岀敓浜ц鍗�*/
-        ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(dto.getWorkOrderId());
-        productWorkOrder.setCompleteQuantity(productWorkOrder.getCompleteQuantity().add(dto.getQuantity()));
-        if (ObjectUtils.isNull(productWorkOrder.getActualStartTime())){
-            productWorkOrder.setActualStartTime(LocalDate.now());//瀹為檯寮�濮嬫椂闂�
-        }
-        if (productWorkOrder.getCompleteQuantity().compareTo(productWorkOrder.getPlanQuantity()) == 0){
-            productWorkOrder.setActualEndTime(LocalDate.now());//瀹為檯缁撴潫鏃堕棿
-        }
-        productWorkOrderMapper.updateById(productWorkOrder);
-        //鐢熶骇璁㈠崟
-        ProductOrder productOrder = productOrderMapper.selectById(productWorkOrder.getProductOrderId());
-        if (ObjectUtils.isNull(productOrder.getStartTime())){
-            productOrder.setStartTime(LocalDateTime.now());//寮�濮嬫椂闂�
-        }
-        if (productProcessRouteItem.getDragSort()==productProcessRouteItems.size()){
-            //濡傛灉鏄渶鍚庝竴閬撳伐搴忔姤宸ヤ箣鍚庣敓浜ц鍗曞畬鎴愭暟閲�+
-            productOrder.setCompleteQuantity(productOrder.getCompleteQuantity().add(dto.getQuantity()));
-            if (productOrder.getCompleteQuantity().compareTo(productOrder.getQuantity()) == 0){
-                productOrder.setEndTime(LocalDateTime.now());//缁撴潫鏃堕棿
+        //鍚堟牸鏁伴噺=鎶ュ伐鏁伴噺-鎶ュ簾鏁伴噺
+        BigDecimal productQty = productionProductOutput.getQuantity().subtract(productionProductOutput.getScrapQty());
+        //鍙湁鍚堟牸鏁伴噺>0鎵嶈兘澧炲姞鐩稿簲鏁版嵁
+        if (productQty.compareTo(BigDecimal.ZERO)>0) {
+            /*鏂板璐ㄦ*/
+            //瀵瑰簲鐨勮繃绋嬫鎴栬�呭嚭鍘傛
+            List<ProductProcessRouteItem> productProcessRouteItems = productProcessRouteItemMapper.selectList(Wrappers.<ProductProcessRouteItem>lambdaQuery().eq(ProductProcessRouteItem::getProductRouteId, productProcessRouteItem.getProductRouteId()));
+            int inspectType = 1;
+            String process = productProcess.getName();//宸ュ簭
+            if (productProcessRouteItem.getDragSort() == productProcessRouteItems.size()) {
+                //鏈�鍚庝竴閬撳伐搴忕敓鎴愬嚭鍘傛
+                inspectType = 2;
+                process = null;
             }
+            Product product = productMapper.selectById(productModel.getProductId());
+            QualityInspect qualityInspect = new QualityInspect();
+            qualityInspect.setProductId(product.getId());
+            qualityInspect.setProductName(product.getProductName());
+            qualityInspect.setModel(productModel.getModel());
+            qualityInspect.setUnit(productModel.getUnit());
+            qualityInspect.setQuantity(productQty);
+            qualityInspect.setProcess(process);
+            qualityInspect.setInspectState(0);
+            qualityInspect.setInspectType(inspectType);
+            qualityInspect.setProductMainId(productionProductMain.getId());
+            qualityInspect.setProductModelId(productModel.getId());
+            qualityInspectMapper.insert(qualityInspect);
+            List<QualityTestStandard> qualityTestStandard = qualityTestStandardMapper.getQualityTestStandardByProductId(product.getId(), inspectType, process);
+            if (qualityTestStandard.size() > 0) {
+                qualityInspect.setTestStandardId(qualityTestStandard.get(0).getId());
+                qualityInspectMapper.updateById(qualityInspect);
+                qualityTestStandardParamMapper.selectList(Wrappers.<QualityTestStandardParam>lambdaQuery()
+                        .eq(QualityTestStandardParam::getTestStandardId, qualityTestStandard.get(0).getId()))//榛樿鑾峰彇鏈�鏂扮殑
+                        .forEach(qualityTestStandardParam -> {
+                            QualityInspectParam param = new QualityInspectParam();
+                            BeanUtils.copyProperties(qualityTestStandardParam, param);
+                            param.setId(null);
+                            param.setInspectId(qualityInspect.getId());
+                            qualityInspectParamMapper.insert(param);
+                        });
+            }
+            /*鏇存柊宸ュ崟鍜岀敓浜ц鍗�*/
+            ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(dto.getWorkOrderId());
+            productWorkOrder.setCompleteQuantity(productWorkOrder.getCompleteQuantity().add(productQty));
+            if (ObjectUtils.isNull(productWorkOrder.getActualStartTime())) {
+                productWorkOrder.setActualStartTime(LocalDate.now());//瀹為檯寮�濮嬫椂闂�
+            }
+            if (productWorkOrder.getCompleteQuantity().compareTo(productWorkOrder.getPlanQuantity()) == 0) {
+                productWorkOrder.setActualEndTime(LocalDate.now());//瀹為檯缁撴潫鏃堕棿
+            }
+            productWorkOrderMapper.updateById(productWorkOrder);
+            //鐢熶骇璁㈠崟
+            ProductOrder productOrder = productOrderMapper.selectById(productWorkOrder.getProductOrderId());
+            if (ObjectUtils.isNull(productOrder.getStartTime())) {
+                productOrder.setStartTime(LocalDateTime.now());//寮�濮嬫椂闂�
+            }
+            if (productProcessRouteItem.getDragSort() == productProcessRouteItems.size()) {
+                //濡傛灉鏄渶鍚庝竴閬撳伐搴忔姤宸ヤ箣鍚庣敓浜ц鍗曞畬鎴愭暟閲�+
+                productOrder.setCompleteQuantity(productOrder.getCompleteQuantity().add(productQty));
+                if (productOrder.getCompleteQuantity().compareTo(productOrder.getQuantity()) == 0) {
+                    productOrder.setEndTime(LocalDateTime.now());//缁撴潫鏃堕棿
+                }
+            }
+            productOrderMapper.updateById(productOrder);
+            /*娣诲姞鐢熶骇鏍哥畻*/
+            SalesLedgerProductionAccounting salesLedgerProductionAccounting = SalesLedgerProductionAccounting.builder()
+                    .salesLedgerWorkId(productionProductMain.getId())
+                    .salesLedgerSchedulingId(0L)
+                    .salesLedgerId(productOrder.getSalesLedgerId())
+                    .salesLedgerProductId(productOrder.getProductModelId())
+                    .schedulingUserId(user.getUserId())
+                    .schedulingUserName(user.getNickName())
+                    .finishedNum(productQty)
+                    .workHours(productProcess.getSalaryQuota())
+                    .process(productProcess.getName())
+                    .schedulingDate(LocalDate.now())
+                    .tenantId(dto.getTenantId())
+                    .build();
+            salesLedgerProductionAccountingMapper.insert(salesLedgerProductionAccounting);
         }
-        productOrderMapper.updateById(productOrder);
-        /*娣诲姞鐢熶骇鏍哥畻*/
-        SalesLedgerProductionAccounting salesLedgerProductionAccounting = SalesLedgerProductionAccounting.builder()
-                .salesLedgerWorkId(productionProductMain.getId())
-                .salesLedgerSchedulingId(0L)
-                .salesLedgerId(productOrder.getSalesLedgerId())
-                .salesLedgerProductId(productOrder.getProductModelId())
-                .schedulingUserId(user.getUserId())
-                .schedulingUserName(user.getNickName())
-                .finishedNum(dto.getQuantity() != null ? dto.getQuantity() : BigDecimal.ZERO)
-                .workHours(productProcess.getSalaryQuota())
-                .process(productProcess.getName())
-                .schedulingDate(LocalDate.now())
-                .tenantId(dto.getTenantId())
-                .build();
-        salesLedgerProductionAccountingMapper.insert(salesLedgerProductionAccounting);
+        //濡傛灉鎶ュ簾鏁伴噺>0,闇�瑕佽繘鍏ユ姤搴熺殑搴撳瓨
+        if (dto.getScrapQty().compareTo(BigDecimal.ZERO) > 0) {
+            stockUtils.addUnStock(productModel.getId(), dto.getScrapQty(), StockUnQualifiedRecordTypeEnum.PRODUCTION_SCRAP.getCode(), productionProductMain.getId());
+        }
         return true;
     }
 
@@ -302,11 +291,13 @@
         // 鍒犻櫎浜у嚭璁板綍
         productionProductOutputMapper.delete(new LambdaQueryWrapper<ProductionProductOutput>()
                 .eq(ProductionProductOutput::getProductMainId, productionProductMain.getId()));
-        /*鍒犻櫎鎶曞叆*/
-        procurementRecordOutMapper.delete(new LambdaQueryWrapper<ProcurementRecordOut>()
-                .eq(ProcurementRecordOut::getSalesLedgerProductId, productionProductMain.getId()));
+        //鍒犻櫎鎶曞叆璁板綍
         productionProductInputMapper.delete(new LambdaQueryWrapper<ProductionProductInput>()
                 .eq(ProductionProductInput::getProductMainId, productionProductMain.getId()));
+        //鍒犻櫎鎶ュ簾鐨勫叆搴撹褰�
+        stockUtils.deleteStockRecord(productionProductMain.getId(), StockUnQualifiedRecordTypeEnum.PRODUCTION_SCRAP.getCode());
+        //鍒犻櫎鎶曞叆瀵瑰簲鐨勫嚭搴撹褰�
+        stockUtils.deleteStockRecord(productionProductMain.getId(), StockQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_OUT.getCode());
         // 鍒犻櫎涓昏〃
         productionProductMainMapper.deleteById(productionProductMain.getId());
         return true;

--
Gitblit v1.9.3