APB vNext 集成微服务实战 丨业务接口
作者：互联网
前言
首先非常感谢老哥提出的问题
@落叶子
IdentityServer、用户、角色、组织 你都没用到 然后生成那么多没用的表，这点感觉不怎么好
首先回答一下上一章，大家提出的疑问，首先我本次搭建的这个项目，在安排上其实需要用到以上的东西。
但是如果说你在用的时候发现abp默认生成的很多表你不想要你该怎么办呢。
针对IdentityServer你可以移除掉改成Jwt
针对组织架构，这一点这里强调说明，在我们开发项目的时候，组织架构是需要我们根据项目要求做出调整的，在真实业务场景是需要重写的，abp提供的组织模块仅供参考。
我最近又思考了一下，我觉得上次的设计在后面会给我自己挖坑，我只是做技术教程，不想写太多业务上的代码，所以我将Entity做出了一点点的调整，将创建问答和文章的支持匿名，相应的问答就不存在采纳，而是改为赞同。
对应的也省掉了修改和删除的接口，我真是太机智了！
开始
上一节 我们简单的创建了下Entity 和 实体映射配置，这一节来吧问答业务写一下。
创捷接口抽象和Dto
根据Abp的规范，我们先要在 Application.Contracts 层创建(Contracts翻译过来就是合约，用于约束具体业务的实现行为)，接口定义和Dto
创建 Questions 文件夹 内部创建 IQuestionAppService 接口
public interface IQuestionAppService : IApplicationService
{
/// <summary>
/// 获取所有问答
/// </summary>
/// <returns></returns>
Task<ListResultDto<QuestionDto>> GetListAllAsync();
/// <summary>
/// 获取问答列表
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
Task<PagedResultDto<QuestionDto>> GetListAsync(GetQuestionInputDto input);
/// <summary>
/// 获取问答详情
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
Task<QuestionDetailsDto> GetAsync(Guid id);
/// <summary>
/// 创建问答
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
Task CreateAsync(CreateQuestionInputDto input);
}
并创建 CreateQuestionInputDto、GetQuestionInputDto、QuestionDetailsDto、QuestionDto 这里因为我们没有修改所以没写修改的Dto，根据我目前的使用经验
一个Entity业务基本上对应以上 5个 Dto 就能够满足正常的CRUD业务需要。
public class CreateQuestionInputDto
{
/// <summary>
/// 标题
/// </summary>
public string Title { get; set; }
/// <summary>
/// 内容
/// </summary>
public string Content { get; set; }
/// <summary>
/// 类别
/// </summary>
public string Tag { get; set; }
}
public class GetQuestionInputDto : PagedAndSortedResultRequestDto
{
public string Filter { get; set; }
}
public class QuestionDetailsDto : FullAuditedEntityDto<Guid>
{
/// <summary>
/// 标题
/// </summary>
public string Title { get; set; }
/// <summary>
/// 内容
/// </summary>
public string Content { get; set; }
/// <summary>
/// 类别
/// </summary>
public string Tag { get; set; }
/// <summary>
/// 访问量
/// </summary>
public int Traffic { get; set; }
/// <summary>
/// 回答
/// </summary>
public List<QuestionCommentDto> QuestionComment = new List<QuestionCommentDto>();
}
public class QuestionDto : FullAuditedEntityDto<Guid>
{
/// <summary>
/// 标题
/// </summary>
public string Title { get; set; }
/// <summary>
/// 内容
/// </summary>
public string Content { get; set; }
/// <summary>
/// 类别
/// </summary>
public string Tag { get; set; }
/// <summary>
/// 访问量
/// </summary>
public int Traffic { get; set; }
/// <summary>
/// 回答数量
/// </summary>
public int QuestionCommentsCount { get; set; }
}
另外因为问答有个评论，我们在内部创建一个 Comments 文件夹，创建 CreateQuestionCommentInputDto、QuestionCommentDto 2个Dto 这里因为我们回答不牵扯修改和指定查询动作所以就2个Dto
public class CreateQuestionCommentInputDto
{
/// <summary>
/// 内容
/// </summary>
public string Content { get; set; }
}
public class QuestionCommentDto : FullAuditedEntityDto<Guid>
{
/// <summary>
/// 内容
/// </summary>
public string Content { get; set; }
/// <summary>
/// 赞同数
/// </summary>
public bool ApproveOf { get; set; }
}
完成后的结构如下图所示
实现接口业务
在 Application 创建 QuestionAppService 继承 AbpvNextAppService 和 刚才创建的 IQuestionAppService 接口。
先列出一个我们最初级的写法，当我们开始用Abp的时候，你不会写你就算用下面的写法你的代码也是很优秀的，因为它可以随着你对Abp的深入了解，非常简单的就能改造完成，
用我经常说的一句话，你已经在这么优秀的框架上进行开发了，你写的代码在烂又能烂到哪去。
public class QuestionAppService: AbpvNextAppService, IQuestionAppService
{
protected readonly IRepository<Question> _questionsRepository;
protected readonly IRepository<QuestionComment> _questionCommentsRepository;
public QuestionAppService(IRepository<Question> questionsRepository, IRepository<QuestionComment> questionCommentsRepository)
{
_questionsRepository = questionsRepository;
_questionCommentsRepository = questionCommentsRepository;
}
/// <summary>
/// 获取所有问答
/// </summary>
/// <returns></returns>
public async Task<ListResultDto<QuestionDto>> GetListAllAsync()
{
var entityList = await _questionsRepository.GetListAsync();
return new ListResultDto<QuestionDto>(ObjectMapper.Map<List<Question>, List<QuestionDto>>(entityList));
}
/// <summary>
/// 获取问答列表
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
public async Task<PagedResultDto<QuestionDto>> GetListAsync(GetQuestionInputDto input)
{
// .WhereIf(!input.Filter.IsNullOrEmpty(), x => x.Title.Contains(input.Filter) || x.Content.Contains(input.Filter))
var entityList = await _questionsRepository.GetPagedListAsync(input.SkipCount, input.MaxResultCount, input.Sorting);
var result = ObjectMapper.Map<List<Question>, List<QuestionDto>>(entityList);
return new PagedResultDto<QuestionDto>(100, result);
}
/// <summary>
/// 获取问答详情
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public async Task<QuestionDetailsDto> GetAsync(Guid id)
{
var entity = await _questionsRepository.FindAsync(x=>x.Id == id);
return ObjectMapper.Map<Question, QuestionDetailsDto>(entity);
}
/// <summary>
/// 创建问答
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
public async Task CreateAsync(CreateQuestionInputDto input)
{
var entity = ObjectMapper.Map<CreateQuestionInputDto, Question>(input);
await _questionsRepository.InsertAsync(entity);
}
}
改造
上面的代码你会看到我把筛选条件给注释了，因为Abp提供的GetPagedListAsync 并不是基于IQueryable而是封装的仓储方法，当然你也可以通过_questionsRepository.WithDetailsAsync()来写linq 完成，但是Abp提供了另一种方案自定义仓储
自定义仓储
在领域层的问答文件夹新建仓储接口 IQuestionRepository,这里传递一些开发经验Abp本身的那个PageList有个非常不好的点，它官方的写法是通过调用2次接口一次返回数据，一次返回Count,对于这么简单的类型返回其实用元组也可以，但是我比较偏向于定于类型所以我封装了一个EntityPageCount来数据，另外根据经验我的仓储都会出现这3个接口，如果业务需要做字段验证我会外加一个 ExistsAsync，如果还需要根据某某编码或者特定字段查询我会加一个 GetByXXXAsync。
public interface IQuestionRepository : IBasicRepository<Question, Guid>
{
Task<EntityPageCount<Question>> GetListAsync(string filter,
bool includeDetails = true, string sorting = null,
int maxResultCount = Int32.MaxValue, int skipCount = 0, CancellationToken cancellationToken = default);
Task<Question> GetByIdAsync(Guid id, bool includeDetails = true,
CancellationToken cancellationToken = default);
Task<List<Question>> GetListByIdsAsync(List<Guid> ids, bool includeDetails = true,
CancellationToken cancellationToken = default);
}
在持久化层 增加 EFCoreRepository 文件夹实现自定义仓储接口,这里有2点经验我说一下，首先是ApplyFilterForGetAll方法该方法应做到所有参数都可以传递null,方便提供给其他方法进行调用，这个可能需要一个复杂业务才能体会到。第二点就是 IncludeDetails 我个人不推荐在使用EF的时候开启懒加载，所以我会扩展一个IncludeDetails方法，通过传递参数来选择是否加载子表
(什么你问我多个子表怎么办？你不会吧bool改成Flag枚举嘛)
public class EfCoreQuestionRepository : EfCoreRepository<AbpvNextDbContext, Question, Guid>, IQuestionRepository
{
public EfCoreQuestionRepository(IDbContextProvider<AbpvNextDbContext> dbContextProvider) : base(dbContextProvider)
{
}
public async Task<EntityPageCount<Question>> GetListAsync(string filter, bool includeDetails = true,
string sorting = null, int maxResultCount = Int32.MaxValue, int skipCount = 0,
CancellationToken cancellationToken = default)
{
IQueryable<Question> query = ApplyFilterForGetAll(await GetDbSetAsync(), filter);
query = query.OrderBy(string.IsNullOrWhiteSpace(sorting) ? nameof(Question.CreationTime) : sorting).AsNoTracking();
var count = query.Count();
var entityList = await query.IncludeDetails(includeDetails).PageBy(skipCount, maxResultCount).ToListAsync(cancellationToken);
return new EntityPageCount<Question>(count, entityList);
}
public async Task<Question> GetByIdAsync(Guid id, bool includeDetails = true, CancellationToken cancellationToken = default)
{
return await(await GetDbSetAsync()).Where(x => x.Id == id).IncludeDetails(includeDetails).FirstOrDefaultAsync(GetCancellationToken(cancellationToken));
}
public async Task<List<Question>> GetListByIdsAsync(List<Guid> ids, bool includeDetails = true, CancellationToken cancellationToken = default)
{
return await(await GetDbSetAsync()).Where(x => ids.Contains(x.Id)).IncludeDetails(includeDetails).ToListAsync(GetCancellationToken(cancellationToken));
}
protected virtual IQueryable<Question> ApplyFilterForGetAll(IQueryable<Question> query, string filter)
{
return query.Include(x => x.QuestionComments)
.WhereIf(!filter.IsNullOrEmpty(), x => x.Title.Contains(filter) || x.Content.Contains(filter));
}
}
采用自定义仓储改完之后接口
public class QuestionAppService: AbpvNextAppService, IQuestionAppService
{
protected readonly IQuestionRepository _questionsRepository;
public QuestionAppService(IQuestionRepository questionsRepository)
{
_questionsRepository = questionsRepository;
}
/// <summary>
/// 获取所有问答
/// </summary>
/// <returns></returns>
public async Task<ListResultDto<QuestionDto>> GetListAllAsync()
{
var entityList = await _questionsRepository.GetListAsync();
return new ListResultDto<QuestionDto>(ObjectMapper.Map<List<Question>, List<QuestionDto>>(entityList));
}
/// <summary>
/// 获取问答列表
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
public async Task<PagedResultDto<QuestionDto>> GetListAsync(GetQuestionInputDto input)
{
var entityList = await _questionsRepository.GetListAsync(input.Filter, false, input.Sorting, input.MaxResultCount, input.SkipCount);
var result = ObjectMapper.Map<List<Question>, List<QuestionDto>>(entityList.EntityList);
return new PagedResultDto<QuestionDto>(entityList.Count, result);
}
/// <summary>
/// 获取问答详情
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public async Task<QuestionDetailsDto> GetAsync(Guid id)
{
var entity = await _questionsRepository.FindAsync(id);
return ObjectMapper.Map<Question, QuestionDetailsDto>(entity);
}
/// <summary>
/// 创建问答
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
public async Task CreateAsync(CreateQuestionInputDto input)
{
var entity = ObjectMapper.Map<CreateQuestionInputDto, Question>(input);
await _questionsRepository.InsertAsync(entity);
}
}
AutoMap映射
接口改完了,接下来需要把数据映射搞一下在 Application 层有一个 xxxApplicationAutoMapperProfile类
public class AbpvNextApplicationAutoMapperProfile : Profile
{
public AbpvNextApplicationAutoMapperProfile()
{
/* You can configure your AutoMapper mapping configuration here.
* Alternatively, you can split your mapping configurations
* into multiple profile classes for a better organization. */
// 问答
CreateMap<Question, QuestionDto>();
CreateMap<Question, QuestionDetailsDto>();
}
}
结语
本节知识点：
1.业务接口
2.泛型仓储介绍
3.如何自定义仓储
4.配置AutoMap映射
就先讲到这里吧，运行代码你会发现创建接口报错，因为我们没有加AutoMap映射，这里不写主要是偷懒不想写多余的代码，因为下一节我们讲DDD实践，现在这样写代码太糙了。
请各位一起指出文章中错误的讲解点 谢谢，如果你也在使用Abp有好的设计思路和想法希望你能共享给我，我们一起交流 加油！
该项目存放仓库在 https://github.com/BaseCoreVueProject/Blog.Core.AbpvNext
联系作者：加群：867095512 @MrChuJiu
标签：vNext,Task,string,get,questionsRepository,接口,APB,input,public 来源： https://www.cnblogs.com/MrChuJiu/p/15085946.html