22ed69884b731fb0b2cb3aa242a415bec8a5049c.svn-base 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.Net.Sockets;
  7. using System.Net;
  8. using System.Threading;
  9. using System.Runtime.InteropServices;
  10. using System.Data.SqlClient;
  11. using System.Data;
  12. using System.Data.OleDb;
  13. namespace BEMSDataGateway
  14. {
  15. public class IcosComm
  16. {
  17. //iCos 통신패킷 선언
  18. iCosMonitorValue _valuePacket;
  19. iCosMonitorText _textPacket;
  20. iCosLogInResponse _loginPacket;
  21. iCosMonitorValueArray _valueArrayPacket;
  22. iCosMonitorTextArray _textArrayPacket;
  23. iCosAlarmAckFromServer _alarmAckServerPacket;
  24. iCosAlarmNotify _alarmNotifyPacket;
  25. iCosAlarmAllAck _alarmAllAckPacket;
  26. LogFileCreate LFC = new LogFileCreate(); //로그 기록 파일
  27. //관제점정보 딕셔너리
  28. Dictionary<string, iCosTag> AddressData = new Dictionary<string, iCosTag>();
  29. Dictionary<int, iCosTagIndex> AddressIndex = new Dictionary<int, iCosTagIndex>();
  30. //통신연결정보 딕셔너리
  31. Dictionary<string, ClientData> Clients = new Dictionary<string, ClientData>();
  32. //통신 Critical section용 오브젝트
  33. private Object iCosCommObj = new Object();
  34. //통신응답 상위 전송용 딜리게이트 함수
  35. public delegate void iCosCallback(string userid, int nType, int nSubType, Object obj);
  36. public event iCosCallback iCosResponse;
  37. //통신 재접속용 쓰레드
  38. Thread ConnectionManageThread;
  39. Thread thread_connect;
  40. Thread thread_managerconnection;
  41. //통신 재접속용 쓰레드 초기화
  42. public void InitThread()
  43. {
  44. try
  45. {
  46. ConnectionManageThread = new Thread(new ThreadStart(ManagerConnection));
  47. ConnectionManageThread.IsBackground = true;
  48. ConnectionManageThread.Start();
  49. LFC.Log("[IcosComm.cs] InitThread 시작");
  50. }
  51. catch (ThreadStartException)
  52. {
  53. LFC.Log("[IcosComm.cs] InitThread 사망" + Environment.NewLine);
  54. }
  55. }
  56. //관제점정보 DB에서 가져오기
  57. public bool InitTagAddress(int nDbType, string dbPath, string dbname, string dbid, string dbpassword) // MS-SQL 디폴트
  58. {
  59. bool bRet = false;
  60. string strSql = "SELECT * FROM TB_POINT";
  61. string strTag;
  62. int nDataCnt;
  63. string strCon;
  64. try
  65. {
  66. if (nDbType == 0) // MDB
  67. {
  68. strCon = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + dbPath;
  69. DataSet ds = new DataSet();
  70. OleDbConnection mdbcon = null;
  71. mdbcon = new OleDbConnection(strCon);
  72. OleDbCommand mdbcmd = new OleDbCommand(strSql, mdbcon);
  73. OleDbDataAdapter adp = new OleDbDataAdapter(mdbcmd);
  74. mdbcon.Open();
  75. adp.Fill(ds, "TB_POINT");
  76. nDataCnt = ds.Tables[0].Rows.Count;
  77. for (int i = 0; i < nDataCnt; i++)
  78. {
  79. iCosTag _tagAddr = new iCosTag();
  80. iCosTagIndex _tagIndex = new iCosTagIndex();
  81. _tagAddr.nChannel = Convert.ToInt32(ds.Tables[0].Rows[i][0]);
  82. _tagAddr.nController = Convert.ToInt32(ds.Tables[0].Rows[i][1]);
  83. _tagAddr.nDataType = Convert.ToInt32(ds.Tables[0].Rows[i][3]);
  84. _tagAddr.nPoint = Convert.ToInt32(ds.Tables[0].Rows[i][2]);
  85. _tagAddr.nState = 0;
  86. _tagAddr.szText = "";
  87. _tagAddr.analog = 0;
  88. _tagAddr.digital = 0;
  89. strTag = ds.Tables[0].Rows[i][4].ToString();
  90. _tagIndex.szTag = strTag;
  91. _tagIndex.nChannel = Convert.ToInt32(ds.Tables[0].Rows[i][0]);
  92. _tagIndex.nController = Convert.ToInt32(ds.Tables[0].Rows[i][1]);
  93. _tagIndex.nDataType = Convert.ToInt32(ds.Tables[0].Rows[i][3]);
  94. _tagIndex.nPoint = Convert.ToInt32(ds.Tables[0].Rows[i][2]);
  95. if (!String.IsNullOrEmpty(strTag))
  96. {
  97. if (AddressData.ContainsKey(strTag) == false)
  98. AddressData.Add(strTag, _tagAddr);
  99. bRet = true;
  100. }
  101. if (AddressIndex.ContainsKey(_tagAddr.nPoint) == false)
  102. {
  103. AddressIndex.Add(_tagIndex.nPoint, _tagIndex);
  104. }
  105. }
  106. }
  107. else if (nDbType == 1)//MS-SQL
  108. {
  109. strCon = @"Data Source = '" + dbPath + "'; Initial Catalog ='" + dbname + "';Persist Security Info=True; User ID = '" + dbid + "'; Password = '" + dbpassword + "'";
  110. SqlConnection dbcon = new SqlConnection();
  111. SqlCommand dbcmd = new SqlCommand();
  112. dbcmd.CommandText = strSql;
  113. dbcmd.Connection = dbcon;
  114. dbcon.ConnectionString = strCon;
  115. dbcon.Open();
  116. SqlDataAdapter adp = new SqlDataAdapter(dbcmd);
  117. DataSet ds = new DataSet();
  118. adp.Fill(ds);
  119. nDataCnt = ds.Tables[0].Rows.Count;
  120. for (int i = 0; i < nDataCnt; i++)// channel, controller, point, datatype
  121. {
  122. iCosTag _tagAddr = new iCosTag();
  123. iCosTagIndex _tagIndex = new iCosTagIndex();
  124. _tagAddr.nChannel = Convert.ToInt32(ds.Tables[0].Rows[i][0]);
  125. _tagAddr.nController = Convert.ToInt32(ds.Tables[0].Rows[i][1]);
  126. _tagAddr.nDataType = Convert.ToInt32(ds.Tables[0].Rows[i][3]);
  127. _tagAddr.nPoint = Convert.ToInt32(ds.Tables[0].Rows[i][2]);
  128. _tagAddr.nState = 0;
  129. _tagAddr.szText = "";
  130. _tagAddr.analog = 0;
  131. _tagAddr.digital = 0;
  132. strTag = ds.Tables[0].Rows[i][4].ToString();
  133. _tagIndex.szTag = strTag;
  134. _tagIndex.nChannel = Convert.ToInt32(ds.Tables[0].Rows[i][0]);
  135. _tagIndex.nController = Convert.ToInt32(ds.Tables[0].Rows[i][1]);
  136. _tagIndex.nDataType = Convert.ToInt32(ds.Tables[0].Rows[i][3]);
  137. _tagIndex.nPoint = Convert.ToInt32(ds.Tables[0].Rows[i][2]);
  138. if (!String.IsNullOrEmpty(strTag))
  139. {
  140. if (AddressData.ContainsKey(strTag) == false)
  141. AddressData.Add(strTag, _tagAddr);
  142. bRet = true;
  143. }
  144. if (AddressIndex.ContainsKey(_tagAddr.nPoint) == false)
  145. {
  146. AddressIndex.Add(_tagIndex.nPoint, _tagIndex);
  147. }
  148. }
  149. }
  150. }
  151. catch
  152. {
  153. bRet = false;
  154. }
  155. return bRet;
  156. }
  157. //iCos통신 수신 확인 함수
  158. public void RecvThread(Object target)
  159. {
  160. ClientData client = (ClientData)target;
  161. byte[] buffer = new byte[8192];
  162. byte[] buffer2 = new byte[8192];
  163. byte[] blength = new byte[4];
  164. byte[] bPacketType = new byte[4];
  165. byte[] bPacketSubType = new byte[4];
  166. int nlength = 0;
  167. int nPacketType = 0;
  168. int nPacketSubType = 0;
  169. string strTag;
  170. while (client.clientSocket.Connected)
  171. {
  172. lock (iCosCommObj)
  173. {
  174. try
  175. {
  176. try
  177. {
  178. client.readStream.Read(blength, 0, 4);
  179. }
  180. catch (Exception e)
  181. {
  182. LFC.Log("[IcosComm.cs] client.readStream.Read 실패 : " + e + ", " + Environment.NewLine);
  183. break;
  184. }
  185. nlength = BitConverter.ToInt32(blength, 0);
  186. if ((nlength > 0) && (nlength < 8192))
  187. {
  188. client.readStream.Read(buffer2, 0, nlength - 4);
  189. Array.Copy(blength, 0, buffer, 0, 4); //blength 0부터 4개를 buffer 0부터 복사
  190. Array.Copy(buffer2, 0, buffer, 4, nlength); //buffer2 0부터 nlength개를 buffer 4부터 복사
  191. Array.Copy(buffer, 4, bPacketType, 0, 4); //buffer 4부터 4개를 bPacketType 0부터 복사
  192. Array.Copy(buffer, 8, bPacketSubType, 0, 4);//buffer 8부터 4개를 bPacketSubType 0부터 복사
  193. nPacketType = BitConverter.ToInt32(bPacketType, 0);
  194. nPacketSubType = BitConverter.ToInt32(bPacketSubType, 0);
  195. } //buffer 0~4 길이, buffer 4~8 PacketType, buffer 8~12 PacketSubType
  196. else
  197. continue;
  198. if (nPacketType == 3)
  199. {
  200. if (nPacketSubType == 4)
  201. {
  202. if ((buffer[20] >= 0) && (buffer[20] <= 5))
  203. {
  204. _valuePacket.Deserialize(buffer);
  205. strTag = AddressIndex[_valuePacket.nPoint].szTag;
  206. AddressData[strTag].nState = _valuePacket.nState;
  207. AddressData[strTag].analog = _valuePacket.Values.analog;
  208. AddressData[strTag].digital = _valuePacket.Values.digital;
  209. }
  210. else if (buffer[20] == 6)
  211. {
  212. _textPacket.Deserialize(buffer);
  213. strTag = AddressIndex[_textPacket.nPoint].szTag;
  214. AddressData[strTag].nState = _textPacket.nState;
  215. AddressData[strTag].szText = _textPacket.szTextValue;
  216. }
  217. }
  218. else if (nPacketSubType == 22)
  219. {
  220. _valueArrayPacket.Values = new PointValue[50];
  221. _valueArrayPacket.Deserialize(buffer);
  222. for (int i = 0; i < _valueArrayPacket.nPntCnt; i++)
  223. {
  224. strTag = AddressIndex[_valueArrayPacket.Values[i].nPoint].szTag;
  225. AddressData[strTag].nState = _valueArrayPacket.Values[i].nState;
  226. AddressData[strTag].analog = _valueArrayPacket.Values[i].Values.analog;
  227. AddressData[strTag].digital = _valueArrayPacket.Values[i].Values.digital;
  228. }
  229. }
  230. else if (nPacketSubType == 23)
  231. {
  232. _textArrayPacket.Values = new PointText[5];
  233. _textArrayPacket.Deserialize(buffer);
  234. for (int i = 0; i < _textArrayPacket.nPntCnt; i++)
  235. {
  236. strTag = AddressIndex[_textArrayPacket.Values[i].nPoint].szTag;
  237. AddressData[strTag].nState = _textArrayPacket.Values[i].nState;
  238. AddressData[strTag].szText = _textArrayPacket.Values[i].szTextValue;
  239. }
  240. }
  241. else
  242. {
  243. int fail = buffer[8];
  244. }
  245. }
  246. else if (nPacketType == 6)
  247. {
  248. if (nPacketSubType == 2)
  249. {
  250. _loginPacket.Deserialize(buffer);
  251. iCosResponse(client.icosId, nPacketType, nPacketSubType, _loginPacket);
  252. }
  253. }
  254. else if (nPacketType == 4) //PTYPE_ALARM
  255. {
  256. if (nPacketSubType == 11) //ALARM_NOTIFY
  257. {
  258. _alarmNotifyPacket.Deserialize(buffer);
  259. iCosResponse(client.icosId, nPacketType, nPacketSubType, _alarmNotifyPacket);
  260. }
  261. else if (nPacketSubType == 9) //ALARM_ACK_FROM_SERVER
  262. {
  263. _alarmAckServerPacket.Deserialize(buffer);
  264. iCosResponse(client.icosId, nPacketType, nPacketSubType, _alarmAckServerPacket);
  265. }
  266. else if (nPacketSubType == 16) //ALARM_CHACK_ALL_PROCESS_FROM_SERVER
  267. {
  268. _alarmAllAckPacket.Deserialize(buffer);
  269. iCosResponse(client.icosId, nPacketType, nPacketSubType, _alarmAllAckPacket);
  270. }
  271. else
  272. {
  273. iCosResponse(client.icosId, nPacketType, nPacketSubType, null);
  274. }
  275. }
  276. }
  277. catch (Exception e)
  278. {
  279. LFC.Log("[IcosComm.cs] Icos 통신실패 : " + e + ", " + Environment.NewLine);
  280. }
  281. }
  282. }
  283. LFC.Log("[IcosComm.cs] Icos 관제점 쓰레드 종료" + Environment.NewLine);
  284. }
  285. public void ManagerConnection()
  286. {
  287. while (true)
  288. {
  289. System.Threading.Thread.Sleep(10000);
  290. lock (iCosCommObj)
  291. {
  292. if (Clients.Count < 1)
  293. continue;
  294. foreach (KeyValuePair<string, ClientData> client in Clients)
  295. {
  296. if (client.Value.clientSocket.Connected == false)
  297. {
  298. string icosAddr = client.Value.ipAddress;
  299. int icosPort = client.Value.nPort;
  300. string icosId = client.Value.icosId;
  301. string icosPassword = client.Value.icosPassword;
  302. Socket newclient;
  303. IPEndPoint icosCon = new IPEndPoint(IPAddress.Parse(icosAddr), icosPort);
  304. newclient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
  305. try
  306. {
  307. newclient.Connect(icosCon);
  308. NetworkStream readStream = new NetworkStream(newclient);
  309. Clients[icosId].clientSocket = newclient;
  310. Clients[icosId].readStream = readStream;
  311. ClientData _conData = new ClientData();
  312. _conData.clientSocket = newclient;
  313. _conData.readStream = readStream;
  314. _conData.ipAddress = icosAddr;
  315. _conData.nPort = icosPort;
  316. _conData.icosId = icosId;
  317. _conData.icosPassword = icosPassword;
  318. thread_managerconnection = new Thread(new ParameterizedThreadStart(RecvThread));
  319. thread_managerconnection.IsBackground = true;
  320. thread_managerconnection.Start(_conData);
  321. IcosLogin(icosId, icosPassword);
  322. LFC.Log("[IcosComm.cs] ManagerConnection 재접속 성공" + Environment.NewLine);
  323. }
  324. catch
  325. {
  326. newclient.Close();
  327. LFC.Log("[IcosComm.cs] ManagerConnection 재접속 실패" + Environment.NewLine);
  328. }
  329. }
  330. }
  331. }
  332. }
  333. }
  334. //iCos 통신 접속 함수
  335. public bool Connect(string icosAddr, int icosPort, string icosId, string icosPassword)
  336. {
  337. bool bRet = false;
  338. lock (iCosCommObj)
  339. {
  340. Socket client;
  341. IPEndPoint icosCon = new IPEndPoint(IPAddress.Parse(icosAddr), icosPort);
  342. client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
  343. try
  344. {
  345. if ((!String.IsNullOrEmpty(icosId)) && (Clients.ContainsKey(icosId) == false))
  346. {
  347. client.Connect(icosCon);
  348. NetworkStream readStream = new NetworkStream(client);
  349. ClientData _conData = new ClientData();
  350. _conData.clientSocket = client;
  351. _conData.readStream = readStream;
  352. _conData.ipAddress = icosAddr;
  353. _conData.nPort = icosPort;
  354. _conData.icosId = icosId;
  355. _conData.icosPassword = icosPassword;
  356. Clients.Add(icosId, _conData);
  357. thread_connect = new Thread(new ParameterizedThreadStart(RecvThread));
  358. thread_connect.IsBackground = true;
  359. thread_connect.Start(_conData);
  360. bRet = true;
  361. }
  362. else
  363. {
  364. return bRet;
  365. }
  366. }
  367. catch
  368. {
  369. LFC.Log("[IcosComm.cs] Icos Connect 실패" + Environment.NewLine);
  370. client.Close();
  371. return bRet;
  372. }
  373. }
  374. return bRet;
  375. }
  376. //iCos 통신 끊기 함수
  377. public void Disconnect(string icosId)
  378. {
  379. if ((String.IsNullOrEmpty(icosId)) || (Clients.ContainsKey(icosId) == false))
  380. return;
  381. lock (iCosCommObj)
  382. {
  383. Clients[icosId].clientSocket.Close();
  384. Clients.Remove(icosId);
  385. }
  386. }
  387. //iCos 로그인 함수
  388. public void IcosLogin(string userid, string password)
  389. {
  390. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  391. return;
  392. iCosLogInRequest PacketData = new iCosLogInRequest();
  393. if (Clients[userid].clientSocket.Connected == true)
  394. {
  395. PacketData.nLength = Marshal.SizeOf(PacketData);
  396. PacketData.nType = 6;
  397. PacketData.nSubType = 1;
  398. PacketData.szId = userid;
  399. PacketData.szPassword = password;
  400. Clients[userid].icosId = userid;
  401. Clients[userid].icosPassword = password;
  402. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  403. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  404. }
  405. }
  406. //iCos 로그아웃 함수
  407. public void IcosLogout(string userid)
  408. {
  409. if ((String.IsNullOrEmpty(userid)) || (Clients.ContainsKey(userid) == false))
  410. return;
  411. iCosLogInRequest PacketData = new iCosLogInRequest();
  412. if (Clients[userid].clientSocket.Connected == true)
  413. {
  414. PacketData.nLength = Marshal.SizeOf(PacketData);
  415. PacketData.nType = 6;
  416. PacketData.nSubType = 3;
  417. PacketData.szId = userid;
  418. PacketData.szPassword = "";
  419. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  420. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  421. }
  422. }
  423. //iCos 관제점 등록 함수
  424. public int IcosRegTag(string userid, int nCnt, string tags)
  425. {
  426. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  427. return 0;
  428. if (nCnt < 1)
  429. return 0;
  430. string[] icosTag = tags.Split(',');
  431. foreach (string tag in icosTag)
  432. {
  433. if (!AddressData.ContainsKey(tag))
  434. continue;
  435. iCosMonitorRegTag PacketData = new iCosMonitorRegTag();
  436. if (Clients[userid].clientSocket.Connected == true)
  437. {
  438. PacketData.nLength = Marshal.SizeOf(PacketData);
  439. PacketData.nType = 3;
  440. PacketData.nSubType = 2;
  441. PacketData.nChannel = AddressData[tag].nChannel;
  442. PacketData.nController = AddressData[tag].nController;
  443. PacketData.nDataType = AddressData[tag].nDataType;
  444. PacketData.nPoint = AddressData[tag].nPoint;
  445. if (Clients[userid].RegTag.Contains(tag) == false)
  446. Clients[userid].RegTag.Add(tag);
  447. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  448. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  449. }
  450. }
  451. return 1;
  452. }
  453. //iCos 관제점 등록삭제 함수
  454. public int IcosUnregTag(string userid, int nCnt, string tags)
  455. {
  456. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  457. return 0;
  458. if (nCnt < 1)
  459. return 0;
  460. string[] icosTag = tags.Split(',');
  461. foreach (string tag in icosTag)
  462. {
  463. if (!AddressData.ContainsKey(tag))
  464. continue;
  465. iCosMonitorRegTag PacketData = new iCosMonitorRegTag();
  466. if (Clients[userid].clientSocket.Connected == true)
  467. {
  468. PacketData.nLength = Marshal.SizeOf(PacketData);
  469. PacketData.nType = 3;
  470. PacketData.nSubType = 3;
  471. PacketData.nChannel = AddressData[tag].nChannel;
  472. PacketData.nController = AddressData[tag].nController;
  473. PacketData.nDataType = AddressData[tag].nDataType;
  474. PacketData.nPoint = AddressData[tag].nPoint;
  475. if (Clients[userid].RegTag.Contains(tag) == true)
  476. Clients[userid].RegTag.Remove(tag);
  477. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  478. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  479. }
  480. }
  481. return 1;
  482. }
  483. //iCos 관제점 값제어 함수, 쓰기
  484. public void IcosControlValue(string userid, string tag, float fvalue)
  485. {
  486. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  487. return;
  488. if (!AddressData.ContainsKey(tag))
  489. return;
  490. iCosMonitorValue PacketData = new iCosMonitorValue();
  491. if (Clients[userid].clientSocket.Connected == true)
  492. {
  493. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  494. PacketData.nLength = Marshal.SizeOf(PacketData);
  495. PacketData.nType = 3;
  496. PacketData.nSubType = 5;
  497. PacketData.nChannel = AddressData[tag].nChannel;
  498. PacketData.nController = AddressData[tag].nController;
  499. PacketData.nDataType = AddressData[tag].nDataType;
  500. PacketData.nPoint = AddressData[tag].nPoint;
  501. PacketData.nState = 1;
  502. PacketData.nReserved1 = 0;
  503. PacketData.nReserved2 = 0;
  504. if (PacketData.nDataType < 2)
  505. PacketData.Values.analog = fvalue;
  506. else
  507. PacketData.Values.digital = (byte)fvalue;
  508. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  509. }
  510. }
  511. //iCos 관제점 문자열제어 함수
  512. public void IcosControlText(string userid, string tag, string txtvalue)
  513. {
  514. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  515. return;
  516. if (!AddressData.ContainsKey(tag))
  517. return;
  518. iCosMonitorText PacketData = new iCosMonitorText();
  519. if (Clients[userid].clientSocket.Connected == true)
  520. {
  521. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  522. PacketData.nLength = Marshal.SizeOf(PacketData);
  523. PacketData.nType = 3;
  524. PacketData.nSubType = 5;
  525. PacketData.nChannel = AddressData[tag].nChannel;
  526. PacketData.nController = AddressData[tag].nController;
  527. PacketData.nDataType = AddressData[tag].nDataType;
  528. PacketData.nPoint = AddressData[tag].nPoint;
  529. PacketData.nState = 1;
  530. PacketData.nReserved1 = 0;
  531. PacketData.nReserved2 = 0;
  532. PacketData.szTextValue = txtvalue;
  533. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  534. }
  535. }
  536. //관제점
  537. public void IcosRegTagArray(string userid, int nCnt, string tags)
  538. {
  539. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  540. return;
  541. if (nCnt < 1)
  542. return;
  543. if (Clients[userid].clientSocket.Connected == false)
  544. return;
  545. iCosMonitorRegTagArray PacketData = new iCosMonitorRegTagArray();
  546. PacketData.Tags = new TagAddr[50];
  547. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  548. string[] icosTag = tags.Split(',');
  549. int nIndex = 0;
  550. int nSendCnt = 0;
  551. foreach (string tag in icosTag)
  552. {
  553. if (!AddressData.ContainsKey(tag))
  554. {
  555. nSendCnt++;
  556. continue;
  557. }
  558. PacketData.nLength = Marshal.SizeOf(PacketData);
  559. PacketData.nType = 3;
  560. PacketData.nSubType = 26;
  561. PacketData.nPntCnt = nIndex + 1;
  562. PacketData.Tags[nIndex].nChannel = AddressData[tag].nChannel;
  563. PacketData.Tags[nIndex].nController = AddressData[tag].nController;
  564. PacketData.Tags[nIndex].nDataType = AddressData[tag].nDataType;
  565. PacketData.Tags[nIndex].nPoint = AddressData[tag].nPoint;
  566. nSendCnt++;
  567. nIndex++;
  568. if (Clients[userid].RegTag.Contains(tag) == false)
  569. Clients[userid].RegTag.Add(tag);
  570. if ((nIndex >= 50) || (nIndex >= nCnt) || (nSendCnt >= nCnt))
  571. {
  572. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  573. nIndex = 0;
  574. PacketData.nPntCnt = 0;
  575. }
  576. }
  577. }
  578. public void IcosUnregTagArray(string userid, int nCnt, string tags)
  579. {
  580. if ((String.IsNullOrEmpty(userid)) && (Clients.ContainsKey(userid) == false))
  581. return;
  582. if (nCnt < 1)
  583. return;
  584. if (Clients[userid].clientSocket.Connected == false)
  585. return;
  586. iCosMonitorRegTagArray PacketData = new iCosMonitorRegTagArray();
  587. PacketData.Tags = new TagAddr[50];
  588. NetworkStream writeStream = new NetworkStream(Clients[userid].clientSocket);
  589. string[] icosTag = tags.Split(',');
  590. int nIndex = 0;
  591. int nSendCnt = 0;
  592. foreach (string tag in icosTag)
  593. {
  594. if (!AddressData.ContainsKey(tag))
  595. {
  596. nSendCnt++;
  597. continue;
  598. }
  599. PacketData.nLength = Marshal.SizeOf(PacketData);
  600. PacketData.nType = 3;
  601. PacketData.nSubType = 27;
  602. PacketData.nPntCnt = nIndex + 1;
  603. PacketData.Tags[nIndex].nChannel = AddressData[tag].nChannel;
  604. PacketData.Tags[nIndex].nController = AddressData[tag].nController;
  605. PacketData.Tags[nIndex].nDataType = AddressData[tag].nDataType;
  606. PacketData.Tags[nIndex].nPoint = AddressData[tag].nPoint;
  607. nSendCnt++;
  608. nIndex++;
  609. if (Clients[userid].RegTag.Contains(tag) == true)
  610. Clients[userid].RegTag.Remove(tag);
  611. if ((nIndex >= 50) || (nIndex >= nCnt) || (nSendCnt >= nCnt))
  612. {
  613. writeStream.Write(PacketData.Serialize(), 0, Marshal.SizeOf(PacketData));
  614. nIndex = 0;
  615. PacketData.nPntCnt = 0;
  616. }
  617. }
  618. }
  619. public string IcosGetTagText(string strTag)
  620. {
  621. string szRet = "";
  622. if ((String.IsNullOrEmpty(strTag)) || (AddressData.ContainsKey(strTag) == false))
  623. return szRet;
  624. szRet = AddressData[strTag].szText;
  625. return szRet;
  626. }
  627. //읽기
  628. public double IcosGetTagValue(string strTag)
  629. {
  630. double fRet = 0;
  631. if ((String.IsNullOrEmpty(strTag)) || (AddressData.ContainsKey(strTag) == false))
  632. return fRet;
  633. if (AddressData[strTag].nDataType < 2)
  634. fRet = AddressData[strTag].analog;
  635. else if ((AddressData[strTag].nDataType > 1) && (AddressData[strTag].nDataType < 6))
  636. fRet = AddressData[strTag].digital;
  637. return fRet;
  638. }
  639. public string GetTagNameByIndex(int nPnt)
  640. {
  641. string szRet = "";
  642. if (AddressIndex.ContainsKey(nPnt) == true)
  643. {
  644. szRet = AddressIndex[nPnt].szTag;
  645. }
  646. return szRet;
  647. }
  648. public int GetRegTagCount(string userid)
  649. {
  650. int nRet = 0;
  651. if ((String.IsNullOrEmpty(userid)) || (Clients.ContainsKey(userid) == false))
  652. return nRet;
  653. nRet = Clients[userid].RegTag.Count;
  654. return nRet;
  655. }
  656. public string GetRegTags(string userid)
  657. {
  658. string szReg = "";
  659. if ((String.IsNullOrEmpty(userid)) || (Clients.ContainsKey(userid) == false))
  660. return szReg;
  661. for (int i = 0; i < Clients[userid].RegTag.Count; i++)
  662. {
  663. szReg = szReg + Clients[userid].RegTag[i];
  664. if (i < Clients[userid].RegTag.Count - 1)
  665. szReg = szReg + ",";
  666. }
  667. return szReg;
  668. }
  669. public bool GetConnectionStatus(string userid)
  670. {
  671. if ((String.IsNullOrEmpty(userid)) || (Clients.ContainsKey(userid) == false))
  672. return false;
  673. bool bRet = Clients[userid].clientSocket.Connected;
  674. return bRet;
  675. }
  676. public bool GetTagAddress(string strTag, ref int nChannel, ref int nController, ref int nType, ref int nPoint, ref int nState)
  677. {
  678. if ((String.IsNullOrEmpty(strTag)) || (AddressData.ContainsKey(strTag) == false))
  679. return false;
  680. nChannel = AddressData[strTag].nChannel;
  681. nController = AddressData[strTag].nController;
  682. nType = AddressData[strTag].nDataType;
  683. nPoint = AddressData[strTag].nPoint;
  684. nState = AddressData[strTag].nState;
  685. return true;
  686. }
  687. }
  688. }