parent
bf3c38820e
commit
0a95314fff
6 changed files with 423 additions and 0 deletions
@ -0,0 +1,83 @@ |
||||
using SparkClient.Model.Entity.Base; |
||||
using System.Reflection; |
||||
using System.Runtime.CompilerServices; |
||||
|
||||
namespace SparkClient.Model.Entity; |
||||
|
||||
/// <summary> |
||||
/// 系统设置实体 |
||||
/// </summary> |
||||
|
||||
public class AlgorithmConfigEntity |
||||
{ |
||||
public static readonly string TableName = "ALGORITHM_CONFIG"; |
||||
[DbField("GUID")] |
||||
public Guid GUID { get; set; } |
||||
/// <summary> |
||||
/// json内容 |
||||
/// </summary> |
||||
[DbField("JSON")] |
||||
public required string Json { get; set; } |
||||
/// <summary> |
||||
/// Json排序 |
||||
/// </summary> |
||||
[DbField("JSON_ORDER")] |
||||
public required int JsonOrder { get; set; } |
||||
|
||||
private static Dictionary<string, string> GetFieldMappings() |
||||
{ |
||||
var properties = typeof(AlgorithmConfigEntity).GetProperties(BindingFlags.Public | BindingFlags.Instance); |
||||
return properties |
||||
.Where(p => Attribute.IsDefined(p, typeof(DbFieldAttribute))) |
||||
.ToDictionary( |
||||
p => p.Name, |
||||
p => ((DbFieldAttribute)p.GetCustomAttribute(typeof(DbFieldAttribute))).FieldName |
||||
); |
||||
} |
||||
|
||||
// 生成 Insert 语句 |
||||
public string GenerateInsertSQL() |
||||
{ |
||||
var mappings = GetFieldMappings(); |
||||
var columns = string.Join(", ", mappings.Values); |
||||
var values = string.Join(", ", mappings.Keys.Select(k => $"@{k}")); |
||||
return $"INSERT INTO {TableName} ({columns}) VALUES ({values});"; |
||||
} |
||||
|
||||
// 生成 Update 语句 |
||||
public string GenerateUpdateSQL(Dictionary<string, object> fieldsToUpdate = null) |
||||
{ |
||||
if (fieldsToUpdate == null || fieldsToUpdate.Count == 0) |
||||
{ |
||||
// 默认根据 ID 更新所有字段 |
||||
var mappings = GetFieldMappings(); |
||||
var setClause = string.Join(", ", mappings.Values.Select(f => $"{f} = @{f}")); |
||||
return $"UPDATE {TableName} SET {setClause} WHERE GUID = " + GUID.ToString() + ";"; |
||||
} |
||||
else |
||||
{ |
||||
// 根据传入的字段更新 |
||||
var setClause = string.Join(", ", fieldsToUpdate.Keys.Select(f => $"{f} = @{f}")); |
||||
return $"UPDATE {TableName} SET {setClause} WHERE GUID = " + GUID.ToString() + ";"; |
||||
} |
||||
} |
||||
|
||||
// 生成 Delete 语句 |
||||
public string GenerateDeleteSQL(Dictionary<string, object> conditions = null) |
||||
{ |
||||
if (conditions == null || conditions.Count == 0) |
||||
{ |
||||
// 默认根据 ID 删除 |
||||
return $"DELETE FROM {TableName} WHERE GUID =" + GUID.ToString() + ";"; |
||||
} |
||||
else |
||||
{ |
||||
// 根据传入条件删除 |
||||
var whereClause = string.Join(" AND ", conditions.Keys.Select(f => $"{f} = @{f}")); |
||||
return $"DELETE FROM {TableName} WHERE {whereClause};"; |
||||
} |
||||
} |
||||
|
||||
} |
||||
|
||||
|
After Width: | Height: | Size: 18 KiB |
After Width: | Height: | Size: 22 KiB |
Loading…
Reference in new issue