#region

using System;
using System.Data;
using CSFrameworkV5.Common;
using CSFrameworkV5.Core;
using CSFrameworkV5.DataAccess;
using CSFrameworkV5.Interfaces;
using CSFrameworkV5.Models;
using CSFrameworkV5.WebRef.CommonService;

#endregion

namespace CSFrameworkV5.Business
{
    /// <summary>
    ///     修改数据历史记录日志-修改数据日志
    /// </summary>
    public class LogEditHistory
    {
        private static IBridge_EditLogHistory _MyBridge;

        /// <summary>
        ///     静态构造器
        /// </summary>
        static LogEditHistory()
        {
            if (BridgeFactory.IsADODirect)
                _MyBridge = new dalEditLogHistory(Loginer.CurrentUser);

            if (BridgeFactory.IsWCFBridge) _MyBridge = new WCF_EditLogHistory();

            if (_MyBridge == null)
                throw new CustomException(BridgeFactory.UNKNOW_BRIDGE_TYPE);
        }

        /// <summary>
        ///     比较新/旧数据,有变动数据自动生成对应的日志.
        /// </summary>
        /// <param name="originalData">当前数据表</param>
        /// <param name="tracedFields">当前数据表的日志配置字段</param>
        /// <param name="keyFieldName">当前数据表的主键字段名</param>
        /// <returns></returns>
        private static DataSet DoCompareTable(DataTable originalData,
            string[] tracedFields, string summaryTableName,
            string keyFieldName)
        {
            //取表结构,sys_Log, sys_LogDtl
            var ds = _MyBridge.SearchLog("-", "-", "", DateTime.MinValue,
                DateTime.MinValue);

            object A;
            object B;
            string T1;
            string T2;
            var logID = Guid.NewGuid().ToStringEx().Replace("-", "").ToLower();

            #region 循环原始数据比较修改后的数据

            foreach (DataRow row in originalData.Rows)
            {
                if (row.RowState == DataRowState.Deleted) continue; //已经删除,不写入日志

                if (row.RowState == DataRowState.Added) continue; //新增记录,不写入日志

                //生成主表数据
                var R = ds.Tables[sys_Log.__TableName].Rows.Add();
                R[sys_Log.GUID32] = logID;
                R[sys_Log.LogDate] = DateTime.Now;
                R[sys_Log.LogUser] = Loginer.CurrentUser.AccountName; //当前登录用户
                R[sys_Log.OPType] = LogDataType.LogEdit; //新增或修改
                R[sys_Log.TableName] = summaryTableName;
                R[sys_Log.DocNo] = ConvertEx.ToString(row[keyFieldName]);
                R[sys_Log.MACD] = NetTools.GetLocalMac(); //获取MAC地址

                //生成明细表数据
                foreach (var fieldName in tracedFields)
                {
                    if (originalData.Columns[fieldName] == null) continue;

                    A = row[fieldName, DataRowVersion.Original]; //旧值
                    B = row[fieldName, DataRowVersion.Current]; //新值

                    if (originalData.Columns[fieldName].DataType ==
                        typeof(DateTime))
                    {
                        T1 = A == DBNull.Value
                            ? ""
                            : ConvertEx.ToDateTimeEx(A)
                                .ToString("yyyy-MM-dd HH:mm:ss");
                        T2 = B == DBNull.Value
                            ? ""
                            : ConvertEx.ToDateTimeEx(B)
                                .ToString("yyyy-MM-dd HH:mm:ss");
                    }
                    else
                    {
                        T1 = ConvertEx.ToString(A); //旧值
                        T2 = ConvertEx.ToString(B); //新值
                    }

                    if (T1 != T2)
                    {
                        var R1 = ds.Tables[sys_LogDtl.__TableName].Rows.Add();
                        R1[sys_LogDtl.GUID32] = logID;
                        R1[sys_LogDtl.TableName] = originalData.TableName;
                        R1[sys_LogDtl.FieldName] = fieldName;
                        R1[sys_LogDtl.OldValue] = ConvertEx.StrLeft(T1, 250);
                        R1[sys_LogDtl.NewValue] = ConvertEx.StrLeft(T2, 250);
                    }
                }
            }

            #endregion

            if (ds.Tables[sys_LogDtl.__TableName].Rows.Count > 0) return ds;

            return null;
        }

        /// <summary>
        ///     获取指定表跟踪的字段列表
        /// </summary>
        /// <param name="tableName">表名</param>
        public static DataTable GetLogFieldDef(string tableName)
        {
            return _MyBridge.GetLogFieldDef(tableName);
        }

        /// <summary>
        ///     获取指定表跟踪的字段列表
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns></returns>
        public static 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;
        }

        /// <summary>
        ///     保存需要生成日志的字段数据
        /// </summary>
        public static bool SaveFieldDef(DataTable data)
        {
            return _MyBridge.SaveFieldDef(data);
        }

        /// <summary>
        ///     搜索系统日志数据
        /// </summary>
        /// <param name="logUser">用户</param>
        /// <param name="tableName">数据表名</param>
        /// <param name="dateFrom">日志日期：由</param>
        /// <param name="dateTo">日志日期：至</param>
        /// <returns></returns>
        public static DataSet SearchLog(string logUser, string tableName,
            string keyValue, DateTime dateFrom,
            DateTime dateTo)
        {
            return _MyBridge.SearchLog(logUser, tableName, keyValue, dateFrom,
                dateTo);
        }

        /// <summary>
        ///     保存资料表修改日志
        /// </summary>
        /// <param name="originalData">当前数据表</param>
        /// <param name="keyFieldName">当前数据表的主键字段名</param>
        public static bool WriteLog(DataTable originalData,
            string summaryTableName, string keyFieldName)
        {
            try
            {
                var result = false;
                var tracedFields = GetTracedFields(originalData.TableName);
                if (tracedFields.Length > 0)
                {
                    var data = DoCompareTable(originalData, tracedFields,
                        summaryTableName, keyFieldName);
                    if (data != null && data.Tables.Count > 0)
                        result = _MyBridge.SaveLog(data);
                }

                return result;
            }
            catch
            {
                return false;
            }
        }

        /// <summary>
        ///     保存资料表修改日志
        /// </summary>
        /// <param name="originalData">当前数据表</param>
        /// <param name="keyFieldName">当前数据表的主键字段名</param>
        /// <returns></returns>
        public static bool WriteLog(DataSet originalData,
            string summaryTableName, string keyFieldName)
        {
            foreach (DataTable dt in originalData.Tables)
                WriteLog(dt, summaryTableName, keyFieldName);

            return true;
        }
    }
}