diff --git a/src/main/java/com/project/milvus/application/impl/MilvusApplicationServiceImpl.java b/src/main/java/com/project/milvus/application/impl/MilvusApplicationServiceImpl.java index d2ab3e1..a75ebe1 100644 --- a/src/main/java/com/project/milvus/application/impl/MilvusApplicationServiceImpl.java +++ b/src/main/java/com/project/milvus/application/impl/MilvusApplicationServiceImpl.java @@ -25,8 +25,6 @@ import java.util.stream.Collectors; @Service @Slf4j public class MilvusApplicationServiceImpl implements MilvusApplicationService { - @Autowired - private MilvusDemoService milvusDemoService; @Autowired private CheckMilvusDomainService checkMilvusDomainService; @Autowired @@ -42,7 +40,9 @@ public class MilvusApplicationServiceImpl implements MilvusApplicationService { @Override @Transactional(rollbackFor = Exception.class) public void insertTitle(TitleVector title) { - // 1. 基础参数校验(在锁外,快速失败) + log.info(">>> [回调处理] 开始持久化题目{},考试任务[{}]",title.QuestionDetailDTO, title.getTaskId()); + + // 基础参数校验(在锁外,快速失败) checkMilvusDomainService.checkBasic(title); String lockKey = buildLockKey(title.getTaskKpIdsList()); @@ -65,27 +65,26 @@ public class MilvusApplicationServiceImpl implements MilvusApplicationService { if (!locked) { throw new RuntimeException("当前知识点正在处理,请稍后再试"); } - //唯一性校验 checkMilvusDomainService.checkUnique(title); //比较相似度 - List> query = milvusDemoService.query(title); - if (CollectionUtil.isNotEmpty(query) && CollectionUtil.isNotEmpty(query.get(0))) { - SearchResp.SearchResult searchResult = query.get(0).get(0); - Float score = searchResult.getScore(); - if(score.compareTo(SIMILARITY_THRESHOLD) > 0){ - throw new MissingParameterException("题目相似度"+ score +",超过阈值"); - } - } +// List> query = milvusDemoService.query(title); +// if (CollectionUtil.isNotEmpty(query) && CollectionUtil.isNotEmpty(query.get(0))) { +// SearchResp.SearchResult searchResult = query.get(0).get(0); +// Float score = searchResult.getScore(); +// if(score.compareTo(SIMILARITY_THRESHOLD) > 0){ +// throw new MissingParameterException("题目相似度"+ score +",超过阈值"); +// } +// } //保存题目到数据库 QuestionDTO questionDTO = buildQuestionDTO(title); questionDTO = saveQuestionDomainService.save(questionDTO).getData(); //保存向量数据到 Milvus - title.setId(questionDTO.getId()); - milvusDemoService.insertRecord(title); +// title.setId(questionDTO.getId()); +// milvusDemoService.insertRecord(title); }catch (InterruptedException e) { Thread.currentThread().interrupt(); diff --git a/src/main/resources/logback-spring.xml b/src/main/resources/logback-spring.xml index b25a44d..e525878 100644 --- a/src/main/resources/logback-spring.xml +++ b/src/main/resources/logback-spring.xml @@ -47,6 +47,34 @@ + + + + logs/generateQuestion.log + + logs/archive/generateQuestion-%d{yyyy-MM-dd}.%i.log.gz + 10MB + 3 + 100MB + + + ${FILE_LOG_PATTERN} + UTF-8 + + + + + + + + + + + + + + +