boot-admin整合flowable官方editor-app源码进行BPMN2-0建模（续） ...

boot-admin整合flowable官方editor-app源码进行BPMN2-0建模（续）
书接上回
项目源码仓库github
项目源码仓库gitee
boot-admin 是一款采用前后端分离模式、基于SpringCloud微服务架构的SaaS后台管理框架。系统内置基础管理、权限管理、运行管理、定义管理、代码生成器和办公管理6个功能模块，集成分布式事务Seata、工作流引擎Flowable、业务规则引擎Drools、后台作业调度框架Quartz等，技术栈包括Mybatis-plus、Redis、Nacos、Seata、Flowable、Drools、Quartz、SpringCloud、Springboot Admin Gateway、Liquibase、jwt、Openfeign、I18n等。
在上一篇博文中，已经介绍了 boot-admin 对 editor-app 前端代码的集成改造，接下来我们看看后端代码。
提供汉化资源json数据

1.    /**
2.      * 获取汉化资源
3.      * @return
4.      */
5.     @RequestMapping(value = "/editor/stencilset", method = RequestMethod.GET, produces = "application/json;charset=utf-8")
6.     public String getStencilset() {
7.         InputStream stencilsetStream = this.getClass().getClassLoader().getResourceAsStream("stencilset.json");
8.         try {
9.             return IOUtils.toString(stencilsetStream, "utf-8");
10.         } catch (Exception e) {
11.             throw new FlowableException("Error while loading stencil set", e);
12.         }
13.     }

复制代码

资源包stencilset.json需放在resources文夹下，这里提供下载：点击下载汉化包
分页获取模型列表

controller：

1. @RequestMapping("/api/workflow/auth/activiti")
2. @RestController
3. @Slf4j
4. public class ModelController extends BaseController {
5.     @Resource
6.     private FormValidator formValidator;
7.     @Autowired
8.     private MyModelService modelService;
10.     @PostMapping("/model/page")
11.     @ApiOperation("分页获取项目数据表列表")
12.     public ResultDTO getTablePage(@Valid @RequestBody ModelQueryVO queryVO, BindingResult bindingResult) throws Exception {
13.         if (bindingResult.hasErrors()) {
14.             return formValidator.generateMessage(bindingResult);
15.         }
16.         return modelService.getPage(queryVO);
17.     }
18. }   

复制代码

service:

1.     @Override
2.     public ResultDTO getPage(ModelQueryVO queryVO) throws Exception {
3.         int offset = (queryVO.getCurrentPage() - 1) * queryVO.getPageSize() + 0;
4.         List<Model> list = repositoryService.createModelQuery().listPage(offset
5.                 , queryVO.getPageSize());
6.         int total = (int) repositoryService.createModelQuery().count();
7.         Page<Model> page = new Page<>();
8.         page.setRecords(list);
9.         page.setTotal(total);
10.         return ResultDTO.success(page);
11.     }

复制代码

读取模型数据

controller：

1. @RequestMapping("/api/workflow/auth/activiti")
2. @RestController
3. @Slf4j
4. public class ModelController extends BaseController {
5.     @Autowired
6.     private RepositoryService repositoryService;
7.     @Autowired
8.     private ObjectMapper objectMapper;
9.     /**
10.      * 获取用于编辑的模型JSON数据
11.      * @param modelId 模型ID
12.      * @return
13.      */
14.     @GetMapping(value = "/model/json")
15.     public ObjectNode getEditorJson(@RequestParam("modelId") String modelId) {
16.         ObjectNode modelNode = null;
17.         Model model = repositoryService.getModel(modelId);
18.         if (model != null) {
19.             try {
20.                 if (StringUtils.isNotEmpty(model.getMetaInfo())) {
21.                     modelNode = (ObjectNode) objectMapper.readTree(model.getMetaInfo());
22.                 } else {
23.                     modelNode = objectMapper.createObjectNode();
24.                     modelNode.put(MODEL_NAME, model.getName());
25.                 }
26.                 modelNode.put(MODEL_ID, model.getId());
27.                 ObjectNode editorJsonNode = (ObjectNode) objectMapper.readTree(
28.                         new String(repositoryService.getModelEditorSource(model.getId()), "utf-8"));
29.                 modelNode.put("model", editorJsonNode);
31.             } catch (Exception e) {
32.                 log.error("Error creating model JSON", e);
33.                 throw new FlowableException("Error creating model JSON", e);
34.             }
35.         }
36.         return modelNode;
37.     }
38. }   

