lakshithacodes

        [HttpGet]
        [Route("get-all")]
        public async Task<List<AllCustomerQueryResponseModel>> GetAllCustomerAsync(AllCustomerQueryRequestModel requestModel)
        {
            try
            {
                return await mediator.Send(requestModel);
            }
            catch
            {

lakshithacodes

    public class AllCustomerQueryHandler : IRequestHandler<AllCustomerQueryRequestModel, List<AllCustomerQueryResponseModel>>
    {
        private readonly CustomerDbContext context;

        public AllCustomerQueryHandler(CustomerDbContext context)
        {
            this.context = context;
        }

        public async Task<List<AllCustomerQueryResponseModel>> Handle(AllCustomerQueryRequestModel request, 

lakshithacodes

   public class AllCustomerQueryResponseModel
    {
        public int CustomerId { get; set; }
        public string Name { get; set; }
        public string City { get; set; }
        public int LoyaltyPoints { get; set; }
    }

lakshithacodes

    [Route("api/[controller]")]
    [ApiController]
    public class CustomerController : ControllerBase
    {
        private readonly IMediator mediator;
        public CustomerController(IMediator mediator)
        {
            this.mediator = mediator;
        }

lakshithacodes

    public class SaveCustomerCommandHandler : IRequestHandler<SaveCustomerRequestModel, Unit>
    {
        private readonly CustomerDbContext context;

        public SaveCustomerCommandHandler(CustomerDbContext context)
        {
            this.context = context;
        }
        public async Task<Unit> Handle(SaveCustomerRequestModel saveCustomerRequestModel, 
        CancellationToken cancellationToken)

lakshithacodes

namespace CQRSwithMediatR.RequestModels.CommandRequests
{
    public class SaveCustomerRequestModel : IRequest 
    {
        public string Title { get; set; }
        public string Name { get; set; }
        public string City { get; set; }
        public int LoyaltyPoints { get; set; }
    }
}

lakshithacodes

        [HttpGet]
        [Route("customer-id")]
        [ProducesResponseType(typeof(CustomerIdQueryResponseModel),StatusCodes.Status200OK)]
        public async Task<IActionResult> GetCustomerAsync([FromQuery] CustomerIdQueryRequestModel model)
        {
            try
            {
                var result = await this.customerIdQueryHandler.GetCustomerAsync(model);
                if (result != null)

lakshithacodes

namespace CustomerManagement.Handlers.QueryHandler
{
    public class CustomerIdQueryHandler : ICustomerIdQueryHandler
    {
        private readonly CustomerDbContext context;
        public CustomerIdQueryHandler(CustomerDbContext context)
        {
            this.context = context;
        }
        public async Task<CustomerIdQueryResponseModel> GetCustomerAsync(CustomerIdQueryRequestModel requestModel)

lakshithacodes

namespace CustomerManagement.Contracts.QueryHandlers
{
    public interface ICustomerIdQueryHandler
    {
        Task<CustomerIdQueryResponseModel> GetCustomerAsync(CustomerIdQueryRequestModel requestModel);
    }
}

lakshithacodes

namespace CustomerManagement.RequestModels.QueryRequests
{
    public class CustomerIdQueryRequestModel
    {
        public int CustomerId { get; set; }
    }
}