server/Coreshop
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

321

Browse Source
This commit is contained in:
zpc 2025-09-26 16:32:58 +08:00
parent 59279cacc3
commit c6042b8922
2 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CoreCms.Net.Core/Config/RedisMessageQueueSetup.cs
View File

@ -39,9 +39,9 @@ namespace CoreCms.Net.Core.Config
typeof(LogingSubscribe), typeof(LogingSubscribe),
typeof(UserSubscribe), typeof(UserSubscribe),
#if DEBUG
typeof(WeChatPayNoticeSubscribe), typeof(WeChatPayNoticeSubscribe),
#endif
typeof(SendWxTemplateMessageSubscribe), typeof(SendWxTemplateMessageSubscribe),
typeof(AfterSalesReviewSubscribe), typeof(AfterSalesReviewSubscribe),

20
CoreCms.Net.Web.WebApi/Controllers/PayNotify/WeChatPayController.cs
View File

@ -63,29 +63,25 @@ namespace CoreCms.Net.Web.WebApi.Controllers.PayNotify
try try
{ {
// 先读取原始请求 Body // 先读取原始请求 Body
Request.EnableBuffering(); // 允许多次读取流 //Request.EnableBuffering(); // 允许多次读取流
string body = ""; //string body = "";
using (var reader = new StreamReader(Request.Body, Encoding.UTF8, leaveOpen: true)) //using (var reader = new StreamReader(Request.Body, Encoding.UTF8, leaveOpen: true))
{ //{
body = await reader.ReadToEndAsync(); // body = await reader.ReadToEndAsync();
Request.Body.Position = 0; // 重置流指针，保证后续能再次读取 // Request.Body.Position = 0; // 重置流指针，保证后续能再次读取
} //}
// 打印原始请求内容（方便定位问题） // 打印原始请求内容（方便定位问题）
NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调原始请求", body); // NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调原始请求", body);
NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调解析结果_optionsAccessor", JsonConvert.SerializeObject(_optionsAccessor.Value));
var notify = await _client.ExecuteAsync<WeChatPayUnifiedOrderNotify>(Request, _optionsAccessor.Value); var notify = await _client.ExecuteAsync<WeChatPayUnifiedOrderNotify>(Request, _optionsAccessor.Value);
// 打印解析后的对象 // 打印解析后的对象
NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调解析结果", JsonConvert.SerializeObject(notify)); NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调解析结果", JsonConvert.SerializeObject(notify));
if (notify.ReturnCode == WeChatPayCode.Success) if (notify.ReturnCode == WeChatPayCode.Success)
{ {
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.WeChatPayNotice, JsonConvert.SerializeObject(notify)); await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.WeChatPayNotice, JsonConvert.SerializeObject(notify));
return WeChatPayNotifyResult.Success; return WeChatPayNotifyResult.Success;
} }
NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调", JsonConvert.SerializeObject(notify)); NLogUtil.WriteAll(LogLevel.Trace, LogType.Order, "微信支付成功回调", JsonConvert.SerializeObject(notify));
//Request.Body
return NoContent(); return NoContent();
} }