trabus322/hoymilesClient
1
0
Fork 0
Code Issues 4 Pull requests Projects 3 Releases Packages Wiki Activity

Compare commits

base: trabus322:0381c3c334344b2cac6a57b250425e6edc7a5a6d
Branches Tags
trabus322:master
trabus322:release
trabus322:microinverterTotalProduction
..
compare: trabus322:ee2c9c33525214fdd3422df27dad152b8b4a1cca
Branches Tags
trabus322:release
trabus322:master
trabus322:microinverterTotalProduction

No commits in common. "0381c3c334344b2cac6a57b250425e6edc7a5a6d" and "ee2c9c33525214fdd3422df27dad152b8b4a1cca" have entirely different histories.
0381c3c334 ... ee2c9c3352

3 changed files with 42 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

54
src/hoymiles/dtu.cpp
View file

@ -1,8 +1,8 @@
#include <chrono>
#include <iostream> #include <iostream>
#include <string> #include <string>
#include <thread>
#include <vector> #include <vector>
#include <chrono>
#include <thread>
#include "modbus.h" #include "modbus.h"
@ -12,10 +12,10 @@
#include "portParameters.h" #include "portParameters.h"
Dtu::Dtu(const char *address, int id, bool rtu, bool tcp) { Dtu::Dtu(const char *address, int id, bool rtu, bool tcp) {
if (tcp) { if(tcp) {
this->modbus = modbus_new_tcp(address, id); this->modbus = modbus_new_tcp(address, id);
} }
if (rtu) { if(rtu) {
this->modbus = modbus_new_rtu(address, 9600, 'N', 8, 1); this->modbus = modbus_new_rtu(address, 9600, 'N', 8, 1);
modbus_rtu_set_serial_mode(this->modbus, MODBUS_RTU_RS485); modbus_rtu_set_serial_mode(this->modbus, MODBUS_RTU_RS485);
} }
@ -23,9 +23,10 @@ Dtu::Dtu(const char *address, int id, bool rtu, bool tcp) {
this->connected = false; this->connected = false;
if (modbus_connect(this->modbus) == -1) { if (modbus_connect(this->modbus) == -1) {
std::cerr << "NOT CONNECTED" << std::endl; std::cerr << "NOT CONNECTED" << std::endl;
} else { }
else {
this->connected = true; this->connected = true;
if (rtu) { if(rtu) {
modbus_set_slave(this->modbus, id); modbus_set_slave(this->modbus, id);
} }
this->populateMicroinverters(); this->populateMicroinverters();
@ -43,11 +44,18 @@ void Dtu::populateMicroinverters() {
int portStartAddress = 0x4000; int portStartAddress = 0x4000;
uint16_t registers[19]; uint16_t registers[19];
while (portStartAddress <= (0x4000 + (0x0019 * 99))) {
int registerCount; int registerCount;
registerCount = modbus_read_registers(this->modbus, portStartAddress, 19, registers); registerCount = modbus_read_registers(this->modbus, portStartAddress, 19, registers);
portStartAddress += 0x0019;
if (registers[0] == 12) { if (registerCount == -1) {
return;
}
while (registerCount != -1) {
if(registers[0] != 12) {
break;
}
Port port{portStartAddress}; Port port{portStartAddress};
port.setParametersFromMicroinverterArray(registers, 0); port.setParametersFromMicroinverterArray(registers, 0);
@ -57,9 +65,11 @@ void Dtu::populateMicroinverters() {
} }
this->getMicroinverterBySerialNumber(port.getParameterByName("microinverterSerialNumber").first.get()->getValue().first.i).first->ports.push_back(port); this->getMicroinverterBySerialNumber(port.getParameterByName("microinverterSerialNumber").first.get()->getValue().first.i).first->ports.push_back(port);
}
portStartAddress += 0x0019;
std::this_thread::sleep_for(std::chrono::milliseconds(10)); std::this_thread::sleep_for(std::chrono::milliseconds(10));
registerCount = modbus_read_registers(this->modbus, portStartAddress, 19, registers);
} }
} }
@ -108,17 +118,13 @@ void Dtu::printMicroinverters(std::vector<std::string> &parametersToGet, bool al
while (microinvertersToGetIterator != microinvertersToGet.end()) { while (microinvertersToGetIterator != microinvertersToGet.end()) {
std::pair<Microinverter *, bool> microinverterPair = this->getMicroinverterBySerialNumber(*microinvertersToGetIterator); std::pair<Microinverter *, bool> microinverterPair = this->getMicroinverterBySerialNumber(*microinvertersToGetIterator);
if (microinverterPair.second) { if (microinverterPair.second) {
std::cout << " " std::cout << " " << "Microinverter: " << microinverterPair.first->serialNumber << std::endl;
<< "Microinverter: " << microinverterPair.first->serialNumber << std::endl; std::cout << " " << "Microinverter Data Age: " << microinverterPair.first->age << std::endl;
std::cout << " "
<< "Microinverter Data Age: " << microinverterPair.first->age << std::endl;
if (printTodayProduction) { if (printTodayProduction) {
std::cout << " " std::cout << " " << "TodayProduction: " << microinverterPair.first->getTodayProduction() << "Wh" << std::endl;
<< "TodayProduction: " << microinverterPair.first->getTodayProduction() << "Wh" << std::endl;
} }
if (printTotalProduction) { if (printTotalProduction) {
std::cout << " " std::cout << " " << "TotalProduction: " << microinverterPair.first->getTotalProduction() << "Wh" << std::endl;
<< "TotalProduction: " << microinverterPair.first->getTotalProduction() << "Wh" << std::endl;
} }
microinverterPair.first->printPorts(parametersToGet, allParameters, shortNames); microinverterPair.first->printPorts(parametersToGet, allParameters, shortNames);
std::cout << std::endl; std::cout << std::endl;
@ -127,7 +133,7 @@ void Dtu::printMicroinverters(std::vector<std::string> &parametersToGet, bool al
} }
} }
void Dtu::setStatusMicroinverters(uint16_t value, std::string statusName, std::vector<long long> &microinvertersToSet) { void Dtu::setStatusMicroinverters(uint16_t value, std::string statusName, std::vector<long long>& microinvertersToSet) {
if (microinvertersToSet.empty()) { if (microinvertersToSet.empty()) {
std::vector<Microinverter>::iterator microinvertersIterator = this->microinverters.begin(); std::vector<Microinverter>::iterator microinvertersIterator = this->microinverters.begin();
while (microinvertersIterator != this->microinverters.end()) { while (microinvertersIterator != this->microinverters.end()) {
@ -137,21 +143,23 @@ void Dtu::setStatusMicroinverters(uint16_t value, std::string statusName, std::v
} }
std::vector<long long>::iterator microinvertersToSetIterator = microinvertersToSet.begin(); std::vector<long long>::iterator microinvertersToSetIterator = microinvertersToSet.begin();
while (microinvertersToSetIterator != microinvertersToSet.end()) { while(microinvertersToSetIterator != microinvertersToSet.end()) {
std::pair<Microinverter *, bool> microinverterPair = this->getMicroinverterBySerialNumber(*microinvertersToSetIterator); std::pair<Microinverter *, bool> microinverterPair = this->getMicroinverterBySerialNumber(*microinvertersToSetIterator);
if (microinverterPair.second) { if(microinverterPair.second) {
microinverterPair.first->setStatusWholeMicroinverter(value, statusName); microinverterPair.first->setStatusWholeMicroinverter(value, statusName);
} }
microinvertersToSetIterator++; microinvertersToSetIterator++;
} }
} }
bool Dtu::empty() { return this->microinverters.empty(); } bool Dtu::empty() {
return this->microinverters.empty();
}
void Dtu::listOfMicroinverters() { void Dtu::listOfMicroinverters() {
std::vector<Microinverter>::iterator microinvertersIterator = this->microinverters.begin(); std::vector<Microinverter>::iterator microinvertersIterator = this->microinverters.begin();
std::cout << "Microinverter list:" << std::endl; std::cout << "Microinverter list:" << std::endl;
while (microinvertersIterator != this->microinverters.end()) { while(microinvertersIterator != this->microinverters.end()) {
std::cout << " " << microinvertersIterator->serialNumber << std::endl; std::cout << " " << microinvertersIterator->serialNumber << std::endl;
microinvertersIterator++; microinvertersIterator++;
} }

5
src/hoymiles/portParameters/portParameters.cpp
View file

@ -11,9 +11,8 @@ void PortParameterMicroinverterSerialNumber::getValueFromRegisters(uint16_t *reg
std::string readValueString = ""; std::string readValueString = "";
for (int i{0}; i < this->registerSize; i++) { for (int i{0}; i < this->registerSize; i++) {
std::stringstream readValueStringStream; std::stringstream readValueStringStream;
readValueStringStream.fill('0'); readValueStringStream << std::hex << (int) ((registers[addressOffset + this->parameterAddressOffset + i] & 0xff00) >> 8);
readValueStringStream << std::setw(2) << std::hex << (int) ((registers[addressOffset + this->parameterAddressOffset + i] & 0xff00) >> 8); readValueStringStream << std::hex << (int) (registers[addressOffset + this->parameterAddressOffset + i] & 0x00ff);
readValueStringStream << std::setw(2) << std::hex << (int) (registers[addressOffset + this->parameterAddressOffset + i] & 0x00ff);
readValueString.append(readValueStringStream.str()); readValueString.append(readValueStringStream.str());
} }
this->value.i = std::stoll(readValueString); this->value.i = std::stoll(readValueString);

2
src/main.cpp
View file

@ -19,7 +19,7 @@ int main(int argc, char **argv) {
signal(SIGTERM, sigHandler); signal(SIGTERM, sigHandler);
signal(SIGABRT, sigHandler); signal(SIGABRT, sigHandler);
std::string version{"v2.4h"}; std::string version{"v2.3h"};
std::cout << version << std::endl; std::cout << version << std::endl;
CLI::App hoymilesClient{"Client for DTU-Pro/DTU-ProS"}; CLI::App hoymilesClient{"Client for DTU-Pro/DTU-ProS"};