routes_config.cpp

См. документацию.

 
#include "../../include/web_routes.h"
#include "../../include/jxct_config_vars.h"
#include "../../include/jxct_ui_system.h"
#include "../../include/jxct_device_info.h"
#include "../../include/logger.h"
#include "../wifi_manager.h"
#include <ArduinoJson.h>
#include "../../include/jxct_strings.h"
 
extern WebServer webServer;
extern WiFiMode currentWiFiMode;
 
// Объявления внешних функций
extern String navHtml();
extern void loadConfig();
extern void saveConfig();
 
// --- API v1 helpers ---
static void sendConfigExportJson();
 
void setupConfigRoutes()
{
    // Красивая страница интервалов и фильтров (оригинальный дизайн)
    webServer.on(
        "/intervals", HTTP_GET,
        []()
        {
            logWebRequest("GET", "/intervals", webServer.client().remoteIP().toString());
 
            if (currentWiFiMode == WiFiMode::AP)
            {
                webServer.send(200, "text/html; charset=utf-8", generateApModeUnavailablePage("Интервалы", UI_ICON_INTERVALS));
                return;
            }
 
            String html = generatePageHeader("Интервалы и фильтры", UI_ICON_INTERVALS);
            html += navHtml();
            html += "<h1>" UI_ICON_INTERVALS " Настройка интервалов и фильтров</h1>";
            html += "<form action='/save_intervals' method='post'>";
 
            html += "<div class='section'><h2>📊 Интервалы опроса и публикации</h2>";
            html += "<div class='form-group'><label for='sensor_interval'>Интервал опроса датчика (сек):</label>";
            html += "<input type='number' id='sensor_interval' name='sensor_interval' min='1' max='300' value='" +
                    String(config.sensorReadInterval / 1000) + "' required>";
            html += "<div class='help'>1-300 сек. Текущее: " + String(config.sensorReadInterval / 1000) +
                    " сек (по умолчанию: 1 сек)</div></div>";
 
            html += "<div class='form-group'><label for='mqtt_interval'>Интервал MQTT публикации (мин):</label>";
            html += "<input type='number' id='mqtt_interval' name='mqtt_interval' min='1' max='60' value='" +
                    String(config.mqttPublishInterval / 60000) + "' required>";
            html += "<div class='help'>1-60 мин. Текущее: " + String(config.mqttPublishInterval / 60000) +
                    " мин</div></div>";
 
            html += "<div class='form-group'><label for='ts_interval'>Интервал ThingSpeak (мин):</label>";
            html += "<input type='number' id='ts_interval' name='ts_interval' min='5' max='120' value='" +
                    String(config.thingSpeakInterval / 60000) + "' required>";
            html += "<div class='help'>5-120 мин. Текущее: " + String(config.thingSpeakInterval / 60000) +
                    " мин</div></div>";
 
            html +=
                "<div class='form-group'><label for='web_interval'>Интервал обновления веб-интерфейса (сек):</label>";
            html += "<input type='number' id='web_interval' name='web_interval' min='5' max='60' value='" +
                    String(config.webUpdateInterval / 1000) + "' required>";
            html += "<div class='help'>5-60 сек. Текущее: " + String(config.webUpdateInterval / 1000) +
                    " сек</div></div></div>";
 
            html += "<div class='section'><h2>🎯 Пороги дельта-фильтра</h2>";
            html += "<div class='form-group'><label for='delta_temp'>Порог температуры (°C):</label>";
            html += "<input type='number' id='delta_temp' name='delta_temp' min='0.1' max='5.0' step='0.1' value='" +
                    String(config.deltaTemperature) + "' required>";
            html += "<div class='help'>0.1-5.0°C. Публикация при изменении более чем на это значение</div></div>";
 
            html += "<div class='form-group'><label for='delta_hum'>Порог влажности (%):</label>";
            html += "<input type='number' id='delta_hum' name='delta_hum' min='0.5' max='10.0' step='0.5' value='" +
                    String(config.deltaHumidity) + "' required>";
            html += "<div class='help'>0.5-10.0%. Публикация при изменении более чем на это значение</div></div>";
 
            html += "<div class='form-group'><label for='delta_ph'>Порог pH:</label>";
            html += "<input type='number' id='delta_ph' name='delta_ph' min='0.01' max='1.0' step='0.01' value='" +
                    String(config.deltaPh) + "' required>";
            html += "<div class='help'>0.01-1.0. Публикация при изменении более чем на это значение</div></div>";
 
            html += "<div class='form-group'><label for='delta_ec'>Порог EC (µS/cm):</label>";
            html += "<input type='number' id='delta_ec' name='delta_ec' min='10' max='500' value='" +
                    String((int)config.deltaEc) + "' required>";
            html += "<div class='help'>10-500 µS/cm. Публикация при изменении более чем на это значение</div></div>";
 
            html += "<div class='form-group'><label for='delta_npk'>Порог NPK (mg/kg):</label>";
            html += "<input type='number' id='delta_npk' name='delta_npk' min='1' max='50' value='" +
                    String((int)config.deltaNpk) + "' required>";
            html +=
                "<div class='help'>1-50 mg/kg. Публикация при изменении более чем на это значение</div></div></div>";
 
            html += "<div class='section'><h2>📈 Скользящее среднее</h2>";
            html += "<div class='form-group'><label for='avg_window'>Размер окна усреднения:</label>";
            html += "<input type='number' id='avg_window' name='avg_window' min='5' max='15' value='" +
                    String(config.movingAverageWindow) + "' required>";
            html += "<div class='help'>5-15 измерений. Больше = плавнее, но медленнее реакция</div></div>";
 
            html += "<div class='form-group'><label for='force_cycles'>Принудительная публикация (циклов):</label>";
            html += "<input type='number' id='force_cycles' name='force_cycles' min='5' max='50' value='" +
                    String(config.forcePublishCycles) + "' required>";
            html += "<div class='help'>5-50 циклов. Публикация каждые N циклов даже без изменений</div></div>";
 
            // Новые настройки алгоритма и фильтра выбросов
            html += "<div class='form-group'><label for='filter_algo'>Алгоритм обработки данных:</label>";
            html += "<select id='filter_algo' name='filter_algo' required>";
            html += "<option value='0'" + String(config.filterAlgorithm == 0 ? " selected" : "") +
                    ">Среднее арифметическое</option>";
            html += "<option value='1'" + String(config.filterAlgorithm == 1 ? " selected" : "") +
                    ">Медианное значение</option>";
            html += "</select>";
            html += "<div class='help'>Среднее - быстрее, медиана - устойчивее к выбросам</div></div>";
 
            html += "<div class='form-group'><label for='outlier_filter'>Фильтр выбросов >2σ:</label>";
            html += "<select id='outlier_filter' name='outlier_filter' required>";
            html += "<option value='0'" + String(config.outlierFilterEnabled == 0 ? " selected" : "") +
                    ">Отключен</option>";
            html +=
                "<option value='1'" + String(config.outlierFilterEnabled == 1 ? " selected" : "") + ">Включен</option>";
            html += "</select>";
            html +=
                "<div class='help'>Автоматически отбрасывает измерения, отклоняющиеся более чем на 2 "
                "сигма</div></div></div>";
 
            html += generateButton(ButtonType::PRIMARY, UI_ICON_SAVE, "Сохранить настройки", "");
            html +=
                generateButton(ButtonType::SECONDARY, UI_ICON_RESET, "Сбросить к умолчанию (1 сек + мин. фильтрация)",
                               "location.href='/reset_intervals'");
            html += "</form>";
            html += generatePageFooter();
 
            webServer.send(200, "text/html; charset=utf-8", html);
        });
 
    // Обработчик сохранения настроек интервалов
    webServer.on("/save_intervals", HTTP_POST,
                 []()
                 {
                     logWebRequest("POST", "/save_intervals", webServer.client().remoteIP().toString());
 
                     if (currentWiFiMode == WiFiMode::AP)
                     {
                         webServer.send(403, "text/plain", "Недоступно в режиме точки доступа");
                         return;
                     }
 
                     // Сохраняем интервалы (с конвертацией в миллисекунды)
                     config.sensorReadInterval = webServer.arg("sensor_interval").toInt() * 1000;  // сек -> мс
                     config.mqttPublishInterval = webServer.arg("mqtt_interval").toInt() * 60000;  // мин -> мс
                     config.thingSpeakInterval = webServer.arg("ts_interval").toInt() * 60000;     // мин -> мс
                     config.webUpdateInterval = webServer.arg("web_interval").toInt() * 1000;      // сек -> мс
 
                     // Сохраняем пороги дельта-фильтра
                     config.deltaTemperature = webServer.arg("delta_temp").toFloat();
                     config.deltaHumidity = webServer.arg("delta_hum").toFloat();
                     config.deltaPh = webServer.arg("delta_ph").toFloat();
                     config.deltaEc = webServer.arg("delta_ec").toFloat();
                     config.deltaNpk = webServer.arg("delta_npk").toFloat();
 
                     // Сохраняем настройки скользящего среднего
                     config.movingAverageWindow = webServer.arg("avg_window").toInt();
                     config.forcePublishCycles = webServer.arg("force_cycles").toInt();
 
                     // Сохраняем новые настройки алгоритма и фильтра выбросов
                     config.filterAlgorithm = webServer.arg("filter_algo").toInt();
                     config.outlierFilterEnabled = webServer.arg("outlier_filter").toInt();
 
                     // Сохраняем в NVS
                     saveConfig();
 
                     String html =
                         "<!DOCTYPE html><html><head><meta charset='UTF-8'><meta http-equiv='refresh' "
                         "content='3;url=/intervals'>";
                     html += "<title>" UI_ICON_SUCCESS " Настройки сохранены</title>";
                     html += "<style>" + String(getUnifiedCSS()) + "</style></head><body><div class='container'>";
                     html += "<h1>" UI_ICON_SUCCESS " Настройки интервалов сохранены!</h1>";
                     html += "<div class='msg msg-success'>" UI_ICON_SUCCESS " Новые настройки вступили в силу</div>";
                     html += "<p><strong>Текущие интервалы:</strong><br>";
                     html += "📊 Датчик: " + String(config.sensorReadInterval / 1000) + " сек<br>";
                     html += "📡 MQTT: " + String(config.mqttPublishInterval / 60000) + " мин<br>";
                     html += "📈 ThingSpeak: " + String(config.thingSpeakInterval / 60000) + " мин</p>";
                     html += "<p><em>Возврат к настройкам через 3 секунды...</em></p>";
                     html += "</div>" + String(getToastHTML()) + "</body></html>";
                     webServer.send(200, "text/html; charset=utf-8", html);
                 });
 
    // Сброс интервалов к умолчанию
    webServer.on("/reset_intervals", HTTP_GET,
                 []()
                 {
                     logWebRequest("GET", "/reset_intervals", webServer.client().remoteIP().toString());
 
                     if (currentWiFiMode == WiFiMode::AP)
                     {
                         webServer.send(403, "text/plain", "Недоступно в режиме точки доступа");
                         return;
                     }
 
                     // Сбрасываем к умолчанию (МИНИМАЛЬНАЯ ФИЛЬТРАЦИЯ + ЧАСТЫЙ MQTT)
                     config.sensorReadInterval = SENSOR_READ_INTERVAL;
                     config.mqttPublishInterval = MQTT_PUBLISH_INTERVAL;
                     config.thingSpeakInterval = THINGSPEAK_INTERVAL;
                     config.webUpdateInterval = WEB_UPDATE_INTERVAL;
                     config.deltaTemperature = DELTA_TEMPERATURE;       // 0.1°C
                     config.deltaHumidity = DELTA_HUMIDITY;             // 0.5%
                     config.deltaPh = DELTA_PH;                         // 0.01 pH
                     config.deltaEc = DELTA_EC;                         // 10 µS/cm
                     config.deltaNpk = DELTA_NPK;                       // 1 mg/kg
                     config.movingAverageWindow = 5;                    // минимальное окно
                     config.forcePublishCycles = FORCE_PUBLISH_CYCLES;  // каждые 5 циклов
                     config.filterAlgorithm = 0;                        // среднее
                     config.outlierFilterEnabled = 0;                   // отключен
 
                     saveConfig();
 
                     String html =
                         "<!DOCTYPE html><html><head><meta charset='UTF-8'><meta http-equiv='refresh' "
                         "content='2;url=/intervals'>";
                     html += "<title>" UI_ICON_RESET " Сброс настроек</title>";
                     html += "<style>" + String(getUnifiedCSS()) + "</style></head><body><div class='container'>";
                     html += "<h1>" UI_ICON_RESET " Настройки сброшены</h1>";
                     html += "<div class='msg msg-success'>" UI_ICON_SUCCESS
                             " Настройки интервалов возвращены к значениям по умолчанию</div>";
                     html += "<p><em>Возврат к настройкам через 2 секунды...</em></p>";
                     html += "</div>" + String(getToastHTML()) + "</body></html>";
                     webServer.send(200, "text/html; charset=utf-8", html);
                 });
 
    // Страница управления конфигурацией
    webServer.on("/config_manager", HTTP_GET,
                 []()
                 {
                     logWebRequest("GET", "/config_manager", webServer.client().remoteIP().toString());
 
                     if (currentWiFiMode == WiFiMode::AP)
                     {
                         String html = "<!DOCTYPE html><html><head><meta charset='UTF-8'><title>" UI_ICON_FOLDER
                                       " Конфигурация</title>";
                         html += "<style>" + String(getUnifiedCSS()) + "</style></head><body><div class='container'>";
                         html += "<h1>" UI_ICON_FOLDER " Конфигурация</h1>";
                         html += "<div class='msg msg-error'>" UI_ICON_ERROR
                                 " Недоступно в режиме точки доступа</div></div></body></html>";
                         webServer.send(200, "text/html; charset=utf-8", html);
                         return;
                     }
 
                     String html =
                         "<!DOCTYPE html><html><head><meta charset='UTF-8'><meta name='viewport' "
                         "content='width=device-width, initial-scale=1.0'>";
                     html += "<title>" UI_ICON_FOLDER " Управление конфигурацией JXCT</title>";
                     html += "<style>" + String(getUnifiedCSS()) + "</style></head><body><div class='container'>";
                     html += navHtml();
                     html += "<h1>" UI_ICON_FOLDER " Управление конфигурацией</h1>";
 
                     if (webServer.hasArg("import_ok")) {
                         html += "<div class='msg msg-success'>✅ Конфигурация успешно импортирована и сохранена</div>";
                     }
 
                     html += "<div class='section'>";
                     html += "<h2>📤 Экспорт конфигурации</h2>";
                     html += "<p>Скачайте текущую конфигурацию в формате JSON (пароли заменены на заглушки):</p>";
                     html += generateButton(ButtonType::PRIMARY, "📥", "Скачать конфигурацию",
                                            "location.href='/api/v1/config/export'");
                     html += "</div>";
 
                     html += "<div class='section'>";
                     html += "<h2>📥 Импорт конфигурации</h2>";
                     html += "<p>Загрузите файл конфигурации для восстановления настроек:</p>";
                     html += "<form action='/api/config/import' method='post' enctype='multipart/form-data'>";
                     html += "<input type='file' name='config' accept='.json' required>";
                     html += generateButton(ButtonType::SECONDARY, "📤", "Загрузить конфигурацию", "");
                     html += "</form>";
                     html += "</div>";
 
                     html += "</div>" + String(getToastHTML()) + "</body></html>";
                     webServer.send(200, "text/html; charset=utf-8", html);
                 });
 
    // API v1 конфигурация
    webServer.on(API_CONFIG_EXPORT, HTTP_GET, sendConfigExportJson);
 
    // Импорт конфигурации через multipart/form-data (файл JSON)
    static String importedJson;
    webServer.on(
        "/api/config/import", HTTP_POST,
        // Финальный обработчик после загрузки
        []()
        {
            logWebRequest("POST", "/api/config/import", webServer.client().remoteIP().toString());
 
            if (currentWiFiMode == WiFiMode::AP)
            {
                webServer.send(403, "application/json", "{\"error\":\"Недоступно в режиме AP\"}");
                importedJson = "";
                return;
            }
 
            // Парсим накопленный JSON
            StaticJsonDocument<2048> doc;
            DeserializationError err = deserializeJson(doc, importedJson);
            if (err)
            {
                String resp = String("{\"error\":\"Ошибка JSON: ") + err.c_str() + "\"}";
                webServer.send(400, "application/json", resp);
                importedJson = "";
                return;
            }
 
            // --- Применяем конфигурацию --- (минимальный набор, расширяйте по необходимости)
            if (doc.containsKey("wifi"))
            {
                JsonObject wifi = doc["wifi"];
                strlcpy(config.ssid, wifi["ssid"].as<const char*>(), sizeof(config.ssid));
                strlcpy(config.password, wifi["password"].as<const char*>(), sizeof(config.password));
            }
 
            if (doc.containsKey("mqtt"))
            {
                JsonObject mqtt = doc["mqtt"];
                config.flags.mqttEnabled = mqtt["enabled"].as<bool>();
                strlcpy(config.mqttServer, mqtt["server"].as<const char*>(), sizeof(config.mqttServer));
                config.mqttPort = mqtt["port"].as<int>();
                strlcpy(config.mqttUser, mqtt["user"].as<const char*>(), sizeof(config.mqttUser));
                strlcpy(config.mqttPassword, mqtt["password"].as<const char*>(), sizeof(config.mqttPassword));
            }
 
            // TODO: обработать intervals, filters, device и др.
 
            saveConfig();
            importedJson = "";
 
            // Отправляем 303 Redirect, чтобы браузер вернулся к менеджеру конфигурации
            webServer.sendHeader("Location", "/config_manager?import_ok=1", true);
            webServer.send(303, "text/plain", "Redirect");
        },
        // uploadHandler: накапливаем файл
        []()
        {
            HTTPUpload& up = webServer.upload();
            if (up.status == UPLOAD_FILE_START)
            {
                importedJson = "";
            }
            else if (up.status == UPLOAD_FILE_WRITE)
            {
                importedJson += String((const char*)up.buf, up.currentSize);
            }
            else if (up.status == UPLOAD_FILE_END)
            {
                // ничего, финальное действие в основном хендлере
            }
        });
 
    logDebug("Маршруты конфигурации настроены: /intervals, /config_manager, /api/v1/config/export");
}
 
