TEAMModelOS/TEAMModelOS.SDK/DI/CoreAPI/CoreAPIHttpService.cs

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Http;
using System.Net.Http.Json;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Extension;


namespace TEAMModelOS.SDK
{
    public static class CoreAPIHttpServiceExtensions
    {
        public static IServiceCollection AddCoreAPIHttpService(this IServiceCollection services,  IConfiguration _configuration,string name = "Default")
        {
            if (services == null) throw new ArgumentNullException(nameof(services));
            string location = _configuration.GetValue<string>("Option:Location");
            string url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
            var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
            var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
            services.AddHttpClient<CoreAPIHttpService>();
            services.Configure<CoreAPIHttpServiceOptions>(name  , o => { o.location = location;o.url =url;o.clientID = clientID; o.clientSecret = clientSecret; });
            return services;
        }
    }
    public class CoreAPIHttpServiceOptions
    {
        public string location { get; set; }
        public string url { get; set; }
        public string clientID { get; set; }
        public string clientSecret { get; set; }

    }
    public class CoreAPIHttpService
    {

        public bool check=true;
        private readonly HttpClient _httpClient;
        public readonly IOptionsMonitor<CoreAPIHttpServiceOptions> options;
        public CoreAPIHttpService(HttpClient httpClient, IOptionsMonitor<CoreAPIHttpServiceOptions> optionsMonitor)
        {
            _httpClient = httpClient;
            options = optionsMonitor;
        }
        /// <summary>
        ///  发送短信验证码
        /// </summary>
        /// <param name="clientID"></param>
        /// <param name="clientSecret"></param>
        /// <param name="location"></param>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<(HttpStatusCode  code ,string content)> SendSmsPin(Dictionary<string, object> data, string location, IConfiguration _configuration, DI.DingDing _dingDing)

        {
            try {
                var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
                //url = "https://api2-rc.teammodel.cn";
                url = $"{url}/service/sandsms/pin";
                var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                if (location.Contains("China"))
                {
                    location = "China";
                }
                else if (location.Contains("Global"))
                {
                    location = "Global";
                }
                var token = await CoreTokenExtensions.CreateAccessToken(clientID, clientSecret, location);
                if (_httpClient.DefaultRequestHeaders.Contains("Authorization"))
                {
                    _httpClient.DefaultRequestHeaders.Remove("Authorization");

                }
                _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
                HttpResponseMessage responseMessage = await _httpClient.PostAsJsonAsync(url, data);
                if (responseMessage.Content != null)
                {
                    string content = await responseMessage.Content.ReadAsStringAsync();
                    if (!string.IsNullOrWhiteSpace(content))
                    {
                        return (responseMessage.StatusCode, content);
                    }
                    else {
                        return (responseMessage.StatusCode, null);
                    }
                }
                else {
                    return (responseMessage.StatusCode, null);
                }
                
               
            } catch (Exception ex) {
                await _dingDing.SendBotMsg($"{location}验证码发送异常：\n{ex.Message}\n{ex.StackTrace}", DI.GroupNames.醍摩豆服務運維群組);
                return (HttpStatusCode.InternalServerError,null);
            }


        }


        /// <summary>
        ///  隐式登录
        /// </summary>
        /// <param name="clientID"></param>
        /// <param name="clientSecret"></param>
        /// <param name="location"></param>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<TmdidImplicit> Implicit( Dictionary<string,string> data,string location, IConfiguration _configuration)

        {
            var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
            //url = "https://api2-rc.teammodel.cn";
            url = $"{url}/oauth2/implicit";
            var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
            var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
            if (location.Contains("China"))
            {
                location = "China";
            }
            else if (location.Contains("Global"))
            {
                location = "Global";
            }
            var token = await CoreTokenExtensions.CreateAccessToken(clientID, clientSecret, location);
            if (_httpClient.DefaultRequestHeaders.Contains("Authorization"))
            {
                _httpClient.DefaultRequestHeaders.Remove("Authorization");
               
            }
            _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
            HttpResponseMessage responseMessage = await _httpClient.PostAsJsonAsync(url, data);
            if (responseMessage.StatusCode == HttpStatusCode.OK)
            {
                string content=await responseMessage.Content.ReadAsStringAsync();
                if (!string.IsNullOrEmpty(content))
                {
                    TmdidImplicit tmdidImplicit = content.ToObject<TmdidImplicit>();
                    return tmdidImplicit;
                }
                else
                {
                    return null;
                }
            }
            else if (responseMessage.StatusCode == HttpStatusCode.Unauthorized)
            {
                return null;
            }
            else
            {
                return null;
            }
        }
        /// <summary>
        ///  获取多个用户信息
        /// </summary>
        /// <param name="clientID"></param>
        /// <param name="clientSecret"></param>
        /// <param name="location"></param>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<string> GetUserInfos(StringContent scontent, string name = "Default") {
            
