MQTT Discovery Message Issues

#include <WiFi.h>
#include <WiFiClient.h>
#include <ArduinoOTA.h>
#include <PubSubClient.h>
#include <Wire.h>
#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include "config.h"

#define GEIGER_PIN 0
#define SCREEN_WIDTH 128
#define SCREEN_HEIGHT 32
#define OLED_RESET -1



WiFiClient espClient;
PubSubClient client(espClient);
Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);

volatile unsigned long counts = 0;
unsigned long lastCount = 0;
unsigned long lastWifiCheck = 0;
unsigned long lastMqttPublish = 0;

const int TUBE_FACTOR = 570; // СБМ-20 фактор * 100000 для целочисленных вычислений
const char* device_id = "ESP32GeigerCounter";

void IRAM_ATTR geigerISR() {
counts++;
}

void setup() {
Serial.begin(115200);
Serial.println("\n[SETUP] Начало инициализации...");

pinMode(GEIGER_PIN, INPUT_PULLUP);
attachInterrupt(digitalPinToInterrupt(GEIGER_PIN), geigerISR, FALLING);
Serial.println("[SETUP] Прерывание для счетчика Гейгера настроено на пин " + String(GEIGER_PIN));

if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) {
Serial.println("[ERROR] Ошибка инициализации SSD1306");
for (;;);
}
Serial.println("[SETUP] OLED дисплей инициализирован");

display.clearDisplay();
display.setTextSize(1);
display.setTextColor(SSD1306_WHITE);

setupWiFi();



ArduinoOTA.begin();
Serial.println("[SETUP] OTA настроено");

client.setServer(mqtt_server, 1883);
Serial.println("[SETUP] MQTT сервер настроен: " + String(mqtt_server));
/*
if (client.connect(device_id, mqtt_user, mqtt_password)) {
// if (client.connect(device_id)) {
Serial.println("[SETUP] Подключено к MQTT");
}
else {
Serial.println("[SETUP] Ошибка подключения, rc=" + String(client.state()));
}
*/
reconnectMQTT();

// publishDiscoveryMessage();
Serial.println("[SETUP] Инициализация завершена");
}

void loop() {
if (WiFi.status() != WL_CONNECTED) {
Serial.println("[WARN] Wi-Fi соединение потеряно, переподключение...");
setupWiFi();
}

ArduinoOTA.handle();

if (!client.connected()) {
Serial.print("[MQTT] Ошибка подключения, код ошибки: ");
Serial.println(client.state());
reconnectMQTT();
}

client.loop();

unsigned long currentMillis = millis();

if (currentMillis - lastWifiCheck > 60000) {
Serial.println("[INFO] Проверка сигнала Wi-Fi");
checkWiFiSignal(); // Добавлен вызов существующей функции
lastWifiCheck = currentMillis;
}

static unsigned long lastUpdate = 0;
if (currentMillis - lastUpdate >= 1000) {
updateRadiationLevel();
lastUpdate = currentMillis;
}
counts++;
if (currentMillis - lastMqttPublish > 60000) {
publishRadiationLevel();
lastMqttPublish = currentMillis;
}
}

void setupWiFi() {
Serial.println("[WIFI] Начало настройки Wi-Fi");
WiFi.disconnect();
WiFi.mode(WIFI_STA);
WiFi.config(static_ip, gateway, subnet, dns1, dns2);

WiFi.begin(ssid1, password1);

while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}

Serial.println("\n[WIFI] Подключено к Wi-Fi");
Serial.println("[WIFI] IP адрес: " + WiFi.localIP().toString());
}

// Объявление функции checkWiFiSignal
void checkWiFiSignal() {
int currentStrength = WiFi.RSSI();
String currentSSID = WiFi.SSID();
int otherStrength = -100;

int n = WiFi.scanNetworks();
if (n > 0) {
for (int i = 0; i < n; ++i) {
if (WiFi.SSID(i) == (currentSSID == ssid1 ? ssid2 : ssid1)) {
otherStrength = WiFi.RSSI(i);
break;
}
}
}

Serial.println("[WIFI] Текущая сеть: " + currentSSID + ", сила сигнала: " + String(currentStrength) + " dBm");
Serial.println("[WIFI] Другая сеть: " + String(currentSSID == ssid1 ? ssid2 : ssid1) + ", сила сигнала: " + String(otherStrength) + " dBm");

if (otherStrength > currentStrength + 5) {
Serial.println("[WIFI] Обнаружена сеть с более сильным сигналом, переключение...");
setupWiFi();
}
}

