using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Runtime.InteropServices; using System.IO; using System.Collections.Concurrent; using System.Net.Sockets; using System.Net; namespace DataGateWayProject { public partial class Form1 : Form { bool startOk = false; LogFileCreate LFC = new LogFileCreate(); My_TimerThread TTs = new My_TimerThread(); static string SelecDir; public Form1() { InitializeComponent(); } private void Form1_Load(object sender, EventArgs e) { ProStartBtn.Enabled = false; //시작 버튼 비활성화 ProStopBtn.Enabled = false; //중단 버튼 비활성화 PointSetBtn.Enabled = false; //관제점 등록 버튼 비활성화 PointUnRegBtn.Enabled = false; //관제점 해제 버튼 비활성화 } private void ProStartBtn_Click(object sender, EventArgs e) //시작버튼 함수 { if (toolStripStatusLabel1.Text != "")//경로 설정 확인 { try { //PingConfirm(); //Creating_Setting_File CSF = new Creating_Setting_File(); //CSF.Create_Setting_Point_File(); EndTxt.Clear(); //모니터링 종료시간 clear //TTs.timer1start(); ProStartBtn.Enabled = false; // 시작버튼 비활성화. StartTxt.Text = Convert.ToString(DateTime.Now);//모니터링 시작 LogTxt.Text += "프로그램 시작 " + Convert.ToString(DateTime.Now) + Environment.NewLine; ProStopBtn.Enabled = true; //정지버튼 활성화 FileSettingBtn.Enabled = false; //프로젝트 설정 버튼 비활성화 FileMatchBtn.Enabled = false; //관제점 설정 버튼 비활성화 FileExpBtn.Enabled = false; //성능분석시 버튼 비활성화 FirstCheck FC = new FirstCheck(); FC.Check_DailyData(); OneMinute_Insert OMI = new OneMinute_Insert(); OMI.Today_PeakMinMax(); OMI.Year_PeakMinMax(); My_TimerThread MTT = new My_TimerThread(); MTT.timer2start(); } catch (Exception eProStart) { LogTxt.Text += "프로그램 오류 " + Convert.ToString("DB에 접속되지 않았습니다.") + " " + eProStart + Convert.ToString(DateTime.Now) + Environment.NewLine; } } else MessageBox.Show("경로를 설정해주세요"); } //System.Timers.Timer timer2 = new System.Timers.Timer(); //public void PingConfirm() //{ // System.Timers.Timer timer2 = new System.Timers.Timer(); // timer2.Interval = 10000; // timer2.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed_ping); // timer2.Enabled = true; //} //void timer_Elapsed_ping(object sender, System.Timers.ElapsedEventArgs e) //{ // Readini Ri = new Readini(); // Ri.ReadData(); // ini의 설정값을 불러옴. // IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(Ri.IP1), 1609); // Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Udp); // server.Connect(ipep); // LFC.Log("연결여부" + ipep + Convert.ToString(DateTime.Now)); //} private void ProStopBtn_Click(object sender, EventArgs e) //중단 { //Close(); TTs.timer2Stop(); FileSettingBtn.Enabled = true; //프로젝트 설정 버튼 활성화 FileMatchBtn.Enabled = true; //관제점설정 버튼 활성화 FileExpBtn.Enabled = true; //성는분석식 버튼 활성화 ProStartBtn.Enabled = true; EndTxt.Text = Convert.ToString(DateTime.Now); LogTxt.Text += "프로그램 중단 " + Convert.ToString(DateTime.Now) + Environment.NewLine; ProStopBtn.Enabled = false; } private void ProSetBtn_Click(object sender, EventArgs e) //접속 설정 { SettingForm SF = new SettingForm(); SF.ShowDialog(); } private void ProPathBtn_Click_1(object sender, EventArgs e) //프로젝트 경로 { FolderBrowserDialog(); } /// /// 셋팅파일 불러오기 버튼 /// /// /// private void FileSettingBtn_Click(object sender, EventArgs e)// 프로젝트 설정 { string FSBLocation = SelecDir + "\\Login.ini"; try { System.Diagnostics.Process.Start(FSBLocation);// Login 파일에 접근 } catch { FileError(FSBLocation); } } /// /// 매칭파일 불러오기 버튼 /// /// /// private void FileMatchBtn_Click(object sender, EventArgs e) //관제점 설정 { string FSBLocation = SelecDir + "\\SettingFile.csv"; try { System.Diagnostics.Process.Start(FSBLocation); } catch { FileError(FSBLocation); } } /// /// 수식파일 불러오기 버튼 /// /// /// private void FileExpBtn_Click(object sender, EventArgs e) //성능 분석식 { string FSBLocation = SelecDir + "\\Expression.csv"; try { System.Diagnostics.Process.Start(FSBLocation); } catch { FileError(FSBLocation); } } public void FileError(string Error)// 오류 같음[Matching.csv => SettingFile.csv] { if ((!Error.Contains("Login.ini")) || (!Error.Contains("expression.csv")) || (!Error.Contains("Matching.csv"))) { MessageBox.Show("파일을 찾을 수 없습니다."); } } public string FolderBrowserDialog() //프로젝트 경로 버튼 클릭 -> 팝업창 { LogFileCreate LFC = new LogFileCreate(); FolderBrowserDialog folderDig = new FolderBrowserDialog(); folderDig.ShowNewFolderButton = true; // Show the FolderBrowserDialog. DialogResult result = folderDig.ShowDialog(); if (result == DialogResult.OK) { SelecDir = folderDig.SelectedPath; Environment.SpecialFolder root = folderDig.RootFolder; toolStripStatusLabel1.Text = "프로젝트 경로 : " + SelecDir; LogTxt.Text += "경로설정완료 " + SelecDir + " " + Convert.ToString(DateTime.Now) + Environment.NewLine; LFC.Log("경로 설정 완료" + SelecDir); } return SelecDir; } private void EraseLog_Click(object sender, EventArgs e) //로그지우기 { LogTxt.Clear(); } // 프로그램 종료시 이벤트 private void Form1_FormClosing(object sender, FormClosingEventArgs e) { if (MessageBox.Show("프로그램을 종료하시겠습니까?", "종료", MessageBoxButtons.YesNo) != DialogResult.Yes) { e.Cancel = true; } } private void PointSetBtn_Click(object sender, EventArgs e) //관제점 등록 { LFC.Log("관제점 등록 시작" + Convert.ToString(DateTime.Now)); LogTxt.Text += "관제점 등록 시작 " + Convert.ToString(DateTime.Now) + Environment.NewLine; //iCosFourDBSET(); GetData_From_iCos GFi = new GetData_From_iCos(); GFi.ReadTag(); LFC.Log("관제점 등록 완료" + Convert.ToString(DateTime.Now)); LogTxt.Text += "관제점 등록 완료 " + Convert.ToString(DateTime.Now) + Environment.NewLine; GFi.GetValueTimer(); } private void Conn_iCos_Btn_Click(object sender, EventArgs e) //icos 접속 { GetData_From_iCos GetData = new GetData_From_iCos(); LogFileCreate LFC = new LogFileCreate(); LFC.Log("접속시작" + Convert.ToString(DateTime.Now)); LogTxt.Text += "접속시작 " + Convert.ToString(DateTime.Now) + Environment.NewLine; string ReturnValue = GetData.iCos3_Conn(); if (ReturnValue == "SUCCESS") { LFC.Log("접속완료" + Convert.ToString(DateTime.Now)); LogTxt.Text += "접속완료 " + Convert.ToString(DateTime.Now) + Environment.NewLine; PointSetBtn.Enabled = true; PointUnRegBtn.Enabled = true; ProStartBtn.Enabled = true; } else { MessageBox.Show("접속에 실패하였습니다."); } } /// /// 생존확인 /// /// //public byte[] Alive_Check() //{ // byte[] Send_Alive = new byte[1024]; // Send_Alive[0] = 0x03; // Send_Alive[1023] = 0x03; // return Send_Alive; //} //static UdpClient client; //20170116.. 318번째 줄 대신 //static IPEndPoint ep; //20170116 //public string iCos3_Conn() //{ // Readini Ri = new Readini(); // Ri.ReadData(); // ini의 설정값을 불러옴. // bool Re_Conn_Check = false; // //var client = new UdpClient(); // var receivedData = new byte[1024]; // string Result_Conn_iCos = ""; // client.Client.SendTimeout = 5000; // send Timeout 5초 설정 // client.Client.ReceiveTimeout = 5000; // receive timeout 5초 설정 // //IPEndPoint ep = new IPEndPoint(IPAddress.Parse(Ri.IP1), Convert.ToInt32(Ri.Port1)); // endpoint where server is listening // ep = new IPEndPoint(IPAddress.Parse(Ri.IP1), Convert.ToInt32(Ri.Port1)); // endpoint where server is listening // LogFileCreate LFC = new LogFileCreate(); // byte[] Send_Alive = Alive_Check(); // 생존 프로토콜 생성 // bool Conn_Flag = false; // bool Error_Conn = false; // string tmplogstring = ""; // try // { // client.Connect(ep); // 접속 // 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) // { // LogTxt.Text += "통신 오류가 발생하였습니다. 다시 시도해주세요." + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + Environment.NewLine; // 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")); // LogTxt.Text += "재접속 시도 중 ...접속 시도 횟수 = " + Re_Conn + " = " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + Environment.NewLine; // 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")); // LogTxt.Text += "재접속 실패 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + Environment.NewLine; // 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 + " "; // } // LogTxt.Text += "수신받은 데이터의 체크섬 = " + rec + Environment.NewLine; // LogTxt.Text += "합산 = " + sum + Environment.NewLine; // LogTxt.Text += "길이 = " + len + Environment.NewLine; // if (receivedData[1023] != sum || receivedData[0] == 0 || len != 1024 || Error_Conn == true) // CheckSum 과 길이 체크. // { // 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 CheckSum(byte[] CheckData) //미사용 { byte Sum = 00; for (int bytenum = 0; bytenum < 1023; bytenum++) { Sum += CheckData[bytenum]; } Sum = (byte)(Sum & 0xFF); return Sum; } private void Control_Req_Btn_Click(object sender, EventArgs e) //없음 { //SetTagValue("ch.ctrl.tag1", 111); } private void PointUnRegBtn_Click(object sender, EventArgs e) //관제점해제 함수 { //UnReg(); } private void LogBtn_Click(object sender, EventArgs e) //없음 { } private void Btn_SettingFile_Click(object sender, EventArgs e) //설정파일 생성 버튼 { Creating_Setting_File CSF = new Creating_Setting_File(); CSF.Create_Setting_Point_File(); } private void Btn_TagSetFile_Click(object sender, EventArgs e) //태그등록파일 생성 버튼 { Creating_Setting_File CSF = new Creating_Setting_File(); CSF.Create_Point_File(); } private void button1_Click(object sender, EventArgs e) //값확인 버튼 { try { LogTxt.Text += GetData_From_iCos.Key_Value_Dic[testtxt.Text] + Environment.NewLine; } catch (Exception e1) { LogTxt.Text += "키값을 입력해주세요" + e1 + Environment.NewLine; } } /// /// 패킷분석 기능 추가 /// private void Btn_Packet_Analysis_Click(object sender, EventArgs e) //값 일괄 확인 버튼 { string[] sArray = File.ReadAllLines("TagSetFile.csv", Encoding.Default); LogTxt.Text += "*********** 현재 시간 : " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "**********"+ Environment.NewLine; try { for (int i = 0; i < sArray.Length; i++) // { string[] tmp = sArray[i].Split(','); // tmp[0] = index, tmp[1] = Tag명. LogTxt.Text += tmp[1] + " 의 값 : " + GetData_From_iCos.Key_Value_Dic[tmp[1]] + Environment.NewLine; } LogTxt.Text += "**************************************************************" + Environment.NewLine; } catch(Exception er) { MessageBox.Show("오류 발생 = " + er); } } private void testtxt_TextChanged(object sender, EventArgs e) { } } }