using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FB.CMS.Repository
{
    using FB.CMS.IRepository;
    using System.Data.Entity;
    using System.Data.Entity.Infrastructure;
    using System.Linq.Expressions;
    using System.Runtime.Remoting.Messaging;
    using System.Threading;
    public class BaseDal<TEntity> : IBaseDal<TEntity> where TEntity : class
    {
        //BaseDbContext db = new BaseDbContext();

        //對建立上下文容器類物件進行優化（原理：一個執行緒下我們只建立一個上下文容器類物件，然後儲存到執行緒快取當中去，當同一個執行緒過來的時候，就從執行緒快取當中取上下文容器類物件）
        public BaseDbContext db
        {
            get
            {
                //獲取BaseDbContext的完全限定名，其實這個名字沒什麼特別的意義，僅僅是一個名字而已，也可以取別的名字的
                string threadName = typeof(BaseDbContext).FullName;
                //獲取key為threadName的這個執行緒快取（CallContext就是執行緒快取容器類）
                object dbObj = CallContext.GetData(threadName);
                //如果key為threadName的執行緒快取不存在
                if (dbObj == null)
                {
                    //建立BaseDbContext類的物件例項
                    dbObj = new BaseDbContext();
                    //將這個BaseDbContext類的物件例項儲存到執行緒快取當中(以鍵值對的形式進行儲存的，我這就將key設為當前執行緒的完全限定名了)
                    CallContext.SetData(threadName, dbObj);
                    return dbObj as BaseDbContext;
                }
                return dbObj as BaseDbContext;
            }

        }
        DbSet<TEntity> _dbset;
        public BaseDal()
        {
            this._dbset = db.Set<TEntity>(); //初始化
        }

        #region 增加
        public void AddEnity(TEntity model)
        {
            if (model == null)
            {
                throw new Exception("moddel不能為null");
            }
            this._dbset.Add(model);


        }

        #endregion

        #region 物理刪除
        /// <summary>
        /// 刪除
        /// </summary>
        /// <param name="model">實體類</param>
        /// <param name="isaddedContext">是否物理刪除</param>
        public void DeleteEntity(TEntity model, bool isaddedContext)
        {
            if (model == null)
            {
                throw new Exception("DeleteEntity方法中的model不能為null");
            }
            //如果僅僅是邏輯刪除的話，那我們只要呼叫編輯方法將標識為邏輯刪除的那個欄位修改為true就可以了。
            if (isaddedContext == true)
            {
                this._dbset.Attach(model);

            }
            this._dbset.Remove(model);
        }

        #endregion

        #region 查尋
        /// <summary>
        /// 普通帶條件查詢
        /// </summary>
        /// <param name="where"></param>
        /// <returns></returns>
        public IQueryable<TEntity> QueryWhere(Expression<Func<TEntity, bool>> where)
        {
            return this._dbset.Where(where);
        }

        /// <summary>
        /// 連表查詢
        /// </summary>
        /// <param name="where">連表查詢的條件篩選查詢</param>
        /// <param name="tablesName">要做連表查詢的所有表名集合</param>
        /// <returns></returns>
        public IQueryable<TEntity> QueryJoin(Expression<Func<TEntity, bool>> where, string[] tablesName)
        {
            if (tablesName == null || tablesName.Any() == false)
            {
                throw new Exception("連表查詢最少也要一個表，所有QueryJoin方法中tablesName中最少也需要有一個表名");
            }

            DbQuery<TEntity> query = this._dbset;
            foreach (string tableName in tablesName)
            {
                //不斷的連表，直到把tablesName裡的所有表都連完
                query = query.Include(tableName);
            }
            return query.Where(where); //然後對連表進行條件篩選查詢
        }

        /// <summary>
        /// 帶條件的分頁查詢
        /// </summary>
        /// <typeparam name="TKey">按哪個欄位進行排序</typeparam>
        /// <param name="pageindex">當前頁</param>
        /// <param name="pagesize">頁大小</param>
        /// <param name="rowCount">資料總條數</param>
        /// <param name="order">排序</param>
        /// <param name="where">篩選條件</param>
        /// <returns></returns>
        public IQueryable<TEntity> QueryByPage<TKey>(int pageindex, int pagesize, out int rowCount, Expression<Func<TEntity, TKey>> order, Expression<Func<TEntity, bool>> where)
        {
            //獲取總條數
            rowCount = this._dbset.Count(where);

            //建議將這個Where條件語句放在前面，如果你放到後面，分頁的時候可能存在問題。
            return this._dbset.Where(where).OrderByDescending(order).Skip((pageindex - 1) * pagesize).Take(pagesize);

        }

        /// <summary>
        /// 呼叫儲存過程或執行SQL語句(但是我們不推薦執行sql語句)
        /// </summary>
        /// <typeparam name="TElement">
        /// 因為儲存過程返回的資料不一定就是TEntity這個實體，因為儲存過返回的結果集有可能是自己拼接出來的，所以這個方法的返回結果
        /// 為Lsit<TEntity>就不合適了。 這個 TElement是在呼叫的儲存過程的時候傳入的一個實體，此實體必須和呼叫的儲存過程的返回結集
        /// 中的欄位名稱儲存一致（你這個儲存過程返回有多個欄位，那麼你這個實體中就應該有多少個屬性）
        /// </typeparam>
        /// <param name="sql">
        /// 假設我建立了這麼一個儲存過程：
        /// create proc proc_T_UserInfo_Paging2(@pageSize int,@currentPage int,@CountData  )  
        /// 那現在我們呼叫這個儲存過程，那麼這個SQL語句的寫法就是：
        /// proc_T_UserInfo_Paging2 @pageSize int,@currentPage int,@CountData       /// 
        /// </param>
        /// <param name="prms">引數化查詢的引數陣列</param>
        /// <returns></returns>
        public List<TElement> RunProc<TElement>(string sql, params object[] prms)
        {
            return db.Database.SqlQuery<TElement>(sql, prms).ToList();
        }
        #endregion

        #region 編輯
        /// <summary>
        /// 編輯
        /// </summary>
        /// <param name="model">實體</param>
        /// <param name="propertyNames">要編輯的的所有屬性名稱序列</param>
        public void EditEntity(TEntity model, string[] propertyNames)
        {
            if (model == null)
            {
                throw new Exception("EditEntity方法中的引數model不能為null");
            }
            if (propertyNames.Any() == false || propertyNames == null)
            {
                throw new Exception("EditEntity方法中的引數propertyNames最少需要一個屬性");
            }
            System.Data.Entity.Infrastructure.DbEntityEntry entry = db.Entry(model);
            entry.State = System.Data.EntityState.Unchanged;
            foreach (string item in propertyNames)
            {
                entry.Property(item).IsModified = true;
            }
            db.Configuration.ValidateOnSaveEnabled = false;
        }

        #endregion

        #region 統一儲存
        public int SaveChanges()
        {
            return db.SaveChanges();
        }
        #endregion
    }
}