Merge branch 'develop' into UPBE-602-be-creazione-api-download-report

# Conflicts:
#	src/main/java/it/gov/pagopa/idpay/transactions/controller/ReportController.java
#	src/main/java/it/gov/pagopa/idpay/transactions/controller/ReportControllerImpl.java
#	src/main/java/it/gov/pagopa/idpay/transactions/service/ReportService.java
#	src/main/java/it/gov/pagopa/idpay/transactions/service/ReportServiceImpl.java
#	src/test/java/it/gov/pagopa/idpay/transactions/service/ReportServiceImplTest.java

Author: v1tt0ri0Alt

pom.xml

@@ -91,6 +91,16 @@
 			<artifactId>janino</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>com.azure.resourcemanager</groupId>
+			<artifactId>azure-resourcemanager-datafactory</artifactId>
+			<version>1.2.0</version>
+		</dependency>
+		<dependency>
+			<groupId>com.azure</groupId>
+			<artifactId>azure-identity</artifactId>
+		</dependency>
+
 		<!--TEST-->
 		<dependency>
 			<groupId>org.springframework.boot</groupId>

src/main/java/it/gov/pagopa/idpay/transactions/controller/ReportController.java

@@ -1,12 +1,19 @@
 package it.gov.pagopa.idpay.transactions.controller;
 
-import it.gov.pagopa.idpay.transactions.dto.*;
+import it.gov.pagopa.idpay.transactions.dto.PatchReportRequest;
+import it.gov.pagopa.idpay.transactions.dto.ReportDTO;
+import it.gov.pagopa.idpay.transactions.dto.ReportListDTO;
+import it.gov.pagopa.idpay.transactions.dto.ReportRequest;
+import it.gov.pagopa.idpay.transactions.dto.report.Report2RunDto;
+import it.gov.pagopa.idpay.transactions.dto.report.ReportGenerateForce;
 import jakarta.validation.Valid;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.web.PageableDefault;
 import org.springframework.web.bind.annotation.*;
 import reactor.core.publisher.Mono;
 
