S8NotificationLayerResolver.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249
  1. using Admin.NET.Plugin.AiDOP.Entity.S8;
  2. using Admin.NET.Plugin.AiDOP.Infrastructure;
  3. using Admin.NET.Plugin.AiDOP.Infrastructure.S8;
  4. using Admin.NET.Plugin.ApprovalFlow.Service;
  5. using Microsoft.Extensions.Logging;
  6. namespace Admin.NET.Plugin.AiDOP.Service.S8;
  7. /// <summary>
  8. /// S8 通知分层路由解析器(S8-NOTIFY-LAYER-RESOLVE-1)
  9. ///
  10. /// 职责链:
  11. /// (tenantId, factoryId, sceneCode, severity)
  12. /// → 命中 ado_s8_notification_layer 行(多行 OK)
  13. /// → 解析 target_role_ids(dual-format)
  14. /// → 解析 notify_channel(IgnoreCase, ',' / ';' 分隔)
  15. /// → S8RoleResolver → userIds
  16. /// → S8NotificationPushAdapter.PushAsync
  17. /// → 由 PushAdapter 落 AdoS8NotificationLog(**每个「已注册且被选中」的渠道**一条)
  18. ///
  19. /// 不接入 watch / scheduler / task 主链路;不写 ApprovalFlowNotifyLog;
  20. /// 不修改任何 schema;任何分支异常仅 LogWarning,不向上抛。
  21. ///
  22. /// S8-STEP6C-CFG-NOTIFY-FIX-AND-CERT-1:平台默认回落粒度 = **(scene, severity, level) 逐层**。
  23. /// 一次 OR 查询取回「平台默认 (0,0) ∪ 本工厂」的同 scene+severity 行,再交
  24. /// <see cref="S8NotificationLayerMerge.Effective"/> 逐 level 取工厂优先。
  25. /// 修正前是整键 fallback(精确租户查到任意一行即完全不读 (0,0)),会导致工厂补一层就丢掉平台其余层级。
  26. /// merge 与配置页 ListAsync 共用同一实现,禁止各自复制。
  27. /// </summary>
  28. public class S8NotificationLayerResolver : ITransient
  29. {
  30. private readonly SqlSugarRepository<AdoS8NotificationLayer> _layerRep;
  31. private readonly S8RoleResolver _roleResolver;
  32. private readonly S8NotificationPushAdapter _pushAdapter;
  33. private readonly ILogger<S8NotificationLayerResolver> _logger;
  34. public S8NotificationLayerResolver(
  35. SqlSugarRepository<AdoS8NotificationLayer> layerRep,
  36. S8RoleResolver roleResolver,
  37. S8NotificationPushAdapter pushAdapter,
  38. ILogger<S8NotificationLayerResolver> logger)
  39. {
  40. _layerRep = layerRep;
  41. _roleResolver = roleResolver;
  42. _pushAdapter = pushAdapter;
  43. _logger = logger;
  44. }
  45. public class DispatchByLayerInput
  46. {
  47. public long TenantId { get; set; }
  48. public long? ExceptionId { get; set; }
  49. public string? ExceptionNo { get; set; }
  50. public string SceneCode { get; set; } = string.Empty;
  51. public string Severity { get; set; } = string.Empty;
  52. public string Title { get; set; } = string.Empty;
  53. public string Content { get; set; } = string.Empty;
  54. public string? Status { get; set; }
  55. public string? SourceRuleCode { get; set; }
  56. public string? JumpUrl { get; set; }
  57. /// <summary>
  58. /// S8-NOTIFY-WIRE-RECOVERED-1:true 表示恢复事件,BuildNotification 会在 Context 中追加
  59. /// "recovered"="true"。默认 false,保持 CREATED 路径载荷向后兼容。
  60. /// </summary>
  61. public bool Recovered { get; set; }
  62. // ============================================================
  63. // S8-DEMO-IMPACT-SORT-NOTICE-1:影响统计字段(可选;CREATED 路径透传,RECOVERED 路径置空)。
  64. // 由 S8WatchSchedulerService.TryDispatchLayerNotificationAsync 调 S8ImpactMetricsService 计算后传入。
  65. // ============================================================
  66. public int? RepeatCount30d { get; set; }
  67. public decimal? CumulativeLossHours30d { get; set; }
  68. public string? SuggestedAttentionLevel { get; set; }
  69. public string? SuggestedAttentionLabel { get; set; }
  70. public string? ImpactReason { get; set; }
  71. // ============================================================
  72. // S8-R03-OVERDUE-CLOSE-NOTICE-1:关闭超时独立预警字段(可选;仅 CloseAsync 命中 closedAt > slaDeadline 时传入)。
  73. // 语义与 TimeoutFlag 运行时口径分离:TimeoutFlag 仅看未关闭超时;OverdueClosed 是已关闭后的闭环及时性提醒。
  74. // ============================================================
  75. public bool? OverdueClosed { get; set; }
  76. public DateTime? ClosedAt { get; set; }
  77. public DateTime? SlaDeadlineRef { get; set; }
  78. public decimal? OverdueCloseHours { get; set; }
  79. }
  80. /// <summary>
  81. /// 调用方:watch/scheduler/task 在拿到 sceneCode + severity 后调用本方法(本轮不接入主链路)。
  82. /// </summary>
  83. public async Task DispatchByLayerAsync(DispatchByLayerInput input)
  84. {
  85. if (input == null)
  86. {
  87. _logger.LogWarning("S8LayerDispatch: input null");
  88. return;
  89. }
  90. if (string.IsNullOrWhiteSpace(input.SceneCode) || string.IsNullOrWhiteSpace(input.Severity))
  91. {
  92. _logger.LogInformation("S8LayerDispatch skip: empty sceneCode or severity (exceptionId={ExceptionId})", input.ExceptionId);
  93. return;
  94. }
  95. // S8-STEP6C-CFG-NOTIFY-FIX-AND-CERT-1:覆盖粒度由「整个 (scene, severity) 键」收敛为**逐 level 覆盖**。
  96. //
  97. // 原实现是两次往返 + 整键 fallback(精确租户查到任意一行 → 完全不读 (0,0))。
  98. // 那意味着工厂只要为某一层建一行,平台默认在该 scene+severity 下的其余层级会整体消失——
  99. // 工厂本意是「补一层」,实际是「换掉整组」,且该副作用在配置页上不可见。
  100. //
  101. // 现在一次 OR 查询同时取回平台默认与本工厂行,再由 S8NotificationLayerMerge 逐 level 取舍。
  102. // merge 与配置页 ListAsync 共用同一函数,杜绝「页面显示一种、运行时派发另一种」。
  103. List<AdoS8NotificationLayer> layers;
  104. var severity = S8SeverityCode.Normalize(input.Severity);
  105. try
  106. {
  107. var candidates = await _layerRep.AsQueryable()
  108. .Where(x => x.SceneCode == input.SceneCode && x.Severity == severity)
  109. // S8-TENANT-ONLY-BATCH6:候选判据去掉 factory 等值,保留 (0,0) 平台默认哨兵。
  110. // 不去掉是必然断链:本批之后异常 factory_id 恒为 0,而库里的 notification_layer
  111. // 租户行 factory_id ≠ 0,租户那一支永远命中不了 —— 分层通知会静默退化成"只有平台默认"。
  112. .Where(x => x.TenantId == input.TenantId
  113. || (x.TenantId == S8ConfigScope.GlobalTenantId && x.FactoryId == S8ConfigScope.GlobalFactoryId))
  114. .ToListAsync();
  115. layers = S8NotificationLayerMerge.Effective(candidates);
  116. }
  117. catch (Exception ex)
  118. {
  119. _logger.LogWarning(ex, "S8LayerDispatch: query AdoS8NotificationLayer failed (scene={Scene}, sev={Sev})", input.SceneCode, input.Severity);
  120. return;
  121. }
  122. if (layers.Count > 0)
  123. _logger.LogInformation(
  124. "S8LayerDispatch: {Total} effective layer rows across {Levels} level(s) for scene={Scene} sev={Sev}; {G} from platform default (tenant=0/factory=0)",
  125. layers.Count,
  126. layers.Select(x => S8NotificationLayerMerge.NormalizeLevel(x.LevelCode)).Distinct().Count(),
  127. input.SceneCode, severity,
  128. layers.Count(x => S8ConfigScope.IsGlobal(x.TenantId, x.FactoryId)));
  129. if (layers.Count == 0)
  130. {
  131. _logger.LogInformation("S8LayerDispatch: no layer matched (tenant={Tenant}, factory={Factory}, scene={Scene}, sev={Sev})",
  132. input.TenantId, input.SceneCode, input.Severity);
  133. return;
  134. }
  135. var notification = BuildNotification(input);
  136. foreach (var layer in layers)
  137. {
  138. List<long> userIds;
  139. try
  140. {
  141. var tokens = S8RoleResolver.SplitTokens(layer.TargetRoleIds);
  142. if (tokens.Count == 0)
  143. {
  144. _logger.LogWarning("S8LayerDispatch: layer id={LayerId} target_role_ids empty, skip row", layer.Id);
  145. continue;
  146. }
  147. // S8-ROLE-TENANT-SCOPE-1:显式透传租户作为安全边界。
  148. // 注意用 input.TenantId 而非 layer.TenantId —— 全局层(tenant_id=0)也必须
  149. // 按**触发异常的租户**解析收件人,否则全局层会解析不到任何角色。
  150. userIds = await _roleResolver.ResolveUserIdsAsync(input.TenantId, tokens);
  151. }
  152. catch (Exception ex)
  153. {
  154. _logger.LogWarning(ex, "S8LayerDispatch: resolve roles failed for layer id={LayerId}", layer.Id);
  155. continue;
  156. }
  157. if (userIds.Count == 0)
  158. {
  159. _logger.LogWarning("S8LayerDispatch: layer id={LayerId} resolved 0 users from target_role_ids='{Roles}'",
  160. layer.Id, layer.TargetRoleIds);
  161. continue;
  162. }
  163. var channels = ParseChannels(layer.NotifyChannel);
  164. try
  165. {
  166. await _pushAdapter.PushAsync(
  167. tenantId: input.TenantId,
  168. // 通知日志的 factory 列写兼容值 0:归属只由 tenant 决定。
  169. factoryId: S8ConfigScope.GlobalFactoryId,
  170. exceptionId: input.ExceptionId,
  171. userIds: userIds,
  172. notification: notification,
  173. channels: channels);
  174. }
  175. catch (Exception ex)
  176. {
  177. // PushAdapter 自身已对内部错误做了捕获;这里再兜一层保证主流程不被打断。
  178. _logger.LogWarning(ex, "S8LayerDispatch: push throw (layer id={LayerId})", layer.Id);
  179. }
  180. }
  181. }
  182. private static FlowNotification BuildNotification(DispatchByLayerInput input)
  183. {
  184. // 注意:FlowNotificationTypeEnum 不含 S8_EXCEPTION 值;BizType 字段承载 "S8_EXCEPTION" 语义。
  185. // InstanceId 仅作为载荷字段(PushAdapter 不写 ApprovalFlowNotifyLog,不会脏写该列)。
  186. var ctx = new Dictionary<string, string?>
  187. {
  188. ["exceptionId"] = input.ExceptionId?.ToString(),
  189. ["exceptionNo"] = input.ExceptionNo,
  190. ["sceneCode"] = input.SceneCode,
  191. ["severity"] = input.Severity,
  192. ["status"] = input.Status,
  193. ["sourceRuleCode"] = input.SourceRuleCode,
  194. ["jumpUrl"] = input.JumpUrl,
  195. };
  196. if (input.Recovered) ctx["recovered"] = "true";
  197. // S8-DEMO-IMPACT-SORT-NOTICE-1:影响统计 5 字段,仅 CREATED 路径携带,RECOVERED 路径不传入。
  198. if (input.RepeatCount30d.HasValue)
  199. ctx["repeatCount30d"] = input.RepeatCount30d.Value.ToString(System.Globalization.CultureInfo.InvariantCulture);
  200. if (input.CumulativeLossHours30d.HasValue)
  201. ctx["cumulativeLossHours30d"] = input.CumulativeLossHours30d.Value.ToString("0.#", System.Globalization.CultureInfo.InvariantCulture);
  202. if (!string.IsNullOrWhiteSpace(input.SuggestedAttentionLevel))
  203. ctx["suggestedAttentionLevel"] = input.SuggestedAttentionLevel;
  204. if (!string.IsNullOrWhiteSpace(input.SuggestedAttentionLabel))
  205. ctx["suggestedAttentionLabel"] = input.SuggestedAttentionLabel;
  206. if (!string.IsNullOrWhiteSpace(input.ImpactReason))
  207. ctx["impactReason"] = input.ImpactReason;
  208. // S8-R03-OVERDUE-CLOSE-NOTICE-1:关闭超时独立预警 4 字段,仅 CloseAsync 命中 closedAt > slaDeadline 时携带。
  209. if (input.OverdueClosed == true)
  210. ctx["overdueClosed"] = "true";
  211. if (input.ClosedAt.HasValue)
  212. ctx["closedAt"] = input.ClosedAt.Value.ToString("yyyy-MM-dd HH:mm:ss", System.Globalization.CultureInfo.InvariantCulture);
  213. if (input.SlaDeadlineRef.HasValue)
  214. ctx["slaDeadline"] = input.SlaDeadlineRef.Value.ToString("yyyy-MM-dd HH:mm:ss", System.Globalization.CultureInfo.InvariantCulture);
  215. if (input.OverdueCloseHours.HasValue)
  216. ctx["overdueCloseHours"] = input.OverdueCloseHours.Value.ToString("0.#", System.Globalization.CultureInfo.InvariantCulture);
  217. return new FlowNotification
  218. {
  219. Type = FlowNotificationTypeEnum.NewTask,
  220. BizType = "S8_EXCEPTION",
  221. InstanceId = input.ExceptionId ?? 0,
  222. Title = input.Title ?? string.Empty,
  223. Content = input.Content ?? string.Empty,
  224. Context = ctx,
  225. };
  226. }
  227. public static List<string> ParseChannels(string? csv)
  228. {
  229. if (string.IsNullOrWhiteSpace(csv)) return new List<string>();
  230. return csv.Split(new[] { ',', ';' }, StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries).ToList();
  231. }
  232. }