Automapper映射期间调用异步方法的实现方案咨询
我来给你几个实用的解决方案,帮你把这几个异步查询整合到AutoMapper的流程里,避免手动赋值容易遗漏的问题:
AutoMapper 10支持异步值解析器,你可以为每个需要异步查询的属性单独封装逻辑,同时借助依赖注入管理你的查询服务,让映射配置更集中、更易维护。
步骤1:创建异步值解析器类
为每个需要查询的属性实现IAsyncValueResolver接口,比如针对RequestedById:
public class RequestedByIdResolver : IAsyncValueResolver<RequestInputDTO, Request, int> { // 注入你的查询服务(比如包含WwidToIdAsync的服务) private readonly IEmployeeService _employeeService; public RequestedByIdResolver(IEmployeeService employeeService) { _employeeService = employeeService; } public async Task<int> ResolveAsync(RequestInputDTO source, Request destination, int destMember, ResolutionContext context) { return await _employeeService.WwidToIdAsync(source.RequestedByWwid); } }
同理,为RequestedForId和OrgHierarchyId分别创建对应的解析器(比如RequestedForIdResolver、OrgHierarchyIdResolver),替换对应的查询方法即可。
步骤2:配置AutoMapper映射
在映射配置中,使用ResolveUsingAsync指定对应的解析器,同时保留原有的AfterMap同步逻辑:
CreateMap<RequestInputDTO, Request>() .ForMember(x => x.RequestedById, opt => opt.ResolveUsingAsync<RequestedByIdResolver>()) .ForMember(x => x.RequestedForId, opt => opt.ResolveUsingAsync<RequestedForIdResolver>()) .ForMember(x => x.OrgHierarchyId, opt => opt.ResolveUsingAsync<OrgHierarchyIdResolver>()) .AfterMap((src, dst) => { dst.Uuid = Guid.NewGuid(); dst.RequestedUtc = DateTime.UtcNow; });
步骤3:调用异步映射方法
使用AutoMapper的MapAsync方法完成映射:
var request = await _mapper.MapAsync<Request>(dto);
优点:每个属性的查询逻辑封装独立,映射配置集中,不会遗漏属性;依赖注入让服务管理更规范,便于单元测试。
缺点:需要为每个属性编写单独的解析器,稍微有点繁琐,但逻辑清晰易维护。
如果你觉得写多个解析器太麻烦,可以自己封装一个扩展方法,把同步映射和异步赋值逻辑整合在一起,保持代码简洁。
步骤1:编写扩展方法
public static async Task<TDestination> MapWithAsyncAfterMap<TSource, TDestination>( this IMapper mapper, TSource source, Func<TSource, TDestination, Task> asyncAfterMap) { // 先完成同步映射 var destination = mapper.Map<TDestination>(source); // 执行异步后续处理 await asyncAfterMap(source, destination); return destination; }
步骤2:调用扩展方法
把之前的手动赋值和同步AfterMap逻辑都放到异步委托里:
var request = await _mapper.MapWithAsyncAfterMap<RequestInputDTO, Request>(dto, async (src, dst) => { dst.RequestedById = await WwidToIdAsync(src.RequestedByWwid); dst.RequestedForId = await WwidToIdAsync(src.RequestedForWwid); dst.OrgHierarchyId = await OrgHierarchyNumberToIdAsync(src.RequestedForOrgHierarchyCode); // 保留原有的同步逻辑 dst.Uuid = Guid.NewGuid(); dst.RequestedUtc = DateTime.UtcNow; });
优点:不需要额外编写解析器,所有逻辑集中在一处,代码简洁直接;适合属性不多、逻辑简单的场景。
缺点:需要调用自定义扩展方法,而非AutoMapper原生方法,团队协作时需要统一认知。
如果你的场景是从数据库查询数据时进行映射(而非创建新实体),可以结合EF Core的ProjectTo和AutoMapper的异步解析器,但这个方案更适合查询场景,对于你当前创建实体的需求,前两个方案更合适。
内容的提问来源于stack exchange,提问作者Gargoyle

