MysKitch.ino

// Room sensor module
/* Sensors: 
 - 4 relays ; command light, radio, webcam, electrical device
 - IR receiver; use a RC IR to command lights
 - water leak
 - Motion (PIR)
 - Gas (MQ-2)
 - Temperature (DS18B20)
 - Buzzer for Alarm
*/

//#define MY_DEBUG 
#define MY_RADIO_NRF24
#define MY_NODE_ID 14
#define MY_PARENT_NODE_ID 0
//#define MY_REPEATER_FEATURE
#include <SPI.h>
#include <MySensor.h>
#include <IRremote.h>
#include <DallasTemperature.h>
#include <OneWire.h>

#define CHILD_ID_REL1 1 // Relay1 - Light
#define CHILD_ID_REL2 2 // Relay2 - Radio
#define CHILD_ID_REL3 3 // Relay3 - WebCam
#define CHILD_ID_REL4 4 // Relay4
#define CHILD_ID_AlmWarn 6 // alarm warning
#define CHILD_ID_AlmSnd 7 // alarm sound
#define CHILD_ID_AlmActivate 8 // alarm ON/OFF
#define CHILD_ID_WATER_LEAK 11  // Water Leak sensor
#define CHILD_ID_PIR 12 // Motion Sensor PIR
#define CHILD_ID_GAS 13 // Gas Sensor MQ-2
#define CHILD_ID_T1 21  // Temperature DS18B20 sensor

/*
PINs for the node built with Arduino NANO:
D0  - Free; Rx; may be used if do not use Serial
D1  - Free; Tx; may be used if do not use Serial
D2  - Free; INT: available
D3  - Free; INT, PWM; if not used for inclusion mode
D4  - Free; if not used for ERR LED
D5  - Free; PWM; if not used for Tx LED
D6  - Free; PWM; if not used for Rx LED
D7  - Free; if not used for signing
D8  - Free; 
D9  - Not free; PWM - NRF24 CE
D10 - Not free; PWM - NRF24 CS
D11 - Not free; PWM - NRF24 MOSI
D12 - Not free; NRF24 MISO
D13 - Not free; internal LED - NRF24 SCK
A0  - Free; 
A1  - Free; 
A2  - Free; 
A3  - Free; if not used for ATSHA204
A4  - Free; 
A5  - Free; 
A6  - Free; only analog: available
A7  - Free; only analog: available
*/

#define REL1_PIN 8  // Relay1 - Light
#define REL2_PIN 7  // Relay2 - Radio
#define REL3_PIN 6  // Relay3 - WebCam
#define REL4_PIN 4  // Relay4
#define AlmWarn_PIN 5 //PWM
#define IR_PIN 2  // IR receive PIN for remote control lights
#define WATER_LEAK_PIN A0 // Water Leak sensor
#define ONE_WIRE_BUS A1 // for DS18B20
#define PIR_PIN A2  // Motion Sensor PIR
#define MQ_PIN A7 // Gas sensor MQ-2

#define TEMPERATURE_PRECISION 12
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);

MyMessage msgREL1(CHILD_ID_REL1, V_LIGHT);  // 2
MyMessage msgREL2(CHILD_ID_REL2, V_LIGHT);
MyMessage msgREL3(CHILD_ID_REL3, V_LIGHT);
MyMessage msgREL4(CHILD_ID_REL4, V_LIGHT);
MyMessage msgAlmWarn(CHILD_ID_AlmWarn, V_LIGHT);
MyMessage msgAlmSnd(CHILD_ID_AlmSnd, V_LIGHT);
MyMessage msgAlmActivate(CHILD_ID_AlmActivate, V_LIGHT);
MyMessage msgT1(CHILD_ID_T1, V_TEMP); // 0
MyMessage msgWater(CHILD_ID_WATER_LEAK, V_TRIPPED);  // 16
MyMessage msgPir(CHILD_ID_PIR, V_TRIPPED);
MyMessage msgGas(CHILD_ID_GAS, V_VAR1);  // 24 .. 28

DeviceAddress addrTemp1 = { 0x28, 0xFF, 0x7E, 0x2C, 0xB1, 0x15, 0x04, 0x80 };

bool StateREL=0, StateREL1=0, StateREL2=0, StateREL3=0, StateREL4=0;
bool StateAlmWarn=0, StateAlmSnd=0, StateAlmActivate=0;
const unsigned long tUpdate=60000; // update interval
unsigned long t0;
byte IrAct;
IRrecv irrecv(IR_PIN);
decode_results results;
float Temp1;
byte StateWATER=0;
byte oldStateWATER=0;
byte StatePIR=0;
byte oldStatePIR=0;
int InAnalog1;
int valMQ=0;
int refMQ=1023; // refference value will be the lowest value read from the sensor

