Class MarketPriceService

java.lang.Object

com.bluebell.greenhouse.radicle.services.AbstractGenericEntityService<MarketPrice, MarketPriceRepository>

com.bluebell.greenhouse.radicle.services.market.price.MarketPriceService

@Service
@Transactional(readOnly=true)
public class MarketPriceService
extends AbstractGenericEntityService<MarketPrice, MarketPriceRepository>

Service-layer for MarketPrice.

Version:

3.0.6

Author:

Stephen Prizio

Constructor Summary

Constructors

Constructor	Description
MarketPriceService(MarketPriceRepository marketPriceRepository, MarketPriceFetchRequestDispatchService marketPriceFetchRequestDispatchService, SymbolService symbolService, SymbolAliasService symbolAliasService, jakarta.persistence.EntityManager entityManager)	Creates the service.

Method Summary

Modifier and Type	Method	Description
MarketPrice	createNewMarketPrice(CreateUpdateMarketPriceDTO data)	Creates a new MarketPrice.
boolean	deleteMarketPrice(MarketPrice marketPrice)	Deletes the given MarketPrice.
List<MarketPrice>	findBestAvailableMarketPricesForPosition(Position position)	Returns the finest available market prices for the given Position, falling back to higher intervals when minute data is unavailable.
PositionChartMarketData	findChartMarketDataForPosition(Position position)	Returns the market price payload best suited to charting the given Position.
List<MarketPrice>	findChartMarketPricesForPosition(Position position)	Returns the MarketPrices best suited to charting the given Position.
Optional<MarketPrice>	findMarketPriceByUid(String uid)	Looks up a MarketPrice by its uid.
List<MarketPrice>	findMarketPricesForPosition(Position position, MarketTimeInterval timeInterval)	Returns a List of MarketPrices for the given Position.
List<MarketPrice>	findMarketPricesForSymbolAlias(SymbolAlias symbolAlias, MarketTimeInterval timeInterval)	Returns a List of MarketPrices for the given SymbolAlias and interval.
List<MarketPrice>	findMarketPricesForSymbolAlias(SymbolAlias symbolAlias, MarketTimeInterval timeInterval, LocalDateTime start, LocalDateTime end)	Returns a List of MarketPrices for the given SymbolAlias and interval, filtered by optional start and end bounds.
List<MarketPrice>	findMarketPricesWithinTimespan(SymbolAlias symbolAlias, MarketTimeInterval timeInterval, LocalDateTime start, LocalDateTime end)	Returns a List of MarketPrices for the given symbol and datasource, within the time span.
String	queueSymbolAnalysisMarketPriceRefreshIfNeeded(SymbolAlias symbolAlias, MarketTimeInterval timeInterval, LocalDateTime start, LocalDateTime end, int requestedBars, List<MarketPrice> marketPrices)	Queues a background refresh for symbol-analysis EOD prices when the stored window is empty, materially behind the requested end date, or shorter than the requested lookback.
int	saveAllSet(Collection<MarketPrice> marketPrices)	Saves all MarketPrices within the given set to the database.
boolean	saveMT4MarketPriceData(MT4MarketData data)	Saves the MT4MarketData as MarketPrices to the database.
org.springframework.data.domain.Page<MarketPrice>	searchMarketPrices(MarketPriceFilter filter, int page, int pageSize, org.springframework.data.domain.Sort sort)	Returns a paginated Page of MarketPrices matching the given filter.
MarketPrice	updateMarketPrice(MarketPrice marketPrice, CreateUpdateMarketPriceDTO data)	Updates an existing MarketPrice.

Methods inherited from class AbstractGenericEntityService

refreshEntity, resolveEntity, resolveEntity, resolveEntity

Methods inherited from class Object

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

Constructor Details

MarketPriceService

public MarketPriceService(MarketPriceRepository marketPriceRepository,
 MarketPriceFetchRequestDispatchService marketPriceFetchRequestDispatchService,
 SymbolService symbolService,
 SymbolAliasService symbolAliasService,
 jakarta.persistence.EntityManager entityManager)

Creates the service.

Parameters:

marketPriceRepository - MarketPriceRepository

marketPriceFetchRequestDispatchService - MarketPriceFetchRequestDispatchService

symbolService - SymbolService

symbolAliasService - SymbolAliasService

entityManager - EntityManager

Method Details

findMarketPriceByUid

public Optional<MarketPrice> findMarketPriceByUid(String uid)

Looks up a MarketPrice by its uid.

Parameters:

uid - uid

Returns:

Optional MarketPrice

createNewMarketPrice

@Transactional
@CacheEvict(cacheNames="symbolAnalysis",
            allEntries=true)
public MarketPrice createNewMarketPrice(CreateUpdateMarketPriceDTO data)

Creates a new MarketPrice.

Parameters:

data - CreateUpdateMarketPriceDTO

Returns:

new MarketPrice

updateMarketPrice

@Transactional
@CacheEvict(cacheNames="symbolAnalysis",
            allEntries=true)
public MarketPrice updateMarketPrice(MarketPrice marketPrice,
 CreateUpdateMarketPriceDTO data)

Updates an existing MarketPrice.

Parameters:

marketPrice - MarketPrice

data - CreateUpdateMarketPriceDTO

Returns:

updated MarketPrice

