mes-client/FileWatcher/AutoAnalysisXmlByStep.cs

using Microsoft.Win32;
using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Threading;
using System.Windows.Forms;
using System.Xml;
using System.Text;
using System.Media;
using System.Linq;
using NPOI.SS.Formula.Functions;
using System.Windows.Media.TextFormatting;
using UMESDLLService;

namespace FileWatcher
{
    public partial class AutoAnalysisXmlByStep : Form
    {

        public static DataHelper dh;

        DataTable dt;

        DataTable DB;

        /// <summary>
        /// 用户编号
        /// </summary>
        string iusercode;
        /// <summary>
        /// 岗位资源
        /// </summary>
        string isource;

        Tip tipform;

        Thread InitDB;
        /// <summary>
        /// 线别
        /// </summary>
        string ilinecode;
        /// <summary>
        /// 不良代码组
        /// </summary>
        string ibadgroup;
        /// <summary>
        /// 当前工序
        /// </summary>
        string istepcode;
        StringBuilder sql = new StringBuilder();
        /// <summary>
        /// 缓存的文件
        /// </summary>
        public static string CachePath = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/Cache.xml";
        /// <summary>
        /// 缓存的文件夹
        /// </summary>
        public static string CachePathFolder = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/";
        /// <summary>
        /// 需要解析的文件名
        /// </summary>
        List<string> _FileName = new List<string>();

        ftpOperater ftp;
        string imaster;

        public AutoAnalysisXmlByStep()
        {
            tipform = new Tip();
            InitializeComponent();
            StartPosition = FormStartPosition.CenterScreen;
        }

        public AutoAnalysisXmlByStep(string iUserName, string iSource, string iMaster)
        {
            tipform = new Tip();
            InitializeComponent();
            iusercode = iUserName;
            isource = iSource.ToUpper();
            imaster = iMaster;
            StartPosition = FormStartPosition.CenterScreen;
        }
        string fieltype = "";
        string ftpulr = "";
        private void Form1_Load(object sender, EventArgs e)
        {
            tipform.Show();
            CheckForIllegalCrossThreadCalls = false;
            FormBorderStyle = FormBorderStyle.FixedSingle;
            InitDB = new Thread(ConnectDB);
            //添加监控事件
            XmlWatcher.Created += new FileSystemEventHandler(XmlWatcher_Created);
            SetLoadingWindow stw = new SetLoadingWindow(InitDB, "正在启动程序");
            stw.StartPosition = FormStartPosition.CenterScreen;
            stw.ShowDialog();
            List<string> CacheInf = new List<string>();
            StreamReader sR = new StreamReader(Application.StartupPath + @"\MES_SETTING.txt", Encoding.Default);
            while ((nextLine = sR.ReadLine()) != null)
            {
                string name = nextLine.ToString().Split('=')[0];
                string value = nextLine.ToString().Split('=')[1];
                if (name == "FTPURL")
                {
                    ftpulr = value;
                }
                if (name == "FileType")
                {
                    fieltype = value;
                }
            }
            string[] FTPInf = ftpulr.Split('#');
            ftp = new ftpOperater(FTPInf[0], FTPInf[1], FTPInf[2]);
            //获取缓存信息
            try
            {
                FolderPath.Text = BaseUtil.GetCacheData("FolderPath").ToString();
                BackUpFolderPath.Text = BaseUtil.GetCacheData("BackUpFolderPath").ToString();
                Master.Text = BaseUtil.GetCacheData("Master").ToString();
                li_code.Text = BaseUtil.GetCacheData("Line").ToString();
                MachineType.Text = BaseUtil.GetCacheData("MachineType").ToString();
                Device.Text = BaseUtil.GetCacheData("Device").ToString();
            }
            catch (Exception ex) { MessageBox.Show(ex.Message); }
            StartWatch.PerformClick();
        }

        private void ConnectDB()
        {
            dh = new DataHelper();
        }

        private void StartWatch_Click(object sender, EventArgs e)
        {
            if (FolderPath.Text == "")
            {
                OperateResult.AppendText("请选择监控文件夹\n");
                return;
            }
            else
            {
                if (!Directory.Exists(FolderPath.Text))
                {
                    OperateResult.AppendText("监控文件夹不存在\n");
                    return;
                }
            }
            if (!dh.CheckExist("line", "li_code='" + li_code.Text + "'"))
            {
                OperateResult.AppendText("线别不存在\n");
                return;
            }
            XmlWatcher.Path = FolderPath.Text;
            XmlWatcher.Filter = "*.*";
            XmlWatcher.EnableRaisingEvents = true;
            //设置缓存数据
            BaseUtil.SetCacheData("FolderPath", FolderPath.Text);
            BaseUtil.SetCacheData("BackUpFolderPath", BackUpFolderPath.Text);
            BaseUtil.SetCacheData("Master", Master.Text);
            BaseUtil.SetCacheData("Line", li_code.Text);
            BaseUtil.SetCacheData("MachineType", MachineType.Text);
            BaseUtil.SetCacheData("Device", Device.Text);
            //BaseUtil.SetCacheData("AutoStart", AutoStart.Checked);
            Timer.Interval = 1000 * 10;
            Timer.Start();
            //设置按钮不可点击
            StartWatch.Enabled = false;
            ChooseFolder.Enabled = false;
            Master.Enabled = false;
            StopWatch.Enabled = true;
            OperateResult.AppendText("开始执行监控\n");
        }

