fix

controllers/future_good/future_good_edb_info.go

@@ -81,6 +81,14 @@ func (this *FutureGoodEdbInfoController) Add() {
 			br.ErrMsg = "获取指标信息失败 AddEdbDataFromWind，Err:" + err.Error()
 			return
 		}
+
+		// 更新指标最大最小值
+		err, errMsg := future_good.UnifiedModifyEdbInfoMaxAndMinInfo(futureGoodEdbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"
@@ -179,3 +187,23 @@ func (this *FutureGoodEdbInfoController) Refresh() {
 	br.Success = true
 	br.Msg = "获取成功"
 }
+
+//func init() {
+//
+//	list, err := future_good.GetFutureGoodEdbInfoList(" AND start_date = '0000-00-00' ", []interface{}{})
+//	if err != nil {
+//		fmt.Println("list err:", err)
+//		return
+//	}
+//
+//	fmt.Println("start")
+//	for _, futureGoodEdbInfo := range list {
+//		// 更新指标最大最小值
+//		err, errMsg := future_good.UnifiedModifyEdbInfoMaxAndMinInfo(futureGoodEdbInfo)
+//		if err != nil {
+//			fmt.Println(futureGoodEdbInfo.FutureGoodEdbCode, "更新失败:", errMsg, ";err:", err)
+//			return
+//		}
+//	}
+//	fmt.Println("end")
+//}

models/future_good/future_good_edb_data.go

@@ -138,7 +138,7 @@ func RefreshFutureGoodEdbDataFromThs(futureGoodEdbInfoId int, edbCode, startDate
 		}
 	}()
 
-	var existList []*FutureGoodEdbDataItem
+	var existList []*FutureGoodEdbData
 	// 获取指标中所有存在的数据值
 	{
 		var condition string
@@ -160,9 +160,9 @@ func RefreshFutureGoodEdbDataFromThs(futureGoodEdbInfoId int, edbCode, startDate
 		_, err = to.Raw(sql, pars).QueryRows(&existList)
 	}
 
-	existMap := make(map[string]*FutureGoodEdbDataItem)
+	existMap := make(map[string]*FutureGoodEdbData)
 	for _, v := range existList {
-		existMap[v.DataTime] = v
+		existMap[v.DataTime.Format(utils.FormatDate)] = v
 	}
 	addSql := ` INSERT INTO future_good_edb_data(future_good_edb_info_id,future_good_edb_code,data_time,trade_code,open,high,low,close,volume,amt,oi,settle,create_time,modify_time,data_timestamp) values `
 	var isAdd bool