Package com.bytedesk.service.routing_strategy

Class RobotThreadRoutingStrategy

java.lang.Object

com.bytedesk.service.routing_strategy.AbstractThreadRoutingStrategy

com.bytedesk.service.routing_strategy.RobotThreadRoutingStrategy

@Component("robotThreadStrategy")
public class RobotThreadRoutingStrategy
extends AbstractThreadRoutingStrategy

机器人线程路由策略

功能特点： - 纯机器人接待，不支持转人工 - 自动创建和管理机器人会话 - 支持会话复用和重新初始化

处理流程： 1. 验证机器人配置 2. 检查现有会话 3. 创建或复用会话 4. 发送欢迎消息

Since:

1.0.0

Author:

jackning 270580156@qq.com

Field Summary

Fields

Modifier and Type	Field	Description
private final org.springframework.context.ApplicationEventPublisher	applicationEventPublisher
private final MessageRestService	messageRestService
private final QueueMemberRestService	queueMemberRestService
private final QueueService	queueService
private final RobotRestService	robotRestService
private final ThreadRestService	threadRestService
private final VisitorThreadService	visitorThreadService

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

ESTIMATED_WAIT_TIME_PER_PERSON, MESSAGE_CACHE_MINUTES

Constructor Summary

Constructors

Constructor	Description
RobotThreadRoutingStrategy()

Method Summary

Modifier and Type	Method	Description
private MessageProtobuf	createAndSaveWelcomeMessage(WelcomeContent wc, ThreadEntity thread)	创建并保存欢迎消息
MessageProtobuf	createRobotThread(VisitorRequest request)	创建机器人会话
MessageProtobuf	createThread(VisitorRequest visitorRequest)	创建线程的核心方法 由具体实现类负责处理不同类型的线程创建逻辑
private ThreadEntity	getOrCreateRobotThread(VisitorRequest request, RobotEntity robotEntity, String topic)	获取或创建机器人会话
private MessageProtobuf	getRobotContinueMessage(VisitorRequest request, RobotEntity robotEntity, ThreadEntity thread)	获取机器人继续对话消息
private RobotEntity	getRobotEntity(String robotUid)	获取机器人实体
private String	getRobotWelcomeMessage(VisitorRequest visitorRequest, RobotEntity robotEntity)
protected ThreadRestService	getThreadRestService()	获取线程服务实例 由具体实现类提供
private MessageProtobuf	handleExistingRobotThread(VisitorRequest request, RobotEntity robotEntity, ThreadEntity thread)	处理现有的机器人会话
private boolean	isDraftEnabled(VisitorRequest visitorRequest)	获取机器人欢迎消息
private boolean	isExistingRobotThread(ThreadEntity thread)	检查是否为现有的机器人会话
private MessageProtobuf	processNewRobotThread(VisitorRequest request, ThreadEntity thread, RobotEntity robotEntity)	处理新的机器人会话
private void	publishRobotThreadEvent(ThreadEntity savedThread)	发布机器人线程事件
private void	updateQueueMemberForRobot(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

robotRestService

private final RobotRestService robotRestService

threadRestService

private final ThreadRestService threadRestService

visitorThreadService

private final VisitorThreadService visitorThreadService

queueService

private final QueueService queueService

queueMemberRestService

private final QueueMemberRestService queueMemberRestService

applicationEventPublisher

private final org.springframework.context.ApplicationEventPublisher applicationEventPublisher

messageRestService

private final MessageRestService messageRestService

Constructor Details

RobotThreadRoutingStrategy

public RobotThreadRoutingStrategy()

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:

消息协议对象

createRobotThread

public MessageProtobuf createRobotThread(VisitorRequest request)

创建机器人会话

Parameters:

request - 访客请求

Returns:

消息协议对象

getRobotEntity

private RobotEntity getRobotEntity(String robotUid)

获取机器人实体

getOrCreateRobotThread

private ThreadEntity getOrCreateRobotThread(VisitorRequest request,
 RobotEntity robotEntity,
 String topic)

获取或创建机器人会话

isExistingRobotThread

private boolean isExistingRobotThread(ThreadEntity thread)

检查是否为现有的机器人会话

handleExistingRobotThread

private MessageProtobuf handleExistingRobotThread(VisitorRequest request,
 RobotEntity robotEntity,
 ThreadEntity thread)

处理现有的机器人会话

processNewRobotThread

private MessageProtobuf processNewRobotThread(VisitorRequest request,
 ThreadEntity thread,
 RobotEntity robotEntity)

处理新的机器人会话

isDraftEnabled

private boolean isDraftEnabled(VisitorRequest visitorRequest)

获取机器人欢迎消息

getRobotWelcomeMessage

private String getRobotWelcomeMessage(VisitorRequest visitorRequest,
 RobotEntity robotEntity)

updateQueueMemberForRobot

private void updateQueueMemberForRobot(QueueMemberEntity queueMemberEntity)

更新队列成员状态为机器人自动接受

publishRobotThreadEvent

private void publishRobotThreadEvent(ThreadEntity savedThread)

发布机器人线程事件

createAndSaveWelcomeMessage

private MessageProtobuf createAndSaveWelcomeMessage(WelcomeContent wc,
 ThreadEntity thread)

创建并保存欢迎消息

getRobotContinueMessage

private MessageProtobuf getRobotContinueMessage(VisitorRequest request,
 RobotEntity robotEntity,
 @Nonnull
 ThreadEntity thread)

获取机器人继续对话消息