iotmanager/IoTManager
1
0
Fork 0
mirror of https://github.com/IoTManagerProject/IoTManager.git synced 2026-03-28 07:02:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

добавил wifi версия которая компилируется

Browse Source
This commit is contained in:
Dmitry Borisenko
2021-12-22 23:33:47 +01:00
parent 5f605a8e7c
commit 0262fa985b
198 changed files with 1043 additions and 15417 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
src/EspFileSystem.cpp
View File

@@ -8,68 +8,3 @@ bool fileSystemInit() {
SerialPrint(F("i"), F("FS"), F("Init completed"));
return true;
}
File seekFile(const String& filename, size_t position) {
String path = filepath(filename);
auto file = FileFS.open(path, "r");
if (!file) {
SerialPrint(F("E"), F("FS"), F("seek file error"));
}
file.seek(position, SeekSet);
return file;
}
const String writeFile(const String& filename, const String& str) {
String path = filepath(filename);
auto file = FileFS.open(path, "w");
if (!file) {
return "failed";
}
file.print(str);
file.close();
return "sucсess";
}
const String readFile(const String& filename, size_t max_size) {
String path = filepath(filename);
auto file = FileFS.open(path, "r");
if (!file) {
return "failed";
}
size_t size = file.size();
if (size > max_size) {
file.close();
return "large";
}
String temp = file.readString();
file.close();
return temp;
}
const String filepath(const String& filename) {
return filename.startsWith("/") ? filename : "/" + filename;
}
bool cutFile(const String& src, const String& dst) {
String srcPath = filepath(src);
String dstPath = filepath(dst);
SerialPrint(F("i"), F("FS"), "cut " + srcPath + " to " + dstPath);
if (!FileFS.exists(srcPath)) {
SerialPrint(F("E"), F("FS"), "not exist: " + srcPath);
return false;
}
if (FileFS.exists(dstPath)) {
FileFS.remove(dstPath);
}
auto srcFile = FileFS.open(srcPath, "r");
auto dstFile = FileFS.open(dstPath, "w");
uint8_t buf[512];
while (srcFile.available()) {
size_t len = srcFile.read(buf, 512);
dstFile.write(buf, len);
}
srcFile.close();
dstFile.close();
FileFS.remove(srcPath);
return true;
}

9
src/Global.cpp Normal file
View File

@@ -0,0 +1,9 @@
#include "Global.h"
//глобальные объекты классов
TickerScheduler ts(MYTEST + 1);
//глобальные переменные
String settingsFlashJson = "{}"; //переменная в которой хранятся все настройки, синхронизированна с flash памятью
String paramsFlashJson = "{}"; //переменная в которой хранятся все параметры, синхронизированна с flash памятью
String paramsHeapJson = "{}"; //переменная в которой хранятся все параметры, находится в оперативной памяти только

213
src/WebServer.cpp Normal file
View File

