mes-client/FileWatcher/AutoSMTRXY.cs

using Microsoft.Win32;
using System;
using System.Collections.Generic;
using System.Data;
using System.Threading;
using System.Windows.Forms;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.IO.Ports;
using HslCommunication;
using System.Diagnostics.PerformanceData;

namespace FileWatcher
{
    public partial class AutoSMTRXY : Form
    {

        DataHelper dh;

        DataTable dt;

        DataTable DB;

        /// <summary>
        /// 用户编号
        /// </summary>
        string iusercode;
        /// <summary>
        /// 岗位资源
        /// </summary>
        string isource;

        Thread InitDB;
        /// 当前工序
        /// </summary>
        string istepcode;
        StringBuilder sql = new StringBuilder();
        /// <summary>
        /// 缓存的文件
        /// </summary>
        public static string CachePath = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/Cache.xml";
        /// <summary>
        /// 缓存的文件夹
        /// </summary>
        public static string CachePathFolder = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/";

        ftpOperater ftp = new ftpOperater();

        HslCommunication.Profinet.Panasonic.PanasonicMewtocol plc;

        /// <summary>
        /// 参数设置（由“设置参数”窗口配置并写入缓存）
        /// </summary>
        string ComPort = "";
        string BaudRate = "9600";
        string Read = "";
        string Write = "";
        string Stop = "";
        string ToZero = "";
        string UseScan = "";
        string CountType = "";

        public AutoSMTRXY()
        {
            InitializeComponent();
            StartPosition = FormStartPosition.CenterScreen;
        }
        DataTable Dbfind;

        string IPAddress = "";
        private void nr_rule_DBChange(object sender, EventArgs e)
        {
            Dbfind = li_code.ReturnData;
            BaseUtil.SetFormValue(this.Controls, Dbfind);
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            CheckForIllegalCrossThreadCalls = false;
            FormBorderStyle = FormBorderStyle.FixedSingle;
            InitDB = new Thread(ConnectDB);
            //添加监控事件
            SetLoadingWindow stw = new SetLoadingWindow(InitDB, "正在启动程序");
            stw.StartPosition = FormStartPosition.CenterScreen;
            stw.ShowDialog();
            List<string> CacheInf = new List<string>();
            IPHostEntry IpEntry = Dns.GetHostEntry(Dns.GetHostName());
            for (int i = 0; i < IpEntry.AddressList.Length; i++)
            {
                if (IpEntry.AddressList[i].AddressFamily == AddressFamily.InterNetwork)
                    IPAddress = IpEntry.AddressList[i].ToString();
            }
            serialPort1.DataReceived += SerialPort1_DataReceived;
            //获取缓存信息
            try
            {
                Type.Text = BaseUtil.GetCacheData("Type").ToString();
                li_code.Text = BaseUtil.GetCacheData("Line").ToString();
                ReloadSettings();
            }
            catch (Exception ex) { OperateResult.AppendText(ex.Message); }

            RemindTimer.Start();
            this.WindowState = FormWindowState.Normal;
            this.Size = new System.Drawing.Size(900, 400); // 替换为你需要的尺寸
            this.CenterToScreen();
        }

        double lastqty = 0;
        private void SerialPort1_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            int len = serialPort1.BytesToRead;
            Byte[] readBuffer = new Byte[len];
            serialPort1.Read(readBuffer, 0, len); //将数据读入缓存
            string data = BitConverter.ToString(readBuffer, 0, readBuffer.Length).Replace("-", "");
            string error = "";
            if (data != "")
            {
                double qty = Convert.ToInt32(data.Substring(6, 8), 16);
                if (lastqty > qty)
                {
                    lastqty = 0;
                }
                NowQTY.Text = qty.ToString();
                if (Type.Text == "投入")
                {
                    string ma_inqty = dh.getFieldDataByCondition("make", "nvl(ma_inqty,0)", "ma_code='" + ma_code.Text + "'").ToString();
                    dh.ExecuteSql("update make set ma_inqty=nvl(ma_inqty,0)+'" + (qty - lastqty) + "' where ma_code='" + ma_code.Text + "' ", "update");
                    dh.ExecuteSql("insert into makehourcount(mhc_id,mhc_macode,mhc_indate,mhc_type,mhc_qty,mhc_linecode,mhc_pcbcount)" +
                        "values(makehourcount_seq.nextval,'" + ma_code.Text + "',sysdate,'" + Type.Text + "','" + (qty - lastqty) + "','" + li_code.Text + "','" + pr_pcbacount.Value + "')", "insert");
                }
                else
                {
                    string ma_endqty = dh.getFieldDataByCondition("make", "nvl(ma_endqty,0)", "ma_code='" + ma_code.Text + "'").ToString();
                    dh.ExecuteSql("update make set ma_endqty=nvl(ma_endqty,0)+'" + (qty - lastqty) + "' where ma_code='" + ma_code.Text + "' ", "update");
                    dh.ExecuteSql("insert into makehourcount(mhc_id,mhc_macode,mhc_indate,mhc_type,mhc_qty,mhc_linecode,mhc_pcbcount)" +
                             "values(makehourcount_seq.nextval,'" + ma_code.Text + "',sysdate,'" + Type.Text + "','" + (qty - lastqty) + "','" + li_code.Text + "','" + pr_pcbacount.Value + "')", "insert");
                }
                dt = (DataTable)dh.ExecuteSql("select nvl(sum(MHC_QTY* MHC_PCBCOUNT),0)MHC_QTY,max(nvl(ma_qty,0)+nvl(ma_boutqty,0))ma_qty from makehourcount left join make on ma_code=mhc_macode where mhc_macode='" + ma_code.Text + "'", "select");
                if (dt.Rows.Count > 0)
                {
                    int MHC_QTY = int.Parse(dt.Rows[0]["MHC_QTY"].ToString());
                    int ma_qty = int.Parse(dt.Rows[0]["ma_qty"].ToString());
                    if (MHC_QTY >= ma_qty)
                    {
                        OperateResult write = plc.Write(Stop, 1);
                        if (write.IsSuccess)
                        {
                            OperateResult.AppendText("通过，发送指令" + Stop + "写入1\n");
                            OperateResult.ScrollToCaret();
                        }
                        else
                        {
                            OperateResult.AppendText("写入失败\n");
                            OperateResult.ScrollToCaret();
                        }
                    }
                }
                if (Counter.Checked)
                {
                    LogicHandler.CS_SetResultRXY(ma_code.Text, li_code.Text, "", qty.ToString(), li_code.Text, "OK", out error);
                }
                lastqty = qty;
            }
        }
        private void ConnectDB()
        {
            dh = new DataHelper();
            SystemInf.dh = dh;

            ma_code.TableName = "make";
            ma_code.SelectField = "ma_code # 工单号";
            ma_code.FormName = Name;
            ma_code.DBTitle = "工单查询";
            ma_code.SetValueField = new string[] { "ma_code" };
            ma_code.Condition = "";
            ma_code.DbChange += nr_rule_DBChange;

            li_code.TableName = "line";
            li_code.SelectField = "li_code # 线别编号,li_name # 线别名称";
            li_code.FormName = Name;
            li_code.DBTitle = "线别查询";
            li_code.SetValueField = new string[] { "li_code" };
            li_code.Condition = "li_wccode in ('SMT','AI')";
            li_code.DbChange += nr_rule_DBChange;
        }

        SerialPort serialPort1 = new SerialPort();

        string nextLine;

        private void Clean_Click(object sender, EventArgs e)
        {
            OperateResult.Clear();
        }
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            string ExitConfirm = MessageBox.Show(this, "确认退出？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
            if (ExitConfirm != "Yes")
            {
                WindowState = FormWindowState.Minimized;
                e.Cancel = true;
            }
        }

        private void AutoStart_CheckedChanged(object sender, EventArgs e)
        {
            SetAutoRun();
        }

