Emma / PB_emma_controller_mbed_src

emma controller code in production board v1

Dependencies:   ADE7758_v1 Crypto DHT11 MQTT MbedJSONValueEmma SDFileSystem TFT_ILI9341 SWSPI SetRTC TFT_fonts Touch W5500Interface mbed-rtos mbed-src SoftSerial

Fork of emma_controller_energy by Emma

emmaCode.cpp@46:86a0c2133130, 2015-08-26 (annotated)

Committer:
arsenalist
Date:
Wed Aug 26 12:30:52 2015 +0000
Revision:
46:86a0c2133130
Parent:
45:2406c2b6995a
Child:
47:97eadcb478b2
Add panelEnergy, panelEnvironment, nodeTemp to emmaModeOperation ETH.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
arsenalist 0:f4e449fa34d7 1 #include "emmaCode.h"
arsenalist 0:f4e449fa34d7 2
arsenalist 0:f4e449fa34d7 3 //init debug port
arsenalist 0:f4e449fa34d7 4 Serial DBG(PA_9, PA_10); //tx, rx
arsenalist 0:f4e449fa34d7 5
arsenalist 0:f4e449fa34d7 6 //init wifi port
arsenalist 0:f4e449fa34d7 7 Serial _ESP(PA_2, PA_3); //tx, rx
arsenalist 8:51a0ca9079ca 8 //init espduino - without ch_pd pin
arsenalist 8:51a0ca9079ca 9 ESP esp(&_ESP, &DBG, ESP_BAUD);
arsenalist 0:f4e449fa34d7 10 //init wifi mqtt
arsenalist 27:562a95c120cc 11 //ESPMQTT mqtt(&esp);
arsenalist 0:f4e449fa34d7 12 //init wifi rest
arsenalist 0:f4e449fa34d7 13 REST rest(&esp);
arsenalist 0:f4e449fa34d7 14
arsenalist 0:f4e449fa34d7 15 //init eth port
arsenalist 0:f4e449fa34d7 16 SPI spi(PB_15, PB_14, PB_13); //mosi, miso, sck
arsenalist 44:c1d11c491237 17 EthernetInterface eth(&spi, PB_12, PC_6); //spi, cs, reset
arsenalist 44:c1d11c491237 18 //MQTTEthernet ipstack(&spi, PB_12, PC_6); //spi, cs, reset
arsenalist 37:93f196daf5cf 19 //MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
arsenalist 45:2406c2b6995a 20 TCPSocketConnection sock;
arsenalist 0:f4e449fa34d7 21
arsenalist 0:f4e449fa34d7 22 //init sd card
arsenalist 8:51a0ca9079ca 23 SDFileSystem sd(PA_7, PA_6, PA_5, PB_3, "sd"); //mosi, miso, sck, cs
arsenalist 0:f4e449fa34d7 24
arsenalist 8:51a0ca9079ca 25 //init ade7758 - without cs pin
arsenalist 14:8287f0f5d987 26 ADE7758 ADE(PB_6, PB_4, PB_5, PB_7); //mosi, miso, sck, irq
arsenalist 0:f4e449fa34d7 27
arsenalist 12:96f637ed37f9 28 //init tft lcd
arsenalist 12:96f637ed37f9 29 SPI_TFT_ILI9341 TFT(PA_7, PA_6, PA_5, PA_4, PC_5, PC_4,"TFT"); //mosi, miso, sclk, cs, reset, dc
arsenalist 12:96f637ed37f9 30 //init touch screen - without cs pin
arsenalist 12:96f637ed37f9 31 TouchScreenADS7843 TP(PB_10, PB_0, PB_1, PB_2, &TFT); //mosi, miso, sclk, irq, tft
arsenalist 12:96f637ed37f9 32
arsenalist 21:33bd8b82560f 33 //init dht sensor
arsenalist 21:33bd8b82560f 34 DHT11 d(PD_2);
arsenalist 21:33bd8b82560f 35
arsenalist 0:f4e449fa34d7 36 //emma settings
arsenalist 0:f4e449fa34d7 37 string emmaUID;
arsenalist 4:76ab12e2f8a3 38 string hmac;
arsenalist 38:e44f35f8129d 39 string appNAME;
arsenalist 38:e44f35f8129d 40 string mqttDOMAIN;
arsenalist 38:e44f35f8129d 41 string mqttKEY;
arsenalist 38:e44f35f8129d 42 string mqttSECRET;
arsenalist 38:e44f35f8129d 43 string mqttSERVER;
arsenalist 38:e44f35f8129d 44 string mqttPORT;
arsenalist 38:e44f35f8129d 45 string restSERVER;
arsenalist 38:e44f35f8129d 46 string restPORT;
arsenalist 0:f4e449fa34d7 47 string wifiSSID;
arsenalist 0:f4e449fa34d7 48 string wifiPASS;
arsenalist 0:f4e449fa34d7 49 string gprsAPN;
arsenalist 0:f4e449fa34d7 50 string proxySERVER;
arsenalist 0:f4e449fa34d7 51 string proxyPORT;
arsenalist 0:f4e449fa34d7 52 string proxyAUTH;
arsenalist 0:f4e449fa34d7 53
arsenalist 4:76ab12e2f8a3 54 //nodes settings
arsenalist 4:76ab12e2f8a3 55 class NODES {
arsenalist 4:76ab12e2f8a3 56 public:
arsenalist 4:76ab12e2f8a3 57 REST *restConn;
arsenalist 4:76ab12e2f8a3 58 NODES(REST *r);
arsenalist 40:77bd44f57ad3 59 int type;
arsenalist 4:76ab12e2f8a3 60 string macAddr;
arsenalist 4:76ab12e2f8a3 61 string ipAddr;
arsenalist 4:76ab12e2f8a3 62 };
arsenalist 4:76ab12e2f8a3 63 NODES::NODES(REST *r) {
arsenalist 4:76ab12e2f8a3 64 restConn = r;
arsenalist 4:76ab12e2f8a3 65 }
arsenalist 4:76ab12e2f8a3 66 REST restObj[NODES_MAX] = {REST(&esp),REST(&esp),REST(&esp),REST(&esp),REST(&esp)};
arsenalist 4:76ab12e2f8a3 67 NODES nodes[NODES_MAX] = {NODES(&restObj[0]),NODES(&restObj[1]),NODES(&restObj[2]),NODES(&restObj[3]),NODES(&restObj[4])};
arsenalist 4:76ab12e2f8a3 68
arsenalist 12:96f637ed37f9 69 //mode box class for main menu
arsenalist 12:96f637ed37f9 70 class modeBox {
arsenalist 12:96f637ed37f9 71 public:
arsenalist 12:96f637ed37f9 72 int xTL; //TopLeft
arsenalist 12:96f637ed37f9 73 int yTL;
arsenalist 12:96f637ed37f9 74 int xBR; //BottomRight
arsenalist 12:96f637ed37f9 75 int yBR;
arsenalist 29:4d94a03d38e0 76 string text;
arsenalist 29:4d94a03d38e0 77 string name;
arsenalist 12:96f637ed37f9 78 };
arsenalist 12:96f637ed37f9 79
arsenalist 0:f4e449fa34d7 80 //ade7758 variables
arsenalist 25:36c6a5db50ed 81 uint32_t AWattHrValue, BWattHrValue, CWattHrValue;
arsenalist 25:36c6a5db50ed 82 uint32_t AVAHrValue, BVAHrValue, CVAHrValue;
arsenalist 19:7e3e9332f719 83 uint32_t AWattHrSum = 0;
arsenalist 19:7e3e9332f719 84 uint32_t BWattHrSum = 0;
arsenalist 19:7e3e9332f719 85 uint32_t CWattHrSum = 0;
arsenalist 0:f4e449fa34d7 86 float AWattHr, BWattHr, CWattHr;
arsenalist 4:76ab12e2f8a3 87 float AVrms, BVrms, CVrms;
arsenalist 4:76ab12e2f8a3 88 float AIrms, BIrms, CIrms;
arsenalist 4:76ab12e2f8a3 89 float AWatt, BWatt, CWatt;
arsenalist 4:76ab12e2f8a3 90 float XWattHr,XVrms,XWatt;
arsenalist 0:f4e449fa34d7 91
arsenalist 0:f4e449fa34d7 92 //variables
arsenalist 0:f4e449fa34d7 93 bool ethAvailable = false;
arsenalist 0:f4e449fa34d7 94 bool wifiAvailable = false;
arsenalist 0:f4e449fa34d7 95 bool gprsAvailable = false;
arsenalist 0:f4e449fa34d7 96 bool ethConnected = false;
arsenalist 0:f4e449fa34d7 97 bool wifiConnected = false;
arsenalist 9:a58c04da4476 98 bool gprsConnected = false;
arsenalist 0:f4e449fa34d7 99 bool useProxy = false;
arsenalist 0:f4e449fa34d7 100 bool newCommand = false;
arsenalist 37:93f196daf5cf 101 bool espFreeMemory = true; //for after bootup
arsenalist 27:562a95c120cc 102 bool espDHCPClientStart = false;
arsenalist 22:e18d361bf688 103 bool newEnergyData = false;
arsenalist 0:f4e449fa34d7 104 string globalCommand;
arsenalist 4:76ab12e2f8a3 105 string rxBuf;
arsenalist 27:562a95c120cc 106 string rxLog;
arsenalist 27:562a95c120cc 107 string rxLogA;
arsenalist 0:f4e449fa34d7 108
arsenalist 12:96f637ed37f9 109 /*start lcd and touch*/
arsenalist 12:96f637ed37f9 110 int emmaModeSelection(void) {
arsenalist 12:96f637ed37f9 111 bool modeSelected = false;
arsenalist 12:96f637ed37f9 112 int md=0;
arsenalist 12:96f637ed37f9 113 int TPx;
arsenalist 12:96f637ed37f9 114 int TPy;
arsenalist 31:e2abded4d85f 115 Timer t;
arsenalist 12:96f637ed37f9 116
arsenalist 12:96f637ed37f9 117 TFT.background(Black);
arsenalist 12:96f637ed37f9 118 TFT.foreground(White);
arsenalist 12:96f637ed37f9 119
arsenalist 12:96f637ed37f9 120 TFT.set_font((unsigned char*) Arial12x12);
arsenalist 12:96f637ed37f9 121 TFT.set_orientation(1);
arsenalist 12:96f637ed37f9 122 TFT.cls();
arsenalist 12:96f637ed37f9 123 TFT.locate(0,0);
arsenalist 12:96f637ed37f9 124 TFT.printf("Hello, I'm Emma!");
arsenalist 13:e8adfe305dbc 125 wait(2);
arsenalist 12:96f637ed37f9 126 TFT.cls();
arsenalist 12:96f637ed37f9 127
arsenalist 12:96f637ed37f9 128 Matrix matrix;
arsenalist 12:96f637ed37f9 129 Coordinate ScreenSample[3];
arsenalist 12:96f637ed37f9 130
arsenalist 44:c1d11c491237 131 //lcd type 1
arsenalist 44:c1d11c491237 132 //matrix.An = 580;
arsenalist 44:c1d11c491237 133 //matrix.Bn = 75980;
arsenalist 44:c1d11c491237 134 //matrix.Cn = -3410580;
arsenalist 44:c1d11c491237 135 //matrix.Dn = 57855;
arsenalist 44:c1d11c491237 136 //matrix.En = -2465;
arsenalist 44:c1d11c491237 137 //matrix.Fn = -3483515;
arsenalist 44:c1d11c491237 138 //matrix.Divider = 209144;
arsenalist 44:c1d11c491237 139
arsenalist 44:c1d11c491237 140 //ScreenSample[0].x = 230;
arsenalist 44:c1d11c491237 141 //ScreenSample[0].y = 167;
arsenalist 44:c1d11c491237 142 //ScreenSample[1].x = 754;
arsenalist 44:c1d11c491237 143 //ScreenSample[1].y = 163;
arsenalist 44:c1d11c491237 144 //ScreenSample[2].x = 771;
arsenalist 44:c1d11c491237 145 //ScreenSample[2].y = 562;
arsenalist 12:96f637ed37f9 146
arsenalist 44:c1d11c491237 147 //lcd type 2
arsenalist 44:c1d11c491237 148 matrix.An = 1305;
arsenalist 44:c1d11c491237 149 matrix.Bn = -77430;
arsenalist 44:c1d11c491237 150 matrix.Cn = 75296670;
arsenalist 44:c1d11c491237 151 matrix.Dn = -57275;
arsenalist 44:c1d11c491237 152 matrix.En = -1160;
arsenalist 44:c1d11c491237 153 matrix.Fn = 55285220;
arsenalist 44:c1d11c491237 154 matrix.Divider = 211002;
arsenalist 44:c1d11c491237 155
arsenalist 44:c1d11c491237 156 ScreenSample[0].x = 782;
arsenalist 44:c1d11c491237 157 ScreenSample[0].y = 863;
arsenalist 44:c1d11c491237 158 ScreenSample[1].x = 248;
arsenalist 44:c1d11c491237 159 ScreenSample[1].y = 854;
arsenalist 44:c1d11c491237 160 ScreenSample[2].x = 256;
arsenalist 44:c1d11c491237 161 ScreenSample[2].y = 459;
arsenalist 12:96f637ed37f9 162
arsenalist 12:96f637ed37f9 163 TP.SetCalibration(&matrix, &ScreenSample[0]);
arsenalist 12:96f637ed37f9 164
arsenalist 12:96f637ed37f9 165 //draw border
arsenalist 12:96f637ed37f9 166 TFT.line(15,15,310,15,Orange);
arsenalist 12:96f637ed37f9 167 TFT.line(310,15,310,250,Orange);
arsenalist 12:96f637ed37f9 168 TFT.line(310,250,15,250,Orange);
arsenalist 12:96f637ed37f9 169 TFT.line(15,250,15,15,Orange);
arsenalist 12:96f637ed37f9 170
arsenalist 12:96f637ed37f9 171 //init main menu
arsenalist 12:96f637ed37f9 172 modeBox menu[6];
arsenalist 12:96f637ed37f9 173
arsenalist 12:96f637ed37f9 174 //wifi config mode
arsenalist 12:96f637ed37f9 175 menu[MODE_WIFI_CONFIG].xTL = 25;
arsenalist 12:96f637ed37f9 176 menu[MODE_WIFI_CONFIG].yTL = 25;
arsenalist 12:96f637ed37f9 177 menu[MODE_WIFI_CONFIG].xBR = 110;
arsenalist 12:96f637ed37f9 178 menu[MODE_WIFI_CONFIG].yBR = 90;
arsenalist 29:4d94a03d38e0 179 menu[MODE_WIFI_CONFIG].text = "1.wifi config";
arsenalist 29:4d94a03d38e0 180 menu[MODE_WIFI_CONFIG].name = "wifi config";
arsenalist 12:96f637ed37f9 181
arsenalist 12:96f637ed37f9 182 //setting mode
arsenalist 29:4d94a03d38e0 183 menu[MODE_SETTINGS].xTL = 25;
arsenalist 29:4d94a03d38e0 184 menu[MODE_SETTINGS].yTL = 100;
arsenalist 29:4d94a03d38e0 185 menu[MODE_SETTINGS].xBR = 110;
arsenalist 29:4d94a03d38e0 186 menu[MODE_SETTINGS].yBR = 165;
arsenalist 29:4d94a03d38e0 187 menu[MODE_SETTINGS].text = "2.settings ";
arsenalist 29:4d94a03d38e0 188 menu[MODE_SETTINGS].name = "settings";
arsenalist 12:96f637ed37f9 189
arsenalist 12:96f637ed37f9 190 //register mode
arsenalist 29:4d94a03d38e0 191 menu[MODE_REGISTER].xTL = 120;
arsenalist 29:4d94a03d38e0 192 menu[MODE_REGISTER].yTL = 25;
arsenalist 29:4d94a03d38e0 193 menu[MODE_REGISTER].xBR = 205;
arsenalist 29:4d94a03d38e0 194 menu[MODE_REGISTER].yBR = 90;
arsenalist 29:4d94a03d38e0 195 menu[MODE_REGISTER].text = "3.register ";
arsenalist 29:4d94a03d38e0 196 menu[MODE_REGISTER].name = "register";
arsenalist 12:96f637ed37f9 197
arsenalist 12:96f637ed37f9 198 //operational mode
arsenalist 12:96f637ed37f9 199 menu[MODE_OPERATION].xTL = 120;
arsenalist 12:96f637ed37f9 200 menu[MODE_OPERATION].yTL = 100;
arsenalist 12:96f637ed37f9 201 menu[MODE_OPERATION].xBR = 205;
arsenalist 12:96f637ed37f9 202 menu[MODE_OPERATION].yBR = 165;
arsenalist 29:4d94a03d38e0 203 menu[MODE_OPERATION].text = "4.operation ";
arsenalist 29:4d94a03d38e0 204 menu[MODE_OPERATION].name = "operation";
arsenalist 12:96f637ed37f9 205
arsenalist 12:96f637ed37f9 206 //firmware download mode
arsenalist 12:96f637ed37f9 207 menu[MODE_FIRMWARE_DOWNLOAD].xTL = 215;
arsenalist 12:96f637ed37f9 208 menu[MODE_FIRMWARE_DOWNLOAD].yTL = 25;
arsenalist 12:96f637ed37f9 209 menu[MODE_FIRMWARE_DOWNLOAD].xBR = 300;
arsenalist 12:96f637ed37f9 210 menu[MODE_FIRMWARE_DOWNLOAD].yBR = 90;
arsenalist 29:4d94a03d38e0 211 menu[MODE_FIRMWARE_DOWNLOAD].text = "5.fw dwld ";
arsenalist 29:4d94a03d38e0 212 menu[MODE_FIRMWARE_DOWNLOAD].name = "fw dwld";
arsenalist 12:96f637ed37f9 213
arsenalist 12:96f637ed37f9 214 //reserved mode
arsenalist 44:c1d11c491237 215 menu[MODE_RESERVED].xTL = 215;
arsenalist 44:c1d11c491237 216 menu[MODE_RESERVED].yTL = 100;
arsenalist 44:c1d11c491237 217 menu[MODE_RESERVED].xBR = 300;
arsenalist 44:c1d11c491237 218 menu[MODE_RESERVED].yBR = 165;
arsenalist 44:c1d11c491237 219 menu[MODE_RESERVED].text = "6.reserved ";
arsenalist 44:c1d11c491237 220 menu[MODE_RESERVED].name = "reserved";
arsenalist 12:96f637ed37f9 221
arsenalist 17:b3ced0e67916 222 //draw main menu
arsenalist 12:96f637ed37f9 223 for(int i=0; i<6; i++) {
arsenalist 12:96f637ed37f9 224 TFT.fillrect(menu[i].xTL,menu[i].yTL,menu[i].xBR,menu[i].yBR,Orange);
arsenalist 12:96f637ed37f9 225 }
arsenalist 12:96f637ed37f9 226
arsenalist 17:b3ced0e67916 227 //add text to main menu
arsenalist 17:b3ced0e67916 228 for(int i=0; i<6; i++) {
arsenalist 17:b3ced0e67916 229 TFT.locate(menu[i].xTL,menu[i].yTL);
arsenalist 31:e2abded4d85f 230 TFT.printf("%s",menu[i].text.c_str());
arsenalist 31:e2abded4d85f 231 }
arsenalist 31:e2abded4d85f 232
arsenalist 31:e2abded4d85f 233 //read emma settings
arsenalist 31:e2abded4d85f 234 emmaReadSettings();
arsenalist 31:e2abded4d85f 235
arsenalist 38:e44f35f8129d 236 //mqttDOMAIN is not empty -> has been registered
arsenalist 38:e44f35f8129d 237 if(!mqttDOMAIN.empty()) {
arsenalist 31:e2abded4d85f 238 TFT.locate(25,170);
arsenalist 31:e2abded4d85f 239 TFT.printf(" auto select enabled");
arsenalist 31:e2abded4d85f 240 t.start();
arsenalist 17:b3ced0e67916 241 }
arsenalist 17:b3ced0e67916 242
arsenalist 12:96f637ed37f9 243 while(!modeSelected) {
arsenalist 12:96f637ed37f9 244 if(!TP._tp_irq) {
arsenalist 12:96f637ed37f9 245 if(TP.Read_Ads7843()) {
arsenalist 12:96f637ed37f9 246 TP.getDisplayPoint();
arsenalist 12:96f637ed37f9 247 TPx = TP.display.x;
arsenalist 12:96f637ed37f9 248 TPy = TP.display.y;
arsenalist 12:96f637ed37f9 249 TP.TP_DrawPoint(TPx,TPy, Blue);
arsenalist 12:96f637ed37f9 250
arsenalist 12:96f637ed37f9 251 for(int i=0; i<6; i++) {
arsenalist 12:96f637ed37f9 252 if((menu[i].xTL < TPx && TPx < menu[i].xBR) && (menu[i].yTL < TPy && TPy < menu[i].yBR)) {
arsenalist 12:96f637ed37f9 253 md = i;
arsenalist 12:96f637ed37f9 254 modeSelected = true;
arsenalist 12:96f637ed37f9 255 }
arsenalist 12:96f637ed37f9 256 }
arsenalist 12:96f637ed37f9 257 }
arsenalist 31:e2abded4d85f 258 }
arsenalist 31:e2abded4d85f 259
arsenalist 31:e2abded4d85f 260 //auto select (to emmaModeOperation) after some times
arsenalist 38:e44f35f8129d 261 if(!mqttDOMAIN.empty()) {
arsenalist 31:e2abded4d85f 262 if(t.read()>20) {
arsenalist 31:e2abded4d85f 263 md = MODE_OPERATION;
arsenalist 31:e2abded4d85f 264 modeSelected = true;
arsenalist 31:e2abded4d85f 265 t.stop();
arsenalist 31:e2abded4d85f 266 t.reset();
arsenalist 31:e2abded4d85f 267 }
arsenalist 31:e2abded4d85f 268 }
arsenalist 31:e2abded4d85f 269
arsenalist 12:96f637ed37f9 270 }
arsenalist 12:96f637ed37f9 271
arsenalist 12:96f637ed37f9 272 TFT.locate(25,170);
arsenalist 12:96f637ed37f9 273 TFT.printf(" ");
arsenalist 12:96f637ed37f9 274 TFT.locate(25,170);
arsenalist 29:4d94a03d38e0 275 TFT.printf("mode: %s is selected",menu[md].name.c_str());
arsenalist 13:e8adfe305dbc 276 wait(2);
arsenalist 12:96f637ed37f9 277 TFT.cls();
arsenalist 12:96f637ed37f9 278
arsenalist 12:96f637ed37f9 279 return md;
arsenalist 12:96f637ed37f9 280 }
arsenalist 12:96f637ed37f9 281 /*end lcd and touch*/
arsenalist 12:96f637ed37f9 282
arsenalist 31:e2abded4d85f 283 /*start emma read settings*/
arsenalist 31:e2abded4d85f 284 void emmaReadSettings(void) {
arsenalist 4:76ab12e2f8a3 285 char s[64];
arsenalist 0:f4e449fa34d7 286 DBG.baud(19200);
arsenalist 31:e2abded4d85f 287 DBG.printf("\r\nemmaReadSettings\r\n");
arsenalist 0:f4e449fa34d7 288
arsenalist 0:f4e449fa34d7 289 //read settings
arsenalist 9:a58c04da4476 290 emmaUID = readSetting("emmaUID");
arsenalist 9:a58c04da4476 291 //emmaUID = "066eff575349896767073038";
arsenalist 0:f4e449fa34d7 292 DBG.printf("emmaUID:%s\r\n",emmaUID.c_str());
arsenalist 37:93f196daf5cf 293
arsenalist 4:76ab12e2f8a3 294 //calculate hmac
arsenalist 4:76ab12e2f8a3 295 for(int i=0; i<sizeof(s); i++) {
arsenalist 4:76ab12e2f8a3 296 s[i]=0; }
arsenalist 4:76ab12e2f8a3 297 sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist 4:76ab12e2f8a3 298 hmac = calculateMD5(s);
arsenalist 4:76ab12e2f8a3 299 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 37:93f196daf5cf 300
arsenalist 38:e44f35f8129d 301 appNAME = readSetting("appNAME");
arsenalist 38:e44f35f8129d 302 DBG.printf("appNAME:%s\r\n",appNAME.c_str());
arsenalist 38:e44f35f8129d 303
arsenalist 38:e44f35f8129d 304 mqttDOMAIN = readSetting("mqttDOMAIN");
arsenalist 38:e44f35f8129d 305 DBG.printf("mqttDOMAIN:%s\r\n",mqttDOMAIN.c_str());
arsenalist 38:e44f35f8129d 306 mqttKEY = readSetting("mqttKEY");
arsenalist 38:e44f35f8129d 307 DBG.printf("mqttKEY:%s\r\n",mqttKEY.c_str());
arsenalist 38:e44f35f8129d 308 mqttSECRET = readSetting("mqttSECRET");
arsenalist 38:e44f35f8129d 309 DBG.printf("mqttSECRET:%s\r\n",mqttSECRET.c_str());
arsenalist 38:e44f35f8129d 310 mqttSERVER = readSetting("mqttSERVER");
arsenalist 38:e44f35f8129d 311 DBG.printf("mqttSERVER:%s\r\n",mqttSERVER.c_str());
arsenalist 38:e44f35f8129d 312 mqttPORT = readSetting("mqttPORT");
arsenalist 38:e44f35f8129d 313 DBG.printf("mqttPORT:%s\r\n",mqttPORT.c_str());
arsenalist 38:e44f35f8129d 314
arsenalist 38:e44f35f8129d 315 restSERVER = readSetting("restSERVER");
arsenalist 38:e44f35f8129d 316 DBG.printf("restSERVER:%s\r\n",restSERVER.c_str());
arsenalist 38:e44f35f8129d 317 restPORT = readSetting("restPORT");
arsenalist 38:e44f35f8129d 318 DBG.printf("restPORT:%s\r\n",restPORT.c_str());
arsenalist 38:e44f35f8129d 319
arsenalist 9:a58c04da4476 320 proxySERVER = readSetting("proxySERVER");
arsenalist 0:f4e449fa34d7 321 DBG.printf("proxySERVER:%s\r\n",proxySERVER.c_str());
arsenalist 9:a58c04da4476 322 proxyPORT = readSetting("proxyPORT");
arsenalist 0:f4e449fa34d7 323 DBG.printf("proxyPORT:%s\r\n",proxyPORT.c_str());
arsenalist 9:a58c04da4476 324 proxyAUTH = readSetting("proxyAUTH");
arsenalist 0:f4e449fa34d7 325 DBG.printf("proxyAUTH:%s\r\n",proxyAUTH.c_str());
arsenalist 28:7561035e3df5 326 wifiSSID = readSetting("wifiSSID");
arsenalist 28:7561035e3df5 327 DBG.printf("wifiSSID:%s\r\n",wifiSSID.c_str());
arsenalist 28:7561035e3df5 328 wifiPASS = readSetting("wifiPASS");
arsenalist 28:7561035e3df5 329 DBG.printf("wifiPASS:%s\r\n",wifiPASS.c_str());
arsenalist 31:e2abded4d85f 330 }
arsenalist 31:e2abded4d85f 331 /*end emma read settings*/
arsenalist 31:e2abded4d85f 332
arsenalist 31:e2abded4d85f 333 /*start emma mode*/
arsenalist 31:e2abded4d85f 334 void emmaInit(int mode) {
arsenalist 31:e2abded4d85f 335 DBG.printf("\r\nemmaInit\r\n");
arsenalist 31:e2abded4d85f 336 DBG.printf("mode:%d\r\n",mode);
arsenalist 0:f4e449fa34d7 337
arsenalist 0:f4e449fa34d7 338 //check proxy
arsenalist 0:f4e449fa34d7 339 if(!proxySERVER.empty() && !proxyPORT.empty() && !proxyAUTH.empty()) {
arsenalist 0:f4e449fa34d7 340 useProxy = true;
arsenalist 0:f4e449fa34d7 341 } else {
arsenalist 0:f4e449fa34d7 342 useProxy = false;
arsenalist 0:f4e449fa34d7 343 }
arsenalist 0:f4e449fa34d7 344 //testing purpose
arsenalist 32:78633fb9b2a1 345 //useProxy = false;
arsenalist 0:f4e449fa34d7 346 DBG.printf("proxy:%d\r\n",useProxy);
arsenalist 0:f4e449fa34d7 347
arsenalist 8:51a0ca9079ca 348 //check available interface
arsenalist 8:51a0ca9079ca 349 isEthAvailable(); //check whether cable is connected
arsenalist 31:e2abded4d85f 350 wifiAvailable = true; //wifi module will always on the board
arsenalist 31:e2abded4d85f 351 gprsAvailable = true; //gprs module will always on the board
arsenalist 8:51a0ca9079ca 352 DBG.printf("eth:%d\r\n",ethAvailable);
arsenalist 8:51a0ca9079ca 353 DBG.printf("wifi:%d\r\n",wifiAvailable);
arsenalist 8:51a0ca9079ca 354 DBG.printf("gprs:%d\r\n",gprsAvailable);
arsenalist 0:f4e449fa34d7 355 }
arsenalist 0:f4e449fa34d7 356 void emmaModeWiFiConfig(void) {
arsenalist 0:f4e449fa34d7 357 string str;
arsenalist 18:87f30ba9ddc5 358 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 359 TFT.printf(" please wait");
arsenalist 0:f4e449fa34d7 360
arsenalist 0:f4e449fa34d7 361 if(wifiAvailable) {
arsenalist 0:f4e449fa34d7 362 DBG.printf("emmaModeWiFiConfig\r\n");
arsenalist 0:f4e449fa34d7 363
arsenalist 0:f4e449fa34d7 364 //set wifi module to configuration
arsenalist 0:f4e449fa34d7 365 _ESP.printf("MODE=C");
arsenalist 0:f4e449fa34d7 366 while(1) {
arsenalist 0:f4e449fa34d7 367 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 368 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 369 str = rcv;
arsenalist 0:f4e449fa34d7 370 if(str.find("SC_STATUS_FIND_CHANNEL") != std::string::npos)
arsenalist 0:f4e449fa34d7 371 break;
arsenalist 0:f4e449fa34d7 372 }
arsenalist 18:87f30ba9ddc5 373
arsenalist 18:87f30ba9ddc5 374 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 375 TFT.printf(" emmaModeWiFiConfig");
arsenalist 18:87f30ba9ddc5 376 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 377 TFT.printf(" connect with emma app now");
arsenalist 18:87f30ba9ddc5 378
arsenalist 0:f4e449fa34d7 379 DBG.printf("entering wifi configuration mode\r\n");
arsenalist 0:f4e449fa34d7 380 while(1) {
arsenalist 0:f4e449fa34d7 381 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 382 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 383 str = rcv;
arsenalist 0:f4e449fa34d7 384 if(str.find("MODE=C OK") != std::string::npos) {
arsenalist 0:f4e449fa34d7 385 //save wifiSSID and wifiPASS
arsenalist 0:f4e449fa34d7 386 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 387 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 388 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 389
arsenalist 0:f4e449fa34d7 390 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 391 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 392
arsenalist 0:f4e449fa34d7 393 char *parameter[2] = {"wifiSSID","wifiPASS"};
arsenalist 0:f4e449fa34d7 394
arsenalist 0:f4e449fa34d7 395 for(int i=0; i<2; i++) {
arsenalist 0:f4e449fa34d7 396 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 397 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 11:2311b2d5157d 398 int st = writeSetting(parameter[i],val.c_str());
arsenalist 11:2311b2d5157d 399 if(st) {
arsenalist 11:2311b2d5157d 400 DBG.printf("%s is saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 401 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 402 TFT.printf(" %s is saved",parameter[i]);
arsenalist 18:87f30ba9ddc5 403 wait(3);
arsenalist 18:87f30ba9ddc5 404 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 405 TFT.printf(" ");
arsenalist 11:2311b2d5157d 406 } else {
arsenalist 11:2311b2d5157d 407 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 408 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 409 TFT.printf(" %s is not saved",parameter[i]);
arsenalist 18:87f30ba9ddc5 410 wait(3);
arsenalist 18:87f30ba9ddc5 411 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 412 TFT.printf(" ");
arsenalist 11:2311b2d5157d 413 }
arsenalist 0:f4e449fa34d7 414 }
arsenalist 0:f4e449fa34d7 415 }
arsenalist 18:87f30ba9ddc5 416
arsenalist 18:87f30ba9ddc5 417 //wificonfig finish
arsenalist 18:87f30ba9ddc5 418 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 419 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 420 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 421 TFT.printf(" wificonfig finish. please restart.");
arsenalist 18:87f30ba9ddc5 422
arsenalist 0:f4e449fa34d7 423 }
arsenalist 18:87f30ba9ddc5 424 } else if(str.find("SC_STATUS_GETTING_SSID_PSWD") != std::string::npos){
arsenalist 18:87f30ba9ddc5 425 DBG.printf("app connected\r\n");
arsenalist 18:87f30ba9ddc5 426 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 427 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 428 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 429 TFT.printf(" app connected");
arsenalist 0:f4e449fa34d7 430 }
arsenalist 0:f4e449fa34d7 431 }
arsenalist 0:f4e449fa34d7 432 } else {
arsenalist 0:f4e449fa34d7 433 DBG.printf("no wifi found\r\n");
arsenalist 18:87f30ba9ddc5 434 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 435 TFT.printf(" no wifi found");
arsenalist 0:f4e449fa34d7 436 }
arsenalist 0:f4e449fa34d7 437 }
arsenalist 0:f4e449fa34d7 438 void emmaModeSettings(void) {
arsenalist 0:f4e449fa34d7 439 bool clientIsConnected = false;
arsenalist 0:f4e449fa34d7 440 bool serverIsListened = false;
arsenalist 0:f4e449fa34d7 441 char s[32];
arsenalist 0:f4e449fa34d7 442 string str;
arsenalist 0:f4e449fa34d7 443
arsenalist 18:87f30ba9ddc5 444 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 445 TFT.printf(" please wait");
arsenalist 18:87f30ba9ddc5 446
arsenalist 8:51a0ca9079ca 447 //create settings dir
arsenalist 0:f4e449fa34d7 448 mkdir("/sd/settings",0777);
arsenalist 8:51a0ca9079ca 449
arsenalist 0:f4e449fa34d7 450 //get and write emmaUID
arsenalist 0:f4e449fa34d7 451 string uid = getUID();
arsenalist 0:f4e449fa34d7 452 sprintf(s,"(%s)",uid.c_str());
arsenalist 0:f4e449fa34d7 453 uid = s;
arsenalist 0:f4e449fa34d7 454 writeSetting("emmaUID",uid);
arsenalist 0:f4e449fa34d7 455
arsenalist 8:51a0ca9079ca 456 if(ethAvailable) {
arsenalist 0:f4e449fa34d7 457 DBG.printf("emmaModeSettings - eth\r\n");
arsenalist 37:93f196daf5cf 458 wait(2);
arsenalist 37:93f196daf5cf 459 TFT.locate(0,0);
arsenalist 37:93f196daf5cf 460 TFT.printf(" ");
arsenalist 37:93f196daf5cf 461 TFT.locate(0,0);
arsenalist 37:93f196daf5cf 462 TFT.printf(" emmaModeSettings");
arsenalist 0:f4e449fa34d7 463
arsenalist 0:f4e449fa34d7 464 TCPSocketServer svr;
arsenalist 0:f4e449fa34d7 465 TCPSocketConnection clientSock;
arsenalist 0:f4e449fa34d7 466
arsenalist 0:f4e449fa34d7 467 if(svr.bind(SERVER_PORT) < 0) {
arsenalist 0:f4e449fa34d7 468 DBG.printf("tcp server bind failed\r\n");
arsenalist 0:f4e449fa34d7 469 } else {
arsenalist 0:f4e449fa34d7 470 DBG.printf("tcp server bind success\r\n");
arsenalist 0:f4e449fa34d7 471 serverIsListened = true;
arsenalist 0:f4e449fa34d7 472 }
arsenalist 0:f4e449fa34d7 473
arsenalist 44:c1d11c491237 474 //DBG.printf("please connect to %s\r\n",ipstack.getEth().getIPAddress());
arsenalist 44:c1d11c491237 475 DBG.printf("please connect to %s\r\n",eth.getIPAddress());
arsenalist 0:f4e449fa34d7 476
arsenalist 0:f4e449fa34d7 477 if(svr.listen(1) < 0) {
arsenalist 37:93f196daf5cf 478 DBG.printf("tcp server listen failed\r\n");
arsenalist 37:93f196daf5cf 479 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 480 TFT.printf(" settings error. please restart.");
arsenalist 37:93f196daf5cf 481 while(1);
arsenalist 0:f4e449fa34d7 482 } else {
arsenalist 37:93f196daf5cf 483 DBG.printf("tcp server is listening...\r\n");
arsenalist 37:93f196daf5cf 484 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 485 TFT.printf(" connect with emma app now!");
arsenalist 0:f4e449fa34d7 486 }
arsenalist 0:f4e449fa34d7 487
arsenalist 0:f4e449fa34d7 488 clientSock.set_blocking(false,30000); //timeout after 30sec
arsenalist 0:f4e449fa34d7 489
arsenalist 0:f4e449fa34d7 490 //listening
arsenalist 0:f4e449fa34d7 491 while (serverIsListened) {
arsenalist 0:f4e449fa34d7 492 if(svr.accept(clientSock) < 0) {
arsenalist 37:93f196daf5cf 493 DBG.printf("failed to accept connection\r\n");
arsenalist 37:93f196daf5cf 494 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 495 TFT.printf(" ");
arsenalist 37:93f196daf5cf 496 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 497 TFT.printf("failed to accept connection");
arsenalist 0:f4e449fa34d7 498 } else {
arsenalist 0:f4e449fa34d7 499 DBG.printf("connection success!\r\nIP: %s\r\n",clientSock.get_address());
arsenalist 37:93f196daf5cf 500 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 501 TFT.printf(" ");
arsenalist 37:93f196daf5cf 502 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 503 //TFT.printf(" connection success! IP: %s",clientSock.get_address());
arsenalist 37:93f196daf5cf 504 TFT.printf(" connection success!");
arsenalist 0:f4e449fa34d7 505 clientIsConnected = true;
arsenalist 0:f4e449fa34d7 506
arsenalist 0:f4e449fa34d7 507 while(clientIsConnected) {
arsenalist 0:f4e449fa34d7 508 char buffer[1024] = {};
arsenalist 0:f4e449fa34d7 509 switch(clientSock.receive(buffer,1023)) {
arsenalist 0:f4e449fa34d7 510 case 0:
arsenalist 0:f4e449fa34d7 511 DBG.printf("received buffer is empty\r\n");
arsenalist 0:f4e449fa34d7 512 clientIsConnected = false;
arsenalist 0:f4e449fa34d7 513 break;
arsenalist 0:f4e449fa34d7 514 case -1:
arsenalist 0:f4e449fa34d7 515 DBG.printf("failed to read data from client\r\n");
arsenalist 0:f4e449fa34d7 516 clientIsConnected = false;
arsenalist 0:f4e449fa34d7 517 break;
arsenalist 0:f4e449fa34d7 518 default:
arsenalist 0:f4e449fa34d7 519 //DBG.printf("received data: %d\r\n%s\r\n",strlen(buffer),buffer);
arsenalist 0:f4e449fa34d7 520 DBG.printf("\r\n");
arsenalist 0:f4e449fa34d7 521
arsenalist 0:f4e449fa34d7 522 str = buffer;
arsenalist 0:f4e449fa34d7 523 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 524 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 525 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 526
arsenalist 0:f4e449fa34d7 527 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 528 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 529
arsenalist 14:8287f0f5d987 530 char *parameter[5] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH","epochTime"};
arsenalist 0:f4e449fa34d7 531
arsenalist 0:f4e449fa34d7 532 for(int i=0; i<4; i++) {
arsenalist 0:f4e449fa34d7 533 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 534 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 535 int st = writeSetting(parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 536 if(st) {
arsenalist 0:f4e449fa34d7 537 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 37:93f196daf5cf 538 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 539 TFT.printf(" %s: %s is saved",parameter[i],val.c_str());
arsenalist 37:93f196daf5cf 540 wait(1);
arsenalist 37:93f196daf5cf 541 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 542 TFT.printf(" ");
arsenalist 0:f4e449fa34d7 543 } else {
arsenalist 0:f4e449fa34d7 544 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 37:93f196daf5cf 545 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 546 TFT.printf(" %s is not saved",parameter[i]);
arsenalist 37:93f196daf5cf 547 wait(1);
arsenalist 37:93f196daf5cf 548 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 549 TFT.printf(" ");
arsenalist 0:f4e449fa34d7 550 }
arsenalist 0:f4e449fa34d7 551 }
arsenalist 0:f4e449fa34d7 552 }
arsenalist 14:8287f0f5d987 553
arsenalist 14:8287f0f5d987 554 //set time
arsenalist 14:8287f0f5d987 555 if(jsonValue.hasMember(parameter[4])) {
arsenalist 14:8287f0f5d987 556 string epTime = jsonValue[parameter[4]].get<std::string>();
arsenalist 20:ea14f175bbb4 557 time_t seconds;
arsenalist 14:8287f0f5d987 558 sscanf(epTime.c_str(),"%d",&seconds);
arsenalist 14:8287f0f5d987 559 set_time(seconds);
arsenalist 14:8287f0f5d987 560 DBG.printf("time is set\r\n");
arsenalist 37:93f196daf5cf 561 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 562 TFT.printf(" time is set");
arsenalist 37:93f196daf5cf 563 wait(1);
arsenalist 37:93f196daf5cf 564 TFT.locate(0,40);
arsenalist 37:93f196daf5cf 565 TFT.printf(" ");
arsenalist 14:8287f0f5d987 566 }
arsenalist 0:f4e449fa34d7 567 }
arsenalist 0:f4e449fa34d7 568 break;
arsenalist 0:f4e449fa34d7 569 }
arsenalist 0:f4e449fa34d7 570 }
arsenalist 0:f4e449fa34d7 571 DBG.printf("close connection\r\n");
arsenalist 37:93f196daf5cf 572 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 573 TFT.printf(" ");
arsenalist 37:93f196daf5cf 574 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 575 TFT.printf(" settings finish. please restart.");
arsenalist 0:f4e449fa34d7 576 clientSock.close();
arsenalist 0:f4e449fa34d7 577 }
arsenalist 0:f4e449fa34d7 578 }
arsenalist 8:51a0ca9079ca 579 } else if(wifiAvailable) {
arsenalist 8:51a0ca9079ca 580 DBG.printf("emmaModeSettings - wifi\r\n");
arsenalist 8:51a0ca9079ca 581
arsenalist 8:51a0ca9079ca 582 _ESP.printf("MODE=S");
arsenalist 8:51a0ca9079ca 583 while(1) {
arsenalist 8:51a0ca9079ca 584 char rcv[128] = {};
arsenalist 8:51a0ca9079ca 585 rcvReply(rcv,3000);
arsenalist 8:51a0ca9079ca 586 str = rcv;
arsenalist 8:51a0ca9079ca 587 if(str.find("MODE=S_OK") != std::string::npos)
arsenalist 8:51a0ca9079ca 588 break;
arsenalist 8:51a0ca9079ca 589 }
arsenalist 8:51a0ca9079ca 590 DBG.printf("entering settings mode\r\n");
arsenalist 17:b3ced0e67916 591 TFT.locate(0,0);
arsenalist 17:b3ced0e67916 592 TFT.printf(" emmaModeSettings");
arsenalist 17:b3ced0e67916 593 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 594 TFT.printf(" connect with emma app now!");
arsenalist 17:b3ced0e67916 595
arsenalist 8:51a0ca9079ca 596 while(1) {
arsenalist 8:51a0ca9079ca 597 char rcv[512] = {};
arsenalist 8:51a0ca9079ca 598 rcvReply(rcv,3000);
arsenalist 8:51a0ca9079ca 599 //DBG.printf("rcv:%s\r\n",rcv);
arsenalist 8:51a0ca9079ca 600 str = rcv;
arsenalist 8:51a0ca9079ca 601 if(str.find("MODE=S_Config") != std::string::npos) {
arsenalist 8:51a0ca9079ca 602 //save gprs and proxy setting
arsenalist 8:51a0ca9079ca 603 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 8:51a0ca9079ca 604 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 8:51a0ca9079ca 605 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 8:51a0ca9079ca 606
arsenalist 8:51a0ca9079ca 607 MbedJSONValue jsonValue;
arsenalist 8:51a0ca9079ca 608 parse(jsonValue,str.c_str());
arsenalist 8:51a0ca9079ca 609
arsenalist 14:8287f0f5d987 610 char *parameter[5] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH","epochTime"};
arsenalist 8:51a0ca9079ca 611
arsenalist 8:51a0ca9079ca 612 for(int i=0; i<4; i++) {
arsenalist 8:51a0ca9079ca 613 if(jsonValue.hasMember(parameter[i])) {
arsenalist 8:51a0ca9079ca 614 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 8:51a0ca9079ca 615 int st = writeSetting(parameter[i],val.c_str());
arsenalist 8:51a0ca9079ca 616 if(st) {
arsenalist 8:51a0ca9079ca 617 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 17:b3ced0e67916 618 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 619 TFT.printf(" %s: %s is saved",parameter[i],val.c_str());
arsenalist 37:93f196daf5cf 620 wait(1);
arsenalist 17:b3ced0e67916 621 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 622 TFT.printf(" ");
arsenalist 8:51a0ca9079ca 623 } else {
arsenalist 8:51a0ca9079ca 624 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 17:b3ced0e67916 625 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 626 TFT.printf(" %s is not saved",parameter[i]);
arsenalist 37:93f196daf5cf 627 wait(1);
arsenalist 17:b3ced0e67916 628 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 629 TFT.printf(" ");
arsenalist 8:51a0ca9079ca 630 }
arsenalist 8:51a0ca9079ca 631 }
arsenalist 8:51a0ca9079ca 632 }
arsenalist 14:8287f0f5d987 633
arsenalist 14:8287f0f5d987 634 //set time
arsenalist 14:8287f0f5d987 635 if(jsonValue.hasMember(parameter[4])) {
arsenalist 14:8287f0f5d987 636 string epTime = jsonValue[parameter[4]].get<std::string>();
arsenalist 14:8287f0f5d987 637 time_t seconds;
arsenalist 14:8287f0f5d987 638 sscanf(epTime.c_str(),"%d",&seconds);
arsenalist 14:8287f0f5d987 639 set_time(seconds);
arsenalist 14:8287f0f5d987 640 DBG.printf("time is set\r\n");
arsenalist 17:b3ced0e67916 641 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 642 TFT.printf(" time is set");
arsenalist 37:93f196daf5cf 643 wait(1);
arsenalist 17:b3ced0e67916 644 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 645 TFT.printf(" ");
arsenalist 14:8287f0f5d987 646 }
arsenalist 18:87f30ba9ddc5 647
arsenalist 18:87f30ba9ddc5 648 //setting finish
arsenalist 18:87f30ba9ddc5 649 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 650 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 651 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 652 TFT.printf(" settings finish. please restart.");
arsenalist 8:51a0ca9079ca 653 }
arsenalist 8:51a0ca9079ca 654 } else if(str.find("connect") != std::string::npos) {
arsenalist 8:51a0ca9079ca 655 DBG.printf("connection success!\r\n");
arsenalist 17:b3ced0e67916 656 TFT.locate(0,20);
arsenalist 17:b3ced0e67916 657 TFT.printf(" ");
arsenalist 17:b3ced0e67916 658 TFT.locate(0,20);
arsenalist 37:93f196daf5cf 659 TFT.printf(" connection success!");
arsenalist 8:51a0ca9079ca 660 }
arsenalist 8:51a0ca9079ca 661 }
arsenalist 0:f4e449fa34d7 662 } else {
arsenalist 9:a58c04da4476 663 DBG.printf("no eth or wifi is available\r\n");
arsenalist 17:b3ced0e67916 664 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 665 TFT.printf(" no iface avail, please restart!");
arsenalist 0:f4e449fa34d7 666 }
arsenalist 0:f4e449fa34d7 667 }
arsenalist 0:f4e449fa34d7 668 void emmaModeRegister(void) {
arsenalist 0:f4e449fa34d7 669 bool emmaGetRegKey = false;
arsenalist 0:f4e449fa34d7 670 bool emmaRegistered = false;
arsenalist 39:f51aa948acee 671 char connBody[256];
arsenalist 0:f4e449fa34d7 672 char s[512];
arsenalist 0:f4e449fa34d7 673 char r[256];
arsenalist 39:f51aa948acee 674 int connBodyLen;
arsenalist 0:f4e449fa34d7 675 int connPort;
arsenalist 0:f4e449fa34d7 676 int loop = 0;
arsenalist 0:f4e449fa34d7 677 string connData;
arsenalist 0:f4e449fa34d7 678 string connHost;
arsenalist 0:f4e449fa34d7 679 string str;
arsenalist 0:f4e449fa34d7 680 string regKey;
arsenalist 0:f4e449fa34d7 681 Timer t;
arsenalist 0:f4e449fa34d7 682
arsenalist 18:87f30ba9ddc5 683 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 684 TFT.printf(" please wait");
arsenalist 18:87f30ba9ddc5 685
arsenalist 0:f4e449fa34d7 686 //check connected interface
arsenalist 8:51a0ca9079ca 687 isEthConnected();
arsenalist 8:51a0ca9079ca 688 isWiFiConnected();
arsenalist 8:51a0ca9079ca 689 isGprsConnected();
arsenalist 0:f4e449fa34d7 690 DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist 0:f4e449fa34d7 691 DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist 0:f4e449fa34d7 692
arsenalist 9:a58c04da4476 693 if(ethConnected) {
arsenalist 9:a58c04da4476 694 DBG.printf("emmaModeRegister - eth\r\n");
arsenalist 38:e44f35f8129d 695 wait(2);
arsenalist 38:e44f35f8129d 696 TFT.locate(0,0);
arsenalist 38:e44f35f8129d 697 TFT.printf(" ");
arsenalist 38:e44f35f8129d 698 TFT.locate(0,0);
arsenalist 38:e44f35f8129d 699 TFT.printf(" emmaModeRegister");
arsenalist 9:a58c04da4476 700
arsenalist 39:f51aa948acee 701 //set connBody, connHost, connPort, connData
arsenalist 39:f51aa948acee 702 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),hmac.c_str());
arsenalist 39:f51aa948acee 703
arsenalist 9:a58c04da4476 704 if(useProxy) {
arsenalist 9:a58c04da4476 705 DBG.printf("use proxy\r\n");
arsenalist 9:a58c04da4476 706 connHost = proxySERVER;
arsenalist 9:a58c04da4476 707 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 9:a58c04da4476 708 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 709 s[i]=0; }
arsenalist 39:f51aa948acee 710 //sprintf(s,"GET http://%s:%s/emma/api/controller/register?uid=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),emmaUID.c_str(),hmac.c_str(),restSERVER.c_str());
arsenalist 39:f51aa948acee 711 //sprintf(s,"POST http://%s:%s/emma/api/controller/register HTTP/1.0\nHost: %s\nContent-Length: 76\n\n{\"uid\":\"%s\",\"hmac\":\"%s\"}\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),restSERVER.c_str(),emmaUID.c_str(),hmac.c_str());
arsenalist 43:612547648ed1 712 sprintf(s,"POST http://%s:%s/%s/api/controller/register HTTP/1.0\nHost: %s\nContent-Length: %d\n\n%s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 9:a58c04da4476 713 connData = s;
arsenalist 9:a58c04da4476 714 } else {
arsenalist 9:a58c04da4476 715 DBG.printf("no proxy\r\n");
arsenalist 38:e44f35f8129d 716 connHost = restSERVER;
arsenalist 38:e44f35f8129d 717 //connPort = restPORT;
arsenalist 38:e44f35f8129d 718 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 9:a58c04da4476 719 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 720 s[i]=0; }
arsenalist 39:f51aa948acee 721 //sprintf(s,"GET /emma/api/controller/register?uid=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",emmaUID.c_str(),hmac.c_str(),restSERVER.c_str());
arsenalist 39:f51aa948acee 722 //sprintf(s,"POST /emma/api/controller/register HTTP/1.0\nHost: %s\nContent-Length: 76\n\n{\"uid\":\"%s\",\"hmac\":\"%s\"}\r\n\r\n",restSERVER.c_str(),emmaUID.c_str(),hmac.c_str());
arsenalist 43:612547648ed1 723 sprintf(s,"POST /%s/api/controller/register HTTP/1.0\nHost: %s\nContent-Length: %d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 9:a58c04da4476 724 connData = s;
arsenalist 9:a58c04da4476 725 }
arsenalist 9:a58c04da4476 726
arsenalist 9:a58c04da4476 727 //register
arsenalist 9:a58c04da4476 728 while(!emmaGetRegKey) {
arsenalist 38:e44f35f8129d 729 //DBG.printf("post:%s\r\n",s);
arsenalist 38:e44f35f8129d 730 str.clear();
arsenalist 40:77bd44f57ad3 731 str = ethREST(connHost,connPort,connData);
arsenalist 9:a58c04da4476 732 DBG.printf("rsp reg:%s\r\n",str.c_str());
arsenalist 9:a58c04da4476 733
arsenalist 38:e44f35f8129d 734 //check and save mqtt setting
arsenalist 9:a58c04da4476 735 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 9:a58c04da4476 736 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 9:a58c04da4476 737 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 9:a58c04da4476 738
arsenalist 9:a58c04da4476 739 MbedJSONValue jsonValue;
arsenalist 9:a58c04da4476 740 parse(jsonValue,str.c_str());
arsenalist 9:a58c04da4476 741
arsenalist 38:e44f35f8129d 742 char *parameter[4] = {"mqttDOMAIN","mqttKEY","mqttSECRET","registrationKey"};
arsenalist 9:a58c04da4476 743
arsenalist 38:e44f35f8129d 744 //save mqtt parameter
arsenalist 9:a58c04da4476 745 writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist 9:a58c04da4476 746 for(int i=0; i<3; i++) {
arsenalist 9:a58c04da4476 747 if(jsonValue.hasMember(parameter[i])) {
arsenalist 9:a58c04da4476 748 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 9:a58c04da4476 749 int st = writeSetting(parameter[i],val.c_str());
arsenalist 9:a58c04da4476 750 if(st) {
arsenalist 9:a58c04da4476 751 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 9:a58c04da4476 752 } else {
arsenalist 9:a58c04da4476 753 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 9:a58c04da4476 754 }
arsenalist 9:a58c04da4476 755 }
arsenalist 9:a58c04da4476 756 }
arsenalist 9:a58c04da4476 757
arsenalist 9:a58c04da4476 758 //get registrationKey
arsenalist 9:a58c04da4476 759 if(jsonValue.hasMember(parameter[3])) {
arsenalist 9:a58c04da4476 760 string val = jsonValue[parameter[3]].get<std::string>();
arsenalist 9:a58c04da4476 761 if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist 9:a58c04da4476 762 val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist 9:a58c04da4476 763 val.erase(val.begin()+val.find(")"),val.end());
arsenalist 9:a58c04da4476 764 regKey = val;
arsenalist 9:a58c04da4476 765 DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 38:e44f35f8129d 766
arsenalist 38:e44f35f8129d 767 TFT.locate(0,20);
arsenalist 38:e44f35f8129d 768 TFT.printf(" %s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 38:e44f35f8129d 769
arsenalist 9:a58c04da4476 770 emmaGetRegKey = true;
arsenalist 9:a58c04da4476 771 }
arsenalist 9:a58c04da4476 772 }
arsenalist 9:a58c04da4476 773 }
arsenalist 9:a58c04da4476 774 }
arsenalist 9:a58c04da4476 775
arsenalist 9:a58c04da4476 776 //calculate hmac
arsenalist 9:a58c04da4476 777 for(int i=0; i<sizeof(r); i++) {
arsenalist 9:a58c04da4476 778 r[i]=0; }
arsenalist 9:a58c04da4476 779 sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist 9:a58c04da4476 780 hmac = calculateMD5(r);
arsenalist 9:a58c04da4476 781 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 9:a58c04da4476 782
arsenalist 39:f51aa948acee 783 //set connBody and connData
arsenalist 39:f51aa948acee 784 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"registrationKey\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist 39:f51aa948acee 785
arsenalist 9:a58c04da4476 786 if(useProxy) {
arsenalist 9:a58c04da4476 787 DBG.printf("use proxy\r\n");
arsenalist 9:a58c04da4476 788 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 789 s[i]=0; }
arsenalist 39:f51aa948acee 790 //sprintf(s,"GET http://%s:%s/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),emmaUID.c_str(),regKey.c_str(),hmac.c_str(),restSERVER.c_str());
arsenalist 43:612547648ed1 791 sprintf(s,"POST http://%s:%s/%s/api/controller/verify HTTP/1.0\nHost: %s\nContent-Length: %d\n\n%s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 9:a58c04da4476 792 connData = s;
arsenalist 9:a58c04da4476 793 } else {
arsenalist 9:a58c04da4476 794 DBG.printf("no proxy\r\n");
arsenalist 9:a58c04da4476 795 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 796 s[i]=0; }
arsenalist 39:f51aa948acee 797 //sprintf(s,"GET /emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",emmaUID.c_str(),regKey.c_str(),hmac.c_str(),restSERVER.c_str());
arsenalist 43:612547648ed1 798 sprintf(s,"POST /%s/api/controller/verify HTTP/1.0\nHost: %s\nContent-Length: %d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 9:a58c04da4476 799 connData = s;
arsenalist 9:a58c04da4476 800 }
arsenalist 9:a58c04da4476 801
arsenalist 9:a58c04da4476 802 //verify registration
arsenalist 9:a58c04da4476 803 while(!emmaRegistered && loop < 12){
arsenalist 9:a58c04da4476 804 str.clear();
arsenalist 40:77bd44f57ad3 805 str = ethREST(connHost,connPort,connData);
arsenalist 9:a58c04da4476 806 DBG.printf("rsp vrf:%s\r\n",str.c_str());
arsenalist 38:e44f35f8129d 807
arsenalist 38:e44f35f8129d 808 TFT.locate(0,40);
arsenalist 38:e44f35f8129d 809 TFT.printf(" ");
arsenalist 38:e44f35f8129d 810 TFT.locate(0,40);
arsenalist 38:e44f35f8129d 811 TFT.printf(" wait:%d\r\n",loop);
arsenalist 9:a58c04da4476 812
arsenalist 9:a58c04da4476 813 //check verification
arsenalist 9:a58c04da4476 814 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 9:a58c04da4476 815 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 9:a58c04da4476 816 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 9:a58c04da4476 817
arsenalist 9:a58c04da4476 818 MbedJSONValue jsonValue;
arsenalist 9:a58c04da4476 819 parse(jsonValue,str.c_str());
arsenalist 9:a58c04da4476 820 if(jsonValue.hasMember("user")) {
arsenalist 9:a58c04da4476 821 string val = jsonValue["user"].get<std::string>();
arsenalist 9:a58c04da4476 822 DBG.printf("%s is registered\r\n",val.c_str());
arsenalist 38:e44f35f8129d 823 TFT.locate(0,40);
arsenalist 38:e44f35f8129d 824 TFT.printf(" ");
arsenalist 38:e44f35f8129d 825 TFT.locate(0,40);
arsenalist 38:e44f35f8129d 826 TFT.printf(" %s is registered\r\n",val.c_str());
arsenalist 9:a58c04da4476 827 emmaRegistered = true;
arsenalist 9:a58c04da4476 828 }
arsenalist 9:a58c04da4476 829 }
arsenalist 9:a58c04da4476 830 wait(5);
arsenalist 9:a58c04da4476 831 loop++;
arsenalist 9:a58c04da4476 832 }
arsenalist 9:a58c04da4476 833
arsenalist 9:a58c04da4476 834 //check whether registration success
arsenalist 9:a58c04da4476 835 if(emmaRegistered) {
arsenalist 9:a58c04da4476 836 DBG.printf("registration successful\r\n");
arsenalist 38:e44f35f8129d 837 TFT.locate(0,60);
arsenalist 38:e44f35f8129d 838 TFT.printf(" registration successful\r\n");
arsenalist 9:a58c04da4476 839 } else {
arsenalist 9:a58c04da4476 840 DBG.printf("registration unsuccessful\r\n");
arsenalist 38:e44f35f8129d 841 TFT.locate(0,60);
arsenalist 38:e44f35f8129d 842 TFT.printf(" registration unsuccessful. please restart.\r\n");
arsenalist 9:a58c04da4476 843 }
arsenalist 9:a58c04da4476 844 while(1);
arsenalist 9:a58c04da4476 845
arsenalist 9:a58c04da4476 846 } else if(wifiConnected) {
arsenalist 0:f4e449fa34d7 847 DBG.printf("emmaModeRegister - wifi\r\n");
arsenalist 0:f4e449fa34d7 848
arsenalist 0:f4e449fa34d7 849 _ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 850 wait(1);
arsenalist 0:f4e449fa34d7 851 while(!esp.ready());
arsenalist 0:f4e449fa34d7 852
arsenalist 0:f4e449fa34d7 853 //set connHost, connPort
arsenalist 0:f4e449fa34d7 854 if(useProxy) {
arsenalist 0:f4e449fa34d7 855 connHost = proxySERVER;
arsenalist 0:f4e449fa34d7 856 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 0:f4e449fa34d7 857 } else {
arsenalist 38:e44f35f8129d 858 connHost = restSERVER;
arsenalist 38:e44f35f8129d 859 //connPort = restPORT;
arsenalist 38:e44f35f8129d 860 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 0:f4e449fa34d7 861 }
arsenalist 18:87f30ba9ddc5 862 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 863 TFT.printf(" emmaModeRegister");
arsenalist 0:f4e449fa34d7 864
arsenalist 0:f4e449fa34d7 865 //rest begin
arsenalist 0:f4e449fa34d7 866 if(!rest.begin(connHost.c_str(),connPort,false)) {
arsenalist 0:f4e449fa34d7 867 DBG.printf("EMMA: fail to setup rest");
arsenalist 32:78633fb9b2a1 868 TFT.locate(0,20);
arsenalist 32:78633fb9b2a1 869 TFT.printf(" fail setup connection");
arsenalist 32:78633fb9b2a1 870 TFT.locate(0,40);
arsenalist 32:78633fb9b2a1 871 TFT.printf(" check your wifi connection or");
arsenalist 32:78633fb9b2a1 872 TFT.locate(0,60);
arsenalist 32:78633fb9b2a1 873 TFT.printf(" you should setup proxy!");
arsenalist 0:f4e449fa34d7 874 while(1);
arsenalist 0:f4e449fa34d7 875 }
arsenalist 0:f4e449fa34d7 876 //wifiConnected = true; //with custom firmware, wifi module should connect automatically
arsenalist 0:f4e449fa34d7 877
arsenalist 0:f4e449fa34d7 878 esp.process();
arsenalist 0:f4e449fa34d7 879 if(wifiConnected) {
arsenalist 32:78633fb9b2a1 880 //check proxy
arsenalist 0:f4e449fa34d7 881 if(useProxy) {
arsenalist 43:612547648ed1 882 sprintf(r,"http://%s:%s/%s/api/controller/register",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str());
arsenalist 38:e44f35f8129d 883 //sprintf(r,"http://%s:%d/emma/api/controller/register HTTP/1.0\nHost: %s:%d\nProxy-Authorization: Basic %s\nCache-Control: no-cache\nContent-Length: %d\n\n",restSERVER,restPORT,restSERVER,restPORT,proxyAUTH.c_str(),76);
arsenalist 38:e44f35f8129d 884 //sprintf(r,"http://%s:%d/emma/api/controller/register HTTP/1.0\nAccept: */*\nAccept-Encoding: gzip,deflate\nContent-Length: %d\r\n\r\n",restSERVER,restPORT,76);
arsenalist 39:f51aa948acee 885 //sprintf(r,"http://%s:%d/emma/coba",restSERVER,REST_SERVER_PORT);
arsenalist 0:f4e449fa34d7 886 } else {
arsenalist 43:612547648ed1 887 sprintf(r,"/%s/api/controller/register",appNAME.c_str());
arsenalist 0:f4e449fa34d7 888 }
arsenalist 0:f4e449fa34d7 889
arsenalist 0:f4e449fa34d7 890 //register
arsenalist 0:f4e449fa34d7 891 while(!emmaGetRegKey) {
arsenalist 32:78633fb9b2a1 892 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),hmac.c_str());
arsenalist 39:f51aa948acee 893 //DBG.printf("s:%s\r\n",s);
arsenalist 32:78633fb9b2a1 894 //string iniStr = "{\"uid\":\"005300553533510334313732\",\"hmac\":\"45fc6a4447989a9434d1f21087a78061\"}";
arsenalist 32:78633fb9b2a1 895 //DBG.printf("s:%s\r\n",iniStr.c_str());
arsenalist 32:78633fb9b2a1 896
arsenalist 32:78633fb9b2a1 897 //rest.post(r,iniStr.c_str());
arsenalist 32:78633fb9b2a1 898 rest.post(r,s);
arsenalist 0:f4e449fa34d7 899 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 900 s[i]=0; }
arsenalist 0:f4e449fa34d7 901 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 902 DBG.printf("rsp reg:%s\r\n",s);
arsenalist 0:f4e449fa34d7 903
arsenalist 38:e44f35f8129d 904 //check and save mqtt setting
arsenalist 0:f4e449fa34d7 905 str = s;
arsenalist 0:f4e449fa34d7 906 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 907 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 908 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 909
arsenalist 0:f4e449fa34d7 910 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 911 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 912
arsenalist 38:e44f35f8129d 913 char *parameter[4] = {"mqttDOMAIN","mqttKEY","mqttSECRET","registrationKey"};
arsenalist 0:f4e449fa34d7 914
arsenalist 38:e44f35f8129d 915 //save mqtt parameter
arsenalist 0:f4e449fa34d7 916 writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist 0:f4e449fa34d7 917 for(int i=0; i<3; i++) {
arsenalist 0:f4e449fa34d7 918 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 919 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 920 int st = writeSetting(parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 921 if(st) {
arsenalist 0:f4e449fa34d7 922 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 923 } else {
arsenalist 0:f4e449fa34d7 924 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 0:f4e449fa34d7 925 }
arsenalist 0:f4e449fa34d7 926 }
arsenalist 0:f4e449fa34d7 927 }
arsenalist 0:f4e449fa34d7 928
arsenalist 0:f4e449fa34d7 929 //get registrationKey
arsenalist 0:f4e449fa34d7 930 if(jsonValue.hasMember(parameter[3])) {
arsenalist 0:f4e449fa34d7 931 string val = jsonValue[parameter[3]].get<std::string>();
arsenalist 0:f4e449fa34d7 932 if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 933 val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist 0:f4e449fa34d7 934 val.erase(val.begin()+val.find(")"),val.end());
arsenalist 0:f4e449fa34d7 935 regKey = val;
arsenalist 0:f4e449fa34d7 936 DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 18:87f30ba9ddc5 937
arsenalist 18:87f30ba9ddc5 938 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 939 TFT.printf(" %s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 18:87f30ba9ddc5 940
arsenalist 0:f4e449fa34d7 941 emmaGetRegKey = true;
arsenalist 0:f4e449fa34d7 942 }
arsenalist 0:f4e449fa34d7 943 }
arsenalist 0:f4e449fa34d7 944 }
arsenalist 32:78633fb9b2a1 945 wait(1);
arsenalist 0:f4e449fa34d7 946 }
arsenalist 0:f4e449fa34d7 947
arsenalist 0:f4e449fa34d7 948 //calculate hmac
arsenalist 0:f4e449fa34d7 949 for(int i=0; i<sizeof(r); i++) {
arsenalist 0:f4e449fa34d7 950 r[i]=0; }
arsenalist 0:f4e449fa34d7 951 sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist 0:f4e449fa34d7 952 hmac = calculateMD5(r);
arsenalist 0:f4e449fa34d7 953 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 0:f4e449fa34d7 954
arsenalist 32:78633fb9b2a1 955 //check proxy
arsenalist 0:f4e449fa34d7 956 if(useProxy) {
arsenalist 43:612547648ed1 957 sprintf(r,"http://%s:%s/%s/api/controller/verify",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str());
arsenalist 0:f4e449fa34d7 958 } else {
arsenalist 43:612547648ed1 959 sprintf(r,"/%s/api/controller/verify",appNAME.c_str());
arsenalist 0:f4e449fa34d7 960 }
arsenalist 0:f4e449fa34d7 961
arsenalist 0:f4e449fa34d7 962 //verify registration
arsenalist 0:f4e449fa34d7 963 while(!emmaRegistered && loop < 12){
arsenalist 32:78633fb9b2a1 964 sprintf(s,"{\"uid\":\"%s\",\"registrationKey\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist 32:78633fb9b2a1 965 rest.post(r,s);
arsenalist 0:f4e449fa34d7 966 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 967 DBG.printf("rsp vrf:%s\r\n",s);
arsenalist 18:87f30ba9ddc5 968 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 969 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 970 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 971 TFT.printf(" wait:%d\r\n",loop);
arsenalist 0:f4e449fa34d7 972
arsenalist 0:f4e449fa34d7 973 //check verification
arsenalist 0:f4e449fa34d7 974 str = s;
arsenalist 0:f4e449fa34d7 975 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 976 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 977 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 978
arsenalist 0:f4e449fa34d7 979 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 980 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 981 if(jsonValue.hasMember("user")) {
arsenalist 0:f4e449fa34d7 982 string val = jsonValue["user"].get<std::string>();
arsenalist 18:87f30ba9ddc5 983 DBG.printf(" %s is registered\r\n",val.c_str());
arsenalist 18:87f30ba9ddc5 984 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 985 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 986 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 987 TFT.printf(" %s is registered\r\n",val.c_str());
arsenalist 0:f4e449fa34d7 988 emmaRegistered = true;
arsenalist 0:f4e449fa34d7 989 }
arsenalist 0:f4e449fa34d7 990 }
arsenalist 0:f4e449fa34d7 991 wait(5);
arsenalist 0:f4e449fa34d7 992 loop++;
arsenalist 0:f4e449fa34d7 993 }
arsenalist 0:f4e449fa34d7 994
arsenalist 0:f4e449fa34d7 995 //check whether registration success
arsenalist 0:f4e449fa34d7 996 if(emmaRegistered) {
arsenalist 0:f4e449fa34d7 997 DBG.printf("registration successful\r\n");
arsenalist 18:87f30ba9ddc5 998 TFT.locate(0,60);
arsenalist 18:87f30ba9ddc5 999 TFT.printf(" registration successful\r\n");
arsenalist 0:f4e449fa34d7 1000 } else {
arsenalist 0:f4e449fa34d7 1001 DBG.printf("registration unsuccessful\r\n");
arsenalist 18:87f30ba9ddc5 1002 TFT.locate(0,60);
arsenalist 38:e44f35f8129d 1003 TFT.printf(" registration unsuccessful. please restart.\r\n");
arsenalist 0:f4e449fa34d7 1004 }
arsenalist 0:f4e449fa34d7 1005 while(1);
arsenalist 0:f4e449fa34d7 1006 }
arsenalist 0:f4e449fa34d7 1007
arsenalist 9:a58c04da4476 1008 } else if(gprsConnected) {
arsenalist 0:f4e449fa34d7 1009 DBG.printf("emmaModeRegister - gprs\r\n");
arsenalist 0:f4e449fa34d7 1010
arsenalist 0:f4e449fa34d7 1011 } else {
arsenalist 9:a58c04da4476 1012 DBG.printf("no eth, wifi, or gprs is connected\r\n");
arsenalist 18:87f30ba9ddc5 1013 TFT.locate(0,60);
arsenalist 18:87f30ba9ddc5 1014 TFT.printf(" no iface connected. please restart.\r\n");
arsenalist 0:f4e449fa34d7 1015 }
arsenalist 0:f4e449fa34d7 1016 }
arsenalist 0:f4e449fa34d7 1017
arsenalist 0:f4e449fa34d7 1018 void emmaModeOperation(void) {
arsenalist 27:562a95c120cc 1019 //char mqttClientId[32];
arsenalist 40:77bd44f57ad3 1020 char connBody[256];
arsenalist 22:e18d361bf688 1021 char p[64];
arsenalist 14:8287f0f5d987 1022 char q[32];
arsenalist 4:76ab12e2f8a3 1023 char r[32];
arsenalist 45:2406c2b6995a 1024 char s[4096];
arsenalist 40:77bd44f57ad3 1025 int connBodyLen;
arsenalist 38:e44f35f8129d 1026 int connPort;
arsenalist 0:f4e449fa34d7 1027 int loop=0;
arsenalist 21:33bd8b82560f 1028 int trial=0;
arsenalist 22:e18d361bf688 1029 string hmacTime;
arsenalist 23:fb369e171b7d 1030 string hmacCmd;
arsenalist 0:f4e449fa34d7 1031 string str;
arsenalist 14:8287f0f5d987 1032 time_t seconds;
arsenalist 0:f4e449fa34d7 1033 Timer t;
arsenalist 24:5d58515ba510 1034 Timer tPanelEnergy;
arsenalist 24:5d58515ba510 1035 Timer tPanel;
arsenalist 4:76ab12e2f8a3 1036 Timer tNodes;
arsenalist 0:f4e449fa34d7 1037
arsenalist 19:7e3e9332f719 1038 TFT.locate(0,0);
arsenalist 19:7e3e9332f719 1039 TFT.printf(" please wait");
arsenalist 19:7e3e9332f719 1040
arsenalist 0:f4e449fa34d7 1041 //check connected interface
arsenalist 8:51a0ca9079ca 1042 isEthConnected();
arsenalist 8:51a0ca9079ca 1043 isWiFiConnected();
arsenalist 8:51a0ca9079ca 1044 isGprsConnected();
arsenalist 0:f4e449fa34d7 1045 DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist 0:f4e449fa34d7 1046 DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist 0:f4e449fa34d7 1047
arsenalist 13:e8adfe305dbc 1048 TFT.locate(0,0);
arsenalist 13:e8adfe305dbc 1049 TFT.printf(" emmaModeOperation");
arsenalist 13:e8adfe305dbc 1050
arsenalist 13:e8adfe305dbc 1051 TFT.locate(0,20);
arsenalist 44:c1d11c491237 1052 TFT.printf(" Interface:");
arsenalist 44:c1d11c491237 1053
arsenalist 44:c1d11c491237 1054 TFT.locate(75,20);
arsenalist 13:e8adfe305dbc 1055 if(ethConnected) {
arsenalist 44:c1d11c491237 1056 TFT.printf("ETH");
arsenalist 44:c1d11c491237 1057 } else if(wifiConnected) {
arsenalist 44:c1d11c491237 1058 TFT.printf("WiFi");
arsenalist 44:c1d11c491237 1059 } else if(gprsConnected) {
arsenalist 44:c1d11c491237 1060 TFT.printf("GPRS");
arsenalist 13:e8adfe305dbc 1061 } else {
arsenalist 44:c1d11c491237 1062 TFT.printf("N/A");
arsenalist 13:e8adfe305dbc 1063 }
arsenalist 13:e8adfe305dbc 1064
arsenalist 44:c1d11c491237 1065 //set ade7758 parameter
arsenalist 44:c1d11c491237 1066 ADE.begin();
arsenalist 44:c1d11c491237 1067 ADE.writeRMSOffset(AIRMSOFFSET, BIRMSOFFSET, CIRMSOFFSET, AVRMSOFFSET, BVRMSOFFSET, CVRMSOFFSET);
arsenalist 44:c1d11c491237 1068 ADE.write16bits(AWG, 0);
arsenalist 44:c1d11c491237 1069 ADE.write16bits(BWG, 0);
arsenalist 44:c1d11c491237 1070 ADE.write16bits(CWG, 0);
arsenalist 44:c1d11c491237 1071 ADE.write16bits(AVAG, 0);
arsenalist 44:c1d11c491237 1072 ADE.write16bits(BVAG, 0);
arsenalist 44:c1d11c491237 1073 ADE.write16bits(CVAG, 0);
arsenalist 13:e8adfe305dbc 1074
arsenalist 10:1dc69e0ce7fd 1075 if(ethConnected) {
arsenalist 10:1dc69e0ce7fd 1076 DBG.printf("emmaModeOperation - eth\r\n");
arsenalist 44:c1d11c491237 1077
arsenalist 44:c1d11c491237 1078 //new log indicator
arsenalist 40:77bd44f57ad3 1079 seconds = time(NULL);
arsenalist 40:77bd44f57ad3 1080 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 40:77bd44f57ad3 1081 DBG.printf("newLog:%d\r\n",writeLog(q,"++++++++++Ethernet++++++++++"));
arsenalist 40:77bd44f57ad3 1082
arsenalist 40:77bd44f57ad3 1083 //check firmware update
arsenalist 40:77bd44f57ad3 1084
arsenalist 40:77bd44f57ad3 1085 //execute last state of switches on board
arsenalist 40:77bd44f57ad3 1086
arsenalist 40:77bd44f57ad3 1087 //get list of nodes from server
arsenalist 40:77bd44f57ad3 1088 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),hmac.c_str());
arsenalist 46:86a0c2133130 1089 sprintf(s,"POST /%s/api/controller/wifinodes HTTP/1.0\nHost: %s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 44:c1d11c491237 1090 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 40:77bd44f57ad3 1091 str.clear();
arsenalist 40:77bd44f57ad3 1092 str = ethREST(restSERVER,connPort,s);
arsenalist 44:c1d11c491237 1093 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 46:86a0c2133130 1094
arsenalist 40:77bd44f57ad3 1095 if(str.rfind("[{\"type\"") != std::string::npos) {
arsenalist 40:77bd44f57ad3 1096 DBG.printf("get nodes from server\r\n");
arsenalist 40:77bd44f57ad3 1097 str.erase(str.begin(),str.begin()+str.rfind("[{\"type\""));
arsenalist 40:77bd44f57ad3 1098 str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist 40:77bd44f57ad3 1099
arsenalist 40:77bd44f57ad3 1100 MbedJSONValue jsonValue;
arsenalist 40:77bd44f57ad3 1101 parse(jsonValue,str.c_str());
arsenalist 40:77bd44f57ad3 1102 char *parameter[3] = {"type","mac","ip"};
arsenalist 40:77bd44f57ad3 1103
arsenalist 40:77bd44f57ad3 1104 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1105 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1106 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1107 TFT.printf("get %d nodes from server",jsonValue.size());
arsenalist 40:77bd44f57ad3 1108 wait(0.5);
arsenalist 40:77bd44f57ad3 1109 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1110 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1111
arsenalist 40:77bd44f57ad3 1112 //check whether nodes valid
arsenalist 40:77bd44f57ad3 1113 bool validNodes = true;
arsenalist 40:77bd44f57ad3 1114 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 40:77bd44f57ad3 1115 for(int j=0; j<3; j++) {
arsenalist 40:77bd44f57ad3 1116 validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist 40:77bd44f57ad3 1117 }
arsenalist 40:77bd44f57ad3 1118 }
arsenalist 40:77bd44f57ad3 1119 DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist 40:77bd44f57ad3 1120
arsenalist 40:77bd44f57ad3 1121 if(validNodes) {
arsenalist 40:77bd44f57ad3 1122 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 44:c1d11c491237 1123 int typeValue = jsonValue[i][parameter[0]].get<int>();
arsenalist 40:77bd44f57ad3 1124 string macValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 40:77bd44f57ad3 1125 string ipValue = jsonValue[i][parameter[2]].get<std::string>();
arsenalist 40:77bd44f57ad3 1126 nodes[i].type = typeValue;
arsenalist 40:77bd44f57ad3 1127 nodes[i].macAddr = macValue;
arsenalist 40:77bd44f57ad3 1128 nodes[i].ipAddr = ipValue;
arsenalist 44:c1d11c491237 1129 DBG.printf("nodes[%d]type:%d\r\n",i,nodes[i].type);
arsenalist 40:77bd44f57ad3 1130 DBG.printf("nodes[%d]mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist 40:77bd44f57ad3 1131 DBG.printf("nodes[%d]ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist 40:77bd44f57ad3 1132 }
arsenalist 36:ed696fd1b44e 1133 }
arsenalist 40:77bd44f57ad3 1134
arsenalist 40:77bd44f57ad3 1135 } else {
arsenalist 40:77bd44f57ad3 1136 DBG.printf("no nodes from server\r\n");
arsenalist 40:77bd44f57ad3 1137 }
arsenalist 40:77bd44f57ad3 1138
arsenalist 40:77bd44f57ad3 1139 //define thread
arsenalist 40:77bd44f57ad3 1140 osThreadDef(energyThread, osPriorityBelowNormal, (8*DEFAULT_STACK_SIZE));
arsenalist 40:77bd44f57ad3 1141 //create thread
arsenalist 40:77bd44f57ad3 1142 osThreadCreate(osThread(energyThread),NULL);
arsenalist 40:77bd44f57ad3 1143
arsenalist 40:77bd44f57ad3 1144 tPanelEnergy.start();
arsenalist 40:77bd44f57ad3 1145 tPanel.start();
arsenalist 40:77bd44f57ad3 1146 tNodes.start();
arsenalist 40:77bd44f57ad3 1147 wait(1);
arsenalist 40:77bd44f57ad3 1148 while(1) {
arsenalist 40:77bd44f57ad3 1149 //checkVoltagePower(); //need revision to support ethernet
arsenalist 40:77bd44f57ad3 1150
arsenalist 40:77bd44f57ad3 1151 //panelEnergy, panelVoltage, and panelPower
arsenalist 40:77bd44f57ad3 1152 if(tPanelEnergy.read() > 30.0f) {
arsenalist 40:77bd44f57ad3 1153 DBG.printf("[%d]WattHR for each phase: %.2f, %.2f, %.2f\r\n", loop, AWattHr, BWattHr, CWattHr);
arsenalist 40:77bd44f57ad3 1154 TFT.locate(0,60);
arsenalist 40:77bd44f57ad3 1155 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1156 TFT.locate(0,60);
arsenalist 40:77bd44f57ad3 1157 TFT.printf("[%d]WHR: %.1f, %.1f, %.1f", loop, AWattHr, BWattHr, CWattHr);
arsenalist 40:77bd44f57ad3 1158
arsenalist 40:77bd44f57ad3 1159 DBG.printf("VRMS for each phase: %.2f, %.2f, %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist 40:77bd44f57ad3 1160 TFT.locate(0,80);
arsenalist 40:77bd44f57ad3 1161 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1162 TFT.locate(0,80);
arsenalist 40:77bd44f57ad3 1163 TFT.printf("VRMS: %.1f, %.1f, %.1f", AVrms, BVrms, CVrms);
arsenalist 40:77bd44f57ad3 1164
arsenalist 40:77bd44f57ad3 1165 DBG.printf("Watt for each phase: %.2f, %.2f, %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist 40:77bd44f57ad3 1166 TFT.locate(0,100);
arsenalist 40:77bd44f57ad3 1167 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1168 TFT.locate(0,100);
arsenalist 40:77bd44f57ad3 1169 TFT.printf("Watt: %.1f, %.1f, %.1f", AWatt, BWatt, CWatt);
arsenalist 40:77bd44f57ad3 1170
arsenalist 40:77bd44f57ad3 1171 if(newEnergyData) {
arsenalist 40:77bd44f57ad3 1172 //for(int i=1; i<4; i++) {
arsenalist 40:77bd44f57ad3 1173 for(int i=1; i<2; i++) {
arsenalist 40:77bd44f57ad3 1174 DBG.printf("sending channel: %d\r\n",i);
arsenalist 40:77bd44f57ad3 1175 if(i==1){
arsenalist 40:77bd44f57ad3 1176 XWattHr = AWattHr;
arsenalist 40:77bd44f57ad3 1177 XVrms = AVrms;
arsenalist 40:77bd44f57ad3 1178 XWatt = AWatt;
arsenalist 40:77bd44f57ad3 1179 } else if(i==2) {
arsenalist 40:77bd44f57ad3 1180 XWattHr = BWattHr;
arsenalist 40:77bd44f57ad3 1181 XVrms = BVrms;
arsenalist 40:77bd44f57ad3 1182 XWatt = BWatt;
arsenalist 40:77bd44f57ad3 1183 } else {
arsenalist 40:77bd44f57ad3 1184 XWattHr = CWattHr;
arsenalist 40:77bd44f57ad3 1185 XVrms = CVrms;
arsenalist 40:77bd44f57ad3 1186 XWatt = CWatt;
arsenalist 40:77bd44f57ad3 1187 }
arsenalist 40:77bd44f57ad3 1188
arsenalist 40:77bd44f57ad3 1189 if(XWattHr != 0.0f) {
arsenalist 40:77bd44f57ad3 1190 seconds = time(NULL);
arsenalist 40:77bd44f57ad3 1191 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 40:77bd44f57ad3 1192
arsenalist 40:77bd44f57ad3 1193 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 40:77bd44f57ad3 1194 hmacTime = calculateMD5(p);
arsenalist 40:77bd44f57ad3 1195
arsenalist 40:77bd44f57ad3 1196 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"energy\":%.2f,\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 40:77bd44f57ad3 1197 emmaUID.c_str(),hmacTime.c_str(),q,XWattHr,XVrms,XWatt);
arsenalist 46:86a0c2133130 1198 sprintf(s,"POST /%s/api/controller/energy/%d HTTP/1.0\nHost:%s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),i,restSERVER.c_str(),connBodyLen,connBody);
arsenalist 40:77bd44f57ad3 1199
arsenalist 46:86a0c2133130 1200 //DBG.printf("dataEnergy:\r\n%s\r\n",connBody);
arsenalist 40:77bd44f57ad3 1201
arsenalist 40:77bd44f57ad3 1202 str.clear();
arsenalist 40:77bd44f57ad3 1203 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 46:86a0c2133130 1204 str = ethREST(restSERVER,connPort,s);
arsenalist 46:86a0c2133130 1205 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 46:86a0c2133130 1206
arsenalist 40:77bd44f57ad3 1207 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 40:77bd44f57ad3 1208 //logging purpose
arsenalist 40:77bd44f57ad3 1209 seconds = time(NULL);
arsenalist 40:77bd44f57ad3 1210 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 40:77bd44f57ad3 1211 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData success"));
arsenalist 40:77bd44f57ad3 1212
arsenalist 40:77bd44f57ad3 1213 DBG.printf("send channel: %d success\r\n",i);
arsenalist 40:77bd44f57ad3 1214 TFT.foreground(Green);
arsenalist 40:77bd44f57ad3 1215 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1216 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1217 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1218 TFT.printf("send ch%d success",i);
arsenalist 40:77bd44f57ad3 1219 wait(1);
arsenalist 40:77bd44f57ad3 1220 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1221 TFT.printf(" ");
arsenalist 44:c1d11c491237 1222 TFT.foreground(White);
arsenalist 40:77bd44f57ad3 1223 } else {
arsenalist 40:77bd44f57ad3 1224 //logging purpose
arsenalist 40:77bd44f57ad3 1225 seconds = time(NULL);
arsenalist 40:77bd44f57ad3 1226 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 40:77bd44f57ad3 1227 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData failed"));
arsenalist 40:77bd44f57ad3 1228
arsenalist 40:77bd44f57ad3 1229 DBG.printf("send channel: %d failed\r\n",i);
arsenalist 40:77bd44f57ad3 1230 TFT.foreground(Red);
arsenalist 40:77bd44f57ad3 1231 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1232 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1233 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1234 TFT.printf("send ch%d failed",i);
arsenalist 40:77bd44f57ad3 1235 wait(1);
arsenalist 40:77bd44f57ad3 1236 TFT.locate(0,120);
arsenalist 40:77bd44f57ad3 1237 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1238 TFT.foreground(White);
arsenalist 40:77bd44f57ad3 1239 }
arsenalist 40:77bd44f57ad3 1240 }
arsenalist 40:77bd44f57ad3 1241 }
arsenalist 40:77bd44f57ad3 1242 newEnergyData = false;
arsenalist 40:77bd44f57ad3 1243 }
arsenalist 40:77bd44f57ad3 1244
arsenalist 40:77bd44f57ad3 1245 tPanelEnergy.reset();
arsenalist 40:77bd44f57ad3 1246 loop++;
arsenalist 36:ed696fd1b44e 1247 }
arsenalist 40:77bd44f57ad3 1248
arsenalist 40:77bd44f57ad3 1249 //panel environment
arsenalist 46:86a0c2133130 1250 if(tPanel.read() > 900.0f) { //900.0f is 15 minutes
arsenalist 46:86a0c2133130 1251 int dTemp=0;
arsenalist 46:86a0c2133130 1252 int dHum=0;
arsenalist 46:86a0c2133130 1253 int dGas=0;
arsenalist 46:86a0c2133130 1254
arsenalist 46:86a0c2133130 1255 DBG.printf("getPanelEnvironment\r\n");
arsenalist 46:86a0c2133130 1256
arsenalist 46:86a0c2133130 1257 //get environment sensor
arsenalist 46:86a0c2133130 1258 trial=0;
arsenalist 46:86a0c2133130 1259 while(1) {
arsenalist 46:86a0c2133130 1260 if(trial>=2) { //two times trial
arsenalist 46:86a0c2133130 1261 break;
arsenalist 46:86a0c2133130 1262 }
arsenalist 46:86a0c2133130 1263 if(d.readData() == DHT11::OK) {
arsenalist 46:86a0c2133130 1264 dTemp = d.readTemperature();
arsenalist 46:86a0c2133130 1265 dHum = d.readHumidity();
arsenalist 46:86a0c2133130 1266 break;
arsenalist 46:86a0c2133130 1267 }
arsenalist 46:86a0c2133130 1268 trial++;
arsenalist 46:86a0c2133130 1269 wait(3);
arsenalist 46:86a0c2133130 1270 }
arsenalist 46:86a0c2133130 1271
arsenalist 46:86a0c2133130 1272 //send environment sensor
arsenalist 46:86a0c2133130 1273 if(dTemp!=0 && dHum!=0) {
arsenalist 46:86a0c2133130 1274 seconds = time(NULL);
arsenalist 46:86a0c2133130 1275 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 46:86a0c2133130 1276
arsenalist 46:86a0c2133130 1277 //calculate hmacTime
arsenalist 46:86a0c2133130 1278 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 46:86a0c2133130 1279 hmacTime = calculateMD5(p);
arsenalist 46:86a0c2133130 1280
arsenalist 46:86a0c2133130 1281 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"temp\":%d,\"hum\":%d,\"gas\":%d}",
arsenalist 46:86a0c2133130 1282 emmaUID.c_str(),hmacTime.c_str(),q,dTemp,dHum,dGas);
arsenalist 46:86a0c2133130 1283 sprintf(s,"POST /%s/api/controller/environment HTTP/1.0\nHost:%s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 46:86a0c2133130 1284
arsenalist 46:86a0c2133130 1285 //DBG.printf("dataEnvironment:\r\n%s\r\n",s);
arsenalist 46:86a0c2133130 1286
arsenalist 46:86a0c2133130 1287 str.clear();
arsenalist 46:86a0c2133130 1288 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 46:86a0c2133130 1289 str = ethREST(restSERVER,connPort,s);
arsenalist 46:86a0c2133130 1290 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 46:86a0c2133130 1291
arsenalist 46:86a0c2133130 1292 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 46:86a0c2133130 1293 //logging purpose
arsenalist 46:86a0c2133130 1294 seconds = time(NULL);
arsenalist 46:86a0c2133130 1295 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 46:86a0c2133130 1296 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv success"));
arsenalist 46:86a0c2133130 1297 DBG.printf("send panel environment success\r\n");
arsenalist 46:86a0c2133130 1298 } else {
arsenalist 46:86a0c2133130 1299 //logging purpose
arsenalist 46:86a0c2133130 1300 seconds = time(NULL);
arsenalist 46:86a0c2133130 1301 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 46:86a0c2133130 1302 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv failed"));
arsenalist 46:86a0c2133130 1303 DBG.printf("send panel environment failed\r\n");
arsenalist 46:86a0c2133130 1304 }
arsenalist 46:86a0c2133130 1305 }
arsenalist 46:86a0c2133130 1306 tPanel.reset();
arsenalist 46:86a0c2133130 1307 }
arsenalist 46:86a0c2133130 1308
arsenalist 46:86a0c2133130 1309 //node temp
arsenalist 46:86a0c2133130 1310 if(tNodes.read() > 60.0f) { //900 is 15 minutes
arsenalist 46:86a0c2133130 1311 DBG.printf("getNodesTemperature\r\n");
arsenalist 46:86a0c2133130 1312
arsenalist 46:86a0c2133130 1313 for(int i=0; i<NODES_MAX; i++) {
arsenalist 46:86a0c2133130 1314 if(!nodes[i].ipAddr.empty() && nodes[i].type == 1) {
arsenalist 46:86a0c2133130 1315 //get node's temp
arsenalist 46:86a0c2133130 1316 string temp;
arsenalist 46:86a0c2133130 1317 str.clear();
arsenalist 46:86a0c2133130 1318 str = ethREST(nodes[i].ipAddr,REMOTE_TCP_PORT,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist 46:86a0c2133130 1319 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 46:86a0c2133130 1320
arsenalist 46:86a0c2133130 1321 if(str.find("200 OK")) {
arsenalist 46:86a0c2133130 1322 if(str.rfind("temp=") != std::string::npos) {
arsenalist 46:86a0c2133130 1323 str.erase(str.begin(),str.begin()+str.rfind("temp=")+6);
arsenalist 46:86a0c2133130 1324 str.erase(str.begin()+str.find("\""),str.end());
arsenalist 46:86a0c2133130 1325 temp = str;
arsenalist 46:86a0c2133130 1326 } else {
arsenalist 46:86a0c2133130 1327 temp = "0"; //connect to node, but receive none
arsenalist 46:86a0c2133130 1328 }
arsenalist 46:86a0c2133130 1329 } else {
arsenalist 46:86a0c2133130 1330 temp = "0"; //not connected to node
arsenalist 46:86a0c2133130 1331 }
arsenalist 46:86a0c2133130 1332 DBG.printf("nodeTemp[%d]:%s\r\n",i,temp.c_str());
arsenalist 46:86a0c2133130 1333
arsenalist 46:86a0c2133130 1334 //send node's temp
arsenalist 46:86a0c2133130 1335 if(temp != "0") {
arsenalist 46:86a0c2133130 1336 seconds = time(NULL);
arsenalist 46:86a0c2133130 1337 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 46:86a0c2133130 1338
arsenalist 46:86a0c2133130 1339 //calculate hmacTime
arsenalist 46:86a0c2133130 1340 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 46:86a0c2133130 1341 hmacTime = calculateMD5(p);
arsenalist 46:86a0c2133130 1342
arsenalist 46:86a0c2133130 1343 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"mac\":%s,\"value\":%s}",
arsenalist 46:86a0c2133130 1344 emmaUID.c_str(),hmacTime.c_str(),q,nodes[i].macAddr.c_str(),temp.c_str());
arsenalist 46:86a0c2133130 1345 sprintf(s,"POST /%s/api/controller/nodetemp HTTP/1.0\nHost:%s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 46:86a0c2133130 1346
arsenalist 46:86a0c2133130 1347 //DBG.printf("dataNodeTemp:\r\n%s\r\n",s);
arsenalist 46:86a0c2133130 1348
arsenalist 46:86a0c2133130 1349 str.clear();
arsenalist 46:86a0c2133130 1350 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 46:86a0c2133130 1351 str = ethREST(restSERVER,connPort,s);
arsenalist 46:86a0c2133130 1352 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 46:86a0c2133130 1353
arsenalist 46:86a0c2133130 1354 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 46:86a0c2133130 1355 DBG.printf("send nodeTemp success\r\n");
arsenalist 46:86a0c2133130 1356 } else {
arsenalist 46:86a0c2133130 1357 DBG.printf("send nodeTemp failed\r\n");
arsenalist 46:86a0c2133130 1358 }
arsenalist 46:86a0c2133130 1359 }
arsenalist 46:86a0c2133130 1360 }
arsenalist 46:86a0c2133130 1361 }
arsenalist 46:86a0c2133130 1362 tNodes.reset();
arsenalist 46:86a0c2133130 1363 }
arsenalist 40:77bd44f57ad3 1364
arsenalist 44:c1d11c491237 1365 //command
arsenalist 45:2406c2b6995a 1366 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),hmac.c_str());
arsenalist 45:2406c2b6995a 1367 sprintf(s,"POST /%s/api/controller/command HTTP/1.0\nHost: %s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 45:2406c2b6995a 1368 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 45:2406c2b6995a 1369 str = ethREST(restSERVER,connPort,s);
arsenalist 45:2406c2b6995a 1370 //DBG.printf("str:%s\r\n",str.c_str());
arsenalist 45:2406c2b6995a 1371
arsenalist 45:2406c2b6995a 1372 if(str.rfind("[{\"from\"") != std::string::npos) {
arsenalist 45:2406c2b6995a 1373 str.erase(str.begin(),str.begin()+str.rfind("[{\"from\""));
arsenalist 45:2406c2b6995a 1374 if(str.find("[{") != std::string::npos && str.rfind("}]") != std::string::npos) {
arsenalist 45:2406c2b6995a 1375 str.erase(str.begin(),str.begin()+str.find("[{"));
arsenalist 45:2406c2b6995a 1376 str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist 45:2406c2b6995a 1377 }
arsenalist 45:2406c2b6995a 1378 //DBG.printf("newCommand:\r\n%s\r\n",str.c_str());
arsenalist 45:2406c2b6995a 1379 TFT.locate(0,160);
arsenalist 45:2406c2b6995a 1380 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1381 TFT.locate(0,160);
arsenalist 45:2406c2b6995a 1382 TFT.printf("newCommand");
arsenalist 45:2406c2b6995a 1383
arsenalist 45:2406c2b6995a 1384 MbedJSONValue jsonValue;
arsenalist 45:2406c2b6995a 1385 parse(jsonValue,str.c_str());
arsenalist 45:2406c2b6995a 1386 char *parameter[5] = {"from","nType","nAddr","dType","cmd"};
arsenalist 45:2406c2b6995a 1387
arsenalist 45:2406c2b6995a 1388 DBG.printf("get %d command\r\n",jsonValue.size());
arsenalist 45:2406c2b6995a 1389
arsenalist 45:2406c2b6995a 1390 //processing each command
arsenalist 45:2406c2b6995a 1391 bool validCommand;
arsenalist 45:2406c2b6995a 1392 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 45:2406c2b6995a 1393 //check whether command is valid
arsenalist 45:2406c2b6995a 1394 DBG.printf("\r\nprocessing cmd[%d]\r\n",i);
arsenalist 45:2406c2b6995a 1395 validCommand = true;
arsenalist 45:2406c2b6995a 1396 for(int j=0; j<5; j++) {
arsenalist 45:2406c2b6995a 1397 validCommand = validCommand && jsonValue[i].hasMember(parameter[j]);
arsenalist 45:2406c2b6995a 1398 }
arsenalist 45:2406c2b6995a 1399 DBG.printf("command validity:%d\r\n",validCommand);
arsenalist 45:2406c2b6995a 1400
arsenalist 45:2406c2b6995a 1401 if(validCommand) {
arsenalist 45:2406c2b6995a 1402 string commandFrom = jsonValue[i][parameter[0]].get<std::string>();
arsenalist 45:2406c2b6995a 1403 string commandNType = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 45:2406c2b6995a 1404 string commandNAddr = jsonValue[i][parameter[2]].get<std::string>();
arsenalist 45:2406c2b6995a 1405 string commandDType = jsonValue[i][parameter[3]].get<std::string>();
arsenalist 45:2406c2b6995a 1406 string commandCmd = jsonValue[i][parameter[4]].get<std::string>();
arsenalist 45:2406c2b6995a 1407
arsenalist 45:2406c2b6995a 1408 if(commandNType == "0") { //switch on panel controller
arsenalist 45:2406c2b6995a 1409 DBG.printf("command for switch\r\n");
arsenalist 45:2406c2b6995a 1410 }
arsenalist 46:86a0c2133130 1411 else if(commandNType == "1" || commandNType == "2") { //ir&rf remote control or wifi smart plug
arsenalist 45:2406c2b6995a 1412 DBG.printf("command for remote control\r\n");
arsenalist 45:2406c2b6995a 1413
arsenalist 45:2406c2b6995a 1414 //get index of node list based on mac address
arsenalist 45:2406c2b6995a 1415 int idx = NODES_INVALID;
arsenalist 45:2406c2b6995a 1416 for(int i=0; i<NODES_MAX; i++) {
arsenalist 45:2406c2b6995a 1417 if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist 45:2406c2b6995a 1418 idx = i;
arsenalist 45:2406c2b6995a 1419 }
arsenalist 45:2406c2b6995a 1420 }
arsenalist 45:2406c2b6995a 1421
arsenalist 45:2406c2b6995a 1422 //execution process
arsenalist 45:2406c2b6995a 1423 string execResult = "failed";
arsenalist 45:2406c2b6995a 1424 if(idx != NODES_INVALID) {
arsenalist 45:2406c2b6995a 1425 DBG.printf("index found at %d\r\n",idx);
arsenalist 45:2406c2b6995a 1426
arsenalist 46:86a0c2133130 1427 if(commandNType == "1"){
arsenalist 46:86a0c2133130 1428 //get cmd string based on device type and command number
arsenalist 46:86a0c2133130 1429 string nodeCmd;
arsenalist 46:86a0c2133130 1430 nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist 46:86a0c2133130 1431 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist 46:86a0c2133130 1432 } else if(commandNType == "2") {
arsenalist 46:86a0c2133130 1433 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"13\"/><app_data on-off=\"%s\"/>\r\n",commandCmd.c_str());
arsenalist 46:86a0c2133130 1434 }
arsenalist 46:86a0c2133130 1435
arsenalist 45:2406c2b6995a 1436 //execute command
arsenalist 45:2406c2b6995a 1437 DBG.printf("executing command\r\n");
arsenalist 46:86a0c2133130 1438
arsenalist 45:2406c2b6995a 1439 trial=0;
arsenalist 45:2406c2b6995a 1440 while(1) {
arsenalist 45:2406c2b6995a 1441 if(trial>=2) { //two times trial
arsenalist 45:2406c2b6995a 1442 DBG.printf("cmd is not executed\r\n");
arsenalist 45:2406c2b6995a 1443 TFT.foreground(Red);
arsenalist 45:2406c2b6995a 1444 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1445 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1446 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1447 TFT.printf("cmd is not executed");
arsenalist 45:2406c2b6995a 1448 wait(1);
arsenalist 45:2406c2b6995a 1449 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1450 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1451 TFT.foreground(White);
arsenalist 45:2406c2b6995a 1452 break;
arsenalist 45:2406c2b6995a 1453 }
arsenalist 45:2406c2b6995a 1454 str = ethREST(nodes[idx].ipAddr,REMOTE_TCP_PORT,s);
arsenalist 45:2406c2b6995a 1455 wait(2);
arsenalist 45:2406c2b6995a 1456 if(str.find("200 OK") != std::string::npos) {
arsenalist 45:2406c2b6995a 1457 DBG.printf("cmd is executed\r\n");
arsenalist 45:2406c2b6995a 1458 TFT.foreground(Green);
arsenalist 45:2406c2b6995a 1459 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1460 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1461 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1462 TFT.printf("cmd is executed");
arsenalist 45:2406c2b6995a 1463 wait(1);
arsenalist 45:2406c2b6995a 1464 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1465 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1466 TFT.foreground(White);
arsenalist 45:2406c2b6995a 1467 execResult = "success";
arsenalist 45:2406c2b6995a 1468 break;
arsenalist 45:2406c2b6995a 1469 }
arsenalist 45:2406c2b6995a 1470 str.clear();
arsenalist 45:2406c2b6995a 1471 trial++;
arsenalist 45:2406c2b6995a 1472 }
arsenalist 45:2406c2b6995a 1473 } else {
arsenalist 45:2406c2b6995a 1474 TFT.foreground(Red);
arsenalist 45:2406c2b6995a 1475 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1476 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1477 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1478 TFT.printf("node is invalid");
arsenalist 45:2406c2b6995a 1479 wait(1);
arsenalist 45:2406c2b6995a 1480 TFT.locate(0,180);
arsenalist 45:2406c2b6995a 1481 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1482 TFT.foreground(White);
arsenalist 45:2406c2b6995a 1483 }
arsenalist 45:2406c2b6995a 1484 wait(2);
arsenalist 45:2406c2b6995a 1485
arsenalist 45:2406c2b6995a 1486 //send execution result
arsenalist 45:2406c2b6995a 1487 sprintf(p,"emma-%s-%s",emmaUID.c_str(),commandCmd.c_str());
arsenalist 45:2406c2b6995a 1488 hmacCmd = calculateMD5(p);
arsenalist 45:2406c2b6995a 1489
arsenalist 45:2406c2b6995a 1490 connBodyLen = sprintf(connBody,"{\"uid\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"from\":\"%s\",\"result\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 45:2406c2b6995a 1491 emmaUID.c_str(), commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),commandFrom.c_str(),execResult.c_str(),hmacCmd.c_str());
arsenalist 45:2406c2b6995a 1492
arsenalist 45:2406c2b6995a 1493 sprintf(s,"POST /%s/api/controller/result HTTP/1.0\nHost: %s\nContent-Length:%d\n\n%s\r\n\r\n",appNAME.c_str(),restSERVER.c_str(),connBodyLen,connBody);
arsenalist 45:2406c2b6995a 1494 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 45:2406c2b6995a 1495
arsenalist 45:2406c2b6995a 1496 trial=0;
arsenalist 45:2406c2b6995a 1497 while(1) {
arsenalist 45:2406c2b6995a 1498 if(trial>=2) { //two times trial
arsenalist 45:2406c2b6995a 1499 DBG.printf("failed to send execution result\r\n");
arsenalist 45:2406c2b6995a 1500 break;
arsenalist 45:2406c2b6995a 1501 }
arsenalist 45:2406c2b6995a 1502 str = ethREST(restSERVER,connPort,s);
arsenalist 45:2406c2b6995a 1503 wait(2);
arsenalist 45:2406c2b6995a 1504 if(str.rfind("[{\"status\"") != std::string::npos) {
arsenalist 45:2406c2b6995a 1505 str.erase(str.begin(),str.begin()+str.rfind("[{\"status\""));
arsenalist 45:2406c2b6995a 1506 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 45:2406c2b6995a 1507 DBG.printf("success to send execution result\r\n");
arsenalist 45:2406c2b6995a 1508 break;
arsenalist 45:2406c2b6995a 1509 }
arsenalist 45:2406c2b6995a 1510 }
arsenalist 45:2406c2b6995a 1511 str.clear();
arsenalist 45:2406c2b6995a 1512 trial++;
arsenalist 45:2406c2b6995a 1513 }
arsenalist 45:2406c2b6995a 1514 }
arsenalist 45:2406c2b6995a 1515 }
arsenalist 45:2406c2b6995a 1516 }
arsenalist 45:2406c2b6995a 1517 //clear text on lcd
arsenalist 45:2406c2b6995a 1518 TFT.locate(0,160);
arsenalist 45:2406c2b6995a 1519 TFT.printf(" ");
arsenalist 45:2406c2b6995a 1520 }
arsenalist 40:77bd44f57ad3 1521 osDelay(5000);
arsenalist 10:1dc69e0ce7fd 1522 }
arsenalist 10:1dc69e0ce7fd 1523 } else if(wifiConnected) {
arsenalist 0:f4e449fa34d7 1524 DBG.printf("emmaModeOperation - wifi\r\n");
arsenalist 29:4d94a03d38e0 1525
arsenalist 44:c1d11c491237 1526 //new log and dbg indicator
arsenalist 29:4d94a03d38e0 1527 seconds = time(NULL);
arsenalist 29:4d94a03d38e0 1528 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 40:77bd44f57ad3 1529 DBG.printf("newLog:%d\r\n",writeLog(q,"++++++++++WiFi++++++++++"));
arsenalist 36:ed696fd1b44e 1530 //DBG.printf("newDbg:%d\r\n",writeDbg(q,"++++++++++++++++++++"));
arsenalist 0:f4e449fa34d7 1531
arsenalist 0:f4e449fa34d7 1532 //do not delete code below - indicator that esp need to MODE=B and esp.ready() to work
arsenalist 0:f4e449fa34d7 1533 //_ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 1534 //wait(1);
arsenalist 0:f4e449fa34d7 1535 //while(!esp.ready());
arsenalist 0:f4e449fa34d7 1536
arsenalist 24:5d58515ba510 1537 /*
arsenalist 0:f4e449fa34d7 1538 DBG.printf("emma: setup mqtt client\r\n");
arsenalist 0:f4e449fa34d7 1539 sprintf(mqttClientId,"emma/%s",emmaUID.c_str());
arsenalist 0:f4e449fa34d7 1540
arsenalist 38:e44f35f8129d 1541 if(mqtt.begin(mqttClientId, mqttKEY.c_str(), mqttSECRET.c_str(), 120, 1)) {
arsenalist 0:f4e449fa34d7 1542 mqtt.connectedCb.attach(&mqttConnected);
arsenalist 0:f4e449fa34d7 1543 mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist 38:e44f35f8129d 1544 mqtt.connect(mqttSERVER,mqttPORT,false);
arsenalist 13:e8adfe305dbc 1545 DBG.printf("emma: success to setup mqtt\r\n");
arsenalist 13:e8adfe305dbc 1546 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1547 TFT.printf("emma: success to setup mqtt");
arsenalist 0:f4e449fa34d7 1548 }
arsenalist 0:f4e449fa34d7 1549 DBG.printf("emma: system started\r\n");
arsenalist 24:5d58515ba510 1550 */
arsenalist 0:f4e449fa34d7 1551
arsenalist 24:5d58515ba510 1552 //t.start();
arsenalist 24:5d58515ba510 1553 //while(t.read_ms() < 5000) {
arsenalist 24:5d58515ba510 1554 // esp.process();
arsenalist 24:5d58515ba510 1555 //}
arsenalist 24:5d58515ba510 1556 //t.stop();
arsenalist 24:5d58515ba510 1557 //t.reset();
arsenalist 0:f4e449fa34d7 1558
arsenalist 0:f4e449fa34d7 1559 //set ade7758 parameter
arsenalist 44:c1d11c491237 1560 //start set beforehand
arsenalist 44:c1d11c491237 1561 /*
arsenalist 0:f4e449fa34d7 1562 ADE.begin();
arsenalist 0:f4e449fa34d7 1563
arsenalist 0:f4e449fa34d7 1564 ADE.writeRMSOffset(AIRMSOFFSET, BIRMSOFFSET, CIRMSOFFSET, AVRMSOFFSET, BVRMSOFFSET, CVRMSOFFSET);
arsenalist 0:f4e449fa34d7 1565
arsenalist 0:f4e449fa34d7 1566 ADE.write16bits(AWG, 0);
arsenalist 0:f4e449fa34d7 1567 ADE.write16bits(BWG, 0);
arsenalist 0:f4e449fa34d7 1568 ADE.write16bits(CWG, 0);
arsenalist 0:f4e449fa34d7 1569 ADE.write16bits(AVAG, 0);
arsenalist 0:f4e449fa34d7 1570 ADE.write16bits(BVAG, 0);
arsenalist 0:f4e449fa34d7 1571 ADE.write16bits(CVAG, 0);
arsenalist 44:c1d11c491237 1572 */
arsenalist 44:c1d11c491237 1573 //end start beforehand
arsenalist 0:f4e449fa34d7 1574
arsenalist 4:76ab12e2f8a3 1575 //init rest to server
arsenalist 38:e44f35f8129d 1576 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 38:e44f35f8129d 1577 if(rest.begin(restSERVER.c_str(),connPort,false)) {
arsenalist 4:76ab12e2f8a3 1578 DBG.printf("rest to server is created\r\n");
arsenalist 13:e8adfe305dbc 1579 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1580 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1581 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1582 TFT.printf("rest to server is created");
arsenalist 4:76ab12e2f8a3 1583 } else {
arsenalist 4:76ab12e2f8a3 1584 DBG.printf("rest to server is NOT created\r\n");
arsenalist 13:e8adfe305dbc 1585 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1586 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1587 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1588 TFT.printf("rest to server is NOT created");
arsenalist 4:76ab12e2f8a3 1589 }
arsenalist 4:76ab12e2f8a3 1590
arsenalist 7:7e8c6ad3fd64 1591 //check firmware update
arsenalist 7:7e8c6ad3fd64 1592
arsenalist 7:7e8c6ad3fd64 1593 //execute last state of switches on board
arsenalist 7:7e8c6ad3fd64 1594
arsenalist 7:7e8c6ad3fd64 1595 //get list of nodes from server
arsenalist 40:77bd44f57ad3 1596 /*
arsenalist 40:77bd44f57ad3 1597 //working
arsenalist 7:7e8c6ad3fd64 1598 sprintf(s,"/emma/api/controller/remotes?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist 7:7e8c6ad3fd64 1599 rest.get(s);
arsenalist 7:7e8c6ad3fd64 1600 for(int i=0; i<sizeof(s); i++) {
arsenalist 7:7e8c6ad3fd64 1601 s[i]=0; }
arsenalist 7:7e8c6ad3fd64 1602 rest.getResponse(s,sizeof(s));
arsenalist 7:7e8c6ad3fd64 1603 str = s;
arsenalist 7:7e8c6ad3fd64 1604 if(str.rfind("[{\"mac\"") != std::string::npos) {
arsenalist 7:7e8c6ad3fd64 1605 DBG.printf("get nodes from server\r\n");
arsenalist 7:7e8c6ad3fd64 1606 str.erase(str.begin(),str.begin()+str.rfind("[{\"mac\""));
arsenalist 7:7e8c6ad3fd64 1607 str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist 7:7e8c6ad3fd64 1608
arsenalist 7:7e8c6ad3fd64 1609 MbedJSONValue jsonValue;
arsenalist 7:7e8c6ad3fd64 1610 parse(jsonValue,str.c_str());
arsenalist 7:7e8c6ad3fd64 1611 char *parameter[2] = {"mac","ip"};
arsenalist 7:7e8c6ad3fd64 1612
arsenalist 13:e8adfe305dbc 1613 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1614 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1615 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1616 TFT.printf("get %d nodes from server",jsonValue.size());
arsenalist 13:e8adfe305dbc 1617 wait(0.5);
arsenalist 13:e8adfe305dbc 1618 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1619 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1620
arsenalist 7:7e8c6ad3fd64 1621 //check whether nodes valid
arsenalist 7:7e8c6ad3fd64 1622 bool validNodes = true;
arsenalist 7:7e8c6ad3fd64 1623 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 7:7e8c6ad3fd64 1624 for(int j=0; j<2; j++) {
arsenalist 7:7e8c6ad3fd64 1625 validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist 7:7e8c6ad3fd64 1626 }
arsenalist 7:7e8c6ad3fd64 1627 }
arsenalist 7:7e8c6ad3fd64 1628 DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist 7:7e8c6ad3fd64 1629
arsenalist 7:7e8c6ad3fd64 1630 if(validNodes) {
arsenalist 7:7e8c6ad3fd64 1631 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 7:7e8c6ad3fd64 1632 string macValue = jsonValue[i][parameter[0]].get<std::string>();
arsenalist 7:7e8c6ad3fd64 1633 string ipValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 7:7e8c6ad3fd64 1634 nodes[i].macAddr = macValue;
arsenalist 7:7e8c6ad3fd64 1635 nodes[i].ipAddr = ipValue;
arsenalist 13:e8adfe305dbc 1636 DBG.printf("nodes[%d]mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist 13:e8adfe305dbc 1637 DBG.printf("nodes[%d]ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist 7:7e8c6ad3fd64 1638 }
arsenalist 7:7e8c6ad3fd64 1639 }
arsenalist 7:7e8c6ad3fd64 1640
arsenalist 7:7e8c6ad3fd64 1641 } else {
arsenalist 7:7e8c6ad3fd64 1642 DBG.printf("no nodes from server\r\n");
arsenalist 7:7e8c6ad3fd64 1643 }
arsenalist 40:77bd44f57ad3 1644 */
arsenalist 40:77bd44f57ad3 1645
arsenalist 40:77bd44f57ad3 1646 _ESP.attach(&rxInterrupt,Serial::RxIrq);
arsenalist 40:77bd44f57ad3 1647
arsenalist 40:77bd44f57ad3 1648 //get list of nodes from server (post)
arsenalist 43:612547648ed1 1649 sprintf(p,"/%s/api/controller/wifinodes",appNAME.c_str());
arsenalist 40:77bd44f57ad3 1650 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",emmaUID.c_str(),hmacTime.c_str());
arsenalist 40:77bd44f57ad3 1651 rest.post(p,s);
arsenalist 40:77bd44f57ad3 1652 wait(2);
arsenalist 40:77bd44f57ad3 1653 str = rxBuf;
arsenalist 40:77bd44f57ad3 1654 if(str.rfind("[{\"type\"") != std::string::npos) {
arsenalist 40:77bd44f57ad3 1655 DBG.printf("get nodes from server\r\n");
arsenalist 40:77bd44f57ad3 1656 str.erase(str.begin(),str.begin()+str.rfind("[{\"type\""));
arsenalist 40:77bd44f57ad3 1657 str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist 40:77bd44f57ad3 1658 //DBG.printf("strCrop:%s\r\n",str.c_str());
arsenalist 40:77bd44f57ad3 1659
arsenalist 40:77bd44f57ad3 1660 //start special handler
arsenalist 40:77bd44f57ad3 1661 while(1){
arsenalist 40:77bd44f57ad3 1662 if(str.find("}],") != std::string::npos) {
arsenalist 40:77bd44f57ad3 1663 str.erase(str.begin()+str.find("}],")+1,str.begin()+str.find("}],")+2);
arsenalist 40:77bd44f57ad3 1664 } else {
arsenalist 40:77bd44f57ad3 1665 break;
arsenalist 40:77bd44f57ad3 1666 }
arsenalist 40:77bd44f57ad3 1667 }
arsenalist 40:77bd44f57ad3 1668 //end special handler
arsenalist 40:77bd44f57ad3 1669
arsenalist 40:77bd44f57ad3 1670 DBG.printf("strCrop:%s\r\n",str.c_str());
arsenalist 40:77bd44f57ad3 1671
arsenalist 40:77bd44f57ad3 1672 MbedJSONValue jsonValue;
arsenalist 40:77bd44f57ad3 1673 parse(jsonValue,str.c_str());
arsenalist 40:77bd44f57ad3 1674 char *parameter[3] = {"type","mac","ip"};
arsenalist 40:77bd44f57ad3 1675
arsenalist 40:77bd44f57ad3 1676 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1677 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1678 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1679 TFT.printf("get %d nodes from server",jsonValue.size());
arsenalist 40:77bd44f57ad3 1680 wait(0.5);
arsenalist 40:77bd44f57ad3 1681 TFT.locate(0,40);
arsenalist 40:77bd44f57ad3 1682 TFT.printf(" ");
arsenalist 40:77bd44f57ad3 1683
arsenalist 40:77bd44f57ad3 1684 //check whether nodes valid
arsenalist 40:77bd44f57ad3 1685 bool validNodes = true;
arsenalist 40:77bd44f57ad3 1686 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 40:77bd44f57ad3 1687 for(int j=0; j<3; j++) {
arsenalist 40:77bd44f57ad3 1688 validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist 40:77bd44f57ad3 1689 }
arsenalist 40:77bd44f57ad3 1690 }
arsenalist 40:77bd44f57ad3 1691 DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist 40:77bd44f57ad3 1692
arsenalist 40:77bd44f57ad3 1693 if(validNodes) {
arsenalist 40:77bd44f57ad3 1694 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 40:77bd44f57ad3 1695 int typeValue = jsonValue[i][parameter[0]].get<int>();
arsenalist 40:77bd44f57ad3 1696 string macValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 40:77bd44f57ad3 1697 string ipValue = jsonValue[i][parameter[2]].get<std::string>();
arsenalist 40:77bd44f57ad3 1698 nodes[i].type = typeValue;
arsenalist 40:77bd44f57ad3 1699 nodes[i].macAddr = macValue;
arsenalist 40:77bd44f57ad3 1700 nodes[i].ipAddr = ipValue;
arsenalist 40:77bd44f57ad3 1701 DBG.printf("nodes[%d]type:%d\r\n",i,nodes[i].type);
arsenalist 40:77bd44f57ad3 1702 DBG.printf("nodes[%d]mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist 40:77bd44f57ad3 1703 DBG.printf("nodes[%d]ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist 40:77bd44f57ad3 1704 }
arsenalist 40:77bd44f57ad3 1705 }
arsenalist 40:77bd44f57ad3 1706
arsenalist 40:77bd44f57ad3 1707 } else {
arsenalist 40:77bd44f57ad3 1708 DBG.printf("no nodes from server\r\n");
arsenalist 40:77bd44f57ad3 1709 }
arsenalist 7:7e8c6ad3fd64 1710
arsenalist 24:5d58515ba510 1711 /*
arsenalist 36:ed696fd1b44e 1712 //working
arsenalist 24:5d58515ba510 1713 DBG.printf("emma: setup mqtt client\r\n");
arsenalist 24:5d58515ba510 1714 sprintf(mqttClientId,"emma/%s",emmaUID.c_str());
arsenalist 38:e44f35f8129d 1715 if(mqtt.begin(mqttClientId, mqttKEY.c_str(), mqttSECRET.c_str(), 120, 1)) {
arsenalist 24:5d58515ba510 1716 mqtt.connectedCb.attach(&mqttConnected);
arsenalist 24:5d58515ba510 1717 mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist 38:e44f35f8129d 1718 mqtt.connect(mqttSERVER,mqttPORT,false);
arsenalist 24:5d58515ba510 1719 DBG.printf("emma: success to setup mqtt\r\n");
arsenalist 24:5d58515ba510 1720 TFT.locate(0,40);
arsenalist 24:5d58515ba510 1721 TFT.printf("emma: success to setup mqtt");
arsenalist 24:5d58515ba510 1722 }
arsenalist 24:5d58515ba510 1723 DBG.printf("emma: system started\r\n");
arsenalist 24:5d58515ba510 1724
arsenalist 24:5d58515ba510 1725 t.start();
arsenalist 24:5d58515ba510 1726 while(t.read_ms() < 5000) {
arsenalist 24:5d58515ba510 1727 esp.process();
arsenalist 24:5d58515ba510 1728 }
arsenalist 24:5d58515ba510 1729 t.stop();
arsenalist 24:5d58515ba510 1730 t.reset();
arsenalist 24:5d58515ba510 1731 */
arsenalist 7:7e8c6ad3fd64 1732
arsenalist 40:77bd44f57ad3 1733 //disable UART2
arsenalist 40:77bd44f57ad3 1734 NVIC_DisableIRQ(USART2_IRQn);
arsenalist 40:77bd44f57ad3 1735
arsenalist 4:76ab12e2f8a3 1736 //init rest to remotes
arsenalist 4:76ab12e2f8a3 1737 for(int i=0; i<NODES_MAX; i++) {
arsenalist 4:76ab12e2f8a3 1738 if(!nodes[i].ipAddr.empty()) {
arsenalist 4:76ab12e2f8a3 1739 DBG.printf("restConn nodes[%d] is created\r\n",i);
arsenalist 45:2406c2b6995a 1740 nodes[i].restConn->begin(nodes[i].ipAddr.c_str(),REMOTE_TCP_PORT,false);
arsenalist 4:76ab12e2f8a3 1741 wait(1);
arsenalist 4:76ab12e2f8a3 1742 } else {
arsenalist 4:76ab12e2f8a3 1743 DBG.printf("restConn nodes[%d] is NOT created\r\n",i);
arsenalist 4:76ab12e2f8a3 1744 wait(1);
arsenalist 4:76ab12e2f8a3 1745 }
arsenalist 4:76ab12e2f8a3 1746 }
arsenalist 4:76ab12e2f8a3 1747
arsenalist 40:77bd44f57ad3 1748 //enable UART2
arsenalist 40:77bd44f57ad3 1749 NVIC_EnableIRQ(USART2_IRQn);
arsenalist 40:77bd44f57ad3 1750
arsenalist 40:77bd44f57ad3 1751 //_ESP.attach(&rxInterrupt,Serial::RxIrq);
arsenalist 4:76ab12e2f8a3 1752
arsenalist 4:76ab12e2f8a3 1753 //define thread
arsenalist 17:b3ced0e67916 1754 osThreadDef(energyThread, osPriorityBelowNormal, (8*DEFAULT_STACK_SIZE));
arsenalist 0:f4e449fa34d7 1755 //create thread
arsenalist 2:fdfdeb5fd6fd 1756 osThreadCreate(osThread(energyThread),NULL);
arsenalist 0:f4e449fa34d7 1757
arsenalist 24:5d58515ba510 1758 tPanelEnergy.start();
arsenalist 24:5d58515ba510 1759 tPanel.start();
arsenalist 4:76ab12e2f8a3 1760 tNodes.start();
arsenalist 4:76ab12e2f8a3 1761 wait(1);
arsenalist 0:f4e449fa34d7 1762 while(1) {
arsenalist 4:76ab12e2f8a3 1763 checkRxBuffer();
arsenalist 20:ea14f175bbb4 1764 checkVoltagePower();
arsenalist 20:ea14f175bbb4 1765
arsenalist 24:5d58515ba510 1766 //whether espFreeMemory occurs
arsenalist 24:5d58515ba510 1767 if(espFreeMemory) {
arsenalist 30:08d290158fa7 1768 //logging
arsenalist 27:562a95c120cc 1769 seconds = time(NULL);
arsenalist 27:562a95c120cc 1770 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1771 DBG.printf("logFreeMemory:%d\r\n",writeLog(q,rxLog.c_str()));
arsenalist 24:5d58515ba510 1772
arsenalist 27:562a95c120cc 1773 espFreeMemory = false;
arsenalist 27:562a95c120cc 1774 }
arsenalist 27:562a95c120cc 1775
arsenalist 27:562a95c120cc 1776 //whether espDHCPClientStart occurs
arsenalist 27:562a95c120cc 1777 if(espDHCPClientStart) {
arsenalist 30:08d290158fa7 1778 //logging
arsenalist 27:562a95c120cc 1779 seconds = time(NULL);
arsenalist 27:562a95c120cc 1780 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1781 DBG.printf("logDHCPClientStart:%d\r\n",writeLog(q,rxLogA.c_str()));
arsenalist 27:562a95c120cc 1782
arsenalist 27:562a95c120cc 1783 _ESP.printf("MODE=B");
arsenalist 27:562a95c120cc 1784 wait(2);
arsenalist 27:562a95c120cc 1785 espDHCPClientStart = false;
arsenalist 24:5d58515ba510 1786 }
arsenalist 24:5d58515ba510 1787
arsenalist 4:76ab12e2f8a3 1788 //panelEnergy, panelVoltage, and panelPower
arsenalist 24:5d58515ba510 1789 if(tPanelEnergy.read() > 30.0f) {
arsenalist 4:76ab12e2f8a3 1790 DBG.printf("[%d]WattHR for each phase: %.2f, %.2f, %.2f\r\n", loop, AWattHr, BWattHr, CWattHr);
arsenalist 13:e8adfe305dbc 1791 TFT.locate(0,60);
arsenalist 13:e8adfe305dbc 1792 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1793 TFT.locate(0,60);
arsenalist 13:e8adfe305dbc 1794 TFT.printf("[%d]WHR: %.1f, %.1f, %.1f", loop, AWattHr, BWattHr, CWattHr);
arsenalist 13:e8adfe305dbc 1795
arsenalist 4:76ab12e2f8a3 1796 DBG.printf("VRMS for each phase: %.2f, %.2f, %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist 13:e8adfe305dbc 1797 TFT.locate(0,80);
arsenalist 13:e8adfe305dbc 1798 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1799 TFT.locate(0,80);
arsenalist 13:e8adfe305dbc 1800 TFT.printf("VRMS: %.1f, %.1f, %.1f", AVrms, BVrms, CVrms);
arsenalist 13:e8adfe305dbc 1801
arsenalist 4:76ab12e2f8a3 1802 DBG.printf("Watt for each phase: %.2f, %.2f, %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist 13:e8adfe305dbc 1803 TFT.locate(0,100);
arsenalist 13:e8adfe305dbc 1804 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1805 TFT.locate(0,100);
arsenalist 13:e8adfe305dbc 1806 TFT.printf("Watt: %.1f, %.1f, %.1f", AWatt, BWatt, CWatt);
arsenalist 4:76ab12e2f8a3 1807
arsenalist 22:e18d361bf688 1808 if(newEnergyData) {
arsenalist 22:e18d361bf688 1809 //for(int i=1; i<4; i++) {
arsenalist 22:e18d361bf688 1810 for(int i=1; i<2; i++) {
arsenalist 22:e18d361bf688 1811 DBG.printf("sending channel: %d\r\n",i);
arsenalist 22:e18d361bf688 1812 if(i==1){
arsenalist 22:e18d361bf688 1813 XWattHr = AWattHr;
arsenalist 22:e18d361bf688 1814 XVrms = AVrms;
arsenalist 22:e18d361bf688 1815 XWatt = AWatt;
arsenalist 22:e18d361bf688 1816 } else if(i==2) {
arsenalist 22:e18d361bf688 1817 XWattHr = BWattHr;
arsenalist 22:e18d361bf688 1818 XVrms = BVrms;
arsenalist 22:e18d361bf688 1819 XWatt = BWatt;
arsenalist 22:e18d361bf688 1820 } else {
arsenalist 22:e18d361bf688 1821 XWattHr = CWattHr;
arsenalist 22:e18d361bf688 1822 XVrms = CVrms;
arsenalist 22:e18d361bf688 1823 XWatt = CWatt;
arsenalist 22:e18d361bf688 1824 }
arsenalist 24:5d58515ba510 1825
arsenalist 24:5d58515ba510 1826 if(XWattHr != 0.0f) {
arsenalist 22:e18d361bf688 1827
arsenalist 43:612547648ed1 1828 sprintf(r,"/%s/api/controller/energy/%d",appNAME.c_str(),i);
arsenalist 24:5d58515ba510 1829 seconds = time(NULL);
arsenalist 24:5d58515ba510 1830 //for(int j=0; j<sizeof(q); j++) {
arsenalist 24:5d58515ba510 1831 // q[j]=0; }
arsenalist 24:5d58515ba510 1832 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 24:5d58515ba510 1833
arsenalist 24:5d58515ba510 1834 //calculate hmacTime
arsenalist 24:5d58515ba510 1835 for(int j=0; j<sizeof(p); j++) {
arsenalist 24:5d58515ba510 1836 p[j]=0; }
arsenalist 24:5d58515ba510 1837 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 24:5d58515ba510 1838 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1839
arsenalist 24:5d58515ba510 1840 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"energy\":%.2f,\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 24:5d58515ba510 1841 emmaUID.c_str(),hmacTime.c_str(),q,XWattHr,XVrms,XWatt);
arsenalist 24:5d58515ba510 1842 //DBG.printf("dataEnergy:\r\n%s\r\n",s);
arsenalist 24:5d58515ba510 1843 rest.post(r,s);
arsenalist 24:5d58515ba510 1844 wait(2);
arsenalist 24:5d58515ba510 1845 if(rxBuf.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 27:562a95c120cc 1846 //logging purpose
arsenalist 27:562a95c120cc 1847 seconds = time(NULL);
arsenalist 27:562a95c120cc 1848 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1849 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData success"));
arsenalist 27:562a95c120cc 1850
arsenalist 24:5d58515ba510 1851 DBG.printf("send channel: %d success\r\n",i);
arsenalist 24:5d58515ba510 1852 TFT.foreground(Green);
arsenalist 24:5d58515ba510 1853 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1854 TFT.printf(" ");
arsenalist 24:5d58515ba510 1855 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1856 TFT.printf("send ch%d success",i);
arsenalist 24:5d58515ba510 1857 wait(1);
arsenalist 24:5d58515ba510 1858 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1859 TFT.printf(" ");
arsenalist 24:5d58515ba510 1860 TFT.foreground(White);
arsenalist 24:5d58515ba510 1861 } else {
arsenalist 27:562a95c120cc 1862 //logging purpose
arsenalist 27:562a95c120cc 1863 seconds = time(NULL);
arsenalist 27:562a95c120cc 1864 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1865 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData failed"));
arsenalist 27:562a95c120cc 1866
arsenalist 24:5d58515ba510 1867 DBG.printf("send channel: %d failed\r\n",i);
arsenalist 24:5d58515ba510 1868 TFT.foreground(Red);
arsenalist 24:5d58515ba510 1869 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1870 TFT.printf(" ");
arsenalist 24:5d58515ba510 1871 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1872 TFT.printf("send ch%d failed",i);
arsenalist 24:5d58515ba510 1873 wait(1);
arsenalist 24:5d58515ba510 1874 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1875 TFT.printf(" ");
arsenalist 24:5d58515ba510 1876 TFT.foreground(White);
arsenalist 24:5d58515ba510 1877 }
arsenalist 22:e18d361bf688 1878 }
arsenalist 4:76ab12e2f8a3 1879 }
arsenalist 22:e18d361bf688 1880
arsenalist 22:e18d361bf688 1881 newEnergyData = false;
arsenalist 0:f4e449fa34d7 1882 }
arsenalist 22:e18d361bf688 1883
arsenalist 24:5d58515ba510 1884 tPanelEnergy.reset();
arsenalist 4:76ab12e2f8a3 1885 loop++;
arsenalist 0:f4e449fa34d7 1886 }
arsenalist 0:f4e449fa34d7 1887
arsenalist 21:33bd8b82560f 1888 //panel environment
arsenalist 5:d00233dd36f5 1889 checkRxBuffer();
arsenalist 25:36c6a5db50ed 1890 if(tPanel.read() > 900.0f) { //900 is 15 minutes
arsenalist 21:33bd8b82560f 1891 int dTemp=0;
arsenalist 21:33bd8b82560f 1892 int dHum=0;
arsenalist 21:33bd8b82560f 1893 int dGas=0;
arsenalist 21:33bd8b82560f 1894
arsenalist 21:33bd8b82560f 1895 DBG.printf("getPanelEnvironment\r\n");
arsenalist 21:33bd8b82560f 1896
arsenalist 21:33bd8b82560f 1897 //get environment sensor
arsenalist 21:33bd8b82560f 1898 trial=0;
arsenalist 21:33bd8b82560f 1899 while(1) {
arsenalist 21:33bd8b82560f 1900 if(trial>=2) { //two times trial
arsenalist 21:33bd8b82560f 1901 break;
arsenalist 21:33bd8b82560f 1902 }
arsenalist 21:33bd8b82560f 1903 if(d.readData() == DHT11::OK) {
arsenalist 21:33bd8b82560f 1904 dTemp = d.readTemperature();
arsenalist 21:33bd8b82560f 1905 dHum = d.readHumidity();
arsenalist 21:33bd8b82560f 1906 break;
arsenalist 21:33bd8b82560f 1907 }
arsenalist 21:33bd8b82560f 1908 trial++;
arsenalist 21:33bd8b82560f 1909 wait(3);
arsenalist 21:33bd8b82560f 1910 }
arsenalist 21:33bd8b82560f 1911
arsenalist 21:33bd8b82560f 1912 //send environment sensor
arsenalist 24:5d58515ba510 1913 if(dTemp!=0 && dHum!=0) {
arsenalist 24:5d58515ba510 1914 seconds = time(NULL);
arsenalist 24:5d58515ba510 1915 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 22:e18d361bf688 1916
arsenalist 24:5d58515ba510 1917 //calculate hmacTime
arsenalist 24:5d58515ba510 1918 for(int j=0; j<sizeof(p); j++) {
arsenalist 24:5d58515ba510 1919 p[j]=0; }
arsenalist 24:5d58515ba510 1920 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 24:5d58515ba510 1921 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1922
arsenalist 24:5d58515ba510 1923 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"temp\":%d,\"hum\":%d,\"gas\":%d}",
arsenalist 24:5d58515ba510 1924 emmaUID.c_str(),hmacTime.c_str(),q,dTemp,dHum,dGas);
arsenalist 24:5d58515ba510 1925 //DBG.printf("dataEnvironment:\r\n%s\r\n",s);
arsenalist 43:612547648ed1 1926 sprintf(p,"/%s/api/controller/environment",appNAME.c_str());
arsenalist 43:612547648ed1 1927 rest.post(p,s);
arsenalist 43:612547648ed1 1928 //rest.post("/emma/api/controller/environment",s); //working
arsenalist 24:5d58515ba510 1929 wait(2);
arsenalist 24:5d58515ba510 1930 str = rxBuf;
arsenalist 24:5d58515ba510 1931 if(str.rfind("/environment") != std::string::npos) {
arsenalist 24:5d58515ba510 1932 str.erase(str.begin(),str.begin()+str.rfind("/environment"));
arsenalist 24:5d58515ba510 1933 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 27:562a95c120cc 1934 //logging purpose
arsenalist 27:562a95c120cc 1935 seconds = time(NULL);
arsenalist 27:562a95c120cc 1936 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1937 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv success"));
arsenalist 24:5d58515ba510 1938 DBG.printf("send panel environment success\r\n");
arsenalist 24:5d58515ba510 1939 } else {
arsenalist 27:562a95c120cc 1940 //logging purpose
arsenalist 27:562a95c120cc 1941 seconds = time(NULL);
arsenalist 27:562a95c120cc 1942 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1943 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv failed"));
arsenalist 24:5d58515ba510 1944 DBG.printf("send panel environment failed\r\n");
arsenalist 24:5d58515ba510 1945 }
arsenalist 21:33bd8b82560f 1946 }
arsenalist 24:5d58515ba510 1947 checkRxBuffer();
arsenalist 21:33bd8b82560f 1948 }
arsenalist 21:33bd8b82560f 1949 tPanel.reset();
arsenalist 21:33bd8b82560f 1950 }
arsenalist 21:33bd8b82560f 1951
arsenalist 0:f4e449fa34d7 1952 //nodeTemp
arsenalist 21:33bd8b82560f 1953 checkRxBuffer();
arsenalist 25:36c6a5db50ed 1954 if(tNodes.read() > 900.0f) { //900 is 15 minutes
arsenalist 5:d00233dd36f5 1955 DBG.printf("getNodesTemperature\r\n");
arsenalist 5:d00233dd36f5 1956
arsenalist 5:d00233dd36f5 1957 for(int i=0; i<NODES_MAX; i++) {
arsenalist 5:d00233dd36f5 1958 if(!nodes[i].ipAddr.empty()) {
arsenalist 5:d00233dd36f5 1959 //get node's temp
arsenalist 5:d00233dd36f5 1960 string temp;
arsenalist 5:d00233dd36f5 1961 nodes[i].restConn->get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist 5:d00233dd36f5 1962 wait(2);
arsenalist 5:d00233dd36f5 1963 temp = rxBuf;
arsenalist 5:d00233dd36f5 1964 if(temp.rfind(nodes[i].ipAddr) != std::string::npos) {
arsenalist 5:d00233dd36f5 1965 temp.erase(temp.begin(),temp.begin()+temp.rfind(nodes[i].ipAddr));
arsenalist 5:d00233dd36f5 1966 if(temp.rfind("temp=") != std::string::npos) {
arsenalist 5:d00233dd36f5 1967 temp.erase(temp.begin(),temp.begin()+temp.rfind("temp=")+6);
arsenalist 5:d00233dd36f5 1968 temp.erase(temp.begin()+temp.find("\""),temp.end());
arsenalist 5:d00233dd36f5 1969 } else {
arsenalist 5:d00233dd36f5 1970 temp = "0"; //connect to node, but receive none
arsenalist 5:d00233dd36f5 1971 }
arsenalist 5:d00233dd36f5 1972 } else {
arsenalist 5:d00233dd36f5 1973 temp = "0"; //not connected to node
arsenalist 5:d00233dd36f5 1974 }
arsenalist 0:f4e449fa34d7 1975
arsenalist 5:d00233dd36f5 1976 DBG.printf("nodeTemp[%d]:%s\r\n",i,temp.c_str());
arsenalist 5:d00233dd36f5 1977
arsenalist 5:d00233dd36f5 1978 //send node's temp
arsenalist 25:36c6a5db50ed 1979 if(temp != "0") {
arsenalist 25:36c6a5db50ed 1980 seconds = time(NULL);
arsenalist 25:36c6a5db50ed 1981 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 22:e18d361bf688 1982
arsenalist 25:36c6a5db50ed 1983 //calculate hmacTime
arsenalist 25:36c6a5db50ed 1984 for(int j=0; j<sizeof(p); j++) {
arsenalist 25:36c6a5db50ed 1985 p[j]=0; }
arsenalist 25:36c6a5db50ed 1986 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 25:36c6a5db50ed 1987 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1988
arsenalist 25:36c6a5db50ed 1989 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"mac\":\"%s\",\"value\":%s}",
arsenalist 25:36c6a5db50ed 1990 emmaUID.c_str(),hmacTime.c_str(),q,nodes[i].macAddr.c_str(),temp.c_str());
arsenalist 25:36c6a5db50ed 1991 //DBG.printf("dataNodeTemp:\r\n%s\r\n",s);
arsenalist 43:612547648ed1 1992 sprintf(p,"/%s/api/controller/nodetemp",appNAME.c_str());
arsenalist 43:612547648ed1 1993 rest.post(p,s);
arsenalist 43:612547648ed1 1994 //rest.post("/emma/api/controller/nodetemp",s); //working
arsenalist 25:36c6a5db50ed 1995 wait(2);
arsenalist 25:36c6a5db50ed 1996 str = rxBuf;
arsenalist 25:36c6a5db50ed 1997 if(str.rfind("/nodetemp") != std::string::npos) {
arsenalist 25:36c6a5db50ed 1998 str.erase(str.begin(),str.begin()+str.rfind("/nodetemp"));
arsenalist 25:36c6a5db50ed 1999 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 25:36c6a5db50ed 2000 DBG.printf("send nodeTemp success\r\n");
arsenalist 25:36c6a5db50ed 2001 } else {
arsenalist 25:36c6a5db50ed 2002 DBG.printf("send nodeTemp failed\r\n");
arsenalist 25:36c6a5db50ed 2003 }
arsenalist 5:d00233dd36f5 2004 }
arsenalist 25:36c6a5db50ed 2005 checkRxBuffer();
arsenalist 5:d00233dd36f5 2006 }
arsenalist 5:d00233dd36f5 2007 }
arsenalist 0:f4e449fa34d7 2008 }
arsenalist 19:7e3e9332f719 2009 tNodes.reset();
arsenalist 19:7e3e9332f719 2010 }
arsenalist 21:33bd8b82560f 2011
arsenalist 21:33bd8b82560f 2012 //command
arsenalist 43:612547648ed1 2013 sprintf(r,"/%s/api/controller/command",appNAME.c_str());
arsenalist 40:77bd44f57ad3 2014 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 44:c1d11c491237 2015 emmaUID.c_str(),hmacTime.c_str()); //INI HARUSNYA HMAC BUKAN?
arsenalist 40:77bd44f57ad3 2016 //rest.get("/emma/api/controller/command");
arsenalist 40:77bd44f57ad3 2017 rest.post(r,s);
arsenalist 40:77bd44f57ad3 2018
arsenalist 5:d00233dd36f5 2019 checkRxBuffer();
arsenalist 0:f4e449fa34d7 2020 if(newCommand) {
arsenalist 42:b32e51a374c7 2021 //DBG.printf("newCommand:\r\n%s\r\n",globalCommand.c_str());
arsenalist 13:e8adfe305dbc 2022 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 2023 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2024 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 2025 TFT.printf("newCommand");
arsenalist 13:e8adfe305dbc 2026
arsenalist 0:f4e449fa34d7 2027 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 2028 parse(jsonValue,globalCommand.c_str());
arsenalist 40:77bd44f57ad3 2029 char *parameter[5] = {"from","nType","nAddr","dType","cmd"};
arsenalist 0:f4e449fa34d7 2030
arsenalist 41:2d023bd80a9c 2031 DBG.printf("get %d command\r\n",jsonValue.size());
arsenalist 41:2d023bd80a9c 2032
arsenalist 41:2d023bd80a9c 2033 //processing each command
arsenalist 41:2d023bd80a9c 2034 bool validCommand;
arsenalist 41:2d023bd80a9c 2035 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 41:2d023bd80a9c 2036 //check whether command is valid
arsenalist 41:2d023bd80a9c 2037 DBG.printf("\r\nprocessing cmd[%d]\r\n",i);
arsenalist 41:2d023bd80a9c 2038 validCommand = true;
arsenalist 41:2d023bd80a9c 2039 for(int j=0; j<5; j++) {
arsenalist 41:2d023bd80a9c 2040 validCommand = validCommand && jsonValue[i].hasMember(parameter[j]);
arsenalist 41:2d023bd80a9c 2041 }
arsenalist 41:2d023bd80a9c 2042 DBG.printf("command validity:%d\r\n",validCommand);
arsenalist 41:2d023bd80a9c 2043
arsenalist 41:2d023bd80a9c 2044 if(validCommand) {
arsenalist 41:2d023bd80a9c 2045 string commandFrom = jsonValue[i][parameter[0]].get<std::string>();
arsenalist 41:2d023bd80a9c 2046 string commandNType = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 41:2d023bd80a9c 2047 string commandNAddr = jsonValue[i][parameter[2]].get<std::string>();
arsenalist 41:2d023bd80a9c 2048 string commandDType = jsonValue[i][parameter[3]].get<std::string>();
arsenalist 41:2d023bd80a9c 2049 string commandCmd = jsonValue[i][parameter[4]].get<std::string>();
arsenalist 41:2d023bd80a9c 2050
arsenalist 41:2d023bd80a9c 2051 if(commandNType == "0") { //switch on panel controller
arsenalist 41:2d023bd80a9c 2052 DBG.printf("command for switch\r\n");
arsenalist 41:2d023bd80a9c 2053 }
arsenalist 42:b32e51a374c7 2054 else if(commandNType == "1") { //ir&rf remote control
arsenalist 42:b32e51a374c7 2055 DBG.printf("command for remote control\r\n");
arsenalist 41:2d023bd80a9c 2056 //get node ip address based on node mac address
arsenalist 41:2d023bd80a9c 2057 //string nodeIP;
arsenalist 41:2d023bd80a9c 2058 //nodeIp = readNodeIP(commandNAddr);
arsenalist 41:2d023bd80a9c 2059 //nodeIP = "192.168.2.15";
arsenalist 41:2d023bd80a9c 2060 //DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist 41:2d023bd80a9c 2061
arsenalist 41:2d023bd80a9c 2062 //get index of node list based on mac address
arsenalist 41:2d023bd80a9c 2063 int idx = NODES_INVALID;
arsenalist 41:2d023bd80a9c 2064 for(int i=0; i<NODES_MAX; i++) {
arsenalist 41:2d023bd80a9c 2065 if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist 41:2d023bd80a9c 2066 idx = i;
arsenalist 41:2d023bd80a9c 2067 }
arsenalist 41:2d023bd80a9c 2068 }
arsenalist 41:2d023bd80a9c 2069
arsenalist 41:2d023bd80a9c 2070 //execution process
arsenalist 41:2d023bd80a9c 2071 string execResult = "failed";
arsenalist 41:2d023bd80a9c 2072 if(idx != NODES_INVALID) {
arsenalist 41:2d023bd80a9c 2073 DBG.printf("index found at %d\r\n",idx);
arsenalist 41:2d023bd80a9c 2074
arsenalist 41:2d023bd80a9c 2075 //get cmd string based on device type and command number
arsenalist 41:2d023bd80a9c 2076 string nodeCmd;
arsenalist 41:2d023bd80a9c 2077 nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist 41:2d023bd80a9c 2078
arsenalist 41:2d023bd80a9c 2079 //execute command
arsenalist 41:2d023bd80a9c 2080 DBG.printf("executing command\r\n");
arsenalist 41:2d023bd80a9c 2081 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist 41:2d023bd80a9c 2082
arsenalist 41:2d023bd80a9c 2083 trial=0;
arsenalist 41:2d023bd80a9c 2084 while(1) {
arsenalist 41:2d023bd80a9c 2085 rxBuf.clear();
arsenalist 41:2d023bd80a9c 2086 if(trial>=2) { //two times trial
arsenalist 41:2d023bd80a9c 2087 DBG.printf("cmd is not executed\r\n");
arsenalist 41:2d023bd80a9c 2088 TFT.foreground(Red);
arsenalist 41:2d023bd80a9c 2089 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2090 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2091 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2092 TFT.printf("cmd is not executed");
arsenalist 41:2d023bd80a9c 2093 wait(1);
arsenalist 41:2d023bd80a9c 2094 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2095 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2096 TFT.foreground(White);
arsenalist 41:2d023bd80a9c 2097 break;
arsenalist 41:2d023bd80a9c 2098 }
arsenalist 41:2d023bd80a9c 2099 nodes[idx].restConn->get("/",s);
arsenalist 41:2d023bd80a9c 2100 wait(2);
arsenalist 41:2d023bd80a9c 2101 if(rxBuf.find("REST: status = 200") != std::string::npos) {
arsenalist 41:2d023bd80a9c 2102 DBG.printf("cmd is executed\r\n");
arsenalist 41:2d023bd80a9c 2103 TFT.foreground(Green);
arsenalist 41:2d023bd80a9c 2104 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2105 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2106 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2107 TFT.printf("cmd is executed");
arsenalist 41:2d023bd80a9c 2108 wait(1);
arsenalist 41:2d023bd80a9c 2109 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2110 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2111 TFT.foreground(White);
arsenalist 41:2d023bd80a9c 2112 execResult = "success";
arsenalist 41:2d023bd80a9c 2113 break;
arsenalist 41:2d023bd80a9c 2114 }
arsenalist 41:2d023bd80a9c 2115 trial++;
arsenalist 41:2d023bd80a9c 2116 }
arsenalist 41:2d023bd80a9c 2117 } else {
arsenalist 41:2d023bd80a9c 2118 TFT.foreground(Red);
arsenalist 41:2d023bd80a9c 2119 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2120 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2121 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2122 TFT.printf("node is invalid");
arsenalist 41:2d023bd80a9c 2123 wait(1);
arsenalist 41:2d023bd80a9c 2124 TFT.locate(0,180);
arsenalist 41:2d023bd80a9c 2125 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2126 TFT.foreground(White);
arsenalist 41:2d023bd80a9c 2127 }
arsenalist 41:2d023bd80a9c 2128
arsenalist 41:2d023bd80a9c 2129 wait(2);
arsenalist 41:2d023bd80a9c 2130 //send execution result
arsenalist 41:2d023bd80a9c 2131 //DBG.printf("send execution result\r\n");
arsenalist 41:2d023bd80a9c 2132
arsenalist 41:2d023bd80a9c 2133 //calculate hmacCmd
arsenalist 41:2d023bd80a9c 2134 //for(int j=0; j<sizeof(p); j++) {
arsenalist 41:2d023bd80a9c 2135 // p[j]=0; }
arsenalist 41:2d023bd80a9c 2136 sprintf(p,"emma-%s-%s",emmaUID.c_str(),commandCmd.c_str());
arsenalist 41:2d023bd80a9c 2137 hmacCmd = calculateMD5(p);
arsenalist 41:2d023bd80a9c 2138
arsenalist 41:2d023bd80a9c 2139 sprintf(s,"{\"uid\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"from\":\"%s\",\"result\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 41:2d023bd80a9c 2140 emmaUID.c_str(), commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),commandFrom.c_str(),execResult.c_str(),hmacCmd.c_str());
arsenalist 41:2d023bd80a9c 2141
arsenalist 41:2d023bd80a9c 2142 trial=0;
arsenalist 41:2d023bd80a9c 2143 while(1) {
arsenalist 41:2d023bd80a9c 2144 if(trial>=2) { //two times trial
arsenalist 41:2d023bd80a9c 2145 DBG.printf("failed to send execution result\r\n");
arsenalist 41:2d023bd80a9c 2146 break;
arsenalist 41:2d023bd80a9c 2147 }
arsenalist 43:612547648ed1 2148 sprintf(p,"/%s/api/controller/result",appNAME.c_str());
arsenalist 43:612547648ed1 2149 rest.post(p,s);
arsenalist 43:612547648ed1 2150 //rest.post("/emma/api/controller/result",s); //working
arsenalist 41:2d023bd80a9c 2151 wait(2);
arsenalist 41:2d023bd80a9c 2152 str = rxBuf;
arsenalist 41:2d023bd80a9c 2153 if(str.rfind("/result") != std::string::npos) {
arsenalist 41:2d023bd80a9c 2154 str.erase(str.begin(),str.begin()+str.rfind("/result"));
arsenalist 41:2d023bd80a9c 2155 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 41:2d023bd80a9c 2156 DBG.printf("success to send execution result\r\n");
arsenalist 41:2d023bd80a9c 2157 break;
arsenalist 41:2d023bd80a9c 2158 }
arsenalist 41:2d023bd80a9c 2159 }
arsenalist 42:b32e51a374c7 2160 //checkRxBuffer();
arsenalist 42:b32e51a374c7 2161 trial++;
arsenalist 42:b32e51a374c7 2162 }
arsenalist 42:b32e51a374c7 2163 } else if(commandNType == "2") { //wifi smart plug
arsenalist 42:b32e51a374c7 2164 DBG.printf("command for smart plug\r\n");
arsenalist 42:b32e51a374c7 2165
arsenalist 42:b32e51a374c7 2166 //get index of node list based on mac address
arsenalist 42:b32e51a374c7 2167 int idx = NODES_INVALID;
arsenalist 42:b32e51a374c7 2168 for(int i=0; i<NODES_MAX; i++) {
arsenalist 42:b32e51a374c7 2169 if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist 42:b32e51a374c7 2170 idx = i;
arsenalist 42:b32e51a374c7 2171 }
arsenalist 42:b32e51a374c7 2172 }
arsenalist 42:b32e51a374c7 2173
arsenalist 42:b32e51a374c7 2174 //execution process
arsenalist 42:b32e51a374c7 2175 string execResult = "failed";
arsenalist 42:b32e51a374c7 2176 if(idx != NODES_INVALID) {
arsenalist 42:b32e51a374c7 2177 DBG.printf("index found at %d\r\n",idx);
arsenalist 42:b32e51a374c7 2178
arsenalist 42:b32e51a374c7 2179 //execute command
arsenalist 42:b32e51a374c7 2180 DBG.printf("executing command\r\n");
arsenalist 42:b32e51a374c7 2181 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"13\"/><app_data on-off=\"%s\"/>\r\n",commandCmd.c_str());
arsenalist 42:b32e51a374c7 2182
arsenalist 42:b32e51a374c7 2183 trial=0;
arsenalist 42:b32e51a374c7 2184 while(1) {
arsenalist 42:b32e51a374c7 2185 rxBuf.clear();
arsenalist 42:b32e51a374c7 2186 if(trial>=2) { //two times trial
arsenalist 42:b32e51a374c7 2187 DBG.printf("cmd is not executed\r\n");
arsenalist 42:b32e51a374c7 2188 TFT.foreground(Red);
arsenalist 42:b32e51a374c7 2189 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2190 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2191 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2192 TFT.printf("cmd is not executed");
arsenalist 42:b32e51a374c7 2193 wait(1);
arsenalist 42:b32e51a374c7 2194 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2195 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2196 TFT.foreground(White);
arsenalist 42:b32e51a374c7 2197 break;
arsenalist 42:b32e51a374c7 2198 }
arsenalist 42:b32e51a374c7 2199 nodes[idx].restConn->get("/",s);
arsenalist 42:b32e51a374c7 2200 wait(2);
arsenalist 42:b32e51a374c7 2201 if(rxBuf.find("REST: status = 200") != std::string::npos) {
arsenalist 42:b32e51a374c7 2202 DBG.printf("cmd is executed\r\n");
arsenalist 42:b32e51a374c7 2203 TFT.foreground(Green);
arsenalist 42:b32e51a374c7 2204 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2205 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2206 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2207 TFT.printf("cmd is executed");
arsenalist 42:b32e51a374c7 2208 wait(1);
arsenalist 42:b32e51a374c7 2209 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2210 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2211 TFT.foreground(White);
arsenalist 42:b32e51a374c7 2212 execResult = "success";
arsenalist 42:b32e51a374c7 2213 break;
arsenalist 42:b32e51a374c7 2214 }
arsenalist 42:b32e51a374c7 2215 trial++;
arsenalist 42:b32e51a374c7 2216 }
arsenalist 42:b32e51a374c7 2217 } else {
arsenalist 42:b32e51a374c7 2218 TFT.foreground(Red);
arsenalist 42:b32e51a374c7 2219 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2220 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2221 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2222 TFT.printf("node is invalid");
arsenalist 42:b32e51a374c7 2223 wait(1);
arsenalist 42:b32e51a374c7 2224 TFT.locate(0,180);
arsenalist 42:b32e51a374c7 2225 TFT.printf(" ");
arsenalist 42:b32e51a374c7 2226 TFT.foreground(White);
arsenalist 42:b32e51a374c7 2227 }
arsenalist 42:b32e51a374c7 2228
arsenalist 42:b32e51a374c7 2229 wait(2);
arsenalist 42:b32e51a374c7 2230 //send execution result
arsenalist 42:b32e51a374c7 2231 //DBG.printf("send execution result\r\n");
arsenalist 42:b32e51a374c7 2232
arsenalist 42:b32e51a374c7 2233 //calculate hmacCmd
arsenalist 42:b32e51a374c7 2234 sprintf(p,"emma-%s-%s",emmaUID.c_str(),commandCmd.c_str());
arsenalist 42:b32e51a374c7 2235 hmacCmd = calculateMD5(p);
arsenalist 42:b32e51a374c7 2236
arsenalist 42:b32e51a374c7 2237 sprintf(s,"{\"uid\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"from\":\"%s\",\"result\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 42:b32e51a374c7 2238 emmaUID.c_str(), commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),commandFrom.c_str(),execResult.c_str(),hmacCmd.c_str());
arsenalist 42:b32e51a374c7 2239
arsenalist 42:b32e51a374c7 2240 trial=0;
arsenalist 42:b32e51a374c7 2241 while(1) {
arsenalist 42:b32e51a374c7 2242 if(trial>=2) { //two times trial
arsenalist 42:b32e51a374c7 2243 DBG.printf("failed to send execution result\r\n");
arsenalist 42:b32e51a374c7 2244 break;
arsenalist 42:b32e51a374c7 2245 }
arsenalist 43:612547648ed1 2246 sprintf(p,"/%s/api/controller/result",appNAME.c_str());
arsenalist 43:612547648ed1 2247 rest.post(p,s);
arsenalist 43:612547648ed1 2248 //rest.post("/emma/api/controller/result",s); //working
arsenalist 42:b32e51a374c7 2249 wait(2);
arsenalist 42:b32e51a374c7 2250 str = rxBuf;
arsenalist 42:b32e51a374c7 2251 if(str.rfind("/result") != std::string::npos) {
arsenalist 42:b32e51a374c7 2252 str.erase(str.begin(),str.begin()+str.rfind("/result"));
arsenalist 42:b32e51a374c7 2253 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 42:b32e51a374c7 2254 DBG.printf("success to send execution result\r\n");
arsenalist 42:b32e51a374c7 2255 break;
arsenalist 42:b32e51a374c7 2256 }
arsenalist 42:b32e51a374c7 2257 }
arsenalist 42:b32e51a374c7 2258 //checkRxBuffer();
arsenalist 41:2d023bd80a9c 2259 trial++;
arsenalist 41:2d023bd80a9c 2260 }
arsenalist 41:2d023bd80a9c 2261 }
arsenalist 41:2d023bd80a9c 2262 }
arsenalist 41:2d023bd80a9c 2263 }
arsenalist 41:2d023bd80a9c 2264 //clear text on lcd
arsenalist 41:2d023bd80a9c 2265 TFT.locate(0,160);
arsenalist 41:2d023bd80a9c 2266 TFT.printf(" ");
arsenalist 41:2d023bd80a9c 2267
arsenalist 41:2d023bd80a9c 2268 newCommand = false;
arsenalist 41:2d023bd80a9c 2269
arsenalist 41:2d023bd80a9c 2270 /*
arsenalist 7:7e8c6ad3fd64 2271 //check whether command is valid
arsenalist 0:f4e449fa34d7 2272 bool validCommand = true;
arsenalist 15:136526c28afb 2273 for(int i=0; i<5; i++) {
arsenalist 0:f4e449fa34d7 2274 validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist 0:f4e449fa34d7 2275 }
arsenalist 0:f4e449fa34d7 2276 DBG.printf("command validity:%d\r\n",validCommand);
arsenalist 0:f4e449fa34d7 2277
arsenalist 0:f4e449fa34d7 2278 if(validCommand) {
arsenalist 40:77bd44f57ad3 2279 string commandFrom = jsonValue[parameter[0]].get<std::string>();
arsenalist 15:136526c28afb 2280 string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist 15:136526c28afb 2281 string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist 15:136526c28afb 2282 string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist 15:136526c28afb 2283 string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist 0:f4e449fa34d7 2284
arsenalist 0:f4e449fa34d7 2285 if(commandNType == "0") { //switch on panel controller
arsenalist 0:f4e449fa34d7 2286 DBG.printf("command for switch\r\n");
arsenalist 0:f4e449fa34d7 2287 }
arsenalist 0:f4e449fa34d7 2288 else if(commandNType == "1") { //node with mac address
arsenalist 0:f4e449fa34d7 2289 DBG.printf("command for node\r\n");
arsenalist 0:f4e449fa34d7 2290 //get node ip address based on node mac address
arsenalist 5:d00233dd36f5 2291 //string nodeIP;
arsenalist 1:d314a43ae6f7 2292 //nodeIp = readNodeIP(commandNAddr);
arsenalist 5:d00233dd36f5 2293 //nodeIP = "192.168.2.15";
arsenalist 0:f4e449fa34d7 2294 //DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist 5:d00233dd36f5 2295
arsenalist 5:d00233dd36f5 2296 //get index of node list based on mac address
arsenalist 5:d00233dd36f5 2297 int idx = NODES_INVALID;
arsenalist 5:d00233dd36f5 2298 for(int i=0; i<NODES_MAX; i++) {
arsenalist 5:d00233dd36f5 2299 if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist 5:d00233dd36f5 2300 idx = i;
arsenalist 5:d00233dd36f5 2301 }
arsenalist 5:d00233dd36f5 2302 }
arsenalist 5:d00233dd36f5 2303
arsenalist 5:d00233dd36f5 2304 //execution process
arsenalist 21:33bd8b82560f 2305 //int trial;
arsenalist 15:136526c28afb 2306 string execResult = "failed";
arsenalist 5:d00233dd36f5 2307 if(idx != NODES_INVALID) {
arsenalist 5:d00233dd36f5 2308 DBG.printf("index found at %d\r\n",idx);
arsenalist 0:f4e449fa34d7 2309
arsenalist 5:d00233dd36f5 2310 //get cmd string based on device type and command number
arsenalist 5:d00233dd36f5 2311 string nodeCmd;
arsenalist 14:8287f0f5d987 2312 nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist 14:8287f0f5d987 2313 //nodeCmd = "020129A0163B161315131613153C151316131514143C153C16141414141415151315141414141514141415141414143D1514143D141415141414143D14000D"; //turn off
arsenalist 5:d00233dd36f5 2314 //DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist 0:f4e449fa34d7 2315
arsenalist 5:d00233dd36f5 2316 //execute command
arsenalist 5:d00233dd36f5 2317 DBG.printf("executing command\r\n");
arsenalist 0:f4e449fa34d7 2318 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist 0:f4e449fa34d7 2319
arsenalist 5:d00233dd36f5 2320 trial=0;
arsenalist 0:f4e449fa34d7 2321 while(1) {
arsenalist 35:b8ba2b73201b 2322 rxBuf.clear();
arsenalist 5:d00233dd36f5 2323 //cmdExecuted = false;
arsenalist 5:d00233dd36f5 2324 if(trial>=2) { //two times trial
arsenalist 0:f4e449fa34d7 2325 DBG.printf("cmd is not executed\r\n");
arsenalist 13:e8adfe305dbc 2326 TFT.foreground(Red);
arsenalist 13:e8adfe305dbc 2327 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2328 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2329 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2330 TFT.printf("cmd is not executed");
arsenalist 14:8287f0f5d987 2331 wait(1);
arsenalist 13:e8adfe305dbc 2332 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2333 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2334 TFT.foreground(White);
arsenalist 0:f4e449fa34d7 2335 break;
arsenalist 0:f4e449fa34d7 2336 }
arsenalist 5:d00233dd36f5 2337 nodes[idx].restConn->get("/",s);
arsenalist 5:d00233dd36f5 2338 wait(2);
arsenalist 35:b8ba2b73201b 2339 if(rxBuf.find("REST: status = 200") != std::string::npos) {
arsenalist 13:e8adfe305dbc 2340 DBG.printf("cmd is executed\r\n");
arsenalist 13:e8adfe305dbc 2341 TFT.foreground(Green);
arsenalist 13:e8adfe305dbc 2342 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2343 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2344 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2345 TFT.printf("cmd is executed");
arsenalist 14:8287f0f5d987 2346 wait(1);
arsenalist 13:e8adfe305dbc 2347 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 2348 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2349 TFT.foreground(White);
arsenalist 15:136526c28afb 2350 execResult = "success";
arsenalist 5:d00233dd36f5 2351 break;
arsenalist 5:d00233dd36f5 2352 }
arsenalist 0:f4e449fa34d7 2353 trial++;
arsenalist 5:d00233dd36f5 2354 }
arsenalist 14:8287f0f5d987 2355 } else {
arsenalist 14:8287f0f5d987 2356 TFT.foreground(Red);
arsenalist 14:8287f0f5d987 2357 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 2358 TFT.printf(" ");
arsenalist 14:8287f0f5d987 2359 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 2360 TFT.printf("node is invalid");
arsenalist 14:8287f0f5d987 2361 wait(1);
arsenalist 14:8287f0f5d987 2362 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 2363 TFT.printf(" ");
arsenalist 14:8287f0f5d987 2364 TFT.foreground(White);
arsenalist 5:d00233dd36f5 2365 }
arsenalist 5:d00233dd36f5 2366
arsenalist 5:d00233dd36f5 2367 wait(2);
arsenalist 5:d00233dd36f5 2368 //send execution result
arsenalist 21:33bd8b82560f 2369 //DBG.printf("send execution result\r\n");
arsenalist 23:fb369e171b7d 2370
arsenalist 23:fb369e171b7d 2371 //calculate hmacCmd
arsenalist 23:fb369e171b7d 2372 for(int j=0; j<sizeof(p); j++) {
arsenalist 23:fb369e171b7d 2373 p[j]=0; }
arsenalist 23:fb369e171b7d 2374 sprintf(p,"emma-%s-%s",emmaUID.c_str(),commandCmd.c_str());
arsenalist 23:fb369e171b7d 2375 hmacCmd = calculateMD5(p);
arsenalist 23:fb369e171b7d 2376
arsenalist 40:77bd44f57ad3 2377 sprintf(s,"{\"uid\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"from\":\"%s\",\"result\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 40:77bd44f57ad3 2378 emmaUID.c_str(), commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),commandFrom.c_str(),execResult.c_str(),hmacCmd.c_str());
arsenalist 5:d00233dd36f5 2379
arsenalist 5:d00233dd36f5 2380 trial=0;
arsenalist 5:d00233dd36f5 2381 while(1) {
arsenalist 5:d00233dd36f5 2382 if(trial>=2) { //two times trial
arsenalist 23:fb369e171b7d 2383 DBG.printf("failed to send execution result\r\n");
arsenalist 5:d00233dd36f5 2384 break;
arsenalist 0:f4e449fa34d7 2385 }
arsenalist 23:fb369e171b7d 2386 rest.post("/emma/api/controller/result",s);
arsenalist 5:d00233dd36f5 2387 wait(2);
arsenalist 23:fb369e171b7d 2388 str = rxBuf;
arsenalist 23:fb369e171b7d 2389 if(str.rfind("/result") != std::string::npos) {
arsenalist 23:fb369e171b7d 2390 str.erase(str.begin(),str.begin()+str.rfind("/result"));
arsenalist 23:fb369e171b7d 2391 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 23:fb369e171b7d 2392 DBG.printf("success to send execution result\r\n");
arsenalist 23:fb369e171b7d 2393 break;
arsenalist 23:fb369e171b7d 2394 }
arsenalist 0:f4e449fa34d7 2395 }
arsenalist 23:fb369e171b7d 2396 checkRxBuffer();
arsenalist 5:d00233dd36f5 2397 trial++;
arsenalist 0:f4e449fa34d7 2398 }
arsenalist 0:f4e449fa34d7 2399 }
arsenalist 0:f4e449fa34d7 2400 }
arsenalist 13:e8adfe305dbc 2401
arsenalist 13:e8adfe305dbc 2402 //clear text on lcd
arsenalist 13:e8adfe305dbc 2403 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 2404 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 2405
arsenalist 0:f4e449fa34d7 2406 newCommand = false;
arsenalist 41:2d023bd80a9c 2407 */
arsenalist 2:fdfdeb5fd6fd 2408 }
arsenalist 30:08d290158fa7 2409
arsenalist 4:76ab12e2f8a3 2410 osDelay(5000);
arsenalist 0:f4e449fa34d7 2411 }
arsenalist 0:f4e449fa34d7 2412 }
arsenalist 0:f4e449fa34d7 2413 }
arsenalist 0:f4e449fa34d7 2414 void emmaModeFirmwareDownload(void) {
arsenalist 0:f4e449fa34d7 2415 bool emmaGetFirmwareParam = false;
arsenalist 0:f4e449fa34d7 2416
arsenalist 0:f4e449fa34d7 2417 DBG.printf("emmaModeFirmwareDownload\r\n");
arsenalist 0:f4e449fa34d7 2418
arsenalist 0:f4e449fa34d7 2419 char s[384];
arsenalist 0:f4e449fa34d7 2420 string str;
arsenalist 0:f4e449fa34d7 2421 string connData;
arsenalist 0:f4e449fa34d7 2422 string chunk;
arsenalist 0:f4e449fa34d7 2423
arsenalist 0:f4e449fa34d7 2424 //firmware parameter
arsenalist 0:f4e449fa34d7 2425 string firmwareVer;
arsenalist 0:f4e449fa34d7 2426 string firmwareName;
arsenalist 0:f4e449fa34d7 2427 int numPart;
arsenalist 0:f4e449fa34d7 2428
arsenalist 0:f4e449fa34d7 2429 //downloading
arsenalist 0:f4e449fa34d7 2430 string firmwarePart;
arsenalist 0:f4e449fa34d7 2431 string calcMD5;
arsenalist 0:f4e449fa34d7 2432 string srvrMD5;
arsenalist 0:f4e449fa34d7 2433 bool nextPart;
arsenalist 0:f4e449fa34d7 2434
arsenalist 0:f4e449fa34d7 2435 //set wifi to mode bridge
arsenalist 0:f4e449fa34d7 2436 _ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 2437 DBG.printf("set mode bridge\r\n");
arsenalist 0:f4e449fa34d7 2438 while(1) {
arsenalist 0:f4e449fa34d7 2439 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 2440 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 2441 str = rcv;
arsenalist 0:f4e449fa34d7 2442 if(str.find("MODE=B_OK") != std::string::npos)
arsenalist 0:f4e449fa34d7 2443 break;
arsenalist 0:f4e449fa34d7 2444 }
arsenalist 0:f4e449fa34d7 2445 DBG.printf("MODE=B\r\n");
arsenalist 0:f4e449fa34d7 2446
arsenalist 0:f4e449fa34d7 2447 esp.enable();
arsenalist 0:f4e449fa34d7 2448 wait(1);
arsenalist 0:f4e449fa34d7 2449 while(!esp.ready());
arsenalist 0:f4e449fa34d7 2450
arsenalist 0:f4e449fa34d7 2451 if(!rest.begin("candra.tritronik.com",3128,false)) {
arsenalist 0:f4e449fa34d7 2452 DBG.printf("EMMA: fail to setup rest");
arsenalist 0:f4e449fa34d7 2453 while(1);
arsenalist 0:f4e449fa34d7 2454 }
arsenalist 0:f4e449fa34d7 2455
arsenalist 0:f4e449fa34d7 2456 //wifiConnected = true; //with custom firmware, panel should connect wifi automatically
arsenalist 0:f4e449fa34d7 2457 useProxy = true;
arsenalist 0:f4e449fa34d7 2458
arsenalist 0:f4e449fa34d7 2459 esp.process();
arsenalist 0:f4e449fa34d7 2460 //set connData
arsenalist 0:f4e449fa34d7 2461 if(useProxy) {
arsenalist 0:f4e449fa34d7 2462 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2463 s[i]=0; }
arsenalist 38:e44f35f8129d 2464 //sprintf(s,"http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s",restSERVER,restPORT,emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 2465 sprintf(s,"http://192.168.128.69/emmaController/firmware/firmwareParameter");
arsenalist 0:f4e449fa34d7 2466 connData = s;
arsenalist 0:f4e449fa34d7 2467 } else {
arsenalist 0:f4e449fa34d7 2468 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2469 s[i]=0; }
arsenalist 0:f4e449fa34d7 2470 //sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 2471 sprintf(s,"/emmaController/firmware/firmwareParameter");
arsenalist 0:f4e449fa34d7 2472 connData = s;
arsenalist 0:f4e449fa34d7 2473 }
arsenalist 0:f4e449fa34d7 2474
arsenalist 0:f4e449fa34d7 2475 //get parameter of firmware to be downloaded
arsenalist 0:f4e449fa34d7 2476 while(!emmaGetFirmwareParam) {
arsenalist 0:f4e449fa34d7 2477 rest.get(connData.c_str());
arsenalist 0:f4e449fa34d7 2478 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2479 s[i]=0; }
arsenalist 0:f4e449fa34d7 2480 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 2481 //DBG.printf("rsp param:%s\r\n",s);
arsenalist 0:f4e449fa34d7 2482
arsenalist 0:f4e449fa34d7 2483 str = s;
arsenalist 0:f4e449fa34d7 2484 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2485 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 2486 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 2487
arsenalist 0:f4e449fa34d7 2488 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 2489 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 2490
arsenalist 0:f4e449fa34d7 2491 char *parameter[2] = {"firmwareVer","numPart"};
arsenalist 0:f4e449fa34d7 2492
arsenalist 0:f4e449fa34d7 2493 for(int i=0; i<2; i++) {
arsenalist 0:f4e449fa34d7 2494 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 2495 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 2496 if(i==0) {
arsenalist 0:f4e449fa34d7 2497 firmwareVer = val;
arsenalist 0:f4e449fa34d7 2498 } else if(i==1) {
arsenalist 0:f4e449fa34d7 2499 sscanf(val.c_str(),"%d",&numPart);
arsenalist 0:f4e449fa34d7 2500 }
arsenalist 0:f4e449fa34d7 2501 }
arsenalist 0:f4e449fa34d7 2502 }
arsenalist 0:f4e449fa34d7 2503
arsenalist 0:f4e449fa34d7 2504 if(!firmwareVer.empty() && numPart!=0) {
arsenalist 0:f4e449fa34d7 2505 emmaGetFirmwareParam = true;
arsenalist 0:f4e449fa34d7 2506 }
arsenalist 0:f4e449fa34d7 2507 }
arsenalist 0:f4e449fa34d7 2508 }
arsenalist 0:f4e449fa34d7 2509 DBG.printf("firmwareVer:%s\r\n",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 2510 DBG.printf("numPart:%d\r\n",numPart);
arsenalist 0:f4e449fa34d7 2511
arsenalist 0:f4e449fa34d7 2512 //clear firmware file
arsenalist 0:f4e449fa34d7 2513 while(1) {
arsenalist 0:f4e449fa34d7 2514 if(clearFirmware()){
arsenalist 0:f4e449fa34d7 2515 DBG.printf("clear firmware on sd card\r\n\r\n");
arsenalist 0:f4e449fa34d7 2516 break;
arsenalist 0:f4e449fa34d7 2517 }
arsenalist 0:f4e449fa34d7 2518 wait(1);
arsenalist 0:f4e449fa34d7 2519 }
arsenalist 0:f4e449fa34d7 2520
arsenalist 0:f4e449fa34d7 2521 //set connData
arsenalist 0:f4e449fa34d7 2522 if(useProxy) {
arsenalist 0:f4e449fa34d7 2523 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2524 s[i]=0; }
arsenalist 0:f4e449fa34d7 2525 sprintf(s,"http://192.168.128.69/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 2526 connData = s;
arsenalist 0:f4e449fa34d7 2527 } else {
arsenalist 0:f4e449fa34d7 2528 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2529 s[i]=0; }
arsenalist 0:f4e449fa34d7 2530 sprintf(s,"/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 2531 connData = s;
arsenalist 0:f4e449fa34d7 2532 }
arsenalist 0:f4e449fa34d7 2533
arsenalist 0:f4e449fa34d7 2534 //download firmware
arsenalist 0:f4e449fa34d7 2535 for(int n=0; n<numPart; n++) {
arsenalist 0:f4e449fa34d7 2536 nextPart = false;
arsenalist 0:f4e449fa34d7 2537 while(!nextPart) {
arsenalist 0:f4e449fa34d7 2538 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2539 s[i]=0; }
arsenalist 0:f4e449fa34d7 2540 sprintf(s,"%s/firmware_Hex_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist 0:f4e449fa34d7 2541 rest.get(s);
arsenalist 0:f4e449fa34d7 2542 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2543 s[i]=0; }
arsenalist 0:f4e449fa34d7 2544 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 2545 //DBG.printf("rsp[%d]:%s\r\n",n,s);
arsenalist 0:f4e449fa34d7 2546
arsenalist 0:f4e449fa34d7 2547 str = s;
arsenalist 0:f4e449fa34d7 2548 if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2549 str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist 0:f4e449fa34d7 2550 str.erase(str.begin()+str.find("}"),str.end());
arsenalist 0:f4e449fa34d7 2551 //DBG.printf("firmwarePart[%d]:%s\r\n",n,str.c_str());
arsenalist 0:f4e449fa34d7 2552 firmwarePart = str;
arsenalist 0:f4e449fa34d7 2553
arsenalist 0:f4e449fa34d7 2554 //calculated MD5
arsenalist 0:f4e449fa34d7 2555 calcMD5 = calculateMD5(firmwarePart);
arsenalist 0:f4e449fa34d7 2556 //DBG.printf("calcMD5[%d]:%s\r\n",n,calcMD5.c_str());
arsenalist 0:f4e449fa34d7 2557
arsenalist 0:f4e449fa34d7 2558 //MD5 from server
arsenalist 0:f4e449fa34d7 2559 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2560 s[i]=0; }
arsenalist 0:f4e449fa34d7 2561 sprintf(s,"%s/MD5/firmware_MD5_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist 0:f4e449fa34d7 2562 rest.get(s);
arsenalist 0:f4e449fa34d7 2563 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2564 s[i]=0; }
arsenalist 0:f4e449fa34d7 2565 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 2566
arsenalist 0:f4e449fa34d7 2567 str = s;
arsenalist 0:f4e449fa34d7 2568 if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2569 str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist 0:f4e449fa34d7 2570 str.erase(str.begin()+str.find("}"),str.end());
arsenalist 0:f4e449fa34d7 2571 srvrMD5 = str;
arsenalist 0:f4e449fa34d7 2572 //DBG.printf("srvrMD5[%d]:%s\r\n",n,srvrMD5.c_str());
arsenalist 0:f4e449fa34d7 2573
arsenalist 0:f4e449fa34d7 2574 //compare original MD5 vs MD5 from server
arsenalist 0:f4e449fa34d7 2575 if(strcmp(calcMD5.c_str(),srvrMD5.c_str()) == 0) {
arsenalist 0:f4e449fa34d7 2576 //DBG.printf("MD5 correct\r\n");
arsenalist 0:f4e449fa34d7 2577
arsenalist 0:f4e449fa34d7 2578 //save to sd card
arsenalist 0:f4e449fa34d7 2579 int st = writeFirmwareHexToChar(firmwarePart);
arsenalist 0:f4e449fa34d7 2580 if(st) {
arsenalist 0:f4e449fa34d7 2581 DBG.printf("firmwarePart[%d/%d] written\r\n",n,numPart-1);
arsenalist 0:f4e449fa34d7 2582 nextPart = true;
arsenalist 0:f4e449fa34d7 2583 }
arsenalist 0:f4e449fa34d7 2584
arsenalist 0:f4e449fa34d7 2585 } else {
arsenalist 0:f4e449fa34d7 2586 DBG.printf("MD5 incorrect\r\n");
arsenalist 0:f4e449fa34d7 2587 }
arsenalist 0:f4e449fa34d7 2588 }
arsenalist 0:f4e449fa34d7 2589 } else {
arsenalist 0:f4e449fa34d7 2590 DBG.printf("retry to fetch firmwarePart[%d]\r\n",n);
arsenalist 0:f4e449fa34d7 2591 }
arsenalist 0:f4e449fa34d7 2592 wait(0.5);
arsenalist 0:f4e449fa34d7 2593 }
arsenalist 0:f4e449fa34d7 2594 }
arsenalist 0:f4e449fa34d7 2595 DBG.printf("download finished\r\n");
arsenalist 0:f4e449fa34d7 2596 }
arsenalist 44:c1d11c491237 2597
arsenalist 44:c1d11c491237 2598 void emmaModeReserved(void) {
arsenalist 44:c1d11c491237 2599 char connBody[128];
arsenalist 44:c1d11c491237 2600 char s[256];
arsenalist 46:86a0c2133130 2601 //char buf[1024];
arsenalist 44:c1d11c491237 2602 int connBodyLen;
arsenalist 44:c1d11c491237 2603 int i=0;
arsenalist 46:86a0c2133130 2604 //int ret=99;
arsenalist 44:c1d11c491237 2605 string str;
arsenalist 44:c1d11c491237 2606 Timer t;
arsenalist 45:2406c2b6995a 2607 //TCPSocketConnection sock;
arsenalist 44:c1d11c491237 2608
arsenalist 44:c1d11c491237 2609 eth.init();
arsenalist 45:2406c2b6995a 2610 eth.connect();
arsenalist 45:2406c2b6995a 2611 connBodyLen = sprintf(connBody,"{\"uid\":\"005e00553533510334313732\",\"hmac\":\"9424c60e708d8e3d3dff6d23fb104339\"}");
arsenalist 45:2406c2b6995a 2612 sprintf(s,"POST /emma/api/controller/command HTTP/1.0\nHost: 36.80.35.8\nContent-Length:%d\n\n%s\r\n\r\n",connBodyLen,connBody);
arsenalist 44:c1d11c491237 2613 while(1) {
arsenalist 44:c1d11c491237 2614 //command
arsenalist 44:c1d11c491237 2615 str.clear();
arsenalist 44:c1d11c491237 2616 str = ethREST("36.80.35.8",8080,s);
arsenalist 44:c1d11c491237 2617 DBG.printf("[%d]str:%s\r\n",i,str.c_str());
arsenalist 44:c1d11c491237 2618 i++;
arsenalist 44:c1d11c491237 2619 wait(5);
arsenalist 44:c1d11c491237 2620 }
arsenalist 44:c1d11c491237 2621
arsenalist 45:2406c2b6995a 2622 /*
arsenalist 44:c1d11c491237 2623 //start working as expected
arsenalist 44:c1d11c491237 2624 eth.init();
arsenalist 44:c1d11c491237 2625 eth.connect();
arsenalist 44:c1d11c491237 2626 connBodyLen = sprintf(connBody,"{\"uid\":\"005e00553533510334313732\",\"hmac\":\"9424c60e708d8e3d3dff6d23fb104339\"}");
arsenalist 44:c1d11c491237 2627 sprintf(s,"POST /emma/api/controller/command HTTP/1.0\nHost: 36.80.35.8\nContent-Length:%d\n\n%s\r\n\r\n",connBodyLen,connBody);
arsenalist 44:c1d11c491237 2628
arsenalist 44:c1d11c491237 2629 while(1) {
arsenalist 44:c1d11c491237 2630 //eth.connect();
arsenalist 44:c1d11c491237 2631 t.start();
arsenalist 44:c1d11c491237 2632 while(eth.linkstatus() && t.read() < 5 && ret !=0) {
arsenalist 44:c1d11c491237 2633 ret = sock.connect("36.80.35.8",8080);
arsenalist 44:c1d11c491237 2634 }
arsenalist 44:c1d11c491237 2635 t.stop();
arsenalist 44:c1d11c491237 2636 t.reset();
arsenalist 44:c1d11c491237 2637
arsenalist 44:c1d11c491237 2638 memset(buf,0,sizeof(buf));
arsenalist 44:c1d11c491237 2639 if(sock.is_connected()) {
arsenalist 44:c1d11c491237 2640 DBG.printf("connect\r\n");
arsenalist 44:c1d11c491237 2641 sock.send_all(s,sizeof(s)-1);
arsenalist 44:c1d11c491237 2642 wait(2);
arsenalist 44:c1d11c491237 2643 //receive return
arsenalist 44:c1d11c491237 2644 t.start();
arsenalist 44:c1d11c491237 2645 while(1) {
arsenalist 44:c1d11c491237 2646 ret = sock.receive(buf, sizeof(buf));
arsenalist 44:c1d11c491237 2647 if(ret<=0 || t.read() > 5) {
arsenalist 44:c1d11c491237 2648 t.stop();
arsenalist 44:c1d11c491237 2649 t.reset();
arsenalist 44:c1d11c491237 2650 break;
arsenalist 44:c1d11c491237 2651 }
arsenalist 44:c1d11c491237 2652 }
arsenalist 44:c1d11c491237 2653 sock.close();
arsenalist 44:c1d11c491237 2654 } else {
arsenalist 44:c1d11c491237 2655 DBG.printf("not connected\r\n");
arsenalist 44:c1d11c491237 2656 }
arsenalist 44:c1d11c491237 2657 //eth.disconnect();
arsenalist 44:c1d11c491237 2658 DBG.printf("[%d]BUF:%s\r\n\r\n",i,buf);
arsenalist 44:c1d11c491237 2659 i++;
arsenalist 44:c1d11c491237 2660 wait(5);
arsenalist 44:c1d11c491237 2661 }
arsenalist 44:c1d11c491237 2662 //end working as expected
arsenalist 45:2406c2b6995a 2663 */
arsenalist 44:c1d11c491237 2664 }
arsenalist 12:96f637ed37f9 2665 /*end emma mode*/
arsenalist 0:f4e449fa34d7 2666
arsenalist 4:76ab12e2f8a3 2667 /*start energy related*/
arsenalist 0:f4e449fa34d7 2668 void energyThread(void const*) {
arsenalist 19:7e3e9332f719 2669 Timer tEnergy;
arsenalist 19:7e3e9332f719 2670
arsenalist 19:7e3e9332f719 2671 while(1) {
arsenalist 19:7e3e9332f719 2672 tEnergy.start();
arsenalist 19:7e3e9332f719 2673 DBG.printf("energyThread-start\r\n");
arsenalist 19:7e3e9332f719 2674
arsenalist 19:7e3e9332f719 2675 AWattHrSum = 0;
arsenalist 19:7e3e9332f719 2676 BWattHrSum = 0;
arsenalist 19:7e3e9332f719 2677 CWattHrSum = 0;
arsenalist 19:7e3e9332f719 2678
arsenalist 20:ea14f175bbb4 2679 while(tEnergy.read() < 1*60.0) {
arsenalist 19:7e3e9332f719 2680 AWattHrValue = ADE.getWattHR(PHASE_A);
arsenalist 19:7e3e9332f719 2681 BWattHrValue = ADE.getWattHR(PHASE_B);
arsenalist 19:7e3e9332f719 2682 CWattHrValue = ADE.getWattHR(PHASE_C);
arsenalist 19:7e3e9332f719 2683
arsenalist 19:7e3e9332f719 2684 AWattHrSum += AWattHrValue;
arsenalist 19:7e3e9332f719 2685 BWattHrSum += BWattHrValue;
arsenalist 20:ea14f175bbb4 2686 CWattHrSum += CWattHrValue;
arsenalist 20:ea14f175bbb4 2687
arsenalist 20:ea14f175bbb4 2688
arsenalist 20:ea14f175bbb4 2689 //start check voltage and power
arsenalist 21:33bd8b82560f 2690 AVrms = ADE.VRMS(PHASE_A) * 0.000124f; //0.000158; //constants are from calculateVRMS function
arsenalist 21:33bd8b82560f 2691 BVrms = ADE.VRMS(PHASE_B) * 0.000123f;
arsenalist 21:33bd8b82560f 2692 CVrms = ADE.VRMS(PHASE_C) * 0.000122f;
arsenalist 20:ea14f175bbb4 2693
arsenalist 21:33bd8b82560f 2694 AIrms = ADE.IRMS(PHASE_A) * 0.00001006f; //0.0000125f; //constants are from calculateIRMS function
arsenalist 21:33bd8b82560f 2695 BIrms = ADE.IRMS(PHASE_B) * 0.00001005f;
arsenalist 21:33bd8b82560f 2696 CIrms = ADE.IRMS(PHASE_C) * 0.00001004f;
arsenalist 20:ea14f175bbb4 2697
arsenalist 20:ea14f175bbb4 2698 AWatt = AVrms * AIrms;
arsenalist 20:ea14f175bbb4 2699 BWatt = BVrms * BIrms;
arsenalist 20:ea14f175bbb4 2700 CWatt = CVrms * CIrms;
arsenalist 20:ea14f175bbb4 2701 //end check voltage and power
arsenalist 20:ea14f175bbb4 2702
arsenalist 19:7e3e9332f719 2703 }
arsenalist 19:7e3e9332f719 2704
arsenalist 25:36c6a5db50ed 2705 AWattHr = AWattHrSum * 0.000044169f; //0.0000198f;
arsenalist 25:36c6a5db50ed 2706 BWattHr = BWattHrSum * 0.000044168f; //0.0000197f;
arsenalist 25:36c6a5db50ed 2707 CWattHr = CWattHrSum * 0.000044167f; //0.0000196f;
arsenalist 19:7e3e9332f719 2708
arsenalist 22:e18d361bf688 2709 newEnergyData = true;
arsenalist 22:e18d361bf688 2710
arsenalist 19:7e3e9332f719 2711 tEnergy.stop();
arsenalist 19:7e3e9332f719 2712 tEnergy.reset();
arsenalist 19:7e3e9332f719 2713 DBG.printf("energyThread-finish\r\n");
arsenalist 19:7e3e9332f719 2714 }
arsenalist 0:f4e449fa34d7 2715 }
arsenalist 21:33bd8b82560f 2716 void checkVoltagePower(void) {
arsenalist 4:76ab12e2f8a3 2717 //check if voltage or power violates threshold
arsenalist 22:e18d361bf688 2718 char p[64];
arsenalist 20:ea14f175bbb4 2719 char q[32];
arsenalist 4:76ab12e2f8a3 2720 char s[256];
arsenalist 22:e18d361bf688 2721 string hmacTime;
arsenalist 4:76ab12e2f8a3 2722 string str;
arsenalist 20:ea14f175bbb4 2723 time_t seconds;
arsenalist 4:76ab12e2f8a3 2724
arsenalist 4:76ab12e2f8a3 2725 //DBG.printf("checkVoltagePower-start\r\n");
arsenalist 4:76ab12e2f8a3 2726
arsenalist 20:ea14f175bbb4 2727 //vrms and irms might be placed inside energy calculation routine
arsenalist 20:ea14f175bbb4 2728 /*
arsenalist 19:7e3e9332f719 2729 AVrms = ADE.VRMS(PHASE_A) * 0.000128f; //0.000158; //constants are from calculateVRMS function
arsenalist 19:7e3e9332f719 2730 BVrms = ADE.VRMS(PHASE_B) * 0.000127f; //0.000157;
arsenalist 19:7e3e9332f719 2731 CVrms = ADE.VRMS(PHASE_C) * 0.000126f; //0.000156;
arsenalist 19:7e3e9332f719 2732
arsenalist 19:7e3e9332f719 2733 AIrms = ADE.IRMS(PHASE_A) * 0.0000125f; //constants are from calculateIRMS function
arsenalist 19:7e3e9332f719 2734 BIrms = ADE.IRMS(PHASE_B) * 0.0000123f;
arsenalist 19:7e3e9332f719 2735 CIrms = ADE.IRMS(PHASE_C) * 0.0000124f;
arsenalist 4:76ab12e2f8a3 2736
arsenalist 4:76ab12e2f8a3 2737 AWatt = AVrms * AIrms;
arsenalist 4:76ab12e2f8a3 2738 BWatt = BVrms * BIrms;
arsenalist 4:76ab12e2f8a3 2739 CWatt = CVrms * CIrms;
arsenalist 20:ea14f175bbb4 2740 */
arsenalist 4:76ab12e2f8a3 2741
arsenalist 21:33bd8b82560f 2742 //DBG.printf("Vrms of each phase:%.2f - %.2f - %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist 21:33bd8b82560f 2743 //DBG.printf("Watt of each phase:%.2f - %.2f - %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist 21:33bd8b82560f 2744 //wait(1);
arsenalist 19:7e3e9332f719 2745
arsenalist 20:ea14f175bbb4 2746 //get time
arsenalist 20:ea14f175bbb4 2747 seconds = time(NULL);
arsenalist 20:ea14f175bbb4 2748 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 20:ea14f175bbb4 2749
arsenalist 22:e18d361bf688 2750 //calculate hmacTime
arsenalist 22:e18d361bf688 2751 for(int j=0; j<sizeof(p); j++) {
arsenalist 22:e18d361bf688 2752 p[j]=0; }
arsenalist 22:e18d361bf688 2753 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 22:e18d361bf688 2754 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 2755
arsenalist 4:76ab12e2f8a3 2756 if(AVrms > VRMSTHRESHOLD || AWatt > WATTTHRESHOLD) {
arsenalist 4:76ab12e2f8a3 2757 DBG.printf("alert on ch1\r\n");
arsenalist 20:ea14f175bbb4 2758 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 2759 emmaUID.c_str(),hmacTime.c_str(),q,AVrms,AWatt);
arsenalist 43:612547648ed1 2760
arsenalist 43:612547648ed1 2761 sprintf(p,"/%s/api/controller/alert/1",appNAME.c_str());
arsenalist 43:612547648ed1 2762 rest.post(p,s);
arsenalist 43:612547648ed1 2763 //rest.post("/emma/api/controller/alert/1",s); //working
arsenalist 4:76ab12e2f8a3 2764 wait(2);
arsenalist 4:76ab12e2f8a3 2765 str = rxBuf;
arsenalist 4:76ab12e2f8a3 2766 if(str.rfind("/alert/1") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2767 str.erase(str.begin(),str.begin()+str.rfind("/alert/1"));
arsenalist 4:76ab12e2f8a3 2768 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2769 DBG.printf("send alert ch1 success\r\n");
arsenalist 4:76ab12e2f8a3 2770 } else {
arsenalist 4:76ab12e2f8a3 2771 DBG.printf("send alert ch1 failed\r\n");
arsenalist 4:76ab12e2f8a3 2772 }
arsenalist 4:76ab12e2f8a3 2773 }
arsenalist 4:76ab12e2f8a3 2774 }
arsenalist 4:76ab12e2f8a3 2775
arsenalist 4:76ab12e2f8a3 2776 if(BVrms > VRMSTHRESHOLD || BWatt > WATTTHRESHOLD) {
arsenalist 4:76ab12e2f8a3 2777 DBG.printf("alert on ch2\r\n");
arsenalist 20:ea14f175bbb4 2778 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 2779 emmaUID.c_str(),hmacTime.c_str(),q,BVrms,BWatt);
arsenalist 43:612547648ed1 2780 sprintf(p,"/%s/api/controller/alert/2",appNAME.c_str());
arsenalist 43:612547648ed1 2781 rest.post(p,s);
arsenalist 43:612547648ed1 2782 //rest.post("/emma/api/controller/alert/2",s);
arsenalist 4:76ab12e2f8a3 2783 wait(2);
arsenalist 4:76ab12e2f8a3 2784 str = rxBuf;
arsenalist 4:76ab12e2f8a3 2785 if(str.rfind("/alert/2") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2786 str.erase(str.begin(),str.begin()+str.rfind("/alert/2"));
arsenalist 4:76ab12e2f8a3 2787 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2788 DBG.printf("send alert ch2 success\r\n");
arsenalist 4:76ab12e2f8a3 2789 } else {
arsenalist 4:76ab12e2f8a3 2790 DBG.printf("send alert ch2 failed\r\n");
arsenalist 4:76ab12e2f8a3 2791 }
arsenalist 4:76ab12e2f8a3 2792 }
arsenalist 4:76ab12e2f8a3 2793 }
arsenalist 4:76ab12e2f8a3 2794
arsenalist 4:76ab12e2f8a3 2795 if(CVrms > VRMSTHRESHOLD || CWatt > WATTTHRESHOLD) {
arsenalist 7:7e8c6ad3fd64 2796 DBG.printf("alert on ch3\r\n");
arsenalist 4:76ab12e2f8a3 2797 DBG.printf("alert on ch3\r\n");
arsenalist 20:ea14f175bbb4 2798 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 2799 emmaUID.c_str(),hmacTime.c_str(),q,CVrms,CWatt);
arsenalist 43:612547648ed1 2800 sprintf(p,"/%s/api/controller/alert/3",appNAME.c_str());
arsenalist 43:612547648ed1 2801 rest.post(p,s);
arsenalist 43:612547648ed1 2802 //rest.post("/emma/api/controller/alert/3",s);
arsenalist 4:76ab12e2f8a3 2803 wait(2);
arsenalist 4:76ab12e2f8a3 2804 str = rxBuf;
arsenalist 4:76ab12e2f8a3 2805 if(str.rfind("/alert/3") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2806 str.erase(str.begin(),str.begin()+str.rfind("/alert/3"));
arsenalist 4:76ab12e2f8a3 2807 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2808 DBG.printf("send alert ch3 success\r\n");
arsenalist 4:76ab12e2f8a3 2809 } else {
arsenalist 4:76ab12e2f8a3 2810 DBG.printf("send alert ch3 failed\r\n");
arsenalist 4:76ab12e2f8a3 2811 }
arsenalist 4:76ab12e2f8a3 2812 }
arsenalist 4:76ab12e2f8a3 2813 }
arsenalist 4:76ab12e2f8a3 2814 //DBG.printf("checkVoltagePower-finish\r\n");
arsenalist 4:76ab12e2f8a3 2815 }
arsenalist 4:76ab12e2f8a3 2816 /*end energy related*/
arsenalist 0:f4e449fa34d7 2817
arsenalist 0:f4e449fa34d7 2818 /*start wifi mqtt*/
arsenalist 0:f4e449fa34d7 2819 void mqttConnected(void* response) {
arsenalist 1:d314a43ae6f7 2820 DBG.printf("MQTT Connected\r\n");
arsenalist 0:f4e449fa34d7 2821 char mqttTopic[64];
arsenalist 38:e44f35f8129d 2822 sprintf(mqttTopic,"%s/%s/command",mqttDOMAIN.c_str(),emmaUID.c_str());
arsenalist 27:562a95c120cc 2823 //mqtt.subscribe(mqttTopic);
arsenalist 0:f4e449fa34d7 2824 }
arsenalist 0:f4e449fa34d7 2825 void mqttDisconnected(void* response) {
arsenalist 1:d314a43ae6f7 2826 DBG.printf("MQTT Disconnected\r\n");
arsenalist 0:f4e449fa34d7 2827 }
arsenalist 0:f4e449fa34d7 2828 /*end wifi mqtt*/
arsenalist 0:f4e449fa34d7 2829
arsenalist 0:f4e449fa34d7 2830 /*start wifi rest*/
arsenalist 27:562a95c120cc 2831 void wifiCb(void* response) {
arsenalist 27:562a95c120cc 2832 uint32_t status;
arsenalist 27:562a95c120cc 2833 RESPONSE res(response);
arsenalist 27:562a95c120cc 2834
arsenalist 27:562a95c120cc 2835 if(res.getArgc() == 1) {
arsenalist 27:562a95c120cc 2836 res.popArgs((uint8_t*)&status,4);
arsenalist 27:562a95c120cc 2837 if(status == STATION_GOT_IP) {
arsenalist 27:562a95c120cc 2838 DBG.printf("WIFI Connected\r\n");
arsenalist 27:562a95c120cc 2839 //wifiConnected = true;
arsenalist 27:562a95c120cc 2840 }
arsenalist 27:562a95c120cc 2841 else {
arsenalist 27:562a95c120cc 2842 //wifiConnected = false;
arsenalist 27:562a95c120cc 2843 }
arsenalist 27:562a95c120cc 2844 }
arsenalist 27:562a95c120cc 2845 }
arsenalist 27:562a95c120cc 2846
arsenalist 4:76ab12e2f8a3 2847 void rxInterrupt(void) {
arsenalist 4:76ab12e2f8a3 2848 char c;
arsenalist 4:76ab12e2f8a3 2849
arsenalist 4:76ab12e2f8a3 2850 while(_ESP.readable()) {
arsenalist 4:76ab12e2f8a3 2851 c = _ESP.getc();
arsenalist 4:76ab12e2f8a3 2852 if(c != 0) { //char is not null
arsenalist 4:76ab12e2f8a3 2853 rxBuf += c;
arsenalist 4:76ab12e2f8a3 2854 }
arsenalist 4:76ab12e2f8a3 2855 }
arsenalist 4:76ab12e2f8a3 2856 }
arsenalist 4:76ab12e2f8a3 2857 void checkRxBuffer(void) {
arsenalist 4:76ab12e2f8a3 2858 //check new command
arsenalist 4:76ab12e2f8a3 2859 if(rxBuf.rfind("/command") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2860 rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.rfind("/command"));
arsenalist 41:2d023bd80a9c 2861 if(rxBuf.find("[{") != std::string::npos && rxBuf.rfind("}]") != std::string::npos) {
arsenalist 41:2d023bd80a9c 2862 rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.find("[{"));
arsenalist 41:2d023bd80a9c 2863 rxBuf.erase(rxBuf.begin()+rxBuf.rfind("}]")+2,rxBuf.end());
arsenalist 41:2d023bd80a9c 2864
arsenalist 41:2d023bd80a9c 2865 //start special handler
arsenalist 41:2d023bd80a9c 2866 while(1){
arsenalist 41:2d023bd80a9c 2867 if(rxBuf.find("}],") != std::string::npos) {
arsenalist 41:2d023bd80a9c 2868 rxBuf.erase(rxBuf.begin()+rxBuf.find("}],")+1,rxBuf.begin()+rxBuf.find("}],")+2);
arsenalist 41:2d023bd80a9c 2869 } else {
arsenalist 41:2d023bd80a9c 2870 break;
arsenalist 41:2d023bd80a9c 2871 }
arsenalist 41:2d023bd80a9c 2872 }
arsenalist 41:2d023bd80a9c 2873 //end special handler
arsenalist 41:2d023bd80a9c 2874
arsenalist 4:76ab12e2f8a3 2875 globalCommand = rxBuf;
arsenalist 4:76ab12e2f8a3 2876 newCommand = true;
arsenalist 4:76ab12e2f8a3 2877 }
arsenalist 4:76ab12e2f8a3 2878 }
arsenalist 4:76ab12e2f8a3 2879
arsenalist 24:5d58515ba510 2880 //check free memory -> reinitialize mqtt connection
arsenalist 27:562a95c120cc 2881 if(rxBuf.rfind("Free memory") != std::string::npos) {
arsenalist 27:562a95c120cc 2882 rxLog = "Free memory-" + rxBuf;
arsenalist 24:5d58515ba510 2883 espFreeMemory = true;
arsenalist 24:5d58515ba510 2884 }
arsenalist 24:5d58515ba510 2885
arsenalist 27:562a95c120cc 2886 //check dhcp client start -> initialize all connection
arsenalist 27:562a95c120cc 2887 if(rxBuf.rfind("dhcp client start") != std::string::npos) {
arsenalist 27:562a95c120cc 2888 rxLogA = "dhcp client start-" + rxBuf;
arsenalist 27:562a95c120cc 2889 espDHCPClientStart = true;
arsenalist 27:562a95c120cc 2890 }
arsenalist 27:562a95c120cc 2891
arsenalist 4:76ab12e2f8a3 2892 //clear rxBuf
arsenalist 4:76ab12e2f8a3 2893 rxBuf.clear();
arsenalist 4:76ab12e2f8a3 2894 }
arsenalist 0:f4e449fa34d7 2895 /*end wifi rest*/
arsenalist 0:f4e449fa34d7 2896
arsenalist 0:f4e449fa34d7 2897 /*start emma settings*/
arsenalist 0:f4e449fa34d7 2898 string getUID(void) {
arsenalist 0:f4e449fa34d7 2899 char s[32];
arsenalist 0:f4e449fa34d7 2900 unsigned long *unique = (unsigned long *)BASE_ADDR;
arsenalist 0:f4e449fa34d7 2901 sprintf(s,"%08x%08x%08x",unique[0], unique[1], unique[2]);
arsenalist 0:f4e449fa34d7 2902 return s;
arsenalist 0:f4e449fa34d7 2903 }
arsenalist 0:f4e449fa34d7 2904
arsenalist 0:f4e449fa34d7 2905 string readSetting(string parameter) {
arsenalist 0:f4e449fa34d7 2906 FILE *fp;
arsenalist 0:f4e449fa34d7 2907 signed char c;
arsenalist 0:f4e449fa34d7 2908 int i=0;
arsenalist 0:f4e449fa34d7 2909 char s[64];
arsenalist 0:f4e449fa34d7 2910 string strS;
arsenalist 0:f4e449fa34d7 2911
arsenalist 0:f4e449fa34d7 2912 sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist 0:f4e449fa34d7 2913
arsenalist 0:f4e449fa34d7 2914 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 2915 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 2916 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2917 while(1) {
arsenalist 0:f4e449fa34d7 2918 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 2919 if(c == EOF){
arsenalist 0:f4e449fa34d7 2920 break;
arsenalist 0:f4e449fa34d7 2921 }
arsenalist 0:f4e449fa34d7 2922 s[i] = c;
arsenalist 0:f4e449fa34d7 2923 i++;
arsenalist 0:f4e449fa34d7 2924 }
arsenalist 0:f4e449fa34d7 2925 strS = s;
arsenalist 0:f4e449fa34d7 2926 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2927 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 2928 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 2929 } else {
arsenalist 0:f4e449fa34d7 2930 strS = "";
arsenalist 0:f4e449fa34d7 2931 }
arsenalist 0:f4e449fa34d7 2932 }
arsenalist 0:f4e449fa34d7 2933 fclose(fp);
arsenalist 30:08d290158fa7 2934 free(fp);
arsenalist 0:f4e449fa34d7 2935 return strS;
arsenalist 0:f4e449fa34d7 2936 }
arsenalist 0:f4e449fa34d7 2937
arsenalist 0:f4e449fa34d7 2938 bool writeSetting(string parameter, string value) {
arsenalist 0:f4e449fa34d7 2939 FILE *fp;
arsenalist 0:f4e449fa34d7 2940 char s[255];
arsenalist 0:f4e449fa34d7 2941
arsenalist 0:f4e449fa34d7 2942 sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist 0:f4e449fa34d7 2943 fp = fopen(s,"w");
arsenalist 0:f4e449fa34d7 2944 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2945 fprintf(fp,value.c_str());
arsenalist 0:f4e449fa34d7 2946 fclose(fp);
arsenalist 30:08d290158fa7 2947 free(fp);
arsenalist 0:f4e449fa34d7 2948 return true;
arsenalist 0:f4e449fa34d7 2949 }
arsenalist 30:08d290158fa7 2950 fclose(fp);
arsenalist 30:08d290158fa7 2951 free(fp);
arsenalist 0:f4e449fa34d7 2952 return false;
arsenalist 0:f4e449fa34d7 2953 }
arsenalist 0:f4e449fa34d7 2954 /*end emma settings*/
arsenalist 0:f4e449fa34d7 2955
arsenalist 0:f4e449fa34d7 2956 /*start emma node*/
arsenalist 0:f4e449fa34d7 2957 string readNodeIP(string macAddr) {
arsenalist 0:f4e449fa34d7 2958 FILE *fp;
arsenalist 0:f4e449fa34d7 2959 signed char c;
arsenalist 0:f4e449fa34d7 2960 int i=0;
arsenalist 0:f4e449fa34d7 2961 char s[64];
arsenalist 0:f4e449fa34d7 2962 string strS;
arsenalist 0:f4e449fa34d7 2963
arsenalist 0:f4e449fa34d7 2964 sprintf(s,"/sd/nodeList/%s/nodeIP.txt",macAddr.c_str());
arsenalist 0:f4e449fa34d7 2965
arsenalist 0:f4e449fa34d7 2966 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 2967 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 2968 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2969 while(1) {
arsenalist 0:f4e449fa34d7 2970 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 2971 if(c == EOF){
arsenalist 0:f4e449fa34d7 2972 break;
arsenalist 0:f4e449fa34d7 2973 }
arsenalist 0:f4e449fa34d7 2974 s[i] = c;
arsenalist 0:f4e449fa34d7 2975 i++;
arsenalist 0:f4e449fa34d7 2976 }
arsenalist 0:f4e449fa34d7 2977 strS = s;
arsenalist 0:f4e449fa34d7 2978 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2979 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 2980 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 2981 } else {
arsenalist 0:f4e449fa34d7 2982 strS = "";
arsenalist 0:f4e449fa34d7 2983 }
arsenalist 0:f4e449fa34d7 2984 }
arsenalist 0:f4e449fa34d7 2985 fclose(fp);
arsenalist 30:08d290158fa7 2986 free(fp);
arsenalist 0:f4e449fa34d7 2987 return strS;
arsenalist 0:f4e449fa34d7 2988 }
arsenalist 0:f4e449fa34d7 2989
arsenalist 0:f4e449fa34d7 2990 string readNodeCmd(string dType, string cmd) {
arsenalist 0:f4e449fa34d7 2991 FILE *fp;
arsenalist 0:f4e449fa34d7 2992 signed char c;
arsenalist 0:f4e449fa34d7 2993 int i=0;
arsenalist 34:8555d471b880 2994 char s[2048];
arsenalist 0:f4e449fa34d7 2995 string strS;
arsenalist 0:f4e449fa34d7 2996
arsenalist 0:f4e449fa34d7 2997 sprintf(s,"/sd/nodeCode/%s/%s.txt",dType.c_str(),cmd.c_str());
arsenalist 0:f4e449fa34d7 2998
arsenalist 0:f4e449fa34d7 2999 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 3000 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 3001 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 3002 while(1) {
arsenalist 0:f4e449fa34d7 3003 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 3004 if(c == EOF){
arsenalist 0:f4e449fa34d7 3005 break;
arsenalist 0:f4e449fa34d7 3006 }
arsenalist 0:f4e449fa34d7 3007 s[i] = c;
arsenalist 0:f4e449fa34d7 3008 i++;
arsenalist 0:f4e449fa34d7 3009 }
arsenalist 0:f4e449fa34d7 3010 strS = s;
arsenalist 0:f4e449fa34d7 3011 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 3012 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 3013 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 3014 } else {
arsenalist 0:f4e449fa34d7 3015 strS = "";
arsenalist 0:f4e449fa34d7 3016 }
arsenalist 0:f4e449fa34d7 3017 }
arsenalist 0:f4e449fa34d7 3018 fclose(fp);
arsenalist 30:08d290158fa7 3019 free(fp);
arsenalist 0:f4e449fa34d7 3020 return strS;
arsenalist 0:f4e449fa34d7 3021 }
arsenalist 0:f4e449fa34d7 3022
arsenalist 0:f4e449fa34d7 3023 string *readNodeList(void) {
arsenalist 0:f4e449fa34d7 3024 static string nd[10]; //max node
arsenalist 0:f4e449fa34d7 3025 DIR *d;
arsenalist 0:f4e449fa34d7 3026 struct dirent *p;
arsenalist 0:f4e449fa34d7 3027 string q;
arsenalist 0:f4e449fa34d7 3028 int i=0;
arsenalist 0:f4e449fa34d7 3029
arsenalist 0:f4e449fa34d7 3030 d = opendir("/sd/nodeList");
arsenalist 0:f4e449fa34d7 3031 if(d != NULL) {
arsenalist 0:f4e449fa34d7 3032 while((p = readdir(d)) != NULL) {
arsenalist 0:f4e449fa34d7 3033 q = p->d_name;
arsenalist 0:f4e449fa34d7 3034 nd[i] = q;
arsenalist 0:f4e449fa34d7 3035 i++;
arsenalist 0:f4e449fa34d7 3036 }
arsenalist 0:f4e449fa34d7 3037 }
arsenalist 0:f4e449fa34d7 3038 closedir(d);
arsenalist 30:08d290158fa7 3039 free(d);
arsenalist 0:f4e449fa34d7 3040 return nd;
arsenalist 0:f4e449fa34d7 3041 }
arsenalist 0:f4e449fa34d7 3042
arsenalist 0:f4e449fa34d7 3043 string wifiGetNodeTemp(string macAddr) {
arsenalist 0:f4e449fa34d7 3044 int trial=0;
arsenalist 0:f4e449fa34d7 3045 string nodeIP = readNodeIP(macAddr);
arsenalist 0:f4e449fa34d7 3046 string str;
arsenalist 0:f4e449fa34d7 3047 string temp = "0";
arsenalist 0:f4e449fa34d7 3048
arsenalist 0:f4e449fa34d7 3049 if(rest.begin(nodeIP.c_str(),REMOTE_TCP_PORT,false)) {
arsenalist 0:f4e449fa34d7 3050 while(1) {
arsenalist 0:f4e449fa34d7 3051 char rcv[256] = {};
arsenalist 0:f4e449fa34d7 3052 rest.get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist 0:f4e449fa34d7 3053 rest.getResponse(rcv,sizeof(rcv));
arsenalist 0:f4e449fa34d7 3054 str = rcv;
arsenalist 0:f4e449fa34d7 3055 if(str.find("temp=") != std::string::npos) {
arsenalist 0:f4e449fa34d7 3056 str.erase(str.begin(),str.begin()+str.find("temp=")+6);
arsenalist 0:f4e449fa34d7 3057 str.erase(str.begin()+str.find("\""),str.end());
arsenalist 0:f4e449fa34d7 3058 temp = str;
arsenalist 0:f4e449fa34d7 3059 break;
arsenalist 0:f4e449fa34d7 3060 }
arsenalist 0:f4e449fa34d7 3061 if(trial>1) { //three times trial
arsenalist 0:f4e449fa34d7 3062 break;
arsenalist 0:f4e449fa34d7 3063 }
arsenalist 0:f4e449fa34d7 3064 trial++;
arsenalist 0:f4e449fa34d7 3065 wait(2);
arsenalist 0:f4e449fa34d7 3066 }
arsenalist 0:f4e449fa34d7 3067 }
arsenalist 0:f4e449fa34d7 3068 return temp;
arsenalist 0:f4e449fa34d7 3069 }
arsenalist 0:f4e449fa34d7 3070 /*end emma node*/
arsenalist 0:f4e449fa34d7 3071
arsenalist 0:f4e449fa34d7 3072 /*start emma connection function*/
arsenalist 40:77bd44f57ad3 3073 string ethREST(string host, int port, string data) {
arsenalist 0:f4e449fa34d7 3074 char buf[1024];
arsenalist 0:f4e449fa34d7 3075 char s[256];
arsenalist 45:2406c2b6995a 3076 int ret=99;
arsenalist 45:2406c2b6995a 3077 Timer t;
arsenalist 45:2406c2b6995a 3078
arsenalist 45:2406c2b6995a 3079 t.start();
arsenalist 45:2406c2b6995a 3080 while(eth.linkstatus() && t.read() < 5 && ret !=0) {
arsenalist 45:2406c2b6995a 3081 ret = sock.connect(host.c_str(),port);
arsenalist 45:2406c2b6995a 3082 }
arsenalist 45:2406c2b6995a 3083 t.stop();
arsenalist 45:2406c2b6995a 3084 t.reset();
arsenalist 44:c1d11c491237 3085
arsenalist 45:2406c2b6995a 3086 memset(buf,0,sizeof(buf));
arsenalist 45:2406c2b6995a 3087 if(sock.is_connected()) {
arsenalist 45:2406c2b6995a 3088 DBG.printf("sockConnect\r\n");
arsenalist 45:2406c2b6995a 3089 sprintf(s,"%s",data.c_str());
arsenalist 45:2406c2b6995a 3090 sock.send_all(s,sizeof(s)-1);
arsenalist 45:2406c2b6995a 3091 //wait(2);
arsenalist 45:2406c2b6995a 3092 wait(0.5);
arsenalist 45:2406c2b6995a 3093
arsenalist 45:2406c2b6995a 3094 //receive return
arsenalist 45:2406c2b6995a 3095 t.start();
arsenalist 45:2406c2b6995a 3096 while(1) {
arsenalist 45:2406c2b6995a 3097 ret = sock.receive(buf, sizeof(buf));
arsenalist 45:2406c2b6995a 3098 if(ret<=0 || t.read() > 5) {
arsenalist 45:2406c2b6995a 3099 t.stop();
arsenalist 45:2406c2b6995a 3100 t.reset();
arsenalist 45:2406c2b6995a 3101 break;
arsenalist 45:2406c2b6995a 3102 }
arsenalist 45:2406c2b6995a 3103 }
arsenalist 45:2406c2b6995a 3104 sock.close();
arsenalist 45:2406c2b6995a 3105 } else {
arsenalist 45:2406c2b6995a 3106 DBG.printf("sockNotConnect\r\n");
arsenalist 45:2406c2b6995a 3107 }
arsenalist 45:2406c2b6995a 3108 return buf;
arsenalist 45:2406c2b6995a 3109
arsenalist 45:2406c2b6995a 3110 /*
arsenalist 44:c1d11c491237 3111 //eth.init(); //use DHCP
arsenalist 44:c1d11c491237 3112 eth.connect();
arsenalist 44:c1d11c491237 3113
arsenalist 45:2406c2b6995a 3114 //TCPSocketConnection sock;
arsenalist 0:f4e449fa34d7 3115 Timer t;
arsenalist 0:f4e449fa34d7 3116
arsenalist 40:77bd44f57ad3 3117 sprintf(s,"%s",data.c_str());
arsenalist 0:f4e449fa34d7 3118 sock.connect(host.c_str(),port);
arsenalist 0:f4e449fa34d7 3119 sock.send_all(s,sizeof(s)-1);
arsenalist 0:f4e449fa34d7 3120 wait(2);
arsenalist 0:f4e449fa34d7 3121
arsenalist 0:f4e449fa34d7 3122 //receive return
arsenalist 0:f4e449fa34d7 3123 t.start();
arsenalist 0:f4e449fa34d7 3124 while(1) {
arsenalist 0:f4e449fa34d7 3125 ret = sock.receive(buf, sizeof(buf));
arsenalist 0:f4e449fa34d7 3126 if(ret<=0 || t.read_ms() > 10000) {
arsenalist 0:f4e449fa34d7 3127 t.stop();
arsenalist 0:f4e449fa34d7 3128 break;
arsenalist 0:f4e449fa34d7 3129 }
arsenalist 0:f4e449fa34d7 3130 }
arsenalist 0:f4e449fa34d7 3131 sock.close();
arsenalist 44:c1d11c491237 3132 eth.disconnect();
arsenalist 0:f4e449fa34d7 3133 return buf;
arsenalist 45:2406c2b6995a 3134 */
arsenalist 0:f4e449fa34d7 3135 }
arsenalist 0:f4e449fa34d7 3136 /*end emma connection function*/
arsenalist 0:f4e449fa34d7 3137
arsenalist 0:f4e449fa34d7 3138 /*start emma private function*/
arsenalist 8:51a0ca9079ca 3139 void isEthAvailable(void) {
arsenalist 44:c1d11c491237 3140 //if(ipstack.getEth().linkstatus()) {
arsenalist 44:c1d11c491237 3141 if(eth.linkstatus()) {
arsenalist 8:51a0ca9079ca 3142 ethAvailable = true;
arsenalist 8:51a0ca9079ca 3143 } else {
arsenalist 8:51a0ca9079ca 3144 ethAvailable = false;
arsenalist 8:51a0ca9079ca 3145 }
arsenalist 8:51a0ca9079ca 3146 }
arsenalist 8:51a0ca9079ca 3147
arsenalist 8:51a0ca9079ca 3148 void isEthConnected(void) {
arsenalist 8:51a0ca9079ca 3149 char s[512];
arsenalist 8:51a0ca9079ca 3150 int connPort;
arsenalist 8:51a0ca9079ca 3151 string connHost;
arsenalist 8:51a0ca9079ca 3152 string str;
arsenalist 8:51a0ca9079ca 3153 Timer t;
arsenalist 8:51a0ca9079ca 3154
arsenalist 45:2406c2b6995a 3155 eth.init(); //init ethernet
arsenalist 45:2406c2b6995a 3156 eth.connect();
arsenalist 45:2406c2b6995a 3157
arsenalist 8:51a0ca9079ca 3158 if(ethAvailable) {
arsenalist 8:51a0ca9079ca 3159 if(useProxy) {
arsenalist 8:51a0ca9079ca 3160 connHost = proxySERVER;
arsenalist 8:51a0ca9079ca 3161 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 44:c1d11c491237 3162 //for(int i=0; i<sizeof(s); i++) {
arsenalist 44:c1d11c491237 3163 // s[i]=0; }
arsenalist 43:612547648ed1 3164 sprintf(s,"GET http://%s:%s/%s/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str(),restSERVER.c_str());
arsenalist 8:51a0ca9079ca 3165 } else {
arsenalist 38:e44f35f8129d 3166 connHost = restSERVER;
arsenalist 38:e44f35f8129d 3167 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 44:c1d11c491237 3168 //for(int i=0; i<sizeof(s); i++) {
arsenalist 44:c1d11c491237 3169 // s[i]=0; }
arsenalist 43:612547648ed1 3170 sprintf(s,"GET /%s/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",appNAME.c_str(),restSERVER.c_str());
arsenalist 8:51a0ca9079ca 3171 }
arsenalist 8:51a0ca9079ca 3172
arsenalist 8:51a0ca9079ca 3173 t.start();
arsenalist 8:51a0ca9079ca 3174 while(1) {
arsenalist 40:77bd44f57ad3 3175 str = ethREST(connHost,connPort,s);
arsenalist 44:c1d11c491237 3176 if(str.find("\"status\":\"OK\"") != std::string::npos) {
arsenalist 8:51a0ca9079ca 3177 t.stop();
arsenalist 8:51a0ca9079ca 3178 ethConnected = true;
arsenalist 8:51a0ca9079ca 3179 break;
arsenalist 8:51a0ca9079ca 3180 }
arsenalist 8:51a0ca9079ca 3181 if(t.read_ms() > 5000) {
arsenalist 8:51a0ca9079ca 3182 t.stop();
arsenalist 8:51a0ca9079ca 3183 ethConnected = false;
arsenalist 8:51a0ca9079ca 3184 break;
arsenalist 8:51a0ca9079ca 3185 }
arsenalist 8:51a0ca9079ca 3186 }
arsenalist 8:51a0ca9079ca 3187 } else {
arsenalist 8:51a0ca9079ca 3188 ethConnected = false;
arsenalist 8:51a0ca9079ca 3189 }
arsenalist 8:51a0ca9079ca 3190 }
arsenalist 8:51a0ca9079ca 3191
arsenalist 8:51a0ca9079ca 3192 void isWiFiConnected(void) { //WARNING: should be run in emmaModeRegister and emmaModeOperation only - limitation with esp, after MODE=B, cannot go to MODE=S
arsenalist 8:51a0ca9079ca 3193 char s[512];
arsenalist 8:51a0ca9079ca 3194 int connPort;
arsenalist 8:51a0ca9079ca 3195 string connHost;
arsenalist 8:51a0ca9079ca 3196 string str;
arsenalist 8:51a0ca9079ca 3197 Timer t;
arsenalist 8:51a0ca9079ca 3198
arsenalist 29:4d94a03d38e0 3199 /*
arsenalist 27:562a95c120cc 3200 esp.enable();
arsenalist 27:562a95c120cc 3201 wait(1);
arsenalist 27:562a95c120cc 3202 esp.reset();
arsenalist 27:562a95c120cc 3203 wait(1);
arsenalist 27:562a95c120cc 3204 while(!esp.ready());
arsenalist 27:562a95c120cc 3205
arsenalist 27:562a95c120cc 3206 //rest begin
arsenalist 38:e44f35f8129d 3207 if(!rest.begin(restSERVER,restPORT,false)) {
arsenalist 27:562a95c120cc 3208 DBG.printf("EMMA: fail to setup rest\r\n");
arsenalist 27:562a95c120cc 3209 TFT.locate(0,20);
arsenalist 27:562a95c120cc 3210 TFT.printf("EMMA: fail to setup rest");
arsenalist 27:562a95c120cc 3211 while(1);
arsenalist 27:562a95c120cc 3212 }
arsenalist 27:562a95c120cc 3213
arsenalist 27:562a95c120cc 3214 //setup wifi
arsenalist 27:562a95c120cc 3215 DBG.printf("EMMA: setup wifi\r\n");
arsenalist 27:562a95c120cc 3216 TFT.locate(0,20);
arsenalist 27:562a95c120cc 3217 TFT.printf("EMMA: setup wifi");
arsenalist 27:562a95c120cc 3218 wait(1);
arsenalist 27:562a95c120cc 3219 esp.wifiCb.attach(&wifiCb);
arsenalist 28:7561035e3df5 3220 //esp.wifiConnect("Tritronik Mobile","Tri12@11");
arsenalist 28:7561035e3df5 3221 esp.wifiConnect(wifiSSID.c_str(),wifiPASS.c_str());
arsenalist 27:562a95c120cc 3222 DBG.printf("EMMA: system started\r\n");
arsenalist 27:562a95c120cc 3223 TFT.locate(0,20);
arsenalist 27:562a95c120cc 3224 TFT.printf("EMMA: system started");
arsenalist 27:562a95c120cc 3225 t.start();
arsenalist 28:7561035e3df5 3226 while(t.read() < 20);
arsenalist 27:562a95c120cc 3227 t.stop();
arsenalist 27:562a95c120cc 3228 t.reset();
arsenalist 28:7561035e3df5 3229 TFT.locate(0,20);
arsenalist 28:7561035e3df5 3230 TFT.printf(" ");
arsenalist 29:4d94a03d38e0 3231 */
arsenalist 27:562a95c120cc 3232
arsenalist 8:51a0ca9079ca 3233 if(wifiAvailable) {
arsenalist 8:51a0ca9079ca 3234 _ESP.printf("MODE=B");
arsenalist 8:51a0ca9079ca 3235 if(useProxy) {
arsenalist 8:51a0ca9079ca 3236 connHost = proxySERVER;
arsenalist 8:51a0ca9079ca 3237 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 44:c1d11c491237 3238 //for(int i=0; i<sizeof(s); i++) {
arsenalist 44:c1d11c491237 3239 // s[i]=0; }
arsenalist 43:612547648ed1 3240 sprintf(s,"http://%s:%s/%s/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",restSERVER.c_str(),restPORT.c_str(),appNAME.c_str(),restSERVER.c_str());
arsenalist 8:51a0ca9079ca 3241 } else {
arsenalist 38:e44f35f8129d 3242 connHost = restSERVER;
arsenalist 38:e44f35f8129d 3243 sscanf(restPORT.c_str(),"%d",&connPort);
arsenalist 44:c1d11c491237 3244 //for(int i=0; i<sizeof(s); i++) {
arsenalist 44:c1d11c491237 3245 // s[i]=0; }
arsenalist 43:612547648ed1 3246 sprintf(s,"/%s/api/controller/test",appNAME.c_str());
arsenalist 8:51a0ca9079ca 3247 }
arsenalist 27:562a95c120cc 3248 wait(2);
arsenalist 8:51a0ca9079ca 3249 t.start();
arsenalist 28:7561035e3df5 3250 while(!esp.ready() && t.read() < 20);
arsenalist 8:51a0ca9079ca 3251 t.stop();
arsenalist 27:562a95c120cc 3252 t.reset();
arsenalist 8:51a0ca9079ca 3253 if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist 44:c1d11c491237 3254 //DBG.printf("rest begin\r\n");
arsenalist 8:51a0ca9079ca 3255 esp.process();
arsenalist 8:51a0ca9079ca 3256 rest.get(s);
arsenalist 44:c1d11c491237 3257 //for(int i=0; i<sizeof(s); i++) {
arsenalist 44:c1d11c491237 3258 // s[i]=0; }
arsenalist 8:51a0ca9079ca 3259 rest.getResponse(s,sizeof(s));
arsenalist 8:51a0ca9079ca 3260 str = s;
arsenalist 27:562a95c120cc 3261 DBG.printf("response:%s\r\n",s);
arsenalist 44:c1d11c491237 3262 if(str.find("\"status\":\"OK\"") != std::string::npos) {
arsenalist 8:51a0ca9079ca 3263 wifiConnected = true;
arsenalist 8:51a0ca9079ca 3264 }
arsenalist 8:51a0ca9079ca 3265 } else {
arsenalist 8:51a0ca9079ca 3266 wifiConnected = false;
arsenalist 8:51a0ca9079ca 3267 }
arsenalist 8:51a0ca9079ca 3268 } else {
arsenalist 8:51a0ca9079ca 3269 wifiConnected = false;
arsenalist 8:51a0ca9079ca 3270 }
arsenalist 8:51a0ca9079ca 3271 }
arsenalist 8:51a0ca9079ca 3272
arsenalist 8:51a0ca9079ca 3273 void isGprsConnected(void) {
arsenalist 8:51a0ca9079ca 3274
arsenalist 8:51a0ca9079ca 3275 }
arsenalist 0:f4e449fa34d7 3276
arsenalist 0:f4e449fa34d7 3277 void addChar(char *s, char c) {
arsenalist 0:f4e449fa34d7 3278 uint16_t k; //customized for EMS
arsenalist 0:f4e449fa34d7 3279 k = strlen(s);
arsenalist 0:f4e449fa34d7 3280 s[k] = c;
arsenalist 0:f4e449fa34d7 3281 s[k + 1] = 0;
arsenalist 0:f4e449fa34d7 3282 }
arsenalist 0:f4e449fa34d7 3283
arsenalist 0:f4e449fa34d7 3284 void rcvReply(char *r, int to) {
arsenalist 0:f4e449fa34d7 3285 Timer t;
arsenalist 0:f4e449fa34d7 3286 bool ended = false;
arsenalist 0:f4e449fa34d7 3287 char c;
arsenalist 0:f4e449fa34d7 3288
arsenalist 0:f4e449fa34d7 3289 strcpy(r,"");
arsenalist 0:f4e449fa34d7 3290 t.start();
arsenalist 0:f4e449fa34d7 3291 while(!ended) {
arsenalist 0:f4e449fa34d7 3292 if(_ESP.readable()) {
arsenalist 0:f4e449fa34d7 3293 c = _ESP.getc();
arsenalist 0:f4e449fa34d7 3294 addChar(r,c);
arsenalist 0:f4e449fa34d7 3295 t.start();
arsenalist 0:f4e449fa34d7 3296 }
arsenalist 0:f4e449fa34d7 3297 if(t.read_ms() > to) {
arsenalist 0:f4e449fa34d7 3298 ended = true;
arsenalist 0:f4e449fa34d7 3299 }
arsenalist 0:f4e449fa34d7 3300 }
arsenalist 0:f4e449fa34d7 3301 addChar(r, 0x00);
arsenalist 0:f4e449fa34d7 3302 }
arsenalist 0:f4e449fa34d7 3303
arsenalist 0:f4e449fa34d7 3304 string calculateMD5(string text) {
arsenalist 0:f4e449fa34d7 3305 char s[64];
arsenalist 0:f4e449fa34d7 3306 memset(s,0,sizeof(s)); //for unknown reason, after reading UID, the 's' will contaion UID data
arsenalist 0:f4e449fa34d7 3307 uint8_t hash[16];
arsenalist 0:f4e449fa34d7 3308 MD5::computeHash(hash, (uint8_t*)text.c_str(), strlen(text.c_str()));
arsenalist 0:f4e449fa34d7 3309 for(int i=0; i<16; ++i) {
arsenalist 0:f4e449fa34d7 3310 sprintf(s,"%s%02x",s,hash[i]);
arsenalist 0:f4e449fa34d7 3311 }
arsenalist 0:f4e449fa34d7 3312 return s;
arsenalist 0:f4e449fa34d7 3313 }
arsenalist 0:f4e449fa34d7 3314
arsenalist 0:f4e449fa34d7 3315 bool writeFirmwareHexToChar(string value) {
arsenalist 0:f4e449fa34d7 3316 FILE *fp;
arsenalist 0:f4e449fa34d7 3317 char s[32];
arsenalist 0:f4e449fa34d7 3318 int number;
arsenalist 0:f4e449fa34d7 3319 string chunk;
arsenalist 0:f4e449fa34d7 3320
arsenalist 0:f4e449fa34d7 3321 sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist 0:f4e449fa34d7 3322 fp = fopen(s,"a");
arsenalist 0:f4e449fa34d7 3323 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 3324 for(int ch=0; ch<value.size(); ch+=2) {
arsenalist 0:f4e449fa34d7 3325 chunk = value.substr(ch,2);
arsenalist 0:f4e449fa34d7 3326 sscanf(chunk.c_str(),"%x",&number);
arsenalist 0:f4e449fa34d7 3327 fprintf(fp,"%c",number);
arsenalist 0:f4e449fa34d7 3328 }
arsenalist 0:f4e449fa34d7 3329 fclose(fp);
arsenalist 30:08d290158fa7 3330 free(fp);
arsenalist 0:f4e449fa34d7 3331 return true;
arsenalist 0:f4e449fa34d7 3332 }
arsenalist 30:08d290158fa7 3333 fclose(fp);
arsenalist 30:08d290158fa7 3334 free(fp);
arsenalist 0:f4e449fa34d7 3335 return false;
arsenalist 0:f4e449fa34d7 3336 }
arsenalist 0:f4e449fa34d7 3337
arsenalist 0:f4e449fa34d7 3338 bool clearFirmware(void) {
arsenalist 0:f4e449fa34d7 3339 FILE *fp;
arsenalist 0:f4e449fa34d7 3340 char s[32];
arsenalist 0:f4e449fa34d7 3341
arsenalist 0:f4e449fa34d7 3342 sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist 0:f4e449fa34d7 3343 fp = fopen(s,"w");
arsenalist 0:f4e449fa34d7 3344 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 3345 fprintf(fp,"");
arsenalist 0:f4e449fa34d7 3346 fclose(fp);
arsenalist 30:08d290158fa7 3347 free(fp);
arsenalist 0:f4e449fa34d7 3348 return true;
arsenalist 0:f4e449fa34d7 3349 }
arsenalist 30:08d290158fa7 3350 fclose(fp);
arsenalist 30:08d290158fa7 3351 free(fp);
arsenalist 0:f4e449fa34d7 3352 return false;
arsenalist 0:f4e449fa34d7 3353 }
arsenalist 27:562a95c120cc 3354
arsenalist 27:562a95c120cc 3355 bool writeLog(string logTime, string logData) {
arsenalist 27:562a95c120cc 3356 FILE *fp;
arsenalist 27:562a95c120cc 3357 char s[255];
arsenalist 27:562a95c120cc 3358 string logAll;
arsenalist 27:562a95c120cc 3359 logAll = logTime + "\t" + logData + "\r\n";
arsenalist 27:562a95c120cc 3360
arsenalist 27:562a95c120cc 3361 sprintf(s,"/sd/log.txt");
arsenalist 27:562a95c120cc 3362 fp = fopen(s,"a");
arsenalist 27:562a95c120cc 3363 if(fp != NULL) {
arsenalist 27:562a95c120cc 3364 fprintf(fp,logAll.c_str());
arsenalist 27:562a95c120cc 3365 fclose(fp);
arsenalist 30:08d290158fa7 3366 free(fp);
arsenalist 27:562a95c120cc 3367 return true;
arsenalist 27:562a95c120cc 3368 }
arsenalist 30:08d290158fa7 3369 fclose(fp);
arsenalist 30:08d290158fa7 3370 free(fp);
arsenalist 30:08d290158fa7 3371 return false;
arsenalist 30:08d290158fa7 3372 }
arsenalist 30:08d290158fa7 3373
arsenalist 30:08d290158fa7 3374 bool writeDbg(string dbgTime, string dbgData) {
arsenalist 30:08d290158fa7 3375 FILE *fp;
arsenalist 30:08d290158fa7 3376 char s[255];
arsenalist 30:08d290158fa7 3377 string dbgAll;
arsenalist 30:08d290158fa7 3378 dbgAll = dbgTime + "\t" + dbgData + "\r\n";
arsenalist 30:08d290158fa7 3379
arsenalist 30:08d290158fa7 3380 sprintf(s,"/sd/dbg.txt");
arsenalist 30:08d290158fa7 3381 fp = fopen(s,"a");
arsenalist 30:08d290158fa7 3382 if(fp != NULL) {
arsenalist 30:08d290158fa7 3383 fprintf(fp,dbgAll.c_str());
arsenalist 30:08d290158fa7 3384 fclose(fp);
arsenalist 30:08d290158fa7 3385 free(fp);
arsenalist 30:08d290158fa7 3386 return true;
arsenalist 30:08d290158fa7 3387 }
arsenalist 30:08d290158fa7 3388 fclose(fp);
arsenalist 30:08d290158fa7 3389 free(fp);
arsenalist 27:562a95c120cc 3390 return false;
arsenalist 27:562a95c120cc 3391 }
arsenalist 0:f4e449fa34d7 3392 /*end emma private function*/