From 4f55ce5729fd6efd8c71a355e90adc0a1dee239a Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 12 Jan 2026 17:53:55 +0800
Subject: [PATCH] feat(ai): 添加成员答题答案字段

---
 src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberAnswerServiceImpl.java |   57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 57 insertions(+), 0 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 2434673..d4fed26 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,13 @@
 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.ApiCompanyStudyDto;
+import cc.mrbird.febs.ai.req.member.ApiMemberAnswerPageDto;
 import cc.mrbird.febs.ai.req.memberAnswer.*;
+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;
@@ -16,6 +21,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;
@@ -29,6 +35,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 +54,8 @@
     private final AiProductService aiProductService;
     private final AiProductQuestionService aiProductQuestionService;
     private final AiProductQuestionItemService aiProductQuestionItemService;
+    private final AiProductDependencyService aiProductDependencyService;
+    private final AiMemberProductUnlockService aiMemberProductUnlockService;
 
 
     @Override
@@ -302,6 +312,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 +340,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);
     }
 
@@ -406,4 +433,34 @@
                 .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);
+    }
+
+    @Override
+    public IPage<ApiCompanyStudyVo> selectListPage(ApiCompanyStudyDto dto, Page<ApiCompanyStudyVo> page) {
+        return aiMemberAnswerMapper.selectProductListPage(page,dto);
+    }
 }

--
Gitblit v1.9.1