LC/workflow.md at 93ae3a07207e36120c36919ce0cd248678e4439f

whai 93ae3a0720 test(activiti): 添加 Activiti 7 流程引擎测试用例

- 新增流程部署、查询、实例初始化和任务管理等测试方法
- 添加历史记录查询功能
- 更新 NIO 服务器示例代码
- 新增枚举类型和自定义类型处理器- 调整 Spring Cloud服务配置
- 添加新的 BPMN 文件

Changes
Activiti7DemoApplicationTests.java
AioServer.java
AmountBig.java
AmountTypeHandler.java
application.yaml
application.yaml
asdf.bpmn20.xml
ASPIServiceImpl.java
bootstrap.yml
BProviderController.java
BService.java
BSPIServiceImpl.java
cn.whaifree.tech.SPI.SPIService
ConfigController.java
FanxinTest.java
FunctionInterfaceDemo.java
GRRXReference.java
leave.bpmn
leave.png
leave1.bpmn20.xml
LeetCode210_207.java
LeetCode469_1.java
LeetCode1648.java
LeetCode2602.java
P1.java
P1.java
pom.xml
pom.xml
pom.xml
RestConfig.java
sadasf.bpmn20.xml
ScheduledThreadPoolTest.java
ServiceBApplication.java
SPIService.java
TestController.java
ThreadDemo1.java
TransactionConfig.java
workflow.md
Unversioned Files
C:\Users\wenhai\project\javaProject\LeetCode\SpringCloud\GateWay\src\main\resources\application.properties
C:\Users\wenhai\project\javaProject\LeetCode\SpringCloud\GateWay\src\main\java\com\whai\springcloud\gateway\GateWayApplication.java
C:\Users\wenhai\project\javaProject\LeetCode\SpringCloud\GateWay\src\test\java\com\whai\springcloud\gateway\GateWayApplicationTests.java
C:\Users\wenhai\project\javaProject\LeetCode\SpringCloud\GateWay\pom.xml

2024-11-16 20:43:40 +08:00

20 KiB

Raw Blame History

WordFlow 工作流引擎

是一种按照预定义规则【需要符合BPMN规范】进行部署，将业务和节点的流程进行分离【特定形式进行关联】，

二、什么是Activiti7？

Activiti 是一个工作流引擎， activiti 可以将业务系统中复杂的业务流程抽取出来，使用专门的建模语言（BPMN2.0）进行定义，业务系统按照预先定义的流程进行执行

https://www.activiti.org

2.2 Activiti7内部核心机制

1️⃣业务流程图要规范化，需要遵守一套标准。

2️⃣业务流程图本质上就是一个XML文件，而XML可以存放所要的数据。

3️⃣读取业务流程图的过程就是解析XML文件的过程。

4️⃣读取一个业务流程图的结点就相当于解析一个XML的结点，进一步将数据插入到MySQL表中，形成一条记录。

5️⃣将一个业务流程图的所有节点都读取并存入到MySQL表中。

6️⃣后面只要读取MySQL表中的记录就相当于读取业务流程图的一个节点。

7️⃣业务流程的推进，后面就转换为读取表中的数据，并且处理数据，结束的时候这一行数据就可以删除了。

BPMN

BPMN（Business Process Model And Notation），业务流程模型和符号，是由BPMI（Business Process Management Initiative）开发的一套的业务流程建模符号，使用BPMN提供的符号可以创建业务流程。2004年5月发布了BPMN1.0规范。

processOn BPMN 概念

BPMN 的核心元素

活动：活动是 BPMN 中最基本的元素之一，它代表了业务流程中的一个具体任务或操作。可以自动/手动、

事件：事件是 BPMN 中用于表示流程中的特定时刻或状态的元素。例如，开始事件、结束事件、中间事件等。

网关：网关用于控制流程的执行路径，可以实现并行、条件、互斥等多种逻辑。

泳道：泳道用于将流程分解为多个并行的部分，每个泳道代表一个独立的执行路径。

一个BPMN的例子：

当事人填写请假单，启动流程后把请假单ID绑定到流程中；

部门经理对请假单进行审核；

然后人事经理进行复核并进行备案；

最后请假流程结束。

Activiti支持的数据库

