liuxiulin 2 天之前
父节点
当前提交
867901c55d
共有 1 个文件被更改,包括 2 次插入2 次删除
  1. 2 2
      pkg/ruleEngine/nodes/temp_alarm_node.go

+ 2 - 2
pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -105,12 +105,12 @@ func (t *TempAlarmNode) newAlarmMessage(message *protocol.Message) error {
 		if result == nil {
 		if result == nil {
 			return nil
 			return nil
 		}
 		}
-		j := gjson.New(result)
+		j := gjson.New(result.Body)
 		fmt.Printf("查询用户信息------------------:%s\r\n", j.MustToJsonString())
 		fmt.Printf("查询用户信息------------------:%s\r\n", j.MustToJsonString())
 		dataMap = j.GetMap("data")
 		dataMap = j.GetMap("data")
 		fmt.Printf("dataMap------------------:%v\r\n", dataMap)
 		fmt.Printf("dataMap------------------:%v\r\n", dataMap)
 	} else {
 	} else {
-		j := gjson.New(message.MetaData)
+		j := gjson.New(message.Data)
 		dataMap = j.GetMap("status")
 		dataMap = j.GetMap("status")
 	}
 	}