@Override
    @Transactional
    public void addSeckillVoucher(Voucher voucher) {
        // 保存優(yōu)惠券
        save(voucher);
        // 保存秒殺信息
        SeckillVoucher seckillVoucher = new SeckillVoucher();
        seckillVoucher.setVoucherId(voucher.getId());
        seckillVoucher.setStock(voucher.getStock());
        seckillVoucher.setBeginTime(voucher.getBeginTime());
        seckillVoucher.setEndTime(voucher.getEndTime());
        seckillVoucherService.save(seckillVoucher);

        // 保存秒殺庫至redis  seckill:stock
        stringRedisTemplate.opsForValue().set(RedisConstants.SECKILL_STOCK_KEY + voucher.getId(), voucher.getStock().toString());
    }

-- 1.參數列表
-- 1.1 優(yōu)惠卷id
local voucherId = ARGV[1]
-- 1.2 用戶id
local userId = ARGV[2]

-- 2. 數據key
-- 2.1 庫存key 拼接 ..
local stockKey = 'seckill:stock:' .. voucherId
-- 2.2 訂單key 拼接 ..
local orderKey = "seckill:order" .. voucherId

-- 3. 腳本業(yè)務
-- 3.1 判斷庫存是否充足
if (tonumber(redis.call('get', stockKey)) <= 0) then
    -- 3.2 庫存不足
    return 1
end
-- 3.2 判斷用戶是否下單 SISMEMBER orderKey userId
if (redis.call('sismember', orderKey, userId) == 1) then
    -- 3.3 存在，證明是重復下單
    return 2
end
-- 3.4 扣庫存 incrby stockKey -1
redis.call('incrby', stockKey, -1)
-- 3.5 下單 保存用戶 sadd orderKey userId
redis.call('sadd', orderKey, userId)
return 0

	
	private static final DefaultRedisScript<Long> SECKILL_SCRIPT;

    static {
        SECKILL_SCRIPT = new DefaultRedisScript<>();
        SECKILL_SCRIPT.setLocation(new ClassPathResource("seckill.lua"));
        SECKILL_SCRIPT.setResultType(Long.class);
    }


    private BlockingQueue<VoucherOrder> orderTasks =new ArrayBlockingQueue<>(1024 * 1024);
    private static final ExecutorService SECKILL_ORDER_EXECUTOR = Executors.newSingleThreadExecutor();

    //項目啟動后執(zhí)行該方法
    @PostConstruct
    private void init() {
        SECKILL_ORDER_EXECUTOR.submit(new VoucherOrderHandler());
    }

    // 用于線程池處理的任務
    // 當初始化完畢后 就會去從對列中去拿信息
    private class VoucherOrderHandler implements Runnable {

        @Override
        public void run() {
            while (true){
                try {
                    // 1.獲取隊列中的訂單信息
                    VoucherOrder voucherOrder = orderTasks.take();
                    // 2.創(chuàng)建訂單
                    handleVoucherOrder(voucherOrder);
                } catch (Exception e) {
                    log.error("處理訂單異常", e);
                }
            }
        }
    }

    private void handleVoucherOrder(VoucherOrder voucherOrder) {
        //1.獲取用戶
        Long userId = voucherOrder.getUserId();
        // 2.創(chuàng)建鎖對象
        RLock lock = redissonClient.getLock("lock:order:" + userId);
        // 3.嘗試獲取鎖
        boolean isLock = lock.tryLock();
        // 4.判斷是否獲得鎖成功
        if (!isLock) {
            // 獲取鎖失敗，直接返回失敗或者重試
            log.error("不允許重復下單！");
            return;
        }
        try {
            //注意：由于是spring的事務是放在threadLocal中，此時的是多線程，事務會失效
            proxy.createVoucherOrder(voucherOrder);
        } finally {
            // 釋放鎖
            lock.unlock();
        }
    }


    // 代理對象
    private IVoucherOrderService proxy;

    @Override
    public Result seckillVoucher(Long voucherId) {
        // 獲取用戶
        Long userId = UserHolder.getUser().getId();

        // 獲取訂單id
        long orderId = redisIdWorker.nextId("order");

        // 1. 執(zhí)行l(wèi)ua 腳本
        Long result = stringRedisTemplate.execute(
                SECKILL_SCRIPT,
                Collections.emptyList(),
                voucherId.toString(),
                userId.toString(), String.valueOf(orderId)
        );

        int r = result.intValue();

        // 2. 判斷結果是否為0
        if (r != 0) {
            // 2.1 不為0 代表沒有購買資格
            return Result.fail(r == 1 ? "庫存不足" : "不允許重復下單");
        }
        // 2.2 為0，有購買資格 把下單信息保存到阻塞隊列
        // 2.2 有購買的資格，創(chuàng)建訂單放入阻塞隊列中
        VoucherOrder voucherOrder = new VoucherOrder();
        // 2.3.訂單id
        voucherOrder.setId(orderId);
        // 2.4.用戶id
        voucherOrder.setUserId(userId);
        // 2.5.代金券id
        voucherOrder.setVoucherId(voucherId);
        // 2.6.放入阻塞隊列
        orderTasks.add(voucherOrder);
        //3.獲取代理對象
        proxy = (IVoucherOrderService)AopContext.currentProxy();
        // 2.3 返回訂單id

        return Result.ok(orderId);
    }


    @Transactional
    public void createVoucherOrder (VoucherOrder voucherOrder){
        // 5.一人一單邏輯
        // 5.1.用戶id
        Long userId = voucherOrder.getUserId();

        // 判斷是否存在
        int count = query().eq("user_id", userId)
                .eq("voucher_id", voucherOrder.getId()).count();

        // 5.2.判斷是否存在
        if (count > 0) {
            // 用戶已經購買過了
            log.error("用戶已經購買過了");
        }

        //6，扣減庫存
        boolean success = seckillVoucherService.update()
                .setSql("stock= stock -1") //set stock = stock -1
                .eq("voucher_id", voucherOrder.getVoucherId()).gt("stock",0).update(); //where id = ？ and stock > 0
        // .eq("voucher_id", voucherId).eq("stock",voucher.getStock()).update(); //where id = ？ and stock = ?

        if (!success) {
            //扣減庫存
            log.error("庫存不足！");
        }

        save(voucherOrder);
    }