mes-client/FileWatcher/AutoAnalysisDevice.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.Net;
using System.Net.Sockets;
using System.Text.RegularExpressions;

namespace FileWatcher
{
    public partial class AutoAnalysisDevice : Form
    {

        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>();

        string master = "WKS";

        ftpOperater ftp = new ftpOperater();

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

        public AutoAnalysisDevice(string iUserName, string iSource, string iMaster)
        {
            tipform = new Tip();
            InitializeComponent();
            iusercode = iUserName;
            isource = iSource.ToUpper();
            master = iMaster;
            StartPosition = FormStartPosition.CenterScreen;
        }
        string IPAddress = "";

        private void Form1_Load(object sender, EventArgs e)
        {
            tipform.Show();
            CheckForIllegalCrossThreadCalls = false;
            FormBorderStyle = FormBorderStyle.FixedSingle;
            InitDB = new Thread(ConnectDB);
            //添加监控事件
            XmlWatcher.Changed += new FileSystemEventHandler(XmlWatcher_Created);
            ATEFile.Created += new FileSystemEventHandler(XmlWatcher_Created);
            SetLoadingWindow stw = new SetLoadingWindow(InitDB, "正在启动程序");
            stw.StartPosition = FormStartPosition.CenterScreen;
            stw.ShowDialog();
            List<string> CacheInf = new List<string>();

            IPHostEntry IpEntry = Dns.GetHostEntry(Dns.GetHostName());
            for (int i = 0; i < IpEntry.AddressList.Length; i++)
            {
                if (IpEntry.AddressList[i].AddressFamily == AddressFamily.InterNetwork)
                    IPAddress = IpEntry.AddressList[i].ToString();
            }
            //获取缓存信息
            try
            {
                FolderPath.Text = BaseUtil.GetCacheData("FolderPath").ToString();
                Device.Text = BaseUtil.GetCacheData("Device").ToString();
                //BackUpFolderPath.Text = BaseUtil.GetCacheData("BackUpFolderPath").ToString();
                //Master.Text = BaseUtil.GetCacheData("Master").ToString();
                //AutoStart.Checked = (bool)BaseUtil.GetCacheData("AutoStart");
            }
            catch (Exception ex) { MessageBox.Show(ex.Message); }
            //获取岗位资源相关信息
            DataTable dt = (DataTable)dh.ExecuteSql("select sc_linecode,sc_stepcode,st_badgroupcode from source left join step on sc_stepcode=st_code where sc_code='" + isource + "'", "select");
            if (dt.Rows.Count > 0)
            {
                ilinecode = dt.Rows[0]["sc_linecode"].ToString();
                istepcode = dt.Rows[0]["sc_stepcode"].ToString();
                ibadgroup = dt.Rows[0]["st_badgroupcode"].ToString();
            }
        }

        private void ConnectDB()
        {
            DataHelper.DBConnectionString = "Connection Timeout=0;Pooling=false;Password=select!#%*(;User ID=N_MES;Pooling=false;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.6.253)(PORT=1521)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=orcl)));";
            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;
                }
            }
            XmlWatcher.Path = FolderPath.Text;
            XmlWatcher.EnableRaisingEvents = true;
            XmlWatcher.NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite;
            ATEFile.Path = FolderPath.Text;
            ATEFile.EnableRaisingEvents = true;
            ATEFile.NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite;
            //设置缓存数据
            BaseUtil.SetCacheData("FolderPath", FolderPath.Text);
            BaseUtil.SetCacheData("Device", Device.Text);

