using JiShe.CollectBus.Common;
using JiShe.CollectBus.Protocol.Contracts.Abstracts;
using JiShe.CollectBus.Protocol.Contracts.Attributes;
using JiShe.CollectBus.Protocol.Contracts.DependencyInjection;
using JiShe.CollectBus.Protocol.Contracts.Models;
using Microsoft.Extensions.Caching.Distributed;
using System.Data;
using TouchSocket.Sockets;
namespace JiShe.CollectBus.Protocol
{
[ProtocolName("StandardProtocol")]
public class StandardProtocolPlugin(IDistributedCache cache) : BaseProtocolPlugin(cache), ISingletonDependency
{
//起始字符
private const string stx = "68";
//结束字符
private const string end = "16";
//头部字节长度
private const int hearderLen = 6;
//消息认证码字段长度
private const int pWLen = 16;
private const int tPLen = 6;
public override ProtocolInfo Get()
{
return new ProtocolInfo("Standard", "376.1", "TCP","376.1协议","DTS1980");
}
public new void Load()
{
base.Load();
}
public override void Received(ReceivedDataEventArgs e)
{
var messageHexString = Convert.ToHexString(e.ByteBlock.Span);
var cmdResult = AnalysisCmd(messageHexString);
if (cmdResult == null)
{
return;
}
AnalysisData(cmdResult);
}
public override void Send()
{
throw new NotImplementedException();
}
#region 下行命令
///
/// 设置电表档案
///
///
///
public void GetAFN04F10DataUnit(ReqParameter reqParameter, List meterParameters)
{
var dataUnit = GetAFN04F10DataUnit(meterParameters);
var bytes = GetCommandBytes(reqParameter, dataUnit);
}
///
/// 查询电表档案
///
///
/// 对象序号
public void GetAFN10F10DataUnit(ReqParameter reqParameter, List meterNumberList)
{
var dataUnit = new List();
var countHex = DataConvert.DecToHex(meterNumberList.Count()).PadLeft(4, '0');
var countHexPairs = DataConvert.StringToPairs(countHex);
countHexPairs.Reverse();
dataUnit.AddRange(countHexPairs);
foreach (var number in meterNumberList)
{
var numberHex = DataConvert.DecToHex(number).PadLeft(4, '0');
var numberHexPairs = DataConvert.StringToPairs(numberHex);
numberHexPairs.Reverse();
dataUnit.AddRange(numberHexPairs);
}
var bytes = GetCommandBytes(reqParameter, dataUnit);
}
///
/// 组装电表阀控
///
/// 电表地址
/// 特殊控制码
/// 密码
/// 是否为开阀
///
public List AmmeterValveControl(string address, string specialnocode, string password, bool state, string modelCode = "")
{
address = address.Trim().TrimStart('0');
if (address.Length < 12) address = address.PadLeft(12, '0');
string Code = string.Empty;
if (state)
{
if (string.IsNullOrEmpty(specialnocode))
Code = "1B";
else
Code = specialnocode == "1B" || specialnocode == "1C" ? specialnocode : "1C";
}
else
Code = "1A";//跳闸
if (specialnocode == "1W")
{
if (state)
Code = "1A";
else
Code = "1C";
}
var pwdLevel = "02";
if (modelCode == "HL_DTSU2625" || modelCode == "DDZY9866")
pwdLevel = "04";
else if (modelCode == "DDS2705")
pwdLevel = "03";
if (!string.IsNullOrWhiteSpace(password) && password.Contains("|"))
{
var sp = password.Split('|');
pwdLevel = sp[1];
password = sp[0];
}
string strDate = DataConvert.StrAddSpan(DateTime.Now.AddYears(3).ToString("000012ddMMyy"));
if (specialnocode == "1D" || modelCode == "SZBD_DDZY1225")
strDate = "FF FF FF FF FF FF";
string strP = DataConvert.StrReverseOrder(DataConvert.StrAddSpan(password));
string strSJY = " " + pwdLevel + " " + strP + " 01 00 00 00 " + Code + " 00 " + strDate;
string strLen = (strSJY.Replace(" ", "").Length / 2).ToString("X2");
string strReturn = "68 " + DataConvert.StrReverseOrder(DataConvert.StrAddSpan(address)) + " 68 1C " + strLen + " " + DataConvert.StrAddHex33(strSJY) + " ";
string strSum = strReturn.Split(new string[] { " " }, StringSplitOptions.RemoveEmptyEntries).Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X");
strReturn += strSum.Substring(strSum.Length - 2) + " 16";
return strReturn.Split(' ').ToList();
}
///
/// 帧命令组装
///
/// 请求参数
/// 数据单元
///
public byte[] GetCommandBytes(ReqParameter reqParameter, List? dataUnit = null)
{
var cmdStrList = new List();
var userDatas = GetUserData(reqParameter, dataUnit);
var hearders = GetHeaders(userDatas.Count);
var cs = GetCS(userDatas);
cmdStrList.AddRange(hearders);
cmdStrList.AddRange(userDatas);
cmdStrList.Add(cs);
cmdStrList.Add(end);
Console.WriteLine(string.Join(" ", cmdStrList));
var bytes = cmdStrList.Select(x => Convert.ToByte(x, 16)).ToArray();
return bytes;
}
///
/// 固定长度的报文头 起始字符+长度+长度+起始字符
///
///
///
private List GetHeaders(int length)
{
var headers = new List();
headers.Add(stx);
var l = GetLength(length);
headers.AddRange(l);
headers.AddRange(l);
headers.Add(stx);
return headers;
}
///
/// 用户数据区
///
///
///
public List GetUserData(ReqParameter reqParameter, List? dataUnit)
{
var c = GetC(reqParameter.CMasterStationFunCode, reqParameter.PRM);
var a = GetAList(reqParameter.A, reqParameter.MSA);
var linkUserData = GetLinkUserData(reqParameter.AFN, reqParameter.Seq,
((ReqParameter2)reqParameter).Pn, ((ReqParameter2)reqParameter).Fn, dataUnit);
var list = new List() { c };
list.AddRange(a);
list.AddRange(linkUserData);
return list;
}
///
/// 长度 2字节 [用户数据区长度]
///
///
private List GetLength(int length1)
{
var binaryLen = DataConvert.DecToBin(length1);
var protocolIdentification = Enum.Format(typeof(ProtocolIdentification),
ProtocolIdentification.本规约使用, "d").PadLeft(2, '0');
var lenStr = $"{binaryLen}{protocolIdentification}";
var hexLen = DataConvert.BinToHex(lenStr);
hexLen = hexLen.PadLeft(4, '0');
var list = DataConvert.StringToPairs(hexLen);
list.Reverse();
return list;
}
///
/// 控制域
///
///
///
///
///
private string GetC(CMasterStationFunCode cMasterStationFunCode, PRM pRM, int fcb = 0, FCV fcv = FCV.FCB位无效)
{
var cMasterStationFunCodeHex = DataConvert.DecToBin((int)cMasterStationFunCode);
cMasterStationFunCodeHex = cMasterStationFunCodeHex.ToString().PadLeft(4, '0');
var strC = $"{(int)DIR.主站下行报文}{(int)pRM}{fcb}{(int)fcv}{cMasterStationFunCodeHex}";
var hexC = DataConvert.BinToHex(strC).PadLeft(2, '0');
return hexC;
}
///
/// 地址域 3220 09872
///
/// 行政区划码 BCD码 3220=2032
/// 逻辑地址 BIN 09872=2690=>9026
/// 主站地址 BIN 0~127
///
private List GetAList(string a, int mSA)
{
var list = new List();
var a1 = a.Substring(0, 4);
var a1Pairs = DataConvert.StringToPairs(a1);
a1Pairs.Reverse();
list.AddRange(a1Pairs);
var a2 = Convert.ToInt32(a.Substring(4));
var decA2 = DataConvert.DecToHex(a2);
var a2Pairs = DataConvert.StringToPairs(decA2.PadLeft(4, '0'));
a2Pairs.Reverse();
list.AddRange(a2Pairs);
//TODO:主站地址和组地址标志
var a3Bin = $"{DataConvert.DecToBin(mSA).PadLeft(7, '0')}0";
list.Add(DataConvert.BinToHex(a3Bin));
return list;
}
#region 链路用户数据
private List GetLinkUserData(AFN aFN, Seq seq, int pn, int fn, List? dataUnit)
{
var aFNValue = DataConvert.DecToHex((int)aFN).PadLeft(2, '0');
var sEQ = GetSEQ(seq.TpV, seq.FIRFIN, seq.CON, seq.PRSEQ);
var dA = GetDA(pn);
var dT = GetDT(fn);
var list = new List() { aFNValue, sEQ };
list.AddRange(dA);
list.AddRange(dT);
if (dataUnit != null)
{
list.AddRange(dataUnit);
}
//list.AddRange(GetDataUnit(aFN,seq));
if (seq.TpV == TpV.附加信息域中带时间标签)
list.AddRange(GetTp("00"));
return list;
}
///
/// 帧序列域
///
///
///
///
///
private string GetSEQ(TpV tpV, FIRFIN fIRFIN, CON cON, int pRSEQ)
{
var tpVValue = Enum.Format(typeof(TpV),
tpV, "d");
var fIRFINValue = Enum.Format(typeof(FIRFIN),
fIRFIN, "d");
var cONValue = (int)cON;
var sEQBin = $"{tpVValue}{fIRFINValue}{cONValue}{DataConvert.DecToBin(pRSEQ).PadLeft(4, '0')}";
var hexSEQ = DataConvert.BinToHex(sEQBin).PadLeft(2, '0');
return hexSEQ;
}
///
/// 信息点标识
///
/// 计量点
///
private List GetDA(int pn)
{
if (pn == 0)
return new List() { "00", "00" };
var dA2 = (pn - 1) / 8 + 1;//信息点组从1开始 第几组
var dA1 = pn - (dA2 - 1) * 8;//pn % 8
var dA1Hex = DataConvert.BinToHex("1".PadRight(dA1, '0'));//对位信息 第几位 二进制有效位
var dA2Hex = DataConvert.DecToHex(dA2);
return new List() { dA1Hex.PadLeft(2, '0'), dA2Hex.PadLeft(2, '0') };
}
///
/// 数据单元标识
///
///
///
private List GetDT(int fn)
{
var dT2 = (fn - 1) / 8;//从零开始 第几组
var dT1 = fn - dT2 * 8;
var dT1Hex = DataConvert.BinToHex("1".PadRight(dT1, '0'));//对位信息 第几位 二进制有效位
var dT2Hex = DataConvert.DecToHex(dT2);
return new List() { dT1Hex.PadLeft(2, '0'), dT2Hex.PadLeft(2, '0') };
}
private List GetDataUnit(AFN aFN, Seq seq)
{
var datas = new List();
switch (aFN)
{
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;
case AFN.请求事件数据:
break;
case AFN.文件传输:
break;
case AFN.数据转发:
break;
default:
break;
}
if (seq.TpV == TpV.附加信息域中带时间标签)
datas.AddRange(GetTp("00"));
return datas;
}
private void GetAFN00DataUnit(Seq seq)
{
//EC+Tp
}
///
/// 终端电能表配置参数
///
///
///
public List GetAFN04F10DataUnit(List meterParameters)
{
var hexDatas = new List();
var countHex = DataConvert.DecToHex(meterParameters.Count()).PadLeft(4, '0');
hexDatas.Add(countHex);
//TODO 优化代码:目标数据入参,返回类型为出参
for (int i = 0; i <= meterParameters.Count - 1; i++)
{
var meter = meterParameters[i];
var indexHex = DataConvert.DecToHex(i + 1).PadLeft(4, '0');
hexDatas.Add(indexHex);
var pnHex = DataConvert.DecToHex(meter.Pn).PadLeft(4, '0');
hexDatas.Add(pnHex);
var baudRateBin = DataConvert.DecToBin(meter.BaudRate).PadLeft(3, '0');
var portBin = DataConvert.DecToBin(meter.Port).PadLeft(5, '0');
var baudRateAndPortHex = DataConvert.BinToHex($"{baudRateBin}{portBin}").PadLeft(2, '0');
hexDatas.Add(baudRateAndPortHex);
var protocolTypeHex = DataConvert.DecToHex((int)meter.ProtocolType).PadLeft(2, '0');
hexDatas.Add(protocolTypeHex);
hexDatas.Add(meter.Address);
hexDatas.Add(meter.Password.PadLeft(12, '0'));
var rateNumberBin = $"0000{DataConvert.DecToBin(meter.RateNumber).PadLeft(4, '0')}";
var rateNumberHex = DataConvert.BinToHex(rateNumberBin).PadLeft(2, '0');
hexDatas.Add(rateNumberHex);
var intBitNumberBin = DataConvert.DecToBin(meter.IntegerBitNumber - 4).PadLeft(2, '0');
var decBitNumberBin = DataConvert.DecToBin(meter.DecimalBitNumber - 1).PadLeft(2, '0');
var intAndDecBitNumberBin = $"0000{intBitNumberBin}{decBitNumberBin}";
var intAndDecBitNumberHex = DataConvert.BinToHex(intAndDecBitNumberBin).PadLeft(2, '0');
hexDatas.Add(intAndDecBitNumberHex);
hexDatas.Add(meter.CollectorAddress.PadLeft(12, '0'));
var userCategoryNumberBin = DataConvert.DecToBin(meter.UserCategoryNumber).PadLeft(4, '0');
var userSubclassNumberBin = DataConvert.DecToBin(meter.UserSubclassNumber).PadLeft(4, '0');
var userNumberHex = DataConvert.BinToHex($"{userCategoryNumberBin}{userSubclassNumberBin}").PadLeft(2, '0');
hexDatas.Add(userNumberHex);
}
//高位在前,低位在后
var datas = new List();
foreach (var hexData in hexDatas)
{
if (hexData.Length == 2)
datas.Add(hexData);
else
{
var lst = DataConvert.StringToPairs(hexData);
lst.Reverse();
datas.AddRange(lst);
}
}
datas.AddRange(GetPW());
return datas;
}
///
/// 透明转发
///
/// 终端通信端口 1~31
/// 0~7 对应300,600,1200,2400,4800,7200,9600,19200
///
///
///
///
public List GetAFN1001DataUnit(int port, BaudRate baudRate, StopBit stopBit, Parity parity, DataBit dataBit,
int waitContentTimeout, int waitByteTimeout, List datas)
{
var dataUnit = new List();
var portHex = DataConvert.DecToHex(port).PadLeft(2, '0');
dataUnit.Add(portHex);
var baudRateBin = DataConvert.DecToBin((int)baudRate).PadLeft(3, '0');
var stopBitBin = DataConvert.DecToBin((int)stopBit);
var parityBin = parity != Parity.None ? $"1{DataConvert.DecToBin((int)parity)}" : $"0{DataConvert.DecToBin((int)parity)}";
var dataBitBin = DataConvert.DecToBin((int)dataBit).PadLeft(2, '0');
var controlHex = DataConvert.BinToHex($"{baudRateBin}{stopBitBin}{parityBin}{dataBitBin}").PadLeft(2, '0'); ;
dataUnit.Add(controlHex);
var waitContentTimeoutBin = $"1{DataConvert.DecToBin(waitContentTimeout).PadLeft(7, '0')}";
var waitContentTimeoutHex = DataConvert.BinToHex(waitContentTimeoutBin).PadLeft(2, '0');
var waitByteTimeoutHex = DataConvert.DecToHex(waitByteTimeout).PadLeft(2, '0');
dataUnit.Add(waitContentTimeoutHex);
dataUnit.Add(waitByteTimeoutHex);
var countHex = DataConvert.DecToHex(datas.Count).PadLeft(4, '0');
var countHexPairs = DataConvert.StringToPairs(countHex);
countHexPairs.Reverse();
dataUnit.AddRange(countHexPairs);
dataUnit.AddRange(datas);
return dataUnit;
}
//TODO AUX=消息认证码字段(PW,16个字节)+时间标签
private List GetPW()
{
var str = "00";
var pWList = Enumerable.Repeat(str, pWLen).ToList();
return pWList;
}
///
/// 时间标签
///
/// 启动帧帧序号计数器PFC 1字节
/// 允许发送传输延时时间 min 1字节
///
private List GetTp(string pFC = "00", int delayTime = 0)
{
var now = DateTime.Now; // 获取当前时间
var seconds = now.Second.ToString().PadLeft(2, '0'); // 获取当前秒数
var minutes = now.Minute.ToString().PadLeft(2, '0'); // 获取当前分钟数
var hours = now.Hour.ToString().PadLeft(2, '0'); // 获取当前小时数
var day = now.Day.ToString().PadLeft(2, '0'); // 获取当前日期的日数
return new List() { pFC, seconds, minutes, hours, day, delayTime.ToString().PadLeft(2, '0') };
}
#endregion
///
/// 帧校验和
///
/// 用户数据区
///
private string GetCS(List userData)
{
byte sum = 0;
foreach (var d in userData)
{
var b = Convert.ToByte(d, 16);
sum += b;
}
return sum.ToString("X2");
}
#endregion
#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 帧结束标志
///
/// 解析上行命令
///
///
///
public CommandReulst? AnalysisCmd(string cmd)
{
CommandReulst? commandReulst = null;
var hexStringList = DataConvert.StringToPairs(cmd);
if (hexStringList.Count < hearderLen)
{
return commandReulst;
}
if (hexStringList[0] != stx || hexStringList[5] != stx)
{
return commandReulst;
}
var lenHexStr = $"{hexStringList[2]}{hexStringList[1]}";
var lenBin = DataConvert.HexToBin(lenHexStr);
var len = DataConvert.BinToDec(lenBin.Remove(lenBin.Length - 2));
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 = DataConvert.HexToBin(aHexList[4]).PadLeft(8, '0');
var mSA = DataConvert.BinToDec(a3Bin.Substring(0, 7));
userDataIndex += 5;
var aFN = (AFN)DataConvert.HexToDec(hexStringList[userDataIndex]);//1字节
userDataIndex += 1;
var seq = DataConvert.HexToBin(hexStringList[userDataIndex]).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 = DataConvert.HexToBin(hexStringList[userDataIndex]);
var da1 = da1Bin == "0" ? 0 : da1Bin.Length;
userDataIndex += 1;
var da2 = DataConvert.HexToDec(hexStringList[userDataIndex]);
userDataIndex += 1;
var pn = da2 == 0 ? 0 : (da2 - 1) * 8 + da1;
//(DT2*8)+DT1=fn
var dt1Bin = DataConvert.HexToBin(hexStringList[userDataIndex]);
var dt1 = dt1Bin != "0" ? dt1Bin.Length : 0;
userDataIndex += 1;
var dt2 = DataConvert.HexToDec(hexStringList[userDataIndex]);
userDataIndex += 1;
var fn = dt2 > 0 ? dt2 * 8 + dt1 : 0;
//数据单元
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 = DataConvert.BinToDec(prseqBin),
},
CmdLength = len,
Pn = pn,
Fn = fn,
HexDatas = datas
};
return commandReulst;
}
///
/// 解析地址
///
///
///
private string AnalysisA(List aHexList)
{
var a1 = aHexList[1] + aHexList[0];
var a2 = aHexList[3] + aHexList[2];
var a2Dec = DataConvert.HexToDec(a2);
var a3 = aHexList[4];
var a = $"{a1}{a2Dec.ToString().PadLeft(5, '0')}";
return a;
}
///
/// 解析上行命令数据包
///
///
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;
}
}
public void AnalysisAFN02(CommandReulst commandReulst)
{
if (commandReulst.Fn == 1) //登录
{
Console.WriteLine($"{commandReulst.A},登录:{DateTime.Now}");
var reqParam = new ReqParameter2()
{
AFN = AFN.确认或否认,
CMasterStationFunCode = CMasterStationFunCode.链路测试,
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.确认或否认,
CMasterStationFunCode = CMasterStationFunCode.链路测试,
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);
}
}
///
/// 解析时间标签
///
///
private void AnalysisTp(List hexDatas)
{
var pFC = DataConvert.HexToDec(hexDatas[0]);//启动帧帧序号计数器
var seconds = Convert.ToInt32(hexDatas[1]); // 获取当前秒数
var minutes = Convert.ToInt32(hexDatas[2]); // 获取当前分钟数
var hours = Convert.ToInt32(hexDatas[3]); // 获取当前小时数
var day = Convert.ToInt32(hexDatas[4]); // 获取当前日期的日数
var delayTime = DataConvert.HexToDec(hexDatas[5]);//延迟时间 min
}
///
/// 解析电表档案
///
///
///
public List AnalysisAFN04F10DataUnit(List hexDatas)
{
var meterList = new List();
var count = DataConvert.HexToDec($"{hexDatas[1]}{hexDatas[0]}");
//if (2 + count * 27 != hexDatas.Count - pWLen - tPLen - 2)
// return;
var index = 2;//数量
for (int i = 1; i <= count; i++)
{
var meterNumber = DataConvert.HexToDec($"{hexDatas[index + 1]}{hexDatas[index]}");
index += 2;
var pn = DataConvert.HexToDec($"{hexDatas[index + 1]}{hexDatas[index]}");
index += 2;
var baudRateAndPortBin = DataConvert.HexToBin(hexDatas[index]).PadLeft(8, '0');
var baudRate = DataConvert.BinToDec(baudRateAndPortBin.Substring(0, 3));
var port = DataConvert.BinToDec(baudRateAndPortBin.Substring(3, 5));
index += 1;
var protocolType = (ProtocolType)DataConvert.HexToDec(hexDatas[index]);
index += 1;
var addressHexList = hexDatas.Skip(index).Take(6).ToList();
addressHexList.Reverse();
var address = string.Join("", addressHexList);
index += 6;
var pwdHexList = hexDatas.Skip(index).Take(6).ToList();
pwdHexList.Reverse();
var password = string.Join("", pwdHexList.Take(3).ToList());
index += 6;
var rateNumberBin = DataConvert.HexToBin(hexDatas[index]).PadLeft(8, '0');
var rateNumber = DataConvert.BinToDec(rateNumberBin.Substring(4));
index += 1;
var intBitAndDecBitNumberBin = DataConvert.HexToBin(hexDatas[index]).PadLeft(8, '0');
var intBitNumber = DataConvert.BinToDec(intBitAndDecBitNumberBin.Substring(4, 2)) + 4;
var decBitNumber = DataConvert.BinToDec(intBitAndDecBitNumberBin.Substring(6, 2)) + 1;
index += 1;
// hexDatas.GetRange()
var collectorAddressHexList = hexDatas.Skip(index).Take(6).ToList();
collectorAddressHexList.Reverse();
var collectorAddress = string.Join("", collectorAddressHexList);
index += 6;
var userClassNumberBin = DataConvert.HexToBin(hexDatas[index]).PadLeft(8, '0');
var userClass = DataConvert.BinToDec(userClassNumberBin.Substring(0, 4));
var userSubClass = DataConvert.BinToDec(userClassNumberBin.Substring(4, 4));
index += 1;
meterList.Add(new MeterParameter()
{
Pn = pn,
BaudRate = baudRate,
Port = port,
ProtocolType = protocolType,
Address = address,
Password = password,
RateNumber = rateNumber,
IntegerBitNumber = intBitNumber,
DecimalBitNumber = decBitNumber,
CollectorAddress = collectorAddress,
UserCategoryNumber = userClass,
UserSubclassNumber = userSubClass,
});
}
return meterList;
}
///
/// 解析实时数据F129
///
///
private void AnalysisAFN0CF129DataUnit(List hexDatas)
{
var minutes = Convert.ToInt32(hexDatas[0]); // 获取当前分钟数
var hours = Convert.ToInt32(hexDatas[1]); // 获取当前小时数
var day = Convert.ToInt32(hexDatas[2]); // 获取当前日期的日数
var month = Convert.ToInt32(hexDatas[3]); // 获取当前月份
var year = Convert.ToInt32(hexDatas[4]); // 获取当前日期的年份
var rateNumber = Convert.ToInt32(hexDatas[5]);
var kwhTotal = hexDatas.Skip(5).Take(5).ToList();
var kwhList = new List();
var index = 11;
for (int i = 0; i < rateNumber; i++)
{
var kwhHexList = hexDatas.Skip(11).Take(5).ToList();
kwhHexList.Reverse();
var integerStr = $"{kwhHexList.Take(0)}{kwhHexList.Take(1)}{kwhHexList.Take(2)}";
var decimalValStr = $"{kwhHexList[3]}{kwhHexList[4]}";
var val = decimal.Parse($"{integerStr}{decimalValStr}");
kwhList.Add(val);
index += 5;
}
}
#endregion
}
}