devbox
人工智能uu
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot集成Flowable

作者：人工智能uu | 2024-08-15 08:30:47

赞

踩

SpringBoot集成Flowable

一、项目结构

 

二、maven配置

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.9.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.mk</groupId>
  12.     <artifactId>flowable</artifactId>
  13.     <version>1.0-SNAPSHOT</version>
  14.     <name>flowable</name>
  15.     <description>flowable</description>
  16.  
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.     </properties>
  20.  
  21.     <dependencies>
  22.         <dependency>
  23.             <groupId>com.alibaba</groupId>
  24.             <artifactId>druid-spring-boot-starter</artifactId>
  25.             <version>1.1.20</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>mysql</groupId>
  29.             <artifactId>mysql-connector-java</artifactId>
  30.             <scope>runtime</scope>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>org.mybatis.spring.boot</groupId>
  34.             <artifactId>mybatis-spring-boot-starter</artifactId>
  35.             <version>2.1.0</version>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.flowable</groupId>
  39.             <artifactId>flowable-spring-boot-starter</artifactId>
  40.             <version>6.5.0</version>
  41.         </dependency>
  42.  
  43.         <dependency>
  44.             <groupId>org.springframework.boot</groupId>
  45.             <artifactId>spring-boot-devtools</artifactId>
  46.             <scope>runtime</scope>
  47.             <optional>true</optional>
  48.         </dependency>
  49.         <dependency>
  50.             <groupId>org.springframework.boot</groupId>
  51.             <artifactId>spring-boot-starter-test</artifactId>
  52.             <scope>test</scope>
  53.         </dependency>
  54.  
  55.         <dependency>
  56.             <groupId>com.h2database</groupId>
  57.             <artifactId>h2</artifactId>
  58.             <version>1.3.168</version>
  59.             <scope>test</scope>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>org.projectlombok</groupId>
  63.             <artifactId>lombok</artifactId>
  64.         </dependency>
  65.     </dependencies>
  66.  
  67.     <build>
  68.         <plugins>
  69.             <plugin>
  70.                 <groupId>org.springframework.boot</groupId>
  71.                 <artifactId>spring-boot-maven-plugin</artifactId>
  72.             </plugin>
  73.         </plugins>
  74.     </build>
  75.  
  76. </project>

