Package com.bytedesk.core.server

Class ServerRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<ServerEntity,ServerRequest,ServerResponse>

com.bytedesk.core.server.ServerRestService

@Service
public class ServerRestService
extends BaseRestService<ServerEntity,ServerRequest,ServerResponse>

REST service for server monitoring operations Provides CRUD operations and business logic for server management

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServerRestService.ServerStatistics	Server statistics data class

Field Summary

Fields

Modifier and Type	Field	Description
private final org.modelmapper.ModelMapper	modelMapper
private final ServerRepository	serverRepository
private final UidUtils	uidUtils

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

authService

Constructor Summary

Constructors

Constructor	Description
ServerRestService()

Method Summary

Modifier and Type	Method	Description
ServerResponse	convertToResponse(ServerEntity entity)
ServerResponse	create(ServerRequest request)
ServerEntity	createServer(ServerEntity serverEntity)	Create server entity directly
protected org.springframework.data.jpa.domain.Specification<ServerEntity>	createSpecification(ServerRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
void	delete(ServerRequest request)
void	deleteByUid(String uid)
ServerEntity	doSave(ServerEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<ServerEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<ServerEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
List<ServerEntity>	findAllServers()	Find all servers
ServerEntity	findByServerName(String serverName)	Find server by server name
List<ServerEntity>	findByStatus(String status)	Find servers by status
List<ServerEntity>	findByType(String type)	Find servers by type
Optional<ServerEntity>	findByUid(String uid)
List<ServerEntity>	findServersWithHighUsage()	Find servers with high resource usage
List<ServerEntity>	findServersWithoutRecentHeartbeat(int minutesThreshold)	Find servers without recent heartbeat
ServerEntity	getCurrentServerMetrics()	Get current server metrics (for self-monitoring)
ServerRestService.ServerStatistics	getServerStatistics()	Get server statistics
protected String	getUidFromRequest(ServerRequest request)	从请求对象中获取UID的通用实现 使用反射调用getUid方法
ServerEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, ServerEntity entity)
ServerResponse	update(ServerRequest request)
Optional<ServerEntity>	updateHeartbeat(String uid)	Update server heartbeat
Optional<ServerEntity>	updateResourceUsage(String uid, Double cpuUsage, Double memoryUsage, Double diskUsage)	Update server resource usage
ServerEntity	updateServer(ServerEntity serverEntity)	Update server entity directly

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

deleteByOrgUid, findByOrgUid, 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

serverRepository

private final ServerRepository serverRepository

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

Constructor Details

ServerRestService

public ServerRestService()

Method Details

createSpecification

protected org.springframework.data.jpa.domain.Specification<ServerEntity> createSpecification(ServerRequest request)

Description copied from class: BaseRestService

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

Specified by:

createSpecification in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

executePageQuery

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

Description copied from class: BaseRestService

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

Specified by:

executePageQuery in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

findByUid

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

Specified by:

findByUid in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

create

public ServerResponse create(ServerRequest request)

Specified by:

create in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

update

public ServerResponse update(ServerRequest request)

Specified by:

update in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

deleteByUid

public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

delete

public void delete(ServerRequest request)

Specified by:

delete in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

getUidFromRequest

protected String getUidFromRequest(ServerRequest request)

Description copied from class: BaseRestService

从请求对象中获取UID的通用实现 使用反射调用getUid方法

Overrides:

getUidFromRequest in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

doSave

public ServerEntity doSave(ServerEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

handleOptimisticLockingFailureException

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

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>

findAllServers

public List<ServerEntity> findAllServers()

Find all servers

Returns:

List<ServerEntity>

findByType

public List<ServerEntity> findByType(String type)

Find servers by type

Parameters:

type - server type

Returns:

List<ServerEntity>

findByStatus

public List<ServerEntity> findByStatus(String status)

Find servers by status

Parameters:

status - server status

Returns:

List<ServerEntity>

findServersWithHighUsage

public List<ServerEntity> findServersWithHighUsage()

Find servers with high resource usage

Returns:

List<ServerEntity>

findServersWithoutRecentHeartbeat

public List<ServerEntity> findServersWithoutRecentHeartbeat(int minutesThreshold)

Find servers without recent heartbeat

Parameters:

minutesThreshold - minutes threshold for heartbeat

Returns:

List<ServerEntity>

updateHeartbeat

@Transactional
public Optional<ServerEntity> updateHeartbeat(String uid)

Update server heartbeat

Parameters:

uid - server UID

Returns:

updated server entity

updateResourceUsage

@Transactional
public Optional<ServerEntity> updateResourceUsage(String uid,
 Double cpuUsage,
 Double memoryUsage,
 Double diskUsage)

Update server resource usage

Parameters:

uid - server UID

cpuUsage - CPU usage percentage

memoryUsage - memory usage percentage

diskUsage - disk usage percentage

Returns:

updated server entity

getCurrentServerMetrics

public ServerEntity getCurrentServerMetrics()

Get current server metrics (for self-monitoring)

Returns:

ServerEntity with current metrics

findByServerName

public ServerEntity findByServerName(String serverName)

Find server by server name

Parameters:

serverName - server name

Returns:

ServerEntity or null if not found

createServer

@Transactional
public ServerEntity createServer(ServerEntity serverEntity)

Create server entity directly

Parameters:

serverEntity - server entity to create

Returns:

created server entity

updateServer

@Transactional
public ServerEntity updateServer(ServerEntity serverEntity)

Update server entity directly

Parameters:

serverEntity - server entity to update

Returns:

updated server entity

getServerStatistics

public ServerRestService.ServerStatistics getServerStatistics()

Get server statistics

Returns:

ServerStatistics object

convertToResponse

public ServerResponse convertToResponse(ServerEntity entity)

Specified by:

convertToResponse in class BaseRestService<ServerEntity,ServerRequest,ServerResponse>