public class Product : Entity, IMustHaveTenant, IMustHaveOrganizationUnit
{public virtual int TenantId { get; set; }public virtual long OrganizationUnitId { get; set; }public virtual string Name { get; set; }public virtual float Price { get; set; }
}

public class ProductManager : IDomainService
{//实体仓储，实体继承自IMustHaveOrganizationUnitprivate readonly IRepository<Product> _productRepository;//OU仓储，通过此仓储读取OUprivate readonly IRepository<OrganizationUnit, long> _organizationUnitRepository;//用户数据Managerprivate readonly UserManager _userManager;//构造函数，DI注入public ProductManager(IRepository<Product> productRepository, IRepository<OrganizationUnit, long> organizationUnitRepository, UserManager userManager){_productRepository = productRepository;_organizationUnitRepository = organizationUnitRepository;_userManager = userManager;}//根据组织节点，获取关联的Productpublic List<Product> GetProductsInOu(long organizationUnitId){return _productRepository.GetAllList(p => p.OrganizationUnitId == organizationUnitId);}//根据组织节点Id查询所有的Products，包含子Product[UnitOfWork]//UnitOfWork支持事务public virtual List<Product> GetProductsInOuIncludingChildren(long organizationUnitId){//根据组织节点id，获取codevar code = _organizationUnitRepository.Get(organizationUnitId).Code;//查询组织节点开头的所有节点，这样避免了递归查询，提升了效率，也是Code定义的目的所在var query =from product in _productRepository.GetAll()join organizationUnit in _organizationUnitRepository.GetAll() on product.OrganizationUnitId equals organizationUnit.Idwhere organizationUnit.Code.StartsWith(code)select product;return query.ToList();}//根据用户查询Product//查询用户关联的组织节点，再根据组织节点，查询关联的Productpublic async Task<List<Product>> GetProductsForUserAsync(long userId){var user = await _userManager.GetUserByIdAsync(userId);var organizationUnits = await _userManager.GetOrganizationUnitsAsync(user);var organizationUnitIds = organizationUnits.Select(ou => ou.Id);return await _productRepository.GetAllListAsync(p => organizationUnitIds.Contains(p.OrganizationUnitId));}//同上个函数类似，查询中加入了子节点[UnitOfWork]public virtual async Task<List<Product>> GetProductsForUserIncludingChildOusAsync(long userId){var user = await _userManager.GetUserByIdAsync(userId);var organizationUnits = await _userManager.GetOrganizationUnitsAsync(user);var organizationUnitCodes = organizationUnits.Select(ou => ou.Code);var query =from product in _productRepository.GetAll()join organizationUnit in _organizationUnitRepository.GetAll() on product.OrganizationUnitId equals organizationUnit.Idwhere organizationUnitCodes.Any(code => organizationUnit.Code.StartsWith(code))select product;return query.ToList();}
}