From 6b8585fc452ecdcaa82d86fab79a9f27bb442851 Mon Sep 17 00:00:00 2001
From: gaoluyang <2820782392@qq.com>
Date: 星期四, 05 十一月 2026 09:13:09 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev_南通_苏珩' into dev_南通_苏珩

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java |   52 +++++++++++-----------------------------------------
 1 files changed, 11 insertions(+), 41 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
index c0ce9a5..32eff6f 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
@@ -67,6 +67,9 @@
 public class MesQcOqcServiceImpl implements MesQcOqcService {
 
     @Resource
+    private cn.iocoder.yudao.module.mes.service.qc.MesQcCompletionHelper completionHelper;
+
+    @Resource
     private MesQcOqcMapper oqcMapper;
 
     @Resource
@@ -111,26 +114,11 @@
         // 1.2 鏍¢獙鏉ユ簮鍗曟嵁鍙傛暟锛屽苟楠岃瘉鏁版嵁瀛樺湪
         String sourceDocCode = validateAndGetSourceDocCode(
                 createReqVO.getSourceDocType(), createReqVO.getSourceLineId());
-        // 1.3 鏍规嵁浜у搧 + OQC 绫诲瀷鏌ユ壘鍙敤璐ㄦ鏂规锛堟敮鎸佸墠绔樉寮忔寚瀹氾級
-        List<MesQcTemplateItemDO> templateItems = templateItemService.getTemplateItemList(
-                createReqVO.getItemId(), MesQcTypeEnum.OQC.getType(), null, null);
-        if (CollUtil.isEmpty(templateItems)) {
-            throw exception(QC_NO_TEMPLATE);
-        }
-        MesQcTemplateItemDO templateItem = templateItems.get(0);
-        if (createReqVO.getTemplateId() != null) {
-            templateItem = templateItems.stream()
-                    .filter(available -> Objects.equals(available.getTemplateId(), createReqVO.getTemplateId()))
-                    .findFirst().orElse(null);
-            if (templateItem == null) {
-                throw exception(QC_NO_TEMPLATE); // 鎸囧畾浜嗘柟妗堜絾涓嶅湪鍖归厤鍒楄〃涓紝鎷掔粷
-            }
-        }
-        Long templateId = templateItem.getTemplateId();
+        // 鏂板缓璐ㄦ鍗曚笉渚濊禆璐ㄦ鏂规銆�
 
         // 2. 鎻掑叆涓昏〃
         MesQcOqcDO oqc = BeanUtils.toBean(createReqVO, MesQcOqcDO.class)
-                .setTemplateId(templateId)
+                .setTemplateId(null)
                 .setSourceDocCode(sourceDocCode)
                 .setStatus(MesQcStatusEnum.DRAFT.getStatus());
         if (createReqVO.getSourceLineId() != null) {
@@ -138,9 +126,6 @@
                     .validateProductSalesLineExists(createReqVO.getSourceLineId())));
         }
         oqcMapper.insert(oqc);
-
-        // 3. 浠庢ā鏉挎寚鏍囪嚜鍔ㄧ敓鎴愭楠岃
-        oqcLineService.createLinesFromTemplate(oqc.getId(), templateId);
         return oqc.getId();
     }
 
@@ -176,18 +161,16 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void finishOqc(Long id) {
+        completionHelper.lockDocument("oqc", id);
         // 1.1 鏍¢獙瀛樺湪 + 鑽夌鐘舵��
         MesQcOqcDO oqc = validateOqcStatusPrepare(id);
-        // 1.2 鏍¢獙妫�娴嬬粨璁哄繀濉�
-        if (oqc.getCheckResult() == null) {
-            throw exception(QC_OQC_CHECK_RESULT_EMPTY);
-        }
-        // 1.3 鏍¢獙鑷冲皯瀛樺湪涓�鏉℃娴嬬粨鏋�
-        indicatorResultService.validateIndicatorResultExistsByQcIdAndType(id, MesQcTypeEnum.OQC.getType());
+        int result = completionHelper.validateAndGetResult("oqc", id, oqc.getQualifiedQuantity(), oqc.getUnqualifiedQuantity(), oqc.getCheckQuantity());
+        oqc.setCheckResult(result);
+
 
         // 2. 鏇存柊鐘舵�佷负宸插畬鎴�
         MesQcOqcDO updateObj = new MesQcOqcDO()
-                .setId(id).setStatus(MesQcStatusEnum.FINISHED.getStatus());
+                .setId(id).setStatus(MesQcStatusEnum.FINISHED.getStatus()).setCheckResult(result);
         oqcMapper.updateById(updateObj);
 
         // 3. 涓嶅悎鏍兼椂鑷姩鍒涘缓 NCR
@@ -367,17 +350,6 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Long createOqcFromProductSales(Long salesId, MesWmProductSalesLineDO line, String salesCode, Long clientId) {
-        // 1. 鏍¢獙鐗╂枡鏄惁閰嶇疆浜� OQC 妫�楠屾ā鏉�
-        MesQcTemplateItemDO templateItem;
-        try {
-            templateItem = templateItemService.getRequiredTemplateByItemIdAndType(
-                    line.getItemId(), MesQcTypeEnum.OQC.getType());
-        } catch (Exception e) {
-            // 鑾峰彇鐗╂枡淇℃伅锛屾彁渚涙洿鏄庣‘鐨勯敊璇彁绀�
-            String itemInfo = getItemInfo(line.getItemId());
-            throw exception(QC_NO_TEMPLATE_FOR_ITEM, itemInfo);
-        }
-        Long templateId = templateItem.getTemplateId();
 
         // 2. 鐢熸垚妫�楠屽崟缂栫爜
         String code = "OQC" + System.currentTimeMillis();
@@ -386,7 +358,7 @@
         MesQcOqcDO oqc = new MesQcOqcDO();
         oqc.setCode(code);
         oqc.setName(salesCode + "-鍑鸿揣妫�楠�");
-        oqc.setTemplateId(templateId);
+
         oqc.setSourceDocType(MesBizTypeConstants.WM_PRODUCT_SALES);
         oqc.setSourceDocId(salesId);
         oqc.setSourceLineId(line.getId());
@@ -407,8 +379,6 @@
         oqc.setStatus(MesQcStatusEnum.DRAFT.getStatus());
         oqcMapper.insert(oqc);
 
-        // 4. 浠庢ā鏉挎寚鏍囪嚜鍔ㄧ敓鎴愭楠岃
-        oqcLineService.createLinesFromTemplate(oqc.getId(), templateId);
 
         return oqc.getId();
     }

--
Gitblit v1.9.3