Package com.bytedesk.ai.springai.providers.zhipuai

Class SpringAIZhipuaiService

java.lang.Object

com.bytedesk.ai.springai.service.BaseSpringAIService

com.bytedesk.ai.springai.providers.zhipuai.SpringAIZhipuaiService

All Implemented Interfaces:

SpringAIService

@Service
@ConditionalOnProperty(name="spring.ai.zhipuai.chat.enabled",
                       havingValue="true")
public class SpringAIZhipuaiService
extends BaseSpringAIService

Field Summary

Fields

Modifier and Type	Field	Description
private org.springframework.ai.zhipuai.ZhiPuAiChatModel	bytedeskZhipuaiChatModel
private org.springframework.ai.zhipuai.api.ZhiPuAiApi	zhipuaiApi

Fields inherited from class com.bytedesk.ai.springai.service.BaseSpringAIService

chunkElasticService, chunkVectorService, faqElasticService, faqVectorService, messagePersistCache, messageRestService, messageSendService, robotMessageCache, robotRestService, textElasticService, textVectorService, threadRestService, uidUtils

Constructor Summary

Constructors

Constructor	Description
SpringAIZhipuaiService()

Method Summary

Modifier and Type	Method	Description
private org.springframework.ai.zhipuai.ZhiPuAiChatModel	createDynamicChatModel(RobotLlm llm)	根据机器人配置创建动态的ZhiPuAiChatModel
private org.springframework.ai.zhipuai.ZhiPuAiChatOptions	createDynamicOptions(RobotLlm llm)	根据机器人配置创建动态的ZhiPuAiChatOptions
Boolean	isServiceHealthy()
protected void	processPromptSse(org.springframework.ai.chat.prompt.Prompt prompt, RobotProtobuf robot, MessageProtobuf messageProtobufQuery, MessageProtobuf messageProtobufReply, org.springframework.web.servlet.mvc.method.annotation.SseEmitter emitter)	方式3：SSE方式调用
protected String	processPromptSync(String message, RobotProtobuf robot)	方式2：同步调用
protected void	processPromptWebsocket(org.springframework.ai.chat.prompt.Prompt prompt, RobotProtobuf robot, MessageProtobuf messageProtobufQuery, MessageProtobuf messageProtobufReply)	方式1：异步流式调用

Methods inherited from class com.bytedesk.ai.springai.service.BaseSpringAIService

createDynamicOptions, extractTextFromResponse, handleSseError, isEmitterCompleted, persistMessage, processDirectLlmRequest, processLlmResponseWebsocket, searchKnowledgeBase, sendMessageWebsocket, sendSseMessage, sendStreamEndMessage, sendStreamMessage, sendStreamStartMessage, sendSyncMessage, sendWebsocketMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

bytedeskZhipuaiChatModel

@Autowired
@Qualifier("bytedeskZhipuaiChatModel")
private org.springframework.ai.zhipuai.ZhiPuAiChatModel bytedeskZhipuaiChatModel

zhipuaiApi

@Autowired
@Qualifier("bytedeskZhipuaiApi")
private org.springframework.ai.zhipuai.api.ZhiPuAiApi zhipuaiApi

Constructor Details

SpringAIZhipuaiService

public SpringAIZhipuaiService()

Method Details

createDynamicOptions

private org.springframework.ai.zhipuai.ZhiPuAiChatOptions createDynamicOptions(RobotLlm llm)

根据机器人配置创建动态的ZhiPuAiChatOptions

Parameters:

llm - 机器人LLM配置

Returns:

根据机器人配置创建的选项

createDynamicChatModel

private org.springframework.ai.zhipuai.ZhiPuAiChatModel createDynamicChatModel(RobotLlm llm)

根据机器人配置创建动态的ZhiPuAiChatModel

Parameters:

llm - 机器人LLM配置

Returns:

配置了特定模型的ZhiPuAiChatModel

processPromptWebsocket

protected void processPromptWebsocket(org.springframework.ai.chat.prompt.Prompt prompt,
 RobotProtobuf robot,
 MessageProtobuf messageProtobufQuery,
 MessageProtobuf messageProtobufReply)

方式1：异步流式调用

Specified by:

processPromptWebsocket in class BaseSpringAIService

processPromptSync

protected String processPromptSync(String message,
 RobotProtobuf robot)

方式2：同步调用

Specified by:

processPromptSync in class BaseSpringAIService

processPromptSse

protected void processPromptSse(org.springframework.ai.chat.prompt.Prompt prompt,
 RobotProtobuf robot,
 MessageProtobuf messageProtobufQuery,
 MessageProtobuf messageProtobufReply,
 org.springframework.web.servlet.mvc.method.annotation.SseEmitter emitter)

方式3：SSE方式调用

Specified by:

processPromptSse in class BaseSpringAIService

isServiceHealthy

public Boolean isServiceHealthy()