复制代码

增加新模型

controller：

1. @RequestMapping("/api/workflow/auth/activiti")
2. @RestController
3. @Slf4j
4. public class ModelController extends BaseController {
5.     @Resource
6.     private FormValidator formValidator;
7.     @Autowired
8.     private MyModelService modelService;
9.    
10.     @PostMapping("/model/add")
11.     @ApiOperation("保存数据")
12.     public ResultDTO save(@Valid @RequestBody ModelDataVO dataVO, BindingResult bindingResult) throws Exception {
13.         if (bindingResult.hasErrors()) {
14.             return formValidator.generateMessage(bindingResult);
15.         }
16.         BaseUser baseUser = UserTool.getBaseUser();
17.         return modelService.addNewModel(dataVO, baseUser);
18.     }
19. }

复制代码

service：

1.     @Override
2.     public ResultDTO addNewModel(ModelDataVO dataVO, BaseUser baseUser) throws Exception {
3.         //初始化一个空模型
4.         Model model = repositoryService.newModel();
5.         //设置一些默认信息
6.         String name = dataVO.getName();
7.         String description = dataVO.getDescription();
8.         int revision = 1;
9.         String key = dataVO.getKey();
11.         ObjectNode modelNode = objectMapper.createObjectNode();
12.         modelNode.put(MODEL_NAME, name);
13.         modelNode.put(MODEL_DESCRIPTION, description);
14.         modelNode.put(ModelDataJsonConstants.MODEL_REVISION, revision);
16.         model.setName(name);
17.         model.setKey(key);
18.         model.setMetaInfo(modelNode.toString());
20.         repositoryService.saveModel(model);
21.         String id = model.getId();
23.         //完善ModelEditorSource
24.         ObjectNode editorNode = objectMapper.createObjectNode();
25.         editorNode.put("id", "canvas");
26.         editorNode.put("resourceId", "canvas");
27.         ObjectNode stencilSetNode = objectMapper.createObjectNode();
28.         stencilSetNode.put("namespace",
29.                 "http://b3mn.org/stencilset/bpmn2.0#");
30.         editorNode.put("stencilset", stencilSetNode);
31.         repositoryService.addModelEditorSource(id, editorNode.toString().getBytes("utf-8"));
32.         return ResultDTO.success(id);
33.     }

复制代码

保存模型数据

1.     /**
2.      * 保存模型数据
3.      * @param modelId
4.      * @param name
5.      * @param description
6.      * @param json_xml
7.      * @param svg_xml
8.      */
9.     @RequestMapping(value = "/model/save", method = RequestMethod.PUT)
10.     @ResponseStatus(value = HttpStatus.OK)
11.     public void saveModel(@RequestParam("modelId") String modelId
12.             , String name, String description
13.             , String json_xml, String svg_xml) {
14.         try {
15.             Model model = repositoryService.getModel(modelId);
16.             ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo());
17.             modelJson.put(MODEL_NAME, name);
18.             modelJson.put(MODEL_DESCRIPTION, description);
19.             model.setMetaInfo(modelJson.toString());
20.             model.setName(name);
21.             repositoryService.saveModel(model);
22.             repositoryService.addModelEditorSource(model.getId(), json_xml.getBytes("utf-8"));
23.             InputStream svgStream = new ByteArrayInputStream(svg_xml.getBytes("utf-8"));
24.             TranscoderInput input = new TranscoderInput(svgStream);
25.             PNGTranscoder transcoder = new PNGTranscoder();
26.             // Setup output
27.             ByteArrayOutputStream outStream = new ByteArrayOutputStream();
28.             TranscoderOutput output = new TranscoderOutput(outStream);
29.             // Do the transformation
30.             transcoder.transcode(input, output);
31.             final byte[] result = outStream.toByteArray();
32.             repositoryService.addModelEditorSourceExtra(model.getId(), result);
33.             outStream.close();
34.         } catch (Exception e) {
35.             log.error("Error saving model", e);
36.             throw new FlowableException("Error saving model", e);
37.         }
38.     }

