SpringBoot Test无页面简单示例

员工请假流程

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

流程图

代码

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（）走流程。循环一次性整个流程走完。

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);
 
    }
 
}

参考博客：https://blog.csdn.net/fly_fly_fly_pig/article/details/81700820

源码地址：https://gitee.com/kylin_lawliet/springboot-demos/tree/master/springboot-activity3

SpringBoot含页面完整示例

流程方面与上方示例代码差不多，加了页面与mybatis plus。就不贴上代码，直接放示例代码吧。

流程图

效果图

源码地址：https://gitee.com/kylin_lawliet/springboot-demos/tree/master/springboot-activity4