Merge remote-tracking branch 'origin/master'

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 {
+//            try {
-                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
+//                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
-                handle(taskId, relatedDocIds);
+//                handle(taskId, relatedDocIds);
-            } catch (Exception e) {
+//            } catch (Exception e) {
-                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
+//                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
-            }
+//            }
-        }, taskInternalExecutor);
+//        }, taskInternalExecutor);
+        try {
+            log.info(">>> 收到考试任务[{}]初始化请求，开始同步处理...", taskId);
+            handle(taskId, relatedDocIds);
+        } catch (Exception e) {
+            log.error(">>> 考试任务[{}]同步初始化过程发生严重异常", taskId, e);
+        }
     }
 
     public void handle(Long taskId, List<Long> docIds) throws Exception {