复制代码

删除模型

controller：

1. @RequestMapping("/api/workflow/auth/activiti")
2. @RestController
3. @Slf4j
4. public class ModelController extends BaseController {
5.     @Resource
6.     private FormValidator formValidator;
7.     @Autowired
8.     private MyModelService modelService;
9.    
10.     @PostMapping("/model/del")
11.     @ApiOperation("删除数据")
12.     public ResultDTO del(@Valid @RequestBody GuidContainerVO guidContainerVO, BindingResult bindingResult) throws Exception {
13.         if (bindingResult.hasErrors()) {
14.             return formValidator.generateMessage(bindingResult);
15.         }
16.         return modelService.delete(guidContainerVO.getGuid());
17.     }   
18. }

复制代码

service：

1.     @Override
2.     public ResultDTO delete(String guid) throws Exception {
3.         repositoryService.deleteModel(guid);
4.         return ResultDTO.success();
5.     }

复制代码

发布（部署）模型

1. @RequestMapping("/api/workflow/auth/activiti")
2. @RestController
3. @Slf4j
4. public class ModelController extends BaseController {
5.     @Resource
6.     private FormValidator formValidator;
7.     @Autowired
8.     private MyModelService modelService;
9.    
10.     @PostMapping("/model/deploy")
11.     public ResultDTO deploy(@Valid @RequestBody GuidContainerVO guidContainerVO, BindingResult bindingResult) throws Exception {
12.         if (bindingResult.hasErrors()) {
13.             return formValidator.generateMessage(bindingResult);
14.         }
15.         return modelService.deploy(guidContainerVO.getGuid());
16.     }
17. }   

复制代码

service：

1.     @Override
2.     public ResultDTO deploy(String guid) throws Exception {
3.         /**获取模型 **/
4.         Model modelData = repositoryService.getModel(guid);
5.         byte[] bytes = repositoryService.getModelEditorSource(modelData.getId());
6.         if (bytes == null) {
7.             return ResultDTO.failureCustom("模型数据为空，请先设计流程并成功保存，再进行发布。");
8.         }
9.         JsonNode modelNode = new ObjectMapper().readTree(bytes);
10.         BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);
11.         if (model.getProcesses().size() == 0) {
12.             return ResultDTO.failureCustom("数据模型不符要求，请至少设计一条主线流程。");
13.         }
14.         /** 设置名称 **/
15.         if(StringUtils.isNotBlank(modelData.getCategory())) {
16.             model.setTargetNamespace(modelData.getCategory());
17.         }
18.         byte[] bpmnBytes = new BpmnXMLConverter().convertToXML(model);
20.         /** 发布流程 .bpmn20.xml必需加 **/
21.         String processName = modelData.getName() + ".bpmn20.xml";
22.         Deployment deployment = repositoryService.createDeployment()
23.                 .name(modelData.getName())
24.                 .category(modelData.getCategory())
25.                 .key(modelData.getKey())
26.                 .addString(processName, new String(bpmnBytes, "UTF-8"))
27.                 .deploy();
28.         modelData.setDeploymentId(deployment.getId());
29.         repositoryService.saveModel(modelData);
30.         return ResultDTO.success();
31.     }

复制代码

总结：经过集成改造，boot-admin与flowable editor-app模型设计器实现紧密整合，不但实现了BPMN流程编辑、修改、发布等功能，还实现前端 携带jwt按权限访问后端资源。
boot-admin 集成 flowable editor-app 运行效果如下图所示：

项目源码仓库github
项目源码仓库gitee

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！