From 14801a2e40bc79833c41151a37fe4cb0acbc5c7f Mon Sep 17 00:00:00 2001
From: lixiaojun <1287241240@qq.com>
Date: 星期一, 20 三月 2023 10:32:25 +0800
Subject: [PATCH] Merge branch 'master' of http://47.103.154.90:83/r/IStation/Service.V4.1
---
Mqtt/IStation.DataDockingMqtt4SQI/helper/HandleDataHelper.cs | 31 ++++++++++++++++++++++---------
1 files changed, 22 insertions(+), 9 deletions(-)
diff --git a/Mqtt/IStation.DataDockingMqtt4SQI/helper/HandleDataHelper.cs b/Mqtt/IStation.DataDockingMqtt4SQI/helper/HandleDataHelper.cs
index 18327a2..4b825d8 100644
--- a/Mqtt/IStation.DataDockingMqtt4SQI/helper/HandleDataHelper.cs
+++ b/Mqtt/IStation.DataDockingMqtt4SQI/helper/HandleDataHelper.cs
@@ -13,19 +13,32 @@
internal class HandleDataHelper
{
- public static void Add(IStation.Model.MonitorDataDockingSrcRecord r)
+ public static void Add(IStation.Model.MonitorDataDockingReceiveRecord r)
{
- /*var queue = new RabbitMqQueueHelper();
- queue.Push(鈥渁aa鈥�, new Model.MonitorDataDockingCorpRecord()
+
+ var queue = new RabbitMqQueueHelper();
+ queue.Push("data_docking_queue", new Model.MonitorDataDockingCorpRecord()
{
- CorpID = configure.CorpID,
- ConfigureID = 9999,
- Records = receive_list
- });*/
+ CorpID = 14,
+ ConfigureID = 1628638727683313664,
+ Records = new List<Model.MonitorDataDockingReceiveRecord>() { r }
+ });
+ LogCustomHelper.Info($"寰� data_docking_queue 閫氶亾鎺ㄥ叆涓�鏉℃暟鎹�");
+ LogCustomHelper.Src(JsonHelper.Object2Json(r));
}
-
-
+ public static void Add(List<IStation.Model.MonitorDataDockingReceiveRecord> r)
+ {
+ var queue = new RabbitMqQueueHelper();
+ queue.Push("data_docking_queue", new Model.MonitorDataDockingCorpRecord()
+ {
+ CorpID = 14,
+ ConfigureID = 1628638727683313664,
+ Records = r
+ });
+ LogCustomHelper.Info($"寰� data_docking_queue 閫氶亾鎺ㄥ叆澶氭潯鏁版嵁");
+ LogCustomHelper.Src(JsonHelper.Object2Json(r));
+ }
}
}
--
Gitblit v1.9.3