Переходим на единый базовый класс IoTItem для всех модулей

This commit is contained in:
2022-02-06 09:11:07 +03:00
parent 73bff64a54
commit 8b83e1649c
11 changed files with 50 additions and 50 deletions

View File

@@ -1,8 +1,8 @@
#pragma once #pragma once
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
extern std::vector<IoTSensor*> iotSensors; // вектор ссылок базового класса IoTSensor - список всех запущенных сенсоров extern std::vector<IoTItem*> IoTItems; // вектор ссылок базового класса IoTItem - список всех запущенных сенсоров
extern void configure(String path); extern void configure(String path);
extern IoTSensor* myIoTSensor; extern IoTItem* myIoTItem;

View File

@@ -2,10 +2,10 @@
#include <WString.h> #include <WString.h>
class IoTSensor { class IoTItem {
public: public:
IoTSensor(String parameters); IoTItem(String parameters);
~IoTSensor(); ~IoTItem();
void loop(); void loop();
virtual void doByInterval(); virtual void doByInterval();

View File

@@ -1,6 +1,6 @@
#include "ESPConfiguration.h" #include "ESPConfiguration.h"
std::vector<IoTSensor*> iotSensors; std::vector<IoTItem*> IoTItems;
void* getAPI(String subtype, String params); void* getAPI(String subtype, String params);
void configure(String path) { void configure(String path) {
@@ -17,9 +17,9 @@ void configure(String path) {
SerialPrint(F("E"), F("Config"), "json error " + subtype); SerialPrint(F("E"), F("Config"), "json error " + subtype);
continue; continue;
} else { } else {
myIoTSensor = (IoTSensor*)getAPI(subtype, jsonArrayElement); myIoTItem = (IoTItem*)getAPI(subtype, jsonArrayElement);
if (myIoTSensor) { if (myIoTItem) {
iotSensors.push_back(myIoTSensor); IoTItems.push_back(myIoTItem);
} }
} }
} }

View File

@@ -75,7 +75,7 @@ void loop() {
//обновление mqtt //обновление mqtt
mqttLoop(); mqttLoop();
for (unsigned int i = 0; i < iotSensors.size(); i++) { for (unsigned int i = 0; i < IoTItems.size(); i++) {
iotSensors[i]->loop(); IoTItems[i]->loop();
} }
} }

View File

