[Vorlage] Stromverbrauch protokollieren - (etwas optimiert)

Elektroniker86

Geil, viiiiieeelen Dank für die ausführliche Info.
Du bist der beste ! ! !

Gruß

Röstkartoffel

"Bitte benutzt das Voting rechts unten im Beitrag wenn er euch geholfen hat"

backons

Hallo,

wenn man das Script z.B. Mitte des Jahres das erste Mal aktiviert dann wird der Stromverbrauch des Jahres ja erst ab dem ersten Start bis zu Ende des Jahres gezählt. Da ich meinen Zählerstand vom 31.12. des Vorjahres weis stellt sich mir die Frage ob ich hier irgendwie manuell eingreifen kann und ihm sagen kann was der Startwert des Jahres ist ?

ChrisXY

hm hab nen EM1000 der gibt mir schon current peak seq und total aus.

bumbumb

Hallo leider kommen bei mir div. Fehlermeldung das variablen nicht definiert wurden. Woran kann es liegen

bumbumb

bei diesem Script

//jshint maxerr:1000
// https://github.com/hdering/homematic_stromverbrauch_protokollieren

//----------------------------------------------------------------------------//

// Version: 1.3.3

//----------------------------------------------------------------------------//
// +++++++++  USER ANPASSUNGEN ++++++++++++++++++++++++

// debug logging
var logging = false;

// Aktivieren der History Instanz
var enable_history = false;

// history Instanz
var instance_history = 'history.0';

// Geräte können unterschiedliche Preise haben
var enable_unterschiedlichePreise = true;

// Speichern der Werte in zusätzlichen Objekten.
// Wenn 0, dann deaktiviert
var Tag_Anzahl_Werte_in_der_Vergangenheit       = 7;
var Woche_Anzahl_Werte_in_der_Vergangenheit     = 4;
var Monat_Anzahl_Werte_in_der_Vergangenheit     = 12;
var Quartal_Anzahl_Werte_in_der_Vergangenheit   = 4;
var Jahr_Anzahl_Werte_in_der_Vergangenheit      = 2;

// Grundpreis einberechnen
var enable_Grundpreis_einberechnen = false;

var instance    = '0';
var instanz     = 'javascript.' + instance + '.';

// Pfad innerhalb der Instanz
var pfad        = 'Verbrauchszaehler.';

var default_unit = 'Wh';
var default_unit_kilo = 'kWh';

// Diese Teile werden aus den Gerätenamen entfernt
var blacklist   = [':1', ':2', ':3', ':4', ':5', ':6', ':7', ':8'];

var AnzahlKommastellenKosten = 2;
var AnzahlKommastellenVerbrauch = 3;
var AnzahlKommastellenZaehlerstand = 3;

var KumulierterWertIstBereitsInKilo = true;

var eigeneDatenpunkte = [
[ 'smartmeter.0.1-0:1_8_0_255.value', 'Verbrauchszähler.Strom', 'Wh', 'kWh' ], // Bezug 
[ 'smartmeter.0.1-0:2_8_0_255.value', 'Lieferungszähler.Strom', 'Wh', 'kWh' ] // Lieferungswerte
    
    // Beispiel:
    // ['Datenpunkt', 'Aliasname', 'Einheit kumulierter Wert', 'Einheit berechnete Werte (kilo/1000)' ],
    
    // [ 'hm-rpc.2.NEQ0861663.1.ENERGY_COUNTER', 'Stromzaehler:1.ENERGY_COUNTER', 'Wh', 'kWh' ],
    // [ 'javascript.1.MeinSonoffGeraet1', 'Strom.Sonoff.MeinSonoffGeraet1', 'Wh', 'kWh' ],
    // [ 'javascript.1.MeinSonoffGeraet2', 'Strom.Sonoff.MeinSonoffGeraet2', 'kWh', 'kWh' ],
    // [ 'javascript.1.MeineGas1', 'Gas.MeinGaszaehler1', 'm3', 'm3' ],
    // [ 'javascript.1.MeineGas2', 'Gas.MeinGaszaehler2', 'm3', 'm3' ],
];

// Pushmeldung
function send_message(text) {
    
    // Hier können die Pushmeldung über alle möglichen Wege verschickt werden.
    
    //console.log(text);
    
    //sendTelegram(text);
}

// ++++ ENDE USER ANPASSUNGEN ++++++++++++++++++++++++
//----------------------------------------------------------------------------//

createState(pfad + 'Preis.aktuell.Arbeitspreis', {
    name: 'Strompreis - aktueller Arbeitspreis (brutto)',
    unit: '€/' + default_unit_kilo,
    type: 'number',
    def:  0,
    min:  0
});

createState(pfad + 'Preis.aktuell.Grundpreis',  {                           
    name: 'Strompreis - aktueller Grundpreis (brutto)',
    unit: '€/Monat',
    type: 'number',
    def:  0,
    min: 0
});

//----------------------------------

createState(pfad + 'Preis.neu.Arbeitspreis', {
    name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)',
    unit: '€/' + default_unit_kilo,
    type: 'number',
    def:  0,
    min:  0
});

createState(pfad + 'Preis.neu.Grundpreis',  {                           
    name: 'Strompreis - neuer Grundpreis ab Datum (brutto)',
    unit: '€/Monat',
    type: 'number',
    def:  0,
    min: 0
});

createState(pfad + 'Preis.neu.Datum',  {                           
    name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)',
    type: 'string',
    def: "01.01.1970",
});

createState(pfad + 'Preis.neu.PreisaenderungDurchgefuehrt', false, {
  read: true, 
  write: true, 
  type: "boolean", 
  def: false
});

//----------------------------------------------------------------------------//

var cacheSelectorStateMeter  = $('channel[state.id=*.METER]');
var cacheSelectorStateEnergyCounter  = $('channel[state.id=*.ENERGY_COUNTER$]');

//----------------------------------------------------------------------------//

function parseObjects(id) {
    var obj = getObject(id);

    return entferneDatenpunkt(obj.common.name);
}

function setRecognizedChange(type, anzahl) {
    
    cacheSelectorStateMeter.each(function (id, i) {
        var geraetename = parseObjects(id);

        rotateVerbrauchUndKosten(geraetename, type, anzahl);
        
        resetVerbrauchUndKosten(geraetename, type);
        
        schreibeZaehlerstand(geraetename, type);
    });

    cacheSelectorStateEnergyCounter.each(function (id, i) {
        var geraetename = parseObjects(id);

        rotateVerbrauchUndKosten(geraetename, type, anzahl);
        
        resetVerbrauchUndKosten(geraetename, type);
        
        schreibeZaehlerstand(geraetename, type);
    });
    
    if (eigeneDatenpunkte.length > 0) {

        for(var i = 0; i < eigeneDatenpunkte.length; i++) {
            var alias = eigeneDatenpunkte[i][1];
            
            rotateVerbrauchUndKosten(alias, type, anzahl);
            
            resetVerbrauchUndKosten(alias, type);
            
            schreibeZaehlerstand(alias, type);
        }
    }
}

//----------------------------------------------------------------------------//

// Tageswechsel
schedule("0 0 * * *", function() {
    setRecognizedChange('Tag', Tag_Anzahl_Werte_in_der_Vergangenheit);
});

// Wochenwechsel
schedule("0 0 * * 1", function() {
    setRecognizedChange('Woche', Woche_Anzahl_Werte_in_der_Vergangenheit);
});

// Monatswechsel
schedule("0 0 1 * *", function() {
    setRecognizedChange('Monat', Monat_Anzahl_Werte_in_der_Vergangenheit);
});

// Quartalswechsel
schedule("0 0 1 */3 *", function() {
    setRecognizedChange('Quartal', Quartal_Anzahl_Werte_in_der_Vergangenheit);
});

// Jahreswechsel
schedule("0 0 1 1 *", function() {
    setRecognizedChange('Jahr', Jahr_Anzahl_Werte_in_der_Vergangenheit);
});

//----------------------------------------------------------------------------//

// Eigene Datenpunkte
function pruefeEigeneDatenpunkte() {
    
    if (eigeneDatenpunkte.length > 0) {
    
        for(var i = 0; i < eigeneDatenpunkte.length; i++) {
            
            var datenpunkt = eigeneDatenpunkte[i][0];
            var alias = eigeneDatenpunkte[i][1];
            var einheit = eigeneDatenpunkte[i][2];
            var einheit_kilo = eigeneDatenpunkte[i][3];
            
            if(logging) console.log("Alias:" + alias + " Datenpunkt:" + datenpunkt + " Einheit:" + einheit + " Einheit_kilo:" + einheit_kilo);

            on(datenpunkt, function(obj) {

                for(var i = 0; i < eigeneDatenpunkte.length; i++) {
                    
                    if(eigeneDatenpunkte[i][0] === obj.id)    
                        run(obj, eigeneDatenpunkte[i][1], eigeneDatenpunkte[i][2], eigeneDatenpunkte[i][3]);
                }
            });
        }
    }
}

pruefeEigeneDatenpunkte();

//----------------------------------------------------------------------------//

// Einlesen der aktuellen Daten vom Zähler
function run(obj, alias, unit, unit_kilo) {
    
    if (logging) {   
        log('-------- Strommesser ---------');
        log('RegExp-Funktion ausgelöst');
        log('id:           ' + obj.id);
        log('Name:         ' + obj.common.name);   // Waschmaschine Küche:2.ENERGY_COUNTER
        log('channel ID:   ' + obj.channelId);     // hm-rpc.0.MEQ0170864.2
        log('channel Name: ' + obj.channelName);   // Waschmaschine Küche:2
        log('device ID:    ' + obj.deviceId);      // hm-rpc.0.MEQ0170864
        log('device name:  ' + obj.deviceName);    // Küche Waschmaschine
        log('neuer Wert:   ' + obj.newState.val);  // 16499.699982
        log('alter Wert:   ' + obj.oldState.val);  // 16499.699982
    }

    // Gerätenamen erstellen
    if (logging) log('vor der Aufbereitung: ' + obj.common.name); 
    
    var geraetename = entferneDatenpunkt(obj.common.name);

    if(typeof alias !== "undefined")  {
        if(logging) console.log("Es wird der Aliasname gesetzt:" + alias);
        
        geraetename = alias;
    }
    
    if (logging) log('Nach der Aufbereitung: ' + geraetename); 
    
    if(typeof geraetename !== "undefined") {
        
        //------------------------------------------------------------------------//
        
        _unit = default_unit;
        _unit_kilo = default_unit_kilo;
        
        // States erstellen (CreateStates für dieses Gerät)
        if(typeof unit !== "undefined")  {
            _unit = unit;
        }
        
        if(typeof unit_kilo !== "undefined")  {
            _unit_kilo = unit_kilo;
        }
        
        erstelleStates(geraetename, _unit, _unit_kilo);
        
        //------------------------------------------------------------------------//
        
        // Schreiben der neuen Werte
    
        var idKumuliert =  instanz + pfad + geraetename + '.Zaehlerstand.kumuliert';
        
        var NeustartEventuellErkannt = false;
        var NeustartSicherErkannt = false;
        
        var oldState = obj.oldState.val;
        var newState = obj.newState.val;
        var difference = newState - oldState;
    
        if(difference > 0) {
            
            if(oldState !== 0) {
    
                // Kumulierten Wert mit Ist-Wert (inkl. Backup) synchronisieren
                var newValueKumuliert = getState(idKumuliert).val + difference;
                
                newValueKumuliert = parseFloat(newValueKumuliert);
    
                setState(idKumuliert, newValueKumuliert);
                
            } else {
                
                if(newState < getState(pfad + geraetename + '.config.NeustartErkanntAlterWert').val) {
    
                    NeustartSicherErkannt = true;
                }
            }
            
        } else {
            
            // Fall 2 oder 3
            // Irgendetwas läuft außerplanmäßig. Wert wird sicherheitshalber gespeichert und nächster Lauf abgewartet
            NeustartEventuellErkannt = true;
            
            setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', obj.oldState.val);
        }
        
        if(NeustartEventuellErkannt) {
            
            if(logging) {
                var message =  geraetename + '\n'
                                + 'Entweder die CCU oder Stromzähler wurden neugestartet/zurückgesetzt.\n'
                                + 'Dieser Wert wird einmal ignoriert und auf den nächsten Wert gewartet.';
            
                send_message(message);
            }
        }
        
        if(NeustartSicherErkannt) {
    
            // zurücksetzen der Variable
            setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', 0);
            
            //----------------------------------------------------------------//
    
            var message2 = geraetename + '\n'
                        + 'Der Stromzähler (' + geraetename + ') ist übergelaufen, gelöscht oder neugestartet worden (ggf. Stromausfall).\n'
                        + 'newState:' + obj.newState.val + '\n' 
                        + 'oldState:' + obj.oldState.val + '\n'
                        + 'differenz:' + difference + '\n'
                        + 'idKumuliert:' + getState(idKumuliert).val;
    
            send_message(message2);
        }
        
        //--------------------------------------------------------------------//

        pruefePreisaenderung();
        
        if(enable_unterschiedlichePreise)
            pruefePreisaenderung(geraetename);
        
        var idStrompreis = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
        var idGrundpreis = instanz + pfad + 'Preis.aktuell.Grundpreis';
        
        // aktualisiere den Verbrauch und die Kosten
        if(KumulierterWertIstBereitsInKilo)
            _zaehler    = (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand);
        else
            _zaehler    = (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand);
        
        _preis      = getState(idStrompreis).val;
        _grundpreis = getState(idGrundpreis).val;
        
        // Wenn das Gerät einen eigenen Strompreis / Grundpreis hat
        if(enable_unterschiedlichePreise) {
            
            if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val > 0) {
                _preis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val;

                if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Strompreis: " + _preis);
            }
            
            if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val > 0) {
                _grundpreis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val;
                
                if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Grundpreis: " + _grundpreis);
            }
        }

        berechneVerbrauchUndKosten(geraetename, _zaehler, _preis, _grundpreis); // in kWh

        if (logging) log('------------ ENDE ------------');
        
    } else {
        
        var message3 = 'Fehler beim Erstellen des Gerätenamens:\n'
                    + 'obj.common.name: ' + obj.common.name;
        
        send_message(message3);
    }
}

