Package com.bytedesk.core.thread

Class ThreadRestService

java.lang.Object

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

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

com.bytedesk.core.thread.ThreadRestService

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

Field Summary

Fields

Modifier and Type	Field	Description
private final AuthService	authService
private final BytedeskEventPublisher	bytedeskEventPublisher
private final CategoryRestService	categoryService
private final org.modelmapper.ModelMapper	modelMapper
private final TagRestService	tagRestService
private final ThreadRepository	threadRepository
private final UidUtils	uidUtils

Constructor Summary

Constructors

Constructor	Description
ThreadRestService()

Method Summary

Modifier and Type	Method	Description
ThreadResponse	autoClose(ThreadEntity thread)
ThreadResponse	close(ThreadRequest threadRequest)
ThreadExcel	convertToExcel(ThreadEntity entity)
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(ThreadEntity thread, UserEntity owner)
ThreadResponse	createSystemChannelThread(UserEntity user)
void	delete(ThreadRequest entity)
void	deleteByTopic(String topic)
void	deleteByUid(String uid)
protected ThreadEntity	doSave(ThreadEntity entity)
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()
ThreadEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, ThreadEntity entity)
void	initThreadCategory(String orgUid)
void	initThreadTag(String orgUid)
org.springframework.data.domain.Page<ThreadResponse>	query(ThreadRequest request)
org.springframework.data.domain.Page<ThreadResponse>	queryByOrg(ThreadRequest request)
org.springframework.data.domain.Page<ThreadEntity>	queryByOrgEntity(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)
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	updateUnread(ThreadRequest threadRequest)
ThreadResponse	updateUnreadCount(ThreadRequest threadRequest)
ThreadResponse	updateUser(ThreadRequest threadRequest)

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

getUidFromRequest, recover, save

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

categoryService

private final CategoryRestService categoryService

tagRestService

private final TagRestService tagRestService

Constructor Details

ThreadRestService

public ThreadRestService()

Method Details

queryByOrgEntity

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

Specified by:

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

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)

updateUnread

public ThreadResponse updateUnread(ThreadRequest threadRequest)

updateState

public ThreadResponse updateState(ThreadRequest threadRequest)

autoClose

public ThreadResponse autoClose(ThreadEntity thread)

close

public ThreadResponse close(ThreadRequest threadRequest)

countByThreadTopicAndState

public int countByThreadTopicAndState(String topic,
 String state)

countByThreadTopicAndStateNot

public int countByThreadTopicAndStateNot(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()

doSave

protected ThreadEntity doSave(ThreadEntity entity)

Specified by:

doSave in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

handleOptimisticLockingFailureException

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

Specified by:

handleOptimisticLockingFailureException 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>

queryByUid

public ThreadResponse queryByUid(ThreadRequest request)

Overrides:

queryByUid in class BaseRestService<ThreadEntity,ThreadRequest,ThreadResponse>

initThreadCategory

public void initThreadCategory(String orgUid)

initThreadTag

public void initThreadTag(String orgUid)

convertToExcel

public ThreadExcel convertToExcel(ThreadEntity entity)

Specified by:

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