openWB Forum

Code: Alles auswählen

          "currentSubscription": {
            "status": "running",
            "priceInfo": {
              "current": {
                "total": 2.5156,
                "energy": 1.9262,
                "tax": 0.5894,
                "startsAt": "2022-11-23T14:00:00.000+01:00"}

Code: Alles auswählen

                "total": 2.5156,
                "energy": 1.9262,
                "tax": 0.5894,

Code: Alles auswählen

def _check_args(arg1, arg2, arg3):
    # entferne alles außer Buchstaben, Zahlen, - und _ aus Parametern
    arg1_str = re.sub('[^A-Za-z0-9_-]+', '', arg1)  # tibber_token
    arg2_str = re.sub('[^A-Za-z0-9_-]+', '', arg2)  # home_id
    arg3_str = re.sub('[^0-9]+', '', arg3)  # Debug-Level
    try:
        arg3_int = int(arg3_str)
    except:
        raise ValueError('3. Parameter (Debug-Level = "' + arg3_str + '") ist keine Zahl') from None
    return arg1_str, arg2_str, arg3_int

def _read_args():
    # gibt Kommandozeilenparameter zurück
    if len(sys.argv) == 4:
        # sys.argv[0] : erstes Argument ist immer Dateiname
        try:
            tibber_token, home_id, debug_level = _check_args(sys.argv[1], sys.argv[2], sys.argv[3])
        except:
            raise
    else:
        raise ValueError('Parameteranzahl falsch (' + str(len(sys.argv) - 1) + ' uebergeben aber 3 gefordert)')
    return tibber_token, home_id, debug_level

def _write_log_entry(message, msg_debug_level = 0):
    # schreibt Eintrag ins Log je nach Level
    global _openWB_debug_level
    if msg_debug_level == 0 or _openWB_debug_level is None or msg_debug_level <= _openWB_debug_level:
        timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S:')
        line = timestamp + ' Modul tibbergetprices.py: ' + message + '\n'
        with open('/var/www/html/openWB/ramdisk/openWB.log', 'a') as f:
            f.write(line)

def _publish_price_data(pricelist_to_publish, current_module_name):
    # schreibt Preisliste und aktuellen Preis in Dateien und veröffentlicht die MQTT-Topics
    with open('/var/www/html/openWB/ramdisk/etproviderprice', 'w') as file_current_price, \
         open('/var/www/html/openWB/ramdisk/etprovidergraphlist', 'w') as file_pricelist:
        file_pricelist.write('%s\n' % current_module_name )  # erster Eintrag ist für Preisliste verantwortliches Modul
        # Preisliste durchlaufen und in ramdisk
        for index, price_data in enumerate(pricelist_to_publish):
            file_pricelist.write('%s,%s\n' % (price_data[0], price_data[1]))  # Timestamp, Preis
            if (index == 0):
                # erster Eintrag ist aktueller Preis
                file_current_price.write('%s\n' % price_data[1])
    #publish MQTT-Daten für Preis und Graph
    os.system('mosquitto_pub -r -t openWB/global/awattar/pricelist -m "$(cat /var/www/html/openWB/ramdisk/etprovidergraphlist)"')
    os.system('mosquitto_pub -r -t openWB/global/awattar/ActualPriceForCharging -m "$(cat /var/www/html/openWB/ramdisk/etproviderprice)"')