IoTManager/src/modules/virtual/LogingHourly/LogingHourly.cpp

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

class LogingHourly : public IoTItem
{
private:
    String logid;
    String id;
    String filesList = "";

    String descr;

    int _publishType = -2;
    int _wsNum = -1;

    int points;

    int testMode;

    int telegram;

    IoTItem *dateIoTItem;

    // String prevDate = "";
    String prevHourly = "";
    bool firstTimeInit = true;

    // long interval;

public:
    LogingHourly(String parameters) : IoTItem(parameters)
    {
        jsonRead(parameters, F("logid"), logid);
        jsonRead(parameters, F("id"), id);
        jsonRead(parameters, F("points"), points);
        jsonRead(parameters, F("test"), testMode);
        jsonRead(parameters, F("telegram"), telegram);
        jsonRead(parameters, F("descr"), descr);

               long interval;

        jsonRead(parameters, F("int"), interval);
        interval = interval * 1000 * 60; // приводим к милисекундам
    }

    void doByInterval()
    {
        if (hasHourlyChanged() || testMode == 1)
        {
            execute();
        }
    }

    void execute()
    {
        // если объект логгирования не был создан
        if (!isItemExist(logid))
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' LogingHourly object not exist, return");
            return;
        }

        String value = getItemValue(logid);

