@ApplicationScoped
public class DefaultAnalyticsQueryService implements AnalyticsQueryService {
    private final DorisClient dorisClient;
    private final RedisDataSource redisDataSource;
    private final ObjectMapper objectMapper;
}

@Override
public AggregateGroupedResponse aggregateGrouped(AggregateGroupedRequest request) {
    long startMs = System.currentTimeMillis();
    String worldId = extractWorldId(request);

    // 1. 缓存查找
    if (request.getUseCache()) {
        String cacheKey = buildCacheKey(worldId, objectType, request.toString());
        AggregateGroupedResponse cached = readFromCache(cacheKey);
        if (cached != null) return cached;
    }

    // 2. 构建 SQL
    AggregateGroupedSqlBuilder builder = new AggregateGroupedSqlBuilder(request);
    AggregateGroupedSqlBuilder.BuildResult buildResult = builder.build();

    // 3. 执行主查询
    List<Map<String, Object>> rows = dorisClient.executeQuery(
            buildResult.getSql(), buildResult.getParams().toArray());

    // 4. 映射行
    List<AggregateRow> aggregateRows = mapRows(rows, request);

    // 5. 总计行（独立查询，无 GROUP BY）
    AggregateRow totalRow = null;
    if (request.getIncludeTotal() && buildResult.hasTotalQuery()) {
        List<Map<String, Object>> totalRows = dorisClient.executeQuery(
                totalQuery.getSql(), totalQuery.getParams().toArray());
        if (!totalRows.isEmpty()) {
            totalRow = mapSingleRow(totalRows.get(0), request, false);
        }
    }

    // 6. 执行信息
    QueryExecutionInfo executionInfo = QueryExecutionInfo.newBuilder()
            .setExecuteMs(executeMs).setTotalMs(totalMs)
            .setCacheHit(false).setQueryId(UUID.randomUUID().toString()).build();

    // 7. 组装响应
    AggregateGroupedResponse response = responseBuilder
            .addAllRows(aggregateRows).setExecutionInfo(executionInfo).build();

    // 8. 写入缓存
    if (request.getUseCache()) writeToCache(cacheKey, response);

    return response;
}

AggregateGroupedSqlBuilder builder = new AggregateGroupedSqlBuilder(request);
AggregateGroupedSqlBuilder.BuildResult buildResult = builder.build();

// buildResult.getSql() => "SELECT dept, SUM(revenue) FROM ... WHERE world_id = ? GROUP BY dept"
// buildResult.getParams() => ["world_main"]

private static final int CACHE_TTL_SECONDS = 30;
private static final String CACHE_KEY_PREFIX = "analytics:grouped:";

private String buildCacheKey(String worldId, String objectType, String requestStr) {
    String raw = worldId + objectType + requestStr;
    return CACHE_KEY_PREFIX + md5(raw);
}

department | region | SUM(revenue)
-----------|--------|-------------
Sales      | East   | 1000         <- 普通行
Sales      | West   | 2000         <- 普通行
Sales      | NULL   | 3000         <- 小计行（Sales 合计）
NULL       | NULL   | 5000         <- 总计行

// TimeBucketSqlBuilder 生成:
// SELECT DATE_FORMAT(created_at, '%Y-%m-%d') AS bucket, SUM(amount)
// FROM orders WHERE world_id = ? AND created_at BETWEEN ? AND ?
// GROUP BY bucket ORDER BY bucket

// TopNSqlBuilder 生成:
// SELECT entity_id, name, SUM(revenue) AS measure
// FROM ... WHERE world_id = ?
// GROUP BY entity_id, name
// ORDER BY measure DESC LIMIT ?

QueryExecutionInfo executionInfo = QueryExecutionInfo.newBuilder()
        .setExecuteMs(executeMs)     // SQL 执行耗时
        .setTotalMs(totalMs)         // 总处理耗时（含缓存查找）
        .setCacheHit(false)          // 是否缓存命中
        .setQueryId(UUID.randomUUID().toString())  // 查询追踪 ID
        .build();