码迷，mamicode.com
首页 > Windows程序 > 详细

C#OPC数据采集（FORM）

时间：2019-12-02 15:13:39      阅读：118      评论：0      收藏：0      [点我收藏+]

标签：pen   proc   释放   nta   x86   lse   enable   rom   subscript   

using System;
using System.Windows.Forms;
using Opc;
using Opc.Da;
using OpcCom;
using opc_Library;
using opcTest.model;
using System.Collections.Generic;
 
namespace opc_collection
{
    public partial class Form1 : Form
    {
        private Opc.Da.Server m_server =null;//定义数据存取服务器
             
        private Opc.Da.Subscription subscription = null;//定义组对象（订阅者）
        private Opc.Da.SubscriptionState state = null;//定义组（订阅者）状态，相当于OPC规范中组的参数
        private Opc.IDiscovery m_discovery = new ServerEnumerator();//定义枚举基于COM服务器的接口，用来搜索所有的此类服务器。
        //时钟
        private Timer _timer = new Timer();
        //写日志记录
        write_log write_log = new write_log();
        public Form1()
        {
            InitializeComponent();
            // _timer.Interval = 2000;
            _timer.Enabled = false;
            _timer.Tick  = MainProcess;
            textBox1.Text = "192.168.1.100";
            //  button2.Enabled = false;
            //  button3.Enabled = false;
        }
          
        private void button1_Click(object sender, EventArgs e)
        {
            comboBox1.Items.Clear();
            //查询服务器
            try
            {
              string str=  Specification.COM_DA_20.ToString();
                Opc.Server[] servers = m_discovery.GetAvailableServers(Specification.COM_DA_20, textBox1.Text.ToString().Trim(), null);
                if (servers != null)
                {
                    foreach (Opc.Da.Server server in servers)
                    {
                        comboBox1.Items.Add(server.Name);
                    }
                }
               // comboBox1.SelectedIndex = 0;
            ls.Items.Add("查询服务器成功.请选择OPC进行连接");
            write_log.write_log_txt("查询服务器成功.请选择OPC进行连接");
 
              //  button1.Enabled = false;
                button2.Enabled = true;
            }
            catch (Exception ex)
            {
 
               ls.Items.Add(ex.Message);
               write_log.write_log_txt(ex.ToString());
            }
        }
 
        private void button2_Click(object sender, EventArgs e)
        {
            //连接
            if (button2.Text=="释放")
            {
                //结束：释放各资源
                button2.Text = "连接";
                ls.Items.Add("释放成功.不能进行读取数据,请重新连接");
                write_log.write_log_txt("释放成功.不能进行读取数据,请重新连接");
                btn_conllection.Enabled = false;
                try
                {
                    subscription.Dispose();//强制.NET资源回收站回收该subscription的所有资源。        
                    m_server.Disconnect();//断开服务器连接
                }
                catch (Exception ex)
                {
                    ls.Items.Add(ex.Message);
                    write_log.write_log_txt(ex.ToString());
                }
            }
            else
            {
                try
                {
                    Opc.Server[] servers = m_discovery.GetAvailableServers(Specification.COM_DA_20, textBox1.Text, null);
                    if (servers != null)
                    {
                        foreach (Opc.Da.Server server in servers)
                        {
                            if (String.Compare(server.Name, comboBox1.Text, true) == 0)//为true忽略大小写
                            {
                                m_server = server;//建立连接。
                                break;
                            }
                        }
                    }
                }
                catch (Exception ex)
                { 
                    ls.Items.Add(ex.Message);
                    write_log.write_log_txt(ex.ToString());
                    return;
                }
                if (m_server != null)
                {
                    try
                    {
                        m_server.Connect();
                       ls.Items.Add("OPC服务器连接成功,请填写变量名称进行读取数据");
                       write_log.write_log_txt("OPC服务器连接成功.");
                      
                        button2.Text = "释放";
                        btn_conllection.Enabled = true;                         
                    }
                    catch (Exception ex)
                    {
                        ls.Items.Add(ex.Message); 
                    } 
                }
                else
                {
                    ls.Items.Add("连接失败,请检查IP以及服务器对象");
                    write_log.write_log_txt("连接失败,请检查IP以及服务器对象");
                }
            }
        }
 
