mes-client/UAS_MES_BG/FunctionCode/Make/Make_ParseLog.cs

using BarTender;
using DevExpress.Utils.OAuth.Provider;
using DevExpress.Xpo.Logger;
using DevExpress.XtraEditors.Controls;
using DevExpress.XtraExport;
using DevExpress.XtraPrinting;
using NPOI.SS.Formula.Functions;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Security;
using System.Security.AccessControl;
using System.Security.Principal;
using System.Text;
using System.Threading.Tasks;
using System.Web.Services.Description;
using System.Web.UI.WebControls;
using System.Windows.Forms;
using System.Xml;
using UAS_MES_NEW.CustomControl.ButtonUtil;
using UAS_MES_NEW.CustomControl.TextBoxWithIcon;
using UAS_MES_NEW.DataOperate;
using UAS_MES_NEW.Entity;
using UAS_MES_NEW.PublicMethod;
using static DevExpress.Xpo.DB.DataStoreLongrunnersWatch;
using static System.Windows.Forms.VisualStyles.VisualStyleElement.Tab;

namespace UAS_MES_NEW.Make
{
    public partial class Make_ParseLog : Form
    {
        public Make_ParseLog()
        {
            InitializeComponent();
        }

        FileSystemWatcher watcher;

        LogStringBuilder sql = new LogStringBuilder();
        DataTable Dbfind;
        DataTable dt;

        DataHelper dh;
        string currFileType = "",equiType = "";

        string SN, omakeCode, oMsid, oErrorMessage = "";
        List<string> fileList = new List<string>();

        Timer formsTimer,SPITimer;
        string outXmlFilePath;

        private void Make_ParseLog_Load(object sender, EventArgs e)
        {
            dh = SystemInf.dh;

            fileList.Add("D:\\MES"); // 劲拓SPI
            fileList.Add("D:\\EYSPI\\DataExport\\Res"); // 思泰克SPI
            fileList.Add("E:\\MES_TEXT_PATH");  // AOI 
            fileList.Add("C:\\GKGPrintTemp");   // GKG印刷机
            fileList.Add("");   // 贴片机
            fileList.Add("D:\\JANETSSC\\SMT\\MachineMonitoring");   // JUKI贴片机

            formsTimer = new Timer();
            formsTimer.Interval = 10000;
            formsTimer.Tick += timer1_Tick;

            SPITimer = new Timer();
            SPITimer.Interval = 30000;
            SPITimer.Tick += SPITimer_Tick;

            //outXmlFilePath = "C:\\Users\\MI\\Desktop\\贴片机\\outLogs";
            outXmlFilePath = "D:\\JANETSSR";

            watcher = new FileSystemWatcher();
            watcher.NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite;
            watcher.Created += OnFileCreated;
            /*watcher.Changed += OnFileChanged;
            watcher.Deleted += OnFileChanged;
            watcher.Renamed += OnFileChanged;*/

            //设置锁定工单
            LockMakeCode.GetMakeCodeCtl(ma_code);
            ma_code.SetLockCheckBox(LockMakeCode);
            //工单号放大镜配置
            ma_code.TableName = "make left join product on ma_prodcode=pr_code";
            ma_code.SelectField = "ma_code # 工单号,pr_code # 产品编号,pr_detail # 产品名称";
            ma_code.FormName = Name;
            ma_code.SetValueField = new string[] { "ma_code", "pr_code", "pr_detail" };
            ma_code.Condition = "ma_statuscode='STARTED'";
            ma_code.DbChange += Ma_code_DbChange;
        }

