| | |
| | | package com.dy.common.mw.protocol4Mqtt; |
| | | |
| | | import lombok.Data; |
| | | import lombok.EqualsAndHashCode; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/5 11:44 |
| | | * @Description |
| | | */ |
| | | public abstract class MqttPubMsg { |
| | | @Data |
| | | public class MqttPubMsg { |
| | | public String commandId ;//命令ID |
| | | |
| | | public String cd ;//功能码 |
| | | |
| | | public String deviceId ;//设备ID |
| | | |
| | |
| | | public boolean isCacheForOffLine ;//下行命令控制,消息中间件不在线是否缓存命令 |
| | | public boolean hasResponse ;//下行命令控制,命令是否有应答 |
| | | |
| | | public abstract boolean valid(); |
| | | public boolean valid(){ |
| | | if (topic == null || topic.isEmpty()) { |
| | | return false; |
| | | } |
| | | if (msg == null || msg.isEmpty()) { |
| | | return false; |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | } |