/***********************************************************************
 *            Project: CoreCms
 *        ProjectName: 百分兵法管理系统                               
 *                Web: hhtp://chuanyin.com                     
 *             Author:                                        
 *              Email:                               
 *         CreateTime: 202403/02   
 *        Description: 暂无
 ***********************************************************************/

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.Sms;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using Flurl.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.ComponentTCBBatchCreateContainerServiceVersionResponse.Types;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.WxaApiUserLogSearchResponse.Types.Data.Types.RealtimeLog.Types;


namespace CoreCms.Net.Services
{
    /// <summary>
    /// 短信发送日志 接口实现
    /// </summary>
    public class CoreCmsSmsServices : BaseServices<CoreCmsSms>, ICoreCmsSmsServices
    {
        private readonly ICoreCmsSmsRepository _dal;
        private readonly ICoreCmsSettingServices _settingServices;
        private readonly IUnitOfWork _unitOfWork;

        private readonly IHttpContextAccessor _httpContextAccessor;

        public CoreCmsSmsServices(IUnitOfWork unitOfWork
            , ICoreCmsSmsRepository dal
            , IHttpContextAccessor httpContextAccessor, ICoreCmsSettingServices settingServices)
        {
            this._dal = dal;
            base.BaseDal = dal;
            _unitOfWork = unitOfWork;

            _httpContextAccessor = httpContextAccessor;
            _settingServices = settingServices;
        }




        #region 发送短信（验证码）

        /// <summary>
        /// 发送短信（验证码）
        /// </summary>
        /// <param name="type"></param>
        /// <param name="mobile"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> DoSendSms(string type, string mobile)
        {
            var jm = new WebApiCallBack();
            var smsOptions = await _settingServices.GetSmsOptions();
            if (smsOptions.Enabled == false)
            {
                jm.msg = "短信功能未开启";
                return jm;
            }

            Random rd = new Random();
            int codeNumber = rd.Next(100000, 999999);


            var dt = DateTime.Now;

            //获取当前ip今日的发送记录
            var ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1";
            if (string.IsNullOrEmpty(ip))
            {
                jm.msg = "短信发送IP获取失败";
                return jm;
            }
            var black = smsOptions.SmsIpSendBlackList.Split('|').ToList();
            if (black.Count > 0 && black.Contains(ip))
            {
                jm.msg = "此IP被禁止短信业务";
                return jm;
            }
            var white = smsOptions.SmsIpSendWhiteList.Split('|').ToList();
            if (white.Count <= 0 || !white.Contains(ip))
            {
                var startDateTime = new DateTime(DateTime.Now.Year, DateTime.Now.Month, DateTime.Now.Day, 0, 0, 0, DateTimeKind.Utc);
                var endDateTime = new DateTime(DateTime.Now.Year, DateTime.Now.Month, DateTime.Now.Day, 23, 59, 59, DateTimeKind.Utc);

                var sendCount = await _dal.GetCountAsync(p => p.ip.Equals(ip) && p.createTime > startDateTime && p.createTime < endDateTime);
                if (smsOptions.SmsIpSendNumber > 0 && sendCount > smsOptions.SmsIpSendNumber)
                {
                    jm.msg = "此IP被已超过每日短信发送限额。";
                    return jm;
                }
            }

            //获取是否存在
            var endDt = dt.AddMinutes(10);

            var oldLog = await _dal.QueryByClauseAsync(p => p.code == type && p.mobile == mobile && p.createTime > dt && p.createTime < endDt, p => p.id, OrderByType.Desc);
            if (oldLog == null)
            {
                oldLog = new CoreCmsSms();
                oldLog.code = type;
                oldLog.createTime = dt;
                oldLog.mobile = mobile;
                oldLog.ip = ip;
                oldLog.isUsed = false;
                var obj = new
                {
                    code = codeNumber
                };
                switch (type)
                {
                    case "login":
                        oldLog.contentBody = "您正在登陆账号，验证码是" + codeNumber + "，请勿告诉他人。";//您本次登陆的验证码是：" + codeNumber + "，请不要将验证码泄露给他人！"
                        oldLog.parameters = JsonConvert.SerializeObject(obj);
                        break;
                    default:
                        oldLog.contentBody = "您的验证码是" + codeNumber + "，请勿告诉他人。"; //"您验证码是：" + codeNumber + "，请不要将验证码泄露给他人！";
                        oldLog.parameters = JsonConvert.SerializeObject(obj);
                        break;
                }
                await _dal.InsertAsync(oldLog);
            }

            var result = await SendSms(oldLog.mobile, oldLog.contentBody, smsOptions);

            jm.status = result.IsSuccess;
            jm.msg = result.IsSuccess ? "发送成功" : result.Message;
            jm.otherData = result;

            return jm;
        }
        #endregion

        #region 校验短信验证码
        /// <summary>
        /// 校验短信验证码
        /// </summary>
        /// <param name="phone"></param>
        /// <param name="verCode"></param>
        /// <param name="code"></param>
        /// <returns></returns>

