Home-IoT/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2024-11-26 17:05:21 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

pylontech: Fix parsing error with US2000 (#6061)

Browse source
This commit is contained in:
functionpointer 2024-01-09 00:26:13 +01:00 committed by Jesse Hills
parent da56d333dc
commit 33051906bd
No known key found for this signature in database
GPG key ID: BEAAE804EFD8E83A
2 changed files with 36 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
esphome/components/pylontech/__init__.py
View file

@ -19,7 +19,7 @@ PylontechComponent = pylontech_ns.class_(
) )
PylontechBattery = pylontech_ns.class_("PylontechBattery") PylontechBattery = pylontech_ns.class_("PylontechBattery")
CV_NUM_BATTERIES = cv.int_range(1, 6) CV_NUM_BATTERIES = cv.int_range(1, 16)
PYLONTECH_COMPONENT_SCHEMA = cv.Schema( PYLONTECH_COMPONENT_SCHEMA = cv.Schema(
{ {

23
esphome/components/pylontech/pylontech.cpp
View file

@ -1,5 +1,6 @@
#include "pylontech.h" #include "pylontech.h"
#include "esphome/core/log.h" #include "esphome/core/log.h"
#include "esphome/core/helpers.h"
namespace esphome { namespace esphome {
namespace pylontech { namespace pylontech {
@ -34,13 +35,15 @@ void PylontechComponent::setup() {
void PylontechComponent::update() { this->write_str("pwr\n"); } void PylontechComponent::update() { this->write_str("pwr\n"); }
void PylontechComponent::loop() { void PylontechComponent::loop() {
uint8_t data; if (this->available() > 0) {
// pylontech sends a lot of data very suddenly // pylontech sends a lot of data very suddenly
// we need to quickly put it all into our own buffer, otherwise the uart's buffer will overflow // we need to quickly put it all into our own buffer, otherwise the uart's buffer will overflow
uint8_t data;
int recv = 0;
while (this->available() > 0) { while (this->available() > 0) {
if (this->read_byte(&data)) { if (this->read_byte(&data)) {
buffer_[buffer_index_write_] += (char) data; buffer_[buffer_index_write_] += (char) data;
recv++;
if (buffer_[buffer_index_write_].back() == static_cast<char>(ASCII_LF) || if (buffer_[buffer_index_write_].back() == static_cast<char>(ASCII_LF) ||
buffer_[buffer_index_write_].length() >= MAX_DATA_LENGTH_BYTES) { buffer_[buffer_index_write_].length() >= MAX_DATA_LENGTH_BYTES) {
// complete line received // complete line received
@ -48,13 +51,15 @@ void PylontechComponent::loop() {
} }
} }
} }
ESP_LOGV(TAG, "received %d bytes", recv);
} else {
// only process one line per call of loop() to not block esphome for too long // only process one line per call of loop() to not block esphome for too long
if (buffer_index_read_ != buffer_index_write_) { if (buffer_index_read_ != buffer_index_write_) {
this->process_line_(buffer_[buffer_index_read_]); this->process_line_(buffer_[buffer_index_read_]);
buffer_[buffer_index_read_].clear(); buffer_[buffer_index_read_].clear();
buffer_index_read_ = (buffer_index_read_ + 1) % NUM_BUFFERS; buffer_index_read_ = (buffer_index_read_ + 1) % NUM_BUFFERS;
} }
}
} }
void PylontechComponent::process_line_(std::string &buffer) { void PylontechComponent::process_line_(std::string &buffer) {
@ -66,10 +71,11 @@ void PylontechComponent::process_line_(std::string &buffer) {
// clang-format on // clang-format on
PylontechListener::LineContents l{}; PylontechListener::LineContents l{};
char mostempr_s[6];
const int parsed = sscanf( // NOLINT const int parsed = sscanf( // NOLINT
buffer.c_str(), "%d %d %d %d %d %d %d %d %7s %7s %7s %7s %d%% %*d-%*d-%*d %*d:%*d:%*d %*s %*s %d %*s", // NOLINT buffer.c_str(), "%d %d %d %d %d %d %d %d %7s %7s %7s %7s %d%% %*d-%*d-%*d %*d:%*d:%*d %*s %*s %5s %*s", // NOLINT
&l.bat_num, &l.volt, &l.curr, &l.tempr, &l.tlow, &l.thigh, &l.vlow, &l.vhigh, l.base_st, l.volt_st, // NOLINT &l.bat_num, &l.volt, &l.curr, &l.tempr, &l.tlow, &l.thigh, &l.vlow, &l.vhigh, l.base_st, l.volt_st, // NOLINT
l.curr_st, l.temp_st, &l.coulomb, &l.mostempr); // NOLINT l.curr_st, l.temp_st, &l.coulomb, mostempr_s); // NOLINT
if (l.bat_num <= 0) { if (l.bat_num <= 0) {
ESP_LOGD(TAG, "invalid bat_num in line %s", buffer.substr(0, buffer.size() - 2).c_str()); ESP_LOGD(TAG, "invalid bat_num in line %s", buffer.substr(0, buffer.size() - 2).c_str());
@ -79,6 +85,13 @@ void PylontechComponent::process_line_(std::string &buffer) {
ESP_LOGW(TAG, "invalid line: found only %d items in %s", parsed, buffer.substr(0, buffer.size() - 2).c_str()); ESP_LOGW(TAG, "invalid line: found only %d items in %s", parsed, buffer.substr(0, buffer.size() - 2).c_str());
return; return;
} }
auto mostempr_parsed = parse_number<int>(mostempr_s);
if (mostempr_parsed.has_value()) {
l.mostempr = mostempr_parsed.value();
} else {
l.mostempr = -300;
ESP_LOGW(TAG, "bat_num %d: received no mostempr", l.bat_num);
}
for (PylontechListener *listener : this->listeners_) { for (PylontechListener *listener : this->listeners_) {
listener->on_line_read(&l); listener->on_line_read(&l);