inverter_bot: update osp util program

3 files changed, 85 insertions, 59 deletions

diff --git a/src/home/inverter/__init__.py b/src/home/inverter/__init__.py
index 967ddff..8831ef3 100644
--- a/src/home/inverter/__init__.py
+++ b/src/home/inverter/__init__.py
@@ -1,10 +1,3 @@
-from .monitor import (
-    ChargingEvent,
-    InverterMonitor,
-    BatteryState,
-    BatteryPowerDirection,
-    ACMode,
-    ACPresentEvent
-)
+from .monitor import InverterMonitor
 from .inverter_wrapper import wrapper_instance
 from .util import beautify_table
diff --git a/src/home/inverter/monitor.py b/src/home/inverter/monitor.py
index 2fcd55a..898c998 100644
--- a/src/home/inverter/monitor.py
+++ b/src/home/inverter/monitor.py
@@ -1,7 +1,7 @@
 import logging
 import time
 
-from enum import Enum, auto
+from .types import *
 from threading import Thread
 from typing import Callable, Optional
 from .inverter_wrapper import wrapper_instance as inverter
@@ -12,55 +12,6 @@ from ..config import config
 logger = logging.getLogger(__name__)
 
 
-class BatteryPowerDirection(Enum):
-    DISCHARGING = auto()
-    CHARGING = auto()
-    DO_NOTHING = auto()
-
-
-class ChargingEvent(Enum):
-    AC_CHARGING_UNAVAILABLE_BECAUSE_SOLAR = auto()
-    AC_NOT_CHARGING = auto()
-    AC_CHARGING_STARTED = auto()
-    AC_DISCONNECTED = auto()
-    AC_CURRENT_CHANGED = auto()
-    AC_MOSTLY_CHARGED = auto()
-    AC_CHARGING_FINISHED = auto()
-
-    UTIL_CHARGING_STARTED = auto()
-    UTIL_CHARGING_STOPPED = auto()
-    UTIL_CHARGING_STOPPED_SOLAR = auto()
-
-
-class ACPresentEvent(Enum):
-    CONNECTED = auto()
-    DISCONNECTED = auto()
-
-
-class ChargingState(Enum):
-    NOT_CHARGING = auto()
-    AC_BUT_SOLAR = auto()
-    AC_WAITING = auto()
-    AC_OK = auto()
-    AC_DONE = auto()
-
-
-class CurrentChangeDirection(Enum):
-    UP = auto()
-    DOWN = auto()
-
-
-class BatteryState(Enum):
-    NORMAL = auto()
-    LOW = auto()
-    CRITICAL = auto()
-
-
-class ACMode(Enum):
-    GENERATOR = 'generator'
-    UTILITIES = 'utilities'
-
-
 def _pd_from_string(pd: str) -> BatteryPowerDirection:
     if pd == 'Discharge':
         return BatteryPowerDirection.DISCHARGING
@@ -94,6 +45,8 @@ class InverterMonitor(Thread):
     battery_event_handler: Optional[Callable]
     util_event_handler: Optional[Callable]
     error_handler: Optional[Callable]
+    osp_change_cb: Optional[Callable]
+    osp: Optional[OutputSourcePriority]
 
     def __init__(self):
         super().__init__()
@@ -102,12 +55,14 @@ class InverterMonitor(Thread):
         self.interrupted = False
         self.min_allowed_current = 0
         self.ac_mode = None
+        self.osp = None
 
         # Event handlers for the bot.
         self.charging_event_handler = None
         self.battery_event_handler = None
         self.util_event_handler = None
         self.error_handler = None
+        self.osp_change_cb = None
 
         # Currents list, defined in the bot config.
         self.currents = cfg.gen_currents
@@ -156,6 +111,12 @@ class InverterMonitor(Thread):
 
         self.min_allowed_current = min(allowed_currents)
 
+        # Reading rated configuration
+        rated = inverter.exec('get-rated')['data']
+        self.osp = OutputSourcePriority.SolarBatteryUtility \
+            if rated['output_source_priority'] == 'Solar-Battery-Utility' \
+            else OutputSourcePriority.SolarUtilityBattery
+
         # Read data and run implemented programs every 2 seconds.
         while not self.interrupted:
             try:
@@ -167,6 +128,7 @@ class InverterMonitor(Thread):
 
                     ac = gs['grid_voltage']['value'] > 0 or gs['grid_freq']['value'] > 0
                     solar = gs['pv1_input_voltage']['value'] > 0 or gs['pv2_input_voltage']['value'] > 0
+                    solar_input = gs['pv1_input_power']['value']
                     v = float(gs['battery_voltage']['value'])
                     load_watts = int(gs['ac_output_active_power']['value'])
                     pd = _pd_from_string(gs['battery_power_direction'])
