diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java index 3b530a7d9..6a22ecdef 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java @@ -179,8 +179,8 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { log.error("Client-IP:【{}】, channelId:【{}】, pileSn:【{}】, ALL_IDLE 总超时", socketString, channelId, pileSn); } if (flag) { - ctx.channel().close(); - close(channelId, pileSn); + // ctx.channel().close(); + // close(channelId, pileSn); } } } @@ -203,7 +203,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size()); ctx.channel().close(); } - close(channelId, pileSn); + // close(channelId, pileSn); } private void close(ChannelId channelId, String pileSn) { diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java index 14fe1f180..95bb80c67 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java @@ -580,8 +580,6 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService { deleteRedisByPileSn(pileSn); redisCache.setCacheObject(redisKey, status, CacheConstants.cache_expire_time_3m); - // TODO 推送联联平台 设备状态变化推送接口 ConnectorStatusInfo - // 异步放缓存 CompletableFuture.runAsync(() -> statusChange(pileConnectorCode)); }