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

心跳包ack修复

Browse Source
This commit is contained in:
三丙
2025-03-18 20:34:37 +08:00
parent 3604630c2b
commit efb72d94c5
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150HeartbeatULCmd.java
View File

@@ -66,16 +66,18 @@ public class YunKuaiChongV150HeartbeatULCmd extends YunKuaiChongUplinkCmdExe {
.build(); .build();
tcpSession.getForwarder().sendMessage(uplinkQueueMessage); tcpSession.getForwarder().sendMessage(uplinkQueueMessage);
pingAck(tcpSession, pileCodeBytes, gunCodeByte); pingAck(tcpSession, yunKuaiChongUplinkMessage, pileCodeBytes, gunCodeByte);
} }
private void pingAck(TcpSession tcpSession, byte[] pileCodeBytes, byte gunCodeByte) { private void pingAck(TcpSession tcpSession, YunKuaiChongUplinkMessage yunKuaiChongUplinkMessage, byte[] pileCodeBytes, byte gunCodeByte) {
ByteBuf pingAckMsgBody = Unpooled.buffer(9); ByteBuf pingAckMsgBody = Unpooled.buffer(9);
pingAckMsgBody.writeBytes(pileCodeBytes); pingAckMsgBody.writeBytes(pileCodeBytes);
pingAckMsgBody.writeByte(gunCodeByte); pingAckMsgBody.writeByte(gunCodeByte);
pingAckMsgBody.writeByte(0); pingAckMsgBody.writeByte(0);
encodeAndWriteFlush(HEARTBEAT, encodeAndWriteFlush(HEARTBEAT,
yunKuaiChongUplinkMessage.getSequenceNumber(),
yunKuaiChongUplinkMessage.getEncryptionFlag(),
pingAckMsgBody, pingAckMsgBody,
tcpSession); tcpSession);
} }