app.MapGet("/stations/{id}",
    async Task<Results<Ok<StationDto>, NotFound, ProblemHttpResult>> 
    (long id, IStationService service) =>
{
    var station = await service.GetAsync(id);
    return station is null
        ? TypedResults.NotFound()
        : TypedResults.Ok(station);
});

public class OperatorContextFilter : IEndpointFilter
{
    public async ValueTask<object?> InvokeAsync(
        EndpointFilterInvocationContext ctx,
        EndpointFilterDelegate next)
    {
        // 解析运营商上下文
        OperatorContext.Current = Resolve(ctx.HttpContext);
        return await next(ctx);
    }
}

app.MapGroup("/api/charge")
   .AddEndpointFilter<OperatorContextFilter>()
   .RequireAuthorization("OperatorPolicy")
   .MapPost("/start", StartCharge);

public static class StationEndpoints
{
    public static IEndpointRouteBuilder MapStation(this IEndpointRouteBuilder app)
    {
        var group = app.MapGroup("/api/station")
            .RequireAuthorization();

        group.MapGet("/{id}", GetStation);
        group.MapPost("/", CreateStation);

        return app;
    }
}

app.MapPost("/agent/charge/analyze",
    async (ChargeAnalyzeRequest req, IChargeAnalyzer analyzer) =>
{
    return TypedResults.Ok(await analyzer.AnalyzeAsync(req));
});

app.MapGet("/bff/station/{id}",
    async (long id, IStationApi api, IPriceApi priceApi) =>
{
    var station = await api.Get(id);
    var price = await priceApi.GetPrice(id);
    return TypedResults.Ok(new StationView(station, price));
});