mirror of
https://github.com/IoTManagerProject/IoTManager.git
synced 2026-03-26 22:22:16 +03:00
316 lines
12 KiB
C++
316 lines
12 KiB
C++
//===============================================================================================================================
|
|
//=========================================Модуль аналогового сенсора============================================================
|
|
void analog() {
|
|
|
|
static boolean flag = true;
|
|
String viget_name = sCmd.next();
|
|
String page_name = sCmd.next();
|
|
String type = sCmd.next();
|
|
String analog_start = sCmd.next();
|
|
String analog_end = sCmd.next();
|
|
String analog_start_out = sCmd.next();
|
|
String analog_end_out = sCmd.next();
|
|
String page_number = sCmd.next();
|
|
|
|
jsonWrite(optionJson, "analog_start", analog_start);
|
|
jsonWrite(optionJson, "analog_end", analog_end);
|
|
jsonWrite(optionJson, "analog_start_out", analog_start_out);
|
|
jsonWrite(optionJson, "analog_end_out", analog_end_out);
|
|
|
|
if (type == "text") createViget (viget_name, page_name, page_number, "vigets/viget.alertsm.json", "analog");
|
|
if (type == "gauge") createViget (viget_name, page_name, page_number, "vigets/viget.fillgauge.json", "analog");
|
|
if (type == "gauge2") createViget (viget_name, page_name, page_number, "vigets/viget.gauge.json", "analog", "maximum", analog_end_out);
|
|
if (type == "termometr") createViget (viget_name, page_name, page_number, "vigets/viget.termometr.json", "analog", "titleString", viget_name);
|
|
|
|
ts.add(ANALOG_, analog_update_int, [&](void*) {
|
|
|
|
static int analog_old;
|
|
|
|
int analog_in = analogRead(35);
|
|
jsonWrite(configJson, "analog_in", analog_in);
|
|
|
|
int analog = map(analog_in,
|
|
jsonReadtoInt(optionJson, "analog_start") ,
|
|
jsonReadtoInt(optionJson, "analog_end"),
|
|
jsonReadtoInt(optionJson, "analog_start_out"),
|
|
jsonReadtoInt(optionJson, "analog_end_out"));
|
|
|
|
jsonWrite(configJson, "analog", analog);
|
|
|
|
// if (analog_old != analog) {
|
|
|
|
eventGen ("analog", "");
|
|
sendSTATUS("analog", String(analog));
|
|
if (client.connected()) {
|
|
Serial.println("[i] sensor analog send date " + String(analog));
|
|
}
|
|
// }
|
|
analog_old = analog;
|
|
}, nullptr, true);
|
|
}
|
|
|
|
//===============================================================================================================================
|
|
//=========================================Модуль аналогового сенсора============================================================
|
|
void ph() {
|
|
|
|
String viget_name = sCmd.next();
|
|
String page_name = sCmd.next();
|
|
String type = sCmd.next();
|
|
String offset = sCmd.next();
|
|
String page_number = sCmd.next();
|
|
|
|
jsonWrite(optionJson, "ph_offset", offset);
|
|
|
|
if (type == "text") createViget (viget_name, page_name, page_number, "vigets/viget.alertsm.json", "ph");
|
|
if (type == "gauge") createViget (viget_name, page_name, page_number, "vigets/viget.fillgauge.json", "ph");
|
|
if (type == "gauge2") createViget (viget_name, page_name, page_number, "vigets/viget.gauge.json", "ph");
|
|
if (type == "termometr") createViget (viget_name, page_name, page_number, "vigets/viget.termometr.json", "ph", "titleString", viget_name);
|
|
|
|
|
|
ts.add(PH, ph_shooting_interval, [&](void*) {
|
|
|
|
static float pHValue_old;
|
|
static int counter;
|
|
|
|
float offset = jsonRead(optionJson, "ph_offset").toFloat();
|
|
|
|
int analog = analogRead(A0);
|
|
analog = medianFilter.filtered(analog);
|
|
float voltage = analog * 3.2 / 1024;
|
|
float pHValue = 3.5 * voltage + offset;
|
|
String pHValue_str = String(pHValue);
|
|
|
|
pHValue_str = selectToMarkerPlus(pHValue_str, "." , 2);
|
|
|
|
counter++;
|
|
|
|
if (counter > ph_times_to_send) {
|
|
counter = 0;
|
|
|
|
jsonWrite(configJson, "ph", pHValue_str);
|
|
|
|
//if (pHValue_old != pHValue) {
|
|
|
|
eventGen ("ph", "");
|
|
sendSTATUS("ph", pHValue_str);
|
|
if (client.connected()) {
|
|
Serial.println("[i] sensor ph send date " + pHValue_str);
|
|
Serial.println("voltage " + String(voltage));
|
|
}
|
|
//}
|
|
pHValue_old = pHValue;
|
|
}
|
|
}, nullptr, true);
|
|
}
|
|
//===================================================================================================================================
|
|
//=========================================Модуль измерения уровня в баке============================================================
|
|
void level() {
|
|
|
|
static boolean flag = true;
|
|
String viget_name = sCmd.next();
|
|
String page_name = sCmd.next();
|
|
String type = sCmd.next();
|
|
String empty_level = sCmd.next();
|
|
String full_level = sCmd.next();
|
|
String page_number = sCmd.next();
|
|
|
|
jsonWrite(optionJson, "empty_level", empty_level);
|
|
jsonWrite(optionJson, "full_level", full_level);
|
|
|
|
pinMode(14, OUTPUT);
|
|
pinMode(12, INPUT);
|
|
|
|
if (type == "text") createViget (viget_name, page_name, page_number, "vigets/viget.alertsm.json", "level");
|
|
if (type == "gauge") createViget (viget_name, page_name, page_number, "vigets/viget.fillgauge.json", "level");
|
|
if (type == "gauge2") createViget (viget_name, page_name, page_number, "vigets/viget.gauge.json", "level", "maximum", "100");
|
|
if (type == "termometr") createViget (viget_name, page_name, page_number, "vigets/viget.termometr.json", "level", "titleString", viget_name);
|
|
|
|
ts.add(LEVEL, tank_level_shooting_interval, [&](void*) {
|
|
|
|
long duration_;
|
|
int distance_cm;
|
|
int level;
|
|
static int level_old; //переменная static сохраняет свое значение между вызовами функции
|
|
static int counter;
|
|
|
|
digitalWrite(14, LOW);
|
|
delayMicroseconds(2);
|
|
digitalWrite(14, HIGH);
|
|
delayMicroseconds(10);
|
|
digitalWrite(14, LOW);
|
|
duration_ = pulseIn(12, HIGH, 30000); // 3000 µs = 50cm // 30000 µs = 5 m
|
|
distance_cm = duration_ / 29 / 2;
|
|
distance_cm = medianFilter.filtered(distance_cm);//отсечение промахов медианным фильтром
|
|
|
|
counter++;
|
|
|
|
if (counter > tank_level_times_to_send) {
|
|
counter = 0;
|
|
jsonWrite(configJson, "level_in", distance_cm);
|
|
|
|
level = map(distance_cm,
|
|
jsonReadtoInt(optionJson, "empty_level"),
|
|
jsonReadtoInt(optionJson, "full_level"), 0, 100);
|
|
|
|
//jsonWrite(configJson, "level", level);
|
|
|
|
//if (level_old != level) {
|
|
|
|
eventGen ("level", "");
|
|
sendSTATUS("level", String(level));
|
|
if (client.connected()) {
|
|
Serial.println("[i] sensor tank level send date " + String(level));
|
|
}
|
|
//}
|
|
level_old = level;
|
|
}
|
|
}, nullptr, true);
|
|
}
|
|
|
|
//==========================================================================================================================================
|
|
//=========================================Модуль температурного сенсора ds18b20============================================================
|
|
void dallas() {
|
|
|
|
static boolean flag = true;
|
|
String pin = sCmd.next();
|
|
String viget_name = sCmd.next();
|
|
String page_name = sCmd.next();
|
|
String type = sCmd.next();
|
|
String page_number = sCmd.next();
|
|
|
|
oneWire = new OneWire((uint8_t) pin.toInt());
|
|
sensors.setOneWire(oneWire);
|
|
sensors.begin();
|
|
sensors.setResolution(12);
|
|
|
|
if (type == "text") createViget (viget_name, page_name, page_number, "vigets/viget.alertsm.json", "dallas");
|
|
if (type == "gauge") createViget (viget_name, page_name, page_number, "vigets/viget.fillgauge.json", "dallas");
|
|
if (type == "gauge2") createViget (viget_name, page_name, page_number, "vigets/viget.gauge.json", "dallas");
|
|
if (type == "termometr") createViget (viget_name, page_name, page_number, "vigets/viget.termometr.json", "dallas", "titleString", viget_name);
|
|
|
|
ts.add(DALLAS, temp_update_int, [&](void*) {
|
|
|
|
float temp = 0;
|
|
static float temp_old;
|
|
sensors.requestTemperatures();
|
|
temp = sensors.getTempCByIndex(0);
|
|
|
|
jsonWrite(configJson, "dallas", String(temp));
|
|
|
|
//if (temp_old != temp) {
|
|
|
|
eventGen ("dallas", "");
|
|
sendSTATUS("dallas", String(temp));
|
|
if (client.connected()) {
|
|
Serial.println("[i] sensor dallas send date " + String(temp));
|
|
}
|
|
//}
|
|
|
|
temp_old = temp;
|
|
}, nullptr, true);
|
|
}
|
|
|
|
//======================================================================================================================
|
|
//===============================================Логирование============================================================
|
|
|
|
void logging() {
|
|
|
|
static boolean flag = true;
|
|
|
|
String sensor_name = sCmd.next();
|
|
String period_min = sCmd.next();
|
|
String maxCount = sCmd.next();
|
|
String viget_name = sCmd.next();
|
|
viget_name.replace("#", " ");
|
|
String page_name = sCmd.next();
|
|
String page_number = sCmd.next();
|
|
|
|
if (sensor_name == "analog") jsonWrite(optionJson, "analog_logging_count", maxCount);
|
|
if (sensor_name == "level") jsonWrite(optionJson, "level_logging_count", maxCount);
|
|
if (sensor_name == "dallas") jsonWrite(optionJson, "dallas_logging_count", maxCount);
|
|
if (sensor_name == "ph") jsonWrite(optionJson, "ph_logging_count", maxCount);
|
|
|
|
if (sensor_name == "analog") createViget (viget_name, page_name, page_number, "vigets/viget.chart.json", "loganalog", "maxCount", maxCount);
|
|
if (sensor_name == "level") createViget (viget_name, page_name, page_number, "vigets/viget.chart.json", "loglevel", "maxCount", maxCount);
|
|
if (sensor_name == "dallas") createViget (viget_name, page_name, page_number, "vigets/viget.chart.json", "logdallas", "maxCount", maxCount);
|
|
if (sensor_name == "ph") createViget (viget_name, page_name, page_number, "vigets/viget.chart.json", "logph", "maxCount", maxCount);
|
|
|
|
if (sensor_name == "analog") {
|
|
flagLoggingAnalog = true;
|
|
ts.remove(ANALOG_LOG);
|
|
ts.add(ANALOG_LOG, period_min.toInt() * 1000 * 60, [&](void*) {
|
|
deleteOldDate("log.analog.txt", jsonReadtoInt(optionJson, "analog_logging_count"), jsonRead(configJson, "analog"), false);
|
|
}, nullptr, true);
|
|
}
|
|
|
|
if (sensor_name == "level") {
|
|
flagLoggingLevel = true;
|
|
ts.remove(LEVEL_LOG);
|
|
ts.add(LEVEL_LOG, period_min.toInt() * 1000 * 60, [&](void*) {
|
|
deleteOldDate("log.level.txt", jsonReadtoInt(optionJson, "level_logging_count"), jsonRead(configJson, "level"), false);
|
|
}, nullptr, true);
|
|
}
|
|
|
|
if (sensor_name == "dallas") {
|
|
flagLoggingDallas = true;
|
|
ts.remove(DALLAS_LOG);
|
|
ts.add(DALLAS_LOG, period_min.toInt() * 1000 * 60, [&](void*) {
|
|
deleteOldDate("log.dallas.txt", jsonReadtoInt(optionJson, "dallas_logging_count"), jsonRead(configJson, "dallas"), false);
|
|
}, nullptr, true);
|
|
}
|
|
|
|
if (sensor_name == "ph") {
|
|
flagLoggingPh = true;
|
|
ts.remove(PH_LOG);
|
|
ts.add(PH_LOG, period_min.toInt() * 1000 * 60, [&](void*) {
|
|
deleteOldDate("log.ph.txt", jsonReadtoInt(optionJson, "ph_logging_count"), jsonRead(configJson, "ph"), false);
|
|
}, nullptr, true);
|
|
}
|
|
}
|
|
|
|
void deleteOldDate(String file, int seted_number_of_lines, String date_to_add, boolean date_time) {
|
|
|
|
String current_time;
|
|
|
|
if (date_time) {
|
|
current_time = GetDataDigital() + " " + GetTimeWOsec();
|
|
current_time.replace(".", "");
|
|
current_time.replace(":", "");
|
|
} else {
|
|
current_time = "";
|
|
}
|
|
|
|
String log_date = readFile(file, 5000);
|
|
getMemoryLoad("[i] after logging procedure");
|
|
|
|
//предел количества строк 255
|
|
|
|
log_date.replace("\r\n", "\n");
|
|
log_date.replace("\r", "\n");
|
|
|
|
int current_number_of_lines = count(log_date, "\n");
|
|
Serial.println("[i] in log file " + file + " " + current_number_of_lines + " lines");
|
|
|
|
|
|
if (current_number_of_lines > seted_number_of_lines + 1) {
|
|
SPIFFS.remove("/" + file);
|
|
current_number_of_lines = 0;
|
|
}
|
|
if (current_number_of_lines == 0) {
|
|
SPIFFS.remove("/" + file);
|
|
current_number_of_lines = 0;
|
|
}
|
|
if (current_number_of_lines > seted_number_of_lines) {
|
|
log_date = deleteBeforeDelimiter(log_date, "\n");
|
|
log_date += current_time + " " + date_to_add + "\n";
|
|
writeFile(file, log_date);
|
|
|
|
} else {
|
|
if (date_time) {
|
|
addFile(file, current_time + " " + date_to_add);
|
|
} else {
|
|
addFile(file, date_to_add);
|
|
}
|
|
}
|
|
}
|