在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 后续设置审批人必须是系统用户
否则会报错

第二步 添加配置

springactiviti:#    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. 流程定义部署

    @Testpublic 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. 启动一个流程实例

  //启动实例@Testpublic 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@Testpublic 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. 用户办理任务 （处理任务）

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

5. 查询已经处理的任务

   @Testpublic 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@Testpublic 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());}

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

挂起，激活流程实例

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

1. 全部流程实例挂起

    @Testpublic 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("挂起了");}}

2. 单个的流程实例挂起

   @Testpublic 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("挂起了");}}