Exemplos de uso do Gateway.Client

using Colosoft.Data.Analytics.Gateway.Client;

ICubeSchema schema = new CubeSchemaBuilder()
    .AddDimension("IdCliente")
    .AddDimension("Nome")
    .AddDimension("TipoCliente")
    .AddDimension("Uf")
    .AddDimension(
        "Situacao",
        filterMap: new Dictionary<string, string>
        {
            ["Ativo"] = "0",
            ["Inativo"] = "1",
        })
    .AddCount("Count")
    .AddSum("SumOfLimite", "Limite")
    .AddSum("SumOfUsoLimite", "UsoLimite")
    .AddCondition(filterExpression)
    .Build();

ICubeSchema schema = new CubeSchemaBuilder()
    // dimensão computada via expressão SQL, com tradução de valor em ambas as direções
    .AddDimension(
        "MesDataCadastro", CubeDimensionType.Field,
        new[] { "LPAD(MONTH(DataCadastro), 2, '0')" }, "Mês Cadastro",
        filterMap: meses.ToDictionary(f => f.Nome, f => f.Numero.ToString("00")),
        labelMap: meses.ToDictionary(f => f.Numero.ToString("00"), f => f.Nome))
    // medida com expressão de agregação SQL customizada (AddMeasure genérico + FirstValue)
    .AddMeasure(
        "SumOfPercentualRentabilidade",
        CubeMeasureType.FirstValue,
        parameters: new[] { "SUM(ValorRentabilidade) / SUM(TotalPedido) * 100" },
        labelText: "Percentual Rentabilidade")
    .Build();

IPivotReport totalClientes = new PivotReportBuilder()
    .Id("quantidadeClientes")
    .Name("Clientes")
    .AddMeasure("Count")
    .ChartType("singleValue")
    .Build();

IPivotReport clientesPorTipo = new PivotReportBuilder()
    .Id("tipoCliente")
    .Name("Tipo Cliente")
    .AddRow("TipoCliente")
    .AddMeasure(m => m.Name("Count").Percentage(PercentageMode.ColumnTotal))
    .ChartType("horizontalStackedBar")
    .Chart(chart => chart.XAxis(axis => axis.Labels(label => label.Show(false))))
    .Labels(otherText: null, emptyText: "Sem tipo")
    .OrderBy(o => o.Values(TableAxis.Rows, null, ListSortDirection.Descending, 0))
    .JavaScriptNumberFormat(0, f => f
        .Locale("pt-BR")
        .MinimumFractionDigits(2)
        .MaximumFractionDigits(2)
        .Suffix("%"))
    .Build();

IPivotReport producaoPorHora = new PivotReportBuilder()
    .Id("producaoPorHora")
    .Name("Produção por Hora")
    .AddRow("SetorSequencial", labelText: "Setor", allowFilter: false)
    .AddColumn("HoraDataLeitura", " ", allowFilter: false, format: "{0}h")
    .Labels(otherText: null, emptyText: " ", totalsRowText: "Totais", totalsColumnText: "Totais")
    .AddMeasure(m => m
        .Name("SumOfMetragemQuadrada")
        .Heatmap(HeatmapMode.Row)
        .HeatmapColor(0x0000FF.ToString())
        .Format("{0:#0.00}"))
    .JavaScriptNumberFormat(0, f => f.Locale("pt-BR").MaximumFractionDigits(2).Suffix(" m²"))
    .Build();

IPivotReport capacidadeLida = new PivotReportBuilder()
    .Id("capacidadeLida")
    .Name("Previsto/Realizado Por Setor")
    .AddColumn("NumeroSequenciaSetor", format: "{0:#00}")
    .AddColumn("Setor")
    .AddMeasure(m => m.Name("MaxOfCapacidadeDiaria").LabelText("Capacidade"))
    .AddMeasure(m => m.Name("SumOfMetragemQuadrada").LabelText("Lida"))
    .ChartType("bar")
    .Chart(chart => chart
        .Colors(new[] { "#F08C41", "#118DFF", "#4CBA36", "#991717" })
        .Chart(c => c.Toolbar(t => t.Show(false)))
        .DataLabels(d => d.Enabled(false)))
    .Build();

IPivotReport rentabilidadePorCliente = new PivotReportBuilder()
    .Id("rentabilidadePorCliente")
    .Name("Rentabilidade por Cliente")
    .AddRow("DescricaoProduto", labelText: "Produto")
    .AddRow("Rota", labelText: "Rota")
    .AddRow("Cliente", labelText: "Cliente")
    .ExpandCollapse(true)
    .AddMeasure(m => m
        .Name("SumOfValorRentabilidade")
        .LabelText("Acumulado")
        .RunningTotal(RunningValuePivotTableDirection.Row))
    .ChartType("line")
    .Chart(chart => chart.Legend(legend => legend
        .Position(LegendPosition.Bottom)
        .ShowForSingleSeries(true)))
    .OrderBy(o => o.Values(TableAxis.Rows, null, ListSortDirection.Descending, 0))
    .Build();

ITableReport detalhamentoCliente = new TableReportBuilder()
    .Id("detalhamento")
    .Name("Detalhamento do cliente")
    .AddColumn("IdCliente")
    .AddColumn("Nome", labelText: "Cliente")
    .AddColumn("CpfCnpj", labelText: "Cpf/Cnpj")
    .AddColumn("DataCadastro", format: "{0:dd/MM/yyyy}")
    .AddColumn("Situacao")
    .LimitRows(1)
    .Build();

ITableReport itensPedido = new TableReportBuilder()
    .Id("itensPedido")
    .Name("Itens do Pedido")
    .AddColumn("Peso", format: "{0:#0.00}", isTotal: true)
    .AddColumn("TotalPedido", labelText: "Total do Pedido", format: "{0:C}", isTotal: true)
    .AddOrderBy("DataCadastro", ListSortDirection.Descending)
    .LimitRows(50)
    .Build();

ISourceDatabase source = new SourceDatabaseBuilder()
    .Configure(query) // consulta expondo as colunas declaradas no schema
    .DataReaderProvider(builder => builder
        .Column(
            "Situacao",
            (_, value) => ((SituacaoCliente)Convert.ToInt32(value)).Translate().Format()))
    .Build();

// 1. Empacota schema + fonte + conexão em um cubo
var cubeFactory = new DatabaseCubeFactory();
IDatabaseCube cube = cubeFactory.Create(
    schema,
    source,
    cancellationToken => Task.FromResult<IDbConnection>(connection),
    leaveOpen: true);

// 2. Abre a conexão SignalR com o Gateway
var compilerFactory = new CubeCompilerFactory(
    "https://seu-gateway/gateway/cubecompiler",
    authenticator); // null se o Gateway não exigir autenticação

using (var compiler = await compilerFactory.Create(CultureInfo.GetCultureInfo("pt-BR"), cancellationToken))
{
    // 3. Registra um observer para receber o resultado compilado
    compiler.Add(new CubeCompilerObserver(
        onResultItem: async (compiledReport, content, contentType, ct) =>
        {
            // content: Stream com o relatório compilado, no formato pedido abaixo
        }));

    // 4. Compila o cubo contra um ou mais relatórios de uma vez
    await compiler.Compile(
        cube,
        new[] { new CubeCompilerReport(report, CubeCompilerReportOutputType.Html) },
        cancellationToken);
}

var authenticator = new UserAuthenticator(
    authenticationEndpoint: new Uri("https://seu-identity-server/connect/token"),
    username: "usuario",
    password: "senha",
    organizationId: "org-id");

var compilerFactory = new CubeCompilerFactory(
    "https://seu-gateway/gateway/cubecompiler",
    authenticator);

IFilter filter = new FilterBuilder()
    .AddConditional("Uf", "=", "SP")
    .Expression("IdCliente in (1,2,3)", "sql")
    .Build();

IPivotReport report = new PivotReportBuilder()
    .Id("clientesFiltrados")
    .Name("Clientes")
    .AddRow("Nome")
    .AddMeasure("Count")
    .FilterConfiguration(filter)
    .Build();