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

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<string, string> 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<string, string> 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<string, string> ParseCsvToKeyValuePairs(string filePath)
        {
            var keyValueDict = new Dictionary<string, string>(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<string, string> ParseInputString(string input)
        {
            var result = new Dictionary<string, string>();
            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.10.171";
            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<string, string> 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");*/

                                dh.ExecuteSql($@"insert into hlh(SPEEDPV1,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,Fan1_PV,Fan2_PV,Fan3_PV) values 
                                                ({hlh["SPEEDPV"]},{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["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");
            }
        }
    }
}