Struggling ; __ ;

This commit is contained in:
TraYali 2024-03-16 15:55:45 +01:00
parent 216ceca3e1
commit b0e50c140e
3 changed files with 101 additions and 43 deletions

View file

@ -10,24 +10,45 @@ struct _modbus;
typedef _modbus modbus_t; typedef _modbus modbus_t;
class PortParameter { class PortParameter {
protected: protected:
uint16_t addressOffset; uint16_t addressOffset;
int registerSize; int registerSize;
void setValue(uint16_t *readArray, int registerCount); virtual void setValue(uint16_t *readArray, int registerCount);
public: public:
PortParameter(std::string name, uint16_t addressOffset, int registerSize); PortParameter(std::string name, uint16_t addressOffset, int registerSize);
std::string name; std::string name;
int age; int age;
int value;
virtual void updateValue(modbus_t *modbus_context, uint16_t portStartAddress); virtual void updateValue(modbus_t *modbus_context, uint16_t portStartAddress);
}; };
class PortParameterSerialNumber : public PortParameter {
template<typename Type>
class PortParameterTemplate : virtual public PortParameter {
public:
PortParameterTemplate(std::string name, uint16_t addressOffset, int registerSize);
Type value;
Type getValue();
};
class PortParameterInt : public PortParameterTemplate<int> {
private:
void setValue(uint16_t *readArray, int registerCount);
public:
PortParameterInt();
};
class PortParameterSerialNumber : public PortParameterTemplate<std::string> {
private: private:
void setValue(uint16_t *readArray, int registerCount); void setValue(uint16_t *readArray, int registerCount);
@ -35,7 +56,9 @@ class PortParameterSerialNumber : public PortParameter {
PortParameterSerialNumber(); PortParameterSerialNumber();
}; };
class PortParameterFloat : public PortParameter {
class PortParameterFloat : public PortParameterTemplate<float> {
private: private:
int decimalPlaces; int decimalPlaces;
@ -47,6 +70,8 @@ class PortParameterFloat : public PortParameter {
float value; float value;
}; };
class Port { class Port {
private: private:
modbus_t *modbus_context; modbus_t *modbus_context;
@ -60,8 +85,14 @@ class Port {
Port(modbus_t *modbus_context, uint16_t portStartAddress); Port(modbus_t *modbus_context, uint16_t portStartAddress);
void updateParameters(); void updateParameters();
std::shared_ptr<PortParameter> getParameterById(int i);
std::shared_ptr<PortParameter> getParameterByName(std::string name);
}; };
class Microinverter { class Microinverter {
private: private:
modbus_t *modbus_context; modbus_t *modbus_context;
@ -80,6 +111,8 @@ class Microinverter {
Port getPort(int i); Port getPort(int i);
}; };
class Dtu { class Dtu {
private: private:
modbus_t *modbus_context; modbus_t *modbus_context;

View file

@ -3,6 +3,7 @@
#include <cmath> #include <cmath>
#include <iostream> #include <iostream>
#include <typeinfo>
Dtu::Dtu(const char *ip_address, int port) { Dtu::Dtu(const char *ip_address, int port) {
this->modbus_context = modbus_new_tcp(ip_address, port); this->modbus_context = modbus_new_tcp(ip_address, port);
@ -34,33 +35,7 @@ void Dtu::updateMicroinverters() {
} }
} }
void PortParameter::setValue(uint16_t *readArray, int registerCount) {
this->value = readArray[0];
}
PortParameter::PortParameter(std::string name, uint16_t addressOffset, int registerSize) {
this->name = name;
this->addressOffset = addressOffset;
this->registerSize = registerSize;
this->value = 0;
}
void PortParameter::updateValue(modbus_t *modbus_context, uint16_t microinverterAddress) {
uint16_t readArray[this->registerSize];
int registerCount;
registerCount = modbus_read_registers(modbus_context, microinverterAddress + this->addressOffset, this->registerSize, readArray);
registerCount = 2;
readArray[0] = 2309;
readArray[1] = 4354;
if (registerCount == -1) {
this->age++;
} else {
this->setValue(readArray, registerCount);
this->age = 0;
}
}
void Microinverter::populatePorts() { void Microinverter::populatePorts() {
Port port{this->modbus_context, 0x1000}; Port port{this->modbus_context, 0x1000};
@ -80,10 +55,21 @@ Microinverter::Microinverter(modbus_t *modbus_context) {
this->populatePorts(); this->populatePorts();
} }
void Port::populateParameters() {
PortParameterFloat portParameter{"gridVoltage", 0x0034, 2, 1};
this->parameters.push_back(std::make_shared<PortParameterFloat>(portParameter));
Port::Port(modbus_t *modbus_context, uint16_t portStartAddress) {
this->modbus_context = modbus_context;
this->portStartAddress = portStartAddress;
this->populateParameters();
}
void Port::populateParameters() {
PortParameterFloat portParameterFloat{"gridVoltage", 0x0034, 2, 1};
this->parameters.push_back(std::make_shared<PortParameterFloat>(portParameterFloat));
PortParameterSerialNumber portParameterSerialNumber{};
this->parameters.push_back(std::make_shared<PortParameterSerialNumber>(portParameterSerialNumber));
} }
void Port::updateParameters() { void Port::updateParameters() {
@ -94,14 +80,44 @@ void Port::updateParameters() {
} }
} }
Port::Port(modbus_t *modbus_context, uint16_t portStartAddress) { std::shared_ptr<PortParameter> Port::getParameterById(int i) {
this->modbus_context = modbus_context; return this->parameters.at(i);
this->portStartAddress = portStartAddress;
this->populateParameters();
} }
PortParameterFloat::PortParameterFloat(std::string name, uint16_t addressOffset, int registerSize, int decimalPlaces) : PortParameter(name, addressOffset, registerSize) {
PortParameter::PortParameter(std::string name, uint16_t addressOffset, int registerSize) {
this->name = name;
this->addressOffset = addressOffset;
this->registerSize = registerSize;
}
void PortParameter::updateValue(modbus_t *modbus_context, uint16_t microinverterAddress) {
uint16_t readArray[this->registerSize];
int registerCount;
registerCount = modbus_read_registers(modbus_context, microinverterAddress + this->addressOffset, this->registerSize, readArray);
registerCount = 2;
readArray[0] = 2309;
readArray[1] = 4354;
if (registerCount == -1) {
this->age++;
} else {
this->setValue(readArray, registerCount);
this->age = 0;
}
}
void PortParameter::setValue(uint16_t *readArray, int registerCount) {}
template<typename Type>
PortParameterTemplate<Type>::PortParameterTemplate(std::string name, uint16_t addressOffset, int registerSize) : PortParameter(name, addressOffset, registerSize) {}
PortParameterFloat::PortParameterFloat(std::string name, uint16_t addressOffset, int registerSize, int decimalPlaces) : PortParameterTemplate<float>(name, addressOffset, registerSize), PortParameter(name, addressOffset, registerSize) {
this->decimalPlaces = decimalPlaces; this->decimalPlaces = decimalPlaces;
this->value = 0; this->value = 0;
} }
@ -112,7 +128,14 @@ void PortParameterFloat::setValue(uint16_t *readArray, int registerCount) {
this->value = readValue / std::pow(10, this->decimalPlaces); this->value = readValue / std::pow(10, this->decimalPlaces);
} }
PortParameterSerialNumber::PortParameterSerialNumber() : PortParameter("serialNumber", 0x0001, 6){}; template<typename Type>
Type PortParameterTemplate<Type>::getValue() {
return this->value;
}
PortParameterSerialNumber::PortParameterSerialNumber() : PortParameterTemplate<std::string>("serialNumber", 0x0001, 6), PortParameter("serialNumber", 0x0001, 6) {};
void PortParameterSerialNumber::setValue(uint16_t *readArray, int registerCount) { void PortParameterSerialNumber::setValue(uint16_t *readArray, int registerCount) {
uint16_t readValue; uint16_t readValue;

View file

@ -21,5 +21,7 @@ int main(){
hoymilesPort.updateParameters(); hoymilesPort.updateParameters();
std::shared_ptr<PortParameter> temp{hoymilesPort.getParameterById(0)};
float temp2 = temp.get()->getValue();
return 0; return 0;
} }