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

using System;
using System.Threading.Tasks;
using CoreCms.Net.Auth.HttpContextUser;
using CoreCms.Net.Caching.AccressToken;
using CoreCms.Net.Configuration;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using CoreCms.Net.WeChat.Service.HttpClients;
using Essensoft.Paylink.WeChatPay;
using Essensoft.Paylink.WeChatPay.V2;
using Essensoft.Paylink.WeChatPay.V2.Request;
using Microsoft.Extensions.DependencyInjection;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using QRCoder;
using SKIT.FlurlHttpClient.Wechat.Api;
using SKIT.FlurlHttpClient.Wechat.Api.Models;
using SqlSugar;

namespace CoreCms.Net.Services
{
    /// <summary>
    ///     微信支付 接口实现
    /// </summary>
    public class WeChatPayServices : BaseServices<CoreCmsSetting>, IWeChatPayServices
    {
        private readonly IWeChatPayClient _client;
        private readonly IHttpContextUser _user;
        private readonly IServiceProvider _serviceProvider;
        private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;

        private readonly IWeChatPayConfigServices _weChatPayConfigServices;

        private readonly ICoreCmsUserServices _userServices;
        private readonly ICoreCmsUserWeChatInfoServices _userWeChatInfoServices;


        public WeChatPayServices(IHttpContextUser user
            , IWeChatPayClient client
            , ICoreCmsUserServices userServices
            , ICoreCmsUserWeChatInfoServices userWeChatInfoServices, IServiceProvider serviceProvider, IWeChatApiHttpClientFactory weChatApiHttpClientFactory, IWeChatPayConfigServices weChatPayConfigServices)
        {

            _client = client;
            _user = user;
            _userServices = userServices;
            _userWeChatInfoServices = userWeChatInfoServices;
            _serviceProvider = serviceProvider;
            _weChatApiHttpClientFactory = weChatApiHttpClientFactory;
            _weChatPayConfigServices = weChatPayConfigServices;
        }

        /// <summary>
        ///     发起支付
        /// </summary>
        /// <param name="entity">实体数据</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> PubPay(CoreCmsBillPayments entity)
        {
            var jm = new WebApiCallBack();

            var tradeType = GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString();
            if (!string.IsNullOrEmpty(entity.parameters))
            {
                var jObj = (JObject)JsonConvert.DeserializeObject(entity.parameters);
                if (jObj != null && jObj.TryGetValue("trade_type", out var value))
                    tradeType = PayHelper.GetWeiChatPayTradeType(value.ObjectToString());
            }

            var config = await _weChatPayConfigServices.QueryByClauseAsync(p => p.isDefault == true && p.isEnable == true && p.appType == tradeType);
            if (config == null)
            {
                jm.msg = "支付配置信息获取失败";
                return jm;
            }

            if (string.IsNullOrEmpty(config.notifyUrl))
            {
                jm.msg = "未获取到配置的通知地址";
                return jm;
            }

            //构建linkPay请求配置实体
            var payOptions = new WeChatPayOptions
            {
                AppId = config.appId,
                MchId = config.mchId,
                APIKey = config.apiKey,
                APIv3Key = config.apiV3Key,
                Certificate = config.certificate,
                RsaPublicKey = config.rsaPublicKey,
                SubAppId = config.subAppId,
                SubMchId = config.subMchId
            };

            var openId = string.Empty;
            if (tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString() || tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI_OFFICIAL.ToString())
            {
                var type = tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString()
                    ? (int)GlobalEnumVars.UserAccountTypes.微信小程序
                    : (int)GlobalEnumVars.UserAccountTypes.微信公众号;

                var user = await _userWeChatInfoServices.QueryByClauseAsync(p => p.userId == _user.ID && p.type == type, p => p.createTime, OrderByType.Desc);
                if (user == null)
                {
                    jm.msg = "微信用户信息获取失败";
                    return jm;
                }


                openId = user.openid;
            }

            var notifyUrl = config.notifyUrl.EndsWith("/") ? config.notifyUrl + "m-" + config.appId : config.notifyUrl + "/m-" + config.appId;


            var orderRequest = new WeChatPayUnifiedOrderRequest
            {
                Body = entity.payTitle.Length > 40 ? entity.payTitle[..40] : entity.payTitle,
                OutTradeNo = entity.paymentId,
                TotalFee = Convert.ToInt32(entity.money * 100),
                SpBillCreateIp = entity.ip,
                NotifyUrl = notifyUrl,
                TradeType = tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI_OFFICIAL.ToString() ? GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString() : tradeType,
                //OpenId = openId
            };

            if (tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString() || tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI_OFFICIAL.ToString())
            {
                if (!string.IsNullOrEmpty(payOptions.SubMchId))
                {
                    orderRequest.SubOpenId = openId;
                }
                else
                {
                    orderRequest.OpenId = openId;
                }
            }

            var response = await _client.ExecuteAsync(orderRequest, payOptions);
            if (response.ReturnCode == WeChatPayCode.Success && response.ResultCode == WeChatPayCode.Success)
            {
                //App微信支付
                if (tradeType == GlobalEnumVars.WeiChatPayTradeType.APP.ToString())
                {
                    var reqApp = new WeChatPayAppSdkRequest()
                    {
                        PrepayId = response.PrepayId
                    };
                    var parameter = await _client.ExecuteAsync(reqApp, payOptions);
                    parameter.Add("paymentId", entity.paymentId);
                    jm.status = true;
                    jm.msg = "创建微信APP支付环境成功";
                    jm.data = parameter;
                    jm.otherData = response;
                }
                //JsApi通用微信支付
                else if (tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString())
                {
                    // 将参数(parameter)给 公众号前端 让他在微信内H5调起支付(https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=7_7&index=6)
                    var req = new WeChatPayJsApiSdkRequest
                    {
                        Package = "prepay_id=" + response.PrepayId
                    };
                    var parameter = await _client.ExecuteAsync(req, payOptions);
                    parameter.Add("paymentId", entity.paymentId);
                    jm.status = true;
                    jm.msg = "创建JSAPI支付环境成功";
                    jm.data = parameter;
                    jm.otherData = response;
                }
                //JsApi通用微信支付（和上一样，但是为了区分，单独编写。）
                else if (tradeType == GlobalEnumVars.WeiChatPayTradeType.JSAPI_OFFICIAL.ToString())
                {
                    // 将参数(parameter)给 公众号前端 让他在微信内H5调起支付(https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=7_7&index=6)
                    var req = new WeChatPayJsApiSdkRequest
                    {
                        Package = "prepay_id=" + response.PrepayId
                    };
                    var parameter = await _client.ExecuteAsync(req, payOptions);
                    parameter.Add("paymentId", entity.paymentId);
                    jm.status = true;
                    jm.msg = "创建微信公众号支付环境成功";
                    jm.data = parameter;
                    jm.otherData = response;
                }
                //扫码支付
                else if (tradeType == GlobalEnumVars.WeiChatPayTradeType.NATIVE.ToString())
                {
                    jm.status = true;
                    jm.msg = "创建微信扫码支付环境成功";
                    jm.data = new
                    {
                        response,
                        entity.paymentId
                    };
                    //确定是否存在扫码的图片，然后转成base64到前端进行扫码支付
                    if (!string.IsNullOrEmpty(response.CodeUrl) && response.CodeUrl.Contains("weixin://wxpay/bizpayurl?pr="))
                    {
                        using var qrGenerator = new QRCodeGenerator();
                        using var qrCodeData = qrGenerator.CreateQrCode(response.CodeUrl, QRCodeGenerator.ECCLevel.L);
                        using var pngByteQrCode = new PngByteQRCode(qrCodeData);
                        var pngBytes = pngByteQrCode.GetGraphic(20, false);
                        var stringBase64Str = Convert.ToBase64String(pngBytes);
                        jm.otherData = stringBase64Str;
                    }
                }
                //H5支付
                else if (tradeType == GlobalEnumVars.WeiChatPayTradeType.MWEB.ToString())
                {
                    jm.status = true;
                    jm.msg = "创建H5支付环境成功";
                    jm.data = response;
                }
            }
            else
            {
                jm.status = false;
                jm.msg = "微信建立支付请求失败";
                jm.otherData = response;
                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.Web, "微信支付失败", JsonConvert.SerializeObject(response));
            }
            return jm;
        }

