Activiti 框架

参考资料

1、官方网站：https://www.activiti.org/

Activiti 介绍

Activiti 是一个开源的工作流引擎，它实现了 BPMN 2.0 规范，可以发布设计好的流程定义，并通过 API 进行流程调度。

BPMN2.0 介绍

BPMN（Business Process Modeling Notation）是一种业务流程模型标识的标准语言，用来绘制业务流程图，以便更好地让各部门之间理解业务流程和相互关系，旨在促进业务流程的沟通和理解。

Activiti 相关表

Activiti 框架能够自动生成相关的数据库表，非常的好用。下面介绍一下表的大致作用。

1、ACT_RE_*: RE 表示 Repository。这个前缀的表包含了流程定义和流程静态资源(图片，规则，等等)。

2、ACT_RU_*: RU 表示 Runtime。这个前缀的表包含流程实例，任务，变量，异步任务，等运行中的数据。

3、ACT_HI_*: HI 表示 History。这个前缀的表包含历史数据，比如历史流程实例， 变量，任务等。

4、ACT_GE_*: GE 表示 General。通用数据，用于不同场景下。

5、ACT_ID_*: ID 代表 Identity。这些表中保存的都是身份信息，如用户和组以及两者之间的关系。

Activiti 架构图

1、ProcessEngine：流程引擎的抽象，可以通过此类获取需要的所有服务。
2、XXXService：通过ProcessEngine获取，Activiti将不同生命周期的服务封装在不同Service中，包括定义、部署、运行。

Activiti 流程部署

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
      .addClasspathResource("approval.bpmn20.xml")
      .name("我的流程部署")
      .deploy();

Activiti 流程启动

RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> map = Maps.newHashMap();
map.put("name", "zhangxingr");
map.put("sex", "man");
map.put("age", "21");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("my-process", map);

Activiti 流程查询

List<Task> list = processEngine.getTaskService()
    .createTaskQuery()
    .taskAssignee("王五")
    .list();

Activiti 流程提交

