污染源异常数据推送系统是怎么运转的

这套系统不只是给夜班准备的。白天忙起来，手头的事一件接一件，数据页面就算开着，也未必顾得上多看一眼。企业多、排口多、因子更多，靠人一个个翻，时间长了总会走神。

夜班当然也要用，但不是全部原因。公司有同事专门盯夜班，真要说只是为了夜班，我可能不会下决心做这套东西。真正让我想把它做出来的，是那些忙起来容易漏掉数据的时段。系统把采集、判断、通知放在一条线上，数据不正常时主动找到人，而不是等人去找它。

数据从哪来

系统对接的是公开的小时数据接口，不需要人工登录，也不会顶掉现场正在使用的账号。采集任务按小时运行，把企业、排口、因子的最新读数存到自己的数据库里。想看某一天某个排口的变化，直接按日期翻就行，不依赖数据源平台的页面。

报警不只看一个数有没有超标。每个因子可以单独设标准值、上限和下限，pH 这类因子按范围判断，低了高了都会提醒。除了阈值，还支持连续多次超标、长时间没有新数据、数值长时间卡在同一个数、当日累计排放量异常这些规则。

污水进口有点特殊。进口水质本来波动就大，没有设置标准值或上限时，不推送超标提醒；但下限设成 0 以后，出现负值仍然会报警，因为这通常意味着仪表或采集出了问题。

通知渠道有 ntfy、企业微信机器人、通用 Webhook 和邮件，后面还可以接公众号。新报警会先发一次，没处理就按间隔重复提醒，数据恢复后再补一条恢复通知。夜里手机响一下，比一直守着电脑现实得多。

账号分成超级管理员、管理员、运维和只读。管理员负责企业、排口和通知渠道；运维只关联自己负责的企业和排口，能改的也只有已监控因子的阈值；只读账号只能看数据。配置好的企业可以共享给同事，不用每个人从头再配一遍。

真正跑起来以后，很多逻辑是边用边改的。比如数据源整体没有新数据时，不再让每个企业各自报无数据，而是合并成一条平台故障通知；停产状态的排口暂停无数据告警；取消某个因子监控时，相关的未处理报警也一起关闭。这些改动都不大，但能少很多半夜的无效提醒。

现在系统接入了二十多家企业、几十个排口，小时数据、报警记录和通知记录都留在自己的服务器上，按天备份，过期数据定时清理。它不追求功能多，目标只有一个：该响的时候响，不该响的时候别吵。!