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-09-13 00:56:34 +02:00
parent e8731b413e
commit 5036fbc2fe
12 changed files with 117 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/Global.cpp
View File

@@ -4,7 +4,7 @@
*****************************************глобальные объекты классов***************************************************
**********************************************************************************************************************/
TickerScheduler ts(PTASK + 1);
TickerScheduler ts(END + 1);
WiFiClient espClient;
PubSubClient mqtt(espClient);
StringCommand sCmd;

5
src/Main.cpp
View File

@@ -1,6 +1,7 @@
#include "Main.h"
#include <time.h>
#include "classes/IoTDB.h"
#include "utils/Statistic.h"
IoTScenario iotScen; // объект управления сценарием
@@ -70,6 +71,8 @@ void setup() {
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}"));
generateEvent("onStart", "");
stInit();
// test
Serial.println("-------test start--------");
//=======проверка очереди из структур=================
@@ -86,7 +89,7 @@ void setup() {
// Serial.println(myDB->front().myword);
// Serial.println(myDB->front().myword);
Serial.println(FileList("lg"));
// Serial.println(FileList("lg"));
Serial.println("--------test end---------");

2
src/WsServer.cpp
View File

@@ -253,10 +253,8 @@ void publishStatusWs(const String& topic, const String& data) {
//публикация статус сообщений
void publishChartWs(int num, String& data) {
if (num == -1) {
Serial.println("broadcastTXT");
standWebSocket.broadcastTXT(data);
} else {
Serial.println("sendTXT");
standWebSocket.sendTXT(num, data);
}
}

2
src/classes/IoTItem.cpp
View File

@@ -130,6 +130,8 @@ String IoTItem::getSubtype() {
void IoTItem::sendChart() {}
void IoTItem::cleanChart() {}
void IoTItem::setPublishType(int publishType, int wsNum){};
void IoTItem::cleanData() {}

53
src/modules/virtual/Logging/Loging.cpp
View File

@@ -19,6 +19,9 @@ class Loging : public IoTItem {
IoTItem *dateIoTItem;
String prevDate = "";
bool firstTimeDate = true;
unsigned long interval;
public:
@@ -80,11 +83,11 @@ class Loging : public IoTItem {
int lines = countLines(filePath);
SerialPrint("i", F("Loging"), "'" + id + "' " + String(lines) + " lines found in file");
//если количество строк до заданной величины
if (lines <= points) {
//если количество строк до заданной величины и дата не менялась
if (lines <= points && !hasDayChanged()) {
//просто добавим в существующий файл новые данные
addNewDataToExistingFile(filePath, logData);
//если больше создадим следующий файл
//если больше или поменялась дата то создадим следующий файл
} else {
createNewFileWithData(logData);
}
@@ -102,6 +105,20 @@ class Loging : public IoTItem {
SerialPrint("i", F("Loging"), "'" + id + "' loging in file http://" + WiFi.localIP().toString() + path);
}
bool hasDayChanged() {
bool changed = false;
String currentDate = getDateDotFormated();
if (!firstTimeDate) {
if (prevDate != currentDate) {
changed = true;
SerialPrint("i", F("NTP"), "Change day event");
}
}
firstTimeDate = false;
prevDate = currentDate;
return changed;
}
#if defined(ESP8266)
void getFilesList8266() {
filesList = "";
@@ -164,9 +181,9 @@ class Loging : public IoTItem {
if (fileUnixTimeLocal > reqUnixTime && fileUnixTimeLocal < reqUnixTime + 86400) {
noData = false;
createJson(buf, i);
SerialPrint("i", F("Loging"), String(f) + ")" + buf + ", " + String(i) + ", " + getDateTimeDotFormatedFromUnix(fileUnixTimeLocal) + ", sent");
SerialPrint("i", F("Loging"), String(f) + ") " + buf + ", " + String(i) + ", " + getDateTimeDotFormatedFromUnix(fileUnixTimeLocal) + ", sent");
} else {
SerialPrint("i", F("Loging"), String(f) + ")" + buf + ", " + String(i) + ", " + getDateTimeDotFormatedFromUnix(fileUnixTimeLocal) + ", skipped");
SerialPrint("i", F("Loging"), String(f) + ") " + buf + ", nil, " + getDateTimeDotFormatedFromUnix(fileUnixTimeLocal) + ", skipped");
}
//}
@@ -174,12 +191,16 @@ class Loging : public IoTItem {
}
//если данных нет отправляем пустой грфик
if (noData) {
SerialPrint("i", F("Loging"), "clear chart");
String cleanJson = createEmtyJson();
publishJson(cleanJson);
cleanChart();
}
}
void cleanChart() {
SerialPrint("i", F("Loging"), "clear chart");
String cleanJson = createEmtyJson();
publishJson(cleanJson);
}
void cleanData() {
getFilesList();
int i = 0;
@@ -265,11 +286,16 @@ class Loging : public IoTItem {
}
void regEvent(String value, String consoleInfo = "") {
generateEvent(_id, value);
publishStatusMqtt(_id, value);
String json = createSingleJson(_id, value);
publishChartWs(-1, json);
SerialPrint("i", "Sensor " + consoleInfo, "'" + _id + "' data: " + value + "'");
String userDate = getItemValue(id + "-date");
String currentDate = getDateDotFormated();
//отправляем в график данные только когда выбран сегодняшний день
if (userDate == currentDate) {
generateEvent(_id, value);
publishStatusMqtt(_id, value);
String json = createSingleJson(_id, value);
publishChartWs(-1, json);
SerialPrint("i", "Sensor " + consoleInfo, "'" + _id + "' data: " + value + "'");
}
}
String createSingleJson(String id, String value) {
@@ -321,6 +347,7 @@ class Date : public IoTItem {
//отправляем только свои данные
if ((*it)->getID() == selectToMarker(id, "-")) {
(*it)->setPublishType(3, -1);
(*it)->cleanChart();
(*it)->sendChart();
}
}

8
src/modules/virtual/Logging/modinfo.json
View File

@@ -20,14 +20,14 @@
"authorName": "Dmitry Borisenko",
"authorContact": "https://t.me/Dmitry_Borisenko",
"authorGit": "https://github.com/DmitryBorisenko33",
"specialThanks": "",
"specialThanks": "@itsid1 @Valiuhaaa Serg",
"moduleName": "Loging",
"moduleVersion": "2.0",
"moduleDesc": "Расширение позволяющее логировать любую величину в график. Графики доступны в мобильном приложении и в веб интерфейсе",
"moduleVersion": "3.0",
"moduleDesc": "Расширение позволяющее логировать любую величину в график. Графики доступны в мобильном приложении и в веб интерфейсе. Данные графиков хранятся в встроенной памяти esp. График отображает период времени выбранный пользователем. В окне ввода даты нужно выбрать день, историю которого вы хотите посмотреть",
"propInfo": {
"int": "Интервал логирования в мнутах, рекомендуется для esp8266 использоать интервал не менее 5-ти минут",
"logid": "ID величины которую будем логировать",
"points": "Максимальное количество точек в одном файле, может быть не более 300",
"points": "Максимальное количество точек в одном файле, может быть не более 300. Не рекомендуется менять этот параметр",
"keepdays": "Количество дней за которое необходимо хранить историю. Данные старее будут удалены автоматически"
}
},

54
src/utils/Statistic.cpp Normal file
View File

@@ -0,0 +1,54 @@
#include "utils/Statistic.h"
#include <Arduino.h>
void stInit() {
if (TELEMETRY_UPDATE_INTERVAL_MIN) {
ts.add(
ST, TELEMETRY_UPDATE_INTERVAL_MIN * 60000, [&](void*) {
updateDeviceStatus();
},
nullptr, true);
}
SerialPrint("i", F("Stat"), F("Stat Init"));
}
void updateDeviceStatus() {
String ret;
String serverIP;
jsonRead(settingsFlashJson, F("serverip"), serverIP);
String url = serverIP + F("/projects/esprebootstat.php");
// SerialPrint("i", "Stat", "url " + url);
if ((WiFi.status() == WL_CONNECTED)) {
WiFiClient client;
HTTPClient http;
http.begin(client, url);
// http.setAuthorization("admin", "admin");
http.addHeader("Content-Type", "application/json");
// String mac = WiFi.macAddress().c_str();
String json = "";
jsonWriteStr_(json, "idesp", getChipId());
jsonWriteStr_(json, "nameesp", jsonReadStr(settingsFlashJson, F("name")));
jsonWriteStr_(json, "firmwarename", String(FIRMWARE_NAME));
jsonWriteStr_(json, "firmwarever", String(FIRMWARE_VERSION));
jsonWriteStr_(json, "rebootreason", ESP_getResetReason());
int httpCode = http.POST(json);
// int httpCode = http.POST("?idesp=" + getChipId() +
// "&nameesp=" + jsonReadStr(settingsFlashJson, F("name")) +
// "&firmwarename=" + String(FIRMWARE_NAME) +
// "&firmwarever=" + String(FIRMWARE_VERSION) +
// "&rebootreason=" + ESP_getResetReason() + "");
if (httpCode > 0) {
ret = httpCode;
if (httpCode == HTTP_CODE_OK) {
String payload = http.getString();
ret += " " + payload;
}
} else {
ret = http.errorToString(httpCode).c_str();
}
http.end();
}
SerialPrint("i", "Stat", "Update device data: " + ret);
}