using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
using System.IO;
using System.Data;
using System.Data.SqlClient;
using Microsoft.Practices.EnterpriseLibrary.Data;
using System.Collections;
using System.Reflection;
using System.ComponentModel;

namespace ThreadTestSMGW
{
    class Program
    {
        //private static int poolFlag = 0;//声明标记
        //private const int amountThread = 10000;//线程总量
        //private const int maxThread = 10000;//可执行线程最大数量
        //private static Mutex muxConsole = new Mutex();

        //初始化短信发送参数
        private static string account = System.Configuration.ConfigurationManager.AppSettings["account"];
        private static string password = System.Configuration.ConfigurationManager.AppSettings["password"];
        private static string mobile = System.Configuration.ConfigurationManager.AppSettings["mobiles"];
        private static string extno = System.Configuration.ConfigurationManager.AppSettings["extno"];
        private static string content = System.Configuration.ConfigurationManager.AppSettings["content"];
        private static string ThreadNum = System.Configuration.ConfigurationManager.AppSettings["ThreadNum"];//线程总数
        private static string CycNum = System.Configuration.ConfigurationManager.AppSettings["CycNum"]; //循环次数
        
        private static int startTime = Convert.ToInt32(System.Configuration.ConfigurationManager.AppSettings["startTime"]);
        private static int endTime = Convert.ToInt32(System.Configuration.ConfigurationManager.AppSettings["endTime"]);
        public static string conn = System.Configuration.ConfigurationManager.AppSettings["ConnectionString"];

        private static int CountNum = Int32.Parse(System.Configuration.ConfigurationManager.AppSettings["Count"]);


        public static bool listFlag = true; //插入成功标识
        static void Main(string[] args)
        {
            //Thread.Sleep(10000);
            Console.WriteLine("开始执行...");

            Thread threads = new Thread(new ThreadStart(DealSMS));
            threads.Start();

            //Thread[] threads = new Thread[Int32.Parse(ThreadNum)];
            //for (int i = 0; i < Int32.Parse(ThreadNum); i++)
            //{
            //    threads[i] = new Thread(DealSMS);
            //    threads[i].IsBackground = true;
            //    threads[i].Name = "线程" + i;
            //    threads[i].Start();

            //}
            
            //Thread listThread = new Thread(listTime);//列表处理
            //listThread.Name = "列表线程";
            //listThread.Start();

            //Thread ReportThread = new Thread(GetReport);
            //ReportThread.Start();



            //bool flag = true;

            
            //while (true)
            //{
            //    for (int i = 0; i < Int32.Parse(ThreadNum); i++)
            //    {
            //        if (threads[i].IsAlive == false)
            //        { flag = false; }
            //        else { flag = true; }
            //    }
            //    if (flag == false)
            //    {
            //        if (listFlag==false)
            //        {
            //            //Console.WriteLine("统计插入完成");
            //            listThread.Abort();
            //            break;
            //        }
                    
            //    }
            //}
            //Console.ReadKey();

        }

        static void GetReport()
        {
            //while (true)
            //{
            //    SMSHandler sms = new SMSHandler();
            //    sms.Report(account, password);
            //    Thread.Sleep(2000);
            //}
        }


        //插入列表
        public static List<SMSModel> smsList = new List<SMSModel>();
        private static object olock = new object();
        public static void addList(string smsid,string starttime,string endtime,string content)
        {
            lock (olock)
            {
                smsList.Add(new SMSModel() { smsid = smsid, starttime = starttime, endtime = endtime,content=content});
            }
        }
        public static int Count = 0;
        //移除列表
        static void listTime()
        {
            Random r = new Random();
            int[] a =new int[60];
            int iii = 1000;
            for (int i = 0; i < 60; i++)
            {
                a[i] = iii;
                iii = 1000 + iii;
            }

            int temp = a[r.Next(59)];

            while (true)
            {
                try
                {
                    if (smsList.Count == CountNum)
                    {
                        Console.WriteLine("统计线程阻塞:" + temp);
                        Thread.Sleep(temp);

                        Console.WriteLine("统计开始...");
                        DataSql ds = new DataSql();
                        ListToDt ltd = new ListToDt();
                        ds.SqlBulkCopyByDatatable(conn, "tb_cs", ltd.ListToDataTable<SMSModel>(smsList));
                        Console.WriteLine("统计结束...");
                        listFlag = false;
                        break;
                    }
                }
                catch (Exception ex)
                { Console.WriteLine(ex.Message); }
                
                /*
                for (int i = 0; i < smsList.Count; i++)
                    {
                        DataSql ds = new DataSql();
                        try
                        {
                            int ii = ds.InsertSql(smsList[i].starttime, smsList[i].endtime);//插入数据库
                            if (ii > 0)
                            {
                                ++Count; smsList.RemoveAt(i);
                            }
                            else
                            {
                                Console.WriteLine("数据库插入异常..");
                            }
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine(ex.Message);
                        }
                    }               
                    */
            }
            
        }


        

