S8TimeoutRuleEvaluator.cs 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189
  1. using System.Data;
  2. using System.Globalization;
  3. using System.Text.Json;
  4. using Admin.NET.Plugin.AiDOP.Entity.S8;
  5. using Admin.NET.Plugin.AiDOP.Infrastructure.S8;
  6. using Microsoft.Extensions.Logging;
  7. using SqlSugar;
  8. namespace Admin.NET.Plugin.AiDOP.Service.S8.Rules;
  9. /// <summary>
  10. /// R2 TIMEOUT 类规则 evaluator MVP。
  11. /// params_json 约定(首版最小集合):
  12. /// { dueAtField, statusField, completedStates[], objectCodeField, objectIdField, graceMinutes, exceptionTypeCode }
  13. /// 判定:dueAt &lt;= now - graceMinutes 且 status 不在 completedStates 内 → HIT。
  14. /// 不做严重度阶梯、不做 SLA 升级、不做事件触发。
  15. /// </summary>
  16. public class S8TimeoutRuleEvaluator : IS8RuleEvaluator, ITransient
  17. {
  18. public const string RuleTypeCode = "TIMEOUT";
  19. public string RuleType => RuleTypeCode;
  20. private const string SqlDataSourceType = "SQL";
  21. private readonly SqlSugarRepository<AdoS8DataSource> _dataSourceRep;
  22. private readonly S8SqlSugarScopeFactory _scopeFactory;
  23. private readonly ILogger<S8TimeoutRuleEvaluator> _logger;
  24. public S8TimeoutRuleEvaluator(
  25. SqlSugarRepository<AdoS8DataSource> dataSourceRep,
  26. S8SqlSugarScopeFactory scopeFactory,
  27. ILogger<S8TimeoutRuleEvaluator> logger)
  28. {
  29. _dataSourceRep = dataSourceRep;
  30. _scopeFactory = scopeFactory;
  31. _logger = logger;
  32. }
  33. public async Task<List<S8RuleHit>> EvaluateAsync(
  34. long tenantId,
  35. long factoryId,
  36. AdoS8WatchRule rule,
  37. IReadOnlyList<AdoS8AlertRule> alertRules,
  38. CancellationToken cancellationToken = default)
  39. {
  40. var hits = new List<S8RuleHit>();
  41. // R5 evaluator 失败语义保护:所有"非命中判定"路径均改为抛出 S8RuleEvaluatorException,
  42. // 由 SchedulerService 标记 evaluate_failed 并跳过 recovery reconcile,避免对未确认未命中的 rule 误标 recovered_at。
  43. if (string.IsNullOrWhiteSpace(rule.Expression) || string.IsNullOrWhiteSpace(rule.ParamsJson))
  44. throw new S8RuleEvaluatorException("rule_not_configured", $"TIMEOUT 规则 {rule.RuleCode} 缺少 expression 或 params_json");
  45. S8TimeoutParams parameters;
  46. try { parameters = S8TimeoutParams.Parse(rule.ParamsJson!); }
  47. catch (Exception ex) { throw new S8RuleEvaluatorException("params_parse_failed", $"TIMEOUT 规则 {rule.RuleCode} params_json 解析失败:{ex.Message}", ex); }
  48. if (string.IsNullOrWhiteSpace(parameters.DueAtField)
  49. || string.IsNullOrWhiteSpace(parameters.StatusField)
  50. || string.IsNullOrWhiteSpace(parameters.ExceptionTypeCode))
  51. throw new S8RuleEvaluatorException("params_schema_invalid", $"TIMEOUT 规则 {rule.RuleCode} params 缺少必填字段 dueAtField/statusField/exceptionTypeCode");
  52. var dataSource = await _dataSourceRep.AsQueryable()
  53. .Where(x => x.Id == rule.DataSourceId
  54. && x.TenantId == tenantId
  55. && x.FactoryId == factoryId
  56. && x.Enabled)
  57. .FirstAsync();
  58. if (dataSource == null
  59. || string.IsNullOrWhiteSpace(dataSource.Endpoint)
  60. || !string.Equals(dataSource.Type?.Trim(), SqlDataSourceType, StringComparison.OrdinalIgnoreCase))
  61. throw new S8RuleEvaluatorException("data_source_unavailable", $"TIMEOUT 规则 {rule.RuleCode} 数据源不可用(id={rule.DataSourceId})");
  62. // S8-SQL-EVALUATOR-GUARD-P2-1:每次评估解析 timeout / maxRows(env 优先,回退代码默认)。
  63. var timeoutSeconds = S8EvaluatorGuard.ResolveCommandTimeoutSeconds(_logger);
  64. var maxRows = S8EvaluatorGuard.ResolveMaxRows(_logger);
  65. DataTable table;
  66. try
  67. {
  68. using var db = _scopeFactory.CreateScope(dataSource.Endpoint!, _dataSourceRep.Context.CurrentConnectionConfig.DbType, timeoutSeconds);
  69. table = await db.Ado.GetDataTableAsync(rule.Expression!);
  70. }
  71. catch (Exception ex)
  72. {
  73. throw new S8RuleEvaluatorException("query_failed", $"TIMEOUT 规则 {rule.RuleCode} SQL 执行失败:{ex.Message}", ex);
  74. }
  75. // 超过安全上限 → result_too_many_rows(由既有 EVALUATE_FAILED 路径承接)。
  76. // 必须置于 try-catch 之外,避免被 query_failed 误捕获再包装。
  77. S8EvaluatorGuard.EnsureRowCountWithinLimit(table.Rows.Count, maxRows, RuleTypeCode, rule.RuleCode);
  78. var detectedAt = DateTime.Now;
  79. var threshold = detectedAt.AddMinutes(-parameters.GraceMinutes);
  80. var sourceObjectType = string.IsNullOrWhiteSpace(rule.SourceObjectType)
  81. ? rule.WatchObjectType
  82. : rule.SourceObjectType!;
  83. foreach (DataRow row in table.Rows)
  84. {
  85. var status = ReadString(row, parameters.StatusField!) ?? string.Empty;
  86. if (parameters.CompletedStates.Contains(status, StringComparer.OrdinalIgnoreCase))
  87. continue;
  88. var due = ReadDateTime(row, parameters.DueAtField!);
  89. if (due == null || due > threshold) continue;
  90. var objectCodeField = string.IsNullOrWhiteSpace(parameters.ObjectCodeField)
  91. ? "related_object_code"
  92. : parameters.ObjectCodeField!;
  93. var relatedObjectCode = ReadString(row, objectCodeField) ?? string.Empty;
  94. if (string.IsNullOrWhiteSpace(relatedObjectCode)) continue;
  95. var sourceObjectId = string.IsNullOrWhiteSpace(parameters.ObjectIdField)
  96. ? relatedObjectCode
  97. : ReadString(row, parameters.ObjectIdField!) ?? relatedObjectCode;
  98. var dedupKey = BuildDedupKey(tenantId, factoryId, rule.RuleCode, sourceObjectType, sourceObjectId);
  99. hits.Add(new S8RuleHit
  100. {
  101. SourceRuleId = rule.Id,
  102. SourceRuleCode = rule.RuleCode,
  103. SourceObjectType = sourceObjectType,
  104. SourceObjectId = sourceObjectId,
  105. RelatedObjectCode = relatedObjectCode,
  106. ExceptionTypeCode = parameters.ExceptionTypeCode!,
  107. SceneCode = rule.SceneCode,
  108. Severity = S8SeverityCode.Normalize(rule.Severity),
  109. DedupKey = dedupKey,
  110. SourcePayload = BuildPayload(row, sourceObjectType, sourceObjectId, due.Value, status, parameters),
  111. DetectedAt = detectedAt,
  112. Title = $"[超时] {sourceObjectType} {sourceObjectId} 已超期至 {due.Value:yyyy-MM-dd HH:mm:ss}(状态 {status})",
  113. DataSourceId = dataSource.Id,
  114. OccurrenceDeptId = ReadLong(row, "occurrence_dept_id"),
  115. ResponsibleDeptId = ReadLong(row, "responsible_dept_id")
  116. });
  117. }
  118. return hits;
  119. }
  120. /// <summary>构造 R2 dedup_key 稳定字符串:T{tenant}:F{factory}:R{ruleCode}:{sourceObjectType}:{sourceObjectId}。internal 暴露供测试。</summary>
  121. internal static string BuildDedupKey(long tenantId, long factoryId, string ruleCode, string sourceObjectType, string sourceObjectId) =>
  122. $"T{tenantId}:F{factoryId}:R{ruleCode}:{sourceObjectType}:{sourceObjectId}";
  123. private static string BuildPayload(DataRow row, string sourceObjectType, string sourceObjectId, DateTime dueAt, string status, S8TimeoutParams parameters)
  124. {
  125. var payload = new Dictionary<string, object?>(StringComparer.OrdinalIgnoreCase);
  126. foreach (DataColumn column in row.Table.Columns)
  127. {
  128. var value = row[column];
  129. payload[column.ColumnName] = value == DBNull.Value ? null : value;
  130. }
  131. payload["__ruleType"] = RuleTypeCode;
  132. payload["__sourceObjectType"] = sourceObjectType;
  133. payload["__sourceObjectId"] = sourceObjectId;
  134. payload["__dueAt"] = dueAt;
  135. payload["__status"] = status;
  136. payload["__graceMinutes"] = parameters.GraceMinutes;
  137. payload["__exceptionTypeCode"] = parameters.ExceptionTypeCode;
  138. return JsonSerializer.Serialize(payload);
  139. }
  140. private static string? ReadString(DataRow row, string columnName)
  141. {
  142. if (string.IsNullOrWhiteSpace(columnName)) return null;
  143. if (!row.Table.Columns.Contains(columnName)) return null;
  144. var v = row[columnName];
  145. return v == DBNull.Value ? null : Convert.ToString(v)?.Trim();
  146. }
  147. private static DateTime? ReadDateTime(DataRow row, string columnName)
  148. {
  149. if (!row.Table.Columns.Contains(columnName)) return null;
  150. var v = row[columnName];
  151. if (v == DBNull.Value) return null;
  152. if (v is DateTime dt) return dt;
  153. return DateTime.TryParse(Convert.ToString(v, CultureInfo.InvariantCulture), out var p) ? p : null;
  154. }
  155. private static long? ReadLong(DataRow row, string columnName)
  156. {
  157. if (!row.Table.Columns.Contains(columnName)) return null;
  158. var v = row[columnName];
  159. if (v == DBNull.Value) return null;
  160. return long.TryParse(Convert.ToString(v, CultureInfo.InvariantCulture), out var r) ? r : null;
  161. }
  162. }