cacheSelectorStateMeter.on(function(obj) {
   run(obj);
});

cacheSelectorStateEnergyCounter.on(function(obj) {
   run(obj);
});

//----------------------------------------------------------------------------//

function entferneDatenpunkt(geraet) {
    
    var rueckgabe = geraet;
    
    // ":2.ENERGY_COUNTER" --> ".ENERGY_COUNTER"
    if (geraet.indexOf(".ENERGY_COUNTER") != -1) {
        
        rueckgabe = geraet.substring(0, geraet.indexOf(".ENERGY_COUNTER"));
        
    } else if (geraet.indexOf(".METER") != -1) {
        
        rueckgabe = geraet.substring(0, geraet.indexOf(".METER"));
    }
    
    if (logging) log('entferneDatenpunkt - rueckgabe1:' + rueckgabe);

    // Rückgabe sollte keine Sonderzeichen oder Leerzeichen enthalten. Wenn doch, werden die entfernt oder ersetzt

    try {
        rueckgabe = checkBlacklist(rueckgabe);
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe);
    }

    try {
        if (rueckgabe.charAt(rueckgabe.length - 1) == "-") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
        if (rueckgabe.charAt(rueckgabe.length - 1) == "\\") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
        if (rueckgabe.charAt(rueckgabe.length - 1) == ":") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe);
    }
    
    // per Regexp Leerzeichen entfernen
    try {
        rueckgabe = rueckgabe.replace(/\s/g, "");
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe);
    }

    return rueckgabe;
}

function checkBlacklist(name) {
    
    var _name = "";
    
    if (blacklist.length > 0) {

        for(var i = 0; i < blacklist.length; i++) {
          
            if (name.indexOf(blacklist[i]) != -1) {

                // Zeichenketten, die in der Blacklist stehen, aus dem Namen löschen
                _name = name.substring(0, name.indexOf(blacklist[i]));
            }
        }

        if(_name === "") {
            return name;
        } else {
            return _name;
        }
    
    } else return (name);
}

function schreibeZaehlerstand(geraet, zeitraum) { 
    
    var idKumuliert =    instanz + pfad + geraet + '.Zaehlerstand.kumuliert',
        idZaehlerstand = instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum;
    
    // Zählerstand für übergebene Zeitraum und das Gerät in Wh auslesen und in kWh speichern (also durch 1000)
    
    if(KumulierterWertIstBereitsInKilo)
        setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand)) );  
    else
        setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand)) ); 

    if (logging) log('Zählerstände für das Gerät ' + geraet + ' (' + zeitraum + ') in Objekten gespeichert');
}

function rotateVerbrauchUndKosten(geraet, zeitraum, anzahl) {

    // Verbrauch
    if(anzahl > 0) {
        
        for(var i = anzahl; i >= 0; i--) {
            
            var j = i;
            
            j++;
            
            if(getObject(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j)) {
                
                if(i === 0)
                    setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum).val);
                else
                    setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + i).val);
            }
        }
    }
    
    // Kosten
    if(anzahl > 0) {
        
        for(var i = anzahl; i >= 0; i--) {
            
            var j = i;
            
            j++;
            
            if(getObject(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j)) {
                
                if(i === 0)
                    setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten.' + zeitraum).val);
                else
                    setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + i).val);
            }
        }
    }
}

function resetVerbrauchUndKosten(geraet, zeitraum) {
    
    // Reset der Stromkosten für den übergebenen Zeitraum
    // Reset des Stromverbrauchs für den übergebenen Zeitraum 
    setState(instanz + pfad + geraet + '.Kosten.' + zeitraum, 0);     
    setState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum, 0);
    
    if (logging) log('Stromkosten und Stromverbrauch für das Gerät ' + geraet + ' (' + zeitraum + ') zurückgesetzt');
} 

function berechneVerbrauchUndKosten(geraet, zaehler, preis, grundpreis) {                      
    
    // bei jedem eingehenden Wert pro Gerät

    if(preis === 0) {
    
        var message0 = 'Achtung!' + '.\n'
                    + 'Es wurde noch kein Arbeitspreis angegeben.' + '\n' 
                    + 'Ohne Arbeitspreis kann das Skript keine Berechnungen durchführen.' + '\n'
                    + 'Diese Information ist zwingend notwendig!';
        
        log(message0, 'error');
        
    } else {
    
        var _grundpreis = 0;
        
        if(enable_Grundpreis_einberechnen) {
    
            _grundpreis = grundpreis * 12 / 365;
            
            _grundpreis = parseFloat(_grundpreis.toFixed(3));
        }
        
        grundpreis_tag      = _grundpreis;
        grundpreis_woche    = _grundpreis * 7;
        grundpreis_monat    = _grundpreis * 30; 
        grundpreis_quartal  = _grundpreis * 90;
        grundpreis_jahr     = _grundpreis * 365;
    
        // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
        setState(instanz + pfad + geraet + '.Kosten.Tag',        parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val) * preis) + grundpreis_tag).toFixed(AnzahlKommastellenKosten) ) );  // Kosten an diesem Tag in €
        
        // Woche
        setState(instanz + pfad + geraet + '.Kosten.Woche',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val) * preis) + grundpreis_woche).toFixed(AnzahlKommastellenKosten) ) );
        
        // Monat
        setState(instanz + pfad + geraet + '.Kosten.Monat',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val) * preis) + grundpreis_monat).toFixed(AnzahlKommastellenKosten) ) );
        
        // Quartal
        setState(instanz + pfad + geraet + '.Kosten.Quartal',    parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val) * preis) + grundpreis_quartal).toFixed(AnzahlKommastellenKosten) ) );
        
        // Jahr
        setState(instanz + pfad + geraet + '.Kosten.Jahr',       parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val) * preis) + grundpreis_jahr).toFixed(AnzahlKommastellenKosten) ) );  
        
        if (logging) log('Stromkosten (' + geraet + ') aktualisiert');
    }
    
    // Verbrauch berechnen
    
    // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
    setState(instanz + pfad + geraet + '.Verbrauch.Tag',     parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val).toFixed(AnzahlKommastellenVerbrauch) ) );           // Verbrauch an diesem Tag in kWh

    // Woche
    setState(instanz + pfad + geraet + '.Verbrauch.Woche',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val).toFixed(AnzahlKommastellenVerbrauch) ) );

    // Monat
    setState(instanz + pfad + geraet + '.Verbrauch.Monat',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val).toFixed(AnzahlKommastellenVerbrauch) ) );

    // Quartal
    setState(instanz + pfad + geraet + '.Verbrauch.Quartal', parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val).toFixed(AnzahlKommastellenVerbrauch) ) );

    // Jahr
    setState(instanz + pfad + geraet + '.Verbrauch.Jahr',    parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val).toFixed(AnzahlKommastellenVerbrauch) ) );
    
    if (logging) log('Stromverbrauch (' + geraet + ') aktualisiert');
}

