spring-boot-activiti集成

package com.activiti; import org.activiti.engine.*; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.history.HistoricTaskInstance; import org.activiti.engine.history.HistoricVariableInstance; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; 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.io.InputStream; import java.util.*; @RunWith(SpringRunner.class) @SpringBootTest public class DemoActivitiSpringBootApplicationTests { //RepositoryService 流程仓库Service，用于管理流程仓库，例如部署、删除、读取流程资源 //IdentityService 身份Service，用于管理和查询用户、组之间的关系 //RuntimeService 运行时Service，可以也拿过来处理所有正在运行状态的流程实例、任务等 //TaskService 任务Service，用于管理和查询任务，例如签收、办理、指派等 //FormService 表单Service，用于读取流程、任务相关的表单数据 //HistoryService 历史Service，用于查询所有历史数据，例如流程实例、任务、活动、变量、附件 //ManagementService 引擎管理Service，和具体业务无关，主要可以查询引擎配置、数据库、作业等 //1.创建核心引擎对象 @Autowired private ProcessEngine processEngine; //单个 //private ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //多个 //private Map<String,ProcessEngine> processEngines = ProcessEngines.getProcessEngines(); @Autowired private RepositoryService repositoryService; @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; //引擎数量 @Test public void getEngineSize(){ Map<String,ProcessEngine> engines = ProcessEngines.getProcessEngines(); System.out.println(engines.size()); } //******************************（demo1）helloWorld start*******************************// /** * 2 部署流程定义 */ @Test public void deploymentProcessDefinition() { Deployment deployment = repositoryService// 与流程定义和部署对象相关的service .createDeployment()// 创建一个部署对象 .name("helloworld入门程序")// 添加部署的名称 .addClasspathResource("processes/helloworld.bpmn")// classpath的资源中加载，一次只能加载一个文件 .addClasspathResource("processes/helloworld.png")// classpath的资源中加载，一次只能加载一个文件 .deploy();// 完成部署 System.out.println("部署ID:" + deployment.getId()); System.out.println("部署名称：" + deployment.getName()); } /** * 3.启动流程实例 */ @Test public void startProcessInstance() { // 流程定义的key String processDefinitionKey = "myProcess"; ProcessInstance pi = runtimeService// 于正在执行的流程实例和执行对象相关的Service .startProcessInstanceByKey(processDefinitionKey);// 使用流程定义的key启动流程实例，key对应hellworld.bpmn文件中id的属性值，使用key值启动，默认是按照最新版本的流程定义启动 System.out.println("流程实例ID:" + pi.getId());// 流程实例ID 101 System.out.println("流程定义ID:" + pi.getProcessDefinitionId()); // 流程定义ID HelloWorld:1:4 } /** * 4 查询当前人的个人任务 */ @Test public void findMyPersonTask() { String assignee = "张三";//被指定（代理）人、角色、权限 List<Task> list = taskService// 与正在执行的认为管理相关的Service .createTaskQuery()// 创建任务查询对象 .taskAssignee(assignee)// 指定个人认为查询，指定办理人 .list(); if (list != null && list.size() > 0) { for (Task task:list) { System.out.println("任务ID:"+task.getId());//12504 System.out.println("任务名称:"+task.getName()); System.out.println("任务的创建时间:"+task); System.out.println("任务的办理人:"+task.getAssignee()); System.out.println("流程实例ID:"+task.getProcessInstanceId()); System.out.println("执行对象ID:"+task.getExecutionId()); System.out.println("流程定义ID:"+task.getProcessDefinitionId()); System.out.println("#################################"); } } } /** * 5.完成我的任务（同时触发下一级任务） */ @Test public void completeMyPersonTask(){ //任务Id String taskId="2504"; //与正在执行的任务管理相关的Service taskService.complete(taskId); System.out.println("完成任务:任务ID:"+taskId); } //******************************（demo1）helloWorld end*******************************// //******************************流程定义的CRUD start*******************************// /** * 查询所有的流程定义 */ @Test public void findProcessDefinition() { List<ProcessDefinition> list = processEngine.getRepositoryService()// 与流程定义和部署对象先相关的service .createProcessDefinitionQuery()// 创建一个流程定义的查询 /** 指定查询条件，where条件 */ // .deploymentId(deploymentId) //使用部署对象ID查询 // .processDefinitionId(processDefinitionId)//使用流程定义ID查询 // .processDefinitionNameLike(processDefinitionNameLike)//使用流程定义的名称模糊查询 /* 排序 */ .orderByProcessDefinitionVersion().asc() // .orderByProcessDefinitionVersion().desc() /* 返回的结果集 */ .list();// 返回一个集合列表，封装流程定义 // .singleResult();//返回惟一结果集 // .count();//返回结果集数量 // .listPage(firstResult, maxResults);//分页查询 if (list != null && list.size() > 0) { for (ProcessDefinition pd : list) { System.out.println("流程定义ID:" + pd.getId());// 流程定义的key+版本+随机生成数 System.out.println("流程定义的名称:" + pd.getName());// 对应helloworld.bpmn文件中的name属性值 System.out.println("流程定义的key:" + pd.getKey());// 对应helloworld.bpmn文件中的id属性值 System.out.println("流程定义的版本:" + pd.getVersion());// 当流程定义的key值相同的相同下，版本升级，默认1 System.out.println("资源名称bpmn文件:" + pd.getResourceName()); System.out.println("资源名称png文件:" + pd.getDiagramResourceName()); System.out.println("部署对象ID：" + pd.getDeploymentId()); System.out.println("#########################################################"); } } } /** * 附加功能，查询最新版本的流程定义 */ @Test public void findLastVersionProcessDefinition() { List<ProcessDefinition> list = processEngine.getRepositoryService() .createProcessDefinitionQuery() .orderByProcessDefinitionVersion().asc() // 使用流程定义的版本升序排列 .list(); /** * Map<String,ProcessDefinition> map集合的key：流程定义的key map集合的value：流程定义的对象 * map集合的特点：当map集合key值相同的情况下，后一次的值将替换前一次的值 */ Map<String, ProcessDefinition> map = new LinkedHashMap<String, ProcessDefinition>(); if (list != null && list.size() > 0) { for (ProcessDefinition pd : list) { map.put(pd.getKey(), pd); } } List<ProcessDefinition> pdList = new ArrayList<ProcessDefinition>( map.values()); if (pdList != null && pdList.size() > 0) { for (ProcessDefinition pd : pdList) { System.out.println("流程定义ID:" + pd.getId());// 流程定义的key+版本+随机生成数 System.out.println("流程定义的名称:" + pd.getName());// 对应helloworld.bpmn文件中的name属性值 System.out.println("流程