Spaces:
Sleeping
Sleeping
File size: 3,398 Bytes
87c9973 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 | using Database.Models;
using Microsoft.EntityFrameworkCore;
namespace LibraryManagement.Backend.Features.Subscriptions
{
public interface ISubscriptionService
{
Task<IEnumerable<MembershipDto>> GetMembershipsAsync();
Task<SubscriptionDto?> GetUserSubscriptionAsync(int userId);
Task<SubscriptionDto> SubscribeUserAsync(int userId, int membershipId);
}
public class SubscriptionService : ISubscriptionService
{
private readonly LibraryManagementContext _context;
public SubscriptionService(LibraryManagementContext context)
{
_context = context;
}
public async Task<IEnumerable<MembershipDto>> GetMembershipsAsync()
{
return await _context.Memberships
.Select(m => new MembershipDto
{
Id = m.Id,
Type = m.Type,
MaxBooks = m.MaxBooks,
BorrowingDays = m.BorrowingDays,
Price = m.Price,
DurationMonths = m.DurationMonths
}).ToListAsync();
}
public async Task<SubscriptionDto?> GetUserSubscriptionAsync(int userId)
{
var subscription = await _context.UserSubscriptions
.Include(s => s.Membership)
.Where(s => s.UserId == userId && s.IsActive)
.OrderByDescending(s => s.StartDate)
.FirstOrDefaultAsync();
if (subscription == null) return null;
return MapToDto(subscription);
}
public async Task<SubscriptionDto> SubscribeUserAsync(int userId, int membershipId)
{
var membership = await _context.Memberships.FindAsync(membershipId);
if (membership == null) throw new Exception("Membership plan not found.");
// Deactivate any existing active subscriptions for this user
var activeSubscriptions = await _context.UserSubscriptions
.Where(s => s.UserId == userId && s.IsActive)
.ToListAsync();
foreach (var s in activeSubscriptions)
{
s.IsActive = false;
}
var subscription = new UserSubscription
{
UserId = userId,
MembershipId = membershipId,
StartDate = DateTime.UtcNow,
ExpiryDate = DateTime.UtcNow.AddMonths(membership.DurationMonths),
IsActive = true
};
_context.UserSubscriptions.Add(subscription);
await _context.SaveChangesAsync();
// Explicitly load the membership data for the DTO mapping
await _context.Entry(subscription).Reference(s => s.Membership).LoadAsync();
return MapToDto(subscription);
}
private static SubscriptionDto MapToDto(UserSubscription subscription)
{
return new SubscriptionDto
{
Id = subscription.Id,
UserId = subscription.UserId,
MembershipId = subscription.MembershipId,
MembershipType = subscription.Membership.Type,
StartDate = subscription.StartDate,
ExpiryDate = subscription.ExpiryDate,
IsActive = subscription.IsActive
};
}
}
}
|