using Chat.Framework.WXSdk.Implement;
using Grpc.Core;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using WechatProto;
using static WechatProto.Wechat;

namespace Chat.Framework.WXSdk.IPAD
{
    public enum GrpcType : int
    {
        Awei = 0,
        Laoyao = 1,
        Huangfan = 2,
        未知 = -1
    }
    internal class GrpcConfig
    {
        public GrpcType Type { get; set; }
        public string Appid { get; set; }

        public string Appkey { get; set; }

        /// <summary>
        /// 启用SSL加密
        /// </summary>
        public bool EnableSSL { get; set; } = true;

        /// <summary>
        /// 服务器全局解密Key
        /// </summary>
        public byte[] RandomEncryKey { get; set; }


        ///// <summary>
        ///// 服务端地址
        ///// </summary>
        //public string GrpcServer { get; set; }

        ///// <summary>
        ///// 备用服务器地址
        ///// </summary>
        //public string GrpcServerBackup { get; set; }

        /// <summary>
        /// 版本号
        /// </summary>
        public string Version { get; set; }

        /// <summary>
        /// Grpc证书
        /// </summary>
        public string GrpcCredentials { get; set; }

        /// <summary>
        /// 机器人码
        /// </summary>
        public string MachineCode { get; set; }


        private Metadata _authHeader;
        /// <summary>
        /// Grpc验证头
        /// </summary>
        public Metadata AuthHeader
        {
            get
            {
                if (_authHeader == null)
                {
                    _authHeader = new Metadata();
                    _authHeader.Add("appid", Appid);
                    _authHeader.Add("appkey", Appkey);
                }
                return _authHeader;
            }
        }

        /// <summary>
        /// 服务器IP
        /// </summary>
        public List<string> Servers { get; set; }



