fix: 651

Merged PR 215: delete workflow documenti emessi with semestrale/annuale

Related work items: #651

Author: mg-dgsspa

.gitignore

@@ -550,4 +550,3 @@ nul
 src/Presentation/PortaleFatture.BE.ImportFattureGrandiAderenti/data/fatture/primo saldo/FatturePagoPa_04_2025.json
 src/Presentation/PortaleFatture.BE.ImportFattureGrandiAderenti/data/fatture/primo saldo/FatturePagoPa_05_2025.json
 src/Presentation/PortaleFatture.BE.ImportFattureGrandiAderenti/data/fatture/primo saldo/FatturePagoPa_06_2025.json
-src/Presentation/PortaleFatture.BE.ImportFattureGrandiAderenti/data/fatture/primo saldo/DEVS/FatturePagoPa_01_2025.json

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Contestazioni/Queries/Persistence/Builder/ContestazioniMassiveSQLBuilder.cs

@@ -264,7 +264,7 @@ public static string SelectContestazioneEnteAnniMesi()
 FROM 
     [pfw].[ContestazioniCalendario]
 WHERE 
-    [DataVerifica] >= SYSDATETIMEOFFSET() AT TIME ZONE 'UTC' AT TIME ZONE 'Central European Standard Time'
+    DATEADD(day, 30, [DataFine]) >= SYSDATETIMEOFFSET() AT TIME ZONE 'UTC' AT TIME ZONE 'Central European Standard Time'
 ORDER BY 
     [AnnoContestazione] DESC, 
     [MeseContestazione] DESC;

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/CommandHandlers/FatturaCancellazioneCommandHandler.cs

@@ -0,0 +1,43 @@
+using MediatR;
+using Microsoft.Extensions.Localization;
+using Microsoft.Extensions.Logging;
+using PortaleFatture.BE.Core.Entities.Storici;
+using PortaleFatture.BE.Core.Extensions;
+using PortaleFatture.BE.Core.Resources;
+using PortaleFatture.BE.Infrastructure.Common.Persistence.Schemas;
+using PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.Commands;
+using PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.Commands.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.Storici.Commands;
+using PortaleFatture.BE.Infrastructure.Common.Storici.Commands.Persistence;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.CommandHandlers;
+
+public class FatturaCancellazioneRipristinoCommandHandler(
+ IFattureDbContextFactory factory,
+ IMediator handler,
+ IStringLocalizer<Localization> localizer,
+ ILogger<FatturaCancellazioneRipristinoCommandHandler> logger) : IRequestHandler<FatturaCancellazioneRipristinoCommand, bool?>
+{
+    private readonly IFattureDbContextFactory _factory = factory;
+    private readonly IMediator _handler = handler;
+    private readonly ILogger<FatturaCancellazioneRipristinoCommandHandler> _logger = logger;
+    private readonly IStringLocalizer<Localization> _localizer = localizer;
+
+    public async Task<bool?> Handle(FatturaCancellazioneRipristinoCommand command, CancellationToken ct)
+    {
+        using var uow = await _factory.Create(cancellationToken: ct);
+        var rowAffected = await uow.Execute(new FatturaCancellazioneRipritistinoCommandPersistence(command, _localizer), ct); 
+        if (rowAffected == 1)
+        {
+            using var uow2 = await _factory.Create(cancellationToken: ct);
+            await uow2.Execute(new StoricoCreateCommandPersistence(new StoricoCreateCommand(
+                     command.AuthenticationInfo!,
+                     DateTime.UtcNow.ItalianTime(),
+                     command.Cancellazione ? TipoStorico.CancellazioneFatture : TipoStorico.RipristionFatture,
+                     command.Serialize())), ct);
+            return true;
+        }
+        else
+            return false;
+    }
+}

src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/CommandHandlers/FatturaCancellazioneRipristinoCommandHandler.cs

@@ -3,7 +3,7 @@
 
 namespace PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.Commands;
 
-public class FatturaCancellazioneCommand(IAuthenticationInfo? authenticationInfo, long[]? idFatture, bool cancellazione) : IRequest<bool?>
+public class FatturaCancellazioneRipristinoCommand(IAuthenticationInfo? authenticationInfo, long[]? idFatture, bool cancellazione) : IRequest<bool?>
 {
     public IAuthenticationInfo? AuthenticationInfo { get; internal set; } = authenticationInfo;
     public long[]? IdFatture { get; set; } = idFatture;

…/Commands/FatturaCancellazioneCommand.cs …FatturaCancellazioneRipristinoCommand.cssrc/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/Commands/FatturaCancellazioneCommand.cs renamed to src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/Commands/FatturaCancellazioneRipristinoCommand.cs src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/Commands/FatturaCancellazioneCommand.cs renamed to src/Infrastructure/PortaleFatture.BE.Infrastructure/Common/SEND/Fatture/Commands/FatturaCancellazioneRipristinoCommand.cs

@@ -0,0 +1,37 @@
+using System.Data;
+using Dapper;
+using Microsoft.Extensions.Localization;
+using PortaleFatture.BE.Core.Resources;
+using PortaleFatture.BE.Infrastructure.Common.Persistence;
+using PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.Extensions;
+
+namespace PortaleFatture.BE.Infrastructure.Common.SEND.Fatture.Commands.Persistence;
+
+public class FatturaCancellazioneRipritistinoCommandPersistence(FatturaCancellazioneRipristinoCommand command, IStringLocalizer<Localization> localizer) : DapperBase, ICommand<int>
+{
+    public bool RequiresTransaction => false;
+    private readonly FatturaCancellazioneRipristinoCommand _command = command;
+    private readonly IStringLocalizer<Localization> _localizer = localizer;
+
+    public async Task<int> Execute(IDbConnection? connection, string schema, IDbTransaction? transaction, CancellationToken cancellationToken = default)
+    {
+        var dataTable = _command.IdFatture!.CreateRipristinoFattureTable();
+
+        var procedureName = _command.Cancellazione == true
+            ? $"pfd.SospendiFattura"
+            : $"pfd.RipristinaFattura";
+
+        var parameterName = _command.Cancellazione == true
+            ? "@SospendiFatture"
+            : "@RipristinoFatture";
+
+        var tableTypeName = $"pfd.RipristinoFatture";
+
+        var parameters = new DynamicParameters();
+        parameters.Add(parameterName, dataTable.AsTableValuedParameter(tableTypeName));
+        parameters.Add("@ReturnValue", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue);
+
+
+        return await ((IDatabase)this).SingleAsync<int>(connection!, procedureName, parameters, transaction, CommandType.StoredProcedure); 
+    }
+}