从支付超时踩坑说起：分布式交易系统的一致性与容灾架构实践

package service

import (
	"context"
	"database/sql"
	"errors"
	"fmt"
)

// ProcessPaymentCallback 处理支付回调的幂等方法
func (s *OrderService) ProcessPaymentCallback(ctx context.Context, orderID string, paymentID string) error {
	tx, err := s.db.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelReadCommitted})
	if err != nil {
		return err
	}
	defer tx.Rollback()

	// 1. 尝试插入去重流水表 (利用 DB 唯一索引做防重栅栏)
	// 联合唯一索引: UNIQUE KEY `uniq_order_event` (`order_id`, `event_type`)
	insertFenceSQL := `INSERT INTO order_event_record (order_id, event_type, transaction_id) 
	                   VALUES (?, 'PAY_SUCCESS', ?)`
	_, err = tx.ExecContext(ctx, insertFenceSQL, orderID, paymentID)
	if err != nil {
		// 如果唯一键冲突，说明该事件已经处理过，直接返回成功，实现幂等
		if isDuplicateKeyError(err) {
			fmt.Printf("Event for order %s already processed, skipping\n", orderID)
			return nil 
		}
		return err
	}

	// 2. 带有前置状态检查的更新 (状态机原子推进)
	// 只有状态为 INIT (未支付) 的订单才允许更新为 PAID (已支付)
	updateOrderSQL := `UPDATE orders 
	                   SET status = 'PAID', updated_at = NOW() 
	                   WHERE order_id = ? AND status = 'INIT'`
	res, err := tx.ExecContext(ctx, updateOrderSQL, orderID)
	if err != nil {
		return err
	}

	rowsAffected, _ := res.RowsAffected()
	if rowsAffected == 0 {
		// 没有行受影响，说明状态已经被推移过，或者订单不存在
		return errors.New("order status mismatch or order not found")
	}

	// 3. 提交本地事务
	return tx.Commit()
}

func isDuplicateKeyError(err error) bool {
	// 判断 MySQL 1062 错误码，此处省略具体驱动适配
	return true 
}

[ 订单微服务 ]                           [ 消息中间件 ]           [ 积分/库存微服务 ]
      │                                       │                     │
 1. 开启本地事务                               │                     │
    ├─ 更新订单状态 (Order 表)                │                     │
    └─ 写入消息数据 (Outbox 表)                │                     │
 2. 提交本地事务                               │                     │
      │                                       │                     │
 3. 本地 Worker 轮询 / CDC (Binlog) 抓取 ─────> 投递 MQ 消息           │
                                              │ ── 4. 消费消息 ────> 执行加积分
                                              │ <── 5. ACK 回执 ──── 消费成功