##任务的处理
```java
processEngine.getTaskService()
      .complete("7502");  //参数是任务ID

Activiti 流程定义查询

List<ProcessDefinition> list = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
    .createProcessDefinitionQuery().list();

Activiti 流程状态查询

ProcessInstance pi = processEngine.getRuntimeService() // 获取运行时Service
    .createProcessInstanceQuery() // 创建流程实例查询
    .processInstanceId("2501") // 用流程实例id查询
    .singleResult();

Activiti 流程定义删除

processEngine.getRepositoryService()
      .deleteDeployment("deploymentId", true);

Activiti 流程资源查看

/**将生成图片放到文件夹下*/
String deploymentId = "801";
//获取图片资源名称
List<String> list = processEngine.getRepositoryService()//
    .getDeploymentResourceNames(deploymentId);
//定义图片资源的名称
String resourceName = "";
if(list!=null && list.size()>0){
    for(String name:list){
          if(name.indexOf(".png")>=0){
                resourceName = name;
          }
    }
}
//获取图片的输入流
InputStream in = processEngine.getRepositoryService()//
      .getResourceAsStream(deploymentId, resourceName);
//将图片生成到D盘的目录下
File file = new File("D:/"+resourceName);
//将输入流的图片写到D盘下
FileUtils.copyInputStreamToFile(in, file);

Activiti 历史活动查询

List<HistoricActivityInstance>  list = processEngine.getHistoryService()
    .createHistoricActivityInstanceQuery() // 创建历史活动实例查询
    .processInstanceId("2501") // 执行流程实例id
    .list();

Activiti 历史任务查询

List<HistoricTaskInstance> list = processEngine.getHistoryService() // 历史相关Service
    .createHistoricTaskInstanceQuery() // 创建历史任务实例查询
    .processInstanceId("2501") // 用流程实例id查询
    .list(); 

Activiti 流程定义的挂起

RepositoryService repositoryService = processEngine.getRepositoryService();
String processDefinitionKey ="purchasingflow";
//根据流程定义的key暂停一个流程定义,并且级联挂起该流程定义下的流程实例
repositoryService.suspendProcessDefinitionByKey(processDefinitionKey, true, null);

Activiti 流程实例的挂起

RuntimeService runtimeService = engine.getRuntimeService();
String processInstanceId="1801";
//根据一个流程实例的id挂起该流程实例
runtimeService.suspendProcessInstanceById(processInstanceId);

UEL 分配任务

任务节点设计的时候，assignce 设置为 ${assignee0}，在启动的时候把这个变量带上，Activiti 就可以动态设置流程接收人。

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService=processEngine.getRuntimeService();
//设置assignee的取值
Map<String,Object> map=new HashMap<>();
map.put("assignee0","xiaoyi");
map.put("assignee1","xiaoer");
map.put("assignee2","xiaosan");
ProcessInstance processInstance=runtimeService.startProcessInstanceByKey("holiday",map);

Activiti 监听器分配任务

在流程设计的时候，指定监听器，在监听器中设置流程接收人，这样也可以动态的指定流程接收人。

Activiti 流程变量

在流程进行的过程可以附带一些数据，控制流程的走向，这些数据叫做流程变量。流程变量支持很多类型，包括 String，Integer，Java实体类。作用域分为节点作用域和全流程作用域。

Activiti 查询组任务

多个人都有权力处理某个单据，多个人处理的任务可以称为组任务。

TaskService taskService = processEngine.getTaskService();
String key="myProcess5";
String candidateUser="zhangsan";
//查询
List<Task> list = taskService.createTaskQuery().processDefinitionKey(key).taskCandidateUser(candidateUser).list();

Activiti 拾取组任务

TaskService taskService = processEngine.getTaskService();
//设置查询条件
String key="myProcess5";
String candidateUser="zhangsan";
//查询
Task task = taskService.createTaskQuery().processDefinitionKey(key).taskCandidateUser(candidateUser).singleResult();
if (task!=null){
    taskService.claim(task.getId(),candidateUser);
    System.out.println("任务拾取完毕！");
}

Activiti 候选人完成组任务

TaskService taskService = processEngine.getTaskService();
//设置查询条件
String key = "myProcess5";
String assignee = "zhangsan";
 //查询
List<Task> list = taskService.createTaskQuery().processDefinitionKey(key).taskAssignee(assignee)//设置任务处理人
    .list();
for (Task task : list) {
    taskService.complete(task.getId());
    System.out.println("任务执行完毕");
}

Activiti 归还组任务

//获取taskService
TaskService taskService = processEngine.getTaskService();
//设置查询条件
String key = "myProcess5";
String assignee = "zhangsan";
String candidateUser = "lishi";
//查询
Task task = taskService.createTaskQuery().processDefinitionKey(key).taskAssignee(assignee)//设置任务处理人
    .singleResult();
if (task!=null){
    taskService.setAssignee(task.getId(),null);//把任务归还,把任务执行人设置为 null
    //taskService.setAssignee(task.getId(),candidateUser); 张三把当前任务指定给 lisi 处理
    System.out.println("任务归还完毕");
}

网关介绍

1、排他网关：请假申请，三天以内，部门经理审批流程就结束了，三天以上需要总经理。

2、并行网关：请假申请，需要项目经理和部门经理都审批，两者不分前后，需要两个人全部审批才能进入下个节点。

3、包含网关：你申请请假，如果是病假，找项目经理+财务审批，如果不是找部门经理+财务审批，三者不分前后。说白了就像是排他网关跟并行网关的合体。

全局监听器

全局监听器主要使用的场景就是监控这个流程的启动和结束。

连线监听器

当节点任务完成的时候，经过连线的时候，我们可以在连线上定义类，实现自己的业务逻辑。

节点监听器

在实际项目开发中，任务节点是经常用到的，所以我们必须要会使用节点监听器。