PQduino

#include <ESP8266WiFi.h>                         
#include <WebSocketsServer.h>                    
#include <ESP8266WebServer.h>                    
#include "ESP8266HTTPUpdateServer.h"
#include "ADE7753.h"
#include <SPI.h>
#include <Math.h>
#include "Main_Webpage.h"

#define SPI_Speed 1000000 //SPI Speed
#define CS_Pin D8         //GPIO15 SPI_Chip Select Pin
#define IRQPin D4         //IRQ Notify Pin on ESP8266

const char* ssid     = "XXXX";
const char* password = "XXXX";

ADE7753 myADE(CS_Pin);

const char* host = "my_powermeter";
const char* update_path = "/firmware";
const char* update_username = "admin";
const char* update_password = "admin";

signed long WAVE_VAL [128];
long voltaje_A=0;
long v_real=0;
String v_string="", v_comp="", v_int="", v_dec="";
long corriente_A=0;
long i_real=0;
String i_string="", i_comp="", i_int="", i_dec="";
byte temp_val=0;
long freq_val=0;
long freq_real=0;
String freq_string="", freq_comp="", freq_int="", freq_dec="";
String REG_DATA;
signed int activa=0, reactiva=0, aparente=0;
volatile byte wave_flag=false;
volatile int wave_counter=0;

unsigned long last;                             
int inputVal;                                    
float voltVal;                                   
float voltValPrev = 0 ;                           
String myString;                                 

String Voltage,Current,P_Power,S_Power,Q_Power,THDV,THDI,Temp,PF,WaveForm;


ESP8266WebServer server (80);
ESP8266HTTPUpdateServer httpUpdater;
WebSocketsServer webSocket = WebSocketsServer(81);

void webSocketEvent(uint8_t num, WStype_t type, uint8_t * payload, size_t length) {                                                                        
  switch(type) {                      
    case WStype_CONNECTED: {IPAddress ip = webSocket.remoteIP(num);webSocket.sendTXT(num,myString);}break;              
    case WStype_DISCONNECTED:break;                         
    case WStype_TEXT:break; 
    case WStype_ERROR:break; 
    }
}

void set_ScreenHead(){
  REG_DATA="";
  REG_DATA=REG_DATA+String(myADE.read16bits(MODE))+'-';
  REG_DATA=REG_DATA+String(myADE.read16bits(LINECYC))+'-';
  REG_DATA=REG_DATA+String(myADE.read8bits(GAIN))+'-';
  REG_DATA=REG_DATA+String(myADE.read16bits(IRQEN));
  Serial.println(REG_DATA);
}
void get_Voltage(){
  myADE.write16(MODE, 0x8C);                            //Cycle energy accumulation Mode
  set_ScreenHead();
  voltaje_A = myADE.getVRMS(10);
  v_real=voltaje_A*449/1000;
  v_comp= String(v_real);
  v_dec= v_comp.substring(v_comp.length()-3);
  v_int= v_comp;
  v_int.replace(v_dec,"");
  v_string=v_int + '.' + v_dec;
  delay(0);
}

void get_Current(){
  myADE.write16(MODE, 0x8C);                            //Cycle energy accumulation Mode 
  set_ScreenHead();
  corriente_A = myADE.getIRMS(10);
  i_real=corriente_A*449/1000;
  i_comp= String(i_real);
  i_dec= i_comp.substring(i_comp.length()-3);
  i_int= i_comp;
  i_int.replace(i_dec,"");
  i_string=i_int + '.' + i_dec;
  delay(0);
}

void get_Temp(){
  temp_val = myADE.read8bits(TEMP);
  temp_val=(temp_val-222)*3+25;                       //If Chip produce value of 222 at 25°C
  //------------------------------
  freq_val = myADE.read16bits(PERIOD);
  freq_real=freq_val;
  freq_comp= String(freq_real);
  freq_dec= freq_comp.substring(freq_comp.length()-3);
  freq_int= freq_comp;
  freq_int.replace(freq_dec,"");
  freq_string=freq_int + '.' + freq_dec + "Hz";
  delay(0);
}


void setup() {
  pinMode(IRQPin, INPUT_PULLUP);
  pinMode(CS_Pin, OUTPUT);
  myADE.Start(SPI_Speed,CS_Pin);
  digitalWrite (CS_Pin,LOW);
  delay(10);
  attachInterrupt(IRQPin,readWaveReg_I,FALLING);
  myADE.write16(MODE, 0x8C);      //Cycle energy accumulation Mode 
  myADE.write16(LINECYC, 0x78);   //120 half-cycles to power accumulation
  myADE.write8(GAIN, 0x00);       //0.5V max per chanel
  delay(10);
  
  Serial.begin(115200);
  Serial.println();

  WiFi.mode(WIFI_STA); //para que no inicie el SoftAP en el modo normal
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {delay(500); Serial.print(".");}
  delay(0);
  Serial.println("");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
  
  webSocket.begin();
  webSocket.onEvent(webSocketEvent);
  server.on("/", []() {server.send_P(200, "text/html", main_webpage);});
  httpUpdater.setup(&server, update_path, update_username, update_password);
  server.begin();                                     
}

void loop() {
  webSocket.loop();
  server.handleClient();                             
  if ((millis()-last) > 500) {
    last = millis();                    
    get_Voltage();
    get_Current();
    if (wave_flag==false){
      WaveForm="";
      for(int a=0;a<128;a++){WaveForm=WaveForm+"$"+String(WAVE_VAL[a]*128/1950);}
      get_WAVE_V();
    }
    myString = String(v_string)+"#"+String(i_real)
               +"#"+String(activa)+"#"+String(reactiva)
               +"#"+String(aparente)+"#"+String(6*voltVal)
               +"#"+String(7*voltVal)+"#"+String(8*voltVal)
               +"#"+String(temp_val)+"#"+String(10*voltVal)
               +"#"+String(11*voltVal)+"#"+String(12*voltVal)
               +"#"+String(13*voltVal)+"#"+String(14*voltVal)
               +"#"+String(15*voltVal)+"#"+String(freq_real)+"#"+String(REG_DATA)+"#"+WaveForm;
    webSocket.broadcastTXT(myString);  
    Serial.println(myString);                                           
  }
}