Startpunkt setzbar und Prognosezeitraum ebenfalls.

This commit is contained in:
Bla Bla
2024-02-25 16:47:28 +01:00
parent 33a6d59bcb
commit 239ad276c9
7 changed files with 140 additions and 130 deletions

View File

@@ -1,35 +1,6 @@
# class EnergieManagementSystem:
# def __init__(self, akku, lastkurve_wh, pv_prognose_wh):
# self.akku = akku
# self.lastkurve_wh = lastkurve_wh
# self.pv_prognose_wh = pv_prognose_wh
from datetime import datetime
from pprint import pprint
# def simuliere(self):
# eigenverbrauch_wh = 0
# netzeinspeisung_wh = 0
# netzbezug_wh = 0
# for stunde in range(len(self.lastkurve_wh)):
# verbrauch = self.lastkurve_wh[stunde]
# erzeugung = self.pv_prognose_wh[stunde]
# if erzeugung > verbrauch:
# überschuss = erzeugung - verbrauch
# eigenverbrauch_wh += verbrauch
# geladene_energie = min(überschuss, self.akku.kapazitaet_wh - self.akku.soc_wh)
# self.akku.energie_laden(geladene_energie)
# netzeinspeisung_wh += überschuss - geladene_energie
# else:
# eigenverbrauch_wh += erzeugung
# benötigte_energie = verbrauch - erzeugung
# aus_akku = self.akku.energie_abgeben(benötigte_energie)
# netzbezug_wh += benötigte_energie - aus_akku
# return {
# 'Eigenverbrauch_Wh': eigenverbrauch_wh,
# 'Netzeinspeisung_Wh': netzeinspeisung_wh,
# 'Netzbezug_Wh': netzbezug_wh
# }
class EnergieManagementSystem:
@@ -39,12 +10,30 @@ class EnergieManagementSystem:
self.pv_prognose_wh = pv_prognose_wh
self.strompreis_cent_pro_wh = strompreis_cent_pro_wh # Strompreis in Cent pro Wh
self.einspeiseverguetung_cent_pro_wh = einspeiseverguetung_cent_pro_wh # Einspeisevergütung in Cent pro Wh
# print("\n\nLastprognose:",self.lastkurve_wh.shape)
# print("PV Prognose:",self.pv_prognose_wh.shape)
# print("Preis Prognose:",self.strompreis_cent_pro_wh.shape)
def set_akku_discharge_hours(self, ds):
self.akku.set_discharge_per_hour(ds)
def reset(self):
self.akku.reset()
def simuliere_ab_jetzt(self):
jetzt = datetime.now()
start_stunde = jetzt.hour
# Berechne die Anzahl der Stunden bis zum gleichen Zeitpunkt am nächsten Tag
stunden_bis_ende_tag = 24 - start_stunde
# Füge diese Stunden zum nächsten Tag hinzu
gesamt_stunden = stunden_bis_ende_tag + 24
# Beginne die Simulation ab der aktuellen Stunde und führe sie für die berechnete Dauer aus
return self.simuliere(start_stunde)
def simuliere(self, start_stunde):
eigenverbrauch_wh_pro_stunde = []
netzeinspeisung_wh_pro_stunde = []
@@ -53,19 +42,17 @@ class EnergieManagementSystem:
einnahmen_euro_pro_stunde = []
akku_soc_pro_stunde = []
ende = len(self.lastkurve_wh) # Berechnet das Ende basierend auf der Länge der Lastkurve
ende = min( len(self.lastkurve_wh),len(self.pv_prognose_wh), len(self.strompreis_cent_pro_wh))
#print(ende)
# Berechnet das Ende basierend auf der Länge der Lastkurve
for stunde in range(start_stunde, ende):
# Anpassung, um sicherzustellen, dass Indizes korrekt sind
verbrauch = self.lastkurve_wh[stunde]
erzeugung = self.pv_prognose_wh[stunde]
strompreis = self.strompreis_cent_pro_wh[stunde] if stunde < len(self.strompreis_cent_pro_wh) else self.strompreis_cent_pro_wh[-1]
# for stunde in range(len(self.lastkurve_wh)):
# verbrauch = self.lastkurve_wh[stunde]
# erzeugung = self.pv_prognose_wh[stunde]
# strompreis = self.strompreis_cent_pro_wh[stunde]
#print(verbrauch," ",erzeugung," ",strompreis)
stündlicher_netzbezug_wh = 0
stündliche_kosten_euro = 0
stündliche_einnahmen_euro = 0
@@ -92,8 +79,16 @@ class EnergieManagementSystem:
# Berechnung der Gesamtbilanzen
gesamtkosten_euro = sum(kosten_euro_pro_stunde) - sum(einnahmen_euro_pro_stunde)
expected_length = ende - start_stunde
array_names = ['Eigenverbrauch_Wh_pro_Stunde', 'Netzeinspeisung_Wh_pro_Stunde', 'Netzbezug_Wh_pro_Stunde', 'Kosten_Euro_pro_Stunde', 'akku_soc_pro_stunde', 'Einnahmen_Euro_pro_Stunde']
all_arrays = [eigenverbrauch_wh_pro_stunde, netzeinspeisung_wh_pro_stunde, netzbezug_wh_pro_stunde, kosten_euro_pro_stunde, akku_soc_pro_stunde, einnahmen_euro_pro_stunde]
return {
inconsistent_arrays = [name for name, arr in zip(array_names, all_arrays) if len(arr) != expected_length]
if inconsistent_arrays:
raise ValueError(f"Inkonsistente Längen bei den Arrays: {', '.join(inconsistent_arrays)}. Erwartete Länge: {expected_length}, gefunden: {[len(all_arrays[array_names.index(name)]) for name in inconsistent_arrays]}")
out = {
'Eigenverbrauch_Wh_pro_Stunde': eigenverbrauch_wh_pro_stunde,
'Netzeinspeisung_Wh_pro_Stunde': netzeinspeisung_wh_pro_stunde,
'Netzbezug_Wh_pro_Stunde': netzbezug_wh_pro_stunde,
@@ -105,42 +100,5 @@ class EnergieManagementSystem:
'Gesamtkosten_Euro': sum(kosten_euro_pro_stunde)
}
# def simuliere(self):
# eigenverbrauch_wh = 0
# netzeinspeisung_wh = 0
# netzbezug_wh = 0
# kosten_euro = 0
# einnahmen_euro = 0
# for stunde in range(len(self.lastkurve_wh)):
# verbrauch = self.lastkurve_wh[stunde]
# erzeugung = self.pv_prognose_wh[stunde]
# strompreis = self.strompreis_cent_pro_wh[stunde]
# if erzeugung > verbrauch:
# überschuss = erzeugung - verbrauch
# eigenverbrauch_wh += verbrauch
# geladene_energie = min(überschuss, self.akku.kapazitaet_wh - self.akku.soc_wh)
# self.akku.energie_laden(geladene_energie)
# netzeinspeisung_wh += überschuss - geladene_energie
# einnahmen_euro += (überschuss - geladene_energie) * self.einspeiseverguetung_cent_pro_wh[stunde] / 100
# else:
# eigenverbrauch_wh += erzeugung
# benötigte_energie = verbrauch - erzeugung
# aus_akku = self.akku.energie_abgeben(benötigte_energie)
# netzbezug_wh += benötigte_energie - aus_akku
# print(strompreis)
# kosten_euro += (benötigte_energie - aus_akku) * strompreis / 100
# gesamtkosten_euro = kosten_euro - einnahmen_euro
# return {
# 'Eigenverbrauch_Wh': eigenverbrauch_wh,
# 'Netzeinspeisung_Wh': netzeinspeisung_wh,
# 'Netzbezug_Wh': netzbezug_wh,
# 'Kosten_Euro': kosten_euro,
# 'Einnahmen_Euro': einnahmen_euro,
# 'Gesamtkosten_Euro': gesamtkosten_euro
# }
return out