| | |
|---|
| | | 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(“aaa”, 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)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
