Arlindo Montagnoli
ProjetoBB
Dependencies: F7_Ethernet WebSocketClient mbed mcp3008
Fork of
Nucleo_F746ZG_Ethernet
by 
Dieter Graef
Diff: main.cpp
- Revision:
- 3:0fc17139f828
- Parent:
- 0:f9b6112278fe
--- a/main.cpp Thu Jun 23 09:07:47 2016 +0000
+++ b/main.cpp Tue Feb 06 00:15:55 2018 +0000
@@ -2,54 +2,667 @@
#include "rtos.h"
#include "EthernetInterface.h"
#include "NTPClient.h"
+#include "Websocket.h"
#include <stdio.h>
+#include "SimpleSMTPClient.h"
+
+#define SERIAL 4
+#define SIGNAL_LEN 256
+
+#define DOMAIN "smtp2go.com"
+#define SERVER "mail.smtp2go.com"//"aspmx.l.google.com"
+#define PORT "2525" // Port 25 doesn't require TSL
+#define USER "arlindonm"
+#define PWD "SmartMeter"
+#define FROM_ADDRESS "arlindonm@smtp2go.com"
+// less than 128 characters.
+#define TO_ADDRESS "arlindonm@gmail.com"
+#define SUBJECT "EnergySmartMeter msg"
+
+IWDG_HandleTypeDef hiwdg;
+
+const char* SERVER_ADDRESS = "200.133.229.238";
+//const char* SERVER_ADDRESS = "192.168.1.110";
+const int SERVER_PORT = 1080;
+
+bool STOPEMAIL = true,flagSendNoBreak=0;
+
+Ticker tickerTensaoCorrente;
+
+//8 pinos da placa
+AnalogIn correnteA(PC_2);
+AnalogIn correnteB(PC_3);
+//-
+//tx
+//rx
+DigitalOut scale(PD_7);
+DigitalOut getVoltagem(PE_3);
+//gnd
+
+//4pinos da placa
+DigitalOut picWatchDog(PC_11);
+AnalogIn tensaoA(PC_0);
+DigitalIn noBreak(PD_3);
+//DigitalIn xxx(PG_2);
+
+
+DigitalOut led1(LED1);
+DigitalOut led2(LED2);
+DigitalOut led3(LED3);
+int cntTick=0;
+int cntTickHora=0;
+int cntSinal=0;
+int cntBK=0;
+bool flagHorVerao=true,scaleIA=0,scaleIB=0,scaleIC=0;
+unsigned int energiaA = 0,energiaB=0,energiaC=0;
+//int vetorTensaoA[62];
+//int vetorTensaoB[62];
+//int vetorTensaoC[62];
+int vetorCorrenteA[62];
+int vetorCorrenteB[62];
+int vetorCorrenteC[62];
+
+
+int sinalVA[SIGNAL_LEN];
+int sinalVB[SIGNAL_LEN];
+int sinalVC[SIGNAL_LEN];
+int sinalIA[SIGNAL_LEN];
+int sinalIB[SIGNAL_LEN];
+int sinalIC[SIGNAL_LEN];
+
+//int rmsVA,rmsVB,rmsVC;
+int rmsIA,rmsIB,rmsIC;
+char serBuf[50],strTimeInterrupt[50],strTimeReturn[50],str485[300];
+char picCmd;
+
+bool EthernetOK=false,flagNoBreak=false;
+ time_t seconds;
+bool flagSend=false;
EthernetInterface eth;
-DigitalOut led1(LED1);
+TCPSocketServer server;
+TCPSocketConnection client;
+bool serverIsListening = false;
+
+DigitalOut sw(LED2);
+
+RawSerial serial(USBTX,USBRX);//(USBTX,USBRX); //tx,rx
+RawSerial serialPic(PD_5,PD_6);
+RawSerial serialRS485(PE_8,PE_7);
+
+int cnt=0;
+
+string httpHeader; // HTTP header
+string httpContent; // HTTP content
+const string HTTP_OK = "HTTP/1.0 200 OK";
+
+NTPClient ntp;
+
+
+void setClock()
+{
+
+ int res =ntp.setTime("0.uk.pool.ntp.org");
+ if ( res == 0)
+ {
+ time_t ctTime;
+ ctTime = time(NULL);
+ //serial.printf("Time is set to : %s \r\n", ctime(&ctTime));
+ int fusoBR= -10800;//-3*3600
+ if(flagHorVerao) fusoBR= -7200;
+ set_time(ctTime+ fusoBR);
+ char strtime[80];
+ time_t seconds;
+ seconds = time(NULL);
+ strftime(strtime, 20, "%D %H:%M:%S\n", localtime(&seconds));
+ //serial.printf("Hora:%s", strtime);
+ }
+ else
+ {
+ serial.printf("Error getting time \r\n");
+ }
+}
+
+
+void getSinal()
+{
+
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ getVoltagem=1;
+ sinalVA[j]=(int)1000*tensaoA.read();
+ sinalVB[j]=(int)1000*tensaoA.read();
+ sinalVC[j]=(int)1000*tensaoA.read();
+ getVoltagem=0;
+ sinalIA[j]=(int)1000*correnteA.read();
+ sinalIB[j]=(int)1000*correnteB.read();
+ sinalIC[j]=(int)1000*tensaoA.read();
+ wait_us(240); //4ciclos
+ }
+}
+void Rms()
+{
+
+ getSinal();
+ float somaVA=0,somaVB=0,somaVC=0,somaIA=0,somaIB=0,somaIC=0;
+ float dcVA,dcVB,dcVC,dcIA,dcIB,dcIC;
+ //DC
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ //somaVA = somaVA + sinalVA[j];
+ //somaVB = somaVB + sinalVB[j];
+ //somaVC = somaVC + sinalVC[j];
+ somaIA = somaIA + sinalIA[j];
+ somaIB = somaIB + sinalIB[j];
+ somaIC = somaIC + sinalIC[j];
+ }
+ //dcVA = somaVA/SIGNAL_LEN;
+ //dcVB = somaVB/SIGNAL_LEN;
+ //dcVC = somaVC/SIGNAL_LEN;
+ dcIA = somaIA/SIGNAL_LEN;
+ dcIB = somaIB/SIGNAL_LEN;
+ dcIC = somaIC/SIGNAL_LEN;
+ //serial.printf("\ndcIA = %f dcIB = %f",dcIA,dcIB);
+ somaVA=somaVB=somaVC=somaIA=somaIB=somaIC=0;
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ //somaVA = somaVA + ((sinalVA[j]-dcVA) * (sinalVA[j]-dcVA));
+ //somaVB = somaVB + ((sinalVB[j]-dcVB) * (sinalVB[j]-dcVB));
+ //somaVC = somaVC + ((sinalVC[j]-dcVC) * (sinalVC[j]-dcVC));
+ somaIA = somaIA + ((sinalIA[j]-dcIA) * (sinalIA[j]-dcIA));
+ somaIB = somaIB + ((sinalIB[j]-dcIB) * (sinalIB[j]-dcIB));
+ somaIC = somaIC + ((sinalIC[j]-dcIC) * (sinalIC[j]-dcIC));
+ }
+ //serial.printf("\nsomaIA = %f somaIB = %f",somaIA,somaIB);
+ //rmsVA = (int)sqrt(somaVA / SIGNAL_LEN);
+ //rmsVB = (int)sqrt(somaVB / SIGNAL_LEN);
+ //rmsVC = (int)sqrt(somaVC / SIGNAL_LEN);
+ scaleIA=scaleIB=scaleIC=0;
+ rmsIA = (int)sqrt(somaIA / SIGNAL_LEN);
+ if(rmsIA> 50)
+ scaleIA=1;
+ rmsIB = (int)sqrt(somaIB / SIGNAL_LEN);
+ if(rmsIB> 50)
+ scaleIB=1;
+ rmsIC = (int)sqrt(somaIC / SIGNAL_LEN);
+ if(rmsIC> 50)
+ scaleIC=1;
+ //serial.printf("\nrmsIA = %d rmsIB = %d",rmsIA,rmsIB);
+
+}
+void TickTensaoCorrente()
+{
+ led2=!led2;
+
+ Rms();
+ //if(scaleIA||scaleIB||scaleIC)
+ // Rms();
+ if(rmsIA-4<2)rmsIA=4;
+ if(rmsIB-4<2)rmsIB=4;
+ if(rmsIC-4<2)rmsIC=4;
+ energiaA += rmsIA-4;
+ energiaB += rmsIB-4;
+ energiaC += rmsIC-4;
+
+ //vetorTensaoA[cntTick]=rmsVA;
+ //vetorTensaoB[cntTick]=rmsVB;
+ //vetorTensaoC[cntTick]=rmsVC;
+ vetorCorrenteA[cntTick]=rmsIA-4;
+ vetorCorrenteB[cntTick]=rmsIB-4;
+ vetorCorrenteC[cntTick]=rmsIC-4;
+
+ cntTick++;
+ cntTickHora++;
+ if(cntTick>61) cntTick=0; //ERRO
+
+
+
+}
+
+int sendData()
+{
+ char str[7000]=""; //A conta tem que ser certa!!!
+ TCPSocketConnection socket;
+ while (socket.connect(SERVER_ADDRESS, SERVER_PORT) < 0)
+ {
+ serial.printf("Unable to connect to (%s) on port (%d)\n", SERVER_ADDRESS, SERVER_PORT);
+ wait(1);
+ return -1;
+ }
+ time_t ctTime;
+ ctTime = time(NULL);
+ sprintf(str,"%d;%s;",SERIAL,ctime(&ctTime));
+
+ /*strcat(str,"VA;"); //Nao precisa enviar a tensao pois e' quase cte a cada 5s
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoA[i]);//tensao cada 5s
+
+ strcat(str,"VB;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoB[i]);//tensao cada 5s
+
+ strcat(str,"VC;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoC[i]);//tensao cada 5s
+ */
+ // strcat(str,"E");
+ sprintf(str,"%s%10d%10d%10d",str,energiaA,energiaB,energiaC);
+
+
+ strcat(str,"IA");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d",str,vetorCorrenteA[i]);//correntecada 10s
+
+ strcat(str,"IB");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d",str,vetorCorrenteB[i]);//correntecada 10s
+
+ strcat(str,"IC");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d",str,vetorCorrenteC[i]);//correntecada 10s
+
+ //--------------
+
+ getSinal();
+ sprintf(str,"%sSVA",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalVA[j]);//sinal tensao
+
+ sprintf(str,"%sSVB",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalVB[j]);//sinal tensao
+
+ sprintf(str,"%sSVC",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalVC[j]);//sinal tensao
+
+ //-----------------
+ sprintf(str,"%sSIA",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalIA[j]);
+
+ sprintf(str,"%sSIB",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalIB[j]);
+
+ sprintf(str,"%sSIC",str);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ sprintf(str,"%s%03d",str,sinalIC[j]);
+
+
+ sprintf(str,"%sRS485%s$\0",str,str485);
+
+ int ret = socket.send(str, sizeof(str) - 1);
+ serial.printf("Socket send n: %d\n",ret);
+ char buf[256];
+ int n = socket.receive(buf, 256);
+ buf[n] = '\0';
+ serial.printf("Received % d message from server: '%s'\n",n, buf);
+ socket.close();
+ if(buf[0]=='1')
+ STOPEMAIL=false;
+ else
+ STOPEMAIL = true;
+
+ if(n>=1)
+ return 0;
+ else
+ return -1;
+
+}
+int sendNoBreak()
+{
+ TCPSocketConnection socket;
+ while (socket.connect(SERVER_ADDRESS, SERVER_PORT) < 0)
+ {
+ serial.printf("Unable to connect to (%s) on port (%d)\n", SERVER_ADDRESS, SERVER_PORT);
+ wait(1);
+ return -1;
+ }
+ char str[256];
+
+ sprintf(str,"%d;\nQueda de Energia: %s\nRetorno de Energia: %s$",SERIAL,strTimeInterrupt,strTimeReturn);
+ socket.send(str, sizeof(str) - 1);
+
+ char buf[256];
+ int n = socket.receive(buf, 256);
+ buf[n] = '\0';
+ serial.printf("Received % d message from server: '%s'\n",n, buf);
+ socket.close();
+ if(buf[0]=='1')
+ STOPEMAIL=false;
+ else
+ STOPEMAIL = true;
+
+ if(n>=1)
+ {
+ flagSendNoBreak = true;
+ return 0;
+ }
+ else
+ return -1;
+
+}
+int sendEmail()
+{
+ /*SimpleSMTPClient smtp;
+ int ret;
+ char str[36560];
+ smtp.setFromAddress(FROM_ADDRESS);
+ smtp.setToAddress(TO_ADDRESS);
+
+ smtp.setMessage(SUBJECT,"Mensagen enviada por e-mail\n");
+
+ time_t ctTime;
+ ctTime = time(NULL);
+ sprintf(str,"Energy Smart Meter - Serial A1%04d.\nHora da placa: %s",SERIAL,ctime(&ctTime));
+ smtp.addMessage(str);
+ ret = smtp.sendmail(SERVER, USER, PWD, DOMAIN,PORT,SMTP_AUTH_LOGIN);
+ strcpy(str,"VA;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoA[i]);//tensao cada 5s
+ smtp.appendMessage(str);
+ strcpy(str,"VB;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoB[i]);//tensao cada 5s
+ smtp.appendMessage(str);
+ strcpy(str,"VC;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorTensaoC[i]);//tensao cada 5s
+ smtp.appendMessage(str);
+
+ strcpy(str,"IA;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorCorrenteA[i]);//corrente cada 5s
+ smtp.appendMessage(str);
+
+ strcpy(str,"IB;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorCorrenteB[i]);//corrente cada 5s
+ smtp.appendMessage(str);
+
+ strcpy(str,"IC;");
+ for(int i=0;i<60;i++)
+ sprintf(str,"%s%03d;",str,vetorCorrenteC[i]);//corrente cada 5s
+ smtp.appendMessage(str);
+
+
+
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SVA%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalVA[i][j]);//sinal tensao
+
+ }
+ smtp.appendMessage(str);
+ }
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SVB%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalVB[i][j]);//sinal tensao
+
+ }
+ smtp.appendMessage(str);
+ }
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SVC%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalVC[i][j]);//sinal tensao
+
+ }
+ smtp.appendMessage(str);
+ }
+ //-----------------
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SIA%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalIA[i][j]);//sinal corrente
+
+ }
+ smtp.appendMessage(str);
+ }
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SIB%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalIB[i][j]);//sinal corrente
+
+ }
+ smtp.appendMessage(str);
+ }
+ for(int i=0;i<5;i++)
+ {
+ sprintf(str,"SIC%d;",i);
+ for(int j=0;j<SIGNAL_LEN;j++)
+ {
+ sprintf(str,"%s%03d;",str,sinalIC[i][j]);//sinal corrente
+
+ }
+ smtp.appendMessage(str);
+ }
+
+
+ smtp.endMessage();
+ if (ret)
+ {
+ serial.printf("E-mail Transmission Error\r\n");
+ return -1;
+ }
+ else
+ {
+ serial.printf("E-mail Transmission OK\r\n");
+ return 0;
+ }*/
+}
+
+void SerialPicReceiver()
+{
+ int i=0;
+ char c;
+ led1=!led1;
+ while(1)
+ {
+ //if(!serialPic.readable())
+ // break;
+ c=serialPic.getc();
+ serBuf[i++] = c;
+ if(c=='\n'||i>49) break;
+
+ }
+
+
+}
+void SerialRS485Receiver()
+{
+ int i=0;
+ char c;
+ led1=!led1;
+ while(1)
+ {
+ //if(!serialPic.readable())
+ // break;
+ c=serialRS485.getc();
+ str485[i++] = c;
+ if(c=='\n'||i>258) break;
+
+ }
+
+
+}
+void BackUpRam()
+{
+ serial.printf("BackUpRam:%d",++cntBK);
+}
int main()
{
- NTPClient ntp;
- char buff[64];
- printf("\n\n*** Ethernet Demo uses NTP to set the clock ***\r\n");
+ serial.baud(115200);
+ serialPic.baud(9600);
+
+ led2=1;
+
+
+
+
+ serial.printf("*** ENERGY SMART METER ***\r\n");
+ serial.printf("Serial: %04d\n",SERIAL);
if(eth.init()!=0) //for DHCP Server
{
//if(eth.init(IP,MASK,GATEWAY)!=0) { //for Static IP Address
- printf("EthernetInterface Initialize Error \r\n");
+ serial.printf("EthernetInterface Initialize Error \r\n");
+ led3=1;
+ wait(2);
+ NVIC_SystemReset();
- while (1)
- {
- }
}
+
if(eth.connect()!=0)
{
- printf("EthernetInterface Connect Error \r\n");
- while (1)
- {
- }
+ serial.printf("EthernetInterface Connect Error \r\n");
+ led3=1;
+ wait(2);
+ NVIC_SystemReset();
+
+
}
- printf("IP Address is %s\r\n", eth.getIPAddress());
- printf("NetMask is %s\r\n", eth.getNetworkMask());
- printf("Gateway Address is %s\r\n", eth.getGateway());
- printf("Ethernet Setup OK\r\n");
- printf("Getting time, 10s timeout. \r\n");
-
- if (ntp.setTime("0.uk.pool.ntp.org") == 0)
+ tickerTensaoCorrente.attach(&TickTensaoCorrente,10);//cada 10s
+
+
+ serial.printf("IP Address is %s\n", eth.getIPAddress());
+ // serial.printf("NetMask is %s\n", eth.getNetworkMask());
+ // serial.printf("Gateway Address is %s\n", eth.getGateway());
+ //serial.printf("Ethernet Setup OK\n");
+ //serial.printf("Getting time, 10s timeout. \r\n");
+ setClock();
+ int flagE=false,flagD=false;
+
+
+//----------
+ serialPic.attach(&SerialPicReceiver);
+ serialPic.printf("*");//ler eeprom
+ wait_ms(500);
+ //serial.printf("SB: %s\n",serBuf);
+ char aux[11];
+ aux[10]=0;
+ for(int i=0;i<10;i++)
+ aux[i] = serBuf[i];
+ energiaA = atoi(aux);
+ serial.printf("EnergiaA: %d\n",energiaA);
+ for(int i=0;i<10;i++)
+ aux[i] = serBuf[i+10];
+ energiaB = atoi(aux);
+ serial.printf("EnergiaB: %d\n",energiaB);
+ for(int i=0;i<10;i++)
+ aux[i] = serBuf[i+20];
+ energiaC = atoi(aux);
+ serial.printf("EnergiaC: %d\n",energiaC);
+
+
+ for(int i=0;i<8;i++)
+ aux[i] = serBuf[i+30];
+ aux[8]=0;
+ sprintf(strTimeInterrupt,"%s ",aux);
+
+ for(int i=0;i<2;i++)
+ aux[i] = serBuf[i+38];
+ aux[2] =0;
+ sprintf(strTimeInterrupt,"%s%s:",strTimeInterrupt,aux);
+ for(int i=0;i<2;i++)
+ aux[i] = serBuf[i+40];
+ aux[2] =0;
+ sprintf(strTimeInterrupt,"%s%s",strTimeInterrupt,aux);
+ serial.printf("Data Interrupcao de energia:\t%s\n",strTimeInterrupt);
+ //char strtime[30];
+ time_t seconds;
+ seconds = time(NULL);
+ strftime(strTimeReturn, 20, "%D %H:%M\n", localtime(&seconds));
+ serial.printf("Data Retorno de energia:\t%s\n", strTimeReturn);
+ flagSendNoBreak=false;
+ sendNoBreak();
+//------
+ serialRS485.attach(&SerialRS485Receiver);
+
+ sprintf(str485,"%s","12345678901234567890123456789012345678901234567890");
+ while(1)
{
- time_t ctTime;
- ctTime = time(NULL);
- printf("Time is set to : %s \r\n", ctime(&ctTime));
+ if(noBreak==0 &&flagNoBreak==false)
+ {
+ serial.printf("Tensao Baixa\n");
+ char strtime[14];
+ time_t seconds;
+ seconds = time(NULL);
+ strftime(strtime, 14, "%D%H%M", localtime(&seconds));
+
+ serialPic.printf("%10d%10d%10d%s#",energiaA,energiaB,energiaC,strtime);
+ flagNoBreak=true;
+ led3= 1;
+ }
+
+
+ if(cntTick>=60) //60 = 10minutos
+ {
+
+ tickerTensaoCorrente.detach();//??????????????????
+ cntTick=0;
+
+ serial.printf("Send data\n");
+ //WatchdogRefresh();
+ picWatchDog =0;
+ flagD = sendData();
+ picWatchDog =1;
+ if(flagD!=0) //0 = OK
+ {
+ wait(0.1);
+
+ picWatchDog =0;
+ flagD = sendData();
+ picWatchDog =1;
+ if(flagD!=0)
+ {
+
+ if(!STOPEMAIL)//debug
+ {
+ picWatchDog =0;
+ flagE = sendEmail();
+ picWatchDog =1;
+ if(flagE!=0)
+ {
+
+ picWatchDog =0;
+ flagE = sendEmail();
+ picWatchDog =1;
+ }
+ }
+ }
+ }
+ if(flagD !=0 && flagE!=0)
+ BackUpRam();
+ tickerTensaoCorrente.attach(&TickTensaoCorrente,10);//cada 5s
+
+
+ }
+ if(cntTickHora>720)//1hora
+ {
+ cntTickHora=0;
+ if(flagSendNoBreak==false)
+ sendNoBreak();
+ setClock();
+ }
+ // if(flagD==0)
+ // led1=!led1;
+ wait_ms(50);
}
- else
- {
- printf("Error getting time \r\n");
- }
+
- printf("end of programm\r\n");
- while (true) {
- led1 = !led1;
- Thread::wait(500);
- }
}