|
@@ -29,6 +29,15 @@ func AddEdbDataFromPb(edbCode string, item *EdbDataFromPb) (err error) {
|
|
|
t := time.Unix(v, 0)
|
|
|
dateTime := t.Format(utils.FormatDate)
|
|
|
|
|
|
+ // //这里的目的是为了北京时间,以防万一,还是重新转一下吧
|
|
|
+ {
|
|
|
+ t, err = time.ParseInLocation(utils.FormatDate, dateTime, time.Local)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ timeStr = fmt.Sprintf("%d", t.UnixNano()/1e6)
|
|
|
+ }
|
|
|
+
|
|
|
val := item.Value[k]
|
|
|
field := item.Field[k]
|
|
|
ticker := item.Ticker[k]
|
|
@@ -97,7 +106,15 @@ func RefreshEdbDataFromPb(edbInfoId int, edbCode, startDate string, item *EdbDat
|
|
|
v = v / 1000
|
|
|
t := time.Unix(v, 0)
|
|
|
dateTime := t.Format(utils.FormatDate)
|
|
|
- t, _ = time.ParseInLocation(utils.FormatDate, dateTime, time.Local) //这里的目的是为了北京时间,以防万一,还是重新转一下吧
|
|
|
+
|
|
|
+ // //这里的目的是为了北京时间,以防万一,还是重新转一下吧
|
|
|
+ {
|
|
|
+ t, err = time.ParseInLocation(utils.FormatDate, dateTime, time.Local)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ timeStr = fmt.Sprintf("%d", t.UnixNano()/1e6)
|
|
|
+ }
|
|
|
|
|
|
val := item.Value[k]
|
|
|
field := item.Field[k]
|