using System;

using System.Collections.Generic;

using System.Net;

using System.Text;
using System.Configuration;
using System.IO;
using System.Collections;
using Jiguang.JPush.Model;
/*

 * 参考文档：http://docs.jpush.cn/display/dev/Index  选择里面的：服务器端 API，Push-API-V3

 *

 * 极光推送的网站的网址是：https://www.jpush.cn/

 *   旧版本V2  http://docs.jpush.cn/display/dev/Push+API+v2

 * 最新版本V3  http://docs.jpush.cn/display/dev/Push-API-v3

 *

 * 其中服务端的接口以及示例代码都在这里：http://docs.jpush.cn/display/dev/Server-SDKs

*/



/// <summary>

/// 极光推送的最新版：PUSH-API-V3

/// 参考地址 http://docs.jpush.cn/display/dev/Push-API-v3

/// POST https://api.jpush.cn/v3/push

/// </summary>
namespace Jiguang.JPush
{
    public class JPushV3
    {

        /// <summary>

        /// 应用标识：极光推送的用户名

        /// </summary>

        private readonly string AppKey = ConfigurationManager.AppSettings["JGAppKey"];

        /// <summary>

        /// 极光推送的密码

        /// </summary>

        private readonly string MasterSecret = ConfigurationManager.AppSettings["JGAppSecret"];

        /// <summary>

        /// 极光推送请求的url地址

        /// </summary>

        private readonly string RequestUrl = "https://api.jpush.cn/v3/push";

        /// <summary>

        /// 查询推送结果请求的Url地址

        /// </summary>

        private readonly string ReceivedUrl = "https://report.jpush.cn/v3/received";


        /// <summary>

        /// 推送消息并保存到已发送表
        /// </summary>
        /// <param name="RegistrationIDList">推送TokenID集合</param>
        /// <param name="title">标题</param>
        /// <param name="senduser">作者</param>
        /// <param name="toid">推送对象ID</param>
        /// <param name="contype">推送对象</param>
        /// <param name="dataid"></param>
        /// <param name="strMsg">推送内容</param>
        /// <param name="is_production"></param>
        /// <param name="strLog">返回日志</param>
        /// <returns></returns>
        public bool SendPushV2(List<string> RegistrationIDList, string title, string dataid, string strMsg, bool is_production, out string strLog)
        {
            try
            {
                var parmARR = new Dictionary<string, object>();
                parmARR.Add("dataid", dataid);
                var mm = new M_PushRegistration();
                mm.registration_id = RegistrationIDList;
                //生成JSON格式参数
                PushPayload pushPayload = new PushPayload()
                {
                    Platform = new List<string> { "android", "ios" },//推送平台
                    Audience = mm,//推送对象
                    Notification = new Notification
                    {
                        Alert = strMsg,
                        Android = new Android
                        {
                            Alert = strMsg,
                            Title = title,
                            Extras = parmARR
                        },
                        IOS = new IOS
                        {
                            Alert = strMsg,
                            Badge = "+1",
                            Extras = parmARR
                        }
                    },
                    Options = new Options
                    {
                        IsApnsProduction = is_production // 设置 iOS 推送生产环境。不设置默认为开发环境。
                    }
                };
                var strParms = pushPayload.ToString();
                var result = SendPostRequest(strParms);
                strLog = result.ToString();
                return true;
                /*var retM = result.Exp_JsonToModel<M_PushReturn>(1);

                if (retM.error == null)
                {

                    strLog = "向设备推送消息成功\r\n请求参数=" + strParms + "\r\n";
                    return true;
                }
                else
                {
                    strLog = "推送失败，错误码：" + retM.error.code + "，错误信息：" + retM.error.message;
                    return false;
                }*/
            }
            catch (Exception ex)
            {
                strLog = "推送异常：" + ex.Message;
                return false;
            }
        }
        /// <summary>

        /// 发送推送请求到JPush，使用HttpWebRequest

        /// </summary>

        /// <param name="method">传入POST或GET</param>

        /// <param name="url">固定地址</param>

        /// <param name="auth">用户名AppKey和密码MasterSecret形成的Base64字符串</param>

        /// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>

        /// <returns></returns>

        public string SendRequest(String method, String url, String auth, String reqParams)
        {

            string resultJson = "";



            HttpWebRequest myReq = null;

            HttpWebResponse response = null;

            try
            {

                myReq = (HttpWebRequest)WebRequest.Create(url);

                myReq.Method = method;

                myReq.ContentType = "application/json";

                if (!String.IsNullOrEmpty(auth))
                {

                    myReq.Headers.Add("Authorization", "Basic " + auth);

                }

                if (method == "POST")
                {

                    byte[] bs = UTF8Encoding.UTF8.GetBytes(reqParams);

                    myReq.ContentLength = bs.Length;

                    using (Stream reqStream = myReq.GetRequestStream())
                    {

                        reqStream.Write(bs, 0, bs.Length);

                        reqStream.Close();

                    }

                }

                response = (HttpWebResponse)myReq.GetResponse();

                HttpStatusCode statusCode = response.StatusCode;



                if (Equals(response.StatusCode, HttpStatusCode.OK))
                {

                    using (StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.UTF8))
                    {

                        resultJson = reader.ReadToEnd();

                        try
                        {

                            object json = Newtonsoft.Json.JsonConvert.DeserializeObject(resultJson);

                        }

                        catch
                        {

                            resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", "响应的结果不是正确的json格式");

                        }

                    }

                }

            }

