工厂厂区周界入侵、仓储库房异常移动、镜头被遮挡破坏时如何用乐橙开放平台setMessageCallback把videoMotion/hoveringAlarm/videoBlind告警回调推送到值班手机、企业微信与语音外呼本文给出可运行的 Node.js 告警推送实战与踩坑清单。一、值守漏报往往不是镜头坏了老周管着一家中小工厂的安防对接。厂区周界、成品仓、无人车间门口都挂着乐橙工业摄像头录像齐全、App 也能看。凌晨两点周界有人反复徘徊踩点成品仓通道出现异常移动更糟的是有一路枪机被短暂遮挡——第二天回放才看清全过程。问题不在「没拍到」而在动检告警、徘徊报警、视频遮挡已经发生却只停在消费端红点里进不了厂务值班室、企业微信群和语音外呼。工厂安防最怕的不是再买一台枪机而是告警进不了业务系统。本文用乐橙开放平台setMessageCallback把工厂安防关心的videoMotion/hoveringAlarm/videoBlind接到你的 HTTPS 回调服务先回 HTTP 200再异步叫醒值班员。二、为什么「轮询告警」救不了工厂值守2.1 问题本质感知在设备侧决策在值班业务侧智慧工厂 / 工业互联网场景里乐橙设备端已能产生三类高价值安防事件见事件消息类型定义msgType含义工厂厂区典型场景videoMotion动态检测动检告警夜班无人车间进画、库房通道异常移动hoveringAlarm徘徊报警厂区周界反复走动、踩点观望videoBlind视频遮挡镜头被挡、喷漆、人为破坏取证视线这三类都属于大类alarm。通过setMessageCallback订阅alarm以及可选的deviceStatus乐橙开放平台会把设备告警推送主动 HTTP POST到你登记的公网 HTTPS 地址——这比定时轮询「查告警」更省配额、延迟更低也更适合 IoT 安防事件回调。整体流程见事件消息推送流程。2.2 解决思路告警回调进业务通道而不是再装一个 App┌─────────────┐ 告警产生 ┌──────────────────┐ │ 乐橙摄像机 │ ─────────────► │ 乐橙开放平台云端 │ │ 动检/徘徊 │ │ 按 callbackUrl │ │ /视频遮挡 │ │ HTTP POST 推送 │ └─────────────┘ └─────────┬────────┘ │ ▼ ┌──────────────────────┐ │ 工厂桥接服务HTTPS │ │ ① 立刻返回 200 │ │ ② 异步短信/语音/企微 │ │ ③ 可选回放留证取证 │ └──────────────────────┘关键约束务必记住回调必须尽快返回 HTTP 200多次无响应平台会停止向该地址推送。callbackUrl必须可被外网访问内网localhost/ 未穿透地址无效。callbackFlag填大类alarm、deviceStatus等细分类在消息体msgType里区分。PaaS 设备开关能力优先用setDeviceCameraStatusenableType首字母小写见设备能力开关。下面进入交付层可运行的 Node.js 示例Express 官方签名算法适合后端 / 物联网开发者直接改造上线。三、从注册到「值班手机响了」的完整实操3.0 准备工作5 分钟打开 乐橙开放平台注册并创建应用拿到appId/appSecret。将厂区摄像机绑定到该开发者应用资产下设备需在线。准备一台有公网 HTTPS 的机器联调可用内网穿透生产请用正式证书域名。确认走现行 OpenAPIhttps://openapi.lechange.cn/openapi/{method}请求壳含systemparamsid开发规范。3.1 签名与 OpenAPI 最小封装先贴代码// imou-client.js —— 现行 OpenAPI 请求壳 MD5 签名constcryptorequire(crypto);const{v4:uuidv4}require(uuid);constOPENAPI_BASEhttps://openapi.lechange.cn/openapi;functioncalcSign(time,nonce,appSecret){// 官方time:{time},nonce:{nonce},appSecret:{appSecret} → MD5 小写 32 位constrawtime:${time},nonce:${nonce},appSecret:${appSecret};returncrypto.createHash(md5).update(raw,utf8).digest(hex);}asyncfunctioncallOpenApi(method,appId,appSecret,params{}){consttimeMath.floor(Date.now()/1000);constnonceuuidv4();constbody{system:{ver:1.0,appId,time,nonce,sign:calcSign(time,nonce,appSecret),},id:uuidv4(),params,};constresawaitfetch(${OPENAPI_BASE}/${method},{method:POST,headers:{Content-Type:application/json},body:JSON.stringify(body),});constjsonawaitres.json();if(!json.result||json.result.code!0){constmsgjson.result?${json.result.code}${json.result.msg}:JSON.stringify(json);thrownewError(OpenAPI${method}failed:${msg});}returnjson.result.data;}module.exports{callOpenApi,calcSign};签名自测与文档标准案例对齐// 文档标准案例应得到 fd37b62889e4757c58b8f3bf05fb9976constassertrequire(assert);const{calcSign}require(./imou-client);assert.strictEqual(calcSign(1706511734,f5a1ae2d-c09c-4d39-a744-83a5c2c653c2,test123456789test123456789),fd37b62889e4757c58b8f3bf05fb9976);console.log(sign ok);解释一句话time与服务器误差不能超过 5 分钟nonce5 分钟内不可重复否则会撞SN1005。3.2 拿管理员 accessToken有效约 3 天// get-token.jsrequire(dotenv).config();const{callOpenApi}require(./imou-client);(async(){constdataawaitcallOpenApi(accessToken,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{}// params 可为空);console.log(accessToken:,data.accessToken);console.log(expireTime(s):,data.expireTime);})();注意遇到TK1002再刷新不要每次业务请求都重新accessToken会白白消耗调用次数。接口说明accessToken。3.3 打开设备侧能力动检 / 徘徊PaaS 推荐对accessTypePaaS的设备文档推荐用setDeviceCameraStatusenableType首字母小写// enable-alarms.jsrequire(dotenv).config();const{callOpenApi}require(./imou-client);asyncfunctionmain(){consttoken(awaitcallOpenApi(accessToken,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{})).accessToken;constdeviceIdprocess.env.DEVICE_ID;// 设备序列号constchannelIdprocess.env.CHANNEL_ID||0;// 动检使能能力集中对应 MotionDetect传参用 motionDetectawaitcallOpenApi(setDeviceCameraStatus,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{token,deviceId,channelId,enableType:motionDetect,enable:true,});// 徘徊报警若能力集含 HoveringAlarm——厂区周界强烈建议开启try{awaitcallOpenApi(setDeviceCameraStatus,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{token,deviceId,channelId,enableType:hoveringAlarm,enable:true,});}catch(e){console.warn(hoveringAlarm 可能不支持该机型,e.message);}// 可选人形智能减少叉车灯光/飞鸟等非目标误报能力集含 AiHuman 时try{awaitcallOpenApi(setDeviceCameraStatus,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{token,deviceId,channelId,enableType:aiHuman,enable:true,});}catch(e){console.warn(aiHuman 可选机型不支持可忽略,e.message);}console.log(设备侧使能已尝试开启);}main();若设备非 PaaS、或你只想动「动检计划开关」可用modifyDeviceAlarmStatusenable: true/false见设置动检开关。是否支持徘徊/遮挡以设备能力集为准——能力集里没有对应项首字母大写形态强行开关会失败这是正常现象不是签名错了。3.4 登记回调setMessageCallback本文核心// set-callback.jsrequire(dotenv).config();const{callOpenApi}require(./imou-client);(async(){consttoken(awaitcallOpenApi(accessToken,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{})).accessToken;awaitcallOpenApi(setMessageCallback,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{token,status:on,callbackUrl:process.env.CALLBACK_URL,// 例如 https://bridge.example.com/imou/callbackcallbackFlag:alarm,deviceStatus,// alarm 覆盖动检/徘徊/遮挡等basePush:2,// 2不向乐橙 App 侧按该策略推送便于业务通道独占排查});constcurrentawaitcallOpenApi(getMessageCallback,process.env.IMOU_APP_ID,process.env.IMOU_APP_SECRET,{token});console.log(当前回调配置,current);})();参数对照官方文档 setMessageCallback参数取值建议说明statuson/off订阅开关callbackUrl公网 HTTPSon时必填callbackFlagalarm,deviceStatus大类逗号分隔basePush2默认1推送 /2不推送开发者账号关联乐橙 App 设备消息是否推送basePush建议联调阶段用2避免「App 有推送、桥接没日志」和「桥接有日志、值班员只盯 App」交叉干扰上线后按厂区安防产品策略再调。3.5 接收端先 200再异步叫醒值班室踩坑素材已写进逻辑普通告警推送体官方事件消息格式定义大致如下{id:2447736561,appId:lcdxxxxxxxxx,did:TESTQWERXXXX,cid:0,msgType:videoMotion,time:1475052555,cname:成品仓通道枪机,remark:,token:可选云录像 tokenplatForm4 时可能带,desc:{}}工厂安防关心的msgType白名单// bridge-server.jsrequire(dotenv).config();constexpressrequire(express);constWATCH_TYPESnewSet([videoMotion,// 动检告警hoveringAlarm,// 徘徊报警周界videoBlind,// 视频遮挡human,// 人形可选增强mobileDetect,// 动检PIRoffline,// 上下线若订阅了 deviceStatusonline,]);// 简单冷却同一设备同一类型 N 秒内只叫醒一次避免叉车/光照连发constcooldownMsNumber(process.env.COOLDOWN_MS||120000);constlastFirenewMap();functionshouldFire(did,msgType){constkey${did}:${msgType};constnowDate.now();constprevlastFire.get(key)||0;if(now-prevcooldownMs)returnfalse;lastFire.set(key,now);returntrue;}asyncfunctionnotifyDuty(event){// 这里换成你的短信 / 语音外呼 / 企业微信机器人// 示例只打日志生产请接云通信或企微 WebhookconstwhennewDate(event.time*1000).toLocaleString(zh-CN,{hour12:false});consttext【工厂安防告警】${event.msgType}\n设备:${event.did}通道:${event.cid}\n点位:${event.cname}\n时间:${when};console.log([NOTIFY],text);// 伪代码// await sms.send(process.env.DUTY_PHONE, text);// await voice.call(process.env.DUTY_PHONE, 厂区触发安防告警请立即查看);// await wecom.webhook(process.env.WECOM_HOOK, text);}constappexpress();app.use(express.json({limit:1mb}));app.post(/imou/callback,(req,res){// ★ 踩坑要点必须先回 200再做耗时逻辑res.status(200).json({code:0,msg:ok});constbodyreq.body||{};// 平台可能直接推告警对象若外层还有包装按你抓包结果微调consteventbody.msgType?body:body.data||body;setImmediate(async(){try{if(!event||!event.msgType){console.warn(unknown payload,JSON.stringify(body).slice(0,500));return;}if(!WATCH_TYPES.has(event.msgType)){console.log(ignore type,event.msgType);return;}if(!shouldFire(event.did||event.deviceId||unknown,event.msgType)){console.log(cooldown skip,event.msgType,event.did);return;}awaitnotifyDuty(event);}catch(err){console.error(async handle error,err);}});});app.get(/health,(_req,res)res.status(200).send(ok));constportprocess.env.PORT||8080;app.listen(port,()console.log(callback listening :${port}));环境变量示例# .envIMOU_APP_IDlcdxxxxxxxxxIMOU_APP_SECRETyour_secretDEVICE_ID你的设备序列号CHANNEL_ID0CALLBACK_URLhttps://bridge.example.com/imou/callbackCOOLDOWN_MS120000DUTY_PHONE13800000000WECOM_HOOKhttps://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyxxx依赖npmi express dotenv uuid# Node 18 自带 fetch更低版本请自行 polyfill3.6 联调清单按顺序打勾部署bridge-server.js确认https://你的域名/imou/callback外网可 POST。跑set-callback.js再用getMessageCallback确认statuson。跑enable-alarms.js开动检及机型支持的徘徊。人为触发在镜头前走动测动检用纸/布短暂遮挡测videoBlind在周界点位来回踱步测徘徊。看桥接日志是否出现对应msgType冷却窗口内重复触发应被 skip。把notifyDuty换成真实短信 / 语音 / 企微后再做一次夜班演练。3.7 实战踩坑实录可直接当 FAQ现象根因处理登记成功但永远收不到推送URL 非公网 / HTTPS 证书问题 / 路径 404curl -X POST自测看 Nginx 访问日志收过一阵后突然没了多次未返回 200平台停推保证同步路径零阻塞修复后重新setMessageCallbackApp 有人形桥接只有动检机型未开aiHuman或能力集无 AiHuman开使能或降级为动检冷却白班误报炸裂灵敏度过高 / 无冷却 / 白班也外呼加时间窗 COOLDOWN_MS白班只记日志/进企微夜班才语音basePush与 App 行为对不上联调时两边同时看联调设basePush:2以桥接日志为准遮挡测不出来部分机型遮挡策略差异以能力集与真机为准可先用动检闭环四、生产环境边界、性能与注意事项4.1 幂等与削峰同一物理事件可能短时间连发多条videoMotion叉车经过、灯光跳变也很常见。生产建议内存冷却上文lastFire→ RedisSET key NX EX 120班次策略22:00–08:00或厂区夜班窗口才语音外呼白班只进企业微信值班群分级响应videoBlind/hoveringAlarm立即电话普通videoMotion仅短信或群消息4.2 安全回调接口建议校验来源 IP 或加自有鉴权头平台推送侧以文档为准你方可在 URL 带短期 token/imou/callback?kxxxappSecret、值班手机号只放环境变量勿进仓库日志脱敏序列号可留手机号打码4.3 与录像留证的关系推送体里的token云录像并非所有设备都有文档说明仅platForm 为 4的设备告警可能带token。没有 token 时仍可用设备本地卡录像 / 开放平台回放类接口事后取证——叫醒靠告警回调取证靠存储两条链路不要绑死在同一次同步请求里。对工厂 EHS / 安防复盘这点尤其重要。4.4 设备能力边界hoveringAlarm、videoBlind、aiHuman均依赖机型能力集。正确姿势是先查设备详情/能力集 → 再setDeviceCameraStatus。能力没有就不要硬开对中小工厂与仓储库房「动检告警 视频遮挡 冷却外呼」已经能覆盖大部分无人值守场景有周界机型再叠加徘徊报警。4.5 可观测性最少三块指标回调 QPS / 200 比例 / 处理耗时按msgType计数动检 vs 徘徊 vs 遮挡「叫醒成功率」短信回执 / 电话接通 / 企微送达平台停推往往是「多次无响应」累积结果——把 P99 响应时间压到几十毫秒内比加机器更重要。五、小结与下一步老周后来的方案很朴素镜头还是厂区那几台乐橙多出来的是一条HTTPS 告警回调桥接——setMessageCallback订阅alarm白名单吃掉videoMotion/hoveringAlarm/videoBlind先 200 再异步推到值班手机与企业微信。事后翻录像变成了当晚被叫醒工厂安防从「存得住」变成了「叫得醒」。如果你也在做工厂厂区安防、仓储库房、无人车间、园区岗亭的告警推送对接在 乐橙开放平台 open.imou.com 注册并创建应用绑定设备按本文打开动检 / 徘徊等使能部署回调服务调用setMessageCallback接上短信 / 语音 / 企业微信等值班通道乐橙开放平台以视频技术与安全为核心开放低代码开发组件一站式助力第三方厂商与个人开发者快速、低成本落地视频场景应用——包括工业摄像头 OpenAPI、工厂安防告警推送、动检告警回调实战等闭环能力。欢迎直接打开注册入口开始https://open.imou.com延伸阅读现行文档事件消息推送流程setMessageCallback设置报警回调地址getMessageCallback查看报警回调地址事件消息类型定义事件消息格式定义setDeviceCameraStatus设置设备使能开关设备能力开关说明开发规范签名