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

update 校验channel是否保存

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-11-18 08:31:31 +08:00
parent c1c756df9c
commit 887dcca0f9
1 changed files with 20 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java
View File

@@ -22,10 +22,22 @@ public class PileChannelEntity {
* 校验channel是否保存 * 校验channel是否保存
*/ */
public static void checkChannel(String pileSn, Channel channel) { public static void checkChannel(String pileSn, Channel channel) {
if (manager.containsKey(pileSn)) { if (!manager.containsKey(pileSn)) {
// 如果manager中不存在pileSn的连接，则保存
log.info("checkChannel-manager中不存在pileSn:{}的连接,保存新的channel:{}", pileSn, channel.id().asLongText());
manager.put(pileSn, channel);
return;
}
// 如果manager中存在pileSn的连接，取出来对比 // 如果manager中存在pileSn的连接，取出来对比
Channel sourceChannel = manager.get(pileSn); Channel sourceChannel = manager.get(pileSn);
if (sourceChannel != null) { if (sourceChannel == null) {
// 为空就put
log.info("checkChannel-manager中pileSn:{}的连接为空,保存新的channel:{}", pileSn, channel.id().asLongText());
manager.put(pileSn, channel);
return;
}
// 两个做对比 // 两个做对比
String sourceChannelId = sourceChannel.id().asLongText(); String sourceChannelId = sourceChannel.id().asLongText();
String channelId = channel.id().asLongText(); String channelId = channel.id().asLongText();
@@ -34,16 +46,6 @@ public class PileChannelEntity {
log.info("checkChannel-manager中pileSn:{}的连接不一致, 老channelId:{}, 保存新的channel:{}", pileSn, sourceChannelId, channelId); log.info("checkChannel-manager中pileSn:{}的连接不一致, 老channelId:{}, 保存新的channel:{}", pileSn, sourceChannelId, channelId);
manager.put(pileSn, channel); manager.put(pileSn, channel);
} }
} else {
// 为空就put
log.info("checkChannel-manager中pileSn:{}的连接为空,保存新的channel:{}", pileSn, channel.id().asLongText());
manager.put(pileSn, channel);
}
} else {
// 如果manager中不存在pileSn的连接，则保存
log.info("checkChannel-manager中不存在pileSn:{}的连接,保存新的channel:{}", pileSn, channel.id().asLongText());
manager.put(pileSn, channel);
}
} }
/** /**