@Component
public class RedisIdGenerator {
    /**
     * 構(gòu)造方法注入stringRedisTemplate對(duì)象
     */
    private StringRedisTemplate stringRedisTemplate;
    public RedisIdGenerator(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }
    // 定義序列號(hào)的位數(shù)
    private static final int COUNT_BITS = 30;
    public long nextId(String keyPrefix) {
        // 生成從指定時(shí)間到現(xiàn)在的時(shí)間戳
        LocalDateTime beginTime = LocalDateTime.of(2022, 1, 1, 0, 0, 0);
        long beginTimeStamp = beginTime.toEpochSecond(ZoneOffset.UTC);
        long endTimeStamp = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
        long timeStamp = endTimeStamp - beginTimeStamp;
        /**
         * 生成序列號(hào) 使用redis的incr方法 K值為"icr:" + keyPrefix + ":" + date
         * 也就是按照日期作為K 每下一次單V就自增1作為序列號(hào)添加到后面
         * 這樣的話既避免了K固定帶來的V超過最大閾值(redis中的V最大為2^64)
         * 而且還方便了統(tǒng)計(jì)一天、一個(gè)月、一年的訂單量，在這段時(shí)間內(nèi)最大的序列號(hào)就是它的最多訂單數(shù)
         */
        String date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy:MM:dd"));
        Long sequenceId = stringRedisTemplate.opsForValue().increment("icr:" + keyPrefix + ":" + date);
        // 拼接生成全局唯一ID并返回 兩個(gè)二進(jìn)制的拼接可以使用前一個(gè)數(shù)左移一定位數(shù) 后一個(gè)數(shù)與位移后的進(jìn)行或運(yùn)算
        return timeStamp << COUNT_BITS | sequenceId;
    }
}

@Resource
private ISeckillVoucherService seckillVoucherService;
@Resource
private RedisIdGenerator generator;
@Override
@Transactional
public Result secKillVoucher(Long voucherId) {
    // 查詢優(yōu)惠券
    SeckillVoucher seckillVoucher = seckillVoucherService.getById(voucherId);
    // 獲取時(shí)間 判斷秒殺活動(dòng)是否開始或者結(jié)束
    if (seckillVoucher.getBeginTime().isAfter(LocalDateTime.now())) {
        return Result.fail("活動(dòng)暫未開始");
    } else if (seckillVoucher.getEndTime().isBefore(LocalDateTime.now())) {
        return Result.fail("活動(dòng)已經(jīng)結(jié)束");
    }
    // 判斷庫存是否充足
    if (seckillVoucher.getStock() < 1) {
        return Result.fail("庫存不足，活動(dòng)結(jié)束");
    }
    // 扣減庫存
    seckillVoucherService.update()
            .setSql("stock = stock - 1")
            .eq("voucher_id", voucherId).update();
    // 創(chuàng)建訂單 并返回id
    VoucherOrder order = new VoucherOrder();
    // 訂單id(redis全局唯一id) 下單用戶id(攔截器中做登錄驗(yàn)證的用戶id) 優(yōu)惠券id(直接傳過來的id)
    long orderId = generator.nextId("order");
    order.setId(orderId);
    order.setUserId(UserHolder.getUser().getId());
    order.setVoucherId(voucherId);
    save(order);
    return Result.ok(orderId);
}

// 扣減庫存
boolean update = seckillVoucherService.update()
        .setSql("stock = stock - 1")
        .eq("voucher_id", voucherId)
        .gt("stock", 0)
        .update();
// 更新失敗說明在扣除庫存的時(shí)候 庫存小于等于0
if (!update) {
    return Result.fail("庫存不足！");
}

// 單用戶id(攔截器中做登錄驗(yàn)證的用戶id)
Long userId = UserHolder.getUser().getId();
// 根據(jù)user_id加鎖  intern方法是去字符常量池中查找值相同的，不加的話字符串值一樣的地址不一樣也會(huì)加上鎖
synchronized (userId.toString().intern()) {
	// 查詢優(yōu)惠券
	// 判斷庫存是否充足
    // user_id和voucher_id聯(lián)合查詢訂單數(shù)
    Integer count = query().eq("user_id", userId)
            .eq("voucher_id", voucherId)
            .count();
    // 訂單數(shù)為1 就說明已經(jīng)下過單了
    if (count.equals(1)) {
        return Result.fail("您已經(jīng)購買過該商品了");
    }
    // 扣減庫存  創(chuàng)建訂單
    return Result.ok(orderId);
}