// 生成唯一的消息ID
|
const messageId = "temp_" + Date.now() + "_" + Math.floor(Math.random() * 1000);
|
const timestamp = Date.now();
|
//nameSpace：命名空间，需要改改为正确的命名空间代码
|
const nameSpace ="Environment"
|
//此处需要改为正确的客户代码
|
const clientCode = "Data-It_XzOffice";
|
//此片 从topic中提取传感器实体ID 无需更改
|
const topicParts = msg.topic.split('/');
|
const deviceId = topicParts.length >= 3 ? topicParts[2] : msg.topic;
|
const deviceType = "sensor";
|
|
// 解析温度值
|
let temperature = parseFloat(msg.payload);
|
if (isNaN(temperature)) {
|
node.warn("接收到无效的温度值: " + msg.payload);
|
return null;
|
}
|
|
// 按照胜透物联网通信协议格式化数据
|
const protocolMessage = {
|
"messageId": messageId,
|
"timestamp": timestamp,
|
"clientCode": clientCode,
|
"deviceId": deviceId,
|
"deviceType": deviceType,
|
"version": "1.0",
|
"data": {
|
"properties": {
|
"temperature": {
|
"value": temperature,
|
"unit": "°C",
|
"quality": "good",
|
"timestamp": timestamp
|
}
|
}
|
}
|
};
|
|
// 设置输出消息
|
msg.payload = JSON.stringify(protocolMessage);
|
msg.topic = `${nameSpace}/sensor/${deviceId}/properties`;
|
msg.qos = 0;
|
|
node.log("温度数据已处理: " + temperature + "°C");
|
|
return msg;
|
