New PowerMeter Class for PowerLimiter

README.md

@@ -1,4 +1,15 @@
-# OpenDTU_VeDirect
+# OpenDTU_PowerLimiter
+
+This is a fork from the project OpenDTU_VeDirect which is a fork from the Hoymiles project OpenDTU.
+
+This project is still under development and adds following features:
+
+* Dynamically sets the Hoymiles power limited according to the currently used energy in the household (needs an MQTT based power meter like Shelly 3EM)
+* Battery support: Read the voltage from Victron MPPT charge controller or from the Hoymiles DC inputs and starts/stops the power producing based on configurable voltage thresholds
+* Voltage correction that takes the voltage drop because of the current output load into account (not 100% reliable calculation)
+* Can read the current solar panel power from the Victron MPPT and adjust the limiter accordingly to not save energy in the battery (for increased system efficiency). Increases the battery lifespan and reduces energy loses.
+* Settings can be configured in the UI
+* Pylontech Battery support (via CAN bus interface). Use the SOC for starting/stopping the power output and provide the battery data via MQTT
 
 [![OpenDTU Build](https://github.com/tbnobody/OpenDTU/actions/workflows/build.yml/badge.svg)](https://github.com/tbnobody/OpenDTU/actions/workflows/build.yml)
 [![cpplint](https://github.com/tbnobody/OpenDTU/actions/workflows/cpplint.yml/badge.svg)](https://github.com/tbnobody/OpenDTU/actions/workflows/cpplint.yml)

include/Battery.h

@@ -0,0 +1,43 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include <stdint.h>
+
+class BatteryClass {
+public:
+    float chargeVoltage;
+    float chargeCurrentLimitation;
+    float dischargeCurrentLimitation;
+    uint16_t stateOfCharge;
+    uint32_t stateOfChargeLastUpdate;
+    uint16_t stateOfHealth;
+    float voltage;
+    float current;
+    float temperature;
+    bool alarmOverCurrentDischarge;
+    bool alarmUnderTemperature;
+    bool alarmOverTemperature;
+    bool alarmUnderVoltage;
+    bool alarmOverVoltage;
+
+    bool alarmBmsInternal;
+    bool alarmOverCurrentCharge;
+
+
+    bool warningHighCurrentDischarge;
+    bool warningLowTemperature;
+    bool warningHighTemperature;
+    bool warningLowVoltage;
+    bool warningHighVoltage;
+
+    bool warningBmsInternal;
+    bool warningHighCurrentCharge;
+    char manufacturer[9];
+    bool chargeEnabled;
+    bool dischargeEnabled;
+    bool chargeImmediately;
+
+private:
+};
+
+extern BatteryClass Battery;

include/Configuration.h

@@ -17,7 +17,7 @@
 #define MQTT_MAX_HOSTNAME_STRLEN 128
 #define MQTT_MAX_USERNAME_STRLEN 64
 #define MQTT_MAX_PASSWORD_STRLEN 64
-#define MQTT_MAX_TOPIC_STRLEN 32
+#define MQTT_MAX_TOPIC_STRLEN 256
 #define MQTT_MAX_LWTVALUE_STRLEN 20
 #define MQTT_MAX_ROOT_CA_CERT_STRLEN 2048 
 
@@ -27,7 +27,7 @@
 
 #define CHAN_MAX_NAME_STRLEN 31
 
-#define JSON_BUFFER_SIZE 6144
+#define JSON_BUFFER_SIZE 8192
 
 struct CHANNEL_CONFIG_T {
     uint16_t MaxChannelPower;
@@ -90,6 +90,30 @@ struct CONFIG_T {
 
     bool Mqtt_Hass_Expire;
 
+
+    bool PowerMeter_Enabled;
+    uint32_t PowerMeter_Interval;
+    uint32_t PowerMeter_Source;
+    char PowerMeter_MqttTopicPowerMeter1[MQTT_MAX_TOPIC_STRLEN + 1];
+    char PowerMeter_MqttTopicPowerMeter2[MQTT_MAX_TOPIC_STRLEN + 1];
+    char PowerMeter_MqttTopicPowerMeter3[MQTT_MAX_TOPIC_STRLEN + 1];
+    uint32_t PowerMeter_SdmBaudrate;
+    uint32_t PowerMeter_SdmAddress;
+
+    bool PowerLimiter_Enabled;
+    bool PowerLimiter_SolarPassTroughEnabled;
+    uint32_t PowerLimiter_Interval;
+    bool PowerLimiter_IsInverterBehindPowerMeter;
+    uint32_t PowerLimiter_LowerPowerLimit;
+    uint32_t PowerLimiter_UpperPowerLimit;
+    uint32_t PowerLimiter_BatterySocStartThreshold;
+    uint32_t PowerLimiter_BatterySocStopThreshold;
+    float PowerLimiter_VoltageStartThreshold;
+    float PowerLimiter_VoltageStopThreshold;
+    float PowerLimiter_VoltageLoadCorrectionFactor;
+
+    bool Battery_Enabled;
+
     char Security_Password[WIFI_MAX_PASSWORD_STRLEN + 1];
     bool Security_AllowReadonly;
 };

include/PowerLimiter.h

@@ -0,0 +1,34 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include "Configuration.h"
+#include <espMqttClient.h>
+#include <Arduino.h>
+#include <Hoymiles.h>
+#include <memory>
+
+class PowerLimiterClass {
+public:
+    void init();
+    void loop();
+    void onMqttMessage(const espMqttClientTypes::MessageProperties& properties, const char* topic, const uint8_t* payload, size_t len, size_t index, size_t total);
+
+private:
+    uint32_t _lastCommandSent;
+    uint32_t _lastLoop;
+    uint32_t _lastPowerMeterUpdate;
+    uint16_t _lastRequestedPowerLimit;
+    bool _consumeSolarPowerOnly;
+
+    float _powerMeter1Power;
+    float _powerMeter2Power;
+    float _powerMeter3Power;
+
+    bool canUseDirectSolarPower();
+    uint32_t getDirectSolarPower();
+    float getLoadCorrectedVoltage(std::shared_ptr<InverterAbstract> inverter);
+    bool isStartThresholdReached(std::shared_ptr<InverterAbstract> inverter);
+    bool isStopThresholdReached(std::shared_ptr<InverterAbstract> inverter);
+};
+
+extern PowerLimiterClass PowerLimiter;

include/PowerMeter.h

@@ -0,0 +1,37 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include "Configuration.h"
+#include <espMqttClient.h>
+#include <Arduino.h>
+#include <Hoymiles.h>
+#include <memory>
+#include "SDM.h"
+
+#ifndef SDM_RX_PIN
+#define SDM_RX_PIN 13
+#endif
+
+#ifndef SDM_TX_PIN
+#define SDM_TX_PIN 32
+#endif
+
+class PowerMeterClass {
+public:
+    void init();
+    void loop();
+    void onMqttMessage(const espMqttClientTypes::MessageProperties& properties, const char* topic, const uint8_t* payload, size_t len, size_t index, size_t total);
+    float getPowerTotal();
+
+private:
+    uint32_t _interval;
+    uint32_t _lastPowerMeterUpdate;
+
+    float _powerMeter1Power;
+    float _powerMeter2Power;
+    float _powerMeter3Power;
+    float _powerMeterTotalPower;
+
+};
+
+extern PowerMeterClass PowerMeter;

include/PylontechCanReceiver.h

@@ -0,0 +1,37 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include "Configuration.h"
+#include <espMqttClient.h>
+#include <Arduino.h>
+#include <Hoymiles.h>
+#include <memory>
+
+#ifndef PYLONTECH_PIN_RX
+#define PYLONTECH_PIN_RX 27
+#endif
+
+#ifndef PYLONTECH_PIN_TX
+#define PYLONTECH_PIN_TX 26
+#endif
+
+class PylontechCanReceiverClass {
+public:
+    void init();
+    void loop();
+    void parseCanPackets();
+    void mqtt();
+
+private:
+    uint8_t readUnsignedInt8();
+    uint16_t readUnsignedInt16();
+    int16_t readSignedInt16();
+    void readString(char* str, uint8_t numBytes);
+    void readBooleanBits8(bool* b, uint8_t numBits);
+    float scaleValue(int16_t value, float factor);
+    bool getBit(uint8_t value, uint8_t bit);
+
+    uint32_t _lastPublish;
+};
+
+extern PylontechCanReceiverClass PylontechCanReceiver;

include/WebApi.h

@@ -1,6 +1,7 @@
 // SPDX-License-Identifier: GPL-2.0-or-later
 #pragma once
 
+#include "WebApi_battery.h"
 #include "WebApi_config.h"
 #include "WebApi_devinfo.h"
 #include "WebApi_dtu.h"
@@ -13,6 +14,8 @@
 #include "WebApi_network.h"
 #include "WebApi_ntp.h"
 #include "WebApi_power.h"
+#include "WebApi_powermeter.h"
+#include "WebApi_powerlimiter.h"
 #include "WebApi_prometheus.h"
 #include "WebApi_security.h"
 #include "WebApi_sysstatus.h"
@@ -36,6 +39,7 @@ class WebApiClass {
     AsyncWebServer _server;
     AsyncEventSource _events;
 
+    WebApiBatteryClass _webApiBattery;
     WebApiConfigClass _webApiConfig;
     WebApiDevInfoClass _webApiDevInfo;
     WebApiDtuClass _webApiDtu;
@@ -48,6 +52,8 @@ class WebApiClass {
     WebApiNetworkClass _webApiNetwork;
     WebApiNtpClass _webApiNtp;
     WebApiPowerClass _webApiPower;
+    WebApiPowerMeterClass _webApiPowerMeter;
+    WebApiPowerLimiterClass _webApiPowerLimiter;
     WebApiPrometheusClass _webApiPrometheus;
     WebApiSecurityClass _webApiSecurity;
     WebApiSysstatusClass _webApiSysstatus;

include/WebApi_battery.h

@@ -0,0 +1,18 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include <ESPAsyncWebServer.h>
+
+
+class WebApiBatteryClass {
+public:
+    void init(AsyncWebServer* server);
+    void loop();
+
+private:
+    void onStatus(AsyncWebServerRequest* request);
+    void onAdminGet(AsyncWebServerRequest* request);
+    void onAdminPost(AsyncWebServerRequest* request);
+
+    AsyncWebServer* _server;
+};

include/WebApi_powerlimiter.h

@@ -0,0 +1,18 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include <ESPAsyncWebServer.h>
+
+
+class WebApiPowerLimiterClass {
+public:
+    void init(AsyncWebServer* server);
+    void loop();
+
+private:
+    void onStatus(AsyncWebServerRequest* request);
+    void onAdminGet(AsyncWebServerRequest* request);
+    void onAdminPost(AsyncWebServerRequest* request);
+
+    AsyncWebServer* _server;
+};

include/WebApi_powermeter.h

@@ -0,0 +1,18 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+#pragma once
+
+#include <ESPAsyncWebServer.h>
+
+
+class WebApiPowerMeterClass {
+public:
+    void init(AsyncWebServer* server);
+    void loop();
+
+private:
+    void onStatus(AsyncWebServerRequest* request);
+    void onAdminGet(AsyncWebServerRequest* request);
+    void onAdminPost(AsyncWebServerRequest* request);
+
+    AsyncWebServer* _server;
+};

include/defaults.h

@@ -81,4 +81,24 @@
 
 #define VEDIRECT_ENABLED false
 #define VEDIRECT_UPDATESONLY true
-#define VEDIRECT_POLL_INTERVAL 5
+#define VEDIRECT_POLL_INTERVAL 5
+
+#define POWERMETER_ENABLED false
+#define POWERMETER_INTERVAL 10
+#define POWERMETER_SOURCE 2
+#define POWERMETER_SDMBAUDRATE 9600
+#define POWERMETER_SDMADDRESS 1
+
+#define POWERLIMITER_ENABLED false
+#define POWERLIMITER_SOLAR_PASSTROUGH_ENABLED true
+#define POWERLIMITER_INTERVAL 10
+#define POWERLIMITER_IS_INVERTER_BEHIND_POWER_METER true
+#define POWERLIMITER_LOWER_POWER_LIMIT 10
+#define POWERLIMITER_UPPER_POWER_LIMIT 800
+#define POWERLIMITER_BATTERY_SOC_START_THRESHOLD 80
+#define POWERLIMITER_BATTERY_SOC_STOP_THRESHOLD 20
+#define POWERLIMITER_VOLTAGE_START_THRESHOLD 50.0
+#define POWERLIMITER_VOLTAGE_STOP_THRESHOLD 49.0
+#define POWERLIMITER_VOLTAGE_LOAD_CORRECTION_FACTOR 0.001
+
+#define BATTERY_ENABLED false