|
|
@ -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" |
|
|
|