        /// <summary>
        ///     用户退款
        /// </summary>
        /// <param name="refundInfo">退款单数据</param>
        /// <param name="paymentInfo">支付单数据</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> Refund(CoreCmsBillRefund refundInfo, CoreCmsBillPayments paymentInfo)
        {
            var jm = new WebApiCallBack();

            var tradeType = GlobalEnumVars.WeiChatPayTradeType.JSAPI.ToString();
            if (!string.IsNullOrEmpty(paymentInfo.parameters))
            {
                var jObj = (JObject)JsonConvert.DeserializeObject(paymentInfo.parameters);
                if (jObj != null && jObj.TryGetValue("trade_type", out var value))
                    tradeType = PayHelper.GetWeiChatPayTradeType(value.ObjectToString());
            }

            var config = await _weChatPayConfigServices.QueryByClauseAsync(p =>
                p.isDefault == true && p.isEnable == true && p.appType == tradeType);
            if (config == null)
            {
                jm.msg = "支付配置信息获取失败";
                return jm;
            }

            if (string.IsNullOrEmpty(config.refundUrl))
            {
                jm.msg = "未获取到配置的退款通知地址";
                return jm;
            }

            //构建linkPay请求配置实体
            var payOptions = new WeChatPayOptions
            {
                AppId = config.appId,
                MchId = config.mchId,
                APIKey = config.apiKey,
                APIv3Key = config.apiV3Key,
                Certificate = config.certificate,
                RsaPublicKey = config.rsaPublicKey,
                SubAppId = config.subAppId,
                SubMchId = config.subMchId
            };


            var request = new WeChatPayRefundRequest
            {
                OutRefundNo = refundInfo.refundId,
                TransactionId = paymentInfo.tradeNo,
                OutTradeNo = paymentInfo.paymentId,
                TotalFee = Convert.ToInt32(paymentInfo.money * 100),
                RefundFee = Convert.ToInt32(refundInfo.money * 100),
                NotifyUrl = config.refundUrl
            };
            var response = await _client.ExecuteAsync(request, payOptions);

            if (response.ReturnCode == WeChatPayCode.Success && response.ResultCode == WeChatPayCode.Success)
            {
                jm.status = true;
                jm.msg = "退款成功";
                jm.data = response;
            }
            else
            {
                jm.status = false;
                jm.msg = "退款失败：" + response.ErrCodeDes;
                jm.data = response;
            }

            return jm;
        }

    }
}