fix

services/data/base_edb_lib.go

@@ -20,6 +20,8 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
 	switch source {
 	case utils.DATA_SOURCE_THS:
 		urlStr = "ths/refresh"
+	case utils.DATA_SOURCE_WIND:
+		urlStr = "wind/refresh"
 	case utils.DATA_SOURCE_PB:
 		urlStr = "pb/refresh"
 	case utils.DATA_SOURCE_PB_FINANCE:

services/data/edb_info.go

@@ -75,9 +75,6 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
 	if err != nil {
 		return err
 	}
-
-	//var endDate string
-	//endDate = time.Now().Format(utils.FormatDate)
 	for _, v := range items {
 		startDate := ""
 		if v.Frequency == "日度" {
@@ -93,11 +90,6 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
 		} else {
 			startDate = v.EndDate.AddDate(0, 0, -utils.DATA_REFRESH).Format(utils.FormatDate)
 		}
-		//err = SyncEdbDataByWind(int64(v.EdbInfoId), v.EdbCode, startDate, endDate)
-		//if err != nil {
-		//	return err
-		//}
-		//edbInfoId, source int, edbCode, startDate string) (resp *models.BaseResponse, err error) {
 		resp, err := RefreshEdbData(v.EdbInfoId, v.Source, v.EdbCode, startDate)
 		if err != nil {
 			return errors.New("RefreshEdbData Err:" + err.Error())
@@ -105,17 +97,8 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
 		if resp.Ret != 200 {
 			return errors.New("RefreshEdbData Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
 		}
-		//item, err := data_manage.GetEdbInfoMaxAndMinInfo(v.Source, v.EdbCode)
-		//if err != nil {
-		//	return err
-		//}
-		//if item != nil {
-		//	err = data_manage.ModifyEdbInfoMaxAndMinInfo(v.EdbInfoId, item)
-		//	if err != nil {
-		//		return err
-		//	}
-		//}
 	}
+	fmt.Println("wind刷新结束")
 	return err
 }