function erstelleStates (geraet, _unit, _unit_kilo) {
    
    // Kumulierter Zählerstand (wird nie kleiner)
    createState(pfad + geraet + '.Zaehlerstand.kumuliert', 0, {name: 'Kumulierter Zählerstand (' + geraet + ')', type: 'number', unit: _unit });
            
    // Zählerstand
    createState(pfad + geraet + '.Zaehlerstand.Tag',     0, {name: 'Zählerstand Tagesbeginn ('       + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Woche',   0, {name: 'Zählerstand Wochenbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Monat',   0, {name: 'Zählerstand Monatsbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Quartal', 0, {name: 'Zählerstand Quartalsbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Jahr',    0, {name: 'Zählerstand Jahresbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    
    // Verbrauch 
    createState(pfad + geraet + '.Verbrauch.Tag',        0, {name: 'Verbrauch seit Tagesbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Woche',      0, {name: 'Verbrauch seit Wochenbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Monat',      0, {name: 'Verbrauch seit Monatsbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Quartal',    0, {name: 'Verbrauch seit Quartalsbeginn (' + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Jahr',       0, {name: 'Verbrauch seit Jahresbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
            
    // Stromkosten
    createState(pfad + geraet + '.Kosten.Tag',           0, {name: 'Stromkosten heute ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Woche',         0, {name: 'Stromkosten Woche ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Monat',         0, {name: 'Stromkosten Monat ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Quartal',       0, {name: 'Stromkosten Quartal ('           + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Jahr',          0, {name: 'Stromkosten Jahr ('              + geraet + ')', type: 'number', unit: '€' });
    
    // Speichern der Werte in zusätzlichen Variablen
    if(Tag_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Tag_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Tag.Tag_' + i,             0, {name: 'Verbrauch vor ' + i + ' Tag(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Tag.Tag_' + i,                0, {name: 'Stromkosten vor ' + i + ' Tag(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Woche_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Woche_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Woche.Woche_' + i,         0, {name: 'Verbrauch vor ' + i + ' Woche(n) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Woche.Woche_' + i,            0, {name: 'Stromkosten vor ' + i + ' Woche(n) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Monat_Anzahl_Werte_in_der_Vergangenheit > 0) {

        for(var i = 1; i <= Monat_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Monat.Monat_' + i,         0, {name: 'Verbrauch vor ' + i + ' Monat(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Monat.Monat_' + i,            0, {name: 'Stromkosten vor ' + i + ' Monat(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Quartal_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Quartal_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Quartal.Quartal_' + i,     0, {name: 'Verbrauch vor ' + i + ' Quartal(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Quartal.Quartal_' + i,        0, {name: 'Stromkosten vor ' + i + ' Quartal(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Jahr_Anzahl_Werte_in_der_Vergangenheit > 0) {

        for(var i = 1; i <= Jahr_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Jahr.Jahr_' + i,           0, {name: 'Verbrauch vor ' + i + ' Jahr(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Jahr.Jahr_' + i,              0, {name: 'Stromkosten vor ' + i + ' Jahr(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }

    // Neustart von CCU oder Gerät erkannt
    createState(pfad + geraet + '.config.NeustartErkanntAlterWert', 0);
    
    // Gerät hat eigenen Strompreis
    if(enable_unterschiedlichePreise) {
        createState(pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis'            , { name: 'Strompreis - aktueller Arbeitspreis ab Datum (brutto)' ,     unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.aktuell.Grundpreis'              , { name: 'Strompreis - aktueller Grundpreis ab Datum (brutto)'   ,     unit: '€/Monat',    type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Arbeitspreis'                , { name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)' ,         unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Grundpreis'                  , { name: 'Strompreis - neuer Grundpreis ab Datum (brutto)'   ,         unit: '€/Monat',    type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Datum'                       , { name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)', def: "01.01.1970", type: 'string' });
        
        createState(pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt' ,     false, { read: true, write: true, type: "boolean", def: false });
    }
    
    // history bei allen Datenpunkten aktivieren
    if(enable_history) {
        enableHistory(geraet, 'Tag');
        enableHistory(geraet, 'Woche');
        enableHistory(geraet, 'Monat');
        enableHistory(geraet, 'Quartal');
        enableHistory(geraet, 'Jahr');
    }

    if (logging) log('States in der Instanz ' + instanz + pfad + ' erstellt');   
}

function enableHistory(geraet, zeitraum) {

    if(instance_history !== '') {
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Kosten.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Verbrauch.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
    }
}

function pruefePreisaenderung(geraet) {
    
    var _Datum = "";
    var _PreisaenderungDurchgefuehrt = "";
    var _Arbeitspreis = "";
    var _Grundpreis = "";
    var _ArbeitspreisNeu = "";
    var _GrundpreisNeu = "";
    
    if(typeof geraet === "undefined") {
        
         // Default Arbeitspreis ändern

        _Datum                          = instanz + pfad + 'Preis.neu.Datum';
        _PreisaenderungDurchgefuehrt    = instanz + pfad + 'Preis.neu.PreisaenderungDurchgefuehrt';
        
        _Arbeitspreis       = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
        _Grundpreis         = instanz + pfad + 'Preis.aktuell.Grundpreis';
        _ArbeitspreisNeu    = instanz + pfad + 'Preis.neu.Arbeitspreis';
        _GrundpreisNeu      = instanz + pfad + 'Preis.neu.Grundpreis';
        
    } else {

        // Arbeitspreis für Gerät ändern
        
        _Datum                          = instanz + pfad + geraet + '.eigenerPreis.neu.Datum';
        _PreisaenderungDurchgefuehrt    = instanz + pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt';
        
        _Arbeitspreis       = instanz + pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis';
        _Grundpreis         = instanz + pfad + geraet + '.eigenerPreis.aktuell.Grundpreis';
        _ArbeitspreisNeu    = instanz + pfad + geraet + '.eigenerPreis.neu.Arbeitspreis';
        _GrundpreisNeu      = instanz + pfad + geraet + '.eigenerPreis.neu.Grundpreis';
    }

    if(getObject(_Datum)) {
        
        var date = getState(_Datum).val;
        
        var Datum_Tag;
        var Datum_Monat;
        var Datum_Jahr;

        try {
            var Datum = date.match(/\d{2}(\.|-)\d{2}(\.|-)\d{4}/g).toString();
            
            Datum_Tag = Datum.split(".")[0];
            Datum_Monat = Datum.split(".")[1];
            Datum_Jahr = Datum.split(".")[2];
            
        } catch (err) {
            console.log("Fehler beim Auslesen des Datums. Eventuell falsche Syntax? " + date + " (Error:" + err + ")");
        }
        
        newdate = new Date(Datum_Monat + " " + Datum_Tag + " " + Datum_Jahr);

        var today = new Date();
        today.setHours(0,0,0,0);

        if(today.getTime() === newdate.getTime()) {
            
            if(!getState(_PreisaenderungDurchgefuehrt).val) {

                setState(_PreisaenderungDurchgefuehrt, true);
                
                var alterArbeitspreis = getState(_Arbeitspreis).val;
                var alterGrundpreis = getState(_Grundpreis).val;
                
                var neuerArbeitspreis = getState(_ArbeitspreisNeu).val;
                var neuerGrundpreis = getState(_GrundpreisNeu).val;
                
                setState(_Arbeitspreis, neuerArbeitspreis);
                setState(_Grundpreis, neuerGrundpreis);
                
                var message =  'Preisänderung für ' + geraet + ' wurde durchgeführt:' + '\n'
                            + 'alter Arbeitspreis:' + alterArbeitspreis + '.\n'
                            + 'alter Grundpeis:' + alterGrundpreis + '.\n'
                            + 'neuer Arbeitspreis:' + neuerArbeitspreis + '.\n'
                            + 'neuer Grundpreis:' + neuerGrundpreis;
                
                send_message(message);
            }
            
        } else if(today.getTime() > newdate.getTime()) {

            // Variable zurücksetzen
            setState(_PreisaenderungDurchgefuehrt, false);
        }
    }
}

//----------------------------------------------------------------------------//

Mod-Edit: Code/Log in Code Tags gepackt. Bitte benutzt die Code Tags Funktion -> </>
Hier gehts zur Hilfe.

Homoran

@bumbumb

Bitte das Skript in Spoiler und Code-Tags setzen!

bumbumb

@bumbumb said in [Vorlage] Stromverbrauch protokollieren - (etwas optimiert):

bei diesem Script

hat denn jemand eine Idee warum es 1zu1 nicht funktioniert.

Alexxx2005

Hallo,

das Skript ist Mega !

mir fehlen noch paar Denkanstöße zur visualisierung , das Skript
gibt schon viele Daten aus. Habt ihr mir paar Ideen ?

gibt es jemand wo die VIS mit dem Stromzähler Bild gelöst hat ?
Habe mal ein Foto gesehen wo es den Zählerstand anzeigt wie
auf einem richtigen konventionellen Stromzähler

Grüße Alex

Alexxx2005

@dering

ist geplant eine Abschlagsberechnung einzuplanen ?

z.b. könnte ich meinen monatlichen Abschlag definieren
und ich sehe monatlich , halbjährlich oder kurz vor Jahresende
ob ich nachzahlen muss und wenn ja wieviel ?

Grüße Alex

xbow42

@bumbumb

//jshint maxerr:1000
// https://github.com/hdering/homematic_stromverbrauch_protokollieren
 
//----------------------------------------------------------------------------//
 
// Version: 1.3.3
 
//----------------------------------------------------------------------------//
// +++++++++  USER ANPASSUNGEN ++++++++++++++++++++++++
 
// debug logging
var logging = false;
 
// Aktivieren der History Instanz
var enable_history = false;
 
// history Instanz
var instance_history = 'history.0';
 
// Geräte können unterschiedliche Preise haben
var enable_unterschiedlichePreise = true;
 
// Speichern der Werte in zusätzlichen Objekten.
// Wenn 0, dann deaktiviert
var Tag_Anzahl_Werte_in_der_Vergangenheit       = 7;
var Woche_Anzahl_Werte_in_der_Vergangenheit     = 4;
var Monat_Anzahl_Werte_in_der_Vergangenheit     = 12;
var Quartal_Anzahl_Werte_in_der_Vergangenheit   = 4;
var Jahr_Anzahl_Werte_in_der_Vergangenheit      = 2;
 
// Grundpreis einberechnen
var enable_Grundpreis_einberechnen = false;
 
var instanznr    = '0';
var instanz     = 'javascript.' + instanznr + '.';
 
// Pfad innerhalb der Instanz
var pfad        = 'Verbrauchszaehler.';
 
var default_unit = 'Wh';
var default_unit_kilo = 'kWh';
 
// Diese Teile werden aus den Gerätenamen entfernt
var blacklist   = [':1', ':2', ':3', ':4', ':5', ':6', ':7', ':8'];
 
var AnzahlKommastellenKosten = 2;
var AnzahlKommastellenVerbrauch = 3;
var AnzahlKommastellenZaehlerstand = 3;
 
var KumulierterWertIstBereitsInKilo = true;
 
var eigeneDatenpunkte = [
[ 'smartmeter.0.1-0:1_8_0_255.value', 'Verbrauchszähler.Strom', 'Wh', 'kWh' ], // Bezug 
[ 'smartmeter.0.1-0:2_8_0_255.value', 'Lieferungszähler.Strom', 'Wh', 'kWh' ] // Lieferungswerte
    
    // Beispiel:
    // ['Datenpunkt', 'Aliasname', 'Einheit kumulierter Wert', 'Einheit berechnete Werte (kilo/1000)' ],
    
    // [ 'hm-rpc.2.NEQ0861663.1.ENERGY_COUNTER', 'Stromzaehler:1.ENERGY_COUNTER', 'Wh', 'kWh' ],
    // [ 'javascript.1.MeinSonoffGeraet1', 'Strom.Sonoff.MeinSonoffGeraet1', 'Wh', 'kWh' ],
    // [ 'javascript.1.MeinSonoffGeraet2', 'Strom.Sonoff.MeinSonoffGeraet2', 'kWh', 'kWh' ],
    // [ 'javascript.1.MeineGas1', 'Gas.MeinGaszaehler1', 'm3', 'm3' ],
    // [ 'javascript.1.MeineGas2', 'Gas.MeinGaszaehler2', 'm3', 'm3' ],
];
 
// Pushmeldung
function send_message(text) {
    
    // Hier können die Pushmeldung über alle möglichen Wege verschickt werden.
    
    //console.log(text);
    
    //sendTelegram(text);
}
 
// ++++ ENDE USER ANPASSUNGEN ++++++++++++++++++++++++
//----------------------------------------------------------------------------//
 
createState(pfad + 'Preis.aktuell.Arbeitspreis', {
    name: 'Strompreis - aktueller Arbeitspreis (brutto)',
    unit: '€/' + default_unit_kilo,
    type: 'number',
    def:  0,
    min:  0
});
 
createState(pfad + 'Preis.aktuell.Grundpreis',  {                           
    name: 'Strompreis - aktueller Grundpreis (brutto)',
    unit: '€/Monat',
    type: 'number',
    def:  0,
    min: 0
});
 
//----------------------------------
 
createState(pfad + 'Preis.neu.Arbeitspreis', {
    name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)',
    unit: '€/' + default_unit_kilo,
    type: 'number',
    def:  0,
    min:  0
});
 
createState(pfad + 'Preis.neu.Grundpreis',  {                           
    name: 'Strompreis - neuer Grundpreis ab Datum (brutto)',
    unit: '€/Monat',
    type: 'number',
    def:  0,
    min: 0
});
 
createState(pfad + 'Preis.neu.Datum',  {                           
    name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)',
    type: 'string',
    def: "01.01.1970",
});
 
createState(pfad + 'Preis.neu.PreisaenderungDurchgefuehrt', false, {
  read: true, 
  write: true, 
  type: "boolean", 
  def: false
});
 
//----------------------------------------------------------------------------//
 
var cacheSelectorStateMeter  = $('channel[state.id=*.METER]');
var cacheSelectorStateEnergyCounter  = $('channel[state.id=*.ENERGY_COUNTER$]');
 
//----------------------------------------------------------------------------//
 
function parseObjects(id) {
    var obj = getObject(id);
 
    return entferneDatenpunkt(obj.common.name);
}
 
function setRecognizedChange(type, anzahl) {
    
    cacheSelectorStateMeter.each(function (id, i) {
        var geraetename = parseObjects(id);
 
        rotateVerbrauchUndKosten(geraetename, type, anzahl);
        
        resetVerbrauchUndKosten(geraetename, type);
        
        schreibeZaehlerstand(geraetename, type);
    });
 
    cacheSelectorStateEnergyCounter.each(function (id, i) {
        var geraetename = parseObjects(id);
 
        rotateVerbrauchUndKosten(geraetename, type, anzahl);
        
        resetVerbrauchUndKosten(geraetename, type);
        
        schreibeZaehlerstand(geraetename, type);
    });
    
    if (eigeneDatenpunkte.length > 0) {
 
        for(var i = 0; i < eigeneDatenpunkte.length; i++) {
            var alias = eigeneDatenpunkte[i][1];
            
            rotateVerbrauchUndKosten(alias, type, anzahl);
            
            resetVerbrauchUndKosten(alias, type);
            
            schreibeZaehlerstand(alias, type);
        }
    }
}
 
//----------------------------------------------------------------------------//
 
// Tageswechsel
schedule("0 0 * * *", function() {
    setRecognizedChange('Tag', Tag_Anzahl_Werte_in_der_Vergangenheit);
});
 
// Wochenwechsel
schedule("0 0 * * 1", function() {
    setRecognizedChange('Woche', Woche_Anzahl_Werte_in_der_Vergangenheit);
});
 
// Monatswechsel
schedule("0 0 1 * *", function() {
    setRecognizedChange('Monat', Monat_Anzahl_Werte_in_der_Vergangenheit);
});
 
// Quartalswechsel
schedule("0 0 1 */3 *", function() {
    setRecognizedChange('Quartal', Quartal_Anzahl_Werte_in_der_Vergangenheit);
});
 
// Jahreswechsel
schedule("0 0 1 1 *", function() {
    setRecognizedChange('Jahr', Jahr_Anzahl_Werte_in_der_Vergangenheit);
});
 
//----------------------------------------------------------------------------//
 
// Eigene Datenpunkte
function pruefeEigeneDatenpunkte() {
    
    if (eigeneDatenpunkte.length > 0) {
    
        for(var i = 0; i < eigeneDatenpunkte.length; i++) {
            
            var datenpunkt = eigeneDatenpunkte[i][0];
            var alias = eigeneDatenpunkte[i][1];
            var einheit = eigeneDatenpunkte[i][2];
            var einheit_kilo = eigeneDatenpunkte[i][3];
            
            if(logging) console.log("Alias:" + alias + " Datenpunkt:" + datenpunkt + " Einheit:" + einheit + " Einheit_kilo:" + einheit_kilo);
 
            on(datenpunkt, function(obj) {
 
                for(var i = 0; i < eigeneDatenpunkte.length; i++) {
                    
                    if(eigeneDatenpunkte[i][0] === obj.id)    
                        run(obj, eigeneDatenpunkte[i][1], eigeneDatenpunkte[i][2], eigeneDatenpunkte[i][3]);
                }
            });
        }
    }
}
 
pruefeEigeneDatenpunkte();
 
//----------------------------------------------------------------------------//
 
// Einlesen der aktuellen Daten vom Zähler
function run(obj, alias, unit, unit_kilo) {
    
    if (logging) {   
        log('-------- Strommesser ---------');
        log('RegExp-Funktion ausgelöst');
        log('id:           ' + obj.id);
        log('Name:         ' + obj.common.name);   // Waschmaschine Küche:2.ENERGY_COUNTER
        log('channel ID:   ' + obj.channelId);     // hm-rpc.0.MEQ0170864.2
        log('channel Name: ' + obj.channelName);   // Waschmaschine Küche:2
        log('device ID:    ' + obj.deviceId);      // hm-rpc.0.MEQ0170864
        log('device name:  ' + obj.deviceName);    // Küche Waschmaschine
        log('neuer Wert:   ' + obj.newState.val);  // 16499.699982
        log('alter Wert:   ' + obj.oldState.val);  // 16499.699982
    }
 
    // Gerätenamen erstellen
    if (logging) log('vor der Aufbereitung: ' + obj.common.name); 
    
    var geraetename = entferneDatenpunkt(obj.common.name);
 
    if(typeof alias !== "undefined")  {
        if(logging) console.log("Es wird der Aliasname gesetzt:" + alias);
        
        geraetename = alias;
    }
    
    if (logging) log('Nach der Aufbereitung: ' + geraetename); 
    
    if(typeof geraetename !== "undefined") {
        
        //------------------------------------------------------------------------//
        
        var _unit = default_unit;
        var _unit_kilo = default_unit_kilo;
        
        // States erstellen (CreateStates für dieses Gerät)
        if(typeof unit !== "undefined")  {
            _unit = unit;
        }
        
        if(typeof unit_kilo !== "undefined")  {
            _unit_kilo = unit_kilo;
        }
        
        erstelleStates(geraetename, _unit, _unit_kilo);
        
        //------------------------------------------------------------------------//
        
        // Schreiben der neuen Werte
    
        var idKumuliert =  instanz + pfad + geraetename + '.Zaehlerstand.kumuliert';
        
        var NeustartEventuellErkannt = false;
        var NeustartSicherErkannt = false;
        
        var oldState = obj.oldState.val;
        var newState = obj.newState.val;
        var difference = newState - oldState;
    
        if(difference > 0) {
            
            if(oldState !== 0) {
    
                // Kumulierten Wert mit Ist-Wert (inkl. Backup) synchronisieren
                var newValueKumuliert = getState(idKumuliert).val + difference;
                
                newValueKumuliert = parseFloat(newValueKumuliert);
    
                setState(idKumuliert, newValueKumuliert);
                
            } else {
                
                if(newState < getState(pfad + geraetename + '.config.NeustartErkanntAlterWert').val) {
    
                    NeustartSicherErkannt = true;
                }
            }
            
        } else {
            
            // Fall 2 oder 3
            // Irgendetwas läuft außerplanmäßig. Wert wird sicherheitshalber gespeichert und nächster Lauf abgewartet
            NeustartEventuellErkannt = true;
            
            setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', obj.oldState.val);
        }
        
        if(NeustartEventuellErkannt) {
            
            if(logging) {
                var message =  geraetename + '\n'
                                + 'Entweder die CCU oder Stromzähler wurden neugestartet/zurückgesetzt.\n'
                                + 'Dieser Wert wird einmal ignoriert und auf den nächsten Wert gewartet.';
            
                send_message(message);
            }
        }
        
        if(NeustartSicherErkannt) {
    
            // zurücksetzen der Variable
            setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', 0);
            
            //----------------------------------------------------------------//
    
            var message2 = geraetename + '\n'
                        + 'Der Stromzähler (' + geraetename + ') ist übergelaufen, gelöscht oder neugestartet worden (ggf. Stromausfall).\n'
                        + 'newState:' + obj.newState.val + '\n' 
                        + 'oldState:' + obj.oldState.val + '\n'
                        + 'differenz:' + difference + '\n'
                        + 'idKumuliert:' + getState(idKumuliert).val;
    
            send_message(message2);
        }
        
        //--------------------------------------------------------------------//
 
        pruefePreisaenderung();
        
        if(enable_unterschiedlichePreise)
            pruefePreisaenderung(geraetename);
        
        var idStrompreis = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
        var idGrundpreis = instanz + pfad + 'Preis.aktuell.Grundpreis';
        var _zaehler = null;
        
        // aktualisiere den Verbrauch und die Kosten
        if(KumulierterWertIstBereitsInKilo)
           _zaehler    = (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand);
        else
           _zaehler    = (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand);
        
        var _preis      = getState(idStrompreis).val;
        var _grundpreis = getState(idGrundpreis).val;
        
        // Wenn das Gerät einen eigenen Strompreis / Grundpreis hat
        if(enable_unterschiedlichePreise) {
            
            if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val > 0) {
                _preis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val;
 
                if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Strompreis: " + _preis);
            }
            
            if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val > 0) {
                _grundpreis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val;
                
                if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Grundpreis: " + _grundpreis);
            }
        }
 
        berechneVerbrauchUndKosten(geraetename, _zaehler, _preis, _grundpreis); // in kWh
 
        if (logging) log('------------ ENDE ------------');
        
    } else {
        
        var message3 = 'Fehler beim Erstellen des Gerätenamens:\n'
                    + 'obj.common.name: ' + obj.common.name;
        
        send_message(message3);
    }
}
 
cacheSelectorStateMeter.on(function(obj) {
   run(obj);
});
 
cacheSelectorStateEnergyCounter.on(function(obj) {
   run(obj);
});
 
//----------------------------------------------------------------------------//
 
function entferneDatenpunkt(geraet) {
    
    var rueckgabe = geraet;
    
    // ":2.ENERGY_COUNTER" --> ".ENERGY_COUNTER"
    if (geraet.indexOf(".ENERGY_COUNTER") != -1) {
        
        rueckgabe = geraet.substring(0, geraet.indexOf(".ENERGY_COUNTER"));
        
    } else if (geraet.indexOf(".METER") != -1) {
        
        rueckgabe = geraet.substring(0, geraet.indexOf(".METER"));
    }
    
    if (logging) log('entferneDatenpunkt - rueckgabe1:' + rueckgabe);
 
    // Rückgabe sollte keine Sonderzeichen oder Leerzeichen enthalten. Wenn doch, werden die entfernt oder ersetzt
 
    try {
        rueckgabe = checkBlacklist(rueckgabe);
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe);
    }
 
    try {
        if (rueckgabe.charAt(rueckgabe.length - 1) == "-") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
        if (rueckgabe.charAt(rueckgabe.length - 1) == "\\") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
        if (rueckgabe.charAt(rueckgabe.length - 1) == ":") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe);
    }
    
    // per Regexp Leerzeichen entfernen
    try {
        rueckgabe = rueckgabe.replace(/\s/g, "");
    }
    catch(err) {
        if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe + ' error:' + err);
    }
    finally {
        if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe);
    }
 
    return rueckgabe;
}
 
function checkBlacklist(name) {
    
    var _name = "";
    
    if (blacklist.length > 0) {
 
        for(var i = 0; i < blacklist.length; i++) {
          
            if (name.indexOf(blacklist[i]) != -1) {
 
                // Zeichenketten, die in der Blacklist stehen, aus dem Namen löschen
                _name = name.substring(0, name.indexOf(blacklist[i]));
            }
        }
 
        if(_name === "") {
            return name;
        } else {
            return _name;
        }
    
    } else return (name);
}
 
function schreibeZaehlerstand(geraet, zeitraum) { 
    
    var idKumuliert =    instanz + pfad + geraet + '.Zaehlerstand.kumuliert',
        idZaehlerstand = instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum;
    
    // Zählerstand für übergebene Zeitraum und das Gerät in Wh auslesen und in kWh speichern (also durch 1000)
    
    if(KumulierterWertIstBereitsInKilo)
        setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand)) );  
    else
        setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand)) ); 
 
    if (logging) log('Zählerstände für das Gerät ' + geraet + ' (' + zeitraum + ') in Objekten gespeichert');
}
 
function rotateVerbrauchUndKosten(geraet, zeitraum, anzahl) {
 
    // Verbrauch
    if(anzahl > 0) {
        
        for(var i = anzahl; i >= 0; i--) {
            
            var j = i;
            
            j++;
            
            if(getObject(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j)) {
                
                if(i === 0)
                    setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum).val);
                else
                    setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + i).val);
            }
        }
    }
    
    // Kosten
    if(anzahl > 0) {
        
        for(var i = anzahl; i >= 0; i--) {
            
            var j = i;
            
            j++;
            
            if(getObject(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j)) {
                
                if(i === 0)
                    setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten.' + zeitraum).val);
                else
                    setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + i).val);
            }
        }
    }
}
 
function resetVerbrauchUndKosten(geraet, zeitraum) {
    
    // Reset der Stromkosten für den übergebenen Zeitraum
    // Reset des Stromverbrauchs für den übergebenen Zeitraum 
    setState(instanz + pfad + geraet + '.Kosten.' + zeitraum, 0);     
    setState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum, 0);
    
    if (logging) log('Stromkosten und Stromverbrauch für das Gerät ' + geraet + ' (' + zeitraum + ') zurückgesetzt');
} 
 
function berechneVerbrauchUndKosten(geraet, zaehler, preis, grundpreis) {                      
    
    // bei jedem eingehenden Wert pro Gerät
 
    if(preis === 0) {
    
        var message0 = 'Achtung!' + '.\n'
                    + 'Es wurde noch kein Arbeitspreis angegeben.' + '\n' 
                    + 'Ohne Arbeitspreis kann das Skript keine Berechnungen durchführen.' + '\n'
                    + 'Diese Information ist zwingend notwendig!';
        
        log(message0, 'error');
        
    } else {
    
        var _grundpreis = 0;
        
        if(enable_Grundpreis_einberechnen) {
    
            _grundpreis = grundpreis * 12 / 365;
            
            _grundpreis = parseFloat(_grundpreis.toFixed(3));
        }
        
        var grundpreis_tag      = _grundpreis;
        var grundpreis_woche    = _grundpreis * 7;
        var grundpreis_monat    = _grundpreis * 30; 
        var grundpreis_quartal  = _grundpreis * 90;
        var grundpreis_jahr     = _grundpreis * 365;
    
        // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
        setState(instanz + pfad + geraet + '.Kosten.Tag',        parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val) * preis) + grundpreis_tag).toFixed(AnzahlKommastellenKosten) ) );  // Kosten an diesem Tag in €
        
        // Woche
        setState(instanz + pfad + geraet + '.Kosten.Woche',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val) * preis) + grundpreis_woche).toFixed(AnzahlKommastellenKosten) ) );
        
        // Monat
        setState(instanz + pfad + geraet + '.Kosten.Monat',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val) * preis) + grundpreis_monat).toFixed(AnzahlKommastellenKosten) ) );
        
        // Quartal
        setState(instanz + pfad + geraet + '.Kosten.Quartal',    parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val) * preis) + grundpreis_quartal).toFixed(AnzahlKommastellenKosten) ) );
        
        // Jahr
        setState(instanz + pfad + geraet + '.Kosten.Jahr',       parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val) * preis) + grundpreis_jahr).toFixed(AnzahlKommastellenKosten) ) );  
        
        if (logging) log('Stromkosten (' + geraet + ') aktualisiert');
    }
    
    // Verbrauch berechnen
    
    // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
    setState(instanz + pfad + geraet + '.Verbrauch.Tag',     parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val).toFixed(AnzahlKommastellenVerbrauch) ) );           // Verbrauch an diesem Tag in kWh
    // Woche
    setState(instanz + pfad + geraet + '.Verbrauch.Woche',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val).toFixed(AnzahlKommastellenVerbrauch) ) );
    // Monat
    setState(instanz + pfad + geraet + '.Verbrauch.Monat',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val).toFixed(AnzahlKommastellenVerbrauch) ) );
    // Quartal
    setState(instanz + pfad + geraet + '.Verbrauch.Quartal', parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val).toFixed(AnzahlKommastellenVerbrauch) ) );
    // Jahr
    setState(instanz + pfad + geraet + '.Verbrauch.Jahr',    parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val).toFixed(AnzahlKommastellenVerbrauch) ) );
    
    if (logging) log('Stromverbrauch (' + geraet + ') aktualisiert');
}
 
