#region

using System;
using System.Data;
using CSFrameworkV5.Business.BLL_Permission;
using CSFrameworkV5.CodeGeneratorCore;
using CSFrameworkV5.Core;
using CSFrameworkV5.Models;
using ConvertEx = CSFrameworkV5.Common.ConvertEx;
using DataConverter = CSFrameworkV5.Common.DataConverter;
using Globals = CSFrameworkV5.Common.Globals;

#endregion

namespace CSFrameworkV5.Business
{
    ///*************************************************************************/
    ///*
    ///* 文件名    ：DataDictCache.cs      
    ///
    ///* 程序说明  : 数据字典缓存数据
    ///               
    ///* 原创作者  ：www.csframework.com 
    ///* Copyright 2010-2012  
    ///*
    ///**************************************************************************/
    /*
     数据字典缓存数据,如系统数据,公共数据,或Lookup组件数据源.
     */
    public class DataDictCache : IDataCacheBase
    {
        protected DataSet _CachedTables;

        /*私有构造器,不允许外部创建实例*/
        protected DataDictCache()
        {
            _CachedTables = new DataSet();
            DataCacheMgr.Instance.AddCache(this); //托管
        }

        public DataTable CustomerAttributes
        {
            get
            {
                var dt = FindFromCache("tb_CustomerAttribute");
                if (dt == null)
                {
                    dt = CommonData.GetDataDict("tb_CustomerAttribute");
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        public DataTable DataSet
        {
            get
            {
                var dt = FindFromCache(tb_DataSet.__TableName);
                if (dt == null)
                {
                    dt = CommonData.GetSystemDataSet();
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        public DataTable LanguageType
        {
            get
            {
                var dt = FindFromCache("sys_LanguageType");
                if (dt == null)
                {
                    dt = new bllLanguage().GetTypeData();
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        /// <summary>
        ///     系统单据列表
        /// </summary>
        [CG_LookupDataSourceAttribute("单据名称表")]
        public DataTable sys_DocName
        {
            get
            {
                var dt = FindFromCache("sys_DocName");
                if (dt == null)
                {
                    dt = CommonData.GetDataDict("sys_DocName");
                    dt.TableName = "sys_DocName";
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        #region Cache - 缓存管理器唯一实例

        private static DataDictCache _Cache;

        /// <summary>
        ///     缓存数据唯一实例
        /// </summary>
        public static DataDictCache Cache
        {
            get
            {
                if (_Cache == null) _Cache = new DataDictCache();

                return _Cache;
            }
        }

        #endregion

        #region RefreshCache - 外部使用的静态方法

        /// <summary>
        ///     刷新缓存数据,清空缓存表.在使用某项数据时从数据库取数. 清空缓存数据及缓存的数据集
        /// </summary>
        public void RefreshCache()
        {
            _CachedTables.Tables.Clear();
            GC.Collect();
        }

        /// <summary>
        ///     刷新单个数据字典
        /// </summary>
        /// <param name="tableName">字典表名</param>
        public static void RefreshCache(string tableName,
            DataDictCache cacheInstance = null)
        {
            if (cacheInstance == null) cacheInstance = Cache;

            var cache = cacheInstance.FindFromCache(tableName);
            if (cache != null) //有客户窗体引用缓存数据时才更新
            {
                var data = CommonData.GetDataDict(tableName);
                if (data != null)
                {
                    cache.Rows.Clear();
                    foreach (DataRow row in data.Rows) cache.ImportRow(row);

                    cache.AcceptChanges();
                }
            }
        }

        #endregion

        #region 1.系统数据库的缓存数据

        [CG_LookupDataSourceAttribute("业务单据表")]
        public DataTable BusinessTables
        {
            get
            {
                var dt = FindFromCache("SysBusinessTables");
                if (dt == null)
                {
                    dt = CommonData.GetDataDict(Globals.DEF_SYSTEM_DBID,
                        sys_BusinessTables.__TableName);
                    dt.TableName = "SysBusinessTables";
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        [CG_LookupDataSourceAttribute("用户资料")]
        public DataTable User
        {
            get
            {
                var dt = FindFromCache(tb_MyUser.__TableName);
                if (dt == null)
                {
                    dt = new bllUser().GetLookupData();
                    AddLookupText(dt, tb_MyUser.Account, tb_MyUser.UserName,
                        CommonFields.LookupDisplayText);
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        [CG_LookupDataSourceAttribute("组织机构(用户组)数据")]
        public DataTable UserGroup
        {
            get
            {
                var dt = FindFromCache(tb_MyGroup.__TableName);
                if (dt == null)
                {
                    dt = new bllGroup().GetLookupData();
                    AddToCache(dt.Copy());
                }

                return dt;
            }
        }

        #endregion

        #region 方法

        /// <summary>
        ///     加到缓存的数据集
        /// </summary>
        /// <param name="dt"></param>
        public void AddToCache(DataTable dt)
        {
            _CachedTables.Tables.Add(dt);
        }

        /// <summary>
        ///     查找缓存表
        /// </summary>
        /// <param name="tableName">指定表名</param>
        /// <returns></returns>
        public DataTable FindFromCache(string tableName)
        {
            return _CachedTables.Tables[tableName];
        }

        /// <summary>
        ///     同步新增或修改缓存数据某一条记录
        /// </summary>
        /// <param name="newlyRow">最新资料</param>
        /// <param name="type">操作类型(新增/修改)</param>
        /// <param name="tableName">字典表名</param>
        /// <param name="keyField">主键</param>
        public void SyncAddOrUpdateCache(DataRow newlyRow, UpdateType type,
            string tableName, string keyField)
        {
            if (type == UpdateType.Add) //同步新增
            {
                var cache = FindFromCache(tableName);
                if (cache != null)
                {
                    var newRow = cache.NewRow(); //缓存数据新增一条记录
                    DataConverter.ReplaceDataRowChanges(newlyRow,
                        newRow); //替换数据
                    cache.Rows.Add(newRow);
                    cache.AcceptChanges();
                }
            }
            else if (type == UpdateType.Modify) //同步修改
            {
                var cache = FindFromCache(tableName);
                if (cache != null)
                {
                    var key = ConvertEx.ToString(newlyRow[keyField]);
                    var rows =
                        cache.Select(keyField + "='" + key + "'"); //找到缓存数据的记录
                    if (rows.Length > 0)
                    {
                        DataConverter.ReplaceDataRowChanges(newlyRow,
                            rows[0]); //替换数据
                        cache.AcceptChanges();
                    }
                }
            }
        }

        /// <summary>
        ///     同步新增一条记录到缓存数据
        /// </summary>
        /// <param name="tableName">字典表名</param>
        /// <param name="keyField">主键</param>
        /// <param name="key">主键值</param>
        /// <param name="newlyRow">最新资料</param>
        public void SyncAddCacheRow(string tableName, string keyField,
            string key, DataRow newlyRow)
        {
            var cache = FindFromCache(tableName);
            if (cache != null)
            {
                var newRow = cache.NewRow(); //缓存数据新增一条记录
                DataConverter.ReplaceDataRowChanges(newlyRow, newRow); //替换数据
                cache.Rows.Add(newRow);
            }

            cache.AcceptChanges();
        }

        /// <summary>
        ///     同步删除缓存数据某一条记录
        /// </summary>
        /// <param name="tableName">字典表名</param>
        /// <param name="keyField">主键</param>
        /// <param name="key">主键值</param>
        public void SyncDeleteCacheRow(string tableName, string keyField,
            string key)
        {
            var cache = FindFromCache(tableName);
            if (cache != null)
            {
                var rows =
                    cache.Select(keyField + "='" + key + "'"); //找到缓存数据的记录
                if (rows.Length > 0) cache.Rows.Remove(rows[0]);

                cache.AcceptChanges();
            }
        }

        /// <summary>
        ///     同步更新缓存数据某一条记录
        /// </summary>
        /// <param name="tableName">字典表名</param>
        /// <param name="keyField">主键</param>
        /// <param name="key">主键值</param>
        /// <param name="newlyRow">最新资料</param>
        public void SyncUpdateCacheRow(string tableName, string keyField,
            string key, DataRow newlyRow)
        {
            var cache = FindFromCache(tableName);
            if (cache != null)
            {
                var rows =
                    cache.Select(keyField + "='" + key + "'"); //找到缓存数据的记录
                if (rows.Length > 0)
                {
                    DataConverter.ReplaceDataRowChanges(newlyRow,
                        rows[0]); //替换数据
                    cache.AcceptChanges();
                }
            }
        }

        /// <summary>
        ///     存在某项值
        /// </summary>
        /// <param name="cache">资料表</param>
        /// <param name="fieldName">字段名</param>
        /// <param name="value">值</param>
        /// <returns></returns>
        public static bool IsExists(DataTable cache, string fieldName,
            string value)
        {
            var rows = cache.Select(fieldName + "='" + value + "'");
            return rows.Length > 0;
        }

        /// <summary>
        ///     取值
        /// </summary>
        /// <param name="cache">资料表</param>
        /// <param name="keyFieldName">主键</param>
        /// <param name="returnField">返回指定字段的值</param>
        /// <param name="value">对应主键的值</param>
        /// <returns></returns>
        public static string GetValue(DataTable cache, string keyFieldName,
            string returnField, string value)
        {
            var rows = cache.Select(keyFieldName + "='" + value + "'");
            if (rows.Length > 0)
                return ConvertEx.ToString(rows[0][returnField]);

            return "";
        }

        /// <summary>
        ///     增加一个Lookup组件显示文本用的字段。
        /// </summary>
        /// <param name="data">资料表</param>
        /// <param name="codeField">编号字段名</param>
        /// <param name="nameField">名称字段名</param>
        /// <param name="lookupField">Lookup显示文本来源字段</param>
        public void AddLookupText(DataTable data, string codeField,
            string nameField, string displayField)
        {
            //显示内容：Code - Name
            if (data.Columns[displayField] == null)
                data.Columns.Add(displayField, typeof(string));

            foreach (DataRow row in data.Rows)
                row[displayField] = ConvertEx.ToString(row[codeField]) + " - "
                    + ConvertEx.ToString(row[nameField]);

            data.AcceptChanges();
        }

        #endregion
    }
}