thesis_project/ fw_esp8266
1
0
Fork 0
Code Issues Pull Requests Releases 1 Wiki Activity

changes to ntp update handling

This commit is contained in:
2EEEB 2020-02-15 21:15:44 +01:00
parent 0a0284e616
commit 29bf14e630
Signed by: 2EEEB
GPG Key ID: 8F12BD6D9D435DB2
1 changed files with 33 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
fw_esp8266.ino
View File

@ -3,6 +3,7 @@
#include "Adafruit_MQTT_Client.h"
#include <NTPClient.h>
#include <WiFiUdp.h>
//#include "time.h"
/************************* WiFi Settings *********************************/
@ -20,9 +21,9 @@
/***********************NTP settings*********************************/
//UTC offset in seconds, 3600 for UTC+1
#define UTC_OFFSET_S 3600
#define UTC_OFFSET_S 3600
//NTP server to use, pool is recommended
#define NTP_SERVER "europe.pool.ntp.org"
#define NTP_SERVER "europe.pool.ntp.org"
/************************* MQTT Setup ************************************/
@ -93,36 +94,38 @@ void loop() {
}
}
i = 0;
i = 0;
if(commRecvd == true){
if(strcmp("?ntp", incoming) == 0){ //if request for time update received, process time update
while(!timeClient.update()){ //update from ntp server
delay(10); //time sync is critical, wait for succesful update
};
Serial.print(">"); //indicate time data
Serial.print(timeClient.getYear());
Serial.print(",");
Serial.print(timeClient.getMonth());
Serial.print(",");
Serial.print(timeClient.getDate());
Serial.print(",");
Serial.print(timeClient.getHours());
Serial.print(",");
Serial.print(timeClient.getMinutes());
Serial.print(",");
Serial.print(timeClient.getSeconds());
Serial.print('\n');
delay(1000); //give time to process comm
} else {
Serial.print("esp: recvd: ");
Serial.println(incoming);
test.publish(incoming);
Serial.println("esp: sent data");
if(commRecvd == true){
if(strcmp("?ntp", incoming) == 0){ //if request for time update received, process time update
while(!timeClient.update()){ //update from ntp server
delay(10); //time sync is critical, wait for succesful update
Serial.print("\\");
};
commRecvd = false;
}
delay(100);;
Serial.print(">"); //indicate time data
delay(50);
Serial.print(timeClient.getYear());
Serial.print("/");
Serial.print(timeClient.getMonth());
Serial.print("/");
Serial.print(timeClient.getDate());
Serial.print("/");
Serial.print(timeClient.getHours());
Serial.print("/");
Serial.print(timeClient.getMinutes());
Serial.print("/");
Serial.print(timeClient.getSeconds());
Serial.print('\n');
delay(1000); //give time to process comm
} else {
Serial.print("esp: recvd: ");
Serial.println(incoming);
test.publish(incoming);
Serial.println("esp: sent data");
};
commRecvd = false;
}
delay(100);;
}
// Function to connect and reconnect as necessary to the MQTT server.