Activiti7获取当前节点的下一个UserTask节点信息

1. /**
2. * 获取当前任务节点的下一个任务节点
3. *
4. * @param task 当前任务节点
5. * @return 下个任务节点
6. * @throws Exception
7. */
8. public static FlowElement getNextUserFlowElement(org.activiti.api.task.model.Task task) throws Exception {
9. // 取得已提交的任务
10. HistoricTaskInstance historicTaskInstance = activitiUtil.historyService.createHistoricTaskInstanceQuery()
11. .taskId(task.getId()).singleResult();
13. // 获得流程定义
14. ProcessDefinition processDefinition = activitiUtil.repositoryService.getProcessDefinition(historicTaskInstance.getProcessDefinitionId());
16. //获得当前流程的活动ID
17. ExecutionQuery executionQuery = activitiUtil.runtimeService.createExecutionQuery();
18. Execution execution = executionQuery.executionId(historicTaskInstance.getExecutionId()).singleResult();
19. String activityId = execution.getActivityId();
20. UserTask userTask = null;
21. while (true) {
22. //根据活动节点获取当前的组件信息
23. FlowNode flowNode = getFlowNode(processDefinition.getId(), activityId);
24. //获取该节点之后的流向
25. List<SequenceFlow> sequenceFlowListOutGoing = flowNode.getOutgoingFlows();
27. // 获取的下个节点不一定是userTask的任务节点，所以要判断是否是任务节点
28. if (sequenceFlowListOutGoing.size() > 1) {
29. // 如果有1条以上的出线，表示有分支，需要判断分支的条件才能知道走哪个分支
30. // 遍历节点的出线得到下个activityId
31. activityId = getNextActivityId(execution.getId(),
32. task.getProcessInstanceId(), sequenceFlowListOutGoing);
33. } else if (sequenceFlowListOutGoing.size() == 1) {
34. // 只有1条出线,直接取得下个节点
35. SequenceFlow sequenceFlow = sequenceFlowListOutGoing.get(0);
36. // 下个节点
37. FlowElement flowElement = sequenceFlow.getTargetFlowElement();
38. if (flowElement instanceof UserTask) {
39. // 下个节点为UserTask时
40. userTask = (UserTask) flowElement;
41. System.out.println("下个任务为:" + userTask.getName());
42. return userTask;
43. } else if (flowElement instanceof ExclusiveGateway) {
44. // 下个节点为排它网关时
45. ExclusiveGateway exclusiveGateway = (ExclusiveGateway) flowElement;
46. List<SequenceFlow> outgoingFlows = exclusiveGateway.getOutgoingFlows();
47. // 遍历网关的出线得到下个activityId
48. activityId = getNextActivityId(execution.getId(), task.getProcessInstanceId(), outgoingFlows);
49. }
51. } else {
52. // 没有出线，则表明是结束节点
53. return null;
54. }
55. }
57. }

/**
     * 获取当前任务节点的下一个任务节点
     *
     * @param task 当前任务节点
     * @return 下个任务节点
     * @throws Exception
     */
    public static FlowElement getNextUserFlowElement(org.activiti.api.task.model.Task task) throws Exception {
        // 取得已提交的任务
        HistoricTaskInstance historicTaskInstance = activitiUtil.historyService.createHistoricTaskInstanceQuery()
                .taskId(task.getId()).singleResult();

        // 获得流程定义
        ProcessDefinition processDefinition = activitiUtil.repositoryService.getProcessDefinition(historicTaskInstance.getProcessDefinitionId());

        //获得当前流程的活动ID
        ExecutionQuery executionQuery = activitiUtil.runtimeService.createExecutionQuery();
        Execution execution = executionQuery.executionId(historicTaskInstance.getExecutionId()).singleResult();
        String activityId = execution.getActivityId();
        UserTask userTask = null;
        while (true) {
            //根据活动节点获取当前的组件信息
            FlowNode flowNode = getFlowNode(processDefinition.getId(), activityId);
            //获取该节点之后的流向
            List<SequenceFlow> sequenceFlowListOutGoing = flowNode.getOutgoingFlows();

            // 获取的下个节点不一定是userTask的任务节点，所以要判断是否是任务节点
            if (sequenceFlowListOutGoing.size() > 1) {
                // 如果有1条以上的出线，表示有分支，需要判断分支的条件才能知道走哪个分支
                // 遍历节点的出线得到下个activityId
                activityId = getNextActivityId(execution.getId(),
                        task.getProcessInstanceId(), sequenceFlowListOutGoing);
            } else if (sequenceFlowListOutGoing.size() == 1) {
                // 只有1条出线,直接取得下个节点
                SequenceFlow sequenceFlow = sequenceFlowListOutGoing.get(0);
                // 下个节点
                FlowElement flowElement = sequenceFlow.getTargetFlowElement();
                if (flowElement instanceof UserTask) {
                    // 下个节点为UserTask时
                    userTask = (UserTask) flowElement;
                    System.out.println("下个任务为:" + userTask.getName());
                    return userTask;
                } else if (flowElement instanceof ExclusiveGateway) {
                    // 下个节点为排它网关时
                    ExclusiveGateway exclusiveGateway = (ExclusiveGateway) flowElement;
                    List<SequenceFlow> outgoingFlows = exclusiveGateway.getOutgoingFlows();
                    // 遍历网关的出线得到下个activityId
                    activityId = getNextActivityId(execution.getId(), task.getProcessInstanceId(), outgoingFlows);
                }

            } else {
                // 没有出线，则表明是结束节点
                return null;
            }
        }

    }