Automatischer Adapter Neustart

darkiop

Hallo, ich brauche um die Daten einer Heizungs WebUI zu regelmäßig parsen die Möglichkeit den Adapter nach X Minuten neu starten zu lassen. Manuell über die Experteneinstellungen als Workaround ist das kein Problem. Der Adapter selbst läuft als 'daemon' da er u.A. auch Objekte überwacht und reagiert.

Wie kann ich dem Adapter mitgeben nach X Minuten function xyz aufzurufen? Die Zeit hätte ich gerne Einstellbar in den Adapter Optionen.

Hier der betroffene Adapter:

https://github.com/darkiop/ioBroker.stiebel-lwz

apollon77

setTimeout nutzen wenn alles fertig verarbeitet ist.

Gesendet vom Handy …

darkiop

Hallo Ingo, das hatte ich:

https://github.com/darkiop/ioBroker.sti … a3888e3818

Wenn ich mode=schedule mit schedule="* * * * *" nutze reagiert der Adapter aktuell nicht auf Objekt-Änderungen.

darkiop

Wenn ich den Adapter nicht stoppe, bekomme ich das hier statt einem restart:

2018-08-02 21:59:00.002  - warn: host.zeus-vm-iobroker instance system.adapter.stiebel-lwz.0 already running with pid 8524

So funktioniert es jetzt wie es soll - wieder eine Baustelle weniger Danke! Die anderen gehe ich demnächst auch noch an.

    setTimeout(function () {
        getISGwebParameters();
        adapter.stop();
    }, 10000);

Edit: Gibt es eine Möglichkeit die Zeit aus schedule in der io-package.json parametrierbar zu machen?

apollon77

Warum willst du stoppen?

Bauenden teil der Daten ließt in eineneigene funktion und die rufst du dann per setTimeout wieder auf.

Gesendet vom Handy …

apollon77

Ich dachte du hast daemon also Modus? Warum dann Adapter.stop()?!

Gesendet vom Handy …

darkiop

Ok, das wars. Wird nun alle N Sekunden aktualisiert.

/* jshint -W097 */ // jshint strict:false
/*jslint node: true */
'use strict';

var utils = require(__dirname + '/lib/utils'); // Get common adapter utils
var adapter = new utils.Adapter('stiebel-lwz');

// is called when adapter shuts down - callback has to be called under any circumstances!
adapter.on('unload', function (callback) {
    try {
        adapter.log.info('cleaned everything up...');
        callback();
    } catch (e) {
        callback();
    }
});

// is called if a subscribed object changes
adapter.on('objectChange', function (id, obj) {
    // Warning, obj can be null if it was deleted
    adapter.log.info('objectChange ' + id + ' ' + JSON.stringify(obj));
});

// SENDE DATEN AN ISG
adapter.on('stateChange', function (id, state) {

    // Debug Ausgabe im Log
    const debugging = adapter.config.debugging;

    // Warning, state can be null if it was deleted
    //adapter.log.info('stateChange ' + id + ' ' + JSON.stringify(state));

    /**
     * SENDE PARAMETER AN ISG
     */

    // https://nodejs.org/api/child_process.html
    const {exec} = require('child_process');

    // Sende Parameter an ISGweb
    var parameter, wert;
    function set_isg_para(isgweburl, parameter, wert) {
        exec('bash /opt/iobroker/node_modules/iobroker.stiebel-lwz/isg_set.sh ' + isgweburl + ' ' + parameter + ' ' + wert, (err, stdout, stderr) => {
            if (err) {
                console.error(err);
                return;
            }
            if (debugging === true) console.log(stdout);
        });
    }

    // BETRIEBSART
    if (id == adapter.name + '.' + adapter.instance + '.Start.Betriebsart') {
        if (debugging === true) adapter.log.info('Setze Betriebsart auf: ' + state.val);
        set_isg_para(adapter.config.isgIP, 'BETRIEBSART', state.val);
    }
    // LUEFTUNGSSTUFEN
    else if (id == adapter.name + '.' + adapter.instance + '.Einstellungen.Lueften.Lueftungsstufen.STUFE_TAG') {
        if (debugging === true) adapter.log.info('Setze Lueftungsstufe STUFE-TAG auf: ' + state.val);
        set_isg_para(adapter.config.isgIP, 'LUEFTERSTUFETAG', state.val);
    }
    // RAUM TEMP TAG
    else if (id == adapter.name + '.' + adapter.instance + '.Einstellungen.Heizen.Raumtemperaturen_HK1.RAUMTEMP_TAG') {
        if (debugging === true) adapter.log.info('Setze Raumtemperaturen_HK1 RAUMTEMP. TAG auf: ' + state.val);
        set_isg_para(adapter.config.isgIP, 'RAUMTEMPTAG', state.val);
    }
    // WARMWASSER TEMP TAG
    else if (id == adapter.name + '.' + adapter.instance + '.Einstellungen.Warmwasser.WW-Temperaturen.WW_SOLL_TAG') {
        if (debugging === true) adapter.log.info('Setze WW-Temperaturen WW SOLL TAG auf: ' + state.val);
        set_isg_para(adapter.config.isgIP, 'WARMWASSERTEMPTAG', state.val);
    }

});