        public async Task<bool> Check(string phone, string verCode, string code)
        {
            var smsInfo = await _dal.QueryByClauseAsync(p =>
                p.mobile == phone && p.code == code && p.createTime < DateTime.Now && p.isUsed == false, p => p.createTime, OrderByType.Desc);
            if (smsInfo != null)
            {
                var parameters = JObject.Parse(smsInfo.parameters);
                if (parameters.ContainsKey("code"))
                {
                    var dataCode = parameters["code"]?.ToString();
                    if (dataCode != verCode) return false;
                    smsInfo.isUsed = true;
                    await _dal.UpdateAsync(smsInfo);
                    return true;
                }
                return false;
            }
            return false;
        }
        #endregion

        #region 接口通道发送短信

        /// <summary>
        /// 接口通道发送短信
        /// </summary>
        /// <param name="mobile"></param>
        /// <param name="contentBody"></param>
        /// <param name="smsOptions">配置文件</param>
        public async Task<SMSReturnData> SendSms(string mobile, string contentBody, SmsOptions smsOptions)
        {
            if (smsOptions.Enabled)
            {
                var result = new SMSReturnData()
                {
                    ReturnStatus = "faild",
                    Message = "短信发送失败",
                    RemainPoint = 0,
                    TaskID = 0,
                    SuccessCounts = 0
                };

                string url = smsOptions.ApiUrl;
                string data = "CorpID="+ smsOptions.Account + "&Pwd="+ smsOptions.Password + "&Mobile=" + mobile + "&Content=" + contentBody + "【川印文化集团股份有限公司】&SendTime="; //退订回N
                string ssss = await HttpClientPostGB2312Async(url, "POST", data);
                int aaaa = 0;
                if (int.TryParse(ssss, out aaaa) && aaaa > 0)
                {
                    result = new SMSReturnData()
                    {
                        ReturnStatus = "success",
                        Message = "短信发送成功",
                        RemainPoint = 0,
                        TaskID = 0,
                        SuccessCounts = 1,
                        IsSuccess = true,
                    };
                }


                //var result = await smsOptions.ApiUrl.PostUrlEncodedAsync(new
                //{
                //    action = "send",
                //    userid = smsOptions.UserId,
                //    account = smsOptions.Account,
                //    password = smsOptions.Password,
                //    mobile,
                //    content = "【" + smsOptions.Signature + "】" + contentBody,
                //    rt = "json"
                //}).ReceiveJson<SMSReturnData>();
                //result.IsSuccess = result.ReturnStatus.ToLowerInvariant() == "success";
                return result;
            }
            else
            {
                var result = new SMSReturnData()
                {
                    ReturnStatus = "faild",
                    Message = "短信功能未开启",
                    RemainPoint = 0,
                    TaskID = 0,
                    SuccessCounts = 0
                };
                return result;
            }
        }
        #endregion

