电梯维保状态监控与分类告警流程

原文要点

这是付费模板，原工作流需购买，本站不复刻文件。作者描述：每30分钟轮询电梯监控API，读取n8n Data Table旧快照，按elevatorId对比openCallbackIds与证书到期，只对新回召工单和刚进入14天窗口的证书告警；OpenAI Chat Model标注gpt-5-mini，用Information Extractor从技师备注抽faultType、困人风险与预计停机；困人风险用Telegram呼叫值班技师，证书临期用Gmail通知物业经理；最后upsert快照。外部动作节点称3次重试、间隔2秒。

这次做成什么

用隔离凭据复刻“轮询—对比—只在变化时告警—回写快照”的电梯维保练习：能喂入合成API JSON，验证新回召触发AI抽取与Telegram急讯，证书进入14天窗口触发Gmail，例行无变化不调用AI。原模板需购买；以下是本站设计，不是原工作流文件。

准备什么

• 已购买或能查看原模板者用于核对界面；无原模板也可做本站简化练习
• n8n可用Schedule Trigger、HTTP Request、Code、Data Table、OpenAI、Telegram、Gmail节点
• 电梯监控厂商API的测试端点与令牌；没有时用本地mock HTTP返回合成JSON
• OpenAI测试密钥，Telegram机器人与值班测试chat，Gmail OAuth2测试账号
• n8n Data Table权限，表名为隔离的elevator_watchdog_state

具体怎么做

1. 建状态表并播种

   创建Data Table：elevatorId、buildingName、lastKnownCallbackIdsJson、certExpiryIso、certFlagged、lastCheckedAt。每台电梯一行，lastKnownCallbackIdsJson存JSON数组字符串，certFlagged存true/false，先导入两台合成电梯。

2. 每30分钟拉取当前状态

   Schedule Trigger设*/30分钟；HTTP Request节点配置厂商测试端点与认证头；没有API时改用HTTP Mock/Function返回下方合成payload。随后Code节点把响应规范成数组：elevatorId、buildingName、openCallbackIds、certExpiryIso、technicianNote。

3. 做快照diff

   Code节点读取Data Table旧行，按elevatorId配对：newCallbacks=当前openCallbackIds中不在lastKnownCallbackIdsJson的项；certNowFlag=证书到期与今天差值小于等于14天且certFlagged=false；其余标记no_change。输出三类数组到后续分支，漏轮时依赖下次diff，不追补告警。

4. 新回召才抽取并呼叫

   仅newCallbacks非空进入OpenAI/Information Extractor，粘贴抽取提示词，输入单个callbackId与technicianNote；解析entrapmentRisk=true时Telegram发给值班测试chat，正文含elevatorId、buildingName、faultType、estimatedDownHours；false可只写日志不呼叫，避免惊扰。

5. 证书临期通知并回写

   certNowFlag=true分支用Gmail发给物业经理测试邮箱，主题含buildingName与certExpiryIso；最后Data Table Upsert每台：lastKnownCallbackIdsJson=当前数组JSON，certExpiryIso=当前值，certFlagged=是否已临期，lastCheckedAt=本轮时间。无变化轮次只更新lastCheckedAt，不调用OpenAI。

可直接复制的材料

只从电梯技师备注抽取结构化字段，不推测备注之外的事实。输入：callbackId={{callbackId}}，technicianNote={{technicianNote}}。输出严格JSON：{"faultType":"door|motor|control|power|sensor|other","entrapmentRisk":true/false,"estimatedDownHours":0-72的数字,"confidence":"low|medium|high"}。若备注写到有人被困、轿厢停层不开门、乘客报警，entrapmentRisk=true；若信息不足，confidence=low且estimatedDownHours=0。不要输出解释。

{"units":[{"elevatorId":"EL-A101","buildingName":"示例大厦A座","openCallbackIds":["CB-9001"],"certExpiryIso":"2026-10-20T00:00:00Z","technicianNote":"轿厢停2层不开门，乘客报警称被困，初步怀疑门锁回路，预计停运6小时。"},{"elevatorId":"EL-B202","buildingName":"示例大厦B座","openCallbackIds":[],"certExpiryIso":"2026-09-16T00:00:00Z","technicianNote":"例行巡检完成，控制柜风扇噪音偏大，建议下次保养更换。"}]}

{"table":"elevator_watchdog_state","seed":[{"elevatorId":"EL-A101","buildingName":"示例大厦A座","lastKnownCallbackIdsJson":"[]","certExpiryIso":"2026-10-20T00:00:00Z","certFlagged":false,"lastCheckedAt":"2026-09-05T08:30:00Z"},{"elevatorId":"EL-B202","buildingName":"示例大厦B座","lastKnownCallbackIdsJson":"[]","certExpiryIso":"2026-09-16T00:00:00Z","certFlagged":false,"lastCheckedAt":"2026-09-05T08:30:00Z"}],"map":{"apiElevatorId":"elevatorId","apiCallbacks":"openCallbackIds","apiCert":"certExpiryIso","apiNote":"technicianNote","storeCallbacks":"lastKnownCallbackIdsJson","storeFlag":"certFlagged"}}

输入与输出示例

本站虚构演示，非作者运行结果；未调用付费模板、厂商API或真实账号。

输入

本轮为2026-09-05T09:00:00Z，mock API返回上面两台电梯；Data Table旧快照中EL-A101与EL-B202的lastKnownCallbackIdsJson均为[]，certFlagged均为false。

对应输出

diff结果：EL-A101 newCallbacks=["CB-9001"]；抽取输出{"faultType":"door","entrapmentRisk":true,"estimatedDownHours":6,"confidence":"medium"}，Telegram急讯含“EL-A101/示例大厦A座/door/约6小时/CB-9001”。EL-B202无新回召，但certExpiry距当天11天，Gmail发给物业经理测试邮箱；回写后A101 lastKnownCallbackIdsJson="[\"CB-9001\"]"，B202 certFlagged=true。

做完检查这些

• 例行两轮拉取相同合成响应时，第二轮不产生OpenAI调用、Telegram或Gmail，仅lastCheckedAt变化
• EL-A101新增CB-9001只告警一次；下一轮同一callbackId已在lastKnownCallbackIdsJson中则不再呼叫
• EL-B202证书首次进入14天窗口发一封Gmail并把certFlagged置true；之后不再重复通知
• 把openCallbackIds或elevatorId改名后流程应在映射处报错，而不是静默漏报或写错表

容易卡住的地方

• 这是付费模板，需购买才能取得原文件；本站示例不是原工作流，模型/短信/邮件服务可能另收费
• 厂商API必须稳定返回elevatorId与openCallbackIds；结构漂移会让diff失效，作者也称依赖一致结构
• 14天窗口和>4小时停机阈值是策略参数，跨法域要改Code节点并重新播种certFlagged
• 供应商停机导致漏轮时只能等下次diff补判，不能倒推已经错过的告警时点
• AI只在newCallbacks非空时调用；若把无变化轮也接入OpenAI会破坏成本设计