Zmartcharge support (#1007)

* ZC initial implementation * ZmartCharge * Fixed zc bug * Adjustments to ZmartCharge connection
2026-04-28 21:08:15 +00:00 · 2025-09-25 11:38:05 +02:00
parent 633671851e
commit e5d260ae3e
10 changed files with 315 additions and 13 deletions
--- a/lib/ZmartCharge/include/ZmartChargeCloudConnector.h
+++ b/lib/ZmartCharge/include/ZmartChargeCloudConnector.h
@@ -0,0 +1,52 @@
+#pragma once
+
+#include "RemoteDebug.h"
+#include "AmsData.h"
+#include "FirmwareVersion.h"
+
+#if defined(ESP8266)
+	#include <ESP8266HTTPClient.h>
+#elif defined(ESP32) // ARDUINO_ARCH_ESP32
+	#include <HTTPClient.h>
+#else
+	#warning "Unsupported board type"
+#endif
+
+static const char ZC_LB_JSON[] PROGMEM = "{\"LBToken\":\"%s\",\"L1A\":\"%.1f\",\"L2A\":\"%.1f\",\"L3A\":\"%.1f\",\"HighConsumption\":\"%d\",\"CurrentPower\":\"%d\"}";
+
+class ZmartChargeCloudConnector {
+public:
+    ZmartChargeCloudConnector(RemoteDebug* debugger, char* buf) {
+        this->debugger = debugger;
+        this->json = buf;
+        http = new HTTPClient();
+        http->setFollowRedirects(HTTPC_STRICT_FOLLOW_REDIRECTS);
+        http->setReuse(false);
+        http->setTimeout(10000);
+        http->setUserAgent("ams2mqtt/" + String(FirmwareVersion::VersionString));
+    };
+    void setup(const char* baseUrl, const char* token);
+    void update(AmsData& data);
+
+    bool isConfigChanged();
+    void ackConfigChanged();
+
+    const char* getBaseUrl();
+
+private:
+    RemoteDebug* debugger;
+    char baseUrl[64];
+    char token[21];
+    uint16_t BufferSize = 2048;
+    char* json;
+
+    bool configChanged = false;
+
+    bool lastFailed = false;
+    uint64_t lastUpdate = 0;
+    HTTPClient* http = NULL;
+
+    uint16_t heartbeat = 30;
+    uint16_t heartbeatFast = 10;
+    uint16_t heartbeatFastThreshold = 32;
+};
--- a/lib/ZmartCharge/src/ZmartChargeCloudConnector.cpp
+++ b/lib/ZmartCharge/src/ZmartChargeCloudConnector.cpp
@@ -0,0 +1,100 @@
+#include "ZmartChargeCloudConnector.h"
+#include "Uptime.h"
+#include "ArduinoJson.h"
+
+void ZmartChargeCloudConnector::setup(const char* baseUrl, const char* token) {
+    memset(this->baseUrl, 0, 64);
+    memset(this->token, 0, 21);
+    strcpy(this->baseUrl, baseUrl);
+    strcpy(this->token, token);
+}
+
+bool ZmartChargeCloudConnector::isConfigChanged() {
+    return configChanged;
+}
+
+void ZmartChargeCloudConnector::ackConfigChanged() {
+    configChanged = false;
+}
+
+const char* ZmartChargeCloudConnector::getBaseUrl() {
+    return baseUrl;
+}
+
+
+void ZmartChargeCloudConnector::update(AmsData& data) {
+    if(strlen(token) == 0) return;
+
+    uint64_t now = millis64();
+
+    float maximum = max(max(data.getL1Current(), data.getL1Current()), data.getL3Current());
+    bool fast = maximum > heartbeatFastThreshold;
+
+    if(now - lastUpdate < (fast ? heartbeatFast : heartbeat) * 1000) return;
+
+    if(strlen(token) != 20) {
+        lastUpdate = now;
+        if(debugger->isActive(RemoteDebug::WARNING)) debugger->printf_P(PSTR("(ZmartCharge) Token defined, but is incorrect length (%s, %d)\n"), token, strlen(token));
+        return;
+    }
+
+    if(((now - lastUpdate) / 1000) > (fast || lastFailed ? heartbeatFast : heartbeat)) {
+        if(debugger->isActive(RemoteDebug::DEBUG)) debugger->printf_P(PSTR("(ZmartCharge) Preparing to update cloud\n"));
+        memset(json, 0, BufferSize);
+        snprintf_P(json, BufferSize, ZC_LB_JSON,
+            token,
+            data.getL1Current(),
+            data.getL2Current(),
+            data.getL3Current(),
+            fast ? 1 : 0,
+            data.getActiveImportPower()
+        );
+        lastFailed = true;
+        char url[128];
+        memset(url, 0, 128);
+        snprintf_P(url, 128, PSTR("%s/loadbalancer"), baseUrl);
+        if(debugger->isActive(RemoteDebug::VERBOSE)) debugger->printf_P(PSTR("(ZmartCharge) Connecting to: %s\n"), baseUrl);
+        if(http->begin(url)) {
+            if(debugger->isActive(RemoteDebug::VERBOSE)) debugger->printf_P(PSTR("(ZmartCharge) Sending data: %s\n"), json);
+            int status = http->POST(json);
+            if(status == 200) {
+                lastFailed = false;
+                JsonDocument doc;
+                String body = http->getString();
+                if(debugger->isActive(RemoteDebug::VERBOSE)) debugger->printf_P(PSTR("(ZmartCharge) Received data: %s\n"), body.c_str());
+                deserializeJson(doc, body);
+                if(doc.containsKey("Settings")) {
+                    if(doc["Settings"].containsKey("HeartBeatTime")) {
+                        heartbeat = doc["Settings"]["HeartBeatTime"].as<long>();
+                    }
+                    if(doc["Settings"].containsKey("HearBeatTimeFast")) {
+                        heartbeatFast = doc["Settings"]["HearBeatTimeFast"].as<long>();
+                    }
+                    if(doc["Settings"].containsKey("HeartBeatTimeFastThreshold")) {
+                        heartbeatFastThreshold = doc["Settings"]["HeartBeatTimeFastThreshold"].as<long>();
+                    }
+                    if(doc["Settings"].containsKey("ZmartChargeUrl")) {
+                        String newBaseUrl = doc["Settings"]["ZmartChargeUrl"].as<String>();
+                        if(newBaseUrl.startsWith("https:") && strncmp(newBaseUrl.c_str(), baseUrl, strlen(baseUrl)) != 0) {
+                            newBaseUrl.replace("\\/", "/");
+                            if(debugger->isActive(RemoteDebug::INFO)) debugger->printf_P(PSTR("(ZmartCharge) Received new URL: %s\n"), newBaseUrl.c_str());
+                            memset(baseUrl, 0, 64);
+                            memcpy(baseUrl, newBaseUrl.c_str(), strlen(newBaseUrl.c_str()));
+                            configChanged = true;
+                        }
+                    }
+                }
+                http->end();
+            } else {
+                if(debugger->isActive(RemoteDebug::ERROR)) debugger->printf_P(PSTR("(ZmartCharge) Communication error, returned status: %d\n"), status);
+                if(debugger->isActive(RemoteDebug::ERROR)) debugger->printf(http->errorToString(status).c_str());
+                if(debugger->isActive(RemoteDebug::DEBUG)) debugger->printf(http->getString().c_str());
+
+                http->end();
+            }
+        } else {
+            if(debugger->isActive(RemoteDebug::ERROR)) debugger->printf_P(PSTR("(ZmartCharge) Unable to establish connection with cloud\n"));
+        }
+        lastUpdate = now;
+    }
+}