备忘录接口增删(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);
}
}
4.最后,修改备忘录(MemoController)控制器和待办事项(ToDoController)控制器 GetAll 方法的参数传入。
[FromQuery]
特性作用:将查询字符串参数值绑定到对应的 QueryParameter 参数上文章来源:https://www.toymoban.com/news/detail-814425.html
文章来源地址https://www.toymoban.com/news/detail-814425.html
到了这里,关于Wpf 使用 Prism 实战开发Day14的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!