From ba98d8ef25006b1ca67688f3cf59cd76428f8a90 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期日, 19 一月 2025 16:54:06 +0800
Subject: [PATCH] 首页推送
---
src/main/java/com/whyc/webSocket/HomeSocket.java | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/HomeSocket.java b/src/main/java/com/whyc/webSocket/HomeSocket.java
index 1698ca7..e9f74d2 100644
--- a/src/main/java/com/whyc/webSocket/HomeSocket.java
+++ b/src/main/java/com/whyc/webSocket/HomeSocket.java
@@ -76,7 +76,7 @@
Map<String, Object> res = new HashMap<>();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
- CountDownLatch latch = new CountDownLatch(5);
+ CountDownLatch latch = new CountDownLatch(6);
poolExecutor.execute(() -> {
//閿佺殑宸ヤ綔鐘舵��
Response resLockState = ainfService.getLockState(userId,urole);
@@ -107,6 +107,12 @@
res.put("resAllCtlLog", resAllCtlLog);
latch.countDown();
});
+ poolExecutor.execute(() -> {
+ //鍦板浘椤堕儴鐨勭鐞嗙殑鍖哄煙鍖呭惈瀛愬尯鍩�
+ Response resAllAinf = ainfService.getHomeAllAinf(userId,urole);
+ res.put("resAllAinf", resAllAinf);
+ latch.countDown();
+ });
latch.await(4, TimeUnit.MINUTES);
} catch (InterruptedException e) {
e.printStackTrace();
--
Gitblit v1.9.1