Environmental and Distance\Door Sensor project on the Mini-WirelessHW-433Mhz

Rick had asked a few months ago to post some of what I had used my anarduino's to monitor. So here goes. I don't do forum and I'm definitely not a coder

That will be obvious to those who are.

This relies on three parts:
Tnode
TGateway
python script to copy to emocms(runs on raspberry pi through a serial dump over usb to ftdi cable)

The below code allows my anarduino's to act as a network and update my emoncms page as specified. Basically I monitor my utility room Temp, Humidity, and Salt level in the softener. One anarduino acts as a broadcast node and the other acts as a gateway. I have a 3rd anarduino that monitors my barn environmental's and the door status.

disclaimer - The below code was built from various internet sources and by another friend of mine, as well as myself. I didn't have a spare anarduino to reupload and test the gateway code, but I'm 99% sure that is the final version i used.

Tgateway

// TGateway - read TNodes... (see Tnode.ino example for more info)
//
// 2014 - anarduino.com
//
#include <RFM69.h>
#include <SPI.h>

#define GATEWAY_ID    1     // this is ME, TGateway
#define NETWORKID     100    //the same on all nodes that talk to each other

// Uncomment only one of the following three to match radio frequency
#define FREQUENCY     RF69_433MHZ    
//#define FREQUENCY     RF69_868MHZ
//#define FREQUENCY     RF69_915MHZ

#define IS_RFM69HW   //NOTE: uncomment this ONLY for RFM69HW or RFM69HCW
#define ENCRYPT_KEY    "my-EncryptionKey2"  // use same 16byte encryption key for all devices on net
#define ACK_TIME       50                  // max msec for ACK wait
#define LED            9                   // Anardino miniWireless has LEDs on D9
#define SERIAL_BAUD    115200
#define TGW_VERSION  "1.0"

typedef struct {
  int           nodeId; //store this nodeId
  unsigned int distance;
  unsigned long uptime; //uptime in ms
  float         temp;   //temperature maybe?
  float         humidity;
  float         vcc;
} Payload;
Payload theData;

RFM69 radio;                  // global radio instance
bool promiscuousMode = false; // set 'true' to sniff all packets on the same network
bool requestACK=false;

void setup() {
  Serial.begin(SERIAL_BAUD);
  Serial.print("TGateway ");
  Serial.print(TGW_VERSION);
  Serial.print(" startup at ");
  Serial.print((FREQUENCY==RF69_433MHZ ? 433 : FREQUENCY==RF69_868MHZ ? 868 : 915));
  Serial.print("Mhz, Network ID: ");
  Serial.println(NETWORKID);
  delay(50);
  radio.initialize(FREQUENCY, GATEWAY_ID, NETWORKID);
  radio.encrypt(0);
  radio.promiscuous(promiscuousMode);
#ifdef IS_RFM69HW
  radio.setHighPower(); //uncomment #define ONLY if radio is of type: RFM69HW or RFM69HCW 
#endif
}

byte ackCount=0;
void loop() {
  if (radio.receiveDone())
  {
    Serial.print(radio.readRSSI());
    Serial.print(", ");
    if (promiscuousMode)
    {
      Serial.print("to [");Serial.print(radio.TARGETID, DEC);Serial.print("] ");
    }

if (radio.DATALEN == sizeof(Payload))
    {
      theData = *(Payload*)radio.DATA; //assume radio.DATA actually contains our struct and not something else
//      Serial.print(" nodeId=");
//      Serial.print(theData.nodeId);
//      Serial.print(" uptime=");
//      Serial.print(theData.uptime);
//      Serial.print(" temp=");
//      Serial.print(theData.temp);
//      Serial.print(" humidity=");
//      Serial.print(theData.humidity);
//      Serial.print(" vcc=");
//      Serial.print(float(theData.vcc/1000),3);
      
      Serial.print(theData.nodeId);
      Serial.print(", ");
      Serial.print(theData.distance);
      Serial.print(", ");
      Serial.print(theData.uptime);
      Serial.print(", ");
      Serial.print(theData.temp);
      Serial.print(", ");
      Serial.print(theData.humidity);
      Serial.print(", ");
      Serial.print(float(theData.vcc/1000),3);
    }
    else 
    {
      Serial.println(sizeof(radio.DATALEN));
      Serial.println(sizeof(Payload));
    }

if (radio.ACKRequested())
    {
      byte theNodeID = radio.SENDERID;
      radio.sendACK();
      Serial.print(" - ACK sent.");

// When a node requests an ACK, respond to the ACK
      // and also send a packet requesting an ACK (every 3rd one only)
      // This way both TX/RX NODE functions are tested on 1 end at the GATEWAY
      if (ackCount++%3==0)
      {
        Serial.print(" Pinging node ");
        Serial.print(theNodeID);
        Serial.print(" - ACK...");
        delay(3); //need this when sending right after reception .. ?
        if (radio.sendWithRetry(theNodeID, "ACK TEST", 8, 0))  // 0 = only 1 attempt, no retries
          Serial.print("ok!");
        else Serial.print("nothing");
      }
    }
    Serial.println();
    Blink(LED,100);
  }
}