Activiti的运行需要数据库的支撑，支持如下:
- h2
- MySQL
- Oracle
- Db2
- postgres
- mysql
在Navicat工具中创建activiti的数据库，用于后续的实验.

Activiti使用步骤

2.4.1 整合Activiti Activiti是一个工作流引擎，业务系统使用Activiti来对系统的业务流程进行自动化管理，为了方便业务系统访问（操作）Activiti的接口或功能，通常将Activiti和业务系统的环境集成在一起。 2.4.2 业务流程建模使用Activiti流程建模工具(Activity-designer)定义业务流程(.bpmn文件)。 .bpmn文件就是业务流程定义文件，通过xml定义业务流程。如果使用其他公司开发的工作引擎一般都提供了可视化的建模工具（Process Designer）用于生成流程定义文件，建模工具操作直观，一般都支持图形化拖拽方式、多窗口的用户界面、丰富的过程图形元素、过程元素拷贝、粘贴、删除等功能。 2.4.3 部署业务流程向Activiti部署业务流程定义(.bpmn文件)。使用Activiti提供的API向Activiti中部署.bpmn文件（一般情况下还需要一起部署业务流程的图片.png）。 2.4.4 启动流程实例启动一个流程实例表示开始一次业务流程的运行，比如员工请假流程部署完成，如果张三要请假就可以启动一个流程实例，如果李四要请假也需要启动一个流程实例，两个流程的执行互不影响，就好比定义一个Java类，实例化两个Java对象一样，部署的流程就好比Java类，启动一个流程实例就好比new一个Java对象。 2.4.5 查询待办任务因为现在系统的业务流程已经交给Activiti管理，通过Activiti就可以查询当前流程执行到哪里了，当前用户需要办理什么任务了，这些Activiti帮我们管理了，而不像传统方式中需要我们在SQL语句中的WHERE条件中指定当前查询的状态值是多少。 2.4.6 处理待办任务用户查询待办任务后，就可以办理某个任务，如果这任务办理完成还需要其他用户办理，比如采购单创建后由部门经理审核，这个过程也是由Activiti帮我们完成了，不需要我们在代码中硬编码指定下一个任务办理人了 2.4.7 结束流程当任务办理完成没有下一个任务/结点了，这个流程实例就完成了。

Service总览

RepositoryService Activiti的资源管理接口：管理和控制流程发布包和流程定义的操作
RuntimeService Activiti的流程运行管理接口：流程执行相关的信息
TaskService Activiti的任务管理接口：
HistoryService Activiti的历史管理接口
ManagementService Activiti的引擎管理接口，管理和维护功能

数据表解读

Activiti 使用到的表都是 ACT_ 开头的，表名的第二部分表示用途。

ACT_GE_ （GE）表示 general 全局通用数据及设置，各种情况都使用的数据。

全局通用数据（ACT_GE_*）

ACT_GE_BYTEARRAY 二进制数据表，存储通用的流程定义和流程资源。

ACT_GE_PROPERTY 系统相关属性，属性数据表存储整个流程引擎级别的数据。

ACT_GE_BYTEARRAY	二进制数据表，存储通用的流程定义和流程资源。
ACT_GE_PROPERTY	系统相关属性，属性数据表存储整个流程引擎级别的数据。

ACT_HI_ （HI）表示 history 历史数据表，包含着程执行的历史相关数据。

ACT_RE_ （RE）表示 repository 存储，包含的是静态信息。

ACT_RU_ （RU）表示 runtime 运行时，运行时的流程变量，用户任务，变量，职责（job）等运行时数据。Activiti 只存储实例执行期间的运行时数据，当流程实例结束时，将删除这些记录（salvio修

流程定义 ProcessDefinition

