生活缴费api
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
sunpengfei
2025-06-11 714eca49223a7eabdfc6666eb745c631d27046dc 
 LifePayment/LifePayment.HttpApi/LifePay/WxPayNotifyController.cs


@@ -1,6 +1,7 @@


using 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,9 @@


                {


                    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)))


                        {