feat(ai): 新增消息构建逻辑支持多种角色对话

Administrator

2025-10-30 94193e74305a30697b9b6e8c841d34d3576a50c8

feat(ai): 新增消息构建逻辑支持多种角色对话

- 实现 getMessages 方法解析 LlmStrategyDto 构建 Message 列表
- 支持 SYSTEM、USER、ASSISTANT 三种角色消息类型
- 在应用参数中加入 messages 字段用于传递对话历史
- 完善百炼工作流调用时的参数构建逻辑

 src/main/java/cc/mrbird/febs/ai/strategy/Impl/AliApplicationLlmStrategyServiceImpl.java

@@ -60,6 +60,36 @@
        return bizParamsMap;
    }

    private List<Message> getMessages(List<LlmStrategyDto> dto) {
        List<Message> messages = new ArrayList<>();
        for (LlmStrategyDto item : dto){
            if (StrUtil.equals(item.getRole(),AiTypeEnum.MESSAGES.getName())){
                List<LlmStrategyDto> messagesList = item.getMessages();
                for (LlmStrategyDto dtoItem : messagesList){
                    if (StrUtil.equals(dtoItem.getRole(),Role.SYSTEM.getValue())){
                        messages.add(Message.builder()
                                .role(Role.SYSTEM.getValue())
                                .content(dtoItem.getContent())
                                .build());
                    }
                    if (StrUtil.equals(dtoItem.getRole(),Role.USER.getValue())){
                        messages.add(Message.builder()
                                .role(Role.USER.getValue())
                                .content(dtoItem.getContent())
                                .build());
                    }
                    if (StrUtil.equals(dtoItem.getRole(),Role.ASSISTANT.getValue())){
                        messages.add(Message.builder()
                                .role(Role.ASSISTANT.getValue())
                                .content(dtoItem.getContent())
                                .build());
                    }
                }
            }
        }
        return messages;
    }

    private String getQuery(List<LlmStrategyDto> dto) {
        String query = null;
        for (LlmStrategyDto dtoItem : dto){
@@ -188,6 +218,8 @@
        if (appId == null){
            throw new FebsException("百炼工作流初始化异常");
        }

        List<Message> messages = getMessages(dto);
        long startTime = System.currentTimeMillis();
        ApplicationParam param = ApplicationParam.builder()
                // 若没有配置环境变量，可用百炼API Key将下行替换为：.apiKey("sk-xxx")。但不建议在生产环境中直接将API Key硬编码到代码中，以减少API Key泄露风险。
@@ -195,6 +227,7 @@
                .appId(appId) //替换为实际的应用 ID
                .flowStreamMode(FlowStreamMode.MESSAGE_FORMAT)
                .prompt(query)
                .messages( messages)
                .bizParams(JsonUtils.toJsonObject( prompt))
                .build();