SpringBoot Activiti6

1、Activiti6简介

对于流程审批类型的项目，用Activiti解决再合适不过了。
Activiti是一种轻量级，可嵌入的BPM引擎，而且还设计适用于可扩展的云架构。可以和SpringBoot完美结合。是一个工作流处理框架。
Activiti6的7 个服务接口和28张表：

服务接口 说明
RepositoryService 仓库服务，用于管理仓库，比如部署或删除流程定义、读取流程资源等。
IdentifyService 身份服务，管理用户、组以及它们之间的关系。
RuntimeService 运行时服务，管理所有正在运行的流程实例、任务等对象。
TaskService 任务服务，管理任务。
FormService 表单服务，管理和流程、任务相关的表单。
HistroyService 历史服务，管理历史数据。
ManagementService 引擎管理服务，比如管理引擎的配置、数据库和作业等核心对象
表 说明
ACTRE* RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 （图片，规则，等等）
ACTRU* RU’表示runtime。这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据，在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。
ACTID* ‘ID’表示identity。 这些表包含身份信息，比如用户，组等等。
ACTHI* ‘HI’表示history。 这些表包含历史数据，比如历史流程实例， 变量，任务等等。
ACTGE* 通用数据， 用于不同场景下，如存放资源文件。

2、引入依赖

  1. <!--fastjson-->
  2. <dependency>
  3.   <artifactId>fastjson</artifactId>
  4.   <groupId>com.alibaba</groupId>
  5.   <version>1.2.67</version>
  6. </dependency>
  8. <dependency>
  9.   <groupId>org.apache.commons</groupId>
  10.   <artifactId>commons-lang3</artifactId>
  11. </dependency>
  13. <!-- https://mvnrepository.com/artifact/io.springfox/springfox-swagger2 -->
  14. <dependency>
  15.   <groupId>io.springfox</groupId>
  16.   <artifactId>springfox-swagger2</artifactId>
  17.   <version>2.9.2</version>
  18. </dependency>
  20. <!-- https://mvnrepository.com/artifact/io.springfox/springfox-swagger-ui -->
  21. <dependency>
  22.   <groupId>io.springfox</groupId>
  23.   <artifactId>springfox-swagger-ui</artifactId>
  24.   <version>2.9.2</version>
  25. </dependency>
  27. <!-- https://mvnrepository.com/artifact/com.github.xiaoymin/swagger-bootstrap-ui -->
  28. <dependency>
  29.   <groupId>com.github.xiaoymin</groupId>
  30.   <artifactId>swagger-bootstrap-ui</artifactId>
  31.   <version>1.8.5</version>
  32. </dependency>
  34. <dependency>
  35.   <groupId>org.activiti</groupId>
  36.   <artifactId>activiti-spring-boot-starter-basic</artifactId>
  37.   <version>6.0.0</version>
  38. </dependency>
  40. <dependency>
  41.   <groupId>com.alibaba</groupId>
  42.   <artifactId>druid-spring-boot-starter</artifactId>
  43.   <version>1.1.13</version>
  44. </dependency>
  46. <dependency>
  47.   <groupId>mysql</groupId>
  48.   <artifactId>mysql-connector-java</artifactId>
  49.   <version>8.0.19</version>
  50. </dependency>
  52. <dependency>
  53.   <groupId>org.springframework.boot</groupId>
  54.   <artifactId>spring-boot-starter-web</artifactId>
  55. </dependency>
  57. <dependency>
  58.   <groupId>javax.servlet</groupId>
  59.   <artifactId>servlet-api</artifactId>
  60.   <version>2.5</version>
  61. </dependency>

