URF.NET
v5.1.0
工作单元和存储库框架|官方URF、可追踪实体和设计工厂团队
该框架（总下载量超过 100K+）最大限度地减少了 ORM 技术在应用程序中传播的表面积。该框架经过精心设计，重量轻，占地面积小，并且易于扩展和维护。当我们说轻量级时，我们真正的意思是轻量级，当将此框架与实体框架提供程序一起使用时，只有 10 个类。这个轻量级框架将允许您通过存储库、工作单元和领域驱动设计优雅、不引人注目且轻松地对您的应用程序和系统进行模式化。是否使用通用存储库？该框架允许通用存储库的自由，以及添加您自己的域特定存储库方法的能力，简而言之，具有可扩展和通用存储库的工作单元。
现场演示：longle.azurewebsites.net
public class CustomerController : ODataController
{
private readonly ICustomerService _customerService ;
private readonly IUnitOfWorkAsync _unitOfWorkAsync ;
public CustomerController (
IUnitOfWorkAsync unitOfWorkAsync ,
ICustomerService customerService )
{
_unitOfWorkAsync = unitOfWorkAsync ;
_customerService = customerService ;
}
// GET: odata/Customers
[ HttpGet ]
[ Queryable ]
public IQueryable < Customer > GetCustomer ( )
{
return _customerService . Queryable ( ) ;
}
// GET: odata/Customers(5)
[ Queryable ]
public SingleResult < Customer > GetCustomer ( [ FromODataUri ] string key )
{
return SingleResult . Create ( _customerService . Queryable ( ) . Where ( t => t . CustomerID == key ) ) ;
}
// PUT: odata/Customers(5)
public async Task < IHttpActionResult > Put ( string key , Customer customer )
{
if ( ! ModelState . IsValid )
{
return BadRequest ( ModelState ) ;
}
if ( key != customer . CustomerID )
{
return BadRequest ( ) ;
}
customer . TrackingState = TrackingState . Modified ;
_customerService . Update ( customer ) ;
try
{
await _unitOfWorkAsync . SaveChangesAsync ( ) ;
}
catch ( DbUpdateConcurrencyException )
{
if ( ! CustomerExists ( key ) )
{
return NotFound ( ) ;
}
throw ;
}
return Updated ( customer ) ;
}
// POST: odata/Customers
public async Task < IHttpActionResult > Post ( Customer customer )
{
if ( ! ModelState . IsValid )
{
return BadRequest ( ModelState ) ;
}
customer . TrackingState = TrackingState . Added ;
_customerService . Insert ( customer ) ;
try
{
await _unitOfWorkAsync . SaveChangesAsync ( ) ;
}
catch ( DbUpdateException )
{
if ( CustomerExists ( customer . CustomerID ) )
{
return Conflict ( ) ;
}
throw ;
}
return Created ( customer ) ;
}
//// PATCH: odata/Customers(5)
[ AcceptVerbs ( " PATCH " , " MERGE " ) ]
public async Task < IHttpActionResult > Patch ( [ FromODataUri ] string key , Delta < Customer > patch )
{
if ( ! ModelState . IsValid )
{
return BadRequest ( ModelState ) ;
}
Customer customer = await _customerService . FindAsync ( key ) ;
if ( customer == null )
{
return NotFound ( ) ;
}
patch . Patch ( customer ) ;
customer . TrackingState = TrackingState . Modified ;
try
{
await _unitOfWorkAsync . SaveChangesAsync ( ) ;
}
catch ( DbUpdateConcurrencyException )
{
if ( ! CustomerExists ( key ) )
{
return NotFound ( ) ;
}
throw ;
}
return Updated ( customer ) ;
}
// DELETE: odata/Customers(5)
public async Task < IHttpActionResult > Delete ( string key )
{
Customer customer = await _customerService . FindAsync ( key ) ;
if ( customer == null )
{
return NotFound ( ) ;
}
customer . TrackingState = TrackingState . Deleted ;
_customerService . Delete ( customer ) ;
await _unitOfWorkAsync . SaveChangesAsync ( ) ;
return StatusCode ( HttpStatusCode . NoContent ) ;
}
// GET: odata/Customers(5)/CustomerDemographics
[ Queryable ]
public IQueryable < CustomerDemographic > GetCustomerDemographics ( [ FromODataUri ] string key )
{
return
_customerService . Queryable ( )
. Where ( m => m . CustomerID == key )
. SelectMany ( m => m . CustomerDemographics ) ;
}
// GET: odata/Customers(5)/Orders
[ Queryable ]
public IQueryable < Order > GetOrders ( [ FromODataUri ] string key )
{
return _customerService . Queryable ( ) . Where ( m => m . CustomerID == key ) . SelectMany ( m => m . Orders ) ;
}
protected override void Dispose ( bool disposing )
{
if ( disposing )
{
_unitOfWorkAsync . Dispose ( ) ;
}
base . Dispose ( disposing ) ;
}
private bool CustomerExists ( string key )
{
return _customerService . Query ( e => e . CustomerID == key ) . Select ( ) . Any ( ) ;
}
} 从Service<TEntity>中的Repository<TEntity>公开的所有方法都可以重写，以添加任何前置或后置域/业务逻辑。域业务逻辑应该位于服务层，而不是位于控制器或存储库中，以实现关注点分离。
ICustomerService ，它应该始终继承IService<TEnttiy>例如IService<Customer>ICustomerService的CustomerServicecontainer.RegisterType<ICustomerService, CustomerService>() ，有关连接 DI 和 IoC 的更多详细信息，请参阅下一个示例。 public interface ICustomerService : IService < Customer >
{
decimal CustomerOrderTotalByYear ( string customerId , int year ) ;
IEnumerable < Customer > CustomersByCompany ( string companyName ) ;
IEnumerable < CustomerOrder > GetCustomerOrder ( string country ) ;
}
public class CustomerService : Service < Customer > , ICustomerService
{
private readonly IRepositoryAsync < Customer > _repository ;
public CustomerService ( IRepositoryAsync < Customer > repository ) : base ( repository )
{
_repository = repository ;
}
public decimal CustomerOrderTotalByYear ( string customerId , int year )
{
// add any domain logic here
return _repository . GetCustomerOrderTotalByYear ( customerId , year ) ;
}
public IEnumerable < Customer > CustomersByCompany ( string companyName )
{
// add any domain logic here
return _repository . CustomersByCompany ( companyName ) ;
}
public IEnumerable < CustomerOrder > GetCustomerOrder ( string country )
{
// add any domain logic here
return _repository . GetCustomerOrder ( country ) ;
}
public override void Insert ( Customer entity )
{
// e.g. add any business logic here before inserting
base . Insert ( entity ) ;
}
public override void Delete ( object id )
{
// e.g. add business logic here before deleting
base . Delete ( id ) ;
}
} UnityConfig.cs
public class UnityConfig
{
private static Lazy < IUnityContainer > container = new Lazy < IUnityContainer > ( ( ) =>
{
var container = new UnityContainer ( ) ;
RegisterTypes ( container ) ;
return container ;
} ) ;
public static IUnityContainer GetConfiguredContainer ( )
{
return container . Value ;
}
public static void RegisterTypes ( IUnityContainer container )
{
container
// Register DbContext instead of IDataDataContext, which is now obsolete.
//.RegisterType<IDataContextAsync, NorthwindContext>(new PerRequestLifetimeManager())
. RegisterType < DbContext , NorthwindContext > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IUnitOfWorkAsync , UnitOfWork > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IRepositoryAsync < Customer > , Repository < Customer > > ( )
. RegisterType < IRepositoryAsync < Product > , Repository < Product > > ( )
. RegisterType < IProductService , ProductService > ( )
. RegisterType < ICustomerService , CustomerService > ( )
. RegisterType < INorthwindStoredProcedures , NorthwindContext > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IStoredProcedureService , StoredProcedureService > ( ) ;
}
}
