iotmanager/IoTManager
1
0
Fork 0
mirror of https://github.com/IoTManagerProject/IoTManager.git synced 2026-05-26 04:39:22 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #220 from biveraxe/ver4dev

Browse Source 
Основном оптимизация
This commit is contained in:
Ilya Belyakov
2022-10-29 20:25:53 +03:00
committed by GitHub
parent 2f375f1ddc 94c156f123
commit 27416945a2
32 changed files with 238 additions and 265 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
include/Buffers.h
View File

@@ -1,7 +1,7 @@
#pragma once
#include "Global.h"
#include "MqttClient.h"
//#pragma once
//#include "Global.h"
//#include "MqttClient.h"
void eventGen2(String eventName, String eventValue);
extern void spaceCmdExecute(String &cmdStr);
extern String getValueJson(String &key);
//void eventGen2(String eventName, String eventValue);
//extern void spaceCmdExecute(String &cmdStr);
//extern String getValueJson(String &key);

34
include/classes/IoTItem.h
View File

@@ -10,14 +10,14 @@ struct IoTValue {
class IoTItem {
public:
IoTItem(String parameters);
IoTItem(const String &parameters);
virtual ~IoTItem() {}
virtual void loop();
virtual void doByInterval();
virtual IoTValue execute(String command, std::vector<IoTValue>& param);
virtual void regEvent(String value, String consoleInfo, bool error = false);
virtual void regEvent(float value, String consoleInfo, bool error = false);
virtual void regEvent(const String& value, const String& consoleInfo, bool error = false, bool genEvent = true);
virtual void regEvent(float value, const String& consoleInfo, bool error = false, bool genEvent = true);
String getSubtype();
@@ -38,8 +38,8 @@ class IoTItem {
bool enableDoByInt = true;
virtual IoTGpio* getGpioDriver();
virtual void setValue(IoTValue Value, bool generateEvent = true);
virtual void setValue(String valStr, bool generateEvent = true);
virtual void setValue(const IoTValue& Value, bool genEvent = true);
virtual void setValue(const String& valStr, bool genEvent = true);
String getRoundValue();
//методы для графиков
@@ -51,30 +51,30 @@ class IoTItem {
protected:
bool _needSave = false; // признак необходимости сохранять и загружать значение элемента на flash
String _subtype;
String _id;
unsigned long _interval;
String _subtype = "";
String _id = "";
unsigned long _interval = 1000;
float _multiply; // умножаем на значение
float _plus; // увеличиваем на значение
int _map1;
int _map2;
int _map3;
int _map4;
int _round; // 1, 10, 100, 1000, 10000
int _map1 = 0;
int _map2 = 0;
int _map3 = 0;
int _map4 = 0;
int _round = 1; // 1, 10, 100, 1000, 10000
bool _global = false; // характеристика айтема, что ему нужно слать и принимать события из внешнего мира
};
IoTItem* findIoTItem(String name); // поиск экземпляра элемента модуля по имени
String getItemValue(String name); // поиск плюс получение значения
bool isItemExist(String name); // существует ли айтем
IoTItem* findIoTItem(const String& name); // поиск экземпляра элемента модуля по имени
String getItemValue(const String& name); // поиск плюс получение значения
bool isItemExist(const String& name); // существует ли айтем
StaticJsonDocument<JSON_BUFFER_SIZE>* getLocalItemsAsJSON(); // сбор всех локальных значений Items
class externalVariable : IoTItem { // объект, создаваемый при получении информации о событии на другом контроллере для хранения информации о событии указанное время
public:
externalVariable(String parameters);
externalVariable(const String& parameters);
~externalVariable();
void doByInterval(); // для данного класса doByInterval+int выполняет роль счетчика обратного отсчета до уничтожения
};

24
include/utils/JsonUtils.h
View File

@@ -10,20 +10,20 @@ extern String jsonWriteInt(String& json, String name, int value, bool e = true);
extern String jsonWriteFloat(String& json, String name, float value, bool e = true);
extern String jsonWriteBool(String& json, String name, boolean value, bool e = true);
extern bool jsonRead(String& json, String key, unsigned long& value, bool e = true);
extern bool jsonRead(String& json, String key, float& value, bool e = true);
extern bool jsonRead(String& json, String key, String& value, bool e = true);
extern bool jsonRead(String& json, String key, bool& value, bool e = true);
extern bool jsonRead(String& json, String key, int& value, bool e = true);
extern bool jsonRead(const String& json, String key, unsigned long& value, bool e = true);
extern bool jsonRead(const String& json, String key, float& value, bool e = true);
extern bool jsonRead(const String& json, String key, String& value, bool e = true);
extern bool jsonRead(const String& json, String key, bool& value, bool e = true);
extern bool jsonRead(const String& json, String key, int& value, bool e = true);
extern String jsonReadStr(String& json, String name, bool e = true);
extern int jsonReadInt(String& json, String name, bool e = true);
extern boolean jsonReadBool(String& json, String name, bool e = true);
extern String jsonReadStr(const String& json, String name, bool e = true);
extern int jsonReadInt(const String& json, String name, bool e = true);
extern boolean jsonReadBool(const String& json, String name, bool e = true);
extern bool jsonWriteStr_(String& json, String name, String value, bool e = true);
extern bool jsonWriteBool_(String& json, String name, bool value, bool e = true);
extern bool jsonWriteInt_(String& json, String name, int value, bool e = true);
extern bool jsonWriteFloat_(String& json, String name, float value, bool e = true);
extern bool jsonWriteStr_(String& json, const String& name, const String& value, bool e = true);
extern bool jsonWriteBool_(String& json, const String& name, bool value, bool e = true);
extern bool jsonWriteInt_(String& json, const String& name, int value, bool e = true);
extern bool jsonWriteFloat_(String& json, const String& name, float value, bool e = true);
void writeUint8tValueToJsonString(uint8_t* payload, size_t length, size_t headerLenth, String& json);
extern bool jsonMergeObjects(String& json1, String& json2, bool e = true);
extern void jsonMergeDocs(JsonObject dest, JsonObjectConst src);

2
include/utils/SerialPrint.h
View File

@@ -3,4 +3,4 @@
#include "utils/TimeUtils.h"
#include "classes/IoTItem.h"
void SerialPrint(String errorLevel, String module, String msg, String itemId = "");
void SerialPrint(const String& errorLevel, const String& module, const String& msg, const String& itemId = "");

22
include/utils/StringUtils.h
View File

@@ -8,29 +8,29 @@ void hex2string(byte array[], unsigned int len, char buffer[]);
int string2hex(const char* str, unsigned char* bytes);
uint8_t hexStringToUint8(String hex);
uint8_t hexStringToUint8(const String& hex);
uint16_t hexStringToUint16(String hex);
uint16_t hexStringToUint16(const String& hex);
String selectToMarkerLast(String str, String found);
String selectToMarkerLast(String str, const String& found);
String selectToMarker(String str, String found);
String selectToMarker(String str, const String& found);
String extractInner(String str);
String deleteAfterDelimiter(String str, String found);
String deleteAfterDelimiter(String str, const String& found);
String deleteBeforeDelimiter(String str, String found);
String deleteBeforeDelimiter(String str, const String& found);
String deleteBeforeDelimiterTo(String str, String found);
String deleteBeforeDelimiterTo(String str, const String& found);
String deleteToMarkerLast(String str, String found);
String deleteToMarkerLast(String str, const String& found);
String selectFromMarkerToMarker(String str, String found, int number);
String selectFromMarkerToMarker(String str, const String& found, int number);
size_t itemsCount2(String str, const String& separator);
char* stringToChar(String& str);
char* stringToChar(const String& str);
//size_t itemsCount(String& str, const char* delim);
@@ -42,4 +42,4 @@ String prettyBytes(size_t size);
String uint64ToString(uint64_t input, uint8_t base = 10);
String cleanString(String str);
void cleanString(String& str);

54
src/Buffers.cpp
View File

@@ -1,35 +1,35 @@
#include "Buffers.h"
//#include "Buffers.h"
//генеирует событие
void eventGen2(String eventName, String eventValue) {
if (!jsonReadBool(settingsFlashJson, "scen")) {
return;
}
String event = eventName + " " + eventValue + ",";
eventBuf += event;
// void eventGen2(String eventName, String eventValue) {
// if (!jsonReadBool(settingsFlashJson, "scen")) {
// return;
// }
// String event = eventName + " " + eventValue + ",";
// eventBuf += event;
SerialPrint("i", "Event add", eventName + " " + eventValue);
// SerialPrint("i", "Event add", eventName + " " + eventValue);
if (jsonReadBool(settingsFlashJson, "MqttOut")) {
if (eventName != "timenow") {
publishEvent(eventName, eventValue);
}
}
}
// if (jsonReadBool(settingsFlashJson, "MqttOut")) {
// if (eventName != "timenow") {
// publishEvent(eventName, eventValue);
// }
// }
// }
void spaceCmdExecute(String& cmdStr) {
cmdStr += "\r\n";
cmdStr.replace("\r\n", "\n");
cmdStr.replace("\r", "\n");
while (cmdStr.length()) {
String buf = selectToMarker(cmdStr, "\n");
if (buf != "") {
sCmd.readStr(buf);
SerialPrint("i", F("Order done W"), buf);
}
cmdStr = deleteBeforeDelimiter(cmdStr, "\n");
}
}
// void spaceCmdExecute(String& cmdStr) {
// cmdStr += "\r\n";
// cmdStr.replace("\r\n", "\n");
// cmdStr.replace("\r", "\n");
// while (cmdStr.length()) {
// String buf = selectToMarker(cmdStr, "\n");
// if (buf != "") {
// sCmd.readStr(buf);
// SerialPrint("i", F("Order done W"), buf);
// }
// cmdStr = deleteBeforeDelimiter(cmdStr, "\n");
// }
// }
// String getValueJson(String& key) {
// String live = jsonReadStr(paramsHeapJson, key);

61
src/classes/IoTItem.cpp
View File

@@ -6,7 +6,7 @@
#include "EventsAndOrders.h"
//получение параметров в экземпляр класса
IoTItem::IoTItem(String parameters) {
IoTItem::IoTItem(const String& parameters) {
jsonRead(parameters, F("int"), _interval);
if (_interval == 0) enableDoByInt = false;
_interval = _interval * 1000;
@@ -18,14 +18,6 @@ IoTItem::IoTItem(String parameters) {
if (!jsonRead(parameters, F("global"), _global, false)) _global = false;
String valAsStr;
if (jsonRead(parameters, F("val"), valAsStr, false)) // значение переменной или датчика при инициализации если есть в конфигурации
setValue(valAsStr, false);
jsonRead(parameters, F("needSave"), _needSave, false);
if (_needSave && jsonRead(valuesFlashJson, _id, valAsStr, false)) // пробуем достать из сохранения значение элемента, если указано, что нужно сохранять
setValue(valAsStr, false);
String map;
jsonRead(parameters, F("map"), map, false);
if (map != "") {
@@ -35,6 +27,14 @@ IoTItem::IoTItem(String parameters) {
_map4 = selectFromMarkerToMarker(map, ",", 3).toInt();
} else
_map1 = _map2 = _map3 = _map4 = 0;
String valAsStr = "";
if (jsonRead(parameters, F("val"), valAsStr, false)) // значение переменной или датчика при инициализации если есть в конфигурации
setValue(valAsStr, false);
jsonRead(parameters, F("needSave"), _needSave, false);
if (_needSave && jsonRead(valuesFlashJson, _id, valAsStr, false)) // пробуем достать из сохранения значение элемента, если указано, что нужно сохранять
setValue(valAsStr, false);
}
//луп выполняющий переодическое дерганье
@@ -58,43 +58,41 @@ String IoTItem::getValue() {
}
//определяем тип прилетевшей величины
void IoTItem::setValue(String valStr, bool generateEvent) {
if (value.isDecimal = isDigitDotCommaStr(valStr)) {
void IoTItem::setValue(const String& valStr, bool genEvent) {
value.isDecimal = isDigitDotCommaStr(valStr);
if (value.isDecimal) {
value.valD = valStr.toFloat();
} else {
value.valS = valStr;
}
setValue(value, generateEvent);
setValue(value, genEvent);
}
//
void IoTItem::setValue(IoTValue Value, bool generateEvent) {
void IoTItem::setValue(const IoTValue& Value, bool genEvent) {
value = Value;
if (generateEvent)
if (value.isDecimal) {
regEvent(value.valD, "");
regEvent(value.valD, "", false, genEvent);
} else {
regEvent(value.valS, "");
regEvent(value.valS, "", false, genEvent);
}
}
//когда событие случилось
void IoTItem::regEvent(String value, String consoleInfo, bool error) {
void IoTItem::regEvent(const String& value, const String& consoleInfo, bool error, bool genEvent) {
if (_needSave) {
jsonWriteStr_(valuesFlashJson, _id, value);
needSaveValues = true;
}
generateEvent(_id, value);
publishStatusMqtt(_id, value);
publishStatusWs(_id, value);
SerialPrint("i", "Sensor", consoleInfo + " '" + _id + "' data: " + value + "'");
//SerialPrint("i", "Sensor", consoleInfo + " '" + _id + "' data: " + value + "'");
if (genEvent) {
generateEvent(_id, value);
// проверка если global установлен то шлем всем о событии
// if (_global) {
// SerialPrint("i", F("=>ALLMQTT"), "Broadcast event: ");
// }
//отправка события другим устройствам в сети если не было ошибки==============================
if (jsonReadBool(settingsFlashJson, "mqttin") && _global && !error) {
String json = "{}";
@@ -105,6 +103,7 @@ void IoTItem::regEvent(String value, String consoleInfo, bool error) {
SerialPrint("i", F("<=MQTT"), "Broadcast event: " + json);
}
//========================================================================
}
}
String IoTItem::getRoundValue() {
@@ -120,14 +119,14 @@ String IoTItem::getRoundValue() {
}
}
void IoTItem::regEvent(float regvalue, String consoleInfo, bool error) {
void IoTItem::regEvent(float regvalue, const String& consoleInfo, bool error, bool genEvent) {
value.valD = regvalue;
if (_multiply) value.valD = value.valD * _multiply;
if (_plus) value.valD = value.valD + _plus;
if (_map1 != _map2) value.valD = map(value.valD, _map1, _map2, _map3, _map4);
regEvent(getRoundValue(), consoleInfo, error);
regEvent(getRoundValue(), consoleInfo, error, genEvent);
}
void IoTItem::doByInterval() {}
@@ -162,7 +161,7 @@ IoTGpio* IoTItem::getGpioDriver() {
//сетевое общение====================================================================================================================================
externalVariable::externalVariable(String parameters) : IoTItem(parameters) {
externalVariable::externalVariable(const String& parameters) : IoTItem(parameters) {
prevMillis = millis(); // запоминаем текущее значение таймера для выполения doByInterval после int сек
iAmLocal = false; // указываем, что это сущность прилетела из сети
//Serial.printf("Call from externalVariable: parameters %s %d\n", parameters.c_str(), _interval);
@@ -181,7 +180,7 @@ void externalVariable::doByInterval() { // для данного класса d
IoTItem* myIoTItem;
// поиск элемента модуля в существующей конфигурации
IoTItem* findIoTItem(String name) {
IoTItem* findIoTItem(const String& name) {
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
if ((*it)->getID() == name) return *it;
}
@@ -189,7 +188,7 @@ IoTItem* findIoTItem(String name) {
return nullptr;
}
// поиск плюс получение значения
String getItemValue(String name) {
String getItemValue(const String& name) {
IoTItem* tmp = findIoTItem(name);
if (tmp)
return tmp->getValue();
@@ -198,7 +197,7 @@ String getItemValue(String name) {
}
// существует ли айтем
bool isItemExist(String name) {
bool isItemExist(const String& name) {
IoTItem* tmp = findIoTItem(name);
if (tmp)
return true;

2
src/classes/IoTScenario.cpp
View File

@@ -566,7 +566,7 @@ class IfExprAST : public ExprAST {
// if (!res_ret) Serial.printf("Call from IfExprAST: Cond result = %f, no body result\n", cond_ret->valD);
// else if (res_ret->isDecimal) Serial.printf("Call from IfExprAST: Cond result = %f, result = %f\n", cond_ret->valD, res_ret->valD);
// else Serial.printf("Call from IfExprAST: Cond result = %f, result = %s\n", cond_ret->valD, res_ret->valS.c_str());
Serial.printf("\n");
//Serial.printf("\n");
return cond_ret;
}

4
src/modules/display/Ws2812b/Ws2181b.cpp
View File

@@ -171,14 +171,14 @@ public:
return {};
}
void setValue(IoTValue Value, bool generateEvent = true){
void setValue(const IoTValue& Value, bool genEvent = true){
if (!_strip) return;
value = Value;
int b = map(value.valD, 1,1024,1,255);
_strip->setBrightness(b);
_strip->show();
if (generateEvent) regEvent(value.valD, "Ws2812b");
regEvent(value.valD, "Ws2812b", false, genEvent);
}
~Ws2812b(){};

4
src/modules/exec/ButtonIn/ButtonIn.cpp
View File

@@ -68,9 +68,9 @@ class ButtonIn : public IoTItem {
_lastButtonState = _reading;
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
if (generateEvent) regEvent((String)(int)value.valD, "ButtonIn");
regEvent((String)(int)value.valD, "ButtonIn", false, genEvent);
}
String getValue() {

4
src/modules/exec/ButtonOut/ButtonOut.cpp
View File

@@ -37,10 +37,10 @@ class ButtonOut : public IoTItem {
return {}; // команда поддерживает возвращаемое значения. Т.е. по итогу выполнения команды или общения с внешней системой, можно вернуть значение в сценарий для дальнейшей обработки
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
IoTgpio.digitalWrite(_pin, _inv?!value.valD:value.valD);
if (generateEvent) regEvent((String)(int)value.valD, "ButtonOut");
regEvent((String)(int)value.valD, "ButtonOut", false, genEvent);
}
String getValue() {

4
src/modules/exec/IoTServo/IoTServo.cpp
View File

@@ -52,12 +52,12 @@ class IoTServo : public IoTItem {
return {};
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
if (value.isDecimal & (_oldValue != value.valD)) {
_oldValue = value.valD;
servObj.write(_oldValue);
if (generateEvent) regEvent(value.valD, "IoTServo");
regEvent(value.valD, "IoTServo", false, genEvent);
}
}

4
src/modules/exec/Pwm32/Pwm32.cpp
View File

@@ -54,10 +54,10 @@ class Pwm32 : public IoTItem {
}
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
ledcWrite(_ledChannel, value.valD);
if (generateEvent) regEvent(value.valD, "Pwm32");
regEvent(value.valD, "Pwm32", false, genEvent);
}
//=======================================================================================================

4
src/modules/exec/Pwm8266/Pwm8266.cpp
View File

@@ -44,10 +44,10 @@ class Pwm8266 : public IoTItem {
}
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
IoTgpio.analogWrite(_pin, value.valD);
if (generateEvent) regEvent(value.valD, "Pwm8266");
regEvent(value.valD, "Pwm8266", false, genEvent);
}
//=======================================================================================================

3
src/modules/sensors/Ads1115/Ads1115.cpp
View File

@@ -12,13 +12,12 @@
#include "Wire.h"
#include <Adafruit_ADS1X15.h> // Библиотека для работы с модулями ADS1115 и ADS1015
// to do убрать глобальный экземпляр
Adafruit_ADS1115 ads;
class Ads1115 : public IoTItem {
int _pin;
bool _isRaw;
bool _isInited = false;
Adafruit_ADS1115 ads;
public:
Ads1115(String parameters) : IoTItem(parameters) {

18
src/modules/sensors/AhtXX/AhtXX.cpp
View File

@@ -7,30 +7,30 @@
std::map<String, AHTxx*> ahts;
void printStatus(AHTxx *aht) {
String getStatus(AHTxx *aht) {
switch (aht->getStatus()) {
case AHTXX_NO_ERROR:
Serial.println(F("no error"));
return F("no error");
break;
case AHTXX_BUSY_ERROR:
Serial.println(F("sensor AHT busy, increase polling time"));
return F("sensor AHT busy, increase polling time");
break;
case AHTXX_ACK_ERROR:
Serial.println(F("sensor AHT didn't return ACK, not connected, broken, long wires (reduce speed), bus locked by slave (increase stretch limit)"));
return F("sensor AHT didn't return ACK, not connected, broken, long wires (reduce speed), bus locked by slave (increase stretch limit)");
break;
case AHTXX_DATA_ERROR:
Serial.println(F(" AHT: received data smaller than expected, not connected, broken, long wires (reduce speed), bus locked by slave (increase stretch limit)"));
return F(" AHT: received data smaller than expected, not connected, broken, long wires (reduce speed), bus locked by slave (increase stretch limit)");
break;
case AHTXX_CRC8_ERROR:
Serial.println(F("AHT: computed CRC8 not match received CRC8, this feature supported only by AHT2x sensors"));
return F("AHT: computed CRC8 not match received CRC8, this feature supported only by AHT2x sensors");
break;
default:
Serial.println(F("AHT: unknown status"));
return F("AHT: unknown status");
break;
}
}
@@ -49,7 +49,7 @@ class AhtXXt : public IoTItem {
if (value.valD != AHTXX_ERROR) {
regEvent(value.valD, "AhtXXt");
} else {
printStatus(_aht); //print temperature command status
SerialPrint("E", "Sensor AHTXX", getStatus(_aht), _id);
}
}
@@ -70,7 +70,7 @@ class AhtXXh : public IoTItem {
if (value.valD != AHTXX_ERROR) {
regEvent(value.valD, "AhtXXh");
} else {
printStatus(_aht); //print temperature command status
SerialPrint("E", "Sensor AHTXX", getStatus(_aht), _id);
}
}

6
src/modules/sensors/Bme280/Bme280.cpp
View File

@@ -26,7 +26,7 @@ class Bme280t : public IoTItem {
if (value.valD != NAN && value.valD < 145)
regEvent(value.valD, "Bme280t");
else
SerialPrint("E", "Sensor Bme280t", "Error");
SerialPrint("E", "Sensor Bme280t", "Error", _id);
}
~Bme280t(){};
@@ -46,7 +46,7 @@ class Bme280h : public IoTItem {
if (value.valD != NAN && value.valD < 100)
regEvent(value.valD, "Bme280h");
else
SerialPrint("E", "Sensor Bme280h", "Error");
SerialPrint("E", "Sensor Bme280h", "Error", _id);
}
~Bme280h(){};
@@ -67,7 +67,7 @@ class Bme280p : public IoTItem {
value.valD = value.valD / 1.333224 / 100;
regEvent(value.valD, "Bme280p");
} else
SerialPrint("E", "Sensor Bme280p", "Error");
SerialPrint("E", "Sensor Bme280p", "Error", _id);
}
~Bme280p(){};

4
src/modules/sensors/Bmp280/Bmp280.cpp
View File

@@ -26,7 +26,7 @@ class Bmp280t : public IoTItem {
if (value.valD != NAN && value.valD < 150)
regEvent(value.valD, "Bmp280t");
else
SerialPrint("E", "Sensor Bmp280t", "Error");
SerialPrint("E", "Sensor Bmp280t", "Error", _id);
}
~Bmp280t(){};
@@ -47,7 +47,7 @@ class Bmp280p : public IoTItem {
value.valD = value.valD / 1.333224 / 100;
regEvent(value.valD, "Bmp280p");
} else
SerialPrint("E", "Sensor Bmp280p", "Error");
SerialPrint("E", "Sensor Bmp280p", "Error", _id);
}
~Bmp280p(){};

4
src/modules/sensors/Dht1122/Dht1122.cpp
View File

@@ -26,7 +26,7 @@ class Dht1122t : public IoTItem {
if (String(value.valD) != "nan")
regEvent(value.valD, "Dht1122t");
else
SerialPrint("E", "Sensor DHTt", "Error");
SerialPrint("E", "Sensor DHTt", "Error", _id);
}
~Dht1122t(){};
@@ -46,7 +46,7 @@ class Dht1122h : public IoTItem {
if (String(value.valD) != "nan")
regEvent(value.valD, "Dht1122h");
else
SerialPrint("E", "Sensor DHTh", "Error");
SerialPrint("E", "Sensor DHTh", "Error", _id);
}
~Dht1122h(){};

2
src/modules/sensors/Ds18b20/Ds18b20.cpp
View File

@@ -71,7 +71,7 @@ class Ds18b20 : public IoTItem {
if (value.valD != DEVICE_DISCONNECTED_C)
regEvent(value.valD, ""); //обязательный вызов для отправки результата работы
else
SerialPrint("E", "Sensor Ds18b20", "Error");
SerialPrint("E", "Sensor Ds18b20", "Error", _id);
}
//=======================================================================================================

4
src/modules/sensors/GY21/GY21.cpp
View File

@@ -23,7 +23,7 @@ class GY21t : public IoTItem {
if (value.valD < 300)
regEvent(value.valD, "GY21"); // TODO: найти способ понимания ошибки получения данных
else
SerialPrint("E", "Sensor GY21t", "Error");
SerialPrint("E", "Sensor GY21t", "Error", _id);
}
~GY21t(){};
@@ -39,7 +39,7 @@ class GY21h : public IoTItem {
if (value.valD != 0)
regEvent(value.valD, "GY21h"); // TODO: найти способ понимания ошибки получения данных
else
SerialPrint("E", "Sensor GY21h", "Error");
SerialPrint("E", "Sensor GY21h", "Error", _id);
}
~GY21h(){};

4
src/modules/sensors/Hdc1080/Hdc1080.cpp
View File

@@ -24,7 +24,7 @@ class Hdc1080t : public IoTItem {
if (value.valD < 124)
regEvent(value.valD, "Hdc1080t");
else
SerialPrint("E", "Sensor Hdc1080t", "Error");
SerialPrint("E", "Sensor Hdc1080t", "Error", _id);
}
~Hdc1080t(){};
@@ -39,7 +39,7 @@ class Hdc1080h : public IoTItem {
if (value.valD < 99)
regEvent(value.valD, "Hdc1080h");
else
SerialPrint("E", "Sensor Hdc1080h", "Error");
SerialPrint("E", "Sensor Hdc1080h", "Error", _id);
}
~Hdc1080h(){};

2
src/modules/sensors/Max6675/Max6675.cpp
View File

@@ -29,7 +29,7 @@ class MAX6675t : public IoTItem {
if (String(value.valD) != "nan") {
regEvent(value.valD, "Max6675t");
} else {
SerialPrint("E", "Sensor Max6675t", "Error");
SerialPrint("E", "Sensor Max6675t", "Error", _id);
}
}

4
src/modules/sensors/Sht20/Sht20.cpp
View File

@@ -16,7 +16,7 @@ class Sht20t : public IoTItem {
if (value.valD > -46.85F)
regEvent(value.valD, "Sht20t");
else
SerialPrint("E", "Sensor Sht20t", "Error");
SerialPrint("E", "Sensor Sht20t", "Error", _id);
}
~Sht20t(){};
@@ -32,7 +32,7 @@ class Sht20h : public IoTItem {
if (value.valD != -6)
regEvent(value.valD, "Sht20h");
else
SerialPrint("E", "Sensor Sht20h", "Error");
SerialPrint("E", "Sensor Sht20h", "Error", _id);
}
~Sht20h(){};

4
src/modules/sensors/Sht30/Sht30.cpp
View File

@@ -26,7 +26,7 @@ class Sht30t : public IoTItem {
SerialPrint("E", "Sensor Sht30t", "OK");
if (value.valD < -46.85F) regEvent(value.valD, "Sht30t"); // TODO: найти способ понимания ошибки получения данных
else SerialPrint("E", "Sensor Sht30t", "Error");
else SerialPrint("E", "Sensor Sht30t", "Error", _id);
}
}
~Sht30t() {};
@@ -42,7 +42,7 @@ class Sht30h : public IoTItem {
SerialPrint("E", "Sensor Sht30h", "OK");
if (value.valD != -6) regEvent(value.valD, "Sht30h"); // TODO: найти способ понимания ошибки получения данных
else SerialPrint("E", "Sensor Sht30h", "Error");
else SerialPrint("E", "Sensor Sht30h", "Error", _id);
}
}
~Sht30h() {};

10
src/modules/virtual/Loging/Loging.cpp
View File

@@ -263,7 +263,7 @@ class Loging : public IoTItem {
}
}
void regEvent(String value, String consoleInfo, bool error = false) {
void regEvent(const String& value, const String& consoleInfo, bool error = false, bool genEvent = true) {
String userDate = getItemValue(id + "-date");
String currentDate = getTodayDateDotFormated();
//отправляем в график данные только когда выбран сегодняшний день
@@ -306,14 +306,14 @@ class Date : public IoTItem {
value.isDecimal = false;
}
void setValue(String valStr) {
void setValue(const String& valStr, bool genEvent = true) {
value.valS = valStr;
setValue(value);
setValue(value, genEvent);
}
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
if (generateEvent) regEvent(value.valS, "");
regEvent(value.valS, "", false, genEvent);
//отправка данных при изменении даты
for (std::list<IoTItem *>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
if ((*it)->getSubtype() == "Loging") {

1
src/modules/virtual/Timer/Timer.cpp
View File

@@ -33,6 +33,7 @@ class Timer : public IoTItem {
if (value.valD == 0) {
regEvent(value.valD, "Time's up");
}
if (!_ticker) regEvent(getValue(), "Timer tick", false, false); // только регистрируем изменения без генерации тиков
}
if (_ticker && (value.valD > 0 || _unfin) && !_pause) regEvent(value.valD, "Timer tick");

4
src/modules/virtual/VButton/VButton.cpp
View File

@@ -6,9 +6,9 @@ class VButton : public IoTItem {
public:
VButton(String parameters): IoTItem(parameters) { }
void setValue(IoTValue Value, bool generateEvent = true) {
void setValue(const IoTValue& Value, bool genEvent = true) {
value = Value;
if (generateEvent) regEvent((String)(int)value.valD, "VButton");
regEvent((String)(int)value.valD, "VButton", false, genEvent);
}
String getValue() {

5
src/modules/virtual/Variable/Variable.cpp
View File

@@ -8,11 +8,6 @@ class Variable : public IoTItem {
Variable(String parameters) : IoTItem(parameters) {
}
// особенность данного модуля - просто хранение значения для сценария, нет событий
// void setValue(IoTValue Value, bool generateEvent = true) {
// value = Value;
// }
void doByInterval() {
}
};

86
src/utils/JsonUtils.cpp
View File

@@ -11,113 +11,87 @@ void jsonWriteStrDoc(DynamicJsonDocument& doc, String name, String value) {
}
// new==============================================================================
bool jsonRead(String& json, String key, unsigned long& value, bool e) {
bool ret = true;
bool jsonRead(const String& json, String key, unsigned long& value, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
if (e) {
SerialPrint("EE", F("jsonRead"), error.f_str());
jsonErrorDetected();
}
ret = false;
return false;
} else if (!doc.containsKey(key)) {
if (e) {
SerialPrint("EE", F("jsonRead"), "json key '" + key + "' missing");
SerialPrint("EE", F("jsonRead"), key + " missing");
jsonErrorDetected();
}
ret = false;
return false;
}
value = doc[key].as<unsigned long>();
return ret;
return true;
}
bool jsonRead(String& json, String key, float& value, bool e) {
bool ret = true;
bool jsonRead(const String& json, String key, float& value, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
if (e) {
SerialPrint("EE", F("jsonRead"), error.f_str());
jsonErrorDetected();
}
ret = false;
return false;
} else if (!doc.containsKey(key)) {
if (e) {
SerialPrint("EE", F("jsonRead"), key + " missing");
jsonErrorDetected();
}
ret = false;
return false;
}
value = doc[key].as<float>();
return ret;
return true;
}
bool jsonRead(String& json, String key, String& value, bool e) {
bool ret = true;
bool jsonRead(const String& json, String key, String& value, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
if (e) {
SerialPrint("EE", F("jsonRead"), error.f_str());
jsonErrorDetected();
}
ret = false;
return false;
} else if (!doc.containsKey(key)) {
if (e) {
SerialPrint("EE", F("jsonRead"), key + " missing");
jsonErrorDetected();
}
ret = false;
return false;
}
value = doc[key].as<String>();
return true;
}
bool jsonRead(const String& json, String key, bool& value, bool e) {
int lvalue = value;
bool ret = jsonRead(json, key, lvalue, e);
value = lvalue;
return ret;
}
bool jsonRead(String& json, String key, bool& value, bool e) {
bool ret = true;
bool jsonRead(const String& json, String key, int& value, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
if (e) {
SerialPrint("EE", F("jsonRead"), error.f_str());
jsonErrorDetected();
}
ret = false;
return false;
} else if (!doc.containsKey(key)) {
if (e) {
SerialPrint("EE", F("jsonRead"), key + " missing");
jsonErrorDetected();
}
ret = false;
return false;
}
value = doc[key].as<int>();
return ret;
}
bool jsonRead(String& json, String key, int& value, bool e) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
if (e) {
SerialPrint("EE", F("jsonRead"), error.f_str());
jsonErrorDetected();
}
ret = false;
} else if (!doc.containsKey(key)) {
if (e) {
SerialPrint("EE", F("jsonRead"), key + " missing");
jsonErrorDetected();
}
ret = false;
}
value = doc[key].as<int>();
return ret;
return true;
}
// new==============================================================================
bool jsonWriteStr_(String& json, String key, String value, bool e) {
bool jsonWriteStr_(String& json, const String& key, const String& value, bool e) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
@@ -134,7 +108,7 @@ bool jsonWriteStr_(String& json, String key, String value, bool e) {
return ret;
}
bool jsonWriteBool_(String& json, String key, bool value, bool e) {
bool jsonWriteBool_(String& json, const String& key, bool value, bool e) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
@@ -151,7 +125,7 @@ bool jsonWriteBool_(String& json, String key, bool value, bool e) {
return ret;
}
bool jsonWriteInt_(String& json, String key, int value, bool e) {
bool jsonWriteInt_(String& json, const String& key, int value, bool e) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
@@ -168,7 +142,7 @@ bool jsonWriteInt_(String& json, String key, int value, bool e) {
return ret;
}
bool jsonWriteFloat_(String& json, String key, float value, bool e) {
bool jsonWriteFloat_(String& json, const String &key, float value, bool e) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
@@ -220,7 +194,7 @@ void jsonMergeDocs(JsonObject dest, JsonObjectConst src) {
}
// depricated======================================================================
String jsonReadStr(String& json, String name, bool e) {
String jsonReadStr(const String& json, String name, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
@@ -232,7 +206,7 @@ String jsonReadStr(String& json, String name, bool e) {
return doc[name].as<String>();
}
boolean jsonReadBool(String& json, String name, bool e) {
boolean jsonReadBool(const String& json, String name, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
@@ -244,7 +218,7 @@ boolean jsonReadBool(String& json, String name, bool e) {
return doc[name].as<bool>();
}
int jsonReadInt(String& json, String name, bool e) {
int jsonReadInt(const String& json, String name, bool e) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {

35
src/utils/SerialPrint.cpp
View File

@@ -1,23 +1,16 @@
#include "utils/SerialPrint.h"
void SerialPrint(String errorLevel, String module, String msg, String itemId) {
void SerialPrint(const String& errorLevel, const String& module, const String& msg, const String& itemId) {
String tosend = prettyMillis(millis());
tosend = tosend + " [" + errorLevel + "] [" + module + "] " + msg;
tosend += " [";
tosend += errorLevel;
tosend += "] [";
tosend += module;
tosend += "] ";
tosend += msg;
Serial.println(tosend);
if (errorLevel == "E") {
msg = cleanString(msg);
// создаем событие об ошибке для возможной реакции в сценарии
if (itemId != "") {
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"" + itemId + "_onError\",\"val\":\"" + msg + "\",\"int\":1}"));
generateEvent(itemId + "_onError", "1");
} else {
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"onError\",\"val\":\"" + module + " " + msg + "\",\"int\":1}"));
generateEvent("onError", "1");
}
}
if (isNetworkActive()) {
if (jsonReadInt(settingsFlashJson, F("log")) != 0) {
// String pl = "/log|" + tosend;
@@ -25,4 +18,18 @@ void SerialPrint(String errorLevel, String module, String msg, String itemId) {
sendStringToWs("corelg", tosend, -1);
}
}
if (errorLevel == "E") {
cleanString(tosend);
// создаем событие об ошибке для возможной реакции в сценарии
if (itemId != "") {
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"" + itemId + "_onError\",\"val\":\"" + tosend + "\",\"int\":1}"));
generateEvent(itemId + "_onError", "1");
} else {
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"onError\",\"val\":\"" + module + " " + tosend + "\",\"int\":1}"));
generateEvent("onError", "1");
}
}
}

30
src/utils/StringUtils.cpp
View File

@@ -8,12 +8,12 @@ void writeUint8tToString(uint8_t* payload, size_t length, size_t headerLenth, St
}
}
String selectToMarkerLast(String str, String found) {
String selectToMarkerLast(String str, const String& found) {
int p = str.lastIndexOf(found);
return str.substring(p + found.length());
}
String selectToMarker(String str, String found) {
String selectToMarker(String str, const String& found) {
int p = str.indexOf(found);
return str.substring(0, p);
}
@@ -24,32 +24,32 @@ String extractInner(String str) {
return str.substring(p1 + 1, p2);
}
String deleteAfterDelimiter(String str, String found) {
String deleteAfterDelimiter(String str, const String& found) {
int p = str.indexOf(found);
return str.substring(0, p);
}
String deleteBeforeDelimiter(String str, String found) {
String deleteBeforeDelimiter(String str, const String& found) {
int p = str.indexOf(found) + found.length();
return str.substring(p);
}
String deleteBeforeDelimiterTo(String str, String found) {
String deleteBeforeDelimiterTo(String str, const String& found) {
int p = str.indexOf(found);
return str.substring(p);
}
String deleteToMarkerLast(String str, String found) {
String deleteToMarkerLast(String str, const String& found) {
int p = str.lastIndexOf(found);
return str.substring(0, p);
}
String selectToMarkerPlus(String str, String found, int plus) {
String selectToMarkerPlus(String str, const String& found, int plus) {
int p = str.indexOf(found);
return str.substring(0, p + plus);
}
String selectFromMarkerToMarker(String str, String tofind, int number) {
String selectFromMarkerToMarker(String str, const String& tofind, int number) {
if (str.indexOf(tofind) == -1) {
return "not found";
}
@@ -98,14 +98,14 @@ int string2hex(const char* str, unsigned char* bytes) {
return i;
}
uint8_t hexStringToUint8(String hex) {
uint8_t hexStringToUint8(const String& hex) {
uint8_t tmp = strtol(hex.c_str(), NULL, 0);
if (tmp >= 0x00 && tmp <= 0xFF) {
return tmp;
}
}
uint16_t hexStringToUint16(String hex) {
uint16_t hexStringToUint16(const String& hex) {
uint16_t tmp = strtol(hex.c_str(), NULL, 0);
if (tmp >= 0x0000 && tmp <= 0xFFFF) {
return tmp;
@@ -141,7 +141,7 @@ size_t itemsCount2(String str, const String& separator) {
// return cnt;
// }
char* stringToChar(String& str) {
char* stringToChar(const String& str) {
char* mychar = new char[str.length() + 1];
strcpy(mychar, str.c_str());
return mychar;
@@ -199,11 +199,9 @@ String uint64ToString(uint64_t input, uint8_t base) {
return result;
}
String cleanString(String str) {
String clearStr = "";
const String allowedChars = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz01234567890АБВГДЕЁЖЗИЙКЛМНОПРСТУФХЦЧШЩЪЫЬЭЮЯабвгдеёжзийклмнопрстуфхцчшщъыьэюя.!-+ ";
void cleanString(String& str) {
const String allowedChars = F("ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz01234567890АБВГДЕЁЖЗИЙКЛМНОПРСТУФХЦЧШЩЪЫЬЭЮЯабвгдеёжзийклмнопрстуфхцчшщъыьэюя.!-+ ");
for (size_t i = 0; i < str.length(); i++) {
if (allowedChars.indexOf(str.charAt(i)) != -1) clearStr += str.charAt(i);
if (allowedChars.indexOf(str.charAt(i)) == -1) str.setCharAt(i, ' ');
}
return clearStr;
}