mirror of
https://github.com/IoTManagerProject/IoTManager.git
synced 2026-03-26 14:12:16 +03:00
добавлено сохранение списка устройств, новый веб интерфейс
This commit is contained in:
Dmitry Borisenko
@@ -1,9 +1,13 @@
|
||||
#include "DeviceList.h"
|
||||
|
||||
// данная функция не записывает поле status из этого следует что поле равно false и поэтому весь список устройств отдаваемый мк
|
||||
// уходит со статусом для всех устройств - offline
|
||||
// приложение svelte хранит свой список и в нем поддерживает корректные статусы, а при получении этого списка
|
||||
// лишь изменяет в своем те элементы массива которые добавились новые, не трогая остальные
|
||||
const String getThisDevice() {
|
||||
String thisDevice = "{}";
|
||||
jsonWriteStr_(thisDevice, F("devicelist_"), ""); //метка для парсинга
|
||||
jsonWriteStr_(thisDevice, F("wg"), jsonReadStr(settingsFlashJson, F("wg"))); //рабочая группа
|
||||
// jsonWriteStr_(thisDevice, F("devicelist_"), ""); // метка для парсинга - она не нужна теперь
|
||||
jsonWriteStr_(thisDevice, F("wg"), jsonReadStr(settingsFlashJson, F("wg"))); // рабочая группа
|
||||
jsonWriteStr_(thisDevice, F("ip"), jsonReadStr(settingsFlashJson, F("ip")));
|
||||
jsonWriteStr_(thisDevice, F("id"), jsonReadStr(settingsFlashJson, F("id")));
|
||||
jsonWriteStr_(thisDevice, F("name"), jsonReadStr(settingsFlashJson, F("name")));
|
||||
@@ -12,54 +16,76 @@ const String getThisDevice() {
|
||||
}
|
||||
|
||||
void addThisDeviceToList() {
|
||||
devListHeapJson = getThisDevice();
|
||||
SerialPrint("i", "List", "Add this dev to list");
|
||||
if (jsonReadInt(settingsFlashJson, F("udps")) != 0) {
|
||||
// если включен автопоиск то записываем это устройство в оперативную память
|
||||
devListHeapJson = getThisDevice();
|
||||
} else {
|
||||
// если выключен автопоиск то записываем это устройство в флешь память
|
||||
// если файла не было никогда
|
||||
String list = readFile("/devlist.json", 2048);
|
||||
if (list == "failed") {
|
||||
writeFile("/devlist.json", getThisDevice());
|
||||
} else {
|
||||
// если файл был то перепишем в нем первое устройство - to do
|
||||
}
|
||||
}
|
||||
|
||||
SerialPrint("i", F("List"), F("This dev added to list"));
|
||||
}
|
||||
|
||||
#ifdef UDP_ENABLED
|
||||
AsyncUDP asyncUdp;
|
||||
|
||||
void asyncUdpInit() {
|
||||
if (asyncUdp.listenMulticast(IPAddress(239, 255, 255, 255), 4210)) {
|
||||
asyncUdp.onPacket([](AsyncUDPPacket packet) {
|
||||
// Serial.print("UDP Packet Type: ");
|
||||
// Serial.println(packet.isBroadcast() ? "Broadcast" : packet.isMulticast() ? "Multicast" : "Unicast");
|
||||
// Serial.print("From: ");
|
||||
// Serial.print(packet.remoteIP());
|
||||
// Serial.print(":");
|
||||
// Serial.println(packet.remotePort());
|
||||
// Serial.print("To: ");
|
||||
// Serial.print(packet.localIP());
|
||||
// Serial.print(":");
|
||||
// Serial.println(packet.localPort());
|
||||
// Serial.print(", Length: ");
|
||||
// Serial.print(packet.length());
|
||||
// Serial.print(", Data: ");
|
||||
// Serial.write(packet.data(), packet.length());
|
||||
|
||||
//String data = {packet.data(), packet.length()}; // для ESP32 подходит как замена uint8tToString, но 8266 не переваривает
|
||||
String data = uint8tToString(packet.data(), packet.length());
|
||||
String remoteWorkgroup = "";
|
||||
data.replace("[", "");
|
||||
data.replace("]", "");
|
||||
if (jsonRead(data, F("wg"), remoteWorkgroup)) { // проверяем чтоб полученный формат был Json и заодно вытягиваем имя группы
|
||||
String loacalWorkgroup = "";
|
||||
jsonRead(settingsFlashJson, F("wg"), loacalWorkgroup);
|
||||
if (remoteWorkgroup == loacalWorkgroup) {
|
||||
SerialPrint("i", F("UDP"), "IP: " + packet.remoteIP().toString() + ":" + String(packet.remotePort()));
|
||||
jsonMergeArrays(devListHeapJson, data);
|
||||
}
|
||||
} else {
|
||||
SerialPrint("E", F("UDP"), F("Udp packet invalid"));
|
||||
}
|
||||
// reply to the client
|
||||
// String ip = WiFi.localIP().toString();
|
||||
// asyncUdp.broadcastTo(ip.c_str(), packet.remotePort());
|
||||
// packet.printf(ip.c_str(), packet.length());
|
||||
});
|
||||
}
|
||||
void udpListningInit() {
|
||||
// если был включен автоматический поиск устройств
|
||||
if (jsonReadInt(settingsFlashJson, F("udps")) != 0) {
|
||||
if (asyncUdp.listenMulticast(IPAddress(239, 255, 255, 255), 4210)) {
|
||||
asyncUdp.onPacket([](AsyncUDPPacket packet) {
|
||||
// Serial.print("UDP Packet Type: ");
|
||||
// Serial.println(packet.isBroadcast() ? "Broadcast" : packet.isMulticast() ? "Multicast" : "Unicast");
|
||||
// Serial.print("From: ");
|
||||
// Serial.print(packet.remoteIP());
|
||||
// Serial.print(":");
|
||||
// Serial.println(packet.remotePort());
|
||||
// Serial.print("To: ");
|
||||
// Serial.print(packet.localIP());
|
||||
// Serial.print(":");
|
||||
// Serial.println(packet.localPort());
|
||||
// Serial.print(", Length: ");
|
||||
// Serial.print(packet.length());
|
||||
// Serial.print(", Data: ");
|
||||
// Serial.write(packet.data(), packet.length());
|
||||
|
||||
//будем отправлять каждые 60 секунд презентацию данного устройства
|
||||
// String data = {packet.data(), packet.length()}; // для ESP32 подходит как замена uint8tToString, но 8266 не переваривает
|
||||
String data = uint8tToString(packet.data(), packet.length());
|
||||
String remoteWorkgroup = "";
|
||||
data.replace("[", "");
|
||||
data.replace("]", "");
|
||||
if (jsonRead(data, F("wg"), remoteWorkgroup)) { // проверяем чтоб полученный формат был Json и заодно вытягиваем имя группы
|
||||
String loacalWorkgroup = "";
|
||||
jsonRead(settingsFlashJson, F("wg"), loacalWorkgroup);
|
||||
if (remoteWorkgroup == loacalWorkgroup) {
|
||||
SerialPrint("i", F("UDP"), "IP: " + packet.remoteIP().toString() + ":" + String(packet.remotePort()));
|
||||
jsonMergeArrays(devListHeapJson, data);
|
||||
}
|
||||
} else {
|
||||
SerialPrint("E", F("UDP"), F("Udp packet invalid"));
|
||||
}
|
||||
// reply to the client
|
||||
// String ip = WiFi.localIP().toString();
|
||||
// asyncUdp.broadcastTo(ip.c_str(), packet.remotePort());
|
||||
// packet.printf(ip.c_str(), packet.length());
|
||||
});
|
||||
}
|
||||
|
||||
SerialPrint("i", F("UDP"), F("Udp listning inited"));
|
||||
} else {
|
||||
devListHeapJson = "";
|
||||
}
|
||||
}
|
||||
|
||||
void udpBroadcastInit() {
|
||||
// будем отправлять каждые 60 секунд презентацию данного устройства
|
||||
ts.add(
|
||||
UDP, 60000, [&](void*) { // UDPP
|
||||
if (isNetworkActive()) {
|
||||
@@ -71,11 +97,11 @@ void asyncUdpInit() {
|
||||
},
|
||||
nullptr, true);
|
||||
|
||||
SerialPrint("i", F("UDP"), F("Udp Init"));
|
||||
SerialPrint("i", F("UDP"), F("Udp broadcast inited"));
|
||||
}
|
||||
|
||||
void jsonMergeArrays(String& existJson, String& incJson) {
|
||||
DynamicJsonDocument incJsonDoc(1024);
|
||||
DynamicJsonDocument incJsonDoc(4096);
|
||||
DeserializationError incJsonError = deserializeJson(incJsonDoc, incJson);
|
||||
// if (incJsonError) { // upd: devlist заведомо верный, зачем проверять еще раз?
|
||||
// SerialPrint("E", F("UDP"), "Invailed json in incomming udp packet " + String(incJsonError.f_str()));
|
||||
@@ -83,7 +109,7 @@ void jsonMergeArrays(String& existJson, String& incJson) {
|
||||
// return;
|
||||
// }
|
||||
|
||||
DynamicJsonDocument existJsonDoc(1024);
|
||||
DynamicJsonDocument existJsonDoc(4096);
|
||||
DeserializationError existJsonError = deserializeJson(existJsonDoc, existJson);
|
||||
// if (existJsonError) { // upd: полученный json уже проверен на целостность
|
||||
// SerialPrint("E", F("UDP"), "Invailed json in existing udp dev list " + String(incJsonError.f_str()));
|
||||
|
||||
Reference in New Issue
Block a user