        //线程处理
        static void DealSMS()
        {
            Thread.CurrentThread.Name = "发送线程";
            var dt = DateTime.Now;
            if(true)
            {
                int i = 0;
                while (i < Int32.Parse(CycNum))
                //while(true)
                {
                    i++;
                    SMSHandler sms = new SMSHandler();
                    //TornadoSMSHandler sms = new TornadoSMSHandler();
                    string addTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");

                    string result = sms.SendSMS(account, password, extno, mobile, content);//迈远网关
                    Console.WriteLine(content);
                    //StrToHex sth = new StrToHex();
                    //string content2 = sth.ToHexString(System.Text.Encoding.Default.GetBytes(content));

                    //string result = sms.SendSMS(account,password,mobile,content2);

                    //string[] sArray = result.Split(',');


                    //addList(sArray[0], addTime, sArray[1], content2);

                    //点对点短信提交

                    //string mobileConentList = "13611452175#【掌骏】您的短信码是322734,有效期为30分钟。若非本人操作，请及时修改密码。\n692676113#【掌骏】您的短信码是322734,有效期为30分钟。若非本人操作，请及时修改密码。";
                    //string result = sms.SendSMS(account,password,extno,mobileConentList);

                    //Console.WriteLine(mobileConentList);
                    string str = string.Format("[{0}]--提交时间:{1}--提交结果:{2}", Thread.CurrentThread.Name, addTime, result);
                    //WriteLog(str);
                    Console.WriteLine(str);

                    Console.ReadKey();
                    Thread.Sleep(10);
                    
                }
                
                Console.WriteLine("["+Thread.CurrentThread.Name+"]--程执行完毕..."+i);
                Thread.CurrentThread.Abort();
            }
        }



        static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim();
        //写日志
        public static void WriteLog(string str)
        {
            try
            {
                LogWriteLock.EnterWriteLock();
                string sFilePath = System.IO.Directory.GetCurrentDirectory();
                string sFileName = DateTime.Now.Date.ToString("yyyy-MM-dd")+"-sms.log";
                sFileName = sFilePath + "\\" + sFileName;
                if (!Directory.Exists(sFilePath))
                {
                    Directory.CreateDirectory(sFilePath);
                }
                FileStream fs;
                StreamWriter sw;
                if (File.Exists(sFileName))
                {
                    fs = new FileStream(sFileName, FileMode.Append, FileAccess.Write);
                }
                else
                {
                    fs = new FileStream(sFileName, FileMode.Create, FileAccess.Write);
                }
                sw = new StreamWriter(fs);
                sw.WriteLine(str);
                sw.Close();
                fs.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                LogWriteLock.ExitWriteLock();
            }
        }










        #region 注释掉的
        /*
        public static void Run()
        {
            muxConsole.WaitOne();  //阻塞队列
            Interlocked.Increment(ref poolFlag);  //标记+1
            if (poolFlag < maxThread)   //判断是否达到线程上限
            {
                muxConsole.ReleaseMutex();     //释放队列锁，加入执行线程
            }
            //Console.WriteLine("{0} 正在运行......\n", Thread.CurrentThread.Name);

            SMSHandler sms = new SMSHandler();
            string errmsg = "";
            bool flag = sms.SendSMS(account,password,extno,mobile,content,out errmsg);


            //Thread.Sleep(3000);   //模拟执行，暂停3秒钟
            //Console.WriteLine("{0} 已经中止....{1}..\n", Thread.CurrentThread.Name,errmsg);

            Interlocked.Decrement(ref poolFlag);  //标记-1
            try
            {
                muxConsole.ReleaseMutex(); //释放阻塞
            }
            catch { }
        }
        public static void Run2()
        {
            SMSHandler sms = new SMSHandler();
            content = "【测试】线程，开始执行测试,时间:" + DateTime.Now.ToString();
            string errmsg = "";
            sms.SendSMS(account, password, extno, mobile, content, out errmsg);
            Console.WriteLine("{0} 已经中止....{1}..\n", Thread.CurrentThread.Name, errmsg);
        }
         */
        #endregion
    }
}