Base_FS_Repository.cs

90 lines | 2.704 kB Blame History Raw Download
using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using Model.Entities.Files;
using Model.UnitsOfWork;

namespace Model.Entities.Base
{
    public abstract class Base_FS_Repository<T> : BaseRepository<T> where T : FS_Item
    {
        protected DbSet<FS_Item> Set_Fs => context.Set<FS_Item>();
        protected readonly Enum_BaseDirectoryEntity RepoType;

        public Base_FS_Repository(UOW UOW, Enum_BaseDirectoryEntity type) : base(UOW)
        {
            this.RepoType = type;
        }

        public override T GetFromDBNoChange(T elem)
        {
            using (var context = new Context())
            {
                var en = context.Set<FS_Item>().
                    FirstOrDefault(e => e.ID == elem.ID);//.
                                                         //Include(e => e.Parent).
                                                         //FirstOrDefault();

                //context.Entry(en).Reference(e => e.Parent).Load();
                var p = en.PhysicalPath;

                return (T)en;
            }
        }

        public override T Create(T elem)
        {
            if (elem.Type != RepoType)
                throw Repo_Exception<T>.Factory(this, elem, Repo_Exceptions.FSRepo_TypeException);

            return base.Create(elem);
        }

        public override void Update(T elem)
        {
            if (elem.Type != RepoType)
                throw Repo_Exception<T>.Factory(this, elem, Repo_Exceptions.FSRepo_TypeException);

            base.Update(elem);
        }

        public override void Delete(T elem)
        {
            if (elem.Type != RepoType)
                throw Repo_Exception<T>.Factory(this, elem, Repo_Exceptions.FSRepo_TypeException);

            base.Delete(elem);
        }


        /// <summary>
        /// Рекурсия
        /// Функция удаляет данные о файлах из базы, при этом не влияя на ФС
        /// Обычно вызывается при сканировании ФС, когда папка/файл из базы не найдена в ФС
        /// </summary>
        /// <param name="elem"></param>
        public virtual void DeleteInList(FS_Item elem)
        {
            _DeleteInList(elem);
            context.SaveChanges();
        }

        private void _DeleteInList(FS_Item elem)
        {
            var items = elem.Items;
            //При foreach вылетает exception изменение коллекции
            for (int i = 0; i < items.Count; i++)
            {
                DeleteInList(items[i]);
            }

            Set_Fs.Remove(elem);
        }

    }
}