From 02104d85e7e2f6e495274591892d6028169d2323 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Fri, 01 Aug 2025 18:18:26 +0800 Subject: [PATCH] feat(ai): 新增产品题目功能 --- src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java | 130 +++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 130 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java index 4084e1c..cdea318 100644 --- a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java @@ -1,15 +1,28 @@ package cc.mrbird.febs.ai.service.impl; +import cc.mrbird.febs.ai.entity.AiMemberRole; +import cc.mrbird.febs.ai.entity.AiProductPoint; import cc.mrbird.febs.ai.entity.AiProductQuestion; +import cc.mrbird.febs.ai.entity.AiProductQuestionItem; import cc.mrbird.febs.ai.mapper.AiProductQuestionMapper; +import cc.mrbird.febs.ai.service.AiProductQuestionItemService; import cc.mrbird.febs.ai.service.AiProductQuestionService; +import cc.mrbird.febs.ai.util.UUID; +import cc.mrbird.febs.common.entity.FebsResponse; +import cc.mrbird.febs.common.entity.QueryRequest; +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.Date; import java.util.List; /** @@ -24,10 +37,127 @@ public class AiProductQuestionServiceImpl extends ServiceImpl<AiProductQuestionMapper, AiProductQuestion> implements AiProductQuestionService { private final AiProductQuestionMapper aiProductQuestionMapper; + private final AiProductQuestionItemService aiProductQuestionItemService; @Override public AiProductQuestion getById(String id) { + return aiProductQuestionMapper.selectById(id); } + @Override + public IPage<AiProductQuestion> listInPage(AiProductQuestion dto, QueryRequest request) { + Page<AiProductQuestion> page = new Page<>(request.getPageNum(), request.getPageSize()); + LambdaQueryWrapper<AiProductQuestion> query = Wrappers.lambdaQuery(AiProductQuestion.class); + query.ne(AiProductQuestion::getState, 2); + Page<AiProductQuestion> pages = aiProductQuestionMapper.selectPage(page, query); + return pages; + } + + @Override + public FebsResponse changeState(String id, Integer state) { + AiProductQuestion entity = this.getById(id); + if(ObjectUtil.isNotEmpty(entity)){ + this.update(null, + Wrappers.lambdaUpdate(AiProductQuestion.class) + .set(AiProductQuestion::getState, state) + .set(AiProductQuestion::getUpdatedTime, new Date()) + .eq(AiProductQuestion::getId, id)); + } + return new FebsResponse().success().message("操作成功"); + } + + @Override + public FebsResponse add(AiProductQuestion dto) { + + List<AiProductQuestionItem> aiProductQuestionItems = dto.getAiProductQuestionItems(); + if(CollUtil.isEmpty(aiProductQuestionItems)){ + return new FebsResponse().fail().message("请添加答案选项"); + } + //stream流操作aiProductQuestionItems,返回aiProductQuestionItems是否存在中correctAnswer为1的元素 + boolean hasCorrectAnswer = aiProductQuestionItems.stream().anyMatch(item -> item != null && item.getCorrectAnswer() != null && item.getCorrectAnswer() == 1); + if (!hasCorrectAnswer) { + return new FebsResponse().fail().message("请添加一项为正确的答案"); + } + + AiProductQuestion entity = new AiProductQuestion(); + entity.setId(UUID.getSimpleUUIDString()); + entity.setCompanyId(dto.getCompanyId()); + entity.setProductCategoryId(dto.getProductCategoryId()); + entity.setTitle(dto.getTitle()); + entity.setDifficulty(dto.getDifficulty()); + entity.setCreatedTime(new Date()); + this.save(entity); + + + for (AiProductQuestionItem item : dto.getAiProductQuestionItems()){ + item.setId(UUID.getSimpleUUIDString()); + item.setProductQuestionId(entity.getId()); + item.setTitle(entity.getTitle()); + item.setCreatedTime(new Date()); + aiProductQuestionItemService.getBaseMapper().insert(item); + } + return new FebsResponse().success().message("操作成功"); + } + + + + @Override + public FebsResponse update(AiProductQuestion dto) { + String id = dto.getId(); + AiProductQuestion entity = this.getById(id); + + List<AiProductQuestionItem> aiProductQuestionItems = dto.getAiProductQuestionItems(); + if(CollUtil.isEmpty(aiProductQuestionItems)){ + return new FebsResponse().fail().message("请添加答案选项"); + } + //stream流操作aiProductQuestionItems,返回aiProductQuestionItems是否存在中correctAnswer为1的元素 + boolean hasCorrectAnswer = aiProductQuestionItems.stream().anyMatch(item -> item != null && item.getCorrectAnswer() != null && item.getCorrectAnswer() == 1); + if (!hasCorrectAnswer) { + return new FebsResponse().fail().message("请添加一项为正确的答案"); + } + if (ObjectUtil.isNotNull( entity)){ + this.update(null, + Wrappers.lambdaUpdate(AiProductQuestion.class) + .set(AiProductQuestion::getCompanyId, dto.getCompanyId()) + .set(AiProductQuestion::getProductCategoryId, dto.getProductCategoryId()) + .set(AiProductQuestion::getTitle, dto.getTitle()) + .set(AiProductQuestion::getDifficulty, dto.getDifficulty()) + .set(AiProductQuestion::getUpdatedTime, new Date()) + .eq(AiProductQuestion::getId, id) + ); + + aiProductQuestionItemService.deleteByQuestionId(id); + + for (AiProductQuestionItem item : dto.getAiProductQuestionItems()){ + item.setId(UUID.getSimpleUUIDString()); + item.setProductQuestionId(entity.getId()); + item.setTitle(entity.getTitle()); + item.setCreatedTime(new Date()); + aiProductQuestionItemService.getBaseMapper().insert(item); + } + } + return new FebsResponse().success().message("操作成功"); + } + + @Override + public FebsResponse delete(String id) { + AiProductQuestion entity = this.getById(id); + if(ObjectUtil.isNotNull( entity)){ + this.update(null, + Wrappers.lambdaUpdate(AiProductQuestion.class) + .set(AiProductQuestion::getState, 2) + .set(AiProductQuestion::getUpdatedTime, new Date()) + .eq(AiProductQuestion::getId, id)); + + } + return new FebsResponse().success().message("操作成功"); + } + + @Override + public List<AiProductQuestion> questionTree() { + + return aiProductQuestionMapper.selectList(null); + } + } -- Gitblit v1.9.1