fix: 减少调用次数,每天只执行一次,不重试

This commit is contained in:
cjy 2026-01-04 09:43:17 +08:00
parent 4bc97b1a7c
commit 3d2a70966e
2 changed files with 4 additions and 2 deletions

View File

@ -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)
}

View File

@ -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("开始计算账号日级指标")