// HomeAssistant MQTT 自动发现配置 - 无分割版本
|
// 每个传感器单独发送，避免分割节点问题
|
|
const deviceId = "central_liquid_supply";
|
const deviceName = "新安国际集中供液系统";
|
const baseTopic = "homeassistant";
|
|
// 设备基本信息
|
const device = {
|
identifiers: [deviceId],
|
name: deviceName,
|
manufacturer: "新安国际",
|
model: "集中供液系统",
|
sw_version: "1.0"
|
};
|
|
// 所有传感器配置
|
const allSensors = [
|
{ type: "sensor", name: "温度", entity_id: "temperature", unit: "°C", device_class: "temperature" },
|
{ type: "sensor", name: "PH值", entity_id: "ph_value", unit: "pH" },
|
{ type: "sensor", name: "电导率", entity_id: "conductivity", unit: "μS/cm" },
|
{ type: "sensor", name: "储液当前液位", entity_id: "storage_level", unit: "L" },
|
{ type: "sensor", name: "供液一压力", entity_id: "supply_pressure_1", unit: "kPa", device_class: "pressure" },
|
{ type: "sensor", name: "供液二压力", entity_id: "supply_pressure_2", unit: "kPa", device_class: "pressure" },
|
{ type: "binary_sensor", name: "工作状态", entity_id: "work_status", device_class: "running" },
|
{ type: "binary_sensor", name: "报警状态", entity_id: "alarm_status", device_class: "problem" }
|
];
|
|
node.warn(`开始处理 ${allSensors.length} 个传感器配置`);
|
|
// 逐个发送传感器配置
|
allSensors.forEach((sensor, index) => {
|
const config = {
|
name: sensor.name,
|
unique_id: `${deviceId}_${sensor.entity_id}`,
|
state_topic: `${deviceId}/${sensor.type}/${sensor.entity_id}/state`,
|
device: device
|
};
|
|
// 根据传感器类型添加特定配置
|
if (sensor.type === "sensor") {
|
config.state_class = "measurement";
|
if (sensor.unit) config.unit_of_measurement = sensor.unit;
|
if (sensor.device_class) config.device_class = sensor.device_class;
|
} else if (sensor.type === "binary_sensor") {
|
config.device_class = sensor.device_class;
|
config.payload_on = sensor.entity_id === "work_status" ? "运行" : "报警";
|
config.payload_off = sensor.entity_id === "work_status" ? "停止" : "正常";
|
}
|
|
const mqttTopic = `${baseTopic}/${sensor.type}/${deviceId}_${sensor.entity_id}/config`;
|
const mqttPayload = JSON.stringify(config);
|
|
node.warn(`发送配置 ${index + 1}/${allSensors.length}: ${sensor.name}`);
|
node.warn(` 主题: ${mqttTopic}`);
|
|
// 立即发送MQTT消息
|
node.send({
|
topic: mqttTopic,
|
payload: mqttPayload,
|
retain: true
|
});
|
|
// 添加小延迟，确保消息按顺序发送
|
setTimeout(() => {
|
if (index === allSensors.length - 1) {
|
// 最后发送设备状态
|
node.send({
|
topic: `${deviceId}/status`,
|
payload: "online",
|
retain: true
|
});
|
node.warn("所有自动发现配置已发送完成");
|
}
|
}, index * 100);
|
});
|
|
return null; // 不通过return发送，直接通过node.send发送
|