void presentation()  {
  sendSketchInfo("Multi", "1.0");
  present(CHILD_ID_REL1, S_LIGHT);
  present(CHILD_ID_REL2, S_LIGHT);
  present(CHILD_ID_REL3, S_LIGHT);
  present(CHILD_ID_REL4, S_LIGHT);
  present(CHILD_ID_AlmWarn, S_LIGHT);
  present(CHILD_ID_AlmSnd, S_LIGHT);
  present(CHILD_ID_AlmActivate, S_LIGHT);  
  present(CHILD_ID_T1, S_TEMP);
  present(CHILD_ID_PIR, S_MOTION);
  present(CHILD_ID_GAS, S_CUSTOM);
  present(CHILD_ID_WATER_LEAK, S_MOTION);
}

void setup() {
  sensors.begin();
  sensors.setResolution(addrTemp1, TEMPERATURE_PRECISION);
  
  pinMode(REL1_PIN, OUTPUT);
  digitalWrite(REL1_PIN, StateREL1);
  pinMode(REL2_PIN, OUTPUT);
  digitalWrite(REL2_PIN, StateREL2);
  pinMode(REL3_PIN, OUTPUT);
  digitalWrite(REL3_PIN, StateREL3);
  pinMode(REL4_PIN, OUTPUT);
  digitalWrite(REL4_PIN, StateREL4);
  analogWrite(AlmWarn_PIN, 0);
  
  pinMode(IR_PIN, INPUT);
  irrecv.enableIRIn();
  
  pinMode(WATER_LEAK_PIN, INPUT);
  pinMode(PIR_PIN, INPUT_PULLUP);

  t0=millis();
}

void loop() {
  IRr();

  StatePIR=digitalRead(PIR_PIN);
  if (StatePIR != oldStatePIR) {
    oldStatePIR=StatePIR;
    send(msgPir.set(StatePIR ? "ON" : "OFF"));
  }

  StateWATER=digitalRead(WATER_LEAK_PIN);
  if (StateWATER != oldStateWATER) {
    oldStateWATER=StateWATER;
  }
    
  if ((millis()-t0) > tUpdate) ServerUpdate();
}

void ServerUpdate() {
  // Update the controller with the actual values
  send(msgWater.set(StateWATER ? "OFF" : "ON"));
  send(msgPir.set(StatePIR ? "ON" : "OFF"));
  
  sensors.requestTemperatures();
  Temp1 = sensors.getTempC(addrTemp1);
  if (Temp1 != -127.00 && Temp1 != 85.00) send(msgT1.set(Temp1,1));
  
  InAnalog1=analogRead(MQ_PIN);
  if (InAnalog1<refMQ) refMQ=InAnalog1; // if read value is lower that actual, change the 0 refference with the actual one
  valMQ=InAnalog1-refMQ;  // send to the gateway the reading value weighted with the refference
  send(msgGas.set(valMQ));

  t0=millis();
}

void receive(const MyMessage &message) {
  // We only expect one type of message from controller. But we better check anyway.
  if (message.type==V_LIGHT) {
    StateREL=strcmp(message.data,"ON")==0;
    switch(message.sensor) {
      case 1: {
        StateREL1=StateREL;
        send(msgREL1.set(StateREL1 ? "ON":"OFF"));
        if (StateREL) {
          digitalWrite(REL1_PIN, HIGH);
        }
        else {
          digitalWrite(REL1_PIN, LOW);
        }
        
      }
      break;
      case 2: {
        StateREL2=StateREL;
        send(msgREL2.set(StateREL2 ? "ON":"OFF"));
        if (StateREL) {
          digitalWrite(REL2_PIN, HIGH);
        }
        else {
          digitalWrite(REL2_PIN, LOW);
        }
      }
      break;
      case 3: {
        StateREL3=StateREL;
        send(msgREL3.set(StateREL3 ? "ON":"OFF"));
        if (StateREL) {
          digitalWrite(REL3_PIN, HIGH);
        }
        else {
          digitalWrite(REL3_PIN, LOW);
        }
      }
      break;
      case 4: {
        StateREL4=StateREL;
        send(msgREL4.set(StateREL4 ? "ON":"OFF"));
        if (StateREL) {
          digitalWrite(REL4_PIN, HIGH);
        }
        else {
          digitalWrite(REL4_PIN, LOW);
        }
      }
      break;
      case 6: { // Alarm Warning
        StateAlmWarn=StateREL;
        send(msgAlmWarn.set(StateAlmWarn ? "ON":"OFF"));
        if (StateREL) {
          analogWrite(AlmWarn_PIN, 15);
        }
        else {
          analogWrite(AlmWarn_PIN, 0);
        }
      }
      break;
      case 7: {  // Alarm Sound
        StateAlmSnd=StateREL;
        send(msgAlmSnd.set(StateAlmSnd ? "ON":"OFF"));
        if (StateREL) {
          analogWrite(AlmWarn_PIN, 255);
        }
        else {
          analogWrite(AlmWarn_PIN, 0);
        }
      }
      break;
      case 8: {  // Alarm ON/OFF
        StateAlmActivate=StateREL;
        send(msgAlmActivate.set(StateAlmActivate ? "ON":"OFF"));
      }
      break;
    }

   } 
}

