update 27.09.2025 07:42h
Dieses ioBroker-Skript dient zur Steuerung und Überwachung des Zendure-Geräts über dessen lokale HTTP-API.
Kein Hack, dafür wurde die offizielle zenSDK verwendet.
Script hat zwei Hauptfunktionen, die derzeit nicht ohne API gesteuert werden können:
SmartMode - speichern von Parametern in RAM
- Automatisches Abfragen des aktuellen SmartMode-Status (ein/aus).
- Umschalten des SmartMode (1: aktivieren/0: deaktivieren) direkt über einen ioBroker-Datenpunkt.
Empfohlene Einstellung => smartMode:1 (RAM)
MQTT-Verbindung
- Abfragen, ob das Gerät aktuell mit dem konfigurierten MQTT-Broker verbunden ist.
- Aktivieren/Deaktivieren der MQTT-Verbindung direkt über ioBroker.
- Alle Daten werden in 0_userdata.0.zendureApi... abgelegt und sind somit für Visualisierungen, Automatisierungen oder Scripte nutzbar.
Die erforderlichen User- und Gerätedaten sowie Datenpunkte usw. können im Abschnitt "konfiguration" eingestellt werden.
Es gibt 2 scripte:
- mit curl umgesetzt für iobroker auf Linux
- plattformunabhängig für Windows, Linux per GET / POST
beide Scripte erfüllen die gleichen Funktionen.
Anpassungen in der Konfiguration
Oben im Script befinden sich die Variablen, die unbedingt an das Setup angepasst werden müssen:
// Intervalle für Abfragen (Sekunden)
const intervalGet = 60; // sek SmartMode (default, empfohlen)
const intervalMqtt = 300; // sek MQTT-Status (default, ausreichend)
// IP und Seriennummer Zendure Gerät
const IP = "192.168.177.103"; // IP des Zendure Geräts
const SN = "EXXXXXXXXXXXXX0"; // Seriennummer
// MQTT Broker Konfiguration
const mqttBrokerIp = "192.168.50.200"; // IP MQTT Broker und in App eingestellt
const mqttPort = "1883"; // PORT MQTT Broker und in App eingestellt
const mqttUsername = "Daisy"; // MQTT Username
const mqttPassword = "coco"; // MQTT Passwort
Angelegte Datenpunkte
Das Script legt folgende Datenpunkte unter 0_userdata.0.zendureApi... an:
Für smartMode ein/aus:
-
SmartMode (.zendureSmartMode)
-
smartModeInfo → aktueller Status (0 = aus, 1 = an).
-
setSmartMode → setzen des Status (0 oder 1 schreiben).
-
setResult → Rückmeldung ob die Aktion erfolgreich war ("ok"/"error").
-
timestamp → Zeitpunkt der letzten Statusabfrage.
Für MQTT ein/aus:
-
MQTT (.zendureMqttState)
-
mqttConnectInfo → Verbindungsstatus (1 = "MQTT verbunden" / 0 = "MQTT getrennt").
-
setMqttConnect → Verbindung aktivieren/deaktivieren (0 oder 1 schreiben).
-
setMqttConnectResult → Rückmeldung ob die Aktion erfolgreich war ("ok"/"error").
-
mqttTimestamp → Zeitpunkt der letzten Statusabfrage.
Script-Funktion:
Beim Start wird der aktuelle SmartMode-Status und der MQTT-Status sofort abgefragt.
Anschließend erfolgen zyklische Abfragen in den eingestellten Intervallen (intervalGet, intervalMqtt).
Änderungen an den Steuer-Datenpunkten (setSmartMode, setMqttConnect) lösen direkt HTTP-POST-Anfragen an das Zendure-Gerät aus.
Alle Antworten werden verarbeitet und im jeweiligen Result-Datenpunkt (setResult, setMqttConnectResult) gespeichert.
Die Skripte enthalten eine Queue, damit Anfragen nacheinander ausgeführt werden und die Antworten eintreffen können, ohne dass es zu Kollisionen kommt.
Hinweise:
-
Wer meine Arbeit nützlich, gut findet und sich bedanken möchte:
Eine Stimme nach oben für einen nützlichen Beitrag ist für mich mehr als genug. (unten von dem Post hier, neben "Zitieren" gibt es einen Pfeil der nach oben zeigt. Einfach darauf klicken.)
-
Dieser erste Post wurde editiert, damit die Scripte immer gleich auffindbar sind.
Set-Datenpunkte (setSmartMode, setMqttConnect) werden nach dem Schreiben nicht automatisch aktualisiert und sind daher nicht für das Auslesen aktueller Zustände gedacht.
Ist bewusst so umgesetzt, damit dieselben Set-Werte jederzeit erneut geschrieben werden können – auch wenn sie bereits zuvor gesendet wurden.
Beispiel:
setMqttConnect = 1, MQTT wird eingeschaltet.
Wird MQTT anschließend über die Zendure-App oder das Gerät selbst ausgeschaltet, bleibt der Wert in ioBroker trotzdem auf 1.
Dadurch ist es möglich, einfach erneut setMqttConnect = 1 zu setzen, um MQTT wieder zu aktivieren.
Zum reinen Auslesen / Vergleichen der aktuellen Zustände in Blockly/Scripts bitte nur diese Datenpunkte verwenden:
- mqttConnectInfo: 0 = MQTT aus / 1 = MQTT an
- smartModeInfo: 0 = Flash / 1 = RAM
@michi-0 sagte in Zendure SmartMode:1 SolarFlow2400 AC SolarFlow800 ( u. Pro):
Die Umstellung bei MQTT dauert zwar sehr lange (gefühlt mehr als 1 Minute), aber es macht dennoch das was es soll!
Das ist normal und hängt an zwei Stellen:
-
Hauptsächlich Geräteseitig
Wenn du den Schaltbefehl schickst, braucht das Zendure-Gerät ein paar Sekunden, bis es den MQTT-Stack sauber herunterfährt und connected=false meldet. Das ist kein sofortiges "Stecker ziehen", sondern ein geregeltes Disconnect. Beim Einschalten genauso.
-
Scriptseitig (Polling)
Script fragt den Status nur alle intervalMqtt Sekunden ab (default 300s).
Direkt nach dem Verbinden/Trennen, steht da evtl. noch 0, bis das nächste Polling kommt.
Deshalb kann es zusätzlich noch maximal die Länge des Poll-Intervalls dauern, bis die Änderung sichtbar wird.
update 27.09.2025 07:42h
curl - Linux:
// konfiguration
// Intervalle für Abfragen (Sekunden)
const intervalGet = 60; // sek SmartMode (default: 60 sek)
const intervalMqtt = 300; // sek MQTT-Status (default: 300 sek)
// IP und Seriennummer Zendure Gerät
const IP = "192.168.177.103"; // IP des Zendure Geräts
const SN = "EXXXXXXXXXXXXX0"; // Seriennummer
// MQTT Broker Konfiguration
const mqttBrokerIp = "192.168.50.200"; //IP MQTT Broker und in App eingestellt
const mqttPort = 1883; // PORT MQTT Broker und in App eingestellt
const mqttUsername = "Daisy"; // MQTT Username
const mqttPassword = "coco"; // MQTT Passwort
//------------------------------------------------------------------------------------
// Datenpunkte
const dpSmartModeInfo = "0_userdata.0.zendureApi.zendureSmartMode.smartModeInfo";
const dpSetSmartMode = "0_userdata.0.zendureApi.zendureSmartMode.setSmartMode";
const dpSetSmartModeResult = "0_userdata.0.zendureApi.zendureSmartMode.setResult";
const dpTimestamp = "0_userdata.0.zendureApi.zendureSmartMode.timestamp";
const dpMqttConnectInfo = "0_userdata.0.zendureApi.zendureMqttState.mqttConnectInfo";
const dpSetMqttConnect = "0_userdata.0.zendureApi.zendureMqttState.setMqttConnect";
const dpSetMqttConnectResult = "0_userdata.0.zendureApi.zendureMqttState.setMqttConnectResult";
const dpMqttTimestamp = "0_userdata.0.zendureApi.zendureMqttState.mqttTimestamp";
//------------------------------------------------------------------------------------
// const {exec} = require("child_process"); // nur außerhalb von ioBroker-Sandbox nötig
//------------------------------------------------------------------------------------
// Queue curls
const curlQueue = [];
let curlRunning = false;
function runQueue() {
if (curlRunning || curlQueue.length === 0) return;
const task = curlQueue.shift();
curlRunning = true;
exec(task.cmd, (error, stdout, stderr) => {
curlRunning = false;
task.callback(error, stdout, stderr);
runQueue(); // nächste Aufgabe ausführen
});
}
// dp anlegen
createState(dpSmartModeInfo, 0, {
name: "SmartMode Info",
type: "number",
role: "state",
read: true,
write: false,
min: 0,
max: 1
}, () => {});
createState(dpSetSmartMode, 0, {
name: "SmartMode Set",
type: "number",
role: "state",
read: true,
write: true,
min: 0,
max: 1
}, () => {});
createState(dpSetSmartModeResult, "", {
name: "SmartMode Set Result",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpTimestamp, "", {
name: "Timestamp",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpMqttConnectInfo, 0, {
name: "MQTT Connect Info",
type: "number",
role: "state",
read: true,
write: false,
min: 0,
max: 1
}, () => {});
createState(dpSetMqttConnect, 0, {
name: "MQTT Connect Set",
type: "number",
role: "state",
read: true,
write: true,
min: 0,
max: 1
}, () => {});
createState(dpSetMqttConnectResult, "", {
name: "MQTT Connect Result",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpMqttTimestamp, "", {
name: "MQTT Timestamp",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
// Zeitformatierung
function formatTime(ts) {
// ts ist Unix Sekunden
const d = new Date(ts * 1000);
const pad = n => n.toString().padStart(2, "0");
return `${pad(d.getDate())}.${pad(d.getMonth()+1)}.${d.getFullYear().toString().slice(-2)} ${pad(d.getHours())}:${pad(d.getMinutes())}:${pad(d.getSeconds())}`;
}
// smartMode GET
function getReport() {
const cmd = `curl -s "http://${IP}/properties/report"`;
curlQueue.push({
cmd,
callback: (error, stdout, stderr) => {
if (error) { console.error("GET Fehler:", stderr); return; }
try {
const data = JSON.parse(stdout);
if (data && data.timestamp) setState(dpTimestamp, formatTime(data.timestamp), true);
if (data && data.properties && typeof data.properties.smartMode !== "undefined")
setState(dpSmartModeInfo, data.properties.smartMode, true);
} catch (e) { console.error("JSON Parse Fehler:", e); }
}
});
runQueue();
}
// smartMode POST
function setSmartMode(val) {
const payload = `{"sn":"${SN}","properties":{"smartMode":${val}}}`;
const cmd = `curl -s -X POST "http://${IP}/properties/write" -H "Content-Type: application/json" -d '${payload}'`;
curlQueue.push({
cmd,
callback: (error, stdout, stderr) => {
if (error) { console.error("POST Fehler:", stderr); setState(dpSetSmartModeResult, "error", true); return; }
setState(dpSetSmartModeResult, "ok", true);
}
});
runQueue();
}
// MQTT Status GET
function getMqttStatus() {
const cmd = `curl -s -X GET "http://${IP}/rpc?method=HA.Mqtt.GetStatus"`;
curlQueue.push({
cmd,
callback: (error, stdout, stderr) => {
if (error) { console.error("MQTT GET Fehler:", stderr); return; }
try {
const data = JSON.parse(stdout);
const state = data.connected ? 1 : 0; // <--- statt "connected"/"disconnected"
setState(dpMqttConnectInfo, state, true);
setState(dpMqttTimestamp, formatTime(Math.floor(Date.now() / 1000)), true);
} catch (e) { console.error("MQTT JSON Parse Fehler:", e); }
}
});
runQueue();
}
// MQTT POST
function setMqttConnect(val) {
const enable = val ? true : false;
const payload = `{"sn":"${SN}","method":"HA.Mqtt.SetConfig","params":{"config":{"enable":${enable},"server":"${mqttBrokerIp}","port":${mqttPort},"protocol":"mqtt","username":"${mqttUsername}","password":"${mqttPassword}"}}}`;
const cmd = `curl -s -X POST "http://${IP}/rpc" -H "Content-Type: application/json" -d '${payload}'`;
curlQueue.push({
cmd,
callback: (error, stdout, stderr) => {
if (error) { console.error("MQTT POST Fehler:", stderr); setState(dpSetMqttConnectResult, "error", true); return; }
setState(dpSetMqttConnectResult, "ok", true);
}
});
runQueue();
}
// Intervalle starten
getReport(); // sofort smartMode
getMqttStatus(); // sofort MQTT
setInterval(getReport, intervalGet * 1000);
setInterval(getMqttStatus, intervalMqtt * 1000);
// Trigger SmartMode
on({id: dpSetSmartMode, ack: false}, obj => {
const val = parseInt(obj.state.val, 10);
if (val === 0 || val === 1) setSmartMode(val);
});
// Trigger MQTT Connect
on({id: dpSetMqttConnect, ack: false}, obj => {
const val = parseInt(obj.state.val, 10);
if (val === 0 || val === 1) setMqttConnect(val);
});
update 27.09.2025 07:42h
plattformunabhängig - Linux, Windows...
// konfiguration
// Intervalle für Abfragen (Sekunden)
const intervalGet = 60; // sek SmartMode (default: 60 sek)
const intervalMqtt = 300; // sek MQTT-Status (default: 300 sek)
// IP und Seriennummer Zendure Gerät
const IP = "192.168.177.103"; // IP des Zendure Geräts
const SN = "EXXXXXXXXXXXXX0"; // Seriennummer
// MQTT Broker Konfiguration
const mqttBrokerIp = "192.168.50.200"; // IP MQTT Broker und in App eingestellt
const mqttPort = 1883; // PORT MQTT Broker und in App eingestellt
const mqttUsername = "Daisy"; // MQTT Username
const mqttPassword = "coco"; // MQTT Passwort
//------------------------------------------------------------------------------------
// Datenpunkte
const dpSmartModeInfo = "0_userdata.0.zendureApi.zendureSmartMode.smartModeInfo";
const dpSetSmartMode = "0_userdata.0.zendureApi.zendureSmartMode.setSmartMode";
const dpSetSmartModeResult = "0_userdata.0.zendureApi.zendureSmartMode.setResult";
const dpTimestamp = "0_userdata.0.zendureApi.zendureSmartMode.timestamp";
const dpMqttConnectInfo = "0_userdata.0.zendureApi.zendureMqttState.mqttConnectInfo";
const dpSetMqttConnect = "0_userdata.0.zendureApi.zendureMqttState.setMqttConnect";
const dpSetMqttConnectResult = "0_userdata.0.zendureApi.zendureMqttState.setMqttConnectResult";
const dpMqttTimestamp = "0_userdata.0.zendureApi.zendureMqttState.mqttTimestamp";
//------------------------------------------------------------------------------------
const http = require("http"); // Node.js http Standardmodul
//------------------------------------------------------------------------------------
// Queue HTTP
const curlQueue = [];
let curlRunning = false;
function runQueue() {
if (curlRunning || curlQueue.length === 0) return;
const task = curlQueue.shift();
curlRunning = true;
task.fn(() => {
curlRunning = false;
runQueue();
});
}
// dp anlegen
createState(dpSmartModeInfo, 0, {
name: "SmartMode Info",
type: "number",
role: "state",
read: true,
write: false,
min: 0,
max: 1
}, () => {});
createState(dpSetSmartMode, 0, {
name: "SmartMode Set",
type: "number",
role: "state",
read: true,
write: true,
min: 0,
max: 1
}, () => {});
createState(dpSetSmartModeResult, "", {
name: "SmartMode Set Result",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpTimestamp, "", {
name: "Timestamp",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpMqttConnectInfo, 0, {
name: "MQTT Connect Info",
type: "number", // <--- statt "string"
role: "state",
read: true,
write: false,
min: 0,
max: 1
}, () => {});
createState(dpSetMqttConnect, 0, {
name: "MQTT Connect Set",
type: "number",
role: "state",
read: true,
write: true,
min: 0,
max: 1
}, () => {});
createState(dpSetMqttConnectResult, "", {
name: "MQTT Connect Result",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
createState(dpMqttTimestamp, "", {
name: "MQTT Timestamp",
type: "string",
role: "info",
read: true,
write: false
}, () => {});
// Zeitformatierung
function formatTime(ts) {
// ts unix sek
const d = new Date(ts * 1000);
const pad = n => n.toString().padStart(2, "0");
return `${pad(d.getDate())}.${pad(d.getMonth()+1)}.${d.getFullYear().toString().slice(-2)} ${pad(d.getHours())}:${pad(d.getMinutes())}:${pad(d.getSeconds())}`;
}
// SmartMode GET
function getReport() {
curlQueue.push({
fn: done => {
const options = {
hostname: IP,
port: 80,
path: "/properties/report",
method: "GET",
timeout: 3000
};
const req = http.request(options, res => {
let data = "";
res.on("data", chunk => data += chunk);
res.on("end", () => {
try {
const json = JSON.parse(data);
if (json.timestamp) setState(dpTimestamp, formatTime(json.timestamp), true);
if (json.properties && typeof json.properties.smartMode !== "undefined") setState(dpSmartModeInfo, json.properties.smartMode, true);
} catch (e) { console.error("GET JSON Parse Fehler:", e); }
done();
});
});
req.on("error", err => { console.error("HTTP GET Fehler:", err.message); done(); });
req.end();
}
});
runQueue();
}
// SmartMode POST
function setSmartMode(val) {
curlQueue.push({
fn: done => {
const payload = JSON.stringify({sn: SN, properties: {smartMode: val}});
const options = {hostname: IP, port: 80, path: "/properties/write", method: "POST", headers: {"Content-Type":"application/json","Content-Length":Buffer.byteLength(payload)}, timeout:3000};
const req = http.request(options, res => {
let data = "";
res.on("data", chunk => data += chunk);
res.on("end", () => {
if (res.statusCode >= 200 && res.statusCode < 300) setState(dpSetSmartModeResult, "ok", true);
else { console.error("POST Antwort:", res.statusCode, data); setState(dpSetSmartModeResult, "error", true); }
done();
});
});
req.on("error", err => { console.error("HTTP POST Fehler:", err.message); setState(dpSetSmartModeResult, "error", true); done(); });
req.write(payload);
req.end();
}
});
runQueue();
}
// MQTT Status GET
function getMqttStatus() {
curlQueue.push({
fn: done => {
const options = {hostname: IP, port: 80, path: "/rpc?method=HA.Mqtt.GetStatus", method: "GET", timeout: 3000};
const req = http.request(options, res => {
let data = "";
res.on("data", chunk => data += chunk);
res.on("end", () => {
try {
const json = JSON.parse(data);
const state = json.connected ? 1 : 0;
setState(dpMqttConnectInfo, state, true);
setState(dpMqttTimestamp, formatTime(Math.floor(Date.now()/1000)), true);
} catch (e) { console.error("MQTT JSON Parse Fehler:", e); }
done();
});
});
req.on("error", err => { console.error("HTTP MQTT GET Fehler:", err.message); done(); });
req.end();
}
});
runQueue();
}
// MQTT POST
function setMqttConnect(val) {
curlQueue.push({
fn: done => {
const enable = val ? true : false;
const payload = JSON.stringify({sn: SN, method:"HA.Mqtt.SetConfig", params:{config:{enable:enable,server:mqttBrokerIp,port:mqttPort,protocol:"mqtt",username:mqttUsername,password:mqttPassword}}});
const options = {hostname: IP, port: 80, path: "/rpc", method: "POST", headers: {"Content-Type":"application/json","Content-Length":Buffer.byteLength(payload)}, timeout:3000};
const req = http.request(options, res => {
let data = "";
res.on("data", chunk => data += chunk);
res.on("end", () => {
if (res.statusCode >= 200 && res.statusCode < 300) setState(dpSetMqttConnectResult, "ok", true);
else { console.error("MQTT POST Antwort:", res.statusCode, data); setState(dpSetMqttConnectResult, "error", true); }
done();
});
});
req.on("error", err => { console.error("HTTP MQTT POST Fehler:", err.message); setState(dpSetMqttConnectResult, "error", true); done(); });
req.write(payload);
req.end();
}
});
runQueue();
}
// Intervalle starten
getReport(); // sofort SmartMode
getMqttStatus(); // sofort MQTT
setInterval(getReport, intervalGet*1000);
setInterval(getMqttStatus, intervalMqtt*1000);
// Trigger SmartMode
on({id: dpSetSmartMode, ack:false}, obj => {
const val = parseInt(obj.state.val,10);
if(val===0||val===1) setSmartMode(val);
});
// Trigger MQTT Connect
on({id: dpSetMqttConnect, ack:false}, obj => {
const val = parseInt(obj.state.val,10);
if(val===0||val===1) setMqttConnect(val);
});
Auch mir fehlt Zeit und habe kein solches Gerät.
Versuche mal ein wenig zu helfen.
Habe mir die zenSDK kurz angeschaut.
Müsste mit einem script umsetzbar sein.
Am schnellsten wenn
- iobroker unter Linux installiert ist
- ip vom Zendure-Gerät schon bekannt ist (sieht man im Router/Fritzbox)
- und wenn ein Standardport von Zendure für http verwendet wird.
Oft 80, 8080 oder 49155, 8000, 3000, 5000, 8888.
Wenn natürlich mDNS/Avahi/Bonjour vorhanden ist, dann würde Port & Hostname direkt angezeigt werden -> sauberste Methode.
Die Seriennummer (sn) müsste von den Datenpunkten bekannt sein, wenn man über die App MQTT konfiguriert hat und auch über den mqtt-Adapter verwendet.
Node.js hat eingebaute Module, die HTTP-Requests machen können, z. B. http oder https.
Damit müsste ein script laufen, das den smartMode:1 setzt und im log sieht man ob es funktioniert hat.
Ob smartMode:1 ständig gesetzt bleibt, weiß ich nicht.
Dazu habe ich auf die Schnelle nichts gefunden.
Beim Hub2000 ist das so und funktioniert.
Hier mal ein Beispiel-js-script, das bei bekannter IP und port, den smartMode:1 setzten sollte:
const http = require('http');
const deviceIP = "192.168.50.123"; // hier richtige Zendure-IP eintragen
const deviceSN = "WOB1NHMAMXXXXX3"; // hier richtige Zendure-sn eintragen
const data = JSON.stringify({
sn: deviceSN,
properties: { smartMode: 1 }
});
const options = {
hostname: deviceIP,
port: 80, // hier richtigen Zendure HTTP-Port eintragen
path: '/properties/write',
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Content-Length': data.length
}
};
const req = http.request(options, (res) => {
let body = '';
res.on('data', chunk => body += chunk);
res.on('end', () => {
log("POST erfolgreich: " + body); // iob-Log
console.log("POST erfolgreich:", body); // Konsolen-Log
});
});
req.on('error', (err) => {
log("Fehler beim POST: " + err.message);
console.error("Fehler beim POST:", err.message);
});
req.write(data);
req.end();
