dapr-dotnet

public static void AddCustomDaprdProcess(this WebApplicationBuilder builder) { var vConfigurationManager = builder.Configuration; var appId = vConfigurationManager.GetValue("AppProfile:AppId", "jytplatformequpmentapi"); var appPort = vConfigurationManager.GetValue("AppProfile:AppPort", 8118); var daprHttpPort = vConfigurationManager.GetValue("AppProfile:DaprHttpPort", 18118); var daprGrpcPort = vConfigurationManager.GetValue("AppProfile:DaprGrpcPort", 28118); var otherDaprConfig = $"--config .dapr/config/config.yaml --resources-path .dapr/components --log-as-json";

#if DEBUG BaseHelper.AddDaprdProcess(appId, appPort, daprHttpPort, daprGrpcPort, otherDaprConfig);

builder.Services.AddControllers().AddDapr(config => { config.UseHttpEndpoint($"http://localhost:{daprHttpPort}"); config.UseGrpcEndpoint($"http://localhost:{daprGrpcPort}"); }); #else builder.Services.AddControllers().AddDapr(); #endif }

public static void AddCustomAutofac(this WebApplicationBuilder builder) { builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory()); builder.Host.ConfigureContainer(builder => { builder.RegisterModule(); }); }

public static void AddCustomLog(this WebApplicationBuilder builder) { builder.Host.UseSerilog((hostingContext, loggerConfiguration) => { const string vOutputTemplate = "{Timestamp:yyyy-MM-dd HH:mm:ss.fff} [{Level}] {Message}{NewLine}{Exception}";

loggerConfiguration.MinimumLevel.Information() .MinimumLevel.Override("Default", LogEventLevel.Information) .MinimumLevel.Override("Microsoft", LogEventLevel.Error) .MinimumLevel.Override("Microsoft.Hosting.Lifetime", LogEventLevel.Information) .Enrich.FromLogContext() .WriteTo.Console(outputTemplate: "[{Timestamp:yyyy-MM-dd HH:mm:ss} {Level:u3}] {Message:lj}{NewLine}{Exception}", theme: Serilog.Sinks.SystemConsole.Themes.AnsiConsoleTheme.Code) .WriteTo.File(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Logs", "log-.txt"), rollingInterval: RollingInterval.Hour, outputTemplate: vOutputTemplate, retainedFileCountLimit: 100) .WriteTo.Logger(s => s.Filter.ByIncludingOnly(e => e.Level >= LogEventLevel.Warning) .WriteTo.File(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Logs", "errors", "log-.txt"), rollingInterval: RollingInterval.Day, outputTemplate: vOutputTemplate, retainedFileCountLimit: 100));

var esUrl = hostingContext.Configuration.GetSection("ElasticSearchUrl").Value;

var indexFormat = $"{appName}" + "-{0:yyyy.MM}";

if (!string.IsNullOrWhiteSpace(esUrl)) { loggerConfiguration.WriteTo.Elasticsearch(new ElasticsearchSinkOptions(new Uri(esUrl)) { MinimumLogEventLevel = LogEventLevel.Information, AutoRegisterTemplate = true, IndexFormat = indexFormat }); } }); }

public static void AddCustomMVC(this WebApplicationBuilder builder) { builder.Services.AddControllers() .AddJsonOptions(options => { //数据格式原样输出 options.JsonSerializerOptions.PropertyNamingPolicy = null; //取消Unicode编码 options.JsonSerializerOptions.Encoder = JavaScriptEncoder.Create(UnicodeRanges.All); //允许额外符号 options.JsonSerializerOptions.AllowTrailingCommas = true; });

builder.Services.AddCors(options => { options.AddPolicy("CorsPolicy", policy => { var withOrigins = builder.Configuration["WithOrigins"]; if (!string.IsNullOrWhiteSpace(withOrigins) && withOrigins.Split(';').Length > 0) policy.WithOrigins(withOrigins.Split(';')); else policy.SetIsOriginAllowed((host) => true);

policy.AllowAnyMethod(); policy.AllowAnyHeader(); policy.AllowCredentials(); }); }); }

public static void AddCustomDbContext(this WebApplicationBuilder builder) { AppContext.SetSwitch("Npgsql.EnableLegacyTimestampBehavior", true); AppContext.SetSwitch("Npgsql.DisableDateTimeInfinityConversions", true); var vDbType = builder.Configuration["CurrentDbType"]; IocDbType vIocDbType = IocDbType.SqlServer; switch (vDbType) { case "SqlServer": vIocDbType = IocDbType.SqlServer; break;

case "MySql": vIocDbType = IocDbType.MySql; break;

case "PostgreSQL": vIocDbType = IocDbType.PostgreSQL; break; } builder.Services.AddSqlSugar(new IocConfig() { ConfigId = "EquipmentAPI", ConnectionString = builder.Configuration[$"DataBase:{vIocDbType}:Database_ConnString"], DbType = vIocDbType, IsAutoCloseConnection = true }); //AOP 统一配置 禁止循环，只能声名一次 builder.Services.ConfigurationSugar(db => { //里面可以循环 db.GetConnection("API").Aop.OnLogExecuting = (sql, p) => { #if DEBUG //ConsoleColor currentForeColor = Console.ForegroundColor; //Console.ForegroundColor = ConsoleColor.Blue; //Console.WriteLine(sql); //Console.ForegroundColor = currentForeColor; #endif }; //里面可以循环 db.GetConnection("API").Aop.OnError = (exp) => { #if DEBUG ConsoleColor currentForeColor = Console.ForegroundColor; Console.ForegroundColor = ConsoleColor.Red; Console.WriteLine($"{exp.Message}：{exp.Sql}"); Console.ForegroundColor = currentForeColor; #endif }; }); }

public static void AddCustomSwagger(this WebApplicationBuilder builder) { builder.Services.AddSwaggerGen(options => { foreach (FieldInfo fileld in typeof(ApiVersionInfo).GetFields()) { options.SwaggerDoc(fileld.Name, new OpenApiInfo { Version = fileld.Name, Title = $"API {fileld.Name} 接口文档", Description = $"API {fileld.Name} 接口文档" }); } var xmlFilename = $"{Assembly.GetExecutingAssembly().GetName().Name}.xml"; options.IncludeXmlComments(Path.Combine(AppContext.BaseDirectory, xmlFilename)); }); }

public static void AddCustomHealthChecks(this WebApplicationBuilder builder) { builder.Services.AddHealthChecks() .AddCheck(appName, () => HealthCheckResult.Healthy()) .AddCheck("dapr"); } }

public class AutofacModule : Autofac.Module { protected override void Load(ContainerBuilder builder) { // 定义需要注册的程序集列表 var vAssemblies = new[] { Assembly.Load("Domain"), Assembly.Load("Infrastructure"), Assembly.Load("Common"), Assembly.Load("Application") };

// 注册所有实现了接口的类型，每个依赖关系创建一个新的实例 foreach (var vAssembly in vAssemblies) { builder.RegisterAssemblyTypes(vAssembly) .AsImplementedInterfaces() .InstancePerDependency(); } } }

Program.cs Setup

Result Pattern
API Result

Application

Domain

Infrastructure