SpringBoot Flowable
Flowable是一个用java语言写的轻量级工作流引擎。

1、相关依赖

  1. <!-- https://mvnrepository.com/artifact/io.springfox/springfox-swagger2 -->
  2. <dependency>
  3.   <groupId>io.springfox</groupId>
  4.   <artifactId>springfox-swagger2</artifactId>
  5.   <version>2.9.2</version>
  6. </dependency>
  8. <!-- https://mvnrepository.com/artifact/io.springfox/springfox-swagger-ui -->
  9. <dependency>
  10.   <groupId>io.springfox</groupId>
  11.   <artifactId>springfox-swagger-ui</artifactId>
  12.   <version>2.9.2</version>
  13. </dependency>
  15. <!-- https://mvnrepository.com/artifact/com.github.xiaoymin/swagger-bootstrap-ui -->
  16. <dependency>
  17.   <groupId>com.github.xiaoymin</groupId>
  18.   <artifactId>swagger-bootstrap-ui</artifactId>
  19.   <version>1.8.5</version>
  20. </dependency>
  22. <dependency>
  23.   <groupId>com.alibaba</groupId>
  24.   <artifactId>druid-spring-boot-starter</artifactId>
  25.   <version>1.1.13</version>
  26. </dependency>
  28. <dependency>
  29.   <groupId>mysql</groupId>
  30.   <artifactId>mysql-connector-java</artifactId>
  31.   <version>8.0.19</version>
  32. </dependency>
  34. <dependency>
  35.   <groupId>org.flowable</groupId>
  36.   <artifactId>flowable-spring-boot-starter</artifactId>
  37.   <version>6.5.0</version>
  38. </dependency>

2、flowable以及数据库的配置

  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. flowable:
  59.   #关闭定时任务JOB
  60.   async-executor-activate: false
  61.   #  将databaseSchemaUpdate设置为true。当Flowable发现库与数据库表结构不一致时，会自动将数据库表结构升级至新版本。
  62.   database-schema-update: true

3、运行项目生成数据库表

image.png

4、定义标准的BPMN流程文件ExpenseProcess.bpmn20.xml放至resource目录下新建processes目录下

