#region Copyright (C) 2016 Kevin (OSS开源系列) 公众号：osscoder

/***************************************************************************
*　　	文件功能描述：OSS.Http.Extention - 通用请求结果扩展
*
*　　	创建人： Kevin
*       创建人Email：1985088337@qq.com
*       创建时间： 2017-5-25
*       
*****************************************************************************/

#endregion
using System;
using System.Net.Http;
using System.Threading.Tasks;
using Newtonsoft.Json;
using OSS.Common.ComModels;
using OSS.Common.ComModels.Enums;
using OSS.Common.Plugs;
using OSS.Common.Plugs.LogPlug;
using OSS.Http.Mos;

namespace OSS.Http.Extention
{
    /// <summary>
    /// 通用请求结果扩展
    /// </summary>
    public static class OsRestExtention
    {
        /// <summary>
        /// 处理远程请求方法，并返回需要的实体
        /// </summary>
        /// <typeparam name="T">需要返回的实体类型</typeparam>
        /// <param name="request">远程请求组件的request基本信息</param>
        /// <param name="formatFunc">处理内容委托</param>
        /// <param name="client">自定义httpclient</param>
        /// <param name="moduleName">模块名称</param>
        /// <returns>实体类型</returns>
        public static async Task<T> RestCommon<T>(this OsHttpRequest request,
            Func<HttpResponseMessage, Task<T>> formatFunc, HttpClient client = null,
            string moduleName = ModuleNames.Default)
            where T : ResultMo, new()
        {
            T t;
            try
            {

                var resp = await request.RestSend(client);
                t = await formatFunc(resp);
            }
            catch (Exception ex)
            {
                t = new T() {ret = (int) ResultTypes.InnerError, msg = ex.Message};
                LogUtil.Error(string.Concat("基类请求出错，错误信息：", ex.Message), "RestCommon", moduleName);
            }
            return t ?? new T() {ret = -1, msg = "未发现结果"};
        }


        /// <summary>
        ///  使用json格式化内容方法
        /// </summary>
        /// <typeparam name="TResp"></typeparam>
        /// <param name="resp"></param>
        /// <returns></returns>
        private static async Task<TResp> JsonFormat<TResp>(HttpResponseMessage resp)
            where TResp : ResultMo, new()
        {
            if (!resp.IsSuccessStatusCode)
                return new TResp()
                {
                    ret = -(int) resp.StatusCode,
                    msg = resp.ReasonPhrase
                };

            var contentStr = await resp.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<TResp>(contentStr);
        }

        /// <summary>
        /// 
        /// </summary>
        /// <typeparam name="TResp"></typeparam>
        /// <param name="request"></param>
        /// <param name="client"></param>
        /// <param name="moduleName"></param>
        /// <returns></returns>
        public static async Task<TResp> RestCommonJson<TResp>(this OsHttpRequest request, HttpClient client = null,
            string moduleName = ModuleNames.Default)
            where TResp : ResultMo, new()
        {
            return await RestCommon(request, JsonFormat<TResp>, client, moduleName);
        }

    }
}