北向代码提交

soc-modules/soc-modules-iot/src/main/java/com/xunmei/iot/service/impl/IotServerInfoServiceImpl.java

@@ -119,6 +119,7 @@ public class IotServerInfoServiceImpl extends ServiceImpl<IotServerInfoMapper, I
         info.setIotName(req.getIotName());
         info.setEnable(req.getEnable());
         updateById(info);
+        //如果编辑为停用,那么会断开对应的iot服务
         if (1 == req.getEnable()) {
             CompletableFuture.runAsync(() -> {
                 try {

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

@@ -95,6 +95,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
                 WebsocketResult result = createWebsocketResult(null, "login", map);
                 WebSocketUtils.sendMessage(session, JacksonUtils.toJSONString(result));
                 session.close();
+                LogUtils.WEBSOCKET_MSG.info("准备建立连接时,token不可用,ip:{}", ip);
                 return;
             }
             serverInfo.setIotIp(ip);
@@ -109,6 +110,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
             LogUtils.WEBSOCKET_MSG.info("[建立连接],token:{}", token);
             return;
         }
+        LogUtils.WEBSOCKET_MSG.info("[建立连接失败],token:{}", token);
         session.close();
     }