feat: 547

Gestione Filtri.  Related work items: #547

Author: mg-dgsspa

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/Persistence/Builder/RelTestataSQLBuilder.cs

@@ -1,7 +1,16 @@
 namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence.Builder;
 
 internal static class RelTestataSQLBuilder
-{
+{ 
+    private static string _sqlAnni = @"
+SELECT distinct(year)
+  FROM [pfd].[RelTestata] 
+";
+
+    private static string _sqlMesi = @"
+SELECT distinct(month)
+  FROM [pfd].[RelTestata]
+";
 
     private static string _sqlDistinctTipologiaFatturaPagoPA = @"
 SELECT TipologiaFattura
@@ -149,4 +158,22 @@ public static string OrderByDistinctTipologiaFattura()
     {
         return " ORDER BY ordine ";
     }
+
+    public static string SelectAnni()
+    {
+        return _sqlAnni;
+    }
+
+    public static string SelectMesi()
+    {
+        return _sqlMesi;
+    }
+
+    public static string OrderByMonth = " order by month desc";
+
+    public static string OrderByYear= " order by year desc";
+
+    public static string GroupByOrderByYear = " group by year, internal_organization_id, contract_id order by year desc";
+
+    public static string GroupByMonthByYear = " group by year, month, internal_organization_id, contract_id  order by month desc";
 }

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/Persistence/RelAnniQueryByIdEntePersistence.cs

@@ -0,0 +1,24 @@
+using System.Data;
+using System.Dynamic;
+using PortaleFatture.BE.Infrastructure.Common.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence.Builder;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence;
+
+public class RelAnniQueryByIdEntePersistence(RelAnniByIdEnteQuery command) : DapperBase, IQuery<IEnumerable<string>?>
+{
+    private readonly RelAnniByIdEnteQuery _command = command;
+    private static readonly string _sql = RelTestataSQLBuilder.SelectAnni();
+    private static readonly string _orderBy = RelTestataSQLBuilder.GroupByOrderByYear;
+    public async Task<IEnumerable<string>?> Execute(IDbConnection? connection, string schema, IDbTransaction? transaction, CancellationToken cancellationToken = default)
+    {
+        var authInfo = _command.AuthenticationInfo;
+        dynamic parameters = new ExpandoObject();
+
+        var where = " WHERE internal_organization_id=@IdEnte ";
+        parameters.IdEnte = authInfo.IdEnte; 
+
+        return await ((IDatabase)this).SelectAsync<string>(
+            connection!, _sql + where + _orderBy, parameters, transaction);
+    }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/Persistence/RelAnniQueryPersistence.cs

@@ -0,0 +1,18 @@
+using System.Data;
+using PortaleFatture.BE.Infrastructure.Common.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence.Builder;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence;
+
+public class RelAnniQueryPersistence(RelAnniQuery command) : DapperBase, IQuery<IEnumerable<string>?>
+{
+    private readonly RelAnniQuery _command = command;
+    private static readonly string _sql = RelTestataSQLBuilder.SelectAnni();
+    private static readonly string _orderBy = RelTestataSQLBuilder.OrderByYear;
+    public async Task<IEnumerable<string>?> Execute(IDbConnection? connection, string schema, IDbTransaction? transaction, CancellationToken cancellationToken = default)
+    {
+
+        return await ((IDatabase)this).SelectAsync<string>(
+            connection!, _sql + _orderBy, _command, transaction);
+    }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/Persistence/RelMesiByIdEnteQueryPersistence.cs

@@ -0,0 +1,24 @@
+using System.Data;
+using System.Dynamic;
+using PortaleFatture.BE.Infrastructure.Common.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence.Builder;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence;
+
+public class RelMesiByIdEnteQueryPersistence(RelMesiByIdEnteQuery command) : DapperBase, IQuery<IEnumerable<string>?>
+{
+    private readonly RelMesiByIdEnteQuery _command = command;
+    private static readonly string _sql = RelTestataSQLBuilder.SelectMesi();
+    private static readonly string _orderBy = RelTestataSQLBuilder.GroupByMonthByYear;
+    public async Task<IEnumerable<string>?> Execute(IDbConnection? connection, string schema, IDbTransaction? transaction, CancellationToken cancellationToken = default)
+    {
+        var authInfo = _command.AuthenticationInfo;
+        dynamic parameters = new ExpandoObject(); 
+        var where = " WHERE year=@anno ";
+        parameters.Anno = _command.Anno;
+        where += " AND internal_organization_id=@IdEnte ";
+        parameters.IdEnte = authInfo.IdEnte; 
+        return await ((IDatabase)this).SelectAsync<string>(
+            connection!, _sql + where + _orderBy, parameters, transaction);
+    }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/Persistence/RelMesiQueryPersistence.cs

@@ -0,0 +1,26 @@
+using System.Data;
+using System.Dynamic;
+using PortaleFatture.BE.Infrastructure.Common.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence.Builder;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence;
+
+public class RelMesiQueryPersistence(RelMesiQuery command) : DapperBase, IQuery<IEnumerable<string>?>
+{
+    private readonly RelMesiQuery _command = command;
+    private static readonly string _sql = RelTestataSQLBuilder.SelectMesi();
+    private static readonly string _orderBy = RelTestataSQLBuilder.OrderByMonth;
+    public async Task<IEnumerable<string>?> Execute(IDbConnection? connection, string schema, IDbTransaction? transaction, CancellationToken cancellationToken = default)
+    {
+        dynamic parameters = new ExpandoObject();
+        var where = string.Empty;
+        if (!string.IsNullOrEmpty(_command.Anno))
+        {
+            where += " WHERE year=@anno ";
+            parameters.Anno = _command.Anno;
+        }
+
+        return await ((IDatabase)this).SelectAsync<string>(
+            connection!, _sql + where + _orderBy, parameters, transaction);
+    }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/RelAnniByIdEnteQuery.cs

@@ -0,0 +1,9 @@
+using MediatR;
+using PortaleFatture.BE.Core.Auth;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries; 
+public class RelAnniByIdEnteQuery(IAuthenticationInfo authenticationInfo) : IRequest<IEnumerable<string>?>
+{
+    public IAuthenticationInfo AuthenticationInfo { get; internal set; } = authenticationInfo; 
+    public string? IdContratto { get; set; }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/RelAnniQuery.cs

@@ -0,0 +1,8 @@
+using MediatR;
+using PortaleFatture.BE.Core.Auth;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries; 
+public class RelAnniQuery(IAuthenticationInfo authenticationInfo) : IRequest<IEnumerable<string>?>
+{
+    public IAuthenticationInfo AuthenticationInfo { get; internal set; } = authenticationInfo;
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/RelMesiByIdEnteQuery.cs

@@ -0,0 +1,13 @@
+using MediatR;
+using PortaleFatture.BE.Core.Auth;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries;
+
+public class RelMesiByIdEnteQuery(IAuthenticationInfo authenticationInfo) : IRequest<IEnumerable<string>?>
+{
+    public IAuthenticationInfo AuthenticationInfo { get; internal set; } = authenticationInfo;
+
+    public string? Anno { get; set; }
+
+    public string? IdContratto { get; set; }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/Queries/RelMesiQuery.cs

@@ -0,0 +1,11 @@
+using MediatR;
+using PortaleFatture.BE.Core.Auth;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries;
+
+public class RelMesiQuery(IAuthenticationInfo authenticationInfo) : IRequest<IEnumerable<string>?>
+{
+    public IAuthenticationInfo AuthenticationInfo { get; internal set; } = authenticationInfo;
+
+    public string? Anno { get; set; }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/DatiRel/QueryHandlers/RelAnniByIdEnteHandler.cs

@@ -0,0 +1,24 @@
+using MediatR;
+using Microsoft.Extensions.Localization;
+using Microsoft.Extensions.Logging;
+using PortaleFatture.BE.Core.Resources;
+using PortaleFatture.BE.Infrastructure.Common.Persistence.Schemas;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries;
+using PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.Queries.Persistence;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.DatiRel.QueryHandlers;
+
+public class RelAnniByIdEnteHandler(
+ IFattureDbContextFactory factory,
+ IStringLocalizer<Localization> localizer,
+ ILogger<RelAnniByIdEnteHandler> logger) : IRequestHandler<RelAnniByIdEnteQuery, IEnumerable<string>?>
+{
+    private readonly IFattureDbContextFactory _factory = factory;
+    private readonly ILogger<RelAnniByIdEnteHandler> _logger = logger;
+    private readonly IStringLocalizer<Localization> _localizer = localizer;
+    public async Task<IEnumerable<string>?> Handle(RelAnniByIdEnteQuery request, CancellationToken ct)
+    {
+        using var rs = await _factory.Create(cancellationToken: ct);
+        return await rs.Query(new RelAnniQueryByIdEntePersistence(request), ct);
+    }
+}