必须填写至少10个字的日志
nnhy authored at 2012-07-27 18:48:21
17.59 KiB
X
/*
 * XCoder v4.5.2011.1108
 * 作者:nnhy/X
 * 时间:2011-11-13 22:43:10
 * 版权:版权所有 (C) 新生命开发团队 2011
*/
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.IO;
using System.Reflection;
using System.Text;
using System.Xml.Serialization;
using XCode;
using XCode.DataAccessLayer;
using NewLife.Exceptions;

namespace NewLife.CommonEntity
{
    /// <summary>模版</summary>
    [ModelCheckMode(ModelCheckModes.CheckTableWhenFirstUse)]
    public class Template : Template<Template> { }

    /// <summary>模版</summary>
    public partial class Template<TEntity> : EntityTree<TEntity> where TEntity : Template<TEntity>, new()
    {
        #region 扩展属性
        [NonSerialized]
        private EntityList<TemplateItem> _TemplateItems;
        /// <summary>该模版所拥有的模版项集合</summary>
        [XmlIgnore]
        public EntityList<TemplateItem> TemplateItems
        {
            get
            {
                if (_TemplateItems == null && ID > 0 && !Dirtys.ContainsKey("TemplateItems"))
                {
                    _TemplateItems = TemplateItem.FindAllByTemplateID(ID);
                    Dirtys["TemplateItems"] = true;
                }
                return _TemplateItems;
            }
            set { _TemplateItems = value; }
        }
        #endregion

        #region 扩展查询
        /// <summary>根据父编号、名称查找</summary>
        /// <param name="parentid">父编号</param>
        /// <param name="name">名称</param>
        /// <returns></returns>
        [DataObjectMethod(DataObjectMethodType.Select, false)]
        public static TEntity FindByParentIDAndName(Int32 parentid, String name)
        {
            if (Meta.Count >= 1000)
                return Find(new String[] { _.ParentID, _.Name }, new Object[] { parentid, name });
            else // 实体缓存
                return Meta.Cache.Entities.Find(e => e.ParentID == parentid && e.Name == name);
        }

        /// <summary>根据用户编号查找</summary>
        /// <param name="userid">用户编号</param>
        /// <returns></returns>
        [DataObjectMethod(DataObjectMethodType.Select, false)]
        public static EntityList<TEntity> FindAllByUserID(Int32 userid)
        {
            if (Meta.Count >= 1000)
                return FindAll(new String[] { _.UserID }, new Object[] { userid });
            else // 实体缓存
                return Meta.Cache.Entities.FindAll(_.UserID, userid);
        }

        /// <summary>根据编号查找</summary>
        /// <param name="id">编号</param>
        /// <returns></returns>
        [DataObjectMethod(DataObjectMethodType.Select, false)]
        public static TEntity FindByID(Int32 id)
        {
            if (Meta.Count >= 1000)
                return Find(new String[] { _.ID }, new Object[] { id });
            else // 实体缓存
                return Meta.Cache.Entities.Find(_.ID, id);
            // 单对象缓存
            //return Meta.SingleCache[id];
        }
        #endregion

        #region 对象操作
        static Template()
        {
            // 检查并增加连接
            if (!DAL.ConnStrs.ContainsKey(Meta.ConnName))
            {
                String path = Runtime.IsWeb ? @"~\App_Data\" : @"Data\";
                // 默认使用SQLite数据库
                DAL.AddConnStr(Meta.ConnName, String.Format("Data Source={0}{1}.db", path, Meta.ConnName), null, "SQLite");
            }
        }

        ///// <summary>
        ///// 已重载。基类先调用Valid(true)验证数据,然后在事务保护内调用OnInsert
        ///// </summary>
        ///// <returns></returns>
        //public override Int32 Insert()
        //{
        //    return base.Insert();
        //}

