using CC.Yi.DALFactory;
using CC.Yi.IBLL;
using CC.Yi.IDAL;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;

namespace CC.Yi.BLL
{
    public class BaseBll<T> : IBaseBll<T> where T : class, new()
    {
        public IBaseDal<T> CurrentDal;
        public BaseBll(IBaseDal<T> cd)
        {
            CurrentDal = cd;
        }
   
        public IQueryable<T> GetAllEntities() 
        {
            return CurrentDal.GetAllEntities();
        }

        public IQueryable<T> GetEntities(Expression<Func<T, bool>> whereLambda)
        {
            return CurrentDal.GetEntities(whereLambda);
        }

        public int GetCount(Expression<Func<T, bool>> whereLambda) //统计数量
        {
            return CurrentDal.GetCount(whereLambda);
        }

        public IQueryable<IGrouping<S, T>> GetGroup<S>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, S>> groupByLambda) //分组
        {
            return CurrentDal.GetGroup(whereLambda, groupByLambda);

        }


        public IQueryable<T> GetPageEntities<S>(int pageSize, int pageIndex, out int total, Expression<Func<T, bool>> whereLambda, Expression<Func<T, S>> orderByLambda, bool isAsc)
        {
            return CurrentDal.GetPageEntities(pageSize, pageIndex, out total, whereLambda, orderByLambda, isAsc);
        }

        public T Add(T entity)
        {
           var myEntity=CurrentDal.Add(entity);
            DbSession.SaveChanges();
            return myEntity;
        }

        public bool Add(IEnumerable<T> entities)
        {
            CurrentDal.AddRange(entities);
            return DbSession.SaveChanges() > 0;
        }

        public bool Update(T entity)
        {
            CurrentDal.Update(entity);
            return DbSession.SaveChanges() > 0;
        }

        public bool Update(T entity, params string[] propertyNames)
        {
            CurrentDal.Update(entity,propertyNames);
            return DbSession.SaveChanges() > 0;
        }

        public bool Delete(T entity)
        {
            CurrentDal.Delete(entity);
            return DbSession.SaveChanges() > 0;
        }
        public IDbSession DbSession
        {
            get
            {
                return DbSessionFactory.GetCurrentDbSession();
            }
        }
        public bool Delete(int id)
        {
            CurrentDal.Detete(id);
            return DbSession.SaveChanges() > 0;
        }

        public bool Delete(IEnumerable<int> ids)
        {
            foreach (var id in ids)
            {
                CurrentDal.Detete(id);
            }
            return DbSession.SaveChanges()>0;
        }
        public bool Delete(Expression<Func<T, bool>> where)
        {
            IQueryable<T> entities =  CurrentDal.GetEntities(where);
            if (entities != null)
            {
                CurrentDal.DeteteRange(entities);

                return DbSession.SaveChanges()>0;
            }
            return false;
        }
    }
}