70 lines
2.3 KiB
C#
70 lines
2.3 KiB
C#
using Microsoft.EntityFrameworkCore;
|
|
using SPMS.Domain.Entities;
|
|
using SPMS.Domain.Enums;
|
|
using SPMS.Domain.Interfaces;
|
|
|
|
namespace SPMS.Infrastructure.Persistence.Repositories;
|
|
|
|
public class DeviceRepository : Repository<Device>, IDeviceRepository
|
|
{
|
|
public DeviceRepository(AppDbContext context) : base(context) { }
|
|
|
|
public async Task<Device?> GetByServiceAndTokenAsync(long serviceId, string deviceToken)
|
|
{
|
|
return await _dbSet.FirstOrDefaultAsync(d => d.ServiceId == serviceId && d.DeviceToken == deviceToken);
|
|
}
|
|
|
|
public async Task<Device?> GetByIdAndServiceAsync(long id, long serviceId)
|
|
{
|
|
return await _dbSet.FirstOrDefaultAsync(d => d.Id == id && d.ServiceId == serviceId);
|
|
}
|
|
|
|
public async Task<int> GetActiveCountByServiceAsync(long serviceId)
|
|
{
|
|
return await _dbSet.CountAsync(d => d.ServiceId == serviceId && d.IsActive);
|
|
}
|
|
|
|
public async Task<IReadOnlyList<Device>> GetByPlatformAsync(long serviceId, Platform platform)
|
|
{
|
|
return await _dbSet
|
|
.Where(d => d.ServiceId == serviceId && d.Platform == platform && d.IsActive)
|
|
.ToListAsync();
|
|
}
|
|
|
|
public async Task<(IReadOnlyList<Device> Items, int TotalCount)> GetPagedAsync(
|
|
long serviceId, int page, int size,
|
|
Platform? platform = null, bool? pushAgreed = null,
|
|
bool? isActive = null, List<int>? tags = null)
|
|
{
|
|
var query = _dbSet.Where(d => d.ServiceId == serviceId);
|
|
|
|
if (platform.HasValue)
|
|
query = query.Where(d => d.Platform == platform.Value);
|
|
|
|
if (pushAgreed.HasValue)
|
|
query = query.Where(d => d.PushAgreed == pushAgreed.Value);
|
|
|
|
if (isActive.HasValue)
|
|
query = query.Where(d => d.IsActive == isActive.Value);
|
|
|
|
if (tags != null && tags.Count > 0)
|
|
{
|
|
foreach (var tag in tags)
|
|
{
|
|
var tagStr = tag.ToString();
|
|
query = query.Where(d => d.Tags != null && EF.Functions.Like(d.Tags, $"%{tagStr}%"));
|
|
}
|
|
}
|
|
|
|
var totalCount = await query.CountAsync();
|
|
|
|
var items = await query
|
|
.OrderByDescending(d => d.CreatedAt)
|
|
.Skip((page - 1) * size)
|
|
.Take(size)
|
|
.ToListAsync();
|
|
|
|
return (items, totalCount);
|
|
}
|
|
}
|