|
|
|
@ -428,6 +428,7 @@ func (the *consumerZWYHBJCAS) getAlarmInfo(am models.AlarmMsg) []interface{} { |
|
|
|
station := models.Station{} |
|
|
|
k1 := fmt.Sprintf("station:%s", sourceId) |
|
|
|
adaptor := the.getAdaptor() |
|
|
|
adaptor.StructInfo = the.Info.StructInfo |
|
|
|
errRedis := adaptor.Redis.GetObj(k1, &station) |
|
|
|
if errRedis != nil { |
|
|
|
log.Printf("redis 获取[s:%d]测点[%s]标签异常", structureId, sourceId) |
|
|
|
|