3、在SpringBoot配置文件配置数据源与Activiti

  1. mysql:
  2.   url: jdbc:mysql:///test?serverTimezone=UTC
  3.   username: root
  4.   password: 123456
  5.   driverClassName: com.mysql.cj.jdbc.Driver
  6. spring:
  7.   application:
  8.     name: ServiceActiviti
  9.   datasource:
  10.     type: com.alibaba.druid.pool.DruidDataSource
  11.     url: ${mysql.url}
  12.     driver-class-name: ${mysql.driverClassName}
  13.     username: ${mysql.username}
  14.     password: ${mysql.password}
  15.     druid: # #
  16.       url: ${mysql.url}
  17.       username: ${mysql.username}
  18.       password: ${mysql.password}
  19.       driver-class-name: ${mysql.driverClassName}
  20.       initial-size: 10
  21.       max-active: 200
  22.       min-idle: 10
  23.       max-wait: 60000
  24.       pool-prepared-statements: false
  25.       validation-query: SELECT 1 FROM DUAL
  26.       test-on-borrow: false
  27.       test-on-return: false
  28.       test-while-idle: true
  29.       time-between-eviction-runs-millis: 60000
  30.       min-evictable-idle-time-millis: 30000
  31.       max-pool-prepared-statement-per-connection-size: 20
  32.       aop-patterns: com.msyyt.crm.activity.*
  33.       filter: # 状态监控
  34.         stat:
  35.           enabled: true
  36.           db-type: mysql
  37.           log-slow-sql: true
  38.           slow-sql-millis: 2000
  39.       web-stat-filter: # 监控过滤器
  40.         enabled: true #是否启用 默认true
  41.         exclusions:
  42.           - '*.js'
  43.           - '*.gif'
  44.           - '*.jpg'
  45.           - '*.png'
  46.           - '*.css'
  47.           - '*.ico'
  48.           - /druid/*
  49.       stat-view-servlet: # druid 监控页面
  50.         enabled: true
  51.         url-pattern: /druid/*
  52.         reset-enable: false
  53.         allow:  # 白名单
  54.         deny:   # 黑名单
  55.         login-username: admin
  56.         login-password:  admin
  57. # 工作流
  58. activiti:
  59.   # 自动部署验证设置:
  60.   # true（默认）自动部署流程
  61.   # false 不自动部署，需要手动部署发布流程
  62.   check-process-definitions: true
  63.   # 可选值为: false,true,create-drop,drop-create
  64.   # 默认为true。为true表示activiti会对数据库中的表进行更新操作，如果不存在，则进行创建。
  65.   database-schema-update: true

4、配置启动类（排除互斥的安全依赖以及包扫描）

  1. package com.fcant.service_acti;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.context.annotation.ComponentScan;
  7. @SpringBootApplication(exclude={
  8.         org.activiti.spring.boot.SecurityAutoConfiguration.class
  9. })
  10. @ComponentScan("com.fcant")
  11. public class ServiceActiApplication {
  13.     public static void main(String[] args) {
  14.         SpringApplication.run(ServiceActiApplication.class, args);
  15.     }
  17. }

5、项目接口文档的配置

  1. package com.fcant.service_acti.config;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
  6. import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
  7. import springfox.documentation.builders.ApiInfoBuilder;
  8. import springfox.documentation.builders.PathSelectors;
  9. import springfox.documentation.builders.RequestHandlerSelectors;
  10. import springfox.documentation.service.ApiInfo;
  11. import springfox.documentation.service.Contact;
  12. import springfox.documentation.spi.DocumentationType;
  13. import springfox.documentation.spring.web.plugins.Docket;
  14. import springfox.documentation.swagger2.annotations.EnableSwagger2;
  16. /**
  17.  * SwaggerConfig
  18.  * <p>
  19.  * encoding:UTF-8
  20.  *
  21.  * @author Fcant 下午 23:41 2020/8/1/0001
  22.  */
  23. @Configuration
  24. @EnableSwagger2
  25. public class SwaggerConfig implements WebMvcConfigurer {
  27.     @Override
  28.     public void addResourceHandlers(ResourceHandlerRegistry registry) {
  29.         registry.addResourceHandler("swagger-ui.html")
  30.                 .addResourceLocations("classpath:/META-INF/resources/");
  31.         registry.addResourceHandler("/webjars/**")
  32.                 .addResourceLocations("classpath:/META-INF/resources/webjars/");
  33.     }
  35.     /**
  36.      * @author Fcant 13:44 2019/12/5
  37.      */
  38.     @Bean
  39.     public Docket petApi() {
  40.         return new Docket(DocumentationType.SWAGGER_2)
  41.                 .apiInfo(apiInfo())
  42.                 .select()
  43.                 .apis(RequestHandlerSelectors.basePackage("com.fcant.service_acti.controller"))
  44.                 .paths(PathSelectors.any())
  45.                 .build();
  46.     }
  48.     /**
  49.      * 该套 API 说明，包含作者、简介、版本、host、服务URL
  50.      * @return
  51.      */
  52.     private ApiInfo apiInfo() {
  53.         return new ApiInfoBuilder()
  54.                 .title("Activiti Service API")
  55.                 .contact(new Contact("fcant","null","fcscanf@outlook.com"))
  56.                 .version("0.1")
  57.                 .termsOfServiceUrl("www.yuque.com/fcant")
  58.                 .description("Activiti Service API")
  59.                 .build();
  60.     }
  62. }

7、在resources下面添加xml类型的工作流文件