            var clientID = options.Get(name).clientID;
            var clientSecret = options.Get(name).clientSecret;
            var location = options.Get(name).location;
            var url = options.Get(name).url;
            if (location.Contains("China"))
            {   url =string.IsNullOrWhiteSpace(url)? "https://api2.teammodel.cn":url;
                location = "China";
            }
            else if (location.Contains("Global"))
            {
                url = string.IsNullOrWhiteSpace(url) ? "https://api2.teammodel.net" : url;
                location = "Global";
            }
            url = $"{url}/oauth2/getuserinfos";
            var token = await CoreTokenExtensions.CreateAccessToken(clientID, clientSecret, location);
            if (_httpClient.DefaultRequestHeaders.Contains("Authorization"))
            {
                _httpClient.DefaultRequestHeaders.Remove("Authorization");
            }
            _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
            HttpResponseMessage responseMessage = await _httpClient.PostAsync(url, scontent);
            if (responseMessage.StatusCode == HttpStatusCode.OK)
            {
                string content = await responseMessage.Content.ReadAsStringAsync();
                if (!string.IsNullOrEmpty(content))
                {
                    return content;
                }
                else
                {
                    return null;
                }
            }
            else if (responseMessage.StatusCode == HttpStatusCode.Unauthorized)
            {
                return null;
            }
            else
            {
                return null;
            }
        }
        /// <summary>
        ///  获取单个用户信息
        /// </summary>
        /// <param name="clientID"></param>
        /// <param name="clientSecret"></param>
        /// <param name="location"></param>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<CoreUser> GetUserInfo(Dictionary<string, string> data, string location, IConfiguration _configuration)
        {
            var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
            //url = "https://api2-rc.teammodel.cn";
            url = $"{url}/oauth2/getuserinfo";
            var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
            var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
            if (location.Contains("China"))
            {
                location = "China";
            }
            else if (location.Contains("Global"))
            {
                location = "Global";
            }
            var token = await CoreTokenExtensions.CreateAccessToken(clientID, clientSecret, location);
            if (_httpClient.DefaultRequestHeaders.Contains("Authorization"))
            {
                _httpClient.DefaultRequestHeaders.Remove("Authorization");

            }
            _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
            HttpResponseMessage responseMessage = await _httpClient.PostAsJsonAsync(url, data);
            if (responseMessage.StatusCode == HttpStatusCode.OK)
            {
                string content = await responseMessage.Content.ReadAsStringAsync();
                if (!string.IsNullOrEmpty(content))
                {
                    CoreUserInfo coreUserInfo = content.ToObject<CoreUserInfo>();
                    if (coreUserInfo != null)
                    {
                        bool isActivate = !string.IsNullOrWhiteSpace(coreUserInfo.password) || !string.IsNullOrWhiteSpace(coreUserInfo.passwordOld);
                        CoreUser coreUser = new CoreUser
                        {
                            isActivate = isActivate,
                            id = coreUserInfo.id,
                            vid = coreUserInfo.vid,
                            mail = coreUserInfo.mail,
                            mobile = coreUserInfo.mobile,
                            name = coreUserInfo.name,
                            picture = coreUserInfo.picture,
                            habook = coreUserInfo.habook,
                            wechat = coreUserInfo.wechat,
                            facebook = coreUserInfo.facebook,
                            google = coreUserInfo.google,
                            ding = coreUserInfo.ding,
                            apple = coreUserInfo.apple,
                        };
                        return coreUser;
                    }
                    else
                    {
                        return null;
                    }
                }
                else {
                    return null;
                }
            }
            else if (responseMessage.StatusCode == HttpStatusCode.Unauthorized)
            {
                return null;
            }
            else
            {
                return null;
            }
        }
    }
    public class TmdidImplicit
    {
        public string id_token { get; set; }
        public string access_token { get; set; }
        public string expires_in { get; set; }
        public string token_type { get; set; }
    }
    public class CoreUser
    {
        public string searchKey { get; set; }
        public string id { get; set; }
        public string vid { get; set; }
        public string mail { get; set; }
        public string mobile { get; set; }
        public string name { get; set; }
        public string picture { get; set; }
        public string habook { get; set; }
        public string wechat { get; set; }
        public string facebook { get; set; }
        public string google { get; set; }
        public string ding { get; set; }
        public string apple { get; set; }
        public bool isActivate { get; set; }
    }
    public class CoreUserInfo : CoreUser
    {
        public string area { get; set; }
        public string country { get; set; }
        public string type { get; set; }
        public string password { get; set; }
        public string salt { get; set; }
        public string passwordOld { get; set; }
        public string saltOld { get; set; }
    }
}