Добавляем в модуль далласа поддержку нескольких линий одновременно

This commit is contained in:
2021-12-24 20:03:38 +03:00
parent 5fecb51d69
commit bebea0732a

View File

@@ -7,16 +7,21 @@
#include "DallasTemperature.h" #include "DallasTemperature.h"
#include <OneWire.h> #include <OneWire.h>
#include <map>
extern std::vector<IoTModule*> iotModules; //v3dev: вектор ссылок базового класса IoTModule - интерфейсы для общения со всеми поддерживаемыми системой модулями extern std::vector<IoTModule*> iotModules; //v3dev: вектор ссылок базового класса IoTModule - интерфейсы для общения со всеми поддерживаемыми системой модулями
#define IOTDALLASTEMPKEY "dallas-temp" #define IOTDALLASTEMPKEY "dallas-temp"
//глобальные списки необходимы для хранения объектов об активных линиях 1-wire используемых разными датчиками из модуля. Ключ - номер пина
std::map<int, OneWire*> oneWireTemperatureArray;
std::map<int, DallasTemperature*> sensorsTemperatureArray;
class IoTSensorDallas: public IoTSensor { class IoTSensorDallas: public IoTSensor {
private: private:
//описание переменных экземпляра датчика - аналог глобальных переменных из Arduino //описание переменных экземпляра датчика - аналог глобальных переменных из Arduino
//для работы библиотеки с несколькими линиями необходимо обеспечить каждый экземпляр класса ссылками на объекты настроенные на эти линии
OneWire* oneWire; OneWire* oneWire;
DallasTemperature sensors; DallasTemperature* sensors;
//описание параметров передаваемых из настроек датчика из веба //описание параметров передаваемых из настроек датчика из веба
String _addr; String _addr;
@@ -31,31 +36,41 @@ class IoTSensorDallas: public IoTSensor {
_index = jsonReadInt(parameters, "index"); _index = jsonReadInt(parameters, "index");
_addr = jsonReadStr(parameters, "addr"); _addr = jsonReadStr(parameters, "addr");
oneWire = new OneWire((uint8_t)_pin); //учитываем, что библиотека может работать с несколькими линиями на разных пинах, поэтому инициируем библиотеку, если линия ранее не использовалась
sensors.setOneWire(oneWire); if (oneWireTemperatureArray.find(_pin) == oneWireTemperatureArray.end()) {
sensors.begin(); oneWire = new OneWire((uint8_t)_pin);
sensors.setResolution(12); sensors = new DallasTemperature();
sensors->setOneWire(oneWire);
sensors->begin();
sensors->setResolution(12);
oneWireTemperatureArray[_pin] = oneWire;
sensorsTemperatureArray[_pin] = sensors;
} else {
oneWire = oneWireTemperatureArray[_pin];
sensors = sensorsTemperatureArray[_pin];
}
} }
~IoTSensorDallas() {} ~IoTSensorDallas() {}
//аналог loop() из Arduino но квотируемый по времени параметром interval //аналог loop() из Arduino но квотируемый по времени параметром interval
void doByInterval() { void doByInterval() {
SerialPrint("I", "Sensor", "Вызывается doByInterval"); //запускаем опрос измерений у всех датчиков на линии
sensors->requestTemperatures();
sensors.requestTemperatures();
//Определяем адрес. Если парамтер addr не установлен, то узнаем адрес по индексу
DeviceAddress deviceAddress; DeviceAddress deviceAddress;
if (_addr == "") { if (_addr == "") {
sensors.getAddress(deviceAddress, _index); sensors->getAddress(deviceAddress, _index);
} else { } else {
string2hex(_addr.c_str(), deviceAddress); string2hex(_addr.c_str(), deviceAddress);
} }
//получаем температуру по адресу
float value = sensors.getTempC(deviceAddress); float value = sensors->getTempC(deviceAddress);
char addrStr[20] = ""; char addrStr[20] = "";
hex2string(deviceAddress, 8, addrStr); hex2string(deviceAddress, 8, addrStr);
regEvent((String)value, "addr: " + String(addrStr)); //обязательный вызов для отправки результата работы regEvent((String)value, "addr: " + String(addrStr)); //обязательный вызов для отправки результата работы
} }