Dapr与.NET专家

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