From 3d2a70966eb7211bfe5e56fc006f730509e9e6c4 Mon Sep 17 00:00:00 2001 From: cjy Date: Sun, 4 Jan 2026 09:43:17 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=87=8F=E5=B0=91=E8=B0=83=E7=94=A8?= =?UTF-8?q?=E6=AC=A1=E6=95=B0=EF=BC=8C=E6=AF=8F=E5=A4=A9=E5=8F=AA=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E4=B8=80=E6=AC=A1=EF=BC=8C=E4=B8=8D=E9=87=8D=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/cron/task.go | 3 ++- pkg/service/cast/analysis.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/cron/task.go b/pkg/cron/task.go index 05fb291..32bd507 100644 --- a/pkg/cron/task.go +++ b/pkg/cron/task.go @@ -25,7 +25,8 @@ func InitTasks() error { err = cm.AddTask("refreshWorkAnalysisApprovalStatus", "0 */1 * * * *", RefreshWorkAnalysisApprovalStatusTask) // 每天 00:30 和 12:30 执行 Ayrshare 指标采集任务 - err = cm.AddTask("ayrshareMetricsCollector", "0 30 0,12 * * *", AyrshareMetricsCollectorTask) + // err = cm.AddTask("ayrshareMetricsCollector", "0 30 0,12 * * *", AyrshareMetricsCollectorTask) + err = cm.AddTask("ayrshareMetricsCollector", "0 30 0 * * *", AyrshareMetricsCollectorTask) if err != nil { log.Printf("添加测试任务失败: %v", err) } diff --git a/pkg/service/cast/analysis.go b/pkg/service/cast/analysis.go index c095775..a3afd0a 100644 --- a/pkg/service/cast/analysis.go +++ b/pkg/service/cast/analysis.go @@ -780,8 +780,9 @@ func executeAyrshareMetricsCollector() { zap.L().Info("Ayrshare 指标采集任务执行完成") fmt.Printf("[%s] [INFO] Ayrshare 指标采集任务执行完成\n", time.Now().Format("2006-01-02 15:04:05")) + // 暂停重试 // 第三步：重试失败的记录（使用并发处理） - retryFailedMetricsForAyrshareConcurrent(ctx, dateCN) + // retryFailedMetricsForAyrshareConcurrent(ctx, dateCN) // 第四步：根据作品数据计算并更新账号日级指标 zap.L().Info("开始计算账号日级指标")