1 创建bpmn流程
- resources下新建一个文件夹，名称随意，这里我们叫：bpmn
- 右键，新创建一个：bpmnFile，名称随意，这里我们叫：hello.bpmn
- 拖拽生成流程节点信息，这里我们简单操作，视频操作流程如下：
此处为语雀视频卡片，点击链接查看：bpmn操作視頻.mp4
好了，截止目前我们就生成了一个简单的，单节点审批的工作流。接下来我们就将以此流程作为Demo，开始我们的学习之路。
2 部署流程定义
此代码是模拟我们开发好一套审批流程，后续员工就可以发起这个流程
请确保你已正确配置数据库连接（端口、用户名、密码），数据库处于启动状态，并且在本地创建了对应的数据库：activiti（名称可以随意）。
代码编写
@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()); }
上述代码唯一需要注意的地方，就是：addClasspathResource 中的路径，如果读者们与我保持不一致，请记得及时修改。
代码测试
运行单测，会发现日志中打印了大量的DDL语句，这是因为Activiti作为一款成熟的工作流引擎框架，他已经有了完善的数据库：
执行完成我们在最后的日志中看到输出结果：
此时我们去刷新数据库，会发现多了25张表，如下（大概表分类我们放在：04-Activiti拓展篇讲解，这里只讲最简单的上手Demo）：
此时，最关键的来了：我们去：act_re_procdef中会发现有我们刚才的流程定义：
这就验证了我们的流程定义代码测试成功。相当于我们公司现在有了一个单节点的审批流程，后面就等着用户发起，这个流程就可以使用起来。
3 启动流程实例
此代码模拟的就是某个用户开始提交流程，此时就会开启某个流程，如下
@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()); }
这里面需要注意的是：流程实例的key，对应表：act_re_procdef.key字段，二者必须保持一致，也就是bpmn文件id属性值。
当我们执行完成，输出打印如下：
此时我们去：act_ru_task 表中可以看到生成一个新的task数据，即当前用户开启了一个新的流程
同时可以查看到流程的多个任务节点信息：act_ru_execution
4 查询当前任务
此代码模拟员工查询目前审批在哪个节点，好催促对应审批人员进行审批
@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()); } } }
运行后代码输出如下：
5 完成指定任务
此代码模拟某个用户完成对应的节点，即：审批通过/拒绝，流程就会自动流转至下一个节点
@Test public void completePersonalTask(){ // 对应task表的id ProcessEngines.getDefaultProcessEngine() .getTaskService() .complete("2505"); }
需要注意的是，此id对应的是上述：4 查询当前任务 返回任务ID保持一致。
当运行完成后，表：act_ru_task、act_ru_execution这种进行中数据都会清空，进入到：act_hi_**表中。
以上我们就完成了一个简单的工作流引擎代码编写与测试。
6 完整代码汇总
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 * 流程编排、流程可视化 */ }