@@ -0,0 +1,213 @@
//
//
//
// AsyncWebSocket ws("/ws");
// AsyncEventSource events("/events");
//
//
//
//
//
// void init() {
// String login = jsonReadStr(settingsFlashJson, "weblogin");
// String pass = jsonReadStr(settingsFlashJson, "webpass");
//#ifdef ESP32
// server.addHandler(new FSEditor(FileFS, login, pass));
//#else
// server.addHandler(new FSEditor(login, pass));
//#endif
//
// server.serveStatic("/css/", FileFS, "/css/").setCacheControl("max-age=600");
// server.serveStatic("/js/", FileFS, "/js/").setCacheControl("max-age=600");
// server.serveStatic("/favicon.ico", FileFS, "/favicon.ico").setCacheControl("max-age=600");
// server.serveStatic("/icon.jpeg", FileFS, "/icon.jpeg").setCacheControl("max-age=600");
// server.serveStatic("/edit", FileFS, "/edit").setCacheControl("max-age=600");
//
//#ifdef svelte
// server.serveStatic("/", FileFS, "/").setDefaultFile("index.html").setAuthentication(login.c_str(), pass.c_str());
//#else
// server.serveStatic("/", FileFS, "/").setDefaultFile("index.htm").setAuthentication(login.c_str(), pass.c_str());
//#endif
//
// server.onNotFound([](AsyncWebServerRequest *request) {
// SerialPrint("[E]", "WebServer", "not found:\n" + getRequestInfo(request));
// request->send(404);
// });
//
// server.onFileUpload([](AsyncWebServerRequest *request, const String &filename, size_t index, uint8_t *data, size_t len, bool final) {
// // TODO
// if (!index) {
// SerialPrint("I", "WebServer", "start upload " + filename);
// }
// if (final) {
// SerialPrint("I", "WebServer", "finish upload: " + prettyBytes(index + len));
// }
// });
//
// // динамические данные
// server.on("/config.live.json", HTTP_GET, [](AsyncWebServerRequest *request) {
// request->send(200, "application/json", configLiveJson);
// });
//
// server.on("/config.store.json", HTTP_GET, [](AsyncWebServerRequest *request) {
// request->send(200, "application/json", paramsFlashJson);
// });
//
// // данные не являющиеся событиями
// server.on("/config.option.json", HTTP_GET, [](AsyncWebServerRequest *request) {
// request->send(200, "application/json", paramsHeapJson);
// });
//
// // для хранения постоянных данных
// server.on("/config.setup.json", HTTP_GET, [](AsyncWebServerRequest *request) {
// request->send(200, "application/json", settingsFlashJson);
// });
//
// server.on("/cmd", HTTP_GET, [](AsyncWebServerRequest *request) {
// String cmdStr = request->getParam("command")->value();
// SerialPrint("I", "WebServer", "do: " + cmdStr);
// loopCmdAdd(cmdStr);
// request->send(200, "text/html", "OK");
// });
//
// server.begin();
//
// initOta();
// initMDNS();
// initWS();
//
// SerialPrint("I", F("HTTP"), F("HttpServer Init"));
//}
//
// void onWsEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len) {
//#ifdef WEBSOCKET_ENABLED
// if (type == WS_EVT_CONNECT) {
// SerialPrint("I", F("WS"), F("CONNECTED"));
// Serial.printf("ws[%s][%u] connect\n", server->url(), client->id());
// // client->printf(json.c_str(), client->id());
// // client->ping();
// } else if (type == WS_EVT_DISCONNECT) {
// Serial.printf("ws[%s][%u] disconnect\n", server->url(), client->id());
// } else if (type == WS_EVT_ERROR) {
// Serial.printf("ws[%s][%u] error(%u): %s\n", server->url(), client->id(), *((uint16_t *)arg), (char *)data);
// } else if (type == WS_EVT_PONG) {
// Serial.printf("ws[%s][%u] pong[%u]: %s\n", server->url(), client->id(), len, (len) ? (char *)data : "");
// } else if (type == WS_EVT_DATA) {
// AwsFrameInfo *info = (AwsFrameInfo *)arg;
// String msg = "";
// if (info->final && info->index == 0 && info->len == len) {
// // the whole message is in a single frame and we got all of it's data
// Serial.printf("ws[%s][%u] %s-message[%llu]: ", server->url(), client->id(), (info->opcode == WS_TEXT) ? "text" : "binary", info->len);
//
// if (info->opcode == WS_TEXT) {
// for (size_t i = 0; i < info->len; i++) {
// msg += (char)data[i];
// }
// } else {
// char buff[3];
// for (size_t i = 0; i < info->len; i++) {
// sprintf(buff, "%02x ", (uint8_t)data[i]);
// msg += buff;
// }
// }
// Serial.printf("%s\n", msg.c_str());
//
// if (msg.startsWith("HELLO")) {
// SerialPrint("I", F("WS"), F("Full update"));
// // publishWidgetsWS();
// // publishStateWS();
// // choose_log_date_and_send(); // функцию выгрузки архива с графиком я не сделал. Забираю при выгрузке по MQTT
// }
//
// if (info->opcode == WS_TEXT)
// client->text("{}");
// else
// client->binary("{}");
// } else {
// // message is comprised of multiple frames or the frame is split into multiple packets
// if (info->index == 0) {
// if (info->num == 0)
// Serial.printf("ws[%s][%u] %s-message start\n", server->url(), client->id(), (info->message_opcode == WS_TEXT) ? "text" : "binary");
// Serial.printf("ws[%s][%u] frame[%u] start[%llu]\n", server->url(), client->id(), info->num, info->len);
// }
//
// Serial.printf("ws[%s][%u] frame[%u] %s[%llu - %llu]: ", server->url(), client->id(), info->num, (info->message_opcode == WS_TEXT) ? "text" : "binary", info->index, info->index + len);
//
// if (info->opcode == WS_TEXT) {
// for (size_t i = 0; i < len; i++) {
// msg += (char)data[i];
// }
// } else {
// char buff[3];
// for (size_t i = 0; i < len; i++) {
// sprintf(buff, "%02x ", (uint8_t)data[i]);
// msg += buff;
// }
// }
// Serial.printf("%s\n", msg.c_str());
//
// if ((info->index + len) == info->len) {
// Serial.printf("ws[%s][%u] frame[%u] end[%llu]\n", server->url(), client->id(), info->num, info->len);
// if (info->final) {
// Serial.printf("ws[%s][%u] %s-message end\n", server->url(), client->id(), (info->message_opcode == WS_TEXT) ? "text" : "binary");
// if (info->message_opcode == WS_TEXT)
// client->text("I got your text message");
// else
// client->binary("I got your binary message");
// }
// }
// }
// }
//#endif
// ;
//}
//
// void initMDNS() {
//#ifdef MDNS_ENABLED
// MDNS.addService("http", "tcp", 80);
// // TODO Add Adduino OTA
//#endif
// ;
//}
//
// void initOta() {
//#ifdef OTA_UPDATES_ENABLED
// ArduinoOTA.onStart([]() {
// events.send("Update Start", "ota");
// });
// ArduinoOTA.onEnd([]() {
// events.send("Update End", "ota");
// });
// ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
// char p[32];
// sprintf(p, "Progress: %u%%\n", (progress / (total / 100)));
// events.send(p, "ota");
// });
// ArduinoOTA.onError([](ota_error_t error) {
// if (error == OTA_AUTH_ERROR)
// events.send("Auth Failed", "ota");
// else if (error == OTA_BEGIN_ERROR)
// events.send("Begin Failed", "ota");
// else if (error == OTA_CONNECT_ERROR)
// events.send("Connect Failed", "ota");
// else if (error == OTA_RECEIVE_ERROR)
// events.send("Recieve Failed", "ota");
// else if (error == OTA_END_ERROR)
// events.send("End Failed", "ota");
// });
// ArduinoOTA.setHostname(hostName);
// ArduinoOTA.begin();
//#endif
// ;
//}
//
// void initWS() {
//#ifdef WEBSOCKET_ENABLED
// ws.onEvent(onWsEvent);
// server.addHandler(&ws);
// events.onConnect([](AsyncEventSourceClient *client) {
// client->send("", NULL, millis(), 1000);
// });
// server.addHandler(&events);
//#endif
//}

