using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using IStation.Untity;
|
using IStation.Model;
|
using SuperSocket.Server;
|
using SuperSocket;
|
|
namespace IStation.Server
|
{
|
/// <summary>
|
/// 接收信息辅助类
|
/// </summary>
|
internal class RequestReceivedHelper
|
{
|
//接收数据
|
public static async ValueTask Receive(IAppSession session, PackageInfo packageInfo)
|
{
|
await Task.Run(async () =>
|
{
|
|
if (packageInfo == null)
|
return;
|
switch (packageInfo.Header.Type)
|
{
|
case eDatagramType.心跳接口:
|
{
|
await session.SendAsync(new ReadOnlyMemory<byte>(packageInfo.HeaderBuffer));
|
LogHelper.Info($"{session.RemoteEndPoint}:发送心跳包.");
|
}
|
break;
|
case eDatagramType.波形数据接口:
|
{
|
LogHelper.Info($"{session.RemoteEndPoint}:发送波形数据包.");
|
var model = BodyWave.Get(packageInfo.BodyBuffer);
|
var dt_now = DateTime.Now;
|
if ((dt_now - model.DataTime).TotalHours > 1)
|
{
|
{
|
//对时
|
var timeHeader = new Model.Header();
|
timeHeader.Type = 0;
|
timeHeader.Memo = BitConverter.GetBytes((int)DateTimeTransfer.ToSeconds(dt_now)).Reverse().ToArray();
|
timeHeader.KeyNum = 1;
|
timeHeader.PackLen = 0;
|
var timeBuffer = timeHeader.GetBuffer();
|
await session.SendAsync(new ReadOnlyMemory<byte>(timeBuffer));
|
LogHelper.Info($"{session.RemoteEndPoint}-DataTime:{model.DataTime:yyyy-MM-dd HH:mm:ss},触发对时接口.");
|
}
|
model.SendTime = dt_now;
|
model.DataTime = dt_now;
|
}
|
if (model.Rpm > 0)
|
{
|
LogHelper.Info($"{model.IP}：Rpm:{model.Rpm}");
|
}
|
MemoryQueueHelper<Model.BodyWave>.Push(model);
|
}
|
break;
|
case eDatagramType.对时接口:
|
{
|
|
}
|
break;
|
case eDatagramType.启停车数据接口:
|
{
|
LogHelper.Info($"{session.RemoteEndPoint}:发送启停车数据.");
|
var model = StartStop.Get(packageInfo.BodyBuffer);
|
LogHelper.Info($"{session.RemoteEndPoint}-{JsonHelper.Object2Json(model)}");
|
}
|
break;
|
default: break;
|
}
|
|
});
|
}
|
}
|
}
|