+import java.util.List;
+
 @RequestMapping("/idpay/merchant/portal")
 public interface ReportController {
 
@@ -32,6 +39,9 @@ Mono<ReportDTO> generateReport(@RequestHeader("x-merchant-id") String merchantId
                                                        @PathVariable("initiativeId") String initiativeId,
                                                        @RequestBody @Valid ReportRequest request);
 
+    @PostMapping("/reports/transaction/force")
+    Mono<List<Report2RunDto>> forceGenerateReports(@RequestBody ReportGenerateForce reportGenerateForce);
+
 
     @PatchMapping("/initiatives/{initiativeId}/reports/{reportId}")
     Mono<ReportDTO> patchReport(@PathVariable("initiativeId") String initiativeId,

src/main/java/it/gov/pagopa/idpay/transactions/controller/ReportControllerImpl.java

@@ -1,6 +1,11 @@
 package it.gov.pagopa.idpay.transactions.controller;
 
-import it.gov.pagopa.idpay.transactions.dto.*;
+import it.gov.pagopa.idpay.transactions.dto.PatchReportRequest;
+import it.gov.pagopa.idpay.transactions.dto.ReportDTO;
+import it.gov.pagopa.idpay.transactions.dto.ReportListDTO;
+import it.gov.pagopa.idpay.transactions.dto.ReportRequest;
+import it.gov.pagopa.idpay.transactions.dto.report.Report2RunDto;
+import it.gov.pagopa.idpay.transactions.dto.report.ReportGenerateForce;
 import it.gov.pagopa.idpay.transactions.service.ReportService;
 import it.gov.pagopa.idpay.transactions.dto.mapper.ReportMapper;
 import it.gov.pagopa.idpay.transactions.utils.Utilities;
@@ -9,6 +14,8 @@
 import org.springframework.web.bind.annotation.RestController;
 import reactor.core.publisher.Mono;
 
+import java.util.List;
+
 @RestController
 @Slf4j
 public class ReportControllerImpl implements ReportController {
@@ -71,4 +78,9 @@ public Mono<ReportDTO> patchReport(String initiativeId,
     ) {
         return reportService.patchReport(initiativeId, reportId, request);
     }
+
+    @Override
+    public Mono<List<Report2RunDto>> forceGenerateReports(ReportGenerateForce reportGenerateForce) {
+        return reportService.forceGenerateReports(reportGenerateForce);
+    }
 }

src/main/java/it/gov/pagopa/idpay/transactions/data/factory/DataFactoryManagerConfig.java

@@ -0,0 +1,30 @@
+package it.gov.pagopa.idpay.transactions.data.factory;
+
+import com.azure.core.management.AzureEnvironment;
+import com.azure.core.management.profile.AzureProfile;
+import com.azure.identity.DefaultAzureCredential;
+import com.azure.identity.DefaultAzureCredentialBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import com.azure.resourcemanager.datafactory.DataFactoryManager;
+
+
+@Configuration
+public class DataFactoryManagerConfig {
+    private final String tenantId;
+    private final String subscriptionId;
+
+    public DataFactoryManagerConfig(@Value("${app.data-factory.tenant-id}") String tenantId,
+                                    @Value("${app.data-factory.subscription-id}") String subscriptionId) {
+        this.tenantId = tenantId;
+        this.subscriptionId = subscriptionId;
+    }
+
+    @Bean
+    public DataFactoryManager dataFactoryManager () {
+        DefaultAzureCredential azureCredentials = new DefaultAzureCredentialBuilder().build();
+        AzureProfile azureProfile = new AzureProfile(tenantId, subscriptionId, AzureEnvironment.AZURE);
+        return DataFactoryManager.authenticate(azureCredentials, azureProfile);
+    }
+}

src/main/java/it/gov/pagopa/idpay/transactions/data/factory/DataFactoryService.java

@@ -0,0 +1,8 @@
+package it.gov.pagopa.idpay.transactions.data.factory;
+
+import it.gov.pagopa.idpay.transactions.model.Report;
+import reactor.core.publisher.Mono;
+
+public interface DataFactoryService {
+    Mono<String> triggerTransactionReportPipeline(Report report);
+}

src/main/java/it/gov/pagopa/idpay/transactions/data/factory/DataFactoryServiceImpl.java

@@ -0,0 +1,92 @@
+package it.gov.pagopa.idpay.transactions.data.factory;
+
+import com.azure.core.http.rest.Response;
+import com.azure.core.util.Context;
+import com.azure.resourcemanager.datafactory.models.CreateRunResponse;
+import it.gov.pagopa.idpay.transactions.exception.AzureConnectingErrorException;
+import it.gov.pagopa.idpay.transactions.model.Report;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import com.azure.resourcemanager.datafactory.DataFactoryManager;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
+import reactor.util.retry.Retry;
+
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+@Slf4j
+public class DataFactoryServiceImpl implements DataFactoryService{
+    private final DataFactoryManager dataFactoryManager;
+    private final String resourceGroup;
+    private final String factoryName;
+    private final String pipelineName;
+    private final int maxRetries;
+
+    public DataFactoryServiceImpl(DataFactoryManager dataFactoryManager,
+                                  @Value("${app.data-factory.resource-group}") String resourceGroup,
+                                  @Value("${app.data-factory.factory-name}") String factoryName,
+                                  @Value("${app.data-factory.pipeline-name}") String pipelineName,
+                                  @Value("${app.data-factory.max-retries}") int maxRetries) {
+        this.dataFactoryManager = dataFactoryManager;
+        this.resourceGroup = resourceGroup;
+        this.factoryName = factoryName;
+        this.pipelineName = pipelineName;
+        this.maxRetries = maxRetries;
+    }
+
+    @Override
+    public Mono<String> triggerTransactionReportPipeline(Report report) {
+        Mono<String> callMono = Mono.fromCallable(() -> {
+                    log.info("[CALLING_DATA_FACTORY] Starting pipeline execution for Report {}", report.getId());
+                    Response<CreateRunResponse> resp = dataFactoryManager.pipelines().createRunWithResponse(
+                            resourceGroup,
+                            factoryName,
+                            pipelineName,
+                            null,
+                            false,
+                            null,
+                            false,
+                            createPipelineParameters(report),
+                            Context.NONE);
+
+                    int status = resp.getStatusCode();
+                    if (status < 200 || status >= 300) {
+                        throw new IllegalStateException("ADF createRun failed. HTTP status: " + status);
+                    }
+
+                    CreateRunResponse body = resp.getValue();
+                    if (body == null) {
+                        throw new IllegalStateException("ADF createRun returned empty body");
+                    }
+                    log.info("[CALLING_DATA_FACTORY] Report {} generation request sent successfully. Run ID: {}", report.getId(), body.runId());
+                    return body.runId();
+                })
+                .subscribeOn(Schedulers.boundedElastic());
+
+        return callMono
+                .retryWhen(Retry.fixedDelay(maxRetries, Duration.ofSeconds(1))
+                        .onRetryExhaustedThrow((spec, signal) ->
+                                new AzureConnectingErrorException(
+                                        "Failed to trigger ADF pipeline after " + (maxRetries + 1) + " attempts",
+                                        signal.failure()
+                                )
+                        )
+                );
+    }
+
+    private Map<String, Object> createPipelineParameters(Report report) {
+        HashMap<String, Object> parameters = new HashMap<>();
+        parameters.put("reportId", report.getId());
+        parameters.put("merchantId", report.getMerchantId());
+        parameters.put("initiativeId", report.getInitiativeId());
+        parameters.put("startDate", report.getStartPeriod());
+        parameters.put("endDate", report.getEndPeriod());
+        parameters.put("reportName", report.getFileName());
+
+        return parameters;
+    }
+}

src/main/java/it/gov/pagopa/idpay/transactions/dto/report/Report2RunDto.java

@@ -0,0 +1,15 @@
+package it.gov.pagopa.idpay.transactions.dto.report;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class Report2RunDto {
+    String reportId;
+    String runId;
+}

src/main/java/it/gov/pagopa/idpay/transactions/dto/report/ReportGenerateForce.java

@@ -0,0 +1,14 @@
+package it.gov.pagopa.idpay.transactions.dto.report;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class ReportGenerateForce {
+    List<String> reportsId;
+}

src/main/java/it/gov/pagopa/idpay/transactions/exception/AzureConnectingErrorException.java

@@ -0,0 +1,8 @@
+package it.gov.pagopa.idpay.transactions.exception;
+
+public class AzureConnectingErrorException extends RuntimeException{
+
+    public AzureConnectingErrorException(String message, Throwable failure) {
+        super(message, failure);
+    }
+}

src/main/java/it/gov/pagopa/idpay/transactions/service/ReportService.java

@@ -4,11 +4,15 @@
 import it.gov.pagopa.idpay.transactions.dto.PatchReportRequest;
 import it.gov.pagopa.idpay.transactions.dto.ReportDTO;
 import it.gov.pagopa.idpay.transactions.dto.ReportRequest;
+import it.gov.pagopa.idpay.transactions.dto.report.Report2RunDto;
+import it.gov.pagopa.idpay.transactions.dto.report.ReportGenerateForce;
 import it.gov.pagopa.idpay.transactions.model.Report;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import reactor.core.publisher.Mono;
 
+import java.util.List;
+
 public interface ReportService {
     Mono<Page<Report>> getTransactionsReports(String merchantId, String organizationRole, String initiativeId, Pageable pageable);
 
@@ -28,4 +32,6 @@ Mono<DownloadReportResponseDTO> downloadTransactionsReport(
             String reportId
     );
 
+
+    Mono<List<Report2RunDto>> forceGenerateReports(ReportGenerateForce reportGenerateForce);
 }