TemperatureService.cpp

#include "TemperatureService.h"
                                                                                
//const char *    TemperatureService::ADDRESS_OUT            = "28afa4459207029e";
//const char *    TemperatureService::ADDRESS_IN             = "282c4445920e0245";

const char *    TemperatureService::ADDRESS_OUT            = "28afa4459207029e"; // Output air t sernsor
const char *    TemperatureService::ADDRESS_BOARD          = "2838c145920c024a"; // on board t sensor
const char *    TemperatureService::ADDRESS_IN             = "282522459205027d"; // Input air t sensor


TemperatureService* TemperatureService::instance = NULL;

TemperatureService::TemperatureService()
{
    instance = this;
}

void TemperatureService::init(int _pin)
{
    pin     = _pin;
    oneWire = new OneWire(pin);
    DS18B20 = new DallasTemperature(oneWire);

    DS18B20->begin();

    // Loop through each device, save its address
    Serial.print("DS18B20 device count: ");
    Serial.println(DS18B20->getDeviceCount());
    for (int i = 0; i < DS18B20->getDeviceCount(); i++) {
        // save device address
        DS18B20->getAddress(addresses[i], i);
        Serial.println(String("device: ") + getAddressToString(addresses[i]));
    }

    this->DS18B20->setWaitForConversion(true);  // Wait for measurement
    this->DS18B20->requestTemperatures();       // Initiate the temperature measurement
    this->ready = true;
}


float TemperatureService::getTemperature(int deviceIndex)
{
    if(deviceIndex >= this->DS18B20->getDeviceCount() || deviceIndex < 0)
    {
        return 0.0;
    }

    //return this->temperatures[deviceIndex];
    return this->queues[deviceIndex].average();
}


float TemperatureService::getTemperatureByAddress(const char * sensorAddress)
{
    int index = this->getDeviceIndex(sensorAddress);
    return this->getTemperature(index);
}

int TemperatureService::getDeviceIndex(const char * sensorAddress)
{
    for(int i = 0; i < DS18B20->getDeviceCount(); i++){
        if (strcmp(getAddressToString(addresses[i]).c_str(), sensorAddress) == 0){
            return i;
        }
    }
    return -1;
}

void TemperatureService::loop()
{
    long now = millis();


    if ( now - lastUpdateTime > interval ) { // Take a measurement at a fixed time (tempMeasInterval = 1000ms, 1s)

        for (int i = 0; i < DS18B20->getDeviceCount(); i++) {
            float temp = this->DS18B20->getTempC( addresses[i] );           // Measuring temperature in Celsius
            this->temperatures[i] = round(temp * 10) / 10;                  // save the measured value to the array

            this->queues[i].add(temp);                                      // Add to queue

            Serial.print(String() +  i + ") " + getAddressToString(addresses[i]) + " = " + this->temperatures[i] + " ºC \t");
        }
        Serial.println(String(" dev count: ") + DS18B20->getDeviceCount()) ;


        // request next measurement
        this->DS18B20->setWaitForConversion(false); //No waiting for measurement
        this->DS18B20->requestTemperatures();       //Initiate the temperature measurement
        
        lastUpdateTime  = millis();                 //Remember the last time measurement
    }
}