1 创建bpmn流程
resources下新建一个文件夹，名称随意，这里我们叫：bpmn
右键，新创建一个：bpmnFile，名称随意，这里我们叫：hello.bpmn
拖拽生成流程节点信息，这里我们简单操作，视频操作流程如下：
好了，截止目前我们就生成了一个简单的，单节点审批的工作流。接下来我们就将以此流程作为Demo，开始我们的学习之路。
2 部署流程定义
此代码是模拟我们开发好一套审批流程，后续员工就可以发起这个流程
请确保你已正确配置数据库连接（端口、用户名、密码），数据库处于启动状态，并且在本地创建了对应的数据库：activiti（名称可以随意）。
代码编写
上述代码唯一需要注意的地方，就是：addClasspathResource 中的路径，如果读者们与我保持不一致，请记得及时修改。
代码测试
运行单测，会发现日志中打印了大量的DDL语句，这是因为Activiti作为一款成熟的工作流引擎框架，他已经有了完善的数据库：
执行完成我们在最后的日志中看到输出结果：
此时我们去刷新数据库，会发现多了25张表，如下（大概表分类我们放在：04-Activiti拓展篇讲解，这里只讲最简单的上手Demo）：
此时，最关键的来了：我们去：act_re_procdef中会发现有我们刚才的流程定义：
这就验证了我们的流程定义代码测试成功。相当于我们公司现在有了一个单节点的审批流程，后面就等着用户发起，这个流程就可以使用起来。
3 启动流程实例
此代码模拟的就是某个用户开始提交流程，此时就会开启某个流程，如下
这里面需要注意的是：流程实例的key，对应表：act_re_procdef.key字段，二者必须保持一致，也就是bpmn文件id属性值。
当我们执行完成，输出打印如下：
此时我们去：act_ru_task 表中可以看到生成一个新的task数据，即当前用户开启了一个新的流程
同时可以查看到流程的多个任务节点信息：act_ru_execution
4 查询当前任务
此代码模拟员工查询目前审批在哪个节点，好催促对应审批人员进行审批
运行后代码输出如下：
5 完成指定任务
此代码模拟某个用户完成对应的节点，即：审批通过/拒绝，流程就会自动流转至下一个节点
需要注意的是，此id对应的是上述：4 查询当前任务 返回任务ID保持一致。
当运行完成后，表：act_ru_task、act_ru_execution这种进行中数据都会清空，进入到：acthi**表中。
以上我们就完成了一个简单的工作流引擎代码编写与测试。
6 完整代码汇总
Java
运行代码
复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
package com.demo;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
import java.util.List;
public class ActivitiTest {
@Test
public void deploymentProcessDefinition(){
//创建ProcessEngine对象
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取RepositoryService对象
RepositoryService repositoryService = processEngine.getRepositoryService();
//进行部署
Deployment deployment = repositoryService
.createDeployment()
.name("测试入门案例")
.addClasspathResource("bpmn/hello.bpmn")
.deploy();
//输出部署的一些信息
System.out.println("流程部署ID:"+deployment.getId());
System.out.println("流程部署名称:"+deployment.getName());
}
@Test
public void startProcessInstance(){
//获取与正在执行的流程示例和执行对象相关的Service
ProcessInstance processInstance = ProcessEngines.getDefaultProcessEngine().getRuntimeService()
//使用流程定义的key启动实例，key对应bpmn文件中id的属性值，默认按照最新版本流程启动
.startProcessInstanceByKey("myProcess_1");
System.out.println("流程实例ID:"+processInstance.getId());
System.out.println("流程实例定义ID:"+processInstance.getProcessDefinitionId());
}
@Test
public void findPersonalTask(){
//与正在执行的任务相关的Service
List<Task> list = ProcessEngines.getDefaultProcessEngine().getTaskService()
.createTaskQuery() //创建查询任务对象
// .taskAssignee("UserTask") //指定个人任务查询，指定办理人
.list();
if(list != null && list.size() > 0){
for(Task task : list){
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());
}
}
}
@Test
public void completePersonalTask(){
// 对应task表的id
ProcessEngines.getDefaultProcessEngine()
.getTaskService()
.complete("2505");
}
/**
* 1-2-3-4
*
* 2-1-3-4
* 3-1-2-4
* 流程编排、流程可视化
*/
}
