组织数据读取权限完成

pkg/rule_engine/message/message.go

@@ -32,17 +32,17 @@ type Message struct {
 	Id       string    //uuid     消息Id
 	Ts       time.Time //时间戳
 	MsgType  string    //消息类型，   attributes（参数），telemetry（遥测），Connect连接事件
-	UserId   string    //客户Id  UUID  设备发布人
+	User     string    //客户  设备发布人 设备所有者
 	Msg      Msg       //数据		数据结构JSON  设备原始数据 msg
 	Metadata Metadata  //消息的元数据		包括设备Id，设备类型，产品ID等
 }
 
 // NewMessage ...
-func NewMessage(userId, messageType string, msg Msg, metadata Metadata) *Message {
+func NewMessage(user, messageType string, msg Msg, metadata Metadata) *Message {
 	return &Message{
 		Id:       uuid.New().String(),
 		Ts:       time.Now(),
-		UserId:   userId,
+		User:     user,
 		MsgType:  messageType,
 		Msg:      msg,
 		Metadata: metadata,

pkg/rule_engine/nodes/action_create_alarm_node.go

@@ -61,6 +61,7 @@ func (n *createAlarmNode) Handle(msg *message.Message) error {
 		alarm.Type = n.AlarmType
 		alarm.Time = time.Now()
 		alarm.OrgId = msg.Metadata.GetValue("orgId").(int64)
+		alarm.Owner = msg.Metadata.GetValue("owner").(string)
 		marshal, _ := json.Marshal(msg.Msg)
 		alarm.Details = string(marshal)
 		err := services.DeviceAlarmModelDao.Insert(*alarm)

pkg/rule_engine/nodes/action_log_node.go

@@ -41,6 +41,7 @@ func (n *logNode) Handle(msg *message.Message) error {
 		MsgType:    msg.MsgType,
 		DeviceId:   msg.Metadata["deviceId"].(string),
 		OrgId:      msg.Metadata["orgId"].(int64),
+		Owner:      msg.Metadata["owner"].(string),
 		DeviceName: msg.Metadata["deviceName"].(string),
 		Ts:         msg.Ts,
 		Content:    logMessage,