[Javascript] Midas (Aquatemp) Poolheizung
-
Kann mir jemand sagen, ob das auch mit dieser WP funktioniert: https://verkauf-bochum.de/products/dc-inverter-pool-warmepumpe-cop-16-17kw
Soweit ich sehe wird die über die TUYA Smart Life APP gesteuert.
Danke
Gruß
-
Eine Registrierung in der App Aqua Temp funktioniert gar nicht mehr. Super.
-
@zeroqool Gute Frage, ich denke aber, dass diese WP nur mit den TUYA-Servern spricht und demnach nicht über Aqua Temp.
Aber die werben ja sogar selbst von einer Home Assistant Integration. Ich glaube, für ioBroker gibt es auch einen guten Adapter für Tuya-Geräte. Hast Du da schonmal geschaut?
-
Nein, noch nicht. Ich stehe nun vor der Frage welche WP ich kaufen soll.
-
@zeroqool Schwierige Frage ... bei den Aquatemp-Modellen aus diesem Thread hier (z. B. InverPro von Poolsana/Midas) läuft es derzeit gut. Bei den Tuyas weiß ich es nicht.
Wenn irgendwie möglich würde ich aber nicht auf Cloud setzen. Da ist mir jedoch auch kein Gerät bekannt
-
Habe ich auch gelesen, aber zum Testen habe ich mir die App heruntergeladen und bei der Registrierung kommt keine Bestätigungsmail an. Steht auch im Apple Store als Rezension das es seit einem Monat nicht mehr geht. Deshalb wäre das wlan Modul beim poolsana Modell nutzlos.
-
@zeroqool Oh ha, das ist krass. Danke für die Info!
Hatte letzten Monat noch ein Zweitkonto angelegt um App und iobroker gleichzeitig nutzen zu können. Da hatte es noch geklappt.
-
Hi !
Ich hab mir nicht den ganzen Thread durch gelesen - bitte verzeiht wenn ich jetzt was schreibe was schon längst bekannt - aber ich hab meine IPS Pro Silent 110 direkt über Tuya Smart eingebunden - also die org. App weg geschmissen und einfach Tuya benutzt.Kommt ziemlich sauber dann über den Tuya Adapter - ich steuere seit 2 Jahren das Ding da drüber - rock stable.
Meine Support Anfrage bei Poolsana war auch "müssen sie über die Platine verkabeln" ... nönönö ... das geht schöner
-
@fog Klingt interessant. Ich bin mir aber nicht sicher, ob das allgemein für alle Modellreihen geht.
Kannst Du beschreiben, wie Du die Registrierung gemacht hast?
Und was meinte Poolsana mit Umlöten? RS485 etwa?
-
@oxident Genau - Support hat mir - nachdem ich gefragt hab ob man die Daten irgendwie online bekommt - geantwortet - Nein ! Nur mit Löten ..8)
Lösung ist Easy - Einfach "Tuya smart" App installieren - und auf "Wärmepumpe hinzufügen" gehen -- dann die Wärmepumpe wie gewohnt in den "Anmelde Modus" bringen (Lange Taste Drücken - siehe Anleitung) - und dann in Tuya einbinden.
Funktionen in der App dann 1:1 das was man auch inder Pool-Sana app bekommt - aber riesen Vorteil -> Mann kann im IOBroker den genialen "Tuya Adapter" benutzen.
Und schon hat man alle Datenpunkte - Lesend und schreibend ...
-
@fog Interessant! Nur zum "Abgleich": Welche App wäre denn für Deine Poolheizung offiziell angeraten? Aquatemp?
-
@oxident Hallo komme den langen Weg von HA auf IoBroker da mein Krone BWP 125-200 den Aquaplus Integration nicht so richtig funktioniert aber deins (V10c) habe ich über Iubuntu auf VM ein IoBroker Server zu testen und dein Script auch, paar kleine Änderungen aber bekomme jetzt erst die wichtigsten Werten aus dem Script.
Ich habe vor on("id", function (){}); updateDeviceSetTemp(device, 54.0) fast ganz unten in script; um den setpoint auf 54 Grad zu setzen aber keine Änderung findet statt und da HA und IoBroker etwas anders ist in paar Sachen wollte ich nur wissen wo mein Gedankenfehler evt. ist.
Generell möchte ich über websock/mqtt (node-red) es so stueren das ich zb in meinem HA die Daten für meinen BBWP die Logik gesteuert aber lasse dein Script auslesen und Input für Änderungen machen lassen.Wie gesagt wollte wissen wenn ich den Funktion updateDeviceSetTemp(device, 54.0); so eingebe sollte den setpoint auf 54 aktiv geändert werden (jetzt ist er auf 55).
Danke
Per -
@europer Bin mir nicht sicher, was Du erreichen willst. Geht es Dir nur darum, die Temperatur einmalig auf 54°C (??) zu setzen?
-
@oxident genau das ich statt über den App jetzt über deinem Script der BBWP auf 54 setpoint zu setzen.
-
@oxident wie gesagt ich würde erst nur den setpoint selber aus einem Logic/Automatisierung von HA oder IoBroker setzen wollen (zb zu nieder Akkuzustand, teuere Tibber Preise, wennig PV Ertrag des Tages, Urlaub den Setpoint runter setzten, genau für "normale" Tage, gute Tage, extra thermische Energie speichern oder Legionella). Deshalb meine Frage wie ich in den Script hier zurück ein Commando sende so dass ich den setpoint ändern kann.
Danke und schöne Grüße aus Norwegen
Per -
@europer Sorry dass ich jetzt nochmal so blöd nachfrage ... aber bist Du sicher, dass Deine BWWP über Aquatemp gesteuert wird? Meiner Meinung nach ist Aquatemp nur für Poolheizungen gemacht worden und Du scheinst eine Wärmepumpe für Warmwasser im Haus zu benutzen.
Ich glaube, Du verwechselst Aquatemp und Aquaplus. Sorry
-
@oxident du hast Recht das eine BBWP ist, der benutz aber der HiTemp App/HiTemp WiFi Modul, kann auch die Parameter mit 022 oder 066 benutzen, ich kann mit deinem Script über den API Abfrage die Daten rauslesen, er findet mein deviceID und Type und Token. Etwas angepasst die Parameter Bezeichnungen, nutzte aber der API Nr 3 von deinem Script. So lesen geht super, will jetzt versuchen den setpoint zu ändern und brauchte hier ein Tips wie, scheint ja sehr identisch zu sein.
Hier ein SS von 066:
Und hier von App selber:
Wie gesagt wir kann ich ein Kommando zurück senden?
Danke PerPS:
Hier die Ergebnisse aus dem auslesen in IoBroker:
und hier bis jetzt der script modifiziert:
// Midas Poolheizung // v0.0.10c // Changelog: // 0.0.10: Weitere Parameter für andere Gerätetypen hinzugefügt // 0.0.8: Testweise Unterstützung von neu registrierten Anlagen // 0.0.7: Kleinigkeiten überarbeitet // weitere Modelle hinzugefügt // 0.0.6: Gültigkeitsprüfung des Zertifikats deaktiviert (Dank an znyde) // Kompatibilität mit Promo Next Modellen durch generische Product-ID (Dank an znyde) // 0.0.5: weitere Abfragewerte hinzugefügt (Kompressor- und Ansaugtemperatur) // 0.0.4: Tokenverfall jetzt 60min nach Skriptstart und nicht zu jeder vollen Stunde (Dank an dering) // 0.0.3: Datenpunkte beim Start automatisch anlegen (Dank an Andy200877) // 0.0.2: Token bei jedem Set-Vorgang prüfen und ggf. neu anfordern (Dank an dering) // ANFANG konfigurierbare Elemente ----- const username = "xxxxxx"; var password = "xxxxxx"; const interval = 30; // Abfrageintervall in Sekunden const dpRoot = "0_userdata.0.BBWP_PMK_V02"; // Stammordner der Datenpunkte const apilevel = 3; // 1: AquaTemp-Accounts, die vor v.1.5.8 erstellt wurden // 2: HiTemp-Accounts // 3: AquaTemp-Accounts, die mit neueren App-Versionen erstellt wurden const debugLevel = 0; // 0: keine erweiterten Informationen protokollieren // 1: Debug-Informationen protokollieren // ENDE -------------------------------- var cloudURL; var token = ""; var tokenRefreshTimer; var device = ""; // ProductIDs: // Gruppe 1: // 1132174963097280512: Midas/Poolsana InverPro const AQUATEMP_POOLSANA = "1132174963097280512"; // Gruppe 2: // 1442284873216843776: //const AQUATEMP_OTHER1="1442284873216843776"; const AQUATEMP_OTHER1 = "1245226668902080512"; var product = ""; var reachable = false; function setupEndpoints() { if (apilevel == 1) { cloudURL = "https://cloud.linked-go.com/cloudservice/api"; } else if (apilevel == 2) { cloudURL = "https://cloud.linked-go.com/cloudservice/api"; } else if (apilevel == 3) { cloudURL = "https://cloud.linked-go.com:449/crmservice/api"; password = require('crypto').createHash('md5').update(password).digest("hex"); } printLog("API-Level " + apilevel, 1); } function clearValues() { saveValue("error", true, "boolean"); saveValue("consumption", 0, "number"); saveValue("state", false, "boolean"); } function saveValue(key, value, sType) { var dp = dpRoot + "." + key; if (!existsState(dp)) { printLog("Schreibe in NEUEN Datenpunkt: " + dp + " - " + value, 1); createState(dp, value, { name: key, type: 'number', role: 'value' }, function() {}); } else { printLog("Schreibe in Datenpunkt: " + dp + " - " + value, 1); setState(dp, value, true); } } function findCodeVal(result, code) { //log(code); printLog("Suche Wert " + code, 1); for (var i = 0; i < result.length; i++) { //log(result[i].code); printLog(result[i].code, 1); if (result[i].code.indexOf(code) >= 0) { printLog("Wert gefunden: " + result[i].value, 1); return result[i].value; } } return ""; } function createobjects() { log("erstelle Objekte"); createState(dpRoot + '.ambient', { read: true, write: false, type: "number", unit: "°C", role: "value.temperature", name: "Umgebungstemperatur" }); createState(dpRoot + '.connection', { read: true, write: false, type: "boolean", role: "state", name: "Verbindung", def: false }); createState(dpRoot + '.error', { read: true, write: false, type: "boolean", role: "state", name: "Fehler", def: false }); createState(dpRoot + '.errorCode', { read: true, write: false, type: "string", name: "Fehlercode", def: "" }); createState(dpRoot + '.errorLevel', { read: true, write: false, type: "number", name: "Fehlerlevel" }); createState(dpRoot + '.errorMessage', { read: true, write: false, type: "string", name: "Fehlermeldung", def: "" }); createState(dpRoot + '.mode', { read: true, write: true, type: "string", states: "-1:off;0:cool;1:heat;2:auto", name: "Modus", def: "" }); createState(dpRoot + '.silent', { read: true, write: true, type: "boolean", role: "state", name: "Silent", def: false }); createState(dpRoot + '.state', { read: true, write: false, type: "boolean", role: "state", name: "Status", def: false }); createState(dpRoot + '.tempIn', { read: true, write: false, type: "number", unit: "°C", role: "value.temperature", name: "Eingangstemperatur" }); createState(dpRoot + '.tempOut', { read: true, write: false, type: "number", unit: "°C", role: "value.temperature", name: "Ausgangstemperatur" }); createState(dpRoot + '.tempSet', { read: true, write: true, type: "number", unit: "°C", role: "level.temperature", name: "Solltemperatur" }); createState(dpRoot + '.suctionTemp', { read: true, write: false, type: "number", unit: "°C", name: "Luftansaugtemperatur" }); createState(dpRoot + '.coilTemp', { read: true, write: false, type: "number", unit: "°C", role: "value.temperature", name: "Kompressortemperatur" }); createState(dpRoot + '.hysterieses', { read: true, write: false, type: "number", unit: "°C", role: "value.temperature", name: "Hysterieses InputTemp" }); createState(dpRoot + '.rawJSON', { read: true, write: false, type: "array", name: "komplette Rückgabe" }); } function updateToken() { if (token == "") { printLog("Token Neuanforderung"); var request = require('request'); var options; if (apilevel < 3) { options = { url: cloudURL + '/app/user/login.json', method: 'POST', json: { "user_name": username, "password": password, "type": "2" }, rejectUnauthorized: false }; } else { options = { url: cloudURL + '/app/user/login', method: 'POST', json: { "userName": username, "password": password, "type": "2" }, rejectUnauthorized: false }; } /* console.log("hier 2"); console.log(options); console.log(JSON.stringify(options)); */ request(options, function(error, response, body) { printLog("Login-Antwort: " + JSON.stringify(response)); if (parseInt(body.error_code) == 0) { if (apilevel < 3) { token = body.object_result["x-token"]; } else { token = body.objectResult["x-token"]; } printLog("Login ok! Token " + token); updateDeviceID(); } else { // Login-Fehler printLog("Login-Fehler in updateToken(): " + response.body); token = ""; saveValue("connection", false, "boolean"); } }); } else { updateDeviceID(); } } function updateDeviceID() { if (token != "") { var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/deviceList.json', headers: { "x-token": token }, body: { "product_ids": [ "1132174963097280512", "1186904563333062656", "1158905952238313472", "1245226668902080512", //mein productID "1442284873216843776", "1548963836789501952", ] }, method: 'POST', json: true, rejectUnauthorized: false }; } else { optionsDev = { url: cloudURL + '/app/device/deviceList', headers: { "x-token": token }, body: { "productIds": [ "1132174963097280512", "1186904563333062656", "1158905952238313472", "1245226668902080512", //mein productID "1442284873216843776", "1548963836789501952", ] }, method: 'POST', json: true, rejectUnauthorized: false }; } var request = require('request'); request(optionsDev, function(error, response, body) { printLog("DeviceList: " + JSON.stringify(response)); console.log("-------------------------------"); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { //token = body.object_result["x-token"]; //log("Login ok! Token " + token); if (apilevel < 3) { device = body.object_result[0].device_code; product = body.object_result[0].product_id; reachable = (body.object_result[0].device_status == "ONLINE"); } else { device = body.objectResult[0].deviceCode; product = body.objectResult[0].productId; reachable = (body.objectResult[0].deviceStatus == "ONLINE"); console.log("DeviceCode: " + device + ", ProductID: " + product + ", DeviceStatus: " + reachable); } printLog("DeviceCode: " + device + ", ProductID: " + product + ", DeviceStatus: " + reachable); if (reachable) { saveValue("connection", true, "boolean"); if (device != "") updateDeviceStatus(device); } else { // offline device = ""; saveValue("connection", false, "boolean"); } } else { // Login-Fehler //log("Fehler in updateDeviceID(): " + response.body, "error"); token = ""; device = ""; reachable = false; saveValue("connection", false, "boolean"); } }); } } function updateDeviceStatus(devicecode) { if (token != "") { console.log("updateDeviceStatus " + "token: " + token); var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/getDeviceStatus.json', headers: { "x-token": token }, json: { "device_code": devicecode }, method: 'POST', rejectUnauthorized: false }; } else { optionsDev = { url: cloudURL + '/app/device/getDeviceStatus', headers: { "x-token": token }, json: { "deviceCode": devicecode }, method: 'POST', rejectUnauthorized: false }; } var request = require('request'); request(optionsDev, function(error, response, body) { printLog("DeviceStatus: " + JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { if (apilevel < 3) { if (body.object_result["is_fault"] == true) { // TODO: Fehlerbeschreibung abrufen //clearValues(); saveValue("error", true, "boolean"); updateDeviceDetails(devicecode); updateDeviceErrorMsg(devicecode); } else { // kein Fehler saveValue("error", false, "boolean"); saveValue("errorMessage", "", "string"); saveValue("errorCode", "", "string"); saveValue("errorLevel", 0, "number"); updateDeviceDetails(devicecode); } } else { if (body.objectResult["is_fault"] == true) { // TODO: Fehlerbeschreibung abrufen //clearValues(); saveValue("error", true, "boolean"); updateDeviceDetails(devicecode); updateDeviceErrorMsg(devicecode); } else { // kein Fehler saveValue("error", false, "boolean"); saveValue("errorMessage", "", "string"); saveValue("errorCode", "", "string"); saveValue("errorLevel", 0, "number"); updateDeviceDetails(devicecode); } } //token = body.object_result["x-token"]; //log("Login ok! Token " + token); } else { // Login-Fehler //log("Fehler in updateDeviceStatus(): " + response.body, "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); } }); } } function updateDeviceErrorMsg(devicecode) { if (token != "") { console.log("updateDeviceErrorMsg " + "token: " + token); var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/getFaultDataByDeviceCode.json', headers: { "x-token": token }, json: { "device_code": devicecode }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } else { optionsDev = { url: cloudURL + '/app/device/getFaultDataByDeviceCode', headers: { "x-token": token }, json: { "deviceCode": devicecode }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } var request = require('request'); request(optionsDev, function(error, response, body) { //log(JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { saveValue("error", true, "boolean"); if (apilevel < 3) { saveValue("errorMessage", body.object_result[0].description, "string"); saveValue("errorCode", body.object_result[0].fault_code, "string"); saveValue("errorLevel", body.object_result[0].error_level, "string"); } else { saveValue("errorMessage", body.objectResult[0].description, "string"); saveValue("errorCode", body.objectResult[0].fault_code, "string"); saveValue("errorLevel", body.objectResult[0].error_level, "string"); } } else { // Login-Fehler //log("Fehler in updateDeviceErrorMsg(): " + response.body, "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); } }); } } function updateDeviceDetails(devicecode) { if (token != "") { console.log("updateDeviceDetails " + "token: " + token); var optionsDev; if (apilevel < 3) { if (product == AQUATEMP_POOLSANA) { optionsDev = { url: cloudURL + '/app/device/getDataByCode.json', headers: { "x-token": token }, json: { "device_code": devicecode, "protocal_codes": [ "Power", "Mode", "Manual-mute", "T01", "T02", "2074", "2075", "2076", "2077", "H03", "Set_Temp", "R08", "R09", "R10", "R11", "R01", "R02", "R03", "T03", "1158", "1159", "F17", "H02", "T04", "T05", "T07", "T14", "T17" ] }, method: 'POST', rejectUnauthorized: false }; } else if (product == AQUATEMP_OTHER1) { console.log("----- get values 03----"); optionsDev = { url: cloudURL + '/app/device/getDataByCode.json', headers: { "x-token": token }, json: { "device_code": devicecode, "protocal_codes": [ "Power", "Mode", "Manual-mute", "O01", "O02", "O03", "O04", "O05", "O06", "O07", "O08", "O09", "T01", "T02", "T03", "T04", "T05", "T06", "T10", "2074", "2075", "2076", "2077", "H03", "R01", "R03", "R04", "R05", "R06", "R07", "R08", "R09", "R10", "R12", "R14", "R15", "R17", "R18", "R19", "R20", "S01", "S03", "S04", "S05", "S06", "H01", "H03", "H07", "1158", "1159" ] }, method: 'POST', rejectUnauthorized: false }; } } else { if (product == AQUATEMP_POOLSANA) { optionsDev = { url: cloudURL + '/app/device/getDataByCode', headers: { "x-token": token }, json: { "deviceCode": devicecode, "protocalCodes": [ "Power", "Mode", "Manual-mute", "T01", "T02", "2074", "2075", "2076", "2077", "H03", "R08", "R09", "R10", "R11", "R01", "R02", "R03", "T03", "1158", "1159", "F17", "H02", "T04", "T05", "T07", "T14", "T17" ] }, method: 'POST', rejectUnauthorized: false }; } else if (product == AQUATEMP_OTHER1) { console.log("---get values ---"); optionsDev = { url: cloudURL + '/app/device/getDataByCode', headers: { "x-token": token }, json: { "deviceCode": devicecode, "protocalCodes": [ "Power", "Mode", "Manual-mute", "O01", "O02", "O03", "O04", "O05", "O06", "O07", "O08", "O09", "T01", "T02", "T03", "T04", "T05", "T06", "T10", "2074", "2075", "2076", "2077", "H03", "Set_Temp", "R01", "R03", "R04", "R05", "R06", "R07", "R08", "R09", "R10", "R12", "R14", "R15", "R17", "R18", "R19", "R20", "S01", "S03", "S04", "S05", "S06", "H01", "H03", "H07", "1158", "1159" ] }, method: 'POST', rejectUnauthorized: false }; } } var request = require('request'); request(optionsDev, function(error, response, body) { printLog("DeviceDetails: " + JSON.stringify(response)); //Main Data JSON from request PMK //console.log("DeviceDetails: " + JSON.stringify(response)); if (parseInt(body.error_code) == 0) { if (apilevel < 3) { saveValue("rawJSON", body.object_result, "string"); if (findCodeVal(body.object_result, "Power") == "1") { if (product == AQUATEMP_POOLSANA) { // Stromverbrauch T07 x T14 in Watt saveValue("consumption", parseFloat(findCodeVal(body.objectResult, "T07")) * parseFloat(findCodeVal(body.objectResult, "T14")), "number"); // Luftansaug-Temperatur T01 saveValue("suctionTemp", parseFloat(findCodeVal(body.object_result, "T01")), "number"); // Inlet-Temperatur T02 saveValue("tempIn", parseFloat(findCodeVal(body.object_result, "T02")), "number"); // outlet-Temperatur T03 saveValue("tempOut", parseFloat(findCodeVal(body.object_result, "T03")), "number"); // Coil-Temperatur T04 saveValue("coilTemp", parseFloat(findCodeVal(body.object_result, "T04")), "number"); // Umgebungs-Temperatur T05 saveValue("ambient", parseFloat(findCodeVal(body.object_result, "T05")), "number"); } else if (product == AQUATEMP_OTHER1) { console.log("---save values 01---"); // Luftansaug-Temperatur T1 saveValue("suctionTemp", parseFloat(findCodeVal(body.object_result, "T05")), "number"); // Inlet-Temperatur T2 saveValue("tempIn", parseFloat(findCodeVal(body.object_result, "T02")), "number"); // outlet-Temperatur T3 saveValue("tempOut", parseFloat(findCodeVal(body.object_result, "T03")), "number"); // Coil-Temperatur T4 saveValue("coilTemp", parseFloat(findCodeVal(body.object_result, "T04")), "number"); // Umgebungs-Temperatur T5 saveValue("ambient", parseFloat(findCodeVal(body.object_result, "T01")), "number"); } } else { saveValue("consumption", 0, "number"); saveValue("rotor", 0, "number"); } // Ziel-Temperatur Set_Temp //saveValue("tempSet", parseFloat(findCodeVal(body.object_result, "Set_Temp")), "number"); // Ziel-Temperatur anhand Modus if (findCodeVal(body.object_result, "Mode") == 1) { // Heiz-Modus (-> R02) saveValue("tempSet", parseFloat(findCodeVal(body.object_result, "R01")), "number"); } else if (findCodeVal(body.object_result, "Mode") == 0) { // Kühl-Modus (-> R01) saveValue("tempSet", parseFloat(findCodeVal(body.object_result, "R01")), "number"); } else if (findCodeVal(body.object_result, "Mode") == 2) { // Auto-Modus (-> R03) saveValue("tempSet", parseFloat(findCodeVal(body.object_result, "R01")), "number"); } // Flüstermodus Manual-mute if (findCodeVal(body.object_result, "Manual-mute") == "1") { saveValue("silent", true, "boolean"); } else { saveValue("silent", false, "boolean"); } // Zustand Power if (findCodeVal(body.object_result, "Power") == "1") { saveValue("state", true, "boolean"); saveValue("mode", findCodeVal(body.object_result, "Mode"), "string"); } else { saveValue("state", false, "boolean"); saveValue("mode", "-1", "string"); } saveValue("connection", true, "boolean"); // Durchlauf ENDE } else { saveValue("rawJSON", body.objectResult, "string"); if (findCodeVal(body.objectResult, "Power") == "1") { if (product == AQUATEMP_POOLSANA) { // Stromverbrauch T07 x T14 in Watt saveValue("consumption", parseFloat(findCodeVal(body.objectResult, "T07")) * parseFloat(findCodeVal(body.objectResult, "T14")), "number"); // Luftansaug-Temperatur T01 saveValue("suctionTemp", parseFloat(findCodeVal(body.objectResult, "T05")), "number"); // Inlet-Temperatur T02 saveValue("tempIn", parseFloat(findCodeVal(body.objectResult, "T02")), "number"); // outlet-Temperatur T03 saveValue("tempOut", parseFloat(findCodeVal(body.objectResult, "T03")), "number"); // Coil-Temperatur T04 saveValue("coilTemp", parseFloat(findCodeVal(body.objectResult, "T04")), "number"); // Umgebungs-Temperatur T05 saveValue("ambient", parseFloat(findCodeVal(body.objectResult, "T01")), "number"); } else if (product == AQUATEMP_OTHER1) { console.log("---save values 02---"); // Luftansaug-Temperatur T1 saveValue("suctionTemp", parseFloat(findCodeVal(body.objectResult, "T01")), "number"); // Inlet-Temperatur T2 saveValue("tempIn", parseFloat(findCodeVal(body.objectResult, "T02")), "number"); // outlet-Temperatur T3 saveValue("tempOut", parseFloat(findCodeVal(body.objectResult, "T03")), "number"); // Coil-Temperatur T4 saveValue("coilTemp", parseFloat(findCodeVal(body.objectResult, "T04")), "number"); // Umgebungs-Temperatur T5 saveValue("ambient", parseFloat(findCodeVal(body.objectResult, "T05")), "number"); // Hysterieses R03 saveValue("hysterieses", parseFloat(findCodeVal(body.objectResult, "R03")), "number"); } } else { saveValue("consumption", 0, "number"); saveValue("rotor", 0, "number"); } // Ziel-Temperatur Set_Temp //saveValue("tempSet", parseFloat(findCodeVal(body.objectResult, "Set_Temp")), "number"); // Ziel-Temperatur anhand Modus if (findCodeVal(body.objectResult, "Mode") == 1) { // Heiz-Modus (-> R02) saveValue("tempSet", parseFloat(findCodeVal(body.objectResult, "R01")), "number"); } else if (findCodeVal(body.objectResult, "Mode") == 0) { // Kühl-Modus (-> R01) saveValue("tempSet", parseFloat(findCodeVal(body.objectResult, "R01")), "number"); } else if (findCodeVal(body.objectResult, "Mode") == 2) { // Auto-Modus (-> R03) saveValue("tempSet", parseFloat(findCodeVal(body.objectResult, "R01")), "number"); } // Flüstermodus Manual-mute if (findCodeVal(body.objectResult, "Manual-mute") == "1") { saveValue("silent", true, "boolean"); } else { saveValue("silent", false, "boolean"); } // Zustand Power if (findCodeVal(body.objectResult, "Power") == "1") { saveValue("state", true, "boolean"); saveValue("mode", findCodeVal(body.objectResult, "Mode"), "string"); } else { saveValue("state", false, "boolean"); saveValue("mode", "-1", "string"); } saveValue("connection", true, "boolean"); // Durchlauf ENDE } } else { // Login-Fehler //log("Fehler in updateDeviceDetails(): " + response.body, "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); } }); } } function updateDevicePower(devicecode, power) { var powerOpt; var powerMode = 2; if (power == -1) { // aus powerOpt = 0; powerMode = -1; } else if (power == 0) { // an und kühlen powerOpt = 1; powerMode = 0; } else if (power == 1) { // an und heizen powerOpt = 1; powerMode = 1; } else if (power == 2) { // an und auto powerOpt = 1; powerMode = 2; } else { log("ungülter Zustand!"); return; } if (token != "") { var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/control.json', headers: { "x-token": token }, json: { "param": [{ "device_code": devicecode, "protocol_code": "Power", "value": powerOpt }] }, method: 'POST', rejectUnauthorized: false }; } else { optionsDev = { url: cloudURL + '/app/device/control', headers: { "x-token": token }, json: { "param": [{ "deviceCode": devicecode, "protocolCode": "Power", "value": powerOpt }] }, method: 'POST', rejectUnauthorized: false }; } var request = require('request'); request(optionsDev, function(error, response, body) { //log(devicecode); //log(JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { saveValue("mode", power, "string"); if (power >= 0) updateDeviceMode(device, power); } else { log("Zustandsänderung fehlgeschlagen!", "error"); } }); } } function updateDeviceMode(devicecode, mode) { if (token != "") { var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/control.json', headers: { "x-token": token }, json: { "param": [{ "device_code": devicecode, "protocol_code": "mode", "value": mode }] }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } else { optionsDev = { url: cloudURL + '/app/device/control', headers: { "x-token": token }, json: { "param": [{ "deviceCode": devicecode, "protocolCode": "mode", "value": mode }] }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } var request = require('request'); request(optionsDev, function(error, response, body) { //log(devicecode); //log(JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { saveValue("mode", mode, "string"); } else { log("Zustandsänderung fehlgeschlagen!", "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); } }); } } function updateDeviceSilent(devicecode, silent) { var silentMode; if (silent) { silentMode = "1"; } else { silentMode = "0"; } if (token != "") { var optionsDev; if (apilevel < 3) { optionsDev = { url: cloudURL + '/app/device/control.json', headers: { "x-token": token }, json: { "param": [{ "device_code": devicecode, "protocol_code": "Manual-mute", "value": silentMode }] }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } else { optionsDev = { url: cloudURL + '/app/device/control', headers: { "x-token": token }, json: { "param": [{ "deviceCode": devicecode, "protocolCode": "Manual-mute", "value": silentMode }] }, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } var request = require('request'); request(optionsDev, function(error, response, body) { //log(devicecode); //log(JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if (parseInt(body.error_code) == 0) { saveValue("silent", silent, "boolean"); } else { log("Zustandsänderung fehlgeschlagen!", "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); } }); } } function updateDeviceSetTemp(devicecode, temperature) { console.log("-----------------updateDeviceSetTemp 1--------------"); var sTemperature = temperature.toString().replace(",", "."); console.log(sTemperature); var sMode = getState(dpRoot + ".mode").val; console.log(sMode); if(sMode=="-1") { //log("Gerät einschalten um Temperatur zu ändern!", 'warn'); return; } else if(sMode=="0") { sMode = "R01"; // Kühlen } else if(sMode=="1") { sMode = "R01"; // Heizen } else if(sMode=="2") { sMode = "R01"; // Auto } console.log("updateDeviceSetTemp 1 für Token: " + token); if(token!="") { console.log("-----------------updateDeviceSetTemp 2--------------"); var optionsDev; if(apilevel<3) { optionsDev = { url: cloudURL + '/app/device/control.json', headers: { "x-token": token }, json: {"param":[{ "device_code": devicecode, "protocol_code": "R01","value": sTemperature },{ "device_code": devicecode, "protocol_code": "R02","value": sTemperature },{ "device_code": devicecode, "protocol_code": "R03","value": sTemperature },{ "device_code": devicecode, "protocol_code": "Set_Temp","value": sTemperature }]}, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } else { console.log("-----------------updateDeviceSetTemp 3--------------"); optionsDev = { url: cloudURL + '/app/device/control', headers: { "x-token": token }, json: {"param":[{ "deviceCode": devicecode, "protocolCode": "R01","value": sTemperature },{ "deviceCode": devicecode, "protocolCode": "R01","value": sTemperature },{ "deviceCode": devicecode, "protocolCode": "R01","value": sTemperature },{ "deviceCode": devicecode, "protocolCode": "Set_Temp","value": sTemperature }]}, method: 'POST', rejectUnauthorized: false //headers: {"content-type": "application/json"}, //charset: 'utf8', //json: true }; } var request = require('request'); request(optionsDev,function (error, response, body){ //log(devicecode); console.log("-----------------updateDeviceSetTemp 4--------------"); console.log(JSON.stringify(response)); //log(JSON.stringify(body.object_result)); if(parseInt(body.error_code)==0) { saveValue("tempSet", temperature, "number"); } else { log("Zustandsänderung fehlgeschlagen!", "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); //log(JSON.stringify(response)); } }); } } function printLog(sMsg, minLevel = 1) { if (debugLevel >= minLevel) { log(sMsg); } } // Beginn des Skripts setupEndpoints(); createobjects(); // DPs anlegen updateToken(); // Zugriffstoken erfragen und aktuelle Werte lesen //console.log("mein token 16.02: "+token); schedule('*/' + interval + ' * * * * *', function() { // regelmäßig Token und Zustand abfragen updateToken(); // gewünschte Änderungen ausführen if (!getState(dpRoot + ".mode").ack) { updateDevicePower(device, getState(dpRoot + ".mode").val); } if (!getState(dpRoot + ".silent").ack) { updateDevicePower(device, getState(dpRoot + ".silent").val); } }); tokenRefreshTimer = setInterval(function() { // Token verfällt nach 60min token = ""; //log("Token nach Intervall verworfen.") updateToken(); }, 3600000); //15.02.2024 von mir /* var dd = "0C7FExxxxxxxxxx"; console.log("mein token 16.02: "+token); console.log("---- updateDeviceSetTemp function abrufen PMK ----"); updateDeviceSetTemp(dd, 50.0); */ on({ id: dpRoot + ".mode", change: "ne", ack: false }, function(obj) { updateToken(); updateDevicePower(device, getState(dpRoot + ".mode").val); }); on({ id: dpRoot + ".silent", change: "ne", ack: false }, function(obj) { updateToken(); updateDeviceSilent(device, getState(dpRoot + ".silent").val); }); on({ id: dpRoot + ".tempSet", change: "ne", ack: false }, function(obj) { updateToken(); updateDeviceSetTemp(device, getState(dpRoot + ".tempSet").val); });und wenn ich hier es so abrufe wird wird aber der Token in den function updateDeviceSetTemp token ="" also hat kein token mehr.
//15.02.2024 von mir /* var dd = "0C7FExxxxxxxxxx"; console.log("mein token 16.02: "+token); console.log("---- updateDeviceSetTemp function abrufen PMK ----"); updateDeviceSetTemp(dd, 50.0); */ -
@europer Okay, abgefahren, dass Krone hier diese Art von Controller benutzt!
Also auf den ersten Blick sieht es leider so aus, als würde der Server die Anforderung einfach abweisen. Der Token wird vom Skript automatisch gelöscht, wenn eine Fehlermeldung kommt.
Du könntest mal testweise die Rückgabe vom Server anzeigen lassen. In meinem Skript ist das in der Nähe der Zeile 1000 (also ganz am Ende der updateDeviceSetTemp-Funktion). Dort die log-Zeile wieder aktivieren:
} else { log("Zustandsänderung fehlgeschlagen!", "error"); token = ""; device = ""; saveValue("connection", false, "boolean"); log(JSON.stringify(response)); } -
@oxident Frage, kann man mit dem Script der Setpoint ändern? Und wie wäre die Abfrage? Lass uns sagen 50 Grad? Oder kann man nur Werte ablesen?
-
@europer Klar kannst Du das. Einfach den DP TempSet ändern. Das Skript macht dann den Rest. Ich empfehle aber, nicht direkt in dieses Skript hier etwas einzubauen sondern lieber ein extra Skript anzulegen.
Aber wie gesagt, für eine Brauchwasserwärmepumpe habe ich es noch nie getestet...
