1

yangle

2023-12-01 65803a6e5864ea62822f08be2a6ebf3a1af00b3a

 WFormSynchronizeData_SMR/WFormReadData_SMR/ReadyDataForm.cs

@@ -20,87 +20,101 @@
        {
            InitializeComponent();
        }
         public static int num = 0;

        //读取数据
        private void btnReadData_Click(object sender, EventArgs e)
        {
            if (this.HEmpCode.Text == "") {

                MessageBox.Show("请输入员工编码");
            }
            else
            if (num == 0) {
                this.btnReadData.Text = "暂停";
                this.timer1.Enabled = true;
                num = 1;
            }else if (num == 1)
            {
                int year = DateTime.Now.Year;
                string month = DateTime.Now.Month.ToString();
                string day = DateTime.Now.Day.ToString();

                string dataTime = DateTime.Now.ToString("yyyyMMdd");
                ////判断是否有这个文件
                //bool flag = File.Exists($@"D:\{year}\{month}\{day}\{dataTime}.txt");
                bool flag = File.Exists($@"C:\Users\admin\Desktop\新建文件夹 (2)\20231123.txt");

                if (flag)
                {
                    //StreamReader stream = new StreamReader($@"D:\{year}\{month}\{day}\{dataTime}.txt", Encoding.GetEncoding("gb2312"));
                    StreamReader stream = new StreamReader($@"C:\Users\admin\Desktop\新建文件夹 (2)\20231123.txt", Encoding.GetEncoding("gb2312"));

                    string FileData = stream.ReadToEnd();
                    stream.Close();
                    FileData = FileData.Substring(0, FileData.Length - 1);
                    FileData = "[" + FileData + "]";
                    //JSON序列化转换字典集合
                    List<Dictionary<string, string>> list = new List<Dictionary<string, string>>();
                    List<object> DataList = JsonConvert.DeserializeObject<List<object>>(FileData);
                    foreach (JObject item in DataList)
                    {
                        Dictionary<string, string> dic = new Dictionary<string, string>();
                        foreach (var itm in item.Properties())
                        {
                            dic.Add(itm.Name, itm.Value.ToString());
                        }
                        list.Add(dic);
                    }
                    //获取当前时间
                    DateTime ActionTime = DateTime.Parse(DateTime.Now.AddMinutes(-1).ToString("yyyy-MM-dd  HH:mm:ss"));
                    DateTime EndTime = DateTime.Parse(DateTime.Now.AddMinutes(1).ToString("yyyy-MM-dd  HH:mm:00"));
                    //循环集合
                    for (int i = 0; i < list.Count; i++)
                    {
                        DateTime NowTime = DateTime.Parse(list[i]["HDate"].ToString());
                        if (NowTime >= ActionTime && NowTime < EndTime)
                        {
                            string HSourceCode = list[i]["HSouceNumber"].ToString();
                            string HEmpCode = this.HEmpCode.Text;
                            //string HEmpCode = "";
                            string HType = list[i]["HBadReason"].ToString();
                            string HBarCode = list[i]["HBadCodeSN"].ToString();
                            int HCount = 1;
                            string HCreateTime = list[i]["HDate"].ToString();
                            string HDate = DateTime.Parse(list[i]["HDate"].ToString()).ToString("yyyy-MM-dd");
                            string HResult = list[i]["HResult"].ToString();
                            string HProcNumber = list[i]["HProcNumber"].ToString();
                            int HFlag = 0;

                            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);
                            }
                        }
                        else
                        {
                            //CustomWriteLog("时间不在保存范围内", DateTime.Now.ToString("yyyy-MM-dd"));
                        }
                    }
                }
                this.btnReadData.Text = "启动";
                this.timer1.Enabled = false;
                num = 0;
            }



//            if (this.HEmpCode.Text == "") {

//                MessageBox.Show("请输入员工编码");
//            }
//            else
//            {
//                int year = DateTime.Now.Year;
//                string month = DateTime.Now.Month.ToString();
//                string day = DateTime.Now.Day.ToString();

//                string dataTime = DateTime.Now.ToString("yyyyMMdd");
//                ////判断是否有这个文件
//                //bool flag = File.Exists($@"D:\{year}\{month}\{day}\{dataTime}.txt");
//                bool flag = File.Exists($@"C:\Users\admin\Desktop\新建文件夹 (2)\20231123.txt");

