From d635db503abc16cb2b552d26e17878b97f3b8e73 Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Tue, 13 Jan 2026 10:10:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84websocket=E5=8F=91=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/nu/websocket/SdWebsocket.java    | 20 +++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/websocket/SdWebsocket.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/websocket/SdWebsocket.java
index c952eb26..5f4693d1 100644
--- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/websocket/SdWebsocket.java
+++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/websocket/SdWebsocket.java
@@ -112,9 +112,25 @@ public class SdWebsocket {
      * @param message
      */
     public void sendMessage(String userId, String message) {
-        log.info("【系统 SdWebsocket】广播，userId:"+userId+"，消息:"+message);
+        log.info("【系统 SdWebsocket】向用户 {} 发送消息: {}", userId, message);
+
+        // 打印所有在线用户
+        StringBuilder userList = new StringBuilder();
+        for (String user : sessionPool.keySet()) {
+            if (userList.length() > 0) {
+                userList.append(", ");
+            }
+            userList.append(user);
+        }
+        log.info("【系统 SdWebsocket】当前在线用户: [{}] 共 {} 人", userList.toString(), sessionPool.size());
+
         Session session = sessionPool.get(userId);
-        session.getAsyncRemote().sendText(message);
+        if (session != null && session.isOpen()) {
+            session.getAsyncRemote().sendText(message);
+            log.debug("【系统 SdWebsocket】消息发送成功");
+        } else {
+            log.warn("【系统 SdWebsocket】用户 {} 不在线或连接已关闭，无法发送消息", userId);
+        }
     }
 
     /**