C#OPC数据采集（FORM）
2021-01-26 18:16
标签：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("成功读取变量为的数据.值为");
}
/* if (values[0].Quality.Equals(Opc.Da.Quality.Good))
{ // textBox3.Text = values[0].Value.ToString();
ls.Items.Add("成功读取变量为的数据.值为");
}
* */
/* }
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点位
Listnew List
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() &