Skip to content

Commit

Permalink
提交
Browse files Browse the repository at this point in the history
  • Loading branch information
qiurunze committed Dec 27, 2018
1 parent f3f3c95 commit 370e0eb
Show file tree
Hide file tree
Showing 7 changed files with 16 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public boolean preHandle(HttpServletRequest request, HttpServletResponse respons
render(response, SESSION_ERROR);
return false;
}
key += "_" + user.getId();
key += "_" + user.getNickname();
}else {
//do nothing
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,16 +29,17 @@ public class LoginController {
@RequestMapping("/to_login")
public String tologin(LoginVo loginVo, Model model) {
logger.info(loginVo.toString());
String count = RedisLua.getVistorCount(COUNTLOGIN).toString();
logger.info("访问网站的次数为:{}",count);
model.addAttribute("count",count);
// String count = RedisLua.getVistorCount(COUNTLOGIN).toString();
// logger.info("访问网站的次数为:{}",count);
// model.addAttribute("count",count);
return "login";
}

@RequestMapping("/do_login")
@ResponseBody
public ResultGeekQ<Boolean> dologin(HttpServletResponse response, @Valid LoginVo loginVo) {
ResultGeekQ<Boolean> result = ResultGeekQ.build();
// RedisLua.vistorCount(COUNTLOGIN);
logger.info(loginVo.toString());
userService.login(response, loginVo);
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,8 +62,8 @@ public class MiaoshaController implements InitializingBean {
* 5000 * 10
* get post get 幂等 从服务端获取数据 不会产生影响  post 对服务端产生变化
*/
// @AccessLimit(seconds = 5, maxCount = 5, needLogin = true)
@RequestMapping(value = "/do_miaosha")
@AccessLimit(seconds = 5, maxCount = 5, needLogin = true)
@RequestMapping(value="/{path}/do_miaosha", method= RequestMethod.POST)
@ResponseBody
public ResultGeekQ<Integer> miaosha(Model model, MiaoshaUser user, @PathVariable("path") String path,
@RequestParam("goodsId") long goodsId) {
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/com/geekq/miaosha/rabbitmq/MQReceiver.java
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ public void receive(String message) {
return;
}
//判断是否已经秒杀到了
MiaoshaOrder order = orderService.getMiaoshaOrderByUserIdGoodsId(user.getId(), goodsId);
MiaoshaOrder order = orderService.getMiaoshaOrderByUserIdGoodsId(Long.valueOf(user.getNickname()), goodsId);
if(order != null) {
return;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public boolean register(HttpServletResponse response , String userName , String
miaoShaUser.setNickname(userName);
try {
miaoShaUserDao.insertMiaoShaUser(miaoShaUser);
MiaoshaUser user = miaoShaUserDao.getById(miaoShaUser.getId());
MiaoshaUser user = miaoShaUserDao.getById(Long.valueOf(miaoShaUser.getNickname()));
if(user == null){
return false;
}
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/com/geekq/miaosha/service/MiaoshaService.java
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ public boolean checkPath(MiaoshaUser user, long goodsId, String path) {
if(user == null || path == null) {
return false;
}
String pathOld = redisService.get(MiaoshaKey.getMiaoshaPath, ""+user.getId() + "_"+ goodsId, String.class);
String pathOld = redisService.get(MiaoshaKey.getMiaoshaPath, ""+user.getNickname() + "_"+ goodsId, String.class);
return path.equals(pathOld);
}

Expand All @@ -78,7 +78,7 @@ public String createMiaoshaPath(MiaoshaUser user, long goodsId) {
return null;
}
String str = MD5Utils.md5(UUIDUtil.uuid()+"123456");
redisService.set(MiaoshaKey.getMiaoshaPath, ""+user.getId() + "_"+ goodsId, str);
redisService.set(MiaoshaKey.getMiaoshaPath, ""+user.getNickname() + "_"+ goodsId, str);
return str;
}

Expand Down Expand Up @@ -113,7 +113,7 @@ public BufferedImage createVerifyCode(MiaoshaUser user, long goodsId) {
g.dispose();
//把验证码存到redis中
int rnd = calc(verifyCode);
redisService.set(MiaoshaKey.getMiaoshaVerifyCode, user.getId()+","+goodsId, rnd);
redisService.set(MiaoshaKey.getMiaoshaVerifyCode, user.getNickname()+","+goodsId, rnd);
//输出图片
return image;
}
Expand Down Expand Up @@ -182,11 +182,11 @@ public boolean checkVerifyCode(MiaoshaUser user, long goodsId, int verifyCode) {
if(user == null || goodsId <=0) {
return false;
}
Integer codeOld = redisService.get(MiaoshaKey.getMiaoshaVerifyCode, user.getId()+","+goodsId, Integer.class);
Integer codeOld = redisService.get(MiaoshaKey.getMiaoshaVerifyCode, user.getNickname()+","+goodsId, Integer.class);
if(codeOld == null || codeOld - verifyCode != 0 ) {
return false;
}
redisService.delete(MiaoshaKey.getMiaoshaVerifyCode, user.getId()+","+goodsId);
redisService.delete(MiaoshaKey.getMiaoshaVerifyCode, user.getNickname()+","+goodsId);
return true;
}

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/com/geekq/miaosha/service/OrderService.java
Original file line number Diff line number Diff line change
Expand Up @@ -46,12 +46,12 @@ public OrderInfo createOrder(MiaoshaUser user, GoodsVo goods) {
orderInfo.setGoodsPrice(goods.getMiaoshaPrice());
orderInfo.setOrderChannel(1);
orderInfo.setStatus(0);
orderInfo.setUserId(user.getId());
orderInfo.setUserId(Long.valueOf(user.getNickname()));
orderDao.insert(orderInfo);
MiaoshaOrder miaoshaOrder = new MiaoshaOrder();
miaoshaOrder.setGoodsId(goods.getId());
miaoshaOrder.setOrderId(orderInfo.getId());
miaoshaOrder.setUserId(user.getId());
miaoshaOrder.setUserId(Long.valueOf(user.getNickname()));
orderDao.insertMiaoshaOrder(miaoshaOrder);
redisService.set(OrderKey.getMiaoshaOrderByUidGid,""+user.getNickname()+"_"+goods.getId(),miaoshaOrder) ;
return orderInfo;
Expand Down

0 comments on commit 370e0eb

Please sign in to comment.