diff --git a/consumers/consumerSavoirTheme.go b/consumers/consumerSavoirTheme.go
index 8782bae..f7d6f41 100644
--- a/consumers/consumerSavoirTheme.go
+++ b/consumers/consumerSavoirTheme.go
@@ -144,9 +144,9 @@ func (the *consumerSavoirTheme) judgeOffline() {
 		}
 		log.Printf("查询相关测点数=%d", len(allThemes))
 		for _, theme := range allThemes {
-			offlineMin := now.Sub(theme.CollectTime).Minutes()
+			offlineMin := now.Sub(theme.CreateTime).Minutes()
 			log.Printf("s:%d,f:%d,sensor:%d 离线%f min", gap.StructId, gap.FactorId, theme.Sensor, offlineMin)
-			log.Printf("s:%d,f:%d,sensor:%d 采集时间%s 当前时间%s", gap.StructId, gap.FactorId, theme.Sensor, theme.CollectTime, now)
+			log.Printf("s:%d,f:%d,sensor:%d 采集时间%s 当前时间%s", gap.StructId, gap.FactorId, theme.Sensor, theme.CreateTime, now)
 
 			//拿到当前es最后一条数据和当前数据库的配置之后去查是否产生告警
 			StrValue := "80040003"