diff --git a/consumers/consumerZWYHBJCAS.go b/consumers/consumerZWYHBJCAS.go
index a513157..2938822 100644
--- a/consumers/consumerZWYHBJCAS.go
+++ b/consumers/consumerZWYHBJCAS.go
@@ -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)