From 21ce45d81800e141a88ff4a7fe57ec6eeaec318d Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Tue, 22 Jul 2025 15:15:12 +0800
Subject: [PATCH] =?UTF-8?q?hms=E6=B7=BB=E5=8A=A0=E8=AE=BE=E5=A4=87sn?=
 =?UTF-8?q?=E5=8C=BA=E5=88=86=E8=AE=BE=E5=A4=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.WebApi/Model/mqtt/HmsAlarmParser.cs    | 6 ++++--
 OpenAuth.WebApi/Model/mqtt/ThingEventHandler.cs | 4 ++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/OpenAuth.WebApi/Model/mqtt/HmsAlarmParser.cs b/OpenAuth.WebApi/Model/mqtt/HmsAlarmParser.cs
index 377278b..f609ebd 100644
--- a/OpenAuth.WebApi/Model/mqtt/HmsAlarmParser.cs
+++ b/OpenAuth.WebApi/Model/mqtt/HmsAlarmParser.cs
@@ -6,11 +6,12 @@ namespace OpenAuth.WebApi.Model.mqtt
     public class HmsAlarmParser
     {
         private readonly JsonObject _hmsMessages;
-
-        public HmsAlarmParser(string hmsJsonPath)
+        private readonly string _getway;
+        public HmsAlarmParser(string hmsJsonPath, string getway)
         {
             string json = File.ReadAllText(hmsJsonPath);
             _hmsMessages = JsonNode.Parse(json)?.AsObject() ?? throw new Exception("hms.json 格式错误");
+            _getway = getway;
         }
 
         public List<LasaManageDeviceHms> ParseAlarmMessages(string rawJson)
@@ -72,6 +73,7 @@ namespace OpenAuth.WebApi.Model.mqtt
                     BId = bid,
                     TId = tid,
                     Level = level,
+                    Sn = _getway,
                     Module = module,
                     CreateTime = DateTime.Now,
                     MessageEn = en,
diff --git a/OpenAuth.WebApi/Model/mqtt/ThingEventHandler.cs b/OpenAuth.WebApi/Model/mqtt/ThingEventHandler.cs
index 0c52729..332d014 100644
--- a/OpenAuth.WebApi/Model/mqtt/ThingEventHandler.cs
+++ b/OpenAuth.WebApi/Model/mqtt/ThingEventHandler.cs
@@ -36,8 +36,8 @@ namespace OpenAuth.WebApi.Model.mqtt
                 var jsondata = JsonSerializer.Deserialize<HmsMessage>(payload);
 
                 var path = Path.Combine(AppContext.BaseDirectory, "hms.json");
-                var parser = new HmsAlarmParser(path);
-
+                string getway = topic.Split('/')[2];
+                var parser = new HmsAlarmParser(path, getway);
                 List<LasaManageDeviceHms> alarmMessages = null;
                 if (jsondata.data != null && jsondata.data.list?.Count > 0)
                 {