S8WatchRuleService.cs 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474
  1. using System.Text.Json;
  2. using Admin.NET.Plugin.AiDOP.Dto.S8;
  3. using Admin.NET.Plugin.AiDOP.Entity.S8;
  4. using Admin.NET.Plugin.AiDOP.Infrastructure;
  5. using Admin.NET.Plugin.AiDOP.Infrastructure.S8;
  6. using Admin.NET.Plugin.AiDOP.Service.S8.Rules;
  7. using Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess;
  8. using Admin.NET.Plugin.AiDOP.Service.S8.Rules.Definitions;
  9. namespace Admin.NET.Plugin.AiDOP.Service.S8;
  10. public class S8WatchRuleService : ITransient
  11. {
  12. private readonly SqlSugarRepository<AdoS8WatchRule> _rep;
  13. private readonly S8DatasetEnableGate _datasetEnableGate;
  14. private readonly IS8RuleCatalog _ruleCatalog;
  15. private readonly IS8DatasetCatalog _datasetCatalog;
  16. public S8WatchRuleService(
  17. SqlSugarRepository<AdoS8WatchRule> rep,
  18. S8DatasetEnableGate datasetEnableGate,
  19. IS8RuleCatalog ruleCatalog,
  20. IS8DatasetCatalog datasetCatalog)
  21. {
  22. _rep = rep;
  23. _datasetEnableGate = datasetEnableGate;
  24. _ruleCatalog = ruleCatalog;
  25. _datasetCatalog = datasetCatalog;
  26. }
  27. /// <summary>
  28. /// S8-RULE-GOVERNANCE-BATCH4:返回合并了**代码定义投影**的只读行模型。
  29. ///
  30. /// <para>原实现直接返回实体,于是配置页只拿得到数据库列 —— 而规则名称、业务说明、
  31. /// 异常类型、判定口径自 Batch 1 起只存在于代码定义里,页面无处取数。
  32. /// 唯一的替代是前端按 ruleCode 硬编码,那等于把定义抄第二份,必然漂移。</para>
  33. ///
  34. /// <para>本方法**纯读**:不写库、不触发供给。孤儿行(目录里没有该 rule_code)
  35. /// 照常返回,但 <c>DefinitionMissing = true</c>、定义字段为 null,
  36. /// 由页面禁用相关操作 —— 不删、不隐藏,运维需要看得见它们。</para>
  37. /// </summary>
  38. public async Task<List<S8WatchRuleRowDto>> ListAsync(long tenantId)
  39. {
  40. var rows = await _rep.AsQueryable()
  41. .Where(x => x.TenantId == tenantId)
  42. .ToListAsync();
  43. return rows.Select(ToRowDto).ToList();
  44. }
  45. private S8WatchRuleRowDto ToRowDto(AdoS8WatchRule row)
  46. {
  47. var definition = _ruleCatalog.TryGet(row.RuleCode);
  48. // 参数解析必须有定义才能进行(取值域与默认值都来自定义)。
  49. // 孤儿行退回实体列原值,让页面仍能显示"它现在是什么样",只是不能改。
  50. var parameters = definition == null ? null : S8RuleRuntimeParameters.Resolve(row, definition);
  51. return new S8WatchRuleRowDto
  52. {
  53. Id = row.Id,
  54. TenantId = row.TenantId,
  55. FactoryId = row.FactoryId,
  56. RuleCode = row.RuleCode,
  57. DefinitionMissing = definition == null,
  58. DisplayName = definition?.DisplayName,
  59. Description = definition?.Description,
  60. DatasetCode = definition?.DatasetCode ?? row.DatasetCode,
  61. // 只下发数据集**业务名称**。数据集 Description 里含物理表名与取数口径,
  62. // 属实现细节,绝不外发(见 S8BusinessDatasetDefinitions 的 Description 正文)。
  63. DatasetDisplayName = _datasetCatalog.Find(definition?.DatasetCode ?? row.DatasetCode)?.DisplayName,
  64. RuleType = definition?.RuleType ?? row.RuleType,
  65. RuleMechanism = definition?.RuleMechanism ?? row.RuleMechanism,
  66. SourceObjectType = definition?.SourceObjectType ?? row.SourceObjectType,
  67. SceneCode = definition?.SceneCode ?? row.SceneCode,
  68. StageCode = definition?.StageCode ?? row.StageCode,
  69. OrderFlowCode = definition?.OrderFlowCode ?? row.OrderFlowCode,
  70. ExceptionTypeCode = definition?.ExceptionTypeCode,
  71. JudgementSummary = definition?.JudgementSummary,
  72. CompletedStates = definition?.Timeout?.CompletedStates ?? Array.Empty<string>(),
  73. DedupIdentitySummary = definition?.DedupIdentitySummary,
  74. AllowedParameters = definition == null ? null : ToPolicyDto(definition.Parameters),
  75. Enabled = row.Enabled,
  76. Severity = parameters?.Severity ?? row.Severity,
  77. PollIntervalSeconds = parameters?.PollIntervalSeconds ?? row.PollIntervalSeconds,
  78. TriggerCountRequired = parameters?.TriggerCountRequired ?? row.TriggerCountRequired,
  79. RecoverCountRequired = parameters?.RecoverCountRequired ?? row.RecoverCountRequired,
  80. GraceMinutes = parameters?.GraceMinutes ?? 0,
  81. DefaultOccurrenceDeptId = parameters?.DefaultOccurrenceDeptId,
  82. DefaultResponsibleDeptId = parameters?.DefaultResponsibleDeptId,
  83. NextRunAt = row.NextRunAt,
  84. LastRunAt = row.LastRunAt,
  85. LastStatus = row.LastStatus,
  86. LastError = row.LastError,
  87. LastDurationMs = row.LastDurationMs,
  88. LastRunId = row.LastRunId,
  89. ConsecutiveFailureCount = row.ConsecutiveFailureCount,
  90. PausedUntil = row.PausedUntil,
  91. PauseReason = row.PauseReason,
  92. CreatedAt = row.CreatedAt,
  93. UpdatedAt = row.UpdatedAt
  94. };
  95. }
  96. private static S8RuleParameterPolicyDto ToPolicyDto(S8RuleParameterPolicy p) => new()
  97. {
  98. PollIntervalSecondsMin = p.PollIntervalSecondsMin,
  99. PollIntervalSecondsMax = p.PollIntervalSecondsMax,
  100. TriggerCountRequiredMin = p.TriggerCountRequiredMin,
  101. TriggerCountRequiredMax = p.TriggerCountRequiredMax,
  102. RecoverCountRequiredMin = p.RecoverCountRequiredMin,
  103. RecoverCountRequiredMax = p.RecoverCountRequiredMax,
  104. GraceMinutesMin = p.GraceMinutesMin,
  105. GraceMinutesMax = p.GraceMinutesMax,
  106. AllowedSeverities = p.AllowedSeverities,
  107. AllowsDepartmentDefaults = p.AllowsDepartmentDefaults
  108. };
  109. // ================================================================================
  110. // S8-RULE-GOVERNANCE-BATCH3:业务侧建规则能力已退役。
  111. //
  112. // 原实现是「客户端传一个 AdoS8WatchRule → 服务端盖章归属 → 校验词表 → 落库」,
  113. // 即调用方可以凭空定义一条规则的 rule_code / dataset_code / rule_type /
  114. // source_object_type / scene_code,再配一段 params_json 决定它判什么。
  115. // 那正是 Batch 1 要消灭的形态:规则的业务语义必须来自代码定义,不能来自请求体。
  116. //
  117. // 替代路径(Batch 2 已建立,且**不经过本方法**):
  118. // S8RuleCatalog(代码定义)
  119. // → S8RuleProvisioningService(系统内部写路径)
  120. // → 每租户一条 runtime policy,默认停用
  121. //
  122. // ⚠️ 抛出发生在**任何 DB 访问之前**:不查重、不读场景、不碰仓储。
  123. // 这既保证零写入,也让「能力没了」这件事与入参是否合法无关。
  124. //
  125. // 保留方法名而非整个删掉:S8RuleCreationRetiredTests 用反射断言
  126. // 「该名字存在但恒抛退役异常」,比断言「名字不存在」更能防住有人换个名字复活它。
  127. // ================================================================================
  128. public Task<AdoS8WatchRule> CreateAsync(AdoS8WatchRule body, S8TrustedScope scope) =>
  129. throw new S8WriteRetiredException(S8WriteRetiredException.WatchRuleCreateMessage);
  130. // ================================================================================
  131. // S8-STEP6E-CFG-WATCH-FIX-AND-SAFE-CERT-1:通用整实体 PUT 已退役。
  132. //
  133. // 原实现 `_rep.UpdateAsync(body)` 是**整列更新**,而 body 直接由客户端 JSON 绑定
  134. // (本实体即 DTO),服务端只重新盖章 5 个字段(Tenant/Factory/Id/CreatedAt/UpdatedAt)。
  135. // 实体与仓储层均无 UpdateIgnoreColumns / IsOnlyIgnoreUpdate 保护,因此调用方可写入
  136. // 全部 13 个 scheduler-owned 运行时列:
  137. // lock_token / locked_by / lock_until / running_started_at /
  138. // next_run_at / last_run_at / last_status / last_error / last_duration_ms / last_run_id /
  139. // consecutive_failure_count / paused_until / pause_reason
  140. //
  141. // 后果(按 S8WatchSchedulerService 的租约语义):
  142. // · 写 lock_token/lock_until → 窃取或作废活跃租约,令运行中实例的回写静默失败
  143. // · 清 lock → 第二实例重复拾取同一规则 → 重复建单
  144. // · lock_until 设远未来 → 该规则永不再被 PickReadyRulesAsync 选中(静默 DoS)
  145. // · paused_until 设远未来 → UI 仍显示「启用」但监控实际已停
  146. // · 写 last_status/last_run_id/last_error → 伪造调度审计轨迹
  147. // 且**无需恶意**:部分字段的 PUT body 会让这 13 列静默变 NULL(HTTP 200、无报错)。
  148. //
  149. // 退役而非改白名单,是因为该入口没有正式消费方(已穷举:前端 s8ConfigApi.watchRules
  150. // 无 update;e2e 只用 GET/POST/DELETE;服务端唯一引用是本 controller),
  151. // 而正式配置修改已有 UpdateParamsAsync / UpdateScheduleAsync 等窄入口。
  152. //
  153. // ⚠️ 抛出发生在**任何 DB 访问之前**:不做 LoadScopedAsync、不做重复性查询。
  154. // 这既保证零 DB 触碰,也保证任意 id(含越权 id)一律 410 而非 404
  155. // ——「这个能力没了」优先于「这条记录不属于你」,避免越权探测反推他租户数据是否存在。
  156. //
  157. // 保留方法签名是硬约束:S8TenantIsolationContractTests 用反射断言带 S8TrustedScope
  158. // 的写入口存在、且无 scope 的旧重载不存在。
  159. // ================================================================================
  160. public Task<AdoS8WatchRule> UpdateAsync(long id, AdoS8WatchRule body, S8TrustedScope scope) =>
  161. throw new S8WriteRetiredException(S8WriteRetiredException.WatchRuleUpdateMessage);
  162. // ================================================================================
  163. // S8-RULE-GOVERNANCE-BATCH3:业务侧删规则能力已退役。
  164. //
  165. // 规则定义的生命周期属于代码版本;运行策略行的删除同样不该由页面触发:
  166. // · 删掉会连带丢失该租户已调好的参数与运行历史(含 recovered/抗抖计数);
  167. // · 下一次供给对账又会把它按默认值建回来 —— 用户看到的是"删了又回来了";
  168. // · 真正的诉求「不想让这条规则再跑」已经有正确表达:**停用**。
  169. //
  170. // 规则撤销的唯一正当路径是代码版本移除 Definition,随后由治理流程处理 orphan 行
  171. //(Provisioning 的 OrphanedCount 会持续上报,Scheduler 以 rule_definition_not_found 拒绝执行)。
  172. //
  173. // ⚠️ 与 CreateAsync 同理:抛出在任何 DB 访问之前,任意 id(含越权 id)一律 410 而非 404。
  174. // ================================================================================
  175. public Task DeleteAsync(long id, S8TrustedScope scope) =>
  176. throw new S8WriteRetiredException(S8WriteRetiredException.WatchRuleDeleteMessage);
  177. /// <summary>
  178. /// 按 Id + 租户取行;不在作用域内一律按「不存在」处理,不泄露他租户资源是否存在。
  179. ///
  180. /// <para><b>S8-TENANT-ONLY-BATCH5:绑行只认 Tenant。</b>
  181. /// 运行策略的身份在 Batch 2 已定为 (TenantId, RuleCode),而此处仍按工厂绑行 ——
  182. /// 结果是 Batch 2 供给出来的 factory_id=0 的行,任何配置操作都会 404。</para>
  183. /// </summary>
  184. private async Task<AdoS8WatchRule> LoadScopedAsync(long id, S8TrustedScope scope) =>
  185. await _rep.AsQueryable()
  186. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  187. .FirstAsync() ?? throw new S8NotFoundException();
  188. /// <summary>
  189. /// S8-RULE-GOVERNANCE-BATCH1:运行参数的**部分更新**。
  190. ///
  191. /// <para>与被它取代的 <c>UpdateParamsAsync</c> 的三处根本差异:</para>
  192. /// <list type="number">
  193. /// <item><b>不再接受 params_json 原文</b>。判定语义(dueAtField / statusField /
  194. /// completedStates / objectIdField / exceptionTypeCode)现在只存在于代码定义里,
  195. /// 没有任何 API 能改到它们;</item>
  196. /// <item><b>不再承担启停</b>。enabled 走 <see cref="EnableAsync"/> / <see cref="DisableAsync"/>;</item>
  197. /// <item><b>PATCH 而非整块覆盖</b>。未提供的字段保持原值 —— 这是 G1 的直接修复:
  198. /// 旧实现里一次 <c>{"enabled":false}</c> 就会把 params_json 抹成 NULL。</item>
  199. /// </list>
  200. ///
  201. /// <para>写入用 <c>UpdateColumns</c> 白名单,物理上无法触碰 Definition 投影列与 13 个调度运行态列。</para>
  202. /// </summary>
  203. public async Task<AdoS8WatchRule> UpdateParametersAsync(long id, S8RuleParametersPayload payload, S8TrustedScope scope)
  204. {
  205. // 前置拒绝:在任何 DB 访问之前判掉非法载荷,越权 id 也不会被用来探测记录是否存在。
  206. // 同一道守卫在 ApplyParameters 内再做一次 —— 那里才是所有调用方的必经之处。
  207. EnsureNoDefinitionFields(payload);
  208. var entity = await LoadScopedAsync(id, scope);
  209. var definition = _ruleCatalog.GetRequired(entity.RuleCode);
  210. var next = ApplyParameters(entity, payload, definition);
  211. await _rep.Context.Updateable<AdoS8WatchRule>()
  212. .SetColumns(x => new AdoS8WatchRule
  213. {
  214. PollIntervalSeconds = next.PollIntervalSeconds,
  215. TriggerCountRequired = next.TriggerCountRequired,
  216. RecoverCountRequired = next.RecoverCountRequired,
  217. Severity = next.Severity,
  218. ParamsJson = next.ToParamsJson(),
  219. UpdatedAt = DateTime.Now
  220. })
  221. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  222. .ExecuteCommandAsync();
  223. return await LoadScopedAsync(id, scope);
  224. }
  225. /// <summary>
  226. /// 纯函数:把 PATCH 载荷叠加到「当前生效参数」上,并按 Definition 声明的取值域校验。
  227. ///
  228. /// <para>抽成 static 是为了让 G1 的核心不变量(未提供 = 不变)能在**不接数据库**的情况下被测试
  229. /// 逐字段断言。之前那条缺陷之所以能活到生产,正是因为它藏在一个必须有仓储才能跑的方法里。</para>
  230. /// </summary>
  231. internal static S8RuleRuntimeParameters ApplyParameters(
  232. AdoS8WatchRule entity, S8RuleParametersPayload payload, S8RuleDefinition definition)
  233. {
  234. EnsureNoDefinitionFields(payload);
  235. var current = S8RuleRuntimeParameters.Resolve(entity, definition);
  236. var policy = definition.Parameters ?? new S8RuleParameterPolicy();
  237. var poll = payload.PollIntervalSeconds ?? current.PollIntervalSeconds;
  238. var trigger = payload.TriggerCountRequired ?? current.TriggerCountRequired;
  239. var recover = payload.RecoverCountRequired ?? current.RecoverCountRequired;
  240. var grace = payload.GraceMinutes ?? current.GraceMinutes;
  241. var severity = payload.Severity?.Trim() ?? current.Severity;
  242. EnsureInRange("轮询间隔(秒)", poll, policy.PollIntervalSecondsMin, policy.PollIntervalSecondsMax);
  243. EnsureInRange("连续命中建单次数", trigger, policy.TriggerCountRequiredMin, policy.TriggerCountRequiredMax);
  244. EnsureInRange("连续未命中恢复次数", recover, policy.RecoverCountRequiredMin, policy.RecoverCountRequiredMax);
  245. EnsureInRange("宽限分钟", grace, policy.GraceMinutesMin, policy.GraceMinutesMax);
  246. if (!policy.AllowedSeverities.Contains(severity, StringComparer.Ordinal))
  247. throw new S8BizException(
  248. $"不支持的严重度:{severity};当前规则仅支持 {string.Join(" / ", policy.AllowedSeverities)}");
  249. var occurrenceDept = payload.DefaultOccurrenceDeptId ?? current.DefaultOccurrenceDeptId;
  250. var responsibleDept = payload.DefaultResponsibleDeptId ?? current.DefaultResponsibleDeptId;
  251. if (!policy.AllowsDepartmentDefaults && (occurrenceDept.HasValue || responsibleDept.HasValue))
  252. throw new S8BizException("当前规则不支持配置部门兜底");
  253. return new S8RuleRuntimeParameters
  254. {
  255. PollIntervalSeconds = poll,
  256. TriggerCountRequired = trigger,
  257. RecoverCountRequired = recover,
  258. Severity = severity,
  259. GraceMinutes = grace,
  260. DefaultOccurrenceDeptId = occurrenceDept,
  261. DefaultResponsibleDeptId = responsibleDept
  262. };
  263. }
  264. /// <summary>
  265. /// 载荷里出现 Definition 字段(或已迁走的 enabled)一律**显式拒绝**。
  266. ///
  267. /// <para>静默忽略等于告诉调用方"改成功了",而实际什么都没发生 —— 那比报错更危险,
  268. /// 因为调用方会据此认为规则已经按新口径运行。</para>
  269. ///
  270. /// <para>放在 <see cref="ApplyParameters"/> 内而不是只放在 API 层:
  271. /// 纯函数是所有写入路径的必经之处,守卫挂在这里才不会被下一个调用方绕过。</para>
  272. /// </summary>
  273. private static void EnsureNoDefinitionFields(S8RuleParametersPayload payload)
  274. {
  275. if (payload == null) throw new S8BizException("请求体不能为空");
  276. var rejected = payload.RejectedDefinitionFields;
  277. if (rejected.Count > 0)
  278. throw new S8BizException(
  279. "以下字段由代码定义,不能通过参数接口修改:" + string.Join(" / ", rejected)
  280. + ";启停请使用 /enable 与 /disable");
  281. }
  282. private static void EnsureInRange(string label, int value, int min, int max)
  283. {
  284. if (value < min || value > max)
  285. throw new S8BizException($"{label} 必须在 {min}–{max} 之间,当前值 {value}");
  286. }
  287. /// <summary>
  288. /// 启用规则。<b>只写 enabled 与调度触发时间,绝不触碰任何参数列或 Definition 投影列。</b>
  289. ///
  290. /// <para>幂等:已启用时直接返回,不产生写入 —— 重复调用不会重排下次执行时间,
  291. /// 也就不会被用来变相"插队"调度。</para>
  292. /// </summary>
  293. public async Task<AdoS8WatchRule> EnableAsync(long id, S8TrustedScope scope)
  294. {
  295. var entity = await LoadScopedAsync(id, scope);
  296. if (entity.Enabled) return entity;
  297. // ① 没有代码定义的规则不得启用。这是 Create API 仍然存在期间的安全过渡:
  298. // 业务即使造出一条任意 rule_code 的规则,也无法让调度器替它跑。
  299. var definition = _ruleCatalog.GetRequired(entity.RuleCode);
  300. // ② 数据集侧完整运行条件。按 Definition 的 dataset_code / rule_type 判定,
  301. // 而不是 DB 上那两列 —— 后者是投影,可能被人为改过。
  302. _datasetEnableGate.EnsureCanEnable(
  303. definition.DatasetCode, definition.RuleType, definition.RuleCode, scope.TenantId);
  304. var now = DateTime.Now;
  305. await _rep.Context.Updateable<AdoS8WatchRule>()
  306. .SetColumns(x => new AdoS8WatchRule
  307. {
  308. Enabled = true,
  309. NextRunAt = now,
  310. UpdatedAt = now
  311. })
  312. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  313. .ExecuteCommandAsync();
  314. return await LoadScopedAsync(id, scope);
  315. }
  316. /// <summary>
  317. /// 停用规则。<b>只写 enabled。</b>
  318. ///
  319. /// <para>幂等:已停用时直接返回。</para>
  320. /// <para>不动 lease / next_run_at:<c>PickReadyRulesAsync</c> 的候选谓词第一条就是
  321. /// <c>x.Enabled</c>,停用后自然不会再被拾取;正在执行中的那一轮由
  322. /// <c>ResetExpiredLeasesAsync</c> 按既有租约语义收尾。强行清租约反而会与正在跑的实例撕扯。</para>
  323. /// </summary>
  324. public async Task<AdoS8WatchRule> DisableAsync(long id, S8TrustedScope scope)
  325. {
  326. var entity = await LoadScopedAsync(id, scope);
  327. if (!entity.Enabled) return entity;
  328. // 停用**不过** Enable Gate:数据集出问题之后仍然必须能把规则关掉。
  329. await _rep.Context.Updateable<AdoS8WatchRule>()
  330. .SetColumns(x => new AdoS8WatchRule
  331. {
  332. Enabled = false,
  333. UpdatedAt = DateTime.Now
  334. })
  335. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  336. .ExecuteCommandAsync();
  337. return await LoadScopedAsync(id, scope);
  338. }
  339. // S8-RULE-GOVERNANCE-BATCH3:以下三段随建规则能力一并删除 ——
  340. // · CanonicalRuleTypes / ValidateVocabularyForCreate:校验的是"调用方传来的 rule_type、
  341. // scene_code、severity 是否在词表内",而这三项现在只可能来自代码定义,
  342. // 由 S8RuleCatalog 在构造期做更严格的校验(含 ordinal 精确匹配);
  343. // · ValidateParamsJsonShape:校验的是调用方提交的 params_json,
  344. // 而 params_json 已不再由任何接口整块写入;
  345. // · ValidateAsync:唯一调用方是已退役的 CreateAsync / TestAsync,且它要求
  346. // ado_s8_scene_config 存在对应场景行 —— 对代码定义的规则那是一条无关的额外前提。
  347. // 留着它们只会让人以为还存在"提交规则定义"这条路。
  348. // S8-SCHED-FRONTEND-1:远未来手工暂停哨兵值(与 SqlSugar DateTime 兼容;前端按 paused_until > now 判定)。
  349. private static readonly DateTime ManualPausedSentinel = new(9999, 12, 31, 23, 59, 59);
  350. /// <summary>
  351. /// S8-SCHED-FRONTEND-1:调度参数安全更新。仅修改 poll_interval_seconds / trigger_count_required /
  352. /// recover_count_required;不动 params_json / expression / rule_type / scene_code / data_source_id。
  353. /// </summary>
  354. public Task<AdoS8WatchRule> UpdateScheduleAsync(long id, S8WatchRuleSchedulePayload payload, S8TrustedScope scope) =>
  355. // S8-RULE-GOVERNANCE-BATCH1:三个调度字段已并入统一参数白名单,本入口只做形状转换后委托,
  356. // 不再各自维护一份取值域 —— 两处取值域一旦漂移,就会出现「A 接口存得下、B 接口存不下」。
  357. UpdateParametersAsync(id, new S8RuleParametersPayload
  358. {
  359. PollIntervalSeconds = payload?.PollIntervalSeconds,
  360. TriggerCountRequired = payload?.TriggerCountRequired,
  361. RecoverCountRequired = payload?.RecoverCountRequired
  362. }, scope);
  363. /// <summary>
  364. /// S8-SCHED-FRONTEND-1:立即执行一次。把 next_run_at 置为 NOW,让下个 tick 拾取。
  365. /// 不直接同步执行 evaluator;不阻塞请求;返回 200 + 提示。
  366. /// </summary>
  367. public async Task<object> RunNowAsync(long id, S8TrustedScope scope)
  368. {
  369. var entity = await LoadScopedAsync(id, scope);
  370. if (!entity.Enabled)
  371. throw new S8BizException("规则未启用,不能立即执行");
  372. var now = DateTime.Now;
  373. if (entity.PausedUntil.HasValue && entity.PausedUntil.Value > now)
  374. throw new S8BizException("规则已暂停,请先恢复");
  375. if (entity.LockUntil.HasValue && entity.LockUntil.Value > now)
  376. throw new S8BizException("规则正在执行中,请稍后再试");
  377. await _rep.Context.Updateable<AdoS8WatchRule>()
  378. .SetColumns(x => new AdoS8WatchRule
  379. {
  380. NextRunAt = now,
  381. UpdatedAt = now
  382. })
  383. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  384. .ExecuteCommandAsync();
  385. return new { id, queued = true, message = "已排队,最长 1 分钟内执行" };
  386. }
  387. /// <summary>
  388. /// S8-SCHED-FRONTEND-1:手工暂停。paused_until = 9999-12-31 哨兵 + pause_reason=MANUAL_PAUSED。
  389. /// 不强杀正在执行的 lease;当前运行完成后下一轮自然不被拾取。
  390. /// 不清 last_status / last_error。
  391. /// </summary>
  392. public async Task<object> PauseAsync(long id, S8TrustedScope scope)
  393. {
  394. var entity = await LoadScopedAsync(id, scope);
  395. await _rep.Context.Updateable<AdoS8WatchRule>()
  396. .SetColumns(x => new AdoS8WatchRule
  397. {
  398. PausedUntil = ManualPausedSentinel,
  399. PauseReason = "MANUAL_PAUSED",
  400. UpdatedAt = DateTime.Now
  401. })
  402. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  403. .ExecuteCommandAsync();
  404. return new { id, paused = true, message = "已暂停" };
  405. }
  406. /// <summary>
  407. /// S8-SCHED-FRONTEND-1:恢复。清 paused_until / pause_reason / last_error;归零 consecutive_failure_count;
  408. /// next_run_at = NOW 让下个 tick 立即拾取。不改 enabled / params_json / rule_type。
  409. /// </summary>
  410. public async Task<object> ResumeAsync(long id, S8TrustedScope scope)
  411. {
  412. var entity = await LoadScopedAsync(id, scope);
  413. var now = DateTime.Now;
  414. await _rep.Context.Updateable<AdoS8WatchRule>()
  415. .SetColumns(x => new AdoS8WatchRule
  416. {
  417. PausedUntil = null,
  418. PauseReason = null,
  419. ConsecutiveFailureCount = 0,
  420. LastError = null,
  421. NextRunAt = now,
  422. UpdatedAt = now
  423. })
  424. .Where(x => x.Id == id && x.TenantId == scope.TenantId)
  425. .ExecuteCommandAsync();
  426. return new { id, resumed = true, message = "已恢复,并将在下一轮调度中执行" };
  427. }
  428. }