        private void Ma_code_DbChange(object sender, EventArgs e)
        {
            Dbfind = ma_code.ReturnData;
            BaseUtil.SetFormValue(this.Controls, Dbfind);
            //获取工单的其他信息
            sql.Clear();
            sql.Append("select ma_code,nvl(mcd_okqty,0) mcd_okqty,ma_prodcode as pr_code ,pr_detail,");
            sql.Append("pr_spec,ma_qty - nvl(mcd_inqty, 0) mcd_remainqty from make left join makecraftdetail on ");
            sql.Append("mcd_maid=ma_id left join product on pr_code=ma_prodcode where ma_code='" + ma_code.Text + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
            dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
            if (dt.Rows.Count > 0)
            {
                BaseUtil.SetFormValue(this.Controls, dt);
            }
        }

        private void Device_SelectedIndexChanged(object sender, EventArgs e)
        {
            if (Device.SelectedIndex == -1) return;

            switch (Device.SelectedIndex)
            {
                case 0:
                    currFileType = "txt";
                    equiType = "SPI";

                    SPITimer_Tick(null, null);
                    SPITimer.Start();
                    break;
                case 1:
                    currFileType = "csv";
                    equiType = "SPI";
                    SPITimer.Stop();
                    break;
                case 2:
                    currFileType = "txt";
                    equiType = "AOI";
                    SPITimer.Stop();
                    break;
                case 3:
                    currFileType = "csv";
                    equiType = "印刷机";
                    SPITimer.Stop();
                    break;
                case 4:
                    currFileType = "xml";
                    equiType = "贴片机";
                    SPITimer.Stop();
                    break;
                case 5:
                    currFileType = "xml";
                    equiType = "贴片机";
                    SPITimer.Stop();
                    break;
            }

            if (Device.SelectedIndex == 4 || Device.SelectedIndex == 2 || Device.SelectedIndex == 5)
            {
                txtPath.Text = fileList[Device.SelectedIndex];
                ma_code.Text = "";
                ma_code.Enabled = false;
                txtPath.Focus();
                txtPath.SelectAll();
                return;
            }
            //if (string.IsNullOrEmpty(ma_code.Text))
            //{
            //    Device.SelectedIndex = -1;
            //    txtPath.Text = "";
            //    MessageBox.Show(this.ParentForm, "请选择工单", "提示");
            //    return;
            //}

            txtPath.Text = fileList[Device.SelectedIndex];
            txtPath.Focus();
            txtPath.SelectAll();
            ma_code.Enabled = true;
            txtPath.Enabled = false;
        }

        private void Choose_Click(object sender, EventArgs e)
        {
            FolderBrowserDialog dialog = new FolderBrowserDialog();
            switch (Device.SelectedIndex)
            {
                case 0:
                    dialog.Description = "请选择读取劲拓SPI设备文件夹";
                    currFileType = "txt";
                    equiType = "SPI";
                    break;
                case 1:
                    dialog.Description = "请选择读取思泰克SPI设备文件夹";
                    currFileType = "csv";
                    equiType = "SPI";
                    break;
                case 2:
                    dialog.Description = "请选择读取AOI设备文本文件";
                    currFileType = "txt";
                    equiType = "AOI";
                    break;
                case 3:
                    dialog.Description = "请选择读取印刷机设备的文本文件夹";
                    currFileType = "csv";
                    equiType = "印刷机";
                    break;
                case 4:
                    dialog.Description = "请选择读取贴片机的文本文件夹";
                    currFileType = "xml";
                    equiType = "贴片机";
                    break;
                case 5:
                    dialog.Description = "请选择读取JUKI贴片机的文本文件夹";
                    currFileType = "xml";
                    equiType = "贴片机";
                    break;
            }
            if (dialog.ShowDialog() == DialogResult.OK)
            {
                txtPath.Text = dialog.SelectedPath;
                txtPath.Enabled = false;
                Device.Enabled = false;
                watcher.EnableRaisingEvents = false;
            }
        }

        private void claerBtn_Click(object sender, EventArgs e)
        {
            lstFiles.Items.Clear();
        }
        private void allParse_Click(object sender, EventArgs e)
        {
            if (Device.SelectedIndex == 0 || Device.SelectedIndex == 1 || Device.SelectedIndex == 3)
            {
                if (string.IsNullOrEmpty(ma_code.Text))
                {
                    MessageBox.Show(this.ParentForm, "请选择工单", "提示");
                    return;
                }
            }
            if (Device.SelectedIndex == -1)
            {
                Device.Focus();
                Device.SelectAll();
                MessageBox.Show(this.ParentForm, "请选择设备", "提示");
                return;
            }
            if (String.IsNullOrEmpty(txtPath.Text))
            {
                txtPath.Focus();
                txtPath.SelectAll();
                return;
            }
            string[] txtFiles = Directory.GetFiles(txtPath.Text, $"*.{currFileType}");
            if (txtFiles.Length == 0)
            {
                LogMessage($"当前{txtPath.Text},没有{equiType}设备输出的{currFileType.ToLower()}文件");
                return;
            }
            RefreshFileList();
        }

        private void onWatch_Click(object sender, EventArgs e)
        {
            if (Device.SelectedIndex == 0 || Device.SelectedIndex == 1 || Device.SelectedIndex == 3)
            {
                if (string.IsNullOrEmpty(ma_code.Text))
                {
                    MessageBox.Show(this.ParentForm, "请选择工单", "提示");
                    return;
                }
            }
            if (Device.SelectedIndex == -1)
            {
                Device.Focus();
                Device.SelectAll();
                MessageBox.Show(this.ParentForm, "请选择设备", "提示");
                return;
            }
            if (String.IsNullOrEmpty(txtPath.Text))
            {
                txtPath.Focus();
                txtPath.SelectAll();
                return;
            }
            try
            {
                #region
                /* 识别文件类型
                var txtFiles = Directory.GetFiles(txtPath.Text, "*.txt");
                var csvFiles = Directory.GetFiles(txtPath.Text, "*.csv");
                currFileType = txtFiles.Length > csvFiles.Length ? "txt" : "csv";
                watcher.Filter = $"*.{currFileType}";*/
                #endregion
                watcher.Path = txtPath.Text;
                watcher.Filter = $"*.{currFileType}";

                if (onWatch.Text == "开启解析")
                {
                    watcher.EnableRaisingEvents = true;
                    onWatch.Text = "关闭解析";

                    if (Device.SelectedIndex == 5) // JUKI贴片机
                    {
                        formsTimer.Start();
                    }
                }
                else
                {
                    watcher.EnableRaisingEvents = false;
                    //watcher.Dispose();
                    onWatch.Text = "开启解析";
                    formsTimer.Stop();
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(this.ParentForm, ex.Message, "警告");
            }
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            try
            {
                sql.Clear();
                sql.Append($@"SELECT dd_date,dd_name,dd_status,dd_id FROM devicedata WHERE dd_status = 0");
                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                if (dt.Rows.Count > 0)
                {
                    string currentDate = DateTime.Now.ToString("yyyyMMddHHmmss");
                    string currentDate1 = DateTime.Now.ToString("yyyy-MM-dd");
                    XmlWriterSettings settings = new XmlWriterSettings
                    {
                        Indent = true
                        //,Encoding = System.Text.Encoding.UTF8
                    };
                    foreach (DataRow dr in dt.Rows)
                    {
                        #region
                        /*var hasFileAry = Directory.GetFiles(outXmlFilePath, $"*.{currFileType}");
                        string xmlName;
                        if (hasFileAry.Length > 0)
                        {
                            var lastFile = Directory.GetFiles(outXmlFilePath).Select(f => new FileInfo(f))
                                            .Where(f => f.CreationTime.Date == DateTime.Today)
                                            .OrderByDescending(f => f.CreationTime).FirstOrDefault().Name;

                            string seqNumStr = lastFile.Substring(lastFile.Length - 7, 3);
                            string fileSeqNum = (int.Parse(seqNumStr) + 1).ToString().PadLeft(seqNumStr.Length, '0'); ;
                            xmlName = $"1.08_{currentDate}_{currentDate}{fileSeqNum}__RequestTotalProduction.xml";
                        }
                        else
                        {
                            xmlName = $"1.08_{currentDate}_{currentDate}001__RequestTotalProduction.xml";
                        }*/
                        #endregion
                        string xmlName = $"1.08__{currentDate1}T101505_{currentDate}001__RequestTotalProduction.xml";
                        string fullPath = Path.Combine(outXmlFilePath, xmlName);

                        using (XmlWriter writer = XmlWriter.Create(fullPath, settings))
                        {
                            writer.WriteStartDocument();
                            writer.WriteStartElement("RequestTotalProductionInfo");
                            writer.WriteAttributeString("MachineName", dr["dd_name"].ToString());
                            writer.WriteEndElement();
                            writer.WriteEndDocument();
                        }

                        sql.Clear();
                        sql.Append($"UPDATE devicedata SET dd_status = -1 WHERE dd_name = '{dr["dd_name"].ToString()}' and dd_status = 0");
                        dh.ExecuteSql(sql.GetString(), "update");
                    }
                }
            }
            catch (Exception ex)
            {
                LogMessage($"写入指令文件异常: {ex.Message}");
            }
        }

        private void SPITimer_Tick(object sender, EventArgs e)
        {
            try
            {
                sql.Clear();
                sql.Append($"SELECT dl_macode FROM deviceline WHERE dl_type = 'SMT' AND dl_linecode = '{User.UserLineCode}'");
                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                if (dt.Rows.Count > 0 && !String.IsNullOrEmpty(dt.Rows[0]["dl_macode"].ToString()))
                {
                    ma_code.Text = dt.Rows[0]["dl_macode"].ToString().Trim();
                    return;
                }

                sql.Clear();
                sql.Append($"SELECT dl_macode FROM deviceline WHERE dl_linecode = '{User.UserLineCode}' AND dl_type IS NULL");
                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                if (dt.Rows.Count > 0 && !String.IsNullOrEmpty(dt.Rows[0]["dl_macode"].ToString()))
                {
                    ma_code.Text = dt.Rows[0]["dl_macode"].ToString().Trim();
                }
            }
            catch (Exception ex)
            {
                LogMessage($"SPI自动识别生产工单Error: {ex.Message}");
            }
        }

        private void OnFileCreated(object sender, FileSystemEventArgs e)
        {
            if (Device.SelectedIndex == 0 && string.IsNullOrEmpty(ma_code.Text))
            {
                Device.SelectedIndex = -1;
                txtPath.Text = "";
                MessageBox.Show(this.ParentForm, "请选择工单", "提示");
                return;
            }

            RefreshFileList();
        }

        private void OnFileChanged(object sender, FileSystemEventArgs e)
        {
            if (e.ChangeType == WatcherChangeTypes.Changed)
            {
                RefreshFileList();
            }
        }

        private void RefreshFileList()
        {
            if (lstFiles.InvokeRequired)
            {
                lstFiles.Invoke(new Action(RefreshFileList));
                lstFiles.BeginInvoke(new Action(RefreshFileList));
                return;
            }

            try
            {
                if (!Directory.Exists(txtPath.Text))
                {
                    LogMessage($"目录不存在: {txtPath.Text}");
                    return;
                }

                string[] txtFiles = Directory.GetFiles(txtPath.Text, $"*.{currFileType}");
                if (txtFiles.Length == 0)
                {
                    return;
                }
                else
                {
                    foreach (string file in txtFiles)
                    {
                        if (!File.Exists(file))
                        {
                            LogMessage($"文件不存在: {file}");
                        }

                        string outFileMsg = CheckFileAccess(file);
                        if (outFileMsg != "OK")
                        {
                            LogMessage(outFileMsg);
                            continue;
                        }

                        if (Device.SelectedIndex == 0) // 劲拓SPI
                        {
                            ParseLogInsert(file);
                        }
                        else if (Device.SelectedIndex == 1) // 思泰克SPI
                        {
                            string fileName = Path.GetFileName(file);
                            string[] lines = File.ReadAllLines(file, Encoding.GetEncoding("GB2312"));

                            //string modelName = lines[1].Split(',')[0];
                            //string lineNumber = lines[1].Split(',')[1];
                            //string boardStatus = lines[2].Split(',')[1];
                            SN = lines[4].Split(',')[16];
                            if (string.IsNullOrEmpty(SN))
                            {
                                LogMessage($"文件: {file},无SN信息");
                                continue;
                            }
                            
                            if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, SN, User.UserCode, out omakeCode, out oMsid, out oErrorMessage))
                            {
                                if (LogicHandler.SetStepResult(omakeCode, User.UserSourceCode, SN, "日志解析", "OK", User.UserCode, out oErrorMessage))
                                {
                                    string sqlStr = $@"select ma_code,nvl(mcd_okqty,0) mcd_okqty,ma_prodcode,pr_detail,ma_qty - nvl(mcd_okqty, 0) remain_qty 
                                        from make left join makecraftdetail on mcd_maid=ma_id left join product on pr_code = ma_prodcode 
                                        where ma_code='" + omakeCode + "' and mcd_stepcode='" + User.CurrentStepCode + "'";
                                    dt = (DataTable)dh.ExecuteSql(sqlStr, "select");
                                    BaseUtil.SetFormValue(Controls, dt);
                                    //记录操作日志
                                    LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ma_code.Text, User.UserLineCode, User.UserSourceCode, "日志解析", "日志解析成功", SN, "");
                                    LogMessage($"处理过站成功");
                                }
                                else
                                {
                                    LogMessage($"处理过站error:{oErrorMessage}");
                                }
                            }
                            else
                            {
                                LogMessage($"处理过站核对error:{oErrorMessage}");
                            }

                            LogMessage($"文件: {file},开始上传");
                            if (UploadFileToFtp(file))
                            {
                                /*dh.ExecuteSql($@"insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class,std_testresult) 
                                                    select STEPTESTDETAIL_seq.nextval,'{SN}','{ma_code.Text}',sysdate,'思泰克SPI',
                                                    'http://112.48.67.154:8088/ftp/mes/TestData/{DateTime.Now.ToString("yyyyMMdd")}/{Path.GetFileName(file)}' from dual", "insert");*/
                                dh.ExecuteSql($@"insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class,std_testresult) 
                                                    select STEPTESTDETAIL_seq.nextval,'{SN}','{ma_code.Text}',sysdate,'思泰克SPI',
                                                    'http://192.168.1.92:8088/ftp/mes/TestData/{DateTime.Now.ToString("yyyyMMdd")}/{Path.GetFileName(file)}' from dual", "insert");
                                string xmlContent = File.ReadAllText(file);
                                if (ConsoleLog(xmlContent, file))
                                {
                                    File.Delete(file);
                                }
                            }
                            #region // 20250630 M 调整对接方式 
                            /*List<SpiData> csvData; 
                            //csvData = ParseCsvFile(file);
                            csvData = ParseCsvFile<SpiData>(file, MapToSpiData);

                            List<string> Barcode = new List<string>();
                            List<string> Date = new List<string>();

                            List<string> AreaPercent = new List<string>();
                            List<string> Height = new List<string>();
                            List<string> VolumePercent = new List<string>();
                            List<string> XOffset = new List<string>();
                            List<string> YOffset = new List<string>();
                            List<string> PadSizeX = new List<string>();
                            List<string> PadSizeY = new List<string>();
                            List<string> Area = new List<string>();
                            List<string> HeightPercent = new List<string>();
                            List<string> Volume = new List<string>();
                            List<string> Result = new List<string>();

                            foreach (var item in csvData)
                            {
                                Barcode.Add(item.Barcode);
                                Date.Add(item.Date);
                                Result.Add(item.Result);

                                AreaPercent.Add(item.AreaPercent);
                                Height.Add(item.Height);
                                VolumePercent.Add(item.VolumePercent);
                                XOffset.Add(item.XOffset);
                                YOffset.Add(item.YOffset);
                                PadSizeX.Add(item.PadSizeX);
                                PadSizeY.Add(item.PadSizeY);
                                Area.Add(item.Area);
                                HeightPercent.Add(item.HeightPercent);
                                Volume.Add(item.Volume);
                            }

                            if (csvData.Count == 0)
                            {
                                LogMessage($"文件: {file}，读取记录 {csvData.Count} 条");
                                return;
                            }

                            sql.Clear();
                            sql.Append($@"INSERT INTO steptestdetail (std_id,std_sn,std_makecode,
                                                    std_testresult,std_class,std_actualvalue,
                                                    std_rescode,STD_SUBCLASS1,STD_VALUE1,
                                                    STD_VALUE2,STD_VALUE3,STD_VALUE4,
                                                    STD_VALUE5,STD_VALUE6,STD_VALUE7,
                                                    STD_VALUE8,STD_VALUE9,STD_VALUE10)
                                                    (select steptestdetail_seq.nextval,:Barcode,'{ma_code.Text}',
                                                    :Result,'{equiType}','notfound',
                                                    '{User.UserSourceCode}','{equiType}',:AreaPercent,
                                                    :Height,:VolumePercent,:XOffset,
                                                    :YOffset,:PadSizeX,:PadSizeY,
                                                    :Area,:HeightPercent,:Volume from dual)");

                            dh.BatchInsert(sql.GetString(),
                                new string[] { "Barcode", "Result", "AreaPercent",
                                        "Height" ,"VolumePercent","XOffset",
                                        "YOffset","PadSizeX","PadSizeY",
                                        "Area","HeightPercent","Volume"},
                                Barcode.ToArray(), Result.ToArray(), AreaPercent.ToArray(),
                                Height.ToArray(), VolumePercent.ToArray(), XOffset.ToArray(),
                                YOffset.ToArray(), PadSizeX.ToArray(), PadSizeY.ToArray(),
                                Area.ToArray(), HeightPercent.ToArray(), Volume.ToArray());


                            LogMessage($"文件: {file},共{csvData.Count}条记录,已解析");

                            string xmlContent = File.ReadAllText(file);
                            if (ConsoleLog(xmlContent, file))
                            {
                                File.Delete(file);
                            }*/
                            #endregion
                        }
                        else if (Device.SelectedIndex == 2) // AOI
                        {
                            ParseLogInsert(file);
                        }
                        else if (Device.SelectedIndex == 3) // 印刷机 ?
                        {
                            List<PrintData> priMacData;
                            priMacData = ParseCsvFile<PrintData>(file, MapToPriMacData);

                            List<string> BarCode = new List<string>();
                            List<string> TimeStamp = new List<string>();
                            List<string> FileName = new List<string>();
                            List<string> ProgramRunning = new List<string>();

                            List<string> CycleTime = new List<string>();
                            List<string> DSPIResult_2 = new List<string>();
                            List<string> PrintSpeed = new List<string>();
                            List<string> FrontSQGPress = new List<string>();
                            List<string> RearSQGPress = new List<string>();
                            List<string> PrintMode = new List<string>();

                            List<string> SnapOffDistance = new List<string>();
                            List<string> SnapOffSpeed = new List<string>();
                            List<string> SnapOffDelay = new List<string>();
                            List<string> SQGUpSpeed = new List<string>();
                            List<string> SQGDownSpeed = new List<string>();
                            List<string> SQGUpFirst = new List<string>();
                            List<string> SQGHeightAtSnapOff = new List<string>();
                            List<string> CleaningAfterLastBoard = new List<string>();
                            List<string> CleaningFrequency = new List<string>();
                            List<string> CleaningSpeed = new List<string>();

                            List<string> CleaningType = new List<string>();
                            List<string> AddSPMode = new List<string>();

                            List<string> PrintDirection = new List<string>();
                            List<string> PCBSize = new List<string>();
                            List<string> TableUpX = new List<string>();
                            List<string> TableUpY1 = new List<string>();
                            List<string> TableUpY2 = new List<string>();

                            foreach (var item in priMacData)
                            {
                                BarCode.Add(item.BarCode);
                                TimeStamp.Add(item.TimeStamp);
                                FileName.Add(item.FileName);
                                ProgramRunning.Add(item.ProgramRunning);

                                CycleTime.Add(item.CycleTime);
                                DSPIResult_2.Add(item._2DSPIResult);
                                PrintSpeed.Add(item.PrintSpeed);
                                FrontSQGPress.Add(item.FrontSQGPress);
                                RearSQGPress.Add(item.RearSQGPress);
                                PrintMode.Add(item.PrintMode);

                                SnapOffDistance.Add(item.SnapOffDistance);
                                SnapOffSpeed.Add(item.SnapOffSpeed);
                                SnapOffDelay.Add(item.SnapOffDelay);
                                SQGUpSpeed.Add(item.SQGUpSpeed);
                                SQGDownSpeed.Add(item.SQGDownSpeed);
                                SQGUpFirst.Add(item.SQGUpFirst);
                                SQGHeightAtSnapOff.Add(item.SQGHeightAtSnapOff);
                                CleaningAfterLastBoard.Add(item.CleaningAfterLastBoard);
                                CleaningFrequency.Add(item.CleaningFrequency);
                                CleaningSpeed.Add(item.CleaningSpeed);

                                CleaningType.Add(item.CleaningType);
                                AddSPMode.Add(item.AddSPMode);

                                PrintDirection.Add(item.PrintDirection);
                                PCBSize.Add(item.PCBSize);
                                TableUpX.Add(item.TableUpX);
                                TableUpY1.Add(item.TableUpY1);
                                TableUpY2.Add(item.TableUpY2);
                            }
                            if (priMacData.Count == 0)
                            {
                                LogMessage($"文件: {file}，读取记录 {priMacData.Count} 条");
                                continue;
                            }

                            sql.Clear();
                            sql.Append($@"INSERT INTO steptestdetail (std_id,std_sn,std_makecode,STD_TESTTIME,STD_CLASS,STD_SUBCLASS1,
                                            STD_SUBCLASS2,STD_SUBCLASS3,STD_VALUE1,STD_VALUE2,STD_VALUE3,STD_VALUE4,
                                            STD_VALUE5,STD_VALUE6,STD_VALUE7,STD_VALUE8,STD_VALUE9,
                                            STD_VALUE10,STD_VALUE11,std_value12,std_value13,std_value14,
                                            std_value15,std_value16,
                                            STD_TESTRESULT,std_value18,std_value19,std_value20,std_value21,
                                            std_rescode)
                                            (select steptestdetail_seq.nextval,:BarCode,'{ma_code.Text}',to_date(:TimeStamp,'yyyy-mm-dd hh24:mi:ss'),'印刷机',:ProgramRunning,
                                            :CycleTime,:DSPIResult2,:PrintSpeed,:FrontSQGPress,:RearSQGPress,:PrintMode,
                                            :SnapOffDistance,:SnapOffSpeed,:SnapOffDelay,:SQGUpSpeed,:SQGDownSpeed,
                                            :SQGUpFirst,:SQGHeightAtSnapOff,:CleaningAfterLastBoard,:CleaningFrequency,:CleaningSpeed,
                                            :CleaningType,:AddSPMode,
                                            :PrintDirection,:PCBSize,:TableUpX,:TableUpY1,:TableUpY2,
                                            '{User.UserSourceCode}' from dual)");

                            dh.BatchInsert(sql.GetString(),
                                new string[] { "BarCode", "TimeStamp","ProgramRunning",
                                    "CycleTime","DSPIResult_2","PrintSpeed","FrontSQGPress","RearSQGPress","PrintMode",
                                    "SnapOffDistance","SnapOffSpeed","SnapOffDelay","SQGUpSpeed","SQGDownSpeed",
                                    "SQGUpFirst","SQGHeightAtSnapOff","CleaningAfterLastBoard","CleaningFrequency","CleaningSpeed",
                                    "CleaningType","AddSPMode",
                                    "PrintDirection","PCBSize","TableUpX","TableUpY1","TableUpY2"},
                                BarCode.ToArray(), TimeStamp.ToArray(), ProgramRunning.ToArray(),
                                CycleTime.ToArray(), DSPIResult_2.ToArray(), PrintSpeed.ToArray(), FrontSQGPress.ToArray(), RearSQGPress.ToArray(), PrintMode.ToArray(),
                                SnapOffDistance.ToArray(), SnapOffSpeed.ToArray(), SnapOffDelay.ToArray(), SQGUpSpeed.ToArray(), SQGDownSpeed.ToArray(),
                                SQGUpFirst.ToArray(), SQGHeightAtSnapOff.ToArray(), CleaningAfterLastBoard.ToArray(), CleaningFrequency.ToArray(), CleaningSpeed.ToArray(),
                                CleaningType.ToArray(), AddSPMode.ToArray(),
                                PrintDirection.ToArray(), PCBSize.ToArray(), TableUpX.ToArray(), TableUpY1.ToArray(), TableUpY2.ToArray());

                            LogMessage($"文件: {file},共{priMacData.Count}条记录,已解析");
                            string xmlContent = File.ReadAllText(file);
                            if (ConsoleLog(xmlContent, file))
                            {
                                File.Delete(file);
                            }
                        }
                        else if (Device.SelectedIndex == 4 || Device.SelectedIndex == 5) // 贴片机
                        {
                            if (Device.SelectedIndex == 5 && !file.Contains("TotalProduction"))
                            {
                                continue;
                            }
                            string xmlContent = File.ReadAllText(file);
                            var xmlList = ParseXml(xmlContent);
                            if (xmlList.Count == 0)
                            {
                                LogMessage($"文件: {file}，读取记录 {xmlList.Count} 条");
                                continue;
                            }

                            List<string> param = new List<string>() { };
                            string PS_CODE = "";
                            LogicHandler.GetSerialNumByCaller("Make!ParseLog", out PS_CODE);
                            List<string> MachineName = new List<string>();
                            List<string> Part = new List<string>();
                            List<string> Station = new List<string>();
                            List<string> ReelNo = new List<string>();
                            List<string> letNo = new List<string>();

                            string Part_ = "",Side_="";
                            int letNoNum = 0;
                            
                            try
                            {
                                foreach (var item in xmlList)
                                {
                                    MachineName.Add(item.MachineName);
                                    Part_ = item.Part.Split('.')[0].Split('-')[0];
                                    Side_ = item.Part.Split('.')[0].Split('-')[1];
                                    Station.Add(item.Station);
                                    ReelNo.Add(item.ReelNo);
                                    letNo.Add((++letNoNum).ToString());
                                }
                            }
                            catch (Exception ex) 
                            {
                                LogMessage($"Error: 解析文件列表失败: 文件格式无面别信息,{ex.Message}");
                                if (ConsoleLog(xmlContent, file))
                                {
                                    File.Delete(file);
                                }
                            }

                            string ps_id = "";
                            string lineId = dh.getFieldDataByCondition("smtlocationinto", "SLI_LANE", "SLI_MCNO='" + MachineName[0] + "'").ToString();

                            if (!dh.CheckExist("productsmt", "ps_prodcode='" + Part_ + "' and PS_LINECODE = '"+ lineId  + "'"))
                            {
                                ps_id = dh.GetSEQ("productsmt_seq");
                                /*dh.ExecuteSql("insert into productsmt(ps_id,ps_prodcode,ps_status,ps_statuscode,PS_LINECODE,PS_CODE,PS_TABLE,PS_INDATE,PS_AUDITDATE)" +
                                    "values('" + ps_id + "','" + Part_ + "','在录入','ENTERING','" + lineId + "','" + PS_CODE + "','A',SYSDATE,SYSDATE)", "insert");*/

                                dh.ExecuteSql("insert into productsmt(ps_id,ps_prodcode,ps_status,ps_statuscode,PS_LINECODE,PS_CODE,PS_TABLE,PS_INDATE,PS_AUDITDATE,PS_AUDITMAN)" +
                                    "values('" + ps_id + "','" + Part_ + "','已审核','AUDITED','" + lineId + "','" + PS_CODE + "','"+ Side_ + "',SYSDATE,SYSDATE,'"+ User.UserName +"')", "insert");
                            }
                            else
                            {
                                ps_id = dh.getFieldDataByCondition("productsmt", "ps_id", "ps_prodcode='" + Part_ + "' and PS_LINECODE = '"+ lineId  + "'").ToString();
                            }
                            if (dh.getRowCount("productsmtlocation", "PSL_PSID='" + ps_id +"'") > 0)
                            {
                                dh.ExecuteSql("delete from productsmtlocation where PSL_PSID = '" + ps_id +"'", "delete");
                            }
                            sql.Clear();
                            sql.Append("insert into productsmtlocation(PSL_ID, PSL_PSID, PSL_DETNO, PSL_PRODCODE, PSL_REPCODE, PSL_LOCATION, PSL_BASEQTY, PSL_TABLE)" +
                                "select productsmtlocation_seq.nextval,'" + ps_id + "',:letArr, :ReelNo,:ReelNo,:Station,BD_BASEQTY,'"+ Side_ + "' from bom@ERP " +
                                "left join bomdetail@ERP on bo_id=bd_bomid where bo_mothercode='" + Part_ + "' and BD_SONCODE=:ReelNo");
                            dh.BatchInsert(sql.GetString(), new string[] { "letArr", "ReelNo", "ReelNo", "Station", "ReelNo" },
                                letNo.ToArray(), ReelNo.ToArray(), ReelNo.ToArray(), Station.ToArray(), ReelNo.ToArray());

                            LogMessage($"文件: {file},已解析生成站位表");

                            if (ConsoleLog(xmlContent, file))
                            {
                                File.Delete(file);
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                LogMessage($"Error: 解析文件列表失败: {ex.Message}");
            }
        }

        public bool UploadFileToFtp(string localFilePath)
        {
            /*string ftpServer = "ftp://10.8.0.208:21/mes/TestData/";*/
            string ftpServer = "ftp://192.168.1.92:21/mes/TestData/";
            string username = "vsftpd";
            string password = "vsftpd3cd79018fl";

            string currentDate = DateTime.Now.ToString("yyyyMMdd");

            string ftpFullPath = $"{ftpServer.TrimEnd('/')}/{currentDate}";
            string outResult = CreateFtpDirectoryIfNotExists(ftpFullPath, username, password);
            if (outResult.Substring(0, 2) == "NG")
            {
                LogMessage(outResult);
                return false;
            }

            string remoteFileName = Path.GetFileName(localFilePath);
            string uri = $"{ftpFullPath}/{remoteFileName}";

            try
            {
                var request = (FtpWebRequest)WebRequest.Create(uri);
                request.Method = WebRequestMethods.Ftp.UploadFile;
                request.Credentials = new NetworkCredential(username, password);
                request.UsePassive = true;
                request.UseBinary = true;
                request.KeepAlive = false;

                using (var fileStream = File.OpenRead(localFilePath))
                using (var requestStream = request.GetRequestStream())
                {
                    byte[] buffer = new byte[4096];
                    int bytesRead;
                    while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) > 0)
                    {
                        requestStream.Write(buffer, 0, bytesRead);
                    }
                }

                using (var response = (FtpWebResponse)request.GetResponse())
                {
                    LogMessage($"文件: {localFilePath}上传成功,状态{response.StatusDescription}");
                    return true;
                }
            }
            catch (WebException ex)
            {
                if (ex.Response is FtpWebResponse response)
                {
                    LogMessage($"FTP 错误码: {(int)response.StatusCode} - {response.StatusDescription}");
                }
                else
                {
                    LogMessage("Web异常: " + ex.Message);
                }
                return false;
            }
            catch (Exception ex)
            {
                LogMessage($"上传失败: " + ex.Message);
                return false;
            }
        }

        private string CreateFtpDirectoryIfNotExists(string ftpDirectoryPath, string username, string password)
        {
            try
            {
                FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpDirectoryPath);
                request.Method = WebRequestMethods.Ftp.MakeDirectory;
                request.Credentials = new NetworkCredential(username, password);
                request.UsePassive = true;
                request.UseBinary = true;
                request.KeepAlive = false;

                using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
                {
                    response.Close();
                    return "OK,目录创建成功: " + response.StatusDescription;
                }
            }
            catch (WebException ex)
            {
                if (ex.Response is FtpWebResponse response && response.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
                {
                    return "OK,目录已存在: " + response.StatusDescription;
                }
                else
                {
                    return "NG,创建目录时发生错误: " + ex.Message;
                }
            }
        }

        private void ParseLogInsert(string PathName)
        {
            try
            {
                StreamReader SR = File.OpenText(PathName);
                string restOfStream = SR.ReadToEnd();
                SR.Close();
                SR.Dispose();

                List<Log> logArr = new List<Log>() { };
                string[] lines = restOfStream.Split(new string[] { "\r\n" }, StringSplitOptions.None);
                int fileNum = string.IsNullOrEmpty(lines[lines.Length - 1]) ? lines.Length - 1 : lines.Length;
                foreach (var item in lines)
                {
                    if (string.IsNullOrEmpty(item)) continue;
                    string[] currItem = item.Split(',');
                    string res = "",wo = "",detail = "",line = "",sn = "";
                    sn = currItem[0];
                    if (string.IsNullOrEmpty(sn))
                    {
                        sn = Path.GetFileNameWithoutExtension(PathName);
                    }

                    if (equiType == "SPI")
                    {
                        res = currItem[1];
                        wo = ma_code.Text;
                        detail = currItem[1];
                        line = User.UserLineCode;
                    }
                    else if (equiType == "AOI")
                    {
                        if(currItem.Length > 3)
                        {
                            res = currItem[3];
                            detail = currItem[3];
                        }

                        if(string.IsNullOrEmpty(res) && string.IsNullOrEmpty(detail))
                        {
                            res = currItem[1];
                            detail = currItem[1];
                        }

                        sql.Clear();
                        sql.Append($"SELECT a.ms_linecode, a.ms_makecode FROM makeserial a WHERE a.ms_sncode = '{currItem[0]}'");
                        dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                        if (dt.Rows.Count > 0 && !String.IsNullOrEmpty(dt.Rows[0]["ms_linecode"].ToString()))
                        {
                            wo = dt.Rows[0]["ms_makecode"].ToString();
                            line = dt.Rows[0]["ms_linecode"].ToString();
                        }

                        if(string.IsNullOrEmpty(wo) && string.IsNullOrEmpty(line))
                        {
                            sql.Clear();
                            sql.Append($"SELECT a.li_code,b.dl_macode,c.sc_name FROM line_ipaoi a,deviceline b,source c WHERE a.ipaddress = '{currItem[2]}' AND a.li_code = b.dl_linecode AND a.li_code = c.sc_linecode AND c.sc_wccode = 'SMT' AND instr(c.sc_name, 'AOI') > 0 AND b.dl_type = 'SMT'");
                            dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                            if (dt.Rows.Count > 0 && !String.IsNullOrEmpty(dt.Rows[0]["dl_macode"].ToString()))
                            {
                                wo = dt.Rows[0]["dl_macode"].ToString();
                                line = dt.Rows[0]["li_code"].ToString();
                            }
                        }
                    }
                    Log itemLog = new Log()
                    {
                        SN = sn,
                        Work_order = wo,
                        Line = line,
                        Source = User.UserSourceCode,
                        Result = res,
                        Details = detail
                    };
                    logArr.Add(itemLog);

                }
                if (InsertDb(logArr, PathName, fileNum))
                {
                    if (ConsoleLog(restOfStream, PathName))
                    {
                        File.WriteAllText(PathName, string.Empty);
                        File.Delete(PathName);
                    }
                }
            }
            catch (Exception ex)
            {
                LogMessage($"Error: 文件 {PathName}, {ex.Message}");
            }
        }

        private bool InsertDb(List<Log> logs, string PathName,int fileNum)
        {
            try
            {
                StringBuilder sql = new StringBuilder();
                List<string> param = new List<string>() { };
                foreach (var item in logs)
                {
                    string ishave_sn = "";
                    sql.Clear();
                    sql.Append($"SELECT b.pr_tm_user FROM make a, product b, makeserial c WHERE a.ma_code = c.ms_makecode AND a.ma_prodcode = b.pr_code AND c.ms_sncode = '{item.SN}'");
                    dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
                    if (dt.Rows.Count > 0)
                    {
                        ishave_sn = dt.Rows[0]["pr_tm_user"].ToString().Trim();
                    }

                    if (string.IsNullOrEmpty(ishave_sn))
                    {
                        sql.Clear();
                        sql.Append($"SELECT b.pr_tm_user FROM make a, product b WHERE a.ma_code = '{item.Work_order}' AND a.ma_prodcode = b.pr_code");
                        dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
                        if (dt.Rows.Count > 0)
                        {
                            ishave_sn = dt.Rows[0]["pr_tm_user"].ToString().Trim();
                        }
                    }

                    if (ishave_sn == "是")
                    {
                        if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, item.SN, User.UserCode, out omakeCode, out oMsid, out oErrorMessage))
                        {
                            if (LogicHandler.SetStepResult(omakeCode, User.UserSourceCode, item.SN, "日志解析", "OK", User.UserCode, out oErrorMessage))
                            {
                                string sqlStr = $@"select ma_code,nvl(mcd_okqty,0) mcd_okqty,ma_prodcode,pr_detail,ma_qty - nvl(mcd_okqty, 0) remain_qty 
                                        from make left join makecraftdetail on mcd_maid=ma_id left join product on pr_code = ma_prodcode 
                                        where ma_code='" + omakeCode + "' and mcd_stepcode='" + User.CurrentStepCode + "'";
                                dt = (DataTable)dh.ExecuteSql(sqlStr, "select");
                                BaseUtil.SetFormValue(Controls, dt);
                                //记录操作日志
                                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ma_code.Text, User.UserLineCode, User.UserSourceCode, "日志解析", "日志解析成功", item.SN, "");

                                param.Add(item.SN);
                                param.Add(omakeCode);
                                param.Add(item.Result == "PASS" ? "OK" : "NG");
                                param.Add(equiType);
                                param.Add(item.Details);
                                param.Add(User.UserCode);
                                param.Add(item.Source);
                                param.Add(item.Line);
                                string res = "";
                                param.Add(res);
                                string[] paramList = param.ToArray();
                                dh.CallProcedure("cs_insert_testrejects", ref paramList);
                                param.Clear();
                                LogMessage($"文件: {PathName},共{fileNum}条记录已过站解析");

                                if (logs.IndexOf(item) == logs.Count - 1)
                                {
                                    return true;
                                }
                            }
                            else
                            {
                                LogMessage($"处理过站NG:{oErrorMessage}");
                                break;
                            }
                        }
                        else
                        {
                            LogMessage($"过站核对NG:{oErrorMessage}");
                            break;
                        }
                    }
                    else
                    {
                        param.Add(item.SN);
                        param.Add(item.Work_order);
                        param.Add(item.Result == "PASS" ? "OK" : "NG");
                        param.Add(equiType);
                        param.Add(item.Details);
                        param.Add(User.UserCode);
                        param.Add(item.Source);
                        param.Add(item.Line);
                        string res = "";
                        param.Add(res);
                        string[] paramList = param.ToArray();
                        dh.CallProcedure("cs_insert_testrejects", ref paramList);
                        param.Clear();
                        LogMessage($"文件: {PathName},共{fileNum}条记录已解析");

                        if (logs.IndexOf(item) == logs.Count - 1)
                        {
                            return true;
                        }
                    }
                    
                }
                return false;
            }
            catch (Exception ex)
            {
                LogMessage($"处理解析写入error:{ex.Message}");
                return false;
            }
        }

