ecoflow-connector-Script zur dynamischen Leistungsanpassung
-
@karo2204 ist das eine rote oder eine Orange Meldung? Wenn orange müsste es dennoch laufen. Ich guck mir das morgen noch mal an.
-
@waly_de Die Meldung war gelb, aber jetzt bekomme ich solche Meldungen in rot. Habe Dein neustes Script drin von gestern:
at processTimers (node:internal/timers:512:7)
javascript.0
2023-11-05 06:00:17.177 error at listOnTimeout (node:internal/timers:569:17)javascript.0
2023-11-05 06:00:17.177 error at Timeout._onTimeout (/opt/iobroker/node_modules/iobroker.javascript/lib/sandbox.js:2743:34)javascript.0
2023-11-05 06:00:17.177 error at Object.<anonymous> (script.js.Ecoflow-1162:919:9)javascript.0
2023-11-05 06:00:17.176 error at CheckforReconnect (script.js.Ecoflow-1162:1299:9)javascript.0
2023-11-05 06:00:17.176 error at script.js.Ecoflow-1162:921:13javascript.0
2023-11-05 06:00:17.175 error at SetBasePower (script.js.Ecoflow-1162:1925:43)javascript.0
2023-11-05 06:00:17.174 error Error in callback: TypeError: Cannot set properties of undefined (setting 'regulieren') -
@karo2204 oha, da ist was anderes im Busch. Hast Du das Modul in den Quelltext des Hautscriptes eingefügt?
Bitte schau noch mal deine Settings etc durch, ob da nicht irgendwo eine Klammer fehlt. Vielleicht das Script noch einmal neu aufsetzen und die Settings anpassen. -
@waly_de Es ist verrückt. Ich hatte ein paar Adapter für ein Dashboard installiert, diese deinstalliert, aber wohl nicht richtig. Jetzt per CLI deinstalliert und jetzt geht auch Dein Script wieder.....
Drück die Daumen, dass jetzt alles soweit geht! Um 10 Uhr sollte das Script wieder umspringen.
UPDATE: Hat funktioniert. Punkt 10 Uhr hat das Script die Steckdose ausgeschaltet und den Prio-Mode umgeschaltet. Heute Abend um 21 Uhr ist es wieder CHEAP, mal sehen was passiert
-
Hallo @Waly_de
Dein Script funktioniert wirklich super, nur ich hätte noch einen Verbesserungsvorschlag:
Leider schaltet der Prio-Modus nicht immer richtig um. Kann man ins 2. Script (Tibber/Ecoflow) noch etwas einbauen, damit stündlich versucht wird in den “richtigen” Prio-Modus zu schalten?
So entsteht im Moment manchmal ein Kreislauf, d.h. die DM wird über das Stromnetz geladen, gibt aber gleichzeitig wieder Strom ab. Erst wenn ich manuell den Prio-Modus umstelle, läuft alles so wie es soll.
-
Bei mir funktioniert auch alles super, danke für die tolle Arbeit.
Eine Frage:
Wie löst ihr das mit der Darstellung des Solar Ertrages am Tag. Die ecoflow App zeigt diese Werte ja eigentlich an, leider kann ich diese jedoch in den Objekten nicht finden.
Werden die irgendwo ausgelesen durch das Script?Gibt es darüber hinaus eine Möglichkeit alle einzelnen Solarwerte auszuwerten? Also nicht nur die der Powerstreams, sondern auch die einer Delta2max als Beispiel.
Ich würde gerne jeglichen Solar Ertrag summieren und anzeigen.
Hat da jemand einen Tipp? -
Hallo,
erstmal danke an alle die sich hier Gedanken machen und Möglichkeiten schaffen den Mist von EcoFlow sinnvoll zu beschalten. Ich hab seit 2 Wochen versucht die Smartplug´s zum laufen zu bekommen aber die sind Müll. Selbst mit EcoFlow-Support haben die Dinger keine Einfluss auf meine Powerstream...
jetzt hab ichs mit ioBroker versucht
leider sagt der scrpt immer."avascript.0 (2028) script.js.EcoFlow: PowerStream [PowerStream] Batteriestand unter Limit:5% (0%). Limitiere Einspeiseleistung auf: 150W"
obwohl laut Akku halb voll ist.
Woran könnte das liegen?
Ich hab Seriennummer und DM2 im script eingetragen wie es sein soll. -
@guhfy9966 das mach ich nicht in iobroker sondern in Homeassistant. Da ist das ganz einfach. K.A. ob/wie das in iobroker ginge. Iobroker hab ich nur für dieses Script installiert, Homeassistant nutz ich schon seit Jahren…
-
@zedwarrior wirklich DM2 und nicht D2M? schau dir mal die Objekte an die angelegt werden, ob die Sinn ergeben. Ansonsten kannst du das limit bei weniger als 5% ja auch auf 600 oder 800W stellen schon mal.
-
@guhfy9966 du kannst in iobroker den Adapter source analytics nehmen.
Dieser addiert die Wh auf und dann kannst du dir den Zählerstand zb in die influxdb schreiben lassen.
Anschließend kann man dann in Grafana die Werte pro Tag/woche/monat anzeigen lassen.Aber ist jetzt nicht so einfach, wie anscheinend bei homeassistant
Wobei ich die tatsächlichen Werte nicht aus dem EcoFlow Baum nehme, sondern meine energiesteckdose auslese.. das macht es ein Stück einfacher
-
@guhfy9966 sagte in ecoflow-connector-Script zur dynamischen Leistungsanpassung:
Bei mir funktioniert auch alles super, danke für die tolle Arbeit.
Eine Frage:
Wie löst ihr das mit der Darstellung des Solar Ertrages am Tag. Die ecoflow App zeigt diese Werte ja eigentlich an, leider kann ich diese jedoch in den Objekten nicht finden.
Werden die irgendwo ausgelesen durch das Script?Gibt es darüber hinaus eine Möglichkeit alle einzelnen Solarwerte auszuwerten? Also nicht nur die der Powerstreams, sondern auch die einer Delta2max als Beispiel.
Ich würde gerne jeglichen Solar Ertrag summieren und anzeigen.
Hat da jemand einen Tipp?Also ich löse das mit Influxdb 2.0 und grafana. Datenquelle ist der Wert
0_userdata.0.ecoflow.totalPV den ich Protokollieren lasse.
in Grafana sieht das dann so aus:
hier die Abfrage dazu:
from(bucket: "iobroker") |> range(start: -30d, stop: now()) |> filter(fn: (r) => r["_measurement"] == "totalPV" and r["_field"] == "value") |> aggregateWindow(every: 60s, fn: mean, createEmpty: false) |> map(fn: (r) => ({ _time: r._time, _value: r._value / 60000.0 // Umrechnung von Watt in Kilowatt })) |> aggregateWindow(every: 1d, fn: sum, createEmpty: false, location: {zone: "Europe/Berlin", offset: 0h}) // tägliche Summierung in der angegebenen Zeitzone |> map(fn: (r) => ({ _time: r._time, Ertrag: r._value // Dies ist nun die Summe der Energieverbräuche in kWh pro Tag })) |> yield(name: "kWh_pro_Tag")Kommt bei mir ganz gut hin
im Script kannst du ja alle Solarwerte mit den Parametern: AdditionalPower erfassen und in totalPV aufnehmen lassen. Musst nur den Pfad zu dem Zustand in IoBroker angeben.
-
@zedwarrior Das Script ließt den Wert aus dem PowerStream aus, auch wenn du deinen Delta garnicht anlegst. Wird also 0% Angezeigt, stimmt etwas mit der Verbindung PS-Delta nicht.
Guck mal ob du auch 100% den PS mit Eingang 1 der Delta verbunden hast.Ausserdem musst du vielleicht etwas Geduld haben, denn die Werte werden nicht so häufig (vielleicht nur bei Änderung) aktualisiert.
-
@karo2204 sagte in ecoflow-connector-Script zur dynamischen Leistungsanpassung:
Leider schaltet der Prio-Modus nicht immer richtig um. Kann man ins 2. Script (Tibber/Ecoflow) noch etwas einbauen, damit stündlich versucht wird in den “richtigen” Prio-Modus zu schalten?
Kann es sein, das dein PS einfach schläft, wenn der Zeitpunkt zum Umschalten kommt? Meine PS sind nachts vom Netz, folglich lassen sie sich auch nicht Setzen....
-
@waly_de Heute Du könntest recht haben. Gestern Abend war sie “aus” und dann hat die DM angefangen zu laden. Erst sah alles super aus, doch als ich wieder in die App geschaut habe, ging sie wieder in den “Kreislauf”.
Es kann auch sein, dass mein Hue Stecker nicht richtig schaltet, dh. rechtzeitig abschaltet. Muss ich weiter beobachten.
Und ich bekomme noch folgenden Fehler im Log angezeigt:
State value to set for "0_userdata.0.ecoflow.Settings.ConfigData" has to be one of type "string", "number", "boolean" but received type "object" -
@waly_de Hallo Zusammen ist über die neue Smartplug und Powerstream Firmware es sinnvoll herauszufinden wie die Smartplugs von der Leistungseinspeisung ins Haus ausgeschlossen werden?
@waly_de hat es im Script ja eigentlich schon herausgefiltert aber soll ich versuchen diese Befehle herauszufinden oder werden die ggf. benötigt? -
hab eine warnmeldung
20.11.2023, 14:51:41.506 [info ]: javascript.0 (189) Stop script script.js.Ecoflow_1_6 20.11.2023, 14:51:41.507 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Ecoflow MQTT-Client beendet 20.11.2023, 14:51:41.558 [info ]: javascript.0 (189) Start javascript script.js.Ecoflow_1_6 20.11.2023, 14:51:41.574 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: registered 0 subscriptions, 0 schedules, 0 messages, 0 logs and 0 file subscriptions 20.11.2023, 14:51:41.660 [warn ]: javascript.0 (189) at script.js.Ecoflow_1_6:1782:68 20.11.2023, 14:51:41.693 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Verbunden mit dem Ecoflow MQTT-Broker 20.11.2023, 14:52:17.828 [info ]: javascript.0 (189) Stop script script.js.Ecoflow_1_6 20.11.2023, 14:52:17.829 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Ecoflow MQTT-Client beendet 20.11.2023, 14:52:17.876 [info ]: javascript.0 (189) Start javascript script.js.Ecoflow_1_6 20.11.2023, 14:52:17.887 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: registered 0 subscriptions, 0 schedules, 0 messages, 0 logs and 0 file subscriptions 20.11.2023, 14:52:17.985 [warn ]: javascript.0 (189) at script.js.Ecoflow_1_6:1782:68 20.11.2023, 14:52:18.016 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Verbunden mit dem Ecoflow MQTT-Broker 20.11.2023, 14:52:35.119 [info ]: javascript.0 (189) Stop script script.js.Ecoflow_1_6 20.11.2023, 14:52:35.120 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Ecoflow MQTT-Client beendet 20.11.2023, 14:52:47.892 [info ]: javascript.0 (189) Start javascript script.js.Ecoflow_1_6 20.11.2023, 14:52:47.904 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: registered 0 subscriptions, 0 schedules, 0 messages, 0 logs and 0 file subscriptions 20.11.2023, 14:52:48.003 [warn ]: javascript.0 (189) at script.js.Ecoflow_1_6:1782:68 20.11.2023, 14:52:48.037 [info ]: javascript.0 (189) script.js.Ecoflow_1_6: Verbunden mit dem Ecoflow MQTT-Broker -
@aherby Ja klar, gerne.
Geht das jetzt? Ich habe noch immer die alte Software auf der PS. Kann es sein, das die neue Software bisher nur für die 800 W Versionen raus ist? -
@karo2204 sagte in ecoflow-connector-Script zur dynamischen Leistungsanpassung:
@waly_de Heute Du könntest recht haben. Gestern Abend war sie “aus” und dann hat die DM angefangen zu laden. Erst sah alles super aus, doch als ich wieder in die App geschaut habe, ging sie wieder in den “Kreislauf”.
Es kann auch sein, dass mein Hue Stecker nicht richtig schaltet, dh. rechtzeitig abschaltet. Muss ich weiter beobachten.
Und ich bekomme noch folgenden Fehler im Log angezeigt:
State value to set for "0_userdata.0.ecoflow.Settings.ConfigData" has to be one of type "string", "number", "boolean" but received type "object"Mit der neusten Version sollte das nicht mehr passieren.
Alternativ: Suche im Script nach:setStateNE(ConfigData.statesPrefix + ".Settings.ConfigData", (ConfigData))und ersetzte es mit:
setStateNE(ConfigData.statesPrefix + ".Settings.ConfigData", JSON.stringify(ConfigData))Leider hab ich grade andere Baustellen, daher kann ich mich um das Problem mit dem Zusatzscript im Moment nicht kümmern. Mach ich aber bei Gelegenheit....
-
@milchbeck sagte in ecoflow-connector-Script zur dynamischen Leistungsanpassung:
hab eine warnmeldung
Kannst Du bitte mal in das große Protokoll (Menüleistenpunkt) sehen? Da sollte einiges mehr an Information stehen.
Es sieht so aus, als hätte es was mit der Konfiguration zu tun:AdditionalPower: [ { name: "Hoymiles2000", id: "off-mqtt.0.solar.116491437470.0.power" }, ],Guck mal bitte, was Du da eingetragen hast.
-
An die Tibber Nutzer:
ich habe ein Script geschrieben, das die Zählerdaten des Pulse lokal, also ohne den Umweg über die Cloud auslesen und in IoBroker Zustände schreiben kann.
Ich weiß, das es mit der Cloud schon mal Probleme gibt, oder die Werte sehr verzögert ankommen.
Das Script kann bisher nur Zähler auslesen, die die SML-Sprache sprechen. Probier es mal aus, wenn Daten ankommen, aber nicht ausgewertet werden können, meldet Euch bitte mit der genauen Bezeichnung Eures Zählers und einem HexDump der Daten, die der Pulse liefert.
Die stehen dann im Zustand: 0_userdata.0.TibberPulse.SMLDataHEXIm Script muss eigentlich nur das Web-Passwort der Pulse-Bridge eingetragen werden.
Vielleicht muss auch der Host angepasst werden.
Ihr müsst nur die Weboberfläche der Bridge dauerhaft aktivieren.
Wie das geht hat marq24 für seine HomeAssistant Anbindung hier super beschrieben:https://github.com/marq24/ha-tibber-pulse-local
Wenn alles klappt, werden die Zählerdaten alle 2 Sekunden in IOBroker-States geschrieben und Ihr könnt im Script diese Konfiguration angeben:
SmartmeterID: "0_userdata.0.TibberPulse.SML.Power"Hier das Script: (update 21.11.23 18:39)
var TibberConfig = { password: "XXXX-XXXX", statesPrefix: "0_userdata.0.TibberPulse", interval: 2000, host: "tibber-host", } const debug = false const http = require('http'); async function getPulseData(password) { const auth = Buffer.from(`admin:${password}`).toString('base64'); const options = { hostname: TibberConfig.host, path: '/metrics.json?node_id=1', method: 'GET', headers: { 'Authorization': `Basic ${auth}`, 'Host': 'tibber-host', 'lang': 'de-de', 'content-type': 'application/json', 'user-agent': 'okhttp/3.14.9' } }; function httpRequest(options) { return new Promise((resolve, reject) => { const req = http.request(options, res => { let data = ''; res.on('data', chunk => { data += chunk; }); res.on('end', () => { resolve(data); }); }); req.on('error', error => { reject(error); }); req.end(); }); } try { let response = await (httpRequest(options)); return response.replace("$type", "type"); // Gibt das Antwortobjekt zurück } catch (error) { console.error("Ein Fehler bei der Ermittlung der Zugangsdaten ist aufgetreten. Bitte prüfe die Zugangsdaten."); throw error; } } function getDataAsHexString(password) { return new Promise((resolve, reject) => { const auth = Buffer.from(`admin:${password}`).toString('base64'); const options = { hostname: TibberConfig.host, path: '/data.json?node_id=1', headers: { 'Authorization': `Basic ${auth}` } }; http.get(options, res => { const chunks = []; res.on('data', chunk => { chunks.push(chunk); }); res.on('end', () => { const buffer = Buffer.concat(chunks); const hexString = buffer.toString('hex'); resolve(hexString); }); }).on('error', error => { reject(error); }); }); } function isState2(strStatePath, strict = true) { let mSelector; if (strict) { mSelector = $(strStatePath); } else { mSelector = $(strStatePath + "*"); } if (mSelector.length > 0) { return true; } else { return false; } } function isValidUnixTimestampAndConvert(n) { // Typüberprüfung if (typeof n !== 'number') { return false; } // Bereichsüberprüfung (optional) const unixEpoch = 0; // UNIX-Epoch: 1. Januar 1970 const currentTime = Math.floor(Date.now() / 1000); if (n < unixEpoch || n > currentTime) { return false; } // Granularität (optional) if (Math.floor(n) !== n) { return false; } // Konvertiere zu deutschem Zeitformat const date = new Date(n * 1000); const germanTimeFormat = date.toLocaleString('de-DE'); return germanTimeFormat; } function generateAndSyncSub(id, JElements, sub = false, preset = "") { //log("Aufruf:" + JElements) if (!JElements || typeof JElements !== 'object') { log('Ungültige JElements übergeben!: ' + JElements); // return; } for (var JElement in JElements) { var AktVal; if (typeof JElements[JElement] === "object") { if (id === "") { generateAndSyncSub(JElement, JElements[JElement], true, preset); } else { generateAndSyncSub(id + "." + JElement, JElements[JElement], true, preset); } //generateAndSyncSub(id + "." + JElement, JElements[JElement], true, preset); } else { try { if (isState2(preset + "." + id + "." + JElement)) AktVal = getState(preset + "." + id + "." + JElement).val; else AktVal = null } catch (e) { log("Fehler: " + e); // } // Überprüfung für den Elementnamen "timestamp" if (JElement === "timestamp") { const TimeValue = isValidUnixTimestampAndConvert(JElements[JElement]) if (TimeValue) JElements[JElement] = TimeValue; } if (AktVal == null) { createState(preset + "." + id + "." + JElement, JElements[JElement], false); AktVal = JElements[JElement]; } if (AktVal != JElements[JElement]) { if (isState2(preset + "." + id + "." + JElement)) { setState(preset + "." + id + "." + JElement, JElements[JElement], true); } } } } } const obisCodesWithNames = [ { code: "0100100700ff", name: "Power" }, { code: "0100010800ff", name: "Import_total" }, { code: "0100020800ff", name: "Export_total" }, { code: "0100010800ff_in_k", name: "Import_total_(kWh)" }, { code: "0100020800ff_in_k", name: "Export_total_(kWh)" }, { code: "0100240700ff", name: "Power_L1" }, { code: "0100380700ff", name: "Power_L2" }, { code: "01004c0700ff", name: "Power_L3" }, { code: "0100200700ff", name: "Potential_L1" }, { code: "0100340700ff", name: "Potential_L2" }, { code: "0100480700ff", name: "Potential_L3" }, { code: "01001f0700ff", name: "Current_L1" }, { code: "0100330700ff", name: "Current_L2" }, { code: "0100470700ff", name: "Current_L3" }, { code: "01000e0700ff", name: "Net_frequency" }, { code: "0100510701ff", name: "Potential_Phase_deviation_L1/L2" }, { code: "0100510702ff", name: "Potential_Phase_deviation_L1/L3" }, { code: "0100510704ff", name: "Current/Potential_L1_Phase_deviation" }, { code: "010051070fff", name: "Current/Potential_L2_Phase_deviation" }, { code: "010051071aff", name: "Current/Potential_L3_Phase_deviation" } ]; function findObisCodeName(code, obisCodesWithNames) { const found = obisCodesWithNames.find(item => item.code === code); return found ? found.name : "Unbekannt"; } /** * Static lookup table */ const dlmsUnits = [ { code: 0x1, unit: "a", quantity: "time", unitName: "year", siDefinition: "52*7*24*60*60 s" }, { code: 0x2, unit: "mo", quantity: "time", unitName: "month", siDefinition: "31*24*60*60 s" }, { code: 0x3, unit: "wk", quantity: "time", unitName: "week", siDefinition: "7*24*60*60 s" }, { code: 0x4, unit: "d", quantity: "time", unitName: "day", siDefinition: "24*60*60 s" }, { code: 0x5, unit: "h", quantity: "time", unitName: "hour", siDefinition: "60*60 s" }, { code: 0x6, unit: "min.", quantity: "time", unitName: "min", siDefinition: "60 s" }, { code: 0x7, unit: "s", quantity: "time", unitName: "second", siDefinition: "s" }, { code: 0x8, unit: "°", quantity: "phase angle", unitName: "degree", siDefinition: "rad*180/π" }, { code: 0x9, unit: "°C", quantity: "temperature", unitName: "degree celsius", siDefinition: "K-273.15" }, { code: 0xA, unit: "currency", quantity: "local currency", unitName: "", siDefinition: "" }, { code: 0xB, unit: "m", quantity: "length", unitName: "metre", siDefinition: "m" }, { code: 0xC, unit: "m/s", quantity: "speed", unitName: "metre per second", siDefinition: "m/s" }, { code: 0xD, unit: "m³", quantity: "volume", unitName: "cubic metre", siDefinition: "m³" }, { code: 0xE, unit: "m³", quantity: "corrected volume", unitName: "cubic metre", siDefinition: "m³" }, { code: 0xF, unit: "m³/h", quantity: "volume flux", unitName: "cubic metre per hour", siDefinition: "m³/(60*60s)" }, { code: 0x10, unit: "m³/h", quantity: "corrected volume flux", unitName: "cubic metre per hour", siDefinition: "m³/(60*60s)" }, { code: 0x11, unit: "m³/d", quantity: "volume flux", unitName: "cubic metre per day", siDefinition: "m³/(24*60*60s)" }, { code: 0x12, unit: "m³/d", quantity: "corrected volume flux", unitName: "cubic metre per day", siDefinition: "m³/(24*60*60s)" }, { code: 0x13, unit: "l", quantity: "volume", unitName: "litre", siDefinition: "10-3 m³" }, { code: 0x14, unit: "kg", quantity: "mass", unitName: "kilogram", siDefinition: "" }, { code: 0x15, unit: "N", quantity: "force", unitName: "newton", siDefinition: "" }, { code: 0x16, unit: "Nm", quantity: "energy", unitName: "newtonmeter", siDefinition: "J = Nm = Ws" }, { code: 0x17, unit: "Pa", quantity: "pressure", unitName: "pascal", siDefinition: "N/m²" }, { code: 0x18, unit: "bar", quantity: "pressure", unitName: "bar", siDefinition: "10⁵ N/m²" }, { code: 0x19, unit: "J", quantity: "energy", unitName: "joule", siDefinition: "J = Nm = Ws" }, { code: 0x1A, unit: "J/h", quantity: "thermal power", unitName: "joule per hour", siDefinition: "J/(60*60s)" }, { code: 0x1B, unit: "W", quantity: "active power", unitName: "watt", siDefinition: "W = J/s" }, { code: 0x1C, unit: "VA", quantity: "apparent power", unitName: "volt-ampere", siDefinition: "" }, { code: 0x1D, unit: "var", quantity: "reactive power", unitName: "var", siDefinition: "" }, { code: 0x1E, unit: "Wh", quantity: "active energy", unitName: "watt-hour", siDefinition: "W*(60*60s)" }, { code: 0x1F, unit: "VAh", quantity: "apparent energy", unitName: "volt-ampere-hour", siDefinition: "VA*(60*60s)" }, { code: 0x20, unit: "varh", quantity: "reactive energy", unitName: "var-hour", siDefinition: "var*(60*60s)" }, { code: 0x21, unit: "A", quantity: "current", unitName: "ampere", siDefinition: "A" }, { code: 0x22, unit: "C", quantity: "electrical charge", unitName: "coulomb", siDefinition: "C = As" }, { code: 0x23, unit: "V", quantity: "voltage", unitName: "volt", siDefinition: "V" }, { code: 0x24, unit: "V/m", quantity: "electric field strength", unitName: "volt per metre", siDefinition: "" }, { code: 0x25, unit: "F", quantity: "capacitance", unitName: "farad", siDefinition: "C/V = As/V" }, { code: 0x26, unit: "Ω", quantity: "resistance", unitName: "ohm", siDefinition: "Ω = V/A" }, { code: 0x27, unit: "Ωm²/m", quantity: "resistivity", unitName: "Ωm", siDefinition: "" }, { code: 0x28, unit: "Wb", quantity: "magnetic flux", unitName: "weber", siDefinition: "Wb = Vs" }, { code: 0x29, unit: "T", quantity: "magnetic flux density", unitName: "tesla", siDefinition: "Wb/m2" }, { code: 0x2A, unit: "A/m", quantity: "magnetic field strength", unitName: "ampere per metre", siDefinition: "A/m" }, { code: 0x2B, unit: "H", quantity: "inductance", unitName: "henry", siDefinition: "H = Wb/A" }, { code: 0x2C, unit: "Hz", quantity: "frequency", unitName: "hertz", siDefinition: "1/s" }, { code: 0x2D, unit: "1/(Wh)", quantity: "R_W", unitName: "Active energy meter constant or pulse value", siDefinition: "" }, { code: 0x2E, unit: "1/(varh)", quantity: "R_B", unitName: "reactive energy meter constant or pulse value", siDefinition: "" }, { code: 0x2F, unit: "1/(VAh)", quantity: "R_S", unitName: "apparent energy meter constant or pulse value", siDefinition: "" }, { code: 0x30, unit: "V²h", quantity: "volt-squared hour", unitName: "volt-squaredhours", siDefinition: "V²(60*60s)" }, { code: 0x31, unit: "A²h", quantity: "ampere-squared hour", unitName: "ampere-squaredhours", siDefinition: "A²(60*60s)" }, { code: 0x32, unit: "kg/s", quantity: "mass flux", unitName: "kilogram per second", siDefinition: "kg/s" }, { code: 0x33, unit: "S, mho", quantity: "conductance siemens", unitName: "siemens", siDefinition: "1/Ω" }, { code: 0x34, unit: "K", quantity: "temperature", unitName: "kelvin", siDefinition: "" }, { code: 0x35, unit: "1/(V²h)", quantity: "", unitName: "Volt-squared hour meter constant or pulse value", siDefinition: "" }, { code: 0x36, unit: "1/(A²h)", quantity: "", unitName: "Ampere-squared hour meter constant or pulse value", siDefinition: "" }, { code: 0x37, unit: "1/m³", quantity: "R_V", unitName: "meter constant or pulse value (volume)", siDefinition: "" }, { code: 0x38, unit: "%", quantity: "percentage", unitName: "%", siDefinition: "" }, { code: 0x39, unit: "Ah", quantity: "ampere-hours", unitName: "ampere-hour", siDefinition: "" }, { code: 0x3C, unit: "Wh/m³", quantity: "energy per volume", unitName: "", siDefinition: "3,6*103 J/m³" }, { code: 0x3D, unit: "J/m³", quantity: "calorific value, wobbe", unitName: "", siDefinition: "" }, { code: 0x3E, unit: "Mol %", quantity: "molar fraction of", unitName: "mole percent", siDefinition: "Basic gas composition unit" }, { code: 0x3F, unit: "Wh/m³", quantity: "energy per volume", unitName: "", siDefinition: "3,6*103 J/m³" }, { code: 0x40, unit: "(reserved)", quantity: "", unitName: "", siDefinition: "" }, { code: 0x41, unit: "(other)", quantity: "", unitName: "", siDefinition: "" }, { code: 0x42, unit: "(unitless)", quantity: "no unit, unitless, count", unitName: "", siDefinition: "" }, { code: 0x0, unit: "", quantity: "", unitName: "", siDefinition: "stop condition for iterator" } ]; function findDlmsUnitByCode(decimalCode, dlmsUnits) { const found = dlmsUnits.find(item => item.code === decimalCode); return found ? found.unit : ""; } function parseSignedHex(hexStr) { let num = BigInt("0x" + hexStr); let bitLength = hexStr.length * 4; if (bitLength <= 32) { // Behandlung als 32-Bit-Zahl if (num > 0x7FFFFFFF) { num = num - 0x100000000n; } } else { // Behandlung als 64-Bit-Zahl if (num > 0x7FFFFFFFFFFFFFFFn) { num = num - 0x10000000000000000n; } } return Number(num.toString()); } function extractAndParseSMLMessages(transfer) { const messages = transfer.matchAll(/7707(0100[0-9a-fA-F].{5}?ff).{6,14}?([0-9a-fA-F]{2})52([0-9a-fA-F]{2})([0-9a-fA-F]{2})([0-9a-fA-F]{4,16})01(?=7)/g); for (const match of messages) { let result = {} if (debug) console.log('Gesamte Übereinstimmung:' + match[0]); //console.log('Gruppe 1:'+ match[1]); // Der Teil, der dem ersten Klammerausdruck entspricht //console.log('Gruppe 2:'+ match[2]); // Der Teil, der dem zweiten Klammerausdruck entspricht //console.log('Gruppe 3:'+ match[3]); // Der Teil, der dem dritten Klammerausdruck entspricht //console.log('Gruppe 4:'+ match[4]); // Der Teil, der dem dritten Klammerausdruck entspricht //console.log('Gruppe 5:'+ match[5]); // Der Teil, der dem vierten Klammerausdruck entspricht result.name = findObisCodeName(match[1], obisCodesWithNames) result.value = parseSignedHex(match[5]) const decimalCode = parseInt(match[2], 16); result.unit = findDlmsUnitByCode(decimalCode, dlmsUnits) if (match[3].toLowerCase() == "ff") { result.value = result.value / 10 } else if (match[3].toLowerCase() == "fe") { result.value = result.value / 100 } const valId = TibberConfig.statesPrefix + ".SML." + result.name if (isState2(valId)) { setStateAsync(valId, result.value, true) } else { let common = { name: result.name, type: 'mixed', role: 'state', unit: result.unit, read: true, write: true, }; let native = {} createState(valId, result.value, false, common, native); } if (debug) log(JSON.stringify(result)) } } function swapEndianness(hexStr) { const result = []; for (let i = 0; i < hexStr.length; i += 2) { result.unshift(hexStr.substring(i, i + 2)); } return result.join(''); } if (typeof TestData == 'undefined') { getPulseData(TibberConfig.password).then(response => { if (debug) console.log("Bridge Data: " + response); // generateAndSyncSub("Data", JSON.parse(response), false, TibberConfig.statesPrefix) }).catch(error => { console.error(error); }); //jede x Sekunden var intervalID = setInterval(function () { // Daten abrufen und als HEX-String ausgeben getDataAsHexString(TibberConfig.password).then(hexString => { extractAndParseSMLMessages(hexString); if (debug) console.log(hexString); // Gibt die Daten als HEX-String aus if (isState2(TibberConfig.statesPrefix + ".SMLDataHEX")) { setState(TibberConfig.statesPrefix + ".SMLDataHEX", hexString, true) } else { createState(TibberConfig.statesPrefix + ".SMLDataHEX", hexString, false); } }).catch(error => { log('Fehler beim Abrufen der Daten:' + error); }); }, TibberConfig.interval); }else{ const parsedMessages = extractAndParseSMLMessages(TestData); }
