using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using IStation.Model;
|
using IStation.Untity;
|
|
namespace IStation.DataDockingSocket.MsgHandle
|
{
|
public class HandleHelper : IDataDockingSocket.IHandleHelper
|
{
|
|
|
|
/// <summary>
|
/// 处理注册码
|
/// </summary>
|
public void HandleRegisterCode(IMonitorDataDockingSession session)
|
{
|
if (session == null)
|
return;
|
if (!session.IsConnected)
|
return;
|
|
if (SessionHelper.Cache != null)
|
{
|
if (SessionHelper.Cache != session)
|
{
|
if (SessionHelper.Cache.IsConnected)
|
{
|
SessionHelper.Cache.Close($"{session.SessionName} 中，产生新的会话！");
|
}
|
}
|
}
|
|
SessionHelper.Cache = session;
|
|
|
foreach (var item in MonitorMsgHelper.GetInstructionQuerys())
|
{
|
SendInstructionJobHelper.StartJob(session, item);
|
if (item.SpaceTime >= 1)
|
Thread.Sleep(item.SpaceTime * 1000);
|
}
|
|
SendControlJobHelper.StartJob(session);
|
}
|
|
/// <summary>
|
/// 处理心跳包
|
/// </summary>
|
public void HandleHeartbeat(IMonitorDataDockingSession session)
|
{
|
|
}
|
|
/// <summary>
|
/// 处理数据
|
/// </summary>
|
public void HandleData
|
(
|
IMonitorDataDockingSession session,
|
byte[] byteMessage,
|
List<DataDockingConfigure.Mapper> mappers,
|
Action<List<MonitorDataDockingReceiveRecord>> onReceive
|
)
|
{
|
if (session == null)
|
return;
|
if (!session.IsConnected)
|
return;
|
if (byteMessage == null || byteMessage.Length < 4)
|
{
|
return;
|
}
|
|
if (MonitorMsgHelper.IsCurrentMsg(byteMessage))
|
{
|
var receList = MonitorMsgHelper.HandleReceive(byteMessage);
|
if (receList == null || receList.Count == 0)
|
return;
|
|
NtLogHelper.Src(byteMessage);
|
|
// NtLogHelper.Debug(src_list);
|
//NtLogHelper.Info($"解析数据数量:{receList.Count}\n\r" +
|
// $"{JsonHelper.Object2Json(receList)}");
|
|
|
onReceive(receList);
|
|
return;//成功就返回掉
|
}
|
//不要加else
|
if (ShunDownMsgHelper.InstructionStatus == eShutDownInstructionStatus.关机机指令发送)
|
{
|
ShunDownMsgHelper.HandleReceive(session,byteMessage);
|
}
|
//不要加else
|
if (StartUpMsgHelper.IsCurrentMsg(byteMessage))
|
{
|
|
}
|
|
}
|
|
}
|
|
|
}
|
