Skip to content

Commit

Permalink
Aggiunti log per i thread di elaborazione tracciati.
Browse files Browse the repository at this point in the history
  • Loading branch information
@pintorig
pintorig committed Mar 15, 2022
1 parent baf754a commit cca57d4
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 11 deletions.
8 changes: 8 additions & 0 deletions jars/core/src/main/java/it/govpay/core/business/Tracciati.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -717,11 +717,14 @@ private void _elaboraTracciatoCSV(TracciatiBD tracciatiBD, Tracciato tracciato,
boolean completed = true;
for(CaricamentoTracciatoThread sender : threads) {
if(!sender.isCompleted()) {
log.trace("Thread ["+sender.getNomeThread()+"] non completato.");
completed = false;
} else {
if(!sender.isCommit()) {
log.trace("Thread ["+sender.getNomeThread()+"] completato, acquisizione risultati.");
sender.setCommit(true);
synchronized (this) {
log.debug("Completata Esecuzione del Thread ["+sender.getNomeThread()+"], ADDOK ["+sender.getNumeroAddElaborateOk()+"], ADDKO ["+sender.getNumeroAddElaborateKo()+"] DELOK ["+sender.getNumeroDelElaborateOk()+"], DELKO ["+sender.getNumeroDelElaborateKo()+"]");
lineeElaborate.addAll(sender.getLineeElaborate());
sommaAddOk += sender.getNumeroAddElaborateOk();
sommaAddKo += sender.getNumeroAddElaborateKo();
Expand All @@ -745,11 +748,14 @@ private void _elaboraTracciatoCSV(TracciatiBD tracciatiBD, Tracciato tracciato,
beanDati.setDescrizioneStepElaborazione(descrizioneEsito);
beanDati.setDataUltimoAggiornamento(new Date());

log.debug("Aggiornamento metadati tracciato dopo il completamento del Thread ["+sender.getNomeThread()+"] in corso...");
tracciatiBD.setAutoCommit(false);
tracciatiBD.updateBeanDati(tracciato, serializer.getObject(beanDati));
tracciatiBD.commit();
log.debug("Aggiornati metadati tracciato dopo il completamento del Thread ["+sender.getNomeThread()+"]");

BatchManager.aggiornaEsecuzione(configWrapper, Operazioni.BATCH_TRACCIATI);
log.debug("Aggiornata esecuzione del batch dopo il completamento del Thread ["+sender.getNomeThread()+"]");
}
}
}
Expand Down Expand Up @@ -929,9 +935,11 @@ private void _elaboraTracciatoCSV(TracciatiBD tracciatiBD, Tracciato tracciato,
boolean completed = true;
for(CreaStampeTracciatoThread sender : threadsStampe) {
if(!sender.isCompleted()) {
log.trace("Thread ["+sender.getNomeThread()+"] non completato.");
completed = false;
} else {
if(!sender.isCommit()) {
log.trace("Thread ["+sender.getNomeThread()+"] completato, acquisizione risultati.");
sender.setCommit(true);
synchronized (this) {

Expand Down
2 changes: 1 addition & 1 deletion ...e/src/main/java/it/govpay/core/business/model/tracciati/operazioni/OperazioneFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -428,7 +428,7 @@ public AbstractOperazioneResponse elaboraLineaCSV(CaricamentoRequest request, Tr

TrasformazioneDTOResponse trasformazioneResponse = TracciatiUtils.trasformazioneInputCSV(log, request.getCodDominio(), request.getCodTipoVersamento(), new String(request.getDati()), request.getTipoTemplateTrasformazioneRichiesta() , request.getTemplateTrasformazioneRichiesta() );

log.debug("Response della trasformazione: " + trasformazioneResponse.getOutput());
log.trace(threadName + ": Response della trasformazione: " + trasformazioneResponse.getOutput());

operazioneResponse.setJsonRichiesta(trasformazioneResponse.getOutput());

Expand Down
8 changes: 4 additions & 4 deletions jars/core/src/main/java/it/govpay/core/utils/CSVUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -63,13 +63,13 @@ public static List<byte[]> splitCSV(byte[] tracciato, long skip) throws IOExcept


public CSVRecord getCSVRecord(String csvEntry) throws IOException {
log.debug("Parsing del record CSV: [" + csvEntry + "] [Delimiter: " + csvFormat.getDelimiter() +" Escape:"+csvFormat.getEscapeCharacter()+"]");
log.trace("Parsing del record CSV: [" + csvEntry + "] [Delimiter: " + csvFormat.getDelimiter() +" Escape:"+csvFormat.getEscapeCharacter()+"]");
CSVParser p = CSVParser.parse(csvEntry, csvFormat);
CSVRecord r = p.getRecords().get(0);
if(log.isDebugEnabled()) {
log.debug("Parsing completed:" );
if(log.isTraceEnabled()) {
log.trace("Parsing completed:" );
for(int i=0; i < r.size(); i++) {
log.debug(i + ": [" + r.get(i) + "]");
log.trace(i + ": [" + r.get(i) + "]");
}
}
return r ;
Expand Down
16 changes: 10 additions & 6 deletions jars/core/src/main/java/it/govpay/core/utils/thread/CaricamentoTracciatoThread.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ public void run() {

operazioniBD.setAutoCommit(false);

log.debug("Elaborazione di " + this.richieste.size() + " operazioni...");
log.debug(this.nomeThread + ": Elaborazione di " + this.richieste.size() + " operazioni...");

for (CaricamentoRequest request : this.richieste) {
try {
Expand Down Expand Up @@ -109,9 +109,13 @@ public void run() {
}

if(created) {
log.debug(this.nomeThread + " Inserimento operazione ["+ (operazione.getLineaElaborazione()) + "] nel DB in corso...");
operazioniBD.insertOperazione(operazione);
log.debug(this.nomeThread + " Inserimento operazione ["+ (operazione.getLineaElaborazione()) + "] nel DB completato.");
} else {
log.debug(this.nomeThread + " Update operazione ["+ (operazione.getLineaElaborazione()) + "] nel DB in corso...");
operazioniBD.updateOperazione(operazione);
log.debug(this.nomeThread + " Update operazione ["+ (operazione.getLineaElaborazione()) + "] nel DB completato.");
}

if(operazione.getStato().equals(StatoOperazioneType.ESEGUITO_OK)) {
Expand All @@ -134,23 +138,23 @@ public void run() {

this.lineeElaborate.add(request.getLinea());
this.risposte.add(operazioneResponse);
log.debug("Inserimento Pendenza Numero ["+ (request.getLinea() -1) + "] elaborata con esito [" +operazione.getStato() + "]: " + operazione.getDettaglioEsito() + " Raw: [" + new String(request.getDati()) + "]");
log.debug(this.nomeThread + " Inserimento Pendenza Numero ["+ (request.getLinea() -1) + "] elaborata con esito [" +operazione.getStato() + "]: " + operazione.getDettaglioEsito() + " Raw: [" + new String(request.getDati()) + "]");
operazioniBD.commit();
}catch(ServiceException e) {
log.error("Errore durante il salvataggio l'accesso alla base dati: " + e.getMessage());
log.error(this.nomeThread + " Errore durante il salvataggio l'accesso alla base dati: " + e.getMessage());
} finally {

}
}
}catch(ServiceException e) {
log.error("Errore durante il salvataggio l'accesso alla base dati: " + e.getMessage());
log.error(this.nomeThread + " Errore durante il salvataggio l'accesso alla base dati: " + e.getMessage());

} finally {
this.completed = true;
if(operazioniBD != null) operazioniBD.closeConnection();

log.debug("Linee elaborate: " + this.lineeElaborate.size());
log.debug("Risposte prodotte: " + this.risposte.size());
log.debug(this.nomeThread + " Linee elaborate: " + this.lineeElaborate.size());
log.debug(this.nomeThread + " Risposte prodotte: " + this.risposte.size());
ContextThreadLocal.unset();
}

Expand Down

0 comments on commit cca57d4

Please sign in to comment.