websocket转发修改提交

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

@@ -152,7 +152,6 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
             WebsocketResult websocketResult = JSON.parseObject(payload, WebsocketResult.class);
             Object obj = websocketResult.getPayload();
             String topic = websocketResult.getTopic();
-            if (ObjectUtil.isNotEmpty(obj)){
                 if (ObjectUtil.isNotEmpty(obj)){
 
                     TopicTypeEnums typeEnums = TopicTypeEnums.matcherTopicTypeEnums(topic);
@@ -189,7 +188,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
                 RouterService routeService = RouterServiceHandler.getRouteService(typeEnums.getProductName(),routingKey);
                 routeService.execute(new WebsocketExecuteReq(event, args,token));
                 //todo 返回iot消息
-            }}
+            }
         } catch (Exception e) {
             log.error("转换消息内容时出错：{}",e);
         }