openWB Forum

Code: Alles auswählen

diff --git a/modules/et_tibber/stromtarifinfo/infopage.php b/modules/et_tibber/stromtarifinfo/infopage.php
index ff344573..cba90029 100755
--- a/modules/et_tibber/stromtarifinfo/infopage.php
+++ b/modules/et_tibber/stromtarifinfo/infopage.php
@@ -230,13 +230,13 @@
                                        initialDataRead = false;
                                        var tibberQueryHead = '{ "query": "{viewer {name home(id:\\"' + tibberHomeID + '\\") {';
                                        var tibberQueryGetAdress = 'address {address1 postalCode city} ';
-                                       var tibberQueryGetPriceInfo = 'currentSubscription {priceInfo {current{total energy tax startsAt} today {total startsAt} tomorrow {total startsAt}}} ';
+                                       var tibberQueryGetPriceInfo = 'currentSubscription {priceInfo(resolution: QUARTER_HOURLY) {current{total energy tax startsAt} today {total startsAt} tomorrow {total startsAt}}} ';
                                } else {
                                        var tibberQueryHead = '{ "query": "{viewer {home(id:\\"' + tibberHomeID + '\\") {';
                                        var tibberQueryGetAdress = '';
                                        var tibberQueryGetPriceInfo = '';
                                }
-                               var tibberQueryGetHourlyConsumption = 'cons_hourly: consumption(resolution: HOURLY, after:\\"' + timeStringBase64 + '\\", first: 25) {nodes {from to cost unitPrice unitPriceVAT consumption}}';
+                               var tibberQueryGetHourlyConsumption = 'cons_hourly: consumption(resolution: HOURLY, after:\\"' + timeStringBase64 + '\\", first: 100) {nodes {from to cost unitPrice unitPriceVAT consumption}}';
                                var tibberQueryTail = '}}}" }';
                                var tibberQuery = tibberQueryHead + tibberQueryGetAdress + tibberQueryGetPriceInfo + tibberQueryGetHourlyConsumption + tibberQueryTail;
 
diff --git a/modules/et_tibber/tibbergetprices.py b/modules/et_tibber/tibbergetprices.py
index dd247139..3450d55f 100755
--- a/modules/et_tibber/tibbergetprices.py
+++ b/modules/et_tibber/tibbergetprices.py
@@ -108,7 +108,8 @@ def _exit_on_invalid_price_data(error, current_module_name):
         file_current_price.write(str(_failure_price) + '\n')
         file_pricelist.write('%s\n' % current_module_name)  # erster Eintrag ist für Preisliste verantwortliches Modul
         now = datetime.now(timezone.utc)  # timezone-aware datetime-object in UTC
