通过maven完成BPMN的创建,定义流程,部署流程,完成流程等操作
- 代码整合
- 创建maven项目
- 添加log4j日志配置
- 添加activiti配置文件
- 创建数据库 activiti
- java类编写程序生成表
- 如果代码运行,没有生成表,可能是没有读取到activiti的配置文件
- Activiti数据表介绍
- 类关系图
- 工作流引擎创建
- 默认创建方式
- 一般创建方式
- Servcie服务接口
- Service创建方式
- Service总览
- RuntimeService
- TaskService
- HistoryService
- ManagementService
- 绘制流程(定义流程)
- 部署流程
- 完成部署
- 数据库 有哪些变化
- 启动流程实例
- 任务查询
- 完成任务
- 依次完成 lisi、wangwu、zhaoliu的申请
- 数据库整体变化
代码整合
创建maven项目
导入一下依赖
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<slf4j.version>1.6.6</slf4j.version>
<log4j.version>1.2.12</log4j.version>
<activiti.version>7.0.0.Beta1</activiti.version>
</properties>
<dependencies>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-engine</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 模型处理 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-model</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 转换 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-converter</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn json数据转换 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-json-converter</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 布局 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-layout</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- activiti 云支持 -->
<dependency>
<groupId>org.activiti.cloud</groupId>
<artifactId>activiti-cloud-services-api</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- mysql驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.31</version>
</dependency>
<!-- mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.5</version>
</dependency>
<!-- 链接池 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
</dependencies>
添加log4j日志配置
#log4j.rootCategory=INFO, CONSOLE debug info warn error fatal
log4j.rootCategory=debug, CONSOLE, LOGFILE
# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE
# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n
# LOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=d:\activiti.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n
添加activiti配置文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/contex
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">
<!-- 这里可以使用 链接池 dbcp-->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost:3306/activiti" />
<property name="username" value="root" />
<property name="password" value="123456" />
<property name="maxActive" value="3" />
<property name="maxIdle" value="1" />
</bean>
<bean id="processEngineConfiguration"
class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<!-- 引用数据源 上面已经设置好了-->
<property name="dataSource" ref="dataSource" />
<!-- activiti数据库表处理策略 -->
<property name="databaseSchemaUpdate" value="true"/>
</bean>
</beans>
创建数据库 activiti
java类编写程序生成表
/**
* 生成 activiti的数据库表
*/
@Test
public void testCreateDbTable() {
//使用classpath下的activiti.cfg.xml中的配置创建processEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
System.out.println(processEngine);
}
如果代码运行,没有生成表,可能是没有读取到activiti的配置文件
请参考文章 https://blog.csdn.net/m0_46267506/article/details/139333129
执行完成后我们查看数据库, 创建了 25 张表,结果如下:
Activiti数据表介绍
表分类 | 表名 | 解释 |
---|---|---|
一般数据 | ||
ACT_GE_BYTEARRAY | 通用的流程定义和流程资源 | |
ACT_GE_PROPERTY | 系统相关属性 | |
流程历史记录 | ||
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_RE_DEPLOYMENT | 部署单元信息 | |
ACT_RE_MODEL | 模型信息 | |
ACT_RE_PROCDEF | 已部署的流程定义 | |
运行实例表 | ||
ACT_RU_EVENT_SUBSCR | 运行时事件 | |
ACT_RU_EXECUTION | 运行时流程执行实例 | |
ACT_RU_IDENTITYLINK | 运行时用户关系信息,存储任务节点与参与者的相关信息 | |
ACT_RU_JOB | 运行时作业 | |
ACT_RU_TASK | 运行时任务 | |
ACT_RU_VARIABLE | 运行时变量表 |
类关系图
工作流引擎创建
工作流引擎(ProcessEngine),相当于一个门面接口,通过ProcessEngineConfiguration创建processEngine,通过ProcessEngine创建各个service接口。
默认创建方式
将activiti.cfg.xml文件名及路径固定,且activiti.cfg.xml文件中有 processEngineConfiguration的配置, 可以使用如下代码创建processEngine:
//直接使用工具类 ProcessEngines,使用classpath下的activiti.cfg.xml中的配置创建processEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
System.out.println(processEngine);
一般创建方式
//先构建ProcessEngineConfiguration
ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml");
//通过ProcessEngineConfiguration创建ProcessEngine,此时会创建数据库
ProcessEngine processEngine = configuration.buildProcessEngine();
Servcie服务接口
Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口,我们使用这些接口可以就是操作服务对应的数据表
Service创建方式
通过ProcessEngine创建Service
方式如下:
RuntimeService runtimeService = processEngine.getRuntimeService();
RepositoryService repositoryService = processEngine.getRepositoryService();
TaskService taskService = processEngine.getTaskService();
Service总览
简单介绍:
RepositoryService
是activiti的资源管理类,提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的业务流程图需要使用此service将流程定义文件的内容部署到计算机。
除了部署流程定义以外还可以:查询引擎中的发布包和流程定义。
暂停或激活发布包,对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了,激活是对应的反向操作。获得多种资源,像是包含在发布包里的文件, 或引擎自动生成的流程图。
获得流程定义的pojo版本, 可以用来通过java解析流程,而不必通过xml。
RuntimeService
Activiti的流程运行管理类。可以从这个服务类中获取很多关于流程执行相关的信息
TaskService
Activiti的任务管理类。可以从这个类中获取任务的信息。
HistoryService
Activiti的历史管理类,可以查询历史信息,执行流程时,引擎会保存很多数据(根据配置),比如流程实例启动时间,任务的参与者, 完成任务的时间,每个流程实例的执行路径,等等。 这个服务主要通过查询功能来获得这些数据。
ManagementService
Activiti的引擎管理类,提供了对 Activiti 流程引擎的管理和维护功能,这些功能不在工作流驱动的应用程序中使用,主要用于 Activiti 系统的日常维护。
绘制流程(定义流程)
添加节点,然后点击空白处 设置流程的id和name
为每个用户节点指定处理人和名称
- zhangsan 请假申请
下面两个用户节点分别是
Assignee | name |
---|---|
lisi | 组长审批 |
wangwu | 班长审批 |
zhaoliu | 老师审批 |
连接每个节点
更改刚刚创建的文件为ecevtion.bpmn文件 因为创建的文件名是xml结尾的.
保存png图片
最终结果
部署流程
/**
* 部署流程
*/
@Test
public void deploymentTest(){
// 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
// 1、创建ProcessEngine
ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
// 2、得到RepositoryService实例
RepositoryService repositoryService = processEngine.getRepositoryService();
// 3、使用RepositoryService进行部署
Deployment deployment = repositoryService.createDeployment()
.name("请假申请流程")
.addClasspathResource("bpmn/evection.bpmn")
.addClasspathResource("bpmn/evection.png")
//禁止校验文件
//.disableSchemaValidation()
.deploy();
// 4、输出部署信息
System.out.println(deployment.getId()+"流程部署id");
System.out.println(deployment.getName()+"流程部署名称");
}
完成部署
数据库 有哪些变化
ACT_RE_DEPLOYMENT 流程定义部署表,每部署一次增加一条记录
act_ge_bytearray 流程资源表 存储的是bpmn文件和流程图
act_re_procdef 流程定义表,部署每个新的流程定义都会在这张表中增加一条记录 一个BPMN文件可以部署多个。
这些记录包含了与流程定义相关的各种信息,包括流程定义的标识符(ID)、名称、版本号、部署 ID、资源文件名称等。 通常情况下,这些信息是从 BPMN 文件中提取并存储在数据库中的。因此,您可以将 ACT_RE_PROCDEF 表看作是存储了 BPMN 文件中的一些重要信息的映射表
act_re_deployment和act_re_procdef一对多关系,一次部署在流程部署表生成一条记录,但一次部署可以部署多个流程定义,每个流程定义在流程定义表生成一条记录。每一个流程定义在act_ge_bytearray会存在两个资源记录,bpmn和png。
启动流程实例
@Test
public void start(){
// 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
// 1、创建ProcessEngine
ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
// 2、获取RunTimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
// 3、根据流程定义key启动流程 操作的是ACT_RE_PROCDEF的key
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey("myEvection");
System.out.println("流程定义id:" + processInstance.getProcessDefinitionId());
System.out.println("流程实例id:" + processInstance.getId());
System.out.println("当前活动Id:" + processInstance.getActivityId());
}
act_hi_actinst 流程实例执行历史 记录的是流程图已经结束或者这在进行的节点
act_hi_identitylink 流程的参与用户历史信息 当前节点的处理人
act_hi_procinst 流程实例历史信息 就是当前流程实例的开始时间 结束时间 实例id 等信息
act_hi_taskinst 流程任务历史信息以及当前正在执行的任务 就是当前流程实例的执行人 开始时间 结束时间 实例id 等信息 当执行到这个节点的时候就会记录
act_ru_execution 流程执行信息
act_ru_identitylink 流程的参与用户信息
act_ru_task 任务信息 当前正在执行的任务
任务查询
@Test
public void selectTask(){
// 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
// 1、创建ProcessEngine
ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
TaskService taskService = processEngine.getTaskService();
List<Task> list = taskService.createTaskQuery()
//流程Key
.processDefinitionKey("myEvection")
//只查询该任务负责人的任务
.taskAssignee("zhagnsan")
.list();
for (Task task : list) {
System.out.println("流程实例id:" + task.getProcessInstanceId());
System.out.println("任务id:" + task.getId());
System.out.println("任务负责人:" + task.getAssignee());
System.out.println("任务名称:" + task.getName());
}
}
具体的SQL语句是
select distinct RES.* from ACT_RU_TASK RES
inner join
ACT_RE_PROCDEF D
on RES.PROC_DEF_ID_ = D.ID_
WHERE RES.ASSIGNEE_ = ?
and D.KEY_ = ? order by RES.ID_ asc LIMIT ? OFFSET ?
完成任务
// 完成任务
@Test
public void commitTask(){
// 获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取taskService
TaskService taskService = processEngine.getTaskService();
// 根据流程key 和 任务的负责人 查询任务
// 返回一个任务对象
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection") //流程Key
.taskAssignee("zhagnsan") //要查询的负责人
.singleResult();
// 完成任务,参数:任务id
// taskService.complete("2505");
taskService.complete(task.getId());
}
ACT_RU_TASK 由原来的请假申请更新为 组长审批
ACT_RU_IDENTITYLINK 增加了 lisi审批人
ACT_HI_ACTINST 新增了组长审批的数据 同时修改请假申请的完成时间
ACT_HI_IDENTITYLINK 增加了 lisi审批人
ACT_HI_TASKINST 新增了组长审批的数据 同时修改请假申请的完成时间
依次完成 lisi、wangwu、zhaoliu的申请
lisi审批
@Test
public void commitTask(){
// 获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取taskService
TaskService taskService = processEngine.getTaskService();
// 根据流程key 和 任务的负责人 查询任务
// 返回一个任务对象
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection") //流程Key
.taskAssignee("lisi") //要查询的负责人
.singleResult();
// 完成任务,参数:任务id
// taskService.complete("2505");
taskService.complete(task.getId());
}
ACT_RU_TASK 变化
wangwu审批
@Test
public void commitTask(){
// 获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取taskService
TaskService taskService = processEngine.getTaskService();
// 根据流程key 和 任务的负责人 查询任务
// 返回一个任务对象
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection") //流程Key
.taskAssignee("wangwu") //要查询的负责人
.singleResult();
// 完成任务,参数:任务id
// taskService.complete("2505");
taskService.complete(task.getId());
}
ACT_RU_TASK变化
zhaoliu审批
@Test
public void commitTask(){
// 获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取taskService
TaskService taskService = processEngine.getTaskService();
// 根据流程key 和 任务的负责人 查询任务
// 返回一个任务对象
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection") //流程Key
.taskAssignee("zhaoliu") //要查询的负责人
.singleResult();
// 完成任务,参数:任务id
// taskService.complete("2505");
taskService.complete(task.getId());
}
ACT_RU_TASK变化 发现正在进行的流程没了 ,流程结束,没有审批人了
数据库整体变化
ACT_HI_ACTINST
发现正对应画的流程图 从开始节点到结束节点。有开始时间,结束时间,审批人,节点的名称
ACT_HI_IDENTITYLINK
当前所有参与节点审批的人
ACT_HI_PROCINST
更新了结束时间和结束节点的id
ACT_HI_TASKINST
只有流程节点的审批人 没有开始节点和结束节点 也是更新了结束时间
ACT_RU_EXECUTION
变空了,因为没有正在运行的流程实例了 对应的下面的ACT_RU_IDENTITYLINK也变空了
ACT_RU_IDENTITYLINK