application.yml 

  1. spring:
  2.   application:
  3.     name: flowable
  4.   profiles:
  5.     active: dev
  6.   jackson:
  7.     time-zone: GMT+8
  8.     date-format: yyyy-MM-dd HH:mm:ss
  9.     default-property-inclusion: ALWAYS
  10.   datasource:
  11.     type: com.alibaba.druid.pool.DruidDataSource
  12.     driver-class-name: com.mysql.jdbc.Driver
  13.     url: "jdbc:mysql://localhost:3306/flowable?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&useSSL=false"
  14.     username: "root"
  15.     password: "admin"
  16.     druid:
  17.       initial-size: 10
  18.       max-active: 100
  19.       min-idle: 10
  20.       max-wait: 60000
  21.       pool-prepared-statements: true
  22.       max-pool-prepared-statement-per-connection-size: 20
  23.       time-between-eviction-runs-millis: 60000
  24.       min-evictable-idle-time-millis: 300000
  25.       validation-query: SELECT 1 FROM DUAL
  26.       test-while-idle: true
  27.       test-on-borrow: false
  28.       test-on-return: false
  29.       filter:
  30.         stat:
  31.           log-slow-sql: true
  32.           slow-sql-millis: 1000
  33.           merge-sql: true
  34.           enabled: true
  35.         wall:
  36.           config:
  37.             multi-statement-allow: true
  38.       stat-view-servlet:
  39.         enabled: true
  40.   servlet:
  41.     multipart:
  42.       max-file-size: 10MB
  43.       max-request-size: 10MB
  44.   mvc:
  45.     date-format: yyyy-MM-dd HH:mm:ss
  46.  
  47. server:
  48.   port: 8008
  49.  
  50. mybatis:
  51.   mapper-locations: classpath*:mapper/*.xml
  52.   type-aliases-package: com.mk.flowable.entity
  53.   configuration:
  54.         map-underscore-to-camel-case: true
  55.   configuration-properties:
  56.     prefix:
  57.     blobType: BLOB
  58.     boolValue: TRUE

 

 

三、常用API

  1. package com.mk.flowable.service;
  2.  
  3. import org.apache.commons.lang3.StringUtils;
  4. import org.flowable.bpmn.model.BpmnModel;
  5. import org.flowable.bpmn.model.EndEvent;
  6. import org.flowable.bpmn.model.FlowElement;
  7. import org.flowable.common.engine.impl.identity.Authentication;
  8. import org.flowable.engine.HistoryService;
  9. import org.flowable.engine.RepositoryService;
  10. import org.flowable.engine.RuntimeService;
  11. import org.flowable.engine.TaskService;
  12. import org.flowable.engine.runtime.ProcessInstance;
  13. import org.flowable.identitylink.api.IdentityLinkInfo;
  14. import org.flowable.task.api.Task;
  15. import org.springframework.stereotype.Service;
  16.  
  17. import javax.annotation.Resource;
  18. import java.util.*;
  19. import java.util.stream.Collectors;
  20.  
  21. @Service
  22. public class FlowableService {
  23.  
  24.     @Resource
  25.     private TaskService taskService;
  26.  
  27.     @Resource
  28.     private RepositoryService repositoryService;
  29.  
  30.     @Resource
  31.     private RuntimeService runtimeService;
  32.  
  33.     @Resource
  34.     private HistoryService historyService;
  35.  
  36.  
  37.     public ProcessInstance start(String processDefinitionKey, String userId) {
  38.  
  39.         Map<String, Object> variables = new HashMap<>();
  40.         variables.put("userName", userId);
  41.  
  42.         variables.put("_ACTIVITI_SKIP_EXPRESSION_ENABLED", true);//允许执行跳过表达式
  43.         Authentication.setAuthenticatedUserId(userId);
  44.         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, variables);
  45.         Authentication.setAuthenticatedUserId(null);
  46.  
  47.         return processInstance;
  48.     }
  49.  
  50.     public ProcessInstance get(String processInstanceId){
  51.  
  52.         ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
  53.         return processInstance;
  54.     }
  55.  
  56.     public List<Task> listTask(String processInstanceId) {
  57.         List<org.flowable.task.api.Task> tasks = taskService.createTaskQuery().processInstanceId(processInstanceId).list();
  58.         return tasks;
  59.     }
  60.  
  61.     public Task getTask(String taskId) {
  62.         Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  63.         return task;
  64.     }
  65.  
  66.     public void complete(String taskId, Map<String, Object> variables) {
  67.  
  68.         taskService.complete(taskId, variables);
  69.     }
  70.  
  71.     public void move(Task task, String activityName) {
  72.  
  73.         runtimeService.createChangeActivityStateBuilder()
  74.                 .processInstanceId(task.getProcessInstanceId())
  75.                 .moveActivityIdsToSingleActivityId(
  76.                         Arrays.asList(task.getTaskDefinitionKey()),
  77.                         activityName)
  78.                 .changeState();
  79.     }
  80.  
  81.  
  82.     public List<EndEvent> getEnd(String processDefinitionId) {
  83.  
  84.         BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
  85.         List<EndEvent> endEvents = bpmnModel.getProcesses().stream().flatMap(v->v.findFlowElementsOfType(EndEvent.class).stream()).collect(Collectors.toList());
  86.         return endEvents;
  87.     }
  88.  
  89.     public FlowElement getFlowElement(Task task) {
  90.  
  91.         BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId());
  92.         FlowElement flowElement = bpmnModel.getFlowElement(task.getTaskDefinitionId());
  93.         return flowElement;
  94.     }
  95.  
  96.  
  97.     public Map<String, Object> getVariables(String taskId) {
  98.  
  99.         Map<String, Object> variables = taskService.getVariables(taskId);
  100.         return variables;
  101.     }
  102.  
  103.     public  List<String> getCandidateUsers(String taskId) {
  104.  
  105.         Task task = taskService.createTaskQuery().taskId(taskId).includeIdentityLinks().singleResult();
  106.         List<? extends IdentityLinkInfo> linkInfos = task.getIdentityLinks();
  107.         List<String> candidateUsers = linkInfos.stream().filter(v -> "candidate".equals(v.getType())).map(IdentityLinkInfo::getUserId)
  108.                 .filter(StringUtils::isNotBlank).collect(Collectors.toList());
  109.         return candidateUsers;
  110.     }
  111.  
  112.     public List<String> getCandidatGroups(String taskId) {
  113.  
  114.         Task task = taskService.createTaskQuery().taskId(taskId).includeIdentityLinks().singleResult();
  115.         List<? extends IdentityLinkInfo> linkInfos = task.getIdentityLinks();
  116.         List<String> candidateUsers = linkInfos.stream().filter(v -> "candidate".equals(v.getType())).map(IdentityLinkInfo::getGroupId)
  117.                 .filter(StringUtils::isNotBlank).collect(Collectors.toList());
  118.         return candidateUsers;
  119.     }
  120.     
  121.     
  122. }

 

四、事件和委托

结束事件监听

  1. package com.mk.flowable.listener;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.flowable.engine.delegate.DelegateExecution;
  5. import org.flowable.engine.delegate.ExecutionListener;
  6.  
  7.  
  8.  
  9. @Slf4j
  10. public class EndListener implements ExecutionListener {
  11.     @Override
  12.     public void notify(DelegateExecution execution) {
  13.  
  14.     }
  15. }

任务监听

  1. package com.mk.flowable.listener;
  2.  
  3. import org.flowable.engine.delegate.TaskListener;
  4. import org.flowable.task.service.delegate.DelegateTask;
  5.  
  6. public class FirstTaskListener implements TaskListener {
  7.  
  8.     @Override
  9.     public void notify(DelegateTask delegateTask) {
  10.  
  11.  
  12.  
  13.     }
  14.  
  15. }

自动节点委托

  1. package com.mk.flowable.service;
  2.  
  3. import org.flowable.engine.delegate.DelegateExecution;
  4. import org.flowable.engine.delegate.JavaDelegate;
  5.  
  6.  
  7. public class AutoExeService implements JavaDelegate {
  8.  
  9.     public void execute(DelegateExecution execution) {
  10.  
  11.     }
  12. }

 

testFlowable.bpmn

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
  3.   <process id="testFlowable" name="testFlowable" isExecutable="true">
  4.     <startEvent id="startevent1" name="Start"></startEvent>
  5.     <endEvent id="endevent1" name="End">
  6.       <extensionElements>
  7.         <activiti:executionListener event="end" class="com.mk.flowable.listener.EndListener"></activiti:executionListener>
  8.       </extensionElements>
  9.     </endEvent>
  10.     <serviceTask id="servicetask1" name="Service Task1" activiti:class="com.mk.flowable.service.AutoExeService">
  11.       <documentation>{"data":"es"}</documentation>
  12.     </serviceTask>
  13.     <serviceTask id="servicetask2" name="Service Task2" activiti:class="com.mk.flowable.service.AutoExeService"></serviceTask>
  14.     <serviceTask id="servicetask3" name="Service Task3" activiti:class="com.mk.flowable.service.AutoExeService"></serviceTask>
  15.     <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask0"></sequenceFlow>
  16.     <sequenceFlow id="flow2" sourceRef="servicetask1" targetRef="servicetask2"></sequenceFlow>
  17.     <sequenceFlow id="flow3" sourceRef="servicetask2" targetRef="servicetask3"></sequenceFlow>
  18.     <sequenceFlow id="flow4" sourceRef="servicetask3" targetRef="endevent1"></sequenceFlow>
  19.     <userTask id="usertask0" name="User Task0" activiti:assignee="${userName}"></userTask>
  20.     <sequenceFlow id="flow5" sourceRef="usertask0" targetRef="servicetask1"></sequenceFlow>
  21.   </process>
  22.   <bpmndi:BPMNDiagram id="BPMNDiagram_testFlowable">
  23.     <bpmndi:BPMNPlane bpmnElement="testFlowable" id="BPMNPlane_testFlowable">
  24.       <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
  25.         <omgdc:Bounds height="35.0" width="35.0" x="30.0" y="180.0"></omgdc:Bounds>
  26.       </bpmndi:BPMNShape>
  27.       <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
  28.         <omgdc:Bounds height="35.0" width="35.0" x="730.0" y="180.0"></omgdc:Bounds>
  29.       </bpmndi:BPMNShape>
  30.       <bpmndi:BPMNShape bpmnElement="servicetask1" id="BPMNShape_servicetask1">
  31.         <omgdc:Bounds height="55.0" width="105.0" x="280.0" y="170.0"></omgdc:Bounds>
  32.       </bpmndi:BPMNShape>
  33.       <bpmndi:BPMNShape bpmnElement="servicetask2" id="BPMNShape_servicetask2">
  34.         <omgdc:Bounds height="55.0" width="105.0" x="430.0" y="170.0"></omgdc:Bounds>
  35.       </bpmndi:BPMNShape>
  36.       <bpmndi:BPMNShape bpmnElement="servicetask3" id="BPMNShape_servicetask3">
  37.         <omgdc:Bounds height="55.0" width="105.0" x="580.0" y="170.0"></omgdc:Bounds>
  38.       </bpmndi:BPMNShape>
  39.       <bpmndi:BPMNShape bpmnElement="usertask0" id="BPMNShape_usertask0">
  40.         <omgdc:Bounds height="55.0" width="105.0" x="120.0" y="170.0"></omgdc:Bounds>
  41.       </bpmndi:BPMNShape>
  42.       <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
  43.         <omgdi:waypoint x="65.0" y="197.0"></omgdi:waypoint>
  44.         <omgdi:waypoint x="120.0" y="197.0"></omgdi:waypoint>
  45.       </bpmndi:BPMNEdge>
  46.       <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
  47.         <omgdi:waypoint x="385.0" y="197.0"></omgdi:waypoint>
  48.         <omgdi:waypoint x="430.0" y="197.0"></omgdi:waypoint>
  49.       </bpmndi:BPMNEdge>
  50.       <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
  51.         <omgdi:waypoint x="535.0" y="197.0"></omgdi:waypoint>
  52.         <omgdi:waypoint x="580.0" y="197.0"></omgdi:waypoint>
  53.       </bpmndi:BPMNEdge>
  54.       <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
  55.         <omgdi:waypoint x="685.0" y="197.0"></omgdi:waypoint>
  56.         <omgdi:waypoint x="730.0" y="197.0"></omgdi:waypoint>
  57.       </bpmndi:BPMNEdge>
  58.       <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
  59.         <omgdi:waypoint x="225.0" y="197.0"></omgdi:waypoint>
  60.         <omgdi:waypoint x="280.0" y="197.0"></omgdi:waypoint>
  61.       </bpmndi:BPMNEdge>
  62.     </bpmndi:BPMNPlane>
  63.   </bpmndi:BPMNDiagram>
  64. </definitions>

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/人工智能uu/article/detail/982814
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。