Merge pull request #2761 from okaegi/smart192

pv Leistung und chargestatus

Author: LKuemmel

packages/smarthome/smartbase.py

@@ -37,6 +37,7 @@ def __init__(self) -> None:
         #  30 = gestartet um fertig bis zu erreichen
         # default 10
         self._first_run = 1
+        self.chargestatus = False
         self.device_nummer = 0
         self.temp0 = '300'
         self.temp1 = '300'
@@ -541,18 +542,6 @@ def conditions(self, speichersoc: int) -> None:
         if ((self.device_canswitch == 0) or
            (self.device_manual == 1)):
             return
-        file_charge = '/var/www/html/openWB/ramdisk/llkombiniert'
-        testcharge = 0.0
-        try:
-            if os.path.isfile(file_charge):
-                with open(file_charge, 'r') as f:
-                    testcharge = float(f.read())
-        except Exception:
-            pass
-        if testcharge <= 1000:
-            chargestatus = 0
-        else:
-            chargestatus = 1
         work_ausschaltschwelle = self._device_ausschaltschwelle
         work_ausschaltverzoegerung = self._device_ausschaltverzoegerung
         local_time = datetime.now(timezone.utc).astimezone()
@@ -777,8 +766,8 @@ def conditions(self, speichersoc: int) -> None:
                 log.info("(" + str(self.device_nummer) + ") " +
                          self.device_name +
                          " Soll reduziert/abgeschaltet werden" +
-                         " bei Ladung, pruefe " + str(testcharge))
-                if chargestatus == 1:
+                         " bei Ladung, pruefe " + str(self.chargestatus))
+                if self.chargestatus:
                     log.info("(" + str(self.device_nummer) + ") " +
                              self.device_name +
                              " Ladung läuft, pruefe Mindestlaufzeit")
@@ -850,8 +839,8 @@ def conditions(self, speichersoc: int) -> None:
                     log.info("(" + str(self.device_nummer) + ") " +
                              self.device_name +
                              " Soll nicht eingeschaltet werden bei" +
-                             " Ladung, pruefe " + str(testcharge))
-                    if chargestatus == 1:
+                             " Ladung, pruefe " + str(self.chargestatus))
+                    if self.chargestatus:
                         log.info("(" + str(self.device_nummer) + ") "
                                  + self.device_name + " Ladung läuft, " +
                                  "wird nicht eingeschaltet")

packages/smarthome/smartcommon.py

@@ -110,7 +110,7 @@ def on_message(client, userdata, msg) -> None:
         log.warning(" Skipped msg " + msg.topic + " Value " + value)
 
 
-def getdevicevalues(uberschuss: int, uberschussoffset: int, pvwatt: int) -> None:
+def getdevicevalues(uberschuss: int, uberschussoffset: int, pvwatt: int, chargestatus: bool) -> None:
     global mydevices
     totalwatt = 0
     totalwattot = 0
@@ -122,6 +122,7 @@ def getdevicevalues(uberschuss: int, uberschussoffset: int, pvwatt: int) -> None
     mqtt_all = {}
     for mydevice in mydevices:
         mydevice.pvwatt = pvwatt
+        mydevice.chargestatus = chargestatus
         mydevice.getwatt(uberschuss, uberschussoffset)
         watt = mydevice.newwatt
         wattk = mydevice.newwattk
@@ -390,7 +391,8 @@ def resetmaxeinschaltdauerfunc() -> None:
         resetmaxeinschaltdauer = 0
 
 
-def loadregelvars(wattbezug: int, speicherleistung: int, speichersoc: int, pvwatt: int) -> Tuple[int, int]:
+def loadregelvars(wattbezug: int, speicherleistung: int, speichersoc: int,
+                  pvwatt: int,  chargestatus: bool) -> Tuple[int, int]:
     global maxspeicher
     global mydevices
     uberschuss = wattbezug + speicherleistung
@@ -400,7 +402,7 @@ def loadregelvars(wattbezug: int, speicherleistung: int, speichersoc: int, pvwat
     log.info("Uberschuss: " + str(uberschuss) +
              " Uberschuss mit Offset: " + str(uberschussoffset) + " Pv: " + str(pvwatt))
     log.info("Speicher Entladung(-)/Ladung(+): " +
-             str(speicherleistung) + " SpeicherSoC: " + str(speichersoc))
+             str(speicherleistung) + " SpeicherSoC: " + str(speichersoc) + " Ladung: " + str(chargestatus))
     reread = 0
     try:
         with open(bp+'/ramdisk/rereadsmarthomedevices', 'r') as value:
@@ -449,16 +451,17 @@ def initparam(inpcg: str, inpcs: str, inpsdevstat: str, inpsglobstat: str, inpto
     mqttport = inpport
 
 
-def mainloop(wattbezug: int, speicherleistung: int, speichersoc: int, pvwatt: int = 0) -> None:
+def mainloop(wattbezug: int, speicherleistung: int, speichersoc: int, pvwatt: int = 0,
+             chargestatus: bool = False) -> None:
     global firststart
     if firststart:
         readmq()
         firststart = False
     mqtt_man = {}
     sendmess = 0
-    uberschuss, uberschussoffset = loadregelvars(wattbezug, speicherleistung, speichersoc, pvwatt)
+    uberschuss, uberschussoffset = loadregelvars(wattbezug, speicherleistung, speichersoc, pvwatt, chargestatus)
     resetmaxeinschaltdauerfunc()
-    getdevicevalues(uberschuss, uberschussoffset, pvwatt)
+    getdevicevalues(uberschuss, uberschussoffset, pvwatt, chargestatus)
     conditions(speichersoc)
     # do the manual stuff
     for i in range(1, (numberOfSupportedDevices+1)):

runs/smarthomemq.py

@@ -2,6 +2,7 @@
 from smarthome.smartcommon import mainloop, initparam
 import time
 import logging
+import os
 log = logging.getLogger("smarthome")
 # openwb 1.9 spec
 mqttcg = 'openWB/config/get/SmartHome/'
@@ -99,5 +100,24 @@ def checkbootdone() -> int:
             log.warning("Fehler beim Auslesen der Ramdisk (wattbezug):"
                         + str(e))
             wattbezug = 0
-        mainloop(wattbezug, speicherleistung, speichersoc)
+        try:
+            with open(bp+'/ramdisk/pvallwatt', 'r') as value:
+                pvwatt = int(float(value.read())) * -1
+        except Exception as e:
+            log.warning("Fehler beim Auslesen der Ramdisk (pvallwatt):"
+                        + str(e))
+            pvwatt = 0
+        file_charge = '/var/www/html/openWB/ramdisk/llkombiniert'
+        testcharge = 0.0
+        try:
+            if os.path.isfile(file_charge):
+                with open(file_charge, 'r') as f:
+                    testcharge = float(f.read())
+        except Exception:
+            pass
+        if testcharge <= 1000:
+            chargestatus = False
+        else:
+            chargestatus = True
+        mainloop(wattbezug, speicherleistung, speichersoc, pvwatt, chargestatus)
         time.sleep(5)