function erstelleStates (geraet, _unit, _unit_kilo) {
    
    // Kumulierter Zählerstand (wird nie kleiner)
    createState(pfad + geraet + '.Zaehlerstand.kumuliert', 0, {name: 'Kumulierter Zählerstand (' + geraet + ')', type: 'number', unit: _unit });
            
    // Zählerstand
    createState(pfad + geraet + '.Zaehlerstand.Tag',     0, {name: 'Zählerstand Tagesbeginn ('       + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Woche',   0, {name: 'Zählerstand Wochenbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Monat',   0, {name: 'Zählerstand Monatsbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Quartal', 0, {name: 'Zählerstand Quartalsbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Zaehlerstand.Jahr',    0, {name: 'Zählerstand Jahresbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
    
    // Verbrauch 
    createState(pfad + geraet + '.Verbrauch.Tag',        0, {name: 'Verbrauch seit Tagesbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Woche',      0, {name: 'Verbrauch seit Wochenbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Monat',      0, {name: 'Verbrauch seit Monatsbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Quartal',    0, {name: 'Verbrauch seit Quartalsbeginn (' + geraet + ')', type: 'number', unit: _unit_kilo });
    createState(pfad + geraet + '.Verbrauch.Jahr',       0, {name: 'Verbrauch seit Jahresbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
            
    // Stromkosten
    createState(pfad + geraet + '.Kosten.Tag',           0, {name: 'Stromkosten heute ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Woche',         0, {name: 'Stromkosten Woche ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Monat',         0, {name: 'Stromkosten Monat ('             + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Quartal',       0, {name: 'Stromkosten Quartal ('           + geraet + ')', type: 'number', unit: '€' });
    createState(pfad + geraet + '.Kosten.Jahr',          0, {name: 'Stromkosten Jahr ('              + geraet + ')', type: 'number', unit: '€' });
    
    // Speichern der Werte in zusätzlichen Variablen
    if(Tag_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Tag_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Tag.Tag_' + i,             0, {name: 'Verbrauch vor ' + i + ' Tag(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Tag.Tag_' + i,                0, {name: 'Stromkosten vor ' + i + ' Tag(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Woche_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Woche_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Woche.Woche_' + i,         0, {name: 'Verbrauch vor ' + i + ' Woche(n) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Woche.Woche_' + i,            0, {name: 'Stromkosten vor ' + i + ' Woche(n) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Monat_Anzahl_Werte_in_der_Vergangenheit > 0) {
 
        for(var i = 1; i <= Monat_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Monat.Monat_' + i,         0, {name: 'Verbrauch vor ' + i + ' Monat(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Monat.Monat_' + i,            0, {name: 'Stromkosten vor ' + i + ' Monat(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Quartal_Anzahl_Werte_in_der_Vergangenheit > 0) {
        
        for(var i = 1; i <= Quartal_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Quartal.Quartal_' + i,     0, {name: 'Verbrauch vor ' + i + ' Quartal(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Quartal.Quartal_' + i,        0, {name: 'Stromkosten vor ' + i + ' Quartal(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
    
    if(Jahr_Anzahl_Werte_in_der_Vergangenheit > 0) {
 
        for(var i = 1; i <= Jahr_Anzahl_Werte_in_der_Vergangenheit; i++) {
            createState(pfad + geraet + '.Verbrauch._Jahr.Jahr_' + i,           0, {name: 'Verbrauch vor ' + i + ' Jahr(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
            createState(pfad + geraet + '.Kosten._Jahr.Jahr_' + i,              0, {name: 'Stromkosten vor ' + i + ' Jahr(en) ('  + geraet + ')', type: 'number', unit:'€'  });
        }
    }
 
    // Neustart von CCU oder Gerät erkannt
    createState(pfad + geraet + '.config.NeustartErkanntAlterWert', 0);
    
    // Gerät hat eigenen Strompreis
    if(enable_unterschiedlichePreise) {
        createState(pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis'            , { name: 'Strompreis - aktueller Arbeitspreis ab Datum (brutto)' ,     unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.aktuell.Grundpreis'              , { name: 'Strompreis - aktueller Grundpreis ab Datum (brutto)'   ,     unit: '€/Monat',    type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Arbeitspreis'                , { name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)' ,         unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Grundpreis'                  , { name: 'Strompreis - neuer Grundpreis ab Datum (brutto)'   ,         unit: '€/Monat',    type: 'number', def: 0 });
        createState(pfad + geraet + '.eigenerPreis.neu.Datum'                       , { name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)', def: "01.01.1970", type: 'string' });
        
        createState(pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt' ,     false, { read: true, write: true, type: "boolean", def: false });
    }
    
    // history bei allen Datenpunkten aktivieren
    if(enable_history) {
        enableHistory(geraet, 'Tag');
        enableHistory(geraet, 'Woche');
        enableHistory(geraet, 'Monat');
        enableHistory(geraet, 'Quartal');
        enableHistory(geraet, 'Jahr');
    }
 
    if (logging) log('States in der Instanz ' + instanz + pfad + ' erstellt');   
}
 
function enableHistory(geraet, zeitraum) {
 
    if(instance_history !== '') {
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Kosten.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Verbrauch.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
        
        sendTo(instance_history, 'enableHistory', {
            id: instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum,
            options: {
                changesOnly:  true,
                debounce:     0,
                retention:    31536000,
                maxLength:    3,
                changesMinDelta: 0.5
            }
        }, function (result) {
            if (result.error) {
                if (logging) log("Fehler beim Aktivieren von History: " + result.error);
            }
        });
    }
}
 
function pruefePreisaenderung(geraet) {
    
    var _Datum = "";
    var _PreisaenderungDurchgefuehrt = "";
    var _Arbeitspreis = "";
    var _Grundpreis = "";
    var _ArbeitspreisNeu = "";
    var _GrundpreisNeu = "";
    
    if(typeof geraet === "undefined") {
        
         // Default Arbeitspreis ändern
 
        _Datum                          = instanz + pfad + 'Preis.neu.Datum';
        _PreisaenderungDurchgefuehrt    = instanz + pfad + 'Preis.neu.PreisaenderungDurchgefuehrt';
        
        _Arbeitspreis       = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
        _Grundpreis         = instanz + pfad + 'Preis.aktuell.Grundpreis';
        _ArbeitspreisNeu    = instanz + pfad + 'Preis.neu.Arbeitspreis';
        _GrundpreisNeu      = instanz + pfad + 'Preis.neu.Grundpreis';
        
    } else {
 
        // Arbeitspreis für Gerät ändern
        
        _Datum                          = instanz + pfad + geraet + '.eigenerPreis.neu.Datum';
        _PreisaenderungDurchgefuehrt    = instanz + pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt';
        
        _Arbeitspreis       = instanz + pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis';
        _Grundpreis         = instanz + pfad + geraet + '.eigenerPreis.aktuell.Grundpreis';
        _ArbeitspreisNeu    = instanz + pfad + geraet + '.eigenerPreis.neu.Arbeitspreis';
        _GrundpreisNeu      = instanz + pfad + geraet + '.eigenerPreis.neu.Grundpreis';
    }
 
    if(getObject(_Datum)) {
        
        var date = getState(_Datum).val;
        
        var Datum_Tag;
        var Datum_Monat;
        var Datum_Jahr;
 
        try {
            var Datum = date.match(/\d{2}(\.|-)\d{2}(\.|-)\d{4}/g).toString();
            
            Datum_Tag = Datum.split(".")[0];
            Datum_Monat = Datum.split(".")[1];
            Datum_Jahr = Datum.split(".")[2];
            
        } catch (err) {
            console.log("Fehler beim Auslesen des Datums. Eventuell falsche Syntax? " + date + " (Error:" + err + ")");
        }
        
        var newdate = new Date(Datum_Monat + " " + Datum_Tag + " " + Datum_Jahr);
 
        var today = new Date();
        today.setHours(0,0,0,0);
 
        if(today.getTime() === newdate.getTime()) {
            
            if(!getState(_PreisaenderungDurchgefuehrt).val) {
 
                setState(_PreisaenderungDurchgefuehrt, true);
                
                var alterArbeitspreis = getState(_Arbeitspreis).val;
                var alterGrundpreis = getState(_Grundpreis).val;
                
                var neuerArbeitspreis = getState(_ArbeitspreisNeu).val;
                var neuerGrundpreis = getState(_GrundpreisNeu).val;
                
                setState(_Arbeitspreis, neuerArbeitspreis);
                setState(_Grundpreis, neuerGrundpreis);
                
                var message =  'Preisänderung für ' + geraet + ' wurde durchgeführt:' + '\n'
                            + 'alter Arbeitspreis:' + alterArbeitspreis + '.\n'
                            + 'alter Grundpeis:' + alterGrundpreis + '.\n'
                            + 'neuer Arbeitspreis:' + neuerArbeitspreis + '.\n'
                            + 'neuer Grundpreis:' + neuerGrundpreis;
                
                send_message(message);
            }
            
        } else if(today.getTime() > newdate.getTime()) {
 
            // Variable zurücksetzen
            setState(_PreisaenderungDurchgefuehrt, false);
        }
    }
}
 
//----------------------------------------------------------------------------//

1zu1 wird das script auch nicht funktionieren du muss die "USER ANPASSUNGEN" schon an deine Datenpunkte anpassen.
Wenn du das Script was du gepostet hast in ioBroker importiert wirst du sehen wo die Fehler liegen(rote Wellenlinien im Code). Die meisten Fehler sind->waren nicht deklarierte Variablen.
Also probiere nochmal mit den Script aus dem Spoiler mit deinen Anpassungen.
Hab es selbst noch nicht ausprobiert, scheint aber genau das zu sein was ich brauche für meine shellys. Danke schon mal an der Schöpfer:+1:

jensus11

Hallo,
ich habe bei mir mehrere Energiemessdosen welche unter Objekte aufgelistet werden.
Eine Option das von allen Geräten die Werte zusammengezählt wird ist nicht vorhanden oder?
Gruss

Hat jemand Telegramm am laufen und könnte seine Config davon posten?

Dutchman

Hey, euch ist bewusst das diese script nicht mehr weiter entwickelt wird und der effort nach SourceAnalytrix gegangen ist :)

xbow42

@Dutchman danke für den Hinweis, Adapter hatte ich schon installiert aber jetzt erst gerafft wie ich die gewünschten DP dazu konfiguriere!

Xsev

Ich suche ein Skript welches mir den Verbauch meiner Shellys zusammen rechnet (geht ja sonst nur über die Shelly Cloud) und idealerweise dann via Float anzeigen lässt in Stunde, Tag, Woche, Monat und Jahr wäre perfekt. Kostenrechner etc brauche ich nicht mir geht es rein um die Verbrauchswerte in Summe der einzelnen Geräte.

xbow42

@Xsev der Hinweis steht doch schon hier 3 Post drüber, denn der neue Adapter von Dutchman "SourceAnalytrix " kann das. logge damit erst mal die shelly-DP.ENERY_Total. dann machst du ein Script was die Werte aus den sourceanalytrix .0.geräten... zusammenzählt. Oder wartest noch etwas bis der Dutchman die Funktionnalität in den Adapter eingebaut hat. ;)
lies dich mal ein hier

Xsev

@xbow42 Danke für die Info!

Sunshinemaker

Hi, irgendwie bekomme ich das Script nicht richitg zum laufen. Mir ist bewußt das es nicht mehr weiter entwickelt wird und das die entwicklung inzwischen in den SourceAnlaytix-Adapter eingeflossen ist. Aber da der zur zeit noch nicht richtig Arbeitet und auch ansonsten das Script für mene bedürfnisse besser passt, würde ich das gerne nehmen.


//jshint maxerr:1000
 // https://github.com/hdering/homematic_stromverbrauch_protokollieren
  
 //----------------------------------------------------------------------------//
  
 // Version: 1.3.3
  
 //----------------------------------------------------------------------------//
 // +++++++++  USER ANPASSUNGEN ++++++++++++++++++++++++
  
 // debug logging
 var logging = true;
  
 // Aktivieren der History Instanz
 var enable_history = false;
  
 // history Instanz
 var instance_history = 'history.0';
  
 // Geräte können unterschiedliche Preise haben
 var enable_unterschiedlichePreise = false;
  
 // Speichern der Werte in zusätzlichen Objekten.
 // Wenn 0, dann deaktiviert
 var Tag_Anzahl_Werte_in_der_Vergangenheit       = 7;
 var Woche_Anzahl_Werte_in_der_Vergangenheit     = 4;
 var Monat_Anzahl_Werte_in_der_Vergangenheit     = 12;
 var Quartal_Anzahl_Werte_in_der_Vergangenheit   = 4;
 var Jahr_Anzahl_Werte_in_der_Vergangenheit      = 2;
  
 // Grundpreis einberechnen
 var enable_Grundpreis_einberechnen = false;
  
 var instance    = '0';
 var instanz     = 'javascript.' + instance + '.';
  
 // Pfad innerhalb der Instanz
 var pfad        = 'Verbrauchszaehler.';
  
 var default_unit = 'Wh';
 var default_unit_kilo = 'kWh';
  
 // Diese Teile werden aus den Gerätenamen entfernt
 var blacklist   = [':1', ':2', ':3', ':4', ':5', ':6', ':7', ':8'];
  
 var AnzahlKommastellenKosten = 2;
 var AnzahlKommastellenVerbrauch = 3;
 var AnzahlKommastellenZaehlerstand = 3;
  
 var KumulierterWertIstBereitsInKilo = false;
  
 var eigeneDatenpunkte = 
 // Fernseher
    [ 'hm-rpc.1.0001D3C99CC3C5.6.ENERGY_COUNTER', 'Steckdose Fernseher', 'Wh', 'kWh' ],

// Kühlschrank
    [ 'hm-rpc.1.0001D3C99C8D73.6.ENERGY_COUNTER', 'Steckdose Kühlschrank', 'Wh', 'kWh' ], 

// Waschmaschine
    [ 'hm-rpc.1.0001D3C99C65D6.6.ENERGY_COUNTER', 'Steckdose Waschmaschine', 'Wh', 'kWh' ] 

     
     // Beispiel:
     // ['Datenpunkt', 'Aliasname', 'Einheit kumulierter Wert', 'Einheit berechnete Werte (kilo/1000)' ],
     
     // [ 'hm-rpc.2.NEQ0861663.1.ENERGY_COUNTER', 'Stromzaehler:1.ENERGY_COUNTER', 'Wh', 'kWh' ],
     // [ 'javascript.1.MeinSonoffGeraet1', 'Strom.Sonoff.MeinSonoffGeraet1', 'Wh', 'kWh' ],
     // [ 'javascript.1.MeinSonoffGeraet2', 'Strom.Sonoff.MeinSonoffGeraet2', 'kWh', 'kWh' ],
     // [ 'javascript.1.MeineGas1', 'Gas.MeinGaszaehler1', 'm3', 'm3' ],
     // [ 'javascript.1.MeineGas2', 'Gas.MeinGaszaehler2', 'm3', 'm3' ],
 ;
  
 // Pushmeldung
 function send_message(text) {
     
     // Hier können die Pushmeldung über alle möglichen Wege verschickt werden.
     
     //console.log(text);
     
     //sendTelegram(text);
 }
  
 // ++++ ENDE USER ANPASSUNGEN ++++++++++++++++++++++++
 //----------------------------------------------------------------------------//
  
 createState(pfad + 'Preis.aktuell.Arbeitspreis', {
     name: 'Strompreis - aktueller Arbeitspreis (brutto)',
     unit: '€/' + default_unit_kilo,
     type: 'number',
     def:  0,
     min:  0
 });
  
 createState(pfad + 'Preis.aktuell.Grundpreis',  {                           
     name: 'Strompreis - aktueller Grundpreis (brutto)',
     unit: '€/Monat',
     type: 'number',
     def:  0,
     min: 0
 });
  
 //----------------------------------
  
 createState(pfad + 'Preis.neu.Arbeitspreis', {
     name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)',
     unit: '€/' + default_unit_kilo,
     type: 'number',
     def:  0,
     min:  0
 });
  
 createState(pfad + 'Preis.neu.Grundpreis',  {                           
     name: 'Strompreis - neuer Grundpreis ab Datum (brutto)',
     unit: '€/Monat',
     type: 'number',
     def:  0,
     min: 0
 });
  
 createState(pfad + 'Preis.neu.Datum',  {                           
     name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)',
     type: 'string',
     def: "01.01.1970",
 });
  
 createState(pfad + 'Preis.neu.PreisaenderungDurchgefuehrt', false, {
   read: true, 
   write: true, 
   type: "boolean", 
   def: false
 });
  
 //----------------------------------------------------------------------------//
  
 var cacheSelectorStateMeter  = $('channel[state.id=*.METER]');
 var cacheSelectorStateEnergyCounter  = $('channel[state.id=*.ENERGY_COUNTER$]');
  
 //----------------------------------------------------------------------------//
  
 function parseObjects(id) {
     var obj = getObject(id);
  
     return entferneDatenpunkt(obj.common.name);
 }
  
 function setRecognizedChange(type, anzahl) {
     
     cacheSelectorStateMeter.each(function (id, i) {
         var geraetename = parseObjects(id);
  
         rotateVerbrauchUndKosten(geraetename, type, anzahl);
         
         resetVerbrauchUndKosten(geraetename, type);
         
         schreibeZaehlerstand(geraetename, type);
     });
  
     cacheSelectorStateEnergyCounter.each(function (id, i) {
         var geraetename = parseObjects(id);
  
         rotateVerbrauchUndKosten(geraetename, type, anzahl);
         
         resetVerbrauchUndKosten(geraetename, type);
         
         schreibeZaehlerstand(geraetename, type);
     });
     
     if (eigeneDatenpunkte.length > 0) {
  
         for(var i = 0; i < eigeneDatenpunkte.length; i++) {
             var alias = eigeneDatenpunkte[i][1];
             
             rotateVerbrauchUndKosten(alias, type, anzahl);
             
             resetVerbrauchUndKosten(alias, type);
             
             schreibeZaehlerstand(alias, type);
         }
     }
 }
  
 //----------------------------------------------------------------------------//
  
 // Tageswechsel
 schedule("0 0 * * *", function() {
     setRecognizedChange('Tag', Tag_Anzahl_Werte_in_der_Vergangenheit);
 });
  
 // Wochenwechsel
 schedule("0 0 * * 1", function() {
     setRecognizedChange('Woche', Woche_Anzahl_Werte_in_der_Vergangenheit);
 });
  
 // Monatswechsel
 schedule("0 0 1 * *", function() {
     setRecognizedChange('Monat', Monat_Anzahl_Werte_in_der_Vergangenheit);
 });
  
 // Quartalswechsel
 schedule("0 0 1 */3 *", function() {
     setRecognizedChange('Quartal', Quartal_Anzahl_Werte_in_der_Vergangenheit);
 });
  
 // Jahreswechsel
 schedule("0 0 1 1 *", function() {
     setRecognizedChange('Jahr', Jahr_Anzahl_Werte_in_der_Vergangenheit);
 });
  
 //----------------------------------------------------------------------------//
  
 // Eigene Datenpunkte
 function pruefeEigeneDatenpunkte() {
     
     if (eigeneDatenpunkte.length > 0) {
     
         for(var i = 0; i < eigeneDatenpunkte.length; i++) {
             
             var datenpunkt = eigeneDatenpunkte[i][0];
             var alias = eigeneDatenpunkte[i][1];
             var einheit = eigeneDatenpunkte[i][2];
             var einheit_kilo = eigeneDatenpunkte[i][3];
             
             if(logging) console.log("Alias:" + alias + " Datenpunkt:" + datenpunkt + " Einheit:" + einheit + " Einheit_kilo:" + einheit_kilo);
  
             on(datenpunkt, function(obj) {
  
                 for(var i = 0; i < eigeneDatenpunkte.length; i++) {
                     
                     if(eigeneDatenpunkte[i][0] === obj.id)    
                         run(obj, eigeneDatenpunkte[i][1], eigeneDatenpunkte[i][2], eigeneDatenpunkte[i][3]);
                 }
             });
         }
     }
 }
  
 pruefeEigeneDatenpunkte();
  
 //----------------------------------------------------------------------------//
  
 // Einlesen der aktuellen Daten vom Zähler
 function run(obj, alias, unit, unit_kilo) {
     
     if (logging) {   
         log('-------- Strommesser ---------');
         log('RegExp-Funktion ausgelöst');
         log('id:           ' + obj.id);
         log('Name:         ' + obj.common.name);   // Waschmaschine Küche:2.ENERGY_COUNTER
         log('channel ID:   ' + obj.channelId);     // hm-rpc.0.MEQ0170864.2
         log('channel Name: ' + obj.channelName);   // Waschmaschine Küche:2
         log('device ID:    ' + obj.deviceId);      // hm-rpc.0.MEQ0170864
         log('device name:  ' + obj.deviceName);    // Küche Waschmaschine
         log('neuer Wert:   ' + obj.newState.val);  // 16499.699982
         log('alter Wert:   ' + obj.oldState.val);  // 16499.699982
     }
  
     // Gerätenamen erstellen
     if (logging) log('vor der Aufbereitung: ' + obj.common.name); 
     
     var geraetename = entferneDatenpunkt(obj.common.name);
  
     if(typeof alias !== "undefined")  {
         if(logging) console.log("Es wird der Aliasname gesetzt:" + alias);
         
         geraetename = alias;
     }
     
     if (logging) log('Nach der Aufbereitung: ' + geraetename); 
     
     if(typeof geraetename !== "undefined") {
         
         //------------------------------------------------------------------------//
         
         _unit = default_unit;
         _unit_kilo = default_unit_kilo;
         
         // States erstellen (CreateStates für dieses Gerät)
         if(typeof unit !== "undefined")  {
             _unit = unit;
         }
         
         if(typeof unit_kilo !== "undefined")  {
             _unit_kilo = unit_kilo;
         }
         
         erstelleStates(geraetename, _unit, _unit_kilo);
         
         //------------------------------------------------------------------------//
         
         // Schreiben der neuen Werte
     
         var idKumuliert =  instanz + pfad + geraetename + '.Zaehlerstand.kumuliert';
         
         var NeustartEventuellErkannt = false;
         var NeustartSicherErkannt = false;
         
         var oldState = obj.oldState.val;
         var newState = obj.newState.val;
         var difference = newState - oldState;
     
         if(difference > 0) {
             
             if(oldState !== 0) {
     
                 // Kumulierten Wert mit Ist-Wert (inkl. Backup) synchronisieren
                 var newValueKumuliert = getState(idKumuliert).val + difference;
                 
                 newValueKumuliert = parseFloat(newValueKumuliert);
     
                 setState(idKumuliert, newValueKumuliert);
                 
             } else {
                 
                 if(newState < getState(pfad + geraetename + '.config.NeustartErkanntAlterWert').val) {
     
                     NeustartSicherErkannt = true;
                 }
             }
             
         } else {
             
             // Fall 2 oder 3
             // Irgendetwas läuft außerplanmäßig. Wert wird sicherheitshalber gespeichert und nächster Lauf abgewartet
             NeustartEventuellErkannt = true;
             
             setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', obj.oldState.val);
         }
         
         if(NeustartEventuellErkannt) {
             
             if(logging) {
                 var message =  geraetename + '\n'
                                 + 'Entweder die CCU oder Stromzähler wurden neugestartet/zurückgesetzt.\n'
                                 + 'Dieser Wert wird einmal ignoriert und auf den nächsten Wert gewartet.';
             
                 send_message(message);
             }
         }
         
         if(NeustartSicherErkannt) {
     
             // zurücksetzen der Variable
             setState(pfad + geraetename + '.config.NeustartErkanntAlterWert', 0);
             
             //----------------------------------------------------------------//
     
             var message2 = geraetename + '\n'
                         + 'Der Stromzähler (' + geraetename + ') ist übergelaufen, gelöscht oder neugestartet worden (ggf. Stromausfall).\n'
                         + 'newState:' + obj.newState.val + '\n' 
                         + 'oldState:' + obj.oldState.val + '\n'
                         + 'differenz:' + difference + '\n'
                         + 'idKumuliert:' + getState(idKumuliert).val;
     
             send_message(message2);
         }
         
         //--------------------------------------------------------------------//
  
         pruefePreisaenderung();
         
         if(enable_unterschiedlichePreise)
             pruefePreisaenderung(geraetename);
         
         var idStrompreis = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
         var idGrundpreis = instanz + pfad + 'Preis.aktuell.Grundpreis';
         
         // aktualisiere den Verbrauch und die Kosten
         if(KumulierterWertIstBereitsInKilo)
             _zaehler    = (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand);
         else
             _zaehler    = (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand);
         
         _preis      = getState(idStrompreis).val;
         _grundpreis = getState(idGrundpreis).val;
         
         // Wenn das Gerät einen eigenen Strompreis / Grundpreis hat
         if(enable_unterschiedlichePreise) {
             
             if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val > 0) {
                 _preis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Arbeitspreis').val;
  
                 if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Strompreis: " + _preis);
             }
             
             if(getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val > 0) {
                 _grundpreis = getState(instanz + pfad + geraetename + '.eigenerPreis.aktuell.Grundpreis').val;
                 
                 if (logging) console.log("Das Gerät:" + geraetename + " hat eigenen Grundpreis: " + _grundpreis);
             }
         }
  
         berechneVerbrauchUndKosten(geraetename, _zaehler, _preis, _grundpreis); // in kWh
  
         if (logging) log('------------ ENDE ------------');
         
     } else {
         
         var message3 = 'Fehler beim Erstellen des Gerätenamens:\n'
                     + 'obj.common.name: ' + obj.common.name;
         
         send_message(message3);
     }
 }
  
 cacheSelectorStateMeter.on(function(obj) {
    run(obj);
 });
  
 cacheSelectorStateEnergyCounter.on(function(obj) {
    run(obj);
 });
  
 //----------------------------------------------------------------------------//
  
 function entferneDatenpunkt(geraet) {
     
     var rueckgabe = geraet;
     
     // ":2.ENERGY_COUNTER" --> ".ENERGY_COUNTER"
     if (geraet.indexOf(".ENERGY_COUNTER") != -1) {
         
         rueckgabe = geraet.substring(0, geraet.indexOf(".ENERGY_COUNTER"));
         
     } else if (geraet.indexOf(".METER") != -1) {
         
         rueckgabe = geraet.substring(0, geraet.indexOf(".METER"));
     }
     
     if (logging) log('entferneDatenpunkt - rueckgabe1:' + rueckgabe);
  
     // Rückgabe sollte keine Sonderzeichen oder Leerzeichen enthalten. Wenn doch, werden die entfernt oder ersetzt
  
     try {
         rueckgabe = checkBlacklist(rueckgabe);
     }
     catch(err) {
         if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe + ' error:' + err);
     }
     finally {
         if (logging) log('entferneDatenpunkt - rueckgabe2:' + rueckgabe);
     }
  
     try {
         if (rueckgabe.charAt(rueckgabe.length - 1) == "-") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
         if (rueckgabe.charAt(rueckgabe.length - 1) == "\\") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
         if (rueckgabe.charAt(rueckgabe.length - 1) == ":") rueckgabe = rueckgabe.substr(0, rueckgabe.length - 1);
     }
     catch(err) {
         if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe + ' error:' + err);
     }
     finally {
         if (logging) log('entferneDatenpunkt - rueckgabe3:' + rueckgabe);
     }
     
     // per Regexp Leerzeichen entfernen
     try {
         rueckgabe = rueckgabe.replace(/\s/g, "");
     }
     catch(err) {
         if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe + ' error:' + err);
     }
     finally {
         if (logging) log('entferneDatenpunkt - rueckgabe4:' + rueckgabe);
     }
  
     return rueckgabe;
 }
  
 function checkBlacklist(name) {
     
     var _name = "";
     
     if (blacklist.length > 0) {
  
         for(var i = 0; i < blacklist.length; i++) {
           
             if (name.indexOf(blacklist[i]) != -1) {
  
                 // Zeichenketten, die in der Blacklist stehen, aus dem Namen löschen
                 _name = name.substring(0, name.indexOf(blacklist[i]));
             }
         }
  
         if(_name === "") {
             return name;
         } else {
             return _name;
         }
     
     } else return (name);
 }
  
 function schreibeZaehlerstand(geraet, zeitraum) { 
     
     var idKumuliert =    instanz + pfad + geraet + '.Zaehlerstand.kumuliert',
         idZaehlerstand = instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum;
     
     // Zählerstand für übergebene Zeitraum und das Gerät in Wh auslesen und in kWh speichern (also durch 1000)
     
     if(KumulierterWertIstBereitsInKilo)
         setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val).toFixed(AnzahlKommastellenZaehlerstand)) );  
     else
         setState(idZaehlerstand, parseFloat( (getState(idKumuliert).val / 1000).toFixed(AnzahlKommastellenZaehlerstand)) ); 
  
     if (logging) log('Zählerstände für das Gerät ' + geraet + ' (' + zeitraum + ') in Objekten gespeichert');
 }
  
 function rotateVerbrauchUndKosten(geraet, zeitraum, anzahl) {
  
     // Verbrauch
     if(anzahl > 0) {
         
         for(var i = anzahl; i >= 0; i--) {
             
             var j = i;
             
             j++;
             
             if(getObject(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j)) {
                 
                 if(i === 0)
                     setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum).val);
                 else
                     setState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Verbrauch._' + zeitraum + '.' + zeitraum + '_' + i).val);
             }
         }
     }
     
     // Kosten
     if(anzahl > 0) {
         
         for(var i = anzahl; i >= 0; i--) {
             
             var j = i;
             
             j++;
             
             if(getObject(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j)) {
                 
                 if(i === 0)
                     setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten.' + zeitraum).val);
                 else
                     setState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + j, getState(instanz + pfad + geraet + '.Kosten._' + zeitraum + '.' + zeitraum + '_' + i).val);
             }
         }
     }
 }
  
 function resetVerbrauchUndKosten(geraet, zeitraum) {
     
     // Reset der Stromkosten für den übergebenen Zeitraum
     // Reset des Stromverbrauchs für den übergebenen Zeitraum 
     setState(instanz + pfad + geraet + '.Kosten.' + zeitraum, 0);     
     setState(instanz + pfad + geraet + '.Verbrauch.' + zeitraum, 0);
     
     if (logging) log('Stromkosten und Stromverbrauch für das Gerät ' + geraet + ' (' + zeitraum + ') zurückgesetzt');
 } 
  
 function berechneVerbrauchUndKosten(geraet, zaehler, preis, grundpreis) {                      
     
     // bei jedem eingehenden Wert pro Gerät
  
     if(preis === 0) {
     
         var message0 = 'Achtung!' + '.\n'
                     + 'Es wurde noch kein Arbeitspreis angegeben.' + '\n' 
                     + 'Ohne Arbeitspreis kann das Skript keine Berechnungen durchführen.' + '\n'
                     + 'Diese Information ist zwingend notwendig!';
         
         log(message0, 'error');
         
     } else {
     
         var _grundpreis = 0;
         
         if(enable_Grundpreis_einberechnen) {
     
             _grundpreis = grundpreis * 12 / 365;
             
             _grundpreis = parseFloat(_grundpreis.toFixed(3));
         }
         
         grundpreis_tag      = _grundpreis;
         grundpreis_woche    = _grundpreis * 7;
         grundpreis_monat    = _grundpreis * 30; 
         grundpreis_quartal  = _grundpreis * 90;
         grundpreis_jahr     = _grundpreis * 365;
     
         // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
         setState(instanz + pfad + geraet + '.Kosten.Tag',        parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val) * preis) + grundpreis_tag).toFixed(AnzahlKommastellenKosten) ) );  // Kosten an diesem Tag in €
         
         // Woche
         setState(instanz + pfad + geraet + '.Kosten.Woche',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val) * preis) + grundpreis_woche).toFixed(AnzahlKommastellenKosten) ) );
         
         // Monat
         setState(instanz + pfad + geraet + '.Kosten.Monat',      parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val) * preis) + grundpreis_monat).toFixed(AnzahlKommastellenKosten) ) );
         
         // Quartal
         setState(instanz + pfad + geraet + '.Kosten.Quartal',    parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val) * preis) + grundpreis_quartal).toFixed(AnzahlKommastellenKosten) ) );
         
         // Jahr
         setState(instanz + pfad + geraet + '.Kosten.Jahr',       parseFloat( (((zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val) * preis) + grundpreis_jahr).toFixed(AnzahlKommastellenKosten) ) );  
         
         if (logging) log('Stromkosten (' + geraet + ') aktualisiert');
     }
     
     // Verbrauch berechnen
     
     // Tag [Verbrauchskosten = (Zähler_ist - Zähler_Tagesbeginn) * Preis ] --- zaehler muss immer größer sein als Tages, Wochen, etc.-Wert
     setState(instanz + pfad + geraet + '.Verbrauch.Tag',     parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Tag').val).toFixed(AnzahlKommastellenVerbrauch) ) );           // Verbrauch an diesem Tag in kWh
  
     // Woche
     setState(instanz + pfad + geraet + '.Verbrauch.Woche',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Woche').val).toFixed(AnzahlKommastellenVerbrauch) ) );
  
     // Monat
     setState(instanz + pfad + geraet + '.Verbrauch.Monat',   parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Monat').val).toFixed(AnzahlKommastellenVerbrauch) ) );
  
     // Quartal
     setState(instanz + pfad + geraet + '.Verbrauch.Quartal', parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Quartal').val).toFixed(AnzahlKommastellenVerbrauch) ) );
  
     // Jahr
     setState(instanz + pfad + geraet + '.Verbrauch.Jahr',    parseFloat(   (zaehler - getState(instanz + pfad + geraet + '.Zaehlerstand.Jahr').val).toFixed(AnzahlKommastellenVerbrauch) ) );
     
     if (logging) log('Stromverbrauch (' + geraet + ') aktualisiert');
 }
  
 function erstelleStates (geraet, _unit, _unit_kilo) {
     
     // Kumulierter Zählerstand (wird nie kleiner)
     createState(pfad + geraet + '.Zaehlerstand.kumuliert', 0, {name: 'Kumulierter Zählerstand (' + geraet + ')', type: 'number', unit: _unit });
             
     // Zählerstand
     createState(pfad + geraet + '.Zaehlerstand.Tag',     0, {name: 'Zählerstand Tagesbeginn ('       + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Zaehlerstand.Woche',   0, {name: 'Zählerstand Wochenbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Zaehlerstand.Monat',   0, {name: 'Zählerstand Monatsbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Zaehlerstand.Quartal', 0, {name: 'Zählerstand Quartalsbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Zaehlerstand.Jahr',    0, {name: 'Zählerstand Jahresbeginn ('      + geraet + ')', type: 'number', unit: _unit_kilo });
     
     // Verbrauch 
     createState(pfad + geraet + '.Verbrauch.Tag',        0, {name: 'Verbrauch seit Tagesbeginn ('    + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Verbrauch.Woche',      0, {name: 'Verbrauch seit Wochenbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Verbrauch.Monat',      0, {name: 'Verbrauch seit Monatsbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Verbrauch.Quartal',    0, {name: 'Verbrauch seit Quartalsbeginn (' + geraet + ')', type: 'number', unit: _unit_kilo });
     createState(pfad + geraet + '.Verbrauch.Jahr',       0, {name: 'Verbrauch seit Jahresbeginn ('   + geraet + ')', type: 'number', unit: _unit_kilo });
             
     // Stromkosten
     createState(pfad + geraet + '.Kosten.Tag',           0, {name: 'Stromkosten heute ('             + geraet + ')', type: 'number', unit: '€' });
     createState(pfad + geraet + '.Kosten.Woche',         0, {name: 'Stromkosten Woche ('             + geraet + ')', type: 'number', unit: '€' });
     createState(pfad + geraet + '.Kosten.Monat',         0, {name: 'Stromkosten Monat ('             + geraet + ')', type: 'number', unit: '€' });
     createState(pfad + geraet + '.Kosten.Quartal',       0, {name: 'Stromkosten Quartal ('           + geraet + ')', type: 'number', unit: '€' });
     createState(pfad + geraet + '.Kosten.Jahr',          0, {name: 'Stromkosten Jahr ('              + geraet + ')', type: 'number', unit: '€' });
     
     // Speichern der Werte in zusätzlichen Variablen
     if(Tag_Anzahl_Werte_in_der_Vergangenheit > 0) {
         
         for(var i = 1; i <= Tag_Anzahl_Werte_in_der_Vergangenheit; i++) {
             createState(pfad + geraet + '.Verbrauch._Tag.Tag_' + i,             0, {name: 'Verbrauch vor ' + i + ' Tag(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
             createState(pfad + geraet + '.Kosten._Tag.Tag_' + i,                0, {name: 'Stromkosten vor ' + i + ' Tag(en) ('  + geraet + ')', type: 'number', unit:'€'  });
         }
     }
     
     if(Woche_Anzahl_Werte_in_der_Vergangenheit > 0) {
         
         for(var i = 1; i <= Woche_Anzahl_Werte_in_der_Vergangenheit; i++) {
             createState(pfad + geraet + '.Verbrauch._Woche.Woche_' + i,         0, {name: 'Verbrauch vor ' + i + ' Woche(n) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
             createState(pfad + geraet + '.Kosten._Woche.Woche_' + i,            0, {name: 'Stromkosten vor ' + i + ' Woche(n) ('  + geraet + ')', type: 'number', unit:'€'  });
         }
     }
     
     if(Monat_Anzahl_Werte_in_der_Vergangenheit > 0) {
  
         for(var i = 1; i <= Monat_Anzahl_Werte_in_der_Vergangenheit; i++) {
             createState(pfad + geraet + '.Verbrauch._Monat.Monat_' + i,         0, {name: 'Verbrauch vor ' + i + ' Monat(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
             createState(pfad + geraet + '.Kosten._Monat.Monat_' + i,            0, {name: 'Stromkosten vor ' + i + ' Monat(en) ('  + geraet + ')', type: 'number', unit:'€'  });
         }
     }
     
     if(Quartal_Anzahl_Werte_in_der_Vergangenheit > 0) {
         
         for(var i = 1; i <= Quartal_Anzahl_Werte_in_der_Vergangenheit; i++) {
             createState(pfad + geraet + '.Verbrauch._Quartal.Quartal_' + i,     0, {name: 'Verbrauch vor ' + i + ' Quartal(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
             createState(pfad + geraet + '.Kosten._Quartal.Quartal_' + i,        0, {name: 'Stromkosten vor ' + i + ' Quartal(en) ('  + geraet + ')', type: 'number', unit:'€'  });
         }
     }
     
     if(Jahr_Anzahl_Werte_in_der_Vergangenheit > 0) {
  
         for(var i = 1; i <= Jahr_Anzahl_Werte_in_der_Vergangenheit; i++) {
             createState(pfad + geraet + '.Verbrauch._Jahr.Jahr_' + i,           0, {name: 'Verbrauch vor ' + i + ' Jahr(en) ('    + geraet + ')', type: 'number', unit: _unit_kilo });
             createState(pfad + geraet + '.Kosten._Jahr.Jahr_' + i,              0, {name: 'Stromkosten vor ' + i + ' Jahr(en) ('  + geraet + ')', type: 'number', unit:'€'  });
         }
     }
  
     // Neustart von CCU oder Gerät erkannt
     createState(pfad + geraet + '.config.NeustartErkanntAlterWert', 0);
     
     // Gerät hat eigenen Strompreis
     if(enable_unterschiedlichePreise) {
         createState(pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis'            , { name: 'Strompreis - aktueller Arbeitspreis ab Datum (brutto)' ,     unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
         createState(pfad + geraet + '.eigenerPreis.aktuell.Grundpreis'              , { name: 'Strompreis - aktueller Grundpreis ab Datum (brutto)'   ,     unit: '€/Monat',    type: 'number', def: 0 });
         createState(pfad + geraet + '.eigenerPreis.neu.Arbeitspreis'                , { name: 'Strompreis - neuer Arbeitspreis ab Datum (brutto)' ,         unit: '€/' + _unit_kilo,      type: 'number', def: 0 });
         createState(pfad + geraet + '.eigenerPreis.neu.Grundpreis'                  , { name: 'Strompreis - neuer Grundpreis ab Datum (brutto)'   ,         unit: '€/Monat',    type: 'number', def: 0 });
         createState(pfad + geraet + '.eigenerPreis.neu.Datum'                       , { name: 'Strompreis und Grundpreis ab folgendem Datum zur Berechnung heranziehen (Beispiel 01.01.2019)', def: "01.01.1970", type: 'string' });
         
         createState(pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt' ,     false, { read: true, write: true, type: "boolean", def: false });
     }
     
     // history bei allen Datenpunkten aktivieren
     if(enable_history) {
         enableHistory(geraet, 'Tag');
         enableHistory(geraet, 'Woche');
         enableHistory(geraet, 'Monat');
         enableHistory(geraet, 'Quartal');
         enableHistory(geraet, 'Jahr');
     }
  
     if (logging) log('States in der Instanz ' + instanz + pfad + ' erstellt');   
 }
  
 function enableHistory(geraet, zeitraum) {
  
     if(instance_history !== '') {
         
         sendTo(instance_history, 'enableHistory', {
             id: instanz + pfad + geraet + '.Kosten.' + zeitraum,
             options: {
                 changesOnly:  true,
                 debounce:     0,
                 retention:    31536000,
                 maxLength:    3,
                 changesMinDelta: 0.5
             }
         }, function (result) {
             if (result.error) {
                 if (logging) log("Fehler beim Aktivieren von History: " + result.error);
             }
         });
         
         sendTo(instance_history, 'enableHistory', {
             id: instanz + pfad + geraet + '.Verbrauch.' + zeitraum,
             options: {
                 changesOnly:  true,
                 debounce:     0,
                 retention:    31536000,
                 maxLength:    3,
                 changesMinDelta: 0.5
             }
         }, function (result) {
             if (result.error) {
                 if (logging) log("Fehler beim Aktivieren von History: " + result.error);
             }
         });
         
         sendTo(instance_history, 'enableHistory', {
             id: instanz + pfad + geraet + '.Zaehlerstand.' + zeitraum,
             options: {
                 changesOnly:  true,
                 debounce:     0,
                 retention:    31536000,
                 maxLength:    3,
                 changesMinDelta: 0.5
             }
         }, function (result) {
             if (result.error) {
                 if (logging) log("Fehler beim Aktivieren von History: " + result.error);
             }
         });
     }
 }
  
 function pruefePreisaenderung(geraet) {
     
     var _Datum = "";
     var _PreisaenderungDurchgefuehrt = "";
     var _Arbeitspreis = "";
     var _Grundpreis = "";
     var _ArbeitspreisNeu = "";
     var _GrundpreisNeu = "";
     
     if(typeof geraet === "undefined") {
         
          // Default Arbeitspreis ändern
  
         _Datum                          = instanz + pfad + 'Preis.neu.Datum';
         _PreisaenderungDurchgefuehrt    = instanz + pfad + 'Preis.neu.PreisaenderungDurchgefuehrt';
         
         _Arbeitspreis       = instanz + pfad + 'Preis.aktuell.Arbeitspreis';
         _Grundpreis         = instanz + pfad + 'Preis.aktuell.Grundpreis';
         _ArbeitspreisNeu    = instanz + pfad + 'Preis.neu.Arbeitspreis';
         _GrundpreisNeu      = instanz + pfad + 'Preis.neu.Grundpreis';
         
     } else {
  
         // Arbeitspreis für Gerät ändern
         
         _Datum                          = instanz + pfad + geraet + '.eigenerPreis.neu.Datum';
         _PreisaenderungDurchgefuehrt    = instanz + pfad + geraet + '.eigenerPreis.neu.PreisaenderungDurchgefuehrt';
         
         _Arbeitspreis       = instanz + pfad + geraet + '.eigenerPreis.aktuell.Arbeitspreis';
         _Grundpreis         = instanz + pfad + geraet + '.eigenerPreis.aktuell.Grundpreis';
         _ArbeitspreisNeu    = instanz + pfad + geraet + '.eigenerPreis.neu.Arbeitspreis';
         _GrundpreisNeu      = instanz + pfad + geraet + '.eigenerPreis.neu.Grundpreis';
     }
  
     if(getObject(_Datum)) {
         
         var date = getState(_Datum).val;
         
         var Datum_Tag;
         var Datum_Monat;
         var Datum_Jahr;
  
         try {
             var Datum = date.match(/\d{2}(\.|-)\d{2}(\.|-)\d{4}/g).toString();
             
             Datum_Tag = Datum.split(".")[0];
             Datum_Monat = Datum.split(".")[1];
             Datum_Jahr = Datum.split(".")[2];
             
         } catch (err) {
             console.log("Fehler beim Auslesen des Datums. Eventuell falsche Syntax? " + date + " (Error:" + err + ")");
         }
         
         newdate = new Date(Datum_Monat + " " + Datum_Tag + " " + Datum_Jahr);
  
         var today = new Date();
         today.setHours(0,0,0,0);
  
         if(today.getTime() === newdate.getTime()) {
             
             if(!getState(_PreisaenderungDurchgefuehrt).val) {
  
                 setState(_PreisaenderungDurchgefuehrt, true);
                 
                 var alterArbeitspreis = getState(_Arbeitspreis).val;
                 var alterGrundpreis = getState(_Grundpreis).val;
                 
                 var neuerArbeitspreis = getState(_ArbeitspreisNeu).val;
                 var neuerGrundpreis = getState(_GrundpreisNeu).val;
                 
                 setState(_Arbeitspreis, neuerArbeitspreis);
                 setState(_Grundpreis, neuerGrundpreis);
                 
                 var message =  'Preisänderung für ' + geraet + ' wurde durchgeführt:' + '\n'
                             + 'alter Arbeitspreis:' + alterArbeitspreis + '.\n'
                             + 'alter Grundpeis:' + alterGrundpreis + '.\n'
                             + 'neuer Arbeitspreis:' + neuerArbeitspreis + '.\n'
                             + 'neuer Grundpreis:' + neuerGrundpreis;
                 
                 send_message(message);
             }
             
         } else if(today.getTime() > newdate.getTime()) {
  
             // Variable zurücksetzen
             setState(_PreisaenderungDurchgefuehrt, false);
         }
     }
 }
  
 //----------------------------------------------------------------------------//

Ich weiß leider nicht was das Problem mit den eigenen Datenpunkten ist bzw was ich falsch gemacht habe. Der dazugehörige fhler aus dem log.

javascript.0	2020-06-14 16:52:04.156	error	(3230) at processTicksAndRejections (internal/process/task_queues.js:97:5)
javascript.0	2020-06-14 16:52:04.155	error	(3230) at runMicrotasks (<anonymous>)
javascript.0	2020-06-14 16:52:04.154	error	(3230) at /opt/iobroker/node_modules/standard-as-callback/built/index.js:19:49
javascript.0	2020-06-14 16:52:04.153	error	(3230) at tryCatcher (/opt/iobroker/node_modules/standard-as-callback/built/utils.js:11:23)
javascript.0	2020-06-14 16:52:04.153	error	(3230) at /opt/iobroker/node_modules/iobroker.js-controller/lib/states/statesInRedis.js:616:17
javascript.0	2020-06-14 16:52:04.152	error	(3230) at /opt/iobroker/node_modules/iobroker.javascript/main.js:1112:17
javascript.0	2020-06-14 16:52:04.152	error	(3230) at /opt/iobroker/node_modules/iobroker.javascript/main.js:1521:17
javascript.0	2020-06-14 16:52:04.150	error	(3230) at prepareScript (/opt/iobroker/node_modules/iobroker.javascript/main.js:1468:37)
javascript.0	2020-06-14 16:52:04.149	error	(3230) at compile (/opt/iobroker/node_modules/iobroker.javascript/main.js:1245:28)
javascript.0	2020-06-14 16:52:04.149	error	(3230) at Object.createScript (vm.js:263:10)
javascript.0	2020-06-14 16:52:04.148	error	(3230) at new Script (vm.js:88:7)
javascript.0	2020-06-14 16:52:04.148	error	(3230) SyntaxError: Invalid destructuring assignment target
javascript.0	2020-06-14 16:52:04.147	error	(3230) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
javascript.0	2020-06-14 16:52:04.147	error	(3230) [ 'hm-rpc.1.0001D3C99C8D73.6.ENERGY_COUNTER', 'Steckdose Kühlschrank', 'Wh', 'kWh' ],
javascript.0	2020-06-14 16:52:04.146	error	at script.js.systemzustaende.Stromzähler:58
javascript.0	2020-06-14 16:52:04.146	error	(3230) script.js.systemzustaende.Stromzähler compile failed:
javascript.0	2020-06-14 16:52:04.137	info	(3230) Start javascript script.js.systemzustaende.Stromzähler

Glasfaser

@Sunshinemaker sagte in [Vorlage] Stromverbrauch protokollieren - (etwas optimiert):

var eigeneDatenpunkte =

Ersetze mal die Zeilen 53 bis 73 .. gegen :

 var eigeneDatenpunkte = [

 // Fernseher
    [ 'hm-rpc.1.0001D3C99CC3C5.6.ENERGY_COUNTER', 'Steckdose Fernseher', 'Wh', 'kWh' ],

// Kühlschrank
    [ 'hm-rpc.1.0001D3C99C8D73.6.ENERGY_COUNTER', 'Steckdose Kühlschrank', 'Wh', 'kWh' ], 

// Waschmaschine
    [ 'hm-rpc.1.0001D3C99C65D6.6.ENERGY_COUNTER', 'Steckdose Waschmaschine', 'Wh', 'kWh' ] ,
];
 // Pushmeldung

Sunshinemaker

@Glasfaser Ich danke dir :+1: :grinning:

Irgendwann werd ich sowas auchmal verstehen :tired_face: oder auch nicht

Community Forum

NEWS

[Vorlage] Stromverbrauch protokollieren - (etwas optimiert)

Support us

677

32.5k

81.6k

1.3m