young
/
Infrastructure
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor projects

Browse Source
master
Young 7 months ago
parent 206595fb64
commit 4f6aaa638f
22 changed files with 375 additions and 419 deletions
Show Stats Download Patch File Download Diff File

1
src/Infrastructure.Tests/GlobalUsing.cs
Unescape View File

@ -13,7 +13,6 @@ global using System.Text.Json;
global using System.Threading;
global using Moq;
global using Infrastructure.Middlewares;
global using Infrastructure.Utils;
global using Microsoft.AspNetCore.Builder;
global using Microsoft.AspNetCore.Hosting;
global using Microsoft.AspNetCore.TestHost;

2
src/Infrastructure.Tests/MiddlewareTests.cs
Unescape View File

@ -1,3 +1,5 @@
using Infrastructure.Extensions;
namespace Infrastructure.Tests;
public class MiddlewareTests

75
src/Infrastructure/Extensions/AuthenticationSetup.cs
Unescape View File

@ -1,75 +0,0 @@
using System.Security.Claims;
using Infrastructure.Options;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.IdentityModel.Tokens;
namespace Infrastructure.Extensions;
public static class AuthenticationSetup
{
/// <summary>
/// 配置认证服务，包含jwt认证
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="builderOptions">自定义认证服务配置</param>
/// <param name="configureAuthenticationOptions">配置认证选项</param>
/// <param name="configureJwtBearerOptions">配置jwt认证选项</param>
/// <returns></returns>
public static IServiceCollection AddDefaultAuthentication(
this IServiceCollection services,
IConfiguration configuration,
Action<AuthenticationBuilder>? builderOptions = null,
Action<AuthenticationOptions>? configureAuthenticationOptions = null,
Action<JwtBearerOptions>? configureJwtBearerOptions = null)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var audienceOptions = configuration.GetSection(AudienceOptions.Name).Get<AudienceOptions>();
if (audienceOptions is null || !audienceOptions.IsEnable)
{
return services;
}
services.TryAddSingleton<IPostConfigureOptions<JwtBearerOptions>, JwtBearerOptionsPostConfigureOptions>();
var key = configuration["AUDIENCE_KEY"] ?? audienceOptions.Secret;
ArgumentException.ThrowIfNullOrEmpty(key);
var buffer = Encoding.UTF8.GetBytes(key);
var securityKey = new SymmetricSecurityKey(buffer);
var tokenValidationParameters = new TokenValidationParameters()
{
ValidateIssuerSigningKey = true,
IssuerSigningKey = securityKey,
ValidIssuer = audienceOptions.Issuer,
ValidateIssuer = true,
ValidateAudience = true,
ValidAudience = audienceOptions.Audience,
ValidateLifetime = true,
ClockSkew = TimeSpan.FromSeconds(0),
RequireExpirationTime = true,
RoleClaimType = ClaimTypes.Role,
LifetimeValidator = (before, expires, token, parameters) =>
before < DateTime.UtcNow - parameters.ClockSkew && DateTime.UtcNow < expires + parameters.ClockSkew
};
var builder = services.AddAuthentication(options =>
{
options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
options.DefaultChallengeScheme = nameof(DefaultAuthenticationHandler);
options.DefaultForbidScheme = nameof(DefaultAuthenticationHandler);
configureAuthenticationOptions?.Invoke(options);
});
builder.AddScheme<AuthenticationSchemeOptions, DefaultAuthenticationHandler>(
nameof(DefaultAuthenticationHandler),
options => { });
builder.AddJwtBearer(options =>
{
options.TokenValidationParameters = tokenValidationParameters;
configureJwtBearerOptions?.Invoke(options);
});
builderOptions?.Invoke(builder);
return services;
}
}

48
src/Infrastructure/Extensions/AuthorizeSetup.cs
Unescape View File

