From c215f6c20445b973ff730dcdf4206426992da81d Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期一, 19 十月 2026 11:30:57 +0800
Subject: [PATCH] feat(mes): 完善质检流程功能

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/ipqc/MesQcIpqcServiceImpl.java |   46 ++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 44 insertions(+), 2 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/ipqc/MesQcIpqcServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/ipqc/MesQcIpqcServiceImpl.java
index ec3f159..5edf94d 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/ipqc/MesQcIpqcServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/ipqc/MesQcIpqcServiceImpl.java
@@ -18,6 +18,7 @@
 import cn.iocoder.yudao.module.mes.dal.dataobject.qc.template.MesQcTemplateItemDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.qc.ipqc.MesQcIpqcMapper;
 import cn.iocoder.yudao.module.mes.enums.qc.MesQcDefectLevelEnum;
+import cn.iocoder.yudao.module.mes.enums.qc.MesQcCheckResultEnum;
 import cn.iocoder.yudao.module.mes.enums.qc.MesQcStatusEnum;
 import cn.iocoder.yudao.module.mes.enums.qc.MesQcTypeEnum;
 import cn.iocoder.yudao.module.mes.enums.pro.MesProFeedbackStatusEnum;
@@ -32,6 +33,8 @@
 import cn.iocoder.yudao.module.mes.service.qc.defectrecord.MesQcDefectRecordService;
 import cn.iocoder.yudao.module.mes.service.qc.indicatorresult.MesQcIndicatorResultService;
 import cn.iocoder.yudao.module.mes.service.qc.template.MesQcTemplateItemService;
+import cn.iocoder.yudao.module.mes.controller.admin.qc.ncr.vo.MesQcNcrSaveReqVO;
+import cn.iocoder.yudao.module.mes.service.qc.ncr.MesQcNcrService;
 import cn.iocoder.yudao.module.mes.service.wm.productproduce.MesWmProductProduceLineService;
 import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
 import jakarta.annotation.Resource;
@@ -52,7 +55,7 @@
 /**
  * MES 杩囩▼妫�楠屽崟锛圛PQC锛� Service 瀹炵幇绫�
  *
- * @author 鑺嬮亾婧愮爜
+ * @author 瓒呯骇绠$悊鍛�
  */
 @Service
 @Validated
@@ -104,6 +107,10 @@
     @Resource
     @Lazy
     private MesWmProductProduceLineService productProduceLineService;
+
+    @Resource
+    @Lazy
+    private MesQcNcrService ncrService;
 
     @Resource
     private AdminUserApi adminUserApi;
@@ -209,6 +216,14 @@
         if (ipqc.getCheckResult() == null) {
             throw exception(QC_IPQC_CHECK_RESULT_EMPTY);
         }
+        if (ipqc.getUnqualifiedQuantity() != null && ipqc.getUnqualifiedQuantity().compareTo(BigDecimal.ZERO) > 0
+                && MesQcCheckResultEnum.QUALIFIED.getType().equals(ipqc.getCheckResult())) {
+            throw new IllegalArgumentException("瀛樺湪涓嶅悎鏍煎搧鏃讹紝杩囩▼妫�楠岀粨璁轰笉鑳戒负鍚堟牸");
+        }
+        if ((ipqc.getUnqualifiedQuantity() == null || ipqc.getUnqualifiedQuantity().compareTo(BigDecimal.ZERO) == 0)
+                && !MesQcCheckResultEnum.QUALIFIED.getType().equals(ipqc.getCheckResult())) {
+            throw new IllegalArgumentException("涓嶅悎鏍兼暟閲忎负 0 鏃讹紝杩囩▼妫�楠岀粨璁哄繀椤讳负鍚堟牸");
+        }
         // 1.3 鏍¢獙鑷冲皯瀛樺湪涓�鏉℃娴嬬粨鏋�
         indicatorResultService.validateIndicatorResultExistsByQcIdAndType(id, MesQcTypeEnum.IPQC.getType());
 
@@ -216,11 +231,38 @@
         ipqcMapper.updateById(new MesQcIpqcDO()
                 .setId(id).setStatus(MesQcStatusEnum.FINISHED.getStatus()));
 
-        // 3. 鍥炲啓鏉ユ簮鍗曟嵁
+        // 3. 涓嶅悎鏍兼椂鑷姩鍒涘缓 NCR
+        generateNcrIfNeeded(ipqc);
+
+        // 4. 鍥炲啓鏉ユ簮鍗曟嵁
         writeBackSourceDoc(ipqc);
     }
 
     /**
+     * 涓嶅悎鏍兼椂鑷姩鍒涘缓 NCR锛堜笉鍚堟牸鍝佸鐞嗗崟锛�
+     *
+     * @param ipqc 杩囩▼妫�楠屽崟
+     */
+    private void generateNcrIfNeeded(MesQcIpqcDO ipqc) {
+        BigDecimal unqualifiedQty = ipqc.getUnqualifiedQuantity();
+        if (unqualifiedQty == null || unqualifiedQty.compareTo(BigDecimal.ZERO) <= 0) {
+            return;
+        }
+        String ncrCode = "NCR" + java.time.LocalDateTime.now()
+                .format(java.time.format.DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));
+        MesQcNcrSaveReqVO saveReqVO = new MesQcNcrSaveReqVO();
+        saveReqVO.setCode(ncrCode);
+        saveReqVO.setName("涓嶅悎鏍煎搧澶勭悊鍗�");
+        saveReqVO.setQcType(MesQcTypeEnum.IPQC.getType());
+        saveReqVO.setQcId(ipqc.getId());
+        saveReqVO.setItemId(ipqc.getItemId());
+        saveReqVO.setUnqualifiedQuantity(unqualifiedQty);
+        saveReqVO.setDefectDescription("鐢辫繃绋嬫楠�(" + ipqc.getCode() + ")鑷姩鐢熸垚");
+        ncrService.createNcr(saveReqVO);
+        log.info("[generateNcrIfNeeded] IPQC({}) 涓嶅悎鏍硷紝鑷姩鍒涘缓 NCR", ipqc.getId());
+    }
+
+    /**
      * 鍥炲啓鏉ユ簮鍗曟嵁锛圛PQC 瀹屾垚鍚庯級
      *
      * <p>褰撴潵婧愪负鎶ュ伐鏃讹紝鎷嗗垎寰呮浜у嚭琛屻�佸畬鎴愪骇鍑哄叆搴撱�佸洖鍐欐姤宸ョ姸鎬佸拰浠诲姟/宸ュ崟杩涘害

--
Gitblit v1.9.3