mes-client/UAS_AutoPass/AutoAnalysisXml.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 UAS_AutoPass.ToolClass;
using BenQGuru.eMES.DLLService;
using System.Text;

namespace UAS_AutoPass
{
    public partial class AutoAnalysisXml : Form
    {

        DataHelper dh;

        DataTable dt;

        DataTable DB;

        MESHelper helper = new MESHelper();
        /// <summary>
        /// 用户编号
        /// </summary>
        string iusercode;
        /// <summary>
        /// 岗位资源
        /// </summary>
        string isource;

        Thread InitDB;
        /// <summary>
        /// 线别
        /// </summary>
        string ilinecode;
        /// <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/";

        public AutoAnalysisXml()
        {
            InitializeComponent();
            StartPosition = FormStartPosition.CenterScreen;
        }

        public AutoAnalysisXml(string iUserName, string iSource)
        {
            InitializeComponent();
            iusercode = iUserName;
            isource = iSource;
            StartPosition = FormStartPosition.CenterScreen;
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            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>();
            DB = (DataTable)dh.ExecuteSql("select ms_pwd,ma_user,ma_address from master", "select");
            Master.DataSource = DB;
            Master.DisplayMember = "ma_user";
            Master.ValueMember = "ma_user";
            //获取缓存信息
            try
            {
                FolderPath.Text = BaseUtil.GetCacheData("FolderPath").ToString();
                BackUpFolderPath.Text = BaseUtil.GetCacheData("BackUpFolderPath").ToString();
                Master.Text = BaseUtil.GetCacheData("Master").ToString();
                AutoStart.Checked = (bool)BaseUtil.GetCacheData("AutoStart");
            }
            catch (Exception ex) { Console.WriteLine(ex.Message); }
            //获取岗位资源相关信息
            dt = (DataTable)dh.ExecuteSql("select sc_linecode,sc_stepcode from source where sc_code='" + isource + "'", "select");
            if (dt.Rows.Count > 0)
            {
                ilinecode = dt.Rows[0]["sc_linecode"].ToString();
                istepcode = dt.Rows[0]["sc_stepcode"].ToString();
            }
        }

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

