Wpf 使用 Prism 实战开发Day14

备忘录接口增删（CURD）改查实现

一.添加备忘录控制器（MemoController）

备忘录控制器（MemoController）和待办事项控制器（ToDoController）功能实现差不多一样。基本套路就是：

定义控制器（Controller）
定义数据传输层（Dto）
配置实体类（Entity）和数据传输类（Dto）关系映射（Auto Mapper）
定义服务接口（IService）
实现服务接口 (Service)
把服务注入控制器中使用
最后在 Program.cs 进行依赖注入

1.在 MyToDo.Api 项目Controllers文件夹中，定义（MemoController）备忘录控制器

    /// <summary>/// 备忘录控制器/// </summary>[ApiController][Route("api/[controller]/[action]")]public class MemoController : ControllerBase{}

2.在 MyToDo.Shared 项目Dtos文件夹中，定义（MemoDto）备忘录数据传输层

    /// <summary>/// 备忘录数据传输实体/// </summary>public class MemoDto : BaseDto{private string title;private string content;public string Title{get { return title; }set { title = value; OnPropertyChanged(); }}public string Content{get { return content; }set { content = value; OnPropertyChanged(); }}}

3.在MyToDo.Api 项目 Extensions 文件夹的 AutoMapperProFile 类中配置Auto Mapper

    public class AutoMapperProFile:MapperConfigurationExpression{public AutoMapperProFile(){/// 实体类和数据传输类进行映射CreateMap<ToDo, ToDoDto>().ReverseMap();CreateMap<Memo, MemoDto>().ReverseMap();}}

4.在MyToDo.Api 项目Service 文件夹中，定义备忘录服务接口（IMemoService）

    public interface IMemoService: IBaseService<MemoDto>{}

5.同样，在MyToDo.Api 项目Service 文件夹中，实现（MemoService）备忘录服务接口

/// <summary>
///备忘录的实现
/// </summary>
public class MemoService : IMemoService
{private readonly IUnitOfWork work;private readonly IMapper mapper;public MemoService(IUnitOfWork work,IMapper mapper){this.work = work;this.mapper = mapper;}public async Task<ApiResponse> AddAsync(MemoDto model){try{var doto= mapper.Map<Memo>(model);//进行数据映射转换await work.GetRepository<Memo>().InsertAsync(doto);if (await work.SaveChangesAsync() > 0) //保存成功{return new ApiResponse(true, model); //返回true，并把添加的实体返回}return new ApiResponse("添加数据失败");}catch (Exception ex){return new ApiResponse(ex.Message);}}public async Task<ApiResponse> DeleteAsync(int id){try{var repository= work.GetRepository<Memo>();//获取仓储//删除之前，先进行查询var todo = await repository.GetFirstOrDefaultAsync(predicate:x=>x.Id.Equals(id));repository.Delete(todo);if (await work.SaveChangesAsync() > 0) //删除成功{return new ApiResponse(true, "删除成功"); }return new ApiResponse("删除数据失败");}catch (Exception ex){return new ApiResponse(ex.Message);}}public async Task<ApiResponse> GetAllAsync(){try{var todos= await work.GetRepository<Memo>().GetAllAsync();return new ApiResponse(true, todos); //返回true，并返回所有数据}catch (Exception ex){return new ApiResponse(ex.Message);}}public async Task<ApiResponse> GetSingleAsync(int id){try{var todo= await work.GetRepository<Memo>().GetFirstOrDefaultAsync(predicate: x => x.Id.Equals(id));return new ApiResponse(true, todo); //把找到的数据返回}catch (Exception ex){return new ApiResponse(ex.Message);}}public async Task<ApiResponse> UpdateAsync(MemoDto model){try{var dbdoto = mapper.Map<Memo>(model);var repository = work.GetRepository<Memo>();//获取仓储//更新之前，先拿到要更新的数据var todo = await repository.GetFirstOrDefaultAsync(predicate: x => x.Id.Equals(dbdoto.Id));todo.Title = dbdoto.Title;todo.Content = dbdoto.Content;todo.UpdateDate = DateTime.Now;repository.Update(todo);if (await work.SaveChangesAsync() > 0) //更新成功{return new ApiResponse(true, "更新成功");}return new ApiResponse("更新数据失败");}catch (Exception ex){return new ApiResponse(ex.Message);}}
}

6.接着，在 MemoController 控制器中注入并使用IMemoService 服务

    /// <summary>/// 备忘录控制器/// </summary>[ApiController][Route("api/[controller]/[action]")]public class MemoController : ControllerBase{private readonly IMemoService service;public MemoController(IMemoService service){this.service = service;}[HttpGet]public async Task<ApiResponse> Get(int id) => await service.GetSingleAsync(id);[HttpGet]public async Task<ApiResponse> GetAll() => await service.GetAllAsync();[HttpPost]public async Task<ApiResponse> Add([FromBody] MemoDto model) => await service.AddAsync(model);[HttpPost]public async Task<ApiResponse> Update([FromBody] MemoDto model) => await service.UpdateAsync(model);[HttpDelete]public async Task<ApiResponse> Delete(int id) => await service.DeleteAsync(id);}

7.最后，在 Program.cs 中注入 IMemoService 服务

builder.Services.AddTransient<IMemoService, MemoService>();

二.高级查询实现

根据传入的条件进行分页查询。

1.在MyToDo.Shared 项目中，创建通用的查询实体类（QueryParameter）

    public class QueryParameter{/// <summary>///  页数/// </summary>public int PageIndex { get; set; }/// <summary>///  总数/// </summary>public int PageSize { get; set; }/// <summary>/// 查询条件/// </summary>public string? Search { get; set; }}

2.改造 IBaseService 基类服务接口，传入通用查询实体类（QueryParameter）

3.在备忘录或待办事项接口服务实现层，去改造实现高级查询逻辑

例如：MemoService 服务实现层，改造GetAllAsync 查询接口

        public async Task<ApiResponse> GetAllAsync(QueryParameter query){try{var todos = await work.GetRepository<Memo>()//根据标题查，如果传过来的Search 为空，直接过。否则就匹配标题。.GetPagedListAsync(predicate: x => string.IsNullOrWhiteSpace(query.Search) ? true : x.Title.Equals(query.Search),pageIndex: query.PageIndex,pageSize: query.PageSize,orderBy:source=>source.OrderByDescending(t=>t.CreateDate) //根据创建时间进行排序);return new ApiResponse(true, todos); //返回true，并返回所有数据}catch (Exception ex){return new ApiResponse(ex.Message);}}