Merge branch 'Feature/program-manager/chat'
# Conflicts: # .gitignore # ServiceHost/appsettings.Development.json # ServiceHost/appsettings.json
This commit is contained in:
@@ -0,0 +1,134 @@
|
||||
using GozareshgirProgramManager.Domain.FileManagementAgg.Entities;
|
||||
using GozareshgirProgramManager.Domain.FileManagementAgg.Enums;
|
||||
using GozareshgirProgramManager.Domain.FileManagementAgg.Repositories;
|
||||
using GozareshgirProgramManager.Infrastructure.Persistence.Context;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
|
||||
namespace GozareshgirProgramManager.Infrastructure.Persistence.Repositories.FileManagement;
|
||||
|
||||
public class UploadedFileRepository : IUploadedFileRepository
|
||||
{
|
||||
private readonly ProgramManagerDbContext _context;
|
||||
|
||||
public UploadedFileRepository(ProgramManagerDbContext context)
|
||||
{
|
||||
_context = context;
|
||||
}
|
||||
|
||||
public async Task<UploadedFile?> GetByIdAsync(Guid fileId)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.FirstOrDefaultAsync(x => x.Id == fileId);
|
||||
}
|
||||
|
||||
public async Task<UploadedFile?> GetByUniqueFileNameAsync(string uniqueFileName)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.FirstOrDefaultAsync(x => x.UniqueFileName == uniqueFileName);
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> GetUserFilesAsync(long userId, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.UploadedByUserId == userId)
|
||||
.OrderByDescending(x => x.UploadDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> GetByCategoryAsync(FileCategory category, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.Category == category)
|
||||
.OrderByDescending(x => x.UploadDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> GetByStatusAsync(FileStatus status, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.Status == status)
|
||||
.OrderByDescending(x => x.UploadDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> GetByReferenceAsync(string entityType, string entityId)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.ReferenceEntityType == entityType && x.ReferenceEntityId == entityId)
|
||||
.OrderByDescending(x => x.UploadDate)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> SearchByNameAsync(string searchTerm, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.OriginalFileName.Contains(searchTerm))
|
||||
.OrderByDescending(x => x.UploadDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<int> GetUserFilesCountAsync(long userId)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.CountAsync(x => x.UploadedByUserId == userId);
|
||||
}
|
||||
|
||||
public async Task<long> GetUserTotalFileSizeAsync(long userId)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.Where(x => x.UploadedByUserId == userId)
|
||||
.SumAsync(x => x.FileSizeBytes);
|
||||
}
|
||||
|
||||
public async Task<List<UploadedFile>> GetExpiredFilesAsync(DateTime olderThan)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.IgnoreQueryFilters() // Include deleted files
|
||||
.Where(x => x.IsDeleted && x.DeletedDate < olderThan)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<UploadedFile> AddAsync(UploadedFile file)
|
||||
{
|
||||
await _context.UploadedFiles.AddAsync(file);
|
||||
return file;
|
||||
}
|
||||
|
||||
public Task UpdateAsync(UploadedFile file)
|
||||
{
|
||||
_context.UploadedFiles.Update(file);
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task DeleteAsync(UploadedFile file)
|
||||
{
|
||||
_context.UploadedFiles.Remove(file);
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public async Task<int> SaveChangesAsync()
|
||||
{
|
||||
return await _context.SaveChangesAsync();
|
||||
}
|
||||
|
||||
public async Task<bool> ExistsAsync(Guid fileId)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.AnyAsync(x => x.Id == fileId);
|
||||
}
|
||||
|
||||
public async Task<bool> ExistsByUniqueFileNameAsync(string uniqueFileName)
|
||||
{
|
||||
return await _context.UploadedFiles
|
||||
.AnyAsync(x => x.UniqueFileName == uniqueFileName);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,122 @@
|
||||
using GozareshgirProgramManager.Domain.TaskChatAgg.Entities;
|
||||
using GozareshgirProgramManager.Domain.TaskChatAgg.Repositories;
|
||||
using GozareshgirProgramManager.Infrastructure.Persistence.Context;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
|
||||
namespace GozareshgirProgramManager.Infrastructure.Persistence.Repositories.TaskChat;
|
||||
|
||||
public class TaskChatMessageRepository : ITaskChatMessageRepository
|
||||
{
|
||||
private readonly ProgramManagerDbContext _context;
|
||||
|
||||
public TaskChatMessageRepository(ProgramManagerDbContext context)
|
||||
{
|
||||
_context = context;
|
||||
}
|
||||
|
||||
public async Task<TaskChatMessage?> GetByIdAsync(Guid messageId)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.FirstOrDefaultAsync(x => x.Id == messageId);
|
||||
}
|
||||
|
||||
public async Task<List<TaskChatMessage>> GetTaskMessagesAsync(Guid taskId, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId)
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.OrderBy(x => x.CreationDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<int> GetTaskMessageCountAsync(Guid taskId)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.CountAsync(x => x.TaskId == taskId);
|
||||
}
|
||||
|
||||
public async Task<List<TaskChatMessage>> GetPinnedMessagesAsync(Guid taskId)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId && x.IsPinned)
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.OrderByDescending(x => x.PinnedDate)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<TaskChatMessage?> GetLastMessageAsync(Guid taskId)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId)
|
||||
.OrderByDescending(x => x.CreationDate)
|
||||
.FirstOrDefaultAsync();
|
||||
}
|
||||
|
||||
public async Task<List<TaskChatMessage>> SearchMessagesAsync(Guid taskId, string searchText, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId &&
|
||||
x.TextContent != null &&
|
||||
x.TextContent.Contains(searchText))
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.OrderByDescending(x => x.CreationDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<TaskChatMessage>> GetUserMessagesAsync(Guid taskId, long userId, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId && x.SenderUserId == userId)
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.OrderByDescending(x => x.CreationDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<List<TaskChatMessage>> GetMediaMessagesAsync(Guid taskId, int pageNumber, int pageSize)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.Where(x => x.TaskId == taskId && x.FileId != null)
|
||||
.Include(x => x.ReplyToMessage)
|
||||
.OrderByDescending(x => x.CreationDate)
|
||||
.Skip((pageNumber - 1) * pageSize)
|
||||
.Take(pageSize)
|
||||
.ToListAsync();
|
||||
}
|
||||
|
||||
public async Task<TaskChatMessage> AddAsync(TaskChatMessage message)
|
||||
{
|
||||
await _context.TaskChatMessages.AddAsync(message);
|
||||
return message;
|
||||
}
|
||||
|
||||
public Task UpdateAsync(TaskChatMessage message)
|
||||
{
|
||||
_context.TaskChatMessages.Update(message);
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task DeleteAsync(TaskChatMessage message)
|
||||
{
|
||||
_context.TaskChatMessages.Remove(message);
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public async Task<int> SaveChangesAsync()
|
||||
{
|
||||
return await _context.SaveChangesAsync();
|
||||
}
|
||||
|
||||
public async Task<bool> ExistsAsync(Guid messageId)
|
||||
{
|
||||
return await _context.TaskChatMessages
|
||||
.AnyAsync(x => x.Id == messageId);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user