using System.ComponentModel.DataAnnotations; using JiShe.CollectBus.Common.Enums; using JiShe.CollectBus.Common.Models; using System.Reflection; namespace JiShe.CollectBus.Common.Extensions { public static class HexStringExtensions { //起始字符 private const string startStr = "68"; //结束字符 private const string endStr = "16"; //头部字节长度 private const int hearderLen = 6; //消息认证码字段长度 private const int pWLen = 16; private const int tPLen = 6; private const int FixedLength = 18; static object locker = new object(); static List MSA = new List(); static Dictionary> usingMSA = new Dictionary>(); static HexStringExtensions() { for (int i = 1; i <= 127; i++) { MSA.Add(i); } } /// /// Gets the msa. /// /// 集中器地址 /// public static int GetMSA(string mark) { lock (locker) { if (!usingMSA.Keys.Contains(mark)) usingMSA.Add(mark, new List()); int msa = MSA.Except(usingMSA[mark]).FirstOrDefault(); //if (msa == 1) msa = 2;//msa=1为自定义指令保留 usingMSA[mark].Add(msa); if (msa == 127) usingMSA[mark].RemoveAll(m => true); return msa; } } public static object GetAnalyzeValue(this List hexStringList, CommandChunkEnum chunk) { if (hexStringList.Count < hearderLen || hexStringList[0] != startStr || hexStringList[5] != startStr || hexStringList.Count < FixedLength) { return null; } switch (chunk) { case CommandChunkEnum.AFN: var aFn = hexStringList[(int)CommandChunkEnum.AFN].HexToDec();//1字节 return aFn; case CommandChunkEnum.FN: //(DT2*8)+DT1=fn var dt1Bin = hexStringList[(int)CommandChunkEnum.FN - 1].HexToBin(); var dt1 = dt1Bin != "0" ? dt1Bin.Length : 0; var dt2 = hexStringList[(int)CommandChunkEnum.FN].HexToDec(); var fn = dt2 * 8 + dt1; return fn; case CommandChunkEnum.A: var aHexList = hexStringList.Skip((int)CommandChunkEnum.A).Take(5).ToList(); 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')}"; var a3Bin = aHexList[4].HexToBin().PadLeft(8, '0'); var msa = a3Bin.Substring(0, 7).BinToDec(); return new Tuple(a, msa); case CommandChunkEnum.SEQ: var seq = hexStringList[(int)CommandChunkEnum.SEQ].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); return new Seq { CON = con, FIRFIN = firfin, PRSEQ = prseqBin.BinToDec(), TpV = tpV }; case CommandChunkEnum.Data: var lenIndex = (int)CommandChunkEnum.Len; var lenBin = (hexStringList[lenIndex + 1]+hexStringList[lenIndex]).HexToBin(); var len = lenBin.Remove(lenBin.Length - 2).BinToDec(); //验证长度 2=(帧校验和+结束字符) if (hexStringList.Count - 2 != hearderLen + len) return null; var dataHexList = hexStringList.Skip(FixedLength).Take(len + hearderLen - FixedLength).ToList(); return dataHexList; default: throw new ArgumentOutOfRangeException(nameof(chunk), chunk, null); } } public static bool IsStartStr(this string str) { return str == startStr ? true : false; } /// /// 字节加33 /// /// /// public static List AddHex33(this List hexStringList) { for (int i = 0; i < hexStringList.Count; i++) { hexStringList[i] = (Convert.ToInt32(hexStringList[i], 16) + Convert.ToInt32("33", 16)).ToString("X2"); if (hexStringList[i].Length > 2) { hexStringList[i] = hexStringList[i].Substring(hexStringList[i].Length - 2); } } return hexStringList; } #region 376.1下行命令 /// /// 构建电表参数设置-下发命令 /// /// 集中器地址 /// /// public static byte[] BuildAmmeterParameterSetSendCmd(string address, List meterParameters) { var dataUnit = BuildAmmeterParameterSendDataUnit(meterParameters); var reqParameter = new ReqParameter2() { AFN = AFN.设置参数, FunCode = (int)CMasterStationFunCode.请求1级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.需要对该帧进行确认, PRSEQ = 10, }, MSA = GetMSA(address), Pn = 0, Fn = 10 }; var bytes = BuildSendCommandBytes(reqParameter, dataUnit); return bytes; } /// /// 构建电表参数读取-下发命令 /// /// 集中器地址 /// 对象序号 public static void BuildAmmeterParameterReadingSendCmd(string address, List meterNumberList) { var dataUnit = new List(); var countHex = meterNumberList.Count().DecToHex().PadLeft(4, '0'); var countHexPairs = countHex.StringToPairs(); countHexPairs.Reverse(); dataUnit.AddRange(countHexPairs); foreach (var number in meterNumberList) { var numberHex = number.DecToHex().PadLeft(4, '0'); var numberHexPairs = numberHex.StringToPairs(); numberHexPairs.Reverse(); dataUnit.AddRange(numberHexPairs); } var reqParameter = new ReqParameter2() { AFN = AFN.查询参数, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 0, }, MSA = GetMSA(address), Pn = 0, Fn = 10 }; var bytes = BuildSendCommandBytes(reqParameter, dataUnit); } /// /// 构建电表抄读一类数据-下发命令 /// /// /// /// 一类数据项 public static void BuildAmmeterReadRealTimeDataSendCmd(string address, int pn, ATypeOfDataItems aTypeOfDataItems) { var reqParameter = new ReqParameter2() { AFN = AFN.请求实时数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = (int)aTypeOfDataItems }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter); } /// /// 构建电表抄读日冻结正向有功电能示值-下发命令 /// /// /// /// public static void BuildAmmeterReadDailyFreezingDataSendCmd(string address, int pn, DateTime time) { var dataUnit = time.ToString("yy-MM-dd").Split('-').ToList(); dataUnit.Reverse(); var reqParameter = new ReqParameter2() { AFN = AFN.请求历史数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = 161 }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter, dataUnit); } /// /// 构建电表抄读实时电流-下发命令 /// /// /// public static void BuildAmmeterRealTimeCurrentDataSendCmd(string address, int pn) { var reqParameter = new ReqParameter2() { AFN = AFN.请求实时数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = 25 }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter); } /// /// 构建电表读取二类数据-下发命令 /// /// /// /// fn /// 冻结密度 /// 冻结点数 public static void BuildAmmeterReadingIIdataTypeItemsSendCmd(string address, int pn, IIdataTypeItems iIDataTypeItems, FreezeDensity density,int points) { var queryDate = DateTime.Today.AddDays(-1); var dataUnit = queryDate.ToString("yyMMddHHmm").StringToPairs(); dataUnit.Reverse(); //冻结密度 dataUnit.Add(((int)density).DecToHex()); dataUnit.Add(points.DecToHex()); var reqParameter = new ReqParameter2() { AFN = AFN.请求历史数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = (int)iIDataTypeItems }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter, dataUnit); } /// /// 构建电表读取二类数据-下发命令 /// /// /// /// fn /// 数据时标 public static void BuildAmmeterReadingBaseDataSendCmd(string address, int pn, IIdataTypeItems iIDataTypeItems,TdType tdType) { var queryDate = DateTime.Today.AddDays(-1); List? dataUnit = null; switch (tdType) { case TdType.Td_d: dataUnit = queryDate.ToString("yyMMdd").StringToPairs(); break; case TdType.Td_m: dataUnit = queryDate.ToString("yyMM").StringToPairs(); break; } if(dataUnit == null) return; dataUnit.Reverse(); var reqParameter = new ReqParameter2() { AFN = AFN.请求历史数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = (int)iIDataTypeItems }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter, dataUnit); } /// /// 组装有/无功电量 /// /// /// /// public static void BuildAmmeterReadingElectricityDataSendCmd(string address, int pn,int cmdType) { var reqParameter = new ReqParameter2() { AFN = AFN.请求实时数据, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 2, }, MSA = GetMSA(address), Pn = pn, Fn = cmdType }; var bytes = HexStringExtensions.BuildSendCommandBytes(reqParameter); } /// /// 构建超功率设置-下发命令 /// /// /// /// /// /// /// public static void BuildAmmeterSuperpowerSettingSendCmd(string address, string password,string modelCode, int port, BaudRate baudRate, decimal power) { if (power > 0) { WsOnSupperPower(address, password, modelCode, true, port, baudRate); //TODO:连续发几条嘛? string dataMark; //如果是多回路电表,地址只取前面部分 例如:564880000001_01 取564880000001 if (address.IndexOf('_') > 0) { var addressSplit = address.Split('_'); address = addressSplit[0]; var loop = Convert.ToInt32(addressSplit[1]); if (loop == 1) { dataMark = "0E300101"; } else if (loop == 2) { dataMark = "0E300201"; } else return; } else { dataMark = "0E300101"; } var turnData = AssembleWsSupperPower(address, password, dataMark, power); if (turnData != null) { var bytes = BuildTransparentForwardingSendCmd(address, port, baudRate, turnData); } } else { WsOnSupperPower(address, password, modelCode, false, port, baudRate); } } /// /// 构建恶性负载绝对功率设置-下发命令 /// /// /// /// /// /// public static void BuildAmmeterAbsolutePowerSettingSendCmd(string address, string password, int port, BaudRate baudRate, decimal power) { if (power <= 0) { power = 99;//等于小0 代表关闭 } string dataMark; //如果是多回路电表,地址只取前面部分 例如:564880000001_01 取564880000001 if (address.IndexOf('_') > 0) { var addressSplit = address.Split('_'); address = addressSplit[0]; var loop = Convert.ToInt32(addressSplit[1]); if (loop == 1) { dataMark = "0E300103"; } else if (loop == 2) { dataMark = "0E300203"; } else return; } else { dataMark = "0E300103"; } var turnData = AssembleWsAbsolutePowerSetting(address, password, dataMark, power); if (turnData != null) { var bytes = BuildTransparentForwardingSendCmd(address, port, baudRate, turnData); } } /// /// 构建恶性负载功率因数设置-下发命令 /// /// /// /// /// /// public static void BuildAmmeterPowerFactorSettingSendCmd(string address, string password, int port, BaudRate baudRate, decimal power) { string dataMark; //如果是多回路电表,地址只取前面部分 例如:564880000001_01 取564880000001 if (address.IndexOf('_') > 0) { var addressSplit = address.Split('_'); address = addressSplit[0]; var loop = Convert.ToInt32(addressSplit[1]); if (loop == 1) { dataMark = "0E300104"; } else if (loop == 2) { dataMark = "0E300204"; } else return; } else { dataMark = "0E300104"; } var turnData = AssembleWsPowerFactor(address, password, dataMark, power); if (turnData != null) { var bytes = BuildTransparentForwardingSendCmd(address, port, baudRate, turnData); } } /// /// 超功率开关 /// /// /// /// /// /// public static void WsOnSupperPower(string address,string password,string modelCode,bool isOn,int port,BaudRate baudRate) { List modelCodes = new List() { "DDS3102-S2", "DDS71", "DDZY71", "DTZY71", "DSZY71" }; //这些型号需进入软编程 if (modelCodes.Contains(modelCode)) { var dataUnit1 = SoftProgram(address, modelCode, password); BuildTransparentForwardingSendCmd(address, port, baudRate, dataUnit1); } var dataUnit2 = AssembleWsOnSupperPower(address, password, isOn); BuildTransparentForwardingSendCmd(address, port, baudRate, dataUnit2); } /// /// 构建水表参数设置-下发命令 /// /// 集中器地址 /// /// public static byte[] BuildWaterMeterParameterSetSendCmd(string address, List meterParameters) { var dataUnit = BuildWaterMeterParameterSendDataUnit(meterParameters); var reqParameter = new ReqParameter2() { AFN = AFN.设置参数, FunCode = (int)CMasterStationFunCode.请求1级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.需要对该帧进行确认, PRSEQ = 10, }, MSA = GetMSA(address), Pn = 0, Fn = 10 }; var bytes = BuildSendCommandBytes(reqParameter, dataUnit); return bytes; } /// /// 构建透明转发-下发命令 /// /// 集中器地址 /// 终端通信端口 1~31 /// 0~7 对应300,600,1200,2400,4800,7200,9600,19200 /// 转发内容 /// 停止位 /// 校验方式 /// 数据位 /// 等待报文超时时间/s /// 等待字节超时时间/ms public static byte[] BuildTransparentForwardingSendCmd(string address, int port, BaudRate baudRate, List datas, StopBit stopBit = StopBit.Stop1, Parity parity = Parity.Even, DataBit dataBit = DataBit.D8, int waitContentTimeout = 100, int waitByteTimeout = 100) { var dataUnit = BuildTransparentForwardingSendDataUnit(port, baudRate, datas, stopBit, parity, dataBit, waitContentTimeout, waitByteTimeout); dataUnit.AddRange(GetPW()); var reqParameter = new ReqParameter2() { AFN = AFN.数据转发, FunCode = (int)CMasterStationFunCode.请求2级数据, A = address, Seq = new Seq() { TpV = TpV.附加信息域中无时间标签, FIRFIN = FIRFIN.单帧, CON = CON.不需要对该帧进行确认, PRSEQ = 0 }, MSA = GetMSA(address), Pn = 0, Fn = 1 }; var bytes = BuildSendCommandBytes(reqParameter, dataUnit); return bytes; } [Obsolete] public static 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 = DateTime.Now.AddYears(3).ToString("000012ddMMyy").StrAddSpan(); if (specialnocode == "1D" || modelCode == "SZBD_DDZY1225") strDate = "FF FF FF FF FF FF"; string strP = password.StrAddSpan().StrReverseOrder(); string strSJY = " " + pwdLevel + " " + strP + " 01 00 00 00 " + Code + " 00 " + strDate; string strLen = (strSJY.Replace(" ", "").Length / 2).ToString("X2"); string strReturn = "68 " + address.StrAddSpan().StrReverseOrder() + " 68 1C " + strLen + " " + strSJY.StrAddHex33() + " "; 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(); } /// /// 构建透明转发-下发数据单元 /// /// 终端通信端口 1~31 /// 0~7 对应300,600,1200,2400,4800,7200,9600,19200 /// 转发内容 /// 停止位 /// 校验方式 /// 数据位 /// 等待报文超时时间/s /// 等待字节超时时间/ms /// private static List BuildTransparentForwardingSendDataUnit(int port, BaudRate baudRate, List datas, StopBit stopBit = StopBit.Stop1, Parity parity = Parity.Even, DataBit dataBit = DataBit.D8, int waitContentTimeout = 100, int waitByteTimeout = 100) { var dataUnit = new List(); var portHex = port.DecToHex().PadLeft(2, '0'); dataUnit.Add(portHex); var baudRateBin = ((int)baudRate).DecToBin().PadLeft(3, '0'); var stopBitBin = ((int)stopBit).DecToBin(); var parityBin = parity != Parity.None ? $"1{((int)parity).DecToBin()}" : "00"; var dataBitBin = ((int)dataBit).DecToBin().PadLeft(2, '0'); var controlHex = $"{baudRateBin}{stopBitBin}{parityBin}{dataBitBin}".BinToHex().PadLeft(2, '0'); ; dataUnit.Add(controlHex); var waitContentTimeoutBin = $"1{waitContentTimeout.DecToBin().PadLeft(7, '0')}"; var waitContentTimeoutHex = waitContentTimeoutBin.BinToHex().PadLeft(2, '0'); var waitByteTimeoutHex = waitByteTimeout.DecToHex().PadLeft(2, '0'); dataUnit.Add(waitContentTimeoutHex); dataUnit.Add(waitByteTimeoutHex); var countHex = datas.Count.DecToHex().PadLeft(4, '0'); var countHexPairs = countHex.StringToPairs(); countHexPairs.Reverse(); dataUnit.AddRange(countHexPairs); dataUnit.AddRange(datas); return dataUnit; } /// /// 构建下发命令 /// /// /// /// public static byte[] BuildSendCommandBytes(ReqParameter reqParameter, List? dataUnit = null) { var cmdStrList = new List(); var userDatas = BuildUserData(reqParameter, dataUnit); var hearders = BuildHeaders(userDatas.Count); var cs = GetCS(userDatas); cmdStrList.AddRange(hearders); cmdStrList.AddRange(userDatas); cmdStrList.Add(cs); cmdStrList.Add(endStr); Console.WriteLine(string.Join(" ", cmdStrList)); var bytes = cmdStrList.Select(x => Convert.ToByte(x, 16)).ToArray(); return bytes; } /// /// 构建电表参数设置-下发数据单元 /// /// /// private static List BuildAmmeterParameterSendDataUnit(List meterParameters) { var hexDatas = new List(); var countHex = meterParameters.Count().DecToHex().PadLeft(4, '0'); hexDatas.Add(countHex); //TODO 优化代码:目标数据入参,返回类型为出参 for (int i = 0; i <= meterParameters.Count - 1; i++) { var meter = meterParameters[i]; var indexHex = (i + 1).DecToHex().PadLeft(4, '0'); hexDatas.Add(indexHex); var pnHex = meter.Pn.DecToHex().PadLeft(4, '0'); hexDatas.Add(pnHex); var baudRateBin = meter.BaudRate.DecToBin().PadLeft(3, '0'); var portBin = meter.Port.DecToBin().PadLeft(5, '0'); var baudRateAndPortHex = $"{baudRateBin}{portBin}".BinToHex().PadLeft(2, '0'); hexDatas.Add(baudRateAndPortHex); var protocolTypeHex = ((int)meter.ProtocolType).DecToHex().PadLeft(2, '0'); hexDatas.Add(protocolTypeHex); hexDatas.Add(meter.Address); hexDatas.Add(meter.Password.PadLeft(12, '0')); var rateNumberBin = $"0000{meter.RateNumber.DecToBin().PadLeft(4, '0')}"; var rateNumberHex = rateNumberBin.BinToHex().PadLeft(2, '0'); hexDatas.Add(rateNumberHex); var intBitNumberBin = (meter.IntegerBitNumber - 4).DecToBin().PadLeft(2, '0'); var decBitNumberBin = (meter.DecimalBitNumber - 1).DecToBin().PadLeft(2, '0'); var intAndDecBitNumberBin = $"0000{intBitNumberBin}{decBitNumberBin}"; var intAndDecBitNumberHex = intAndDecBitNumberBin.BinToHex().PadLeft(2, '0'); hexDatas.Add(intAndDecBitNumberHex); hexDatas.Add(meter.CollectorAddress.PadLeft(12, '0')); var userCategoryNumberBin = meter.UserCategoryNumber.DecToBin().PadLeft(4, '0'); var userSubclassNumberBin = meter.UserSubclassNumber.DecToBin().PadLeft(4, '0'); var userNumberHex = $"{userCategoryNumberBin}{userSubclassNumberBin}".BinToHex().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 = hexData.StringToPairs(); lst.Reverse(); datas.AddRange(lst); } } datas.AddRange(GetPW()); return datas; } /// /// 构建水表参数设置-下发数据单元 /// /// /// private static List BuildWaterMeterParameterSendDataUnit(List meterParameters) { var hexDatas = new List(); var countHex = meterParameters.Count().DecToHex().PadLeft(4, '0'); hexDatas.Add(countHex); for (int i = 0; i <= meterParameters.Count - 1; i++) { var meter = meterParameters[i]; var protocolType = (int)meter.ProtocolType; var currentProtocolType = protocolType; if (protocolType == 43) currentProtocolType = 1; else if (protocolType > 32) currentProtocolType = 32; //TODO:无线水表 小数位 if (currentProtocolType == 32 && meter.Address.Substring(0, 2) != "00") { var ejz = meter.Address.Substring(0, 2).HexToBin().PadLeft(8, '0'); var xs = ejz.Substring(6, 2).BinToDec(); var zs = ejz.Substring(0, 6).BinToDec(); //userData.Add(new QGDW3671UserData() { Name = "整数位无线水表", Value = zs }); //userData.Add(new QGDW3671UserData() { Name = "小数位无线水表", Value = xs }); } var userCategoryNumber = meter.UserCategoryNumber; var userSubclassNumber = meter.UserSubclassNumber; if (protocolType == 32) userCategoryNumber = 1; else if (protocolType == 45) { userCategoryNumber = 1; userSubclassNumber = 9; } else if (protocolType == 1) userSubclassNumber = 1; var indexHex = (i + 1).DecToHex().PadLeft(4, '0'); hexDatas.Add(indexHex); var pnHex = meter.Pn.DecToHex().PadLeft(4, '0'); hexDatas.Add(pnHex); var baudRateBin = meter.BaudRate.DecToBin().PadLeft(3, '0'); var portBin = meter.Port.DecToBin().PadLeft(5, '0'); var baudRateAndPortHex = $"{baudRateBin}{portBin}".BinToHex().PadLeft(2, '0'); hexDatas.Add(baudRateAndPortHex); var protocolTypeHex = currentProtocolType.DecToHex().PadLeft(2, '0'); hexDatas.Add(protocolTypeHex); hexDatas.Add(meter.Address); hexDatas.Add(meter.Password.PadLeft(12, '0')); var rateNumberBin = $"0000{meter.RateNumber.DecToBin().PadLeft(4, '0')}"; var rateNumberHex = rateNumberBin.BinToHex().PadLeft(2, '0'); hexDatas.Add(rateNumberHex); var intBitNumberBin = meter.IntegerBitNumber.DecToBin().PadLeft(2, '0'); var decBitNumberBin = meter.DecimalBitNumber.DecToBin().PadLeft(2, '0'); var intAndDecBitNumberBin = $"0000{intBitNumberBin}{decBitNumberBin}"; var intAndDecBitNumberHex = intAndDecBitNumberBin.BinToHex().PadLeft(2, '0'); hexDatas.Add(intAndDecBitNumberHex); hexDatas.Add(meter.CollectorAddress.PadLeft(12, '0')); var userCategoryNumberBin = userCategoryNumber.DecToBin().PadLeft(4, '0'); var userSubclassNumberBin = userSubclassNumber.DecToBin().PadLeft(4, '0'); var userNumberHex = $"{userCategoryNumberBin}{userSubclassNumberBin}".BinToHex().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 = hexData.StringToPairs(); lst.Reverse(); datas.AddRange(lst); } } datas.AddRange(GetPW()); return datas; } //AUX=消息认证码字段(PW,16个字节) private static List GetPW() { var str = "00"; var pWList = Enumerable.Repeat(str, pWLen).ToList(); return pWList; } /// /// 帧校验和 /// /// 用户数据区 /// private static string GetCS(List userData) { byte sum = 0; foreach (var d in userData) { var b = Convert.ToByte(d, 16); sum += b; } return sum.ToString("X2"); } /// /// 用户数据区 /// /// /// private static List BuildUserData(ReqParameter reqParameter, List? dataUnit) { var c = BuildC(reqParameter.FunCode, reqParameter.PRM); var a = BuildAList(reqParameter.A, reqParameter.MSA); var linkUserData = BuildLinkUserData(reqParameter.AFN, reqParameter.Seq, ((ReqParameter2)reqParameter).Pn, ((ReqParameter2)reqParameter).Fn, dataUnit); var list = new List() { c }; list.AddRange(a); list.AddRange(linkUserData); return list; } /// /// 固定长度的报文头 起始字符+长度+长度+起始字符 /// /// /// private static List BuildHeaders(int length) { var headers = new List(); headers.Add(startStr); var l = BuildLength(length); headers.AddRange(l); headers.AddRange(l); headers.Add(startStr); return headers; } /// /// 长度 2字节 [用户数据区长度] /// /// private static List BuildLength(int length1) { var binaryLen = length1.DecToBin(); var protocolIdentification = Enum.Format(typeof(ProtocolIdentification), ProtocolIdentification.本规约使用, "d").PadLeft(2, '0'); var lenStr = $"{binaryLen}{protocolIdentification}"; var hexLen = lenStr.BinToHex(); hexLen = hexLen.PadLeft(4, '0'); var list = hexLen.StringToPairs(); list.Reverse(); return list; } /// /// 控制域 /// /// 功能码 /// /// /// private static string BuildC(int funCode, PRM pRM, int fcb = 0, FCV fcv = FCV.FCB位无效) { var cMasterStationFunCodeHex = funCode.DecToBin(); cMasterStationFunCodeHex = cMasterStationFunCodeHex.ToString().PadLeft(4, '0'); var strC = $"{(int)DIR.主站下行报文}{(int)pRM}{fcb}{(int)fcv}{cMasterStationFunCodeHex}"; var hexC = strC.BinToHex().PadLeft(2, '0'); return hexC; } /// /// 地址域 3220 09872 /// /// 行政区划码 BCD码 3220=2032 /// 逻辑地址 BIN 09872=2690=>9026 /// 主站地址 BIN 0~127 /// private static List BuildAList(string a, int mSA) { var list = new List(); var a1 = a.Substring(0, 4); var a1Pairs = a1.StringToPairs(); a1Pairs.Reverse(); list.AddRange(a1Pairs); var a2 = Convert.ToInt32(a.Substring(4)); var decA2 = a2.DecToHex(); var a2Pairs = decA2.PadLeft(4, '0').StringToPairs(); a2Pairs.Reverse(); list.AddRange(a2Pairs); //TODO:主站地址和组地址标志 var a3Bin = $"{mSA.DecToBin().PadLeft(7, '0')}0"; list.Add(a3Bin.BinToHex().PadLeft(2, '0')); return list; } private static List BuildLinkUserData(AFN aFN, Seq seq, int pn, int fn, List? dataUnit) { var aFNValue = ((int)aFN).DecToHex().PadLeft(2, '0'); var sEQ = BuildSEQ(seq.TpV, seq.FIRFIN, seq.CON, seq.PRSEQ); var dA = BuildDA(pn); var dT = BuildDT(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(BuildTp("00")); return list; } /// /// 帧序列域 /// /// /// /// /// private static string BuildSEQ(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}{pRSEQ.DecToBin().PadLeft(4, '0')}"; var hexSEQ = sEQBin.BinToHex().PadLeft(2, '0'); return hexSEQ; } /// /// 信息点标识 /// /// 计量点 /// private static List BuildDA(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 = "1".PadRight(dA1, '0').BinToHex();//对位信息 第几位 二进制有效位 var dA2Hex = dA2.DecToHex(); return new List() { dA1Hex.PadLeft(2, '0'), dA2Hex.PadLeft(2, '0') }; } /// /// 数据单元标识 /// /// /// private static List BuildDT(int fn) { var dT2 = (fn - 1) / 8;//从零开始 第几组 var dT1 = fn - dT2 * 8; var dT1Hex = "1".PadRight(dT1, '0').BinToHex();//对位信息 第几位 二进制有效位 var dT2Hex = dT2.DecToHex(); return new List() { dT1Hex.PadLeft(2, '0'), dT2Hex.PadLeft(2, '0') }; } /// /// 时间标签 /// /// 启动帧帧序号计数器PFC 1字节 /// 允许发送传输延时时间 min 1字节 /// private static List BuildTp(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 #region 645下行命令 /// /// 构建电表阀控下发数据单元 /// /// 电表地址 /// 特殊控制码 /// 密码 /// 是否为开阀 /// 型号码 /// public static List BuildAmmeterValveControlSendDataUnit(string address, string specialControlCode, string password, bool state, string modelCode = "") { var code = string.Empty; if (state) { if (string.IsNullOrEmpty(specialControlCode)) code = "1B"; else code = specialControlCode == "1B" || specialControlCode == "1C" ? specialControlCode : "1C"; } else code = "1A";//跳闸 if (specialControlCode == "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]; } var strDate = DateTime.Now.AddYears(3).ToString("000012ddMMyy").StrAddSpan();//命令有效截止时间 if (specialControlCode == "1D" || modelCode == "SZBD_DDZY1225") strDate = "FF FF FF FF FF FF"; var strP = password.StrAddSpan().StrReverseOrder(); var strSJY = " " + pwdLevel + " " + strP + " 01 00 00 00 " + code + " 00 " + strDate; var dataUnit = strSJY.Replace(" ", "").StringToPairs(); var dataList = Build645SendCommand(address, "1C", dataUnit); return dataList; //string strLen = (strSJY.Replace(" ", "").Length / 2).ToString("X2"); //string strReturn = "68 " + address.StrAddSpan().StrReverseOrder() + " 68 1C " + strLen + " " + strSJY.StrAddHex33() + " "; //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(); } /// /// 构建电表保电下发数据单元 /// /// 电表地址 /// /// true 保电 false 保电解除 /// 型号码 /// public static List BuildAmmeterLockSendDataUnit(string address, string password, bool state, string modelCode = "") { var code = state ? "3A" : "3B"; var strDate = (code + DateTime.Now.AddDays(1).ToString("00000012ddMMyy")).StrAddSpan(); if (modelCode == "SZBD_DDZY1225") strDate = $"{code} 00 FF FF FF FF FF FF"; var strP = password.StrAddSpan().StrReverseOrder(); var strSJY = " 02 " + strP + " 01 00 00 00 " + strDate; var dataUnit = strSJY.Replace(" ", "").StringToPairs(); var dataList = Build645SendCommand(address, "1C", dataUnit); return dataList; } /// /// 构建电表认证下发数据单元 /// /// 电表地址 /// /// /// public static List BuildAmmeterIdentitySendDataUnit(string address, string ramDon, string maco) { var codeList = "070004FF".StringToPairs(); codeList.Reverse(); var ramDonList = ramDon.StringToPairs(); ramDonList.Reverse(); var macoList = maco.StringToPairs(); macoList.Reverse(); var dataUnit = new List(); dataUnit.AddRange(codeList); dataUnit.AddRange(ramDonList); dataUnit.AddRange(macoList); var dataList = Build645SendCommand(address, "03", dataUnit); return dataList; } /// /// 构建电表清零下发数据单元 /// /// 电表地址 /// /// public static List BuildAmmterClearSendDataUnit(string address, string password) { var strP = password.StrAddSpan().StrReverseOrder(); var strSJY = " 02 " + strP + " 01 00 00 00 "; var dataUnit = strSJY.Replace(" ", "").StringToPairs(); var dataList = Build645SendCommand(address, "1A", dataUnit); return dataList; } /// /// 构建645协议下发命令 /// /// 电表地址 /// 控制码 /// 数据域 发送方按字节进行加33处理,接收方按字节减33 /// public static List Build645SendCommand(string ammeterAddress, string controlCode, List? dataUnit) { var cmdStrList = new List(); cmdStrList.Add(startStr); ammeterAddress = ammeterAddress.PadLeft(12, '0'); var addressList = ammeterAddress.StringToPairs(); addressList.Reverse(); cmdStrList.AddRange(addressList); cmdStrList.Add(startStr); cmdStrList.Add(controlCode); var len = dataUnit != null ? dataUnit.Count.DecToHex().PadLeft(2, '0') : "00"; cmdStrList.Add(len); if (dataUnit != null) { cmdStrList.AddRange(dataUnit.AddHex33()); } var strSum = cmdStrList.Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X"); strSum = strSum.Substring(strSum.Length - 2); cmdStrList.Add(strSum); cmdStrList.Add(endStr); return cmdStrList; } /// /// 威胜表的超功率(第一路恶性负载超功率判断阀值) /// /// /// /// /// /// public static List? AssembleWsSupperPower(string address, string password, string dataMark, decimal power) { power = Math.Round(power, 4); if (power > (decimal)99.9999) return null; var strPower = power < 10 ? $"0{power}" : power.ToString(); var pStr = strPower.Replace(".", "").PadRight(6, '0'); var data = new string[] { pStr[4] + "" + pStr[5], pStr[2] + "" + pStr[3], pStr[0] + "" + pStr[1] }; return AssembleWrite(address, password, dataMark, data); } /// /// 威胜表的超功率(超功率开关) /// /// /// /// /// public static List AssembleWsOnSupperPower(string address, string password, bool isOn = true) { var data = new string[] { (isOn ? "01" : "00") }; return AssembleWrite(address, password, "0E400001", data); } /// /// 威胜表的超功率(第一路恶性负载绝对功率判断阈值) /// /// /// /// /// /// public static List? AssembleWsAbsolutePowerSetting(string address, string password, string dataMark, decimal power) { power = Math.Round(power, 4); if (power > (decimal)99.9999) return null; var strPower = power < 10 ? $"0{power}" : power.ToString(); var pStr = strPower.Replace(".", "").PadRight(6, '0'); var data = new string[] { pStr[4] + "" + pStr[5], pStr[2] + "" + pStr[3], pStr[0] + "" + pStr[1] }; return AssembleWrite(address, password, dataMark, data); } /// /// 威胜表的超功率(第一路恶性负载功率因数判断阀值) /// /// /// /// /// /// public static List? AssembleWsPowerFactor(string address, string password, string dataMark, decimal factor) { factor = Math.Round(factor, 3); if (factor >= (decimal)1.0 || factor <= 0) return null; var strFactor = factor.ToString(); var pStr = strFactor.Replace(".", "").PadRight(4, '0'); var data = new string[] { pStr[2] + "" + pStr[3], pStr[0] + "" + pStr[1] }; return AssembleWrite(address, password, dataMark, data); } /// /// 构建写数据 /// /// /// /// /// /// public static List AssembleWrite(string address, string password, string di0_3, string[] data) { var returnList = new List(); returnList.Add(startStr); var addressList = address.StringToPairs(); addressList.Reverse(); returnList.AddRange(addressList); returnList.Add(startStr); returnList.Add("14"); var len = (12 + data.Length).ToString("X2"); returnList.Add(len); var di03List = di0_3.StringToPairs(); di03List.Reverse(); di03List.Add("02"); var pwdList = password.StringToPairs(); pwdList.Reverse(); di03List.AddRange(pwdList); var mList = new List() { "00", "11", "22", "33" }; di03List.AddRange(mList); di03List.AddRange(data); var listAdd33 = di03List.AddHex33(); returnList.AddRange(listAdd33); var strSum = returnList.Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X"); var cs = strSum.Substring(strSum.Length - 2); returnList.Add(cs); returnList.Add(endStr); return returnList; } /// /// 生成软编程指令 /// 型号编码 /// /// private static List SoftProgram(string address,string modelCode,string password) { string bccmd = string.Empty; if (modelCode == "DDS71") { bccmd = "68 AA AA AA AA AA AA 68 04 07 4E F4 35 BB BB BB 32"; } else { bccmd = "68 AA AA AA AA AA AA 68 14 10 41 35 33 41 37 33 33 33 34 33 33 33 77 66 55 44"; } //替换密码 var passwordList = password.StringToPairs(); passwordList.Reverse(); passwordList = passwordList.AddHex33(); var passwordStr = string.Join(" ", passwordList); bccmd = bccmd.Replace("BB BB BB", passwordStr); //替换表地址 var addressList = address.StringToPairs(); addressList.Reverse(); var addressStr = string.Join(" ", addressList); bccmd = bccmd.Replace("AA AA AA AA AA AA", addressStr); var fm = bccmd.Split(' ').ToList(); //生成CRC var cRC = GetCRC(fm); fm.Add(cRC); fm.Add("16"); return fm; } #endregion #region 188 下行命令 /// /// 标准 188协议阀控 /// /// /// 表计类型 /// public static List BuildConfirm188WaterValve(string waterMeterAddress, bool state, string mtype = "10") { if (string.IsNullOrWhiteSpace(waterMeterAddress)) return null; var dataUnit = new List() { "A0", "17", "00", state ? "55" : "99" }; var dataList = Build188SendCommand(waterMeterAddress, "04", dataUnit); return dataList; } /// /// 构建188水表抄读下发数据单元 /// /// /// public static List Build188WaterMeterReadingSendDataUnit(string waterMeterAddress) { var dataUnit = new List() { "1F", "90", "00" }; var dataList = Build188SendCommand(waterMeterAddress, "01", dataUnit); return dataList; } /// /// 构建188协议下发命令 /// /// 水表地址 /// 控制码 /// 数据域 /// 表类型 /// public static List Build188SendCommand(string waterMeterAddress, string controlCode, List? dataUnit = null, string meterType = "10") { //address.Substring(address.Length - 12, 12) var cmdStrList = new List(); cmdStrList.Add(startStr); cmdStrList.Add(meterType); waterMeterAddress = waterMeterAddress.PadLeft(14, '0'); var addressList = waterMeterAddress.StringToPairs(); addressList.Reverse(); cmdStrList.AddRange(addressList); //控制码 cmdStrList.Add(controlCode); var len = dataUnit != null ? dataUnit.Count.DecToHex().PadLeft(2, '0') : "00"; cmdStrList.Add(len); if (dataUnit != null) { cmdStrList.AddRange(dataUnit); } var strSum = cmdStrList.Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X"); strSum = strSum.Substring(strSum.Length - 2); cmdStrList.Add(strSum); cmdStrList.Add(endStr); return cmdStrList; } /// /// 组装水表阀控 /// /// 水表地址 /// The password. /// The poprotocol. /// if set to true [isopenvalve]. /// public static List? WaterMeterValveControl(string waterMeterAddress, string password, int protocol, bool state) { List? turnData = null; if (protocol == 1) turnData = GetControlCode97(waterMeterAddress.Substring(waterMeterAddress.Length - 12, 12), password, state ? "3355" : "9966");//开阀/关阀 else if (protocol == 30) turnData = GetControlCode07(waterMeterAddress.Substring(waterMeterAddress.Length - 12, 12), password, state ? "3355" : "9966");//开阀/关阀 return turnData; } private static List GetControlCode97(string waterMeterAddress, string password, string valueCode) { var dataList = new List(); var passwordList = password.StringToPairs(); passwordList.Reverse(); var valueCodeList = valueCode.StringToPairs(); valueCodeList.Reverse(); dataList.AddRange(valueCodeList); dataList.AddRange(passwordList); dataList.AddRange(valueCodeList); return GetCode(waterMeterAddress, "04", dataList); } private static List GetControlCode07(string waterMeterAddress, string password, string valueCode) { var dataList = new List(); dataList.Add("02"); var passwordList = password.StringToPairs(); passwordList.Reverse(); dataList.AddRange(passwordList); dataList.AddRange("01000000".StringToPairs()); dataList.AddRange(valueCode.StringToPairs()); dataList.Add("00"); var time = DateTime.Now.AddDays(1).ToString("yyMMddHHmmss"); var timeList = time.StringToPairs(); timeList.Reverse(); dataList.AddRange(timeList); return GetCode(waterMeterAddress, "1C", dataList); } public static List GetCode(string waterMeterAddress, string controlCode, List childDataList) { var dataList = new List { startStr }; waterMeterAddress = waterMeterAddress.PadLeft(12, '0'); var addressList = waterMeterAddress.StringToPairs(); addressList.Reverse(); dataList.AddRange(addressList); dataList.Add(startStr); dataList.Add(controlCode); var num = childDataList.Count; dataList.Add(num.ToString("X2")); dataList.AddRange(childDataList.AddHex33()); var cs = dataList.Select(it => Convert.ToInt32(it, 16)).Sum().ToString("X2"); cs = cs.Substring(cs.Length - 2, 2); dataList.Add(cs); dataList.Add(endStr); return dataList; } public static string GetCRC(List inputFrm, int startIndex = 0) { int sum = 0; for (int i = startIndex; i < inputFrm.Count; i++) { sum += (Convert.ToInt32(inputFrm[i], 16)); } var sum16 = Convert.ToString(sum, 16); return sum16.Substring(sum16.Length - 2, 2).ToUpper(); } public static object GetAnalyzeValue(this List hexStringList, CommandChunkEnum188 chunk) { if (hexStringList.Count < 11) { return null; } switch (chunk) { case CommandChunkEnum188.A: var aHexList = hexStringList[(int)CommandChunkEnum188.A].Take(7).ToList(); aHexList.Reverse(); return string.Join("", aHexList.Skip(1).Take(6).ToList()); case CommandChunkEnum188.C: var cHex = hexStringList[(int)CommandChunkEnum188.C]; return cHex; case CommandChunkEnum188.Data: var lenIndex = (int)CommandChunkEnum188.L; var len = hexStringList[lenIndex].HexToDec(); //验证长度 2=(帧校验和+结束字符) if (hexStringList.Count - 2 != 11 + len) return null; var dataHexList = hexStringList.Skip(11).Take(len).ToList(); return dataHexList; default: throw new ArgumentOutOfRangeException(nameof(chunk), chunk, null); } } //public double AnalyzeCurrentTotalRate(List hexList) //{ // var str = string.Join("", hexList); // var number = Convert.ToInt32(str) * 0.01; // return number; //} #endregion } }