Package com.bytedesk.ai.provider.vendors.zhipuai

Class ZhipuaiChatService

java.lang.Object

com.bytedesk.ai.provider.vendors.zhipuai.ZhipuaiChatService

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

@Service
@ConditionalOnProperty(name="spring.ai.zhipuai.chat.enabled",
                       havingValue="true")
public class ZhipuaiChatService
extends Object
implements org.springframework.beans.factory.DisposableBean

https://open.bigmodel.cn/dev/api#sdk_install https://github.com/MetaGLM/zhipuai-sdk-java-v4 https://docs.spring.io/spring-ai/reference/api/chat/zhipuai-chat.html https://open.bigmodel.cn/dev/api/normal-model/glm-4 https://github.com/spring-projects/spring-ai/blob/main/models/spring-ai-zhipuai/src/main/java/org/springframework/ai/zhipuai/api/ZhiPuAiApi.java

Field Summary

Fields

Modifier and Type	Field	Description
private final IMessageSendService	messageSendService
private final MessageRestService	messageService
private final org.modelmapper.ModelMapper	modelMapper
private final String	PROMPT_BLUEPRINT
private final String	PROMPT_QA_TEMPLATE
private final String	PROMPT_TEMPLATE
private final SpringAIVectorService	springAIVectorService
private final SpringAIZhipuaiConfig	springAiZhipuaiConfig
private final ThreadRestService	threadService
private final UidUtils	uidUtils
private final com.zhipu.oapi.ClientV4	zhipuaiClient

Constructor Summary

Constructors

Constructor	Description
ZhipuaiChatService()

Method Summary

Modifier and Type	Method	Description
void	destroy()
String	generateFaqPairsAsync(String chunk)
void	generateFaqPairsSync(String chunk)
void	getSseAnswer(String uid, String sid, String question, org.springframework.web.servlet.mvc.method.annotation.SseEmitter emitter)	sse调用
static io.reactivex.Flowable<com.zhipu.oapi.service.v4.model.ChatMessageAccumulator>	mapStreamToAccumulator(io.reactivex.Flowable<com.zhipu.oapi.service.v4.model.ModelData> flowable)
void	sendWsKbAutoReply(String query, String kbUid, MessageProtobuf messageProtobuf)
void	sendWsKbMessage(String query, RobotEntity robot, MessageProtobuf messageProtobuf)
void	sendWsMessage(String query, RobotLlm robotLlm, MessageProtobuf messageProtobuf)	websocket 发送消息 LLM 聊天

Methods inherited from class java.lang.Object

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

Field Details

springAiZhipuaiConfig

private final SpringAIZhipuaiConfig springAiZhipuaiConfig

zhipuaiClient

private final com.zhipu.oapi.ClientV4 zhipuaiClient

uidUtils

private final UidUtils uidUtils

threadService

private final ThreadRestService threadService

modelMapper

private final org.modelmapper.ModelMapper modelMapper

messageService

private final MessageRestService messageService

springAIVectorService

private final SpringAIVectorService springAIVectorService

messageSendService

private final IMessageSendService messageSendService

PROMPT_BLUEPRINT

private final String PROMPT_BLUEPRINT

See Also:

• Constant Field Values

PROMPT_TEMPLATE

private final String PROMPT_TEMPLATE

See Also:

• Constant Field Values

PROMPT_QA_TEMPLATE

private final String PROMPT_QA_TEMPLATE

See Also:

• Constant Field Values

Constructor Details

ZhipuaiChatService

public ZhipuaiChatService()

Method Details

sendWsKbMessage

public void sendWsKbMessage(String query,
 RobotEntity robot,
 MessageProtobuf messageProtobuf)

sendWsKbAutoReply

public void sendWsKbAutoReply(String query,
 String kbUid,
 MessageProtobuf messageProtobuf)

generateFaqPairsAsync

public String generateFaqPairsAsync(String chunk)

generateFaqPairsSync

public void generateFaqPairsSync(String chunk)

getSseAnswer

public void getSseAnswer(String uid,
 String sid,
 String question,
 org.springframework.web.servlet.mvc.method.annotation.SseEmitter emitter)

sse调用

sendWsMessage

public void sendWsMessage(String query,
 RobotLlm robotLlm,
 MessageProtobuf messageProtobuf)

websocket 发送消息 LLM 聊天

mapStreamToAccumulator

public static io.reactivex.Flowable<com.zhipu.oapi.service.v4.model.ChatMessageAccumulator> mapStreamToAccumulator(io.reactivex.Flowable<com.zhipu.oapi.service.v4.model.ModelData> flowable)

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception