在Springboot集成Activiti工作流引擎-引入、调用，测试【基础讲解】

工作流通过计算机对业务流程自动化执行管理
他主要解决的是使在多个参与者之间按照某种“预定义规则”自动进行传递稳定信息或任务的过程
通俗来讲业务上一个玩着的审批流程比如请假，出差外出采购等

工作流引擎就是来解决流程问题的提高我们的工作效率

如果没有工作流引擎我们就需要自己去写逻辑就特别的复杂扩展性还不强

使用工作流引擎业务改变，不需要修改代码
如果是我们自己写的逻辑有可能业务改变，代码也需要改变

那么为什么工作流引擎不用修改代码
因为我们的工作流引擎都实现了一个规范
这个规范要求我们的流程管理与状态字段无关，始终都是读取业务流程图的下一个节点
当业务发生改变我们只需要更新业务流程图即可

常见的工作流引擎有
Activiti、jBPM、Camunda、Flowable 还有我们国产的盘古BPM、云程

https://www.activiti.org/ 官网地址

建模语言BPMN
BPM 意思就是业务流程管理，
BPM 软件根据企业中业务环节的变化，推进人与人之间，人与系统之间以及系统与系统之间的整理及调整的经营方法和解决方案的IT工具

BPMN 意思就是业务流程模型和符号，是一套标准的业务流程建模符号 Activiti就是使用BPMN 进行流程建模和流程执行管理

事件 Event

开始表示一个流程的开始
中间发生的开始和结束事件之间，影响处理流程
结束表示该过程结束
在这里插入图片描述

活动 Activities

活动是工作或任务的一个通用术语，一个活动也可以是一个任务还是可以是一个当前流程的子处理流程
其次你还可以为活动指定不同的类型
比如
用户任务-> 服务任务-> 子流程
在这里插入图片描述

网关 GateWay

用于表示流程的分支与合并
排他网关并行网关包容网关综合网关事件网关

在这里插入图片描述

排他网关只有一条路径会被选择
并行网关所有路径都会被同时选择
包容网关可以同时执行多条线路，也可以在网关上设置条件
事件网关专门为中间捕获事件设置的，允许设置多个输出流指向多个不同的中间捕获事件
当流程执行到事件网关后，流程处于等待状态，需要等抛出事件才能将等待状态转换为活动状态

在这里插入图片描述

流向 Flow
流是连接两个流程节点的连线
顺序流：用一个带实心箭头的实心线表示，用于指定活动执行顺序
信息流：用一条带箭头的虚线表示，用于描述两个独立的业务参与者之间发送和接受的消息流动
关联: 用一根带有线箭头的点线表示，用于将相关的数据，文本，和其他人工信息与流对象联系起来
用于展示活动的输入和输出

在这里插入图片描述

Activiti的使用流程

第一步引入依赖并初始化数据库
引入依赖

第二步通过工具绘画流程图
通过Activiti流程建模工具定义业务流程生成（.bpmn文件）
.bpmn文件就是业务流程定义文件通过xml定义业务流程

第三步流程定义部署
向Activiti部署业务流程定义（.bpmn文件）使用Activiti提供的api向Activiti中部署.bpmn文件
通俗一点就是让Activiti认识要使用的流程

第四步启动一个流程实例
启动一个流程实例表示开始一次业务流程的运行

第五步用户查询代办任务
因为现在流程的业务交给了Activiti管理通过Activiti就可以查询当前流程执行到那里了
当前用户需要执行什么任务这些Activiti都会帮我们管理
我们学习了Activiti的API 就可以了

第六步用户办理任务
用户查询代办任务后，就可以办理某个任务，如果这个任务办理还需要其他用户办理，也不需要我们写代码
Activiti 帮我们完成了

第七步流程结束

Activiti 数据库支持 mysql 等

项目使用

第一步引入依赖

    <dependency>
        <groupId>org.activiti</groupId>
        <artifactId>activiti-spring-boot-starter</artifactId>
        <version>7.1.0.M6</version>
        <exclusions>
            <exclusion>
                <artifactId>mybatis</artifactId>
                <groupId>org.mybatis</groupId>
            </exclusion>
        </exclusions>
    </dependency>

activiti 默认集成了Security 安全框架，当前我们项目里已经集成了Security 后续设置审批人必须是系统用户
否则会报错

第二步添加配置

spring
   activiti:
     #    false:默认，数据库表不变，但是如果版本不对或者缺失表会抛出异常（生产使用）
     #    true:表不存在，自动创建（开发使用）
     #    create_drop: 启动时创建，关闭时删除表（测试使用）
     #    drop_create: 启动时删除表,在创建表 （不需要手动关闭引擎）
     database-schema-update: true
     #监测历史表是否存在，activities7默认不开启历史表
     db-history-used: true
     #none：不保存任何历史数据，流程中这是最高效的
     #activity：只保存流程实例和流程行为
     #audit：除了activity，还保存全部的流程任务以及其属性，audit为history默认值
     #full：除了audit、还保存其他全部流程相关的细节数据，包括一些流程参数
     history-level: full
     #校验流程文件，默认校验resources下的process 文件夹的流程文件
     check-process-definitions: true

第三步：启动项目后如果表不存在会自动创建

表介绍
act_re re表示repository 这个前缀包含了定义和流程静态资源
act_ru ru表示runtime 表示表运行时
act_hi hi表示history 历史数据
act_ge ge表示general 通用数据
在这里插入图片描述

第四步 activiti 设计工具

