Merge branch 'feature/tenant-manager'

Controllers/TenantsController.cs

@@ -68,7 +68,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(typeof(TenantDto), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<ActionResult<TenantDto>> GetTenant(long id)
+    public async Task<ActionResult<TenantDto>> GetTenant(int id)
     {
         try
         {
@@ -100,7 +100,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(typeof(IEnumerable<UserDto>), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<ActionResult<IEnumerable<UserDto>>> GetTenantUsers(long tenantId)
+    public async Task<ActionResult<IEnumerable<UserDto>>> GetTenantUsers(int tenantId)
     {
         try
         {
@@ -132,7 +132,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(typeof(IEnumerable<object>), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<ActionResult<IEnumerable<object>>> GetTenantRoles(long tenantId)
+    public async Task<ActionResult<IEnumerable<object>>> GetTenantRoles(int tenantId)
     {
         try
         {
@@ -164,7 +164,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(typeof(TenantSettingsDto), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<ActionResult<TenantSettingsDto>> GetTenantSettings(long id)
+    public async Task<ActionResult<TenantSettingsDto>> GetTenantSettings(int id)
     {
         try
         {
@@ -196,7 +196,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(StatusCodes.Status204NoContent)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<IActionResult> UpdateTenantSettings(long id, [FromBody] TenantSettingsDto settings)
+    public async Task<IActionResult> UpdateTenantSettings(int id, [FromBody] TenantSettingsDto settings)
     {
         try
         {
@@ -253,7 +253,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(StatusCodes.Status204NoContent)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<IActionResult> UpdateTenant(long id, [FromBody] UpdateTenantDto dto)
+    public async Task<IActionResult> UpdateTenant(int id, [FromBody] UpdateTenantDto dto)
     {
         try
         {
@@ -284,7 +284,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(StatusCodes.Status204NoContent)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<IActionResult> DeleteTenant(long id)
+    public async Task<IActionResult> DeleteTenant(int id)
     {
         try
         {
@@ -316,7 +316,7 @@ public class TenantsController : ControllerBase
     [ProducesResponseType(typeof(H5LinkResult), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(object), StatusCodes.Status404NotFound)]
     [ProducesResponseType(typeof(object), StatusCodes.Status500InternalServerError)]
-    public async Task<ActionResult<H5LinkResult>> GetH5Link(long id)
+    public async Task<ActionResult<H5LinkResult>> GetH5Link(int id)
     {
         try
         {

Datas/ApplicationDbContext.cs

@@ -1,12 +1,14 @@
 using Fengling.Console.Models.Entities;
 using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore;
+using System.Reflection;
 
 namespace Fengling.Console.Datas;
 
 public class ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
     : IdentityDbContext<ApplicationUser, ApplicationRole, long>(options)
 {
+    public DbSet<Tenant> Tenants { get; set; }
     public DbSet<AccessLog> AccessLogs { get; set; }
     public DbSet<AuditLog> AuditLogs { get; set; }
 
@@ -14,19 +16,13 @@ public class ApplicationDbContext(DbContextOptions<ApplicationDbContext> options
     {
         base.OnModelCreating(builder);
 
+        builder.ApplyConfigurationsFromAssembly(Assembly.GetExecutingAssembly());
+
         builder.Entity<ApplicationUser>(entity =>
         {
             entity.Property(e => e.RealName).HasMaxLength(100);
             entity.Property(e => e.Phone).HasMaxLength(20);
             entity.HasIndex(e => e.Phone).IsUnique();
-
-            entity.OwnsOne(e => e.TenantInfo, navigationBuilder =>
-            {
-                navigationBuilder.Property(e => e.TenantCode).HasColumnName("TenantCode");
-                navigationBuilder.Property(e => e.TenantId).HasColumnName("TenantId");
-                navigationBuilder.Property(e => e.TenantName).HasColumnName("TenantName");
-                navigationBuilder.WithOwner();
-            });
         });
 
         builder.Entity<ApplicationRole>(entity => { entity.Property(e => e.Description).HasMaxLength(200); });

EntityConfigurations/TenantEntityTypeConfiguration.cs

@@ -0,0 +1,36 @@
+namespace Fengling.Console.EntityConfigurations;
+
+using Fengling.Console.Models.Entities;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+public class TenantEntityTypeConfiguration : IEntityTypeConfiguration<Tenant>
+{
+    public void Configure(EntityTypeBuilder<Tenant> builder)
+    {
+        builder.ToTable("Tenants");
+        builder.HasKey(x => x.Id);
+        
+        builder.Property(x => x.Id)
+            .ValueGeneratedOnAdd();
+        
+        builder.Property(x => x.TenantCode)
+            .IsRequired()
+            .HasMaxLength(50);
+            
+        builder.Property(x => x.Name)
+            .IsRequired()
+            .HasMaxLength(100);
+            
+        builder.Property(x => x.ContactName)
+            .IsRequired()
+            .HasMaxLength(50);
+            
+        builder.Property(x => x.ContactEmail)
+            .IsRequired()
+            .HasMaxLength(100);
+            
+        builder.HasIndex(x => x.TenantCode).IsUnique();
+        builder.HasIndex(x => x.Name);
+    }
+}

Managers/TenantManager.cs

@@ -0,0 +1,88 @@
+using Fengling.Console.Models.Entities;
+using Fengling.Console.Stores;
+using Microsoft.AspNetCore.Identity;
+
+namespace Fengling.Console.Managers;
+
+public interface ITenantManager
+{
+    Task<Tenant?> FindByIdAsync(int tenantId, CancellationToken cancellationToken = default);
+    Task<Tenant?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default);
+    Task<IList<Tenant>> GetAllAsync(CancellationToken cancellationToken = default);
+    Task<IList<Tenant>> GetPagedAsync(int page, int pageSize, string? name = null, string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default);
+    Task<int> GetCountAsync(string? name = null, string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default);
+    Task<IdentityResult> CreateAsync(Tenant tenant, CancellationToken cancellationToken = default);
+    Task<IdentityResult> UpdateAsync(Tenant tenant, CancellationToken cancellationToken = default);
+    Task<IdentityResult> DeleteAsync(Tenant tenant, CancellationToken cancellationToken = default);
+    Task<int> GetUserCountAsync(int tenantId, CancellationToken cancellationToken = default);
+    Task<IdentityResult> SetTenantCodeAsync(Tenant tenant, string code, CancellationToken cancellationToken = default);
+}
+
+public class TenantManager : ITenantManager
+{
+    private readonly ITenantStore<Tenant> _store;
+
+    public TenantManager(ITenantStore<Tenant> store)
+    {
+        _store = store;
+    }
+
+    public virtual async Task<Tenant?> FindByIdAsync(int tenantId, CancellationToken cancellationToken = default)
+    {
+        return await _store.FindByIdAsync(tenantId, cancellationToken);
+    }
+
+    public virtual async Task<Tenant?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default)
+    {
+        return await _store.FindByTenantCodeAsync(tenantCode, cancellationToken);
+    }
+
+    public virtual async Task<IList<Tenant>> GetAllAsync(CancellationToken cancellationToken = default)
+    {
+        return await _store.GetAllAsync(cancellationToken);
+    }
+
+    public virtual async Task<IList<Tenant>> GetPagedAsync(int page, int pageSize, string? name = null, 
+        string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default)
+    {
+        return await _store.GetPagedAsync(page, pageSize, name, tenantCode, status, cancellationToken);
+    }
+
+    public virtual async Task<int> GetCountAsync(string? name = null, string? tenantCode = null, 
+        TenantStatus? status = null, CancellationToken cancellationToken = default)
+    {
+        return await _store.GetCountAsync(name, tenantCode, status, cancellationToken);
+    }
+
+    public virtual async Task<IdentityResult> CreateAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        return await _store.CreateAsync(tenant, cancellationToken);
+    }
+
+    public virtual async Task<IdentityResult> UpdateAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        return await _store.UpdateAsync(tenant, cancellationToken);
+    }
+
+    public virtual async Task<IdentityResult> DeleteAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        return await _store.DeleteAsync(tenant, cancellationToken);
+    }
+
+    public virtual async Task<int> GetUserCountAsync(int tenantId, CancellationToken cancellationToken = default)
+    {
+        return await _store.GetUserCountAsync(tenantId, cancellationToken);
+    }
+
+    public virtual async Task<IdentityResult> SetTenantCodeAsync(Tenant tenant, string code, CancellationToken cancellationToken = default)
+    {
+        var existing = await _store.FindByTenantCodeAsync(code, cancellationToken);
+        if (existing != null && existing.Id != tenant.Id)
+        {
+            return IdentityResult.Failed(new IdentityError { Description = "租户编码已存在" });
+        }
+        
+        await _store.SetTenantCodeAsync(tenant, code, cancellationToken);
+        return IdentityResult.Success;
+    }
+}

Models/Dtos/TenantDto.cs

@@ -1,10 +1,10 @@
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
+using Fengling.Console.Models.Entities;
 
 namespace Fengling.Console.Models.Dtos;
 
 public class TenantDto
 {
-    public long Id { get; set; }
+    public int Id { get; set; }
     public string TenantCode { get; set; } = "";
     public string Name { get; set; } = "";
     public string ContactName { get; set; } = "";

Models/Dtos/TenantQueryDto.cs

@@ -1,4 +1,4 @@
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
+using Fengling.Console.Models.Entities;
 
 namespace Fengling.Console.Models.Dtos;
 

Models/Entities/ApplicationRole.cs

@@ -6,7 +6,7 @@ public class ApplicationRole : IdentityRole<long>
 {
     public string? Description { get; set; }
     public DateTime CreatedTime { get; set; } = DateTime.UtcNow;
-    public long? TenantId { get; set; }
+    public int? TenantId { get; set; }
     public bool IsSystem { get; set; }
     public string? DisplayName { get; set; }
     public List<string>? Permissions { get; set; }

Models/Entities/ApplicationUser.cs

@@ -1,4 +1,3 @@
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
 using Microsoft.AspNetCore.Identity;
 
 namespace Fengling.Console.Models.Entities;
@@ -7,7 +6,7 @@ public class ApplicationUser : IdentityUser<long>
 {
     public string? RealName { get; set; }
     public string? Phone { get; set; }
-    public TenantInfo TenantInfo { get; set; } = null!;
+    public int TenantId { get; set; }
     public DateTime CreatedTime { get; set; } = DateTime.UtcNow;
     public DateTime? UpdatedTime { get; set; }
     public bool IsDeleted { get; set; }

Models/Entities/Tenant.cs

@@ -0,0 +1,25 @@
+namespace Fengling.Console.Models.Entities;
+
+public class Tenant
+{
+    public int Id { get; set; }
+    public string TenantCode { get; set; } = string.Empty;
+    public string Name { get; set; } = string.Empty;
+    public string ContactName { get; set; } = string.Empty;
+    public string ContactEmail { get; set; } = string.Empty;
+    public string? ContactPhone { get; set; }
+    public int? MaxUsers { get; set; }
+    public string? Description { get; set; }
+    public TenantStatus Status { get; set; } = TenantStatus.Active;
+    public DateTime? ExpiresAt { get; set; }
+    public DateTime CreatedAt { get; set; } = DateTime.UtcNow;
+    public DateTime? UpdatedAt { get; set; }
+    public bool IsDeleted { get; set; }
+}
+
+public enum TenantStatus
+{
+    Active = 1,
+    Inactive = 2,
+    Frozen = 3
+}

Program.cs

@@ -1,6 +1,8 @@
 using System.Reflection;
 using Fengling.Console.Repositories;
 using Fengling.Console.Services;
+using Fengling.Console.Stores;
+using Fengling.Console.Managers;
 using Fengling.Platform.Infrastructure.Repositories;
 using OpenIddict.Abstractions;
 using Microsoft.EntityFrameworkCore;
@@ -39,9 +41,11 @@ builder.Services.AddHttpContextAccessor();
 builder.Services.AddHttpClient();
 builder.Services.AddScoped<IOAuthClientService, OAuthClientService>();
 builder.Services.AddScoped<IUserRepository, UserRepository>();
-builder.Services.AddScoped<ITenantRepository, TenantRepository>();
 builder.Services.AddScoped<IRoleRepository, RoleRepository>();
 
+builder.Services.AddScoped<ITenantStore<Tenant>, TenantStore>();
+builder.Services.AddScoped<ITenantManager, TenantManager>();
+
 builder.Services.AddScoped<IUserService, UserService>();
 builder.Services.AddScoped<ITenantService, TenantService>();
 builder.Services.AddScoped<IRoleService, RoleService>();

Repositories/UserRepository.cs

@@ -45,7 +45,7 @@ public class UserRepository : IUserRepository
 
         if (!string.IsNullOrEmpty(tenantCode))
         {
-            query = query.Where(u => u.TenantInfo.TenantCode.Contains(tenantCode));
+            query = query.Where(u => u.TenantId.ToString().Contains(tenantCode));
         }
 
         return await query
@@ -71,7 +71,7 @@ public class UserRepository : IUserRepository
 
         if (!string.IsNullOrEmpty(tenantCode))
         {
-            query = query.Where(u => u.TenantInfo.TenantCode.Contains(tenantCode));
+            query = query.Where(u => u.TenantId.ToString().Contains(tenantCode));
         }
 
         return await query.CountAsync();

Services/H5LinkService.cs

@@ -1,15 +1,14 @@
 using Fengling.Console.Models.Entities;
-using Fengling.Console.Repositories;
+using Fengling.Console.Managers;
-using Fengling.Platform.Infrastructure.Repositories;
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
 using Microsoft.Extensions.Configuration;
 using QRCoder;
+using Tenant = Fengling.Console.Models.Entities.Tenant;
 
 namespace Fengling.Console.Services;
 
 public interface IH5LinkService
 {
-    Task<H5LinkResult> GenerateH5LinkAsync(long tenantId);
+    Task<H5LinkResult> GenerateH5LinkAsync(int tenantId);
 }
 
 public class H5LinkResult
@@ -20,18 +19,18 @@ public class H5LinkResult
 
 public class H5LinkService : IH5LinkService
 {
-    private readonly ITenantRepository _tenantRepository;
+    private readonly ITenantManager _tenantManager;
     private readonly IConfiguration _configuration;
 
-    public H5LinkService(ITenantRepository tenantRepository, IConfiguration configuration)
+    public H5LinkService(ITenantManager tenantManager, IConfiguration configuration)
     {
-        _tenantRepository = tenantRepository;
+        _tenantManager = tenantManager;
         _configuration = configuration;
     }
 
-    public async Task<H5LinkResult> GenerateH5LinkAsync(long tenantId)
+    public async Task<H5LinkResult> GenerateH5LinkAsync(int tenantId)
     {
-        var tenant = await _tenantRepository.GetByIdAsync(tenantId)
+        var tenant = await _tenantManager.FindByIdAsync(tenantId)
             ?? throw new KeyNotFoundException($"Tenant with ID {tenantId} not found");
 
         var link = GenerateLink(tenant);

Services/RoleService.cs

@@ -1,5 +1,6 @@
 using Fengling.Console.Models.Dtos;
 using Fengling.Console.Repositories;
+using Fengling.Console.Managers;
 using Microsoft.AspNetCore.Identity;
 using System.Security.Claims;
 using Fengling.Console.Datas;
@@ -24,6 +25,7 @@ public interface IRoleService
 public class RoleService : IRoleService
 {
     private readonly IRoleRepository _repository;
+    private readonly ITenantManager _tenantManager;
     private readonly UserManager<ApplicationUser> _userManager;
     private readonly RoleManager<ApplicationRole> _roleManager;
     private readonly ApplicationDbContext _context;
@@ -31,12 +33,14 @@ public class RoleService : IRoleService
 
     public RoleService(
         IRoleRepository repository,
+        ITenantManager tenantManager,
         UserManager<ApplicationUser> userManager,
         RoleManager<ApplicationRole> roleManager,
         ApplicationDbContext context,
         IHttpContextAccessor httpContextAccessor)
     {
         _repository = repository;
+        _tenantManager = tenantManager;
         _userManager = userManager;
         _roleManager = roleManager;
         _context = context;
@@ -103,14 +107,15 @@ public class RoleService : IRoleService
         foreach (var user in users)
         {
             var roles = await _userManager.GetRolesAsync(user);
+            var tenant = user.TenantId > 0 ? await _tenantManager.FindByIdAsync(user.TenantId) : null;
             userDtos.Add(new UserDto
             {
                 Id = user.Id,
                 UserName = user.UserName,
                 Email = user.Email,
                 RealName = user.RealName,
-                TenantCode = user.TenantInfo.TenantCode,
+                TenantCode = user.TenantId.ToString(),
-                TenantName = user.TenantInfo.TenantName,
+                TenantName = tenant?.Name ?? "",
                 Roles = roles.ToList(),
                 EmailConfirmed = user.EmailConfirmed,
                 IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,
@@ -128,7 +133,7 @@ public class RoleService : IRoleService
             Name = dto.Name,
             DisplayName = dto.DisplayName,
             Description = dto.Description,
-            TenantId = dto.TenantId,
+            TenantId = dto.TenantId.HasValue ? (int?)dto.TenantId.Value : null,
             Permissions = dto.Permissions,
             IsSystem = false,
             CreatedTime = DateTime.UtcNow

Services/TenantService.cs

@@ -1,11 +1,11 @@
+using Fengling.Console.Managers;
 using Fengling.Console.Models.Dtos;
 using Fengling.Console.Repositories;
-using Fengling.Platform.Infrastructure.Repositories;
 using Microsoft.AspNetCore.Identity;
 using System.Security.Claims;
 using Fengling.Console.Datas;
 using Fengling.Console.Models.Entities;
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
+using TenantStatus = Fengling.Console.Models.Entities.TenantStatus;
 
 namespace Fengling.Console.Services;
 
@@ -13,18 +13,18 @@ public interface ITenantService
 {
     Task<(IEnumerable<TenantDto> Items, int TotalCount)> GetTenantsAsync(int page, int pageSize, string? name = null,
         string? tenantCode = null, TenantStatus? status = null);
-    Task<TenantDto?> GetTenantAsync(long id);
+    Task<TenantDto?> GetTenantAsync(int id);
-    Task<IEnumerable<UserDto>> GetTenantUsersAsync(long tenantId);
+    Task<IEnumerable<UserDto>> GetTenantUsersAsync(int tenantId);
-    Task<IEnumerable<object>> GetTenantRolesAsync(long tenantId);
+    Task<IEnumerable<object>> GetTenantRolesAsync(int tenantId);
-    Task<TenantSettingsDto> GetTenantSettingsAsync(long id);
+    Task<TenantSettingsDto> GetTenantSettingsAsync(int id);
-    Task UpdateTenantSettingsAsync(long id, TenantSettingsDto settings);
+    Task UpdateTenantSettingsAsync(int id, TenantSettingsDto settings);
     Task<TenantDto> CreateTenantAsync(CreateTenantDto dto);
-    Task<TenantDto> UpdateTenantAsync(long id, UpdateTenantDto dto);
+    Task<TenantDto> UpdateTenantAsync(int id, UpdateTenantDto dto);
-    Task DeleteTenantAsync(long id);
+    Task DeleteTenantAsync(int id);
 }
 
 public class TenantService(
-    ITenantRepository repository,
+    ITenantManager tenantManager,
     IUserRepository userRepository,
     IRoleRepository roleRepository,
     UserManager<ApplicationUser> userManager,
@@ -35,13 +35,13 @@ public class TenantService(
     public async Task<(IEnumerable<TenantDto> Items, int TotalCount)> GetTenantsAsync
         (int page, int pageSize, string? name = null, string? tenantCode = null, TenantStatus? status = null)
     {
-        var tenants = await repository.GetPagedAsync(page, pageSize, name, tenantCode, status);
+        var tenants = await tenantManager.GetPagedAsync(page, pageSize, name, tenantCode, status);
-        var totalCount = await repository.CountAsync(name, tenantCode, status);
+        var totalCount = await tenantManager.GetCountAsync(name, tenantCode, status);
 
         var tenantDtos = new List<TenantDto>();
         foreach (var tenant in tenants)
         {
-            var userCount = await repository.GetUserCountAsync(tenant.Id);
+            var userCount = await tenantManager.GetUserCountAsync(tenant.Id);
             tenantDtos.Add(new TenantDto
             {
                 Id = tenant.Id,
@@ -62,9 +62,9 @@ public class TenantService(
         return (tenantDtos, totalCount);
     }
 
-    public async Task<TenantDto?> GetTenantAsync(long id)
+    public async Task<TenantDto?> GetTenantAsync(int id)
     {
-        var tenant = await repository.GetByIdAsync(id);
+        var tenant = await tenantManager.FindByIdAsync(id);
         if (tenant == null) return null;
 
         return new TenantDto
@@ -76,7 +76,7 @@ public class TenantService(
             ContactEmail = tenant.ContactEmail,
             ContactPhone = tenant.ContactPhone,
             MaxUsers = tenant.MaxUsers,
-            UserCount = await repository.GetUserCountAsync(tenant.Id),
+            UserCount = await tenantManager.GetUserCountAsync(tenant.Id),
             Status = tenant.Status,
             ExpiresAt = tenant.ExpiresAt,
             Description = tenant.Description,
@@ -84,9 +84,9 @@ public class TenantService(
         };
     }
 
-    public async Task<IEnumerable<UserDto>> GetTenantUsersAsync(long tenantId)
+    public async Task<IEnumerable<UserDto>> GetTenantUsersAsync(int tenantId)
     {
-        var tenant = await repository.GetByIdAsync(tenantId);
+        var tenant = await tenantManager.FindByIdAsync(tenantId);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {tenantId} not found");
@@ -104,8 +104,8 @@ public class TenantService(
                 UserName = user.UserName,
                 Email = user.Email,
                 RealName = user.RealName,
-                TenantCode = user.TenantInfo.TenantCode,
+                TenantCode = user.TenantId.ToString(),
-                TenantName = user.TenantInfo.TenantName,
+                TenantName = tenant?.Name ?? "",
                 Roles = roles.ToList(),
                 EmailConfirmed = user.EmailConfirmed,
                 IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,
@@ -116,9 +116,9 @@ public class TenantService(
         return userDtos;
     }
 
-    public async Task<IEnumerable<object>> GetTenantRolesAsync(long tenantId)
+    public async Task<IEnumerable<object>> GetTenantRolesAsync(int tenantId)
     {
-        var tenant = await repository.GetByIdAsync(tenantId);
+        var tenant = await tenantManager.FindByIdAsync(tenantId);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {tenantId} not found");
@@ -133,9 +133,9 @@ public class TenantService(
         });
     }
 
-    public async Task<TenantSettingsDto> GetTenantSettingsAsync(long id)
+    public async Task<TenantSettingsDto> GetTenantSettingsAsync(int id)
     {
-        var tenant = await repository.GetByIdAsync(id);
+        var tenant = await tenantManager.FindByIdAsync(id);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {id} not found");
@@ -152,9 +152,9 @@ public class TenantService(
         };
     }
 
-    public async Task UpdateTenantSettingsAsync(long id, TenantSettingsDto settings)
+    public async Task UpdateTenantSettingsAsync(int id, TenantSettingsDto settings)
     {
-        var tenant = await repository.GetByIdAsync(id);
+        var tenant = await tenantManager.FindByIdAsync(id);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {id} not found");
@@ -165,10 +165,27 @@ public class TenantService(
 
     public async Task<TenantDto> CreateTenantAsync(CreateTenantDto dto)
     {
-        var tenant = new Tenant(dto.TenantCode, dto.Name, dto.ContactName, dto.ContactEmail, 
+        var tenant = new Tenant
-            dto.ContactPhone,dto.MaxUsers,dto.Description,dto.ExpiresAt);
+        {
+            TenantCode = dto.TenantCode,
+            Name = dto.Name,
+            ContactName = dto.ContactName,
+            ContactEmail = dto.ContactEmail,
+            ContactPhone = dto.ContactPhone,
+            MaxUsers = dto.MaxUsers,
+            Description = dto.Description,
+            ExpiresAt = dto.ExpiresAt,
+            Status = TenantStatus.Active,
+            CreatedAt = DateTime.UtcNow
+        };
 
-        await repository.AddAsync(tenant);
+        var result = await tenantManager.CreateAsync(tenant);
+
+        if (!result.Succeeded)
+        {
+            var errors = string.Join(", ", result.Errors.Select(e => e.Description));
+            throw new InvalidOperationException($"Failed to create tenant: {errors}");
+        }
 
         await CreateAuditLog("tenant", "create", "Tenant", tenant.Id, tenant.Name, null, 
             System.Text.Json.JsonSerializer.Serialize(dto));
@@ -190,9 +207,9 @@ public class TenantService(
         };
     }
 
-    public async Task<TenantDto> UpdateTenantAsync(long id, UpdateTenantDto dto)
+    public async Task<TenantDto> UpdateTenantAsync(int id, UpdateTenantDto dto)
     {
-        var tenant = await repository.GetByIdAsync(id);
+        var tenant = await tenantManager.FindByIdAsync(id);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {id} not found");
@@ -200,9 +217,19 @@ public class TenantService(
 
         var oldValue = System.Text.Json.JsonSerializer.Serialize(tenant);
 
-        tenant.UpdateInfo(dto.Name,dto.ContactName,dto.ContactEmail,dto.ContactPhone);
+        tenant.Name = dto.Name;
+        tenant.ContactName = dto.ContactName;
+        tenant.ContactEmail = dto.ContactEmail;
+        tenant.ContactPhone = dto.ContactPhone;
+        tenant.UpdatedAt = DateTime.UtcNow;
 
-        await repository.UpdateAsync(tenant);
+        var result = await tenantManager.UpdateAsync(tenant);
+
+        if (!result.Succeeded)
+        {
+            var errors = string.Join(", ", result.Errors.Select(e => e.Description));
+            throw new InvalidOperationException($"Failed to update tenant: {errors}");
+        }
 
         await CreateAuditLog("tenant", "update", "Tenant", tenant.Id, tenant.Name, oldValue, 
             System.Text.Json.JsonSerializer.Serialize(tenant));
@@ -216,7 +243,7 @@ public class TenantService(
             ContactEmail = tenant.ContactEmail,
             ContactPhone = tenant.ContactPhone,
             MaxUsers = tenant.MaxUsers,
-            UserCount = await repository.GetUserCountAsync(tenant.Id),
+            UserCount = await tenantManager.GetUserCountAsync(tenant.Id),
             Status = tenant.Status,
             ExpiresAt = tenant.ExpiresAt,
             Description = tenant.Description,
@@ -224,9 +251,9 @@ public class TenantService(
         };
     }
 
-    public async Task DeleteTenantAsync(long id)
+    public async Task DeleteTenantAsync(int id)
     {
-        var tenant = await repository.GetByIdAsync(id);
+        var tenant = await tenantManager.FindByIdAsync(id);
         if (tenant == null)
         {
             throw new KeyNotFoundException($"Tenant with ID {id} not found");
@@ -242,26 +269,32 @@ public class TenantService(
             await context.SaveChangesAsync();
         }
 
-        tenant.Delete();;
+        tenant.IsDeleted = true;
-        await repository.UpdateAsync(tenant);
+        var result = await tenantManager.UpdateAsync(tenant);
+
+        if (!result.Succeeded)
+        {
+            var errors = string.Join(", ", result.Errors.Select(e => e.Description));
+            throw new InvalidOperationException($"Failed to delete tenant: {errors}");
+        }
 
         await CreateAuditLog("tenant", "delete", "Tenant", tenant.Id, tenant.Name, oldValue);
     }
 
-    private async Task CreateAuditLog(string operation, string action, string targetType, long? targetId, string? targetName, string? oldValue = null, string? newValue = null)
+    private async Task CreateAuditLog(string operation, string action, string targetType, int? targetId, string? targetName, string? oldValue = null, string? newValue = null)
     {
         var httpContext = httpContextAccessor.HttpContext;
         var userName = httpContext?.User?.FindFirstValue(ClaimTypes.NameIdentifier) ?? httpContext?.User?.Identity?.Name ?? "system";
-        var tenantId = httpContext?.User?.FindFirstValue("TenantId");
+        var tenantIdClaim = httpContext?.User?.FindFirstValue("TenantId");
 
         var log = new AuditLog
         {
             Operator = userName,
-            TenantId = tenantId,
+            TenantId = tenantIdClaim,
             Operation = operation,
             Action = action,
             TargetType = targetType,
-            TargetId = targetId,
+            TargetId = targetId.HasValue ? (long)targetId.Value : null,
             TargetName = targetName,
             IpAddress = httpContext?.Connection?.RemoteIpAddress?.ToString() ?? "unknown",
             Status = "success",

Services/UserService.cs

@@ -1,11 +1,11 @@
 using Fengling.Console.Models.Dtos;
 using Fengling.Console.Repositories;
-using Fengling.Platform.Infrastructure.Repositories;
+using Fengling.Console.Managers;
 using Microsoft.AspNetCore.Identity;
 using System.Security.Claims;
 using Fengling.Console.Datas;
 using Fengling.Console.Models.Entities;
-using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
+using Tenant = Fengling.Console.Models.Entities.Tenant;
 
 namespace Fengling.Console.Services;
 
@@ -21,7 +21,7 @@ public interface IUserService
 
 public class UserService(
     IUserRepository repository,
-    ITenantRepository tenantRepository,
+    ITenantManager tenantManager,
     UserManager<ApplicationUser> userManager,
     RoleManager<ApplicationRole> roleManager,
     ApplicationDbContext context,
@@ -37,6 +37,7 @@ public class UserService(
         foreach (var user in users)
         {
             var roles = await userManager.GetRolesAsync(user);
+            var tenant = user.TenantId > 0 ? await tenantManager.FindByIdAsync(user.TenantId) : null;
             userDtos.Add(new UserDto
             {
                 Id = user.Id,
@@ -44,8 +45,8 @@ public class UserService(
                 Email = user.Email,
                 RealName = user.RealName,
                 Phone = user.Phone,
-                TenantCode = user.TenantInfo.TenantCode,
+                TenantCode = user.TenantId.ToString(),
-                TenantName = user.TenantInfo.TenantName,
+                TenantName = tenant?.Name ?? "",
                 Roles = roles.ToList(),
                 EmailConfirmed = user.EmailConfirmed,
                 IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,
@@ -62,6 +63,7 @@ public class UserService(
         if (user == null) return null;
 
         var roles = await userManager.GetRolesAsync(user);
+        var tenant = user.TenantId > 0 ? await tenantManager.FindByIdAsync(user.TenantId) : null;
         return new UserDto
         {
             Id = user.Id,
@@ -69,8 +71,8 @@ public class UserService(
             Email = user.Email,
             RealName = user.RealName,
             Phone = user.Phone,
-            TenantCode = user.TenantInfo.TenantCode,
+            TenantCode = user.TenantId.ToString(),
-            TenantName = user.TenantInfo.TenantName,
+            TenantName = tenant?.Name ?? "",
             Roles = roles.ToList(),
             EmailConfirmed = user.EmailConfirmed,
             IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,
@@ -80,12 +82,12 @@ public class UserService(
 
     public async Task<UserDto> CreateUserAsync(CreateUserDto dto)
     {
-        var tenantId = dto.TenantId ?? 0;
+        var tenantId = dto.TenantId.HasValue ? (int)dto.TenantId.Value : 0;
         Tenant? tenant = null;
 
         if (tenantId != 0)
         {
-            tenant = await tenantRepository.GetByIdAsync(tenantId);
+            tenant = await tenantManager.FindByIdAsync(tenantId);
             if (tenant == null)
             {
                 throw new InvalidOperationException("Invalid tenant ID");
@@ -98,7 +100,7 @@ public class UserService(
             Email = dto.Email,
             RealName = dto.RealName,
             Phone = dto.Phone,
-            TenantInfo = new TenantInfo(tenant!),
+            TenantId = tenant?.Id ?? 0,
             EmailConfirmed = dto.EmailConfirmed,
             CreatedTime = DateTime.UtcNow
         };
@@ -137,8 +139,8 @@ public class UserService(
             Email = user.Email,
             RealName = user.RealName,
             Phone = user.Phone,
-            TenantCode = user.TenantInfo.TenantCode,
+            TenantCode = user.TenantId.ToString(),
-            TenantName = user.TenantInfo.TenantName,
+            TenantName = tenant?.Name ?? "",
             Roles = roles.ToList(),
             EmailConfirmed = user.EmailConfirmed,
             IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,
@@ -175,6 +177,8 @@ public class UserService(
 
         await context.SaveChangesAsync();
 
+        var tenant = user.TenantId > 0 ? await tenantManager.FindByIdAsync(user.TenantId) : null;
+
         await CreateAuditLog("user", "update", "User", user.Id, user.UserName, oldValue, System.Text.Json.JsonSerializer.Serialize(user));
 
         var roles = await userManager.GetRolesAsync(user);
@@ -185,8 +189,8 @@ public class UserService(
             Email = user.Email,
             RealName = user.RealName,
             Phone = user.Phone,
-            TenantCode = user.TenantInfo.TenantCode,
+            TenantCode = user.TenantId.ToString(),
-            TenantName = user.TenantInfo.TenantName,
+            TenantName = tenant?.Name ?? "",
             Roles = roles.ToList(),
             EmailConfirmed = user.EmailConfirmed,
             IsActive = !user.LockoutEnabled || user.LockoutEnd == null || user.LockoutEnd < DateTimeOffset.UtcNow,

Stores/ITenantStore.cs

@@ -0,0 +1,41 @@
+using Fengling.Console.Models.Entities;
+using Microsoft.AspNetCore.Identity;
+
+namespace Fengling.Console.Stores;
+
+public interface ITenantStore<TTenant> : IDisposable where TTenant : class
+{
+    Task<TTenant?> FindByIdAsync(int tenantId, CancellationToken cancellationToken = default);
+    Task<TTenant?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default);
+    Task<IList<TTenant>> GetAllAsync(CancellationToken cancellationToken = default);
+    Task<IList<TTenant>> GetPagedAsync(int page, int pageSize, string? name = null, string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default);
+    Task<int> GetCountAsync(string? name = null, string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default);
+    Task<IdentityResult> CreateAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<IdentityResult> UpdateAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<IdentityResult> DeleteAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<int> GetUserCountAsync(int tenantId, CancellationToken cancellationToken = default);
+    
+    Task<string> GetTenantCodeAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<string> GetNameAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<string> GetContactNameAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<string> GetContactEmailAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<string?> GetContactPhoneAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<int?> GetMaxUsersAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<string?> GetDescriptionAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<TenantStatus> GetStatusAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<DateTime?> GetExpiresAtAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<DateTime> GetCreatedAtAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<DateTime?> GetUpdatedAtAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    Task<bool> GetIsDeletedAsync(TTenant tenant, CancellationToken cancellationToken = default);
+    
+    Task SetTenantCodeAsync(TTenant tenant, string code, CancellationToken cancellationToken = default);
+    Task SetNameAsync(TTenant tenant, string name, CancellationToken cancellationToken = default);
+    Task SetContactNameAsync(TTenant tenant, string name, CancellationToken cancellationToken = default);
+    Task SetContactEmailAsync(TTenant tenant, string email, CancellationToken cancellationToken = default);
+    Task SetContactPhoneAsync(TTenant tenant, string? phone, CancellationToken cancellationToken = default);
+    Task SetMaxUsersAsync(TTenant tenant, int? maxUsers, CancellationToken cancellationToken = default);
+    Task SetDescriptionAsync(TTenant tenant, string? description, CancellationToken cancellationToken = default);
+    Task SetStatusAsync(TTenant tenant, TenantStatus status, CancellationToken cancellationToken = default);
+    Task SetExpiresAtAsync(TTenant tenant, DateTime? expiresAt, CancellationToken cancellationToken = default);
+    Task SetIsDeletedAsync(TTenant tenant, bool isDeleted, CancellationToken cancellationToken = default);
+}

Stores/TenantStore.cs

@@ -0,0 +1,196 @@
+using Fengling.Console.Datas;
+using Fengling.Console.Models.Entities;
+using Microsoft.AspNetCore.Identity;
+using Microsoft.EntityFrameworkCore;
+
+namespace Fengling.Console.Stores;
+
+public class TenantStore : ITenantStore<Tenant>
+{
+    private readonly ApplicationDbContext _context;
+    private readonly DbSet<Tenant> _tenants;
+
+    public TenantStore(ApplicationDbContext context)
+    {
+        _context = context;
+        _tenants = context.Tenants;
+    }
+
+    public void Dispose() { }
+
+    public virtual Task<Tenant?> FindByIdAsync(int tenantId, CancellationToken cancellationToken = default)
+    {
+        return _tenants.FirstOrDefaultAsync(t => t.Id == tenantId, cancellationToken);
+    }
+
+    public virtual Task<Tenant?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default)
+    {
+        return _tenants.FirstOrDefaultAsync(t => t.TenantCode == tenantCode, cancellationToken);
+    }
+
+    public virtual async Task<IList<Tenant>> GetAllAsync(CancellationToken cancellationToken = default)
+    {
+        return (IList<Tenant>)await _tenants.ToListAsync(cancellationToken);
+    }
+
+    public virtual async Task<IList<Tenant>> GetPagedAsync(int page, int pageSize, string? name = null, 
+        string? tenantCode = null, TenantStatus? status = null, CancellationToken cancellationToken = default)
+    {
+        var query = _tenants.AsQueryable();
+
+        if (!string.IsNullOrEmpty(name))
+            query = query.Where(t => t.Name.Contains(name));
+
+        if (!string.IsNullOrEmpty(tenantCode))
+            query = query.Where(t => t.TenantCode.Contains(tenantCode));
+
+        if (status.HasValue)
+            query = query.Where(t => t.Status == status);
+
+        return await query
+            .OrderByDescending(t => t.CreatedAt)
+            .Skip((page - 1) * pageSize)
+            .Take(pageSize)
+            .ToListAsync(cancellationToken);
+    }
+
+    public virtual async Task<int> GetCountAsync(string? name = null, string? tenantCode = null, 
+        TenantStatus? status = null, CancellationToken cancellationToken = default)
+    {
+        var query = _tenants.AsQueryable();
+
+        if (!string.IsNullOrEmpty(name))
+            query = query.Where(t => t.Name.Contains(name));
+
+        if (!string.IsNullOrEmpty(tenantCode))
+            query = query.Where(t => t.TenantCode.Contains(tenantCode));
+
+        if (status.HasValue)
+            query = query.Where(t => t.Status == status);
+
+        return await query.CountAsync(cancellationToken);
+    }
+
+    public virtual async Task<IdentityResult> CreateAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        _tenants.Add(tenant);
+        await _context.SaveChangesAsync(cancellationToken);
+        return IdentityResult.Success;
+    }
+
+    public virtual async Task<IdentityResult> UpdateAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        tenant.UpdatedAt = DateTime.UtcNow;
+        _tenants.Update(tenant);
+        await _context.SaveChangesAsync(cancellationToken);
+        return IdentityResult.Success;
+    }
+
+    public virtual async Task<IdentityResult> DeleteAsync(Tenant tenant, CancellationToken cancellationToken = default)
+    {
+        _tenants.Remove(tenant);
+        await _context.SaveChangesAsync(cancellationToken);
+        return IdentityResult.Success;
+    }
+
+    public virtual async Task<int> GetUserCountAsync(int tenantId, CancellationToken cancellationToken = default)
+    {
+        return await _context.Users.CountAsync(u => u.TenantId == tenantId && !u.IsDeleted, cancellationToken);
+    }
+
+    public virtual Task<string> GetTenantCodeAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.TenantCode);
+    
+    public virtual Task<string> GetNameAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.Name);
+    
+    public virtual Task<string> GetContactNameAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.ContactName);
+    
+    public virtual Task<string> GetContactEmailAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.ContactEmail);
+    
+    public virtual Task<string?> GetContactPhoneAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.ContactPhone);
+    
+    public virtual Task<int?> GetMaxUsersAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.MaxUsers);
+    
+    public virtual Task<string?> GetDescriptionAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.Description);
+    
+    public virtual Task<TenantStatus> GetStatusAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.Status);
+    
+    public virtual Task<DateTime?> GetExpiresAtAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.ExpiresAt);
+    
+    public virtual Task<DateTime> GetCreatedAtAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.CreatedAt);
+    
+    public virtual Task<DateTime?> GetUpdatedAtAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.UpdatedAt);
+    
+    public virtual Task<bool> GetIsDeletedAsync(Tenant tenant, CancellationToken cancellationToken = default)
+        => Task.FromResult(tenant.IsDeleted);
+
+    public virtual Task SetTenantCodeAsync(Tenant tenant, string code, CancellationToken cancellationToken = default)
+    {
+        tenant.TenantCode = code;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetNameAsync(Tenant tenant, string name, CancellationToken cancellationToken = default)
+    {
+        tenant.Name = name;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetContactNameAsync(Tenant tenant, string name, CancellationToken cancellationToken = default)
+    {
+        tenant.ContactName = name;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetContactEmailAsync(Tenant tenant, string email, CancellationToken cancellationToken = default)
+    {
+        tenant.ContactEmail = email;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetContactPhoneAsync(Tenant tenant, string? phone, CancellationToken cancellationToken = default)
+    {
+        tenant.ContactPhone = phone;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetMaxUsersAsync(Tenant tenant, int? maxUsers, CancellationToken cancellationToken = default)
+    {
+        tenant.MaxUsers = maxUsers;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetDescriptionAsync(Tenant tenant, string? description, CancellationToken cancellationToken = default)
+    {
+        tenant.Description = description;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetStatusAsync(Tenant tenant, TenantStatus status, CancellationToken cancellationToken = default)
+    {
+        tenant.Status = status;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetExpiresAtAsync(Tenant tenant, DateTime? expiresAt, CancellationToken cancellationToken = default)
+    {
+        tenant.ExpiresAt = expiresAt;
+        return Task.CompletedTask;
+    }
+
+    public virtual Task SetIsDeletedAsync(Tenant tenant, bool isDeleted, CancellationToken cancellationToken = default)
+    {
+        tenant.IsDeleted = isDeleted;
+        return Task.CompletedTask;
+    }
+}