Victoria's Blog | Home Monitoring (home made)

Home Monitoring (home made) – Export

01/03/2014

Categories: Arduino Development Eco Solar

Reading the export meter

Reading the export meter is relatively easy as the Arduino in the meter cupboard can be extended to have another light voltage converter to read the export meter.

So we purchased another part from CPC (for those interested in replicating this, you can use one of these: http://cpc.farnell.com/taos/tsl257-lf/sensor-light-voltage-converter/dp/SC12392?Ntt=SC12392)

The Arduino program then needed extending to attach another interrupt for the export meter. The only gotcha here is that the export meter flashes 1000 times for 1kh, but the import meter only 800 times for 1kwh.

And it looks like this:

The complete Arduino program:

#include <SPI.h>
#include <WiFi.h>
#include <WiFiUDP.h>

///////// CHANGEABLE VALUES /////////

double importMultiplier = 1.25;
double exportMultiplier = 1.0;

char ssid[] = "REPLACE THIS";
char pass[] = "REPLACE THIS";

char pompeii[] = "192.168.0.16";
int pompeiiPort = 80;

double minutesBetweenCalls = 1.0;

///////// CHANGEABLE VALUES ABOVE /////////

int status = WL_IDLE_STATUS;

WiFiClient pompeiiClient;
char pompeiiService[] = "/pvoutput-post.php";

unsigned long importImpulseCount = 0;
unsigned long exportImpulseCount = 0;

unsigned long lastTimeUploaded = millis();

boolean importInterruptAttached = false;
boolean exportInterruptAttached = false;

double millisecondsPerMinute = 60000.0;
double timeBetweenCalls = minutesBetweenCalls * millisecondsPerMinute;

void setup() {
  Serial.begin(9600);
  connectToWiFi();
}

void connectToWiFi()
{
  // attempt to connect to Wifi network:
  while ( status != WL_CONNECTED) {
    Serial.print("Attempting to connect to WPA SSID: ");
    Serial.println(ssid);
    // Connect to WPA/WPA2 network:    
    status = WiFi.begin(ssid, pass);

    delay(5000);
  }

  Serial.print("Connected to the network");
  printWifiData();
}

void loop() {
  addImportFlashInterrupt();
  addExportFlashInterrupt();

  if (isTimeToUploadData())
  {
    Serial.println("Uploading data");
    sendResultsToPompeii();
  }
}

void addImportFlashInterrupt()
{
  if (!importInterruptAttached)
  {
    importInterruptAttached = true;
    Serial.println("Attaching import interrupt on pin 3");
    attachInterrupt(1, flashImport, FALLING);
  }
}

void addExportFlashInterrupt()
{
  if (!exportInterruptAttached)
  {
    exportInterruptAttached = true;
    Serial.println("Attaching export interrupt on pin 2");
    attachInterrupt(0, flashExport, FALLING);
  }
}

boolean isTimeToUploadData() {
  unsigned long time = millis();

  if( (time - lastTimeUploaded) >= timeBetweenCalls) {
    Serial.println("Time to upload");
    lastTimeUploaded = time;
    return true;
  }
  return false;
}


void printWifiData() {
  // print your WiFi shield's IP address:
  IPAddress ip = WiFi.localIP();
  Serial.print("IP Address: ");
  Serial.println(ip);
}

/* Handles the interrupt flash logic */
void flashImport() {
  importImpulseCount++;
}

void flashExport() {
  exportImpulseCount++;
}

void sendResultsToPompeii() {
  Serial.println("sendResultsToPompeii");

  String postData = getPostData();
  Serial.println(postData);

  if (pompeiiClient.connect(pompeii, pompeiiPort)) {
    Serial.println("connected to pompeii");
    // Make a HTTP request:
    pompeiiClient.print("POST ");
    pompeiiClient.print(pompeiiService);
    pompeiiClient.println(" HTTP/1.1");
    pompeiiClient.print("Host: ");
    pompeiiClient.print(pompeii);
    pompeiiClient.print(":");
    pompeiiClient.println(pompeiiPort);
    pompeiiClient.println("Accept: text/html");
    pompeiiClient.println("Content-Type: application/x-www-form-urlencoded; charset=UTF-8");
    pompeiiClient.print("Content-Length: ");
    pompeiiClient.println(postData.length());
    pompeiiClient.println("Pragma: no-cache");
    pompeiiClient.println("Cache-Control: no-cache");
    pompeiiClient.println("Connection: close");
    pompeiiClient.println();

    pompeiiClient.println(postData);
    pompeiiClient.println();

    pompeiiClient.stop();
    pompeiiClient.flush();
    Serial.println("Called pompeii");
  }
}

String calculateImportWattsAndResetFlashes()
{
  if (importImpulseCount == 0UL) {
    return "0";
  }

  double watts = (importImpulseCount * importMultiplier);
  Serial.print("Calculated Import Watts: ");
  Serial.println(watts);
  
  importImpulseCount = 0UL;
  
  return doubleToString(watts);
}

String calculateExportWattsAndResetFlashes()
{
  if (exportImpulseCount == 0UL) {
    return "0";
  }

  double watts = (exportImpulseCount * exportMultiplier);
  Serial.print("Calculated Export Watts: ");
  Serial.println(watts);
  
  exportImpulseCount = 0UL;
  
  return doubleToString(watts);
}

String doubleToString(double valueToConvert)
{
  char doubleChar[15];
  dtostrf(valueToConvert,9,2,doubleChar);
  String dts = String(doubleChar);
  Serial.println(dts);
  return dts;
}

String getPostData()
{
  String importWatts = calculateImportWattsAndResetFlashes();
  String exportWatts = calculateExportWattsAndResetFlashes();
  
  String wattHourPeriod = doubleToString(timeBetweenCalls);
  
  return "iw=" + importWatts + "&ew=" + exportWatts + "&msBetweenCalls=" + wattHourPeriod;
}