Merge pull request #130 from biveraxe/ver4dev

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

data_svelte/items.json

@@ -102,10 +102,46 @@
         "type": "Reading",
         "subtype": "Bmp280p",
         "id": "Press3",
-        "widget": "anydataPress",
+        "widget": "anydataMm",
         "page": "Сенсоры",
         "descr": "Давление",
         "int": 15,
         "addr": "0x76"
+    },
+    {
+        "name": "9. Cенсор температуры Bme280",
+        "num": 9,
+        "type": "Reading",
+        "subtype": "Bme280t",
+        "id": "tmp3",
+        "widget": "anydataTmp",
+        "page": "Сенсоры",
+        "descr": "Температура",
+        "int": 15,
+        "addr": "0x76"
+    },
+    {
+        "name": "10. Cенсор давления Bme280",
+        "num": 10,
+        "type": "Reading",
+        "subtype": "Bme280p",
+        "id": "Press3",
+        "widget": "anydataMm",
+        "page": "Сенсоры",
+        "descr": "Давление",
+        "int": 15,
+        "addr": "0x76"
+    },
+    {
+        "name": "11. Cенсор влажности Bme280",
+        "num": 11,
+        "type": "Reading",
+        "subtype": "Bme280h",
+        "id": "Hum3",
+        "widget": "anydataHum",
+        "page": "Сенсоры",
+        "descr": "Влажность",
+        "int": 15,
+        "addr": "0x76"
     }
 ]

include/ESPConfiguration.h

@@ -1,8 +1,8 @@
 #pragma once
 #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 IoTSensor* myIoTSensor;
+extern IoTItem* myIoTItem;

include/classes/IoTItem.h

@@ -2,13 +2,15 @@
 
 #include <WString.h>
 
-class IoTSensor {
+class IoTItem {
    public:
-    IoTSensor(String parameters);
-    ~IoTSensor();
+    IoTItem(String parameters);
+    ~IoTItem();
 
     void loop();
     virtual void doByInterval();
+    virtual void execute(String command, String param);
+
     void regEvent(String value, String consoleInfo);
     void regEvent(float value, String consoleInfo);
 

platformio.ini

@@ -31,6 +31,7 @@ lib_deps =
 	robtillaart/SHT2x@^0.1.1
 	beegee-tokyo/DHT sensor library for ESPx
 	adafruit/Adafruit BMP280 Library
+	adafruit/Adafruit BME280 Library
 monitor_filters = esp8266_exception_decoder
 upload_speed = 921600
 monitor_speed = 115200
@@ -47,6 +48,7 @@ lib_deps =
 	robtillaart/SHT2x@^0.1.1
 	beegee-tokyo/DHT sensor library for ESPx
 	adafruit/Adafruit BMP280 Library
+	adafruit/Adafruit BME280 Library
 monitor_filters = esp32_exception_decoder
 upload_speed = 921600
 monitor_speed = 115200

src/ESPConfiguration.cpp

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

src/Main.cpp

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

src/classes/IoTItem.cpp

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

src/modules/API.cpp

@@ -7,6 +7,7 @@ void* getAPI_Ds18b20(String subtype, String params);
 void* getAPI_Sht20(String subtype, String params);
 void* getAPI_Dht1122(String subtype, String params);
 void* getAPI_Bmp280(String subtype, String params);
+void* getAPI_Bme280(String subtype, String params);
 //============================================================================================
 
 void* getAPI(String subtype, String params) {
@@ -18,6 +19,7 @@ void* getAPI(String subtype, String params) {
     if ((tmpAPI = getAPI_Sht20(subtype, params)) != nullptr) return tmpAPI;
     if ((tmpAPI = getAPI_Dht1122(subtype, params)) != nullptr) return tmpAPI;
     if ((tmpAPI = getAPI_Bmp280(subtype, params)) != nullptr) return tmpAPI;
+    if ((tmpAPI = getAPI_Bme280(subtype, params)) != nullptr) return tmpAPI;
     //================================================================================================================
 
     return nullptr;

src/modules/AnalogAdc.cpp

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

src/modules/Bme280.cpp

@@ -0,0 +1,94 @@
+/******************************************************************
+  Used Adafruit BME280 Driver (Barometric Pressure Sensor)
+  Support for BME280
+  https://github.com/adafruit/Adafruit_BME280_Library
+ ******************************************************************/
+
+
+#include "Global.h"
+#include "Classes/IoTItem.h"
+
+#include <Adafruit_BME280.h>
+#include <map>
+
+
+std::map<String, Adafruit_BME280*> bmes;
+
+class Bme280t : public IoTItem {
+   private:
+    Adafruit_BME280* _bme; 
+   
+   public:
+    Bme280t(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
+        _bme = bme;
+    }
+    
+    void doByInterval() {
+        float value = _bme->readTemperature();
+        if (value < 145) regEvent(value, "Bme280t");
+            else SerialPrint("E", "Sensor Bme280t", "Error");  
+    }
+
+    ~Bme280t();
+};
+
+  
+class Bme280h : public IoTItem {
+   private:
+    Adafruit_BME280* _bme; 
+
+   public:
+    Bme280h(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
+        _bme = bme;
+    }
+    
+    void doByInterval() {
+        float value = _bme->readHumidity();
+        if (value < 100) regEvent(value, "Bme280h");
+            else SerialPrint("E", "Sensor Bme280h", "Error");  
+    }
+
+    ~Bme280h();
+};
+
+
+class Bme280p : public IoTItem {
+   private:
+    Adafruit_BME280* _bme; 
+
+   public:
+    Bme280p(Adafruit_BME280* bme, String parameters): IoTItem(parameters) {
+        _bme = bme;
+    }
+    
+    void doByInterval() {
+        float value = _bme->readPressure();
+        if (value > 0) {
+            value = value / 1.333224 / 100;
+            regEvent(value, "Bme280p");
+        } else SerialPrint("E", "Sensor Bme280p", "Error");  
+    }
+
+    ~Bme280p();
+};
+
+
+void* getAPI_Bme280(String subtype, String param) {    
+    String addr;
+    jsonRead(param, "addr", addr);
+
+    if (bmes.find(addr) == bmes.end()) {
+        bmes[addr] = new Adafruit_BME280();
+        bmes[addr]->begin(hexStringToUint8(addr));
+    }
+
+    if (subtype == F("Bme280t")) {
+        return new Bme280t(bmes[addr], param);
+    } else if (subtype == F("Bme280h")) {
+        return new Bme280h(bmes[addr], param);
+    } else if (subtype == F("Bme280p")) {
+        return new Bme280p(bmes[addr], param);
+    } else {
+        return nullptr;
+    }
+}

src/modules/Bmp280.cpp

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

src/modules/Dht1122.cpp

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

src/modules/Sht20.cpp

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

src/modules/ds18b20.cpp

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