image.png

  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"
  3.              xmlns:flowable="http://flowable.org/bpmn" 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.              typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath"
  6.              targetNamespace="http://www.flowable.org/processdef">
  7.     <process id="Expense" name="ExpenseProcess" isExecutable="true">
  8.         <documentation>报销流程</documentation>
  9.         <startEvent id="start" name="开始"></startEvent>
  10.         <userTask id="fillTask" name="出差报销" flowable:assignee="${taskUser}">
  11.             <extensionElements>
  12.                 <modeler:initiator-can-complete xmlns:modeler="http://flowable.org/modeler">
  13.                     <![CDATA[false]]></modeler:initiator-can-complete>
  14.             </extensionElements>
  15.         </userTask>
  16.         <exclusiveGateway id="judgeTask"></exclusiveGateway>
  17.         <userTask id="directorTak" name="经理审批">
  18.             <extensionElements>
  19.                 <flowable:taskListener event="create"
  20.                                        class="com.fcant.service_flowable.handler.ManagerTaskHandler"></flowable:taskListener>
  21.             </extensionElements>
  22.         </userTask>
  23.         <userTask id="bossTask" name="老板审批">
  24.             <extensionElements>
  25.                 <flowable:taskListener event="create"
  26.                                        class="com.fcant.service_flowable.handler.BossTaskHandler"></flowable:taskListener>
  27.             </extensionElements>
  28.         </userTask>
  29.         <endEvent id="end" name="结束"></endEvent>
  30.         <sequenceFlow id="directorNotPassFlow" name="驳回" sourceRef="directorTak" targetRef="fillTask">
  31.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${outcome=='驳回'}]]></conditionExpression>
  32.         </sequenceFlow>
  33.         <sequenceFlow id="bossNotPassFlow" name="驳回" sourceRef="bossTask" targetRef="fillTask">
  34.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${outcome=='驳回'}]]></conditionExpression>
  35.         </sequenceFlow>
  36.         <sequenceFlow id="flow1" sourceRef="start" targetRef="fillTask"></sequenceFlow>
  37.         <sequenceFlow id="flow2" sourceRef="fillTask" targetRef="judgeTask"></sequenceFlow>
  38.         <sequenceFlow id="judgeMore" name="大于500元" sourceRef="judgeTask" targetRef="bossTask">
  39.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${money > 500}]]></conditionExpression>
  40.         </sequenceFlow>
  41.         <sequenceFlow id="bossPassFlow" name="通过" sourceRef="bossTask" targetRef="end">
  42.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${outcome=='通过'}]]></conditionExpression>
  43.         </sequenceFlow>
  44.         <sequenceFlow id="directorPassFlow" name="通过" sourceRef="directorTak" targetRef="end">
  45.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${outcome=='通过'}]]></conditionExpression>
  46.         </sequenceFlow>
  47.         <sequenceFlow id="judgeLess" name="小于500元" sourceRef="judgeTask" targetRef="directorTak">
  48.             <conditionExpression xsi:type="tFormalExpression"><![CDATA[${money <= 500}]]></conditionExpression>
  49.         </sequenceFlow>
  50.     </process>
  51.     <bpmndi:BPMNDiagram id="BPMNDiagram_Expense">
  52.         <bpmndi:BPMNPlane bpmnElement="Expense" id="BPMNPlane_Expense">
  53.             <bpmndi:BPMNShape bpmnElement="start" id="BPMNShape_start">
  54.                 <omgdc:Bounds height="30.0" width="30.0" x="285.0" y="135.0"></omgdc:Bounds>
  55.             </bpmndi:BPMNShape>
  56.             <bpmndi:BPMNShape bpmnElement="fillTask" id="BPMNShape_fillTask">
  57.                 <omgdc:Bounds height="80.0" width="100.0" x="405.0" y="110.0"></omgdc:Bounds>
  58.             </bpmndi:BPMNShape>
  59.             <bpmndi:BPMNShape bpmnElement="judgeTask" id="BPMNShape_judgeTask">
  60.                 <omgdc:Bounds height="40.0" width="40.0" x="585.0" y="130.0"></omgdc:Bounds>
  61.             </bpmndi:BPMNShape>
  62.             <bpmndi:BPMNShape bpmnElement="directorTak" id="BPMNShape_directorTak">
  63.                 <omgdc:Bounds height="80.0" width="100.0" x="735.0" y="110.0"></omgdc:Bounds>
  64.             </bpmndi:BPMNShape>
  65.             <bpmndi:BPMNShape bpmnElement="bossTask" id="BPMNShape_bossTask">
  66.                 <omgdc:Bounds height="80.0" width="100.0" x="555.0" y="255.0"></omgdc:Bounds>
  67.             </bpmndi:BPMNShape>
  68.             <bpmndi:BPMNShape bpmnElement="end" id="BPMNShape_end">
  69.                 <omgdc:Bounds height="28.0" width="28.0" x="771.0" y="281.0"></omgdc:Bounds>
  70.             </bpmndi:BPMNShape>
  71.             <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
  72.                 <omgdi:waypoint x="315.0" y="150.0"></omgdi:waypoint>
  73.                 <omgdi:waypoint x="405.0" y="150.0"></omgdi:waypoint>
  74.             </bpmndi:BPMNEdge>
  75.             <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
  76.                 <omgdi:waypoint x="505.0" y="150.16611295681062"></omgdi:waypoint>
  77.                 <omgdi:waypoint x="585.4333333333333" y="150.43333333333334"></omgdi:waypoint>
  78.             </bpmndi:BPMNEdge>
  79.             <bpmndi:BPMNEdge bpmnElement="judgeLess" id="BPMNEdge_judgeLess">
  80.                 <omgdi:waypoint x="624.5530726256983" y="150.44692737430168"></omgdi:waypoint>
  81.                 <omgdi:waypoint x="735.0" y="150.1392757660167"></omgdi:waypoint>
  82.             </bpmndi:BPMNEdge>
  83.             <bpmndi:BPMNEdge bpmnElement="directorNotPassFlow" id="BPMNEdge_directorNotPassFlow">
  84.                 <omgdi:waypoint x="785.0" y="110.0"></omgdi:waypoint>
  85.                 <omgdi:waypoint x="785.0" y="37.0"></omgdi:waypoint>
  86.                 <omgdi:waypoint x="455.0" y="37.0"></omgdi:waypoint>
  87.                 <omgdi:waypoint x="455.0" y="110.0"></omgdi:waypoint>
  88.             </bpmndi:BPMNEdge>
  89.             <bpmndi:BPMNEdge bpmnElement="bossPassFlow" id="BPMNEdge_bossPassFlow">
  90.                 <omgdi:waypoint x="655.0" y="295.0"></omgdi:waypoint>
  91.                 <omgdi:waypoint x="771.0" y="295.0"></omgdi:waypoint>
  92.             </bpmndi:BPMNEdge>
  93.             <bpmndi:BPMNEdge bpmnElement="judgeMore" id="BPMNEdge_judgeMore">
  94.                 <omgdi:waypoint x="605.4340277777778" y="169.56597222222223"></omgdi:waypoint>
  95.                 <omgdi:waypoint x="605.1384083044983" y="255.0"></omgdi:waypoint>
  96.             </bpmndi:BPMNEdge>
  97.             <bpmndi:BPMNEdge bpmnElement="directorPassFlow" id="BPMNEdge_directorPassFlow">
  98.                 <omgdi:waypoint x="785.0" y="190.0"></omgdi:waypoint>
  99.                 <omgdi:waypoint x="785.0" y="281.0"></omgdi:waypoint>
  100.             </bpmndi:BPMNEdge>
  101.             <bpmndi:BPMNEdge bpmnElement="bossNotPassFlow" id="BPMNEdge_bossNotPassFlow">
  102.                 <omgdi:waypoint x="555.0" y="295.0"></omgdi:waypoint>
  103.                 <omgdi:waypoint x="455.0" y="295.0"></omgdi:waypoint>
  104.                 <omgdi:waypoint x="455.0" y="190.0"></omgdi:waypoint>
  105.             </bpmndi:BPMNEdge>
  106.         </bpmndi:BPMNPlane>
  107.     </bpmndi:BPMNDiagram>
  108. </definitions>

5、添加代理类

A.ManagerTaskHandler.java

  1. package com.fcant.service_flowable.handler;
  3. import org.flowable.engine.delegate.TaskListener;
  4. import org.flowable.task.service.delegate.DelegateTask;
  6. /**
  7.  * ManagerTaskHandler
  8.  * <p>
  9.  * encoding:UTF-8
  10.  *
  11.  * @author Fcant 下午 19:42 2020/8/2/0002
  12.  */
  13. public class ManagerTaskHandler implements TaskListener {
  14.     @Override
  15.     public void notify(DelegateTask delegateTask) {
  16.         delegateTask.setAssignee("经理");
  17.     }
  19. }

B.BossTaskHandler.java

  1. package com.fcant.service_flowable.handler;
  3. import org.flowable.engine.delegate.TaskListener;
  4. import org.flowable.task.service.delegate.DelegateTask;
  6. /**
  7.  * BossTaskHandler
  8.  * <p>
  9.  * encoding:UTF-8
  10.  *
  11.  * @author Fcant 下午 19:43 2020/8/2/0002
  12.  */
  13. public class BossTaskHandler implements TaskListener {
  15.     @Override
  16.     public void notify(DelegateTask delegateTask) {
  17.         delegateTask.setAssignee("老板");
  18.     }
  19. }

C.以上代理类可以使用标签进行替换

  1. <userTask id="holidayApprovedTask" name="Holiday approved" flowable:assignee="${employee}"/>

D.代理类完成后需要在BPMN进行类指定

image.png

6、业务逻辑层以及测试接口

A.ExpenseService.java

  1. package com.fcant.service_flowable.service;
  3. import javax.servlet.http.HttpServletResponse;
  5. /**
  6.  * ExpenseService
  7.  * <p>
  8.  * encoding:UTF-8
  9.  *
  10.  * @author Fcant 下午 20:10 2020/8/2/0002
  11.  */
  12. public interface ExpenseService {
  14.     /**
  15.      * 添加报销
  16.      *
  17.      * @param userId 用户Id
  18.      * @param money 报销金额
  19.      * @param descption 描述
  20.      * @return String
  21.      * @author Fcant 下午 20:02 2020/8/2/0002
  22.      */
  23.     public String addExpense(String userId, Integer money, String descption);
  25.     /**
  26.      * 获取审批管理列表
  27.      *
  28.      * @param userId 对应用户的审批列表
  29.      * @return Object
  30.      * @author Fcant 下午 20:01 2020/8/2/0002
  31.      */
  32.     public Object list(String userId);
  34.     /**
  35.      * 批准
  36.      *
  37.      * @param taskId 批准的工作流ID
  38.      * @return
  39.      * @author Fcant 下午 20:01 2020/8/2/0002
  40.      */
  41.     public String apply(String taskId);
  43.     /**
  44.      * 拒绝
  45.      *
  46.      * @param taskId 拒绝的工作流ID
  47.      * @return String
  48.      * @author Fcant 下午 20:00 2020/8/2/0002
  49.      */
  50.     public String reject(String taskId);
  52.     /**
  53.      * 生成流程图
  54.      *
  55.      * @param processId 任务ID
  56.      * @author Fcant 下午 19:59 2020/8/2/0002
  57.      */
  58.     public void genProcessDiagram(HttpServletResponse httpServletResponse, String processId) throws Exception;
  59. }

