From 512a4af30988171a1d14e656880eff4d615d31d7 Mon Sep 17 00:00:00 2001 From: zhaoyz <2@2.com> Date: Mon, 29 Apr 2024 14:32:19 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9C=E7=A8=8B=E7=AE=A1=E7=90=86=E7=BB=99?= =?UTF-8?q?=E8=8D=AFws=E5=85=B3=E9=97=AD=E4=BA=8B=E4=BB=B6=E5=A4=84?= =?UTF-8?q?=E7=90=86=E9=94=99=E8=AF=AF=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/rax/vital/timer/VitalSignTimer.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/vital-signs/src/main/java/com/rax/vital/timer/VitalSignTimer.java b/vital-signs/src/main/java/com/rax/vital/timer/VitalSignTimer.java index 15fa2d7..94b36ce 100644 --- a/vital-signs/src/main/java/com/rax/vital/timer/VitalSignTimer.java +++ b/vital-signs/src/main/java/com/rax/vital/timer/VitalSignTimer.java @@ -1,6 +1,5 @@ package com.rax.vital.timer; -import cn.hutool.core.collection.ConcurrentHashSet; import com.alibaba.fastjson.JSONObject; import com.rax.common.security.util.SecurityUtils; import com.rax.vital.datasource.MongoDBSource; @@ -21,7 +20,6 @@ import java.io.IOException; import java.sql.Connection; import java.util.*; import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.ConcurrentMap; /** * 生命体征和用药信息推送 @@ -316,7 +314,7 @@ public class VitalSignTimer { public void removeWSAIFlagSession(WebSocketSession session) { userSessionMap.remove(session.getId()); if (userDatabaseSessionMap.containsValue(session.getId())) { - for (String database : userDatabaseSessionMap.values()) { + for (String database : userDatabaseSessionMap.keySet()) { if (userDatabaseSessionMap.get(database).equals(session.getId())) { userDatabaseSessionMap.remove(database); } @@ -365,10 +363,10 @@ public class VitalSignTimer { machineSessionMap.put(session.getId(), session); } - public void removeMachineSessionMap(WebSocketSession session) throws IOException { + public void removeMachineSessionMap(WebSocketSession session) throws Exception { machineSessionMap.remove(session.getId()); if (machineDatabaseSessionMap.containsValue(session.getId())) { - for (String database : machineDatabaseSessionMap.values()) { + for (String database : machineDatabaseSessionMap.keySet()) { if (machineDatabaseSessionMap.get(database).equals(session.getId())) { machineDatabaseSessionMap.remove(database); }