完成音视频协议接口对接

Pu Zhibing

2025-03-24 87c2f1ec41e244dfdd4722884fcdf285a1fe9b41

 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;
   }
}