@ -1,48 +0,0 @@
using Infrastructure.Options;
using Microsoft.AspNetCore.Authorization;
using Microsoft.IdentityModel.Tokens;
namespace Infrastructure.Extensions;
public static class AuthorizeSetup
{
/// <summary>
/// 添加权限认证，权限Policy、Roles从配置中获取
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="configureAuthorizeBuilder"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultAuthorize(
this IServiceCollection services,
IConfiguration configuration,
Action<AuthorizationBuilder>? configureAuthorizeBuilder = null)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var audienceOptions = configuration.GetSection(AudienceOptions.Name).Get<AudienceOptions>();
if (audienceOptions is null || !audienceOptions.IsEnable)
{
return services;
}
var key = configuration["AUDIENCE_KEY"] ?? audienceOptions.Secret;
ArgumentException.ThrowIfNullOrEmpty(key);
var buffer = Encoding.UTF8.GetBytes(key);
var securityKey = new SymmetricSecurityKey(buffer);
var signingCredentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256);
services.TryAddSingleton(new JwtContext(
audienceOptions.Issuer,
audienceOptions.Audience,
audienceOptions.Duration,
signingCredentials));
var builder = services.AddAuthorizationBuilder();
builder.AddPolicy(audienceOptions.Policy!, policy =>
policy.RequireRole(audienceOptions.Roles!)
.Build());
configureAuthorizeBuilder?.Invoke(builder);
return services;
}
}

57
src/Infrastructure/Extensions/ControllerSetup.cs
Unescape View File

@ -1,57 +0,0 @@
using Infrastructure.Filters;
using Infrastructure.Utils;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json.Serialization;
namespace Infrastructure.Extensions;
public static class ControllerSetup
{
/// <summary>
/// 配置controller，包含过滤器、json序列化以及模型验证等配置
/// </summary>
/// <param name="services"></param>
/// <param name="configureControllers">配置Controllers</param>
/// <param name="configureMvcOptions">mvc配置选项</param>
/// <param name="configureMvcNewtonsoftJsonOptions">json序列化配置选项</param>
/// <param name="configureApiBehaviorOptions">api行为配置选项</param>
/// <returns></returns>
public static IServiceCollection AddDefaultControllers(this IServiceCollection services,
Action<IMvcBuilder>? configureControllers = null,
Action<MvcOptions>? configureMvcOptions = null,
Action<MvcNewtonsoftJsonOptions>? configureMvcNewtonsoftJsonOptions = null,
Action<ApiBehaviorOptions>? configureApiBehaviorOptions = null)
{
ArgumentNullException.ThrowIfNull(services);
var mvcBuilder = services.AddControllers(options =>
{
options.Filters.Add<ExceptionsFilter>();
options.Filters.Add<IdempotencyFilter>();
configureMvcOptions?.Invoke(options);
});
mvcBuilder.AddNewtonsoftJson(options =>
{
options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver();
options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";
options.SerializerSettings.DateTimeZoneHandling = DateTimeZoneHandling.Local;
options.SerializerSettings.NullValueHandling = NullValueHandling.Ignore;
options.SerializerSettings.Converters.Add(new StringEnumConverter());
configureMvcNewtonsoftJsonOptions?.Invoke(options);
});
mvcBuilder.ConfigureApiBehaviorOptions(options =>
{
options.InvalidModelStateResponseFactory = _ =>
{
var message = new MessageData(false, "the input value not valid", 400);
return new OkObjectResult(message.Serialize());
};
configureApiBehaviorOptions?.Invoke(options);
});
configureControllers?.Invoke(mvcBuilder);
return services;
}
}

16
src/Infrastructure/Extensions/EncryptionSetup.cs
Unescape View File

@ -1,16 +0,0 @@
namespace Infrastructure.Extensions;
public static class EncryptionSetup
{
/// <summary>
/// 注入Aes加密对称加密服务
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddAesEncryption(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddSingleton<IEncryptionService, EncryptionService>();
return services;
}
}

2
src/Infrastructure/Utils/HttpContextExtension.cs → src/Infrastructure/Extensions/HttpContextExtension.cs
Unescape View File

@ -1,6 +1,6 @@
using Microsoft.AspNetCore.Http;
namespace Infrastructure.Utils;
namespace Infrastructure.Extensions;
/// <summary>
/// HttpContext扩展

30
src/Infrastructure/Extensions/MongoDbSetup.cs
Unescape View File

