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

Включаем сетевые сценарии на базе MQTT

Browse Source
This commit is contained in:
biver
2022-10-22 08:00:48 +03:00
parent 55c0cfd718
commit 538257208d
2 changed files with 36 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
src/MqttClient.cpp
View File

@@ -161,29 +161,33 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length) {
else if (topicStr.indexOf("event") != -1) { else if (topicStr.indexOf("event") != -1) {
//пока не работает сетевой обмен этот код будет закомментирован //пока не работает сетевой обмен этот код будет закомментирован
// if (!jsonReadBool(settingsFlashJson, "mqttin")) { if (!jsonReadBool(settingsFlashJson, "mqttin")) {
// return; return;
// } }
// if (topicStr.indexOf(chipId) == -1) { if (topicStr.indexOf(chipId) == -1) {
// String devId = selectFromMarkerToMarker(topicStr, "/", 2); String devId = selectFromMarkerToMarker(topicStr, "/", 2);
// String id = selectFromMarkerToMarker(topicStr, "/", 3); String id = selectFromMarkerToMarker(topicStr, "/", 3);
// IoTItem* itemExist = findIoTItem(id); String valAsStr;
// if (itemExist) { jsonRead(payloadStr, F("val"), valAsStr, false);
// String valAsStr;
// if (jsonRead(payloadStr, F("val"), valAsStr, false)) { IoTItem* itemExist = findIoTItem(id);
// itemExist->setValue(valAsStr); if (itemExist) {
// unsigned long interval; unsigned long interval;
// jsonRead(payloadStr, F("int"), interval); jsonRead(payloadStr, F("int"), interval);
// itemExist->setInterval(interval); itemExist->setInterval(interval);
// } itemExist->setValue(valAsStr, false);
// } else { } else {
// //добавим событие в базу //добавим событие в базу
// // IoTItems.push_back((IoTItem*)new externalVariable(payloadStr)); itemExist = (IoTItem*)new externalVariable(payloadStr);
// } IoTItems.push_back(itemExist);
// //запустим проверку его в сценариях }
// generateEvent(id, payloadStr); //запустим проверку его в сценариях
// SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + id + " " + payloadStr); generateEvent(id, valAsStr);
// } publishStatusMqtt(id, valAsStr);
publishStatusWs(id, valAsStr);
//itemExist->regEvent(valAsStr, "");
SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + id + " " + valAsStr);
}
} }
//здесь мы получаем прямые команды которые сразу выполнятся на этом устройстве //здесь мы получаем прямые команды которые сразу выполнятся на этом устройстве

18
src/classes/IoTItem.cpp
View File

@@ -64,7 +64,7 @@ void IoTItem::setValue(String valStr, bool generateEvent) {
} else { } else {
value.valS = valStr; value.valS = valStr;
} }
if (generateEvent) setValue(value, generateEvent); setValue(value, generateEvent);
} }
// //
@@ -96,14 +96,14 @@ void IoTItem::regEvent(String value, String consoleInfo = "") {
// SerialPrint("i", F("=>ALLMQTT"), "Broadcast event: "); // SerialPrint("i", F("=>ALLMQTT"), "Broadcast event: ");
// } // }
//отправка события другим устройствам в сети============================== //отправка события другим устройствам в сети==============================
// if (jsonReadBool(settingsFlashJson, "mqttin")) { if (jsonReadBool(settingsFlashJson, "mqttin")) {
// String json = "{}"; String json = "{}";
// jsonWriteStr_(json, "id", _id); jsonWriteStr_(json, "id", _id);
// jsonWriteStr_(json, "val", value); jsonWriteStr_(json, "val", value);
// jsonWriteInt_(json, "int", _interval + 5000); // 5 секунд про запас jsonWriteInt_(json, "int", _interval/1000 + 5); // 5 секунд про запас
// publishEvent(_id, json); publishEvent(_id, json);
// SerialPrint("i", F("<=MQTT"), "Broadcast event: " + json); SerialPrint("i", F("<=MQTT"), "Broadcast event: " + json);
//} }
//======================================================================== //========================================================================
} }