From 7ca0198b3326b4d280a6377261c2aa0aba0f741f Mon Sep 17 00:00:00 2001 From: yarnom Date: Fri, 22 Aug 2025 21:05:31 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=20=E5=BB=B6=E9=95=BF=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E7=BB=9F=E8=AE=A1=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/tools/exporter.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/internal/tools/exporter.go b/internal/tools/exporter.go index 79526de..e526d17 100644 --- a/internal/tools/exporter.go +++ b/internal/tools/exporter.go @@ -61,9 +61,9 @@ func (e *Exporter) Start(ctx context.Context) error { } now := time.Now().In(e.loc) - // 下一个10分钟边界 + 30s - next := alignToNextBucketEnd(now, 10).Add(30 * time.Second) - e.logger.Printf("调度: 当前=%s, 下次执行=%s", now.Format("2006-01-02 15:04:05"), next.Format("2006-01-02 15:04:05")) + // 下一个10分钟边界 + 1分钟（改为60秒延迟） + next := alignToNextBucketEnd(now, 10).Add(1 * time.Minute) + e.logger.Printf("调度: 当前=%s, 下次执行=%s (延迟1分钟)", now.Format("2006-01-02 15:04:05"), next.Format("2006-01-02 15:04:05")) delay := time.Until(next) if delay > 0 { timer := time.NewTimer(delay) @@ -75,11 +75,11 @@ func (e *Exporter) Start(ctx context.Context) error { } } - // 修正：当前时间是桶末，需要导出的是刚结束的上一个桶 - // 例如：现在是20:50:30，应该导出的是20:40桶（表示20:40-20:50的数据） + // 当前时间是桶末，需要导出的是刚结束的上一个桶 + // 例如：现在是21:01:00，应该导出的是20:50桶（表示20:50-21:00的数据） currentTime := time.Now().In(e.loc) - bucketEnd := alignToPrevBucketEnd(currentTime, 10) // 上一个桶末，如20:50 - bucketStart := bucketEnd.Add(-10 * time.Minute) // 上一个桶开始，如20:40 + bucketEnd := alignToPrevBucketEnd(currentTime, 10) // 上一个桶末，如21:00 + bucketStart := bucketEnd.Add(-10 * time.Minute) // 上一个桶开始，如20:50 e.logger.Printf("当前时间=%s, 导出桶=%s-%s", currentTime.Format("2006-01-02 15:04:05"),