Issue #440

Aggiunta gestione del numero di risultati da leggere ad ogni iterazione per la creazione del tracciato APK.
link-it · Dec 20, 2021 · 208a728 · 208a728
1 parent b4a8b8d
commit 208a728
Show file tree

Hide file tree

Showing 6 changed files with 29 additions and 2 deletions.
diff --git a/ear/src/main/application/properties/govpay.properties b/ear/src/main/application/properties/govpay.properties
@@ -148,6 +148,9 @@ it.govpay.batch.caricamentoTracciati.numeroAvvisiDaStamparePerThread=${it.govpay
 # Abilita il batch di caricamento dei tracciati notifica pagamenti
 it.govpay.batch.caricamentoTracciatiNotificaPagamenti.enabled=${it.govpay.batch.caricamentoTracciatiNotificaPagamenti.enabled}
 
+# Definisce la dimensione della paginazione da utilizzare per la lettura delle entries da db da inserire nel tracciato
+it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina=${it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina}
+
 
 # GovPay API: Gestione Diagnostici, Dump e Giornale Eventi
 

diff --git a/jars/core/src/main/java/it/govpay/core/business/TracciatiNotificaPagamenti.java b/jars/core/src/main/java/it/govpay/core/business/TracciatiNotificaPagamenti.java
@@ -62,6 +62,7 @@
 import it.govpay.bd.viste.model.VersamentoNonRendicontato;
 import it.govpay.core.beans.JSONSerializable;
 import it.govpay.core.utils.CSVUtils;
+import it.govpay.core.utils.GovpayConfig;
 import it.govpay.core.utils.JaxbUtils;
 import it.govpay.core.utils.SimpleDateFormatUtils;
 import it.govpay.core.utils.tracciati.TracciatiNotificaPagamentiUtils;
@@ -751,7 +752,7 @@ private void popolaTracciatoHyperSicAPK(TracciatoNotificaPagamenti tracciato, Co
 
 		int lineaElaborazione = 0;
 		int offset = 0;
-		int limit = 100; 
+		Integer limit = GovpayConfig.getInstance().getBatchCaricamentoTracciatiNotificaPagamentiDimensionePagina(); 
 		RendicontazioniBD rendicontazioniBD = new RendicontazioniBD(rptBD);
 		rendicontazioniBD.setAtomica(false);
 

diff --git a/jars/core/src/main/java/it/govpay/core/utils/GovpayConfig.java b/jars/core/src/main/java/it/govpay/core/utils/GovpayConfig.java
@@ -140,6 +140,7 @@ public static GovpayConfig newInstance(InputStream is) throws Exception {
 	private Integer dimensioneMassimaListaRisultati;
 
 	private boolean batchCaricamentoTracciatiNotificaPagamenti;
+	private Integer batchCaricamentoTracciatiNotificaPagamentiDimensionePagina;
 
 	private boolean ricercaRiconciliazioniIdFlussoCaseInsensitive;
 
@@ -639,6 +640,14 @@ public void readProperties() throws Exception {
 			if(batchCaricamentoTracciatiNotificaPagamentiString != null && Boolean.valueOf(batchCaricamentoTracciatiNotificaPagamentiString))
 				this.batchCaricamentoTracciatiNotificaPagamenti = true;
 
+			String batchCaricamentoTracciatiNotificaPagamentiDimensionePaginaString = getProperty("it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina", this.props, false, log);
+			try{
+				this.batchCaricamentoTracciatiNotificaPagamentiDimensionePagina = Integer.parseInt(batchCaricamentoTracciatiNotificaPagamentiDimensionePaginaString);
+			} catch(Throwable t) {
+				log.info("Proprieta \"it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina\" impostata con valore di default "+ BasicFindRequestDTO.DEFAULT_MAX_LIMIT);
+				this.batchCaricamentoTracciatiNotificaPagamentiDimensionePagina = BasicFindRequestDTO.DEFAULT_MAX_LIMIT;
+			}
+
 			String ricercaRiconciliazioniIdFlussoCaseInsensitiveString = getProperty("it.govpay.riconciliazione.idFlussoCaseInsensitive.enabled", this.props, false, log);
 			if(ricercaRiconciliazioniIdFlussoCaseInsensitiveString != null && Boolean.valueOf(ricercaRiconciliazioniIdFlussoCaseInsensitiveString))
 				this.ricercaRiconciliazioniIdFlussoCaseInsensitive = true;
@@ -1028,6 +1037,10 @@ public boolean isBatchCaricamentoTracciatiNotificaPagamenti() {
 		return batchCaricamentoTracciatiNotificaPagamenti;
 	}
 
+	public Integer getBatchCaricamentoTracciatiNotificaPagamentiDimensionePagina() {
+		return batchCaricamentoTracciatiNotificaPagamentiDimensionePagina;
+	}
+
 	public boolean isRicercaRiconciliazioniIdFlussoCaseInsensitive() {
 		return ricercaRiconciliazioniIdFlussoCaseInsensitive;
 	}

diff --git a/jars/orm/src/main/java/it/govpay/bd/viste/RendicontazioniBD.java b/jars/orm/src/main/java/it/govpay/bd/viste/RendicontazioniBD.java
@@ -456,7 +456,11 @@ public List<it.govpay.bd.viste.model.Rendicontazione> ricercaRiscossioniDominio(
 			}
 
 			IPaginatedExpression pagExp = this.getVistaRendicontazioneServiceSearch().toPaginatedExpression(exp);
-			pagExp.offset(offset).limit(limit);
+			if(offset != null)
+				pagExp.offset(offset);
+
+			if(limit != null)
+				pagExp.limit(limit);
 			pagExp.addOrder(model.PAG_DATA_PAGAMENTO, SortOrder.ASC);
 
 			List<Rendicontazione> entratePrevisteLst = new ArrayList<>();

diff --git a/src/main/resources/filters/installer_template.filter.properties b/src/main/resources/filters/installer_template.filter.properties
@@ -150,6 +150,9 @@ it.govpay.batch.caricamentoTracciati.numeroAvvisiDaStamparePerThread=5
 # Abilita il batch di caricamento dei tracciati notifica pagamenti
 it.govpay.batch.caricamentoTracciatiNotificaPagamenti.enabled=false
 
+# Definisce la dimensione della paginazione da utilizzare per la lettura delle entries da db da inserire nel tracciato
+it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina=200
+
 # GovPay API: Gestione Diagnostici e Dump
 
 # Gestione salvataggio diagnostici su file

diff --git a/src/main/resources/filters/template.filter.properties b/src/main/resources/filters/template.filter.properties
@@ -150,6 +150,9 @@ it.govpay.batch.caricamentoTracciati.numeroAvvisiDaStamparePerThread=5
 # Abilita il batch di caricamento dei tracciati notifica pagamenti
 it.govpay.batch.caricamentoTracciatiNotificaPagamenti.enabled=true
 
+# Definisce la dimensione della paginazione da utilizzare per la lettura delle entries da db da inserire nel tracciato
+it.govpay.batch.caricamentoTracciatiNotificaPagamenti.dimensionePagina=200
+
 
 # GovPay API: Gestione Diagnostici e Dump