namespace AsiaINFO.SMS.APPCMPP2.MyThread.CMPPThread
{
    using AsiaINFO.SMS.APPCMPP2;
    using AsiaINFO.SMS.APPCMPP2.MyThread;
    using AsiaINFO.SMS.CMPP2;
    using AsiaINFO.SMS.Entity;
    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Threading;
    using System.IO;

    public class SubmitRespThread : CMPPThreadBase
    {
        private Dictionary<ulong, SubmitInfo> _slidingWindowDic;
        private SyncEvents _slidingWindowEvents;
        private SyncEvents _submitOKEvents;
        private Queue<SubmitInfo> _submitOKQueue;
        private Queue<byte[]> _submitRespQueue;
        private object _syncSlidingWindowDicObject;
        private CMPP_SUBMIT_RESP response;
        private SubmitInfo submit;

        

        public SubmitRespThread(CMPPClient cmppClient, SyncEvents syncEvents, object syncSlidingWindowDicObject, Dictionary<ulong, SubmitInfo> slidingWindowDic, SyncEvents slidingWindowEvents, Queue<SubmitInfo> submitOKQueue, SyncEvents submitOKEvents, Queue<byte[]> submitRespQueue) : base(cmppClient, syncEvents)
        {
            if (((syncSlidingWindowDicObject == null) || (slidingWindowDic == null)) || (((submitOKQueue == null) || (submitOKEvents == null)) || (submitRespQueue == null)))
            {
                throw new Exception("SubmitRespThread参数不能为空！");
            }
            this._syncSlidingWindowDicObject = syncSlidingWindowDicObject;
            this._slidingWindowDic = slidingWindowDic;
            this._slidingWindowEvents = slidingWindowEvents;
            this._submitOKQueue = submitOKQueue;
            this._submitOKEvents = submitOKEvents;
            this._submitRespQueue = submitRespQueue;
        }


        private void DealData(byte[] data)
        {
            try
            {
                int count = 0;
                CMPP_SUBMIT_RESP cmpp_submit_resp = new CMPP_SUBMIT_RESP(data);
                lock (this._syncSlidingWindowDicObject)
                {
                    this._slidingWindowDic.TryGetValue((ulong) cmpp_submit_resp.Header.Sequence_Id, out this.submit);
                }
                if (this.submit != null)
                {
                    lock (this._syncSlidingWindowDicObject)
                    {
                        OnMsg($"[_slidingWindowDic]移除已经提交的数据------Guid：{submit.MTWait.Guid},号码：{submit.MTWait.MOBILE_NO}",MsgLevel.Debug);
                        this._slidingWindowDic.Remove((ulong) cmpp_submit_resp.Header.Sequence_Id);
                        count = this._slidingWindowDic.Count;
                    }
                    this.submit.Result = cmpp_submit_resp.Result;
                    this.submit.RespMsgID = cmpp_submit_resp.Msg_Id;
                    string msg = string.Format("收到SUBMIT反馈  MsgID={0} State={1}，------时间："+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), this.submit.RespMsgID, this.submit.Result);
                    base.OnMsg(msg, MsgLevel.Debug);
                    this._submitOKData = this.submit;
                    this._submitOKEvents.NewItemEvent.Set();
                    if (count <= 0)
                    {
                        this._slidingWindowEvents.NewItemEvent.Set();
                    }
                }
            }
            catch (Exception exception)
            {
                base.OnMsg("[CMPP_SUBMIT_RESP]异常:" + exception.Message, MsgLevel.Err);
            }
        }

        protected override void Run()
        {
            byte[] data = null;
            while (WaitHandle.WaitAny(base._syncEvents.EventArray) != 1)
            {
            Label_0004:
                data = null;
                lock (((ICollection) this._submitRespQueue).SyncRoot)
                {
                    if (this._submitRespQueue.Count > 0)
                    {
                        data = this._submitRespQueue.Dequeue();
                    }
                }
                if (data != null)
                {
                    this.DealData(data);
                    goto Label_0004;
                }
            }
            base.Stop();
        }

        public override void Stop()
        {
            if ((base._thread != null) && (base._thread.ThreadState == ThreadState.Suspended))
            {
                base.StartRun();
            }
            base._syncEvents.ExitThreadEvent.Set();
        }

        private int _submitDicCount
        {
            get
            {
                lock (this._syncSlidingWindowDicObject)
                {
                    return this._slidingWindowDic.Count;
                }
            }
        }

        private SubmitInfo _submitOKData
        {
            get
            {
                lock (((ICollection) this._submitOKQueue).SyncRoot)
                {
                    if (this._submitOKQueue.Count > 0)
                    {
                        return this._submitOKQueue.Dequeue();
                    }
                }
                return null;
            }
            set
            {
                lock (((ICollection) this._submitOKQueue).SyncRoot)
                {
                    this._submitOKQueue.Enqueue(value);
                }
            }
        }

        private byte[] _submitRespData
        {
            get
            {
                lock (((ICollection) this._submitRespQueue).SyncRoot)
                {
                    if (this._submitRespQueue.Count > 0)
                    {
                        return this._submitRespQueue.Dequeue();
                    }
                }
                return null;
            }
        }
    }
}