mirror of https://github.com/abpframework/abp.git
8 changed files with 449 additions and 259 deletions
@ -0,0 +1,341 @@ |
|||||
|
using System; |
||||
|
using System.Linq; |
||||
|
using System.Linq.Dynamic.Core; |
||||
|
using System.Threading.Tasks; |
||||
|
using Volo.Abp.Application.Dtos; |
||||
|
using Volo.Abp.Auditing; |
||||
|
using Volo.Abp.Domain.Entities; |
||||
|
using Volo.Abp.Domain.Repositories; |
||||
|
using Volo.Abp.Linq; |
||||
|
using Volo.Abp.MultiTenancy; |
||||
|
using Volo.Abp.ObjectMapping; |
||||
|
|
||||
|
namespace Volo.Abp.Application.Services |
||||
|
{ |
||||
|
public abstract class AbstractKeyCrudAppService<TEntity, TEntityDto, TKey> |
||||
|
: AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, PagedAndSortedResultRequestDto> |
||||
|
where TEntity : class, IEntity |
||||
|
{ |
||||
|
protected AbstractKeyCrudAppService(IRepository<TEntity> repository) |
||||
|
: base(repository) |
||||
|
{ |
||||
|
|
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public abstract class AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, TGetListInput> |
||||
|
: AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TEntityDto, TEntityDto> |
||||
|
where TEntity : class, IEntity |
||||
|
{ |
||||
|
protected AbstractKeyCrudAppService(IRepository<TEntity> repository) |
||||
|
: base(repository) |
||||
|
{ |
||||
|
|
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public abstract class AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput> |
||||
|
: AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TCreateInput> |
||||
|
where TEntity : class, IEntity |
||||
|
{ |
||||
|
protected AbstractKeyCrudAppService(IRepository<TEntity> repository) |
||||
|
: base(repository) |
||||
|
{ |
||||
|
|
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public abstract class AbstractKeyCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput> |
||||
|
: AbstractKeyCrudAppService<TEntity, TEntityDto, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput> |
||||
|
where TEntity : class, IEntity |
||||
|
{ |
||||
|
protected AbstractKeyCrudAppService(IRepository<TEntity> repository) |
||||
|
: base(repository) |
||||
|
{ |
||||
|
|
||||
|
} |
||||
|
|
||||
|
protected override TEntityDto MapToGetListOutputDto(TEntity entity) |
||||
|
{ |
||||
|
return MapToGetOutputDto(entity); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public abstract class AbstractKeyCrudAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput> |
||||
|
: ApplicationService, |
||||
|
ICrudAppService<TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput> |
||||
|
where TEntity : class, IEntity |
||||
|
{ |
||||
|
public IAsyncQueryableExecuter AsyncQueryableExecuter { get; set; } |
||||
|
|
||||
|
protected IRepository<TEntity> Repository { get; } |
||||
|
|
||||
|
protected virtual string GetPolicyName { get; set; } |
||||
|
|
||||
|
protected virtual string GetListPolicyName { get; set; } |
||||
|
|
||||
|
protected virtual string CreatePolicyName { get; set; } |
||||
|
|
||||
|
protected virtual string UpdatePolicyName { get; set; } |
||||
|
|
||||
|
protected virtual string DeletePolicyName { get; set; } |
||||
|
|
||||
|
protected AbstractKeyCrudAppService(IRepository<TEntity> repository) |
||||
|
{ |
||||
|
Repository = repository; |
||||
|
AsyncQueryableExecuter = DefaultAsyncQueryableExecuter.Instance; |
||||
|
} |
||||
|
|
||||
|
public virtual async Task<TGetOutputDto> GetAsync(TKey id) |
||||
|
{ |
||||
|
await CheckGetPolicyAsync(); |
||||
|
|
||||
|
var entity = await GetEntityByIdAsync(id); |
||||
|
return MapToGetOutputDto(entity); |
||||
|
} |
||||
|
|
||||
|
public virtual async Task<PagedResultDto<TGetListOutputDto>> GetListAsync(TGetListInput input) |
||||
|
{ |
||||
|
await CheckGetListPolicyAsync(); |
||||
|
|
||||
|
var query = CreateFilteredQuery(input); |
||||
|
|
||||
|
var totalCount = await AsyncQueryableExecuter.CountAsync(query); |
||||
|
|
||||
|
query = ApplySorting(query, input); |
||||
|
query = ApplyPaging(query, input); |
||||
|
|
||||
|
var entities = await AsyncQueryableExecuter.ToListAsync(query); |
||||
|
|
||||
|
return new PagedResultDto<TGetListOutputDto>( |
||||
|
totalCount, |
||||
|
entities.Select(MapToGetListOutputDto).ToList() |
||||
|
); |
||||
|
} |
||||
|
|
||||
|
public virtual async Task<TGetOutputDto> CreateAsync(TCreateInput input) |
||||
|
{ |
||||
|
await CheckCreatePolicyAsync(); |
||||
|
|
||||
|
var entity = MapToEntity(input); |
||||
|
|
||||
|
TryToSetTenantId(entity); |
||||
|
|
||||
|
await Repository.InsertAsync(entity, autoSave: true); |
||||
|
|
||||
|
return MapToGetOutputDto(entity); |
||||
|
} |
||||
|
|
||||
|
public virtual async Task<TGetOutputDto> UpdateAsync(TKey id, TUpdateInput input) |
||||
|
{ |
||||
|
await CheckUpdatePolicyAsync(); |
||||
|
|
||||
|
var entity = await GetEntityByIdAsync(id); |
||||
|
//TODO: Check if input has id different than given id and normalize if it's default value, throw ex otherwise
|
||||
|
MapToEntity(input, entity); |
||||
|
await Repository.UpdateAsync(entity, autoSave: true); |
||||
|
|
||||
|
return MapToGetOutputDto(entity); |
||||
|
} |
||||
|
|
||||
|
public virtual async Task DeleteAsync(TKey id) |
||||
|
{ |
||||
|
await CheckDeletePolicyAsync(); |
||||
|
|
||||
|
await DeleteByIdAsync(id); |
||||
|
} |
||||
|
|
||||
|
protected abstract Task DeleteByIdAsync(TKey id); |
||||
|
|
||||
|
protected abstract Task<TEntity> GetEntityByIdAsync(TKey id); |
||||
|
|
||||
|
protected virtual async Task CheckGetPolicyAsync() |
||||
|
{ |
||||
|
await CheckPolicyAsync(GetPolicyName); |
||||
|
} |
||||
|
|
||||
|
protected virtual async Task CheckGetListPolicyAsync() |
||||
|
{ |
||||
|
await CheckPolicyAsync(GetListPolicyName); |
||||
|
} |
||||
|
|
||||
|
protected virtual async Task CheckCreatePolicyAsync() |
||||
|
{ |
||||
|
await CheckPolicyAsync(CreatePolicyName); |
||||
|
} |
||||
|
|
||||
|
protected virtual async Task CheckUpdatePolicyAsync() |
||||
|
{ |
||||
|
await CheckPolicyAsync(UpdatePolicyName); |
||||
|
} |
||||
|
|
||||
|
protected virtual async Task CheckDeletePolicyAsync() |
||||
|
{ |
||||
|
await CheckPolicyAsync(DeletePolicyName); |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Should apply sorting if needed.
|
||||
|
/// </summary>
|
||||
|
/// <param name="query">The query.</param>
|
||||
|
/// <param name="input">The input.</param>
|
||||
|
protected virtual IQueryable<TEntity> ApplySorting(IQueryable<TEntity> query, TGetListInput input) |
||||
|
{ |
||||
|
//Try to sort query if available
|
||||
|
if (input is ISortedResultRequest sortInput) |
||||
|
{ |
||||
|
if (!sortInput.Sorting.IsNullOrWhiteSpace()) |
||||
|
{ |
||||
|
return query.OrderBy(sortInput.Sorting); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
//IQueryable.Task requires sorting, so we should sort if Take will be used.
|
||||
|
if (input is ILimitedResultRequest) |
||||
|
{ |
||||
|
return ApplyDefaultSorting(query); |
||||
|
} |
||||
|
|
||||
|
//No sorting
|
||||
|
return query; |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Applies sorting if no sorting specified but a limited result requested.
|
||||
|
/// </summary>
|
||||
|
/// <param name="query">The query.</param>
|
||||
|
protected virtual IQueryable<TEntity> ApplyDefaultSorting(IQueryable<TEntity> query) |
||||
|
{ |
||||
|
if (typeof(TEntity).IsAssignableTo<ICreationAuditedObject>()) |
||||
|
{ |
||||
|
return query.OrderByDescending(e => ((ICreationAuditedObject)e).CreationTime); |
||||
|
} |
||||
|
|
||||
|
throw new AbpException("No sorting specified but this query requires sorting. Override the ApplyDefaultSorting method for your application service derived from AbstractKeyCrudAppService!"); |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Should apply paging if needed.
|
||||
|
/// </summary>
|
||||
|
/// <param name="query">The query.</param>
|
||||
|
/// <param name="input">The input.</param>
|
||||
|
protected virtual IQueryable<TEntity> ApplyPaging(IQueryable<TEntity> query, TGetListInput input) |
||||
|
{ |
||||
|
//Try to use paging if available
|
||||
|
if (input is IPagedResultRequest pagedInput) |
||||
|
{ |
||||
|
return query.PageBy(pagedInput); |
||||
|
} |
||||
|
|
||||
|
//Try to limit query result if available
|
||||
|
if (input is ILimitedResultRequest limitedInput) |
||||
|
{ |
||||
|
return query.Take(limitedInput.MaxResultCount); |
||||
|
} |
||||
|
|
||||
|
//No paging
|
||||
|
return query; |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// This method should create <see cref="IQueryable{TEntity}"/> based on given input.
|
||||
|
/// It should filter query if needed, but should not do sorting or paging.
|
||||
|
/// Sorting should be done in <see cref="ApplySorting"/> and paging should be done in <see cref="ApplyPaging"/>
|
||||
|
/// methods.
|
||||
|
/// </summary>
|
||||
|
/// <param name="input">The input.</param>
|
||||
|
protected virtual IQueryable<TEntity> CreateFilteredQuery(TGetListInput input) |
||||
|
{ |
||||
|
return Repository; |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Maps <see cref="TEntity"/> to <see cref="TGetOutputDto"/>.
|
||||
|
/// It uses <see cref="IObjectMapper"/> by default.
|
||||
|
/// It can be overriden for custom mapping.
|
||||
|
/// </summary>
|
||||
|
protected virtual TGetOutputDto MapToGetOutputDto(TEntity entity) |
||||
|
{ |
||||
|
return ObjectMapper.Map<TEntity, TGetOutputDto>(entity); |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Maps <see cref="TEntity"/> to <see cref="TGetListOutputDto"/>.
|
||||
|
/// It uses <see cref="IObjectMapper"/> by default.
|
||||
|
/// It can be overriden for custom mapping.
|
||||
|
/// </summary>
|
||||
|
protected virtual TGetListOutputDto MapToGetListOutputDto(TEntity entity) |
||||
|
{ |
||||
|
return ObjectMapper.Map<TEntity, TGetListOutputDto>(entity); |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Maps <see cref="TCreateInput"/> to <see cref="TEntity"/> to create a new entity.
|
||||
|
/// It uses <see cref="IObjectMapper"/> by default.
|
||||
|
/// It can be overriden for custom mapping.
|
||||
|
/// </summary>
|
||||
|
protected virtual TEntity MapToEntity(TCreateInput createInput) |
||||
|
{ |
||||
|
var entity = ObjectMapper.Map<TCreateInput, TEntity>(createInput); |
||||
|
SetIdForGuids(entity); |
||||
|
return entity; |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Sets Id value for the entity if <see cref="TKey"/> is <see cref="Guid"/>.
|
||||
|
/// It's used while creating a new entity.
|
||||
|
/// </summary>
|
||||
|
protected virtual void SetIdForGuids(TEntity entity) |
||||
|
{ |
||||
|
var entityWithGuidId = entity as IEntity<Guid>; |
||||
|
|
||||
|
if (entityWithGuidId == null || entityWithGuidId.Id != Guid.Empty) |
||||
|
{ |
||||
|
return; |
||||
|
} |
||||
|
|
||||
|
EntityHelper.TrySetId( |
||||
|
entityWithGuidId, |
||||
|
() => GuidGenerator.Create(), |
||||
|
true |
||||
|
); |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// Maps <see cref="TUpdateInput"/> to <see cref="TEntity"/> to update the entity.
|
||||
|
/// It uses <see cref="IObjectMapper"/> by default.
|
||||
|
/// It can be overriden for custom mapping.
|
||||
|
/// </summary>
|
||||
|
protected virtual void MapToEntity(TUpdateInput updateInput, TEntity entity) |
||||
|
{ |
||||
|
ObjectMapper.Map(updateInput, entity); |
||||
|
} |
||||
|
|
||||
|
protected virtual void TryToSetTenantId(TEntity entity) |
||||
|
{ |
||||
|
if (entity is IMultiTenant && HasTenantIdProperty(entity)) |
||||
|
{ |
||||
|
var tenantId = CurrentTenant.Id; |
||||
|
|
||||
|
if (!tenantId.HasValue) |
||||
|
{ |
||||
|
return; |
||||
|
} |
||||
|
|
||||
|
var propertyInfo = entity.GetType().GetProperty(nameof(IMultiTenant.TenantId)); |
||||
|
|
||||
|
if (propertyInfo == null || propertyInfo.GetSetMethod(true) == null) |
||||
|
{ |
||||
|
return; |
||||
|
} |
||||
|
|
||||
|
propertyInfo.SetValue(entity, tenantId); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
protected virtual bool HasTenantIdProperty(TEntity entity) |
||||
|
{ |
||||
|
return entity.GetType().GetProperty(nameof(IMultiTenant.TenantId)) != null; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,30 @@ |
|||||
|
using System.Linq; |
||||
|
using System.Threading.Tasks; |
||||
|
using Volo.Abp.TestApp.Domain; |
||||
|
using Volo.Abp.Application.Services; |
||||
|
using Volo.Abp.Domain.Repositories; |
||||
|
using Volo.Abp.TestApp.Application.Dto; |
||||
|
|
||||
|
namespace Volo.Abp.TestApp.Application |
||||
|
{ |
||||
|
//This is especially used to test the AbstractKeyCrudAppService
|
||||
|
public class DistrictAppService : AbstractKeyCrudAppService<District, DistrictDto, DistrictKey> |
||||
|
{ |
||||
|
public DistrictAppService(IRepository<District> repository) |
||||
|
: base(repository) |
||||
|
{ |
||||
|
} |
||||
|
|
||||
|
protected override async Task DeleteByIdAsync(DistrictKey id) |
||||
|
{ |
||||
|
await Repository.DeleteAsync(d => d.CityId == id.CityId && d.Name == id.Name); |
||||
|
} |
||||
|
|
||||
|
protected override async Task<District> GetEntityByIdAsync(DistrictKey id) |
||||
|
{ |
||||
|
return await AsyncQueryableExecuter.FirstOrDefaultAsync( |
||||
|
Repository.Where(d => d.CityId == id.CityId && d.Name == id.Name) |
||||
|
); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,11 @@ |
|||||
|
using System; |
||||
|
|
||||
|
namespace Volo.Abp.TestApp.Application |
||||
|
{ |
||||
|
public class DistrictKey |
||||
|
{ |
||||
|
public Guid CityId { get; set; } |
||||
|
|
||||
|
public string Name { get; set; } |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,14 @@ |
|||||
|
using System; |
||||
|
using Volo.Abp.Application.Dtos; |
||||
|
|
||||
|
namespace Volo.Abp.TestApp.Application.Dto |
||||
|
{ |
||||
|
public class DistrictDto : EntityDto |
||||
|
{ |
||||
|
public Guid CityId { get; set; } |
||||
|
|
||||
|
public string Name { get; set; } |
||||
|
|
||||
|
public int Population { get; set; } |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue