SondaBatch.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */


  22. package org.openspcoop2.utils.sonde.impl;

  24. import java.sql.Connection;
  25. import java.text.SimpleDateFormat;
  26. import java.util.Date;
  27. import java.util.HashSet;
  28. import java.util.Properties;
  29. import java.util.Set;

  31. import org.openspcoop2.utils.TipiDatabase;
  32. import org.openspcoop2.utils.io.Base64Utilities;
  33. import org.openspcoop2.utils.sonde.ParametriSonda;
  34. import org.openspcoop2.utils.sonde.Sonda;
  35. import org.openspcoop2.utils.sonde.SondaException;

  37. /**
  38.  * Classe di implementazione della Sonda per i batch
  39.  * 
  40.  *
  41.  * @author Bussu Giovanni (bussu@link.it)
  42.  * @author $Author$
  43.  * @version $Rev$, $Date$
  44.  */
  45. public class SondaBatch extends Sonda {

  47.     /**
  48.      * Costruttore per la classe SondaBatch
  49.      * @param param parametri costruttivi della sonda
  50.      * @throws Exception
  51.      */
  52.     public SondaBatch(ParametriSonda param) {
  53.         super(param);
  54.         Set<String> reserved = new HashSet<String>();
  55.         reserved.add("data_ultimo_batch");
  56.         reserved.add("esito_batch");
  57.         reserved.add("interazioni_fallite");
  58.         reserved.add("descrizione_errore");
  59.         this.getParam().setReserved(reserved);

  61.     }

  63.     @Override
  64.     public StatoSonda getStatoSonda(){


  67.         Date now = new Date();
  68.         Date data_warn = new Date(now.getTime() - super.getParam().getSogliaWarn());
  69.         Date data_err = new Date(now.getTime() - super.getParam().getSogliaError());

  71.         StatoSonda statoSonda = new StatoSonda();
  72.         boolean esito_batch = false;
  73.         if(super.getParam().getDatiCheck().containsKey("esito_batch")) {
  74.             String esitoBatchString = (String) super.getParam().getDatiCheck().getProperty("esito_batch");
  75.             try{
  76.                 esito_batch = Boolean.parseBoolean(esitoBatchString);
  77.             } catch(NumberFormatException e){
  78.                 e.printStackTrace(System.err);
  79.                 System.err.println("Errore durante il parsing del parametro esito_batch: " + super.getParam().getDatiCheck().getProperty("esito_batch") + ". Elimino il valore");
  80.                 super.getParam().getDatiCheck().remove("esito_batch");
  81.             }
  82.         } else {
  83.             System.err.println("Parametro esito_batch non trovato");
  84.         }

  86.         Long dataUltimoBatchLong = null;
  87.         if(super.getParam().getDatiCheck().containsKey("data_ultimo_batch")) {
  88.             try {
  89.                 
  90.                 dataUltimoBatchLong = Long.valueOf(super.getParam().getDatiCheck().getProperty("data_ultimo_batch"));
  91.             } catch(NumberFormatException e) {
  92.                 e.printStackTrace(System.err);
  93.                 System.err.println("Errore durante il parsing del parametro data_ultimo_batch: " + super.getParam().getDatiCheck().getProperty("data_ultimo_batch") + ". Elimino il valore");
  94.                 super.getParam().getDatiCheck().remove("data_ultimo_batch");
  95.             }
  96.         } else {
  97.             System.err.println("Parametro data_ultimo_batch non trovato");
  98.         }

  100.         if(dataUltimoBatchLong == null) {
  101.             statoSonda.setStato(2);
  102.             statoSonda.setDescrizione("Il batch "+super.getParam().getNome()+" risulta non essere eseguito.");
  103.             return statoSonda;
  104.         }

  106.         Date data_ultimo_batch = new Date(dataUltimoBatchLong);

  108.         SimpleDateFormat format = new SimpleDateFormat(PATTERN);
  109.         String dataUltimoBatchString = format.format(data_ultimo_batch);
  110.         
  111.         if(esito_batch) {

  113.             //Valuto l'eventuale superamento delle soglie e calcolo lo stato
  114.             if(data_ultimo_batch.before(data_err)) {
  115.                 String errorDateFormatted = format.format(data_err);
  116.                 statoSonda.setStato(2);
  117.                 statoSonda.setDescrizione("Il batch "+super.getParam().getNome()+" risulta non essere eseguito dal "+dataUltimoBatchString+". Data di error ("+errorDateFormatted+") superata.");
  118.             } else if(data_ultimo_batch.before(data_warn)) {
  119.                 String warnDateFormatted = format.format(data_warn);
  120.                 statoSonda.setStato(1);
  121.                 statoSonda.setDescrizione("Il batch "+super.getParam().getNome()+" risulta non essere eseguito dal "+dataUltimoBatchString+". Data di warn ("+warnDateFormatted+") superata.");
  122.             } else {
  123.                 statoSonda.setStato(0);
  124.                 statoSonda.setDescrizione("Batch "+super.getParam().getNome()+" eseguito con successo il "+dataUltimoBatchString+".");
  125.             }
  126.      
  127.             return statoSonda;
  128.         } else {
  129.             
  130.             Integer interazioniFallite = -1;
  131.             if(super.getParam().getDatiCheck().containsKey("interazioni_fallite")) {
  132.                 try{
  133.                     interazioniFallite = Integer.parseInt(super.getParam().getDatiCheck().getProperty("interazioni_fallite"));
  134.                 } catch(NumberFormatException e) {
  135.                     e.printStackTrace(System.err);
  136.                     System.err.println("Errore durante il parsing del parametro interazioni_fallite: " + super.getParam().getDatiCheck().getProperty("interazioni_fallite") + ". Elimino il valore");
  137.                     super.getParam().getDatiCheck().remove("interazioni_fallite");
  138.                 }
  139.             } else {
  140.                 System.err.println("Parametro interazioni_fallite non trovato");
  141.             }

  143.             statoSonda.setStato(2);
  144.             String descr = null;
  145.             if(super.getParam().getDatiCheck().containsKey("descrizione_errore")) {
  146.                 descr = new String(Base64Utilities.decode((String) super.getParam().getDatiCheck().get("descrizione_errore")));
  147.             }
  148.             statoSonda.setDescrizione("Il batch "+super.getParam().getNome()+" risulta fallire dal "+dataUltimoBatchString+" (fallite "+interazioniFallite+" iterazioni). Descrizione dell'ultimo errore:" + descr);
  149.             return statoSonda;
  150.         }
  151.     }

  153.     
  154.     //retrocompatibilita
  155.     public StatoSonda aggiornaStatoSonda(boolean esito_batch, Date data_ultimo_batch, String descrizioneErrore, Connection connection, TipiDatabase tipoDatabase) throws SondaException {
  156.         return this.aggiornaStatoSonda(esito_batch, null, data_ultimo_batch, descrizioneErrore, connection, tipoDatabase);
  157.     }
  158.     
  159.     /**
  160.      * @param esito_batch true se l'esito e' positivo, false altrimenti
  161.      * @param data_ultimo_batch ultima data di esecuzione del batch 
  162.      * @param descrizioneErrore eventuale descrizione dell'errore (in caso di esito negativo)
  163.      * @param connection connessione per il DB
  164.      * @param tipoDatabase tipo database
  165.      * @return lo stato attuale della sonda
  166.      * @throws SondaException
  167.      */
  168.     public StatoSonda aggiornaStatoSonda(boolean esito_batch, Properties params, Date data_ultimo_batch, String descrizioneErrore, Connection connection, TipiDatabase tipoDatabase) throws SondaException {
  169.         // inserisce i dati nel properties
  170.         
  171.         super.getParam().putAllCheck(params);
  172.         
  173.         super.getParam().getDatiCheck().put("data_ultimo_batch", data_ultimo_batch.getTime()+ "");
  174.         super.getParam().getDatiCheck().put("esito_batch", String.valueOf(esito_batch));
  175.         if(!esito_batch) {
  176.             if(super.getParam().getDatiCheck().containsKey("interazioni_fallite")) {
  177.                 Integer interazioniFallite = Integer.parseInt(super.getParam().getDatiCheck().getProperty("interazioni_fallite"));
  178.                 super.getParam().getDatiCheck().put("interazioni_fallite", (interazioniFallite+1) + "");
  179.             } else {
  180.                 super.getParam().getDatiCheck().put("interazioni_fallite", 1 + "");
  181.             }
  182.             if(descrizioneErrore != null) {
  183.                 super.getParam().getDatiCheck().put("descrizione_errore", Base64Utilities.encodeAsString(descrizioneErrore.getBytes()));
  184.             }
  185.         } else {
  186.             if(super.getParam().getDatiCheck().containsKey("descrizione_errore"))
  187.                 super.getParam().getDatiCheck().remove("descrizione_errore");
  188.             if(super.getParam().getDatiCheck().containsKey("interazioni_fallite"))
  189.                 super.getParam().getDatiCheck().remove("interazioni_fallite");
  190.         }
  191.         return updateSonda(connection, tipoDatabase);
  192.     }

  194. }
Created with JaCoCo 0.8.8.202204050719