            catch (WebException ex)
            {

                if (ex.Status == WebExceptionStatus.ProtocolError)
                {

                    HttpStatusCode errorCode = ((HttpWebResponse)ex.Response).StatusCode;

                    string statusDescription = ((HttpWebResponse)ex.Response).StatusDescription;

                    using (StreamReader sr = new StreamReader(((HttpWebResponse)ex.Response).GetResponseStream(), System.Text.Encoding.UTF8))
                    {

                        resultJson = sr.ReadToEnd();

                        //{"errcode":404,"errmsg":"request api doesn't exist"}

                        Dictionary<string, object> dict = JsonToDictionary(resultJson);

                        string errCode = "10086";

                        string errMsg = "发送推送的请求地址不存在或无法连接";

                        if (dict.ContainsKey("errcode"))
                        {

                            errCode = dict["errcode"].ToString();

                        }

                        if (dict.ContainsKey("errmsg"))
                        {

                            errMsg = dict["errmsg"].ToString();

                        }

                        resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": {1}}}}}", errMsg, errCode);

                    }

                }

                else
                {

                    //这里一定是error作为键名（自定义错误号10086），和极光推送失败时的json格式保持一致 如 {"error": {"message": "Missing parameter", "code": 1002}}

                    resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", ex.Message.Replace("\"", " ").Replace("'", " "));

                }

            }

            catch (System.Exception ex)
            {

                resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", ex.Message.Replace("\"", " ").Replace("'", " "));

            }

            finally
            {

                if (response != null)
                {

                    response.Close();

                }

                if (myReq != null)
                {

                    myReq.Abort();

                }

            }

            return resultJson;

        }



        /// <summary>

        /// 通过用户名AppKey和密码获取验证码

        /// </summary>

        /// <returns></returns>

        private string GetBase64Auth()
        {

            string str = this.AppKey + ":" + this.MasterSecret;

            byte[] bytes = Encoding.Default.GetBytes(str);

            return Convert.ToBase64String(bytes);

        }



        /// <summary>

        /// 发送推送请求到JPush

        /// </summary>

        /// <param name="method">POST或GET</param>

        /// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>

        /// <returns></returns>

        public string SendRequest(String method, String reqParams)
        {

            string auth = GetBase64Auth();

            return SendRequest(method, this.RequestUrl, auth, reqParams);

        }



        /// <summary>

        /// 发送Post请求

        /// </summary>

        /// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>

        /// <returns></returns>

        public string SendPostRequest(String reqParams)
        {

            string auth = GetBase64Auth();

            return SendRequest("POST", this.RequestUrl, auth, reqParams);

        }



        /// <summary>

        /// 发送Get请求

        /// </summary>

        /// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>

        /// <returns></returns>

        public string SendGetRequest(String reqParams)
        {

            string auth = GetBase64Auth();

            return SendRequest("GET", this.RequestUrl, auth, reqParams);

        }



        /*

         * 生成唯一的sendNo的方法： 取序列号

         * 查看返回结果的方法

        */



        /// <summary>

        /// 查询推送的结果

        /// </summary>

        /// <param name="msg_ids">生成的json信息唯一id</param>

        /// <returns></returns>

        public string GetReceivedResult(String msg_ids)
        {

            string url = this.ReceivedUrl + "?msg_ids=" + msg_ids;

            String auth = GetBase64Auth();

            return SendRequest("GET", url, auth, null); ;

        }



        /*

         * 1.正确时返回结果{"sendno":"123456","msg_id":"1799597405"}

         * 或者 {"sendno":"0","msg_id":"351403900"}

         * 2.入参json完全正确，但找不到要到达的设备。错误时：返回

         * {"msg_id": 3125719446, "error": {"message": "cannot find user by this audience", "code": 1011}}

         * 3.传入空字符串 或者 非json格式，或者没有必须的选项：{"error": {"message": "Missing parameter", "code": 1002}}

         * 传入的键（键区分大小写）、值不符合要求 {"error": {"message": "Audience value must be JSON Array format!", "code": 1003}} 

        */



        /// <summary>

        /// 将返回的json转换为Hashtable对象

        /// </summary>

        /// <param name="jsonString"></param>

        /// <returns></returns>

        public Hashtable JsonToHashtable(string jsonString)
        {

            /*

             * 正确时返回结果{"sendno":"123456","msg_id":"1799597405"}

             * {"sendno":"0","msg_id":"351403900"}

             * 入参json完全正确，但找不到要到达的设备。错误时：返回 {"msg_id": 3125719446, "error": {"message": "cannot find user by this audience", "code": 1011}}

             * 传入空字符串 或者 非json格式，或者没有必须的选项：{"error": {"message": "Missing parameter", "code": 1002}}

             * 传入的键值不符合要求 {"error": {"message": "Audience value must be JSON Array format!", "code": 1003}}  键区分大小写

            */

            Hashtable ht = new Hashtable();

            object json = Newtonsoft.Json.JsonConvert.DeserializeObject(jsonString);

            //返回的结果一定是一个json对象

            Newtonsoft.Json.Linq.JObject jsonObject = json as Newtonsoft.Json.Linq.JObject;

            if (jsonObject == null)
            {

                return ht;

            }

            foreach (Newtonsoft.Json.Linq.JProperty jProperty in jsonObject.Properties())
            {

                Newtonsoft.Json.Linq.JToken jToken = jProperty.Value;

                string value = "";

                if (jToken != null)
                {

                    value = jToken.ToString();

                }

                ht.Add(jProperty.Name, value);

            }

            return ht;

        }



        /// <summary>

        /// 根据json返回的结果判断是否推送成功

        /// </summary>

        /// <param name="jsonString">响应的json</param>

        /// <param name="errorMessage">错误信息</param>

        /// <param name="errorCode">错误号</param>

        /// <returns></returns>

        public bool IsSuccess(string jsonString, out string errorMessage, out string errorCode)
        {

            Hashtable ht = JsonToHashtable(jsonString);

            errorMessage = "";

            errorCode = "";

            foreach (string key in ht.Keys)
            {

                //如果存在error键,说明推送出错

                if (key == "error")
                {

                    string errJson = ht[key].ToString();

                    Hashtable htError = JsonToHashtable(errJson);

                    errorMessage = htError["message"].ToString();

                    errorCode = htError["code"].ToString();

                    return false;

                }

            }

            return true;

        }



        /// <summary>

        /// 根据返回的响应json来判断推送是否成功，成功时记录sendno与msg_id。

        /// 失败时记录错误信息errorMessage、错误号errCode等

        /// </summary>

        /// <param name="jsonString">响应的json</param>

        /// <param name="errorMessage">错误信息</param>

        /// <param name="errorCode">错误号</param>

        /// <param name="sendno">用户自定义的推送编号（从序列号中获取），不设置则为0，成功后返回该编号</param>

        /// <param name="msg_id">极光服务器处理后返回的信息编号</param>

        /// <returns></returns>

        public bool IsSuccess(string jsonString, out string errorMessage, out string errorCode, out string sendno, out string msg_id)
        {

            bool result = IsSuccess(jsonString, out errorMessage, out errorCode);

            Hashtable ht = JsonToHashtable(jsonString);

            sendno = "";

            msg_id = "";

            if (result) //推送成功时，只有键sendno、msg_id
            {

                sendno = ht["sendno"].ToString();

                msg_id = ht["msg_id"].ToString();

            }

            else //如果失败时存在msg_id键，则记录msg_id的值
            {

                if (ht.ContainsKey("msg_id"))
                {

                    msg_id = ht["msg_id"].ToString();

                }

            }

            return result;

        }



        /// <summary>

        /// 将返回的json转换为字典Dictionary对象

        /// </summary>

        /// <param name="jsonString"></param>

        /// <returns></returns>

        public Dictionary<string, object> JsonToDictionary(string jsonString)
        {

            Dictionary<string, object> ht = new Dictionary<string, object>();

            object json = Newtonsoft.Json.JsonConvert.DeserializeObject(jsonString);

            //返回的结果一定是一个json对象

            Newtonsoft.Json.Linq.JObject jsonObject = json as Newtonsoft.Json.Linq.JObject;

            if (jsonObject == null)
            {

                return ht;

            }

            foreach (Newtonsoft.Json.Linq.JProperty jProperty in jsonObject.Properties())
            {

                Newtonsoft.Json.Linq.JToken jToken = jProperty.Value;

                string value = "";

                if (jToken != null)
                {

                    value = jToken.ToString();

                }

                ht.Add(jProperty.Name, value);

            }

            return ht;

        }
        public class M_PushRegistration
        {
            public List<string> registration_id { get; set; }
        }
        public class M_PushReturn
        {
            public string sendno { get; set; }
            public string msg_id { get; set; }
            public M_PushError error { get; set; }
        }
        public class M_PushError
        {
            public string message { get; set; }
            public string code { get; set; }
        }
    }
}