before big rewrite

v2/architecture.py

@@ -8,7 +8,7 @@ from supplier import Supplier
 from data_processing import read_datasets, add_production_field, interpolate_and_join, Parameters
 
 
-STEPS_PER_HOUR = 4
+STEPS_PER_HOUR = 12
 
 
 # mock model
@@ -68,7 +68,7 @@ class Decider:
     def __init__(self):
         self.parameters = None
         self.input_window_size = STEPS_PER_HOUR * 24 # day long window.
-        self.output_window_size = STEPS_PER_HOUR # only output 4 decisions for the next hour
+        self.output_window_size = STEPS_PER_HOUR # only output decisions for the next hour
 
     # prod_cons_pred is a dataframe starting at now, containing
     # fields Production and Consumption.
@@ -95,6 +95,134 @@ def simulator(battery_model, supplier, prod_cons, decider):
     return None
 
 
+# TODO even in a first mockup version, parameters should come from a single
+# place, not some from the parameters dataclass and some from the battery_model.
+def simulator(battery_model, supplier, prod_cons, decider, parameters):
+    battery_model = copy.copy(battery_model)
+
+    demand_np = prod_cons['Consumption'].to_numpy()
+    production_np = prod_cons['Production'].to_numpy()
+    assert len(demand_np) == len(production_np)
+    step_in_minutes = prod_cons.index.freq.n
+    print(step_in_minutes)
+    assert step_in_minutes == 5
+
+    print("Simulating for", len(demand_np), "time steps. Each step is", step_in_minutes, "minutes.")
+    soc_series = []
+    # by convention, we only call end user demand, demand,
+    # and we only call end user consumption, consumption.
+    # in our simple model, demand is always satisfied, hence demand=consumption.
+    # BESS demand is called charge.
+    consumption_from_solar_series = [] # demand satisfied by solar production
+    consumption_from_network_series = [] # demand satisfied by network
+    consumption_from_bess_series = [] # demand satisfied by BESS
+    # the previous three must sum to demand_series.
+
+    # power taken from solar by BESS.
+    # note: in inital mock version power is never taken from network by BESS.
+    charge_of_bess_series = []
+    discarded_production_series = [] # solar power thrown away
+
+    # 1 is not nominal but targeted (healthy) maximum charge.
+    # we start with an empty battery, but not emptier than what's healthy for the batteries.
+
+    # For the sake of simplicity 0 <= soc <=1
+    # soc=0 means battery is emptied till it's 20% and soc=1 means battery is charged till 80% of its capacity
+    # soc = 1 - maximal_depth_of_discharge
+    # and will use only maximal_depth_of_discharge percent of the real battery capacity
+
+    max_cap_of_battery = parameters.bess_capacity * parameters.maximal_depth_of_discharge
+    cap_of_battery = soc * max_cap_of_battery
+
+    time_interval = step_in_minutes / 60 # amount of time step in hours
+    for i, (demand, production) in enumerate(zip(demand_np, production_np)):
+
+        # these five are modified on the appropriate codepaths:
+        consumption_from_solar = 0
+        consumption_from_bess = 0
+        consumption_from_network = 0
+        discarded_production = 0
+
+        unsatisfied_demand = demand
+        remaining_production = production
+        
+        if parameters.bess_present:
+            is_battery_charged_enough = battery_model.soc > 0
+            is_battery_chargeable = battery_model.soc < 1.0
+        else:
+            is_battery_charged_enough = battery_model.soc <= 0
+            is_battery_chargeable = battery_model.soc >= 1.0
+
+        if unsatisfied_demand >= remaining_production:
+            # all goes to demand
+            consumption_from_solar = remaining_production
+            unsatisfied_demand -= consumption_from_solar
+            remaining_production = 0
+            # we try to cover the rest from BESS
+            if (unsatisfied_demand > 0 ) and parameters.bess_present:
+                if is_battery_charged_enough:
+                    # battery capacity is limited!
+                    if cap_of_battery >= unsatisfied_demand * time_interval :
+                        consumption_from_bess = unsatisfied_demand
+                        unsatisfied_demand = 0
+                        cap_of_battery -= consumption_from_bess * time_interval
+                        soc = cap_of_battery / max_cap_of_battery
+                    else:
+                        discharge_of_bess = cap_of_battery / time_interval
+                        discharge = min(parameters.bess_discharge, discharge_of_bess)
+                        consumption_from_bess = discharge
+                        unsatisfied_demand -= consumption_from_bess
+                        cap_of_battery -= consumption_from_bess * time_interval
+                        soc = cap_of_battery / max_cap_of_battery
+                        consumption_from_network = unsatisfied_demand
+                        unsatisfied_demand = 0
+                else:
+                    # we cover the rest from network
+                    consumption_from_network = unsatisfied_demand
+                    unsatisfied_demand = 0
+        else:
+            # demand fully satisfied by production
+            consumption_from_solar = unsatisfied_demand
+            remaining_production -= unsatisfied_demand
+            unsatisfied_demand = 0
+            if (remaining_production > 0) and parameters.bess_present:
+                # exploitable production still remains:
+                if is_battery_chargeable:
+                    # we try to specify the BESS modell
+                    if parameters.bess_charge <= remaining_production :
+                        energy = parameters.bess_charge * time_interval
+                        remaining_production = remaining_production - parameters.bess_charge
+                    else :
+                        energy = remaining_production * time_interval
+                        remaining_production = 0
+                    cap_of_battery += energy
+                    soc = cap_of_battery / max_cap_of_battery
+
+        discarded_production = remaining_production
+
+        soc_series.append(battery_model.soc)
+        consumption_from_solar_series.append(consumption_from_solar)
+        consumption_from_network_series.append(consumption_from_network)
+        consumption_from_bess_series.append(consumption_from_bess)
+        discarded_production_series.append(discarded_production)
+
+    soc_series = np.array(soc_series)
+    consumption_from_solar_series = np.array(consumption_from_solar_series)
+    consumption_from_network_series = np.array(consumption_from_network_series)
+    consumption_from_bess_series = np.array(consumption_from_bess_series)
+    discarded_production_series = np.array(discarded_production_series)
+
+    results = pd.DataFrame({'soc_series': soc_series, 'consumption_from_solar': consumption_from_solar_series,
+                            'consumption_from_network': consumption_from_network_series,
+                            'consumption_from_bess': consumption_from_bess_series,
+                            'discarded_production': discarded_production_series,
+                            'Consumption': all_data['Consumption'],
+                            'Production': all_data['Production']
+                            })
+    results = results.set_index(all_data.index)
+    return results
+
+
 def main():
     battery_model = BatteryModel(capacity=200, efficiency=0.95)
 
@@ -109,7 +237,7 @@ def main():
 
     decider = Decider()
 
-    results = simulator(battery_model, supplier, all_2021_data, decider)
+    results = simulator(battery_model, supplier, all_2021_data, decider, parameters)
 
 
 if __name__ == '__main__':