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