correction bug reco MQTT

Author: xlyric

src/config/config.h

@@ -154,7 +154,7 @@ constexpr size_t NTP_UPDATE_INTERVAL_MS = 3600000; /// synch de l'heure toute le
   //  #define ARDUINO_RUNNING_CORE 1
 #endif
 
-#define RELEASE "Version 20250418"
+#define RELEASE "Version 20250422"
 constexpr const int FS_RELEASE = 20250324;
 
 #ifdef LIGHT_FIRMWARE

src/config/enums.h

@@ -27,7 +27,7 @@
 //***********************************
 //************* Constantes
 //***********************************
-#define TABLEAU_SIZE 16 // NOSONAR
+#define TABLEAU_SIZE 7 // NOSONAR
 #define SECURITEPASS "MyPassword" // NOSONAR
 #if DEBUG == true
   #define serial_print(x)  Serial.print (x)
@@ -40,7 +40,7 @@
 //***********************************
 //************* Variable locales
 //***********************************
-int tableaudemo[TABLEAU_SIZE] = {180, 180, 0, 0, -150, -150, 4, 4 ,180, 180, 5,5, -150 ,-150, 2,2 }; // NOSONAR
+int tableaudemo[TABLEAU_SIZE] = {180, 3, -150, 4, 150, 5, -180}; // NOSONAR
 
 //***********************************
 //************* class DEVICE_STATE

src/functions/Mqtt_http_Functions.h

@@ -87,12 +87,13 @@ WiFiClient espClient;
       } else {
         Serial.print("MQTT failed, retcode="); 
         Serial.print(client.state());
-        Serial.println(" try again in 2 seconds");
+        Serial.println(" try again in 5 seconds");
         ///dans le doute si le mode AP est actif on le coupe
         Serial.println(WiFi.status());
 
         // Wait 2 seconds before retrying
-        delay(2000);  // 24/01/2023 passage de 5 à 2s 
+        yield(); // permet de libérer le CPU pour d'autres tâches
+        delay(5000);  // 24/01/2023 passage de 5 à 2s 
       } // else
     } // while
   }
@@ -230,14 +231,12 @@ WiFiClient espClient;
     client.subscribe(("memory/"+compteur_grid.topic+"#").c_str());
     client.loop();
 
-    if (xSemaphoreTake(mutex, portMAX_DELAY)) {  // Prend le mutex  
       if (config.IDXdimmer != 0 ) {  
         Mqtt_send(String(config.IDXdimmer),"0","","Dimmer"); 
       }
       if (strcmp(config.topic_Shelly,"none") != 0) 
         client.subscribe(config.topic_Shelly);
-      xSemaphoreGive(mutex);  // Libère le mutex
-    }
+
   }
 #endif //ifndef LIGHT_FIRMWARE
 #endif //ifndef MQTT_FUNCTIONS

src/main.cpp

@@ -767,10 +767,10 @@ void loop() {
 
 
 
-
-  int retry_wifi = 0;
-
   #ifdef DEBUGLEVEL1
+  // test de la connexion client mqtt
+  Serial.print("client connected ? :");
+  Serial.println(client.connected());
 //// test de synchro pour debug
   if (dimmer1.getsync()) {
     Serial.println("sync ok");
@@ -806,6 +806,18 @@ void loop() {
     printTaskStack(myTaskwatchdogmemory, "myTaskwatchdogmemory");
   #endif
 
+    //**** Loop - vérification de la connexion au serveur MQTT **** 
+    #ifndef LIGHT_FIRMWARE
+    if (config.mqtt) {
+      if (!client.connected()) {
+        reconnect(); 
+      }
+      client.loop(); // Keep the MQTT connection alive
+    }
+    #endif // not LIGHT_FIRMWARE
+
+    int retry_wifi = 0;
+
   //***********************************
   //************* Loop - web socket loop
   //*********************************** 
@@ -884,13 +896,13 @@ void loop() {
         strcpy(programme_marche_forcee.heure_demarrage, "00:00"); // NOSONAR
         strcpy(programme_marche_forcee.heure_arret, "00:00");  // NOSONAR        
         /// remonté MQTT
-        #ifndef LIGHT_FIRMWARE
+      /* #ifndef LIGHT_FIRMWARE
             Mqtt_send(String(config.IDX), String(unified_dimmer.get_power()),"pourcent"); // remonté MQTT de la commande réelle
             if (configmqtt.HA) {
               int instant_power = unified_dimmer.get_power();
               device_dimmer.send(String(instant_power * config.charge/100));
             } 
-        #endif // not LIGHT_FIRMWARE
+        #endif */ // not LIGHT_FIRMWARE
       } // if (programme.stop_progr() || programme_marche_forcee.stop_progr() )
     } // if (programme.run || programme_marche_forcee.run)  
 
@@ -910,7 +922,7 @@ void loop() {
         //demarrage du ventilateur 
         digitalWrite(COOLER, HIGH);      
         /// remonté MQTT
-        #ifndef LIGHT_FIRMWARE
+    /*    #ifndef LIGHT_FIRMWARE
 
             Mqtt_send(String(config.IDX), String(unified_dimmer.get_power()),"pourcent"); // remonté MQTT de la commande réelle
               if (configmqtt.HA) {
@@ -921,6 +933,7 @@ void loop() {
                 }
               } 
         #endif // not LIGHT_FIRMWARE
+        */
       } // if (programme.start_progr() ||  programme_marche_forcee.start_progr() )
     } // else
   } // if (config.dimmerlocal)

src/tasks/send-mqtt.h

@@ -81,7 +81,7 @@ void send_to_mqtt(void * parameter) { // NOSONAR
             long timemesure = start-beforetime;
             float wattheure = (timemesure * abs(gDisplayValues.watt) / timemilli);  
             #ifndef LIGHT_FIRMWARE
-            if (xSemaphoreTake(mutex, portMAX_DELAY)) {   
+
               // domoticz et jeedom
               if (config.IDX != 0 ) {
                 Mqtt_send(String(config.IDX), String(int(gDisplayValues.watt)),"","watt");  
@@ -138,13 +138,13 @@ void send_to_mqtt(void * parameter) { // NOSONAR
                 }
               }
               //maj 202030209
-              xSemaphoreGive(mutex);  // Libère le mutex
+
             #endif  // not LIGHT_FIRMWARE
 
             beforetime = start; 
             Pow_mqtt_send = 0 ;
 
-          }
+
         #endif   
       }