namespace AsiaINFO.SMS.APPCMPP2.MyThread.DataThread
{
    using AsiaINFO.SMS.APPCMPP2;
    using AsiaINFO.SMS.APPCMPP2.MyThread;
    using AsiaINFO.SMS.BusinessFactory;
    using AsiaINFO.SMS.CMPP2;
    using AsiaINFO.SMS.Entity;
    using System;
    using System.Collections;
    using System.Collections.Generic;

    public class GetMTWaitThread : ThreadBase
    {
        private string _out_gateway_id;
        private SyncEvents _submitEvents;
        private Queue<SubmitInfo> _submitQueue;
        private readonly int _waitlong;
        private readonly int _waitshort;

        public GetMTWaitThread(SyncEvents syncEvents, Queue<SubmitInfo> submitQueue, SyncEvents submitEvents, string out_gateway_id) : base(syncEvents)
        {
            //this._waitlong = 5;
            this._waitlong = 10;
            if ((submitQueue == null) || (submitEvents == null))
            {
                throw new Exception("GetMTWaitThread参数不能为空！");
            }
            this._submitQueue = submitQueue;
            this._submitEvents = submitEvents;
            this._out_gateway_id = out_gateway_id;
        }

        protected void CheckFull()
        {
            do
            {
                if (this._submitCount < 0x1388)
                {
                    return;
                }
            }
            while (!base._syncEvents.ExitThreadEvent.WaitOne((int)(0x3e8 * this._waitlong), false));
        }

        private List<MTWaitInfo> GetMTWaitList()
        {
            List<MTWaitInfo> list = new List<MTWaitInfo>();
            try
            {
                list = MTBusiness.GetMTWaitList(100, ShareData.CurrentISMG, this._out_gateway_id);
            }
            catch (Exception exception)
            {
                base.OnMsg("[GetMTWaitList] " + exception.Message, MsgLevel.Err);
            }
            return list;
        }

        private bool checkFull()
        {
            return this._submitCount >= 100;
        }

        protected override void Run()
        {
            List<MTWaitInfo> mTWaitList = null;
            int num = this._waitlong;
            do
            {
                lock (base._syncSuspendLogLockObject)
                {
                    //this.CheckFull();

                    if (this.checkFull())
                    {
                        base.OnMsg("【待发送】队列已满...等待数:" + this._submitCount,MsgLevel.Msg);
                        //this._submitEvents.NewItemEvent.Set();
                        //base.OnMsg($"【待发送】开始，唤醒...",MsgLevel.Debug);
                        

                        System.Threading.Thread.Sleep(500);
                        continue;
                    }

                    base.OnMsg("【待发送】执行检查...", MsgLevel.Msg);
                    MTBusiness.UpdateUnSendMsg();

                    mTWaitList = this.GetMTWaitList();
                    base.OnMsg($"【待发送】已经获取待发送数据，结果:"+mTWaitList.Count,MsgLevel.Msg);
                    if ((mTWaitList != null) && (mTWaitList.Count > 0))
                    {
                        num = this._waitshort;
                        foreach (MTWaitInfo info in mTWaitList)
                        {
                            //检查是否重复
                            if (!DetectionBusiness.Instance.checkMessageId(info.Guid))
                            {
                                DBFactory.log4netService.Debug("[待发送]添加 guid=" + info.Guid + ",手机号码：" + info.MOBILE_NO);
                                DetectionBusiness.Instance.addSubmitMessageToCache(info.Guid);
                            }
                            else
                            {
                                try
                                {
                                    DBFactory.log4netService.Debug("[待发送][已存在不处理]-guid=" + info.Guid + ",手机号码：" + info.MOBILE_NO);
                                    //SubmitInfo info3 = new SubmitInfo(info, ShareData.SeqID, 1);
                                    //MTBusiness.UpdateMTInfo(info3);

                                    MTBusiness.DeleteMTWait(info, ShareData.CurrentISMG);
                                }
                                catch (Exception ex)
                                {
                                    base.OnMsg("[检测重复的异常]- " + ex.Message, MsgLevel.Err);
                                }
                                continue;
                            }

                            SubmitInfo info2 = new SubmitInfo(info, ShareData.SeqID, 1);
                            this._submitData = info2;
                        }
                        this._submitEvents.NewItemEvent.Set();
                    }
                    else
                    {
                        num = this._waitlong;
                    }
                }
            }
            while (!base._syncEvents.ExitThreadEvent.WaitOne((int) (0x3e8 * num), false));
            base.Stop();
        }

        private int _submitCount
        {
            get
            {
                lock (((ICollection) this._submitQueue).SyncRoot)
                {
                    return this._submitQueue.Count;
                }
            }
        }

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