You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
300 lines
12 KiB
300 lines
12 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Data;
|
|
using QMFrameWork.Data;
|
|
using QMFrameWork.Data.Attributes;
|
|
using QMAPP.Entity.Sys;
|
|
using System.Reflection;
|
|
|
|
namespace QMAPP.DAL.Sys
|
|
{
|
|
/// <summary>
|
|
/// 数据变更痕迹管理
|
|
/// 创建者：李炳海
|
|
/// 创建日期：2013.3.10
|
|
/// </summary>
|
|
public class DataChangeManageDAL
|
|
{
|
|
/// <summary>
|
|
/// 数据会话
|
|
/// </summary>
|
|
public IDataSession Session { get; set; }
|
|
|
|
#region 获取数据变更列表
|
|
|
|
/// <summary>
|
|
/// 获取数据变更列表
|
|
/// </summary>
|
|
/// <param name="condition">查询条件</param>
|
|
/// <param name="page">分页设置</param>
|
|
/// <returns>数据页</returns>
|
|
public DataPage GetList(DataMark condition, DataPage page)
|
|
{
|
|
string sql = null;
|
|
List<DataParameter> parameters = new List<DataParameter>();
|
|
try
|
|
{
|
|
//获取查询语句
|
|
//sql = this.GetQuerySqlByOracle(condition, ref parameters);
|
|
sql = this.GetQuerySqlBySqlServer(condition, ref parameters);
|
|
|
|
//分页关键字段及排序
|
|
page.KeyName = "USERID";
|
|
if (string.IsNullOrEmpty(page.SortExpression))
|
|
{
|
|
page.SortExpression = "OPERATETIME DESC";
|
|
}
|
|
|
|
using (IDataSession session = AppDataFactory.CreateMainSession())
|
|
{
|
|
|
|
page = session.GetDataPage<DataMark>(sql, parameters.ToArray(), page);
|
|
}
|
|
|
|
return page;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 获取查询条件
|
|
|
|
/// <summary>
|
|
/// 获取查询语句
|
|
/// </summary>
|
|
/// <param name="user">查询条件</param>
|
|
/// <param name="parameters">参数</param>
|
|
/// <returns>查询语句</returns>
|
|
private string GetQuerySqlByOracle(DataMark condition, ref List<DataParameter> parameters)
|
|
{
|
|
StringBuilder sqlBuilder = new StringBuilder();
|
|
StringBuilder whereBuilder = new StringBuilder();
|
|
|
|
try
|
|
{
|
|
sqlBuilder.Append("SELECT T1.MARKID,T1.OPERATETIME,T2.USERNAME AS OPERATEUSER,T1.OPERATETYPE,T3.COMMENTS AS DATAKIND ");
|
|
sqlBuilder.Append("FROM T_BD_DATAMARK T1 ");
|
|
sqlBuilder.Append("LEFT JOIN T_QM_USER T2 ON T1.OPERATEUSER=T2.USERID ");
|
|
sqlBuilder.Append("LEFT JOIN ALL_TAB_COMMENTS T3 ON T3.OWNER='KANBAN' AND T1.DATAKIND=T3.TABLE_NAME ");
|
|
|
|
if (string.IsNullOrEmpty(condition.STARTOPERATETIME)==false)
|
|
{
|
|
whereBuilder.Append(" AND T1.OPERATETIME >= :DATE1");
|
|
parameters.Add(new DataParameter("DATE1", DateTime.Parse(condition.STARTOPERATETIME)));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.ENDOPERATETIME)==false)
|
|
{
|
|
whereBuilder.Append(" AND T1.OPERATETIME <= :DATE2");
|
|
parameters.Add(new DataParameter("DATE2", DateTime.Parse(condition.ENDOPERATETIME).AddDays(1).AddSeconds(-1)));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.OPERATEUSER) == false)
|
|
{
|
|
whereBuilder.Append(" AND (T2.USERNAME LIKE :OPERATEUSER OR T2.LOGINUSERID LIKE :OPERATEUSER)");
|
|
parameters.Add(new DataParameter("OPERATEUSER", "%" + condition.OPERATEUSER + "%"));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.DATAKIND) == false)
|
|
{
|
|
whereBuilder.Append(" AND T1.DATAKIND=:DATAKIND");
|
|
parameters.Add(new DataParameter("DATAKIND", condition.DATAKIND));
|
|
}
|
|
|
|
if (whereBuilder.Length > 0)
|
|
{
|
|
sqlBuilder.Append(" WHERE " + whereBuilder.ToString().Substring(4));
|
|
}
|
|
|
|
return sqlBuilder.ToString();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取查询语句
|
|
/// </summary>
|
|
/// <param name="user">查询条件</param>
|
|
/// <param name="parameters">参数</param>
|
|
/// <returns>查询语句</returns>
|
|
private string GetQuerySqlBySqlServer(DataMark condition, ref List<DataParameter> parameters)
|
|
{
|
|
StringBuilder sqlBuilder = new StringBuilder();
|
|
StringBuilder whereBuilder = new StringBuilder();
|
|
|
|
try
|
|
{
|
|
sqlBuilder.Append("SELECT T1.MARKID,T1.OPERATETIME,T2.USERNAME AS OPERATEUSER,T1.OPERATETYPE ");
|
|
sqlBuilder.Append(@",(SELECT VALUE
|
|
FROM SYS.EXTENDED_PROPERTIES WHERE
|
|
MAJOR_ID=Object_Id(T1.DATAKIND) AND MINOR_ID = 0 ) AS DATAKIND ");
|
|
sqlBuilder.Append("FROM T_BD_DATAMARK T1 ");
|
|
sqlBuilder.Append("LEFT JOIN T_QM_USER T2 ON T1.OPERATEUSER=T2.USERID ");
|
|
|
|
if (string.IsNullOrEmpty(condition.STARTOPERATETIME) == false)
|
|
{
|
|
whereBuilder.Append(" AND T1.OPERATETIME >= @DATE1");
|
|
parameters.Add(new DataParameter("DATE1", DateTime.Parse(condition.STARTOPERATETIME)));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.ENDOPERATETIME) == false)
|
|
{
|
|
whereBuilder.Append(" AND T1.OPERATETIME <= @DATE2");
|
|
parameters.Add(new DataParameter("DATE2", DateTime.Parse(condition.ENDOPERATETIME).AddDays(1).AddSeconds(-1)));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.OPERATEUSER) == false)
|
|
{
|
|
whereBuilder.Append(" AND (T2.USERNAME LIKE @OPERATEUSER OR T2.LOGINUSERID LIKE @OPERATEUSER)");
|
|
parameters.Add(new DataParameter("OPERATEUSER", "%" + condition.OPERATEUSER + "%"));
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(condition.DATAKIND) == false)
|
|
{
|
|
whereBuilder.Append(" AND T1.DATAKIND = @DATAKIND");
|
|
parameters.Add(new DataParameter("DATAKIND", condition.DATAKIND));
|
|
}
|
|
|
|
if (whereBuilder.Length > 0)
|
|
{
|
|
sqlBuilder.Append(" WHERE " + whereBuilder.ToString().Substring(4));
|
|
}
|
|
|
|
return sqlBuilder.ToString();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 记录数据变更新信息
|
|
|
|
/// <summary>
|
|
/// 记录数据变更新信息
|
|
/// </summary>
|
|
/// <typeparam name="T">数据类型</typeparam>
|
|
/// <param name="oprType">操作类型</param>
|
|
/// <param name="OperateUser">操作者</param>
|
|
/// <param name="oldInfo">原数据</param>
|
|
/// <param name="newInfo">新数据</param>
|
|
public void RecordDataChangeMark<T>(DataOprType oprType,string OperateUser,T oldInfo,T newInfo) where T:new()
|
|
{
|
|
string tableName = "";
|
|
DataMark mark = new DataMark();
|
|
try
|
|
{
|
|
Type type = typeof(T);
|
|
|
|
//获取表名
|
|
object[] attrsClassAtt = type.GetCustomAttributes(typeof(DBTableAttribute), true);
|
|
DBTableAttribute tableAtt = (DBTableAttribute)attrsClassAtt[0];
|
|
tableName = tableAtt.TableName;
|
|
|
|
//创建痕迹信息
|
|
mark.MARKID = Guid.NewGuid().ToString();
|
|
mark.OPERATEUSER = OperateUser;
|
|
mark.DATAKIND = tableName;
|
|
mark.OPERATETIME = DateTime.Now;
|
|
mark.OPERATETYPE = oprType.ToString();
|
|
mark.DATAID = "";
|
|
|
|
mark.ORIGINALDATA = QMFrameWork.Common.Serialization.JsonConvertHelper.GetSerializes(oldInfo);
|
|
|
|
if (oprType == DataOprType.Update||oprType==DataOprType.Insert)
|
|
{
|
|
mark.CHANGEDDATA = QMFrameWork.Common.Serialization.JsonConvertHelper.GetSerializes(newInfo);
|
|
}
|
|
|
|
//保存痕迹信息
|
|
Session.Insert<DataMark>(mark);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 获取数据变更痕迹数据
|
|
|
|
/// <summary>
|
|
/// 获取数据变更痕迹数据
|
|
/// </summary>
|
|
/// <param name="info">变更痕迹</param>
|
|
/// <returns>变更痕迹</returns>
|
|
public DataMark GetInfo(DataMark info,ref DataTable columnDt)
|
|
{
|
|
StringBuilder sqlBuilder = new StringBuilder();
|
|
List<DataParameter> parameters = new List<DataParameter>();
|
|
try
|
|
{
|
|
//using (IDataSession session = AppDataFactory.CreateMainSession())
|
|
//{
|
|
// sqlBuilder.Append("SELECT T1.MARKID,T1.OPERATETIME,T2.USERDES AS OPERATEUSER,T1.OPERATETYPE,T1.DATAKIND,T3.COMMENTS AS DATAKINDDES,T1.OriginalData,T1.ChangedData ");
|
|
// sqlBuilder.Append("FROM T_BD_DATAMARK T1 ");
|
|
// sqlBuilder.Append("left JOIN T_QM_USER T2 ON t1.OPERATEUSER=T2.USERID ");
|
|
// sqlBuilder.Append("left JOIN ALL_TAB_COMMENTS T3 ON T3.OWNER='PLP' AND T1.DATAKIND=T3.TABLE_NAME ");
|
|
// sqlBuilder.Append("WHERE T1.MARKID=:MARKID");
|
|
// //获取变更痕迹信息
|
|
// info = session.Get<DataMark>(sqlBuilder.ToString(), new DataParameter("MARKID", info.MARKID));
|
|
|
|
// //获取字段描述信息
|
|
// if (columnDt != null)
|
|
// {
|
|
// sqlBuilder.Clear();
|
|
// sqlBuilder.Append("SELECT T1.COLUMN_NAME AS COLUMNNAME, T1.COMMENTS AS COLUMNDES ");
|
|
// sqlBuilder.Append("FROM USER_COL_COMMENTS T1, ALL_TAB_COMMENTS T2 ");
|
|
// sqlBuilder.Append("WHERE T1.TABLE_NAME = T2.TABLE_NAME AND T1.TABLE_NAME = :TABLENAME");
|
|
// parameters.Add(new DataParameter("TABLENAME", info.DATAKIND));
|
|
|
|
// session.FillTable(columnDt, sqlBuilder.ToString(), parameters.ToArray());
|
|
// }
|
|
//}
|
|
|
|
using (IDataSession session = AppDataFactory.CreateMainSession())
|
|
{
|
|
sqlBuilder.Append("SELECT T1.MARKID,T1.OPERATETIME,T2.USERNAME AS OPERATEUSER,T1.OPERATETYPE,T1.DATAKIND,T1.ORIGINALDATA,T1.CHANGEDDATA ");
|
|
sqlBuilder.Append("FROM T_BD_DATAMARK T1 ");
|
|
sqlBuilder.Append("left JOIN T_QM_USER T2 ON t1.OPERATEUSER=T2.USERID ");
|
|
sqlBuilder.Append("WHERE T1.MARKID=@MARKID");
|
|
//获取变更痕迹信息
|
|
info = session.Get<DataMark>(sqlBuilder.ToString(), new DataParameter("MARKID", info.MARKID));
|
|
|
|
//获取字段描述信息
|
|
if (columnDt != null)
|
|
{
|
|
string sql = @"SELECT sys.columns.name as COLUMNNAME,(SELECT value FROM sys.extended_properties WHERE sys.extended_properties.major_id = sys.columns.object_id AND sys.extended_properties.minor_id = sys.columns.column_id) AS COLUMNDES
|
|
FROM sys.columns, sys.tables, sys.types
|
|
WHERE sys.columns.object_id = sys.tables.object_id
|
|
AND sys.columns.system_type_id=sys.types.system_type_id
|
|
AND sys.tables.name=@TABLENAME
|
|
AND sys.types.name<>'sysname' ORDER BY sys.columns.column_id";
|
|
parameters.Add(new DataParameter("TABLENAME", info.DATAKIND));
|
|
|
|
session.FillTable(columnDt, sql, parameters.ToArray());
|
|
}
|
|
}
|
|
return info;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
}
|
|
}
|
|
|