From cd7fd2ea35de966cfd1c6f3038e593097d7a6dec Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期四, 03 七月 2025 11:26:46 +0800
Subject: [PATCH] 轮灌组PC端接口

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttPubMsg.java |   20 +++++++++++++++++---
 1 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttPubMsg.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttPubMsg.java
index eba4ecf..89e4058 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttPubMsg.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttPubMsg.java
@@ -1,14 +1,20 @@
 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 deviceId ;//璁惧ID
+    public String cd ;//鍔熻兘鐮�
+
+    public String deviceId ;//璁惧ID(FBox搴忓垪鍙�)
 
     public String mqttResultSendWebUrl ;//Mqtt杩斿洖鍛戒护缁撴灉 鍙戝悜鐩殑鍦皐eb URL
 
@@ -18,6 +24,14 @@
     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;
+    }
 
 }

--
Gitblit v1.8.0