mirror of
https://github.com/IoTManagerProject/IoTManager.git
synced 2026-03-26 22:22:16 +03:00
update Thermostat and Loging
This commit is contained in:
Mit4el
339
src/modules/virtual/LogingHourly/LogingHourly.cpp
Normal file
339
src/modules/virtual/LogingHourly/LogingHourly.cpp
Normal file
@@ -0,0 +1,339 @@
|
||||
#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;
|
||||
}
|
||||
SerialPrint("i", F("LogingHourly"), "'" + id + "' file created http://" + WiFi.localIP().toString() + path);
|
||||
}
|
||||
|
||||
void addNewDataToExistingFile(String &path, String &logData)
|
||||
{
|
||||
logData = logData + ",";
|
||||
if (addFile(path, logData) != "success")
|
||||
{
|
||||
SerialPrint("i", F("LogingHourly"), "'" + id + "' file writing error, return");
|
||||
return;
|
||||
};
|
||||
SerialPrint("i", F("LogingHourly"), "'" + id + "' LogingHourly in file http://" + WiFi.localIP().toString() + path);
|
||||
}
|
||||
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;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user