        private bool ConsoleLog(string Content, string PathName)
        {
            try
            {
                string sourceDir = Path.GetDirectoryName(PathName);
                string newFolderName = "Logs";
                string newFolderPath = Path.Combine(sourceDir, newFolderName);

                if (!Directory.Exists(newFolderPath))
                {
                    Directory.CreateDirectory(newFolderPath);
                }
                string newFileName = "Log_" + Path.GetFileName(PathName);
                string newFilePath = Path.Combine(newFolderPath, newFileName);

                File.AppendAllText(newFilePath, Content + Environment.NewLine);
                return true;
            }
            catch (Exception ex)
            {
                MessageBox.Show(this.ParentForm, ex.Message, "警告");
                return false;
            }
        }

        private void LogMessage(string message)
        {
            if (lstFiles.InvokeRequired)
            {
                lstFiles.Invoke(new Action<string>(LogMessage), message);
                return;
            }
            lstFiles.Items.Add($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] {message}");
            lstFiles.TopIndex = lstFiles.Items.Count - 1;
        }

        public List<MachineList> ParseXml(string xmlContent)
        {
            List<MachineList> result = new List<MachineList>();
            try
            {
                XmlDocument xmlDoc = new XmlDocument();
                xmlDoc.LoadXml(xmlContent);

                XmlNode machineNode = xmlDoc.SelectSingleNode("//TotalProductionInfo");
                string machineName = machineNode?.Attributes["MachineName"]?.Value ?? "Unknown";
                string part = machineNode?.Attributes["ProductionProgramName"]?.Value ?? "Unknown";

                XmlNodeList feederNodes = xmlDoc.SelectNodes("//FeederProductionManageInfo");
                foreach (XmlNode feederNode in feederNodes)
                {
                    MachineList machineList = new MachineList();
                    string feederBankPosition = feederNode.Attributes["FeederBankPosition"]?.Value ?? "Unknown";
                    string holeNo = feederNode.Attributes["HoleNo"]?.Value ?? "Unknown";
                    string componentName = feederNode.Attributes["ComponentName"]?.Value ?? "Unknown";

                    machineList.MachineName = machineName;
                    machineList.Part = part;
                    machineList.ReelNo = componentName;
                    machineList.Station = $"{machineName}-{feederBankPosition[0]}-{holeNo}";
                    result.Add(machineList);
                }
            }
            catch (Exception ex)
            {
                LogMessage($"Error parsing XML: {ex.Message}");
            }

            return result;
        }