        ///// <summary>
        ///// 已重载。在事务保护范围内处理业务,位于Valid之后
        ///// </summary>
        ///// <returns></returns>
        //protected override Int32 OnInsert()
        //{
        //    return base.OnInsert();
        //}

        /// <summary>验证数据,通过抛出异常的方式提示验证失败。</summary>
        /// <param name="isNew"></param>
        public override void Valid(Boolean isNew)
        {
            if (String.IsNullOrEmpty(Name)) throw new ArgumentNullException(_.Name, _.Name.Description + "不能为空!");

            // 建议先调用基类方法,基类方法会对唯一索引的数据进行验证
            base.Valid(isNew);

            if (isNew && !Dirtys[_.CreateTime])
                CreateTime = DateTime.Now;
            else if (!isNew && !Dirtys[_.LastModify])
                LastModify = DateTime.Now;

            if (!Dirtys[_.UserID] && !Dirtys[_.UserName])
            {
                // 获取当前登录用户
                IManageUser user = ManageProvider.Provider.Current;
                if (user != null)
                {
                    if (user.ID is Int32) UserID = (Int32)user.ID;
                    UserName = user.ToString();
                }
            }
        }

        /// <summary>已重载。删除关联数据</summary>
        /// <returns></returns>
        protected override int OnDelete()
        {
            if (TemplateItems != null) TemplateItems.Delete();
            var list = Childs;
            if (list != null) list.Delete();

            return base.OnDelete();
        }

        ///// <summary>
        ///// 首次连接数据库时初始化数据,仅用于实体类重载,用户不应该调用该方法
        ///// </summary>
        //[EditorBrowsable(EditorBrowsableState.Never)]
        //protected override void InitData()
        //{
        //    base.InitData();

        //    //// InitData一般用于当数据表没有数据时添加一些默认数据,该实体类的任何第一次数据库操作都会触发该方法,默认异步调用
        //    //// Meta.Count是快速取得表记录数
        //    //if (Meta.Count > 0) return;

        //    //// 需要注意的是,如果该方法调用了其它实体类的首次数据库操作,目标实体类的数据初始化将会在同一个线程完成
        //    //if (XTrace.Debug) XTrace.WriteLine("开始初始化{0}模版数据……", typeof(TEntity).Name);

        //    //TEntity user = new TEntity();
        //    //user.Name = "admin";
        //    //user.Password = DataHelper.Hash("admin");
        //    //user.DisplayName = "管理员";
        //    //user.RoleID = 1;
        //    //user.IsEnable = true;
        //    //user.Insert();

        //    //if (XTrace.Debug) XTrace.WriteLine("完成初始化{0}模版数据!", typeof(TEntity).Name);
        //}
        #endregion

        #region 高级查询
        // 以下为自定义高级查询的例子

        ///// <summary>
        ///// 查询满足条件的记录集,分页、排序
        ///// </summary>
        ///// <param name="key">关键字</param>
        ///// <param name="orderClause">排序,不带Order By</param>
        ///// <param name="startRowIndex">开始行,0表示第一行</param>
        ///// <param name="maximumRows">最大返回行数,0表示所有行</param>
        ///// <returns>实体集</returns>
        //[DataObjectMethod(DataObjectMethodType.Select, true)]
        //public static EntityList<TEntity> Search(String key, String orderClause, Int32 startRowIndex, Int32 maximumRows)
        //{
        //    return FindAll(SearchWhere(key), orderClause, null, startRowIndex, maximumRows);
        //}

        ///// <summary>
        ///// 查询满足条件的记录总数,分页和排序无效,带参数是因为ObjectDataSource要求它跟Search统一
        ///// </summary>
        ///// <param name="key">关键字</param>
        ///// <param name="orderClause">排序,不带Order By</param>
        ///// <param name="startRowIndex">开始行,0表示第一行</param>
        ///// <param name="maximumRows">最大返回行数,0表示所有行</param>
        ///// <returns>记录数</returns>
        //public static Int32 SearchCount(String key, String orderClause, Int32 startRowIndex, Int32 maximumRows)
        //{
        //    return FindCount(SearchWhere(key), null, null, 0, 0);
        //}