        // если значение логгирования пустое
        if (value == "")
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' LogingHourly value is empty, return");
            return;
        }

        // если время не было получено из интернета
        if (!isTimeSynch)
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' Cant LogingHourly - time not synchronized, return");
            return;
        }

        String logData;

        float currentValue = value.toFloat();
        // прочитаем предудущее значение
        float prevValue = readDataDB(id + "-v").toFloat();
        // сохраним в базу данных текущее значение, понадобится в следующие час
        saveDataDB(id + "-v", value);

        float difference = currentValue - prevValue;

        if (telegram == 1)
        {
            String msg = descr + ": total " + String(currentValue) + ", consumed " + String(difference);
            for (std::list<IoTItem *>::iterator it = IoTItems.begin(); it != IoTItems.end(); ++it)
            {
                if ((*it)->getSubtype() == "TelegramLT" || "Telegram")
                {
                    (*it)->sendTelegramMsg(false, msg);
                }
            }
        }

        // jsonWriteInt(logData, "x", unixTime - 120);
        jsonWriteInt(logData, "x", unixTime - 120);
        jsonWriteFloat(logData, "y1", difference);

        // прочитаем путь к файлу последнего сохранения
        String filePath = readDataDB(id);

        // если данные о файле отсутствуют, создадим новый
        if (filePath == "failed" || filePath == "")
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' file path not found, start create new file");
            createNewFileWithData(logData);
            return;
        }

        // считаем количество строк и определяем размер файла
        size_t size = 0;
        int lines = countJsonObj(filePath, size);
        SerialPrint("i", F("LogingHourly"), "'" + id + "' " + "lines = " + String(lines) + ", size = " + String(size));

        // если количество строк до заданной величины и час и дата не менялась
        // if (lines <= points && !hasHourlyChanged()) {
        if (lines <= points)
        {
            // просто добавим в существующий файл новые данные
            addNewDataToExistingFile(filePath, logData);
        }
        else
        {
            String file = readFile(filePath, 2000);
            file = deleteBeforeDelimiter(file, "},");
            writeFile(filePath, file);
            addNewDataToExistingFile(filePath, logData);
        }
    }

    void createNewFileWithData(String &logData)
    {
        logData = logData + ",";

        String path = "/lgh/" + id + "/" + id + ".txt"; // создадим путь вида /lgd/id/id.txt
        // создадим пустой файл
        if (writeEmptyFile(path) != "success")
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' file writing error, return");
            return;
        }

        // запишем в него данные
        if (addFile(path, logData) != "success")
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' data writing error, return");
            return;
        }
        // запишем путь к нему в базу данных
        if (saveDataDB(id, path) != "success")
        {
            SerialPrint("E", F("LogingHourly"), "'" + id + "' db file writing error, return");
            return;
        }
        #ifdef LIBRETINY
        SerialPrint("i", F("LogingHourly"), "'" + id + "' file created http://" + ipToString(WiFi.localIP()) + path);
        #else
        SerialPrint("i", F("LogingHourly"), "'" + id + "' file created http://" + WiFi.localIP().toString() + path);
        #endif
    }

    void addNewDataToExistingFile(String &path, String &logData)
    {
        logData = logData + ",";
        if (addFile(path, logData) != "success")
        {
            SerialPrint("i", F("LogingHourly"), "'" + id + "' file writing error, return");
            return;
        };
        #ifdef LIBRETINY
        SerialPrint("i", F("LogingHourly"), "'" + id + "' LogingHourly in file http://" + ipToString(WiFi.localIP()) + path);
        #else
        SerialPrint("i", F("LogingHourly"), "'" + id + "' LogingHourly in file http://" + WiFi.localIP().toString() + path);
        #endif
    }
    const String getTimeLocal_hh()
    {
        char buf[32];
        sprintf(buf, "%02d", _time_local.hour);
        return String(buf);
    }

    bool hasHourlyChanged()
    {
        bool changed = false;
        String currentHourly = getTimeLocal_hh();
        if (!firstTimeInit)
        {
            if (prevHourly != currentHourly)
            {
                changed = true;
                SerialPrint("i", F("NTP"), F("Change hourly event"));
#if defined(ESP8266)
                FileFS.gc();
#endif
#if defined(ESP32)
#endif
            }
        }
        if (isTimeSynch)
            firstTimeInit = false;
        prevHourly = currentHourly;
        return changed;
    }

    bool hasDayChanged()
    {
        bool changed = false;
        String currentDate = getTodayDateDotFormated();
        if (!firstTimeInit)
        {
            if (prevDate != currentDate)
            {
                changed = true;
                SerialPrint("i", F("NTP"), F("Change day event"));
#if defined(ESP8266)
                FileFS.gc();
#endif
#if defined(ESP32)
#endif
            }
        }
        if (isTimeSynch)
            firstTimeInit = false;
        prevDate = currentDate;
        return changed;
    }

    void publishValue()
    {
        String dir = "/lgh/" + id;
        filesList = getFilesList(dir);

        SerialPrint("i", F("LogingHourly"), "file list: " + filesList);

        int f = 0;

        while (filesList.length())
        {
            String path = selectToMarker(filesList, ";");

            path = "/lgh/" + id + path;

            f++;
            String json = getAdditionalJson();
            if (_publishType == TO_MQTT)
            {
                publishChartFileToMqtt(path, id, calculateMaxCount());
            }
            else if (_publishType == TO_WS)
            {
                sendFileToWsByFrames(path, "charta", json, _wsNum, WEB_SOCKETS_FRAME_SIZE);
            }
            else if (_publishType == TO_MQTT_WS)
            {
                publishChartFileToMqtt(path, id, calculateMaxCount());
                sendFileToWsByFrames(path, "charta", json, _wsNum, WEB_SOCKETS_FRAME_SIZE);
            }
            SerialPrint("i", F("LogingHourly"), String(f) + ") " + path + ", sent");

            filesList = deleteBeforeDelimiter(filesList, ";");
        }
    }

    String getAdditionalJson()
    {
        String topic = mqttRootDevice + "/" + id;
        String json = "{\"maxCount\":" + String(calculateMaxCount()) + ",\"topic\":\"" + topic + "\"}";
        return json;
    }

    void clearHistory()
    {
        String dir = "/lgh/" + id;
        cleanDirectory(dir);
    }

    // void publishChartToWsSinglePoint(String value) {
    //     String topic = mqttRootDevice + "/" + id;
    //     String json = "{\"maxCount\":" + String(calculateMaxCount()) + ",\"topic\":\"" + topic + "\",\"status\":[{\"x\":" + String(unixTime) + ",\"y1\":" + value + "}]}";
    //     String pk = "/string/chart.json|" + json;
    //     standWebSocket.broadcastTXT(pk);
    // }

    void setPublishDestination(int publishType, int wsNum = -1)
    {
        _publishType = publishType;
        _wsNum = wsNum;
    }

    String getValue()
    {
        return "";
    }
    /*
        void loop() {
            if (enableDoByInt) {
                currentMillis = millis();
                difference = currentMillis - prevMillis;
                if (difference >= interval) {
                    prevMillis = millis();
                    this->doByInterval();
                }
            }
        }
    */
    // просто максимальное количество точек
    int calculateMaxCount()
    {
        // return 1440;//1440
        return 3600; // 1440
    }

    void onModuleOrder(String &key, String &value)
    {
        if (key == "defvalue")
        {
            saveDataDB(id + "-v", value);
            SerialPrint("i", F("LogingHourly"), "User set default value: " + value);
        }
        else if (key == "reset")
        {
            clearHistory();
            SerialPrint("i", F("LogingHourly"), F("User clean chart history"));
        }
    }
};

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