Adiciona novo construtor à classe Fatura com HttpClient

Inclui uma sobrecarga do construtor de Fatura que recebe id, fatura_path e HttpClient, realiza requisição para obter status da fatura, faz parsing do JSON de resposta e inicializa propriedades relevantes, incluindo suporte a faturas agrupadas.

Download Faturas.Tests/divergencias.csv

@@ -1,2 +0,0 @@
-FaturaId	Distribuidora	oldConsumo_P	newConsumo_P	oldConsumo_FP	newConsumo_FP	oldDem_Reg_P	newDem_Reg_P	oldDem_Reg_FP	newDem_Reg_FP	oldEn_Reativa_Mvarh	newEn_Reativa_Mvarh
-3471939		0	0,46028	0	5,23094	0	8,6592	0	11,4144	0	0,04156

Faturas.Tests/4Docs_2025_07.csv

@@ -1,2 +1,19 @@
-"ID	""Doc""	""Status""	""Invalidar""	""Origin""	""Last changed""	""Submitted""	""JSON""	""Name""";;;;;;;;
+"ID"	"Doc"	"Status"	"Invalidar"	"Origin"	"Last changed"	"Submitted"	"JSON"	"Name"
-"3471939	""View | Raw""	""SUCCESS""	""""	""BOT""	""2025-11-11 10:31:03""	""2025-11-11 10:30:41""	""View | Raw""	""1114467.pdf""";;;;;;;;
+"3019848"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-11 10:31:03"	"2025-11-11 10:30:41"	"View | Raw"	"1114467.pdf"
+"3001963"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-05 07:14:49"	"2025-11-05 07:14:33"	"View | Raw"	"1104802.pdf"
+"3001801"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-05 05:38:54"	"2025-11-05 05:38:34"	"View | Raw"	"1104653.pdf"
+"3001795"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-05 05:36:13"	"2025-11-05 05:36:01"	"View | Raw"	"1104647.pdf"
+"2993194"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-04 06:28:45"	"2025-11-04 06:28:29"	"View | Raw"	"1098537.pdf"
+"2988061"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-03 12:12:41"	"2025-11-03 12:12:20"	"View | Raw"	"1095060.pdf"
+"2987758"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-03 11:07:52"	"2025-11-03 11:07:41"	"View | Raw"	"1094871.pdf"
+"2987323"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-03 09:08:33"	"2025-11-03 09:08:18"	"View | Raw"	"1094470.pdf"
+"2987073"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-11-03 07:37:46"	"2025-11-03 07:37:34"	"View | Raw"	"1094220.pdf"
+"2924492"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-15 16:15:59"	"2025-10-10 08:26:03"	"View | Raw"	"1062999.pdf"
+"2906853"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-06 12:50:24"	"2025-10-06 12:50:08"	"View | Raw"	"1058041.pdf"
+"2906573"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-06 12:10:55"	"2025-10-06 12:10:31"	"View | Raw"	"1058009.pdf"
+"2905879"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-06 05:58:46"	"2025-10-06 05:58:29"	"View | Raw"	"1057526.pdf"
+"2903836"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-03 11:42:27"	"2025-10-03 11:42:09"	"View | Raw"	"1056838.pdf"
+"2901834"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-02 10:08:21"	"2025-10-02 10:08:08"	"View | Raw"	"1055842.pdf"
+"2901695"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-02 08:56:24"	"2025-10-02 08:56:17"	"View | Raw"	"1055712.pdf"
+"2901665"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-02 08:42:42"	"2025-10-02 08:42:34"	"View | Raw"	"1055684.pdf"
+"2901319"	"View | Raw"	"SUCCESS"	""	"BOT"	"2025-10-02 06:20:25"	"2025-10-02 06:20:09"	"View | Raw"	"1055363.pdf"

Faturas.Tests/FaturaIntegrationTests.cs

