..

services/chart_info.go

@@ -143,11 +143,13 @@ func UpdateChart(chartInfoId int) (err error, errMsg string) {
 		return
 	}
 	// 更新投研资源库里的图表和指标绑定关系
-	err = models.UpdateForumChartEdbMapping(chartInfoId, edbInfoStr)
-	if err != nil {
-		errMsg = "更新投研资源库里的图表和指标绑定关系失败"
-		err = fmt.Errorf("更新投研资源库里的图表和指标绑定关系失败,Err:" + err.Error())
-		return
+	if oldEdbInfoStr != edbInfoStr {
+		err = models.UpdateForumChartEdbMapping(chartInfoId, edbInfoStr)
+		if err != nil {
+			errMsg = "更新投研资源库里的图表和指标绑定关系失败"
+			err = fmt.Errorf("更新投研资源库里的图表和指标绑定关系失败,Err:" + err.Error())
+			return
+		}
 	}
 	return
 }
@@ -341,7 +343,8 @@ func ChartInfoSaveBatch() (err error) {
 		}
 		utils.FileLog.Info("更新图表数据完成, 更新图表数据总数:", success)
 	}
-
+	// 更新指标数据
+	utils.Rc.LPush(utils.CACHE_KEY_EDB_DATA_UPDATE_LOG, []byte("1"))
 	sysUser, err := models.GetSysUserByAdminName("admin")
 	if err != nil {
 		err = fmt.Errorf("获取系统用户失败,Err:" + err.Error())
@@ -408,8 +411,7 @@ func ChartInfoSaveBatch() (err error) {
 	}
 	utils.FileLog.Info("上传图表数据完成, 上传图表数据总数:", success)
 
-	// 更新指标数据
-	utils.Rc.LPush(utils.CACHE_KEY_EDB_DATA_UPDATE_LOG, []byte("1"))
+	
 	return
 }
 

services/edb_data.go

@@ -20,6 +20,7 @@ type EdbDataBinlogReq struct {
 }
 
 func HandleBinlogEdbUpdateLog() error {
+	fmt.Println("HandleBinlogEdbUpdateLog 开始")
 	// 设置缓存防止重复调用
 	cacheKey := utils.CACHE_KEY_EDB_DATA_UPDATE_LOG
 	if utils.Rc.Get(cacheKey) != nil {
@@ -42,10 +43,15 @@ func HandleBinlogEdbUpdateLog() error {
 		return nil
 	}
 	offset := 0
-	pageSize := 10
+	pageSize := 1000
+	// 计算需要分多少页
+	pageNum := total / pageSize
+	if total % pageSize != 0 {
+		pageNum += 1
+	}
 
-		// 循环更新1000个图表数据
-	for i := 0; offset < total; i++ {
+	// 循环更新1000个图表数据
+	for i := 0; i < pageNum; i++ {
 		// 查询需要更新的图表信息
 		logs, err := models.GetEdbUpdateLogList(dateTime, offset, pageSize)
 		if err != nil {
@@ -98,6 +104,7 @@ func HandleBinlogEdbUpdateLog() error {
 			return err
 		}
 	}
+	fmt.Println("HandleBinlogEdbUpdateLog 结束")
 	return nil
 }