@@ -1,10 +1,10 @@
#include "Utils/JsonUtils.h" #include "Utils/JsonUtils.h"
#include "Utils/SerialPrint.h" #include "Utils/SerialPrint.h"
#include "Classes/ScenarioClass3.h" #include "Classes/ScenarioClass3.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include "WsServer.h" #include "WsServer.h"
IoTSensor::IoTSensor(String parameters) { IoTItem::IoTItem(String parameters) {
jsonRead(parameters, "int", _interval); jsonRead(parameters, "int", _interval);
_interval = _interval * 1000; _interval = _interval * 1000;
jsonRead(parameters, "subtype", _subtype); jsonRead(parameters, "subtype", _subtype);
@@ -22,17 +22,17 @@ IoTSensor::IoTSensor(String parameters) {
_map4 = selectFromMarkerToMarker(map, ",", 3).toInt(); _map4 = selectFromMarkerToMarker(map, ",", 3).toInt();
} }
} }
IoTSensor::~IoTSensor() {} IoTItem::~IoTItem() {}
String IoTSensor::getSubtype() { String IoTItem::getSubtype() {
return _subtype; return _subtype;
} }
String IoTSensor::getID() { String IoTItem::getID() {
return _id; return _id;
}; };
void IoTSensor::loop() { void IoTItem::loop() {
currentMillis = millis(); currentMillis = millis();
difference = currentMillis - prevMillis; difference = currentMillis - prevMillis;
if (difference >= _interval) { if (difference >= _interval) {
@@ -41,7 +41,7 @@ void IoTSensor::loop() {
} }
} }
void IoTSensor::regEvent(String value, String consoleInfo = "") { void IoTItem::regEvent(String value, String consoleInfo = "") {
eventGen2(_id, value); eventGen2(_id, value);
jsonWriteStr(paramsFlashJson, _id, value); jsonWriteStr(paramsFlashJson, _id, value);
publishStatusMqtt(_id, value); publishStatusMqtt(_id, value);
@@ -49,7 +49,7 @@ void IoTSensor::regEvent(String value, String consoleInfo = "") {
SerialPrint("I", "Sensor " + consoleInfo, "'" + _id + "' data: " + value + "'"); SerialPrint("I", "Sensor " + consoleInfo, "'" + _id + "' data: " + value + "'");
} }
void IoTSensor::regEvent(float value, String consoleInfo = "") { void IoTItem::regEvent(float value, String consoleInfo = "") {
if (_multiply) value = value * _multiply; if (_multiply) value = value * _multiply;
if (_plus) value = value + _multiply; if (_plus) value = value + _multiply;
if (_round != 0) { if (_round != 0) {
@@ -70,6 +70,6 @@ void IoTSensor::regEvent(float value, String consoleInfo = "") {
regEvent((String)buf, consoleInfo); regEvent((String)buf, consoleInfo);
} }
void IoTSensor::doByInterval() {} void IoTItem::doByInterval() {}
IoTSensor* myIoTSensor; IoTItem* myIoTItem;

View File

@@ -1,11 +1,11 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
//Это файл сенсора, в нем осуществляется чтение сенсора. //Это файл сенсора, в нем осуществляется чтение сенсора.
//для добавления сенсора вам нужно скопировать этот файл и заменить в нем текст AnalogAdc на название вашего сенсора //для добавления сенсора вам нужно скопировать этот файл и заменить в нем текст AnalogAdc на название вашего сенсора
//Название должно быть уникальным, коротким и отражать суть сенсора. //Название должно быть уникальным, коротким и отражать суть сенсора.
class AnalogAdc : public IoTSensor { class AnalogAdc : public IoTItem {
private: private:
//======================================================================================================= //=======================================================================================================
// Секция переменных. // Секция переменных.
@@ -20,7 +20,7 @@ class AnalogAdc : public IoTSensor {
//Такие как ...begin и подставлять в них параметры полученные из web интерфейса. //Такие как ...begin и подставлять в них параметры полученные из web интерфейса.
//Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции: //Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции:
// jsonReadStr, jsonReadBool, jsonReadInt // jsonReadStr, jsonReadBool, jsonReadInt
AnalogAdc(String parameters): IoTSensor(parameters) { AnalogAdc(String parameters): IoTItem(parameters) {
_pin = jsonReadInt(parameters, "pin"); _pin = jsonReadInt(parameters, "pin");
} }
//======================================================================================================= //=======================================================================================================

View File

@@ -6,7 +6,7 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include <Adafruit_BME280.h> #include <Adafruit_BME280.h>
#include <map> #include <map>
@@ -14,12 +14,12 @@
std::map<String, Adafruit_BME280*> bmes; std::map<String, Adafruit_BME280*> bmes;
class Bme280t : public IoTSensor { class Bme280t : public IoTItem {
private: private:
Adafruit_BME280* _bme; Adafruit_BME280* _bme;
public: public:
Bme280t(Adafruit_BME280* bme, String parameters): IoTSensor(parameters) { Bme280t(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
_bme = bme; _bme = bme;
} }
@@ -33,12 +33,12 @@ class Bme280t : public IoTSensor {
}; };
class Bme280h : public IoTSensor { class Bme280h : public IoTItem {
private: private:
Adafruit_BME280* _bme; Adafruit_BME280* _bme;
public: public:
Bme280h(Adafruit_BME280* bme, String parameters): IoTSensor(parameters) { Bme280h(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
_bme = bme; _bme = bme;
} }
@@ -52,12 +52,12 @@ class Bme280h : public IoTSensor {
}; };
class Bme280p : public IoTSensor { class Bme280p : public IoTItem {
private: private:
Adafruit_BME280* _bme; Adafruit_BME280* _bme;
public: public:
Bme280p(Adafruit_BME280* bme, String parameters): IoTSensor(parameters) { Bme280p(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
_bme = bme; _bme = bme;
} }

View File

@@ -6,7 +6,7 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include <Adafruit_BMP280.h> #include <Adafruit_BMP280.h>
#include <map> #include <map>
@@ -14,12 +14,12 @@
std::map<String, Adafruit_BMP280*> bmps; std::map<String, Adafruit_BMP280*> bmps;
class Bmp280t : public IoTSensor { class Bmp280t : public IoTItem {
private: private:
Adafruit_BMP280* _bmp; Adafruit_BMP280* _bmp;
public: public:
Bmp280t(Adafruit_BMP280* bmp, String parameters): IoTSensor(parameters) { Bmp280t(Adafruit_BMP280* bmp, String parameters): IoTItem(parameters) {
_bmp = bmp; _bmp = bmp;
} }
@@ -33,12 +33,12 @@ class Bmp280t : public IoTSensor {
}; };
class Bmp280p : public IoTSensor { class Bmp280p : public IoTItem {
private: private:
Adafruit_BMP280* _bmp; Adafruit_BMP280* _bmp;
public: public:
Bmp280p(Adafruit_BMP280* bmp, String parameters): IoTSensor(parameters) { Bmp280p(Adafruit_BMP280* bmp, String parameters): IoTItem(parameters) {
_bmp = bmp; _bmp = bmp;
} }

View File

@@ -6,7 +6,7 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include "DHTesp.h" #include "DHTesp.h"
#include <map> #include <map>
@@ -14,12 +14,12 @@
std::map<int, DHTesp*> dhts; std::map<int, DHTesp*> dhts;
class Dht1122t : public IoTSensor { class Dht1122t : public IoTItem {
private: private:
DHTesp* _dht; DHTesp* _dht;
public: public:
Dht1122t(DHTesp* dht, String parameters): IoTSensor(parameters) { Dht1122t(DHTesp* dht, String parameters): IoTItem(parameters) {
_dht = dht; _dht = dht;
} }
@@ -33,12 +33,12 @@ class Dht1122t : public IoTSensor {
}; };
class Dht1122h : public IoTSensor { class Dht1122h : public IoTItem {
private: private:
DHTesp* _dht; DHTesp* _dht;
public: public:
Dht1122h(DHTesp* dht, String parameters): IoTSensor(parameters) { Dht1122h(DHTesp* dht, String parameters): IoTItem(parameters) {
_dht = dht; _dht = dht;
} }

View File

@@ -1,5 +1,5 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include "Wire.h" #include "Wire.h"
#include "SHT2x.h" #include "SHT2x.h"
@@ -7,9 +7,9 @@
SHT2x* sht = nullptr; SHT2x* sht = nullptr;
class Sht20t : public IoTSensor { class Sht20t : public IoTItem {
public: public:
Sht20t(String parameters): IoTSensor(parameters) { } Sht20t(String parameters): IoTItem(parameters) { }
void doByInterval() { void doByInterval() {
sht->read(); sht->read();
@@ -21,9 +21,9 @@ class Sht20t : public IoTSensor {
~Sht20t(); ~Sht20t();
}; };
class Sht20h : public IoTSensor { class Sht20h : public IoTItem {
public: public:
Sht20h(String parameters): IoTSensor(parameters) { } Sht20h(String parameters): IoTItem(parameters) { }
void doByInterval() { void doByInterval() {
sht->read(); sht->read();

View File

@@ -1,5 +1,5 @@
#include "Global.h" #include "Global.h"
#include "Classes/IoTSensor.h" #include "Classes/IoTItem.h"
#include "DallasTemperature.h" #include "DallasTemperature.h"
#include <OneWire.h> #include <OneWire.h>
@@ -9,7 +9,7 @@
std::map<int, OneWire*> oneWireTemperatureArray; std::map<int, OneWire*> oneWireTemperatureArray;
std::map<int, DallasTemperature*> sensorsTemperatureArray; std::map<int, DallasTemperature*> sensorsTemperatureArray;
class Ds18b20 : public IoTSensor { class Ds18b20 : public IoTItem {
private: private:
//для работы библиотеки с несколькими линиями необходимо обеспечить каждый экземпляр класса ссылками на объекты настроенные на эти линии //для работы библиотеки с несколькими линиями необходимо обеспечить каждый экземпляр класса ссылками на объекты настроенные на эти линии
OneWire* oneWire; OneWire* oneWire;
@@ -27,7 +27,7 @@ class Ds18b20 : public IoTSensor {
//Такие как ...begin и подставлять в них параметры полученные из web интерфейса. //Такие как ...begin и подставлять в них параметры полученные из web интерфейса.
//Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции: //Все параметры хранятся в перемененной parameters, вы можете прочитать любой параметр используя jsonRead функции:
// jsonReadStr, jsonReadBool, jsonReadInt // jsonReadStr, jsonReadBool, jsonReadInt
Ds18b20(String parameters): IoTSensor(parameters) { Ds18b20(String parameters): IoTItem(parameters) {
jsonRead(parameters, "pin", _pin); jsonRead(parameters, "pin", _pin);
jsonRead(parameters, "index", _index); jsonRead(parameters, "index", _index);
jsonRead(parameters, "addr", _addr); jsonRead(parameters, "addr", _addr);