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

начальные изменения

Browse Source
This commit is contained in:
Dmitry Borisenko
2022-08-11 14:50:37 +02:00
parent 0dc05a14d4
commit 6d4b899fc0
5 changed files with 201 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
src/MqttClient.cpp
View File

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