        public List<SpiData> ParseCsvFile(string filePath)
        {
            var SpiDataList = new List<SpiData>();
            try
            {
                string fileName = Path.GetFileName(filePath);

                Encoding fileEncoding = DetectFileEncoding(filePath);
                string[] lines = File.ReadAllLines(filePath, fileEncoding);

                if (lines.Length < 3) return SpiDataList;

                string modelName = lines[1].Split(',')[0];
                string lineNumber = lines[1].Split(',')[1];
                string boardStatus = lines[2].Split(',')[1];
                string[] headers = lines[3].Split(',');

                for (int i = 4; i < lines.Length; i++)
                {
                    string[] values = lines[i].Split(',');

                    var SpiData = new SpiData
                    {
                        FileName = fileName,
                        ModelName = modelName,
                        LineNumber = lineNumber,
                        BoardStatus = boardStatus,
                        PadID = GetValue(values, 0, headers, "PadID"),
                        ComponentID = GetValue(values, 1, headers, "ComponentID"),
                        Type = GetValue(values, 2, headers, "Type"),
                        AreaPercent = GetValue(values, 3, headers, "Area(%)"),
                        Height = GetValue(values, 4, headers, "Height"),
                        VolumePercent = GetValue(values, 5, headers, "Volume(%)"),
                        XOffset = GetValue(values, 6, headers, "XOffset"),
                        YOffset = GetValue(values, 7, headers, "YOffset"),
                        PadSizeX = GetValue(values, 8, headers, "PadSize(X)"),
                        PadSizeY = GetValue(values, 9, headers, "PadSize(Y)"),
                        Area = GetValue(values, 10, headers, "Area"),
                        HeightPercent = GetValue(values, 11, headers, "Height(%)"),
                        Volume = GetValue(values, 12, headers, "Volume"),
                        Result = GetValue(values, 13, headers, "Result"),
                        Errcode = GetValue(values, 14, headers, "Errcode"),
                        PinNum = GetValue(values, 15, headers, "PinNum"),
                        Barcode = GetValue(values, 16, headers, "Barcode"),
                        Date = GetValue(values, 17, headers, "Date"),
                        Time = GetValue(values, 18, headers, "Time"),
                        ArrayID = GetValue(values, 19, headers, "ArrayID")
                    };
                    SpiDataList.Add(SpiData);
                }
            }
            catch (Exception ex)
            {
                LogMessage($"解析csv文件报错，{ex.Message}");
            }

            return SpiDataList;
        }

