|
@@ -856,7 +856,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void scheduleUpdateDurationToDatabase() {
|
|
public void scheduleUpdateDurationToDatabase() {
|
|
- log.info("开始更新会员看课时长,检查完课>>>>>>");
|
|
|
|
|
|
+ log.info("WXH5-开始更新会员看课时长,检查完课>>>>>>");
|
|
//读取所有的key
|
|
//读取所有的key
|
|
Collection<String> keys = redisCache.keys("h5wxuser:watch:duration::*");
|
|
Collection<String> keys = redisCache.keys("h5wxuser:watch:duration::*");
|
|
//读取看课配置
|
|
//读取看课配置
|
|
@@ -906,7 +906,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void checkFsUserWatchStatus() {
|
|
public void checkFsUserWatchStatus() {
|
|
- log.info("开始更新会员看课中断记录>>>>>");
|
|
|
|
|
|
+ log.info("WXH5-开始更新会员看课中断记录>>>>>");
|
|
// 从 Redis 中获取所有正在看课的用户记录
|
|
// 从 Redis 中获取所有正在看课的用户记录
|
|
Collection<String> keys = redisCache.keys("h5wxuser:watch:heartbeat:*");
|
|
Collection<String> keys = redisCache.keys("h5wxuser:watch:heartbeat:*");
|
|
LocalDateTime now = LocalDateTime.now();
|
|
LocalDateTime now = LocalDateTime.now();
|