feat(ai): 新增陪练记录相关接口和分页查询功能

Administrator

2025-10-10 3861ca73a58797316065f49c22f48734b4160c6a

 src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberTalkStreamServiceImpl.java

@@ -5,10 +5,15 @@
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.memberTalkStream.*;
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkListDto;
import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkMemberAnswerSavaVo;
import cc.mrbird.febs.ai.res.memberTalk.ApiTalkReportListVo;
import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkReloadStreamVo;
import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkStreamVo;
import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkListVo;
import cc.mrbird.febs.ai.service.*;
import cc.mrbird.febs.ai.strategy.LlmStrategyFactory;
import cc.mrbird.febs.ai.strategy.enumerates.LlmApplicationAppIdEnum;
@@ -101,6 +106,28 @@
        apiMemberTalkVo.setQuestionCnt(aiMemberTalk.getQuestionCnt());
        apiMemberTalkVo.setDoneCnt(aiMemberTalk.getDoneCnt() + 1);
        return new FebsResponse().success().data(apiMemberTalkVo);
    }

    @Override
    public FebsResponse talkList(ApiMemberTalkListDto dto) {

        return new FebsResponse().success().data(aiMemberTalkService.getPageByDto(dto));
    }

    @Override
    public FebsResponse talkMemberList(ApiTalkMemberListDto dto) {

        return new FebsResponse().success().data(aiMemberTalkItemService.getPageByDto(dto));
    }

    @Override
    public FebsResponse talkReportList(ApiTalkReportListDto dto) {
        ApiTalkReportListVo apiTalkReportListDto = new ApiTalkReportListVo();

        String memberTalkId = dto.getMemberTalkId();
        AiMemberTalk byId = aiMemberTalkService.getById(memberTalkId);
        apiTalkReportListDto.setAnalysis(byId.getAnalysis());
        return new FebsResponse().success().data(apiTalkReportListDto);
    }

    @Override
@@ -445,7 +472,12 @@
        llmStrategyDtoList.add(llmStrategyDto);
        llmStrategyDto = this.buildLlmStrategyDtoList("请按照要求生成报告", 2);
        llmStrategyDtoList.add(llmStrategyDto);
        llmStrategyDto = this.buildLlmStrategyDtoList(String.valueOf(LlmApplicationAppIdEnum.REPORT.getCode()), 4);

        AiCompanyWorkflow aiCompanyWorkflow = aiCompanyWorkflowService.getByTypeAndCompanyId(LlmApplicationAppIdEnum.REPORT.getCode(),aiMemberTalk.getCompanyId());
        if (ObjectUtil.isNull(aiCompanyWorkflow)){
            throw new FebsException("工作流配置异常，请联系管理员");
        }
        llmStrategyDto = this.buildLlmStrategyDtoList(aiCompanyWorkflow.getCode(), 4);
        llmStrategyDtoList.add(llmStrategyDto);

        LlmStrategyDto llmStrategyDtoMessage = buildMessages(memberTalkId);