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 fileList = new List(); 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; SPITimer.Stop(); switch (Device.SelectedIndex) { case 0: currFileType = "txt"; equiType = "SPI"; SPITimer_Tick(null, null); SPITimer.Start(); break; case 1: currFileType = "csv"; equiType = "SPI"; SPITimer_Tick(null, null); SPITimer.Start(); break; case 2: currFileType = "txt"; equiType = "AOI"; break; case 3: currFileType = "csv"; equiType = "印刷机"; break; case 4: currFileType = "xml"; equiType = "贴片机"; break; case 5: currFileType = "xml"; equiType = "贴片机"; 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; } 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) { 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)) { LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, omakeCode, 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); } } } else if (Device.SelectedIndex == 2) // AOI { ParseLogInsert(file); } else if (Device.SelectedIndex == 3) // 印刷机 ? { List priMacData; priMacData = ParseCsvFile(file, MapToPriMacData); List BarCode = new List(); List TimeStamp = new List(); List FileName = new List(); List ProgramRunning = new List(); List CycleTime = new List(); List DSPIResult_2 = new List(); List PrintSpeed = new List(); List FrontSQGPress = new List(); List RearSQGPress = new List(); List PrintMode = new List(); List SnapOffDistance = new List(); List SnapOffSpeed = new List(); List SnapOffDelay = new List(); List SQGUpSpeed = new List(); List SQGDownSpeed = new List(); List SQGUpFirst = new List(); List SQGHeightAtSnapOff = new List(); List CleaningAfterLastBoard = new List(); List CleaningFrequency = new List(); List CleaningSpeed = new List(); List CleaningType = new List(); List AddSPMode = new List(); List PrintDirection = new List(); List PCBSize = new List(); List TableUpX = new List(); List TableUpY1 = new List(); List TableUpY2 = new List(); 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 param = new List() { }; string PS_CODE = ""; LogicHandler.GetSerialNumByCaller("Make!ParseLog", out PS_CODE); List MachineName = new List(); List Part = new List(); List Station = new List(); List ReelNo = new List(); List letNo = new List(); 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); continue; } } if (string.IsNullOrEmpty(Part_) || string.IsNullOrEmpty(Side_)) { LogMessage($"Error: 输出文件无产品编号或面别信息"); continue; } 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,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"); string wo = dh.getFieldDataByCondition("deviceline", "DL_MACODE", "dl_prodcode = "+ Part_ + "").ToString(); LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, wo, User.UserLineCode, User.UserSourceCode, "贴片机对接", $"已删除更新站位: {ps_id}", "", ""); } 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 logArr = new List() { }; 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 = ""; bool hasSn = false; 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 }; foreach (var appendItem in logArr) { if(appendItem.SN == sn) { if(itemLog.Result.ToUpper() != "PASS") { appendItem.Result = itemLog.Result; appendItem.Details = itemLog.Details; } hasSn = true; } } if (!hasSn) { 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 logs, string PathName,int fileNum) { try { StringBuilder sql = new StringBuilder(); List param = new List() { }; 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 (equiType == "AOI") { dt = (DataTable)dh.ExecuteSql($"select * from makeserial where ms_sncode = '{item.SN}' and ms_status = 3", "select"); if (dt.Rows.Count > 0) { if (logs.IndexOf(item) == logs.Count - 1) { return true; } LogMessage($"序列号: {item.SN}为不良品,不记录系统"); continue; } } if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, item.SN, User.UserCode, out omakeCode, out oMsid, out oErrorMessage)) { string passStationRes = "OK"; if (equiType == "AOI") { passStationRes = item.Result == "PASS" ? "OK" : "NG"; ma_code.Text = ""; } if (LogicHandler.SetStepResult(omakeCode, User.UserSourceCode, item.SN, "日志解析", passStationRes, User.UserCode, out oErrorMessage)) { LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, omakeCode, 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($"文件: {PathName},处理过站NG:{oErrorMessage}"); break; } } else { LogMessage($"文件: {PathName},过站核对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($"文件: {PathName},处理解析写入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) { LogMessage($"Error: 移动解析文件报错, {ex.Message}"); return false; } } private void LogMessage(string message) { if (lstFiles.InvokeRequired) { lstFiles.Invoke(new Action(LogMessage), message); return; } lstFiles.Items.Add($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] {message}"); lstFiles.TopIndex = lstFiles.Items.Count - 1; } public List ParseXml(string xmlContent) { List result = new List(); 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 ParseCsvFile(string filePath) { var SpiDataList = new List(); 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 ParseCsvFile(string filePath, Func mapper) where T : class { var dataList = new List(); 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 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; } } } }