Package com.bytedesk.service.visitor_thread

Class VisitorThreadService

java.lang.Object

com.bytedesk.core.base.BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

com.bytedesk.service.visitor_thread.VisitorThreadService

@Service
public class VisitorThreadService
extends BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final AgentRestService	agentRestService
private final AgentSettingsRestService	agentSettingsRestService
private final MessageRestService	messageRestService
private final IMessageSendService	messageSendService
private final org.modelmapper.ModelMapper	modelMapper
private final QueueMemberRestService	queueMemberRestService
private final RobotSettingsRestService	robotSettingsRestService
private final ThreadRestService	threadRestService
private final UidUtils	uidUtils
private final VisitorThreadRepository	visitorThreadRepository
private final WorkgroupRestService	workgroupRestService
private final WorkgroupSettingsRestService	workgroupSettingsRestService

Fields inherited from class com.bytedesk.core.base.BaseRestService

authService

Constructor Summary

Constructors

Constructor	Description
VisitorThreadService()

Method Summary

Modifier and Type	Method	Description
void	autoRemindAgentOrCloseThread(List<ThreadEntity> threads)	自动提醒客服或关闭会话
private String	buildAgentExtra(VisitorRequest visitorRequest, AgentEntity agent)	根据请求与客服实体构建 thread.extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览
private String	buildRobotExtra(VisitorRequest visitorRequest, RobotEntity robot)	根据请求与机器人实体构建 thread.extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览
private String	buildWorkflowExtra(VisitorRequest visitorRequest, WorkflowEntity workflow)	根据请求与工作流实体构建 thread.extra - 工作流暂时不支持 debug 预览
private String	buildWorkgroupExtra(VisitorRequest visitorRequest, WorkgroupEntity workgroup)	根据请求与工作组实体构建 thread.extra - 社交渠道：直接使用请求中的 extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览
private long	calculateThreadTimeoutMinutes(ThreadEntity thread)	计算线程超时分钟数
boolean	consumeVisitorNoResponseTriggerPermit(String threadUid, int noResponseTimeoutSeconds)	主动触发：判断“访客长时间未发送消息”是否达到阈值，并用 QueueMember.lastNotifiedAt 做节流。
VisitorThreadResponse	convertToResponse(VisitorThreadEntity entity)
VisitorThreadResponse	create(VisitorThreadRequest request)
ThreadEntity	createAgentThread(VisitorRequest visitorRequest, AgentEntity agent, String topic)
ThreadEntity	createRobotThread(VisitorRequest visitorRequest, RobotEntity robot, String topic)
protected org.springframework.data.jpa.domain.Specification<VisitorThreadEntity>	createSpecification(VisitorThreadRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
ThreadEntity	createWorkflowThread(VisitorRequest visitorRequest, WorkflowEntity workflow, String topic)
ThreadEntity	createWorkgroupThread(VisitorRequest visitorRequest, WorkgroupEntity workgroup, String topic)
void	delete(VisitorThreadRequest entity)
void	deleteByUid(String uid)
protected VisitorThreadEntity	doSave(VisitorThreadEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<VisitorThreadEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<VisitorThreadEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
Boolean	existsByUid(String uid)
Optional<VisitorThreadEntity>	findByUid(String uid)
Optional<VisitorThreadEntity>	findFirstByTopic(String topic)
private double	getAutoCloseMinutes(ServiceSettingsResponseVisitor settings)	获取自动关闭分钟数
private void	handleAutoClose(ThreadEntity thread, long diffInMinutes)	处理自动关闭逻辑
VisitorThreadEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, VisitorThreadEntity entity)
MessageProtobuf	handleQueueOverflowLeaveMessage(ThreadEntity thread, QueueMemberEntity queueMember)
private boolean	handleQueueWaitTimeout(ThreadEntity thread)	处理排队等待超时逻辑
private void	handleTimeoutReminder(ThreadEntity thread, long diffInMinutes)	处理超时提醒逻辑
private ServiceSettingsResponseVisitor	parseThreadSettings(ThreadEntity thread)	解析线程设置
private void	processAgentTimeoutReminder(ThreadEntity thread, AgentEntity agent)	处理客服超时提醒
private void	processThreadTimeout(ThreadEntity thread)	处理单个Thread会话的超时逻辑
ThreadEntity	reInitAgentThreadExtra(VisitorRequest visitorRequest, ThreadEntity thread, AgentEntity agent)
ThreadEntity	reInitRobotThreadExtra(VisitorRequest visitorRequest, ThreadEntity thread, RobotEntity robot)
ThreadEntity	reInitWorkflowThreadExtra(VisitorRequest visitorRequest, ThreadEntity thread, WorkflowEntity workflow)
ThreadEntity	reInitWorkgroupThreadExtra(VisitorRequest visitorRequest, ThreadEntity thread, WorkgroupEntity workgroup)
private String	resolveLeaveMessageTip(ThreadEntity thread)
private String	resolveLeaveMessageTip(AgentEntity agent)
private String	resolveLeaveMessageTip(WorkgroupEntity workgroup)
private int	resolveQueueMaxWaitSeconds(QueueSettingsEntity queueSettings)
private QueueSettingsEntity	resolveQueueSettings(ThreadEntity thread)
private QueueSettingsEntity	resolveQueueSettingsFromAgent(AgentEntity agent)
private QueueSettingsEntity	resolveQueueSettingsFromWorkgroup(WorkgroupEntity workgroup)
private void	sendRemindMessage(QueueMemberEntity queueMember, ThreadEntity thread, AgentEntity agent)
private boolean	shouldSendTimeoutReminder(QueueMemberEntity queueMember)	判断是否应该发送超时提醒
private MessageProtobuf	triggerQueueLeaveMessage(ThreadEntity thread, QueueMemberEntity queueMember)
VisitorThreadEntity	update(ThreadEntity thread)
VisitorThreadResponse	update(VisitorThreadRequest request)

Methods inherited from class com.bytedesk.core.base.BaseRestService

deleteByOrgUid, findByOrgUid, getUidFromRequest, queryByOrg, queryByUid, queryByUser, recover, save, setUserUidToRequest

Methods inherited from class java.lang.Object

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

Field Details

visitorThreadRepository

private final VisitorThreadRepository visitorThreadRepository

threadRestService

private final ThreadRestService threadRestService

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

queueMemberRestService

private final QueueMemberRestService queueMemberRestService

agentRestService

private final AgentRestService agentRestService

messageSendService

private final IMessageSendService messageSendService

messageRestService

private final MessageRestService messageRestService

agentSettingsRestService

private final AgentSettingsRestService agentSettingsRestService

robotSettingsRestService

private final RobotSettingsRestService robotSettingsRestService

workgroupSettingsRestService

private final WorkgroupSettingsRestService workgroupSettingsRestService

workgroupRestService

private final WorkgroupRestService workgroupRestService

Constructor Details

VisitorThreadService

public VisitorThreadService()

Method Details

findByUid

@Cacheable(value="visitor_thread",
           key="#uid",
           unless="#result == null")
public Optional<VisitorThreadEntity> findByUid(String uid)

Specified by:

findByUid in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

existsByUid

public Boolean existsByUid(String uid)

findFirstByTopic

@Cacheable(value="visitor_thread",
           key="#topic",
           unless="#result == null")
public Optional<VisitorThreadEntity> findFirstByTopic(String topic)

consumeVisitorNoResponseTriggerPermit

public boolean consumeVisitorNoResponseTriggerPermit(String threadUid,
 int noResponseTimeoutSeconds)

主动触发：判断“访客长时间未发送消息”是否达到阈值，并用 QueueMember.lastNotifiedAt 做节流。 规则： - 优先使用 QueueMember.visitorLastMessageAt 作为基准时间 - 若为空，则使用 visitorEnqueueAt 作为兜底 - 达到 noResponseTimeoutSeconds 才允许触发 - 触发后写入 lastNotifiedAt，避免每分钟重复触发

createWorkgroupThread

public ThreadEntity createWorkgroupThread(VisitorRequest visitorRequest,
 WorkgroupEntity workgroup,
 String topic)

reInitWorkgroupThreadExtra

public ThreadEntity reInitWorkgroupThreadExtra(VisitorRequest visitorRequest,
 ThreadEntity thread,
 WorkgroupEntity workgroup)

createAgentThread

public ThreadEntity createAgentThread(VisitorRequest visitorRequest,
 AgentEntity agent,
 String topic)

reInitAgentThreadExtra

public ThreadEntity reInitAgentThreadExtra(VisitorRequest visitorRequest,
 ThreadEntity thread,
 AgentEntity agent)

createRobotThread

public ThreadEntity createRobotThread(VisitorRequest visitorRequest,
 RobotEntity robot,
 String topic)

reInitRobotThreadExtra

public ThreadEntity reInitRobotThreadExtra(VisitorRequest visitorRequest,
 ThreadEntity thread,
 RobotEntity robot)

createWorkflowThread

public ThreadEntity createWorkflowThread(VisitorRequest visitorRequest,
 WorkflowEntity workflow,
 String topic)

reInitWorkflowThreadExtra

public ThreadEntity reInitWorkflowThreadExtra(VisitorRequest visitorRequest,
 ThreadEntity thread,
 WorkflowEntity workflow)

buildWorkflowExtra

private String buildWorkflowExtra(VisitorRequest visitorRequest,
 WorkflowEntity workflow)

根据请求与工作流实体构建 thread.extra - 工作流暂时不支持 debug 预览

buildWorkgroupExtra

private String buildWorkgroupExtra(VisitorRequest visitorRequest,
 WorkgroupEntity workgroup)

根据请求与工作组实体构建 thread.extra - 社交渠道：直接使用请求中的 extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览

buildAgentExtra

private String buildAgentExtra(VisitorRequest visitorRequest,
 AgentEntity agent)

根据请求与客服实体构建 thread.extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览

buildRobotExtra

private String buildRobotExtra(VisitorRequest visitorRequest,
 RobotEntity robot)

根据请求与机器人实体构建 thread.extra - 普通渠道：构建 ServiceSettingsResponseVisitor JSON 若 debug=true 且 settingsUid 非空，则优先使用指定 settings 进行预览

update

public VisitorThreadEntity update(ThreadEntity thread)

create

public VisitorThreadResponse create(VisitorThreadRequest request)

Specified by:

create in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

update

public VisitorThreadResponse update(VisitorThreadRequest request)

Specified by:

update in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

autoRemindAgentOrCloseThread

@Async
public void autoRemindAgentOrCloseThread(List<ThreadEntity> threads)

自动提醒客服或关闭会话

processThreadTimeout

private void processThreadTimeout(ThreadEntity thread)

处理单个Thread会话的超时逻辑

calculateThreadTimeoutMinutes

private long calculateThreadTimeoutMinutes(ThreadEntity thread)

计算线程超时分钟数

handleAutoClose

private void handleAutoClose(ThreadEntity thread,
 long diffInMinutes)

处理自动关闭逻辑

parseThreadSettings

private ServiceSettingsResponseVisitor parseThreadSettings(ThreadEntity thread)

解析线程设置

getAutoCloseMinutes

private double getAutoCloseMinutes(ServiceSettingsResponseVisitor settings)

获取自动关闭分钟数

handleTimeoutReminder

private void handleTimeoutReminder(ThreadEntity thread,
 long diffInMinutes)

处理超时提醒逻辑

processAgentTimeoutReminder

private void processAgentTimeoutReminder(ThreadEntity thread,
 AgentEntity agent)

处理客服超时提醒

shouldSendTimeoutReminder

private boolean shouldSendTimeoutReminder(QueueMemberEntity queueMember)

判断是否应该发送超时提醒

sendRemindMessage

private void sendRemindMessage(QueueMemberEntity queueMember,
 ThreadEntity thread,
 AgentEntity agent)

handleQueueWaitTimeout

private boolean handleQueueWaitTimeout(ThreadEntity thread)

处理排队等待超时逻辑

Returns:

true 如果会话已被处理（触发了离线留言），false 如果未处理

handleQueueOverflowLeaveMessage

public MessageProtobuf handleQueueOverflowLeaveMessage(ThreadEntity thread,
 QueueMemberEntity queueMember)

resolveQueueSettings

private QueueSettingsEntity resolveQueueSettings(ThreadEntity thread)

resolveQueueSettingsFromAgent

private QueueSettingsEntity resolveQueueSettingsFromAgent(AgentEntity agent)

resolveQueueSettingsFromWorkgroup

private QueueSettingsEntity resolveQueueSettingsFromWorkgroup(WorkgroupEntity workgroup)

resolveQueueMaxWaitSeconds

private int resolveQueueMaxWaitSeconds(QueueSettingsEntity queueSettings)

triggerQueueLeaveMessage

private MessageProtobuf triggerQueueLeaveMessage(ThreadEntity thread,
 QueueMemberEntity queueMember)

resolveLeaveMessageTip

private String resolveLeaveMessageTip(ThreadEntity thread)

resolveLeaveMessageTip

private String resolveLeaveMessageTip(AgentEntity agent)

resolveLeaveMessageTip

private String resolveLeaveMessageTip(WorkgroupEntity workgroup)

doSave

protected VisitorThreadEntity doSave(VisitorThreadEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

deleteByUid

public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

delete

public void delete(VisitorThreadRequest entity)

Specified by:

delete in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

handleOptimisticLockingFailureException

public VisitorThreadEntity handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 VisitorThreadEntity entity)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

convertToResponse

public VisitorThreadResponse convertToResponse(VisitorThreadEntity entity)

Specified by:

convertToResponse in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

createSpecification

protected org.springframework.data.jpa.domain.Specification<VisitorThreadEntity> createSpecification(VisitorThreadRequest request)

Description copied from class: BaseRestService

创建Specification对象，子类必须实现 用于queryByOrg的通用实现

Specified by:

createSpecification in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>

executePageQuery

protected org.springframework.data.domain.Page<VisitorThreadEntity> executePageQuery(org.springframework.data.jpa.domain.Specification<VisitorThreadEntity> spec,
 org.springframework.data.domain.Pageable pageable)

Description copied from class: BaseRestService

执行分页查询，子类必须实现 用于queryByOrg的通用实现

Specified by:

executePageQuery in class BaseRestService<VisitorThreadEntity,VisitorThreadRequest,VisitorThreadResponse>