        private void button3_Click(object sender, EventArgs e)
        {
         _timer.Interval =Int32.Parse(txt_time.Text.ToString().Trim());
         _timer.Enabled = true;
 
           // l_m.Clear();
            //   xm.xml_to_model("XML_opc.xml");
          //  l_m = xm.get_monitor_Xml_m_all();
       //     Item[] items = new Item[100];//定义数据项，即item
            int i = 0;
        /*    string daname = string.Empty;
            foreach (var e_1 in l_m)    //遍历集合
            {
             //   items[i].ClientHandle = Guid.NewGuid().ToString();//客户端给该数据项分配的句柄。
             //   items[i].ItemPath = null; //该数据项在服务器中的路径。
             //   items[i].ItemName = e_1.Opc_da;//itemName[0]; //该数据项在服务器中的名字。
             //   i  ;
                daname = e_1.Opc_da;
            }
            try
            {
                state = new Opc.Da.SubscriptionState();//组（订阅者）状态，相当于OPC规范中组的参数
                state.Name = "newGroup";//组名
                state.ServerHandle = null;//服务器给该组分配的句柄。
                state.ClientHandle = Guid.NewGuid().ToString();//客户端给该组分配的句柄。
                state.Active = true;//激活该组。
                state.UpdateRate = 100;//刷新频率为1秒。
                state.Deadband = 0;// 死区值，设为0时，服务器端该组内任何数据变化都通知组。
                state.Locale = null;//不设置地区值。
 
                subscription = (Opc.Da.Subscription)m_server.CreateSubscription(state);//创建组
                ls.Items.Add("1");
                string[] itemName = new string[] {""};
                ls.Items.Add("2");
                itemName[0] = daname;
                ls.Items.Add("2.1");
                Item[] items = new Item[1];//定义数据项，即item
                items[0] = new Item();
                items[0].ClientHandle = Guid.NewGuid().ToString();//客户端给该数据项分配的句柄。
                items[0].ItemPath = null; //该数据项在服务器中的路径。
                items[0].ItemName = itemName[0]; //该数据项在服务器中的名字。
                subscription.AddItems(items);
                ls.Items.Add("3");
                ItemValueResult[] values =  subscription.Read(subscription.Items);
                ls.Items.Add("4");
                ls.Items.Add(items[0].Key.ToString());
               // ls.Items.Add(values[0].Value.ToString() );
               // ls.Items.Add(values[1].Value.ToString());
                try
                {
                     
                    foreach (ItemValueResult value in values)
                    {
                       ls.Items.Add("5");
                       ls.Items.Add("成功读取变量为<"   daname   ">的数据.值为<"   value.Value.ToString()   ">");
                    }
            /*        if (values[0].Quality.Equals(Opc.Da.Quality.Good))
                    {                        
                        // textBox3.Text = values[0].Value.ToString();
                        ls.Items.Add("成功读取变量为<"   daname   ">的数据.值为<"   values[0].Value.ToString()   ">");
                    }
             * */
       /*         }
                catch (Exception e2)
                {
                    ls.Items.Add("e2:" e2.ToString());
                }
                subscription.RemoveItems(subscription.Items);
                m_server.CancelSubscription(subscription);//m_server前文已说明，通知服务器要求删除组。
            }
            catch (Exception ex)
            { 
                ls.Items.Add(ex.Message);
            }
*/
        }
 
     //Form界面控制部分 
     #region Form_Monitor   
 
        private void alert(string msg)
        {
            MessageBox.Show(msg, "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
        }
 
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (e.CloseReason == CloseReason.UserClosing)//当用户点击窗体右上角X按钮或(Alt   F4)时 发生           
            {
                e.Cancel = true;
                this.ShowInTaskbar = false;
                this.notifyIcon1.Icon = this.Icon;
                this.Hide();
            } 
        }
 
        private void notifyIcon1_MouseClick(object sender, MouseEventArgs e)
        {
            if (e.Button == MouseButtons.Right)
            {
                mymenu.Show(System.Windows.Forms.Cursor.Position.X, System.Windows.Forms.Cursor.Position.Y);
                mymenu.Show();
            }
 
            if (e.Button == MouseButtons.Left)
            {
                this.Visible = true;
                mymenu.Hide();
                this.Icon = Resource1._20151104082741597_easyicon_net_256;
                this.WindowState = FormWindowState.Normal;
            }        
        }
 
        private void mymenu_Click(object sender, EventArgs e)
        {
 
        }
 
        private void mymenu_Opening(object sender, System.ComponentModel.CancelEventArgs e)
        {
 
        }
 
        private void mymenu_child_Click(object sender, EventArgs e)
        {
            Application.Exit();  
        }
 
