zhou zhou
20 小时以前 4954d3978cf1967729a5a2d5b90f6baef18974da
rsf-server/src/main/java/com/vincent/rsf/server/ai/service/impl/AiConfigResolverServiceImpl.java
@@ -6,6 +6,7 @@
import com.vincent.rsf.server.ai.service.AiMcpMountService;
import com.vincent.rsf.server.ai.service.AiParamService;
import com.vincent.rsf.server.ai.service.AiPromptService;
import com.vincent.rsf.framework.exception.CoolException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
@@ -17,15 +18,36 @@
    private final AiParamService aiParamService;
    private final AiPromptService aiPromptService;
    private final AiMcpMountService aiMcpMountService;
    private final AiRedisSupport aiRedisSupport;
    /**
     * 按租户解析一次完整的 AI 运行配置。
     * 该方法是对话入口、运行态摘要和配置中心共用的统一解析点,
     * 负责把当前生效的参数、Prompt 和 MCP 挂载聚合成一个不可再拆分的配置对象。
     */
    @Override
    public AiResolvedConfig resolve(String promptCode, Long tenantId) {
        return resolve(promptCode, tenantId, null);
    }
    @Override
    public AiResolvedConfig resolve(String promptCode) {
    public AiResolvedConfig resolve(String promptCode, Long tenantId, Long aiParamId) {
        if (tenantId == null) {
            throw new CoolException("当前租户不存在");
        }
        String finalPromptCode = StringUtils.hasText(promptCode) ? promptCode : AiDefaults.DEFAULT_PROMPT_CODE;
        return AiResolvedConfig.builder()
        // 配置解析是多个入口共享的热点路径,命中缓存时可以避免三张配置表的重复查询。
        AiResolvedConfig cached = aiRedisSupport.getResolvedConfig(tenantId, finalPromptCode, aiParamId);
        if (cached != null) {
            return cached;
        }
        AiResolvedConfig resolvedConfig = AiResolvedConfig.builder()
                .promptCode(finalPromptCode)
                .aiParam(aiParamService.getActiveParam())
                .prompt(aiPromptService.getActivePrompt(finalPromptCode))
                .mcpMounts(aiMcpMountService.listActiveMounts())
                .aiParam(aiParamService.getChatParam(tenantId, aiParamId))
                .prompt(aiPromptService.getActivePrompt(finalPromptCode, tenantId))
                .mcpMounts(aiMcpMountService.listActiveMounts(tenantId))
                .build();
        aiRedisSupport.cacheResolvedConfig(tenantId, finalPromptCode, aiParamId, resolvedConfig);
        return resolvedConfig;
    }
}