#region
|
|
using System;
|
using System.Data;
|
using CSFrameworkV5.Common;
|
using CSFrameworkV5.Core;
|
using CSFrameworkV5.Core.CodeGenerator;
|
using CSFrameworkV5.Interfaces;
|
using CSFrameworkV5.Models;
|
|
///*************************************************************************/
|
///*
|
///* 文件名 ：SystemLog.cs
|
///* 程序说明 : 系统日志业务逻辑
|
///* 原创作者 ：www.csframework.com
|
///*
|
///* Copyright 2006-2021 C/S框架网 www.csframework.com
|
///*
|
///**************************************************************************/
|
|
#endregion
|
|
namespace CSFrameworkV5.DataAccess
|
{
|
/// <summary>
|
/// 修改历史记录的数据层
|
/// </summary>
|
[DefaultORM_UpdateMode(typeof(sys_LogFields), true)]
|
public class dalEditLogHistory : dalBaseDataDict, IBridge_EditLogHistory
|
{
|
/// <summary>
|
/// 构造器
|
/// </summary>
|
/// <param name="loginer">当前登录用户</param>
|
public dalEditLogHistory(Loginer loginer) : base(loginer)
|
{
|
_KeyName = sys_LogFields.__KeyName; //主键字段
|
_TableName = sys_LogFields.__TableName; //表名
|
_ModelType = typeof(sys_LogFields); //指定ORM模型
|
_UpdateSummaryKeyMode = UpdateKeyMode.None;
|
}
|
|
/// <summary>
|
/// 获取跟踪的字段
|
/// </summary>
|
/// <param name="tableName">表名</param>
|
public DataTable GetLogFieldDef(string tableName)
|
{
|
var sql =
|
$"SELECT * FROM sys_LogFields WHERE TableName={_Database.ParamSymboName}TableName AND FlagLog={_Database.ParamSymboName}FlagLog;";
|
var cmd = _Database.CreateCommand(sql);
|
cmd.AddParam("TableName", tableName);
|
cmd.AddParam("FlagLog", "Y");
|
return _Database.GetTable(cmd.Command, sys_LogFields.__TableName);
|
}
|
|
/// <summary>
|
/// 获取指定表需要跟踪的字段列表
|
/// </summary>
|
/// <param name="tableName">数据表</param>
|
/// <returns></returns>
|
public string[] GetTracedFields(string tableName)
|
{
|
var tracedFields = GetLogFieldDef(tableName);
|
var fields = new string[tracedFields.Rows.Count];
|
for (var i = 0; i <= tracedFields.Rows.Count - 1; i++)
|
fields[i] = tracedFields.Rows[i]["FieldName"].ToStringEx();
|
|
return fields;
|
}
|
|
[Obsolete]
|
public bool SaveFieldDef(DataTable data)
|
{
|
var ds = new DataSet();
|
ds.Tables.Add(data);
|
return Update(ds);
|
}
|
|
public bool SaveLog(DataSet dsLogData)
|
{
|
return base.Update(dsLogData);
|
}
|
|
/// <summary>
|
/// 搜索系统日志数据
|
/// </summary>
|
/// <param name="logUser">用户</param>
|
/// <param name="tableName">数据表名</param>
|
/// <param name="dateFrom">日志日期：由</param>
|
/// <param name="dateTo">日志日期：至</param>
|
/// <returns></returns>
|
public DataSet SearchLog(string logUser, string tableName,
|
string keyValue, DateTime dateFrom,
|
DateTime dateTo)
|
{
|
var cmd = _Database.CreateSqlProc("sp_sys_SearchLog");
|
cmd.AddParam("LogUser", DbType.String, logUser);
|
cmd.AddParam("TableName", DbType.String, tableName);
|
cmd.AddParam("KeyValue", DbType.String, keyValue);
|
cmd.AddParam("LogDateFrom", DbType.String,
|
ConvertEx.ToCharYYYYMMDD(dateFrom));
|
cmd.AddParam("LogDateTo", DbType.String,
|
ConvertEx.ToCharYYYYMMDD(dateTo));
|
var ds = _Database.GetDataSet(cmd.Command);
|
ds.Tables[0].TableName = sys_Log.__TableName;
|
ds.Tables[1].TableName = sys_LogDtl.__TableName;
|
return ds;
|
}
|
|
/// <summary>
|
/// 根据表名获取该表的SQL命令生成器
|
/// </summary>
|
/// <param name="tableName">表名</param>
|
/// <returns></returns>
|
protected override IGenerateSqlCommand CreateSqlGenerator(
|
DataTable table)
|
{
|
Type ORM = null;
|
if (table.TableName == sys_LogFields.__TableName)
|
ORM = typeof(sys_LogFields);
|
|
if (table.TableName == sys_Log.__TableName) ORM = typeof(sys_Log);
|
|
if (table.TableName == sys_LogDtl.__TableName)
|
ORM = typeof(sys_LogDtl);
|
|
if (ORM == null) throw new Exception(table.TableName + "表没有ORM模型！");
|
|
return new GenerateSqlCmdByTableFields(ORM, table,
|
GeneratorFactory);
|
}
|
}
|
}
|
