using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Data.OracleClient; using System.Diagnostics; using System.Drawing; using System.IO; using System.Linq; using System.Net; using System.Runtime.InteropServices; using System.Text; using System.Threading; using System.Threading.Tasks; using System.Windows.Forms; namespace GetData_PLC { public partial class frmMain : Form { [DllImport("Iphlpapi.dll")] private static extern int SendARP(Int32 dest, Int32 host, ref Int64 mac, ref Int32 length); //[DllImport("Ws2_32.dll")] private static string strErr = ""; public static string strAppPath = Environment.CurrentDirectory ; //采集程序路径 public static string strAPPDataPath = Environment.CurrentDirectory + @"\Data\"; //采集程序文件存储路径 public static string strParPath = strAPPDataPath + @"par\"; //计量参数文件存储路径 public static string strConfigPath = strAPPDataPath + @"Config\"; //采集程序参数保存路径 public static string strDataPath = strAPPDataPath + @"RealTime\"; //实时数据存储路径 public static string strDataPath_JlData = strDataPath + @"JlData\"; //分站计量实时数据存储路径 public static string strDataPath_ScData = strDataPath + @"ScData\"; //输差数据XML存储文件夹 public static string strDataPath_DataTime = strDataPath + @"DateTime\"; //分站时间xml存储文件夹 public static string strDataPath_Log = strDataPath + @"Log\"; //日志存储文件夹 //log 日志存放数据 public static string strLogPath = strDataPath + @"log\" + DateTime.Now.Year.ToString() + "-" + DateTime.Now.Month.ToString() + "-" + DateTime.Now.Day.ToString() + "_log.txt"; public static string strLogPath_Data = strDataPath + @"log\" + DateTime.Now.Year.ToString() + "-" + DateTime.Now.Month.ToString() + "-" + DateTime.Now.Day.ToString() + "_Datalog_"; private DataTable dtZhan = new DataTable(); static DataTable dtJld = new DataTable(); //检查控制台程序，如果一分钟之内启动超过3次，则可能有错误，重启计算机。 private static int StartConselTimes; //控制台是否运行的标志 private static bool ConselRunFlag; // 程序启动的时间，用于主程序自动重启 private static DateTime MainPragramStartTime; Boolean SaveHourFlag; //小时保存数据 Boolean SaveSSFlag; //实时数据保存数据 Boolean SaveDayFlag; //保存日报表标志 Boolean SaveSCDayFlag; //保存日报表标志 Boolean UpdateFlag; //更新计量器具的标志 private static int SaveDiff = 300;//实时数据存盘间隔 五分钟 bool SaveEnable; private static DateTime PragramStartTime;// 程序启动的时间，用于主程序自动重启 private static DateTime LastSaveTime; public frmMain() { InitializeComponent(); } private void frmMain_Load(object sender, EventArgs e) { //写入程序已经运行的标志 避免服务器程序重复启动 System.IO.Directory.CreateDirectory(strAPPDataPath); //Data文件夹 System.IO.Directory.CreateDirectory(strParPath); //Data\par文件夹 System.IO.Directory.CreateDirectory(strDataPath); //Data\realtime文件夹 System.IO.Directory.CreateDirectory(strConfigPath); //Data\realtime文件夹 System.IO.Directory.CreateDirectory(strDataPath_JlData); //分站xml存储文件夹 System.IO.Directory.CreateDirectory(strDataPath_ScData); //输差数据XML存储文件夹 System.IO.Directory.CreateDirectory(strDataPath_DataTime);//分站时间xml存储文件夹 System.IO.Directory.CreateDirectory(strDataPath_Log); //日志存储文件夹 // 备份数据库 DataSet dsBackUp = new DataSet(); DataTable dtBackUp = new DataTable(); dtBackUp = OracleLink.ExecuteDataTable("select * from RV2_BASEINFO", "JLXT", ""); dtBackUp.TableName = "FlowMeter"; dsBackUp.Tables.Add(dtBackUp.Copy()); dtBackUp = new DataTable(); dtBackUp = OracleLink.ExecuteDataTable("select * from RV2_TRANS_CONFIG", "JLXT", ""); dtBackUp.TableName = "SCConfig"; dsBackUp.Tables.Add(dtBackUp.Copy()); dtBackUp = new DataTable(); dtBackUp = OracleLink.ExecuteDataTable("select * from SYS_ORGANISE", "JLXT", ""); dtBackUp.TableName = "OrgConfig"; dsBackUp.Tables.Add(dtBackUp.Copy()); dsBackUp .WriteXml (strParPath + "dsConfig.xml", XmlWriteMode.WriteSchema); string strParPath1 = strParPath + "runstate.txt"; if (File.Exists(strParPath)) { if (File.ReadAllText(strParPath1) == "true") { MessageBox.Show("已有一个采集进程在运行，退出 ！", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Error); Application.Exit(); } } else { File.WriteAllText(strParPath1, "true"); } System.Net.IPAddress[] addressList = Dns.GetHostByName(Dns.GetHostName()).AddressList; toolStripStatusLabel1.Text = "天然气产销厂自动计量采集程序"; toolStripStatusLabel2.Text = DateTime.Now.ToString(); Control.CheckForIllegalCrossThreadCalls = false;//跨线程操作 string strFileName = ""; dtZhan = new DataTable(); try { dtZhan = OracleLink.ExecuteDataTable(SQL_Strings.strSQLZhan, "JLXT", strErr); } catch (Exception) { strFileName = strDataPath + "dtZhan.xml"; dtZhan.ReadXml(strFileName); } dtZhan.TableName = "集输站场"; DataTable dtStationNew = dtZhan.Copy(); try { for (int i = 0; i < dtZhan.Rows.Count; i++) { //柳屯配气站两台PLC 区分 string[] tempIp = dtZhan.Rows[i]["IP"].ToString().Split(','); string[] tempPORT = dtZhan.Rows[i]["PORT"].ToString().Split(','); if (tempIp.Length > 1) { DataRow drTemp = dtStationNew.NewRow(); drTemp.ItemArray = dtZhan.Rows[i].ItemArray; dtStationNew.Rows[i]["org_id"] = dtZhan.Rows[i]["org_id"].ToString() + "_0"; dtStationNew.Rows[i]["org_name"] = dtZhan.Rows[i]["org_name"].ToString() + "_0"; dtStationNew.Rows[i]["IP"] = tempIp[0]; dtStationNew.Rows[i]["PORT"] = tempPORT[0]; for (int j = 1; j < tempIp.Length; j++) { drTemp["org_id"] = dtZhan.Rows[i]["org_id"].ToString() + "_" + j.ToString(); drTemp["org_name"] = dtZhan.Rows[i]["org_name"].ToString() + "_" + j.ToString(); drTemp["IP"] = tempIp[j]; drTemp["PORT"] = tempPORT[j]; dtStationNew.Rows.Add(drTemp); } } } comboBox1.DataSource = dtStationNew; comboBox1.DisplayMember = dtZhan.Columns["ORG_NAME"].ToString(); comboBox1.ValueMember = dtZhan.Columns["ORG_ID"].ToString(); dtStationNew.WriteXml(strDataPath + "dtZhan.xml", XmlWriteMode.WriteSchema); } catch (Exception ex) { } LastSaveTime = DateTime.Now; PragramStartTime = DateTime.Now; string name = Dns.GetHostName(); IPAddress[] ipadrlist = Dns.GetHostAddresses(name); for (int i = 0; i < ipadrlist.Length; i++) { if (ipadrlist[i].ToString() == "10.75.167.5" || ipadrlist[i].ToString() == "10.75.166.5") { checkBox1.Checked = true; } } } #region "启停采集控制台" private void startConsel(string _filePath, string _ProcessesName) { foreach (Process p in Process.GetProcesses()) { if (p.ProcessName == _ProcessesName) { try { p.Kill(); } catch { } } } //实例化一个进程类 //Thread.Sleep(5000); Process cmd = new Process(); cmd.StartInfo.FileName = _filePath + "\\" + _ProcessesName + ".exe"; //不显示命令行窗口界面true不显示 cmd.StartInfo.CreateNoWindow = true; cmd.StartInfo.WindowStyle = ProcessWindowStyle.Normal; cmd.Start(); //启动进程 textBox1.AppendText("采集程序启动---" + DateTime.Now + "\r\n"); ConselRunFlag = true; StartConselTimes = 0; } private void CloseConsel(string _ProcessesName) { foreach (Process p in Process.GetProcesses()) { if (p.ProcessName == _ProcessesName) { try { p.Kill(); } catch { } } } } private void timer3_Tick(object sender, EventArgs e) { //定时重启 2天重启一次 TimeSpan stST = DateTime.Now - MainPragramStartTime; DateTime SAVETIME = DateTime.Now; DateTime oldTime = DateTime.Parse(toolStripStatusLabel2.Text); TimeSpan strRuntime = SAVETIME - oldTime; toolStripStatusLabel3.Text = "已运行【" + strRuntime.Days.ToString("0#") + "天" + strRuntime.Hours.ToString("0#") + "小时" + strRuntime.Minutes.ToString("0#") + "分钟" + strRuntime.Seconds.ToString("0#") + "秒 】"; toolStripStatusLabel4.Text = DateTime.Now.ToString(); #region //启动停止更新计量器具控制台程序 //try //{ // if (SAVETIME.Hour >= 2 && SAVETIME.Hour < 3 && UpdateFlag == false) //过了2点启动 // { // UpdateFlag = true; // startConsel(strAppPath, "UpdateMeter"); // try // { // File.Delete(strAppPath + @"\Data\UpdateMeter\updateFlag.xml"); // } // catch (Exception) // { // } // } // if (UpdateFlag) //如果更新成功 则关闭控制台程序 // { // if (File.Exists(strAppPath + @"\Data\UpdateMeter\updateFlag.xml")) // { // CloseConsel("UpdateMeter"); // } // } // if (SAVETIME.Hour < 2 || SAVETIME.Hour > 3) // { // UpdateFlag = false; // try // { // File.Delete(strAppPath + @"\Data\UpdateMeter\updateFlag.xml"); // } // catch (Exception) // { // } // } //} //catch (Exception ex) //{ //} #endregion #region //客户端重启control try { string strQuery = "select * from control"; //从数据库中查询出所有站场的名称和站场ID//返回不带重复记录的站场ID表格 string RestartFlag = ""; DataTable ReadFlagTable = OracleLink.ExecuteDataTable(strQuery, "DTJK", ""); RestartFlag = ReadFlagTable.Rows[0]["RESTART"].ToString(); if (RestartFlag == "1") { strQuery = "update control set RESTART=0 where id=1 "; //从数据库中查询出所有站场的名称和站场ID//返回不带重复记录的站场ID表格 OracleLink.ExecuteNonQuery(strQuery, "DTJK", strErr); startConsel(strAppPath, "ConsoleGetPLCData"); } } catch (SystemException err) { } #endregion try { if (stST.Minutes > 2880) { System.Diagnostics.Process.Start(System.Reflection.Assembly.GetExecutingAssembly().Location); Application.Restart(); } toolStripStatusLabel5.Text = ""; Int64 intPLCPageMemory = 0; Int64 intPLCSystemMemory = 0; ConselRunFlag = false; foreach (Process p in Process.GetProcesses()) { if (p.ProcessName == "ConsoleGetPLCData") { string PLCMemory = "PLC采集程序【物理内存：" + (p.WorkingSet64 / 1024 / 1024).ToString() + " MB--" + "分页内存：" + (p.PagedMemorySize64 / 1024 / 1024).ToString() + " MB】"; intPLCPageMemory = p.PagedMemorySize64 / 1024 / 1024; intPLCSystemMemory = p.WorkingSet64 / 1024 / 1024; toolStripStatusLabel5.Text = PLCMemory; ConselRunFlag = true; StartConselTimes = 0; break; } } if (ConselRunFlag == false) { StartConselTimes = StartConselTimes + 1; startConsel(strAppPath, "ConsoleGetPLCData"); textBox1.AppendText("启动采集程序 " + "\r\n"); } bool Restart = false; if ((System.Math.IEEERemainder(SAVETIME.Minute, 5) > 0 && System.Math.IEEERemainder(SAVETIME.Minute, 5) < 4) || (DateTime.Now.Hour == 23 && DateTime.Now.Minute >= 56)) { Restart = true; } if (intPLCPageMemory >= 250 && Restart) { CloseConsel("ConsoleGetPLCData"); Thread.Sleep(2000); startConsel(strAppPath, "ConsoleGetPLCData"); toolStripStatusLabel7.Text = (int.Parse(toolStripStatusLabel7.Text) + 1).ToString(); textBox1.AppendText("分页内存超过250MB，重启采集程序----" + DateTime.Now + "\r\n"); } if (intPLCSystemMemory >= 150 && Restart) { CloseConsel("ConsoleGetPLCData"); Thread.Sleep(2000); startConsel(strAppPath, "ConsoleGetPLCData"); toolStripStatusLabel7.Text = (int.Parse(toolStripStatusLabel7.Text) + 1).ToString(); textBox1.AppendText("物理内存超过150MB，重启采集程序----" + DateTime.Now + "\r\n"); } timer1.Enabled = true; } catch (Exception) { } } #endregion private void comboBox1_SelectedIndexChanged(object sender, EventArgs e) { } private void timer1_Tick(object sender, EventArgs e) { try { string strFilePath = @"D:\GetPLCData\Data\RealTime\"; DataTable dtStation = new DataTable(); dtStation.ReadXml(strFilePath + "JlData\\" + comboBox1.SelectedValue.ToString() + ".xml"); dataGridView1.DataSource = dtStation; DataSet SsDataDs = new DataSet();//数据集，用于存放全厂所有计量点实时数据 DataTable dtScRealTime = new DataTable();//数据集，用于存放全厂站场输差、管管线输差和自定义输差的实时显示 DataTable TotalTable = new DataTable(); try { dtScRealTime.ReadXml(strDataPath + "ScData.xml"); SsDataDs.ReadXml(strDataPath + "SsData.xml", XmlReadMode.ReadSchema); TotalTable.ReadXml(strDataPath + "TotalData.xml"); } catch (SystemException err) { if (err.Message != null) { //textBox1.AppendText("注意： 读取合并xml文件出错 " + err.Message + err.StackTrace.Substring(err.StackTrace.LastIndexOf("行号") - 1) + "\r\n"); //textBox1.AppendText("注意： 读取合并xml文件出错 " + "\r\n"); } } try { CopyDirectory(strAppPath + "\\Data\\", textBox2 .Text ); } catch { } #region 保存到数据库 if (checkBox1.Checked) { DateTime SAVETIME = DateTime.Now; string strQuery = ""; #region"保存实时数据"//------------------------------------------------------------------------ //if (System.Math.Abs(DateDiff.TotalSeconds - SaveDiff) < 1) if (System.Math.IEEERemainder(SAVETIME.Minute, 5) == 0 && SaveSSFlag == false) { strQuery = "select ID,DEPT_ID,STATION_ID,JLD_ID,RTIME,WD,YL,CY,SSL,JRL,JRSJ,YBZT,SSGKLL,CXFLAG from REALTIME_DATA where ID=0"; DataTable SaveRealTimeData = OracleLink.ExecuteDataTable(strQuery, "DTJK", strErr); for (int j = 0; j < TotalTable.Rows.Count; j++) { DataRow tempRow = SaveRealTimeData.NewRow(); tempRow["ID"] = TotalTable.Rows[j]["ID"]; tempRow["RTIME"] = SAVETIME; tempRow["WD"] = TotalTable.Rows[j]["WD"]; tempRow["YL"] = TotalTable.Rows[j]["YL"]; tempRow["CY"] = TotalTable.Rows[j]["CY"]; tempRow["SSL"] = TotalTable.Rows[j]["SSL"]; tempRow["JRL"] = TotalTable.Rows[j]["JRL"]; tempRow["JRSJ"] = TotalTable.Rows[j]["JRSJ"]; tempRow["YBZT"] = TotalTable.Rows[j]["YBZT"]; tempRow["SSGKLL"] = TotalTable.Rows[j]["SSGKLL"]; tempRow["CXFLAG"] = TotalTable.Rows[j]["CXFLAG"]; tempRow["DEPT_ID"] = TotalTable.Rows[j]["DEPT_ID"]; tempRow["STATION_ID"] = TotalTable.Rows[j]["STATION_ID"]; tempRow["JLD_ID"] = TotalTable.Rows[j]["JLD_ID"]; SaveRealTimeData.Rows.Add(tempRow); } try { strQuery = "select ID,DEPT_ID,STATION_ID,JLD_ID,RTIME,WD,YL,CY,SSL,JRL,JRSJ,YBZT,SSGKLL,CXFLAG from REALTIME_DATA"; SaveRealTimeData.WriteXml ("d:\\ccc.xml",XmlWriteMode.WriteSchema); OracleLink.SaveDataTable(strQuery, SaveRealTimeData, "DTJK", strErr); strErr = "注意：" + DateTime.Now + "保存实时数据成功" + "\r\n"; textBox1.AppendText(strErr); } catch (SystemException err) { if (err.Message != null) { strErr = "注意：" + DateTime.Now + "保存实时数据库时出错" + err.Message + "\r\n"; textBox1.AppendText(strErr); } } #endregion #region"保存实时输差"//----------------------------------------------------- strQuery = "select id, in_p,out_p,rtime, scname, ssintotal, ssouttotal, sssc, ssscbfs, jrlintotal, jrlouttotal, jrlsc, jrlscbfs, station_id, sctype, redept_name from SC_DATA where id=0 "; try { DataTable ScTotalTable = new DataTable(); ScTotalTable = OracleLink.ExecuteDataTable(strQuery, "DTJK", strErr); ScTotalTable.Rows.Clear(); for (int j = 0; j < dtScRealTime.Rows.Count; j++) { DataRow tempRow = ScTotalTable.NewRow(); tempRow["RTIME"] = SAVETIME; tempRow["ID"] = dtScRealTime.Rows[j]["SCID"]; tempRow["IN_P"] = dtScRealTime.Rows[j]["IN_P"]; tempRow["OUT_P"] = dtScRealTime.Rows[j]["OUT_P"]; tempRow["scname"] = dtScRealTime.Rows[j]["SCNAME"]; tempRow["ssintotal"] = dtScRealTime.Rows[j]["SsInTotal"]; tempRow["ssouttotal"] = dtScRealTime.Rows[j]["SsOutTotal"]; tempRow["sssc"] = dtScRealTime.Rows[j]["SsSc"]; tempRow["ssscbfs"] = dtScRealTime.Rows[j]["SsPer"]; tempRow["jrlintotal"] = dtScRealTime.Rows[j]["JrInTotal"]; tempRow["jrlouttotal"] = dtScRealTime.Rows[j]["JrOutTotal"]; tempRow["jrlsc"] = dtScRealTime.Rows[j]["JrSc"]; tempRow["jrlscbfs"] = dtScRealTime.Rows[j]["JrPer"]; tempRow["station_id"] = dtScRealTime.Rows[j]["station_id"]; tempRow["redept_name"] = dtScRealTime.Rows[j]["RE_DEPT_ID"]; tempRow["sctype"] = dtScRealTime.Rows[j]["SCTYPE"]; ScTotalTable.Rows.Add(tempRow); } strQuery = "select id, rtime,in_p,out_p, scname, ssintotal, ssouttotal, sssc, ssscbfs, jrlintotal, jrlouttotal, jrlsc, jrlscbfs, station_id, sctype, redept_name from SC_DATA "; OracleLink.SaveDataTable(strQuery, ScTotalTable, "DTJK", strErr); strErr = "注意：" + DateTime.Now + "保存实时输差数据成功" + "\r\n"; textBox1.AppendText(strErr); } catch (SystemException err) { if (err.Message != null) { strErr = ("注意：" + DateTime.Now + "保存输差数据失败" + err.Message) + "\r\n"; textBox1.AppendText(strErr); } } LastSaveTime = SAVETIME; SaveSSFlag = true; } if (System.Math.IEEERemainder(SAVETIME.Minute, 5) != 0) { SaveSSFlag = false; } #endregion #region "存小时数据"//----------------------------------------------------------------- if (SAVETIME.Minute == 59 && SAVETIME.Second > 40 && SaveHourFlag == false) //到小时整点，如果还没有存储过则开始存储 { strQuery = "select ID,RTIME,WD,YL,CY,SSL,JRL,JRSJ,YBZT,DEPT_ID,STATION_ID,JLD_ID from HOURREPORT where ID=0"; DataTable SaveHourTable = OracleLink.ExecuteDataTable(strQuery, "DTJK", strErr); for (int j = 0; j < TotalTable.Rows.Count; j++) { DataRow tempRow = SaveHourTable.NewRow(); tempRow["ID"] = TotalTable.Rows[j]["ID"]; tempRow["RTIME"] = SAVETIME; tempRow["WD"] = TotalTable.Rows[j]["WD"]; tempRow["YL"] = TotalTable.Rows[j]["YL"]; tempRow["CY"] = TotalTable.Rows[j]["CY"]; tempRow["SSL"] = TotalTable.Rows[j]["SSL"]; tempRow["JRL"] = TotalTable.Rows[j]["JRL"]; tempRow["JRSJ"] = TotalTable.Rows[j]["JRSJ"]; tempRow["YBZT"] = TotalTable.Rows[j]["YBZT"]; tempRow["DEPT_ID"] = TotalTable.Rows[j]["DEPT_ID"]; tempRow["STATION_ID"] = TotalTable.Rows[j]["STATION_ID"]; tempRow["JLD_ID"] = TotalTable.Rows[j]["JLD_ID"]; SaveHourTable.Rows.Add(tempRow); } strQuery = "select ID,RTIME,WD,YL,CY,SSL,JRL,JRSJ,YBZT,DEPT_ID,STATION_ID,JLD_ID from HOURREPORT"; try { OracleLink.SaveDataTable(strQuery, SaveHourTable, "DTJK", strErr); strErr = "注意：" + DateTime.Now + "保存小时数据成功" + "\r\n"; textBox1.AppendText(strErr); SaveHourFlag = true; SaveHourTable.Dispose(); } catch (SystemException err) { if (err.Message != null) { strErr = "注意：" + DateTime.Now + "保存小时数据出错" + "\r\n"; textBox1.AppendText(strErr); } } } if (SAVETIME.Minute != 59) //过了小时准点 存储标志设为否 { SaveHourFlag = false; } #endregion #region "输差每日23:59:55 存盘一次 if (SAVETIME.Hour == 23 && SAVETIME.Minute.ToString() == "59" && SAVETIME.Second.ToString() == "55" && SaveSCDayFlag == false) //过了零点十分则日报表 { strQuery = "select id, in_p,out_p,rtime, scname, ssintotal, ssouttotal, sssc, ssscbfs, jrlintotal, jrlouttotal, jrlsc, jrlscbfs, station_id, sctype, redept_name from SC_DAYDATA where id=0 "; DataTable ScTotalTableH = new DataTable(); ScTotalTableH = OracleLink.ExecuteDataTable(strQuery, "DTJK", strErr); ScTotalTableH.Rows.Clear(); try { for (int j = 0; j < dtScRealTime.Rows.Count; j++) { DataRow tempRow = ScTotalTableH.NewRow(); tempRow["RTIME"] = SAVETIME; tempRow["ID"] = dtScRealTime.Rows[j]["SCID"]; tempRow["IN_P"] = dtScRealTime.Rows[j]["IN_P"]; tempRow["OUT_P"] = dtScRealTime.Rows[j]["OUT_P"]; tempRow["scname"] = dtScRealTime.Rows[j]["SCNAME"]; tempRow["ssintotal"] = dtScRealTime.Rows[j]["SsInTotal"]; tempRow["ssouttotal"] = dtScRealTime.Rows[j]["SsOutTotal"]; tempRow["sssc"] = dtScRealTime.Rows[j]["SsSc"]; tempRow["ssscbfs"] = dtScRealTime.Rows[j]["SsPer"]; tempRow["jrlintotal"] = dtScRealTime.Rows[j]["JrInTotal"]; tempRow["jrlouttotal"] = dtScRealTime.Rows[j]["JrOutTotal"]; tempRow["jrlsc"] = dtScRealTime.Rows[j]["JrSc"]; tempRow["jrlscbfs"] = dtScRealTime.Rows[j]["JrPer"]; tempRow["station_id"] = dtScRealTime.Rows[j]["station_id"]; tempRow["redept_name"] = dtScRealTime.Rows[j]["RE_DEPT_ID"]; tempRow["sctype"] = dtScRealTime.Rows[j]["SCTYPE"]; ScTotalTableH.Rows.Add(tempRow); } strQuery = "select id, rtime,in_p,out_p, scname, ssintotal, ssouttotal, sssc, ssscbfs, jrlintotal, jrlouttotal, jrlsc, jrlscbfs, station_id, sctype, redept_name from SC_DAYDATA "; OracleLink.SaveDataTable(strQuery, ScTotalTableH, "DTJK", strErr); strErr = "注意：" + DateTime.Now + "保存实时输差数据成功" + "\r\n"; SaveSCDayFlag = true; textBox1.AppendText(strErr); } catch (SystemException err) { if (err.Message != null) { strErr = ("注意：" + DateTime.Now + "保存输差数据失败" + err.Message) + "\r\n"; textBox1.AppendText(strErr); } } } if (SAVETIME.Hour != 23 && SAVETIME.Minute.ToString() != "59" && SAVETIME.Second.ToString() != "55") //过了小时准点 存储标志设为否 { SaveSCDayFlag = false; } #endregion #region "存日报表"//----------------------------------------------------------- if (SAVETIME.Hour == 0 && SAVETIME.Minute.ToString() == "10" && SaveDayFlag == false) //过了零点十分则日报表 { string Queryql = "select ID,RTIME,QL,DEPT_ID,STATION_ID,JLD_ID,JLSJ from DAYREPORT where ID=0"; DataTable SaveDAYTable = OracleLink.ExecuteDataTable(Queryql, "DTJK", strErr); DateTime _Date = DateTime.Now.AddDays(-1); _Date = DateTime.Parse(_Date.ToString("yyyy-MM-dd")); for (int j = 0; j < TotalTable.Rows.Count; j++) { DataRow tempRow = SaveDAYTable.NewRow(); tempRow["ID"] = TotalTable.Rows[j]["ID"]; tempRow["RTIME"] = _Date; tempRow["QL"] = TotalTable.Rows[j]["ZRL"]; tempRow["DEPT_ID"] = TotalTable.Rows[j]["DEPT_ID"]; tempRow["STATION_ID"] = TotalTable.Rows[j]["STATION_ID"]; tempRow["JLD_ID"] = TotalTable.Rows[j]["JLD_ID"]; tempRow["JLSJ"] = TotalTable.Rows[j]["ZRSJ"]; SaveDAYTable.Rows.Add(tempRow); } Queryql = "select ID,RTIME,QL,DEPT_ID,STATION_ID,JLD_ID,JLSJ from DAYREPORT"; try { OracleLink.SaveDataTable(Queryql, SaveDAYTable, "DTJK", strErr); //SaveDAYTable.WriteXml(strDataPath + DateTime.Now.ToString() + "SaveTable.xml",XmlWriteMode.WriteSchema); //File.Copy(strDataPath + "TotalData.xml", strDataPath + DateTime.Now.ToString() + "TotalData.xml"); strErr = "注意：" + DateTime.Now + "保存日报表成功" + "\r\n"; textBox1.AppendText(strErr); SaveDayFlag = true; SaveDAYTable.Dispose(); } catch (SystemException err) { if (err.Message != null) { strErr = "注意：" + DateTime.Now + "保存日报表数据出错" + strErr + "\r\n"; textBox1.AppendText(strErr); } } } if (SAVETIME.Hour != 1 && SAVETIME.Minute.ToString() != "10") //过了小时准点 存储标志设为否 { SaveDayFlag = false; } #endregion } #endregion } catch { } } private void frmMain_Activated(object sender, EventArgs e) { } private void frmMain_FormClosed(object sender, FormClosedEventArgs e) { CloseConsel("ConsoleGetPLCData"); } private void frmMain_FormClosing(object sender, FormClosingEventArgs e) { CloseConsel("ConsoleGetPLCData"); File.WriteAllText(strParPath + "runstate.txt", "false"); System.Environment.Exit(0);//彻底关闭线程 } private void timer2_Tick(object sender, EventArgs e) { } private void button3_Click(object sender, EventArgs e) { string strQuery = "update control set ThreadRestartFlag='1',Thread_ZCID='" + comboBox1.SelectedValue.ToString() + "' where id=1 "; //从数据库中查询出所有站场的名称和站场ID//返回不带重复记录的站场ID表格 OracleLink.ExecuteNonQuery(strQuery, "DTJK", strErr); } private void button1_Click(object sender, EventArgs e) { string strQuery = "update control set ThreadRestartFlag='1',Thread_ZCID='" + comboBox1.SelectedValue.ToString() + "' where id=1 "; //从数据库中查询出所有站场的名称和站场ID//返回不带重复记录的站场ID表格 OracleLink.ExecuteNonQuery(strQuery, "DTJK", strErr); } private void button4_Click(object sender, EventArgs e) { FolderBrowserDialog fbd = new FolderBrowserDialog(); fbd.SelectedPath = @"D:\"; if (fbd.ShowDialog() == DialogResult.OK) { this.textBox2.Text = fbd.SelectedPath; } File.WriteAllText(strAppPath + "\\CopyPath.txt", textBox2.Text); } public void CopyDirectory(string sourceDirName, string destDirName) { try { if (!Directory.Exists(destDirName)) { Directory.CreateDirectory(destDirName); File.SetAttributes(destDirName, File.GetAttributes(sourceDirName)); } if (destDirName[destDirName.Length - 1] != Path.DirectorySeparatorChar) destDirName = destDirName + Path.DirectorySeparatorChar; string[] files = Directory.GetFiles(sourceDirName); foreach (string file in files) { File.Copy(file, destDirName + Path.GetFileName(file), true); File.SetAttributes(destDirName + Path.GetFileName(file), FileAttributes.Normal); //total++; } string[] dirs = Directory.GetDirectories(sourceDirName); foreach (string dir in dirs) { CopyDirectory(dir, destDirName + Path.GetFileName(dir)); } } catch (Exception ex) { StreamWriter sw = new StreamWriter(Application.StartupPath + "\\log.txt", true); sw.Write(ex.Message + " " + DateTime.Now + "\r\n"); sw.Close(); } } } }