@ -1,30 +0,0 @@
using Infrastructure.Options;
using Infrastructure.Repository.Mongo;
using MongoDB.Driver;
namespace Infrastructure.Extensions;
public static class MongoDbSetup
{
public static IServiceCollection AddMongoDbSetup(
this IServiceCollection services,
IConfiguration configuration)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var mongoDbOptions = configuration.GetSection(MongoDbOptions.Name).Get<MongoDbOptions>();
if (mongoDbOptions is null || !mongoDbOptions.IsEnable)
{
return services;
}
services.TryAddSingleton<IMongoDatabase>(_ =>
new MongoClient(mongoDbOptions.ConnectionString)
.GetDatabase(mongoDbOptions.Database));
services.TryAddScoped(typeof(IMongoRepositoryBase<,>), typeof(MongoRepositoryBase<,>));
return services;
}
}

43
src/Infrastructure/Extensions/RedisSetup.cs
Unescape View File

@ -1,43 +0,0 @@
using Infrastructure.Options;
using Infrastructure.Repository;
using Infrastructure.Repository.Redis;
using StackExchange.Redis;
namespace Infrastructure.Extensions;
public static class RedisSetup
{
/// <summary>
/// 配置redis连接服务,以及redis数据访问仓储
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultRedis(this IServiceCollection services, IConfiguration configuration)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var redisOptions = configuration.GetSection(RedisOptions.Name).Get<RedisOptions>();
if (redisOptions is null || !redisOptions.IsEnable)
{
return services;
}
services.TryAddScoped<IRedisBasketRepository, RedisBasketRepository>();
services.TryAddSingleton<ConnectionMultiplexer>(_ =>
{
var host = configuration["REDIS_HOST"] ?? redisOptions.Host;
ArgumentException.ThrowIfNullOrEmpty(host);
var password = configuration["REDIS_PASSWORD"] ?? redisOptions.Password;
ArgumentException.ThrowIfNullOrEmpty(password);
var serviceName = configuration["REDIS_SERVICE_NAME"] ?? redisOptions.ServiceName;
var connectionString = string.IsNullOrEmpty(serviceName)
? $"{host},password={password}"
: $"{host},password={password},serviceName={serviceName}";
var redisConfig = ConfigurationOptions.Parse(connectionString, true);
redisConfig.ResolveDns = true;
return ConnectionMultiplexer.Connect(redisConfig);
});
return services;
}
}

19
src/Infrastructure/Extensions/RepositoryContextSetup.cs
Unescape View File

@ -1,19 +0,0 @@
using Infrastructure.Repository;
namespace Infrastructure.Extensions;
public static class RepositoryContextSetup
{
/// <summary>
/// 配置数据库仓储服务
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultRepositoryContext(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddScoped<IUnitOfWork, UnitOfWork>();
services.TryAddScoped(typeof(IRepositoryBase<,>), typeof(RepositoryBase<,>));
return services;
}
}

2
src/Infrastructure/Utils/SerializeExtension.cs → src/Infrastructure/Extensions/SerializeExtension.cs
Unescape View File

@ -1,7 +1,7 @@
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
namespace Infrastructure.Utils;
namespace Infrastructure.Extensions;
/// <summary>
/// json序列化扩展

364
src/Infrastructure/Extensions/ServiceCollectionExtensions.cs
Unescape View File

@ -0,0 +1,364 @@
using System.Security.Claims;
using Infrastructure.Filters;
using Infrastructure.HttpUserContext;
using Infrastructure.Options;
using Infrastructure.Repository;
using Infrastructure.Repository.Mongo;
using Infrastructure.Repository.Redis;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using MongoDB.Driver;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json.Serialization;
using Serilog;
using SqlSugar;
using SqlSugar.Extensions;
using StackExchange.Redis;
namespace Infrastructure.Extensions;
public static class ServiceCollectionExtensions
{
/// <summary>
/// 配置redis连接服务,以及redis数据访问仓储
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultRedis(this IServiceCollection services, IConfiguration configuration)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var redisOptions = configuration.GetSection(RedisOptions.Name).Get<RedisOptions>();
if (redisOptions is null || !redisOptions.IsEnable)
{
return services;
}
services.TryAddScoped<IRedisBasketRepository, RedisBasketRepository>();
services.TryAddSingleton<ConnectionMultiplexer>(_ =>
{
var host = configuration["REDIS_HOST"] ?? redisOptions.Host;
ArgumentException.ThrowIfNullOrEmpty(host);
var password = configuration["REDIS_PASSWORD"] ?? redisOptions.Password;
ArgumentException.ThrowIfNullOrEmpty(password);
var serviceName = configuration["REDIS_SERVICE_NAME"] ?? redisOptions.ServiceName;
var connectionString = string.IsNullOrEmpty(serviceName)
? $"{host},password={password}"
: $"{host},password={password},serviceName={serviceName}";
var redisConfig = ConfigurationOptions.Parse(connectionString, true);
redisConfig.ResolveDns = true;
return ConnectionMultiplexer.Connect(redisConfig);
});
return services;
}
/// <summary>
/// 配置认证服务，包含jwt认证
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="builderOptions">自定义认证服务配置</param>
/// <param name="configureAuthenticationOptions">配置认证选项</param>
/// <param name="configureJwtBearerOptions">配置jwt认证选项</param>
/// <returns></returns>
public static IServiceCollection AddDefaultAuthentication(
this IServiceCollection services,
IConfiguration configuration,
Action<AuthenticationBuilder>? builderOptions = null,
Action<AuthenticationOptions>? configureAuthenticationOptions = null,
Action<JwtBearerOptions>? configureJwtBearerOptions = null)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var audienceOptions = configuration.GetSection(AudienceOptions.Name).Get<AudienceOptions>();
if (audienceOptions is null || !audienceOptions.IsEnable)
{
return services;
}
services.TryAddSingleton<IPostConfigureOptions<JwtBearerOptions>, JwtBearerOptionsPostConfigureOptions>();
var key = configuration["AUDIENCE_KEY"] ?? audienceOptions.Secret;
ArgumentException.ThrowIfNullOrEmpty(key);
var buffer = Encoding.UTF8.GetBytes(key);
var securityKey = new SymmetricSecurityKey(buffer);
var tokenValidationParameters = new TokenValidationParameters()
{
ValidateIssuerSigningKey = true,
IssuerSigningKey = securityKey,
ValidIssuer = audienceOptions.Issuer,
ValidateIssuer = true,
ValidateAudience = true,
ValidAudience = audienceOptions.Audience,
ValidateLifetime = true,
ClockSkew = TimeSpan.FromSeconds(0),
RequireExpirationTime = true,
RoleClaimType = ClaimTypes.Role,
LifetimeValidator = (before, expires, token, parameters) =>
before < DateTime.UtcNow - parameters.ClockSkew && DateTime.UtcNow < expires + parameters.ClockSkew
};
var builder = services.AddAuthentication(options =>
{
options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
options.DefaultChallengeScheme = nameof(DefaultAuthenticationHandler);
options.DefaultForbidScheme = nameof(DefaultAuthenticationHandler);
configureAuthenticationOptions?.Invoke(options);
});
builder.AddScheme<AuthenticationSchemeOptions, DefaultAuthenticationHandler>(
nameof(DefaultAuthenticationHandler),
options => { });
builder.AddJwtBearer(options =>
{
options.TokenValidationParameters = tokenValidationParameters;
configureJwtBearerOptions?.Invoke(options);
});
builderOptions?.Invoke(builder);
return services;
}
/// <summary>
/// 添加权限认证，权限Policy、Roles从配置中获取
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="configureAuthorizeBuilder"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultAuthorize(
this IServiceCollection services,
IConfiguration configuration,
Action<AuthorizationBuilder>? configureAuthorizeBuilder = null)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var audienceOptions = configuration.GetSection(AudienceOptions.Name).Get<AudienceOptions>();
if (audienceOptions is null || !audienceOptions.IsEnable)
{
return services;
}
var key = configuration["AUDIENCE_KEY"] ?? audienceOptions.Secret;
ArgumentException.ThrowIfNullOrEmpty(key);
var buffer = Encoding.UTF8.GetBytes(key);
var securityKey = new SymmetricSecurityKey(buffer);
var signingCredentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256);
services.TryAddSingleton(new JwtContext(
audienceOptions.Issuer,
audienceOptions.Audience,
audienceOptions.Duration,
signingCredentials));
var builder = services.AddAuthorizationBuilder();
builder.AddPolicy(audienceOptions.Policy!, policy =>
policy.RequireRole(audienceOptions.Roles!)
.Build());
configureAuthorizeBuilder?.Invoke(builder);
return services;
}
/// <summary>
/// 配置controller，包含过滤器、json序列化以及模型验证等配置
/// </summary>
/// <param name="services"></param>
/// <param name="configureControllers">配置Controllers</param>
/// <param name="configureMvcOptions">mvc配置选项</param>
/// <param name="configureMvcNewtonsoftJsonOptions">json序列化配置选项</param>
/// <param name="configureApiBehaviorOptions">api行为配置选项</param>
/// <returns></returns>
public static IServiceCollection AddDefaultControllers(this IServiceCollection services,
Action<IMvcBuilder>? configureControllers = null,
Action<MvcOptions>? configureMvcOptions = null,
Action<MvcNewtonsoftJsonOptions>? configureMvcNewtonsoftJsonOptions = null,
Action<ApiBehaviorOptions>? configureApiBehaviorOptions = null)
{
ArgumentNullException.ThrowIfNull(services);
var mvcBuilder = services.AddControllers(options =>
{
options.Filters.Add<ExceptionsFilter>();
options.Filters.Add<IdempotencyFilter>();
configureMvcOptions?.Invoke(options);
});
mvcBuilder.AddNewtonsoftJson(options =>
{
options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver();
options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";
options.SerializerSettings.DateTimeZoneHandling = DateTimeZoneHandling.Local;
options.SerializerSettings.NullValueHandling = NullValueHandling.Ignore;
options.SerializerSettings.Converters.Add(new StringEnumConverter());
configureMvcNewtonsoftJsonOptions?.Invoke(options);
});
mvcBuilder.ConfigureApiBehaviorOptions(options =>
{
options.InvalidModelStateResponseFactory = _ =>
{
var message = new MessageData(false, "the input value not valid", 400);
return new OkObjectResult(message.Serialize());
};
configureApiBehaviorOptions?.Invoke(options);
});
configureControllers?.Invoke(mvcBuilder);
return services;
}
/// <summary>
/// 配置Aes加密对称加密服务
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddAesEncryption(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddSingleton<IEncryptionService, EncryptionService>();
return services;
}
/// <summary>
/// 配置mongodb连接以及仓储
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <returns></returns>
public static IServiceCollection AddMongoDbSetup(
this IServiceCollection services,
IConfiguration configuration)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
var mongoDbOptions = configuration.GetSection(MongoDbOptions.Name).Get<MongoDbOptions>();
if (mongoDbOptions is null || !mongoDbOptions.IsEnable)
{
return services;
}
services.TryAddSingleton<IMongoDatabase>(_ =>
new MongoClient(mongoDbOptions.ConnectionString)
.GetDatabase(mongoDbOptions.Database));
services.TryAddScoped(typeof(IMongoRepositoryBase<,>), typeof(MongoRepositoryBase<,>));
return services;
}
/// <summary>
/// 配置数据库仓储服务
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultRepositoryContext(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddScoped<IUnitOfWork, UnitOfWork>();
services.TryAddScoped(typeof(IRepositoryBase<,>), typeof(RepositoryBase<,>));
return services;
}
/// <summary>
/// 配置sqlsugar ORM连接
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="hostEnvironment"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultSqlSugarSetup(
this IServiceCollection services,
IConfiguration configuration,
IWebHostEnvironment hostEnvironment)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
ArgumentNullException.ThrowIfNull(hostEnvironment);
var sqlSugarOptions = configuration.GetSection(SqlSugarOptions.Name).Get<SqlSugarOptions>();
if (sqlSugarOptions is null || !sqlSugarOptions.IsEnable)
{
return services;
}
if (sqlSugarOptions.SnowFlake?.IsEnable ?? false)
{
var workerId = configuration["SNOWFLAKES_WORKERID"]?.ObjToInt() ?? sqlSugarOptions.SnowFlake?.WorkerId;
ArgumentNullException.ThrowIfNull(workerId);
SnowFlakeSingle.WorkId = (int)workerId;
}
var server = configuration["DB_HOST"] ?? sqlSugarOptions.Server;
ArgumentException.ThrowIfNullOrEmpty(server);
var port = configuration["DB_PORT"] ?? sqlSugarOptions.Port.ToString();
ArgumentException.ThrowIfNullOrEmpty(port);
var database = configuration["DB_DATABASE"] ?? sqlSugarOptions.Database;
ArgumentException.ThrowIfNullOrEmpty(database);
var user = configuration["DB_USER"] ?? sqlSugarOptions.User;
ArgumentException.ThrowIfNullOrEmpty(user);
var password = configuration["DB_PASSWORD"] ?? sqlSugarOptions.Password;
ArgumentException.ThrowIfNullOrEmpty(password);
var connectionString = $"server={server};port={port};database={database};userid={user};password={password};";
var connectionConfig = new ConnectionConfig()
{
DbType = DbType.PostgreSQL,
ConnectionString = connectionString,
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
MoreSettings = new ConnMoreSettings()
{
PgSqlIsAutoToLower = false,
PgSqlIsAutoToLowerCodeFirst = false,
}
};
var sugarScope = new SqlSugarScope(connectionConfig, config =>
{
config.QueryFilter.AddTableFilter<IDeletable>(d => !d.IsDeleted);
if (hostEnvironment.IsDevelopment() || hostEnvironment.IsStaging())
{
config.Aop.OnLogExecuting = (sql, parameters) => { Log.Logger.Information(sql); };
}
});
services.AddSingleton<ISqlSugarClient>(sugarScope);
return services;
}
/// <summary>
/// 配置jwt相关上下文
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultTokenContext(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddSingleton<JsonWebTokenHandler>();
services.TryAddSingleton<DefaultTokenHandler>();
return services;
}
/// <summary>
/// 配置用户上下文服务 T为主键类型
/// </summary>
/// <param name="services"></param>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
public static IServiceCollection AddDefaultUserContext<T>(this IServiceCollection services) where T : IEquatable<T>
{
ArgumentNullException.ThrowIfNull(services);
services.AddHttpContextAccessor();
services.TryAddScoped(typeof(IUserContext<T>), typeof(UserContext<T>));
return services;
}
}

