Merge branch 'ver4dev' into tlgrm_fast

src/modules/sceninfo.json

@@ -69,6 +69,11 @@
                 "descr": "Отправить значение в топик MQTT",
                 "params": ["Топик", "Значение"]
             },
+            {
+                "name": "mqttIsConnect",
+                "descr": "Получить состояние подключения к MQTT",
+                "params": []
+            },
             {
                 "name": "getHours",
                 "descr": "Получить текущее число часов. Если время не получено из сети Интернет или внешнего RTC, то условие пропускается",

src/modules/sensors/ExternalMQTT/ExternalMQTT.cpp

@@ -13,16 +13,24 @@ private:
     int red = 0;
     int offline = 0;
     bool dataFromNode = false;
+    String _topic = "";
+    bool _isJson;
+    bool _addPrefix;
+    bool _debug;
 
 public:
     ExternalMQTT(String parameters) : IoTItem(parameters)
     {
-        _MAC = jsonReadStr(parameters, "MAC");
         _sensor = jsonReadStr(parameters, "sensor");
         jsonRead(parameters, F("orange"), orange);
         jsonRead(parameters, F("red"), red);
         jsonRead(parameters, F("offline"), offline);
+        _topic = jsonReadStr(parameters, "topic");
+        _isJson = jsonReadBool(parameters, "isJson");
+        _addPrefix = jsonReadBool(parameters, "addPrefix");
+        _debug = jsonReadBool(parameters, "debug");
         dataFromNode = false;
+        mqttSubscribeExternal(_topic, _addPrefix);
     }
     char *TimeToString(unsigned long t)
     {
@@ -38,38 +46,58 @@ public:
     {
         if (msg.indexOf("HELLO") == -1)
         {
-
-            //        SerialPrint("i", "onMqttRecive", "Прилетело  " + topic);
-            //        SerialPrint("i", "onMqttRecive", "Прилетело  " + msg);
+            if (_debug)
+            {
+                SerialPrint("i", "onMqttRecive", "Прилетело  " + topic + " msg: " + msg);
+                //  SerialPrint("i", "onMqttRecive", "Прилетело  " + msg);
+            }
             String dev = selectToMarkerLast(topic, "/");
             dev.toUpperCase();
             dev.replace(":", "");
-            if (_MAC == "")
+            if (_topic != topic)
             {
-                SerialPrint("i", "onMqttRecive", dev + " -->  " + msg);
+                return;
             }
-            DynamicJsonDocument doc(JSON_BUFFER_SIZE);
-            DeserializationError error = deserializeJson(doc, msg);
-            if (error)
+            if (_isJson)
             {
-                SerialPrint("E", F("onMqttRecive"), error.f_str());
-            }
-            JsonObject jsonObject = doc.as<JsonObject>();
-
-            for (JsonPair kv : jsonObject)
-            {
-                String key = kv.key().c_str();
-                String val = kv.value();
-                if (_MAC == dev && _sensor == key)
+                DynamicJsonDocument doc(JSON_BUFFER_SIZE);
+                DeserializationError error = deserializeJson(doc, msg);
+                if (error)
                 {
-                    dataFromNode = true;
-                    _minutesPassed = 0;
-                    setValue(val);
-                    // setNewWidgetAttributes();
+                    SerialPrint("E", F("onMqttRecive"), error.f_str());
                 }
+                JsonObject jsonObject = doc.as<JsonObject>();
 
-                //   Serial.println("Key: " + key);
-                //   Serial.println("Value: " + val);
+                for (JsonPair kv : jsonObject)
+                {
+                    String key = kv.key().c_str();
+                    String val = kv.value();
+                    if (_debug)
+                    {
+                        SerialPrint("i", "onMqttRecive", "Прилетело MAC: " + dev + " key=" + key + " val=" + val);
+                    }
+                    if (_sensor == key)
+                    {
+                        dataFromNode = true;
+                        _minutesPassed = 0;
+                        setValue(val);
+                        // setNewWidgetAttributes();
+                    }
+
+                    //   Serial.println("Key: " + key);
+                    //   Serial.println("Value: " + val);
+                }
+            }
+            else
+            {
+                if (_debug)
+                {
+                    SerialPrint("i", "onMqttRecive", "Прилетело MAC: " + dev + " val=" + msg);
+                }
+                dataFromNode = true;
+                _minutesPassed = 0;
+                setValue(msg);
+                // setNewWidgetAttributes();
             }
         }
     }
@@ -116,7 +144,22 @@ public:
         }
         sendSubWidgetsValues(_id, json);
     }
-
+    /*
+        IoTValue execute(String command, std::vector<IoTValue> &param)
+        {
+            if (command == "mqttSubscribe")
+            {
+                if (param.size() == 2)
+                {
+                    if (!param[0].isDecimal && param[1].isDecimal)
+                    {
+                        mqttSubscribeExternal(param[0].valS, (bool)param[0].valD);
+                    }
+                }
+            }
+            return {};
+        }
+    */
     ~ExternalMQTT(){};
 };
 

src/modules/sensors/ExternalMQTT/modinfo.json

@@ -10,13 +10,16 @@
       "widget": "",
       "page": "",
       "descr": "",
-      "MAC": "",
       "sensor": "",
+      "topic": "",
+      "addPrefix": 0,
+      "isJson": 1,
       "round": "",
       "orange": 60,
       "red": 120,
       "offline": 180,
-      "int": 60
+      "int": 60,
+      "debug": 0
     }
   ],
   "about": {
@@ -25,7 +28,7 @@
     "authorGit": "https://github.com/avaksru",
     "specialThanks": "",
     "moduleName": "ExternalMQTT",
-    "moduleVersion": "1",
+    "moduleVersion": "1.2",
     "usedRam": {
       "esp32_4mb": 15,
       "esp8266_4mb": 15
@@ -38,13 +41,18 @@
       "orange": "количество минут после которого окрасить виджет в оранжевый цвет",
       "red": "количество минут после которого окрасить виджет в красный цвет",
       "offline": "количество минут после которого отобразить что устройство offline, если все три orange red и offline поставить в ноль - то функция окраски выключится",
-      "MAC": "MAC адрес беспроводного датчика",
-      "sensor": "Тип сенсора: температура / влажность / время / ...   "
+      "sensor": "Тип сенсора: температура / влажность / время / ... Он же ключ в json пакете  ",
+      "topic":"Подписаться на произвольный топик (полный путь), в модуле данный топик буде проверяться с отправителем, например homed/fd/zigbee/temp",
+      "addPrefix":"1 (число), будет добавлен стандартный префикс из настроек, 0 - не добавлять префикс",
+      "isJson":"1 - ожидаем в топике json, 0 - в топике просто значение (при 0 поле sensor заполнять не требуется)",
+      "debug":"1 - выводить дополнительный лог в сериал"
     }
+    
   },
   "defActive": false,
   "usedLibs": {
     "esp32_4mb": [],
+    "esp32s2_4mb": [],
     "esp32cam_4mb": [],
     "esp8266_4mb": [],
     "esp8266_1mb": [],