From dd6402d8b615a3758721e6cdb4864ccda665ef92 Mon Sep 17 00:00:00 2001
From: zzz <1720989295@qq.com>
Date: Tue, 16 Dec 2025 18:46:37 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B4=A8=E5=AE=89=E7=AE=A1=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../websocket/service/BigScreenWebSocketServer.java         | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/websocket/service/BigScreenWebSocketServer.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/websocket/service/BigScreenWebSocketServer.java
index 0bb1123e..caf8dd18 100644
--- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/websocket/service/BigScreenWebSocketServer.java
+++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/websocket/service/BigScreenWebSocketServer.java
@@ -59,18 +59,16 @@ public class BigScreenWebSocketServer {
     public void onOpen(Session session) {
         // 从连接URL的查询参数中获取订阅ID（客户端连接格式：ws://xxx/websocket/bigScreen?subscriptionId=123）
         Map<String, List<String>> params = session.getRequestParameterMap();
-        Long timeType;
+
         List<String> subscriptionIds = params.get("subscriptionId");
         if (subscriptionIds != null && !subscriptionIds.isEmpty()) {
             this.currentSubscriptionId = subscriptionIds.get(0); // 取第一个订阅ID
-            timeType = Long.parseLong(params.get("timeType").getFirst());
             // 建立映射关系
             SUBSCRIPTION_SESSIONS.put(currentSubscriptionId, session);
             SESSION_TO_SUBSCRIPTION.put(session.getId(), currentSubscriptionId);
             log.info("📌 客户端订阅成功！订阅ID：{}，会话ID：{}，当前订阅数：{}",
                     currentSubscriptionId, session.getId(), SUBSCRIPTION_SESSIONS.size());
         } else {
-            timeType = null;
             log.warn("📌 客户端连接未携带订阅ID！会话ID：{}", session.getId());
         }
 
@@ -98,6 +96,8 @@ public class BigScreenWebSocketServer {
                     case 1:
                         break;
                     case 2:
+                        Long timeType;
+                        timeType = Long.parseLong(params.get("timeType").getFirst());
                         //判断参数
                         if (timeType == null || (timeType != 1L && timeType != 2L && timeType != 3L)){
                             throw new RuntimeException("时间类型参数错误");