Package energy.eddie.regionconnector.de.eta.persistence

Interface DePermissionRequestRepository

All Superinterfaces:

FullPermissionRequestRepository<DePermissionRequest>, PermissionRequestRepository<DePermissionRequest>, org.springframework.data.repository.Repository<DePermissionRequest,String>, StalePermissionRequestRepository<DePermissionRequest>, StatusPermissionRequestRepository<DePermissionRequest>

@Repository
public interface DePermissionRequestRepository
extends org.springframework.data.repository.Repository<DePermissionRequest,String>, FullPermissionRequestRepository<DePermissionRequest>

Repository interface for DePermissionRequest. Extends Spring Data Repository and FullPermissionRequestRepository to provide all necessary operations.

Method Summary

Modifier and Type	Method	Description
Optional<DePermissionRequest>	findByPermissionId(String permissionId)	Finds a permission request by its permission id.
List<DePermissionRequest>	findByStatus(PermissionProcessStatus status)
List<DePermissionRequest>	findStalePermissionRequests(int stalenessDuration)	Finds all permission request that are older than the stalenessDuration and have either the status VALIDATED or SENT_TO_PERMISSION_ADMINISTRATOR.

Methods inherited from interface energy.eddie.api.agnostic.process.model.persistence.PermissionRequestRepository

getByPermissionId, save

Method Details

findByPermissionId

Optional<DePermissionRequest> findByPermissionId(String permissionId)

Description copied from interface: PermissionRequestRepository

Finds a permission request by its permission id. If there is no permission request, it returns an empty optional.

Specified by:

findByPermissionId in interface PermissionRequestRepository<DePermissionRequest>

Parameters:

permissionId - the id of the permission request.

Returns:

an optional that contains the permission request if it exists.

findByStatus

List<DePermissionRequest> findByStatus(PermissionProcessStatus status)

Specified by:

findByStatus in interface StatusPermissionRequestRepository<DePermissionRequest>

findStalePermissionRequests

@Query(value="SELECT permission_id, data_source_connection_id, metering_point_id, data_start, data_end, granularity, energy_type, status, data_need_id, created, latest_meter_reading, message, cause FROM de_eta.eta_permission_request WHERE status = \'SENT_TO_PERMISSION_ADMINISTRATOR\' AND created <= NOW() - :hours * INTERVAL \'1 hour\'",
       nativeQuery=true)
List<DePermissionRequest> findStalePermissionRequests(@Param("hours")
 int stalenessDuration)

Description copied from interface: StalePermissionRequestRepository

Finds all permission request that are older than the stalenessDuration and have either the status VALIDATED or SENT_TO_PERMISSION_ADMINISTRATOR.

Specified by:

findStalePermissionRequests in interface StalePermissionRequestRepository<DePermissionRequest>

Parameters:

stalenessDuration - the max amount of hours the permission request has to be created ago to not be considered stale.

Returns:

all permission request created now - stalenessDuration hours ago, with above specified status.