diff --git a/include/Class/ScenarioClass3.h b/include/Class/ScenarioClass3.h index 177fcdce..ca09d7e1 100644 --- a/include/Class/ScenarioClass3.h +++ b/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; } }; diff --git a/include/Utils/StringUtils.h b/include/Utils/StringUtils.h index 36784ad5..02520618 100644 --- a/include/Utils/StringUtils.h +++ b/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); diff --git a/include/items/vSensorDallas.h b/include/items/vSensorDallas.h index 23704f3e..a30677cc 100644 --- a/include/items/vSensorDallas.h +++ b/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; diff --git a/src/Utils/StringUtils.cpp b/src/Utils/StringUtils.cpp index cf67f1ab..ac78ab04 100644 --- a/src/Utils/StringUtils.cpp +++ b/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); diff --git a/src/items/vSensorDallas.cpp b/src/items/vSensorDallas.cpp index 3e621bd4..4c53a50b 100644 --- a/src/items/vSensorDallas.cpp +++ b/src/items/vSensorDallas.cpp @@ -6,12 +6,13 @@ #include "Global.h" #include "DallasTemperature.h" #include "Utils/StringUtils.h" +#include #include //ИНТЕГРИРУЮ: переменные необходимые для работы интегрируемой библиотеки. Аналог Arduino -OneWire* oneWire; -DallasTemperature sensors; +std::map oneWireTemperatureArray; +std::map 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));