deleteMarketPrice

@Transactional
@CacheEvict(cacheNames="symbolAnalysis",
            allEntries=true)
public boolean deleteMarketPrice(MarketPrice marketPrice)

Deletes the given MarketPrice.

Parameters:

marketPrice - MarketPrice

Returns:

true if deleted

findMarketPricesWithinTimespan

public List<MarketPrice> findMarketPricesWithinTimespan(SymbolAlias symbolAlias,
 MarketTimeInterval timeInterval,
 LocalDateTime start,
 LocalDateTime end)

Returns a List of MarketPrices for the given symbol and datasource, within the time span.

Parameters:

symbolAlias - SymbolAlias

timeInterval - MarketTimeInterval

start - LocalDateTime

end - LocalDateTime

Returns:

List of MarketPrice

findMarketPricesForSymbolAlias

public List<MarketPrice> findMarketPricesForSymbolAlias(SymbolAlias symbolAlias,
 MarketTimeInterval timeInterval)

Returns a List of MarketPrices for the given SymbolAlias and interval.

Parameters:

symbolAlias - SymbolAlias

timeInterval - MarketTimeInterval

Returns:

List of MarketPrice

findMarketPricesForSymbolAlias

public List<MarketPrice> findMarketPricesForSymbolAlias(SymbolAlias symbolAlias,
 MarketTimeInterval timeInterval,
 LocalDateTime start,
 LocalDateTime end)

Returns a List of MarketPrices for the given SymbolAlias and interval, filtered by optional start and end bounds.

Parameters:

symbolAlias - SymbolAlias

timeInterval - MarketTimeInterval

start - optional start date time, inclusive

end - optional end date time, exclusive

Returns:

List of MarketPrice

queueSymbolAnalysisMarketPriceRefreshIfNeeded

public String queueSymbolAnalysisMarketPriceRefreshIfNeeded(SymbolAlias symbolAlias,
 MarketTimeInterval timeInterval,
 LocalDateTime start,
 LocalDateTime end,
 int requestedBars,
 List<MarketPrice> marketPrices)

Queues a background refresh for symbol-analysis EOD prices when the stored window is empty, materially behind the requested end date, or shorter than the requested lookback.

Only DataSource.EOD aliases are eligible for automatic refresh from symbol analysis. MT4 and other data sources rely on their own ingestion flows.

Parameters:

symbolAlias - SymbolAlias

timeInterval - MarketTimeInterval

start - optional request start

end - request end, exclusive

requestedBars - requested bar count

marketPrices - current stored market prices for the window

Returns:

optional note describing the queued refresh

searchMarketPrices

public org.springframework.data.domain.Page<MarketPrice> searchMarketPrices(MarketPriceFilter filter,
 int page,
 int pageSize,
 org.springframework.data.domain.Sort sort)

Returns a paginated Page of MarketPrices matching the given filter.

Parameters:

filter - MarketPriceFilter

page - current page

pageSize - page size

sort - Sort

Returns:

Page of MarketPrice

findMarketPricesForPosition

public List<MarketPrice> findMarketPricesForPosition(Position position,
 MarketTimeInterval timeInterval)

Returns a List of MarketPrices for the given Position.

Parameters:

position - Position

timeInterval - MarketTimeInterval

Returns:

List of MarketPrice

findBestAvailableMarketPricesForPosition

public List<MarketPrice> findBestAvailableMarketPricesForPosition(Position position)

Returns the finest available market prices for the given Position, falling back to higher intervals when minute data is unavailable.

Parameters:

position - Position

Returns:

List of MarketPrice

findChartMarketPricesForPosition

public List<MarketPrice> findChartMarketPricesForPosition(Position position)

Returns the MarketPrices best suited to charting the given Position.

The resolution is derived from the position's duration so that long-running positions are not rendered with an unmanageable number of fine-grained bars (e.g. a multi-day position will not use one-minute data). The finest interval whose estimated bar count stays within CHART_TARGET_MAX_BARS is preferred, falling back to coarser (then finer) intervals when the preferred resolution has no stored data. When the resulting series is shorter than CHART_MIN_BARS, the window is widened symmetrically around the position to provide context.

Parameters:

position - Position

Returns:

List of MarketPrice, empty when no data is available

findChartMarketDataForPosition

public PositionChartMarketData findChartMarketDataForPosition(Position position)

Returns the market price payload best suited to charting the given Position.

The response includes the resolved symbol alias, chosen interval, and any prices found for the chart window. When no prices are available the alias and preferred interval are still returned so callers can display metadata while a background fetch request is queued.

Parameters:

position - Position

Returns:

PositionChartMarketData

saveAllSet

@Transactional
@CacheEvict(cacheNames="symbolAnalysis",
            allEntries=true)
public int saveAllSet(Collection<MarketPrice> marketPrices)

Saves all MarketPrices within the given set to the database.

Parameters:

marketPrices - Collection of MarketPrice

Returns:

count of insertions/updates

saveMT4MarketPriceData

@Transactional
@CacheEvict(cacheNames="symbolAnalysis",
            allEntries=true)
public boolean saveMT4MarketPriceData(MT4MarketData data)

Saves the MT4MarketData as MarketPrices to the database.

Parameters:

data - MT4MarketData

Returns:

true if the data was saved successfully