feat(ai): 添加 HunYuan模型支持

- 新增 HunYuanAutoConfiguration 类实现自动配置
- 添加 HunYuanChatProperties 和 HunYuanCommonProperties 类管理配置属性
- 更新 HunYuanApi 和 HunYuanChatModel 类以支持新功能
-增加相关测试用例验证功能

Author: StudiousXiaoYu

models/spring-ai-hunyuan/pom.xml

@@ -26,8 +26,8 @@
     </parent>
     <artifactId>spring-ai-hunyuan</artifactId>
     <packaging>jar</packaging>
-    <name>Spring AI Model - Hunyuan</name>
-    <description>Hunyuan support</description>
+    <name>Spring AI Model - HunYuan</name>
+    <description>HunYuan support</description>
     <url>https://github.com/spring-projects/spring-ai</url>
 
     <scm>

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/HunYuanChatModel.java

@@ -66,10 +66,9 @@
 import org.springframework.util.CollectionUtils;
 
 /**
- * HunyuanChatModel is a {@link ChatModel} implementation that uses the Hunyuan
+ * HunYuanChatModel is a {@link ChatModel} implementation that uses the HunYuan
  *
- * @author Geng Rong
- * @author Alexandros Pappas
+ * @author Guo Junyu
  */
 public class HunYuanChatModel extends AbstractToolCallSupport implements ChatModel, StreamingChatModel {
 
@@ -83,7 +82,7 @@ public class HunYuanChatModel extends AbstractToolCallSupport implements ChatMod
 	private final HunYuanChatOptions defaultOptions;
 
 	/**
-	 * Low-level access to the Hunyuan API.
+	 * Low-level access to the HunYuan API.
 	 */
 	private final HunYuanApi hunYuanApi;
 
@@ -100,29 +99,29 @@ public class HunYuanChatModel extends AbstractToolCallSupport implements ChatMod
 	private ChatModelObservationConvention observationConvention = DEFAULT_OBSERVATION_CONVENTION;
 
 	/**
-	 * Initializes a new instance of the HunyuanChatModel.
-	 * @param hunYuanApi The Hunyuan instance to be used for interacting with the
-	 * Hunyuan Chat API.
+	 * Initializes a new instance of the HunYuanChatModel.
+	 * @param hunYuanApi The HunYuan instance to be used for interacting with the
+	 * HunYuan Chat API.
 	 */
 	public HunYuanChatModel(HunYuanApi hunYuanApi) {
 		this(hunYuanApi, HunYuanChatOptions.builder().model(HunYuanApi.DEFAULT_CHAT_MODEL).build());
 	}
 
 	/**
-	 * Initializes a new instance of the HunyuanChatModel.
-	 * @param hunYuanApi The Hunyuan instance to be used for interacting with the
-	 * Hunyuan Chat API.
-	 * @param options The HunyuanChatOptions to configure the chat client.
+	 * Initializes a new instance of the HunYuanChatModel.
+	 * @param hunYuanApi The HunYuan instance to be used for interacting with the
+	 * HunYuan Chat API.
+	 * @param options The HunYuanChatOptions to configure the chat client.
 	 */
 	public HunYuanChatModel(HunYuanApi hunYuanApi, HunYuanChatOptions options) {
 		this(hunYuanApi, options, null, RetryUtils.DEFAULT_RETRY_TEMPLATE);
 	}
 
 	/**
-	 * Initializes a new instance of the HunyuanChatModel.
-	 * @param hunYuanApi The Hunyuan instance to be used for interacting with the
-	 * Hunyuan Chat API.
-	 * @param options The HunyuanChatOptions to configure the chat client.
+	 * Initializes a new instance of the HunYuanChatModel.
+	 * @param hunYuanApi The HunYuan instance to be used for interacting with the
+	 * HunYuan Chat API.
+	 * @param options The HunYuanChatOptions to configure the chat client.
 	 * @param functionCallbackResolver The function callback resolver to resolve the
 	 * function by its name.
 	 * @param retryTemplate The retry template.
@@ -133,10 +132,10 @@ public HunYuanChatModel(HunYuanApi hunYuanApi, HunYuanChatOptions options,
 	}
 
 	/**
-	 * Initializes a new instance of the HunyuanChatModel.
-	 * @param hunYuanApi The Hunyuan instance to be used for interacting with the
-	 * Hunyuan Chat API.
-	 * @param options The HunyuanChatOptions to configure the chat client.
+	 * Initializes a new instance of the HunYuanChatModel.
+	 * @param hunYuanApi The HunYuan instance to be used for interacting with the
+	 * HunYuan Chat API.
+	 * @param options The HunYuanChatOptions to configure the chat client.
 	 * @param functionCallbackResolver resolves the function by its name.
 	 * @param toolFunctionCallbacks The tool function callbacks.
 	 * @param retryTemplate The retry template.
@@ -146,7 +145,7 @@ public HunYuanChatModel(HunYuanApi hunYuanApi, HunYuanChatOptions options,
 							FunctionCallbackResolver functionCallbackResolver, List<FunctionCallback> toolFunctionCallbacks,
 							RetryTemplate retryTemplate, ObservationRegistry observationRegistry) {
 		super(functionCallbackResolver, options, toolFunctionCallbacks);
-		Assert.notNull(hunYuanApi, "HunyuanApi must not be null");
+		Assert.notNull(hunYuanApi, "HunYuanApi must not be null");
 		Assert.notNull(options, "Options must not be null");
 		Assert.notNull(retryTemplate, "RetryTemplate must not be null");
 		Assert.isTrue(CollectionUtils.isEmpty(options.getFunctionCallbacks()),
@@ -311,7 +310,7 @@ public Flux<ChatResponse> stream(Prompt prompt) {
 	}
 
 	private ChatResponseMetadata from(ChatCompletionRequest request, ChatCompletion result) {
-		Assert.notNull(result, "Hunyuan ChatCompletionResult must not be null");
+		Assert.notNull(result, "HunYuan ChatCompletionResult must not be null");
 		return ChatResponseMetadata.builder()
 			.id(result.id() != null ? result.id() : "")
 			.usage(result.usage() != null ? HunYuanUsage.from(result.usage()) : new EmptyUsage())

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/HunYuanChatOptions.java

@@ -29,11 +29,9 @@
 import org.springframework.util.Assert;
 
 /**
- * Options for Hunyuan chat completions.
+ * Options for HunYuan chat completions.
  *
- * @author Geng Rong
- * @author Thomas Vitale
- * @author Alexandros Pappas
+ * @author Guo Junyu
  */
 @JsonInclude(JsonInclude.Include.NON_NULL)
 public class HunYuanChatOptions implements FunctionCallingOptions {
@@ -71,7 +69,7 @@ public class HunYuanChatOptions implements FunctionCallingOptions {
 
 
 	/**
-	 * Hunyuan Tool Function Callbacks to register with the ChatModel. For Prompt Options
+	 * HunYuan Tool Function Callbacks to register with the ChatModel. For Prompt Options
 	 * the functionCallbacks are automatically enabled for the duration of the prompt
 	 * execution. For Default Options the functionCallbacks are registered but disabled by
 	 * default. Use the enableFunctions to set the functions from the registry to be used

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/api/HunYuanApi.java

@@ -20,18 +20,13 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Consumer;
 import java.util.function.Predicate;
-import java.util.stream.Collectors;
 
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonInclude.Include;
 import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.ai.hunyuan.api.auth.HunYuanAuthApi;
-import org.springframework.util.CollectionUtils;
 import org.springframework.util.MultiValueMap;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -311,6 +306,11 @@ public record Usage(
 	 * like 0.8 will make the output more random, while lower values like 0.2 will make it
 	 * more focused and deterministic. We generally recommend altering this or top_p but
 	 * not both.
+	 * @param enableEnhancement Enables or disables feature enhancements such as search. This parameter does not affect the security review capability.
+	 * For hunyuan-lite, this parameter is ineffective.
+	 * If not specified, the switch is turned on by default.
+	 * Turning off this switch can reduce response latency, especially for the first character in stream mode, but may slightly degrade the response quality in some scenarios.
+	 * Example: true
 	 * @param topP An alternative to sampling with temperature, called nucleus sampling,
 	 * where the model considers the results of the tokens with top_p probability mass. So
 	 * 0.1 means only the tokens comprising the top 10% probability mass are considered.
@@ -319,12 +319,46 @@ public record Usage(
 	 * @param stream If set, partial message deltas will be sent.Tokens will be sent as
 	 * data-only server-sent events as they become available, with the stream terminated
 	 * by a data: [DONE] message.
+	 * @param streamModeration Controls whether the output is reviewed in real-time during streaming.
+	 * This field is effective only when Stream is set to true.
+	 * If true, the output is reviewed in real-time, and segments that fail the review will have their FinishReason set to sensitive.
+	 * If false, the entire output is reviewed before being returned.
+	 * If real-time text display is required in your application, you should handle the case where FinishReason is sensitive by撤回已显示的内容 and providing a custom message.
+	 * Example: false
 	 * @param tools A list of tools the model may call. Currently, only functions are
 	 * supported as a tool.
-	 * @param toolChoice Controls which (if any) function is called by the model.
-	 * @param customTool A custom tool to be used by the model.
-	 * @param searchInfo Whether to include search information in the response.
-	 * @param citation Whether to include citation information in the response.
+	 * @param toolChoice Controls which (if any) function is called by the model. Possible values are none, auto, and custom.
+	 *  If not specified, the default is auto.
+	 *  Example: auto
+	 * @param customTool Forces the model to call a specific tool. This parameter is required when ToolChoice is set to custom.
+	 * @param searchInfo If true, the interface will return SearchInfo when a search hit occurs. Example: false
+	 * @param citation Enables or disables citation markers in the response.
+	 * This parameter works in conjunction with EnableEnhancement and SearchInfo.
+	 * If true, search results in the response will be marked with a citation marker corresponding to links in the SearchInfo list.
+	 * If not specified, the default is false.
+	 * Example: false
+	 * @param enableSpeedSearch Enables or disables the fast version of search.
+	 * If true and a search hit occurs, the fast version of search will be used, which can reduce the latency of the first character in the stream.
+	 * Example: false
+	 * @param enableMultimedia  Enables or disables multimedia capabilities.
+	 * This parameter is effective only for whitelisted users and when EnableEnhancement is true and EnableSpeedSearch is false.
+	 * For hunyuan-lite, this parameter is ineffective.
+	 * If not specified, the default is false.
+	 * When enabled and a multimedia hit occurs, the corresponding multimedia address will be output.
+	 * Example: false
+	 * @param enableDeepSearch Enables or disables deep research on the question.
+	 *  If true and a deep research hit occurs, information about the deep research will be returned.
+	 *  Example: false
+	 * @param seed Ensures the model's output is reproducible.
+	 * The value should be a non-zero positive integer, with a maximum value of 10000.
+	 * It is not recommended to use this parameter unless necessary, as improper values can affect the output quality.
+	 * Example: 1
+	 * @param forceSearchEnhancement Forces the use of AI search.
+	 * If true, AI search will be used, and if the AI search result is empty, the large model will provide a fallback response.
+	 * Example: false
+	 * @param enableRecommendedQuestions Enables or disables the recommendation of additional questions.
+	 * If true, the response will include a RecommendedQuestions field with up to 3 recommended questions in the last package.
+	 * Example: false
 	 */
 	@JsonInclude(Include.NON_NULL)
 	public record ChatCompletionRequest(
@@ -346,7 +380,7 @@ public record ChatCompletionRequest(
 			@JsonProperty("EnableMultimedia") Boolean enableMultimedia,
 			@JsonProperty("EnableDeepSearch") Boolean enableDeepSearch,
 			@JsonProperty("Seed") Integer seed,
-			@JsonProperty("ForceSearchEnhancement") Boolean ForceSearchEnhancement,
+			@JsonProperty("ForceSearchEnhancement") Boolean forceSearchEnhancement,
 			@JsonProperty("EnableRecommendedQuestions") Boolean enableRecommendedQuestions
 	) {
 		 // @formatter:on
@@ -403,6 +437,19 @@ public ChatCompletionRequest(List<ChatCompletionMessage> messages, String model,
 									 String toolChoice) {
 			this(model,messages, null, null, null, null, null, null, tools, toolChoice, null, null, null, null, null, null, null, null, null);
 		}
+
+		/**
+		 *  Shortcut constructor for a chat completion request with the given messages,
+		 *  model, stream, streamModeration, enableEnhancement, searchInfo, citation, enableSpeedSearch.
+		 * @param messages A list of messages comprising the conversation so far.
+		 * @param model	  ID of the model to use.
+		 * @param stream  Whether to stream back partial progress.
+		 * @param streamModeration Whether to stream back partial progress.
+		 * @param enableEnhancement Enables or disables the enhancement feature.
+		 * @param searchInfo Enables or disables the search information feature.
+		 * @param citation Enables or disables the citation feature.
+		 * @param enableSpeedSearch Enables or disables the speed search feature.
+		 */
 		public ChatCompletionRequest(List<ChatCompletionMessage> messages, String model,
 									 Boolean stream,
 									 Boolean streamModeration,
@@ -454,7 +501,7 @@ public static Object function(String functionName) {
 	 * @param rawContent The raw contents of the message.
 	 * @param role The role of the message's author. Could be one of the {@link Role}
 	 * types.
-	 * @param chatContent The name of the message's author.
+	 * @param chatContents The name of the message's author.
 	 * @param toolCallId The ID of the tool call associated with the message.
 	 * @param toolCalls The list of tool calls associated with the message.
 	 */
@@ -583,14 +630,7 @@ public record ChatCompletionFunction(@JsonProperty("Name") String name,
 	/**
 	 * Represents a chat completion response returned by model, based on the provided
 	 * input.
-	 *
-	 * @param id A unique identifier for the chat completion.
-	 * @param object The object type, which is always chat.completion.
-	 * @param created The Unix timestamp (in seconds) of when the chat completion was
-	 * created.
-	 * @param model The model used for the chat completion.
-	 * @param choices A list of chat completion choices.
-	 * @param usage Usage statistics for the completion request.
+	 * @param response The response object containing the generated chat completion.
 	 */
 	@JsonInclude(Include.NON_NULL)
 	public record ChatCompletionResponse(
@@ -754,12 +794,13 @@ public record ErrorMsg(
 	 * on the provided input.
 	 *
 	 * @param id A unique identifier for the chat completion. Each chunk has the same ID.
-	 * @param object The object type, which is always 'chat.completion.chunk'.
+	 * @param errorMsg The error message, if any.
 	 * @param created The Unix timestamp (in seconds) of when the chat completion was
 	 * created. Each chunk has the same timestamp.
-	 * @param model The model used for the chat completion.
+	 * @param note A note about the generated content. Each chunk has the same note.
 	 * @param choices A list of chat completion choices. Can be more than one if n is
 	 * greater than 1.
+	 * @param usage The usage statistics for the chat completion.
 	 */
 	@JsonInclude(Include.NON_NULL)
 	public record ChatCompletionChunk(

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/api/HunYuanConstants.java

@@ -19,9 +19,9 @@
 import org.springframework.ai.observation.conventions.AiProvider;
 
 /**
- * Constants for Moonshot API.
+ * Constants for HunYuan API.
  *
- * @author Geng Rong
+ * @author Guo Junyu
  */
 public final class HunYuanConstants {
 

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/api/HunYuanStreamFunctionCallingHelper.java

@@ -28,7 +28,7 @@
  * Helper class to support Streaming function calling. It can merge the streamed
  * ChatCompletionChunk in case of function calling message.
  *
- * @author Geng Rong
+ * @author Guo Junyu
  */
 public class HunYuanStreamFunctionCallingHelper {
 

models/spring-ai-hunyuan/src/main/java/org/springframework/ai/hunyuan/metadata/HunYuanUsage.java

@@ -21,9 +21,9 @@
 import org.springframework.util.Assert;
 
 /**
- * Represents the usage of a Hunyuan model.
+ * Represents the usage of a HunYuan model.
  *
- * @author Geng Rong
+ * @author Guo Junyu
  */
 public class HunYuanUsage implements Usage {
 

models/spring-ai-hunyuan/src/test/java/org/springframework/ai/hunyuan/HunYuanChatCompletionRequestTest.java

@@ -26,8 +26,7 @@
 import static org.assertj.core.api.Assertions.assertThat;
 
 /**
- * @author Geng Rong
- * @author Alexandros Pappas
+ * @author Guo Junyu
  */
 @SpringBootTest
 @EnabledIfEnvironmentVariable(named = "HUNYUAN_SECRET_ID", matches = ".+")

models/spring-ai-hunyuan/src/test/java/org/springframework/ai/hunyuan/HunYuanRetryTests.java

@@ -48,8 +48,7 @@
 import static org.mockito.BDDMockito.given;
 
 /**
- * @author Geng Rong
- * @author Alexandros Pappas
+ * @author Guo Junyu
  */
 @SuppressWarnings("unchecked")
 @ExtendWith(MockitoExtension.class)
@@ -99,7 +98,7 @@ public void hunyuanChatTransientError() {
 	}
 
 	@Test
-	public void moonshotChatNonTransientError() {
+	public void hunYuanChatNonTransientError() {
 		given(this.hunYuanApi.chatCompletionEntity(isA(ChatCompletionRequest.class)))
 			.willThrow(new RuntimeException("Non Transient Error"));
 		assertThrows(RuntimeException.class, () -> this.chatModel.call(new Prompt("text")));

models/spring-ai-hunyuan/src/test/java/org/springframework/ai/hunyuan/HunYuanTestConfiguration.java

@@ -22,7 +22,7 @@
 import org.springframework.util.StringUtils;
 
 /**
- * @author Geng Rong
+ * @author Guo Junyu
  */
 @SpringBootConfiguration
 public class HunYuanTestConfiguration {