namespace AsiaINFO.SMS.BusinessFactory
{
    using AsiaINFO.SMS.DBFactory;
    using AsiaINFO.SMS.Entity;
    using Common;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Linq;

    public class MTBusiness
    {
        public static void AddReportWait(ReportInfo report, int ismg)
        {
            try
            {
                MTFactory.AddReportWait(report, ismg);
            }
            catch (Exception exception)
            {
                throw new Exception("[MTBusiness.AddReportWait] " + exception.Message);
            }
        }


        public static void DeleteMTWait(MTWaitInfo mtwait, int ismg)
        {
            try
            {
                switch (ismg)
                {
                    case 1:
                        MTFactory.Delete_MTWait_CM(mtwait.Guid);
                        return;

                    case 2:
                        MTFactory.Delete_MTWait_CU(mtwait.Guid);
                        return;

                    case 3:
                        MTFactory.Delete_MTWait_TEL(mtwait.Guid);
                        return;
                }
            }
            catch (Exception exception)
            {
                throw new Exception("[MTBusiness.DeleteMTWait] " + exception.Message);
            }
        }

        public static List<MTWaitInfo> GetMTWaitList(int rows, int ismg, string out_gateway_id)
        {
           
            List<MTWaitInfo> list = null;
            DataTable table = null;
            try
            {
                SetSendToWait();
                switch (ismg)
                {
                    case 1:
                        table = MTFactory.GetItemList_MTWait_CM(rows);
                        goto Label_0050;

                    case 2:
                        table = MTFactory.GetItemList_MTWait_CU(rows);
                        goto Label_0050;

                    case 3:
                        table = MTFactory.GetItemList_MTWait_TEL(rows);
                        goto Label_0050;
                }
            }
            catch (Exception exception)
            {
                throw new Exception("[MTBusiness.GetMTWaitList_1] " + exception.Message);
            }
        Label_0050:
            list = (table == null) ? new List<MTWaitInfo>() : new List<MTWaitInfo>(table.Rows.Count);
            foreach (DataRow row in table.Rows)
            {
                try
                {
                    string guid = row["GUID"].ToString().Trim();
                    string longSvrNo = row["LONG_SERV_NO"].ToString().Trim();
                    string svrCode = row["SERV_CODE"].ToString().Trim();
                    string mobileNo = row["MOBILE_NO"].ToString().Trim();
                    int num = Utils.StrToInt(row["MOBILE_NO_TYPE"].ToString().Trim(), 1);
                    string str5 = row["FEE_TYPE"].ToString().Trim();
                    string fee = row["FEE"].ToString().Trim();
                    string str7 = row["SMS_CONTENT"].ToString();
                    string linkId = row["LINK_ID"].ToString().Trim();
                    string wapurl = row["WAPURL"].ToString().Trim();
                    uint msgSum = (uint)Utils.StrToInt(row["MSGSUM"].ToString().Trim(), 1);
                    uint msgSub = (uint)Utils.StrToInt(row["MSGSUB"].ToString().Trim(), 1);
                    MTWaitInfo item = new MTWaitInfo(guid, longSvrNo, svrCode, mobileNo, num, str5, fee, str7, linkId, wapurl, msgSum, msgSub);
                    list.Add(item);
                    continue;
                }
                catch (Exception exception2)
                {
                    throw new Exception("[MTBusiness.GetMTWaitList_2] " + exception2.Message);
                }
            }
            try
            {
                switch (ismg)
                {
                    case 1:
                        foreach (MTWaitInfo info2 in list)
                        {
                            MTFactory.Update_MTWait_CM(info2.Guid, out_gateway_id);
                        }
                        return list;

                    case 2:
                        foreach (MTWaitInfo info3 in list)
                        {
                            MTFactory.Update_MTWait_CU(info3.Guid, out_gateway_id);
                        }
                        return list;

                    case 3:
                        break;

                    default:
                        return list;
                }
                foreach (MTWaitInfo info4 in list)
                {
                    MTFactory.Update_MTWait_TEL(info4.Guid, out_gateway_id);
                }
            }
            catch (Exception exception3)
            {
                throw new Exception("[MTBusiness.GetMTWaitList_3] " + exception3.Message);
            }
            return list;
        }
        /// <summary>
        /// from SMS_Send to SMS_MT and SMS_MT to SMS_CM_WAIT
        /// </summary>
        public static void SetSendToWait()
        {
            try
            {
                DataTable sendMsgDt = MTFactory.GetSendMsg();
                foreach (DataRow dr in sendMsgDt.Rows)
                {
                    int batchid = Int32.Parse(dr["batchid"].ToString());
                    string smscontent = dr["smscontent"].ToString();
                    string sendtime = dr["sendtime"].ToString();
                    string subnumber = dr["subnumber"].ToString();
                    int priority = Int32.Parse(dr["Priority"].ToString());
                    //string svrCode = dr["SER_CODE"].ToString();
                    DataTable sendMsgNODt = MTFactory.GetSendMsgNo(batchid);
                    List<string> numberArr = new List<string>();
                    foreach (DataRow numberDr in sendMsgNODt.Rows)
                    {
                        numberArr.Add(numberDr["mobileNo"].ToString());
                    }
                    
                    MTFactory.AddSMSInfo(smscontent, numberArr.ToArray(), subnumber, "",DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),subnumber,sendtime,batchid,priority);
                    MTFactory.UpdateSendMsg(batchid);
                }
                MTFactory.SendMTTOWait();
            }
            catch(Exception ex) {
                log4netService.Error("send±í²åÈëmt±íÒì³£:"+ex.Message);
                throw new Exception("[MTBusiness.SetSendToWait] " + ex.Message);
            
            }
        }
        public static Dictionary<int, string> SplitSmsIfOverLength(string smsContent)
        {
            Func<char, int> func = null;
            Action<string> action = null;
            Dictionary<int, string> dict = new Dictionary<int, string>();
            if ((smsContent != null) && (smsContent.Length <= 70))
            {
                dict.Add(1, smsContent);
                return dict;
            }
            int i = -1;
            int index = 0;
            if (smsContent != null)
            {
                if (func == null)
                {
                    func = s => ++i / 70;
                }
                if (action == null)
                {
                    action = delegate(string s)
                    {
                        dict.Add(++index, s);
                    };
                }
                (from g in Enumerable.GroupBy<char, int>(smsContent, func) select new string(g.ToArray<char>())).ToList<string>().ForEach(action);
            }
            return dict;
        }

        public static bool UpdateMTInfo(ReportInfo report)
        {
            bool flag;
            try
            {
                if (MTFactory.UpdateMTInfo(report) > 0)
                {
                    return true;
                }
                flag = false;
            }
            catch (Exception exception)
            {
                
                throw new Exception("[MTBusiness.UpdateMTInfo2] " + exception.Message+exception.StackTrace);
            }
            return flag;
        }

        public static void UpdateMTInfo(SubmitInfo submit)
        {
            try
            {
                MTFactory.UpdateMTInfo(submit);
            }
            catch (Exception exception)
            {
                throw new Exception("[MTBusiness.UpdateMTInfo1] " + exception.Message);
            }
        }

        public static void UpdateMTWait(string out_gateway_id, int ismg)
        {
            try
            {
                switch (ismg)
                {
                    case 1:
                        MTFactory.Update_MTWait_CM_REPLACE(out_gateway_id, "");
                        return;

                    case 2:
                        MTFactory.Update_MTWait_CU_REPLACE(out_gateway_id, "");
                        return;

                    case 3:
                        MTFactory.Update_MTWait_TEL_REPLACE(out_gateway_id, "");
                        return;
                }
            }
            catch (Exception exception)
            {
                throw new Exception("[MTBusiness.UpdateMTWait] " + exception.Message);
            }
        }

        //ÖØз¢ËÍ
        public static void UpdateUnSendMsg()
        {
            MTFactory.UpdateUnSendMsg();
        }
    }
}