diff --git a/JiShe.CollectBus.Common/Enums/645Enums.cs b/JiShe.CollectBus.Common/Enums/645Enums.cs
new file mode 100644
index 0000000..bf18666
--- /dev/null
+++ b/JiShe.CollectBus.Common/Enums/645Enums.cs
@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace JiShe.CollectBus.Common.Enums
+{
+ ///
+ /// 控制码
+ ///
+ public enum ControlCode
+ {
+
+ }
+}
diff --git a/JiShe.CollectBus.Common/Extensions/HexStringExtensions.cs b/JiShe.CollectBus.Common/Extensions/HexStringExtensions.cs
index 674359e..39696c0 100644
--- a/JiShe.CollectBus.Common/Extensions/HexStringExtensions.cs
+++ b/JiShe.CollectBus.Common/Extensions/HexStringExtensions.cs
@@ -81,7 +81,26 @@ namespace JiShe.CollectBus.Common.Extensions
return str == startStr ? true : false;
}
- #region 下行命令
+ ///
+ /// 字节加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下行命令
///
/// 构建电表参数设置-下发命令
@@ -181,65 +200,6 @@ namespace JiShe.CollectBus.Common.Extensions
return bytes;
}
- ///
- /// 组装电表阀控下发数据单元
- ///
- /// 电表地址
- /// 特殊控制码
- /// 密码
- /// 是否为开阀
- ///
- public static List BuildAmmeterValveControlSendDataUnit(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();
- }
-
-
///
/// 构建电表参数设置-下发数据单元
///
@@ -319,7 +279,6 @@ namespace JiShe.CollectBus.Common.Extensions
return pWList;
}
-
///
/// 帧校验和
@@ -525,5 +484,187 @@ namespace JiShe.CollectBus.Common.Extensions
#endregion
+
+ #region 645下行命令
+
+
+ ///
+ /// 构建电表阀控下发数据单元
+ ///
+ /// 电表地址
+ /// 特殊控制码
+ /// 密码
+ /// 是否为开阀
+ ///
+ public static List BuildAmmeterValveControlSendDataUnit(string address, string specialnocode, string password, bool state, string modelCode = "")
+ {
+ var 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];
+ }
+
+ var strDate = DateTime.Now.AddYears(3).ToString("000012ddMMyy").StrAddSpan();//命令有效截止时间
+ if (specialnocode == "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 = BuildSendCommand(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();
+ }
+
+ ///
+ /// 构建电表保电下发数据单元
+ ///
+ /// 电表地址
+ ///
+ ///
+ ///
+ public static List BuildAmmeterLockSendDataUnit(string address, string password, bool state, string modelCode = "")
+ {
+ string code = string.Empty;
+ if (state)
+ code = "3A";
+ else
+ code = "3B";
+ string strDate = (code + DateTime.Now.AddDays(1).ToString("00000012ddMMyy")).StrAddSpan();
+
+ if (modelCode == "SZBD_DDZY1225")
+ strDate = $"{code} 00 FF FF FF FF FF FF";
+
+ string strP = password.StrAddSpan().StrReverseOrder();
+ string strSJY = " 02 " + strP + " 01 00 00 00 " + strDate;
+
+ var dataUnit = strSJY.Replace(" ", "").StringToPairs();
+ var dataList = BuildSendCommand(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[] { " " }, System.StringSplitOptions.RemoveEmptyEntries).Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X");
+ //strReturn += strSum.Substring(strSum.Length - 2) + " 16";
+ //return strReturn.Split(' ').ToList();
+ }
+
+ ///
+ /// 构建645协议下发命令
+ ///
+ /// 电表地址
+ /// 控制码
+ /// 数据域 发送方按字节进行加33处理，接收方按字节减33
+ ///
+ public static List BuildSendCommand(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);
+
+ 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;
+ }
+
+ ///
+ /// 构建写数据 TODO:待优化
+ ///
+ ///
+ public static List AssembleWrite(string address, string password, string Di0_3, string[] data)
+ {
+ var address_str = address.StrAddSpan().StrReverseOrder();
+ var L = (12 + data.Length).ToString("X2");
+ var m = "00 11 22 33";
+ var Di0_3_str = Di0_3.StrAddSpan().StrReverseOrder();
+ var pwd_str = password.StrAddSpan().StrReverseOrder();
+ var data_str = string.Join(" ", data);
+ var data_add33 = (Di0_3_str + " 02 " + pwd_str + " " + m + " " + data_str).StrAddHex33();
+ var frame = $"68 {address_str} 68 14 {L} {data_add33}";
+ string strSum = frame.Split(new string[] { " " }, StringSplitOptions.RemoveEmptyEntries).Select(i => Convert.ToInt32(i, 16)).Sum().ToString("X");
+ var cs = strSum.Substring(strSum.Length - 2);
+ return $"{frame} {cs} 16".Split(' ').ToList();
+ }
+
+ #endregion
+
+ ///
+ /// 标准 188协议阀控 WaterMeterSend
+ ///
+ ///
+ ///
+ ///
+ public static List Confirm188WaterValve(string address, bool state, string mtype = "10")
+ {
+ if (string.IsNullOrWhiteSpace(address)) return null;
+ var frm = $"68 {mtype} [00 00 00 00 00 00 00] 04 04 A0 17 00 {(state ? "55" : "99")} 21 16".Split(' ').ToList();
+ address = address.PadLeft(14, '0');
+ int n = 0;
+ for (int i = 7; i > 0; i--)
+ {
+ frm[i + 1] = address.Substring(n, 2);
+ n += 2;
+ }
+ frm[frm.Count - 2] = GetCRC(frm.Take(frm.Count - 2).ToList());
+ return frm;
+ }
+
+ 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();
+ }
+
}
}