Merge branch 'IoTManagerProject:ver4dev' into ver4dev

include/classes/IoTItem.h

@@ -11,7 +11,7 @@ struct IoTValue {
 class IoTItem {
    public:
     IoTItem(const String& parameters);
-    virtual ~IoTItem() {}
+    virtual ~IoTItem() {};
     virtual void loop();
     virtual void doByInterval();
     virtual IoTValue execute(String command, std::vector<IoTValue>& param);
@@ -35,9 +35,12 @@ class IoTItem {
     void setInterval(long interval);
     void setIntFromNet(int interval);
 
-    unsigned long currentMillis;
+    // unsigned long currentMillis;
-    unsigned long prevMillis;
+    // unsigned long prevMillis;
-    unsigned long difference;
+    // unsigned long difference;
+    unsigned long nextMillis=0; // достаточно 1 переменной, надо экономить память
+    // задержка следующего вызова, не изменяет текущий _interval
+    void suspendNextDoByInt(unsigned long _delay); // 0 - force
 
     IoTValue value;  // хранение основного значения, которое обновляется из сценария, execute(), loop() или doByInterval()
 

src/Main.cpp

@@ -10,8 +10,8 @@
 IoTScenario iotScen;  // объект управления сценарием
 
 String volStrForSave = "";
-unsigned long currentMillis;
+// unsigned long currentMillis; // это сдесь лишнее
-unsigned long prevMillis;
+// unsigned long prevMillis;
 
 void elementsLoop() {
     // передаем управление каждому элементу конфигурации для выполнения своих функций

src/MqttClient.cpp

@@ -5,7 +5,7 @@ void mqttInit() {
     ts.add(
         WIFI_MQTT_CONNECTION_CHECK, MQTT_RECONNECT_INTERVAL,
         [&](void*) {
-            if (WiFi.status() == WL_CONNECTED) {
+            if (isNetworkActive()) {
                 SerialPrint("i", F("WIFI"), "http://" + jsonReadStr(settingsFlashJson, F("ip")));
                 wifiUptimeCalc();
                 if (mqtt.connected()) {

src/classes/IoTItem.cpp

@@ -7,9 +7,7 @@
 
 IoTItem::IoTItem(const String& parameters) {
     jsonRead(parameters, F("int"), _interval, false);
-    if (_interval == 0) enableDoByInt = false;           // выключаем использование периодического выполнения в модуле
+    setInterval(_interval);
-    if (_interval > 0) _interval = _interval * 1000;    // если int положителен, то считаем, что получены секунды
-    if (_interval < 0) _interval = _interval * -1;      // если int отрицательный, то миллисекунды
     jsonRead(parameters, F("subtype"), _subtype, false);
     jsonRead(parameters, F("id"), _id);
     if (!jsonRead(parameters, F("multiply"), _multiply, false)) _multiply = 1;
@@ -45,12 +43,16 @@ IoTItem::IoTItem(const String& parameters) {
     }
 }
 
+void IoTItem::suspendNextDoByInt(unsigned long _delay) { // 0 - force
+    nextMillis = millis() + _delay; 
+}
+
 void IoTItem::loop() {
     if (enableDoByInt) {
-        currentMillis = millis();
+        unsigned long currentMillis = millis(); // _interval должен быть < 2147483647 мс (24 суток)
-        difference = currentMillis - prevMillis;
+        if (nextMillis - currentMillis > 2147483647UL /*ULONG_MAX/2*/ ) {
-        if (difference >= _interval) {
+            nextMillis = currentMillis + _interval;
-            prevMillis = millis();
+            // SerialPrint(F("i"), _id, "this->doByInterval");
             this->doByInterval();
         }
     }
@@ -215,7 +217,13 @@ bool IoTItem::isStrInID(const String& str) {
 }
 
 void IoTItem::setInterval(long interval) {
-    _interval = interval;
+    if (interval == 0) enableDoByInt = false;           // выключаем использование периодического выполнения в модуле
+    else {
+        enableDoByInt = true;
+        if (interval > 0) _interval = interval * 1000;    // если int положителен, то считаем, что получены секунды
+        else if (interval < 0) _interval = interval * -1;      // если int отрицательный, то миллисекунды
+    }
+    // SerialPrint(F("i"), F("IoTItem"), "setInterval: " + _interval.toString);
 }
 
 IoTGpio* IoTItem::getGpioDriver() {

src/modules/display/NextionUpload/NextionUpload.cpp

@@ -43,13 +43,16 @@ public:
 #if defined ESP8266
                 if (!http.begin(_host, 80, _url))
                 {
-#elif defined ESP32
-                if (!http.begin(String("http://") + _host + _url))
-                {
-#endif
                     //  Serial.println("connection failed");
                     SerialPrint("I", F("NextionUpdate"), "connection failed  ");
                 }
+#elif defined ESP32
+                if (!http.begin(String("http://") + _host + _url))
+                {
+                    //  Serial.println("connection failed");
+                    SerialPrint("I", F("NextionUpdate"), "connection failed  ");
+                }
+#endif
 
                 SerialPrint("I", F("NextionUpdate"), "Requesting file:   " + (String)_url);
                 int code = http.GET();

src/modules/exec/ButtonOut/ButtonOut.cpp

@@ -3,24 +3,28 @@
 
 extern IoTGpio IoTgpio;
 
-
 class ButtonOut : public IoTItem {
    private:
-    int _pin, _inv;
+    int _pin;
+    bool _inv;
 
    public:
     ButtonOut(String parameters): IoTItem(parameters) {
         jsonRead(parameters, "pin", _pin);
         jsonRead(parameters, "inv", _inv);
         _round = 0;
-
         IoTgpio.pinMode(_pin, OUTPUT);
         IoTgpio.digitalWrite(_pin, _inv?!value.valD:value.valD);
+        enableDoByInt = false;
     }
 
     void doByInterval() {
-        //value.valD = IoTgpio.analogRead(_pin);
+        int val = _inv?1:0;
-
+        IoTgpio.digitalWrite(_pin, val);
+        // SerialPrint("I", "ButtonOut","single pulse end");
+        value.valD = 0;
+        regEvent(0, "ButtonOut");
+        enableDoByInt = false;
         //regEvent(value.valD, "ButtonOut");  //обязательный вызов хотяб один
     }
 
@@ -30,24 +34,40 @@ class ButtonOut : public IoTItem {
         // param - вектор ("массив") значений параметров переданных вместе с командой: ID.Команда("пар1", 22, 33) -> param[0].ValS = "пар1", param[1].ValD = 22
     
         if (command == "change") { 
-            value.valD = 1 - IoTgpio.digitalRead(_pin);
+            value.valD = 1 - (int)value.valD;
-            IoTgpio.digitalWrite(_pin, value.valD);
+            IoTgpio.digitalWrite(_pin, _inv?!value.valD:value.valD);
             regEvent(value.valD, "ButtonOut");
         }
-
+        else if (command == "pulse") {
+            if (param[0].isDecimal && (param[0].valD != 0)) {
+                value.valD = !_inv?1:0;
+                enableDoByInt = true;
+                // SerialPrint("I", "ButtonOut","single pulse start");
+                regEvent((String)(int)!_inv?1:0, "ButtonOut");
+                suspendNextDoByInt(param[0].valD);
+                IoTgpio.digitalWrite(_pin, !_inv?1:0);
+            }
+        }
         return {};  // команда поддерживает возвращаемое значения. Т.е. по итогу выполнения команды или общения с внешней системой, можно вернуть значение в сценарий для дальнейшей обработки
     }
 
     void setValue(const IoTValue& Value, bool genEvent = true) {
         value = Value;
-        IoTgpio.digitalWrite(_pin, _inv?!value.valD:value.valD);
+        if ((value.valD == !_inv?1:0) && (_interval != 0)) {
+            value.valD = !_inv?1:0;
+            enableDoByInt = true;
+            // SerialPrint("I", "ButtonOut","single pulse start");
+            suspendNextDoByInt(_interval);
+        } else {
+            enableDoByInt = false;
+        }
         regEvent((String)(int)value.valD, "ButtonOut", false, genEvent);
+        IoTgpio.digitalWrite(_pin, _inv?!value.valD:value.valD);
     }
 
     String getValue() {
         return (String)(int)value.valD;
     }
-    //=======================================================================================================
 
     ~ButtonOut() {};
 };

src/modules/exec/ButtonOut/modinfo.json

@@ -39,6 +39,11 @@
                 "name": "change",
                 "descr": "Инвертирует значение переключателя",
                 "params": []
+            },
+            {
+                "name": "pulse",
+                "descr": "Генерирует одиночный импульс",
+                "params": ["Длительность (ms)"]
             }
         ]
     },

src/modules/exec/Buzzer/Buzzer.cpp

@@ -79,16 +79,7 @@ public:
 
         case 1:
             // for doByIntervals
-            if (enableDoByInt)
+            IoTItem::loop();
-            {
-                currentMillis = millis();
-                difference = currentMillis - prevMillis;
-                if (difference >= _interval)
-                {
-                    prevMillis = millis();
-                    this->doByInterval();
-                }
-            }
             break;
 
         case 2:

src/modules/exec/HttpGet/HttpGet.cpp

@@ -10,7 +10,7 @@ public:
 
     void sendHttpPOST(String url, String msg)
     {
-        if (WiFi.status() == WL_CONNECTED)
+        if (isNetworkActive())
         {
 
             WiFiClient client;

src/modules/exec/MySensors/MySensorsGate.cpp

@@ -3,6 +3,11 @@
 #include "Arduino.h"
 #include "MySensorsGate.h"
 
+// временное решение
+unsigned long currentMillis;
+unsigned long prevMillis;
+unsigned long difference;
+
 #ifdef MYSENSORS
 // callback библиотеки mysensors
 void receive(const MyMessage& message) {

src/modules/exec/TelegramLT/TelegramLT.cpp

@@ -13,7 +13,7 @@ class TelegramLT : public IoTItem {
     }
 
     void sendTelegramMsg(bool often, String msg) {
-        if (WiFi.status() == WL_CONNECTED && (often || !often && _prevMsg != msg)) {
+        if (isNetworkActive() && (often || !often && _prevMsg != msg)) {
             WiFiClient client;
             HTTPClient http;
             http.begin(client, "http://live-control.com/iotm/telegram.php");

src/modules/exec/Thermostat/Thermostat.cpp

@@ -246,6 +246,11 @@ protected:
         pv_last = pv;
     }
 
+// временное решение
+    unsigned long currentMillis;
+    unsigned long prevMillis;
+    unsigned long difference;
+    
     void loop()
     {
         if (enableDoByInt)

src/modules/sensors/AnalogAdc/AnalogAdc.cpp

@@ -64,13 +64,7 @@ class AnalogAdc : public IoTItem {
             _avgSumm = _avgSumm + IoTgpio.analogRead(_pin);
             _avgCount++;
         }
-
+        IoTItem::loop();
-        currentMillis = millis();
-        difference = currentMillis - prevMillis;
-        if (difference >= _interval) {
-            prevMillis = millis();
-            this->doByInterval();
-        }
     }
 
     ~AnalogAdc(){};

src/modules/sensors/ExampleModule/ExampleModule.cpp

@@ -107,13 +107,7 @@ public:
         adc = IoTgpio.analogRead(_pin);
 
         // Блок вызова doByInterval, так как если определили loop, то сам он не вызовится
-        currentMillis = millis();
+        IoTItem::loop();
-        difference = currentMillis - prevMillis;
-        if (difference >= _interval)
-        {
-            prevMillis = millis();
-            this->doByInterval();
-        }
     }
 
     ~ExampleModule_A()

src/modules/sensors/Sds011/Sds011.cpp

@@ -157,16 +157,17 @@ public:
     void loop()
     {
         ts_sds.update();
-        if (enableDoByInt)
+        IoTItem::loop();
-        {
+        // if (enableDoByInt)
-            currentMillis = millis();
+        // {
-            difference = currentMillis - prevMillis;
+        //     currentMillis = millis();
-            if (difference >= _interval)
+        //     difference = currentMillis - prevMillis;
-            {
+        //     if (difference >= _interval)
-                prevMillis = millis();
+        //     {
-                this->doByInterval();
+        //         prevMillis = millis();
-            }
+        //         this->doByInterval();
-        }
+        //     }
+        // }
     }
     //=======================================================================================================
     // doByInterval()

src/modules/virtual/GoogleSheet/GoogleSheet.cpp

@@ -10,7 +10,7 @@ private:
   String scid = "";
   String shname = "";
   //  bool init = false;
-  int interval = 1;
+  // int interval = 1;
   // long interval;
   String URL = ("http://iotmanager.org/projects/google.php?/macros/s/"); // F("https://script.google.com/macros/s/");
   String urlFinal;
@@ -24,14 +24,17 @@ public:
     jsonRead(parameters, F("logid"), logid);
     jsonRead(parameters, F("scid"), scid);
     jsonRead(parameters, F("shname"), shname);
-    jsonRead(parameters, F("int"), interval);
+    // jsonRead(parameters, F("int"), interval);
-    interval = interval * 1000 * 60; // так как у нас в минутах
+    long interval;
+    jsonRead(parameters, F("int"), interval); // в минутах
+    setInterval(interval * 60);
+    // interval = interval * 1000 * 60; // так как у нас в минутах
     urlFinal = URL + scid + F("/exec?") + F("sheet=") + shname;
   }
 
   void doByInterval()
   {
-    if (WiFi.status() == WL_CONNECTED)
+    if (isNetworkActive())
     {
       String value = getItemValue(logid);
       if (value != "")
@@ -39,23 +42,23 @@ public:
     }
   }
 
-  void loop()
+  // void loop()
-  {
+  // {
-    if (enableDoByInt)
+  //   if (enableDoByInt)
-    {
+  //   {
-      currentMillis = millis();
+  //     currentMillis = millis();
-      difference = currentMillis - prevMillis;
+  //     difference = currentMillis - prevMillis;
-      if (difference >= interval)
+  //     if (difference >= interval)
-      {
+  //     {
-        prevMillis = millis();
+  //       prevMillis = millis();
-        this->doByInterval();
+  //       this->doByInterval();
-      }
+  //     }
-    }
+  //   }
-  }
+  // }
 
   IoTValue execute(String command, std::vector<IoTValue> &param)
   {
-    if (WiFi.status() == WL_CONNECTED)
+    if (isNetworkActive())
     {
       if (command == F("logGoogle"))
       { // Логирование определенного элемента по его идентификатору в GoogleSheet

src/modules/virtual/Loging/Loging.cpp

@@ -23,7 +23,7 @@ class Loging : public IoTItem {
     String prevDate = "";
     bool firstTimeInit = true;
 
-    long interval;
+    // long interval;
 
    public:
     Loging(String parameters) : IoTItem(parameters) {
@@ -34,8 +34,9 @@ class Loging : public IoTItem {
             points = 300;
             SerialPrint("E", F("Loging"), "'" + id + "' user set more points than allowed, value reset to 300");
         }
-        jsonRead(parameters, F("int"), interval);
+        long interval;
-        interval = interval * 1000 * 60;  // приводим к милисекундам
+        jsonRead(parameters, F("int"), interval); // в минутах
+        setInterval(interval * 60);
         //jsonRead(parameters, F("keepdays"), keepdays, false);
 
         // создадим экземпляр класса даты
@@ -303,18 +304,18 @@ class Loging : public IoTItem {
         return "";
     }
 
-    void loop() {
+    // void loop() {
-        if (enableDoByInt) {
+    //     if (enableDoByInt) {
-            currentMillis = millis();
+    //         currentMillis = millis();
-            difference = currentMillis - prevMillis;
+    //         difference = currentMillis - prevMillis;
-            if (difference >= interval) {
+    //         if (difference >= interval) {
-                prevMillis = millis();
+    //             prevMillis = millis();
-                if (interval != 0) {
+    //             if (interval != 0) {
-                    this->doByInterval();
+    //                 this->doByInterval();
-                }
+    //             }
-            }
+    //         }
-        }
+    //     }
-    }
+    // }
 
     void regEvent(const String &value, const String &consoleInfo, bool error = false, bool genEvent = true) {
         String userDate = getItemValue(id + "-date");

src/modules/virtual/LogingDaily/LogingDaily.cpp

@@ -25,7 +25,7 @@ class LogingDaily : public IoTItem {
     String prevDate = "";
     bool firstTimeInit = true;
 
-    long interval;
+    // long interval;
 
    public:
     LogingDaily(String parameters) : IoTItem(parameters) {
@@ -40,8 +40,9 @@ class LogingDaily : public IoTItem {
             points = 365;
             SerialPrint("E", F("LogingDaily"), "'" + id + "' user set more points than allowed, value reset to 365");
         }
-        jsonRead(parameters, F("int"), interval);
+        long interval;
-        interval = interval * 1000 * 60;  // приводим к милисекундам
+        jsonRead(parameters, F("int"), interval); // в минутах
+        setInterval(interval * 60);
     }
 
     void doByInterval() {
@@ -225,16 +226,16 @@ class LogingDaily : public IoTItem {
         return "";
     }
 
-    void loop() {
+    // void loop() {
-        if (enableDoByInt) {
+    //     if (enableDoByInt) {
-            currentMillis = millis();
+    //         currentMillis = millis();
-            difference = currentMillis - prevMillis;
+    //         difference = currentMillis - prevMillis;
-            if (difference >= interval) {
+    //         if (difference >= interval) {
-                prevMillis = millis();
+    //             prevMillis = millis();
-                this->doByInterval();
+    //             this->doByInterval();
-            }
+    //         }
-        }
+    //     }
-    }
+    // }
 
     // просто максимальное количество точек
     int calculateMaxCount() {

src/modules/virtual/Weather/Weather.cpp

@@ -11,22 +11,23 @@ class Weather : public IoTItem
 private:
     String _location;
     String _param;
-    long interval;
+    // long interval;
 
 public:
     Weather(String parameters) : IoTItem(parameters)
     {
         _location = jsonReadStr(parameters, "location");
         _param = jsonReadStr(parameters, "param");
-        jsonRead(parameters, F("int"), interval);
+        long interval;
-        interval = interval * 1000 * 60 * 60; // интервал проверки погоды в часах
+        jsonRead(parameters, F("int"), interval); // интервал проверки погоды в часах
+        setInterval(interval * 60 * 60);
     }
 
     void getWeather()
     {
         String ret;
 
-        if (WiFi.status() == WL_CONNECTED)
+        if (isNetworkActive())
         {
             // char c;
             String payload;
@@ -113,19 +114,21 @@ public:
             regEvent(value.valS, "Weather");
         }
     }
-    void loop()
+
-    {
+    // void loop()
-        if (enableDoByInt)
+    // {
-        {
+    //     if (enableDoByInt)
-            currentMillis = millis();
+    //     {
-            difference = currentMillis - prevMillis;
+    //         currentMillis = millis();
-            if (difference >= interval)
+    //         difference = currentMillis - prevMillis;
-            {
+    //         if (difference >= interval)
-                prevMillis = millis();
+    //         {
-                this->doByInterval();
+    //             prevMillis = millis();
-            }
+    //             this->doByInterval();
-        }
+    //         }
-    }
+    //     }
+    // }
+
     IoTValue execute(String command, std::vector<IoTValue> &param)
     {
         if (command == "get")

src/utils/Statistic.cpp

@@ -20,7 +20,7 @@ void updateDeviceStatus() {
     // jsonRead(settingsFlashJson, F("serverip"), serverIP);
     String url = serverIP + F("/projects/esprebootstat.php");
     // SerialPrint("i", "Stat", "url " + url);
-    if ((WiFi.status() == WL_CONNECTED)) {
+    if ((isNetworkActive())) {
         WiFiClient client;
         HTTPClient http;
         http.begin(client, url);

src/utils/WiFiUtils.cpp

@@ -175,36 +175,23 @@ boolean RouterFind(std::vector<String> jArray)
 //     return WiFi.status() == WL_CONNECTED;
 // }
 
-uint8_t RSSIquality()
+uint8_t RSSIquality() {
-{
+    uint8_t res = 0;
-  uint8_t res = 0;
+    if (isNetworkActive()) {
-  if (WiFi.status() == WL_CONNECTED)
+        int rssi = WiFi.RSSI();
-  {
+        if (rssi >= -50) {
-    int rssi = WiFi.RSSI();
+            res = 6;  //"Excellent";
-    if (rssi >= -50)
+        } else if (rssi < -50 && rssi >= -60) {
-    {
+            res = 5;  //"Very good";
-      res = 6; //"Excellent";
+        } else if (rssi < -60 && rssi >= -70) {
+            res = 4;  //"Good";
+        } else if (rssi < -70 && rssi >= -80) {
+            res = 3;  //"Low";
+        } else if (rssi < -80 && rssi > -100) {
+            res = 2;  //"Very low";
+        } else if (rssi <= -100) {
+            res = 1;  //"No signal";
+        }
     }
-    else if (rssi < -50 && rssi >= -60)
+    return res;
-    {
-      res = 5; //"Very good";
-    }
-    else if (rssi < -60 && rssi >= -70)
-    {
-      res = 4; //"Good";
-    }
-    else if (rssi < -70 && rssi >= -80)
-    {
-      res = 3; //"Low";
-    }
-    else if (rssi < -80 && rssi > -100)
-    {
-      res = 2; //"Very low";
-    }
-    else if (rssi <= -100)
-    {
-      res = 1; //"No signal";
-    }
-  }
-  return res;
 }