From e1ab0366f00bcfa11874daedccc51749b13e4fe1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B9=9B=E5=85=AE?= Date: Fri, 12 Jun 2026 04:00:04 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E9=99=8D=E4=BD=8E=E9=80=9A=E7=9F=A5=20o?= =?UTF-8?q?utbox=20=E7=A9=BA=E6=89=AB=E6=8F=8F=E5=AE=A1=E8=AE=A1=E5=99=AA?= =?UTF-8?q?=E9=9F=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wecom/notification-outbox-retry.service.ts | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/notifications/wecom/notification-outbox-retry.service.ts b/src/notifications/wecom/notification-outbox-retry.service.ts index 034f3b3..97bfb91 100644 --- a/src/notifications/wecom/notification-outbox-retry.service.ts +++ b/src/notifications/wecom/notification-outbox-retry.service.ts @@ -1,5 +1,6 @@ /** - * 通知 outbox 重试器复用当前 provider 投递边界，后续可迁移到 BullMQ worker。 + * 通知 outbox 重试器复用当前 provider 投递边界，并避免空扫描刷屏审计。 + * 后续迁移到 BullMQ 时保留“有候选才记录成功 tick”的可观测边界。 */ import { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common'; import { ConfigService } from '@nestjs/config'; @@ -86,6 +87,10 @@ export class NotificationOutboxRetryService } } + if (messages.length === 0) { + return; + } + await this.auditService.record({ action: 'NOTIFICATION_OUTBOX_RETRY_TICK_COMPLETED', resourceType: 'notification_outbox',