03-Activity代码实现

1 创建bpmn流程

1. resources下新建一个文件夹，名称随意，这里我们叫：bpmn

2. 右键，新创建一个：bpmnFile，名称随意，这里我们叫：hello.bpmn

3. 拖拽生成流程节点信息，这里我们简单操作，视频操作流程如下：

好了，截止目前我们就生成了一个简单的，单节点审批的工作流。接下来我们就将以此流程作为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 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这种进行中数据都会清空，进入到：acthi**表中。

以上我们就完成了一个简单的工作流引擎代码编写与测试。
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
 * 流程编排、流程可视化
 */

}