From 24681c81c09022f584a57006f2534b5f74723414 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 30 六月 2026 09:27:31 +0800
Subject: [PATCH] 初始化项目

---
 yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/BaiChuanChatModelTests.java |   38 ++++++++++++++++++++++++++------------
 1 files changed, 26 insertions(+), 12 deletions(-)

diff --git a/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/BaiChuanChatModelTests.java b/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/BaiChuanChatModelTests.java
index 96a1257..167532a 100644
--- a/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/BaiChuanChatModelTests.java
+++ b/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/BaiChuanChatModelTests.java
@@ -1,7 +1,7 @@
 package cn.iocoder.yudao.module.ai.framework.ai.core.model.chat;
 
+import cn.hutool.system.SystemUtil;
 import cn.iocoder.yudao.module.ai.framework.ai.core.model.baichuan.BaiChuanChatModel;
-import com.openai.client.okhttp.OpenAIOkHttpClient;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.springframework.ai.chat.messages.Message;
@@ -9,12 +9,16 @@
 import org.springframework.ai.chat.messages.UserMessage;
 import org.springframework.ai.chat.model.ChatResponse;
 import org.springframework.ai.chat.prompt.Prompt;
-import org.springframework.ai.openai.OpenAiChatModel;
-import org.springframework.ai.openai.OpenAiChatOptions;
+import org.springframework.ai.deepseek.DeepSeekChatModel;
+import org.springframework.ai.deepseek.DeepSeekChatOptions;
+import org.springframework.ai.deepseek.api.DeepSeekApi;
 import reactor.core.publisher.Flux;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
+
+import static cn.iocoder.yudao.module.ai.util.AiUtils.validateApiKey;
 
 /**
  * {@link BaiChuanChatModel} 闆嗘垚娴嬭瘯
@@ -23,22 +27,27 @@
  */
 public class BaiChuanChatModelTests {
 
-    private final OpenAiChatModel openAiChatModel = OpenAiChatModel.builder()
-            .openAiClient(OpenAIOkHttpClient.builder()
+    private static final String API_KEY = SystemUtil.get("BAICHUAN_API_KEY",
+            "sk-xxxx"); // 鎸夐渶鏀规垚浣犵殑鐧惧窛 API Key
+    private static final String MODEL = SystemUtil.get("BAICHUAN_MODEL",
+            BaiChuanChatModel.MODEL_DEFAULT);
+
+    private final BaiChuanChatModel chatModel = new BaiChuanChatModel(DeepSeekChatModel.builder()
+            .deepSeekApi(DeepSeekApi.builder()
                     .baseUrl(BaiChuanChatModel.BASE_URL)
-                    .apiKey("sk-61b6766a94c70786ed02673f5e16af3c") // apiKey
+                    .completionsPath(BaiChuanChatModel.COMPLETE_PATH)
+                    .apiKey(API_KEY)
                     .build())
-            .options(OpenAiChatOptions.builder()
-                    .model("Baichuan4-Turbo") // 妯″瀷锛坔ttps://platform.baichuan-ai.com/docs/api锛�
+            .options(DeepSeekChatOptions.builder()
+                    .model(MODEL)
                     .temperature(0.7)
                     .build())
-            .build();
-
-    private final BaiChuanChatModel chatModel = new BaiChuanChatModel(openAiChatModel);
+            .build());
 
     @Test
     @Disabled
     public void testCall() {
+        validateApiKey(API_KEY);
         // 鍑嗗鍙傛暟
         List<Message> messages = new ArrayList<>();
         messages.add(new SystemMessage("浣犳槸涓�涓紭璐ㄧ殑鏂囪█鏂囦綔鑰咃紝鐢ㄦ枃瑷�鏂囨弿杩扮潃鍚勫煄甯傜殑浜烘枃椋庢櫙銆�"));
@@ -48,11 +57,13 @@
         ChatResponse response = chatModel.call(new Prompt(messages));
         // 鎵撳嵃缁撴灉
         System.out.println(response);
+        System.out.println(Objects.requireNonNull(response.getResult()).getOutput());
     }
 
     @Test
     @Disabled
     public void testStream() {
+        validateApiKey(API_KEY);
         // 鍑嗗鍙傛暟
         List<Message> messages = new ArrayList<>();
         messages.add(new SystemMessage("浣犳槸涓�涓紭璐ㄧ殑鏂囪█鏂囦綔鑰咃紝鐢ㄦ枃瑷�鏂囨弿杩扮潃鍚勫煄甯傜殑浜烘枃椋庢櫙銆�"));
@@ -61,7 +72,10 @@
         // 璋冪敤
         Flux<ChatResponse> flux = chatModel.stream(new Prompt(messages));
         // 鎵撳嵃缁撴灉
-        flux.doOnNext(System.out::println).then().block();
+        flux.doOnNext(response -> {
+//            System.out.println(response);
+            System.out.println(Objects.requireNonNull(response.getResult()).getOutput());
+        }).then().block();
     }
 
 }

--
Gitblit v1.9.3