spring boot 2 +activiti 6

package com.example.demo; import com.example.demo.dao.LeaveBillDao; import com.example.demo.dao.UserDao; import com.example.demo.model.LeaveBill; import com.example.demo.utils.ActivitiUtils; 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.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.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; @RunWith(SpringRunner.class) @SpringBootTest public class ActivitiTest { @Autowired RuntimeService runtimeService; @Autowired RepositoryService repositoryService; @Autowired TaskService taskService; @Autowired ActivitiUtils activitiUtils; @Autowired UserDao userDao; @Autowired LeaveBillDao leaveBillDao; @Test public void createProcessIns() { repositoryService.createDeployment() .name("请假审批流程") .addClasspathResource("processes/leave.bpmn") .addClasspathResource("processes/leave.png") .deploy(); } @Test public void deleteProcess(){ String deploymentId ="27501"; repositoryService .deleteDeployment(deploymentId,true); } @Test public void startProcess() { String bussinessId = UUID.randomUUID().toString(); String userId = "1"; String reason = "病假"; String day = "6"; //业务代码 LeaveBill leaveBill = new LeaveBill(); leaveBill.setId(bussinessId); leaveBill.setUserId(userId); leaveBill.setReason(reason); leaveBill.setDay(day); leaveBillDao.insert(leaveBill); //流程记录 Map<String, Object> variables = new HashMap<>(); variables.put("userId", userId); variables.put("reason", reason); variables.put("day", day); runtimeService.startProcessInstanceByKey("leaveProcess", bussinessId, variables); activitiUtils.setOwner(bussinessId,userId); } @Test public void getProcessInstId(){ ProcessInstance processInstance = runtimeService.createProcessInstanceQuery() .processInstanceBusinessKey("5f6c1124-85bc-4551-ae33-9b799839f060") .singleResult(); System.out.println(processInstance.getBusinessKey()); System.out.println(processInstance.getProcessInstanceId() ); } @Test public void processDefintion() { List<Deployment> list = repositoryService .createDeploymentQuery() .orderByDeploymentId() .asc() .list(); for (Deployment deployment :list){ System.out.println(deployment.getId()); } } @Test public void suspend(){ String processDefinitionKey ="leaveProcess"; activitiUtils.suspend(processDefinitionKey); } @Test public void active(){ String processDefinitionKey ="leaveProcess"; activitiUtils.activate(processDefinitionKey); } /** * 查询任务 * 根据任务的申请人查询正在执行任务(通过act_ru_task数据表) */ @Test public void testQueryTaskByOwner() { // 当前用户当前正在执行的所有的任务 String userId = "1"; List<Task> tasks = taskService .createTaskQuery() .orderByTaskCreateTime() .desc() .taskOwner(userId) .list(); for (Task task : tasks) { System.out.println(task.getName()); System.out.println(task.getOwner()); System.out.println(task.getId()); } } /** * 查询任务 * 根据任务的执行人查询正在执行任务(通过act_ru_task数据表) */ @Test public void testQueryTaskByAssignee() { // 当前用户当前正在执行的所有的任务 String userId = "1"; List<Task> tasks = taskService .createTaskQuery() .orderByTaskCreateTime() .desc() .taskAssignee(userId) .list(); for (Task task : tasks) { System.out.println(task.getName()); System.out.println(task.getAssignee()); System.out.println(task.getId()); } } /** * 进入下一级审批,并进行下一个节点的审批人员的信息的传递 */ @Test public void nextTask() { String taskId = "37508"; String user = "总经理"; Map<String, Object> map = new HashMap<>(); map.put("user", user); map.put("users","主管经理，分管经理"); taskService.complete(taskId,map); } @Test public void claim(){ String taskId = "32503"; String userId = "7"; taskService .claim(taskId,userId); } @Test public void findProcessDefinition(){ List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list(); for(ProcessDefinition processDefinition:list) { System.out.println(processDefinition.getId()); System.out.println(processDefinition.getDeploymentId()); System.out.println(processDefinition.getName()); } List<Deployment> list1 = repositoryService.createDeploymentQuery() .orderByDeploymentId() .desc() .list(); } }