Svenska ElektronikForumet

Kod: Markera allt

#define xbee Serial
#define pinVarh 8
#define pinWh 9

byte ioPin[2] = {pinWh, pinVarh};
byte statePin[2];
unsigned long lastHigh[2];

boolean pulseStart(byte varSelect) {
  if(digitalRead(ioPin[varSelect]) == HIGH) {
    if(statePin[varSelect] == 0) {
      statePin[varSelect] == 1;
      return(true);
    } else {
      return(false);
    }
  } else {
    statePin[varSelect] == 0;
    return(false);
  }
}

unsigned long interval(unsigned long lastTime, unsigned long tickNow) {
  return( (lastTime <= tickNow) ? (tickNow - lastTime) : ((lastTime - 2 ^ 16) - (tickNow + 2 ^ 16)) );
}

unsigned long usedEnergy(unsigned long useInterval) {
  const unsigned long timeConst = 3600000UL;

  return(timeConst / useInterval);
}

void setup() {
  byte seenHigh[2] = {0, 0};

  for(byte i=0; i<2; i++) {
    pinMode(ioPin[i], INPUT);
  }
  xbee.begin(9600);

  while(seenHigh[0] == 0 || seenHigh[1] == 0) {
    for(byte i=0; i<2; i++) {
      if(pulseStart(i)) {
        seenHigh[i] = 1;
        lastHigh[i] = millis();
      }
    }
  }

  xbee.println("channel,interval,energy");
}

void loop() {
  unsigned long thisInterval, tickNow;
  for(int i=0; i<2; i++) {
    if(pulseStart(i)) {
      tickNow = millis();
      xbee.print(i);
      xbee.print(",");
      thisInterval = interval(lastHigh[i], tickNow);
      xbee.print(thisInterval);
      xbee.print(",");
      xbee.println(usedEnergy(thisInterval));
      lastHigh[i] = tickNow;
    }
  }
}

Kod: Markera allt

#include <Wire.h>
#define xbee Serial
#define xbeeBps 57600
#define pinWh 5
#define saRtc 0x68  // Slave Address of DS1307 I2C RTC

int ioPin = pinWh;
unsigned long lastPulse;
const unsigned long msPerHour = 3600000UL;
const unsigned long pulseTimeout = 25000000UL;
const unsigned long pulseMinLength = 12000UL;  // in milliseconds; pulses are about 14 ms (13 - 14,6)

#define buffSize 32
unsigned int buffData[buffSize];
byte buffPtr;

char rtcString[] = "42-42-42 42:96:96,";

void rtcRead(void) {
  char ds1307Raw[7];
  char ds1307Mask[7] = {0x7f, 0xff, 0x3f, 0xff, 0xff, 0xff, 0xff};
  byte rtcXlat[6][2] = {{0, 6}, {3, 5}, {6, 4}, {9, 2}, {12, 1}, {15, 0}};
  
  Wire.beginTransmission(saRtc);
  Wire.send(0x00);
  Wire.endTransmission();
  Wire.requestFrom(saRtc, 7);
  for(byte i=0; i<7; i++) { ds1307Raw[i] = Wire.receive() & ds1307Mask[i]; }
  for(byte i=0; i<6; i++) {
    rtcString[rtcXlat[i][0]]     = '0' + ((ds1307Raw[rtcXlat[i][1]] & 0xf0) >> 4);
    rtcString[rtcXlat[i][0] + 1] = '0' +  (ds1307Raw[rtcXlat[i][1]] & 0x0f);
  }
}

unsigned int avgInterval(void) {
  unsigned long buffSum = 0;
  
  for(byte i=0; i<buffSize; i++) { buffSum += buffData[i]; }
  return((unsigned int)(buffSum / (unsigned long)buffSize));
}

void reportData(void) {
  unsigned long foo;
  
  rtcRead();
  foo = avgInterval();
  xbee.print(rtcString);
  xbee.print(buffData[buffPtr]);                        xbee.print(",");
  xbee.print(msPerHour / buffData[buffPtr]);            xbee.print(",");
  xbee.print((foo * (unsigned long)buffSize) / 1000UL); xbee.print(",");
  xbee.print(msPerHour / foo);                          xbee.println();
}

boolean getData(void) {
  unsigned long tickNow;

  if((pulseIn(ioPin, HIGH, pulseTimeout) > pulseMinLength)) {
    tickNow = millis();
    buffPtr = ++buffPtr % buffSize;
    buffData[buffPtr] = (lastPulse <= tickNow) ? (tickNow - lastPulse) : ((lastPulse - 2 ^ 16) - (tickNow + 2 ^ 16));
    lastPulse = tickNow;
    return(true);
  } else return(false);
}

void setup() {
  Wire.begin();
  pinMode(ioPin, INPUT);
  xbee.begin(xbeeBps);
  for(byte i=0; i<buffSize; i++) { while(!getData()); }
  xbee.println("date time,Wh-interval,Wh,averaged seconds,average Wh");
}

void loop() {
  while(!getData());
  reportData();
}