92 lines
3.2 KiB
C#
92 lines
3.2 KiB
C#
using Infrastructure.Attribute;
|
|
using Infrastructure.Extensions;
|
|
using SqlSugar;
|
|
using System;
|
|
using ZR.Model;
|
|
using ZR.Model.System;
|
|
using ZR.Repository;
|
|
using ZR.Service.System.IService;
|
|
using ZR.ServiceCore.Model;
|
|
using ZR.ServiceCore.Model.Dto;
|
|
|
|
namespace ZR.Service.System
|
|
{
|
|
/// <summary>
|
|
/// 数据差异日志Service业务层处理
|
|
/// </summary>
|
|
[AppService(ServiceType = typeof(ISqlDiffLogService), ServiceLifetime = LifeTime.Transient)]
|
|
public class SqlDiffLogService : BaseService<SqlDiffLog>, ISqlDiffLogService
|
|
{
|
|
/// <summary>
|
|
/// 查询数据差异日志列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<SqlDiffLogDto> GetList(SqlDiffLogQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<SqlDiffLog>();
|
|
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.TableName), it => it.TableName == parm.TableName);
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.DiffType), it => it.DiffType == parm.DiffType);
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.UserName), it => it.UserName == parm.UserName);
|
|
predicate = predicate.AndIF(parm.BeginAddTime == null, it => it.AddTime >= DateTime.Now.ToShortDateString().ParseToDateTime());
|
|
predicate = predicate.AndIF(parm.BeginAddTime != null, it => it.AddTime >= parm.BeginAddTime);
|
|
predicate = predicate.AndIF(parm.EndAddTime != null, it => it.AddTime <= parm.EndAddTime);
|
|
var response = Queryable()
|
|
//.OrderBy("PId desc")
|
|
.Where(predicate.ToExpression())
|
|
.ToPage<SqlDiffLog, SqlDiffLogDto>(parm);
|
|
|
|
return response;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 获取详情
|
|
/// </summary>
|
|
/// <param name="PId"></param>
|
|
/// <returns></returns>
|
|
public SqlDiffLog GetInfo(long PId)
|
|
{
|
|
var response = Queryable()
|
|
.Where(x => x.PId == PId)
|
|
.First();
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 添加数据差异日志
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public SqlDiffLog AddSqlDiffLog(SqlDiffLog model)
|
|
{
|
|
return Context.Insertable(model).ExecuteReturnEntity();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改数据差异日志
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public int UpdateSqlDiffLog(SqlDiffLog model)
|
|
{
|
|
//var response = Update(w => w.PId == model.PId, it => new SqlDiffLog()
|
|
//{
|
|
// TableName = model.TableName,
|
|
// BusinessData = model.BusinessData,
|
|
// DiffType = model.DiffType,
|
|
// Sql = model.Sql,
|
|
// BeforeData = model.BeforeData,
|
|
// AfterData = model.AfterData,
|
|
// UserName = model.UserName,
|
|
// AddTime = model.AddTime,
|
|
// ConfigId = model.ConfigId,
|
|
//});
|
|
//return response;
|
|
return Update(model, true);
|
|
}
|
|
|
|
}
|
|
} |