TSocket.cs 39 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039
  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. {
  14. public class TSocket
  15. {// 소켓 클래스
  16. private TcpClient cmd_tcpclient;
  17. private TcpClient event_tcpclient;
  18. private Tprotocol tprotocol;
  19. private String DestIP;
  20. private int commandPort;
  21. private int eventPort;
  22. private Thread cmd_rcv_th;
  23. private int cmd_rcv_th_state = 0;
  24. private NetworkStream cmd_sendStm, cmd_recvStm;
  25. private NetworkStream event_sendStm, event_recvStm;
  26. private Thread event_rcv_th;
  27. private int event_rcv_th_state;
  28. byte[] CMD_RcvBuffer = new byte[2048];
  29. int CMD_RcvBufferPos = 0;
  30. LogFileCreate LFC = new LogFileCreate();
  31. private bool cmdConnected = false;
  32. private bool eventConnected = false;
  33. public delegate int dRcvProcess(byte[] buffer, int size);
  34. private event dRcvProcess CMDRcvProcess;
  35. private event dRcvProcess EVENTRcvProcess;
  36. public TSocket(String Dest_ip, int commandPort, int eventPort, int Demon_ID, Tprotocol tp)
  37. {
  38. try
  39. {
  40. this.DestIP = Dest_ip;
  41. // LCH 2018.02.27 : 데몬을 다른 PC에 둔다
  42. //this.DestIP = "192.168.100.218";
  43. this.commandPort = commandPort;
  44. this.eventPort = eventPort;
  45. this.tprotocol = tp;
  46. CMDRcvProcess += new dRcvProcess(this.tprotocol.CMDResponceFunc);
  47. EVENTRcvProcess += new dRcvProcess(this.tprotocol.EVENTCallFunc);
  48. this.cmd_tcpclient = new TcpClient();
  49. this.event_tcpclient = new TcpClient();
  50. }
  51. catch (Exception ex)
  52. {
  53. Util.UErrorMessage(ex, 0, 0);
  54. }
  55. }
  56. public int ConnectSocket()
  57. {// 소켓 연결 함수
  58. int iret = 0;
  59. try
  60. {
  61. iret = this.Start_Connection();
  62. if (iret == 1)
  63. {// 연결 성공시
  64. this.cmdConnected = true;
  65. this.eventConnected = true;
  66. iret = this.cmd_tcpclient.Connected ? 1 : 0;
  67. }
  68. }
  69. catch (Exception ex)
  70. {
  71. iret = -1;
  72. Util.UErrorMessage(ex, 0, 0);
  73. }
  74. return iret;
  75. }
  76. public int DisconnectToDemon(int Own_ID, int Demon_ID)
  77. {// 데몬 연결 해제
  78. try
  79. {
  80. Stop_Connection();
  81. this.cmdConnected = false;
  82. this.eventConnected = false;
  83. }
  84. catch (Exception ex)
  85. {
  86. Util.UErrorMessage(ex, 0, 0);
  87. }
  88. return 0;
  89. }
  90. IPEndPoint CommandEndPoint { get { return new IPEndPoint(IPAddress.Parse(this.DestIP), this.commandPort); } }
  91. IPEndPoint EventEndPoint { get { return new IPEndPoint(IPAddress.Parse(this.DestIP), this.eventPort); } }
  92. //cmd연결정보
  93. public Boolean cmd_Connected
  94. {//2010,11,22, k.s.d , demon connection status check routine rollback , ( 탁은임 과장이 중간에 바꿨음. 왜 바꾼지는 모름 )
  95. get
  96. {
  97. Boolean TcpConnected = false;
  98. try
  99. {
  100. //if (this.cmd_tcpclient != null) {
  101. // TcpConnected = this.cmd_tcpclient.Connected;
  102. // if (TcpConnected) {
  103. // TcpConnected = this.cmdConnected;
  104. // }
  105. //}
  106. ////
  107. if (this.cmd_tcpclient != null) TcpConnected = this.cmdConnected;
  108. }
  109. catch (Exception ex)
  110. {
  111. Util.UErrorMessage(ex, 0, 0);
  112. }
  113. return TcpConnected;
  114. }
  115. }
  116. //이벤트연결정보
  117. public Boolean event_Connected
  118. {//2010,11,22, k.s.d , demon connection status check routine rollback , ( 탁은임 과장이 중간에 바꿨음. 왜 바꾼지는 모름 )
  119. get
  120. {
  121. Boolean TcpConnected = false;
  122. try
  123. {
  124. //if (this.event_tcpclient != null) {
  125. // TcpConnected = this.event_tcpclient.Connected;
  126. // if (TcpConnected) {
  127. // TcpConnected = this.eventConnected;
  128. // }
  129. //}
  130. ////
  131. if (this.event_tcpclient != null) TcpConnected = this.eventConnected;
  132. }
  133. catch (Exception ex)
  134. {
  135. Util.UErrorMessage(ex, 0, 0);
  136. }
  137. return TcpConnected;
  138. }
  139. }
  140. public int Start_Connection()
  141. {// 연결 시작 함수
  142. int ret = 0;
  143. try
  144. {
  145. ret = Start_Con_cmd();
  146. if (ret == 1)
  147. {// 연결 성공
  148. ret = Start_Con_event();
  149. }
  150. }
  151. catch (Exception ex)
  152. {
  153. ret = -1;
  154. Util.UErrorMessage(ex, 0, 0);
  155. }
  156. return ret;
  157. }
  158. // cyim 2016.12.29 : 화면 멈춤 문제 수정
  159. public delegate void Connect_Thread_Inform_Handler();
  160. public event Connect_Thread_Inform_Handler Connect_Thread_Inform_Event;
  161. public bool Connect_Thread_Inform_Event_Receive = false;
  162. public void Connect_Thread(TcpClient socket, int port, TimeSpan timeout)
  163. {
  164. Connect_Thread_Inform_Event_Receive = false;
  165. if (this.Connect_Thread_Inform_Event != null)
  166. this.Connect_Thread_Inform_Event -= new Connect_Thread_Inform_Handler(TSocket_Connect_Thread_Inform_Event);
  167. this.Connect_Thread_Inform_Event += new Connect_Thread_Inform_Handler(TSocket_Connect_Thread_Inform_Event);
  168. _ConnectThread ConnectThread = new _ConnectThread();
  169. ConnectThread.socket = socket;
  170. ConnectThread.port = port;
  171. ConnectThread.timeout = timeout;
  172. // 스레드로 실행
  173. Thread WorkingThread = new Thread(new ParameterizedThreadStart(Connect_Thread_WorkFunction));
  174. WorkingThread.Start(ConnectThread);
  175. // cyim 2017.01.02
  176. // 프로그램 구조를 잡은 최초 개발자의 의도와는 다르게 소방 수신반의 화면멈춤을 처리하기 위해 일부 변경해야 한다
  177. // 즉, 코드 루틴 중간에 접속을 위한 딜레이가 발생하는것은 어쩔수없이 이벤트 처리를 해야한다
  178. // 소스 루틴 중간에 접속여부를 물어보는 코드를 비동기로 처리하기 위해서 AutoResetEvent 와 같이 스레드가 무한으로 이벤트를 기다리게 할수는 있지만
  179. // 현재 구성된 구조를 변경해야 되므로 비동기+스레드 인 현재 상황에서는 이 방법이 최선인것같다
  180. while (true)
  181. {
  182. if (Connect_Thread_Inform_Event_Receive)
  183. break;
  184. }
  185. if (this.Connect_Thread_Inform_Event != null)
  186. this.Connect_Thread_Inform_Event -= new Connect_Thread_Inform_Handler(TSocket_Connect_Thread_Inform_Event);
  187. }
  188. public void TSocket_Connect_Thread_Inform_Event()
  189. {
  190. Connect_Thread_Inform_Event_Receive = true;
  191. }
  192. // 접속함수를 스레드도 대체하고 타임아웃을 발생시켜서 결과를 획득한다
  193. public bool Connect_Thread_Result = false;
  194. public void Connect_Thread_WorkFunction(object obj)
  195. {
  196. // 소켓 접속을 위한 정보
  197. _ConnectThread ConnectThread = (_ConnectThread)obj;
  198. TcpClient socket = ConnectThread.socket;
  199. int port = ConnectThread.port;
  200. TimeSpan timeout = ConnectThread.timeout;
  201. try
  202. {
  203. IPAddress addr = IPAddress.Parse(this.DestIP);
  204. var result = socket.BeginConnect(addr, port, null, null);
  205. bool success = result.AsyncWaitHandle.WaitOne(timeout, true);
  206. if (success)
  207. {
  208. socket.EndConnect(result);
  209. Connect_Thread_Result = true;
  210. }
  211. else
  212. {
  213. socket.Close();
  214. Connect_Thread_Result = false;
  215. Console.WriteLine(this.DestIP);
  216. }
  217. }
  218. catch
  219. {
  220. socket.Close();
  221. Connect_Thread_Result = false;
  222. }
  223. TSocket_Connect_Thread_Inform_Event();
  224. }
  225. // 2010,11,25, k.s.d , return value add .
  226. int Start_Con_cmd()
  227. {
  228. int ret = 0;
  229. try
  230. {
  231. // cyim 2016.12.29 : 화면 멈춤 문제 수정
  232. if (_Data.FireDeskMode == true)
  233. {
  234. Connect_Thread(this.cmd_tcpclient, this.commandPort, new TimeSpan(0, 0, 1));
  235. }
  236. else
  237. {
  238. this.cmd_tcpclient.Connect(this.CommandEndPoint);
  239. }
  240. this.cmd_sendStm = new NetworkStream(this.cmd_tcpclient.Client);
  241. this.cmd_recvStm = new NetworkStream(this.cmd_tcpclient.Client);
  242. this.cmd_rcv_th = new Thread(this.Cmd_ReceiveThread);
  243. this.cmd_rcv_th_state = 1;
  244. if (this.cmd_rcv_th != null) // 쓰레드 할당 여부 확인후 동작시킴.
  245. {
  246. this.cmd_rcv_th.Start();
  247. }
  248. ret = 1;
  249. }
  250. catch (Exception ex)
  251. {
  252. ret = -1;
  253. Util.UErrorMessage(ex, 0, 0);
  254. }
  255. return ret;
  256. }
  257. // 2010,11,25, k.s.d , return value add .
  258. int Start_Con_event()
  259. {
  260. int ret = 0;
  261. try
  262. {
  263. // cyim 2016.12.29 : 화면 멈춤 문제 수정
  264. if (_Data.FireDeskMode == true)
  265. {
  266. Connect_Thread(this.event_tcpclient, this.eventPort, new TimeSpan(0, 0, 1));
  267. }
  268. else
  269. {
  270. this.event_tcpclient.Connect(this.EventEndPoint);
  271. }
  272. this.event_sendStm = new NetworkStream(this.event_tcpclient.Client);
  273. if (this.event_sendStm == null)
  274. {
  275. ret = -1;
  276. return ret;
  277. }
  278. this.event_recvStm = new NetworkStream(this.event_tcpclient.Client);
  279. if (this.event_recvStm == null)
  280. {
  281. ret = -1;
  282. return ret;
  283. }
  284. this.event_rcv_th = new Thread(this.Event_ReceiveThread);
  285. if (this.event_rcv_th != null)
  286. {
  287. //===============================================
  288. // 에러 발견 수정 2013-06-05 CSW
  289. //===============================================
  290. this.event_rcv_th_state = 1;
  291. this.event_rcv_th.Start();
  292. ret = 1;
  293. }
  294. else
  295. {
  296. ret = -1;
  297. }
  298. //Util.UDebugMessage("Start_Con_event Start",0,0);
  299. }
  300. catch (Exception ex)
  301. {
  302. ret = -1;
  303. Util.UErrorMessage(ex, 0, 0);
  304. }
  305. return ret;
  306. }
  307. public void Stop_Connection()
  308. {
  309. try
  310. {
  311. //Util.UDebugMessage("Stop",0,0);
  312. Stop_Con_cmd();
  313. Stop_Con_event();
  314. }
  315. catch (Exception ex)
  316. {
  317. Util.UErrorMessage(ex, 0, 0);
  318. }
  319. }
  320. void Stop_Con_cmd()
  321. {
  322. try
  323. {
  324. // if (this.cmd_rcv_th_state == 1) this.cmd_rcv_th.Abort();
  325. if (this.cmd_rcv_th != null) // cyim 2016.12.28 : 예외처리 추가
  326. if (this.cmd_rcv_th.IsAlive)
  327. this.cmd_rcv_th.Abort(); // 쓰레드 종료.
  328. if (this.cmd_tcpclient != null) this.cmd_tcpclient.Close();
  329. }
  330. catch (Exception ex)
  331. {
  332. Util.UErrorMessage(ex, 0, 0);
  333. }
  334. }
  335. void Stop_Con_event()
  336. {
  337. try
  338. {
  339. //if (this.event_rcv_th_state == 1) this.event_rcv_th.Abort();
  340. if (this.event_rcv_th != null) // cyim 2016.12.28 : 예외처리 추가
  341. if (this.event_rcv_th.IsAlive)
  342. this.event_rcv_th.Abort();
  343. if (this.event_tcpclient != null) this.event_tcpclient.Close();
  344. }
  345. catch (Exception ex)
  346. {
  347. Util.UErrorMessage(ex, 0, 0);
  348. }
  349. }
  350. //명령전송
  351. public int Cmd_Send(byte[] bt, int size)
  352. { //2010.3.12ksd ,// cmd 전송 함수
  353. int ret = 0;
  354. try
  355. {
  356. if (this.cmd_tcpclient != null)
  357. {
  358. if (this.cmd_tcpclient.Connected)
  359. {
  360. try
  361. {
  362. string Data = String.Empty;
  363. for (int i = 0; i < bt.Length; i++)
  364. {
  365. string value = Convert.ToString(bt[i], 16);
  366. if (value.Length == 1) value = "0" + value;
  367. Data += value + " ";
  368. }
  369. if (Data.Substring(12, 2) != "14")
  370. LFC.Log("[ Commo ] [전송] " + Data);
  371. if (_Data.Enable_Log == true)
  372. {
  373. _Event.Log_SendMessage_Write("[ Commo ] [전송] " + Data);
  374. }
  375. this.cmd_sendStm.Write(bt, 0, size);
  376. this.cmd_sendStm.Flush();
  377. ret = 1;
  378. }
  379. catch (Exception ex)
  380. {
  381. Util.UErrorMessage(ex, 0, 0);
  382. ret = -3;
  383. }
  384. }
  385. else
  386. {
  387. ret = -2;
  388. }
  389. }
  390. else
  391. {
  392. ret = -1;
  393. }
  394. }
  395. catch (Exception ex)
  396. {
  397. ret = -1;
  398. Util.UErrorMessage(ex, 0, 0);
  399. }
  400. return ret;
  401. }
  402. void Cmd_ReceiveThread()
  403. {//cmd listen thread
  404. byte[] ReadBuffer = new byte[1024];
  405. int offset = 0;
  406. while (this.cmd_rcv_th_state == 1)
  407. {
  408. try
  409. {
  410. if (this.cmd_tcpclient.Connected)
  411. {
  412. // cyim 2013.7.19 속도개선작업
  413. //for (int i = 0; i < 1024; i++)
  414. //{
  415. // ReadBuffer[i] = 0x00;
  416. //}
  417. Array.Clear(ReadBuffer, 0, 1024);
  418. offset = 0;
  419. if (this.cmd_recvStm.CanRead)
  420. {
  421. offset = this.cmd_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  422. //Debug.WriteLine("Receive Read : " + offset.ToString());
  423. if (offset > 0)
  424. {
  425. //Debug.WriteLine(ToHex(ReadBuffer, offset));
  426. string Data = String.Empty;
  427. for (int i = 0; i < offset; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  428. {
  429. string value = Convert.ToString(ReadBuffer[i], 16);
  430. if (value.Length == 1) value = "0" + value;
  431. Data += value + " ";
  432. }
  433. if (Data.Substring(12, 2) != "80" && Data.Substring(12, 2) != "94")
  434. LFC.Log("[ Commo ] [응답] " + Data);
  435. if (_Data.Enable_Log == true)
  436. {
  437. _Event.Log_SendMessage_Write("[ Commo ] [응답] " + Data);
  438. System.Diagnostics.Debug.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff") + " 응답 " + Data + "\r\n");
  439. }
  440. CMDReceiveMSGProc(ReadBuffer, offset);
  441. }
  442. else
  443. {
  444. if (cmd_recvStm.DataAvailable)
  445. {
  446. //Debug.WriteLine("cmd_recvStm.DataAvailable");
  447. }
  448. else
  449. {
  450. //Debug.WriteLine("Error");
  451. this.cmd_rcv_th_state = 0;
  452. this.cmdConnected = false;
  453. break;
  454. }
  455. }
  456. }
  457. else
  458. {
  459. //Debug.WriteLine("Error");
  460. this.cmd_rcv_th_state = 0;
  461. this.cmdConnected = false;
  462. break;
  463. }
  464. this.cmd_recvStm.Flush();
  465. }
  466. else
  467. {
  468. // don't connected
  469. //Debug.WriteLine("Error");
  470. this.cmd_rcv_th_state = 0;
  471. this.cmdConnected = false;
  472. break;
  473. }
  474. }
  475. catch (Exception ex)
  476. {
  477. Util.UErrorMessage(ex, 0, 0);
  478. //Debug.WriteLine(e.ToString());
  479. //Debug.WriteLine("Error");
  480. this.cmd_rcv_th_state = 0;
  481. this.cmdConnected = false;
  482. break;
  483. }
  484. }
  485. this.cmd_rcv_th_state = 0;
  486. }
  487. //void Cmd_ReceiveThread()
  488. //{
  489. // try
  490. // {
  491. // byte[] ReadBuffer = new byte[1024];
  492. // int offset = 0;
  493. // while (this.cmd_rcv_th_state == 1)
  494. // {
  495. // if (this.cmd_tcpclient.Connected)
  496. // {
  497. // //Debug.WriteLine("Receive Connected");
  498. // for (int i = 0; i < 1024; i++)
  499. // {
  500. // ReadBuffer[i] = 0x00;
  501. // }
  502. // offset = 0;
  503. // if (this.cmd_recvStm.CanRead)
  504. // {
  505. // //Debug.WriteLine("Receive CanRead");
  506. // offset = this.cmd_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  507. // //Debug.WriteLine("Receive Read");
  508. // if (offset > 0)
  509. // {
  510. // Debug.WriteLine(ToHex(ReadBuffer, offset));
  511. // CMDReceiveMSGProc(ReadBuffer, offset);
  512. // }
  513. // else
  514. // {
  515. // //데몬이 죽었다..
  516. // this.cmd_rcv_th_state = 0;
  517. // Stop_Con_cmd();
  518. // break;
  519. // }
  520. // }
  521. // //데몬이 끊기면 무한루프 돈다..
  522. // //if (!this.cmd_recvStm.DataAvailable) this.cmd_rcv_th_state = 0;
  523. // this.cmd_recvStm.Flush();
  524. // }
  525. // else
  526. // {
  527. // // don't connected
  528. // break;
  529. // }
  530. // }
  531. // this.cmd_rcv_th_state = 0;
  532. // }
  533. // catch (Exception ex)
  534. // {
  535. // MessageBox.Show(string.Format("[{0}]\r\n{1}",ex.Message,ex.Source),Application.ProductName);
  536. // }
  537. //}
  538. void CMDReceiveMSGProc(byte[] ReadBuffer, int size)
  539. {
  540. // cmd message processing function
  541. // cyim 2013.7.19 속도개선작업
  542. //init buffer
  543. //for (int i = 0; i < 2048; i++)
  544. //{
  545. // CMD_RcvBuffer[i] = 0x00;
  546. //}
  547. Array.Clear(CMD_RcvBuffer, 0, 2048);
  548. CMD_RcvBufferPos = 0;
  549. for (int i = 0; i < size; i++)
  550. {
  551. //copy buffer
  552. CMD_RcvBuffer[CMD_RcvBufferPos + i] = ReadBuffer[i];
  553. }
  554. CMD_RcvBufferPos += size;
  555. int datasize = CMD_RcvBuffer[3];
  556. if (datasize == 0)
  557. {
  558. datasize = (CMD_RcvBuffer[5] & 0xff | (CMD_RcvBuffer[6] << 8) & 0xff00) & 0xffff;
  559. }
  560. //CMDResponceFunc(datasize);
  561. byte[] cmdbuffer = new byte[datasize + 1];
  562. Array.Copy(CMD_RcvBuffer, 0, cmdbuffer, 0, datasize + 1);
  563. //for (int i = 0; i < rcvSize + 1; i++)
  564. //{//copy data
  565. // cmdbuffer[i] = rcvBuff[i];
  566. //}
  567. for (int i = 0; i < 2048; i++)
  568. {//rcv buffer compress
  569. if (i < CMD_RcvBufferPos)
  570. {
  571. CMD_RcvBuffer[i] = CMD_RcvBuffer[i + datasize + 1];
  572. }
  573. else
  574. {
  575. CMD_RcvBuffer[i] = 0x00;
  576. }
  577. CMD_RcvBufferPos -= datasize + 1;
  578. }
  579. //명령처리 이벤트
  580. CMDRcvProcess(cmdbuffer, datasize);
  581. }
  582. public void Event_Send(byte[] bt, int size)
  583. { //2010.3.17_moon //don't using
  584. try
  585. {
  586. if (this.event_tcpclient != null)
  587. {
  588. if (this.event_tcpclient.Connected)
  589. {
  590. this.event_sendStm.Write(bt, 0, size);
  591. this.event_sendStm.Flush();
  592. }
  593. }
  594. }
  595. catch (Exception ex)
  596. {
  597. Util.UErrorMessage(ex, 0, 0);
  598. }
  599. }
  600. //void Event_ReceiveThread()
  601. //{
  602. // byte[] ReadBuffer = new byte[1024];
  603. // int offset = 0;
  604. // while (this.event_rcv_th_state == 1)
  605. // {
  606. // if (this.event_tcpclient.Connected)
  607. // {
  608. // // Debug.WriteLine("Event_ReceiveThread");
  609. // try
  610. // {
  611. // if (this.event_recvStm.CanRead)
  612. // {
  613. // for (int i = 0; i < 1024; i++)
  614. // {
  615. // ReadBuffer[i] = 0x00;
  616. // }
  617. // offset = this.event_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  618. // if (offset > 0)
  619. // {
  620. // string str;
  621. // str = ToHex(ReadBuffer, offset);
  622. // Debug.WriteLine("Event_ReceiveThread size : " + offset.ToString() + "//data : " + str);
  623. // // Debug.WriteLine(string.Format("0x{0:x2} ", ReadBuffer[offset-1]));
  624. // EVENTReceiveMSGFunc(ReadBuffer, offset);
  625. // }
  626. // else
  627. // {
  628. // //데몬이 죽었다..
  629. // this.event_rcv_th_state = 0;
  630. // Stop_Con_event();
  631. // break;
  632. // }
  633. // }
  634. // this.event_recvStm.Flush();
  635. // // call main func -> case by case
  636. // }
  637. // catch (Exception e)
  638. // {
  639. // //error
  640. // Debug.WriteLine(e.Message);
  641. // }
  642. // }
  643. // else
  644. // {
  645. // break;
  646. // }
  647. // }
  648. // this.event_rcv_th_state = 0;
  649. //}
  650. void Event_ReceiveThread()
  651. {// event listen thread
  652. byte[] ReadBuffer = new byte[3072];//2048
  653. int offset = 0;
  654. while (this.event_rcv_th_state == 1)
  655. {
  656. if (this.event_tcpclient.Connected)
  657. {
  658. // //Debug.WriteLine("Event_ReceiveThread");
  659. try
  660. {
  661. if (this.event_recvStm.CanRead)
  662. {
  663. // cyim 2013.7.19 속도개선작업
  664. //for (int i = 0; i < 3072; i++)
  665. //{
  666. // ReadBuffer[i] = 0x00;
  667. //}
  668. Array.Clear(ReadBuffer, 0, 3072);//2048
  669. offset = this.event_recvStm.Read(ReadBuffer, 0, ReadBuffer.Length);
  670. if (offset > 0)
  671. {
  672. string str;
  673. str = ToHex(ReadBuffer, offset);
  674. //Debug.WriteLine("Event_ReceiveThread size : " + offset.ToString() + "//data : " + str);3072
  675. // //Debug.WriteLine(string.Format("0x{0:x2} ", ReadBuffer[offset-1]));
  676. //Util.LogBineryWrite(ReadBuffer, offset); //데몬에서 보내온 패킷을 파일에 저장한다.. --임시
  677. EVENTReceiveMSGFunc(ReadBuffer, offset);
  678. // LCH 2018.02.27 : 이벤트 로그
  679. /*
  680. if (_Data.Enable_Log == true)
  681. {
  682. string Data = String.Empty;
  683. for (int i = 0; i < offset; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  684. {
  685. string value = Convert.ToString(ReadBuffer[i], 16);
  686. if (value.Length == 1) value = "0" + value;
  687. Data += value + " ";
  688. }
  689. _Event.Log_SendMessage_Write("[ Event ] [응답] " + Data);
  690. LFC.Log("[ Event ] [응답] " + Data);
  691. //System.Diagnostics.Debug.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff") + " 응답 " + Data + "\r\n");
  692. }
  693. else
  694. {
  695. string Data = String.Empty;
  696. for (int i = 0; i < offset; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  697. {
  698. string value = Convert.ToString(ReadBuffer[i], 16);
  699. if (value.Length == 1) value = "0" + value;
  700. Data += value + " ";
  701. }
  702. LFC.Log("[ Event ] [응답] " + Data);
  703. }*/
  704. }
  705. else
  706. {
  707. if (event_recvStm.DataAvailable)
  708. {
  709. //Debug.WriteLine("cmd_recvStm.DataAvailable");
  710. }
  711. else
  712. {
  713. //Debug.WriteLine("Error");
  714. this.event_rcv_th_state = 0;
  715. this.eventConnected = false;
  716. break;
  717. }
  718. }
  719. }
  720. else
  721. {
  722. //Debug.WriteLine("Error");
  723. this.cmd_rcv_th_state = 0;
  724. this.cmdConnected = false;
  725. break;
  726. }
  727. this.event_recvStm.Flush();
  728. // call main func -> case by case
  729. }
  730. catch (Exception ex)
  731. {
  732. Util.UErrorMessage(ex, 0, 0);
  733. //Debug.WriteLine(e.Message);
  734. //Debug.WriteLine("Error");
  735. this.cmd_rcv_th_state = 0;
  736. this.cmdConnected = false;
  737. break;
  738. }
  739. }
  740. else
  741. {
  742. //Debug.WriteLine("Error");
  743. this.cmd_rcv_th_state = 0;
  744. this.cmdConnected = false;
  745. break;
  746. }
  747. }
  748. this.event_rcv_th_state = 0;
  749. }
  750. byte[] EVENT_RcvBuffer = new byte[6144];
  751. int EVENT_RcvBufferPos = 0;
  752. void EVENTReceiveMSGFunc(byte[] ReadBuffer, int size)
  753. {
  754. // event data processing functin
  755. //Util.LogWrite(string.Format("EVENTReceiveMSGFunc() ReadBuffer:{0},size:{1}", Util.ToHex(ReadBuffer), size));
  756. if ((EVENT_RcvBufferPos < 0) && (EVENT_RcvBufferPos > 3072))
  757. {
  758. // cyim 2013.7.19 버퍼 초과 경고창
  759. //Util.LogWrite(string.Format("버퍼사이즈 초과!! 에러 EVENT_RcvBufferPos:{0}", EVENT_RcvBufferPos));
  760. // cyim 2015.8.4 수신반을 위한 static 클래스 정리 : 불필요한 루틴 제거
  761. //mdi.Event.SocketBufferError_Inform_Write(string.Format("버퍼사이즈 초과!! 에러 EVENT_RcvBufferPos:{0}", EVENT_RcvBufferPos));
  762. // cyim 2013.7.19 속도개선작업
  763. //init buffer
  764. //for (int i = 0; i < 3072; i++)
  765. //{
  766. // EVENT_RcvBuffer[i] = 0x00;
  767. //}
  768. Array.Clear(EVENT_RcvBuffer, 0, 3072);
  769. EVENT_RcvBufferPos = 0;
  770. }
  771. for (int i = 0; i < size; i++)
  772. {
  773. //copy buffer
  774. EVENT_RcvBuffer[EVENT_RcvBufferPos + i] = ReadBuffer[i];
  775. }
  776. EVENT_RcvBufferPos += size;
  777. while (EVENT_RcvBufferPos > 7)
  778. {
  779. // data minimum size
  780. if (EVENT_RcvBuffer[0] == 0x02)
  781. {
  782. // stx
  783. if (EVENT_RcvBuffer[3] == 0x00)
  784. {
  785. //extend size
  786. int extendsize = (EVENT_RcvBuffer[5] & 0xff | (EVENT_RcvBuffer[6] << 8) & 0xff00) & 0xffff;
  787. //Util.UDebugMessage("EVENTReceiveMSGFunc: extend size : " + extendsize.ToString(),0,0);
  788. if (extendsize + 1 > EVENT_RcvBufferPos)
  789. {
  790. //short , next
  791. //Util.UDebugMessage("EVENTReceiveMSGFunc: short , next ",0,0);
  792. break;
  793. }
  794. else
  795. {
  796. //processing
  797. //처리할 패킷만큼 보낸다..
  798. byte[] cmdbuffer = new byte[extendsize + 1];
  799. Array.Copy(EVENT_RcvBuffer, cmdbuffer, extendsize + 1);
  800. EVENTRcvProcess(cmdbuffer, extendsize); //패킷처리
  801. //로그 처리 cmdbuffer, extendsiz
  802. if (_Data.Enable_Log == true)
  803. {
  804. string Data = String.Empty;
  805. for (int i = 0; i < extendsize; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  806. {
  807. string value = Convert.ToString(cmdbuffer[i], 16);
  808. if (value.Length == 1) value = "0" + value;
  809. Data += value + " ";
  810. }
  811. _Event.Log_SendMessage_Write("[ Event ] [응답] " + Data);
  812. LFC.Log("[ Event ] [응답] " + Data);
  813. }
  814. else
  815. {
  816. string Data = String.Empty;
  817. for (int i = 0; i < extendsize; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  818. {
  819. string value = Convert.ToString(cmdbuffer[i], 16);
  820. if (value.Length == 1) value = "0" + value;
  821. Data += value + " ";
  822. }
  823. LFC.Log("[ Event ] [응답] " + Data);
  824. }
  825. //처리한 패킷을 제거한다.
  826. Array.Copy(EVENT_RcvBuffer, extendsize + 1, EVENT_RcvBuffer, 0, EVENT_RcvBuffer.Length - extendsize - 1);
  827. EVENT_RcvBufferPos -= extendsize + 1;
  828. //Debug.WriteLine("EVENTReceiveMSGFunc: processing ");
  829. //EVENTRcvProcess(EVENT_RcvBuffer,extendsize);
  830. //Util.LogWrite(string.Format("EVENT_RcvBuffer:{0},Length:{1}", Util.ToHex(EVENT_RcvBuffer), extendsize));
  831. //EVENT_RcvBufferPos -= extendsize + 1;
  832. }
  833. }
  834. else if (EVENT_RcvBuffer[3] + 1 > EVENT_RcvBufferPos)
  835. {
  836. //short , next
  837. //Util.UDebugMessage("EVENTReceiveMSGFunc: short , next",0,0);
  838. break;
  839. }
  840. else
  841. {
  842. int extendsize = EVENT_RcvBuffer[3];
  843. //처리할 패킷만큼 보낸다..
  844. byte[] cmdbuffer = new byte[extendsize + 1];
  845. Array.Copy(EVENT_RcvBuffer, cmdbuffer, extendsize + 1);
  846. EVENTRcvProcess(cmdbuffer, extendsize); //패킷처리
  847. //로그 처리 cmdbuffer, extendsiz
  848. if (_Data.Enable_Log == true)
  849. {
  850. string Data = String.Empty;
  851. for (int i = 0; i < extendsize; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  852. {
  853. string value = Convert.ToString(cmdbuffer[i], 16);
  854. if (value.Length == 1) value = "0" + value;
  855. Data += value + " ";
  856. }
  857. _Event.Log_SendMessage_Write("[ Event ] [응답] " + Data);
  858. LFC.Log("[ Event ] [응답] " + Data);
  859. }
  860. else
  861. {
  862. string Data = String.Empty;
  863. for (int i = 0; i < extendsize; i++) // for (int i = 0; i < ReadBuffer.Length; i++)
  864. {
  865. string value = Convert.ToString(cmdbuffer[i], 16);
  866. if (value.Length == 1) value = "0" + value;
  867. Data += value + " ";
  868. }
  869. LFC.Log("[ Event ] [응답] " + Data);
  870. }
  871. //처리한 패킷을 제거한다.
  872. Array.Copy(EVENT_RcvBuffer, extendsize + 1, EVENT_RcvBuffer, 0, EVENT_RcvBuffer.Length - extendsize - 1);
  873. EVENT_RcvBufferPos -= extendsize + 1;
  874. ////processing
  875. //Debug.WriteLine("EVENTReceiveMSGFunc: size : " + EVENT_RcvBuffer[3].ToString());
  876. //Debug.WriteLine("EVENTReceiveMSGFunc: processing" + EVENT_RcvBuffer[3].ToString());
  877. //int extendsize = EVENT_RcvBuffer[3];
  878. //EVENTRcvProcess(EVENT_RcvBuffer, extendsize);
  879. //Util.LogWrite(string.Format("EVENT_RcvBuffer:{0},Length:{1}", Util.ToHex(EVENT_RcvBuffer), extendsize));
  880. //EVENT_RcvBufferPos -= extendsize + 1;
  881. }
  882. }
  883. else
  884. {
  885. // header error
  886. Util.LogWrite(string.Format("EVENTReceiveMSGFunc header error {0}", Util.ToHex(EVENT_RcvBuffer))); //명령 로그에 저장
  887. //Debug.WriteLine("EVENTReceiveMSGFunc: header error : " + EVENT_RcvBuffer[0].ToString());
  888. for (int i = 0; i < 3072; i++)
  889. {
  890. //init buffer
  891. //EVENT_RcvBuffer[i] = 0x00;
  892. //다음 헤더를 찾는다..
  893. if (EVENT_RcvBuffer[i] == 0x02)
  894. {
  895. //헤더를 찾은위치 이전까지 버린다.
  896. int extendsize = i - 1;
  897. //처리한 패킷을 제거한다.
  898. Array.Copy(EVENT_RcvBuffer, extendsize + 1, EVENT_RcvBuffer, 0, EVENT_RcvBuffer.Length - extendsize - 1);
  899. EVENT_RcvBufferPos -= extendsize + 1;
  900. break;
  901. }
  902. }
  903. //for (int i = 0; i < 3072; i++)
  904. //{//init buffer
  905. // EVENT_RcvBuffer[i] = 0x00;
  906. //}
  907. //EVENT_RcvBufferPos = 0;
  908. break;
  909. }
  910. }
  911. }
  912. string ToHex(byte[] bin_data)
  913. {// byte to hex function
  914. string result = "";
  915. try
  916. {
  917. foreach (byte ch in bin_data)
  918. {
  919. result += string.Format("{0:x2} ", ch);
  920. }
  921. }
  922. catch (Exception ex)
  923. {
  924. Util.UErrorMessage(ex, 0, 0);
  925. }
  926. return result;
  927. }
  928. string ToHex(byte[] bin_data, int len)
  929. {// multiple byte to hex
  930. string result = "";
  931. try
  932. {
  933. for (int i = 0; i < len; i++)
  934. {
  935. result += string.Format("{0:x2} ", bin_data[i]);
  936. }
  937. }
  938. catch (Exception ex)
  939. {
  940. Util.UErrorMessage(ex, 0, 0);
  941. }
  942. return result;
  943. }
  944. }
  945. }