fs-service/src/main/java/com/fs/course/service/impl/FsCourseWatchLogServiceImpl.java

@@ -413,7 +413,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
             }
             logs.add(watchLog);
         }
-        batchUpdateFsUserCourseWatchLog(logs, 100);
+        batchUpdateFsUserCourseWatchLog(logs, 500);
     }
 
     @Override
@@ -598,7 +598,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
                 log.error("处理heartbeat key {} 时发生异常: {}", key, e.getMessage());
             }
         }
-        batchUpdateFsUserCourseWatchLog(logs, 100);
+        batchUpdateFsUserCourseWatchLog(logs, 500);
     }
 
     @Override
@@ -675,7 +675,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
             logs.add(watchLog);
         }
 
-        batchUpdateFsCourseWatchLogIsOpen(logs, 100);
+        batchUpdateFsCourseWatchLogIsOpen(logs, 500);
     }
 
     public void batchUpdateFsCourseWatchLogIsOpen(List<FsCourseWatchLog> logs, int batchSize) {
@@ -976,7 +976,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
             executorService.shutdown();
 
             // 批量更新到数据库
-            batchUpdateFsCourseWatchLog(logs, 100);
+            batchUpdateFsCourseWatchLog(logs, 500);
 
         } catch (Exception e) {
             log.error("定时任务执行失败 scheduleBatchUpdateToDatabase", e);
@@ -1112,7 +1112,7 @@ public class FsCourseWatchLogServiceImpl extends ServiceImpl<FsCourseWatchLogMap
             executorService.shutdown();
 
             // 批量更新到数据库
-            batchUpdateFsCourseWatchLog(logs, 100);
+            batchUpdateFsCourseWatchLog(logs, 500);
 
         } catch (Exception e) {
             log.error("定时任务执行失败checkWatchStatus", e);