Package com.bytedesk.core.thread

Class ThreadRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<T,TRequest,TResponse>

com.bytedesk.core.base.BaseRestServiceWithExport<ThreadEntity,ThreadRequest,ThreadResponse,ThreadExcel>

com.bytedesk.core.thread.ThreadRestService

@Service
public class ThreadRestService
extends BaseRestServiceWithExport<ThreadEntity,ThreadRequest,ThreadResponse,ThreadExcel>

Field Summary

Fields

Modifier and Type	Field	Description
private final AuthService	authService
private final BytedeskEventPublisher	bytedeskEventPublisher
private final org.modelmapper.ModelMapper	modelMapper
private final ThreadRepository	threadRepository
private final TopicRestService	topicRestService
private final UidUtils	uidUtils

Constructor Summary

Constructors

Constructor	Description
ThreadRestService()

Method Summary

Modifier and Type	Method	Description
ThreadResponse	autoClose(ThreadEntity thread)
ThreadResponse	closeByTopic(ThreadRequest request)
ThreadResponse	closeByUid(ThreadRequest request)
ThreadExcel	convertToExcel(ThreadEntity entity)	转换为Excel对象 子类必须实现此方法
ThreadResponse	convertToResponse(ThreadEntity thread)
int	countByThreadTopicAndState(String topic, String state)
int	countByThreadTopicAndStateNot(String topic, String state)
ThreadResponse	create(ThreadRequest request)
ThreadResponse	createFileAssistantThread(UserEntity user)	文件助手会话：file/{user_uid}
ThreadResponse	createGroupMemberThread(String user, String topic, String orgUid, UserEntity owner)
protected org.springframework.data.jpa.domain.Specification<ThreadEntity>	createSpecification(ThreadRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
ThreadResponse	createSystemNoticeAccountThread(UserEntity user)
void	delete(ThreadRequest entity)
void	deleteByTopic(String topic)
void	deleteByUid(String uid)
protected ThreadEntity	doSave(ThreadEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<ThreadEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<ThreadEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
Boolean	existsByUid(String uid)
org.springframework.data.domain.Page<ThreadEntity>	findByOwner(UserEntity user, org.springframework.data.domain.Pageable pageable)
List<ThreadEntity>	findByTopicStartsWithAndStatus(String topicPrefix, String status)
Optional<ThreadEntity>	findByUid(String uid)
Optional<ThreadEntity>	findFirstByTopic(String topic)
Optional<ThreadEntity>	findFirstByTopicAndOwner(String topic, UserEntity user)
Optional<ThreadEntity>	findFirstByTopicNotClosed(String topic)
List<ThreadEntity>	findListByTopic(String topic)
List<ThreadEntity>	findRecentAgentThreadsByVisitorUid(String visitorUid)	根据访客ID查找最近的客服会话记录 用于最近一次会话路由策略
List<ThreadEntity>	findServiceThreadStateStarted()
ThreadEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, ThreadEntity entity)
org.springframework.data.domain.Page<ThreadResponse>	query(ThreadRequest request)
org.springframework.data.domain.Page<ThreadResponse>	queryByOrg(ThreadRequest request)	通用的queryByOrg实现 子类如果有特殊逻辑可以重写此方法
org.springframework.data.domain.Page<ThreadEntity>	queryByOrgEntity(ThreadRequest request)	查询实体对象（用于Excel导出） 子类必须实现此方法
org.springframework.data.domain.Page<ThreadResponse>	queryByTopic(ThreadRequest request)
ThreadResponse	queryByTopicAndOwner(ThreadRequest request)
ThreadResponse	queryByUid(ThreadRequest request)	通用的queryByUid实现
org.springframework.data.domain.Page<ThreadResponse>	queryByUser(ThreadRequest request)	通用的queryByUser实现 子类如果有特殊逻辑可以重写此方法
org.springframework.data.domain.Page<ThreadResponse>	queryThreadsByUserTopics(ThreadRequest request)
void	removeGroupMemberThread(String topic, UserEntity owner)
ThreadResponse	update(ThreadRequest threadRequest)
ThreadResponse	updateFold(ThreadRequest threadRequest)
void	updateGroupMemberThread(String user, String topic, UserEntity owner)
ThreadResponse	updateHide(ThreadRequest threadRequest)
ThreadResponse	updateMute(ThreadRequest threadRequest)
ThreadResponse	updateNote(ThreadRequest threadRequest)
ThreadResponse	updateStar(ThreadRequest threadRequest)
ThreadResponse	updateState(ThreadRequest threadRequest)
ThreadResponse	updateTagList(ThreadRequest threadRequest)
ThreadResponse	updateTop(ThreadRequest threadRequest)
ThreadResponse	updateUnread(ThreadRequest threadRequest)
ThreadResponse	updateUser(ThreadRequest threadRequest)

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

deleteByOrgUid, findByOrgUid, getUidFromRequest, recover, save, setUserUidToRequest

Methods inherited from class java.lang.Object

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

Field Details

authService

private final AuthService authService

modelMapper

private final org.modelmapper.ModelMapper modelMapper

threadRepository

private final ThreadRepository threadRepository

uidUtils

private final UidUtils uidUtils

bytedeskEventPublisher

private final BytedeskEventPublisher bytedeskEventPublisher

topicRestService

private final TopicRestService topicRestService

Constructor Details

ThreadRestService

public ThreadRestService()

Method Details

queryByOrgEntity

public org.springframework.data.domain.Page<ThreadEntity> queryByOrgEntity(ThreadRequest request)

Description copied from class: BaseRestServiceWithExport

查询实体对象（用于Excel导出） 子类必须实现此方法

Overrides:

queryByOrgEntity in class BaseRestServiceWithExport<ThreadEntity,ThreadRequest,ThreadResponse,ThreadExcel>

queryByOrg

public org.springframework.data.domain.Page<ThreadResponse> queryByOrg(ThreadRequest request)

Description copied from class: BaseRestService

通用的queryByOrg实现 子类如果有特殊逻辑可以重写此方法

Overrides:

queryByOrg in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

query

public org.springframework.data.domain.Page<ThreadResponse> query(ThreadRequest request)

queryByUser

public org.springframework.data.domain.Page<ThreadResponse> queryByUser(ThreadRequest request)

Description copied from class: BaseRestService

通用的queryByUser实现 子类如果有特殊逻辑可以重写此方法

Overrides:

queryByUser in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

queryByTopic

public org.springframework.data.domain.Page<ThreadResponse> queryByTopic(ThreadRequest request)

queryByTopicAndOwner

public ThreadResponse queryByTopicAndOwner(ThreadRequest request)

queryByUid

public ThreadResponse queryByUid(ThreadRequest request)

Description copied from class: BaseRestService

通用的queryByUid实现

Overrides:

queryByUid in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

queryThreadsByUserTopics

public org.springframework.data.domain.Page<ThreadResponse> queryThreadsByUserTopics(ThreadRequest request)

create

@Transactional
public ThreadResponse create(ThreadRequest request)

Specified by:

create in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

createGroupMemberThread

@Transactional
public ThreadResponse createGroupMemberThread(String user,
 String topic,
 String orgUid,
 UserEntity owner)

removeGroupMemberThread

public void removeGroupMemberThread(String topic,
 UserEntity owner)

updateGroupMemberThread

public void updateGroupMemberThread(String user,
 String topic,
 UserEntity owner)

createFileAssistantThread

public ThreadResponse createFileAssistantThread(UserEntity user)

文件助手会话：file/{user_uid}

createSystemNoticeAccountThread

public ThreadResponse createSystemNoticeAccountThread(UserEntity user)

update

public ThreadResponse update(ThreadRequest threadRequest)

Specified by:

update in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

updateTop

public ThreadResponse updateTop(ThreadRequest threadRequest)

updateStar

public ThreadResponse updateStar(ThreadRequest threadRequest)

updateMute

public ThreadResponse updateMute(ThreadRequest threadRequest)

updateHide

public ThreadResponse updateHide(ThreadRequest threadRequest)

updateFold

public ThreadResponse updateFold(ThreadRequest threadRequest)

updateUser

public ThreadResponse updateUser(ThreadRequest threadRequest)

updateTagList

public ThreadResponse updateTagList(ThreadRequest threadRequest)

updateUnread

public ThreadResponse updateUnread(ThreadRequest threadRequest)

updateState

public ThreadResponse updateState(ThreadRequest threadRequest)

updateNote

public ThreadResponse updateNote(ThreadRequest threadRequest)

autoClose

public ThreadResponse autoClose(ThreadEntity thread)

closeByUid

public ThreadResponse closeByUid(ThreadRequest request)

closeByTopic

public ThreadResponse closeByTopic(ThreadRequest request)

countByThreadTopicAndState

public int countByThreadTopicAndState(String topic,
 String state)

countByThreadTopicAndStateNot

public int countByThreadTopicAndStateNot(String topic,
 String state)

findByUid

public Optional<ThreadEntity> findByUid(@NonNull
 String uid)

Specified by:

findByUid in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

existsByUid

public Boolean existsByUid(@NonNull
 String uid)

findFirstByTopicAndOwner

@Cacheable(value="thread",
           key="#topic + \'-\' + #user.uid",
           unless="#result == null")
public Optional<ThreadEntity> findFirstByTopicAndOwner(@NonNull
 String topic,
 UserEntity user)

findListByTopic

@Cacheable(value="threads",
           key="#topic",
           unless="#result == null")
public List<ThreadEntity> findListByTopic(@NonNull
 String topic)

findFirstByTopic

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

findFirstByTopicNotClosed

@Cacheable(value="thread",
           key="#topic",
           unless="#result == null")
public Optional<ThreadEntity> findFirstByTopicNotClosed(String topic)

findByTopicStartsWithAndStatus

public List<ThreadEntity> findByTopicStartsWithAndStatus(String topicPrefix,
 String status)

findByOwner

@Cacheable(value="thread",
           key="#user.uid + \'-\' + #pageable.getPageNumber()",
           unless="#result == null")
public org.springframework.data.domain.Page<ThreadEntity> findByOwner(UserEntity user,
 org.springframework.data.domain.Pageable pageable)

findRecentAgentThreadsByVisitorUid

public List<ThreadEntity> findRecentAgentThreadsByVisitorUid(String visitorUid)

根据访客ID查找最近的客服会话记录 用于最近一次会话路由策略

findServiceThreadStateStarted

public List<ThreadEntity> findServiceThreadStateStarted()

doSave

@CachePut(value="thread",key="#thread.uid",unless="#result == null") @CachePut(value="thread",key="#thread.topic",unless="#result == null")
protected ThreadEntity doSave(ThreadEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

handleOptimisticLockingFailureException

@CachePut(value="thread",key="#entity.uid",unless="#result == null") @CachePut(value="thread",key="#entity.topic",unless="#result == null")
public ThreadEntity handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 ThreadEntity entity)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

deleteByTopic

@CacheEvict(value="thread",
            key="#uid")
public void deleteByTopic(String topic)

deleteByUid

@CacheEvict(value="thread",
            key="#uid")
public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

delete

@CacheEvict(value="thread",key="#thread.uid") @CacheEvict(value="thread",key="#thread.topic")
public void delete(@NonNull
 ThreadRequest entity)

Specified by:

delete in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

convertToResponse

public ThreadResponse convertToResponse(ThreadEntity thread)

Specified by:

convertToResponse in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

convertToExcel

public ThreadExcel convertToExcel(ThreadEntity entity)

Description copied from class: BaseRestServiceWithExport

转换为Excel对象 子类必须实现此方法

Specified by:

convertToExcel in class BaseRestServiceWithExport<ThreadEntity,ThreadRequest,ThreadResponse,ThreadExcel>

createSpecification

protected org.springframework.data.jpa.domain.Specification<ThreadEntity> createSpecification(ThreadRequest request)

Description copied from class: BaseRestService

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

Specified by:

createSpecification in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

executePageQuery

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

Description copied from class: BaseRestService

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

Specified by:

executePageQuery in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>