using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using OPCAutomation;

using System.Threading;

namespace SPCTest

{

    public partial class Form2 : Form

    {

        private OPCServer KepServer;

        private OPCGroups KepGroups;

        private OPCGroup KepGroup;

        private OPCItems KepItems;

        //轴承净重，注脂量，防尘盖压入深度，防尘盖平整度   压入OK/NG

        private OPCItem item1, item2, item3;

        public Form2()

        {

            InitializeComponent();

        }

        #region OPC Server

        private void KepServerLoad()

        {

            try

            {

                KepServer = new OPCServer();

                KepServer.Connect("KEPware.KEPServerEx.V4", "127.0.0.1");

                if (KepServer.ServerState == (int)OPCServerState.OPCRunning)

                {

                   // statusLabelConnectInfo.Text = "OPC Server连接成功";

                }

                else

                {

                   // statusLabelConnectInfo.Text = "OPC Server连接失败";

                    return;

                }

            }

            catch (Exception ex)

            {

               // statusLabelConnectInfo.Text = "OPC Server连接失败," + ex.Message;

                return;

            }

            KepGroups = KepServer.OPCGroups;

            Thread t1; // 开1个线程用于读取数据

            t1 = new Thread(new ThreadStart(KepProcess));

            t1.Start();

        }

        public void KepProcess()

        {

            //KepGroup = KepGroups.Add("Channel.Device.Group");

            KepGroup = KepGroups.Add("Channel1.Device1.Group");

            KepGroup.UpdateRate = ;

            KepGroup.IsActive = true;

            KepGroup.IsSubscribed = true;

            //当KepGroup中数据发生改变的触发事件

            KepGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(KepGroup_DataChange);

            KepItems = KepGroup.OPCItems;

            item1 = KepItems.AddItem("Channel1.Device1.A01", );

            item2 = KepItems.AddItem("Channel1.Device1.A02", );

            item3 = KepItems.AddItem("Channel1.Device1.A03", );

        }

        //当数据改变时触发的事件

        public delegate void DelegateShowMessage(string str);

        public void KepGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)

        {

            string str = "";

            DelegateShowMessage show1 = new DelegateShowMessage(ShowMessage);

            for (int i = ; i <= NumItems; i++)

            {

                if (ClientHandles.GetValue(i).Equals())

                {

                    str = "A01:" + ItemValues.GetValue(i).ToString();

                }

                if (ClientHandles.GetValue(i).Equals())

                {

                    str = "A02:" + ItemValues.GetValue(i).ToString();

                }

                if (ClientHandles.GetValue(i).Equals())

                {

                    str = "A03:" + ItemValues.GetValue(i).ToString();

                }

                BeginInvoke(show1, new string[] { str });

            }

        }

        public void ShowMessage(string str)

        {

            richTextBox1.AppendText(str+",");

        }

        #endregion

        private void Form2_Load(object sender, EventArgs e)

        {

            KepServerLoad();

        }

        private void Form2_FormClosing(object sender, FormClosingEventArgs e)

        {

            KepServer.Disconnect();

        }

    }

}