package com.lxzn.activiti;
|
|
import org.activiti.engine.ProcessEngine;
|
import org.activiti.engine.RepositoryService;
|
import org.activiti.engine.RuntimeService;
|
import org.activiti.engine.TaskService;
|
import org.activiti.engine.repository.Deployment;
|
import org.activiti.engine.runtime.ProcessInstance;
|
import org.activiti.engine.task.Task;
|
import org.junit.Test;
|
import org.junit.runner.RunWith;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.test.context.junit4.SpringRunner;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@RunWith(SpringRunner.class)
|
@SpringBootTest
|
public class TestActiviti {
|
@Autowired
|
private RuntimeService runtimeService;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private ProcessEngine processEngine;
|
|
/**
|
* 流程定义的部署
|
* activiti表有哪些？
|
* act_re_deployment 部署信息
|
* act_re_procdef 流程定义的一些信息
|
* act_ge_bytearray 流程定义的bpmn文件及png文件
|
*/
|
@Test
|
public void testDeployment() {
|
//ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
RepositoryService repositoryService = processEngine.getRepositoryService();
|
Deployment deployment = repositoryService.createDeployment().addClasspathResource("processes/assign_nc_to_device.bpmn") //添加bpmn资源
|
.name("指派NC文档到设备")
|
.deploy();
|
System.out.println(deployment.getName());
|
System.out.println(deployment.getId());
|
}
|
|
/**
|
* 启动流程实例:
|
* 前提是先已经完成流程定义的部署工作
|
*
|
* 背后影响的表：
|
* ACT_HI_ACTINST 已完成的活动信息
|
* ACT_HI_DETAIL 历史详情
|
* ACT_HI_IDENTITYLINK 参与者信息
|
* ACT_HI_PROCINST 流程实例
|
* ACT_HI_TASKINST 任务实例
|
* ACT_HI_VARINST 历史变量
|
* ACT_RU_IDENTITYLINK 执行时 参与者信息
|
* ACT_RU_EXECUTION 执行表
|
* ACT_RU_TASK 当前任务
|
* ACT_RU_VARIABLE 执行时 参数信息
|
*/
|
@Test
|
public void testStartInstance() {
|
//3.创建流程实例 流程定义的key需要知道 holiday
|
String applyUser = "1255172650880737281";
|
//String[] approveUsers = {"1254773336467689474", "1254966905669160962"};
|
String approveUsers = "1254773336467689474, 1254966905669160962";
|
String businessKey = "111111";
|
String key = "assign_nc_to_device";
|
Map<String, Object> map = new HashMap<>();
|
|
map.put("apply_user", applyUser);
|
map.put("approve_users", approveUsers);
|
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(key, businessKey, map);
|
|
//4.输出实例的相关信息
|
System.out.println("流程部署ID"+processInstance.getDeploymentId());//null
|
System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//holiday:1:4
|
System.out.println("流程实例ID"+processInstance.getId());//2501
|
System.out.println("活动ID"+processInstance.getActivityId());//null
|
}
|
|
/**
|
* 从ACT_RU_TASK表中获取当前用户的任务列表
|
* 从ACT_RU_TASK表中获取taskId的任务
|
*/
|
@Test
|
public void testCompleteTask() {
|
//获取用户的任务列表
|
//List<Task> taskList = taskService.createTaskQuery().taskAssignee("1255172650880737281").list();
|
Task task = taskService.createTaskQuery().taskId("7509").singleResult();
|
if(task != null) {
|
//4.任务列表的展示
|
System.out.println("流程实例ID:"+task.getProcessInstanceId());
|
System.out.println("任务ID:"+task.getId()); //5002
|
System.out.println("任务负责人:"+task.getAssignee());
|
System.out.println("任务名称:"+task.getName());
|
taskService.complete(task.getId());
|
}
|
}
|
|
@Test
|
public void testCandidateUser() {
|
String key = "assign_nc_to_device";
|
String candidate_user = "1254773336467689474";
|
// List<Task> taskList = taskService.createTaskQuery().processDefinitionKey(key).taskCandidateUser(candidate_user)//设置候选用户
|
// .list();
|
// taskList.forEach(System.out::println);
|
Task task = taskService.createTaskQuery().processDefinitionKey(key)
|
.taskCandidateUser(candidate_user).singleResult();
|
if(task != null) {
|
taskService.claim(task.getId(), candidate_user);
|
System.out.println("拾取任务成功");
|
taskService.complete(task.getId());
|
System.out.println("完成任务成功");
|
}
|
}
|
}
|
