From 020151d5065660f08a7bea9251d2b7538772e069 Mon Sep 17 00:00:00 2001
From: luoweijian <1329394916@qq.com>
Date: Fri, 26 Jun 2026 11:41:23 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                              |  7 ++++++-
 .../impl/SaveDataExtractResultDomainServiceImpl.java | 12 +++++++++++-
 2 files changed, 17 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4a58dc3..fb25743 100644
--- a/pom.xml
+++ b/pom.xml
@@ -46,7 +46,12 @@
       <artifactId>poi-ooxml</artifactId>
       <version>5.2.3</version>
     </dependency>
-
+    <!-- MQTT 客户端依赖，用于连接 oam.itc-pa.cn -->
+    <dependency>
+      <groupId>org.eclipse.paho</groupId>
+      <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+      <version>1.2.5</version>
+    </dependency>
     <!-- 钉钉官方 Java SDK (新版) -->
     <dependency>
       <groupId>com.aliyun</groupId>
diff --git a/src/main/java/com/project/interaction/domain/service/impl/SaveDataExtractResultDomainServiceImpl.java b/src/main/java/com/project/interaction/domain/service/impl/SaveDataExtractResultDomainServiceImpl.java
index 6397533..adc9c70 100644
--- a/src/main/java/com/project/interaction/domain/service/impl/SaveDataExtractResultDomainServiceImpl.java
+++ b/src/main/java/com/project/interaction/domain/service/impl/SaveDataExtractResultDomainServiceImpl.java
@@ -5,6 +5,7 @@ import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.project.information.domain.entity.InformationEntity;
 import com.project.information.domain.entity.InformationFileEntity;
+import com.project.information.domain.enums.DraftStatusEnum;
 import com.project.information.domain.enums.FileParseStatusEnum;
 import com.project.information.domain.enums.InformationParseStatusEnum;
 import com.project.information.domain.service.InformationBaseService;
@@ -101,6 +102,15 @@ public class SaveDataExtractResultDomainServiceImpl implements SaveDataExtractRe
         AiExtractRequestDTO request = buildExtractRequest(informationId);
         if (request != null) {
             postToAiExtractDomainService.postToAiExtract(request);
+        } else {
+            // 所有子文件解析文本均为空，无知识点可提取，视为解析成功
+            InformationEntity information = informationBaseService.getById(informationId);
+            if (information != null) {
+                information.setParseStatus(InformationParseStatusEnum.Success.getValue());
+                information.setDraftStatus(DraftStatusEnum.PENDING.getValue());
+                informationBaseService.updateById(information);
+            }
+            log.info(">>> [数据服务回调] 虚拟资料 {} 所有子文件解析文本为空，无知识点，视为解析成功，draftStatus=PENDING", informationId);
         }
     }
 
@@ -116,7 +126,7 @@ public class SaveDataExtractResultDomainServiceImpl implements SaveDataExtractRe
 
         List<AiExtractRequestDTO.Segment> allSegments = new ArrayList<>();
         for (InformationFileEntity f : allFiles) {
-            if (f.getParsedText() == null || f.getParsedText().isBlank()) {
+            if (f.getParsedText() == null || f.getParsedText().isBlank() || "null".equals(f.getParsedText())) {
                 continue;
             }
             // 解析 parsed_text JSON: {"segments": [[{"content": "...", "supplement": "", "chapter": "...", "content_type": "..."}]]}