springboot2.2 集成 activity6实现请假完整流程示例详解

新手学习记录。写在springboot test 示例示例代码地址看结尾。后面有带页面的示例。

SpringBoot Test无页面简单示例

员工请假流程

员工发起申请,附带请假信息(请假几天)
单位领导审批,如果通过,交付经理审批,不通过,重新申请
经理审批,如果请假天数不超过三天,经理1审批
如果请假天数在3-5天,经理3审批
超过5天,经理2审批
经理审批通过,流程结束,经理审批不通过,员工重新申请

流程图

springboot2.2 集成 activity6实现请假完整流程示例详解

代码

activiti.cfg.xml为必须文件且数据库连接正确，否则ProcessEngines.getDefaultProcessEngine()会报空指针。

									复制代码

									<?xml version="1.0" encoding="UTF-8"?>

									<beans xmlns="http://www.springframework.org/schema/beans"

									  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

									  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

									 <!-- Activity 的引擎配置管理器 -->

									 <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">

									  <!-- 指定数据源 -->

									  <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activity?serverTimezone=UTC&amp;characterEncoding=UTF-8" />

									  <property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver" />

									  <property name="jdbcUsername" value="root" />

									  <property name="jdbcPassword" value="111111" />

									  <property name="databaseSchemaUpdate" value="true" />

									 </bean>

									</beans>

测试类

三个方法可合并在一起运行，拆开是自己为了方便查看代码步骤。

1. 先运行deploymentProcess（）部署一个流程。

2. 运行startLeaveProcess() 开启流程。

3. 运行getTaskAndComplete（）走流程。循环一次性整个流程走完。

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

									package com.blackcat.activity;

									import org.activiti.engine.*;

									import org.activiti.engine.repository.Deployment;

									import org.activiti.engine.runtime.ProcessInstance;

									import org.activiti.engine.task.Task;

									import org.junit.jupiter.api.Test;

									import org.springframework.boot.test.context.SpringBootTest;

									import java.util.HashMap;

									import java.util.Map;

									/**

									 * @Title 申请测试

									 * @Description 

									 * @author zhanghui

									 * @date 2020年07月17日 15:06

									 * @version V1.0

									 * @see

									 * @link https://blog.csdn.net/fly_fly_fly_pig/article/details/81700820 参考该博客

									 * @since V1.0

									 */

									@SpringBootTest

									class LeaveProcessTest {

									 // 获取默认的流程引擎

									 private ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();

									 // 实例流程id,用来记录流程,以便获取当前任务

									 private String processInstanceId;

									 // 部署一个流程

									 @Test

									 void deploymentProcess(){

									  RepositoryService rs = engine.getRepositoryService();

									  Deployment deploy = rs.createDeployment().addClasspathResource("processes/LeaveProcess.bpmn").deploy();

									  rs.createProcessDefinitionQuery().deploymentId(deploy.getId()).singleResult();

									 }

									 // 开启流程

									 @Test

									 void startLeaveProcess(){

									  // 获取runtimeservice对象

									  RuntimeService runtimeService = engine.getRuntimeService();

									  // 根据流程key值,获取流程

									  String processKey = "leaveProcess";

									  // 将信息加入map,以便传入流程中

									  Map<String, Object> variables = new HashMap<>();

									  variables.put("employeeName", "张三");

									  variables.put("day",10);

									  // 开启流程

									  ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processKey, variables);

									  // 将得到的实例流程id值赋给之前设置的变量

									  processInstanceId = processInstance.getId();

									  System.out.println("流程开启成功.......实例流程id:"+processInstanceId);

									 }

									 // 开始走流程

									 // 1.获取当前任务,并且完成

									 @Test

									 void getTaskAndComplete(){

									//  processInstanceId = "12501";

									  // 获取taskservice实例

									  TaskService taskService = engine.getTaskService();

									  // 开始进行流程

									  while(engine.getRuntimeService()

									    .createProcessInstanceQuery()// 获取查询对象

									    .processInstanceId(processInstanceId)// 根据id查询流程实例

									    .singleResult()// 获取查询结果,如果为空,说明这个流程已经执行完毕,否则,获取任务并执行

									    !=null){

									   Task task = taskService.createTaskQuery()// 创建查询对象

									     .processInstanceId(processInstanceId)// 通过流程实例id来查询当前任务

									     .singleResult();// 获取单个查询结果

									   String taskName = task.getName();

									   if(taskName.equals("发起申请")){// 职员节点

									    completeEmployeeTask(task);

									   }else if(taskName.equals("领导审批")){// 领导节点

									    completeLeaderTask(task);

									   }else{// 经理节点

									    completeJingliTask(task);

									   }

									  }

									  System.out.println("审核结束..........");

									 }

									 // 职员提交申请

									 void completeEmployeeTask(Task task){

									  // 获取任务id

									  String taskId = task.getId();

									  // 完成任务

									  engine.getTaskService().complete(taskId);

									  System.out.println("职员已经提交申请.......");

									 }

									 // 领导审批

									 void completeLeaderTask(Task task){

									  // 获取任务id

									  String taskId = task.getId();

									  // 领导意见

									  Map<String, Object> variables = new HashMap<>();

									  variables.put("leaderResult", 1);

									  // 完成任务

									  engine.getTaskService().complete(taskId, variables);

									  System.out.println("领导审核完毕........");

									 }

									 // 经理审批

									 void completeJingliTask(Task task){

									  // 获取任务id

									  String taskId = task.getId();

									  String name = task.getName();

									  // 经理意见

									  // 领导意见和经理意见,用0和1表示,0表示未通过,1表示通过

									  // 任一环节设置不同意,陷入死循环

									  Map<String, Object> variables = new HashMap<>();

									  variables.put("result", 1);

									  // 完成任务

									  engine.getTaskService().complete(taskId, variables);

									  System.out.println("经理审核完毕........,审核经理:"+name);

									 }