Package com.bytedesk.service.routing_strategy

Class WorkflowThreadRoutingStrategy

java.lang.Object

com.bytedesk.service.routing_strategy.AbstractThreadRoutingStrategy

com.bytedesk.service.routing_strategy.WorkflowThreadRoutingStrategy

@Component("workflowThreadStrategy")
public class WorkflowThreadRoutingStrategy
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 ThreadRestService	threadRestService
private final VisitorThreadService	visitorThreadService
private final WorkflowRestService	workflowRestService

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

ESTIMATED_WAIT_TIME_PER_PERSON, MESSAGE_CACHE_MINUTES

Constructor Summary

Constructors

Constructor	Description
WorkflowThreadRoutingStrategy()

Method Summary

Modifier and Type	Method	Description
private MessageProtobuf	createAndSaveWelcomeMessage(WelcomeContent wc, ThreadEntity thread)	创建并保存欢迎消息
MessageProtobuf	createThread(VisitorRequest visitorRequest)	创建线程的核心方法 由具体实现类负责处理不同类型的线程创建逻辑
MessageProtobuf	createWorkflowThread(VisitorRequest request)	创建工作流会话
private ThreadEntity	getOrCreateWorkflowThread(VisitorRequest request, WorkflowEntity workflowEntity, String topic)	获取或创建工作流会话
protected ThreadRestService	getThreadRestService()	获取线程服务实例 由具体实现类提供
private MessageProtobuf	getWorkflowContinueMessage(WorkflowEntity workflowEntity, ThreadEntity thread)	获取工作流继续对话消息
private WorkflowEntity	getWorkflowEntity(String workflowUid)	获取工作流实体
private String	getWorkflowWelcomeMessage(WorkflowEntity workflowEntity)	获取工作流欢迎消息
private MessageProtobuf	handleExistingWorkflowThread(WorkflowEntity workflowEntity, ThreadEntity thread)	处理现有的工作流会话
private boolean	isExistingWorkflowThread(ThreadEntity thread)	检查是否为现有的工作流会话
private MessageProtobuf	processNewWorkflowThread(VisitorRequest request, ThreadEntity thread, WorkflowEntity workflowEntity)	处理新的工作流会话
private void	publishWorkflowThreadEvent(ThreadEntity savedThread)	发布工作流线程事件
private void	updateQueueMemberForWorkflow(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

workflowRestService

private final WorkflowRestService workflowRestService

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

WorkflowThreadRoutingStrategy

public WorkflowThreadRoutingStrategy()

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:

消息协议对象

createWorkflowThread

public MessageProtobuf createWorkflowThread(VisitorRequest request)

创建工作流会话

Parameters:

request - 访客请求

Returns:

消息协议对象

getWorkflowEntity

private WorkflowEntity getWorkflowEntity(String workflowUid)

获取工作流实体

getOrCreateWorkflowThread

private ThreadEntity getOrCreateWorkflowThread(VisitorRequest request,
 WorkflowEntity workflowEntity,
 String topic)

获取或创建工作流会话

isExistingWorkflowThread

private boolean isExistingWorkflowThread(ThreadEntity thread)

检查是否为现有的工作流会话

handleExistingWorkflowThread

private MessageProtobuf handleExistingWorkflowThread(WorkflowEntity workflowEntity,
 ThreadEntity thread)

处理现有的工作流会话

processNewWorkflowThread

private MessageProtobuf processNewWorkflowThread(VisitorRequest request,
 ThreadEntity thread,
 WorkflowEntity workflowEntity)

处理新的工作流会话

getWorkflowWelcomeMessage

private String getWorkflowWelcomeMessage(WorkflowEntity workflowEntity)

获取工作流欢迎消息

updateQueueMemberForWorkflow

private void updateQueueMemberForWorkflow(QueueMemberEntity queueMemberEntity)

更新队列成员状态为工作流自动接受

publishWorkflowThreadEvent

private void publishWorkflowThreadEvent(ThreadEntity savedThread)

发布工作流线程事件

createAndSaveWelcomeMessage

private MessageProtobuf createAndSaveWelcomeMessage(WelcomeContent wc,
 ThreadEntity thread)

创建并保存欢迎消息

getWorkflowContinueMessage

private MessageProtobuf getWorkflowContinueMessage(WorkflowEntity workflowEntity,
 @Nonnull
 ThreadEntity thread)

获取工作流继续对话消息