package com.fastbee.common.core.mq.message; import com.fastbee.common.core.protocol.Message; import com.fastbee.common.core.protocol.modbus.ModbusCode; import io.netty.buffer.ByteBuf; import lombok.Builder; import lombok.Data; import lombok.EqualsAndHashCode; /** * 消息解析model * @author gsb * @date 2022/10/10 15:53 */ @EqualsAndHashCode(callSuper = true) @Data @Builder public class DeviceData extends Message { /*topic*/ private String topicName; /*设备编号*/ private String serialNumber; /*原数据*/ private byte[] data; private ByteBuf buf; /*消息类型 1.设备上报数据 2.设备回调数据*/ private int messageType; /*下发数据model*/ private DeviceDownMessage downMessage; private Object body; /*MQTT OR 其他*/ private int type; /*Modbus*/ private ModbusCode code; private PropRead prop; /*是否使用modbus客户端模拟测试*/ private boolean isEnabledTest; /**产品id*/ private Long productId; }