设计一个订单和支付系统

用户 ──> 订单服务 ──预占库存──> 库存服务
           │ 创建订单（待支付），超时未支付由延时任务取消
           ▼
         支付服务 <────────> 第三方支付
           │ ① 创建支付单，调用渠道的下单接口
           │ ② 接收异步回调：验签、核对、幂等更新
           │ ③ 迟迟没有回调：主动调用查询接口
           ▼ 支付成功：支付单、订单状态、本地消息在一个事务里提交
         MQ ──> 发货、积分、通知（各自幂等）；对账服务每天和渠道账单逐笔核对

        支付成功             发货            确认收货 / 超时自动确认
待支付 ─────────> 已支付 ─────────> 已发货 ─────────────────────> 已完成
  │                 │                 │                            │
  │ 超时 / 用户取消   └─── 申请退款 ────┴───── 售后期内申请退款 ───────┘
  ▼                                   ▼
已取消                               退款中 ──退款成功──> 已退款
                                      └── 驳回或撤销：回到申请前的状态

-- 发货：只有已支付的订单能发货
UPDATE orders SET status = 'SHIPPED', shipped_at = NOW() WHERE order_no = ? AND status = 'PAID';
-- 申请退款：记下申请前的状态，驳回时还原。MySQL 单表 UPDATE 从左到右赋值，后面的赋值读到的是新值
-- （和标准 SQL 不同），所以 status_before_refund 必须写在 status 前面，写反了会存成 REFUNDING
UPDATE orders SET status_before_refund = status, status = 'REFUNDING'
WHERE order_no = ? AND status IN ('PAID', 'SHIPPED', 'COMPLETED');

CREATE TABLE orders (
  order_no   VARCHAR(32) PRIMARY KEY,     -- 分布式 ID 生成，不用自增 ID
  user_id    BIGINT NOT NULL,
  request_id VARCHAR(64) NOT NULL,        -- 客户端生成的请求号，下单幂等用
  status     VARCHAR(16) NOT NULL, status_before_refund VARCHAR(16),
  total_amount BIGINT NOT NULL, pay_amount BIGINT NOT NULL,  -- 商品总额、优惠后实付
  expire_at  DATETIME NOT NULL, paid_at DATETIME, shipped_at DATETIME, created_at DATETIME NOT NULL,
  UNIQUE KEY uk_req (user_id, request_id)
);
CREATE TABLE payment (                    -- 支付单：一笔订单可能有多次支付尝试
  pay_no   VARCHAR(32) PRIMARY KEY,       -- 传给渠道的商户订单号
  order_no VARCHAR(32) NOT NULL,
  channel  VARCHAR(16) NOT NULL, amount BIGINT NOT NULL,
  status   VARCHAR(16) NOT NULL,          -- PAYING / SUCCESS / CLOSED
  channel_trade_no VARCHAR(64) UNIQUE, paid_at DATETIME,  -- 渠道的交易号、支付时间
  KEY idx_order (order_no)
);
-- 另有 order_item（下单时的商品快照）、refund（退款单）、outbox（本地消息表）

export async function onPayNotify(pool, notify) {
  const conn = await pool.getConnection()
  try {
    await conn.beginTransaction()
    // 锁住支付单：同一笔支付的并发通知在这里排队
    const [[pay]] = await conn.query('SELECT * FROM payment WHERE pay_no = ? FOR UPDATE', [notify.payNo])
    if (!pay) throw new Error(`支付单不存在：${notify.payNo}`)
    // 统一转成 BigInt 再比较：mysql2 的 BIGINT 按配置可能返回 Number 或字符串（supportBigNumbers）
    if (BigInt(pay.amount) !== BigInt(notify.amount)) throw new Error(`金额不一致：${notify.payNo}`) // 告警，转人工
    if (pay.status === 'SUCCESS') {
      await conn.commit()
      return 'DUPLICATE' // 重复通知，直接应答成功
    }
    await conn.query("UPDATE payment SET status = 'SUCCESS', channel_trade_no = ?, paid_at = ? WHERE pay_no = ?",
      [notify.channelTradeNo, notify.paidAt, notify.payNo])
    // 条件更新：只有待支付的订单才能变成已支付
    const [r] = await conn.query("UPDATE orders SET status = 'PAID', paid_at = ? WHERE order_no = ? AND status = 'UNPAID'",
      [notify.paidAt, pay.order_no])
    // 影响 0 行：订单已超时取消，或已被另一笔支付付过。钱已经收到，转入自动退款
    const topic = r.affectedRows === 1 ? 'order-paid' : 'refund-required'
    await conn.query('INSERT INTO outbox (id, topic, payload) VALUES (?, ?, ?)',
      [`${topic}:${notify.payNo}`, topic, JSON.stringify(notify)])
    await conn.commit()
    return topic
  } catch (err) {
    await conn.rollback()
    throw err // 应答失败，等渠道重发；主动查询任务也会补偿
  } finally {
    conn.release()
  }
}