From d2bcd5c64ac61fb597c52d04c3a7507b45616d59 Mon Sep 17 00:00:00 2001
From: zlzw <583819556@qq.com>
Date: Tue, 10 Dec 2024 09:51:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/yutou/biliapi/net/WebSocketServer.java     | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/yutou/biliapi/net/WebSocketServer.java b/src/main/java/com/yutou/biliapi/net/WebSocketServer.java
index a2de8f3..26b6626 100644
--- a/src/main/java/com/yutou/biliapi/net/WebSocketServer.java
+++ b/src/main/java/com/yutou/biliapi/net/WebSocketServer.java
@@ -23,6 +23,7 @@ import com.yutou.common.okhttp.HttpCallback;
 import com.yutou.common.utils.ConfigTools;
 import com.yutou.common.utils.Log;
 import jakarta.annotation.Resource;
+import lombok.Setter;
 import okhttp3.Headers;
 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.handshake.ServerHandshake;
@@ -86,13 +87,13 @@ public class WebSocketServer {
 
     public void stopRoom(String roomId, boolean isUser) {
         LiveRoomConfig roomConfig = new LiveRoomConfig();
-        roomConfig.setRoomId(new String(roomId));
+        roomConfig.setRoomId(roomId);
         if (checkRoom(roomConfig)) {
             roomMap.get(roomConfig).close();
             roomMap.remove(roomConfig);
         }
         if (isUser) {
-            userStopList.add(roomConfig.getRoomId().toString());
+            userStopList.add(roomConfig.getRoomId());
         }
     }
 
@@ -120,7 +121,7 @@ public class WebSocketServer {
             LiveApi api = BiliLiveNetApiManager.getInstance().getApi(roomConfig.getLoginUid());
             Response<HttpBody<LiveRoomInfo>> execute = null;
             try {
-                execute = api.getRoomInfo(roomConfig.getRoomId().toString()).execute();
+                execute = api.getRoomInfo(roomConfig.getRoomId()).execute();
                 if (execute.isSuccessful()) {
                     roomConfig.setRoomInfo(execute.body() != null ? execute.body().getData() : null);
                 }
@@ -211,7 +212,7 @@ public class WebSocketServer {
 
         @Override
         public void onError(Exception e) {
-            Log.getDynamicLogger(logTag).info("WebSocketClientTh.onError,{}", roomConfig.getRoomId());
+            Log.getDynamicLogger(logTag).error("WebSocketClientTh.onError,{}", roomConfig.getRoomId());
             Log.e(e);
             roomMap.remove(roomConfig);
             heartbeatTask.cancel();
@@ -262,13 +263,10 @@ public class WebSocketServer {
             }
         }
 
+        @Setter
         private class HeartbeatTask extends TimerTask {
             WebSocketClientTh socket;
 
-            public void setSocket(WebSocketClientTh socket) {
-                this.socket = socket;
-            }
-
             @Override
             public void run() {
                 try {