void Blink(byte PIN, int DELAY_MS)
{
  pinMode(PIN, OUTPUT);
  digitalWrite(PIN,HIGH);
  delay(DELAY_MS);
  digitalWrite(PIN,LOW);
}

Tnode

// NOTE: code sample was inspired from ideas gained from: https://github.com/aanon4/RFM69
//
// TNode - periodically send time(millis), radio temperature, VCC voltage to gateway...
// 2014 - anarduino.com
//
#include <Time.h>
#include <MCP7940RTC.h>
#include <RFM69.h>
#include <SPI.h>
#include <SPIFlash.h>
#include <dht.h>
#include <LowPower.h>
#include <Wire.h>
#include <NewPing.h>

dht DHT;

#define DHT22_PIN     5
#define MAGSW_PIN     11 
#define GATEWAY_ID    1
#define NODE_ID       10    // node ID
#define NETWORKID     100    //the same on all nodes that talk to each other
#define MSG_INTERVAL  3000

#define TRIGGER_PIN  7  // Arduino pin tied to trigger pin on the ultrasonic sensor.
#define ECHO_PIN     8  // Arduino pin tied to echo pin on the ultrasonic sensor.
#define MAX_DISTANCE 200 // Maximum distance we want to ping for (in centimeters). Maximum sensor distance is rated at 400-500cm.

// Uncomment only one of the following three to match radio frequency
#define FREQUENCY     RF69_433MHZ

#define IS_RFM69HW   //NOTE: uncomment this ONLY for RFM69HW or RFM69HCW
#define ENCRYPT_KEY    "my-EncryptionKey2"  // use same 16byte encryption key for all devices on net
#define ACK_TIME       50                  // max msec for ACK wait
#define LED            9                   // Anardino miniWireless has LEDs on D9
#define SERIAL_BAUD    115200
#define TNODE_VERSION  "1.0"

volatile int gotInterrupt = 0;
MCP7940RTC *pRTC; //Clock
SPIFlash flash(5); //Flash

NewPing sonar(TRIGGER_PIN, ECHO_PIN, MAX_DISTANCE); // Added by JPB - NewPing setup of pins and maximum distance.

unsigned long start, finished, elapsed;
unsigned int  addonsensor;
unsigned int           magstatus; //status of mag switch
//unsigned int           doorstatus; // stores status od mag switch result
void rtcIntr() {  
  gotInterrupt=1;  
}

RFM69 radio;                  // global radio instance
bool promiscuousMode = false; // set 'true' to sniff all packets on the same network
bool requestACK=false;

typedef struct {
  int           nodeId; //store this nodeId
 
  //unsigned int  doorstatus; // stores status od mag switch result
  
  unsigned int  addonsensor;
  unsigned long uptime; //uptime in ms
  float         temp;   //temperature maybe?
  float         humidity;
  float         vcc;
 
} Payload;
Payload theData;

////int distance;

void setup() {    
  pinMode(MAGSW_PIN, INPUT);
  Serial.begin(SERIAL_BAUD);
  Serial.print("TNode ");
  Serial.print(TNODE_VERSION);
  Serial.print(" startup at ");
  Serial.print((FREQUENCY==RF69_433MHZ ? 433 : FREQUENCY==RF69_868MHZ ? 868 : 915));
  Serial.println("Mhz...");
  delay(20);
  radio.initialize(FREQUENCY, NODE_ID, NETWORKID);
  radio.encrypt(0);
  radio.promiscuous(promiscuousMode);
#ifdef IS_RFM69HW
  radio.setHighPower(); //uncomment #define ONLY if radio is of type: RFM69HW or RFM69HCW 
#endif
  pRTC = new MCP7940RTC();  
  pRTC->set(1387798395);  
  pRTC->setTimeRTC(1388534400); // 2014-01-01 00:00:00  
  
  attachInterrupt(1,rtcIntr,CHANGE );
  pRTC->setAlarm0(pRTC->get() + 30);
  
}

