ShineBridge v1.8.31 — EMS-Fixes: konfigurierbarer Max-Ladestrom, Zwangsladen-Retry, Fault-State-Handling

- ems_max_current_ma konfigurierbar statt hardcoded 32A (Zwangsladen darf jetzt nicht mehr
  mehr fordern als die tatsächliche Wallbox liefern kann, z.B. 16A bei einer 11kW-Wallbox)
- Zwangsladen setzt den Ladestrom bei jedem Poll erneut (statt nur einmal beim Start) —
  ein einzelner fehlgeschlagener Modbus-Write hängt nicht mehr die ganze Nacht
- Unbekannte/Fehler-Ladezustände (z.B. Fahrzeug-Störung) werden nicht mehr wie 'abgesteckt'
  behandelt — Strom wird pausiert, aber der Zwangslade-Timer bleibt erhalten
- Neues Settings-Feld 'Max. Ladestrom (A)' im EMS-Dialog

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>

.gitignore

@@ -6,3 +6,7 @@ shinelanx-modbus/
 __pycache__/
 *.pyc
 .env
+
+# versehentlich getrackte Alt-Dateien, gehoeren nicht ins Repo
+Modbus-Server-Kathrein.pdf
+ShineLAN-X/releases/*.bin

ROADMAP.md

@@ -97,3 +97,7 @@
 | v1.8.20 | 2026-05-05 | Fix: Eigenversorgungskarte bei PV offline, Stromtarif-Einstellungen gehen nicht verloren |
 | v1.8.21 | 2026-05-05 | Fix: Finanzen-Tab bleibt nicht bei "Lade..." hängen (fEur/fKwh Scope-Bug) |
 | v1.8.22 | 2026-05-06 | Fix: Stromtarif-Einstellungen bleiben nach Neustart erhalten; Finanzen-Tab Layout |
+| v1.8.23 | 2026-05-07 | Fix: Goodwe Netzbezug-Periode zeigt 0 kWh — integrierter grid_power-Zähler statt e_total_imp-Delta |
+| v1.8.24 | 2026-05-07 | Fix: WR/Wallbox-Offline-Flapping — erst nach 3 aufeinanderfolgenden Lesefehlern offline schalten |
+| v1.8.25 | 2026-05-07 | Fix: TCP-Timeout auf max. 40% des Poll-Intervalls begrenzt (Wallbox + Modbus) — verhindert Poll-Überlappung |
+| v1.8.26 | 2026-05-07 | Fix: EMS-Countdown läuft ohne Auto — Kathrein 0x0060 IllegalAddress = kein Fahrzeug (default war fälschlich 1=Connected) |

haos-addon/config.yaml

@@ -1,5 +1,5 @@
 name: ShineBridge
-version: "1.8.22"
+version: "1.8.31"
 slug: shinebridge
 description: Growatt Wechselrichter lokal in Home Assistant — Modbus TCP via ShineLAN-X, MQTT Discovery, Web UI
 url: https://gitea.bitfire.work/retr0/shinebridge

haos-addon/src/ems_controller.py

@@ -23,6 +23,11 @@ TARGET_HOUR      = 6         # Zielstunde: Vollladung bis 06:00
 POLL_INTERVAL_S  = 30        # Sekunden zwischen EMS-Updates
 PHASES           = 3         # Anzahl der Phasen
 VOLTAGE_V        = 230       # Netzspannung
+MAX_CHARGE_MA    = 32000     # Absolutes Wallbox-Limit (Hardware-Grenze WallboxReader).
+                              # ACHTUNG: die tatsächlich installierte Wallbox/Zuleitung kann
+                              # niedriger dimensioniert sein (z.B. 11kW-Wallbox = 16A) — dann
+                              # über max_charge_ma im Konstruktor auf den echten Wert begrenzen,
+                              # sonst fordert das Zwangsladen mehr an als das Gerät liefern kann.
 
 # Charging-State Werte (Kathrein Modbus)
 STATE_IDLE        = 0
@@ -39,11 +44,13 @@ class EmsController:
         pv_timeout_h: float = PV_TIMEOUT_H,
         target_hour: int = TARGET_HOUR,
         phases: int = PHASES,
+        max_charge_ma: int = MAX_CHARGE_MA,
     ):
         self.min_pv_power = min_pv_power
         self.pv_timeout_h = pv_timeout_h
         self.target_hour = target_hour
         self.phases = phases
+        self.max_charge_ma = max_charge_ma
 
         self._pv_ok_since: Optional[float] = None   # Zeitpunkt letzter ausreichender PV
         self._no_pv_since: Optional[float] = None   # Zeitpunkt seit kein PV
@@ -66,7 +73,7 @@ class EmsController:
         total_w = surplus_w + wallbox_w
         current_a = total_w / (VOLTAGE_V * self.phases)
         ma = int(current_a * 1000)
-        return max(6000, min(32000, ma))
+        return max(6000, min(self.max_charge_ma, ma))
 
     def update(self, wallbox_reader, pv_surplus_w: float, charging_state: int,
                wallbox_power_w: float = 0.0) -> str:
@@ -84,8 +91,8 @@ class EmsController:
                 if wallbox_reader.enable_ems():
                     self._ems_enabled = True
                     log.info("[EMS] EMS aktiviert")
-        else:
+        elif charging_state == STATE_IDLE:
-            # Auto weg → alles zurücksetzen
+            # Wirklich kein Fahrzeug angesteckt → alles zurücksetzen, Timer neu starten
             if self._ems_enabled:
                 wallbox_reader.set_current(0)
                 self._ems_enabled = False
@@ -93,6 +100,16 @@ class EmsController:
                 self._no_pv_since = None
                 log.info("[EMS] Auto abgesteckt — EMS zurückgesetzt")
             return "kein Fahrzeug"
+        else:
+            # Unbekannter/nicht abgedeckter Ladezustand (z.B. Fehler/Störung am Fahrzeug).
+            # NICHT wie "abgesteckt" behandeln — sonst verliert der Zwangslade-Timer seinen
+            # Fortschritt und die Deadline (Zielzeit) wird nie mehr erreicht, obwohl das Auto
+            # die ganze Zeit angesteckt war. Strom sicherheitshalber pausieren, aber Zustand/
+            # Timer erhalten, damit nach Rückkehr in einen bekannten Zustand nahtlos weitergeht.
+            wallbox_reader.set_current(0)
+            log.warning("[EMS] Unbekannter Ladezustand %d (evtl. Störung am Fahrzeug) — "
+                        "Strom pausiert, Zwangslade-Timer bleibt erhalten", charging_state)
+            return f"unbekannter Zustand ({charging_state})"
 
         if charging_state == STATE_COMPLETED:
             wallbox_reader.set_current(0)
@@ -116,13 +133,16 @@ class EmsController:
         no_pv_h = (now - self._no_pv_since) / 3600.0
 
         if no_pv_h >= self.pv_timeout_h:
-            # Zwangsladen bis Zielzeit
+            # Zwangsladen bis Zielzeit — Strom bei JEDEM Update erneut setzen (nicht nur beim
+            # ersten Eintritt), sonst bleibt ein einzelner fehlgeschlagener/verworfener Write
+            # (Modbus-Hänger, Fahrzeug-Störung) unbemerkt für den Rest der Nacht stehen.
             target = self._next_target()
             mins_left = (target - datetime.now()).total_seconds() / 60
             if not self._forced_charging:
-                wallbox_reader.set_current(32000, self.phases)
                 self._forced_charging = True
-                log.info("[EMS] Zwangsladen gestartet — %dmin bis %02d:00", int(mins_left), self.target_hour)
+                log.info("[EMS] Zwangsladen gestartet — %dmin bis %02d:00, max %.0fA",
+                          int(mins_left), self.target_hour, self.max_charge_ma / 1000)
+            wallbox_reader.set_current(self.max_charge_ma, self.phases)
             return f"Zwangsladen ({no_pv_h:.1f}h kein PV, {int(mins_left)}min bis {self.target_hour:02d}:00)"
 
         # Warten auf PV

haos-addon/src/history.py

@@ -7,7 +7,7 @@ from typing import Dict, List, Optional, Tuple
 log = logging.getLogger(__name__)
 
 DB_PATH = "/data/history.db"
-RETENTION_DAYS = 7
+RETENTION_DAYS = 14
 
 _lock = threading.Lock()
 _conn: sqlite3.Connection | None = None
@@ -59,9 +59,19 @@ def init_db():
         """)
         c.commit()
     cleanup_old()
+    _start_cleanup_scheduler()
     log.info("History DB initialisiert: %s", DB_PATH)
 
 
+def _start_cleanup_scheduler():
+    def _loop():
+        while True:
+            time.sleep(86400)
+            cleanup_old()
+    t = threading.Thread(target=_loop, daemon=True, name="history-cleanup")
+    t.start()
+
+
 def period_key(period_type: str, billing_day: int = 1, billing_month: int = 1) -> str:
     import datetime
     today = datetime.date.today()
@@ -117,21 +127,18 @@ def write_batch(inv_id: str, ts: float, values: Dict[str, float]):
 def load_recent(inv_id: str, limit: int = 300) -> Dict[str, List[Tuple[float, float]]]:
     """Letzte `limit` Messpunkte pro Sensor — zum Befüllen der In-Memory-Deque beim Start."""
     with _lock:
-        rows = _get_conn().execute("""
+        c = _get_conn()
-            SELECT sensor_id, ts, value
+        sensors = [r[0] for r in c.execute(
-            FROM (
+            "SELECT DISTINCT sensor_id FROM measurements WHERE inv_id = ?", (inv_id,)
-                SELECT sensor_id, ts, value,
+        ).fetchall()]
-                       ROW_NUMBER() OVER (PARTITION BY sensor_id ORDER BY ts DESC) AS rn
+        result: Dict[str, List[Tuple[float, float]]] = {}
-                FROM measurements
+        for sid in sensors:
-                WHERE inv_id = ?
+            rows = c.execute(
-            )
+                "SELECT ts, value FROM measurements "
-            WHERE rn <= ?
+                "WHERE inv_id = ? AND sensor_id = ? ORDER BY ts DESC LIMIT ?",
-            ORDER BY ts ASC
+                (inv_id, sid, limit),
-        """, (inv_id, limit)).fetchall()
+            ).fetchall()
-
+            result[sid] = [(ts, val) for ts, val in reversed(rows)]
-    result: Dict[str, List[Tuple[float, float]]] = {}
-    for sensor_id, ts, value in rows:
-        result.setdefault(sensor_id, []).append((ts, value))
     return result
 
 

haos-addon/src/inverters.py

@@ -247,8 +247,9 @@ INVERTERS = {
         name="Kathrein Wallbox",
         manufacturer="Kathrein",
         sensors=_kathrein_sensors(),
-        # Meter-Block + EVSE-Status + EMS-Setpoint
+        # Meter-Block 0x0030-0x005F + charging_state 0x0060 (solo, 0x0061-0x0064 existieren nicht)
-        read_ranges=[(0x0030, 48), (0x0060, 10), (0x00A2, 1)],
+        # + EVSE-Status 0x0065-0x006A + EMS-Setpoint 0x00A2
+        read_ranges=[(0x0030, 48), (0x0060, 1), (0x0065, 6), (0x00A2, 1)],
         protocol="kathrein",
         goodwe_family="",
     ),

haos-addon/src/main.py

@@ -55,8 +55,8 @@ AGG_SENSOR_IDS: Dict[str, List[str]] = {
     "total_energy_today":  ["energy_today", "e_day"],
     "total_energy_total":  ["energy_total", "e_total"],
     "grid_power":          ["grid_power"],
-    "grid_import_kwh":     ["import_kwh", "e_total_imp"],
+    "grid_import_kwh":     ["import_kwh", "_int_import", "e_total_imp"],
-    "grid_export_kwh":     ["export_kwh", "e_total_exp"],
+    "grid_export_kwh":     ["export_kwh", "_int_export", "e_total_exp"],
     "bat_charge_power":    ["bat_charge_power"],
     "bat_discharge_power": ["bat_discharge_power"],
     "bat_charge_total":    ["bat_charge_total", "e_bat_charge_total"],
@@ -280,17 +280,18 @@ def _poll_loop(inv_cfg: Dict[str, Any], stop: threading.Event):
         log.info("[%s] Poll-Loop: %s @ %s (Goodwe UDP/8899) alle %ds",
                  inv_id, inverter.name, host, interval)
     elif inverter.protocol == "kathrein":
-        reader = WallboxReader(host=host, port=port)
+        reader = WallboxReader(host=host, port=port, timeout=min(5.0, interval * 0.4))
         ems = EmsController(
             min_pv_power=inv_cfg.get("ems_min_pv", 1400),
             pv_timeout_h=inv_cfg.get("ems_timeout", 4.0),
             target_hour=inv_cfg.get("ems_target_hour", 6),
             phases=inv_cfg.get("ems_phases", 3),
+            max_charge_ma=inv_cfg.get("ems_max_current_ma", 32000),
         )
         log.info("[%s] Poll-Loop: %s @ %s:%s (Kathrein EMS) alle %ds",
                  inv_id, inverter.name, host, port, interval)
     else:
-        reader = ModbusReader(host=host, port=port, slave=slave)
+        reader = ModbusReader(host=host, port=port, slave=slave, timeout=min(5.0, interval * 0.4))
         log.info("[%s] Poll-Loop: %s @ %s:%s alle %ds",
                  inv_id, inverter.name, host, port, interval)
 
@@ -310,6 +311,13 @@ def _poll_loop(inv_cfg: Dict[str, Any], stop: threading.Event):
                 q.append(pt)
     log.info("[%s] %d Sensoren aus DB geladen", inv_id, len(hist_data))
 
+    # Integrierte Grid-Zähler — starten bei 0, wachsen mit jedem Poll, persistieren in DB
+    inv_int_import = hist_data["_int_import"][-1][1] if hist_data.get("_int_import") else 0.0
+    inv_int_export = hist_data["_int_export"][-1][1] if hist_data.get("_int_export") else 0.0
+    last_grid_ts = time.time()
+    _fail_count = 0          # aufeinanderfolgende Lesefehler; erst ab >= 3 → offline
+    _OFFLINE_THRESHOLD = 3
+
     while not stop.is_set():
         t0 = time.time()
         values = reader.read(inverter)
@@ -322,12 +330,24 @@ def _poll_loop(inv_cfg: Dict[str, Any], stop: threading.Event):
         if values and "grid_power" not in values and "import_kwh" in values and "total_power" in values:
             values["grid_power"] = values["total_power"]
 
+        # grid_power integrieren → interne kWh-Zähler (Periodenberechnung für Goodwe / kein SDM-630)
+        if values is not None and "grid_power" in values:
+            dt_s = t0 - last_grid_ts
+            if 0 < dt_s < 300:
+                gp = values["grid_power"]
+                if gp > 0:
+                    inv_int_import = round(inv_int_import + gp * dt_s / 3_600_000, 6)
+                elif gp < 0:
+                    inv_int_export = round(inv_int_export + (-gp) * dt_s / 3_600_000, 6)
+            values["_int_import"] = inv_int_import
+            values["_int_export"] = inv_int_export
+        last_grid_ts = t0
+
         # EMS: PV-Überschuss aus anderen Geräten holen und Ladestrom regeln
         if ems is not None and values is not None and inv_cfg.get("ems_enabled", True):
             pv_surplus = _get_pv_surplus()
-            # 0x0060 manchmal nicht lesbar → 1 (EV Connected) annehmen,
+            # charging_state aus 0x0060 (solo-Read); fehlt bei kein Fahrzeug → 0 (Idle)
-            # damit EMS aktiviert; Wallbox ignoriert Befehle wenn kein Auto da
+            charging_state = int(values.get("charging_state", 0))
-            charging_state = int(values.get("charging_state", 1))
             wallbox_power = values.get("total_power", 0.0)
             ems_status = ems.update(reader, pv_surplus, charging_state, wallbox_power)
             values["ems_status_code"] = float(charging_state)
@@ -336,6 +356,7 @@ def _poll_loop(inv_cfg: Dict[str, Any], stop: threading.Event):
         with State.lock:
             d = State.inv_data.setdefault(inv_id, {"poll_count": 0})
             if values is not None:
+                _fail_count = 0
                 d["values"] = values
                 d["last_update"] = time.time()
                 d["modbus_ok"] = True
@@ -347,12 +368,15 @@ def _poll_loop(inv_cfg: Dict[str, Any], stop: threading.Event):
                     q.append((now, val))
                 history.write_batch(inv_id, now, values)
                 if _publisher:
-                    _publisher.publish_data(values, prefix)
+                    pub_values = {k: v for k, v in values.items() if not k.startswith("_")}
+                    _publisher.publish_data(pub_values, prefix)
                     _publisher.publish_status("online", prefix)
             else:
-                d["modbus_ok"] = False
+                _fail_count += 1
-                if _publisher:
+                if _fail_count >= _OFFLINE_THRESHOLD:
-                    _publisher.publish_status("offline", prefix)
+                    d["modbus_ok"] = False
+                    if _publisher:
+                        _publisher.publish_status("offline", prefix)
 
         # Aggregate nach jedem erfolgreichen Poll neu berechnen und publizieren
         if values is not None and _publisher:

haos-addon/src/web/index.html

@@ -495,6 +495,9 @@ GND  → GND
           <option value="2">2-phasig</option>
           <option value="3" selected>3-phasig</option>
         </select></div>
+      <div class="field"><label>Max. Ladestrom (A)</label>
+        <input type="number" id="ems-max-current" value="32" min="6" max="32" step="1">
+        <div style="font-size:11px;color:var(--muted);margin-top:3px">Obergrenze für Zwangsladen — auf die tatsächliche Wallbox-/Zuleitungs-Absicherung setzen (z.B. 16A bei einer 11kW-Wallbox), nicht höher als die Hardware zulässt</div></div>
     </div>
 
     <div class="modal-actions">
@@ -1195,6 +1198,7 @@ async function openModal(invId) {
     document.getElementById("ems-timeout").value = inv.ems_timeout ?? 4;
     document.getElementById("ems-target-hour").value = inv.ems_target_hour ?? 6;
     document.getElementById("ems-phases").value = inv.ems_phases ?? 3;
+    document.getElementById("ems-max-current").value = inv.ems_max_current_ma ? inv.ems_max_current_ma / 1000 : 32;
     document.getElementById("ems-enabled").checked = inv.ems_enabled ?? true;
   } else {
     document.getElementById("modal-title").textContent = "Gerät hinzufügen";
@@ -1209,6 +1213,7 @@ async function openModal(invId) {
     document.getElementById("ems-timeout").value = "4";
     document.getElementById("ems-target-hour").value = "6";
     document.getElementById("ems-phases").value = "3";
+    document.getElementById("ems-max-current").value = "32";
   }
   toggleEmsSection(modelSel.value);
   modal.classList.add("open");
@@ -1243,6 +1248,7 @@ async function saveInverter() {
     inv.ems_timeout = parseFloat(document.getElementById("ems-timeout").value);
     inv.ems_target_hour = parseInt(document.getElementById("ems-target-hour").value);
     inv.ems_phases = parseInt(document.getElementById("ems-phases").value);
+    inv.ems_max_current_ma = Math.round(parseFloat(document.getElementById("ems-max-current").value) * 1000);
     inv.ems_enabled = document.getElementById("ems-enabled").checked;
   }
   const idx = invertersList.findIndex(i => i.id === id);
@@ -1693,7 +1699,7 @@ async function wizardStep2Next() {
   if (!name || !ip) { showToast("Name und IP sind Pflichtfelder", "err"); return; }
   const model = document.getElementById("wz-inv-model").value;
   const id = Math.random().toString(36).slice(2, 10);
-  const body = [{
+  const newInv = {
     id,
     name,
     inverter_model:    model,
@@ -1702,7 +1708,9 @@ async function wizardStep2Next() {
     modbus_address:    parseInt(document.getElementById("wz-inv-addr").value)  || 1,
     mqtt_topic_prefix: `growatt/${name.toLowerCase().replace(/\s+/g, "_")}`,
     update_interval:   30,
-  }];
+  };
+  // Bestehende Geräte behalten — Wizard darf nicht die komplette Liste überschreiben
+  const body = [...invertersList, newInv];
   try {
     await fetchJSON(api("api/inverters-config"), {
       method: "POST", headers: {"Content-Type": "application/json"},