start
This commit is contained in:
commit
bd09b9d570
10
.vscode/extensions.json
vendored
Normal file
10
.vscode/extensions.json
vendored
Normal file
@ -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"
|
||||
]
|
||||
}
|
||||
34
platformio.ini
Normal file
34
platformio.ini
Normal file
@ -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
|
||||
401
src/main.cpp
Normal file
401
src/main.cpp
Normal file
@ -0,0 +1,401 @@
|
||||
#include <WiFi.h>
|
||||
#include <PubSubClient.h>
|
||||
#include <NTPClient.h>
|
||||
#include <WiFiUdp.h>
|
||||
#include <ArduinoJson.h>
|
||||
#include <EEPROM.h>
|
||||
#include <esp_task_wdt.h>
|
||||
|
||||
// =================== 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
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user