Compare commits
11 Commits
added_noti
...
master
Author | SHA1 | Date | |
---|---|---|---|
48ffc8d22c | |||
42eae6ec9c | |||
3a2aedb11a | |||
|
9350b6f77d | ||
|
f161e467bf | ||
d6292768a9 | |||
fe936941f1 | |||
|
56d7018812 | ||
38bc729b95 | |||
eeda3bea86 | |||
5a3612f6d8 |
5
.vscode/arduino.json
vendored
Normal file → Executable file
5
.vscode/arduino.json
vendored
Normal file → Executable file
@ -1,7 +1,6 @@
|
||||
{
|
||||
"board": "esp8266:esp8266:generic",
|
||||
"configuration": "CpuFrequency=160,FlashFreq=80,FlashMode=dio,UploadSpeed=115200,FlashSize=1M512,ResetMethod=ck,Debug=Disabled,DebugLevel=None____",
|
||||
"port": "/dev/ttyUSB0",
|
||||
"configuration": "xtal=80,vt=flash,exception=disabled,ssl=all,ResetMethod=ck,CrystalFreq=26,FlashFreq=40,FlashMode=qio,eesz=4M1M,led=2,sdk=nonosdk221,ip=lm2f,dbg=Disabled,lvl=None____,wipe=none,baud=921600",
|
||||
"sketch": "frontend.ino",
|
||||
"output": "Output"
|
||||
"port": "/dev/ttyUSB0"
|
||||
}
|
5
.vscode/settings.json
vendored
Normal file → Executable file
5
.vscode/settings.json
vendored
Normal file → Executable file
@ -1,3 +1,6 @@
|
||||
{
|
||||
"C_Cpp.intelliSenseEngineFallback": "Enabled"
|
||||
"C_Cpp.intelliSenseEngineFallback": "Enabled",
|
||||
"files.associations": {
|
||||
"*.inc": "cpp"
|
||||
}
|
||||
}
|
0
front.svg
Normal file → Executable file
0
front.svg
Normal file → Executable file
Before Width: | Height: | Size: 11 KiB After Width: | Height: | Size: 11 KiB |
456
frontend.ino
Normal file → Executable file
456
frontend.ino
Normal file → Executable file
@ -1,260 +1,123 @@
|
||||
#include <ESP8266WiFi.h>
|
||||
#include <WiFiClient.h>
|
||||
#include <ESP8266WebServer.h>
|
||||
#include <ESP8266mDNS.h>
|
||||
#include <NTPClient.h>
|
||||
#include <WiFiUdp.h>
|
||||
#include "SSD1306Brzo.h"
|
||||
#include <ArduinoJson.h>
|
||||
#include <FS.h>
|
||||
#include "wifi.h"
|
||||
#include "Adafruit_MQTT.h"
|
||||
#include "Adafruit_MQTT_Client.h"
|
||||
#include <ESP8266HTTPClient.h>
|
||||
|
||||
double inTemp,outTemp,pressure,humid;
|
||||
unsigned short int onTime = 5, offTime = 23, beepDelay = 60, lastNtp, lastBeep;
|
||||
bool mqttAvail;
|
||||
String inTemp,outTemp,pressure,humid;
|
||||
const unsigned short int onTime=6, offTime=23, beepDelay=60, timeOffset=3;
|
||||
short int lastBeep;
|
||||
const String httpAddr="http://meteo-front:1880";
|
||||
int alarms[10]={660,1260};
|
||||
int alarmDuration(6);
|
||||
int alarmStop(0);
|
||||
|
||||
WiFiUDP ntpUDP;
|
||||
NTPClient timeClient(ntpUDP);
|
||||
SSD1306Brzo display(0x3C, 4, 5); //oled display w/ address 0x3C with SDA on GPIO4 and SCL on GPIO5 //address == offset
|
||||
|
||||
WiFiClient client;
|
||||
ESP8266WebServer server(80);
|
||||
Adafruit_MQTT_Client mqtt(&client, "192.168.100.102", 1883);
|
||||
|
||||
Adafruit_MQTT_Subscribe pressureFeed = Adafruit_MQTT_Subscribe(&mqtt, "pressure");
|
||||
Adafruit_MQTT_Subscribe inFeed = Adafruit_MQTT_Subscribe(&mqtt, "bmpTemp");
|
||||
Adafruit_MQTT_Subscribe outFeed = Adafruit_MQTT_Subscribe(&mqtt, "externalTemp");
|
||||
Adafruit_MQTT_Subscribe humidFeed = Adafruit_MQTT_Subscribe(&mqtt, "humid");
|
||||
|
||||
void wifiConnect() {
|
||||
int beginMillis = millis();
|
||||
WiFi.begin(ssid, password);
|
||||
while (WiFi.status() != WL_CONNECTED && millis() - beginMillis < 30000) {
|
||||
delay(250);
|
||||
displayStatus(1);
|
||||
Serial.print(".");
|
||||
}
|
||||
if (WiFi.status() != WL_CONNECTED) {
|
||||
displayStatus(2);
|
||||
delay(10000);
|
||||
ESP.reset();
|
||||
} else {
|
||||
MDNS.begin("esp8266-frontend");
|
||||
Serial.print("Connected to " + String(ssid) + "; IP address: ");
|
||||
Serial.println(WiFi.localIP());
|
||||
displayStatus(0);
|
||||
}
|
||||
}
|
||||
SSD1306Brzo display(0x3C, 5, 4);
|
||||
void demo();
|
||||
void setup(){
|
||||
Serial.begin(115200);
|
||||
//==DISPLAY INIT==
|
||||
display.init();
|
||||
display.flipScreenVertically();
|
||||
display.setContrast(255);
|
||||
// display.invertDisplay();
|
||||
display.clear();
|
||||
display.fillRect(0,0,128,64);
|
||||
display.display();
|
||||
delay(3000);
|
||||
if (!digitalRead(0)) //button
|
||||
demo(120000);
|
||||
Serial.begin(115200);
|
||||
|
||||
//==WIFI CONNECT==
|
||||
WiFi.mode(WIFI_STA);
|
||||
wifiConnect();
|
||||
//==READ CONFIG==
|
||||
if (!SPIFFS.begin())
|
||||
SPIFFS.format();
|
||||
|
||||
if (!readConfig())
|
||||
defConfig();
|
||||
|
||||
//==NTP INIT==
|
||||
timeClient.begin();
|
||||
timeClient.setTimeOffset(10800);
|
||||
//MQTT
|
||||
pressureFeed.setCallback(pressureCall);
|
||||
inFeed.setCallback(inCall);
|
||||
outFeed.setCallback(outCall);
|
||||
humidFeed.setCallback(humidCall);
|
||||
mqtt.subscribe(&pressureFeed);
|
||||
mqtt.subscribe(&outFeed);
|
||||
mqtt.subscribe(&inFeed);
|
||||
mqtt.subscribe(&humidFeed);
|
||||
server.on("/edit", editConfig);
|
||||
server.begin();
|
||||
timeClient.setTimeOffset(timeOffset*3600);
|
||||
netTasks();
|
||||
}
|
||||
|
||||
void loop(){
|
||||
if (WiFi.status() != WL_CONNECTED) { //check wifi status
|
||||
wifiConnect();
|
||||
}
|
||||
server.handleClient();
|
||||
MQTT_connect();//check connection and get packets for 0.5s
|
||||
mqtt.processPackets(500);
|
||||
|
||||
mainScreen();//it could be cool and smooth if we could update screen independently, in some kind of separate thread or smthn similar
|
||||
|
||||
if ((timeClient.getHours()*60 + timeClient.getMinutes() - lastBeep > beepDelay)&&(!nightMode())){ //beep every $lastBeep
|
||||
mainScreen();
|
||||
if (((timeClient.getHours()*60 + timeClient.getMinutes()) % beepDelay == 0)&&(timeClient.getSeconds() < 1)&&(!nightMode())){
|
||||
tone(15,1000);
|
||||
delay(100);
|
||||
noTone(15);
|
||||
tone(15,1000);
|
||||
delay(100);
|
||||
noTone(15);
|
||||
lastBeep = timeClient.getHours()*60;
|
||||
netTasks();
|
||||
// demo(12000);
|
||||
}
|
||||
|
||||
updateNtp();//update time
|
||||
else {
|
||||
delay(500);
|
||||
}
|
||||
checkAlarm();
|
||||
}
|
||||
|
||||
//TODO
|
||||
//AT LEAST MAKE IT WORK (show ui and get data + ntp) - compiling - ... - WORKS!!11
|
||||
|
||||
//debug -> release
|
||||
//remove useless serial debug - DONE
|
||||
//show wifi info on oled - DONE
|
||||
//reset on not connected - DONE
|
||||
//check connectivity during work and do actions - DONE
|
||||
//beep hourly - DONE
|
||||
//github - oh yeahhh
|
||||
|
||||
//load config
|
||||
//webconfig (?) - in progress
|
||||
//mqtt update interval
|
||||
|
||||
//second screen
|
||||
|
||||
//reconfig wifi if not found (start webserver and AP)
|
||||
|
||||
//GRAPH
|
||||
/*
|
||||
get json from server
|
||||
~12 values
|
||||
hourly values + hourly display
|
||||
if pressure lowers then weather gonna be bad
|
||||
if pressure uppers then weather gonna be good
|
||||
*/
|
||||
|
||||
//CONFIG
|
||||
/*
|
||||
beep time
|
||||
on time
|
||||
off time
|
||||
mqtt update interval
|
||||
|
||||
*/
|
||||
|
||||
|
||||
//====================IN PROGRESS===================
|
||||
void editConfig(){
|
||||
if (server.args() > 0 ) {
|
||||
for ( uint8_t i = 0; i < server.args(); i++ ){
|
||||
String Argument_Name = server.argName(i);
|
||||
String client_response = server.arg(i);
|
||||
|
||||
if (Argument_Name == "beepDelay"){
|
||||
beepDelay = client_response.toInt();
|
||||
void checkAlarm()
|
||||
{
|
||||
for (int i(0);i<10;i++)
|
||||
{
|
||||
if ((timeClient.getHours()*60+timeClient.getMinutes() >= alarms[i])&&(timeClient.getHours()*60+timeClient.getMinutes() - alarms[i] < alarmDuration)&&(alarms[i] != 0))
|
||||
{
|
||||
if (alarmStop != alarms[i])
|
||||
{
|
||||
tone(15,1000);
|
||||
delay(100);
|
||||
noTone(15);
|
||||
delay(100);
|
||||
tone(15,1000);
|
||||
delay(100);
|
||||
noTone(15);
|
||||
delay(1000);
|
||||
}
|
||||
if (Argument_Name == "onTime"){
|
||||
onTime = client_response.toInt();
|
||||
}
|
||||
if (Argument_Name == "offTime"){
|
||||
offTime = client_response.toInt();
|
||||
}
|
||||
updateConfig();
|
||||
server.send(200, "text/plain", "updatedConfig");
|
||||
if (!digitalRead(0)) //button
|
||||
alarmStop = alarms[i];
|
||||
if (timeClient.getHours()*60+timeClient.getMinutes() - alarms[i] > alarmDuration)//stop current alarm
|
||||
alarmStop = -1;
|
||||
}
|
||||
} else {
|
||||
server.send(200, "text/plain", "to update config, goto " + String(WiFi.localIP()) + "/edit?parameter=value");
|
||||
}
|
||||
}
|
||||
|
||||
bool updateConfig() {
|
||||
StaticJsonBuffer<200> jsonBuffer;
|
||||
JsonObject& json = jsonBuffer.createObject();
|
||||
json["onTime"] = onTime;
|
||||
json["offTime"] = offTime;
|
||||
json["beepDelay"] = beepDelay;
|
||||
File configFile = SPIFFS.open("/config.json", "w");
|
||||
if (!configFile) {
|
||||
Serial.println("Failed to open config file for writing");
|
||||
return false;
|
||||
void netTasks() {
|
||||
HTTPClient http;
|
||||
WiFi.forceSleepWake();
|
||||
if (WiFi.status() != WL_CONNECTED) {
|
||||
wifiConnect(false);
|
||||
}
|
||||
http.begin(httpAddr+"/inTemp");
|
||||
if (http.GET() < 0)
|
||||
return;
|
||||
inTemp="i:"+http.getString()+"C";
|
||||
http.end();
|
||||
|
||||
json.printTo(configFile);
|
||||
return true;
|
||||
http.begin(httpAddr+"/outTemp");
|
||||
if (http.GET() < 0)
|
||||
return;
|
||||
outTemp="o:"+http.getString()+"C";
|
||||
http.end();
|
||||
|
||||
http.begin(httpAddr+"/humid");
|
||||
if (http.GET() < 0)
|
||||
return;
|
||||
humid="h:"+http.getString()+"%";
|
||||
http.end();
|
||||
|
||||
http.begin(httpAddr+"/pressure");
|
||||
if (http.GET() < 0)
|
||||
return;
|
||||
pressure="p:"+http.getString()+"mBar";
|
||||
http.end();
|
||||
|
||||
updateNtp();
|
||||
WiFi.disconnect();
|
||||
}
|
||||
|
||||
bool readConfig() {
|
||||
File configFile = SPIFFS.open("/config.json", "r");
|
||||
if (!configFile) {
|
||||
Serial.println("Failed to open config file");
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
size_t size = configFile.size();
|
||||
if (size > 1024) {
|
||||
Serial.println("Config file size is too large");
|
||||
return false;
|
||||
}
|
||||
|
||||
// Allocate a buffer to store contents of the file.
|
||||
std::unique_ptr<char[]> buf(new char[size]);
|
||||
|
||||
// We don't use String here because ArduinoJson library requires the input buffer to be mutable. If you don't use ArduinoJson, you may as well use configFile.readString instead.
|
||||
configFile.readBytes(buf.get(), size);
|
||||
|
||||
StaticJsonBuffer<200> jsonBuffer;
|
||||
JsonObject& json = jsonBuffer.parseObject(buf.get());
|
||||
|
||||
if (!json.success()) {
|
||||
Serial.println("Failed to parse config file");
|
||||
return false;
|
||||
}
|
||||
|
||||
offTime = int(json["offTime"]);
|
||||
onTime = int(json["onTime"]);
|
||||
beepDelay = int(json["beepDelay"]);
|
||||
return true;
|
||||
|
||||
}
|
||||
bool defConfig() {
|
||||
StaticJsonBuffer<200> jsonBuffer;
|
||||
JsonObject& json = jsonBuffer.createObject();
|
||||
json["onTime"] = "6";
|
||||
json["offTime"] = "23";
|
||||
json["beepDelay"] = "60";
|
||||
File configFile = SPIFFS.open("/config.json", "w");
|
||||
if (!configFile) {
|
||||
Serial.println("Failed to open config file for writing");
|
||||
return false;
|
||||
}
|
||||
|
||||
json.printTo(configFile);
|
||||
return true;
|
||||
}
|
||||
|
||||
//====================paused===================
|
||||
|
||||
|
||||
// void secondDisplay() {
|
||||
// display.clear();
|
||||
// display.setFont(ArialMT_Plain_16);
|
||||
// display.setTextAlignment(TEXT_ALIGN_CENTER);
|
||||
// display.drawString(0, 30, timeClient.getFormattedTime());
|
||||
|
||||
// display.drawRect(0,18,128,53); //frame
|
||||
// /*
|
||||
// 128/12=10px
|
||||
// 128x32 resolution
|
||||
// 32-19=13px for graph
|
||||
// */
|
||||
// int x = 0;
|
||||
// for (int i=0;i<12;++i){
|
||||
// display.drawLine(x+i*10, y[x], x+i*10+10, y[x]);
|
||||
// }
|
||||
|
||||
// }
|
||||
|
||||
//===================WELL DONE=======================
|
||||
void mainScreen() {
|
||||
display.clear();
|
||||
|
||||
if (!nightMode()) { //turn off screen at night
|
||||
if (!nightMode()) {
|
||||
int x = (timeClient.getHours()*60+timeClient.getMinutes())/11;
|
||||
//Time
|
||||
display.setFont(ArialMT_Plain_24);
|
||||
@ -262,98 +125,99 @@ void mainScreen() {
|
||||
display.drawString(64, 22, timeClient.getFormattedTime());
|
||||
//progress bar
|
||||
display.drawLine(0,22,x,22);
|
||||
if (mqttAvail){ //do not show info if mqtt not available
|
||||
//external temp //top left
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
display.drawString(0, 0, "o:"+String(outTemp));
|
||||
//pressure //top right
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_RIGHT);
|
||||
display.drawString(128, 0, "p:"+String(pressure));
|
||||
//inside temp //bottom left
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
display.drawString(0, 53, "i:"+String(inTemp));
|
||||
//humid //bottom right
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_RIGHT);
|
||||
display.drawString(128, 53, "h:"+String(humid)+"%");
|
||||
}
|
||||
else {
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
display.drawString(0, 53, "mqtt unavailable");
|
||||
}
|
||||
}
|
||||
display.display();
|
||||
}
|
||||
|
||||
void displayStatus(int state){
|
||||
display.clear();
|
||||
if (state == 0) {
|
||||
display.setFont(ArialMT_Plain_16);
|
||||
display.setTextAlignment(TEXT_ALIGN_CENTER);
|
||||
display.drawString(64, 22, "Connected!");
|
||||
|
||||
}
|
||||
if (state == 1) {
|
||||
display.setFont(ArialMT_Plain_16);
|
||||
display.setTextAlignment(TEXT_ALIGN_CENTER);
|
||||
display.drawString(64, 22, "Connecting...");
|
||||
}
|
||||
if (state == 2) {
|
||||
display.setFont(ArialMT_Plain_16);
|
||||
display.setTextAlignment(TEXT_ALIGN_CENTER);
|
||||
display.drawString(64, 22, "Not connected!");
|
||||
// external temp //top left
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
display.drawString(0, 53, "we will die in 10s! :0");
|
||||
display.drawString(0, 0, outTemp);
|
||||
//pressure //top right
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_RIGHT);
|
||||
display.drawString(128, 0, pressure);
|
||||
//inside temp //bottom left
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
display.drawString(0, 53, inTemp);
|
||||
//humid //bottom right
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_RIGHT);
|
||||
display.drawString(128, 53, humid);
|
||||
}
|
||||
display.display();
|
||||
}
|
||||
void displayStatus(){
|
||||
bool run(true);
|
||||
display.setFont(ArialMT_Plain_10);
|
||||
display.setTextAlignment(TEXT_ALIGN_LEFT);
|
||||
int x(0),y(0);
|
||||
bool xd(false);//false - right, true - left
|
||||
|
||||
while (run)
|
||||
{
|
||||
display.clear();
|
||||
if (WiFi.status() != WL_CONNECTED) {
|
||||
display.fillRect(x,y,30,50);
|
||||
if (x > 128-30)
|
||||
xd = true;
|
||||
if (x < 0)
|
||||
xd = false;
|
||||
if (xd) {
|
||||
x--;
|
||||
} else {
|
||||
x++;
|
||||
}
|
||||
|
||||
display.drawString(1, 52, ssid);
|
||||
|
||||
void MQTT_connect() {
|
||||
if (mqtt.connected()) {
|
||||
return;
|
||||
}
|
||||
int8_t ret;
|
||||
uint8_t retries = 3;
|
||||
while ((ret = mqtt.connect()) != 0) {
|
||||
displayStatus(3);
|
||||
mqtt.disconnect();
|
||||
delay(5000);
|
||||
retries--;
|
||||
if (retries == 0) {
|
||||
mqttAvail = false;
|
||||
}
|
||||
if (WiFi.status() == WL_CONNECTED) {
|
||||
run = false;
|
||||
}
|
||||
display.display();
|
||||
}
|
||||
if (mqtt.connected())
|
||||
mqttAvail = true;
|
||||
}
|
||||
void pressureCall(double x) {
|
||||
pressure = x;
|
||||
}
|
||||
void inCall(double x) {
|
||||
inTemp = x;
|
||||
}
|
||||
void outCall(double x) {
|
||||
outTemp = x;
|
||||
}
|
||||
void humidCall(double x){
|
||||
humid = x;
|
||||
|
||||
}
|
||||
void updateNtp() {
|
||||
if (lastNtp != timeClient.getHours()) {
|
||||
if (timeClient.update())
|
||||
lastNtp = timeClient.getHours();
|
||||
}
|
||||
while (!timeClient.update())
|
||||
Serial.println(timeClient.getHours());
|
||||
}
|
||||
bool nightMode() {
|
||||
if ((timeClient.getHours() > offTime)||(timeClient.getHours() < onTime)) { //turn off screen between loaded time
|
||||
if ((timeClient.getHours() > offTime)||(timeClient.getHours() < onTime)) {
|
||||
return true;
|
||||
}
|
||||
else
|
||||
return false;
|
||||
}
|
||||
void wifiConnect(bool boot) {
|
||||
int beginMillis = millis();
|
||||
WiFi.begin(ssid, password);
|
||||
displayStatus();
|
||||
}
|
||||
|
||||
|
||||
void demo(int duration)
|
||||
{
|
||||
short xp(0),yp(0),xd(1),yd(1);
|
||||
unsigned int startTime = millis();
|
||||
bool run(true);
|
||||
while (run) {
|
||||
if ((xp > 128) || (xp < 0))
|
||||
{
|
||||
xd = xd * -1;
|
||||
}
|
||||
if ((yp > 64) || (yp < 0))
|
||||
{
|
||||
yd = yd * -1;
|
||||
}
|
||||
xp+=xd;
|
||||
yp+=yd;
|
||||
|
||||
delay(10);
|
||||
display.clear();
|
||||
display.fillCircle(xp,yp,10);
|
||||
display.display();
|
||||
|
||||
if (millis() - startTime > duration)
|
||||
run = false;
|
||||
}
|
||||
|
||||
}
|
7
wifi.templ.h
Executable file
7
wifi.templ.h
Executable file
@ -0,0 +1,7 @@
|
||||
#ifndef ssid_pass_h
|
||||
#define ssid_pass_h
|
||||
|
||||
const char* ssid = "";
|
||||
const char* password = "";
|
||||
|
||||
#endif
|
Loading…
Reference in New Issue
Block a user