@@ -14,13 +14,13 @@ namespace Download_Faturas.Tests
         public async Task CompareFaturaWithFaturaOld_ShouldReportDifferences()
         {
             // Sample fatura IDs to test (replace with real IDs or fetch dynamically)
-            var faturaIds = LoadCsvColumn("../../../../Faturas.Tests/4Docs_2025_07.csv", 0);
+            var faturaIds = LoadCsvColumn("../../../../Download Faturas.Tests/4Docs_2025_07.csv", 0);
             var differences = new List<string>
             {
                 $"FaturaId\tDistribuidora\toldConsumo_P\tnewConsumo_P\toldConsumo_FP\tnewConsumo_FP\toldDem_Reg_P\tnewDem_Reg_P\toldDem_Reg_FP\tnewDem_Reg_FP\toldEn_Reativa_Mvarh\tnewEn_Reativa_Mvarh"
             };
 
-            using (OleDbConnection conn = new (@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=X:/Middle/Informativo Setorial/Modelo Word/BD1_dados cadastrais e faturas.accdb;Jet OLEDB:Database Password=gds21"))
+            using (OleDbConnection conn = new (@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=X:/Middle/Informativo Setorial/Modelo Word/BD1_Testes.accdb;Jet OLEDB:Database Password=gds21"))
             {
                 // Open the connection to the test database
                 conn.Open();
@@ -51,7 +51,7 @@ namespace Download_Faturas.Tests
 
                     fatura.Processar(conn); // This will also write to DB, but we want to compare without writing
                     var newVal = GetDadosTusd(conn, fatura.CodTusd);
-                    //DeleteTusdRecords(conn, fatura.CodTusd); // Delete old TUSD records before processing
+                    DeleteTusdRecords(conn, fatura.CodTusd); // Delete old TUSD records before processing
 
                     if (!Equals(newVal, oldVal))
                     {
@@ -126,7 +126,7 @@ namespace Download_Faturas.Tests
                     if (line != null)
                     {
                         var values = line.Split('\t');
-                        if (values.Length > columnIndex && (values[4] == "\"\"API\"\"" || values[4] == "\"\"BOT\"\""))
+                        if (values.Length > columnIndex && (values[4] == "\"API\"" || values[4] == "\"BOT\""))
                         {
                             columnData.Add(values[columnIndex].Replace("\"", "").Trim());
                         }

Faturas.Tests/Faturas.Tests.csproj

@@ -6,18 +6,12 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <IsPackable>false</IsPackable>
-    <PlatformTarget>AnyCPU</PlatformTarget>
-    <IsTestProject>true</IsTestProject>
   </PropertyGroup>
 
   <ItemGroup>
     <PackageReference Include="coverlet.collector" Version="6.0.2" />
-    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.1" />
-    <PackageReference Include="xunit.v3" Version="3.2.2" />
+    <PackageReference Include="xunit" Version="2.9.3" />
-    <PackageReference Include="xunit.runner.visualstudio" Version="3.1.5">
-      <PrivateAssets>all</PrivateAssets>
-      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
-    </PackageReference>
   </ItemGroup>
 
   <ItemGroup>

Faturas/Fatura.cs

@@ -34,6 +34,26 @@ namespace Faturas
         /// <param name="id">Identificador da fatura no serviço 4docs.</param>
         /// <param name="fatura_path">Caminho completo para o arquivo PDF da fatura local.</param>
         /// <param name="httpClient">Instância de HttpClient usada para realizar chamadas HTTP à API.</param>
+        public Fatura(string id, JsonElement fatura_Parsed, string fatura_path)
+        {
+            // Utilizado para gerar novo token
+            // this.token = Req_token(HttpClient).ToString();
+            faturaParsed = fatura_Parsed;
+            Agrupada = faturaParsed.TryGetProperty("multiple", out var _);
+            Status = faturaParsed.GetProperty("newStatus").GetString();
+            Arquivo = new FileInfo(fatura_path);
+            this.id = id;
+
+            if (faturaParsed.TryGetProperty("external", out var _))
+            {
+                pagina = JsonDocument.Parse(faturaParsed.GetProperty("external").GetString() !).RootElement.GetProperty("origin")[0].GetProperty("page").GetInt32();
+            }
+
+            if (Agrupada)
+            {
+                Agrupada_children = faturaParsed.GetProperty("children").EnumerateArray();
+            }
+        }
         public Fatura(string id, string fatura_path, HttpClient httpClient)
         {
             // Utilizado para gerar novo token
@@ -49,7 +69,7 @@ namespace Faturas
 
                 if (faturaParsed.GetProperty("external").GetString() is not null)
                 {
-                    pagina = JsonDocument.Parse(faturaParsed.GetProperty("external").GetString() !).RootElement.GetProperty("origin")[0].GetProperty("page").GetInt32();
+                    pagina = JsonDocument.Parse(faturaParsed.GetProperty("external").GetString()!).RootElement.GetProperty("origin")[0].GetProperty("page").GetInt32();
                 }
 
                 if (Agrupada)
@@ -58,7 +78,6 @@ namespace Faturas
                 }
             }
         }
-
         /// <summary>
         /// Initializes a new instance of the <see cref="Fatura"/> class.
         /// Inicializa uma nova instância da classe <see cref="Fatura"/> para faturas já processadas.
@@ -144,36 +163,20 @@ namespace Faturas
 
             dadosTusd.Mes = int.Parse(parsedResult.dates.reading.periodUntil.AddDays(-15).ToString("yMM"));
 
-            string uc = "%" + new Regex("^0+").Replace(parsedResult.locationNumber, string.Empty).Replace("/", string.Empty).Replace("-", string.Empty).Replace(".", string.Empty) + "%";
+            string uc = new Regex("^0+").Replace(parsedResult.locationNumber, string.Empty).Replace("/", string.Empty).Replace("-", string.Empty).Replace(".", string.Empty);
 
             // Vinculo da fatura com os dados cadastrais
             int? unidades;
-            string sqlQuery = $"SELECT COUNT (Cod_Smart_unidade) FROM Dados_cadastrais WHERE Codigo_Instalacao LIKE @uc AND unidade_gerenciada";
+            string sqlQuery = $"SELECT COUNT (Cod_Smart_unidade) FROM Dados_cadastrais WHERE Codigo_Instalacao = @uc AND unidade_gerenciada";
             using (OleDbCommand cmd = new (sqlQuery, conn))
             {
                 cmd.Parameters.AddWithValue("@uc", uc);
 
                 unidades = (int?)cmd.ExecuteScalar();
 
-            }
-            if (unidades == 1)
-            {
-                sqlQuery = $"SELECT Cod_Smart_unidade, Gestao, Cliente, Unidade, PerfilCCEE, Submercado, Status_unidade, Grupo, Perfil, Distribuidora, ICMS_TUSD, Demanda_P, Demanda_FP, Caminho_NFs, Data_de_Migracao FROM Dados_cadastrais WHERE Codigo_Instalacao LIKE @uc AND unidade_gerenciada";
-            }
-            else
-            {
-                uc = parsedResult.locationNumber;
-                sqlQuery = $"SELECT COUNT (Cod_Smart_unidade) FROM Dados_cadastrais WHERE new_number LIKE @uc AND unidade_gerenciada";
-                using (OleDbCommand cmd = new(sqlQuery, conn))
-                {
-                    cmd.Parameters.AddWithValue("@uc", uc);
-
-                    unidades = (int?)cmd.ExecuteScalar();
-
-                }
                 if (unidades == 1)
                 {
-                    sqlQuery = $"SELECT Cod_Smart_unidade, Gestao, Cliente, Unidade, PerfilCCEE, Submercado, Status_unidade, Grupo, Perfil, Distribuidora, ICMS_TUSD, Demanda_P, Demanda_FP, Caminho_NFs, Data_de_Migracao FROM Dados_cadastrais WHERE new_number LIKE @uc AND unidade_gerenciada";
+                    sqlQuery = $"SELECT Cod_Smart_unidade, Gestao, Cliente, Unidade, PerfilCCEE, Submercado, Status_unidade, Grupo, Perfil, Distribuidora, ICMS_TUSD, Demanda_P, Demanda_FP, Caminho_NFs, Data_de_Migracao FROM Dados_cadastrais WHERE Codigo_Instalacao = @uc AND unidade_gerenciada";
                 }
                 else
                 {

Upload Faturas/Program.cs

@@ -4,6 +4,7 @@
 
 namespace Download_Faturas
 {
+    using System.Net;
     using System.Net.Http.Headers;
     using System.Text;
     using System.Text.Json;
@@ -133,7 +134,19 @@ namespace Download_Faturas
                 };
                 multipartContent.ElementAt(0).Headers.Add("Content-Type", "application/pdf");
 
-                multipartContent.Add(new StringContent($"{{\"callbackUrl\":\"https://api.4docs.cloud/v2/null\",\"pipelineName\":\"energy\",\"multiple\":{agrupada.ToString().ToLower()},\"clientData\":{{\"fatura_PATH\":\"{fatura.Replace(",", string.Empty)}\"}}}}"), "json");
+                var payload = new
+                {
+                    callbackUrl = "https://4docs.webhook.smartenergia.com.br/api",
+                    pipelineName = "energy",
+                    multiple = agrupada,
+                    clientData = new
+                    {
+                        fatura_PATH = fatura.Replace(",", string.Empty).Replace("1 - INDIVIDUAIS", "3 - PROCESSANDO"),
+                    },
+                };
+
+                var json = JsonSerializer.Serialize(payload);
+                multipartContent.Add(new StringContent(json, Encoding.UTF8, "application/json"), "json");
 
                 request.Content = multipartContent;
 

Webhook 4docs/Migrations/20260227164052_AddJsonBodyToProcessedInvoices.Designer.cs

@@ -1,55 +0,0 @@
-// <auto-generated />
-using System;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Infrastructure;
-using Microsoft.EntityFrameworkCore.Migrations;
-using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
-using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
-using Webhook_4docs;
-
-#nullable disable
-
-namespace Webhook_4docs.Migrations
-{
-    [DbContext(typeof(WebhookDbContext))]
-    [Migration("20260227164052_AddJsonBodyToProcessedInvoices")]
-    partial class AddJsonBodyToProcessedInvoices
-    {
-        /// <inheritdoc />
-        protected override void BuildTargetModel(ModelBuilder modelBuilder)
-        {
-#pragma warning disable 612, 618
-            modelBuilder
-                .HasAnnotation("ProductVersion", "9.0.0")
-                .HasAnnotation("Relational:MaxIdentifierLength", 63);
-
-            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
-
-            modelBuilder.Entity("Webhook_4docs.ProcessedInvoices", b =>
-                {
-                    b.Property<int>("InvoiceId")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("integer");
-
-                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("InvoiceId"));
-
-                    b.Property<DateTime>("DateTimeProcessed")
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("InvoicePath")
-                        .HasColumnType("text");
-
-                    b.Property<string>("JsonBody")
-                        .HasColumnType("jsonb");
-
-                    b.Property<string>("Status")
-                        .HasColumnType("text");
-
-                    b.HasKey("InvoiceId");
-
-                    b.ToTable("ProcessedInvoices");
-                });
-#pragma warning restore 612, 618
-        }
-    }
-}

Webhook 4docs/Migrations/20260227164052_AddJsonBodyToProcessedInvoices.cs

@@ -1,28 +0,0 @@
-using Microsoft.EntityFrameworkCore.Migrations;
-
-#nullable disable
-
-namespace Webhook_4docs.Migrations
-{
-    /// <inheritdoc />
-    public partial class AddJsonBodyToProcessedInvoices : Migration
-    {
-        /// <inheritdoc />
-        protected override void Up(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.AddColumn<string>(
-                name: "JsonBody",
-                table: "ProcessedInvoices",
-                type: "jsonb",
-                nullable: true);
-        }
-
-        /// <inheritdoc />
-        protected override void Down(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.DropColumn(
-                name: "JsonBody",
-                table: "ProcessedInvoices");
-        }
-    }
-}

Webhook 4docs/Migrations/WebhookDbContextModelSnapshot.cs

@@ -4,7 +4,6 @@ using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
 using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
-using Webhook_4docs;
 
 #nullable disable
 
@@ -17,12 +16,12 @@ namespace Webhook_4docs.Migrations
         {
 #pragma warning disable 612, 618
             modelBuilder
-                .HasAnnotation("ProductVersion", "9.0.0")
+                .HasAnnotation("ProductVersion", "7.0.17")
                 .HasAnnotation("Relational:MaxIdentifierLength", 63);
 
             NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
 
-            modelBuilder.Entity("Webhook_4docs.ProcessedInvoices", b =>
+            modelBuilder.Entity("ProcessedInvoices", b =>
                 {
                     b.Property<int>("InvoiceId")
                         .ValueGeneratedOnAdd()
@@ -36,9 +35,6 @@ namespace Webhook_4docs.Migrations
                     b.Property<string>("InvoicePath")
                         .HasColumnType("text");
 
-                    b.Property<string>("JsonBody")
-                        .HasColumnType("jsonb");
-
                     b.Property<string>("Status")
                         .HasColumnType("text");
 

Webhook 4docs/ProcessedInvoices.cs

@@ -1,5 +1,4 @@
 using System.ComponentModel.DataAnnotations;
-using System.Text.Json;
 
 namespace Webhook_4docs
 {
@@ -10,6 +9,5 @@ namespace Webhook_4docs
         public DateTime DateTimeProcessed { get; set; }
         public string? Status { get; set; }
         public string? InvoicePath { get; set; }
-        public JsonDocument? JsonBody { get; set; }
     }
 }

Webhook 4docs/Program.cs

@@ -13,33 +13,14 @@ namespace Webhook_4docs
         {
             PermitLimit = 1
         });
+
         public static void Main(string[] args)
         {
-            static string IndexedFilename(string stub, string extension)
-            {
-                int ix = 0;
-                string? filename = null;
-
-                if (File.Exists(String.Format("{0}.{1}", stub, extension)))
-                {
-                    do
-                    {
-                        ix++;
-                        filename = String.Format("{0} ({1}).{2}", stub, ix, extension);
-                    } while (File.Exists(filename));
-                }
-                else
-                {
-                    filename = String.Format("{0}.{1}", stub, extension);
-                }
-                return filename;
-            }
-
             var builder = WebApplication.CreateBuilder(args);
             builder.Configuration.AddJsonFile("appsettings.json");
 
             var connectionString = builder.Configuration.GetConnectionString("WebhookDbContext");
-            string? appFolder = builder.Configuration["PathBase"];
+            var appFolder = builder.Configuration["PathBase"];
 
             builder.Services.AddDbContext<WebhookDbContext>(options =>
                 options.UseNpgsql(connectionString)
@@ -51,215 +32,382 @@ namespace Webhook_4docs
                 loggingBuilder.AddConsole();
             });
 
-            // Add services to the container.
             builder.Services.AddRazorPages();
 
             var app = builder.Build();
-
             var logger = app.Services.GetRequiredService<ILogger<Program>>();
 
             using (var scope = app.Services.CreateScope())
             {
                 var dbContext = scope.ServiceProvider.GetRequiredService<WebhookDbContext>();
-                dbContext.Database.EnsureCreated();
                 dbContext.Database.Migrate();
             }
 
-            string fatura_arquivo;
-            // Configure the HTTP request pipeline.
             if (!app.Environment.IsDevelopment())
             {
                 app.UseExceptionHandler("/Error");
-                // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
                 app.UseHsts();
             }
-            
+
-            app.UsePathBase(appFolder);
+            if (!string.IsNullOrWhiteSpace(appFolder))
+            {
+                app.UsePathBase(appFolder);
+            }
 
             app.UseRouting();
-
             app.UseStaticFiles();
-
             app.UseAuthorization();
 
             app.MapRazorPages();
 
-            app.Use((context, next) =>
+            // PATCH /api -> health ou invoice (json)
+            app.MapPatch("/api", async context =>
             {
-                context.Request.PathBase = new PathString(appFolder);
+                var logger = context.RequestServices.GetRequiredService<ILogger<Program>>();
-                return next(context);
+                var bodyText = await SafeReadBodyAsync(context.Request, logger);
+                if (bodyText is null)
+                {
+                    context.Response.StatusCode = StatusCodes.Status400BadRequest;
+                    await context.Response.WriteAsync("Invalid JSON");
+                    return;
+                }
+
+                if (!TryParseJson(bodyText, out var root, logger))
+                {
+                    context.Response.StatusCode = StatusCodes.Status400BadRequest;
+                    await context.Response.WriteAsync("Invalid JSON");
+                    return;
+                }
+
+                // Health: healthy + blame + locationID
+                bool isHealth =
+                    root.TryGetProperty("healthy", out _) &&
+                    root.TryGetProperty("blame", out _) &&
+                    root.TryGetProperty("locationID", out _);
+
+                if (isHealth)
+                {
+                    await ProcessHealthAsync(root, GetCaminhoDb(), logger);
+                    context.Response.StatusCode = StatusCodes.Status200OK;
+                    return;
+                }
+
+                // Invoice: requestID/requestId + json
+                bool hasRequestId = root.TryGetProperty("requestID", out var reqIdEl);
+                bool hasJson = root.TryGetProperty("json", out var dataEl);
+
+                if (hasRequestId && hasJson)
+                {
+                    await ProcessInvoiceAsync(root, dataEl, GetCaminhoDb(), logger, app, reqIdEl.ToString());
+
+                    context.Response.StatusCode = StatusCodes.Status200OK;
+                    return;
+                }
+
+                logger.LogDebug("PATCH /api payload não reconhecido.");
+                context.Response.StatusCode = StatusCodes.Status202Accepted;
             });
 
-            // Endpoint para \api
+            // PUT /api -> somente invoice (result)
-            app.UseEndpoints(endpoints =>
+            app.MapPut("/api", async context =>
             {
-                endpoints.MapControllers();
+                var logger = context.RequestServices.GetRequiredService<ILogger<Program>>();
-                endpoints.MapPatch("/api", async context =>
+                var bodyText = await SafeReadBodyAsync(context.Request, logger);
+                if (bodyText is null)
                 {
-                    
+                    context.Response.StatusCode = StatusCodes.Status400BadRequest;
-                    string requestBody;
+                    await context.Response.WriteAsync("Invalid JSON");
-                    using (var reader = new StreamReader(context.Request.Body, Encoding.UTF8, true, 1024, true))
+                    return;
-                    {
+                }
-                        requestBody = await reader.ReadToEndAsync();
-                    }
 
-                    var JsonBody = JsonDocument.Parse(requestBody).RootElement;
+                if (!TryParseJson(bodyText, out var root, logger))
-                    var JsonBodyDocument = JsonDocument.Parse(requestBody);
-                    string CaminhoDB = "X:/Middle/Informativo Setorial/Modelo Word/BD1_dados cadastrais e faturas.accdb";
-
-                    if (JsonBody.TryGetProperty("requestID", out JsonElement fatura_ID_json))
-                    {
-                        string fatura_ID = fatura_ID_json.ToString();
-
-                        if (!JsonBody.TryGetProperty("json", out JsonElement root)) { return; }
-
-                        JsonElement DadosJson = JsonDocument.Parse(root.ToString()).RootElement;
-
-                        string tipoDocumento = root.Get("documentType").ToString() ?? string.Empty.ToLower();
-
-                        if (tipoDocumento != string.Empty && tipoDocumento != "nota_fiscal")
-                        {
-                            return;
-                        }
-
-                        Fatura fatura = new(fatura_ID, JsonBody);
-                        bool completed = false;
-
-                        while (!completed)
-                        {
-                            var connLease = await connRateLimiter.AcquireAsync();
-
-                            if (connLease.IsAcquired)
-                            {
-                                using (OleDbConnection conn = new(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + CaminhoDB + ";Jet OLEDB:Database Password=gds21"))
-                                {
-                                    if (conn != null)
-                                    {
-                                        if (conn.State == System.Data.ConnectionState.Closed)
-                                        {
-                                            await conn.OpenAsync();
-                                        }
-
-                                        try
-                                        {
-                                            fatura.Processar(conn);
-                                        }
-                                        catch (Exception ex)
-                                        {
-                                            completed = true;
-                                            connLease.Dispose();
-                                            throw new Exception(ex.Message);
-                                        }
-                                    }
-                                }
-                                completed = true;
-                                connLease.Dispose();
-                            }
-                        }
-
-                        string? status = fatura.Status;
-
-                        int status_id = 0;
-
-                        switch (status)
-                        {
-                            case ("FATURA DUPLICADA NO BD"):
-                                status_id = 4;
-                                break;
-                            case ("UNIDADE CONSUMIDORA NÃO LOCALIZADA NO BD"):
-                                status_id = 5;
-                                break;
-                            case ("FATURA INCLUIDA NO BD"):
-                                status_id = 6;
-                                break;
-                            case (_):
-                                status = "ERRO";
-                                status_id = 7;
-                                break;
-                        }
-
-                        try
-                        {
-                            string path = $@"X:\Middle\Carteira {fatura.Gestao![0]}\Carteira {fatura.Gestao}\Faturas fourdocs\{status_id} - {status}";
-                            if (status_id == 6 && fatura.PastaTUSD!.Exists)
-                            {
-                                path = fatura.PastaTUSD!.FullName;
-                            }
-
-                            if (status_id != 4)
-                            {
-                                fatura_arquivo = IndexedFilename($@"{path}\ID {fatura_ID!} -  Mês {fatura.Mes} -  Empresa {fatura.Empresa} -  Unidade {fatura.Unidade}", "pdf");
-                                CriarArquivo(fatura_arquivo, JsonBody.GetProperty("pdfFile").ToString());
-
-                                var DatabaseModel = new ProcessedInvoices
-                                {
-                                    InvoiceId = Int32.Parse(fatura_ID),
-                                    DateTimeProcessed = DateTime.UtcNow,
-                                    Status = status,
-                                    InvoicePath = fatura_arquivo,
-                                    JsonBody = JsonBodyDocument
-                                };
-
-                                logger.LogInformation("Fatura incluída no BD");
-
-                                logger.LogInformation("Fatura salva na pasta " + fatura_arquivo);
-
-                                using (var scope = app.Services.CreateScope())
-                                {
-                                    var dbContext = scope.ServiceProvider.GetRequiredService<WebhookDbContext>();
-                                    dbContext.ProcessedInvoices.Add(DatabaseModel);
-                                    await dbContext.SaveChangesAsync();
-                                }
-                            }
-                            else
-                            {
-                                logger.LogInformation("Fatura duplicada no BD");
-
-                                logger.LogInformation("Fatura descartada");
-                            }
-                        }
-                        catch
-                        {
-                            logger.LogError("Erro no processamento da fatura");
-                        }
-                    }
-                    else if (JsonBody.TryGetProperty("healthy", out _) && JsonBody.TryGetProperty("blame", out _) && JsonBody.TryGetProperty("locationID", out _))
-                    {
-                        double errorID = 0;
-
-                        switch (JsonBody.GetProperty("healthy").GetBoolean(), JsonBody.GetProperty("blame").ToString().ToLower())
-                        {
-                            case (false, "user"):
-                                logger.LogError("Loc ID: " + JsonBody.GetProperty("locationID").ToString() + " Sem acesso");
-                                errorID = 1;
-                                break;
-                            case (false, "system"):
-                                logger.LogError("Loc ID: " + JsonBody.GetProperty("locationID").ToString() + " Com erro de sistema");
-                                errorID = 2;
-                                break;
-                            case (false, _):
-                                logger.LogError("Loc ID: " + JsonBody.GetProperty("locationID").ToString() + " Com erro " + JsonBody.GetProperty("blame").ToString());
-                                errorID = 3;
-                                break;
-                            case (true, _):
-                                //logger.LogInformation("Loc ID: " + JsonBody.GetProperty("locationID").ToString() + " está saudável");
-                                break;
-                        }
-
-                        var errorText = GetErrorText(JsonBody);
-                        await UpdateErrorIdStatusAsync(CaminhoDB, JsonBody.GetProperty("locationID").GetInt64(), errorID, errorText, logger);
-
-                    }
-                });
-                //implementação futura para receber as faturas enviadas via api de forma assíncrona - Upload4Docs (substituir parte do agendador de tarefas)
-                endpoints.MapPut("/api", async context =>
                 {
-                    var a = 10;
+                    context.Response.StatusCode = StatusCodes.Status400BadRequest;
-                    a++;
+                    await context.Response.WriteAsync("Invalid JSON");
-                    await Task.CompletedTask;
+                    return;
-                });
+                }
+
+                // Invoice: requestID/requestId + result
+                bool hasRequestId = root.TryGetProperty("requestId", out var reqIdEl);
+                bool hasResult = root.TryGetProperty("result", out var dataEl);
+
+                if (!(hasRequestId && hasResult))
+                {
+                    logger.LogDebug("PUT /api payload inválido para este endpoint.");
+                    context.Response.StatusCode = StatusCodes.Status400BadRequest;
+                    return;
+                }
+
+                await ProcessInvoiceAsync(root, dataEl, GetCaminhoDb(), logger, app, reqIdEl.ToString());
+
+                context.Response.StatusCode = StatusCodes.Status200OK;
             });
+
             app.Run();
+
+            string GetCaminhoDb() =>
+                @"X:/Middle/Informativo Setorial/Modelo Word/BD1_dados cadastrais e faturas.accdb";
+        }
+
+        // ===== Utilitários de request/JSON =====
+        static async Task<string?> SafeReadBodyAsync(HttpRequest request, ILogger logger, int maxBytes = 10 * 1024 * 1024)
+        {
+            request.EnableBuffering();
+            using var ms = new MemoryStream(capacity: Math.Min(maxBytes, 1024 * 64));
+            await request.Body.CopyToAsync(ms);
+            if (ms.Length > maxBytes)
+            {
+                logger.LogWarning("Payload excede o limite de {MaxBytes} bytes.", maxBytes);
+                return null;
+            }
+            ms.Position = 0;
+            using var reader = new StreamReader(ms, Encoding.UTF8, detectEncodingFromByteOrderMarks: true, bufferSize: 1024, leaveOpen: true);
+            return await reader.ReadToEndAsync();
+        }
+
+        static bool TryParseJson(string text, out JsonElement root, ILogger logger)
+        {
+            try
+            {
+                root = JsonDocument.Parse(text).RootElement.Clone();
+                return true;
+            }
+            catch (JsonException ex)
+            {
+                logger.LogWarning(ex, "Falha ao parsear JSON.");
+                root = default;
+                return false;
+            }
+        }
+
+        // ===== Processamento de Invoice =====
+        static async Task ProcessInvoiceAsync(JsonElement root, JsonElement dataEl, string caminhoDB, ILogger logger, WebApplication app, string fatura_ID)
+        {
+            var tipoDocumento = dataEl.Get("documentType")?.GetString()?.ToLowerInvariant()
+                                ?? string.Empty;
+
+            var deveProcessar = string.IsNullOrEmpty(tipoDocumento) || tipoDocumento == "nota_fiscal";
+            if (!deveProcessar)
+            {
+                logger.LogInformation("Invoice ignorada por tipoDocumento: {TipoDocumento}", tipoDocumento);
+                return;
+            }
+
+            var hasPath = !string.IsNullOrEmpty(root.GetProperty("clientData").ToString());
+
+
+            if (hasPath)
+            {
+                root.GetProperty("clientData").TryGetProperty("fatura_PATH", out var pathEl);
+                await ProcessInvoiceFromPath(root, fatura_ID, pathEl!.GetString()!, caminhoDB, logger, app);
+            }
+            else
+            {
+                await ProcessInvoiceFromJson(root, fatura_ID, caminhoDB, logger, app);
+            }
+        }
+
+        static async Task ProcessInvoiceFromPath(JsonElement root, string fatura_ID, string pdfPath, string caminhoDB, ILogger logger, WebApplication app)
+        {
+            var fatura = new Fatura(fatura_ID, root, pdfPath);
+            var completed = false;
+
+            while (!completed)
+            {
+                var connLease = await connRateLimiter.AcquireAsync();
+                if (!connLease.IsAcquired) continue;
+
+                try
+                {
+                    using var conn = new OleDbConnection(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminhoDB + ";Jet OLEDB:Database Password=gds21");
+                    if (conn.State == System.Data.ConnectionState.Closed)
+                    {
+                        await conn.OpenAsync();
+                    }
+
+                    fatura.Processar(conn);
+                    completed = true;
+                }
+                catch (Exception ex)
+                {
+                    completed = true;
+                    throw new Exception(ex.Message);
+                }
+                finally
+                {
+                    connLease.Dispose();
+                }
+            }
+
+            await FinalizarPersistenciaAsync(fatura, fatura_ID, async targetPath =>
+            {
+                try
+                {
+                    if (!File.Exists(targetPath))
+                    {
+                        fatura.Mover(false);
+                    }
+                }
+                catch (IOException ioEx)
+                {
+                    logger.LogWarning(ioEx, "Falha ao copiar arquivo para {Target}", targetPath);
+                }
+                await Task.CompletedTask;
+            }, logger, app);
+        }
+
+        static async Task ProcessInvoiceFromJson(JsonElement root, string fatura_ID, string caminhoDB, ILogger logger, WebApplication app)
+        {
+            var fatura = new Fatura(fatura_ID, root);
+            var completed = false;
+
+            while (!completed)
+            {
+                var connLease = await connRateLimiter.AcquireAsync();
+                if (!connLease.IsAcquired) continue;
+
+                try
+                {
+                    using var conn = new OleDbConnection(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminhoDB + ";Jet OLEDB:Database Password=gds21");
+                    if (conn.State == System.Data.ConnectionState.Closed)
+                    {
+                        await conn.OpenAsync();
+                    }
+
+                    fatura.Processar(conn);
+                    completed = true;
+                }
+                catch (Exception ex)
+                {
+                    completed = true;
+                    throw new Exception(ex.Message);
+                }
+                finally
+                {
+                    connLease.Dispose();
+                }
+            }
+
+            await FinalizarPersistenciaAsync(fatura, fatura_ID, async targetPath =>
+            {
+                var base64 = root.Get("pdfFile")?.GetString();
+
+                if (string.IsNullOrWhiteSpace(base64))
+                {
+                    logger.LogWarning("Campo pdfFile/pdfFileBase64 ausente no payload.");
+                    return;
+                }
+
+                CriarArquivo(targetPath, base64!);
+                await Task.CompletedTask;
+            }, logger, app);
+        }
+
+        static async Task FinalizarPersistenciaAsync(Fatura fatura, string fatura_ID, Func<string, Task> persistFile, ILogger logger, WebApplication app)
+        {
+            var status = fatura.Status;
+            var status_id = status switch
+            {
+                "FATURA DUPLICADA NO BD" => 4,
+                "UNIDADE CONSUMIDORA NÃO LOCALIZADA NO BD" => 5,
+                "FATURA INCLUIDA NO BD" => 6,
+                _ => 7
+            };
+            status = status_id == 7 ? "ERRO" : status;
+
+            try
+            {
+                var pathBase = $@"X:\Middle\Carteira {fatura.Gestao![0]}\Carteira {fatura.Gestao}\Faturas fourdocs\{status_id} - {status}";
+                if (status_id == 6 && fatura.PastaTUSD!.Exists)
+                {
+                    pathBase = fatura.PastaTUSD!.FullName;
+                }
+
+                if (status_id != 4)
+                {
+                    Directory.CreateDirectory(pathBase);
+                    var targetFile = IndexedFilename($@"{pathBase}\ID {fatura_ID!} -  Mês {fatura.Mes} -  Empresa {fatura.Empresa} -  Unidade {fatura.Unidade}", "pdf");
+
+                    await persistFile(targetFile);
+
+                    var dbModel = new ProcessedInvoices
+                    {
+                        InvoiceId = int.Parse(fatura_ID),
+                        DateTimeProcessed = DateTime.UtcNow,
+                        Status = status,
+                        InvoicePath = targetFile
+                    };
+
+                    logger.LogInformation("Fatura incluída no BD");
+                    logger.LogInformation("Fatura salva na pasta {Arquivo}", targetFile);
+
+                    using var scope = app.Services.CreateScope();
+                    var dbContext = scope.ServiceProvider.GetRequiredService<WebhookDbContext>();
+                    dbContext.ProcessedInvoices.Add(dbModel);
+                    await dbContext.SaveChangesAsync();
+                }
+                else
+                {
+                    logger.LogInformation("Fatura duplicada no BD");
+                    logger.LogInformation("Fatura descartada");
+                }
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "Erro no processamento da fatura");
+            }
+        }
+
+        public static void CriarArquivo(string fatura_arquivo, string pdfFile64)
+        {
+            if (!File.Exists(fatura_arquivo))
+            {
+                byte[] bytes = Convert.FromBase64String(pdfFile64);
+                using var stream = new FileStream(fatura_arquivo, FileMode.CreateNew, FileAccess.Write, FileShare.None);
+                using var writer = new BinaryWriter(stream);
+                writer.Write(bytes, 0, bytes.Length);
+            }
+        }
+
+        static string IndexedFilename(string stub, string extension)
+        {
+            int ix = 0;
+            string? filename;
+
+            if (File.Exists($"{stub}.{extension}"))
+            {
+                do
+                {
+                    ix++;
+                    filename = $"{stub} ({ix}).{extension}";
+                } while (File.Exists(filename));
+            }
+            else
+            {
+                filename = $"{stub}.{extension}";
+            }
+            return filename;
+        }
+
+        // ===== Processamento de Health =====
+        static async Task ProcessHealthAsync(JsonElement jsonBody, string caminhoDB, ILogger logger)
+        {
+            var healthy = jsonBody.GetProperty("healthy").GetBoolean();
+            var blame = jsonBody.GetProperty("blame").GetString()?.ToLowerInvariant() ?? string.Empty;
+            var locationId = jsonBody.GetProperty("locationID").ToString();
+
+            var (errorID, logAction) = (healthy, blame) switch
+            {
+                (false, "user")    => (1d, (Action)(() => logger.LogError("Loc ID: {LocationId} Sem acesso", locationId))),
+                (false, "system")  => (2d, (Action)(() => logger.LogError("Loc ID: {LocationId} Com erro de sistema", locationId))),
+                (false, var other) => (3d, (Action)(() => logger.LogError("Loc ID: {LocationId} Com erro {Blame}", locationId, other))),
+                (true, _)          => (0d, (Action)(() => { }))
+            };
+
+            logAction();
+
+            var errorText = GetErrorText(jsonBody);
+            await UpdateErrorIdStatusAsync(caminhoDB, jsonBody.GetProperty("locationID").GetInt64(), errorID, errorText, logger);
         }
         //tenta pegar o deactivationReport, se não conseguir ou for null, tenta pegar o websiteText, se não conseguir ou for null, tenta pegar o systemText. As propriedades podem não exisir
         public static string GetErrorText(JsonElement root)
@@ -285,6 +433,7 @@ namespace Webhook_4docs
 
             return errorText;
         }
+
         public static async Task<int> UpdateErrorIdStatusAsync(string CaminhoDB, double location_id, double errorID, string systemText, ILogger logger)
         {
             int test = 0;
@@ -299,40 +448,35 @@ namespace Webhook_4docs
                 {
                     try
                     {
-                        using (OleDbConnection conn = new (@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + CaminhoDB + ";Jet OLEDB:Database Password=gds21"))
+                        using (OleDbConnection conn = new(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + CaminhoDB + ";Jet OLEDB:Database Password=gds21"))
                         {
                             await conn.OpenAsync();
 
-                            using (OleDbCommand cmd = new (
+                            using (OleDbCommand cmd = new(
                                 @"UPDATE AgVirtual4Docs 
                                   SET errorID = @errorID, status = @status
                                   WHERE location_id = @location_id", conn))
                             {
-                                // Adiciona parâmetros de forma segura
                                 cmd.Parameters.AddWithValue("@errorID", errorID);
                                 cmd.Parameters.AddWithValue("@status", systemText);
                                 cmd.Parameters.AddWithValue("@location_id", location_id);
 
-                                // Executa o comando e captura o resultado
                                 test = await cmd.ExecuteNonQueryAsync();
                             }
                         }
 
-                        break; // Sai do loop em caso de sucesso
+                        break;
                     }
                     catch (OleDbException ex)
                     {
-                        // Registra o erro
                         logger.LogInformation($"Erro no OleDb update: {ex.Message} (Tentativa {attempt + 1} de {maxRetries})");
 
                         if (attempt < maxRetries - 1)
                         {
-                            // Aguarda antes de tentar novamente
+                            await Task.Delay(1000 * (int)Math.Pow(2, attempt));
-                            await Task.Delay(1000 * (int)Math.Pow(2, attempt)); // Retry com Backoff Exponencial
                         }
                         else
                         {
-                            // Propaga a exceção na última tentativa
                             throw;
                         }
                     }
@@ -341,32 +485,17 @@ namespace Webhook_4docs
                         connLease.Dispose();
                     }
 
-                    attempt++; // Incrementa a tentativa após adquirir o lease, mesmo que falhe
+                    attempt++;
                 }
                 else
                 {
-                    // Aguarda um curto período antes de tentar novamente se não conseguiu adquirir o lease
                     await Task.Delay(200);
                 }
             }
-
             return test;
         }
-        public static void CriarArquivo(string fatura_arquivo, string pdfFile64)
-        {
-            //string fatura_arquivo = Environment.GetFolderPath(Environment.SpecialFolder.Desktop) + @"\test.pdf";
-            if (!File.Exists(fatura_arquivo))
-            {
-                byte[] bytes = Convert.FromBase64String(pdfFile64);
-
-                System.IO.FileStream stream = new(fatura_arquivo, FileMode.CreateNew);
-                System.IO.BinaryWriter writer =
-                    new(stream);
-                writer.Write(bytes, 0, bytes.Length);
-                writer.Close();
-            }
-        }
     }
+
     public static partial class JsonExtensions
     {
         public static JsonElement? Get(this JsonElement element, string name) =>
@@ -377,7 +506,7 @@ namespace Webhook_4docs
         {
             if (element.ValueKind == JsonValueKind.Null || element.ValueKind == JsonValueKind.Undefined)
                 return null;
-            // Throw if index < 0
+
             return index < element.GetArrayLength() ? element[index] : null;
         }
     }

Webhook 4docs/WebhookDbContext.cs

@@ -1,25 +1,9 @@
 using Microsoft.EntityFrameworkCore;
-using System.Text.Json;
 
 namespace Webhook_4docs
 {
     public class WebhookDbContext(DbContextOptions<WebhookDbContext> options) : DbContext(options)
     {
         public DbSet<ProcessedInvoices> ProcessedInvoices { get; set; }
-
-        protected override void OnModelCreating(ModelBuilder modelBuilder)
-        {
-            base.OnModelCreating(modelBuilder);
-
-            modelBuilder.Entity<ProcessedInvoices>()
-                .Property(p => p.JsonBody)
-                .HasColumnType("jsonb")
-                .HasConversion(
-                    v => v == null ? null : v.RootElement.GetRawText(),
-                    v => v == null ? null : ParseJsonDocument(v));
-        }
-
-        private static JsonDocument ParseJsonDocument(string json)
-            => JsonDocument.Parse(json);
     }
 }

Webhook 4docs/appsettings.json

@@ -1,4 +1,4 @@
-{
+{
     "Logging": {
         "LogLevel": {
             "Default": "Information",
@@ -17,7 +17,7 @@
     "Kestrel": {
         "Endpoints": {
             "HttpLocalhost": {
-                "Url": "http://localhost:8662/"
+                "Url": "http://*:8664/"
             }
         }
     },