        public List<T> ParseCsvFile<T>(string filePath, Func<string, string[], string[], string, int, T> mapper) where T : class
        {
            var dataList = new List<T>();

            if (!File.Exists(filePath))
            {
                LogMessage($"文件不存在: {filePath}");
                return dataList;
            }
            try
            {
                string fileName = Path.GetFileName(filePath);
                /*Encoding fileEncoding = DetectFileEncoding(filePath);*/
                string[] lines = File.ReadAllLines(filePath, Encoding.GetEncoding("GB2312"));

                for (int i = 1; i < lines.Length; i++)
                {
                    if (string.IsNullOrWhiteSpace(lines[i])) continue;

                    if (equiType == "SPI")
                    {
                        if (lines.Length < 4) return dataList;

                        string modelName = lines[1].Split(',')[0];
                        string lineNumber = lines[1].Split(',')[1];
                        string boardStatus = lines[2].Split(',')[1];

                        if(i > 3)
                        {
                            string[] headers = lines[3].Split(',');
                            string[] values = lines[i].Split(',');
                            var item = mapper(fileName, headers, values, $"{modelName},{lineNumber},{boardStatus}", i);
                            if (item != null)
                            {
                                dataList.Add(item);
                            }
                        }
                    } else if (equiType == "印刷机")
                    {
                        string[] headers = lines[0].Split(',');
                        string[] values = lines[i].Split(',');
                        var item = mapper(fileName, headers, values, "", i);
                        if (item != null)
                        {
                            dataList.Add(item);
                        }
                    }
                    
                }
            }
            catch (Exception ex)
            {
                LogMessage($"解析csv文件报错: {ex.Message}");
            }

            return dataList;
        }

