设计一个消息通知系统（站内信、短信、推送）

业务方（订单、营销、安全）──> 通知 API：鉴权、参数校验、按业务唯一键幂等
                                 │ 写发送任务，投递到 MQ，立即返回"已受理"
                                 ▼
               预处理 worker：展开收件人 → 用户偏好、免打扰 → 去重、频控 → 渲染模板 → 选渠道
                                 │ 按渠道和优先级分到不同队列
       ┌──────────────┬──────────┴───────┬────────────────┐
   站内信队列        推送队列           短信队列          邮件队列
       │              │                  │                 │
  写收件箱表、     APNs、FCM、         短信供应商 A / B    邮件服务
  更新未读数       厂商推送通道        （限速、熔断、切换）
                                 │ 回执回调、主动查询
                                 ▼
                       发送记录表：状态追踪，供业务方和客服查询

CREATE TABLE notify_record (                -- 每个用户、每个渠道一条发送记录
  id              BIGINT PRIMARY KEY,
  biz_key         VARCHAR(64) NOT NULL,     -- 业务唯一键，如 order_shipped:订单号
  user_id         BIGINT NOT NULL,
  channel         VARCHAR(16) NOT NULL,     -- inbox / push / sms / email
  template_code   VARCHAR(64) NOT NULL,
  status          VARCHAR(16) NOT NULL,     -- PENDING / FILTERED / SENT / DELIVERED / FAILED
  reason          VARCHAR(64),              -- 被过滤或失败的原因：免打扰、超频、号码无效……
  provider        VARCHAR(32),              -- 实际使用的供应商
  provider_msg_id VARCHAR(64),              -- 供应商返回的消息 ID，用来匹配回执
  retry_count     INT NOT NULL DEFAULT 0,
  created_at DATETIME NOT NULL, sent_at DATETIME,
  UNIQUE KEY uk_biz (biz_key, user_id, channel)  -- 同一事件、同一用户、同一渠道只发一次
);
-- 另有 template、user_notify_setting（按分类和渠道的开关、免打扰时段）、user_device（推送 token）

// KEYS[1] 去重 key，KEYS[2] 当天的计数 key；ARGV[1] 去重窗口（秒），ARGV[2] 每日上限，ARGV[3] 计数 key 的过期时间（秒）
const GUARD = `
if redis.call('EXISTS', KEYS[1]) == 1 then return 1 end
local n = tonumber(redis.call('GET', KEYS[2]) or '0')
if n >= tonumber(ARGV[2]) then return 2 end
redis.call('SET', KEYS[1], '1', 'EX', ARGV[1])
redis.call('INCR', KEYS[2])
if n == 0 then redis.call('EXPIRE', KEYS[2], ARGV[3]) end
return 0`

const RESULT = ['PASS', 'DUPLICATE', 'OVER_LIMIT']

export async function guard(redis, { userId, category, dedupKey, date, dailyLimit, dedupSeconds = 3600 }) {
  // {userId} 是 hash tag，保证 Cluster 下两个 key 落在同一个槽
  const keys = [`notify:dedup:{${userId}}:${dedupKey}`, `notify:freq:{${userId}}:${category}:${date}`]
  const code = await redis.eval(GUARD, 2, ...keys, dedupSeconds, dailyLimit, 2 * 86400)
  return RESULT[code]
}

// 指数退避 + 随机抖动：第 attempt 次重试前等待的毫秒数
export function backoff(attempt, baseMs = 1000, maxMs = 10 * 60_000) {
  const cap = Math.min(maxMs, baseMs * 2 ** attempt)
  return Math.round(cap / 2 + Math.random() * (cap / 2)) // 落在 [cap/2, cap] 之间，避免大家同时重试
}