fix:wind的时间戳

models/base_from_wind.go

@@ -22,10 +22,14 @@ func AddEdbDataFromWind(edbCode string, item *EdbDataFromWind) (err error) {
 	var isAdd bool
 	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 {
-		timeStr := fmt.Sprintf("%d", v)
-		v = v / 1000
+		//timeStr := fmt.Sprintf("%d", v)
+		//v = v / 1000
 		t := time.Unix(v, 0)
 		dateTime := t.Format(utils.FormatDate)
+		t, _ = time.ParseInLocation(utils.FormatDate, dateTime, time.Local) // 这里的目的是为了处理成北京时间，所以多转一遍
+		timestamp := t.UnixNano() / 1e6
+		timeStr := fmt.Sprintf("%d", timestamp)
+
 		val := item.Close[k]
 		saveVal := utils.SubFloatToString(val, 20)
 		addSql += GetAddSql("0", edbCode, dateTime, timeStr, saveVal)
@@ -85,11 +89,13 @@ func RefreshEdbDataFromWind(edbInfoId int, edbCode, startDate string, item *EdbD
 	addMap := make(map[string]string)
 	edbInfoIdStr := strconv.Itoa(edbInfoId)
 	for k, v := range item.Dt {
-		timeStr := fmt.Sprintf("%d", v)
-		v = v / 1000
+		//timeStr := fmt.Sprintf("%d", v)
+		//v = v / 1000
 		t := time.Unix(v, 0)
 		dateTime := t.Format(utils.FormatDate)
 		t, _ = time.ParseInLocation(utils.FormatDate, dateTime, time.Local) // 这里的目的是为了处理成北京时间，所以多转一遍
+		timestamp := t.UnixNano() / 1e6
+		timeStr := fmt.Sprintf("%d", timestamp)
 
 		val := item.Close[k]
 		saveVal := utils.SubFloatToString(val, 30)