monster/esphome-saeco-series-6000
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
kislovdm
2025-07-21 19:54:32 +03:00
commit 7c7cd6a198
6 changed files with 464 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
components/saeco_series_6000/__init__.py
+48
View File
@@ -0,0 +1,48 @@
DEPENDENCIES = ["uart", "sensor"]
import esphome.codegen as cg
import esphome.config_validation as cv
from esphome.components import uart, sensor
from esphome.const import CONF_ID, CONF_DEBUG
CONF_STATE_SENSOR = "state_sensor"
CONF_B0_STATUS_SENSOR = "b0_status_sensor"
CONF_B5_STATUS_SENSOR = "b5_status_sensor"
CONF_BA_STATUS_SENSOR = "ba_status_sensor"
CONF_S90_STATUS_SENSOR = "s90_status_sensor"
CONF_S91_STATUS_SENSOR = "s91_status_sensor"
CONF_S93_STATUS_SENSOR = "s93_status_sensor"
CONF_WATER_SENSOR = "water_sensor"
CONF_COFFEE_GROUNDS_CONTAINER_SENSOR = "coffee_grounds_container_sensor"
CONF_PALLET_SENSOR = "pallet_sensor"
CONF_ERROR_CODE_SENSOR = "error_code_sensor"
CONF_GRAIN_TRAY_SENSOR = "grain_tray_sensor"
CONF_STATUS_TEXT_SENSOR = "status_text_sensor"
saeco_series_6000_ns = cg.esphome_ns.namespace('saeco_series_6000')
SaecoSeries6000 = saeco_series_6000_ns.class_('SaecoSeries6000', cg.Component)
CONFIG_SCHEMA = cv.Schema({
cv.GenerateID(): cv.declare_id(SaecoSeries6000),
cv.Required('uart_display'): cv.use_id(uart.UARTComponent),
cv.Required('uart_mainboard'): cv.use_id(uart.UARTComponent),
cv.Optional(CONF_DEBUG, default=False): cv.boolean,
cv.Optional(CONF_STATE_SENSOR): sensor.sensor_schema(),
}).extend(cv.COMPONENT_SCHEMA)
def to_code(config):
var = cg.new_Pvariable(config[CONF_ID])
yield cg.register_component(var, config)
uart_display = yield cg.get_variable(config['uart_display'])
cg.add(var.set_uart_display(uart_display))
uart_mainboard = yield cg.get_variable(config['uart_mainboard'])
cg.add(var.set_uart_mainboard(uart_mainboard))
if config[CONF_DEBUG]:
cg.add(var.set_debug(True))
if CONF_STATE_SENSOR in config:
sens = yield sensor.new_sensor(config[CONF_STATE_SENSOR])
cg.add(var.set_status_sensor(sens))
components/saeco_series_6000/__pycache__/__init__.cpython-311.pyc
BIN
View File
Binary file not shown.
components/saeco_series_6000/saeco_series_6000.cpp
+185
View File
@@ -0,0 +1,185 @@
#include "saeco_series_6000.h"
#include "esphome/core/log.h"
#include <vector>
namespace esphome {
namespace saeco_series_6000 {
static const char *TAG = "saeco_series_6000";
static uint32_t last_activity_time = 0;
void SaecoSeries6000::loop() {
uint8_t byte;
// Bridge from uart_display (display) to uart_mainboard (mainboard)
while (uart_display_->available()) {
uart_display_->read_byte(&byte);
uart_mainboard_->write_byte(byte); // Mirror byte immediately
process_display_byte(byte); // Process the "sniffed" byte
}
// Bridge from uart_mainboard (mainboard) to uart_display (display)
while (uart_mainboard_->available()) {
uart_mainboard_->read_byte(&byte);
uart_display_->write_byte(byte); // Mirror byte immediately
process_mainboard_byte(byte); // Process the "sniffed" byte
}
// Контроль активности UART (выключение через 15 сек)
static uint32_t last_check = 0;
uint32_t now = millis();
if (now - last_check > 1000) { // проверяем каждую секунду
last_check = now;
if (now - last_activity_time > 15000) {
pub_status(2); // публикуем статус "выключено"
last_activity_time = now; // чтобы не публиковать повторно
}
}
}
void SaecoSeries6000::process_display_byte(uint8_t byte) {
// Если получили первый 0xAA — начинаем новый пакет
if (byte == 0xAA && display_buffer_pos_ == 0) {
display_buffer_[display_buffer_pos_++] = byte;
return;
}
// Если уже начали собирать пакет
if (display_buffer_pos_ > 0 && display_buffer_pos_ < DISPLAY_BUFFER_SIZE) {
display_buffer_[display_buffer_pos_++] = byte;
if (byte == 0x55) {
parse_display_packet(display_buffer_, display_buffer_pos_);
display_buffer_pos_ = 0;
}
}
}
void SaecoSeries6000::process_mainboard_byte(uint8_t byte) {
// Если получили первый 0xAA — начинаем новый пакет
if (byte == 0xAA && mainboard_buffer_pos_ == 0) {
mainboard_buffer_[mainboard_buffer_pos_++] = byte;
return;
}
// Если уже начали собирать пакет
if (mainboard_buffer_pos_ > 0 && mainboard_buffer_pos_ < MAINBOARD_BUFFER_SIZE) {
mainboard_buffer_[mainboard_buffer_pos_++] = byte;
if (byte == 0x55) {
parse_mainboard_packet(mainboard_buffer_, mainboard_buffer_pos_);
mainboard_buffer_pos_ = 0;
}
}
}
void SaecoSeries6000::parse_display_packet(const uint8_t* buffer, uint16_t size) {
if (debug_) {
ESP_LOGD(TAG, "parse_display_packet: size=%u", size);
}
// Здесь больше не парсим B0-пакеты, только debug
}
void SaecoSeries6000::parse_mainboard_packet(const uint8_t* buffer, uint16_t size) {
last_activity_time = millis(); // сбрасываем таймер активности при любом пакете
if (debug_) {
std::vector<char> hex_buffer;
hex_buffer.resize(size * 3 + 1);
for (uint16_t i = 0; i < size; i++) {
sprintf(hex_buffer.data() + i * 3, "%02X ", buffer[i]);
}
ESP_LOGD(TAG, "Packet from Mainboard: %s", hex_buffer.data());
ESP_LOGD(TAG, "parse_mainboard_packet: size=%u", size);
}
// Парсим B0
if (size > 4 && buffer[3] == 0xB0) {
// Логика из philips_series_5400.cpp
if (size < 12) return;
if (buffer[6] == 0x0E) {
if (buffer[9] == 0x00) {
pub_status(20); // "Опорож. контейнер для коф. гущи"
} else {
if ((buffer[9] & 0x40) != 0) {
pub_status(22); // "Воды нет"
} else {
pub_status(17); // "Вода есть"
}
if ((buffer[9] & 0x80) != 0) {
pub_status(23); // "Извлечен"
} else {
pub_status(18); // "Вставлен"
}
}
} else if (buffer[6] == 0x06) {
pub_status(21); // "Вода есть","Вставлен","Зерна есть","Выберите напиток","Пустой"
} else if (buffer[6] == 0x0C) {
if (buffer[7] == 0x01) {
pub_status(8); // "Наслаждайтесь"
} else if (buffer[7] == 0x02) {
pub_status(15); // "Что-то (07 0C 02)"
}
} else if (buffer[6] == 0x07) {
if (buffer[7] == 0x0E) {
pub_status(9); // "Нагрев воды"
} else if (buffer[7] == 0x0D) {
pub_status(10); // "Перемалываем зерна"
} else if (buffer[7] == 0x10) {
pub_status(3); // "Наливаем молоко"
} else if (buffer[7] == 0x11) {
pub_status(4); // "Наливаем кофе"
} else if (buffer[7] == 0x12) {
pub_status(5); // "Предварительное дозирование"
} else if (buffer[7] == 0x13) {
pub_status(6); // "Создание пара для молока"
} else if (buffer[7] == 0x14) {
pub_status(7); // "Заварочный узел в положение заваривания"
} else if (buffer[7] == 0x15) {
pub_status(15); // "Наслаждайтесь"
}
} else if (buffer[6] == 0x08) {
if (buffer[7] == 0x0E) {
pub_status(14); // "Нагревание"
} else if (buffer[7] == 0x02) {
pub_status(11); // "Промывка"
} else if (buffer[7] == 0x14) {
pub_status(13); // "Что-то (07 08 14)"
} else if (buffer[7] == 0x05) {
pub_status(12); // "Зерна закончились"
} else if (buffer[7] == 0x16) {
pub_status(24); // "Удаление накипи стадия 1"
} else if (buffer[7] == 0x18) {
pub_status(25); // "Удаление накипи стадия 2"
}
} else if (buffer[7] == 0x00) {
if (buffer[6] == 0x01) {
pub_status(1); // "Что-то (07 01 00)"
} else if (buffer[6] == 0x05) {
pub_status(2); // "Выключено"
}
}
} else if (size > 12 && buffer[3] == 0xB5) {
// Парсим B5 (Error Code)
if (buffer[10] == 0x00) {
if (buffer[11] == 0x00) pub_status(30);
else if (buffer[11] == 0x0B) pub_status(31);
else if (buffer[11] == 0xE6) pub_status(32);
else if (buffer[11] == 0x80) pub_status(33);
else if (buffer[11] == 0xCB) pub_status(34);
else if (buffer[11] == 0xFF) pub_status(35);
else if (buffer[11] == 0xA0) pub_status(36);
} else if (buffer[10] == 0x01) {
pub_status(37); // "Статус2 0x01"
}
}
}
void SaecoSeries6000::pub_status(uint8_t status) {
if (status_sensor_ != nullptr) {
status_sensor_->publish_state(status);
}
}
void SaecoSeries6000::dump_config() {
ESP_LOGCONFIG(TAG, "Saeco Series 6000 UART Bridge");
ESP_LOGCONFIG(TAG, " UART Display (uart_display): %p", uart_display_);
ESP_LOGCONFIG(TAG, " UART Mainboard (uart_mainboard): %p", uart_mainboard_);
ESP_LOGCONFIG(TAG, " Debug mode: %s", ONOFF(this->debug_));
}
} // namespace saeco_series_6000
} // namespace esphome
components/saeco_series_6000/saeco_series_6000.h
+51
View File
@@ -0,0 +1,51 @@
#pragma once
#include "esphome/core/component.h"
#include "esphome/components/uart/uart.h"
#include "esphome/components/sensor/sensor.h"
namespace esphome {
namespace saeco_series_6000 {
// Buffer sizes for packet sniffing
constexpr size_t DISPLAY_BUFFER_SIZE = 128;
constexpr size_t MAINBOARD_BUFFER_SIZE = 128;
class SaecoSeries6000 : public Component {
public:
void set_uart_display(uart::UARTComponent *uart_display) { uart_display_ = uart_display; }
void set_uart_mainboard(uart::UARTComponent *uart_mainboard) { uart_mainboard_ = uart_mainboard; }
void set_debug(bool debug) { debug_ = debug; }
void set_status_sensor(sensor::Sensor *sensor) { status_sensor_ = sensor; }
void loop() override;
void dump_config() override;
protected:
uart::UARTComponent *uart_display_;
uart::UARTComponent *uart_mainboard_;
bool debug_{false};
sensor::Sensor *status_sensor_{nullptr};
private:
uint8_t display_buffer_[DISPLAY_BUFFER_SIZE];
uint16_t display_buffer_pos_{0};
uint8_t mainboard_buffer_[MAINBOARD_BUFFER_SIZE];
uint16_t mainboard_buffer_pos_{0};
uint8_t display_last_bytes_[3] = {0, 0, 0};
uint8_t mainboard_last_bytes_[3] = {0, 0, 0};
uint8_t display_sync_count_{0};
uint8_t mainboard_sync_count_{0};
void process_display_byte(uint8_t byte);
void process_mainboard_byte(uint8_t byte);
void parse_display_packet(const uint8_t* buffer, uint16_t size);
void parse_mainboard_packet(const uint8_t* buffer, uint16_t size);
void pub_status(uint8_t status);
};
} // namespace saeco_series_6000
} // namespace esphome