@Autowired
private RepositoryService repositoryService;
@Test
void queryProcessDe() {
    List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition processDefinition : processDefinitions) {
        System.out.println("流程定义ID:" + processDefinition.getId());
        System.out.println("流程定义名称:" + processDefinition.getName());
        System.out.println("流程定义key:" + processDefinition.getKey());
        System.out.println("流程定义版本:" + processDefinition.getVersion());
        System.out.println("流程部署ID:" + processDefinition.getDeploymentId());
        System.out.println("流程定义资源名称:" + processDefinition.getResourceName());
        System.out.println("流程定义图片资源名称:" + processDefinition.getDiagramResourceName());
        System.out.println("流程定义描述:" + processDefinition.getDescription());
        System.out.println("流程定义分类:" + processDefinition.getCategory());
        System.out.println("======================================================");
    }
    /**
     * Opening JDBC Connection
     * ==>  Preparing: select distinct RES.* from ACT_RE_PROCDEF RES order by RES.ID_ asc LIMIT ? OFFSET ?
     * ==> Parameters: 2147483647(Integer), 0(Integer)
     * <==    Columns: ID_, REV_, CATEGORY_, NAME_, KEY_, VERSION_, DEPLOYMENT_ID_, RESOURCE_NAME_, DGRM_RESOURCE_NAME_, DESCRIPTION_, HAS_START_FORM_KEY_, HAS_GRAPHICAL_NOTATION_, SUSPENSION_STATE_, TENANT_ID_, ENGINE_VERSION_
     * <==        Row: Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec, 1, http://www.activiti.org/processdef, Part1_Deployment, Part1_Deployment, 1, 0c82b70d-a0c1-11ef-9820-6ac6acfdceec, bpmn/leave.bpmn, bpmn/leave.png, null, 0, 1, 1, , null
     * <==      Total: 1
     * Closing JDBC Connection [Transaction-aware proxy for target Connection [HikariProxyConnection@1566233058 wrapping com.mysql.cj.jdbc.ConnectionImpl@17796f47]]
     * 流程定义ID:Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec
     * 流程定义名称:Part1_Deployment
     * 流程定义key:Part1_Deployment
     * 流程定义版本:1
     * 流程部署ID:0c82b70d-a0c1-11ef-9820-6ac6acfdceec
     * 流程定义资源名称:bpmn/leave.bpmn
     * 流程定义图片资源名称:bpmn/leave.png
     * 流程定义描述:null
     * 流程定义分类:http://www.activiti.org/processdef
     * ======================================================
     */
}

流程实例 ProcessInstance

/**
 * 初始化流程实例
 */
