副标题[/!--empirenews.page--]
内容:
“商品秒杀”功能模块是建立在“商品详情”功能模块的基础之上,对于这一功能模块而言,其主要的核心流程在于:前端发起抢购请求,该请求将携带着一些请求数据:待秒杀Id跟当前用户Id等数据;后端接口在接收到请求之后,将执行一系列的判断与秒杀处理逻辑,最终将处理结果返回给到前端。
其中,后端接口的这一系列判断与秒杀处理逻辑还是挺复杂的,Debug将其绘制成了如下的流程图:
从该业务流程图中可以看出,后端接口在接收前端用户的秒杀请求时,其核心处理逻辑为:
(1)首先判断当前用户是否已经抢购过该商品了,如果否,则代表用户没有抢购过该商品,可以进入下一步的处理逻辑
(2)判断该商品可抢的剩余数量,即库存是否充足(即是否大于0),如果是,则进入下一步的处理逻辑
(3)扣减库存,并更新数据库的中对应抢购记录的库存(一般是减一操作),判断更新库存的数据库操作是否成功了,如果是,则创建用户秒杀成功的订单,并异步发送短信或者邮件通知信息通知用户
(4)以上的操作逻辑如果有任何一步是不满足条件的,则直接结束整个秒杀的流程,即秒杀失败!
接下来,我们仍然基于MVC的开发模式,采用代码实战实现这一功能模块!
(1)首先是在KillController 控制器开发接收“前端用户秒杀请求”的功能方法,其中,该方法需要接收前端请求过来的“待秒杀Id”,而当前用户的Id可以通过上一篇博文介绍的Shiro 的会话模块Session进行获取!
其源代码如下所示:
- private static final String prefix = "kill";
-
- @Autowired
- private IKillService killService;
-
- @Autowired
- private ItemKillSuccessMapper itemKillSuccessMapper;
-
- /***
- * 商品秒杀核心业务逻辑
- */
- @RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
- @ResponseBody
- public BaseResponse execute(@RequestBody @Validated KillDto dto, BindingResult result, HttpSession session){
- if (result.hasErrors() || dto.getKillId()<=0){
- return new BaseResponse(StatusCode.InvalidParams);
- }
- //获取当前登录用户的信息
- Object uId=session.getAttribute("uid");
- if (uId==null){
- return new BaseResponse(StatusCode.UserNotLogin);
- }
- Integer userId= (Integer)uId ;
- BaseResponse response=new BaseResponse(StatusCode.Success);
- try {
- Boolean res=killService.killItem(dto.getKillId(),userId);
- if (!res){
- return new BaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已抢购完毕或者不在抢购时间段哦!");
- }
- }catch (Exception e){
- response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage());
- }
- return response;
- }复制代码
其中,KillDto对象主要封装了“待秒杀Id”等字段信息,其主要用于接收前端过来的用户秒杀请求信息,源代码如下所示:
- @Data
- @ToString
- public class KillDto implements Serializable{
- @NotNull
- private Integer killId;
-
- private Integer userId; //在整合shiro之后,userId字段可以不需要了!因为通过session进行获取了
- }复制代码
(2)紧接着是开发 killService.killItem(dto.getKillId(),userId) 的功能,该功能对应的代码的编写逻辑可以参见本文刚开始介绍时的流程图!其完整源代码如下所示:
- @Autowired
- private ItemKillSuccessMapper itemKillSuccessMapper;
-
- @Autowired
- private ItemKillMapper itemKillMapper;
-
- @Autowired
- private RabbitSenderService rabbitSenderService;
-
- //商品秒杀核心业务逻辑的处理
- @Override
- public Boolean killItem(Integer killId, Integer userId) throws Exception {
- Boolean result=false;
-
- //TODO:判断当前用户是否已经抢购过当前商品
- if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){
- //TODO:查询待秒杀商品详情
- ItemKill itemKill=itemKillMapper.selectById(killId);
-
- //TODO:判断是否可以被秒杀canKill=1?
- if (itemKill!=null && 1==itemKill.getCanKill() ){
- //TODO:扣减库存-减一
- int res=itemKillMapper.updateKillItem(killId);
-
- //TODO:扣减是否成功?是-生成秒杀成功的订单,同时通知用户秒杀成功的消息
- if (res>0){
- commonRecordKillSuccessInfo(itemKill,userId);
-
- result=true;
- }
- }
- }else{
- throw new Exception("您已经抢购过该商品了!");
- }
- return result;
- }复制代码
(编辑:南平站长网)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|