OmronV640Tcp.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332
  1. using Aitex.Core.RT.Event;
  2. using Aitex.Core.RT.Log;
  3. using Aitex.Core.RT.SCCore;
  4. using MECF.Framework.Common.Communications;
  5. using MECF.Framework.RT.EquipmentLibrary.HardwareUnits.CarrierIdReaders.CarrierIDReaderBase;
  6. using MECF.Framework.RT.EquipmentLibrary.HardwareUnits.LoadPorts;
  7. using MECF.Framework.RT.EquipmentLibrary.HardwareUnits.LoadPorts.LoadPortBase;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Linq;
  11. using System.Text;
  12. using System.Text.RegularExpressions;
  13. using System.Threading;
  14. using System.Threading.Tasks;
  15. namespace MECF.Framework.RT.EquipmentLibrary.HardwareUnits.CarrierIdReaders.OmronV640
  16. {
  17. public class OmronV640Tcp:CIDReaderBaseDevice,IConnection
  18. {
  19. private string _scRoot;
  20. private DateTime _startTime;
  21. public OmronV640Tcp(string module,string name,string scRoot,LoadPortBaseDevice lp =null,int offset=0,int length=16,int readerIndex=1)
  22. :base(module,name,lp,readerIndex)
  23. {
  24. _scRoot = scRoot;
  25. _address = SC.GetStringValue($"{_scRoot}.{Name}.Address");
  26. Offset = offset;
  27. Length = length;
  28. _socket = new AsyncSocket(_address);
  29. _socket.OnDataChanged += new AsyncSocket.MessageHandler(OnDataChanged);
  30. _socket.OnErrorHappened += new AsyncSocket.ErrorHandler(OnErrorHandler);
  31. ConnectionManager.Instance.Subscribe($"{Name}", this);
  32. //int connecttime = 0;
  33. _socket.Connect(_address);
  34. //while(!_socket.IsConnected && connecttime++<retryMaxtime)
  35. //{
  36. // _socket.Connect(_address);
  37. // if (!_socket.IsConnected)
  38. // Thread.Sleep(1000);
  39. //}
  40. }
  41. private void OnErrorHandler(ErrorEventArgs args)
  42. {
  43. OnError();
  44. }
  45. private void OnDataChanged(string package)
  46. {
  47. try
  48. {
  49. Thread.Sleep(500);
  50. package = package.ToUpper();
  51. string[] msgs = Regex.Split(package, "\r");
  52. foreach (string msg in msgs)
  53. {
  54. if (msg.Length > 0)
  55. {
  56. string type = msg.Substring(0, 2);
  57. if (type != "00")
  58. {
  59. EV.PostAlarmLog("RFID", $"{Name} occurred error:{getErrMsg(type)}");
  60. if (DeviceState == CIDReaderStateEnum.ReadCarrierID)
  61. {
  62. OnCarrierIDReadFailed(type);
  63. }
  64. if (DeviceState == CIDReaderStateEnum.WriteCarrierID)
  65. {
  66. OnCarrierIDWriteFailed(type);
  67. }
  68. return;
  69. }
  70. if (DeviceState == CIDReaderStateEnum.ReadCarrierID)
  71. {
  72. string msgdata = msg.Substring(2, msg.Length - 2);
  73. string tempID = HEX2ASCII(msg);
  74. CarrierIDBeRead = tempID.Split('\0')[1].Replace("\0","");
  75. if (SC.ContainsItem("LoadPort.CarrierIdNeedTrimSpace") && SC.GetValue<bool>("LoadPort.CarrierIdNeedTrimSpace"))
  76. {
  77. CarrierIDBeRead = CarrierIDBeRead.Trim();
  78. }
  79. OnCarrierIDRead(CarrierIDBeRead);
  80. }
  81. if (DeviceState == CIDReaderStateEnum.WriteCarrierID)
  82. {
  83. OnCarrierIDWrite();
  84. }
  85. }
  86. }
  87. }
  88. catch (Exception ex)
  89. {
  90. LOG.Write(ex);
  91. }
  92. }
  93. protected override bool fStartReset(object[] param)
  94. {
  95. if (_socket.IsConnected)
  96. return true;
  97. else
  98. {
  99. _address = SC.GetStringValue($"{_scRoot}.{Name}.Address");
  100. _socket.Connect(_address);
  101. }
  102. return true;
  103. }
  104. protected override bool fMonitorReset(object[] param)
  105. {
  106. if(_socket.IsConnected)
  107. return true;
  108. else
  109. {
  110. _address = SC.GetStringValue($"{_scRoot}.{Name}.Address");
  111. _socket.Connect(_address);
  112. if (_socket.IsConnected)
  113. return true;
  114. }
  115. return false;
  116. }
  117. protected override bool fStartReadCarrierID(object[] param)
  118. {
  119. try
  120. {
  121. _startTime = DateTime.Now;
  122. int offset = 0;
  123. int length = 16;
  124. if (param != null)
  125. {
  126. offset = (int)param[0];
  127. length = (int)param[1];
  128. }
  129. CarrierIDStartPage = offset + 1;
  130. CarrierIDPageLength = length;
  131. string msgdata = string.Format("{0}{1}\r", "0100", GetPage(offset + 1, length));
  132. return _socket.Write(msgdata);
  133. }
  134. catch(Exception ex)
  135. {
  136. LOG.Write(ex);
  137. return false;
  138. }
  139. }
  140. protected override bool fStartWriteCarrierID(object[] param)
  141. {
  142. try
  143. {
  144. _startTime = DateTime.Now;
  145. CarrierIDToBeWriten = param[0].ToString();
  146. int offset = 0;
  147. int length = 16;
  148. if (param.Length == 3)
  149. {
  150. offset = (int)param[1];
  151. length = (int)param[2];
  152. }
  153. CarrierIDStartPage = offset + 1;
  154. CarrierIDPageLength = length;
  155. string msgdata = string.Format("{0}{1}{2}\r", "0200", GetPage(offset+1, length), ASCII2HEX(CarrierIDToBeWriten,length));
  156. return _socket.Write(msgdata);
  157. }
  158. catch(Exception ex)
  159. {
  160. LOG.Write(ex);
  161. return false;
  162. }
  163. }
  164. protected override bool fMonitorReadCarrierID(object[] param)
  165. {
  166. if (DateTime.Now - _startTime > TimeSpan.FromSeconds(10))
  167. {
  168. OnCarrierIDReadFailed("Timeout");
  169. return true;
  170. }
  171. return base.fMonitorReadCarrierID(param);
  172. }
  173. protected override bool fMonitorWriteCarrierID(object[] param)
  174. {
  175. if (DateTime.Now - _startTime > TimeSpan.FromSeconds(10))
  176. {
  177. OnCarrierIDWriteFailed("Timeout");
  178. return true;
  179. }
  180. return base.fMonitorReadCarrierID(param);
  181. }
  182. public string Address => _address;
  183. private string _address;
  184. private AsyncSocket _socket;
  185. public bool IsConnected =>_socket.IsConnected;
  186. public int Offset { get; private set; }
  187. public int Length { get; private set; }
  188. public bool Connect()
  189. {
  190. _socket.Connect(_address);
  191. return true;
  192. }
  193. public bool Disconnect()
  194. {
  195. _socket.Dispose();
  196. return true;
  197. }
  198. private string getErrMsg(string error)
  199. {
  200. string msg = "";
  201. switch (error)
  202. {
  203. case "14":
  204. msg = "Format error There is a mistake in the command format";
  205. break;
  206. case "70":
  207. msg = "Communications error Noise or another hindrance occurs during communications with an ID Tag, and communications cannot be completed normally.";
  208. break;
  209. case "71":
  210. msg = "Verification error Correct data cannot be written to an ID Tag";
  211. break;
  212. case "72":
  213. msg = "No Tag error Either there is no ID Tag in front of the CIDRW Head, or the CIDRW Head is unable to detect the ID Tag due to environmental factors";
  214. break;
  215. case "7B":
  216. msg = "Outside write area error A write operation was not completed normally because the ID Tag was in an area in which the ID Tag could be read but not written";
  217. break;
  218. case "7E":
  219. msg = "ID system error (1) The ID Tag is in a status where it cannot execute command processing";
  220. break;
  221. case "7F":
  222. msg = "ID system error (2) An inapplicable ID Tag has been used";
  223. break;
  224. case "9A":
  225. msg = "Hardware error in CPU An error occurred when writing to EEPROM.";
  226. break;
  227. }
  228. return msg;
  229. }
  230. public string HEX2ASCII(string hex)
  231. {
  232. string res = String.Empty;
  233. try
  234. {
  235. for (int a = 0; a < hex.Length; a = a + 2)
  236. {
  237. string Char2Convert = hex.Substring(a, 2);
  238. int n = Convert.ToInt32(Char2Convert, 16);
  239. char c = (char)n;
  240. res += c.ToString();
  241. }
  242. }
  243. catch (Exception e)
  244. {
  245. LOG.Write(e);
  246. }
  247. return res;
  248. }
  249. private string GetPage(int startpage, int length)
  250. {
  251. double dpage = 0;
  252. for (int i = 0; i < length; i++)
  253. {
  254. dpage = dpage + Math.Pow(2, startpage + 1 + i);
  255. }
  256. string pageret = String.Format("{0:X}", Convert.ToInt32(dpage));
  257. for (int j = pageret.Length; j < 8; j++)
  258. {
  259. pageret = "0" + pageret;
  260. }
  261. return pageret;
  262. }
  263. private string ASCII2HEX(string src,int length)
  264. {
  265. while (src.Length < length * 8)
  266. {
  267. src = src + '\0';
  268. }
  269. if (src.Length > length * 8)
  270. {
  271. src = src.Substring(0, length * 8);
  272. LOG.Write($"RFID support max {(length * 8).ToString()} characters");
  273. }
  274. string res = String.Empty;
  275. try
  276. {
  277. char[] charValues = src.ToCharArray();
  278. string hexOutput = "";
  279. foreach (char _eachChar in charValues)
  280. {
  281. // Get the integral value of the character.
  282. int value = Convert.ToInt32(_eachChar);
  283. // Convert the decimal value to a hexadecimal value in string form.
  284. hexOutput += String.Format("{0:X2}", value);
  285. // to make output as your eg
  286. // hexOutput +=" "+ String.Format("{0:X}", value);
  287. }
  288. return hexOutput;
  289. }
  290. catch (Exception e)
  291. {
  292. LOG.Write(e);
  293. }
  294. return res;
  295. }
  296. }
  297. }