修复自发现重启HA无效

qlwz · Jan 16, 2020 · a5b1302 · a5b1302
1 parent 6cef68d
commit a5b1302
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/src/Cover.cpp b/src/Cover.cpp
@@ -246,11 +246,11 @@ void Cover::mqttDiscovery(boolean isEnable)
         sprintf(message, HASS_DISCOVER_COVER, UID, mqtt->getCmndTopic(F("set")).c_str(), mqtt->getStatTopic(F("position")).c_str(),
                 mqtt->getCmndTopic(F("set_position")).c_str(), mqtt->getTeleTopic(F("availability")).c_str());
         Debug.AddLog(LOG_LEVEL_INFO, PSTR("discovery: %s - %s"), topic, message);
-        mqtt->publish(topic, message);
+        mqtt->publish(topic, message, true);
     }
     else
     {
-        mqtt->publish(topic, "");
+        mqtt->publish(topic, "", true);
     }
 }
 

diff --git a/src/Relay.cpp b/src/Relay.cpp
@@ -197,11 +197,11 @@ void Relay::mqttDiscovery(boolean isEnable)
                     Relay::channels == 1 ? powerTopic.c_str() : (powerTopic + (ch + 1)).c_str(),
                     mqtt->getTeleTopic(F("availability")).c_str());
             Debug.AddLog(LOG_LEVEL_INFO, PSTR("discovery: %s - %s"), topic, message);
-            mqtt->publish(topic, message);
+            mqtt->publish(topic, message, true);
         }
         else
         {
-            mqtt->publish(topic, "");
+            mqtt->publish(topic, "", true);
         }
     }
 }

diff --git a/src/Weile.cpp b/src/Weile.cpp
@@ -174,11 +174,11 @@ void Weile::mqttDiscovery(boolean isEnable)
                 powerTopic.c_str(),
                 mqtt->getTeleTopic(F("availability")).c_str());
         Debug.AddLog(LOG_LEVEL_INFO, PSTR("discovery: %s - %s"), topic, message);
-        mqtt->publish(topic, message);
+        mqtt->publish(topic, message, true);
     }
     else
     {
-        mqtt->publish(topic, "");
+        mqtt->publish(topic, "", true);
     }
 }
 

diff --git a/src/Zinguo.cpp b/src/Zinguo.cpp
@@ -256,11 +256,11 @@ void Zinguo::mqttDiscovery(boolean isEnable)
                     mqtt->getStatTopic(tims[i]).c_str(),
                     mqtt->getTeleTopic(F("availability")).c_str());
             Debug.AddLog(LOG_LEVEL_INFO, PSTR("discovery: %s - %s"), topic, message);
-            mqtt->publish(topic, message);
+            mqtt->publish(topic, message, true);
         }
         else
         {
-            mqtt->publish(topic, "");
+            mqtt->publish(topic, "", true);
         }
     }
 
@@ -277,11 +277,11 @@ void Zinguo::mqttDiscovery(boolean isEnable)
                 mqtt->getStatTopic("temp").c_str(),
                 mqtt->getTeleTopic(F("availability")).c_str());
         Debug.AddLog(LOG_LEVEL_INFO, PSTR("discovery: %s - %s"), topic, message);
-        mqtt->publish(topic, message);
+        mqtt->publish(topic, message, true);
     }
     else
     {
-        mqtt->publish(topic, "");
+        mqtt->publish(topic, "", true);
     }
 }
 #pragma endregion