| | |
| | | jumpAndWaitTaskKeys.addAll(runtimeTaskKey); |
| | | hisTaskList = hisTaskList.stream().filter(hisTask -> jumpAndWaitTaskKeys.indexOf(hisTask.getTaskDefinitionKey()) == -1).collect(Collectors.toList()); |
| | | List<String> hisTaskKeys = hisTaskList.stream().map(HistoricTaskInstance::getTaskDefinitionKey).distinct().collect(Collectors.toList()); |
| | | |
| | | if (CollectionUtils.isEmpty(hisTaskKeys)) { |
| | | return 0L; |
| | | } |
| | | Map<String, HistoricTaskInstance> hisTaskMap = hisTaskList.stream().collect(Collectors.toMap(HistoricTaskInstance::getTaskDefinitionKey, his -> his)); |
| | | // 查出时间正常的任务key |
| | | List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper()) |
| | |
| | | jumpAndWaitTaskKeys.addAll(runtimeTaskKey); |
| | | hisTaskList = hisTaskList.stream().filter(hisTask -> jumpAndWaitTaskKeys.indexOf(hisTask.getTaskDefinitionKey()) == -1).collect(Collectors.toList()); |
| | | List<String> hisTaskKeys = hisTaskList.stream().map(HistoricTaskInstance::getTaskDefinitionKey).distinct().collect(Collectors.toList()); |
| | | |
| | | if (CollectionUtils.isEmpty(hisTaskKeys)) { |
| | | result.total(0); |
| | | return new ArrayList<>(); |
| | | } |
| | | Map<String, HistoricTaskInstance> hisTaskMap = hisTaskList.stream().collect(Collectors.toMap(HistoricTaskInstance::getTaskDefinitionKey, his -> his)); |
| | | // 查出时间正常的任务key |
| | | List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper()) |
| | |
| | | |
| | | List<String> jumpTaskIds = allJumpTaskList.stream().map(ProcessLog::getTaskId).collect(Collectors.toList()); |
| | | jumpTaskIds.removeAll(rejectTaskIds); |
| | | if(CollectionUtils.isEmpty(rejectTaskIds)) { |
| | | if(CollectionUtils.isEmpty(jumpTaskIds)) { |
| | | return 0L; |
| | | } |
| | | List<HistoricTaskInstance> hisTaskList = historyService.createHistoricTaskInstanceQuery() |
| | |
| | | |
| | | List<String> jumpTaskIds = allJumpTaskList.stream().map(ProcessLog::getTaskId).collect(Collectors.toList()); |
| | | jumpTaskIds.removeAll(rejectTaskIds); |
| | | if(CollectionUtils.isEmpty(rejectTaskIds)) { |
| | | if(CollectionUtils.isEmpty(jumpTaskIds)) { |
| | | result.total(0l); |
| | | return new ArrayList<>(); |
| | | } |