autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-05 02:19:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
三丙
2025-03-22 00:50:46 +08:00
parent 39cea215f5
commit f8baacdc38
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jcpp-app/src/main/java/sanbing/jcpp/app/service/impl/DefaultPileProtocolService.java
View File

@@ -106,6 +106,8 @@ public class DefaultPileProtocolService implements PileProtocolService {
heartBeatRequest.getNodeRestPort(), heartBeatRequest.getNodeRestPort(),
heartBeatRequest.getNodeGrpcPort()); heartBeatRequest.getNodeGrpcPort());
} }
callback.onSuccess();
} }
private void cacheSession(UplinkQueueMessage uplinkQueueMessage, private void cacheSession(UplinkQueueMessage uplinkQueueMessage,

11
jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/YunKuaiChongProtocolMessageProcessor.java
View File

@@ -118,12 +118,15 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
return; return;
} }
// 读取两字节校验域
byte[] byCheckSum = new byte[2]; byte[] byCheckSum = new byte[2];
in.readBytes(byCheckSum); in.readBytes(byCheckSum);
ByteBuf csTemp = Unpooled.copiedBuffer(byCheckSum);
// 校验校验和 ByteBuf csTemp = Unpooled.buffer();
int checkSum = csTemp.readUnsignedShort(); csTemp.writeBytes(byCheckSum);
// 校验校验和，先用小端获取做短路校验
int checkSum = csTemp.readUnsignedShortLE();
byte[] checkData = new byte[dataLength]; byte[] checkData = new byte[dataLength];
@@ -133,7 +136,7 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
if (Boolean.FALSE.equals(checkResult.getFirst())) { if (Boolean.FALSE.equals(checkResult.getFirst())) {
csTemp.writeBytes(byCheckSum); csTemp.writeBytes(byCheckSum);
checkSum = csTemp.readUnsignedShortLE(); checkSum = csTemp.readUnsignedShort();
checkResult = checkCrcSum(checkData, checkSum); checkResult = checkCrcSum(checkData, checkSum);
log.debug("云快充检验和 第二次检查: checkResult:{}, checkSum:{}", checkResult, checkSum); log.debug("云快充检验和 第二次检查: checkResult:{}, checkSum:{}", checkResult, checkSum);
} }