Package com.bytedesk.service.thread_transfer

Class ThreadTransferService

java.lang.Object

com.bytedesk.service.thread_transfer.ThreadTransferService

@Service
public class ThreadTransferService
extends Object

会话转接业务服务类 负责处理会话转接的核心业务逻辑

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ThreadTransferService.TransferAcceptContext	转接接受上下文

Field Summary

Fields

Modifier and Type	Field	Description
private final AgentRestService	agentRestService
private final org.modelmapper.ModelMapper	modelMapper
private final NoticeService	noticeService
private final ThreadRestService	threadRestService
private final ThreadTransferTimeoutService	timeoutService
private final TopicCacheService	topicCacheService
private final TopicRestService	topicRestService
private final ThreadTransferRepository	transferRepository
private final UidUtils	uidUtils
private final UserRestService	userRestService

Constructor Summary

Constructors

Constructor	Description
ThreadTransferService()

Method Summary

Modifier and Type	Method	Description
ThreadTransferEntity	accept(ThreadTransferRequest request)	接受转接请求
private ThreadTransferEntity	buildTransferEntity(ThreadTransferRequest request, UserEntity user)	构建转接实体
ThreadTransferEntity	cancel(ThreadTransferRequest request)	取消转接请求
ThreadTransferEntity	create(ThreadTransferRequest request, UserEntity user)	创建转接请求
private ThreadTransferEntity	getAndValidateTransferEntity(String uid)	获取并验证转接实体
private NoticeRequest	getNoticeRequestByStatus(MessageStatusEnum status, String extra, String receiverUserUid, String orgUid)	根据状态获取通知请求
private String	getReceiverUserUid(UserProtobuf receiver)	获取接收者用户UID
private ThreadTransferService.TransferAcceptContext	processTransferAccept(ThreadTransferRequest request, ThreadTransferEntity transferEntity)	处理转接接受的业务逻辑
ThreadTransferEntity	reject(ThreadTransferRequest request)	拒绝转接请求
void	sendNotificationForCreate(ThreadTransferEntity transferEntity, String receiverUserUid, String orgUid)	发送创建转接的通知
private void	sendTransferNotification(ThreadTransferEntity transferEntity, MessageStatusEnum status, String receiverUserUid, String orgUid)	发送转接通知
ThreadTransferEntity	timeout(ThreadTransferRequest request)	转接超时处理
private ThreadEntity	updateThreadStatus(ThreadTransferEntity transferEntity, ThreadTransferStatusEnum status)	更新会话转接状态
private void	updateThreadTransferStatus(ThreadEntity threadEntity, ThreadTransferStatusEnum status)	更新会话转接状态
private ThreadEntity	validateThreadOwnership(String threadUid, String userUid)	验证会话所有权
private void	validateTransferState(ThreadTransferEntity transferEntity)	验证转接状态，确保可以进行状态变更

Methods inherited from class java.lang.Object

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

Field Details

transferRepository

private final ThreadTransferRepository transferRepository

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

noticeService

private final NoticeService noticeService

agentRestService

private final AgentRestService agentRestService

topicRestService

private final TopicRestService topicRestService

threadRestService

private final ThreadRestService threadRestService

userRestService

private final UserRestService userRestService

topicCacheService

private final TopicCacheService topicCacheService

timeoutService

private final ThreadTransferTimeoutService timeoutService

Constructor Details

ThreadTransferService

public ThreadTransferService()

Method Details

create

@Transactional
public ThreadTransferEntity create(ThreadTransferRequest request,
 UserEntity user)

创建转接请求

accept

@Transactional
public ThreadTransferEntity accept(ThreadTransferRequest request)

接受转接请求

reject

@Transactional
public ThreadTransferEntity reject(ThreadTransferRequest request)

拒绝转接请求

cancel

@Transactional
public ThreadTransferEntity cancel(ThreadTransferRequest request)

取消转接请求

timeout

@Transactional
public ThreadTransferEntity timeout(ThreadTransferRequest request)

转接超时处理

sendNotificationForCreate

public void sendNotificationForCreate(ThreadTransferEntity transferEntity,
 String receiverUserUid,
 String orgUid)

发送创建转接的通知

getAndValidateTransferEntity

private ThreadTransferEntity getAndValidateTransferEntity(String uid)

获取并验证转接实体

validateTransferState

private void validateTransferState(ThreadTransferEntity transferEntity)

验证转接状态，确保可以进行状态变更

updateThreadStatus

private ThreadEntity updateThreadStatus(ThreadTransferEntity transferEntity,
 ThreadTransferStatusEnum status)

更新会话转接状态

getReceiverUserUid

private String getReceiverUserUid(UserProtobuf receiver)

获取接收者用户UID

sendTransferNotification

private void sendTransferNotification(ThreadTransferEntity transferEntity,
 MessageStatusEnum status,
 String receiverUserUid,
 String orgUid)

发送转接通知

getNoticeRequestByStatus

private NoticeRequest getNoticeRequestByStatus(MessageStatusEnum status,
 String extra,
 String receiverUserUid,
 String orgUid)

根据状态获取通知请求

processTransferAccept

private ThreadTransferService.TransferAcceptContext processTransferAccept(ThreadTransferRequest request,
 ThreadTransferEntity transferEntity)

处理转接接受的业务逻辑

validateThreadOwnership

private ThreadEntity validateThreadOwnership(String threadUid,
 String userUid)

验证会话所有权

buildTransferEntity

private ThreadTransferEntity buildTransferEntity(ThreadTransferRequest request,
 UserEntity user)

构建转接实体

updateThreadTransferStatus

private void updateThreadTransferStatus(ThreadEntity threadEntity,
 ThreadTransferStatusEnum status)

更新会话转接状态