|
using Common;
|
using Common.MqttNets;
|
using HDLCloudMonitorSupportCtrlOldUdpGate.Logs;
|
using HDLCloudMonitorSupportCtrlOldUdpGate.Context;
|
using System;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using static System.Net.Mime.MediaTypeNames;
|
|
namespace HDLCloudMonitorSupportCtrlOldUdpGate
|
{
|
public class MockEmqCtrlBusproUdpGateway
|
{
|
private static int CtrlTimerCount = 10;
|
|
public static async Task StartCtrlBusproUdpGateway()
|
{
|
var option = new MqttClientEngineOption
|
{
|
ClientId = Config.ClientId,
|
MqttDomainOrIp = Config.MqttDomainOrIp,
|
MqttPort = 1883,
|
UserName = Config.ConnUsername,
|
Password = Config.ConnPassword,
|
};
|
option.SubscribeList.Add(new SubscribeTopicInfo { Topic = $"/BusGateWayToClient/{Config.MacMark}/Common/#" });
|
|
option.UseApplicationMessageReceivedHandler += async (mqttMessage) =>
|
{
|
await Task.Run(async () =>
|
{
|
try
|
{
|
var resStr = Encoding.UTF8.GetString(mqttMessage.ApplicationMessage.Payload);
|
if (resStr.Contains(GlobalRecordContext.RequestGuid))
|
{
|
DateTime tim = DateTime.Now;
|
GlobalRecordContext.CtrlRecordDto.ComebackMilliseconds= (tim - GlobalRecordContext.ReceiveResponseTime).TotalMilliseconds;
|
|
// Console.WriteLine("控制端-Udp网关接收时间:" + GlobalRecordContext.CtrlRecordDto.ComebackMilliseconds+" ms");
|
|
Console.WriteLine($"控制端收到:{ tim.ToString(Consts.TimeFormat1)}");
|
|
// Console.WriteLine(GlobalRecordContext.CtrlRecordDto);
|
|
MqttLogHp.Save();
|
|
GlobalRecordContext.ResetCtrlRecordDto();
|
}
|
else
|
{
|
//Console.WriteLine($"其他:Topic={ mqttMessage.ApplicationMessage.Topic }");
|
}
|
}
|
catch (Exception ex)
|
{
|
}
|
});
|
};
|
|
await MqttClientEngine.ServerMqttEngine(option);
|
bool isMenu = true;
|
while (true)
|
{
|
try
|
{
|
if (isMenu)
|
{
|
OutputMenu();
|
}
|
String input = Console.ReadLine().ToLower();
|
Console.WriteLine(input);
|
|
switch (input)
|
{
|
case "c":
|
{
|
isMenu = true;
|
Console.Clear();
|
}; break;
|
case "a":
|
{
|
isMenu = true;
|
while (true)
|
{
|
Console.WriteLine();
|
await FactoryCtrl();
|
Thread.Sleep(TimeSpan.FromSeconds(3));
|
}
|
}; break;
|
default:
|
{
|
await FactoryCtrl();
|
isMenu = false;
|
}; break;
|
}
|
}
|
catch
|
{
|
Thread.Sleep(TimeSpan.FromSeconds(1));
|
}
|
}
|
}
|
|
private static void OutputMenu()
|
{
|
Console.WriteLine("----------------------------------------");
|
Console.WriteLine("[ c:清屏 ]");
|
Console.WriteLine("[ enter:执行一次控制 ]");
|
Console.WriteLine("[ a:自动控制(间隔3s) ]");
|
Console.WriteLine("----------------------------------------");
|
Console.WriteLine("请输入命令:");
|
}
|
|
private static async Task FactoryCtrl()
|
{
|
GlobalRecordContext.RequestGuid = Guid.NewGuid().ToString();
|
GlobalRecordContext.CtrlStartTime = DateTime.Now;
|
|
#region 控制端连接服务器获取一端口的信息
|
|
var data = new Data();
|
data.SubnetID = 0xFB;
|
data.DeviceID = 0xFB;
|
data.Command = 0x000E;
|
data.AddData = Encoding.UTF8.GetBytes(GlobalRecordContext.RequestGuid);
|
|
|
Console.WriteLine($" 开始控制:{GlobalRecordContext.CtrlStartTime.ToString(Consts.TimeFormat1)}");
|
string pubTopic = $"/ClientToBusGateWay/{Config.MacMark}/Common/MonitorFilterProcessor";
|
await MqttClientEngine.PublishTopic(pubTopic, null, data.SendBytes);
|
|
#endregion
|
}
|
}
|
}
|
