[Major Update] SourceAnalytix v0.4.7-beta.0 released !

[Willi-Wunder]

@ostseereiter
@babl
Hi, habe genau das gleiche Problem mit dem Adapter. Hab ein Skript gefunden, welche meine Wünsche bisher alle erfüllt. Hoffe ich darf es hier posten, soll ja schließlich erstmal helfen

//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 = 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 = [
    
    // Beispiel:
    // ['Datenpunkt', 'Aliasname', 'Einheit kumulierter Wert', 'Einheit berechnete Werte (kilo/1000)' ],
    

  [ 'shelly.0.SHEM-3#84CCA8AD304A#1.Total.ConsumedPower'/*Total consumed energy*/,'Verbrauch_Waermepumpe', 'Wh', 'kWh' ],

    // [ '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);
        }
    }
}

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

Wenn dies nicht erwünscht ist, bitte löschen.

Gruß Willi

[Dutchman]

Für dev 0 Problem leider warten auf neue js-controller Version

[David G.]

@Dutchman

Was ist das dev0 Problem denn?
Lese in den ganzen Posts immer von.
Finde aber nicht, wie es sich äußert.

Bei mir läuft bisher alles gut.

[Willi-Wunder]

@David-G
Man hat plötzlich negativ Werte drin......

[MichMein]

@Dutchman
Wie sieht es denn bezüglich der previous Daten aus, oder werden diese auch erst mit den neuen JS-Controller funktionieren?

[Dutchman]

@MichMein sagte in [Major Update] SourceAnalytix v0.4.7-beta.0 released !:

@Dutchman
Wie sieht es denn bezüglich der previous Daten aus, oder werden diese auch erst mit den neuen JS-Controller funktionieren?

Sie nehme ich in dem Update dazu mit, wen es die Woche passt noch eher

[klassisch]

Vielen Dank für den prima Adapter.
Habe ihn mir heute unstalliert und er hat die Objekte angelegt.
Dabei ist mir peinlicherweise aufgefallen, daß ich bisher bei den Kubikmeter immer falsche Dimensionen angegeben habe.
Der Adapter erwartet bei der automatischen Erkennung m³, mit meinem m^3 kann er nichts anfangen.
Aber wie bekommt man beim manuellen (oder auch skriptgesteuerten) Anlegen die unit m³ in den ioBroker? Klasr, die frage hat jetzt nichts mit dem Adapter zu tun. Der Adapter hat mir nur gezeigt, daß ich das seit Jahren falsch mache.

[quorle]

Hab leider auch ein Problem mit dem Adapter.
Meine Werte werden pro Tag für den Gaszähler nicht aktualisiert und daher auch keine Kosten angezeigt.
Eventuell hat auch jemand das Problem.

Aktuell habe ich die Version: 0.4.8-alpha.2

Fehlerbild:

Einstellung Datenpunkt:

Adapterkonfig:

[Habedere]

Servus,
ich habe auch ein paar Probleme mit dem Adapter - der in der Vergangenheit aber einwandfrei lief...

sourceanalytix.0	2020-12-30 18:28:21.753	error	(4836) No cost type defined for mbus.0.PAD-1194840.data.0-0-Current, please Select Type of calculation at state setting
sourceanalytix.0	2020-12-30 18:28:21.752	error	(4836) Cannot execute calculations for mbus.0.PAD-1194840.data.0-0-Current adjust settings !
sourceanalytix.0	2020-12-30 18:28:21.747	error	(4836) No cost type defined for mbus.0.LUG-67578194.data.2-0-Current, please Select Type of calculation at state setting
sourceanalytix.0	2020-12-30 18:28:21.745	error	(4836) Cannot execute calculations for mbus.0.LUG-67578194.data.2-0-Current adjust settings !
sourceanalytix.0	2020-12-30 18:28:21.740	error	(4836) No cost type defined for mbus.0.LUG-67578190.data.2-0-Current, please Select Type of calculation at state setting
sourceanalytix.0	2020-12-30 18:28:21.739	error	(4836) Cannot execute calculations for mbus.0.LUG-67578190.data.2-0-Current adjust settings !

[MichMein]

@quorle hi, du hast beim Preis pro Einheit ein Komma anstatt einem Punkt eingetragen. Und ich weiß nicht genau ob Du bei den Anfangswerten eventuell auch Punkte nehmen musst.

[quorle]

@MichMein
Hab nun mal alle Komma durch Punkte ersetzt. Mal sehen, was sich jetzt so die Tage tut. Hoffe der Adapter bekommt mal ein Update

[MichMein]

@quorle Sind denn jetzt die "null" Werte verschwunden?

[quorle]

@MichMein sagte in [Major Update] SourceAnalytix v0.4.7-beta.0 released !:

@quorle Sind denn jetzt die "null" Werte verschwunden?

Ja, bislang sieht alles gut aus. Werde jetzt mal eine Woche warten, wie es sich entwickelt. Sollte es nicht anders werden, melde ich mich einfach nochmal hier

[Michi_Pi]

@klassisch einfach in den Datenpunkteinstellung oder in der RAW "m³" bei Maßeinheit eingeben.

[klassisch]

@Michi_Pi Danke, mit copy&paste gehts, aber meine Tastatur scheint das ansonsten nicht herzugeben. Halt, doch. Wer suchen kann wird schlauer. Alt Gr 3 . Da verstecken sich die etwas kleineren 2 und 3 schon seit Jahren auf meiner Tastatur und ich schreibe noch wie vor 30 Jahren ^2 und ^3 .

