From 6e9730ebbbff634d27c2c49ec328156c8905b508 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 30 Oct 2025 13:52:14 +0800
Subject: [PATCH] feat(ai): 简化AI对话项创建逻辑并新增连续对话类型 - 移除复杂的对话项更新逻辑，统一通过add方法创建新项 - 新增AiTalkOutputEnum枚举值CONTEXT_TALK用于AI陪练连续对话 - 更新ApiMemberTalkAnswerSavaDto注释以包含新的对话类型 - 修复对话项创建时类型参数未正确传递的问题 - 优化代码结构，减少冗余的条件判断和数据转换操作
---
src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java | 69 ++++++++++++++++++++++++++++++++--
1 files changed, 64 insertions(+), 5 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 56576c6..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,8 +1,11 @@
package cc.mrbird.febs.ai.service.impl;
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.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;
@@ -29,6 +32,8 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
/**
* AI用户答题记录 Service实现类
@@ -46,6 +51,8 @@
private final AiProductService aiProductService;
private final AiProductQuestionService aiProductQuestionService;
private final AiProductQuestionItemService aiProductQuestionItemService;
+ private final AiProductDependencyService aiProductDependencyService;
+ private final AiMemberProductUnlockService aiMemberProductUnlockService;
@Override
@@ -253,11 +260,11 @@
throw new FebsException("答题记录不存在");
}
- String companyId = aiMemberAnswer.getCompanyId();
+ Date nowTime = new Date();
- Date createdTime = new Date();
+ String companyId = aiMemberAnswer.getCompanyId();
AiMemberAnswerItem aiMemberAnswerItem = aiMemberAnswerItemService.getById(memberAnswerItemId);
- aiMemberAnswerItem.setUpdatedTime(createdTime);
+ aiMemberAnswerItem.setUpdatedTime(nowTime);
AiProductQuestion aiProductQuestion = aiProductQuestionService.getById(productQuestionId);
LambdaQueryWrapper<AiProductQuestionItem> productQuestionItemLambdaQueryWrapper = Wrappers.lambdaQuery(AiProductQuestionItem.class);
@@ -282,14 +289,14 @@
}else{
aiMemberAnswerItem.setIsCollected(0);
}
+ aiMemberAnswerItem.setCompanyId(companyId);
aiMemberAnswerItemService.updateById(aiMemberAnswerItem);
aiMemberAnswer.setDoneCnt(aiMemberAnswer.getDoneCnt() + 1);
if (aiMemberAnswerItem.getMemberAnswerState() == 1){
aiMemberAnswer.setCorrectCnt(aiMemberAnswer.getCorrectCnt() + 1);
}
- aiMemberAnswerItem.setCompanyId(companyId);
- aiMemberAnswer.setUpdatedTime(createdTime);
+ aiMemberAnswer.setUpdatedTime(nowTime);
aiMemberAnswerMapper.updateById(aiMemberAnswer);
apiQuestionItemInfoVo.setAnswerAnalysis(aiMemberAnswerItem.getAnswerAnalysis());
@@ -302,6 +309,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();
@@ -329,6 +337,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);
}
@@ -396,4 +420,39 @@
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