Class AgentCostByDateQueryResultMapper

java.lang.Object

com.flowable.platform.service.dashboard.resultmapper.extractor.AgentCostByDateQueryResultMapper

All Implemented Interfaces:

DashboardComponentQueryResultMapper

public class AgentCostByDateQueryResultMapper
extends Object
implements DashboardComponentQueryResultMapper

Computes the total LLM cost per time bucket (a time series for a line chart) by combining per-bucket, per-model token sums with the configured model prices for the tenant.

The dashboard query framework cannot express a single aggregation that groups by both date and model, so this mapper does not use the (single) query result it is given. Instead it resolves the dashboard's date range from the input parameters and delegates to AgentCostTokenService, which already buckets the range by day/week/month and runs the per-model token query once per bucket (the same logic that powers the Control agent timeline). The per-bucket per-model token sums are then priced here.

Field Summary

Fields

Modifier and Type	Field	Description
protected final AgentCostTokenService	agentCostTokenService
protected final AgentModelPricingService	agentModelPricingService
protected final StandardDataQueryInputValuesTransformer	inputValuesTransformer
protected static final BigDecimal	TOKENS_PER_PRICE_UNIT
static final String	TYPE
protected static final String	TYPE_ABSOLUTE
protected static final String	TYPE_RELATIVE

Constructor Summary

Constructors

Constructor	Description
AgentCostByDateQueryResultMapper(AgentModelPricingService agentModelPricingService, AgentCostTokenService agentCostTokenService, StandardDataQueryInputValuesTransformer inputValuesTransformer)

Method Summary

Modifier and Type	Method	Description
protected static BigDecimal	computeCost(double inputTokens, double outputTokens, double cachedTokens, AgentModelPrice price)	Computes the cost for a single model.
protected static BigDecimal	costFor(double tokens, BigDecimal pricePerUnit)
String	getType()
DashboardComponentData	map(DashboardComponentDefinitionModel dashboardComponentDefinitionModel, Map<String, tools.jackson.databind.JsonNode> queryPayload, tools.jackson.databind.JsonNode queryResult)
DashboardComponentData	map(DashboardComponentDefinitionModel dashboardComponentDefinitionModel, Map<String, tools.jackson.databind.JsonNode> queryPayload, tools.jackson.databind.JsonNode queryResult, String tenantId)
protected static AgentModelPrice	matchPrice(String model, List<AgentModelPrice> prices)	Returns the price whose modelPrefix is the longest prefix of the given model name, or null when no configured prefix matches.
protected List<String>	resolveAgentDefinitionKeys(Map<String, tools.jackson.databind.JsonNode> queryPayload)	Resolves the optional agent definition filter from the query payload (an array of { "key": ... } refs).
protected StandardDataQueryPayloadValues.DateRangeValue	resolveDateRange(Map<String, tools.jackson.databind.JsonNode> queryPayload)	Resolves the date range from the query payload.

Methods inherited from class Object

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

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

TOKENS_PER_PRICE_UNIT

protected static final BigDecimal TOKENS_PER_PRICE_UNIT

TYPE_ABSOLUTE

protected static final String TYPE_ABSOLUTE

See Also:

• Constant Field Values

TYPE_RELATIVE

protected static final String TYPE_RELATIVE

See Also:

• Constant Field Values

agentModelPricingService

protected final AgentModelPricingService agentModelPricingService

agentCostTokenService

protected final AgentCostTokenService agentCostTokenService

inputValuesTransformer

protected final StandardDataQueryInputValuesTransformer inputValuesTransformer

Constructor Details

AgentCostByDateQueryResultMapper

public AgentCostByDateQueryResultMapper(AgentModelPricingService agentModelPricingService,
 AgentCostTokenService agentCostTokenService,
 StandardDataQueryInputValuesTransformer inputValuesTransformer)

Method Details

getType

public String getType()

Specified by:

getType in interface DashboardComponentQueryResultMapper

map

public DashboardComponentData map(DashboardComponentDefinitionModel dashboardComponentDefinitionModel,
 Map<String, tools.jackson.databind.JsonNode> queryPayload,
 tools.jackson.databind.JsonNode queryResult)

Specified by:

map in interface DashboardComponentQueryResultMapper

map

public DashboardComponentData map(DashboardComponentDefinitionModel dashboardComponentDefinitionModel,
 Map<String, tools.jackson.databind.JsonNode> queryPayload,
 tools.jackson.databind.JsonNode queryResult,
 String tenantId)

Specified by:

map in interface DashboardComponentQueryResultMapper

resolveDateRange

protected StandardDataQueryPayloadValues.DateRangeValue resolveDateRange(Map<String, tools.jackson.databind.JsonNode> queryPayload)

Resolves the date range from the query payload. The payload is keyed by query parameter name, so this finds the first value shaped like a date-range filter (an absolute or relative type) and resolves it with the shared transformer (start and end are carried by the same range object).

resolveAgentDefinitionKeys

protected List<String> resolveAgentDefinitionKeys(Map<String, tools.jackson.databind.JsonNode> queryPayload)

Resolves the optional agent definition filter from the query payload (an array of { "key": ... } refs).

computeCost

protected static BigDecimal computeCost(double inputTokens,
 double outputTokens,
 double cachedTokens,
 AgentModelPrice price)

Computes the cost for a single model. Each token type is priced per 1,000,000 tokens; a null price for a token type contributes zero.

costFor

protected static BigDecimal costFor(double tokens,
 BigDecimal pricePerUnit)

matchPrice

protected static AgentModelPrice matchPrice(String model,
 List<AgentModelPrice> prices)

Returns the price whose modelPrefix is the longest prefix of the given model name, or null when no configured prefix matches.