復(fù)制代碼
<?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">
 <!-- 指定數(shù)據(jù)源 -->
 <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>

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,用來記錄流程,以便獲取當(dāng)前任務(wù)
 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();
 
 // 根據(jù)流程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值賦給之前設(shè)置的變量
 processInstanceId = processInstance.getId();
 System.out.println("流程開啟成功.......實例流程id:"+processInstanceId);
 }
 
 // 開始走流程
 // 1.獲取當(dāng)前任務(wù),并且完成
 @Test
 void getTaskAndComplete(){
// processInstanceId = "12501";
 // 獲取taskservice實例
 TaskService taskService = engine.getTaskService();
 
 // 開始進行流程
 while(engine.getRuntimeService()
 .createProcessInstanceQuery()// 獲取查詢對象
 .processInstanceId(processInstanceId)// 根據(jù)id查詢流程實例
 .singleResult()// 獲取查詢結(jié)果,如果為空,說明這個流程已經(jīng)執(zhí)行完畢,否則,獲取任務(wù)并執(zhí)行
 !=null){
 Task task = taskService.createTaskQuery()// 創(chuàng)建查詢對象
  .processInstanceId(processInstanceId)// 通過流程實例id來查詢當(dāng)前任務(wù)
  .singleResult();// 獲取單個查詢結(jié)果
 String taskName = task.getName();
 
 if(taskName.equals("發(fā)起申請")){// 職員節(jié)點
 completeEmployeeTask(task);
 }else if(taskName.equals("領(lǐng)導(dǎo)審批")){// 領(lǐng)導(dǎo)節(jié)點
 completeLeaderTask(task);
 }else{// 經(jīng)理節(jié)點
 completeJingliTask(task);
 }
 }
 
 System.out.println("審核結(jié)束..........");
 }
 
 // 職員提交申請
 void completeEmployeeTask(Task task){
 // 獲取任務(wù)id
 String taskId = task.getId();
 
 // 完成任務(wù)
 engine.getTaskService().complete(taskId);
 System.out.println("職員已經(jīng)提交申請.......");
 }
 
 // 領(lǐng)導(dǎo)審批
 void completeLeaderTask(Task task){
 // 獲取任務(wù)id
 String taskId = task.getId();
 
 // 領(lǐng)導(dǎo)意見
 Map<String, Object> variables = new HashMap<>();
 variables.put("leaderResult", 1);
 
 // 完成任務(wù)
 engine.getTaskService().complete(taskId, variables);
 System.out.println("領(lǐng)導(dǎo)審核完畢........");
 
 }
 
 // 經(jīng)理審批
 void completeJingliTask(Task task){
 // 獲取任務(wù)id
 String taskId = task.getId();
 String name = task.getName();
 
 // 經(jīng)理意見
 // 領(lǐng)導(dǎo)意見和經(jīng)理意見,用0和1表示,0表示未通過,1表示通過
 // 任一環(huán)節(jié)設(shè)置不同意,陷入死循環(huán)
 Map<String, Object> variables = new HashMap<>();
 variables.put("result", 1);
 
 // 完成任務(wù)
 engine.getTaskService().complete(taskId, variables);
 System.out.println("經(jīng)理審核完畢........,審核經(jīng)理:"+name);
 
 }