| | |
| | | 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()) |