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@30:08d290158fa7, 2015-08-06 (annotated)

Committer:
arsenalist
Date:
Thu Aug 06 04:38:09 2015 +0000
Revision:
30:08d290158fa7
Parent:
29:4d94a03d38e0
Child:
31:e2abded4d85f
Free fp pointer in accessing sd card.; Currently running test.

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 0:f4e449fa34d7 17 MQTTEthernet ipstack(&spi, PB_12, PC_6); //spi, cs, reset
arsenalist 0:f4e449fa34d7 18 MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
arsenalist 0:f4e449fa34d7 19
arsenalist 0:f4e449fa34d7 20 //init sd card
arsenalist 8:51a0ca9079ca 21 SDFileSystem sd(PA_7, PA_6, PA_5, PB_3, "sd"); //mosi, miso, sck, cs
arsenalist 0:f4e449fa34d7 22
arsenalist 8:51a0ca9079ca 23 //init ade7758 - without cs pin
arsenalist 14:8287f0f5d987 24 ADE7758 ADE(PB_6, PB_4, PB_5, PB_7); //mosi, miso, sck, irq
arsenalist 0:f4e449fa34d7 25
arsenalist 12:96f637ed37f9 26 //init tft lcd
arsenalist 12:96f637ed37f9 27 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 28 //init touch screen - without cs pin
arsenalist 12:96f637ed37f9 29 TouchScreenADS7843 TP(PB_10, PB_0, PB_1, PB_2, &TFT); //mosi, miso, sclk, irq, tft
arsenalist 12:96f637ed37f9 30 //InterruptIn tpIRQ(PB_2);
arsenalist 12:96f637ed37f9 31
arsenalist 21:33bd8b82560f 32 //init dht sensor
arsenalist 21:33bd8b82560f 33 DHT11 d(PD_2);
arsenalist 21:33bd8b82560f 34
arsenalist 0:f4e449fa34d7 35 //emma settings
arsenalist 0:f4e449fa34d7 36 string emmaUID;
arsenalist 4:76ab12e2f8a3 37 string hmac;
arsenalist 0:f4e449fa34d7 38 string platformDOMAIN;
arsenalist 0:f4e449fa34d7 39 string platformKEY;
arsenalist 0:f4e449fa34d7 40 string platformSECRET;
arsenalist 0:f4e449fa34d7 41 string wifiSSID;
arsenalist 0:f4e449fa34d7 42 string wifiPASS;
arsenalist 0:f4e449fa34d7 43 string gprsAPN;
arsenalist 0:f4e449fa34d7 44 string proxySERVER;
arsenalist 0:f4e449fa34d7 45 string proxyPORT;
arsenalist 0:f4e449fa34d7 46 string proxyAUTH;
arsenalist 0:f4e449fa34d7 47
arsenalist 4:76ab12e2f8a3 48 //nodes settings
arsenalist 4:76ab12e2f8a3 49 class NODES {
arsenalist 4:76ab12e2f8a3 50 public:
arsenalist 4:76ab12e2f8a3 51 REST *restConn;
arsenalist 4:76ab12e2f8a3 52 NODES(REST *r);
arsenalist 4:76ab12e2f8a3 53 string macAddr;
arsenalist 4:76ab12e2f8a3 54 string ipAddr;
arsenalist 4:76ab12e2f8a3 55 };
arsenalist 4:76ab12e2f8a3 56 NODES::NODES(REST *r) {
arsenalist 4:76ab12e2f8a3 57 restConn = r;
arsenalist 4:76ab12e2f8a3 58 }
arsenalist 4:76ab12e2f8a3 59 REST restObj[NODES_MAX] = {REST(&esp),REST(&esp),REST(&esp),REST(&esp),REST(&esp)};
arsenalist 4:76ab12e2f8a3 60 NODES nodes[NODES_MAX] = {NODES(&restObj[0]),NODES(&restObj[1]),NODES(&restObj[2]),NODES(&restObj[3]),NODES(&restObj[4])};
arsenalist 4:76ab12e2f8a3 61
arsenalist 12:96f637ed37f9 62 //mode box class for main menu
arsenalist 12:96f637ed37f9 63 class modeBox {
arsenalist 12:96f637ed37f9 64 public:
arsenalist 12:96f637ed37f9 65 int xTL; //TopLeft
arsenalist 12:96f637ed37f9 66 int yTL;
arsenalist 12:96f637ed37f9 67 int xBR; //BottomRight
arsenalist 12:96f637ed37f9 68 int yBR;
arsenalist 29:4d94a03d38e0 69 string text;
arsenalist 29:4d94a03d38e0 70 string name;
arsenalist 12:96f637ed37f9 71 };
arsenalist 12:96f637ed37f9 72
arsenalist 0:f4e449fa34d7 73 //ade7758 variables
arsenalist 25:36c6a5db50ed 74 uint32_t AWattHrValue, BWattHrValue, CWattHrValue;
arsenalist 25:36c6a5db50ed 75 uint32_t AVAHrValue, BVAHrValue, CVAHrValue;
arsenalist 19:7e3e9332f719 76 //long AWattHrSum = 0;
arsenalist 19:7e3e9332f719 77 //long BWattHrSum = 0;
arsenalist 19:7e3e9332f719 78 //long CWattHrSum = 0;
arsenalist 19:7e3e9332f719 79 uint32_t AWattHrSum = 0;
arsenalist 19:7e3e9332f719 80 uint32_t BWattHrSum = 0;
arsenalist 19:7e3e9332f719 81 uint32_t CWattHrSum = 0;
arsenalist 0:f4e449fa34d7 82 float AWattHr, BWattHr, CWattHr;
arsenalist 4:76ab12e2f8a3 83 float AVrms, BVrms, CVrms;
arsenalist 4:76ab12e2f8a3 84 float AIrms, BIrms, CIrms;
arsenalist 4:76ab12e2f8a3 85 float AWatt, BWatt, CWatt;
arsenalist 4:76ab12e2f8a3 86 float XWattHr,XVrms,XWatt;
arsenalist 0:f4e449fa34d7 87
arsenalist 0:f4e449fa34d7 88 //variables
arsenalist 0:f4e449fa34d7 89 bool ethAvailable = false;
arsenalist 0:f4e449fa34d7 90 bool wifiAvailable = false;
arsenalist 0:f4e449fa34d7 91 bool gprsAvailable = false;
arsenalist 0:f4e449fa34d7 92 bool ethConnected = false;
arsenalist 0:f4e449fa34d7 93 bool wifiConnected = false;
arsenalist 9:a58c04da4476 94 bool gprsConnected = false;
arsenalist 0:f4e449fa34d7 95 bool useProxy = false;
arsenalist 0:f4e449fa34d7 96 bool newCommand = false;
arsenalist 24:5d58515ba510 97 bool espFreeMemory = true; //for after bootup initialization
arsenalist 27:562a95c120cc 98 bool espDHCPClientStart = false;
arsenalist 22:e18d361bf688 99 bool newEnergyData = false;
arsenalist 0:f4e449fa34d7 100 string globalCommand;
arsenalist 4:76ab12e2f8a3 101 string rxBuf;
arsenalist 27:562a95c120cc 102 string rxLog;
arsenalist 27:562a95c120cc 103 string rxLogA;
arsenalist 0:f4e449fa34d7 104
arsenalist 12:96f637ed37f9 105 /*start lcd and touch*/
arsenalist 12:96f637ed37f9 106 int emmaModeSelection(void) {
arsenalist 12:96f637ed37f9 107 bool modeSelected = false;
arsenalist 12:96f637ed37f9 108 int md=0;
arsenalist 12:96f637ed37f9 109 int TPx;
arsenalist 12:96f637ed37f9 110 int TPy;
arsenalist 12:96f637ed37f9 111
arsenalist 12:96f637ed37f9 112 TFT.background(Black);
arsenalist 12:96f637ed37f9 113 TFT.foreground(White);
arsenalist 12:96f637ed37f9 114
arsenalist 12:96f637ed37f9 115 TFT.set_font((unsigned char*) Arial12x12);
arsenalist 12:96f637ed37f9 116 TFT.set_orientation(1);
arsenalist 12:96f637ed37f9 117 TFT.cls();
arsenalist 12:96f637ed37f9 118 TFT.locate(0,0);
arsenalist 12:96f637ed37f9 119 TFT.printf("Hello, I'm Emma!");
arsenalist 13:e8adfe305dbc 120 wait(2);
arsenalist 12:96f637ed37f9 121 TFT.cls();
arsenalist 12:96f637ed37f9 122
arsenalist 12:96f637ed37f9 123 Matrix matrix;
arsenalist 12:96f637ed37f9 124 Coordinate ScreenSample[3];
arsenalist 12:96f637ed37f9 125
arsenalist 12:96f637ed37f9 126 matrix.An = 580;
arsenalist 12:96f637ed37f9 127 matrix.Bn = 75980;
arsenalist 12:96f637ed37f9 128 matrix.Cn = -3410580;
arsenalist 12:96f637ed37f9 129 matrix.Dn = 57855;
arsenalist 12:96f637ed37f9 130 matrix.En = -2465;
arsenalist 12:96f637ed37f9 131 matrix.Fn = -3483515;
arsenalist 12:96f637ed37f9 132 matrix.Divider = 209144;
arsenalist 12:96f637ed37f9 133
arsenalist 12:96f637ed37f9 134 ScreenSample[0].x = 230;
arsenalist 12:96f637ed37f9 135 ScreenSample[0].y = 167;
arsenalist 12:96f637ed37f9 136 ScreenSample[1].x = 754;
arsenalist 12:96f637ed37f9 137 ScreenSample[1].y = 163;
arsenalist 12:96f637ed37f9 138 ScreenSample[2].x = 771;
arsenalist 12:96f637ed37f9 139 ScreenSample[2].y = 562;
arsenalist 12:96f637ed37f9 140
arsenalist 12:96f637ed37f9 141 TP.SetCalibration(&matrix, &ScreenSample[0]);
arsenalist 12:96f637ed37f9 142
arsenalist 17:b3ced0e67916 143 //TFT.locate(0,0);
arsenalist 17:b3ced0e67916 144 //TFT.printf(" X:");
arsenalist 17:b3ced0e67916 145 //TFT.locate(70,0);
arsenalist 17:b3ced0e67916 146 //TFT.printf(" Y:");
arsenalist 12:96f637ed37f9 147
arsenalist 12:96f637ed37f9 148 //draw border
arsenalist 12:96f637ed37f9 149 TFT.line(15,15,310,15,Orange);
arsenalist 12:96f637ed37f9 150 TFT.line(310,15,310,250,Orange);
arsenalist 12:96f637ed37f9 151 TFT.line(310,250,15,250,Orange);
arsenalist 12:96f637ed37f9 152 TFT.line(15,250,15,15,Orange);
arsenalist 12:96f637ed37f9 153
arsenalist 12:96f637ed37f9 154 //init main menu
arsenalist 12:96f637ed37f9 155 modeBox menu[6];
arsenalist 12:96f637ed37f9 156
arsenalist 12:96f637ed37f9 157 //wifi config mode
arsenalist 12:96f637ed37f9 158 menu[MODE_WIFI_CONFIG].xTL = 25;
arsenalist 12:96f637ed37f9 159 menu[MODE_WIFI_CONFIG].yTL = 25;
arsenalist 12:96f637ed37f9 160 menu[MODE_WIFI_CONFIG].xBR = 110;
arsenalist 12:96f637ed37f9 161 menu[MODE_WIFI_CONFIG].yBR = 90;
arsenalist 29:4d94a03d38e0 162 menu[MODE_WIFI_CONFIG].text = "1.wifi config";
arsenalist 29:4d94a03d38e0 163 menu[MODE_WIFI_CONFIG].name = "wifi config";
arsenalist 12:96f637ed37f9 164
arsenalist 12:96f637ed37f9 165 //setting mode
arsenalist 29:4d94a03d38e0 166 menu[MODE_SETTINGS].xTL = 25;
arsenalist 29:4d94a03d38e0 167 menu[MODE_SETTINGS].yTL = 100;
arsenalist 29:4d94a03d38e0 168 menu[MODE_SETTINGS].xBR = 110;
arsenalist 29:4d94a03d38e0 169 menu[MODE_SETTINGS].yBR = 165;
arsenalist 29:4d94a03d38e0 170 menu[MODE_SETTINGS].text = "2.settings ";
arsenalist 29:4d94a03d38e0 171 menu[MODE_SETTINGS].name = "settings";
arsenalist 12:96f637ed37f9 172
arsenalist 12:96f637ed37f9 173 //register mode
arsenalist 29:4d94a03d38e0 174 menu[MODE_REGISTER].xTL = 120;
arsenalist 29:4d94a03d38e0 175 menu[MODE_REGISTER].yTL = 25;
arsenalist 29:4d94a03d38e0 176 menu[MODE_REGISTER].xBR = 205;
arsenalist 29:4d94a03d38e0 177 menu[MODE_REGISTER].yBR = 90;
arsenalist 29:4d94a03d38e0 178 menu[MODE_REGISTER].text = "3.register ";
arsenalist 29:4d94a03d38e0 179 menu[MODE_REGISTER].name = "register";
arsenalist 12:96f637ed37f9 180
arsenalist 12:96f637ed37f9 181 //operational mode
arsenalist 12:96f637ed37f9 182 menu[MODE_OPERATION].xTL = 120;
arsenalist 12:96f637ed37f9 183 menu[MODE_OPERATION].yTL = 100;
arsenalist 12:96f637ed37f9 184 menu[MODE_OPERATION].xBR = 205;
arsenalist 12:96f637ed37f9 185 menu[MODE_OPERATION].yBR = 165;
arsenalist 29:4d94a03d38e0 186 menu[MODE_OPERATION].text = "4.operation ";
arsenalist 29:4d94a03d38e0 187 menu[MODE_OPERATION].name = "operation";
arsenalist 12:96f637ed37f9 188
arsenalist 12:96f637ed37f9 189 //firmware download mode
arsenalist 12:96f637ed37f9 190 menu[MODE_FIRMWARE_DOWNLOAD].xTL = 215;
arsenalist 12:96f637ed37f9 191 menu[MODE_FIRMWARE_DOWNLOAD].yTL = 25;
arsenalist 12:96f637ed37f9 192 menu[MODE_FIRMWARE_DOWNLOAD].xBR = 300;
arsenalist 12:96f637ed37f9 193 menu[MODE_FIRMWARE_DOWNLOAD].yBR = 90;
arsenalist 29:4d94a03d38e0 194 menu[MODE_FIRMWARE_DOWNLOAD].text = "5.fw dwld ";
arsenalist 29:4d94a03d38e0 195 menu[MODE_FIRMWARE_DOWNLOAD].name = "fw dwld";
arsenalist 12:96f637ed37f9 196
arsenalist 12:96f637ed37f9 197 //reserved mode
arsenalist 12:96f637ed37f9 198 menu[5].xTL = 215;
arsenalist 12:96f637ed37f9 199 menu[5].yTL = 100;
arsenalist 12:96f637ed37f9 200 menu[5].xBR = 300;
arsenalist 12:96f637ed37f9 201 menu[5].yBR = 165;
arsenalist 29:4d94a03d38e0 202 menu[5].text = "6.reserved ";
arsenalist 29:4d94a03d38e0 203 menu[5].name = "reserved";
arsenalist 12:96f637ed37f9 204
arsenalist 17:b3ced0e67916 205 //draw main menu
arsenalist 12:96f637ed37f9 206 for(int i=0; i<6; i++) {
arsenalist 12:96f637ed37f9 207 TFT.fillrect(menu[i].xTL,menu[i].yTL,menu[i].xBR,menu[i].yBR,Orange);
arsenalist 12:96f637ed37f9 208 }
arsenalist 12:96f637ed37f9 209
arsenalist 17:b3ced0e67916 210 //add text to main menu
arsenalist 17:b3ced0e67916 211 for(int i=0; i<6; i++) {
arsenalist 17:b3ced0e67916 212 TFT.locate(menu[i].xTL,menu[i].yTL);
arsenalist 17:b3ced0e67916 213 TFT.printf("%s",menu[i].text.c_str());
arsenalist 17:b3ced0e67916 214 }
arsenalist 17:b3ced0e67916 215
arsenalist 12:96f637ed37f9 216 while(!modeSelected) {
arsenalist 12:96f637ed37f9 217 if(!TP._tp_irq) {
arsenalist 12:96f637ed37f9 218 if(TP.Read_Ads7843()) {
arsenalist 12:96f637ed37f9 219 TP.getDisplayPoint();
arsenalist 12:96f637ed37f9 220 TPx = TP.display.x;
arsenalist 12:96f637ed37f9 221 TPy = TP.display.y;
arsenalist 12:96f637ed37f9 222 TP.TP_DrawPoint(TPx,TPy, Blue);
arsenalist 17:b3ced0e67916 223 //TFT.locate(25,0);
arsenalist 17:b3ced0e67916 224 //TFT.printf("%03d",TPx);
arsenalist 17:b3ced0e67916 225 //TFT.locate(95,0);
arsenalist 17:b3ced0e67916 226 //TFT.printf("%03d",TPy);
arsenalist 12:96f637ed37f9 227
arsenalist 12:96f637ed37f9 228 for(int i=0; i<6; i++) {
arsenalist 12:96f637ed37f9 229 if((menu[i].xTL < TPx && TPx < menu[i].xBR) && (menu[i].yTL < TPy && TPy < menu[i].yBR)) {
arsenalist 12:96f637ed37f9 230 //TFT.locate(25,170);
arsenalist 12:96f637ed37f9 231 //TFT.printf(" ");
arsenalist 12:96f637ed37f9 232 //TFT.locate(25,170);
arsenalist 12:96f637ed37f9 233 //TFT.printf("mode: %s is selected",menu[i].text.c_str());
arsenalist 12:96f637ed37f9 234 //wait(3);
arsenalist 12:96f637ed37f9 235 md = i;
arsenalist 12:96f637ed37f9 236 modeSelected = true;
arsenalist 12:96f637ed37f9 237 }
arsenalist 12:96f637ed37f9 238 }
arsenalist 12:96f637ed37f9 239 }
arsenalist 12:96f637ed37f9 240 }
arsenalist 12:96f637ed37f9 241 }
arsenalist 12:96f637ed37f9 242
arsenalist 12:96f637ed37f9 243 TFT.locate(25,170);
arsenalist 12:96f637ed37f9 244 TFT.printf(" ");
arsenalist 12:96f637ed37f9 245 TFT.locate(25,170);
arsenalist 29:4d94a03d38e0 246 TFT.printf("mode: %s is selected",menu[md].name.c_str());
arsenalist 13:e8adfe305dbc 247 wait(2);
arsenalist 12:96f637ed37f9 248 TFT.cls();
arsenalist 12:96f637ed37f9 249
arsenalist 12:96f637ed37f9 250 return md;
arsenalist 12:96f637ed37f9 251 }
arsenalist 12:96f637ed37f9 252 /*end lcd and touch*/
arsenalist 12:96f637ed37f9 253
arsenalist 12:96f637ed37f9 254 /*start emma mode*/
arsenalist 12:96f637ed37f9 255 void emmaInit(int mode) {
arsenalist 4:76ab12e2f8a3 256 char s[64];
arsenalist 0:f4e449fa34d7 257 DBG.baud(19200);
arsenalist 0:f4e449fa34d7 258 DBG.printf("\r\nemmaInit\r\n");
arsenalist 12:96f637ed37f9 259 DBG.printf("mode:%d\r\n",mode);
arsenalist 0:f4e449fa34d7 260
arsenalist 0:f4e449fa34d7 261 //read settings
arsenalist 0:f4e449fa34d7 262 //readSetting("emmaUID"); //sd card need to be read once before working correctly
arsenalist 9:a58c04da4476 263 emmaUID = readSetting("emmaUID");
arsenalist 9:a58c04da4476 264 //emmaUID = "066eff575349896767073038";
arsenalist 0:f4e449fa34d7 265 DBG.printf("emmaUID:%s\r\n",emmaUID.c_str());
arsenalist 4:76ab12e2f8a3 266 //calculate hmac
arsenalist 4:76ab12e2f8a3 267 for(int i=0; i<sizeof(s); i++) {
arsenalist 4:76ab12e2f8a3 268 s[i]=0; }
arsenalist 4:76ab12e2f8a3 269 sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist 4:76ab12e2f8a3 270 hmac = calculateMD5(s);
arsenalist 4:76ab12e2f8a3 271 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 9:a58c04da4476 272 platformDOMAIN = readSetting("platformDOMAIN");
arsenalist 9:a58c04da4476 273 //platformDOMAIN = "testdulu";
arsenalist 0:f4e449fa34d7 274 DBG.printf("platformDOMAIN:%s\r\n",platformDOMAIN.c_str());
arsenalist 9:a58c04da4476 275 platformKEY = readSetting("platformKEY");
arsenalist 9:a58c04da4476 276 //platformKEY = "5980e444-81dd-47ba-8222-6a40bc94fdce";
arsenalist 0:f4e449fa34d7 277 DBG.printf("platformKEY:%s\r\n",platformKEY.c_str());
arsenalist 9:a58c04da4476 278 platformSECRET = readSetting("platformSECRET");
arsenalist 9:a58c04da4476 279 //platformSECRET = "3ca8ec0239fda2b6d12ba1580c91a052";
arsenalist 0:f4e449fa34d7 280 DBG.printf("platformSECRET:%s\r\n",platformSECRET.c_str());
arsenalist 9:a58c04da4476 281 proxySERVER = readSetting("proxySERVER");
arsenalist 0:f4e449fa34d7 282 DBG.printf("proxySERVER:%s\r\n",proxySERVER.c_str());
arsenalist 9:a58c04da4476 283 proxyPORT = readSetting("proxyPORT");
arsenalist 0:f4e449fa34d7 284 DBG.printf("proxyPORT:%s\r\n",proxyPORT.c_str());
arsenalist 9:a58c04da4476 285 proxyAUTH = readSetting("proxyAUTH");
arsenalist 0:f4e449fa34d7 286 DBG.printf("proxyAUTH:%s\r\n",proxyAUTH.c_str());
arsenalist 28:7561035e3df5 287 wifiSSID = readSetting("wifiSSID");
arsenalist 28:7561035e3df5 288 DBG.printf("wifiSSID:%s\r\n",wifiSSID.c_str());
arsenalist 28:7561035e3df5 289 wifiPASS = readSetting("wifiPASS");
arsenalist 28:7561035e3df5 290 DBG.printf("wifiPASS:%s\r\n",wifiPASS.c_str());
arsenalist 0:f4e449fa34d7 291
arsenalist 0:f4e449fa34d7 292 //check proxy
arsenalist 0:f4e449fa34d7 293 if(!proxySERVER.empty() && !proxyPORT.empty() && !proxyAUTH.empty()) {
arsenalist 0:f4e449fa34d7 294 useProxy = true;
arsenalist 0:f4e449fa34d7 295 } else {
arsenalist 0:f4e449fa34d7 296 useProxy = false;
arsenalist 0:f4e449fa34d7 297 }
arsenalist 0:f4e449fa34d7 298 //testing purpose
arsenalist 0:f4e449fa34d7 299 useProxy = false;
arsenalist 0:f4e449fa34d7 300 DBG.printf("proxy:%d\r\n",useProxy);
arsenalist 0:f4e449fa34d7 301
arsenalist 8:51a0ca9079ca 302 //check available interface
arsenalist 8:51a0ca9079ca 303 isEthAvailable(); //check whether cable is connected
arsenalist 9:a58c04da4476 304 wifiAvailable = true; //we assume wifi will always available
arsenalist 8:51a0ca9079ca 305 DBG.printf("eth:%d\r\n",ethAvailable);
arsenalist 8:51a0ca9079ca 306 DBG.printf("wifi:%d\r\n",wifiAvailable);
arsenalist 8:51a0ca9079ca 307 DBG.printf("gprs:%d\r\n",gprsAvailable);
arsenalist 0:f4e449fa34d7 308 }
arsenalist 0:f4e449fa34d7 309 void emmaModeWiFiConfig(void) {
arsenalist 0:f4e449fa34d7 310 string str;
arsenalist 18:87f30ba9ddc5 311 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 312 TFT.printf(" please wait");
arsenalist 0:f4e449fa34d7 313
arsenalist 0:f4e449fa34d7 314 if(wifiAvailable) {
arsenalist 0:f4e449fa34d7 315 DBG.printf("emmaModeWiFiConfig\r\n");
arsenalist 0:f4e449fa34d7 316
arsenalist 0:f4e449fa34d7 317 //set wifi module to configuration
arsenalist 0:f4e449fa34d7 318 _ESP.printf("MODE=C");
arsenalist 0:f4e449fa34d7 319 while(1) {
arsenalist 0:f4e449fa34d7 320 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 321 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 322 str = rcv;
arsenalist 0:f4e449fa34d7 323 if(str.find("SC_STATUS_FIND_CHANNEL") != std::string::npos)
arsenalist 0:f4e449fa34d7 324 break;
arsenalist 0:f4e449fa34d7 325 }
arsenalist 18:87f30ba9ddc5 326
arsenalist 18:87f30ba9ddc5 327 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 328 TFT.printf(" emmaModeWiFiConfig");
arsenalist 18:87f30ba9ddc5 329 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 330 TFT.printf(" connect with emma app now");
arsenalist 18:87f30ba9ddc5 331
arsenalist 0:f4e449fa34d7 332 DBG.printf("entering wifi configuration mode\r\n");
arsenalist 0:f4e449fa34d7 333 while(1) {
arsenalist 0:f4e449fa34d7 334 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 335 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 336 str = rcv;
arsenalist 0:f4e449fa34d7 337 if(str.find("MODE=C OK") != std::string::npos) {
arsenalist 0:f4e449fa34d7 338 //save wifiSSID and wifiPASS
arsenalist 0:f4e449fa34d7 339 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 340 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 341 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 342
arsenalist 0:f4e449fa34d7 343 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 344 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 345
arsenalist 0:f4e449fa34d7 346 char *parameter[2] = {"wifiSSID","wifiPASS"};
arsenalist 0:f4e449fa34d7 347
arsenalist 0:f4e449fa34d7 348 for(int i=0; i<2; i++) {
arsenalist 0:f4e449fa34d7 349 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 350 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 11:2311b2d5157d 351 int st = writeSetting(parameter[i],val.c_str());
arsenalist 11:2311b2d5157d 352 if(st) {
arsenalist 11:2311b2d5157d 353 DBG.printf("%s is saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 354 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 355 TFT.printf(" %s is saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 356 wait(3);
arsenalist 18:87f30ba9ddc5 357 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 358 TFT.printf(" ");
arsenalist 11:2311b2d5157d 359 } else {
arsenalist 11:2311b2d5157d 360 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 361 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 362 TFT.printf(" %s is not saved\r\n",parameter[i]);
arsenalist 18:87f30ba9ddc5 363 wait(3);
arsenalist 18:87f30ba9ddc5 364 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 365 TFT.printf(" ");
arsenalist 11:2311b2d5157d 366 }
arsenalist 0:f4e449fa34d7 367 }
arsenalist 0:f4e449fa34d7 368 }
arsenalist 18:87f30ba9ddc5 369
arsenalist 18:87f30ba9ddc5 370 //wificonfig finish
arsenalist 18:87f30ba9ddc5 371 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 372 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 373 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 374 TFT.printf(" wificonfig finish. please restart.");
arsenalist 18:87f30ba9ddc5 375
arsenalist 0:f4e449fa34d7 376 }
arsenalist 18:87f30ba9ddc5 377 } else if(str.find("SC_STATUS_GETTING_SSID_PSWD") != std::string::npos){
arsenalist 18:87f30ba9ddc5 378 DBG.printf("app connected\r\n");
arsenalist 18:87f30ba9ddc5 379 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 380 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 381 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 382 TFT.printf(" app connected");
arsenalist 0:f4e449fa34d7 383 }
arsenalist 0:f4e449fa34d7 384 }
arsenalist 0:f4e449fa34d7 385 } else {
arsenalist 0:f4e449fa34d7 386 DBG.printf("no wifi found\r\n");
arsenalist 18:87f30ba9ddc5 387 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 388 TFT.printf(" no wifi found");
arsenalist 0:f4e449fa34d7 389 }
arsenalist 0:f4e449fa34d7 390 }
arsenalist 0:f4e449fa34d7 391 void emmaModeSettings(void) {
arsenalist 0:f4e449fa34d7 392 bool clientIsConnected = false;
arsenalist 0:f4e449fa34d7 393 bool serverIsListened = false;
arsenalist 0:f4e449fa34d7 394 char s[32];
arsenalist 0:f4e449fa34d7 395 string str;
arsenalist 0:f4e449fa34d7 396
arsenalist 18:87f30ba9ddc5 397 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 398 TFT.printf(" please wait");
arsenalist 18:87f30ba9ddc5 399
arsenalist 8:51a0ca9079ca 400 //create settings dir
arsenalist 0:f4e449fa34d7 401 mkdir("/sd/settings",0777);
arsenalist 8:51a0ca9079ca 402
arsenalist 0:f4e449fa34d7 403 //get and write emmaUID
arsenalist 0:f4e449fa34d7 404 string uid = getUID();
arsenalist 0:f4e449fa34d7 405 sprintf(s,"(%s)",uid.c_str());
arsenalist 0:f4e449fa34d7 406 uid = s;
arsenalist 0:f4e449fa34d7 407 writeSetting("emmaUID",uid);
arsenalist 0:f4e449fa34d7 408
arsenalist 8:51a0ca9079ca 409 if(ethAvailable) {
arsenalist 0:f4e449fa34d7 410 DBG.printf("emmaModeSettings - eth\r\n");
arsenalist 0:f4e449fa34d7 411
arsenalist 0:f4e449fa34d7 412 TCPSocketServer svr;
arsenalist 0:f4e449fa34d7 413 TCPSocketConnection clientSock;
arsenalist 0:f4e449fa34d7 414
arsenalist 0:f4e449fa34d7 415 if(svr.bind(SERVER_PORT) < 0) {
arsenalist 0:f4e449fa34d7 416 DBG.printf("tcp server bind failed\r\n");
arsenalist 0:f4e449fa34d7 417 } else {
arsenalist 0:f4e449fa34d7 418 DBG.printf("tcp server bind success\r\n");
arsenalist 0:f4e449fa34d7 419 serverIsListened = true;
arsenalist 0:f4e449fa34d7 420 }
arsenalist 0:f4e449fa34d7 421
arsenalist 0:f4e449fa34d7 422 DBG.printf("please connect to %s\r\n",ipstack.getEth().getIPAddress());
arsenalist 0:f4e449fa34d7 423
arsenalist 0:f4e449fa34d7 424 if(svr.listen(1) < 0) {
arsenalist 0:f4e449fa34d7 425 DBG.printf("tcp server listen failed\r\n");
arsenalist 0:f4e449fa34d7 426 } else {
arsenalist 0:f4e449fa34d7 427 DBG.printf("tcp server is listening...\r\n");
arsenalist 0:f4e449fa34d7 428 }
arsenalist 0:f4e449fa34d7 429
arsenalist 0:f4e449fa34d7 430 clientSock.set_blocking(false,30000); //timeout after 30sec
arsenalist 0:f4e449fa34d7 431
arsenalist 0:f4e449fa34d7 432 //listening
arsenalist 0:f4e449fa34d7 433 while (serverIsListened) {
arsenalist 0:f4e449fa34d7 434 if(svr.accept(clientSock) < 0) {
arsenalist 0:f4e449fa34d7 435 DBG.printf("failed to accept connection\r\n");
arsenalist 0:f4e449fa34d7 436 } else {
arsenalist 0:f4e449fa34d7 437 DBG.printf("connection success!\r\nIP: %s\r\n",clientSock.get_address());
arsenalist 0:f4e449fa34d7 438 clientIsConnected = true;
arsenalist 0:f4e449fa34d7 439
arsenalist 0:f4e449fa34d7 440 while(clientIsConnected) {
arsenalist 0:f4e449fa34d7 441 char buffer[1024] = {};
arsenalist 0:f4e449fa34d7 442 switch(clientSock.receive(buffer,1023)) {
arsenalist 0:f4e449fa34d7 443 case 0:
arsenalist 0:f4e449fa34d7 444 DBG.printf("received buffer is empty\r\n");
arsenalist 0:f4e449fa34d7 445 clientIsConnected = false;
arsenalist 0:f4e449fa34d7 446 break;
arsenalist 0:f4e449fa34d7 447 case -1:
arsenalist 0:f4e449fa34d7 448 DBG.printf("failed to read data from client\r\n");
arsenalist 0:f4e449fa34d7 449 clientIsConnected = false;
arsenalist 0:f4e449fa34d7 450 break;
arsenalist 0:f4e449fa34d7 451 default:
arsenalist 0:f4e449fa34d7 452 //DBG.printf("received data: %d\r\n%s\r\n",strlen(buffer),buffer);
arsenalist 0:f4e449fa34d7 453 DBG.printf("\r\n");
arsenalist 0:f4e449fa34d7 454
arsenalist 0:f4e449fa34d7 455 str = buffer;
arsenalist 0:f4e449fa34d7 456 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 457 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 458 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 459
arsenalist 0:f4e449fa34d7 460 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 461 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 462
arsenalist 14:8287f0f5d987 463 char *parameter[5] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH","epochTime"};
arsenalist 0:f4e449fa34d7 464
arsenalist 0:f4e449fa34d7 465 for(int i=0; i<4; i++) {
arsenalist 0:f4e449fa34d7 466 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 467 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 468 int st = writeSetting(parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 469 if(st) {
arsenalist 0:f4e449fa34d7 470 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 471 } else {
arsenalist 0:f4e449fa34d7 472 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 0:f4e449fa34d7 473 }
arsenalist 0:f4e449fa34d7 474 }
arsenalist 0:f4e449fa34d7 475 }
arsenalist 14:8287f0f5d987 476
arsenalist 14:8287f0f5d987 477 //set time
arsenalist 14:8287f0f5d987 478 if(jsonValue.hasMember(parameter[4])) {
arsenalist 14:8287f0f5d987 479 string epTime = jsonValue[parameter[4]].get<std::string>();
arsenalist 20:ea14f175bbb4 480 time_t seconds;
arsenalist 14:8287f0f5d987 481 sscanf(epTime.c_str(),"%d",&seconds);
arsenalist 14:8287f0f5d987 482 set_time(seconds);
arsenalist 14:8287f0f5d987 483 DBG.printf("time is set\r\n");
arsenalist 14:8287f0f5d987 484 }
arsenalist 0:f4e449fa34d7 485 }
arsenalist 0:f4e449fa34d7 486 break;
arsenalist 0:f4e449fa34d7 487 }
arsenalist 0:f4e449fa34d7 488 }
arsenalist 0:f4e449fa34d7 489 DBG.printf("close connection\r\n");
arsenalist 0:f4e449fa34d7 490 clientSock.close();
arsenalist 0:f4e449fa34d7 491 }
arsenalist 0:f4e449fa34d7 492 }
arsenalist 8:51a0ca9079ca 493 } else if(wifiAvailable) {
arsenalist 8:51a0ca9079ca 494 DBG.printf("emmaModeSettings - wifi\r\n");
arsenalist 8:51a0ca9079ca 495
arsenalist 8:51a0ca9079ca 496 _ESP.printf("MODE=S");
arsenalist 8:51a0ca9079ca 497 while(1) {
arsenalist 8:51a0ca9079ca 498 char rcv[128] = {};
arsenalist 8:51a0ca9079ca 499 rcvReply(rcv,3000);
arsenalist 8:51a0ca9079ca 500 str = rcv;
arsenalist 8:51a0ca9079ca 501 if(str.find("MODE=S_OK") != std::string::npos)
arsenalist 8:51a0ca9079ca 502 break;
arsenalist 8:51a0ca9079ca 503 }
arsenalist 8:51a0ca9079ca 504 DBG.printf("entering settings mode\r\n");
arsenalist 17:b3ced0e67916 505 TFT.locate(0,0);
arsenalist 17:b3ced0e67916 506 TFT.printf(" emmaModeSettings");
arsenalist 17:b3ced0e67916 507 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 508 TFT.printf(" connect with emma app now");
arsenalist 17:b3ced0e67916 509
arsenalist 8:51a0ca9079ca 510 while(1) {
arsenalist 8:51a0ca9079ca 511 char rcv[512] = {};
arsenalist 8:51a0ca9079ca 512 rcvReply(rcv,3000);
arsenalist 8:51a0ca9079ca 513 //DBG.printf("rcv:%s\r\n",rcv);
arsenalist 8:51a0ca9079ca 514 str = rcv;
arsenalist 8:51a0ca9079ca 515 if(str.find("MODE=S_Config") != std::string::npos) {
arsenalist 8:51a0ca9079ca 516 //save gprs and proxy setting
arsenalist 8:51a0ca9079ca 517 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 8:51a0ca9079ca 518 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 8:51a0ca9079ca 519 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 8:51a0ca9079ca 520
arsenalist 8:51a0ca9079ca 521 MbedJSONValue jsonValue;
arsenalist 8:51a0ca9079ca 522 parse(jsonValue,str.c_str());
arsenalist 8:51a0ca9079ca 523
arsenalist 14:8287f0f5d987 524 char *parameter[5] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH","epochTime"};
arsenalist 8:51a0ca9079ca 525
arsenalist 8:51a0ca9079ca 526 for(int i=0; i<4; i++) {
arsenalist 8:51a0ca9079ca 527 if(jsonValue.hasMember(parameter[i])) {
arsenalist 8:51a0ca9079ca 528 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 8:51a0ca9079ca 529 int st = writeSetting(parameter[i],val.c_str());
arsenalist 8:51a0ca9079ca 530 if(st) {
arsenalist 8:51a0ca9079ca 531 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 17:b3ced0e67916 532 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 533 TFT.printf(" %s: %s is saved",parameter[i],val.c_str());
arsenalist 17:b3ced0e67916 534 wait(3);
arsenalist 17:b3ced0e67916 535 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 536 TFT.printf(" ");
arsenalist 8:51a0ca9079ca 537 } else {
arsenalist 8:51a0ca9079ca 538 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 17:b3ced0e67916 539 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 540 TFT.printf(" %s is not saved",parameter[i]);
arsenalist 17:b3ced0e67916 541 wait(3);
arsenalist 17:b3ced0e67916 542 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 543 TFT.printf(" ");
arsenalist 8:51a0ca9079ca 544 }
arsenalist 8:51a0ca9079ca 545 }
arsenalist 8:51a0ca9079ca 546 }
arsenalist 14:8287f0f5d987 547
arsenalist 14:8287f0f5d987 548 //set time
arsenalist 14:8287f0f5d987 549 if(jsonValue.hasMember(parameter[4])) {
arsenalist 14:8287f0f5d987 550 string epTime = jsonValue[parameter[4]].get<std::string>();
arsenalist 14:8287f0f5d987 551 time_t seconds;
arsenalist 14:8287f0f5d987 552 sscanf(epTime.c_str(),"%d",&seconds);
arsenalist 14:8287f0f5d987 553 set_time(seconds);
arsenalist 14:8287f0f5d987 554 DBG.printf("time is set\r\n");
arsenalist 17:b3ced0e67916 555 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 556 TFT.printf(" time is set");
arsenalist 17:b3ced0e67916 557 wait(3);
arsenalist 17:b3ced0e67916 558 TFT.locate(0,40);
arsenalist 17:b3ced0e67916 559 TFT.printf(" ");
arsenalist 14:8287f0f5d987 560 }
arsenalist 18:87f30ba9ddc5 561
arsenalist 18:87f30ba9ddc5 562 //setting finish
arsenalist 18:87f30ba9ddc5 563 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 564 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 565 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 566 TFT.printf(" settings finish. please restart.");
arsenalist 8:51a0ca9079ca 567 }
arsenalist 8:51a0ca9079ca 568 } else if(str.find("connect") != std::string::npos) {
arsenalist 8:51a0ca9079ca 569 DBG.printf("connection success!\r\n");
arsenalist 17:b3ced0e67916 570 TFT.locate(0,20);
arsenalist 17:b3ced0e67916 571 TFT.printf(" ");
arsenalist 17:b3ced0e67916 572 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 573 TFT.printf(" connection success");
arsenalist 8:51a0ca9079ca 574 }
arsenalist 8:51a0ca9079ca 575 }
arsenalist 0:f4e449fa34d7 576 } else {
arsenalist 9:a58c04da4476 577 DBG.printf("no eth or wifi is available\r\n");
arsenalist 17:b3ced0e67916 578 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 579 TFT.printf(" no iface avail, please restart!");
arsenalist 0:f4e449fa34d7 580 }
arsenalist 0:f4e449fa34d7 581 }
arsenalist 0:f4e449fa34d7 582 void emmaModeRegister(void) {
arsenalist 0:f4e449fa34d7 583 bool emmaGetRegKey = false;
arsenalist 0:f4e449fa34d7 584 bool emmaRegistered = false;
arsenalist 0:f4e449fa34d7 585 char s[512];
arsenalist 0:f4e449fa34d7 586 char r[256];
arsenalist 0:f4e449fa34d7 587 int connPort;
arsenalist 0:f4e449fa34d7 588 int loop = 0;
arsenalist 0:f4e449fa34d7 589 string connData;
arsenalist 0:f4e449fa34d7 590 string connHost;
arsenalist 4:76ab12e2f8a3 591 //string hmac;
arsenalist 0:f4e449fa34d7 592 string str;
arsenalist 0:f4e449fa34d7 593 string regKey;
arsenalist 0:f4e449fa34d7 594 Timer t;
arsenalist 0:f4e449fa34d7 595
arsenalist 18:87f30ba9ddc5 596 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 597 TFT.printf(" please wait");
arsenalist 18:87f30ba9ddc5 598
arsenalist 0:f4e449fa34d7 599 //check connected interface
arsenalist 8:51a0ca9079ca 600 //connectedIface();
arsenalist 8:51a0ca9079ca 601 isEthConnected();
arsenalist 8:51a0ca9079ca 602 isWiFiConnected();
arsenalist 8:51a0ca9079ca 603 isGprsConnected();
arsenalist 0:f4e449fa34d7 604 DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist 0:f4e449fa34d7 605 DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist 0:f4e449fa34d7 606
arsenalist 0:f4e449fa34d7 607 //calculate hmac
arsenalist 4:76ab12e2f8a3 608 //for(int i=0; i<sizeof(s); i++) {
arsenalist 4:76ab12e2f8a3 609 // s[i]=0; }
arsenalist 4:76ab12e2f8a3 610 //sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist 4:76ab12e2f8a3 611 //hmac = calculateMD5(s);
arsenalist 4:76ab12e2f8a3 612 //DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 0:f4e449fa34d7 613
arsenalist 9:a58c04da4476 614 if(ethConnected) {
arsenalist 9:a58c04da4476 615 DBG.printf("emmaModeRegister - eth\r\n");
arsenalist 9:a58c04da4476 616
arsenalist 9:a58c04da4476 617 //set connHost, connPort, connData
arsenalist 9:a58c04da4476 618 if(useProxy) {
arsenalist 9:a58c04da4476 619 DBG.printf("use proxy\r\n");
arsenalist 9:a58c04da4476 620 connHost = proxySERVER;
arsenalist 9:a58c04da4476 621 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 9:a58c04da4476 622 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 623 s[i]=0; }
arsenalist 9:a58c04da4476 624 sprintf(s,"GET http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist 9:a58c04da4476 625 connData = s;
arsenalist 9:a58c04da4476 626 } else {
arsenalist 9:a58c04da4476 627 DBG.printf("no proxy\r\n");
arsenalist 9:a58c04da4476 628 connHost = EMMA_SERVER_HOST;
arsenalist 9:a58c04da4476 629 connPort = EMMA_SERVER_PORT;
arsenalist 9:a58c04da4476 630 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 631 s[i]=0; }
arsenalist 9:a58c04da4476 632 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(),EMMA_SERVER_HOST);
arsenalist 9:a58c04da4476 633 connData = s;
arsenalist 9:a58c04da4476 634 }
arsenalist 9:a58c04da4476 635
arsenalist 9:a58c04da4476 636 //register
arsenalist 9:a58c04da4476 637 while(!emmaGetRegKey) {
arsenalist 9:a58c04da4476 638 str = "";
arsenalist 9:a58c04da4476 639 str = ethGET(connHost,connPort,connData);
arsenalist 9:a58c04da4476 640 DBG.printf("rsp reg:%s\r\n",str.c_str());
arsenalist 9:a58c04da4476 641
arsenalist 9:a58c04da4476 642 //check and save platform setting
arsenalist 9:a58c04da4476 643 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 9:a58c04da4476 644 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 9:a58c04da4476 645 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 9:a58c04da4476 646
arsenalist 9:a58c04da4476 647 MbedJSONValue jsonValue;
arsenalist 9:a58c04da4476 648 parse(jsonValue,str.c_str());
arsenalist 9:a58c04da4476 649
arsenalist 9:a58c04da4476 650 char *parameter[4] = {"platformDOMAIN","platformKEY","platformSECRET","registrationKey"};
arsenalist 9:a58c04da4476 651
arsenalist 9:a58c04da4476 652 //save platform parameter
arsenalist 9:a58c04da4476 653 writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist 9:a58c04da4476 654 for(int i=0; i<3; i++) {
arsenalist 9:a58c04da4476 655 if(jsonValue.hasMember(parameter[i])) {
arsenalist 9:a58c04da4476 656 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 9:a58c04da4476 657 int st = writeSetting(parameter[i],val.c_str());
arsenalist 9:a58c04da4476 658 if(st) {
arsenalist 9:a58c04da4476 659 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 9:a58c04da4476 660 } else {
arsenalist 9:a58c04da4476 661 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 9:a58c04da4476 662 }
arsenalist 9:a58c04da4476 663 }
arsenalist 9:a58c04da4476 664 }
arsenalist 9:a58c04da4476 665
arsenalist 9:a58c04da4476 666 //get registrationKey
arsenalist 9:a58c04da4476 667 if(jsonValue.hasMember(parameter[3])) {
arsenalist 9:a58c04da4476 668 string val = jsonValue[parameter[3]].get<std::string>();
arsenalist 9:a58c04da4476 669 if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist 9:a58c04da4476 670 val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist 9:a58c04da4476 671 val.erase(val.begin()+val.find(")"),val.end());
arsenalist 9:a58c04da4476 672 regKey = val;
arsenalist 9:a58c04da4476 673 DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 9:a58c04da4476 674 emmaGetRegKey = true;
arsenalist 9:a58c04da4476 675 }
arsenalist 9:a58c04da4476 676 }
arsenalist 9:a58c04da4476 677 }
arsenalist 9:a58c04da4476 678 }
arsenalist 9:a58c04da4476 679
arsenalist 9:a58c04da4476 680 //calculate hmac
arsenalist 9:a58c04da4476 681 for(int i=0; i<sizeof(r); i++) {
arsenalist 9:a58c04da4476 682 r[i]=0; }
arsenalist 9:a58c04da4476 683 sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist 9:a58c04da4476 684 hmac = calculateMD5(r);
arsenalist 9:a58c04da4476 685 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 9:a58c04da4476 686
arsenalist 9:a58c04da4476 687 //set connData
arsenalist 9:a58c04da4476 688 if(useProxy) {
arsenalist 9:a58c04da4476 689 DBG.printf("use proxy\r\n");
arsenalist 9:a58c04da4476 690 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 691 s[i]=0; }
arsenalist 9:a58c04da4476 692 sprintf(s,"GET http://%s:%d/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),regKey.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist 9:a58c04da4476 693 connData = s;
arsenalist 9:a58c04da4476 694 } else {
arsenalist 9:a58c04da4476 695 DBG.printf("no proxy\r\n");
arsenalist 9:a58c04da4476 696 for(int i=0; i<sizeof(s); i++) {
arsenalist 9:a58c04da4476 697 s[i]=0; }
arsenalist 9:a58c04da4476 698 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(),EMMA_SERVER_HOST);
arsenalist 9:a58c04da4476 699 connData = s;
arsenalist 9:a58c04da4476 700 }
arsenalist 9:a58c04da4476 701
arsenalist 9:a58c04da4476 702 //verify registration
arsenalist 9:a58c04da4476 703 while(!emmaRegistered && loop < 12){
arsenalist 9:a58c04da4476 704 str.clear();
arsenalist 9:a58c04da4476 705 str = ethGET(connHost,connPort,connData);
arsenalist 9:a58c04da4476 706 DBG.printf("rsp vrf:%s\r\n",str.c_str());
arsenalist 9:a58c04da4476 707
arsenalist 9:a58c04da4476 708 //check verification
arsenalist 9:a58c04da4476 709 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 9:a58c04da4476 710 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 9:a58c04da4476 711 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 9:a58c04da4476 712
arsenalist 9:a58c04da4476 713 MbedJSONValue jsonValue;
arsenalist 9:a58c04da4476 714 parse(jsonValue,str.c_str());
arsenalist 9:a58c04da4476 715 if(jsonValue.hasMember("user")) {
arsenalist 9:a58c04da4476 716 string val = jsonValue["user"].get<std::string>();
arsenalist 9:a58c04da4476 717 DBG.printf("%s is registered\r\n",val.c_str());
arsenalist 9:a58c04da4476 718 emmaRegistered = true;
arsenalist 9:a58c04da4476 719 }
arsenalist 9:a58c04da4476 720 }
arsenalist 9:a58c04da4476 721 wait(5);
arsenalist 9:a58c04da4476 722 loop++;
arsenalist 9:a58c04da4476 723 }
arsenalist 9:a58c04da4476 724
arsenalist 9:a58c04da4476 725 //check whether registration success
arsenalist 9:a58c04da4476 726 if(emmaRegistered) {
arsenalist 9:a58c04da4476 727 DBG.printf("registration successful\r\n");
arsenalist 9:a58c04da4476 728 } else {
arsenalist 9:a58c04da4476 729 DBG.printf("registration unsuccessful\r\n");
arsenalist 9:a58c04da4476 730 }
arsenalist 9:a58c04da4476 731 while(1);
arsenalist 9:a58c04da4476 732
arsenalist 9:a58c04da4476 733 } else if(wifiConnected) {
arsenalist 0:f4e449fa34d7 734 DBG.printf("emmaModeRegister - wifi\r\n");
arsenalist 0:f4e449fa34d7 735
arsenalist 0:f4e449fa34d7 736 _ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 737 wait(1);
arsenalist 0:f4e449fa34d7 738 while(!esp.ready());
arsenalist 0:f4e449fa34d7 739
arsenalist 0:f4e449fa34d7 740 //set connHost, connPort
arsenalist 0:f4e449fa34d7 741 if(useProxy) {
arsenalist 0:f4e449fa34d7 742 connHost = proxySERVER;
arsenalist 0:f4e449fa34d7 743 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 0:f4e449fa34d7 744 } else {
arsenalist 0:f4e449fa34d7 745 connHost = EMMA_SERVER_HOST;
arsenalist 0:f4e449fa34d7 746 connPort = EMMA_SERVER_PORT;
arsenalist 0:f4e449fa34d7 747 }
arsenalist 18:87f30ba9ddc5 748 TFT.locate(0,0);
arsenalist 18:87f30ba9ddc5 749 TFT.printf(" emmaModeRegister");
arsenalist 0:f4e449fa34d7 750
arsenalist 0:f4e449fa34d7 751 //rest begin
arsenalist 0:f4e449fa34d7 752 if(!rest.begin(connHost.c_str(),connPort,false)) {
arsenalist 0:f4e449fa34d7 753 DBG.printf("EMMA: fail to setup rest");
arsenalist 0:f4e449fa34d7 754 while(1);
arsenalist 0:f4e449fa34d7 755 }
arsenalist 0:f4e449fa34d7 756 //wifiConnected = true; //with custom firmware, wifi module should connect automatically
arsenalist 0:f4e449fa34d7 757
arsenalist 0:f4e449fa34d7 758 esp.process();
arsenalist 0:f4e449fa34d7 759 if(wifiConnected) {
arsenalist 0:f4e449fa34d7 760 //set connData
arsenalist 0:f4e449fa34d7 761 if(useProxy) {
arsenalist 0:f4e449fa34d7 762 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 763 s[i]=0; }
arsenalist 0:f4e449fa34d7 764 sprintf(s,"http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 765 connData = s;
arsenalist 0:f4e449fa34d7 766 } else {
arsenalist 0:f4e449fa34d7 767 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 768 s[i]=0; }
arsenalist 0:f4e449fa34d7 769 sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 770 connData = s;
arsenalist 0:f4e449fa34d7 771 }
arsenalist 0:f4e449fa34d7 772
arsenalist 0:f4e449fa34d7 773 //register
arsenalist 0:f4e449fa34d7 774 while(!emmaGetRegKey) {
arsenalist 0:f4e449fa34d7 775 rest.get(connData.c_str());
arsenalist 0:f4e449fa34d7 776 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 777 s[i]=0; }
arsenalist 0:f4e449fa34d7 778 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 779 DBG.printf("rsp reg:%s\r\n",s);
arsenalist 0:f4e449fa34d7 780
arsenalist 0:f4e449fa34d7 781 //check and save platform setting
arsenalist 0:f4e449fa34d7 782 str = s;
arsenalist 0:f4e449fa34d7 783 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 784 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 785 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 786
arsenalist 0:f4e449fa34d7 787 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 788 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 789
arsenalist 0:f4e449fa34d7 790 char *parameter[4] = {"platformDOMAIN","platformKEY","platformSECRET","registrationKey"};
arsenalist 0:f4e449fa34d7 791
arsenalist 0:f4e449fa34d7 792 //save platform parameter
arsenalist 0:f4e449fa34d7 793 writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist 0:f4e449fa34d7 794 for(int i=0; i<3; i++) {
arsenalist 0:f4e449fa34d7 795 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 796 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 797 int st = writeSetting(parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 798 if(st) {
arsenalist 0:f4e449fa34d7 799 DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist 0:f4e449fa34d7 800 } else {
arsenalist 0:f4e449fa34d7 801 DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist 0:f4e449fa34d7 802 }
arsenalist 0:f4e449fa34d7 803 }
arsenalist 0:f4e449fa34d7 804 }
arsenalist 0:f4e449fa34d7 805
arsenalist 0:f4e449fa34d7 806 //get registrationKey
arsenalist 0:f4e449fa34d7 807 if(jsonValue.hasMember(parameter[3])) {
arsenalist 0:f4e449fa34d7 808 string val = jsonValue[parameter[3]].get<std::string>();
arsenalist 0:f4e449fa34d7 809 if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 810 val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist 0:f4e449fa34d7 811 val.erase(val.begin()+val.find(")"),val.end());
arsenalist 0:f4e449fa34d7 812 regKey = val;
arsenalist 0:f4e449fa34d7 813 DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 18:87f30ba9ddc5 814
arsenalist 18:87f30ba9ddc5 815 TFT.locate(0,20);
arsenalist 18:87f30ba9ddc5 816 TFT.printf(" %s: %s\r\n",parameter[3],regKey.c_str());
arsenalist 18:87f30ba9ddc5 817
arsenalist 0:f4e449fa34d7 818 emmaGetRegKey = true;
arsenalist 0:f4e449fa34d7 819 }
arsenalist 0:f4e449fa34d7 820 }
arsenalist 0:f4e449fa34d7 821 }
arsenalist 0:f4e449fa34d7 822 }
arsenalist 0:f4e449fa34d7 823
arsenalist 0:f4e449fa34d7 824 //calculate hmac
arsenalist 0:f4e449fa34d7 825 for(int i=0; i<sizeof(r); i++) {
arsenalist 0:f4e449fa34d7 826 r[i]=0; }
arsenalist 0:f4e449fa34d7 827 sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist 0:f4e449fa34d7 828 hmac = calculateMD5(r);
arsenalist 0:f4e449fa34d7 829 DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 0:f4e449fa34d7 830
arsenalist 0:f4e449fa34d7 831 //set connData
arsenalist 0:f4e449fa34d7 832 if(useProxy) {
arsenalist 0:f4e449fa34d7 833 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 834 s[i]=0; }
arsenalist 0:f4e449fa34d7 835 sprintf(s,"http://%s:%d/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 836 connData = s;
arsenalist 0:f4e449fa34d7 837 } else {
arsenalist 0:f4e449fa34d7 838 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 839 s[i]=0; }
arsenalist 0:f4e449fa34d7 840 sprintf(s,"/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s",emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 841 connData = s;
arsenalist 0:f4e449fa34d7 842 }
arsenalist 0:f4e449fa34d7 843
arsenalist 0:f4e449fa34d7 844 //verify registration
arsenalist 0:f4e449fa34d7 845 while(!emmaRegistered && loop < 12){
arsenalist 0:f4e449fa34d7 846 rest.get(connData.c_str());
arsenalist 0:f4e449fa34d7 847 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 848 s[i]=0; }
arsenalist 0:f4e449fa34d7 849 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 850 DBG.printf("rsp vrf:%s\r\n",s);
arsenalist 18:87f30ba9ddc5 851 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 852 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 853 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 854 TFT.printf(" wait:%d\r\n",loop);
arsenalist 0:f4e449fa34d7 855
arsenalist 0:f4e449fa34d7 856 //check verification
arsenalist 0:f4e449fa34d7 857 str = s;
arsenalist 0:f4e449fa34d7 858 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 859 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 860 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 861
arsenalist 0:f4e449fa34d7 862 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 863 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 864 if(jsonValue.hasMember("user")) {
arsenalist 0:f4e449fa34d7 865 string val = jsonValue["user"].get<std::string>();
arsenalist 18:87f30ba9ddc5 866 DBG.printf(" %s is registered\r\n",val.c_str());
arsenalist 18:87f30ba9ddc5 867 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 868 TFT.printf(" ");
arsenalist 18:87f30ba9ddc5 869 TFT.locate(0,40);
arsenalist 18:87f30ba9ddc5 870 TFT.printf(" %s is registered\r\n",val.c_str());
arsenalist 0:f4e449fa34d7 871 emmaRegistered = true;
arsenalist 0:f4e449fa34d7 872 }
arsenalist 0:f4e449fa34d7 873 }
arsenalist 0:f4e449fa34d7 874 wait(5);
arsenalist 0:f4e449fa34d7 875 loop++;
arsenalist 0:f4e449fa34d7 876 }
arsenalist 0:f4e449fa34d7 877
arsenalist 0:f4e449fa34d7 878 //check whether registration success
arsenalist 0:f4e449fa34d7 879 if(emmaRegistered) {
arsenalist 0:f4e449fa34d7 880 DBG.printf("registration successful\r\n");
arsenalist 18:87f30ba9ddc5 881 TFT.locate(0,60);
arsenalist 18:87f30ba9ddc5 882 TFT.printf(" registration successful\r\n");
arsenalist 0:f4e449fa34d7 883 } else {
arsenalist 0:f4e449fa34d7 884 DBG.printf("registration unsuccessful\r\n");
arsenalist 18:87f30ba9ddc5 885 TFT.locate(0,60);
arsenalist 18:87f30ba9ddc5 886 TFT.printf(" egistration unsuccessful. please restart.\r\n");
arsenalist 0:f4e449fa34d7 887 }
arsenalist 0:f4e449fa34d7 888 while(1);
arsenalist 0:f4e449fa34d7 889 }
arsenalist 0:f4e449fa34d7 890
arsenalist 9:a58c04da4476 891 } else if(gprsConnected) {
arsenalist 0:f4e449fa34d7 892 DBG.printf("emmaModeRegister - gprs\r\n");
arsenalist 0:f4e449fa34d7 893
arsenalist 0:f4e449fa34d7 894 } else {
arsenalist 9:a58c04da4476 895 DBG.printf("no eth, wifi, or gprs is connected\r\n");
arsenalist 18:87f30ba9ddc5 896 TFT.locate(0,60);
arsenalist 18:87f30ba9ddc5 897 TFT.printf(" no iface connected. please restart.\r\n");
arsenalist 0:f4e449fa34d7 898 }
arsenalist 0:f4e449fa34d7 899 }
arsenalist 0:f4e449fa34d7 900
arsenalist 0:f4e449fa34d7 901 void emmaModeOperation(void) {
arsenalist 27:562a95c120cc 902 //char mqttClientId[32];
arsenalist 22:e18d361bf688 903 char p[64];
arsenalist 14:8287f0f5d987 904 char q[32];
arsenalist 4:76ab12e2f8a3 905 char r[32];
arsenalist 0:f4e449fa34d7 906 char s[512];
arsenalist 30:08d290158fa7 907 int dbgLoop=0;
arsenalist 0:f4e449fa34d7 908 int loop=0;
arsenalist 21:33bd8b82560f 909 int trial=0;
arsenalist 4:76ab12e2f8a3 910 //string hmac;
arsenalist 22:e18d361bf688 911 string hmacTime;
arsenalist 23:fb369e171b7d 912 string hmacCmd;
arsenalist 0:f4e449fa34d7 913 string str;
arsenalist 14:8287f0f5d987 914 time_t seconds;
arsenalist 0:f4e449fa34d7 915 Timer t;
arsenalist 24:5d58515ba510 916 Timer tPanelEnergy;
arsenalist 24:5d58515ba510 917 Timer tPanel;
arsenalist 4:76ab12e2f8a3 918 Timer tNodes;
arsenalist 0:f4e449fa34d7 919
arsenalist 19:7e3e9332f719 920 TFT.locate(0,0);
arsenalist 19:7e3e9332f719 921 TFT.printf(" please wait");
arsenalist 19:7e3e9332f719 922
arsenalist 0:f4e449fa34d7 923 //check connected interface
arsenalist 8:51a0ca9079ca 924 //connectedIface();
arsenalist 8:51a0ca9079ca 925 isEthConnected();
arsenalist 8:51a0ca9079ca 926 isWiFiConnected();
arsenalist 8:51a0ca9079ca 927 isGprsConnected();
arsenalist 0:f4e449fa34d7 928 DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist 0:f4e449fa34d7 929 DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist 0:f4e449fa34d7 930
arsenalist 13:e8adfe305dbc 931 TFT.locate(0,0);
arsenalist 13:e8adfe305dbc 932 TFT.printf(" emmaModeOperation");
arsenalist 13:e8adfe305dbc 933
arsenalist 13:e8adfe305dbc 934 TFT.locate(0,20);
arsenalist 13:e8adfe305dbc 935 if(ethConnected) {
arsenalist 13:e8adfe305dbc 936 TFT.printf("ETH:Avail");
arsenalist 13:e8adfe305dbc 937 } else {
arsenalist 13:e8adfe305dbc 938 TFT.printf("ETH:N/A");
arsenalist 13:e8adfe305dbc 939 }
arsenalist 13:e8adfe305dbc 940
arsenalist 13:e8adfe305dbc 941 TFT.locate(80,20);
arsenalist 13:e8adfe305dbc 942 if(wifiConnected) {
arsenalist 13:e8adfe305dbc 943 TFT.printf("WiFi:Avail");
arsenalist 13:e8adfe305dbc 944 } else {
arsenalist 13:e8adfe305dbc 945 TFT.printf("WiFi:N/A");
arsenalist 13:e8adfe305dbc 946 }
arsenalist 13:e8adfe305dbc 947
arsenalist 13:e8adfe305dbc 948 TFT.locate(160,20);
arsenalist 13:e8adfe305dbc 949 if(gprsConnected) {
arsenalist 13:e8adfe305dbc 950 TFT.printf("GPRS:Avail");
arsenalist 13:e8adfe305dbc 951 } else {
arsenalist 13:e8adfe305dbc 952 TFT.printf("GPRS:N/A");
arsenalist 13:e8adfe305dbc 953 }
arsenalist 13:e8adfe305dbc 954
arsenalist 0:f4e449fa34d7 955 //calculate hmac
arsenalist 4:76ab12e2f8a3 956 //for(int j=0; j<sizeof(s); j++) {
arsenalist 4:76ab12e2f8a3 957 // s[j]=0; }
arsenalist 4:76ab12e2f8a3 958 //sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist 4:76ab12e2f8a3 959 //hmac = calculateMD5(s);
arsenalist 4:76ab12e2f8a3 960 //DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist 0:f4e449fa34d7 961
arsenalist 10:1dc69e0ce7fd 962 if(ethConnected) {
arsenalist 10:1dc69e0ce7fd 963 DBG.printf("emmaModeOperation - eth\r\n");
arsenalist 10:1dc69e0ce7fd 964 //DBG.printf("IP Address:%s\r\n",ipstack.getEth().getIPAddress());
arsenalist 10:1dc69e0ce7fd 965 //DBG.printf("MAC Address:%s\r\n",ipstack.getEth().getMACAddress());
arsenalist 10:1dc69e0ce7fd 966 ethMQTTAttemptConnect(&client, &ipstack);
arsenalist 10:1dc69e0ce7fd 967 //t.start();
arsenalist 10:1dc69e0ce7fd 968 DBG.printf("start\r\n");
arsenalist 10:1dc69e0ce7fd 969 while(true) {
arsenalist 10:1dc69e0ce7fd 970 //if(!ipstack.getEth().linkstatus()) {
arsenalist 10:1dc69e0ce7fd 971 // NVIC_SystemReset();
arsenalist 10:1dc69e0ce7fd 972 //}
arsenalist 10:1dc69e0ce7fd 973 //if(t.read_ms() > 5000) {
arsenalist 10:1dc69e0ce7fd 974 // if(publish(&client,&ipstack) != 0)
arsenalist 10:1dc69e0ce7fd 975 // ethMQTTAttemptConnect(&client, &ipstack);
arsenalist 10:1dc69e0ce7fd 976 // t.reset();
arsenalist 10:1dc69e0ce7fd 977 //}
arsenalist 10:1dc69e0ce7fd 978
arsenalist 10:1dc69e0ce7fd 979 //check for new command
arsenalist 10:1dc69e0ce7fd 980 if(newCommand) {
arsenalist 10:1dc69e0ce7fd 981 DBG.printf("newCommand\r\n");
arsenalist 10:1dc69e0ce7fd 982 //DBG.printf("globalCommand: %s\r\n",globalCommand.c_str());
arsenalist 10:1dc69e0ce7fd 983 //string qw(globCmd);
arsenalist 10:1dc69e0ce7fd 984
arsenalist 10:1dc69e0ce7fd 985 //if(cmd.find("[") != std::string::npos && cmd.find("]") != std::string::npos) {
arsenalist 10:1dc69e0ce7fd 986 // cmd.erase(cmd.begin(),cmd.begin()+cmd.find("[")+1);
arsenalist 10:1dc69e0ce7fd 987 // cmd.erase(cmd.begin()+cmd.find("]"),cmd.end());
arsenalist 10:1dc69e0ce7fd 988 //globalCommand = cmd;
arsenalist 10:1dc69e0ce7fd 989 //newCommand = true;
arsenalist 10:1dc69e0ce7fd 990 //}
arsenalist 10:1dc69e0ce7fd 991 /*
arsenalist 10:1dc69e0ce7fd 992 MbedJSONValue jsonValue;
arsenalist 10:1dc69e0ce7fd 993 parse(jsonValue,globalCommand.c_str());
arsenalist 10:1dc69e0ce7fd 994 char *parameter[5] = {"id","nType","nAddr","dType","cmd"};
arsenalist 10:1dc69e0ce7fd 995
arsenalist 10:1dc69e0ce7fd 996 //check if command is valid
arsenalist 10:1dc69e0ce7fd 997 bool validCommand = true;
arsenalist 10:1dc69e0ce7fd 998 for(int i=0; i<5; i++) {
arsenalist 10:1dc69e0ce7fd 999 validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist 10:1dc69e0ce7fd 1000 }
arsenalist 10:1dc69e0ce7fd 1001 DBG.printf("command validity:%d\r\n",validCommand);
arsenalist 10:1dc69e0ce7fd 1002
arsenalist 10:1dc69e0ce7fd 1003 if(validCommand) {
arsenalist 10:1dc69e0ce7fd 1004 string commandId = jsonValue[parameter[0]].get<std::string>();
arsenalist 10:1dc69e0ce7fd 1005 string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist 10:1dc69e0ce7fd 1006 string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist 10:1dc69e0ce7fd 1007 string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist 10:1dc69e0ce7fd 1008 string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist 10:1dc69e0ce7fd 1009
arsenalist 10:1dc69e0ce7fd 1010 if(commandNType == "0") { //switch on panel controller
arsenalist 10:1dc69e0ce7fd 1011 DBG.printf("command for switch\r\n");
arsenalist 10:1dc69e0ce7fd 1012 }
arsenalist 10:1dc69e0ce7fd 1013 else if(commandNType == "1") { //node with mac address
arsenalist 10:1dc69e0ce7fd 1014 DBG.printf("command for node\r\n");
arsenalist 10:1dc69e0ce7fd 1015 //get node ip address based on node mac address
arsenalist 10:1dc69e0ce7fd 1016 string nodeIP = readNodeIP(commandNAddr);
arsenalist 10:1dc69e0ce7fd 1017 DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist 10:1dc69e0ce7fd 1018
arsenalist 10:1dc69e0ce7fd 1019 //get cmd string based on device type and command number
arsenalist 10:1dc69e0ce7fd 1020 string nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist 10:1dc69e0ce7fd 1021 DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist 10:1dc69e0ce7fd 1022
arsenalist 10:1dc69e0ce7fd 1023 //execute command
arsenalist 21:33bd8b82560f 1024 //int trial=0;
arsenalist 21:33bd8b82560f 1025 trial = 0;
arsenalist 10:1dc69e0ce7fd 1026 string execStatus="failed";
arsenalist 10:1dc69e0ce7fd 1027
arsenalist 10:1dc69e0ce7fd 1028 while(1) {
arsenalist 10:1dc69e0ce7fd 1029 sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist 10:1dc69e0ce7fd 1030 str = s;
arsenalist 10:1dc69e0ce7fd 1031 string rcv = ethGET(nodeIP,REMOTE_TCP_PORT,str);
arsenalist 10:1dc69e0ce7fd 1032 DBG.printf("response:%s\r\n",rcv.c_str());
arsenalist 10:1dc69e0ce7fd 1033 str = rcv;
arsenalist 10:1dc69e0ce7fd 1034 if(str.find("OK") != std::string::npos) {
arsenalist 10:1dc69e0ce7fd 1035 DBG.printf("cmd executed\r\n");
arsenalist 10:1dc69e0ce7fd 1036 execStatus = "success";
arsenalist 10:1dc69e0ce7fd 1037 break;
arsenalist 10:1dc69e0ce7fd 1038 }
arsenalist 10:1dc69e0ce7fd 1039 if(trial>0) { //two times trial
arsenalist 10:1dc69e0ce7fd 1040 DBG.printf("cmd is not executed\r\n");
arsenalist 10:1dc69e0ce7fd 1041 break;
arsenalist 10:1dc69e0ce7fd 1042 }
arsenalist 10:1dc69e0ce7fd 1043 trial++;
arsenalist 10:1dc69e0ce7fd 1044 wait(3);
arsenalist 10:1dc69e0ce7fd 1045 }
arsenalist 10:1dc69e0ce7fd 1046
arsenalist 10:1dc69e0ce7fd 1047 //send execution status
arsenalist 10:1dc69e0ce7fd 1048 }
arsenalist 10:1dc69e0ce7fd 1049 }
arsenalist 10:1dc69e0ce7fd 1050 */
arsenalist 10:1dc69e0ce7fd 1051 newCommand = false;
arsenalist 10:1dc69e0ce7fd 1052 }
arsenalist 10:1dc69e0ce7fd 1053 client.yield(100); //allow MQTT client to receive message
arsenalist 10:1dc69e0ce7fd 1054 }
arsenalist 10:1dc69e0ce7fd 1055 } else if(wifiConnected) {
arsenalist 0:f4e449fa34d7 1056 DBG.printf("emmaModeOperation - wifi\r\n");
arsenalist 29:4d94a03d38e0 1057
arsenalist 30:08d290158fa7 1058 //start new log and dbg indicator
arsenalist 29:4d94a03d38e0 1059 seconds = time(NULL);
arsenalist 29:4d94a03d38e0 1060 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 29:4d94a03d38e0 1061 DBG.printf("newLog:%d\r\n",writeLog(q,"++++++++++++++++++++"));
arsenalist 30:08d290158fa7 1062 DBG.printf("newDbg:%d\r\n",writeDbg(q,"++++++++++++++++++++"));
arsenalist 0:f4e449fa34d7 1063
arsenalist 0:f4e449fa34d7 1064 //do not delete code below - indicator that esp need to MODE=B and esp.ready() to work
arsenalist 0:f4e449fa34d7 1065 //_ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 1066 //wait(1);
arsenalist 0:f4e449fa34d7 1067 //while(!esp.ready());
arsenalist 0:f4e449fa34d7 1068
arsenalist 24:5d58515ba510 1069 /*
arsenalist 0:f4e449fa34d7 1070 DBG.printf("emma: setup mqtt client\r\n");
arsenalist 0:f4e449fa34d7 1071 sprintf(mqttClientId,"emma/%s",emmaUID.c_str());
arsenalist 0:f4e449fa34d7 1072
arsenalist 0:f4e449fa34d7 1073 if(mqtt.begin(mqttClientId, platformKEY.c_str(), platformSECRET.c_str(), 120, 1)) {
arsenalist 0:f4e449fa34d7 1074 mqtt.connectedCb.attach(&mqttConnected);
arsenalist 0:f4e449fa34d7 1075 mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist 0:f4e449fa34d7 1076 mqtt.connect(MQTT_HOST,MQTT_PORT,false);
arsenalist 13:e8adfe305dbc 1077 DBG.printf("emma: success to setup mqtt\r\n");
arsenalist 13:e8adfe305dbc 1078 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1079 TFT.printf("emma: success to setup mqtt");
arsenalist 0:f4e449fa34d7 1080 }
arsenalist 0:f4e449fa34d7 1081 DBG.printf("emma: system started\r\n");
arsenalist 24:5d58515ba510 1082 */
arsenalist 0:f4e449fa34d7 1083
arsenalist 24:5d58515ba510 1084 //t.start();
arsenalist 24:5d58515ba510 1085 //while(t.read_ms() < 5000) {
arsenalist 24:5d58515ba510 1086 // esp.process();
arsenalist 24:5d58515ba510 1087 //}
arsenalist 24:5d58515ba510 1088 //t.stop();
arsenalist 24:5d58515ba510 1089 //t.reset();
arsenalist 0:f4e449fa34d7 1090
arsenalist 0:f4e449fa34d7 1091 //set ade7758 parameter
arsenalist 0:f4e449fa34d7 1092 ADE.begin();
arsenalist 20:ea14f175bbb4 1093 //ADE.AVRMSCalib = 1526873.00;
arsenalist 20:ea14f175bbb4 1094 //ADE.BVRMSCalib = 534202.00;
arsenalist 20:ea14f175bbb4 1095 //ADE.CVRMSCalib = 456990.00;
arsenalist 20:ea14f175bbb4 1096 //ADE.AIRMSCalib = 39248.00;
arsenalist 20:ea14f175bbb4 1097 //ADE.BIRMSCalib = 654.00;
arsenalist 20:ea14f175bbb4 1098 //ADE.CIRMSCalib = 111.00;
arsenalist 0:f4e449fa34d7 1099
arsenalist 0:f4e449fa34d7 1100 ADE.writeRMSOffset(AIRMSOFFSET, BIRMSOFFSET, CIRMSOFFSET, AVRMSOFFSET, BVRMSOFFSET, CVRMSOFFSET);
arsenalist 0:f4e449fa34d7 1101
arsenalist 0:f4e449fa34d7 1102 ADE.write16bits(AWG, 0);
arsenalist 0:f4e449fa34d7 1103 ADE.write16bits(BWG, 0);
arsenalist 0:f4e449fa34d7 1104 ADE.write16bits(CWG, 0);
arsenalist 0:f4e449fa34d7 1105 ADE.write16bits(AVAG, 0);
arsenalist 0:f4e449fa34d7 1106 ADE.write16bits(BVAG, 0);
arsenalist 0:f4e449fa34d7 1107 ADE.write16bits(CVAG, 0);
arsenalist 0:f4e449fa34d7 1108
arsenalist 16:3c8d0142bf63 1109 //ADE.AWhLSB = 0.000001192;//0.00006025556;
arsenalist 20:ea14f175bbb4 1110 //ADE.AWhLSB = 0.00002109;
arsenalist 20:ea14f175bbb4 1111 //ADE.BWhLSB = 0.25075167;
arsenalist 20:ea14f175bbb4 1112 //ADE.CWhLSB = 0.25075167;
arsenalist 0:f4e449fa34d7 1113
arsenalist 20:ea14f175bbb4 1114 //ADE.AVAhLSB = 0.00008370;
arsenalist 20:ea14f175bbb4 1115 //ADE.BVAhLSB = 0;
arsenalist 20:ea14f175bbb4 1116 //ADE.CVAhLSB = 0;
arsenalist 0:f4e449fa34d7 1117
arsenalist 4:76ab12e2f8a3 1118 //init rest to server
arsenalist 7:7e8c6ad3fd64 1119 if(rest.begin(EMMA_SERVER_HOST,EMMA_SERVER_PORT,false)) {
arsenalist 4:76ab12e2f8a3 1120 DBG.printf("rest to server is created\r\n");
arsenalist 13:e8adfe305dbc 1121 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1122 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1123 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1124 TFT.printf("rest to server is created");
arsenalist 4:76ab12e2f8a3 1125 } else {
arsenalist 4:76ab12e2f8a3 1126 DBG.printf("rest to server is NOT created\r\n");
arsenalist 13:e8adfe305dbc 1127 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1128 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1129 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1130 TFT.printf("rest to server is NOT created");
arsenalist 4:76ab12e2f8a3 1131 }
arsenalist 4:76ab12e2f8a3 1132
arsenalist 7:7e8c6ad3fd64 1133 //check firmware update
arsenalist 7:7e8c6ad3fd64 1134
arsenalist 7:7e8c6ad3fd64 1135 //execute last state of switches on board
arsenalist 7:7e8c6ad3fd64 1136
arsenalist 7:7e8c6ad3fd64 1137 //get list of nodes from server
arsenalist 7:7e8c6ad3fd64 1138 sprintf(s,"/emma/api/controller/remotes?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist 7:7e8c6ad3fd64 1139 rest.get(s);
arsenalist 7:7e8c6ad3fd64 1140 for(int i=0; i<sizeof(s); i++) {
arsenalist 7:7e8c6ad3fd64 1141 s[i]=0; }
arsenalist 7:7e8c6ad3fd64 1142 rest.getResponse(s,sizeof(s));
arsenalist 7:7e8c6ad3fd64 1143 str = s;
arsenalist 7:7e8c6ad3fd64 1144 if(str.rfind("[{\"mac\"") != std::string::npos) {
arsenalist 7:7e8c6ad3fd64 1145 DBG.printf("get nodes from server\r\n");
arsenalist 7:7e8c6ad3fd64 1146 str.erase(str.begin(),str.begin()+str.rfind("[{\"mac\""));
arsenalist 7:7e8c6ad3fd64 1147 str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist 7:7e8c6ad3fd64 1148
arsenalist 7:7e8c6ad3fd64 1149 MbedJSONValue jsonValue;
arsenalist 7:7e8c6ad3fd64 1150 parse(jsonValue,str.c_str());
arsenalist 7:7e8c6ad3fd64 1151 char *parameter[2] = {"mac","ip"};
arsenalist 7:7e8c6ad3fd64 1152
arsenalist 13:e8adfe305dbc 1153 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1154 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1155 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1156 TFT.printf("get %d nodes from server",jsonValue.size());
arsenalist 13:e8adfe305dbc 1157 wait(0.5);
arsenalist 13:e8adfe305dbc 1158 TFT.locate(0,40);
arsenalist 13:e8adfe305dbc 1159 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1160
arsenalist 7:7e8c6ad3fd64 1161 //check whether nodes valid
arsenalist 7:7e8c6ad3fd64 1162 bool validNodes = true;
arsenalist 7:7e8c6ad3fd64 1163 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 7:7e8c6ad3fd64 1164 for(int j=0; j<2; j++) {
arsenalist 7:7e8c6ad3fd64 1165 validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist 7:7e8c6ad3fd64 1166 }
arsenalist 7:7e8c6ad3fd64 1167 }
arsenalist 7:7e8c6ad3fd64 1168 DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist 7:7e8c6ad3fd64 1169
arsenalist 7:7e8c6ad3fd64 1170 if(validNodes) {
arsenalist 7:7e8c6ad3fd64 1171 for(int i=0; i<jsonValue.size(); i++) {
arsenalist 7:7e8c6ad3fd64 1172 string macValue = jsonValue[i][parameter[0]].get<std::string>();
arsenalist 7:7e8c6ad3fd64 1173 string ipValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist 7:7e8c6ad3fd64 1174 nodes[i].macAddr = macValue;
arsenalist 7:7e8c6ad3fd64 1175 nodes[i].ipAddr = ipValue;
arsenalist 13:e8adfe305dbc 1176 DBG.printf("nodes[%d]mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist 13:e8adfe305dbc 1177 DBG.printf("nodes[%d]ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist 7:7e8c6ad3fd64 1178 }
arsenalist 7:7e8c6ad3fd64 1179 }
arsenalist 7:7e8c6ad3fd64 1180
arsenalist 7:7e8c6ad3fd64 1181 } else {
arsenalist 7:7e8c6ad3fd64 1182 DBG.printf("no nodes from server\r\n");
arsenalist 7:7e8c6ad3fd64 1183 }
arsenalist 7:7e8c6ad3fd64 1184
arsenalist 24:5d58515ba510 1185 /*
arsenalist 24:5d58515ba510 1186 //success
arsenalist 24:5d58515ba510 1187 DBG.printf("emma: setup mqtt client\r\n");
arsenalist 24:5d58515ba510 1188 sprintf(mqttClientId,"emma/%s",emmaUID.c_str());
arsenalist 24:5d58515ba510 1189 if(mqtt.begin(mqttClientId, platformKEY.c_str(), platformSECRET.c_str(), 120, 1)) {
arsenalist 24:5d58515ba510 1190 mqtt.connectedCb.attach(&mqttConnected);
arsenalist 24:5d58515ba510 1191 mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist 24:5d58515ba510 1192 mqtt.connect(MQTT_HOST,MQTT_PORT,false);
arsenalist 24:5d58515ba510 1193 DBG.printf("emma: success to setup mqtt\r\n");
arsenalist 24:5d58515ba510 1194 TFT.locate(0,40);
arsenalist 24:5d58515ba510 1195 TFT.printf("emma: success to setup mqtt");
arsenalist 24:5d58515ba510 1196 }
arsenalist 24:5d58515ba510 1197 DBG.printf("emma: system started\r\n");
arsenalist 24:5d58515ba510 1198
arsenalist 24:5d58515ba510 1199 t.start();
arsenalist 24:5d58515ba510 1200 while(t.read_ms() < 5000) {
arsenalist 24:5d58515ba510 1201 esp.process();
arsenalist 24:5d58515ba510 1202 }
arsenalist 24:5d58515ba510 1203 t.stop();
arsenalist 24:5d58515ba510 1204 t.reset();
arsenalist 24:5d58515ba510 1205 */
arsenalist 7:7e8c6ad3fd64 1206
arsenalist 4:76ab12e2f8a3 1207 //preset nodes' macAddr and ipAddr
arsenalist 7:7e8c6ad3fd64 1208 //nodes[0].macAddr = "002629034222";
arsenalist 7:7e8c6ad3fd64 1209 //nodes[0].ipAddr = "192.168.2.15";
arsenalist 7:7e8c6ad3fd64 1210 //nodes[1].macAddr = "00262903424e";
arsenalist 7:7e8c6ad3fd64 1211 //nodes[1].ipAddr = "192.168.2.32";
arsenalist 4:76ab12e2f8a3 1212
arsenalist 4:76ab12e2f8a3 1213 //init rest to remotes
arsenalist 4:76ab12e2f8a3 1214 for(int i=0; i<NODES_MAX; i++) {
arsenalist 4:76ab12e2f8a3 1215 if(!nodes[i].ipAddr.empty()) {
arsenalist 4:76ab12e2f8a3 1216 DBG.printf("restConn nodes[%d] is created\r\n",i);
arsenalist 4:76ab12e2f8a3 1217 nodes[i].restConn->begin(nodes[i].ipAddr.c_str(),16038,false);
arsenalist 4:76ab12e2f8a3 1218 wait(1);
arsenalist 4:76ab12e2f8a3 1219 } else {
arsenalist 4:76ab12e2f8a3 1220 DBG.printf("restConn nodes[%d] is NOT created\r\n",i);
arsenalist 4:76ab12e2f8a3 1221 wait(1);
arsenalist 4:76ab12e2f8a3 1222 }
arsenalist 4:76ab12e2f8a3 1223 }
arsenalist 4:76ab12e2f8a3 1224
arsenalist 4:76ab12e2f8a3 1225 _ESP.attach(&rxInterrupt,Serial::RxIrq);
arsenalist 4:76ab12e2f8a3 1226
arsenalist 4:76ab12e2f8a3 1227 //define thread
arsenalist 17:b3ced0e67916 1228 osThreadDef(energyThread, osPriorityBelowNormal, (8*DEFAULT_STACK_SIZE));
arsenalist 0:f4e449fa34d7 1229 //create thread
arsenalist 2:fdfdeb5fd6fd 1230 osThreadCreate(osThread(energyThread),NULL);
arsenalist 0:f4e449fa34d7 1231
arsenalist 24:5d58515ba510 1232 tPanelEnergy.start();
arsenalist 24:5d58515ba510 1233 tPanel.start();
arsenalist 4:76ab12e2f8a3 1234 tNodes.start();
arsenalist 4:76ab12e2f8a3 1235 wait(1);
arsenalist 0:f4e449fa34d7 1236 while(1) {
arsenalist 4:76ab12e2f8a3 1237 checkRxBuffer();
arsenalist 20:ea14f175bbb4 1238 checkVoltagePower();
arsenalist 20:ea14f175bbb4 1239
arsenalist 24:5d58515ba510 1240 //whether espFreeMemory occurs
arsenalist 24:5d58515ba510 1241 if(espFreeMemory) {
arsenalist 30:08d290158fa7 1242 //logging
arsenalist 27:562a95c120cc 1243 seconds = time(NULL);
arsenalist 27:562a95c120cc 1244 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1245 DBG.printf("logFreeMemory:%d\r\n",writeLog(q,rxLog.c_str()));
arsenalist 24:5d58515ba510 1246
arsenalist 27:562a95c120cc 1247 espFreeMemory = false;
arsenalist 27:562a95c120cc 1248 }
arsenalist 27:562a95c120cc 1249
arsenalist 27:562a95c120cc 1250 //whether espDHCPClientStart occurs
arsenalist 27:562a95c120cc 1251 if(espDHCPClientStart) {
arsenalist 30:08d290158fa7 1252 //logging
arsenalist 27:562a95c120cc 1253 seconds = time(NULL);
arsenalist 27:562a95c120cc 1254 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1255 DBG.printf("logDHCPClientStart:%d\r\n",writeLog(q,rxLogA.c_str()));
arsenalist 27:562a95c120cc 1256
arsenalist 27:562a95c120cc 1257 _ESP.printf("MODE=B");
arsenalist 27:562a95c120cc 1258 wait(2);
arsenalist 27:562a95c120cc 1259 espDHCPClientStart = false;
arsenalist 24:5d58515ba510 1260 }
arsenalist 24:5d58515ba510 1261
arsenalist 30:08d290158fa7 1262 //debugging
arsenalist 30:08d290158fa7 1263 seconds = time(NULL);
arsenalist 30:08d290158fa7 1264 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 30:08d290158fa7 1265 sprintf(r,"dbgPE[%d]",dbgLoop);
arsenalist 30:08d290158fa7 1266 DBG.printf("dbgPE:%d\r\n",writeDbg(q,r));
arsenalist 30:08d290158fa7 1267
arsenalist 4:76ab12e2f8a3 1268 //panelEnergy, panelVoltage, and panelPower
arsenalist 24:5d58515ba510 1269 if(tPanelEnergy.read() > 30.0f) {
arsenalist 4:76ab12e2f8a3 1270 DBG.printf("[%d]WattHR for each phase: %.2f, %.2f, %.2f\r\n", loop, AWattHr, BWattHr, CWattHr);
arsenalist 13:e8adfe305dbc 1271 TFT.locate(0,60);
arsenalist 13:e8adfe305dbc 1272 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1273 TFT.locate(0,60);
arsenalist 13:e8adfe305dbc 1274 TFT.printf("[%d]WHR: %.1f, %.1f, %.1f", loop, AWattHr, BWattHr, CWattHr);
arsenalist 13:e8adfe305dbc 1275
arsenalist 4:76ab12e2f8a3 1276 DBG.printf("VRMS for each phase: %.2f, %.2f, %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist 13:e8adfe305dbc 1277 TFT.locate(0,80);
arsenalist 13:e8adfe305dbc 1278 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1279 TFT.locate(0,80);
arsenalist 13:e8adfe305dbc 1280 TFT.printf("VRMS: %.1f, %.1f, %.1f", AVrms, BVrms, CVrms);
arsenalist 13:e8adfe305dbc 1281
arsenalist 4:76ab12e2f8a3 1282 DBG.printf("Watt for each phase: %.2f, %.2f, %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist 13:e8adfe305dbc 1283 TFT.locate(0,100);
arsenalist 13:e8adfe305dbc 1284 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1285 TFT.locate(0,100);
arsenalist 13:e8adfe305dbc 1286 TFT.printf("Watt: %.1f, %.1f, %.1f", AWatt, BWatt, CWatt);
arsenalist 4:76ab12e2f8a3 1287
arsenalist 22:e18d361bf688 1288 if(newEnergyData) {
arsenalist 22:e18d361bf688 1289 //for(int i=1; i<4; i++) {
arsenalist 22:e18d361bf688 1290 for(int i=1; i<2; i++) {
arsenalist 22:e18d361bf688 1291 DBG.printf("sending channel: %d\r\n",i);
arsenalist 22:e18d361bf688 1292 if(i==1){
arsenalist 22:e18d361bf688 1293 XWattHr = AWattHr;
arsenalist 22:e18d361bf688 1294 XVrms = AVrms;
arsenalist 22:e18d361bf688 1295 XWatt = AWatt;
arsenalist 22:e18d361bf688 1296 } else if(i==2) {
arsenalist 22:e18d361bf688 1297 XWattHr = BWattHr;
arsenalist 22:e18d361bf688 1298 XVrms = BVrms;
arsenalist 22:e18d361bf688 1299 XWatt = BWatt;
arsenalist 22:e18d361bf688 1300 } else {
arsenalist 22:e18d361bf688 1301 XWattHr = CWattHr;
arsenalist 22:e18d361bf688 1302 XVrms = CVrms;
arsenalist 22:e18d361bf688 1303 XWatt = CWatt;
arsenalist 22:e18d361bf688 1304 }
arsenalist 24:5d58515ba510 1305
arsenalist 24:5d58515ba510 1306 if(XWattHr != 0.0f) {
arsenalist 22:e18d361bf688 1307
arsenalist 24:5d58515ba510 1308 sprintf(r,"/emma/api/controller/energy/%d",i);
arsenalist 24:5d58515ba510 1309 seconds = time(NULL);
arsenalist 24:5d58515ba510 1310 //for(int j=0; j<sizeof(q); j++) {
arsenalist 24:5d58515ba510 1311 // q[j]=0; }
arsenalist 24:5d58515ba510 1312 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 24:5d58515ba510 1313
arsenalist 24:5d58515ba510 1314 //calculate hmacTime
arsenalist 24:5d58515ba510 1315 for(int j=0; j<sizeof(p); j++) {
arsenalist 24:5d58515ba510 1316 p[j]=0; }
arsenalist 24:5d58515ba510 1317 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 24:5d58515ba510 1318 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1319
arsenalist 24:5d58515ba510 1320 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"energy\":%.2f,\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 24:5d58515ba510 1321 emmaUID.c_str(),hmacTime.c_str(),q,XWattHr,XVrms,XWatt);
arsenalist 24:5d58515ba510 1322 //DBG.printf("dataEnergy:\r\n%s\r\n",s);
arsenalist 24:5d58515ba510 1323 rest.post(r,s);
arsenalist 24:5d58515ba510 1324 wait(2);
arsenalist 24:5d58515ba510 1325 if(rxBuf.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 27:562a95c120cc 1326 //logging purpose
arsenalist 27:562a95c120cc 1327 seconds = time(NULL);
arsenalist 27:562a95c120cc 1328 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1329 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData success"));
arsenalist 27:562a95c120cc 1330
arsenalist 24:5d58515ba510 1331 DBG.printf("send channel: %d success\r\n",i);
arsenalist 24:5d58515ba510 1332 TFT.foreground(Green);
arsenalist 24:5d58515ba510 1333 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1334 TFT.printf(" ");
arsenalist 24:5d58515ba510 1335 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1336 TFT.printf("send ch%d success",i);
arsenalist 24:5d58515ba510 1337 wait(1);
arsenalist 24:5d58515ba510 1338 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1339 TFT.printf(" ");
arsenalist 24:5d58515ba510 1340 TFT.foreground(White);
arsenalist 24:5d58515ba510 1341 } else {
arsenalist 27:562a95c120cc 1342 //logging purpose
arsenalist 27:562a95c120cc 1343 seconds = time(NULL);
arsenalist 27:562a95c120cc 1344 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1345 DBG.printf("logPE:%d\r\n",writeLog(q,"sendEnergyData failed"));
arsenalist 27:562a95c120cc 1346
arsenalist 24:5d58515ba510 1347 DBG.printf("send channel: %d failed\r\n",i);
arsenalist 24:5d58515ba510 1348 TFT.foreground(Red);
arsenalist 24:5d58515ba510 1349 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1350 TFT.printf(" ");
arsenalist 24:5d58515ba510 1351 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1352 TFT.printf("send ch%d failed",i);
arsenalist 24:5d58515ba510 1353 wait(1);
arsenalist 24:5d58515ba510 1354 TFT.locate(0,120);
arsenalist 24:5d58515ba510 1355 TFT.printf(" ");
arsenalist 24:5d58515ba510 1356 TFT.foreground(White);
arsenalist 24:5d58515ba510 1357 }
arsenalist 22:e18d361bf688 1358 }
arsenalist 4:76ab12e2f8a3 1359 }
arsenalist 22:e18d361bf688 1360
arsenalist 22:e18d361bf688 1361 newEnergyData = false;
arsenalist 0:f4e449fa34d7 1362 }
arsenalist 22:e18d361bf688 1363
arsenalist 24:5d58515ba510 1364 tPanelEnergy.reset();
arsenalist 4:76ab12e2f8a3 1365 loop++;
arsenalist 0:f4e449fa34d7 1366 }
arsenalist 0:f4e449fa34d7 1367
arsenalist 30:08d290158fa7 1368 //debugging
arsenalist 30:08d290158fa7 1369 seconds = time(NULL);
arsenalist 30:08d290158fa7 1370 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 30:08d290158fa7 1371 sprintf(r,"dbgPEnv[%d]",dbgLoop);
arsenalist 30:08d290158fa7 1372 DBG.printf("dbgPEnv:%d\r\n",writeDbg(q,r));
arsenalist 30:08d290158fa7 1373
arsenalist 21:33bd8b82560f 1374 //panel environment
arsenalist 5:d00233dd36f5 1375 checkRxBuffer();
arsenalist 25:36c6a5db50ed 1376 if(tPanel.read() > 900.0f) { //900 is 15 minutes
arsenalist 21:33bd8b82560f 1377 int dTemp=0;
arsenalist 21:33bd8b82560f 1378 int dHum=0;
arsenalist 21:33bd8b82560f 1379 int dGas=0;
arsenalist 21:33bd8b82560f 1380
arsenalist 21:33bd8b82560f 1381 DBG.printf("getPanelEnvironment\r\n");
arsenalist 21:33bd8b82560f 1382
arsenalist 21:33bd8b82560f 1383 //get environment sensor
arsenalist 21:33bd8b82560f 1384 trial=0;
arsenalist 21:33bd8b82560f 1385 while(1) {
arsenalist 21:33bd8b82560f 1386 if(trial>=2) { //two times trial
arsenalist 21:33bd8b82560f 1387 break;
arsenalist 21:33bd8b82560f 1388 }
arsenalist 21:33bd8b82560f 1389 if(d.readData() == DHT11::OK) {
arsenalist 21:33bd8b82560f 1390 dTemp = d.readTemperature();
arsenalist 21:33bd8b82560f 1391 dHum = d.readHumidity();
arsenalist 21:33bd8b82560f 1392 break;
arsenalist 21:33bd8b82560f 1393 }
arsenalist 21:33bd8b82560f 1394 trial++;
arsenalist 21:33bd8b82560f 1395 wait(3);
arsenalist 21:33bd8b82560f 1396 }
arsenalist 21:33bd8b82560f 1397
arsenalist 21:33bd8b82560f 1398 //send environment sensor
arsenalist 24:5d58515ba510 1399 if(dTemp!=0 && dHum!=0) {
arsenalist 24:5d58515ba510 1400 seconds = time(NULL);
arsenalist 24:5d58515ba510 1401 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 22:e18d361bf688 1402
arsenalist 24:5d58515ba510 1403 //calculate hmacTime
arsenalist 24:5d58515ba510 1404 for(int j=0; j<sizeof(p); j++) {
arsenalist 24:5d58515ba510 1405 p[j]=0; }
arsenalist 24:5d58515ba510 1406 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 24:5d58515ba510 1407 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1408
arsenalist 24:5d58515ba510 1409 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"temp\":%d,\"hum\":%d,\"gas\":%d}",
arsenalist 24:5d58515ba510 1410 emmaUID.c_str(),hmacTime.c_str(),q,dTemp,dHum,dGas);
arsenalist 24:5d58515ba510 1411 //DBG.printf("dataEnvironment:\r\n%s\r\n",s);
arsenalist 24:5d58515ba510 1412 rest.post("/emma/api/controller/environment",s);
arsenalist 24:5d58515ba510 1413 wait(2);
arsenalist 24:5d58515ba510 1414 str = rxBuf;
arsenalist 24:5d58515ba510 1415 if(str.rfind("/environment") != std::string::npos) {
arsenalist 24:5d58515ba510 1416 str.erase(str.begin(),str.begin()+str.rfind("/environment"));
arsenalist 24:5d58515ba510 1417 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 27:562a95c120cc 1418 //logging purpose
arsenalist 27:562a95c120cc 1419 seconds = time(NULL);
arsenalist 27:562a95c120cc 1420 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1421 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv success"));
arsenalist 24:5d58515ba510 1422 DBG.printf("send panel environment success\r\n");
arsenalist 24:5d58515ba510 1423 } else {
arsenalist 27:562a95c120cc 1424 //logging purpose
arsenalist 27:562a95c120cc 1425 seconds = time(NULL);
arsenalist 27:562a95c120cc 1426 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 27:562a95c120cc 1427 DBG.printf("logPEnv:%d\r\n",writeLog(q,"sendPanelEnv failed"));
arsenalist 24:5d58515ba510 1428 DBG.printf("send panel environment failed\r\n");
arsenalist 24:5d58515ba510 1429 }
arsenalist 21:33bd8b82560f 1430 }
arsenalist 24:5d58515ba510 1431 checkRxBuffer();
arsenalist 21:33bd8b82560f 1432 }
arsenalist 21:33bd8b82560f 1433 tPanel.reset();
arsenalist 21:33bd8b82560f 1434 }
arsenalist 21:33bd8b82560f 1435
arsenalist 30:08d290158fa7 1436 //debugging
arsenalist 30:08d290158fa7 1437 seconds = time(NULL);
arsenalist 30:08d290158fa7 1438 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 30:08d290158fa7 1439 sprintf(r,"dbgNT[%d]",dbgLoop);
arsenalist 30:08d290158fa7 1440 DBG.printf("dbgNT:%d\r\n",writeDbg(q,r));
arsenalist 30:08d290158fa7 1441
arsenalist 0:f4e449fa34d7 1442 //nodeTemp
arsenalist 21:33bd8b82560f 1443 checkRxBuffer();
arsenalist 25:36c6a5db50ed 1444 if(tNodes.read() > 900.0f) { //900 is 15 minutes
arsenalist 5:d00233dd36f5 1445 DBG.printf("getNodesTemperature\r\n");
arsenalist 5:d00233dd36f5 1446
arsenalist 5:d00233dd36f5 1447 for(int i=0; i<NODES_MAX; i++) {
arsenalist 5:d00233dd36f5 1448 if(!nodes[i].ipAddr.empty()) {
arsenalist 5:d00233dd36f5 1449 //get node's temp
arsenalist 5:d00233dd36f5 1450 string temp;
arsenalist 5:d00233dd36f5 1451 nodes[i].restConn->get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist 5:d00233dd36f5 1452 wait(2);
arsenalist 5:d00233dd36f5 1453 temp = rxBuf;
arsenalist 5:d00233dd36f5 1454 if(temp.rfind(nodes[i].ipAddr) != std::string::npos) {
arsenalist 5:d00233dd36f5 1455 temp.erase(temp.begin(),temp.begin()+temp.rfind(nodes[i].ipAddr));
arsenalist 5:d00233dd36f5 1456 if(temp.rfind("temp=") != std::string::npos) {
arsenalist 5:d00233dd36f5 1457 temp.erase(temp.begin(),temp.begin()+temp.rfind("temp=")+6);
arsenalist 5:d00233dd36f5 1458 temp.erase(temp.begin()+temp.find("\""),temp.end());
arsenalist 5:d00233dd36f5 1459 } else {
arsenalist 5:d00233dd36f5 1460 temp = "0"; //connect to node, but receive none
arsenalist 5:d00233dd36f5 1461 }
arsenalist 5:d00233dd36f5 1462 } else {
arsenalist 5:d00233dd36f5 1463 temp = "0"; //not connected to node
arsenalist 5:d00233dd36f5 1464 }
arsenalist 0:f4e449fa34d7 1465
arsenalist 5:d00233dd36f5 1466 DBG.printf("nodeTemp[%d]:%s\r\n",i,temp.c_str());
arsenalist 5:d00233dd36f5 1467
arsenalist 5:d00233dd36f5 1468 //send node's temp
arsenalist 25:36c6a5db50ed 1469 if(temp != "0") {
arsenalist 25:36c6a5db50ed 1470 seconds = time(NULL);
arsenalist 25:36c6a5db50ed 1471 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 22:e18d361bf688 1472
arsenalist 25:36c6a5db50ed 1473 //calculate hmacTime
arsenalist 25:36c6a5db50ed 1474 for(int j=0; j<sizeof(p); j++) {
arsenalist 25:36c6a5db50ed 1475 p[j]=0; }
arsenalist 25:36c6a5db50ed 1476 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 25:36c6a5db50ed 1477 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1478
arsenalist 25:36c6a5db50ed 1479 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"mac\":\"%s\",\"value\":%s}",
arsenalist 25:36c6a5db50ed 1480 emmaUID.c_str(),hmacTime.c_str(),q,nodes[i].macAddr.c_str(),temp.c_str());
arsenalist 25:36c6a5db50ed 1481 //DBG.printf("dataNodeTemp:\r\n%s\r\n",s);
arsenalist 25:36c6a5db50ed 1482 rest.post("/emma/api/controller/nodetemp",s);
arsenalist 25:36c6a5db50ed 1483 wait(2);
arsenalist 25:36c6a5db50ed 1484 str = rxBuf;
arsenalist 25:36c6a5db50ed 1485 if(str.rfind("/nodetemp") != std::string::npos) {
arsenalist 25:36c6a5db50ed 1486 str.erase(str.begin(),str.begin()+str.rfind("/nodetemp"));
arsenalist 25:36c6a5db50ed 1487 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 25:36c6a5db50ed 1488 DBG.printf("send nodeTemp success\r\n");
arsenalist 25:36c6a5db50ed 1489 } else {
arsenalist 25:36c6a5db50ed 1490 DBG.printf("send nodeTemp failed\r\n");
arsenalist 25:36c6a5db50ed 1491 }
arsenalist 5:d00233dd36f5 1492 }
arsenalist 25:36c6a5db50ed 1493 checkRxBuffer();
arsenalist 5:d00233dd36f5 1494 }
arsenalist 5:d00233dd36f5 1495 }
arsenalist 0:f4e449fa34d7 1496 }
arsenalist 19:7e3e9332f719 1497 tNodes.reset();
arsenalist 19:7e3e9332f719 1498 }
arsenalist 21:33bd8b82560f 1499
arsenalist 30:08d290158fa7 1500 //debugging
arsenalist 30:08d290158fa7 1501 seconds = time(NULL);
arsenalist 30:08d290158fa7 1502 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 30:08d290158fa7 1503 sprintf(r,"dbgCmd[%d]",dbgLoop);
arsenalist 30:08d290158fa7 1504 DBG.printf("dbgCmd:%d\r\n",writeDbg(q,r));
arsenalist 30:08d290158fa7 1505
arsenalist 21:33bd8b82560f 1506 //command
arsenalist 27:562a95c120cc 1507 rest.get("/emma/api/controller/command");
arsenalist 5:d00233dd36f5 1508 checkRxBuffer();
arsenalist 0:f4e449fa34d7 1509 if(newCommand) {
arsenalist 5:d00233dd36f5 1510 DBG.printf("newCommand:\r\n%s\r\n",globalCommand.c_str());
arsenalist 13:e8adfe305dbc 1511 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 1512 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1513 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 1514 TFT.printf("newCommand");
arsenalist 13:e8adfe305dbc 1515
arsenalist 0:f4e449fa34d7 1516 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 1517 parse(jsonValue,globalCommand.c_str());
arsenalist 15:136526c28afb 1518 char *parameter[5] = {"name","nType","nAddr","dType","cmd"};
arsenalist 0:f4e449fa34d7 1519
arsenalist 7:7e8c6ad3fd64 1520 //check whether command is valid
arsenalist 0:f4e449fa34d7 1521 bool validCommand = true;
arsenalist 15:136526c28afb 1522 for(int i=0; i<5; i++) {
arsenalist 0:f4e449fa34d7 1523 validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist 0:f4e449fa34d7 1524 }
arsenalist 0:f4e449fa34d7 1525 DBG.printf("command validity:%d\r\n",validCommand);
arsenalist 0:f4e449fa34d7 1526
arsenalist 0:f4e449fa34d7 1527 if(validCommand) {
arsenalist 15:136526c28afb 1528 string commandName = jsonValue[parameter[0]].get<std::string>();
arsenalist 15:136526c28afb 1529 string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist 15:136526c28afb 1530 string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist 15:136526c28afb 1531 string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist 15:136526c28afb 1532 string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist 0:f4e449fa34d7 1533
arsenalist 0:f4e449fa34d7 1534 if(commandNType == "0") { //switch on panel controller
arsenalist 0:f4e449fa34d7 1535 DBG.printf("command for switch\r\n");
arsenalist 0:f4e449fa34d7 1536 }
arsenalist 0:f4e449fa34d7 1537 else if(commandNType == "1") { //node with mac address
arsenalist 0:f4e449fa34d7 1538 DBG.printf("command for node\r\n");
arsenalist 0:f4e449fa34d7 1539 //get node ip address based on node mac address
arsenalist 5:d00233dd36f5 1540 //string nodeIP;
arsenalist 1:d314a43ae6f7 1541 //nodeIp = readNodeIP(commandNAddr);
arsenalist 5:d00233dd36f5 1542 //nodeIP = "192.168.2.15";
arsenalist 0:f4e449fa34d7 1543 //DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist 5:d00233dd36f5 1544
arsenalist 5:d00233dd36f5 1545 //get index of node list based on mac address
arsenalist 5:d00233dd36f5 1546 int idx = NODES_INVALID;
arsenalist 5:d00233dd36f5 1547 for(int i=0; i<NODES_MAX; i++) {
arsenalist 5:d00233dd36f5 1548 if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist 5:d00233dd36f5 1549 idx = i;
arsenalist 5:d00233dd36f5 1550 }
arsenalist 5:d00233dd36f5 1551 }
arsenalist 5:d00233dd36f5 1552
arsenalist 5:d00233dd36f5 1553 //execution process
arsenalist 21:33bd8b82560f 1554 //int trial;
arsenalist 15:136526c28afb 1555 string execResult = "failed";
arsenalist 5:d00233dd36f5 1556 if(idx != NODES_INVALID) {
arsenalist 5:d00233dd36f5 1557 DBG.printf("index found at %d\r\n",idx);
arsenalist 0:f4e449fa34d7 1558
arsenalist 5:d00233dd36f5 1559 //get cmd string based on device type and command number
arsenalist 5:d00233dd36f5 1560 string nodeCmd;
arsenalist 14:8287f0f5d987 1561 nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist 14:8287f0f5d987 1562 //nodeCmd = "020129A0163B161315131613153C151316131514143C153C16141414141415151315141414141514141415141414143D1514143D141415141414143D14000D"; //turn off
arsenalist 5:d00233dd36f5 1563 //DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist 0:f4e449fa34d7 1564
arsenalist 5:d00233dd36f5 1565 //execute command
arsenalist 5:d00233dd36f5 1566 DBG.printf("executing command\r\n");
arsenalist 0:f4e449fa34d7 1567 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 1568
arsenalist 5:d00233dd36f5 1569 trial=0;
arsenalist 0:f4e449fa34d7 1570 while(1) {
arsenalist 5:d00233dd36f5 1571 //cmdExecuted = false;
arsenalist 5:d00233dd36f5 1572 if(trial>=2) { //two times trial
arsenalist 0:f4e449fa34d7 1573 DBG.printf("cmd is not executed\r\n");
arsenalist 13:e8adfe305dbc 1574 TFT.foreground(Red);
arsenalist 13:e8adfe305dbc 1575 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1576 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1577 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1578 TFT.printf("cmd is not executed");
arsenalist 14:8287f0f5d987 1579 wait(1);
arsenalist 13:e8adfe305dbc 1580 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1581 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1582 TFT.foreground(White);
arsenalist 0:f4e449fa34d7 1583 break;
arsenalist 0:f4e449fa34d7 1584 }
arsenalist 5:d00233dd36f5 1585 nodes[idx].restConn->get("/",s);
arsenalist 5:d00233dd36f5 1586 wait(2);
arsenalist 5:d00233dd36f5 1587 if(rxBuf.find("REST: Sent") != std::string::npos) {
arsenalist 13:e8adfe305dbc 1588 DBG.printf("cmd is executed\r\n");
arsenalist 13:e8adfe305dbc 1589 TFT.foreground(Green);
arsenalist 13:e8adfe305dbc 1590 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1591 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1592 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1593 TFT.printf("cmd is executed");
arsenalist 14:8287f0f5d987 1594 wait(1);
arsenalist 13:e8adfe305dbc 1595 TFT.locate(0,180);
arsenalist 13:e8adfe305dbc 1596 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1597 TFT.foreground(White);
arsenalist 15:136526c28afb 1598 execResult = "success";
arsenalist 5:d00233dd36f5 1599 break;
arsenalist 5:d00233dd36f5 1600 }
arsenalist 0:f4e449fa34d7 1601 trial++;
arsenalist 5:d00233dd36f5 1602 }
arsenalist 14:8287f0f5d987 1603 } else {
arsenalist 14:8287f0f5d987 1604 TFT.foreground(Red);
arsenalist 14:8287f0f5d987 1605 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 1606 TFT.printf(" ");
arsenalist 14:8287f0f5d987 1607 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 1608 TFT.printf("node is invalid");
arsenalist 14:8287f0f5d987 1609 wait(1);
arsenalist 14:8287f0f5d987 1610 TFT.locate(0,180);
arsenalist 14:8287f0f5d987 1611 TFT.printf(" ");
arsenalist 14:8287f0f5d987 1612 TFT.foreground(White);
arsenalist 5:d00233dd36f5 1613 }
arsenalist 5:d00233dd36f5 1614
arsenalist 5:d00233dd36f5 1615 wait(2);
arsenalist 5:d00233dd36f5 1616 //send execution result
arsenalist 21:33bd8b82560f 1617 //DBG.printf("send execution result\r\n");
arsenalist 23:fb369e171b7d 1618
arsenalist 23:fb369e171b7d 1619 //calculate hmacCmd
arsenalist 23:fb369e171b7d 1620 for(int j=0; j<sizeof(p); j++) {
arsenalist 23:fb369e171b7d 1621 p[j]=0; }
arsenalist 23:fb369e171b7d 1622 sprintf(p,"emma-%s-%s",emmaUID.c_str(),commandCmd.c_str());
arsenalist 23:fb369e171b7d 1623 hmacCmd = calculateMD5(p);
arsenalist 23:fb369e171b7d 1624
arsenalist 23:fb369e171b7d 1625 sprintf(s,"{\"uid\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"name\":\"%s\",\"result\":\"%s\",\"hmac\":\"%s\"}",
arsenalist 23:fb369e171b7d 1626 emmaUID.c_str(), commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),commandName.c_str(),execResult.c_str(),hmacCmd.c_str());
arsenalist 5:d00233dd36f5 1627
arsenalist 5:d00233dd36f5 1628 trial=0;
arsenalist 5:d00233dd36f5 1629 while(1) {
arsenalist 5:d00233dd36f5 1630 if(trial>=2) { //two times trial
arsenalist 23:fb369e171b7d 1631 DBG.printf("failed to send execution result\r\n");
arsenalist 5:d00233dd36f5 1632 break;
arsenalist 0:f4e449fa34d7 1633 }
arsenalist 23:fb369e171b7d 1634 rest.post("/emma/api/controller/result",s);
arsenalist 5:d00233dd36f5 1635 wait(2);
arsenalist 23:fb369e171b7d 1636 str = rxBuf;
arsenalist 23:fb369e171b7d 1637 if(str.rfind("/result") != std::string::npos) {
arsenalist 23:fb369e171b7d 1638 str.erase(str.begin(),str.begin()+str.rfind("/result"));
arsenalist 23:fb369e171b7d 1639 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 23:fb369e171b7d 1640 DBG.printf("success to send execution result\r\n");
arsenalist 23:fb369e171b7d 1641 break;
arsenalist 23:fb369e171b7d 1642 }
arsenalist 0:f4e449fa34d7 1643 }
arsenalist 23:fb369e171b7d 1644 checkRxBuffer();
arsenalist 5:d00233dd36f5 1645 trial++;
arsenalist 0:f4e449fa34d7 1646 }
arsenalist 0:f4e449fa34d7 1647 }
arsenalist 0:f4e449fa34d7 1648 }
arsenalist 13:e8adfe305dbc 1649
arsenalist 13:e8adfe305dbc 1650 //clear text on lcd
arsenalist 13:e8adfe305dbc 1651 TFT.locate(0,160);
arsenalist 13:e8adfe305dbc 1652 TFT.printf(" ");
arsenalist 13:e8adfe305dbc 1653
arsenalist 0:f4e449fa34d7 1654 newCommand = false;
arsenalist 2:fdfdeb5fd6fd 1655 }
arsenalist 30:08d290158fa7 1656
arsenalist 30:08d290158fa7 1657 //debugging
arsenalist 30:08d290158fa7 1658 dbgLoop++;
arsenalist 30:08d290158fa7 1659
arsenalist 4:76ab12e2f8a3 1660 osDelay(5000);
arsenalist 0:f4e449fa34d7 1661 }
arsenalist 0:f4e449fa34d7 1662 }
arsenalist 0:f4e449fa34d7 1663 }
arsenalist 0:f4e449fa34d7 1664 void emmaModeFirmwareDownload(void) {
arsenalist 0:f4e449fa34d7 1665 bool emmaGetFirmwareParam = false;
arsenalist 0:f4e449fa34d7 1666
arsenalist 0:f4e449fa34d7 1667 DBG.printf("emmaModeFirmwareDownload\r\n");
arsenalist 0:f4e449fa34d7 1668
arsenalist 0:f4e449fa34d7 1669 char s[384];
arsenalist 0:f4e449fa34d7 1670 string str;
arsenalist 0:f4e449fa34d7 1671 string connData;
arsenalist 0:f4e449fa34d7 1672 string chunk;
arsenalist 0:f4e449fa34d7 1673
arsenalist 0:f4e449fa34d7 1674 //firmware parameter
arsenalist 0:f4e449fa34d7 1675 string firmwareVer;
arsenalist 0:f4e449fa34d7 1676 string firmwareName;
arsenalist 0:f4e449fa34d7 1677 int numPart;
arsenalist 0:f4e449fa34d7 1678
arsenalist 0:f4e449fa34d7 1679 //downloading
arsenalist 0:f4e449fa34d7 1680 string firmwarePart;
arsenalist 0:f4e449fa34d7 1681 string calcMD5;
arsenalist 0:f4e449fa34d7 1682 string srvrMD5;
arsenalist 0:f4e449fa34d7 1683 bool nextPart;
arsenalist 0:f4e449fa34d7 1684
arsenalist 0:f4e449fa34d7 1685 //set wifi to mode bridge
arsenalist 0:f4e449fa34d7 1686 _ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 1687 DBG.printf("set mode bridge\r\n");
arsenalist 0:f4e449fa34d7 1688 while(1) {
arsenalist 0:f4e449fa34d7 1689 char rcv[128] = {};
arsenalist 0:f4e449fa34d7 1690 rcvReply(rcv,3000);
arsenalist 0:f4e449fa34d7 1691 str = rcv;
arsenalist 0:f4e449fa34d7 1692 if(str.find("MODE=B_OK") != std::string::npos)
arsenalist 0:f4e449fa34d7 1693 break;
arsenalist 0:f4e449fa34d7 1694 }
arsenalist 0:f4e449fa34d7 1695 DBG.printf("MODE=B\r\n");
arsenalist 0:f4e449fa34d7 1696
arsenalist 0:f4e449fa34d7 1697 esp.enable();
arsenalist 0:f4e449fa34d7 1698 wait(1);
arsenalist 0:f4e449fa34d7 1699 while(!esp.ready());
arsenalist 0:f4e449fa34d7 1700
arsenalist 0:f4e449fa34d7 1701 if(!rest.begin("candra.tritronik.com",3128,false)) {
arsenalist 0:f4e449fa34d7 1702 DBG.printf("EMMA: fail to setup rest");
arsenalist 0:f4e449fa34d7 1703 while(1);
arsenalist 0:f4e449fa34d7 1704 }
arsenalist 0:f4e449fa34d7 1705
arsenalist 0:f4e449fa34d7 1706 //wifiConnected = true; //with custom firmware, panel should connect wifi automatically
arsenalist 0:f4e449fa34d7 1707 useProxy = true;
arsenalist 0:f4e449fa34d7 1708
arsenalist 0:f4e449fa34d7 1709 esp.process();
arsenalist 0:f4e449fa34d7 1710 //set connData
arsenalist 0:f4e449fa34d7 1711 if(useProxy) {
arsenalist 0:f4e449fa34d7 1712 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1713 s[i]=0; }
arsenalist 0:f4e449fa34d7 1714 //sprintf(s,"http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 1715 sprintf(s,"http://192.168.128.69/emmaController/firmware/firmwareParameter");
arsenalist 0:f4e449fa34d7 1716 connData = s;
arsenalist 0:f4e449fa34d7 1717 } else {
arsenalist 0:f4e449fa34d7 1718 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1719 s[i]=0; }
arsenalist 0:f4e449fa34d7 1720 //sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist 0:f4e449fa34d7 1721 sprintf(s,"/emmaController/firmware/firmwareParameter");
arsenalist 0:f4e449fa34d7 1722 connData = s;
arsenalist 0:f4e449fa34d7 1723 }
arsenalist 0:f4e449fa34d7 1724
arsenalist 0:f4e449fa34d7 1725 //get parameter of firmware to be downloaded
arsenalist 0:f4e449fa34d7 1726 while(!emmaGetFirmwareParam) {
arsenalist 0:f4e449fa34d7 1727 rest.get(connData.c_str());
arsenalist 0:f4e449fa34d7 1728 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1729 s[i]=0; }
arsenalist 0:f4e449fa34d7 1730 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 1731 //DBG.printf("rsp param:%s\r\n",s);
arsenalist 0:f4e449fa34d7 1732
arsenalist 0:f4e449fa34d7 1733 str = s;
arsenalist 0:f4e449fa34d7 1734 if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist 0:f4e449fa34d7 1735 str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist 0:f4e449fa34d7 1736 str.erase(str.begin()+str.find("]"),str.end());
arsenalist 0:f4e449fa34d7 1737
arsenalist 0:f4e449fa34d7 1738 MbedJSONValue jsonValue;
arsenalist 0:f4e449fa34d7 1739 parse(jsonValue,str.c_str());
arsenalist 0:f4e449fa34d7 1740
arsenalist 0:f4e449fa34d7 1741 char *parameter[2] = {"firmwareVer","numPart"};
arsenalist 0:f4e449fa34d7 1742
arsenalist 0:f4e449fa34d7 1743 for(int i=0; i<2; i++) {
arsenalist 0:f4e449fa34d7 1744 if(jsonValue.hasMember(parameter[i])) {
arsenalist 0:f4e449fa34d7 1745 string val = jsonValue[parameter[i]].get<std::string>();
arsenalist 0:f4e449fa34d7 1746 if(i==0) {
arsenalist 0:f4e449fa34d7 1747 firmwareVer = val;
arsenalist 0:f4e449fa34d7 1748 } else if(i==1) {
arsenalist 0:f4e449fa34d7 1749 sscanf(val.c_str(),"%d",&numPart);
arsenalist 0:f4e449fa34d7 1750 }
arsenalist 0:f4e449fa34d7 1751 }
arsenalist 0:f4e449fa34d7 1752 }
arsenalist 0:f4e449fa34d7 1753
arsenalist 0:f4e449fa34d7 1754 if(!firmwareVer.empty() && numPart!=0) {
arsenalist 0:f4e449fa34d7 1755 emmaGetFirmwareParam = true;
arsenalist 0:f4e449fa34d7 1756 }
arsenalist 0:f4e449fa34d7 1757 }
arsenalist 0:f4e449fa34d7 1758 }
arsenalist 0:f4e449fa34d7 1759 DBG.printf("firmwareVer:%s\r\n",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 1760 DBG.printf("numPart:%d\r\n",numPart);
arsenalist 0:f4e449fa34d7 1761
arsenalist 0:f4e449fa34d7 1762 //clear firmware file
arsenalist 0:f4e449fa34d7 1763 while(1) {
arsenalist 0:f4e449fa34d7 1764 if(clearFirmware()){
arsenalist 0:f4e449fa34d7 1765 DBG.printf("clear firmware on sd card\r\n\r\n");
arsenalist 0:f4e449fa34d7 1766 break;
arsenalist 0:f4e449fa34d7 1767 }
arsenalist 0:f4e449fa34d7 1768 wait(1);
arsenalist 0:f4e449fa34d7 1769 }
arsenalist 0:f4e449fa34d7 1770
arsenalist 0:f4e449fa34d7 1771 //set connData
arsenalist 0:f4e449fa34d7 1772 if(useProxy) {
arsenalist 0:f4e449fa34d7 1773 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1774 s[i]=0; }
arsenalist 0:f4e449fa34d7 1775 sprintf(s,"http://192.168.128.69/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 1776 connData = s;
arsenalist 0:f4e449fa34d7 1777 } else {
arsenalist 0:f4e449fa34d7 1778 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1779 s[i]=0; }
arsenalist 0:f4e449fa34d7 1780 sprintf(s,"/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist 0:f4e449fa34d7 1781 connData = s;
arsenalist 0:f4e449fa34d7 1782 }
arsenalist 0:f4e449fa34d7 1783
arsenalist 0:f4e449fa34d7 1784 //download firmware
arsenalist 0:f4e449fa34d7 1785 for(int n=0; n<numPart; n++) {
arsenalist 0:f4e449fa34d7 1786 nextPart = false;
arsenalist 0:f4e449fa34d7 1787 while(!nextPart) {
arsenalist 0:f4e449fa34d7 1788 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1789 s[i]=0; }
arsenalist 0:f4e449fa34d7 1790 sprintf(s,"%s/firmware_Hex_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist 0:f4e449fa34d7 1791 rest.get(s);
arsenalist 0:f4e449fa34d7 1792 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1793 s[i]=0; }
arsenalist 0:f4e449fa34d7 1794 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 1795 //DBG.printf("rsp[%d]:%s\r\n",n,s);
arsenalist 0:f4e449fa34d7 1796
arsenalist 0:f4e449fa34d7 1797 str = s;
arsenalist 0:f4e449fa34d7 1798 if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist 0:f4e449fa34d7 1799 str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist 0:f4e449fa34d7 1800 str.erase(str.begin()+str.find("}"),str.end());
arsenalist 0:f4e449fa34d7 1801 //DBG.printf("firmwarePart[%d]:%s\r\n",n,str.c_str());
arsenalist 0:f4e449fa34d7 1802 firmwarePart = str;
arsenalist 0:f4e449fa34d7 1803
arsenalist 0:f4e449fa34d7 1804 //calculated MD5
arsenalist 0:f4e449fa34d7 1805 calcMD5 = calculateMD5(firmwarePart);
arsenalist 0:f4e449fa34d7 1806 //DBG.printf("calcMD5[%d]:%s\r\n",n,calcMD5.c_str());
arsenalist 0:f4e449fa34d7 1807
arsenalist 0:f4e449fa34d7 1808 //MD5 from server
arsenalist 0:f4e449fa34d7 1809 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1810 s[i]=0; }
arsenalist 0:f4e449fa34d7 1811 sprintf(s,"%s/MD5/firmware_MD5_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist 0:f4e449fa34d7 1812 rest.get(s);
arsenalist 0:f4e449fa34d7 1813 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 1814 s[i]=0; }
arsenalist 0:f4e449fa34d7 1815 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 1816
arsenalist 0:f4e449fa34d7 1817 str = s;
arsenalist 0:f4e449fa34d7 1818 if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist 0:f4e449fa34d7 1819 str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist 0:f4e449fa34d7 1820 str.erase(str.begin()+str.find("}"),str.end());
arsenalist 0:f4e449fa34d7 1821 srvrMD5 = str;
arsenalist 0:f4e449fa34d7 1822 //DBG.printf("srvrMD5[%d]:%s\r\n",n,srvrMD5.c_str());
arsenalist 0:f4e449fa34d7 1823
arsenalist 0:f4e449fa34d7 1824 //compare original MD5 vs MD5 from server
arsenalist 0:f4e449fa34d7 1825 if(strcmp(calcMD5.c_str(),srvrMD5.c_str()) == 0) {
arsenalist 0:f4e449fa34d7 1826 //DBG.printf("MD5 correct\r\n");
arsenalist 0:f4e449fa34d7 1827
arsenalist 0:f4e449fa34d7 1828 //save to sd card
arsenalist 0:f4e449fa34d7 1829 int st = writeFirmwareHexToChar(firmwarePart);
arsenalist 0:f4e449fa34d7 1830 if(st) {
arsenalist 0:f4e449fa34d7 1831 DBG.printf("firmwarePart[%d/%d] written\r\n",n,numPart-1);
arsenalist 0:f4e449fa34d7 1832 nextPart = true;
arsenalist 0:f4e449fa34d7 1833 }
arsenalist 0:f4e449fa34d7 1834
arsenalist 0:f4e449fa34d7 1835 } else {
arsenalist 0:f4e449fa34d7 1836 DBG.printf("MD5 incorrect\r\n");
arsenalist 0:f4e449fa34d7 1837 }
arsenalist 0:f4e449fa34d7 1838 }
arsenalist 0:f4e449fa34d7 1839 } else {
arsenalist 0:f4e449fa34d7 1840 DBG.printf("retry to fetch firmwarePart[%d]\r\n",n);
arsenalist 0:f4e449fa34d7 1841 }
arsenalist 0:f4e449fa34d7 1842 wait(0.5);
arsenalist 0:f4e449fa34d7 1843 }
arsenalist 0:f4e449fa34d7 1844 }
arsenalist 0:f4e449fa34d7 1845 DBG.printf("download finished\r\n");
arsenalist 0:f4e449fa34d7 1846 }
arsenalist 12:96f637ed37f9 1847 /*end emma mode*/
arsenalist 0:f4e449fa34d7 1848
arsenalist 4:76ab12e2f8a3 1849 /*start energy related*/
arsenalist 0:f4e449fa34d7 1850 void energyThread(void const*) {
arsenalist 19:7e3e9332f719 1851 Timer tEnergy;
arsenalist 19:7e3e9332f719 1852
arsenalist 19:7e3e9332f719 1853 while(1) {
arsenalist 19:7e3e9332f719 1854 tEnergy.start();
arsenalist 19:7e3e9332f719 1855 DBG.printf("energyThread-start\r\n");
arsenalist 19:7e3e9332f719 1856
arsenalist 19:7e3e9332f719 1857 AWattHrSum = 0;
arsenalist 19:7e3e9332f719 1858 BWattHrSum = 0;
arsenalist 19:7e3e9332f719 1859 CWattHrSum = 0;
arsenalist 19:7e3e9332f719 1860
arsenalist 20:ea14f175bbb4 1861 while(tEnergy.read() < 1*60.0) {
arsenalist 19:7e3e9332f719 1862 AWattHrValue = ADE.getWattHR(PHASE_A);
arsenalist 19:7e3e9332f719 1863 BWattHrValue = ADE.getWattHR(PHASE_B);
arsenalist 19:7e3e9332f719 1864 CWattHrValue = ADE.getWattHR(PHASE_C);
arsenalist 19:7e3e9332f719 1865
arsenalist 19:7e3e9332f719 1866 AWattHrSum += AWattHrValue;
arsenalist 19:7e3e9332f719 1867 BWattHrSum += BWattHrValue;
arsenalist 20:ea14f175bbb4 1868 CWattHrSum += CWattHrValue;
arsenalist 20:ea14f175bbb4 1869
arsenalist 20:ea14f175bbb4 1870
arsenalist 20:ea14f175bbb4 1871 //start check voltage and power
arsenalist 21:33bd8b82560f 1872 AVrms = ADE.VRMS(PHASE_A) * 0.000124f; //0.000158; //constants are from calculateVRMS function
arsenalist 21:33bd8b82560f 1873 BVrms = ADE.VRMS(PHASE_B) * 0.000123f;
arsenalist 21:33bd8b82560f 1874 CVrms = ADE.VRMS(PHASE_C) * 0.000122f;
arsenalist 20:ea14f175bbb4 1875
arsenalist 21:33bd8b82560f 1876 AIrms = ADE.IRMS(PHASE_A) * 0.00001006f; //0.0000125f; //constants are from calculateIRMS function
arsenalist 21:33bd8b82560f 1877 BIrms = ADE.IRMS(PHASE_B) * 0.00001005f;
arsenalist 21:33bd8b82560f 1878 CIrms = ADE.IRMS(PHASE_C) * 0.00001004f;
arsenalist 20:ea14f175bbb4 1879
arsenalist 20:ea14f175bbb4 1880 AWatt = AVrms * AIrms;
arsenalist 20:ea14f175bbb4 1881 BWatt = BVrms * BIrms;
arsenalist 20:ea14f175bbb4 1882 CWatt = CVrms * CIrms;
arsenalist 20:ea14f175bbb4 1883 //end check voltage and power
arsenalist 20:ea14f175bbb4 1884
arsenalist 19:7e3e9332f719 1885 }
arsenalist 19:7e3e9332f719 1886
arsenalist 25:36c6a5db50ed 1887 AWattHr = AWattHrSum * 0.000044169f; //0.0000198f;
arsenalist 25:36c6a5db50ed 1888 BWattHr = BWattHrSum * 0.000044168f; //0.0000197f;
arsenalist 25:36c6a5db50ed 1889 CWattHr = CWattHrSum * 0.000044167f; //0.0000196f;
arsenalist 19:7e3e9332f719 1890
arsenalist 22:e18d361bf688 1891 newEnergyData = true;
arsenalist 22:e18d361bf688 1892
arsenalist 19:7e3e9332f719 1893 tEnergy.stop();
arsenalist 19:7e3e9332f719 1894 tEnergy.reset();
arsenalist 19:7e3e9332f719 1895 DBG.printf("energyThread-finish\r\n");
arsenalist 19:7e3e9332f719 1896 }
arsenalist 0:f4e449fa34d7 1897 }
arsenalist 21:33bd8b82560f 1898 void checkVoltagePower(void) {
arsenalist 4:76ab12e2f8a3 1899 //check if voltage or power violates threshold
arsenalist 22:e18d361bf688 1900 char p[64];
arsenalist 20:ea14f175bbb4 1901 char q[32];
arsenalist 4:76ab12e2f8a3 1902 char s[256];
arsenalist 22:e18d361bf688 1903 string hmacTime;
arsenalist 4:76ab12e2f8a3 1904 string str;
arsenalist 20:ea14f175bbb4 1905 time_t seconds;
arsenalist 4:76ab12e2f8a3 1906
arsenalist 4:76ab12e2f8a3 1907 //DBG.printf("checkVoltagePower-start\r\n");
arsenalist 4:76ab12e2f8a3 1908
arsenalist 20:ea14f175bbb4 1909 //vrms and irms might be placed inside energy calculation routine
arsenalist 20:ea14f175bbb4 1910 /*
arsenalist 19:7e3e9332f719 1911 AVrms = ADE.VRMS(PHASE_A) * 0.000128f; //0.000158; //constants are from calculateVRMS function
arsenalist 19:7e3e9332f719 1912 BVrms = ADE.VRMS(PHASE_B) * 0.000127f; //0.000157;
arsenalist 19:7e3e9332f719 1913 CVrms = ADE.VRMS(PHASE_C) * 0.000126f; //0.000156;
arsenalist 19:7e3e9332f719 1914
arsenalist 19:7e3e9332f719 1915 AIrms = ADE.IRMS(PHASE_A) * 0.0000125f; //constants are from calculateIRMS function
arsenalist 19:7e3e9332f719 1916 BIrms = ADE.IRMS(PHASE_B) * 0.0000123f;
arsenalist 19:7e3e9332f719 1917 CIrms = ADE.IRMS(PHASE_C) * 0.0000124f;
arsenalist 4:76ab12e2f8a3 1918
arsenalist 4:76ab12e2f8a3 1919 AWatt = AVrms * AIrms;
arsenalist 4:76ab12e2f8a3 1920 BWatt = BVrms * BIrms;
arsenalist 4:76ab12e2f8a3 1921 CWatt = CVrms * CIrms;
arsenalist 20:ea14f175bbb4 1922 */
arsenalist 4:76ab12e2f8a3 1923
arsenalist 21:33bd8b82560f 1924 //DBG.printf("Vrms of each phase:%.2f - %.2f - %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist 21:33bd8b82560f 1925 //DBG.printf("Watt of each phase:%.2f - %.2f - %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist 21:33bd8b82560f 1926 //wait(1);
arsenalist 19:7e3e9332f719 1927
arsenalist 20:ea14f175bbb4 1928 //get time
arsenalist 20:ea14f175bbb4 1929 seconds = time(NULL);
arsenalist 20:ea14f175bbb4 1930 strftime(q, 32, "%Y-%m-%d %H:%M:%S",localtime(&seconds));
arsenalist 20:ea14f175bbb4 1931
arsenalist 22:e18d361bf688 1932 //calculate hmacTime
arsenalist 22:e18d361bf688 1933 for(int j=0; j<sizeof(p); j++) {
arsenalist 22:e18d361bf688 1934 p[j]=0; }
arsenalist 22:e18d361bf688 1935 sprintf(p,"emma-%s-%s",emmaUID.c_str(),q);
arsenalist 22:e18d361bf688 1936 hmacTime = calculateMD5(p);
arsenalist 22:e18d361bf688 1937
arsenalist 4:76ab12e2f8a3 1938 if(AVrms > VRMSTHRESHOLD || AWatt > WATTTHRESHOLD) {
arsenalist 4:76ab12e2f8a3 1939 DBG.printf("alert on ch1\r\n");
arsenalist 20:ea14f175bbb4 1940 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 1941 emmaUID.c_str(),hmacTime.c_str(),q,AVrms,AWatt);
arsenalist 4:76ab12e2f8a3 1942 rest.post("/emma/api/controller/alert/1",s);
arsenalist 4:76ab12e2f8a3 1943 wait(2);
arsenalist 4:76ab12e2f8a3 1944 str = rxBuf;
arsenalist 4:76ab12e2f8a3 1945 if(str.rfind("/alert/1") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1946 str.erase(str.begin(),str.begin()+str.rfind("/alert/1"));
arsenalist 4:76ab12e2f8a3 1947 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1948 DBG.printf("send alert ch1 success\r\n");
arsenalist 4:76ab12e2f8a3 1949 } else {
arsenalist 4:76ab12e2f8a3 1950 DBG.printf("send alert ch1 failed\r\n");
arsenalist 4:76ab12e2f8a3 1951 }
arsenalist 4:76ab12e2f8a3 1952 }
arsenalist 4:76ab12e2f8a3 1953 }
arsenalist 4:76ab12e2f8a3 1954
arsenalist 4:76ab12e2f8a3 1955 if(BVrms > VRMSTHRESHOLD || BWatt > WATTTHRESHOLD) {
arsenalist 4:76ab12e2f8a3 1956 DBG.printf("alert on ch2\r\n");
arsenalist 20:ea14f175bbb4 1957 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 1958 emmaUID.c_str(),hmacTime.c_str(),q,BVrms,BWatt);
arsenalist 4:76ab12e2f8a3 1959 rest.post("/emma/api/controller/alert/2",s);
arsenalist 4:76ab12e2f8a3 1960 wait(2);
arsenalist 4:76ab12e2f8a3 1961 str = rxBuf;
arsenalist 4:76ab12e2f8a3 1962 if(str.rfind("/alert/2") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1963 str.erase(str.begin(),str.begin()+str.rfind("/alert/2"));
arsenalist 4:76ab12e2f8a3 1964 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1965 DBG.printf("send alert ch2 success\r\n");
arsenalist 4:76ab12e2f8a3 1966 } else {
arsenalist 4:76ab12e2f8a3 1967 DBG.printf("send alert ch2 failed\r\n");
arsenalist 4:76ab12e2f8a3 1968 }
arsenalist 4:76ab12e2f8a3 1969 }
arsenalist 4:76ab12e2f8a3 1970 }
arsenalist 4:76ab12e2f8a3 1971
arsenalist 4:76ab12e2f8a3 1972 if(CVrms > VRMSTHRESHOLD || CWatt > WATTTHRESHOLD) {
arsenalist 7:7e8c6ad3fd64 1973 DBG.printf("alert on ch3\r\n");
arsenalist 4:76ab12e2f8a3 1974 DBG.printf("alert on ch3\r\n");
arsenalist 20:ea14f175bbb4 1975 sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"%s\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist 22:e18d361bf688 1976 emmaUID.c_str(),hmacTime.c_str(),q,CVrms,CWatt);
arsenalist 4:76ab12e2f8a3 1977 rest.post("/emma/api/controller/alert/3",s);
arsenalist 4:76ab12e2f8a3 1978 wait(2);
arsenalist 4:76ab12e2f8a3 1979 str = rxBuf;
arsenalist 4:76ab12e2f8a3 1980 if(str.rfind("/alert/3") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1981 str.erase(str.begin(),str.begin()+str.rfind("/alert/3"));
arsenalist 4:76ab12e2f8a3 1982 if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 1983 DBG.printf("send alert ch3 success\r\n");
arsenalist 4:76ab12e2f8a3 1984 } else {
arsenalist 4:76ab12e2f8a3 1985 DBG.printf("send alert ch3 failed\r\n");
arsenalist 4:76ab12e2f8a3 1986 }
arsenalist 4:76ab12e2f8a3 1987 }
arsenalist 4:76ab12e2f8a3 1988 }
arsenalist 4:76ab12e2f8a3 1989 //DBG.printf("checkVoltagePower-finish\r\n");
arsenalist 4:76ab12e2f8a3 1990 }
arsenalist 4:76ab12e2f8a3 1991 /*end energy related*/
arsenalist 0:f4e449fa34d7 1992
arsenalist 0:f4e449fa34d7 1993 /*start wifi mqtt*/
arsenalist 0:f4e449fa34d7 1994 void mqttConnected(void* response) {
arsenalist 1:d314a43ae6f7 1995 DBG.printf("MQTT Connected\r\n");
arsenalist 0:f4e449fa34d7 1996 char mqttTopic[64];
arsenalist 0:f4e449fa34d7 1997 sprintf(mqttTopic,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist 27:562a95c120cc 1998 //mqtt.subscribe(mqttTopic);
arsenalist 0:f4e449fa34d7 1999 }
arsenalist 0:f4e449fa34d7 2000 void mqttDisconnected(void* response) {
arsenalist 1:d314a43ae6f7 2001 DBG.printf("MQTT Disconnected\r\n");
arsenalist 0:f4e449fa34d7 2002 }
arsenalist 0:f4e449fa34d7 2003 /*end wifi mqtt*/
arsenalist 0:f4e449fa34d7 2004
arsenalist 0:f4e449fa34d7 2005 /*start wifi rest*/
arsenalist 27:562a95c120cc 2006 void wifiCb(void* response) {
arsenalist 27:562a95c120cc 2007 uint32_t status;
arsenalist 27:562a95c120cc 2008 RESPONSE res(response);
arsenalist 27:562a95c120cc 2009
arsenalist 27:562a95c120cc 2010 if(res.getArgc() == 1) {
arsenalist 27:562a95c120cc 2011 res.popArgs((uint8_t*)&status,4);
arsenalist 27:562a95c120cc 2012 if(status == STATION_GOT_IP) {
arsenalist 27:562a95c120cc 2013 DBG.printf("WIFI Connected\r\n");
arsenalist 27:562a95c120cc 2014 //wifiConnected = true;
arsenalist 27:562a95c120cc 2015 }
arsenalist 27:562a95c120cc 2016 else {
arsenalist 27:562a95c120cc 2017 //wifiConnected = false;
arsenalist 27:562a95c120cc 2018 }
arsenalist 27:562a95c120cc 2019 }
arsenalist 27:562a95c120cc 2020 }
arsenalist 27:562a95c120cc 2021
arsenalist 4:76ab12e2f8a3 2022 void rxInterrupt(void) {
arsenalist 4:76ab12e2f8a3 2023 char c;
arsenalist 4:76ab12e2f8a3 2024
arsenalist 4:76ab12e2f8a3 2025 while(_ESP.readable()) {
arsenalist 4:76ab12e2f8a3 2026 c = _ESP.getc();
arsenalist 4:76ab12e2f8a3 2027 if(c != 0) { //char is not null
arsenalist 4:76ab12e2f8a3 2028 rxBuf += c;
arsenalist 4:76ab12e2f8a3 2029 }
arsenalist 4:76ab12e2f8a3 2030 }
arsenalist 4:76ab12e2f8a3 2031 }
arsenalist 4:76ab12e2f8a3 2032 void checkRxBuffer(void) {
arsenalist 4:76ab12e2f8a3 2033 //check new command
arsenalist 4:76ab12e2f8a3 2034 if(rxBuf.rfind("/command") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2035 rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.rfind("/command"));
arsenalist 4:76ab12e2f8a3 2036 if(rxBuf.find("[{") != std::string::npos && rxBuf.find("}]") != std::string::npos) {
arsenalist 4:76ab12e2f8a3 2037 rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.find("[{")+1);
arsenalist 4:76ab12e2f8a3 2038 rxBuf.erase(rxBuf.begin()+rxBuf.find("]"),rxBuf.end());
arsenalist 4:76ab12e2f8a3 2039 globalCommand = rxBuf;
arsenalist 4:76ab12e2f8a3 2040 //DBG.printf("gC:%s\r\n",globalCommand.c_str());
arsenalist 4:76ab12e2f8a3 2041 newCommand = true;
arsenalist 4:76ab12e2f8a3 2042 }
arsenalist 4:76ab12e2f8a3 2043 }
arsenalist 4:76ab12e2f8a3 2044
arsenalist 24:5d58515ba510 2045 //check free memory -> reinitialize mqtt connection
arsenalist 27:562a95c120cc 2046 if(rxBuf.rfind("Free memory") != std::string::npos) {
arsenalist 27:562a95c120cc 2047 rxLog = "Free memory-" + rxBuf;
arsenalist 24:5d58515ba510 2048 espFreeMemory = true;
arsenalist 24:5d58515ba510 2049 }
arsenalist 24:5d58515ba510 2050
arsenalist 27:562a95c120cc 2051 //check dhcp client start -> initialize all connection
arsenalist 27:562a95c120cc 2052 if(rxBuf.rfind("dhcp client start") != std::string::npos) {
arsenalist 27:562a95c120cc 2053 rxLogA = "dhcp client start-" + rxBuf;
arsenalist 27:562a95c120cc 2054 espDHCPClientStart = true;
arsenalist 27:562a95c120cc 2055 }
arsenalist 27:562a95c120cc 2056
arsenalist 4:76ab12e2f8a3 2057 //clear rxBuf
arsenalist 4:76ab12e2f8a3 2058 rxBuf.clear();
arsenalist 4:76ab12e2f8a3 2059 }
arsenalist 0:f4e449fa34d7 2060 /*end wifi rest*/
arsenalist 0:f4e449fa34d7 2061
arsenalist 0:f4e449fa34d7 2062 /*start eth mqtt*/
arsenalist 0:f4e449fa34d7 2063 void ethMQTTMessageArrived(MQTT::MessageData& md) {
arsenalist 0:f4e449fa34d7 2064 MQTT::Message &message = md.message;
arsenalist 0:f4e449fa34d7 2065 DBG.printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n",
arsenalist 0:f4e449fa34d7 2066 message.qos, message.retained, message.dup, message.id);
arsenalist 0:f4e449fa34d7 2067 DBG.printf("Payload: %.*s\r\n", message.payloadlen, (char*)message.payload);
arsenalist 0:f4e449fa34d7 2068 //DBG.printf("Payload %s\r\n",message.payload);
arsenalist 0:f4e449fa34d7 2069
arsenalist 0:f4e449fa34d7 2070
arsenalist 0:f4e449fa34d7 2071 //check whether cmd is json
arsenalist 0:f4e449fa34d7 2072 //char r[255];
arsenalist 0:f4e449fa34d7 2073 char *s = (char*)message.payload;
arsenalist 0:f4e449fa34d7 2074 string sp(s);
arsenalist 0:f4e449fa34d7 2075 //sprintf(s,"%.*s",message.payloadlen, (char*)message.payload);
arsenalist 0:f4e449fa34d7 2076 //sprintf(globCmd,"%s",s);
arsenalist 0:f4e449fa34d7 2077 //DBG.printf("Payload: %s\r\n", r);
arsenalist 0:f4e449fa34d7 2078 //string cmd = r;
arsenalist 0:f4e449fa34d7 2079 //globalCommand = cmd;
arsenalist 10:1dc69e0ce7fd 2080
arsenalist 10:1dc69e0ce7fd 2081 //globalCommand = sp;
arsenalist 10:1dc69e0ce7fd 2082
arsenalist 0:f4e449fa34d7 2083 //globCmd = (char*)message.payload;
arsenalist 0:f4e449fa34d7 2084 //string globCmd((char*)message.payload);
arsenalist 0:f4e449fa34d7 2085 //std::string *sp = static_cast<std::char*>(message.payload);
arsenalist 0:f4e449fa34d7 2086 //string sp((char*)message.payload);
arsenalist 10:1dc69e0ce7fd 2087
arsenalist 10:1dc69e0ce7fd 2088 //DBG.printf("String: %s\r\n",sp.c_str());
arsenalist 10:1dc69e0ce7fd 2089
arsenalist 0:f4e449fa34d7 2090 //globCmd = sp;
arsenalist 0:f4e449fa34d7 2091
arsenalist 10:1dc69e0ce7fd 2092 //newCommand = true;
arsenalist 10:1dc69e0ce7fd 2093 if(sp.find("[") != std::string::npos && sp.find("]") != std::string::npos) {
arsenalist 10:1dc69e0ce7fd 2094 sp.erase(sp.begin(),sp.begin()+sp.find("[")+1);
arsenalist 10:1dc69e0ce7fd 2095 sp.erase(sp.begin()+sp.find("]"),sp.end());
arsenalist 10:1dc69e0ce7fd 2096 globalCommand = sp;
arsenalist 0:f4e449fa34d7 2097 newCommand = true;
arsenalist 0:f4e449fa34d7 2098 }
arsenalist 10:1dc69e0ce7fd 2099 sp.clear();
arsenalist 0:f4e449fa34d7 2100 }
arsenalist 0:f4e449fa34d7 2101
arsenalist 0:f4e449fa34d7 2102 int ethMQTTConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist 0:f4e449fa34d7 2103 //char hostname[] = "q.thingfabric.com";
arsenalist 0:f4e449fa34d7 2104 //char hostname[] = "192.168.131.200";
arsenalist 0:f4e449fa34d7 2105 //int rc = ipstack->connect(hostname, MQTT_PORT);
arsenalist 0:f4e449fa34d7 2106 int rc = ipstack->connect(MQTT_HOST, MQTT_PORT);
arsenalist 0:f4e449fa34d7 2107
arsenalist 0:f4e449fa34d7 2108 if(rc!=0)
arsenalist 0:f4e449fa34d7 2109 return rc;
arsenalist 0:f4e449fa34d7 2110
arsenalist 0:f4e449fa34d7 2111 //MQTT Connect
arsenalist 0:f4e449fa34d7 2112 //char clientId[] = "emma/0674ff575349896767072538";
arsenalist 0:f4e449fa34d7 2113 char clientId [32];
arsenalist 0:f4e449fa34d7 2114 sprintf(clientId,"emma/%s",emmaUID.c_str());
arsenalist 0:f4e449fa34d7 2115 //DBG.printf("clientId:%s\r\n",clientId);
arsenalist 0:f4e449fa34d7 2116 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
arsenalist 0:f4e449fa34d7 2117 data.MQTTVersion = 3;
arsenalist 0:f4e449fa34d7 2118 data.clientID.cstring = clientId;
arsenalist 0:f4e449fa34d7 2119 data.username.cstring = "761b233e-a49a-4830-a8ae-87cec3dc1086";
arsenalist 0:f4e449fa34d7 2120 data.password.cstring = "ef25cf4567fbc07113252f8d72b7faf2";
arsenalist 0:f4e449fa34d7 2121
arsenalist 0:f4e449fa34d7 2122 if((rc = client->connect(&data)) == 0) {
arsenalist 0:f4e449fa34d7 2123 DBG.printf("connected\r\n");
arsenalist 0:f4e449fa34d7 2124 }
arsenalist 0:f4e449fa34d7 2125
arsenalist 0:f4e449fa34d7 2126 //MQTT Subscribe
arsenalist 0:f4e449fa34d7 2127 //char* topic = "gaisbwqreqrfxjc/0674ff575349896767072538/command";
arsenalist 0:f4e449fa34d7 2128 char s[64];
arsenalist 0:f4e449fa34d7 2129 sprintf(s,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist 0:f4e449fa34d7 2130 string topic = s;
arsenalist 0:f4e449fa34d7 2131 //DBG.printf("topic:%s\r\n",topic.c_str());
arsenalist 0:f4e449fa34d7 2132 if((rc=client->subscribe(topic.c_str(),MQTT::QOS0,ethMQTTMessageArrived)) == 0) {
arsenalist 0:f4e449fa34d7 2133 DBG.printf("subscribe success!\r\n");
arsenalist 0:f4e449fa34d7 2134 }
arsenalist 0:f4e449fa34d7 2135 return rc;
arsenalist 0:f4e449fa34d7 2136 }
arsenalist 0:f4e449fa34d7 2137 void ethMQTTAttemptConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist 0:f4e449fa34d7 2138 int retryAttempt = 0;
arsenalist 0:f4e449fa34d7 2139
arsenalist 0:f4e449fa34d7 2140 while(!ipstack->getEth().linkstatus()) {
arsenalist 0:f4e449fa34d7 2141 DBG.printf("Ethernet link not present. Check cable connection\r\n");
arsenalist 0:f4e449fa34d7 2142 wait(1);
arsenalist 0:f4e449fa34d7 2143 }
arsenalist 0:f4e449fa34d7 2144
arsenalist 0:f4e449fa34d7 2145 while(ethMQTTConnect(client,ipstack) != 0) {
arsenalist 0:f4e449fa34d7 2146 int timeout = 3;
arsenalist 0:f4e449fa34d7 2147 DBG.printf("Retry attempt number %d waiting %d\r\n", retryAttempt, timeout);
arsenalist 0:f4e449fa34d7 2148 wait(timeout);
arsenalist 0:f4e449fa34d7 2149 retryAttempt++;
arsenalist 0:f4e449fa34d7 2150 }
arsenalist 0:f4e449fa34d7 2151 }
arsenalist 0:f4e449fa34d7 2152 /*end eth mqtt*/
arsenalist 0:f4e449fa34d7 2153
arsenalist 0:f4e449fa34d7 2154 /*start emma settings*/
arsenalist 0:f4e449fa34d7 2155 string getUID(void) {
arsenalist 0:f4e449fa34d7 2156 char s[32];
arsenalist 0:f4e449fa34d7 2157 unsigned long *unique = (unsigned long *)BASE_ADDR;
arsenalist 0:f4e449fa34d7 2158 sprintf(s,"%08x%08x%08x",unique[0], unique[1], unique[2]);
arsenalist 0:f4e449fa34d7 2159 return s;
arsenalist 0:f4e449fa34d7 2160 }
arsenalist 0:f4e449fa34d7 2161
arsenalist 0:f4e449fa34d7 2162 string readSetting(string parameter) {
arsenalist 0:f4e449fa34d7 2163 FILE *fp;
arsenalist 0:f4e449fa34d7 2164 signed char c;
arsenalist 0:f4e449fa34d7 2165 int i=0;
arsenalist 0:f4e449fa34d7 2166 char s[64];
arsenalist 0:f4e449fa34d7 2167 string strS;
arsenalist 0:f4e449fa34d7 2168
arsenalist 0:f4e449fa34d7 2169 sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist 0:f4e449fa34d7 2170
arsenalist 0:f4e449fa34d7 2171 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 2172 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 2173 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2174 while(1) {
arsenalist 0:f4e449fa34d7 2175 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 2176 if(c == EOF){
arsenalist 0:f4e449fa34d7 2177 break;
arsenalist 0:f4e449fa34d7 2178 }
arsenalist 0:f4e449fa34d7 2179 s[i] = c;
arsenalist 0:f4e449fa34d7 2180 i++;
arsenalist 0:f4e449fa34d7 2181 }
arsenalist 0:f4e449fa34d7 2182 strS = s;
arsenalist 0:f4e449fa34d7 2183 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2184 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 2185 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 2186 } else {
arsenalist 0:f4e449fa34d7 2187 strS = "";
arsenalist 0:f4e449fa34d7 2188 }
arsenalist 0:f4e449fa34d7 2189 }
arsenalist 0:f4e449fa34d7 2190 fclose(fp);
arsenalist 30:08d290158fa7 2191 free(fp);
arsenalist 0:f4e449fa34d7 2192 return strS;
arsenalist 0:f4e449fa34d7 2193 }
arsenalist 0:f4e449fa34d7 2194
arsenalist 0:f4e449fa34d7 2195 bool writeSetting(string parameter, string value) {
arsenalist 0:f4e449fa34d7 2196 FILE *fp;
arsenalist 0:f4e449fa34d7 2197 char s[255];
arsenalist 0:f4e449fa34d7 2198
arsenalist 0:f4e449fa34d7 2199 sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist 0:f4e449fa34d7 2200 fp = fopen(s,"w");
arsenalist 0:f4e449fa34d7 2201 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2202 fprintf(fp,value.c_str());
arsenalist 0:f4e449fa34d7 2203 fclose(fp);
arsenalist 30:08d290158fa7 2204 free(fp);
arsenalist 0:f4e449fa34d7 2205 return true;
arsenalist 0:f4e449fa34d7 2206 }
arsenalist 30:08d290158fa7 2207 fclose(fp);
arsenalist 30:08d290158fa7 2208 free(fp);
arsenalist 0:f4e449fa34d7 2209 return false;
arsenalist 0:f4e449fa34d7 2210 }
arsenalist 0:f4e449fa34d7 2211 /*end emma settings*/
arsenalist 0:f4e449fa34d7 2212
arsenalist 0:f4e449fa34d7 2213 /*start emma node*/
arsenalist 0:f4e449fa34d7 2214 string readNodeIP(string macAddr) {
arsenalist 0:f4e449fa34d7 2215 FILE *fp;
arsenalist 0:f4e449fa34d7 2216 signed char c;
arsenalist 0:f4e449fa34d7 2217 int i=0;
arsenalist 0:f4e449fa34d7 2218 char s[64];
arsenalist 0:f4e449fa34d7 2219 string strS;
arsenalist 0:f4e449fa34d7 2220
arsenalist 0:f4e449fa34d7 2221 sprintf(s,"/sd/nodeList/%s/nodeIP.txt",macAddr.c_str());
arsenalist 0:f4e449fa34d7 2222
arsenalist 0:f4e449fa34d7 2223 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 2224 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 2225 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2226 while(1) {
arsenalist 0:f4e449fa34d7 2227 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 2228 if(c == EOF){
arsenalist 0:f4e449fa34d7 2229 break;
arsenalist 0:f4e449fa34d7 2230 }
arsenalist 0:f4e449fa34d7 2231 s[i] = c;
arsenalist 0:f4e449fa34d7 2232 i++;
arsenalist 0:f4e449fa34d7 2233 }
arsenalist 0:f4e449fa34d7 2234 strS = s;
arsenalist 0:f4e449fa34d7 2235 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2236 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 2237 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 2238 } else {
arsenalist 0:f4e449fa34d7 2239 strS = "";
arsenalist 0:f4e449fa34d7 2240 }
arsenalist 0:f4e449fa34d7 2241 }
arsenalist 0:f4e449fa34d7 2242 fclose(fp);
arsenalist 30:08d290158fa7 2243 free(fp);
arsenalist 0:f4e449fa34d7 2244 return strS;
arsenalist 0:f4e449fa34d7 2245 }
arsenalist 0:f4e449fa34d7 2246
arsenalist 0:f4e449fa34d7 2247 string readNodeCmd(string dType, string cmd) {
arsenalist 0:f4e449fa34d7 2248 FILE *fp;
arsenalist 0:f4e449fa34d7 2249 signed char c;
arsenalist 0:f4e449fa34d7 2250 int i=0;
arsenalist 0:f4e449fa34d7 2251 char s[128];
arsenalist 0:f4e449fa34d7 2252 string strS;
arsenalist 0:f4e449fa34d7 2253
arsenalist 0:f4e449fa34d7 2254 sprintf(s,"/sd/nodeCode/%s/%s.txt",dType.c_str(),cmd.c_str());
arsenalist 0:f4e449fa34d7 2255
arsenalist 0:f4e449fa34d7 2256 fp = fopen(s,"r");
arsenalist 0:f4e449fa34d7 2257 memset(s,0,sizeof(s));
arsenalist 0:f4e449fa34d7 2258 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2259 while(1) {
arsenalist 0:f4e449fa34d7 2260 c = fgetc(fp);
arsenalist 0:f4e449fa34d7 2261 if(c == EOF){
arsenalist 0:f4e449fa34d7 2262 break;
arsenalist 0:f4e449fa34d7 2263 }
arsenalist 0:f4e449fa34d7 2264 s[i] = c;
arsenalist 0:f4e449fa34d7 2265 i++;
arsenalist 0:f4e449fa34d7 2266 }
arsenalist 0:f4e449fa34d7 2267 strS = s;
arsenalist 0:f4e449fa34d7 2268 if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2269 strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist 0:f4e449fa34d7 2270 strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist 0:f4e449fa34d7 2271 } else {
arsenalist 0:f4e449fa34d7 2272 strS = "";
arsenalist 0:f4e449fa34d7 2273 }
arsenalist 0:f4e449fa34d7 2274 }
arsenalist 0:f4e449fa34d7 2275 fclose(fp);
arsenalist 30:08d290158fa7 2276 free(fp);
arsenalist 0:f4e449fa34d7 2277 return strS;
arsenalist 0:f4e449fa34d7 2278 }
arsenalist 0:f4e449fa34d7 2279
arsenalist 0:f4e449fa34d7 2280 string *readNodeList(void) {
arsenalist 0:f4e449fa34d7 2281 static string nd[10]; //max node
arsenalist 0:f4e449fa34d7 2282 DIR *d;
arsenalist 0:f4e449fa34d7 2283 struct dirent *p;
arsenalist 0:f4e449fa34d7 2284 string q;
arsenalist 0:f4e449fa34d7 2285 int i=0;
arsenalist 0:f4e449fa34d7 2286
arsenalist 0:f4e449fa34d7 2287 d = opendir("/sd/nodeList");
arsenalist 0:f4e449fa34d7 2288 if(d != NULL) {
arsenalist 0:f4e449fa34d7 2289 while((p = readdir(d)) != NULL) {
arsenalist 0:f4e449fa34d7 2290 q = p->d_name;
arsenalist 0:f4e449fa34d7 2291 nd[i] = q;
arsenalist 0:f4e449fa34d7 2292 i++;
arsenalist 0:f4e449fa34d7 2293 }
arsenalist 0:f4e449fa34d7 2294 }
arsenalist 0:f4e449fa34d7 2295 closedir(d);
arsenalist 30:08d290158fa7 2296 free(d);
arsenalist 0:f4e449fa34d7 2297 return nd;
arsenalist 0:f4e449fa34d7 2298 }
arsenalist 0:f4e449fa34d7 2299
arsenalist 0:f4e449fa34d7 2300 string wifiGetNodeTemp(string macAddr) {
arsenalist 0:f4e449fa34d7 2301 int trial=0;
arsenalist 0:f4e449fa34d7 2302 string nodeIP = readNodeIP(macAddr);
arsenalist 0:f4e449fa34d7 2303 string str;
arsenalist 0:f4e449fa34d7 2304 string temp = "0";
arsenalist 0:f4e449fa34d7 2305
arsenalist 0:f4e449fa34d7 2306 if(rest.begin(nodeIP.c_str(),REMOTE_TCP_PORT,false)) {
arsenalist 0:f4e449fa34d7 2307 while(1) {
arsenalist 0:f4e449fa34d7 2308 char rcv[256] = {};
arsenalist 0:f4e449fa34d7 2309 rest.get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist 0:f4e449fa34d7 2310 rest.getResponse(rcv,sizeof(rcv));
arsenalist 0:f4e449fa34d7 2311 str = rcv;
arsenalist 0:f4e449fa34d7 2312 if(str.find("temp=") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2313 str.erase(str.begin(),str.begin()+str.find("temp=")+6);
arsenalist 0:f4e449fa34d7 2314 str.erase(str.begin()+str.find("\""),str.end());
arsenalist 0:f4e449fa34d7 2315 temp = str;
arsenalist 0:f4e449fa34d7 2316 break;
arsenalist 0:f4e449fa34d7 2317 }
arsenalist 0:f4e449fa34d7 2318 if(trial>1) { //three times trial
arsenalist 0:f4e449fa34d7 2319 break;
arsenalist 0:f4e449fa34d7 2320 }
arsenalist 0:f4e449fa34d7 2321 trial++;
arsenalist 0:f4e449fa34d7 2322 wait(2);
arsenalist 0:f4e449fa34d7 2323 }
arsenalist 0:f4e449fa34d7 2324 }
arsenalist 0:f4e449fa34d7 2325 return temp;
arsenalist 0:f4e449fa34d7 2326 }
arsenalist 0:f4e449fa34d7 2327 /*end emma node*/
arsenalist 0:f4e449fa34d7 2328
arsenalist 0:f4e449fa34d7 2329 /*start emma connection function*/
arsenalist 0:f4e449fa34d7 2330 string ethGET(string host, int port, string url) {
arsenalist 0:f4e449fa34d7 2331 char buf[1024];
arsenalist 0:f4e449fa34d7 2332 char s[256];
arsenalist 0:f4e449fa34d7 2333 int ret;
arsenalist 0:f4e449fa34d7 2334 TCPSocketConnection sock;
arsenalist 0:f4e449fa34d7 2335 Timer t;
arsenalist 0:f4e449fa34d7 2336
arsenalist 0:f4e449fa34d7 2337 sprintf(s,"%s",url.c_str());
arsenalist 0:f4e449fa34d7 2338 sock.connect(host.c_str(),port);
arsenalist 0:f4e449fa34d7 2339 sock.send_all(s,sizeof(s)-1);
arsenalist 0:f4e449fa34d7 2340 wait(2);
arsenalist 0:f4e449fa34d7 2341
arsenalist 0:f4e449fa34d7 2342 //receive return
arsenalist 0:f4e449fa34d7 2343 t.start();
arsenalist 0:f4e449fa34d7 2344 while(1) {
arsenalist 0:f4e449fa34d7 2345 ret = sock.receive(buf, sizeof(buf));
arsenalist 0:f4e449fa34d7 2346 if(ret<=0 || t.read_ms() > 10000) {
arsenalist 0:f4e449fa34d7 2347 t.stop();
arsenalist 0:f4e449fa34d7 2348 break;
arsenalist 0:f4e449fa34d7 2349 }
arsenalist 0:f4e449fa34d7 2350 }
arsenalist 0:f4e449fa34d7 2351 sock.close();
arsenalist 0:f4e449fa34d7 2352 return buf;
arsenalist 0:f4e449fa34d7 2353 }
arsenalist 0:f4e449fa34d7 2354 /*end emma connection function*/
arsenalist 0:f4e449fa34d7 2355
arsenalist 0:f4e449fa34d7 2356 /*start emma private function*/
arsenalist 8:51a0ca9079ca 2357 /*
arsenalist 8:51a0ca9079ca 2358 void connectedIface(void) { //WARNING: should be run in emmaModeRegister and emmaModeOperation only - problem with esp, after MODE=B, cannot go back to MODE=S
arsenalist 0:f4e449fa34d7 2359 char s[512];
arsenalist 0:f4e449fa34d7 2360 int connPort;
arsenalist 0:f4e449fa34d7 2361 string connHost;
arsenalist 0:f4e449fa34d7 2362 string str;
arsenalist 0:f4e449fa34d7 2363 Timer t;
arsenalist 0:f4e449fa34d7 2364
arsenalist 0:f4e449fa34d7 2365 //wifi interface
arsenalist 0:f4e449fa34d7 2366 if(wifiAvailable) {
arsenalist 0:f4e449fa34d7 2367 _ESP.printf("MODE=B");
arsenalist 0:f4e449fa34d7 2368 if(useProxy) {
arsenalist 0:f4e449fa34d7 2369 connHost = proxySERVER;
arsenalist 0:f4e449fa34d7 2370 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 0:f4e449fa34d7 2371 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2372 s[i]=0; }
arsenalist 4:76ab12e2f8a3 2373 sprintf(s,"http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist 0:f4e449fa34d7 2374 } else {
arsenalist 0:f4e449fa34d7 2375 connHost = EMMA_SERVER_HOST;
arsenalist 0:f4e449fa34d7 2376 connPort = EMMA_SERVER_PORT;
arsenalist 0:f4e449fa34d7 2377 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2378 s[i]=0; }
arsenalist 4:76ab12e2f8a3 2379 sprintf(s,"/emma/api/controller/test");
arsenalist 0:f4e449fa34d7 2380 }
arsenalist 0:f4e449fa34d7 2381 wait(1);
arsenalist 0:f4e449fa34d7 2382 t.start();
arsenalist 0:f4e449fa34d7 2383 while(!esp.ready() && t.read_ms() < 5000);
arsenalist 0:f4e449fa34d7 2384 t.stop();
arsenalist 0:f4e449fa34d7 2385 if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist 0:f4e449fa34d7 2386 //DBG.printf("rest begin\r\n");
arsenalist 0:f4e449fa34d7 2387 esp.process();
arsenalist 0:f4e449fa34d7 2388 rest.get(s);
arsenalist 0:f4e449fa34d7 2389 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2390 s[i]=0; }
arsenalist 0:f4e449fa34d7 2391 rest.getResponse(s,sizeof(s));
arsenalist 0:f4e449fa34d7 2392 str = s;
arsenalist 0:f4e449fa34d7 2393 //DBG.printf("response:%s\r\n",s);
arsenalist 0:f4e449fa34d7 2394 if(str.find("OK") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2395 wifiConnected = true;
arsenalist 0:f4e449fa34d7 2396 }
arsenalist 0:f4e449fa34d7 2397 } else {
arsenalist 0:f4e449fa34d7 2398 wifiConnected = false;
arsenalist 0:f4e449fa34d7 2399 }
arsenalist 0:f4e449fa34d7 2400 } else {
arsenalist 0:f4e449fa34d7 2401 wifiConnected = false;
arsenalist 0:f4e449fa34d7 2402 }
arsenalist 0:f4e449fa34d7 2403
arsenalist 0:f4e449fa34d7 2404 //eth interface
arsenalist 0:f4e449fa34d7 2405 if(ethAvailable) {
arsenalist 0:f4e449fa34d7 2406 if(useProxy) {
arsenalist 0:f4e449fa34d7 2407 connHost = proxySERVER;
arsenalist 0:f4e449fa34d7 2408 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 0:f4e449fa34d7 2409 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2410 s[i]=0; }
arsenalist 0:f4e449fa34d7 2411 sprintf(s,"GET http://%s:%d/emma/api/web/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist 0:f4e449fa34d7 2412 } else {
arsenalist 0:f4e449fa34d7 2413 connHost = EMMA_SERVER_HOST;
arsenalist 0:f4e449fa34d7 2414 connPort = EMMA_SERVER_PORT;
arsenalist 0:f4e449fa34d7 2415 for(int i=0; i<sizeof(s); i++) {
arsenalist 0:f4e449fa34d7 2416 s[i]=0; }
arsenalist 0:f4e449fa34d7 2417 strcpy(s,"GET /emma/api/web/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist 0:f4e449fa34d7 2418 }
arsenalist 0:f4e449fa34d7 2419
arsenalist 0:f4e449fa34d7 2420 t.start();
arsenalist 0:f4e449fa34d7 2421 while(1) {
arsenalist 0:f4e449fa34d7 2422 str = ethGET(connHost,connPort,s);
arsenalist 0:f4e449fa34d7 2423 if(str.find("OK") != std::string::npos) {
arsenalist 0:f4e449fa34d7 2424 t.stop();
arsenalist 0:f4e449fa34d7 2425 ethConnected = true;
arsenalist 0:f4e449fa34d7 2426 break;
arsenalist 0:f4e449fa34d7 2427 }
arsenalist 0:f4e449fa34d7 2428 if(t.read_ms() > 5000) {
arsenalist 0:f4e449fa34d7 2429 t.stop();
arsenalist 0:f4e449fa34d7 2430 ethConnected = false;
arsenalist 0:f4e449fa34d7 2431 break;
arsenalist 0:f4e449fa34d7 2432 }
arsenalist 0:f4e449fa34d7 2433 }
arsenalist 0:f4e449fa34d7 2434 } else {
arsenalist 0:f4e449fa34d7 2435 ethConnected = false;
arsenalist 0:f4e449fa34d7 2436 }
arsenalist 0:f4e449fa34d7 2437
arsenalist 0:f4e449fa34d7 2438 //gprs interface
arsenalist 0:f4e449fa34d7 2439 }
arsenalist 8:51a0ca9079ca 2440 */
arsenalist 8:51a0ca9079ca 2441 void isEthAvailable(void) {
arsenalist 8:51a0ca9079ca 2442 if(ipstack.getEth().linkstatus()) {
arsenalist 8:51a0ca9079ca 2443 ethAvailable = true;
arsenalist 8:51a0ca9079ca 2444 } else {
arsenalist 8:51a0ca9079ca 2445 ethAvailable = false;
arsenalist 8:51a0ca9079ca 2446 }
arsenalist 8:51a0ca9079ca 2447 }
arsenalist 8:51a0ca9079ca 2448
arsenalist 8:51a0ca9079ca 2449 void isEthConnected(void) {
arsenalist 8:51a0ca9079ca 2450 char s[512];
arsenalist 8:51a0ca9079ca 2451 int connPort;
arsenalist 8:51a0ca9079ca 2452 string connHost;
arsenalist 8:51a0ca9079ca 2453 string str;
arsenalist 8:51a0ca9079ca 2454 Timer t;
arsenalist 8:51a0ca9079ca 2455
arsenalist 8:51a0ca9079ca 2456 if(ethAvailable) {
arsenalist 8:51a0ca9079ca 2457 if(useProxy) {
arsenalist 8:51a0ca9079ca 2458 connHost = proxySERVER;
arsenalist 8:51a0ca9079ca 2459 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 8:51a0ca9079ca 2460 for(int i=0; i<sizeof(s); i++) {
arsenalist 8:51a0ca9079ca 2461 s[i]=0; }
arsenalist 8:51a0ca9079ca 2462 sprintf(s,"GET http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist 8:51a0ca9079ca 2463 } else {
arsenalist 8:51a0ca9079ca 2464 connHost = EMMA_SERVER_HOST;
arsenalist 8:51a0ca9079ca 2465 connPort = EMMA_SERVER_PORT;
arsenalist 8:51a0ca9079ca 2466 for(int i=0; i<sizeof(s); i++) {
arsenalist 8:51a0ca9079ca 2467 s[i]=0; }
arsenalist 8:51a0ca9079ca 2468 strcpy(s,"GET /emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist 8:51a0ca9079ca 2469 }
arsenalist 8:51a0ca9079ca 2470
arsenalist 8:51a0ca9079ca 2471 t.start();
arsenalist 8:51a0ca9079ca 2472 while(1) {
arsenalist 8:51a0ca9079ca 2473 str = ethGET(connHost,connPort,s);
arsenalist 8:51a0ca9079ca 2474 if(str.find("OK") != std::string::npos) {
arsenalist 8:51a0ca9079ca 2475 t.stop();
arsenalist 8:51a0ca9079ca 2476 ethConnected = true;
arsenalist 8:51a0ca9079ca 2477 break;
arsenalist 8:51a0ca9079ca 2478 }
arsenalist 8:51a0ca9079ca 2479 if(t.read_ms() > 5000) {
arsenalist 8:51a0ca9079ca 2480 t.stop();
arsenalist 8:51a0ca9079ca 2481 ethConnected = false;
arsenalist 8:51a0ca9079ca 2482 break;
arsenalist 8:51a0ca9079ca 2483 }
arsenalist 8:51a0ca9079ca 2484 }
arsenalist 8:51a0ca9079ca 2485 } else {
arsenalist 8:51a0ca9079ca 2486 ethConnected = false;
arsenalist 8:51a0ca9079ca 2487 }
arsenalist 8:51a0ca9079ca 2488 }
arsenalist 8:51a0ca9079ca 2489
arsenalist 8:51a0ca9079ca 2490 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 2491 char s[512];
arsenalist 8:51a0ca9079ca 2492 int connPort;
arsenalist 8:51a0ca9079ca 2493 string connHost;
arsenalist 8:51a0ca9079ca 2494 string str;
arsenalist 8:51a0ca9079ca 2495 Timer t;
arsenalist 8:51a0ca9079ca 2496
arsenalist 29:4d94a03d38e0 2497 /*
arsenalist 27:562a95c120cc 2498 esp.enable();
arsenalist 27:562a95c120cc 2499 wait(1);
arsenalist 27:562a95c120cc 2500 esp.reset();
arsenalist 27:562a95c120cc 2501 wait(1);
arsenalist 27:562a95c120cc 2502 while(!esp.ready());
arsenalist 27:562a95c120cc 2503
arsenalist 27:562a95c120cc 2504 //rest begin
arsenalist 27:562a95c120cc 2505 if(!rest.begin(EMMA_SERVER_HOST,EMMA_SERVER_PORT,false)) {
arsenalist 27:562a95c120cc 2506 DBG.printf("EMMA: fail to setup rest\r\n");
arsenalist 27:562a95c120cc 2507 TFT.locate(0,20);
arsenalist 27:562a95c120cc 2508 TFT.printf("EMMA: fail to setup rest");
arsenalist 27:562a95c120cc 2509 while(1);
arsenalist 27:562a95c120cc 2510 }
arsenalist 27:562a95c120cc 2511
arsenalist 27:562a95c120cc 2512 //setup wifi
arsenalist 27:562a95c120cc 2513 DBG.printf("EMMA: setup wifi\r\n");
arsenalist 27:562a95c120cc 2514 TFT.locate(0,20);
arsenalist 27:562a95c120cc 2515 TFT.printf("EMMA: setup wifi");
arsenalist 27:562a95c120cc 2516 wait(1);
arsenalist 27:562a95c120cc 2517 esp.wifiCb.attach(&wifiCb);
arsenalist 28:7561035e3df5 2518 //esp.wifiConnect("Tritronik Mobile","Tri12@11");
arsenalist 28:7561035e3df5 2519 esp.wifiConnect(wifiSSID.c_str(),wifiPASS.c_str());
arsenalist 27:562a95c120cc 2520 DBG.printf("EMMA: system started\r\n");
arsenalist 27:562a95c120cc 2521 TFT.locate(0,20);
arsenalist 27:562a95c120cc 2522 TFT.printf("EMMA: system started");
arsenalist 27:562a95c120cc 2523 t.start();
arsenalist 28:7561035e3df5 2524 while(t.read() < 20);
arsenalist 27:562a95c120cc 2525 t.stop();
arsenalist 27:562a95c120cc 2526 t.reset();
arsenalist 28:7561035e3df5 2527 TFT.locate(0,20);
arsenalist 28:7561035e3df5 2528 TFT.printf(" ");
arsenalist 29:4d94a03d38e0 2529 */
arsenalist 27:562a95c120cc 2530
arsenalist 8:51a0ca9079ca 2531 if(wifiAvailable) {
arsenalist 8:51a0ca9079ca 2532 _ESP.printf("MODE=B");
arsenalist 8:51a0ca9079ca 2533 if(useProxy) {
arsenalist 8:51a0ca9079ca 2534 connHost = proxySERVER;
arsenalist 8:51a0ca9079ca 2535 sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist 8:51a0ca9079ca 2536 for(int i=0; i<sizeof(s); i++) {
arsenalist 8:51a0ca9079ca 2537 s[i]=0; }
arsenalist 8:51a0ca9079ca 2538 sprintf(s,"http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist 8:51a0ca9079ca 2539 } else {
arsenalist 8:51a0ca9079ca 2540 connHost = EMMA_SERVER_HOST;
arsenalist 8:51a0ca9079ca 2541 connPort = EMMA_SERVER_PORT;
arsenalist 8:51a0ca9079ca 2542 for(int i=0; i<sizeof(s); i++) {
arsenalist 8:51a0ca9079ca 2543 s[i]=0; }
arsenalist 8:51a0ca9079ca 2544 sprintf(s,"/emma/api/controller/test");
arsenalist 8:51a0ca9079ca 2545 }
arsenalist 27:562a95c120cc 2546 wait(2);
arsenalist 8:51a0ca9079ca 2547 t.start();
arsenalist 28:7561035e3df5 2548 while(!esp.ready() && t.read() < 20);
arsenalist 8:51a0ca9079ca 2549 t.stop();
arsenalist 27:562a95c120cc 2550 t.reset();
arsenalist 8:51a0ca9079ca 2551 if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist 27:562a95c120cc 2552 DBG.printf("rest begin\r\n");
arsenalist 8:51a0ca9079ca 2553 esp.process();
arsenalist 8:51a0ca9079ca 2554 rest.get(s);
arsenalist 8:51a0ca9079ca 2555 for(int i=0; i<sizeof(s); i++) {
arsenalist 8:51a0ca9079ca 2556 s[i]=0; }
arsenalist 8:51a0ca9079ca 2557 rest.getResponse(s,sizeof(s));
arsenalist 8:51a0ca9079ca 2558 str = s;
arsenalist 27:562a95c120cc 2559 DBG.printf("response:%s\r\n",s);
arsenalist 8:51a0ca9079ca 2560 if(str.find("OK") != std::string::npos) {
arsenalist 8:51a0ca9079ca 2561 wifiConnected = true;
arsenalist 8:51a0ca9079ca 2562 }
arsenalist 8:51a0ca9079ca 2563 } else {
arsenalist 8:51a0ca9079ca 2564 wifiConnected = false;
arsenalist 8:51a0ca9079ca 2565 }
arsenalist 8:51a0ca9079ca 2566 } else {
arsenalist 8:51a0ca9079ca 2567 wifiConnected = false;
arsenalist 8:51a0ca9079ca 2568 }
arsenalist 8:51a0ca9079ca 2569 }
arsenalist 8:51a0ca9079ca 2570
arsenalist 8:51a0ca9079ca 2571 void isGprsConnected(void) {
arsenalist 8:51a0ca9079ca 2572
arsenalist 8:51a0ca9079ca 2573 }
arsenalist 0:f4e449fa34d7 2574
arsenalist 0:f4e449fa34d7 2575 void addChar(char *s, char c) {
arsenalist 0:f4e449fa34d7 2576 uint16_t k; //customized for EMS
arsenalist 0:f4e449fa34d7 2577 k = strlen(s);
arsenalist 0:f4e449fa34d7 2578 s[k] = c;
arsenalist 0:f4e449fa34d7 2579 s[k + 1] = 0;
arsenalist 0:f4e449fa34d7 2580 }
arsenalist 0:f4e449fa34d7 2581
arsenalist 0:f4e449fa34d7 2582 void rcvReply(char *r, int to) {
arsenalist 0:f4e449fa34d7 2583 Timer t;
arsenalist 0:f4e449fa34d7 2584 bool ended = false;
arsenalist 0:f4e449fa34d7 2585 char c;
arsenalist 0:f4e449fa34d7 2586
arsenalist 0:f4e449fa34d7 2587 strcpy(r,"");
arsenalist 0:f4e449fa34d7 2588 t.start();
arsenalist 0:f4e449fa34d7 2589 while(!ended) {
arsenalist 0:f4e449fa34d7 2590 if(_ESP.readable()) {
arsenalist 0:f4e449fa34d7 2591 c = _ESP.getc();
arsenalist 0:f4e449fa34d7 2592 addChar(r,c);
arsenalist 0:f4e449fa34d7 2593 t.start();
arsenalist 0:f4e449fa34d7 2594 }
arsenalist 0:f4e449fa34d7 2595 if(t.read_ms() > to) {
arsenalist 0:f4e449fa34d7 2596 ended = true;
arsenalist 0:f4e449fa34d7 2597 }
arsenalist 0:f4e449fa34d7 2598 }
arsenalist 0:f4e449fa34d7 2599 addChar(r, 0x00);
arsenalist 0:f4e449fa34d7 2600 }
arsenalist 0:f4e449fa34d7 2601
arsenalist 0:f4e449fa34d7 2602 string calculateMD5(string text) {
arsenalist 0:f4e449fa34d7 2603 char s[64];
arsenalist 0:f4e449fa34d7 2604 memset(s,0,sizeof(s)); //for unknown reason, after reading UID, the 's' will contaion UID data
arsenalist 0:f4e449fa34d7 2605 uint8_t hash[16];
arsenalist 0:f4e449fa34d7 2606 MD5::computeHash(hash, (uint8_t*)text.c_str(), strlen(text.c_str()));
arsenalist 0:f4e449fa34d7 2607 for(int i=0; i<16; ++i) {
arsenalist 0:f4e449fa34d7 2608 sprintf(s,"%s%02x",s,hash[i]);
arsenalist 0:f4e449fa34d7 2609 }
arsenalist 0:f4e449fa34d7 2610 return s;
arsenalist 0:f4e449fa34d7 2611 }
arsenalist 0:f4e449fa34d7 2612
arsenalist 0:f4e449fa34d7 2613 bool writeFirmwareHexToChar(string value) {
arsenalist 0:f4e449fa34d7 2614 FILE *fp;
arsenalist 0:f4e449fa34d7 2615 char s[32];
arsenalist 0:f4e449fa34d7 2616 int number;
arsenalist 0:f4e449fa34d7 2617 string chunk;
arsenalist 0:f4e449fa34d7 2618
arsenalist 0:f4e449fa34d7 2619 sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist 0:f4e449fa34d7 2620 fp = fopen(s,"a");
arsenalist 0:f4e449fa34d7 2621 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2622 for(int ch=0; ch<value.size(); ch+=2) {
arsenalist 0:f4e449fa34d7 2623 chunk = value.substr(ch,2);
arsenalist 0:f4e449fa34d7 2624 sscanf(chunk.c_str(),"%x",&number);
arsenalist 0:f4e449fa34d7 2625 fprintf(fp,"%c",number);
arsenalist 0:f4e449fa34d7 2626 }
arsenalist 0:f4e449fa34d7 2627 fclose(fp);
arsenalist 30:08d290158fa7 2628 free(fp);
arsenalist 0:f4e449fa34d7 2629 return true;
arsenalist 0:f4e449fa34d7 2630 }
arsenalist 30:08d290158fa7 2631 fclose(fp);
arsenalist 30:08d290158fa7 2632 free(fp);
arsenalist 0:f4e449fa34d7 2633 return false;
arsenalist 0:f4e449fa34d7 2634 }
arsenalist 0:f4e449fa34d7 2635
arsenalist 0:f4e449fa34d7 2636 bool clearFirmware(void) {
arsenalist 0:f4e449fa34d7 2637 FILE *fp;
arsenalist 0:f4e449fa34d7 2638 char s[32];
arsenalist 0:f4e449fa34d7 2639
arsenalist 0:f4e449fa34d7 2640 sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist 0:f4e449fa34d7 2641 fp = fopen(s,"w");
arsenalist 0:f4e449fa34d7 2642 if(fp != NULL) {
arsenalist 0:f4e449fa34d7 2643 fprintf(fp,"");
arsenalist 0:f4e449fa34d7 2644 fclose(fp);
arsenalist 30:08d290158fa7 2645 free(fp);
arsenalist 0:f4e449fa34d7 2646 return true;
arsenalist 0:f4e449fa34d7 2647 }
arsenalist 30:08d290158fa7 2648 fclose(fp);
arsenalist 30:08d290158fa7 2649 free(fp);
arsenalist 0:f4e449fa34d7 2650 return false;
arsenalist 0:f4e449fa34d7 2651 }
arsenalist 27:562a95c120cc 2652
arsenalist 27:562a95c120cc 2653 bool writeLog(string logTime, string logData) {
arsenalist 27:562a95c120cc 2654 FILE *fp;
arsenalist 27:562a95c120cc 2655 char s[255];
arsenalist 27:562a95c120cc 2656 string logAll;
arsenalist 27:562a95c120cc 2657 logAll = logTime + "\t" + logData + "\r\n";
arsenalist 27:562a95c120cc 2658
arsenalist 27:562a95c120cc 2659 sprintf(s,"/sd/log.txt");
arsenalist 27:562a95c120cc 2660 fp = fopen(s,"a");
arsenalist 27:562a95c120cc 2661 if(fp != NULL) {
arsenalist 27:562a95c120cc 2662 fprintf(fp,logAll.c_str());
arsenalist 27:562a95c120cc 2663 fclose(fp);
arsenalist 30:08d290158fa7 2664 free(fp);
arsenalist 27:562a95c120cc 2665 return true;
arsenalist 27:562a95c120cc 2666 }
arsenalist 30:08d290158fa7 2667 fclose(fp);
arsenalist 30:08d290158fa7 2668 free(fp);
arsenalist 30:08d290158fa7 2669 return false;
arsenalist 30:08d290158fa7 2670 }
arsenalist 30:08d290158fa7 2671
arsenalist 30:08d290158fa7 2672 bool writeDbg(string dbgTime, string dbgData) {
arsenalist 30:08d290158fa7 2673 FILE *fp;
arsenalist 30:08d290158fa7 2674 char s[255];
arsenalist 30:08d290158fa7 2675 string dbgAll;
arsenalist 30:08d290158fa7 2676 dbgAll = dbgTime + "\t" + dbgData + "\r\n";
arsenalist 30:08d290158fa7 2677
arsenalist 30:08d290158fa7 2678 sprintf(s,"/sd/dbg.txt");
arsenalist 30:08d290158fa7 2679 fp = fopen(s,"a");
arsenalist 30:08d290158fa7 2680 if(fp != NULL) {
arsenalist 30:08d290158fa7 2681 fprintf(fp,dbgAll.c_str());
arsenalist 30:08d290158fa7 2682 fclose(fp);
arsenalist 30:08d290158fa7 2683 free(fp);
arsenalist 30:08d290158fa7 2684 return true;
arsenalist 30:08d290158fa7 2685 }
arsenalist 30:08d290158fa7 2686 fclose(fp);
arsenalist 30:08d290158fa7 2687 free(fp);
arsenalist 27:562a95c120cc 2688 return false;
arsenalist 27:562a95c120cc 2689 }
arsenalist 0:f4e449fa34d7 2690 /*end emma private function*/