fix(manager): Energieausgleich aus Enelix 1 wiederherstellen

fix(easee): veraltete Ladeleistung nach Ladestopp nullen
fix(ladestation): Fahrzeugstrom nach Lernzeit begrenzen
2026-09-29 14:14:25 +00:00 · 2026-09-29 13:15:43 +00:00 · 2026-09-29 12:47:23 +00:00 · 2026-09-29 12:25:35 +00:00 · 2026-09-29 12:11:43 +00:00 · 2026-09-29 12:06:51 +00:00
34 changed files with 1370 additions and 159 deletions
@@ -17,6 +17,13 @@ Alle wesentlichen Aenderungen an Enelix EMS werden in dieser Datei dokumentiert.

 - Stufenlose Leistungsbereiche fuer Batteriespeicher.
 - Ladefreigabe neuer Ladestationsinstanzen standardmaessig aktiviert.
+- Stand-alone-Ladestationen erkennen nach einer einstellbaren Beobachtungszeit den niedrigeren Fahrzeug-Maximalstrom und begrenzen ihr Leistungsangebot ohne Ladeunterbruch.
+- Easee-Ladestationen laden einen fehlenden Initialstatus ueber die Observations-API nach und starten bei noch unbekannter Ausgangsphase konservativ einphasig.
+- Wartende Easee-Ladestationen erhalten bei positiver Stromvorgabe einmal pro Fahrzeugverbindung einen Startbefehl; Freigabe- und Blockiergruende werden diagnostiziert.
+- Fehlende oder veraltete Verbraucher blockieren die Verteilung an aktuelle Verbraucher nicht mehr.
+- Verbraucher gleicher Prioritaet werden wie in Enelix 1 anhand ihrer bezogenen Energie in 2-kWh-Gruppen ausgeglichen.
+- Die Stoerungsueberwachung fordert einen fehlenden Geraetezugang innerhalb ihres Retry-Zyklus automatisch neu an.
+- Der Warmwassererwaermer verwendet konfigurierbare Temperatur-Stoergrenzen von standardmaessig 0 bis 100 Grad C.
 - Vollstaendige PHP-, Struktur- und Symcon-Modultests fuer alle Module.

 ### Hinweise
@@ -16,6 +16,7 @@ class EaseeGateway extends IPSModule
    private const SIGNALR_BASE_URL = 'https://streams.easee.com/hubs/chargers';
    private const API_BASE_URL = 'https://api.easee.com';
    private const RECORD_SEPARATOR = "\x1e";
+    private const CACHE_MAXIMALALTER_SEKUNDEN = 60;

    public function Create(): void
    {
@@ -112,7 +113,10 @@ class EaseeGateway extends IPSModule
                return;

            case 'RefreshToken':
-                if ($this->erneuereZugangsdaten(false)) {
+                if (
+                    $this->erneuereZugangsdaten(false)
+                    && $this->GetBuffer('SignalRReady') !== '1'
+                ) {
                    $this->verbindeSignalR();
                }
                return;
@@ -221,6 +225,12 @@ class EaseeGateway extends IPSModule
                    $seriennummer,
                    (float) ($anfrage['amps'] ?? -1)
                ), JSON_THROW_ON_ERROR);