        private void Form1_MinimumSizeChanged(object sender, EventArgs e)
        {
            if (this.WindowState == FormWindowState.Normal && this.Visible == true)
            { 
                this.notifyIcon1.Visible = true;//在通知区显示Form的Icon 
                this.WindowState = FormWindowState.Minimized; 
                this.Visible = false; 
                this.ShowInTaskbar = false;//使Form不在任务栏上显示 
            } 
        }
  #endregion
        private void btn_stop_Click(object sender, EventArgs e)
        {
            _timer.Enabled = false;
            ls.Items.Clear();
        } 
        //重新加载OPC点位
        List<monitor> l_m = new List<monitor>();
        xml_to_model xm = new xml_to_model("XML_opc.xml");
        string daname = string.Empty;
        public void MainProcess(object sender, EventArgs e)
        {
            l_m.Clear();
         //   xm.xml_to_model("XML_opc.xml");
            l_m=xm.get_monitor_Xml_m_all();
       //     Item[] items = new Item[100];//定义数据项，即item
        //    int i = 0;
            
        //    foreach (var e_1 in l_m)  //遍历集合
         //   {
 
            foreach (var e_1 in l_m)    //遍历集合
            {
                daname = e_1.Opc_da; 
                try
                {
                    state = new Opc.Da.SubscriptionState();//组（订阅者）状态，相当于OPC规范中组的参数
                    state.Name = "newGroup";//组名
                    state.ServerHandle = null;//服务器给该组分配的句柄。
                    state.ClientHandle = Guid.NewGuid().ToString();//客户端给该组分配的句柄。
                    state.Active = true;//激活该组。
                    state.UpdateRate = 100;//刷新频率为1秒。
                    state.Deadband = 0;// 死区值，设为0时，服务器端该组内任何数据变化都通知组。
                    state.Locale = null;//不设置地区值。
 
                    subscription = (Opc.Da.Subscription)m_server.CreateSubscription(state);//创建组
                    ls.Items.Add("1");
                    string[] itemName = new string[] { "" };
                    ls.Items.Add("2");
                    itemName[0] = daname;
                    ls.Items.Add("2.1");
                    Item[] items = new Item[1];//定义数据项，即item
                    items[0] = new Item();
                    items[0].ClientHandle = Guid.NewGuid().ToString();//客户端给该数据项分配的句柄。
                    items[0].ItemPath = null; //该数据项在服务器中的路径。
                    items[0].ItemName = itemName[0]; //该数据项在服务器中的名字。
                    subscription.AddItems(items);
                    ls.Items.Add("3");
                    ItemValueResult[] values = subscription.Read(subscription.Items);
                    ls.Items.Add("4");
                    ls.Items.Add(items[0].Key.ToString());
                    // ls.Items.Add(values[0].Value.ToString() );
                    // ls.Items.Add(values[1].Value.ToString());
                    try
                    {
 
                       // foreach (ItemValueResult value in values)
                      //  {
                            ls.Items.Add("5");
                            #region
                            //插入DB OPCMAP
                            Db_Access dba = new Db_Access();
                            //判断MAP表里是否有该DA
                            ReadXml readxml = new ReadXml();
                            string[] db_name_insert = readxml.getXml_node("2", "db_name", "XML_db.xml");
                            string db_name = db_name_insert[0];
                            string map_isexists = @"select count(opc_id) from";
                            map_isexists = map_isexists   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map]";
                            write_log.write_log_txt(map_isexists);
                            if (dba.get_sql_int("2", map_isexists) == 0)
                            {
                                string map_insert = @"INSERT INTO ";
                                map_insert = map_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map]([opc_id]" 
                                " ,[opc_da],[opc_name],[opc_type],[c_flag])"   " "   "select "   "‘"   "1"   "‘,"   "‘"   e_1.Opc_da.Trim()   "‘,"   "‘"   e_1.Opc_name.Trim()   "‘"   ","   "‘"   e_1.Opc_type.Trim()   "‘,"   "‘"   e_1.C_flag.Trim()   "‘";
                                write_log.write_log_txt(map_insert);
                                if (dba.get_sql_opreate("2", map_insert) == "1")
                                {
                                    //获取插入的OPC ID
                                    string opc_id_sql = @"select top 1 opc_id from";
                                    opc_id_sql = opc_id_sql   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map] where opc_name=‘"   e_1.Opc_name.Trim()   "‘";
                                    write_log.write_log_txt(opc_id_sql );
                                    string opc_id = dba.get_sql_opreate("2", opc_id_sql);
                                    string opc_insert = @"INSERT INTO ";
                                    opc_insert = opc_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc]([opc_id]"
                                          ",opc_value,collection_time)"   "select "   "‘"   opc_id.Trim()   "‘,"   "‘"  "0.01"  "‘,"   "‘"   DateTime.Now.ToString()   "‘";
                                //  opc_insert = opc_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc]([opc_id]"
                                //          ",opc_value,collection_time)"   "select "   "‘"   opc_id.Trim()   "‘,"   "‘"  values[0].Value.ToString().Trim()   "‘,"   "‘"   DateTime.Now.ToString()   "‘";
                                    write_log.write_log_txt(opc_insert );
                                    if (dba.get_sql_opreate("2", opc_insert) == "0")
                                    {
                                        write_log.write_log_txt("插入OPC数据表失败，请检查程序。");
                                    }
                                }
                                else
                                {
                                    write_log.write_log_txt("插入OPC配置表失败，请检查程序。");
                                }
                            }
 
                            if (dba.get_sql_int("2", map_isexists) > 0)
                            {
 
                                //获取插入的OPC ID
                                string opc_id_sql = @"select count(opc_id) from";
                                opc_id_sql = opc_id_sql   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map] where opc_name=‘"   e_1.Opc_name.Trim()   "‘";
                                write_log.write_log_txt(">0:"   opc_id_sql);
                               // string opc_id = dba.get_sql_opreate("2", opc_id_sql);
                                int opc_id_flag = dba.get_sql_int("2", opc_id_sql);
                                string opc_id = string.Empty;
                                if (opc_id_flag > 0)
                                {
                                     string opc_id_sql_1 = @"select top 1 opc_id from";
                                     opc_id_sql_1 = opc_id_sql_1   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map] where opc_name=‘"   e_1.Opc_name.Trim()   "‘";
 
                                    opc_id = dba.get_sql_str("2", opc_id_sql_1);
                                }
                                if (opc_id_flag == 0)
                                {
 
 
                                    string opc_id_sql_1 = @"select max(opc_id) 1 from";
                                    opc_id_sql_1 = opc_id_sql_1   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map]";
 
                                  string   opc_id_map= dba.get_sql_str("2", opc_id_sql_1);
 
                                    string map_insert = @"INSERT INTO ";
                                    map_insert = map_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map]([opc_id]" 
                                    " ,[opc_da],[opc_name],[opc_type],[c_flag])"   " "   "select "   "‘"   opc_id_map   "‘,"   "‘"   e_1.Opc_da.Trim()   "‘,"   "‘"   e_1.Opc_name.Trim()   "‘"   ","   "‘"   e_1.Opc_type.Trim()   "‘,"   "‘"   e_1.C_flag.Trim()   "‘";
                                    dba.get_sql_opreate("2",map_insert);
                                    string opc_id_sql_2 = @"select top 1 opc_id from";
                                    opc_id_sql_2 = opc_id_sql_2   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc_map] where opc_name=‘"   e_1.Opc_name.Trim()   "‘";
 