            //BaseUtil.SetCacheData("BackUpFolderPath", BackUpFolderPath.Text);
            //BaseUtil.SetCacheData("Master", Master.Text);
            //BaseUtil.SetCacheData("AutoStart", AutoStart.Checked);
            Timer.Interval = 1000 * 10;
            Timer.Start();
            //设置按钮不可点击
            StartWatch.Enabled = false;
            ChooseFolder.Enabled = false;
            Master.Enabled = false;
            ma_code.Enabled = false;
            StopWatch.Enabled = true;
            OperateResult.AppendText("开始执行监控\n");
        }

        private void XmlWatcher_Created(object sender, FileSystemEventArgs e)
        {
            OperateResult.AppendText("文件修改:" + e.FullPath + "\n");
            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>();
            if (Device.Text == "老化设备")
            {
                StreamReader sR = new StreamReader(FileName, Encoding.Default);
                Console.WriteLine(sR.CurrentEncoding);
                DataTable filedt = new DataTable();
                //文件内的行，用一个DataTable存储
                int Rowindex = 0;
                while ((nextLine = sR.ReadLine()) != null)
                {
                    //DataTable用第一行的数据作为列名
                    string[] title = nextLine.Split(',');
                    DataRow dr = filedt.NewRow();
                    for (int i = 0; i < title.Length; i++)
                    {
                        if (Rowindex == 0)
                        {
                            switch (i)
                            {
                                case 0:
                                    filedt.Columns.Add("区域");
                                    break;
                                case 1:
                                    filedt.Columns.Add("产品代码");
                                    break;
                                case 2:
                                    filedt.Columns.Add("上架时间");
                                    break;
                                case 3:
                                    filedt.Columns.Add("下架时间");
                                    break;
                                case 4:
                                    filedt.Columns.Add("上架数量");
                                    break;
                                case 5:
                                    filedt.Columns.Add("合格数量");
                                    break;
                                case 6:
                                    filedt.Columns.Add("不良数量");
                                    break;
                                case 7:
                                    filedt.Columns.Add("文件路径");
                                    break;
                                default:
                                    break;
                            }
                        }
                        dr[filedt.Columns[i].ColumnName] = title[i];
                    }
                    filedt.Rows.Add(dr);
                    Rowindex = Rowindex + 1;
                }
                sR.Close();
                OperateResult.AppendText("文件修改" + filedt.Rows.Count + "\n");
                for (int i = 0; i < filedt.Rows.Count; i++)
                {
                    if (!dh.CheckExist("Devicetestinfo", "(dti_uptime)=to_date('" + filedt.Rows[i]["上架时间"].ToString() + "','yyyy/mm/dd hh24:mi:ss') and dti_ipaddress='" + IPAddress + "'"))
                    {
                        string filename = filedt.Rows[i]["文件路径"].ToString();
                        Dictionary<string, object> dic = new Dictionary<string, object>
                        {
                            { "em_name", "管理员" },
                            { "em_code", "ADMIN" },
                            { "caller", "AGING" }
                        };
                        string fp_id;
                        string fp_path;
                        UploadFilesToRemoteUrl("http://192.168.6.253:8099/mes/MEScommon/uploadFiles.action?_noc=1", filename, dic,out fp_path, out fp_id);
                        fp_path = "http://192.168.6.253:8099/" + fp_path.Replace("/app/uas/webapps/", "");
                        fp_path= fp_path.Replace("\"","");
                        dh.ExecuteSql("insert into Devicetestinfo(dti_id,dti_prodcode,dti_area,dti_uptime,dti_downtime,dti_upqty,dti_okqty,dti_ngqty,dti_ipaddress,dti_filepath,dti_indate,dti_fpid)values(Devicetestinfo_seq.nextval,'" + filedt.Rows[i]["产品代码"].ToString() + "','" + filedt.Rows[i]["区域"].ToString() + "',to_date('" + filedt.Rows[i]["上架时间"].ToString() + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + filedt.Rows[i]["下架时间"].ToString() + "','yyyy/mm/dd hh24:mi:ss'),'" + filedt.Rows[i]["上架数量"].ToString() + "','" + filedt.Rows[i]["合格数量"].ToString() + "','" + filedt.Rows[i]["不良数量"].ToString() + "','" + IPAddress + "','"+ fp_path + "',sysdate,'"+ fp_id + "')", "insert");
                        OperateResult.AppendText("上传文件" + filename + "\n");
                    }
                }
            }
            else if (Device.Text == "ATE设备")
            {
                try
                {
                    StreamReader sR = File.OpenText(FileName);
                    string filename = FileName;
                    List<string> programname = new List<string>();
                    List<string> data = new List<string>();
                    Regex re = new Regex(@"\d+");
                    if (filename.Substring(filename.LastIndexOf(".") + 1).ToUpper() == "INI")
                    {
                        while ((nextLine = sR.ReadLine()) != null)
                        {
                            programname.Add(nextLine);
                        }
                        string[] str = programname.ToArray();
                        for (int i = str.Length - 4; i < str.Length; i++)
                        {
                            if (str[i].Contains("["))
                            {
                                data.Add(str[i]);
                            }
                            else
                            {
                                data.Add(re.Match(str[i]).Groups[0].Value);
                            }
                        }
                        dh.ExecuteSql("insert into ATETESTDATA(atd_id,atd_name,atd_passqty,atd_ngqty,atd_lastqty,atd_ipaddress,atd_makecode,atd_makecode)values(ATETESTDATA_seq.nextval,'" + data.ToArray()[0] + "','" + data.ToArray()[1] + "','" + data.ToArray()[2] + "','" + data.ToArray()[3] + "','" + IPAddress + "','" + ma_code.Text + "',sysdate)", "insert");
                    }
                }
                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;
            ma_code.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)
            {

            }
        }

        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)
        {
            TxtHandleProcess(@"C:\Users\callm\Desktop\导入数据\客户资料\睿德电子\新建文本文档.log");
            //TxtHandleProcess(@"C:\Users\callm\Desktop\导入数据\客户资料\睿德电子\PowerTestTj.ini");
        }

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

        /// <summary>
        /// 请求上传图片到阿里云
        /// </summary>
        /// <param name="url">上传地址</param>
        /// <param name="filepath">本地文件路径</param>
        /// <param name="dic">上传的数据信息</param>
        /// <returns></returns>
        public string UploadFilesToRemoteUrl(string url1, string filepath, Dictionary<string, object> dic,out string fp_path,out string fp_id)
        {
            fp_id = "";
            fp_path = "";
            try
            {
                ServicePointManager.DefaultConnectionLimit = 50;

                string boundary = DateTime.Now.Ticks.ToString("x");

                byte[] boundarybytes = System.Text.Encoding.UTF8.GetBytes("--" + boundary + "\r\n");

                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url1);
                request.Method = "POST";
                request.Timeout = 10 * 10000;
                request.ContentType = "multipart/form-data; boundary=" + boundary;

                Stream rs = request.GetRequestStream();

                var endBoundaryBytes = Encoding.UTF8.GetBytes("--" + boundary + "--\r\n");

                string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n" + "\r\n" + "{1}" + "\r\n";
                if (dic != null)
                {
                    foreach (string key in dic.Keys)
                    {
                        rs.Write(boundarybytes, 0, boundarybytes.Length);

                        string formitem = string.Format(formdataTemplate, key, dic[key]);

                        byte[] formitembytes = System.Text.Encoding.UTF8.GetBytes(formitem);

                        rs.Write(formitembytes, 0, formitembytes.Length);
                    }

                }

                string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\n\r\n";
                {
                    rs.Write(boundarybytes, 0, boundarybytes.Length);

                    var header = string.Format(headerTemplate, "file", Path.GetFileName(filepath));

                    var headerbytes = System.Text.Encoding.UTF8.GetBytes(header);

                    rs.Write(headerbytes, 0, headerbytes.Length);

                    using (var fileStream = new FileStream(filepath, FileMode.Open, FileAccess.Read))
                    {
                        var buffer = new byte[1024];

                        var bytesRead = 0;

                        while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
                        {
                            rs.Write(buffer, 0, bytesRead);
                        }
                    }
                    var cr = Encoding.UTF8.GetBytes("\r\n");

                    rs.Write(cr, 0, cr.Length);
                }

                rs.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);

                var response = request.GetResponse() as HttpWebResponse;

                StreamReader newReader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
                string Content = newReader.ReadToEnd();
                Dictionary<string, object> dic1 = new Dictionary<string, object>();
                List<Dictionary<string, object>> dic2 = null;
                dic1 = BaseUtil.ToDictionary(Content);
                dic2 = dic1["data"] as List<Dictionary<string, object>>;
            
                if (dic2[0]["filepath"] != null)
                {
                    fp_id = dic2[0]["filepath"].ToString();
                    fp_path= dic2[0]["path"].ToString();
                }
                if (response.StatusCode == HttpStatusCode.OK)
                {
                    Console.WriteLine(fp_id);
                    return fp_id;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message + e.StackTrace);
            }
            return "";
        }
    }
}