Commit df4474ac authored by liuyang's avatar liuyang

fixed bug 课程观看记录

parent ba3e1f16
...@@ -44,12 +44,14 @@ public class CourseConsumeRecordController { ...@@ -44,12 +44,14 @@ public class CourseConsumeRecordController {
return Result.succeed("ok"); return Result.succeed("ok");
} }
//缓存用户观看记录 //缓存用户观看记录
redisTemplate.opsForValue().set("record_"+UserContext.getUserId()+"_"+model.getCourseId(),model, 5,TimeUnit.MINUTES); redisTemplate.opsForValue().set("record_"+UserContext.getUserId()+"_"+model.getCourseId(),model, 10,TimeUnit.MINUTES);
//缓存课程观看记录 //缓存课程观看记录
if(redisTemplate.opsForHash().hasKey(BizConstants.CACHE_KE_CONSUME_RECORD,model.getUuid())){ if(redisTemplate.opsForHash().hasKey(BizConstants.CACHE_KE_CONSUME_RECORD,model.getUuid())){
CourseConsumeRecordPO cacheModel = (CourseConsumeRecordPO) redisTemplate.opsForHash().get(BizConstants.CACHE_KE_CONSUME_RECORD,model.getUuid()); CourseConsumeRecordPO cacheModel = (CourseConsumeRecordPO) redisTemplate.opsForHash().get(BizConstants.CACHE_KE_CONSUME_RECORD,model.getUuid());
cacheModel.setWatchTime(model.getLearnDuration()); cacheModel.setWatchTime(model.getLearnDuration());
if (model.getVideoDuration() != null){
cacheModel.setVideoTime(model.getVideoDuration()); cacheModel.setVideoTime(model.getVideoDuration());
}
cacheModel.setUpdateTime(LocalDateTime.now()); cacheModel.setUpdateTime(LocalDateTime.now());
if (StrUtil.isNotBlank(model.getEvent()) && "flush".equals(model.getEvent())){ if (StrUtil.isNotBlank(model.getEvent()) && "flush".equals(model.getEvent())){
recordService.saveOrUpdateBatch(Lists.newArrayList(cacheModel)); recordService.saveOrUpdateBatch(Lists.newArrayList(cacheModel));
......
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