From 2ae5f2f4ad7d69cd68f2f805d2681b7ed3c5fb5e Mon Sep 17 00:00:00 2001
From: wenjinbo <599483010@qq.com>
Date: Wed, 17 Sep 2025 16:25:30 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E8=B0=83=E7=94=A8?=
 =?UTF-8?q?=E7=B3=BB=E7=BB=9F=E5=86=85=E7=BD=AE=E6=96=87=E4=BB=B6=E8=A1=A8?=
 =?UTF-8?q?=E5=88=9B=E5=BB=BAes=E7=B4=A2=E5=BC=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../brichat/service/task/IndexingStatusTaskService.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/chat-server/src/main/java/com/bjtds/brichat/service/task/IndexingStatusTaskService.java b/chat-server/src/main/java/com/bjtds/brichat/service/task/IndexingStatusTaskService.java
index 668a232..49fbae9 100644
--- a/chat-server/src/main/java/com/bjtds/brichat/service/task/IndexingStatusTaskService.java
+++ b/chat-server/src/main/java/com/bjtds/brichat/service/task/IndexingStatusTaskService.java
@@ -6,6 +6,7 @@ import com.bjtds.brichat.enums.IndexingStatusEnum;
 import com.bjtds.brichat.mapper.postgresql.DifyDatasetsDocMapper;
 import com.bjtds.brichat.service.DatasetFilesService;
 import com.bjtds.brichat.service.EsKnowledgeService;
+import com.bjtds.brichat.service.EsTDatasetFilesService;
 import com.bjtds.brichat.service.IndexingTaskQueueService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -36,7 +37,7 @@ public class IndexingStatusTaskService {
     private DifyDatasetsDocMapper difyDatasetsDocMapper;
 
     @Resource
-    private EsKnowledgeService esKnowledgeService;
+    private EsTDatasetFilesService esTDatasetFilesService;
     
     /**
      * 定时任务：每1秒检查一次文档索引状态
@@ -100,7 +101,7 @@ public class IndexingStatusTaskService {
 
 
                 //添加索引到ES
-                esKnowledgeService.createIndex(task.getDocumentId());
+                esTDatasetFilesService.createIndex(task.getDocumentId());
                 //修改文件状态
                 TDatasetFiles file = datasetFilesService.getFileById(task.getFileId());
                 if (file != null) {