|
@@ -23,7 +23,7 @@ func AddEdbDataFromWind(edbCode string, item *EdbDataFromWind) (err error) {
|
|
|
addSql := ` INSERT INTO edb_data_wind(edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) values `
|
|
|
for k, v := range item.Dt {
|
|
|
|
|
|
-
|
|
|
+ v = v / 1000
|
|
|
t := time.Unix(v, 0)
|
|
|
dateTime := t.Format(utils.FormatDate)
|
|
|
t, _ = time.ParseInLocation(utils.FormatDate, dateTime, time.Local)
|
|
@@ -91,7 +91,7 @@ func RefreshEdbDataFromWind(edbInfoId int, edbCode, startDate string, item *EdbD
|
|
|
edbInfoIdStr := strconv.Itoa(edbInfoId)
|
|
|
for k, v := range item.Dt {
|
|
|
|
|
|
-
|
|
|
+ v = v / 1000
|
|
|
t := time.Unix(v, 0)
|
|
|
dateTime := t.Format(utils.FormatDate)
|
|
|
t, _ = time.ParseInLocation(utils.FormatDate, dateTime, time.Local)
|