From a3416fc4497d2e9e5da1a1aa54c1109b388172d8 Mon Sep 17 00:00:00 2001 From: gnomeshgh <18153063927@163.com> Date: Fri, 3 Jul 2026 22:38:11 +0800 Subject: [PATCH] feat(bpm)：新增导入模型接口 --- yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/definition/BpmModelController.java | 27 +++++++++++++++++++++++++++ yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelService.java | 8 ++++++++ yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelServiceImpl.java | 23 +++++++++++++++++++++++ 3 files changed, 58 insertions(+), 0 deletions(-) diff --git a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/definition/BpmModelController.java b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/definition/BpmModelController.java index aa4c484..bdc84f1 100644 --- a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/definition/BpmModelController.java +++ b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/definition/BpmModelController.java @@ -1,7 +1,9 @@ package cn.iocoder.yudao.module.bpm.controller.admin.definition; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.StrUtil; import cn.iocoder.yudao.framework.common.pojo.CommonResult; +import cn.iocoder.yudao.framework.common.util.json.JsonUtils; import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.*; import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelNodeVO; import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelUpdateReqVO; @@ -18,6 +20,7 @@ import cn.iocoder.yudao.module.system.api.user.AdminUserApi; import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.Parameters; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.annotation.Resource; import jakarta.validation.Valid; @@ -27,7 +30,9 @@ import org.flowable.engine.repository.ProcessDefinition; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; +import java.io.IOException; import java.util.Collections; import java.util.List; import java.util.Map; @@ -119,6 +124,28 @@ public class BpmModelController { return success(modelService.createModel(createRetVO)); } + @PostMapping("/import") + @Operation(summary = "导入模型") + @Parameters({ + @Parameter(name = "file", description = "流程模型 JSON 文件", required = true), + @Parameter(name = "key", description = "流程标识，替换导入文件中的标识", example = "process_yudao"), + @Parameter(name = "name", description = "流程名称，替换导入文件中的名称", example = "芋道") + }) + @PreAuthorize("@ss.hasPermission('bpm:model:import')") + public CommonResult importModel(@RequestParam("file") MultipartFile file, + @RequestParam(value = "key", required = false) String key, + @RequestParam(value = "name", required = false) String name) throws IOException + { + BpmModelSaveReqVO reqVO = JsonUtils.parseObject(file.getBytes(), BpmModelSaveReqVO.class); + if (StrUtil.isNotEmpty(key)) { + reqVO.setKey(key); + } + if (StrUtil.isNotEmpty(name)) { + reqVO.setName(name); + } + return success(modelService.importModel(reqVO)); + } + @PutMapping("/update") @Operation(summary = "修改模型") @PreAuthorize("@ss.hasPermission('bpm:model:update')") diff --git a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelService.java b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelService.java index 3273d24..c0f2672 100644 --- a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelService.java +++ b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelService.java @@ -41,6 +41,14 @@ public interface BpmModelService { String createModel(@Valid BpmModelSaveReqVO modelVO); /** + * 导入流程模型 + * + * @param reqVO 导入信息 + * @return 创建的流程模型的编号 + */ + String importModel(@Valid BpmModelSaveReqVO reqVO); + + /** * 获得流程模块 * * @param id 编号 diff --git a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelServiceImpl.java b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelServiceImpl.java index c23ea9c..aa00057 100644 --- a/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelServiceImpl.java +++ b/yudao-module-bpm/src/main/java/cn/iocoder/yudao/module/bpm/service/definition/BpmModelServiceImpl.java @@ -120,6 +120,29 @@ public class BpmModelServiceImpl implements BpmModelService { } @Override + @Transactional(rollbackFor = Exception.class) + public String importModel(@Valid BpmModelSaveReqVO reqVO) { + if (!ValidationUtils.isXmlNCName(reqVO.getKey())) { + throw exception(MODEL_KEY_VALID); + } + // 1. 校验流程标识已经存在 + Model keyModel = getModelByKey(reqVO.getKey()); + if (keyModel != null) { + throw exception(MODEL_KEY_EXISTS, reqVO.getKey()); + } + + // 2. 创建 Model 对象 + reqVO.setSort(System.currentTimeMillis()); + Model model = repositoryService.newModel(); + BpmModelConvert.INSTANCE.copyToModel(model, reqVO); + model.setTenantId(FlowableUtils.getTenantId()); + + // 3. 保存模型 + saveModel(model, reqVO); + return model.getId(); + } + + @Override @Transactional(rollbackFor = Exception.class) // 因为进行多个操作，所以开启事务 public void updateModel(Long userId, BpmModelSaveReqVO updateReqVO) { // 1. 校验流程模型存在 -- libgit2 0.21.4