Package com.bytedesk.service.routing_strategy

Class AgentThreadRoutingStrategy

java.lang.Object

com.bytedesk.service.routing_strategy.AbstractThreadRoutingStrategy

com.bytedesk.service.routing_strategy.AgentThreadRoutingStrategy

@Component("agentThreadStrategy")
public class AgentThreadRoutingStrategy
extends AbstractThreadRoutingStrategy

客服线程路由策略 负责处理一对一人工客服的线程创建和路由逻辑

Author:

jackning 270580156@qq.com

Field Summary

Fields

Modifier and Type	Field	Description
private final AgentRestService	agentRestService
private final BytedeskEventPublisher	bytedeskEventPublisher
private final MessageRestService	messageRestService
private final IMessageSendService	messageSendService
private final QueueMemberRestService	queueMemberRestService
private final QueueService	queueService
private final ThreadRestService	threadRestService
private final VisitorThreadService	visitorThreadService

Fields inherited from class com.bytedesk.service.routing_strategy.AbstractThreadRoutingStrategy

DEFAULT_OFFLINE_MESSAGE, DEFAULT_WELCOME_MESSAGE, ESTIMATED_WAIT_TIME_PER_PERSON, MESSAGE_CACHE_MINUTES, QUEUE_NEXT_MESSAGE, QUEUE_WAITING_MESSAGE_TEMPLATE

Constructor Summary

Constructors

Constructor	Description
AgentThreadRoutingStrategy()

Method Summary

Modifier and Type	Method	Description
MessageProtobuf	createAgentThread(VisitorRequest visitorRequest)	创建客服线程 一对一人工客服，不支持机器人接待
MessageProtobuf	createThread(VisitorRequest visitorRequest)	创建线程的核心方法 由具体实现类负责处理不同类型的线程创建逻辑
private String	generateAgentQueueMessage(QueueMemberEntity queueMemberEntity)	生成客服排队消息
private MessageProtobuf	getAgentContinueMessage(ThreadEntity thread)	获取客服继续对话消息
private AgentEntity	getAgentEntity(String agentUid)	获取客服实体
private String	getAgentOfflineMessage(AgentEntity agent)	获取客服离线消息
private MessageProtobuf	getAgentQueuingMessage(ThreadEntity thread)	获取客服排队消息
private String	getAgentWelcomeMessage(AgentEntity agent)	获取客服欢迎消息
private ThreadEntity	getOrCreateThread(VisitorRequest visitorRequest, AgentEntity agentEntity, String topic)	获取或创建线程
protected ThreadRestService	getThreadRestService()	获取线程服务实例 由具体实现类提供
private MessageProtobuf	handleAvailableAgent(ThreadEntity threadFromRequest, AgentEntity agent, QueueMemberEntity queueMemberEntity)	处理可用客服（客服在线且未达到最大接待人数）
private MessageProtobuf	handleExistingThread(ThreadEntity thread, AgentEntity agentEntity)	处理已存在的线程
private MessageProtobuf	handleOfflineAgent(ThreadEntity threadFromRequest, AgentEntity agent, QueueMemberEntity queueMemberEntity)	处理离线客服
private MessageProtobuf	handleQueuedAgent(ThreadEntity threadFromRequest, AgentEntity agent, QueueMemberEntity queueMemberEntity)	处理排队客服（客服在线但已达到最大接待人数）
private boolean	isExistingActiveThread(ThreadEntity thread)	检查是否为已存在的活跃线程
private void	publishThreadEvents(ThreadEntity savedThread)	发布线程相关事件
private MessageProtobuf	routeNewThread(ThreadEntity thread, AgentEntity agentEntity, VisitorRequest visitorRequest)	路由新线程
private MessageProtobuf	routeOnlineAgent(ThreadEntity thread, AgentEntity agentEntity, QueueMemberEntity queueMemberEntity)	路由在线客服
private void	updateQueueMemberForAcceptance(QueueMemberEntity queueMemberEntity)	更新队列成员接受状态

Methods inherited from class com.bytedesk.service.routing_strategy.AbstractThreadRoutingStrategy

