定时任务

services/report_pdf_service.go

@@ -237,10 +237,18 @@ func StartGenerateReportPDF() {
 			tasks, getErr := report.GetPendingTasks()
 			if getErr != nil {
 				utils.FileLog.Error("获取待处理任务失败: %v", getErr)
+				for len(reportHandler.TryTimer().C) > 0 {
+					<-reportHandler.TryTimer().C
+				}
+				reportHandler.TryTimer().Reset(taskInterval)
 				continue
 			}
 			if len(tasks) == 0 {
 				utils.FileLog.Info("暂无待处理任务")
+				for len(reportHandler.TryTimer().C) > 0 {
+					<-reportHandler.TryTimer().C
+				}
+				reportHandler.TryTimer().Reset(taskInterval)
 				continue
 			}
 			// 提交任务到协程池