From c7cee264bccb5026fd42a9f0dc83d274aaee40cf Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 30 Oct 2025 10:05:28 +0800
Subject: [PATCH] feat(ai): 新增AI陪练流式对话V2接口
---
src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java | 508 +++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 409 insertions(+), 99 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java b/src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java
index 9a4d288..4ee4a14 100644
--- a/src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java
@@ -1,16 +1,39 @@
package cc.mrbird.febs.ai.service.impl;
-import cc.mrbird.febs.ai.entity.AiMemberAnswer;
+import cc.mrbird.febs.ai.entity.*;
+import cc.mrbird.febs.ai.enumerates.AiTypeEnum;
import cc.mrbird.febs.ai.mapper.AiMemberAnswerMapper;
-import cc.mrbird.febs.ai.service.AiMemberAnswerService;
+import cc.mrbird.febs.ai.req.member.ApiMemberAnswerPageDto;
+import cc.mrbird.febs.ai.req.memberAnswer.*;
+import cc.mrbird.febs.ai.res.member.ApiMemberAnswerPageVo;
+import cc.mrbird.febs.ai.res.memberAnswer.*;
+import cc.mrbird.febs.ai.res.product.ApiProductVo;
+import cc.mrbird.febs.ai.res.productQuestionItem.ApiMemberAnswerItemVo;
+import cc.mrbird.febs.ai.service.*;
+import cc.mrbird.febs.ai.utils.UUID;
+import cc.mrbird.febs.common.entity.FebsResponse;
+import cc.mrbird.febs.common.exception.FebsException;
+import cc.mrbird.febs.common.utils.LoginUserUtil;
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUnit;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+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.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
/**
* AI用户答题记录 Service实现类
@@ -24,125 +47,412 @@
public class AiMemberAnswerServiceImpl extends ServiceImpl<AiMemberAnswerMapper, AiMemberAnswer> implements AiMemberAnswerService {
private final AiMemberAnswerMapper aiMemberAnswerMapper;
+ private final AiMemberAnswerItemService aiMemberAnswerItemService;
+ private final AiProductService aiProductService;
+ private final AiProductQuestionService aiProductQuestionService;
+ private final AiProductQuestionItemService aiProductQuestionItemService;
+ private final AiProductDependencyService aiProductDependencyService;
+ private final AiMemberProductUnlockService aiMemberProductUnlockService;
+
@Override
- public AiMemberAnswer getById(String id) {
- return this.getById(id);
+ public AiMemberAnswer getOneByQuery(LambdaQueryWrapper<AiMemberAnswer> aiMemberAnswerLambdaQueryWrapper) {
+ aiMemberAnswerLambdaQueryWrapper.last("limit 1");
+ return aiMemberAnswerMapper.selectOne(aiMemberAnswerLambdaQueryWrapper);
}
@Override
- public List<AiMemberAnswer> getByMemberId(String memberId) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getMemberId, memberId);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
+ public FebsResponse startAnswerV2(ApiMemberAnswerDto dto) {
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+ ApiMemberAnswerVoV2 apiMemberAnswerVoV2 = new ApiMemberAnswerVoV2();
- @Override
- public List<AiMemberAnswer> getByProductId(String productId) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getProductId, productId);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- public List<AiMemberAnswer> getByCompanyId(String companyId) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getCompanyId, companyId);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- public List<AiMemberAnswer> getByState(Integer state) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getState, state);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- public List<AiMemberAnswer> getByMemberIdAndState(String memberId, Integer state) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getMemberId, memberId);
- queryWrapper.eq(AiMemberAnswer::getState, state);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- public List<AiMemberAnswer> getByCompanyIdAndMemberId(String companyId, String memberId) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getCompanyId, companyId);
- queryWrapper.eq(AiMemberAnswer::getMemberId, memberId);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- public List<AiMemberAnswer> getByScoreRange(Integer minScore, Integer maxScore) {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.ge(AiMemberAnswer::getScore, minScore);
- queryWrapper.le(AiMemberAnswer::getScore, maxScore);
- queryWrapper.orderByDesc(AiMemberAnswer::getCreatedTime);
- return this.list(queryWrapper);
- }
-
- @Override
- @Transactional(rollbackFor = Exception.class)
- public boolean saveAnswer(AiMemberAnswer aiMemberAnswer) {
- try {
- return this.save(aiMemberAnswer);
- } catch (Exception e) {
- log.error("保存答题记录失败: ", e);
- return false;
+ String productId = dto.getId();
+ AiProduct aiProduct = aiProductService.getById(productId);
+ if(ObjectUtil.isNull(aiProduct)){
+ throw new FebsException("产品不存在");
}
+ String companyId = aiProduct.getCompanyId();
+ //验证产品分类下是否有题目
+ String productCategoryId = aiProduct.getProductCategoryId();
+ LambdaQueryWrapper<AiProductQuestion> questionLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestion.class);
+ questionLambdaQueryWrapper.eq(AiProductQuestion::getProductCategoryId,productCategoryId);
+ questionLambdaQueryWrapper.eq(AiProductQuestion::getState,1);
+ questionLambdaQueryWrapper.last("limit 1");
+ List<AiProductQuestion> aiProductQuestions = aiProductQuestionService.getListByQuery(questionLambdaQueryWrapper);
+ if(CollUtil.isEmpty(aiProductQuestions)){
+ // todo 没有题目采用AI生成题目
+ throw new FebsException("产品没有题目");
+ }
+ //判断该产品是否有正在进行的练习
+ Date createdTime = new Date();
+ LambdaQueryWrapper<AiMemberAnswer> aiMemberAnswerLambdaQueryWrapper = Wrappers.lambdaQuery(AiMemberAnswer.class);
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getMemberId,memberUuid);
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getProductId,aiProduct.getId());
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getState,0);
+ AiMemberAnswer aiMemberAnswer = this.getOneByQuery(aiMemberAnswerLambdaQueryWrapper);
+ if(ObjectUtil.isNull(aiMemberAnswer)){
+ Integer questionCount = aiProduct.getQuestionCount();
+ aiMemberAnswer = new AiMemberAnswer();
+ aiMemberAnswer.setId(UUID.getSimpleUUIDString());
+ aiMemberAnswer.setCompanyId(companyId);
+ aiMemberAnswer.setCreatedTime(createdTime);
+ aiMemberAnswer.setUpdatedTime(createdTime);
+ aiMemberAnswer.setProductId(aiProduct.getId());
+ aiMemberAnswer.setMemberId(memberUuid);
+ aiMemberAnswer.setState(0);
+ aiMemberAnswer.setScore(0);
+ aiMemberAnswer.setQuestionCnt(questionCount);
+ aiMemberAnswer.setDoneCnt(0);
+ aiMemberAnswer.setCorrectCnt(0);
+ aiMemberAnswerMapper.insert(aiMemberAnswer);
+ List<AiMemberAnswerItem> aiMemberAnswerItems = new ArrayList<>();
+ for (int i = 1; i <= questionCount; i++){
+ //初始化答题记录
+ AiProductQuestion aiProductQuestion = aiProductQuestionService.createQuestion(aiProduct.getId());
+ AiMemberAnswerItem aiMemberAnswerItem = new AiMemberAnswerItem();
+ aiMemberAnswerItem.setId(UUID.getSimpleUUIDString());
+ aiMemberAnswerItem.setCompanyId(companyId);
+ aiMemberAnswerItem.setCreatedTime(createdTime);
+ aiMemberAnswerItem.setAnswerId(aiMemberAnswer.getId());
+ aiMemberAnswerItem.setProductId(aiMemberAnswer.getProductId());
+ aiMemberAnswerItem.setMemberId(memberUuid);
+ aiMemberAnswerItem.setProductQuestionId(aiProductQuestion.getId());
+ aiMemberAnswerItem.setTitle(aiProductQuestion.getTitle());
+ aiMemberAnswerItem.setDifficulty(aiProductQuestion.getDifficulty());
+ aiMemberAnswerItem.setMemberAnswerState(0);
+ aiMemberAnswerItem.setSort( i );
+ aiMemberAnswerItems.add(aiMemberAnswerItem);
+ }
+ aiMemberAnswerItemService.saveBatch(aiMemberAnswerItems);
+ apiMemberAnswerVoV2.setCurrent(1);
+ }else{
+ if (aiMemberAnswer.getQuestionCnt() > aiMemberAnswer.getDoneCnt()){
+ apiMemberAnswerVoV2.setCurrent(aiMemberAnswer.getDoneCnt() + 1);
+ }else{
+ apiMemberAnswerVoV2.setCurrent(aiMemberAnswer.getDoneCnt());
+ }
+ }
+ apiMemberAnswerVoV2.setMemberAnswerId(aiMemberAnswer.getId());
+
+ return new FebsResponse().success().data(apiMemberAnswerVoV2);
+ }
+
+
+ @Override
+ public FebsResponse startAnswer(ApiMemberAnswerDto dto) {
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+
+ String productId = dto.getId();
+ AiProduct aiProduct = aiProductService.getById(productId);
+ if(ObjectUtil.isNull(aiProduct)){
+ throw new FebsException("产品不存在");
+ }
+ //验证产品分类下是否有题目
+ String productCategoryId = aiProduct.getProductCategoryId();
+ LambdaQueryWrapper<AiProductQuestion> questionLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestion.class);
+ questionLambdaQueryWrapper.eq(AiProductQuestion::getProductCategoryId,productCategoryId);
+ questionLambdaQueryWrapper.eq(AiProductQuestion::getState,1);
+ questionLambdaQueryWrapper.last("limit 1");
+ List<AiProductQuestion> aiProductQuestions = aiProductQuestionService.getListByQuery(questionLambdaQueryWrapper);
+ if(CollUtil.isEmpty(aiProductQuestions)){
+ // todo 没有题目采用AI生成题目
+ throw new FebsException("产品没有题目");
+ }
+ //判断该产品是否有正在进行的练习
+ Date createdTime = new Date();
+ LambdaQueryWrapper<AiMemberAnswer> aiMemberAnswerLambdaQueryWrapper = Wrappers.lambdaQuery(AiMemberAnswer.class);
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getMemberId,memberUuid);
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getProductId,aiProduct.getId());
+ aiMemberAnswerLambdaQueryWrapper.eq(AiMemberAnswer::getState,0);
+ AiMemberAnswer aiMemberAnswer = this.getOneByQuery(aiMemberAnswerLambdaQueryWrapper);
+ if(ObjectUtil.isNull(aiMemberAnswer)){
+ aiMemberAnswer = new AiMemberAnswer();
+ aiMemberAnswer.setId(UUID.getSimpleUUIDString());
+ aiMemberAnswer.setCreatedTime(createdTime);
+ aiMemberAnswer.setUpdatedTime(createdTime);
+ aiMemberAnswer.setProductId(aiProduct.getId());
+ aiMemberAnswer.setMemberId(memberUuid);
+ aiMemberAnswer.setState(0);
+ aiMemberAnswer.setScore(0);
+ aiMemberAnswer.setQuestionCnt(aiProduct.getQuestionCount());
+ aiMemberAnswer.setDoneCnt(0);
+ aiMemberAnswer.setCorrectCnt(0);
+ aiMemberAnswerMapper.insert(aiMemberAnswer);
+ }
+ boolean checkMemberAnswerDone = this.checkMemberAnswerDone(aiMemberAnswer);
+ if(!checkMemberAnswerDone){
+ return new FebsResponse().fail().message("您已完成本次答题");
+ }
+
+ ApiMemberAnswerVo apiMemberAnswerVo = new ApiMemberAnswerVo();
+ apiMemberAnswerVo.setMemberAnswerId(aiMemberAnswer.getId());
+ apiMemberAnswerVo.setName(aiProduct.getName());
+ apiMemberAnswerVo.setQuestionCnt(aiMemberAnswer.getQuestionCnt());
+ apiMemberAnswerVo.setDoneCnt(aiMemberAnswer.getDoneCnt());
+ apiMemberAnswerVo.setCorrectCnt(aiMemberAnswer.getCorrectCnt());
+ apiMemberAnswerVo.setProductId(aiMemberAnswer.getProductId());
+
+ AiProductQuestion aiProductQuestion = aiProductQuestionService.createQuestion(aiProduct.getId());
+ if(ObjectUtil.isNotNull(aiProductQuestion)){
+ apiMemberAnswerVo.setProductQuestionId(aiProductQuestion.getId());
+ apiMemberAnswerVo.setTitle(aiProductQuestion.getTitle());
+ apiMemberAnswerVo.setDifficulty(aiProductQuestion.getDifficulty());
+
+ //初始化答题记录
+ AiMemberAnswerItem aiMemberAnswerItem = new AiMemberAnswerItem();
+ aiMemberAnswerItem.setId(UUID.getSimpleUUIDString());
+ aiMemberAnswerItem.setCreatedTime(createdTime);
+ aiMemberAnswerItem.setAnswerId(aiMemberAnswer.getId());
+ aiMemberAnswerItem.setProductId(aiMemberAnswer.getProductId());
+ aiMemberAnswerItem.setMemberId(memberUuid);
+ aiMemberAnswerItem.setProductQuestionId(aiProductQuestion.getId());
+ aiMemberAnswerItem.setTitle(aiProductQuestion.getTitle());
+ aiMemberAnswerItem.setDifficulty(aiProductQuestion.getDifficulty());
+ aiMemberAnswerItem.setMemberAnswerState(0);
+ aiMemberAnswerItemService.save(aiMemberAnswerItem);
+ apiMemberAnswerVo.setMemberAnswerState(aiMemberAnswerItem.getMemberAnswerState());
+ apiMemberAnswerVo.setMemberAnswerItemId(aiMemberAnswerItem.getId());
+
+ List<ApiMemberAnswerItemVo> answerList = new ArrayList<>();
+ LambdaQueryWrapper<AiProductQuestionItem> productQuestionItemLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestionItem.class);
+ productQuestionItemLambdaQueryWrapper.eq(AiProductQuestionItem::getProductQuestionId,aiProductQuestion.getId());
+ productQuestionItemLambdaQueryWrapper.orderByAsc(AiProductQuestionItem::getCreatedTime);
+ List<AiProductQuestionItem> aiProductQuestionItems = aiProductQuestionItemService.getListByQuery(productQuestionItemLambdaQueryWrapper);
+ if (CollUtil.isNotEmpty(aiProductQuestionItems)){
+ for (AiProductQuestionItem aiProductQuestionItem : aiProductQuestionItems){
+ ApiMemberAnswerItemVo apiMemberAnswerItemVo = new ApiMemberAnswerItemVo();
+ apiMemberAnswerItemVo.setId(aiProductQuestionItem.getId());
+ apiMemberAnswerItemVo.setAnswer(aiProductQuestionItem.getAnswer());
+ apiMemberAnswerItemVo.setAnswerAnalysis(aiProductQuestionItem.getAnswerAnalysis());
+ apiMemberAnswerItemVo.setCorrectAnswer(aiProductQuestionItem.getCorrectAnswer());
+ answerList.add(apiMemberAnswerItemVo);
+ }
+ }
+ apiMemberAnswerVo.setAnswerList(answerList);
+ }
+
+ return new FebsResponse().success().data(apiMemberAnswerVo);
}
@Override
- @Transactional(rollbackFor = Exception.class)
- public boolean saveBatchAnswers(List<AiMemberAnswer> answers) {
- try {
- return this.saveBatch(answers);
- } catch (Exception e) {
- log.error("批量保存答题记录失败: ", e);
- return false;
+ public boolean checkMemberAnswerDone(AiMemberAnswer aiMemberAnswer) {
+ Integer doneCnt = aiMemberAnswer.getDoneCnt();
+ Integer questionCnt = aiMemberAnswer.getQuestionCnt();
+ if (questionCnt > doneCnt){
+ return true;
}
+ return false;
}
@Override
- @Transactional(rollbackFor = Exception.class)
- public boolean updateAnswer(AiMemberAnswer aiMemberAnswer) {
- try {
- return this.updateById(aiMemberAnswer);
- } catch (Exception e) {
- log.error("更新答题记录失败: ", e);
- return false;
+ public FebsResponse answer(ApiQuestionAnswerDto dto) {
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+
+ ApiQuestionItemInfoVo apiQuestionItemInfoVo = new ApiQuestionItemInfoVo();
+
+ String productQuestionItemId = dto.getId();
+ String productQuestionId = dto.getProductQuestionId();
+ String memberAnswerId = dto.getMemberAnswerId();
+ String memberAnswerItemId = dto.getMemberAnswerItemId();
+ AiMemberAnswer aiMemberAnswer = this.getById(memberAnswerId);
+
+ if(ObjectUtil.isNull(aiMemberAnswer)){
+ throw new FebsException("答题记录不存在");
}
+
+ Date nowTime = new Date();
+
+ String companyId = aiMemberAnswer.getCompanyId();
+ AiMemberAnswerItem aiMemberAnswerItem = aiMemberAnswerItemService.getById(memberAnswerItemId);
+ aiMemberAnswerItem.setUpdatedTime(nowTime);
+ AiProductQuestion aiProductQuestion = aiProductQuestionService.getById(productQuestionId);
+
+ LambdaQueryWrapper<AiProductQuestionItem> productQuestionItemLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestionItem.class);
+ productQuestionItemLambdaQueryWrapper.eq(AiProductQuestionItem::getProductQuestionId,aiProductQuestion.getId());
+ productQuestionItemLambdaQueryWrapper.eq(AiProductQuestionItem::getCorrectAnswer,1);
+ List<AiProductQuestionItem> listByQuery = aiProductQuestionItemService.getListByQuery(productQuestionItemLambdaQueryWrapper);
+ if(CollUtil.isNotEmpty(listByQuery)){
+ AiProductQuestionItem aiProductQuestionItem = listByQuery.get(0);
+ aiMemberAnswerItem.setAnswer(aiProductQuestionItem.getId());
+ aiMemberAnswerItem.setCorrectAnswer(aiProductQuestionItem.getCorrectAnswer());
+ aiMemberAnswerItem.setAnswerAnalysis(aiProductQuestionItem.getAnswerAnalysis());
+
+ apiQuestionItemInfoVo.setAnswerID(aiProductQuestionItem.getId());
+ apiQuestionItemInfoVo.setAnswer(aiProductQuestionItem.getAnswer());
+ }
+ aiMemberAnswerItem.setMemberAnswerQuestionId(productQuestionItemId);
+ aiMemberAnswerItem.setMemberAnswerState(
+ ObjectUtil.equal(aiMemberAnswerItem.getMemberAnswerQuestionId(),aiMemberAnswerItem.getAnswer()) ? 1 : 2
+ );
+ if (aiMemberAnswerItem.getMemberAnswerState() == 2){
+ aiMemberAnswerItem.setIsCollected(1);
+ }else{
+ aiMemberAnswerItem.setIsCollected(0);
+ }
+ aiMemberAnswerItem.setCompanyId(companyId);
+ aiMemberAnswerItemService.updateById(aiMemberAnswerItem);
+
+ aiMemberAnswer.setDoneCnt(aiMemberAnswer.getDoneCnt() + 1);
+ if (aiMemberAnswerItem.getMemberAnswerState() == 1){
+ aiMemberAnswer.setCorrectCnt(aiMemberAnswer.getCorrectCnt() + 1);
+ }
+ aiMemberAnswer.setUpdatedTime(nowTime);
+ aiMemberAnswerMapper.updateById(aiMemberAnswer);
+
+ apiQuestionItemInfoVo.setAnswerAnalysis(aiMemberAnswerItem.getAnswerAnalysis());
+ apiQuestionItemInfoVo.setMemberAnswerState(aiMemberAnswerItem.getMemberAnswerState());
+ apiQuestionItemInfoVo.setQuestionCnt(aiMemberAnswer.getQuestionCnt());
+ apiQuestionItemInfoVo.setDoneCnt(aiMemberAnswer.getDoneCnt());
+ return new FebsResponse().success().data(apiQuestionItemInfoVo);
}
@Override
- @Transactional(rollbackFor = Exception.class)
- public boolean deleteById(String id) {
- try {
- return this.removeById(id);
- } catch (Exception e) {
- log.error("删除答题记录失败: ", e);
- return false;
+ public FebsResponse insure(ApiMemberAnswerInsureDto dto) {
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+ String companyId = LoginUserUtil.getLoginUser().getCompanyId();
+
+ ApiMemberAnswerInsureVo apiMemberAnswerInsureVo = new ApiMemberAnswerInsureVo();
+ String memberAnswerId = dto.getMemberAnswerId();
+ AiMemberAnswer aiMemberAnswer = this.getById(memberAnswerId);
+ Integer questionCnt = aiMemberAnswer.getQuestionCnt();
+ Integer correctCnt = aiMemberAnswer.getCorrectCnt();
+ Date createdTime = aiMemberAnswer.getCreatedTime();
+ Date updatedTime = aiMemberAnswer.getUpdatedTime();
+ apiMemberAnswerInsureVo.setCorrectCnt(correctCnt);
+
+ BigDecimal divide = new BigDecimal(correctCnt).divide(new BigDecimal(questionCnt), 2, RoundingMode.HALF_DOWN);
+ // 转换为百分比字符串
+ BigDecimal percentage = divide.multiply(new BigDecimal(100));
+ String percentageStr = percentage.setScale(2, RoundingMode.HALF_DOWN).toString() + "%";
+ apiMemberAnswerInsureVo.setCorrectCntPercent(percentageStr);
+
+ long between = DateUtil.between(createdTime, updatedTime, DateUnit.MINUTE);
+ apiMemberAnswerInsureVo.setUseTime(between);
+ apiMemberAnswerInsureVo.setProductId(aiMemberAnswer.getProductId());
+
+ aiMemberAnswerMapper.update(null,
+ Wrappers.lambdaUpdate(AiMemberAnswer.class)
+ .set(AiMemberAnswer::getUpdatedTime, new Date())
+ .set(AiMemberAnswer::getState, 1)
+ .set(AiMemberAnswer::getScore, percentage.intValue())
+ .eq(AiMemberAnswer::getId, memberAnswerId)
+ );
+
+ //如果有升级规则，则解锁
+ List<AiProductDependency> aiProductDependencies = aiProductDependencyService.selectListByProductId(aiMemberAnswer.getProductId(),percentage.intValue());
+ if (CollUtil.isNotEmpty(aiProductDependencies)){
+ //stream流操作aiProductDependencies,获取全部的targetProductId
+ Set<String> targetProductIds = aiProductDependencies.stream().map(AiProductDependency::getTargetProductId).collect(Collectors.toSet());
+
+ List<AiMemberProductUnlock> aiMemberProductUnlocks = aiMemberProductUnlockService.selectListByProductIds(targetProductIds, memberUuid);
+ Set<String> doneProductIds = aiMemberProductUnlocks.stream().map(AiMemberProductUnlock::getProductId).collect(Collectors.toSet());
+
+ //获取在targetProductIds集合中，并且不在doneProductIds集合中的productId
+ Set<String> unlockProductIds = targetProductIds.stream().filter(productId -> !doneProductIds.contains(productId)).collect(Collectors.toSet());
+ if (CollUtil.isNotEmpty(unlockProductIds)){
+ aiMemberProductUnlockService.insertList(companyId,unlockProductIds, memberUuid,percentage.intValue());
+ }
}
+ return new FebsResponse().success().data(apiMemberAnswerInsureVo);
}
@Override
- @Transactional(rollbackFor = Exception.class)
- public boolean deleteByMemberId(String memberId) {
- try {
- LambdaQueryWrapper<AiMemberAnswer> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(AiMemberAnswer::getMemberId, memberId);
- return this.remove(queryWrapper);
- } catch (Exception e) {
- log.error("根据用户ID删除答题记录失败: ", e);
- return false;
+ public FebsResponse previous(ApiMemberAnswerPreviousDto dto) {
+
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+
+ // 创建分页对象，传入当前页和每页大小
+ Page<ApiMemberAnswerPreviousVo> page = new Page<>(dto.getPageNow(), dto.getPageSize());
+ Page<ApiMemberAnswerPreviousVo> pageListByQuery = aiMemberAnswerItemService.getPageListByQuery(page, dto);
+ List<ApiMemberAnswerPreviousVo> records = pageListByQuery.getRecords();
+ if (CollUtil.isNotEmpty(records)){
+ ApiMemberAnswerPreviousVo apiMemberAnswerPreviousVo = records.get(0);
+
+ String memberAnswerId = apiMemberAnswerPreviousVo.getMemberAnswerId();
+ AiMemberAnswer aiMemberAnswer = this.getById(memberAnswerId);
+ String productId = aiMemberAnswer.getProductId();
+ AiProduct aiProduct = aiProductService.getById(productId);
+ apiMemberAnswerPreviousVo.setName(aiProduct.getName());
+ apiMemberAnswerPreviousVo.setQuestionCnt(aiMemberAnswer.getQuestionCnt());
+ apiMemberAnswerPreviousVo.setDoneCnt(aiMemberAnswer.getDoneCnt());
+
+ String productQuestionId = apiMemberAnswerPreviousVo.getProductQuestionId();
+ AiProductQuestion aiProductQuestion = aiProductQuestionService.getById(productQuestionId);
+ apiMemberAnswerPreviousVo.setTitle(aiProductQuestion.getTitle());
+ apiMemberAnswerPreviousVo.setDifficulty(aiProductQuestion.getDifficulty());
+
+ List<ApiMemberAnswerPreviousItemVo> answerList = new ArrayList<>();
+ LambdaQueryWrapper<AiProductQuestionItem> productQuestionItemLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestionItem.class);
+ productQuestionItemLambdaQueryWrapper.eq(AiProductQuestionItem::getProductQuestionId,productQuestionId);
+ productQuestionItemLambdaQueryWrapper.orderByAsc(AiProductQuestionItem::getCreatedTime);
+ List<AiProductQuestionItem> listByQuery = aiProductQuestionItemService.getListByQuery(productQuestionItemLambdaQueryWrapper);
+ if(CollUtil.isNotEmpty(listByQuery)){
+ for (AiProductQuestionItem aiProductQuestionItem : listByQuery){
+ ApiMemberAnswerPreviousItemVo apiMemberAnswerPreviousItemVo = new ApiMemberAnswerPreviousItemVo();
+ apiMemberAnswerPreviousItemVo.setId(aiProductQuestionItem.getId());
+ apiMemberAnswerPreviousItemVo.setAnswer(aiProductQuestionItem.getAnswer());
+ apiMemberAnswerPreviousItemVo.setAnswerAnalysis(aiProductQuestionItem.getAnswerAnalysis());
+ apiMemberAnswerPreviousItemVo.setCorrectAnswer(aiProductQuestionItem.getCorrectAnswer());
+ answerList.add(apiMemberAnswerPreviousItemVo);
+ }
+ apiMemberAnswerPreviousVo.setAnswerList(answerList);
+ }
}
+ return new FebsResponse().success().data(pageListByQuery);
+ }
+
+ @Override
+ public FebsResponse wrongPage(ApiMemberAnswerWrongPageDto dto) {
+
+
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+ dto.setMemberUuid(memberUuid);
+ return aiMemberAnswerItemService.wrongPage(dto);
+ }
+
+ @Override
+ public FebsResponse myWork(ApiMemberProductWorkPageDto dto) {
+ String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+ dto.setMemberUuid(memberUuid);
+ // 创建分页对象，传入当前页和每页大小
+ Page<ApiMemberProductWorkVo> page = new Page<>(dto.getPageNow(), dto.getPageSize());
+ Page<ApiMemberProductWorkVo> pageListByQuery = this.getBaseMapper().getPageMyWorkListByQuery(page, dto);
+
+ return new FebsResponse().success().data(pageListByQuery);
+ }
+
+ @Override
+ public void updateMemberAnswerUpdateTime(String memberAnswerId, Date updateTime) {
+ aiMemberAnswerMapper.update(
+ null,
+ Wrappers.lambdaUpdate(AiMemberAnswer.class)
+ .set(AiMemberAnswer::getUpdatedTime,updateTime)
+ .eq(AiMemberAnswer::getId,memberAnswerId)
+ );
+ }
+
+ @Override
+ public List<AiMemberAnswer> getListByCompanyId(String companyId) {
+ return aiMemberAnswerMapper.selectList(
+ Wrappers.lambdaQuery(AiMemberAnswer.class)
+ .eq(AiMemberAnswer::getCompanyId, companyId)
+ .eq(AiMemberAnswer::getState, AiTypeEnum.AI_MEMBER_ANSWER_STATE_DONE.getCode())
+ );
+ }
+
+ @Override
+ public List<AiMemberAnswer> getListByCompanyIdAndMemberUuid(String companyId, String memberUuid) {
+ return aiMemberAnswerMapper.selectList(
+ Wrappers.lambdaQuery(AiMemberAnswer.class)
+ .eq(AiMemberAnswer::getCompanyId, companyId)
+ .eq(AiMemberAnswer::getMemberId, memberUuid)
+ .eq(AiMemberAnswer::getState, AiTypeEnum.AI_MEMBER_ANSWER_STATE_DONE.getCode())
+ );
+ }
+
+ @Override
+ public Page<ApiMemberAnswerPageVo> getAnswerPage(Page<ApiMemberAnswerPageVo> page, ApiMemberAnswerPageDto dto) {
+
+ return aiMemberAnswerMapper.getAnswerPage(page,dto);
}
}
--
Gitblit v1.9.1