        /// <summary>构造搜索条件</summary>
        /// <param name="key">关键字</param>
        /// <returns></returns>
        private static String SearchWhere(String key)
        {
            // WhereExpression重载&和|运算符,作为And和Or的替代
            WhereExpression exp = new WhereExpression();

            // SearchWhereByKeys系列方法用于构建针对字符串字段的模糊搜索
            if (!String.IsNullOrEmpty(key)) SearchWhereByKeys(exp.Builder, key);

            // 以下仅为演示,2、3行是同一个意思的不同写法,FieldItem重载了等于以外的运算符(第4行)
            //exp &= _.Name.Equal("testName")
            //    & !String.IsNullOrEmpty(key) & _.Name.Equal(key)
            //    .AndIf(!String.IsNullOrEmpty(key), _.Name.Equal(key))
            //    | _.ID > 0;

            return exp;
        }
        #endregion

        #region 扩展操作
        #endregion

        #region 业务
        /// <summary>根据路径创建,自动识别或创建父级</summary>
        /// <param name="path"></param>
        /// <returns></returns>
        public static TEntity Create(String path)
        {
            if (String.IsNullOrEmpty(path)) return null;

            String[] ss = path.Split(@"\");
            if (ss.Length < 1) return null;

            // 先解决父级,这里用到递归
            TEntity parent = null;
            if (ss.Length <= 1)
                parent = Root;
            else
                parent = Create(String.Join(@"\", ss, 0, ss.Length - 1));

            // 如果找不到父级,就有问题了
            if (parent == null) return null;

            String name = ss[ss.Length - 1];
            TEntity entity = FindByParentIDAndName(parent.ID, name);
            if (entity != null) return entity;

            entity = new TEntity();
            entity.ParentID = parent.ID;
            entity.Name = name;
            entity.Save();

            return entity;
        }

        /// <summary>复制所有子项</summary>
        /// <param name="src"></param>
        public void CopyItems(TEntity src)
        {
            if (src == null) return;

            var items = src.TemplateItems;
            if (items == null) return;

            foreach (var item in items)
            {
                // 看看本地是否存在该模版
                var ti = TemplateItem.FindByTemplateIDAndName(ID, item.Name);
                // 如果不存在,新建一个
                if (ti == null) ti = new TemplateItem { TemplateID = ID, Name = item.Name };
                // 复制内容
                ti.CopyContent(item);
                // 保存
                ti.Save();
            }
        }
        #endregion

        #region 静态方法
        /// <summary>复制模版。若目标存在,则复制内容;否则新建</summary>
        /// <param name="src"></param>
        /// <param name="des"></param>
        public static void Copy(string src, string des)
        {
            if (String.IsNullOrEmpty(src) || String.IsNullOrEmpty(des)) return;
            // 相同路径也不处理
            if (src.EqualIgnoreCase(des)) return;

            var obj1 = GetTemplateObject(src);
            if (obj1 == null) return;

            var obj2 = GetTemplateObject(des);
            // 目标允许不存在
            //if (obj2 == null) return;

            Meta.BeginTrans();
            try
            {
                if (obj1 is Template)
                {
                    var ts = obj1 as TEntity;
                    var td = obj2 as TEntity;
                    if (ts == null) return;
                    // 如果目标存在,必须是相同类型
                    if (obj2 != null && td == null) throw new XException("已存在目标模版项{0},无法复制!", des);

                    if (td == null) td = Create(des);
                    // 复制子项
                    td.CopyItems(ts);
                }
                else
                {
                    var ts = obj1 as TemplateItem;
                    var td = obj2 as TemplateItem;
                    if (ts == null) return;
                    // 如果目标存在,必须是相同类型
                    if (obj2 != null && td == null) throw new XException("已存在目标模版{0},无法复制!", des);

                    if (td == null) td = TemplateItem.CreateItem(des);
                    // 复制内容
                    td.CopyContent(ts);
                    td.Save();
                }

                Meta.Commit();
            }
            catch { Meta.Rollback(); throw; }
        }

        /// <summary>获取路径所指定的模版,如果是模版目录,则返回Template,否则返回TemplateItem</summary>
        /// <param name="path"></param>
        /// <returns></returns>
        public static Object GetTemplateObject(String path)
        {
            if (String.IsNullOrEmpty(path)) return null;

            // 父目录,以此来获取一次Template
            String parent = Path.GetDirectoryName(path);
            var tmpParent = String.IsNullOrEmpty(parent) ? Root : Root.FindByPath(parent);
            // 如果父目录都找不到,剩下的就不要想了
            if (tmpParent == null) return null;

            // 获取文件名部分,当然,也有可能是下一级目录
            String filename = Path.GetFileName(path);
            if (String.IsNullOrEmpty(filename)) return tmpParent;

            // 先来试试这个是不是目录
            var entity = tmpParent.Childs.FindIgnoreCase(_.Name, filename);
            if (entity != null) return entity;

            // 再试试是不是模版项
            TemplateItem ti = tmpParent.TemplateItems.FindIgnoreCase(TemplateItem._.Name, filename);
            if (ti != null) return ti;

            // 最后,即使找到了父目录,但是因为找不到子目录或者模版项,也是返回空
            return null;
        }
        #endregion

        #region 检查并导入模版
        /// <summary>检查并导入模版</summary>
        /// <param name="pid">目标</param>
        /// <param name="asm"></param>
        /// <param name="prefix"></param>
        public static void ImportFromAssembly(Int32 pid, Assembly asm, String prefix)
        {
            Meta.BeginTrans();
            try
            {
                // 默认导入到全局中
                TEntity parent = FindByID(pid);
                if (parent == null)
                {
                    parent = new TEntity();
                    parent.Name = "全局";
                    parent.Save();
                }

                // 内置模版进入字典
                Dictionary<String, List<String>> dic = new Dictionary<String, List<String>>();
                if (asm == null) asm = Assembly.GetCallingAssembly();
                foreach (String item in asm.GetManifestResourceNames())
                {
                    String name = item;
                    // 去掉前缀,注意点号
                    if (!name.StartsWith(prefix)) continue;
                    name = name.Substring(prefix.Length + 1);

                    Int32 p = name.IndexOf(".");
                    String path = name.Substring(0, p);
                    name = name.Substring(p + 1);

                    List<String> list = null;
                    if (!dic.TryGetValue(path, out list))
                    {
                        list = new List<string>();
                        dic.Add(path, list);
                    }

                    list.Add(name);
                }

                // 开始处理模版
                foreach (String path in dic.Keys)
                {
                    List<String> list = dic[path];

                    TEntity entity = FindByParentIDAndName(parent.ID, path);
                    if (entity == null)
                    {
                        entity = new TEntity();
                        entity.Name = path;
                        entity.ParentID = parent.ID;
                        entity.Save();
                    }

                    // 读出模版,添加模版项
                    foreach (String name in list)
                    {
                        TemplateItem ti = TemplateItem.FindByTemplateIDAndName(entity.ID, name);
                        if (ti != null) continue;

                        Stream stream = asm.GetManifestResourceStream(String.Format("{0}.{1}.{2}", prefix, path, name));
                        Byte[] bts = new Byte[stream.Length];
                        stream.Read(bts, 0, bts.Length);

                        ti = new TemplateItem();
                        ti.TemplateID = entity.ID;
                        ti.Name = name;
                        ti["Content"] = Encoding.UTF8.GetString(bts);
                        ti.Save();
                    }
                }

                Meta.Commit();
            }
            catch
            {
                Meta.Rollback();
                throw;
            }
        }
        #endregion
    }
}