|
|
@ -191,7 +191,8 @@ func (the *consumerAXYThemeToES) judgeTime(rawMsg string) (time.Time, time.Time, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
queryStr := the.getESTimeQueryStr(theme.Station.Structure.Id, theme.Station.Id) |
|
|
queryStr := the.getESTimeQueryStr(theme.Station.Structure.Id, theme.Station.Id) |
|
|
TimeTheme, err := the.OutEs.SearchThemeData("anxincloud_last_theme", queryStr) |
|
|
index := the.Info.IoConfig.Out.Es.Index |
|
|
|
|
|
TimeTheme, err := the.OutEs.SearchThemeData(index, queryStr) |
|
|
//如果es里面没有这个数据时间,呢就返回测点的时间
|
|
|
//如果es里面没有这个数据时间,呢就返回测点的时间
|
|
|
if len(TimeTheme) > 0 { |
|
|
if len(TimeTheme) > 0 { |
|
|
cTime := TimeTheme[0].CollectTime |
|
|
cTime := TimeTheme[0].CollectTime |
|
|
|