/// <summary>
    /// 消息(xi)生產(chan)者
    /// 具體(ti)消息生產(chan)者(zhe)是單例，如Email,SMS,Rtx等
    /// </summary>
    public class MessageFactory
    {
        /// <summary>
        /// 消息工(gong)廠
        /// </summary>
        public static IMessageManager GetService(MessageType messageType)
        {
            switch (messageType)
            {
                case MessageType.Email:
                    return EmailMessageManager.Instance;
                case MessageType.SMS:
                    return SMSMessageManager.Instance;
                case MessageType.RTX:
                    return RTXMessageManager.Instance;
                default:
                    throw new NotImplementedException("消息生產者未被識別(bie)...");
            }
        }

    }

   /// <summary>
    /// RTX消(xiao)息服務
    /// </summary>
    internal class RTXMessageManager : IMessageManager
    {
        #region Singleton
        private static object lockObj = new object();
        public static RTXMessageManager Instance;
        static RTXMessageManager()
        {
            lock (lockObj)
            {
                if (Instance == null)
                    Instance = new RTXMessageManager();
            }
        }
        private RTXMessageManager()
        { }
        #endregion

        private string EncodingString(string str)
        {
            return HttpUtility.UrlEncode(str, Encoding.GetEncoding("GB2312"));
        }

        private string rtxUrl = System.Configuration.ConfigurationManager.AppSettings["RtxApi"] ??
            "//192.168.1.8:8012/sendnotifynew.cgi?";

        #region IMessageManager 成員

        public void Send(string recipient, string subject, string body)
        {
            Send(new List<string> { recipient }, subject, body);
        }

        public void Send(IEnumerable<string> recipients, string subject, string body)
        {
            try
            {
                var dic = new Dictionary<string, string>()       
                {    {"title",EncodingString(subject)},
                     {"msg",EncodingString(body)},
                     {"receiver", EncodingString(string.Join(",",recipients))},
                     {"delaytime","0"}
                 };
                StringBuilder str = new StringBuilder();
                foreach (var item in dic)
                {
                    str.Append(item.Key + "=" + item.Value + "&");
                }
                new HttpClient().GetAsync(rtxUrl + str.ToString()).Wait();
            }
            catch (Exception ex)
            {
                Logger.Core.LoggerFactory.Instance.Logger_Info(ex.Message);
            }
        }

        public void Send(IEnumerable<string> recipients, string subject, string body, bool isAsync)
        {
            if (isAsync)
                Task.Run(() =>
                {
                    Send(recipients, subject, body);
                });
            else
                Send(recipients, subject, body);
        }

        #endregion
    }