        private static Dictionary<GrpcType, GrpcConfig> grpcConfig = new Dictionary<GrpcType, GrpcConfig>();
        public static GrpcConfig Get(GrpcType type, bool refresh = false)
        {
            //if (type == GrpcType.Huangfan)
            //{
            //}
            ////type = GrpcType.Laoyao;//TODO 这里强制用老妖的

            lock (grpcConfig)
            {
                GrpcConfig config = grpcConfig.ContainsKey(type) ? grpcConfig[type] : null;
                if (config != null && !refresh) return config;
                switch (type)
                {
                    case GrpcType.Awei:
                        config = new GrpcConfig()
                        {

                            Appid = "v1_meesii_CodeVip",
                            Appkey = "v2_d6fb34d020a209471fe7122d4a55e69c",
                            Servers = new List<string>() { "grpc.wxipad.com:12580" },
                            MachineCode = "v3_e9de924f32fae3126b42fac40b0f5b6d",
                            RandomEncryKey = CsharpHttpHelper.HttpExtend.RandomByte(16),
                            EnableSSL = true,
                            GrpcCredentials = @"-----BEGIN CERTIFICATE-----
MIIDqjCCApKgAwIBAgIJAOf7+/avi9foMA0GCSqGSIb3DQEBCwUAMGoxCzAJBgNV
BAYTAkNOMQswCQYDVQQIDAJ4eDELMAkGA1UEBwwCeHgxCzAJBgNVBAoMAnh4MQsw
CQYDVQQLDAJ4eDEUMBIGA1UEAwwLd2VjaGF0QHJvb3QxETAPBgkqhkiG9w0BCQEW
Anh4MB4XDTE4MDUwODAwMzE1MFoXDTI4MDUwNTAwMzE1MFowajELMAkGA1UEBhMC
Q04xCzAJBgNVBAgMAnh4MQswCQYDVQQHDAJ4eDELMAkGA1UECgwCeHgxCzAJBgNV
BAsMAnh4MRQwEgYDVQQDDAt3ZWNoYXRAcm9vdDERMA8GCSqGSIb3DQEJARYCeHgw
ggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDNcWVlhOpXjqivCpJpVHCG
eM+Q/e83MDpqXmlT33hAFlCfUzWYYhFAHwc+xShkvuoaBwKpAr0fcHT7Kj4TLSJB
F9FwBccPp4Tv0YH0h4pzZ9nWZCMGXB5TlXAreXrcu8Qab0MPAxMKtMO0FZzQawRD
mO/S43u6tDBrhW2zgFzCUo+cRiCYRXoewuFVT4RT7eYvEu579oy4mto7YpR8GfPY
ywiTh7D/4To7nNoWbly84WB9ZSQ8HZoC1KTykqaeSGw7xUhKEoPoeKPke1ECfXB2
lSZMwKar2IU0BVlvxL55EMF8oXJozLVEZeVIZ4Wp9EFY2KaZJowgoOa1I+vcwBbd
AgMBAAGjUzBRMB0GA1UdDgQWBBR2SmMGUpTN/Dl0wcSYcPav6o01iDAfBgNVHSME
GDAWgBR2SmMGUpTN/Dl0wcSYcPav6o01iDAPBgNVHRMBAf8EBTADAQH/MA0GCSqG
SIb3DQEBCwUAA4IBAQAdCSkska27VdLcGqK9/sraopxaX31Nseci/sJbimIHxr+q
DwAHExU5sJ1qT827n2OpF/lWMRhnJZ3ubeJ8oGA3CAKu4EiKKGA1hGOLCbEvagCc
sdBSegk050qkMssJzNaw7boZB8vek1RDK32Fuhsh4m+MUZBj6bJCdGW9K+ZMmpZl
bMwmsgqV6+EMvr+PhFHy8bOAdIs4/eOTjW7R0JwYgFArVXMrVKgiRknkhM+PBBHG
DPWO0j3855SF2X5r4jQs2PvKGJjOMuQeIgsf2GbwSQhXEhM8lGdjn9up8hm7VSXf
x8wZquXczPSdDez7tP+g9nKbxcJtGnxo8+Jntmvs
-----END CERTIFICATE-----",
                            Version = "7.0.3"
                        };
                        break;
                    case GrpcType.Laoyao:
                        config = new GrpcConfig()
                        {
                            Appid = "v1_LCEO_Code",
                            Appkey = "v2_4d5d55d6fbb6ce87b0f53019fefebb89",
                            Servers = new List<string>() { "111.230.216.32:12588" },
                            MachineCode = "v3_7af2592d5c49d94424bac95e80cb07a4",
                            RandomEncryKey = CsharpHttpHelper.HttpExtend.RandomByte(16),
                            EnableSSL = true,
                            GrpcCredentials = @"-----BEGIN CERTIFICATE-----
MIIDqjCCApKgAwIBAgIJAOf7+/avi9foMA0GCSqGSIb3DQEBCwUAMGoxCzAJBgNV
BAYTAkNOMQswCQYDVQQIDAJ4eDELMAkGA1UEBwwCeHgxCzAJBgNVBAoMAnh4MQsw
CQYDVQQLDAJ4eDEUMBIGA1UEAwwLd2VjaGF0QHJvb3QxETAPBgkqhkiG9w0BCQEW
Anh4MB4XDTE4MDUwODAwMzE1MFoXDTI4MDUwNTAwMzE1MFowajELMAkGA1UEBhMC
Q04xCzAJBgNVBAgMAnh4MQswCQYDVQQHDAJ4eDELMAkGA1UECgwCeHgxCzAJBgNV
BAsMAnh4MRQwEgYDVQQDDAt3ZWNoYXRAcm9vdDERMA8GCSqGSIb3DQEJARYCeHgw
ggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDNcWVlhOpXjqivCpJpVHCG
eM+Q/e83MDpqXmlT33hAFlCfUzWYYhFAHwc+xShkvuoaBwKpAr0fcHT7Kj4TLSJB
F9FwBccPp4Tv0YH0h4pzZ9nWZCMGXB5TlXAreXrcu8Qab0MPAxMKtMO0FZzQawRD
mO/S43u6tDBrhW2zgFzCUo+cRiCYRXoewuFVT4RT7eYvEu579oy4mto7YpR8GfPY
ywiTh7D/4To7nNoWbly84WB9ZSQ8HZoC1KTykqaeSGw7xUhKEoPoeKPke1ECfXB2
lSZMwKar2IU0BVlvxL55EMF8oXJozLVEZeVIZ4Wp9EFY2KaZJowgoOa1I+vcwBbd
AgMBAAGjUzBRMB0GA1UdDgQWBBR2SmMGUpTN/Dl0wcSYcPav6o01iDAfBgNVHSME
GDAWgBR2SmMGUpTN/Dl0wcSYcPav6o01iDAPBgNVHRMBAf8EBTADAQH/MA0GCSqG
SIb3DQEBCwUAA4IBAQAdCSkska27VdLcGqK9/sraopxaX31Nseci/sJbimIHxr+q
DwAHExU5sJ1qT827n2OpF/lWMRhnJZ3ubeJ8oGA3CAKu4EiKKGA1hGOLCbEvagCc
sdBSegk050qkMssJzNaw7boZB8vek1RDK32Fuhsh4m+MUZBj6bJCdGW9K+ZMmpZl
bMwmsgqV6+EMvr+PhFHy8bOAdIs4/eOTjW7R0JwYgFArVXMrVKgiRknkhM+PBBHG
DPWO0j3855SF2X5r4jQs2PvKGJjOMuQeIgsf2GbwSQhXEhM8lGdjn9up8hm7VSXf
x8wZquXczPSdDez7tP+g9nKbxcJtGnxo8+Jntmvs
-----END CERTIFICATE-----",
                            Version = "7.0.3"
                        };
                        //Console.WriteLine(config.AuthHeader);
                        break;
                    case GrpcType.Huangfan:
                        config = new GrpcConfig()
                        {
                            Appid = "v1_23229f55b208d33b_CodeVip",
                            Appkey = "v2_d72d0b8d148afb50e8a0beed37efd1b5",
                            Servers = new List<string>() { "47.93.227.173:12580" },
                            MachineCode = "v3_951b8b394d904962d981f02e5d4cee31",
                            RandomEncryKey = CsharpHttpHelper.HttpExtend.RandomByte(16),
                            GrpcCredentials = @"-----BEGIN CERTIFICATE-----
MIIDqjCCApKgAwIBAgIJAOf7+/avi9foMA0GCSqGSIb3DQEBCwUAMGoxCzAJBgNV
BAYTAkNOMQswCQYDVQQIDAJ4eDELMAkGA1UEBwwCeHgxCzAJBgNVBAoMAnh4MQsw
CQYDVQQLDAJ4eDEUMBIGA1UEAwwLd2VjaGF0QHJvb3QxETAPBgkqhkiG9w0BCQEW
Anh4MB4XDTE4MDUwODAwMzE1MFoXDTI4MDUwNTAwMzE1MFowajELMAkGA1UEBhMC
Q04xCzAJBgNVBAgMAnh4MQswCQYDVQQHDAJ4eDELMAkGA1UECgwCeHgxCzAJBgNV
BAsMAnh4MRQwEgYDVQQDDAt3ZWNoYXRAcm9vdDERMA8GCSqGSIb3DQEJARYCeHgw
ggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDNcWVlhOpXjqivCpJpVHCG
eM+Q/e83MDpqXmlT33hAFlCfUzWYYhFAHwc+xShkvuoaBwKpAr0fcHT7Kj4TLSJB
F9FwBccPp4Tv0YH0h4pzZ9nWZCMGXB5TlXAreXrcu8Qab0MPAxMKtMO0FZzQawRD
mO/S43u6tDBrhW2zgFzCUo+cRiCYRXoewuFVT4RT7eYvEu579oy4mto7YpR8GfPY
ywiTh7D/4To7nNoWbly84WB9ZSQ8HZoC1KTykqaeSGw7xUhKEoPoeKPke1ECfXB2
lSZMwKar2IU0BVlvxL55EMF8oXJozLVEZeVIZ4Wp9EFY2KaZJowgoOa1I+vcwBbd
AgMBAAGjUzBRMB0GA1UdDgQWBBR2SmMGUpTN/Dl0wcSYcPav6o01iDAfBgNVHSME
GDAWgBR2SmMGUpTN/Dl0wcSYcPav6o01iDAPBgNVHRMBAf8EBTADAQH/MA0GCSqG
SIb3DQEBCwUAA4IBAQAdCSkska27VdLcGqK9/sraopxaX31Nseci/sJbimIHxr+q
DwAHExU5sJ1qT827n2OpF/lWMRhnJZ3ubeJ8oGA3CAKu4EiKKGA1hGOLCbEvagCc
sdBSegk050qkMssJzNaw7boZB8vek1RDK32Fuhsh4m+MUZBj6bJCdGW9K+ZMmpZl
bMwmsgqV6+EMvr+PhFHy8bOAdIs4/eOTjW7R0JwYgFArVXMrVKgiRknkhM+PBBHG
DPWO0j3855SF2X5r4jQs2PvKGJjOMuQeIgsf2GbwSQhXEhM8lGdjn9up8hm7VSXf
x8wZquXczPSdDez7tP+g9nKbxcJtGnxo8+Jntmvs
-----END CERTIFICATE-----",
                            Version = "7.0.3"
                        };
                        Console.WriteLine(config.AuthHeader);
                        break;
                    default:
                        break;
                }
                if (config != null)
                {
                    config.Type = type;
                    grpcConfig[type] = config;
                }

                return config;
            }
        }

    }
    class GrpcClient : IDisposable
    {
        private Channel _channel;
        private WechatClient _baseClient;

