From 09b7b1bdcdc91d7413ab2c140112affb168d4c64 Mon Sep 17 00:00:00 2001
From: YuTengjing <ytj2713151713@gmail.com>
Date: Wed, 25 Mar 2026 22:00:49 +0800
Subject: [PATCH] =?UTF-8?q?=E2=99=BB=EF=B8=8F=20refactor:=20use=20generati?=
 =?UTF-8?q?onBatchId=20as=20notification=20dedupeKey?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/app/(backend)/api/webhooks/video/[provider]/route.ts     | 2 +-
 src/business/server/image-generation/notifyImageCompleted.ts | 2 +-
 src/business/server/video-generation/notifyVideoCompleted.ts | 2 +-
 src/server/routers/async/image.ts                            | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/app/(backend)/api/webhooks/video/[provider]/route.ts b/src/app/(backend)/api/webhooks/video/[provider]/route.ts
index 6527f24ffd..470c335001 100644
--- a/src/app/(backend)/api/webhooks/video/[provider]/route.ts
+++ b/src/app/(backend)/api/webhooks/video/[provider]/route.ts
@@ -203,9 +203,9 @@ export const POST = async (req: Request, { params }: { params: Promise<{ provide
     });
 
     notifyVideoCompleted({
+      generationBatchId: generation.generationBatchId!,
       model: resolvedModel,
       prompt: batch?.prompt ?? '',
-      taskId: asyncTask.id,
       topicId: batch?.generationTopicId,
       userId: asyncTask.userId,
     }).catch((err) => console.error('[video-webhook] notification failed:', err));
diff --git a/src/business/server/image-generation/notifyImageCompleted.ts b/src/business/server/image-generation/notifyImageCompleted.ts
index 33b5326226..44525841fe 100644
--- a/src/business/server/image-generation/notifyImageCompleted.ts
+++ b/src/business/server/image-generation/notifyImageCompleted.ts
@@ -1,8 +1,8 @@
 interface NotifyImageCompletedParams {
   duration: number;
+  generationBatchId: string;
   model: string;
   prompt: string;
-  taskId: string;
   topicId?: string;
   userId: string;
 }
diff --git a/src/business/server/video-generation/notifyVideoCompleted.ts b/src/business/server/video-generation/notifyVideoCompleted.ts
index f99afd24de..b49d1d5e0a 100644
--- a/src/business/server/video-generation/notifyVideoCompleted.ts
+++ b/src/business/server/video-generation/notifyVideoCompleted.ts
@@ -1,7 +1,7 @@
 interface NotifyVideoCompletedParams {
+  generationBatchId: string;
   model: string;
   prompt: string;
-  taskId: string;
   topicId?: string;
   userId: string;
 }
diff --git a/src/server/routers/async/image.ts b/src/server/routers/async/image.ts
index 4f81481d6f..d746a4b4c4 100644
--- a/src/server/routers/async/image.ts
+++ b/src/server/routers/async/image.ts
@@ -345,9 +345,9 @@ export const imageRouter = router({
 
           notifyImageCompleted({
             duration,
+            generationBatchId,
             model,
             prompt: params.prompt,
-            taskId,
             topicId: generationTopicId,
             userId: ctx.userId,
           }).catch((err) => console.error('[image-async] notification failed:', err));