【feature】添加组织数据读取权限

pkg/rule_engine/nodes/action_create_alarm_node.go

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

pkg/rule_engine/nodes/action_log_node.go

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