using DevExpress.XtraRichEdit.API.Word; using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.IO; using System.Linq; using System.Net.Sockets; using System.Net; using System.Text; using System.Windows.Forms; using System.Xml; using UAS_MES_NEW.DataOperate; using UAS_MES_NEW.Entity; using UAS_MES_NEW.PublicMethod; using System.Threading; using DevExpress.Entity.ProjectModel; namespace UAS_MES_NEW.Make { public partial class Make_CollectHLH : Form { DataHelper dh = SystemInf.dh; AutoSizeFormClass asc = new AutoSizeFormClass(); LogStringBuilder sql = new LogStringBuilder(); DataTable dt; //当前序列号记录 string sn_code; //制造单号 string macode; //采集网标号 string net_code; //网标查询条件ms_id string oMsID; //判断是否输入网标 Boolean isnetcode = false; //打印计数 int printcount = 0; int ma_unlimitin; public Make_CollectHLH() { InitializeComponent(); } //FileSystemWatcher watcher; private void Make_CollectNetCode_Load(object sender, EventArgs e) { asc.controllInitializeSize(this); string sharedFolderPath = @"\\192.168.10.1\othersystem\Type2Output"; sharedFolderPath = @"D:\mes"; sharedFolderPath = @"\\192.168.10.1\othersystem\PickupInformation"; sharedFolderPath = @"D:\标签"; ////// 确保路径以反斜杠结尾,以便正确监控目录 ////if (!sharedFolderPath.EndsWith("\")) ////{ //// sharedFolderPath += "\"; ////} //// 创建FileSystemWatcher实例 //watcher = new FileSystemWatcher //{ // Path = sharedFolderPath, // NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite | NotifyFilters.Size | NotifyFilters.DirectoryName, // Filter = "*.*", // 监控所有文件 // IncludeSubdirectories = false, // 根据需要设置为true以监控子目录 // EnableRaisingEvents = true //}; // 绑定事件处理程序 //fileSystemWatcher1.Created += OnCreated; //watcher.Changed += OnChanged; //watcher.Deleted += OnDeleted; //watcher.Renamed += OnRenamed; //OperateResult.AppendText(DateTime.Now+" 开始监控文件夹: " + fileSystemWatcher1.Path+ "\n"); //OperateResult.AppendText(DateTime.Now + " 开始监控文件夹: " + fileSystemWatcher2.Path + "\n"); } // 文件创建事件处理程序 private void OnCreated(object sender, FileSystemEventArgs e) { OperateResult.AppendText("文件新增: " + e.FullPath+"\n"); //string filePath = "D:\\csy\\FileRecv\\FileRecv\\行之成\\回流焊\\70830L-TFT-A_JT12_250314_10-01-13_202-SPC-70830-15TFT2025031202406.csv"; Dictionary data = ParseCsvToKeyValuePairs(e.FullPath); // 示例：遍历输出结果 if (!data.ContainsKey("Board_Barcode=")) { OperateResult.AppendText("未查询到条码信息" + "\n"); return; } else { DataTable dt = (DataTable)dh.ExecuteSql("SELECT B.MSL_SNCODE SNCODE FROM MAKESNLIST A LEFT JOIN MAKESNLIST B ON A.msl_mainbarcode" + " = b.msl_mainbarcode WHERE replace(A.MSL_SNCODE,' ') = '" + data["Board_Barcode="] + "'", "select"); string[] keys = data.Keys.ToArray(); string[] Values = data.Values.ToArray(); for (int i = 0; i < dt.Rows.Count; i++) { string htdid = dh.GetSEQ("HLHTESTDETAIL_SEQ"); OperateResult.AppendText("插入条码" + dt.Rows[i]["SNCODE"].ToString() + "\n"); dh.BatchInsert("insert into HLHTESTDETAIL(htd_id,htd_sn,htd_class,htd_value) values (" + htdid + ",'" + dt.Rows[i]["SNCODE"].ToString() + "',:keyss,:valuess)", new string[] { "keyss", "valuess" }, keys, Values); } } } // 文件更改事件处理程序 private void OnChanged(object sender, FileSystemEventArgs e) { // OperateResult.AppendText("文件更改: " + e.FullPath+"\n"); } // 文件删除事件处理程序 private void OnDeleted(object sender, FileSystemEventArgs e) { //OperateResult.AppendText("文件删除: " + e.FullPath + "\n"); } // 文件重命名事件处理程序 private void OnRenamed(object sender, RenamedEventArgs e) { //OperateResult.AppendText("文件重命名: 从 "+ e.OldFullPath + " 到 "+ e.FullPath + "\n"); } private void sncode_KeyDown(object sender, KeyEventArgs e) { } private void Make_CollectNetCode_SizeChanged(object sender, EventArgs e) { asc.controlAutoSize(this); } private void Make_CollectNetCode_Activated(object sender, EventArgs e) { } private void deleteButton1_Click(object sender, EventArgs e) { } private void Make_CollectNetCode_FormClosed(object sender, FormClosedEventArgs e) { // 释放资源 fileSystemWatcher1.Dispose(); timer1.Dispose(); } private void fileSystemWatcher2_Created(object sender, FileSystemEventArgs e) { int i = 0; try { OperateResult.AppendText(DateTime.Now + " 文件创建: " + e.FullPath + "\n"); if (e.FullPath.Contains("dat")) { // i = PLGET(e, i); } } catch (Exception ex) { OperateResult.AppendText(i+" "+DateTime.Now + " " + ex.Message + "\n"); } } private void PLGET(String path) { int i = 0; bool ql = false; try { string[] lines = File.ReadAllLines(path); // 解析文件内容 foreach (string line in lines) { if (!line.StartsWith("[PlotInfo]") && !line.StartsWith("MCNo") && line.Trim() != "") // 跳过标题行 { string[] fields = line.Split(' '); // 提取字段 String mcNo = fields[0]; String lane = fields[1]; String fAdd = fields[2]; String fsAdd = fields[3]; string partsName = fields[4].Trim('"'); string feederSerial = fields[5].Trim('"'); Double pickup = Double.Parse(fields[6]); Double needpickup = Double.Parse(fields[6]); String location = ""; // ... 其他字段 // 处理数据 if (pickup > 0) { location = dh.getFieldDataByCondition("smtlocationinto", "sli_location", "sli_mcno = '" + mcNo + "' " + "and sli_fadd ='" + fAdd + "' and instr(sli_fsadd,'" + fsAdd + "')>0").ToString(); //OperateResult.AppendText(DateTime.Now + $"料号: {mcNo}, 轨道: {lane},fAdd: {fAdd} ," + // $"fsAdd: {fsAdd},站位:{location} PartsName: {partsName}, FeederSerial: {feederSerial},pickup: {pickup}" + "\n"); double reaminqtysum = Double.Parse(dh.getFieldDataByCondition("DEVSMTLOCATION", "nvl(sum(DSL_REMAINQTY),0)", " dsl_location = '" + location + "' ").ToString()); if (reaminqtysum < pickup) { OperateResult.AppendText(DateTime.Now + $"站位:{location}缺料 {pickup}" + "\n", Color.OrangeRed); ql = true; } else { DataTable dt = (DataTable)dh.ExecuteSql(" select dsl_id,dsl_remainqty,dsl_barcode from DEVSMTLOCATION " + "where dsl_location = '" + location + "' and nvl(DSL_USABLE,0)<>2 and dsl_remainqty >0 order by dsl_id asc ", "select"); for (int j = 0; j < dt.Rows.Count; j++) { if (needpickup > 0) { double v_v_useqty = 0; if (double.Parse(dt.Rows[j]["dsl_remainqty"].ToString()) >= needpickup || j == dt.Rows.Count - 1) { v_v_useqty = needpickup; needpickup = 0; dh.UpdateByCondition("DEVSMTLOCATION", "dsl_remainqty= dsl_remainqty - " + v_v_useqty + ",dsl_validtime=(case when dsl_validtime is null then sysdate else dsl_validtime end) ", "dsl_id=" + dt.Rows[j]["dsl_id"].ToString() + ""); } else { v_v_useqty = double.Parse(dt.Rows[j]["dsl_remainqty"].ToString()); needpickup = needpickup - v_v_useqty; dh.UpdateByCondition("DEVSMTLOCATION", "dsl_remainqty= dsl_remainqty - " + v_v_useqty + ",dsl_validtime=(case when dsl_validtime is null then sysdate else dsl_validtime end) ", "dsl_id=" + dt.Rows[j]["dsl_id"].ToString() + ""); } } } dh.UpdateByCondition("DEVSMTLOCATION", "DSL_USABLE= 2,dsl_invalidtime=(case when dsl_invalidtime is null then sysdate else dsl_invalidtime end) ", "dsl_location='" + location + "' and nvl(dsl_remainqty,0)<=0"); OperateResult.AppendText(DateTime.Now + $"站位:{location}扣料{pickup}成功" + "\n", Color.Black); } } i++; // ... 其他处理 } } if (ql) { OperateResult.AppendText(DateTime.Now + $"SMT缺料提醒" + "\n", Color.Blue); } } catch (Exception ex) { OperateResult.AppendText(i + " " + DateTime.Now + " " + ex.Message + "\n"); } } private void fileSystemWatcher2_Changed(object sender, FileSystemEventArgs e) { OperateResult.AppendText(DateTime.Now + " 文件修改: " + e.FullPath + "\n"); } private void fileSystemWatcher2_Deleted(object sender, FileSystemEventArgs e) { OperateResult.AppendText(DateTime.Now + " 文件删除: " + e.FullPath + "\n"); } private void fileSystemWatcher2_Renamed(object sender, RenamedEventArgs e) { OperateResult.AppendText(DateTime.Now + " 文件重命名: " + e.FullPath + "\n"); } const int ReceiveTimeout = 5000; // 接收超时时间（毫秒） static ManualResetEvent receiveDone = new ManualResetEvent(false); private void button1_Click(object sender, EventArgs e) { string filePath = "D:\\csy\\FileRecv\\FileRecv\\行之成\\回流焊\\70830L-TFT-A_JT12_250314_10-01-13_202-SPC-70830-15TFT2025031202406.csv"; Dictionary data = ParseCsvToKeyValuePairs(filePath); // 示例：遍历输出结果 if (!data.ContainsKey("Board_Barcode=")) { OperateResult.AppendText("未查询到条码信息" + "\n"); return; } else { DataTable dt = (DataTable)dh.ExecuteSql("SELECT B.MSL_SNCODE SNCODE FROM MAKESNLIST A LEFT JOIN MAKESNLIST B ON A.msl_mainbarcode" + " = b.msl_mainbarcode WHERE replace(A.MSL_SNCODE,' ') = '"+ data["Board_Barcode="] + "'", "select"); string[] keys = data.Keys.ToArray(); string[] Values = data.Values.ToArray(); for (int i = 0; i < dt.Rows.Count; i++) { string htdid = dh.GetSEQ("HLHTESTDETAIL_SEQ"); OperateResult.AppendText("插入条码"+ dt.Rows[i]["SNCODE"].ToString() + "\n"); dh.BatchInsert("insert into HLHTESTDETAIL(htd_id,htd_sn,htd_class,htd_value) values ("+ htdid + ",'" + dt.Rows[i]["SNCODE"].ToString() +"',:keyss,:valuess)", new string[] { "keyss", "valuess" }, keys,Values); } } } static Dictionary ParseCsvToKeyValuePairs(string filePath) { var keyValueDict = new Dictionary(StringComparer.OrdinalIgnoreCase); foreach (var line in File.ReadAllLines(filePath) .Where(l => !string.IsNullOrWhiteSpace(l))) { var columns = line.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries); if (columns.Length >= 2) { string key = columns[0].Trim(); string value = columns[1].Trim(); if (keyValueDict.ContainsKey(key)) { keyValueDict[key] = value; // 重复键则覆盖 } else { keyValueDict.Add(key, value); } } } return keyValueDict; } private Dictionary ParseInputString(string input) { var result = new Dictionary(); var items = input.Split(new[] { ';' }, StringSplitOptions.RemoveEmptyEntries); foreach (var item in items) { var parts = item.Trim().Split(','); if (parts.Length != 2) throw new FormatException($"无效的数据格式: {item}"); var key = parts[0].Trim().ToUpper(); if (string.IsNullOrWhiteSpace(key)) throw new ArgumentException($"参数名不能为空: {item}"); var value = parts[1].Trim(); if (string.IsNullOrWhiteSpace(value)) throw new ArgumentException($"值不能为空: {item}"); result[key] = value; } return result; } private static void ReceiveCallback(IAsyncResult ar) { try { object[] state = (object[])ar.AsyncState; NetworkStream stream = (NetworkStream)state[0]; byte[] buffer = (byte[])state[1]; int bytesRead = stream.EndRead(ar); if (bytesRead > 0) { string response = Encoding.UTF8.GetString(buffer, 0, bytesRead); Console.WriteLine($"收到响应: {response}"); } else { Console.WriteLine("服务器已关闭连接"); } } catch (Exception ex) { Console.WriteLine($"接收异常: {ex.Message}"); } finally { receiveDone.Set(); } } private void timer1_Tick(object sender, EventArgs e) { string serverIP = "192.168.110.42"; int port = 8008; try { using (TcpClient client = new TcpClient()) { // 尝试连接服务器（同步方式,超时约20-30秒） // 同步连接（带超时） IAsyncResult connectResult = client.BeginConnect(serverIP, port, null, null); if (!connectResult.AsyncWaitHandle.WaitOne(5000, true)) { OperateResult.AppendText("连接超时 (5秒)" + "\n"); return; } client.EndConnect(connectResult); OperateResult.AppendText("连接服务器成功！" + "\n"); if (client.Connected) { //Console.WriteLine("连接服务器成功！"); using (NetworkStream stream = client.GetStream()) { // 发送消息到服务器 string message = "jtauto;27508459"; byte[] sendData = Encoding.UTF8.GetBytes(message); stream.Write(sendData, 0, sendData.Length); OperateResult.AppendText($"已发送消息: {message}" + "\n"); string response; ////接收服务器响应 //byte[] receiveBuffer = new byte[102400000]; //stream.BeginRead(receiveBuffer, 0, receiveBuffer.Length, ReceiveCallback, new object[] { stream, receiveBuffer }); //// 等待接收完成或超时 //if (!receiveDone.WaitOne(ReceiveTimeout)) //{ // Console.WriteLine("接收响应超时"); //} //else //{ // response = Encoding.UTF8.GetString(receiveBuffer); // Console.WriteLine($"收到响应: {response}"); //} Thread.Sleep(ReceiveTimeout); // 发送消息到服务器 message = "GetStatevValues"; sendData = Encoding.UTF8.GetBytes(message); stream.Write(sendData, 0, sendData.Length); OperateResult.AppendText($"已发送消息: {message}" + "\n"); // 接收服务器响应 //接收服务器响应 byte[] receiveBuffer = new byte[1024000]; stream.BeginRead(receiveBuffer, 0, receiveBuffer.Length, ReceiveCallback, new object[] { stream, receiveBuffer }); // 等待接收完成或超时 if (!receiveDone.WaitOne(ReceiveTimeout)) { OperateResult.AppendText("接收响应超时" + "\n"); } else { response = Encoding.UTF8.GetString(receiveBuffer).TrimEnd('\0'); OperateResult.AppendText($"收到响应: {response}" + "\n"); Dictionary hlh = ParseInputString(response); // string a = hlh["1212"]; // string b = hlh["1212"]; dh.ExecuteSql(" insert into hlh(HLH_ID,HLH_INDATE,SPEEDPV1,SPEEDPV2,ZONE1PV_UP,ZONE1PV_DOWN,ZONE2PV_UP,ZONE2PV_DOWN,ZONE3PV_UP,ZONE3PV_DOWN,ZONE4PV_UP,ZONE4PV_DOWN,ZONE5PV_UP,ZONE5PV_DOWN,ZONE6PV_UP,ZONE6PV_DOWN,ZONE7PV_UP,ZONE7PV_DOWN,ZONE8PV_UP,ZONE8PV_DOWN,ZONE9PV_UP,ZONE9PV_DOWN,ZONE10PV_UP,ZONE10PV_DOWN,ZONE11PV_UP,ZONE11PV_DOWN,ZONE12PV_UP,ZONE12PV_DOWN,FAN1_PV,FAN2_PV,FAN3_PV)" + " values (hlh_seq.nextval,sysdate,'" + hlh["SPEEDPV1"] + "','" + hlh["SPEEDPV2"] + "' ,'" + hlh["ZONE1PV_UP"] + "','" + hlh["ZONE1PV_DOWN"] + "','" + hlh["ZONE2PV_UP"] + "','" + hlh["ZONE2PV_DOWN"] + "','" + hlh["ZONE3PV_UP"] + "','" + hlh["ZONE3PV_DOWN"] + "','" + hlh["ZONE4PV_UP"] + "'" + ",'" + hlh["ZONE4PV_DOWN"] + "','" + hlh["ZONE5PV_UP"] + "','" + hlh["ZONE5PV_DOWN"] + "','" + hlh["ZONE6PV_UP"] + "','" + hlh["ZONE6PV_DOWN"] + "','" + hlh["ZONE7PV_UP"] + "','" + hlh["ZONE7PV_DOWN"] + "','" + hlh["ZONE8PV_UP"] + "','" + hlh["ZONE8PV_DOWN"] + "','" + hlh["ZONE9PV_UP"] + "'" + ",'" + hlh["ZONE9PV_DOWN"] + "','" + hlh["ZONE10PV_UP"] + "','" + hlh["ZONE10PV_DOWN"] + "','" + hlh["ZONE11PV_UP"] + "','" + hlh["ZONE11PV_DOWN"] + "','" + hlh["ZONE12PV_UP"] + "','" + hlh["ZONE12PV_DOWN"] + "','" + hlh["FAN1_PV"] + "','" + hlh["FAN2_PV"] + "','" + hlh["FAN3_PV"] + "' ) ", "insert"); } } } } } catch (SocketException ex) { OperateResult.AppendText($"连接失败！错误代码 {ex.ErrorCode}: {ex.Message}" + "\n"); } catch (Exception ex) { OperateResult.AppendText($"发生错误: {ex.Message}" + "\n"); } } } }