3
src/main.cpp
View File

@@ -9,7 +9,8 @@ void setup() {
//инициализация файловой системы
fileSystemInit();
//выводим остаток оперативной памяти после старта (пустой код без wifi остаток = 50.28 kB)
//выводим остаток оперативной памяти после старта
// 22.12.21 пустой код без wifi остаток = 50.28 kB
SerialPrint(F("i"), F("HEAP"), prettyBytes(ESP.getFreeHeap()));
}

66
src/utils/FileUtils.cpp Normal file
View File

@@ -0,0 +1,66 @@
#include "Utils/FileUtils.h"
File seekFile(const String& filename, size_t position) {
String path = filepath(filename);
auto file = FileFS.open(path, "r");
if (!file) {
SerialPrint(F("E"), F("FS"), F("seek file error"));
}
file.seek(position, SeekSet);
return file;
}
const String writeFile(const String& filename, const String& str) {
String path = filepath(filename);
auto file = FileFS.open(path, "w");
if (!file) {
return "failed";
}
file.print(str);
file.close();
return "sucсess";
}
const String readFile(const String& filename, size_t max_size) {
String path = filepath(filename);
auto file = FileFS.open(path, "r");
if (!file) {
return "failed";
}
size_t size = file.size();
if (size > max_size) {
file.close();
return "large";
}
String temp = file.readString();
file.close();
return temp;
}
const String filepath(const String& filename) {
return filename.startsWith("/") ? filename : "/" + filename;
}
bool cutFile(const String& src, const String& dst) {
String srcPath = filepath(src);
String dstPath = filepath(dst);
SerialPrint(F("i"), F("FS"), "cut " + srcPath + " to " + dstPath);
if (!FileFS.exists(srcPath)) {
SerialPrint(F("E"), F("FS"), "not exist: " + srcPath);
return false;
}
if (FileFS.exists(dstPath)) {
FileFS.remove(dstPath);
}
auto srcFile = FileFS.open(srcPath, "r");
auto dstFile = FileFS.open(dstPath, "w");
uint8_t buf[512];
while (srcFile.available()) {
size_t len = srcFile.read(buf, 512);
dstFile.write(buf, len);
}
srcFile.close();
dstFile.close();
FileFS.remove(srcPath);
return true;
}

