using UserManagement.Data; using UserManagement.Data.Dto; using UserManagement.MediatR.Queries; using UserManagement.Repository; using MediatR; using Microsoft.EntityFrameworkCore; using System; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace UserManagement.MediatR.Handlers { public class GetMonthlyReminderQueryHandler : IRequestHandler> { private readonly IReminderRepository _reminderRepository; private readonly UserInfoToken _userInfo; public GetMonthlyReminderQueryHandler(IReminderRepository reminderRepository, UserInfoToken userInfo) { _reminderRepository = reminderRepository; _userInfo = userInfo; } public async Task> Handle(GetMonthlyReminderQuery request, CancellationToken cancellationToken) { var startDate = new DateTime(request.Year, request.Month, 1, 0, 0, 1); var monthEndDate = startDate.AddMonths(1).AddDays(-1); var endDate = new DateTime(monthEndDate.Year, monthEndDate.Month, monthEndDate.Day, 23, 59, 59); var lastDayOfMonth = endDate.Day; var reminders = await _reminderRepository.All .Include(c => c.ReminderUsers) .Where(c => c.Frequency == Frequency.Monthly && c.StartDate <= endDate && (!c.EndDate.HasValue || c.EndDate >= startDate) && (c.CreatedBy == Guid.Parse(_userInfo.Id) || c.ReminderUsers.Any(c => c.UserId == Guid.Parse(_userInfo.Id)))) .ToListAsync(); var reminderDto = reminders.Select(c => new CalenderReminderDto { RemiderId = c.Id, Title = c.Subject, Start = new DateTime(startDate.Year, startDate.Month, c.StartDate.Day > lastDayOfMonth ? lastDayOfMonth : c.StartDate.Day, startDate.Hour, startDate.Minute, startDate.Hour), End = new DateTime(startDate.Year, startDate.Month, c.StartDate.Day > lastDayOfMonth ? lastDayOfMonth : c.StartDate.Day, startDate.Hour, startDate.Minute, startDate.Hour), }).ToList(); return reminderDto; } } }