@@ -177,7 +139,7 @@ class InverterMonitor(Thread):
                         self.gen_charging_program(ac, solar, v, pd)
 
                     elif self.ac_mode == ACMode.UTILITIES:
-                        self.utilities_monitoring_program(ac, solar, pd)
+                        self.utilities_monitoring_program(ac, solar, v, load_watts, solar_input, pd)
 
                     if not ac or pd != BatteryPowerDirection.CHARGING:
                         # if AC is disconnected or not charging, run the low voltage checking program
@@ -195,6 +157,9 @@ class InverterMonitor(Thread):
     def utilities_monitoring_program(self,
                                      ac: bool,                  # whether AC is connected
                                      solar: bool,               # whether MPPT is active
+                                     v: float,                  # battery voltage
+                                     load_watts: int,           # load, wh
+                                     solar_input: int,          # input from solar panels, wh
                                      pd: BatteryPowerDirection  # current power direction
                                      ):
         pd_event_send = False
@@ -204,6 +169,15 @@ class InverterMonitor(Thread):
                 self.charging_event_handler(ChargingEvent.UTIL_CHARGING_STOPPED_SOLAR)
                 pd_event_send = True
 
+        if solar:
+            if v <= 48 and self.osp == OutputSourcePriority.SolarBatteryUtility:
+                self.osp_change_cb(OutputSourcePriority.SolarUtilityBattery, solar_input=solar_input, v=v)
+                self.osp = OutputSourcePriority.SolarUtilityBattery
+
+            if self.osp == OutputSourcePriority.SolarUtilityBattery and solar_input >= 900:
+                self.osp_change_cb(OutputSourcePriority.SolarBatteryUtility, solar_input=solar_input, v=v)
+                self.osp = OutputSourcePriority.SolarBatteryUtility
+
         if self.util_ac_present is None or ac != self.util_ac_present:
             self.util_event_handler(ACPresentEvent.CONNECTED if ac else ACPresentEvent.DISCONNECTED)
             self.util_ac_present = ac
@@ -213,6 +187,7 @@ class InverterMonitor(Thread):
             if not pd_event_send and not solar:
                 if pd == BatteryPowerDirection.CHARGING:
                     self.charging_event_handler(ChargingEvent.UTIL_CHARGING_STARTED)
+
                 elif pd == BatteryPowerDirection.DISCHARGING:
                     self.charging_event_handler(ChargingEvent.UTIL_CHARGING_STOPPED)
 
@@ -493,6 +468,9 @@ class InverterMonitor(Thread):
     def set_error_handler(self, handler: Callable):
         self.error_handler = handler
 
+    def set_osp_need_change_callback(self, cb: Callable):
+        self.osp_change_cb = cb
+
     def set_ac_mode(self, mode: ACMode):
         self.ac_mode = mode
 
diff --git a/src/home/inverter/types.py b/src/home/inverter/types.py
new file mode 100644
index 0000000..0292c15
--- /dev/null
+++ b/src/home/inverter/types.py
@@ -0,0 +1,55 @@
+from enum import Enum, auto
+
+
+class BatteryPowerDirection(Enum):
+    DISCHARGING = auto()
+    CHARGING = auto()
+    DO_NOTHING = auto()
+
+
+class ChargingEvent(Enum):
+    AC_CHARGING_UNAVAILABLE_BECAUSE_SOLAR = auto()
+    AC_NOT_CHARGING = auto()
+    AC_CHARGING_STARTED = auto()
+    AC_DISCONNECTED = auto()
+    AC_CURRENT_CHANGED = auto()
+    AC_MOSTLY_CHARGED = auto()
+    AC_CHARGING_FINISHED = auto()
+
+    UTIL_CHARGING_STARTED = auto()
+    UTIL_CHARGING_STOPPED = auto()
+    UTIL_CHARGING_STOPPED_SOLAR = auto()
+
+
+class ACPresentEvent(Enum):
+    CONNECTED = auto()
+    DISCONNECTED = auto()
+
+
+class ChargingState(Enum):
+    NOT_CHARGING = auto()
+    AC_BUT_SOLAR = auto()
+    AC_WAITING = auto()
+    AC_OK = auto()
+    AC_DONE = auto()
+
+
+class CurrentChangeDirection(Enum):
+    UP = auto()
+    DOWN = auto()
+
+
+class BatteryState(Enum):
+    NORMAL = auto()
+    LOW = auto()
+    CRITICAL = auto()
+
+
+class ACMode(Enum):
+    GENERATOR = 'generator'
+    UTILITIES = 'utilities'
+
+
+class OutputSourcePriority(Enum):
+    SolarUtilityBattery = 'SUB'
+    SolarBatteryUtility = 'SBU'
\ No newline at end of file