Panasonic Wärmepumpenmanager, Script / Ideen gesucht

ticaki

{
    "vinfo_rsp_sessionid=4198B670&id=36:6_4_6": "UHR-NZ1 ----- ",
    "vinfo_rsp_sessionid=4198B670&id=35:6_4_5": "keine Störung ",
    "vinfo_rsp_sessionid=4198B670&id=34:6_4_4": "Nennbetrieb NZ1 ",
    "vinfo_rsp_sessionid=4198B670&id=75:2_4_4": "Status",
    "vinfo_rsp_sessionid=4198B670&id=37:6_4_7": "SW-Spei 48.0 °C",
    "vinfo_rsp_sessionid=4198B670&id=38:6_4_8": " 46.0 °C",
    "vinfo_rsp_sessionid=4198B670&id=117:6_6_13": "Ein",
    "vinfo_rsp_sessionid=4198B670&id=55:6_4_3": "SW-NN 48.0 °C",
    "vinfo_rsp_sessionid=4198B670&id=171:6_4_2": "SW-NZ2 48.0 °C",
    "vinfo_rsp_sessionid=4198B670&id=54:6_4_1": "SW-NZ1 48.0 °C"
}

bissle hab ich schon.

sonny

@ticaki

Ach . super, Du ich brauch da aber nur die Daten , die ich oben beschrieben hab, gell, nicht das du dir da zuviel arbeit machst.

Also die Sollwerte (SW) der Nutzungszeiten NZ1,2,3, die Uhrenkanäle "UHR NZ1 usw sind unnotwendig , "Keine Störung" auch nicht .
Weiss nicht ob du da hier lediglich was testest :)
Also den kompletten Manager brauchen wir nicht zu zerrupfen :)

Das kann ich dann eh ummoddeln...
Screenshot 2024-01-13 130047.png

Screenshot 2024-01-13 130143.png

ticaki

@sonny
die Daten einzeln rauszusuchen ist mehr arbeit als das was ich jetzt habe.

Was ich bisher habe ist hier angehangen. Ich bezweifele das es geht, da ich aber die Geräte nicht habe müsste ich jetzt einen test coden auf den ich gerade keine Lust habe :) Versuchs einfach mal aus, wenns geht gut, wenns nicht geht, dann werde ich heute abend oder morgen das testen.

Du musst in der Javascript Instanze einstellung bei Zusätzliche NPM-Module folgendes Eintragen.:html-to-json-parser

Das ist das Typescript:

const ip = '192.168.8.165';
const prefix = '0_userdata.0.test';


const axios = require('axios');
const { HTMLToJSON } = require('html-to-json-parser');

