using System;
using System.Collections.Generic;
using System.Windows.Forms;
using System.Linq;
using System.Text;
using OPCAutomation;
using EventTool;

namespace M423project
{
    public class OPC
    {
        public const int TransIDMainform = 2012;

        private OPCServer opcServer;
        private OPCGroups opcGroups;
        private OPCGroup opcReadGroup;
        private OPCGroup opcWriteGroup;

        private int itmHandleClient;
        private string serverName;
        private string serverIP;
        private GroupProperty groupProperty;

        public ListenEventCreater listenEventCreater;
        public class Item
        {
            public string name;
            public int clientHandle;
            public int serverHandle;
            public object value;
            public Control control;
            public string onText;
            public string offText;
        }

        public Dictionary<string, Item> itemReadDict;
        public Dictionary<string, Item> itemWriteDict;

        public OPC(opcConfig opcConfig)
        {
            serverIP = opcConfig.serverIP;
            serverName = opcConfig.serverName;
            itmHandleClient = opcConfig.itmHandleClient;
            groupProperty = opcConfig.groupProperty;
        }
        /// <summary>
        /// 连接OPC服务器
        /// </summary>
        /// <returns></returns>
        public bool Connect()
        {
            CommonUtil.WriteLog(LogType.Inf, "开始连接OPC Server...");
            try
            {
                opcServer = new OPCServer();
                opcServer.Connect(serverName, serverIP);
                if (opcServer.ServerState==(int)OPCServerState.OPCRunning)
                {
                    CommonUtil.WriteLog(LogType.Inf, string.Format("已连接到OPC Server(ServerName:{0}, IP:{1})", serverName, serverIP));
                    return true;
                }
                else
                {
                    CommonUtil.WriteLog(LogType.Err, string.Format("连接OPC Server(ServerName:{0}, IP:{1})失败,状态：{2}", 
                        serverName, serverIP, opcServer.ServerState));
                }
            }
            catch (Exception ee)
            {
                CommonUtil.WriteLog(LogType.Exc,
                    string.Format("连接 OPC-Server 出现错误, ServerName:{0}, IP:{1}, 错误信息：{2}", serverName, serverIP,
                        ee.Message));
            }
            return false;
        }
        /// <summary>
        /// 创建组
        /// </summary>.
        /// <returns></returns>
        public bool CreateGroup()
        {
            CommonUtil.WriteLog(LogType.Inf, "开始连接创建OPC Server组列表...");
            try
            {
                OPCBrowser browser = opcServer.CreateBrowser();
                RecurBrowser(browser);
                opcGroups = opcServer.OPCGroups;
                opcReadGroup = opcGroups.Add("ReadGroup");
                opcWriteGroup = opcGroups.Add("WriteGroup");
                
                SetGroupProperty(opcReadGroup);
                SetGroupProperty(opcWriteGroup);

                listenEventCreater = new ListenEventCreater();
                opcReadGroup.DataChange+=new DIOPCGroupEvent_DataChangeEventHandler(opcReadGroup_DataChange);

                SetHandles(opcReadGroup, itemReadDict);
                SetHandles(opcWriteGroup, itemWriteDict);
                CommonUtil.WriteLog(LogType.Inf, "OPC Server 组列表创建完成");
                return true;
            }
            catch (Exception ee)
            {
                CommonUtil.WriteLog(LogType.Exc,
                    string.Format("创建OPCServer组列表出现异常：{0}", ee.Message));

            }
            return false;

        }
        /// <summary>
        /// 列出OPC服务器中所有Tag 并加入到opcBrowser中
        /// </summary>
        /// <param name="opcBrowser"></param>
        private void RecurBrowser(OPCBrowser opcBrowser)
        {
            //将所有子项全部展开，所有的Item
            opcBrowser.ShowBranches();
            opcBrowser.ShowLeafs(true);

            // 初始化item列表
            itemReadDict = new Dictionary<string, Item>();
            itemWriteDict = new Dictionary<string, Item>();

            foreach (object turn in opcBrowser)
            {
                Item item = new Item();
                item.name = turn.ToString();
                if (turn.ToString().Contains("Input"))
                {
                    itemReadDict.Add(item.name, item);
                }
                else if (turn.ToString().Contains("Output"))
                {
                    itemWriteDict.Add(item.name, item);
                }
            }

        }
        /// <summary>
        /// 设置组属性
        /// </summary>
        /// <param name="opcGroup"></param>
        private void SetGroupProperty(OPCGroup opcGroup)
        {
            opcServer.OPCGroups.DefaultGroupIsActive = groupProperty.defaultGroupIsActive;
            opcServer.OPCGroups.DefaultGroupDeadband = groupProperty.defaultGroupDeadband;
            opcGroup.UpdateRate = groupProperty.updateRate;
            opcGroup.IsActive = groupProperty.isActive;
            opcGroup.IsSubscribed = groupProperty.isSubscribed;
        }
        /// <summary>
        /// ReadGroup组数据发生变化时发生的事件
        /// </summary>
        /// <param name="TransactionID"></param>
        /// <param name="NumItems"></param>
        /// <param name="ClientHandles"></param>
        /// <param name="ItemValues"></param>
        /// <param name="Qualities"></param>
        /// <param name="TimeStamps"></param>
        private void opcReadGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            for (int i = 1; i <= NumItems; i++)
            {
                foreach (Item item in itemReadDict.Values)
                {
                    if (item.clientHandle == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        itemReadDict[item.name].value = Convert.ToInt32(ItemValues.GetValue(i));
                        string state = item.name; // 改变的item的名称
                        item.value = ItemValues.GetValue(i);
                        listenEventCreater.ChangeValue(new EventData(item));
                    }
                }
            }
        }
     
