北向代码提交

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/holder/WebSocketSessionHolder.java

@@ -129,8 +129,6 @@ public class WebSocketSessionHolder {
             for (WebSocketSession session : USER_SESSION_MAP.values()) {
                 session.sendMessage(new TextMessage(message));
                 x++;
-                String sessionKey = WebSocketSessionHolder.getSessionKey(session);
-                LogUtils.WEBSOCKET_MSG.info("获取设备基础数据,token:{},发送消息内容：{}", sessionKey, message);
             }
             LogUtils.WEBSOCKET_MSG.info("消息广播成功,发送消息内容：{},发送消息数量:{}", message, x);
         } catch (IOException e) {

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/service/impl/WebsocketServiceImpl.java

@@ -85,13 +85,10 @@ public class WebsocketServiceImpl implements WebsocketService, RouterService {
 
     @Override
     public void invokeBaseDeviceInfoForSchedule() {
-        LogUtils.WEBSOCKET_MSG.info("开始执行获取获取设备基础数据任务........");
         List<String> categories = Arrays.asList(WebSocketConstants.DVS, WebSocketConstants.ALARM_HOST);
         JSONObject args = new JSONObject();
         args.put("categories", categories);
-
-        final WebsocketResult result = IotServerUtils.invokeIotServer(iotServerDeviceTopic, WebSocketConstants.GET_DEVICE_BASE_INFOS, args);
-        LogUtils.WEBSOCKET_MSG.info("获取设备基础数据,发送消息内容：{}", JacksonUtils.toJSONString(result));
+        IotServerUtils.invokeIotServer(iotServerDeviceTopic, WebSocketConstants.GET_DEVICE_BASE_INFOS, args);
     }
 
     @Override