增加文档聚类实体类

src/main/java/com/project/interaction/domain/service/impl/SaveClusterDomainServiceImpl.java

@@ -83,7 +83,7 @@ public class SaveClusterDomainServiceImpl implements SaveClusterDomainService {
             // 批量插入
             knowledgePointBaseService.updateBatchById(kpList);
         }
-        Thread.sleep(60000);
+//        Thread.sleep(60000);
 
         InformationEntity byId = informationBaseService.getById(informationId);
         byId.setParseStatus(InformationParseStatusEnum.Success.getValue());

src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java

@@ -42,14 +42,20 @@ public class InitTaskDomainServiceImpl implements InitTaskDomainService {
 
     @Override
     public void asyncInitialize(Long taskId, List<Long> relatedDocIds) {
-        CompletableFuture.runAsync(() -> {
+//        CompletableFuture.runAsync(() -> {
+//            try {
+//                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
+//                handle(taskId, relatedDocIds);
+//            } catch (Exception e) {
+//                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
+//            }
+//        }, taskInternalExecutor);
         try {
-                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
+            log.info(">>> 收到考试任务[{}]初始化请求，开始同步处理...", taskId);
             handle(taskId, relatedDocIds);
         } catch (Exception e) {
-                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
+            log.error(">>> 考试任务[{}]同步初始化过程发生严重异常", taskId, e);
         }
-        }, taskInternalExecutor);
     }
 
     public void handle(Long taskId, List<Long> docIds) throws Exception {