pass data object as parameter in set_power_limit methode, review

packages/control/counter_all/hierarchy.py

@@ -27,7 +27,7 @@ def _get_all_elements_without_children_recursive(self: HierarchyProtocol, child:
                 log.exception("Fehler in der allgemeinen Zähler-Klasse")
 
     def get_loads_of_counter(self: HierarchyProtocol, counter: str) -> List[str]:
-        """ gibt eine Liste der Ladepunkte, die in den folgenden Zweigen des Zählers sind, zurück.
+        """ gibt eine Liste der Ladepunkte und Verbraucher, die in den folgenden Zweigen des Zählers sind, zurück.
         """
         self.connected_loads = []
         if counter == self.get_evu_counter_str():
@@ -45,7 +45,8 @@ def get_loads_of_counter(self: HierarchyProtocol, counter: str) -> List[str]:
         return self.connected_loads
 
     def _get_all_loads_connected_to_counter(self: HierarchyProtocol, child: Dict) -> None:
-        """ Rekursive Funktion, die alle Ladepunkte ermittelt, die an den angegebenen Zähler angeschlossen sind.
+        """ Rekursive Funktion, die alle Ladepunkte und Verbraucher ermittelt, die an den angegebenen Zähler
+        angeschlossen sind.
         """
         # Alle Objekte der Ebene durchgehen
         for child in child["children"]:
@@ -61,7 +62,7 @@ def _get_all_loads_connected_to_counter(self: HierarchyProtocol, child: Dict) ->
                 log.exception("Fehler in der allgemeinen Zähler-Klasse")
 
     def get_counters_to_check(self: HierarchyProtocol, num: int) -> List[str]:
-        """ ermittelt alle Zähler im Zweig des Ladepunkts.
+        """ ermittelt alle Zähler im Zweig des Ladepunkts/Verbrauchers.
         """
         self.connected_counters = []
         self._get_all_counter_in_branch(self.data.get.hierarchy[0], num)
@@ -91,8 +92,8 @@ def _is_id_in_top_level(self: HierarchyProtocol, id_to_find: int) -> Dict:
             return {}
 
     def _get_all_counter_in_branch(self: HierarchyProtocol, child: Dict, id_to_find: int) -> bool:
-        """ Rekursive Funktion, die alle Zweige durchgeht, bis der entsprechende Ladepunkt gefunden wird und dann alle
-        Zähler in diesem Pfad der Liste anhängt.
+        """ Rekursive Funktion, die alle Zweige durchgeht, bis der entsprechende Ladepunkt/Verbraucher gefunden wird
+        und dann alle Zähler in diesem Pfad der Liste anhängt.
         """
         parent_id = child["id"]
         for child in child["children"]:
@@ -135,8 +136,8 @@ def _get_entry_of_parent(self: HierarchyProtocol, child: Dict, id_to_find: int)
     def hierarchy_add_item_aside(self: HierarchyProtocol,
                                  new_id: int, new_type: ComponentType,
                                  id_to_find: int) -> None:
-        """ ruft die rekursive Funktion zum Hinzufügen eines Zählers oder Ladepunkts in die Zählerhierarchie auf
-        derselben Ebene wie das angegebene Element.
+        """ ruft die rekursive Funktion zum Hinzufügen eines Zählers, Ladepunkts oder Verbrauchers in die
+        Zählerhierarchie auf derselben Ebene wie das angegebene Element.
         """
         if self._is_id_in_top_level(id_to_find):
             self.data.get.hierarchy.append({"id": new_id, "type": new_type.value, "children": []})

packages/control/process.py

@@ -181,6 +181,8 @@ def _update_state_consumer(self, consumer: Consumer) -> None:
             consumer.data.set.current = consumer.data.set.current_prev
         else:
             consumer.data.set.current = round(consumer.data.set.current, 2)
+        if consumer.data.set.current != consumer.data.set.current_prev:
+            consumer.data.set.timestamp_last_current_set = timecheck.create_timestamp()
         if consumer.data.set.current != 0 and control_parameter.state not in CHARGING_STATES:
             control_parameter.state = ChargepointState.CHARGING_ALLOWED
         if control_parameter.state != ChargepointState.NO_CHARGING_ALLOWED or consumer.data.set.current != 0:
@@ -191,8 +193,6 @@ def _update_state_consumer(self, consumer: Consumer) -> None:
                  f"state {ChargepointState(control_parameter.state).name}")
 
     def _start_consumer(self, consumer: Consumer) -> Thread:
-        if consumer.data.set.current != consumer.data.set.current_prev:
-            consumer.data.set.timestamp_last_current_set = timecheck.create_timestamp()
         if consumer.data.usage.type in (ConsumerUsage.CONTINUOUS,
                                         ConsumerUsage.SUSPENDABLE_ONOFF):
             return Thread(

packages/helpermodules/command.py

@@ -799,7 +799,7 @@ def removeVehicle(self, connection_id: str, payload: dict) -> None:
             if SubData.system_data["system"].data["security"]["user_management_active"]:
                 remove_acl_role("vehicle-<id>-access", payload["data"]["id"])
                 remove_acl_role("vehicle-<id>-write-access", payload["data"]["id"])
-            SubData.counter_all_data.remove_loadmanagement_prio_item(payload["data"]["id"])
+            SubData.counter_all_data.remove_loadmanagement_prio_item(ComponentType.VEHICLE, payload["data"]["id"])
             Pub().pub("openWB/set/counter/get/loadmanagement_prios",
                       SubData.counter_all_data.data.get.loadmanagement_prios)
             pub_user_message(
@@ -1214,7 +1214,7 @@ def removeConsumer(self, connection_id: str, payload: dict) -> None:
         ProcessBrokerBranch(f'consumer/{payload["data"]["consumer_id"]}/').remove_topics()
         SubData.counter_all_data.hierarchy_remove_item(payload["data"]["consumer_id"])
         Pub().pub("openWB/set/counter/get/hierarchy", SubData.counter_all_data.data.get.hierarchy)
-        SubData.counter_all_data.remove_loadmanagement_prio_item(payload["data"]["consumer_id"])
+        SubData.counter_all_data.remove_loadmanagement_prio_item(ComponentType.CONSUMER, payload["data"]["consumer_id"])
         Pub().pub("openWB/set/counter/get/loadmanagement_prios", SubData.counter_all_data.data.get.loadmanagement_prios)
         pub_user_message(payload, connection_id,
                          f'Verbraucher mit ID \'{payload["data"]["consumer_id"]}\' gelöscht.', MessageType.SUCCESS)