@Test
public void initProcessInstance() {
    // 流程定义KEY
    String processDefinitionKey = "Part1_Deployment";
    // 业务表KEY（用于把业务数据与Activiti7流程数据相关联）
    String businessKey = "4208169753200945";
    // 参数
    Map<String, Object> variables = new HashMap<>(16);
    ProcessInstance processInstance = this.runtimeService
            .startProcessInstanceByKey(processDefinitionKey, businessKey, variables);
    System.out.println("流程实例ID：" + processInstance.getProcessInstanceId());
    /**
     * Opening JDBC Connection
     * ==>  Preparing: select * from ACT_RE_PROCDEF where KEY_ = ? and (TENANT_ID_ = '' or TENANT_ID_ is null) and VERSION_ = (select max(VERSION_) from ACT_RE_PROCDEF where KEY_ = ? and (TENANT_ID_ = '' or TENANT_ID_ is null))
     * ==> Parameters: Part1_Deployment(String), Part1_Deployment(String)
     * <==    Columns: ID_, REV_, CATEGORY_, NAME_, KEY_, VERSION_, DEPLOYMENT_ID_, RESOURCE_NAME_, DGRM_RESOURCE_NAME_, DESCRIPTION_, HAS_START_FORM_KEY_, HAS_GRAPHICAL_NOTATION_, SUSPENSION_STATE_, TENANT_ID_, ENGINE_VERSION_
     * <==        Row: Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec, 1, http://www.activiti.org/processdef, Part1_Deployment, Part1_Deployment, 1, 0c82b70d-a0c1-11ef-9820-6ac6acfdceec, bpmn/leave.bpmn, bpmn/leave.png, null, 0, 1, 1, , null
     * <==      Total: 1
     * ==>  Preparing: select * from ACT_RU_VARIABLE where TASK_ID_ = ?
     * ==> Parameters: b25c87dd-a0c3-11ef-8ba8-68c6acfdcef0(String)
     * <==      Total: 0
     * ==>  Preparing: insert into ACT_HI_TASKINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_, EXECUTION_ID_, NAME_, PARENT_TASK_ID_, DESCRIPTION_, OWNER_, ASSIGNEE_, START_TIME_, CLAIM_TIME_, END_TIME_, DURATION_, DELETE_REASON_, TASK_DEF_KEY_, FORM_KEY_, PRIORITY_, DUE_DATE_, CATEGORY_, TENANT_ID_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )
     * ==> Parameters: b25c87dd-a0c3-11ef-8ba8-68c6acfdcef0(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25ab31a-a0c3-11ef-8ba8-68c6acfdcef0(String), UserTask(String), null, null, null, admin(String), 2024-11-12 14:59:44.325(Timestamp), null, null, null, null, sid-192966db-031d-4a50-886d-379935dd9bc1(String), null, 50(Integer), null, null, (String)
     * <==    Updates: 1
     * ==>  Preparing: insert into ACT_HI_PROCINST ( ID_, PROC_INST_ID_, BUSINESS_KEY_, PROC_DEF_ID_, START_TIME_, END_TIME_, DURATION_, START_USER_ID_, START_ACT_ID_, END_ACT_ID_, SUPER_PROCESS_INSTANCE_ID_, DELETE_REASON_, TENANT_ID_, NAME_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )
     * ==> Parameters: b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), 4208169753200945(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), 2024-11-12 14:59:44.311(Timestamp), null, null, null, sid-26d6e725-878e-411d-b23d-6df4ae3cbd24(String), null, null, null, (String), null
     * <==    Updates: 1
     * ==>  Preparing: insert into ACT_HI_ACTINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_, EXECUTION_ID_, ACT_ID_, TASK_ID_, CALL_PROC_INST_ID_, ACT_NAME_, ACT_TYPE_, ASSIGNEE_, START_TIME_, END_TIME_, DURATION_, DELETE_REASON_, TENANT_ID_ ) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) , (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
     * ==> Parameters: b25ada2b-a0c3-11ef-8ba8-68c6acfdcef0(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25ab31a-a0c3-11ef-8ba8-68c6acfdcef0(String), sid-26d6e725-878e-411d-b23d-6df4ae3cbd24(String), null, null, null, startEvent(String), null, 2024-11-12 14:59:44.314(Timestamp), 2024-11-12 14:59:44.316(Timestamp), 2(Long), null, (String), b25b4f5c-a0c3-11ef-8ba8-68c6acfdcef0(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25ab31a-a0c3-11ef-8ba8-68c6acfdcef0(String), sid-192966db-031d-4a50-886d-379935dd9bc1(String), b25c87dd-a0c3-11ef-8ba8-68c6acfdcef0(String), null, UserTask(String), userTask(String), admin(String), 2024-11-12 14:59:44.317(Timestamp), null, null, null, (String)
     * <==    Updates: 2
     * ==>  Preparing: insert into ACT_HI_IDENTITYLINK (ID_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_) values (?, ?, ?, ?, ?, ?)
     * ==> Parameters: b25cd5fe-a0c3-11ef-8ba8-68c6acfdcef0(String), participant(String), admin(String), null, null, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String)
     * <==    Updates: 1
     * ==>  Preparing: insert into ACT_RU_EXECUTION (ID_, REV_, PROC_INST_ID_, BUSINESS_KEY_, PROC_DEF_ID_, ACT_ID_, IS_ACTIVE_, IS_CONCURRENT_, IS_SCOPE_,IS_EVENT_SCOPE_, IS_MI_ROOT_, PARENT_ID_, SUPER_EXEC_, ROOT_PROC_INST_ID_, SUSPENSION_STATE_, TENANT_ID_, NAME_, START_TIME_, START_USER_ID_, IS_COUNT_ENABLED_, EVT_SUBSCR_COUNT_, TASK_COUNT_, JOB_COUNT_, TIMER_JOB_COUNT_, SUSP_JOB_COUNT_, DEADLETTER_JOB_COUNT_, VAR_COUNT_, ID_LINK_COUNT_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) , (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
     * ==> Parameters: b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), 4208169753200945(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), null, true(Boolean), false(Boolean), true(Boolean), false(Boolean), false(Boolean), null, null, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), 1(Integer), (String), null, 2024-11-12 14:59:44.311(Timestamp), null, false(Boolean), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), b25ab31a-a0c3-11ef-8ba8-68c6acfdcef0(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), null, Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), sid-192966db-031d-4a50-886d-379935dd9bc1(String), true(Boolean), false(Boolean), false(Boolean), false(Boolean), false(Boolean), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), null, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), 1(Integer), (String), null, 2024-11-12 14:59:44.313(Timestamp), null, false(Boolean), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer)
     * <==    Updates: 2
     * ==>  Preparing: insert into ACT_RU_TASK (ID_, REV_, NAME_, PARENT_TASK_ID_, DESCRIPTION_, PRIORITY_, CREATE_TIME_, OWNER_, ASSIGNEE_, DELEGATION_, EXECUTION_ID_, PROC_INST_ID_, PROC_DEF_ID_, TASK_DEF_KEY_, DUE_DATE_, CATEGORY_, SUSPENSION_STATE_, TENANT_ID_, FORM_KEY_, CLAIM_TIME_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )
     * ==> Parameters: b25c87dd-a0c3-11ef-8ba8-68c6acfdcef0(String), UserTask(String), null, null, 50(Integer), 2024-11-12 14:59:44.317(Timestamp), null, admin(String), null, b25ab31a-a0c3-11ef-8ba8-68c6acfdcef0(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec(String), sid-192966db-031d-4a50-886d-379935dd9bc1(String), null, null, 1(Integer), (String), null, null
     * <==    Updates: 1
     * ==>  Preparing: insert into ACT_RU_IDENTITYLINK (ID_, REV_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_, PROC_DEF_ID_) values (?, 1, ?, ?, ?, ?, ?, ?)
     * ==> Parameters: b25cd5fe-a0c3-11ef-8ba8-68c6acfdcef0(String), participant(String), admin(String), null, null, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), null
     * <==    Updates: 1
     * Closing JDBC Connection [Transaction-aware proxy for target Connection [HikariProxyConnection@621103114 wrapping com.mysql.cj.jdbc.ConnectionImpl@4ac2b4c6]]
     * 流程实例ID：b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0
     */
}

