Create code.js

code.js

@@ -0,0 +1,118 @@
+// 定义要轮询的实体列表
+const entities = [
+    "sensor.0x158d00044fdb62_temperature",   // 实体时长不更新，且实体状态unavailable
+    "sensor.tasmota_ds18b20_2_temperature",  // 正常实体
+    "sensor.zywdongpdx_temperature",   // 正常实体
+    "sensor.0x158d00044fdb62_te" // 不存在的实体
+];
+
+// 获取当前时间
+var newtime = flow.get("newtime");
+if (!newtime) {
+    node.error("当前时间未设置");
+    return null; // 返回null以中断流程
+}
+
+// 轮询每个实体
+for (const entity_id of entities) {
+    var sensorState = global.get('homeassistant').ha.states[entity_id];
+    var currentTime = new Date(newtime).getTime(); // 获取当前时间的时间戳
+    var lastNotifyTime = flow.get(entity_id); // 获取上次通知时间
+    lastNotifyTime = lastNotifyTime ? new Date(lastNotifyTime).getTime() : 0; // 转换为时间戳
+
+    // 检查实体状态是否存在
+    if (!sensorState) {
+        if (currentTime - lastNotifyTime >= (12 * 60 * 60 * 1000)) { // 12小时
+            notifyEntityNotFound(entity_id);
+            node.warn("实体ID: " + entity_id + " 未找到。");
+            flow.set(entity_id, newtime); // 记录通知时间
+        }
+        continue; // 继续下一个实体
+    }
+
+    // 获取实体的状态和更新时间
+    var state = sensorState.state;
+    var oldtime = sensorState.last_updated; // 使用last_updated
+    var friendly_name = sensorState.attributes.friendly_name;
+
+    if (!oldtime || !state || !friendly_name) {
+        node.error("缺少必要的数据字段: " + JSON.stringify(sensorState));
+        continue; // 继续下一个实体
+    }
+
+    // 将last_updated转换为本地时间
+    var oldtimeLocal = new Date(oldtime).getTime() + (8 * 60 * 60 * 1000); // 转换为UTC+8时间
+
+    var timeDiffInSeconds = calculateTimeDifference(new Date(newtime), new Date(oldtimeLocal));
+    var { minutesDiff, hoursDiff, daysDiff, yearsDiff } = calculateTimeUnits(timeDiffInSeconds);
+
+    // 调试输出，查看状态和更新时间
+    node.warn(`实体ID: ${entity_id}, 状态: ${state}, 最后更新时间: ${oldtime}, 当前时间: ${newtime}, 时间差: ${yearsDiff}年 ${daysDiff}天 ${hoursDiff}小时 ${minutesDiff}分钟`);
+
+    // 如果状态为 unavailable 或 unknown，或者时间差大于 30 分钟，进行通知
+    if ((state === "unavailable" || state === "unknown" || minutesDiff > 30) && 
+        (currentTime - lastNotifyTime >= (12 * 60 * 60 * 1000))) { // 12小时
+        notifySensorIssue(entity_id, friendly_name, oldtime, state, yearsDiff, daysDiff, hoursDiff, minutesDiff);
+        flow.set(entity_id, newtime); // 更新通知时间
+    }
+}
+
+// 通知实体未找到
+function notifyEntityNotFound(entity_id) {
+    node.warn("通知未找到实体: " + entity_id);
+
+    var msg = {}; // 创建新消息对象
+    msg.payload = {
+        "touser": "jjcsjjtz",
+        "msgtype": "news",
+        "agentid": "1000002",
+        "news": {
+            "articles": [
+                {
+                    "title": "系统警告：未找到实体",
+                    "description": "未能找到实体ID: " + entity_id + "，请检查配置。",
+                }
+            ]
+        }
+    };
+    node.send(msg); // 发送消息
+}
+
+// 通知传感器问题
+function notifySensorIssue(entity_id, friendly_name, oldtime, state, yearsDiff, daysDiff, hoursDiff, minutesDiff) {
+    var msg = {}; // 创建新消息对象
+    msg.payload = {
+        "touser": "jjcsjjtz",
+        "msgtype": "news",
+        "agentid": "1000002",
+        "news": {
+            "articles": [
+                {
+                    "title": "系统工单：当前传感器存在长时间未更新情况，请及时处理",
+                    "description": "离线传感器ID:" + entity_id + "\n" +
+                                   "离线传感器名称：" + friendly_name + "\n" +
+                                   "离线时长：" + yearsDiff + "年 " + daysDiff + "天 " + hoursDiff + "小时 " + minutesDiff + "分钟\n" +
+                                   "\n" + "最后更新时间：" + oldtime + "\n" +
+                                   "传感器最后更新值：" + state + "\n" +
+                                   "当前系统时间：" + newtime,
+                }
+            ]
+        }
+    };
+    node.send(msg); // 发送消息
+}
+
+// 计算时间差
+function calculateTimeDifference(startTime, endTime) {
+    return Math.abs((endTime - startTime) / 1000); // 返回秒
+}
+
+// 计算时间单位
+function calculateTimeUnits(timeInSeconds) {
+    var secondsDiff = Math.floor(timeInSeconds);
+    var minutesDiff = Math.floor(secondsDiff / 60);
+    var hoursDiff = Math.floor(minutesDiff / 60);
+    var daysDiff = Math.floor(hoursDiff / 24);
+    var yearsDiff = Math.floor(daysDiff / 365);
+    return { minutesDiff, hoursDiff, daysDiff, yearsDiff }; // 返回所有时间单位
+}