D
/*
* MySBootloader 1.3.0 16 MHz
*
* 9-13 NRF24 (standard mysensors)
* 1 PIR
* 2 temperatura (DS18B20)
*/
#define MY_DEBUG
#define MY_DEBUG_DETAIL
#define MY_NODE_ID 3
#define CHILD_ID_PIR 1
#define CHILD_ID_TEMP 2
#define pirPin 8
#define TempPin 2
#include <MyRF24_P0_GW2.h>
#include <MySensors.h>
#include <MyCircularBuffer.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#define wdt_check_min 10;
#define wdt_check_max 150;
#include <MyWDT.h>
OneWire oneWire(TempPin);
DallasTemperature sensors(&oneWire);
DeviceAddress ds18Addr;
MyMessage msgPIR(CHILD_ID_PIR, V_TRIPPED);
MyMessage msgTEMP(CHILD_ID_TEMP, V_TEMP);
int nNoUpdatesPIR = 0, nNoUpdatesTEMP = 0;
unsigned const int FORCE_UPDATE_N_READS = 300;
unsigned int calibrationTime = 10;
unsigned int p;
unsigned int p_tot;
float temp, last_temp = 0, tempTot = 0;
unsigned int msg;
unsigned int last_msg = 9; //per forzare primo invio
unsigned const int loop_cycles = 60;
unsigned const int loop_wait = 1; //secondi tra ogni rilevazione del PIR
/*
unsigned int wdt_failures = 0;
unsigned int wdt_check_interval = 30;
unsigned int wdt_loops = 0;
unsigned int wdt_uplink = 0;
*/
MyCircularBuffer<byte,loop_cycles> pirBuffer;
MyCircularBuffer<float,10> TempBuffer;
//CircularBuffer<byte,3> wdtBuffer;
void setup() {
wdt_disable();
pinMode(pirPin, INPUT);
digitalWrite(pirPin, LOW);
//Fase di calibrazione
Serial.print("Calibrating sensor ");
for(int i = 0; i < calibrationTime; i++){
Serial.print(".");
p = digitalRead(pirPin);
pirBuffer.push(p);
delay(1000);
}
Serial.println(" done");
Serial.println("SENSOR ACTIVE");
delay(50);
sensors.begin();
if (!sensors.getAddress(ds18Addr, 0))
Serial.println("Unable to find address for Device 0");
sensors.setResolution(ds18Addr, 11);
wdt_enable(WDTO_4S);
}
void presentation()
{
// Send the sketch version information to the gateway and Controller
sendSketchInfo("P0 - PIR Studio", "1.1");
present(CHILD_ID_PIR, S_MOTION, "P0 PIR Studio");
present(CHILD_ID_TEMP, S_TEMP, "P0 Temperatura Studio");
}
void loop() {
p = digitalRead(pirPin);
pirBuffer.push(p);
p_tot = 0;
for(int i=0; i<pirBuffer.size(); i++){
p_tot += pirBuffer[i];
}
if(p_tot > loop_cycles/4){
msg = 1;
}
else {
msg = 0;
}
if (msg != last_msg || nNoUpdatesPIR == FORCE_UPDATE_N_READS) {
last_msg = msg;
nNoUpdatesPIR = 0;
send(msgPIR.set(msg), true);
#ifdef MY_DEBUG
Serial.print("P: ");
Serial.println(msg);
#endif
} else {
nNoUpdatesPIR++;
}
//check external temp
sensors.requestTemperatures();
wait(1000);
//temp = sensors.getTempCByIndex(0);
temp = sensors.getTempC(ds18Addr);
if(temp != DEVICE_DISCONNECTED_C)
TempBuffer.push(temp);
tempTot = 0;
for(int i=0; i<TempBuffer.size(); i++){
tempTot += TempBuffer[i];
}
tempTot = tempTot / TempBuffer.size();
if (abs(tempTot - last_temp) > 0.1 || nNoUpdatesTEMP == FORCE_UPDATE_N_READS) {
last_temp = tempTot;
nNoUpdatesTEMP = 0;
send(msgTEMP.set(tempTot,1), true);
#ifdef MY_DEBUG
Serial.print("T avg: ");
Serial.println(tempTot);
#endif
} else {
nNoUpdatesTEMP++;
}
#ifdef MY_DEBUG_DETAIL
Serial.print("T: ");
Serial.print(temp);
Serial.print(" - P:");
Serial.println(p);
#endif
wait(loop_wait * 1000);
//wdt uplink check
wdt_check();
}
