using System;
using System.Collections;
using System.IO;
using System.Text;
using BP.En;
using BP.Pub;
using BP.Sys;
using BP.Web;
using BP.Difference;
using System.Collections.Generic;

namespace BP.DA
{

    /// <summary>
    /// Cache 的摘要说明。
    /// </summary>
    public class Cache
    {
        public static void ClearCache(string enName)
        {
            if (_BS_Cache != null)
            {
                if (_BS_Cache.ContainsKey(enName) == true)
                    _BS_Cache.Remove(enName);
            }

            if (_SQL_Cache != null)
            {
                if (_SQL_Cache.ContainsKey(enName) == true)
                    _SQL_Cache.Remove(enName);
            }


            if (_EnsData_Cache != null)
            {
                if (_EnsData_Cache.ContainsKey(enName) == true)
                    _EnsData_Cache.Remove(enName);
            }

            if (_Map_Cache != null)
            {
                if (_Map_Cache.ContainsKey(enName) == true)
                    _Map_Cache.Remove(enName);
            }

            if (_EnsData_Cache_Ext != null)
            {
                if (_EnsData_Cache_Ext.ContainsKey(enName) == true)
                    _EnsData_Cache_Ext.Remove(enName);
            }

            if (_Bill_Cache != null)
            {
                if (_Bill_Cache.ContainsKey(enName) == true)
                    _Bill_Cache.Remove(enName);
            }

            if (_Row_Cache != null)
            {
                if (_Row_Cache.ContainsKey(enName) == true)
                    _Row_Cache.Remove(enName);
            }

            //清除
          //  Cache2019.ClearCache();
        }
        /// <summary>
        /// 清空缓存.
        /// </summary>
        public static void ClearCache()
        {
            if (_BS_Cache != null)
                _BS_Cache.Clear();

            if (_SQL_Cache != null)
                _SQL_Cache.Clear();

            if (_EnsData_Cache != null)
                _EnsData_Cache.Clear();

            if (_Map_Cache != null)
                _Map_Cache.Clear();

            if (_EnsData_Cache_Ext != null)
                _EnsData_Cache_Ext.Clear();

            if (_Bill_Cache != null)
                _Bill_Cache.Clear();

            if (_Row_Cache != null)
                _Row_Cache.Clear();

            //清除
            Cache2019.ClearCache();
        }
        static Cache()
        {
            if (BP.Difference.SystemConfig.isBSsystem == false)
            {
                CS_Cache = new Hashtable();
            }
        }
        public static readonly Hashtable CS_Cache;

        #region Bill_Cache 单据模板Cache.
        private static Hashtable _Bill_Cache;
        public static Hashtable Bill_Cache
        {
            get
            {
                if (_Bill_Cache == null)
                    _Bill_Cache = new Hashtable();
                return _Bill_Cache;
            }
        }
        public static string GetBillStr(string cfile, bool isCheckCache)
        {
            cfile = cfile.Replace(".rtf.rtf", ".rtf");

            string val = Bill_Cache[cfile] as string;
            if (isCheckCache == true)
                val = null;


            if (val == null)
            {
                string file = null;
                if (cfile.Contains(":"))
                    file = cfile;
                else
                    file = BP.Difference.SystemConfig.PathOfDataUser + "CyclostyleFile/" + cfile;

                try
                {
                    StreamReader read = new StreamReader(file, System.Text.Encoding.ASCII); // 文件流.
                    val = read.ReadToEnd();  //读取完毕。
                    read.Close(); // 关闭。
                }
                catch (Exception ex)
                {
                    throw new Exception("@读取单据模板时出现错误。cfile=" + cfile + " @Ex=" + ex.Message);
                }
                _Bill_Cache[cfile] = val;
            }
            return val.Substring(0);
        }
        public static string[] GetBillParas(string cfile, string ensStrs, Entities ens)
        {
            string[] paras = Bill_Cache[cfile + "Para"] as string[];
            if (paras != null)
                return paras;

            Attrs attrs = new Attrs();
            foreach (Entity en in ens)
            {
                string perKey = en.ToString();

                Attrs enAttrs = en.EnMap.Attrs;
                foreach (Attr attr in enAttrs)
                {
                    Attr attrN = new Attr();
                    attrN.Key = perKey + "." + attr.Key;

                    if (attr.ItIsRefAttr)
                    {
                        attrN.Field = perKey + "." + attr.Key + "Text";
                    }
                    attrN.MyDataType = attr.MyDataType;
                    attrN.MyFieldType = attr.MyFieldType;
                    attrN.UIBindKey = attr.UIBindKey;
                    attrN.Field = attr.Field;
                    attrs.Add(attrN);
                }
            }

            paras = Cache.GetBillParas_Gener(cfile, attrs);
            _Bill_Cache[cfile + "Para"] = paras;
            return paras;
        }
        public static string[] GetBillParas(string cfile, string ensStrs, Entity en)
        {
            string[] paras = Bill_Cache[cfile + "Para"] as string[];
            if (paras != null)
                return paras;

            paras = Cache.GetBillParas_Gener(cfile, en.EnMap.Attrs);
            _Bill_Cache[cfile + "Para"] = paras;
            return paras;
        }
        public static string[] GetBillParas_Gener(string cfile, Attrs attrs)
        {
            cfile = cfile.Replace(".rtf.rtf", ".rtf");

            //  Attrs attrs = en.EnMap.Attrs;
            string[] paras = new string[300];
            string Billstr = Cache.GetBillStr(cfile, true);
            char[] chars = Billstr.ToCharArray();
            string para = "";
            int i = 0;
            bool haveError = false;
            string msg = "";
            foreach (char c in chars)
            {
                if (c == '>')
                {
                    #region 首先解决空格的问题.
                    string real = para.Clone().ToString();
                    if (attrs != null && real.Contains(" "))
                    {
                        real = real.Replace(" ", "");
                        Billstr = Billstr.Replace(para, real);
                        para = real;
                        haveError = true;
                    }
                    #endregion 首先解决空格的问题.

                    #region 解决特殊符号
                    if (attrs != null && real.Contains("/") && real.Contains("ND") == false)
                    {
                        haveError = true;
                        string findKey = null;
                        int keyLen = 0;
                        foreach (Attr attr in attrs)
                        {
                            if (real.Contains(attr.Key))
                            {
                                if (keyLen <= attr.Key.Length)
                                {
                                    keyLen = attr.Key.Length;
                                    findKey = attr.Key;
                                }
                            }
                        }

                        if (findKey == null)
                        {
                            msg += "@参数:<font color=red><b>[" + real + "]</b></font>可能拼写错误。";
                            continue;
                        }

                        if (real.Contains(findKey + ".NYR") == true)
                        {
                            real = findKey + ".NYR";
                        }
                        else if (real.Contains(findKey + ".RMB") == true)
                        {
                            real = findKey + ".RMB";
                        }
                        else if (real.Contains(findKey + ".RMBDX") == true)
                        {
                            real = findKey + ".RMBDX";
                        }
                        else if (real.Contains(findKey + ".Year") == true)
                        {
                            real = findKey + ".Year";
                        }
                        else if (real.Contains(findKey + ".Month") == true)
                        {
                            real = findKey + ".Month";
                        }
                        else if (real.Contains(findKey + ".Day") == true)
                        {
                            real = findKey + ".Day";
                        }
                        else
                        {
                            real = findKey;
                        }

                        Billstr = Billstr.Replace(para, real);
                        // msg += "@参数:<font color=red><b>[" + para + "]</b></font>不符合规范。";
                        //continue;
                    }
                    #endregion 首先解决空格的问题.

                    paras.SetValue(para, i);
                    i++;
                }

                if (c == '<')
                {
                    para = ""; // 如果遇到了 '<' 开始记录
                }
                else
                {
                    if (DataType.IsNullOrEmpty(c.ToString()))
                        continue;
                    para += c.ToString();
                }
            }


            if (msg != "")
            {
                string s = "@帮助信息:用记事本打开它模板,找到红色的字体. 把尖括号内部的非法字符去了,例如:《|f0|fs20RDT.NYR|lang1033|kerning2》，修改后事例：《RDT.NYR》。@注意把双引号代替单引号，竖线代替反斜线。";
                //throw new Exception("@单据模板（"+cfile+"）如下标记出现错误，系统无法修复它，需要您手工的删除标记或者用记事本打开查找到这写标记修复他们.@" + msg + s);
            }
            return paras;
        }
        #endregion

        #region Conn Cache
        private static Hashtable _Conn_Cache;
        public static Hashtable Conn_Cache
        {
            get
            {
                if (_Conn_Cache == null)
                    _Conn_Cache = new Hashtable();
                return _Conn_Cache;
            }
        }
        public static object GetConn(string fk_emp)
        {
            return Conn_Cache[fk_emp];
        }
        public static void SetConn(string fk_emp, object csh)
        {
            if (fk_emp == null)
                throw new Exception("fk_emp.  csh 参数有一个为空。");
            Conn_Cache[fk_emp] = csh;
        }
        #endregion

        #region BS_Cache
        private static String bsCacheKey = SystemConfig.RedisCacheKey("BSCache");
        private static Hashtable _BS_Cache = new Hashtable();
        public static Hashtable BS_Cache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(bsCacheKey);
                    if (list == null || list.Count==0)
                        _BS_Cache = null;
                    else
                        _BS_Cache = list[0];
                }
                if (_BS_Cache == null)
                    _BS_Cache = new Hashtable();
                return _BS_Cache;
            }
        }
        #endregion

        #region SQL Cache
        private static String sqlCacheKey = SystemConfig.RedisCacheKey("SQLCache");
        private static Hashtable _SQL_Cache = new Hashtable();
        public static Hashtable SQL_Cache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(sqlCacheKey);
                    if (list == null || list.Count == 0)
                        _SQL_Cache = null;
                    else
                        _SQL_Cache = list[0];
                }
                    
                if (_SQL_Cache == null)
                    _SQL_Cache = new Hashtable();
                return _SQL_Cache;
            }
        }
        public static SQLCache GetSQL(string clName)
        {
            return SQL_Cache[clName] as BP.En.SQLCache;
        }
        public static void SetSQL(string clName, BP.En.SQLCache csh)
        {
            if (clName == null || csh == null)
                throw new Exception("clName.  csh 参数有一个为空。");
            SQL_Cache[clName] = csh;
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.SetInHash(sqlCacheKey, clName, csh);
        }
        /// <summary>
        /// 清除缓存
        /// </summary>
        /// <param name="clName"></param>
        public static void ClearSQL(string clName)
        {
            SQL_Cache.Remove(clName);
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.RemoveHash(sqlCacheKey);
        }

        #endregion

        #region EnsData Cache
        private static String ensDataCacheKey = SystemConfig.RedisCacheKey("EnsDataCache");
        private static Hashtable _EnsData_Cache;
        public static Hashtable EnsData_Cache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(ensDataCacheKey);
                    if (list == null || list.Count == 0)
                        _EnsData_Cache = null;
                    else
                        _EnsData_Cache = list[0];
                }
                if (_EnsData_Cache == null)
                    _EnsData_Cache = new Hashtable();
                return _EnsData_Cache;
            }
        }
        public static BP.En.Entities GetEnsData(string clName)
        {
            Entities ens = EnsData_Cache[clName] as BP.En.Entities;
            if (ens == null)
                return null;

            if (ens.Count == 0)
                return null;
            return ens;
        }
        public static void EnsDataSet(string clName, BP.En.Entities obj)
        {


            EnsData_Cache[clName] = obj;
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.SetInHash(ensDataCacheKey, clName, obj);

        }
        public static void Remove(string clName)
        {
            EnsData_Cache.Remove(clName);
        }
        #endregion

        #region EnsData Cache 扩展 临时的Cache 文件。
        private static String ensCacheExtKey = SystemConfig.RedisCacheKey("EnsDataCacheExt");
        private static Hashtable _EnsData_Cache_Ext;
        public static Hashtable EnsData_Cache_Ext
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(ensCacheExtKey);
                    if (list == null || list.Count == 0)
                        _EnsData_Cache_Ext = null;
                    else
                        _EnsData_Cache_Ext = list[0];
                }
                if (_EnsData_Cache_Ext == null)
                    _EnsData_Cache_Ext = new Hashtable();
                return _EnsData_Cache_Ext;
            }
        }
        /// <summary>
        /// 为部分数据做的缓冲处理
        /// </summary>
        /// <param name="clName"></param>
        /// <returns></returns>
        public static BP.En.Entities GetEnsDataExt(string clName)
        {
            // 判断是否失效了。
            if (BP.Difference.SystemConfig.isTempCacheFail)
            {
                EnsData_Cache_Ext.Clear();
                return null;
            }

            try
            {
                BP.En.Entities ens;
                ens = EnsData_Cache_Ext[clName] as BP.En.Entities;
                return ens;
            }
            catch
            {
                return null;
            }
        }
        /// <summary>
        /// 为部分数据做的缓冲处理
        /// </summary>
        /// <param name="clName"></param>
        /// <param name="obj"></param>
        public static void SetEnsDataExt(string clName, BP.En.Entities obj)
        {
            if (clName == null || obj == null)
                throw new Exception("clName.  obj 参数有一个为空。");
            EnsData_Cache_Ext[clName] = obj;
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.SetInHash(ensCacheExtKey, clName, obj);
        }
        #endregion

        #region TSmap Cache
        private static String mapCacheTSKey = SystemConfig.RedisCacheKey("MapCacheTS");
        private static Hashtable _Map_CacheTS;
        public static Hashtable Map_CacheTS
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(mapCacheTSKey);
                    if (list == null || list.Count == 0)
                        _Map_CacheTS = null;
                    else
                        _Map_CacheTS = list[0];
                }

                if (_Map_CacheTS == null)
                    _Map_CacheTS = new Hashtable();
                return _Map_CacheTS;
            }
        }
        public static BP.En.Map GetMapTS(string clName)
        {
            try
            {
                return Map_CacheTS[clName] as BP.En.Map;
            }
            catch
            {
                return null;
            }
        }
        public static void SetMapTS(string clName, BP.En.Map map)
        {
            if (clName == null)
                return;
            //    throw new Exception("clName.不能为空。");
            if (map == null)
            {
                Map_CacheTS.Remove(clName);
                return;
            }
            Map_CacheTS[clName] = map;
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.SetInHash(mapCacheTSKey, clName, map);
        }
        /// <summary>
        /// 是否存map.
        /// </summary>
        /// <param name="clName"></param>
        /// <returns></returns>
        public static bool IsExitMapTS(string clName)
        {
            if (clName == null)
                throw new Exception("clName.不能为空。");

            return Map_CacheTS.ContainsKey(clName);
        }
        #endregion


        #region map Cache
        private static String mapCacheKey = SystemConfig.RedisCacheKey("MapCache");
        private static Hashtable _Map_Cache;
        public static Hashtable Map_Cache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(mapCacheKey);
                    if (list == null || list.Count == 0)
                        _Map_Cache = null;
                    else
                        _Map_Cache = list[0];
                }
                if (_Map_Cache == null)
                    _Map_Cache = new Hashtable();
                return _Map_Cache;
            }
        }
        public static BP.En.Map GetMap(string clName)
        {
            try
            {
                return Map_Cache[clName] as BP.En.Map;
            }
            catch
            {
                return null;
            }
        }
        public static void SetMap(string clName, BP.En.Map map)
        {
            if (clName == null)
                return;
            //    throw new Exception("clName.不能为空。");
            if (map == null)
            {
                Map_Cache.Remove(clName);
                return;
            }
            Map_Cache[clName] = map;
            if (SystemConfig.RedisIsEnable())
                HttpContextHelper.RedisUtils.SetInHash(mapCacheKey, clName, map);
        }
        /// <summary>
        /// 是否存map.
        /// </summary>
        /// <param name="clName"></param>
        /// <returns></returns>
        public static bool IsExitMap(string clName)
        {
            if (clName == null)
                throw new Exception("clName.不能为空。");

            return Map_Cache.ContainsKey(clName);
        }
        #endregion

        #region row Cache
        private static Hashtable _Row_Cache;
        public static Hashtable Row_Cache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(mapCacheKey);
                    if (list == null || list.Count == 0)
                        _Map_Cache = null;
                    else
                        _Map_Cache = list[0];
                }

                if (_Row_Cache == null)
                    _Row_Cache = new Hashtable();
                return _Row_Cache;
            }
        }
        public static BP.En.Row GetRow(string clName)
        {
            BP.En.Row row = Row_Cache[clName] as BP.En.Row;
            if (row == null)
                return null;

            return (BP.En.Row)row.Clone();
        }
        public static void SetRow(string clName, BP.En.Row map)
        {
            if (clName == null)
                return;
            //    throw new Exception("clName.不能为空。");
            if (map == null)
            {
                Row_Cache.Remove(clName);
                return;
            }
            Row_Cache[clName] = map;
        }
        /// <summary>
        /// 是否存map.
        /// </summary>
        /// <param name="clName"></param>
        /// <returns></returns>
        public static bool IsExitRow(string clName)
        {
            if (clName == null)
                throw new Exception("clName.不能为空。");

            return Row_Cache.ContainsKey(clName);
        }
        #endregion

        #region 取出对象
        /// <summary>
        /// 从 Cache 里面取出对象.
        /// </summary>
        public static object GetObj(string key, Depositary where)
        {

#if DEBUG
            if (where == Depositary.None)
                throw new Exception("您没有把[" + key + "]放到session or application 里面不能找出他们.");
#endif

            if (BP.Difference.SystemConfig.isBSsystem)
            {
                if (where == Depositary.Application)
                    // return  System.Web.HttpContext.Current.Cache[key];
                    return BS_Cache[key]; //  System.Web.HttpContext.Current.Cache[key];
                else
                    return HttpContextHelper.SessionGet(key);
            }
            else
            {
                return CS_Cache[key];
            }
        }
        public static object GetObj(string key)
        {
            if (BP.Difference.SystemConfig.isBSsystem)
            {
                object obj = BS_Cache[key]; // Cache.GetObjFormApplication(key, null);
                if (obj == null)
                    obj = Cache.GetObjFormSession(key);
                return obj;
            }
            else
            {
                return CS_Cache[key];
            }
        }
        /// <summary>
        /// 删除 like 名称的缓存对象。
        /// </summary>
        /// <param name="likeKey"></param>
        /// <returns></returns>
        public static int DelObjFormApplication(string likeKey)
        {
            int i = 0;
            if (BP.Difference.SystemConfig.isBSsystem)
            {
                string willDelKeys = "";
                foreach (string key in BS_Cache.Keys)
                {
                    if (key.Contains(likeKey) == false)
                        continue;
                    willDelKeys += "@" + key;
                }

                string[] strs = willDelKeys.Split('@');
                foreach (string s in strs)
                {
                    if (DataType.IsNullOrEmpty(s) == true)
                        continue;
                    BS_Cache.Remove(s);
                    i++;
                }
            }
            else
            {
                string willDelKeys = "";
                foreach (string key in CS_Cache.Keys)
                {
                    if (key.Contains(likeKey) == false)
                        continue;
                    willDelKeys += "@" + key;
                }

                string[] strs = willDelKeys.Split('@');
                foreach (string s in strs)
                {
                    if (DataType.IsNullOrEmpty(s) == true)
                        continue;
                    CS_Cache.Remove(s);
                    i++;
                }
            }

            return i;
        }
        public static object GetObjFormApplication(string key, object isNullAsVal)
        {
            if (BP.Difference.SystemConfig.isBSsystem)
            {
                object obj = BS_Cache[key]; // System.Web.HttpContext.Current.Cache[key];
                if (obj == null)
                    return isNullAsVal;
                else
                    return obj;
            }
            else
            {
                object obj = CS_Cache[key];
                if (obj == null)
                    return isNullAsVal;
                else
                    return obj;
            }
        }
        public static object GetObjFormSession(string key)
        {
            if (BP.Difference.SystemConfig.isBSsystem)
            {
                try
                {
                    return HttpContextHelper.SessionGet(key);
                }
                catch
                {
                    return null;
                }
            }
            else
            {
                return CS_Cache[key];
            }
        }
        #endregion

        #region Remove Obj
        /// <summary>
        /// RemoveObj
        /// </summary>
        /// <param name="key"></param>
        /// <param name="where"></param>
        public static void RemoveObj(string key, Depositary where)
        {
            if (Cache.IsExits(key, where) == false)
                return;

            if (BP.Difference.SystemConfig.isBSsystem)
            {
                if (where == Depositary.Application)
                    CacheHelper.Remove(key);
                else
                    HttpContextHelper.Session.Remove(key);
            }
            else
            {
                CS_Cache.Remove(key);
            }
        }
        #endregion

        #region 放入对象
        public static void RemoveObj(string key)
        {
            BS_Cache.Remove(key);
        }
        public static void AddObj(string key, Depositary where, object obj)
        {
            if (key == null)
                throw new Exception("您需要为obj=" + obj.ToString() + ",设置为主键值。key");

            if (obj == null)
                throw new Exception("您需要为obj=null  设置为主键值。key=" + key);

#if DEBUG
            if (where == Depositary.None)
                throw new Exception("您没有把[" + key + "]放到 session or application 里面设置他们.");
#endif
            //if (Cache.IsExits(key, where))
            //    return;

            if (BP.Difference.SystemConfig.isBSsystem)
            {
                if (where == Depositary.Application)
                {
                    BS_Cache[key] = obj;
                }
                else
                {
                    HttpContextHelper.SessionSet(key, obj);
                }
            }
            else
            {
                if (CS_Cache.ContainsKey(key))
                    CS_Cache[key] = obj;
                else
                    CS_Cache.Add(key, obj);
            }
        }
        #endregion

        #region 判断对象是不是存在
        /// <summary>
        /// 判断对象是不是存在
        /// </summary>
        public static bool IsExits(string key, Depositary where)
        {
            if (BP.Difference.SystemConfig.isBSsystem)
            {
                if (where == Depositary.Application)
                {
                    return CacheHelper.Contains(key);
                }
                else
                {
                    return HttpContextHelper.SessionGet(key) != null;
                }
            }
            else
            {
                return CS_Cache.ContainsKey(key);
            }
        }
        #endregion

    }

    public class CacheEntity
    {
        #region Hashtable 属性
        private static String dCacheKey = SystemConfig.RedisCacheKey("DCache");
        private static Hashtable _Cache=new Hashtable();
        public static Hashtable DCache
        {
            get
            {
                if (SystemConfig.RedisIsEnable())
                {
                    List<Hashtable> list = HttpContextHelper.RedisUtils.GetAllHashValues<Hashtable>(dCacheKey);
                    if (list == null || list.Count == 0)
                        _Cache = null;
                    else
                        _Cache = list[0];
                }
                

                if (_Cache == null)
                    _Cache = new Hashtable();
                return _Cache;
            }
        }
        #endregion

        /// <summary>
        /// 更新对象
        /// </summary>
        /// <param name="enName"></param>
        /// <param name="key"></param>
        /// <param name="en"></param>
        public static void Update(string enName, string key, Entity en)
        {
            Hashtable ht = CacheEntity.DCache[enName] as Hashtable;
            if (ht == null)
            {
                ht = new Hashtable();
                CacheEntity.DCache[enName] = ht;
            }
            ht[key] = en;

            //清除集合.
            CacheEntity.DCache.Remove(enName + "Ens");
        }
        /// <summary>
        /// 获取一个实体
        /// </summary>
        /// <param name="enName">实体Name</param>
        /// <param name="pkVal">主键值</param>
        /// <returns>返回这个实体</returns>
        public static Entity Select(string enName, string pkVal)
        {
            Hashtable ht = CacheEntity.DCache[enName] as Hashtable;
            if (ht == null)
                return null;

            return ht[pkVal] as Entity;
        }
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="enName"></param>
        /// <param name="pkVal"></param>
        public static void Delete(string enName, string pkVal)
        {
            Hashtable ht = CacheEntity.DCache[enName] as Hashtable;
            if (ht == null)
                return;

            ht.Remove(pkVal);
            //清除集合.
            CacheEntity.DCache.Remove(enName + "Ens");
        }
        /// <summary>
        /// 插入
        /// </summary>
        /// <param name="enName"></param>
        /// <param name="en"></param>
        /// <param name="pkVal"></param>
        public static void Insert(string enName, string pkVal, Entity en)
        {
            Hashtable ht = CacheEntity.DCache[enName] as Hashtable;
            if (ht == null)
                return;

            //edited by liuxc,2014-8-21 17:21
            if (ht.ContainsKey(pkVal))
                ht[pkVal] = en;
            else
                ht.Add(pkVal, en);

            //清除集合.
            CacheEntity.DCache.Remove(enName + "Ens");
        }
    }
}