176
src/utils/JsonUtils.cpp Normal file
View File

@@ -0,0 +1,176 @@
#include "Utils/JsonUtils.h"
#include "Utils/FileUtils.h"
// depricated======================================================================
String jsonReadStr(String& json, String name) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonRead"), error.f_str());
return doc[name].as<String>();
}
boolean jsonReadBool(String& json, String name) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonRead"), error.f_str());
return doc[name].as<bool>();
}
int jsonReadInt(String& json, String name) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonRead"), error.f_str());
return doc[name].as<int>();
}
// new==============================================================================
bool jsonRead(String& json, String key, String& value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonRead"), error.f_str());
ret = false;
} else if (!doc.containsKey(key)) {
SerialPrint("EE", F("jsonRead"), key + " missing");
ret = false;
}
value = doc[key].as<String>();
return ret;
}
bool jsonRead(String& json, String key, bool& value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonRead"), error.f_str());
ret = false;
} else if (!doc.containsKey(key)) {
SerialPrint("EE", F("jsonRead"), key + " missing");
ret = false;
}
value = doc[key].as<bool>();
return ret;
}
bool jsonRead(String& json, String key, int& value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonRead"), error.f_str());
ret = false;
} else if (!doc.containsKey(key)) {
SerialPrint("EE", F("jsonRead"), key + " missing");
ret = false;
}
value = doc[key].as<int>();
return ret;
}
// depricated========================================================================
String jsonWriteStr(String& json, String name, String value) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonWrite"), error.f_str());
doc[name] = value;
json = "";
serializeJson(doc, json);
return json;
}
String jsonWriteBool(String& json, String name, boolean value) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonWrite"), error.f_str());
doc[name] = value;
json = "";
serializeJson(doc, json);
return json;
}
String jsonWriteInt(String& json, String name, int value) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonWrite"), error.f_str());
doc[name] = value;
json = "";
serializeJson(doc, json);
return json;
}
String jsonWriteFloat(String& json, String name, float value) {
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) SerialPrint("EE", F("jsonWrite"), error.f_str());
doc[name] = value;
json = "";
serializeJson(doc, json);
return json;
}
// new==============================================================================
bool jsonWriteStr_(String& json, String key, String value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonWrite"), error.f_str());
ret = false;
}
doc[key] = value;
json = "";
serializeJson(doc, json);
return ret;
}
bool jsonWriteBool_(String& json, String key, bool value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonWrite"), error.f_str());
ret = false;
}
doc[key] = value;
json = "";
serializeJson(doc, json);
return ret;
}
bool jsonWriteInt_(String& json, String key, int value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonWrite"), error.f_str());
ret = false;
}
doc[key] = value;
json = "";
serializeJson(doc, json);
return ret;
}
bool jsonWriteFloat_(String& json, String key, float value) {
bool ret = true;
DynamicJsonDocument doc(JSON_BUFFER_SIZE);
DeserializationError error = deserializeJson(doc, json);
if (error) {
SerialPrint("EE", F("jsonWrite"), error.f_str());
ret = false;
}
doc[key] = value;
json = "";
serializeJson(doc, json);
return ret;
}
//=================================================================================
void saveConfig() {
writeFile(String("config.json"), settingsFlashJson);
}
void saveStore() {
writeFile(String("store.json"), paramsFlashJson);
}

170
src/utils/WiFiUtils.cpp Normal file
View File

