OA.BLL/BaseService.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

using OA.DALFactory;
using OA.IDAL;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Linq.Expressions;

namespace OA.BLL
{
    public abstract class BaseService<T> where T :class,new()
    {
        public IDbSession DbSession//为什么要抽象？理解去
        {
            //get { return new DbSession(); }//没有必要在每个业务操作类里都new一次
            get { return DbSessionFactory.CreateDbSession(); }
        }
        /****************通过子类DbSession拿到****************/
        public IBaseDal<T> CurrentDal { get; set; }
        public abstract void SetCurrentDal();
        public BaseService()
        {
            SetCurrentDal();
        }
        /****************************************************/
        public IQueryable<T> LoadEntities(Expression<Func<T, bool>> whereLabda)
        {
            return this.CurrentDal.LoadEntities(whereLabda);
        }
        public IQueryable<T> LoadPageEntities<s>(int pageIndex,int pageSize,out int totalCount,Expression<Func<T,bool>>whereLambda,Expression<Func<T,s>>orderbyLambda,bool isAsc)
        {
            return this.CurrentDal.LoadPageEntities<s>(pageIndex,pageSize,out totalCount,whereLambda,orderbyLambda,isAsc);
        }
        public bool DeleteEntity(T entity)
        {
            this.CurrentDal.DeleteEntities(entity);
            return this.DbSession.SaveChanges();
        }
        public bool UpdateEntity(T entity)
        {
            this.CurrentDal.UpdateEntities(entity);
            return this.DbSession.SaveChanges();
        }
        public T AddEntity(T entity)
        {
            this.CurrentDal.AddEntities(entity);
             this.DbSession.SaveChanges();
            return entity;
        }
    }
}