image.png

  1. <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
  2. <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn"
  3.              xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
  4.              xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
  5.              xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" expressionLanguage="http://www.w3.org/1999/XPath"
  6.              id="m1572942222337" name="" targetNamespace="http://www.activiti.org/test"
  7.              typeLanguage="http://www.w3.org/2001/XMLSchema">
  8.     <process id="QjFlow" isClosed="false" isExecutable="true" processType="None">
  9.         <startEvent id="startevent1" name="开始">
  10.             <documentation id="startevent1_D_1"/>
  11.         </startEvent>
  12.         <userTask activiti:candidateUsers="${approveUserIds}" activiti:exclusive="true" id="usertask2" name="用户审批"/>
  13.         <exclusiveGateway gatewayDirection="Unspecified" id="exclusivegateway1" name="审核网关"/>
  14.         <userTask activiti:assignee="${applyUserId}" activiti:exclusive="true" id="usertask1" name="提交申请"/>
  15.         <endEvent id="endevent1" name="结束"/>
  16.         <sequenceFlow id="flow3" sourceRef="usertask2" targetRef="exclusivegateway1"/>
  17.         <sequenceFlow id="flow6" sourceRef="startevent1" targetRef="usertask1"/>
  18.         <sequenceFlow id="flow7" sourceRef="usertask1" targetRef="usertask2"/>
  19.         <userTask activiti:assignee="${applyUserId}" activiti:exclusive="true" id="_2" name="重新提交"/>
  20.         <exclusiveGateway gatewayDirection="Unspecified" id="_5" name="审核网关"/>
  21.         <sequenceFlow id="_6" sourceRef="_2" targetRef="_5"/>
  22.         <sequenceFlow id="_7" sourceRef="_5" targetRef="usertask2">
  23.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==1}]]></conditionExpression>
  24.         </sequenceFlow>
  25.         <sequenceFlow id="_8" sourceRef="_5" targetRef="endevent1">
  26.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==0}]]></conditionExpression>
  27.         </sequenceFlow>
  28.         <sequenceFlow id="_9" sourceRef="exclusivegateway1" targetRef="endevent1">
  29.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==1 || result==2}]]></conditionExpression>
  30.         </sequenceFlow>
  31.         <sequenceFlow id="_10" sourceRef="exclusivegateway1" targetRef="_2">
  32.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==0}]]></conditionExpression>
  33.         </sequenceFlow>
  34.     </process>
  35.     <bpmndi:BPMNDiagram documentation="background=#3C3F41;count=1;horizontalcount=1;orientation=0;width=842.4;height=1195.2;imageableWidth=832.4;imageableHeight=1185.2;imageableX=5.0;imageableY=5.0" id="Diagram-_1" name="New Diagram">
  36.         <bpmndi:BPMNPlane bpmnElement="QjFlow">
  37.             <bpmndi:BPMNShape bpmnElement="startevent1" id="Shape-startevent1">
  38.                 <omgdc:Bounds height="32.0" width="32.0" x="75.0" y="140.0"/>
  39.                 <bpmndi:BPMNLabel>
  40.                     <omgdc:Bounds height="32.0" width="32.0" x="0.0" y="0.0"/>
  41.                 </bpmndi:BPMNLabel>
  42.             </bpmndi:BPMNShape>
  43.             <bpmndi:BPMNShape bpmnElement="usertask2" id="Shape-usertask2">
  44.                 <omgdc:Bounds height="55.0" width="105.0" x="320.0" y="130.0"/>
  45.                 <bpmndi:BPMNLabel>
  46.                     <omgdc:Bounds height="55.0" width="105.0" x="0.0" y="0.0"/>
  47.                 </bpmndi:BPMNLabel>
  48.             </bpmndi:BPMNShape>
  49.             <bpmndi:BPMNShape bpmnElement="exclusivegateway1" id="Shape-exclusivegateway1" isMarkerVisible="false">
  50.                 <omgdc:Bounds height="32.0" width="32.0" x="480.0" y="140.0"/>
  51.                 <bpmndi:BPMNLabel>
  52.                     <omgdc:Bounds height="32.0" width="32.0" x="0.0" y="0.0"/>
  53.                 </bpmndi:BPMNLabel>
  54.             </bpmndi:BPMNShape>
  55.             <bpmndi:BPMNShape bpmnElement="usertask1" id="Shape-usertask1">
  56.                 <omgdc:Bounds height="55.0" width="105.0" x="165.0" y="130.0"/>
  57.                 <bpmndi:BPMNLabel>
  58.                     <omgdc:Bounds height="55.0" width="105.0" x="0.0" y="0.0"/>
  59.                 </bpmndi:BPMNLabel>
  60.             </bpmndi:BPMNShape>
  61.             <bpmndi:BPMNShape bpmnElement="endevent1" id="Shape-endevent1">
  62.                 <omgdc:Bounds height="32.0" width="32.0" x="685.0" y="140.0"/>
  63.                 <bpmndi:BPMNLabel>
  64.                     <omgdc:Bounds height="32.0" width="32.0" x="0.0" y="0.0"/>
  65.                 </bpmndi:BPMNLabel>
  66.             </bpmndi:BPMNShape>
  67.             <bpmndi:BPMNShape bpmnElement="_2" id="Shape-_2">
  68.                 <omgdc:Bounds height="55.0" width="85.0" x="455.0" y="260.0"/>
  69.                 <bpmndi:BPMNLabel>
  70.                     <omgdc:Bounds height="55.0" width="85.0" x="0.0" y="0.0"/>
  71.                 </bpmndi:BPMNLabel>
  72.             </bpmndi:BPMNShape>
  73.             <bpmndi:BPMNShape bpmnElement="_5" id="Shape-_5" isMarkerVisible="false">
  74.                 <omgdc:Bounds height="32.0" width="32.0" x="340.0" y="365.0"/>
  75.                 <bpmndi:BPMNLabel>
  76.                     <omgdc:Bounds height="32.0" width="32.0" x="0.0" y="0.0"/>
  77.                 </bpmndi:BPMNLabel>
  78.             </bpmndi:BPMNShape>
  79.             <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3" sourceElement="usertask2" targetElement="exclusivegateway1">
  80.                 <omgdi:waypoint x="425.0" y="157.5"/>
  81.                 <omgdi:waypoint x="480.0" y="156.0"/>
  82.                 <bpmndi:BPMNLabel>
  83.                     <omgdc:Bounds height="-1.0" width="-1.0" x="-1.0" y="-1.0"/>
  84.                 </bpmndi:BPMNLabel>
  85.             </bpmndi:BPMNEdge>
  86.             <bpmndi:BPMNEdge bpmnElement="_6" id="BPMNEdge__6" sourceElement="_2" targetElement="_5">
  87.                 <omgdi:waypoint x="455.0" y="287.5"/>
  88.                 <omgdi:waypoint x="372.0" y="381.0"/>
  89.                 <bpmndi:BPMNLabel>
  90.                     <omgdc:Bounds height="0.0" width="0.0" x="0.0" y="0.0"/>
  91.                 </bpmndi:BPMNLabel>
  92.             </bpmndi:BPMNEdge>
  93.             <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6" sourceElement="startevent1" targetElement="usertask1">
  94.                 <omgdi:waypoint x="107.0" y="156.0"/>
  95.                 <omgdi:waypoint x="165.0" y="157.5"/>
  96.                 <bpmndi:BPMNLabel>
  97.                     <omgdc:Bounds height="-1.0" width="-1.0" x="-1.0" y="-1.0"/>
  98.                 </bpmndi:BPMNLabel>
  99.             </bpmndi:BPMNEdge>
  100.             <bpmndi:BPMNEdge bpmnElement="_7" id="BPMNEdge__7" sourceElement="_5" targetElement="usertask2">
  101.                 <omgdi:waypoint x="340.0" y="381.0"/>
  102.                 <omgdi:waypoint x="290.0" y="315.0"/>
  103.                 <omgdi:waypoint x="320.0" y="157.5"/>
  104.                 <bpmndi:BPMNLabel>
  105.                     <omgdc:Bounds height="0.0" width="0.0" x="0.0" y="0.0"/>
  106.                 </bpmndi:BPMNLabel>
  107.             </bpmndi:BPMNEdge>
  108.             <bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7" sourceElement="usertask1" targetElement="usertask2">
  109.                 <omgdi:waypoint x="270.0" y="157.5"/>
  110.                 <omgdi:waypoint x="320.0" y="157.5"/>
  111.                 <bpmndi:BPMNLabel>
  112.                     <omgdc:Bounds height="-1.0" width="-1.0" x="-1.0" y="-1.0"/>
  113.                 </bpmndi:BPMNLabel>
  114.             </bpmndi:BPMNEdge>
  115.             <bpmndi:BPMNEdge bpmnElement="_8" id="BPMNEdge__8" sourceElement="_5" targetElement="endevent1">
  116.                 <omgdi:waypoint x="371.0" y="380.0"/>
  117.                 <omgdi:waypoint x="600.0" y="380.0"/>
  118.                 <omgdi:waypoint x="685.0" y="156.0"/>
  119.                 <bpmndi:BPMNLabel>
  120.                     <omgdc:Bounds height="0.0" width="0.0" x="0.0" y="0.0"/>
  121.                 </bpmndi:BPMNLabel>
  122.             </bpmndi:BPMNEdge>
  123.             <bpmndi:BPMNEdge bpmnElement="_9" id="BPMNEdge__9" sourceElement="exclusivegateway1" targetElement="endevent1">
  124.                 <omgdi:waypoint x="512.0" y="156.0"/>
  125.                 <omgdi:waypoint x="685.0" y="156.0"/>
  126.                 <bpmndi:BPMNLabel>
  127.                     <omgdc:Bounds height="0.0" width="0.0" x="0.0" y="0.0"/>
  128.                 </bpmndi:BPMNLabel>
  129.             </bpmndi:BPMNEdge>
  130.             <bpmndi:BPMNEdge bpmnElement="_10" id="BPMNEdge__10" sourceElement="exclusivegateway1" targetElement="_2">
  131.                 <omgdi:waypoint x="496.0" y="172.0"/>
  132.                 <omgdi:waypoint x="496.0" y="260.0"/>
  133.                 <bpmndi:BPMNLabel>
  134.                     <omgdc:Bounds height="0.0" width="0.0" x="0.0" y="0.0"/>
  135.                 </bpmndi:BPMNLabel>
  136.             </bpmndi:BPMNEdge>
  137.         </bpmndi:BPMNPlane>
  138.     </bpmndi:BPMNDiagram>
  139. </definitions>

