From ac61e142795d9572798f33f384481a47ba5b6457 Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期四, 04 十二月 2025 09:20:55 +0800
Subject: [PATCH] feat:开发
---
LifePayment/LifePayment.Application/LifePay/LifePayService.cs | 149 ++++++++++++++++++++++++++-----------------------
1 files changed, 79 insertions(+), 70 deletions(-)
diff --git a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
index 258cc91..dfa50f8 100644
--- a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
+++ b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
@@ -1533,82 +1533,91 @@
{
await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{orderNo}", TimeSpan.FromSeconds(60));
_logger.LogInformation($"閿侊細LockKey:UpdateOrder:{orderNo} - {orderLock != null}");
-
- var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();
-
- CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "璁㈠崟涓嶅瓨鍦�");
-
- if (order.ACOOLYStatus.HasValue && (int)order.ACOOLYStatus > (int)acoolyStatus)
+ try
{
- _logger.LogInformation($"璁㈠崟锛坽orderNo}锛夌敱{order.ACOOLYStatus}鑷硔acoolyStatus}澶辫触锛屼笉鍙洖婊氱姸鎬�");
- return;
- }
+ var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();
- if (order.LifePayOrderStatus == status && order.ACOOLYStatus == acoolyStatus)
- {
- _logger.LogInformation($"璁㈠崟锛坽orderNo}锛夊凡澶勭悊璇ョ姸鎬�");
- return;
- }
+ CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "璁㈠崟涓嶅瓨鍦�");
- order.ActualReceivedAmount = actualParValue;
- order.PlatformDeductionAmount = Math.Round((order.ActualReceivedAmount ?? 0) * (order.PlatformRate ?? 0) / 100, 2);
-
- if (acoolyOrderNo.IsNotNullOrEmpty())
- {
- order.ACOOLYOrderNo = acoolyOrderNo;
- }
-
- if (status == LifePayOrderStatusEnum.寰呴��娆�)
- {
- order.LifePayRefundStatus = LifePayRefundStatusEnum.寰呴��娆�;
- }
-
- if (refundApplyRemark.IsNotNullOrEmpty())
- {
- order.RefundApplyRemark = refundApplyRemark;
- }
-
- order.LifePayOrderStatus = status;
- order.ACOOLYStatus = acoolyStatus;
-
- if (order.LifePayOrderStatus == LifePayOrderStatusEnum.宸插畬鎴�
- || order.LifePayOrderStatus == LifePayOrderStatusEnum.宸查��娆�)
- {
- order.FinishTime = DateTime.Now;
- }
-
- if (order.ACOOLYStatus == ACOOLYStatusEnum.宸查��娆� || order.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�)
- {
- order.RefundPrice = Math.Round((1 - ((order.ActualReceivedAmount ?? 0) / (order.RechargeAmount ?? 0))) * (order.PayAmount ?? 0), 2);
- }
-
- if (order.LifePayOrderStatus == LifePayOrderStatusEnum.宸插畬鎴�)
- {
- ///缁撶畻娓犻亾浣ｉ噾
- /// 姣涘埄
- var grossProfit = order.RechargeAmount * (order.ChannleRate - order.PlatformRate) / 100;
- /// 娓犻亾浣ｉ噾 锛�(鍏呭�奸潰棰� * 娓犻亾鎶樻墸姣斾緥)-(鍏呭�奸潰棰� * 骞冲彴鎶樻墸姣斾緥)锛�* 浣ｉ噾姣斾緥
- var channlesRakePrice = grossProfit * (order.ChannlesRakeRate) / 100;
- if (channlesRakePrice.HasValue)
+ if (order.ACOOLYStatus.HasValue && (int)order.ACOOLYStatus > (int)acoolyStatus)
{
- LifePayChannlesRake lifePayChannlesRake = new LifePayChannlesRake()
- {
- OrderNo = order.OrderNo,
- PayAmount = order.RechargeAmount ?? 0,
- ChannlesRakeRate = order.ChannlesRakeRate ?? 0,
- ChannlesRakePrice = channlesRakePrice ?? 0,
- FinishTime = order.FinishTime.Value,
- ChannelId = order.ChannelId,
- };
- await _lifePayChannlesRakeRepository.InsertAsync(lifePayChannlesRake);
+ _logger.LogInformation($"璁㈠崟锛坽orderNo}锛夌敱{order.ACOOLYStatus}鑷硔acoolyStatus}澶辫触锛屼笉鍙洖婊氱姸鎬�");
+ return;
}
+
+ if (order.LifePayOrderStatus == status && order.ACOOLYStatus == acoolyStatus)
+ {
+ _logger.LogInformation($"璁㈠崟锛坽orderNo}锛夊凡澶勭悊璇ョ姸鎬�");
+ return;
+ }
+
+ order.ActualReceivedAmount = actualParValue;
+ order.PlatformDeductionAmount = Math.Round((order.ActualReceivedAmount ?? 0) * (order.PlatformRate ?? 0) / 100, 2);
+
+ if (acoolyOrderNo.IsNotNullOrEmpty())
+ {
+ order.ACOOLYOrderNo = acoolyOrderNo;
+ }
+
+ if (status == LifePayOrderStatusEnum.寰呴��娆�)
+ {
+ order.LifePayRefundStatus = LifePayRefundStatusEnum.寰呴��娆�;
+ }
+
+ if (refundApplyRemark.IsNotNullOrEmpty())
+ {
+ order.RefundApplyRemark = refundApplyRemark;
+ }
+
+ order.LifePayOrderStatus = status;
+ order.ACOOLYStatus = acoolyStatus;
+
+ if (order.LifePayOrderStatus == LifePayOrderStatusEnum.宸插畬鎴�
+ || order.LifePayOrderStatus == LifePayOrderStatusEnum.宸查��娆�)
+ {
+ order.FinishTime = DateTime.Now;
+ }
+
+ if (order.ACOOLYStatus == ACOOLYStatusEnum.宸查��娆� || order.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�)
+ {
+ order.RefundPrice = Math.Round((1 - ((order.ActualReceivedAmount ?? 0) / (order.RechargeAmount ?? 0))) * (order.PayAmount ?? 0), 2);
+ }
+
+ if (order.LifePayOrderStatus == LifePayOrderStatusEnum.宸插畬鎴�)
+ {
+ ///缁撶畻娓犻亾浣ｉ噾
+ /// 姣涘埄
+ var grossProfit = order.RechargeAmount * (order.ChannleRate - order.PlatformRate) / 100;
+ /// 娓犻亾浣ｉ噾 锛�(鍏呭�奸潰棰� * 娓犻亾鎶樻墸姣斾緥)-(鍏呭�奸潰棰� * 骞冲彴鎶樻墸姣斾緥)锛�* 浣ｉ噾姣斾緥
+ var channlesRakePrice = grossProfit * (order.ChannlesRakeRate) / 100;
+ if (channlesRakePrice.HasValue)
+ {
+ LifePayChannlesRake lifePayChannlesRake = new LifePayChannlesRake()
+ {
+ OrderNo = order.OrderNo,
+ PayAmount = order.RechargeAmount ?? 0,
+ ChannlesRakeRate = order.ChannlesRakeRate ?? 0,
+ ChannlesRakePrice = channlesRakePrice ?? 0,
+ FinishTime = order.FinishTime.Value,
+ ChannelId = order.ChannelId,
+ };
+ await _lifePayChannlesRakeRepository.InsertAsync(lifePayChannlesRake);
+ }
+ }
+
+ /// 鍒涘缓鐢熸椿缂磋垂娑堣垂璁板綍
+ await _lifePayOrderService.CreatLifePayConsumption(acoolyStatus, order.OrderNo, order.ACOOLYOrderNo,
+ order.PlatformDeductionAmount ?? 0, order.ChannelId, order.CreationTime, order.FinishTime, order.ChannleRate, parValue, actualParValue);
+
+ await CurrentUnitOfWork.SaveChangesAsync();
+
+ _logger.LogInformation("浜嬪姟瀹屾垚");
}
-
- /// 鍒涘缓鐢熸椿缂磋垂娑堣垂璁板綍
- await _lifePayOrderService.CreatLifePayConsumption(acoolyStatus, order.OrderNo, order.ACOOLYOrderNo,
- order.PlatformDeductionAmount ?? 0, order.ChannelId, order.CreationTime, order.FinishTime, order.ChannleRate, parValue, actualParValue);
-
- await CurrentUnitOfWork.SaveChangesAsync();
+ catch (Exception ex)
+ {
+ await CurrentUnitOfWork.RollbackAsync();
+ _logger.LogError($"渚涘簲鍟嗗洖璋冨紓甯革細{ex.Message}", ex);
+ }
}
/// <summary>
--
Gitblit v1.9.1