From 62885005e09e584947c19975e176ee336b1eb781 Mon Sep 17 00:00:00 2001
From: abearxiong <xiongxiao@xiongxiao.me>
Date: Sat, 10 Jan 2026 16:51:18 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E4=B8=8B=E8=BD=BD=E5=9B=BE?=
 =?UTF-8?q?=E5=83=8F=E6=96=B9=E6=B3=95=E4=BB=A5=E8=BF=94=E5=9B=9E=20Uint8A?=
 =?UTF-8?q?rray=EF=BC=8C=E8=B0=83=E6=95=B4=E4=B8=8B=E8=BD=BD=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E7=9A=84=E9=87=8D=E8=AF=95=E5=BB=B6=E8=BF=9F=E5=92=8C?=
 =?UTF-8?q?=E5=B9=B6=E5=8F=91=E8=AE=BE=E7=BD=AE=EF=BC=8C=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E6=8F=90=E7=A4=BA=E8=AF=8D=E5=B7=A5=E4=BD=9C=E8=80=85=E7=9A=84?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97=E8=BE=93=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 prompts/src/services/jimeng.service.ts   | 4 ++--
 prompts/src/task/image-creator.job.ts    | 8 ++++----
 prompts/src/task/perfect-sentence.job.ts | 4 ++--
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/prompts/src/services/jimeng.service.ts b/prompts/src/services/jimeng.service.ts
index e4835dc..6f6c18a 100644
--- a/prompts/src/services/jimeng.service.ts
+++ b/prompts/src/services/jimeng.service.ts
@@ -80,7 +80,7 @@ export class JimengService {
     }
   }
 
-  async downloadImage(url: string): Promise<Buffer> {
+  async downloadImage(url: string): Promise<Uint8Array> {
     const controller = new AbortController();
     const timeoutId = setTimeout(() => controller.abort(), this.timeout);
 
@@ -96,7 +96,7 @@ export class JimengService {
       }
 
       const arrayBuffer = await response.arrayBuffer();
-      return Buffer.from(arrayBuffer);
+      return new Uint8Array(arrayBuffer);
     } catch (error: any) {
       clearTimeout(timeoutId);
       if (error.name === 'AbortError') {
diff --git a/prompts/src/task/image-creator.job.ts b/prompts/src/task/image-creator.job.ts
index 0e87723..e7745ba 100644
--- a/prompts/src/task/image-creator.job.ts
+++ b/prompts/src/task/image-creator.job.ts
@@ -95,7 +95,7 @@ export async function addImageDownloadJob(
     attempts: DOWNLOAD_MAX_RETRIES,
     backoff: {
       type: 'exponential',
-      delay: 2000, // 初始 2 秒
+      delay: 200, // 初始 200 毫秒
     },
     removeOnComplete: 100,
     removeOnFail: 100,
@@ -147,7 +147,7 @@ export async function runImageDownloadWorker(): Promise<void> {
     },
     {
       connection,
-      concurrency: 3,
+      concurrency: 1, // 避免更新冲突
       lockDuration: 60000 * 5, // 锁持续时间 5分钟
       stalledInterval: 30000, // 每30秒检查一次 stalled
     } as any
@@ -162,7 +162,7 @@ export async function runImageDownloadWorker(): Promise<void> {
     notify.notify(`[ImageDownload] \nJob failed: ${job?.id}, error: ${err.message}\n Job data: ${JSON.stringify(job?.data)}`);
   });
 
-  console.log('[ImageDownload] Worker started');
+  console.log('[ImageDownload] Worker 开始运行');
 }
 
 /**
@@ -226,7 +226,7 @@ export async function runImageGenerateWorker(): Promise<void> {
     }
   });
 
-  console.log('[ImageGenerate] Worker started');
+  console.log('[ImageGenerate] Worker 开始运行');
 }
 
 export { updateItemStatus };
diff --git a/prompts/src/task/perfect-sentence.job.ts b/prompts/src/task/perfect-sentence.job.ts
index 61a83ed..657226b 100644
--- a/prompts/src/task/perfect-sentence.job.ts
+++ b/prompts/src/task/perfect-sentence.job.ts
@@ -79,7 +79,7 @@ export const runPerfectSentencePromptWorker = () => {
         const perfectPrompt = perfect.clearPerfectTags(ai.responseText!) || '';
         console.log(`[Sentence] 提示词优化 ${itemId}:\n`, perfectPrompt);
 
-        await updateItemStatus(itemId, '提示词优化完成',{
+        await updateItemStatus(itemId, '提示词优化完成', {
           description: perfectPrompt
         });
         await sleep(500); // 确保数据已保存
@@ -116,6 +116,6 @@ export const runPerfectSentencePromptWorker = () => {
       notify.notify(`[Sentence] 提示词优化工作者在条目 ${job.data.itemId} 达到最大重试次数后停止`);
     }
   });
-
+  console.log('[Sentence] Worker 开始运行');
   return worker;
 };
\ No newline at end of file