/**
 * @Author oldlu
 */
@Service
@Transactional  //控制事務(wù)
public class OrderServiceImpl implements OrderService {

    @Autowired
    private StockMapper stockMapper;

    private OrderMapper orderMapper;

    //在非并發(fā)情況下無問題
    @Override
    public Integer kill(Integer id) {
        //根據(jù)商品id校驗庫存是否還存在
        Stock stock = stockMapper.checkStock(id);
        //當(dāng)已售和庫存相等就庫存不足了
        if(stock.getSale().equals(stock.getCount())){
            throw new RuntimeException("庫存不足!");
        }else{
            //扣除庫存  (已售數(shù)量+1)
            stock.setSale(stock.getSale()+1);
            stockMapper.updateSale(stock);   //更新信息
            //創(chuàng)建訂單
            Order order = new Order();
            order.setSid(stock.getId()).setName(stock.getName()).setCreateDate(new Date());
            orderMapper.createOrder(order); //創(chuàng)建訂單
            return order.getId();   //mybatis主鍵生成策略 直接返回創(chuàng)建的id
        }
    }
}

/**
 * @Author oldlu
 */
@RestController
@RequestMapping("/stock")
public class StockController {
    @Autowired
    private OrderService orderService;
    //開發(fā)秒殺方法
    @GetMapping("/kill/{id}")
    public String kill(@PathVariable("id") Integer id){
        System.out.println("秒殺商品的ID=====================>"+id);
        try {
            //根據(jù)秒殺商品id調(diào)用秒殺業(yè)務(wù)
            Integer orderId = orderService.kill(id);
            return "秒殺成功,訂單ID為："+String.valueOf(orderId);
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }
}

/**
 * @Author oldlu
 */
@RestController
@RequestMapping("/stock")
public class StockController {

    @Autowired
    private OrderService orderService;

    //開發(fā)秒殺方法
    @GetMapping("/kill/{id}")
    public String kill(@PathVariable("id") Integer id){
        System.out.println("秒殺商品的ID=====================>"+id);
        try {
            //使用悲觀鎖
            synchronized (this){
                //根據(jù)秒殺商品id調(diào)用秒殺業(yè)務(wù)
                Integer orderId = orderService.kill(id);
                return "秒殺成功,訂單ID為："+String.valueOf(orderId);
            }
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }

}

    /**
     * 扣除庫存
     * @param stock
     */
    public void updateSale(Stock stock){
        //扣除庫存  (已售數(shù)量+1)
        stock.setSale(stock.getSale()+1);
        stockMapper.updateSale(stock);   //更新信息
    }

/**
 * 扣除庫存
 * @param stock
 */
public void updateSale(Stock stock){
    //在sql層面完成銷量+1 和 版本號 +1 并且根據(jù)商品id和版本號同時查詢更新的商品
    Integer updRows = stockMapper.updateSale(stock);   //更新信息
    if(updRows == 0){   //代表沒有拿到版本號
        throw new RuntimeException("搶購失敗,請重試！");
    }
}