Administrator
2025-09-03 18fdf89338e84e1cab48c2795631777e22b05b81
src/main/java/cc/mrbird/febs/ai/service/impl/AiTalkServiceImpl.java
@@ -8,7 +8,6 @@
import cc.mrbird.febs.ai.req.talk.ApiTalkDto;
import cc.mrbird.febs.ai.req.talk.ApiTalkItemPageDto;
import cc.mrbird.febs.ai.req.talk.ApiTalkPageDto;
import cc.mrbird.febs.ai.res.memberAnswer.ApiMemberProductWorkVo;
import cc.mrbird.febs.ai.res.talk.ApiTalkPageVo;
import cc.mrbird.febs.ai.res.talk.ApiTalkQuestionVo;
import cc.mrbird.febs.ai.res.talk.ApiTalkVo;
@@ -17,6 +16,7 @@
import cc.mrbird.febs.ai.service.AiTalkItemService;
import cc.mrbird.febs.ai.service.AiTalkService;
import cc.mrbird.febs.ai.strategy.LlmStrategyFactory;
import cc.mrbird.febs.ai.strategy.enumerates.LlmStrategyContextEnum;
import cc.mrbird.febs.ai.strategy.enumerates.LlmStrategyEnum;
import cc.mrbird.febs.ai.strategy.param.LlmStrategyDto;
import cc.mrbird.febs.ai.utils.UUID;
@@ -26,6 +26,7 @@
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.dashscope.common.Role;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -38,6 +39,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
@Slf4j
@@ -72,6 +74,7 @@
        String talkId = dto.getTalkId();
        String context = dto.getContext();
        Integer type = dto.getType();
        String reasoningContent = dto.getReasoningContent();
        String memberUuid = LoginUserUtil.getLoginUser().getMemberUuid();
        AiTalk aiTalk = this.getById(talkId);
@@ -79,8 +82,10 @@
        if (StrUtil.isEmpty(talkId)){
            aiTalk = this.add(memberUuid,context, date);
        }
        aiTalkItemService.add(aiTalk.getId(), type, context, memberUuid, date);
        HashMap<String, String> stringStringHashMap = new HashMap<>();
        stringStringHashMap.put(LlmStrategyContextEnum.THINK.getName(),reasoningContent);
        stringStringHashMap.put(LlmStrategyContextEnum.CONTENT.getName(),context);
        aiTalkItemService.add(aiTalk.getId(), type, JSONUtil.toJsonStr(stringStringHashMap), memberUuid, date);
        ApiTalkVo apiTalkVo = new ApiTalkVo();
        apiTalkVo.setTalkId(aiTalk.getId());
@@ -133,7 +138,7 @@
        if (dto.getPrompt() != null){
            LlmStrategyDto llmStrategyDto = new LlmStrategyDto();
            llmStrategyDto.setRole(Role.SYSTEM.getValue());
            llmStrategyDto.setContent(AiPromptEnum.STREAM_NORMAL.getPrompt());
            llmStrategyDto.setContent(aiService.getSystemSetLTAiPrompt());
            llmStrategyDtoList.add(llmStrategyDto);
        }
        if (dto.getQuestion() != null){
@@ -143,7 +148,7 @@
            llmStrategyDtoList.add(llmStrategyDto);
        }
        String modelName = LlmStrategyEnum.getName(aiService.getSystemSetAiType());
        return llmStrategyFactory.getCalculationStrategyMap().get(modelName).llmInvokeStreaming(llmStrategyDtoList);
        return llmStrategyFactory.getCalculationStrategyMap().get(modelName).llmInvokeStreamingWithThink(llmStrategyDtoList);
    }
}