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

namespace LLMF
{
    public class OPC
    {
        public const int TransIDMainform = 2012;
        public const int TransIDSetttings = 2013;
        public const int ReadTagNum = 3;

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

        private int itmHandleClient;
        private string serverIP;
        private string serverName;
        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 AlarmState alarmState;
        }

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

        public OPC(OPCConfig opcConfig)
        {
            serverIP = opcConfig.serverIP;
            serverName = opcConfig.serverName;
            itmHandleClient = opcConfig.itmHandleClient;
            groupProperty = opcConfig.groupProperty;
        }

        public enum AlarmState
        {
            Ready,
            NReady,
            Alarm,
            Warning
        }

        /// <summary>
        /// 连接OPC服务器
        /// </summary>
        public bool Connect()
        {
            try
            {
                opcServer = new OPCServer();
                opcServer.Connect(serverName, serverIP);
                if (opcServer.ServerState == (int) OPCServerState.OPCRunning)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }
            catch (Exception err)
            {
                MessageBox.Show("连接 OPC-Server 出现错误：" + err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                return false;
            }
        }

        /// <summary>
        /// 列出OPC服务器中所有Tag 并加入到opcBrowser中
        /// </summary>
        /// <param name="opcBrowser"></param>
        private void RecurBrowse(OPCBrowser opcBrowser)
        {
            //展开分支
            opcBrowser.ShowBranches();
            //展开叶子
            opcBrowser.ShowLeafs(true);
            // 初始化item列表
            itemReadDict = new Dictionary<string, Item>();
            itemWriteDict = new Dictionary<string, Item>();
            itemRobotDict = 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="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));
                        switch (state)
                        {
                               
                              //I/O界面输入显示
                            case InputTag.X_JinDian:
                            case InputTag.Z_JinDian:
                           
                            case InputTag.X_CW:
                            case InputTag.X_CCW:
                            case InputTag.Z_CW:
                            case InputTag.Z_CCW:
                            case InputTag.DingWei_CW:
                            case InputTag.DingWei_CCW:
                            case InputTag.DingWei_JinDian:
                           
                            case InputTag.Reset:
                           
                            
                            case InputTag.OpenJieJin:
                            case InputTag.CeBianQian:
                            case InputTag.CeBianHou:
                            case InputTag.WuGanQian:
                            case InputTag.WuGanHou:
                                    SignalSensorAndElse(item,true);
                                    break;        //传感器、轴和其他信号
                                case InputTag.Start1:
                                case InputTag.Start2:
                                    SignalSensorAndElse(item, false);
                                    break;        //传感器、轴和其他信号
                                case InputTag.X_Alarm:
                                case InputTag.Z_Alarm:
                                case InputTag.E_Stop:
                                case InputTag.SafeCurtain:
                                case InputTag.DingWei_Alarm:
                                    SignalAlarm(item);
                                    break;        //报警信号

                        }
                    }
                }
            }
        }
        public void SignalSensorAndElse(Item item, bool IsPlus)
        {
            if (item.control != null)
            {
                if (IsPlus)
                {
                    if (Convert.ToBoolean(item.value))
                    {
                        item.control.BackColor = System.Drawing.Color.Green;
                    }
                    else
                    {
                        item.control.BackColor = System.Drawing.Color.Gray;
                    }
                }
                else
                {
                    if (Convert.ToBoolean(item.value))
                    {
                        item.control.BackColor = System.Drawing.Color.Gray;
                    }
                    else
                    {
                        item.control.BackColor = System.Drawing.Color.Green;
                    }

                }
            }
        }
        public void SignalAlarm(Item item)
        {
            if (item.control != null)
            {

                if (Convert.ToBoolean(item.value))
                {
                    item.control.BackColor = System.Drawing.Color.Gray;
                }
                else
                {
                    item.control.BackColor = System.Drawing.Color.Red;
                }
            }

        }
        private void opcRobotGroup_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 itemRobotDict.Values)
                {
                    if (item.clientHandle == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        itemRobotDict[item.name].value = Convert.ToInt32(ItemValues.GetValue(i));
                        string state = item.name; // 改变的item的名称
                        item.value = ItemValues.GetValue(i);
                        listenEventCreater.ChangeValue(new EventData(item));
                    }
                }
            }
        }

        private void opcWriteGroup_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 itemWriteDict.Values)
                {
                    if (item.clientHandle == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        itemWriteDict[item.name].value = Convert.ToInt32(ItemValues.GetValue(i));
                        item.value = ItemValues.GetValue(i);
                        listenEventCreater.ChangeValue(new EventData(item));
                        string state = item.name; // 改变的item的名称
                        switch (state)
                        {
                            //I/O界面输出显示
                            case OutputTag.Red:
                            case OutputTag.Yellow:
                            case OutputTag.Green:
                            case OutputTag.Buzzer:
                            case OutputTag.CeBianCylider:
                            case OutputTag.ZhengBianCylider:
                            case OutputTag.WuGanCylider:
                            case OutputTag.HuaTaiCylider
:
                            case OutputTag.SiFuPowerOn:
                            case OutputTag.X_SRV_ON:
                            case OutputTag.Z_SRV_ON:
                            case OutputTag.DingWei_SRV_ON
:

                            case OutputTag.Z_ShaChe:
                            case OutputTag.ForApple
:
                            case OutputTag.CameraLighto:
                            case OutputTag.WuGanCylider2:
                            
                                SignalSensorAndElse(item, true);
                                break;
                        }

                    }
                }
            }

        }

        /// <summary>
        /// 创建Group
        /// </summary>
        /// <returns></returns>
        public bool CreateGroup()
        {
            try
            {
                OPCBrowser browser = opcServer.CreateBrowser();
                RecurBrowse(browser); // 建立读字典和写字典

                opcGroups = opcServer.OPCGroups;
                opcReadGroup = opcGroups.Add("ReadGroup");
                opcWriteGroup = opcGroups.Add("WriteGroup");
                opcRobotGroup = opcGroups.Add("RobotGroup");

                /* 设置监听相关属性 */
                SetGroupProperty(opcReadGroup);
                SetGroupProperty(opcWriteGroup);
                SetGroupProperty(opcRobotGroup);

                listenEventCreater = new ListenEventCreater();  // 初始化监听
                opcReadGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(opcReadGroup_DataChange);     // 读区域数据变化
                opcWriteGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(opcWriteGroup_DataChange);   // 写区域数据变化

                /* 设置handles */
                SetHandles(opcReadGroup, itemReadDict);
                SetHandles(opcWriteGroup, itemWriteDict);
            }
            catch (Exception err)
            {
                MessageBox.Show("创建组出现错误：" + err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                return false;
            }
            return true;
        }


        /// <summary>
        /// 设置属性
        /// </summary>
        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>
        /// 设置ClientHandles和ServerHandles
        /// </summary>
        /// <param name="opcGroup"></param>
        /// <returns></returns>
        public 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);
            //KepItem.Write(txtWriteTagValue.Text);//这句也可以写入，但并不触发写入事件
            
            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);
                //KepItem.Write(txtWriteTagValue.Text);//这句也可以写入，但并不触发写入事件
            }
            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);
                //KepItem.Write(txtWriteTagValue.Text);//这句也可以写入，但并不触发写入事件
            }
            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();
        }

    } 
}