/**
 * 查询流程实例
 */
@Test
public void getProcessInstance() {
    String processInstanceId = "b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0";
    ProcessInstance processInstance = this.runtimeService.createProcessInstanceQuery()
            .processInstanceId(processInstanceId)
            .singleResult();
    System.out.println("ProcessInstanceId：" + processInstance.getProcessInstanceId());
    System.out.println("ProcessDefinitionId：" + processInstance.getProcessDefinitionId());
    System.out.println("isEnded：" + processInstance.isEnded());
    System.out.println("isSuspended：" + processInstance.isSuspended());
    /**
     * Opening JDBC Connection
     * ==>  Preparing: select distinct RES.* , P.KEY_ as ProcessDefinitionKey, P.ID_ as ProcessDefinitionId, P.NAME_ as ProcessDefinitionName, P.VERSION_ as ProcessDefinitionVersion, P.DEPLOYMENT_ID_ as DeploymentId, S.PROC_INST_ID_ AS PARENT_PROC_INST_ID_ from ACT_RU_EXECUTION RES inner join ACT_RE_PROCDEF P on RES.PROC_DEF_ID_ = P.ID_ left outer join ACT_RU_EXECUTION S on RES.SUPER_EXEC_ = S.ID_ WHERE RES.PARENT_ID_ is null and RES.ID_ = ? and RES.PROC_INST_ID_ = ? order by RES.ID_ asc LIMIT ? OFFSET ?
     * ==> Parameters: b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0(String), 2147483647(Integer), 0(Integer)
     * <==    Columns: ID_, REV_, PROC_INST_ID_, BUSINESS_KEY_, PARENT_ID_, PROC_DEF_ID_, SUPER_EXEC_, ROOT_PROC_INST_ID_, ACT_ID_, IS_ACTIVE_, IS_CONCURRENT_, IS_SCOPE_, IS_EVENT_SCOPE_, IS_MI_ROOT_, SUSPENSION_STATE_, CACHED_ENT_STATE_, TENANT_ID_, NAME_, START_TIME_, START_USER_ID_, LOCK_TIME_, IS_COUNT_ENABLED_, EVT_SUBSCR_COUNT_, TASK_COUNT_, JOB_COUNT_, TIMER_JOB_COUNT_, SUSP_JOB_COUNT_, DEADLETTER_JOB_COUNT_, VAR_COUNT_, ID_LINK_COUNT_, ProcessDefinitionKey, ProcessDefinitionId, ProcessDefinitionName, ProcessDefinitionVersion, DeploymentId, PARENT_PROC_INST_ID_
     * <==        Row: b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0, 1, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0, 4208169753200945, null, Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec, null, b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0, null, 1, 0, 1, 0, 0, 1, null, , null, 2024-11-12 14:59:44.311, null, null, 0, 0, 0, 0, 0, 0, 0, 0, 0, Part1_Deployment, Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec, Part1_Deployment, 1, 0c82b70d-a0c1-11ef-9820-6ac6acfdceec, null
     * <==      Total: 1
     * Closing JDBC Connection [Transaction-aware proxy for target Connection [HikariProxyConnection@1118158255 wrapping com.mysql.cj.jdbc.ConnectionImpl@77eb0e47]]
     * ProcessInstanceId：b25a64f9-a0c3-11ef-8ba8-68c6acfdcef0
     * ProcessDefinitionId：Part1_Deployment:1:0c957bc0-a0c1-11ef-9820-6ac6acfdceec
     * isEnded：false
     * isSuspended：false
     */

    // 查询流程实例列表
    List<ProcessInstance> processInstanceList = this.runtimeService.createProcessInstanceQuery().list();
    if (!CollectionUtils.isEmpty(processInstanceList)) {
        processInstanceList.forEach(pi -> {
            System.out.println("ProcessInstanceId：" + pi.getProcessInstanceId());
            System.out.println("ProcessDefinitionId：" + pi.getProcessDefinitionId());
            System.out.println("isEnded：" + pi.isEnded());
            System.out.println("isSuspended：" + pi.isSuspended());
        });
    }
    // 挂起流程实例
    this.runtimeService.suspendProcessInstanceById(processInstanceId);
    // 激活流程实例
    this.runtimeService.activateProcessInstanceById(processInstanceId);
    // 删除流程实例
    this.runtimeService.deleteProcessInstance(processInstanceId, "测试删除流程实例");
}

20 KiB

Raw Blame History

WordFlow 工作流引擎

二、什么是Activiti7？

BPMN

BPMN 的核心元素

Activiti支持的数据库

Activiti使用步骤

Service总览

数据表解读

ACT_GE_ （GE）表示 general 全局通用数据及设置，各种情况都使用的数据。

全局通用数据（ACT_GE_*）

ACT_HI_ （HI）表示 history 历史数据表，包含着程执行的历史相关数据。

ACT_RE_ （RE）表示 repository 存储，包含的是静态信息。

ACT_RU_ （RU）表示 runtime 运行时，运行时的流程变量，用户任务，变量，职责（job）等运行时数据。Activiti 只存储实例执行期间的运行时数据，当流程实例结束时，将删除这些记录（salvio修

流程定义 ProcessDefinition

流程实例 ProcessInstance

流程符号

事件 Event

网关 GateWay

流向 Flow

20 KiB Raw Blame History Unescape Escape

WordFlow 工作流引擎

二、什么是Activiti7？

BPMN

BPMN 的核心元素

Activiti支持的数据库

Activiti使用步骤

Service总览

数据表解读

ACT_GE_ （GE） 表示 general 全局通用数据及设置，各种情况都使用的数据。

全局通用数据（ACT_GE_*）

ACT_HI_ （HI） 表示 history 历史数据表，包含着程执行的历史相关数据。

ACT_RE_ （RE） 表示 repository 存储，包含的是静态信息。

ACT_RU_ （RU） 表示 runtime 运行时，运行时的流程变量，用户任务，变量，职责（job）等运行时数据。Activiti 只存储实例执行期间的运行时数据，当流程实例结束时，将删除这些记录 （salvio修

流程定义 ProcessDefinition

流程实例 ProcessInstance

流程符号

事件 Event

网关 GateWay

流向 Flow

20 KiB

Raw Blame History

ACT_GE_ （GE）表示 general 全局通用数据及设置，各种情况都使用的数据。

ACT_HI_ （HI）表示 history 历史数据表，包含着程执行的历史相关数据。

ACT_RE_ （RE）表示 repository 存储，包含的是静态信息。

ACT_RU_ （RU）表示 runtime 运行时，运行时的流程变量，用户任务，变量，职责（job）等运行时数据。Activiti 只存储实例执行期间的运行时数据，当流程实例结束时，将删除这些记录（salvio修