dapr-dotnetDapr与.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

(k => k.AllowSynchronousIO = true)
.Configure(k => k.AllowSynchronousIO = true);
var app = builder.Build();
builder.AddCustomDaprdProcess();
builder.AddCustomAutofac();
builder.AddCustomLog();
builder.AddCustomMVC();
builder.AddCustomServices();
builder.AddCustomDbContext();
builder.AddCustomSwagger();
builder.AddCustomHealthChecks();
builder.Services.AddHttpClient();

var appPort = app.Configuration["AppProfile:AppPort"].ToString();
app.Urls.Add($"http://*:{appPort}");
if (app.Environment.IsDevelopment())
{
app.UseSwagger().UseSwaggerUI(s =>
{
foreach (FieldInfo field in typeof(ApiVersionInfo).GetFields())
{
s.SwaggerEndpoint($"/swagger/{field.Name}/swagger.json", $"API {field.Name} 版本");
}
});
}
app.Use(
(context, next) =>
{
context.Request.EnableBuffering();
return next(context);
});
app.UseCloudEvents();
app.UseRouting();
app.UseCors("CorsPolicy");
app.MapDefaultControllerRoute();
app.MapControllers();
app.MapSubscribeHandler();
app.MapCustomHealthChecks();
try
{
app.Logger.LogInformation("==============Starting API WebHost==============");
app.Run();
}
catch (Exception e)
{
app.Logger.LogError(e, "==============Host terminated unexpectedly==============");
}
finally
{
Log.CloseAndFlush();
}

---

## Result Pattern

### API Result

csharp
// Common/ApiResult.cs
public class BaseResult
{
///

/// 响应码
///

[NotNull]
public virtual HttpStatusCode Code { get; set; }

///

/// 响应成功
///

///
public virtual void Success()
{
Code = HttpStatusCode.OK;
}

///

/// 响应失败
///

///
public virtual void Failed()
{
Code = HttpStatusCode.InternalServerError;
}
}

///

/// API返回结果结构
///

public class ApiResult : BaseResult
{
public ApiResult()
{
Success();
}

private string _Message = string.Empty;
private string _Data = string.Empty;
private byte[] _Base64Data;
private string _ModelType = string.Empty;

///

/// 消息提示
///

public string Message { get => Message; set => Message = value; }
///

/// 数据源
///

public string Data { get => Data; set => Data = value; }
///

/// 数据源模型
///

public string ModelType { get => ModelType; set => ModelType = value; }
///

/// Base64数据源
///

public byte[] Base64Data { get => Base64Data; set => Base64Data = value; }

///

/// 响应成功
///

/// 消息
public void Success(string message)
{
base.Success();
_Message = message;
}

///

/// 响应成功
///

/// 数据
public void Success(dynamic data)
{
base.Success();

_Data = JsonSerializer.Serialize(data, new JsonSerializerOptions
{
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
});

_ModelType = GetDataType(data);
}

///

/// 响应成功
///

/// 数据
/// 消息
public void Success(dynamic data, string message)
{
base.Success();
_Message = message;
_Data = JsonSerializer.Serialize(data, new JsonSerializerOptions
{
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
});
_ModelType = GetDataType(data);
}

///

/// 响应成功
///

/// 数据
public void Success(List dataList)
{
base.Success();

if (dataList != null && dataList.Any())
{
_Data = JsonSerializer.Serialize(dataList, new JsonSerializerOptions
{
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
});
_ModelType = GetDataType(dataList);
}
else
{
_Data = string.Empty;
_ModelType = string.Empty;
}
}

///

/// 响应成功
///

/// 数据
/// 消息
public void Success(List dataList, string message)
{
base.Success();
_Message = message;
if (dataList != null && dataList.Any())
{
_Data = JsonSerializer.Serialize(dataList, new JsonSerializerOptions
{
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
});
_ModelType = GetDataType(dataList);
}
else
{
_Data = string.Empty;
_ModelType = string.Empty;
}
}

///

/// 响应失败
///

///
public void Failed(string message)
{
base.Failed();
_Message = message;
}

///

/// 响应失败
///

///
public void Failed(Exception ex)
{
base.Failed();
_Message = ex.Message.ToString();
}

///

/// 响应失败
///

///
public void Failed(HttpStatusCode httpStatusCode, string message)
{
Code = httpStatusCode;
_Message = message;
}

///

/// 成功
///

/// 数据源
/// 状态码
/// 消息提示
/// 是否需要序列化
public static ApiResult Success(dynamic dataSource, string message = "操作成功", HttpStatusCode code = HttpStatusCode.OK, bool isSerialize = true)
{
return new ApiResult(dataSource, code, message, isSerialize);
}

///

/// 成功
///

/// 数据源
/// 状态码
/// 消息提示
/// 是否需要序列化
public static ApiResult Success(List dataSourceList, string message = "操作成功", HttpStatusCode code = HttpStatusCode.OK, bool isSerialize = true)
{
if (dataSourceList != null && dataSourceList.Any())
{
return new ApiResult(dataSourceList, code, message, isSerialize);
}
else
{
return new ApiResult(string.Empty, code, message, isSerialize);
}
}

///

/// 失败
///

/// 状态码
/// 消息提示
public static ApiResult Failed(string message = "操作失败", HttpStatusCode code = HttpStatusCode.InternalServerError)
{
return new ApiResult(string.Empty, code, message, false);
}

///

/// 响应模型
///

/// 数据源
/// 状态码
/// 消息提示
/// 是否需要序列化
private ApiResult(dynamic dataSource, HttpStatusCode code, string message, bool isSerialize)
{
if (dataSource != null && dataSource.GetType() == typeof(byte[]) && !isSerialize)
{
_Base64Data = dataSource;
}
else if (dataSource != null && dataSource?.GetType() != typeof(string) && isSerialize)
{
_Data = JsonSerializer.Serialize(dataSource, new JsonSerializerOptions
{
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
NumberHandling = JsonNumberHandling.WriteAsString,
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
});
}
else
{
_Data = dataSource;
}
Code = code;
_Message = message;
_ModelType = GetDataType(dataSource);
}

///

/// 获取返回模型的所有属性
///

///
///
private static string GetDataType(dynamic data)
{
var str = string.Empty;

System.Reflection.PropertyInfo[] properties = data.GetType().GetProperties();

foreach (System.Reflection.PropertyInfo property in properties)
{
string propertyName = property.Name;
string propertyType = property.PropertyType.Name;

str += $"{propertyName} ({propertyType}),";
}

return !string.IsNullOrWhiteSpace(str) ? str[..^1] : str;
}
}

