|
@@ -22,11 +22,12 @@ func SyncEdbDataByWind(edbInfoId int64, edbCode, startDate, endDate string) (err
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- thsUrl := utils.Hz_Data_Url + `edbInfo/wind/?EdbCode=%s&StartDate=%s&EndDate=%s`
|
|
|
- thsUrl = fmt.Sprintf(thsUrl, edbCode, startDate, endDate)
|
|
|
- utils.FileLog.Info("thsUrl:%s", thsUrl)
|
|
|
- body, err := http.Get(thsUrl)
|
|
|
- fmt.Println("GetEdbDataByThs body:")
|
|
|
+ windUrl := utils.Hz_Data_Url + `edbInfo/wind/?EdbCode=%s&StartDate=%s&EndDate=%s`
|
|
|
+ windUrl = fmt.Sprintf(windUrl, edbCode, startDate, endDate)
|
|
|
+ utils.FileLog.Info("thsUrl:%s", windUrl)
|
|
|
+ body, err := http.Get(windUrl)
|
|
|
+ fmt.Println(windUrl)
|
|
|
+ fmt.Println("SyncEdbDataByWind body:")
|
|
|
fmt.Println(string(body))
|
|
|
utils.FileLog.Info("wind %s", string(body))
|
|
|
|
|
@@ -60,7 +61,7 @@ func SyncEdbDataByWind(edbInfoId int64, edbCode, startDate, endDate string) (err
|
|
|
|
|
|
item := new(data_manage.EdbDataWind)
|
|
|
item.EdbCode = edbCode
|
|
|
- item.EdbInfoId = 0
|
|
|
+ item.EdbInfoId = int(edbInfoId)
|
|
|
item.CreateTime = time.Now()
|
|
|
item.ModifyTime = time.Now()
|
|
|
item.DataTime = dateTime
|