From 41c64a5680521bf1d41fa6b9caadc55feac68ca3 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期四, 05 六月 2025 16:12:59 +0800 Subject: [PATCH] 优化报警 --- ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/model/UPPlaybackMsgControlAck.java | 35 +++++++++++++++++++++++++++++++++-- 1 files changed, 33 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..93bac1d 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,25 @@ * 0x02: 不支持 * 0x03: 会话结束 */ - private Integer result; + @Field(type = FieldType.Integer) + private int result; + + + /** + * 解析报文 + */ + public UPPlaybackMsgControlAck decode(PlaybackMsg playbackMsg) { + try { + 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(); + }catch (Exception e){ + e.printStackTrace(); + } + return this; + } } -- Gitblit v1.7.1