84
src/Infrastructure/Extensions/SqlSugarSetup.cs
Unescape View File

@ -1,84 +0,0 @@
using Infrastructure.Options;
using Infrastructure.Repository;
using Microsoft.AspNetCore.Hosting;
using Serilog;
using SqlSugar;
using SqlSugar.Extensions;
namespace Infrastructure.Extensions;
public static class SqlSugarSetup
{
/// <summary>
/// 配置sqlsugar ORM连接
/// </summary>
/// <param name="services"></param>
/// <param name="configuration"></param>
/// <param name="hostEnvironment"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultSqlSugarSetup(
this IServiceCollection services,
IConfiguration configuration,
IWebHostEnvironment hostEnvironment)
{
ArgumentNullException.ThrowIfNull(services);
ArgumentNullException.ThrowIfNull(configuration);
ArgumentNullException.ThrowIfNull(hostEnvironment);
var sqlSugarOptions = configuration.GetSection(SqlSugarOptions.Name).Get<SqlSugarOptions>();
if (sqlSugarOptions is null || !sqlSugarOptions.IsEnable)
{
return services;
}
if (sqlSugarOptions.SnowFlake?.IsEnable ?? false)
{
var workerId = configuration["SNOWFLAKES_WORKERID"]?.ObjToInt() ?? sqlSugarOptions.SnowFlake?.WorkerId;
ArgumentNullException.ThrowIfNull(workerId);
SnowFlakeSingle.WorkId = (int)workerId;
}
var server = configuration["DB_HOST"] ?? sqlSugarOptions.Server;
ArgumentException.ThrowIfNullOrEmpty(server);
var port = configuration["DB_PORT"] ?? sqlSugarOptions.Port.ToString();
ArgumentException.ThrowIfNullOrEmpty(port);
var database = configuration["DB_DATABASE"] ?? sqlSugarOptions.Database;
ArgumentException.ThrowIfNullOrEmpty(database);
var user = configuration["DB_USER"] ?? sqlSugarOptions.User;
ArgumentException.ThrowIfNullOrEmpty(user);
var password = configuration["DB_PASSWORD"] ?? sqlSugarOptions.Password;
ArgumentException.ThrowIfNullOrEmpty(password);
var connectionString = $"server={server};port={port};database={database};userid={user};password={password};";
var connectionConfig = new ConnectionConfig()
{
DbType = DbType.PostgreSQL,
ConnectionString = connectionString,
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
MoreSettings = new ConnMoreSettings()
{
PgSqlIsAutoToLower = false,
PgSqlIsAutoToLowerCodeFirst = false,
}
};
var sugarScope = new SqlSugarScope(connectionConfig, config =>
{
config.QueryFilter.AddTableFilter<IDeletable>(d => !d.IsDeleted);
if (hostEnvironment.IsDevelopment() || hostEnvironment.IsStaging())
{
config.Aop.OnLogExecuting = (sql, parameters) => { Log.Logger.Information(sql); };
}
});
services.AddSingleton<ISqlSugarClient>(sugarScope);
return services;
}
}

17
src/Infrastructure/Extensions/TokenContextSetup.cs
Unescape View File

@ -1,17 +0,0 @@
namespace Infrastructure.Extensions;
public static class TokenContextSetup
{
/// <summary>
///
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
public static IServiceCollection AddDefaultTokenContext(this IServiceCollection services)
{
ArgumentNullException.ThrowIfNull(services);
services.TryAddSingleton<JsonWebTokenHandler>();
services.TryAddSingleton<DefaultTokenHandler>();
return services;
}
}

20
src/Infrastructure/Extensions/UserContextSetup.cs
Unescape View File

@ -1,20 +0,0 @@
using Infrastructure.HttpUserContext;
namespace Infrastructure.Extensions;
public static class UserContextSetup
{
/// <summary>
/// 配置用户上下文服务 T为主键类型
/// </summary>
/// <param name="services"></param>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
public static IServiceCollection AddDefaultUserContext<T>(this IServiceCollection services) where T : IEquatable<T>
{
ArgumentNullException.ThrowIfNull(services);
services.AddHttpContextAccessor();
services.TryAddScoped(typeof(IUserContext<T>), typeof(UserContext<T>));
return services;
}
}

2
src/Infrastructure/Filters/ExceptionsFilter.cs
Unescape View File

@ -1,5 +1,5 @@
using Infrastructure.Exceptions;
using Infrastructure.Utils;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;