// is called when databases are connected and adapter received configuration.
adapter.on('ready', function () {
    main();
});

function main() {

    // Debug Ausgabe im Log
    const debugging = adapter.config.debugging;

    // TODO: cron? automatischer adapter restart?

    // Ausgabe der eingestellten IP im Log
    if (debugging === true) adapter.log.info('isgIP: ' + adapter.config.isgIP);

    // TODO: Abbruch bei keiner eingetragenen IP
    /*
    if (adapter.config.isgIP === "0.0.0.0") {
        adapter.log.error('Keine IP Adresse eingetragen! Adapterstart wird abgebrochen!');
        fail;
    }
    */

    // LADE cheerioReq
    // https://github.com/IonicaBizau/cheerio-req
    const cheerioReq = require('cheerio-req');

    function getISGwebParameters() {

        /* cheerio & request
        const cheerio = require('cheerio');
        const request = require('request');

        request('http://' + adapter.config.isgIP + '/?s=1,0', function (error, response, body) {

            var $ = cheerio.load(body);

            .....
        }
        */

        // Funktion um die letzten Stellen des Strings zu entfernen: °C || m³/h || Hz || %
        function removeUnit(input, unitLength, unit) {
            if (unit)
                unit.valueOf = unit.toSource = unit.toString = input.substring(input.length - unitLength, input.length);
            var value = input.substring(0, input.length - unitLength);
            value = value.replace(/,/, ".");
            return parseFloat(value);
        }

        function removeSign(input, length, unit) {
            return removeUnit(input, length, unit);
        }

        /**
         * DATENQUELLE: START
         */

        cheerioReq('http://' + adapter.config.isgIP, (err, $) => {

            // BETRIEBSART
            var value = $('input#aval39').val();
            adapter.setState('Start.Betriebsart', value, true);
            if (debugging === true) adapter.log.info('BETRIEBSART: ' + value);

            // SYSTEMSTATUS
            var value = $('#box_start_status_system div > p.info').text().trim();
            adapter.setState('Start.Systemstatus', value, true);
            if (debugging === true) adapter.log.info('SYSTEMSTATUS: ' + value);

            // PORTALSTATUS Letzter Kontakt
            var value = $('#box_start_status_portal div p').eq(0).text().trim();
            adapter.setState('Start.Portalstatus_letzter_Kontakt', value, true);
            if (debugging === true) adapter.log.info('PORTALSTATUS: ' + value);

            // PORTALSTATUS Schlüssel
            var value = $('#box_start_status_portal div > p.info').text().trim();
            adapter.setState('Start.Portalstatus_Schluessel', value, true);
            if (debugging === true) adapter.log.info('PORTALSTATUS: ' + value);

            // ISGweb VERSION
            var value = $('#versionsNummer').text().trim();
            adapter.setState('Start.ISGwebVersion', value, true);
            if (debugging === true) adapter.log.info('ISGwebVersion: ' + value);

            // LUEFTERSTUFE fuer DP zum setzen der Luefterstufe --> Später 4,2
            // ==> AUS JS auslesen
            var value = $('script').text().trim();
            adapter.log.info('TEST' + value);
            /*

            */

        });

        /**
         * DATENQUELLE: INFO -> ANLAGE
         */

        cheerioReq('http://' + adapter.config.isgIP + '/?s=1,0', (err, $) => {

            var d = $("td.value");

            //console.log('tds: ' + d);

            // The parseFloat() function parses a string and returns a floating point number.
            // The text property sets or returns the text of an option element.
            // The trim() method removes whitespace from both sides of a string.
            // The .eq() selector selects an element with a specific index number. The index numbers start at 0, so the first element will have the index number 0 (not 1).

            var parameter, select, dp;
            function setStateRemoveUnits(parameter, select, dp) {
                var value = d.eq(select).text().trim();
                //adapter.log.info(parameter + ': ' + value);
                value = removeSign(value, 2);
                if (isNaN(value)) value = 0;
                if (debugging === true) adapter.log.info(parameter + ': ' + value);
                adapter.setState(dp, value, true);
            }

            // RAUMTEMPERATUR
            setStateRemoveUnits('RAUMISTTEMP_HK1', 0, 'Info.Anlage.Raumtemperatur.RAUMISTTEMP_HK1')
            setStateRemoveUnits('RAUMSOLLTEMP_HK1', 1, 'Info.Anlage.Raumtemperatur.RAUMSOLLTEMP_HK1')
            setStateRemoveUnits('RAUMFEUCHTE_HK1', 2, 'Info.Anlage.Raumtemperatur.RAUMFEUCHTE_HK1')
            setStateRemoveUnits('RAUMISTTEMP_HK2', 3, 'Info.Anlage.Raumtemperatur.RAUMISTTEMP_HK2')
            setStateRemoveUnits('RAUMSOLLTEMP_HK2', 4, 'Info.Anlage.Raumtemperatur.RAUMSOLLTEMP_HK2')
            setStateRemoveUnits('RAUMFEUCHTE_HK2', 5, 'Info.Anlage.Raumtemperatur.RAUMFEUCHTE_HK2')

            // HEIZEN
            setStateRemoveUnits('AUSSENTEMPERATUR', 6, 'Info.Anlage.Heizen.AUSSENTEMPERATUR')
            setStateRemoveUnits('ISTWERT_HK1', 7, 'Info.Anlage.Heizen.ISTWERT_HK1')
            setStateRemoveUnits('SOLLWERT_HK1', 8, 'Info.Anlage.Heizen.SOLLWERT_HK1')
            setStateRemoveUnits('ISTWERT_HK2', 9, 'Info.Anlage.Heizen.ISTWERT_HK2')
            setStateRemoveUnits('SOLLWERT_HK2', 10, 'Info.Anlage.Heizen.SOLLWERT_HK2')
            setStateRemoveUnits('VORLAUFTEMPERATUR', 11, 'Info.Anlage.Heizen.VORLAUFTEMPERATUR')
            setStateRemoveUnits('RUECKLAUFTEMPERATUR', 12, 'Info.Anlage.Heizen.RUECKLAUFTEMPERATUR')

            // WARMWASSER
            setStateRemoveUnits('WW_ISTTEMP', 13, 'Info.Anlage.Warmwasser.WW_ISTTEMP')
            setStateRemoveUnits('WW_SOLLTEMP', 14, 'Info.Anlage.Warmwasser.WW_SOLLTEMP')

            // LÜFTEN
            setStateRemoveUnits('ZULUFT_IST_LUEFTERDREHZAHL', 15, 'Info.Anlage.Lueften.ZULUFT_IST_LUEFTERDREHZAHL')
            setStateRemoveUnits('ZULUFT_SOLL_VOLUMENSTROM', 16, 'Info.Anlage.Lueften.ZULUFT_SOLL_VOLUMENSTROM')
            setStateRemoveUnits('ABLUFT_IST_LUEFTERDREHZAHL', 17, 'Info.Anlage.Lueften.ABLUFT_IST_LUEFTERDREHZAHL')
            setStateRemoveUnits('ABLUFT_SOLL_VOLUMENSTROM', 18, 'Info.Anlage.Lueften.ABLUFT_SOLL_VOLUMENSTROM')

            // WÄRMEERZEUGER
            setStateRemoveUnits('HEIZSTUFE', 19, 'Info.Anlage.Waermeerzeuger.HEIZSTUFE')

        }); // end of cheerioReq()

        /**
         * DATENQUELLE: INFO -> WAERMEPUMPE
         */

        cheerioReq('http://' + adapter.config.isgIP + '/?s=1,1', (err, $) => {

            var d = $("td.value");

            var parameter, select, dp;
            function setStateRemoveUnits(parameter, select, dp) {
                var value = d.eq(select).text().trim();
                //adapter.log.info(parameter + ': ' + value);
                value = removeSign(value, 2);
                if (debugging === true) adapter.log.info(parameter + ': ' + value);
                if (isNaN(value)) value = 0;
                adapter.setState(dp, value, true);
            }

            // PROZESSWERTE
            setStateRemoveUnits('HEISSGASTEMPERATUR', 0, 'Info.Waermepumpe.Prozesswerte.HEISSGASTEMPERATUR')
            setStateRemoveUnits('VERDAMPFERTEMP', 1, 'Info.Waermepumpe.Prozesswerte.VERDAMPFERTEMP')
            setStateRemoveUnits('VERFLUESSIGERTEMP', 2, 'Info.Waermepumpe.Prozesswerte.VERFLUESSIGERTEMP')
            setStateRemoveUnits('FORTLUFT_IST_LUEFTERDREHZAHL', 3, 'Info.Waermepumpe.Prozesswerte.FORTLUFT_IST_LUEFTERDREHZAHL')
            setStateRemoveUnits('FORTLUFT_SOLL_VOLUMENSTROM', 4, 'Info.Waermepumpe.Prozesswerte.FORTLUFT_SOLL_VOLUMENSTROM')

            // WAERMEMENGEN
            setStateRemoveUnits('WM_HEIZEN_TAG', 5, 'Info.Waermepumpe.Waermemengen.WM_HEIZEN_TAG')
            setStateRemoveUnits('WM_HEIZEN_SUMME', 6, 'Info.Waermepumpe.Waermemengen.WM_HEIZEN_SUMME')
            setStateRemoveUnits('WM_WW_TAG', 7, 'Info.Waermepumpe.Waermemengen.WM_WW_TAG')
            setStateRemoveUnits('WM_WW_SUMME', 8, 'Info.Waermepumpe.Waermemengen.WM_WW_SUMME')
            setStateRemoveUnits('WM_NE_HEIZEN_SUMME', 9, 'Info.Waermepumpe.Waermemengen.WM_NE_HEIZEN_SUMME')
            setStateRemoveUnits('WM_NE_WW_SUMME', 10, 'Info.Waermepumpe.Waermemengen.WM_NE_WW_SUMME')
            setStateRemoveUnits('WM_WRG_TAG', 11, 'Info.Waermepumpe.Waermemengen.WM_WRG_TAG')
            setStateRemoveUnits('WM_WRG_SUMME', 12, 'Info.Waermepumpe.Waermemengen.WM_WRG_SUMME')

            // LEISTUNGSAUFNAHME
            setStateRemoveUnits('P_HEIZUNG_TAG', 13, 'Info.Waermepumpe.Leistungsaufnahme.P_HEIZUNG_TAG')
            setStateRemoveUnits('P_HEIZUNG_SUMME', 14, 'Info.Waermepumpe.Leistungsaufnahme.P_HEIZUNG_SUMME')
            setStateRemoveUnits('P_WW_TAG', 15, 'Info.Waermepumpe.Leistungsaufnahme.P_WW_TAG')
            setStateRemoveUnits('P_WW_SUMME', 16, 'Info.Waermepumpe.Leistungsaufnahme.P_WW_SUMME')

            // LAUFZEITEN
            setStateRemoveUnits('VERDICHTER_HEIZEN', 17, 'Info.Waermepumpe.Laufzeiten.VERDICHTER_HEIZEN')
            setStateRemoveUnits('VERDICHTER_WW', 18, 'Info.Waermepumpe.Laufzeiten.VERDICHTER_WW')
            setStateRemoveUnits('ELEKTR_NE_HEIZEN', 19, 'Info.Waermepumpe.Laufzeiten.ELEKTR_NE_HEIZEN')
            setStateRemoveUnits('ELEKTR_NE_WW', 20, 'Info.Waermepumpe.Laufzeiten.ELEKTR_NE_WW')

        }); // end of cheerioReq()

        setTimeout(function () {
            getISGwebParameters();
        }, 10000);

    } // end of getISGwebParameters()

    if (adapter.config.loadISGwebParameters === true) {
        getISGwebParameters();
    }

    // in this stiebel-lwz all states changes inside the adapters namespace are subscribed
    adapter.subscribeStates('*');

    /*
    setTimeout(function () {
        getISGwebParameters();
        adapter.stop();
    }, 10000);
    */

} // end of main()

NEWS

Automatischer Adapter Neustart

Support us

660
Online

31.7k
Users

79.8k
Topics

1.3m
Posts

NEWS

Automatischer Adapter Neustart

Support us

660Online

31.7kUsers

79.8kTopics

1.3mPosts

660
Online

31.7k
Users

79.8k
Topics

1.3m
Posts