Package com.bytedesk.service.queue_member

Class QueueMemberAiRestService

java.lang.Object

com.bytedesk.service.queue_member.QueueMemberAiRestService

@Service
public class QueueMemberAiRestService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	AI_THREAD_CONTEXT_MAX_CHARS
private static final int	AI_THREAD_CONTEXT_MAX_MESSAGES
private final MessageRestService	messageRestService
private final com.fasterxml.jackson.databind.ObjectMapper	objectMapper
private final QueueMemberRepository	queueMemberRepository
private final RobotAgentService	robotAgentService
private final ThreadEmotionRestService	threadEmotionRestService
private final ThreadIntentionRestService	threadIntentionRestService
private final ThreadSummaryRestService	threadSummaryRestService

Constructor Summary

Constructors

Constructor	Description
QueueMemberAiRestService()

Method Summary

Modifier and Type	Method	Description
QueueMemberResponse	autoEmotion(QueueMemberRequest request)
QueueMemberResponse	autoIntention(QueueMemberRequest request)
QueueMemberResponse	autoSummary(QueueMemberRequest request)
private String	buildThreadContent(String threadUid)
private ThreadEmotionRequest	buildThreadEmotionRequest(String json, String orgUid, String threadUid, QueueMemberEntity member)
private ThreadIntentionRequest	buildThreadIntentionRequest(String json, String orgUid, String threadUid, QueueMemberEntity member)
private ThreadSummaryRequest	buildThreadSummaryRequest(String json, String orgUid, String threadUid, QueueMemberEntity member)
private String	extractJsonObject(String text)	尽量从 LLM 输出中提取 JSON 对象（容错：前后可能夹杂说明文本）。
private <E extends Enum<E>> E	parseEnumSafe(String json, String fieldName, Class<E> enumClass, E defaultValue)
private QueueMemberEntity	resolveMember(QueueMemberRequest request)
private String	resolveOrgUid(QueueMemberRequest request)
private String	resolveThreadUid(QueueMemberEntity member)
private String	sanitizeLlmOutput(String raw)

Methods inherited from class java.lang.Object

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

Field Details

queueMemberRepository

private final QueueMemberRepository queueMemberRepository

messageRestService

private final MessageRestService messageRestService

robotAgentService

private final RobotAgentService robotAgentService

objectMapper

private final com.fasterxml.jackson.databind.ObjectMapper objectMapper

threadIntentionRestService

private final ThreadIntentionRestService threadIntentionRestService

threadEmotionRestService

private final ThreadEmotionRestService threadEmotionRestService

threadSummaryRestService

private final ThreadSummaryRestService threadSummaryRestService

AI_THREAD_CONTEXT_MAX_MESSAGES

private static final int AI_THREAD_CONTEXT_MAX_MESSAGES

See Also:

• Constant Field Values

AI_THREAD_CONTEXT_MAX_CHARS

private static final int AI_THREAD_CONTEXT_MAX_CHARS

See Also:

• Constant Field Values

Constructor Details

QueueMemberAiRestService

public QueueMemberAiRestService()

Method Details

autoIntention

public QueueMemberResponse autoIntention(QueueMemberRequest request)

autoEmotion

public QueueMemberResponse autoEmotion(QueueMemberRequest request)

autoSummary

public QueueMemberResponse autoSummary(QueueMemberRequest request)

resolveMember

private QueueMemberEntity resolveMember(QueueMemberRequest request)

resolveThreadUid

private String resolveThreadUid(QueueMemberEntity member)

resolveOrgUid

private String resolveOrgUid(QueueMemberRequest request)

buildThreadContent

private String buildThreadContent(String threadUid)

sanitizeLlmOutput

private String sanitizeLlmOutput(String raw)

extractJsonObject

private String extractJsonObject(String text)

尽量从 LLM 输出中提取 JSON 对象（容错：前后可能夹杂说明文本）。

buildThreadIntentionRequest

private ThreadIntentionRequest buildThreadIntentionRequest(String json,
 String orgUid,
 String threadUid,
 QueueMemberEntity member)

buildThreadEmotionRequest

private ThreadEmotionRequest buildThreadEmotionRequest(String json,
 String orgUid,
 String threadUid,
 QueueMemberEntity member)

buildThreadSummaryRequest

private ThreadSummaryRequest buildThreadSummaryRequest(String json,
 String orgUid,
 String threadUid,
 QueueMemberEntity member)

parseEnumSafe

private <E extends Enum<E>> E parseEnumSafe(String json,
 String fieldName,
 Class<E> enumClass,
 E defaultValue)