@@ -0,0 +1,170 @@
#include "Utils/WiFiUtils.h"
void routerConnect() {
WiFi.setAutoConnect(false);
WiFi.persistent(false);
WiFi.mode(WIFI_STA);
byte tries = 40;
String _ssid = jsonReadStr(settingsFlashJson, "routerssid");
String _password = jsonReadStr(settingsFlashJson, "routerpass");
if (_ssid == "" && _password == "") {
WiFi.begin();
} else {
WiFi.begin(_ssid.c_str(), _password.c_str());
#ifdef ESP32
WiFi.setTxPower(WIFI_POWER_19_5dBm);
#else
WiFi.setOutputPower(20.5);
#endif
SerialPrint("I", "WIFI", "ssid: " + _ssid);
SerialPrint("I", "WIFI", "pass: " + _password);
}
while (--tries && WiFi.status() != WL_CONNECTED) {
if (WiFi.status() == WL_CONNECT_FAILED) {
SerialPrint("E", "WIFI", "password is not correct");
tries = 1;
jsonWriteInt(paramsHeapJson, "pass_status", 1);
}
Serial.print(".");
delay(1000);
}
if (WiFi.status() != WL_CONNECTED) {
Serial.println("");
startAPMode();
} else {
Serial.println("");
SerialPrint("I", "WIFI", "http://" + WiFi.localIP().toString());
jsonWriteStr(settingsFlashJson, "ip", WiFi.localIP().toString());
//mqttInit();
}
SerialPrint("I", F("WIFI"), F("Network Init"));
}
bool startAPMode() {
SerialPrint("I", "WIFI", "AP Mode");
WiFi.disconnect();
WiFi.mode(WIFI_AP);
String _ssidAP = jsonReadStr(settingsFlashJson, "apssid");
String _passwordAP = jsonReadStr(settingsFlashJson, "appass");
WiFi.softAP(_ssidAP.c_str(), _passwordAP.c_str());
IPAddress myIP = WiFi.softAPIP();
SerialPrint("I", "WIFI", "AP IP: " + myIP.toString());
jsonWriteStr(settingsFlashJson, "ip", myIP.toString());
// if (jsonReadInt(paramsHeapJson, "pass_status") != 1) {
ts.add(
WIFI_SCAN, 10 * 1000, [&](void*) {
String sta_ssid = jsonReadStr(settingsFlashJson, "routerssid");
SerialPrint("I", "WIFI", "scanning for " + sta_ssid);
if (RouterFind(sta_ssid)) {
ts.remove(WIFI_SCAN);
WiFi.scanDelete();
routerConnect();
}
},
nullptr, true);
//}
return true;
}
boolean RouterFind(String ssid) {
bool res = false;
int n = WiFi.scanComplete();
SerialPrint("I", "WIFI", "scan result: " + String(n, DEC));
if (n == -2) { //Сканирование не было запущено, запускаем
SerialPrint("I", "WIFI", "start scanning");
WiFi.scanNetworks(true, false); // async, show_hidden
}
else if (n == -1) { //Сканирование все еще выполняется
SerialPrint("I", "WIFI", "scanning in progress");
}
else if (n == 0) { //ни одна сеть не найдена
SerialPrint("I", "WIFI", "no networks found");
WiFi.scanNetworks(true, false);
}
else if (n > 0) {
for (int8_t i = 0; i < n; i++) {
if (WiFi.SSID(i) == ssid) {
res = true;
}
SerialPrint("I", "WIFI", (res ? "*" : "") + String(i, DEC) + ") " + WiFi.SSID(i));
}
}
WiFi.scanDelete();
return res;
}
boolean isNetworkActive() {
return WiFi.status() == WL_CONNECTED;
}
uint8_t RSSIquality() {
uint8_t res = 0;
if (WiFi.status() == WL_CONNECTED) {
int rssi = WiFi.RSSI();
if (rssi >= -50) {
res = 6; //"Excellent";
} else if (rssi < -50 && rssi >= -60) {
res = 5; //"Very good";
} else if (rssi < -60 && rssi >= -70) {
res = 4; //"Good";
} else if (rssi < -70 && rssi >= -80) {
res = 3; //"Low";
} else if (rssi < -80 && rssi > -100) {
res = 2; //"Very low";
} else if (rssi <= -100) {
res = 1; //"No signal";
}
}
return res;
}
void wifiSignalInit() {
ts.add(
SYGNAL, 1000 * 60, [&](void*) {
//SerialPrint("I", "System", printMemoryStatus());
//getFSInfo();
switch (RSSIquality()) {
case 0:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='red'>не подключено к роутеру</font>"));
break;
case 1:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='red'>нет сигнала</font>"));
break;
case 2:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='red'>очень низкий</font>"));
break;
case 3:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='orange'>низкий</font>"));
break;
case 4:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='green'>хороший</font>"));
break;
case 5:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='green'>очень хороший</font>"));
break;
case 6:
jsonWriteStr(settingsFlashJson, F("signal"), F("Уровень WiFi сигнала: <font color='green'>отличный</font>"));
break;
}
},
nullptr, true);
}