| | |
|---|
| | | import io.netty.buffer.ByteBuf; |
|---|
| | | import io.netty.buffer.Unpooled; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.data.elasticsearch.annotations.Document; |
|---|
| | | import org.springframework.data.elasticsearch.annotations.Field; |
|---|
| | | import org.springframework.data.elasticsearch.annotations.FieldType; |
|---|
| | |
|---|
| | | * @author zhibing.pu |
|---|
| | | * @Date 2025/3/3 14:50 |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @Data |
|---|
| | | @Document(indexName = "up_warn_msg_adpt_info") |
|---|
| | | public class UPWarnMsgAdptInfo extends BaseModel { |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 报警时间 |
|---|
| | | */ |
|---|
| | | @Field(type = FieldType.Integer) |
|---|
| | | @Field(type = FieldType.Long) |
|---|
| | | private long warnTime; |
|---|
| | | /** |
|---|
| | | * 信息ID |
|---|
| | |
|---|
| | | byte[] readableBytes = new byte[8]; |
|---|
| | | byteBuf.readBytes(readableBytes); |
|---|
| | | String time = ByteArrayUtil.bytes2HexStr(readableBytes); |
|---|
| | | log.info("报警时间1: {}", time); |
|---|
| | | //报警时间 |
|---|
| | | this.warnTime = Long.parseLong(time, 16); |
|---|
| | | log.info("报警时间2: {}", this.warnTime); |
|---|
| | | //团标扩展 |
|---|
| | | //信息ID |
|---|
| | | this.infoId = Jtt809Util.readGBKString(byteBuf,32); |
|---|
