From a34ec9e61586d69bb83cab89c8a5cb6898db7a39 Mon Sep 17 00:00:00 2001
From: luogw <3132758203@qq.com>
Date: Tue, 7 Apr 2026 08:56:03 +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

---
 .../impl/InitTaskDomainServiceImpl.java       | 28 +++++++++----------
 .../SaveOrUpdateTaskDomainServiceImpl.java    | 11 ++++----
 2 files changed, 19 insertions(+), 20 deletions(-)

diff --git a/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java b/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
index 92fa336..7385841 100644
--- a/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
+++ b/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
@@ -42,20 +42,20 @@ public class InitTaskDomainServiceImpl implements InitTaskDomainService {
 
     @Override
     public void asyncInitialize(Long taskId, List<Long> relatedDocIds) {
-//        CompletableFuture.runAsync(() -> {
-//            try {
-//                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
-//                handle(taskId, relatedDocIds);
-//            } catch (Exception e) {
-//                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
-//            }
-//        }, taskInternalExecutor);
-        try {
-            log.info(">>> 收到考试任务[{}]初始化请求，开始同步处理...", taskId);
-            handle(taskId, relatedDocIds);
-        } catch (Exception e) {
-            log.error(">>> 考试任务[{}]同步初始化过程发生严重异常", taskId, e);
-        }
+        CompletableFuture.runAsync(() -> {
+            try {
+                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
+                handle(taskId, relatedDocIds);
+            } catch (Exception e) {
+                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
+            }
+        }, 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 {
diff --git a/src/main/java/com/project/task/domain/service/impl/SaveOrUpdateTaskDomainServiceImpl.java b/src/main/java/com/project/task/domain/service/impl/SaveOrUpdateTaskDomainServiceImpl.java
index e92e0c3..d18e457 100644
--- a/src/main/java/com/project/task/domain/service/impl/SaveOrUpdateTaskDomainServiceImpl.java
+++ b/src/main/java/com/project/task/domain/service/impl/SaveOrUpdateTaskDomainServiceImpl.java
@@ -102,12 +102,6 @@ public class SaveOrUpdateTaskDomainServiceImpl implements SaveOrUpdateTaskDomain
         saveEntity.setPassNum(0);
         taskBaseService.saveOrUpdate(saveEntity);
 
-        // todo 知识点分簇，预出题
-
-        if (Objects.isNull(dto.getId())) {
-            initTaskDomainService.asyncInitialize(saveEntity.getId() , saveEntity.getRelatedDocumentList());
-        }
-
         // 保存关联表 TaskUserEntity
         taskUserBaseService.remove(new LambdaQueryWrapper<TaskUserEntity>()
                 .eq(TaskUserEntity::getTaskId , saveEntity.getId()));
@@ -138,6 +132,11 @@ public class SaveOrUpdateTaskDomainServiceImpl implements SaveOrUpdateTaskDomain
             taskUserEntityList.add(taskUserEntity);
         }
         taskUserBaseService.saveBatch(taskUserEntityList);
+
+        // todo 知识点分簇，预出题
+        if (Objects.isNull(dto.getId())) {
+            initTaskDomainService.asyncInitialize(saveEntity.getId() , saveEntity.getRelatedDocumentList());
+        }
         return Result.success(saveEntity.toDTO(TaskDTO::new));
     }