feat:问答知识库分片 批量更新

src/main/java/cn/com/poc/knowledge/aggregate/QAKnowledgeService.java

@@ -50,6 +50,15 @@ public interface QAKnowledgeService {
      */
     void updateKnowledgeChunkDoc(Integer kdId, String chunkRelationId, Long structId, String content);
 
+    /**
+     * 批量更新知识库分片内容
+     *
+     * @param kdId
+     * @param chunkRelationId
+     * @param chunkInfos
+     */
+    void updateKnowledgeChunkDoc(Integer kdId, String chunkRelationId, List<ChunkInfo> chunkInfos);
+
     /**
      * 新增知识库分片
      *

src/main/java/cn/com/poc/knowledge/aggregate/impl/QAKnowledgeServiceImpl.java

@@ -61,6 +61,13 @@ public class QAKnowledgeServiceImpl implements QAKnowledgeService {
         demandQAKnowledgeService.updateKnowledgeChunkDoc(knowledgeId, chunkRelationId, structId, content);
     }
 
+    @Override
+    public void updateKnowledgeChunkDoc(Integer kdId, String chunkRelationId, List<ChunkInfo> chunkInfos) {
+        logger.info("updateKnowledgeChunkDoc: kdId={}, chunkRelationId={}, chunkInfos={}", kdId, chunkRelationId, chunkInfos);
+        String knowledgeId = getKnowledgeId(kdId);
+        demandQAKnowledgeService.updateKnowledgeChunkDoc(knowledgeId, chunkRelationId, chunkInfos);
+    }
+
     @Override
     public void addKnowledgeChunk(Integer kdId, List<ChunkInfo> chunkInfos, Integer chunkSort) {
         logger.info("addKnowledgeChunk: kdId={}, chunkInfos={}, chunkSort={}", kdId, chunkInfos, chunkSort);

src/main/java/cn/com/poc/knowledge/rest/QAKnowledgeRest.java

@@ -36,6 +36,13 @@ public interface QAKnowledgeRest extends BaseRest {
      */
     void updateKnowledgeChunkDoc(@RequestBody UpsertChunkInfoDto dto);
 
+    /**
+     * 批量更新知识库分片内容
+     *
+     * @param dto
+     */
+    void batchUpdateKnowledgeChunkDoc(@RequestBody UpsertChunkInfoDto dto);
+
     /**
      * 新增知识库分片
      */

src/main/java/cn/com/poc/knowledge/rest/impl/QAKnowledgeRestImpl.java

@@ -40,6 +40,11 @@ public class QAKnowledgeRestImpl implements QAKnowledgeRest {
         qaKnowledgeService.updateKnowledgeChunkDoc(dto.getKdId(), dto.getChunkRelationId(), dto.getStructId(), dto.getChunkContent());
     }
 
+    @Override
+    public void batchUpdateKnowledgeChunkDoc(UpsertChunkInfoDto dto) {
+        qaKnowledgeService.updateKnowledgeChunkDoc(dto.getKdId(), dto.getChunkRelationId(), dto.getChunkInfos());
+    }
+
     @Override
     public void addKnowledgeChunk(UpsertChunkInfoDto dto) {
         qaKnowledgeService.addKnowledgeChunk(dto.getKdId(), dto.getChunkInfos(), dto.getChunkSort());

src/main/java/cn/com/poc/thirdparty/resource/demand/ai/aggregate/DemandQAKnowledgeService.java

@@ -54,6 +54,16 @@ public interface DemandQAKnowledgeService {
      */
     void updateKnowledgeChunkDoc(String knowledgeId, String chunkRelationId, Long structId, String content);
 
+
+    /**
+     * 批量更新分片内容
+     *
+     * @param knowledgeId
+     * @param chunkRelationId
+     * @param chunkInfos
+     */
+    void updateKnowledgeChunkDoc(String knowledgeId, String chunkRelationId, List<ChunkInfo> chunkInfos);
+
     /**
      * 新增分片
      *

src/main/java/cn/com/poc/thirdparty/resource/demand/ai/aggregate/impl/DemandQAKnowledgeServiceImpl.java

@@ -74,6 +74,17 @@ public class DemandQAKnowledgeServiceImpl implements DemandQAKnowledgeService {
         dgToolsAbstractHttpClient.doRequest(DgtoolsApiRoute.DgtoolsAI.UPDATE_QA_KNOWLEDGE_CHUNK, request, getHeaders());
     }
 
+    @Override
+    public void updateKnowledgeChunkDoc(String knowledgeId, String chunkRelationId, List<ChunkInfo> chunkInfos) {
+        Assert.notBlank(knowledgeId);
+        Assert.notBlank(chunkRelationId);
+        UpsertChunkInfoRequest request = new UpsertChunkInfoRequest();
+        request.setKnowledgeId(knowledgeId);
+        request.setChunkRelationId(chunkRelationId);
+        request.setChunkInfos(chunkInfos);
+        dgToolsAbstractHttpClient.doRequest(DgtoolsApiRoute.DgtoolsAI.BATCH_UPDATE_QA_KNOWLEDGE_CHUNK, request, getHeaders());
+    }
+
     @Override
     public void addKnowledgeChunk(String knowledgeId, List<ChunkInfo> chunkInfos, Integer sort) {
         Assert.notBlank(knowledgeId);

src/main/java/cn/com/poc/thirdparty/resource/demand/ai/route/DgtoolsApiRoute.java

@@ -262,6 +262,8 @@ public interface DgtoolsApiRoute {
 
         String UPDATE_QA_KNOWLEDGE_CHUNK = "qAKnowledgeRest/updateKnowledgeChunkDoc.json"; //修改分片内容
 
+        String BATCH_UPDATE_QA_KNOWLEDGE_CHUNK = "qAKnowledgeRest/batchUpdateKnowledgeChunk.json"; //批量修改分片内容
+
         String DELETE_QA_KNOWLEDGE_CHUNK = "qAKnowledgeRest/deleteKnowledgeChunk.json"; //删除知识库分片
 
         String OPEN_QA_KNOWLEDGE_CHUNK = "qAKnowledgeRest/openKnowledgeChunk.json"; //开关知识库分片信息