From 2a1330e9b216efa54415bef76585a4dfd91abae5 Mon Sep 17 00:00:00 2001 From: lucas Date: Thu, 25 Dec 2025 09:51:34 +0800 Subject: [PATCH] =?UTF-8?q?update=20=20anxinyun=20=E4=B8=BB=E9=A2=98?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E7=B4=A2=E5=BC=95=E6=94=B9=E7=94=A8=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E9=87=8C=E9=9D=A2=E7=9A=84=E7=B4=A2=E5=BC=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerAXYThemeToES.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/consumers/consumerAXYThemeToES.go b/consumers/consumerAXYThemeToES.go index c5f677d..02c8356 100644 --- a/consumers/consumerAXYThemeToES.go +++ b/consumers/consumerAXYThemeToES.go @@ -191,7 +191,8 @@ func (the *consumerAXYThemeToES) judgeTime(rawMsg string) (time.Time, time.Time, } 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里面没有这个数据时间，呢就返回测点的时间 if len(TimeTheme) > 0 { cTime := TimeTheme[0].CollectTime