        public void CreateNode(XmlDocument xmlDoc, XmlNode parentNode, string name, string value)
        {
            XmlNode node = xmlDoc.CreateNode(XmlNodeType.Element, name, null);
            node.InnerText = value;
            parentNode.AppendChild(node);
        }

        private void XmlWatcher_Created(object sender, FileSystemEventArgs e)
        {
            string[] str = fieltype.Split('#');
            for (int i = 0; i < str.Length; i++)
            {
                if (e.FullPath.ToUpper().EndsWith(str[i].ToUpper()))
                {
                    TxtHandleProcess(e.FullPath);
                }
            }
        }
        string nextLine;
        private void TxtHandleProcess(string FileName)
        {
            List<string> badcode = new List<string>();
            List<string> badlocation = new List<string>();
            List<string> badprod = new List<string>();
            try
            {
                string filename = FileName;
                string folderpath = FileName.Substring(0, FileName.LastIndexOf(@"\"));
                string SN = FileName.Substring(FileName.LastIndexOf(@"\") + 1);
                string filetype = FileName.Substring(FileName.LastIndexOf(".") + 1);
                {
                    try
                    {
                        string sn1 = SN.Split('.')[0];
                        //string makecode = dh.getFieldDataByCondition("makeserial", "ms_makecode", "ms_sncode='" + sn1 + "'").ToString();
                        //MachineType.Text = makecode;
                        string ftppath = "/" + MachineType.Text + "/";
                        //string ErrMessage = ftp.UpLoadFile(folderpath, SN, ftppath, "");
                        DirectoryInfo info = new DirectoryInfo(folderpath);
                        MachineType.Text = info.Name;//获取当前路径最后一级文件夹名称
                        if (Device.Text == "炉后AOI")
                        {
                            StreamReader sR = new StreamReader(FileName, Encoding.Default);
                            string ASN = "";
                            string Model = "";
                            string Shift = "";
                            string Rep_Date_Time = "";
                            string OPID = "";
                            string StationName = "";
                            string Surface = "";
                            string CycleTime = "";
                            string Result = "";
                            int Rowindex = 0;
                            List<string> Location = new List<string>();
                            List<string> PinNum = new List<string>();
                            List<string> ErrCode = new List<string>();
                            List<string> RepairStatus = new List<string>();
                            while ((nextLine = sR.ReadLine()) != null)
                            {
                                string data = nextLine.ToString().Split('=')[1];
                                string itemname = nextLine.ToString().Split('=')[0];
                                switch (Rowindex)
                                {
                                    case 0:
                                        ASN = data;
                                        break;
                                    case 1:
                                        Model = data;
                                        break;
                                    case 2:
                                        Shift = data;
                                        break;
                                    case 3:
                                        Rep_Date_Time = data;
                                        break;
                                    case 4:
                                        OPID = data;
                                        break;
                                    case 5:
                                        StationName = data;
                                        break;
                                    case 6:
                                        Surface = data;
                                        break;
                                    case 7:
                                        CycleTime = data;
                                        break;
                                    default:
                                        break;
                                }
                                if (itemname == "Result")
                                {
                                    Result = data;
                                    continue;
                                }
                                if (Rowindex >= 8)
                                {
                                    //Location
                                    if ((Rowindex - 8) % 4 == 0)
                                    {
                                        Location.Add(data);
                                    }
                                    //PinNum
                                    if ((Rowindex - 8) % 4 == 1)
                                    {
                                        PinNum.Add(data);
                                    }
                                    //ErrCode
                                    if ((Rowindex - 8) % 4 == 2)
                                    {
                                        ErrCode.Add(data);
                                    }
                                    //RepairStatus
                                    if ((Rowindex - 8) % 4 == 3)
                                    {
                                        RepairStatus.Add(data);
                                    }
                                }

                                Rowindex = Rowindex + 1;
                            }
                            sR.Close();
                            Thread.Sleep(500);
                            int num = int.Parse(dh.ExecuteSql("insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class,STD_RESCODE,std_stepcode,std_linecode,std_machinetype, STD_TESTRESULT)select STEPTESTDETAIL_seq.nextval,'" + SN + "','',sysdate,'" + ftpulr.Split('#')[0] + imaster + "/" + ftppath + SN + "','" + isource + "','" + Device.Text + "','" + li_code.Text + "','" + MachineType.Text + "','" + Result + "' from dual", "insert").ToString());
                            if (Result.ToUpper() == "FAIL")
                            {
                                sql.Clear();
                                sql.Append("insert into makebad(mb_id,MB_MSCODE, MB_SNCODE, MB_INDATE, MB_STEPCODE, MB_SOURCECODE, MB_BADCODE, MB_YMD, MB_LINECODE,MB_BADNAME)");
                                sql.Append("values(makebad_seq.nextval,'" + ASN + "','" + ASN + "',sysdate,'AOI-B','',:MB_BADCODE,to_char(sysdate,'yyyymmdd'),'" + li_code.Text + "',:MB_BADNAME)");
                                dh.BatchInsert(sql.ToString(), new string[] { "mb_badcode", "mb_badname" }, ErrCode.ToArray(), Location.ToArray());
                            }
                            if (num > 0)
                            {
                                OperateResult.AppendText("序列号:" + SN + "上传成功\n");
                                string Backupfilename = BackUpFolderPath.Text + @"\" + MachineType.Text + @"\" + SN;
                                if (!Directory.Exists(BackUpFolderPath.Text + @"\" + MachineType.Text))
                                {
                                    Directory.CreateDirectory(BackUpFolderPath.Text + @"\" + MachineType.Text);
                                }
                                if (File.Exists(Backupfilename))
                                {
                                    File.Delete(Backupfilename);
                                }
                                File.Move(FileName, Backupfilename);
                            }
                        }
                        else
                        {
                            int num = int.Parse(dh.ExecuteSql("insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class,STD_RESCODE,std_stepcode,std_linecode,std_machinetype)select STEPTESTDETAIL_seq.nextval,'" + SN + "','',sysdate,'" + ftpulr.Split('#')[0] + imaster + "/" + ftppath + SN + "','" + isource + "','" + Device.Text + "','" + li_code.Text + "','" + MachineType.Text + "' from dual", "insert").ToString());
                            if (num > 0)
                            {
                                OperateResult.AppendText("序列号:" + SN + "上传成功\n");
                                string Backupfilename = BackUpFolderPath.Text + @"\" + MachineType.Text + @"\" + SN;
                                if (!Directory.Exists(BackUpFolderPath.Text + @"\" + MachineType.Text))
                                {
                                    Directory.CreateDirectory(BackUpFolderPath.Text + @"\" + MachineType.Text);
                                }
                                File.Move(FileName, Backupfilename);
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        OperateResult.AppendText(ex.Message + ex.StackTrace + "\n");
                    }
                }
            }
            catch (Exception e)
            {
                OperateResult.AppendText("解析失败:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + FileName + "\n" + e.Message + "\n");
            }
        }

        private void StopWatch_Click(object sender, EventArgs e)
        {
            XmlWatcher.EnableRaisingEvents = false;
            StartWatch.Enabled = true;
            Master.Enabled = true;
            ChooseFolder.Enabled = true;

            StopWatch.Enabled = false;
            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 ChooseBackUpFolder_Click(object sender, EventArgs e)
        {
            FolderBrowserDialog folder = new FolderBrowserDialog();
            folder.Description = "选择备份文件夹";
            DialogResult result = folder.ShowDialog();
            if (result == DialogResult.OK)
            {
                BackUpFolderPath.Text = folder.SelectedPath;
            }
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            string ExitConfirm = MessageBox.Show(this, "确认退出？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
            if (ExitConfirm != "Yes")
            {
                WindowState = FormWindowState.Minimized;
                e.Cancel = true;
            }
        }

        private void AutoStart_CheckedChanged(object sender, EventArgs e)
        {
            SetAutoRun();
        }

        private 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自动过站解析器.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自动过站解析器.exe", false);
                rk2.Close();
                rk.Close();
            }
        }

        private void BatchAnalysus_Click(object sender, EventArgs e)
        {
            //var AllXmls = Directory.GetFiles(FolderPath.Text, "*.txt");
            //foreach (var Xml in AllXmls)
            //{
            //    TxtHandleProcess(Xml);
            //}
        }

        private void Timer_Tick(object sender, EventArgs e)
        {
            //var AllXmls = Directory.GetFiles(FolderPath.Text, "*.*", SearchOption.AllDirectories).Where(s => s.EndsWith(".txt") || s.EndsWith(".ini"));
            //foreach (var Xml in AllXmls)
            //{
            //    TxtHandleProcess(Xml);
            //}
        }

        private void CleanFolderPath_Click(object sender, EventArgs e)
        {
            FolderPath.Text = "";
        }

        private void CleanBackUpFolderPath_Click(object sender, EventArgs e)
        {
            BackUpFolderPath.Text = "";
        }
    }
}