@@ -96,7 +96,8 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
return errors.New("RefreshEdbData Err:" + err.Error())
}
if resp.Ret != 200 {
- return errors.New("RefreshEdbData Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
+ fmt.Println("RefreshEdbData Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
+ //return errors.New("RefreshEdbData Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
fmt.Println("wind刷新结束")
@@ -48,7 +48,7 @@ func RefreshData(cont context.Context) (err error) {
wg.Add(7)
//同花顺
go data.RefreshDataFromThs(&wg)
- //同花顺
+ // wind
go data.RefreshDataFromWind(&wg)
//彭博
go data.RefreshDataFromPb(&wg)