Merge pull request #32 from JasperE84/v2.0.5-dev

V2.0.5 dev

Author: JasperE84

README.md

@@ -172,6 +172,7 @@ Take the following steps to achieve this:
 # Changelog
 | Version | Description |
 | --- | --- |
+| 2.0.5 | Bugfix for incorrect fusionsolar northbound API docs, which state active_power for inverters returns kW, but in fact returns W |
 | 2.0.4 | Bugfix for fusionsolar cumulative energy quirk where cumulative energy provided by dashboard shortly decreases with the days production |
 | 2.0.3 | Bugfix in scheduler |
 | 2.0.2 | Default to kW in home assistant with 3 digit precision suggestion |

main.py

@@ -19,7 +19,7 @@
 formatter = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
 streamHandler.setFormatter(formatter)
 logger.addHandler(streamHandler)
-logger.info("PyFusionSolarDataRelay 2.0.4 started")
+logger.info("PyFusionSolarDataRelay 2.0.5 started")
 
 # Config
 conf = Conf(logger).read_and_validate_config()

modules/fetch_fusion_solar_open_api.py

@@ -161,10 +161,12 @@ def fetch_fusionsolar_grid_meter_device_kpis(self) -> List[FusionSolarMeterMeasu
         inverter_measurements = []
         for api_measurement in api_measurement_list:
             try:
-                active_power_w = float(api_measurement["dataItemMap"]["active_power"]) * 1000
+                # Do not multiply by 1000, fusionsolar returns W instead of kW despite docs saying kW
+                active_power_w = float(api_measurement["dataItemMap"]["active_power"])
 
-                # fix for fusionsolar openapi quirk
-                # active_power_w = 0 if int(active_power_w) == -65230000000 else active_power_w
+                # Fix for fusionsolar meter device quirk, set to 0 of power drawn is greater than 16bits maxout (66.55MW) plus 10MW pv capacity
+                quirk_threshold_w = float(-66553500 + 10000000)
+                active_power_w = 0 if active_power_w < quirk_threshold_w else active_power_w
 
             except KeyError as missing_key:
                 self.logger.error(f"Key '{missing_key}' is missing from FusionSolarOpenAPI grid meter measurement. Skipping this device.")

modules/relay_fusionsolar_kiosk.py

@@ -59,7 +59,7 @@ def write_pvdata_to_pvoutput(self, kiosk_measurement: FusionSolarInverterMeasure
                 # Log but do not raise, other outputs should proceed.
                 self.logger.exception(f"Error writing PV data to PVOutput.org for fusionsolar kiosk [{kiosk_settings.descriptive_name}] with kkid [{kiosk_settings.api_kkid}]: {e}")
         else:
-            self.logger.debug(f"Skipping publishing to InfluxDB, module disabled, or PVOutput disabled in fusionsolar kiosk config.")
+            self.logger.debug(f"Skipping publishing to PvOutput, module disabled, or PVOutput disabled in fusionsolar kiosk config.")
 
     def publish_pvdata_to_mqtt(self, kiosk_measurement: FusionSolarInverterMeasurement, kiosk_settings: FusionSolarKioskSettings):
         if self.conf.mqtt_module_enabled and kiosk_settings.output_mqtt:

modules/relay_fusionsolar_open_api.py

@@ -79,7 +79,7 @@ def write_pvdata_to_pvoutput(self, inverter_measurement: FusionSolarInverterMeas
                     f"Error writing PV data to PVOutput.org for fusionsolar open_api [{inverter_measurement.settings_descriptive_name}] with dev_id [{inverter_measurement.settings_device_id}]: {e}"
                 )
         else:
-            self.logger.debug(f"Skipping publishing to InfluxDB, module disabled, or PVOutput disabled in fusionsolar open_api config.")
+            self.logger.debug(f"Skipping publishing to PvOutpu, module disabled, or PVOutput disabled in fusionsolar open_api config.")
 
     def publish_pvdata_to_mqtt(self, inverter_measurement: FusionSolarInverterMeasurement):
         if self.conf.mqtt_module_enabled and ((inverter_measurement.settings is not None and inverter_measurement.settings.output_mqtt) or self.conf.fusionsolar_open_api_mqtt_for_discovered_dev):