C# OPC 数据采集

C#语言基础
下载此实例
开发语言：C#
实例大小：50.42M
下载次数：784
浏览次数：7835
发布时间：2016-07-21
实例类别：C#语言基础
发布人：libaofeng_1_1
文件格式：.rar
所需积分：6
实例介绍

【实例简介】
【实例截图】
【核心代码】
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#
实例下载地址

C# OPC 数据采集

点此下载实例
不能下载？内容有错？点击这里报错 + 投诉 + 提问
好例子网口号：伸出你的我的手 — 分享！
网友评论

我要评论
第 1 楼 surfer 发表于: 2017-02-28 16:19 03: 不错，收藏之
支持(0) 盖楼(回复)
第 2 楼 shenglangle 发表于: 2020-11-20 02:27 05: 可以运行，不过只能到32位系统中才可以运行，64位无法注册DLL
支持(0) 盖楼(回复)
第 3 楼 shenglangle 发表于: 2021-02-06 14:06 28: 还可以，改改就能用
支持(0) 盖楼(回复)
第 4 楼 wanglongming 发表于: 2021-04-07 15:12 49: OpcRcw.Dx东西我是加载进去的，但是还是显示的未加载这个文件，该如何解决？
支持(0) 盖楼(回复)
第 5 楼 wanglongming 发表于: 2021-04-07 15:12 52: OpcRcw.Dx东西我是加载进去的，但是还是显示的未加载这个文件，该如何解决？
支持(0) 盖楼(回复)
小贴士

感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网

本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见版权及免责申明
C# OPC 数据采集

同类人气实例

实例介绍

实例下载地址

C# OPC 数据采集

相关软件

相关文章

网友评论

小贴士

关于好例子网

下载周排行

下载总排行
