diff --git a/src/modules/knowledge-source/knowledge-source.controller.ts b/src/modules/knowledge-source/knowledge-source.controller.ts
index 833962d..a57c78b 100644
--- a/src/modules/knowledge-source/knowledge-source.controller.ts
+++ b/src/modules/knowledge-source/knowledge-source.controller.ts
@@ -32,6 +32,15 @@ export class KnowledgeSourceController {
     return this.service.findOne(id);
   }
 
+  @Post(':id/parse')
+  @ApiOperation({ summary: '手动触发资料解析' })
+  async triggerParse(
+    @CurrentUser() user: UserPayload,
+    @Param('id') id: string,
+  ) {
+    return this.service.triggerParse(id, user.id);
+  }
+
   @Delete(':id')
   @ApiOperation({ summary: '删除资料来源' })
   async remove(@CurrentUser() user: UserPayload, @Param('id') id: string) {
diff --git a/src/modules/knowledge-source/knowledge-source.service.ts b/src/modules/knowledge-source/knowledge-source.service.ts
index dd8a431..99b9dd9 100644
--- a/src/modules/knowledge-source/knowledge-source.service.ts
+++ b/src/modules/knowledge-source/knowledge-source.service.ts
@@ -68,6 +68,37 @@ export class KnowledgeSourceService {
     return this.repository.softDelete(id);
   }
 
+  async triggerParse(sourceId: string, userId: string) {
+    const source = await this.repository.findById(sourceId);
+    if (!source) throw new NotFoundException('资料来源不存在');
+
+    // 创建新的 import 任务
+    const importJob = await this.importRepo.create({
+      userId,
+      knowledgeBaseId: source.knowledgeBaseId,
+      sourceId: source.id,
+      sourceType: source.type ?? 'file',
+      sourceName: source.originalFilename ?? source.title ?? '',
+      status: 'QUEUED',
+    });
+
+    // 设置 Redis 状态
+    await this.redis.set(`job:document-import:${importJob.id}:status`, 'pending', 86400);
+    await this.redis.set(`job:document-import:${importJob.id}:progress`, '0', 86400);
+    await this.redis.set(`job:document-import:${importJob.id}:message`, '手动触发重新解析', 86400);
+
+    // 入队
+    await this.queue.add('document-import', {
+      importId: importJob.id,
+      userId,
+      knowledgeBaseId: source.knowledgeBaseId,
+      sourceId: source.id,
+      fileName: source.originalFilename ?? source.title,
+    });
+
+    return { jobId: importJob.id, status: 'queued' };
+  }
+
   async updateParseStatus(id: string, parseStatus: string, data?: any) {
     return this.repository.updateParseStatus(id, parseStatus, data);
   }