生活缴费api
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
sunpengfei
2025-06-12 8cffc2cde22edfa1378f5d0e7b9780aa31c6e8ba 
 LifePayment/LifePayment.HttpApi/LifePay/AliPayNotifyController.cs


@@ -2,6 +2,7 @@


using Castle.Core.Internal;


using LifePayment.Application.Contracts;


using LifePayment.Domain.Shared;


using Medallion.Threading;


using Microsoft.AspNetCore.Authorization;


using Microsoft.AspNetCore.Mvc;


using Microsoft.Extensions.Logging;


@@ -11,6 +12,7 @@


using System.Text.RegularExpressions;


using System.Threading.Tasks;


using Volo.Abp.AspNetCore.Mvc;


using Volo.Abp.DistributedLocking;


using Volo.Abp.Uow;


using ZeroD.Util;




@@ -27,15 +29,17 @@


        private readonly ILifePayOrderService _lifePayOrderService;




        private readonly ILogger<AliPayNotifyController> _logger;


        private readonly IAbpDistributedLock distributedLock;




        public AliPayNotifyController(




               ILogger<AliPayNotifyController> logger,




               IAbpDistributedLock distributedLock,


               ILifePayService lifePayService,


               ILifePayOrderService lifePayOrderService)


        {


            _logger = logger;


            this.distributedLock = distributedLock;


            _lifePayService = lifePayService;


            _lifePayOrderService = lifePayOrderService;


        }


@@ -61,6 +65,9 @@


            {


                if (input.TradeStatus == LifePaymentConstant.AliPayStatus.支付成功 && input.OutBizNo.IsNullOrEmpty())


                {


                    await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{input.OutTradeNo}", TimeSpan.FromSeconds(60));


                    _logger.LogInformation($"锁：LockKey:UpdateOrder:{input.OutTradeNo} - {orderLock != null}");




                    await _lifePayService.LifePaySuccessHandler(input.OutTradeNo, input.TradeNo);


                    // 插入收支流水


                    await _lifePayOrderService.AddLifePayExpensesReceipts(new AddLifePayExpensesReceiptsInput()


@@ -75,6 +82,9 @@


                    && input.OutBizNo.IsNotNullOrEmpty()


                    && (input.RefundFee.HasValue && input.RefundFee > 0)))


                {


                    await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{input.OutTradeNo}", TimeSpan.FromSeconds(60));


                    _logger.LogInformation($"锁：LockKey:UpdateOrder:{input.OutTradeNo} - {orderLock != null}");




                    await _lifePayService.LifePayRefundsHandler(input.OutTradeNo, LifePayRefundStatusEnum.已退款);


                    // 插入收支流水


                    await _lifePayOrderService.AddLifePayExpensesReceipts(new AddLifePayExpensesReceiptsInput()