using Microsoft.Win32; using System; using System.Collections.Generic; using System.Data; using System.IO; using System.Windows.Forms; using System.Xml; namespace UAS_XmlAnalysor { public partial class Form1 : Form { DataHelper dh = new DataHelper(); DataTable dt; public Form1() { InitializeComponent(); } private void Form1_Load(object sender, EventArgs e) { FolderPath.Text = Properties.Settings.Default.FolderPath; BackUpFolderPath.Text = Properties.Settings.Default.BackUpFolderPath; Source.Text = Properties.Settings.Default.Source; Master.Text = Properties.Settings.Default.Master; AutoStart.Checked = Properties.Settings.Default.AutoStart; dt = (DataTable)dh.ExecuteSql("select ms_pwd,ma_user,ma_address from master ", "select"); Master.DataSource = dt; Master.DisplayMember = "ma_user"; Master.ValueMember = "ma_user"; StartWatch.PerformClick(); } private void StartWatch_Click(object sender, EventArgs e) { for (int i = 0; i < dt.Rows.Count; i++) { if (Master.Text == dt.Rows[i]["ma_user"].ToString()) { DataHelper.DBConnectionString = "Data Source=" + dt.Rows[i]["ma_address"] + ";User ID=" + dt.Rows[i]["ma_user"] + ";PassWord=" + dt.Rows[i]["ms_pwd"]; ; Console.WriteLine(DataHelper.DBConnectionString); dh = new DataHelper(); } } if (!dh.CheckExist("source", "sc_code='" + Source.Text + "' and sc_statuscode='AUDITED'")) { OperateResult.AppendText("岗位资源错误或者未审核\n"); return; } XmlWatcher.Path = FolderPath.Text; XmlWatcher.Filter = "*.xml"; XmlWatcher.Created += new FileSystemEventHandler(XmlWatcher_Created); XmlWatcher.EnableRaisingEvents = true; Properties.Settings.Default.FolderPath = FolderPath.Text; Properties.Settings.Default.BackUpFolderPath = BackUpFolderPath.Text; Properties.Settings.Default.Source = Source.Text; Properties.Settings.Default.Master = Master.Text; Properties.Settings.Default.AutoStart = AutoStart.Checked; Properties.Settings.Default.Save(); Source.Enabled = false; StartWatch.Enabled = false; ChooseFolder.Enabled = false; ChooseBackUpFolder.Enabled = false; SetAutoRun(); OperateResult.AppendText("开始执行监控\n"); } public void SetAutoRun() { if (AutoStart.Checked) //设置开机自启动 { string path = Application.ExecutablePath; RegistryKey rk = Registry.LocalMachine; RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run"); rk2.SetValue("UAS_XML解析器.exe", path); rk2.Close(); rk.Close(); } else //取消开机自启动 { string path = Application.ExecutablePath; RegistryKey rk = Registry.LocalMachine; RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run"); rk2.DeleteValue("UAS_XML解析器.exe", false); rk2.Close(); rk.Close(); } } private void XmlWatcher_Created(object sender, FileSystemEventArgs e) { while (true) { try { using (Stream stream = File.Open(e.FullPath, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite)) { if (stream != null) break; } System.Threading.Thread.Sleep(500); } catch (Exception) { } } string testDate = ""; string testTime = ""; XmlReader myReader = XmlReader.Create(FolderPath.Text + @"\" + e.Name); string sncode = e.Name.Split('.')[0]; string iMakeCode = dh.getFieldDataByCondition("makeserial", "ms_makecode", "ms_sncode='" + sncode + "'").ToString(); OperateResult.AppendText("读取文件" + e.Name + "\n"); List name = new List(); List result = new List(); int name_or_result = 0; while (myReader.Read()) { if (myReader.NodeType == XmlNodeType.Element && myReader.Name == "test") { testDate = myReader.GetAttribute(1); testTime = myReader.GetAttribute(0); } if (myReader.NodeType == XmlNodeType.Text) { if (name_or_result % 2 == 0) { name.Add(myReader.Value); name_or_result++; } else { result.Add(myReader.Value); name_or_result++; } } } string date = testDate + " " + testTime; string sql = "insert into STEPTESTDETAIL(std_id,std_makecode,std_sn,std_subclass1,std_testresult,std_indate,"; sql += "std_rescode,std_testdate,std_testtime,std_date) values(STEPTESTDETAIL_seq.nextval, '" + iMakeCode + "', "; sql += "'" + sncode + "',:std_subclass1,:std_testresult, sysdate,'" + Source.Text + "',to_char(to_date('"+testDate+"','YYYY/MM/DD'), 'YYYYMMDD'),"; sql += "to_char(to_date('"+testTime+ "','hh24:mi:ss'), 'hh24miss'),to_date('"+ date + "','YYYY/MM/DD hh24:mi:ss'))"; dh.BatchInsert(sql, new string[] { "std_subclass1", "std_testresult" }, name.ToArray(), result.ToArray()); myReader.Close(); FileInfo file = new FileInfo(FolderPath.Text + @"\" + e.Name); if (file.Exists) { try { file.MoveTo(BackUpFolderPath.Text + @"\" + e.Name); } catch (Exception ex) { OperateResult.AppendText(e.Name + ex.Message + "\n"); } } } private void StopWatch_Click(object sender, EventArgs e) { XmlWatcher.EnableRaisingEvents = false; Source.Enabled = true; StartWatch.Enabled = true; ChooseFolder.Enabled = true; ChooseBackUpFolder.Enabled = true; OperateResult.AppendText("停止执行监控\n"); } private void Clean_Click(object sender, EventArgs e) { OperateResult.Clear(); } private void ChooseFolder_Click(object sender, EventArgs e) { FolderBrowserDialog folder = new FolderBrowserDialog(); folder.Description = "选择监控文件夹"; DialogResult result = folder.ShowDialog(); if (result == DialogResult.OK) { FolderPath.Text = folder.SelectedPath; } } private void ReadNodeFromXML(string FileName) { } private void ChooseBackUpFolder_Click(object sender, EventArgs e) { FolderBrowserDialog folder = new FolderBrowserDialog(); folder.Description = "选择备份文件夹"; DialogResult result = folder.ShowDialog(); if (result == DialogResult.OK) { BackUpFolderPath.Text = folder.SelectedPath; } } } }