Merge pull request #110 from biveraxe/ver3

Работаем со временем в сценариях и температурой сразу на нескольких линиях

include/Class/ScenarioClass3.h

@@ -10,10 +10,14 @@ class Scenario {
         if (!jsonReadBool(configSetupJson, "scen")) {
             return;
         }
+
         String allBlocks = scenario;
         allBlocks += "\n";
-
+        
         String incommingEvent = selectToMarker(eventBuf, ",");
+        if (incommingEvent == "") {
+            return;
+        }
 
         String incommingEventKey = selectToMarker(incommingEvent, " ");
         String incommingEventValue = selectToMarkerLast(incommingEvent, " ");
@@ -159,18 +163,20 @@ class Scenario {
 
    private:
     bool isScenarioNeedToDo(String &condition, String &incommingEventKey, String &incommingEventValue, int type) {
-        bool res = false;
+        if (condition == "") return false;
         String setEventKey = selectFromMarkerToMarker(condition, " ", 0);
         if (isEventExist(incommingEventKey, setEventKey)) {
             String setEventSign;
             String setEventValue;
-            if (type == 1) preCalculation(condition, setEventSign, setEventValue);
+            String cloneOfIncommingEventValue = incommingEventValue; //клонируем для изменения в preCalculation и передачи для проверки по условиям
+            if (type == 1) preCalculation(condition, setEventSign, cloneOfIncommingEventValue, setEventValue);
             if (type == 2) preCalculationGisteresis(condition, setEventSign, setEventValue);
-            if (isConditionMatch(setEventSign, incommingEventValue, setEventValue)) {
-                res = true;
+            if (isConditionMatch(setEventSign, cloneOfIncommingEventValue, setEventValue)) {
+                return true;
             }
+            //SerialPrint("I", "incommingEventKey", incommingEventKey);
         }
-        return res;
+        return false;
     }
 
     bool isScenarioNeedToDoJson(String &condition) {
@@ -178,8 +184,9 @@ class Scenario {
         String setEventKey = selectFromMarkerToMarker(condition, " ", 0);
         String setEventSign;
         String setEventValue;
-        preCalculation(condition, setEventSign, setEventValue);
+
         String jsonValue = getValue(setEventKey);
+        preCalculation(condition, setEventSign, jsonValue, setEventValue);
         if (isConditionMatch(setEventSign, jsonValue, setEventValue)) {
             res = true;
         }
@@ -200,11 +207,22 @@ class Scenario {
     //    return res;
     //}
 
-    void preCalculation(String &condition, String &setEventSign, String &setEventValue) {
+    void preCalculation(String &condition, String &setEventSign, String &incommingEventValue, String &setEventValue) {
         setEventSign = selectFromMarkerToMarker(condition, " ", 1);
         setEventValue = selectFromMarkerToMarker(condition, " ", 2);
+
         if (!isDigitDotCommaStr(setEventValue)) {
-            setEventValue = getValue(setEventValue);
+            if (isTimeStr(incommingEventValue)) {
+                int hhLStr = selectToMarker(incommingEventValue, ":").toInt();
+                int mmLStr = selectToMarkerLast(incommingEventValue, ":").toInt(); 
+                int hhRStr = selectToMarker(setEventValue, ":").toInt();
+                int mmRStr = selectToMarkerLast(setEventValue, ":").toInt(); 
+
+                incommingEventValue = hhLStr*60 + mmLStr;
+                setEventValue = hhRStr*60 + mmRStr;
+            } else {
+                setEventValue = getValue(setEventValue);
+            }
         }
     }
 
@@ -228,14 +246,20 @@ class Scenario {
 
     bool isEventExist(String &incommingEventKey, String &setEventKey) {
         bool res = false;
-        if (incommingEventKey == setEventKey) {
+        if (incommingEventKey != "not found" && incommingEventKey == setEventKey) {
             res = true;
         }
         return res;
     }
 
     bool isConditionMatch(String &setEventSign, String &incommingEventValue, String &setEventValue) {
+        if (setEventValue == "no value") return false;
+        
         boolean flag = false;
+        //SerialPrint("I", "setEventSign", setEventSign);
+        //SerialPrint("I", "incommingEventValue", incommingEventValue);
+        //SerialPrint("I", "setEventValue", setEventValue);
+        //SerialPrint("I", "==========", "===============");
         if (setEventSign == "=") {
             flag = incommingEventValue == setEventValue;
         } else if (setEventSign == "!=") {
@@ -249,6 +273,7 @@ class Scenario {
         } else if (setEventSign == "<=") {
             flag = incommingEventValue.toFloat() <= setEventValue.toFloat();
         }
+
         return flag;
     }
 };

include/Utils/StringUtils.h

@@ -34,6 +34,8 @@ size_t itemsCount(String& str, const char* delim);
 
 boolean isDigitStr(const String& str);
 
+boolean isTimeStr(const String& str);
+
 boolean isDigitDotCommaStr(const String& str);
 
 String prettyBytes(size_t size);

include/items/vSensorDallas.h

@@ -32,6 +32,10 @@ class SensorDallas {
     String _addr;
     unsigned int _pin;
     unsigned int _index;
+
+    //для работы библиотеки с несколькими линиями  необходимо обеспечить каждый экземпляр класса ссылками на объекты настроенные на эти линии
+    OneWire* oneWire;
+    DallasTemperature* sensors;
 };
 
 extern MySensorDallasVector* mySensorDallas2;

src/Utils/StringUtils.cpp

@@ -155,6 +155,18 @@ boolean isDigitStr(const String& str) {
     return str.length();
 }
 
+boolean isTimeStr(const String& str) {
+    
+    for (size_t i = 0; i < str.length(); i++) {
+        char latter = str.charAt(i);
+        if (!isDigit(latter) && latter != ':') {
+            return false;
+        }
+    }
+    if (str.charAt(2) != ':') return false;
+    return true;
+}
+
 boolean isDigitDotCommaStr(const String& str) {
     for (size_t i = 0; i < str.length(); i++) {
         char latter = str.charAt(i);

src/items/vSensorDallas.cpp

@@ -6,12 +6,13 @@
 #include "Global.h"
 #include "DallasTemperature.h"
 #include "Utils/StringUtils.h"
+#include <map>
 
 #include <Arduino.h>
 
 //ИНТЕГРИРУЮ: переменные необходимые для работы интегрируемой библиотеки. Аналог Arduino
-OneWire* oneWire;
-DallasTemperature sensors;
+std::map<int, OneWire*> oneWireTemperatureArray;
+std::map<int, DallasTemperature*> sensorsTemperatureArray;
 
 //ИНТЕГРИРУЮ:
 //Для каждого датчика указанного в конфигурации вызывается конструктор для настройки перед запуском. Аналог функции setup() в Arduino.
@@ -26,10 +27,20 @@ SensorDallas::SensorDallas(unsigned long interval, unsigned int pin, unsigned in
 
     //ИНТЕГРИРУЮ: 
     //вызываем необходимые инициирующие функции интегрируемой библиотеки
-    oneWire = new OneWire((uint8_t)_pin);
-    sensors.setOneWire(oneWire);
-    sensors.begin();
-    sensors.setResolution(12);
+    //учитываем, что библиотека может работать с несколькими линиями на разных пинах, поэтому инициируем библиотеку, если линия ранее не использовалась
+    if (oneWireTemperatureArray.find(_pin) == oneWireTemperatureArray.end()) {
+        oneWire = new OneWire((uint8_t)_pin);
+        sensors = new DallasTemperature();
+        sensors->setOneWire(oneWire);
+        sensors->begin();
+        sensors->setResolution(12);
+
+        oneWireTemperatureArray[_pin] = oneWire;
+        sensorsTemperatureArray[_pin] = sensors;
+    } else {
+        oneWire = oneWireTemperatureArray[_pin];
+        sensors = sensorsTemperatureArray[_pin];
+    }
 }
 
 //ИНТЕГРИРУЮ: оставляем как есть или развиваем, если нужно правильно завершить работу с интегрируемой библиотекой после отключения датчика
@@ -48,18 +59,18 @@ void SensorDallas::loop() {
 //ИНТЕГРИРУЮ: вызывается из цикла loop каждый установленный временно интервал в параметрах датчика. Необходимо изменить для чтения данных из датчика.
 void SensorDallas::readDallas() {
     //запускаем опрос измерений у всех датчиков на линии
-    sensors.requestTemperatures();
+    sensors->requestTemperatures();
     
     //Определяем адрес. Если парамтер addr не установлен, то узнаем адрес по индексу
     DeviceAddress deviceAddress;
     if (_addr == "") {
-        sensors.getAddress(deviceAddress, _index);
+        sensors->getAddress(deviceAddress, _index);
     } else {
         string2hex(_addr.c_str(), deviceAddress);
     }
 
     //получаем температуру по адресу
-    float value = sensors.getTempC(deviceAddress);
+    float value = sensors->getTempC(deviceAddress);
     
     //ИНТЕГРИРУЮ: блок генерации уведомлений в ядре системы. Стоит обратить внимание только на формат выводимого сообщения в консоли. 
     eventGen2(_key, String(value));