From a9d3712ef909312bb02c06ab32100dadf3dc3292 Mon Sep 17 00:00:00 2001 From: DanielHaefliger Date: Thu, 6 Aug 2026 15:41:28 +0200 Subject: [PATCH] no message --- Ladestation/README.md | 169 ++-- Ladestation/form.json | 88 +- Ladestation/module.json | 10 +- Ladestation/module.php | 1720 ++++++++++++++++++++++++++----------- Ladestation_v2/README.md | 22 +- Ladestation_v2/module.php | 258 +++++- 6 files changed, 1609 insertions(+), 658 deletions(-) diff --git a/Ladestation/README.md b/Ladestation/README.md index aa23783..f7b1520 100644 --- a/Ladestation/README.md +++ b/Ladestation/README.md @@ -1,142 +1,69 @@ -# Enelix-Verbrauchermodul Ladestation (EV Charger) +# Ladestation -Dieses Modul integriert smarte Ladestationen (Wallboxen) für Elektroautos als steuerbare Verbraucher in das Belevo Energiemanagement-System (Enelix). Es regelt die Ladeleistung dynamisch, unterstützt verschiedene Hersteller-APIs und optimiert das Laden nach PV-Überschuss oder Peak-Shaving-Vorgaben. +Das Modul steuert verschiedene Ladestationstypen. ---- +Das Konfigurationsformular zeigt die Verbindungsdaten abhängig vom gewählten +Ladestationstyp an. Allgemeine Regel- und Zeitparameter bleiben immer sichtbar. -## Inhaltsverzeichnis +## Easee -1. [Funktionsumfang](#1-funktionsumfang) -2. [Voraussetzungen](#2-voraussetzungen) -3. [Installation](#3-installation) -4. [Instanz anlegen & Konfiguration](#4-instanz-anlegen--konfiguration) -5. [Statusvariablen & Profile](#5-statusvariablen--profile) -6. [WebFront / Bedienung](#6-webfront--bedienung) -7. [Mapping auf Code-Komponenten](#7-mapping-auf-code-komponenten) -8. [Zukünftige Erweiterungen](#8-zukünftige-erweiterungen) +Die Ladestationstypen 5 und 6 verwenden das oben als Schnittstelle ausgewählte +`Easee SignalR Gateway`. Die Schnittstellenauswahl wird bei allen +Stationstypen angezeigt. ---- +- Typ 5: Easee mit zusätzlicher eCarUp-Benutzerprüfung für Solarladen +- Typ 6: Easee ohne eCarUp-Benutzerprüfung -## 1. Funktionsumfang +Die Easee-Zugangsdaten werden ausschließlich im Gateway eingetragen. In der +Ladestationsinstanz muss die Easee-Seriennummer hinterlegt sein. -- **Hersteller-Integration:** Native Unterstützung verschiedener Ladestationen und Cloud-APIs (z.B. Smart-me Pico, Easee, eCarUp, generisches MQTT / REST-API). -- **Phasenerkennung:** Das Modul erkennt automatisch (über Leistungsschwellen, z.B. > 7500W), ob das Fahrzeug 1-phasig oder 3-phasig lädt, und passt die internen Strom-zu-Leistung-Umrechnungen an. -- **PowerSteps-Generierung:** Übersetzt die zulässigen Ladeströme (Ampere) in Watt-Schritte (`PowerSteps`), die dem Enelix-Manager für die Energieverteilung angeboten werden (abhängig vom definierten `Mindestaldestrom`, minimal 6A). -- **Verzögerungs- und Schutzlogiken:** - - `Ein_Zeit` / `Aus_Zeit`: Mindestlaufzeiten und Pausenzeiten, um den Schütz im Auto und in der Wallbox vor zu häufigem Schalten zu schützen (Taktschutz). - - `Zeit_Zwischen_Zustandswechseln`: Dämpfung von Leistungssprüngen. -- **Betriebsmodi:** - - *Solarladen:* Automatische Regelung nach PV-Überschuss. - - *Sperr-Priorität:* Regelung nach Peak-Shaving (Netzbezugsgrenzen). - - *Fahrzeugerkennung:* Freigabe der Ladeleistung nur, wenn ein Auto gesteckt (`Car_detected`) und nicht voll (`Car_is_full`) ist. -- **Token-Management:** Automatischer Login und Token-Refresh für Cloud-basierte Systeme (wie Easee, E-Car-Up). -- **Tarifabhängiges Solarladen** Nutzerbasiertes Solarladen mit unterschiedlichen Tarifen für Solar- und Netzladen. Dieese Funktion ist nur über spezielle Token und kostenpflichtigen Konten von drittfirmen aktivierbar. Für weitere Informationen bitte die Belevo AG kontaktieren. +Das Gateway liefert: ---- +- Observation 47: maximaler Ladestrom der Station +- Observation 109: Fahrzeug-/Ladestatus +- Observation 110: freigegebene Ausgangsphase +- Observation 120: aktuelle Gesamtleistung in kW +- Observations 182 bis 185: gemessene Leiterströme -## 2. Voraussetzungen +Bei Easee erfolgt die Fahrzeug- und Phasenerkennung ohne den zeitbasierten +`Pending_Counter`. Der maximale Ladestrom wird aus Observation 47 übernommen +und zusätzlich durch `Max_Current_abs` begrenzt. Die Typen 1 bis 4 verwenden +weiterhin unverändert die bisherige zeit- und leistungsbasierte Erkennung. +Die Fahrzeugphasen werden anhand der tatsächlich gemessenen Leiterströme +erkannt; alte Phasenwerte werden beim Trennen oder Neuverbinden verworfen. -- IP-Symcon **≥ 8.0** -- Modul-URL: `https://git.belevo.ch/dh/enelix.git` -- Vorhandener und eingerichteter Enelix Manager. -- Netzwerkzugriff auf die Ladestation (lokale IP) oder aktive Internetverbindung für Cloud-APIs. +Stromvorgaben von 0 bis 32 A werden ebenfalls über das Gateway gesendet. ---- +## Andere Ladestationstypen -## 3. Installation +Die Typen 1 bis 4 benötigen kein Easee-Gateway. -1. In IP-Symcon **Module Control** öffnen. -2. **Hinzufügen → Git-Repository**. -3. URL eingeben und **Installieren**. -4. IP-Symcon neu starten. +### Go-e ---- +Die Typen 1 und 2 erkennen ein verbundenes Fahrzeug direkt über den +Go-e-Fahrzeugstatus. Die tatsächlich verwendeten Phasen werden aus den drei +gemessenen Strömen des `nrg`-Arrays bestimmt. Der maximale Ladestrom wird durch +die Stations-, Kabel- und Modulgrenze begrenzt. -## 4. Instanz anlegen & Konfiguration +### Smart-Me Pico -### 4.1 Instanz anlegen +Typ 3 erkennt ein verbundenes Fahrzeug über den Pico-Ladestatus. Die +Phasenerkennung verwendet `CurrentL1`, `CurrentL2` und `CurrentL3` des +Smart-Me-Geräte-Endpunkts. Der maximale Stationsstrom wird direkt aus den +Pico-Ladedaten übernommen. -- Rechtsklick **Instanzen** → **Instanz hinzufügen** -- Filter: **Belevo** -- Auswahl: **Ladestation v2 (Verbraucher)** +Bei Typ 1 bis 3 entfällt die zeitbasierte Fahrzeug- und Phasenerkennung über +den `Pending_Counter`. Die Phasenzahl wird aktualisiert, sobald ein messbarer +Ladestrom fließt. Beim Abstecken werden die erkannten Phasen zurückgesetzt. -### 4.2 Properties +Typ 4 bleibt unverändert. -| Name | Typ | Beschreibung | -|---|---|---| -| **IP_Adresse** | String | Lokale IP-Adresse der Ladestation (für lokale APIs). | -| **Ladestation** | Select/Int | Auswahl des API-/Hardware-Typs (z.B. 1=MQTT, 2=REST, 3=Pico, 5=eCarUp, 6=Easee). | -| **ID** | String | Stations-ID (z.B. für Smart-me Pico oder eCarUp). | -| **Seriennummer** | String | Seriennummer der Station (z.B. für Easee). | -| **Username** | String | Benutzername für Cloud-APIs. | -| **Password** | String | Passwort für Cloud-APIs. | -| **Interval** | NumberSpinner | Berechnungsintervall und Polling-Rate (Sekunden). | -| **Max_Current_abs** | NumberSpinner | Absoluter Maximalstrom der Zuleitung/Station in Ampere (z.B. 16 oder 32). | -| **Zeit_Zwischen_Zustandswechseln**| NumberSpinner | Verzögerungszeit zwischen zwei Leistungsanpassungen (in Minuten). | -| **Ein_Zeit** | NumberSpinner | Mindestlaufzeit, wenn die Ladung gestartet wird (Minuten). | -| **Aus_Zeit** | NumberSpinner | Mindestpausenzeit nach einem Ladeabbruch (Minuten). | -| **Token_Easee** | SelectVariable | Referenz auf das externe Easee-Token (Variable). | -| **Token_ECarUp** | SelectVariable | Referenz auf das externe eCarUp-Token (Variable). | -| **IdleCounterMax**| NumberSpinner | Anzahl Interval-Zyklen zwischen Leistungsänderungen (Modul-Idle). | +## Einrichtung ---- +1. Eine Instanz `Easee SignalR Gateway` anlegen. +2. Easee-Benutzername und Passwort im Gateway eintragen. +3. In `Ladestation` Typ 5 oder 6 sowie die Easee-Seriennummer wählen. +4. Oben über `Schnittstelle konfigurieren` beziehungsweise + `Schnittstelle ändern` die gewünschte Gateway-Instanz auswählen. -## 5. Statusvariablen & Profile - -Das Modul verwendet viele interne (versteckte) Variablen für die Manager-Kommunikation. Hier die wichtigsten sichtbaren und steuerbaren Variablen: - -| Ident | Typ | Profil | Beschreibung | -|---|---|---|---| -| **Ladebereit** | Boolean | ~Switch | Hauptschalter: Ladestation generell freigegeben oder blockiert. | -| **Solarladen** | Boolean | ~Switch | Aktiviert den reinen PV-Überschusslade-Modus. | -| **Mindestaldestrom** | Integer | - | Minimaler Ladestrom in Ampere (normalerweise mind. 6A für Typ 2). | -| **Is_1_ph** | Boolean | ~Switch | Anzeige: Das Fahrzeug lädt aktuell nur auf einer Phase. | -| **Car_detected** | Boolean | ~Switch | Status: Ein Fahrzeug ist angesteckt und bereit. | -| **Car_is_full** | Boolean | ~Switch | Status: Fahrzeugakku ist voll (Ladestrom < Schwelle). | -| **Pending_Counter** | Integer | Zähler zum Abwarten des Stationszustandes bei Zustandänderung | -| **Leistung_Delta** | Integer | Leistungsabweichung von vorgegebener Soll- und Istleistung | -| **Idle** | Boolean | Status der Sperrzeit (`true` = bereit für neue Werte, `false` = gesperrt). | -| **Ladeleistung_Effektiv**| Float | - | Aktuell gemessene reale Ladeleistung in Watt. | -| **Bezogene_Energie** | Float | - | Rechnerisch aufsummierte Ladeenergie. | -| **Aktuelle_Leistung** | Integer | Die aktuell von der Station erbrachte Leistung. | -| **PowerSteps** | String | JSON-Array der dem Manager angebotenen Leistungsschritte. | -| **Letzer_User** | String | - | Zuletzt authentifizierter RFID-Nutzer (z.B. via eCarUp). | -| **Bezogene_Energie** | Float | Rechnerisch aufsummierte Energie (Leistung × Zeit). | -| **PV_Prio** | Integer | Priorität des Verbrauchers für PV-Optimierung, Tiefe Nummer = Hohe Priorität | -| **Sperre_Prio** | Integer | Priorität des Verbrauchers für Peak-Optimierung, Tiefe Nummer = Hohe Priorität | -| **PV_Prio** | Integer | Priorität des Verbrauchers für PV-Optimierung, Tiefe Nummer = Hohe Priorität | -| **Sperre_Prio** | Integer | Priorität des Verbrauchers für Peak-Optimierung, Tiefe Nummer = Hohe Priorität | - ---- - -## 6. WebFront / Bedienung - -Im WebFront bietet die Instanz dem Nutzer Eingriffsmöglichkeiten in das Ladeverhalten: -- **Ladebereit:** Kann genutzt werden, um die Wallbox per Knopfdruck komplett zu deaktivieren. -- **Solarladen:** Zwingt das Modul in den Überschuss-Modus (es wird nur geladen, wenn Leistung durch den Manager zugewiesen wird), Andernfalls wird bei verbundenem Auto solange geladen, bis der Peakshaving-Modus die Leistung reduziert. -- **Mindestaldestrom:** Definiert den Einstiegspunkt für die Ladung (z.B. 6A = ~1,4 kW bei 1-phasig / ~4,1 kW bei 3-phasig). - -- **PV_Prio** - Priorität des Verbrauchers für PV-Optimierung, Tiefe Nummer = Hohe Priorität -- **Sperre_Prio** - Priorität des Verbrauchers für Peak-Optimierung, Tiefe Nummer = Hohe Priorität - -Zudem dient die Instanz zur Statuskontrolle (Ist ein Auto verbunden? Lädt es? Ist es voll?). - ---- - -## 7. Mapping auf Code-Komponenten - -| Komponente | Funktion im Code (`module.php`) | -|---|---| -| **API-Schnittstellen** | `Get_Car_Status($carType)` fragt die jeweilige Hardware ab (cURL an REST/MQTT/Easee) und aktualisiert `Ladeleistung_Effektiv` sowie den `Fahrzeugstatus`. | -| **Autodetektion** | `Detect_Car()` prüft den Zustand, zählt `Pending_Counter` hoch und entscheidet über `Is_1_ph` basierend auf Leistungsgrenzen (7500W). | -| **Leistung → Strom** | `Get_Array_From_Current()` und `Get_Current_From_Power()` rechnen Watt in Ampere um ($P = U \cdot I \cdot Phasen$). | -| **Manager-Interface** | `GetCurrentData($Peak)` baut die `PowerSteps` (z.B. [0, 4140, 4830, ...]) und übergibt diese dem Manager. | -| **Stationssteuerung** | `sendPowerToStation($value)` übersetzt den Soll-Strom (Ampere) in API-spezifische Kommandos (z.B. `amp=16` oder `{"amps":16}`). | -| **Taktschutz (Timers)**| `SetTimerNullMindestlast()`, `SetTimerOn()` und die entsprechenden Reset-Methoden sperren Zustandswechsel nach Start/Stopp. | -| **Token-Refresh** | `Refresh_Token()` erneuert zyklisch das Access-Token (z.B. Easee) über die hinterlegten Credentials. | - ---- - -## 8. Zukünftige Erweiterungen - -- **Automatische Phasenumschaltung:** Direkte Ansteuerung von Wallboxen, die eine Umschaltung zwischen 1- und 3-phasigem Laden im laufenden Betrieb unterstützen (zur Erweiterung des Regelbereichs bei wenig Sonne). +Mehrere Easee-Ladestationen desselben Kontos verwenden gemeinsam ein Gateway. diff --git a/Ladestation/form.json b/Ladestation/form.json index 0ef4448..4722992 100644 --- a/Ladestation/form.json +++ b/Ladestation/form.json @@ -3,19 +3,15 @@ { "type": "Select", "name": "Ladestation", - "caption": "Ladestation Typ", + "caption": "Ladestationstyp", + "onChange": "IPS_RequestAction($id, \"UpdateStationForm\", $Ladestation);", "options": [ - - { - "caption": "Herstellerunabhängig (Ohne interne kommunikation mit Station)", - "value": 4 - }, { "caption": "Go-E Wallbox (Alte Version)", "value": 1 }, { - "caption": "Go-E Germini / Germini Flex", + "caption": "Go-E Gemini / Gemini Flex", "value": 2 }, { @@ -23,91 +19,97 @@ "value": 3 }, { - "caption": "Easee", - "value": 6 + "caption": "Dummy Station (Ohne Ansteuerung)", + "value": 4 }, { - "caption": "Easee - Nur tarifabhängiges Solarladen", + "caption": "Easee - Nur Solarladen", "value": 5 + }, + { + "caption": "Easee", + "value": 6 } ] }, { "type": "NumberSpinner", "name": "IdleCounterMax", - "caption": "Anzahl Interval-Zyklen zwischen zwei Leistungsänderungen", - "suffix": "" + "caption": "Wartezyklen nach einer Leistungsänderung", + "suffix": "Zyklen" }, { "type": "NumberSpinner", "name": "Interval", - "caption": "Intervall Neuberechnung der Werte", + "caption": "Berechnungsintervall", "suffix": "Sekunden" }, { "type": "NumberSpinner", "name": "Max_Current_abs", - "caption": "Maximaler Ladestrom der Station", + "caption": "Maximaler Ladestrom", "suffix": "Ampere" }, { "type": "NumberSpinner", "name": "Zeit_Zwischen_Zustandswechseln", - "caption": "Mindestlaufzeit des Verbrauchers bei Lastschaltung (Veraltet, auf 0 lassen, wird demnächst entfehrnt, wird ersetzt durch Mindestlaufzeiten)", - "suffix": "" + "caption": "Mindestzeit zwischen Leistungsänderungen", + "suffix": "Minuten" }, { "type": "NumberSpinner", "name": "Ein_Zeit", - "caption": "Mindestlaufzeit Ladestation wenn Ein", - "suffix": "" + "caption": "Mindestlaufzeit nach dem Einschalten", + "suffix": "Minuten" }, { "type": "NumberSpinner", "name": "Aus_Zeit", - "caption": "Mindestlaufzeit Ladestation wenn Aus", - "suffix": "" + "caption": "Mindeststillstandszeit nach dem Ausschalten", + "suffix": "Minuten" }, { "type": "ValidationTextBox", "name": "IP_Adresse", - "caption": "IP-Adresse Ladestation (für Go-E Modelle)" - + "caption": "IP-Adresse", + "visible": false }, { "type": "ValidationTextBox", - "caption": "Geräte-ID (für Smart-Me / ECarUp / Easee)", - "name": "ID" - + "name": "ID", + "caption": "Geräte-ID", + "visible": false }, { "type": "ValidationTextBox", - "caption": "Seriennummer (für Smart-Me / ECarUp / Easee)", - "name": "Seriennummer" - + "name": "Seriennummer", + "caption": "Seriennummer", + "visible": false }, { "type": "ValidationTextBox", - "caption": "Username / Benutzernahme (für Easee, Smart-Me, )", - "name": "Username" - - }, - { "type": "PasswordTextBox", - "caption": "Password -> (Smart-Me)", - "name": "Password" + "name": "Username", + "caption": "Benutzername", + "visible": false }, { - "type": "SelectVariable", - "name": "Token_Easee", - "caption": "Variable API-Token für Easee-Solarladen", - "suffix": "" + "type": "PasswordTextBox", + "name": "Password", + "caption": "Passwort", + "visible": false }, { "type": "SelectVariable", "name": "Token_ECarUp", - "caption": "Variable API-Token für ECarUp (Easee Solarladen)", - "suffix": "" + "caption": "Variable mit eCarUp API-Token", + "suffix": "", + "visible": false + }, + { + "type": "Label", + "name": "EaseeGatewayHint", + "caption": "Das Easee SignalR Gateway wird oben über Schnittstelle konfigurieren/ändern ausgewählt.", + "visible": false } - ] -} \ No newline at end of file +} diff --git a/Ladestation/module.json b/Ladestation/module.json index 7803342..3e68d11 100644 --- a/Ladestation/module.json +++ b/Ladestation/module.json @@ -4,9 +4,13 @@ "type": 3, "vendor": "Belevo AG", "aliases": [], - "parentRequirements": [], + "parentRequirements": [ + "{BC4E9B83-9C9B-44C3-A902-5CEB45B0E5B1}" + ], "childRequirements": [], - "implemented": [], + "implemented": [ + "{A8EF2E37-6B35-4E92-A7D1-4F8172790BA2}" + ], "prefix": "GEF", "url": "https://git.belevo.ch/dh/Enelix/src/branch/main/Ladestation" -} \ No newline at end of file +} diff --git a/Ladestation/module.php b/Ladestation/module.php index d42bbb4..3f17484 100644 --- a/Ladestation/module.php +++ b/Ladestation/module.php @@ -1,9 +1,16 @@ RegisterPropertyString("IP_Adresse", "0.0.0.0"); $this->RegisterPropertyInteger("Ladestation", 2); @@ -16,150 +23,588 @@ class Ladestation extends IPSModule $this->RegisterPropertyInteger("Zeit_Zwischen_Zustandswechseln", 1); $this->RegisterPropertyInteger("Ein_Zeit", 0); // Recheninterval $this->RegisterPropertyInteger("Aus_Zeit", 0); // Recheninterval - $this->RegisterPropertyInteger("Token_Easee", 0); // Recheninterval $this->RegisterPropertyInteger("Token_ECarUp", 0); // Recheninterval + $this->RegisterPropertyInteger("EaseeGatewayID", 0); + + // Ladestationspezifische Variabeln - $this->RegisterVariableFloat("Max_Current", "Maximaler Ladestrom", "", 0); - IPS_SetHidden($this->GetIDForIdent("Max_Current") , true); + $this->RegisterVariableFloat("Max_Current","Maximaler Ladestrom","", 0); + IPS_SetHidden($this->GetIDForIdent("Max_Current"), true); $this->RegisterVariableBoolean("Is_1_ph", "Auto lädt 1-Phasig", "~Switch", false); - $this->RegisterVariableBoolean("Car_detected", "Auto erkannt", "~Switch", false); + $this->RegisterVariableBoolean("Car_detected", "Auto erkannt","~Switch", false); $this->RegisterVariableInteger("Pending_Counter", "Pending_Counter", "", 0); - IPS_SetHidden($this->GetIDForIdent("Pending_Counter") , true); + IPS_SetHidden($this->GetIDForIdent("Pending_Counter"), true); $this->RegisterVariableBoolean("Car_is_full", "Auto fertig geladen", "~Switch", false); $this->RegisterVariableBoolean("Ladebereit", "Ladestation ein", "~Switch", true); $this->EnableAction("Ladebereit"); $this->RegisterVariableBoolean("Solarladen", "Solarladen ein", "~Switch", false); $this->EnableAction("Solarladen"); $this->RegisterVariableInteger("Fahrzeugstatus", "Fahrzeugstatus", "", 0); - IPS_SetHidden($this->GetIDForIdent("Fahrzeugstatus") , true); + IPS_SetHidden($this->GetIDForIdent("Fahrzeugstatus"), true); + $this->RegisterVariableFloat("Ladeleistung_Effektiv", "Aktuelle Ladeleistung", "", 0); $this->RegisterVariableBoolean("Peak", "Peak", "", 0); - IPS_SetHidden($this->GetIDForIdent("Peak") , true); + IPS_SetHidden($this->GetIDForIdent("Peak"), true); + $this->RegisterVariableBoolean("IsTimerActive", "IsTimerActive", "", false); - IPS_SetHidden($this->GetIDForIdent("IsTimerActive") , true); - $this->RegisterTimer("ZustandswechselTimer", 0, "IPS_RequestAction(" . $this->InstanceID . ', "ResetTimer", "");'); + IPS_SetHidden($this->GetIDForIdent("IsTimerActive"), true); + + $this->RegisterTimer("ZustandswechselTimer",0,"IPS_RequestAction(" .$this->InstanceID .', "ResetTimer", "");'); + $this->RegisterVariableBoolean("IsTimerActive_Null_Timer", "IsTimerActive_Null_Timer", "", false); - IPS_SetHidden($this->GetIDForIdent("IsTimerActive_Null_Timer") , true); - $this->RegisterTimer("Null_Timer", 0, "IPS_RequestAction(" . $this->InstanceID . ', "ResetNullTimer", "");'); + IPS_SetHidden($this->GetIDForIdent("IsTimerActive_Null_Timer"), true); + + $this->RegisterTimer("Null_Timer",0,"IPS_RequestAction(" .$this->InstanceID .', "ResetNullTimer", "");'); + $this->RegisterVariableString("Letzer_User", "Letzter registrierter Benutzer"); - IPS_SetHidden($this->GetIDForIdent("Letzer_User") , true); + IPS_SetHidden($this->GetIDForIdent("Letzer_User"), true); + + + // Variabeln für Kommunkation mit Manager $this->RegisterVariableInteger("Sperre_Prio", "Priorität Sperre", "", 0); $this->EnableAction("Sperre_Prio"); - IPS_SetHidden($this->GetIDForIdent("Sperre_Prio") , true); + IPS_SetHidden($this->GetIDForIdent("Sperre_Prio"), true); + $this->RegisterVariableInteger("PV_Prio", "Priorität Solarladen", "", 0); $this->EnableAction("PV_Prio"); - IPS_SetHidden($this->GetIDForIdent("PV_Prio") , true); + IPS_SetHidden($this->GetIDForIdent("PV_Prio"), true); + $this->RegisterVariableBoolean("Idle", "Idle", "", 0); - IPS_SetHidden($this->GetIDForIdent("Idle") , true); + IPS_SetHidden($this->GetIDForIdent("Idle"), true); + $this->RegisterVariableInteger("Aktuelle_Leistung", "Aktuelle_Leistung", "", 0); - IPS_SetHidden($this->GetIDForIdent("Aktuelle_Leistung") , true); + IPS_SetHidden($this->GetIDForIdent("Aktuelle_Leistung"), true); + $this->RegisterVariableFloat("Bezogene_Energie", "Gesamter Energiebezug", "", 0); - IPS_SetHidden($this->GetIDForIdent("Bezogene_Energie") , true); + IPS_SetHidden($this->GetIDForIdent("Bezogene_Energie"), true); + $this->RegisterVariableString("PowerSteps", "Leistungsschritte"); - IPS_SetHidden($this->GetIDForIdent("PowerSteps") , true); + IPS_SetHidden($this->GetIDForIdent("PowerSteps"), true); + $this->RegisterVariableInteger("Power", "Power"); - IPS_SetHidden($this->GetIDForIdent("Power") , true); + IPS_SetHidden($this->GetIDForIdent("Power"), true); + $this->RegisterVariableBoolean("Is_Peak_Shaving", "Is_Peak_Shaving"); - IPS_SetHidden($this->GetIDForIdent("Is_Peak_Shaving") , true); + IPS_SetHidden($this->GetIDForIdent("Is_Peak_Shaving"), true); + $this->RegisterVariableInteger("Leistung_Delta", "Leistung_Delta", "", 0); - IPS_SetHidden($this->GetIDForIdent("Leistung_Delta") , true); - $this->RegisterVariableString("Token_Intern", "Internes Token Easee"); - IPS_SetHidden($this->GetIDForIdent("Token_Intern") , true); + IPS_SetHidden($this->GetIDForIdent("Leistung_Delta"), true); + + $this->RegisterVariableBoolean( + "Easee_Gateway_Connected", + "Easee Gateway verbunden", + "~Switch", + false + ); + IPS_SetHidden($this->GetIDForIdent("Easee_Gateway_Connected"), true); + $this->SetBuffer("EaseeGatewayState", "{}"); + // Hilfsvariabeln für Idle zustand $this->RegisterPropertyInteger("IdleCounterMax", 2); $this->RegisterVariableInteger("IdleCounter", "IdleCounter", "", 0); - IPS_SetHidden($this->GetIDForIdent("IdleCounter") , true); + IPS_SetHidden($this->GetIDForIdent("IdleCounter"), true); $this->SetValue("IdleCounter", 0); + // Initialisiere Idle $this->SetValue("Idle", true); - $this->RegisterTimer("Timer_Do_UserCalc_EVC", $this->ReadPropertyInteger("Interval") * 1000, "IPS_RequestAction(" . $this->InstanceID . ', "Do_UserCalc", "");'); - $this->RegisterTimer("Timer_Refresh_Token", 0, "IPS_RequestAction(" . $this->InstanceID . ', "Refresh_Token", "");'); + + $this->RegisterTimer("Timer_Do_UserCalc_EVC",$this->ReadPropertyInteger("Interval")*1000,"IPS_RequestAction(" .$this->InstanceID .', "Do_UserCalc", "");'); $this->RegisterVariableInteger("Mindestaldestrom", "Mindestaldestrom", "", 0); $this->EnableAction("Mindestaldestrom"); + } + + public function Migrate($JSONData) + { + parent::Migrate($JSONData); + + $data = json_decode($JSONData, true); + if (!is_array($data)) { + return ""; + } + + if (!isset($data["configuration"]) || !is_array($data["configuration"])) { + $data["configuration"] = []; + } + + if (array_key_exists("EaseeGatewayID", $data["configuration"])) { + return ""; + } + + // In Migrate keine Instanzfunktionen aufrufen: Die Instanzschnittstelle + // wird zu diesem Zeitpunkt erst aufgebaut. + $data["configuration"]["EaseeGatewayID"] = 0; + return json_encode($data); + } + + public function GetConfigurationForm() + { + $form = json_decode(file_get_contents(__DIR__ . "/form.json"), true); + $fieldConfiguration = $this->GetStationFormConfiguration( + $this->ReadPropertyInteger("Ladestation") + ); + + foreach ($form["elements"] as &$element) { + $name = (string)($element["name"] ?? ""); + if (!isset($fieldConfiguration[$name])) { + continue; + } + + foreach ($fieldConfiguration[$name] as $parameter => $value) { + $element[$parameter] = $value; + } + } + unset($element); + + return json_encode($form); + } + + private function GetStationFormConfiguration(int $stationType): array + { + $configuration = [ + "IP_Adresse" => [ + "visible" => false, + "caption" => "IP-Adresse", + ], + "ID" => [ + "visible" => false, + "caption" => "Geräte-ID", + ], + "Seriennummer" => [ + "visible" => false, + "caption" => "Seriennummer", + ], + "Username" => [ + "visible" => false, + "caption" => "Benutzername", + ], + "Password" => [ + "visible" => false, + "caption" => "Passwort", + ], + "Token_ECarUp" => [ + "visible" => false, + "caption" => "Variable mit eCarUp API-Token", + ], + "EaseeGatewayHint" => [ + "visible" => false, + ], + ]; + + switch ($stationType) { + case 1: + $configuration["IP_Adresse"] = [ + "visible" => true, + "caption" => "IP-Adresse der Go-E Wallbox", + ]; + break; + + case 2: + $configuration["IP_Adresse"] = [ + "visible" => true, + "caption" => "IP-Adresse der Go-E Gemini / Gemini Flex", + ]; + break; + + case 3: + $configuration["ID"] = [ + "visible" => true, + "caption" => "Smart-Me Geräte-ID", + ]; + $configuration["Seriennummer"] = [ + "visible" => true, + "caption" => "Smart-Me Seriennummer", + ]; + $configuration["Username"] = [ + "visible" => true, + "caption" => "Smart-Me Benutzername", + ]; + $configuration["Password"] = [ + "visible" => true, + "caption" => "Smart-Me Passwort", + ]; + break; + + case 5: + $configuration["ID"] = [ + "visible" => true, + "caption" => "eCarUp Stations-/Connector-ID", + ]; + $configuration["Seriennummer"] = [ + "visible" => true, + "caption" => "Easee Seriennummer", + ]; + $configuration["Username"] = [ + "visible" => true, + "caption" => "eCarUp Benutzerkennung für Solarladen", + ]; + $configuration["Token_ECarUp"]["visible"] = true; + $configuration["EaseeGatewayHint"]["visible"] = true; + break; + + case 6: + $configuration["Seriennummer"] = [ + "visible" => true, + "caption" => "Easee Seriennummer", + ]; + $configuration["EaseeGatewayHint"]["visible"] = true; + break; + } + + return $configuration; + } + + private function UpdateStationForm(int $stationType) + { + foreach ($this->GetStationFormConfiguration($stationType) as $field => $parameters) { + foreach ($parameters as $parameter => $value) { + $this->UpdateFormField($field, $parameter, $value); + } + } + } + public function ApplyChanges() { parent::ApplyChanges(); - $this->SetTimerInterval("Timer_Do_UserCalc_EVC", $this->ReadPropertyInteger("Interval") * 1000); - // erstelle einen Timer der das Request token aktualisiert wenn die station dies braucht (aktuell nur für Solarladelösung Easee). - if ($this->ReadPropertyInteger("Ladestation") == 6) - { - $this->Refresh_Token(); - $this->SetTimerInterval("Timer_Refresh_Token", 1800000); + // Bei aktualisierten Bestandsinstanzen die in Version 1.1 neue Variable + // sofort anlegen; RegisterVariableBoolean ist idempotent. + $this->RegisterVariableBoolean( + "Easee_Gateway_Connected", + "Easee Gateway verbunden", + "~Switch", + false + ); + $this->SetTimerInterval("Timer_Do_UserCalc_EVC",$this->ReadPropertyInteger("Interval")*1000); + $stationType = $this->ReadPropertyInteger("Ladestation"); + $usesEaseeGateway = $this->UsesEaseeGateway($stationType); + IPS_SetHidden( + $this->GetIDForIdent("Easee_Gateway_Connected"), + !$usesEaseeGateway + ); + + $instance = IPS_GetInstance($this->InstanceID); + $parentID = (int)$instance["ConnectionID"]; + + // Eine in Version 1.2/1.3 gespeicherte Gateway-Auswahl wieder als + // normale IP-Symcon-Schnittstelle verbinden. + if ($parentID <= 0) { + $storedGatewayID = $this->GetConfiguredEaseeGatewayID(); + if ($storedGatewayID > 0) { + IPS_ConnectInstance($this->InstanceID, $storedGatewayID); + $parentID = $storedGatewayID; + } } + + if ($usesEaseeGateway && $this->IsEaseeGatewayInstance($parentID)) { + $this->SubscribeToEaseeGateway(); + } else { + $this->SetValue("Easee_Gateway_Connected", false); + } + + // erstelle einen Timer der das Request token aktualisiert wenn die station dies braucht. + // Zusätzliche Anpassungen nach Bedarf } + + public function RequestAction($Ident, $Value) { - switch ($Ident) - { + switch ($Ident) { + + case "UpdateStationForm": + $this->UpdateStationForm((int)$Value); + break; + case "SetAktuelle_Leistung": $this->SetValue("Power", (int)$Value); - break; + break; + case "GetCurrentData": $this->SetValue("Is_Peak_Shaving", (bool)$Value); - break; - case "Do_UserCalc": // Auto und ladestrom erkennen. - if ($this->Detect_Car($this->ReadPropertyInteger("Ladestation"))) - { + break; + + case "Do_UserCalc": + + + if($this->Detect_Car($this->ReadPropertyInteger("Ladestation"))){ $this->SetAktuelle_Leistung($this->GetValue("Power")); $this->GetCurrentData($this->GetValue("Is_Peak_Shaving")); } - else - { - SetValue($this->GetIDForIdent("PowerSteps") , json_encode([0])); + else{ + SetValue($this->GetIDForIdent("PowerSteps"), json_encode([0])); $this->SetValue("PowerSteps", json_encode([0])); + + } - break; + break; + case "Sperre_Prio": $this->SetValue("Sperre_Prio", (bool)$Value); - break; + break; + case "PV_Prio": $this->SetValue("PV_Prio", (bool)$Value); - break; + break; + case "Solarladen": $this->SetValue("Solarladen", (bool)$Value); - break; + break; + case "Ladebereit": $this->SetValue("Ladebereit", (bool)$Value); - break; + break; + case "ResetTimer": - $this->ResetTimer(); - break; + $this->ResetTimer(); + break; + case "ResetNullTimer": - $this->ResetNullTimer(); - break; - case "Refresh_Token": - $this->Refresh_Token(); - break; + $this->ResetNullTimer(); + break; + case "Mindestaldestrom": - $this->SetValue("Mindestaldestrom", (int)$Value); - break; + $this->SetValue("Mindestaldestrom", (int)$Value); + break; + default: - break; + throw new Exception("Invalid Ident"); } } - // Erkenne, ob ein auto angeschlossen ist und mit welchem strom es lädt, setzte Statusvariabeln zur Ladestation - public function Detect_Car(int $carType) + + public function ReceiveData($JSONString) { - if ($this->GetValue("Car_detected") == true) - { // Wenn schon auto angeschlossen, schaue ob es noch lädt - if ($this->Get_Car_Status($carType) == true) - { - $this->SetValue("Car_detected", true); - if ($this->GetValue("Max_Current") < 6) - { - $this->SetValue("Car_is_full", true); - $this->ResetTimer(); - $this->ResetNullTimer(); + $packet = json_decode($JSONString, true); + if (!is_array($packet) || !isset($packet["Buffer"])) { + return; + } + + $message = json_decode($packet["Buffer"], true); + if (!is_array($message) || !isset($message["type"])) { + return; + } + + if ($message["type"] === "GatewayStatus") { + $this->SetValue( + "Easee_Gateway_Connected", + (bool)($message["connected"] ?? false) + ); + return; + } + + if ( + $message["type"] !== "Observation" || + strtoupper((string)($message["serialNumber"] ?? "")) !== + strtoupper($this->ReadPropertyString("Seriennummer")) + ) { + return; + } + + $this->StoreEaseeObservation( + (int)($message["id"] ?? 0), + $message["value"] ?? null, + (int)($message["timestamp"] ?? time()) + ); + } + + private function SubscribeToEaseeGateway() + { + $serialNumber = strtoupper(trim($this->ReadPropertyString("Seriennummer"))); + if ($serialNumber === "") { + return; + } + + $response = $this->SendEaseeGatewayRequest([ + "action" => "Subscribe", + "serialNumber" => $serialNumber, + ]); + $this->ApplyEaseeGatewayResponse($response); + } + + private function GetEaseeStateFromGateway() + { + $serialNumber = strtoupper(trim($this->ReadPropertyString("Seriennummer"))); + if ($serialNumber === "") { + return; + } + + $response = $this->SendEaseeGatewayRequest([ + "action" => "GetState", + "serialNumber" => $serialNumber, + ]); + $this->ApplyEaseeGatewayResponse($response); + } + + private function SendEaseeGatewayRequest(array $request) + { + $instance = IPS_GetInstance($this->InstanceID); + $parentID = (int)$instance["ConnectionID"]; + if (!$this->IsEaseeGatewayInstance($parentID)) { + $this->SetValue("Easee_Gateway_Connected", false); + return null; + } + + $response = $this->SendDataToParent(json_encode([ + "DataID" => self::EASEE_GATEWAY_REQUEST_ID, + "Buffer" => json_encode($request), + ])); + + if (!is_string($response) || $response === "") { + return null; + } + + $decoded = json_decode($response, true); + return is_array($decoded) ? $decoded : null; + } + + private function GetConfiguredEaseeGatewayID(): int + { + $gatewayID = $this->ReadPropertyInteger("EaseeGatewayID"); + if ($gatewayID <= 0 || !IPS_InstanceExists($gatewayID)) { + return 0; + } + + $gateway = IPS_GetInstance($gatewayID); + if ($gateway["ModuleInfo"]["ModuleID"] !== self::EASEE_GATEWAY_MODULE_ID) { + return 0; + } + + return $gatewayID; + } + + private function IsEaseeGatewayInstance(int $instanceID): bool + { + if ($instanceID <= 0 || !IPS_InstanceExists($instanceID)) { + return false; + } + + $instance = IPS_GetInstance($instanceID); + return $instance["ModuleInfo"]["ModuleID"] === self::EASEE_GATEWAY_MODULE_ID; + } + + private function UsesEaseeGateway(int $stationType): bool + { + return $stationType === 5 || $stationType === 6; + } + + private function UsesDirectStationDetection(int $stationType): bool + { + return in_array($stationType, [1, 2, 3, 5, 6], true); + } + + private function ApplyEaseeGatewayResponse($response) + { + if (!is_array($response)) { + $this->SetValue("Easee_Gateway_Connected", false); + return; + } + + if (array_key_exists("connected", $response)) { + $this->SetValue( + "Easee_Gateway_Connected", + (bool)$response["connected"] + ); + } + + if (!isset($response["state"]) || !is_array($response["state"])) { + return; + } + + $updated = (int)($response["state"]["updated"] ?? time()); + foreach ([47, 109, 110, 120, 182, 183, 184, 185] as $observationID) { + $key = (string)$observationID; + if (array_key_exists($key, $response["state"])) { + $this->StoreEaseeObservation( + $observationID, + $response["state"][$key], + $updated + ); + } + } + } + + private function StoreEaseeObservation(int $observationID, $value, int $timestamp) + { + if (!in_array($observationID, [47, 109, 110, 120, 182, 183, 184, 185], true)) { + return; + } + + $state = json_decode($this->GetBuffer("EaseeGatewayState"), true); + if (!is_array($state)) { + $state = []; + } + + if ($observationID === 109) { + $previousMode = (int)($state["109"] ?? -1); + if ((int)$value === 1 || $previousMode === 1) { + foreach ([110, 182, 183, 184, 185] as $sessionObservationID) { + $state[(string)$sessionObservationID] = 0; } } - else - { - $this->SetValue("Car_detected", false); - $this->SetValue("Pending_Counter", 0); + } + + $state[(string)$observationID] = $value; + $state["updated"] = $timestamp; + $this->SetBuffer("EaseeGatewayState", json_encode($state)); + + if ($observationID === 109) { + $this->SetValue("Fahrzeugstatus", (int)$value); + } elseif ($observationID === 120) { + $this->SetValue("Ladeleistung_Effektiv", round((float)$value * 1000)); + } + } + + private function GetEaseeCarStatusFromGateway(bool $currentState): bool + { + $this->GetEaseeStateFromGateway(); + $state = json_decode($this->GetBuffer("EaseeGatewayState"), true); + if (!is_array($state) || !array_key_exists("109", $state)) { + return $currentState; + } + + $chargerOpMode = (int)$state["109"]; + $currentState = in_array($chargerOpMode, [2, 3, 4, 6], true); + + if (array_key_exists("120", $state)) { + $this->SetValue( + "Ladeleistung_Effektiv", + round((float)$state["120"] * 1000) + ); + } + $this->SetValue("Fahrzeugstatus", $chargerOpMode); + + return $currentState; + } + + private function DetectEaseeCar(int $carType): bool + { + $wasDetected = $this->GetValue("Car_detected"); + $wasOnePhase = $this->GetValue("Is_1_ph"); + $carDetected = $this->Get_Car_Status($carType); + $state = json_decode($this->GetBuffer("EaseeGatewayState"), true); + if (!is_array($state)) { + $state = []; + } + + $this->SetValue("Pending_Counter", 0); + + $this->DetectEaseePhases($state); + $phaseChanged = $wasOnePhase !== $this->GetValue("Is_1_ph"); + + // Observation 47 ist der nichtflüchtige maximale Ladestrom der + // Station. Die lokal konfigurierte Obergrenze bleibt zusätzlich aktiv. + $maxCurrent = (float)$this->ReadPropertyInteger("Max_Current_abs"); + if (array_key_exists("47", $state) && (float)$state["47"] > 0) { + $maxCurrent = min($maxCurrent, (float)$state["47"]); + } + $this->SetValue("Max_Current", $maxCurrent); + + if (!$carDetected) { + $this->SetValue("Car_detected", false); + $this->SetValue("Car_is_full", false); + + $chargerOpMode = (int)($state["109"] ?? -1); + if ($chargerOpMode === 1) { $this->SetValue("Leistung_Delta", 0); - $this->SetValue("Car_is_full", false); $this->ResetTimer(); $this->ResetNullTimer(); $this->SetValue("Is_1_ph", false); @@ -167,145 +612,521 @@ class Ladestation extends IPSModule $this->SetValue("IdleCounter", 0); $this->SetValue("Idle", true); } + + return false; } - else - { // wenn kein auto angeschlossen schaue ob eines angesteckt wurde - if ($this->Get_Car_Status($carType) == true) - { - $this->sendPowerToStation($this->ReadPropertyInteger("Max_Current_abs")); - $counter = $this->GetValue("Pending_Counter"); - if ($counter > (60 / ($this->ReadPropertyInteger("Interval")))) - { - $this->SetValue("Pending_Counter", 0); - if ($this->GetValue("Ladeleistung_Effektiv") > 7500) - { - $this->SetValue("Is_1_ph", false); - $this->Calc_Max_Current(false); - } - else - { - $this->SetValue("Is_1_ph", true); - $this->Calc_Max_Current(true); - } - $this->SetValue("Car_detected", true); - if ($this->GetValue("Is_1_ph")) - { - $power = $this->GetValue("Mindestaldestrom") * 230; - } - else - { - $power = $this->GetValue("Mindestaldestrom") * 400 * 1.71; - } - $this->SetValue("Power", $power); - } - else - { - $this->SetValue("Pending_Counter", $counter + 1); - $this->SetValue("Car_detected", false); + + $this->SetValue("Car_detected", true); + $this->SetValue("Car_is_full", (int)($state["109"] ?? 0) === 4); + + if (!$wasDetected || $phaseChanged) { + if ($this->GetValue("Is_1_ph")) { + $power = $this->GetValue("Mindestaldestrom") * 230; + } else { + $power = $this->GetValue("Mindestaldestrom") * 400 * 1.71; + } + $this->SetValue("Power", $power); + } + + return true; + } + + private function DetectEaseePhases(array $state) + { + $outputPhase = (int)($state["110"] ?? 0); + + // Ein explizit einphasiger Easee-Ausgang ist auch in IT-Netzen + // einphasig, obwohl dort Strom auf zwei Leitern gemessen wird. + if ($outputPhase >= 10 && $outputPhase <= 15) { + $this->SetValue("Is_1_ph", true); + return; + } + + $activePhaseConductors = 0; + foreach ([183, 184, 185] as $observationID) { + if (abs((float)($state[(string)$observationID] ?? 0)) >= 1.0) { + $activePhaseConductors++; + } + } + + // Bei einem dreiphasig freigegebenen Ausgang kann ein einphasiges Auto + // trotzdem nur auf einem Leiter Strom beziehen. Observation 110 allein + // kann diesen Fahrzeugwechsel deshalb nicht erkennen. + if ($activePhaseConductors === 1) { + $this->SetValue("Is_1_ph", true); + } elseif ($activePhaseConductors >= 2) { + $this->SetValue("Is_1_ph", false); + } elseif ( + ($outputPhase >= 20 && $outputPhase <= 22) || + $outputPhase === 30 + ) { + $this->SetValue("Is_1_ph", false); + } + } + + private function ReadJsonEndpoint(string $url, bool $useAuthentication = false) + { + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $url); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); + curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5); + curl_setopt($ch, CURLOPT_TIMEOUT, 10); + + if ($useAuthentication) { + curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); + curl_setopt( + $ch, + CURLOPT_USERPWD, + $this->ReadPropertyString("Username") . ":" . + $this->ReadPropertyString("Password") + ); + } + + $response = curl_exec($ch); + $httpCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE); + curl_close($ch); + + if (!is_string($response) || $response === "" || $httpCode >= 400) { + return null; + } + + $data = json_decode($response, true); + return is_array($data) ? $data : null; + } + + private function DetectOnePhaseFromCurrents(array $currents) + { + $activePhases = 0; + $hasMeasurements = false; + + foreach ($currents as $current) { + if (!is_numeric($current)) { + continue; + } + + $hasMeasurements = true; + if (abs((float)$current) >= 1.0) { + $activePhases++; + } + } + + if (!$hasMeasurements || $activePhases === 0) { + return null; + } + + return $activePhases === 1; + } + + private function ApplyDirectStationDetection( + bool $carDetected, + bool $carIsFull, + $isOnePhase, + float $maxCurrent + ): bool { + $wasDetected = $this->GetValue("Car_detected"); + $wasOnePhase = $this->GetValue("Is_1_ph"); + + $this->SetValue("Pending_Counter", 0); + $this->SetValue("Max_Current", $maxCurrent); + + if (!$carDetected) { + $this->SetValue("Car_detected", false); + $this->SetValue("Car_is_full", false); + $this->SetValue("Leistung_Delta", 0); + $this->ResetTimer(); + $this->ResetNullTimer(); + $this->SetValue("Is_1_ph", false); + $this->SetValue("Aktuelle_Leistung", 0); + $this->SetValue("IdleCounter", 0); + $this->SetValue("Idle", true); + return false; + } + + if (is_bool($isOnePhase)) { + $this->SetValue("Is_1_ph", $isOnePhase); + } + + $this->SetValue("Car_detected", true); + $this->SetValue("Car_is_full", $carIsFull); + + $phaseChanged = $wasOnePhase !== $this->GetValue("Is_1_ph"); + if (!$wasDetected || $phaseChanged) { + if ($this->GetValue("Is_1_ph")) { + $power = $this->GetValue("Mindestaldestrom") * 230; + } else { + $power = $this->GetValue("Mindestaldestrom") * 400 * 1.71; + } + $this->SetValue("Power", $power); + } + + return true; + } + + private function GetGoEMaxCurrent(array $data): float + { + $maxCurrent = (float)$this->ReadPropertyInteger("Max_Current_abs"); + + foreach (["ama", "cbl"] as $key) { + if (isset($data[$key]) && is_numeric($data[$key])) { + $candidate = (float)$data[$key]; + if ($candidate >= 6) { + $maxCurrent = min($maxCurrent, $candidate); } } - else - { + } + + if (isset($data["var"]) && is_numeric($data["var"])) { + $variant = (int)$data["var"]; + if ($variant === 11) { + $maxCurrent = min($maxCurrent, 16); + } elseif ($variant === 22) { + $maxCurrent = min($maxCurrent, 32); + } + } + + return $maxCurrent; + } + + private function DetectGoECar(int $stationType): bool + { + $path = $stationType === 1 ? "/mqtt?payload=" : "/api/status"; + $data = $this->ReadJsonEndpoint( + "http://" . $this->ReadPropertyString("IP_Adresse") . $path + ); + + if (!is_array($data) || !isset($data["car"]) || !is_numeric($data["car"])) { + return $this->GetValue("Car_detected"); + } + + $carState = (int)$data["car"]; + if (!in_array($carState, [1, 2, 3, 4, 5], true)) { + return $this->GetValue("Car_detected"); + } + + $this->SetValue("Fahrzeugstatus", $carState); + + $isOnePhase = null; + if (isset($data["nrg"]) && is_array($data["nrg"])) { + $currentFactor = $stationType === 1 ? 0.1 : 1.0; + $phaseCurrents = []; + foreach ([4, 5, 6] as $index) { + $phaseCurrents[] = isset($data["nrg"][$index]) && + is_numeric($data["nrg"][$index]) + ? (float)$data["nrg"][$index] * $currentFactor + : null; + } + $isOnePhase = $this->DetectOnePhaseFromCurrents($phaseCurrents); + + if (isset($data["nrg"][11]) && is_numeric($data["nrg"][11])) { + $powerFactor = $stationType === 1 ? 10 : 1; + $this->SetValue( + "Ladeleistung_Effektiv", + round((float)$data["nrg"][11] * $powerFactor) + ); + } + } + + return $this->ApplyDirectStationDetection( + in_array($carState, [2, 3, 4, 5], true), + $carState === 4, + $isOnePhase, + $this->GetGoEMaxCurrent($data) + ); + } + + private function DetectSmartMeCar(): bool + { + $deviceID = trim($this->ReadPropertyString("ID")); + if ($deviceID === "") { + return $this->GetValue("Car_detected"); + } + + $chargingData = $this->ReadJsonEndpoint( + "https://api.smart-me.com/pico/charging/" . $deviceID, + true + ); + if (!is_array($chargingData)) { + return $this->GetValue("Car_detected"); + } + + $stateValue = $chargingData["State"] ?? $chargingData["state"] ?? null; + if (!is_numeric($stateValue)) { + return $this->GetValue("Car_detected"); + } + + $stationState = (int)$stateValue; + if (!in_array($stationState, [1, 2, 3, 4, 6], true)) { + return $this->GetValue("Car_detected"); + } + + $this->SetValue("Fahrzeugstatus", $stationState); + + $chargingPower = $chargingData["ActiveChargingPower"] ?? + $chargingData["activeChargingPower"] ?? null; + if (is_numeric($chargingPower)) { + $this->SetValue( + "Ladeleistung_Effektiv", + round((float)$chargingPower * 1000) + ); + } + + $isOnePhase = null; + $deviceData = $this->ReadJsonEndpoint( + "https://api.smart-me.com/Devices/" . $deviceID, + true + ); + if (is_array($deviceData)) { + $phaseCurrents = [ + $deviceData["CurrentL1"] ?? $deviceData["currentL1"] ?? null, + $deviceData["CurrentL2"] ?? $deviceData["currentL2"] ?? null, + $deviceData["CurrentL3"] ?? $deviceData["currentL3"] ?? null, + ]; + $isOnePhase = $this->DetectOnePhaseFromCurrents($phaseCurrents); + } + + $maxCurrent = (float)$this->ReadPropertyInteger("Max_Current_abs"); + foreach ([ + "MaxStationCurrent", + "maxStationCurrent", + "MaxLoadmanagementGroupCurrent", + "maxLoadmanagementGroupCurrent", + ] as $key) { + if (isset($chargingData[$key]) && is_numeric($chargingData[$key])) { + $candidate = (float)$chargingData[$key]; + if ($candidate >= 6) { + $maxCurrent = min($maxCurrent, $candidate); + } + } + } + + return $this->ApplyDirectStationDetection( + in_array($stationState, [2, 3, 4, 6], true), + false, + $isOnePhase, + $maxCurrent + ); + } + + private function SendEaseeCurrentToGateway(float $value) + { + $response = $this->SendEaseeGatewayRequest([ + "action" => "SetDynamicChargerCurrent", + "serialNumber" => strtoupper(trim($this->ReadPropertyString("Seriennummer"))), + "amps" => $value, + ]); + + if (!is_array($response) || !($response["success"] ?? false)) { + $error = is_array($response) + ? (string)($response["error"] ?? "Unbekannter Gateway-Fehler") + : "Easee Gateway nicht erreichbar"; + return $error; + } + + return $response["body"] ?? null; + } + + + public function Detect_Car(int $carType) + { + + if ($carType === 1 || $carType === 2) { + return $this->DetectGoECar($carType); + } + + if ($carType === 3) { + return $this->DetectSmartMeCar(); + } + + if ($this->UsesEaseeGateway($carType)) { + return $this->DetectEaseeCar($carType); + } + + if($this->GetValue("Car_detected")==true){ + if($this->Get_Car_Status($carType)==true){ + $this->SetValue("Car_detected", true); + if($this->GetValue("Max_Current")<6){ + $this->SetValue("Car_is_full", true); + $this->ResetTimer(); + $this->ResetNullTimer(); + + } + + }else{ + $this->SetValue("Car_detected", false); + $this->SetValue("Pending_Counter", 0); + $this->SetValue("Leistung_Delta", 0); + $this->SetValue("Car_is_full", false); + $this->ResetTimer(); + $this->ResetNullTimer(); + $this->SetValue("Is_1_ph", false); + $this->SetValue("Aktuelle_Leistung", 0); + $this->SetValue("IdleCounter", 0); + $this->SetValue("Idle", true); + } + } + else{ + if($this->Get_Car_Status($carType)==true){ + + $this->sendPowerToStation($this->ReadPropertyInteger("Max_Current_abs")); + + $counter = $this->GetValue("Pending_Counter"); + + if($counter>(60/($this->ReadPropertyInteger("Interval")))){ + + $this->SetValue("Pending_Counter", 0); + if($this->GetValue("Ladeleistung_Effektiv")>7500){ + $this->SetValue("Is_1_ph", false); + $this->Calc_Max_Current(false); + + } + else{ + $this->SetValue("Is_1_ph", true); + $this->Calc_Max_Current(true); + + } + + $this->SetValue("Car_detected", true); + + if ($this->GetValue("Is_1_ph")) { + $power = $this->GetValue("Mindestaldestrom") * 230; + } + else { + $power = $this->GetValue("Mindestaldestrom") * 400 * 1.71; + } + + $this->SetValue("Power", $power); + + + } + else{ + $this->SetValue("Pending_Counter", $counter+1); + $this->SetValue("Car_detected", false); + + } + + }else{ $this->SetValue("Car_detected", false); $this->SetValue("Leistung_Delta", 0); - $this->sendPowerToStation($this->ReadPropertyInteger("Max_Current_abs")); + $this->sendPowerToStation($this->ReadPropertyInteger("Max_Current_abs")); } } - return $this->GetValue("Car_detected"); + + return $this->GetValue("Car_detected"); + } + + + // Methode zum Setzen der PowerSteps und Timer starten public function SetTimerOn() { - // Timer setzen, der nach "Zeit_Zwischen_Zustandswechseln" abläuft, verhindert schnelles Takten + // Timer setzen, der nach "Zeit_Zwischen_Zustandswechseln" abläuft $zeitZwischenZustandswechseln = $this->ReadPropertyInteger("Zeit_Zwischen_Zustandswechseln"); - if ($zeitZwischenZustandswechseln > 0) - { + + if($zeitZwischenZustandswechseln>0){ $this->SetTimerInterval("ZustandswechselTimer", $zeitZwischenZustandswechseln * 60000); // Timer in Millisekunden // Timer-Status auf true setzen $this->SetValue("IsTimerActive", true); - } - else - { + }else{ $this->SetValue("IsTimerActive", false); + } } - // Methode zum Setzen eines mindeststromes beim laden, über einen timer + + + // Methode zum Setzen der PowerSteps und Timer starten public function SetTimerNullMindestlast($time) { - if ($time > 0) - { + if($time>0){ $this->SetTimerInterval("Null_Timer", $time * 60000); // Timer in Millisekunden // Timer-Status auf true setzen $this->SetValue("IsTimerActive_Null_Timer", true); - } - else - { + }else{ $this->SetValue("IsTimerActive_Null_Timer", false); + } } - // Methode zum Zurücksetzen nach Ablauf des Timers + + + // Methode zum Zurücksetzen von PowerSteps nach Ablauf des Timers public function ResetTimer() { // Timer stoppen $this->SetTimerInterval("ZustandswechselTimer", 0); + // Timer-Status auf false setzen $this->SetValue("IsTimerActive", false); } - // Methode zum Zurücksetzen nach Ablauf des Timers Mindeststroms + + // Methode zum Zurücksetzen von PowerSteps nach Ablauf des Timers public function ResetNullTimer() { // Timer stoppen $this->SetTimerInterval("Null_Timer", 0); + // Timer-Status auf false setzen $this->SetValue("IsTimerActive_Null_Timer", false); } - // Erkenne Autostatus (ladestrom, status) auf basis des Typs + + + public function Get_Car_Status(int $carType) { - $ch = curl_init(); - $car_on_station = $this->GetValue("Car_detected"); - switch ($carType) - { - case 1: // GO-E alt + $car_on_station = $this->GetValue("Car_detected"); + switch ($carType) { + case 1: + $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, "http://" . $this->ReadPropertyString("IP_Adresse") . "/mqtt?payload="); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); $response = curl_exec($ch); curl_close($ch); $data = json_decode($response, true); - if (json_last_error() === JSON_ERROR_NONE && isset($data["car"])) - { - if ($data["car"] != 1) - { - $car_on_station = true; + + if (json_last_error() === JSON_ERROR_NONE && isset($data["car"])) { + /*if ($data["car"] != 1) { + $this->SetValue("Car_detected", true); } - else - { - $car_on_station = false; + else{ + $this->SetValue("Car_detected", false); + }*/ + if ($data["car"] != 1) { + $car_on_station = true; } - $this->SetValue("Ladeleistung_Effektiv", $data["nrg"][11] * 10); + else{ + $car_on_station = false; + } + $this->SetValue("Ladeleistung_Effektiv", $data["nrg"][11]*10); $this->SetValue("Fahrzeugstatus", $data["car"]); } - break; - case 2: // Go-E Gemini + break; + + case 2: + $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, "http://" . $this->ReadPropertyString("IP_Adresse") . "/api/status"); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); $response = curl_exec($ch); curl_close($ch); $data = json_decode($response, true); - if (json_last_error() === JSON_ERROR_NONE && isset($data["car"])) - { - if ($data["car"] != 1) - { - $car_on_station = true; + + if (json_last_error() === JSON_ERROR_NONE && isset($data["car"])) { + /*if ($data["car"] != 1) { + $this->SetValue("Car_detected", true); } - else - { - $car_on_station = false; + else{ + $this->SetValue("Car_detected", false); + }*/ + if ($data["car"] != 1) { + $car_on_station = true; + } + else{ + $car_on_station = false; } $this->SetValue("Ladeleistung_Effektiv", $data["nrg"][11]); $this->SetValue("Fahrzeugstatus", $data["car"]); } - break; - case 3: // Smart-Me Pico + break; + + case 3: + $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, "https://api.smart-me.com/pico/charging/" . $this->ReadPropertyString("ID")); curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); curl_setopt($ch, CURLOPT_USERPWD, $this->ReadPropertyString("Username") . ":" . $this->ReadPropertyString("Password")); @@ -313,394 +1134,359 @@ class Ladestation extends IPSModule $response = curl_exec($ch); curl_close($ch); $data = json_decode($response, true); - if (json_last_error() === JSON_ERROR_NONE && isset($data["State"])) - { - if ($data["State"] != 1) - { - $car_on_station = true; + + if (json_last_error() === JSON_ERROR_NONE && isset($data["State"])) { + /*if ($data["car"] != 1) { + $this->SetValue("Car_detected", true); } - else - { - $car_on_station = false; + else{ + $this->SetValue("Car_detected", false); + }*/ + if ($data["State"] != 1) { + $car_on_station = true; } - $this->SetValue("Ladeleistung_Effektiv", round($data["ActiveChargingPower"] * 1000)); + else{ + $car_on_station = false; + } + $this->SetValue("Ladeleistung_Effektiv", round($data["ActiveChargingPower"]*1000)); $this->SetValue("Fahrzeugstatus", $data["State"]); + } - break; - case 4: // Herstellerunabh. - $car_on_station = true; - break; - case 5: // Solarladen E-Car-Up + break; + + case 4: + $car_on_station = true; + break; + + case 5: + // Benutzer eCarUp abfragen + $authToken = GetValue($this->ReadPropertyInteger("Token_ECarUp")); $ID = $this->ReadPropertyString("ID"); - $apiUrl = 'https://public-api.ecarup.com/v1/station/' . $ID . '/conn' . 'ectors/' . $ID . '/active-charging'; + $apiUrl = 'https://public-api.ecarup.com/v1/station/' . $ID . '/conn'.'ectors/'. $ID . '/active-charging'; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $apiUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); - curl_setopt($ch, CURLOPT_HTTPHEADER, ['accept: application/json', 'Authorization: Bearer ' . $authToken]); + curl_setopt($ch, CURLOPT_HTTPHEADER, [ + 'accept: application/json', + 'Authorization: Bearer ' . $authToken + ]); + $response = curl_exec($ch); $data = json_decode($response, true); + curl_close($ch); - if (json_last_error() === JSON_ERROR_NONE && isset($data["driverIdentifier"])) - { + + if (json_last_error() === JSON_ERROR_NONE && isset($data["driverIdentifier"])) { + $this->SetValue("Letzer_User", $data["driverIdentifier"]); - if ($this->ReadPropertyString("Username") === $data["driverIdentifier"]) - { + + if($this->ReadPropertyString("Username") === $data["driverIdentifier"]){ $this->SetValue("Solarladen", true); - } - else - { + }else{ $this->SetValue("Solarladen", false); } } - //Aktueller Zustand Ladestation abfragen (Leistung, auto eingesteckt?) - $ch2 = curl_init(); - $url2 = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/state"; - curl_setopt_array($ch2, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "GET", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . GetValue($this->ReadPropertyInteger("Token_Easee")) . "", "content-type: application/*+json"], ]); - curl_setopt($ch2, CURLOPT_URL, $url2); - curl_setopt($ch2, CURLOPT_RETURNTRANSFER, true); - $response_easee = curl_exec($ch2); - curl_close($ch2); - $easee_data = json_decode($response_easee, true); - if (json_last_error() === JSON_ERROR_NONE && isset($easee_data["chargerOpMode"])) - { - if ($easee_data["chargerOpMode"] != 1 && (($easee_data["chargerOpMode"] != 6) || ($this->GetValue("Car_detected") == true)) && $easee_data["chargerOpMode"] != 7) - { - $car_on_station = true; - } - else - { - $car_on_station = false; - } - $this->SetValue("Ladeleistung_Effektiv", round($easee_data["totalPower"] * 1000)); - $this->SetValue("Fahrzeugstatus", $easee_data["chargerOpMode"]); - } - break; - case 6: // Easee - //Aktueller Zustand Ladestation abfragen (Leistung, auto eingesteckt?) - $ch2 = curl_init(); - $url2 = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/state"; - curl_setopt_array($ch2, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "GET", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . $this->GetBuffer("Token_Intern") . "", "content-type: application/*+json"], ]); - curl_setopt($ch2, CURLOPT_URL, $url2); - curl_setopt($ch2, CURLOPT_RETURNTRANSFER, true); - $response_easee = curl_exec($ch2); - curl_close($ch2); - $easee_data = json_decode($response_easee, true); - if (json_last_error() === JSON_ERROR_NONE && isset($easee_data["chargerOpMode"])) - { - if ($easee_data["chargerOpMode"] != 1 && (($easee_data["chargerOpMode"] != 6) || ($this->GetValue("Car_detected") == true)) && $easee_data["chargerOpMode"] != 7) - { - $car_on_station = true; - } - else - { - $car_on_station = false; - } - $this->SetValue("Ladeleistung_Effektiv", round($easee_data["totalPower"] * 1000)); - $this->SetValue("Fahrzeugstatus", $easee_data["chargerOpMode"]); - } - break; + + $car_on_station = $this->GetEaseeCarStatusFromGateway($car_on_station); + + break; + + case 6: + $car_on_station = $this->GetEaseeCarStatusFromGateway($car_on_station); + + break; + default: $this->SetValue("Car_detected", false); $this->SetValue("Fahrzeugstatus", -1); - break; + break; } + + return $car_on_station; } - // Methode zum Berechnen des Maximalen Stroms den eine Ladestation/Auto ziehen kann. - public function Calc_Max_Current(bool $is_1_ph) + + public function Calc_Max_Current(bool $is_1_ph) { - $maxCurrent = 32; - if ($is_1_ph) - { - $maxCurrent = 2.5 + ($this->GetValue("Ladeleistung_Effektiv") / 230); + $maxCurrent = 32; + if($is_1_ph){ + + $maxCurrent = 2.5 + ($this->GetValue("Ladeleistung_Effektiv") / 230); } - else - { - $maxCurrent = 2.5 + ($this->GetValue("Ladeleistung_Effektiv") / (1.71 * 400)); + else{ + + $maxCurrent = 2.5 + ($this->GetValue("Ladeleistung_Effektiv") / (1.71*400)); } - if ($maxCurrent > $this->ReadPropertyInteger("Max_Current_abs")) - { - $maxCurrent = $this->ReadPropertyInteger("Max_Current_abs"); + if($maxCurrent>$this->ReadPropertyInteger("Max_Current_abs")){ + $maxCurrent = $this->ReadPropertyInteger("Max_Current_abs"); } - $this->SetValue("Max_Current", $maxCurrent); + $this->SetValue("Max_Current", $maxCurrent); } - // Mehtohde zum Umrechnen Leistung/Strom + public function Get_Current_From_Power(bool $is_1_ph, int $power) { - if ($is_1_ph) - { + if ($is_1_ph) { $current = round($power / 230); - } - else - { + } else { $current = round($power / (400 * 1.71)); } + return $current; } - // Methode zum ermitteln aller möglcihen leistungsschritte mit aktuellem Maximalstrom + public function Get_Array_From_Current(bool $is_1_ph, float $current, int $power, bool $timer) { $resultArray = []; - if ($timer) - { + + if ($timer) { // Timer an - if ($power === 0) - { + if ($power === 0) { // power == 0: nur eine 0 zurückgeben $resultArray[] = 0; return $resultArray; + + }else{ + // Schleife wie gehabt + for ($i = (max($this->GetValue("Mindestaldestrom") + 1, 6)); $i <= $current; $i++) { + if ($is_1_ph) { + $resultArray[] = $i * 230; + } else { + $resultArray[] = $i * 400 * 1.71; } - else - { - for ($i = (max($this->GetValue("Mindestaldestrom") + 1, 6));$i <= $current;$i++) - { - if ($is_1_ph) - { - $resultArray[] = $i * 230; - } - else - { - $resultArray[] = $i * 400 * 1.71; - } - } - } - // power > 0: keine 0 am Anfang, Schleife normal durchlaufen - } - else - { - if ($is_1_ph) - { + + } + + // power > 0: keine 0 am Anfang, Schleife normal durchlaufen + } else { + // Timer aus: wie bisher, 0 am Anfang + + if ($is_1_ph) { $resultArray[] = $this->GetValue("Mindestaldestrom") * 230; - } - else - { + } else { $resultArray[] = $this->GetValue("Mindestaldestrom") * 400 * 1.71; } - // Schleife wie gehabt - for ($i = (max($this->GetValue("Mindestaldestrom") + 1, 6));$i <= $current;$i++) - { - if ($is_1_ph) - { - $resultArray[] = $i * 230; - } - else - { - $resultArray[] = $i * 400 * 1.71; - } + + + + // Schleife wie gehabt + for ($i = (max($this->GetValue("Mindestaldestrom") + 1, 6)); $i <= $current; $i++) { + if ($is_1_ph) { + $resultArray[] = $i * 230; + } else { + $resultArray[] = $i * 400 * 1.71; } } +} return $resultArray; } + + + + public function SetAktuelle_Leistung(int $power) { - // Hier eine Leistungsänderung detektieren für Idle und interne Mindestlaufzeiten + // Hier eine Leistungsänderung detektieren für Idle und interne Mindestlaufzeiten $this->CheckIdle($power); - if ($this->GetValue("Aktuelle_Leistung") != $power) - { + if ($this->GetValue("Aktuelle_Leistung") != $power) { $this->SetTimerOn(); } - // Leistung nur ändern wenn aktuell kein Timer aktiv ist - if (($this->GetValue("Aktuelle_Leistung") == 0) && ($power > 0)) - { + + if (($this->GetValue("Aktuelle_Leistung") == 0) && ($power>0)) { $this->SetTimerNullMindestlast($this->ReadPropertyInteger("Ein_Zeit")); } - elseif (($this->GetValue("Aktuelle_Leistung") > 0) && ($power == 0)) - { + elseif(($this->GetValue("Aktuelle_Leistung") > 0) && ($power==0)){ $this->SetTimerNullMindestlast($this->ReadPropertyInteger("Aus_Zeit")); + } + $internalPower = GetValue($this->GetIDForIdent("Aktuelle_Leistung")); + // Aktuelle Leistungsvorgabe setzen - SetValue($this->GetIDForIdent("Aktuelle_Leistung") , $power); - if ($power <= 0) - { - $this->SetValue("Pending_Counter", 0); + SetValue($this->GetIDForIdent("Aktuelle_Leistung"), $power); + if($power <= 0){ + $this->SetValue("Pending_Counter", 0); } - // Bezogene Energie aufintegrieren - $this->SetValue("Bezogene_Energie", ($this->GetValue("Bezogene_Energie") + ($this->GetValue("Aktuelle_Leistung") * ($this->ReadPropertyInteger("Interval") / 3600)))); - if ($power != $internalPower) - { + + $this->SetValue("Bezogene_Energie", ($this->GetValue("Bezogene_Energie") + ($this->GetValue("Aktuelle_Leistung")*($this->ReadPropertyInteger("Interval")/3600)))); + + if ($power != $internalPower) { // Setze die interne Leistungsvorgabe + // Idle für x Zyklen auf false setzen - SetValue($this->GetIDForIdent("Idle") , false); - SetValue($this->GetIDForIdent("IdleCounter") , $this->ReadPropertyInteger("IdleCounterMax")); - } - else - { + SetValue($this->GetIDForIdent("Idle"), false); + SetValue( + $this->GetIDForIdent("IdleCounter"), + $this->ReadPropertyInteger("IdleCounterMax") + ); + } else { // IdleCallCounter herunterzählen, wenn power == interne Leistungsvorgabe $idleCounter = GetValue($this->GetIDForIdent("IdleCounter")); - if ($idleCounter > 0) - { + if ($idleCounter > 0) { $idleCounter--; - $this->SetValue("Pending_Counter", 0); - SetValue($this->GetIDForIdent("IdleCounter") , $idleCounter); - if ($idleCounter == 0) - { - SetValue($this->GetIDForIdent("Idle") , true); + $this->SetValue("Pending_Counter", 0); + SetValue($this->GetIDForIdent("IdleCounter"), $idleCounter); + if ($idleCounter == 0) { + SetValue($this->GetIDForIdent("Idle"), true); } } } + // Ladeleistung setzen $peak = GetValue($this->GetIDForIdent("Peak")); $solarladen = GetValue($this->GetIDForIdent("Solarladen")); $Ladebereit = GetValue($this->GetIDForIdent("Ladebereit")); - if (!$Ladebereit) - { + if (!$Ladebereit) { + $this->sendPowerToStation(0); - } - elseif (!$peak && !$solarladen) - { + + } elseif (!$peak && !$solarladen) { // Wenn weder Peak noch Solarladen aktiv sind, setze Ladeleistung auf MaxLeistung - $this->sendPowerToStation($this->Get_Current_From_Power($this->GetValue("Is_1_ph") , $power)); - } - else - { + $this->sendPowerToStation($this->Get_Current_From_Power($this->GetValue("Is_1_ph"), $power)); + + } else { // Ansonsten setze Ladeleistung auf die aktuelle Leistungsvorgabe (Aktuelle_Leistung) - $this->sendPowerToStation($this->Get_Current_From_Power($this->GetValue("Is_1_ph") , $power)); + $this->sendPowerToStation($this->Get_Current_From_Power($this->GetValue("Is_1_ph"), $power)); } } + // Methode zum Abrufen der aktuellen Daten public function GetCurrentData(bool $Peak) { + // Überprüfen, ob der Timer aktiv ist - if ($this->GetValue("IsTimerActive")) - { + if ($this->GetValue("IsTimerActive")) { // Timer ist aktiv, PowerSteps setzen - $this->SetValue("PowerSteps", json_encode([$this->GetValue("Aktuelle_Leistung") ])); - $this->SetValue("Leistung_Delta", $this->GetValue("Aktuelle_Leistung") - $this->GetValue("Ladeleistung_Effektiv")); - return; - } - else - { + $this->SetValue("PowerSteps", json_encode([$this->GetValue("Aktuelle_Leistung")])); + $this->SetValue("Leistung_Delta", $this->GetValue("Aktuelle_Leistung")-$this->GetValue("Ladeleistung_Effektiv")); + + return; + }else{ $this->SetValue("Leistung_Delta", 0); } + // Aktuelle Properties abrufen $ladebereit = GetValue($this->GetIDForIdent("Ladebereit")); $solarladen = GetValue($this->GetIDForIdent("Solarladen")); + + // Peak-Wert speichern $this->SetValue("Peak", $Peak); + // Array für die Powersteps initialisieren $powerSteps = []; - // Konfiguration des powerSteps-Arrays basierend auf den Properties - if (!$ladebereit || $this->GetValue("Car_is_full")) - { - $powerSteps = [0]; - } - elseif (!$Peak && !$solarladen) - { - $powerSteps = [max($this->Get_Array_From_Current($this->GetValue("Is_1_ph") , $this->GetValue("Max_Current") , $this->GetValue("Aktuelle_Leistung") , $this->GetValue("IsTimerActive_Null_Timer"))) ]; - } - elseif (!$Peak && $solarladen) - { - $powerSteps = $this->Get_Array_From_Current($this->GetValue("Is_1_ph") , $this->GetValue("Max_Current") , $this->GetValue("Aktuelle_Leistung") , $this->GetValue("IsTimerActive_Null_Timer")); - } - elseif ($solarladen && $Peak) - { - if ($is_1_ph) - { - $powerSteps = [$this->GetValue("Mindestaldestrom") * 230]; - } - else - { - $powerSteps = [$this->GetValue("Mindestaldestrom") * 400 * 1.71]; - } - } - else - { - $powerSteps = $this->Get_Array_From_Current($this->GetValue("Is_1_ph") , $this->GetValue("Max_Current") , $this->GetValue("Aktuelle_Leistung") , $this->GetValue("IsTimerActive_Null_Timer")); - } - // PowerSteps in der RegisterVariable speichern - SetValue($this->GetIDForIdent("PowerSteps") , json_encode($powerSteps)); - // Rückgabe der Powersteps - $counter = $this->GetValue("Pending_Counter"); - if ($this->GetValue("Aktuelle_Leistung") > (1.11 * $this->GetValue("Ladeleistung_Effektiv"))) - { - $this->SetValue("Pending_Counter", $counter + 1); - } - elseif (max($this->Get_Array_From_Current($this->GetValue("Is_1_ph") , $this->GetValue("Max_Current") , $this->GetValue("Aktuelle_Leistung") , $this->GetValue("IsTimerActive_Null_Timer"))) < (1.11 * $this->GetValue("Ladeleistung_Effektiv"))) - { // diesen elseif ggf wieder rauslöschen - $this->SetValue("Pending_Counter", $counter + 1); - } - else - { - $this->SetValue("Pending_Counter", 0); - } - if ($counter > (90 / ($this->ReadPropertyInteger("Interval")))) - { - $this->SetValue("Pending_Counter", 0); - if ((max(json_decode($this->GetValue("PowerSteps")))) > 0) - { - if ($this->GetValue("Aktuelle_Leistung") > (1.11 * $this->GetValue("Ladeleistung_Effektiv"))) - { - $this->Calc_Max_Current($this->GetValue("Is_1_ph")); + + // Konfiguration des powerSteps-Arrays basierend auf den Properties + if (!$ladebereit || $this->GetValue("Car_is_full")) { + $powerSteps = [0]; + } elseif (!$Peak && !$solarladen) { + $powerSteps = [max($this->Get_Array_From_Current($this->GetValue("Is_1_ph"),$this->GetValue("Max_Current"), $this->GetValue("Aktuelle_Leistung"), $this->GetValue("IsTimerActive_Null_Timer")))]; + } elseif (!$Peak && $solarladen) { + $powerSteps = $this->Get_Array_From_Current($this->GetValue("Is_1_ph"),$this->GetValue("Max_Current"), $this->GetValue("Aktuelle_Leistung"), $this->GetValue("IsTimerActive_Null_Timer")); + } elseif ($solarladen && $Peak) { + if ($this->GetValue("Is_1_ph")) { + $powerSteps = [$this->GetValue("Mindestaldestrom") * 230]; + } else { + $powerSteps = [$this->GetValue("Mindestaldestrom") * 400 * 1.71]; } + + } else { + $powerSteps = $this->Get_Array_From_Current($this->GetValue("Is_1_ph"),$this->GetValue("Max_Current"), $this->GetValue("Aktuelle_Leistung"), $this->GetValue("IsTimerActive_Null_Timer")); } + + // PowerSteps in der RegisterVariable speichern + SetValue($this->GetIDForIdent("PowerSteps"), json_encode($powerSteps)); + // Rückgabe der Powersteps + if (!$this->UsesDirectStationDetection($this->ReadPropertyInteger("Ladestation"))) { + $counter = $this->GetValue("Pending_Counter"); + + if($this->GetValue("Aktuelle_Leistung")>(1.11*$this->GetValue("Ladeleistung_Effektiv"))){ + $this->SetValue("Pending_Counter", $counter+1); + + }elseif(max($this->Get_Array_From_Current($this->GetValue("Is_1_ph"),$this->GetValue("Max_Current"), $this->GetValue("Aktuelle_Leistung"), $this->GetValue("IsTimerActive_Null_Timer")))<(1.11*$this->GetValue("Ladeleistung_Effektiv"))){ // diesen elseif ggf wieder rauslöschen + $this->SetValue("Pending_Counter", $counter+1); + + } + else{ + + $this->SetValue("Pending_Counter", 0); + + } + + if($counter>(90/($this->ReadPropertyInteger("Interval")))){ + + $this->SetValue("Pending_Counter", 0); + + if((max(json_decode($this->GetValue("PowerSteps")))) >0){ + + if($this->GetValue("Aktuelle_Leistung")>(1.11*$this->GetValue("Ladeleistung_Effektiv"))) { + + $this->Calc_Max_Current($this->GetValue("Is_1_ph")); + + + } + + } + + } + } else { + $this->SetValue("Pending_Counter", 0); } + return $powerSteps; } - // + public function sendPowerToStation(float $value) { $baseUrl = ""; $stationType = $this->ReadPropertyInteger("Ladestation"); - switch ($stationType) - { - case 1: // GO-E alt + + if ($stationType === 5 || $stationType === 6) { + if ( + $stationType === 5 && + $this->ReadPropertyString("Username") != $this->GetValue("Letzer_User") + ) { + return; + } + return $this->SendEaseeCurrentToGateway($value); + } + + switch ($stationType) { + case 1: $baseUrl = "http://" . $this->ReadPropertyString("IP_Adresse") . "/mqtt?payload="; - break; - case 2: // GO-E Gemini + break; + case 2: $baseUrl = "http://" . $this->ReadPropertyString("IP_Adresse") . "/api/set?"; - break; - case 3: // Smart Me Pico + break; + case 3: $baseUrl = "https://api.smart-me.com/pico/loadmanagementgroup/current/" . $this->ReadPropertyString("Seriennummer") . "?current="; - break; - case 4: // Dummy + break; + case 4: // Nichts zu tun für Dummy station return; - case 5: // Easee Solar - // Keine base Url nötig - - break; - case 6: // Easee - // Keine base Url nötig - - break; } - $ch = curl_init(); - IPS_LogMessage("value", "nach konvertierung" . $value); - if ($value == 0) - { - switch ($stationType) - { - case 1: // GO-E alt + + $ch = curl_init(); + if ($value == 0) { + switch ($stationType) { + case 1: $url = $baseUrl . "alw=0"; - break; - case 2: // GO-E Gemini + break; + case 2: $url = $baseUrl . "frc=1&sua=false"; - break; - case 3: // Smart Me Pico + + break; + case 3: $url = $baseUrl . "0"; curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); curl_setopt($ch, CURLOPT_USERPWD, $this->ReadPropertyString("Username") . ":" . $this->ReadPropertyString("Password")); - break; - case 4: // Dummy + break; + case 4: // Nichts zu tun für Dummy station return; - case 5: // Easee Solar - if ($this->ReadPropertyString("Username") != $this->GetValue("Letzer_User")) - { - return; - } - $url = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/commands/set_dynamic_charger_current"; - curl_setopt_array($ch, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "POST", CURLOPT_POSTFIELDS => "{\"amps\":" . $value . ",\"minutes\":0}", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . GetValue($this->ReadPropertyInteger("Token_Easee")) . "", "content-type: application/*+json"], ]); - break; - case 6: // Easee - $url = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/commands/set_dynamic_charger_current"; - curl_setopt_array($ch, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "POST", CURLOPT_POSTFIELDS => "{\"amps\":" . $value . ",\"minutes\":0}", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . $this->GetBuffer("Token_Intern") . "", "content-type: application/*+json"], ]); - break; default: return "Invalid station type."; } @@ -709,113 +1495,69 @@ class Ladestation extends IPSModule $response = curl_exec($ch); curl_close($ch); return $response; - } - elseif ($value >= 1 && $value <= 32) - { - switch ($stationType) - { - case 1: // Go-E Alt + } elseif ($value >= 1 && $value <= 32) { + switch ($stationType) { + case 1: $url1 = $baseUrl . "alw=1"; $url2 = $baseUrl . "amp=$value"; - break; - case 2: // Go-E Gemini + break; + case 2: $url1 = $baseUrl . "frc=2"; $url2 = $baseUrl . "amp=$value"; - break; - case 3: // Pico + break; + case 3: $url2 = $baseUrl . ($value * 1000); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); curl_setopt($ch, CURLOPT_USERPWD, $this->ReadPropertyString("Username") . ":" . $this->ReadPropertyString("Password")); - break; - case 4: //Dummy + break; + case 4: // Nichts zu tun für Dummy station return; - case 5: // Easee solar - if ($this->ReadPropertyString("Username") != $this->GetValue("Letzer_User")) - { - return; - } - $url2 = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/commands/set_dynamic_charger_current"; - curl_setopt_array($ch, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "POST", CURLOPT_POSTFIELDS => "{\"amps\":" . $value . ",\"minutes\":0}", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . GetValue($this->ReadPropertyInteger("Token_Easee")) . "", "content-type: application/*+json"], ]); - break; - case 6: // Easee - $url2 = "https://api.easee.com/api/chargers/" . $this->ReadPropertyString("Seriennummer") . "/commands/set_dynamic_charger_current"; - curl_setopt_array($ch, [CURLOPT_ENCODING => "", CURLOPT_MAXREDIRS => 10, CURLOPT_TIMEOUT => 30, CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1, CURLOPT_CUSTOMREQUEST => "POST", CURLOPT_POSTFIELDS => "{\"amps\":" . $value . ",\"minutes\":0}", CURLOPT_HTTPHEADER => ["Authorization: Bearer " . $this->GetBuffer("Token_Intern") . "", "content-type: application/*+json"], ]); - break; default: return "Invalid station type."; } - if (isset($url1)) - { + + if (isset($url1)) { curl_setopt($ch, CURLOPT_URL, $url1); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); $response1 = curl_exec($ch); - if (curl_errno($ch)) - { + if (curl_errno($ch)) { curl_close($ch); return "Error:" . curl_error($ch); } } + curl_setopt($ch, CURLOPT_URL, $url2); $response2 = curl_exec($ch); - if (curl_errno($ch)) - { + if (curl_errno($ch)) { curl_close($ch); return "Error:" . curl_error($ch); } curl_close($ch); return; - } - else - { + } else { return "Invalid value. Must be between 0 and 32."; } } - // Token für Solarladen Easee neu holen - public function Refresh_Token() - { - $payload = json_encode(['userName' => $this->ReadPropertyString("Username") , 'password' => $this->ReadPropertyString("Password") , ]); - // cURL-Handle initialisieren - $ch = curl_init('https://api.easee.com/api/accounts/login'); - // cURL-Optionen setzen - curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, // Antwort als String zurückgeben - CURLOPT_POST => true, // POST-Methode verwenden - CURLOPT_HTTPHEADER => ['Accept: application/json', 'Content-Type: application/json', ], CURLOPT_POSTFIELDS => $payload, // JSON-Body übergeben - ]); - // Anfrage ausführen und Antwort speichern - $response = curl_exec($ch); - // Auf Fehler prüfen - if ($response === false) - { - echo 'cURL-Fehler: ' . curl_error($ch); - curl_close($ch); - exit; - } - // cURL-Handle schließen - curl_close($ch); - $this->SetBuffer("Token_Intern", (json_decode($response, true) ['accessToken'])); - } - // Intern Idle counter zählen + public function CheckIdle($power) { $lastpower = GetValue($this->GetIDForIdent("Aktuelle_Leistung")); - if ($lastpower != $power) - { + if ($lastpower != $power) { $this->SetValue("Idle", false); - $this->SetValue("IdleCounter", $this->ReadPropertyInteger("IdleCounterMax")); + $this->SetValue("IdleCounter",$this->ReadPropertyInteger("IdleCounterMax")); } // IdleCounter auslesen und verarbeiten $idleCounter = $this->GetValue("IdleCounter"); - if ($idleCounter > 0) - { + if ($idleCounter > 0) { $this->SetValue("Idle", false); $this->SetValue("IdleCounter", $idleCounter - 1); - } - else - { + } else { $this->SetValue("Idle", true); } } + + } ?> diff --git a/Ladestation_v2/README.md b/Ladestation_v2/README.md index 3d25df6..c2c3a82 100644 --- a/Ladestation_v2/README.md +++ b/Ladestation_v2/README.md @@ -36,7 +36,27 @@ Stromvorgaben von 0 bis 32 A werden ebenfalls über das Gateway gesendet. ## Andere Ladestationstypen -Die Typen 1 bis 4 arbeiten unverändert und benötigen kein Easee-Gateway. +Die Typen 1 bis 4 benötigen kein Easee-Gateway. + +### Go-e + +Die Typen 1 und 2 erkennen ein verbundenes Fahrzeug direkt über den +Go-e-Fahrzeugstatus. Die tatsächlich verwendeten Phasen werden aus den drei +gemessenen Strömen des `nrg`-Arrays bestimmt. Der maximale Ladestrom wird durch +die Stations-, Kabel- und Modulgrenze begrenzt. + +### Smart-Me Pico + +Typ 3 erkennt ein verbundenes Fahrzeug über den Pico-Ladestatus. Die +Phasenerkennung verwendet `CurrentL1`, `CurrentL2` und `CurrentL3` des +Smart-Me-Geräte-Endpunkts. Der maximale Stationsstrom wird direkt aus den +Pico-Ladedaten übernommen. + +Bei Typ 1 bis 3 entfällt die zeitbasierte Fahrzeug- und Phasenerkennung über +den `Pending_Counter`. Die Phasenzahl wird aktualisiert, sobald ein messbarer +Ladestrom fließt. Beim Abstecken werden die erkannten Phasen zurückgesetzt. + +Typ 4 bleibt unverändert. ## Einrichtung diff --git a/Ladestation_v2/module.php b/Ladestation_v2/module.php index a4e97f5..5dfe2ea 100644 --- a/Ladestation_v2/module.php +++ b/Ladestation_v2/module.php @@ -486,6 +486,11 @@ class Ladestation_v2 extends IPSModule return $stationType === 5 || $stationType === 6; } + private function UsesDirectStationDetection(int $stationType): bool + { + return in_array($stationType, [1, 2, 3, 5, 6], true); + } + private function ApplyEaseeGatewayResponse($response) { if (!is_array($response)) { @@ -659,6 +664,249 @@ class Ladestation_v2 extends IPSModule } } + private function ReadJsonEndpoint(string $url, bool $useAuthentication = false) + { + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $url); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); + curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5); + curl_setopt($ch, CURLOPT_TIMEOUT, 10); + + if ($useAuthentication) { + curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); + curl_setopt( + $ch, + CURLOPT_USERPWD, + $this->ReadPropertyString("Username") . ":" . + $this->ReadPropertyString("Password") + ); + } + + $response = curl_exec($ch); + $httpCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE); + curl_close($ch); + + if (!is_string($response) || $response === "" || $httpCode >= 400) { + return null; + } + + $data = json_decode($response, true); + return is_array($data) ? $data : null; + } + + private function DetectOnePhaseFromCurrents(array $currents) + { + $activePhases = 0; + $hasMeasurements = false; + + foreach ($currents as $current) { + if (!is_numeric($current)) { + continue; + } + + $hasMeasurements = true; + if (abs((float)$current) >= 1.0) { + $activePhases++; + } + } + + if (!$hasMeasurements || $activePhases === 0) { + return null; + } + + return $activePhases === 1; + } + + private function ApplyDirectStationDetection( + bool $carDetected, + bool $carIsFull, + $isOnePhase, + float $maxCurrent + ): bool { + $wasDetected = $this->GetValue("Car_detected"); + $wasOnePhase = $this->GetValue("Is_1_ph"); + + $this->SetValue("Pending_Counter", 0); + $this->SetValue("Max_Current", $maxCurrent); + + if (!$carDetected) { + $this->SetValue("Car_detected", false); + $this->SetValue("Car_is_full", false); + $this->SetValue("Leistung_Delta", 0); + $this->ResetTimer(); + $this->ResetNullTimer(); + $this->SetValue("Is_1_ph", false); + $this->SetValue("Aktuelle_Leistung", 0); + $this->SetValue("IdleCounter", 0); + $this->SetValue("Idle", true); + return false; + } + + if (is_bool($isOnePhase)) { + $this->SetValue("Is_1_ph", $isOnePhase); + } + + $this->SetValue("Car_detected", true); + $this->SetValue("Car_is_full", $carIsFull); + + $phaseChanged = $wasOnePhase !== $this->GetValue("Is_1_ph"); + if (!$wasDetected || $phaseChanged) { + if ($this->GetValue("Is_1_ph")) { + $power = $this->GetValue("Mindestaldestrom") * 230; + } else { + $power = $this->GetValue("Mindestaldestrom") * 400 * 1.71; + } + $this->SetValue("Power", $power); + } + + return true; + } + + private function GetGoEMaxCurrent(array $data): float + { + $maxCurrent = (float)$this->ReadPropertyInteger("Max_Current_abs"); + + foreach (["ama", "cbl"] as $key) { + if (isset($data[$key]) && is_numeric($data[$key])) { + $candidate = (float)$data[$key]; + if ($candidate >= 6) { + $maxCurrent = min($maxCurrent, $candidate); + } + } + } + + if (isset($data["var"]) && is_numeric($data["var"])) { + $variant = (int)$data["var"]; + if ($variant === 11) { + $maxCurrent = min($maxCurrent, 16); + } elseif ($variant === 22) { + $maxCurrent = min($maxCurrent, 32); + } + } + + return $maxCurrent; + } + + private function DetectGoECar(int $stationType): bool + { + $path = $stationType === 1 ? "/mqtt?payload=" : "/api/status"; + $data = $this->ReadJsonEndpoint( + "http://" . $this->ReadPropertyString("IP_Adresse") . $path + ); + + if (!is_array($data) || !isset($data["car"]) || !is_numeric($data["car"])) { + return $this->GetValue("Car_detected"); + } + + $carState = (int)$data["car"]; + if (!in_array($carState, [1, 2, 3, 4, 5], true)) { + return $this->GetValue("Car_detected"); + } + + $this->SetValue("Fahrzeugstatus", $carState); + + $isOnePhase = null; + if (isset($data["nrg"]) && is_array($data["nrg"])) { + $currentFactor = $stationType === 1 ? 0.1 : 1.0; + $phaseCurrents = []; + foreach ([4, 5, 6] as $index) { + $phaseCurrents[] = isset($data["nrg"][$index]) && + is_numeric($data["nrg"][$index]) + ? (float)$data["nrg"][$index] * $currentFactor + : null; + } + $isOnePhase = $this->DetectOnePhaseFromCurrents($phaseCurrents); + + if (isset($data["nrg"][11]) && is_numeric($data["nrg"][11])) { + $powerFactor = $stationType === 1 ? 10 : 1; + $this->SetValue( + "Ladeleistung_Effektiv", + round((float)$data["nrg"][11] * $powerFactor) + ); + } + } + + return $this->ApplyDirectStationDetection( + in_array($carState, [2, 3, 4, 5], true), + $carState === 4, + $isOnePhase, + $this->GetGoEMaxCurrent($data) + ); + } + + private function DetectSmartMeCar(): bool + { + $deviceID = trim($this->ReadPropertyString("ID")); + if ($deviceID === "") { + return $this->GetValue("Car_detected"); + } + + $chargingData = $this->ReadJsonEndpoint( + "https://api.smart-me.com/pico/charging/" . $deviceID, + true + ); + if (!is_array($chargingData)) { + return $this->GetValue("Car_detected"); + } + + $stateValue = $chargingData["State"] ?? $chargingData["state"] ?? null; + if (!is_numeric($stateValue)) { + return $this->GetValue("Car_detected"); + } + + $stationState = (int)$stateValue; + if (!in_array($stationState, [1, 2, 3, 4, 6], true)) { + return $this->GetValue("Car_detected"); + } + + $this->SetValue("Fahrzeugstatus", $stationState); + + $chargingPower = $chargingData["ActiveChargingPower"] ?? + $chargingData["activeChargingPower"] ?? null; + if (is_numeric($chargingPower)) { + $this->SetValue( + "Ladeleistung_Effektiv", + round((float)$chargingPower * 1000) + ); + } + + $isOnePhase = null; + $deviceData = $this->ReadJsonEndpoint( + "https://api.smart-me.com/Devices/" . $deviceID, + true + ); + if (is_array($deviceData)) { + $phaseCurrents = [ + $deviceData["CurrentL1"] ?? $deviceData["currentL1"] ?? null, + $deviceData["CurrentL2"] ?? $deviceData["currentL2"] ?? null, + $deviceData["CurrentL3"] ?? $deviceData["currentL3"] ?? null, + ]; + $isOnePhase = $this->DetectOnePhaseFromCurrents($phaseCurrents); + } + + $maxCurrent = (float)$this->ReadPropertyInteger("Max_Current_abs"); + foreach ([ + "MaxStationCurrent", + "maxStationCurrent", + "MaxLoadmanagementGroupCurrent", + "maxLoadmanagementGroupCurrent", + ] as $key) { + if (isset($chargingData[$key]) && is_numeric($chargingData[$key])) { + $candidate = (float)$chargingData[$key]; + if ($candidate >= 6) { + $maxCurrent = min($maxCurrent, $candidate); + } + } + } + + return $this->ApplyDirectStationDetection( + in_array($stationState, [2, 3, 4, 6], true), + false, + $isOnePhase, + $maxCurrent + ); + } + private function SendEaseeCurrentToGateway(float $value) { $response = $this->SendEaseeGatewayRequest([ @@ -681,6 +929,14 @@ class Ladestation_v2 extends IPSModule public function Detect_Car(int $carType) { + if ($carType === 1 || $carType === 2) { + return $this->DetectGoECar($carType); + } + + if ($carType === 3) { + return $this->DetectSmartMeCar(); + } + if ($this->UsesEaseeGateway($carType)) { return $this->DetectEaseeCar($carType); } @@ -1143,7 +1399,7 @@ class Ladestation_v2 extends IPSModule // PowerSteps in der RegisterVariable speichern SetValue($this->GetIDForIdent("PowerSteps"), json_encode($powerSteps)); // Rückgabe der Powersteps - if (!$this->UsesEaseeGateway($this->ReadPropertyInteger("Ladestation"))) { + if (!$this->UsesDirectStationDetection($this->ReadPropertyInteger("Ladestation"))) { $counter = $this->GetValue("Pending_Counter"); if($this->GetValue("Aktuelle_Leistung")>(1.11*$this->GetValue("Ladeleistung_Effektiv"))){