test(p1r): 补齐 AI 与 Knowledge 外部端到端验收

muse-cloud/muse-module-ai/muse-module-ai-server/src/main/resources/application.yaml

@@ -73,8 +73,8 @@ mybatis-plus:
       #      id-type: AUTO # 自增 ID，适合 MySQL 等直接自增的数据库
       #      id-type: INPUT # 用户输入 ID，适合 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库
       #      id-type: ASSIGN_ID # 分配 ID，默认使用雪花算法。注意，Oracle、PostgreSQL、Kingbase、DB2、H2 数据库时，需要去除实体类上的 @KeySequence 注解
-      logic-delete-value: 1 # 逻辑已删除值(默认为 1)
-      logic-not-delete-value: 0 # 逻辑未删除值(默认为 0)
+      logic-delete-value: true # 逻辑已删除值，匹配 PostgreSQL boolean deleted 字段
+      logic-not-delete-value: false # 逻辑未删除值，匹配 PostgreSQL boolean deleted 字段
     banner: false # 关闭控制台的 Banner 打印
   type-aliases-package: ${muse.info.base-package}.module.*.dal.dataobject
   encryptor:

muse-cloud/muse-module-knowledge/muse-module-knowledge-server/src/main/java/cn/iocoder/muse/module/knowledge/application/muse/MuseKnowledgeDocumentService.java

@@ -293,7 +293,7 @@ public class MuseKnowledgeDocumentService {
             return new UploadOutcome(ragflowContext, "failed");
         }
         processingTaskService.markRagflowParseAccepted(ragflowContext.version().getId(), ragflowContext.task().getTaskId(),
-                uploadResult.externalId(), parseResult);
+                ragflowContext.ragflowDatasetId(), uploadResult.externalId(), parseResult);
         return new UploadOutcome(ragflowContext, "processing");
     }
 

muse-cloud/muse-module-knowledge/muse-module-knowledge-server/src/main/java/cn/iocoder/muse/module/knowledge/application/muse/MuseKnowledgeProcessingTaskService.java

@@ -177,13 +177,15 @@ public class MuseKnowledgeProcessingTaskService {
     }
 
     @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
-    public void markRagflowParseAccepted(Long documentVersionId, String taskId, String ragflowDocumentId,
-                                         RagFlowKnowledgeRuntimeClient.RuntimeResult result) {
+    public void markRagflowParseAccepted(Long documentVersionId, String taskId, String ragflowDatasetId,
+                                         String ragflowDocumentId, RagFlowKnowledgeRuntimeClient.RuntimeResult result) {
         MuseKnowledgeProcessingTaskDO task = processingTaskMapper.selectByTaskId(taskId);
         if (task != null) {
             task.setStatus("parsing");
             task.setParseStatus("processing");
             task.setIndexStatus("pending");
+            // 新建 dataset 的上传链路必须把外部 datasetId 同步固化到 task，后续轮询、补偿和 live 取证都依赖这条事实。
+            task.setRagflowDatasetId(ragflowDatasetId);
             task.setRagflowDocumentId(ragflowDocumentId);
             task.setRetryable(false);
             task.setProgressMessage("RAGFlow parse accepted; polling required");

muse-cloud/muse-module-knowledge/muse-module-knowledge-server/src/test/java/cn/iocoder/muse/module/knowledge/application/muse/MuseKnowledgeDocumentServiceTest.java

@@ -377,6 +377,7 @@ class MuseKnowledgeDocumentServiceTest extends BaseMockitoUnitTest {
                         && RagFlowKnowledgeRuntimeClient.Status.ACCEPTED.equals(call.getStatus())));
         verify(processingTaskMapper).updateById(org.mockito.ArgumentMatchers.<MuseKnowledgeProcessingTaskDO>argThat(task ->
                 "parsing".equals(task.getStatus())
+                        && "rag-dataset-1".equals(task.getRagflowDatasetId())
                         && "rag-doc-1".equals(task.getRagflowDocumentId())
                         && "processing".equals(task.getResultSummary()) == false));
     }

muse-cloud/muse-server/src/main/resources/application.yaml

@@ -95,8 +95,8 @@ mybatis-plus:
 #      id-type: AUTO # 自增 ID，适合 MySQL 等直接自增的数据库
 #      id-type: INPUT # 用户输入 ID，适合 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库
 #      id-type: ASSIGN_ID # 分配 ID，默认使用雪花算法。注意，Oracle、PostgreSQL、Kingbase、DB2、H2 数据库时，需要去除实体类上的 @KeySequence 注解
-      logic-delete-value: 1 # 逻辑已删除值(默认为 1)
-      logic-not-delete-value: 0 # 逻辑未删除值(默认为 0)
+      logic-delete-value: true # 逻辑已删除值，匹配 PostgreSQL boolean deleted 字段
+      logic-not-delete-value: false # 逻辑未删除值，匹配 PostgreSQL boolean deleted 字段
     banner: false # 关闭控制台的 Banner 打印
   type-aliases-package: ${muse.info.base-package}.module.*.dal.dataobject
   encryptor: