Security/Yuebon.Security.Services/SqlLogService.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Yuebon.Security.Services;

/// <summary>
/// SQL日志服务接口实现
/// </summary>
public class SqlLogService: BaseService<SqlLog, SqlLogOutputDto>, ISqlLogService
{
    public SqlLogService(IRepository<SqlLog> _repository)
    {
			repository=_repository;
    }


    public async void AddAsync(SqlLogInputDto entity)
    {
        await repository.InsertAsync(entity.MapTo<SqlLog>());
    }
    /// <summary>
    /// 根据条件查询数据库,并返回对象集合(用于分页数据显示)
    /// </summary>
    /// <param name="search">查询的条件</param>
    /// <returns>指定对象的集合</returns>
    public async Task<PageResult<SqlLogOutputDto>> FindWithPagerSearchAsync(SearchVisitLogModel search)
    {
        bool order = search.Order == "asc" ? false : true;
        string where = GetDataPrivilege(false);
        if (!string.IsNullOrEmpty(search.CreatorTime1))
        {
            where += " and CreatorTime >='" + search.CreatorTime1.ToDateTime() + "'";
        }
        if (!string.IsNullOrEmpty(search.CreatorTime2))
        {
            where += " and CreatorTime <='" + search.CreatorTime2.ToDateTime() + "'";
        }
        if (!string.IsNullOrEmpty(search.Filter.IPAddress))
        {
            where += string.Format(" and IPAddress = '{0}'", search.Filter.IPAddress);
        };
        if (!string.IsNullOrEmpty(search.Filter.Account))
        {
            where += string.Format(" and Account = '{0}'", search.Filter.Account);
        };
        PagerInfo pagerInfo = new PagerInfo
        {
            CurrenetPageIndex = search.CurrenetPageIndex,
            PageSize = search.PageSize
        };
        List<SqlLog> list = await repository.FindWithPagerAsync(where, pagerInfo, search.Sort, order);
        PageResult<SqlLogOutputDto> pageResult = new PageResult<SqlLogOutputDto>
        {
            CurrentPage = pagerInfo.CurrenetPageIndex,
            Items = list.MapTo<SqlLogOutputDto>(),
            ItemsPerPage = pagerInfo.PageSize,
            TotalItems = pagerInfo.RecordCount
        };
        return pageResult;
    }
}