        private SpiData MapToSpiData(string fileName, string[] headers, string[] values,string others,int num)
        {
            return new SpiData
            {
                FileName = fileName,
                ModelName = others.Split(',')[0],
                LineNumber = others.Split(',')[1],
                BoardStatus = others.Split(',')[2],
                PadID = GetValue(values, 0, headers, "PadID"),
                ComponentID = GetValue(values, 1, headers, "ComponentID"),
                Type = GetValue(values, 2, headers, "Type"),
                AreaPercent = GetValue(values, 3, headers, "Area(%)"),
                Height = GetValue(values, 4, headers, "Height"),
                VolumePercent = GetValue(values, 5, headers, "Volume(%)"),
                XOffset = GetValue(values, 6, headers, "XOffset"),
                YOffset = GetValue(values, 7, headers, "YOffset"),
                PadSizeX = GetValue(values, 8, headers, "PadSize(X)"),
                PadSizeY = GetValue(values, 9, headers, "PadSize(Y)"),
                Area = GetValue(values, 10, headers, "Area"),
                HeightPercent = GetValue(values, 11, headers, "Height(%)"),
                Volume = GetValue(values, 12, headers, "Volume"),
                Result = GetValue(values, 13, headers, "Result"),
                Errcode = GetValue(values, 14, headers, "Errcode"),
                PinNum = GetValue(values, 15, headers, "PinNum"),
                Barcode = GetValue(values, 16, headers, "Barcode"),
                Date = GetValue(values, 17, headers, "Date"),
                Time = GetValue(values, 18, headers, "Time"),
                ArrayID = GetValue(values, 19, headers, "ArrayID")
            };
        }

