|
|
@@ -441,7 +441,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
//集合中增加
|
|
|
logs.add(watchLog);
|
|
|
}
|
|
|
- batchUpdateFsUserCourseWatchLog(logs, 100);
|
|
|
+ batchUpdateFsUserCourseWatchLog(logs, 500);
|
|
|
}
|
|
|
|
|
|
public Long getFsUserVideoDuration(Long videoId) {
|
|
|
@@ -499,7 +499,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
}
|
|
|
logs.add(watchLog);
|
|
|
}
|
|
|
- batchUpdateFsUserCourseWatchLog(logs, 100);
|
|
|
+ batchUpdateFsUserCourseWatchLog(logs, 500);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -576,7 +576,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
logs.add(watchLog);
|
|
|
}
|
|
|
|
|
|
- batchUpdateFsCourseWatchLogIsOpen(logs, 100);
|
|
|
+ batchUpdateFsCourseWatchLogIsOpen(logs, 500);
|
|
|
}
|
|
|
|
|
|
public void batchUpdateFsCourseWatchLogIsOpen(List<FsCourseWatchLog> logs, int batchSize) {
|
|
|
@@ -877,7 +877,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
executorService.shutdown();
|
|
|
|
|
|
// 批量更新到数据库
|
|
|
- batchUpdateFsCourseWatchLog(logs, 100);
|
|
|
+ batchUpdateFsCourseWatchLog(logs, 500);
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
log.error("定时任务执行失败 scheduleBatchUpdateToDatabase", e);
|
|
|
@@ -1013,7 +1013,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
|
|
|
executorService.shutdown();
|
|
|
|
|
|
// 批量更新到数据库
|
|
|
- batchUpdateFsCourseWatchLog(logs, 100);
|
|
|
+ batchUpdateFsCourseWatchLog(logs, 500);
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
log.error("定时任务执行失败checkWatchStatus", e);
|