Browse Source

fix(internal/server): 修改任务调度的执行周期

- 将任务调度的执行周期从每小时一次修改为每分钟一次
-涉及的任务包括:同步到期时间
fusu 1 tuần trước cách đây
mục cha
commit
85321f6481
1 tập tin đã thay đổi với 4 bổ sung4 xóa
  1. 4 4
      internal/server/task.go

+ 4 - 4
internal/server/task.go

@@ -76,7 +76,7 @@ func (t *TaskServer) Start(ctx context.Context) error {
 
 
 
-	_, err := t.scheduler.Cron("0 * * * *").Do(func() {
+	_, err := t.scheduler.Cron("* * * * *").Do(func() {
 		err := t.wafTask.SynchronizationTime(ctx)
 		if err != nil {
 			t.log.Error("同步到期时间失败", zap.Error(err))
@@ -86,7 +86,7 @@ func (t *TaskServer) Start(ctx context.Context) error {
 		t.log.Error("同步到期时间注册任务失败", zap.Error(err))
 	}
 
-	_, err = t.scheduler.Cron("0 * * * *").Do(func() {
+	_, err = t.scheduler.Cron("* * * * *").Do(func() {
 		err := t.wafTask.StopPlan(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("0 * * * *").Do(func() {
+	_, err = t.scheduler.Cron("* * * * *").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("0 * * * *").Do(func() {
+	_, err = t.scheduler.Cron("* * * * *").Do(func() {
 		err := t.wafTask.CleanUpStaleRecords(ctx)
 		if err != nil {
 			t.log.Error("续费失败", zap.Error(err))