From 87c2f1ec41e244dfdd4722884fcdf285a1fe9b41 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 24 三月 2025 14:41:25 +0800
Subject: [PATCH] 完成音视频协议接口对接
---
ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java | 31 +++++++++++++++++++++++++++++--
1 files changed, 29 insertions(+), 2 deletions(-)
diff --git a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java
index 6d61acd..328065e 100644
--- a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java
+++ b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java
@@ -1,6 +1,12 @@
package com.ruoyi.dataInterchange.model;
+import com.ruoyi.dataInterchange.pojo.BaseModel;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
import lombok.Data;
+import org.springframework.data.elasticsearch.annotations.Document;
+import org.springframework.data.elasticsearch.annotations.Field;
+import org.springframework.data.elasticsearch.annotations.FieldType;
/**
* 远程录像回放控制请求应答
@@ -9,22 +15,27 @@
* @Date 2025/3/21 10:37
*/
@Data
-public class UPPlaybackMsgControlAck {
+@Document(indexName = "up_playback_msg_control_ack")
+public class UPPlaybackMsgControlAck extends BaseModel {
/**
* 车牌号
*/
+ @Field(type = FieldType.Text)
private String vehicleNo;
/**
* 车牌颜色
*/
+ @Field(type = FieldType.Integer)
private Integer vehicleColor;
/**
* 子业务类型标识
*/
+ @Field(type = FieldType.Integer)
private Integer dataType;
/**
* 后续数据长度
*/
+ @Field(type = FieldType.Integer)
private Integer dataLength;
/**
* 应答结果
@@ -33,5 +44,21 @@
* 0x02: 不支持
* 0x03: 会话结束
*/
- private Integer result;
+ @Field(type = FieldType.Integer)
+ private int result;
+
+
+ /**
+ * 解析报文
+ */
+ public UPPlaybackMsgControlAck decode(PlaybackMsg playbackMsg) {
+ byte[] data = playbackMsg.getData();
+ ByteBuf byteBuf = Unpooled.wrappedBuffer(data);
+ this.vehicleNo = playbackMsg.getVehicleNo();
+ this.vehicleColor = playbackMsg.getVehicleColor();
+ this.dataType = playbackMsg.getDataType();
+ this.dataLength = playbackMsg.getDataLength();
+ this.result = byteBuf.readByte();
+ return this;
+ }
}
--
Gitblit v1.7.1