质检同步排序

blade-service/blade-manager/src/main/java/org/springblade/manager/service/impl/WbsTreePrivateServiceImpl.java

@@ -472,7 +472,7 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
 
     @Async
     public void refreshRedisCache(List<WbsTreeContract> listContractAdd) {
-        Map<Long, List<String>> contractIdByParentIds = listContractAdd.stream()
+        /*Map<Long, List<String>> contractIdByParentIds = listContractAdd.stream()
                 .filter(contract -> contract.getParentId() != null)
                 .collect(Collectors.groupingBy(WbsTreeContract::getParentId,
                         Collectors.mapping(WbsTreeContract::getContractId, Collectors.toList())));
@@ -480,6 +480,11 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
         for (Long parentId : parentIds) {
             String contractId = contractIdByParentIds.get(parentId).stream().findAny().orElse(null);
             informationQueryClient.AsyncWbsTree("", parentId + "", contractId + "", "", "1");
+        }*/
+
+        List<String> collect = listContractAdd.stream().map(WbsTreeContract::getContractId).distinct().collect(Collectors.toList());
+        for (String id : collect) {
+            informationQueryClient.delAsyncWbsTree(id);
         }
     }