代码提交

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

@@ -211,7 +211,6 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
 
     private void handleRequestBasedOnType(WebsocketExecuteReq executeReq, TopicTypeEnums typeEnums, WebSocketSession session, String payload) {
         WebsocketResult result;
-        int sendBy = 0;
         switch (typeEnums) {
             case PRODUCT_EVENT_NOTICE:
             case PRODUCT_SERVICE_REPLY:
@@ -230,7 +229,9 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
                 result = WebsocketResult.replyError(executeReq, ErrorMsgConstants.ERROR_TOPIC);
                 break;
         }
-
+        if (ObjectUtil.isEmpty(result)){
+            return;
+        }
         final boolean sendFlag = WebSocketUtils.sendMessage(session, result);
         if (sendFlag) {
             websocketMsgService.sendSuccessMsg(result, executeReq.getId());