8、WorkFlow业务逻辑以及接口设计

A.WorkFlowService.java

  1. package com.fcant.service_acti.service;
  3. import javax.servlet.http.HttpServletResponse;
  4. import java.util.List;
  5. import java.util.Map;
  7. /**
  8.  * WorkFlowService
  9.  * <p>
  10.  * encoding:UTF-8
  11.  *
  12.  * @author Fcant 下午 22:21 2020/8/1/0001
  13.  */
  14. public interface WorkFlowService {
  16.     /**
  17.      * 启动流程
  18.      * @param pdKey
  19.      * @param businessKey
  20.      * @param variables
  21.      * @return
  22.      */
  23.     String startWorkflow(String pdKey, String businessKey, Map<String,Object> variables);
  25.     /**
  26.      * 继续流程
  27.      * @param taskId
  28.      * @param variables
  29.      */
  30.     void continueWorkflow(String taskId, Map variables);
  32.     /**
  33.      * 委托流程
  34.      * @param taskId
  35.      * @param variables
  36.      */
  37.     void delegateWorkflow(String taskId, Map variables);
  39.     /**
  40.      * 结束流程(一般不使用，让流程正常结束)
  41.      * @param pProcessInstanceId
  42.      */
  43.     void endWorkflow(String pProcessInstanceId,String deleteReason);
  45.     /**
  46.      * 获取当前的任务节点
  47.      * @param pProcessInstanceId
  48.      */
  49.     String getCurrentTask(String pProcessInstanceId);
  52.     /**
  53.      * 查询用户待办流程实例ID集合
  54.      * @param userId
  55.      * @param pdKey
  56.      * @return
  57.      */
  58.     List<String> findUserProcessIds(String userId, String pdKey, Integer pageNo, Integer pageSize);
  60.     /**
  61.      * 获取流程图像，已执行节点和流程线高亮显示
  62.      */
  63.     void getProcessImage(String pProcessInstanceId, HttpServletResponse response);
  64. }