///

/// 泛型类型返回体
///

///
public class ApiResult : ApiResult
{
///

/// 数据
///

public T TData { get; set; }

///

/// 列表的记录数
///

public int Total { get; set; }
}

### Application

csharp
// Application/IServices/IBaseService.cs
public interface IBaseService where T : class, new()
{
///

/// 添加
///

///
///
bool Insert(T AEntity);

///

/// 添加
///

///
///
Task InsertAsync(T AEntity);

///

/// 批量添加
///

///
///
Task InsertRangeAsync(List AList);

///

/// 删除
///

///
///
bool Delete(T AEntity);

///

/// 删除
///

///
///
Task DeleteAsync(dynamic AId);

///

/// 批量删除
///

///
///
Task DeleteByIdsAsync(dynamic[] AIds);

///

/// 更新
///

///
///
bool Update(T AEntity);

///

/// 更新
///

///
///
Task UpdateAsync(T AEntity);

///

/// 批量更新
///

///
///
Task UpdateRangeAsync(List AList);

///

/// 查询
///

///
///
T Find(Expression> func);

///

/// 根据ID查询
///

///
///
Task FindAsync(dynamic AId);

///

/// 查询
///

///
///
Task FindAsync(Expression> func);

///

/// 查询
///

///
List Query();

///

/// 自定义查询
///

///
///
List Query(Expression> func);

///

/// 查询
///

///
Task> QueryAsync();

///

/// 自定义查询
///

///
///
Task> QueryAsync(Expression> func);

///

/// 分页查询
///

///
///
///
///
Task> QueryAsync(int APageIndex, int APageSize, RefAsync ATotal);

///

/// 自定义条件分页查询
///

///
///
///
///
///
Task> QueryAsync(Expression> func, int APageIndex, int APageSize, RefAsync ATotal);

///

/// 自定义条件分页查询
///

///
///
///
///
///
Task> QueryAsync(Expression> func, string orderByFields, int APageIndex, int APageSize, RefAsync ATotal);

///

/// 自定义条件分页查询
///

///
///
///
///
///
///
///
Task> QueryAsync(Expression> whereExpression, Expression> orderByExpression, OrderByType order, int APageIndex, int APageSize, RefAsync ATotal);

///

/// 开始事务
///

void BeginTran();

///

/// 提交
///

void CommitTran();

///

/// 回滚
///

void RollbackTran();

#region 执行sql

///

/// 获取DataTable数据
///

///
///
/// DataTable
DataTable GetDataTable(string sql, object parameters);

///

/// 获取DataTable数据
///

///
///
/// DataTable
DataTable GetDataTable(string sql, params SugarParameter[] parameters);

///

/// 获取DataTable数据
///

///
///
/// DataTable
DataTable GetDataTable(string sql, List parameters);

///

/// 获取DataTable数据
///

///
///
/// DataTable
Task GetDataTableAsync(string sql, object parameters);

///

/// 获取DataTable数据
///

///
///
/// DataTable
Task GetDataTableAsync(string ASql, params SugarParameter[] parameters);

///

/// 获取DataTable数据
///

///
///
/// DataTable
Task GetDataTableAsync(string sql, List parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
DataSet GetDataSetAll(string sql, object parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
DataSet GetDataSetAll(string sql, params SugarParameter[] parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
DataSet GetDataSetAll(string sql, List parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
Task GetDataSetAllAsync(string sql, object parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
Task GetDataSetAllAsync(string sql, params SugarParameter[] parameters);

///

/// 获取DataSet数据
///

///
///
/// DataSet
Task GetDataSetAllAsync(string sql, List parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
IDataReader GetDataReader(string sql, object parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
IDataReader GetDataReader(string sql, params SugarParameter[] parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
IDataReader GetDataReader(string sql, List parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
Task GetDataReaderAsync(string sql, object parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
Task GetDataReaderAsync(string sql, params SugarParameter[] parameters);

///

/// 获取DataReader数据
///

///
///
/// IDataReader
Task GetDataReaderAsync(string sql, List parameters);

///

/// 获取object数据
///

///
///
/// object
object GetScalar(string sql, object parameters);

///

/// 获取object数据
///

///
///
/// object
object GetScalar(string sql, params SugarParameter[] parameters);

///

/// 获取object数据
///

///
///
/// object
object GetScalar(string sql, List parameters);

///

/// 获取object数据
///

///
///
/// object
Task