implement outputs for stepwise control

Author: benderl

packages/control/process.py

@@ -15,6 +15,7 @@
 from modules.common.fault_state_level import FaultStateLevel
 from modules.io_actions.controllable_consumers.dimming.api import Dimming
 from modules.io_actions.controllable_consumers.dimming_direct_control.api import DimmingDirectControl
+from modules.io_actions.generator_systems.stepwise_control.api import StepwiseControl
 
 log = logging.getLogger(__name__)
 
@@ -85,6 +86,12 @@ def process_algorithm_results(self) -> None:
                             data.data.io_states[f"io_states{d['id']}"].data.set.digital_output[d["digital_output"]] = (
                                 not action.dimming_active()  # active output (True) if no dimming
                             )
+                if isinstance(action, StepwiseControl):
+                    for d in action.config.configuration.devices:
+                        if d["type"] == "io":
+                            data.data.io_states[f"io_states{d['id']}"].data.set.digital_output[d["digital_output"]] = (
+                                action.control_stepwise() == d["value"]  # active output (True) if value matches
+                            )
             for io in data.data.system_data.values():
                 if isinstance(io, AbstractIoDevice):
                     modules_threads.append(

packages/modules/io_actions/generator_systems/stepwise_control/api.py

@@ -6,6 +6,7 @@
 from helpermodules.timecheck import create_timestamp
 from modules.common.abstract_device import DeviceDescriptor
 from modules.common.abstract_io import AbstractIoAction
+from modules.common.utils.component_parser import get_component_name_by_id, get_io_name_by_id
 from modules.io_actions.generator_systems.stepwise_control.config import StepwiseControlSetup
 
 control_command_log = logging.getLogger("steuve_control_command")
@@ -19,11 +20,24 @@ def __init__(self, config: StepwiseControlSetup):
             for key in pattern["input_matrix"].keys():
                 if key not in self.__unique_inputs:
                     self.__unique_inputs.append(key)
-        assigned_devices = [io_device["id"] for io_device in self.config.configuration.devices]
+        assigned_inverters = [
+            f"{device['id']}"
+            for device in self.config.configuration.devices
+            if device["type"] == "inverter"
+        ]
+        assigned_outputs = [
+            f"{device['id']}/{device['digital_output']}"
+            for device in self.config.configuration.devices
+            if device["type"] == "io"
+        ]
+        # Log the configuration details
+        # We cannot use configured names here, as the devices are not yet initialized
+        # and thus the names are not available.
         control_command_log.info(
             f"Stufenweise Steuerung von EZA: I/O-Gerät: {self.config.configuration.io_device}, "
             f"Überwachte digitale Eingänge: {self.__unique_inputs}, "
-            f"zugeordnete Erzeugungsanlagen: {assigned_devices} "
+            f"zugeordnete Erzeugungsanlagen: {assigned_inverters} "
+            f"zugeordnete IO-Ausgänge: {assigned_outputs} "
             "Die Begrenzung muss in den EZA vorgenommen werden!"
         )
         super().__init__()
@@ -52,6 +66,18 @@ def setup(self) -> None:
                         if changed:
                             Pub().pub(f"openWB/set/io/action/{self.config.id}/timestamp", create_timestamp())
                             control_command_log.info(f"EZA-Begrenzung mit Wert {int(pattern['value']*100)}% aktiviert.")
+                            for device in self.config.configuration.devices:
+                                if device["type"] == "inverter":
+                                    control_command_log.info(
+                                        f"Erzeugungsanlage {get_component_name_by_id(device['id'])} "
+                                        f"auf {int(pattern['value']*100)}% begrenzt."
+                                    )
+                                elif device["type"] == "io":
+                                    control_command_log.info(
+                                        f"IO-Gerät {get_io_name_by_id(device['id'])} Ausgang "
+                                        f"{device['digital_output']} "
+                                        f"{'aktiviert' if device['value'] == pattern['value'] else 'deaktiviert'}."
+                                    )
                         break
             else:
                 if changed:

packages/modules/io_actions/generator_systems/stepwise_control/config.py

@@ -9,7 +9,8 @@ class StepwiseControlConfig:
     io_device: Optional[int] = None
     input_pattern: List[Dict] = field(default_factory=empty_io_pattern_stepwise_factory)
     devices: List[Dict] = field(default_factory=empty_list_factory)
-    # [{"type": "inverter", "id": 1},...]
+    # [{"type": "inverter", "id": 1},
+    # {"type": "io", "id": 1, "digital_output": "SofortLa", "value": 0.6},...]
 
 
 class StepwiseControlSetup: