From 962f78c8383e7c884ddb08c951c15e5ba6eb4cb8 Mon Sep 17 00:00:00 2001
From: liu <2021943741@qq.com>
Date: 星期五, 23 十月 2026 15:43:33 +0800
Subject: [PATCH] fix: 完善审批流程与业务状态校验

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/processparamtemplate/MesPdProcessParamTemplateServiceImpl.java |   88 +++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 82 insertions(+), 6 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/processparamtemplate/MesPdProcessParamTemplateServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/processparamtemplate/MesPdProcessParamTemplateServiceImpl.java
index 9d67013..c3e4fb7 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/processparamtemplate/MesPdProcessParamTemplateServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/processparamtemplate/MesPdProcessParamTemplateServiceImpl.java
@@ -1,7 +1,11 @@
 package cn.iocoder.yudao.module.mes.service.pd.processparamtemplate;
 
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.mes.controller.admin.pd.processparamtemplate.vo.MesPdProcessParamTemplateImportExcelVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pd.processparamtemplate.vo.MesPdProcessParamTemplateImportRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pd.processparamtemplate.vo.MesPdProcessParamTemplatePageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pd.processparamtemplate.vo.MesPdProcessParamTemplateSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pd.processparam.MesPdProcessParamDO;
@@ -19,7 +23,9 @@
 import org.springframework.validation.annotation.Validated;
 
 import java.util.ArrayList;
+import java.util.LinkedHashMap;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
@@ -27,7 +33,7 @@
 /**
  * MES 宸ヨ壓鍙傛暟妯℃澘 Service 瀹炵幇绫�
  *
- * @author 鑺嬮亾婧愮爜
+ * @author 瓒呯骇绠$悊鍛�
  */
 @Service
 @Validated