void IRr(){
  unsigned long IC1=0;
  if (irrecv.decode(&results)) {
    IC1 = results.value;
    switch (IC1) {
      case 16724175: IrAct=1; break; // 1
      case 16718055: IrAct=2; break; // 2
      //case 16743045: IrAct=3; break; // 3
      case 16716015: IrAct=4; break; // 4
      case 16769055: IrAct=10; break; // -
      case 16754775: IrAct=20; break; // +
      case 16748655: IrAct=31; break; // EQ - alm ON
      case 16761405: IrAct=30; break; // >| - alm OFF
      default:IrAct=0; break;
      }
  irrecv.resume();

  switch(IrAct) {
      case 1: {
        StateREL1=!StateREL1;
        if (StateREL1) {
          digitalWrite(REL1_PIN, HIGH);
        }
        else {
          digitalWrite(REL1_PIN, LOW);
        }
        send(msgREL1.set(StateREL1 ? "ON":"OFF"));
      }
      break;
      case 2: {
        StateREL2=!StateREL2;
        if (StateREL2) {
          digitalWrite(REL2_PIN, HIGH);
        }
        else {
          digitalWrite(REL2_PIN, LOW);
        }
        send(msgREL2.set(StateREL2 ? "ON":"OFF"));
      }
      break;
      case 3: {
        StateREL3=!StateREL3;
        if (StateREL3) {
          digitalWrite(REL3_PIN, HIGH);
        }
        else {
          digitalWrite(REL3_PIN, LOW);
        }
        send(msgREL3.set(StateREL3 ? "ON":"OFF"));
      }
      break;
      case 4: {
        StateREL4=!StateREL4;
        if (StateREL4) {
          digitalWrite(REL4_PIN, HIGH);
        }
        else {
          digitalWrite(REL4_PIN, LOW);
        }
        send(msgREL4.set(StateREL4 ? "ON":"OFF"));
      }
      break;
      case 10: {
        StateREL1=0;
        digitalWrite(REL1_PIN, LOW);
        send(msgREL1.set("OFF"));
        StateREL2=0;
        digitalWrite(REL2_PIN, LOW);
        send(msgREL2.set("OFF"));
        //StateREL3=0;
        //digitalWrite(REL3_PIN, LOW);
        //send(msgREL3.set("OFF"));
        StateREL4=0;
        digitalWrite(REL4_PIN, LOW);
        send(msgREL4.set("OFF"));
      }
      break;
      case 20: {
        StateREL1=1;
        digitalWrite(REL1_PIN, HIGH);
        send(msgREL1.set("ON"));
        StateREL2=1;
        digitalWrite(REL2_PIN, HIGH);
        send(msgREL2.set("ON"));
        //StateREL3=1;
        //digitalWrite(REL3_PIN, HIGH);
        //send(msgREL3.set("ON"));
        StateREL4=1;
        digitalWrite(REL4_PIN, HIGH);
        send(msgREL4.set("ON"));
      }
      break;
      case 31: {
        StateAlmActivate=true;
        send(msgAlmActivate.set(StateAlmActivate ? "ON":"OFF"));
      }
      break;
      case 30: {
        StateAlmActivate=false;
        send(msgAlmActivate.set(StateAlmActivate ? "ON":"OFF"));
      }
      break;

    }
  }
}


/* IR Remote codes HEX:
 *  16753245  FFA25D  CH-
 *  16736925  FF629D  CH
 *  16769565  FFE21D  CH+
 *  16720605  FF22DD  <<
 *  16712445  FF02FD  >>
 *  16761405  FFC23D  >|
 *  16769055  FFE01F  -
 *  16754775  FFA857  +
 *  16748655  FF906F  EQ
 *  16738455  FF6897  0
 *  16750695  FF9867  100+
 *  16756815  FFB04F  200+
 *  16724175  FF30CF  1
 *  16718055  FF18E7  2
 *  16743045  FF7A85  3
 *  16716015  FF10EF  4
 *  16726215  FF38C7  5
 *  16734885  FF5AA5  6
 *  16728765  FF42BD  7
 *  16730805  FF4AB5  8
 *  16732845  FF52AD  9
 */