Administrator
2026-02-25 44e8988174ba750026fe3a5fcfade198d959766c
src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberTalkStreamServiceImpl.java
@@ -4,12 +4,11 @@
import cc.mrbird.febs.ai.enumerates.AiTalkOutputEnum;
import cc.mrbird.febs.ai.enumerates.AiTypeEnum;
import cc.mrbird.febs.ai.mapper.AiMemberTalkMapper;
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkItemPageDto;
import cc.mrbird.febs.ai.req.memberTalk.ApiTalkMemberListDto;
import cc.mrbird.febs.ai.req.memberTalk.ApiTalkReportListDto;
import cc.mrbird.febs.ai.req.memberTalk.*;
import cc.mrbird.febs.ai.req.memberTalkStream.*;
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkListDto;
import cc.mrbird.febs.ai.req.memberTalkStream.ApiMemberTalkStreamDto;
import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkMemberAnswerSavaVo;
import cc.mrbird.febs.ai.res.memberTalk.ApiMemberProductTalkVo;
import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkReloadStreamVo;
import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkStreamVo;
import cc.mrbird.febs.ai.service.*;
@@ -27,6 +26,7 @@
import com.alibaba.dashscope.common.Role;
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;
@@ -74,7 +74,7 @@
        }
        AiProduct aiProduct = aiProductService.getById(productId);
        Integer questionCount = aiProduct.getQuestionCount();
        Integer talkCnt = aiProduct.getTalkCnt();
        String companyId = aiProductRoleLink.getCompanyId();
@@ -91,7 +91,7 @@
        AiMemberTalk aiMemberTalk = aiMemberTalkService.getByQuery(query);
        String title = "加载时间过程,请重试!";
        if (ObjectUtil.isNull(aiMemberTalk)){
            aiMemberTalk = aiMemberTalkService.add(memberUuid,companyId,productId,nowTime,questionCount);
            aiMemberTalk = aiMemberTalkService.add(memberUuid,companyId,productId,nowTime,talkCnt);
            AiProductQuestion question = aiProductQuestionService.createQuestion(productId);
            if (ObjectUtil.isNotNull(question)){
                title = question.getTitle();
@@ -167,6 +167,22 @@
    }
    @Override
    public FebsResponse myTalkList(ApiMemberProductTalkPageDto dto) {
        String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
        dto.setMemberUuid(memberUuid);
        String companyId = LoginUserUtil.getLoginUser().getCompanyId();
        dto.setCompanyId(companyId);
        // 创建分页对象,传入当前页和每页大小
        Page<ApiMemberProductTalkVo> page = new Page<>(dto.getPageNow(), dto.getPageSize());
        Page<ApiMemberProductTalkVo> pageListByQuery = aiMemberTalkMapper.getPageMyTalkListByQuery(page, dto);
        return new FebsResponse().success().data(pageListByQuery);
    }
    @Override
    public FebsResponse talkList(ApiMemberTalkListDto dto) {
        return new FebsResponse().success().data(aiMemberTalkService.getPageByDto(dto));