301 lines
11 KiB
C#
301 lines
11 KiB
C#
using JiShe.CollectBus.Common.Enums;
|
||
using JiShe.CollectBus.Common.Extensions;
|
||
using JiShe.CollectBus.Common.Extensions.DependencyInjections;
|
||
using JiShe.CollectBus.Common.Models;
|
||
using JiShe.CollectBus.Protocol.Contracts.Abstracts;
|
||
using JiShe.CollectBus.Protocol.Contracts.Attributes;
|
||
using JiShe.CollectBus.Protocol.Contracts.Models;
|
||
using JiShe.CollectBus.RabbitMQ.Senders;
|
||
using Microsoft.Extensions.Logging;
|
||
|
||
namespace JiShe.CollectBus.Protocol
|
||
{
|
||
[ProtocolName("StandardProtocol")]
|
||
public class StandardProtocolPlugin(INSender nSender, ILogger<BaseProtocolPlugin> logger) : BaseProtocolPlugin(logger), ISingletonDependency
|
||
{
|
||
public override async Task<ProtocolInfo> GetAsync()
|
||
{
|
||
var info = new ProtocolInfo("Standard", "376.1", "TCP", "376.1协议", "DTS1980");
|
||
return await Task.FromResult(info);
|
||
}
|
||
public override async Task AnalyzeAsync(MessageReceivedEvent messageReceivedEvent, Action<byte[]>? sendAction = null)
|
||
{
|
||
var cmdResult = AnalysisCmd(messageReceivedEvent.MessageHexString);
|
||
if (cmdResult == null)
|
||
{
|
||
return;
|
||
}
|
||
AnalysisData(cmdResult);
|
||
await Task.CompletedTask;
|
||
}
|
||
|
||
public override async Task LoginAsync(MessageReceivedLoginEvent messageReceivedEvent, Action<byte[]>? sendAction = null)
|
||
{
|
||
async void SendAction(byte[] bytes)
|
||
{
|
||
await nSender.SendToIssuedAsync(new MessageIssuedEvent { ClientId = messageReceivedEvent.ClientId, DeviceNo = messageReceivedEvent.DeviceNo, Message = bytes, Type = IssuedEventType.Login,MessageId = messageReceivedEvent.MessageId});
|
||
}
|
||
|
||
await base.LoginAsync(messageReceivedEvent, SendAction);
|
||
}
|
||
|
||
public override async Task HeartbeatAsync(MessageReceivedHeartbeatEvent messageReceivedEvent, Action<byte[]>? sendAction = null)
|
||
{
|
||
async void SendAction(byte[] bytes)
|
||
{
|
||
await nSender.SendToIssuedAsync(new MessageIssuedEvent { ClientId = messageReceivedEvent.ClientId, DeviceNo = messageReceivedEvent.DeviceNo, Message = bytes, Type = IssuedEventType.Login, MessageId = messageReceivedEvent.MessageId });
|
||
}
|
||
await base.HeartbeatAsync(messageReceivedEvent, SendAction);
|
||
}
|
||
|
||
|
||
|
||
#region 上行命令
|
||
|
||
//68
|
||
//32 00
|
||
//32 00
|
||
//68
|
||
//C9 1100'1001. 控制域C。
|
||
// D7=1, （终端发送）上行方向。
|
||
// D6=1, 此帧来自启动站。
|
||
// D5=0, (上行方向)要求访问位。表示终端无事件数据等待访问。
|
||
// D4=0, 保留
|
||
// D3~D0=9, 功能码。链路测试
|
||
|
||
//20 32 行政区划码
|
||
//90 26 终端地址
|
||
//00 主站地址和组地址标志。终端为单地址。 //3220 09 87 2
|
||
// 终端启动的发送帧的 MSA 应为 0, 其主站响应帧的 MSA 也应为 0.
|
||
//02 应用层功能码。AFN=2, 链路接口检测
|
||
//70 0111'0000. 帧序列域。无时间标签、单帧、需要确认。
|
||
//00 00 信息点。DA1和DA2全为“0”时，表示终端信息点。
|
||
//01 00 信息类。F1, 登录。
|
||
//44 帧尾，包含用户区数据校验和
|
||
//16 帧结束标志
|
||
|
||
/// <summary>
|
||
/// 解析上行命令
|
||
/// </summary>
|
||
/// <param name="cmd"></param>
|
||
/// <returns></returns>
|
||
public CommandReulst? AnalysisCmd(string cmd)
|
||
{
|
||
CommandReulst? commandReulst = null;
|
||
var hexStringList = cmd.StringToPairs();
|
||
|
||
if (hexStringList.Count < hearderLen)
|
||
{
|
||
return commandReulst;
|
||
}
|
||
//验证起始字符
|
||
if (hexStringList[0] != stx || hexStringList[5] != stx)
|
||
{
|
||
return commandReulst;
|
||
}
|
||
|
||
var lenHexStr = $"{hexStringList[2]}{hexStringList[1]}";
|
||
var lenBin = lenHexStr.HexToBin();
|
||
var len = lenBin.Remove(lenBin.Length - 2).BinToDec();
|
||
//验证长度
|
||
if (hexStringList.Count - 2 != hearderLen + len)
|
||
return commandReulst;
|
||
|
||
var userDataIndex = hearderLen;
|
||
var c = hexStringList[userDataIndex];//控制域 1字节
|
||
userDataIndex += 1;
|
||
|
||
var aHexList = hexStringList.Skip(userDataIndex).Take(5).ToList();//地址域 5字节
|
||
var a = AnalysisA(aHexList);
|
||
var a3Bin = aHexList[4].HexToBin().PadLeft(8, '0');
|
||
var mSA = a3Bin.Substring(0, 7).BinToDec();
|
||
userDataIndex += 5;
|
||
|
||
var aFN = (AFN)hexStringList[userDataIndex].HexToDec();//1字节
|
||
userDataIndex += 1;
|
||
|
||
var seq = hexStringList[userDataIndex].HexToBin().PadLeft(8, '0');
|
||
var tpV = (TpV)Convert.ToInt32(seq.Substring(0, 1));
|
||
var fIRFIN = (FIRFIN)Convert.ToInt32(seq.Substring(1, 2));
|
||
var cON = (CON)Convert.ToInt32(seq.Substring(3, 1));
|
||
var prseqBin = seq.Substring(4, 4);
|
||
userDataIndex += 1;
|
||
|
||
// (DA2 - 1) * 8 + DA1 = pn
|
||
var da1Bin = hexStringList[userDataIndex].HexToBin();
|
||
var da1 = da1Bin == "0" ? 0 : da1Bin.Length;
|
||
userDataIndex += 1;
|
||
var da2 = hexStringList[userDataIndex].HexToDec();
|
||
var pn = da2 == 0 ? 0 : (da2 - 1) * 8 + da1;
|
||
userDataIndex += 1;
|
||
//(DT2*8)+DT1=fn
|
||
var dt1Bin = hexStringList[userDataIndex].HexToBin();
|
||
var dt1 = dt1Bin != "0" ? dt1Bin.Length : 0;
|
||
userDataIndex += 1;
|
||
var dt2 = hexStringList[userDataIndex].HexToDec();
|
||
var fn = dt2 * 8 + dt1;
|
||
userDataIndex += 1;
|
||
|
||
//数据单元
|
||
var datas = hexStringList.Skip(userDataIndex).Take(len + hearderLen - userDataIndex).ToList();
|
||
|
||
//EC
|
||
//Tp
|
||
commandReulst = new CommandReulst()
|
||
{
|
||
A = a,
|
||
MSA = mSA,
|
||
AFN = aFN,
|
||
Seq = new Seq()
|
||
{
|
||
TpV = tpV,
|
||
FIRFIN = fIRFIN,
|
||
CON = cON,
|
||
PRSEQ = prseqBin.BinToDec(),
|
||
},
|
||
CmdLength = len,
|
||
Pn = pn,
|
||
Fn = fn,
|
||
HexDatas = datas
|
||
};
|
||
|
||
return commandReulst;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 解析地址
|
||
/// </summary>
|
||
/// <param name="aHexList"></param>
|
||
/// <returns></returns>
|
||
private string AnalysisA(List<string> aHexList)
|
||
{
|
||
var a1 = aHexList[1] + aHexList[0];
|
||
var a2 = aHexList[3] + aHexList[2];
|
||
var a2Dec = a2.HexToDec();
|
||
var a3 = aHexList[4];
|
||
var a = $"{a1}{a2Dec.ToString().PadLeft(5, '0')}";
|
||
return a;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 解析上行命令数据包
|
||
/// </summary>
|
||
/// <param name="commandReulst"></param>
|
||
public void AnalysisData(CommandReulst commandReulst)
|
||
{
|
||
switch (commandReulst.AFN)
|
||
{
|
||
case AFN.确认或否认:
|
||
//commandReulst.fn
|
||
//1:全部确认
|
||
//2:全部否认
|
||
//3:按数据单元表示确认和否认
|
||
//4 硬件安全认证错误应答
|
||
break;
|
||
case AFN.复位:
|
||
break;
|
||
case AFN.链路接口检测:
|
||
AnalysisAFN02(commandReulst);
|
||
break;
|
||
case AFN.中继站命令:
|
||
break;
|
||
case AFN.设置参数:
|
||
break;
|
||
case AFN.控制命令:
|
||
break;
|
||
case AFN.身份认证及密钥协商:
|
||
break;
|
||
case AFN.备用:
|
||
break;
|
||
case AFN.请求被级联终端主动上报:
|
||
break;
|
||
case AFN.请求终端配置:
|
||
break;
|
||
case AFN.查询参数:
|
||
break;
|
||
case AFN.请求任务数据:
|
||
break;
|
||
case AFN.请求实时数据:
|
||
break;
|
||
case AFN.请求历史数据:
|
||
break;
|
||
case AFN.请求事件数据:
|
||
break;
|
||
case AFN.文件传输:
|
||
break;
|
||
case AFN.数据转发:
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
|
||
//终端启动发送帧的MSA应为零，其主站响应帧的MSA也应为零
|
||
public void AnalysisAFN02(CommandReulst commandReulst)
|
||
{
|
||
if (commandReulst.Fn == 1) //登录
|
||
{
|
||
Console.WriteLine($"{commandReulst.A},登录:{DateTime.Now}");
|
||
var reqParam = new ReqParameter2()
|
||
{
|
||
AFN = AFN.确认或否认,
|
||
FunCode = (int)CFromStationFunCode.链路数据,
|
||
PRM = PRM.从动站报文,
|
||
A = commandReulst.A,
|
||
Seq = new Seq()
|
||
{
|
||
TpV = TpV.附加信息域中无时间标签,
|
||
FIRFIN = FIRFIN.单帧,
|
||
CON = CON.需要对该帧进行确认,
|
||
PRSEQ = commandReulst.Seq.PRSEQ,
|
||
},
|
||
MSA = commandReulst.MSA,
|
||
Pn = 0,
|
||
Fn = 1
|
||
};
|
||
commandReulst.ReplyBytes = GetCommandBytes(reqParam);
|
||
}
|
||
else if (commandReulst.Fn == 2)//退出登录
|
||
{
|
||
Console.WriteLine($"{commandReulst.A},退出登录:{DateTime.Now}");
|
||
}
|
||
else if (commandReulst.Fn == 3)//心跳
|
||
{
|
||
Console.WriteLine($"{commandReulst.A},心跳:{DateTime.Now}");
|
||
AnalysisHeartbeat(commandReulst);
|
||
}
|
||
}
|
||
|
||
public void AnalysisHeartbeat(CommandReulst commandReulst)
|
||
{
|
||
if (commandReulst.Seq.TpV == TpV.附加信息域中带时间标签)
|
||
{
|
||
//解析
|
||
|
||
}
|
||
if (commandReulst.Seq.CON == CON.需要对该帧进行确认)
|
||
{
|
||
var reqParam = new ReqParameter2()
|
||
{
|
||
AFN = AFN.确认或否认,
|
||
FunCode = (int)CFromStationFunCode.链路数据,
|
||
PRM = PRM.从动站报文,
|
||
A = commandReulst.A,
|
||
Seq = new Seq()
|
||
{
|
||
TpV = TpV.附加信息域中无时间标签,
|
||
FIRFIN = FIRFIN.单帧,
|
||
CON = CON.不需要对该帧进行确认,
|
||
PRSEQ = commandReulst.Seq.PRSEQ,
|
||
},
|
||
MSA = commandReulst.MSA,
|
||
Pn = 0,
|
||
Fn = 1
|
||
};
|
||
commandReulst.ReplyBytes = GetCommandBytes(reqParam);
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
}
|