From 931af963b116636f130a7e6edee1005139f884f0 Mon Sep 17 00:00:00 2001
From: zhouweiyi
Date: 星期五, 16 五月 2025 13:50:12 +0800
Subject: [PATCH] feat:pdf文件解析图片和分析图片，上传向量数据库都修改成 成异步处理
---
ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/DealFileService.java | 5 -----
ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/KnowledgeInfoServiceImpl.java | 29 +++++++++++++++++++----------
2 files changed, 19 insertions(+), 15 deletions(-)
diff --git a/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/DealFileService.java b/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/DealFileService.java
index 882fce3..2951c20 100644
--- a/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/DealFileService.java
+++ b/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/DealFileService.java
@@ -302,11 +302,6 @@
.eq(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_20)
.eq(KnowledgeAttachPic::getId, picItem.getId()));
throw new RuntimeException(e);
- } finally {
- //灏嗗浘鐗囧垎鏋愬け璐ョ殑鏁版嵁 閲嶆柊璁剧疆鐘舵��
- picMapper.update(new LambdaUpdateWrapper<KnowledgeAttachPic>()
- .set(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_10)
- .eq(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_40));
}
}
diff --git a/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/KnowledgeInfoServiceImpl.java b/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/KnowledgeInfoServiceImpl.java
index fb237b2..c34b4af 100644
--- a/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/KnowledgeInfoServiceImpl.java
+++ b/ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/knowledge/KnowledgeInfoServiceImpl.java
@@ -317,7 +317,6 @@
}
-
/**
* 妫�鏌ョ敤鎴锋槸鍚︽湁鍒犻櫎鐭ヨ瘑搴撴潈闄�
*
@@ -331,8 +330,6 @@
}
}
}
-
-
/**
* 绗竴姝� 瀹氭椂 鎷嗚ВPDF鏂囦欢涓殑鍥剧墖
*/
@@ -352,8 +349,6 @@
}
}
}
-
-
/**
* 绗簩姝� 瀹氭椂 瑙ｆ瀽鍥剧墖鍐呭
*/
@@ -363,6 +358,7 @@
List<KnowledgeAttachPic> knowledgeAttachPics = picMapper.selectList(
new LambdaQueryWrapper<KnowledgeAttachPic>()
.eq(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_10)
+ .last("LIMIT 20")
);
if (ObjectUtil.isNotEmpty(knowledgeAttachPics)) {
for (KnowledgeAttachPic picItem : knowledgeAttachPics) {
@@ -370,8 +366,6 @@
}
}
}
-
-
/**
* 绗笁姝� 瀹氭椂 澶勭悊 闄勪欢涓婁紶鍚庝笂浼犲悜閲忔暟鎹簱
*/
@@ -391,7 +385,22 @@
}
}
}
-
-
-
+ /**
+ * 绗洓姝� 瀹氭椂 澶勭悊 澶辫触鏁版嵁
+ */
+ @Scheduled(fixedDelay = 30 * 60 * 1000)
+ public void dealKnowledge40Status() throws Exception {
+ //鎷嗚ВPDF澶辫触 閲嶆柊璁剧疆鐘舵��
+ attachMapper.update(new LambdaUpdateWrapper<KnowledgeAttach>()
+ .set(KnowledgeAttach::getPicStatus, DealStatus.STATUS_10)
+ .eq(KnowledgeAttach::getPicStatus, DealStatus.STATUS_40));
+ //灏嗗浘鐗囧垎鏋愬け璐ョ殑鏁版嵁 閲嶆柊璁剧疆鐘舵��
+ picMapper.update(new LambdaUpdateWrapper<KnowledgeAttachPic>()
+ .set(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_10)
+ .eq(KnowledgeAttachPic::getPicAnysStatus, DealStatus.STATUS_40));
+ //涓婁紶鍚戦噺搴撳け璐� 閲嶆柊璁剧疆鐘舵��
+ attachMapper.update(new LambdaUpdateWrapper<KnowledgeAttach>()
+ .set(KnowledgeAttach::getVectorStatus, DealStatus.STATUS_10)
+ .eq(KnowledgeAttach::getVectorStatus, DealStatus.STATUS_40));
+ }
}
--
Gitblit v1.9.3