ASP.NET MVC5網(wǎng)站開發(fā)之業(yè)務(wù)邏輯層的架構(gòu)和基本功能 （四）

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

namespace Ninesky.Core
{
 public class NineskyContext:DbContext
 {


  public NineskyContext():base("DefaultConnection")
  {
   Database.SetInitializerNineskyContext>(new CreateDatabaseIfNotExistsNineskyContext>());
  }
 }
}

using System.Runtime.Remoting.Messaging;

namespace Ninesky.Core
{
 /// summary>
 /// 數(shù)據(jù)上下文工廠
 /// /summary>
 public class ContextFactory
 {
  /// summary>
  /// 獲取當(dāng)前線程的數(shù)據(jù)上下文
  /// /summary>
  /// returns>數(shù)據(jù)上下文/returns>
  public static NineskyContext CurrentContext()
  {
   NineskyContext _nContext = CallContext.GetData("NineskyContext") as NineskyContext;
   if (_nContext == null)
   {
    _nContext = new NineskyContext();
    CallContext.SetData("NineskyContext", _nContext);
   }
   return _nContext;
  }
 }
}

namespace Ninesky.Core.Types
{
 /// summary>
 /// 
 /// /summary>
 public class Response
 {
  /// summary>
  /// 返回代碼. 0-失敗，1-成功，其他-具體見方法返回值說明
  /// /summary>
  public int Code { get; set; }

  /// summary>
  /// 返回消息
  /// /summary>
  public string Message { get; set; }

  /// summary>
  /// 返回?cái)?shù)據(jù)
  /// /summary>
  public dynamic Data { get; set; }

  public Response()
  {
   Code = 0;
  }
 }
}

using System.Collections.Generic;

namespace Ninesky.Core.Types
{
 public class PagingT>
 {
  /// summary>
  /// 當(dāng)前頁。從1計(jì)數(shù)
  /// /summary>
  public int PageIndex { get; set; }

  /// summary>
  /// 每頁記錄數(shù)。默認(rèn)20
  /// /summary>
  public int PageSize { get; set; }

  /// summary>
  /// 總記錄數(shù)
  /// /summary>
  public int TotalNumber;/// summary>
  /// 當(dāng)前頁記錄列表
  /// /summary>
  public ListT> Items { get; set; }
  
  public Paging()
  {
   PageIndex = 1;
   PageSize = 20;
  }
 }
}

using Ninesky.Core.Types;
using Ninesky.DataLibrary;
using System.Data.Entity;
using System.Linq;

namespace Ninesky.Core
{
 /// summary>
 /// 管理類的基類
 /// /summary>
 /// typeparam name="T">模型類/typeparam>
 public abstract class BaseManagerT> where T :class
 {
  /// summary>
  /// 數(shù)據(jù)倉儲類
  /// /summary>
  protected RepositoryT> Repository;

  /// summary>
  /// 默認(rèn)構(gòu)造函數(shù)
  /// /summary>
  public BaseManager():this(ContextFactory.CurrentContext())
  {
  }
  /// summary>
  /// 構(gòu)造函數(shù)
  /// /summary>
  /// param name="dbContext">數(shù)據(jù)上下文/param>
  public BaseManager(DbContext dbContext){
   Repository = new RepositoryT>(dbContext);
  }

  /// summary>
  /// 添加
  /// /summary>
  /// param name="entity">實(shí)體數(shù)據(jù)/param>
  /// returns>成功時(shí)屬性【Data】為添加后的數(shù)據(jù)實(shí)體/returns>
  public virtual Response Add(T entity)
  {
   Response _response = new Response();
   if(Repository.Add(entity)>0)
   {
    _response.Code = 1;
    _response.Message = "添加數(shù)據(jù)成功！";
    _response.Data = entity;
   }
   else
   {
    _response.Code = 0;
    _response.Message = "添加數(shù)據(jù)失?。?;
   }

   return _response;
  }

  /// summary>
  /// 更新
  /// /summary>
  /// param name="entity">實(shí)體數(shù)據(jù)/param>
  /// returns>成功時(shí)屬性【Data】為更新后的數(shù)據(jù)實(shí)體/returns>
  public virtual Response Update(T entity)
  {
   Response _response = new Response();
   if (Repository.Update(entity) > 0)
   {
    _response.Code = 1;
    _response.Message = "更新數(shù)據(jù)成功！";
    _response.Data = entity;
   }
   else
   {
    _response.Code = 0;
    _response.Message = "更新數(shù)據(jù)失敗！";
   }

   return _response;
  }


  /// summary>
  /// 刪除
  /// /summary>
  /// param name="ID">主鍵/param>
  /// returns>Code：0-刪除失??；1-刪除陳功；10-記錄不存在/returns>
  public virtual Response Delete(int ID)
  {
   Response _response = new Response();
   var _entity = Find(ID);
   if (_entity == null)
   {
    _response.Code = 10;
    _response.Message = "記錄不存在！";
   }
   else
   {
    if (Repository.Delete(_entity) > 0)
    {
     _response.Code = 1;
     _response.Message = "刪除數(shù)據(jù)成功！";
    }
    else
    {
     _response.Code = 0;
     _response.Message = "刪除數(shù)據(jù)失敗！";
    }
   }
   

   return _response;
  }

  /// summary>
  /// 查找實(shí)體
  /// /summary>
  /// param name="ID">主鍵/param>
  /// returns>實(shí)體/returns>
  public virtual T Find(int ID)
  {
   return Repository.Find(ID);
  }

  /// summary>
  /// 查找數(shù)據(jù)列表-【所有數(shù)據(jù)】
  /// /summary>
  /// returns>所有數(shù)據(jù)/returns>
  public IQueryableT> FindList()
  {
   return Repository.FindList();
  }

  /// summary>
  /// 查找分頁數(shù)據(jù)
  /// /summary>
  /// param name="paging">分頁數(shù)據(jù)/param>
  /// returns>分頁數(shù)據(jù)/returns>
  public PagingT> FindPageList(PagingT> paging)
  {
   paging.Items = Repository.FindPageList(paging.PageSize, paging.PageIndex, out paging.TotalNumber).ToList();
   return paging;
  }

  /// summary>
  /// 總記錄數(shù)
  /// /summary>
  /// returns>總記錄數(shù)/returns>
  public virtual int Count()
  {
   return Repository.Count();
  }
 }
}