        private PrintData MapToPriMacData(string fileName, string[] headers, string[] values, string others, int num)
        {
            return new PrintData
            {
                BarCode = GetValue(values, 0, headers, "BarCode"),
                TimeStamp = GetValue(values, 1, headers, "TimeStamp"),
                FileName = GetValue(values, 2, headers, "FileName"),
                ProgramRunning = GetValue(values, 3, headers, "ProgramRunning"),

                CycleTime = GetValue(values, 7, headers, "CycleTime"),
                _2DSPIResult = GetValue(values, 8, headers, "_2DSPIResult"),
                PrintSpeed = GetValue(values, 9, headers, "PrintSpeed"),
                FrontSQGPress = GetValue(values, 10, headers, "FrontSQGPress"),
                RearSQGPress = GetValue(values, 11, headers, "RearSQGPress"),
                PrintMode = GetValue(values, 12, headers, "PrintMode"),

                SnapOffDistance = GetValue(values, 14, headers, "SnapOffDistance"),
                SnapOffSpeed = GetValue(values, 15, headers, "SnapOffSpeed"),
                SnapOffDelay = GetValue(values, 16, headers, "SnapOffDelay"),
                SQGUpSpeed = GetValue(values, 17, headers, "SQGUpSpeed"),
                SQGDownSpeed = GetValue(values, 18, headers, "SQGDownSpeed"),
                SQGUpFirst = GetValue(values, 19, headers, "SQGUpFirst"),
                SQGHeightAtSnapOff = GetValue(values, 20, headers, "SQGHeightAtSnapOff"),
                CleaningAfterLastBoard = GetValue(values, 21, headers, "CleaningAfterLastBoard"),
                CleaningFrequency = GetValue(values, 22, headers, "CleaningFrequency"),
                CleaningSpeed = GetValue(values, 23, headers, "CleaningSpeed"),


                CleaningType = GetValue(values, 25, headers, "CleaningType"),
                AddSPMode = GetValue(values, 26, headers, "AddSPMode"),

                PrintDirection = GetValue(values, 29, headers, "PrintDirection"),
                PCBSize = GetValue(values, 30, headers, "PCBSize"),
                TableUpX = GetValue(values, 31, headers, "TableUpX"),
                TableUpY1 = GetValue(values, 32, headers, "TableUpY1"),
                TableUpY2 = GetValue(values, 33, headers, "TableUpY2"),
            };
        }

