ZF/spring-boot-seckill
1
0
Fork 0
mirror of https://gitee.com/52itstyle/spring-boot-seckill.git synced 2025-12-30 10:22:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

:bug:消息推送BUG修复

Browse Source
This commit is contained in:
小柒2012
2020-12-09 21:39:48 +08:00
parent 74ade941fd
commit 8835e9042a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/itstyle/seckill/queue/redis/RedisConsumer.java
View File

@@ -28,13 +28,13 @@ public class RedisConsumer {
if(redisUtil.getValue(array[0])==null){//control层已经判断了，其实这里不需要再判断了
Result result = seckillService.startSeckilDBPCC_TWO(Long.parseLong(array[0]), Long.parseLong(array[1]));
if(result.equals(Result.ok(SeckillStatEnum.SUCCESS))){
WebSocketServer.sendInfo(array[0], "秒杀成功");//推送给前台
WebSocketServer.sendInfo("秒杀成功",array[0]);//推送给前台
}else{
WebSocketServer.sendInfo(array[0], "秒杀失败");//推送给前台
WebSocketServer.sendInfo("秒杀失败",array[0]);//推送给前台
redisUtil.cacheValue(array[0], "ok");//秒杀结束
}
}else{
WebSocketServer.sendInfo(array[0], "秒杀失败");//推送给前台
WebSocketServer.sendInfo("秒杀失败",array[0]);//推送给前台
}
}
}