        #region 发送短信统一方法
        /// <summary>
        /// 发送短信统一方法
        /// </summary>
        /// <param name="mobile">接受者手机号码</param>
        /// <param name="code">模板编码</param>
        /// <param name="parameters">参数</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> Send(string mobile, string code, JObject parameters)
        {
            var jm = new WebApiCallBack();
            var smsOptions = await _settingServices.GetSmsOptions();
            if (smsOptions.Enabled == false)
            {
                jm.msg = "短信功能未开启";
                return jm;
            }
            var dt = DateTime.Now;

            //获取当前ip今日的发送记录
            var ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "";
            if (string.IsNullOrEmpty(ip))
            {
                jm.msg = "短信发送IP获取失败";
                return jm;
            }
            var black = smsOptions.SmsIpSendBlackList.Split('|').ToList();
            if (black.Count > 0 && black.Contains(ip))
            {
                jm.msg = "此IP被禁止短信业务";
                return jm;
            }
            var white = smsOptions.SmsIpSendWhiteList.Split('|').ToList();
            if (white.Count <= 0 || !white.Contains(ip))
            {
                var startDateTime = new DateTime(DateTime.Now.Year, DateTime.Now.Month, DateTime.Now.Day, 0, 0, 0,
                    DateTimeKind.Utc);
                var endDateTime = new DateTime(DateTime.Now.Year, DateTime.Now.Month, DateTime.Now.Day, 23, 59, 59,
                    DateTimeKind.Utc);

                var sendCount = await _dal.GetCountAsync(p => p.ip.Equals(ip) && p.createTime > startDateTime && p.createTime < endDateTime);
                if (smsOptions.SmsIpSendNumber > 0 && sendCount > smsOptions.SmsIpSendNumber)
                {
                    jm.msg = "此IP被已超过每日短信发送限额。";
                    return jm;
                }
            }

            if (string.IsNullOrEmpty(mobile))
            {
                jm.msg = GlobalErrorCodeVars.Code11051;
                return jm;
            }
            var isUsed = false;
            if (code == GlobalEnumVars.SmsMessageTypes.Reg.ToString() || code == GlobalEnumVars.SmsMessageTypes.Login.ToString() || code == GlobalEnumVars.SmsMessageTypes.Veri.ToString())
            {
                var newCreateTime = DateTime.Now.AddSeconds(-60);
                var smsInfo = await _dal.QueryByClauseAsync(p =>
                    p.mobile == mobile && p.code == code && p.createTime < newCreateTime && p.isUsed == false);
                if (smsInfo != null)
                {
                    var ts = dt - smsInfo.createTime;
                    if (ts.Seconds < 60)
                    {
                        jm.msg = "两次发送时间间隔小于60秒";
                        return jm;
                    }
                    parameters = JObject.Parse(smsInfo.parameters);
                }
                else
                {
                    Random rd = new Random();
                    int codeNumber = rd.Next(100000, 999999);
                    if (parameters.ContainsKey("code"))
                    {
                        parameters.Remove("code");
                    }
                    parameters.Add("code", codeNumber);
                }
                isUsed = false;
            }
            else
            {
                isUsed = true;
            }

            var str = string.Empty;
            var allConfigs = await _settingServices.GetConfigDictionaries();

            if (code == GlobalEnumVars.SmsMessageTypes.Reg.ToString())
            {
                // 账户注册
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForReg);
                if (!string.IsNullOrEmpty(msg))
                {
                    var sendCode = string.Empty;
                    if (parameters.ContainsKey("code"))
                    {
                        sendCode = parameters["code"]?.ToString();
                    }
                    str = msg.Replace("{code}", sendCode);
                }
            }
            else if (code == GlobalEnumVars.SmsMessageTypes.Login.ToString())
            {
                // 账户登录
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForLogin);
                if (!string.IsNullOrEmpty(msg))
                {
                    var sendCode = string.Empty;
                    if (parameters.ContainsKey("code"))
                    {
                        sendCode = parameters["code"]?.ToString();
                    }
                    str = msg.Replace("{code}", sendCode);
                }
            }
            else if (code == GlobalEnumVars.SmsMessageTypes.Veri.ToString())
            {
                // 验证验证码
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForVeri);
                if (!string.IsNullOrEmpty(msg))
                {
                    var sendCode = string.Empty;
                    if (parameters.ContainsKey("code"))
                    {
                        sendCode = parameters["code"]?.ToString();
                    }
                    str = msg.Replace("{code}", sendCode);
                }
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.CreateOrder.ToString())
            {
                // 订单创建
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForCreateOrder);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.OrderPayed.ToString())
            {
                // 订单支付通知买家
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForOrderPayed);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.RemindOrderPay.ToString())
            {
                // 未支付催单
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForRemindOrderPay);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.DeliveryNotice.ToString())
            {
                // 订单发货
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForDeliveryNotice);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.AfterSalesPass.ToString())
            {
                // 售后审核通过
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForAfterSalesPass);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.RefundSuccess.ToString())
            {
                // 退款已处理
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForRefundSuccess);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.SellerOrderNotice.ToString())
            {
                // 订单支付通知卖家
                var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForSellerOrderNotice);
                str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
            }
            else if (code == GlobalEnumVars.PlatformMessageTypes.Common.ToString())
            {
                //通用类型
                var tpl = string.Empty;
                if (parameters.ContainsKey("tpl"))
                {
                    tpl = parameters["tpl"]?.ToString();
                }
                str = tpl;
                if (string.IsNullOrEmpty(str))
                {
                    var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForCommon);
                    str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
                }
            }

            if (string.IsNullOrEmpty(str))
            {
                jm.msg = GlobalErrorCodeVars.Code10009;
                return jm;
            }

            var oldLog = new CoreCmsSms();
            oldLog.mobile = mobile;
            oldLog.code = code;
            oldLog.parameters = JsonConvert.SerializeObject(parameters);
            oldLog.contentBody = str;
            oldLog.createTime = dt;
            oldLog.ip = ip;
            oldLog.isUsed = isUsed;

            await _dal.InsertAsync(oldLog);

            var result = await SendSms(oldLog.mobile, oldLog.contentBody, smsOptions);

            jm.status = result.IsSuccess;
            jm.msg = result.IsSuccess ? "发送成功" : result.Message;

            return jm;
        }
        #endregion

        public async Task<string> HttpClientPostGB2312Async(string url, string Method, string data = "")
        {
            string _url = url;// "http://localhost:65022/login/getaa";
            string jsonParam = data;// "{\"a\":\"aa\",\"b\":\"bb\",\"c\":\"cc\"}";
            var request = (HttpWebRequest)WebRequest.Create(_url);
            request.Method = Method;//"POST";
            request.ContentType = "application/x-www-form-urlencoded;charset=GB2312";
            var byteData = Encoding.GetEncoding("GB2312").GetBytes(jsonParam);
            var length = byteData.Length;
            request.ContentLength = length;
            request.ServicePoint.Expect100Continue = false;
            //ServicePointManager.Expect100Continue = false;
            request.Timeout = 5000; //是进行后续同步请求时使用 GetResponse 方法等待响应以及 GetRequestStream 方法等待流所允许的毫秒数
            var writer = request.GetRequestStream();
            await writer.WriteAsync(byteData, 0, length);
            writer.Close();

            //接收响应内容
            var response = (HttpWebResponse)request.GetResponse();
            var responseString = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("utf-8")).ReadToEnd();
            return responseString.ToString();
        }
    }
}