rax/rax-remote-v2
3
0
Fork 0
mirror of https://gitee.com/republicline/rax-remote-v2.git synced 2025-08-24 00:14:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

远程管理给药ws关闭事件处理错误修复

This commit is contained in:
zhaoyz 2024-04-29 14:32:19 +08:00
parent 9820b845d4
commit 512a4af309
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
vital-signs/src/main/java/com/rax/vital/timer/VitalSignTimer.java
View File

@ -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);
}