using AsiaINFO.SMS.CMPP2;
using AsiaINFO.SMS.DBFactory;
using AsiaINFO.SMS.Entity;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Text;

namespace CMPPHOST
{
    class Program
    {

       
        static byte[] ReadFromStream(int Length, NetworkStream Stream)
        {
            byte[] buffer = null;
            if (Stream.CanRead && Stream.DataAvailable)
            {
                buffer = new byte[Length];
                int num = 0;
                for (int i = 0; i < Length; i += num)
                {
                    num = Stream.Read(buffer, i, Length - i);
                }
            }
            return buffer;
        }
        static byte[] ReadFromStreamWithLock(int Length, NetworkStream Stream)
        {
            try
            {
               
                    return ReadFromStream(Length, Stream);
               
            }
            catch (Exception exception)
            {

                Console.WriteLine(exception);
            }
            return null;
        }
        static  void WriteToStream(byte[] bytes, NetworkStream Stream)
        {
            if (Stream.CanWrite)
            {
                Stream.Write(bytes, 0, bytes.Length);
            }
            else
            {
                throw new Exception("Cann't Write Stream");
            }
        }
        static void WriteToStreamWithLock(byte[] data, NetworkStream Stream)
        {
            try
            {
                if (Stream == null)
                {
                    throw new Exception("Stream is null.");
                }
               
                    if (!Stream.CanWrite) throw new Exception("Cann't Write Stream!");
                WriteToStream(data, Stream);
               
            }
            catch (Exception exception)
            {
                IsConnected = false;
                Console.Write(exception);
            }
        }
        static void DealConnResp(byte[] data)
        {
            CMPP_CONNECT_RESP cmpp_connect_resp = new CMPP_CONNECT_RESP(data);
            IsConnected = cmpp_connect_resp.Status == 0;
          
        }
        static bool IsConnected = false;
        static void DistributeData(byte[] data)
        {


            try
            {
                Console.WriteLine("收到消息了!");
                MessageEventArgs args = new MessageEventArgs(data);
                MessageHeader header = args.Header;
                byte[] array = new byte[header.Total_Length];
                header.ToBytes().CopyTo(array, 0);
                args.BodyData.CopyTo(array, 12);
                if (header.Command_Id != CMPP_Command_Id.CMPP_ACTIVE_TEST_RESP || header.Command_Id != CMPP_Command_Id.CMPP_ACTIVE_TEST)
                {
                    Console.WriteLine("返回的commandId:" + header.Command_Id + "   时间：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"));
                }
                Console.Write(header.Command_Id);
                switch (header.Command_Id)
                {

                    case CMPP_Command_Id.CMPP_CONNECT_RESP:
                        DealConnResp(data);
                        return;
                    

                    default:
                        DealConnResp(data);
                        return;
                }
               
            }
            catch (Exception exception)
            {
                Console.WriteLine(exception);
            }
        }






