1
yangle
2024-11-12 871fa09fa6b84be39f7d060eb25a7159e0a2ca40
WFormSynchronizeData_SMR/WFormReadData_SMR/ReadCSV.cs
@@ -128,6 +128,7 @@
                    this.btnGH.Enabled = false;
                    this.btnSelect.Enabled = false;
                    num = 1;
                    //ReadCsv();
                }
                else if (num == 1)
                {
@@ -158,20 +159,36 @@
            string Date = DateTime.Now.ToString("yyMMdd");
            string HBath = this.txtHBath.Text;
            string Year = DateTime.Now.Year.ToString();
            Year = Year.Substring(Year.Length - 2, 2);
            string Month = DateTime.Now.Month.ToString();
            Month = Month.Length > 1 ? Month : "0" + Month;
            string Day = DateTime.Now.Day.ToString();
            Day = Day.Length > 1 ? Day : "0" + Day;
            //注:斯莫尔组装3 在E盘  _332009
            //其余在D盘 _C332001_2M
            //string csv_file_path = $@"C:\Users\admin\Desktop\新建文件夹 (2)\20231123.csv";
            //string csv_file_path = $@"D:\THLCR_Data\{HBath}\{HBath}_{Date}_C332001_2M.csv"; //组装1 组装2路径 
            string csv_file_path = $@"E:\THLCR_Data\{HBath}\{HBath}_{Date}_332009.csv";  //组装3路径
            //15车间缺少路径 D:\DATA SAVE\年\年月\年月日\批次号\数据保存.csv
            //string csv_file_path = $@"D:\DATA SAVE\{Year}\{Year + Month}\{Year + Month + Day}\{HBath}\数据保存.csv";
            bool flag = File.Exists(csv_file_path);
            if (flag)
            {
                DataTable dt = new DataTable();
                //string HTypeName = "无尘";
                //string csv_file_path_Read = @"C:\Users\admin\Desktop\新建文件夹 (2)\20231123_1.csv";
                //string csv_file_path_Read = $@"D:\THLCR_Data\{HBath}\{HBath}_{Date}_C332001_2M_Read.csv"; //组装1 组装2路径 
                string csv_file_path_Read = $@"E:\THLCR_Data\{HBath}\{HBath}_{Date}_332009_Read.csv";  //组装3路径
                //string csv_file_path_Read = $@"E:\THLCR_Data\{HBath}\{HBath}_{Date}_332009_Read.csv";  //组装3路径
                string HTypeName = "15";
                //15车间缺少路径 D:\DATA SAVE\年\年月\年月日\批次号\数据保存.csv
                //string csv_file_path_Read = $@"C:\Users\admin\Desktop\新建文件夹 (2)\DATA SAVE\数据保存_MES读取.csv";
                string csv_file_path_Read = $@"D:\DATA SAVE\{Year}\{Year + Month}\{Year + Month + Day}\{HBath}\数据保存_MES读取.csv";
                File.Copy(csv_file_path, csv_file_path_Read, true);
@@ -203,61 +220,131 @@
                parser.Close();
                //获取当前时间
                DateTime ActionTime = DateTime.Parse(DateTime.Now.AddMinutes(-1).ToString("yyyy-MM-dd  HH:mm:ss"));
                DateTime ActionTime = DateTime.Parse(DateTime.Now.AddMinutes(-2).ToString("yyyy-MM-dd  HH:mm:ss"));
                DateTime EndTime = DateTime.Parse(DateTime.Now.AddMinutes(1).ToString("yyyy-MM-dd  HH:mm:00"));
                foreach (DataRow item in dt.Rows)
                {
                    DateTime NowTime = DateTime.Parse(item["测试时间"].ToString());
                    string HBadCodeSN = item["序号"].ToString();
                    if (((NowTime >= ActionTime && NowTime < EndTime) || dt.Rows.Count <= 20) && HBadCodeSN != "")
                    if (HTypeName == "无尘")
                    {
                        DateTime NowTime = DateTime.Parse(item["测试时间"].ToString());
                        string HBadCodeSN = item["序号"].ToString();
                        string HSourceCode = this.HSouce.Text; //设备编号 组装1 9994 组装2 9995 组装3 9996
                        string HEmpCode = this.HEmpCode.Text;
                        string HBarCode = item["序号"].ToString();
                        string HCreateTime = item["测试时间"].ToString();
                        string HDate = DateTime.Parse(item["测试时间"].ToString()).ToString("yyyy-MM-dd");
                        string HResult = item["分选"].ToString() == "PASS" ? "OK" : "NG";
                        string HProcNumber = "005";
                        int HFlag = 0;
                        //string HEmpCode = "";
                        if (HBadCodeSN != "")
                        if (((NowTime >= ActionTime && NowTime < EndTime) || dt.Rows.Count <= 20) && HBadCodeSN != "")
                        {
                            string HType = "";
                            int HCount = 1;
                            DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollection_SN where HBarCode='" + HBarCode + "' and HCreateTime='" + HCreateTime + "'", "Sb_EquipMentCollection_SN");
                            if (ds.Tables[0].Rows.Count == 0)
                            string HSourceCode = this.HSouce.Text; //设备编号 组装1 9994 组装2 9995 组装3 9996
                            string HEmpCode = this.HEmpCode.Text;
                            string HBarCode = item["序号"].ToString();
                            string HCreateTime = item["测试时间"].ToString();
                            string HDate = DateTime.Parse(item["测试时间"].ToString()).ToString("yyyy-MM-dd");
                            string HResult = item["分选"].ToString() == "PASS" ? "OK" : "NG";
                            string HProcNumber = "005";
                            int HFlag = 0;
                            //string HEmpCode = "";
                            if (HBadCodeSN != "")
                            {
                                string sql = $@"insert into Sb_EquipMentCollection_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
                    values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{HCount}','{HCreateTime}','{HDate}','{HResult}','{HProcNumber}','{HFlag}')";
                                oCN.RunProc(sql);
                                ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                            }
                        }
                                string HType = "";
                                int HCount = 1;
                        for (int i = 0; i < dt.Columns.Count; i++)
                        {
                            if (dt.Columns[i].ColumnName.Contains("Hz"))
                            {
                                string HType = dt.Columns[i].ColumnName;
                                string HCount = item[HType].ToString();
                                DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollectionTechParam_SN where HBarCode='" + HBarCode + "' and HType='" + HType + "'", "Sb_EquipMentCollectionTechParam_SN");
                                DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollection_SN where HBarCode='" + HBarCode + "' and HCreateTime='" + HCreateTime + "'", "Sb_EquipMentCollection_SN");
                                if (ds.Tables[0].Rows.Count == 0)
                                {
                                    string sql = $@"insert into Sb_EquipMentCollectionTechParam_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{HCount}','{HCreateTime}','{HDate}','{HResult}','{HProcNumber}','{HFlag}')";
                                    string sql = $@"insert into Sb_EquipMentCollection_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
                    values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{HCount}','{HCreateTime}','{HDate}','{HResult}','{HProcNumber}','{HFlag}')";
                                    oCN.RunProc(sql);
                                    //ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                                    ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                                }
                            }
                            for (int i = 0; i < dt.Columns.Count; i++)
                            {
                                if (dt.Columns[i].ColumnName.Contains("Hz"))
                                {
                                    string HType = dt.Columns[i].ColumnName;
                                    string HCount = item[HType].ToString();
                                    DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollectionTechParam_SN where HBarCode='" + HBarCode + "' and HType='" + HType + "'", "Sb_EquipMentCollectionTechParam_SN");
                                    if (ds.Tables[0].Rows.Count == 0)
                                    {
                                        string sql = $@"insert into Sb_EquipMentCollectionTechParam_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{HCount}','{HCreateTime}','{HDate}','{HResult}','{HProcNumber}','{HFlag}')";
                                        oCN.RunProc(sql);
                                        //ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                                    }
                                }
                            }
                        }
                    }
                    if (HTypeName == "15")
                    {
                        DateTime NowTime = DateTime.Parse(item["CS_时间"].ToString());
                        string HBadCodeSN = item["CS_DM码"].ToString();
                        if (((NowTime >= ActionTime && NowTime < EndTime) || dt.Rows.Count <= 20) && HBadCodeSN != "")
                        {
                            string HSourceCode = this.HSouce.Text; //设备编号 组装1 9994 组装2 9995 组装3 9996
                            string HEmpCode = this.HEmpCode.Text;
                            string HBarCode = item["CS_DM码"].ToString();
                            string HCreateTime = item["CS_时间"].ToString();
                            string HDate = DateTime.Parse(item["CS_时间"].ToString()).ToString("yyyy-MM-dd");
                            string HResult = item["CS_总结果"].ToString();
                            string HProcNumber = "005";
                            int HFlag = 0;
                            if (HResult != "") {
                                if (HBadCodeSN != "")
                                {
                                    string HType = "";
                                    int HCount = 1;
                                    DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollection_SN where HBarCode='" + HBarCode + "' and HCreateTime='" + HCreateTime + "'", "Sb_EquipMentCollection_SN");
                                    if (ds.Tables[0].Rows.Count == 0)
                                    {
                                        string sql = $@"insert into Sb_EquipMentCollection_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
                    values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{HCount}','{HCreateTime}','{HDate}','{HResult}','{HProcNumber}','{HFlag}')";
                                        oCN.RunProc(sql);
                                        ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                                    }
                                }
                                for (int i = 0; i < dt.Columns.Count; i++)
                                {
                                    if (dt.Columns[i].ColumnName.Contains("CS_"))
                                    {
                                        string HType = dt.Columns[i].ColumnName;
                                        string HCount = item[HType].ToString();
                                        string HResult_TechParam = "";
                                        if (HType != "CS_时间" && HType != "CS_DM码" && HType != "CS_总结果")
                                        {
                                            HResult_TechParam = HCount;
                                            double number = 0;
                                            if (!Double.TryParse(HCount, out number))
                                            {
                                                HCount = "0";
                                            }
                                            DataSet ds = oCN.RunProcReturn(@"select * from Sb_EquipMentCollectionTechParam_SN where HBarCode='" + HBarCode + "' and HType='" + HType + "'", "Sb_EquipMentCollectionTechParam_SN");
                                            if (ds.Tables[0].Rows.Count == 0)
                                            {
                                                string sql = $@"insert into Sb_EquipMentCollectionTechParam_SN(HSourceCode,HEmpCode,HType,HBarCode,HCount,HCreateTime,HDate,HResult,HProcNumber,HFlag)
values('{HSourceCode}','{HEmpCode}','{HType}','{HBarCode}','{(HCount == "" ? " 0" : HCount)}','{HCreateTime}','{HDate}','{HResult_TechParam}','{HProcNumber}','{HFlag}')";
                                                oCN.RunProc(sql);
                                                //ListSelect.Items.Add("条码:" + HBarCode + ",日期:" + HCreateTime + ",结果:" + HResult);
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }