From 1605af1ced748313e99f38e5eb6888768fbc7d54 Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期三, 11 六月 2025 14:46:43 +0800
Subject: [PATCH] fix:支付回调和供应商回调的并发问题

---
 LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs |    9 ++++++++-
 1 files changed, 8 insertions(+), 1 deletions(-)

diff --git a/LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs b/LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs
index de9e04b..3ff1a0d 100644
--- a/LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs
+++ b/LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs
@@ -1,6 +1,7 @@
 锘縰sing LifePayment.Application.Contracts;
 using LifePayment.Domain;
 using LifePayment.Domain.Shared;
+using Medallion.Threading;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Caching.Distributed;
 using Microsoft.Extensions.Logging;
@@ -10,6 +11,7 @@
 using System.Threading.Tasks;
 using Volo.Abp.AspNetCore.Mvc;
 using Volo.Abp.Caching;
+using Volo.Abp.DistributedLocking;
 using Volo.Abp.Uow;
 using ZeroD.Util;
 
@@ -26,6 +28,7 @@
         private readonly ILifePayService _lifePayService;
         private readonly ILifePayOrderService _lifePayOrderService;
         private readonly IDistributedCache<string> distributedCache;
+        private readonly IAbpDistributedLock distributedLock;
         private readonly ILogger<WxPayNotifyController> _logger;
 
         public WxPayNotifyController(
@@ -33,13 +36,15 @@
                ILogger<WxPayNotifyController> logger,
                ILifePayService lifePayService,
                ILifePayOrderService lifePayOrderService,
-               IDistributedCache<string> distributedCache)
+               IDistributedCache<string> distributedCache,
+               IAbpDistributedLock distributedLock)
         {
             _wxPayApi = wxPayApi;
             _logger = logger;
             _lifePayService = lifePayService;
             _lifePayOrderService = lifePayOrderService;
             this.distributedCache = distributedCache;
+            this.distributedLock = distributedLock;
         }
 
         /// <summary>
@@ -63,6 +68,8 @@
                 {
                     if (wxPayNotice.TradeState == LifePaymentConstant.WxPayStatus.鏀粯鎴愬姛)
                     {
+                        await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{wxPayNotice.OutTradeNo}", TimeSpan.FromSeconds(60));
+
                         var key = $"WxRechargeNotify_{wxPayNotice.OutTradeNo}";
                         if (string.IsNullOrWhiteSpace(distributedCache.Get(key)))
                         {

--
Gitblit v1.9.1