[kj187]

@Dutchman ah, ich habe vor kurzem selbst mit der Programmierung eines solchen Adapters angefangen, aber das breche ich jetzt erstmal ab und werde mir deinen ansehen und testen! Auf den ersten Blick sieht er schon mal sehr sehr gut aus!

Frage, berechnet er NUR ab dem Tag wo der Adapter installiert und für ein Objekt aktiviert wurde oder ist es auch möglich das er Rückwirkend berechnet? Setzt natürlich vorraus das die Daten vorhanden sind, ich habe alles in Influxdb, ist das Möglich? Oder geht Influx nicht und es hätte der History Adapter sein müssen oder geht es garnicht Rückwirgend?

Ach und arbeitest du noch aktiv an dem Adapter bzw. hast es noch vor? Deine letzten Commits sind schon etwas länger her, daher die Frage

LG
KJ

[Lucifor1976]

Bei mir hat der Adapter das neue Jahr verschlafen, Datenpunkte wurden erst nach Neustart des Adapter angelegt und ich musste die komplette VIS des Stromverbrauchts/berechnung von Hand anpassen.
Ich finde es immer noch sinvoll die Monate auch im CurrentYear zu bekommen. Ebenfalls wäre (für mich) sinvoll die Daten in CurrentYear und LastYear zu haben. So ein Adapter macht für mich den meisten Sinn, wenn ich vergleichen kann (ohne mindestens einmal im Jahr die Datenpunke von Hand anpassen zu müssen) was in der aktuellen Struktur nicht geht. Somit muss ich 55 Datenpunkte von Hand anpassen.

Derzeit ist es so das Monatswerte im Jahr abgelegt werden (das macht es nötig nach dem 01.01.xx die Datenpunkte anzupassen)
Wenn ich also eine VIS habe (so wie ich) die Quasi so aussieht:

IST:
Verbauch Monat (Januar), Verbrauch Monat Vorjahr(Januar), Kosten Monat(Januar), Kosten Vorjahr(Januar)
Fester DP in 2021        Fester DP in 2020                Fester DP in 2021     Fester DP in 2020

Warum so kompliziert? Ich vergleiche Monate und Wochen.

Besser:
Verbauch Monat (Januar), Verbrauch Monat Vorjahr(Januar), Kosten Monat(Januar), Kosten Vorjahr(Januar)
CurrentYear              LastYear                         CurrentYear           LastYear

[JB_Sullivan]

@Lucifor1976 @Dutchman

Also das man beim Jahreswechsel die DP`s in einer Visualisierung anpassen muss, finde ich auch nicht so praktisch.

Auf der Arbeit, verwende ich auch viele Tabellen und Diagramme auf Excel Basis. In der Regel will man ja meistens mit dem Vorjahr vergleichen. Darum verwende ich auf der Arbeit auch immer die Begriffe "aktuelles Jahr" und "Vorjahr".

Für das verändern der DP`s in ioBroker nach einem Jahreswechsel kann man ggf. das kleine folgende Workaround verwenden.

Ich habe folgendes VIEW im Einsatz und habe nach dem Jahreswechsel 2 Minuten gebraucht, um dieses für 2021 anzupassen.

1.) VIS Editor öffnen
2.) VIEW exportieren und in die Zwischenablage kopieren
3.) Notepad ++ öffnen und die Zwischenablage in ein neues Arbeitsblatt kopieren (geht auch mit dem Windows eigenen Editor)
4.) In Notepad++ die Funktion "ersetzen" auswählen und alle Einträge 2020 durch 2021 ersetzen (kann einzeln oder in einem Rutsch passieren)
5.) geänderten Quellcode aus Notepad++ in die Zwischenablage kopieren
6.) VIS Editor öffnen und neues VIEW importieren (Daten aus der Zwischenablage einfügen)
7.) Fertig

Man sollte bei der Namensvergabe der entsprechenden VIEW`s diese vielleicht gleich mit den entsprechenden Jahreszahlen oder Begrifflichkeiten belegen.

Also z.B. - VIEW Name

001_Strom_2020 oder 001_Strom_Vorjahr
001_Strom_2021 oder 001_Strom_aktuellesJahr

Dann braucht man nach dem erzeugen eines neuen VIEWS bestenfalls die Verknüpfung zu diesem neuen VIEW von 2020 auf 2021 ändern - und das finde ich ehrlich gesagt nicht so dramatisch. Außerdem hat man dann das 2020er VIEW immer noch zur Verwendung in weiteren Verlinkungen innerhalb des Projektes vorliegen.

[dos1973]

HI zusammen, ich möchte auch Strom visualisieren, den verbrauch und die Kosten darstellen...

ich habe fast nur shelly's im Einsatz.
Frage, welchen Wert nehmen ich denn Energy oder Power?

shelly.0.SHSW-25#73FBAB#1.Relay0.Energy

aktueller Wert = 0.37Wh

oder Power

shelly.0.SHSW-25#73FBAB#1.Relay0.Power

0W = Licht aus
xxW = wenn Licht brennt.

und noch eine Frage:
ich habe jetzt einige Geräte in Source Analytix aufgenommen und habe jetzt die unterschiedlichen DP je Endgerät. Wie gruppiere ich denn einen Raum?, muss das als Blockly script zusammengeführt (addiert) werden?

letzte Frage:
es gibt nur den Source Analytik Adapter für Strom? gefällt mir bisher gut, aber ist ja noch Beta, gibts etwas "produktives"

[guergen]

@dos1973 Nimm den Wert Energy, das ist der Richtige