From 26db66e5e4c4ed230e01293abe23f8ed526a3d78 Mon Sep 17 00:00:00 2001 From: 18209 Date: Tue, 21 Oct 2025 10:28:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=97=B6=E9=97=B4=E6=A0=BC?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerAXYThemeToES.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/consumers/consumerAXYThemeToES.go b/consumers/consumerAXYThemeToES.go index dca3deb..06296ba 100644 --- a/consumers/consumerAXYThemeToES.go +++ b/consumers/consumerAXYThemeToES.go @@ -146,11 +146,11 @@ func (the *consumerAXYThemeToES) onData(topic string, msg string) bool { judgeBool := false - esAtime1, esErr := time.Parse("2006-01-02T15:04:05.000+0800", esTimeStr) - esAtime := esAtime1.Add(8 * time.Hour) + esAtime1, esErr := time.Parse("2006-01-02T15:04:05.000Z", esTimeStr) if esErr != nil { log.Printf("安心云 esAtime数据时间 %s 解析错误: %v", esTimeStr, esErr) } + esAtime := esAtime1.Add(8 * time.Hour) // 转为北京时间 newAtime, newErr := time.Parse("2006-01-02T15:04:05.000+0800", newTimeStr) if newErr != nil { @@ -189,8 +189,8 @@ func (the *consumerAXYThemeToES) judgeTime(rawMsg string) (string, string) { log.Printf("反序列化 异常 dev数据=%s", rawMsg) } - queryStr := the.getESTimeQueryStr(theme.Station.Id, theme.Station.Id) - TimeTheme, err := the.OutEs.SearchThemeData("savoir_last_theme", queryStr) + queryStr := the.getESTimeQueryStr(theme.Station.Structure.Id, theme.Station.Id) + TimeTheme, err := the.OutEs.SearchThemeData("anxincloud_last_theme", queryStr) log.Printf("判断 esTimeStr:%s,newTimeStr:%s", TimeTheme[0].CollectTime, theme.AcqTime) return TimeTheme[0].CollectTime, theme.AcqTime }