// ---------------------------------------------------------------------------
// API v1: /api/v1/config/export
// ---------------------------------------------------------------------------
static void sendConfigExportJson()
{
    logWebRequest("GET", webServer.uri(), webServer.client().remoteIP().toString());
 
    if (currentWiFiMode == WiFiMode::AP)
    {
        webServer.send(403, "application/json", "{\"error\":\"Недоступно в режиме точки доступа\"}");
        return;
    }
 
    StaticJsonDocument<1024> root;
 
    // MQTT
    JsonObject mqtt = root.createNestedObject("mqtt");
    mqtt["enabled"] = (bool)config.flags.mqttEnabled;
    mqtt["server"] = "YOUR_MQTT_SERVER_HERE";
    mqtt["port"] = config.mqttPort;
    mqtt["user"] = "YOUR_MQTT_USER_HERE";
    mqtt["password"] = "YOUR_MQTT_PASSWORD_HERE";
 
    // ThingSpeak
    JsonObject ts = root.createNestedObject("thingspeak");
    ts["enabled"] = (bool)config.flags.thingSpeakEnabled;
    ts["channel_id"] = "YOUR_CHANNEL_ID_HERE";
    ts["api_key"] = "YOUR_API_KEY_HERE";
 
    // Intervals
    JsonObject intervals = root.createNestedObject("intervals");
    intervals["sensor_read"] = config.sensorReadInterval;
    intervals["mqtt_publish"] = config.mqttPublishInterval;
    intervals["thingspeak"] = config.thingSpeakInterval;
    intervals["web_update"] = config.webUpdateInterval;
 
    // Filters
    JsonObject filters = root.createNestedObject("filters");
    filters["delta_temperature"] = config.deltaTemperature;
    filters["delta_humidity"] = config.deltaHumidity;
    filters["delta_ph"] = config.deltaPh;
    filters["delta_ec"] = config.deltaEc;
    filters["delta_npk"] = config.deltaNpk;
    filters["moving_average_window"] = config.movingAverageWindow;
    filters["force_publish_cycles"] = config.forcePublishCycles;
    filters["filter_algorithm"] = config.filterAlgorithm;
    filters["outlier_filter_enabled"] = config.outlierFilterEnabled;
 
    // Device flags
    JsonObject device = root.createNestedObject("device");
    device["use_real_sensor"] = (bool)config.flags.useRealSensor;
    device["hass_enabled"] = (bool)config.flags.hassEnabled;
 
    root["export_timestamp"] = millis();
 
    String json;
    serializeJson(root, json);
 
    webServer.sendHeader("Content-Disposition", "attachment; filename=\"jxct_config_" + String(millis()) + ".json\"");
    webServer.send(200, "application/json", json);
}