|
const registers = msg.payload;
|
// node.warn(`解析${registers}`);
|
|
// 检查是否为状态数据（布尔类型或布尔数组）
|
if (typeof registers === 'boolean' ||
|
(Array.isArray(registers) && registers.length === 1 && typeof registers[0] === 'boolean') ||
|
(Array.isArray(registers) && registers.length === 1 && typeof registers[0] === 'number' && (registers[0] === 0 || registers[0] === 1)) ||
|
(Array.isArray(registers) && registers.length > 1 && typeof registers[0] === 'boolean')) {
|
|
// 处理布尔状态数据
|
let boolValue;
|
if (typeof registers === 'boolean') {
|
boolValue = registers;
|
} else if (Array.isArray(registers) && registers.length === 1) {
|
boolValue = typeof registers[0] === 'boolean' ? registers[0] : (registers[0] === 1);
|
} else if (Array.isArray(registers) && registers.length > 1 && typeof registers[0] === 'boolean') {
|
// 对于多个布尔值的数组，取第一个值作为主要状态
|
boolValue = registers[0];
|
// node.warn(`布尔数组长度: ${registers.length}, 取第一个值: ${boolValue}`);
|
}
|
|
// 根据 topic 确定状态类型
|
let dataType = "未知状态";
|
let statusValue = boolValue;
|
|
if (msg.topic) {
|
if (msg.topic.includes("工作状态") || msg.topic.includes("work") || msg.topic.includes("Q1.6")) {
|
dataType = "工作状态";
|
statusValue = boolValue ? "运行" : "停止";
|
msg.workStatus = statusValue;
|
} else if (msg.topic.includes("报警状态") || msg.topic.includes("alarm") || msg.topic.includes("Q1.5")) {
|
dataType = "报警状态";
|
statusValue = boolValue ? "报警" : "正常";
|
msg.alarmStatus = statusValue;
|
} else if (msg.topic.includes("状态") || msg.topic.includes("status")) {
|
dataType = "设备状态";
|
statusValue = boolValue ? "激活" : "关闭";
|
msg.status = statusValue;
|
}
|
} else {
|
// 如果没有 topic，使用通用状态字段
|
msg.status = boolValue;
|
dataType = "状态";
|
}
|
|
// 打印解析结果到调试控制台
|
// node.warn(`解析${dataType} ---> ${statusValue}`);
|
|
// 保留原始的 payload，添加解析后的值
|
msg.originalPayload = msg.payload;
|
msg.payload = statusValue;
|
|
return msg;
|
}
|
|
// 检查寄存器长度（浮点数解析）
|
if (!Array.isArray(registers) || registers.length !== 2) {
|
node.warn("寄存器数量不足，无法解析浮点数！");
|
return null;
|
}
|
|
// 处理 Modbus 寄存器数据
|
// 寄存器数据按 Big Endian 字序存储，但浮点数需要按 Little Endian 读取
|
const highRegister = registers[0]; // 高16位寄存器
|
const lowRegister = registers[1]; // 低16位寄存器
|
|
// 创建一个 4 字节缓冲区
|
const buffer = Buffer.alloc(4);
|
|
// 按照 Big Endian 方式写入寄存器数据
|
buffer.writeUInt16BE(highRegister, 0); // 写入高16位到前两个字节
|
buffer.writeUInt16BE(lowRegister, 2); // 写入低16位到后两个字节
|
|
// 按照 Little Endian 方式读取 IEEE 754 浮点数
|
const rawValue = buffer.readFloatLE(0);
|
|
// 保留两位小数
|
const value = Math.round(rawValue * 100) / 100;
|
|
// 根据输入消息的 topic 或其他标识来确定数据类型
|
let dataType = "未知数据";
|
if (msg.topic) {
|
if (msg.topic.includes("温度") || msg.topic.includes("temperature")) {
|
dataType = "温度";
|
msg.temperature = value;
|
} else if (msg.topic.includes("PH") || msg.topic.includes("ph")) {
|
dataType = "PH值";
|
msg.ph = value;
|
} else if (msg.topic.includes("液位") || msg.topic.includes("level")) {
|
dataType = "液位";
|
msg.level = value;
|
} else if (msg.topic.includes("电导率") || msg.topic.includes("conductivity")) {
|
dataType = "电导率";
|
msg.conductivity = value;
|
} else if (msg.topic.includes("压力") || msg.topic.includes("pressure")) {
|
dataType = "压力";
|
msg.pressure = value;
|
}
|
} else {
|
// 如果没有 topic，使用通用字段名
|
msg.value = value;
|
dataType = "数值";
|
}
|
|
// 打印解析结果到调试控制台
|
// node.warn(`解析${dataType} ---> ${value}`);
|
|
// 保留原始的 payload，添加解析后的值
|
msg.originalPayload = msg.payload;
|
msg.payload = value;
|
|
// 返回 msg 对象，供后续节点使用
|
return msg;
|
