pref:优化事务

sunpengfei

2025-06-13 67fc39c356d8b480b7005cb2fa4769a0a6c6cfb1

 LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs

@@ -53,7 +53,7 @@
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        [UnitOfWork]
        [UnitOfWork(false)]
        public async Task<WxRechargeNotifyResult> WxRechargeNotify(WxRechargeNotifyInput input)
        {
            try
@@ -64,12 +64,13 @@
                _logger.LogInformation($"生活管家微信充值回调通知data：" + data);
                var wxPayNotice = JsonConvert.DeserializeObject<WxPayNotice>(data);

                await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{wxPayNotice.OutTradeNo}", TimeSpan.FromSeconds(60));
                _logger.LogInformation($"锁：LockKey:UpdateOrder:{wxPayNotice.OutTradeNo} - {orderLock != null}");

                if (wxPayNotice.OutTradeNo.Contains("JF"))
                {
                    if (wxPayNotice.TradeState == LifePaymentConstant.WxPayStatus.支付成功)
                    {
                        await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{wxPayNotice.OutTradeNo}", TimeSpan.FromSeconds(60));
                        _logger.LogInformation($"锁：LockKey:UpdateOrder:{wxPayNotice.OutTradeNo} - {orderLock != null}");

                        var key = $"WxRechargeNotify_{wxPayNotice.OutTradeNo}";
                        if (string.IsNullOrWhiteSpace(distributedCache.Get(key)))
@@ -93,6 +94,9 @@
                            {
                                AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(10)
                            });

                            await CurrentUnitOfWork.CompleteAsync();
                            _logger.LogInformation("事务完成");
                        }
                        else
                        {
@@ -112,6 +116,7 @@
            catch (Exception ex)
            {
                await CurrentUnitOfWork.RollbackAsync();
                _logger.LogError($"微信支付回调异常：{ex.Message}", ex);
                return new WxRechargeNotifyResult
                {
                    Code = "FAIL",