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

удаление часов реального времени

Browse Source
This commit is contained in:
Dmitry Borisenko
2022-08-12 22:13:50 +02:00
parent ca95a4528d
commit d22580aac9
17 changed files with 278 additions and 387 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
include/classes/IoTItem.h
View File

@@ -41,7 +41,8 @@ class IoTItem {
bool needSave = false; bool needSave = false;
bool enableDoByInt = true; bool enableDoByInt = true;
virtual IoTGpio* getGpioDriver(); virtual bool isGpioDriver();
virtual iarduino_RTC_BASE* getRtcDriver(); virtual iarduino_RTC_BASE* getRtcDriver();
virtual void setValue(IoTValue Value); virtual void setValue(IoTValue Value);
virtual void setValue(String valStr); virtual void setValue(String valStr);

22
include/classes/IoTRTC.h
View File

@@ -1,22 +0,0 @@
#pragma once
#include <Arduino.h>
#include <iarduino_RTC.h>
class iarduino_RTC_NTP: public iarduino_RTC_BASE {
public:
iarduino_RTC_NTP();
~iarduino_RTC_NTP();
void begin(void);
uint8_t funcReadTimeIndex(uint8_t i);
void funcWriteTimeIndex(uint8_t i, uint8_t j);
uint8_t funcConvertNumToCode (uint8_t i) {return ((i/10) << 4) + (i%10);}
};
class IoTRTC : public iarduino_RTC {
public:
IoTRTC(uint8_t i, uint8_t j=SS, uint8_t k=SCK, uint8_t n=MOSI) : iarduino_RTC(i, j, k, n) {
if (i == 0) objClass = new iarduino_RTC_NTP();
};
~IoTRTC();
};

20
src/ESPConfiguration.cpp
View File

@@ -1,9 +1,7 @@
#include "ESPConfiguration.h" #include "ESPConfiguration.h"
#include "classes/IoTGpio.h" #include "classes/IoTGpio.h"
#include "classes/IoTRTC.h"
extern IoTGpio IoTgpio; extern IoTGpio IoTgpio;
extern IoTRTC *watch;
std::list<IoTItem*> IoTItems; std::list<IoTItem*> IoTItems;
void* getAPI(String subtype, String params); void* getAPI(String subtype, String params);
@@ -25,23 +23,11 @@ void configure(String path) {
SerialPrint(F("E"), F("Config"), "json error " + subtype); SerialPrint(F("E"), F("Config"), "json error " + subtype);
continue; continue;
} else { } else {
//(IoTItem*) - getAPI вернула ссылку, что бы ее привести к классу IoTItem используем
myIoTItem = (IoTItem*)getAPI(subtype, jsonArrayElement); myIoTItem = (IoTItem*)getAPI(subtype, jsonArrayElement);
if (myIoTItem) { if (myIoTItem) {
// пробуем спросить драйвер GPIO // пробуем спросить драйвер GPIO
IoTGpio* gpiotmp = myIoTItem->getGpioDriver(); if (myIoTItem->isGpioDriver()) IoTgpio.regDriver((IoTGpio*)myIoTItem);
if (gpiotmp) IoTgpio.regDriver(gpiotmp);
// пробуем спросить драйвер RTC
iarduino_RTC_BASE* rtctmp = myIoTItem->getRtcDriver();
if (rtctmp) {
Serial.println("Start delete watch objClass");
delete watch->objClass;
watch->objClass = rtctmp;
int valPeriod_save = watch->valPeriod;
watch->valPeriod = 0;
watch->gettime();
watch->valPeriod = valPeriod_save;
}
IoTItems.push_back(myIoTItem); IoTItems.push_back(myIoTItem);
} }
@@ -54,7 +40,7 @@ void configure(String path) {
void clearConfigure() { void clearConfigure() {
Serial.printf("Start clearing config\n"); Serial.printf("Start clearing config\n");
for (std::list<IoTItem*>::iterator it=IoTItems.begin(); it != IoTItems.end(); ++it) { for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
Serial.printf("Start delete iotitem %s \n", (*it)->getID().c_str()); Serial.printf("Start delete iotitem %s \n", (*it)->getID().c_str());
if (*it) delete *it; if (*it) delete *it;
} }

37
src/Main.cpp
View File

@@ -1,12 +1,8 @@
#include "Main.h" #include "Main.h"
#include "classes/IoTRTC.h"
#include <time.h> #include <time.h>
IoTScenario iotScen; // объект управления сценарием IoTScenario iotScen; // объект управления сценарием
IoTRTC *watch; // объект хранения времени, при старте часы 00:00
time_t iotTimeNow;
String volStrForSave = ""; String volStrForSave = "";
unsigned long currentMillis; unsigned long currentMillis;
unsigned long prevMillis; unsigned long prevMillis;
@@ -32,29 +28,6 @@ void setup() {
//подключаемся к роутеру //подключаемся к роутеру
routerConnect(); routerConnect();
// настраиваем получение времени из сети Интернет
String ntpServer = jsonReadStr(settingsFlashJson, F("ntp"));
int timezone = jsonReadInt(settingsFlashJson, F("timezone"));
configTime(3600*timezone, 0, ntpServer.c_str(), "ru.pool.ntp.org", "pool.ntp.org");
Serial.println("Start syncing NTP time");
time(&iotTimeNow);
// int i = 0;
// while (isNetworkActive() && iotTimeNow < 1510592825 && i < 200)
// {
// time(&iotTimeNow);
// delay(300);
// Serial.print(".");
// i++;
// }
// Serial.println();
// настраиваем локальный RTC
watch = new IoTRTC(0); // создаем объект главного хранилища времени, но с заглушкой (0) для получения системного времени
watch->period(60); // время в минутах для синхронизации с часами реального времени или системным
watch->begin();
//Serial.print(F("Time from Local: "));
//Serial.println(watch->gettime("d-m-Y, H:i:s, M"));
//инициализация асинхронного веб сервера и веб сокетов //инициализация асинхронного веб сервера и веб сокетов
#ifdef ASYNC_WEB_SERVER #ifdef ASYNC_WEB_SERVER
asyncWebServerInit(); asyncWebServerInit();
@@ -89,7 +62,7 @@ void setup() {
//загрузка сценария //загрузка сценария
iotScen.loadScenario("/scenario.txt"); iotScen.loadScenario("/scenario.txt");
// создаем событие завершения конфигурирования для возможности выполнения блока кода при загрузке // создаем событие завершения конфигурирования для возможности выполнения блока кода при загрузке
IoTItems.push_back((IoTItem*)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}")); IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}"));
generateEvent("onStart", ""); generateEvent("onStart", "");
// test // test
@@ -123,7 +96,6 @@ void loop() {
// delay(1); // delay(1);
// } // }
//обновление задач таскера //обновление задач таскера
ts.update(); ts.update();
@@ -146,7 +118,7 @@ void loop() {
mqttLoop(); mqttLoop();
// передаем управление каждому элементу конфигурации для выполнения своих функций // передаем управление каждому элементу конфигурации для выполнения своих функций
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) { for (std::list<IoTItem *>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
(*it)->loop(); (*it)->loop();
if ((*it)->iAmDead) { if ((*it)->iAmDead) {
delete *it; delete *it;
@@ -164,7 +136,7 @@ void loop() {
if (currentMillis - prevMillis >= 1000) { if (currentMillis - prevMillis >= 1000) {
prevMillis = millis(); prevMillis = millis();
volStrForSave = ""; volStrForSave = "";
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) { for (std::list<IoTItem *>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it) {
if ((*it)->needSave) { if ((*it)->needSave) {
(*it)->needSave = false; (*it)->needSave = false;
volStrForSave = volStrForSave + (*it)->getID() + "=" + (*it)->getValue() + ";"; volStrForSave = volStrForSave + (*it)->getID() + "=" + (*it)->getValue() + ";";
@@ -176,7 +148,4 @@ void loop() {
Serial.println(volStrForSave.c_str()); Serial.println(volStrForSave.c_str());
} }
} }
} }

4
src/classes/IoTItem.cpp
View File

@@ -128,8 +128,8 @@ void IoTItem::setInterval(unsigned long interval) {
_interval = interval; _interval = interval;
} }
IoTGpio* IoTItem::getGpioDriver() { bool IoTItem::isGpioDriver() {
return nullptr; return false;
} }
iarduino_RTC_BASE* IoTItem::getRtcDriver() { iarduino_RTC_BASE* IoTItem::getRtcDriver() {

46
src/classes/IoTRTC.cpp
View File

@@ -1,46 +0,0 @@
#include "classes/IoTRTC.h"
IoTRTC::~IoTRTC() {
}
iarduino_RTC_NTP::iarduino_RTC_NTP() {
}
void iarduino_RTC_NTP::begin(void) {
}
uint8_t iarduino_RTC_NTP::funcReadTimeIndex(uint8_t i) {
static tm localTimeVar;
if (i == 0) {
Serial.println(F("Read time from system."));
time_t timeNowVar;
time(&timeNowVar);
localTimeVar = *localtime(&timeNowVar);
}
switch (i)
{
case 0: return funcConvertNumToCode(localTimeVar.tm_sec);
case 1: return funcConvertNumToCode(localTimeVar.tm_min);
case 2: return funcConvertNumToCode(localTimeVar.tm_hour);
case 3: return funcConvertNumToCode(localTimeVar.tm_mday);
case 4: return funcConvertNumToCode(localTimeVar.tm_mon+1);
case 5: return funcConvertNumToCode(localTimeVar.tm_year-100);
case 6: return funcConvertNumToCode(localTimeVar.tm_wday);
}
return 0;
}
void iarduino_RTC_NTP::funcWriteTimeIndex(uint8_t i, uint8_t j) {
}
iarduino_RTC_NTP::~iarduino_RTC_NTP() {
}

54
src/modules/API.cpp
View File

@@ -18,7 +18,6 @@ void* getAPI_Sht30(String subtype, String params);
void* getAPI_Sonar(String subtype, String params); void* getAPI_Sonar(String subtype, String params);
void* getAPI_ButtonIn(String subtype, String params); void* getAPI_ButtonIn(String subtype, String params);
void* getAPI_ButtonOut(String subtype, String params); void* getAPI_ButtonOut(String subtype, String params);
void* getAPI_IarduinoRTC(String subtype, String params);
void* getAPI_IoTServo(String subtype, String params); void* getAPI_IoTServo(String subtype, String params);
void* getAPI_Mcp23017(String subtype, String params); void* getAPI_Mcp23017(String subtype, String params);
void* getAPI_Mp3(String subtype, String params); void* getAPI_Mp3(String subtype, String params);
@@ -27,31 +26,30 @@ void* getAPI_SysExt(String subtype, String params);
void* getAPI_Lcd2004(String subtype, String params); void* getAPI_Lcd2004(String subtype, String params);
void* getAPI(String subtype, String params) { void* getAPI(String subtype, String params) {
void* tmpAPI; void* tmpAPI;
if ((tmpAPI = getAPI_Timer(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Timer(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Variable(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Variable(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_VButton(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_VButton(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Aht20(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Aht20(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_AnalogAdc(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_AnalogAdc(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Bme280(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Bme280(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Bmp280(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Bmp280(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Dht1122(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Dht1122(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Ds18b20(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Ds18b20(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_GY21(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_GY21(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Hdc1080(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Hdc1080(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Max6675(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Max6675(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_RCswitch(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_RCswitch(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Sht20(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Sht20(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Sht30(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Sht30(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Sonar(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Sonar(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_ButtonIn(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_ButtonIn(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_ButtonOut(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_ButtonOut(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_IarduinoRTC(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_IoTServo(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_IoTServo(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Mcp23017(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Mcp23017(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Mp3(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Mp3(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Pwm8266(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Pwm8266(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_SysExt(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_SysExt(subtype, params)) != nullptr) return tmpAPI; if ((tmpAPI = getAPI_Lcd2004(subtype, params)) != nullptr) return tmpAPI;
if ((tmpAPI = getAPI_Lcd2004(subtype, params)) != nullptr) return tmpAPI; return nullptr;
return nullptr;
} }

112
src/modules/exec/IarduinoRTC/IarduinoRTC.cpp
View File

@@ -1,112 +0,0 @@
#include "Global.h"
#include "classes/IoTItem.h"
#include "classes/IoTRTC.h"
#include <iarduino_RTC.h>
#include "iarduino_RTC_DS1302.h" // Подключаем файл iarduino_RTC_DS1302.h
#include "iarduino_RTC_DS1307.h" // Подключаем файл iarduino_RTC_DS1307.h
#include "iarduino_RTC_DS3231.h" // Подключаем файл iarduino_RTC_DS3231.h
#include "iarduino_RTC_RX8025.h"
extern IoTRTC *watch;
class IarduinoRTC : public IoTItem {
private:
int _chipNum, _rst, _clk, _dat, _ticker;
String _defFormat;
iarduino_RTC_BASE *RTCDriver;
public:
IarduinoRTC(String parameters): IoTItem(parameters) {
jsonRead(parameters, "chipNum", _chipNum);
jsonRead(parameters, "rst", _rst);
jsonRead(parameters, "clk", _clk);
jsonRead(parameters, "dat", _dat);
jsonRead(parameters, "defFormat", _defFormat);
jsonRead(parameters, "ticker", _ticker);
switch (_chipNum) {
case 0:
RTCDriver = new iarduino_RTC_NTP();
break;
case 1:
RTCDriver = new iarduino_RTC_DS1302(_rst, _clk, _dat);
break;
case 2:
RTCDriver = new iarduino_RTC_DS1307();
break;
case 3:
RTCDriver = new iarduino_RTC_DS3231();
break;
case 4:
RTCDriver = new iarduino_RTC_RX8025();
break;
}
if (RTCDriver) RTCDriver->begin();
}
void doByInterval() {
value.isDecimal = false;
value.valS = watch->gettime(_defFormat.c_str());
if (_ticker) regEvent(value.valS, "time ticker");
}
IoTValue execute(String command, std::vector<IoTValue> &param) {
IoTValue tmpValue;
if (command == "getTime") {
if (param.size()) {
tmpValue.isDecimal = false;
tmpValue.valS = watch->gettime(param[0].valS.c_str());
return tmpValue;
}
} else if (command == "saveSysTime") {
tm localTimeVar;
time_t timeNowVar;
time(&timeNowVar);
localTimeVar = *localtime(&timeNowVar);
watch->settime(localTimeVar.tm_sec, localTimeVar.tm_min, localTimeVar.tm_hour, localTimeVar.tm_mday, localTimeVar.tm_mon+1, localTimeVar.tm_year-100, localTimeVar.tm_wday);
} else if (command == "setTime") {
if (param.size()) {
watch->settime(param[0].valD, param[1].valD, param[2].valD, param[3].valD, param[4].valD, param[5].valD, param[6].valD);
}
} else if (command == "setUnixTime") {
if (param.size()) {
watch->settimeUnix(param[0].valD);
}
} else if (command == "getHours") {
tmpValue.valD = watch->Hours; // Часы 0-23
return tmpValue;
} else if (command == "getMinutes") {
tmpValue.valD = watch->minutes; // Минуты 0-59
return tmpValue;
} else if (command == "getSeconds") {
tmpValue.valD = watch->seconds; // Секунды 0-59
return tmpValue;
} else if (command == "getMonth") {
tmpValue.valD = watch->month; // Месяц 1-12
return tmpValue;
} else if (command == "getDay") {
tmpValue.valD = watch->day; // День месяца 1-31
return tmpValue;
}
return {};
}
iarduino_RTC_BASE* getRtcDriver() {
return RTCDriver;
}
~IarduinoRTC() {};
};
void* getAPI_IarduinoRTC(String subtype, String param) {
if (subtype == F("IarduinoRTC")) {
return new IarduinoRTC(param);
} else {
return nullptr;
}
}

47
src/modules/exec/IarduinoRTC/modinfo.json
View File

@@ -1,47 +0,0 @@
{
"menuSection": "Исполнительные устройства",
"configItem": [{
"name": "Поддержка DS1302(1), DS1307(2), DS3231(3), RX8025(4)",
"type": "Reading",
"subtype": "IarduinoRTC",
"id": "RTC",
"widget": "",
"page": "",
"descr": "",
"int": "1",
"chipNum": 1,
"rst": 16,
"clk": 5,
"dat": 4,
"defFormat": "d-m-Y",
"ticker": 0
}],
"about": {
"authorName": "Ilya Belyakov",
"authorContact": "https://t.me/Biveraxe",
"authorGit": "https://github.com/biveraxe",
"specialThanks": "Sergey @Serghei63",
"moduleName": "IarduinoRTC",
"moduleVersion": "1.0",
"moduleDesc": "Позволяет использовать часы реального времени в виде внешнего физического модуля или виртуального с синхронизацией через сеть Интернет.",
"propInfo": {
"int": "Период времени в секундах между опросами времени с RTC",
"chipNum": "Выбор источника: 0 - время с Интернет, 1 - модуль DS1302, 2 - модуль DS1307, 3 - модуль DS3231, 4 - модуль RX38025",
"rst": "Номер пина для подключения вашего модуля часов. (не всегда используется).",
"clk": "Номер пина для SDL вашего модуля часов",
"dat": "Номер пина для SDA вашего модуля часов",
"defFormat": "Вывод информации в формате defFormat",
"ticker": "Генерировать(1) или нет(0) события при каждом тике модуля = int. Позволяет не применять модуль таймера, если нужно просто тактировать работу."
}
},
"defActive": true,
"devices": {
"esp32_4mb": [],
"esp8266_4mb": []
}
}

17
src/modules/exec/Mcp23017/Mcp23017.cpp
View File

@@ -3,25 +3,21 @@
#include "classes/IoTGpio.h" #include "classes/IoTGpio.h"
#include <Adafruit_MCP23X17.h> #include <Adafruit_MCP23X17.h>
class Mcp23017 : public IoTItem, IoTGpio { class Mcp23017 : public IoTItem, IoTGpio {
private: private:
public: public:
Adafruit_MCP23X17 mcp; Adafruit_MCP23X17 mcp;
Mcp23017(String parameters, int index): IoTItem(parameters), IoTGpio(index) { Mcp23017(String parameters, int index) : IoTItem(parameters), IoTGpio(index) {
} }
void doByInterval() { void doByInterval() {
// regEvent(value.valD, "Mcp23017");
//regEvent(value.valD, "Mcp23017");
} }
IoTGpio* getGpioDriver() { //возвращает ссылку на экземпляр класса Mcp23017
return this; bool isGpioDriver() {
return true;
} }
void pinMode(uint8_t pin, uint8_t mode) { void pinMode(uint8_t pin, uint8_t mode) {
@@ -40,10 +36,9 @@ class Mcp23017 : public IoTItem, IoTGpio {
mcp.digitalWrite(pin, 1 - mcp.digitalRead(pin)); mcp.digitalWrite(pin, 1 - mcp.digitalRead(pin));
} }
~Mcp23017() {}; ~Mcp23017(){};
}; };
void* getAPI_Mcp23017(String subtype, String param) { void* getAPI_Mcp23017(String subtype, String param) {
if (subtype == F("Mcp23017")) { if (subtype == F("Mcp23017")) {
String addr; String addr;

86
src/modules/exec/SysExt/SysExt.cpp
View File

@@ -1,7 +1,5 @@
#include "Global.h" #include "Global.h"
#include "classes/IoTItem.h" #include "classes/IoTItem.h"
#include "classes/IoTRTC.h"
extern IoTRTC *watch;
// Пример модуля расширения возможностей системы на примере добавления новых команд в сценарии // Пример модуля расширения возможностей системы на примере добавления новых команд в сценарии
// При комбинации использования doByInterval() и execute() можно обеспечить интеграцию с внешними сервисами, такими как Telegram, например. // При комбинации использования doByInterval() и execute() можно обеспечить интеграцию с внешними сервисами, такими как Telegram, например.
@@ -9,24 +7,24 @@ extern IoTRTC *watch;
class SysExt : public IoTItem { class SysExt : public IoTItem {
public: public:
SysExt(String parameters): IoTItem(parameters) { SysExt(String parameters) : IoTItem(parameters) {
// инициализация внутренних переменных и объектов для взаимодействия с внешними системами // инициализация внутренних переменных и объектов для взаимодействия с внешними системами
//jsonRead(parameters, "addr", addr); // получаем параметры из настроек модуля. Наименования могут быть любыми. // jsonRead(parameters, "addr", addr); // получаем параметры из настроек модуля. Наименования могут быть любыми.
} }
void doByInterval() { void doByInterval() {
// выполнение периодических проверок каждые Int секунд из настроек модуля // выполнение периодических проверок каждые Int секунд из настроек модуля
//regEvent(Значение, Описание); // регистрация найденного события после проверок для запуска сценариев и других реакций в системе // regEvent(Значение, Описание); // регистрация найденного события после проверок для запуска сценариев и других реакций в системе
} }
//void loop() { // void loop() {
// выполнение необходимых проверок в теле основного цикла программы. // выполнение необходимых проверок в теле основного цикла программы.
// ВАЖНО: 1. при использовании loop() отключается doByInterval() // ВАЖНО: 1. при использовании loop() отключается doByInterval()
// 2. любые заминки в данном цикле повлияют на общую работу системы // 2. любые заминки в данном цикле повлияют на общую работу системы
//} //}
IoTValue execute(String command, std::vector<IoTValue> &param) { IoTValue execute(String command, std::vector<IoTValue>& param) {
// реакция на вызов команды модуля из сценария // реакция на вызов команды модуля из сценария
// String command - имя команды после ID. (ID.Команда()) // String command - имя команды после ID. (ID.Команда())
// param - вектор ("массив") значений параметров переданных вместе с командой: ID.Команда("пар1", 22, 33) -> param[0].ValS = "пар1", param[1].ValD = 22 // param - вектор ("массив") значений параметров переданных вместе с командой: ID.Команда("пар1", 22, 33) -> param[0].ValS = "пар1", param[1].ValD = 22
@@ -57,42 +55,42 @@ class SysExt : public IoTItem {
IoTgpio.digitalInvert(param[0].valD); IoTgpio.digitalInvert(param[0].valD);
return {}; return {};
} }
} else if (command == "getTime") { //} else if (command == "getTime") {
if (param.size()) { // if (param.size()) {
value.isDecimal = false; // value.isDecimal = false;
value.valS = watch->gettime(param[0].valS.c_str()); // value.valS = watch->gettime(param[0].valS.c_str());
return value; // return value;
} // }
} else if (command == "getHours") { //} else if (command == "getHours") {
value.valD = watch->Hours; // Часы 0-23 // value.valD = watch->Hours; // Часы 0-23
value.isDecimal = true; // value.isDecimal = true;
return value; // return value;
} else if (command == "getMinutes") { //} else if (command == "getMinutes") {
value.valD = watch->minutes; // Минуты 0-59 // value.valD = watch->minutes; // Минуты 0-59
value.isDecimal = true; // value.isDecimal = true;
return value; // return value;
} else if (command == "getSeconds") { //} else if (command == "getSeconds") {
value.valD = watch->seconds; // Секунды 0-59 // value.valD = watch->seconds; // Секунды 0-59
value.isDecimal = true; // value.isDecimal = true;
return value; // return value;
} else if (command == "getMonth") { //} else if (command == "getMonth") {
value.valD = watch->month; // Месяц 1-12 // value.valD = watch->month; // Месяц 1-12
value.isDecimal = true; // value.isDecimal = true;
return value; // return value;
} else if (command == "getDay") { //} else if (command == "getDay") {
value.valD = watch->day; // День месяца 1-31 // value.valD = watch->day; // День месяца 1-31
value.isDecimal = true; // value.isDecimal = true;
return value; // return value;
} else if (command == "deepSleep") { } else if (command == "deepSleep") {
if (param.size()) { if (param.size()) {
Serial.printf("Ушел спать на %d сек...", (int)param[0].valD); Serial.printf("Ушел спать на %d сек...", (int)param[0].valD);
#ifdef ESP32 #ifdef ESP32
esp_sleep_enable_timer_wakeup(param[0].valD * 1000000); esp_sleep_enable_timer_wakeup(param[0].valD * 1000000);
delay(1000); delay(1000);
esp_deep_sleep_start(); esp_deep_sleep_start();
#else #else
ESP.deepSleep(param[0].valD * 1000000); ESP.deepSleep(param[0].valD * 1000000);
#endif #endif
} }
return {}; return {};
} }
@@ -126,7 +124,7 @@ class SysExt : public IoTItem {
return {}; // команда поддерживает возвращаемое значения. Т.е. по итогу выполнения команды или общения с внешней системой, можно вернуть значение в сценарий для дальнейшей обработки return {}; // команда поддерживает возвращаемое значения. Т.е. по итогу выполнения команды или общения с внешней системой, можно вернуть значение в сценарий для дальнейшей обработки
} }
~SysExt() {}; ~SysExt(){};
}; };
void* getAPI_SysExt(String subtype, String param) { void* getAPI_SysExt(String subtype, String param) {

5
src/modules/sensors/AnalogAdc/AnalogAdc.cpp
View File

@@ -7,6 +7,7 @@ extern IoTGpio IoTgpio;
// для добавления сенсора вам нужно скопировать этот файл и заменить в нем текст AnalogAdc на название вашего сенсора // для добавления сенсора вам нужно скопировать этот файл и заменить в нем текст AnalogAdc на название вашего сенсора
// Название должно быть уникальным, коротким и отражать суть сенсора. // Название должно быть уникальным, коротким и отражать суть сенсора.
//ребенок - родитель
class AnalogAdc : public IoTItem { class AnalogAdc : public IoTItem {
private: private:
//======================================================================================================= //=======================================================================================================
@@ -24,7 +25,7 @@ class AnalogAdc : public IoTItem {
// Такие как ...begin и подставлять в них параметры полученные из web интерфейса. // Такие как ...begin и подставлять в них параметры полученные из web интерфейса.
// Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции: // Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции:
// jsonReadStr, jsonReadBool, jsonReadInt // jsonReadStr, jsonReadBool, jsonReadInt
AnalogAdc(String parameters): IoTItem(parameters) { AnalogAdc(String parameters) : IoTItem(parameters) {
_pin = jsonReadInt(parameters, "pin"); _pin = jsonReadInt(parameters, "pin");
_avgSteps = jsonReadInt(parameters, "avgSteps"); _avgSteps = jsonReadInt(parameters, "avgSteps");
_avgSumm = 0; _avgSumm = 0;
@@ -69,7 +70,7 @@ class AnalogAdc : public IoTItem {
} }
} }
~AnalogAdc() {}; ~AnalogAdc(){};
}; };
// после замены названия сенсора, на функцию можно не обращать внимания // после замены названия сенсора, на функцию можно не обращать внимания

0
src/modules/virtual/Logging/Logging.cpp Normal file
View File

7
src/utils/SerialPrint.cpp
View File

@@ -1,13 +1,10 @@
#include "utils/SerialPrint.h" #include "utils/SerialPrint.h"
#include "classes/IoTRTC.h"
extern IoTRTC *watch;
void SerialPrint(String errorLevel, String module, String msg) { void SerialPrint(String errorLevel, String module, String msg) {
String tosend; String tosend;
if (watch) tosend = watch->gettime("d.m.y H:i:s");
else tosend = prettyMillis(millis()); tosend = prettyMillis(millis());
tosend = tosend + " [" + errorLevel + "] [" + module + "] " + msg; tosend = tosend + " [" + errorLevel + "] [" + module + "] " + msg;
Serial.println(tosend); Serial.println(tosend);

106
training/IarduinoRTC.cpp Normal file
View File

@@ -0,0 +1,106 @@
//#include "Global.h"
//#include "classes/IoTItem.h"
//
//#include <iarduino_RTC.h>
//#include "iarduino_RTC_DS1302.h" // Подключаем файл iarduino_RTC_DS1302.h
//#include "iarduino_RTC_DS1307.h" // Подключаем файл iarduino_RTC_DS1307.h
//#include "iarduino_RTC_DS3231.h" // Подключаем файл iarduino_RTC_DS3231.h
//#include "iarduino_RTC_RX8025.h"
//
// class IarduinoRTC : public IoTItem {
// private:
// int _chipNum, _rst, _clk, _dat, _ticker;
// String _defFormat;
// iarduino_RTC_BASE* RTCDriver;
//
// public:
// IarduinoRTC(String parameters) : IoTItem(parameters) {
// jsonRead(parameters, "chipNum", _chipNum);
// jsonRead(parameters, "rst", _rst);
// jsonRead(parameters, "clk", _clk);
// jsonRead(parameters, "dat", _dat);
// jsonRead(parameters, "defFormat", _defFormat);
// jsonRead(parameters, "ticker", _ticker);
//
// switch (_chipNum) {
// case 0:
// RTCDriver = new iarduino_RTC_NTP();
// break;
// case 1:
// RTCDriver = new iarduino_RTC_DS1302(_rst, _clk, _dat);
// break;
// case 2:
// RTCDriver = new iarduino_RTC_DS1307();
// break;
// case 3:
// RTCDriver = new iarduino_RTC_DS3231();
// break;
// case 4:
// RTCDriver = new iarduino_RTC_RX8025();
// break;
// }
// if (RTCDriver) RTCDriver->begin();
// }
//
// void doByInterval() {
// value.isDecimal = false;
// value.valS = watch->gettime(_defFormat.c_str());
// if (_ticker) regEvent(value.valS, "time ticker");
// }
//
// IoTValue execute(String command, std::vector<IoTValue>& param) {
// IoTValue tmpValue;
// if (command == "getTime") {
// if (param.size()) {
// tmpValue.isDecimal = false;
// tmpValue.valS = watch->gettime(param[0].valS.c_str());
// return tmpValue;
// }
// } else if (command == "saveSysTime") {
// tm localTimeVar;
// time_t timeNowVar;
// time(&timeNowVar);
// localTimeVar = *localtime(&timeNowVar);
// watch->settime(localTimeVar.tm_sec, localTimeVar.tm_min, localTimeVar.tm_hour, localTimeVar.tm_mday, localTimeVar.tm_mon + 1, localTimeVar.tm_year - 100, localTimeVar.tm_wday);
// } else if (command == "setTime") {
// if (param.size()) {
// watch->settime(param[0].valD, param[1].valD, param[2].valD, param[3].valD, param[4].valD, param[5].valD, param[6].valD);
// }
// } else if (command == "setUnixTime") {
// if (param.size()) {
// watch->settimeUnix(param[0].valD);
// }
// } else if (command == "getHours") {
// tmpValue.valD = watch->Hours; // Часы 0-23
// return tmpValue;
// } else if (command == "getMinutes") {
// tmpValue.valD = watch->minutes; // Минуты 0-59
// return tmpValue;
// } else if (command == "getSeconds") {
// tmpValue.valD = watch->seconds; // Секунды 0-59
// return tmpValue;
// } else if (command == "getMonth") {
// tmpValue.valD = watch->month; // Месяц 1-12
// return tmpValue;
// } else if (command == "getDay") {
// tmpValue.valD = watch->day; // День месяца 1-31
// return tmpValue;
// }
//
// return {};
// }
//
// iarduino_RTC_BASE* getRtcDriver() {
// return RTCDriver;
// }
//
// ~IarduinoRTC(){};
//};
//
// void* getAPI_IarduinoRTC(String subtype, String param) {
// if (subtype == F("IarduinoRTC")) {
// return new IarduinoRTC(param);
// } else {
// return nullptr;
// }
//}

45
training/IoTRTC.cpp Normal file
View File

@@ -0,0 +1,45 @@
//#include "classes/IoTRTC.h"
//
// IoTRTC::~IoTRTC() {
//
//}
//
//
// iarduino_RTC_NTP::iarduino_RTC_NTP() {
//
//}
//
// void iarduino_RTC_NTP::begin(void) {
//
//}
//
// uint8_t iarduino_RTC_NTP::funcReadTimeIndex(uint8_t i) {
// static tm localTimeVar;
// if (i == 0) {
// Serial.println(F("Read time from system."));
// time_t timeNowVar;
// time(&timeNowVar);
// localTimeVar = *localtime(&timeNowVar);
// }
//
// switch (i)
// {
// case 0: return funcConvertNumToCode(localTimeVar.tm_sec);
// case 1: return funcConvertNumToCode(localTimeVar.tm_min);
// case 2: return funcConvertNumToCode(localTimeVar.tm_hour);
// case 3: return funcConvertNumToCode(localTimeVar.tm_mday);
// case 4: return funcConvertNumToCode(localTimeVar.tm_mon+1);
// case 5: return funcConvertNumToCode(localTimeVar.tm_year-100);
// case 6: return funcConvertNumToCode(localTimeVar.tm_wday);
// }
//
// return 0;
//}
//
// void iarduino_RTC_NTP::funcWriteTimeIndex(uint8_t i, uint8_t j) {
//
//}
//
// iarduino_RTC_NTP::~iarduino_RTC_NTP() {
//
//}

22
training/IoTRTC.h Normal file
View File

@@ -0,0 +1,22 @@
//#pragma once
//#include <Arduino.h>
//#include <iarduino_RTC.h>
//
// class iarduino_RTC_NTP: public iarduino_RTC_BASE {
// public:
// iarduino_RTC_NTP();
// ~iarduino_RTC_NTP();
// void begin(void);
// uint8_t funcReadTimeIndex(uint8_t i);
// void funcWriteTimeIndex(uint8_t i, uint8_t j);
// uint8_t funcConvertNumToCode (uint8_t i) {return ((i/10) << 4) + (i%10);}
//};
//
// class IoTRTC : public iarduino_RTC {
// public:
// IoTRTC(uint8_t i, uint8_t j=SS, uint8_t k=SCK, uint8_t n=MOSI) : iarduino_RTC(i, j, k, n) {
// if (i == 0) objClass = new iarduino_RTC_NTP();
// };
//
// ~IoTRTC();
//};