PB_emma_controller_mbed_src - emma controller code in production board v1

Emma » Code » 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@45:2406c2b6995a, 2015-08-26 (annotated)

Committer:: arsenalist
Date:: Wed Aug 26 10:00:39 2015 +0000
Revision:: 45:2406c2b6995a
Parent:: 44:c1d11c491237
Child:: 46:86a0c2133130

Get command ETH emmaModeOperation.

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Created:	25 Jul 2015
Imports:	4
Forks:	1
Commits:	65
Dependents:	0
Dependencies:	15
Followers:	6

This repository is Public (Unlisted).

The code in this repository is Apache licensed.

emmaCode.cpp@45:2406c2b6995a, 2015-08-26 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning