From 45ef9e340f9bb4b98fd88a758343470dfe125cb3 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期三, 07 五月 2025 17:12:48 +0800
Subject: [PATCH] 苏州地铁推送修改
---
src/main/java/com/whyc/webSocket/ScreenForSZ2Socket.java | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/ScreenForSZ2Socket.java b/src/main/java/com/whyc/webSocket/ScreenForSZ2Socket.java
index 59dc4c3..e3ab15e 100644
--- a/src/main/java/com/whyc/webSocket/ScreenForSZ2Socket.java
+++ b/src/main/java/com/whyc/webSocket/ScreenForSZ2Socket.java
@@ -89,7 +89,7 @@
public Map<String, Object> getStatic(Integer userId) throws InterruptedException {
Map<String, Object> res = new HashMap<>();
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
- CountDownLatch latch = new CountDownLatch(3);
+ CountDownLatch latch = new CountDownLatch(4);
poolExecutor.execute(()->{
//1缁熻鏈烘埧涓暟锛岃澶囦釜鏁帮紝鐢垫睜缁勪釜鏁�
Response<Map> res_inf = battInfService.getAllInfInSz2(userId);
@@ -108,6 +108,12 @@
res.put("res_battState", res_battState);
latch.countDown();
});
+ poolExecutor.execute(()->{
+ //4.涓棿鍦板浘
+ Response<Map> res_station = battInfService.getAllStationInSz2(userId);
+ res.put("res_station", res_station);
+ latch.countDown();
+ });
latch.await(10, TimeUnit.MINUTES);
return res;
--
Gitblit v1.9.1