using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using IStation.Untity;
|
|
namespace IStation.DataDockingMqtt
|
{
|
/// <summary>
|
/// 处理数据辅助类
|
/// </summary>
|
internal class HandleDataHelper
|
{
|
|
public static void Add(IStation.Model.MonitorDataDockingReceiveRecord r)
|
{
|
|
var queue = new RabbitMqQueueHelper();
|
queue.Push("data_docking_queue", new Model.MonitorDataDockingCorpRecord()
|
{
|
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));
|
}
|
|
}
|
}
|
