报告同步

models/eta/eta_report.go

@@ -91,7 +91,7 @@ func GetUpdateETAReports() (filterList []ETAReport, err error) {
 		for i := 0; i < len(reports); i++ {
 			setClassifyIdValue(&reports[i])
 			key := redis.GenerateReportRefreshKey("ETA", reports[i].ID, reports[i].ModifyTime.UnixMilli())
-			if rd().SetIfNotExist(key, "processed", 60) {
+			if rd().SetIfNotExist(key, "processed", 3600) {
 				logger.Info("同步eta报告 ID :%d,修改时间:%v", reports[i].ID, reports[i].ModifyTime)
 				filterList = append(filterList, reports[i])
 			} else {

task/report/report_update_task.go

@@ -59,7 +59,7 @@ func (re *ReportUpdateTask) Execute(taskDetail *base.TaskDetail) error {
 		htReportList, err := ht.GetUpdateHTReports()
 		for i := 0; i < len(htReportList); i++ {
 			key := redis.GenerateReportRefreshKey("HT", htReportList[i].Id, int64(htReportList[i].PublishTime))
-			if rd().SetIfNotExist(key, "processed", 60) {
+			if rd().SetIfNotExist(key, "processed", 3600) {
 				logger.Info("同步eta报告 ID :%d,修改时间:%v", htReportList[i].Id, int64(htReportList[i].PublishTime))
 				filterReportList = append(filterReportList, htReportList[i])
 			} else {