let values: any = {};
async function main() {
    const result = axios(`http://${ip}`);
    if ( result && result.data) {
        for (const r of db) {
            const match = result.data.match(r);
            if (match && Array.isArray(match) && match.length >= 1) {
                const response = await axios(`http://${ip}/${match[0]}`);

                const body = response.data.replace(/\n/gm, '').match(/<body>.*?<\/body>/gm)[0]
                let data
                try {
                    data = await HTMLToJSON(body, false);
                } catch (e) {
                    log(e)
                }
                if (data && data.type == 'body') {
                    let d = data.content;
                    let c = 0;
                    while (c < d.length) {
                        const v = d[c++];
                        if (v.type === 'div') {
                            for (const i of v.content) {
                                if (i.attributes && i.attributes.class == 'dp') {
                                    for (const b of i.content) {
                                        if (b.type) {
                                            let val = b.content.join(' ').match(/ [0-9\.,]+/);
                                            let end = '';
                                            if (!val || isNaN(val.join(''))) val = b.content.join(' ');
                                            else {
                                                end = '_' + b.content.join(' ').replace(val, '');
                                                val = parseFloat(val[0]);
                                            }
                                            values[(b.attributes.href + end).replace(/^.*?sessionid\=[0-9]+\&id\=/, '').replace(/[^_\-/:!#$%&()+=@^{}|~\p{Ll}\p{Lu}\p{Nd}]+/gu, '_')] = val;
                                        }
                                    }
                                }
                            }

                        }
                    }
                }
            }
        }
    }
    for (const id in values) {
        const val = values[id];
        if (!existsState(`${prefix}.${id}`)) await createStateAsync(`${prefix}.${id}`, val, {name: 'no description', role: typeof val === 'string' ? 'text' : 'value', type: typeof val, read: true, write: false})
        await setStateAsync(`${prefix}.${id}`, val, true);
    }
}


const db: RegExp[] = [
    /v107000\.rsp\?sessionid=[0-9]+/,
    /v21\.rsp\?sessionid=[0-9]+/,
    /v50\.rsp\?sessionid=[0-9]+/   
]
main();

EDIT: du könntest nach dem letzten = await axiosnoch ein log(response.data) beim ersten durchlauf einfügen um zu sehen ob die ermittelten Links daten liefern und im log obs die richtigen sind.

EDIT: war noch ein dummer fehler drin - jetzt hab ich doch lust es weiter zu testen. Melde mich wenn fertig

sonny

@ticaki

Danke dir :) - hab einen Ordner "test" bei userdata erstellt.
Das Script eingefügt (Noch ohne dem log(response.data) ), Starten lassen. Gibt folgende Fehler aus :

Screenshot 2024-01-13 141914.png

Vorher hab ich den HTML to json parser in der Javascript instanz hinzugefügt...

ticaki

@sonny

Das ist ein Typescript Typescript Typescript Typescript :P

Hier eine Funktionierende Version, alles was jetzt noch zu testen ist, kann ich nicht testen. Waren noch 2 Fehler drin.

Bildschirmfoto 2024-01-13 um 14.40.19.png

const ip = '192.168.8.165';
const prefix = '0_userdata.0.test'; // wird erstellt oder erweitert bei jedem durchlauf
const channelName = 'My great channel';

const axios = require('axios');
const { HTMLToJSON } = require('html-to-json-parser');

let values: any = {};
async function main() {
    const result = axios(`http://${ip}`);
    if ( result && result.data) {
        for (const r of db) {
            const match = result.data.match(r);
            if (match && Array.isArray(match) && match.length >= 1) {
                log(`http://${ip}/${match[0]}`)
                const response = await axios(`http://${ip}/${match[0]}`);

                const body = response.data.replace(/\n/gm, '').match(/<body>.*?<\/body>/gm)[0]
                let data
                try {
                    data = await HTMLToJSON(body, false);
                } catch (e) {
                    log(e)
                }
                if (data && data.type == 'body') {
                    let d = data.content;
                    let c = 0;
                    while (c < d.length) {
                        const v = d[c++];
                        if (v.type === 'div') {
                            for (const i of v.content) {
                                if (i.attributes && i.attributes.class == 'dp') {
                                    for (const b of i.content) {
                                        if (b.type) {
                                            let val = b.content.join(' ').match(/ [0-9\.,]+/);
                                            let end = '';
                                            if (!val || isNaN(val.join(''))) val = b.content.join(' ');
                                            else {
                                                end = '_' + b.content.join(' ').replace(val, '');
                                                val = parseFloat(val[0]);
                                            }
                                            values[(b.attributes.href + end).replace(/^.*?sessionid\=[0-9A-Z]+\&id\=/, '').replace(/[^_\-/:!#$%&()+=@^{}|~\p{Ll}\p{Lu}\p{Nd}]+/gu, '_')] = val;
                                        }
                                    }
                                }
                            }

                        }
                    }
                }
            }
        }
    }
    for (const id in values) {
        const val = values[id];
        await extendObjectAsync(`${prefix}`,{type: 'channel', common:{name: channelName}});
        if (!existsState(`${prefix}.${id}`)) await createStateAsync(`${prefix}.${id}`, val, {name: 'no description', role: typeof val === 'string' ? 'text' : 'value', type: typeof val, read: true, write: false})
        await setStateAsync(`${prefix}.${id}`, val, true);
    }
}


const db: RegExp[] = [
    /v107000\.rsp\?sessionid=[0-9A-Z]+/,
    /v21\.rsp\?sessionid=[0-9A-Z]+/,
    /v50\.rsp\?sessionid=[0-9A-Z]+/  
]

main();

ticaki

Noch als Hinweis.

Du kannst bei den States den Namen im Objektbrowser vergeben, damit du weißt was was ist. Die werden nicht überschrieben. Den Namen des übergeordenten Channels und auch dessen ID wird im Skript bestimmt und dessen name wird immer vom Skript überschrieben(id ist die 1. Spalte, name die 2. in der Objektansicht)

EDIT: Die Ids werden gegen verbotene chars gecheckt. z.B. 0_userdata.0.test.102:2_2_1_4 findest du im html code wenn du nach 102:2.2.1.4 suchst.

EDIT2: Wenn du das in Intervalen ausführen willst ersetzt das main() in der letzten Zeile durch schedule('* * * * *', main) für jede Minute - schedule('*/10 * * * *', main) für alle 10 Minuten und schedule('1 * * * *', main) für jede Stunde

sonny

@ticaki

Ach ein Type ist das, ach herrje.
Okay, das wurde ausgeführt, ohne Fehler.

Ich hab den Ordner /Userdata/0/test gelöscht.

Soweit ich sehe läuft das Script :) :) :) , Fehler stehen keine Im Log, nur finde ich nirgendwo den Datenordner (leg ich "test" von hand an , bleibt er leer- und lösch ich ihn, sollte er lt. deinem kommentar im code neu erstellt / erweitert werden, was nicht passiert soweit)

Läuft dieses Script mit einem Cron (schedule) ? So alle 60 sekunden automatisch einmal durch ?
LG und danke derweil

ticaki

@sonny
in deinem LOG müssten 3 Einträge mit http:// sein vom skript. Ruf die mal im Browser auf. Falls nicht, füge mal hier das log ein und poste den eintrag:

const result = axios(`http://${ip}`);
log(result.data)
if ( result && result.data) {

sonny

@ticaki

Ne, da seh ich nur das, und das bleibt so (unverändert)
Screenshot 2024-01-13 145527.png

ticaki

@sonny
siehe eedit

sonny

@ticaki

hab das "log (result.data)" im Code hinzugefügt an entsprechender Stelle:
Screenshot 2024-01-13 150154.png

Log selber meldet mir dabei "undefined"

ticaki

@sonny
Sry och ne... hab beim Entfernen der Auskommentierung nach dem Test auch das await gelöscht. moment edit kommt gleich

const ip = '192.168.8.165';
const prefix = '0_userdata.0.test'; // wird erstellt oder erweitert bei jedem durchlauf
const channelName = 'My great channel';

const axios = require('axios');
const { HTMLToJSON } = require('html-to-json-parser');

let values: any = {};
async function main() {
    const result = await axios(`http://${ip}`);
    if ( result && result.data) {
        for (const r of db) {
            const match = result.data.match(r);
            if (match && Array.isArray(match) && match.length >= 1) {
                log(`http://${ip}/${match[0]}`)
                const response = await axios(`http://${ip}/${match[0]}`);

                const body = response.data.replace(/\n/gm, '').match(/<body>.*?<\/body>/gm)[0]
                let data
                try {
                    data = await HTMLToJSON(body, false);
                } catch (e) {
                    log(e)
                }
                if (data && data.type == 'body') {
                    let d = data.content;
                    let c = 0;
                    while (c < d.length) {
                        const v = d[c++];
                        if (v.type === 'div') {
                            for (const i of v.content) {
                                if (i.attributes && i.attributes.class == 'dp') {
                                    for (const b of i.content) {
                                        if (b.type) {
                                            let val = b.content.join(' ').match(/ [0-9\.,]+/);
                                            let end = '';
                                            if (!val || isNaN(val.join(''))) val = b.content.join(' ');
                                            else {
                                                end = '_' + b.content.join(' ').replace(val, '');
                                                val = parseFloat(val[0]);
                                            }
                                            values[(b.attributes.href + end).replace(/^.*?sessionid\=[0-9A-Z]+\&id\=/, '').replace(/[^_\-/:!#$%&()+=@^{}|~\p{Ll}\p{Lu}\p{Nd}]+/gu, '_')] = val;
                                        }
                                    }
                                }
                            }

                        }
                    }
                }
            }
        }
    }
    for (const id in values) {
        const val = values[id];
        await extendObjectAsync(`${prefix}`,{type: 'channel', common:{name: channelName}});
        if (!existsState(`${prefix}.${id}`)) await createStateAsync(`${prefix}.${id}`, val, {name: 'no description', role: typeof val === 'string' ? 'text' : 'value', type: typeof val, read: true, write: false})
        await setStateAsync(`${prefix}.${id}`, val, true);
    }
}


const db: RegExp[] = [
    /v107000\.rsp\?sessionid=[0-9A-Z]+/,
    /v21\.rsp\?sessionid=[0-9A-Z]+/,
    /v50\.rsp\?sessionid=[0-9A-Z]+/  
]

main();

sonny

@ticaki

Bitteschön :
script.js.Statische_Scripte.Wärmepumpe: http://192.168.8.165/v107000.rsp?sessionid=5A5B0295

Eine am Deckel krieg ich aber auch :
Screenshot 2024-01-13 145527.png

ticaki

@sonny

Funktioniert die url in deinem browser?

sonny

@ticaki

Ja, was mich wundert (Mein Computer hat ne andere IP Adresse in meinem Netzwerk als der Iobroker Raspberry, ich müsste normalerweise vom Pumpenmanager nen Tritt in den Hintern bekommen oder eine neue Session ID)

Scheint aber zu funktionieren Siehe:

Screenshot 2024-01-13 151332.png

ticaki

@sonny

Ich füge mal unterschämt viele Debuglog einträge hinzu - 5-10 Minuten

sonny

@ticaki

Ich stell 2 Kaffee in den Raum hier inzwischen !

ticaki

@sonny

Hab den schedule eingebaut, dauert bis zur vollen Minute bevor es durchläuft.

brauche 3 Logeinträge vor dem Fehler.

const ip = '192.168.8.165';
const prefix = '0_userdata.0.test'; // wird erstellt oder erweitert bei jedem durchlauf
const channelName = 'My great channel';
const interval = '* * * * *';
const DEBUG = true


const axios = require('axios');
const { HTMLToJSON } = require('html-to-json-parser');

let values: any = {};
async function main() {
    const result = await axios(`http://${ip}`);
    if ( result && result.data) {
        logDebug(`Get data from http://${ip}`);
        logDebug(``);
        for (const r of db) {
            const match = result.data.match(r);
            if (match && Array.isArray(match) && match.length >= 1) {
                log(`http://${ip}/${match[0]}`)
                const response = await axios(`http://${ip}/${match[0]}`);
                if (response && response.data) {
                    logDebug(`Get data from http://${ip}/${match[0]}`);
                    const body = response.data.replace(/\n/gm, '').match(/<body>.*?<\/body>/gm)[0]
                    let data
                    try {
                        data = await HTMLToJSON(body, false);
                    } catch (e) {
                        log(e)
                    }
                    if (data && data.type == 'body') {
                        logDebug(`Parse data ok, found body`);
                        let d = data.content;
                        for (const c in d) {
                            const v = d[c];
                            if (v.type === 'div') {
                                logDebug(`div found`);
                                for (const i of v.content) {
                                    if (i.attributes && i.attributes.class == 'dp') {
                                        logDebug(`class db found`);
                                        for (const b of i.content) {
                                            if (b.type) {
                                                logDebug(`type ${b.type} found`);
                                                let val = b.content.join(' ').match(/ [0-9\.,]+/);
                                                let end = '';
                                                logDebug(val);
                                                if (!val || isNaN(val.join(''))) val = b.content.join(' ');
                                                else {
                                                    end = '_' + b.content.join(' ').replace(val, '');
                                                    val = parseFloat(val.join(''));
                                                }
                                                values[(b.attributes.href + end).replace(/^.*?sessionid\=[0-9A-Z]+\&id\=/, '').replace(/[^_\-/:!#$%&()+=@^{}|~\p{Ll}\p{Lu}\p{Nd}]+/gu, '_')] = val;
                                            }
                                        }
                                    }
                                }

                            }
                        }
                    } else logDebug(`${data ? 'Parse data ok' : 'Parse data failed!'}, ${data.type == 'body' ? 'body found' : 'body not found'}`);
                } else logDebug(`Don't get data from http://${ip}/${match[0]}`);
            }
        }
    } else logDebug(`Don't get data from http://${ip}`);
    for (const id in values) {
        const val = values[id];
        await extendObjectAsync(`${prefix}`,{type: 'channel', common:{name: channelName}});
        if (!existsState(`${prefix}.${id}`)) await createStateAsync(`${prefix}.${id}`, val, {name: 'no description', role: typeof val === 'string' ? 'text' : 'value', type: typeof val, read: true, write: false})
        await setStateAsync(`${prefix}.${id}`, val, true);
    }
}

function logDebug(l: string): void {
    if (DEBUG) log(l);
}

const db: RegExp[] = [
    /v107000\.rsp\?sessionid=[0-9A-Z]+/,
    /v21\.rsp\?sessionid=[0-9A-Z]+/,
    /v50\.rsp\?sessionid=[0-9A-Z]+/  
]

schedule(interval, main);

sonny

@ticaki

Screenshot 2024-01-13 145527.png

Das kommt raus dabei ...

Hab 4 Durchläufe durch, Session ID ändert sich brav mit (Einmal pro Minute geht sich aus, mehr wie 3 Sitzungen, wo ich nicht wusste wann er die letzte "vergisst" mag er nicht)

Also soweit:
script.js.Statische_Scripte.Wärmepumpe: Get data from http://192.168.8.165/v107000.rsp?sessionid=0417D206

klappt es

ticaki

@sonny

Ja ich weiß wo der Fehler liegt, aber muß rumprobieren wie ich ihn behebe. die Regex kommt mit den Zeilenumbrüchen nicht klar und das entfernen sebiger hat scheinbar nicht geholfen.

const ip = '192.168.8.165';
const prefix = '0_userdata.0.test'; // wird erstellt oder erweitert bei jedem durchlauf
const channelName = 'My great channel';
const interval = '* * * * *';
const DEBUG = true


const axios = require('axios');
const { HTMLToJSON } = require('html-to-json-parser');

let values: any = {};
async function main() {
    const result = await axios(`http://${ip}`);
    if ( result && result.data) {
        logDebug(`Get data from http://${ip}`);
        logDebug(``);
        for (const r of db) {
            const match = result.data.match(r);
            if (match && Array.isArray(match) && match.length >= 1) {
                log(`http://${ip}/${match[0]}`)
                const response = await axios(`http://${ip}/${match[0]}`);
                if (response && response.data) {
                    logDebug(`Get data from http://${ip}/${match[0]}`);
                    let body = response.data.replace(/\n/gm, '').match(/<body>.*?<\/body>/gms)
                    if (body || Array.isArray(body) ) {
                        body = body[0];
                    }
                    if (!body) {
                        log('Regex: Body not found', 'error');
                        continue;
                    }
                    let data
                    try {
                        data = await HTMLToJSON(body, false);
                    } catch (e) {
                        log(e)
                    }
                    if (data && data.type == 'body') {
                        logDebug(`Parse data ok, found body`);
                        let d = data.content;
                        for (const c in d) {
                            const v = d[c];
                            if (v.type === 'div') {
                                logDebug(`div found`);
                                for (const i of v.content) {
                                    if (i.attributes && i.attributes.class == 'dp') {
                                        logDebug(`class db found`);
                                        for (const b of i.content) {
                                            if (b.type) {
                                                logDebug(`type ${b.type} found`);
                                                let val = b.content.join(' ').match(/ [0-9\.,]+/);
                                                let end = '';
                                                logDebug(val);
                                                if (!val || isNaN(val.join(''))) val = b.content.join(' ');
                                                else {
                                                    end = '_' + b.content.join(' ').replace(val, '');
                                                    val = parseFloat(val.join(''));
                                                }
                                                values[(b.attributes.href + end).replace(/^.*?sessionid\=[0-9A-Z]+\&id\=/, '').replace(/[^_\-/:!#$%&()+=@^{}|~\p{Ll}\p{Lu}\p{Nd}]+/gu, '_')] = val;
                                            }
                                        }
                                    }
                                }

                            }
                        }
                    } else logDebug(`${data ? 'Parse data ok' : 'Parse data failed!'}, ${data.type == 'body' ? 'body found' : 'body not found'}`);
                } else logDebug(`Don't get data from http://${ip}/${match[0]}`);
            }
        }
    } else logDebug(`Don't get data from http://${ip}`);
    for (const id in values) {
        const val = values[id];
        await extendObjectAsync(`${prefix}`,{type: 'channel', common:{name: channelName}});
        if (!existsState(`${prefix}.${id}`)) await createStateAsync(`${prefix}.${id}`, val, {name: 'no description', role: typeof val === 'string' ? 'text' : 'value', type: typeof val, read: true, write: false})
        await setStateAsync(`${prefix}.${id}`, val, true);
    }
}

function logDebug(l: string): void {
    if (DEBUG) log(l);
}

const db: RegExp[] = [
    /v107000\.rsp\?sessionid=[0-9A-Z]+/,
    /v21\.rsp\?sessionid=[0-9A-Z]+/,
    /v50\.rsp\?sessionid=[0-9A-Z]+/  
]

schedule(interval, main);

Jetzt gibts nicht mehr den großen Fehler sondern nur noch welche die zeigen das die Regex noch immer nicht funktioniert.

Community Forum

NEWS

Panasonic Wärmepumpenmanager, Script / Ideen gesucht

Support us

672

32.5k

81.6k

1.3m