using Bro.Common.Interface;
using Newtonsoft.Json;
using System;
using System.Threading;

namespace Bro.Common.Base
{
    public class InputConfigBase : IInputConfig
    {
        //public InputConfigBase()
        //{
        //    StateMachine.OnDeviceInput += OnDeviceInput;
        //}

        //[JsonIgnore]
        //public AutoResetEvent InputHanlder { get; set; } = new AutoResetEvent(false);

        // [JsonIgnore]
        //public string IConfigId = Guid.NewGuid().ToString();

        //[JsonIgnore]
        //public Dictionary<string, AutoResetEvent> InputHanlderDict { get; set; } = new Dictionary<string, AutoResetEvent>();

        //[JsonIgnore]
        //public Dictionary<string, bool> InputFlagDict { get; set; } = new Dictionary<string, bool>();

        //[JsonIgnore]
        //public ConcurrentDictionary<string, AutoResetEvent> InputHanlderDict { get; set; } = new ConcurrentDictionary<string, AutoResetEvent>();

        //[JsonIgnore]
        //public ConcurrentDictionary<string, bool> InputFlagDict { get; set; } = new ConcurrentDictionary<string, bool>();

        [JsonIgnore]
        public bool BoundFlag { get; set; } = false;

        public bool IsInputNeed { get; set; } = false;

        public string InputMethodName { get; set; }

        /// <summary>
        /// 第三方设备输入参数
        /// </summary>
        [JsonIgnore]
        public dynamic InputPara { get; set; }

        private string processId;
        [JsonIgnore]
        public string ProcessId
        {
            get
            {
                return processId;
            }
            set
            {
                if (processId != value)
                {
                    //仅在工序编号赋值后建立消息连接
                    processId = value;

                    //if (conn == null)
                    //{
                    //    conn = new HubConnection(GlobalVar.SignalRServer);

                    //    proxy = conn.CreateHubProxy("DeviceHub");
                    //    proxy.On<InputPara>("OnDeviceInput", OnDeviceInput);

                    //    conn.Start().Wait();
                    //}
                    //lock (this)
                    {
                        //InputHanlderDict[processId] = new AutoResetEvent(false);
                        //InputFlagDict[processId] = false;
                        //InputHanlderDict.AddOrUpdate(processId, new AutoResetEvent(false), (a, b) => { return new AutoResetEvent(false); });
                        //InputFlagDict.AddOrUpdate(processId, false, (a, b) => { return false; });

                        InputHandle = new AutoResetEvent(false);
                        //StateMachine.OnDeviceInput += OnDeviceInput;
                    }

                    //if (StateMachine.OnDeviceInput != null)
                    //{
                    //    var list = StateMachine.OnDeviceInput.GetInvocationList().ToList();
                    //    if (list != null)
                    //    {
                    //        if (!list.Any(d =>
                    //        {
                    //            InputConfigBase icb = d.Target as InputConfigBase;
                    //            return icb.ProcessId == ProcessId;
                    //        }))
                    //        {
                    //            StateMachine.OnDeviceInput += OnDeviceInput;
                    //        }
                    //    }
                    //    else
                    //    {
                    //        StateMachine.OnDeviceInput += OnDeviceInput;
                    //    }
                    //}
                    //else
                    //{
                    //StateMachine.OnDeviceInput += OnDeviceInput;
                    //PubSubCenter.GetInstance().Subscribe(processId, OnDeviceInput);
                    //}
                }
            }
        }

        [JsonIgnore]
        public AutoResetEvent InputHandle { get; set; } = new AutoResetEvent(false);

        public string ProcessName { get; set; }



        //HubConnection conn;
        //IHubProxy proxy;

        /// <summary>
        /// 适用于第三方的信号输入
        /// </summary>
        /// <param name="obj"></param>
        //private object OnDeviceInput(ISubscriber sub, object param1, object param2)
        private void OnDeviceInput(InputPara obj)
        {
            //Debug.WriteLine(DateTime.Now.ToString("mm:ss.fff") + "\t输入流程：" + obj.ProcessId + "；\t本流程编号：" + ProcessId);
            //输入参数必须有一个字段是ProcessId，保存工序编号
            //string processId = obj.ProcessId;

            //if (obj.ProcessId == ProcessId)
            //{
            //    InputPara = obj.ParaObj;
            //    InputHanlderDict[].Set();
            //    BoundFlag = false;
            //}

            //InputPara obj = param1 as InputPara;

            //lock (this)
            {
                try
                {
                    //if (InputHanlderDict.Keys.Contains(obj.ProcessId))
                    if (ProcessId == obj.ProcessId)
                    {
                        //Debug.WriteLine(DateTime.Now.ToString("mm:ss.fff") + "\t流程编号：" + obj.ProcessId);
                        //InputHanlderDict[obj.ProcessId].Set();
                        //InputFlagDict[obj.ProcessId] = true;
                        InputHandle.Set();
                        //InputHanlderDict.Remove(obj.ProcessId);
                        //StateMachine.OnDeviceInput -= OnDeviceInput;
                        //PubSubCenter.GetInstance().RemoveSubscriber(ProcessId, OnDeviceInput);
                    }
                }
                catch (Exception)
                {
                }

                //return null;
            }
        }

        public virtual void Dispose()
        {
            //foreach (var handle in InputHanlderDict)
            //{
            //    handle.Value.Set();
            //}

            //StateMachine.OnDeviceInput -= OnDeviceInput;

            //InputHanlderDict = new ConcurrentDictionary<string, AutoResetEvent>();
            //InputFlagDict = new ConcurrentDictionary<string, bool>();

            //GC.Collect();
        }

    }

    [Serializable]
    public class InputPara : IProcessID
    {
        public string ProcessId { get; set; }

        //[DataMember]
        public dynamic ParaObj { get; set; }

        public string ProcessName { get; set; }
    }
}