iotmanager/IoTManager
1
0
Fork 0
mirror of https://github.com/IoTManagerProject/IoTManager.git synced 2026-03-30 20:09:14 +03:00
Code Issues Packages Projects Releases Wiki Activity

исправил баг удаления данных после отключения устройства

Browse Source
This commit is contained in:
Dmitry Borisenko
2022-09-01 12:54:03 +02:00
parent 00118c026d
commit 9ac0ab0b5a
3 changed files with 57 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
data_svelte/build/bundle.js
View File

File diff suppressed because one or more lines are too long

75
src/WsServer.cpp
View File

@@ -50,7 +50,11 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
SerialPrint("E", "WS " + String(num), "Package without header"); SerialPrint("E", "WS " + String(num), "Package without header");
} }
// Страница веб интерфейса dashboard=================================================================== //----------------------------------------------------------------------//
// Страница веб интерфейса dashboard
//----------------------------------------------------------------------//
//отвечаем данными на запрос страницы
if (headerStr == "/|") { if (headerStr == "/|") {
sendFileToWs("/layout.json", num, 1024); sendFileToWs("/layout.json", num, 1024);
String json = getParamsJson(); String json = getParamsJson();
@@ -62,8 +66,12 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
} }
} }
} }
// Страница веб интерфейса configutation================================================================
//========отправка=========================================================// //----------------------------------------------------------------------//
// Страница веб интерфейса configutation
//----------------------------------------------------------------------//
//отвечаем данными на запрос страницы
if (headerStr == "/config|") { if (headerStr == "/config|") {
sendFileToWs("/items.json", num, 1024); sendFileToWs("/items.json", num, 1024);
sendFileToWs("/widgets.json", num, 1024); sendFileToWs("/widgets.json", num, 1024);
@@ -71,7 +79,8 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
sendFileToWs("/scenario.json", num, 1024); sendFileToWs("/scenario.json", num, 1024);
standWebSocket.sendTXT(num, settingsFlashJson); standWebSocket.sendTXT(num, settingsFlashJson);
} }
//========сохранение=======================================================//
//обработка кнопки сохранить
if (headerStr == "/gifnoc|") { if (headerStr == "/gifnoc|") {
writeFileUint8tByFrames("config.json", payload, length, headerLenth, 256); writeFileUint8tByFrames("config.json", payload, length, headerLenth, 256);
} }
@@ -102,29 +111,29 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
IoTItems.push_back((IoTItem*)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}")); IoTItems.push_back((IoTItem*)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}"));
generateEvent("onStart", ""); generateEvent("onStart", "");
} }
// Страница веб интерфейса connection===================================================================
//========отправка========================================================// //----------------------------------------------------------------------//
// Страница веб интерфейса connection
//----------------------------------------------------------------------//
//отвечаем данными на запрос страницы
if (headerStr == "/connection|") { if (headerStr == "/connection|") {
standWebSocket.sendTXT(num, settingsFlashJson); standWebSocket.sendTXT(num, settingsFlashJson);
standWebSocket.sendTXT(num, ssidListHeapJson); standWebSocket.sendTXT(num, ssidListHeapJson);
standWebSocket.sendTXT(num, errorsHeapJson); standWebSocket.sendTXT(num, errorsHeapJson);
//запуск асинхронного сканирования wifi сетей при переходе на страницу соединений // запуск асинхронного сканирования wifi сетей при переходе на страницу соединений
// RouterFind(jsonReadStr(settingsFlashJson, F("routerssid"))); // RouterFind(jsonReadStr(settingsFlashJson, F("routerssid")));
} }
//========сохранение========================================================//
//обработка кнопки сохранить настройки wifi
if (headerStr == "/sgnittes|") { if (headerStr == "/sgnittes|") {
writeUint8tToString(payload, length, headerLenth, settingsFlashJson); writeUint8tToString(payload, length, headerLenth, settingsFlashJson);
writeFileUint8tByFrames("settings.json", payload, length, headerLenth, 256); writeFileUint8tByFrames("settings.json", payload, length, headerLenth, 256);
standWebSocket.sendTXT(num, errorsHeapJson); standWebSocket.sendTXT(num, errorsHeapJson);
addThisDeviceToList(); addThisDeviceToList();
} }
//========отправка========================================================//
if (headerStr == "/scan|") { //обработка кнопки сохранить настройки mqtt
//запуск асинхронного сканирования wifi сетей при нажатии выпадающего списка
RouterFind(jsonReadStr(settingsFlashJson, F("routerssid")));
standWebSocket.sendTXT(num, ssidListHeapJson);
}
//========сохранение========================================================//
if (headerStr == "/mqtt|") { if (headerStr == "/mqtt|") {
standWebSocket.sendTXT(num, settingsFlashJson); //отправляем в ответ новые полученные настройки standWebSocket.sendTXT(num, settingsFlashJson); //отправляем в ответ новые полученные настройки
handleMqttStatus(false, 8); //меняем статус на неопределенный handleMqttStatus(false, 8); //меняем статус на неопределенный
@@ -132,33 +141,51 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
standWebSocket.sendTXT(num, errorsHeapJson); //отправляем что статус неопределен standWebSocket.sendTXT(num, errorsHeapJson); //отправляем что статус неопределен
standWebSocket.sendTXT(num, ssidListHeapJson); standWebSocket.sendTXT(num, ssidListHeapJson);
} }
// Страница веб интерфейса list ==========================================================================
//========отправка========================================================// //запуск асинхронного сканирования wifi сетей при нажатии выпадающего списка
if (headerStr == "/scan|") {
RouterFind(jsonReadStr(settingsFlashJson, F("routerssid")));
standWebSocket.sendTXT(num, ssidListHeapJson);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса list
//----------------------------------------------------------------------//
//отвечаем данными на запрос страницы
if (headerStr == "/list|") { if (headerStr == "/list|") {
standWebSocket.sendTXT(num, devListHeapJson); standWebSocket.sendTXT(num, devListHeapJson);
} }
// траница веб интерфейса system =========================================================================
//========отправка========================================================// //----------------------------------------------------------------------//
// Страница веб интерфейса system
//----------------------------------------------------------------------//
//отвечаем данными на запрос страницы
if (headerStr == "/system|") { if (headerStr == "/system|") {
standWebSocket.sendTXT(num, errorsHeapJson); standWebSocket.sendTXT(num, errorsHeapJson);
standWebSocket.sendTXT(num, settingsFlashJson); standWebSocket.sendTXT(num, settingsFlashJson);
} }
//========сохранение========================================================//
//----------------------------------------------------------------------//
// отдельные команды веб интерфейса
//----------------------------------------------------------------------//
//переписать любое поле в errors json //переписать любое поле в errors json
if (headerStr == "/rorre|") { if (headerStr == "/rorre|") {
writeUint8tValueToJsonString(payload, length, headerLenth, errorsHeapJson); writeUint8tValueToJsonString(payload, length, headerLenth, errorsHeapJson);
} }
//Команды веб интерфейса ==============================================================================
//команда перезагрузки esp// //команда перезагрузки esp
if (headerStr == "/reboot|") { if (headerStr == "/reboot|") {
ESP.restart(); ESP.restart();
} }
//команда очистки всех логов esp// //команда очистки всех логов esp
if (headerStr == "/clean|") { if (headerStr == "/clean|") {
cleanLogs(); cleanLogs();
} }
//Прием сообщений cotrol ============================================================================== //Прием команд control c dashboard
if (headerStr == "/control|") { if (headerStr == "/control|") {
String msg; String msg;
writeUint8tToString(payload, length, headerLenth, msg); writeUint8tToString(payload, length, headerLenth, msg);

5
src/modules/virtual/Logging/Loging.cpp
View File

@@ -92,6 +92,11 @@ class Loging : public IoTItem {
} }
void sendChart(bool mqtt) { void sendChart(bool mqtt) {
//отправка графика может происходить только если время синхронизированно
if (!isTimeSynch) {
SerialPrint("E", F("Loging"), "'" + id + "' Сant send chart - time not synchronized");
return;
}
SerialPrint("i", F("Loging"), "'" + id + "'----------------------------"); SerialPrint("i", F("Loging"), "'" + id + "'----------------------------");
String reqUnixTimeStr = "27.08.2022"; //нужно получить эту дату из окна ввода под графиком. String reqUnixTimeStr = "27.08.2022"; //нужно получить эту дату из окна ввода под графиком.
unsigned long reqUnixTime = strDateToUnix(reqUnixTimeStr); unsigned long reqUnixTime = strDateToUnix(reqUnixTimeStr);