From bd09b9d570c335bd3199f9b0a4336d4fbd7820e9 Mon Sep 17 00:00:00 2001 From: jens Date: Fri, 6 Feb 2026 16:49:21 +0100 Subject: [PATCH] start --- .vscode/extensions.json | 10 + platformio.ini | 34 ++++ src/main.cpp | 401 ++++++++++++++++++++++++++++++++++++++++ 3 files changed, 445 insertions(+) create mode 100644 .vscode/extensions.json create mode 100644 platformio.ini create mode 100644 src/main.cpp diff --git a/.vscode/extensions.json b/.vscode/extensions.json new file mode 100644 index 0000000..080e70d --- /dev/null +++ b/.vscode/extensions.json @@ -0,0 +1,10 @@ +{ + // See http://go.microsoft.com/fwlink/?LinkId=827846 + // for the documentation about the extensions.json format + "recommendations": [ + "platformio.platformio-ide" + ], + "unwantedRecommendations": [ + "ms-vscode.cpptools-extension-pack" + ] +} diff --git a/platformio.ini b/platformio.ini new file mode 100644 index 0000000..eceffa0 --- /dev/null +++ b/platformio.ini @@ -0,0 +1,34 @@ +; PlatformIO Project Configuration File +; +; Build options: build flags, source filter +; Upload options: custom upload port, speed and extra flags +; Library options: dependencies, extra library storages +; Advanced options: extra scripting +; +; Please visit documentation for the other options and examples +; https://docs.platformio.org/page/projectconf.html + +[env:esp32dev] +platform = espressif32 +board = esp32dev +framework = arduino +# Libraries hier eintragen: +lib_deps = + knolleary/PubSubClient @ ^2.8 + arduino-libraries/NTPClient @ ^3.2.1 + bblanchon/ArduinoJson @ ^6.21.3 +# SERIAL MONITOR EINSTELLUNGEN: +monitor_speed = 115200 # Baudrate +monitor_port = COM9 # Port festlegen +monitor_filters = # Filter aktivieren + colorize # Farbige Ausgabe + esp32_exception_decoder # ESP32 Fehler dekodieren + log2file # In Datei speichern + time # Zeitstempel + default # Standardfilter +monitor_rts = 0 # RTS deaktivieren +monitor_dtr = 0 # DTR deaktivieren +monitor_echo = yes # Eingaben anzeigen +monitor_raw = no # Raw-Mode +monitor_encoding = utf8 # Encoding +monitor_rx_timeout = 3 # Timeout in Sekunden diff --git a/src/main.cpp b/src/main.cpp new file mode 100644 index 0000000..681cb95 --- /dev/null +++ b/src/main.cpp @@ -0,0 +1,401 @@ +#include +#include +#include +#include +#include +#include +#include + +// =================== HARDWARE KONFIGURATION =================== +// WICHTIG: Dein KY-025 ist INVERTIERT (HIGH bei Magnet, LOW ohne Magnet) +#define REED_PIN 4 // GPIO4 (funktioniert gut mit Pullup) +const float PULSES_PER_M3 = 100.0; // Anpassen: Wie viele Impulse pro m³? + +// =================== NETZWERK KONFIGURATION =================== +const char* SSID = "pipanet"; +const char* PASS = "passatvr6"; + +// =================== MQTT KONFIGURATION =================== +const char* MQTT_SERVER = "192.168.2.173"; +const char* STATE_TOPIC = "homeassistant/sensor/gaszahler/state"; +const char* COMMAND_TOPIC = "homeassistant/sensor/gaszahler/set"; +const char* CONFIG_TOPIC = "homeassistant/sensor/gaszahler/config"; +const char* AVAILABILITY_TOPIC = "homeassistant/sensor/gaszahler/status"; + +// =================== GLOBALE VARIABLEN =================== +// volatile für Interrupt-Sicherheit +volatile unsigned long totalPulses = 0; +volatile unsigned long dailyPulses = 0; +volatile bool lastReedState = false; +volatile unsigned long lastPulseTime = 0; +volatile bool pulseFlag = false; // Für sichere Hauptschleife-Verarbeitung + +const unsigned long DEBOUNCE_MS = 50; // Entprellzeit +const unsigned long MIN_PULSE_GAP = 100; // Minimaler Impulsabstand (ms) +const int EEPROM_SIZE = 128; + +// =================== OBJEKTE =================== +WiFiUDP ntpUDP; +NTPClient timeClient(ntpUDP, "pool.ntp.org", 3600, 60000); // UTC+1, Update alle 60s +WiFiClient wifiClient; +PubSubClient mqtt(wifiClient); + +// =================== EEPROM FUNKTIONEN =================== +void saveToEEPROM() { + EEPROM.begin(EEPROM_SIZE); + + // Magic Number zum Erkennen von gültigen Daten + EEPROM.put(0, 0xABCD1234); + + // Daten speichern + EEPROM.put(4, totalPulses); + EEPROM.put(8, dailyPulses); + + // CRC-Prüfsumme + uint32_t crc = totalPulses ^ dailyPulses ^ 0x55AA55AA; + EEPROM.put(12, crc); + + EEPROM.commit(); + EEPROM.end(); + + Serial.printf("EEPROM gespeichert: Total=%lu, Daily=%lu\n", totalPulses, dailyPulses); +} + +void loadFromEEPROM() { + EEPROM.begin(EEPROM_SIZE); + + // Magic Number prüfen + uint32_t magic; + EEPROM.get(0, magic); + + if (magic == 0xABCD1234) { + // Daten laden + EEPROM.get(4, totalPulses); + EEPROM.get(8, dailyPulses); + + // CRC prüfen + uint32_t storedCRC, calculatedCRC; + EEPROM.get(12, storedCRC); + calculatedCRC = totalPulses ^ dailyPulses ^ 0x55AA55AA; + + if (storedCRC == calculatedCRC) { + Serial.printf("EEPROM geladen: Total=%lu (%.2f m³), Daily=%lu (%.2f m³)\n", + totalPulses, totalPulses / PULSES_PER_M3, + dailyPulses, dailyPulses / PULSES_PER_M3); + } else { + Serial.println("EEPROM CRC Fehler - Reset auf 0"); + totalPulses = 0; + dailyPulses = 0; + } + } else { + Serial.println("Keine gültigen EEPROM-Daten gefunden"); + totalPulses = 0; + dailyPulses = 0; + } + + EEPROM.end(); +} + +// =================== INTERRUPT HANDLER =================== +void IRAM_ATTR handleReedInterrupt() { + unsigned long now = millis(); + + // Hardware-Entprellung und Mindestabstand + if (now - lastPulseTime < MIN_PULSE_GAP) { + return; // Zu schnelle Impulse ignorieren + } + + bool currentState = digitalRead(REED_PIN); + + // WICHTIG: Dein Sensor ist INVERTIERT! + // HIGH = Magnet vorhanden (Zähler im Ruhezustand) + // LOW = Magnet weg (Zähler bewegt sich -> Impuls) + + if (currentState == LOW && lastReedState == HIGH) { + // Flanke von HIGH nach LOW = Magnet wurde entfernt = Zähler bewegt sich + pulseFlag = true; // Für Hauptschleife + lastPulseTime = now; + } + + lastReedState = currentState; +} + +// =================== MQTT FUNKTIONEN =================== +void sendHAConfig() { + StaticJsonDocument<512> config; + + // Gerätekonfiguration + JsonObject device = config.createNestedObject("device"); + device["identifiers"][0] = String("gasmeter_") + String((uint32_t)ESP.getEfuseMac(), HEX); + device["name"] = "Gas Zähler"; + device["manufacturer"] = "DIY"; + device["model"] = "ESP32 + KY-025"; + device["sw_version"] = "2.0"; + + // Totale Gasmenge + config["name"] = "Gas Verbrauch Total"; + config["unique_id"] = String("gasmeter_total_") + String((uint32_t)ESP.getEfuseMac(), HEX); + config["state_topic"] = STATE_TOPIC; + config["unit_of_meas"] = "m³"; + config["device_class"] = "gas"; + config["state_class"] = "total_increasing"; + config["value_template"] = "{{ value_json.total_m3 }}"; + config["availability_topic"] = AVAILABILITY_TOPIC; + config["payload_available"] = "online"; + config["payload_not_available"] = "offline"; + config["json_attributes_topic"] = STATE_TOPIC; + + char buffer[512]; + serializeJson(config, buffer); + mqtt.publish(CONFIG_TOPIC, buffer, true); + Serial.println("Home Assistant Config gesendet"); +} + +void sendMQTTData() { + StaticJsonDocument<256> doc; + + // Berechnungen + float total_m3 = totalPulses / PULSES_PER_M3; + float daily_m3 = dailyPulses / PULSES_PER_M3; + float hourly_m3 = daily_m3 / 24.0; // Vereinfachte Annahme + + // Hauptwerte + doc["total_m3"] = total_m3; + doc["daily_m3"] = daily_m3; + doc["hourly_m3"] = hourly_m3; + doc["total_pulses"] = totalPulses; + + // Zusätzliche Info + doc["pulses_per_m3"] = PULSES_PER_M3; + doc["timestamp"] = timeClient.getFormattedTime(); + doc["uptime"] = millis() / 1000; + doc["rssi"] = WiFi.RSSI(); + + char output[256]; + serializeJson(doc, output); + + if (mqtt.publish(STATE_TOPIC, output, true)) { + Serial.printf("MQTT gesendet: %.3f m³ total, %.3f m³ heute\n", total_m3, daily_m3); + } else { + Serial.println("MQTT Sendefehler!"); + } +} + +void mqttCallback(char* topic, byte* payload, unsigned int length) { + char message[length + 1]; + memcpy(message, payload, length); + message[length] = '\0'; + + Serial.printf("MQTT Callback: Topic=%s, Message=%s\n", topic, message); + + if (String(topic) == COMMAND_TOPIC) { + if (strcmp(message, "reset_total") == 0) { + totalPulses = 0; + saveToEEPROM(); + Serial.println("Totalzähler zurückgesetzt"); + } + else if (strcmp(message, "reset_daily") == 0) { + dailyPulses = 0; + saveToEEPROM(); + Serial.println("Tageszähler zurückgesetzt"); + } + else if (strcmp(message, "restart") == 0) { + Serial.println("Neustart via MQTT..."); + ESP.restart(); + } + + // Sofortige Bestätigung senden + sendMQTTData(); + } +} + +void reconnectMQTT() { + static unsigned long lastAttempt = 0; + + if (!mqtt.connected()) { + if (millis() - lastAttempt > 5000) { + Serial.print("Verbinde mit MQTT..."); + + // Client ID mit MAC-Adresse für Eindeutigkeit + String clientId = "GasMeter-" + String((uint32_t)ESP.getEfuseMac(), HEX); + + if (mqtt.connect(clientId.c_str(), AVAILABILITY_TOPIC, 1, true, "offline")) { + Serial.println("verbunden!"); + + // Verfügbarkeit melden + mqtt.publish(AVAILABILITY_TOPIC, "online", true); + + // Topics abonnieren + mqtt.subscribe(COMMAND_TOPIC); + + // Config an HA senden + sendHAConfig(); + + // Sofort Daten senden + sendMQTTData(); + } else { + Serial.printf("fehlgeschlagen, rc=%d\n", mqtt.state()); + } + lastAttempt = millis(); + } + } +} + +// =================== TAGESRESET =================== +void checkDailyReset() { + static int lastDay = -1; + + timeClient.update(); + int currentDay = timeClient.getDay(); + + if (lastDay != -1 && currentDay != lastDay) { + Serial.println("Neuer Tag - Tageszähler wird zurückgesetzt"); + dailyPulses = 0; + saveToEEPROM(); + + // Sofort MQTT Update + if (mqtt.connected()) { + sendMQTTData(); + } + } + + lastDay = currentDay; +} + +// =================== WATCHDOG & ÜBERWACHUNG =================== +void setupWatchdog() { + // Task Watchdog für Hauptschleife (5 Sekunden) + esp_task_wdt_init(5, true); + esp_task_wdt_add(NULL); +} + +// =================== SETUP =================== +void setup() { + Serial.begin(115200); + delay(1000); + + Serial.println("\n================================="); + Serial.println(" ESP32 Gaszähler v2.0"); + Serial.println("================================="); + Serial.printf("Chip-ID: %08X\n", (uint32_t)ESP.getEfuseMac()); + Serial.printf("Free Heap: %d bytes\n", ESP.getFreeHeap()); + + // EEPROM Daten laden + loadFromEEPROM(); + + // Reed-Sensor initialisieren + pinMode(REED_PIN, INPUT_PULLUP); + + // Initialen Zustand lesen (INVERTIERT!) + lastReedState = digitalRead(REED_PIN); + Serial.printf("Startzustand Reed-Pin: %s\n", + lastReedState ? "HIGH (Magnet vorhanden)" : "LOW (kein Magnet)"); + + // Interrupt konfigurieren + attachInterrupt(digitalPinToInterrupt(REED_PIN), handleReedInterrupt, CHANGE); + Serial.println("Interrupt aktiviert (CHANGE)"); + + // WiFi verbinden + Serial.print("Verbinde mit WiFi"); + WiFi.begin(SSID, PASS); + WiFi.setSleep(false); // Bessere Stabilität + + unsigned long wifiTimeout = millis() + 30000; + while (WiFi.status() != WL_CONNECTED && millis() < wifiTimeout) { + delay(500); + Serial.print("."); + } + + if (WiFi.status() == WL_CONNECTED) { + Serial.println("\nWiFi verbunden!"); + Serial.printf("IP: %s, RSSI: %d dBm\n", + WiFi.localIP().toString().c_str(), WiFi.RSSI()); + } else { + Serial.println("\nWiFi Fehler - im Offline-Modus"); + } + + // NTP Client + timeClient.begin(); + timeClient.update(); + Serial.printf("NTP Zeit: %s\n", timeClient.getFormattedTime().c_str()); + + // MQTT Client + mqtt.setServer(MQTT_SERVER, 1883); + mqtt.setCallback(mqttCallback); + mqtt.setBufferSize(512); + mqtt.setKeepAlive(30); + + // Watchdog + setupWatchdog(); + + Serial.println("Setup abgeschlossen!"); + Serial.println("=================================\n"); +} + +// =================== HAUPTLOOP =================== +void loop() { + static unsigned long lastMQTTSend = 0; + static unsigned long lastSerialOutput = 0; + static unsigned long lastStateCheck = 0; + + // Watchdog füttern + esp_task_wdt_reset(); + + // Impulse in Hauptschleife verarbeiten (thread-sicher) + if (pulseFlag) { + // Warte kurze Zeit für Stabilität + delay(1); + + // Nochmal prüfen (Entprellung) + if (digitalRead(REED_PIN) == LOW) { + totalPulses++; + dailyPulses++; + + Serial.printf("[IMPULS] Total: %lu (%.3f m³), Heute: %lu (%.3f m³)\n", + totalPulses, totalPulses / PULSES_PER_M3, + dailyPulses, dailyPulses / PULSES_PER_M3); + + // Bei jedem Impuls speichern (für maximale Datenintegrität) + saveToEEPROM(); + + // Sofort MQTT Update bei aktivem Impuls + if (mqtt.connected() && (millis() - lastMQTTSend > 1000)) { + sendMQTTData(); + lastMQTTSend = millis(); + } + } + + pulseFlag = false; + } + + // Netzwerk Updates + if (WiFi.status() == WL_CONNECTED) { + timeClient.update(); + mqtt.loop(); + reconnectMQTT(); + checkDailyReset(); + } + + // Regelmäßiges MQTT Update (alle 30 Sekunden) + if (mqtt.connected() && (millis() - lastMQTTSend > 30000)) { + sendMQTTData(); + lastMQTTSend = millis(); + } + + // Serieller Status (alle 60 Sekunden) + if (millis() - lastSerialOutput > 60000) { + Serial.printf("[STATUS] Heap: %d, Uptime: %lu s, RSSI: %d dBm\n", + ESP.getFreeHeap(), millis() / 1000, WiFi.RSSI()); + lastSerialOutput = millis(); + } + + // Reed-Pin Status prüfen (Debug, alle 10s) + if (millis() - lastStateCheck > 10000) { + bool currentState = digitalRead(REED_PIN); + Serial.printf("[SENSOR] Pin: %s\n", + currentState ? "HIGH (Magnet da)" : "LOW (Magnet weg)"); + lastStateCheck = millis(); + } + + delay(10); // Kleine Pause für Stabilität +} \ No newline at end of file