        /// <summary>
        /// 为组内每一个Item设置serverHandle与clientHandle
        /// </summary>
        /// <param name="opcGroup"></param>
        /// <param name="itemDict"></param>
        /// <returns></returns>
        private bool SetHandles(OPCGroup opcGroup, Dictionary<string, Item> itemDict)
        {
            OPCItems opcItems;
            OPCItem opcItem;
            opcItems = opcGroup.OPCItems;
            foreach (var item in itemDict.Values)
            {
                item.clientHandle = itmHandleClient;
                itmHandleClient++;
                opcItem = opcItems.AddItem(item.name, item.clientHandle);
                item.serverHandle = opcItem.ServerHandle;
            }
            return true;
        }
        /// <summary>
        /// 异步写
        /// </summary>
        /// <param name="name"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public bool Write(string name, object value)
        {
            Array serverHandles = new int[2] { 0, itemWriteDict[name].serverHandle };
            Array values; // = new object[2] { "", value.ToString()};
            Array Errors;
            int cancelID;
            values = new object[2] { "", value.ToString() };
            opcWriteGroup.AsyncWrite(1, ref serverHandles, ref values, out Errors, TransIDMainform, out cancelID);
            GC.Collect();
            return true;
        }

        public bool Write(string name, object value, ref string warning)
        {
            Array serverHandles = new int[2] { 0, itemWriteDict[name].serverHandle };
            Array values = new object[2] { "", value.ToString() };
            Array Errors;
            int cancelID;

            try
            {
                opcWriteGroup.AsyncWrite(1, ref serverHandles, ref values, out Errors, TransIDMainform, out cancelID);
            }
            catch (Exception e)
            {
                warning = e.Message;

                GC.Collect();
                return false;
            }

            GC.Collect();
            return true;
        }

        public bool Write(OPCGroup group, int handle, object value, ref string warning)
        {
            Array serverHandles = new int[2] { 0, handle };
            Array values = new object[2] { "", value.ToString() };
            Array Errors;
            int cancelID;

            try
            {
                group.AsyncWrite(1, ref serverHandles, ref values, out Errors, TransIDMainform, out cancelID);
            }
            catch (Exception e)
            {
                warning = e.Message;

                GC.Collect();
                return false;
            }

            GC.Collect();
            return true;
        }

        public bool ReadOneItem_Wrapper(string name, ref object result)
        {
            Item item;

            if (itemReadDict.ContainsKey(name))
            {
                item = itemReadDict[name];
                ReadOneItem(ref item, opcReadGroup);
                result = item.value;
                itemReadDict[name].value = result;
            }
            else if (itemWriteDict.ContainsKey(name))
            {
                item = itemWriteDict[name];
                ReadOneItem(ref item, opcWriteGroup);
                result = item.value;
                itemWriteDict[name].value = result;
            }
            else
            {
                return false;
            }

            return true;
        }

        public bool ReadOneItem(ref Item item, OPCGroup opcGroup)
        {
            Array serverHandles;
            Array values;
            Array errors;
            object qualities;
            object timeStamps;

            serverHandles = new int[2] { 0, item.serverHandle };
            opcGroup.SyncRead(1, 1, ref serverHandles, out values, out errors, out qualities, out timeStamps);
            item.value = values.GetValue(1);

            GC.Collect();

            return true;
        }

        internal void Close()
        {
            opcServer.Disconnect();
        }
    }
}