diff --git a/scripts/wx_finance_poller.py b/scripts/wx_finance_poller.py index 864d849..94f9dce 100644 --- a/scripts/wx_finance_poller.py +++ b/scripts/wx_finance_poller.py @@ -94,6 +94,14 @@ def _handle(client: httpx.Client, msg: dict) -> None: # weapp 卡片按小程序判源平台;image(截图)判不出平台,沿用 meituan。 source = _resolve_source(msg) if msgtype == "weapp" else "meituan" logger.info("命中触发 from=%s type=%s source=%s", frm, msgtype, source) + # 归档延迟排查: msgtime 是腾讯给的消息发送时刻(毫秒), 与 poller 此刻之差 + # ≈ 企业微信会话存档的归档延迟(+ 本地 ≤0.5s 轮询间隔), 用来隔离"是我们慢还是归档慢"。 + try: + _msgtime_ms = float(msg.get("msgtime") or 0) + if _msgtime_ms > 0: + logger.info("归档延迟(msgtime→poller取到) ≈ %.2fs", time.time() - _msgtime_ms / 1000.0) + except Exception: + pass _notify(client, source, msgtype)