From 6f8e36ae1d6c41560b2d7692f12c9371a9ccdcf2 Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期二, 27 六月 2023 09:34:51 +0800
Subject: [PATCH] mqqt 代码修改
---
Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs b/Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs
index 449d37e..9710549 100644
--- a/Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs
+++ b/Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs
@@ -86,7 +86,7 @@
if (e.ApplicationMessage == null)
return;
Console.WriteLine(">>> 鏀跺埌娑堟伅:" + e.ApplicationMessage.ConvertPayloadToString() + ",鏉ヨ嚜瀹㈡埛绔�" + e.ClientId + ",涓婚:" + e.ApplicationMessage.Topic);
-
+
var data = JsonHelper.Json2Object<Mqtt1Msg>(e.ApplicationMessage.ConvertPayloadToString());
if (data != null && data.sensor != null && data.sensor.data != null && data.sensor.data.value != null
&& data.sensor.data.value.Count > 0)
@@ -133,12 +133,12 @@
r.SysId = 1620682379477782528;
HandleDataHelper.Add(r);
}
- /*if (id== "")
+ if (id == "23020001")
{
//杩涘彛鍘嬪姏
r.SysId = 1620681990539972608;
- HandleDataHelper.Add(r);
- }*/
+ HandleDataHelper.Add(r);
+ }
}
}
}
--
Gitblit v1.9.3