89 lines
3.2 KiB
C#
89 lines
3.2 KiB
C#
using Longbow.Web.Mvc;
|
|
using PetaPoco;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
|
|
namespace Bootstrap.DataAccess
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
[TableName("Logs")]
|
|
public class Log : Trace
|
|
{
|
|
/// <summary>
|
|
/// 获得/设置 操作类型
|
|
/// </summary>
|
|
public string CRUD { get; set; }
|
|
|
|
/// <summary>
|
|
/// 获得/设置 请求数据
|
|
/// </summary>
|
|
public string RequestData { get; set; }
|
|
|
|
/// <summary>
|
|
/// 查询所有操作日志信息
|
|
/// </summary>
|
|
/// <param name="po"></param>
|
|
/// <param name="startTime"></param>
|
|
/// <param name="endTime"></param>
|
|
/// <param name="opType"></param>
|
|
/// <returns></returns>
|
|
public virtual new Page<Log> RetrievePages(PaginationOption po, DateTime? startTime, DateTime? endTime, string opType)
|
|
{
|
|
var sql = new Sql("select CRUD, UserName, LogTime, Ip, Browser, OS, City, RequestUrl, RequestData from Logs");
|
|
if (startTime.HasValue) sql.Where("LogTime >= @0", startTime.Value);
|
|
if (endTime.HasValue) sql.Where("LogTime < @0", endTime.Value.AddDays(1).AddSeconds(-1));
|
|
if (startTime == null && endTime == null) sql.Where("LogTime > @0", DateTime.Today.AddMonths(0 - DictHelper.RetrieveExceptionsLogPeriod()));
|
|
if (!string.IsNullOrEmpty(opType)) sql.Where("CRUD = @0", opType);
|
|
sql.OrderBy($"{po.Sort} {po.Order}");
|
|
|
|
return DbManager.Create().Page<Log>(po.PageIndex, po.Limit, sql);
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="startTime"></param>
|
|
/// <param name="endTime"></param>
|
|
/// <param name="opType"></param>
|
|
/// <returns></returns>
|
|
public virtual new IEnumerable<Log> RetrieveAll(DateTime? startTime, DateTime? endTime, string opType)
|
|
{
|
|
var sql = new Sql("select CRUD, UserName, LogTime, Ip, Browser, OS, City, RequestUrl, RequestData from Logs");
|
|
if (startTime.HasValue) sql.Where("LogTime >= @0", startTime.Value);
|
|
if (endTime.HasValue) sql.Where("LogTime < @0", endTime.Value.AddDays(1).AddSeconds(-1));
|
|
if (!string.IsNullOrEmpty(opType)) sql.Where("CRUD = @0", opType);
|
|
sql.OrderBy("LogTime");
|
|
|
|
return DbManager.Create().Fetch<Log>(sql);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除日志信息
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private static void DeleteLogAsync()
|
|
{
|
|
System.Threading.Tasks.Task.Run(() =>
|
|
{
|
|
var dtm = DateTime.Now.AddMonths(0 - DictHelper.RetrieveLogsPeriod());
|
|
DbManager.Create().Execute("delete from Logs where LogTime < @0", dtm);
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// 保存新增的日志信息
|
|
/// </summary>
|
|
/// <param name="p"></param>
|
|
/// <returns></returns>
|
|
public virtual bool Save(Log p)
|
|
{
|
|
if (p == null) throw new ArgumentNullException(nameof(p));
|
|
DeleteLogAsync();
|
|
DbManager.Create().Save(p);
|
|
return true;
|
|
}
|
|
}
|
|
}
|