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

update

Browse Source
This commit is contained in:
Lemon
2025-07-02 11:54:57 +08:00
parent 883ebe7022
commit ba40605af7
5 changed files with 20 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jsowell-common/src/main/java/com/jsowell/common/util/YKCUtils.java
View File

@@ -214,7 +214,7 @@ public class YKCUtils {
// 保存桩号和channel的关系 // 保存桩号和channel的关系
PileChannelEntity.checkChannel(pileSn, ctx); PileChannelEntity.checkChannel(pileSn, ctx);
PileChannelEntity.checkChannelV2(pileSn, ctx); // PileChannelEntity.checkChannelV2(pileSn, ctx);
} }
/** /**

2
jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java
View File

@@ -70,7 +70,7 @@ public abstract class AbstractYkcHandler implements InitializingBean {
// 保存桩号和channel的关系 // 保存桩号和channel的关系
PileChannelEntity.checkChannel(pileSn, ctx); PileChannelEntity.checkChannel(pileSn, ctx);
PileChannelEntity.checkChannelV2(pileSn, ctx); // PileChannelEntity.checkChannelV2(pileSn, ctx);
} }
/** /**

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

@@ -307,7 +307,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
} }
log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size()); log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size());
// 删除连接 // 删除连接
PileChannelEntity.deleteChannel(pileSn, ctx); // PileChannelEntity.deleteChannel(pileSn, ctx);
ctx.channel().close(); ctx.channel().close();
} }
} finally { } finally {

2
jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java
View File

@@ -88,7 +88,7 @@ public class YKCBusinessServiceImpl implements YKCBusinessService {
pileMsgRecordService.save(pileSn, pileSn, type, jsonMsg, ""); pileMsgRecordService.save(pileSn, pileSn, type, jsonMsg, "");
// 删除连接 // 删除连接
PileChannelEntity.deleteChannel(pileSn, ctx); // PileChannelEntity.deleteChannel(pileSn, ctx);
// 删除桩编号和channel的关系 // 删除桩编号和channel的关系
// PileChannelEntity.removeByPileSn(pileSn); // PileChannelEntity.removeByPileSn(pileSn);

32
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/YKCPushCommandServiceImpl.java
View File

@@ -126,14 +126,14 @@ public class YKCPushCommandServiceImpl implements YKCPushCommandService {
log.error("push发送命令失败, pileSn:{}", pileSn, cause); log.error("push发送命令失败, pileSn:{}", pileSn, cause);
// 异步删除Map中的保存关系(带关闭连接) // 异步删除Map中的保存关系(带关闭连接)
CompletableFuture.runAsync(() -> { // CompletableFuture.runAsync(() -> {
try { // try {
// 删除Map中的保存关系 // // 删除Map中的保存关系
PileChannelEntity.deleteChannel(pileSn, ctx); // PileChannelEntity.deleteChannel(pileSn, ctx);
} catch (Exception e) { // } catch (Exception e) {
log.error("异步删除、关闭连接 error", e); // log.error("异步删除、关闭连接 error", e);
} // }
}, executor); // }, executor);
} }
}); });
@@ -231,14 +231,14 @@ public class YKCPushCommandServiceImpl implements YKCPushCommandService {
log.error("push发送命令失败, pileSn:{}", pileSn, cause); log.error("push发送命令失败, pileSn:{}", pileSn, cause);
// 异步删除Map中的保存关系(带关闭连接) // 异步删除Map中的保存关系(带关闭连接)
CompletableFuture.runAsync(() -> { // CompletableFuture.runAsync(() -> {
try { // try {
// 删除Map中的保存关系 // // 删除Map中的保存关系
PileChannelEntity.deleteChannel(pileSn, ctx); // PileChannelEntity.deleteChannel(pileSn, ctx);
} catch (Exception e) { // } catch (Exception e) {
log.error("异步删除、关闭连接 error", e); // log.error("异步删除、关闭连接 error", e);
} // }
}, executor); // }, executor);
} }
}); });