-        timestamp = now.replace(minute=0, second=0, microsecond=0)  # volle Stunde
+        quarter_hour = (now.minute // 15) * 15
+        timestamp = now.replace(minute=quarter_hour, second=0, microsecond=0)  # volle Stunde
         for i in range(9):
             file_pricelist.write('%d, %f\n' % (timestamp.timestamp(), _failure_price))
             timestamp = timestamp + timedelta(hours=1)
@@ -178,7 +179,7 @@ def _try_api_call(max_tries=3, delay=5, backoff=2, exceptions=(Exception,), hook
 @_try_api_call()
 def _readAPI(token, id):
     headers = {'Authorization': 'Bearer ' + token, 'Content-Type': 'application/json'}
-    data = '{ "query": "{viewer {home(id:\\"' + id + '\\") {currentSubscription {priceInfo {today {total startsAt} tomorrow {total startsAt}}}}}}" }'
+    data = '{ "query": "{viewer {home(id:\\"' + id + '\\") {currentSubscription {priceInfo(resolution: QUARTER_HOURLY) {today {total startsAt} tomorrow {total startsAt}}}}}}" }'
     # Timeout für Verbindung = 2 sek und Antwort = 6 sek
     response = requests.post('https://api.tibber.com/v1-beta/gql', headers=headers, data=data, timeout=(2, 6))
     return response
@@ -191,34 +192,36 @@ def _get_utcfromtimestamp(timestamp):
     return datetime_obj
 
 def _cleanup_pricelist(pricelist):
-    # bereinigt sortierte Preisliste, löscht Einträge die älter als aktuelle Stunde sind
+    # bereinigt sortierte Preisliste, löscht Einträge die älter als aktuelle Viertelstunde sind
     # und über morgen hinausgehen
-    # wenn der erste Preis nicht für die aktuelle Stunde ist, wird leere Liste zurückgegeben
+    # wenn der erste Preis nicht für die aktuelle Viertelstunde ist, wird leere Liste zurückgegeben
     # prüft auf Abstand der Preise: ist dieser >1h, wird Liste ab diesem Punkt abgeschnitten
     if len(pricelist) > 0:
         now = datetime.now(timezone.utc)  # timezone-aware datetime-object in UTC
-        now_full_hour = now.replace(minute=0, second=0, microsecond=0)  # volle Stunde
-        now_full_hour_timestamp = datetime.timestamp(now_full_hour)
+        # Runde Minuten auf die nächste Viertelstunde (0, 15, 30, 45)
+        quarter_hour = (now.minute // 15) * 15
+        now_quarter_hour = now.replace(minute=quarter_hour, second=0, microsecond=0)
+        now_quarter_hour_timestamp = datetime.timestamp(now_quarter_hour)
         # zuerst filtern auf "ab diese Stunde" bis "längstens morgen"
         for index, price in enumerate(pricelist[:]):  # über Kopie der Liste iterieren, um das Original zu manipulieren
             try:
                 starttime_utc = _get_utcfromtimestamp(float(price[0]))  # Start-Zeitstempel aus Preisliste umwandeln
             except:
                 raise TypeError('Zeitstempel-Umwandlung fehlgeschlagen') from None
-            # ältere als aktuelle Stunde und weiter als morgen löschen
-            if (float(price[0]) < now_full_hour_timestamp) or (starttime_utc.date() > now.date() + timedelta(days=1)):
+            # ältere als aktuelle Viertelstunde und weiter als morgen löschen
+            if (float(price[0]) < now_quarter_hour_timestamp) or (starttime_utc.date() > now.date() + timedelta(days=1)):
                 pricelist.remove(price)
-        # jetzt prüfen auf Start mit aktueller Stunde und Stundenabstände
+        # jetzt prüfen auf Start mit aktueller Viertelstunde und Viertelstundenabstände
         if len(pricelist) > 0:
             timestamp_prev = float(pricelist[0][0])  # erster Listeneintrag
             starttime_utc = _get_utcfromtimestamp(float(pricelist[0][0]))
-            if _get_utcfromtimestamp(timestamp_prev) == now_full_hour:  # erster Preis ist der von aktueller Stunde
+            if _get_utcfromtimestamp(timestamp_prev) == now_quarter_hour:  # erster Preis ist der von aktueller Stunde
                 for index, price in enumerate(pricelist[:]):  # über Kopie der Liste iterieren, um das Original zu manipulieren
                     if index > 0:
                         timestamp = float(price[0])
                         secondsdiff = timestamp - timestamp_prev
                         timestamp_prev = float(price[0])
-                        if secondsdiff != 3600.0:  # ist Abstand <> 1h dann ab hier Liste löschen
+                        if secondsdiff != 900.0:  # ist Abstand <> 1h dann ab hier Liste löschen
                             del pricelist[index:]
                             break
             else:
@@ -262,7 +265,8 @@ def _get_updated_pricelist():
         _write_log_entry("Tibber-Preisliste extrahiert", 1)
         # alle Zeiten in UTC verarbeiten
         now = datetime.now(timezone.utc)  # timezone-aware datetime-object in UTC
-        now_full_hour = now.replace(minute=0, second=0, microsecond=0)  # volle Stunde
+        quarter_hour = (now.minute // 15) * 15
+        now_quarter_hour = now.replace(minute=quarter_hour, second=0, microsecond=0)  # volle Stunde
         _write_log_entry('Formatiere und analysiere Preisliste', 1)
         pricelist = []
         for price_data in sorted_marketprices: