Posts made by brahim

Hi , i update your sketch for Multiple sensor

#define MY_RADIO_NRF24
#define MY_DEBUG

#include <SPI.h>
#include <MySensors.h>  
#include <EmonLib.h> 

#define SERIAL_BAUD 115200

#define PIN_ANALOG_I1 A0   // The input you attached SCT1.
#define PIN_ANALOG_I2 A1   // The input you attached SCT2.
#define PIN_ANALOG_I3 A2   // The input you attached SCT3.

#define CHILD_ID_WATT 0    // child-id of sensor
#define CHILD_ID_KWH  1    // child-id of sensor
#define CHILD_ID_VAR1 2    // child-id of sensor

#define MAX_CT 3           // Number of CT sensor

EnergyMonitor ct1, ct2, ct3;

MyMessage msgWatt(CHILD_ID_WATT,V_WATT);
MyMessage msgKwh(CHILD_ID_KWH,V_KWH);
MyMessage msgVar(CHILD_ID_VAR1,V_VAR1);

unsigned long lastSend_power = millis();
unsigned long lastSend_c = millis();
unsigned long SEND_FREQUENCY   = 60000;               // 1 mn Minimum time between send (in milliseconds).
unsigned long FREQUENCY_SAMPLE = SEND_FREQUENCY / 12 ; // ( 5 s)

#define MAX_CT 3

double  Irms[MAX_CT];
float   nrj[MAX_CT];
boolean pcReceived[MAX_CT];

int    index = 0;

void setup()
{
#ifdef MY_DEBUG
  Serial.begin(SERIAL_BAUD);
  Serial.println("Begin SETUP");
#endif
  //ct1.current(PIN_ANALOG_I1, 111.1);     // Current: input pin, calibration.                                        
  ct1.current(PIN_ANALOG_I1, 60);          // current constant = (100 ÷ 0.050) ÷ 33 Homs = 60
  ct2.current(PIN_ANALOG_I2, 60);            
  ct3.current(PIN_ANALOG_I3, 60);            

  Irms[0] = ct1.calcIrms(1480);            // initial boot to charge up capacitor (no reading is taken) - testing
  Irms[1] = ct2.calcIrms(1480);
  Irms[2] = ct3.calcIrms(1480);

  for (int i=0; i<MAX_CT; i++) {
       Irms[i] = nrj[i] = 0;
       pcReceived[i]=false;
  }
#ifdef MY_DEBUG
  Serial.println("SETUP completed");
#endif

}

void presentation() {
  
  sendSketchInfo("Energy Meter", "2.1");

  present(0, S_POWER);
  request(0, V_VAR1);
  
  present(1, S_POWER);
  request(1, V_VAR1);

  present(2, S_POWER);
  request(2, V_VAR1);  
}


void receive(const MyMessage &message) {
  int SensorID ;

  SensorID = message.sensor ;
  
  if (message.type == V_VAR1) {
    
      nrj[SensorID] =  message.getFloat();
      pcReceived[SensorID] = true;

#ifdef MY_DEBUG
      Serial.print("Received last nrj[");
      Serial.print(SensorID);
      Serial.print("] count from GW:");
      Serial.println(nrj[SensorID]);
#endif
  }
}

void send_data(double intrms, int SensorID) {

#ifdef MY_DEBUG
  Serial.print("Send data for SensorID="); 
  Serial.println(SensorID);
#endif

  double energie = (intrms * 240.0 * SEND_FREQUENCY / 1000) / 3.6E6;
  
  nrj[SensorID] += energie;
  send(msgWatt.setSensor(SensorID).set(intrms * 240.0, 1));
  send(msgKwh.setSensor(SensorID).set(nrj[SensorID], 5));
  send(msgVar.setSensor(SensorID).set(nrj[SensorID], 5));
}

void loop() {
  
  unsigned long now = millis();
  double _Irms[MAX_CT];
  bool sendTime_c = now - lastSend_c > FREQUENCY_SAMPLE;
  
  if (sendTime_c)
  {
    _Irms[0] = ct1.calcIrms(1480) ; if (_Irms[0] < 0.3) _Irms[0] = 0;
    _Irms[1] = ct2.calcIrms(1480) ; if (_Irms[1] < 0.3) _Irms[1] = 0;
    _Irms[2] = ct3.calcIrms(1480) ; if (_Irms[2] < 0.3) _Irms[2] = 0;

    Irms[0] = (index * Irms[0] + _Irms[0]) / (index + 1);
    Irms[1] = (index * Irms[1] + _Irms[1]) / (index + 1);
    Irms[2] = (index * Irms[2] + _Irms[2]) / (index + 1);

    lastSend_c = now;
    index++;

#ifdef MY_DEBUG
    for (int i=0; i<MAX_CT; i++) {
        Serial.print("CT");
        Serial.print(i);  Serial.print(" : ");
        Serial.print(Irms[i]*240.0);  // Apparent power
        Serial.print(" ");
        Serial.println(Irms[i]);      // Irms
    }
#endif
  }

  bool sendTime_power = now - lastSend_power > SEND_FREQUENCY;

  if (sendTime_power)
  {
    for (int i=0; i<MAX_CT; i++) {
    // Envoi ou request Puissance1
       if (pcReceived[i])
        { 
         send_data(Irms[i], i);
        } else {
         request(i, V_VAR1);
         Serial.println("Request VAR1");
        }
    }
    //on reinitialise les compteurs
    lastSend_power = now;
    index = 0;
  }
}