B.WorkFlowServiceImpl.java

  1. package com.fcant.service_acti.service.impl;
  3. import com.fcant.service_acti.service.WorkFlowService;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.activiti.bpmn.model.BpmnModel;
  6. import org.activiti.bpmn.model.FlowNode;
  7. import org.activiti.bpmn.model.SequenceFlow;
  8. import org.activiti.engine.*;
  9. import org.activiti.engine.history.HistoricActivityInstance;
  10. import org.activiti.engine.history.HistoricProcessInstance;
  11. import org.activiti.engine.repository.ProcessDefinition;
  12. import org.activiti.engine.runtime.ProcessInstance;
  13. import org.activiti.engine.task.DelegationState;
  14. import org.activiti.engine.task.Task;
  15. import org.activiti.image.ProcessDiagramGenerator;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.stereotype.Service;
  18. import org.springframework.transaction.annotation.Transactional;
  20. import javax.servlet.http.HttpServletResponse;
  21. import java.io.IOException;
  22. import java.io.InputStream;
  23. import java.io.OutputStream;
  24. import java.text.SimpleDateFormat;
  25. import java.util.ArrayList;
  26. import java.util.List;
  27. import java.util.Map;
  28. import java.util.stream.Collectors;
  30. /**
  31.  * WorkFlowServiceImpl
  32.  * <p>
  33.  * encoding:UTF-8
  34.  *
  35.  * @author Fcant 下午 22:04 2020/8/1/0001
  36.  */
  37. @Service
  38. @Slf4j
  39. @Transactional(rollbackFor = Exception.class)
  40. public class WorkFlowServiceImpl implements WorkFlowService {
  41.     @Autowired
  42.     private RepositoryService repositoryService;
  44.     @Autowired
  45.     private RuntimeService runtimeService;
  47.     @Autowired
  48.     private TaskService taskService;
  50.     @Autowired
  51.     private HistoryService historyService;
  53.     @Autowired
  54.     private ProcessEngine processEngine;
  56.     public static final String DEAL_USER_ID_KEY = "dealUserId";
  58.     public static final String DELEGATE_STATE = "PENDING";
  60.     /**
  61.      * 启动工作流
  62.      *
  63.      * @param pdKey
  64.      * @param businessKey
  65.      * @param variables
  66.      * @return
  67.      */
  68.     @Override
  69.     public String startWorkflow(String pdKey, String businessKey, Map<String,Object> variables) {
  70.         ProcessDefinition processDef = getLatestProcDef(pdKey);
  71.         if (processDef == null) {
  72.             // 部署流程
  73.             processEngine.getRepositoryService()
  74.                     .createDeployment()//创建部署对象
  75.                     .name(pdKey)
  76.                     .addClasspathResource("processes/"+pdKey+".bpmn")
  77.                     .deploy();
  78.             processDef = getLatestProcDef(pdKey);
  79.         }
  80.         ProcessInstance process  = runtimeService.startProcessInstanceById(processDef.getId(), businessKey, variables);
  81.         return process.getId();
  82.     }
  84.     /**
  85.      * 继续流程
  86.      *
  87.      * @param taskId
  88.      * @param variables
  89.      */
  90.     @Override
  91.     public void continueWorkflow(String taskId, Map variables){
  92.         //根据taskId提取任务
  93.         Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  94.         DelegationState delegationState = task.getDelegationState();
  95.         if(delegationState != null && DELEGATE_STATE.equals(delegationState.toString())){
  96.             // 委托任务，先需要被委派人处理完成任务
  97.             taskService.resolveTask(taskId,variables);
  98.         }else {
  99.             // 当前受理人
  100.             String dealUserId =variables.get(DEAL_USER_ID_KEY).toString();
  101.             // 签收
  102.             taskService.claim(taskId, dealUserId);
  103.         }
  104.         // 设置参数
  105.         taskService.setVariables(taskId, variables);
  106.         // 完成
  107.         taskService.complete(taskId);
  108.     }
  110.     /**
  111.      * 委托流程
  112.      * @param taskId
  113.      * @param variables
  114.      */
  115.     @Override
  116.     public void delegateWorkflow(String taskId, Map variables){
  117.         // 受委托人
  118.         String dealUserId =variables.get(DEAL_USER_ID_KEY).toString();
  119.         // 委托
  120.         taskService.delegateTask(taskId, dealUserId);
  121.     }
  123.     /**
  124.      * 结束流程
  125.      * @param pProcessInstanceId
  126.      */
  127.     @Override
  128.     public void endWorkflow(String pProcessInstanceId,String deleteReason){
  129.         // 结束流程
  130.         runtimeService.deleteProcessInstance(pProcessInstanceId, deleteReason);
  131.     }
  133.     /**
  134.      * 获取当前的任务节点
  135.      * @param pProcessInstanceId
  136.      */
  137.     @Override
  138.     public String getCurrentTask(String pProcessInstanceId){
  139.         Task task = taskService.createTaskQuery().processInstanceId(pProcessInstanceId).active().singleResult();
  140.         return task.getId();
  141.     }
  143.     /**
  144.      *
  145.      * 根据用户id查询待办流程实例ID集合
  146.      *
  147.      */
  148.     @Override
  149.     public List<String> findUserProcessIds(String userId, String pdKey, Integer pageNo, Integer pageSize) {
  150.         List<Task> resultTask;
  151.         if(pageSize == 0 ){
  152.             // 不分页
  153.             resultTask = taskService.createTaskQuery().processDefinitionKey(pdKey)
  154.                     .taskCandidateOrAssigned(userId).list();
  155.         }else {
  156.             resultTask = taskService.createTaskQuery().processDefinitionKey(pdKey)
  157.                     .taskCandidateOrAssigned(userId).listPage(pageNo-1,pageSize);
  158.         }
  159.         //根据流程实例ID集合
  160.         List<String> processInstanceIds = resultTask.stream()
  161.                 .map(task -> task.getProcessInstanceId())
  162.                 .collect(Collectors.toList());
  163.         return processInstanceIds == null ? new ArrayList<>() : processInstanceIds;
  164.     }
  166.     /**
  167.      * 获取流程图像，已执行节点和流程线高亮显示
  168.      */
  169.     @Override
  170.     public void getProcessImage(String pProcessInstanceId, HttpServletResponse response) {
  171.         log.info("[开始]-获取流程图图像");
  172.         // 设置页面不缓存
  173.         response.setHeader("Pragma", "No-cache");
  174.         response.setHeader("Cache-Control", "no-cache");
  175.         response.setDateHeader("Expires", 0);
  176.         response.setContentType("image/png");
  177.         InputStream imageStream = null;
  178.         try (OutputStream os = response.getOutputStream()){
  179.             //  获取历史流程实例
  180.             HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
  181.                     .processInstanceId(pProcessInstanceId).singleResult();
  183.             if (historicProcessInstance == null) {
  184.                 System.out.println("获取流程实例ID[" + pProcessInstanceId + "]对应的历史流程实例失败！");
  185.             } else {
  186.                 // 获取流程历史中已执行节点，并按照节点在流程中执行先后顺序排序
  187.                 List<HistoricActivityInstance> historicActivityInstanceList = historyService.createHistoricActivityInstanceQuery()
  188.                         .processInstanceId(pProcessInstanceId).orderByHistoricActivityInstanceId().asc().list();
  190.                 // 已执行的节点ID集合
  191.                 List<String> executedActivityIdList = new ArrayList<String>();
  192.                 int index = 1;
  193.                 log.info("获取已经执行的节点ID");
  194.                 for (HistoricActivityInstance activityInstance : historicActivityInstanceList) {
  195.                     executedActivityIdList.add(activityInstance.getActivityId());
  197.                     log.info("第[" + index + "]个已执行节点=" + activityInstance.getActivityId() + " : " +activityInstance.getActivityName());
  198.                     index++;
  199.                 }
  200.                 // 获取流程定义
  201.                 BpmnModel bpmnModel = repositoryService.getBpmnModel(historicProcessInstance.getProcessDefinitionId());
  203.                 // 已执行的线集合
  204.                 List<String> flowIds = getHighLightedFlows(bpmnModel, historicActivityInstanceList);
  206.                 // 流程图生成器
  207.                 ProcessDiagramGenerator pec = processEngine.getProcessEngineConfiguration().getProcessDiagramGenerator();
  208.                 // 获取流程图图像字符流（png/jpg）
  209.                 imageStream = pec.generateDiagram(bpmnModel, "jpg", executedActivityIdList, flowIds, "宋体", "微软雅黑", "黑体", null, 2.0);
  211.                 int bytesRead = 0;
  212.                 byte[] buffer = new byte[8192];
  213.                 while ((bytesRead = imageStream.read(buffer, 0, 8192)) != -1) {
  214.                     os.write(buffer, 0, bytesRead);
  215.                 }
  217.             }
  218.             log.info("[完成]-获取流程图图像");
  219.         } catch (Exception e) {
  220.             log.error("【异常】-获取流程图失败！",e);
  221.         }finally {
  222.             if(imageStream != null){
  223.                 try {
  224.                     imageStream.close();
  225.                 } catch (IOException e) {
  226.                     log.error("关闭流异常：",e);
  227.                 }
  228.             }
  229.         }
  230.     }
  232.     public List<String> getHighLightedFlows(BpmnModel bpmnModel, List<HistoricActivityInstance> historicActivityInstances) {
  233.         // 24小时制
  234.         SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  235.         // 用以保存高亮的线flowId
  236.         List<String> highFlows = new ArrayList<String>();
  238.         for (int i = 0; i < historicActivityInstances.size() - 1; i++) {
  239.             // 对历史流程节点进行遍历
  240.             // 得到节点定义的详细信息
  241.             FlowNode activityImpl = (FlowNode) bpmnModel.getMainProcess().getFlowElement(historicActivityInstances.get(i).getActivityId());
  243.             // 用以保存后续开始时间相同的节点
  244.             List<FlowNode> sameStartTimeNodes = new ArrayList<FlowNode>();
  245.             FlowNode sameActivityImpl1 = null;
  246.             // 第一个节点
  247.             HistoricActivityInstance activityImpl_ = historicActivityInstances.get(i);
  248.             HistoricActivityInstance activityImp2_;
  250.             for (int k = i + 1; k <= historicActivityInstances.size() - 1; k++) {
  251.                 // 后续第1个节点
  252.                 activityImp2_ = historicActivityInstances.get(k);
  254.                 if (activityImpl_.getActivityType().equals("userTask") && activityImp2_.getActivityType().equals("userTask") &&
  255.                         df.format(activityImpl_.getStartTime()).equals(df.format(activityImp2_.getStartTime()))) {
  256.                     // 都是usertask，且主节点与后续节点的开始时间相同，说明不是真实的后继节点
  257.                 } else {
  258.                     //找到紧跟在后面的一个节点
  259.                     sameActivityImpl1 = (FlowNode) bpmnModel.getMainProcess().getFlowElement(historicActivityInstances.get(k).getActivityId());
  260.                     break;
  261.                 }
  263.             }
  264.             // 将后面第一个节点放在时间相同节点的集合里
  265.             sameStartTimeNodes.add(sameActivityImpl1);
  266.             for (int j = i + 1; j < historicActivityInstances.size() - 1; j++) {
  267.                 // 后续第一个节点
  268.                 HistoricActivityInstance activityImpl1 = historicActivityInstances.get(j);
  269.                 // 后续第二个节点
  270.                 HistoricActivityInstance activityImpl2 = historicActivityInstances.get(j + 1);
  272.                 if (df.format(activityImpl1.getStartTime()).equals(df.format(activityImpl2.getStartTime()))) {
  273.                     // 如果第一个节点和第二个节点开始时间相同保存
  274.                     FlowNode sameActivityImpl2 = (FlowNode) bpmnModel.getMainProcess().getFlowElement(activityImpl2.getActivityId());
  275.                     sameStartTimeNodes.add(sameActivityImpl2);
  276.                 } else {// 有不相同跳出循环
  277.                     break;
  278.                 }
  279.             }
  280.             // 取出节点的所有出去的线
  281.             List<SequenceFlow> pvmTransitions = activityImpl.getOutgoingFlows();
  282.             // 对所有的线进行遍历
  283.             for (SequenceFlow pvmTransition : pvmTransitions) {
  284.                 // 如果取出的线的目标节点存在时间相同的节点里，保存该线的id，进行高亮显示
  285.                 FlowNode pvmActivityImpl = (FlowNode) bpmnModel.getMainProcess().getFlowElement(pvmTransition.getTargetRef());
  286.                 if (sameStartTimeNodes.contains(pvmActivityImpl)) {
  287.                     highFlows.add(pvmTransition.getId());
  288.                 }
  289.             }
  291.         }
  292.         return highFlows;
  294.     }
  296.     /**
  297.      * 获取最新版本流程
  298.      *
  299.      * @param modelName
  300.      * @return
  301.      */
  302.     private ProcessDefinition getLatestProcDef(String modelName) {
  303.         return repositoryService.createProcessDefinitionQuery().processDefinitionKey(modelName).
  304.                 latestVersion().singleResult();
  305.     }
  307. }

