Package com.bytedesk.service.agent

Class AgentRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<AgentEntity,AgentRequest,AgentResponse>

com.bytedesk.service.agent.AgentRestService

@Service
public class AgentRestService
extends BaseRestService<AgentEntity,AgentRequest,AgentResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final ActionRestService	actionService
private final AgentRepository	agentRepository
private final AuthService	authService
private final BytedeskEventPublisher	bytedeskEventPublisher
private static final int	MAX_RETRY_ATTEMPTS
private final MemberRestService	memberService
private final org.modelmapper.ModelMapper	modelMapper
private final MqttConnectionService	mqttConnectionService
private static final long	RETRY_DELAY_MS
private final Queue<AgentEntity>	retryQueue
private final ServiceSettingsService	serviceSettingsService
private final ThreadRestService	threadRestService
private final UidUtils	uidUtils
private final UserService	userService

Constructor Summary

Constructors

Constructor	Description
AgentRestService()

Method Summary

Modifier and Type	Method	Description
AgentResponse	convertToResponse(AgentEntity entity)
AgentResponse	create(AgentRequest request)
void	createFromMember(String mobile, String orgUid, String agentUid)
void	delete(AgentRequest request)
void	deleteByUid(String uid)
Boolean	existsByUserUidAndOrgUid(String userUid, String orgUid)
List<AgentEntity>	findAllConnected()
List<AgentEntity>	findByConnected(boolean connected)
Optional<AgentEntity>	findByEmailAndOrgUid(String email, String orgUid)
Optional<AgentEntity>	findByMobileAndOrgUid(String mobile, String orgUid)
Optional<AgentEntity>	findByUid(String uid)
Optional<AgentEntity>	findByUserUid(String userUid)
Optional<AgentEntity>	findByUserUidAndOrgUid(String userUid, String orgUid)
private void	handleFailedRetries(AgentEntity agent)
void	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, AgentEntity agent)
private void	processRetryQueue()
AgentResponse	query(AgentRequest request)
org.springframework.data.domain.Page<AgentResponse>	queryByOrg(AgentRequest request)
org.springframework.data.domain.Page<AgentResponse>	queryByUser(AgentRequest request)
AgentResponse	queryDetail(String uid)
AgentEntity	save(AgentEntity agent)
AgentResponse	syncCurrentThreadCount(AgentRequest request)
AgentResponse	update(AgentRequest request)
AgentResponse	updateAutoReply(AgentRequest request)
AgentResponse	updateAvatar(AgentRequest request)
void	updateConnect(String userUid, boolean connected)	更新坐席在线状态
AgentResponse	updateStatus(AgentRequest request)

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

getUidFromRequest, queryByUid

Methods inherited from class java.lang.Object

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

Field Details

agentRepository

private final AgentRepository agentRepository

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

memberService

private final MemberRestService memberService

userService

private final UserService userService

authService

private final AuthService authService

bytedeskEventPublisher

private final BytedeskEventPublisher bytedeskEventPublisher

actionService

private final ActionRestService actionService

serviceSettingsService

private final ServiceSettingsService serviceSettingsService

mqttConnectionService

private final MqttConnectionService mqttConnectionService

threadRestService

private final ThreadRestService threadRestService

MAX_RETRY_ATTEMPTS

private static final int MAX_RETRY_ATTEMPTS

See Also:

• Constant Field Values

RETRY_DELAY_MS

private static final long RETRY_DELAY_MS

See Also:

• Constant Field Values

retryQueue

private final Queue<AgentEntity> retryQueue

Constructor Details

AgentRestService

public AgentRestService()

Method Details

queryByOrg

public org.springframework.data.domain.Page<AgentResponse> queryByOrg(AgentRequest request)

Specified by:

queryByOrg in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

queryByUser

public org.springframework.data.domain.Page<AgentResponse> queryByUser(AgentRequest request)

Specified by:

queryByUser in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

query

public AgentResponse query(AgentRequest request)

queryDetail

public AgentResponse queryDetail(String uid)

create

@Transactional
public AgentResponse create(AgentRequest request)

Specified by:

create in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

createFromMember

public void createFromMember(String mobile,
 String orgUid,
 String agentUid)

update

@Transactional
public AgentResponse update(AgentRequest request)

Specified by:

update in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

updateAvatar

@Transactional
public AgentResponse updateAvatar(AgentRequest request)

updateStatus

@Transactional
public AgentResponse updateStatus(AgentRequest request)

syncCurrentThreadCount

public AgentResponse syncCurrentThreadCount(AgentRequest request)

updateAutoReply

@Transactional
public AgentResponse updateAutoReply(AgentRequest request)

updateConnect

@Async
@Transactional
public void updateConnect(String userUid,
 boolean connected)

更新坐席在线状态

Parameters:

userUid - 用户ID

connected - 是否在线

findByUid

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

Specified by:

findByUid in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

findByUserUid

@Cacheable(value="agent",
           key="#userUid",
           unless="#result == null")
public Optional<AgentEntity> findByUserUid(String userUid)

findByMobileAndOrgUid

@Cacheable(value="agent",
           key="#mobile",
           unless="#result == null")
public Optional<AgentEntity> findByMobileAndOrgUid(String mobile,
 String orgUid)

findByEmailAndOrgUid

@Cacheable(value="agent",
           key="#email",
           unless="#result == null")
public Optional<AgentEntity> findByEmailAndOrgUid(String email,
 String orgUid)

findByUserUidAndOrgUid

@Cacheable(value="agent",
           key="#userUid",
           unless="#result == null")
public Optional<AgentEntity> findByUserUidAndOrgUid(String userUid,
 String orgUid)

existsByUserUidAndOrgUid

public Boolean existsByUserUidAndOrgUid(String userUid,
 String orgUid)

findAllConnected

public List<AgentEntity> findAllConnected()

findByConnected

public List<AgentEntity> findByConnected(boolean connected)

save

@CachePut(value="agent",key="#agent.uid") @CachePut(value="agent",key="#agent.mobile",unless="#agent.mobile == null") @CachePut(value="agent",key="#agent.email",unless="#agent.email == null")
public AgentEntity save(AgentEntity agent)

Specified by:

save in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

deleteByUid

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

Specified by:

deleteByUid in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

delete

public void delete(AgentRequest request)

Specified by:

delete in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

convertToResponse

public AgentResponse convertToResponse(AgentEntity entity)

Specified by:

convertToResponse in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

handleOptimisticLockingFailureException

public void handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 AgentEntity agent)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<AgentEntity,AgentRequest,AgentResponse>

processRetryQueue

private void processRetryQueue()

handleFailedRetries

private void handleFailedRetries(AgentEntity agent)