Browse Source

bug修复

master
luogw 2 weeks ago
parent
commit
a34ec9e615
  1. 28
      src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
  2. 11
      src/main/java/com/project/task/domain/service/impl/SaveOrUpdateTaskDomainServiceImpl.java

28
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 {

11
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));
}

Loading…
Cancel
Save