+
+            case 'StartCharging':
+                return json_encode(
+                    $this->sendeLadestart($seriennummer),
+                    JSON_THROW_ON_ERROR
+                );
        }

        return json_encode([
@@ -340,7 +350,7 @@ class EaseeGateway extends IPSModule
        $this->SetBuffer('ReceiveBuffer', '');
        $this->SetBuffer('SubscribedThisConnection', '{}');
        $this->SetBuffer('PendingInvocations', '{}');
-        $this->WriteAttributeString('ObservationCache', '{}');
+        $this->markiereBeobachtungscacheVeraltet();
        $this->setzeVerbunden(false);

        if (!$this->konfiguriereWebSocketParent($url)) {
@@ -530,6 +540,25 @@ class EaseeGateway extends IPSModule
            return;
        }

+        $this->speichereBeobachtungImCache($seriennummer, $id, $wert);
+
+        $this->SendDataToChildren(json_encode([
+            'DataID' => self::CHILD_EVENT_DATA_ID,
+            'Buffer' => json_encode([
+                'type' => 'Observation',
+                'serialNumber' => $seriennummer,
+                'id' => $id,
+                'value' => $wert,
+                'timestamp' => time(),
+            ], JSON_THROW_ON_ERROR),
+        ], JSON_THROW_ON_ERROR));
+    }
+
+    private function speichereBeobachtungImCache(
+        string $seriennummer,
+        int $id,
+        $wert
+    ): void {
        $cache = $this->leseAttributArray('ObservationCache');
        if (!isset($cache[$seriennummer]) || !is_array($cache[$seriennummer])) {
            $cache[$seriennummer] = [];
@@ -545,21 +574,84 @@ class EaseeGateway extends IPSModule
            'ObservationCache',
            json_encode($cache, JSON_THROW_ON_ERROR)
        );
+    }

-        $this->SendDataToChildren(json_encode([
-            'DataID' => self::CHILD_EVENT_DATA_ID,
-            'Buffer' => json_encode([
-                'type' => 'Observation',
-                'serialNumber' => $seriennummer,
-                'id' => $id,
-                'value' => $wert,
-                'timestamp' => time(),
-            ], JSON_THROW_ON_ERROR),
-        ], JSON_THROW_ON_ERROR));
+    private function markiereBeobachtungscacheVeraltet(): void
+    {
+        $cache = $this->leseAttributArray('ObservationCache');
+        foreach ($cache as &$zustand) {
+            if (is_array($zustand)) {
+                $zustand['updated'] = 0;
+            }
+        }
+        unset($zustand);
+        $this->WriteAttributeString(
+            'ObservationCache',
+            json_encode($cache, JSON_THROW_ON_ERROR)
+        );
+    }
+
+    private function stelleAktuellenStatusSicher(string $seriennummer): void
+    {
+        $cache = $this->leseAttributArray('ObservationCache');
+        $zustand = $cache[$seriennummer] ?? [];
+        $cacheIstAktuell = is_array($zustand)
+            && array_key_exists('109', $zustand)
+            && (int) ($zustand['updated'] ?? 0) >= time() - self::CACHE_MAXIMALALTER_SEKUNDEN;
+        if (
+            $cacheIstAktuell
+            || $this->ReadPropertyBoolean('Testmodus')
+            || $this->GetBuffer('SignalRReady') !== '1'
+        ) {
+            return;
+        }
+
+        $antwort = $this->autorisierteApiAnfrage(
+            'GET',
+            '/state/' . rawurlencode($seriennummer) . '/observations?ids='
+                . rawurlencode(implode(',', EaseeGatewayProtokoll::BEOBACHTUNGEN)),
+            ''
+        );
+        if (!($antwort['success'] ?? false)) {
+            $this->setzeLetztenFehler(
+                'Easee-Status konnte nicht geladen werden: '
+                    . (string) ($antwort['error'] ?? 'Unbekannter API-Fehler.')
+            );
+            return;
+        }
+
+        $daten = json_decode((string) ($antwort['body'] ?? ''), true);
+        if (!is_array($daten)) {
+            $this->setzeLetztenFehler('Easee-Statusantwort ist ungueltig.');
+            return;
+        }
+        $beobachtungen = EaseeGatewayProtokoll::extrahiereBeobachtungen(
+            $daten,
+            [$seriennummer],
+            $seriennummer
+        );
+        $betriebsstatusGeladen = false;
+        foreach ($beobachtungen as $beobachtung) {
+            $this->speichereBeobachtungImCache(
+                $beobachtung['Seriennummer'],
+                $beobachtung['ID'],
+                $beobachtung['Wert']
+            );
+            $betriebsstatusGeladen = $betriebsstatusGeladen
+                || $beobachtung['ID'] === 109;
+        }
+        if (!$betriebsstatusGeladen) {
+            $this->setzeLetztenFehler(
+                'Easee-Statusantwort enthaelt keinen Betriebsstatus (109).'
+            );
+            return;
+        }
+        $this->setzeLetztenFehler('');
    }

    private function erstelleStatusantwort(string $seriennummer): string
    {
+        $this->stelleAktuellenStatusSicher($seriennummer);
        $cache = $this->leseAttributArray('ObservationCache');
        return json_encode([
            'success' => true,
@@ -606,6 +698,24 @@ class EaseeGateway extends IPSModule
        );
    }

+    /** @return array<string, mixed> */
+    private function sendeLadestart(string $seriennummer): array
+    {
+        if ($seriennummer === '') {
+            return ['success' => false, 'error' => 'Seriennummer fehlt.'];
+        }
+        if ($this->ReadPropertyBoolean('Testmodus')) {
+            return ['success' => true, 'httpCode' => 200, 'body' => '{}'];
+        }
+
+        return $this->autorisierteApiAnfrage(
+            'POST',
+            '/api/chargers/' . rawurlencode($seriennummer)
+                . '/commands/start_charging',
+            ''
+        );
+    }
+
    /** @return array<string, mixed> */
    private function autorisierteApiAnfrage(
        string $methode,
@@ -760,7 +870,11 @@ class EaseeGateway extends IPSModule

    private function setzeVerbunden(bool $verbunden): void
    {
+        $warVerbunden = (bool) $this->GetValue('Connected');
        $this->SetValue('Connected', $verbunden);
+        if ($warVerbunden === $verbunden) {
+            return;
+        }
        $this->SendDataToChildren(json_encode([
            'DataID' => self::CHILD_EVENT_DATA_ID,
            'Buffer' => json_encode([
@@ -41,7 +41,13 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        'Stoertext',
        'GatewayVerbunden',
        'ApiMaximalstrom',
+        'EaseeAktiviert',
+        'AutorisierungErforderlich',
+        'RemoteStartErforderlich',
+        'SmartCharging',
+        'GrundKeinLadestrom',
        'LetzterGeraetebefehl',
+        'LetzterStartbefehl',
        'LeistungsangebotDiagnose',
    ];

@@ -82,6 +88,11 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        $this->RegisterAttributeString('EaseeBeobachtungen', '{}');
        $this->RegisterAttributeInteger('LetzteBeobachtung', 0);
        $this->RegisterAttributeInteger('ApiMaximalstrom', 16);
+        $this->RegisterAttributeBoolean('ZustandEaseeAktiviert', true);
+        $this->RegisterAttributeBoolean('ZustandAutorisierungErforderlich', false);
+        $this->RegisterAttributeBoolean('ZustandRemoteStartErforderlich', false);
+        $this->RegisterAttributeBoolean('ZustandSmartCharging', false);
+        $this->RegisterAttributeInteger('ZustandGrundKeinLadestrom', 0);
        $this->RegisterAttributeBoolean('ZustandFahrzeugVerbunden', false);
        $this->RegisterAttributeBoolean('ZustandFahrzeugGeladen', false);
        $this->RegisterAttributeInteger('ZustandFahrzeugstatus', 0);
@@ -99,7 +110,9 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        $this->RegisterAttributeInteger('LetzteManagerID', 0);
        $this->RegisterAttributeInteger('LetzteVorgabeZeit', 0);
        $this->RegisterAttributeInteger('LetzterGesetzterStrom', -1);
+        $this->RegisterAttributeBoolean('LadestartFuerVerbindungGesendet', false);
        $this->RegisterAttributeString('LetzterGeraetebefehl', '');
+        $this->RegisterAttributeString('LetzterStartbefehl', '');

        $this->RegisterTimer(
            'Meldezyklus',
@@ -128,6 +141,7 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        $this->aktualisiereVariablen();
        $this->WriteAttributeBoolean('GatewayVerbunden', false);
        $this->WriteAttributeInteger('LetzterGesetzterStrom', -1);
+        $this->WriteAttributeBoolean('LadestartFuerVerbindungGesendet', false);

        try {
            $this->pruefeKonfiguration();
@@ -405,6 +419,11 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                'Phasenzahl',
                'Istleistung_W',
                'Ladestrom_A',
+                'EaseeAktiviert',
+                'AutorisierungErforderlich',
+                'RemoteStartErforderlich',
+                'SmartCharging',
+                'GrundKeinLadestrom',
            ] as $feld) {
                $this->setzeZustand($feld, $status[$feld]);
            }
@@ -416,13 +435,19 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                'ApiMaximalstrom',
                $status['ApiMaximalstrom_A']
            );
+            if (!$status['FahrzeugVerbunden']) {
+                $this->WriteAttributeBoolean('LadestartFuerVerbindungGesendet', false);
+            }

            $gatewayVerbunden = $this->ReadAttributeBoolean('GatewayVerbunden');
            $phaseGueltig = in_array($status['Phasenzahl'], [1, 3], true);
+            $regelPhasenzahl = $phaseGueltig ? $status['Phasenzahl'] : 1;
+            $phaseErforderlich = $status['Fahrzeugstatus'] === 3;
            $steuerbar = $gatewayVerbunden
                && $status['StatusGueltig']
+                && $status['EaseeAktiviert']
                && !$status['Stoerung']
-                && (!$status['FahrzeugVerbunden'] || $phaseGueltig);
+                && (!$phaseErforderlich || $phaseGueltig);

            $solarladen = $this->ReadAttributeBoolean('ZustandSolarladen');
            $peakbetrieb = $this->ReadAttributeString('Betriebsart')
@@ -432,7 +457,7 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                $this->ReadAttributeBoolean('ZustandLadefreigabe'),
                $steuerbar && $status['FahrzeugVerbunden'],
                $status['FahrzeugGeladen'],
-                $phaseGueltig ? $status['Phasenzahl'] : 1,
+                $regelPhasenzahl,
                $status['ApiMaximalstrom_A'],
                $solarladen,
                $peakbetrieb
@@ -460,8 +485,8 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
            } elseif ($status['Stoerung']) {
                $stoertext = $status['Stoertext'];
                $this->SetStatus(self::STATUS_LADEFEHLER);
-            } elseif ($status['FahrzeugVerbunden'] && !$phaseGueltig) {
-                $stoertext = 'Easee meldet keine unterstuetzte aktive Ausgangsphase.';
+            } elseif ($phaseErforderlich && !$phaseGueltig) {
+                $stoertext = 'Easee meldet beim Laden keine unterstuetzte aktive Ausgangsphase.';
                $this->SetStatus(self::STATUS_WARTET_AUF_DATEN);
            } else {
                $this->SetStatus(self::STATUS_AKTIV);
@@ -471,7 +496,8 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
            if ($gatewayVerbunden && $status['StatusGueltig']) {
                $this->setzeLadestrom(
                    $this->bestimmeWirksameSollleistung($angebot),
-                    $status['Phasenzahl']
+                    $regelPhasenzahl,
+                    $status['Fahrzeugstatus'] === 2
                );
            } else {
                $this->WriteAttributeInteger('LetzterGesetzterStrom', -1);
@@ -510,34 +536,64 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        return 0;
    }

-    private function setzeLadestrom(int $leistung, int $phasenzahl): void
-    {
+    private function setzeLadestrom(
+        int $leistung,
+        int $phasenzahl,
+        bool $wartetAufStart
+    ): void {
        $strom = $leistung === 0
            ? 0
            : LadestationRegler::stromFuerLeistung($leistung, $phasenzahl);
-        if ($strom === $this->ReadAttributeInteger('LetzterGesetzterStrom')) {
-            return;
+        if ($strom !== $this->ReadAttributeInteger('LetzterGesetzterStrom')) {
+            $antwort = $this->gatewayAnfrage([
+                'action' => 'SetDynamicChargerCurrent',
+                'serialNumber' => $this->seriennummer(),
+                'amps' => $strom,
+            ]);
+            if (!($antwort['success'] ?? false)) {
+                throw new RuntimeException(
+                    (string) ($antwort['error'] ?? 'Easee-Stromvorgabe fehlgeschlagen.')
+                );
+            }
+
+            $befehl = json_encode([
+                'Aktion' => 'SetDynamicChargerCurrent',
+                'Seriennummer' => $this->seriennummer(),
+                'Ampere' => $strom,
+            ], JSON_THROW_ON_ERROR);
+            $this->WriteAttributeString('LetzterGeraetebefehl', $befehl);
+            $this->setzeSichtbareVariable('LetzterGeraetebefehl', $befehl);
+            $this->WriteAttributeInteger('LetzterGesetzterStrom', $strom);
        }

+        if (
+            $strom > 0
+            && $wartetAufStart
+            && !$this->ReadAttributeBoolean('LadestartFuerVerbindungGesendet')
+        ) {
+            $this->sendeLadestart();
+        }
+    }
+
+    private function sendeLadestart(): void
+    {
        $antwort = $this->gatewayAnfrage([
-            'action' => 'SetDynamicChargerCurrent',
+            'action' => 'StartCharging',
            'serialNumber' => $this->seriennummer(),
-            'amps' => $strom,
        ]);
        if (!($antwort['success'] ?? false)) {
            throw new RuntimeException(
-                (string) ($antwort['error'] ?? 'Easee-Stromvorgabe fehlgeschlagen.')
+                (string) ($antwort['error'] ?? 'Easee-Ladestart fehlgeschlagen.')
            );
        }

        $befehl = json_encode([
-            'Aktion' => 'SetDynamicChargerCurrent',
+            'Aktion' => 'StartCharging',
            'Seriennummer' => $this->seriennummer(),
-            'Ampere' => $strom,
        ], JSON_THROW_ON_ERROR);
-        $this->WriteAttributeString('LetzterGeraetebefehl', $befehl);
-        $this->setzeSichtbareVariable('LetzterGeraetebefehl', $befehl);
-        $this->WriteAttributeInteger('LetzterGesetzterStrom', $strom);
+        $this->WriteAttributeBoolean('LadestartFuerVerbindungGesendet', true);
+        $this->WriteAttributeString('LetzterStartbefehl', $befehl);
+        $this->setzeSichtbareVariable('LetzterStartbefehl', $befehl);
    }

    private function seriennummer(): string
@@ -648,6 +704,36 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                    'Wert' => $this->ReadAttributeBoolean('ZustandSolarladen'),
                    'Einheit' => '',
                ],
+                [
+                    'Kennung' => 'EaseeAktiviert',
+                    'Art' => 'Status',
+                    'Wert' => (bool) $this->leseZustand('EaseeAktiviert'),
+                    'Einheit' => '',
+                ],
+                [
+                    'Kennung' => 'AutorisierungErforderlich',
+                    'Art' => 'Status',
+                    'Wert' => (bool) $this->leseZustand('AutorisierungErforderlich'),
+                    'Einheit' => '',
+                ],
+                [
+                    'Kennung' => 'RemoteStartErforderlich',
+                    'Art' => 'Status',
+                    'Wert' => (bool) $this->leseZustand('RemoteStartErforderlich'),
+                    'Einheit' => '',
+                ],
+                [
+                    'Kennung' => 'SmartCharging',
+                    'Art' => 'Status',
+                    'Wert' => (bool) $this->leseZustand('SmartCharging'),
+                    'Einheit' => '',
+                ],
+                [
+                    'Kennung' => 'GrundKeinLadestrom',
+                    'Art' => 'Status',
+                    'Wert' => (int) $this->leseZustand('GrundKeinLadestrom'),
+                    'Einheit' => '',
+                ],
                [
                    'Kennung' => 'Ladefehler',
                    'Art' => 'Stoerung',
@@ -813,17 +899,53 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                '',
                210
            );
+            $this->RegisterVariableBoolean(
+                'EaseeAktiviert',
+                'Easee aktiviert',
+                '~Switch',
+                220
+            );
+            $this->RegisterVariableBoolean(
+                'AutorisierungErforderlich',
+                'Autorisierung erforderlich',
+                '~Switch',
+                230
+            );
+            $this->RegisterVariableBoolean(
+                'RemoteStartErforderlich',
+                'Remote-Start erforderlich',
+                '~Switch',
+                240
+            );
+            $this->RegisterVariableBoolean(
+                'SmartCharging',
+                'Easee Smart Charging',
+                '~Switch',
+                250
+            );
+            $this->RegisterVariableInteger(
+                'GrundKeinLadestrom',
+                'Grund kein Ladestrom',
+                '',
+                260
+            );
            $this->RegisterVariableString(
                'LetzterGeraetebefehl',
                'Letzter Geraetebefehl',
                '',
-                220
+                270
+            );
+            $this->RegisterVariableString(
+                'LetzterStartbefehl',
+                'Letzter Startbefehl',
+                '',
+                280
            );
            $this->RegisterVariableString(
                'LeistungsangebotDiagnose',
                'Leistungsangebot',
                '',
-                230
+                290
            );
            $this->SetValue(
                'LeistungsangebotDiagnose',
@@ -833,11 +955,16 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                'LetzterGeraetebefehl',
                $this->ReadAttributeString('LetzterGeraetebefehl')
            );
+            $this->SetValue(
+                'LetzterStartbefehl',
+                $this->ReadAttributeString('LetzterStartbefehl')
+            );
            foreach (self::DIAGNOSE_VARIABLEN as $ident) {
                if (!in_array($ident, [
                    'GatewayVerbunden',
                    'ApiMaximalstrom',
                    'LetzterGeraetebefehl',
+                    'LetzterStartbefehl',
                    'LeistungsangebotDiagnose',
                ], true)) {
                    $this->setzeSichtbareVariable($ident, $this->leseZustand($ident));
@@ -872,6 +999,10 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        switch ($ident) {
            case 'FahrzeugVerbunden':
            case 'FahrzeugGeladen':
+            case 'EaseeAktiviert':
+            case 'AutorisierungErforderlich':
+            case 'RemoteStartErforderlich':
+            case 'SmartCharging':
            case 'SollwertGueltig':
            case 'Verfuegbar':
            case 'AenderungMoeglich':
@@ -880,6 +1011,7 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
                break;
            case 'Fahrzeugstatus':
            case 'Phasenzahl':
+            case 'GrundKeinLadestrom':
            case 'Sollleistung':
                $this->WriteAttributeInteger('Zustand' . $ident, (int) $wert);
                break;
@@ -915,6 +1047,10 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        if (in_array($ident, [
            'FahrzeugVerbunden',
            'FahrzeugGeladen',
+            'EaseeAktiviert',
+            'AutorisierungErforderlich',
+            'RemoteStartErforderlich',
+            'SmartCharging',
            'SollwertGueltig',
            'Verfuegbar',
            'AenderungMoeglich',
@@ -925,6 +1061,7 @@ class LadestationGateway extends IPSModule implements VerbraucherSchnittstelle
        if (in_array($ident, [
            'Fahrzeugstatus',
            'Phasenzahl',
+            'GrundKeinLadestrom',
            'Sollleistung',
        ], true)) {
            return $this->ReadAttributeInteger('Zustand' . $ident);
@@ -37,6 +37,13 @@
                    "caption": "Geraetestatus abfragen",
                    "suffix": " s",
                    "minimum": 1
+                },
+                {
+                    "type": "NumberSpinner",
+                    "name": "FahrzeugstromErkennungszeit",
+                    "caption": "Fahrzeug-Maximalstrom erkennen nach",
+                    "suffix": " s",
+                    "minimum": 30
                }
            ]
        },
@@ -34,6 +34,7 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        'AenderungMoeglich',
        'Stoerung',
        'Stoertext',
+        'FahrzeugMaximalstrom',
        'LetzterGeraetebefehl',
        'LeistungsangebotDiagnose',
    ];
@@ -50,6 +51,7 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        $this->RegisterPropertyString('Benutzername', '');
        $this->RegisterPropertyString('Passwort', '');
        $this->RegisterPropertyInteger('MaximalerLadestrom', 16);
+        $this->RegisterPropertyInteger('FahrzeugstromErkennungszeit', 90);
        $this->RegisterPropertyInteger('Abfrageintervall', 5);
        $this->RegisterPropertyBoolean('Ladefreigabe', true);
        $this->RegisterPropertyBoolean('Solarladen', true);
@@ -87,6 +89,10 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        $this->RegisterAttributeInteger('LetzteManagerID', 0);
        $this->RegisterAttributeInteger('LetzteVorgabeZeit', 0);
        $this->RegisterAttributeInteger('LetzterGesetzterStrom', -1);
+        $this->RegisterAttributeBoolean('LadeleistungSeitFreigabeErkannt', false);
+        $this->RegisterAttributeInteger('ErkannterMaximalstrom', 32);
+        $this->RegisterAttributeInteger('FahrzeugstromKandidat', 0);
+        $this->RegisterAttributeInteger('FahrzeugstromKandidatSeit', 0);

        $this->RegisterTimer(
            'Statuszyklus',
@@ -117,6 +123,16 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        $this->initialisiereLokaleEinstellungen();
        $this->aktualisiereVariablen();

+        // Ein persistiertes Ladeende nach Neueinrichtung oder Modulupdate einmal neu pruefen.
+        $this->setzeZustand('FahrzeugGeladen', false);
+        $this->WriteAttributeInteger('LetzterGesetzterStrom', -1);
+        $this->WriteAttributeBoolean('LadeleistungSeitFreigabeErkannt', false);
+        $this->WriteAttributeInteger(
+            'ErkannterMaximalstrom',
+            $this->ReadPropertyInteger('MaximalerLadestrom')
+        );
+        $this->setzeFahrzeugstromKandidatZurueck();
+
        try {
            $this->pruefeKonfiguration();
        } catch (Throwable $fehler) {
@@ -239,7 +255,11 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
            $verbunden = $this->ReadAttributeBoolean('ZustandFahrzeugVerbunden');
            $geladen = $this->ReadAttributeBoolean('ZustandFahrzeugGeladen');
            $phasenzahl = $this->ReadAttributeInteger('ZustandPhasenzahl');
-            $maximalstrom = $this->ReadPropertyInteger('MaximalerLadestrom');
+            $maximalstrom = min(
+                $this->ReadPropertyInteger('MaximalerLadestrom'),
+                max(6, $this->ReadAttributeInteger('ErkannterMaximalstrom'))
+            );
+            $this->setzeSichtbareVariable('FahrzeugMaximalstrom', $maximalstrom);
            $solarladen = $this->ReadAttributeBoolean('ZustandSolarladen');
            $peakbetrieb = $this->ReadAttributeString('Betriebsart')
                === Nachrichtenvertrag::BETRIEBSART_PEAK;
@@ -301,14 +321,69 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        );
        $status = LadestationRegler::normalisiereStatus(
            $rohstatus,
-            $this->ReadAttributeBoolean('ZustandFahrzeugVerbunden')
+            $this->ReadAttributeBoolean('ZustandFahrzeugVerbunden'),
+            $this->ReadAttributeBoolean('ZustandFahrzeugGeladen'),
+            $this->ReadAttributeInteger('LetzterGesetzterStrom') >= 6,
+            $this->ReadAttributeBoolean('LadeleistungSeitFreigabeErkannt')
        );
+        if (!$status['FahrzeugVerbunden']) {
+            $this->WriteAttributeBoolean('LadeleistungSeitFreigabeErkannt', false);
+        } elseif ($status['Ladestrom_A'] >= 3.5) {
+            $this->WriteAttributeBoolean('LadeleistungSeitFreigabeErkannt', true);
+        }
+        $this->aktualisiereFahrzeugstromgrenze($status);

        foreach ($status as $ident => $wert) {
            $this->setzeZustand($ident, $wert);
        }
    }

+    /** @param array<string, int|float|bool> $status */
+    private function aktualisiereFahrzeugstromgrenze(array $status): void
+    {
+        $konfigurierterMaximalstrom = $this->ReadPropertyInteger('MaximalerLadestrom');
+        if (!$status['FahrzeugVerbunden']) {
+            $this->WriteAttributeInteger('ErkannterMaximalstrom', $konfigurierterMaximalstrom);
+            $this->setzeSichtbareVariable('FahrzeugMaximalstrom', $konfigurierterMaximalstrom);
+            $this->setzeFahrzeugstromKandidatZurueck();
+            return;
+        }
+
+        $kandidat = LadestationRegler::ermittleFahrzeugMaximalstrom(
+            $this->ReadAttributeInteger('LetzterGesetzterStrom'),
+            (float) $status['Ladestrom_A'],
+            $konfigurierterMaximalstrom
+        );
+        if ($kandidat === null
+            || $kandidat >= $this->ReadAttributeInteger('ErkannterMaximalstrom')
+        ) {
+            $this->setzeFahrzeugstromKandidatZurueck();
+            return;
+        }
+
+        $jetzt = time();
+        if ($this->ReadAttributeInteger('FahrzeugstromKandidat') !== $kandidat) {
+            $this->WriteAttributeInteger('FahrzeugstromKandidat', $kandidat);
+            $this->WriteAttributeInteger('FahrzeugstromKandidatSeit', $jetzt);
+            return;
+        }
+        if (($jetzt - $this->ReadAttributeInteger('FahrzeugstromKandidatSeit'))
+            < $this->ReadPropertyInteger('FahrzeugstromErkennungszeit')
+        ) {
+            return;
+        }
+
+        $this->WriteAttributeInteger('ErkannterMaximalstrom', $kandidat);
+        $this->setzeSichtbareVariable('FahrzeugMaximalstrom', $kandidat);
+        $this->setzeFahrzeugstromKandidatZurueck();
+    }
+
+    private function setzeFahrzeugstromKandidatZurueck(): void
+    {
+        $this->WriteAttributeInteger('FahrzeugstromKandidat', 0);
+        $this->WriteAttributeInteger('FahrzeugstromKandidatSeit', 0);
+    }
+
    /** @param list<int> $angebot */
    private function bestimmeWirksameSollleistung(array $angebot): int
    {
@@ -318,6 +393,14 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
                return $sollleistung;
            }
            $this->setzeZustand('SollwertGueltig', false);
+            $ersatz = 0;
+            foreach ($angebot as $leistungswert) {
+                if ($leistungswert > $sollleistung) {
+                    break;
+                }
+                $ersatz = $leistungswert;
+            }
+            return $ersatz;
        }

        if (!$this->ReadAttributeBoolean('ZustandSolarladen') && $angebot !== [0]) {
@@ -336,6 +419,8 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
        if ($strom === $this->ReadAttributeInteger('LetzterGesetzterStrom')) {
            return;
        }
+        $this->WriteAttributeBoolean('LadeleistungSeitFreigabeErkannt', false);
+        $this->setzeFahrzeugstromKandidatZurueck();

        $transport = new LadestationTransport(
            fn (array $anfrage): string => $this->fuehreHttpAnfrageAus($anfrage)
@@ -571,7 +656,12 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
                throw new InvalidArgumentException($property . ' muss mindestens 0 sein.');
            }
        }
-        foreach (['Meldeintervall', 'VorgabeTimeout', 'Abfrageintervall'] as $property) {
+        foreach ([
+            'Meldeintervall',
+            'VorgabeTimeout',
+            'Abfrageintervall',
+            'FahrzeugstromErkennungszeit',
+        ] as $property) {
            if ($this->ReadPropertyInteger($property) <= 0) {
                throw new InvalidArgumentException($property . ' muss groesser als 0 sein.');
            }
@@ -627,12 +717,26 @@ class LadestationStandAlone extends IPSModule implements VerbraucherSchnittstell
            $this->registriereVerbraucherDiagnose();
            $this->RegisterVariableString('LetzterGeraetebefehl', 'Letzter Geraetebefehl', '', 200);
            $this->RegisterVariableString('LeistungsangebotDiagnose', 'Leistungsangebot', '', 210);
+            $this->RegisterVariableInteger(
+                'FahrzeugMaximalstrom',
+                'Erkannter Fahrzeug-Maximalstrom',
+                '',
+                220
+            );
+            $this->SetValue(
+                'FahrzeugMaximalstrom',
+                $this->ReadAttributeInteger('ErkannterMaximalstrom')
+            );
            $this->SetValue(
                'LeistungsangebotDiagnose',
                $this->ReadAttributeString('Leistungsangebot')
            );
            foreach (self::DIAGNOSE_VARIABLEN as $ident) {
-                if (!in_array($ident, ['LetzterGeraetebefehl', 'LeistungsangebotDiagnose'], true)) {
+                if (!in_array($ident, [
+                    'LetzterGeraetebefehl',
+                    'LeistungsangebotDiagnose',
+                    'FahrzeugMaximalstrom',
+                ], true)) {
                    $this->setzeSichtbareVariable($ident, $this->leseZustand($ident));
                }
            }
@@ -180,6 +180,7 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        $this->RegisterVariableFloat('Netzleistung', 'Netzleistung', '', 30);

        $this->RegisterAttributeString('VerbraucherCache', '{}');
+        $this->RegisterAttributeString('VerbraucherEnergie', '{}');
        $this->RegisterAttributeString('LetzteSollwerte', '{}');
        $this->RegisterAttributeString('LetztePvGrenzen', '{}');
        $this->RegisterAttributeString('Netzfahrplan', '{}');
@@ -266,8 +267,7 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        }
        $this->setzeDiagnosewert('Monatsgrenzen', $this->ReadPropertyString('Monatsgrenzen'));
        $this->aktualisiereAnschlussstatus();
-        $geraetezugangFehlt = ($this->ReadPropertyBoolean('PrognoseAktiv')
-                || $this->ReadPropertyBoolean('StoerueberwachungAktiv'))
+        $geraetezugangFehlt = $this->geraetezugangBenoetigt()
            && $this->ReadAttributeString('PrognoseInstallationsToken') === '';
        if (!$this->aktualisiereLizenzfreigabe(
            $this->ReadPropertyString('Lizenzcode'),
@@ -500,7 +500,9 @@ class Manager extends IPSModule implements ManagerSchnittstelle
                if (!is_string($wert)) {
                    throw new InvalidArgumentException('Der Lizenzcode muss als Text uebergeben werden.');
                }
-                $this->aktualisiereLizenzfreigabe($wert, true);
+                if ($this->aktualisiereLizenzfreigabe($wert, true)) {
+                    $this->synchronisiereAnlagentopologie();
+                }
                $this->UpdateFormField('LizenzInformation', 'caption', $this->lizenzStatustext($wert));
                $this->aktualisiereLastspitzenformular($wert);
                $this->aktualisierePrognoseformular($wert);
@@ -602,15 +604,78 @@ class Manager extends IPSModule implements ManagerSchnittstelle
            throw new InvalidArgumentException('Der Absender ist diesem Manager nicht aktiv zugeordnet.');
        }

+        $jetzt = time();
+        $this->aktualisiereVerbraucherEnergie($absenderID, $daten, $jetzt);
+
        $cache = $this->leseJsonAttribut('VerbraucherCache');
        $cache[(string) $absenderID] = [
-            'EmpfangenAm' => time(),
+            'EmpfangenAm' => $jetzt,
            'Daten' => $daten,
        ];
        $this->WriteAttributeString('VerbraucherCache', json_encode($cache, JSON_THROW_ON_ERROR));
        $this->regeln(false);
    }

+    /** @param array<string, mixed> $daten */
+    private function aktualisiereVerbraucherEnergie(int $instanzID, array $daten, int $jetzt): void
+    {
+        $energien = $this->leseJsonAttribut('VerbraucherEnergie');
+        $bisher = $energien[(string) $instanzID] ?? [];
+        $energieWh = is_array($bisher) && is_numeric($bisher['Energie_Wh'] ?? null)
+            ? (float) $bisher['Energie_Wh']
+            : 0.0;
+        $letzterZeitpunkt = is_array($bisher) && is_int($bisher['Zeitpunkt'] ?? null)
+            ? $bisher['Zeitpunkt']
+            : 0;
+        $letzteLeistung = is_array($bisher) && is_numeric($bisher['Leistung_W'] ?? null)
+            ? (float) $bisher['Leistung_W']
+            : 0.0;
+
+        if ($letzterZeitpunkt > 0 && $jetzt > $letzterZeitpunkt) {
+            $dauer = min(
+                $jetzt - $letzterZeitpunkt,
+                $this->ReadPropertyInteger('VerbraucherTimeout')
+            );
+            $energieWh += $letzteLeistung * $dauer / 3600.0;
+        }
+
+        $energien[(string) $instanzID] = [
+            'Energie_Wh' => $energieWh,
+            'Zeitpunkt' => $jetzt,
+            'Leistung_W' => $this->verbraucherleistung($daten),
+        ];
+        $this->WriteAttributeString(
+            'VerbraucherEnergie',
+            json_encode($energien, JSON_THROW_ON_ERROR)
+        );
+    }
+
+    /** @param array<string, mixed> $daten */
+    private function verbraucherleistung(array $daten): float
+    {
+        if ($daten['Leistungsquelle'] !== Nachrichtenvertrag::LEISTUNGSQUELLE_NICHT_VORHANDEN
+            && is_numeric($daten['Istleistung_W'])
+        ) {
+            return (float) $daten['Istleistung_W'];
+        }
+
+        return (float) (ManagerRegler::angenommenerSollwert($daten) ?? 0);
+    }
+
+    /** @return array<int, float> */
+    private function bezogeneVerbraucherEnergienWh(): array
+    {
+        $ergebnis = [];
+        foreach ($this->leseJsonAttribut('VerbraucherEnergie') as $instanzID => $eintrag) {
+            if (!is_array($eintrag) || !is_numeric($eintrag['Energie_Wh'] ?? null)) {
+                continue;
+            }
+            $ergebnis[(int) $instanzID] = (float) $eintrag['Energie_Wh'];
+        }
+
+        return $ergebnis;
+    }
+
    private function regeln(bool $erneuern): void
    {
        if (!$this->aktualisiereLizenzfreigabe($this->ReadPropertyString('Lizenzcode'), false)) {
@@ -689,22 +754,6 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        );
        $this->setzeDiagnosewert('WirksameLastspitzengrenze', $lastspitzengrenze ?? 0.0);
        $this->regleEinspeisung($netzleistung, $stoerungen, $erneuern);
-        if (!$synchronisiert) {
-            $this->setzeDiagnosewert('Verteilbudget', 0.0);
-            $this->setzeDiagnosewert('Verbraucherstatus', json_encode([
-                'Betriebsart' => $betriebsart,
-                'Synchronisiert' => false,
-                'Verbraucher' => $verbraucher,
-                'NichtGeregelt' => $nichtGeregelt,
-            ], JSON_THROW_ON_ERROR));
-            $this->setzeDiagnosewert(
-                'NichtGeregelteGeraete',
-                $this->nichtGeregelteGeraeteText($nichtGeregelt)
-            );
-            $this->aktualisiereStoerungen($verbraucher, $stoerungen);
-            $this->SetStatus(self::STATUS_AKTIV);
-            return;
-        }

        $fahrplanVorgabe = $this->aktuelleNetzfahrplanVorgabe();
        $zielnetzleistung = $betriebsart === ManagerRegler::BETRIEBSART_PEAK
@@ -714,19 +763,22 @@ class Manager extends IPSModule implements ManagerSchnittstelle
            $netzleistung,
            $zielnetzleistung,
            $verbraucher,
-            $betriebsart === ManagerRegler::BETRIEBSART_PEAK ? 'PrioritaetPeak' : 'PrioritaetPV'
+            $betriebsart === ManagerRegler::BETRIEBSART_PEAK ? 'PrioritaetPeak' : 'PrioritaetPV',
+            $this->bezogeneVerbraucherEnergienWh()
        );
        $this->setzeDiagnosewert('Verteilbudget', (float) $ergebnis['Verteilbudget_W']);
        $this->setzeDiagnosewert('Verbraucherstatus', json_encode([
            'Betriebsart' => $betriebsart,
-            'Synchronisiert' => true,
+            'Synchronisiert' => $synchronisiert,
            'Restabweichung_W' => $ergebnis['Restabweichung_W'],
            'Verbraucher' => $verbraucher,
-            'NichtGeregelt' => [],
+            'NichtGeregelt' => $nichtGeregelt,
        ], JSON_THROW_ON_ERROR));
        $this->setzeDiagnosewert(
            'NichtGeregelteGeraete',
-            'Alle aktiven Verbraucher werden geregelt.'
+            $nichtGeregelt === []
+                ? 'Alle aktiven Verbraucher werden geregelt.'
+                : $this->nichtGeregelteGeraeteText($nichtGeregelt)
        );

        $letzteSollwerte = $this->leseJsonAttribut('LetzteSollwerte');
@@ -1450,7 +1502,18 @@ class Manager extends IPSModule implements ManagerSchnittstelle

            $token = trim($this->ReadAttributeString('PrognoseInstallationsToken'));
            if ($token === '') {
-                throw new RuntimeException('Der Geraetezugang fuer die Stoerueberwachung fehlt.');
+                $this->aktualisiereLizenzfreigabe(
+                    $this->ReadPropertyString('Lizenzcode'),
+                    true
+                );
+                $token = trim($this->ReadAttributeString('PrognoseInstallationsToken'));
+            }
+            if ($token === '') {
+                $lizenzfehler = trim($this->ReadAttributeString('LizenzLetzterFehler'));
+                throw new RuntimeException(
+                    'Der Geraetezugang fuer die Stoerueberwachung fehlt.'
+                    . ($lizenzfehler !== '' ? ' Lizenzpruefung: ' . $lizenzfehler : '')
+                );
            }
            $snapshot['capturedAt'] = gmdate('Y-m-d\TH:i:s\Z', $jetzt);
            $this->uebertrageStoerungsSnapshot(
@@ -2126,8 +2189,7 @@ class Manager extends IPSModule implements ManagerSchnittstelle
            && $this->lizenzBerechtigungenPassen($lease, $lastspitzenmodus);
        $gueltig = $leaseGueltig && $berechtigungenPassen;
        $berechtigungenVeraltet = $basisGueltig && !$berechtigungenPassen;
-        $geraetezugangFehlt = ($this->ReadPropertyBoolean('PrognoseAktiv')
-                || $this->ReadPropertyBoolean('StoerueberwachungAktiv'))
+        $geraetezugangFehlt = $this->geraetezugangBenoetigt()
            && $this->ReadAttributeString('PrognoseInstallationsToken') === '';
        $routineFaellig = (!$gueltig && !$berechtigungenVeraltet)
            || $geraetezugangFehlt
@@ -2266,12 +2328,7 @@ class Manager extends IPSModule implements ManagerSchnittstelle
    /** @param array<string, mixed> $lease */
    private function prognoseBerechtigungInLease(array $lease): bool
    {
-        return Lizenzpruefung::berechtigungsMenge($lease, Lizenzpruefung::NETZFAHRPLAN) > 0
-            || (Lizenzpruefung::berechtigungsMenge($lease, Lizenzpruefung::PROGNOSE_PV) > 0
-                && Lizenzpruefung::berechtigungsMenge(
-                    $lease,
-                    Lizenzpruefung::PROGNOSE_VERBRAUCH
-                ) > 0);
+        return Lizenzpruefung::hatPrognoseBerechtigung($lease);
    }

    private function berechtigungLizenziert(string $kennung, ?string $lizenzcode = null): bool
@@ -2421,7 +2478,10 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        if (!$lizenziert) {
            return 'Prognosen sind deaktiviert. Fuer die Manager-ID '
                . $managerID
-                . ' fehlen forecast_pv plus forecast_load oder grid_schedule.';
+                . ' ist keine Prognoseberechtigung vorhanden. Benoetigt wird entweder '
+                . 'PV-Ertragsprognose zusammen mit Verbrauchsprognose oder der '
+                . 'Intelligente Netzfahrplan. Nach der Erweiterung im Lizenzportal '
+                . 'die Lizenz erneut pruefen und binden.';
        }

        return ($aktiv ? 'Prognosen sind aktiviert. ' : 'Prognosen sind deaktiviert. ')
@@ -2480,8 +2540,7 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        $nutzlast = json_encode([
            'code' => $lizenzcode,
            'installationId' => $installationID,
-            'issueDeviceToken' => ($this->ReadPropertyBoolean('PrognoseAktiv')
-                    || $this->ReadPropertyBoolean('StoerueberwachungAktiv'))
+            'issueDeviceToken' => $this->geraetezugangBenoetigt()
                && $this->ReadAttributeString('PrognoseInstallationsToken') === '',
        ], JSON_THROW_ON_ERROR | JSON_UNESCAPED_SLASHES);
        $curl = curl_init(self::LIZENZ_ENDPOINT);
@@ -2651,6 +2710,25 @@ class Manager extends IPSModule implements ManagerSchnittstelle
        );
    }

+    private function geraetezugangBenoetigt(): bool
+    {
+        if ($this->ReadPropertyBoolean('PrognoseAktiv')
+            || $this->ReadPropertyBoolean('StoerueberwachungAktiv')
+        ) {
+            return true;
+        }
+
+        try {
+            $topologie = $this->leseAnlagentopologie();
+        } catch (Throwable $fehler) {
+            return false;
+        }
+
+        return $topologie['inverters'] !== []
+            || $topologie['pvArrays'] !== []
+            || $topologie['batteries'] !== [];
+    }
+
    private function prognoseTelemetrieKonfiguriert(): bool
    {
        return $this->ReadPropertyBoolean('PrognoseAktiv')
@@ -2702,11 +2780,6 @@ class Manager extends IPSModule implements ManagerSchnittstelle

    private function synchronisiereAnlagentopologie(): void
    {
-        if (!$this->ReadPropertyBoolean('PrognoseAktiv')) {
-            $this->setzeDiagnosewert('Prognosestatus', 'NichtVerwendet');
-            return;
-        }
-
        try {
            $topologie = $this->leseAnlagentopologie();
            if ($topologie['inverters'] === []
@@ -2722,7 +2795,12 @@ class Manager extends IPSModule implements ManagerSchnittstelle
                throw new RuntimeException('Der Geraetezugang fuer die Prognose fehlt.');
            }
            $this->sendeAnlagentopologie($topologie, $token);
-            $this->setzeDiagnosewert('Prognosestatus', 'Verbunden');
+            $this->setzeDiagnosewert(
+                'Prognosestatus',
+                $this->ReadPropertyBoolean('PrognoseAktiv')
+                    ? 'Verbunden'
+                    : 'Topologie synchronisiert'
+            );
        } catch (Throwable $fehler) {
            $meldung = substr($fehler->getMessage(), 0, 500);
            $this->setzeDiagnosewert('Prognosestatus', 'Fehler: ' . $meldung);
@@ -43,12 +43,16 @@ Ein Betriebsartwechsel wird synchronisiert:
 3. `null` ist nur eine Ankuendigung und kein Schaltbefehl.
 4. Jeder Verbraucher berechnet sein zustandsabhaengiges Leistungsangebot neu
   und meldet es mit derselben Betriebsart zurueck.
-5. Erst wenn alle aktiven Verbraucher synchronisiert sind, verteilt der
-   Manager konkrete Sollleistungen.
+5. Der Manager verteilt konkrete Sollleistungen an alle bereits
+   synchronisierten Verbraucher.
+6. Fehlende, veraltete oder noch nicht umgeschaltete Verbraucher bleiben von
+   der Verteilung ausgeschlossen und werden als Stoerung ausgewiesen.

-Der Manager verwendet damit nie ein PV-Angebot fuer Peak oder umgekehrt. Eine
-technische Schaltsperre, eine ausstehende Rueckmeldung oder eine Mindestzeit
-kann das Angebot weiterhin auf die aktuell gehaltene Leistung begrenzen.
+Der Manager verwendet damit nie ein PV-Angebot fuer Peak oder umgekehrt. Ein
+nicht antwortender Verbraucher blockiert die Regelung der uebrigen Anlage
+nicht; sein aktueller Einfluss ist bereits in der Netzleistungsmessung
+enthalten. Eine technische Schaltsperre oder eine Mindestzeit kann das Angebot
+weiterhin auf die aktuell gehaltene Leistung begrenzen.

 | Verbraucher | PV-Angebot | Peak-Angebot |
 | --- | --- | --- |
@@ -130,6 +130,20 @@
                    "minimum": 0.1,
                    "digits": 1
                },
+                {
+                    "type": "NumberSpinner",
+                    "name": "TemperaturUntergrenze",
+                    "caption": "Untertemperaturgrenze",
+                    "suffix": " °C",
+                    "digits": 1
+                },
+                {
+                    "type": "NumberSpinner",
+                    "name": "TemperaturObergrenze",
+                    "caption": "Übertemperaturgrenze",
+                    "suffix": " °C",
+                    "digits": 1
+                },
                {
                    "type": "List",
                    "name": "Zeitplan",
@@ -56,6 +56,8 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
        $this->RegisterPropertyString('Zeitplan', '[]');
        $this->RegisterPropertyInteger('LastwechselSperrzeit', 5);
        $this->RegisterPropertyInteger('TemperaturMaxAlter', 30);
+        $this->RegisterPropertyFloat('TemperaturUntergrenze', 0.0);
+        $this->RegisterPropertyFloat('TemperaturObergrenze', 100.0);
        $this->RegisterPropertyFloat('Hysterese', 5.0);
        $this->RegisterPropertyBoolean('LegionellenfunktionAktiv', true);
        $this->RegisterPropertyInteger('LegionellenMinimalintervallTage', 4);
@@ -537,6 +539,10 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
        if (!$temperaturGueltig) {
            $stoerungen[] = 'Boilertemperatur fehlt oder ist veraltet.';
        }
+        $untertemperatur = $this->istUntertemperatur($temperaturGueltig);
+        if ($untertemperatur) {
+            $stoerungen[] = 'Untertemperatur erkannt.';
+        }
        $uebertemperatur = $this->istUebertemperatur($temperaturGueltig);
        if ($uebertemperatur) {
            $stoerungen[] = 'Uebertemperatur erkannt.';
@@ -555,19 +561,18 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
        }
    }

+    private function istUntertemperatur(bool $temperaturGueltig): bool
+    {
+        return $temperaturGueltig
+            && (float) $this->GetValue('Boilertemperatur')
+                < $this->ReadPropertyFloat('TemperaturUntergrenze');
+    }
+
    private function istUebertemperatur(bool $temperaturGueltig): bool
    {
-        if (!$temperaturGueltig) {
-            return false;
-        }
-
-        $grenze = (float) $this->GetValue('Maximaltemperatur');
-        if ($this->ReadPropertyBoolean('LegionellenfunktionAktiv')) {
-            $grenze = max($grenze, $this->ReadAttributeFloat('ZustandLegionellentemperatur'));
-        }
-
-        return (float) $this->GetValue('Boilertemperatur')
-            > $grenze + $this->ReadPropertyFloat('Hysterese');
+        return $temperaturGueltig
+            && (float) $this->GetValue('Boilertemperatur')
+                > $this->ReadPropertyFloat('TemperaturObergrenze');
    }

    private function sendeVerbraucherdaten(): void
@@ -592,6 +597,7 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
    {
        $temperaturGueltig = (bool) $this->leseZustand('TemperaturGueltig');
        $schaltfehler = $this->ReadAttributeString('Schaltfehler');
+        $untertemperatur = $this->istUntertemperatur($temperaturGueltig);
        $uebertemperatur = $this->istUebertemperatur($temperaturGueltig);

        return [
@@ -655,6 +661,13 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
                    'Einheit' => '',
                    'Text' => $temperaturGueltig ? '' : 'Boilertemperatur fehlt oder ist veraltet.',
                ],
+                [
+                    'Kennung' => 'Untertemperatur',
+                    'Art' => 'Stoerung',
+                    'Wert' => $untertemperatur,
+                    'Einheit' => '',
+                    'Text' => $untertemperatur ? 'Untertemperatur erkannt.' : '',
+                ],
                [
                    'Kennung' => 'Uebertemperatur',
                    'Art' => 'Stoerung',
@@ -745,6 +758,13 @@ class VerbraucherWarmwassererwaermer extends IPSModule implements VerbraucherSch
        if ($this->ReadPropertyFloat('Hysterese') <= 0) {
            throw new InvalidArgumentException('Hysterese muss groesser als 0 sein.');
        }
+        if ($this->ReadPropertyFloat('TemperaturUntergrenze')
+            >= $this->ReadPropertyFloat('TemperaturObergrenze')
+        ) {
+            throw new InvalidArgumentException(
+                'Die Temperaturuntergrenze muss kleiner als die Temperaturobergrenze sein.'
+            );
+        }
        $minimum = (float) $this->GetValue('Mindesttemperatur');
        $maximum = (float) $this->GetValue('Maximaltemperatur');
        $legionellen = (float) $this->ReadAttributeFloat('ZustandLegionellentemperatur');
@@ -78,8 +78,11 @@ zulaessig ist.
   `Sollleistung_W=null`.
 4. Jeder Verbraucher berechnet und meldet seine PowerSteps fuer diese
   Betriebsart.
-5. Erst wenn alle aktiven Verbraucher synchronisiert sind, verteilt der Manager
-   Sollleistungen.
+5. Der Manager verteilt Sollleistungen an alle bereits synchronisierten
+   Verbraucher.
+6. Fehlende, veraltete oder noch nicht umgeschaltete Verbraucher werden nicht
+   angesteuert und als Stoerung ausgewiesen; sie blockieren die aktuellen
+   Verbraucher nicht.

 Damit kann jeder Verbrauchertyp unterschiedliche Angebote fuer PV und Peak
 melden, ohne dass der Manager seine interne Geraetelogik kennen muss.
@@ -87,6 +90,12 @@ melden, ohne dass der Manager seine interne Geraetelogik kennen muss.
 ## Feste Regeln

 - Prioritaeten beginnen bei 0; eine kleinere Zahl bedeutet hoehere Prioritaet.
+- Jeder verfuegbare, synchronisierte Verbraucher mit einem nicht leeren
+  `Leistungswerte_W`-Angebot erhaelt einen Sollwert aus genau diesem Angebot.
+- `AenderungMoeglich=false` kennzeichnet ein fixes Angebot und ist kein
+  Ausschlussgrund. Ein Angebot `[11000]` fuehrt deshalb zwingend zu `11000 W`.
+- Prioritaeten verteilen nur die ueber den jeweiligen Mindestwert hinaus
+  verfuegbare Leistung; sie duerfen keinen angebotenen Mindestwert verdrängen.
 - `Leistungsquelle`: 0 nicht vorhanden, 1 berechnet, 2 gemessen.
 - Bei Leistungsquelle 0 ist `Istleistung_W` zwingend `null`.
 - Leistungsbereiche enthalten jeden ganzen Wattwert von `Von_W` bis `Bis_W`.
@@ -13,9 +13,11 @@
 | `Interval` | entfaellt | Die Regelung wird ereignisbasiert ausgeloest. |
 | `IdleCounterMax` | `LastwechselSperrzeit` | Zykluszaehler wird durch eine Sperrzeit in Sekunden ersetzt; Standard `5`. |

-Die neuen Properties `TemperaturMaxAlter`, `Hysterese`, die Parameter der
-Legionellenfunktion und `DiagnosevariablenAnzeigen` ersetzen feste Werte und
-nicht pruefbare Annahmen des Altmoduls.
+Die neuen Properties `TemperaturMaxAlter`, `TemperaturUntergrenze`,
+`TemperaturObergrenze`, `Hysterese`, die Parameter der Legionellenfunktion und
+`DiagnosevariablenAnzeigen` ersetzen feste Werte und nicht pruefbare Annahmen
+des Altmoduls. Die Stoergrenzen liegen standardmaessig bei 0 und 100 Grad C und
+sind von den Regel-Sollwerten `Mindesttemperatur` und `Maximaltemperatur` getrennt.

 ## Variablen

@@ -58,12 +58,15 @@ als ungueltig behandelt und ergeben bis zur gueltigen 1-/3-Phasenmeldung nur

 Immer sichtbar sind `Aktiv`, `FahrzeugVerbunden`, `FahrzeugGeladen`,
 `Fahrzeugstatus`, `Ladestrom` und `Phasenzahl`. Der normalisierte
-Fahrzeugstatus ist `0` unbekannt, `1` getrennt, `2` bereit, `3` laedt,
-`4` geladen oder `5` Fehler.
+Fahrzeugstatus ist `0` unbekannt, `1` getrennt, `2` wartet auf Start,
+`3` laedt, `4` geladen oder `5` Fehler.

 Optional sichtbar sind die gemeinsamen EMS-Diagnosewerte sowie
-`GatewayVerbunden`, `ApiMaximalstrom`, `LetzterGeraetebefehl` und
-`LeistungsangebotDiagnose`.
+`GatewayVerbunden`, `ApiMaximalstrom`, `EaseeAktiviert`,
+`AutorisierungErforderlich`, `RemoteStartErforderlich`, `SmartCharging`,
+`GrundKeinLadestrom`, `LetzterGeraetebefehl`, `LetzterStartbefehl` und
+`LeistungsangebotDiagnose`. `GrundKeinLadestrom=55` bedeutet bei Easee, dass
+die Autorisierung fehlt.

 ## Regelung

@@ -83,7 +86,10 @@ Angebot sofort neu und meldet die Aenderung kurz gebuendelt an den Manager.
 Bei einer Gateway-Unterbrechung werden Fahrzeug- und Phasenstatus sofort
 verworfen; erst ein neuer aktueller Gateway-Zustand gibt die Regelung wieder
 frei. Die eigentliche Vorgabe wird als dynamischer Ladestrom mit `minutes=0`
-an Easee gesendet.
+an Easee gesendet. Meldet Easee bei positiver Stromvorgabe weiterhin
+`Awaiting Start`, sendet das Modul einmal pro Fahrzeugverbindung zusaetzlich
+`start_charging`. Dieser Befehl autorisiert den Ladevorgang, uebersteuert aber
+keinen vorhandenen Easee-Ladeplan.

 ## Managerkommunikation

@@ -279,6 +279,7 @@ stabile ID gebunden werden.
 | HTTP `429` | Zu viele Aktivierungsversuche; vor dem naechsten Versuch warten. |
 | `Lizenzserver nicht erreichbar` | DNS, Internetzugang, HTTPS und Systemzeit des Symcon-Systems pruefen. Eine bestehende Lease gilt nur bis `offlineUntil`. |
 | `Offline-Freigabe ist abgelaufen.` | Verbindung zum Lizenzserver wiederherstellen und Lizenz erneut pruefen. |
+| `Keine Prognoseberechtigung vorhanden` | Im Lizenzportal entweder PV-Ertragsprognose zusammen mit Verbrauchsprognose oder den Intelligenten Netzfahrplan ergaenzen. Anschliessend im Manager `Lizenz pruefen und binden` ausloesen, die Prognose aktivieren und die Konfiguration speichern. |

 Fuer eine genauere Diagnose koennen die Diagnosevariablen eingeblendet werden.
 `Lizenzstatus` zeigt dann den aktuellen Zustand. Mit aktiviertem Debug-Logging
@@ -302,14 +303,22 @@ der aktiven Betriebsart und der aktuellen Leistung aller frisch gemeldeten
 Verbraucher. Eine gültige Istleistung wird bevorzugt; fehlt sie, bleibt der im
 Zustand bestätigte Sollwert konservativ reserviert.

-Nicht verfügbare, nicht änderbare oder aktuell angebotlose Verbraucher behalten
-ihre Leistung und erhalten keine neue Vorgabe. Die übrigen Verbraucher werden
-nach der gemeldeten PV- beziehungsweise Peak-Priorität und danach stabil nach
-Instanz-ID sortiert. Von ihrem jeweils kleinsten erlaubten Leistungswert aus
-wird das Budget in dieser Reihenfolge aufgefüllt. Einzelwerte und ganzzahlige
-Bereiche werden direkt verarbeitet; Lücken werden nie durch unzulässige Werte
-geschlossen. Eine verbleibende Abweichung wird im `Verbraucherstatus`
-dokumentiert.
+Nicht verfügbare oder aktuell angebotlose Verbraucher behalten ihre Leistung
+und erhalten keine neue Vorgabe. Jeder verfügbare, synchronisierte Verbraucher
+mit einem nicht leeren Angebot erhält dagegen einen Sollwert aus diesem Angebot.
+Das gilt auch bei `AenderungMoeglich=false`: Ein fixes Angebot wie `[11000]`
+wird mit genau `11000 W` zugeteilt.
+
+Die Verbraucher werden nach der gemeldeten PV- beziehungsweise Peak-Priorität
+sortiert. Bei gleicher Priorität bevorzugt der Manager wie Enelix 1 den
+Verbraucher mit der bisher kleineren bezogenen Energie; verglichen wird in
+2-kWh-Gruppen. Erst wenn auch diese Gruppe gleich ist, entscheidet stabil die
+Instanz-ID. Zuerst reserviert der Manager für jeden Verbraucher den kleinsten
+erlaubten Leistungswert. Nur das danach
+verbleibende Budget wird in Prioritätsreihenfolge aufgefüllt. Einzelwerte und
+ganzzahlige Bereiche werden direkt verarbeitet; Lücken werden nie durch
+unzulässige Werte geschlossen. Eine verbleibende Abweichung wird im
+`Verbraucherstatus` dokumentiert.

 Die Betriebsart wechselt unterhalb des Solar-Sollwerts zu `PV` und oberhalb
 der wirksamen Lastspitzengrenze zu `Peak`. Zwischen den beiden Zielwerten
@@ -8,7 +8,8 @@ final class EaseeGatewayProtokoll
 {
    /** @var list<int> */
    public const BEOBACHTUNGEN = [
-        47, 48, 100, 104, 109, 110, 119, 120, 182, 183, 184, 185, 250,
+        31, 41, 42, 43, 47, 48, 62, 96, 100, 102, 104, 109, 110,
+        111, 112, 113, 114, 119, 120, 182, 183, 184, 185, 250,
    ];

    public static function seriennummer(string $wert): string
@@ -22,6 +22,11 @@ final class EaseeLadestatus
     *   Istleistung_W: float,
     *   Ladestrom_A: float,
     *   ApiMaximalstrom_A: int,
+     *   EaseeAktiviert: bool,
+     *   AutorisierungErforderlich: bool,
+     *   RemoteStartErforderlich: bool,
+     *   SmartCharging: bool,
+     *   GrundKeinLadestrom: int,
     *   Stoerung: bool,
     *   Stoertext: string
     * }
@@ -48,11 +53,16 @@ final class EaseeLadestatus
            ? self::phasenzahl((int) ($beobachtungen['110'] ?? 0))
            : 0;

-        $leistung = max(0.0, (float) ($beobachtungen['120'] ?? 0.0) * 1000.0);
+        $laedt = $betriebszustand === 3;
+        $leistung = $laedt
+            ? max(0.0, (float) ($beobachtungen['120'] ?? 0.0) * 1000.0)
+            : 0.0;
        $stroeme = [];
-        foreach ([182, 183, 184, 185] as $id) {
-            if (array_key_exists((string) $id, $beobachtungen)) {
-                $stroeme[] = abs((float) $beobachtungen[(string) $id]);
+        if ($laedt) {
+            foreach ([182, 183, 184, 185] as $id) {
+                if (array_key_exists((string) $id, $beobachtungen)) {
+                    $stroeme[] = abs((float) $beobachtungen[(string) $id]);
+                }
            }
        }
        $ladestrom = $stroeme === [] ? 0.0 : max($stroeme);
@@ -65,6 +75,16 @@ final class EaseeLadestatus
            }
        }
        $apiMaximalstrom = max(6, min($grenzen));
+        $easeeAktiviert = !array_key_exists('31', $beobachtungen)
+            || (bool) $beobachtungen['31'];
+        $autorisierungErforderlich = (bool) (
+            $beobachtungen['42'] ?? $beobachtungen['41'] ?? false
+        );
+        $remoteStartErforderlich = (bool) ($beobachtungen['43'] ?? false);
+        $smartCharging = (bool) ($beobachtungen['102'] ?? false);
+        $grundKeinLadestrom = is_numeric($beobachtungen['96'] ?? null)
+            ? (int) $beobachtungen['96']
+            : 0;

        $fehlercode = (int) ($beobachtungen['119'] ?? 0);
        $stoerung = $betriebszustand === 5 || $fehlercode !== 0;
@@ -85,6 +105,11 @@ final class EaseeLadestatus
            'Istleistung_W' => $leistung,
            'Ladestrom_A' => $ladestrom,
            'ApiMaximalstrom_A' => $apiMaximalstrom,
+            'EaseeAktiviert' => $easeeAktiviert,
+            'AutorisierungErforderlich' => $autorisierungErforderlich,
+            'RemoteStartErforderlich' => $remoteStartErforderlich,
+            'SmartCharging' => $smartCharging,
+            'GrundKeinLadestrom' => $grundKeinLadestrom,
            'Stoerung' => $stoerung,
            'Stoertext' => trim($stoertext),
        ];
@@ -91,7 +91,7 @@ final class LadestationAdapter
    }

    /**
-     * @return array{Rohstatus: int, Istleistung_W: float}
+     * @return array{Rohstatus: int, Istleistung_W: float, Iststrom_A?: float}
     */
    public static function dekodiereStatus(int $geraetetyp, string $antwort): array
    {
@@ -110,12 +110,25 @@ final class LadestationAdapter
                throw new RuntimeException('Die go-e-Antwort enthaelt nicht alle Statusfelder.');
            }

-            $faktor = $geraetetyp === self::GO_E_ALT ? 10.0 : 1.0;
-
-            return [
+            $leistungsfaktor = $geraetetyp === self::GO_E_ALT ? 10.0 : 1.0;
+            $status = [
                'Rohstatus' => (int) $daten['car'],
-                'Istleistung_W' => (float) $daten['nrg'][11] * $faktor,
+                'Istleistung_W' => (float) $daten['nrg'][11] * $leistungsfaktor,
            ];
+            if (isset($daten['nrg'][4], $daten['nrg'][5], $daten['nrg'][6])
+                && is_numeric($daten['nrg'][4])
+                && is_numeric($daten['nrg'][5])
+                && is_numeric($daten['nrg'][6])
+            ) {
+                $stromfaktor = $geraetetyp === self::GO_E_ALT ? 0.1 : 1.0;
+                $status['Iststrom_A'] = max(
+                    (float) $daten['nrg'][4],
+                    (float) $daten['nrg'][5],
+                    (float) $daten['nrg'][6]
+                ) * $stromfaktor;
+            }
+
+            return $status;
        }

        if ($geraetetyp === self::SMART_ME_PICO) {
@@ -28,14 +28,20 @@ final class LadestationRegler
    ];

    /**
-     * Die Schwelle, die Voll-Erkennung und der Zuschlag von 2.5 A stammen
-     * aus der Enelix-1-Ladestation und bleiben bewusst kompatibel.
+     * Die Schwelle und der Zuschlag von 2.5 A stammen aus der Enelix-1-Ladestation.
+     * Ein Ladeende wird erst nach zuvor gemessener Ladeleistung angenommen, damit
+     * die Anlaufzeit nach einer neuen Stromvorgabe nicht als volles Fahrzeug gilt.
     *
-     * @param array{Rohstatus: int, Istleistung_W: float} $rohstatus
+     * @param array{Rohstatus: int, Istleistung_W: float, Iststrom_A?: float} $rohstatus
     * @return array<string, int|float|bool>
     */
-    public static function normalisiereStatus(array $rohstatus, bool $warVerbunden): array
-    {
+    public static function normalisiereStatus(
+        array $rohstatus,
+        bool $warVerbunden,
+        bool $warGeladen = false,
+        bool $ladungErwartet = true,
+        bool $ladeleistungWurdeErkannt = false
+    ): array {
        $verbunden = $rohstatus['Rohstatus'] !== 1;
        $leistung = max(0.0, $rohstatus['Istleistung_W']);
        $phasen = self::PHASEN_UNBEKANNT;
@@ -45,9 +51,15 @@ final class LadestationRegler
        if ($verbunden) {
            $phasen = $leistung > 7500.0 ? self::PHASEN_DREI : self::PHASEN_EIN;
            $nenner = $phasen === self::PHASEN_EIN ? 230.0 : 1.71 * 400.0;
-            $ladestrom = $leistung / $nenner;
+            $ladestrom = isset($rohstatus['Iststrom_A'])
+                ? max(0.0, (float) $rohstatus['Iststrom_A'])
+                : $leistung / $nenner;
            $ermittelterMaximalstrom = 2.5 + $ladestrom;
-            $geladen = $warVerbunden && $ermittelterMaximalstrom < 6.0;
+            $geladen = $warGeladen
+                || ($warVerbunden
+                    && $ladungErwartet
+                    && $ladeleistungWurdeErkannt
+                    && $ermittelterMaximalstrom < 6.0);
        }

        if (!$verbunden) {
@@ -70,6 +82,26 @@ final class LadestationRegler
        ];
    }

+    public static function ermittleFahrzeugMaximalstrom(
+        int $vorgegebenerStrom,
+        float $gemessenerStrom,
+        int $konfigurierterMaximalstrom
+    ): ?int {
+        if ($konfigurierterMaximalstrom < 6 || $konfigurierterMaximalstrom > 32) {
+            throw new InvalidArgumentException('MaximalerLadestrom muss zwischen 6 und 32 A liegen.');
+        }
+        if ($vorgegebenerStrom < 6 || $gemessenerStrom < 5.5) {
+            return null;
+        }
+
+        $kandidat = max(6, min($konfigurierterMaximalstrom, (int) round($gemessenerStrom)));
+        if ($kandidat > $vorgegebenerStrom - 2 || $kandidat >= $konfigurierterMaximalstrom) {
+            return null;
+        }
+
+        return $kandidat;
+    }
+
    /** @return list<int> */
    public static function leistungsangebot(
        bool $aktiv,
@@ -117,6 +117,19 @@ final class Lizenzpruefung
        return $menge;
    }

+    /**
+     * Eine Prognose ist entweder durch den Netzfahrplan oder durch beide
+     * Einzelberechtigungen fuer PV und Verbrauch freigeschaltet.
+     *
+     * @param array<string, mixed> $lease
+     */
+    public static function hatPrognoseBerechtigung(array $lease): bool
+    {
+        return self::berechtigungsMenge($lease, self::NETZFAHRPLAN) > 0
+            || (self::berechtigungsMenge($lease, self::PROGNOSE_PV) > 0
+                && self::berechtigungsMenge($lease, self::PROGNOSE_VERBRAUCH) > 0);
+    }
+
    /**
     * Rechnet freie, bestehende Einzellizenzen auf nicht separat lizenzierte Waermepumpen an.
     *
@@ -92,6 +92,7 @@ final class ManagerRegler

    /**
     * @param list<array<string, mixed>> $verbraucher Vollstaendige, bereits gepruefte Verbraucherdaten
+     * @param array<int, float|int> $bezogeneEnergieWh Bezogene Energie je Verbraucher in Wh
     * @return array{
     *     Verteilbudget_W: int,
     *     AktuelleVerbraucherleistung_W: int,
@@ -104,7 +105,8 @@ final class ManagerRegler
        float $netzleistung,
        float $zielnetzleistung,
        array $verbraucher,
-        string $prioritaetsfeld
+        string $prioritaetsfeld,
+        array $bezogeneEnergieWh = []
    ): array {
        if (!in_array($prioritaetsfeld, ['PrioritaetPV', 'PrioritaetPeak'], true)) {
            throw new InvalidArgumentException('Unbekanntes Prioritaetsfeld.');
@@ -120,20 +122,35 @@ final class ManagerRegler
            $aktuelleLeistung += $leistung;

            $daten = $eintrag['Daten'];
-            if (!$daten['Verfuegbar'] || !$daten['AenderungMoeglich'] || $daten['Leistungswerte_W'] === []) {
+            if (!$daten['Verfuegbar'] || $daten['Leistungswerte_W'] === []) {
                $nichtSteuerbar += $leistung;
                continue;
            }

+            $energie = $bezogeneEnergieWh[$eintrag['InstanzID']] ?? 0.0;
+            if ((!is_int($energie) && !is_float($energie))
+                || (is_float($energie) && !is_finite($energie))
+            ) {
+                throw new InvalidArgumentException('Bezogene Energie muss eine endliche Zahl sein.');
+            }
            $steuerbar[] = [
                'InstanzID' => $eintrag['InstanzID'],
                'Prioritaet' => $daten[$prioritaetsfeld],
+                'Energiegruppe' => (int) round((float) $energie / 2000.0),
                'Leistungswerte_W' => $daten['Leistungswerte_W'],
            ];
        }

        usort($steuerbar, static function (array $links, array $rechts): int {
-            return [$links['Prioritaet'], $links['InstanzID']] <=> [$rechts['Prioritaet'], $rechts['InstanzID']];
+            return [
+                $links['Prioritaet'],
+                $links['Energiegruppe'],
+                $links['InstanzID'],
+            ] <=> [
+                $rechts['Prioritaet'],
+                $rechts['Energiegruppe'],
+                $rechts['InstanzID'],
+            ];
        });

        $verteilbudget = (int) round($aktuelleLeistung + $zielnetzleistung - $netzleistung);
@@ -45,6 +45,37 @@ final class EaseeGatewayProtokollTest extends TestCase
        self::assertSame([], $beobachtungen);
    }

+    public function testRestBeobachtungenVerwendenAngefragteSeriennummer(): void
+    {
+        $beobachtungen = EaseeGatewayProtokoll::extrahiereBeobachtungen([
+            ['id' => 109, 'value' => 1],
+            ['observationId' => 110, 'value' => 30],
+        ], ['EU2FGKEU'], 'EU2FGKEU');
+
+        self::assertSame([
+            ['Seriennummer' => 'EU2FGKEU', 'ID' => 109, 'Wert' => 1],
+            ['Seriennummer' => 'EU2FGKEU', 'ID' => 110, 'Wert' => 30],
+        ], $beobachtungen);
+    }
+
+    public function testFreigabediagnoseWirdAusBeobachtungenExtrahiert(): void
+    {
+        $beobachtungen = EaseeGatewayProtokoll::extrahiereBeobachtungen([
+            'serialNumber' => 'EH123456',
+            'observations' => [
+                ['id' => 42, 'value' => true],
+                ['id' => 43, 'value' => true],
+                ['id' => 96, 'value' => 55],
+            ],
+        ], ['EH123456']);
+
+        self::assertSame([
+            ['Seriennummer' => 'EH123456', 'ID' => 42, 'Wert' => true],
+            ['Seriennummer' => 'EH123456', 'ID' => 43, 'Wert' => true],
+            ['Seriennummer' => 'EH123456', 'ID' => 96, 'Wert' => 55],
+        ], $beobachtungen);
+    }
+
    public function testSeriennummerWirdNormalisiert(): void
    {
        self::assertSame(
@@ -77,6 +77,33 @@ final class EaseeLadestatusTest extends TestCase
        self::assertSame(0, $status['Phasenzahl']);
    }

+    public function testStillstehendeWallboxSetztVeralteteLeistungUndStromAufNull(): void
+    {
+        $status = EaseeLadestatus::ausBeobachtungen([
+            '109' => 2,
+            '110' => 30,
+            '120' => 10.294,
+            '182' => 14.9,
+            '183' => 14.8,
+            '184' => 14.7,
+        ], 32);
+
+        self::assertEqualsWithDelta(0.0, $status['Istleistung_W'], 0.01);
+        self::assertEqualsWithDelta(0.0, $status['Ladestrom_A'], 0.01);
+    }
+
+    public function testFertigGeladeneWallboxSetztVeralteteLeistungAufNull(): void
+    {
+        $status = EaseeLadestatus::ausBeobachtungen([
+            '109' => 4,
+            '110' => 30,
+            '120' => 10.294,
+        ], 32);
+
+        self::assertTrue($status['FahrzeugGeladen']);
+        self::assertEqualsWithDelta(0.0, $status['Istleistung_W'], 0.01);
+    }
+
    public function testApiUndKabelgrenzenBegrenzenDenKonfiguriertenStrom(): void
    {
        $status = EaseeLadestatus::ausBeobachtungen([
@@ -89,6 +116,24 @@ final class EaseeLadestatusTest extends TestCase
        self::assertSame(13, $status['ApiMaximalstrom_A']);
    }

+    public function testFreigabeUndGrundOhneLadestromKommenAusEaseeBeobachtungen(): void
+    {
+        $status = EaseeLadestatus::ausBeobachtungen([
+            '31' => true,
+            '42' => true,
+            '43' => true,
+            '96' => 55,
+            '102' => true,
+            '109' => 2,
+        ], 16);
+
+        self::assertTrue($status['EaseeAktiviert']);
+        self::assertTrue($status['AutorisierungErforderlich']);
+        self::assertTrue($status['RemoteStartErforderlich']);
+        self::assertTrue($status['SmartCharging']);
+        self::assertSame(55, $status['GrundKeinLadestrom']);
+    }
+
    public function testNurSolarladenIstFestErzwungen(): void
    {
        self::assertFalse(EaseeLadestatus::solarladenErzwungen(0));
@@ -70,6 +70,12 @@ final class EaseeModuleStrukturTest extends TestCase
        self::assertStringContainsString("'Phasenzahl'", $modul);
        self::assertStringNotContainsString('7500', $modul);
        self::assertStringNotContainsString('Abfrageintervall', $modul);
+        self::assertStringContainsString("'action' => 'StartCharging'", $modul);
+
+        $gateway = (string) file_get_contents(
+            __DIR__ . '/../EaseeGateway/module.php'
+        );
+        self::assertStringContainsString('/commands/start_charging', $gateway);
    }

    /** @return array<string, mixed> */
@@ -13,7 +13,7 @@ final class LadestationAdapterTest extends TestCase
    /**
     * @dataProvider statusFaelle
     * @param array<string, string> $konfiguration
-     * @param array{Rohstatus: int, Istleistung_W: float} $erwartet
+     * @param array{Rohstatus: int, Istleistung_W: float, Iststrom_A?: float} $erwartet
     */
    public function testStatusaufrufUndDekodierungFuerAlleGeraete(
        int $geraetetyp,
@@ -47,16 +47,16 @@ final class LadestationAdapterTest extends TestCase
        yield 'go-e alt' => [
            LadestationAdapter::GO_E_ALT,
            $this->lokaleKonfiguration(),
-            $this->goEAntwort(2, 1100),
+            $this->goEAntwort(2, 1100, [160, 158, 159]),
            'http://192.0.2.10/mqtt?payload=',
-            ['Rohstatus' => 2, 'Istleistung_W' => 11000.0],
+            ['Rohstatus' => 2, 'Istleistung_W' => 11000.0, 'Iststrom_A' => 16.0],
        ];
        yield 'go-e Gemini' => [
            LadestationAdapter::GO_E_GEMINI,
            $this->lokaleKonfiguration(),
-            $this->goEAntwort(2, 2300),
+            $this->goEAntwort(2, 2300, [9.8, 0, 0]),
            'http://192.0.2.10/api/status',
-            ['Rohstatus' => 2, 'Istleistung_W' => 2300.0],
+            ['Rohstatus' => 2, 'Istleistung_W' => 2300.0, 'Iststrom_A' => 9.8],
        ];
        yield 'Smart-me Pico' => [
            LadestationAdapter::SMART_ME_PICO,
@@ -161,9 +161,13 @@ final class LadestationAdapterTest extends TestCase
        ];
    }

-    private function goEAntwort(int $status, float $leistung): string
+    /** @param list<int|float> $stroeme */
+    private function goEAntwort(int $status, float $leistung, array $stroeme): string
    {
        $nrg = array_fill(0, 12, 0);
+        foreach (array_values($stroeme) as $index => $strom) {
+            $nrg[4 + $index] = $strom;
+        }
        $nrg[11] = $leistung;

        return json_encode(['car' => $status, 'nrg' => $nrg], JSON_THROW_ON_ERROR);
@@ -33,17 +33,68 @@ final class LadestationReglerTest extends TestCase
        self::assertEqualsWithDelta(10.0, $status['Ladestrom_A'], 0.01);
    }

-    public function testGeladenWirdNachVerbindungUnterSechsAmpereErkannt(): void
+    public function testAnlaufOhneGemesseneLadeleistungGiltNichtAlsLadeende(): void
    {
        $status = LadestationRegler::normalisiereStatus([
            'Rohstatus' => 2,
            'Istleistung_W' => 0.0,
-        ], true);
+        ], true, false, true, false);
+
+        self::assertFalse($status['FahrzeugGeladen']);
+        self::assertSame(2, $status['Fahrzeugstatus']);
+    }
+
+    public function testGeladenWirdErstNachZuvorGemessenerLadeleistungErkannt(): void
+    {
+        $status = LadestationRegler::normalisiereStatus([
+            'Rohstatus' => 2,
+            'Istleistung_W' => 0.0,
+        ], true, false, true, true);

        self::assertTrue($status['FahrzeugGeladen']);
        self::assertSame(4, $status['Fahrzeugstatus']);
    }

+    public function testAbsichtlichGestoppteLadungWirdNichtAlsGeladenErkannt(): void
+    {
+        $status = LadestationRegler::normalisiereStatus([
+            'Rohstatus' => 2,
+            'Istleistung_W' => 0.0,
+        ], true, false, false);
+
+        self::assertFalse($status['FahrzeugGeladen']);
+        self::assertSame(2, $status['Fahrzeugstatus']);
+    }
+
+    public function testErkanntesLadeendeBleibtBisZumAbsteckenErhalten(): void
+    {
+        $status = LadestationRegler::normalisiereStatus([
+            'Rohstatus' => 2,
+            'Istleistung_W' => 0.0,
+        ], true, true, false);
+
+        self::assertTrue($status['FahrzeugGeladen']);
+        self::assertSame(4, $status['Fahrzeugstatus']);
+    }
+
+    public function testDirekterPhasenstromHatVorrangVorNominalerLeistungsumrechnung(): void
+    {
+        $status = LadestationRegler::normalisiereStatus([
+            'Rohstatus' => 2,
+            'Istleistung_W' => 10263.0,
+            'Iststrom_A' => 15.9,
+        ], true);
+
+        self::assertEqualsWithDelta(15.9, $status['Ladestrom_A'], 0.01);
+    }
+
+    public function testFahrzeugMaximalstromWirdMitZweiAmpereAbstandErkannt(): void
+    {
+        self::assertSame(16, LadestationRegler::ermittleFahrzeugMaximalstrom(20, 15.9, 20));
+        self::assertNull(LadestationRegler::ermittleFahrzeugMaximalstrom(17, 15.9, 20));
+        self::assertNull(LadestationRegler::ermittleFahrzeugMaximalstrom(20, 0.0, 20));
+    }
+
    public function testBetriebsartUndSolarladenBestimmenDasLeistungsangebot(): void
    {
        $solarPV = LadestationRegler::leistungsangebot(true, true, true, false, 1, 16, true, false);
@@ -228,6 +228,47 @@ final class LizenzpruefungTest extends TestCase
        Lizenzpruefung::pruefeVerbrauchermengen($lease, $pruefmengen);
    }

+    public function testPvUndVerbrauchGebenPrognoseFrei(): void
+    {
+        $lease = $this->lease('manager_standard');
+        $lease['entitlements'][] = [
+            'catalog_key' => Lizenzpruefung::PROGNOSE_PV,
+            'quantity' => 1,
+            'status' => 'active',
+        ];
+        $lease['entitlements'][] = [
+            'catalog_key' => Lizenzpruefung::PROGNOSE_VERBRAUCH,
+            'quantity' => 1,
+            'status' => 'active',
+        ];
+
+        self::assertTrue(Lizenzpruefung::hatPrognoseBerechtigung($lease));
+    }
+
+    public function testEinzelnePrognoseBerechtigungReichtNichtAus(): void
+    {
+        $lease = $this->lease('manager_standard');
+        $lease['entitlements'][] = [
+            'catalog_key' => Lizenzpruefung::PROGNOSE_PV,
+            'quantity' => 1,
+            'status' => 'active',
+        ];
+
+        self::assertFalse(Lizenzpruefung::hatPrognoseBerechtigung($lease));
+    }
+
+    public function testNetzfahrplanGibtPrognoseAlleineFrei(): void
+    {
+        $lease = $this->lease('manager_standard');
+        $lease['entitlements'][] = [
+            'catalog_key' => Lizenzpruefung::NETZFAHRPLAN,
+            'quantity' => 1,
+            'status' => 'active',
+        ];
+
+        self::assertTrue(Lizenzpruefung::hatPrognoseBerechtigung($lease));
+    }
+
    public function testLizenzcodeWirdWieAufDemServerNormalisiert(): void
    {
        self::assertSame(
@@ -218,14 +218,28 @@ final class ManagerModulstrukturTest extends TestCase
        self::assertStringContainsString("'issueDeviceToken' =>", $inhalt);
        self::assertStringContainsString("unset(\$neueLease['deviceToken'])", $inhalt);
        self::assertStringContainsString(
-            "|| \$this->ReadPropertyBoolean('StoerueberwachungAktiv'))",
+            "|| \$this->ReadPropertyBoolean('StoerueberwachungAktiv')",
            $inhalt
        );
+        self::assertGreaterThanOrEqual(
+            3,
+            substr_count($inhalt, '$this->geraetezugangBenoetigt()'),
+            'Der Geraetezugang muss beim Anwenden, Erneuern und Anfordern beruecksichtigt werden.'
+        );
        self::assertStringContainsString(
            "\$this->ReadPropertyString('Lizenzcode'),\n            \$geraetezugangFehlt",
            $inhalt
        );
        self::assertStringContainsString('synchronisiereAnlagentopologie()', $inhalt);
+        self::assertStringContainsString('private function geraetezugangBenoetigt(): bool', $inhalt);
+        self::assertStringContainsString(
+            "if (\$this->aktualisiereLizenzfreigabe(\$wert, true)) {",
+            $inhalt
+        );
+        self::assertStringNotContainsString(
+            "if (!\$this->ReadPropertyBoolean('PrognoseAktiv')) {\n            \$this->setzeDiagnosewert('Prognosestatus', 'NichtVerwendet');\n            return;\n        }\n\n        try {",
+            $inhalt
+        );
        self::assertStringContainsString(
            'https://license.enelix.ch/api/v1/installations/%s/prognosis/telemetry',
            $inhalt
@@ -254,6 +268,25 @@ final class ManagerModulstrukturTest extends TestCase
        );
    }

+    public function testManagerRegeltAktuelleVerbraucherTrotzFehlenderRueckmeldungen(): void
+    {
+        $inhalt = (string) file_get_contents(__DIR__ . '/../Manager/module.php');
+
+        self::assertStringNotContainsString("if (!\$synchronisiert) {", $inhalt);
+        self::assertStringContainsString(
+            "'Synchronisiert' => \$synchronisiert",
+            $inhalt
+        );
+        self::assertStringContainsString(
+            "'NichtGeregelt' => \$nichtGeregelt",
+            $inhalt
+        );
+        self::assertStringContainsString(
+            "\$ergebnis = ManagerRegler::verteile(",
+            $inhalt
+        );
+    }
+
    public function testManagerUebertraegtStoerungsvollsnapshotsMitRetry(): void
    {
        $inhalt = (string) file_get_contents(__DIR__ . '/../Manager/module.php');
@@ -280,13 +313,17 @@ final class ManagerModulstrukturTest extends TestCase
            '"name":"StoermeldeAnschluss"',
            str_replace(' ', '', (string) file_get_contents(__DIR__ . '/../Manager/form.json'))
        );
+        self::assertStringContainsString(
+            "if (\$token === '') {\n"
+                . "                \$this->aktualisiereLizenzfreigabe(\n"
+                . "                    \$this->ReadPropertyString('Lizenzcode'),\n"
+                . "                    true",
+            $inhalt
+        );
        self::assertGreaterThanOrEqual(
            3,
-            substr_count(
-                $inhalt,
-                "|| \$this->ReadPropertyBoolean('StoerueberwachungAktiv'))"
-            ),
-            'Der Gerätezugang muss beim Anwenden, Erneuern und Anfordern berücksichtigt werden.'
+            substr_count($inhalt, '$this->geraetezugangBenoetigt()'),
+            'Der Geraetezugang muss beim Anwenden, Erneuern und Anfordern beruecksichtigt werden.'
        );
    }

@@ -113,21 +113,116 @@ final class ManagerReglerTest extends TestCase
        self::assertSame(500, $ergebnis['Restabweichung_W']);
    }

-    public function testNichtAenderbarerVerbraucherReserviertSeineIstleistung(): void
+    public function testGleichePrioritaetBevorzugtWieEnelix1DenVerbraucherMitWenigerEnergie(): void
    {
-        $fest = $this->verbraucher(10, 0, [0, 3000], 3000, false);
+        $ergebnis = ManagerRegler::verteile(
+            0.0,
+            3000.0,
+            [
+                $this->verbraucher(10, 0, [0, 3000], 0),
+                $this->verbraucher(20, 0, [0, 3000], 0),
+            ],
+            'PrioritaetPV',
+            [10 => 3000.0, 20 => 0.0]
+        );
+
+        self::assertSame([20 => 3000, 10 => 0], $ergebnis['Sollwerte']);
+        self::assertSame(0, $ergebnis['Restabweichung_W']);
+    }
+
+    public function testEnergievergleichVerwendetWieEnelix1ZweiKilowattstundenGruppen(): void
+    {
+        $ergebnis = ManagerRegler::verteile(
+            0.0,
+            3000.0,
+            [
+                $this->verbraucher(10, 0, [0, 3000], 0),
+                $this->verbraucher(20, 0, [0, 3000], 0),
+            ],
+            'PrioritaetPV',
+            [10 => 999.0, 20 => 0.0]
+        );
+
+        self::assertSame([10 => 3000, 20 => 0], $ergebnis['Sollwerte']);
+    }
+
+    public function testFestwertWirdUnabhaengigVonAenderungMoeglichZugewiesen(): void
+    {
+        $fest = $this->verbraucher(10, 0, [3000], 3000, false);
        $steuerbar = $this->verbraucher(20, 1, [0, ['Von_W' => 1, 'Bis_W' => 4000]], 0);

        $ergebnis = ManagerRegler::verteile(3000.0, 5000.0, [$fest, $steuerbar], 'PrioritaetPV');

-        self::assertSame(3000, $ergebnis['NichtSteuerbar_W']);
-        self::assertSame([20 => 2000], $ergebnis['Sollwerte']);
+        self::assertSame(0, $ergebnis['NichtSteuerbar_W']);
+        self::assertSame([10 => 3000, 20 => 2000], $ergebnis['Sollwerte']);
+        self::assertSame(0, $ergebnis['Restabweichung_W']);
+    }
+
+    public function testFestwerteWerdenMitHoeherPriorisierterBatterieZugewiesen(): void
+    {
+        $ergebnis = ManagerRegler::verteile(
+            -2411.0,
+            0.0,
+            [
+                $this->verbraucher(
+                    44234,
+                    0,
+                    [['Von_W' => -39000, 'Bis_W' => 39000]],
+                    0
+                ),
+                $this->verbraucher(38676, 1, [0, 4600], 0),
+                $this->verbraucher(29743, 1, [0, 6500], 0),
+                $this->verbraucher(43878, 2, [13850], 10151, false),
+                $this->verbraucher(46052, 2, [11000], 0, false),
+            ],
+            'PrioritaetPV'
+        );
+
+        self::assertSame(12562, $ergebnis['Verteilbudget_W']);
+        self::assertSame(
+            [
+                44234 => -12288,
+                29743 => 0,
+                38676 => 0,
+                43878 => 13850,
+                46052 => 11000,
+            ],
+            $ergebnis['Sollwerte']
+        );
+        self::assertSame(0, $ergebnis['Restabweichung_W']);
+    }
+
+    public function testBegrenztesFahrzeugLaedtVorBatterieOhneBatterieentladung(): void
+    {
+        $ergebnis = ManagerRegler::verteile(
+            -3587.0,
+            0.0,
+            [
+                $this->verbraucher(
+                    10,
+                    0,
+                    [0, 4150, 4850, 5550, 6250, 6950, 7600, 8300, 9000, 9700, 10300, 11000],
+                    10263
+                ),
+                $this->verbraucher(
+                    20,
+                    1,
+                    [['Von_W' => -39000, 'Bis_W' => 39000]],
+                    0
+                ),
+            ],
+            'PrioritaetPV'
+        );
+
+        self::assertSame(13850, $ergebnis['Verteilbudget_W']);
+        self::assertSame([10 => 11000, 20 => 2850], $ergebnis['Sollwerte']);
+        self::assertGreaterThanOrEqual(0, $ergebnis['Sollwerte'][20]);
        self::assertSame(0, $ergebnis['Restabweichung_W']);
    }

    public function testFehlendeIstleistungFaelltAufAngenommenenSollwertZurueck(): void
    {
-        $verbraucher = $this->verbraucher(10, 0, [0, 3000], null, false);
+        $verbraucher = $this->verbraucher(10, 0, [3000], null, false);
        $verbraucher['Daten']['Leistungsquelle'] = Nachrichtenvertrag::LEISTUNGSQUELLE_NICHT_VORHANDEN;
        $verbraucher['Daten']['Istleistung_W'] = null;
        $verbraucher['Daten']['Zustand'][0]['Wert'] = 3000;
@@ -135,6 +230,7 @@ final class ManagerReglerTest extends TestCase
        $ergebnis = ManagerRegler::verteile(3000.0, 0.0, [$verbraucher], 'PrioritaetPV');

        self::assertSame(3000, $ergebnis['AktuelleVerbraucherleistung_W']);
+        self::assertSame([10 => 3000], $ergebnis['Sollwerte']);
        self::assertSame(-3000, $ergebnis['Restabweichung_W']);
    }

@@ -72,6 +72,21 @@ return static function (TestContext $test): void {
        $test->assertSame(200, $antwort['httpCode']);
    });

+    $test->runCase('Ladestart wird ueber Gateway angenommen', static function (
+        TestContext $test
+    ) use ($gateway): void {
+        $antwort = json_decode(ENELIXEASEE_ProcessStationRequest(
+            $gateway,
+            json_encode([
+                'action' => 'StartCharging',
+                'serialNumber' => 'EH123456',
+            ], JSON_THROW_ON_ERROR)
+        ), true, 512, JSON_THROW_ON_ERROR);
+
+        $test->assertSame(true, $antwort['success']);
+        $test->assertSame(200, $antwort['httpCode']);
+    });
+
    $test->runCase('Gebrochene Stromvorgabe wird abgelehnt', static function (
        TestContext $test
    ) use ($gateway): void {
@@ -108,6 +108,54 @@ return static function (TestContext $test): void {
        ));
    });

+    $test->runCase('Wartezustand startet konservativ ohne aktive Phase', static function (
+        TestContext $test
+    ) use ($sendeBeobachtung, $station): void {
+        $sendeBeobachtung('EH123456', 42, true);
+        $sendeBeobachtung('EH123456', 43, true);
+        $sendeBeobachtung('EH123456', 96, 55);
+        $sendeBeobachtung('EH123456', 102, true);
+        $sendeBeobachtung('EH123456', 109, 2);
+        $sendeBeobachtung('EH123456', 110, 0);
+        IPS_RequestAction($station, 'Solarladen', false);
+
+        $test->assertSame(
+            0,
+            GetValue($test->objectByIdent('Phasenzahl', $station))
+        );
+        $test->assertInstanceStatus($station);
+        $test->assertSame(
+            '[3850]',
+            (string) GetValue(
+                $test->objectByIdent('LeistungsangebotDiagnose', $station)
+            )
+        );
+        $test->assertTrue(str_contains(
+            (string) GetValue(
+                $test->objectByIdent('LetzterGeraetebefehl', $station)
+            ),
+            '"Ampere":16'
+        ));
+        $test->assertTrue(str_contains(
+            (string) GetValue(
+                $test->objectByIdent('LetzterStartbefehl', $station)
+            ),
+            '"Aktion":"StartCharging"'
+        ));
+        $test->assertSame(
+            55,
+            GetValue($test->objectByIdent('GrundKeinLadestrom', $station))
+        );
+        $test->assertSame(
+            true,
+            GetValue($test->objectByIdent('AutorisierungErforderlich', $station))
+        );
+
+        IPS_RequestAction($station, 'Solarladen', true);
+        $sendeBeobachtung('EH123456', 110, 30);
+        $sendeBeobachtung('EH123456', 109, 3);
+    });
+
    $test->runCase('Nur-Solar-Variante laesst Solarladen nicht abschalten', static function (
        TestContext $test
    ) use ($nurSolar): void {
@@ -6,8 +6,11 @@ use Belevo\EnelixEMS\SymconTest\TestContext;

 return static function (TestContext $test): void {
    $testPasswort = hash('sha256', __FILE__);
-    $goEAntwort = static function (int $status, float $leistung): string {
+    $goEAntwort = static function (int $status, float $leistung, array $stroeme = []): string {
        $nrg = array_fill(0, 12, 0);
+        foreach (array_values($stroeme) as $index => $strom) {
+            $nrg[4 + $index] = $strom;
+        }
        $nrg[11] = $leistung;
        return json_encode(['car' => $status, 'nrg' => $nrg], JSON_THROW_ON_ERROR);
    };
@@ -16,14 +19,14 @@ return static function (TestContext $test): void {
        'go-e alt' => [
            'Geraetetyp' => 1,
            'Geraeteadresse' => '192.0.2.10',
-            'Testantwort' => $goEAntwort(2, 1100),
+            'Testantwort' => $goEAntwort(2, 1100, [160, 158, 159]),
            'Phasenzahl' => 3,
            'BefehlUrlTeil' => 'amp=16',
        ],
        'go-e Gemini' => [
            'Geraetetyp' => 2,
            'Geraeteadresse' => '192.0.2.11',
-            'Testantwort' => $goEAntwort(2, 2300),
+            'Testantwort' => $goEAntwort(2, 2300, [10, 0, 0]),
            'Phasenzahl' => 1,
            'BefehlUrlTeil' => 'amp=16',
        ],
@@ -61,6 +64,39 @@ return static function (TestContext $test): void {
        );
    }

+    $solarPause = $test->createInstance(
+        '{0D94913C-0F31-4C29-A685-6EB4AE58E55D}',
+        'Ladestation Solarpause',
+        [
+            'Geraetetyp' => 1,
+            'Geraeteadresse' => '192.0.2.12',
+            'MaximalerLadestrom' => 16,
+            'Ladefreigabe' => true,
+            'Solarladen' => true,
+            'EinstellungenInVisu' => true,
+            'DiagnosevariablenAnzeigen' => true,
+            'Testmodus' => true,
+            'Testantwort' => $goEAntwort(2, 0),
+        ]
+    );
+
+    $stromerkennung = $test->createInstance(
+        '{0D94913C-0F31-4C29-A685-6EB4AE58E55D}',
+        'Ladestation Fahrzeugstromerkennung',
+        [
+            'Geraetetyp' => 2,
+            'Geraeteadresse' => '192.0.2.13',
+            'MaximalerLadestrom' => 20,
+            'FahrzeugstromErkennungszeit' => 1,
+            'Ladefreigabe' => true,
+            'Solarladen' => true,
+            'EinstellungenInVisu' => true,
+            'DiagnosevariablenAnzeigen' => true,
+            'Testmodus' => true,
+            'Testantwort' => $goEAntwort(2, 10263, [15.9, 15.8, 15.7]),
+        ]
+    );
+
    $managerId = $test->createInstance(
        '{6F771B18-59D4-4C8A-B951-3B2FE9F6A2C4}',
        'Hilfsmanager Ladestation',
@@ -68,7 +104,7 @@ return static function (TestContext $test): void {
            'AutomatischeSuche' => false,
            'VerbraucherZuordnung' => json_encode(array_map(
                static fn (int $id): array => ['InstanzID' => $id, 'Aktiv' => true],
-                array_values($stationen)
+                array_merge(array_values($stationen), [$stromerkennung])
            ), JSON_THROW_ON_ERROR),
        ]
    );
@@ -120,6 +156,44 @@ return static function (TestContext $test): void {
        }
    });

+    $test->runCase('Solarpause wird nicht als Ladeende erkannt', static function (
+        TestContext $test
+    ) use ($solarPause): void {
+        IPS_RequestAction($solarPause, 'Solarladen', true);
+
+        $test->assertSame(
+            false,
+            GetValue($test->objectByIdent('FahrzeugGeladen', $solarPause))
+        );
+        $test->assertSame(
+            2,
+            GetValue($test->objectByIdent('Fahrzeugstatus', $solarPause))
+        );
+    });
+
+    $test->runCase('ApplyChanges prueft ein gespeichertes Ladeende neu', static function (
+        TestContext $test
+    ) use ($goEAntwort, $solarPause): void {
+        IPS_RequestAction($solarPause, 'Solarladen', false);
+        IPS_RequestAction($solarPause, 'Statuszyklus', false);
+        $test->assertSame(
+            true,
+            GetValue($test->objectByIdent('FahrzeugGeladen', $solarPause))
+        );
+
+        IPS_SetProperty($solarPause, 'Testantwort', $goEAntwort(2, 2300, [100, 100, 100]));
+        IPS_ApplyChanges($solarPause);
+
+        $test->assertSame(
+            false,
+            GetValue($test->objectByIdent('FahrzeugGeladen', $solarPause))
+        );
+        $test->assertSame(
+            3,
+            GetValue($test->objectByIdent('Fahrzeugstatus', $solarPause))
+        );
+    });
+
    $test->runCase('Solar- und Peakbetrieb liefern die Enelix-1-Angebote', static function (
        TestContext $test
    ) use ($stationen, $anforderungSenden): void {
@@ -174,4 +248,58 @@ return static function (TestContext $test): void {
            'alw=0'
        ), 'Peak mit Solarladen muss die Ladestation stoppen.');
    });
+
+    $test->runCase('Fahrzeugstrom wird nach stabiler Unterschreitung begrenzt', static function (
+        TestContext $test
+    ) use ($stromerkennung, $anforderungSenden): void {
+        IPS_RequestAction($stromerkennung, 'Aktiv', true);
+        IPS_RequestAction($stromerkennung, 'Solarladen', true);
+        $anforderungSenden($stromerkennung, 13850);
+        IPS_RequestAction($stromerkennung, 'Statuszyklus', false);
+        IPS_Sleep(2100);
+        IPS_RequestAction($stromerkennung, 'Statuszyklus', false);
+
+        $test->assertSame(
+            16,
+            GetValue($test->objectByIdent('FahrzeugMaximalstrom', $stromerkennung))
+        );
+        $test->assertSame(
+            '[0,4150,4850,5550,6250,6950,7600,8300,9000,9700,10300,11000]',
+            (string) GetValue($test->objectByIdent('LeistungsangebotDiagnose', $stromerkennung))
+        );
+        $test->assertTrue(str_contains(
+            (string) GetValue($test->objectByIdent('LetzterGeraetebefehl', $stromerkennung)),
+            'amp=16'
+        ));
+    });
+
+    $test->runCase('Sollwert bleibt waehrend der Ladeanlaufzeit gueltig', static function (
+        TestContext $test
+    ) use ($goEAntwort, $stationen, $anforderungSenden): void {
+        $stationId = $stationen['go-e Gemini'];
+        IPS_SetProperty($stationId, 'Testantwort', $goEAntwort(2, 0));
+        IPS_ApplyChanges($stationId);
+        IPS_RequestAction($stationId, 'Aktiv', true);
+        IPS_RequestAction($stationId, 'Solarladen', true);
+
+        $anforderungSenden($stationId, 3850);
+        IPS_RequestAction($stationId, 'Statuszyklus', false);
+
+        $test->assertSame(
+            false,
+            GetValue($test->objectByIdent('FahrzeugGeladen', $stationId))
+        );
+        $test->assertSame(
+            true,
+            GetValue($test->objectByIdent('SollwertGueltig', $stationId))
+        );
+        $test->assertSame(
+            3850,
+            GetValue($test->objectByIdent('Sollleistung', $stationId))
+        );
+        $test->assertSame(
+            '[0,1450,1690,1930,2170,2410,2650,2890,3130,3370,3610,3850]',
+            (string) GetValue($test->objectByIdent('LeistungsangebotDiagnose', $stationId))
+        );
+    });
 };
@@ -444,4 +444,46 @@ return static function (TestContext $test): void {
            $test->objectByIdent('Sammelstoerung', $managerId)
        ));
    });
+
+    $test->runCase('Veralteter Verbraucher blockiert aktuelle Verbraucher nicht', static function (
+        TestContext $test
+    ) use (
+        $managerId,
+        $netzleistungId,
+        $einStufigId,
+        $warmwasserId,
+        $pufferspeicherId,
+        $melden,
+        $verbraucherstatus
+    ): void {
+        IPS_SetProperty($managerId, 'VerbraucherTimeout', 1);
+        IPS_ApplyChanges($managerId);
+        SetValue($netzleistungId, -2400.0);
+        $melden();
+        IPS_RequestAction($managerId, 'Regeln', true);
+        $test->waitUntil(
+            static fn (): bool => ($verbraucherstatus()['Synchronisiert'] ?? false) === true
+        );
+
+        IPS_Sleep(1100);
+        IPS_RequestAction($warmwasserId, 'Melden', true);
+        IPS_RequestAction($pufferspeicherId, 'Melden', true);
+        IPS_RequestAction($managerId, 'Regeln', true);
+
+        $daten = $verbraucherstatus();
+        $test->assertSame(false, $daten['Synchronisiert'] ?? null);
+        $test->assertSame(2, count($daten['Verbraucher'] ?? []));
+        $test->assertSame(1, count($daten['NichtGeregelt'] ?? []));
+        $test->assertSame(
+            $einStufigId,
+            $daten['NichtGeregelt'][0]['InstanzID'] ?? null
+        );
+        $test->assertSame(
+            'Meldung ist veraltet',
+            $daten['NichtGeregelt'][0]['Grund'] ?? null
+        );
+        $test->assertTrue(
+            (float) GetValue($test->objectByIdent('Verteilbudget', $managerId)) > 0.0
+        );
+    });
 };
@@ -22,7 +22,7 @@ return static function (TestContext $test): void {
            'Wiederholsperre' => 3,
            'Mindestlaufzeit' => 5,
            'Mindestsperrzeit' => 0,
-            'MaximaleSperrzeit' => 2,
+            'MaximaleSperrzeit' => 3,
            'MaximaleSperrzeit24h' => 60,
            'VorgabeTimeout' => 30,
            'DiagnosevariablenAnzeigen' => true,
@@ -136,13 +136,16 @@ return static function (TestContext $test): void {
    ) use ($waermepumpe, $kontakt1, $kontakt2, $senden): void {
        $senden(null, 'Peak');
        $senden(0, 'Peak');
-        $test->waitUntil(static fn (): bool => GetValue($kontakt1) === true);
+        $test->waitUntil(static fn (): bool => GetValue($kontakt1) === true, 2500);
        $test->assertSame(false, GetValue($kontakt2));
        $test->assertSame(true, GetValue(
            $test->objectByIdent('SperreAktiv', $waermepumpe)
        ));

-        $test->waitUntil(static fn (): bool => GetValue($kontakt1) === false, 2500);
+        $test->waitUntil(static fn (): bool => GetValue($kontakt1) === false, 3500);
+        $test->waitUntil(static fn (): bool => GetValue(
+            $test->objectByIdent('SperrerholungAktiv', $waermepumpe)
+        ) === true);
        $test->assertSame(true, GetValue(
            $test->objectByIdent('SperrerholungAktiv', $waermepumpe)
        ));
@@ -31,6 +31,8 @@ return static function (TestContext $test): void {
            'LastwechselSperrzeit' => 1,
            'Hysterese' => 5.0,
            'TemperaturMaxAlter' => 120,
+            'TemperaturUntergrenze' => 0.0,
+            'TemperaturObergrenze' => 100.0,
            'LegionellenfunktionAktiv' => true,
            'LegionellenMinimalintervallTage' => 4,
            'LegionellenMaximalintervallTage' => 7,
@@ -90,6 +92,24 @@ return static function (TestContext $test): void {
        IPS_RequestAction($managerId, 'Regeln', true);
    };

+    $test->runCase('Temperaturgrenzen melden Unter- und Uebertemperatur', static function (
+        TestContext $test
+    ) use ($verbraucherId, $temperaturSetzen): void {
+        $stoertextId = $test->objectByIdent('Stoertext', $verbraucherId);
+
+        $temperaturSetzen(100.0);
+        $test->assertTrue(!str_contains((string) GetValue($stoertextId), 'Uebertemperatur'));
+        $temperaturSetzen(100.1);
+        $test->assertTrue(str_contains((string) GetValue($stoertextId), 'Uebertemperatur'));
+
+        $temperaturSetzen(0.0);
+        $test->assertTrue(!str_contains((string) GetValue($stoertextId), 'Untertemperatur'));
+        $temperaturSetzen(-0.1);
+        $test->assertTrue(str_contains((string) GetValue($stoertextId), 'Untertemperatur'));
+
+        $temperaturSetzen(52.0);
+    });
+
    if ($lizenzcode === '') {
        $test->runCase('Manager bleibt ohne Lizenz sicher gesperrt', static function (
            TestContext $test
@@ -29,14 +29,14 @@ final class WarmwassererwaermerModulstrukturTest extends TestCase
        self::assertMatchesRegularExpression('/^\{[0-9A-F-]{36}\}$/', $metadaten['id']);
    }

-    public function testAlle19PropertiesSindRegistriertUndImFormularDokumentiert(): void
+    public function testAlle21PropertiesSindRegistriertUndImFormularDokumentiert(): void
    {
        $basis = (string) file_get_contents(__DIR__ . '/../libs/VerbraucherBasisTrait.php');
        $modul = (string) file_get_contents(self::MODULPFAD . 'module.php');
        preg_match_all('/RegisterProperty(?:Integer|Float|Boolean|String)\(\'([^\']+)\'/', $basis . $modul, $treffer);
        $properties = array_values(array_unique($treffer[1]));

-        self::assertCount(19, $properties);
+        self::assertCount(21, $properties);

        $formular = (string) file_get_contents(self::MODULPFAD . 'form.json');
        foreach ($properties as $property) {
@@ -136,6 +136,38 @@ final class WarmwassererwaermerModulstrukturTest extends TestCase
        self::assertStringContainsString('Mindesttemperatur < Maximaltemperatur', $inhalt);
    }

+    public function testTemperaturstoergrenzenSindKonfigurierbarUndVonSollwertenGetrennt(): void
+    {
+        $inhalt = (string) file_get_contents(self::MODULPFAD . 'module.php');
+        self::assertStringContainsString(
+            "RegisterPropertyFloat('TemperaturUntergrenze', 0.0)",
+            $inhalt
+        );
+        self::assertStringContainsString(
+            "RegisterPropertyFloat('TemperaturObergrenze', 100.0)",
+            $inhalt
+        );
+        self::assertStringContainsString("ReadPropertyFloat('TemperaturUntergrenze')", $inhalt);
+        self::assertStringContainsString("ReadPropertyFloat('TemperaturObergrenze')", $inhalt);
+        self::assertStringContainsString("'Kennung' => 'Untertemperatur'", $inhalt);
+        self::assertStringContainsString("'Kennung' => 'Uebertemperatur'", $inhalt);
+
+        $formular = json_decode(
+            (string) file_get_contents(self::MODULPFAD . 'form.json'),
+            true,
+            512,
+            JSON_THROW_ON_ERROR
+        );
+        $erweitert = array_values(array_filter(
+            $formular['elements'],
+            static fn (array $element): bool =>
+                $element['caption'] === 'Erweiterte Speichereinstellungen'
+        ));
+        self::assertCount(1, $erweitert);
+        self::assertContains('TemperaturUntergrenze', array_column($erweitert[0]['items'], 'name'));
+        self::assertContains('TemperaturObergrenze', array_column($erweitert[0]['items'], 'name'));
+    }
+
    public function testSchaltfolgeIstBreakBeforeMake(): void
    {
        $inhalt = (string) file_get_contents(self::MODULPFAD . 'module.php');
Author	SHA1	Message	Date
dh	fdc2007bb1	fix(manager): Energieausgleich aus Enelix 1 wiederherstellen Tests / test (push) Successful in 54s Details	2026-09-29 14:14:25 +00:00
dh	37400878b6	fix(easee): veraltete Ladeleistung nach Ladestopp nullen Tests / test (push) Successful in 50s Details	2026-09-29 13:15:43 +00:00
dh	ace1821213	fix(ladestation): Fahrzeugstrom nach Lernzeit begrenzen Tests / test (push) Successful in 56s Details	2026-09-29 12:47:23 +00:00
dh	b3b868cd2a	fix(ladestation): Ladeanlauf und Easee-Verbindung stabilisieren Tests / test (push) Successful in 1m23s Details	2026-09-29 12:25:35 +00:00
dh	a74f14aa19	feat(warmwasser): Temperaturgrenzen konfigurierbar machen Tests / test (push) Successful in 1m10s Details	2026-09-29 12:11:43 +00:00
dh	fe966516b5	test: integrierte Freigabepruefungen stabilisieren Tests / test (push) Successful in 1m14s Details	2026-09-29 12:06:51 +00:00
dh	b3bbae1a72	fix(manager): Anlagentopologie immer synchronisieren Tests / test (push) Failing after 50s Details	2026-09-29 11:51:55 +00:00
dh	ae2cd8ecff	Merge remote-tracking branch 'origin/develop' into develop Tests / test (push) Successful in 46s Details	2026-09-29 11:43:12 +00:00
dh	995b704e36	fix(manager): Prognoseberechtigungen verständlich diagnostizieren Tests / test (push) Successful in 49s Details	2026-09-29 11:40:24 +00:00
dh	5ff0d405d4	fix(manager): feste Leistungsangebote immer zuteilen	2026-09-29 11:40:24 +00:00
dh	ccecc437e9	fix(easee): wartende Ladevorgaenge starten Tests / test (push) Successful in 45s Details	2026-09-29 09:34:37 +00:00
dh	156591a91e	fix(ladestation): Ladeende nach Update neu prüfen Tests / test (push) Successful in 47s Details	2026-09-29 09:19:56 +00:00
dh	e0814a0c14	fix(ladestation): Ladeende nach Update neu prüfen	2026-09-29 09:19:39 +00:00
dh	3cabf597ac	fix(ladestation): Solarpause nicht als Ladeende erkennen	2026-09-29 09:07:56 +00:00
dh	b86810d30f	fix(ladestation): Solarpause nicht als Ladeende erkennen	2026-09-29 09:07:44 +00:00
dh	d1fc62d43c	fix(manager): Regelung bei veralteten Verbrauchern fortsetzen Tests / test (push) Successful in 46s Details	2026-09-29 08:46:44 +00:00
dh	21577c0125	fix(manager): Prognoseberechtigungen verständlich diagnostizieren	2026-09-29 08:41:32 +00:00
dh	aefe46352f	fix(easee): Wartezustand ohne Ausgangsphase zulassen Tests / test (push) Successful in 48s Details	2026-09-29 08:25:08 +00:00
dh	6f76e6cd86	fix(easee): Initialstatus der Ladestation laden Tests / test (push) Successful in 48s Details	2026-09-29 07:55:31 +00:00