From 52b61fce22f188e37a88c20740e005ff109637a7 Mon Sep 17 00:00:00 2001
From: hsy <1029150275@qq.com>
Date: 星期一, 17 八月 2026 15:02:27 +0800
Subject: [PATCH] dos: 新增表：mes_pro_task_pause_record
---
yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/attach/BpmBusinessAttachServiceImpl.java | 119 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 119 insertions(+), 0 deletions(-)
diff --git a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/attach/BpmBusinessAttachServiceImpl.java b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/attach/BpmBusinessAttachServiceImpl.java
new file mode 100644
index 0000000..2d14ef5
--- /dev/null
+++ b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/attach/BpmBusinessAttachServiceImpl.java
@@ -0,0 +1,119 @@
+package cn.iocoder.yudao.module.bpm.service.attach;
+
+import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachPageReqVO;
+import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachSaveReqVO;
+import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.process.BpmProcessDefinitionRespVO;
+import cn.iocoder.yudao.module.bpm.dal.dataobject.definition.BpmBusinessAttachDO;
+import cn.iocoder.yudao.module.bpm.dal.mysql.attach.BpmBusinessAttachMapper;
+import cn.iocoder.yudao.module.bpm.enums.definition.BpmModelFormTypeEnum;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+
+import java.util.Objects;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_NOT_EXISTS;
+import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_PROCESS_DEFINITION_KEY_DUPLICATE;
+
+/**
+ * BPM 涓氬姟闄勪欢閰嶇疆 Service 瀹炵幇绫�
+ *
+ * @author 瓒呯骇绠＄悊鍛�
+ */
+@Service
+@Validated
+public class BpmBusinessAttachServiceImpl implements BpmBusinessAttachService {
+
+ @Resource
+ private BpmBusinessAttachMapper businessAttachMapper;
+
+ @Override
+ public Long createBusinessAttach(BpmBusinessAttachSaveReqVO createReqVO) {
+ // 鏍￠獙娴佺▼瀹氫箟 Key 鍞竴
+ validateProcessDefinitionKeyUnique(createReqVO);
+ // 鎻掑叆
+ BpmBusinessAttachDO attach = BeanUtils.toBean(createReqVO, BpmBusinessAttachDO.class);
+ businessAttachMapper.insert(attach);
+ return attach.getId();
+ }
+
+ @Override
+ public void updateBusinessAttach(BpmBusinessAttachSaveReqVO updateReqVO) {
+ // 鏍￠獙瀛樺湪
+ validateBusinessAttachExists(updateReqVO.getId());
+ // 鏍￠獙娴佺▼瀹氫箟 Key 鍞竴
+ validateProcessDefinitionKeyUnique(updateReqVO);
+ // 鏇存柊
+ BpmBusinessAttachDO updateObj = BeanUtils.toBean(updateReqVO, BpmBusinessAttachDO.class);
+ businessAttachMapper.updateById(updateObj);
+ }
+
+ private void validateProcessDefinitionKeyUnique(BpmBusinessAttachSaveReqVO reqVO) {
+ BpmBusinessAttachDO attach = businessAttachMapper.selectByProcessDefinitionKey(reqVO.getProcessDefinitionKey());
+ if (attach == null || ObjUtil.equal(attach.getId(), reqVO.getId())) {
+ return;
+ }
+ throw exception(BUSINESS_ATTACH_PROCESS_DEFINITION_KEY_DUPLICATE, reqVO.getProcessDefinitionKey());
+ }
+
+ @Override
+ public void deleteBusinessAttach(Long id) {
+ // 鏍￠獙瀛樺湪
+ validateBusinessAttachExists(id);
+ // 鍒犻櫎
+ businessAttachMapper.deleteById(id);
+ }
+
+ private BpmBusinessAttachDO validateBusinessAttachExists(Long id) {
+ BpmBusinessAttachDO attach = businessAttachMapper.selectById(id);
+ if (attach == null) {
+ throw exception(BUSINESS_ATTACH_NOT_EXISTS);
+ }
+ return attach;
+ }
+
+ @Override
+ public BpmBusinessAttachDO getBusinessAttach(Long id) {
+ return businessAttachMapper.selectById(id);
+ }
+
+ @Override
+ public PageResult<BpmBusinessAttachDO> getBusinessAttachPage(BpmBusinessAttachPageReqVO pageReqVO) {
+ return businessAttachMapper.selectPage(pageReqVO);
+ }
+
+ @Override
+ public BpmBusinessAttachDO getBusinessAttachByProcessDefinitionKey(String processDefinitionKey) {
+ return businessAttachMapper.selectByProcessDefinitionKey(processDefinitionKey);
+ }
+
+ @Override
+ public void fillBusinessForm(BpmProcessDefinitionRespVO definitionResp, String processDefinitionKey, String businessKey) {
+ // 鏈彂璧� / 鏃犱笟鍔′富閿細涓嶆敞鍏�
+ if (definitionResp == null || StrUtil.isBlank(businessKey)) {
+ return;
+ }
+ // 闈� NORMAL 娴佺▼琛ㄥ崟锛堝凡鎵嬪姩閰嶇疆 CUSTOM锛夛細涓嶈鐩�
+ if (!Objects.equals(definitionResp.getFormType(), BpmModelFormTypeEnum.NORMAL.getType())) {
+ return;
+ }
+ // 鏈懡涓厤缃� / 閰嶇疆琚鐢細淇濇寔鍘熸牱
+ BpmBusinessAttachDO attach = getBusinessAttachByProcessDefinitionKey(processDefinitionKey);
+ if (attach == null || !Objects.equals(attach.getStatus(), CommonStatusEnum.ENABLE.getStatus())) {
+ return;
+ }
+ // 瑕嗙洊涓� CUSTOM锛屾敞鍏ヤ笟鍔¤鎯呯粍浠惰矾寰�
+ definitionResp.setFormType(BpmModelFormTypeEnum.CUSTOM.getType());
+ definitionResp.setFormCustomViewPath(attach.getComponentPath());
+ // 娓呯┖鏅�氳〃鍗曞瓧娈碉細璇︽儏椤� CUSTOM 鍒嗘敮涓嶈锛涙墦鍗伴〉鎸� formFields.length == 0 鍒ゆ柇娓叉煋涓氬姟缁勪欢
+ definitionResp.setFormFields(null);
+ definitionResp.setFormConf(null);
+ }
+
+}
--
Gitblit v1.9.3