asp.net 學(xué)習(xí)之路 項目整體框架簡單的搭建

public class BaseRepositoryT>:IDAL.IBaseRepositoryT> where T:class
{
private DbContext container = EFContentFactory.GetCurrentContext();
#region 增加
public T AddEntity(T entity)
{
container.SetT>().Add(entity);
return entity;
}
#endregion
#region 刪除
public bool DeleteEntity(T entity)
{
container.SetT>().Attach(entity);
container.Entry(entity).State = EntityState.Deleted;
return true;
}
#endregion
#region 修改
public bool UpdateEntity(T entity)
{
container.SetT>().Attach(entity);
container.Entry(entity).State = EntityState.Modified;
return true;
}
#endregion
#region 查詢
public IQueryableT> GetEntities(FuncT, bool> lambdaWhere)
{
IQueryableT> entities = container.SetT>().Where(lambdaWhere).AsQueryable();
return entities;
}
#endregion
#region 分頁
public IQueryableT> GetEntitiesByPageIndexTS>(int pageIndex, int pageSize, out int totalCount, FuncT, bool> lambdaWhere, FuncT, TS> orderByRole, bool descending)
{
var temp = container.SetT>().Where(lambdaWhere).AsQueryable();
totalCount = temp.Count();
if (descending)
{
temp = temp.OrderByDescending(orderByRole)
.Skip(pageSize * (pageIndex - 1))
.Take(pageSize).AsQueryable();
}
else
{
temp = temp.OrderBy(orderByRole)
.Skip(pageSize * (pageIndex - 1))
.Take(pageSize).AsQueryable();
}
return temp;
}
#endregion
}

public static class ShopDaoFactory
{
public static IUserInfoRepository UserInfoRepository
{
get{return new UserInfoRepository();}
}
public static IRoleRepository RoleRepository
{
get{return new RoleRepository();}
}
}

public abstract class BaseServiceT> :IBLL.IBaseServiceT> where T:class, new ()
{
public BaseService()
{
GetInstance();
}
protected IDAL.IDbSession _DbSession = DbSeesionFactory.GetSession();
protected IDAL.IBaseRepositoryT> CurrentRepository { get; set; }
public abstract void GetInstance();
public IQueryableT> GetEntities(FuncT, bool> lambdaWhere)
{
//_DbSession.SavaChanges();
return CurrentRepository.GetEntities(lambdaWhere);
}
public bool DeleteEntity(T entity)
{
CurrentRepository.DeleteEntity(entity);
return _DbSession.SaveChanges() > 0;
}
public bool UpdateEntity(T entity)
{
CurrentRepository.UpdateEntity(entity);
return _DbSession.SaveChanges() > 0;
}
public T AddEntity(T entity)
{
var en = CurrentRepository.AddEntity(entity);
_DbSession.SaveChanges();
return en;
}
public IQueryableT> GetEntitiesByPageIndexTS>(int pageIndex, int pageSize, out int totalCount, FuncT, bool> lambdaWhere, FuncT, TS> orderByRole, bool descending)
{
return CurrentRepository.GetEntitiesByPageIndex(pageIndex, pageSize, out totalCount, lambdaWhere, orderByRole,
descending);
}
}
}

public partial class DbSession:IDAL.IDbSession
{
#region 代碼生成器生成
//public IDAL.IRoleRepository RoleRepository
//{
// get { return new RoleRepository();}
//}
//public IDAL.IUserInfoRepository UserInfoRepository
//{
// get { return new UserInfoRepository();}
//}
#endregion
public int SaveChanges()
{
return EFContentFactory.GetCurrentContext().SaveChanges();
}
public int ExcuteSql(string strSql, System.Data.Objects.ObjectParameter[] parameters)
{
return EFContentFactory.GetCurrentContext().Database.ExecuteSqlCommand(strSql, parameters);
}
}
public class EFContentFactory
{
public static DbContext GetCurrentContext()
{
DbContext obj = CallContext.GetData("DbContext") as DbContext;
if (obj==null)
{
obj = new Model.DataContainer();
CallContext.SetData("DbContext",obj);
}
return obj;
}
}

public class DbSeesionFactory
{
/// summary>
/// 保證線程內(nèi)dbsession唯一
/// /summary>
/// returns>/returns>
public static IDAL.IDbSession GetSession()
{
IDAL.IDbSession _dbSession = CallContext.GetData("DbSession") as IDbSession;
if (_dbSession == null)
{
_dbSession = new DbSession();
CallContext.SetData("DbSession", _dbSession);
}
return _dbSession;
}
}

public partial class ActionInfoService:BaseServiceActionInfo>,IBLL.IActionInfoService
{
public override void GetInstance()
{
CurrentRepository = _DbSession.ActionInfoRepository;
}
}

public partial class R_UserInfo_ActionInfoService:BaseServiceR_UserInfo_ActionInfo>,IBLL.IR_UserInfo_ActionInfoService
{
public override void GetInstance()
{
CurrentRepository = _DbSession.R_UserInfo_ActionInfoRepository;
}
}

public partial class RoleService:BaseServiceRole>,IBLL.IRoleService
{
public override void GetInstance()
{
CurrentRepository = _DbSession.RoleRepository;
}
}

public int DeleteUsers(Listint> list)
{
foreach (var i in list)
{
_DbSession.UserInfoRepository.DeleteEntity(new UserInfo() {ID = i});
}
return _DbSession.SaveChanges();
}