Added web api to set limit

This commit is contained in:
Thomas Basler 2022-09-16 18:18:32 +02:00
parent a2880cc447
commit d57a5f7ea6
2 changed files with 71 additions and 0 deletions

View File

@ -10,6 +10,7 @@ public:
private: private:
void onLimitStatus(AsyncWebServerRequest* request); void onLimitStatus(AsyncWebServerRequest* request);
void onLimitPost(AsyncWebServerRequest* request);
AsyncWebServer* _server; AsyncWebServer* _server;
}; };

View File

@ -14,6 +14,7 @@ void WebApiLimitClass::init(AsyncWebServer* server)
_server = server; _server = server;
_server->on("/api/limit/status", HTTP_GET, std::bind(&WebApiLimitClass::onLimitStatus, this, _1)); _server->on("/api/limit/status", HTTP_GET, std::bind(&WebApiLimitClass::onLimitStatus, this, _1));
_server->on("/api/limit/config", HTTP_POST, std::bind(&WebApiLimitClass::onLimitPost, this, _1));
} }
void WebApiLimitClass::loop() void WebApiLimitClass::loop()
@ -37,6 +38,75 @@ void WebApiLimitClass::onLimitStatus(AsyncWebServerRequest* request)
root[buffer]["limit"] = inv->SystemConfigPara()->getLimitPercent(); root[buffer]["limit"] = inv->SystemConfigPara()->getLimitPercent();
} }
response->setLength();
request->send(response);
}
void WebApiLimitClass::onLimitPost(AsyncWebServerRequest* request)
{
AsyncJsonResponse* response = new AsyncJsonResponse();
JsonObject retMsg = response->getRoot();
retMsg[F("type")] = F("warning");
if (!request->hasParam("data", true)) {
retMsg[F("message")] = F("No values found!");
response->setLength();
request->send(response);
return;
}
String json = request->getParam("data", true)->value();
if (json.length() > 1024) {
retMsg[F("message")] = F("Data too large!");
response->setLength();
request->send(response);
return;
}
DynamicJsonDocument root(1024);
DeserializationError error = deserializeJson(root, json);
if (error) {
retMsg[F("message")] = F("Failed to parse data!");
response->setLength();
request->send(response);
return;
}
if (!(root.containsKey("serial")
&& root.containsKey("limit_value")
&& root.containsKey("limit_type"))) {
retMsg[F("message")] = F("Values are missing!");
response->setLength();
request->send(response);
return;
}
if (root[F("serial")].as<uint64_t>() == 0) {
retMsg[F("message")] = F("Serial must be a number > 0!");
response->setLength();
request->send(response);
return;
}
if (root[F("limit_value")].as<uint32_t>() == 0 || root[F("limit_value")].as<uint32_t>() > 1500) {
retMsg[F("message")] = F("Limit must between 1 and 1500!");
response->setLength();
request->send(response);
return;
}
uint64_t serial = strtoll(root[F("serial")].as<String>().c_str(), NULL, 16);
uint64_t limit = root[F("serial")].as<uint64_t>();
auto inv = Hoymiles.getInverterBySerial(serial);
inv->sendActivePowerControlRequest(Hoymiles.getRadio(), limit, PowerLimitControlType::RelativNonPersistent);
retMsg[F("type")] = F("success");
retMsg[F("message")] = F("Settings saved!");
response->setLength(); response->setLength();
request->send(response); request->send(response);
} }