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)
{
}
}
}