From 7a656bbeaef11fdb9aed6dddbf02ed819bab2305 Mon Sep 17 00:00:00 2001
From: wood chen <wood@czl.net>
Date: Wed, 26 Mar 2025 14:35:54 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=88=9D=E5=A7=8B=E5=8C=96=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将 InitCronJobs 函数重命名为 Init，并优化定时任务的执行时间，OpenRouter价格获取任务调整为每4小时执行一次。
- 简化了定时任务的注册过程，提升了代码可读性和维护性。
---
 backend/cron/main.go | 28 ++++++++--------------------
 backend/main.go      |  2 +-
 2 files changed, 9 insertions(+), 21 deletions(-)

diff --git a/backend/cron/main.go b/backend/cron/main.go
index 9a91d7a..4c1cd02 100644
--- a/backend/cron/main.go
+++ b/backend/cron/main.go
@@ -12,47 +12,35 @@ import (
 
 var cronScheduler *cron.Cron
 
-// InitCronJobs 初始化并启动所有定时任务
-func InitCronJobs() {
+// Init 初始化并启动所有定时任务
+func Init() {
 	log.Println("初始化定时任务...")
 
 	// 创建一个新的cron调度器，使用秒级精度
 	cronScheduler = cron.New(cron.WithSeconds())
 
-	// 注册OpenRouter价格获取任务
-	// 每24小时执行一次
-	_, err := cronScheduler.AddFunc("4 6 * * *", func() {
+	// 注册价格获取任务
+	// 每4小时执行一次
+	_, err := cronScheduler.AddFunc("0 */4 * * *", func() {
 		if err := openrouter_api.FetchAndSavePrices(); err != nil {
 			log.Printf("OpenRouter价格获取任务执行失败: %v", err)
 		}
-	})
 
-	if err != nil {
-		log.Printf("注册OpenRouter价格获取任务失败: %v", err)
-	}
+		time.Sleep(3 * time.Second)
 
-	// 注册其他厂商价格更新任务
-	// 每24小时执行一次，错开时间避免同时执行
-	_, err = cronScheduler.AddFunc("30 6 * * *", func() {
 		if err := openrouter_api.UpdateOtherPrices(); err != nil {
 			log.Printf("其他厂商价格更新任务执行失败: %v", err)
 		}
-	})
 
-	if err != nil {
-		log.Printf("注册其他厂商价格更新任务失败: %v", err)
-	}
+		time.Sleep(3 * time.Second)
 
-	// 注册SiliconFlow价格更新任务
-	// 每24小时执行一次，错开时间避免同时执行
-	_, err = cronScheduler.AddFunc("0 7 * * *", func() {
 		if err := siliconflow_api.UpdateSiliconFlowPrices(); err != nil {
 			log.Printf("SiliconFlow价格更新任务执行失败: %v", err)
 		}
 	})
 
 	if err != nil {
-		log.Printf("注册SiliconFlow价格更新任务失败: %v", err)
+		log.Printf("注册价格更新定时任务失败: %v", err)
 	}
 
 	// 启动定时任务
diff --git a/backend/main.go b/backend/main.go
index 2af25cb..b568c1c 100644
--- a/backend/main.go
+++ b/backend/main.go
@@ -36,7 +36,7 @@ func main() {
 	}
 
 	// 初始化并启动定时任务
-	cron.InitCronJobs()
+	cron.Init()
 	defer cron.StopCronJobs()
 
 	r := gin.Default()