                                    opc_id = dba.get_sql_str("2", opc_id_sql_2);
                                }
                                string opc_insert = @"INSERT INTO ";
                                opc_insert = opc_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc]([opc_id]"
                                      ",opc_value,collection_time)"   "select "   "‘"   opc_id.Trim()   "‘,"   "‘"   "0.00"  "‘,"   "‘"   DateTime.Now.ToString()   "‘";
                            //    opc_insert = opc_insert   " "   "[".Trim()   db_name.Trim()   "]".Trim()   ".".Trim()   "[dbo]".Trim()   ".".Trim()   "[tb_opc]([opc_id]"
                             //     ",opc_value,collection_time)"   "select "   "‘"   opc_id.Trim()   "‘,"   "‘"   values[0].Value.ToString().Trim()   "‘,"   "‘"   DateTime.Now.ToString()   "‘";
                        
                                write_log.write_log_txt(">0:"   opc_insert);
                                if (dba.get_sql_opreate("2", opc_insert) == "0")
                                {
                                    write_log.write_log_txt("插入OPC数据表失败，请检查程序。");
                                }
                            }
                            #endregion
                            ls.Items.Add(new ListViewItem(new string[] { e_1.Opc_da.Trim(), e_1.Opc_name.Trim(), values[0].Value.ToString().Trim(), DateTime.Now.ToString() }));
                            write_log.write_log_txt(e_1.Opc_da   "  "   e_1.Opc_name   "  "   values[0].Value.ToString()   "  "   DateTime.Now.ToString());
                    //    }
                        /*        if (values[0].Quality.Equals(Opc.Da.Quality.Good))
                                {
                        
                                    // textBox3.Text = values[0].Value.ToString();
                                    ls.Items.Add("成功读取变量为<"   daname   ">的数据.值为<"   values[0].Value.ToString()   ">");
                                }
                         * */
                    }
                    catch (Exception e2)
                    {
                        ls.Items.Add("e2:"   e2.ToString());
                    }
                    subscription.RemoveItems(subscription.Items);
                    m_server.CancelSubscription(subscription);//m_server前文已说明，通知服务器要求删除组。
                }
                catch (Exception ex)
                { 
                    ls.Items.Add(ex.Message);
                }
            }                 
            }         
    }
}

C#OPC数据采集（FORM）

标签：pen   proc   释放   nta   x86   lse   enable   rom   subscript   

原文地址：https://www.cnblogs.com/keepdoit/p/11970650.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！