RfidRailWayNo.cs 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257
  1. using System;
  2. using System.IO;
  3. using System.IO.Ports;
  4. using System.Threading;
  5. namespace RailLocalMeter
  6. {
  7. public class RfidRailWayNo
  8. {
  9. Log lg = Log.GetInstance();
  10. SerialPort serialPort1;
  11. bool blThreadFlag = false;
  12. private object obj = new object();
  13. private Thread mThread = null;
  14. /// <summary>
  15. /// comPara是配置文件中的comPara
  16. /// </summary>
  17. /// <param name="comPara"></param>
  18. public void StartThreadSweep(out string msg)
  19. {
  20. #region 串口采集配置
  21. Parity parity = Parity.None;
  22. switch (AppConfigCache.comParity)
  23. {
  24. case "ODD": parity = Parity.Odd; break;
  25. case "EVEN": parity = Parity.Even; break;
  26. default: break;
  27. }
  28. StopBits stopBits = StopBits.None;
  29. switch (AppConfigCache.comStopBits)
  30. {
  31. case "1": stopBits = StopBits.One; break;
  32. case "1.5": stopBits = StopBits.OnePointFive; break;
  33. case "2": stopBits = StopBits.Two; break;
  34. default: break;
  35. }
  36. serialPort1 = new SerialPort(AppConfigCache.comPort, AppConfigCache.comBaud, parity, AppConfigCache.comLength, stopBits);
  37. int icnt = 0;
  38. msg = "";
  39. while (!serialPort1.IsOpen)
  40. {
  41. try
  42. {
  43. icnt++;
  44. serialPort1.Open();
  45. }
  46. catch (Exception err)
  47. {
  48. lg.WriteLog(LogType.RfidLoc, $"打开串口失败,正重试{err.Message}");
  49. }
  50. System.Threading.Thread.Sleep(500);
  51. if (icnt > 5)
  52. {
  53. msg = "串口打开失败,请检查串口是否存在,且是否被占用";
  54. return;
  55. }
  56. }
  57. #endregion
  58. blThreadFlag = true;
  59. mThread = new Thread(new ThreadStart(ThreadSweepInfo));
  60. mThread.Start();
  61. }
  62. private byte[] ReadPort(byte[] sendData)
  63. {
  64. serialPort1.Write(sendData, 0, sendData.Length);
  65. Thread.Sleep(50);
  66. byte[] recData = new byte[serialPort1.BytesToRead];
  67. serialPort1.Read(recData, 0, recData.Length);
  68. return recData;
  69. }
  70. /// <summary>
  71. /// 扫码信息读取
  72. /// </summary>
  73. /// <returns></returns>
  74. private void ThreadSweepInfo()
  75. {
  76. try
  77. {
  78. bool isFirst = true;
  79. string strInfo = "", strTest = "", strOldNo = "";
  80. //int iDx = 0;
  81. //bool isRight = false;
  82. //string[] strS = new string[3] { "T", "G", "Q" };
  83. while (blThreadFlag)
  84. {
  85. lock (obj)
  86. {
  87. byte[] bt = ReadPort(new byte[] { 0x11 });
  88. string strtmp = System.Text.Encoding.UTF8.GetString(bt);
  89. if (!string.IsNullOrEmpty(strtmp))
  90. {
  91. if (isFirst)
  92. {
  93. strInfo = strtmp;
  94. isFirst = false;
  95. }
  96. else
  97. {
  98. strInfo += strtmp;
  99. if (strInfo.Length >= 20)
  100. {
  101. strOldNo = strInfo.Substring(0, 20);
  102. if (CacleCls.rfidCarNo != strOldNo)
  103. {
  104. CacleCls.rfidCarNo = strInfo.Substring(0,20);
  105. strOldNo = CacleCls.rfidCarNo;
  106. lg.WriteLog(LogType.RfidLoc, $"提供给界面的读卡器数据:{strInfo.Substring(0, 20)}");
  107. if (strInfo.Length > 20)
  108. strInfo = strInfo.Substring(20);
  109. else
  110. strInfo = "";
  111. }
  112. }
  113. }
  114. #region 注释
  115. /*
  116. strInfo += strtmp;
  117. if (strInfo.Length >= 40)
  118. {
  119. foreach (string s in strS)
  120. {
  121. iDx = strInfo.IndexOf(s);
  122. if (iDx >= 0 && (iDx + 20) < strInfo.Length)
  123. {
  124. string st = strInfo.Substring(strInfo.IndexOf(s), 20);
  125. string ms = strInfo.Substring((iDx + 20));
  126. if (st.Substring(0, ms.Length) == ms)
  127. {
  128. if (CacleCls.rfidCarNo != st)
  129. {
  130. CacleCls.rfidCarNo = st;
  131. lg.WriteLog(LogType.RfidLoc, $"提供给界面的读卡器数据:{st}");
  132. }
  133. isRight = true;
  134. break;
  135. }
  136. }
  137. }
  138. if (!isRight)
  139. {
  140. strInfo = "";
  141. iDx = 0;
  142. }
  143. }
  144. //*/
  145. /*
  146. if (strInfo == "")
  147. {
  148. if (strtmp.IndexOf("T") == 0 || strtmp.IndexOf("Q") == 0 || strtmp.IndexOf("G") == 0)
  149. {
  150. strInfo = strtmp;
  151. }
  152. else
  153. {
  154. strInfo = "";
  155. }
  156. }
  157. else if (strInfo.Length < 20)
  158. {
  159. strInfo += strtmp;
  160. if (strInfo.Length > 20) strInfo = strInfo.Substring(0, 20);
  161. }
  162. if (strInfo.Length == 20)
  163. {
  164. if (CacleCls.rfidCarNo != strInfo)
  165. {
  166. CacleCls.rfidCarNo = strInfo;
  167. lg.WriteLog(LogType.RfidLoc, $"提供给界面的读卡器数据:{strInfo}");
  168. }
  169. strInfo = "";
  170. }
  171. //*/
  172. /*
  173. if ((strtmp.IndexOf("T") == 0 || strtmp.IndexOf("Q") == 0 || strtmp.IndexOf("G") == 0) && strtmp.Length > 14)
  174. {
  175. if (CacleCls.rfidCarNo != strtmp && strtmp.Trim() != "")
  176. {
  177. CacleCls.rfidCarNo = strtmp;
  178. lg.WriteLog(LogType.RfidLoc, $"获取并提供给界面的读卡器数据:{strtmp}");
  179. }
  180. }
  181. else
  182. {
  183. lg.WriteLog(LogType.RfidLoc, $"读卡器读取的数据:{strtmp}");
  184. }
  185. //*/
  186. #endregion
  187. strTest += strtmp;
  188. if (strTest.Length >= 100)
  189. {
  190. lg.WriteLog(LogType.RfidLoc, $"读卡器读取的数据:{strTest}");
  191. strTest = "";
  192. }
  193. }
  194. else
  195. {
  196. isFirst = true;
  197. strInfo = "";
  198. }
  199. }
  200. }
  201. }
  202. catch (Exception exp)
  203. {
  204. lg.WriteLog(LogType.RfidLoc, $"读卡器数据读取异常:{exp.Message}");
  205. }
  206. }
  207. /// <summary>
  208. /// 关闭线程
  209. /// </summary>
  210. /// <returns></returns>
  211. public bool CloseThread()
  212. {
  213. try
  214. {
  215. blThreadFlag = false;
  216. Close();
  217. return true;
  218. }
  219. catch
  220. {
  221. return false;
  222. }
  223. }
  224. /// <summary>
  225. /// 关闭扫描枪
  226. /// </summary>
  227. private void Close()
  228. {
  229. lg.WriteLog(LogType.RfidLoc, $"读卡器关闭");
  230. if (serialPort1 != null && serialPort1.IsOpen) serialPort1.Close();
  231. }
  232. }
  233. }