CommonMessage.cs 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221
  1. using Edge.Core.Parser;
  2. using Edge.Core.Parser.BinaryParser.MessageEntity;
  3. using System.Runtime.InteropServices;
  4. namespace HengshanPaymentTerminal.MessageEntity
  5. {
  6. /// <summary>
  7. /// 与油机通讯的基础数据包对象
  8. /// </summary>
  9. public abstract class CommonMessage: MessageTemplateBase
  10. {
  11. public enum Command
  12. {
  13. /// <summary>
  14. /// 通用应答命令字
  15. /// </summary>
  16. COMMON = 0x55,
  17. /// <summary>
  18. /// 心跳命令字
  19. /// </summary>
  20. HEART_BRET = 0x10,
  21. /// <summary>
  22. /// 油枪信息命令字
  23. /// </summary>
  24. NOZZLE_INFO = 0x61,
  25. /// <summary>
  26. /// 油枪状态命令字
  27. /// </summary>
  28. NOZZLE_STATE = 0x62,
  29. /// <summary>
  30. /// 发送二维码给油机命令字
  31. /// </summary>
  32. SEND_QR_CODE = 0x63,
  33. /// <summary>
  34. /// 获取单价命令字
  35. /// </summary>
  36. GET_PRICE = 0x64,
  37. /// <summary>
  38. /// 授权命令字
  39. /// </summary>
  40. ACCREDIT = 0x65,
  41. /// <summary>
  42. /// 取消授权命令字
  43. /// </summary>
  44. CANCEL_ACCREDIT = 0x66,
  45. /// <summary>
  46. /// 接收油机订单命令字
  47. /// </summary>
  48. RECIEVE_TRANX = 0x18,
  49. /// <summary>
  50. /// 发送应付金额给油机命令字
  51. /// </summary>
  52. SEND_NEED_AMOUNT = 0x19
  53. }
  54. /// <summary>
  55. /// 包头 0xFA
  56. /// </summary>
  57. public Byte Head { get; set; }
  58. /// <summary>
  59. /// 目标地址
  60. /// </summary>
  61. public Byte DestinationAddr { get; set; }
  62. /// <summary>
  63. /// 源地址
  64. /// </summary>
  65. public Byte SourceAddr { get; set; }
  66. /// <summary>
  67. /// 帧号
  68. /// </summary>
  69. public int FrameNum { get; set; }
  70. /// <summary>
  71. /// 有效数据长度,标识油机数据包中,有效数据的长度
  72. /// </summary>
  73. public int DataLength { get; set; }
  74. /// <summary>
  75. /// 命令字,用来标识数据包传递的数据
  76. /// </summary>
  77. public Byte Handle { get; set; }
  78. /// <summary>
  79. /// crc 校验值
  80. /// </summary>
  81. public Byte[] CRC { get; set; }
  82. /// <summary>
  83. /// 是否为错误响应(与油机通讯协议无关)
  84. /// </summary>
  85. public bool IsError { get; set; } = false;
  86. /// <summary>
  87. /// 错误信息(与油机协议无关)
  88. /// </summary>
  89. public string ErrorMessage { get; set; }
  90. public CommonMessage getBaseData(byte[] data)
  91. {
  92. this.Handle = data[0];
  93. this.DestinationAddr = data[1];
  94. this.SourceAddr = data[2];
  95. this.FrameNum = data[3];
  96. this.DataLength = Bcd2Int(data[4], data[5]);
  97. this.Handle = data[6];
  98. this.CRC = new byte[]{ data[data.Length - 2],data[data.Length - 1] };
  99. return this;
  100. }
  101. /// <summary>
  102. /// 传入有效数据,拼接为要发送给油机包
  103. /// </summary>
  104. /// <param name="content"></param>
  105. /// <returns></returns>
  106. public byte[] content2data(byte[] content)
  107. {
  108. List<byte> list = new List<byte>();
  109. //目标地址,源地址,帧号
  110. byte[] head = new byte[] { this.SourceAddr, this.DestinationAddr, (byte)this.FrameNum };
  111. byte[] length = Int2BCD(content.Length);
  112. list.AddRange(head);
  113. list.AddRange(length);
  114. list.AddRange(content);
  115. byte[] crc = HengshanCRC16.ComputeChecksumToBytes(list.ToArray());
  116. list.AddRange(crc);
  117. List<byte> addFAList = addFA(list);
  118. addFAList.Insert(0,0xFA);
  119. return addFAList.ToArray();
  120. }
  121. public int Bcd2Int(byte byte1, byte byte2)
  122. {
  123. // 提取第一个字节的高四位和低四位
  124. int digit1 = (byte1 >> 4) & 0x0F; // 高四位
  125. int digit2 = byte1 & 0x0F; // 低四位
  126. // 提取第二个字节的高四位和低四位
  127. int digit3 = (byte2 >> 4) & 0x0F; // 高四位
  128. int digit4 = byte2 & 0x0F; // 低四位
  129. // 组合成一个整数
  130. int result = digit1 * 1000 + digit2 * 100 + digit3 * 10 + digit4;
  131. return result;
  132. }
  133. public byte[] Int2BCD(int number)
  134. {
  135. // 提取千位、百位、十位和个位
  136. int thousands = number / 1000;
  137. int hundreds = (number / 100) % 10;
  138. int tens = (number / 10) % 10;
  139. int units = number % 10;
  140. // 将千位和百位组合成一个字节(千位在高四位,百位在低四位)
  141. byte firstByte = (byte)((thousands * 16) + hundreds); // 乘以16相当于左移4位
  142. // 将十位和个位组合成一个字节(十位在高四位,个位在低四位)
  143. byte secondByte = (byte)((tens * 16) + units);
  144. // 返回结果数组
  145. return new byte[] { firstByte, secondByte };
  146. }
  147. /// <summary>
  148. /// 数组转数字
  149. /// </summary>
  150. /// <param name="datas">数组</param>
  151. /// <param name="startIndex">开始的截取的下标</param>
  152. /// <param name="length">截取长度</param>
  153. /// <returns></returns>
  154. public T Bytes2Number<T>(byte[] datas,int startIndex,int length) where T: unmanaged
  155. {
  156. Span<byte> span = datas.AsSpan(startIndex, length);
  157. if (BitConverter.IsLittleEndian) span.Reverse();
  158. return MemoryMarshal.Read<T>(span);
  159. }
  160. public List<Byte> addFA(List<Byte> list)
  161. {
  162. List<byte> result = new List<byte>();
  163. foreach (byte b in list)
  164. {
  165. if (b == 0xFA)
  166. {
  167. result.Add(0xFA);
  168. result.Add(0xFA);
  169. }
  170. else
  171. {
  172. result.Add(b);
  173. }
  174. }
  175. return result;
  176. }
  177. public DateTime? bytes2DateTime(byte[] timeBytes)
  178. {
  179. string formate = "yyyyMMddHHmmss";
  180. string timeStr = BitConverter.ToString(timeBytes).Replace("-", "");
  181. DateTime parsedDateTime;
  182. bool success = DateTime.TryParseExact(timeStr, formate, null, System.Globalization.DateTimeStyles.None, out parsedDateTime);
  183. return success ? parsedDateTime : null;
  184. }
  185. }
  186. }