2
src/Infrastructure/Filters/IdempotencyFilter.cs
Unescape View File

@ -1,9 +1,9 @@
using Infrastructure.Attributes;
using Infrastructure.Repository;
using Infrastructure.Utils;
using Microsoft.AspNetCore.Mvc.Controllers;
using Microsoft.AspNetCore.Mvc.Filters;
using System.Security.Cryptography;
using Infrastructure.Extensions;
using Infrastructure.Repository.Redis;
using Microsoft.AspNetCore.Mvc;

2
src/Infrastructure/HttpUserContext/UserContext.cs
Unescape View File

@ -1,6 +1,6 @@
using System.Globalization;
using System.Security.Claims;
using Infrastructure.Utils;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.AspNetCore.Http;

2
src/Infrastructure/Middlewares/NotFoundMiddleware.cs
Unescape View File

@ -1,4 +1,4 @@
using Infrastructure.Utils;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Http;
namespace Infrastructure.Middlewares;

2
src/Infrastructure/Repository/Redis/RedisBasketRepository.cs
Unescape View File

@ -1,4 +1,4 @@
using Infrastructure.Utils;
using Infrastructure.Extensions;
using StackExchange.Redis;
namespace Infrastructure.Repository.Redis;

2
src/Infrastructure/Security/DefaultAuthenticationHandler.cs
Unescape View File

@ -1,5 +1,5 @@
using System.Text.Encodings.Web;
using Infrastructure.Utils;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Http;

2
src/Infrastructure/Seed/DatabaseSeed.cs
Unescape View File

@ -1,4 +1,4 @@
using Infrastructure.Utils;
using Infrastructure.Extensions;
using SqlSugar;
namespace Infrastructure.Seed;

Write Preview
Loading…
Cancel
Save