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); } } } }}