IoTManager/src/modules/sensors/ExternalMQTT/ExternalMQTT.cpp

#include "Global.h"
#include "classes/IoTItem.h"

class ExternalMQTT : public IoTItem
{
private:
    String _MAC;
    String _sensor;
    IoTItem *tmp;
    int _minutesPassed = 0;
    String json = "{}";
    int orange = 0;
    int red = 0;
    int offline = 0;
    bool dataFromNode = false;

public:
    ExternalMQTT(String parameters) : IoTItem(parameters)
    {
        _MAC = jsonReadStr(parameters, "MAC");
        _sensor = jsonReadStr(parameters, "sensor");
        jsonRead(parameters, F("orange"), orange);
        jsonRead(parameters, F("red"), red);
        jsonRead(parameters, F("offline"), offline);
        dataFromNode = false;
    }
    char *TimeToString(unsigned long t)
    {
        static char str[12];
        long h = t / 3600;
        t = t % 3600;
        int m = t / 60;
        int s = t % 60;
        sprintf(str, "%02ld:%02d:%02d", h, m, s);
        return str;
    }
    void onMqttRecive(String &topic, String &msg)
    {
        if (msg.indexOf("HELLO") == -1)
        {

            //        SerialPrint("i", "onMqttRecive", "Прилетело  " + topic);
            //        SerialPrint("i", "onMqttRecive", "Прилетело  " + msg);
            String dev = selectToMarkerLast(topic, "/");
            dev.toUpperCase();
            dev.replace(":", "");
            if (_MAC == "")
            {
                SerialPrint("i", "onMqttRecive", dev + " -->  " + msg);
            }
            DynamicJsonDocument doc(JSON_BUFFER_SIZE);
            DeserializationError error = deserializeJson(doc, msg);
            if (error)
            {
                SerialPrint("E", F("onMqttRecive"), error.f_str());
            }
            JsonObject jsonObject = doc.as<JsonObject>();

            for (JsonPair kv : jsonObject)
            {
                String key = kv.key().c_str();
                String val = kv.value();
                if (_MAC == dev && _sensor == key)
                {
                    dataFromNode = true;
                    _minutesPassed = 0;
                    setValue(val);
                    // setNewWidgetAttributes();
                }

                //   Serial.println("Key: " + key);
                //   Serial.println("Value: " + val);
            }
        }
    }

    void doByInterval()
    {
        _minutesPassed++;
        setNewWidgetAttributes();
    }
    void onMqttWsAppConnectEvent()
    {
        setNewWidgetAttributes();
    }

    void setNewWidgetAttributes()
    {

        jsonWriteStr(json, F("info"), prettyMinutsTimeout(_minutesPassed));
        if (dataFromNode)
        {
            if (orange != 0 && red != 0 && offline != 0)
            {
                if (_minutesPassed < orange)
                {
                    jsonWriteStr(json, F("color"), "");
                }
                if (_minutesPassed >= orange && _minutesPassed < red)
                {
                    jsonWriteStr(json, F("color"), F("orange")); // сделаем виджет оранжевым
                }
                if (_minutesPassed >= red && _minutesPassed < offline)
                {
                    jsonWriteStr(json, F("color"), F("red")); // сделаем виджет красным
                }
                if (_minutesPassed >= offline)
                {
                    jsonWriteStr(json, F("info"), F("offline"));
                }
            }
        }
        else
        {
            jsonWriteStr(json, F("info"), F("awaiting"));
        }
        sendSubWidgetsValues(_id, json);
    }

    ~ExternalMQTT(){};
};

void *getAPI_ExternalMQTT(String subtype, String param)
{
    if (subtype == F("ExternalMQTT"))
    {
        return new ExternalMQTT(param);
    }
    else
    {
        return nullptr;
    }
}