From e3f9f30e2f814e39157017e7f9bf2be886335877 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 04 Feb 2026 15:51:12 +0800
Subject: [PATCH] feat(mall): 添加会员角色ID字段
---
src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java | 91 +++++++++++++++++++++++++++++++++++++++++----
1 files changed, 83 insertions(+), 8 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 faac604..93419ec 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
@@ -3,7 +3,13 @@
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.req.member.ApiCompanyStudyDto;
+import cc.mrbird.febs.ai.req.member.ApiCompanyStudyRecordDto;
+import cc.mrbird.febs.ai.req.member.ApiMemberAnswerPageDto;
import cc.mrbird.febs.ai.req.memberAnswer.*;
+import cc.mrbird.febs.ai.res.member.ApiCompanyStudyRecordVo;
+import cc.mrbird.febs.ai.res.member.ApiCompanyStudyVo;
+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;
@@ -17,6 +23,7 @@
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.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;
@@ -27,9 +34,8 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* AI用户答题记录 Service实现类
@@ -47,6 +53,8 @@
private final AiProductService aiProductService;
private final AiProductQuestionService aiProductQuestionService;
private final AiProductQuestionItemService aiProductQuestionItemService;
+ private final AiProductDependencyService aiProductDependencyService;
+ private final AiMemberProductUnlockService aiMemberProductUnlockService;
@Override
@@ -56,6 +64,7 @@
}
@Override
+ @Transactional
public FebsResponse startAnswerV2(ApiMemberAnswerDto dto) {
String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
ApiMemberAnswerVoV2 apiMemberAnswerVoV2 = new ApiMemberAnswerVoV2();
@@ -100,9 +109,30 @@
aiMemberAnswer.setCorrectCnt(0);
aiMemberAnswerMapper.insert(aiMemberAnswer);
List<AiMemberAnswerItem> aiMemberAnswerItems = new ArrayList<>();
- for (int i = 1; i <= questionCount; i++){
- //初始化答题记录
- AiProductQuestion aiProductQuestion = aiProductQuestionService.createQuestion(aiProduct.getId());
+// 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);
+// }
+
+ List<AiProductQuestion> questionList = aiProductQuestionService.createQuestionList(aiProduct.getId(), questionCount);
+ if (CollUtil.isEmpty(questionList)){
+ throw new FebsException("产品没有题目");
+ }
+ for (int i = 0; i < questionList.size(); i++){
+ AiProductQuestion aiProductQuestion = questionList.get(i);
AiMemberAnswerItem aiMemberAnswerItem = new AiMemberAnswerItem();
aiMemberAnswerItem.setId(UUID.getSimpleUUIDString());
aiMemberAnswerItem.setCompanyId(companyId);
@@ -114,7 +144,7 @@
aiMemberAnswerItem.setTitle(aiProductQuestion.getTitle());
aiMemberAnswerItem.setDifficulty(aiProductQuestion.getDifficulty());
aiMemberAnswerItem.setMemberAnswerState(0);
- aiMemberAnswerItem.setSort( i );
+ aiMemberAnswerItem.setSort( i +1);
aiMemberAnswerItems.add(aiMemberAnswerItem);
}
aiMemberAnswerItemService.saveBatch(aiMemberAnswerItems);
@@ -303,6 +333,7 @@
@Override
public FebsResponse insure(ApiMemberAnswerInsureDto dto) {
String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
+ String companyId = LoginUserUtil.getLoginUser().getCompanyId();
ApiMemberAnswerInsureVo apiMemberAnswerInsureVo = new ApiMemberAnswerInsureVo();
String memberAnswerId = dto.getMemberAnswerId();
@@ -330,6 +361,22 @@
.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);
}
@@ -361,9 +408,10 @@
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)){
+ //让listByQuery随机排序一次
+ Collections.shuffle(listByQuery);
for (AiProductQuestionItem aiProductQuestionItem : listByQuery){
ApiMemberAnswerPreviousItemVo apiMemberAnswerPreviousItemVo = new ApiMemberAnswerPreviousItemVo();
apiMemberAnswerPreviousItemVo.setId(aiProductQuestionItem.getId());
@@ -426,4 +474,31 @@
.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);
+ }
+
+ @Override
+ public IPage<ApiCompanyStudyVo> selectListPage(ApiCompanyStudyDto dto, Page<ApiCompanyStudyVo> page) {
+ return aiMemberAnswerMapper.selectProductListPage(page,dto);
+ }
+
+ @Override
+ public IPage<ApiCompanyStudyRecordVo> getStudyRecordList(Page<ApiCompanyStudyRecordVo> page, ApiCompanyStudyRecordDto dto) {
+ return aiMemberAnswerMapper.getStudyRecordList(page,dto);
+ }
+
+ @Override
+ public List<AiMemberAnswer> getIdListByCompanyIdAndProductId(String companyId, Set<String> collect) {
+ return aiMemberAnswerMapper.selectList(
+ Wrappers.lambdaQuery(AiMemberAnswer.class)
+ .select(AiMemberAnswer::getId,AiMemberAnswer::getProductId)
+ .eq(AiMemberAnswer::getCompanyId, companyId)
+ .in(AiMemberAnswer::getProductId, collect)
+ .eq(AiMemberAnswer::getState, AiTypeEnum.AI_MEMBER_ANSWER_STATE_DONE.getCode())
+ );
+ }
}
--
Gitblit v1.9.1