官网下载地址
https://www.activiti.org/#get-started
官方提供的一个工具
Activiti Modeler
这个工具是 war包测试的话自行去搭建 tomcat

地址 localhost:8080/activiti-explorer
默认用户名密码
kermit kermit

在这个系统里生成流程后然后导出 xml和流程图片

然后把这两个资源导入到resources 里
导入也可以用压缩包方式导入
这些操作就不写了

然后测试

1. 流程定义部署

    @Test
    public void deployProcess(){
        Deployment deploy = repositoryService.createDeployment()
                .addClasspathResource("process/qingjia.bpmn20.xml")
                .addClasspathResource("process/qingjia.png")
                .name("请假流程")
                .deploy();
        System.out.println(deploy.getId());
        System.out.println(deploy.getName());
    }

2. 启动一个流程实例

  //启动实例
    @Test
    public void startProcess(){
        ProcessInstance qingjia = runtimeService.startProcessInstanceByKey("qingjia");
        System.out.println("流程定义ID"+qingjia.getProcessDefinitionId());
        System.out.println("流程实例ID"+qingjia.getId());
        System.out.println("流程活动ID"+qingjia.getActivityId());
    }

3. 用户查询代办任务

    //查询个人代办任务 -- zhangsan
    @Test
    public void findTaskList(){
        String name="zhangsan";
        List<Task> taskList = taskService.createTaskQuery()
                .taskAssignee(name)
                .list();
        taskList.forEach(item->{
            System.out.println("流程实例的ID"+item.getProcessInstanceId());
            System.out.println("任务id"+item.getId());
            System.out.println("任务负责人"+item.getAssignee());
            System.out.println("任务名称"+item.getName());
        });

    }

4. 用户办理任务（处理任务）

    @Test
    public void completTask(){
        String name="zhangsan";
        //查询负责人需要处理的任务 返回一条
        Task task = taskService.createTaskQuery().taskAssignee(name).singleResult();
        //处理任务 参数就是id
        taskService.complete(task.getId());
        //完成后会自动到下一个节点

    }

5. 查询已经处理的任务

   @Test
    public void findcompleteTaskList(){
        String name="zhangsan";
        List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery()
                .taskAssignee(name)
                .finished().list();
        list.forEach(item->{
            System.out.println("流程实例的ID"+item.getProcessInstanceId());
            System.out.println("任务id"+item.getId());
            System.out.println("任务负责人"+item.getAssignee());
            System.out.println("任务名称"+item.getName());
        });

    }

====================================

什么叫流程实例
流程定义 ProcessDefinition和流程实例ProcessInstance是 activiti重要概念
类似于java类和java实例的关系
启动一个流程实例就是启动一个业务流程的运行
一个业务流程就要启动一个实例

让实际业务和activiti表关联（BusinessKey）
比如我们填写了一个请假单一定会有一个请假单的唯一标识
通常会使用这个标识来关联activiti 这个标识在activiti中成为BusinessKey

BusinessKey：业务标识，通常为业务主键，业务标识和流程标识一一对应
业务标识来源于业务系统，存储业务标识就是根据业务标识来关联查询业务系统数据

举例请假启动一个流程实例，将请假单的id作为业务标识存储到activiti中
将来查询activiti的流程实例信息就可以获取请假单的id从而关联查询业务系统里的请节单数据

测试：

 //启动实例 添加BusinessKey
    @Test
    public void startProcessBusinessKey(){
    //startProcessInstanceByKey 参数二
        ProcessInstance qingjia = runtimeService.startProcessInstanceByKey("qingjia","1001");
        System.out.println("流程定义ID"+qingjia.getProcessDefinitionId());
        System.out.println("流程实例ID"+qingjia.getId());
        System.out.println("流程活动ID"+qingjia.getActivityId());
        System.out.println("BusinessKey-业务id"+qingjia.getBusinessKey());
    }

==================================================================

挂起，激活流程实例

应用场景
比如公司每个月的最后一天需要封账，这个时候申请的报销审批就可以挂起

全部流程实例挂起

    @Test
    public void suspendProcessInstance(){
           //1.获取流程定义对象
        ProcessDefinition qingjia = repositoryService.createProcessDefinitionQuery()
                .processDefinitionKey("qingjia")
                .singleResult();
        //2. 调用流程定义对象的方法判断当前状态：挂起 还是激活
        boolean suspended = qingjia.isSuspended();
        //3. 判断挂起还是激活
        //如果 true 挂起状态 就要让他激活
        if(suspended){
            //那就执行激活
            //第一个参数 流程定义的id
            // 第二个参数 是否激活 true
            // 第三个参数 时间点
            repositoryService.activateProcessDefinitionById(qingjia.getId(),true,null);
            System.out.println("激活了");
        }else{
            repositoryService.suspendProcessDefinitionById(qingjia.getId(),true,null);
            System.out.println("挂起了");
        }
    }

单个的流程实例挂起

   @Test
    public void suspendProcessInstanceOne(){
        ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                .processInstanceId("流程实例ID")
                .singleResult();
        boolean suspended = processInstance.isSuspended();
        //如果 true 挂起状态 就要让他激活
        if(suspended){
            //那就执行激活
            //第一个参数 流程定义的id
            // 第二个参数 是否激活 true
            // 第三个参数 时间点
            runtimeService.activateProcessInstanceById("流程实例ID");
            System.out.println("激活了");
        }else{
            runtimeService.startProcessInstanceByKey("流程实例ID");
            System.out.println("挂起了");
        }

    }