//                if (flag)
//                {
//                    //StreamReader stream = new StreamReader($@"D:\{year}\{month}\{day}\{dataTime}.txt", Encoding.GetEncoding("gb2312"));
//                    StreamReader stream = new StreamReader($@"C:\Users\admin\Desktop\新建文件夹 (2)\20231123.txt", Encoding.GetEncoding("gb2312"));

//                    string FileData = stream.ReadToEnd();
//                    stream.Close();
//                    FileData = FileData.Substring(0, FileData.Length - 1);
//                    FileData = "[" + FileData + "]";
//                    //JSON序列化转换字典集合
//                    List<Dictionary<string, string>> list = new List<Dictionary<string, string>>();
//                    List<object> DataList = JsonConvert.DeserializeObject<List<object>>(FileData);
//                    foreach (JObject item in DataList)
//                    {
//                        Dictionary<string, string> dic = new Dictionary<string, string>();
//                        foreach (var itm in item.Properties())
//                        {
//                            dic.Add(itm.Name, itm.Value.ToString());
//                        }
//                        list.Add(dic);
//                    }
//                    //获取当前时间
//                    DateTime ActionTime = DateTime.Parse(DateTime.Now.AddMinutes(-1).ToString("yyyy-MM-dd  HH:mm:ss"));
//                    DateTime EndTime = DateTime.Parse(DateTime.Now.AddMinutes(1).ToString("yyyy-MM-dd  HH:mm:00"));
//                    //循环集合
//                    for (int i = 0; i < list.Count; i++)
//                    {
//                        DateTime NowTime = DateTime.Parse(list[i]["HDate"].ToString());
//                        if (NowTime >= ActionTime && NowTime < EndTime)
//                        {
//                            string HSourceCode = list[i]["HSouceNumber"].ToString();
//                            string HEmpCode = this.HEmpCode.Text;
//                            //string HEmpCode = "";
//                            string HType = list[i]["HBadReason"].ToString();
//                            string HBarCode = list[i]["HBadCodeSN"].ToString();
//                            int HCount = 1;
//                            string HCreateTime = list[i]["HDate"].ToString();
//                            string HDate = DateTime.Parse(list[i]["HDate"].ToString()).ToString("yyyy-MM-dd");
//                            string HResult = list[i]["HResult"].ToString();
//                            string HProcNumber = list[i]["HProcNumber"].ToString();
//                            int HFlag = 0;

//                            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);
//                            }
//                        }
//                        else
//                        {
//                            //CustomWriteLog("时间不在保存范围内", DateTime.Now.ToString("yyyy-MM-dd"));
//                        }
//                    }
//                }
//            }
        }

        //输入员工编码
        //员工编码回车
        private void HEmpCode_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter) {
@@ -140,6 +154,11 @@
            this.HEmpCode.Focus();
            this.HEmpCode.Text = "";
            this.HEmpCodeName.Text = "";

            this.HSouce.ReadOnly = false;
            this.HSouce.Focus();
            this.HSouce.Text = "";
            this.HSouceName.Text = "";
        }

        private void timer1_Tick(object sender, EventArgs e)
@@ -220,5 +239,39 @@
                }
            }
        }

        //生产资源回车
        private void HSouce_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                SelectHSouc(this.HSouce.Text);
            }
        }

        //查询生产资源
        public void SelectHSouc(string HNumber)
        {
            try
            {
                DataSet ds = oCN.RunProcReturn("select  * from Gy_Source where HNumber='" + HNumber + "' ", "Gy_Source");
                if (ds.Tables[0].Rows.Count == 0)
                {
                    MessageBox.Show("查无数据!");
                }
                else
                {
                    string HSouceName = ds.Tables[0].Rows[0]["HName"].ToString();
                    string HSouceNumber = ds.Tables[0].Rows[0]["HNumber"].ToString();
                    this.HSouceName.Text = HSouceName;
                    this.HSouce.Text = HSouceNumber;
                    this.HSouce.ReadOnly = true;
                }
            }
            catch (Exception e)
            {
                MessageBox.Show(this, e.Message, "提示");
            }
        }
    }
}