From efb72d94c50fb8bd7b51cf1dbfea450de9643827 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=89=E4=B8=99?= Date: Tue, 18 Mar 2025 20:34:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BF=83=E8=B7=B3=E5=8C=85ack=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../v150/cmd/YunKuaiChongV150HeartbeatULCmd.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150HeartbeatULCmd.java b/jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150HeartbeatULCmd.java index aac5a62..4ba60fd 100644 --- a/jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150HeartbeatULCmd.java +++ b/jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150HeartbeatULCmd.java @@ -66,16 +66,18 @@ public class YunKuaiChongV150HeartbeatULCmd extends YunKuaiChongUplinkCmdExe { .build(); 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); pingAckMsgBody.writeBytes(pileCodeBytes); pingAckMsgBody.writeByte(gunCodeByte); pingAckMsgBody.writeByte(0); encodeAndWriteFlush(HEARTBEAT, + yunKuaiChongUplinkMessage.getSequenceNumber(), + yunKuaiChongUplinkMessage.getEncryptionFlag(), pingAckMsgBody, tcpSession); }