TPacket.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using System.Net;
  5. using System.Net.Sockets;
  6. using System.IO;
  7. using System.Threading;
  8. using System.Runtime.Serialization.Formatters.Binary;
  9. using System.Runtime.InteropServices;
  10. using System.Reflection;
  11. namespace FPER
  12. {
  13. class Paket
  14. {// 데몬 데이터 패킷 클래스
  15. static byte[] RawSerialize(object anything)
  16. {// 패킷 Serialize 함수
  17. int rawsize = Marshal.SizeOf(anything);
  18. IntPtr buffer = Marshal.AllocHGlobal(rawsize);
  19. Marshal.StructureToPtr(anything, buffer, false);
  20. byte[] rawdatas = new byte[rawsize];
  21. Marshal.Copy(buffer, rawdatas, 0, rawsize);
  22. Marshal.FreeHGlobal(buffer);
  23. return rawdatas;
  24. }
  25. static object RawDeserialize(byte[] rawdatas, Type anytype)
  26. {// 패킷 Deserialize 함수
  27. object ret_obj;
  28. int rawsize = Marshal.SizeOf(anytype);
  29. if (rawsize > rawdatas.Length)
  30. return null;
  31. IntPtr buffer = Marshal.AllocHGlobal(rawsize);
  32. Marshal.Copy(rawdatas, 0, buffer, rawsize);
  33. ret_obj = Marshal.PtrToStructure(buffer, anytype);
  34. Marshal.FreeHGlobal(buffer);
  35. return ret_obj;
  36. }
  37. byte DoCalcs(byte[] bt, int size)
  38. {// cs 계산 함수
  39. byte ret_byte = 0x00;
  40. try
  41. {
  42. int counter = 0;
  43. do
  44. {
  45. ret_byte = (byte)(ret_byte ^ bt[counter]);
  46. ret_byte++;
  47. counter++;
  48. }
  49. while (counter < size);
  50. }
  51. catch (Exception ex)
  52. {
  53. Util.UErrorMessage(ex, 0, 0);
  54. }
  55. return ret_byte;
  56. }
  57. public int DoCheckcs(byte[] bt, int size, byte cs)
  58. {/// cs 체크 함수
  59. int ret = 0;
  60. try
  61. {
  62. byte calcs = 0x00;
  63. calcs = DoCalcs(bt, size);
  64. if (cs == calcs)
  65. {
  66. ret = 1;
  67. }
  68. else
  69. {
  70. ret = 0;
  71. }
  72. }
  73. catch (Exception ex)
  74. {
  75. Util.UErrorMessage(ex, 0, 0);
  76. }
  77. return ret;
  78. }
  79. public byte[] CreatePKT_SayHello_To_Board(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  80. {
  81. byte[] ret_byte_data = null;
  82. try
  83. {
  84. PRTReceiver_Type1 PKT = new PRTReceiver_Type1();
  85. int psize = (byte)default_value_define.size_PRTReceiver_Type1;
  86. PKT.head = (byte)default_value_define.prt_header_id;
  87. PKT.RPT_loop = RPT_loop;
  88. PKT.TBD_ID = TBD_ID;
  89. PKT.length = (byte)psize;
  90. PKT.cmd = (byte)prt_cmd_define.say_hello;
  91. PKT.IVK_ID = IVK_ID;
  92. PKT.RCVR_ID = RCV_ID;
  93. ret_byte_data = RawSerialize(PKT);
  94. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  95. }
  96. catch (Exception ex)
  97. {
  98. Util.UErrorMessage(ex, 0, 0);
  99. }
  100. return ret_byte_data;
  101. }
  102. public byte[] CreatePKT_ReadBoardStatus(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  103. {
  104. byte[] ret_byte_data = null;
  105. try
  106. {
  107. PRTReceiver_Type1 PKT = new PRTReceiver_Type1();
  108. int psize = (byte)default_value_define.size_PRTReceiver_Type1;
  109. PKT.head = (byte)default_value_define.prt_header_id;
  110. PKT.RPT_loop = RPT_loop;
  111. PKT.TBD_ID = TBD_ID;
  112. PKT.length = (byte)psize;
  113. PKT.cmd = (byte)prt_cmd_define.resd_tbd_state;
  114. PKT.IVK_ID = IVK_ID;
  115. PKT.RCVR_ID = RCV_ID;
  116. ret_byte_data = RawSerialize(PKT);
  117. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  118. }
  119. catch (Exception ex)
  120. {
  121. Util.UErrorMessage(ex, 0, 0);
  122. }
  123. return ret_byte_data;
  124. }
  125. public byte[] CreatePKT_WriteBoardStatus(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte RT_BaudRate, byte loop1_BaudRate, byte loop2_BaudRate, byte RT_Term, byte BD_Reset)
  126. { //2010.3.24_moon
  127. byte[] ret_byte_data = null;
  128. try
  129. {
  130. PRTReceiver_Type6 PKT = new PRTReceiver_Type6();
  131. int psize = (byte)default_value_define.size_PRTReceiver_Type6;
  132. PKT.head = (byte)default_value_define.prt_header_id;
  133. PKT.RPT_loop = RPT_loop;
  134. PKT.TBD_ID = TBD_ID;
  135. PKT.length = (byte)psize;
  136. PKT.cmd = (byte)prt_cmd_define.write_tbd_state;
  137. PKT.IVK_ID = IVK_ID;
  138. PKT.RCVR_ID = RCV_ID;
  139. PKT.Option1 = RT_BaudRate;
  140. PKT.Option2 = loop1_BaudRate;
  141. PKT.Option3 = loop2_BaudRate;
  142. PKT.Option4 = RT_Term;
  143. PKT.Option5 = BD_Reset;
  144. ret_byte_data = RawSerialize(PKT);
  145. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  146. }
  147. catch (Exception ex)
  148. {
  149. Util.UErrorMessage(ex, 0, 0);
  150. }
  151. return ret_byte_data;
  152. }
  153. public byte[] CreatePKT_SearchRepeaterUNIT(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID)
  154. {
  155. byte[] ret_byte_data = null;
  156. try
  157. {
  158. PRTReceiver_Type2 PKT = new PRTReceiver_Type2();
  159. int psize = (byte)default_value_define.size_PRTReceiver_Type2;
  160. PKT.head = (byte)default_value_define.prt_header_id;
  161. PKT.RPT_loop = RPT_loop;
  162. PKT.TBD_ID = TBD_ID;
  163. PKT.length = (byte)psize;
  164. PKT.cmd = (byte)prt_cmd_define.search_repeater_unit;
  165. PKT.IVK_ID = IVK_ID;
  166. PKT.RCVR_ID = RCV_ID;
  167. PKT.Option1 = Repeater_ID;
  168. ret_byte_data = RawSerialize(PKT);
  169. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  170. }
  171. catch (Exception ex)
  172. {
  173. Util.UErrorMessage(ex, 0, 0);
  174. }
  175. return ret_byte_data;
  176. }
  177. public byte[] CreatePKT_SearchRepeaterAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  178. {
  179. byte[] ret_byte_data = null;
  180. try
  181. {
  182. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  183. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  184. PKT.head = (byte)default_value_define.prt_header_id;
  185. PKT.RPT_loop = RPT_loop;
  186. PKT.TBD_ID = TBD_ID;
  187. PKT.length = (byte)psize;
  188. PKT.cmd = (byte)prt_cmd_define.search_repeater_all;
  189. PKT.IVK_ID = IVK_ID;
  190. PKT.RCVR_ID = RCV_ID;
  191. PKT.Option1 = 0xff; //2010.3.24_moon All
  192. PKT.Option2 = 0x00;
  193. ret_byte_data = RawSerialize(PKT);
  194. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  195. }
  196. catch (Exception ex)
  197. {
  198. Util.UErrorMessage(ex, 0, 0);
  199. }
  200. return ret_byte_data;
  201. }
  202. public byte[] CreatePKT_ReadRepeaterPointAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  203. {
  204. byte[] ret_byte_data = null;
  205. try
  206. {
  207. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  208. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  209. PKT.head = (byte)default_value_define.prt_header_id;
  210. PKT.RPT_loop = RPT_loop;
  211. PKT.TBD_ID = TBD_ID;
  212. PKT.length = (byte)psize;
  213. PKT.cmd = (byte)prt_cmd_define.read_repeater_all;
  214. PKT.IVK_ID = IVK_ID;
  215. PKT.RCVR_ID = RCV_ID;
  216. PKT.Option1 = 0xff; //2010.3.24_moon All
  217. PKT.Option2 = 0x00;
  218. ret_byte_data = RawSerialize(PKT);
  219. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  220. }
  221. catch (Exception ex)
  222. {
  223. Util.UErrorMessage(ex, 0, 0);
  224. }
  225. return ret_byte_data;
  226. }
  227. public byte[] CreatePKT_WriteRepeaterOutputUNIT(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID, byte Repeater_Out_Value)
  228. {
  229. byte[] ret_byte_data = null;
  230. try
  231. {
  232. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  233. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  234. PKT.head = (byte)default_value_define.prt_header_id;
  235. PKT.RPT_loop = RPT_loop;
  236. PKT.TBD_ID = TBD_ID;
  237. PKT.length = (byte)psize;
  238. PKT.cmd = (byte)prt_cmd_define.write_repeater_output_unit;
  239. PKT.IVK_ID = IVK_ID;
  240. PKT.RCVR_ID = RCV_ID;
  241. PKT.Option1 = Repeater_ID;
  242. PKT.Option2 = Repeater_Out_Value;
  243. ret_byte_data = RawSerialize(PKT);
  244. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  245. }
  246. catch (Exception ex)
  247. {
  248. Util.UErrorMessage(ex, 0, 0);
  249. }
  250. return ret_byte_data;
  251. }
  252. public byte[] CreatePKT_ReadRepeaterInfoAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  253. {
  254. byte[] ret_byte_data = null;
  255. try
  256. {
  257. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  258. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  259. PKT.head = (byte)default_value_define.prt_header_id;
  260. PKT.RPT_loop = RPT_loop;
  261. PKT.TBD_ID = TBD_ID;
  262. PKT.length = (byte)psize;
  263. PKT.cmd = (byte)prt_cmd_define.read_repeater_info_all;
  264. PKT.IVK_ID = IVK_ID;
  265. PKT.RCVR_ID = RCV_ID;
  266. PKT.Option1 = 0xff; //2010.3.24_moon All
  267. PKT.Option2 = 0x00;
  268. ret_byte_data = RawSerialize(PKT);
  269. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  270. }
  271. catch (Exception ex)
  272. {
  273. Util.UErrorMessage(ex, 0, 0);
  274. }
  275. return ret_byte_data;
  276. }
  277. public byte[] CreatePKT_WriteRepeaterInfoUNIT(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID, byte Repeater_Out_Value)
  278. {
  279. byte[] ret_byte_data = null;
  280. try
  281. {
  282. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  283. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  284. PKT.head = (byte)default_value_define.prt_header_id;
  285. PKT.RPT_loop = RPT_loop;
  286. PKT.TBD_ID = TBD_ID;
  287. PKT.length = (byte)psize;
  288. PKT.cmd = (byte)prt_cmd_define.write_repeater_info_unit;
  289. PKT.IVK_ID = IVK_ID;
  290. PKT.RCVR_ID = RCV_ID;
  291. PKT.Option1 = Repeater_ID;
  292. PKT.Option2 = Repeater_Out_Value;
  293. ret_byte_data = RawSerialize(PKT);
  294. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  295. }
  296. catch (Exception ex)
  297. {
  298. Util.UErrorMessage(ex, 0, 0);
  299. }
  300. return ret_byte_data;
  301. }
  302. //2010.12.05, k.s.d, repeater information block write.
  303. public byte[] CreatePKT_WriteRepeaterInfoAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID, RepeaterDataAll Repeater_Out_Value)
  304. {
  305. int psize = (byte)default_value_define.size_PRTReceiver_Type7;
  306. byte[] PKT = new byte[psize + 1];
  307. try
  308. {
  309. PKT[0] = (byte)default_value_define.prt_header_id;
  310. PKT[1] = RPT_loop;
  311. PKT[2] = TBD_ID;
  312. PKT[3] = (byte)psize;
  313. PKT[4] = (byte)prt_cmd_define.write_repeater_info_all;
  314. PKT[5] = IVK_ID;
  315. PKT[6] = RCV_ID;
  316. PKT[7] = 0x01;
  317. PKT[8] = 127;
  318. //PKT[7] = Repeater_ID;
  319. for (int i = 0; i < 127; i++)
  320. {
  321. PKT[9 + i] = Repeater_Out_Value.Data[i].Repeater_Info;
  322. }
  323. //ret_byte_data = PKT;
  324. PKT[psize] = DoCalcs(PKT, psize);
  325. }
  326. catch (Exception ex)
  327. {
  328. Util.UErrorMessage(ex, 0, 0);
  329. }
  330. return PKT;
  331. }
  332. public byte[] CreatePKT_ResetRepeaterUNIT(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID)
  333. {
  334. byte[] ret_byte_data = null;
  335. try
  336. {
  337. PRTReceiver_Type2 PKT = new PRTReceiver_Type2();
  338. int psize = (byte)default_value_define.size_PRTReceiver_Type2;
  339. PKT.head = (byte)default_value_define.prt_header_id;
  340. PKT.RPT_loop = RPT_loop;
  341. PKT.TBD_ID = TBD_ID;
  342. PKT.length = (byte)psize;
  343. PKT.cmd = (byte)prt_cmd_define.reset_repeater_unit;
  344. PKT.IVK_ID = IVK_ID;
  345. PKT.RCVR_ID = RCV_ID;
  346. PKT.Option1 = Repeater_ID;
  347. ret_byte_data = RawSerialize(PKT);
  348. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  349. }
  350. catch (Exception ex)
  351. {
  352. Util.UErrorMessage(ex, 0, 0);
  353. }
  354. return ret_byte_data;
  355. }
  356. // 중계기 모두 복구
  357. public byte[] CreatePKT_ResetRepeaterAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID)
  358. {
  359. byte[] ret_byte_data = null;
  360. try
  361. {
  362. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  363. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  364. PKT.head = (byte)default_value_define.prt_header_id;
  365. PKT.RPT_loop = RPT_loop;
  366. PKT.TBD_ID = TBD_ID;
  367. PKT.length = (byte)psize;
  368. PKT.cmd = (byte)prt_cmd_define.reset_repeater_all;
  369. PKT.IVK_ID = IVK_ID;
  370. PKT.RCVR_ID = RCV_ID;
  371. PKT.Option1 = 0xff; //2010.3.24_moon All
  372. PKT.Option2 = 0x00;
  373. ret_byte_data = RawSerialize(PKT);
  374. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  375. }
  376. catch (Exception ex)
  377. {
  378. Util.UErrorMessage(ex, 0, 0);
  379. }
  380. return ret_byte_data;
  381. }
  382. // cyim 2013.3.13
  383. // 입력쓰기 테스트 이후 복구 버튼을 눌러서 중계기 별로 복구하도록 명령한다
  384. // Function Overload : 중계기를 지정하여 복구
  385. public byte[] CreatePKT_ResetRepeaterAll(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID)
  386. {
  387. byte[] ret_byte_data = null;
  388. try
  389. {
  390. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  391. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  392. PKT.head = (byte)default_value_define.prt_header_id;
  393. PKT.RPT_loop = RPT_loop;
  394. PKT.TBD_ID = TBD_ID;
  395. PKT.length = (byte)psize;
  396. PKT.cmd = (byte)prt_cmd_define.reset_repeater_all;
  397. PKT.IVK_ID = IVK_ID;
  398. PKT.RCVR_ID = RCV_ID;
  399. PKT.Option1 = Repeater_ID; // cyim 2013.3.13
  400. PKT.Option2 = 0x01;
  401. ret_byte_data = RawSerialize(PKT);
  402. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  403. }
  404. catch (Exception ex)
  405. {
  406. Util.UErrorMessage(ex, 0, 0);
  407. }
  408. return ret_byte_data;
  409. }
  410. public byte[] CreatePKT_WriteRepeaterInputUNIT(byte RPT_loop, byte TBD_ID, byte IVK_ID, byte RCV_ID, byte Repeater_ID, byte Repeater_In_Value)
  411. {
  412. byte[] ret_byte_data = null;
  413. try
  414. {
  415. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  416. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  417. PKT.head = (byte)default_value_define.prt_header_id;
  418. PKT.RPT_loop = RPT_loop;
  419. PKT.TBD_ID = TBD_ID;
  420. PKT.length = (byte)psize;
  421. PKT.cmd = (byte)prt_cmd_define.write_repeater_input_unit;
  422. PKT.IVK_ID = IVK_ID;
  423. PKT.RCVR_ID = RCV_ID;
  424. PKT.Option1 = Repeater_ID;
  425. PKT.Option2 = Repeater_In_Value;
  426. ret_byte_data = RawSerialize(PKT);
  427. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  428. }
  429. catch (Exception ex)
  430. {
  431. Util.UErrorMessage(ex, 0, 0);
  432. }
  433. return ret_byte_data;
  434. }
  435. public byte[] CreatePKT_SayHello_To_IOBoard(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID)
  436. {
  437. byte[] ret_byte_data = null;
  438. try
  439. {
  440. PRTIO_Type1 PKT = new PRTIO_Type1();
  441. int psize = (byte)default_value_define.size_PRTIO_Type1;
  442. PKT.head = (byte)default_value_define.prt_header_id;
  443. PKT.RPT_loop = RPT_loop;
  444. PKT.BD_ID = IOBD_ID;
  445. PKT.length = (byte)psize;
  446. PKT.cmd = (byte)prt_cmd_define.sayhello_to_ioboard;
  447. PKT.IVK_ID = IVK_ID;
  448. PKT.RCVR_ID = RCV_ID;
  449. ret_byte_data = RawSerialize(PKT);
  450. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  451. }
  452. catch (Exception ex)
  453. {
  454. Util.UErrorMessage(ex, 0, 0);
  455. }
  456. return ret_byte_data;
  457. }
  458. public byte[] CreatePKT_ReadIOBoardStatus(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID)
  459. {
  460. byte[] ret_byte_data = null;
  461. try
  462. {
  463. PRTIO_Type1 PKT = new PRTIO_Type1();
  464. int psize = (byte)default_value_define.size_PRTIO_Type1;
  465. PKT.head = (byte)default_value_define.prt_header_id;
  466. PKT.RPT_loop = RPT_loop;
  467. PKT.BD_ID = IOBD_ID;
  468. PKT.length = (byte)psize;
  469. PKT.cmd = (byte)prt_cmd_define.read_ioboard_status;
  470. PKT.IVK_ID = IVK_ID;
  471. PKT.RCVR_ID = RCV_ID;
  472. ret_byte_data = RawSerialize(PKT);
  473. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  474. }
  475. catch (Exception ex)
  476. {
  477. Util.UErrorMessage(ex, 0, 0);
  478. }
  479. return ret_byte_data;
  480. }
  481. public byte[] CreatePKT_WriteIOBoardStatus(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID, byte Brate, byte BD_Reset)
  482. {
  483. byte[] ret_byte_data = null;
  484. try
  485. {
  486. PRTIO_Type3 PKT = new PRTIO_Type3();
  487. int psize = (byte)default_value_define.size_PRTIO_Type3;
  488. PKT.head = (byte)default_value_define.prt_header_id;
  489. PKT.RPT_loop = RPT_loop;
  490. PKT.BD_ID = IOBD_ID;
  491. PKT.length = (byte)psize;
  492. PKT.cmd = (byte)prt_cmd_define.write_ioboard_status;
  493. PKT.IVK_ID = IVK_ID;
  494. PKT.RCVR_ID = RCV_ID;
  495. PKT.Option1 = Brate;
  496. PKT.Option2 = BD_Reset;
  497. ret_byte_data = RawSerialize(PKT);
  498. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  499. }
  500. catch (Exception ex)
  501. {
  502. Util.UErrorMessage(ex, 0, 0);
  503. }
  504. return ret_byte_data;
  505. }
  506. public byte[] CreatePKT_ReadIOBoardData(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID)
  507. {
  508. byte[] ret_byte_data = null;
  509. try
  510. {
  511. PRTIO_Type1 PKT = new PRTIO_Type1();
  512. int psize = (byte)default_value_define.size_PRTIO_Type1;
  513. PKT.head = (byte)default_value_define.prt_header_id;
  514. PKT.RPT_loop = RPT_loop;
  515. PKT.BD_ID = IOBD_ID;
  516. PKT.length = (byte)psize;
  517. PKT.cmd = (byte)prt_cmd_define.read_ioboard_data;
  518. PKT.IVK_ID = IVK_ID;
  519. PKT.RCVR_ID = RCV_ID;
  520. ret_byte_data = RawSerialize(PKT);
  521. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  522. }
  523. catch (Exception ex)
  524. {
  525. Util.UErrorMessage(ex, 0, 0);
  526. }
  527. return ret_byte_data;
  528. }
  529. public byte[] CreatePKT_WriteIOBoardData(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID, byte dbyte_outpoint, byte ubyte_outpoint)
  530. {
  531. byte[] ret_byte_data = null;
  532. try
  533. {
  534. PRTIO_Type3 PKT = new PRTIO_Type3();
  535. int psize = (byte)default_value_define.size_PRTIO_Type3;
  536. PKT.head = (byte)default_value_define.prt_header_id;
  537. PKT.RPT_loop = RPT_loop;
  538. PKT.BD_ID = IOBD_ID;
  539. PKT.length = (byte)psize;
  540. PKT.cmd = (byte)prt_cmd_define.write_ioboard_data;
  541. PKT.IVK_ID = IVK_ID;
  542. PKT.RCVR_ID = RCV_ID;
  543. PKT.Option1 = dbyte_outpoint;
  544. PKT.Option2 = ubyte_outpoint;
  545. ret_byte_data = RawSerialize(PKT);
  546. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  547. }
  548. catch (Exception ex)
  549. {
  550. Util.UErrorMessage(ex, 0, 0);
  551. }
  552. return ret_byte_data;
  553. }
  554. public byte[] CreatePKT_ReadIOBoardPointData(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID, byte POINT_ID)
  555. {
  556. byte[] ret_byte_data = null;
  557. try
  558. {
  559. PRTIO_Type2 PKT = new PRTIO_Type2();
  560. int psize = (byte)default_value_define.size_PRTIO_Type1;
  561. PKT.head = (byte)default_value_define.prt_header_id;
  562. PKT.RPT_loop = RPT_loop;
  563. PKT.BD_ID = IOBD_ID;
  564. PKT.length = (byte)psize;
  565. PKT.cmd = (byte)prt_cmd_define.read_ioboard_point_data;
  566. PKT.IVK_ID = IVK_ID;
  567. PKT.Option1 = POINT_ID;
  568. PKT.RCVR_ID = RCV_ID;
  569. ret_byte_data = RawSerialize(PKT);
  570. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  571. }
  572. catch (Exception ex)
  573. {
  574. Util.UErrorMessage(ex, 0, 0);
  575. }
  576. return ret_byte_data;
  577. }
  578. public byte[] CreatePKT_WriteIOBoardPointData(byte RPT_loop, byte IOBD_ID, byte IVK_ID, byte RCV_ID, byte POINT_ID, byte POINT_STATUS)
  579. {
  580. byte[] ret_byte_data = null;
  581. try
  582. {
  583. PRTIO_Type3 PKT = new PRTIO_Type3();
  584. int psize = (byte)default_value_define.size_PRTIO_Type3;
  585. PKT.head = (byte)default_value_define.prt_header_id;
  586. PKT.RPT_loop = RPT_loop;
  587. PKT.BD_ID = IOBD_ID;
  588. PKT.length = (byte)psize;
  589. PKT.cmd = (byte)prt_cmd_define.write_ioboard_point_data;
  590. PKT.IVK_ID = IVK_ID;
  591. PKT.RCVR_ID = RCV_ID;
  592. PKT.Option1 = (byte)(0x7F + POINT_ID);
  593. PKT.Option2 = POINT_STATUS;
  594. ret_byte_data = RawSerialize(PKT);
  595. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  596. }
  597. catch (Exception ex)
  598. {
  599. Util.UErrorMessage(ex, 0, 0);
  600. }
  601. return ret_byte_data;
  602. }
  603. public byte[] CreatePKT_SayHello_To_Demon(byte IVK_ID, byte RCV_ID)
  604. {
  605. byte[] ret_byte_data = null;
  606. try
  607. {
  608. PRTDemon_Type1 PKT = new PRTDemon_Type1();
  609. int psize = (byte)default_value_define.size_PRTDemon_Type1;
  610. PKT.head = (byte)default_value_define.prt_header_id;
  611. PKT.RPT_loop = 0x00;
  612. PKT.BD_ID = 0x00;
  613. PKT.length = (byte)psize;
  614. PKT.cmd = (byte)prt_cmd_define.sayhello_to_demon;
  615. PKT.IVK_ID = IVK_ID;
  616. PKT.RCVR_ID = RCV_ID;
  617. ret_byte_data = RawSerialize(PKT);
  618. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  619. }
  620. catch (Exception ex)
  621. {
  622. Util.UErrorMessage(ex, 0, 0);
  623. }
  624. return ret_byte_data;
  625. }
  626. public byte[] CreatePKT_StartPolling(byte IVK_ID, byte RCV_ID)
  627. {
  628. byte[] ret_byte_data = null;
  629. try
  630. {
  631. PRTDemon_Type1 PKT = new PRTDemon_Type1();
  632. int psize = (byte)default_value_define.size_PRTDemon_Type1;
  633. PKT.head = (byte)default_value_define.prt_header_id;
  634. PKT.RPT_loop = 0x00;
  635. PKT.BD_ID = 0x00;
  636. PKT.length = (byte)psize;
  637. PKT.cmd = (byte)prt_cmd_define.start_polling;
  638. PKT.IVK_ID = IVK_ID;
  639. PKT.RCVR_ID = RCV_ID;
  640. ret_byte_data = RawSerialize(PKT);
  641. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  642. }
  643. catch (Exception ex)
  644. {
  645. Util.UErrorMessage(ex, 0, 0);
  646. }
  647. return ret_byte_data;
  648. }
  649. public byte[] CreatePKT_StopPolling(byte IVK_ID, byte RCV_ID)
  650. {
  651. byte[] ret_byte_data = null;
  652. try
  653. {
  654. PRTDemon_Type1 PKT = new PRTDemon_Type1();
  655. int psize = (byte)default_value_define.size_PRTDemon_Type1;
  656. PKT.head = (byte)default_value_define.prt_header_id;
  657. PKT.RPT_loop = 0x00;
  658. PKT.BD_ID = 0x00;
  659. PKT.length = (byte)psize;
  660. PKT.cmd = (byte)prt_cmd_define.stop_polling;
  661. PKT.IVK_ID = IVK_ID;
  662. PKT.RCVR_ID = RCV_ID;
  663. ret_byte_data = RawSerialize(PKT);
  664. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  665. }
  666. catch (Exception ex)
  667. {
  668. Util.UErrorMessage(ex, 0, 0);
  669. }
  670. return ret_byte_data;
  671. }
  672. public byte[] CreatePKT_ReadDemonStatus(byte IVK_ID, byte RCV_ID)
  673. {
  674. byte[] ret_byte_data = null;
  675. try
  676. {
  677. PRTDemon_Type1 PKT = new PRTDemon_Type1();
  678. int psize = (byte)default_value_define.size_PRTDemon_Type1;
  679. PKT.head = (byte)default_value_define.prt_header_id;
  680. PKT.RPT_loop = 0x00;
  681. PKT.BD_ID = 0x00;
  682. PKT.length = (byte)psize;
  683. PKT.cmd = (byte)prt_cmd_define.read_demon_status;
  684. PKT.IVK_ID = IVK_ID;
  685. PKT.RCVR_ID = RCV_ID;
  686. ret_byte_data = RawSerialize(PKT);
  687. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  688. }
  689. catch (Exception ex)
  690. {
  691. Util.UErrorMessage(ex, 0, 0);
  692. }
  693. return ret_byte_data;
  694. }
  695. public byte[] CreatePKT_Notify_DBUpdated(byte IVK_ID, byte RCV_ID)
  696. {
  697. byte[] ret_byte_data = null;
  698. try
  699. {
  700. PRTDemon_Type1 PKT = new PRTDemon_Type1();
  701. int psize = (byte)default_value_define.size_PRTDemon_Type1;
  702. PKT.head = (byte)default_value_define.prt_header_id;
  703. PKT.RPT_loop = 0x00;
  704. PKT.BD_ID = 0x00;
  705. PKT.length = (byte)psize;
  706. PKT.cmd = (byte)prt_cmd_define.notify_db_update;
  707. PKT.IVK_ID = IVK_ID;
  708. PKT.RCVR_ID = RCV_ID;
  709. ret_byte_data = RawSerialize(PKT);
  710. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  711. }
  712. catch (Exception ex)
  713. {
  714. Util.UErrorMessage(ex, 0, 0);
  715. }
  716. return ret_byte_data;
  717. }
  718. //누적카운트 읽기 명령 byte생성
  719. public byte[] CreatePKT_ReadCommandStatus(byte IVK_ID, byte RCV_ID, int LoopNo, int BoardID, int repeaterID, int address, Char inOut
  720. , Char CommandType1, Char CommandType2, Char SubType, Char ApplyRange, int Status, int commid)
  721. {
  722. byte[] ret_byte_data = null;
  723. try
  724. {
  725. PRTReceiver_Type_CommandStatus PKT = new PRTReceiver_Type_CommandStatus();
  726. int psize = 16;
  727. PKT.head = (byte)default_value_define.prt_header_id; //0x02
  728. PKT.RPT_loop = (byte)LoopNo; //ID 하위 바이트 (Loop 번호)
  729. PKT.TBD_ID = (byte)BoardID; //ID 상위 바이트 (통신보드 ID)
  730. PKT.length = (byte)psize; //0x0D, 전체 Packet 길이
  731. PKT.cmd = (byte)prt_cmd_define.read_command_status;
  732. PKT.IVK_ID = IVK_ID; //Invoke ID
  733. PKT.RCVR_ID = RCV_ID;
  734. PKT.RepeaterID = (byte)repeaterID;
  735. PKT.Address = (byte)address;
  736. PKT.InOut = (byte)inOut;
  737. PKT.CommId = (byte)commid;
  738. PKT.CommandType1 = (byte)CommandType1;
  739. PKT.CommandType2 = (byte)CommandType2;
  740. PKT.SubType = (byte)SubType;
  741. PKT.ApplyRange = (byte)ApplyRange;
  742. PKT.Status = (byte)Status;
  743. ret_byte_data = RawSerialize(PKT);
  744. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize); //cs
  745. }
  746. catch (Exception ex)
  747. {
  748. Util.UErrorMessage(ex, 0, 0);
  749. }
  750. return ret_byte_data;
  751. }
  752. // cyim 2015.6.29 아날로그감지기 레벨값 쓰기 명령 프로토콜 추가
  753. public byte[] CreatePKT_AnalogDetecterLevel_Write(byte IVK_ID, byte RCV_ID, int LoopNo, int BoardID, int repeaterID, byte Fault, byte PreFire, byte FireNight, byte FireDay)
  754. {
  755. byte[] ret_byte_data = null;
  756. try
  757. {
  758. PRTReceiver_Type_AnalogDetecterLevel PKT = new PRTReceiver_Type_AnalogDetecterLevel();
  759. int psize = (byte)default_value_define.size_PRTWrite_AnalogDetecter_Level;
  760. PKT.head = (byte)default_value_define.prt_header_id;
  761. PKT.RPT_loop = (byte)LoopNo;
  762. PKT.TBD_ID = (byte)BoardID;
  763. PKT.length = (byte)psize;
  764. PKT.cmd = (byte)prt_cmd_define.write_analogdetecter_level;
  765. PKT.IVK_ID = IVK_ID;
  766. PKT.RCVR_ID = RCV_ID;
  767. PKT.RepeaterID = (byte)repeaterID;
  768. PKT.Fault = Fault;
  769. PKT.PreFire = PreFire;
  770. PKT.FireNight = FireNight;
  771. PKT.FireDay = FireDay;
  772. ret_byte_data = RawSerialize(PKT);
  773. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  774. }
  775. catch (Exception ex)
  776. {
  777. Util.UErrorMessage(ex, 0, 0);
  778. }
  779. return ret_byte_data;
  780. }
  781. // cyim 2016.10.27 : 대용량 수신기 아날로그 감지기 트랜드 읽기
  782. public byte[] CreatePKT_AnalogDetecterTrend_Read(byte IVK_ID, byte RCV_ID, int LoopNo, int BoardID, int repeaterID)
  783. {
  784. byte[] ret_byte_data = null;
  785. try
  786. {
  787. PRTReceiver_Type_AnalogDetecterTrend PKT = new PRTReceiver_Type_AnalogDetecterTrend();
  788. int psize = (byte)default_value_define.size_PRTReceiver_Type_AnalogDetecterTrend;
  789. PKT.head = (byte)default_value_define.prt_header_id;
  790. PKT.RPT_loop = (byte)LoopNo;
  791. PKT.TBD_ID = (byte)BoardID;
  792. PKT.length = (byte)psize;
  793. PKT.cmd = (byte)prt_cmd_define.read_analogdetecter_trend;
  794. PKT.IVK_ID = IVK_ID;
  795. PKT.RCVR_ID = RCV_ID;
  796. PKT.RepeaterID = (byte)repeaterID;
  797. ret_byte_data = RawSerialize(PKT);
  798. ret_byte_data[psize] = DoCalcs(ret_byte_data, psize);
  799. }
  800. catch (Exception ex)
  801. {
  802. Util.UErrorMessage(ex, 0, 0);
  803. }
  804. return ret_byte_data;
  805. }
  806. // LCH 2018.02.27 : 수정됨
  807. // cyim 2016.10.28 : 대용량 수신기 아날로그 감지기 레벨 Block 쓰기
  808. public byte[] CreatePKT_AnalogDetecterLevel_WriteAll(byte IVK_ID, byte RCV_ID, byte RPT_loop, byte TBD_ID, RepeaterDataAll AnalogDetecter)
  809. {
  810. int cnt = 0;
  811. for (int i = 0; i < 127; i++)
  812. {
  813. if (AnalogDetecter.Data[i].AnalogDetecter == true)
  814. {
  815. cnt++;
  816. }
  817. }
  818. // 아날로그 감지기 개수에 따라 패킷길이가 틀려지는 가변 패킷이다!
  819. // Length : 1개 라면 12, 2개 라면 17 (7 + 5n)
  820. //int psize = (byte)(7 + 5 * cnt);
  821. int psize = 9 + (5 * cnt);
  822. byte[] PKT = new byte[psize + 1];
  823. // 확장길이 구하는 방법
  824. //int a = 300;
  825. //byte b = ((byte)(a >> 0)); // 하위 : 0x2C
  826. //byte c = ((byte)(a >> 8)); // 상위 : 0x01
  827. try
  828. {
  829. PKT[0] = (byte)default_value_define.prt_header_id;
  830. PKT[1] = RPT_loop;
  831. PKT[2] = TBD_ID;
  832. PKT[3] = 0x00; // 확장길이 사용 -> 300 이면 hex 값으로 0x012C 이며, 상위 0x01, 하위 0x2C 이다
  833. PKT[4] = (byte)prt_cmd_define.write_analogdetecter_level_all;
  834. PKT[5] = ((byte)(psize >> 0)); // 하위
  835. PKT[6] = ((byte)(psize >> 8)); // 상위
  836. PKT[7] = IVK_ID;
  837. PKT[8] = RCV_ID;
  838. cnt = 0;
  839. for (int i = 0; i < 127; i++)
  840. {
  841. if (AnalogDetecter.Data[i].AnalogDetecter == true)
  842. {
  843. int index = 9 + (5 * cnt);
  844. PKT[index + 0] = (byte)(i + 1);// 아날로그 감지기 아이디
  845. PKT[index + 1] = AnalogDetecter.Data[i].AnalogDetecterFault;
  846. PKT[index + 2] = AnalogDetecter.Data[i].AnalogDetecterPreFire;
  847. PKT[index + 3] = AnalogDetecter.Data[i].AnalogDetecterFireNight;
  848. PKT[index + 4] = AnalogDetecter.Data[i].AnalogDetecterFireDay;
  849. cnt++;
  850. }
  851. }
  852. PKT[psize] = DoCalcs(PKT, psize);
  853. }
  854. catch (Exception ex)
  855. {
  856. Util.UErrorMessage(ex, 0, 0);
  857. }
  858. return PKT;
  859. }
  860. }
  861. }