1. Python技术站首页
  2. 其他
  3. Java

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

• Java

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数据

   /**
     * 获取汉化资源
     * @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 {
    @Resource
    private FormValidator formValidator;
    @Autowired
    private 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:

    @Override
    public 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 {
    @Autowired
    private RepositoryService repositoryService;
    @Autowired
    private 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 {
    @Resource
    private FormValidator formValidator;
    @Autowired
    private 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：

    @Override
    public 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();

        //完善ModelEditorSource
        ObjectNode 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 output
            ByteArrayOutputStream outStream = new ByteArrayOutputStream();
            TranscoderOutput output = new TranscoderOutput(outStream);
            // Do the transformation
            transcoder.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 {
    @Resource
    private FormValidator formValidator;
    @Autowired
    private 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：

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

发布（部署）模型

@RequestMapping("/api/workflow/auth/activiti")
@RestController
@Slf4j
public class ModelController extends BaseController {
    @Resource
    private FormValidator formValidator;
    @Autowired
    private 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：

    @Override
    public 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

原文链接：https://www.cnblogs.com/soft1314/p/17341871.html

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：boot-admin整合flowable官方editor-app源码进行BPMN2-0建模（续） - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年4月22日
下一篇 2023年4月22日

相关文章

  • htm调用JS代码

    当HTML页面引入JavaScript（JS）文件并调用JS代码时，可以通过以下步骤实现： 在HTML文件中使用标签引入JS文件。在HTML中使用标签时，需要指定src属性来引入JS文件。 例如，在如下HTML页面中，通过引入“script.js”文件实现JS代码的调用： <!DOCTYPE html> <html lang="e…

    Java 2023年6月15日
    00

  • java实现树形菜单对象

    实现树形菜单对象可以采用Java语言和基于树形结构的数据结构，下面是具体的实现攻略： 步骤一：创建树形结构的数据类型 树形菜单对象可以用树形结构数据类型表示，包括各个节点的名称、节点值、父节点、子节点等信息，这个数据结构可以通过类的形式实现： public class TreeNode { private String name; private Objec…

    Java 2023年5月26日
    00

  • java Date获取本月的开始时间与结束时间

    获取本月开始时间和结束时间可以通过Java中的Date类和Calendar类来实现。 获取本月开始时间 // 获取当前日期 Date date = new Date(); // 创建Calendar实例并设置日期为当前日期 Calendar calendar = Calendar.getInstance(); calendar.setTime(date); …

    Java 2023年5月20日
    00

  • Java中过滤器 (Filter) 和 拦截器 (Interceptor)的使用

    Java中的过滤器(Filter)和拦截器(Interceptor)是Web开发中常用的两个概念，它们能够有效地对请求进行处理和控制。在本文中，我们将针对Java中过滤器和拦截器的使用进行详细讲解，包括二者的区别、使用方法、作用范围等内容，并举例说明。 一、过滤器(Filter)和拦截器(Interceptor)的区别 过滤器(Filter)和拦截器(Int…

    Java 2023年5月26日
    00

  • Spring Security实现分布式系统授权方案详解

    Spring Security实现分布式系统授权方案详解 简介 Spring Security是一个基于Spring的安全框架，提供了一套全面的安全服务，支持Web访问控制、安全认证、权限管理、API授权等。在分布式系统中，如何对服务进行安全认证和权限控制变得十分重要。本文将介绍如何使用Spring Security实现分布式系统的授权方案。 实现步骤 1.…

    Java 2023年6月3日
    00

  • Java如何调用Matlab程序

    下面是关于Java如何调用Matlab程序的完整攻略和示例说明： 一、Matlab引擎API Matlab引擎API是Matlab提供的一种机制，使得Java程序能够通过API与Matlab交互。下面是Java调用Matlab程序的基本步骤： 首先需要安装Matlab引擎API，它可以在Matlab中的“Add-Ons”里找到，需要选择需要使用版本对应的AP…

    Java 2023年5月26日
    00

  • maven导入本地仓库jar包,报:Could not find artifact的解决

    当我们在使用Maven构建项目时，有时候会遇到Maven导入本地仓库jar包时出现“Could not find artifact”的错误，这可能是因为Maven没有将该jar包添加到本地仓库中。 以下是解决该问题的完整攻略： 1.通过命令行将jar包安装到本地仓库 首先，我们需要打开命令行工具，进入到jar包所在的文件夹。然后，使用以下命令将该jar包安装…

    Java 2023年5月20日
    00

  • Java Web使用简单的批处理操作(记事本+Tomcat)

    Java Web使用简单的批处理操作(记事本+Tomcat) 在Java Web开发中，经常需要进行简单的批处理操作，比如启动/停止Tomcat服务等。在Windows环境下，可以用记事本来编写批处理脚本，以进行一些简单的操作。 编写批处理脚本 打开记事本，输入以下代码： echo off :: 打印欢迎信息 echo 欢迎使用批处理脚本 :: 启动Tomc…

    Java 2023年6月2日
    00
合作推广
合作推广
分享本页
返回顶部