From c55aca77e84607238c3354168a8642176c575ca1 Mon Sep 17 00:00:00 2001
From: gaoluyang <2820782392@qq.com>
Date: 星期二, 10 十一月 2026 11:42:16 +0800
Subject: [PATCH] feat(bpm): 待办任务站内信实时推送
---
yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java b/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java
index 9b9b933..2e73801 100644
--- a/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java
+++ b/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java
@@ -43,7 +43,8 @@
idSessions.put(session.getId(), session);
// 娣诲姞鍒� userSessions 涓�
LoginUser user = WebSocketFrameworkUtils.getLoginUser(session);
- if (user == null) {
+ // 鐢ㄦ埛鎴栫敤鎴风被鍨嬩负绌烘椂涓嶅鐞嗭細ConcurrentHashMap 涓嶅厑璁� null key锛屼細鐩存帴鎶� NPE 鏂紑杩炴帴
+ if (user == null || user.getUserType() == null || user.getId() == null) {
return;
}
ConcurrentMap<Long, CopyOnWriteArrayList<WebSocketSession>> userSessionsMap = userSessions.get(user.getUserType());
@@ -69,7 +70,8 @@
idSessions.remove(session.getId());
// 绉婚櫎浠� idSessions 涓�
LoginUser user = WebSocketFrameworkUtils.getLoginUser(session);
- if (user == null) {
+ // 鐢ㄦ埛鎴栫敤鎴风被鍨嬩负绌烘椂涓嶅鐞嗭細ConcurrentHashMap 涓嶅厑璁� null key锛屼細鐩存帴鎶� NPE 鏂紑杩炴帴
+ if (user == null || user.getUserType() == null || user.getId() == null) {
return;
}
ConcurrentMap<Long, CopyOnWriteArrayList<WebSocketSession>> userSessionsMap = userSessions.get(user.getUserType());
--
Gitblit v1.9.3