ETM-Schurig
/
powersync-plugins-modbus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Sungrow: Improve connection stability

master
trinnes 2024-05-12 11:35:38 +02:00
parent 6bd514f44e
commit 0a06dc565c
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
sungrow/integrationpluginsungrow.cpp
View File

@ -318,13 +318,24 @@ void IntegrationPluginSungrow::postSetupThing(Thing *thing)
qCDebug(dcSungrow()) << "Starting plugin timer..."; qCDebug(dcSungrow()) << "Starting plugin timer...";
m_refreshTimer = hardwareManager()->pluginTimerManager()->registerTimer(2); m_refreshTimer = hardwareManager()->pluginTimerManager()->registerTimer(2);
connect(m_refreshTimer, &PluginTimer::timeout, this, [this] { connect(m_refreshTimer, &PluginTimer::timeout, this, [this] {
foreach(SungrowModbusTcpConnection *connection, m_tcpConnections) { foreach(auto thing, myThings().filterByThingClassId(sungrowInverterTcpThingClassId)) {
auto monitor = m_monitors.value(thing);
if (!monitor->reachable()) {
continue;
}
auto connection = m_tcpConnections.value(thing);
if (connection->initializing()) { if (connection->initializing()) {
qCDebug(dcSungrow()) << "Skip updating" << connection->modbusTcpMaster() << "since the connection is still initializing."; qCDebug(dcSungrow()) << "Skip updating" << connection->modbusTcpMaster() << "since the connection is still initializing.";
continue; continue;
} }
qCDebug(dcSungrow()) << "Updating connection" << connection->modbusTcpMaster()->hostAddress().toString(); if (connection->reachable()) {
connection->update(); qCDebug(dcSungrow()) << "Updating connection" << connection->modbusTcpMaster()->hostAddress().toString();
connection->update();
} else {
qCDebug(dcSungrow()) << "Device not reachable. Probably a TCP connection error. Reconnecting TCP socket";
connection->reconnectDevice();
}
} }
}); });
m_refreshTimer->start(); m_refreshTimer->start();