1、前言介绍
1.1 Activiti简介
Activiti是基于Apache许可的开源BPM平台,创始人Tom Baeyens原是JBPM架构师,BPM是由Alfresco软件发布的业务流程管理(BPM)框架,它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。
1.2 springboot 整合 Activiti7
activiti7提供了对springboot的场景starter(activiti-spring-boot-starter)和相应的依赖管理的包,所有整合过程相对简单。
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring-boot-starter</artifactId>
<version>7.1.0.M5</version>
</dependency>
<dependency>
<groupId>org.activiti.dependencies</groupId>
<artifactId>activiti-dependencies</artifactId>
<version>7.1.0.M5</version>
<type>pom</type>
</dependency>
但是,Activiti7默认使用了Spring Security做权限认证,反而不利于使用。
2、Activiti 数据库表结构
2.1 表名称说明
表分类 | 分类说明 |
---|---|
act_hi_* | 'hi’表示 history,此前缀的表包含历史数据,如历史(结束)流程实例,变量,任务等等。 |
act_ge_* | 'ge’表示 general,此前缀的表为通用数据,用于不同场景中。 |
act_evt_* | 'evt’表示 event,此前缀的表为事件日志。 |
act_procdef_* | 'procdef’表示 processdefine,此前缀的表为记录流程定义信息。 |
act_re_* | 're’表示 repository,此前缀的表包含了流程定义和流程静态资源(图片,规则等等)。 |
act_ru_* | 'ru’表示 runtime,此前缀的表是记录运行时的数据,包含流程实例,任务,变量,异步任务等运行中的数据。Activiti只在流程实例执行过程中保存这些数据,在流程结束时就会删除这些记录。 |
2.2 表注释
表名 | 表注释 |
---|---|
act_ge_bytearray | 二进制数据表,存储通用的流程定义和流程资源。 |
act_ge_property | 系统相关属性,属性数据表存储整个流程引擎级别的数据,初始化表结构时,会默认插入三条记录。 |
act_re_deployment | 部署信息表 |
act_re_model | 流程设计模型部署表 |
act_re_procdef | 流程定义数据表 |
act_ru_deadletter_job | 作业死亡信息表,作业失败超过重试次数 |
act_ru_event_subscr | 运行时事件表 |
act_ru_execution | 运行时流程执行实例表 |
act_ru_identitylink | 运行时用户信息表 |
act_ru_integration | 运行时积分表 |
act_ru_job | 运行时作业信息表 |
act_ru_suspended_job | 运行时作业暂停表 |
act_ru_task | 运行时任务信息表 |
act_ru_timer_job | 运行时定时器作业表 |
act_ru_variable | 运行时变量信息表 |
act_hi_actinst | 历史节点表 |
act_hi_attachment | 历史附件表 |
act_hi_comment | 历史意见表 |
act_hi_detail | 历史详情表,提供历史变量的查询 |
act_hi_identitylink | 历史流程用户信息表 |
act_hi_procinst | 历史流程实例表 |
act_hi_taskinst | 历史任务实例表 |
act_hi_varinst | 历史变量表 |
act_evt_log | 流程引擎的通用事件日志记录表 |
act_procdef_info | 流程定义的动态变更信息 |
3、Acticiti核心类介绍
类名 | 类说明 |
---|---|
ProcessEngine | 流程引擎的抽象,可以通过此类获取流程引擎需要的所有服务。 |
Service类 | 通过ProcessEngine获取,Activiti将不同生命周期的服务封装在不同Service中,包括定义、部署、运行。通过服务类可获取相关生命周期中的服务信息。 |
taskService | 流程运行过程中,每个任务节点的相关操作接口,如complete,delete,delegate等。 |
RepositoryService | 流程定义和部署相关的存储服务 |
RuntimeService | 流程运行时相关的服务,如根据流程好启动流程实例startProcessInstanceByKey。 |
HistoryService | 历史记录相关服务接口。 |
ProcessRuntime | Process相关功能封装,方便使用,@PreAuthorize("hasRole('ACTIVITI_USER')") |
TaskRuntime | taskService封装,方便使用,限制权限 |
3、使用流程介绍
资源类似java中的类,启动实例就是类的实例化。
3.1、 部署流程
/**
* 部署流程
*/
repositoryService.createDeployment()
.addClasspathResource("bpm/askForLeaveBpm.bpmn")
.addClasspathResource ("bpm/test.png")
.name("请假流程")
.key("ASK_FOR_LEAVE_ACT")
.deploy();
System.out.println("流程部署成功!");
3.1、启动一个流程实例
/**
* 启动流程实例
*/
public void startProcess() {
String processDefinitionKey = "ASK_FOR_LEAVE_ACT";
Map map = new HashMap<> ();
//使用UEL 表达式设置
// 学生填写申请单 Assignee:${student}
map.put ("student", "lucy");
// 班主任审批 Assignee:${teacher}
map.put ("teacher", "jack");
ProcessInstance instance = runtimeService.startProcessInstanceByKey (processDefinitionKey, map);
System.out.println ("流程实例ID:" + instance.getId ());
System.out.println ("流程定义ID:" + instance.getProcessDefinitionId ());
}
3.1、查询当前流程中等待执行的任务
/**
* 任务查询
*/
public List searchTask() {
//流程启动后,各各任务的负责人就可以查询自己当前需要处理的任务,查询出来的任务都是该用户的待办任务。
List list = taskService.createTaskQuery ()
//流程实例key
.processDefinitionKey ("test01")
//查询谁的任务
//.taskAssignee("")
.list ();
List idList = new ArrayList ();
for (Task task : list) {
idList.add (task.getId ());
System.out.println ("任务ID:" + task.getId ());
System.out.println ("任务名称:" + task.getName ());
System.out.println ("任务的创建时间:" + task.getCreateTime ());
System.out.println ("任务的办理人:" + task.getAssignee ());
System.out.println ("流程实例ID:" + task.getProcessInstanceId ());
System.out.println ("执行对象ID:" + task.getExecutionId ());
System.out.println ("流程定义ID:" + task.getProcessDefinitionId ());
}
return idList;
}
3.1、处理任务
/**
* 处理任务
*/
public void disposeTask(List list) {
for (String id : list) {
// 任务id
taskService.complete (id);
System.out.println ("处理任务id:" + id);
}
}
4、禁用springsecurity
Activiti7默认集成springsecurity权限模块,启动服务访问模块时,浏览器会弹出一个登录界面,可通过一下设置禁用。
@SpringBootApplication(
exclude = {
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class,
org.springframework.boot.actuate.autoconfigure.security.servlet.ManagementWebSecurityAutoConfiguration.class
})