|
@@ -1025,11 +1025,15 @@ func FutureGoodChartInfoRefresh(chartInfoId int) (err error) {
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- edbInfoMapping, err := data_manage.GetEtaEdbChartEdbMapping(chartInfoId)
|
|
|
+ edbInfoMappingList, err := data_manage.GetEtaEdbChartEdbMappingList(chartInfoId)
|
|
|
if err != nil {
|
|
|
errMsg = "获取需要刷新的ETA指标失败:Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
+ edbInfoIds := make([]int, 0)
|
|
|
+ for _, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ edbInfoIds = append(edbInfoIds, edbInfoMapping.EdbInfoId)
|
|
|
+ }
|
|
|
// 获取期货指标
|
|
|
futureGoodEdbInfoMapping, err := data_manage.GetFutureGoodEdbChartEdbMapping(chartInfoId)
|
|
|
if err != nil {
|
|
@@ -1044,7 +1048,7 @@ func FutureGoodChartInfoRefresh(chartInfoId int) (err error) {
|
|
|
}
|
|
|
|
|
|
// 批量刷新ETA指标
|
|
|
- err, _ = data.EdbInfoRefreshAllFromBaseV3([]int{edbInfoMapping.EdbInfoId}, false, true, false)
|
|
|
+ err, _ = data.EdbInfoRefreshAllFromBaseV3(edbInfoIds, false, true, false)
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|