Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b66b231917 | ||
|
|
61c18916eb | ||
|
|
021f464c0d | ||
|
|
b9bf925c45 |
@ -34,4 +34,11 @@ public class GwDestination
|
||||
/// 状态
|
||||
/// </summary>
|
||||
public int Status { get; set; } = 1;
|
||||
|
||||
/// <summary>
|
||||
/// 租户代码,用于区分租户专属目标
|
||||
/// null 或空字符串表示默认目标(所有租户共享)
|
||||
/// 有值表示该目标专属于指定租户
|
||||
/// </summary>
|
||||
public string? TenantCode { get; set; }
|
||||
}
|
||||
|
||||
@ -1,16 +1,12 @@
|
||||
namespace Fengling.Platform.Domain.AggregatesModel.GatewayAggregate;
|
||||
|
||||
/// <summary>
|
||||
/// 网关租户路由实体 - 表示路由规则配置
|
||||
/// 网关路由实体 - 表示全局路由规则配置
|
||||
/// </summary>
|
||||
public class GwTenantRoute
|
||||
public class GwRoute
|
||||
{
|
||||
public string Id { get; set; } = Guid.CreateVersion7().ToString("N");
|
||||
|
||||
/// <summary>
|
||||
/// 租户代码
|
||||
/// </summary>
|
||||
public string TenantCode { get; set; } = string.Empty;
|
||||
|
||||
/// <summary>
|
||||
/// 服务名称
|
||||
@ -67,10 +63,6 @@ public class GwTenantRoute
|
||||
/// </summary>
|
||||
public int Status { get; set; } = 1;
|
||||
|
||||
/// <summary>
|
||||
/// 是否全局路由
|
||||
/// </summary>
|
||||
public bool IsGlobal { get; set; } = false;
|
||||
|
||||
/// <summary>
|
||||
/// 创建人ID
|
||||
@ -1,3 +1,7 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using System.ComponentModel.DataAnnotations.Schema;
|
||||
using System.Text.Json.Serialization;
|
||||
|
||||
namespace Fengling.Platform.Domain.AggregatesModel.GatewayAggregate;
|
||||
|
||||
/// <summary>
|
||||
@ -24,11 +28,15 @@ public class GwRouteMatch
|
||||
/// <summary>
|
||||
/// Header 匹配规则
|
||||
/// </summary>
|
||||
[NotMapped]
|
||||
[JsonInclude]
|
||||
public List<GwRouteHeader>? Headers { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 查询参数匹配规则
|
||||
/// </summary>
|
||||
[NotMapped]
|
||||
[JsonInclude]
|
||||
public List<GwRouteQueryParameter>? QueryParameters { get; set; }
|
||||
}
|
||||
|
||||
|
||||
@ -6,6 +6,8 @@
|
||||
<Nullable>enable</Nullable>
|
||||
<ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
|
||||
<EnableDefaultEmbeddedResourceItems>false</EnableDefaultEmbeddedResourceItems>
|
||||
<Version>1.0.0</Version>
|
||||
<PackageVersion>1.0.0</PackageVersion>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
|
||||
@ -9,10 +9,9 @@ namespace Fengling.Platform.Infrastructure;
|
||||
/// </summary>
|
||||
public interface IRouteManager
|
||||
{
|
||||
Task<GwTenantRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default);
|
||||
Task<GwTenantRoute?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default);
|
||||
Task<IList<GwTenantRoute>> GetAllAsync(CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> CreateRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> UpdateRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> DeleteRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<GwRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default);
|
||||
Task<IList<GwRoute>> GetAllAsync(CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> CreateRouteAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> UpdateRouteAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> DeleteRouteAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
}
|
||||
|
||||
@ -9,15 +9,14 @@ namespace Fengling.Platform.Infrastructure;
|
||||
/// </summary>
|
||||
public interface IRouteStore
|
||||
{
|
||||
Task<GwTenantRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default);
|
||||
Task<GwTenantRoute?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default);
|
||||
Task<GwTenantRoute?> FindByClusterIdAsync(string clusterId, CancellationToken cancellationToken = default);
|
||||
Task<IList<GwTenantRoute>> GetAllAsync(CancellationToken cancellationToken = default);
|
||||
Task<IList<GwTenantRoute>> GetPagedAsync(int page, int pageSize, string? tenantCode = null,
|
||||
Task<GwRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default);
|
||||
Task<GwRoute?> FindByClusterIdAsync(string clusterId, CancellationToken cancellationToken = default);
|
||||
Task<IList<GwRoute>> GetAllAsync(CancellationToken cancellationToken = default);
|
||||
Task<IList<GwRoute>> GetPagedAsync(int page, int pageSize,
|
||||
string? serviceName = null, RouteStatus? status = null, CancellationToken cancellationToken = default);
|
||||
Task<int> GetCountAsync(string? tenantCode = null, string? serviceName = null,
|
||||
Task<int> GetCountAsync(string? serviceName = null,
|
||||
RouteStatus? status = null, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> CreateAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> UpdateAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> DeleteAsync(GwTenantRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> CreateAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> UpdateAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
Task<IdentityResult> DeleteAsync(GwRoute route, CancellationToken cancellationToken = default);
|
||||
}
|
||||
|
||||
@ -4,6 +4,9 @@ using Fengling.Platform.Domain.AggregatesModel.TenantAggregate;
|
||||
using Fengling.Platform.Domain.AggregatesModel.UserAggregate;
|
||||
using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.EntityFrameworkCore.ChangeTracking;
|
||||
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
|
||||
using System.Text.Json;
|
||||
|
||||
namespace Fengling.Platform.Infrastructure;
|
||||
|
||||
@ -15,7 +18,7 @@ public class PlatformDbContext(DbContextOptions options)
|
||||
public DbSet<AuditLog> AuditLogs => Set<AuditLog>();
|
||||
|
||||
// Gateway 实体
|
||||
public DbSet<GwTenantRoute> GwTenantRoutes => Set<GwTenantRoute>();
|
||||
public DbSet<GwRoute> GwRoutes => Set<GwRoute>();
|
||||
public DbSet<GwCluster> GwClusters => Set<GwCluster>();
|
||||
|
||||
protected override void OnModelCreating(ModelBuilder modelBuilder)
|
||||
@ -25,6 +28,12 @@ public class PlatformDbContext(DbContextOptions options)
|
||||
throw new ArgumentNullException(nameof(modelBuilder));
|
||||
}
|
||||
|
||||
// 忽略这些类型,让它们只作为 JSON 值对象使用
|
||||
modelBuilder.Ignore<GwRouteMatch>();
|
||||
modelBuilder.Ignore<GwRouteHeader>();
|
||||
modelBuilder.Ignore<GwRouteQueryParameter>();
|
||||
modelBuilder.Ignore<GwTransform>();
|
||||
|
||||
modelBuilder.Entity<ApplicationUser>(entity =>
|
||||
{
|
||||
entity.Property(e => e.PhoneNumber).HasMaxLength(20);
|
||||
@ -82,10 +91,10 @@ public class PlatformDbContext(DbContextOptions options)
|
||||
});
|
||||
|
||||
// Gateway 实体配置
|
||||
modelBuilder.Entity<GwTenantRoute>(entity =>
|
||||
modelBuilder.Entity<GwRoute>(entity =>
|
||||
{
|
||||
entity.ToTable("GwRoutes");
|
||||
entity.HasKey(e => e.Id);
|
||||
entity.Property(e => e.TenantCode).HasMaxLength(50);
|
||||
entity.Property(e => e.ServiceName).HasMaxLength(100).IsRequired();
|
||||
entity.Property(e => e.ClusterId).HasMaxLength(100).IsRequired();
|
||||
entity.Property(e => e.AuthorizationPolicy).HasMaxLength(100);
|
||||
@ -100,27 +109,38 @@ public class PlatformDbContext(DbContextOptions options)
|
||||
)
|
||||
.HasMaxLength(50);
|
||||
|
||||
// 值对象映射为 JSON 列
|
||||
entity.OwnsOne(e => e.Match, navigationBuilder =>
|
||||
{
|
||||
navigationBuilder.ToJson();
|
||||
});
|
||||
// 值对象映射为 JSON 列 - 使用值转换器
|
||||
var jsonOptions = new JsonSerializerOptions { PropertyNamingPolicy = JsonNamingPolicy.CamelCase };
|
||||
entity.Property(e => e.Match)
|
||||
.HasConversion(
|
||||
v => JsonSerializer.Serialize(v, jsonOptions),
|
||||
v => JsonSerializer.Deserialize<GwRouteMatch>(v, jsonOptions)!,
|
||||
new ValueComparer<GwRouteMatch>(
|
||||
(c1, c2) => JsonSerializer.Serialize(c1, jsonOptions) == JsonSerializer.Serialize(c2, jsonOptions),
|
||||
c => c == null ? 0 : JsonSerializer.Serialize(c, jsonOptions).GetHashCode(),
|
||||
c => JsonSerializer.Deserialize<GwRouteMatch>(JsonSerializer.Serialize(c, jsonOptions), jsonOptions)!))
|
||||
.HasColumnType("jsonb");
|
||||
|
||||
// 转换规则映射为 JSON 列
|
||||
entity.OwnsMany(e => e.Transforms, navigationBuilder =>
|
||||
{
|
||||
navigationBuilder.ToJson();
|
||||
});
|
||||
// 转换规则映射为 JSON 列 - 使用值转换器
|
||||
entity.Property(e => e.Transforms)
|
||||
.HasConversion(
|
||||
v => JsonSerializer.Serialize(v, jsonOptions),
|
||||
v => JsonSerializer.Deserialize<List<GwTransform>>(v, jsonOptions),
|
||||
new ValueComparer<List<GwTransform>>(
|
||||
(c1, c2) => JsonSerializer.Serialize(c1, jsonOptions) == JsonSerializer.Serialize(c2, jsonOptions),
|
||||
c => c == null ? 0 : JsonSerializer.Serialize(c, jsonOptions).GetHashCode(),
|
||||
c => JsonSerializer.Deserialize<List<GwTransform>>(JsonSerializer.Serialize(c, jsonOptions), jsonOptions)!))
|
||||
.HasColumnType("jsonb");
|
||||
|
||||
entity.HasIndex(e => e.TenantCode);
|
||||
entity.HasIndex(e => e.ServiceName);
|
||||
entity.HasIndex(e => e.ClusterId);
|
||||
entity.HasIndex(e => new { e.ServiceName, e.IsGlobal, e.Status });
|
||||
entity.HasIndex(e => new { e.ServiceName, e.Status });
|
||||
});
|
||||
|
||||
// GwCluster 聚合根配置
|
||||
modelBuilder.Entity<GwCluster>(entity =>
|
||||
{
|
||||
entity.ToTable("ServiceInstances");
|
||||
entity.HasKey(e => e.Id);
|
||||
entity.Property(e => e.ClusterId).HasMaxLength(100).IsRequired();
|
||||
entity.Property(e => e.Name).HasMaxLength(100).IsRequired();
|
||||
|
||||
@ -15,24 +15,21 @@ public class RouteManager : IRouteManager
|
||||
_store = store;
|
||||
}
|
||||
|
||||
public virtual Task<GwTenantRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default)
|
||||
public virtual Task<GwRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default)
|
||||
=> _store.FindByIdAsync(id, cancellationToken);
|
||||
|
||||
public virtual Task<GwTenantRoute?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default)
|
||||
=> _store.FindByTenantCodeAsync(tenantCode, cancellationToken);
|
||||
|
||||
public virtual Task<IList<GwTenantRoute>> GetAllAsync(CancellationToken cancellationToken = default)
|
||||
public virtual Task<IList<GwRoute>> GetAllAsync(CancellationToken cancellationToken = default)
|
||||
=> _store.GetAllAsync(cancellationToken);
|
||||
|
||||
public virtual Task<IdentityResult> CreateRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual Task<IdentityResult> CreateRouteAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
{
|
||||
route.CreatedTime = DateTime.UtcNow;
|
||||
return _store.CreateAsync(route, cancellationToken);
|
||||
}
|
||||
|
||||
public virtual Task<IdentityResult> UpdateRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual Task<IdentityResult> UpdateRouteAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
=> _store.UpdateAsync(route, cancellationToken);
|
||||
|
||||
public virtual Task<IdentityResult> DeleteRouteAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual Task<IdentityResult> DeleteRouteAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
=> _store.DeleteAsync(route, cancellationToken);
|
||||
}
|
||||
|
||||
@ -11,45 +11,37 @@ public class RouteStore<TContext> : IRouteStore
|
||||
where TContext : PlatformDbContext
|
||||
{
|
||||
private readonly TContext _context;
|
||||
private readonly DbSet<GwTenantRoute> _routes;
|
||||
private readonly DbSet<GwRoute> _routes;
|
||||
|
||||
public RouteStore(TContext context)
|
||||
{
|
||||
_context = context;
|
||||
_routes = context.GwTenantRoutes;
|
||||
_routes = context.GwRoutes;
|
||||
}
|
||||
|
||||
public void Dispose() { }
|
||||
|
||||
public virtual Task<GwTenantRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default)
|
||||
public virtual Task<GwRoute?> FindByIdAsync(string? id, CancellationToken cancellationToken = default)
|
||||
{
|
||||
if (id == null) return Task.FromResult<GwTenantRoute?>(null);
|
||||
if (id == null) return Task.FromResult<GwRoute?>(null);
|
||||
return _routes.FirstOrDefaultAsync(r => r.Id == id, cancellationToken);
|
||||
}
|
||||
|
||||
public virtual Task<GwTenantRoute?> FindByTenantCodeAsync(string tenantCode, CancellationToken cancellationToken = default)
|
||||
{
|
||||
return _routes.FirstOrDefaultAsync(r => r.TenantCode == tenantCode && !r.IsDeleted, cancellationToken);
|
||||
}
|
||||
|
||||
public virtual Task<GwTenantRoute?> FindByClusterIdAsync(string clusterId, CancellationToken cancellationToken = default)
|
||||
public virtual Task<GwRoute?> FindByClusterIdAsync(string clusterId, CancellationToken cancellationToken = default)
|
||||
{
|
||||
return _routes.FirstOrDefaultAsync(r => r.ClusterId == clusterId && !r.IsDeleted, cancellationToken);
|
||||
}
|
||||
|
||||
public virtual async Task<IList<GwTenantRoute>> GetAllAsync(CancellationToken cancellationToken = default)
|
||||
public virtual async Task<IList<GwRoute>> GetAllAsync(CancellationToken cancellationToken = default)
|
||||
{
|
||||
return await _routes.Where(r => !r.IsDeleted).ToListAsync(cancellationToken);
|
||||
}
|
||||
|
||||
public virtual async Task<IList<GwTenantRoute>> GetPagedAsync(int page, int pageSize, string? tenantCode = null,
|
||||
public virtual async Task<IList<GwRoute>> GetPagedAsync(int page, int pageSize,
|
||||
string? serviceName = null, RouteStatus? status = null, CancellationToken cancellationToken = default)
|
||||
{
|
||||
var query = _routes.AsQueryable();
|
||||
|
||||
if (!string.IsNullOrEmpty(tenantCode))
|
||||
query = query.Where(r => r.TenantCode.Contains(tenantCode));
|
||||
|
||||
if (!string.IsNullOrEmpty(serviceName))
|
||||
query = query.Where(r => r.ServiceName.Contains(serviceName));
|
||||
|
||||
@ -64,14 +56,11 @@ public class RouteStore<TContext> : IRouteStore
|
||||
.ToListAsync(cancellationToken);
|
||||
}
|
||||
|
||||
public virtual async Task<int> GetCountAsync(string? tenantCode = null, string? serviceName = null,
|
||||
public virtual async Task<int> GetCountAsync(string? serviceName = null,
|
||||
RouteStatus? status = null, CancellationToken cancellationToken = default)
|
||||
{
|
||||
var query = _routes.AsQueryable();
|
||||
|
||||
if (!string.IsNullOrEmpty(tenantCode))
|
||||
query = query.Where(r => r.TenantCode.Contains(tenantCode));
|
||||
|
||||
if (!string.IsNullOrEmpty(serviceName))
|
||||
query = query.Where(r => r.ServiceName.Contains(serviceName));
|
||||
|
||||
@ -81,14 +70,14 @@ public class RouteStore<TContext> : IRouteStore
|
||||
return await query.Where(r => !r.IsDeleted).CountAsync(cancellationToken);
|
||||
}
|
||||
|
||||
public virtual async Task<IdentityResult> CreateAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual async Task<IdentityResult> CreateAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
{
|
||||
_routes.Add(route);
|
||||
await _context.SaveChangesAsync(cancellationToken);
|
||||
return IdentityResult.Success;
|
||||
}
|
||||
|
||||
public virtual async Task<IdentityResult> UpdateAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual async Task<IdentityResult> UpdateAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
{
|
||||
route.UpdatedTime = DateTime.UtcNow;
|
||||
_routes.Update(route);
|
||||
@ -96,7 +85,7 @@ public class RouteStore<TContext> : IRouteStore
|
||||
return IdentityResult.Success;
|
||||
}
|
||||
|
||||
public virtual async Task<IdentityResult> DeleteAsync(GwTenantRoute route, CancellationToken cancellationToken = default)
|
||||
public virtual async Task<IdentityResult> DeleteAsync(GwRoute route, CancellationToken cancellationToken = default)
|
||||
{
|
||||
// 软删除
|
||||
route.IsDeleted = true;
|
||||
|
||||
Loading…
Reference in New Issue
Block a user