|
@@ -1199,25 +1199,6 @@ public class WmPackageManager {
|
|
|
List<String> pkgIds =
|
|
|
pkgBatch.stream().map(p -> p.getId()).sorted().collect(Collectors.toList());
|
|
|
|
|
|
- List<String> cPkgIdBatch =
|
|
|
- pkgIds.stream()
|
|
|
- .map(id -> scope.parentId2PkgMap.getOrDefault(id, new ArrayList<>()))
|
|
|
- .flatMap(list -> list.stream())
|
|
|
- .sorted()
|
|
|
- .collect(Collectors.toList());
|
|
|
-
|
|
|
- if (CollUtil.isEmpty(cPkgIdBatch)) {
|
|
|
- log.warn("No child pkg found in batch: {}", i);
|
|
|
- continue;
|
|
|
- }
|
|
|
- List<WmTask> tasks =
|
|
|
- taskService.list(
|
|
|
- Wrappers.<WmTask>lambdaQuery()
|
|
|
- .eq(WmTask::getDelFlag, CommonConstants.STATUS_NORMAL) // filter 2099 rows
|
|
|
- .in(WmTask::getScorePackageId, cPkgIdBatch));
|
|
|
- Map<String, List<WmTask>> cPkg2TaskListMap =
|
|
|
- tasks.stream().collect(Collectors.groupingBy(WmTask::getScorePackageId));
|
|
|
-
|
|
|
List<Map<String, Object>> checkBatch =
|
|
|
sysCheckChainNodeCheckHistoryMapper.getTaskCheckHisForDivisionPkgs(pkgIds);
|
|
|
Map<String, List<Map<String, Object>>> pkg2CheckListMap =
|