using HTEXLib.COMM.Helpers;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Options;
using OpenXmlPowerTools;
using System;
using System.Collections.Generic;
using System.Dynamic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Json;
using System.Security.Policy;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.DI.CoreAPI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;

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
    {
        private readonly IWebHostEnvironment _environment;
        public bool check=true;
        private SnowflakeId _snowflakeId;
        private readonly HttpClient _httpClient;
        public readonly IOptionsMonitor<CoreAPIHttpServiceOptions> options;
        private readonly IConfiguration _configuration;
        private readonly DI.DingDing _dingDing;
        public readonly Option _option;
        public CoreAPIHttpService(IOptionsSnapshot<Option> option, DingDing dingDing,IConfiguration configuration,HttpClient httpClient, IOptionsMonitor<CoreAPIHttpServiceOptions> optionsMonitor, IWebHostEnvironment environment,SnowflakeId snowflakeId)
        {
            _httpClient = httpClient;
            options = optionsMonitor;
            _environment = environment;
            _snowflakeId= snowflakeId;
            _option = option?.Value;
            _configuration = configuration;
            _dingDing = dingDing;

        }
        /*
        hubName	string	Optional	指定要傳送到哪個訊息中樞，若沒給則不傳送端外通知，只會發送端內通知。(目前只有"hita"及"hita5"能使用)
        sender	string	Optional	發送訊息的來源端
        tags	string array	Required	接收對象或手機註冊的tag，ID或服務等...
        title	string	Optional	標題，會"直接"顯示於端外通知的title位置
        body	string	Optional	正文，會"直接"顯示於端外通知的body位置
        eventId	string	Optional	事件ID
        eventName	string	Optional	事件名稱
        data	string	Optional	額外資料


        'request_school': vm.$t('notice.type1'), // 管理员收到他人申请加入的通知
        'invite_school': vm.$t('notice.type2'), // 你收到学校邀请你的通知
        'remove_school': vm.$t('notice.type3'), // 学校将你移除的通知
        'request-join_school': vm.$t('notice.type1'), // 学校同意你的加入请求
        'invite-join_school': vm.$t('notice.type2'), // 某人已同意你对他的邀请
        'coedit_syllabus': vm.$t('notice.type4'), // 邀请课纲共编的通知
        'share_syllabus': vm.$t('notice.type4'), // 个人课纲分享的通知
        'transfer-admin_school': vm.$t('notice.type5'), // 管理员转移的通知
        'scoring-arb_school': vm.$t('notice.type6'), // 仲裁卷阅卷任务分配通知
        'scoring-err_school': vm.$t('notice.type6'), // 异常卷阅卷任务分配通知
        'scoring-mark_school': vm.$t('notice.type6'), // 普通阅卷任务分配通知
        'scan-join_groupList': vm.$t('notice.type7'), // 扫码加入名单通知
        'scan-join_school': vm.$t('notice.type7'), // 扫码加入学校通知
        'submitanswer_homework': vm.$t('notice.type8'), // 作业提交通知
        'expire_lessonRecord': vm.$t('notice.type9'), // 课例过期通知
         */
        /// <summary>
        /// 
        ///  發送端內外通知
        /// 
        /// id: 教师id,name 教师名称，code 语系
        /// </summary>
        /// <param name="toTeachers"></param>
        /// <param name="notifyCode"></param>
        /// <param name="replaceData"></param>
        /// <param name="location"></param>
        /// <param name="_configuration"></param>
        /// <param name="_dingDing"></param>
        /// <returns></returns>
        public   void PushNotify(List<IdNameCode> toTeachers ,  string notifyCode,string notifyType,Dictionary<string, object> replaceData) {
            /*
             * IES5_Management  shift-assist_school  DelBeforeCopyAbility-mark_start  copyAbility-mark_finish  copyAbility-mark_start 
             *                  transfer-admin_school invite-join_school invite_school  request_school request-join_school remove_school  scan-join_school
             * IES5_Course      submitanswer_homework   scan-join_groupList    expire-school_lessonRecord
             * IES5_Task        scoring-mark_school scoring-arb_school scoring-err_school 
             * IES5_Contect     coedit_syllabus  share_syllabus 
             {
                "hubName":"hita5",
                "sender":"ies5",
                "tags":["1595321354_IES5_Management"]
                "title":"",
                "body":"",
                "eventId":"",
                "eventName":"",
                "data":""action":{"type":"click\link","tokenbindtype":1,"url":"http://xxxx"}"
            }
            */
            string lang = _option.Location.Contains("China") ? "zh-cn" : "en-us";
            toTeachers.FindAll(x => string.IsNullOrWhiteSpace(x.code)||(!x.code.Equals("zh-cn")&& !x.code.Equals("zh-tw")&& !x.code.Equals("en-us"))).ForEach(x => { x.code = lang; });
            var groups = toTeachers.GroupBy(x => x.code).Select(x => new { x.Key, list = x.ToList() });
            var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
            var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
            var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
            var token = CoreTokenExtensions.CreateAccessToken(clientID, clientSecret,_option.Location).Result;
            _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
            foreach (var group in groups)
            {
                string path = $"{_environment.ContentRootPath}/Lang/{group.Key}.json";
                var sampleJson = File.ReadAllBytes(path).AsSpan();
                Utf8JsonReader reader = new Utf8JsonReader(sampleJson);
                if (JsonDocument.TryParseValue(ref reader, out JsonDocument jsonDoc) && jsonDoc.RootElement.TryGetProperty(notifyCode, out JsonElement json )) {
                    List<string> msgs = json.ToObject<List<string>>();
                    if (msgs.IsNotEmpty()) {
                        var tags= group.list.Select(x => $"{x.id}_{notifyType}");
                        NotifyData notifyData = new NotifyData
                        {
                            hubName = "hita5",
                            sender = "ies5",
                            tags = tags.ToList(),
                            title = msgs[0],
                            eventId = $"{notifyCode}-{_snowflakeId.NextId()}",
                            eventName = $"{msgs[0]}",
                            data = new { value = replaceData }.ToJsonString()
                        };
                        if (msgs.Count == 1)
                        {
                            notifyData.body = msgs[0];
                        }
                        else
                        {
                            replaceData.Keys.ToList().ForEach(x => {
                                msgs[1]=  msgs[1].Replace("{" + x + "}", $"{replaceData[x]}");
                            });
                            notifyData.body = msgs[1];
                        }
                        _ = _httpClient.PostAsJsonAsync(url, notifyData);
                    }
                }
            }
        }
        public class NotifyData { 
            public string hubName { get; set; }
            public string sender { get; set; }
            public List<string> tags { get; set; } = new List<string>();
            public string title { get; set; }
            public string body { get; set; }
            public string eventId { get; set; }
            public string eventName { get; set; }
            public string data { get; set; }
        }
        /// <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; }
    }
}