Package com.bytedesk.core.thread

Class ThreadRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

com.bytedesk.core.thread.ThreadRestService

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

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 UidUtils	uidUtils

Constructor Summary

Constructors

Constructor	Description
ThreadRestService()

Method Summary

Modifier and Type	Method	Description
ThreadResponse	acceptByAgent(ThreadRequest threadRequest)
ThreadResponse	autoClose(ThreadEntity thread)
ThreadResponse	close(ThreadRequest threadRequest)
ThreadResponse	convertToResponse(ThreadEntity thread)
int	countByThreadTopicAndState(String topic, String state)
ThreadResponse	create(ThreadRequest request)
ThreadResponse	createFileAssistantThread(UserEntity user)	文件助手会话：file/{user_uid}
ThreadResponse	createGroupMemberThread(ThreadEntity thread, UserEntity owner)
ThreadResponse	createSystemChannelThread(UserEntity user)
void	delete(ThreadRequest entity)
void	deleteByTopic(String topic)
void	deleteByUid(String uid)
Boolean	existsByUid(String uid)
org.springframework.data.domain.Page<ThreadEntity>	findByOwner(UserEntity user, org.springframework.data.domain.Pageable pageable)
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>	findServiceThreadStateStarted()
void	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)
Optional<ThreadResponse>	queryByThreadUid(ThreadRequest request)
Optional<ThreadResponse>	queryByTopic(ThreadRequest request)
ThreadResponse	queryByUid(ThreadRequest request)
org.springframework.data.domain.Page<ThreadResponse>	queryByUser(ThreadRequest request)
ThreadEntity	save(ThreadEntity thread)
ThreadResponse	update(ThreadRequest threadRequest)
ThreadResponse	updateMute(ThreadRequest threadRequest)
ThreadResponse	updateStar(ThreadRequest threadRequest)
ThreadResponse	updateState(ThreadRequest threadRequest)
ThreadResponse	updateTagList(ThreadRequest threadRequest)
ThreadResponse	updateTop(ThreadRequest threadRequest)
ThreadResponse	updateUnreadCount(ThreadRequest threadRequest)
ThreadResponse	updateUser(ThreadRequest threadRequest)

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

getUidFromRequest

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

Constructor Details

ThreadRestService

public ThreadRestService()

Method Details

queryByOrg

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

Specified by:

queryByOrg in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

query

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

queryByTopic

public Optional<ThreadResponse> queryByTopic(ThreadRequest request)

queryByThreadUid

public Optional<ThreadResponse> queryByThreadUid(ThreadRequest request)

create

public ThreadResponse create(ThreadRequest request)

Specified by:

create in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

createGroupMemberThread

public ThreadResponse createGroupMemberThread(ThreadEntity thread,
 UserEntity owner)

createFileAssistantThread

public ThreadResponse createFileAssistantThread(UserEntity user)

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

createSystemChannelThread

public ThreadResponse createSystemChannelThread(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)

updateUser

public ThreadResponse updateUser(ThreadRequest threadRequest)

updateTagList

public ThreadResponse updateTagList(ThreadRequest threadRequest)

updateUnreadCount

public ThreadResponse updateUnreadCount(ThreadRequest threadRequest)

updateState

public ThreadResponse updateState(ThreadRequest threadRequest)

autoClose

public ThreadResponse autoClose(ThreadEntity thread)

close

public ThreadResponse close(ThreadRequest threadRequest)

acceptByAgent

public ThreadResponse acceptByAgent(ThreadRequest threadRequest)

countByThreadTopicAndState

public int countByThreadTopicAndState(String topic,
 String state)

findByUid

@Cacheable(value="thread",
           key="#uid",
           unless="#result == null")
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)

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)

findServiceThreadStateStarted

public List<ThreadEntity> findServiceThreadStateStarted()

save

@CachePut(value="thread",key="#thread.uid") @CachePut(value="thread",key="#thread.topic")
public ThreadEntity save(@NonNull
 ThreadEntity thread)

Specified by:

save in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

deleteByTopic

public void deleteByTopic(String topic)

deleteByUid

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>

queryByUser

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

Specified by:

queryByUser in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

handleOptimisticLockingFailureException

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

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

queryByUid

public ThreadResponse queryByUid(ThreadRequest request)

Overrides:

queryByUid in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>