51 lines
1.3 KiB
C#
51 lines
1.3 KiB
C#
|
using PoweredSoft.CQRS.Abstractions;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
namespace Demo.Queries
|
|||
|
|
{
|
|||
|
|
public class Person
|
|||
|
|
{
|
|||
|
|
public long Id { get; set; }
|
|||
|
|
public string FirstName { get; set; }
|
|||
|
|
public string LastName { get; set; }
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public class PersonQuery
|
|||
|
|
{
|
|||
|
|
public string Search { get; set; }
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public class PersonQueryHandler : IQueryHandler<PersonQuery, IQueryable<Person>>
|
|||
|
|
{
|
|||
|
|
private readonly IEnumerable<Person> _persons = new List<Person>()
|
|||
|
|
{
|
|||
|
|
new Person
|
|||
|
|
{
|
|||
|
|
Id = 1,
|
|||
|
|
FirstName = "David",
|
|||
|
|
LastName = "Lebee"
|
|||
|
|
},
|
|||
|
|
new Person
|
|||
|
|
{
|
|||
|
|
Id = 2,
|
|||
|
|
FirstName = "John",
|
|||
|
|
LastName = "Doe"
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
public Task<IQueryable<Person>> HandleAsync(PersonQuery query, CancellationToken cancellationToken = default)
|
|||
|
|
{
|
|||
|
|
var ret = _persons.AsQueryable();
|
|||
|
|
|
|||
|
|
if (query != null && !string.IsNullOrEmpty(query.Search))
|
|||
|
|
ret = ret.Where(t => t.FirstName.Contains(query.Search) || t.LastName.Contains(query.Search));
|
|||
|
|
|
|||
|
|
return Task.FromResult(ret);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|