using IStation.Model;
|
using IStation.Untity;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using static System.Collections.Specialized.BitVector32;
|
|
namespace IStation.DataDockingSocket
|
{
|
internal class StartUpMsgHelper
|
{
|
public static eStartUpInstructionStatus InstructionStatus = eStartUpInstructionStatus.未发送;
|
public static DateTime _lastHzSendTime;
|
public static DateTime _lastOpenSendTime;
|
public static MonitorTestControlParas.StartContext _lastParas = null;
|
|
/// <summary>
|
/// 开机
|
/// </summary>
|
/// <param name="session"></param>
|
/// <returns></returns>
|
public static bool StartJob(Model.IMonitorDataDockingSession session, MonitorTestControlParas.StartContext paras)
|
{
|
if (session == null)
|
{
|
NtLogHelper.Error($"开机 session:Close");
|
return false;
|
}
|
if(paras == null)
|
{
|
NtLogHelper.Error($"开机参数为空");
|
return false;
|
}
|
|
if (!session.IsConnected)
|
{
|
NtLogHelper.Error($"开机时 session:Not connected");
|
return false;
|
}
|
if (paras.HZ <= 10)
|
{
|
NtLogHelper.Error($"开机时 设置的调频频率过低!");
|
return false;
|
}
|
_lastParas = paras;
|
|
//switch (context.OperatingMode)
|
//{
|
// case Model.MonitorTestControlParas.eOperatingMode.Timing:
|
// break;
|
// case Model.MonitorTestControlParas.eOperatingMode.ConstantFlow:
|
// break;
|
// default:
|
// break;
|
//}
|
|
byte[] bts = GetControlMsg调频(paras.HZ);
|
|
|
session.Send(bts, 0, bts.Length);
|
InstructionStatus = eStartUpInstructionStatus.调频指令发送;
|
_lastHzSendTime = DateTime.Now;
|
|
NtLogHelper.Info("开机指令: 调频 " + BitTransfer.ToString(bts) + ", HZ:"+ paras.HZ);
|
|
return true;
|
}
|
|
/// <summary>
|
/// 是否需要当前类进行处理
|
/// </summary>
|
/// <param name="byteMessage"></param>
|
/// <returns></returns>
|
public static bool IsNeedHandle(byte[] byteMessage)
|
{
|
if(InstructionStatus != eStartUpInstructionStatus.未发送)
|
return true;
|
else
|
return false;
|
}
|
/// <summary>
|
/// 开机指令
|
/// </summary>
|
static string ControlMsgOpen = "01-06-00-0F-00-01-78-09";
|
/// <summary>
|
/// 读取返回消息 处理成功返回成功, 不成功或者不需要处理返回false
|
/// </summary>
|
/// <param name="byteMessage"></param>
|
public static bool HandleReceive(Model.IMonitorDataDockingSession session, byte[] byteMessage)
|
{
|
if (InstructionStatus == eStartUpInstructionStatus.未发送)
|
{
|
NtLogHelper.Info("InstructionStatus==eStartUpInstructionStatus.未发送");
|
return false;
|
}
|
if (InstructionStatus == eStartUpInstructionStatus.开机指令发送)
|
{
|
NtLogHelper.Info("InstructionStatus==eStartUpInstructionStatus.开机指令发送");
|
var byteMsgOpen = Encoding.Unicode.GetBytes(ControlMsgOpen);
|
//if (byteMessage.Length >= byteMsgOpen.Length)
|
//{
|
string strMessage = BitConverter.ToString(byteMessage, 0, byteMessage.Length);
|
if (strMessage == ControlMsgOpen)
|
{
|
NtLogHelper.Info($"strMessage ({strMessage})== ControlMsgOpen ({ControlMsgOpen})");
|
//01-06-00-0F-00-01-78-09
|
InstructionStatus = eStartUpInstructionStatus.未发送;
|
|
NtLogHelper.Info("开机指令返回:" + BitTransfer.ToString(byteMessage));
|
if (_lastParas.OperatingValue > 0)
|
{
|
//开启自动关闭
|
ShutDownMsgHelper.StartAutoClose(_lastParas.OperatingValue);
|
}
|
else
|
{
|
NtLogHelper.Info("时间小于等于0,不开启自动关闭");
|
}
|
return true;
|
}
|
else
|
{
|
NtLogHelper.Info($"strMessage ({strMessage})!= ControlMsgOpen ({ControlMsgOpen})");
|
}
|
//}
|
//else
|
//{
|
// NtLogHelper.Info($"byteMessage.Length ({byteMessage.Length}) <= ControlMsgOpen.Length ({ControlMsgOpen.Length})");
|
//}
|
|
//返回失败, 再发送一次再确认一下
|
if ((DateTime.Now - _lastOpenSendTime).TotalSeconds > 5)
|
{
|
NtLogHelper.Info($"返回失败, 再发送一次再确认一下");
|
SendOpenMsg(session);
|
}
|
}
|
|
if (InstructionStatus == eStartUpInstructionStatus.调频指令发送)
|
{
|
NtLogHelper.Info($"InstructionStatus == eStartUpInstructionStatus.调频指令发送");
|
//需要判断是否是调频指令:以后再补充
|
{
|
SendOpenMsg(session);
|
}
|
|
|
//返回失败, 再发送一次再确认一下
|
if ((DateTime.Now - _lastHzSendTime).TotalSeconds > 5)
|
{
|
NtLogHelper.Info($"返回失败, 再发送一次再确认一下");
|
StartJob(session, _lastParas);
|
}
|
}
|
|
return false;
|
}
|
|
private static void SendOpenMsg(Model.IMonitorDataDockingSession session)
|
{
|
byte[] bts = GetControlMsg开机();
|
|
session.Send(bts, 0, bts.Length);
|
InstructionStatus = eStartUpInstructionStatus.开机指令发送;
|
_lastOpenSendTime = DateTime.Now;
|
|
NtLogHelper.Info("开机指令: 开机 " + BitTransfer.ToString(bts) + ", ");
|
}
|
|
|
/// <summary>
|
/// 获取控制指令(开机)
|
/// </summary>
|
/// <returns></returns>
|
public static byte[] GetControlMsg开机()
|
{
|
//var appParas = AppParasHelper.GetInstance();
|
//if (appParas == null || appParas.InstructionStartUp == null || appParas.InstructionStartUp.Content == null)
|
{
|
return BitTransfer.FromString(ControlMsgOpen);
|
}
|
//return BitTransfer.FromString(appParas.InstructionStartUp.Content);
|
}
|
|
/// <summary>
|
/// 获取控制指令(调频)
|
/// </summary>
|
/// <returns></returns>
|
public static byte[] GetControlMsg调频(double frequece)
|
{
|
var iFrequece = (int)(frequece * 10);
|
|
byte[] commandSend = null;
|
|
ModBusRtuHelper.BuildSendMessage06(0x01, 20, 2,
|
iFrequece, ref commandSend);
|
|
return commandSend;
|
}
|
|
|
|
|
|
}
|
}
|
