wind wsd

controllers/base_from_wind_wsd.go

@@ -132,7 +132,7 @@ func (this *WindWsdController) Add() {
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"
-		br.Data = dataItem
+		//br.Data = dataItem
 	} else {
 		br.Ret = 501
 		br.Success = true

models/base_from_wind_wsd.go

@@ -29,10 +29,20 @@ func AddEdbDataFromWindWsd(stockCode string, item map[string]map[string]interfac
 			vk = strings.ToLower(vk)
 			indexCode = windWsd + stockCode + vk
 
-			timeStr := wk
 			wkInt = wkInt / 1000
 			t := time.Unix(wkInt, 0)
+			if t.After(time.Now()) {
+				continue
+			}
 			dateTime := t.Format(utils.FormatDate)
+
+			dataTime, err := time.ParseInLocation(utils.FormatDate, dateTime, time.Local)
+			if err != nil {
+				return err
+			}
+			timestamp := dataTime.UnixNano() / 1e6
+			timeStr := fmt.Sprintf("%d", timestamp)
+
 			//saveVal := utils.SubFloatToString(val, 20)
 			if vv == nil {
 				continue