2022-02-22 20:16:33 +01:00
|
|
|
|
#include "EventsAndOrders.h"
|
|
|
|
|
|
|
|
|
|
|
|
// orderBuf - буфер прямых команд, которые нужно выпонить сразу, нажали на кнопку в приложении, сработало условие сценария
|
|
|
|
|
|
//необходимо тут же изменить параметр, записать новое значение
|
|
|
|
|
|
|
|
|
|
|
|
// eventBuf - буфер событий, в нем как на конвеере едут события, и каждое событие проверяется через все условия сценариев
|
|
|
|
|
|
//его главное отличие от orderBuf в том что события в нем не для выполнения, а для проверки в условиях сценариев
|
|
|
|
|
|
//события в нем лишь вызывают другие команды, помещенные в блоке сценария, если условие совпало.
|
|
|
|
|
|
|
2022-02-22 23:58:35 +03:00
|
|
|
|
|
|
|
|
|
|
|
2022-02-22 20:16:33 +01:00
|
|
|
|
//эта функция будет вызываться:
|
|
|
|
|
|
// 1.на приеме сообщений в mqtt (см mqttCallback строку 142 в mqttClient.cpp)
|
|
|
|
|
|
// 2.на приеме сообщений в ws
|
|
|
|
|
|
// 3.в сценарях когда надо выполнить команды
|
|
|
|
|
|
void generateOrder(const String& id, const String& value) {
|
|
|
|
|
|
String event = id + " " + value + ",";
|
|
|
|
|
|
orderBuf += event;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//эта функция будет вызываться в loop()
|
|
|
|
|
|
void handleOrder() {
|
|
|
|
|
|
if (orderBuf.length()) {
|
|
|
|
|
|
String order = selectToMarker(orderBuf, ",");
|
|
|
|
|
|
Serial.println("order: " + order);
|
2022-02-22 23:58:35 +03:00
|
|
|
|
|
2022-02-22 20:16:33 +01:00
|
|
|
|
//здесь нужно перебрать все методы execute всех векторов и выполнить те id которых совпали с id события
|
2022-02-22 23:58:35 +03:00
|
|
|
|
IoTItem* item = findIoTItem(selectToMarker(order, " "));
|
|
|
|
|
|
if (item) {
|
|
|
|
|
|
String valStr = selectToMarkerLast(order, " ");
|
|
|
|
|
|
IoTValue value;
|
|
|
|
|
|
if (value.isDecimal = isDigitStr(valStr)) value.valD = valStr.toFloat();
|
|
|
|
|
|
else value.valS = valStr;
|
|
|
|
|
|
item->setValue(value);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
2022-02-22 20:16:33 +01:00
|
|
|
|
orderBuf = deleteBeforeDelimiter(orderBuf, ",");
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//эта функция будет вызываться:
|
|
|
|
|
|
// 1.в местах где событие только что произошло (IoTItem::regEvent)
|
|
|
|
|
|
void generateEvent(const String& id, const String& value) {
|
|
|
|
|
|
String event = id + " " + value + ",";
|
|
|
|
|
|
eventBuf += event;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//эта функция будет вызываться в loop()
|
|
|
|
|
|
void handleEvent() {
|
|
|
|
|
|
if (eventBuf.length()) {
|
|
|
|
|
|
String event = selectToMarker(eventBuf, ",");
|
|
|
|
|
|
Serial.println("event: " + event);
|
|
|
|
|
|
//здесь нужно пропускать данное событие через условия сценариев
|
|
|
|
|
|
//и если оно есть в условии сценария и совподает
|
|
|
|
|
|
//то нужно поместить все команды этого блока сценария в generateOrder(order1, order2, ....)
|
|
|
|
|
|
//который в свою очередь их выполнит
|
|
|
|
|
|
eventBuf = deleteBeforeDelimiter(eventBuf, ",");
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|