录像完整性代码提交

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/handler/SocWebSocketHandler.java

@@ -1,6 +1,7 @@
 package com.xunmei.mediator.websocket.handler;
 
 import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson2.JSON;
 import com.xunmei.common.core.domain.iot.domain.IotServerInfo;
 import com.xunmei.common.core.enums.iot.IotServerConnectStatus;
@@ -10,7 +11,6 @@ import com.xunmei.mediator.api.server.service.IotServerInfoService;
 import com.xunmei.mediator.websocket.constant.WebSocketConstants;
 import com.xunmei.mediator.websocket.dto.WebsocketExecuteReq;
 import com.xunmei.mediator.websocket.dto.WebsocketResult;
-import com.xunmei.mediator.websocket.enums.TopicTypeEnums;
 import com.xunmei.mediator.websocket.enums.WebsocketStatus;
 import com.xunmei.mediator.websocket.holder.WebSocketSessionHolder;
 import com.xunmei.mediator.websocket.service.RouterService;
@@ -102,7 +102,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
      * @throws Exception 处理消息过程中可能抛出的异常
      */
     @Override
-    /*protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
+    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
         // 从WebSocket会话中获取登录用户信息
         WebSocketSessionHolder.updateToken(session);
         String payload = message.getPayload();
@@ -136,9 +136,9 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
         }
 
 
-    }*/
+    }
 
-    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
+    /*protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
         // 从WebSocket会话中获取登录用户信息
         WebSocketSessionHolder.updateToken(session);
         String payload = message.getPayload();
@@ -194,7 +194,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
         }
 
 
-    }
+    }*/
 
     /**
      * 处理接收到的二进制消息