|
@@ -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
|
|
|
}
|
|
|
// 提交任务到协程池
|