| | |
|---|
| | | // 判断前置任务是不是和当前任务为同一个executeId |
|---|
| | | // 判断当前任务是否被挂起中 |
|---|
| | | String finalProcessInsId = processInsId; |
|---|
| | | beforeNodes.stream().filter(node -> { |
|---|
| | | beforeNodes = beforeNodes.stream().filter(node -> { |
|---|
| | | if (node.getCurrent()) { |
|---|
| | | return Boolean.TRUE; |
|---|
| | | } |
|---|
| | | HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(finalProcessInsId).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult(); |
|---|
| | | return Objects.nonNull(beforeTask); |
|---|
| | | }).forEach(node -> { |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | beforeNodes.forEach(node -> { |
|---|
| | | if (node.getCurrent()) { |
|---|
| | | if (processLogService.taskIsHangup(taskId, finalProcessInsId)) { |
|---|
| | | node.setTaskStatus(TaskStatusEnum.HANGUP); |
|---|
