import OpenAI from "openai";
import process from 'process';

// 初始化OpenAI客户端
const openai = new OpenAI({
  // 如果没有配置环境变量，请用千问云API Key替换：apiKey: "sk-xxx"
  apiKey: process.env.DASHSCOPE_API_KEY,
  baseURL: 'https://dashscope.aliyuncs.com/compatible-mode/v1'
});

let reasoningContent = ''; // 完整思考过程
let answerContent = ''; // 完整回复
let isAnswering = false; // 是否进入回复阶段

async function main() {
  const messages = [{ role: 'user', content: '你是谁' }];

  const stream = await openai.chat.completions.create({
    model: 'kimi-k2-thinking',
    messages,
    stream: true,
  });

int = false;
      }
      System.out.print(reasoning);
    }

    if (content != null && !content.isEmpty()) {
      finalContent.append(content);
      if (!isFirstPrint) {
        System.out.println("\n====================完整回复====================");
        isFirstPrint = true;
      }
      System.out.print(content);
    }
  }

  private static GenerationParam buildGenerationParam(Message userMsg) {
    return GenerationParam.builder()
        // 若没有配置环境变量，请用千问云API Key将下行替换为：.apiKey("sk-xxx")
        .apiKey(System.getenv("DASHSCOPE_API_KEY"))
        .model("MiniMax-M2.5")
        .incrementalOutput(true)
        .resultFormat("message")
        .messages(Arrays.asList(userMsg))
        .build();
  }

  public static void streamCallWithMessage(Generation gen, Message userMsg)
      throws NoApiKeyException, ApiException, InputRequiredException {
    GenerationParam param = buildGenerationParam(userMsg);
    Flowable<GenerationResult> result = gen.streamCall(param);
    result.blockingForEach(message -> handleGenerationResult(message));
  }

  public static void main(String[] args) {
    try {
      Generation gen = new Generation();
      Message userMsg = Message.builder().role(Role.USER.getValue()).content("你是谁？").build();
      streamCallWithMessage(gen, userMsg);
    } catch (ApiException | NoApiKeyException | InputRequiredException e) {
      logger.error("An exception occurred: {}", e.getMessage());
    }
    System.exit(0);
  }
}

====================思考过程====================

用户用中文问"你是谁"，意思是"你是谁？"或"Who are you?"

我应该用中文回复，介绍自己是一个AI助手。
====================完整回复====================

你好！我是 MiniMax-M2.5，一个AI助手。我可以帮助你回答问题、提供信息、进行对话等。有什么我可以帮你的吗？

curl -X POST "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation" \
-H "Authorization: Bearer $DASHSCOPE_API_KEY" \
-H "Content-Type: application/json" \
-d '{
    "model": "MiniMax-M2.5",
    "input":{
        "messages":[      
            {
                "role": "user",
                "content": "你是谁？"
            }
        ]
    },
    "parameters": {
        "result_format": "message"
    }
}'

{
    "output": {
        "choices": [
            {
                "finish_reason": "stop",
                "message": {
                    "content": "你好！我是 MiniMax-M2.5，由 MiniMax 公司开发的 AI 助手。我可以帮助你回答问题、提供信息、进行对话等。有什么我可以帮你的吗？",
                    "reasoning_content": "用户用中文问\"你是谁？\"，意思是\"Who are you?\"\n\n我应该用中文回答，介绍自己。我应该说明我是MiniMax-M2.5，由MiniMax公司开发的AI助手。",
                    "role": "assistant"
                }
            }
        ]
    },
    "usage": {
        "input_tokens": 41,
        "output_tokens": 79,
        "output_tokens_details": {
            "reasoning_tokens": 39
        },
        "prompt_tokens_details": {
            "cached_tokens": 0
        },
        "total_tokens": 120
    },
    "request_id": "1bbd770e-564a-4601-83fc-3bf639423xxx"
}