Procházet zdrojové kódy

perf(task): 调整任务调度时间为每小时执行一次

- 将同步到期时间任务的执行频率从每分钟改为每小时- 将续费任务的执行频率从每分钟改为每小时- 将清理过期记录任务的执行频率从每分钟改为每小时
fusu před 6 dny
rodič
revize
f42e368a78
1 změnil soubory, kde provedl 3 přidání a 3 odebrání
  1. 3 3
      internal/server/task.go

+ 3 - 3
internal/server/task.go

@@ -76,7 +76,7 @@ func (t *TaskServer) Start(ctx context.Context) error {
 
 
 
-	_, err := t.scheduler.Cron("* * * * *").Do(func() {
+	_, err := t.scheduler.Cron("0 * * * *").Do(func() {
 		err := t.wafTask.SynchronizationTime(ctx)
 		if err != nil {
 			t.log.Error("同步到期时间失败", zap.Error(err))
@@ -97,7 +97,7 @@ func (t *TaskServer) Start(ctx context.Context) error {
 	}
 
 
-	_, err = t.scheduler.Cron("* * * * *").Do(func() {
+	_, err = t.scheduler.Cron("0 * * * *").Do(func() {
 		err := t.wafTask.RecoverRecentPlan(ctx)
 		if err != nil {
 			t.log.Error("续费失败", zap.Error(err))
@@ -108,7 +108,7 @@ func (t *TaskServer) Start(ctx context.Context) error {
 	}
 
 
-	_, err = t.scheduler.Cron("* * * * *").Do(func() {
+	_, err = t.scheduler.Cron("0 * * * *").Do(func() {
 		err := t.wafTask.CleanUpStaleRecords(ctx)
 		if err != nil {
 			t.log.Error("清理过期记录失败", zap.Error(err))