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 e175c15..c4077c0 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 @@ -1,5 +1,6 @@ package com.project.task.domain.service.impl; +import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.project.information.domain.dto.KnowledgePointDTO; import com.project.information.domain.entity.InformationEntity; @@ -64,8 +65,12 @@ public class InitTaskDomainServiceImpl implements InitTaskDomainService { log.warn(">>> 任务[{}]选取的文档中未发现任何知识点,流程终止", taskId); return; } - algorithmApplicationService.postToClustering(taskId , kpList); - log.info(">>> [任务初始化] 任务[{}]知识点已成功送往算法端,当前异步线程任务结束", taskId); + if (CollUtil.isNotEmpty(kpList)) { + algorithmApplicationService.postToClustering(taskId , kpList); + log.info(">>> [任务初始化] 任务[{}]知识点已成功送往算法端,当前异步线程任务结束", taskId); + } else { + log.info(">>> [任务初始化] 任务[{}]知识点集合为空", taskId); + } } /**