void updateRadiationLevel() {
noInterrupts();

unsigned long currentCounts = counts;
counts = 0;
interrupts();

unsigned long cpm = (currentCounts - lastCount) * 6;
lastCount = currentCounts;

unsigned long microroentgens = (cpm * TUBE_FACTOR) / 100;

display.clearDisplay();
display.setCursor(0, 0);
display.print("Radiation: ");
display.print(microroentgens);
display.println(" uR/h");
display.print("CPM: ");
display.println(cpm);
display.display();

Serial.println("[RAD] Уровень радиации: " + String(microroentgens) + " uR/h");
Serial.println("[RAD] CPM: " + String(cpm));
}

void publishRadiationLevel() {
unsigned long cpm = counts * 6;
unsigned long microroentgens = (cpm * TUBE_FACTOR) / 100;

// Преобразуем уровень радиации в строку
char msg[16];
snprintf(msg, 16, "%lu", microroentgens);

// Публикуем только числовое значение радиации
if (client.publish("homeassistant/sensor/esp32_radiation/state", msg, true)) {
Serial.println("[MQTT] Опубликовано: " + String(microroentgens) + " uR/h");
} else {
Serial.println("[ERROR] Ошибка публикации в MQTT");
}

counts = 0;
}

/*
void publishRadiationLevel() {
unsigned long cpm = counts * 6;
unsigned long microroentgens = (cpm * TUBE_FACTOR) / 100;

char msg[128];
snprintf(msg, 128, "{\"radiation_level\": %lu, \"CPM\": %lu}", microroentgens, cpm);

if (client.publish("homeassistant/sensor/esp32_radiation/state", msg, true)) {
Serial.println("[MQTT] Опубликовано: " + String(microroentgens) + " uR/h");
} else {
Serial.println("[ERROR] Ошибка публикации в MQTT");
}

counts = 0;
}
*/
void reconnectMQTT() {
Serial.println("[MQTT] Попытка подключения к MQTT...");
while (!client.connected()) {
if (client.connect(device_id, mqtt_user, mqtt_password)) {
// if (client.connect(device_id)) {
Serial.println("[MQTT] Подключено к MQTT");
publishDiscoveryMessage();
} else {
Serial.println("[MQTT] Ошибка подключения, rc=" + String(client.state()) + ". Повторная попытка через 5 секунд.");
delay(5000);
}
}
}


void publishDiscoveryMessage() {
const char* discovery_topic = "homeassistant/sensor/esp32_radiation/config";

// const char* discovery_payload = "{\"device_class\": \"radiation\", \"name\": \"ESP32 Radiation Level\", \"state_topic\": \"homeassistant/sensor/esp32_radiation/state\", \"unit_of_measurement\": \"uR/h\", \"value_template\": \"{{ value }}\", \"device\": {\"identifiers\": [\"esp32_radiation\"], \"name\": \"ESP32 Radiation Detector\", \"model\": \"ESP32 Geiger Counter\", \"manufacturer\": \"DIY\"}}";

const char* discovery_payload = "{ \"name\": \"ESP32 Radiation Level\", \"state_topic\": \"homeassistant/sensor/esp32_radiation/state\", \"value_template\": \"{{ value }}\", \"device\": {\"identifiers\": [\"esp32_radiation\"], \"name\": \"ESP32 Radiation Detector\", \"model\": \"ESP32 Geiger Counter\", \"manufacturer\": \"DIY\"}}";
//, \"unique_id\": \"My_esp32_radiation_sensor\"
// const char* discovery_payload = "{\"device_class\": \"radiation\", \"name\": \"ESP32 Radiation Level\", \"state_topic\": \"homeassistant/sensor/esp32_radiation/state\", \"unit_of_measurement\": \"uR/h\", \"value_template\": \"{{ value_json.radiation_level }}\" }";
// Проверяем, подключен ли клиент
if (!client.connected()) {
Serial.println("[ERROR] Клиент не подключен, перед публикацией необходимо подключение.");
reconnectMQTT(); // Пробуем подключиться
}

if (client.publish(discovery_topic, discovery_payload, true)) {
Serial.println("[MQTT] Опубликовано сообщение обнаружения");
} else {
Serial.println("[ERROR] Ошибка публикации сообщения обнаружения");
}
}
найди ошибке в publishDiscoveryMessage, mqtt сервер homeassistant не принимает discovery_payload с value_json.radiation_level
работает только с value и без device