汾渭 更新数据

models/base_from_fenwei.go

@@ -500,3 +500,10 @@ func GetBaseFromFenWeiIndexByIndexCode(indexCode string) (item *BaseFromFenweiIn
 
 	return
 }
+
+// UpdateBaseFromFenweiData 更新汾渭数据
+func UpdateBaseFromFenweiData(data *BaseFromFenweiData) error {
+	o := orm.NewOrm()
+	_, err := o.Update(data)
+	return err
+}

services/base_from_fenwei.go

@@ -351,7 +351,17 @@ func handleIndexData(indexInfo *models.FenWeiNetIndexInfo, indexIdMap map[string
 		return nil, err
 	}
 	if indexData != nil {
-		// 汾渭不存在数据更新和预测值情况，所以此处未做更新逻辑
+		// 对数据做更新处理
+		if indexData.Value != fmt.Sprintf("%v", indexInfo.Value) {
+			indexData.Value = fmt.Sprintf("%v", indexInfo.Value)
+			indexData.ModifyTime = time.Now()
+			logs.Info("handleIndexData update indexData : ", indexData)
+			err = models.UpdateBaseFromFenweiData(indexData)
+			if err != nil {
+				return nil, err
+			}
+		}
+
 		return nil, nil
 	}