123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671 |
- using System;
- using System.Collections.Concurrent;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.Net;
- using System.Net.NetworkInformation;
- using System.Net.Sockets;
- using System.Text;
- namespace DataGateWayProject
- {
- class GetData_From_iCos
- {
- static UdpClient client;
- static IPEndPoint ep;
-
- Form1 F1 = new Form1();
-
- LogFileCreate LFC = new LogFileCreate();
-
- System.Timers.Timer timer_GetData = new System.Timers.Timer();
-
- public static ConcurrentDictionary<string, string> Key_Value_Dic = new ConcurrentDictionary<string, string>();
- public static ConcurrentDictionary<string, string> TagName_Matching_Dic = new ConcurrentDictionary<string, string>();
- public string GetTagValue(string TagKey)
- {
- string Value_Return = "";
- Value_Return = Key_Value_Dic[TagKey];
- if(Value_Return=="")
- {
- Value_Return = "0";
- }
- return Value_Return;
- }
- public void GetValueTimer()
- {
-
- timer_GetData.Interval = 5000;
- timer_GetData.Elapsed -= new System.Timers.ElapsedEventHandler(timer_Elapsed);
- timer_GetData.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);
- timer_GetData.Start();
- }
- public void SetTagValue(string TagName, float Tagvalue)
- {
- Readini Ri = new Readini();
- Ri.ReadData();
- int Col = 2;
-
- byte[] byteArr1;
- byte[] byteArr2;
- byte[] TmpByte = new byte[1024];
-
-
-
- string[] tmp = new string[2];
- tmp[0] = TagName;
- tmp[1] = Convert.ToString(Tagvalue);
- byteArr1 = System.Text.Encoding.Default.GetBytes(tmp[1]);
- foreach (byte words in byteArr1)
- {
- TmpByte[Col] = words;
- Col++;
- }
- TmpByte[Col] = 0x3D;
- Col++;
- byteArr2 = System.Text.Encoding.Default.GetBytes(tmp[2]);
- foreach (byte words in byteArr2)
- {
- TmpByte[Col] = words;
- Col++;
- }
- TmpByte[Col] = 0x00;
- TmpByte[1023] = CheckSum(TmpByte);
- client.Send(TmpByte, 1024);
- try
- {
- var receive_WriteTagValue = client.Receive(ref ep);
- }
- catch(Exception e)
- {
- LFC.Log("값 설정 실패 = " + e);
- }
- }
- public byte CheckSum(byte[] CheckData)
- {
- byte Sum = 00;
- for (int bytenum = 0; bytenum < 1023; bytenum++)
- {
- Sum += CheckData[bytenum];
- }
- Sum = (byte)(Sum & 0xFF);
- return Sum;
- }
- public void ReadTag()
- {
-
- Readini Ri = new Readini();
- Ri.ReadData();
-
-
-
- byte[,] tmp = Read_TagSetFile();
- int Num_Row = tmp.Length / 1024;
- try
- {
- for (int RowNum = 0; RowNum < Num_Row; RowNum++)
- {
- byte[] Send_data = new byte[1024];
- for (int InsertData = 0; InsertData < 1023; InsertData++)
- {
- Send_data[InsertData] = tmp[RowNum, InsertData];
- }
- byte checksum = CheckSum(Send_data);
- Send_data[1023] = checksum;
-
- client.Send(Send_data, 1024);
- string tmpsendpacket = "";
-
- LFC.Log("보낸 패킷");
- foreach (byte tagPacket_send in Send_data)
- {
- tmpsendpacket += tagPacket_send + " ";
- }
- LFC.Log(tmpsendpacket);
- var receivedData1 = client.Receive(ref ep);
- LFC.Log("Tag에 대한 Packet");
- string tmppacket = "";
- foreach(byte tagPacket in receivedData1)
- {
- tmppacket += tagPacket + " ";
- }
- LFC.Log(tmppacket);
- }
- }
- catch (Exception e)
- {
- LogFileCreate LFC = new LogFileCreate();
- LFC.Log("등록에러 = " + e);
- }
- }
- public byte[] Alive_Check()
- {
- byte[] Send_Alive = new byte[1024];
- Send_Alive[0] = 0x03;
- Send_Alive[1023] = 0x03;
- return Send_Alive;
- }
-
- public string iCos3_Conn()
- {
- Readini Ri = new Readini();
- LogFileCreate LFC = new LogFileCreate();
- Ri.ReadData();
- bool Re_Conn_Check = false;
- client = new UdpClient();
- var receivedData = new byte[1024];
- string Result_Conn_iCos = "";
-
- string[] sArray = File.ReadAllLines("TagSetFile.csv", Encoding.Default);
-
- for (int i = 0; i < sArray.Length; i++)
- {
- string[] tmp = sArray[i].Split(',');
- Key_Value_Dic.TryAdd(tmp[1], "0");
- }
-
-
- ep = new IPEndPoint(IPAddress.Parse(Ri.IP1), Convert.ToInt32(Ri.Port1));
-
- byte[] Send_Alive = Alive_Check();
- bool Conn_Flag = false;
- bool Error_Conn = false;
- string tmplogstring = "";
- try
- {
- client.Connect(ep);
- client.Client.SendTimeout = 5000;
- client.Client.ReceiveTimeout = 5000;
- client.Send(Send_Alive, 1024);
- receivedData = client.Receive(ref ep);
- foreach (byte tmplog in receivedData)
- {
- tmplogstring += tmplog;
- }
- LFC.Log(tmplogstring);
- foreach (byte tmp in receivedData)
- {
- if (tmp == 0x06)
- {
-
- Conn_Flag = true;
- client.Close();
- Error_Conn = true;
- }
- break;
- }
- }
- catch (Exception e1)
- {
- LFC.Log("접속실패 " + e1 + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
- Result_Conn_iCos = "FAIL";
- Re_Conn_Check = true;
- }
- if (Re_Conn_Check == true)
- {
- for (int Re_Conn = 0; Re_Conn < 2; Re_Conn++)
- {
- try
- {
- LFC.Log("재접속 시도 중 ...접속 시도 횟수 = " + Re_Conn + " = " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-
- client.Connect(ep);
- client.Send(Send_Alive, 1024);
- receivedData = client.Receive(ref ep);
- if (receivedData != null)
- {
- break;
- }
- }
- catch
- {
- LFC.Log("재접속 실패 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-
- Result_Conn_iCos = "FAIL";
- }
- }
- }
- int len = receivedData.Length;
- byte sum = CheckSum(receivedData);
- byte rec = receivedData[1023];
- string packetstring = "";
- foreach (byte log in receivedData)
- {
- packetstring += log + " ";
- }
-
-
-
- if (receivedData[1023] != sum || receivedData[0] == 0 || len != 1024 || Error_Conn == true)
- {
- LFC.Log("체크섬 = " + Convert.ToString(sum));
- LFC.Log("길이 = " + Convert.ToString(len));
- LFC.Log("접속 실패 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
- Result_Conn_iCos = "FAIL";
- }
- else
- {
- LFC.Log("접속 성공 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
- Result_Conn_iCos = "SUCCESS";
- }
- return Result_Conn_iCos;
- }
- public byte[,] Read_TagSetFile()
- {
- UnicodeEncoding enc = new UnicodeEncoding();
- string[] TagSum = new string[2];
- string[] CSVReadLine = new string[2];
-
- int count = 0;
- int One_Raw_Count = 0;
- int Col = 4;
- int Row = 0;
- int TotalCount = 0;
- int Length_Check = 0;
-
- string[] sArray = File.ReadAllLines("TagSetFile.csv", Encoding.Default);
- double Rotate = Math.Ceiling(Convert.ToDouble(sArray.Length) / 25);
- double c = sArray.Length / 25;
- byte[,] TmpByte = new byte[Convert.ToInt32(Rotate), 1024];
- for (int i = 0; i < sArray.Length; i++)
- {
- byte[] byteArr;
- string[] tmp = sArray[i].Split(',');
- TagName_Matching_Dic.TryAdd(tmp[0], tmp[1]);
-
- byteArr = System.Text.Encoding.Default.GetBytes(tmp[1]);
- foreach (byte words in byteArr)
- {
- TmpByte[Row, Col] = words;
- Col++;
- }
- if (sArray.Length < 25)
- {
- Length_Check++;
- if (sArray.Length == 1)
- {
- TmpByte[Row, Col] = 00;
- TmpByte[Row, 0] = 0x08;
- byte sum = CheckSum2(TmpByte, Row);
- TmpByte[Row, 1023] = sum;
- }
- else if (One_Raw_Count < sArray.Length - 1)
- {
- TmpByte[Row, Col] = 01;
- Col++;
- One_Raw_Count++;
- }
- else
- {
- TmpByte[Row, Col] = 00;
- TmpByte[Row, 0] = 0x08;
- byte sum = CheckSum2(TmpByte, Row);
- TmpByte[Row, 1023] = sum;
- }
- }
- else
- {
- TmpByte[Row, Col] = 01;
- Col++;
- }
- count++;
- if (Length_Check == 0)
- {
- if (count == 25 || (TotalCount == System.Math.Truncate(c)) && (count == sArray.Length % 25))
- {
-
-
-
- TmpByte[Row, 0] = 0x08;
- if (Row == 0)
- {
- TmpByte[Row, 1] = 0x02;
- }
- else
- {
- TmpByte[Row, 1] = 0x00;
- }
- TmpByte[Row, 2] = Convert.ToByte(Row);
- TmpByte[Row, 3] = 0x00;
- Col--;
- TmpByte[Row, Col] = 0x00;
- byte sum = CheckSum2(TmpByte, Row);
- TmpByte[Row, 1023] = sum;
- count = 0;
- Col = 4;
- Row++;
- TotalCount++;
- }
- }
- }
- return TmpByte;
- }
- public byte CheckSum2(byte[,] CheckData, int Row)
- {
- byte Sum = 00;
- for (int bytenum = 0; bytenum < 1023; bytenum++)
- {
- Sum += CheckData[Row, bytenum];
- }
- Sum = (byte)(Sum & 0xFF);
- return Sum;
- }
- public byte Error_Check(byte[,] CheckData, int Row)
- {
- byte Sum = 00;
- return Sum;
- }
- bool mConnecting = false;
-
-
-
-
-
- void timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
- {
- if (mConnecting == false)
- {
- mConnecting = true;
- LogFileCreate LFC = new LogFileCreate();
-
- Work();
-
- mConnecting = false;
-
- }
- }
-
- private My_TimerThread MTT = new My_TimerThread();
- private void Work()
- {
- try
- {
- byte[] a = new byte[1024];
- int tmp_hour = Convert.ToInt32(DateTime.Now.ToString("HH"));
- int tmp_min = Convert.ToInt32(DateTime.Now.ToString("mm"));
- for (int i = 0; i < 50; i++)
- {
- byte[] Obtain_Value = new byte[1024];
- bool TagCheck = false;
- bool Tag_Value_Check = false;
- Obtain_Value[0] = 0x02;
- Obtain_Value[1023] = 0x02;
- client.Send(Obtain_Value, 1024);
- var receivedData2 = client.Receive(ref ep);
-
-
-
-
-
-
-
-
-
-
-
-
-
- int Count = 0;
- string Tag_Name = "";
- string Tag_Value = "";
- foreach (byte Raw_Packet in receivedData2)
- {
- Count++;
- if (Count < 8)
- {
- continue;
- }
- else
- {
- if (Raw_Packet == 0x3d)
- {
- Key_Value_Dic.TryAdd(TagName_Matching_Dic[Tag_Name], "0");
- TagCheck = true;
- Tag_Value_Check = true;
- continue;
- }
- if (Raw_Packet == 0x01)
- {
-
-
- if(Tag_Value == "")
- {
- Tag_Value = "0";
- }
- Key_Value_Dic.AddOrUpdate(TagName_Matching_Dic[Tag_Name], "0", (Tag_Name2, currentValue2) => Tag_Value);
- Tag_Name = "";
- Tag_Value = "";
- TagCheck = false;
- Tag_Value_Check = false;
- continue;
- }
- if (Raw_Packet == 0x00)
- {
-
-
- if (Tag_Value == "")
- {
- Tag_Value = "0";
- }
- Key_Value_Dic.AddOrUpdate(TagName_Matching_Dic[Tag_Name], "0", (Tag_Name2, currentValue2) => Tag_Value);
- break;
- }
- if (TagCheck == false)
- {
-
- char Tag_Name_Tmp = Convert.ToChar(Raw_Packet);
- Tag_Name += Tag_Name_Tmp.ToString();
- }
- else if (Tag_Value_Check == true)
- {
- char Tag_Value_Tmp = Convert.ToChar(Raw_Packet);
- Tag_Value += Tag_Value_Tmp.ToString();
- }
- }
- }
- Count = 0;
- }
- }
- catch (Exception e)
- {
- client.Close();
-
- timer_GetData.Stop();
- LFC.Log("데이터 얻는 행위 중단");
-
-
- LFC.Log("통신끊김" + e);
- LFC.Log("재접속시작" + Convert.ToString(DateTime.Now));
- Form1 F1 = new Form1();
- while (true)
- {
- string ReturnValue = iCos3_Conn();
- bool check = false;
- if (ReturnValue == "SUCCESS" && check == false)
- {
- check = true;
- My_TimerThread.check = false;
- LFC.Log("접속완료" + Convert.ToString(DateTime.Now));
- GetData_From_iCos GFi = new GetData_From_iCos();
- GFi.ReadTag();
- LFC.Log("관제점 재등록 완료" + Convert.ToString(DateTime.Now));
- timer_GetData.Start();
- LFC.Log("데이터 얻는 타이머 동작시작 완료" + Convert.ToString(DateTime.Now));
-
-
- break;
- }
- }
- }
- }
- }
- }
|