C.ActivitiController.java

  1. package com.fcant.service_acti.controller;
  3. import com.fcant.service_acti.result.Result;
  4. import com.fcant.service_acti.service.WorkFlowService;
  5. import io.swagger.annotations.Api;
  6. import io.swagger.annotations.ApiOperation;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.apache.commons.lang.StringUtils;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.web.bind.annotation.*;
  12. import javax.servlet.http.HttpServletResponse;
  13. import java.util.Arrays;
  14. import java.util.HashMap;
  15. import java.util.Map;
  17. /**
  18.  * ActivitiController
  19.  * <p>
  20.  * encoding:UTF-8
  21.  *
  22.  * @author Fcant 下午 22:16 2020/8/1/0001
  23.  */
  24. @RestController
  25. @Api(tags = "activiti",value = "工作流控制器")
  26. @RequestMapping("/activiti")
  27. @Slf4j
  28. public class ActivitiController {
  30.     @Autowired
  31.     private WorkFlowService workFlowService;
  34.     @PostMapping("/apply")
  35.     @ApiOperation(value="启动请假流程")
  36.     public Result startWorkflow(@RequestParam(required = false) String pdKey){
  37.         Map param = new HashMap(4){{
  38.             put("applyUserId","001");
  39.             put("approveUserIds", Arrays.asList("001","002","003"));
  40.         }};
  42.         if(StringUtils.isBlank(pdKey)){
  43.             pdKey="QjFlow";
  44.         }
  45.         // 启动流程
  46.         String pdId = workFlowService.startWorkflow(pdKey, "QJ001", param);
  47.         // 获取请假申请任务节点
  48.         String Id = workFlowService.getCurrentTask(pdId);
  49.         // 完成请假申请任务节点
  50.         Map continueParam = new HashMap(2){{
  51.             put("dealUserId",param.get("applyUserId"));
  52.         }};
  53.         workFlowService.continueWorkflow(Id,continueParam);
  54.         return Result.success().reSetMsg("请假已提交");
  55.     }
  57.     @PostMapping("/approve")
  58.     @ApiOperation(value="审批请假流程")
  59.     public Result continueWorkflow(@RequestParam String pId,@RequestParam String result){
  60.         Map param = new HashMap(2){{
  61.             put("dealUserId","001");
  62.             put("result",result);
  63.         }};
  65.         // 获取请假审批任务节点
  66.         String Id = workFlowService.getCurrentTask(pId);
  67.         // 完成请假审批任务节点
  68.         workFlowService.continueWorkflow(Id,param);
  69.         return Result.success().reSetMsg("审批成功");
  70.     }
  72.     @PostMapping("/delegate")
  73.     @ApiOperation(value="委托请假流程")
  74.     public Result delegateWorkflow(@RequestParam String pId,@RequestParam String userId){
  75.         Map param = new HashMap(2){{
  76.             put("dealUserId",userId);
  77.         }};
  78.         // 获取请假审批任务节点
  79.         String Id = workFlowService.getCurrentTask(pId);
  80.         // 完成请假审批任务节点
  81.         workFlowService.delegateWorkflow(Id,param);
  82.         return Result.success().reSetMsg("委托成功");
  83.     }
  85.     /**
  86.      *  查询用户待办流程实例
  87.      * @param userId
  88.      * @param pdKey
  89.      */
  90.     @GetMapping("/user-process")
  91.     @ApiOperation(value="查询用户待办流程实例")
  92.     public Result findUserProcessIds(@RequestParam String userId, @RequestParam(required = false) String pdKey) {
  93.         if(StringUtils.isBlank(pdKey)){
  94.             pdKey="QjFlow";
  95.         }
  96.         // 获取流程图
  97.         return Result.success().addData("workflow", workFlowService.findUserProcessIds(userId,pdKey,1,0));
  98.     }
  100.     /**
  101.      * 读取流程资源
  102.      * @param pId 流程实例id
  103.      */
  104.     @GetMapping("/read-resource")
  105.     @ApiOperation(value="读取流程资源")
  106.     public void readResource(@RequestParam String pId, HttpServletResponse response) {
  107.         // 获取流程图
  108.         workFlowService.getProcessImage(pId, response);
  109.     }
  111. }

9、启动项目，生成28张acti表

image.png

10、访问接口进行测试

image.png