-- 用戶表
CREATE TABLE t_user (
    id VARCHAR(50) PRIMARY KEY,
    name VARCHAR(50),
    coupon_count INT DEFAULT 0
);

-- 訂單表
CREATE TABLE t_order (
    id VARCHAR(50) PRIMARY KEY,
    user_id VARCHAR(50),
    status VARCHAR(20), -- "待收貨"、"已完成"
    version BIGINT DEFAULT 0
);

-- 用戶張三，沒有優(yōu)惠券
INSERT INTO t_user VALUES ('u1', '張三', 0);

-- 一筆待收貨訂單
INSERT INTO t_order VALUES ('o1', 'u1', '待收貨', 0);

@Transactional
public String confirmOrder(String orderId) {
    // 查詢訂單狀態(tài)
    Order order = orderMapper.selectById(orderId);
    if ("已完成".equals(order.getStatus())) {
        return "SUCCESS";
    }

    // 核心：只更新待收貨的訂單
    int rows = orderMapper.updateStatusIfUnfinished(orderId, "已完成", "待收貨");

    if (rows == 1) {
        // 發(fā)優(yōu)惠券
        userMapper.addCoupon(order.getUserId(), 1);
        return "SUCCESS";
    } else {
        throw new RuntimeException("系統(tǒng)繁忙，請(qǐng)稍后重試");
    }
}

@Transactional(rollbackFor = Exception.class)
public String handleRecharge(String rechargeId) {
    // 根據(jù)rechargeId去找充值記錄，如果已處理過，則直接返回成功
    RechargePO rechargePo = rechargeMapper.selectById(rechargeId);
    if (rechargePo == null) {
        throw new IllegalArgumentException("充值記錄不存在");
    }

    // 充值記錄已處理過，直接返回成功
    if (rechargePo.getStatus() == 1) {
        return "SUCCESS";
    }

    // 開啟Spring事務(wù)（由 @Transactional 控制）

    // 在where后面要加 status = 0 這個(gè)條件；count表示影響行數(shù)
    int count = rechargeMapper.updateStatusToProcessed(rechargeId, 0, 1);

    // count = 1，表示上面sql執(zhí)行成功
    if (count != 1) {
        // 走到這里，說明有并發(fā)，直接拋出異常
        throw new RuntimeException("系統(tǒng)繁忙，請(qǐng)重試");
    } else {
        // 給賬戶加錢
        accountMapper.increaseBalance(rechargePo.getAccountId(), rechargePo.getPrice());
    }

    // 提交Spring事務(wù)（由 @Transactional 控制）

    return "SUCCESS";
}

CREATE TABLE t_idempotent (
    id VARCHAR(50) PRIMARY KEY,
    idempotent_key VARCHAR(100) NOT NULL,
    UNIQUE KEY uq_idempotent_key (idempotent_key)
);

@Transactional
public String confirmOrderWithUniqueKey(String orderId) {
    String idempotentKey = "order_confirm:" + orderId;

    try {
        idempotentMapper.insert(idempotentKey);
    } catch (DuplicateKeyException e) {
        return "SUCCESS";
    }

    Order order = orderMapper.selectById(orderId);
    if ("已完成".equals(order.getStatus())) return "SUCCESS";

    orderMapper.updateStatus(orderId, "已完成");
    userMapper.addCoupon(order.getUserId(), 1);
    return "SUCCESS";
}

public String confirmOrderWithRedisLock(String orderId) {
    String lockKey = "lock:order:confirm:" + orderId;

    if (!redisLock.tryLock(lockKey, 5秒)) {
        throw new RuntimeException("系統(tǒng)繁忙，請(qǐng)稍后重試");
    }

    try {
        // 冪等處理邏輯
        ...
    } finally {
        redisLock.release(lockKey);
    }
}