@@ -50,9 +56,16 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Long createProcessParamTemplate(MesPdProcessParamTemplateSaveReqVO createReqVO) {
-        // 1. 鐢熸垚妯℃澘缂栫爜
-        String templateCode = autoCodeRecordService.generateAutoCode(
-                MesMdAutoCodeRuleCodeEnum.PD_PROCESS_PARAM_TEMPLATE_CODE.getCode());
+        // 1. 浣跨敤鎵嬪~缂栫爜锛屾垨鑷姩鐢熸垚缂栫爜
+        String templateCode = createReqVO.getTemplateCode();
+        if (StrUtil.isNotBlank(templateCode)) {
+            if (templateMapper.selectByTemplateCode(templateCode) != null) {
+                throw exception(PD_PROCESS_PARAM_TEMPLATE_CODE_DUPLICATE);
+            }
+        } else {
+            templateCode = autoCodeRecordService.generateAutoCode(
+                    MesMdAutoCodeRuleCodeEnum.PD_PROCESS_PARAM_TEMPLATE_CODE.getCode());
+        }
         // 2. 鎻掑叆妯℃澘涓昏〃
         MesPdProcessParamTemplateDO template = BeanUtils.toBean(createReqVO, MesPdProcessParamTemplateDO.class);
         template.setTemplateCode(templateCode);
@@ -66,9 +79,19 @@
     @Transactional(rollbackFor = Exception.class)
     public void updateProcessParamTemplate(MesPdProcessParamTemplateSaveReqVO updateReqVO) {
         // 1. 鏍¢獙瀛樺湪
-        validateProcessParamTemplateExists(updateReqVO.getId());
-        // 2. 鏇存柊妯℃澘涓昏〃
+        MesPdProcessParamTemplateDO existing = validateProcessParamTemplateExists(updateReqVO.getId());
+        // 2. 鏇存柊妯℃澘涓昏〃锛氱紪鐮佺暀绌烘垨鏈彉鍖栧垯涓嶄慨鏀癸紱濉啓浜嗘柊缂栫爜鍒欐牎楠屽敮涓�
         MesPdProcessParamTemplateDO updateObj = BeanUtils.toBean(updateReqVO, MesPdProcessParamTemplateDO.class);
+        String templateCode = updateReqVO.getTemplateCode();
+        if (StrUtil.isNotBlank(templateCode) && !StrUtil.equals(templateCode, existing.getTemplateCode())) {
+            if (templateMapper.selectByTemplateCode(templateCode) != null) {
+                throw exception(PD_PROCESS_PARAM_TEMPLATE_CODE_DUPLICATE);
+            }
+            updateObj.setTemplateCode(templateCode);
+        } else {
+            // 缃┖锛岄伩鍏� MyBatis-Plus 鏇存柊鏃惰鐩栧師缂栫爜
+            updateObj.setTemplateCode(null);
+        }
         templateMapper.updateById(updateObj);
         // 3. 鍒犻櫎鏃ф槑缁嗗苟閲嶆柊鎻掑叆锛堝揩鐓фā寮忥細鍏堝垹鍚庢彃锛�
         detailMapper.deleteByTemplateId(updateReqVO.getId());
@@ -110,6 +133,59 @@
         return detailMapper.selectListByTemplateId(templateId);
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public MesPdProcessParamTemplateImportRespVO importProcessParamTemplateList(List<MesPdProcessParamTemplateImportExcelVO> importList,
+                                                                                boolean updateSupport) {
+        // 1. 鏍¢獙闈炵┖
+        if (CollUtil.isEmpty(importList)) {
+            throw exception(PD_PROCESS_PARAM_TEMPLATE_IMPORT_LIST_IS_EMPTY);
+        }
+
+        // 2. 閫愯澶勭悊
+        MesPdProcessParamTemplateImportRespVO respVO = MesPdProcessParamTemplateImportRespVO.builder()
+                .createCodes(new ArrayList<>()).updateCodes(new ArrayList<>())
+                .failureCodes(new LinkedHashMap<>()).build();
+        AtomicInteger index = new AtomicInteger(1);
+        importList.forEach(importItem -> {
+            int currentIndex = index.getAndIncrement();
+            String key = StrUtil.blankToDefault(importItem.getTemplateCode(), "绗� " + currentIndex + " 琛�");
+            if (StrUtil.isBlank(importItem.getTemplateName())) {
+                respVO.getFailureCodes().put(key, "妯℃澘鍚嶇О涓嶈兘涓虹┖");
+                return;
+            }
+            // 2.1 鍒ゆ柇锛氬垱寤� or 鏇存柊锛堢紪鐮佷负绌烘椂鑷姩鐢熸垚锛�
+            if (StrUtil.isNotBlank(importItem.getTemplateCode())) {
+                MesPdProcessParamTemplateDO existTemplate = templateMapper.selectByTemplateCode(importItem.getTemplateCode());
+                if (existTemplate == null) {
+                    // 2.1.1 鎸囧畾缂栫爜鏂板锛堜粎涓昏〃锛屾槑缁嗛渶鍦ㄩ〉闈㈢淮鎶わ級
+                    MesPdProcessParamTemplateDO template = BeanUtils.toBean(importItem, MesPdProcessParamTemplateDO.class);
+                    template.setId(null);
+                    templateMapper.insert(template);
+                    respVO.getCreateCodes().add(importItem.getTemplateCode());
+                } else if (updateSupport) {
+                    // 2.1.2 鏇存柊锛堜粎鏇存柊涓昏〃锛屼笉鍔ㄦ槑缁嗭級
+                    MesPdProcessParamTemplateDO updateObj = BeanUtils.toBean(importItem, MesPdProcessParamTemplateDO.class);
+                    updateObj.setId(existTemplate.getId());
+                    updateObj.setTemplateCode(existTemplate.getTemplateCode());
+                    templateMapper.updateById(updateObj);
+                    respVO.getUpdateCodes().add(importItem.getTemplateCode());
+                } else {
+                    respVO.getFailureCodes().put(key, "妯℃澘缂栫爜宸插瓨鍦�");
+                }
+            } else {
+                // 2.1.3 缂栫爜涓虹┖锛氳嚜鍔ㄧ敓鎴愮紪鐮佹柊澧�
+                MesPdProcessParamTemplateDO template = BeanUtils.toBean(importItem, MesPdProcessParamTemplateDO.class);
+                template.setId(null);
+                template.setTemplateCode(autoCodeRecordService.generateAutoCode(
+                        MesMdAutoCodeRuleCodeEnum.PD_PROCESS_PARAM_TEMPLATE_CODE.getCode()));
+                templateMapper.insert(template);
+                respVO.getCreateCodes().add(template.getTemplateCode());
+            }
+        });
+        return respVO;
+    }
+
     /**
      * 鍒涘缓妯℃澘鏄庣粏锛堝揩鐓ч�昏緫锛氫粠宸ヨ壓鍙傛暟涓昏〃澶嶅埗鍊煎埌鏄庣粏锛�
      *

--
Gitblit v1.9.3