        /// <summary>
        /// GRpc配置信息
        /// </summary>
        public GrpcConfig Config { get; private set; }

        public GrpcClient(GrpcConfig config = null)
        {
            if (config != null)
            {
                Config = config;
            }
            Init();
        }

        public bool IsConnected
        {
            get
            {
                if (_channel != null && (_channel.State == ChannelState.Ready || _channel.State == ChannelState.Connecting || _channel.State == ChannelState.Idle))
                {
                    return true;
                }
                return false;
            }
        }

        /// <summary>
        /// 初始化
        /// </summary>
        public void Init()
        {
            if (Config.Servers.Count == 0)
            {
                LogHelper.GetSingleObj().Error("Grpc服务器", "当前无可用的Grpc服务器");
                return;
            }
            this.Stop();

            Config.Servers = ChatClient.GetServerDataMethod("grpc_type_" + Config.Type.ToString().ToLower()).Split(',').ToList();
            //if (Config.Type == GrpcType.Huangfan) Config.Servers = new string[] { "106.15.26.141:12580" }.ToList();
            // Config.Servers = new string[] { "45.253.67.81:12580" }.ToList();
            //switch (Config.Type)
            //{
            //    case GrpcType.Awei:

            //        break;
            //    case GrpcType.Laoyao:
            //        break;
            //    case GrpcType.Huangfan:
            //        break;
            //    default:
            //        break;
            //}

            var channelOptions = new List<ChannelOption>
            {
                new ChannelOption(ChannelOptions.SslTargetNameOverride,"wechat@root"),
                new ChannelOption(ChannelOptions.MaxConcurrentStreams,int.MaxValue),
                new ChannelOption(ChannelOptions.MaxSendMessageLength,int.MaxValue),
                new ChannelOption(ChannelOptions.MaxReceiveMessageLength,int.MaxValue)
            };

            if (Config.EnableSSL)
            {
                var grpcCredentials = new SslCredentials(Config.GrpcCredentials);
                _channel = new Channel(ServerIp, grpcCredentials, channelOptions);
            }
            else
                _channel = new Channel(ServerIp, ChannelCredentials.Insecure, channelOptions);

            _baseClient = new WechatClient(_channel);
        }

