using Common;
|
using HDLCloudMonitorSupportCtrlOldUdpGate.Context;
|
using System;
|
using System.Net.Sockets;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
|
namespace HDLCloudMonitorSupportCtrlOldUdpGate
|
{
|
public class MockBusproUdpGateway
|
{
|
public static async Task StartUdpClient()
|
{
|
var udpSender = new UdpClient(0);
|
|
udpSender.Connect(Config.UdpServerIP, Config.UdpServerPort);
|
|
//定时发网关心跳
|
new Thread(() =>
|
{
|
while (true)
|
{
|
try
|
{
|
var sendBytes = new byte[56];
|
|
//工程备注
|
byte[] projectBytes = Encoding.ASCII.GetBytes(Config.ProjectName);
|
Array.Copy(projectBytes, 0, sendBytes, 0, projectBytes.Length);
|
|
//群组备注
|
byte[] groupBytes = Encoding.ASCII.GetBytes(Config.GroupName);
|
Array.Copy(groupBytes, 0, sendBytes, 20, groupBytes.Length);
|
|
//远程访问的用户名
|
byte[] userBytes = Encoding.ASCII.GetBytes(Config.UserName);
|
Array.Copy(userBytes, 0, sendBytes, 40, userBytes.Length);
|
|
byte[] macBytes = Encoding.ASCII.GetBytes(Config.Mac); //4141434D41434241 、MacMark: fd3b738d-0a43-4602-83bd-979cefdac13b
|
Array.Copy(macBytes, 0, sendBytes, 48, macBytes.Length);
|
|
var data = new Data { AddData = sendBytes };
|
data.SubnetID = 1;
|
data.DeviceID = 2;
|
data.Command = 0x300B;
|
udpSender.Send(data.SendBytes, data.SendBytes.Length);
|
|
Thread.Sleep(10 * 1000);
|
}
|
catch (Exception ex)
|
{
|
Thread.Sleep(TimeSpan.FromSeconds(1));
|
}
|
}
|
})
|
{
|
IsBackground=true
|
}.Start();
|
|
//接收Udp转发过来的数据
|
new Thread(async () =>
|
{
|
do
|
{
|
try
|
{
|
//等待接收云端响应
|
UdpReceiveResult udpReceiveResult = await udpSender.ReceiveAsync();
|
string receiveData = BinaryHp.ToHexadecimalStr(udpReceiveResult.Buffer, false);
|
|
if (receiveData.Contains("300C") || receiveData.Contains("300c"))
|
{
|
// Console.WriteLine($"心跳响应:{receiveData}");
|
}
|
else if (receiveData.Contains("300F") || receiveData.Contains("300f"))
|
{
|
//验证
|
var sendBytes = new byte[] { 0xF8 };
|
var data = new Data { AddData = sendBytes };
|
data.SubnetID = 1;
|
data.DeviceID = 2;
|
data.Command = 0x3010;
|
udpSender.Send(data.SendBytes, data.SendBytes.Length);
|
}
|
else if (receiveData.Contains("000E") || receiveData.Contains("000e"))
|
{
|
#region 获取网关备注
|
|
var buff = new byte[udpReceiveResult.Buffer.Length - 25 - 2];
|
Array.Copy(udpReceiveResult.Buffer, 25, buff, 0, buff.Length);
|
string reqStr = Encoding.UTF8.GetString(buff);
|
if (reqStr.Length == 36)
|
{
|
GlobalRecordContext.ReceiveResponseTime = DateTime.Now;
|
|
//到达网关用时
|
GlobalRecordContext.CtrlRecordDto.ArrivalsMilliseconds = (GlobalRecordContext.ReceiveResponseTime - GlobalRecordContext.CtrlStartTime).TotalMilliseconds;
|
|
|
Console.WriteLine($" 网关收到:{ GlobalRecordContext.ReceiveResponseTime.ToString(Consts.TimeFormat1)}");
|
//Console.WriteLine("Udp 网关收到时间-开始控制时间值:"+ GlobalRecordContext.CtrlRecordDto.ArrivalsMilliseconds.ToString()+" ms");
|
|
|
//把收到数据原样返回
|
var data = new Data { AddData = buff };
|
data.SubnetID = 1;
|
data.DeviceID = 2;
|
data.Command = 0x000F;
|
udpSender.Send(data.SendBytes, data.SendBytes.Length);
|
}
|
else
|
{
|
// Console.WriteLine($"收到转发的数据(非36):{reqStr}");
|
}
|
#endregion
|
}
|
else
|
{
|
//Console.WriteLine($"其他:{receiveData}");
|
}
|
}
|
catch (Exception ex)
|
{
|
}
|
|
} while (true);
|
})
|
{
|
IsBackground=true
|
}.Start();
|
}
|
}
|
}
|
