feature(*): 修复bug

- 修复bug

feature(*): 修复bug
- 修复bug
张志伟
1 parent a7d67547
Showing 1 changed file with 3 additions and 2 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/pub/PubFollowBizService.java
@@ -170,7 +170,8 @@ public class PubFollowBizService {
             return new ArrayList<>();
         }
         List<PubPoolSimpleVO> simpleList = list.stream()
-                .map(PubPoolSimpleVO::with).collect(Collectors.toList());
+                .map(PubPoolSimpleVO::with)
+                .collect(Collectors.toList());
         CompletableFuture<Void>[] futureArr = simpleList.stream()
                 .map(pool -> CompletableFuture.runAsync(() -> {
                     Customer customer = customerService.queryByFrameNo(pool.getVin(), pool.getGroupId());
@@ -185,7 +186,7 @@ public class PubFollowBizService {
                 })).<CompletableFuture<Void>>toArray(CompletableFuture[]::new);
  
         try {
-            CompletableFuture.allOf(futureArr);
+            CompletableFuture.allOf(futureArr).get();
         } catch (Exception e) {
             log.error("数据查询失败", e);
         }