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

Корректируем работу сетевых сценариев

Browse Source 
отключаем скрытое создание элементов при приеме событий
Входящие события будут регистрироваться только при наличии
одноименного элемента в списке
This commit is contained in:
biver
2022-10-30 12:12:15 +03:00
parent 96c99ef5ac
commit d91ffc4e25
6 changed files with 61 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/MqttClient.cpp
View File

@@ -160,7 +160,6 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length) {
//здесь мы получаем события с других устройств, которые потом проверяются в сценариях этого устройства
else if (topicStr.indexOf("event") != -1) {
//пока не работает сетевой обмен этот код будет закомментирован
if (!jsonReadBool(settingsFlashJson, "mqttin")) {
return;
}
@@ -174,24 +173,24 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length) {
if (itemExist) {
unsigned long interval;
jsonRead(payloadStr, F("int"), interval);
itemExist->setInterval(interval);
itemExist->setValue(valAsStr, false);
itemExist->setInterval(interval); // устанавливаем такой же интервал как на источнике события
itemExist->setValue(valAsStr, false); // только регистрируем изменения в интерфейсе без создания цикла сетевых событий
if (interval) itemExist->setIntFromNet(interval+5); // если пришедший интервал =0, значит не нужно контролировать доверие, иначе даем фору в 5 сек
// запустим проверку его в сценариях
generateEvent(id, valAsStr);
SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + id + " " + valAsStr);
} else {
//добавим событие в базу
itemExist = (IoTItem*)new externalVariable(payloadStr);
IoTItems.push_back(itemExist);
// зафиксируем данные в базе, если локально элемент отсутствует
//itemExist = (IoTItem*)new externalVariable(payloadStr);
//IoTItems.push_back(itemExist);
}
//запустим проверку его в сценариях
generateEvent(id, valAsStr);
publishStatusMqtt(id, valAsStr);
publishStatusWs(id, valAsStr);
//itemExist->regEvent(valAsStr, "");
SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + id + " " + valAsStr);
}
}
//здесь мы получаем прямые команды которые сразу выполнятся на этом устройстве
//необходимо для тех кто хочет управлять своим устройством из mqtt
// здесь мы получаем прямые команды которые сразу выполнятся на этом устройстве
// необходимо для тех кто хочет управлять своим устройством из mqtt
else if (topicStr.indexOf("order") != -1) {
if (!jsonReadBool(settingsFlashJson, "mqttin")) {
return;