Tprotocol_20100331.cs 61 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934
  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. using System.Diagnostics;
  12. namespace FPER {
  13. public enum default_value_define : byte {
  14. prt_header_id = 0x02,
  15. size_PRTReceiver_Type1 = 0x08,
  16. size_PRTReceiver_Type2 = 0x09,
  17. size_PRTReceiver_Type3 = 0x0A,
  18. size_PRTReceiver_Type4 = 0x0B,
  19. size_PRTReceiver_Type5 = 0x0C,
  20. size_PRTReceiver_Type6 = 0x0D
  21. }
  22. public enum CMD_define : byte {
  23. say_hello = 0x01,
  24. resd_tbd_state = 0x05,
  25. write_tbd_state = 0x06,
  26. search_repeater_all = 0x12,
  27. read_repeater_all = 0x14,
  28. write_repeater_output_unit = 0x15,
  29. read_repeater_info_all = 0x18,
  30. write_repeater_info_unit = 0x19,
  31. reset_repeater_unit = 0x1B,
  32. reset_repeater_all = 0x1C,
  33. write_repeater_input_unit = 0x1D
  34. }
  35. public enum RES_define : byte {
  36. general_ack = 0x81,
  37. general_nack = 0x80,
  38. say_hello = 0x81,
  39. resd_tbd_state = 0x85,
  40. write_tbd_state = 0x86,
  41. search_repeater_all = general_ack,
  42. read_repeater_all = 0x94,
  43. write_repeater_output_unit = 0x95,
  44. read_repeater_info_all = 0x98,
  45. write_repeater_info_unit = 0x99,
  46. reset_repeater_unit = general_ack,
  47. reset_repeater_all = general_ack,
  48. write_repeater_input_unit = 0x1D
  49. }
  50. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  51. public struct PRTReceiver_Type1 {
  52. public byte head;
  53. public byte RPT_loop;
  54. public byte TBD_ID;
  55. public byte length;
  56. public byte cmd;
  57. public byte IVK_ID;
  58. public byte RCVR_ID;
  59. public byte TBD_loop;
  60. public byte cs;
  61. }
  62. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  63. public struct PRTReceiver_Type2 {
  64. public byte head;
  65. public byte RPT_loop;
  66. public byte TBD_ID;
  67. public byte length;
  68. public byte cmd;
  69. public byte IVK_ID;
  70. public byte RCVR_ID;
  71. public byte TBD_loop;
  72. public byte Option1;
  73. public byte cs;
  74. }
  75. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  76. public struct PRTReceiver_Type3 {
  77. public byte head;
  78. public byte RPT_loop;
  79. public byte TBD_ID;
  80. public byte length;
  81. public byte cmd;
  82. public byte IVK_ID;
  83. public byte RCVR_ID;
  84. public byte TBD_loop;
  85. public byte Option1;
  86. public byte Option2;
  87. public byte cs;
  88. }
  89. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  90. public struct PRTReceiver_Type4 {
  91. public byte head;
  92. public byte RPT_loop;
  93. public byte TBD_ID;
  94. public byte length;
  95. public byte cmd;
  96. public byte IVK_ID;
  97. public byte RCVR_ID;
  98. public byte TBD_loop;
  99. public byte Option1;
  100. public byte Option2;
  101. public byte Option3;
  102. public byte cs;
  103. }
  104. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  105. public struct PRTReceiver_Type5 {
  106. public byte head;
  107. public byte RPT_loop;
  108. public byte TBD_ID;
  109. public byte length;
  110. public byte cmd;
  111. public byte IVK_ID;
  112. public byte RCVR_ID;
  113. public byte TBD_loop;
  114. public byte Option1;
  115. public byte Option2;
  116. public byte Option3;
  117. public byte Option4;
  118. public byte cs;
  119. }
  120. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  121. public struct PRTReceiver_Type6 {
  122. public byte head;
  123. public byte RPT_loop;
  124. public byte TBD_ID;
  125. public byte length;
  126. public byte cmd;
  127. public byte IVK_ID;
  128. public byte RCVR_ID;
  129. public byte TBD_loop;
  130. public byte Option1;
  131. public byte Option2;
  132. public byte Option3;
  133. public byte Option4;
  134. public byte Option5;
  135. public byte cs;
  136. }
  137. [StructLayout(LayoutKind.Sequential, Pack = 1)]
  138. public struct Receiver {
  139. public byte head;
  140. public byte cmdID;
  141. public byte Reserved_1;
  142. public byte length;
  143. public byte cmd;
  144. public byte option1;
  145. public byte option2;
  146. public byte option3;
  147. public byte option4;
  148. public byte cs;
  149. }
  150. public class RCVData_ACK {
  151. // base data //
  152. public int TBD_ID = 0;
  153. public int TBD_loop = 1;
  154. public int repeater_loop = 0;
  155. public int repeater_ID = 0;
  156. public int ReceiverID = 0; //수신기ID
  157. public int InvorkNo = 0; //명령ID
  158. public void Set_Data(byte[] buffer) {
  159. this.TBD_ID = buffer[2];
  160. this.TBD_loop = buffer[7];
  161. this.repeater_loop = buffer[1];
  162. this.InvorkNo = buffer[5];
  163. this.ReceiverID = buffer[6];
  164. //insert data
  165. }
  166. }
  167. public class RCVData_NACK {
  168. // base data //
  169. public int TBD_ID = 0;
  170. public int TBD_loop = 1;
  171. public int repeater_loop = 0;
  172. public int repeater_ID = 0;
  173. public int ReceiverID = 0; //수신기ID
  174. public int InvorkNo = 0; //명령ID
  175. public void Set_Data(byte[] buffer) {
  176. this.TBD_ID = buffer[2];
  177. this.TBD_loop = buffer[7];
  178. this.repeater_loop = buffer[1];
  179. this.InvorkNo = buffer[5];
  180. this.ReceiverID = buffer[6];
  181. //insert data
  182. }
  183. }
  184. public class RCVData_ReadTBoardStatus {
  185. // base data //
  186. public int TBD_ID = 0;
  187. public int TBD_loop = 1;
  188. public int repeater_loop = 0;
  189. public int repeater_ID = 0;
  190. public int ReceiverID = 0; //수신기ID
  191. public int InvorkNo = 0; //명령ID
  192. public int TBD_MainVersion;
  193. public int TBD_SubVersion;
  194. public int RCV_BaudRate;
  195. public int TBD_Loop1_BaudRate;
  196. public int TBD_Loop2_BaudRate;
  197. public int TBD_Term;
  198. public int TBD_24Voltage;
  199. public int TBD_5Voltage;
  200. public int TBD_33Voltage;
  201. public int TBD_Cut;
  202. public void Set_Data(byte[] buffer) {
  203. this.TBD_ID = buffer[2];
  204. this.TBD_loop = buffer[7];
  205. this.repeater_loop = buffer[1];
  206. this.InvorkNo = buffer[5];
  207. this.ReceiverID = buffer[6];
  208. //insert data
  209. }
  210. }
  211. public class RCVData_WriteTBoardStatus {
  212. // base data //
  213. public int TBD_ID = 0;
  214. public int TBD_loop = 1;
  215. public int repeater_loop = 0;
  216. public int repeater_ID = 0;
  217. public int ReceiverID = 0; //수신기ID
  218. public int InvorkNo = 0; //명령ID
  219. public void Set_Data(byte[] buffer) {
  220. this.TBD_ID = buffer[2];
  221. this.TBD_loop = buffer[7];
  222. this.repeater_loop = buffer[1];
  223. this.InvorkNo = buffer[5];
  224. this.ReceiverID = buffer[6];
  225. //insert data
  226. }
  227. }
  228. public class RCVData_ReadRepeaterPoint_unit {
  229. // repeater id//
  230. public int repeater_ID = 0;
  231. // repeater state //
  232. public int Err = 0; //에러상태
  233. public int Non = 0; //존재하지 않는 중계기
  234. public int R0 = 0; //Reserved
  235. public int R1 = 0; //Reserved
  236. public int R2 = 0; //Reserved
  237. public int R = 0; //중계기 복구 명령 0-완료,1-완료안함
  238. public int W = 0; //출력쓰기 완료 0-완료,1-완료안함
  239. public int S = 0; //Search Complete 0-완료,1-완료안함
  240. // repeater input //
  241. public int repeater_state_1 = 0; //0-감지,1-정상,3-단선
  242. public int repeater_state_2 = 0; //0-감지,1-정상,3-단선
  243. public int repeater_state_3 = 0; //0-감지,1-정상,3-단선
  244. public int repeater_state_4 = 0; //0-감지,1-정상,3-단선
  245. //repeater output //
  246. public int repeater_output_4_C = 0; //출력확인 0-완료,1-완료안함
  247. public int repeater_output_3_C = 0; //출력확인 0-완료,1-완료안함
  248. public int repeater_output_2_C = 0; //출력확인 0-완료,1-완료안함
  249. public int repeater_output_1_C = 0; //출력확인 0-완료,1-완료안함
  250. public int repeater_output_4_W = 0; //출력쓰기
  251. public int repeater_output_3_W = 0; //출력쓰기
  252. public int repeater_output_2_W = 0; //출력쓰기
  253. public int repeater_output_1_W = 0; //출력쓰기
  254. //public int repeater_state_1 { get { return this.repeater_state_1; } }
  255. public void Set_Data(byte repeater_ID,byte state,byte input,byte output) {
  256. this.repeater_ID = repeater_ID;
  257. set_state_data(state);
  258. set_input_data(input);
  259. set_output_data(output);
  260. }
  261. public void set_state_data(byte in_data){
  262. Err = (in_data >> 7) & 0x01;
  263. Non = (in_data >> 6) & 0x01;
  264. R0 = (in_data >> 5) & 0x01;
  265. R1 = (in_data >> 4) & 0x01;
  266. R2 = (in_data >> 3) & 0x01;
  267. R = (in_data >> 2) & 0x01;
  268. W = (in_data >> 1) & 0x01;
  269. S = (in_data >> 0) & 0x01;
  270. }
  271. public void set_input_data(byte in_data){
  272. repeater_state_4 = (in_data >> 6) & 0x03;
  273. repeater_state_3 = (in_data >> 4) & 0x03;
  274. repeater_state_2 = (in_data >> 2) & 0x03;
  275. repeater_state_1 = (in_data >> 0) & 0x03;
  276. }
  277. public void set_output_data(byte in_data){
  278. repeater_output_4_C = (in_data >> 7) & 0x01;
  279. repeater_output_3_C = (in_data >> 6) & 0x01;
  280. repeater_output_2_C = (in_data >> 5) & 0x01;
  281. repeater_output_1_C = (in_data >> 4) & 0x01;
  282. repeater_output_4_W = (in_data >> 3) & 0x01;
  283. repeater_output_3_W = (in_data >> 2) & 0x01;
  284. repeater_output_2_W = (in_data >> 1) & 0x01;
  285. repeater_output_1_W = (in_data >> 0) & 0x01;
  286. }
  287. }
  288. public class RCVData_ReadRepeaterPointAll {
  289. // repeater id // -> bd no , loop no , repeater id.
  290. public int TBD_ID = 0;
  291. public int TBD_loop = 1;
  292. public int repeater_loop = 0;
  293. public int ReceiverID = 0; //수신기ID
  294. public int InvorkNo = 0; //명령ID
  295. public RCVData_ReadRepeaterPoint_unit[] data = new RCVData_ReadRepeaterPoint_unit[127];
  296. public void Set_Data(byte[] buffer) {
  297. this.TBD_ID = buffer[2];
  298. this.TBD_loop = buffer[9];
  299. this.repeater_loop = buffer[1];
  300. this.InvorkNo = buffer[7];
  301. this.ReceiverID = buffer[8];
  302. for(int i=0; i<127; i++) {
  303. //
  304. data[i] = new RCVData_ReadRepeaterPoint_unit();
  305. data[i].Set_Data((byte)(i + 1), buffer[3 * i + 10], buffer[3 * i + 11], buffer[3 * i + 12]);
  306. }
  307. }
  308. }
  309. public class RCVData_WriteRepeaterOutputUNIT {
  310. // base data //
  311. public int TBD_ID = 0;
  312. public int TBD_loop = 1;
  313. public int repeater_loop = 0;
  314. public int repeater_ID = 0;
  315. public int ReceiverID = 0; //수신기ID
  316. public int InvorkNo = 0; //명령ID
  317. public RCVData_ReadRepeaterPoint_unit data = new RCVData_ReadRepeaterPoint_unit();
  318. public void Set_Data(byte[] buffer) {
  319. this.TBD_ID = buffer[2];
  320. this.TBD_loop = buffer[7];
  321. this.repeater_loop = buffer[1];
  322. this.InvorkNo = buffer[5];
  323. this.ReceiverID = buffer[6];
  324. this.data.Set_Data(buffer[8], buffer[9], buffer[10], buffer[11]);
  325. }
  326. }
  327. public class RCVData_ReadRepeaterInfo_unit {
  328. // repeater id//
  329. public int repeater_ID = 0;
  330. // repeater info //
  331. public int B = 0;
  332. public int Rserved1 = 0;
  333. public int Rserved2 = 0;
  334. public int Rserved3 = 0;
  335. public int Info = 0;
  336. public void Set_Data(byte repeater_ID,byte InfoData) {
  337. this.repeater_ID = repeater_ID;
  338. this.set_infodata(InfoData);
  339. }
  340. void set_infodata(byte InfoData) {
  341. this.B = (InfoData >> 7) & 0x01;
  342. this.Rserved1 = (InfoData >> 6) & 0x01;
  343. this.Rserved2 = (InfoData >> 5) & 0x01;
  344. this.Rserved3 = (InfoData >> 4) & 0x01;
  345. int tmp_data = (InfoData >> 0) & 0x0f;
  346. switch(tmp_data) {
  347. case 0x00: {
  348. this.Info = 0;
  349. break;
  350. }
  351. case 0x01: {
  352. this.Info = 1;
  353. break;
  354. }
  355. case 0x02: {
  356. this.Info = 2;
  357. break;
  358. }
  359. case 0x04: {
  360. this.Info = 3;
  361. break;
  362. }
  363. case 0x05: {
  364. this.Info = 4;
  365. break;
  366. }
  367. default : {
  368. this.Info = -1;
  369. break;
  370. }
  371. }
  372. }
  373. }
  374. //중계기 회로 데이터--
  375. public class RCVData_ReadRepeaterInfoAll {
  376. // base data //
  377. public int TBD_ID = 0;
  378. public int TBD_loop = 1;
  379. public int repeater_loop = 0;
  380. public int repeater_ID = 0;
  381. public int ReceiverID = 0; //수신기ID
  382. public int InvorkNo = 0; //명령ID
  383. public RCVData_ReadRepeaterInfo_unit[] data = new RCVData_ReadRepeaterInfo_unit[127];
  384. public void Set_Data(byte[] buffer) {
  385. this.TBD_ID = buffer[2];
  386. this.TBD_loop = buffer[7];
  387. this.repeater_loop = buffer[1];
  388. this.InvorkNo = buffer[5];
  389. this.ReceiverID = buffer[6];
  390. for(int i=0; i<128; i++) {
  391. this.data[i].Set_Data((byte)(i+1), buffer[i+8]);
  392. }
  393. }
  394. }
  395. public class RCVData_WriteRepeaterInfoUNIT {
  396. // base data //
  397. public int TBD_ID = 0;
  398. public int TBD_loop = 1;
  399. public int repeater_loop = 0;
  400. public int repeater_ID = 0;
  401. public int ReceiverID = 0; //수신기ID
  402. public int InvorkNo = 0; //명령ID
  403. public RCVData_ReadRepeaterInfo_unit data = new RCVData_ReadRepeaterInfo_unit();
  404. public void Set_Data(byte[] buffer) {
  405. this.TBD_ID = buffer[2];
  406. this.TBD_loop = buffer[7];
  407. this.repeater_loop = buffer[1];
  408. this.InvorkNo = buffer[5];
  409. this.ReceiverID = buffer[6];
  410. this.data.Set_Data(buffer[8], buffer[9]);
  411. }
  412. }
  413. public class RCVData_WriteRepeaterInputUNIT {
  414. // base data //
  415. public int TBD_ID = 0;
  416. public int TBD_loop = 1;
  417. public int repeater_loop = 0;
  418. public int repeater_ID = 0;
  419. public int ReceiverID = 0; //수신기ID
  420. public int InvorkNo = 0; //명령ID
  421. public RCVData_ReadRepeaterPoint_unit data = new RCVData_ReadRepeaterPoint_unit();
  422. public void Set_Data(byte[] buffer) {
  423. this.TBD_ID = buffer[2];
  424. this.TBD_loop = buffer[7];
  425. this.repeater_loop = buffer[1];
  426. this.InvorkNo = buffer[5];
  427. this.ReceiverID = buffer[6];
  428. this.data.Set_Data(buffer[8], buffer[9], buffer[10], buffer[11]);
  429. }
  430. }
  431. public class Tprotocol {
  432. private MDIParent main;
  433. private TcpClient cmd_tcpclient;
  434. private TcpClient event_tcpclient;
  435. private String DestIP;
  436. private int commandPort;
  437. private int eventPort;
  438. private Thread cmd_hn_th;
  439. private int cmd_hn_th_state = 0;
  440. private Thread cmd_rcv_th;
  441. private int cmd_rcv_th_state = 0;
  442. //private Socket sc;
  443. private NetworkStream cmd_sendStm, cmd_recvStm;
  444. private NetworkStream event_sendStm, event_recvStm;
  445. private Thread event_rcv_th;
  446. private int event_rcv_th_state;
  447. private Paket pkt;
  448. private int cmd_state = 0; // 0 : init , cmd don't exist , 1: cmd exist, before send , 2 : cmd exist , after sned , before rcv , 3: cmd exist , after rcv , -1 : cmd exit, after send , rcv time out error , -2 : unknown cmd, -3: unknown rcv
  449. [DllImport("kernel32.dll")]
  450. static extern void OutputDebugString(string message);
  451. public void DoPrintDBGMSG(string str) {
  452. str = "[FPER]" + System.DateTime.Now.ToString("[hh:mm:ss]") + ":" + str;
  453. OutputDebugString(str);
  454. }
  455. public void OpenDBGMSG(string str) {
  456. DoPrintDBGMSG("+" + str);
  457. }
  458. public void CloseDBGMSG(string str) {
  459. DoPrintDBGMSG("-" + str);
  460. }
  461. public Tprotocol(MDIParent main) {
  462. this.main = main;
  463. this.pkt = new Paket();
  464. }
  465. public int ConnectToDemon(String Dest_ip, int commandPort , int eventPort ,int Demon_ID) {
  466. // start rcv thread
  467. // send connect cmd
  468. // check connect cmd' response
  469. // return result
  470. try {
  471. this.DestIP = Dest_ip;
  472. this.commandPort = commandPort;
  473. this.eventPort = eventPort;
  474. this.cmd_tcpclient = new TcpClient();
  475. this.event_tcpclient = new TcpClient();
  476. this.Start_Connection();
  477. }
  478. catch(Exception ex) {
  479. throw ex;
  480. }
  481. return this.cmd_tcpclient.Connected ? 1:0;
  482. }
  483. public int DisconnectToDemon(int Own_ID, int Demon_ID) {
  484. // send disconnect cmd
  485. // check disconneect cmd' response
  486. // stop rcv thread
  487. // return result
  488. Stop_Connection();
  489. return 0;
  490. }
  491. public void SayHello_To_Board(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  492. byte[] bt;
  493. bt = pkt.CreatePKT_SayHello_To_Board(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  494. DoPrintDBGMSG(ToHex(bt));
  495. Cmd_Send(bt,(int)bt[3] +1);
  496. }
  497. public void ReadBoardStatus(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  498. byte[] bt;
  499. bt = pkt.CreatePKT_ReadBoardStatus(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  500. DoPrintDBGMSG(ToHex(bt));
  501. Cmd_Send(bt,(int)bt[3] +1);
  502. }
  503. public void WriteBoardStatus(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte RT_BaudRate,byte loop1_BaudRate,byte loop2_BaudRate,byte RT_Term, byte BD_Reset) {
  504. byte[] bt;
  505. bt = pkt.CreatePKT_WriteBoardStatus(loop, TBD_ID ,IVK_ID,RCV_ID, TBD_loop,RT_BaudRate,loop1_BaudRate,loop2_BaudRate,RT_Term, BD_Reset);
  506. DoPrintDBGMSG(ToHex(bt));
  507. Cmd_Send(bt,(int)bt[3] +1);
  508. }
  509. public void SearchRepeaterAll(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  510. byte[] bt;
  511. bt = pkt.CreatePKT_SearchRepeaterAll(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  512. DoPrintDBGMSG(ToHex(bt));
  513. Cmd_Send(bt,(int)bt[3] +1);
  514. }
  515. //중계기 정보읽기
  516. public void ReadRepeaterPointAll(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  517. byte[] bt;
  518. bt = pkt.CreatePKT_ReadRepeaterPointAll(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  519. DoPrintDBGMSG(ToHex(bt));
  520. Cmd_Send(bt,(int)bt[3] +1);
  521. }
  522. public void WriteRepeaterOutputUNIT(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  523. byte[] bt;
  524. bt = pkt.CreatePKT_WriteRepeaterOutputUNIT(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop, Repeater_ID, Repeater_Out_Value);
  525. DoPrintDBGMSG(ToHex(bt));
  526. Cmd_Send(bt,(int)bt[3] +1);
  527. }
  528. public void ReadRepeaterInfoAll(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  529. byte[] bt;
  530. bt = pkt.CreatePKT_ReadRepeaterInfoAll(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  531. DoPrintDBGMSG(ToHex(bt));
  532. Cmd_Send(bt,(int)bt[3] +1);
  533. }
  534. public void WriteRepeaterInfoUNIT(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  535. byte[] bt;
  536. bt = pkt.CreatePKT_WriteRepeaterInfoUNIT(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop, Repeater_ID, Repeater_Out_Value);
  537. DoPrintDBGMSG(ToHex(bt));
  538. Cmd_Send(bt,(int)bt[3] +1);
  539. }
  540. public void ResetRepeaterUNIT(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID) {
  541. byte[] bt;
  542. bt = pkt.CreatePKT_ResetRepeaterUNIT(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop, Repeater_ID);
  543. DoPrintDBGMSG(ToHex(bt));
  544. Cmd_Send(bt,(int)bt[3] +1);
  545. }
  546. public void ResetRepeaterAll(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  547. byte[] bt;
  548. bt = pkt.CreatePKT_ResetRepeaterAll(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop);
  549. DoPrintDBGMSG(ToHex(bt));
  550. Cmd_Send(bt,(int)bt[3] +1);
  551. }
  552. public void WriteRepeaterInputUNIT(byte loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  553. byte[] bt;
  554. bt = pkt.CreatePKT_WriteRepeaterInputUNIT(loop, TBD_ID, IVK_ID, RCV_ID, TBD_loop, Repeater_ID, Repeater_Out_Value);
  555. DoPrintDBGMSG(ToHex(bt));
  556. Cmd_Send(bt,(int)bt[3] +1);
  557. }
  558. private CmdInfo cmd;
  559. // private int TimeOut = 3000;
  560. // private int cmd_send_time = 0;
  561. // private bool simulation_mode = false;
  562. // ----------------------- 명령을 받는함수 -----------------------
  563. public void getCommand(CmdInfo cmd) {
  564. try
  565. {
  566. // byte[] bt;
  567. if (cmd_tcpclient != null)
  568. {
  569. //if (cmd_tcpclient.Connected)
  570. //{
  571. //this.TimeOut = cmd.TimeOut;
  572. // cmd_send_time = Environment.TickCount & Int32.MaxValue;
  573. switch (cmd.Command)
  574. {
  575. //#if (false)
  576. // case CMD_define.read_repeater_all : {
  577. // this.cmd = cmd;
  578. // ReadRepeaterPointAll((byte)cmd.loopNo,(byte)cmd.boardNo,(byte)cmd.invorkNo,(byte)cmd.receiverID);
  579. // if(simulation_mode) {
  580. // //결과값 리턴----------------시작
  581. // byte[] bt = new byte [1024];
  582. // for(int i=0; i<1024 ; i++) {
  583. // bt[i] = (byte)i;
  584. // }
  585. // this.cmd.ResponseData = bt;
  586. // main.ui.getResponse(this.cmd);
  587. // //결과값 리턴----------------끝
  588. // }
  589. // break;
  590. // }
  591. //#endif
  592. case CMD_define.say_hello:
  593. {
  594. this.cmd = cmd;
  595. SayHello_To_Board((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  596. break;
  597. }
  598. case CMD_define.resd_tbd_state:
  599. {
  600. this.cmd = cmd;
  601. ReadBoardStatus((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  602. break;
  603. }
  604. case CMD_define.write_tbd_state:
  605. {
  606. this.cmd = cmd;
  607. WriteBoardStatus((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00);
  608. break;
  609. }
  610. case CMD_define.search_repeater_all:
  611. {
  612. this.cmd = cmd;
  613. SearchRepeaterAll((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  614. break;
  615. }
  616. case CMD_define.read_repeater_all:
  617. {
  618. this.cmd = cmd;
  619. ReadRepeaterPointAll((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  620. ////강제로 0으로 셋팅----------------------------------------
  621. //byte[] cmdbuffer = new byte[1200];
  622. //for (int i = 0; i < 9; i++) //설정
  623. //{
  624. // cmdbuffer[i] = 0x03;
  625. //}
  626. //for (int i = 0; i < 127; i++)
  627. //{
  628. // cmdbuffer[(i * 3) + 9] = 0x00; //상태
  629. // cmdbuffer[(i * 3) + 10] = 0x03; //입력
  630. // cmdbuffer[(i * 3) + 11] = 0x14; //출력
  631. //}
  632. //RCVData_ReadRepeaterPointAll ResponseData = new RCVData_ReadRepeaterPointAll();
  633. //ResponseData.Set_Data(cmdbuffer);
  634. //this.cmd.ResponseData = ResponseData;
  635. //main.ui.getResponse(this.cmd);
  636. break;
  637. }
  638. case CMD_define.write_repeater_output_unit:
  639. {
  640. this.cmd = cmd; //2010.3.24_moon
  641. WriteRepeaterOutputUNIT((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01, (byte)cmd.repeaterNo, 0x00);
  642. break;
  643. }
  644. case CMD_define.read_repeater_info_all:
  645. {
  646. this.cmd = cmd;
  647. ReadRepeaterInfoAll((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  648. break;
  649. }
  650. case CMD_define.write_repeater_info_unit:
  651. {
  652. this.cmd = cmd;
  653. WriteRepeaterInfoUNIT((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01, (byte)cmd.repeaterNo, 0x00);
  654. break;
  655. }
  656. case CMD_define.reset_repeater_unit:
  657. {
  658. this.cmd = cmd;
  659. ResetRepeaterUNIT((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01, (byte)cmd.repeaterNo);
  660. break;
  661. }
  662. case CMD_define.reset_repeater_all:
  663. {
  664. this.cmd = cmd;
  665. ResetRepeaterAll((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01);
  666. break;
  667. }
  668. case CMD_define.write_repeater_input_unit:
  669. {
  670. this.cmd = cmd;
  671. WriteRepeaterInputUNIT((byte)cmd.loopNo, (byte)cmd.boardNo, (byte)cmd.invorkNo, (byte)cmd.receiverID, 0x01, (byte)cmd.repeaterNo, 0x00);
  672. break;
  673. }
  674. default:
  675. {
  676. break;
  677. }
  678. }
  679. }
  680. //}
  681. }
  682. catch(Exception ex)
  683. {
  684. throw ex;
  685. }
  686. //string str;
  687. //str = ToHex(bt);
  688. //DoPrintDBGMSG(str);
  689. //Send(bt, 7);
  690. }
  691. // ----------------------- 명령을 받는함수 -----------------------
  692. // ----------------------- 명현재 연결된 소켓수 -----------------------
  693. public int TcpSockeCnt
  694. {
  695. get
  696. {
  697. int TcpCnt = 0;
  698. //
  699. if (this.cmd_tcpclient != null)
  700. {
  701. if (this.cmd_tcpclient.Connected) ++TcpCnt;
  702. }
  703. if (this.event_tcpclient != null)
  704. {
  705. if (this.event_tcpclient.Connected) ++TcpCnt;
  706. }
  707. return TcpCnt;
  708. }
  709. }
  710. public Boolean cmd_Connected
  711. {
  712. get
  713. {
  714. Boolean TcpConnected = false;
  715. try
  716. {
  717. if (this.cmd_tcpclient != null) TcpConnected = this.cmd_tcpclient.Connected;
  718. }
  719. catch
  720. {
  721. }
  722. return TcpConnected;
  723. }
  724. }
  725. public Boolean event_Connected
  726. {
  727. get
  728. {
  729. Boolean TcpConnected = false;
  730. try
  731. {
  732. if (this.event_tcpclient != null) TcpConnected = this.event_tcpclient.Connected;
  733. }
  734. catch
  735. {
  736. }
  737. return TcpConnected;
  738. }
  739. }
  740. // ----------------------- 명현재 연결된 소켓수 -----------------------
  741. public int SendDataToDemon(byte[] data , int size) {// don't using now. //2010.3.16_moon
  742. //if conencted
  743. // send msg
  744. // check response
  745. return 0;
  746. }
  747. public int SendDataToDemon(String strdata, int size) {// don't using now. //2010.3.16_moon
  748. //if conencted
  749. // send msg
  750. // check response
  751. return 0;
  752. }
  753. string ToHex(byte[] bin_data) {
  754. string result = "";
  755. foreach (byte ch in bin_data) {
  756. result += string.Format("{0:x2} ", ch);
  757. }
  758. return result;
  759. }
  760. string ToHex(byte[] bin_data,int len) {
  761. string result = "";
  762. for(int i=0; i<len ; i++) {
  763. result += string.Format("{0:x2} ", bin_data[i]);
  764. }
  765. return result;
  766. }
  767. IPEndPoint CommandEndPoint {
  768. get {
  769. return new IPEndPoint(IPAddress.Parse(this.DestIP), this.commandPort);
  770. }
  771. }
  772. IPEndPoint EventEndPoint {
  773. get {
  774. return new IPEndPoint(IPAddress.Parse(this.DestIP), this.eventPort);
  775. }
  776. }
  777. void Start_Connection() {
  778. Start_Con_cmd();
  779. Start_Con_event();
  780. #if (false)
  781. try {
  782. DoPrintDBGMSG("Start 1");
  783. this.cmd_tcpclient.Connect(this.CommandEndPoint);
  784. //this.sc = cmd_tcpclient.Client;
  785. this.cmd_sendStm = new NetworkStream(this.cmd_tcpclient.Client);
  786. this.cmd_recvStm = new NetworkStream(this.cmd_tcpclient.Client);
  787. this.cmd_rcv_th = new Thread(this.Cmd_ReceiveThread);
  788. this.cmd_rcv_th_state = 1;
  789. this.cmd_rcv_th.Start();
  790. DoPrintDBGMSG("Start 2");
  791. this.event_tcpclient.Connect(this.EventEndPoint);
  792. this.event_sendStm = new NetworkStream(this.event_tcpclient.Client);
  793. this.event_recvStm = new NetworkStream(this.event_tcpclient.Client);
  794. this.event_rcv_th = new Thread(this.Event_ReceiveThread);
  795. this.event_rcv_th_state = 1;
  796. this.event_rcv_th.Start();
  797. DoPrintDBGMSG("Start 3");
  798. }
  799. catch {
  800. //error
  801. }
  802. #endif
  803. }
  804. void Start_Con_cmd() {
  805. this.cmd_tcpclient.Connect(this.CommandEndPoint);
  806. //this.sc = cmd_tcpclient.Client;
  807. this.cmd_sendStm = new NetworkStream(this.cmd_tcpclient.Client);
  808. this.cmd_recvStm = new NetworkStream(this.cmd_tcpclient.Client);
  809. this.cmd_rcv_th = new Thread(this.Cmd_ReceiveThread);
  810. this.cmd_rcv_th_state = 1;
  811. this.cmd_rcv_th.Start();
  812. // this.cmd_hn_th = new Thread(this.Cmd_HandlingThread);
  813. // this.cmd_hn_th_state = 1;
  814. // this.cmd_hn_th.Start();
  815. }
  816. void Start_Con_event() {
  817. this.event_tcpclient.Connect(this.EventEndPoint);
  818. this.event_sendStm = new NetworkStream(this.event_tcpclient.Client);
  819. this.event_recvStm = new NetworkStream(this.event_tcpclient.Client);
  820. this.event_rcv_th = new Thread(this.Event_ReceiveThread);
  821. this.event_rcv_th_state = 1;
  822. this.event_rcv_th.Start();
  823. DoPrintDBGMSG("Start 3");
  824. }
  825. void Stop_Connection() {
  826. Stop_Con_cmd();
  827. Stop_Con_event();
  828. #if (false)
  829. if(this.cmd_rcv_th_state == 1){
  830. this.cmd_rcv_th.Abort();
  831. }
  832. if (this.cmd_tcpclient != null) {
  833. this.cmd_tcpclient.Close();
  834. }
  835. if(this.event_rcv_th_state == 1){
  836. this.event_rcv_th.Abort();
  837. }
  838. if (this.event_tcpclient != null) {
  839. this.event_tcpclient.Close();
  840. }
  841. #endif
  842. }
  843. void Stop_Con_cmd() {
  844. if(this.cmd_hn_th_state == 1){
  845. this.cmd_hn_th.Abort();
  846. }
  847. if(this.cmd_rcv_th_state == 1){
  848. this.cmd_rcv_th.Abort();
  849. }
  850. if (this.cmd_tcpclient != null) {
  851. this.cmd_tcpclient.Close();
  852. }
  853. }
  854. void Stop_Con_event() {
  855. if(this.event_rcv_th_state == 1){
  856. this.event_rcv_th.Abort();
  857. }
  858. if (this.event_tcpclient != null) {
  859. this.event_tcpclient.Close();
  860. }
  861. }
  862. void Cmd_Send(byte[] bt, int size) { //2010.3.12_moon
  863. if( this.cmd_tcpclient != null){
  864. if(this.cmd_tcpclient.Connected) {
  865. try {
  866. this.cmd_sendStm.Write(bt, 0, size);
  867. this.cmd_sendStm.Flush();
  868. }
  869. catch {
  870. return;
  871. }
  872. }
  873. }
  874. }
  875. void Cmd_HandlingThread() {
  876. while(cmd_hn_th_state == 1) {
  877. if(true) {
  878. // cmd send
  879. // rcv wait
  880. // rcv data process
  881. // if rcv data ok
  882. // else if rcv data error -> retry
  883. // or time out
  884. this.cmd_state = 1; // result setting.
  885. // DoPrintDBGMSG(this.cmd_state.ToString());
  886. // send result to main.
  887. }
  888. }
  889. }
  890. void Cmd_ReceiveThread() {
  891. byte[] ReadBuffer = new byte[1024];
  892. int offset = 0;
  893. while(this.cmd_rcv_th_state == 1) {
  894. if(this.cmd_tcpclient.Connected) {
  895. DoPrintDBGMSG("ReceiveThread");
  896. for(int i=0; i<1024; i++) {
  897. ReadBuffer[i] = 0x00;
  898. }
  899. offset = 0;
  900. try {
  901. if(this.cmd_recvStm.CanRead) {
  902. offset = this.cmd_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  903. if(offset>0) {
  904. DoPrintDBGMSG(ToHex(ReadBuffer,offset));
  905. // rcv msg process
  906. // if rcv msg ok -> send cmd handling thread
  907. // else if rcv msg short -> wait next msg
  908. // else if rcv msg error -> sned error handling thread ( header error , cs error,
  909. CMDReceiveMSGProc(ReadBuffer,offset);
  910. }
  911. }
  912. this.cmd_recvStm.Flush();
  913. }
  914. catch (Exception e) {
  915. //error
  916. DoPrintDBGMSG("error : " + e.Message);
  917. }
  918. }
  919. else {
  920. // don't connected
  921. break;
  922. }
  923. }
  924. this.cmd_rcv_th_state = 0;
  925. }
  926. byte[] CMD_RcvBuffer = new byte [2048];
  927. int CMD_RcvBufferPos = 0;
  928. void CMDReceiveMSGProc(byte[] ReadBuffer, int size) {
  929. DoPrintDBGMSG("ReceiveMSGProcess");
  930. for(int i=0; i<2048 ; i++) {//init buffer
  931. CMD_RcvBuffer[i] = 0x00;
  932. }
  933. CMD_RcvBufferPos = 0;
  934. for(int i=0; i<size; i++) {//copy buffer
  935. CMD_RcvBuffer[CMD_RcvBufferPos+i] = ReadBuffer[i];
  936. }
  937. CMD_RcvBufferPos += size;
  938. int datasize = CMD_RcvBuffer[3];
  939. CMDResponceProc(datasize);
  940. #if (false)
  941. int current_time = Environment.TickCount & Int32.MaxValue;
  942. if(false) {
  943. // if(cmd_send_time + TimeOut > current_time) { //time out
  944. DoPrintDBGMSG("ReceiveMSGProcess to ");
  945. for(int i=0; i<2048 ; i++) {//init buffer
  946. RcvBuffer[i] = 0x00;
  947. }
  948. RcvBufferPos = 0;
  949. }
  950. else {
  951. DoPrintDBGMSG("ReceiveMSGProcess 2");
  952. for(int i=0; i<size; i++) {//copy buffer
  953. RcvBuffer[RcvBufferPos+i] = ReadBuffer[i];
  954. }
  955. RcvBufferPos += size;
  956. if( RcvBuffer[0] != 0x02 ) { //header error
  957. DoPrintDBGMSG("ReceiveMSGProcess 3 ");
  958. for(int i=0; i<2048 ; i++) {//init buffer
  959. RcvBuffer[i] = 0x00;
  960. }
  961. RcvBufferPos = 0;
  962. }
  963. else if(RcvBufferPos < 8) { // too short
  964. DoPrintDBGMSG("ReceiveMSGProcess 4 ");
  965. //wait next input
  966. }
  967. else {
  968. DoPrintDBGMSG("ReceiveMSGProcess 5 ");
  969. if(RcvBuffer[3] == 0x00) {// extend packet size
  970. DoPrintDBGMSG("ReceiveMSGProcess 6 ");
  971. byte[] bt_extendsize = new byte[2];
  972. bt_extendsize[0] = RcvBuffer[5];
  973. bt_extendsize[1] = RcvBuffer[6];
  974. int extendsize = ( bt_extendsize[0]&0xff | (bt_extendsize [1] << 8)& 0xff00 ) & 0xffff;
  975. if(RcvBufferPos < extendsize+1) {//need more data
  976. //wait next input
  977. }
  978. else {
  979. CMDResponceProcess(extendsize);
  980. }
  981. }
  982. else if(RcvBuffer[3] > RcvBufferPos) {//need more data
  983. DoPrintDBGMSG("ReceiveMSGProcess 7 ");
  984. }
  985. else {
  986. DoPrintDBGMSG("ReceiveMSGProcess 8");
  987. int datasize = RcvBuffer[3];
  988. CMDResponceProcess(datasize);
  989. switch(RcvBuffer[4]) {
  990. case 0x94: {
  991. break;
  992. }
  993. default : {
  994. break;
  995. }
  996. }
  997. }
  998. }
  999. }
  1000. /*
  1001. switch(ReadBuffer[4]) {
  1002. case 0x94: {
  1003. //결과값 리턴----------------시작
  1004. byte[] bt = new byte [size];
  1005. for(int i=0; i<size ; i++) {
  1006. bt[i] = ReadBuffer[i];
  1007. }
  1008. this.cmd.ResponseData = bt;
  1009. main.ui.getResponse(this.cmd);
  1010. //결과값 리턴----------------끝
  1011. break;
  1012. }
  1013. default : {
  1014. break;
  1015. }
  1016. }
  1017. */
  1018. #endif
  1019. }
  1020. void CMDResponceProc(int size) {
  1021. DoPrintDBGMSG ( " + CMDResponceProcess " );
  1022. byte[] cmdbuffer = new byte[size+1];
  1023. for(int i=0; i<size+1 ; i++) {//copy data
  1024. cmdbuffer[i] = CMD_RcvBuffer[i];
  1025. }
  1026. for(int i=0; i<2048; i++) {//rcv buffer compress
  1027. if(i<CMD_RcvBufferPos) {
  1028. CMD_RcvBuffer[i] = CMD_RcvBuffer[i+size+1];
  1029. }
  1030. else {
  1031. CMD_RcvBuffer[i] = 0x00;
  1032. }
  1033. CMD_RcvBufferPos -= size+1;
  1034. }
  1035. int ret = pkt.DoCheckcs(cmdbuffer , size, cmdbuffer[size]);
  1036. DoPrintDBGMSG ( "CMDResponceProcess cs = " + ret.ToString());
  1037. //check cs
  1038. if(ret == 1) {
  1039. //data setting
  1040. // send to ui
  1041. #if (false)
  1042. res_data_header res_data = new res_data_header(cmdbuffer,size+1);
  1043. res_data.LoopNo = cmdbuffer[1];
  1044. res_data.BoardNo = cmdbuffer[2];
  1045. res_data.InvorkNo = cmdbuffer[7];
  1046. res_data.ReceiverID = cmdbuffer[8];
  1047. switch(cmdbuffer[4]) {
  1048. case (byte)RES_define.general_ack: {
  1049. break;
  1050. }
  1051. case (byte)RES_define.general_nack: {
  1052. break;
  1053. }
  1054. case (byte)RES_define.resd_tbd_state: {
  1055. break;
  1056. }
  1057. case (byte)RES_define.write_tbd_state: {
  1058. break;
  1059. }
  1060. case (byte)RES_define.read_repeater_all: {
  1061. res_data.data = new res_data_repeater[127];
  1062. for(int i=0; i<127; i++) {
  1063. // res_data.data[i].Set_Data(cmdbuffer[2],byte TBD_loop,cmdbuffer[1],byte repeater_ID,cmdbuffer[7],cmdbuffer[8],cmdbuffer[3*i+9],cmdbuffer[3*i+10],cmdbuffer[3*i+11]);
  1064. }
  1065. break;
  1066. }
  1067. case (byte)RES_define.write_repeater_output_unit: {
  1068. break;
  1069. }
  1070. case (byte)RES_define.read_repeater_info_all: {
  1071. break;
  1072. }
  1073. case (byte)RES_define.write_repeater_info_unit: {
  1074. break;
  1075. }
  1076. case (byte)RES_define.write_repeater_input_unit: {
  1077. break;
  1078. }
  1079. default : {
  1080. DoPrintDBGMSG ( " unKnown CMD " );
  1081. break;
  1082. }
  1083. }
  1084. this.cmd.ResponseData = res_data;
  1085. #endif
  1086. switch(cmdbuffer[4]) {
  1087. case (byte)RES_define.general_ack: {
  1088. RCVData_ACK ResponseData = new RCVData_ACK();
  1089. ResponseData.Set_Data(cmdbuffer);
  1090. this.cmd.ResponseData = ResponseData;
  1091. break;
  1092. }
  1093. case (byte)RES_define.general_nack: {
  1094. RCVData_NACK ResponseData = new RCVData_NACK();
  1095. ResponseData.Set_Data(cmdbuffer);
  1096. this.cmd.ResponseData = ResponseData;
  1097. break;
  1098. }
  1099. case (byte)RES_define.resd_tbd_state: {
  1100. RCVData_ReadTBoardStatus ResponseData = new RCVData_ReadTBoardStatus();
  1101. ResponseData.Set_Data(cmdbuffer);
  1102. this.cmd.ResponseData = ResponseData;
  1103. break;
  1104. }
  1105. case (byte)RES_define.write_tbd_state: {
  1106. RCVData_WriteTBoardStatus ResponseData = new RCVData_WriteTBoardStatus();
  1107. ResponseData.Set_Data(cmdbuffer);
  1108. this.cmd.ResponseData = ResponseData;
  1109. break;
  1110. }
  1111. case (byte)RES_define.read_repeater_all: {
  1112. RCVData_ReadRepeaterPointAll ResponseData = new RCVData_ReadRepeaterPointAll();
  1113. ResponseData.Set_Data(cmdbuffer);
  1114. this.cmd.ResponseData = ResponseData;
  1115. break;
  1116. }
  1117. case (byte)RES_define.write_repeater_output_unit: {
  1118. RCVData_WriteRepeaterOutputUNIT ResponseData = new RCVData_WriteRepeaterOutputUNIT();
  1119. ResponseData.Set_Data(cmdbuffer);
  1120. this.cmd.ResponseData = ResponseData;
  1121. break;
  1122. }
  1123. case (byte)RES_define.read_repeater_info_all: {
  1124. RCVData_ReadRepeaterInfoAll ResponseData = new RCVData_ReadRepeaterInfoAll();
  1125. ResponseData.Set_Data(cmdbuffer);
  1126. this.cmd.ResponseData = ResponseData;
  1127. break;
  1128. }
  1129. case (byte)RES_define.write_repeater_info_unit: {
  1130. RCVData_WriteRepeaterInfoUNIT ResponseData = new RCVData_WriteRepeaterInfoUNIT();
  1131. ResponseData.Set_Data(cmdbuffer);
  1132. this.cmd.ResponseData = ResponseData;
  1133. break;
  1134. }
  1135. case (byte)RES_define.write_repeater_input_unit: {
  1136. RCVData_WriteRepeaterInputUNIT ResponseData = new RCVData_WriteRepeaterInputUNIT();
  1137. ResponseData.Set_Data(cmdbuffer);
  1138. this.cmd.ResponseData = ResponseData;
  1139. break;
  1140. }
  1141. default : {
  1142. DoPrintDBGMSG ( " unKnown CMD " );
  1143. break;
  1144. }
  1145. }
  1146. this.main.ui.getResponse(cmd);
  1147. }
  1148. DoPrintDBGMSG ( " - CMDResponceProcess " );
  1149. }
  1150. public class res_data_repeater {
  1151. // repeater id // -> bd no , loop no , repeater id.
  1152. public int TBD_ID = 0;
  1153. public int TBD_loop = 1;
  1154. public int repeater_loop = 0;
  1155. public int repeater_ID = 0;
  1156. public int ReceiverID = 0; //수신기ID
  1157. public int InvorkNo = 0; //명령ID
  1158. // repeater state //
  1159. public int Err = 0;
  1160. public int Non = 0;
  1161. public int R0 = 0;
  1162. public int R1 = 0;
  1163. public int R2 = 0;
  1164. public int R = 0;
  1165. public int W = 0;
  1166. public int S = 0;
  1167. // repeater input //
  1168. public int repeater_state_1 = 0;
  1169. public int repeater_state_2 = 0;
  1170. public int repeater_state_3 = 0;
  1171. public int repeater_state_4 = 0;
  1172. //repeater output //
  1173. public int repeater_output_4_C = 0;
  1174. public int repeater_output_3_C = 0;
  1175. public int repeater_output_2_C = 0;
  1176. public int repeater_output_1_C = 0;
  1177. public int repeater_output_4_W = 0;
  1178. public int repeater_output_3_W = 0;
  1179. public int repeater_output_2_W = 0;
  1180. public int repeater_output_1_W = 0;
  1181. public void Set_Data(byte TBD_ID,byte TBD_loop,byte repeater_loop,byte repeater_ID,byte InvorkNo,byte ReceiverID,byte state,byte input,byte output) {
  1182. this.TBD_ID = TBD_ID;
  1183. this.TBD_loop = TBD_loop;
  1184. this.repeater_loop = repeater_loop;
  1185. this.repeater_ID = repeater_ID;
  1186. this.InvorkNo = InvorkNo;
  1187. this.ReceiverID = ReceiverID;
  1188. set_state_data(state);
  1189. set_input_data(input);
  1190. set_output_data(output);
  1191. }
  1192. public void set_state_data(byte in_data){
  1193. Err = (in_data >> 7) & 0x01;
  1194. Non = (in_data >> 6) & 0x01;
  1195. R0 = (in_data >> 5) & 0x01;
  1196. R1 = (in_data >> 4) & 0x01;
  1197. R2 = (in_data >> 3) & 0x01;
  1198. R = (in_data >> 2) & 0x01;
  1199. W = (in_data >> 1) & 0x01;
  1200. S = (in_data >> 0) & 0x01;
  1201. }
  1202. public void set_input_data(byte in_data){
  1203. repeater_state_4 = (in_data >> 6) & 0x03;
  1204. repeater_state_3 = (in_data >> 4) & 0x03;
  1205. repeater_state_2 = (in_data >> 2) & 0x03;
  1206. repeater_state_1 = (in_data >> 0) & 0x03;
  1207. }
  1208. public void set_output_data(byte in_data){
  1209. repeater_output_4_C = (in_data >> 7) & 0x01;
  1210. repeater_output_3_C = (in_data >> 6) & 0x01;
  1211. repeater_output_2_C = (in_data >> 5) & 0x01;
  1212. repeater_output_1_C = (in_data >> 4) & 0x01;
  1213. repeater_output_4_W = (in_data >> 3) & 0x01;
  1214. repeater_output_3_W = (in_data >> 2) & 0x01;
  1215. repeater_output_2_W = (in_data >> 1) & 0x01;
  1216. repeater_output_1_W = (in_data >> 0) & 0x01;
  1217. }
  1218. }
  1219. public class res_data_header {
  1220. public CMD_define cmd_define;
  1221. public int ReceiverID = 0; //수신기ID
  1222. public int LoopNo = 0; //LoopNo
  1223. public int BoardNo = 0; //BoardNo
  1224. public int RepeaterNo = 0; //중계기No
  1225. public int InvorkNo = 0; //명령ID
  1226. public res_data_repeater[] data;
  1227. public int[] temp_data = new int[1024];
  1228. public res_data_header(byte[] RcvData, int size) {
  1229. }
  1230. }
  1231. void Event_Send(byte[] bt, int size) { //2010.3.17_moon //don't using
  1232. if( this.event_tcpclient != null){
  1233. if(this.event_tcpclient.Connected) {
  1234. try {
  1235. this.event_sendStm.Write(bt, 0, size);
  1236. this.event_sendStm.Flush();
  1237. }
  1238. catch {
  1239. return;
  1240. }
  1241. }
  1242. }
  1243. }
  1244. void Event_ReceiveThread() {
  1245. byte[] ReadBuffer = new byte[1024];
  1246. int offset = 0;
  1247. while(this.event_rcv_th_state == 1) {
  1248. if(this.event_tcpclient.Connected) {
  1249. // DoPrintDBGMSG("Event_ReceiveThread");
  1250. try {
  1251. if(this.event_recvStm.CanRead) {
  1252. for(int i=0; i<1024; i++) {
  1253. ReadBuffer[i] = 0x00;
  1254. }
  1255. offset = this.event_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  1256. if(offset>0) {
  1257. string str;
  1258. str = ToHex(ReadBuffer,offset);
  1259. // DoPrintDBGMSG("size : " + offset.ToString() + "//" +str);
  1260. // DoPrintDBGMSG(string.Format("{0:x2} ", ReadBuffer[offset-1]));
  1261. //Thread.Sleep(1000);
  1262. EVENTReceiveMSGFunc(ReadBuffer,offset);
  1263. }
  1264. }
  1265. this.event_recvStm.Flush();
  1266. // call main func -> case by case
  1267. }
  1268. catch (Exception e) {
  1269. //error
  1270. DoPrintDBGMSG(e.Message);
  1271. }
  1272. }
  1273. else {
  1274. break;
  1275. }
  1276. }
  1277. this.event_rcv_th_state = 0;
  1278. }
  1279. byte[] EVENT_RcvBuffer = new byte [1024*3];
  1280. int EVENT_RcvBufferPos = 0;
  1281. void EVENTReceiveMSGFunc(byte[] ReadBuffer, int size) {
  1282. DoPrintDBGMSG("+ EVENTReceiveMSGProc");
  1283. if((EVENT_RcvBufferPos <0)&&(EVENT_RcvBufferPos >2048)) {
  1284. DoPrintDBGMSG("///////////////////ERROR////////////////");
  1285. for(int i=0; i<2048 ; i++) {//init buffer
  1286. EVENT_RcvBuffer[i] = 0x00;
  1287. }
  1288. EVENT_RcvBufferPos = 0;
  1289. }
  1290. DoPrintDBGMSG("EVENTReceiveMSGProc EVENT_RcvBufferPos = "+ EVENT_RcvBufferPos.ToString());
  1291. DoPrintDBGMSG("EVENTReceiveMSGProc size = "+ size.ToString());
  1292. for(int i=0; i<size; i++) {//copy buffer
  1293. EVENT_RcvBuffer[EVENT_RcvBufferPos+i] = ReadBuffer[i];
  1294. }
  1295. EVENT_RcvBufferPos += size;
  1296. DoPrintDBGMSG("EVENTReceiveMSGProc EVENT_RcvBufferPos = "+ EVENT_RcvBufferPos.ToString());
  1297. while(EVENT_RcvBufferPos >7) {
  1298. DoPrintDBGMSG("EVENTReceiveMSGProc:1 ");
  1299. if(EVENT_RcvBuffer[0] == 0x02) {
  1300. if(EVENT_RcvBuffer[3] == 0x00) {//extend size
  1301. int extendsize = ( EVENT_RcvBuffer[5]&0xff | (EVENT_RcvBuffer[6] << 8)& 0xff00 ) & 0xffff;
  1302. DoPrintDBGMSG("EVENTReceiveMSGProc:2 " + extendsize.ToString());
  1303. if(extendsize +1 > EVENT_RcvBufferPos) {//short , next
  1304. DoPrintDBGMSG("EVENTReceiveMSGProc:3 ");
  1305. break;
  1306. }
  1307. else {//processing
  1308. DoPrintDBGMSG("EVENTReceiveMSGProc:4 ");
  1309. EVENTCallFunc(extendsize);
  1310. }
  1311. }
  1312. else if(EVENT_RcvBuffer[3]+1 > EVENT_RcvBufferPos) {//short , next
  1313. DoPrintDBGMSG("EVENTReceiveMSGProc:5 ");
  1314. break;
  1315. }
  1316. else {//processing
  1317. DoPrintDBGMSG("EVENTReceiveMSGProc:6 " + EVENT_RcvBuffer[3].ToString());
  1318. EVENTCallFunc(EVENT_RcvBuffer[3]);
  1319. }
  1320. }
  1321. else { // header error
  1322. DoPrintDBGMSG("EVENTReceiveMSGProc:7 ");
  1323. for(int i=0; i<1024*3 ; i++) {//init buffer
  1324. EVENT_RcvBuffer[i] = 0x00;
  1325. }
  1326. EVENT_RcvBufferPos = 0;
  1327. break;
  1328. }
  1329. // int datasize = EVENT_RcvBuffer[3];
  1330. // EVENTCallFunc(datasize);
  1331. }
  1332. // Thread.Sleep(1000);
  1333. DoPrintDBGMSG("- EVENTReceiveMSGProc");
  1334. }
  1335. void EVENTCallFunc(int size) {
  1336. DoPrintDBGMSG ( " + EVENTCallFunc " );
  1337. byte[] cmdbuffer = new byte[size+1];
  1338. for(int i=0; i<size+1 ; i++) {//copy data
  1339. cmdbuffer[i] = EVENT_RcvBuffer[i];
  1340. }
  1341. for(int i=0; i<1024*3; i++) {//rcv buffer compress
  1342. if(i<size+1) {
  1343. EVENT_RcvBuffer[i] = EVENT_RcvBuffer[i+size+1];
  1344. }
  1345. else {
  1346. EVENT_RcvBuffer[i] = 0x00;
  1347. }
  1348. }
  1349. EVENT_RcvBufferPos -= size+1;
  1350. int ret = pkt.DoCheckcs(cmdbuffer , size, cmdbuffer[size]);
  1351. DoPrintDBGMSG ( "EVENTCallFunc cs = " + ret.ToString());
  1352. //check cs
  1353. //if(false) {
  1354. //data setting
  1355. // send to ui
  1356. switch(cmdbuffer[4]) {
  1357. case (byte)RES_define.general_ack: {
  1358. RCVData_ACK ResponseData = new RCVData_ACK();
  1359. ResponseData.Set_Data(cmdbuffer);
  1360. this.cmd.ResponseData = ResponseData;
  1361. break;
  1362. }
  1363. case (byte)RES_define.general_nack: {
  1364. RCVData_NACK ResponseData = new RCVData_NACK();
  1365. ResponseData.Set_Data(cmdbuffer);
  1366. this.cmd.ResponseData = ResponseData;
  1367. break;
  1368. }
  1369. case (byte)RES_define.resd_tbd_state: {
  1370. RCVData_ReadTBoardStatus ResponseData = new RCVData_ReadTBoardStatus();
  1371. ResponseData.Set_Data(cmdbuffer);
  1372. this.cmd.ResponseData = ResponseData;
  1373. break;
  1374. }
  1375. case (byte)RES_define.write_tbd_state: {
  1376. RCVData_WriteTBoardStatus ResponseData = new RCVData_WriteTBoardStatus();
  1377. ResponseData.Set_Data(cmdbuffer);
  1378. this.cmd.ResponseData = ResponseData;
  1379. break;
  1380. }
  1381. case (byte)RES_define.read_repeater_all: {
  1382. RCVData_ReadRepeaterPointAll ResponseData = new RCVData_ReadRepeaterPointAll();
  1383. ResponseData.Set_Data(cmdbuffer);
  1384. int LoopNo = 0;
  1385. int BoardNo = 0;
  1386. this.cmd = new CmdInfo(CMD_define.read_repeater_all, this.main.ui.MyReceiverID, 1, LoopNo, BoardNo, null);
  1387. this.cmd.ResponseData = ResponseData;
  1388. break;
  1389. }
  1390. case (byte)RES_define.write_repeater_output_unit: {
  1391. RCVData_WriteRepeaterOutputUNIT ResponseData = new RCVData_WriteRepeaterOutputUNIT();
  1392. ResponseData.Set_Data(cmdbuffer);
  1393. this.cmd.ResponseData = ResponseData;
  1394. break;
  1395. }
  1396. case (byte)RES_define.read_repeater_info_all: {
  1397. RCVData_ReadRepeaterInfoAll ResponseData = new RCVData_ReadRepeaterInfoAll();
  1398. ResponseData.Set_Data(cmdbuffer);
  1399. this.cmd.ResponseData = ResponseData;
  1400. break;
  1401. }
  1402. case (byte)RES_define.write_repeater_info_unit: {
  1403. RCVData_WriteRepeaterInfoUNIT ResponseData = new RCVData_WriteRepeaterInfoUNIT();
  1404. ResponseData.Set_Data(cmdbuffer);
  1405. this.cmd.ResponseData = ResponseData;
  1406. break;
  1407. }
  1408. case (byte)RES_define.write_repeater_input_unit: {
  1409. RCVData_WriteRepeaterInputUNIT ResponseData = new RCVData_WriteRepeaterInputUNIT();
  1410. ResponseData.Set_Data(cmdbuffer);
  1411. this.cmd.ResponseData = ResponseData;
  1412. break;
  1413. }
  1414. default : {
  1415. DoPrintDBGMSG ( " unKnown CMD " );
  1416. break;
  1417. }
  1418. //}
  1419. // this.main.ui.getEvent(cmd);
  1420. }
  1421. DoPrintDBGMSG ( " - EVENTCallFunc " );
  1422. }
  1423. }
  1424. class Paket {
  1425. static byte[] RawSerialize( object anything ) {
  1426. int rawsize = Marshal.SizeOf( anything );
  1427. IntPtr buffer = Marshal.AllocHGlobal( rawsize );
  1428. Marshal.StructureToPtr( anything, buffer, false );
  1429. byte[] rawdatas = new byte[ rawsize ];
  1430. Marshal.Copy( buffer, rawdatas, 0, rawsize );
  1431. Marshal.FreeHGlobal( buffer );
  1432. return rawdatas;
  1433. }
  1434. static object RawDeserialize( byte[] rawdatas, Type anytype ) {
  1435. object ret_obj;
  1436. int rawsize = Marshal.SizeOf( anytype );
  1437. if( rawsize > rawdatas.Length )
  1438. return null;
  1439. IntPtr buffer = Marshal.AllocHGlobal( rawsize );
  1440. Marshal.Copy( rawdatas, 0, buffer, rawsize );
  1441. ret_obj = Marshal.PtrToStructure( buffer, anytype );
  1442. Marshal.FreeHGlobal( buffer );
  1443. return ret_obj;
  1444. }
  1445. byte DoCalcs(byte[] bt, int size) {
  1446. byte ret_byte = 0x00;
  1447. int counter = 0;
  1448. do {
  1449. ret_byte = (byte) (ret_byte ^ bt[counter]);
  1450. ret_byte++;
  1451. counter++;
  1452. }
  1453. while(counter < size);
  1454. return ret_byte;
  1455. }
  1456. public int DoCheckcs(byte[] bt, int size,byte cs) {
  1457. int ret = 0;
  1458. byte calcs = 0x00;
  1459. calcs = DoCalcs(bt,size);
  1460. if(cs == calcs) {
  1461. ret = 1;
  1462. }
  1463. else {
  1464. ret = 0;
  1465. }
  1466. return ret;
  1467. }
  1468. public byte[] CreatePKT_SayHello_To_Board(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1469. byte[] ret_byte_data;
  1470. PRTReceiver_Type1 PKT = new PRTReceiver_Type1();
  1471. int psize = (byte)default_value_define.size_PRTReceiver_Type1;
  1472. PKT.head = (byte)default_value_define.prt_header_id;
  1473. PKT.RPT_loop = RPT_loop;
  1474. PKT.TBD_ID = TBD_ID;
  1475. PKT.length = (byte)psize;
  1476. PKT.cmd = (byte)CMD_define.say_hello;
  1477. PKT.IVK_ID = IVK_ID;
  1478. PKT.RCVR_ID = RCV_ID;
  1479. PKT.TBD_loop = TBD_loop;
  1480. ret_byte_data = RawSerialize(PKT);
  1481. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1482. return ret_byte_data;
  1483. }
  1484. public byte[] CreatePKT_ReadBoardStatus(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1485. byte[] ret_byte_data;
  1486. PRTReceiver_Type1 PKT = new PRTReceiver_Type1();
  1487. int psize = (byte)default_value_define.size_PRTReceiver_Type1;
  1488. PKT.head = (byte)default_value_define.prt_header_id;
  1489. PKT.RPT_loop = RPT_loop;
  1490. PKT.TBD_ID = TBD_ID;
  1491. PKT.length = (byte)psize;
  1492. PKT.cmd = (byte)CMD_define.resd_tbd_state;
  1493. PKT.IVK_ID = IVK_ID;
  1494. PKT.RCVR_ID = RCV_ID;
  1495. PKT.TBD_loop = TBD_loop;
  1496. ret_byte_data = RawSerialize(PKT);
  1497. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1498. return ret_byte_data;
  1499. }
  1500. public byte[] CreatePKT_WriteBoardStatus(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte RT_BaudRate,byte loop1_BaudRate,byte loop2_BaudRate,byte RT_Term, byte BD_Reset) { //2010.3.24_moon
  1501. byte[] ret_byte_data;
  1502. PRTReceiver_Type6 PKT = new PRTReceiver_Type6();
  1503. int psize = (byte)default_value_define.size_PRTReceiver_Type6;
  1504. PKT.head = (byte)default_value_define.prt_header_id;
  1505. PKT.RPT_loop = RPT_loop;
  1506. PKT.TBD_ID = TBD_ID;
  1507. PKT.length = (byte)psize;
  1508. PKT.cmd = (byte)CMD_define.write_tbd_state;
  1509. PKT.IVK_ID = IVK_ID;
  1510. PKT.RCVR_ID = RCV_ID;
  1511. PKT.Option1 = RT_BaudRate;
  1512. PKT.Option2 = loop1_BaudRate;
  1513. PKT.Option3 = loop2_BaudRate;
  1514. PKT.Option4 = RT_Term;
  1515. PKT.Option5 = BD_Reset;
  1516. PKT.TBD_loop = TBD_loop;
  1517. ret_byte_data = RawSerialize(PKT);
  1518. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1519. return ret_byte_data;
  1520. }
  1521. public byte[] CreatePKT_SearchRepeaterAll(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1522. byte[] ret_byte_data;
  1523. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1524. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1525. PKT.head = (byte)default_value_define.prt_header_id;
  1526. PKT.RPT_loop = RPT_loop;
  1527. PKT.TBD_ID = TBD_ID;
  1528. PKT.length = (byte)psize;
  1529. PKT.cmd = (byte)CMD_define.search_repeater_all;
  1530. PKT.IVK_ID = IVK_ID;
  1531. PKT.RCVR_ID = RCV_ID;
  1532. PKT.TBD_loop = TBD_loop;
  1533. PKT.Option1 = 0xff; //2010.3.24_moon All
  1534. PKT.Option2 = 0x00;
  1535. ret_byte_data = RawSerialize(PKT);
  1536. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1537. return ret_byte_data;
  1538. }
  1539. public byte[] CreatePKT_ReadRepeaterPointAll(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1540. byte[] ret_byte_data;
  1541. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1542. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1543. PKT.head = (byte)default_value_define.prt_header_id;
  1544. PKT.RPT_loop = RPT_loop;
  1545. PKT.TBD_ID = TBD_ID;
  1546. PKT.length = (byte)psize;
  1547. PKT.cmd = (byte)CMD_define.read_repeater_all;
  1548. PKT.IVK_ID = IVK_ID;
  1549. PKT.RCVR_ID = RCV_ID;
  1550. PKT.TBD_loop = TBD_loop;
  1551. PKT.Option1 = 0xff; //2010.3.24_moon All
  1552. PKT.Option2 = 0x00;
  1553. ret_byte_data = RawSerialize(PKT);
  1554. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1555. return ret_byte_data;
  1556. }
  1557. public byte[] CreatePKT_WriteRepeaterOutputUNIT(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  1558. byte[] ret_byte_data;
  1559. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1560. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1561. PKT.head = (byte)default_value_define.prt_header_id;
  1562. PKT.RPT_loop = RPT_loop;
  1563. PKT.TBD_ID = TBD_ID;
  1564. PKT.length = (byte)psize;
  1565. PKT.cmd = (byte)CMD_define.write_repeater_output_unit;
  1566. PKT.IVK_ID = IVK_ID;
  1567. PKT.RCVR_ID = RCV_ID;
  1568. PKT.TBD_loop = TBD_loop;
  1569. PKT.Option1 = Repeater_ID;
  1570. PKT.Option2 = Repeater_Out_Value;
  1571. ret_byte_data = RawSerialize(PKT);
  1572. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1573. return ret_byte_data;
  1574. }
  1575. public byte[] CreatePKT_ReadRepeaterInfoAll(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1576. byte[] ret_byte_data;
  1577. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1578. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1579. PKT.head = (byte)default_value_define.prt_header_id;
  1580. PKT.RPT_loop = RPT_loop;
  1581. PKT.TBD_ID = TBD_ID;
  1582. PKT.length = (byte)psize;
  1583. PKT.cmd = (byte)CMD_define.read_repeater_info_all;
  1584. PKT.IVK_ID = IVK_ID;
  1585. PKT.RCVR_ID = RCV_ID;
  1586. PKT.TBD_loop = TBD_loop;
  1587. PKT.Option1 = 0xff; //2010.3.24_moon All
  1588. PKT.Option2 = 0x00;
  1589. ret_byte_data = RawSerialize(PKT);
  1590. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1591. return ret_byte_data;
  1592. }
  1593. public byte[] CreatePKT_WriteRepeaterInfoUNIT(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  1594. byte[] ret_byte_data;
  1595. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1596. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1597. PKT.head = (byte)default_value_define.prt_header_id;
  1598. PKT.RPT_loop = RPT_loop;
  1599. PKT.TBD_ID = TBD_ID;
  1600. PKT.length = (byte)psize;
  1601. PKT.cmd = (byte)CMD_define.write_repeater_info_unit;
  1602. PKT.IVK_ID = IVK_ID;
  1603. PKT.RCVR_ID = RCV_ID;
  1604. PKT.TBD_loop = TBD_loop;
  1605. PKT.Option1 = Repeater_ID;
  1606. PKT.Option2 = Repeater_Out_Value;
  1607. ret_byte_data = RawSerialize(PKT);
  1608. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1609. return ret_byte_data;
  1610. }
  1611. public byte[] CreatePKT_ResetRepeaterUNIT(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID) {
  1612. byte[] ret_byte_data;
  1613. PRTReceiver_Type2 PKT = new PRTReceiver_Type2();
  1614. int psize = (byte)default_value_define.size_PRTReceiver_Type2;
  1615. PKT.head = (byte)default_value_define.prt_header_id;
  1616. PKT.RPT_loop = RPT_loop;
  1617. PKT.TBD_ID = TBD_ID;
  1618. PKT.length = (byte)psize;
  1619. PKT.cmd = (byte)CMD_define.reset_repeater_unit;
  1620. PKT.IVK_ID = IVK_ID;
  1621. PKT.RCVR_ID = RCV_ID;
  1622. PKT.TBD_loop = TBD_loop;
  1623. PKT.Option1 = Repeater_ID;
  1624. ret_byte_data = RawSerialize(PKT);
  1625. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1626. return ret_byte_data;
  1627. }
  1628. public byte[] CreatePKT_ResetRepeaterAll(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop) {
  1629. byte[] ret_byte_data;
  1630. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1631. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1632. PKT.head = (byte)default_value_define.prt_header_id;
  1633. PKT.RPT_loop = RPT_loop;
  1634. PKT.TBD_ID = TBD_ID;
  1635. PKT.length = (byte)psize;
  1636. PKT.cmd = (byte)CMD_define.reset_repeater_all;
  1637. PKT.IVK_ID = IVK_ID;
  1638. PKT.RCVR_ID = RCV_ID;
  1639. PKT.TBD_loop = TBD_loop;
  1640. PKT.Option1 = 0xff; //2010.3.24_moon All
  1641. PKT.Option2 = 0x00;
  1642. ret_byte_data = RawSerialize(PKT);
  1643. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1644. return ret_byte_data;
  1645. }
  1646. public byte[] CreatePKT_WriteRepeaterInputUNIT(byte RPT_loop, byte TBD_ID ,byte IVK_ID,byte RCV_ID,byte TBD_loop,byte Repeater_ID,byte Repeater_Out_Value) {
  1647. byte[] ret_byte_data;
  1648. PRTReceiver_Type3 PKT = new PRTReceiver_Type3();
  1649. int psize = (byte)default_value_define.size_PRTReceiver_Type3;
  1650. PKT.head = (byte)default_value_define.prt_header_id;
  1651. PKT.RPT_loop = RPT_loop;
  1652. PKT.TBD_ID = TBD_ID;
  1653. PKT.length = (byte)psize;
  1654. PKT.cmd = (byte)CMD_define.write_repeater_input_unit;
  1655. PKT.IVK_ID = IVK_ID;
  1656. PKT.RCVR_ID = RCV_ID;
  1657. PKT.TBD_loop = TBD_loop;
  1658. PKT.Option1 = Repeater_ID;
  1659. PKT.Option2 = Repeater_Out_Value;
  1660. ret_byte_data = RawSerialize(PKT);
  1661. ret_byte_data[psize]= DoCalcs(ret_byte_data,psize);
  1662. return ret_byte_data;
  1663. }
  1664. public void DecPacket(byte [] data , int size) {
  1665. // check cs
  1666. // make upload data
  1667. //
  1668. }
  1669. }
  1670. }