B.ExpenseServiceImpl.java

  1. package com.fcant.service_flowable.service.impl;
  3. import com.fcant.service_flowable.service.ExpenseService;
  4. import org.flowable.bpmn.model.BpmnModel;
  5. import org.flowable.engine.*;
  6. import org.flowable.engine.runtime.Execution;
  7. import org.flowable.engine.runtime.ProcessInstance;
  8. import org.flowable.image.ProcessDiagramGenerator;
  9. import org.flowable.task.api.Task;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  13. import javax.servlet.http.HttpServletResponse;
  14. import java.io.InputStream;
  15. import java.io.OutputStream;
  16. import java.util.ArrayList;
  17. import java.util.HashMap;
  18. import java.util.List;
  20. /**
  21.  * ExpenseServiceImpl
  22.  * <p>
  23.  * encoding:UTF-8
  24.  *
  25.  * @author Fcant 下午 20:10 2020/8/2/0002
  26.  */
  27. @Service
  28. public class ExpenseServiceImpl implements ExpenseService {
  30.     @Autowired
  31.     private RuntimeService runtimeService;
  33.     @Autowired
  34.     private TaskService taskService;
  36.     @Autowired
  37.     private RepositoryService repositoryService;
  39.     @Autowired
  40.     private ProcessEngine processEngine;
  42.     /**
  43.      * 添加报销
  44.      *
  45.      * @param userId 用户Id
  46.      * @param money 报销金额
  47.      * @param descption 描述
  48.      * @return String
  49.      * @author Fcant 下午 20:02 2020/8/2/0002
  50.      */
  51.     @Override
  52.     public String addExpense(String userId, Integer money, String descption) {
  53.         //启动流程
  54.         HashMap<String, Object> map = new HashMap<>();
  55.         map.put("taskUser", userId);
  56.         map.put("money", money);
  57.         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("Expense", map);
  58.         return "提交成功.流程Id为：" + processInstance.getId();
  59.     }
  61.     /**
  62.      * 获取审批管理列表
  63.      *
  64.      * @param userId 对应用户的审批列表
  65.      * @return Object
  66.      * @author Fcant 下午 20:01 2020/8/2/0002
  67.      */
  68.     @Override
  69.     public Object list(String userId) {
  70.         List<Task> tasks = taskService.createTaskQuery().taskAssignee(userId).orderByTaskCreateTime().desc().list();
  71.         for (Task task : tasks) {
  72.             System.out.println(task.toString());
  73.         }
  74.         return tasks.toArray().toString();
  75.     }
  77.     /**
  78.      * 批准
  79.      *
  80.      * @param taskId 批准的工作流ID
  81.      * @return
  82.      * @author Fcant 下午 20:01 2020/8/2/0002
  83.      */
  84.     @Override
  85.     public String apply(String taskId) {
  86.         Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  87.         if (task == null) {
  88.             throw new RuntimeException("流程不存在");
  89.         }
  90.         //通过审核
  91.         HashMap<String, Object> map = new HashMap<>();
  92.         map.put("outcome", "通过");
  93.         taskService.complete(taskId, map);
  94.         return "processed ok!";
  95.     }
  97.     /**
  98.      * 拒绝
  99.      *
  100.      * @param taskId 拒绝的工作流ID
  101.      * @return String
  102.      * @author Fcant 下午 20:00 2020/8/2/0002
  103.      */
  104.     @Override
  105.     public String reject(String taskId) {
  106.         HashMap<String, Object> map = new HashMap<>();
  107.         map.put("outcome", "驳回");
  108.         taskService.complete(taskId, map);
  109.         return "reject";
  110.     }
  112.     /**
  113.      * 生成流程图
  114.      *
  115.      * @param processId 任务ID
  116.      * @author Fcant 下午 19:59 2020/8/2/0002
  117.      */
  118.     @Override
  119.     public void genProcessDiagram(HttpServletResponse httpServletResponse, String processId) throws Exception {
  120.         ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processId).singleResult();
  121.         //流程走完的不显示图
  122.         if (pi == null) {
  123.             return;
  124.         }
  125.         Task task = taskService.createTaskQuery().processInstanceId(pi.getId()).singleResult();
  126.         //使用流程实例ID，查询正在执行的执行对象表，返回流程实例对象
  127.         String InstanceId = task.getProcessInstanceId();
  128.         List<Execution> executions = runtimeService
  129.                 .createExecutionQuery()
  130.                 .processInstanceId(InstanceId)
  131.                 .list();
  133.         //得到正在执行的Activity的Id
  134.         List<String> activityIds = new ArrayList<>();
  135.         List<String> flows = new ArrayList<>();
  136.         for (Execution exe : executions) {
  137.             List<String> ids = runtimeService.getActiveActivityIds(exe.getId());
  138.             activityIds.addAll(ids);
  139.         }
  141.         //获取流程图
  142.         BpmnModel bpmnModel = repositoryService.getBpmnModel(pi.getProcessDefinitionId());
  143.         ProcessEngineConfiguration engconf = processEngine.getProcessEngineConfiguration();
  144.         ProcessDiagramGenerator diagramGenerator = engconf.getProcessDiagramGenerator();
  145.         InputStream in = diagramGenerator.generateDiagram(bpmnModel,
  146.                 "png", activityIds, flows, engconf.getActivityFontName(),
  147.                 engconf.getLabelFontName(), engconf.getAnnotationFontName(),
  148.                 engconf.getClassLoader(), 1.0, true);
  149.         OutputStream out = null;
  150.         byte[] buf = new byte[1024];
  151.         int legth = 0;
  152.         try {
  153.             out = httpServletResponse.getOutputStream();
  154.             while ((legth = in.read(buf)) != -1) {
  155.                 out.write(buf, 0, legth);
  156.             }
  157.         } finally {
  158.             if (in != null) {
  159.                 in.close();
  160.             }
  161.             if (out != null) {
  162.                 out.close();
  163.             }
  164.         }
  165.     }
  166. }

