优化定时任务更新指标数据

services/chart_info.go

@@ -314,7 +314,7 @@ func ChartInfoSaveBatch() (err error) {
 		success := 0
 
 		// 循环更新100个图表数据
-		for i := 0; offset <= total; i++ {
+		for i := 0; offset < total; i++ {
 			// 查询需要更新的图表信息
 			chartInfos, e := models.GetChartInfoListByCondition(condition, []interface{}{}, offset, pageSize)
 			if e != nil {
@@ -382,7 +382,7 @@ func ChartInfoSaveBatch() (err error) {
 	success := 0
 
 	// 循环更新100个图表数据
-	for i := 0; offset <= total; i++ {
+	for i := 0; offset < total; i++ {
 		// 查询需要更新的图表信息
 		chartInfos, e := models.GetChartInfoListByCondition(condition, []interface{}{chartClassifyIdList}, offset, pageSize)
 		if e != nil {

services/edb_data.go

@@ -6,6 +6,7 @@ import (
 	"time"
 
 	"eta/eta_forum_task/models"
+	"eta/eta_forum_task/services/alarm_msg"
 	"eta/eta_forum_task/services/eta_forum"
 	"eta/eta_forum_task/utils"
 )
@@ -19,8 +20,8 @@ type EdbDataBinlogReq struct {
 	List []*EdbDataBinlogDataReq `description:"指标数据列表"`
 }
 
-func HandleBinlogEdbUpdateLog() error {
-	fmt.Println("HandleBinlogEdbUpdateLog 开始")
+func HandleBinlogEdbUpdateLog() (err error) {
+	utils.FileLog.Info("HandleBinlogEdbUpdateLog 开始")
 	// 设置缓存防止重复调用
 	cacheKey := utils.CACHE_KEY_EDB_DATA_UPDATE_LOG
 	if utils.Rc.Get(cacheKey) != nil {
@@ -30,6 +31,9 @@ func HandleBinlogEdbUpdateLog() error {
 	utils.Rc.SetNX(cacheKey, "1", 10*time.Minute)
 	defer func() {
 		utils.Rc.Delete(cacheKey)
+		if err := recover(); err != nil {
+			utils.FileLog.Error("[HandleBinlogEdbUpdateLog]", err)
+		}
 	}()
 	//查询记录总数
 	dateTime := "2024-10-14 00:00:00"
@@ -104,20 +108,19 @@ func HandleBinlogEdbUpdateLog() error {
 			return err
 		}
 	}
-	fmt.Println("HandleBinlogEdbUpdateLog 结束")
+	utils.FileLog.Info("HandleBinlogEdbUpdateLog 结束")
 	return nil
 }
 
 // the service for log
 func AutoUpdateEdbDataToEtaForum() {
-	defer func() {
-		if err := recover(); err != nil {
-			fmt.Println("[AutoUpdateEdbDataToEtaForum]", err)
-		}
-	}()
 	for {
 		utils.Rc.Brpop(utils.CACHE_KEY_EDB_DATA_UPDATE_LOG, func(b []byte) {
-			HandleBinlogEdbUpdateLog()
+			err := HandleBinlogEdbUpdateLog()
+			if err != nil {
+				utils.FileLog.Info("[AutoUpdateEdbDataToEtaForum]", err)
+				go alarm_msg.SendAlarmMsg(fmt.Sprintf("[AutoUpdateEdbDataToEtaForum] 更新指标数据失败,Err:%s", err), 3)
+			}
 		})
 	}
 }