JiShe.CollectBus/JiShe.CollectBus.Protocol/StandardProtocolPlugin.cs

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
    }
}