        /// <summary>
        /// 停止GRpc
        /// </summary>
        public void Stop()
        {
            if (_channel != null)
            {
                try
                {
                    _channel.ShutdownAsync().Wait();
                    _baseClient = null;
                    _channel = null;
                }
                catch
                {
                    // ignored
                }

            }

        }
        public DateTime LastTime { get; private set; }


        /// <summary>
        /// Grpc发包（5次尝试）
        /// </summary>
        /// <param name="pack"></param>
        /// <returns></returns>
        public Task<WechatMsg> Send(WechatMsg _pack, WXClientImpl_IPAD weixin)
        {

            #region 2019年8月1日21:49:42
            ////while (_baseClient == null)
            ////{
            ////    Thread.Sleep(100);
            ////}

            //return Task.Run(() =>
            //{
            //    var tryTimes = 3;

            //again:
            //    var cmd = 0;
            //    try
            //    {
            //        if (this._channel == null) this.Init();
            //        LastTime = DateTime.Now;
            //        cmd = pack.BaseMsg.Cmd;
            //        var send = pack.Clone();
            //        send.Token = Config.MachineCode;
            //        //return _baseClient.HelloWechat(send, Config.AuthHeader, DateTime.UtcNow.AddSeconds(10));
            //        return _baseClient.HelloWechatAsync(send, Config.AuthHeader, DateTime.UtcNow.AddSeconds(10)).ResponseAsync.Result;
            //    }
            //    catch (RpcException ex)
            //    {
            //        if (tryTimes >= 0)
            //        {
            //            tryTimes--;
            //            Thread.Sleep(1000);
            //            if (ex.StatusCode == StatusCode.Unknown || ex.StatusCode == StatusCode.DeadlineExceeded)
            //            {
            //                this.Init();
            //                goto again;
            //            }
            //            else if (ex.StatusCode == StatusCode.Unavailable) goto again;
            //        }
            //        LogHelper.GetSingleObj().Error("Grpc异常" + cmd, $"StatusCode ->{ex.StatusCode} Msg ->{ex.Message}");

            //        return null;
            //    }

            //});
            #endregion

            #region

            //while (_baseClient == null)
            //{
            //    Thread.Sleep(100);
            //}
            WechatMsg pack = _pack;
            return Task.Run<WechatMsg>(() =>
            {
                var tryTimes = 3;
                for (int i = 0; i < tryTimes; i++)
                {
                    if (i > 0) Thread.Sleep(1000);
                    var cmd = 0;
                    try
                    {
                        if (this._channel == null || _baseClient == null)
                            this.Init();
                        LastTime = DateTime.Now;
                        cmd = pack.BaseMsg.Cmd;
                        var send = pack.Clone();
                        send.Token = Config.MachineCode;
                        //return _baseClient.HelloWechat(send, Config.AuthHeader, DateTime.UtcNow.AddSeconds(10));
                        return _baseClient.HelloWechatAsync(send, Config.AuthHeader, DateTime.UtcNow.AddSeconds(10)).ResponseAsync.Result;
                    }

                    catch (RpcException ex)
                    {

                        LogHelper.GetSingleObj().Error("Grpc异常" + cmd, $"StatusCode ->{ex.StatusCode} Msg ->{ex.Message}");
                        if (ex.StatusCode == StatusCode.Unavailable) continue;
                        else if (ex.StatusCode == StatusCode.Unknown || ex.StatusCode == StatusCode.DeadlineExceeded)
                        {
                            this.Init();
                            continue;
                        }
                    }
                    catch (Exception ex)
                    {
                        LogHelper.GetSingleObj().Error("Grpc异常" + cmd, $"Msg ->{ex.InnerException}");
                        continue;
                    }
                }
                return null;
            });
            #endregion
        }

        public void Dispose()
        {

        }

        /// <summary>
        /// 上次获取时间
        /// </summary>
        private readonly DateTime _checkDate = DateTime.Now;

        /// <summary>
        /// Grpc服务器IP
        /// </summary>
        private string _serverIp;

        /// <summary>
        /// Grpc服务器IP
        /// </summary>
        public string ServerIp
        {
            get
            {
                //return "grpc.wxipad.com:12580";

                //if (string.IsNullOrEmpty(ServerIp) || (DateTime.Now - _checkDate).TotalSeconds >= 300)
                //{
                //    GetConfig();
                //}

                var random = new Random();
                var index = random.Next(0, Config.Servers.Count);
                _serverIp = Config.Servers[index];
                return _serverIp;
            }
        }
    }
}