1
@Slf4j
2
public class LocalCacheHelper {
3

4

5
    /**
6
     * 缓存，key为skuId，value为库存状态0表示售罄，1表示未售罄
7
     */
8
    private final static Map<String, Object> cacheMap = new ConcurrentHashMap<String, Object>();
9

10
    /**
11
     * 加入缓存
12
     *
13
     * @param key
14
     * @param cacheObject
15
     */
16
    public static void put(String key, Object cacheObject) {
17
        cacheMap.put(key, cacheObject);
18
        log.info("当前本地缓存 cacheMap:{}", JSON.toJSONString(cacheMap));
19
    }
20

21
    /**
22
     * 获取缓存
23
     * @param key
24
     * @return
25
     */
26
    public static Object get(String key) {
27
        return cacheMap.get(key);
28
    }
29

30
    /**
31
     * 清除缓存
32
     *
33
     * @param key
34
     * @return
35
     */
36
    public static void remove(String key) {
37
        cacheMap.remove(key);
38
    }
39

40

41
    public static void removeAll() {
42
        cacheMap.clear();
43
    }
44
}

1
@Component
2
@EnableScheduling
3
public class ScheduledTask {
4

5
  @Scheduled(cron = "0 0 1 * * ?")   // 每天凌晨一点执行
6
    public void importIntoRedisTask(){
7

8
        // 1. 从数据库查询今天的秒杀商品数据
9
        // where status = CHECKED_PASS AND stock_count > 0 AND DATE_FORMAT(start_time,'%Y-%m-%d') = ?
10

11

12
        // 2. 初始化库存状态位
13
        for(...) {
14

15
        // eg: 50-1 表示skuId为50的商品还有库存
16
        // eg: 49-0 表示skuId为49的商品没有库存
17
        LocalCacheHelper.put(skuId,"1");
18

19
        }
20
    }
21
}

1
/**
2
  * 提交秒杀订单
3
    * POST http://localhost/seckill/auth/submitOrder
4
*/
5
@PostMapping("/seckill/auth/submitOrder")
6
public Result submitOrder(@RequestBody OrderInfoParam orderInfo, HttpServletRequest request) {
7

8
    Long skuId = orderInfo.getOrderDetailList().get(0).getSkuId();
9
    // 1. 获取用户id
10
    String userId = AuthContext.getUserId(request);
11

12
    // 2. 校验本地库存状态位
13
    Object stockFlag = LocalCacheHelper.get(skuId.toString());
14
    if (!"1".equals(stockFlag)) {
15
        return Result.build(null, SeckillCodeEnum.SECKILL_FINISH);
16
    }
17

18
    // 3. 校验是否重复下单
19
    RSet<Long> set = redissonClient.getSet(RedisConst.PROMO_USER_ORDERED_FLAG + userId);
20
    boolean ret = set.tryAdd(skuId);
21
    if (!ret) {
22
        return Result.build(null, SeckillCodeEnum.SECKILL_DUPLICATE_TRADE);
23
    }
24

25
    orderInfo.setUserId(Long.valueOf(userId));
26

27
    // 4. 提交秒杀订单
28
    boolean submitOrderRet = promoService.submitOrder(orderInfo);
29
    if (!submitOrderRet) {
30
        return Result.build(null, SeckillCodeEnum.SECKILL_FINISH);
31
    }
32

33
    // 返回下单成功
34
    return Result.build(null, SeckillCodeEnum.SECKILL_ORDER_SUCCESS);
35

36
}

1
public boolean submitOrder(OrderInfoParam orderInfo) {
2

3
    Long skuId = orderInfo.getOrderDetailList().get(0).getSkuId();
4

5
    // 1. 扣减库存
6
    int affectedRows = seckillGoodsMapper.decreaseStock(skuId, 1);
7
    if (affectedRows < 1) {
8
        // 没有库存了
9
        // 更新本地库存状态位
10
        LocalCacheHelper.put(skuId.toString(), "0");
11
        return false;
12
    }
13

14
    // 2. 调用订单接口，生成订单
15
    Long orderId = orderApiClient.submitOrder(orderInfo);
16
    if (orderId != null) {
17
        return true;
18
    }
19

20
    return false;
21
}