Merge branch 'dev' of https://gitea.nxsir.cn/nanxun/ql_apimanager_backend into dev

Apimanager_backend/Services/IPayService.cs

@@ -6,5 +6,6 @@ namespace Apimanager_backend.Services
     public interface IPayService
     {
         Task<PayReturnData> CreateEpay(Order order,PaymentConfig paymentConfig,string returnUrl);
+        Task<bool> BuyAsync(BuyDto dto);
     }
 }

Apimanager_backend/Services/OrderService.cs

@@ -79,6 +79,7 @@ namespace Apimanager_backend.Services
         #region 更新订单状态
         public async Task<bool> UpdateOrderAsync(OrderDto order)
         {
+            var transaction = await _apiContext.Database.BeginTransactionAsync();
             try
             {
                 var data = await _apiContext.Orders.SingleOrDefaultAsync(x => x.OrderNumber == order.OrderNumber || x.ThirdPartyOrderId == order.ThirdPartyOrderId);
@@ -89,13 +90,22 @@ namespace Apimanager_backend.Services
                 data.UpdatedAt = DateTime.Now;
                 data.Status = order.Status;
                 data.PaiAt = order.Status == OrderStatus.Completed ? DateTime.Now : null;
+                var user = await _apiContext.Users.FirstOrDefaultAsync(x => x.Id == order.UserId);
+                if (user == null)
+                {
+                    throw new BaseException(2004, "用户未找到");
+                }
+                user.Balance += order.Amount;
                 _apiContext.Orders.Update(data);
+                _apiContext.Users.Update(user);
                 await _apiContext.SaveChangesAsync();
+                await transaction.CommitAsync();
                 return true;
             }catch(Exception e)
             {
+                await transaction.RollbackAsync();
                 logger.LogError(e.Message);
-                throw new BaseException(4003, "订单未找到"); 
+                throw;
             }
         }
         #endregion

Apimanager_backend/Services/PayService.cs

@@ -13,12 +13,61 @@ namespace Apimanager_backend.Services
         private IMapper _mapper;
         private ILogger<PayService> _logger;
         private ApiContext _context;
-        public PayService(IMapper mapper,ILogger<PayService> logger,ApiContext apiContext)
+        public PayService(IMapper mapper,ILogger<PayService> logger,
+            ApiContext apiContext)
         {
             _mapper = mapper;
             _logger = logger;
             _context = apiContext;
         }
+
+        public async Task<bool> BuyAsync(BuyDto dto)
+        {
+            var transaction = await _context.Database.BeginTransactionAsync();
+            try
+            {
+                var package = await _context.Apipackages.FirstOrDefaultAsync(x => x.Id == dto.ApiPackageId);
+                if (package == null) throw new BaseException(4004,"套餐未找到");
+                var user = await _context.Users.FirstOrDefaultAsync(x => x.Id == dto.UserId);
+                if (user == null) throw new BaseException(2004,"用户不存在");
+                if (user.Balance < package.Price)
+                {
+                    throw new BaseException(4002, "支付失败，余额不足。");
+                }
+                var uPackage = await _context.UserPackages.FirstOrDefaultAsync(x => x.UserId == dto.UserId && x.PackageId == dto.ApiPackageId);
+                if (uPackage == null)
+                {
+                    UserPackage userPackage = new UserPackage();
+                    userPackage.UserId = dto.UserId;
+                    userPackage.PackageId = dto.ApiPackageId;
+                    userPackage.RemainingCalls = package.CallLimit;
+                    userPackage.ExpiryDate = DateTime.Now.AddMonths(1);
+                    await _context.UserPackages.AddAsync(userPackage);
+                }
+                else
+                {
+                    var baseDate = uPackage.ExpiryDate > DateTime.Now ? uPackage.ExpiryDate : DateTime.Now;
+                    _context.UserPackages.Update(uPackage);
+                }
+                user.Balance -= package.Price;
+                _context.Users.Update(user);
+                await _context.SaveChangesAsync();
+                await transaction.CommitAsync();
+                return true;
+            }catch(Exception e) when(!(e is BaseException))
+            {
+                await transaction.RollbackAsync();
+                _logger.LogError(e,"购买套餐失败：{Message}",e.Message);
+                throw new BaseException(1005,"服务器内部错误");
+            }
+            catch (BaseException)
+            {
+                await transaction.RollbackAsync();
+                throw;
+            }
+
+        }
+
         public async Task<PayReturnData> CreateEpay(Order order, PaymentConfig paymentConfig,string returnUrl)
         {
             try