        //音频提示站位,料号，剩余数量信息
        private void Remind()
        {
            if (RemindVoice.Checked)
            {
                sql.Clear();
                sql.Append("SELECT 总需求数,余数,站位,料号 from(select bar_batchqty,dsl_barcode,dsl_prodcode 料号, " +
                    "dsl_location  站位,dsl_baseqty 用量,(select sum(case when dsl_getqty=0 then 1 else dsl_getqty end)" +
                    " from devsmtlocation T  where  T.dsl_location=devsmtlocation.dsl_location    and dsl_invalidtime is null) " +
                    "上料数, (select max(to_char(dsl_indate ,'MM-DD hh24:mi:ss'))  from devsmtlocation  T  where " +
                    "T.dsl_location=devsmtlocation.dsl_location  and  dsl_usable>0)接料时间,dsl_madeqty  料卷产出数, allmadeqty " +
                    " 站位产出数,DSL_VALIDTIME, dsl_remainqty,(select sum(dsl_remainqty)from devsmtlocation T  where  " +
                    "T.dsl_location=devsmtlocation.dsl_location    and dsl_invalidtime is null)余数,dsl_needqty 总需求数 " +
                    " from devsmtlocation left  join    (select DSL_LINECODE alllincode,Dsl_Location allLocation, " +
                    " sum(dsl_madeqty)allmadeqty from devsmtlocation    group by  DSL_LINECODE,Dsl_Location)A on  " +
                    " alllincode=devsmtlocation.dsl_linecode and allLocation=dsl_location left join barcode  " +
                    " on dsl_barcode = bar_code where  dsl_status=0 and dsl_usable=1)  ");
                System.Data.DataTable dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    string 站位 = dt.Rows[i]["站位"].ToString();
                    string 余数 = dt.Rows[i]["余数"].ToString();
                    string 料号 = dt.Rows[i]["料号"].ToString();
                    BaseUtil.PlaySound("站位" + 站位 + "物料" + 料号 + "数量剩余" + 余数 + "请及时接料");
                }
                if (dt.Rows.Count > 0)
                {
                    if (plc != null)
                    {
                        OperateResult write = plc.Write(Stop, 1);
                        if (write.IsSuccess)
                        {
                            OperateResult.AppendText("通过，发送指令" + Stop + "写入1\n");
                            OperateResult.ScrollToCaret();
                        }
                        else
                        {
                            OperateResult.AppendText("写入失败\n");
                            OperateResult.ScrollToCaret();
                        }

                    }
                }
            }
        }

        private void SetAutoRun()
        {
            if (AutoStart.Checked) //设置开机自启动  
            {
                string path = Application.ExecutablePath;
                RegistryKey rk = Registry.LocalMachine;
                RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run");
                rk2.SetValue("FileWatcher.exe", path);
                rk2.Close();
                rk.Close();
            }
            else //取消开机自启动  
            {
                string path = Application.ExecutablePath;
                RegistryKey rk = Registry.LocalMachine;
                RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run");
                rk2.DeleteValue("FileWatcher.exe", false);
                rk2.Close();
                rk.Close();
            }
        }

        private void ms_sncode_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                if (!dh.CheckExist("make", "ma_code='" + ma_code.Text + "'"))
                {
                    OperateResult.AppendText("工单号不存在\n");
                    OperateResult.ScrollToCaret();
                    return;
                }
                if (!dh.CheckExist("line", "li_code='" + li_code.Text + "'"))
                {
                    OperateResult.AppendText("线别不存在\n");
                    OperateResult.ScrollToCaret();
                    return;
                }
                string error = "";
                if (SN.Checked)
                {
                    OperateResult write = plc.Write(Write, 1);
                    if (write.IsSuccess)
                    {
                        OperateResult.AppendText("通过，发送指令" + Write + "写入1\n");
                        OperateResult.ScrollToCaret();
                    }
                    else
                    {
                        OperateResult.AppendText("写入失败\n");
                        OperateResult.ScrollToCaret();
                    }
                    System.Data.DataTable dt = (System.Data.DataTable)dh.ExecuteSql("select MSL_MAINSN from makesnlist where msl_sncode='" + ms_sncode.Text + "'", "select");
                    if (dt.Rows.Count > 0)
                    {
                        string MainSN = dt.Rows[0]["MSL_MAINSN"].ToString();
                        if (LogicHandler.CS_SetResultRXY(ma_code.Text, li_code.Text, MainSN, "0", li_code.Text, "OK", out error))
                        {
                            OperateResult.AppendText("SN:" + MainSN + "采集成功\n");
                            OperateResult.ScrollToCaret();
                            ms_sncode.Clear();
                        }
                        else
                        {
                            OperateResult.AppendText(error + "\n");
                            OperateResult.ScrollToCaret();
                            ms_sncode.Clear();
                        }
                    }
                    ms_sncode.Clear();
                }
            }
        }

        private void RemindTimer_Tick(object sender, EventArgs e)
        {
            Remind();
        }

        private void StartWatch_Click(object sender, EventArgs e)
        {
            BaseUtil.SetCacheData("Line", li_code.Text);
            BaseUtil.SetCacheData("Type", Type.Text);


            if (!dh.CheckExist("Make", "ma_code='" + ma_code.Text + "'"))
            {
                OperateResult.AppendText("工单号不能为空\n");
                return;
            }
            string DL_STATUSCODE = dh.getFieldDataByCondition("deviceline", "DL_STATUSCODE", "DL_LINECODE='" + li_code.Text + "' and DL_MACODE='" + ma_code.Text + "'").ToString();

            if (DL_STATUSCODE != "STARTED")
            {
                OperateResult.AppendText("机台尚未启动，请在APP上启动机台\n");
                return;
            }

            if (CountType == "")
            {
                OperateResult.AppendText("请选择计数类型\n");
                return;
            }
            if (ComPort == "")
            {
                OperateResult.AppendText("请选择串口\n");
                return;
            }
            if (Type.Text == "")
            {
                OperateResult.AppendText("请选择投入产出类型\n");
                return;
            }
            if (!dh.CheckExist("line", "li_code='" + li_code.Text + "'"))
            {
                OperateResult.AppendText("线别不能为空\n");
                return;
            }

            string ExitConfirm = MessageBox.Show(this, "确认计数器是否置为0？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
            if (ExitConfirm != "Yes")
            {
                return;
            }
            //设置按钮不可点击
            StartWatch.Enabled = false;
            ma_code.Enabled = false;
            StopWatch.Enabled = true;
            try
            {
                if (CountType == "PLC")
                {
                    plc = new HslCommunication.Profinet.Panasonic.PanasonicMewtocol();
                    plc.Station = 238;
                    HslCommunication.Core.Pipe.PipeSerialPort pipe = new HslCommunication.Core.Pipe.PipeSerialPort();
                    pipe.SerialPortInni(ComPort, 9600, 8, StopBits.One, Parity.Odd);
                    pipe.RtsEnable = false;
                    pipe.DtrEnable = false;
                    pipe.SleepTime = 20;
                    pipe.ReceiveTimeOut = 5000;
                    plc.CommunicationPipe = pipe;
                    if (Counter.Checked)
                    {
                        OperateResult write = plc.Write(UseScan, 0);
                        if (write.IsSuccess)
                        {
                            OperateResult.AppendText("通过，发送指令" + UseScan + "写入0\n");
                        }
                        else
                        {
                            OperateResult.AppendText("写入失败\n");
                        }
                    }
                    else
                    {
                        OperateResult write = plc.Write(UseScan, 2);
                        if (write.IsSuccess)
                        {
                            OperateResult.AppendText("通过，发送指令" + UseScan + "写入2\n");
                        }
                        else
                        {
                            OperateResult.AppendText("写入失败\n");
                        }
                    }
                }
                else
                {
                    serialPort1.PortName = ComPort;
                    serialPort1.BaudRate = int.Parse(BaudRate);
                    serialPort1.Open();
                }
                Timer.Start();
            }
            catch (Exception mes)
            {
                if (BaudRate == "" || ComPort == "")
                    OperateResult.AppendText(">>请先维护波特率和串口\n");
                else
                    OperateResult.AppendText(">>" + mes.Message + "\n");
            }
            OperateResult.AppendText("开始执行监控\n");
        }

        private void StopWatch_Click(object sender, EventArgs e)
        {
            StartWatch.Enabled = true;
            ma_code.Enabled = true;
            StopWatch.Enabled = false;
            serialPort1.Close();
            OperateResult.AppendText("停止执行监控\n");
        }

        bool realwritedata = false;

        private void Timer_Tick(object sender, EventArgs e)
        {
            if (CountType == "PLC")
            {
                string error = "";
                OperateResult<short> read = plc.ReadInt16(Read);
                //OperateResult.AppendText("读取数据\n");
                if (read.IsSuccess)
                {
                    if (read.Content != 0)
                    {
                        double qty = Convert.ToInt32(read.Content);
                        if (lastqty > qty)
                        {
                            lastqty = 0;
                        }
                        //else
                        //{
                        //    if (qty - lastqty > 0)
                        //    {
                        //        OperateResult write = plc.Write(Write, 1);
                        //        if (write.IsSuccess)
                        //        {
                        //            OperateResult.AppendText("通过，发送指令" + Write + "写入1\n");
                        //        }
                        //        else
                        //        {
                        //            OperateResult.AppendText("写入失败\n");
                        //        }
                        //    }
                        //}
                        NowQTY.Text = qty.ToString();
                        if (Type.Text == "投入")
                        {
                            string ma_inqty = dh.getFieldDataByCondition("make", "nvl(ma_inqty,0)", "ma_code='" + ma_code.Text + "'").ToString();
                            dh.ExecuteSql("update make set ma_inqty=nvl(ma_inqty,0)+'" + (qty - lastqty) + "' where ma_code='" + ma_code.Text + "' ", "update");
                            dh.ExecuteSql("insert into makehourcount(mhc_id,mhc_macode,mhc_indate,mhc_type,mhc_qty,mhc_linecode,mhc_pcbcount)" +
                                "values(makehourcount_seq.nextval,'" + ma_code.Text + "',sysdate,'" + Type.Text + "','" + (qty - lastqty) + "','" + li_code.Text + "','" + pr_pcbacount.Value + "')", "insert");
                        }
                        else
                        {
                            string ma_endqty = dh.getFieldDataByCondition("make", "nvl(ma_endqty,0)", "ma_code='" + ma_code.Text + "'").ToString();
                            dh.ExecuteSql("update make set ma_endqty=nvl(ma_endqty,0)+'" + (qty - lastqty) + "' where ma_code='" + ma_code.Text + "' ", "update");
                            dh.ExecuteSql("insert into makehourcount(mhc_id,mhc_macode,mhc_indate,mhc_type,mhc_qty,mhc_linecode,mhc_pcbcount)" +
                                     "values(makehourcount_seq.nextval,'" + ma_code.Text + "',sysdate,'" + Type.Text + "','" + (qty - lastqty) + "','" + li_code.Text + "','" + pr_pcbacount.Value + "')", "insert");
                        }
                        if (Counter.Checked)
                        {
                            LogicHandler.CS_SetResultRXY(ma_code.Text, li_code.Text, "", qty.ToString(), li_code.Text, "OK", out error);
                        }
                        lastqty = qty;
                    }
                }
                else
                {
                    OperateResult.AppendText("Read [D60] failed: " + read.Message);
                }
            }
            else
            {

            }
        }

        private byte[] HexStringToBytes(string hs)//十六进制字符串转byte
        {
            string a = hs.Replace(" ", "");
            int bytelength = 0;
            if (a.Length % 2 == 0)
            {
                bytelength = a.Length / 2;
            }
            else
            {
                bytelength = a.Length / 2 + 1;
            }
            byte[] b = new byte[bytelength];
            //逐个字符变为16进制字节数据
            for (int i = 0; i < bytelength; i++)
            {
                if (i == bytelength - 1)
                {
                    b[i] = Convert.ToByte(a.Substring(i * 2), 16);
                }
                else
                {
                    b[i] = Convert.ToByte(a.Substring(i * 2, 2), 16);
                }
            }
            //按照指定编码将字节数组变为字符串
            return b;
        }

        private void CleanData_Click(object sender, EventArgs e)
        {
            string ExitConfirm = MessageBox.Show(this, "确认计数器是否置为0？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
            if (ExitConfirm == "Yes")
            {
                NowQTY.Text = "0";
                OperateResult write = plc.Write(ToZero, 0);
                if (write.IsSuccess)
                {
                    OperateResult.AppendText("通过，发送指令" + ToZero + "写入0\n");
                }
                else
                {
                    OperateResult.AppendText("写入失败\n");
                }
            }
        }

        private void Setting_Click(object sender, EventArgs e)
        {
            //打开参数设置窗口，保存后刷新本窗体的参数
            AutoSMTRXYSetting settingForm = new AutoSMTRXYSetting();
            settingForm.StartPosition = FormStartPosition.CenterParent;
            if (settingForm.ShowDialog(this) == DialogResult.OK)
            {
                ReloadSettings();
                OperateResult.AppendText("参数设置已保存\n");
                OperateResult.ScrollToCaret();
            }
        }

        /// <summary>
        /// 从缓存重新加载参数设置
        /// </summary>
        private void ReloadSettings()
        {
            ComPort = GetCacheString("ComPort");
            BaudRate = GetCacheString("BaudRate");
            Read = GetCacheString("Read");
            Write = GetCacheString("Write");
            ToZero = GetCacheString("ToZero");
            CountType = GetCacheString("CountType");
            UseScan = GetCacheString("UseScan");
            Stop = GetCacheString("Stop");
            if (BaudRate == "")
            {
                BaudRate = "9600";
            }
            if (CountType == "")
            {
                CountType = "PLC";
            }
        }

        private string GetCacheString(string ParamName)
        {
            object value = BaseUtil.GetCacheData(ParamName);
            return value == null ? "" : value.ToString();
        }

        private void Counter_CheckedChanged(object sender, EventArgs e)
        {
            if (Counter.Checked)
            {
                string ExitConfirm = MessageBox.Show(this, "确认切换为计数器？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
                if (ExitConfirm == "Yes")
                {
                    OperateResult write = plc.Write(UseScan, 0);
                    if (write.IsSuccess)
                    {
                        OperateResult.AppendText("通过，发送指令" + UseScan + "写入0\n");
                    }
                    else
                    {
                        OperateResult.AppendText("写入失败\n");
                    }
                }
                else
                {
                    SN.Checked = false;
                }
            }

        }

        private void SN_CheckedChanged(object sender, EventArgs e)
        {
            if (SN.Checked)
            {
                string ExitConfirm = MessageBox.Show(this, "确认切换为扫码？", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
                if (ExitConfirm == "Yes")
                {
                    if (plc == null)
                    {
                        OperateResult.AppendText("请先开始监控\n");
                        return;
                    }
                    OperateResult write = plc.Write(UseScan, 2);
                    if (write.IsSuccess)
                    {
                        OperateResult.AppendText("通过，发送指令" + UseScan + "写入2\n");
                    }
                    else
                    {
                        OperateResult.AppendText("写入失败\n");
                    }
                }
                else
                {
                    Counter.Checked = true;
                }
            }

        }

        private void Start_Click(object sender, EventArgs e)
        {
            OperateResult write = plc.Write(Stop, 0);
            if (write.IsSuccess)
            {
                OperateResult.AppendText("通过，发送指令" + Stop + "写入0\n");
            }
            else
            {
                OperateResult.AppendText("写入失败\n");
            }
        }
    }
}