Commit 3ac5e1a7 authored by 罗林杰's avatar 罗林杰

修改访问量缓存清除

parent 81d8563f
......@@ -66,7 +66,6 @@ public class MemTrafficServiceImpl extends ServiceImpl<MemTrafficRepository,MemT
BigInteger memberId = memTraffic.getMemberId();
Object isFirst = cyRedisServiceImpl.get(MemTrafficRedisBean.USER_MEMTRAFFIC + memberId);
this.redisTemplate.opsForValue().increment(MemTrafficRedisBean.USER_MEMTRAFFIC + memberId, 1L);
if (isFirst == null){
// 获取当前日期
LocalDate today = LocalDate.now();
......@@ -79,8 +78,12 @@ public class MemTrafficServiceImpl extends ServiceImpl<MemTrafficRepository,MemT
memTraffic.setBeginTime(createDate);
baseMapper.insertMemTraffic(memTraffic);
}
cyRedisServiceImpl.set(MemberInfoRedisBean.USER_LIKE_ALL + memberId,1L, Long.valueOf(48 * 60 * 60));
} else {
this.redisTemplate.opsForValue().increment(MemTrafficRedisBean.USER_MEMTRAFFIC + memberId, 1L);
}
return new CyPersistModel(1);
}
......@@ -133,19 +136,6 @@ public class MemTrafficServiceImpl extends ServiceImpl<MemTrafficRepository,MemT
log.info("用户访问数据定时任务结束---");
}
/**
* 定时删除redis中的访问量
*/
public void memTrafficDelSchedule() {
//将redis中存储的点赞数同步到opm_user_like表中
Set<String> keys = redisTemplate.keys(MemTrafficRedisBean.USER_MEMTRAFFIC + "*");
if (keys != null && !keys.isEmpty()) {
for (String key : keys) {
redisTemplate.delete(key);
}
}
}
/**
* 删除 访问量表
* @param memTraffic
......
......@@ -107,17 +107,10 @@ public class ScheduleTasks {
/**
* 定时更新访问量表
*/
@Scheduled(cron = "0 * * * * ?")
@Scheduled(cron = "0 0/20 * * * ?")
public void memTrafficSchedule() {
memTrafficService.memTrafficSchedule();
}
/**
* 定时删除redis中的访问量
*/
@Scheduled(cron = "0 0 0 * * ?")
public void memTrafficDelSchedule() {
memTrafficService.memTrafficDelSchedule();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment