activiti 工作流实例-实现请假流程

package test.service; import java.io.IOException; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.zip.ZipInputStream; import org.activiti.engine.HistoryService; import org.activiti.engine.IdentityService; import org.activiti.engine.ManagementService; import org.activiti.engine.RepositoryService; import org.activiti.engine.RuntimeService; import org.activiti.engine.TaskService; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.identity.Group; import org.activiti.engine.identity.User; import org.activiti.engine.impl.RepositoryServiceImpl; import org.activiti.engine.impl.persistence.entity.ExecutionEntity; import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity; import org.activiti.engine.impl.pvm.process.ActivityImpl; import org.activiti.engine.impl.pvm.process.ProcessDefinitionImpl; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; public class WorkFlowService { //ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); private RepositoryService repositoryService; private RuntimeService runtimeService; private TaskService taskService; private HistoryService historyService; private ManagementService managementService; private IdentityService identityService; public void setRepositoryService(RepositoryService repositoryService) { this.repositoryService = repositoryService; } public void setRuntimeService(RuntimeService runtimeService) { this.runtimeService = runtimeService; } public void setTaskService(TaskService taskService) { this.taskService = taskService; } public void setHistoryService(HistoryService historyService) { this.historyService = historyService; } public void setManagementService(ManagementService managementService) { this.managementService = managementService; } public void setIdentityService(IdentityService identityService) { this.identityService = identityService; } /** * 部署流程定义 */ public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = this.getClass().getResourceAsStream("helloworld.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("helloworld.png"); Deployment deployment =repositoryService .createDeployment() .name("请假流程") .addInputStream("helloworld.bpmn", inputStreamBpmn) .addInputStream("helloworld.png", inputStreamPng) .deploy(); System.out.println("部署ID:"+deployment.getId()); System.out.println("部署名称"+deployment.getName()); } /**启动流程*/ public ProcessInstance startProcessInstance(String processDefinitionKey ){ ProcessInstance pi = runtimeService .startProcessInstanceByKey(processDefinitionKey); System.out.println("流程实例ID"+pi.getId());//流程实例ID System.out.println("流程定义ID:"+pi.getProcessDefinitionId());//流程定义ID return pi; } /** * 根据流程实例ID获取历史表的流程定义实体 * 当流程走完时，要查询流程定义图只能通过在历史表找到历史流程实例对象 * @param instanceId * @return */ public HistoricProcessInstance getHistoricActivityInstanceByInstanceId(String instanceId){ return historyService.createHistoricProcessInstanceQuery().processInstanceId(instanceId).list().get(0); } /**查询个人任务*/ public List<Task> findMyPersonalTask(String assignee ){ List<Task> list = taskService .createTaskQuery()//创建查询 .taskAssignee(assignee)//根据一个人来查询 //.taskCandidateGroup(assignee)根据组来查询 // .taskCandidateUser(candidateUser)//根据多个人来查询 // .processDefinitionId(processDefinitionId) // .processInstanceId(processInstanceId) // .executionId(executionId) .orderByTaskCreateTime().asc()//根据任务时间升序排序 // .singleResult()// // .count()// // .listPage(firstResult, maxResults);//分页查询 .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()); // System.out.println("########################################################"); // } // } return list; } /** * 根据任务ID获取任务实体 * @param taskId * @return */ public Task getTaskById(String taskId){ Task t= taskService .createTaskQuery().taskId(taskId).singleResult(); return t; } /** * 根据流程实例ID获取任务实体 * @param taskId * @return */ public Task getTaskByProcessInstanceId(String processInstanceId){ Task t= taskService .createTaskQuery().processInstanceId(processInstanceId).singleResult(); return t; } /** * 获取流程定义图 * @param task * @return */ public InputStream getProcessImgByProcessDefinitionId(String processDefinitionId){ ProcessDefinition procDef = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefinitionId).singleResult(); String diagramResourceName = procDef.getDiagramResourceName(); InputStream imageStream = repositoryService.getResourceAsStream( procDef.getDeploymentId(), diagramResourceName); return imageStream; } /** * 获取当前活动节点 * @param task * @return */ public ActivityImpl getActivityImpl(Task task){ ProcessDefinition processDefinition =repositoryService .createProcessDefinitionQuery().processDefinitionId(task.getProcessDefinitionId()).singleResult(); ProcessDefinitionImpl pdImpl = (ProcessDefinitionImpl) processDefinition; String processDefinitionId = pdImpl.getId();// 流程定义ID RepositoryServiceImpl repositoryServiceImpl = (RepositoryServiceImpl) repositoryService ; ProcessDefinitionEntity def = (ProcessDefinitionEntity) repositoryServiceImpl.getDeployedProcessDefinition(processDefinitionId); List<ActivityImpl> activitiList = def.getActivities();//获取当前活动节点 ActivityImpl actImpl = null; ExecutionEntity execution =null ; if(task.getExecutionId()!=null){ execution = (ExecutionEntity) runtimeService .createExecutionQuery().executionId(task.getExecutionId()).singleResult();//获取唯一记录 } // endevent1 if(execution==null){ for (ActivityImpl activityImpl : activitiList) { if(activityImpl.getId().equals("endevent1")){ actImpl = activityImpl; break; } } }else{ String activitiId = execution.getActivityId();//获取活动节点的ID for (ActivityImpl activityImpl : activitiList) { String id = activityImpl.getId(); if (id.equals(activitiId)) {//循环遍历流程定义图，如果活动节点的id==遍历节点的id，此节点就是活动节点，获取的相关的坐标等信息。 actImpl = activityImpl; break; } } } return actImpl; } /** * 获取结束节点 * @param task *