using System.Diagnostics;
using AutoMapper;
using DMS.Core.Enums;
using DMS.Core.Interfaces.Repositories;
using DMS.Core.Models;
using DMS.Infrastructure.Data;
using DMS.Infrastructure.Entities;
using Microsoft.Extensions.Logging;
namespace DMS.Infrastructure.Repositories;
///
/// 菜单仓储实现类,负责菜单数据的持久化操作。
/// 继承自 并实现 接口。
///
public class MenuRepository : BaseRepository, IMenuRepository
{
private readonly IMapper _mapper;
///
/// 构造函数,注入 AutoMapper 和 SqlSugarDbContext。
///
/// AutoMapper 实例,用于实体模型和数据库模型之间的映射。
/// SqlSugar 数据库上下文,用于数据库操作。
/// 日志记录器实例。
public MenuRepository(IMapper mapper, SqlSugarDbContext dbContext, ILogger logger)
: base(dbContext, logger)
{
_mapper = mapper;
}
///
/// 异步获取所有菜单树结构。
///
/// 包含所有菜单树结构的列表。
public async Task> GetMenuTreesAsync()
{
var stopwatch = new Stopwatch();
stopwatch.Start();
var dbMenuTree = await _dbContext.GetInstance().Queryable()
.ToTreeAsync(dm => dm.Childrens, dm => dm.ParentId, 0);
stopwatch.Stop();
_logger.LogInformation($"获取菜单树耗时:{stopwatch.ElapsedMilliseconds}ms");
return _mapper.Map>(dbMenuTree);
}
///
/// 异步根据ID获取单个菜单。
///
/// 菜单的唯一标识符。
/// 对应的菜单实体,如果不存在则为null。
public async Task GetByIdAsync(int id)
{
var dbMenu = await base.GetByIdAsync(id);
return _mapper.Map(dbMenu);
}
///
/// 异步获取所有菜单。
///
/// 包含所有菜单实体的列表。
public async Task> GetAllAsync()
{
var dbList = await base.GetAllAsync();
return _mapper.Map>(dbList);
}
///
/// 异步添加新菜单。
///
/// 要添加的菜单实体。
/// 添加成功后的菜单实体(包含数据库生成的ID等信息)。
public async Task AddAsync(MenuBean entity)
{
var dbMenu = await base.AddAsync(_mapper.Map(entity));
return _mapper.Map(dbMenu, entity);
}
///
/// 异步更新现有菜单。
///
/// 要更新的菜单实体。
/// 受影响的行数。
public async Task UpdateAsync(MenuBean entity) => await base.UpdateAsync(_mapper.Map(entity));
///
/// 异步删除菜单。
///
/// 要删除的菜单实体。
/// 受影响的行数。
public async Task DeleteAsync(MenuBean entity) => await base.DeleteAsync(_mapper.Map(entity));
///
/// 异步根据ID删除菜单。
///
/// 要删除菜单的唯一标识符。
/// 受影响的行数。
public async Task DeleteByIdAsync(int id)
{
var stopwatch = new Stopwatch();
stopwatch.Start();
var result = await _dbContext.GetInstance().Deleteable(new DbMenu { Id = id })
.ExecuteCommandAsync();
stopwatch.Stop();
_logger.LogInformation($"Delete {typeof(DbMenu)},ID={id},耗时:{stopwatch.ElapsedMilliseconds}ms");
return result;
}
///
/// 异步根据菜单ID删除菜单树(包括子菜单)。
///
/// 要删除菜单树的根菜单ID。
/// 受影响的行数。
public async Task DeleteMenuTreeByIdAsync(int id)
{
var stopwatch = new Stopwatch();
stopwatch.Start();
int delConut = 0;
var childList = await _dbContext.GetInstance().Queryable()
.ToChildListAsync(c => c.ParentId, id);
delConut = await _dbContext.GetInstance().Deleteable(childList)
.ExecuteCommandAsync();
delConut += await _dbContext.GetInstance().Deleteable()
.Where(m => m.Id == id)
.ExecuteCommandAsync();
stopwatch.Stop();
_logger.LogInformation($"Delete {typeof(DbMenu)},ID={id},耗时:{stopwatch.ElapsedMilliseconds}ms");
return delConut;
}
///
/// 异步根据菜单类型和目标ID删除菜单树。
///
/// 菜单类型。
/// 目标ID。
/// 受影响的行数。
public async Task DeleteMenuTreeByTargetIdAsync(MenuType menuType, int targetId)
{
var stopwatch = new Stopwatch();
stopwatch.Start();
var menu = await _dbContext.GetInstance().Queryable().FirstAsync(m => m.MenuType == menuType && m.TargetId == targetId);
if (menu == null) return 0;
var childList = await _dbContext.GetInstance().Queryable()
.ToChildListAsync(c => c.ParentId, menu.Id);
var delConut = await _dbContext.GetInstance().Deleteable(childList)
.ExecuteCommandAsync();
delConut += await _dbContext.GetInstance().Deleteable()
.Where(m => m.Id == menu.Id)
.ExecuteCommandAsync();
stopwatch.Stop();
_logger.LogInformation($"Delete {typeof(DbMenu)},TargetId={targetId},耗时:{stopwatch.ElapsedMilliseconds}ms");
return delConut;
}
///
/// 异步根据菜单类型和目标ID获取菜单。
///
/// 菜单类型。
/// 目标ID。
/// 对应的菜单实体,如果不存在则为null。
public async Task GetMenuByTargetIdAsync(MenuType menuType, int targetId)
{
var dbMenu = await _dbContext.GetInstance().Queryable().FirstAsync(m => m.MenuType == menuType && m.TargetId == targetId);
return _mapper.Map(dbMenu);
}
///
/// 异步获取指定数量的菜单。
///
/// 要获取的菜单数量。
/// 包含指定数量菜单实体的列表。
public new async Task> TakeAsync(int number)
{
var dbList = await base.TakeAsync(number);
return _mapper.Map>(dbList);
}
public async Task> AddBatchAsync(List entities)
{
var dbEntities = _mapper.Map>(entities);
var addedEntities = await base.AddBatchAsync(dbEntities);
return _mapper.Map>(addedEntities);
}
}