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:
Dmitry Borisenko
2022-02-28 01:10:14 +01:00
parent c50e0606e4
commit 28add9cb25
14 changed files with 121 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
src/MqttClient.cpp
View File

@@ -109,7 +109,7 @@ void mqttSubscribe() {
mqtt.subscribe((mqttRootDevice + "/+/control").c_str());
mqtt.subscribe((mqttRootDevice + "/update").c_str());
if (jsonReadBool(settingsFlashJson, "MqttIn")) {
if (jsonReadBool(settingsFlashJson, "mqttin")) {
mqtt.subscribe((mqttPrefix + "/+/+/event").c_str());
mqtt.subscribe((mqttPrefix + "/+/+/order").c_str());
mqtt.subscribe((mqttPrefix + "/+/+/info").c_str());
@@ -145,31 +145,34 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length) {
SerialPrint("i", F("=>MQTT"), "Msg from iotmanager app: " + key + " " + payloadStr);
}
// else if (topicStr.indexOf("event") != -1) {
// if (!jsonReadBool(settingsFlashJson, "MqttIn")) {
// return;
// }
// if (topicStr.indexOf(chipId) == -1) {
// String devId = selectFromMarkerToMarker(topicStr, "/", 2);
// String key = selectFromMarkerToMarker(topicStr, "/", 3);
// SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + key + " " + payloadStr);
// String event = key + " " + payloadStr + ",";
// eventBuf += event;
// }
//}
//
// else if (topicStr.indexOf("order") != -1) {
// if (!jsonReadBool(settingsFlashJson, "MqttIn")) {
// return;
// }
// String devId = selectFromMarkerToMarker(topicStr, "/", 2);
// String key = selectFromMarkerToMarker(topicStr, "/", 3);
// SerialPrint("i", F("=>MQTT"), "Received direct order " + key + " " + payloadStr);
// String order = key + " " + payloadStr + ",";
// loopCmdAdd(order);
// SerialPrint("i", "Order add", order);
//}
//
//здесь мы получаем события с других устройств, которые потом проверяются в сценариях этого устройства
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);
//добавим событие в базу
IoTItems.push_back((IoTItem*)new externalVariable(payloadStr));
//запустим проверку его в сценариях
generateEvent(id, payloadStr);
SerialPrint("i", F("=>MQTT"), "Received event from other device: '" + devId + "' " + id + " " + payloadStr);
}
}
//здесь мы получаем прямые команды которые сразу выполнятся на этом устройстве
//необходимо для тех кто хочет управлять своим устройством из mqtt
else if (topicStr.indexOf("order") != -1) {
if (!jsonReadBool(settingsFlashJson, "mqttin")) {
return;
}
String devId = selectFromMarkerToMarker(topicStr, "/", 2);
String id = selectFromMarkerToMarker(topicStr, "/", 3);
generateOrder(id, payloadStr);
SerialPrint("i", F("=>MQTT"), "Received direct order " + id + " " + payloadStr);
}
// else if (topicStr.indexOf("info") != -1) {
// if (topicStr.indexOf("scen") != -1) {
// writeFile(String(DEVICE_SCENARIO_FILE), payloadStr);
@@ -260,9 +263,7 @@ void publishWidgets() {
}
void publishState() {
String json = "{}";
jsonMergeObjects(json, paramsHeapJson);
jsonMergeObjects(json, paramsFlashJson);
String json = getParamsJson();
json.replace("{", "");
json.replace("}", "");
json.replace("\"", "");