<?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>

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

    }

}