        private void StartWatch_Click(object sender, EventArgs e)
        {
            if (FolderPath.Text == "" || BackUpFolderPath.Text == "")
            {
                OperateResult.AppendText("请选择监控文件夹和备份文件夹\n");
                return;
            }
            else
            {
                if (!Directory.Exists(FolderPath.Text))
                {
                    OperateResult.AppendText("监控文件夹不存在\n");
                    return;
                }
                if (!Directory.Exists(BackUpFolderPath.Text))
                {
                    OperateResult.AppendText("备份文件夹不存在\n");
                    return;
                }
            }
            if (FolderPath.Text == BackUpFolderPath.Text)
            {
                OperateResult.AppendText("监控文件夹和备份文件夹不能相同\n");
                return;
            }
            for (int i = 0; i < DB.Rows.Count; i++)
            {
                if (Master.Text == DB.Rows[i]["ma_user"].ToString())
                {
                    DataHelper.DBConnectionString = "Data Source=" + DB.Rows[i]["ma_address"] + ";User ID=" + DB.Rows[i]["ma_user"] + ";PassWord=" + DB.Rows[i]["ms_pwd"]; ;
                    dh = new DataHelper();
                }
            }
            //暂时不用归属工单
            //if (!dh.CheckExist("make", "ma_statuscode='STARTED' and ma_code='" + MakeCode.Text + "'"))
            //{
            //    OperateResult.AppendText("工单不存在或者未下放\n");
            //    return;
            //}
            XmlWatcher.Path = FolderPath.Text;
            XmlWatcher.Filter = "*.xml";
            XmlWatcher.EnableRaisingEvents = true;
            //设置缓存数据
            BaseUtil.SetCacheData("FolderPath", FolderPath.Text);
            BaseUtil.SetCacheData("BackUpFolderPath", BackUpFolderPath.Text);
            BaseUtil.SetCacheData("Master", Master.Text);
            BaseUtil.SetCacheData("AutoStart", AutoStart.Checked);
            //设置按钮不可点击
            StartWatch.Enabled = false;
            ChooseFolder.Enabled = false;
            MakeCode.Enabled = false;
            ChooseBackUpFolder.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)
        {
            while (true)
            {
                try
                {
                    using (Stream stream = File.Open(e.FullPath, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite))
                    {
                        if (stream != null)
                            break;
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
            string test_date = "";
            string test_result = "";
            string test_sn = "";
            string imageurl = "";
            XmlReader myReader = XmlReader.Create(FolderPath.Text + @"\" + e.Name);
            OperateResult.AppendText("读取文件" + e.Name + "\n");
            //获取采集的项目名称
            List<string> badcode = new List<string>();
            //获取采集项目的结果
            List<string> badlocation = new List<string>();
            int code_or_location = 0;
            while (myReader.Read())
            {
                if (myReader.NodeType == XmlNodeType.Element && myReader.Name == "test" && myReader.IsStartElement())
                {
                    test_sn = myReader.GetAttribute("test_sn");
                    test_result = myReader.GetAttribute("test_result");
                    test_date = myReader.GetAttribute("test_date");
                    imageurl = myReader.GetAttribute("imgurl");
                }
                if (myReader.NodeType == XmlNodeType.Text)
                {
                    if (code_or_location % 2 == 0)
                    {
                        badcode.Add(myReader.Value);
                        code_or_location++;
                    }
                    else
                    {
                        badlocation.Add(myReader.Value);
                        code_or_location++;
                    }
                }
            }
            myReader.Close();
            //获取文件名的序列号,如SA123456.xml，如果开头为-表示无条码需要自动获取
            string sncode = e.Name.Substring(0, 1) == "-" ? "" : e.Name.Split('.')[0];
            string makecode = "";
            string ErrMessage = "";
            //获取序列号ID最大的工单号,测试良品时才进行分配
            if (sncode == "" && test_result == "OK")
            {
                //获取资源,线别,工序相等，并且状态在线的序列号进行分配
                sql.Clear();
                sql.Append("select ms_sncode,ms_makecode from makeserial left join source on sc_code=ms_sccode where ");
                sql.Append("ms_linecode='" + ilinecode + "' and ms_nextstepcode='" + istepcode + "' and ms_status=1 order by ms_id");
                dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
                if (dt.Rows.Count > 0)
                {
                    makecode = dt.Rows[0]["ms_makecode"].ToString();
                    sncode = dt.Rows[0]["ms_sncode"].ToString();
                }
                string combinecode = e.Name.Substring(1, 1);
                sql.Clear();
                sql.Append("insert into AUTOSCANLOG(as_id,as_indate,as_testdate,as_sourcecode,as_stepcode,");
                sql.Append("as_linecode,as_makecode,as_sncode,as_filename,");

                sql.Clear();
                sql.Append("insert into AUTOSCAN_REJUDGE(asr_id,asr_indate,asr_filename,asr_combinecode,asr_sourcecode,");
                sql.Append("asr_linecode,asr_makecode,asr_sncode) values(AUTOSCAN_REJUDGE_seq.nextval,sysdate,'" + e.Name + "'");
                sql.Append(",'" + combinecode + "','" + isource + "','" + ilinecode + "','" + makecode + "','" + sncode + "')");
                dh.ExecuteSql(sql.ToString(), "insert");
                if (!LogicHandler.SetStepResult(makecode, isource, sncode, "自动过站采集", test_result, iusercode, out ErrMessage))
                {
                    OperateResult.AppendText(ErrMessage + "\n");
                    return;
                }
            }
            //没有条码并且不良进行记录
            else if (sncode == "" && test_result == "NG")
            {
                //-2-NG2017/10/2514:46:29.xml取第二位版号
                string combinecode = e.Name.Substring(1, 1);
                sql.Clear();
                sql.Append("insert into AUTOSCAN_REJUDGE(asr_id,asr_indate,asr_filename,asr_combinecode,asr_sourcecode,");
                sql.Append("asr_linecode) values(AUTOSCAN_REJUDGE_seq.nextval,sysdate,'" + e.Name + "','" + combinecode + "','" + isource + "','" + ilinecode + "')");
                dh.ExecuteSql(sql.ToString(), "insert");
            }
            else if (sncode != "")
            {
                //获取序列号ID最大的工单
                string msid = "";
                dt = (DataTable)dh.ExecuteSql("select ms_makecode,ms_id from makeserial where ms_sncode='" + sncode + "' order by ms_id desc", "select");
                if (dt.Rows.Count > 0)
                {
                    msid = dt.Rows[0]["ms_id"].ToString();
                    makecode = dt.Rows[0]["ms_makecode"].ToString();
                    switch (test_result)
                    {
                        case "OK":
                            if (!LogicHandler.SetStepResult(makecode, isource, sncode, "自动过站采集", test_result, iusercode, out ErrMessage))
                            {
                                OperateResult.AppendText(ErrMessage + "\n");
                                return;
                            }
                            break;
                        case "NG":
                            sql.Clear();
                            sql.Append("insert into makebad(mb_id,mb_makecode,mb_mscode,mb_sncode,mb_inman,mb_indate,mb_stepcode");
                            sql.Append(",mb_sourcecode,mb_badcode,mb_badtable,mb_soncode,mb_status) select makebad_seq.nextval");
                            sql.Append(",ma_code,ms_code,ms_sncode,'" + iusercode + "',sysdate,'" + istepcode + "','" + isource + "',:bc_code,'',");
                            sql.Append("sp_soncode,'0' from make left join makeSerial on ms_makecode=ma_code left join stepProduct on sp_mothercode");
                            sql.Append("=ma_prodcode and sp_stepcode=ms_nextstepcode where ms_sncode='" + sncode + "' and ms_makecode='" + makecode + "'");
                            dh.BatchInsert(sql.ToString(), new string[] { "bc_code" }, badcode.ToArray());
                            //更新序列号不良状态
                            dh.UpdateByCondition("makeserial", "ms_status=3", "ms_id='" + msid + "'");
                            for (int i = 0; i < badcode.Count; i++)
                            {
                                //保存不良位置
                                string[] location = badlocation[i].Split(',');
                                sql.Clear();
                                sql.Append("insert into makebadrsloc(mbl_id,mbl_loc,mbl_badcode,mbl_sncode,mbl_makecode,");
                                sql.Append("mbl_indate ,mbl_inman) select makebadrsloc_seq.nextval,");
                                sql.Append(":location,'" + badcode[i] + "','" + sncode + "','" + makecode + "',");
                                sql.Append("sysdate,'" + iusercode + "' from dual");
                                dh.BatchInsert(sql.ToString(), new string[] { "location" }, location);
                            }
                            if (!LogicHandler.SetStepResult(makecode, isource, sncode, "自动过站采集", test_result, iusercode, out ErrMessage))
                            {
                                OperateResult.AppendText(ErrMessage + "\n");
                                return;
                            }
                            break;
                        default:
                            break;
                    }
                }
            }
            FileInfo file = new FileInfo(FolderPath.Text + @"\" + e.Name);
            if (file.Exists)
            {
                try
                {
                    for (int i = 1; i <= 20; i++)
                    {
                        if (!File.Exists(BackUpFolderPath.Text + @"\" + e.Name))
                        {
                            file.MoveTo(BackUpFolderPath.Text + @"\" + e.Name);
                            OperateResult.AppendText("成功解析文件" + e.Name + "\n");
                            break;
                        }
                        else if (!File.Exists(BackUpFolderPath.Text + @"\" + e.Name.Split('.')[0] + "(" + i + ")" + "." + e.Name.Split('.')[1]))
                        {
                            file.MoveTo(BackUpFolderPath.Text + @"\" + e.Name.Split('.')[0] + "(" + i + ")" + "." + e.Name.Split('.')[1]);
                            OperateResult.AppendText("成功解析文件" + e.Name + "\n");
                            break;
                        }
                    }
                }
                catch (Exception ex)
                {
                    OperateResult.AppendText(e.Name + ex.Message + "\n");
                }
            }
        }

        private void StopWatch_Click(object sender, EventArgs e)
        {
            XmlWatcher.EnableRaisingEvents = false;
            StartWatch.Enabled = true;
            MakeCode.Enabled = true;
            ChooseFolder.Enabled = true;
            ChooseBackUpFolder.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_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();
            }
        }
    }
}