From 71501a1e3ae80a29603daac43312a6c6a21f94fd Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Fri, 10 Nov 2023 11:55:50 +0800 Subject: [PATCH 1/2] update --- .../jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java | 2 -- 1 file changed, 2 deletions(-) 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)); } From af45b8d64b538ad70698b629694afee985c922d1 Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Fri, 10 Nov 2023 13:42:18 +0800 Subject: [PATCH 2/2] update --- .../netty/server/yunkuaichong/NettyServerHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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) {