Patrick Haßel
52e2b1cffb
Some checks failed
OpenDTU Build / Gather Environments (push) Has been cancelled
cpplint / build (push) Has been cancelled
Yarn Linting / build (push) Has been cancelled
Yarn Prettier / build (push) Has been cancelled
OpenDTU Build / Build Environments (push) Has been cancelled
OpenDTU Build / Create Release (push) Has been cancelled
76 lines
2.3 KiB
C++
76 lines
2.3 KiB
C++
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
#pragma once
|
|
|
|
#include "Configuration.h"
|
|
#include <Hoymiles.h>
|
|
#include <TaskSchedulerDeclarations.h>
|
|
#include <espMqttClient.h>
|
|
#include <frozen/map.h>
|
|
#include <frozen/string.h>
|
|
|
|
class MqttHandleInverterClass {
|
|
public:
|
|
MqttHandleInverterClass();
|
|
void init(Scheduler& scheduler);
|
|
|
|
static String getTopic(std::shared_ptr<InverterAbstract> inv, const ChannelType_t type, const ChannelNum_t channel, const FieldId_t fieldId);
|
|
|
|
void subscribeTopics();
|
|
void unsubscribeTopics();
|
|
|
|
private:
|
|
void loop();
|
|
|
|
static void patrixSend(const std::shared_ptr<InverterAbstract>& inv);
|
|
|
|
static double patrixGetField(const std::shared_ptr<InverterAbstract>& inv, const ChannelType_t type, const ChannelNum_t channel, const FieldId_t fieldId);
|
|
|
|
void publishField(std::shared_ptr<InverterAbstract> inv, const ChannelType_t type, const ChannelNum_t channel, const FieldId_t fieldId);
|
|
|
|
Task _loopTask;
|
|
|
|
uint32_t _lastPublishStats[INV_MAX_COUNT] = { 0 };
|
|
|
|
FieldId_t _publishFields[14] = {
|
|
FLD_UDC,
|
|
FLD_IDC,
|
|
FLD_PDC,
|
|
FLD_YD,
|
|
FLD_YT,
|
|
FLD_UAC,
|
|
FLD_IAC,
|
|
FLD_PAC,
|
|
FLD_F,
|
|
FLD_T,
|
|
FLD_PF,
|
|
FLD_EFF,
|
|
FLD_IRR,
|
|
FLD_Q
|
|
};
|
|
|
|
enum class Topic : unsigned {
|
|
LimitPersistentRelative,
|
|
LimitPersistentAbsolute,
|
|
LimitNonPersistentRelative,
|
|
LimitNonPersistentAbsolute,
|
|
Power,
|
|
Restart,
|
|
ResetRfStats,
|
|
};
|
|
|
|
static constexpr frozen::string _cmdtopic = "+/cmd/";
|
|
static constexpr frozen::map<frozen::string, Topic, 7> _subscriptions = {
|
|
{ "limit_persistent_relative", Topic::LimitPersistentRelative },
|
|
{ "limit_persistent_absolute", Topic::LimitPersistentAbsolute },
|
|
{ "limit_nonpersistent_relative", Topic::LimitNonPersistentRelative },
|
|
{ "limit_nonpersistent_absolute", Topic::LimitNonPersistentAbsolute },
|
|
{ "power", Topic::Power },
|
|
{ "restart", Topic::Restart },
|
|
{ "reset_rf_stats", Topic::ResetRfStats },
|
|
};
|
|
|
|
void onMqttMessage(Topic t, const espMqttClientTypes::MessageProperties& properties, const char* topic, const uint8_t* payload, const size_t len, const size_t index, const size_t total);
|
|
};
|
|
|
|
extern MqttHandleInverterClass MqttHandleInverter;
|