void loop() {
  
  if (gotInterrupt) { 
      start = millis(); 
      beginning:

DHT.read22(DHT22_PIN);
      float temp = (DHT.temperature*9+2)/5+32;
      float humd = DHT.humidity;  
      int vcc = readVcc();
      int n=1; 
      addonsensor = sonar.ping_cm();
      
      magstatus=digitalRead(MAGSW_PIN); 
      if (magstatus == HIGH)
      {
     addonsensor = 00;
      Serial.println("door is open");
      Serial.println(addonsensor);
      }
      else
      {
      addonsensor = 11;
      Serial.println("door is closed");
      Serial.println(addonsensor);
      } 
      
      
      
      
      
      
      
      
      //if(distance <= 0 || distance >= 150)
        //{
        //Serial.println("Sensor Out of Range");
        //distance = 1; //uncomment for testing without sonar connected
       // }
      //else
      //{
       // Serial.print(" Distance to salt is: ");
       // Serial.print(distance);  
       // Serial.println("cm");

//}

theData.nodeId = NODE_ID;
      //theData.doorstatus = doorstatus;
      theData.addonsensor = addonsensor;
      theData.uptime = millis();
      theData.temp = temp;
      theData.humidity = humd;  
      theData.vcc = vcc;
      
    
      Serial.println(NODE_ID);
      //Serial.println(doorstatus);
      Serial.println(addonsensor);
      Serial.println(millis());
      Serial.println(temp);
      Serial.println(humd);
      Serial.println(vcc);
      
      Serial.println(sizeof(Payload));
      Serial.flush();
      
      //Blink(9,100);
      radio.send((byte)GATEWAY_ID, (const void *)(&theData), (byte)sizeof(theData), requestACK);
      
      flash.sleep();
      radio.sleep();
      pRTC->setAlarm0(pRTC->get() + 30);  
      gotInterrupt=0;  
    
      Serial.println("Sleeping for 30s");
      Serial.print("Awake for: ");
      finished = millis();
      elapsed = finished - start;
      Serial.println(elapsed); 
      Serial.flush();  
      LowPower.powerDown(SLEEP_FOREVER, ADC_OFF, BOD_OFF); 
  }
        
//      for (int i=0; i < 4; i++)
//      { 
//        Serial.println("Power Down for 34s");
//        Serial.flush();
//        //flash.sleep();
//        radio.sleep();
//        LowPower.powerDown(SLEEP_8S, ADC_OFF, BOD_OFF); 
//      }
  
}

int readVcc() {   // return vcc voltage in millivolts
  long result;
  // Read 1.1V reference against AVcc
  ADMUX = _BV(REFS0) | _BV(MUX3) | _BV(MUX2) | _BV(MUX1);
  delay(2);             // Wait for Vref to settle
  ADCSRA |= _BV(ADSC);  // Convert
  while (bit_is_set(ADCSRA,ADSC));
  result = ADCL;
  result |= ADCH<<8;
  result = 1126400L / result; // Back-calculate in mV
  int t = (int)result;
  return t;
}

void Blink(byte PIN, int DELAY_MS)
{
  pinMode(PIN, OUTPUT);
  digitalWrite(PIN,HIGH);
  delay(DELAY_MS);
  digitalWrite(PIN,LOW);
}

python

import serial
import httplib
import time
import socket
import pickle
import struct
import random

def now():
    return int(time.time())

# Domain you want to post to: localhost would be an emoncms installation on your own laptop
# this could be changed to emoncms.org to post to emoncms.org
domain = "emoncms.org"

# Location of emoncms in your server, the standard setup is to place it in a folder called emoncms
# To post to emoncms.org change this to blank: ""
emoncmspath = ""

# Write apikey of emoncms account
apikey = "e2355bb8b22764cfd0b21ef346211c3c"

# Node id youd like the emontx to appear as

# Set this to the serial port of your emontx and baud rate, 9600 is
# standard emontx baud rate
ser = serial.Serial('/dev/ttyUSB0', 115200, timeout=1)

while 1:

# Read in line of readings from emontx serial
    linestr = ser.readline()
    if linestr != '' and not 'TGateway' in linestr:
        print linestr.strip()
        csv = [c.strip() for c in linestr.split(',')]

rssi = csv[0]
        node = csv[1]
        addon = int(csv[2])
        milli = int(csv[3])
        temp = float(csv[4])
        humd = float(csv[5])
        vcc = csv[6]

data = "%s,%s,%s,%s,%s,%s" % (rssi, milli, addon, temp, humd, vcc)
        message = (csv[0], csv[1], int(csv[2]), int(csv[3]), float(csv[4]), float(csv[5]), csv[6])
#        send_to_graphite(message)

# Send to emoncms
        try:
            conn = httplib.HTTPConnection(domain)
            conn.request("GET", "/" + emoncmspath + "/input/post.json?apikey=" +
                         apikey + "&node=" + str(node) + "&csv=" + data)
            response = conn.getresponse()
            print node, data, response.read()
            collect_metric("sensors.%s.", random.randrange(68, 85), now())
        except Exception as err:
            print "Send to emoncms failed..."
            print err

hello
Thanks for providing a detailed information on the project. I read the post and found it interesting. Good luck with it. Any more information regarding the project please do update.
Thanks for posting
Research paper writing service