秒杀场景_重复抢单问题分析与实现_03

文章目录

• ​​SkillGoodService 改造​​

SkillGoodService 改造

package com.gblfy.service;

import com.gblfy.dao.SkillOrderRepository;
import com.gblfy.entity.SkillEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import javax.transaction.Transactional;

@Service
public class SkillGoodService {

    public static final String SKILL_GOODS_PHONE = "SKILL_GOODS_PHONE";
    public static final String SKILL_GOODS_LIST = "SKILL_GOODS_LIST";
    public static final String SKILL_GOODS_ONLY = "SKILL_GOODS_ONLY";

    @Autowired
    private RedisTemplate redisTemplate;
    @Autowired
    private MutilThreadOrder mutilThreadOrder;

    @Transactional
    public void add(Long productId, String userId) throws Exception {
        //判断这个用户是否参加过抢单
        Long time = redisTemplate.boundHashOps(SKILL_GOODS_ONLY).increment(userId, 1L);
        if(time>1){
            throw new Exception("重复抢单，不要太贪心");
        }
        // 先封装对象 并且放入redis 队列
        SkillEntity skillEntity = new SkillEntity();
        skillEntity.setProductId(productId);
        skillEntity.setUserId(userId);
        redisTemplate.boundListOps(SKILL_GOODS_LIST).leftPush(skillEntity);
        mutilThreadOrder.createOrder();

    }
}