C.ExpenseController.java

  1. package com.fcant.service_flowable.controller;
  3. import com.fcant.service_flowable.service.ExpenseService;
  4. import io.swagger.annotations.Api;
  5. import io.swagger.annotations.ApiOperation;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Controller;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.ResponseBody;
  11. import javax.servlet.http.HttpServletResponse;
  13. /**
  14.  * ExpenseController
  15.  * <p>
  16.  * encoding:UTF-8
  17.  *
  18.  * @author Fcant 下午 19:46 2020/8/2/0002
  19.  */
  20. @Api(tags = "expense",value = "工作流控制器")
  21. @Controller
  22. @RequestMapping("/expense")
  23. public class ExpenseController {
  24.     @Autowired
  25.     ExpenseService expenseService;
  27.     /**
  28.      * 添加报销
  29.      *
  30.      * @param userId 用户Id
  31.      * @param money 报销金额
  32.      * @param descption 描述
  33.      * @return String
  34.      * @author Fcant 下午 20:02 2020/8/2/0002
  35.      */
  36.     @ApiOperation(value="添加报销")
  37.     @RequestMapping(value = "/add")
  38.     @ResponseBody
  39.     public String addExpense(String userId, Integer money, String descption) {
  40.         return expenseService.addExpense(userId, money, descption);
  41.     }
  43.     /**
  44.      * 获取审批管理列表
  45.      *
  46.      * @param userId 对应用户的审批列表
  47.      * @return Object
  48.      * @author Fcant 下午 20:01 2020/8/2/0002
  49.      */
  50.     @ApiOperation(value="获取审批管理列表")
  51.     @RequestMapping(value = "/list")
  52.     @ResponseBody
  53.     public Object list(String userId) {
  54.         return expenseService.list(userId);
  55.     }
  57.     /**
  58.      * 批准
  59.      *
  60.      * @param taskId 批准的工作流ID
  61.      * @return
  62.      * @author Fcant 下午 20:01 2020/8/2/0002
  63.      */
  64.     @ApiOperation(value="批准")
  65.     @RequestMapping(value = "/apply")
  66.     @ResponseBody
  67.     public String apply(String taskId) {
  68.         expenseService.apply(taskId);
  69.         return "processed ok!";
  70.     }
  72.     /**
  73.      * 拒绝
  74.      *
  75.      * @param taskId 拒绝的工作流ID
  76.      * @return String
  77.      * @author Fcant 下午 20:00 2020/8/2/0002
  78.      */
  79.     @ApiOperation(value="拒绝")
  80.     @ResponseBody
  81.     @RequestMapping(value = "/reject")
  82.     public String reject(String taskId) {
  83.         expenseService.reject(taskId);
  84.         return "reject";
  85.     }
  87.     /**
  88.      * 生成流程图
  89.      *
  90.      * @param processId 任务ID
  91.      * @author Fcant 下午 19:59 2020/8/2/0002
  92.      */
  93.     @ApiOperation(value="生成流程图")
  94.     @RequestMapping(value = "/processDiagram")
  95.     public void genProcessDiagram(HttpServletResponse httpServletResponse, String processId) throws Exception {
  96.         expenseService.genProcessDiagram(httpServletResponse, processId);
  97.     }
  98. }

7、配置生成的流图的字体（防止/解决生成流程图片的乱码问题）

  1. package com.fcant.service_flowable.config;
  3. import org.flowable.spring.SpringProcessEngineConfiguration;
  4. import org.flowable.spring.boot.EngineConfigurationConfigurer;
  5. import org.springframework.context.annotation.Configuration;
  7. /**
  8.  * FlowableConfig
  9.  * <p>
  10.  * encoding:UTF-8
  11.  *
  12.  * @author Fcant 下午 19:51 2020/8/2/0002
  13.  */
  14. @Configuration
  15. public class FlowableConfig implements EngineConfigurationConfigurer<SpringProcessEngineConfiguration> {
  18.     @Override
  19.     public void configure(SpringProcessEngineConfiguration engineConfiguration) {
  20.         engineConfiguration.setActivityFontName("宋体");
  21.         engineConfiguration.setLabelFontName("宋体");
  22.         engineConfiguration.setAnnotationFontName("宋体");
  23.     }
  24. }

8、配置Swagger

  1. package com.fcant.service_flowable.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_flowable.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("Flowable Service API")
  55.                 .contact(new Contact("fcant","null","fcscanf@outlook.com"))
  56.                 .version("0.1")
  57.                 .termsOfServiceUrl("www.yuque.com/fcant")
  58.                 .description("Flowable Service API")
  59.                 .build();
  60.     }
  61. }

9、启动项目，访问Swagger页面进行接口测试

image.png
image.png