        private static Encoding DetectFileEncoding(string filePath)
        {
            byte[] bom = new byte[4];
            using (var file = new FileStream(filePath, FileMode.Open, FileAccess.Read))
            {
                file.Read(bom, 0, 4);
            }
            if (bom[0] == 0xef && bom[1] == 0xbb && bom[2] == 0xbf) return Encoding.UTF8;
            if (bom[0] == 0xff && bom[1] == 0xfe) return Encoding.Unicode;
            if (bom[0] == 0xfe && bom[1] == 0xff) return Encoding.BigEndianUnicode;
            if (bom[0] == 0 && bom[1] == 0 && bom[2] == 0xfe && bom[3] == 0xff) return Encoding.UTF32;

            try
            {
                string content = File.ReadAllText(filePath, Encoding.UTF8);
                return Encoding.UTF8;
            }
            catch
            {
                return Encoding.GetEncoding("GB2312");
            }
        }

        private string GetValue(string[] values, int index, string[] headers, string expectedHeader)
        {
            if (index >= values.Length || index >= headers.Length || headers[index] != expectedHeader) return string.Empty;

            return values[index];
        }

        public string CheckFileAccess(string filePath)
        {
            try
            {
                using (FileStream fileStream = File.Open(filePath, FileMode.Open, FileAccess.Read, FileShare.None))
                {
                    return "OK";
                }
            }
            catch (IOException ex)
            {
                return "文件被占用: " + ex.Message;
            }
            catch (UnauthorizedAccessException ex)
            {
                return "权限不足，无法访问文件: " + ex.Message;
            }
            catch (Exception ex)
            {
                return ex.Message;
            }
        }


        private class Log
        {
            public string Work_order {  get; set; }
            public string Line { get; set; }
            public string Source { get; set; }
            public string SN { set; get; }
            public string Result { set; get; }
            /*public List<NgData> Details { set; get; }*/
            public string Details { set; get; }
        }

        public class MachineList
        {
            public string MachineName { set; get; }

            public string Part { set; get; }
            public string Station { set; get; }
            public string ReelNo { set; get; }
        }

        public class SpiData
        {
            public string FileName { get; set; }
            public string ModelName { get; set; }
            public string LineNumber { get; set; }
            public string BoardStatus { get; set; }
            public string PadID { get; set; }
            public string ComponentID { get; set; }
            public string Type { get; set; }
            public string AreaPercent { get; set; }
            public string Height { get; set; }
            public string VolumePercent { get; set; }
            public string XOffset { get; set; }
            public string YOffset { get; set; }
            public string PadSizeX { get; set; }
            public string PadSizeY { get; set; }
            public string Area { get; set; }
            public string HeightPercent { get; set; }
            public string Volume { get; set; }
            public string Result { get; set; }
            public string Errcode { get; set; }
            public string PinNum { get; set; }
            public string Barcode { get; set; }
            public string Date { get; set; }
            public string Time { get; set; }
            public string ArrayID { get; set; }
        }

        public class PrintData
        {
            public string BarCode { get; set; }
            public string TimeStamp { get; set; }
            public string FileName { get; set; }
            public string ProgramRunning { get; set; }

            public string CycleTime { get; set; }
            public string _2DSPIResult { get; set; }
            public string PrintSpeed { get; set; }
            public string FrontSQGPress { get; set; }
            public string RearSQGPress { get; set; }
            public string PrintMode { get; set; }

            public string SnapOffDistance { get; set; }
            public string SnapOffSpeed { get; set; }
            public string SnapOffDelay { get; set; }
            public string SQGUpSpeed { get; set; }
            public string SQGDownSpeed { get; set; }
            public string SQGUpFirst { get; set; }
            public string SQGHeightAtSnapOff { get; set; }
            public string CleaningAfterLastBoard { get; set; }
            public string CleaningFrequency { get; set; }
            public string CleaningSpeed { get; set; }

            public string CleaningType { get; set; }
            public string AddSPMode { get; set; }

            public string PrintDirection { get; set; }
            public string PCBSize { get; set; }
            public string TableUpX { get; set; }
            public string TableUpY1 { get; set; }
            public string TableUpY2 { get; set; }
        }

        private PrinterData ReadWithXmlReader(string filePath)
        {
            PrinterData data = new PrinterData();

            using (XmlReader reader = XmlReader.Create(filePath))
            {
                while (reader.Read())
                {
                    if (reader.NodeType == XmlNodeType.Element)
                    {
                        switch (reader.Name)
                        {
                            case "SN":
                                data.SN = reader.ReadElementContentAsString();
                                break;
                            case "Barcode":
                                data.Barcode = reader.ReadElementContentAsString();
                                break;
                            case "Direction":
                                data.Direction = reader.ReadElementContentAsString();
                                break;
                            case "PrintTime":
                                data.PrintTime = reader.ReadElementContentAsString();
                                break;
                            case "PANEL":
                                ReadPanelData(reader, data.Panel);
                                break;
                            case "PROCESS":
                                ReadProcessData(reader, data.Process);
                                break;
                        }
                    }
                }
            }

            return data;
        }

        private void ReadPanelData(XmlReader reader, Panel panel)
        {
            while (reader.Read())
            {
                if (reader.NodeType == XmlNodeType.Element)
                {
                    switch (reader.Name)
                    {
                        case "PanelID":
                            panel.PanelID = reader.ReadElementContentAsString();
                            break;
                        case "PanelName":
                            panel.PanelName = reader.ReadElementContentAsString();
                            break;
                        case "PanelFirm":
                            panel.PanelFirm = reader.ReadElementContentAsString();
                            break;
                        case "PanelLength":
                            panel.PanelLength = reader.ReadElementContentAsDouble();
                            break;
                        case "PanelWide":
                            panel.PanelWide = reader.ReadElementContentAsDouble();
                            break;
                        case "PanelThickness":
                            panel.PanelThickness = reader.ReadElementContentAsDouble();
                            break;
                    }
                }
                else if (reader.NodeType == XmlNodeType.EndElement && reader.Name == "PANEL")
                {
                    break;
                }
            }
        }

        private void ReadProcessData(XmlReader reader, Process process)
        {
            while (reader.Read())
            {
                if (reader.NodeType == XmlNodeType.Element)
                {
                    switch (reader.Name)
                    {
                        case "ProcessName":
                            process.ProcessName = reader.ReadElementContentAsString();
                            break;
                        case "LineNumber":
                            process.LineNumber = reader.ReadElementContentAsString();
                            break;
                        case "StencilNum":
                            process.StencilNum = reader.ReadElementContentAsString();
                            break;
                    }
                }
                else if (reader.NodeType == XmlNodeType.EndElement && reader.Name == "PROCESS")
                {
                    break;
                }
            }
        }


        private class PrinterData
        {
            public string SN { get; set; }
            public string Barcode { get; set; }
            public string Direction { get; set; }
            public string PrintTime { get; set; }
            public Panel Panel { get; set; } = new Panel();
            public Process Process { get; set; } = new Process();
        }

        private class Panel
        {
            public string PanelID { get; set; }
            public string PanelName { get; set; }
            public string PanelFirm { get; set; }
            public double PanelLength { get; set; }
            public double PanelWide { get; set; }
            public double PanelThickness { get; set; }
        }

        private class Process
        {
            public string ProcessName { get; set; }
            public string LineNumber { get; set; }
            public string StencilNum { get; set; }
        }
    }
}