executeWithExceptionHandling, generateQueueMessage, getThreadByUid, getValidOfflineMessage, getValidWelcomeMessage, handleStrategyException, isActiveThread, isClosedThread, isMessageInCacheTime, isNewThread, logThreadStatusChange, saveThread, validateThread, validateUid

Methods inherited from class java.lang.Object

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

Field Details

agentRestService

private final AgentRestService agentRestService

threadRestService

private final ThreadRestService threadRestService

visitorThreadService

private final VisitorThreadService visitorThreadService

messageSendService

private final IMessageSendService messageSendService

queueService

private final QueueService queueService

queueMemberRestService

private final QueueMemberRestService queueMemberRestService

messageRestService

private final MessageRestService messageRestService

bytedeskEventPublisher

private final BytedeskEventPublisher bytedeskEventPublisher

Constructor Details

AgentThreadRoutingStrategy

public AgentThreadRoutingStrategy()

Method Details

getThreadRestService

protected ThreadRestService getThreadRestService()

Description copied from class: AbstractThreadRoutingStrategy

获取线程服务实例 由具体实现类提供

Specified by:

getThreadRestService in class AbstractThreadRoutingStrategy

Returns:

ThreadRestService实例

createThread

public MessageProtobuf createThread(VisitorRequest visitorRequest)

Description copied from class: AbstractThreadRoutingStrategy

创建线程的核心方法 由具体实现类负责处理不同类型的线程创建逻辑

Specified by:

createThread in class AbstractThreadRoutingStrategy

Parameters:

visitorRequest - 访客请求信息

Returns:

消息协议对象

createAgentThread

public MessageProtobuf createAgentThread(VisitorRequest visitorRequest)

创建客服线程 一对一人工客服，不支持机器人接待

getOrCreateThread

private ThreadEntity getOrCreateThread(VisitorRequest visitorRequest,
 AgentEntity agentEntity,
 String topic)

获取或创建线程

isExistingActiveThread

private boolean isExistingActiveThread(ThreadEntity thread)

检查是否为已存在的活跃线程

handleExistingThread

private MessageProtobuf handleExistingThread(ThreadEntity thread,
 AgentEntity agentEntity)

处理已存在的线程

routeNewThread

private MessageProtobuf routeNewThread(ThreadEntity thread,
 AgentEntity agentEntity,
 VisitorRequest visitorRequest)

路由新线程

routeOnlineAgent

private MessageProtobuf routeOnlineAgent(ThreadEntity thread,
 AgentEntity agentEntity,
 QueueMemberEntity queueMemberEntity)

路由在线客服

handleAvailableAgent

private MessageProtobuf handleAvailableAgent(ThreadEntity threadFromRequest,
 AgentEntity agent,
 QueueMemberEntity queueMemberEntity)

处理可用客服（客服在线且未达到最大接待人数）

handleQueuedAgent

private MessageProtobuf handleQueuedAgent(ThreadEntity threadFromRequest,
 AgentEntity agent,
 QueueMemberEntity queueMemberEntity)

处理排队客服（客服在线但已达到最大接待人数）

handleOfflineAgent

private MessageProtobuf handleOfflineAgent(ThreadEntity threadFromRequest,
 AgentEntity agent,
 QueueMemberEntity queueMemberEntity)

处理离线客服

getAgentEntity

private AgentEntity getAgentEntity(String agentUid)

获取客服实体

getAgentWelcomeMessage

private String getAgentWelcomeMessage(AgentEntity agent)

获取客服欢迎消息

getAgentOfflineMessage

private String getAgentOfflineMessage(AgentEntity agent)

获取客服离线消息

generateAgentQueueMessage

private String generateAgentQueueMessage(QueueMemberEntity queueMemberEntity)

生成客服排队消息

updateQueueMemberForAcceptance

private void updateQueueMemberForAcceptance(QueueMemberEntity queueMemberEntity)

更新队列成员接受状态

publishThreadEvents

private void publishThreadEvents(ThreadEntity savedThread)

发布线程相关事件

getAgentContinueMessage

private MessageProtobuf getAgentContinueMessage(ThreadEntity thread)

获取客服继续对话消息

getAgentQueuingMessage

private MessageProtobuf getAgentQueuingMessage(ThreadEntity thread)

获取客服排队消息