1、新建MenoDto.cs
/// <summary>
/// 备忘录传输实体
/// </summary>
public class MenoDto : BaseDto
{
private string title;
/// <summary>
/// 标题
/// </summary>
public string Title
{
get { return title; }
set { title = value; }
}
private string content;
/// <summary>
/// 内容
/// </summary>
public string Content
{
get { return content; }
set { content = value; }
}
}2、添加映射关系
CreateMap<Memo, MemoDto>().ReverseMap();3、新建服务接口IMemoService
public interface IMemoService : IBaseService<MemoDto>
{
}4、新建服务MemoService
public class MemoService : IMemoService
{
private readonly IUnitOfWork _unitOfWork;
private readonly IMapper mapper;
public MemoService(IMapper mapper, IUnitOfWork unitOfWork)
{
this.mapper = mapper;
_unitOfWork = unitOfWork;
}
/// <summary>
/// 新增备忘录
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public async Task<ApiResponse> AddEntityAsync(MemoDto model)
{
try
{
var memo = mapper.Map<Memo>(model);
await _unitOfWork.GetRepository<Memo>().InsertAsync(memo);
if(await _unitOfWork.SaveChangesAsync() > 0)
{
return new ApiResponse(true, memo);
}
else
{
return new ApiResponse(false, "添加数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}
/// <summary>
/// 删除备忘录
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public async Task<ApiResponse> DeleteEntityAsync(int id)
{
try
{
var repository = _unitOfWork.GetRepository<Memo>();
var memo = await repository.GetFirstOrDefaultAsync(predicate: t => t.Id.Equals(id));
if(memo != null)
{
repository.Delete(memo);
}
if(await _unitOfWork.SaveChangesAsync() > 0)
{
return new ApiResponse(true, "删除数据成功！");
}
else
{
return new ApiResponse(false, "删除数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}
/// <summary>
/// 查询所有备忘录
/// </summary>
/// <returns></returns>
public async Task<ApiResponse> GetAllAsync()
{
try
{
var repository = _unitOfWork.GetRepository<Memo>();
var memo = await repository.GetAllAsync();
if(memo != null)
{
return new ApiResponse(true, memo);
}
else
{
return new ApiResponse(false, "查询数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}
/// <summary>
/// 根据Id查询备忘录
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public async Task<ApiResponse> GetSingleAsync(int id)
{
try
{
var repository = _unitOfWork.GetRepository<Memo>();
var memo = await repository.GetFirstOrDefaultAsync(predicate: t => t.Id.Equals(id));
if(memo != null)
{
return new ApiResponse(true, memo);
}
else
{
return new ApiResponse(false, $"查询Id={id}的数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}
/// <summary>
/// 更新备忘录
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public async Task<ApiResponse> UpdateEntityAsync(MemoDto model)
{
try
{
var dbmemo = mapper.Map<Memo>(model);
var repository = _unitOfWork.GetRepository<Memo>();
var memo = await repository.GetFirstOrDefaultAsync(predicate: t => t.Id.Equals(dbmemo.Id));
if( memo != null)
{
memo.Title = dbmemo.Title;
memo.Content = dbmemo.Content;
memo.UpdateDate = DateTime.Now;
repository.Update(memo);
if(await _unitOfWork.SaveChangesAsync() > 0)
{
return new ApiResponse(true, "更新数据成功！");
}
else
{
return new ApiResponse(false, "更新数据失败！");
}
}
else
{
return new ApiResponse(false, $"未查询到Id={dbmemo.Id}的数据！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}
}5、新增MemoController控制器
public class MemoController : BaseApiController
{
private readonly IUnitOfWork _unitOfWork;
private readonly IMemoService memoService;
public MemoController(IMemoService memoService, IUnitOfWork unitOfWork)
{
this.memoService = memoService;
_unitOfWork = unitOfWork;
}
[HttpGet]
public async Task<ApiResponse> GetMemoById(int Id)
{
return await memoService.GetSingleAsync(Id);
}
[HttpPost]
public async Task<ApiResponse> AddMemo([FromBody] MemoDto memoDto)
{
return await memoService.AddEntityAsync(memoDto);
}
[HttpDelete]
public async Task<ApiResponse> DeleteMemo(int Id)
{
return await memoService.DeleteEntityAsync(Id);
}
[HttpGet]
public async Task<ApiResponse> GetAllMemo()
{
return await memoService.GetAllAsync();
}
[HttpPost]
public async Task<ApiResponse> UpdateMemo(MemoDto memoDto)
{
return await memoService.UpdateEntityAsync(memoDto);
}
}6、在program.cs添加服务
builder.Services.AddTransient<IMemoService, MemoService>();7、F5运行项目
8、针对查询数据可以做个优化，增加查询的页数、内容、数据量等，新建查询参数类
public class QueryParameter
{
public int PageIndex { get; set; }
public int PageSize { get; set; }
public string Search { get; set; }
}9、在IToDoService.cs和IMemoService.cs中添加分页查询的接口
public interface IToDoService : IBaseService<TodoDto>
{
Task<ApiResponse> GetPageListAllAsync(QueryParameter parameter);
}
public interface IMemoService : IBaseService<MemoDto>
{
Task<ApiResponse> GetPageListAllAsync(QueryParameter parameter);
}10、在ToDoService.cs中实现接口和MemoService.cs中实现接口
/// <summary>
/// 分页查询所有数据
/// </summary>
/// <param name="parameter"></param>
/// <returns></returns>
/// <exception cref="NotImplementedException"></exception>
public async Task<ApiResponse> GetPageListAllAsync(QueryParameter parameter)
{
try
{
var repository = unitOfWork.GetRepository<ToDo>();
var todo = await repository.GetPagedListAsync(predicate: x => string.IsNullOrWhiteSpace(parameter.Search) ? true : x.Title.Contains(parameter.Search),
pageIndex: parameter.PageIndex,
pageSize: parameter.PageSize,
orderBy: y => y.OrderByDescending(t => t.CreateDate));
if (todo != null)
{
return new ApiResponse(true, todo);
}
else
{
return new ApiResponse(false, "查询数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}/// <summary>
/// 分页查询所有备忘录
/// </summary>
/// <param name="parameter"></param>
/// <returns></returns>
/// <exception cref="NotImplementedException"></exception>
public async Task<ApiResponse> GetPageListAllAsync(QueryParameter parameter)
{
try
{
var repository = _unitOfWork.GetRepository<Memo>();
var memo = await repository.GetPagedListAsync(predicate: x => string.IsNullOrWhiteSpace(parameter.Search) ? true : x.Title.Contains(parameter.Search),
pageIndex: parameter.PageIndex,
pageSize: parameter.PageSize,
orderBy: y => y.OrderByDescending(t => t.CreateDate));
if (memo != null)
{
return new ApiResponse(true, memo);
}
else
{
return new ApiResponse(false, "查询数据失败！");
}
}
catch (Exception ex)
{
return new ApiResponse(false, ex.Message);
}
}11、在ToDoController和MemoController中添加代码
[HttpGet]
public async Task<ApiResponse> GetAllPageListToDo([FromQuery] QueryParameter parameter)
{
return await toDoService.GetPageListAllAsync(parameter);
}
[HttpGet]
public async Task<ApiResponse> GetAllPageListMemo([FromQuery] QueryParameter parameter)
{
return await memoService.GetPageListAllAsync(parameter);
}12、F5运行项目
![java八股文面试[多线程]——Synchronized的底层实现原理](https://img-blog.csdnimg.cn/ca21a0072cf44e23a5c218f32cd972c6.png)
