Merge pull request #269 from biveraxe/ver4dev

Много мелких правок март 2023
This commit is contained in:
2023-04-07 20:56:48 +03:00
committed by GitHub
48 changed files with 523 additions and 234 deletions

View File

@@ -20,6 +20,8 @@
# esp8266_1mb_ota
# esp8285_1mb
# esp8285_1mb_ota
# esp8266_2mb
# esp8266_2mb_ota
import configparser
import os, json, sys, getopt
@@ -119,7 +121,7 @@ deviceName = profJson['projectProp']['platformio']['default_envs']
# назначаем папку с файлами прошивки в зависимости от устройства и запоминаем в профиле
dataDir = 'data_svelte'
if deviceName == 'esp8266_1mb_ota' or deviceName == 'esp8285_1mb_ota':
if deviceName == 'esp8266_1mb_ota' or deviceName == 'esp8285_1mb_ota' or deviceName == 'esp8266_2mb_ota':
dataDir = 'data_svelte_lite'
profJson['projectProp'] = {
'platformio': {

View File

@@ -574,8 +574,8 @@
"descr": "",
"widget": "nil",
"id": "u",
"tx": 12,
"rx": 13,
"tx": 4,
"rx": 5,
"line": 2,
"speed": 9600,
"eventFormat": 0,

View File

@@ -11,6 +11,14 @@
#define FIRMWARE_NAME "esp8266_1mb"
#endif
#ifdef esp8266_2mb
#define FIRMWARE_NAME "esp8266_2mb"
#endif
#ifdef esp8266_2mb_ota
#define FIRMWARE_NAME "esp8266_2mb_ota"
#endif
#ifdef esp8266_4mb
#define FIRMWARE_NAME "esp8266_4mb"
#endif

View File

@@ -24,6 +24,7 @@ class IoTItem {
String getSubtype();
String getID();
bool isStrInID(const String& str);
int getIntFromNet();
virtual String getValue();
long getInterval();
@@ -47,7 +48,7 @@ class IoTItem {
virtual IoTGpio* getGpioDriver();
virtual IoTItem* getRtcDriver();
virtual ulong getRtcUnixTime();
virtual unsigned long getRtcUnixTime();
virtual void setValue(const IoTValue& Value, bool genEvent = true);
virtual void setValue(const String& valStr, bool genEvent = true);
@@ -91,6 +92,7 @@ class IoTItem {
};
IoTItem* findIoTItem(const String& name); // поиск экземпляра элемента модуля по имени
IoTItem* findIoTItemByPartOfName(const String& partName); // поиск элемента модуля в существующей конфигурации по части имени
String getItemValue(const String& name); // поиск плюс получение значения
bool isItemExist(const String& name); // существует ли айтем
//StaticJsonDocument<JSON_BUFFER_SIZE>* getLocalItemsAsJSON(); // сбор всех локальных значений Items

View File

@@ -70,6 +70,48 @@ build_src_filter =
+<modules/*.cpp>
${env:esp8285_1mb_ota_fromitems.build_src_filter}
[env:esp8266_2mb]
lib_deps =
${common_env_data.lib_deps_external}
${env:esp8266_2mb_fromitems.lib_deps}
ESPAsyncUDP
build_flags = -Desp8266_2mb="esp8266_2mb"
framework = arduino
board = d1_wroom_02
board_build.ldscript = eagle.flash.2m1m.ld
platform = espressif8266
monitor_filters = esp8266_exception_decoder
upload_speed = 921600
monitor_speed = 115200
board_build.filesystem = littlefs
build_src_filter =
+<*.cpp>
+<classes/*.cpp>
+<utils/*.cpp>
+<modules/*.cpp>
${env:esp8266_2mb_fromitems.build_src_filter}
[env:esp8266_2mb_ota]
lib_deps =
${common_env_data.lib_deps_external}
${env:esp8266_2mb_fromitems.lib_deps}
ESPAsyncUDP
build_flags = -Desp8266_2mb_ota="esp8266_2mb_ota"
framework = arduino
board = d1_wroom_02
board_build.ldscript = eagle.flash.2m256.ld
platform = espressif8266
monitor_filters = esp8266_exception_decoder
upload_speed = 921600
monitor_speed = 115200
board_build.filesystem = littlefs
build_src_filter =
+<*.cpp>
+<classes/*.cpp>
+<utils/*.cpp>
+<modules/*.cpp>
${env:esp8266_2mb_fromitems.build_src_filter}
[env:esp8285_1mb]
lib_deps =
${common_env_data.lib_deps_external}
@@ -116,7 +158,6 @@ build_src_filter =
lib_deps =
${common_env_data.lib_deps_external}
${env:esp32_4mb_fromitems.lib_deps}
plerup/EspSoftwareSerial@^7.0.0
build_flags = -Desp32_4mb="esp32_4mb"
framework = arduino
board = esp32dev
@@ -135,69 +176,74 @@ build_src_filter =
[env:esp8266_1mb_ota_fromitems]
lib_deps =
adafruit/Adafruit BME280 Library
adafruit/Adafruit BMP280 Library
https://github.com/milesburton/Arduino-Temperature-Control-Library
https://github.com/tremaru/iarduino_RTC
robtillaart/SHT2x@^0.1.1
WEMOS SHT3x@1.0.0
adafruit/Adafruit MCP23017 Arduino Library@^2.1.0
adafruit/Adafruit BusIO @ ^1.13.2
adafruit/Adafruit BusIO @ ^1.13.2
https://github.com/robotclass/RobotClass_LiquidCrystal_I2C
marcoschwartz/LiquidCrystal_I2C@^1.1.4
plerup/espsoftwareserial
build_src_filter =
+<modules/virtual/Cron>
+<modules/virtual/Loging>
+<modules/virtual/LogingDaily>
+<modules/virtual/Timer>
+<modules/virtual/Variable>
+<modules/virtual/VariableColor>
+<modules/virtual/VButton>
+<modules/sensors/AnalogAdc>
+<modules/sensors/Bme280>
+<modules/sensors/Bmp280>
+<modules/sensors/Ds18b20>
+<modules/sensors/RTC>
+<modules/sensors/Sht20>
+<modules/sensors/Sht30>
+<modules/sensors/Sonar>
+<modules/exec/ButtonIn>
+<modules/exec/ButtonOut>
+<modules/exec/Mcp23017>
+<modules/exec/Multitouch>
+<modules/exec/Pcf8574>
+<modules/exec/Pwm8266>
+<modules/sensors/Pzem004t>
+<modules/sensors/UART>
+<modules/exec/TelegramLT>
+<modules/display/Lcd2004>
[env:esp8266_1mb_fromitems]
lib_deps =
adafruit/Adafruit BME280 Library
adafruit/Adafruit BMP280 Library
milesburton/DallasTemperature@^3.9.1
robtillaart/SHT2x@^0.1.1
WEMOS SHT3x@1.0.0
adafruit/Adafruit MCP23017 Arduino Library@^2.1.0
adafruit/Adafruit BusIO @ ^1.13.2
adafruit/Adafruit BusIO @ ^1.13.2
marcoschwartz/LiquidCrystal_I2C@^1.1.4
plerup/espsoftwareserial
build_src_filter =
+<modules/virtual/Cron>
+<modules/virtual/Loging>
+<modules/virtual/LogingDaily>
+<modules/virtual/Timer>
+<modules/virtual/Variable>
+<modules/virtual/VariableColor>
+<modules/virtual/VButton>
+<modules/sensors/AnalogAdc>
+<modules/sensors/Bme280>
+<modules/sensors/Bmp280>
+<modules/sensors/Ds18b20>
+<modules/sensors/Sht20>
+<modules/sensors/Sht30>
+<modules/sensors/Sonar>
+<modules/sensors/Pzem004t>
+<modules/sensors/UART>
+<modules/exec/ButtonIn>
+<modules/exec/ButtonOut>
+<modules/exec/Mcp23017>
+<modules/exec/Multitouch>
+<modules/exec/Pcf8574>
+<modules/exec/Pwm8266>
+<modules/exec/TelegramLT>
+<modules/display/Lcd2004>
[env:esp8266_2mb_fromitems]
lib_deps =
plerup/EspSoftwareSerial
build_src_filter =
+<modules/virtual/Cron>
+<modules/virtual/Loging>
+<modules/virtual/LogingDaily>
+<modules/virtual/Timer>
+<modules/virtual/Variable>
+<modules/virtual/VariableColor>
+<modules/virtual/VButton>
+<modules/sensors/Pzem004t>
+<modules/sensors/UART>
+<modules/exec/TelegramLT>
[env:esp8266_2mb_ota_fromitems]
lib_deps =
plerup/EspSoftwareSerial
build_src_filter =
+<modules/virtual/Cron>
+<modules/virtual/Loging>
+<modules/virtual/LogingDaily>
+<modules/virtual/Timer>
+<modules/virtual/Variable>
+<modules/virtual/VariableColor>
+<modules/virtual/VButton>
+<modules/sensors/Pzem004t>
+<modules/sensors/UART>
+<modules/exec/TelegramLT>
[env:esp8285_1mb_ota_fromitems]
lib_deps =
@@ -264,7 +310,7 @@ lib_deps =
https://github.com/tremaru/iarduino_RTC
robtillaart/SHT2x@^0.1.1
WEMOS SHT3x@1.0.0
plerup/EspSoftwareSerial@^7.0.0
plerup/EspSoftwareSerial
adafruit/Adafruit MCP23017 Arduino Library@^2.1.0
adafruit/Adafruit BusIO @ ^1.13.2
dfrobot/DFRobotDFPlayerMini @ ^1.0.5
@@ -305,22 +351,10 @@ build_src_filter =
[env:esp32_4mb_fromitems]
lib_deps =
https://github.com/enjoyneering/AHTxx.git
adafruit/Adafruit BME280 Library
adafruit/Adafruit BMP280 Library
beegee-tokyo/DHT sensor library for ESPx
https://github.com/milesburton/Arduino-Temperature-Control-Library
https://github.com/tremaru/iarduino_RTC
robtillaart/SHT2x@^0.1.1
WEMOS SHT3x@1.0.0
plerup/espsoftwareserial
https://github.com/RoboticsBrno/ServoESP32
adafruit/Adafruit MCP23017 Arduino Library@^2.1.0
adafruit/Adafruit BusIO @ ^1.13.2
dfrobot/DFRobotDFPlayerMini @ ^1.0.5
adafruit/Adafruit BusIO @ ^1.13.2
https://github.com/robotclass/RobotClass_LiquidCrystal_I2C
marcoschwartz/LiquidCrystal_I2C@^1.1.4
plerup/EspSoftwareSerial
build_src_filter =
+<modules/virtual/Cron>
+<modules/virtual/Loging>
@@ -329,28 +363,12 @@ build_src_filter =
+<modules/virtual/Variable>
+<modules/virtual/VariableColor>
+<modules/virtual/VButton>
+<modules/sensors/Acs712>
+<modules/sensors/AhtXX>
+<modules/sensors/AnalogAdc>
+<modules/sensors/Bme280>
+<modules/sensors/Bmp280>
+<modules/sensors/Dht1122>
+<modules/sensors/Ds18b20>
+<modules/sensors/Pzem004t>
+<modules/sensors/RTC>
+<modules/sensors/Sht20>
+<modules/sensors/Sht30>
+<modules/sensors/Sonar>
+<modules/sensors/UART>
+<modules/exec/ButtonIn>
+<modules/exec/ButtonOut>
+<modules/exec/IoTServo>
+<modules/exec/Mcp23017>
+<modules/exec/Mp3>
+<modules/exec/Multitouch>
+<modules/exec/Pcf8574>
+<modules/exec/Pwm32>
+<modules/exec/TelegramLT>
+<modules/display/DwinI>
+<modules/display/Lcd2004>

View File

@@ -51,10 +51,16 @@ void handleEvent() {
if (eventBuf.length()) {
String event = selectToMarker(eventBuf, ",");
SerialPrint("i", F("EVENT"), event);
String enentIdName = selectToMarker(event, " ");
// распространяем событие через хуки
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
(*it)->onRegEvent(findIoTItem(enentIdName));
}
//здесь нужно пропускать данное событие через условия сценариев
//и если оно есть в условии сценария и совподает
iotScen.exec(selectToMarker(event, " "));
iotScen.exec(enentIdName);
eventBuf = deleteBeforeDelimiter(eventBuf, ",");
}

View File

@@ -44,7 +44,7 @@ void ntpInit() {
}
void synchTime() {
configTime(0, 0, "pool.ntp.org", "ru.pool.ntp.org", "pool.ntp.org");
configTime(0, 0, "pool.ntp.org", "ru.pool.ntp.org", jsonReadStr(settingsFlashJson, F("ntp")).c_str());
}
//событие смены даты

View File

@@ -72,7 +72,7 @@ bool upgradeBuild() {
handleUpdateStatus(true, PATH_ERROR);
return ret;
}
#if defined (esp8266_4mb) || defined (esp8266_1mb) || defined (esp8266_1mb_ota)
#if defined (esp8266_4mb) || defined (esp8266_1mb) || defined (esp8266_1mb_ota) || defined (esp8266_2mb) || defined (esp8266_2mb_ota)
ESPhttpUpdate.rebootOnUpdate(false);
t_httpUpdate_return retBuild = ESPhttpUpdate.update(wifiClient, getBinPath("firmware.bin"));
#endif

View File

@@ -101,11 +101,6 @@ void IoTItem::regEvent(const String& value, const String& consoleInfo, bool erro
if (genEvent) {
generateEvent(_id, value);
// распространяем событие через хуки
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
(*it)->onRegEvent(this);
}
// отправка события другим устройствам в сети если не было ошибки
if (_global && !error) {
String json = "{}";
@@ -200,6 +195,10 @@ String IoTItem::getID() {
return _id;
};
bool IoTItem::isStrInID(const String& str) {
return _id.indexOf(str) != -1;
}
void IoTItem::setInterval(long interval) {
_interval = interval;
}
@@ -212,7 +211,7 @@ IoTItem* IoTItem::getRtcDriver() {
return nullptr;
}
ulong IoTItem::getRtcUnixTime() {
unsigned long IoTItem::getRtcUnixTime() {
return 0;
}
@@ -245,6 +244,17 @@ IoTItem* findIoTItem(const String& name) {
return nullptr;
}
// поиск элемента модуля в существующей конфигурации по части имени
IoTItem* findIoTItemByPartOfName(const String& partName) {
if (partName == "") return nullptr;
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
if ((*it)->isStrInID(partName)) return *it;
}
return nullptr;
}
// поиск плюс получение значения
String getItemValue(const String& name) {
IoTItem* tmp = findIoTItem(name);

View File

@@ -156,8 +156,8 @@ class BinaryExprAST : public ExprAST {
IoTValue *lhs = LHS->exec(); // если присваивания не произошло, значит операция иная и необходимо значение левого операнда
if (lhs == nullptr) return nullptr;
// все бинарные операции кроме +, - и == обязаны работать с числами
if (Op != '+' && Op != '-' && Op != tok_equal) {
// все бинарные операции кроме +, -, != и == обязаны работать с числами
if (Op != '+' && Op != '-' && Op != tok_equal && Op != tok_notequal) {
// поэтому преобразовываем строки в булевые интерпретации
if (!lhs->isDecimal) lhs->valD = lhs->valS != ""; // пустая строка = false
if (!rhs->isDecimal) rhs->valD = rhs->valS != ""; // пустая строка = false
@@ -175,9 +175,6 @@ class BinaryExprAST : public ExprAST {
case tok_greateq:
val.valD = lhs->valD >= rhs->valD;
break;
case tok_notequal:
val.valD = lhs->valD != rhs->valD;
break;
case '*':
val.valD = lhs->valD * rhs->valD;
@@ -199,7 +196,7 @@ class BinaryExprAST : public ExprAST {
default:
break;
}
} else { // иначе имеем дело с операциями + или - или ==, которые могут работать с разными типами данных
} else { // иначе имеем дело с операциями + или - или == или !=, которые могут работать с разными типами данных
if (lhs->isDecimal && lhs->valS == "") lhs->valS = (String)lhs->valD; // небольшой костыль пока не переделаем работу со значениями, планируется добавить long, работу со временем, перенести округление и модификаторы в IoTValue
if (rhs->isDecimal && rhs->valS == "") rhs->valS = (String)rhs->valD; // пока для сохранения округления в IoTItem применяется хитрость с сохранением внешнего вида числа в строку valS,
// но некоторые модули и системные не делают этого, поэтому отлавливаем эту ситуацию тут и учитываем.
@@ -211,6 +208,13 @@ class BinaryExprAST : public ExprAST {
val.valD = compStr(lhs->valS, rhs->valS);
break;
case tok_notequal:
if (lhs->isDecimal && rhs->isDecimal)
val.valD = lhs->valD != rhs->valD;
else
val.valD = !compStr(lhs->valS, rhs->valS);
break;
case '+':
if (lhs->isDecimal && rhs->isDecimal)
val.valD = lhs->valD + rhs->valD;

View File

@@ -127,6 +127,14 @@
"esp8285_1mb_ota": [
"https://github.com/robotclass/RobotClass_LiquidCrystal_I2C",
"marcoschwartz/LiquidCrystal_I2C@^1.1.4"
],
"esp8266_2mb": [
"https://github.com/robotclass/RobotClass_LiquidCrystal_I2C",
"marcoschwartz/LiquidCrystal_I2C@^1.1.4"
],
"esp8266_2mb_ota": [
"https://github.com/robotclass/RobotClass_LiquidCrystal_I2C",
"marcoschwartz/LiquidCrystal_I2C@^1.1.4"
]
}
}

View File

@@ -50,6 +50,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -49,6 +49,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -34,14 +34,14 @@
"name": "get",
"descr": "Отправить http запрос методом GET.",
"params": [
"http.get('URL')"
"URL"
]
},
{
"name": "post",
"descr": "Отправить http запрос методом POST.",
"params": [
"http.post('URL','message')"
"URL","message"
]
}
]
@@ -53,6 +53,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -62,6 +62,14 @@
"esp8285_1mb_ota": [
"adafruit/Adafruit Mcp23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb": [
"adafruit/Adafruit Mcp23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb_ota": [
"adafruit/Adafruit Mcp23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
]
}
}

View File

@@ -62,6 +62,14 @@
"esp8285_1mb_ota": [
"adafruit/Adafruit MCP23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb": [
"adafruit/Adafruit MCP23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb_ota": [
"adafruit/Adafruit MCP23017 Arduino Library@^2.1.0",
"adafruit/Adafruit BusIO @ ^1.13.2"
]
}
}

View File

@@ -48,6 +48,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -50,6 +50,12 @@
],
"esp8285_1mb_ota": [
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb": [
"adafruit/Adafruit BusIO @ ^1.13.2"
],
"esp8266_2mb_ota": [
"adafruit/Adafruit BusIO @ ^1.13.2"
]
}
}

View File

@@ -46,6 +46,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -60,6 +60,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -134,6 +134,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -46,6 +46,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -85,6 +85,24 @@
],
"esp8266_4mb": [
"adafruit/Adafruit BME280 Library"
],
"esp8266_1mb": [
"adafruit/Adafruit BME280 Library"
],
"esp8266_1mb_ota": [
"adafruit/Adafruit BME280 Library"
],
"esp8285_1mb": [
"adafruit/Adafruit BME280 Library"
],
"esp8285_1mb_ota": [
"adafruit/Adafruit BME280 Library"
],
"esp8266_2mb": [
"adafruit/Adafruit BME280 Library"
],
"esp8266_2mb_ota": [
"adafruit/Adafruit BME280 Library"
]
}
}

View File

@@ -64,11 +64,20 @@
"esp8266_1mb_ota": [
"adafruit/Adafruit BMP280 Library"
],
"esp8266_2mb": [
"adafruit/Adafruit BMP280 Library"
],
"esp8285_1mb": [
"adafruit/Adafruit BMP280 Library"
],
"esp8285_1mb_ota": [
"adafruit/Adafruit BMP280 Library"
],
"esp8266_2mb": [
"adafruit/Adafruit BMP280 Library"
],
"esp8266_2mb_ota": [
"adafruit/Adafruit BMP280 Library"
]
}
}

View File

@@ -35,17 +35,13 @@
},
"defActive": false,
"usedLibs": {
"esp32_4mb": [
],
"esp8266_4mb": [
],
"esp8266_1mb": [
],
"esp8266_1mb_ota": [
],
"esp8285_1mb": [
],
"esp8285_1mb_ota": [
]
"esp32_4mb": [],
"esp8266_4mb": [],
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -56,6 +56,12 @@
],
"esp8285_1mb_ota": [
"https://github.com/milesburton/Arduino-Temperature-Control-Library"
],
"esp8266_2mb": [
"https://github.com/milesburton/Arduino-Temperature-Control-Library"
],
"esp8266_2mb_ota": [
"https://github.com/milesburton/Arduino-Temperature-Control-Library"
]
}
}

View File

@@ -53,6 +53,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -30,9 +30,10 @@ class PZEMSensor {
bool search();
// Get most up to date values from device registers and cache them
bool refresh();
void updateSerial(Stream *serial) {_serial = serial;}
private:
void init(void);
void init(void);
private:
PZEM_Info _values; // Measured values

View File

@@ -1,23 +1,25 @@
#include "Global.h"
#include "classes/IoTItem.h"
#include "PZEMSensor.h"
#include "modules/sensors/UART/Uart.h"
#include <map>
// глобальные списки необходимы для хранения объектов об экземплярах Pzem . Ключ - адрес
std::map<String, PZEMSensor*> pzemSensorArray;
//PZEMContainer _pzemCntr;
class Pzem004v : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004v(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
// раскомментируйте эту строку если нужно поменять адрес pzem
// SerialPrint("i", "Pzem", String(pzem->setAddress(0x03)));
}
Pzem004v(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -28,8 +30,11 @@ class Pzem004v : public IoTItem {
regEvent(value.valD, "Pzem V");
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error");
SerialPrint("E", "Pzem", "V error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -39,14 +44,11 @@ class Pzem004v : public IoTItem {
class Pzem004a : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004a(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
}
Pzem004a(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -57,8 +59,11 @@ class Pzem004a : public IoTItem {
regEvent(value.valD, "Pzem A");
} else {
regEvent(NAN, "Pzem A");
SerialPrint("E", "Pzem", "A error");
SerialPrint("E", "Pzem", "A error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -68,14 +73,11 @@ class Pzem004a : public IoTItem {
class Pzem004w : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004w(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
}
Pzem004w(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -86,8 +88,11 @@ class Pzem004w : public IoTItem {
regEvent(value.valD, "Pzem W");
} else {
regEvent(NAN, "Pzem W");
SerialPrint("E", "Pzem", "W error");
SerialPrint("E", "Pzem", "W error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -97,14 +102,11 @@ class Pzem004w : public IoTItem {
class Pzem004wh : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004wh(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
}
Pzem004wh(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -115,8 +117,11 @@ class Pzem004wh : public IoTItem {
regEvent(value.valD, "Pzem Wh");
} else {
regEvent(NAN, "Pzem Wh");
SerialPrint("E", "Pzem", "Wh error");
SerialPrint("E", "Pzem", "Wh error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -126,14 +131,11 @@ class Pzem004wh : public IoTItem {
class Pzem004hz : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004hz(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
}
Pzem004hz(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -144,8 +146,11 @@ class Pzem004hz : public IoTItem {
regEvent(value.valD, "Pzem Hz");
} else {
regEvent(NAN, "Pzem Hz");
SerialPrint("E", "Pzem", "Hz error");
SerialPrint("E", "Pzem", "Hz error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -155,14 +160,11 @@ class Pzem004hz : public IoTItem {
class Pzem004pf : public IoTItem {
private:
String addr;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004pf(String parameters) : IoTItem(parameters) {
addr = jsonReadStr(parameters, "addr");
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
}
Pzem004pf(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
pzem = _pzem;
}
void doByInterval() {
@@ -173,8 +175,11 @@ class Pzem004pf : public IoTItem {
regEvent(value.valD, "Pzem Pf");
} else {
regEvent(NAN, "Pzem Pf");
SerialPrint("E", "Pzem", "Pf error");
SerialPrint("E", "Pzem", "Pf error", _id);
}
} else {
regEvent(NAN, "Pzem V");
SerialPrint("E", "Pzem", "V error", _id);
}
}
@@ -187,17 +192,17 @@ class Pzem004cmd : public IoTItem {
int changeaddr;
String setaddr;
int reset;
PZEMSensor* pzem;
PZEMSensor* pzem = nullptr;
public:
Pzem004cmd(String parameters) : IoTItem(parameters) {
Pzem004cmd(PZEMSensor* _pzem, String parameters) : IoTItem(parameters) {
jsonRead(parameters, F("addr"), addr);
jsonRead(parameters, F("changeaddr"), changeaddr);
jsonRead(parameters, F("setaddr"), setaddr);
jsonRead(parameters, F("reset"), reset);
if (myUART) {
pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
pzem = _pzem;
if (pzem && myUART) {
if (changeaddr == 1) {
if (pzem->setAddress(hexStringToUint8(setaddr))) {
SerialPrint("i", "Pzem", "address set: " + setaddr);
@@ -212,7 +217,7 @@ class Pzem004cmd : public IoTItem {
SerialPrint("i", "Pzem", "reset error");
}
}
}
} else SerialPrint("i", "Pzem", "Pzem command error");
}
void doByInterval() {
@@ -224,20 +229,37 @@ class Pzem004cmd : public IoTItem {
};
void* getAPI_Pzem004(String subtype, String param) {
PZEMSensor *pzem = nullptr;
if (myUART) {
if (subtype == F("Pzem004v") || subtype == F("Pzem004a") || subtype == F("Pzem004w")
|| subtype == F("Pzem004wh") || subtype == F("Pzem004hz") || subtype == F("Pzem004pf")
|| subtype == F("Pzem004cmd") ) {
String addr;
jsonRead(param, "addr", addr);
if (pzemSensorArray.find(addr) == pzemSensorArray.end()) {
// pzem = new PZEMSensor(myUART, hexStringToUint8(addr));
pzemSensorArray[addr] = new PZEMSensor(myUART, hexStringToUint8(addr));
} else {
pzemSensorArray[addr]->updateSerial(myUART);
}
pzem = pzemSensorArray[addr];
}
}
if (subtype == F("Pzem004v")) {
return new Pzem004v(param);
return new Pzem004v(pzem, param);
} else if (subtype == F("Pzem004a")) {
return new Pzem004a(param);
return new Pzem004a(pzem, param);
} else if (subtype == F("Pzem004w")) {
return new Pzem004w(param);
return new Pzem004w(pzem, param);
} else if (subtype == F("Pzem004wh")) {
return new Pzem004wh(param);
return new Pzem004wh(pzem, param);
} else if (subtype == F("Pzem004hz")) {
return new Pzem004hz(param);
return new Pzem004hz(pzem, param);
} else if (subtype == F("Pzem004pf")) {
return new Pzem004pf(param);
return new Pzem004pf(pzem, param);
} else if (subtype == F("Pzem004cmd")) {
return new Pzem004cmd(param);
return new Pzem004cmd(pzem, param);
} else {
return nullptr;
}

View File

@@ -128,6 +128,12 @@
"defActive": true,
"usedLibs": {
"esp32_4mb": [],
"esp8266_4mb": []
"esp8266_4mb": [],
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -78,6 +78,12 @@
],
"esp8285_1mb_ota": [
"rc-switch @ ^2.6.4"
],
"esp8266_2mb": [
"rc-switch @ ^2.6.4"
],
"esp8266_2mb_ota": [
"rc-switch @ ^2.6.4"
]
}
}

View File

@@ -62,6 +62,8 @@
"esp8266_1mb": ["https://github.com/tremaru/iarduino_RTC"],
"esp8266_1mb_ota": ["https://github.com/tremaru/iarduino_RTC"],
"esp8285_1mb": ["https://github.com/tremaru/iarduino_RTC"],
"esp8285_1mb_ota": ["https://github.com/tremaru/iarduino_RTC"]
"esp8285_1mb_ota": ["https://github.com/tremaru/iarduino_RTC"],
"esp8266_2mb": ["https://github.com/tremaru/iarduino_RTC"],
"esp8266_2mb_ota": ["https://github.com/tremaru/iarduino_RTC"]
}
}

View File

@@ -65,6 +65,12 @@
],
"esp8285_1mb_ota": [
"sparkfun/SparkFun SGP30 Arduino Library@^1.0.5"
],
"esp8266_2mb": [
"sparkfun/SparkFun SGP30 Arduino Library@^1.0.5"
],
"esp8266_2mb_ota": [
"sparkfun/SparkFun SGP30 Arduino Library@^1.0.5"
]
}
}

View File

@@ -66,6 +66,12 @@
],
"esp8285_1mb_ota": [
"robtillaart/SHT2x@^0.1.1"
],
"esp8266_2mb": [
"robtillaart/SHT2x@^0.1.1"
],
"esp8266_2mb_ota": [
"robtillaart/SHT2x@^0.1.1"
]
}
}

View File

@@ -66,6 +66,12 @@
],
"esp8285_1mb_ota": [
"WEMOS SHT3x@1.0.0"
],
"esp8266_2mb": [
"WEMOS SHT3x@1.0.0"
],
"esp8266_2mb_ota": [
"WEMOS SHT3x@1.0.0"
]
}
}

View File

@@ -42,6 +42,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -11,9 +11,13 @@
HardwareSerial* myUART = nullptr;
#endif
class UART : public IoTItem {
class IoTmUART : public IoTItem {
private:
int _eventFormat = 0; // 0 - нет приема, 1 - json IoTM, 2 - Nextion
char _inc;
String _inStr = ""; // буфер приема строк в режимах 0, 1, 2
uint8_t _headerBuf[260]; // буфер для приема пакета dwin
int _headerIndex = 0; // счетчик принятых байт пакета
#ifdef ESP8266
SoftwareSerial* _myUART = nullptr;
@@ -22,7 +26,7 @@ class UART : public IoTItem {
#endif
public:
UART(String parameters) : IoTItem(parameters) {
IoTmUART(String parameters) : IoTItem(parameters) {
int _tx, _rx, _speed, _line;
jsonRead(parameters, "tx", _tx);
jsonRead(parameters, "rx", _rx);
@@ -70,23 +74,61 @@ class UART : public IoTItem {
if (!_myUART) return;
if (_myUART->available()) {
static String inStr = "";
char inc;
inc = _myUART->read();
if (inc == 0xFF) {
inc = _myUART->read();
inc = _myUART->read();
inStr = "";
return;
}
if (_eventFormat == 3) { // третий режим, значит ожидаем бинарный пакет данных от dwin
_headerBuf[_headerIndex] = _myUART->read();
if (inc == '\r') return;
if (inc == '\n') {
analyzeString(inStr);
inStr = "";
} else inStr += inc;
// ищем валидный заголовок пакета dwin, проверяя каждый следующий байт
if (_headerIndex == 0 && _headerBuf[_headerIndex] != 0x5A ||
_headerIndex == 1 && _headerBuf[_headerIndex] != 0xA5 ||
_headerIndex == 2 && _headerBuf[_headerIndex] == 0 ||
_headerIndex == 3 && _headerBuf[_headerIndex] == 0x82 ) {
_headerIndex = 0;
return;
}
if (_headerIndex == _headerBuf[2] + 2) { // получили все данные из пакета
// Serial.print("ffffffff");
// for (int i=0; i<=_headerIndex; i++)
// Serial.printf("%#x ", _headerBuf[i]);
// Serial.println("!!!");
String valStr, id = "_";
if (_headerIndex == 8) { // предполагаем, что получили int16
valStr = (String)((_headerBuf[7] << 8) | _headerBuf[8]);
}
char buf[5];
hex2string(_headerBuf + 4, 2, buf);
id += (String)buf;
IoTItem* item = findIoTItemByPartOfName(id);
if (item) {
//Serial.printf("received data: %s for VP: %s for ID: %s\n", valStr, buf, item->getID());
generateOrder(item->getID(), valStr);
}
_headerIndex = 0;
return;
}
_headerIndex++;
} else {
_inc = _myUART->read();
if (_inc == 0xFF) {
_inc = _myUART->read();
_inc = _myUART->read();
_inStr = "";
return;
}
if (_inc == '\r') return;
if (_inc == '\n') {
analyzeString(_inStr);
_inStr = "";
} else _inStr += _inc;
}
}
}
@@ -128,51 +170,81 @@ class UART : public IoTItem {
break;
case 3: // формат событий для Dwin
//for (int i=0; i<2; i++) {
printStr = eventItem->getID();
indexOf_ = printStr.indexOf("_");
if (indexOf_ == -1 || !_myUART) return; // пропускаем событие, если нет используемого признака типа данных - _txt или _vol
uint8_t sizeOfVPPart = printStr.length() - indexOf_ - 1;
if (indexOf_ == -1 || !_myUART || sizeOfVPPart < 4 || indexOf_ == 0) return; // пропускаем событие, если нет признака _ или признак пустой
String VP = selectToMarkerLast(printStr, "_");
char typeOfVP = sizeOfVPPart == 5 ? printStr.charAt(indexOf_ + 5) : 0;
String VP = printStr.substring(indexOf_ + 1, indexOf_ + 5);
_myUART->write(0x5A);
_myUART->write(0xA5);
if (typeOfVP == 0) { // если не указан тип, то додумываем на основании типа данных источника
if (eventItem->value.isDecimal)
typeOfVP = 'i';
else
typeOfVP = 's';
}
if (eventItem->value.isDecimal) { // пока отправляем только целые числа
if (typeOfVP == 'i') {
_myUART->write(0x5A);
_myUART->write(0xA5);
_myUART->write(0x05); // размер данных отправляемых с учетом целых чисел int
_myUART->write(0x82); // требуем запись в память
uartPrintHex(VP); // отправляем адрес в памяти VP
if (!eventItem->value.isDecimal) {
eventItem->value.valD = atoi(eventItem->value.valS.c_str());
}
_myUART->write(highByte((int)eventItem->value.valD));
_myUART->write(lowByte((int)eventItem->value.valD));
}
if (typeOfVP == 's') {
if (eventItem->value.isDecimal) {
eventItem->value.valS = eventItem->getValue();
}
byte raw[2];
(int&)raw = eventItem->value.valD;
_myUART->write(raw[1]);
_myUART->write(raw[0]);
} else {
// подсчитываем количество символов отличающихся от ASCII, для понимания сколько символов состоит из дух байт
int u16counter = 0;
const char* valSptr = eventItem->value.valS.c_str();
//Serial.print("iiiii ");
for (int i=0; i < eventItem->value.valS.length(); i++) {
if (valSptr[i] > 200) u16counter++;
//Serial.printf("%d ", valSptr[i]);
}
//Serial.println();
_myUART->write(0x5A);
_myUART->write(0xA5);
_myUART->write((eventItem->value.valS.length() - u16counter) * 2 + 5); // подсчитываем и отправляем размер итоговой строки + служебные байты
_myUART->write(0x82); // требуем запись в память
uartPrintHex(VP); // отправляем адрес в памяти VP
Serial.println("ffffff " + VP);
//_myUART->write(0x53);
//_myUART->write(0x00);
uartPrintStrInUTF16(eventItem->value.valS.c_str(), eventItem->value.valS.length()); // отправляем строку для записи
_myUART->write(0xFF); // терминируем строку, чтоб экран очистил все остальное в элементе своем
_myUART->write(0xFF);
//uint8_t Data[8] = {0x00, 0x31, 0x00, 0x44, 0x04, 0x10, 0x00, 0x00};
//uartPrintArray(Data, 6);
//Serial.printf("fffffffff %#x %#x %#x %#x \n", Data[0], Data[1], Data[2], Data[3]);
}
//}
if (typeOfVP == 'f') {
_myUART->write(0x5A);
_myUART->write(0xA5);
_myUART->write(0x07); // размер данных отправляемых с учетом дробных чисел dword
_myUART->write(0x82); // требуем запись в память
uartPrintHex(VP); // отправляем адрес в памяти VP
byte hex[4] = {0};
if (!eventItem->value.isDecimal) {
eventItem->value.valD = atof(eventItem->value.valS.c_str());
}
byte* f_byte = reinterpret_cast<byte*>(&(eventItem->value.valD));
memcpy(hex, f_byte, 4);
_myUART->write(hex[3]);
_myUART->write(hex[2]);
_myUART->write(hex[1]);
_myUART->write(hex[0]);
}
break;
}
}
@@ -202,10 +274,6 @@ class UART : public IoTItem {
}
}
void uartPrintArray(uint8_t *_Data, uint8_t _Size) {
for (size_t i = 0; i < _Size; i++) _myUART->write(_Data[i]);
}
virtual void loop() {
uartHandle();
}
@@ -283,7 +351,7 @@ class UART : public IoTItem {
void* getAPI_UART(String subtype, String param) {
if (subtype == F("UART")) {
return new UART(param);
return new IoTmUART(param);
} else {
return nullptr;
}

View File

@@ -9,8 +9,8 @@
"descr": "",
"widget": "nil",
"id": "u",
"tx": 12,
"rx": 13,
"tx": 4,
"rx": 5,
"line": 2,
"speed": 9600,
"eventFormat": 0
@@ -66,10 +66,23 @@
"defActive": true,
"usedLibs": {
"esp32_4mb": [
"plerup/EspSoftwareSerial@^7.0.0"
"plerup/EspSoftwareSerial"
],
"esp8266_4mb": [
"plerup/EspSoftwareSerial@^7.0.0"
"plerup/EspSoftwareSerial"
],
"esp8266_1mb": [
"plerup/EspSoftwareSerial"
],
"esp8266_1mb_ota": [
"plerup/EspSoftwareSerial"
],
"esp8266_2mb": [
"plerup/EspSoftwareSerial"
],
"esp8266_2mb_ota": [
"plerup/EspSoftwareSerial"
]
}
}

View File

@@ -54,6 +54,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -68,8 +68,8 @@ class Loging : public IoTItem {
String logData;
jsonWriteInt(logData, "x", unixTime);
jsonWriteFloat(logData, "y1", value.toFloat());
jsonWriteInt(logData, "x", unixTime, false);
jsonWriteFloat(logData, "y1", value.toFloat(), false);
// прочитаем путь к файлу последнего сохранения
String filePath = readDataDB(id);
@@ -119,8 +119,8 @@ class Loging : public IoTItem {
}
regEvent(value, F("LogingEvent"));
String logData;
jsonWriteInt(logData, "x", unixTime);
jsonWriteFloat(logData, "y1", value.toFloat());
jsonWriteInt(logData, "x", unixTime, false);
jsonWriteFloat(logData, "y1", value.toFloat(), false);
// прочитаем путь к файлу последнего сохранения
String filePath = readDataDB(id);

View File

@@ -51,6 +51,12 @@
"defActive": true,
"usedLibs": {
"esp32_4mb": [],
"esp8266_4mb": []
"esp8266_4mb": [],
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -156,7 +156,7 @@ class LogingDaily : public IoTItem {
if (!firstTimeInit) {
if (prevDate != currentDate) {
changed = true;
SerialPrint("i", F("NTP"), "Change day event");
SerialPrint("i", F("NTP"), F("Change day event"));
#if defined(ESP8266)
FileFS.gc();
#endif
@@ -164,7 +164,7 @@ class LogingDaily : public IoTItem {
#endif
}
}
firstTimeInit = false;
if (isTimeSynch) firstTimeInit = false;
prevDate = currentDate;
return changed;
}

View File

@@ -44,6 +44,12 @@
"defActive": true,
"usedLibs": {
"esp32_4mb": [],
"esp8266_4mb": []
"esp8266_4mb": [],
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -74,6 +74,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -40,6 +40,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -100,6 +100,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -41,6 +41,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}

View File

@@ -48,6 +48,8 @@
"esp8266_1mb": [],
"esp8266_1mb_ota": [],
"esp8285_1mb": [],
"esp8285_1mb_ota": []
"esp8285_1mb_ota": [],
"esp8266_2mb": [],
"esp8266_2mb_ota": []
}
}