diff --git a/pkg/cron/task.go b/pkg/cron/task.go index 44f6704..12f3231 100644 --- a/pkg/cron/task.go +++ b/pkg/cron/task.go @@ -43,7 +43,7 @@ func InitTasks() error { } // 每2分钟执行一次标签观看次数更新任务 - err = cm.AddTask("updateCastTagWatchCount", "0 */2 * * * *", UpdateCastTagWatchCountTask) + err = cm.AddTask("updateCastTagWatchCount", "0 */1 * * * *", UpdateCastTagWatchCountTask) cm.Start() // 启动队列消费者 @@ -522,7 +522,7 @@ func UpdateCastTagWatchCountTask() { CreatedAtEnd: createdAtEndStr, IsWatchCountCalled: 2, // 2表示未调用 Page: 1, - PageSize: 20, + PageSize: 10, } listResp, err := service.CastProvider.ListCastTags(ctx, listReq)