File size: 3,938 Bytes
8edbc20 |
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 98 99 100 101 102 103 104 105 106 |
using Backend_Teamwork.src.Database;
using Backend_Teamwork.src.Entities;
using Backend_Teamwork.src.Utils;
using Microsoft.EntityFrameworkCore;
namespace Backend_Teamwork.src.Repository
{
public class OrderRepository
{
private readonly DbSet<Order> _order;
private readonly DatabaseContext _databaseContext;
public OrderRepository(DatabaseContext databaseContext)
{
_databaseContext = databaseContext;
_order = databaseContext.Set<Order>();
}
public async Task<List<Order>> GetAllAsync()
{
// Include User, OrderDetails, Artwork, and Category
return await _order
.Include(o => o.User) // Include User details
.Include(o => o.OrderDetails)
.ThenInclude(od => od.Artwork) // Include Artwork
.ThenInclude(a => a.Category) // Include Category if it's a related entity
.ToListAsync();
}
public async Task<List<Order>> GetOrdersByUserIdAsync(Guid userId)
{
return await _databaseContext
.Order.Include(o => o.User) // Include User
.Include(o => o.OrderDetails)
.ThenInclude(od => od.Artwork) // Include Artwork
.ThenInclude(a => a.Category) // Include Category in Artwork
.Where(order => order.UserId == userId)
.ToListAsync();
}
public async Task<Order?> CreateOneAsync(Order newOrder)
{
await _order.AddAsync(newOrder);
await _databaseContext.SaveChangesAsync();
return await GetByIdAsync(newOrder.Id);
}
public async Task<Order?> GetByIdAsync(Guid id)
{
return await _order
.Include(o => o.User) // Include User
.Include(o => o.OrderDetails)
.ThenInclude(od => od.Artwork) // Include Artwork
.ThenInclude(a => a.Category) // Include Category in Artwork
.FirstOrDefaultAsync(o => o.Id == id);
}
public async Task<bool> DeleteOneAsync(Order Order)
{
if (Order == null)
return false;
_order.Remove(Order);
await _databaseContext.SaveChangesAsync();
return true;
}
public async Task<bool> UpdateOneAsync(Order updateOrder)
{
if (updateOrder == null)
return false;
_order.Update(updateOrder);
await _databaseContext.SaveChangesAsync();
return true;
}
public async Task<List<Order>> GetAllAsync(PaginationOptions paginationOptions)
{
// Query for orders with optional search
var orderQuery = _order
.Include(o => o.OrderDetails) // Include order details
.Include(o => o.User)
.Where(o =>
o.ShippingAddress.Contains(paginationOptions.Search)
|| o.TotalAmount.ToString().Contains(paginationOptions.Search)
);
// Apply pagination
orderQuery = orderQuery
.Skip((paginationOptions.PageNumber - 1) * paginationOptions.PageSize)
.Take(paginationOptions.PageSize);
// Sorting logic
orderQuery = paginationOptions.SortOrder switch
{
"amount_desc" => orderQuery.OrderByDescending(o => o.TotalAmount),
"amount_asc" => orderQuery.OrderBy(o => o.TotalAmount),
"date_desc" => orderQuery.OrderByDescending(o => o.CreatedAt),
"date_asc" => orderQuery.OrderBy(o => o.CreatedAt),
_ => orderQuery.OrderBy(o => o.ShippingAddress), // Default sorting by ShippingAddress
};
return await orderQuery.ToListAsync();
}
}
}
|