using AutoMapper; using UserManagement.Common.UnitOfWork; using UserManagement.Data.Dto; using UserManagement.Data; using UserManagement.Helper; using UserManagement.MediatR.Commands; using UserManagement.Repository; using MediatR; using System; using System.Threading; using System.Threading.Tasks; using Microsoft.EntityFrameworkCore; using UserManagement.Domain; namespace UserManagement.MediatR.Handlers { public class CreatePageHelperCommandHandler : IRequestHandler> { private readonly IPageHelperRepository _pageHelperRepository; private readonly IUnitOfWork _uow; private readonly IMapper _mapper; public CreatePageHelperCommandHandler(IPageHelperRepository pageHelperRepository, IMapper mapper, IUnitOfWork uow) { _pageHelperRepository = pageHelperRepository; _mapper = mapper; _uow = uow; } public async Task> Handle(CreatePageHelperCommand request, CancellationToken cancellationToken) { var entityExist = await _pageHelperRepository.FindBy(c => c.Name.ToUpper() == request.Name.ToUpper()).FirstOrDefaultAsync(); if (entityExist != null) { return ServiceResponse.Return409("Page helper with same name already exists."); } var entity = _mapper.Map(request); entity.Code = entity.Name.ToUpper().Replace(" ", "_"); entity.Id = Guid.NewGuid(); _pageHelperRepository.Add(entity); if (await _uow.SaveAsync() <= 0) { return ServiceResponse.Return500(); } var entityDto = _mapper.Map(entity); return ServiceResponse.ReturnResultWith201(entityDto); } } }