//emonTx Shield
#define FILTERSETTLETIME 5000                                           //  Time (ms) to allow the filters to settle before sending data


const int CT1 = 1; 
const int CT2 = 1;                                                      // Set to 0 to disable 
const int CT3 = 1;
const int CT4 = 1;




#define freq RF12_868MHZ                                                // Frequency of RF12B module can be RF12_433MHZ, RF12_868MHZ or RF12_915MHZ. You should use the one matching the module you have.
const int nodeID = 10;                                                  // emonTx RFM12B node ID
const int networkGroup = 210;                                           // emonTx RFM12B wireless network group - needs to be same as emonBase and emonGLCD                                                 


// LIBRERIE
#include 
#include 
#include  
#include                                                      // Download JeeLib: http://github.com/jcw/jeelib
#include "EmonLib.h"
 
// RETE
static byte mac_Add[] = {0x90, 0xA2, 0xDA, 0x0D, 0xAB, 0x5C };
static byte ip_Add[] = {192, 168, 1, 221 };
WebServer webserver("", 80);


// VARIABILI DI CALCOLO


int statocons = 0;                 //  Wat reale invio in rete  
int statodispo = 0;               //   Wat Disponibili 


//emonTx Shield
EnergyMonitor ct1,ct2,ct3, ct4;                                              // Create  instances for each CT channel


typedef struct { int power1, power2, power3, power4, Vrms;} PayloadTX;      // create structure - a neat way of packaging data for RF comms
PayloadTX emontx;                                                       


const int LEDpin = 9;                                                   // On-board emonTx LED 


boolean settled = false;




//START
void Start(WebServer &server, WebServer::ConnectionType type, char *url_param, bool param_complete)
{
  server.httpSuccess();
     
 
    // HTM 
    P(htmlHead) =
    ""
    ""
    ""
    "<span style="font-size:10px">"&nbsp;&nbsp; &nbsp;"<INDEX.HTML>"&nbsp;&nbsp; &nbsp;"</span>"
    ""
    ""
    "";
 
    server.printP(htmlHead);


    server.print("");
    
     server.println("Wat Produzione Fotovoltaico= "); //Scrive sul browser il valore
     server.print(emontx.power2);
     server.println("
Wat consumi Reali Casa= "); //Scrive sul browser il valore
     server.print(emontx.power1);
     server.println("
Wat disponibili Fotovoltaico = "); //Scrive sul browser il valore
     server.print(statodispo);
     server.println("
Volt Tensione = "); //Scrive sul browser il valore
     server.print(emontx.Vrms);
 
     if(statocons >0)
      server.println("
Sovraproduzione : " );
    else
      server.println("
Consumo eccessivo : ");
      server.print(statocons);
      server.print("");
  }


//=============================================================================






void setup() 
{
//emonTx Shield     
  Serial.begin(9600);
   //while (!Serial) {
    ; // wait for serial port to connect. Needed for Leonardo only
  
  Serial.println("emonTX Shield CT123 Voltage example"); 
  Serial.println("OpenEnergyMonitor.org");
  Serial.print("Node: "); 
  Serial.print(nodeID); 
  Serial.print(" Freq: "); 
  if (freq == RF12_433MHZ) Serial.print("433Mhz");
  if (freq == RF12_868MHZ) Serial.print("868Mhz");
  if (freq == RF12_915MHZ) Serial.print("915Mhz"); 
 Serial.print(" Network: "); 
  Serial.println(networkGroup);
  // }
   
  if (CT1) ct1.current(1, 60.606);                                     // Setup emonTX CT channel (ADC input, calibration)
  if (CT2) ct2.current(2, 60.606);                                     // Calibration factor = CT ratio / burden resistance
  if (CT3) ct3.current(3, 60.606);                                     // emonTx Shield Calibration factor = (100A / 0.05A) / 33 Ohms
  if (CT4) ct4.current(4, 60.606); 
  
  if (CT1) ct1.voltage(0, 234.26, 1.7);                                // ct.voltageTX(ADC input, calibration, phase_shift) - make sure to select correct calibration for AC-AC adapter  http://openenergymonitor.org/emon/modules/emontx/firmware/calibration. Default set for Ideal Power adapter                                         
  if (CT2) ct2.voltage(0, 234.26, 1.7);                                
  if (CT3) ct3.voltage(0, 234.26, 1.7);
  if (CT4) ct4.voltage(0, 234.26, 1.7);
  
  rf12_set_cs(8);                                                       // da modificare secondo saldatura
  rf12_initialize(nodeID, freq, networkGroup);                          // initialize RFM12B
  rf12_sleep(RF12_SLEEP);


  pinMode(LEDpin, OUTPUT);                                              // Setup indicator LED
  digitalWrite(LEDpin, HIGH);
  
  //WEB
  Ethernet.begin(mac_Add, ip_Add);
  webserver.setDefaultCommand(&Start);
  webserver.addCommand("index.htm", &Start);
  webserver.begin();
  delay(100);
                                                                                    
}


void loop() 
{ 
  // WEB SERVER 
  webserver.processConnection();
  
//emonTx Shield  
  if (CT1) {
    ct1.calcVI(20,2000);                                                  // Calculate all. No.of crossings, time-out 
    emontx.power1 = ct1.realPower;
    Serial.print(emontx.power1);                                         
  }
  
  emontx.Vrms = ct1.Vrms;                                            // AC Mains rms voltage 
  
  if (CT2) {
    ct2.calcVI(20,2000);                                                  // Calculate all. No.of crossings, time-out 
    emontx.power2 = ct2.realPower;
    Serial.print(" "); Serial.print(emontx.power2);
  } 


  if (CT3) {
    ct3.calcVI(20,2000);                                                  // Calculate all. No.of crossings, time-out 
    emontx.power3 = ct3.realPower;
    Serial.print(" "); Serial.print(emontx.power3);
  } 
  
   if (CT4) {
     ct4.calcVI(20,2000);                                                  // Calculate all. No.of crossings, time-out 
    emontx.power4 = ct4.realPower;
    Serial.print(" "); Serial.print(emontx.power4);
  } 
  
  Serial.print(" "); Serial.print(ct1.Vrms);
  
  Serial.println(); delay(100);


  // because millis() returns to zero after 50 days ! 
  if (!settled && millis() > FILTERSETTLETIME) settled = true;


  if (settled)                                                            // send data only after filters have settled
  { 
    send_rf_data();                                                       // *SEND RF DATA* - see emontx_lib
    digitalWrite(LEDpin, HIGH); delay(2); digitalWrite(LEDpin, LOW);      // flash LED
    delay(2000);                                                          // delay between readings in ms
  }
  
 // stato consumi


statocons = emontx.power2-emontx.power1;


 
}