/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Loging;
|
using CoreCms.Net.Model.Entities;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Options;
|
using Newtonsoft.Json;
|
using NLog;
|
using System;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
using Essensoft.Paylink.WeChatPay;
|
using Essensoft.Paylink.WeChatPay.V2;
|
using Essensoft.Paylink.WeChatPay.V2.Notify;
|
|
namespace CoreCms.Net.Web.WebApi.Controllers.PayNotify
|
{
|
/// <summary>
|
/// 微信支付异步通知
|
/// </summary>
|
[Route("Notify/[controller]/[action]")]
|
public class WeChatPayController : ControllerBase
|
{
|
private readonly ICoreCmsBillPaymentsServices _billPaymentsServices;
|
private readonly ICoreCmsBillRefundServices _billRefundServices;
|
private readonly IWeChatPayNotifyClient _client;
|
private readonly IRedisOperationRepository _redisOperationRepository;
|
|
private readonly IWeChatPayConfigServices _weChatPayConfigServices;
|
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public WeChatPayController(
|
IWeChatPayNotifyClient client
|
, ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsBillRefundServices billRefundServices, IRedisOperationRepository redisOperationRepository, IWeChatPayConfigServices weChatPayConfigServices)
|
{
|
_client = client;
|
_billPaymentsServices = billPaymentsServices;
|
_billRefundServices = billRefundServices;
|
_redisOperationRepository = redisOperationRepository;
|
_weChatPayConfigServices = weChatPayConfigServices;
|
}
|
|
/// <summary>
|
/// 统一下单支付结果通知
|
/// </summary>
|
[HttpPost]
|
[Route("m-{appid}")]
|
public async Task<IActionResult> Unifiedorder([FromRoute(Name = "appid")] string appid)
|
{
|
try
|
{
|
//NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功接收appid", JsonConvert.SerializeObject(appid));
|
|
var config = await _weChatPayConfigServices.QueryByClauseAsync(p => p.isDefault == true && p.isEnable == true && p.appId == appid);
|
//构建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 notify = await _client.ExecuteAsync<WeChatPayUnifiedOrderNotify>(Request, payOptions);
|
if (notify.ReturnCode == WeChatPayCode.Success)
|
{
|
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.WeChatPayNotice, JsonConvert.SerializeObject(notify));
|
NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调", JsonConvert.SerializeObject(notify));
|
return WeChatPayNotifyResult.Success;
|
}
|
else
|
{
|
NLogUtil.WriteAll(LogLevel.Error, LogType.Order, "微信支付成功回调", JsonConvert.SerializeObject(notify));
|
}
|
return NoContent();
|
}
|
catch (Exception ex)
|
{
|
NLogUtil.WriteAll(LogLevel.Error, LogType.Order, "微信支付成功回调异常", "统一下单支付结果通知", ex);
|
return NoContent();
|
}
|
}
|
|
/// <summary>
|
/// 退款结果通知
|
/// </summary>
|
[HttpPost]
|
public async Task<IActionResult> Refund()
|
{
|
try
|
{
|
var config = await _weChatPayConfigServices.QueryByClauseAsync(p => p.isDefault == true && p.isEnable == true);
|
//构建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 notify = await _client.ExecuteAsync<WeChatPayRefundNotify>(Request, payOptions);
|
NLogUtil.WriteAll(LogLevel.Trace, LogType.Refund, "微信退款结果通知", JsonConvert.SerializeObject(notify));
|
|
if (notify.ReturnCode != WeChatPayCode.Success) return NoContent();
|
{
|
var memo = JsonConvert.SerializeObject(notify);
|
|
var status = notify.RefundStatus == WeChatPayCode.Success
|
? (int)GlobalEnumVars.BillRefundStatus.STATUS_REFUND
|
: (int)GlobalEnumVars.BillRefundStatus.STATUS_FAIL;
|
|
await _billRefundServices.UpdateAsync(p => new CoreCmsBillRefund { memo = memo, updateTime = DateTime.Now, status = status }, p => p.refundId == notify.OutTradeNo);
|
|
//这个返回只是告诉回调这个业务我们接收到了。
|
return WeChatPayNotifyResult.Success;
|
}
|
|
}
|
catch (Exception ex)
|
{
|
NLogUtil.WriteAll(LogLevel.Trace, LogType.Refund, "微信退款结果通知", "退款结果通知", ex);
|
|
return NoContent();
|
}
|
}
|
}
|
}
|
