Package com.bytedesk.service.queue

Class QueueService

java.lang.Object

com.bytedesk.service.queue.QueueService

@Service
public class QueueService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	QueueService.AgentQueuingCount	客服排队人数统计结果

Field Summary

Fields

Modifier and Type	Field	Description
private final QueueMemberRestService	queueMemberRestService
private final QueueRepository	queueRepository
private final UidUtils	uidUtils
private final WorkgroupRepository	workgroupRepository

Constructor Summary

Constructors

Constructor	Description
QueueService()

Method Summary

Modifier and Type	Method	Description
private QueueMemberEntity	createNewQueueMember(ThreadEntity threadEntity, UserProtobuf agent, WorkgroupEntity workgroupEntity, QueueTypeEnum queueType)	创建新的队列成员
private QueueEntity	createQueueEntity(String queueTopic, String nickname, String type, String day, String orgUid)
QueueMemberEntity	enqueueAgent(ThreadEntity threadEntity, UserProtobuf agent, VisitorRequest visitorRequest)
QueueMemberEntity	enqueueRobot(ThreadEntity threadEntity, UserProtobuf agent, VisitorRequest visitorRequest)
private QueueMemberEntity	enqueueToQueue(ThreadEntity threadEntity, UserProtobuf agent, WorkgroupEntity workgroupEntity, QueueTypeEnum queueType)	统一的入队方法
QueueMemberEntity	enqueueWorkflow(ThreadEntity threadEntity, UserProtobuf workflow, VisitorRequest visitorRequest)
QueueMemberEntity	enqueueWorkgroup(ThreadEntity threadEntity, UserProtobuf agent, WorkgroupEntity workgroupEntity, VisitorRequest visitorRequest)
Optional<QueueEntity>	findByTopicAndDay(String queueTopic, String day)	根据队列主题和日期查询队列
private QueueEntity	getAgentOrRobotQueue(UserProtobuf agent, String orgUid)	根据用户获取或创建 agent/robot 队列
AgentQueueStatsResponse	getAgentQueueStats(String agentUid)	获取客服的完整队列统计信息 包括今日服务人数、排队人数、接待人数、留言数、转人工数等
QueueService.AgentQueuingCount	getAgentTotalQueuingCount(String agentUid)	获取客服的完整排队人数统计 包括： 1.
private QueueEntity	getOrCreateQueue(String queueTopic, String nickname, String type, String orgUid)	通用的队列获取或创建方法
private QueueEntity	getQueue(ThreadEntity threadEntity, String queueNickname)	根据线程实体获取或创建队列
private QueueMemberEntity	handleExistingMember(QueueMemberEntity member, UserProtobuf agent, ThreadEntity threadEntity, QueueTypeEnum queueType)	处理已存在的队列成员
private <T> T	retryOperation(Supplier<T> operation)	重试操作的通用方法
private QueueMemberEntity	saveQueueMember(QueueMemberEntity member)	保存队列成员并验证结果
private void	validateQueue(QueueEntity queue, String errorMessage)	验证队列是否可以入队

Methods inherited from class java.lang.Object

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

Field Details

queueMemberRestService

private final QueueMemberRestService queueMemberRestService

queueRepository

private final QueueRepository queueRepository

workgroupRepository

private final WorkgroupRepository workgroupRepository

uidUtils

private final UidUtils uidUtils

Constructor Details

QueueService

public QueueService()

Method Details

enqueueRobot

@Transactional
public QueueMemberEntity enqueueRobot(ThreadEntity threadEntity,
 UserProtobuf agent,
 VisitorRequest visitorRequest)

enqueueAgent

@Transactional
public QueueMemberEntity enqueueAgent(ThreadEntity threadEntity,
 UserProtobuf agent,
 VisitorRequest visitorRequest)

enqueueWorkgroup

@Transactional
public QueueMemberEntity enqueueWorkgroup(ThreadEntity threadEntity,
 UserProtobuf agent,
 WorkgroupEntity workgroupEntity,
 VisitorRequest visitorRequest)

enqueueWorkflow

@Transactional
public QueueMemberEntity enqueueWorkflow(ThreadEntity threadEntity,
 UserProtobuf workflow,
 VisitorRequest visitorRequest)

enqueueToQueue

@Transactional
private QueueMemberEntity enqueueToQueue(ThreadEntity threadEntity,
 UserProtobuf agent,
 WorkgroupEntity workgroupEntity,
 QueueTypeEnum queueType)

统一的入队方法

handleExistingMember

private QueueMemberEntity handleExistingMember(QueueMemberEntity member,
 UserProtobuf agent,
 ThreadEntity threadEntity,
 QueueTypeEnum queueType)

处理已存在的队列成员

createNewQueueMember

private QueueMemberEntity createNewQueueMember(ThreadEntity threadEntity,
 UserProtobuf agent,
 WorkgroupEntity workgroupEntity,
 QueueTypeEnum queueType)

创建新的队列成员

getQueue

@Transactional
private QueueEntity getQueue(ThreadEntity threadEntity,
 String queueNickname)

根据线程实体获取或创建队列

getAgentOrRobotQueue

@Transactional
private QueueEntity getAgentOrRobotQueue(UserProtobuf agent,
 String orgUid)

根据用户获取或创建 agent/robot 队列

getOrCreateQueue

@Transactional
private QueueEntity getOrCreateQueue(String queueTopic,
 String nickname,
 String type,
 String orgUid)

通用的队列获取或创建方法

findByTopicAndDay

public Optional<QueueEntity> findByTopicAndDay(String queueTopic,
 String day)

根据队列主题和日期查询队列

Parameters:

queueTopic - 队列主题

day - 日期（格式：yyyy-MM-dd）

Returns:

队列实体（可选）

createQueueEntity

private QueueEntity createQueueEntity(String queueTopic,
 String nickname,
 String type,
 String day,
 String orgUid)

saveQueueMember

private QueueMemberEntity saveQueueMember(QueueMemberEntity member)

保存队列成员并验证结果

validateQueue

private void validateQueue(QueueEntity queue,
 String errorMessage)

验证队列是否可以入队

retryOperation

private <T> T retryOperation(Supplier<T> operation)

重试操作的通用方法

getAgentTotalQueuingCount

public QueueService.AgentQueuingCount getAgentTotalQueuingCount(String agentUid)

获取客服的完整排队人数统计 包括： 1. 直接在客服队列（agentQueue）中排队的人数（一对一会话） 2. 客服所在工作组队列中等待分配的排队人数（工作组会话，agentQueue 为 null）

Parameters:

agentUid - 客服UID

Returns:

完整排队人数统计结果

getAgentQueueStats

public AgentQueueStatsResponse getAgentQueueStats(String agentUid)

获取客服的完整队列统计信息 包括今日服务人数、排队人数、接待人数、留言数、转人工数等

Parameters:

agentUid - 客服UID

Returns:

完整队列统计响应