        static NetworkStream _NetworkStream = null;
        private static string _Source_Addr="";
        static void Main(string[] args)
        {
            
          
           

            string userId= SysConf.Instance.SPID;
            string passwd = SysConf.Instance.PASSWD;
            string host = SysConf.Instance.ServerIP;
            int port = SysConf.Instance.ServerPort;
            _Source_Addr = userId;
            uint seqId = 1;
            CMPP_CONNECT cmpp_connect = new CMPP_CONNECT(userId, passwd, DateTime.Now, 0x20, seqId);
            var tc = new TcpClient();
            tc.Connect(host, port);
           
            if (_NetworkStream != null)
            {
                try
                {
                    _NetworkStream.Close();
                    _NetworkStream = null;
                }
                catch (Exception)
                {
                }
            }
            Console.WriteLine("连接服务器成功");
            _NetworkStream = tc.GetStream();
            WriteToStreamWithLock(cmpp_connect.ToBytes(), _NetworkStream);
            Console.WriteLine("开始登录服务器");
         

            while (true) {
                if (_NetworkStream.CanRead && _NetworkStream.DataAvailable)
                {
                    Console.WriteLine("接收到数据流...");
                    byte[] bytes = new byte[12];
                    bytes = Program.ReadFromStreamWithLock(12, _NetworkStream);
                    MessageHeader header = new MessageHeader(bytes);
                    byte[] dst = new byte[header.Total_Length];
                    Buffer.BlockCopy(bytes, 0, dst, 0, bytes.Length);
                    int length = ((int)header.Total_Length) - 12;
                    if (length > 0)
                    {
                        bytes = ReadFromStreamWithLock(length, _NetworkStream);
                        Buffer.BlockCopy(bytes, 0, dst, 12, bytes.Length);
                    }
                    DistributeData(dst);
                    Console.WriteLine("连接成功");
                    IsConnected = true;
                    break;
                }
            }


           


             int maxSmsCount = 1;
            DateTime startdate = DateTime.Now;
            System.Threading.Thread.Sleep(500);
            string batchId = DateTime.Now.ToString("yyyyMMddHHmmss");
            Console.WriteLine("开始发送：" + startdate.ToString("yyyy-MM-dd HH:mm:ss:ms"));
            for (var i = 0; i < maxSmsCount; i++) {
                string mobile = "13611452175"; // "1350201" + string.Format("{0:D4}", i);
                Console.WriteLine(mobile);
                DateTime oneStartTime = DateTime.Now;
                Console.WriteLine("发送一条开始时间：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ms"));
                MTWaitInfo mtInfo = new MTWaitInfo(Guid.NewGuid().ToString(), "10690001", "001", mobile, 1, "01","0","【掌骏】验证码测试短信，请忽略,批次："+ batchId + "序号："+i,"","",1,1);
               
                sendSubmit(new SubmitInfo(mtInfo, (uint)i, 0));
                DateTime oneEndTime = DateTime.Now;
                Console.WriteLine("发送一条结束时间：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ms") + "一条时长：" + (oneEndTime - oneStartTime).TotalMilliseconds);


            }
            DateTime endDate = DateTime.Now;
            Console.WriteLine("结束发送：" + endDate.ToString("yyyy-MM-dd HH:mm:ss:ms"));
            Console.WriteLine("发送总量：" + maxSmsCount);
            double diff = (endDate - startdate).TotalSeconds;
            double agv = maxSmsCount / diff;

            Console.WriteLine(string.Format("总共消耗时间：{0} 平均每秒发送量：{1:N4}", diff, agv));
            Console.Read();

            //连接服务器
        }
        static void Submit(ulong MsgId, string mobile, string MsgContent, uint SequenceId, string Service_Id, string FeeType, string FeeCode, string Src_Id, string WapURL, uint MsgSum, uint MsgSub)
        {
            if ((mobile != null) && (mobile.Length == 11))
            {
                mobile = "86" + mobile;
            }
            Submit(MsgId, mobile, new string[] { mobile }, MsgContent, SequenceId, Service_Id, FeeType, FeeCode, Src_Id, WapURL, MsgSum, MsgSub);
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="MsgId"></param>
        /// <param name="FeeTerminalId">收费</param>
        /// <param name="DestTerminalId"></param>
        /// <param name="MsgContent"></param>
        /// <param name="SequenceId"></param>
        /// <param name="Service_Id">企业帐户如 hs0055</param>
        /// <param name="FeeType">默认都为01</param>
        /// <param name="FeeCode">0</param>
        /// <param name="Src_Id">接入号：如 1069022600055</param>
        /// <param name="WapURL"></param>
        /// <param name="MsgSum"></param>
        /// <param name="MsgSub"></param>
        static void Submit(ulong MsgId, string FeeTerminalId, string[] DestTerminalId, string MsgContent, uint SequenceId, string Service_Id, string FeeType, string FeeCode, string Src_Id, string WapURL, uint MsgSum, uint MsgSub)
        {
            Submit(MsgId, 1, 0, FeeTerminalId, DestTerminalId, MsgContent, SequenceId, Service_Id, FeeType, FeeCode, Src_Id, WapURL, MsgSum, MsgSub);
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="MsgId"></param>
        /// <param name="RegisteredDelivery">1表示需要上报状态报告</param>
        /// <param name="Fee_UserType"></param>
        /// <param name="FeeTerminalId"></param>
        /// <param name="DestTerminalId"></param>
        /// <param name="MsgContent"></param>
        /// <param name="SequenceId"></param>
        /// <param name="Service_Id"></param>
        /// <param name="FeeType"></param>
        /// <param name="FeeCode"></param>
        /// <param name="Src_Id"></param>
        /// <param name="WapURL"></param>
        /// <param name="MsgSum"></param>
        /// <param name="MsgSub"></param>
        static void Submit(ulong MsgId, uint RegisteredDelivery, uint Fee_UserType, string FeeTerminalId, string[] DestTerminalId, string MsgContent, uint SequenceId, string Service_Id, string FeeType, string FeeCode, string Src_Id, string WapURL, uint MsgSum, uint MsgSub)
        {
            CMPP_SUBMIT submit = new CMPP_SUBMIT(SequenceId)
            {
                WapURL = WapURL,
                Msg_Id = MsgId,
                Pk_total = MsgSum,
                Pk_number = MsgSub,
                Registered_Delivery = RegisteredDelivery,
                Msg_level = 1,
                Service_Id = Service_Id,
                Fee_UserType = Fee_UserType,
                Fee_terminal_Id = "",
                TP_pId = 0,
                TP_udhi = 0,
                Msg_Fmt = 8,
                Msg_src = _Source_Addr,
                FeeType = FeeType,
                FeeCode = FeeCode,
                ValId_Time = "",
                At_Time = "",
                Src_Id = Src_Id,
                Dest_terminal_Id = DestTerminalId,
                DestUsr_tl = (uint)DestTerminalId.Length,
                Msg_Content = MsgContent,
                Reserve = ""
            };

            WriteToStreamWithLock(submit.ToBytes(), _NetworkStream);
        }
        private static void sendSubmit(SubmitInfo submit)
        {
            //长短信处理
            string smscontent = submit.MTWait.SMS_CONTENT;

            if (!MTFactory.checkSplitSMSContent(smscontent))
            {
                Submit(0L, submit.MTWait.MOBILE_NO, submit.MTWait.SMS_CONTENT, submit.SeqID, submit.MTWait.SERV_CODE, submit.MTWait.FEE_TYPE, submit.MTWait.FEE, submit.MTWait.LONG_SERV_NO, submit.MTWait.WapURL, submit.MTWait.MSG_SUM, submit.MTWait.MSG_SUB);
            }
            else
            {
                Dictionary<int, string> dict = MTFactory.SplitContent(smscontent);
                foreach (KeyValuePair<int, string> pair in dict)
                {
                   Submit(0L, submit.MTWait.MOBILE_NO, pair.Value, submit.SeqID, submit.MTWait.SERV_CODE, submit.MTWait.FEE_TYPE, submit.MTWait.FEE, submit.MTWait.LONG_SERV_NO, submit.MTWait.WapURL, (uint)dict.Count, (uint)pair.Key);
                }
            }
        }
    }
}