书接上回

项目源码仓库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数据

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

资源包stencilset.json需放在resources文夹下，这里提供下载：点击下载汉化包

分页获取模型列表

controller：

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {@Resourceprivate FormValidator formValidator;@Autowiredprivate MyModelService modelService;@PostMapping("/model/page")@ApiOperation("分页获取项目数据表列表")public ResultDTO getTablePage(@Valid @RequestBody ModelQueryVO queryVO, BindingResult bindingResult) throws Exception {if (bindingResult.hasErrors()) {return formValidator.generateMessage(bindingResult);}return modelService.getPage(queryVO);}
}    

service:

    @Overridepublic ResultDTO getPage(ModelQueryVO queryVO) throws Exception {int offset = (queryVO.getCurrentPage() - 1) * queryVO.getPageSize() + 0;List<Model> list = repositoryService.createModelQuery().listPage(offset, queryVO.getPageSize());int total = (int) repositoryService.createModelQuery().count();Page<Model> page = new Page<>();page.setRecords(list);page.setTotal(total);return ResultDTO.success(page);}

读取模型数据

controller：

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {@Autowiredprivate RepositoryService repositoryService;@Autowiredprivate ObjectMapper objectMapper;/*** 获取用于编辑的模型JSON数据* @param modelId 模型ID* @return*/@GetMapping(value = "/model/json")public ObjectNode getEditorJson(@RequestParam("modelId") String modelId) {ObjectNode modelNode = null;Model model = repositoryService.getModel(modelId);if (model != null) {try {if (StringUtils.isNotEmpty(model.getMetaInfo())) {modelNode = (ObjectNode) objectMapper.readTree(model.getMetaInfo());} else {modelNode = objectMapper.createObjectNode();modelNode.put(MODEL_NAME, model.getName());}modelNode.put(MODEL_ID, model.getId());ObjectNode editorJsonNode = (ObjectNode) objectMapper.readTree(new String(repositoryService.getModelEditorSource(model.getId()), "utf-8"));modelNode.put("model", editorJsonNode);} catch (Exception e) {log.error("Error creating model JSON", e);throw new FlowableException("Error creating model JSON", e);}}return modelNode;}
}    

增加新模型

controller：

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {@Resourceprivate FormValidator formValidator;@Autowiredprivate MyModelService modelService;@PostMapping("/model/add")@ApiOperation("保存数据")public ResultDTO save(@Valid @RequestBody ModelDataVO dataVO, BindingResult bindingResult) throws Exception {if (bindingResult.hasErrors()) {return formValidator.generateMessage(bindingResult);}BaseUser baseUser = UserTool.getBaseUser();return modelService.addNewModel(dataVO, baseUser);}
} 

service：

    @Overridepublic ResultDTO addNewModel(ModelDataVO dataVO, BaseUser baseUser) throws Exception {//初始化一个空模型Model model = repositoryService.newModel();//设置一些默认信息String name = dataVO.getName();String description = dataVO.getDescription();int revision = 1;String key = dataVO.getKey();ObjectNode modelNode = objectMapper.createObjectNode();modelNode.put(MODEL_NAME, name);modelNode.put(MODEL_DESCRIPTION, description);modelNode.put(ModelDataJsonConstants.MODEL_REVISION, revision);model.setName(name);model.setKey(key);model.setMetaInfo(modelNode.toString());repositoryService.saveModel(model);String id = model.getId();//完善ModelEditorSourceObjectNode editorNode = objectMapper.createObjectNode();editorNode.put("id", "canvas");editorNode.put("resourceId", "canvas");ObjectNode stencilSetNode = objectMapper.createObjectNode();stencilSetNode.put("namespace","http://b3mn.org/stencilset/bpmn2.0#");editorNode.put("stencilset", stencilSetNode);repositoryService.addModelEditorSource(id, editorNode.toString().getBytes("utf-8"));return ResultDTO.success(id);}

保存模型数据

    /*** 保存模型数据* @param modelId* @param name* @param description* @param json_xml* @param svg_xml*/@RequestMapping(value = "/model/save", method = RequestMethod.PUT)@ResponseStatus(value = HttpStatus.OK)public void saveModel(@RequestParam("modelId") String modelId, String name, String description, String json_xml, String svg_xml) {try {Model model = repositoryService.getModel(modelId);ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo());modelJson.put(MODEL_NAME, name);modelJson.put(MODEL_DESCRIPTION, description);model.setMetaInfo(modelJson.toString());model.setName(name);repositoryService.saveModel(model);repositoryService.addModelEditorSource(model.getId(), json_xml.getBytes("utf-8"));InputStream svgStream = new ByteArrayInputStream(svg_xml.getBytes("utf-8"));TranscoderInput input = new TranscoderInput(svgStream);PNGTranscoder transcoder = new PNGTranscoder();// Setup outputByteArrayOutputStream outStream = new ByteArrayOutputStream();TranscoderOutput output = new TranscoderOutput(outStream);// Do the transformationtranscoder.transcode(input, output);final byte[] result = outStream.toByteArray();repositoryService.addModelEditorSourceExtra(model.getId(), result);outStream.close();} catch (Exception e) {log.error("Error saving model", e);throw new FlowableException("Error saving model", e);}}

删除模型

controller：

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {@Resourceprivate FormValidator formValidator;@Autowiredprivate MyModelService modelService;@PostMapping("/model/del")@ApiOperation("删除数据")public ResultDTO del(@Valid @RequestBody GuidContainerVO guidContainerVO, BindingResult bindingResult) throws Exception {if (bindingResult.hasErrors()) {return formValidator.generateMessage(bindingResult);}return modelService.delete(guidContainerVO.getGuid());}    
} 

service：

    @Overridepublic ResultDTO delete(String guid) throws Exception {repositoryService.deleteModel(guid);return ResultDTO.success();}

发布（部署）模型

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {@Resourceprivate FormValidator formValidator;@Autowiredprivate MyModelService modelService;@PostMapping("/model/deploy")public ResultDTO deploy(@Valid @RequestBody GuidContainerVO guidContainerVO, BindingResult bindingResult) throws Exception {if (bindingResult.hasErrors()) {return formValidator.generateMessage(bindingResult);}return modelService.deploy(guidContainerVO.getGuid());}
}    

service：

    @Overridepublic ResultDTO deploy(String guid) throws Exception {/**获取模型 **/Model modelData = repositoryService.getModel(guid);byte[] bytes = repositoryService.getModelEditorSource(modelData.getId());if (bytes == null) {return ResultDTO.failureCustom("模型数据为空，请先设计流程并成功保存，再进行发布。");}JsonNode modelNode = new ObjectMapper().readTree(bytes);BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);if (model.getProcesses().size() == 0) {return ResultDTO.failureCustom("数据模型不符要求，请至少设计一条主线流程。");}/** 设置名称 **/if(StringUtils.isNotBlank(modelData.getCategory())) {model.setTargetNamespace(modelData.getCategory());}byte[] bpmnBytes = new BpmnXMLConverter().convertToXML(model);/** 发布流程 .bpmn20.xml必需加 **/String processName = modelData.getName() + ".bpmn20.xml";Deployment deployment = repositoryService.createDeployment().name(modelData.getName()).category(modelData.getCategory()).key(modelData.getKey()).addString(processName, new String(bpmnBytes, "UTF-8")).deploy();modelData.setDeploymentId(deployment.getId());repositoryService.saveModel(modelData);return ResultDTO.success();}

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

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

老人咖美文