fix:有色网爬虫数据源更新同步更新指标库

controllers/shanghai_smm.go

@@ -61,6 +61,7 @@ func (this *ShanghaiSmmController) RefreshData() {
 	updateIndexList := make([]*models.BaseFromSmmIndex, 0)
 	addDateList := make([]*models.BaseFromSmmData, 0)
 	readyDateList := make([]*models.BaseFromSmmData, 0)
+	updateIndexCode := make([]string, 0)
 	for _, v := range req {
 		indexInfo := ShanghaiSmmNameToIndexMap[v.IndexName]
 		if indexInfo == nil {
@@ -126,6 +127,7 @@ func (this *ShanghaiSmmController) RefreshData() {
 				item.ModifyTime = time.Now()
 				item.DataTimestamp = time.Now().UnixMilli()
 				addDateList = append(addDateList, item)
+				updateIndexCode = append(updateIndexCode, indexInfo.IndexCode)
 			} else {
 				smmData, err := models.GetBaseFromSmmDataByCodeAndDate(indexInfo.IndexCode, v.RenewDate)
 				if err != nil {
@@ -148,6 +150,7 @@ func (this *ShanghaiSmmController) RefreshData() {
 					if err != nil {
 						utils.FileLog.Info("indexCode: %s,更新指标数据失败，Err:%s", v.IndexCode, err.Error())
 					}
+					updateIndexCode = append(updateIndexCode, indexInfo.IndexCode)
 				}
 
 			}
@@ -213,12 +216,12 @@ func (this *ShanghaiSmmController) RefreshData() {
 			utils.FileLog.Info("SMM RefreshData errMsg: %s", errMsg)
 		}
 	}()
-	for _, v := range updateIndexList {
-		itemInfo, err := models.GetSmmIndexInfoMaxAndMinInfo(v.IndexCode)
+	for _, v := range updateIndexCode {
+		itemInfo, err := models.GetSmmIndexInfoMaxAndMinInfo(v)
 		if err == nil && itemInfo != nil {
-			e := models.ModifySmmIndexMaxAndMinInfo(v.IndexCode, itemInfo)
+			e := models.ModifySmmIndexMaxAndMinInfo(v, itemInfo)
 			if e != nil {
-				messages = append(messages, fmt.Sprintf("更新指标最大最小值失败, indexCode: %s, err: %s", v.IndexCode, e.Error()))
+				messages = append(messages, fmt.Sprintf("更新指标最大最小值失败, indexCode: %s, err: %s", v, e.Error()))
 				return
 			}
 		}
@@ -226,9 +229,9 @@ func (this *ShanghaiSmmController) RefreshData() {
 		// 同步刷新ETA图库有色的指标
 		{
 			// 获取指标详情
-			edbInfo, e := models.GetEdbInfoByEdbCode(utils.DATA_SOURCE_YS, v.IndexCode)
+			edbInfo, e := models.GetEdbInfoByEdbCode(utils.DATA_SOURCE_YS, v)
 			if e != nil && e.Error() != utils.ErrNoRow() {
-				messages = append(messages, fmt.Sprintf("刷新ETA指标异常, indexCode: %s, err: %s", v.IndexCode, e.Error()))
+				messages = append(messages, fmt.Sprintf("刷新ETA指标异常, indexCode: %s, err: %s", v, e.Error()))
 			}
 
 			// 已经加入到指标库的话，那么就去更新ETA指标库吧