autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-14 23:08:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'dev' of http://192.168.2.2:8099/jsowell/jsowell-charger-web into dev

Browse Source
This commit is contained in:
Lemon
2023-11-12 09:40:24 +08:00
parent 631874298c af45b8d64b
commit e0ebe9955f
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
View File

@@ -179,8 +179,8 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
log.error("Client-IP:【{}】, channelId:【{}】, pileSn:【{}】, ALL_IDLE 总超时", socketString, channelId, pileSn); log.error("Client-IP:【{}】, channelId:【{}】, pileSn:【{}】, ALL_IDLE 总超时", socketString, channelId, pileSn);
} }
if (flag) { if (flag) {
ctx.channel().close(); // ctx.channel().close();
close(channelId, pileSn); // close(channelId, pileSn);
} }
} }
} }
@@ -203,7 +203,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size()); log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size());
ctx.channel().close(); ctx.channel().close();
} }
close(channelId, pileSn); // close(channelId, pileSn);
} }
private void close(ChannelId channelId, String pileSn) { private void close(ChannelId channelId, String pileSn) {

2
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
View File

@@ -580,8 +580,6 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService {
deleteRedisByPileSn(pileSn); deleteRedisByPileSn(pileSn);
redisCache.setCacheObject(redisKey, status, CacheConstants.cache_expire_time_3m); redisCache.setCacheObject(redisKey, status, CacheConstants.cache_expire_time_3m);
// TODO 推送联联平台 设备状态变化推送接口 ConnectorStatusInfo
// 异步放缓存 // 异步放缓存
CompletableFuture.runAsync(() -> statusChange(pileConnectorCode)); CompletableFuture.runAsync(() -> statusChange(pileConnectorCode));
} }