DiagnosticProducer.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.  */



  23. package org.openspcoop2.protocol.basic.diagnostica;

  25. import java.sql.Connection;
  26. import java.sql.PreparedStatement;
  27. import java.util.ArrayList;
  28. import java.util.Date;
  29. import java.util.List;

  31. import org.openspcoop2.core.config.OpenspcoopAppender;
  32. import org.openspcoop2.core.constants.CostantiDB;
  33. import org.openspcoop2.core.id.IDSoggetto;
  34. import org.openspcoop2.protocol.basic.BasicConnectionResult;
  35. import org.openspcoop2.protocol.basic.BasicProducer;
  36. import org.openspcoop2.protocol.basic.BasicProducerType;
  37. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  38. import org.openspcoop2.protocol.sdk.ProtocolException;
  39. import org.openspcoop2.protocol.sdk.diagnostica.IDiagnosticProducer;
  40. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  41. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnosticoException;
  42. import org.openspcoop2.utils.TipiDatabase;
  43. import org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject;
  44. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKey;
  45. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyJDBCType;
  46. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyObject;
  47. import org.openspcoop2.utils.jdbc.JDBCUtilities;


  50. /**
  51.  * Contiene l'implementazione di un appender personalizzato,
  52.  * per la registrazione dei msg diagnostici su database.
  53.  *
  54.  * @author Poli Andrea (apoli@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class DiagnosticProducer extends BasicProducer implements IDiagnosticProducer{

  60.     public DiagnosticProducer(IProtocolFactory<?> factory) throws ProtocolException{
  61.         super(factory, BasicProducerType.DIAGNOSTIC);
  62.     }
  63.     
  64.     
  65.     
  66.     /**
  67.      * Inizializza l'engine di un appender per la registrazione
  68.      * di un msg Diagnostico emesso da una porta di dominio.
  69.      * 
  70.      * @param appenderProperties Proprieta' dell'appender
  71.      * @throws MsgDiagnosticoException
  72.      */
  73.     @Override
  74.     public void initializeAppender(OpenspcoopAppender appenderProperties) throws MsgDiagnosticoException{
  75.         
  76.         try{
  77.             this.initializeAppender(appenderProperties, false);
  78.         }catch(Exception e){
  79.             throw new MsgDiagnosticoException("Errore durante l'inizializzazione dell'appender: "+e.getMessage(),e);
  80.         }
  81.     }

  83.     
  84.     /**
  85.      * Registra un msg Diagnostico emesso da una porta di dominio,
  86.      * utilizzando le informazioni definite dalla specifica SPC.
  87.      * 
  88.      * @param msgDiagnostico Messaggio diagnostico
  89.      * @throws MsgDiagnosticoException
  90.      */
  91.     @Override
  92.     public void log(Connection conOpenSPCoopPdD,MsgDiagnostico msgDiagnostico) throws MsgDiagnosticoException{
  93.         
  94.         if(TipiDatabase.POSTGRESQL.equals(this.tipoDatabase) && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(msgDiagnostico.getMessaggio())){
  95.             msgDiagnostico.setMessaggio(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(msgDiagnostico.getMessaggio()));
  96.         }
  97.         
  98.         PreparedStatement stmt = null;
  99.         Connection con = null;
  100.         String messaggio = msgDiagnostico.getMessaggio();
  101.         BasicConnectionResult cr = null;
  102.         try{
  103.             
  104.             Date gdo = msgDiagnostico.getGdo();
  105.             IDSoggetto idPorta = msgDiagnostico.getIdSoggetto();
  106.             String idFunzione = msgDiagnostico.getIdFunzione();
  107.             int severita = msgDiagnostico.getSeverita();
  108.             String idBusta = msgDiagnostico.getIdBusta();
  109.             String idBustaRisposta = msgDiagnostico.getIdBustaRisposta();
  110.             String codiceDiagnostico = msgDiagnostico.getCodice();
  111.             String applicativo = msgDiagnostico.getApplicativo();
  112.             
  113.             String idTransazione = msgDiagnostico.getIdTransazione();
  114.             
  115.             if(this.debug){
  116.                 this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] ....");
  117.             }
  118.             
  119.             TipiDatabase tipo = null;
  120.             if(this.tipoDatabase!=null){
  121.                 if(!TipiDatabase.isAMember(this.tipoDatabase)){
  122.                     throw new MsgDiagnosticoException("Tipo database ["+this.tipoDatabase+"] non supportato");
  123.                 }
  124.                 tipo = TipiDatabase.toEnumConstant(this.tipoDatabase);
  125.             }
  126.             
  127.             //  Connessione al DB
  128.             cr = this.getConnection(conOpenSPCoopPdD,"log");
  129.             con = cr.getConnection();

  131.             if(this.debug){
  132.                 this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] (getConnection finished) ....");
  133.             }
  134.             
  135.             if(tipo==null){
  136.             
  137.                 // Inserimento della traccia nel DB in modalità retro compatibile
  138.                 // in questa versione non viene recuperato l'id long
  139.                 
  140.                 if(this.debug){
  141.                     this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] (inserimentoDiagnostico BackwardCompatible) ....");
  142.                 }
  143.                 
  144.                 String updateString = "INSERT INTO "+CostantiDB.MSG_DIAGNOSTICI+" ("+
  145.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO+", "+
  146.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_CODICE+", "+
  147.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_TIPO_SOGGETTO+", "+
  148.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_NOME_SOGGETTO+", "+
  149.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE+", "+
  150.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_SEVERITA+", "+
  151.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_MESSAGGIO+", "+
  152.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO+", "+
  153.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO_RISPOSTA+", "+
  154.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_PROTOCOLLO+", "+
  155.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_CODICE+", "+
  156.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID_TRANSAZIONE+", "+
  157.                         CostantiDB.MSG_DIAGNOSTICI_COLUMN_APPLICATIVO+""+
  158.                 ") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? , ?, ?)";
  159.                 int index = 1;
  160.                 stmt = con.prepareStatement(updateString);
  161.                 if(gdo!=null)
  162.                     stmt.setTimestamp(index++, new java.sql.Timestamp(gdo.getTime()));
  163.                 else
  164.                     stmt.setTimestamp(index++,null);
  165.                 JDBCUtilities.setSQLStringValue(stmt,index++, idPorta.getCodicePorta());
  166.                 JDBCUtilities.setSQLStringValue(stmt,index++, idPorta.getTipo());
  167.                 JDBCUtilities.setSQLStringValue(stmt,index++, idPorta.getNome());
  168.                 JDBCUtilities.setSQLStringValue(stmt,index++, idFunzione);
  169.                 stmt.setInt(index++, severita);
  170.                 JDBCUtilities.setSQLStringValue(stmt,index++, messaggio);
  171.                 JDBCUtilities.setSQLStringValue(stmt,index++, idBusta);
  172.                 JDBCUtilities.setSQLStringValue(stmt,index++, idBustaRisposta);
  173.                 JDBCUtilities.setSQLStringValue(stmt,index++,msgDiagnostico.getProtocollo());
  174.                 JDBCUtilities.setSQLStringValue(stmt,index++, codiceDiagnostico);
  175.                 JDBCUtilities.setSQLStringValue(stmt,index++, idTransazione);
  176.                 JDBCUtilities.setSQLStringValue(stmt,index++, applicativo);
  177.                 stmt.executeUpdate();
  178.                 stmt.close();
  179.                 
  180.                 if(this.debug){
  181.                     this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] (inserimentoDiagnostico BackwardCompatible terminato) ....");
  182.                 }
  183.                 
  184.             }
  185.             else{
  186.                 
  187.                 // Modalità di inserimento dove viene recuperato l'id long
  188.                 
  189.                 if(this.debug){
  190.                     this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] (inserimentoDiagnostico) ....");
  191.                 }
  192.                 
  193.                 List<InsertAndGeneratedKeyObject> listInsertAndGeneratedKeyObject = new ArrayList<>();
  194.                 java.sql.Timestamp gdoT = null;
  195.                 if(gdo!=null)
  196.                     gdoT =  new java.sql.Timestamp(gdo.getTime());
  197.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO, gdoT , InsertAndGeneratedKeyJDBCType.TIMESTAMP) );
  198.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_CODICE, getSQLStringValue(idPorta.getCodicePorta()), InsertAndGeneratedKeyJDBCType.STRING) );
  199.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_TIPO_SOGGETTO, getSQLStringValue(idPorta.getTipo()), InsertAndGeneratedKeyJDBCType.STRING) );
  200.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_NOME_SOGGETTO, getSQLStringValue(idPorta.getNome()), InsertAndGeneratedKeyJDBCType.STRING) );
  201.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE, getSQLStringValue(idFunzione), InsertAndGeneratedKeyJDBCType.STRING) );
  202.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_SEVERITA, severita, InsertAndGeneratedKeyJDBCType.INT) );
  203.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_MESSAGGIO, getSQLStringValue(messaggio), InsertAndGeneratedKeyJDBCType.STRING) );
  204.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO, getSQLStringValue(idBusta), InsertAndGeneratedKeyJDBCType.STRING) );
  205.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO_RISPOSTA, getSQLStringValue(idBustaRisposta), InsertAndGeneratedKeyJDBCType.STRING) );
  206.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PROTOCOLLO, getSQLStringValue(msgDiagnostico.getProtocollo()), InsertAndGeneratedKeyJDBCType.STRING) );
  207.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_CODICE, getSQLStringValue(codiceDiagnostico), InsertAndGeneratedKeyJDBCType.STRING) );
  208.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID_TRANSAZIONE, getSQLStringValue(idTransazione), InsertAndGeneratedKeyJDBCType.STRING) );
  209.                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.MSG_DIAGNOSTICI_COLUMN_APPLICATIVO, getSQLStringValue(applicativo), InsertAndGeneratedKeyJDBCType.STRING) );
  210.                                 
  211.                 // ** Insert and return generated key
  212.                 long iddiagnostico = InsertAndGeneratedKey.insertAndReturnGeneratedKey(con, tipo, 
  213.                         new CustomKeyGeneratorObject(CostantiDB.MSG_DIAGNOSTICI, CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID, CostantiDB.MSG_DIAGNOSTICI_SEQUENCE, CostantiDB.MSG_DIAGNOSTICI_TABLE_FOR_ID),
  214.                         listInsertAndGeneratedKeyObject.toArray(new InsertAndGeneratedKeyObject[1]));
  215.                 if(iddiagnostico<=0){
  216.                     throw new Exception("ID autoincrementale non ottenuto");
  217.                 }
  218.                 msgDiagnostico.setId(iddiagnostico);
  219.                 
  220.                 if(this.debug){
  221.                     this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] (inserimentoDiagnostico terminato) ....");
  222.                 }
  223.             }
  224.             
  225.             if(this.debug){
  226.                 this.log.debug("@@ log idTransazione["+idTransazione+"] idBusta["+idBusta+"] completato");
  227.             }
  228.             
  229.         }catch(Exception e){
  230.             throw new MsgDiagnosticoException("Errore durante la registrazione del msg diagnostico: "+e.getMessage()+"\nIl messaggio era: "+messaggio,e);
  231.         }finally{
  232.             try{
  233.                 if(stmt!=null)
  234.                     stmt.close();
  235.             }catch(Exception e){
  236.                 // close
  237.             }
  238.             try{
  239.                 this.releaseConnection(cr, "log");
  240.             }catch(Exception e){
  241.                 // close
  242.             }
  243.         }
  244.     }
  245.         

  247. }
Created with JaCoCo 0.8.8.202204050719