DriverMonitoraggio.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.pdd.monitor.driver;

  25. import java.sql.Connection;
  26. import java.sql.DriverManager;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;
  30. import java.sql.Timestamp;
  31. import java.util.ArrayList;
  32. import java.util.List;
  33. import java.util.Properties;

  35. import javax.naming.InitialContext;
  36. import javax.sql.DataSource;

  38. import org.openspcoop2.pdd.core.GestoreMessaggi;
  39. import org.openspcoop2.pdd.mdb.ConsegnaContenutiApplicativi;
  40. import org.openspcoop2.pdd.mdb.InoltroBuste;
  41. import org.openspcoop2.pdd.mdb.InoltroRisposte;
  42. import org.openspcoop2.pdd.monitor.Busta;
  43. import org.openspcoop2.pdd.monitor.BustaServizio;
  44. import org.openspcoop2.pdd.monitor.BustaSoggetto;
  45. import org.openspcoop2.pdd.monitor.Dettaglio;
  46. import org.openspcoop2.pdd.monitor.Messaggio;
  47. import org.openspcoop2.pdd.monitor.Proprieta;
  48. import org.openspcoop2.pdd.monitor.ServizioApplicativoConsegna;
  49. import org.openspcoop2.pdd.monitor.StatoPdd;
  50. import org.openspcoop2.pdd.monitor.constants.CostantiMonitoraggio;
  51. import org.openspcoop2.pdd.monitor.constants.StatoMessaggio;
  52. import org.openspcoop2.pdd.timers.TimerConsegnaContenutiApplicativiThread;
  53. import org.openspcoop2.pdd.timers.TimerGestoreMessaggi;
  54. import org.openspcoop2.protocol.basic.BasicComponentFactory;
  55. import org.openspcoop2.protocol.engine.constants.Costanti;
  56. import org.openspcoop2.utils.LoggerWrapperFactory;
  57. import org.openspcoop2.utils.TipiDatabase;
  58. import org.openspcoop2.utils.date.DateManager;
  59. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  60. import org.openspcoop2.utils.resources.ClassLoaderUtilities;
  61. import org.openspcoop2.utils.sql.ISQLQueryObject;
  62. import org.openspcoop2.utils.sql.SQLObjectFactory;
  63. import org.openspcoop2.utils.sql.SQLQueryObjectException;
  64. import org.slf4j.Logger;

  66. /**
  67.  * Driver per il Monitoraggio di GovWay
  68.  *
  69.  * @author Poli Andrea (apoli@link.it)
  70.  * @author $Author$
  71.  * @version $Rev$, $Date$
  72.  */

  74. public class DriverMonitoraggio implements IDriverMonitoraggio{

  76.     /** 
  77.      * DataSource
  78.      */
  79.     private DataSource datasource = null;

  81.     // Connection passata al momento della creazione dell'oggetto
  82.     private Connection globalConnection = null;
  83.     /**
  84.      * SQLQueryObject
  85.      */
  86.     private String tipoDatabase = null;


  89.     /** Logger utilizzato per info. */
  90.     private Logger log = null;
  91.     private void logError(String msg, Exception e) {
  92.         if(this.log!=null) {
  93.             this.log.error(msg, e);
  94.         }
  95.     }
  96.     private void logDebug(String msg) {
  97.         if(this.log!=null) {
  98.             this.log.debug(msg);
  99.         }
  100.     }

  102.     /**
  103.      * Properties
  104.      */
  105.     private List<String> properties;
  106.     public void setProperties(List<String> properties) {
  107.         this.properties = properties;
  108.     }

  110.     public DriverMonitoraggio(String nomeDataSource, String tipoDatabase, Properties prop) throws DriverMonitoraggioException {
  111.         this(nomeDataSource,tipoDatabase,prop,null);
  112.     }

  114.     public DriverMonitoraggio(String nomeDataSource, String tipoDatabase, Properties prop,Logger log) throws DriverMonitoraggioException {
  115.         // Logger
  116.         try {
  117.             if(log==null)
  118.                 this.log = LoggerWrapperFactory.getLogger(CostantiMonitoraggio.MONITORAGGIO_DRIVER_DB_LOGGER);
  119.             else
  120.                 this.log = log;
  121.         } catch (Exception e) {
  122.             throw new DriverMonitoraggioException("Errore durante l'inizializzazione del logger...",e);
  123.         }

  125.         // Datasource
  126.         try {
  127.             this.log.info("Inizializzo DriverMonitoraggioDB...");
  128.             InitialContext initCtx = new InitialContext(prop);
  129.             this.datasource = (DataSource) initCtx.lookup(nomeDataSource);
  130.             if (this.datasource == null)
  131.                 throw new DriverMonitoraggioException ("datasource is null");

  133.             initCtx.close();
  134.             this.log.info("Inizializzo DriverMonitoraggioDB terminata.");
  135.         } catch (Exception e) {
  136.             this.logError("Errore durante la ricerca del datasource...",e);
  137.             throw new DriverMonitoraggioException("Errore durante la ricerca del datasource...",e);
  138.         }

  140.         // ISQLQueryObject SQLObjectFactory
  141.         try {
  142.             this.log.info("Inizializzo ISQLQueryObject ...");
  143.             if (TipiDatabase.isAMember(tipoDatabase)) {
  144.                 this.tipoDatabase = tipoDatabase;               
  145.             } else {
  146.                 throw new DriverMonitoraggioException("Tipo database non gestito");
  147.             }

  149.             this.log.info("Inizializzo ISQLQueryObject terminata.");

  151.         } catch (Exception e) {
  152.             this.logError("Errore durante la ricerca del SQLQueryObject...",e);
  153.             throw new DriverMonitoraggioException("Errore durante la ricerca del SQLQueryObject("+tipoDatabase+")...",e);
  154.         }
  155.     }



  159.     public DriverMonitoraggio(String connectionUrl, String driverJDBC,
  160.             String username, String password, String tipoDatabase)
  161.                     throws DriverMonitoraggioException {
  162.         this(connectionUrl, driverJDBC, username, password, tipoDatabase, null);
  163.     }

  165.     public DriverMonitoraggio(String connectionUrl, String driverJDBC,
  166.             String username, String password, String tipoDatabase,Logger log)
  167.                     throws DriverMonitoraggioException {
  168.         // Logger
  169.         try {
  170.             if(log==null)
  171.                 this.log = LoggerWrapperFactory.getLogger(CostantiMonitoraggio.MONITORAGGIO_DRIVER_DB_LOGGER);
  172.             else
  173.                 this.log = log;
  174.         } catch (Exception e) {
  175.             throw new DriverMonitoraggioException("Errore durante l'inizializzazione del logger...",e);
  176.         }

  178.         // Connection
  179.         try{
  180.             this.log.info("Inizializzo DriverMonitoraggioDB...");
  181.             ClassLoaderUtilities.newInstance(driverJDBC);
  182.             this.globalConnection = initConnection(connectionUrl, username, password);
  183.             checkConnection(this.globalConnection);
  184.             this.log.info("Inizializzo DriverMonitoraggioDB terminata.");
  185.         } catch (Exception e) {
  186.             this.logError("Errore durante l'inizializzazione della connessione...",e);
  187.             throw new DriverMonitoraggioException("Errore durante l'inizializzazione della connessione...",e);
  188.         }

  190.         // ISQLQueryObject SQLObjectFactory
  191.         try {
  192.             this.log.info("Inizializzo ISQLQueryObject ...");
  193.             if (TipiDatabase.isAMember(tipoDatabase)) {
  194.                 this.tipoDatabase = tipoDatabase;               
  195.             } else {
  196.                 throw new DriverMonitoraggioException("Tipo database non gestito");
  197.             }

  199.             this.log.info("Inizializzo ISQLQueryObject terminata.");

  201.         } catch (Exception e) {
  202.             this.logError("Errore durante la ricerca del SQLQueryObject...",e);
  203.             throw new DriverMonitoraggioException("Errore durante la ricerca del SQLQueryObject("+tipoDatabase+")...",e);
  204.         }
  205.     }


  208.     private static Connection initConnection(String connectionUrl, String username, String password) throws SQLException {
  209.         if(username!=null){
  210.             return DriverManager.getConnection(connectionUrl,username,password);
  211.         }else{
  212.             return DriverManager.getConnection(connectionUrl);
  213.         }
  214.     }
  215.     private static void checkConnection(Connection con) throws DriverMonitoraggioException {
  216.         if(con == null){
  217.             throw new DriverMonitoraggioException("Connection is null");
  218.         }
  219.     }
  220.     
  221.     private Connection getConnection() throws SQLException {
  222.         if (this.datasource!=null)
  223.             return this.datasource.getConnection();
  224.         else
  225.             return this.globalConnection;
  226.     }
  227.     private void releaseConnection(Connection con) {
  228.         try{
  229.             if(this.datasource!=null && con!=null) {
  230.                 JDBCUtilities.closeConnection(BasicComponentFactory.getCheckLogger(), con, BasicComponentFactory.isCheckAutocommit(), BasicComponentFactory.isCheckIsClosed());
  231.             }
  232.         }catch(Exception e){
  233.             // close
  234.         }
  235.     }

  237.     /**
  238.      * Ritorna lo stato delle richieste pendenti che matchano il criterio di filtro.
  239.      * 
  240.      * @param search criterio di filtro
  241.      * @return stato delle richieste pendenti
  242.      * @throws DriverMonitoraggioException
  243.      */
  244.     @Override
  245.     public StatoPdd getStatoRichiestePendenti(FilterSearch search) throws DriverMonitoraggioException{
  246.         Connection con = null;
  247.         PreparedStatement pstmt = null;
  248.         ResultSet rs = null;
  249.         ISQLQueryObject sqlQueryObject = null;
  250.         try{

  252.             // Ottengo connessione
  253.             con = getConnection();
  254.             if(con==null)
  255.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  257.             StatoPdd statoPdD = new StatoPdd();
  258.             java.sql.Timestamp now = DateManager.getTimestamp();
  259.             java.sql.Timestamp dataRegistrazioneLimite = null;
  260.             //  FILTRO d) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia()) Soglia in Minuti
  261.             if(search.getSoglia()!=-1){
  262.                 dataRegistrazioneLimite = new java.sql.Timestamp(DateManager.getTimeMillis()-(search.getSoglia()*1000*60));
  263.             }


  266.             // TotaleMessaggi
  267.             long totaleMessaggi = 0;
  268.             long totaleMessaggiDuplicati = -1;
  269.             sqlQueryObject = this.newSQLQueryObjectStatoRichiestePendenti(search);
  270.             pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  271.             int paramIndex = 0;
  272.             if(search.getSoglia()!=-1)
  273.                 pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  274.             List<BustaSoggetto> filtroSoggetti = search.getSoggettoList();
  275.             if(filtroSoggetti!=null){           
  276.                 for(int k=0; k<filtroSoggetti.size(); k++){

  278.                     // fruitore
  279.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  280.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  282.                     // OR

  284.                     // erogatore
  285.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  286.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  287.                 }
  288.             }
  289.             rs = pstmt.executeQuery();
  290.             if(rs.next()){
  291.                 totaleMessaggi = rs.getLong("totMessaggi");
  292.                 if(totaleMessaggi>0){
  293.                     statoPdD.setTotMessaggi(totaleMessaggi);
  294.                     statoPdD.setTempoMedioAttesa((now.getTime()-rs.getLong("ora_registrazione_media"))/1000);
  295.                     statoPdD.setTempoMaxAttesa((now.getTime()-rs.getLong("ora_registrazione_old"))/1000);
  296.                 }
  297.             }
  298.             rs.close();
  299.             pstmt.close();
  300.             this.logDebug("query["+sqlQueryObject+"] totaleMessaggi:"+totaleMessaggi);
  301.             this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggi");

  303.             if(totaleMessaggi>0){

  305.                 // Messaggi in Consegna
  306.                 if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) || (StatoMessaggio.CONSEGNA.equals(search.getStato())) ){
  307.                     sqlQueryObject = this.newSQLQueryObjectStatoRichiestePendenti(search);
  308.                     if((search.getStato()==null) || ("".equals(search.getStato().getValue()))){
  309.                         sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".PROPRIETARIO='"+ConsegnaContenutiApplicativi.ID_MODULO+"'");
  310.                     }
  311.                     pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  312.                     paramIndex = 0;
  313.                     if(search.getSoglia()!=-1)
  314.                         pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  315.                     if(filtroSoggetti!=null){
  316.                         for(int k=0; k<filtroSoggetti.size(); k++){

  318.                             // fruitore
  319.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  320.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  322.                             // OR

  324.                             // erogatore
  325.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  326.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  327.                         }
  328.                     }
  329.                     rs = pstmt.executeQuery();
  330.                     if(rs.next()){
  331.                         long tot = rs.getLong("totMessaggi");
  332.                         if(tot>0){
  333.                             statoPdD.setNumMsgInConsegna(tot);
  334.                             statoPdD.setTempoMedioAttesaInConsegna((now.getTime()-rs.getLong("ora_registrazione_media"))/1000);
  335.                             statoPdD.setTempoMaxAttesaInConsegna((now.getTime()-rs.getLong("ora_registrazione_old"))/1000);
  336.                         }
  337.                     }
  338.                     rs.close();
  339.                     pstmt.close();
  340.                     this.logDebug("query["+sqlQueryObject+"] totaleMessaggiInConsegna:"+statoPdD.getNumMsgInConsegna());
  341.                     this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggiInConsegna");
  342.                 }

  344.                 // Messaggi in Spedizione
  345.                 if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) || (StatoMessaggio.SPEDIZIONE.equals(search.getStato())) ){
  346.                     sqlQueryObject = this.newSQLQueryObjectStatoRichiestePendenti(search);
  347.                     if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) ){
  348.                         sqlQueryObject.addWhereCondition(false,GestoreMessaggi.MESSAGGI+".PROPRIETARIO='InoltroBuste'",
  349.                                 GestoreMessaggi.MESSAGGI+".PROPRIETARIO='InoltroRisposte'");
  350.                     }
  351.                     pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  352.                     paramIndex = 0;
  353.                     if(search.getSoglia()!=-1)
  354.                         pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  355.                     if(filtroSoggetti!=null){
  356.                         for(int k=0; k<filtroSoggetti.size(); k++){

  358.                             // fruitore
  359.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  360.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  362.                             // OR

  364.                             // erogatore
  365.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  366.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  367.                         }
  368.                     }
  369.                     rs = pstmt.executeQuery();
  370.                     if(rs.next()){
  371.                         long tot = rs.getLong("totMessaggi");
  372.                         if(tot>0){
  373.                             statoPdD.setNumMsgInSpedizione(tot);
  374.                             statoPdD.setTempoMedioAttesaInSpedizione((now.getTime()-rs.getLong("ora_registrazione_media"))/1000);
  375.                             statoPdD.setTempoMaxAttesaInSpedizione((now.getTime()-rs.getLong("ora_registrazione_old"))/1000);
  376.                         }
  377.                     }
  378.                     rs.close();
  379.                     pstmt.close();
  380.                     this.logDebug("query["+sqlQueryObject+"] totaleMessaggiInSpedizione:"+statoPdD.getNumMsgInSpedizione());
  381.                     this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggiInSpedizione");
  382.                 }

  384.                 // Messaggi ne in Spedizione, ne in Consegna (PROCESSAMENTO) 
  385.                 if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) || (StatoMessaggio.PROCESSAMENTO.equals(search.getStato())) ){
  386.                     sqlQueryObject = this.newSQLQueryObjectStatoRichiestePendenti(search);
  387.                     if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) ){
  388.                         sqlQueryObject.addWhereCondition(true, GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'InoltroBuste'",
  389.                                 GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'InoltroRisposte'",
  390.                                 GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+ConsegnaContenutiApplicativi.ID_MODULO+"'");
  391.                     }
  392.                     pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  393.                     paramIndex = 0;
  394.                     if(search.getSoglia()!=-1)
  395.                         pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  396.                     if(filtroSoggetti!=null){
  397.                         for(int k=0; k<filtroSoggetti.size(); k++){

  399.                             // fruitore
  400.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  401.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  403.                             // OR

  405.                             // erogatore
  406.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  407.                             pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  408.                         }
  409.                     }
  410.                     rs = pstmt.executeQuery();
  411.                     if(rs.next()){
  412.                         long tot = rs.getLong("totMessaggi");
  413.                         if(tot>0){
  414.                             statoPdD.setNumMsgInProcessamento(tot);
  415.                             statoPdD.setTempoMedioAttesaInProcessamento((now.getTime()-rs.getLong("ora_registrazione_media"))/1000);
  416.                             statoPdD.setTempoMaxAttesaInProcessamento((now.getTime()-rs.getLong("ora_registrazione_old"))/1000);
  417.                         }
  418.                     }
  419.                     rs.close();
  420.                     pstmt.close();
  421.                     this.logDebug("query["+sqlQueryObject+"] totaleMessaggiInProcessamento:"+statoPdD.getNumMsgInProcessamento());
  422.                     this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggiInProcessamento");
  423.                 }

  425.             }

  427.             // MessaggiDuplicati
  428.             this.logDebug("Calcolo numero pacchetti duplicati...");
  429.             sqlQueryObject = this.newSQLQueryPacchettiDuplicati(search);
  430.             pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  431.             if(search.getSoglia()!=-1)
  432.                 pstmt.setTimestamp(1, dataRegistrazioneLimite);
  433.             rs = pstmt.executeQuery();
  434.             if(rs.next()){
  435.                 totaleMessaggiDuplicati = rs.getLong("numduplicati");
  436.                 statoPdD.setTotMessaggiDuplicati(totaleMessaggiDuplicati);
  437.             }
  438.             rs.close();
  439.             pstmt.close();
  440.             this.logDebug("query["+sqlQueryObject.toString()+"] totaleMessaggiDuplicati:"+totaleMessaggiDuplicati);
  441.             this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggiDuplicati");


  444.             return statoPdD;

  446.         }catch(Exception e){
  447.             if(sqlQueryObject!=null){
  448.                 this.logError("getStatoRichiestePendenti error SQL["+sqlQueryObject.toString()+"]",e);
  449.                 throw new DriverMonitoraggioException("getStatoRichiestePendenti error SQL["+sqlQueryObject.toString()+"]: "+e.getMessage(),e);
  450.             }else{
  451.                 this.logError("getStatoRichiestePendenti error",e);
  452.                 throw new DriverMonitoraggioException("getStatoRichiestePendenti error: "+e.getMessage(),e);
  453.             }

  455.         }finally{
  456.             JDBCUtilities.closeResources(rs, pstmt);
  457.             releaseConnection(con);
  458.         }
  459.     }

  461.     /**
  462.      * Ritorna semplicemente il numero di messaggi in gestione
  463.      * 
  464.      * @return il numero di messaggi in gestione
  465.      * @throws DriverMonitoraggioException
  466.      */
  467.     public long getTotaleMessaggiInGestione() throws DriverMonitoraggioException{
  468.         Connection con = null;
  469.         PreparedStatement pstmt = null;
  470.         ResultSet rs = null;
  471.         try{

  473.             // Ottengo connessione
  474.             con = getConnection();
  475.             if(con==null)
  476.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  478.             // TotaleMessaggi
  479.             long totaleMessaggi = 0;
  480.             String query = "SELECT count(*) as totMessaggi FROM "+GestoreMessaggi.MESSAGGI+" WHERE "+GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+TimerGestoreMessaggi.ID_MODULO+"'";
  481.             pstmt = con.prepareStatement(query);
  482.             rs = pstmt.executeQuery();
  483.             if(rs.next()){
  484.                 totaleMessaggi = rs.getLong("totMessaggi");
  485.             }
  486.             rs.close();
  487.             pstmt.close();
  488.             this.logDebug("query["+query+"] totaleMessaggi:"+totaleMessaggi);

  490.             return totaleMessaggi;

  492.         }catch(Exception e){
  493.             this.logError("getTotaleMessaggiInGestione error",e);
  494.             throw new DriverMonitoraggioException("getStatoRichiestePendenti error: "+e.getMessage(),e);
  495.         }finally{
  496.             try{
  497.                 if(rs!=null)
  498.                     rs.close();
  499.             }catch(Exception e){
  500.                 // close
  501.             }
  502.             try{
  503.                 if(pstmt!=null)
  504.                     pstmt.close();
  505.             }catch(Exception e){
  506.                 // close
  507.             }
  508.             releaseConnection(con);
  509.         }
  510.     }

  512.     /**
  513.      * Ritorna il numero delle richieste pendenti che matchano il criterio di filtro.
  514.      * 
  515.      * @param search criterio di filtro
  516.      * @return numero di richieste pendenti
  517.      * @throws DriverMonitoraggioException
  518.      */
  519.     @Override
  520.     public long countListaRichiestePendenti(FilterSearch search) throws DriverMonitoraggioException{
  521.         Connection con = null;
  522.         PreparedStatement pstmt = null;
  523.         ResultSet rs = null;
  524.         ISQLQueryObject sqlQueryObject = null;
  525.         // Congelamento di offset e limit (per la count non deve essere utilizzato)
  526.         long oldLimit = search.getLimit();
  527.         long oldOffset = search.getOffset();
  528.         try{
  529.             // Ottengo connessione
  530.             con = getConnection();
  531.             if(con==null)
  532.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  534.             java.sql.Timestamp dataRegistrazioneLimite = null;
  535.             //  FILTRO d) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia()) Soglia in Minuti
  536.             if(search.getSoglia()!=-1){
  537.                 dataRegistrazioneLimite = new java.sql.Timestamp(DateManager.getTimeMillis()-(search.getSoglia()*1000*60));
  538.             }

  540.             // TotaleMessaggi: Il totale dei messaggi non deve subire influenze di offset/limit
  541.             long totaleMessaggi = 0;
  542.             search.setLimit(-1);
  543.             search.setOffset(-1);
  544.             sqlQueryObject = this.newSQLQueryObjectStatoRichiestePendenti(search);
  545.             pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  546.             int paramIndex = 0;
  547.             if(search.getSoglia()!=-1)
  548.                 pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  549.             List<BustaSoggetto> filtroSoggetti = search.getSoggettoList();
  550.             if(filtroSoggetti!=null){
  551.                 for(int k=0; k<filtroSoggetti.size(); k++){

  553.                     // fruitore
  554.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  555.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  557.                     // OR

  559.                     // erogatore
  560.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  561.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  562.                 }
  563.             }
  564.             rs = pstmt.executeQuery();
  565.             if(rs.next()){
  566.                 totaleMessaggi = rs.getLong("totMessaggi");
  567.             }
  568.             rs.close();
  569.             pstmt.close();
  570.             this.logDebug("query["+sqlQueryObject+"] totaleMessaggi:"+totaleMessaggi);
  571.             this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] totaleMessaggi");

  573.             return totaleMessaggi;

  575.         }catch(Exception e){
  576.             if(sqlQueryObject!=null){
  577.                 this.logError("getListaRichiestePendenti error SQL["+sqlQueryObject.toString()+"]",e);
  578.                 throw new DriverMonitoraggioException("getListaRichiestePendenti error SQL["+sqlQueryObject.toString()+"]: "+e.getMessage(),e);
  579.             }else{
  580.                 this.logError("getListaRichiestePendenti error",e);
  581.                 throw new DriverMonitoraggioException("getListaRichiestePendenti error: "+e.getMessage(),e);
  582.             }
  583.         }finally{
  584.             // ripristino valori offset/limit
  585.             search.setLimit(oldLimit);
  586.             search.setOffset(oldOffset);
  587.             JDBCUtilities.closeResources(rs, pstmt);
  588.             releaseConnection(con);
  589.         }
  590.     }

  592.     /**
  593.      * Ritorna I dettagli dei messaggi delle richieste pendenti che matchano il criterio di filtro.
  594.      * 
  595.      * @param search criterio di filtro
  596.      * @return dettagli dei messaggi delle richieste pendenti
  597.      * @throws DriverMonitoraggioException
  598.      */
  599.     @Override
  600.     public List<Messaggio> getListaRichiestePendenti(FilterSearch search) throws DriverMonitoraggioException{
  601.         Connection con = null;
  602.         PreparedStatement pstmt = null;
  603.         ResultSet rs = null;
  604.         ISQLQueryObject sqlQueryObject = null;
  605.         try{
  606.             // Ottengo connessione
  607.             con = getConnection();
  608.             if(con==null)
  609.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  611.             java.sql.Timestamp dataRegistrazioneLimite = null;
  612.             //  FILTRO d) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia()) Soglia in Minuti
  613.             if(search.getSoglia()!=-1){
  614.                 dataRegistrazioneLimite = new java.sql.Timestamp(DateManager.getTimeMillis()-(search.getSoglia()*1000*60));
  615.             }

  617.             List<BustaSoggetto> filtroSoggetti = search.getSoggettoList();

  619.             // Query
  620.             sqlQueryObject = this.newSQLQueryObjectListaRichiestePendenti(search);
  621.             pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  622.             int paramIndex = 0;
  623.             if(search.getSoglia()!=-1)
  624.                 pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  625.             if(filtroSoggetti!=null){
  626.                 for(int k=0; k<filtroSoggetti.size(); k++){

  628.                     // fruitore
  629.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  630.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  632.                     // OR

  634.                     // erogatore
  635.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  636.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  637.                 }
  638.             }
  639.             rs = pstmt.executeQuery();
  640.             List<Messaggio> msgs = new ArrayList<>();

  642.             this.logDebug("query["+sqlQueryObject+"] listaMessaggi");
  643.             this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] listaMessaggi");
  644.             
  645.             while(rs.next()){
  646.                 Messaggio m = new Messaggio();
  647.                 // id
  648.                 m.setIdMessaggio(rs.getString("id_messaggio"));
  649.                 // Dettaglio
  650.                 Dettaglio dettaglio = new Dettaglio();
  651.                 dettaglio.setIdModulo(rs.getString("PROPRIETARIO"));
  652.                 dettaglio.setTipo(rs.getString("tipo"));
  653.                 dettaglio.setErroreProcessamento(rs.getString("ERRORE_PROCESSAMENTO"));
  654.                 dettaglio.setIdCorrelazioneApplicativa(rs.getString("CORRELAZIONE_APPLICATIVA"));
  655.                 if(this.properties!=null){
  656.                     for (int i = 0; i < this.properties.size(); i++) {
  657.                         String key = this.properties.get(i);
  658.                         Proprieta proprieta = new Proprieta();
  659.                         proprieta.setNome(key);
  660.                         proprieta.setValore(rs.getString(key));
  661.                         dettaglio.addProprieta(proprieta);
  662.                     }
  663.                 }
  664.                 m.setDettaglio(dettaglio);
  665.                 // Ora Registrazione
  666.                 if(rs.getTimestamp("ORA_REGISTRAZIONE")!=null){
  667.                     m.setOraRegistrazione(rs.getTimestamp("ORA_REGISTRAZIONE"));
  668.                 }
  669.                 // Ora Attuale
  670.                 m.setOraAttuale(DateManager.getDate());
  671.                 // Stato
  672.                 if(ConsegnaContenutiApplicativi.ID_MODULO.equals(rs.getString("PROPRIETARIO"))){
  673.                     m.setStato(StatoMessaggio.CONSEGNA);
  674.                 }else if(InoltroBuste.ID_MODULO.equals(rs.getString("PROPRIETARIO"))){
  675.                     m.setStato(StatoMessaggio.SPEDIZIONE);
  676.                 }else if(InoltroRisposte.ID_MODULO.equals(rs.getString("PROPRIETARIO"))){
  677.                     m.setStato(StatoMessaggio.SPEDIZIONE);
  678.                 }else {
  679.                     m.setStato(StatoMessaggio.PROCESSAMENTO);
  680.                 }

  682.                 // Info
  683.                 if(search.getBusta()!=null){
  684.                     Busta bustaInfo = new Busta();
  685.                     // Mittente
  686.                     BustaSoggetto mittente = new BustaSoggetto();
  687.                     mittente.setNome(rs.getString("MITTENTE"));
  688.                     mittente.setTipo(rs.getString("TIPO_MITTENTE"));
  689.                     bustaInfo.setMittente(mittente);
  690.                     // Destinatario
  691.                     BustaSoggetto destinatario = new BustaSoggetto();
  692.                     destinatario.setNome(rs.getString("DESTINATARIO"));
  693.                     destinatario.setTipo(rs.getString("TIPO_DESTINATARIO"));
  694.                     bustaInfo.setDestinatario(destinatario);
  695.                     // Servizio
  696.                     BustaServizio servizio = new BustaServizio();
  697.                     servizio.setTipo(rs.getString("TIPO_SERVIZIO"));
  698.                     servizio.setNome(rs.getString("SERVIZIO"));
  699.                     try {
  700.                         servizio.setVersione(Integer.valueOf(rs.getString("VERSIONE_SERVIZIO")));
  701.                     }catch(Exception e) {
  702.                         // ignore
  703.                     }
  704.                     bustaInfo.setServizio(servizio);
  705.                     // Azione
  706.                     bustaInfo.setAzione(rs.getString("AZIONE"));
  707.                     // Profilo di Collaborazione
  708.                     bustaInfo.setProfiloCollaborazione(rs.getString("PROFILO_DI_COLLABORAZIONE"));
  709.                     // RiferimentoMessaggio
  710.                     bustaInfo.setRiferimentoMessaggio(rs.getString("RIFERIMENTO_MESSAGGIO"));
  711.                     //  Collaborazione
  712.                     bustaInfo.setCollaborazione(rs.getString("COLLABORAZIONE"));
  713.                     m.setBustaInfo(bustaInfo);
  714.                 }
  715.                 msgs.add(m);
  716.             }
  717.             rs.close();
  718.             pstmt.close();

  720.             for(int i=0; i<msgs.size(); i++){

  722.                 //  Prendo Dettaglio servizio applicativo per messaggi in consegna
  723.                 boolean checkSA = false;
  724.                 if(msgs.get(i)!=null && 
  725.                         StatoMessaggio.CONSEGNA.equals(msgs.get(i).getStato()) &&
  726.                         msgs.get(i).getDettaglio()!=null){
  727.                     checkSA = true;
  728.                 }else if(msgs.get(i)!=null &&  msgs.get(i).getDettaglio()!=null && 
  729.                         msgs.get(i).getDettaglio().getIdModulo()!=null &&
  730.                         msgs.get(i).getDettaglio().getIdModulo().startsWith("RicezioneContenutiApplicativi")){
  731.                     checkSA = true;
  732.                 }                   
  733.                 if(checkSA){
  734.                     this.logDebug("Raccolgo informazioni dei servizi applicativi...");
  735.                     String sqlQuerySA = "SELECT * FROM "+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI +
  736.                             " WHERE ID_MESSAGGIO=?";
  737.                     pstmt = con.prepareStatement(sqlQuerySA);
  738.                     pstmt.setString(1, msgs.get(i).getIdMessaggio());
  739.                     rs = pstmt.executeQuery();
  740.                     List<ServizioApplicativoConsegna> sconsegna = new ArrayList<>();
  741.                     while(rs.next()){
  742.                         ServizioApplicativoConsegna datiConsegna = new ServizioApplicativoConsegna();
  743.                         if(rs.getInt("SBUSTAMENTO_SOAP")==1)
  744.                             datiConsegna.setSbustamentoSoap(true);
  745.                         else
  746.                             datiConsegna.setSbustamentoSoap(false);
  747.                         if(rs.getInt("SBUSTAMENTO_INFO_PROTOCOL")==1)
  748.                             datiConsegna.setSbustamentoInformazioniProtocollo(true);
  749.                         else
  750.                             datiConsegna.setSbustamentoInformazioniProtocollo(false);
  751.                         if(rs.getInt("INTEGRATION_MANAGER")==1)
  752.                             datiConsegna.setAutorizzazioneIntegrationManager(true);
  753.                         else
  754.                             datiConsegna.setAutorizzazioneIntegrationManager(false);
  755.                         datiConsegna.setNome(rs.getString("SERVIZIO_APPLICATIVO"));
  756.                         datiConsegna.setTipoConsegna(rs.getString("TIPO_CONSEGNA"));
  757.                         datiConsegna.setErroreProcessamento(rs.getString("ERRORE_PROCESSAMENTO"));
  758.                         if(rs.getTimestamp("RISPEDIZIONE")!=null){
  759.                             datiConsegna.setDataRispedizione(rs.getTimestamp("RISPEDIZIONE"));
  760.                         }
  761.                         datiConsegna.setNomePorta(rs.getString("NOME_PORTA"));
  762.                         datiConsegna.setCoda(rs.getString("CODA"));
  763.                         datiConsegna.setPriorita(rs.getString("PRIORITA"));
  764.                         if(rs.getInt("ATTESA_ESITO")==1)
  765.                             datiConsegna.setAttesaEsito(true);
  766.                         else
  767.                             datiConsegna.setAttesaEsito(false);
  768.                         sconsegna.add(datiConsegna);
  769.                     }
  770.                     rs.close();
  771.                     pstmt.close();

  773.                     if(!sconsegna.isEmpty()){
  774.                         msgs.get(i).getDettaglio().setServizioApplicativoConsegnaList(sconsegna);
  775.                     }

  777.                 }

  779.                 if(msgs.get(i)!=null &&  msgs.get(i).getBustaInfo()!=null &&
  780.                         StatoMessaggio.SPEDIZIONE.equals(msgs.get(i).getStato())){
  781.                     // Prendo dettaglio AttesaRiscontro
  782.                     if(search.getBusta()!=null && search.getBusta().isAttesaRiscontro()){
  783.                         msgs.get(i).getBustaInfo().setAttesaRiscontro(true);
  784.                     }else{
  785.                         this.logDebug("Raccolgo informazioni per attesa riscontro...");
  786.                         String sqlQueryRiscontro = "SELECT * FROM "+Costanti.RISCONTRI_DA_RICEVERE +
  787.                                 " WHERE ID_MESSAGGIO=?";
  788.                         pstmt = con.prepareStatement(sqlQueryRiscontro);
  789.                         pstmt.setString(1, msgs.get(i).getIdMessaggio());
  790.                         rs = pstmt.executeQuery();
  791.                         msgs.get(i).getBustaInfo().setAttesaRiscontro(rs.next());
  792.                         rs.close();
  793.                         pstmt.close();
  794.                     }
  795.                 }
  796.             }


  799.             return msgs;

  801.         }catch(Exception e){
  802.             if(sqlQueryObject!=null){
  803.                 this.logError("getListaRichiestePendenti error SQL["+sqlQueryObject.toString()+"]",e);
  804.                 throw new DriverMonitoraggioException("getListaRichiestePendenti error SQL["+sqlQueryObject.toString()+"]: "+e.getMessage(),e);
  805.             }else{
  806.                 this.logError("getListaRichiestePendenti error",e);
  807.                 throw new DriverMonitoraggioException("getListaRichiestePendenti error: "+e.getMessage(),e);
  808.             }
  809.         }finally{
  810.             JDBCUtilities.closeResources(rs, pstmt);
  811.             releaseConnection(con);
  812.         }
  813.     }


  816.     /**
  817.      * Elimina puntualmente il messaggio indicato dall'id.
  818.      * 
  819.      * @param idMessaggio messaggio da eliminare
  820.      * @throws DriverMonitoraggioException
  821.      */
  822.     private boolean deleteMessaggio(String idMessaggio,String tipo) throws DriverMonitoraggioException{
  823.         Connection con = null;
  824.         PreparedStatement pstmt = null;
  825.         try{

  827.             // Ottengo connessione
  828.             con = getConnection();
  829.             if(con==null)
  830.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  832.             // Raccolta valori chiave
  833.             // TIPO
  834.             String tipoMessaggio = tipo;
  835.             // Ricerco tipoMessaggio se non presenti 
  836.             if(tipoMessaggio==null){
  837.                 this.logDebug("Ricerco tipo messaggio...");
  838.                 FilterSearch filtro = new FilterSearch();
  839.                 filtro.setIdMessaggio(idMessaggio);
  840.                 List<Messaggio> lista = this.getListaRichiestePendenti(filtro);
  841.                 if(lista==null || lista.isEmpty()){
  842.                     return false; // messaggio non presente
  843.                 }
  844.                 if(lista.get(0).getDettaglio()==null ||
  845.                         lista.get(0).getDettaglio().getTipo()==null){
  846.                     throw new DriverMonitoraggioException("Tipo messaggio non identificato per l'id: "+idMessaggio);
  847.                 }
  848.                 tipoMessaggio = lista.get(0).getDettaglio().getTipo();
  849.             }
  850.             this.logDebug("Messaggio con id("+idMessaggio+") da eliminare possiede tipo: "+tipoMessaggio);

  852.             if(Costanti.OUTBOX.equals(tipoMessaggio)){
  853.                 // Elimino eventuali riscontri
  854.                 String sqlQuery = "DELETE FROM "+Costanti.RISCONTRI_DA_RICEVERE + " WHERE ID_MESSAGGIO=?";
  855.                 pstmt = con.prepareStatement(sqlQuery);
  856.                 pstmt.setString(1, idMessaggio);
  857.                 int operation = pstmt.executeUpdate();
  858.                 if(operation>0){
  859.                     this.logDebug("Attesa riscontro per "+idMessaggio+" eliminato");
  860.                 }else{
  861.                     this.logDebug("Attesa riscontro per "+idMessaggio+" non esistente");
  862.                 }
  863.                 pstmt.close();

  865.                 // Elimino eventuali asincroni
  866.                 sqlQuery = "DELETE FROM "+Costanti.PROFILO_ASINCRONO + " WHERE ID_MESSAGGIO=? AND TIPO=?";
  867.                 pstmt = con.prepareStatement(sqlQuery);
  868.                 pstmt.setString(1, idMessaggio);
  869.                 pstmt.setString(2, tipoMessaggio);
  870.                 operation = pstmt.executeUpdate();
  871.                 if(operation>0){
  872.                     this.logDebug("ProfiloAsincrono per "+idMessaggio+" eliminato");
  873.                 }else{
  874.                     this.logDebug("ProfiloAsincrono per "+idMessaggio+" non esistente");
  875.                 }
  876.                 pstmt.close();
  877.             }


  880.             // Elimino messaggio
  881.             String sqlQuery = "UPDATE "+GestoreMessaggi.MESSAGGI + " SET PROPRIETARIO='"+TimerGestoreMessaggi.ID_MODULO+"' WHERE PROPRIETARIO<>'"+TimerGestoreMessaggi.ID_MODULO+"' AND ID_MESSAGGIO=?  AND tipo=?";
  882.             pstmt = con.prepareStatement(sqlQuery);
  883.             pstmt.setString(1, idMessaggio);
  884.             pstmt.setString(2, tipoMessaggio);
  885.             int operation = pstmt.executeUpdate();
  886.             boolean result = false;
  887.             if(operation>0){
  888.                 result = true;
  889.                 this.logDebug("Messaggio "+idMessaggio+" eliminato");
  890.             }else{
  891.                 this.logDebug("Messaggio "+idMessaggio+" non esistente");
  892.             }
  893.             pstmt.close();
  894.             return result;

  896.         }catch(Exception e){
  897.             this.logError("deleteMessaggio error",e);
  898.             throw new DriverMonitoraggioException("deleteMessaggio error: "+e.getMessage());
  899.         }finally{
  900.             JDBCUtilities.closeResources(pstmt);
  901.             releaseConnection(con);
  902.         }
  903.     }
  904.     
  905.     private boolean aggiornaDataRispedizioneMessaggio(String idMessaggio,String tipo,Timestamp data) throws DriverMonitoraggioException{
  906.         Connection con = null;
  907.         PreparedStatement pstmt = null;
  908.         try{

  910.             // Ottengo connessione
  911.             con = getConnection();
  912.             if(con==null)
  913.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  915.             // Raccolta valori chiave
  916.             // TIPO
  917.             String tipoMessaggio = tipo;
  918.             // Ricerco tipoMessaggio se non presenti 
  919.             if(tipoMessaggio==null){
  920.                 this.logDebug("Ricerco tipo messaggio...");
  921.                 FilterSearch filtro = new FilterSearch();
  922.                 filtro.setIdMessaggio(idMessaggio);
  923.                 List<Messaggio> lista = this.getListaRichiestePendenti(filtro);
  924.                 if(lista==null || lista.isEmpty()){
  925.                     return false; // messaggio non presente
  926.                 }
  927.                 if(lista.get(0).getDettaglio()==null ||
  928.                         lista.get(0).getDettaglio().getTipo()==null){
  929.                     throw new DriverMonitoraggioException("Tipo messaggio non identificato per l'id: "+idMessaggio);
  930.                 }
  931.                 tipoMessaggio = lista.get(0).getDettaglio().getTipo();
  932.             }
  933.             this.logDebug("Messaggio con id("+idMessaggio+") da eliminare possiede tipo: "+tipoMessaggio);

  935.             if(Costanti.OUTBOX.equals(tipoMessaggio)){
  936.                 // Aggiorno messaggio
  937.                 String sqlQuery = "UPDATE "+GestoreMessaggi.MESSAGGI + " SET RISPEDIZIONE=? WHERE ID_MESSAGGIO=?  AND TIPO=?";
  938.                 pstmt = con.prepareStatement(sqlQuery);
  939.                 pstmt.setTimestamp(1, data);
  940.                 pstmt.setString(2, idMessaggio);
  941.                 pstmt.setString(3, tipoMessaggio);
  942.                 int operation = pstmt.executeUpdate();
  943.                 boolean result = false;
  944.                 if(operation>0){
  945.                     result = true;
  946.                     this.logDebug("Messaggio "+idMessaggio+" aggiornato");
  947.                 }else{
  948.                     this.logDebug("Messaggio "+idMessaggio+" non aggiornato");
  949.                 }
  950.                 pstmt.close();
  951.                 return result;  
  952.             }
  953.             else {
  954.                 // Aggiorno messaggio
  955.                 String sqlQuery = "UPDATE "+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI + " SET RISPEDIZIONE=? WHERE ID_MESSAGGIO=?  AND TIPO=?";
  956.                 pstmt = con.prepareStatement(sqlQuery);
  957.                 pstmt.setTimestamp(1, data);
  958.                 pstmt.setString(2, idMessaggio);
  959.                 pstmt.setString(3, tipoMessaggio);
  960.                 int operation = pstmt.executeUpdate();
  961.                 boolean result = false;
  962.                 if(operation>0){
  963.                     result = true;
  964.                     this.logDebug("Messaggio "+idMessaggio+" aggiornato");
  965.                 }else{
  966.                     this.logDebug("Messaggio "+idMessaggio+" non aggiornato");
  967.                 }
  968.                 pstmt.close();
  969.                 return result;  
  970.             }

  972.         }catch(Exception e){
  973.             this.logError("deleteMessaggio error",e);
  974.             throw new DriverMonitoraggioException("deleteMessaggio error: "+e.getMessage());
  975.         }finally{
  976.             try{
  977.                 if(pstmt!=null)
  978.                     pstmt.close();
  979.             }catch(Exception e){
  980.                 // close
  981.             }
  982.             releaseConnection(con);
  983.         }
  984.     }



  988.     /**
  989.      * Ritorna e cancella i dettagli dei messaggi delle richieste pendenti che matchano il criterio di filtro.
  990.      * 
  991.      * @param search criterio di filtro
  992.      * @return dettagli dei messaggi delle richieste pendenti
  993.      * @throws DriverMonitoraggioException
  994.      */
  995.     @Override
  996.     public long deleteRichiestePendenti(FilterSearch search) throws DriverMonitoraggioException{
  997.         return richiestePendentiEngine(search, true);
  998.     }
  999.     
  1000.     /**
  1001.      * Aggiorna la data di rispedizione delle richieste pendenti che matchano il criterio di filtro.
  1002.      * 
  1003.      * @param search criterio di filtro
  1004.      * @return numero dei messaggi delle richieste pendenti
  1005.      * @throws DriverMonitoraggioException
  1006.      */
  1007.     @Override
  1008.     public long aggiornaDataRispedizioneRichiestePendenti(FilterSearch search) throws DriverMonitoraggioException{
  1009.         return richiestePendentiEngine(search, false);
  1010.     }
  1011.     
  1012.     private long richiestePendentiEngine(FilterSearch search, boolean delete) throws DriverMonitoraggioException{
  1013.         
  1014.         String nomeMetodo = delete? "deleteRichiestePendenti":"aggiornaDataRispedizioneRichiestePendenti";
  1015.         
  1016.         Connection con = null;
  1017.         PreparedStatement pstmt = null;
  1018.         ResultSet rs = null;
  1019.         ISQLQueryObject sqlQueryObject = null;
  1020.         try{
  1021.             // Ottengo connessione
  1022.             con = getConnection();
  1023.             if(con==null)
  1024.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  1026.             java.sql.Timestamp dataRegistrazioneLimite = null;
  1027.             //  FILTRO d) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia()) Soglia in Minuti
  1028.             if(search.getSoglia()!=-1){
  1029.                 dataRegistrazioneLimite = new java.sql.Timestamp(DateManager.getTimeMillis()-(search.getSoglia()*1000*60));
  1030.             }
  1031.             // Query
  1032.             sqlQueryObject = this.newSQLQueryObjectListaRichiestePendenti(search);
  1033.             pstmt = con.prepareStatement(sqlQueryObject.createSQLQuery());
  1034.             int paramIndex = 0;
  1035.             if(search.getSoglia()!=-1)
  1036.                 pstmt.setTimestamp(++paramIndex, dataRegistrazioneLimite);
  1037.             List<BustaSoggetto> filtroSoggetti = search.getSoggettoList();
  1038.             if(filtroSoggetti!=null){
  1039.                 for(int k=0; k<filtroSoggetti.size(); k++){

  1041.                     // fruitore
  1042.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  1043.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());

  1045.                     // OR

  1047.                     // erogatore
  1048.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getTipo());
  1049.                     pstmt.setString(++paramIndex, filtroSoggetti.get(k).getNome());
  1050.                 }
  1051.             }
  1052.             rs = pstmt.executeQuery();
  1053.             List<Messaggio> msgs = new ArrayList<>();

  1055.             this.logDebug("query["+sqlQueryObject+"] listaMessaggi");
  1056.             this.logDebug("Soglia ["+search.getSoglia()+"] ["+dataRegistrazioneLimite+"] listaMessaggi");

  1058.             while(rs.next()){
  1059.                 Messaggio m = new Messaggio();
  1060.                 // id
  1061.                 m.setIdMessaggio(rs.getString("ID_MESSAGGIO"));
  1062.                 // Dettaglio
  1063.                 Dettaglio dettaglio = new Dettaglio();
  1064.                 dettaglio.setTipo(rs.getString("tipo"));
  1065.                 m.setDettaglio(dettaglio);
  1066.                 msgs.add(m);
  1067.             }
  1068.             rs.close();
  1069.             pstmt.close();

  1071.             Timestamp now = DateManager.getTimestamp();
  1072.             
  1073.             long numeroMsg = 0;
  1074.             while(!msgs.isEmpty()){
  1075.                 Messaggio msgForDelete = msgs.remove(0);
  1076.                 if(delete) {
  1077.                     if(this.deleteMessaggio(msgForDelete.getIdMessaggio(), msgForDelete.getDettaglio().getTipo())) {
  1078.                         numeroMsg++;
  1079.                     }
  1080.                 }
  1081.                 else {
  1082.                     if(this.aggiornaDataRispedizioneMessaggio(msgForDelete.getIdMessaggio(), msgForDelete.getDettaglio().getTipo(), now)) {
  1083.                         numeroMsg++;
  1084.                     }
  1085.                 }
  1086.             }
  1087.             if(delete) {
  1088.                 this.logDebug("eliminati "+numeroMsg+" messaggi");
  1089.             }
  1090.             else {
  1091.                 this.logDebug("aggiornati "+numeroMsg+" messaggi");
  1092.             }

  1094.             return numeroMsg;

  1096.         }catch(Exception e){
  1097.             if(sqlQueryObject!=null){
  1098.                 this.logError(nomeMetodo+" error SQL["+sqlQueryObject.toString()+"]",e);
  1099.                 throw new DriverMonitoraggioException(nomeMetodo+" error SQL["+sqlQueryObject.toString()+"]: "+e.getMessage(),e);
  1100.             }else{
  1101.                 this.logError(nomeMetodo+" error",e);
  1102.                 throw new DriverMonitoraggioException(nomeMetodo+" error: "+e.getMessage(),e);
  1103.             }
  1104.         }finally{
  1105.             JDBCUtilities.closeResources(rs, pstmt);
  1106.             releaseConnection(con);
  1107.         }
  1108.     }


  1111.     @Override
  1112.     public StatoConsegneAsincrone getStatoConsegneAsincrone(FiltroStatoConsegnaAsincrona filtro) throws DriverMonitoraggioException{
  1113.         
  1114.         String nomeMetodo = "getStatoConsegneAsincrone";
  1115.         
  1116.         Connection con = null;
  1117.         PreparedStatement pstmt = null;
  1118.         ResultSet rs = null;
  1119.         String sqlQuery = null;
  1120.         try{
  1121.             // Ottengo connessione
  1122.             con = getConnection();
  1123.             if(con==null)
  1124.                 throw new DriverMonitoraggioException("Connection non ottenuta dal datasource["+this.datasource+"]");

  1126.             // Query
  1127.             sqlQuery = this.newSQLQueryStatoConsegneAsincrone(filtro);
  1128.             /**System.out.println("QUERY: "+sqlQuery);*/
  1129.             pstmt = con.prepareStatement(sqlQuery);
  1130.             rs = pstmt.executeQuery();
  1131.             StatoConsegneAsincrone stati = new StatoConsegneAsincrone();

  1133.             this.logDebug("query["+sqlQuery+"] getStatoConsegneAsincrone");
  1134.             
  1135.             while(rs.next()){
  1136.                 StatoConsegnaAsincrona stato = new StatoConsegnaAsincrona();
  1137.                 
  1138.                 // dati generali
  1139.                 stato.setNow(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_NOW));
  1140.                 stato.setServizioApplicativo(rs.getString(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO));
  1141.                 
  1142.                 // InCoda
  1143.                 stato.setInCoda(rs.getLong(StatoConsegnaAsincrona.ALIAS_IN_CODA));
  1144.                 stato.setVecchioInCoda(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO));
  1145.                 stato.setRecenteInCoda(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE));
  1146.                 
  1147.                 // InRiconsegna
  1148.                 stato.setInRiconsegna(rs.getLong(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA));
  1149.                 stato.setVecchioInRiconsegna(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO));
  1150.                 stato.setRecenteInRiconsegna(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE));
  1151.                 
  1152.                 // InMessageBox
  1153.                 stato.setInMessageBox(rs.getLong(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX));
  1154.                 stato.setVecchioInMessageBox(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO));
  1155.                 stato.setRecenteInMessageBox(rs.getTimestamp(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE));
  1156.                 
  1157.                 stati.addStato(stato);
  1158.             }
  1159.             rs.close();
  1160.             pstmt.close();

  1162.             this.logDebug("trovati "+stati.size()+" stati");
  1163.     
  1164.             return stati;

  1166.         }catch(Exception e){
  1167.             if(sqlQuery!=null){
  1168.                 this.logError(nomeMetodo+" error SQL["+sqlQuery+"]",e);
  1169.                 throw new DriverMonitoraggioException(nomeMetodo+" error SQL["+sqlQuery+"]: "+e.getMessage(),e);
  1170.             }else{
  1171.                 this.logError(nomeMetodo+" error",e);
  1172.                 throw new DriverMonitoraggioException(nomeMetodo+" error: "+e.getMessage(),e);
  1173.             }
  1174.         }finally{
  1175.             JDBCUtilities.closeResources(rs, pstmt);
  1176.             releaseConnection(con);
  1177.         }
  1178.         
  1179.     }
  1180.     
  1181.     




  1186.     private ISQLQueryObject newSQLQueryObjectStatoRichiestePendenti(FilterSearch search) throws SQLQueryObjectException{
  1187.         return newSQLQueryObjectRichiestePendenti(true,search);
  1188.     }
  1189.     private ISQLQueryObject newSQLQueryObjectListaRichiestePendenti(FilterSearch search) throws SQLQueryObjectException{
  1190.         return newSQLQueryObjectRichiestePendenti(false,search);
  1191.     }

  1193.     private ISQLQueryObject newSQLQueryObjectRichiestePendenti(boolean statoRichieste,FilterSearch search) throws SQLQueryObjectException{

  1195.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);

  1197.         // FROM TABLE
  1198.         sqlQueryObject.addFromTable(GestoreMessaggi.MESSAGGI);
  1199.         if( (search.getMessagePattern()!=null) && (!"".equals(search.getMessagePattern())) ){
  1200.             sqlQueryObject.addFromTable(GestoreMessaggi.DEFINIZIONE_MESSAGGI);
  1201.         }
  1202.         if( (search.getBusta()!=null) ){
  1203.             sqlQueryObject.addFromTable(Costanti.REPOSITORY);
  1204.             if(search.getBusta().isAttesaRiscontro()){
  1205.                 sqlQueryObject.addFromTable(Costanti.RISCONTRI_DA_RICEVERE);
  1206.             }
  1207.         }else if(search.getSoggettoList()!=null && !search.getSoggettoList().isEmpty()){
  1208.             sqlQueryObject.addFromTable(Costanti.REPOSITORY);
  1209.         }

  1211.         // Condizione per legare le tabelle
  1212.         String legameTabelleSQLMsgId = GestoreMessaggi.MESSAGGI+".ID_MESSAGGIO="+GestoreMessaggi.DEFINIZIONE_MESSAGGI+".ID_MESSAGGIO";
  1213.         String legameTabelleSQLMsgTipo = GestoreMessaggi.MESSAGGI+".TIPO="+GestoreMessaggi.DEFINIZIONE_MESSAGGI+".TIPO";
  1214.         String legameTabelleSQLBustaId = GestoreMessaggi.MESSAGGI+".ID_MESSAGGIO="+Costanti.REPOSITORY+".ID_MESSAGGIO";
  1215.         String legameTabelleSQLBustaTipo = GestoreMessaggi.MESSAGGI+".TIPO="+Costanti.REPOSITORY+".TIPO";
  1216.         String legameTabelleSQLRiscontro = GestoreMessaggi.MESSAGGI+".ID_MESSAGGIO="+Costanti.RISCONTRI_DA_RICEVERE+".ID_MESSAGGIO";
  1217.         if( (search.getMessagePattern()!=null) && (!"".equals(search.getMessagePattern())) ){
  1218.             sqlQueryObject.addWhereCondition(true,legameTabelleSQLMsgId,legameTabelleSQLMsgTipo);
  1219.         }
  1220.         if(search.getBusta()!=null){
  1221.             sqlQueryObject.addWhereCondition(true,legameTabelleSQLBustaId,legameTabelleSQLBustaTipo);
  1222.         }else if(search.getSoggettoList()!=null && !search.getSoggettoList().isEmpty()){
  1223.             sqlQueryObject.addWhereCondition(true,legameTabelleSQLBustaId,legameTabelleSQLBustaTipo);
  1224.         }
  1225.         if(search.getBusta()!=null && search.getBusta().isAttesaRiscontro()){
  1226.             sqlQueryObject.addWhereCondition(legameTabelleSQLRiscontro);
  1227.         }



  1231.         if(statoRichieste){
  1232.             // SELECT PER STATO

  1234.             // Count
  1235.             sqlQueryObject.addSelectCountField(GestoreMessaggi.MESSAGGI+".ID_MESSAGGIO", "totMessaggi", true);

  1237.             // Tempo Medio
  1238.             sqlQueryObject.addSelectAvgTimestampField(GestoreMessaggi.MESSAGGI+".ora_registrazione", "ora_registrazione_media");

  1240.             // Tempo Massimo
  1241.             sqlQueryObject.addSelectMinTimestampField(GestoreMessaggi.MESSAGGI+".ora_registrazione", "ora_registrazione_old");

  1243.         }else {

  1245.             // SELECT FIELD PER LISTA

  1247.             // Tabella OpenSPCoop.sql.Messaggi
  1248.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"ID_MESSAGGIO");
  1249.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"TIPO");
  1250.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"PROPRIETARIO");
  1251.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"ORA_REGISTRAZIONE");
  1252.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"ERRORE_PROCESSAMENTO");     
  1253.             sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,"CORRELAZIONE_APPLICATIVA");
  1254.             if(this.properties!=null){
  1255.                 for (int i = 0; i < this.properties.size(); i++) {
  1256.                     String key = this.properties.get(i);
  1257.                     sqlQueryObject.addSelectField(GestoreMessaggi.MESSAGGI,key);
  1258.                 }
  1259.             }
  1260.             if( (search.getMessagePattern()!=null) && (!"".equals(search.getMessagePattern())) ){
  1261.                 // Tabella OpenSPCoop.sql.DefinizioneMessaggi
  1262. // Queste due colonne non servono: altrimenti si ottiene un errore column ambiguously defined.
  1263. // se in futuro serviranno, utilizzare degli alias
  1264.                 /**sqlQueryObject.addSelectField(GestoreMessaggi.DEFINIZIONE_MESSAGGI,"ID_MESSAGGIO");
  1265.                 sqlQueryObject.addSelectField(GestoreMessaggi.DEFINIZIONE_MESSAGGI,"TIPO");*/
  1266.                 sqlQueryObject.addSelectField(GestoreMessaggi.DEFINIZIONE_MESSAGGI,"MSG_BYTES");
  1267.             }   
  1268.             if(search.getBusta()!=null){
  1269.                 // Tabella Libreria.sql.Repository
  1270. // Queste due colonne non servono: altrimenti si ottiene un errore column ambiguously defined.
  1271. // se in futuro serviranno, utilizzare degli alias
  1272.                 /**sqlQueryObject.addSelectField(Costanti.REPOSITORY,"ID_MESSAGGIO");
  1273.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"TIPO");*/
  1274.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"TIPO_MITTENTE");
  1275.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"MITTENTE");
  1276.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"TIPO_DESTINATARIO");
  1277.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"DESTINATARIO");
  1278.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"TIPO_SERVIZIO");
  1279.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"SERVIZIO");
  1280.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"AZIONE");
  1281.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"PROFILO_DI_COLLABORAZIONE");
  1282.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"RIFERIMENTO_MESSAGGIO");
  1283.                 sqlQueryObject.addSelectField(Costanti.REPOSITORY,"COLLABORAZIONE");
  1284.             }   
  1285.             if(search.getBusta()!=null && search.getBusta().isAttesaRiscontro()){
  1286.                 // Tabella Libreria.sql.RiscontriDaRicevere
  1287. // Queste due colonne non servono: altrimenti si ottiene un errore column ambiguously defined.
  1288. // se in futuro serviranno, utilizzare degli alias
  1289.                 /**sqlQueryObject.addSelectField(Costanti.RISCONTRI_DA_RICEVERE,"ID_MESSAGGIO");*/
  1290.             }

  1292.         }

  1294.         // Where Logico Operator
  1295.         sqlQueryObject.setANDLogicOperator(true);

  1297.         // Order By OraRegistrazione
  1298.         if(!statoRichieste){
  1299.             sqlQueryObject.addOrderBy(GestoreMessaggi.MESSAGGI+".ORA_REGISTRAZIONE");
  1300.             sqlQueryObject.setSortType(false); // DESC
  1301.         }

  1303.         // Proprietario non deve essere GestoreMessaggi, a meno che il filtro non richieda proprio questo
  1304.         if( (search.getStato()==null) || ("".equals(search.getStato().getValue())) || (!StatoMessaggio.CANCELLATO.equals(search.getStato())) )
  1305.             sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+TimerGestoreMessaggi.ID_MODULO+"'");

  1307.         // Filtri:

  1309.         // a) StatoMessaggio
  1310.         if( (search.getStato()!=null) && (!"".equals(search.getStato().getValue())) ){
  1311.             if(StatoMessaggio.CONSEGNA.equals(search.getStato())){
  1312.                 sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".PROPRIETARIO='"+ConsegnaContenutiApplicativi.ID_MODULO+"'");
  1313.             }else if(StatoMessaggio.SPEDIZIONE.equals(search.getStato())){
  1314.                 sqlQueryObject.addWhereCondition(false,
  1315.                         GestoreMessaggi.MESSAGGI+".PROPRIETARIO='"+InoltroBuste.ID_MODULO+"'",
  1316.                         GestoreMessaggi.MESSAGGI+".PROPRIETARIO='"+InoltroRisposte.ID_MODULO+"'");
  1317.             }else if(StatoMessaggio.CANCELLATO.equals(search.getStato())){
  1318.                 sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".PROPRIETARIO='"+TimerGestoreMessaggi.ID_MODULO+"'");
  1319.             }else if(StatoMessaggio.PROCESSAMENTO.equals(search.getStato())){
  1320.                 sqlQueryObject.addWhereCondition(true, GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+InoltroBuste.ID_MODULO+"'",
  1321.                         GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+InoltroRisposte.ID_MODULO+"'",
  1322.                         GestoreMessaggi.MESSAGGI+".PROPRIETARIO<>'"+ConsegnaContenutiApplicativi.ID_MODULO+"'");
  1323.             }else{
  1324.                 throw new SQLQueryObjectException("Stato per filtro non conosciuto: "+search.getStato());
  1325.             }
  1326.         }

  1328.         // b) idMessaggio e propertiesRicerca
  1329.         if( (search.getIdMessaggio()!=null) && (!"".equals(search.getIdMessaggio())) ){
  1330.             sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".ID_MESSAGGIO='"+search.getIdMessaggio()+"'");
  1331.         }
  1332.         if( (search.getProprietaList()!=null) && (!search.getProprietaList().isEmpty()) ){
  1333.             List<Proprieta> proprietaList = search.getProprietaList();
  1334.             for (Proprieta proprieta : proprietaList) {
  1335.                 sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+"."+proprieta.getNome()+"='"+proprieta.getValore()+"'");  
  1336.             }
  1337.         }

  1339.         // c) MessagePattern e CorrelazioneApplicativa
  1340.         if( (search.getMessagePattern()!=null) && (!"".equals(search.getMessagePattern())) ){
  1341.             sqlQueryObject.addWhereLikeCondition(GestoreMessaggi.DEFINIZIONE_MESSAGGI+".MSG_BYTES",search.getMessagePattern(),true,true);
  1342.         }
  1343.         if( (search.getCorrelazioneApplicativa()!=null) && (!"".equals(search.getCorrelazioneApplicativa())) ){
  1344.             sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".CORRELAZIONE_APPLICATIVA='"+search.getCorrelazioneApplicativa()+"'");
  1345.         }

  1347.         // d) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia())
  1348.         if(search.getSoglia()!=-1){
  1349.             sqlQueryObject.addWhereCondition(GestoreMessaggi.MESSAGGI+".ora_registrazione<=?");
  1350.         }

  1352.         if(!statoRichieste){
  1353.             // e) limit
  1354.             if(search.getLimit()!=-1){
  1355.                 sqlQueryObject.setLimit((int)search.getLimit());
  1356.             }
  1357.             // f) offset
  1358.             if(search.getOffset()!=-1){
  1359.                 sqlQueryObject.setOffset((int)search.getOffset());
  1360.             }
  1361.         }

  1363.         if(search.getBusta()!=null){

  1365.             // Busta filter

  1367.             // mittente
  1368.             if(search.getBusta().getMittente()!=null){
  1369.                 if( (search.getBusta().getMittente().getTipo()!=null) && (!"".equals(search.getBusta().getMittente().getTipo())) ){
  1370.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_MITTENTE='"+search.getBusta().getMittente().getTipo()+"'");
  1371.                 }
  1372.                 if( (search.getBusta().getMittente().getNome()!=null) && (!"".equals(search.getBusta().getMittente().getNome())) ){
  1373.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".MITTENTE='"+search.getBusta().getMittente().getNome()+"'");
  1374.                 }
  1375.             }

  1377.             // destinatario
  1378.             if(search.getBusta().getDestinatario()!=null){
  1379.                 if( (search.getBusta().getDestinatario().getTipo()!=null) && (!"".equals(search.getBusta().getDestinatario().getTipo())) ){
  1380.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_DESTINATARIO='"+search.getBusta().getDestinatario().getTipo()+"'");
  1381.                 }
  1382.                 if( (search.getBusta().getDestinatario().getNome()!=null) && (!"".equals(search.getBusta().getDestinatario().getNome())) ){
  1383.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".DESTINATARIO='"+search.getBusta().getDestinatario().getNome()+"'");
  1384.                 }
  1385.             }

  1387.             // servizio
  1388.             if(search.getBusta().getServizio()!=null){
  1389.                 if( (search.getBusta().getServizio().getTipo()!=null) && (!"".equals(search.getBusta().getServizio().getTipo())) ){
  1390.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_SERVIZIO='"+search.getBusta().getServizio().getTipo()+"'");
  1391.                 }
  1392.                 if( (search.getBusta().getServizio().getNome()!=null) && (!"".equals(search.getBusta().getServizio().getNome())) ){
  1393.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".SERVIZIO='"+search.getBusta().getServizio().getNome()+"'");
  1394.                 }
  1395.                 if( (search.getBusta().getServizio().getVersione()!=null) && (search.getBusta().getServizio().getVersione().intValue()>0) ){
  1396.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".VERSIONE_SERVIZIO='"+search.getBusta().getServizio().getVersione().intValue()+"'");
  1397.                 }
  1398.             }

  1400.             // azione
  1401.             if( (search.getBusta().getAzione()!=null) && (!"".equals(search.getBusta().getAzione())) ){
  1402.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".AZIONE='"+search.getBusta().getAzione()+"'");
  1403.             }

  1405.             // profiloCollaborazione
  1406.             if( (search.getBusta().getProfiloCollaborazione()!=null) && (!"".equals(search.getBusta().getProfiloCollaborazione())) ){
  1407.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".PROFILO_DI_COLLABORAZIONE='"+search.getBusta().getProfiloCollaborazione()+"'");
  1408.             }

  1410.             // riferimentoMessaggio
  1411.             if( (search.getBusta().getRiferimentoMessaggio()!=null) && (!"".equals(search.getBusta().getRiferimentoMessaggio())) ){
  1412.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".RIFERIMENTO_MESSAGGIO='"+search.getBusta().getRiferimentoMessaggio()+"'");
  1413.             }

  1415.             // Collaborazione
  1416.             if( (search.getBusta().getCollaborazione()!=null) && (!"".equals(search.getBusta().getCollaborazione())) ){
  1417.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".COLLABORAZIONE='"+search.getBusta().getCollaborazione()+"'");
  1418.             }

  1420.         }

  1422.         if(search.getSoggettoList()!=null && !search.getSoggettoList().isEmpty()){

  1424.             List<BustaSoggetto> filtroSoggetti = search.getSoggettoList();
  1425.             StringBuilder query = new StringBuilder();
  1426.             for(int k=0; k<filtroSoggetti.size(); k++){
  1427.                 if(k>0)
  1428.                     query.append(" OR ");
  1429.                 query.append("( ");
  1430.                 query.append("("+Costanti.REPOSITORY+".TIPO_MITTENTE = ? AND "+Costanti.REPOSITORY+".MITTENTE = ?)");
  1431.                 query.append(" OR ");
  1432.                 query.append("("+Costanti.REPOSITORY+".TIPO_DESTINATARIO = ? AND "+Costanti.REPOSITORY+".DESTINATARIO = ?)");
  1433.                 query.append(" )");
  1434.             }
  1435.             sqlQueryObject.addWhereCondition(query.toString());
  1436.         }

  1438.         return sqlQueryObject;
  1439.     }










  1450.     private ISQLQueryObject newSQLQueryPacchettiDuplicati(FilterSearch search) throws SQLQueryObjectException{

  1452.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);

  1454.         // FROM TABLE
  1455.         sqlQueryObject.addFromTable(Costanti.REPOSITORY);

  1457.         // SELECT FIELD
  1458.         sqlQueryObject.addSelectField("sum(DUPLICATI) as numduplicati");

  1460.         // Where Logico Operator
  1461.         sqlQueryObject.setANDLogicOperator(true);


  1464.         // Filtri:

  1466.         // a) idMessaggio
  1467.         if( (search.getIdMessaggio()!=null) && (!"".equals(search.getIdMessaggio())) ){
  1468.             sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".ID_MESSAGGIO='"+search.getIdMessaggio()+"'");
  1469.         }

  1471.         // b) Soglia (ora_registrazione piu' vecchia di NOW-search.getSoglia())
  1472.         if(search.getSoglia()!=-1){
  1473.             sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".ora_registrazione<=?");
  1474.         }

  1476.         if(search.getBusta()!=null){

  1478.             // Busta filter

  1480.             // mittente
  1481.             if(search.getBusta().getMittente()!=null){
  1482.                 if( (search.getBusta().getMittente().getTipo()!=null) && (!"".equals(search.getBusta().getMittente().getTipo())) ){
  1483.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_MITTENTE='"+search.getBusta().getMittente().getTipo()+"'");
  1484.                 }
  1485.                 if( (search.getBusta().getMittente().getNome()!=null) && (!"".equals(search.getBusta().getMittente().getNome())) ){
  1486.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".MITTENTE='"+search.getBusta().getMittente().getNome()+"'");
  1487.                 }
  1488.             }

  1490.             // destinatario
  1491.             if(search.getBusta().getDestinatario()!=null){
  1492.                 if( (search.getBusta().getDestinatario().getTipo()!=null) && (!"".equals(search.getBusta().getDestinatario().getTipo())) ){
  1493.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_DESTINATARIO='"+search.getBusta().getDestinatario().getTipo()+"'");
  1494.                 }
  1495.                 if( (search.getBusta().getDestinatario().getNome()!=null) && (!"".equals(search.getBusta().getDestinatario().getNome())) ){
  1496.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".DESTINATARIO='"+search.getBusta().getDestinatario().getNome()+"'");
  1497.                 }
  1498.             }

  1500.             // servizio
  1501.             if(search.getBusta().getServizio()!=null){
  1502.                 if( (search.getBusta().getServizio().getTipo()!=null) && (!"".equals(search.getBusta().getServizio().getTipo())) ){
  1503.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".TIPO_SERVIZIO='"+search.getBusta().getServizio().getTipo()+"'");
  1504.                 }
  1505.                 if( (search.getBusta().getServizio().getNome()!=null) && (!"".equals(search.getBusta().getServizio().getNome())) ){
  1506.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".SERVIZIO='"+search.getBusta().getServizio().getNome()+"'");
  1507.                 }
  1508.                 if( (search.getBusta().getServizio().getVersione()!=null) && (search.getBusta().getServizio().getVersione().intValue()>0) ){
  1509.                     sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".VERSIONE_SERVIZIO='"+search.getBusta().getServizio().getVersione().intValue()+"'");
  1510.                 }
  1511.             }

  1513.             // azione
  1514.             if( (search.getBusta().getAzione()!=null) && (!"".equals(search.getBusta().getAzione())) ){
  1515.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".AZIONE='"+search.getBusta().getAzione()+"'");
  1516.             }

  1518.             // profiloCollaborazione
  1519.             if( (search.getBusta().getProfiloCollaborazione()!=null) && (!"".equals(search.getBusta().getProfiloCollaborazione())) ){
  1520.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".PROFILO_DI_COLLABORAZIONE='"+search.getBusta().getProfiloCollaborazione()+"'");
  1521.             }

  1523.             // riferimentoMessaggio
  1524.             if( (search.getBusta().getRiferimentoMessaggio()!=null) && (!"".equals(search.getBusta().getRiferimentoMessaggio())) ){
  1525.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".RIFERIMENTO_MESSAGGIO='"+search.getBusta().getRiferimentoMessaggio()+"'");
  1526.             }

  1528.             // Collaborazione
  1529.             if( (search.getBusta().getCollaborazione()!=null) && (!"".equals(search.getBusta().getCollaborazione())) ){
  1530.                 sqlQueryObject.addWhereCondition(Costanti.REPOSITORY+".COLLABORAZIONE='"+search.getBusta().getCollaborazione()+"'");
  1531.             }

  1533.         }

  1535.         return sqlQueryObject;
  1536.     }
  1537.     
  1538.     
  1539.     private String newSQLQueryStatoConsegneAsincrone(FiltroStatoConsegnaAsincrona filtro) throws SQLQueryObjectException{

  1541.         String aliasTableServiziApplicativi = "sa";
  1542.         String aliasTableMessaggi = "m";
  1543.         
  1544.         // ** InCoda **
  1545.         
  1546.         /*
  1547.          *  select 0 as inRiconsegna, count(*) as inCoda, 
  1548.          *  null::timestamp as vecchioInRiconsegna, null::timestamp as recenteInRiconsegna, 
  1549.          *  min(sa.ora_registrazione) as vecchioInCoda, max(sa.ora_registrazione) as recenteInCoda, 
  1550.          *  0 as inCaricoIM, null::timestamp as vecchioInCaricoIM, null::timestamp as recenteInCaricoIM, 
  1551.          *  sa.SERVIZIO_APPLICATIVO  
  1552.          *  from msg_servizi_applicativi sa,messaggi m 
  1553.          *  where 
  1554.          *  sa.attesa_esito=0 AND 
  1555.          *  (sa.errore_processamento_compact='TimerConsegnaContenutiApplicativi') AND 
  1556.          *  sa.tipo_consegna='Connettore' AND 
  1557.          *  m.id_messaggio=sa.id_messaggio AND 
  1558.          *  m.proprietario<>'GestoreMessaggi' 
  1559.          *  group by sa.servizio_applicativo
  1560.          **/
  1561.         
  1562.         ISQLQueryObject sqlQueryObjectCoda = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  1563.         
  1564.         sqlQueryObjectCoda.addFromTable(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI,aliasTableServiziApplicativi);
  1565.         sqlQueryObjectCoda.addFromTable(GestoreMessaggi.MESSAGGI,aliasTableMessaggi);
  1566.         
  1567.         sqlQueryObjectCoda.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA);
  1568.         sqlQueryObjectCoda.addSelectCountField(StatoConsegnaAsincrona.ALIAS_IN_CODA);
  1569.         sqlQueryObjectCoda.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO);
  1570.         sqlQueryObjectCoda.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE);
  1571.         sqlQueryObjectCoda.addSelectMinField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO);
  1572.         sqlQueryObjectCoda.addSelectMaxField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE);
  1573.         sqlQueryObjectCoda.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX);
  1574.         sqlQueryObjectCoda.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO);
  1575.         sqlQueryObjectCoda.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE);
  1576.         sqlQueryObjectCoda.addSelectAliasField(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_SERVIZIO_APPLICATIVO,StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1577.         
  1578.         sqlQueryObjectCoda.setANDLogicOperator(true);
  1579.         sqlQueryObjectCoda.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ATTESA_ESITO+"=0");
  1580.         sqlQueryObjectCoda.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ERRORE_PROCESSAMENTO_COMPACT+"='"+TimerConsegnaContenutiApplicativiThread.ID_MODULO+"'");
  1581.         sqlQueryObjectCoda.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_TIPO_CONSEGNA+"='"+GestoreMessaggi.CONSEGNA_TRAMITE_CONNETTORE+"'");
  1582.         sqlQueryObjectCoda.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_ID_MESSAGGIO+"="+aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ID_MESSAGGIO);
  1583.         sqlQueryObjectCoda.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_PROPRIETARIO+"<>'"+TimerGestoreMessaggi.ID_MODULO+"'");
  1584.         
  1585.         sqlQueryObjectCoda.addGroupBy(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1586.         
  1587.         
  1588.         // ** InRiconsegna **
  1589.         
  1590.         /*
  1591.          *  select count(*) as inRiconsegna, 0 as inCoda, 
  1592.          *  min(sa.ora_registrazione) as vecchioInRiconsegna, max(sa.ora_registrazione) as recenteInRiconsegna,  
  1593.          *  null::timestamp as vecchioInCoda, null::timestamp as recenteInCoda, 
  1594.          *  0 as inCaricoIM, null::timestamp as vecchioInCaricoIM, null::timestamp as recenteInCaricoIM, 
  1595.          *  sa.SERVIZIO_APPLICATIVO 
  1596.          *  from msg_servizi_applicativi sa,messaggi m 
  1597.          *  where 
  1598.          *  sa.attesa_esito=0 AND 
  1599.          *  (sa.errore_processamento_compact<>'TimerConsegnaContenutiApplicativi') AND 
  1600.          *  sa.tipo_consegna='Connettore' AND 
  1601.          *  m.id_messaggio=sa.id_messaggio AND 
  1602.          *  m.proprietario<>'GestoreMessaggi' 
  1603.          *  group by sa.servizio_applicativo
  1604.          **/
  1605.         
  1606.         ISQLQueryObject sqlQueryObjectRiconsegna = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  1607.         
  1608.         sqlQueryObjectRiconsegna.addFromTable(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI,aliasTableServiziApplicativi);
  1609.         sqlQueryObjectRiconsegna.addFromTable(GestoreMessaggi.MESSAGGI,aliasTableMessaggi);
  1610.         
  1611.         sqlQueryObjectRiconsegna.addSelectCountField(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA);
  1612.         sqlQueryObjectRiconsegna.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA);
  1613.         sqlQueryObjectRiconsegna.addSelectMinField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO);
  1614.         sqlQueryObjectRiconsegna.addSelectMaxField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE);
  1615.         sqlQueryObjectRiconsegna.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO);
  1616.         sqlQueryObjectRiconsegna.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE);
  1617.         sqlQueryObjectRiconsegna.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX);
  1618.         sqlQueryObjectRiconsegna.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO);
  1619.         sqlQueryObjectRiconsegna.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE);
  1620.         sqlQueryObjectRiconsegna.addSelectAliasField(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_SERVIZIO_APPLICATIVO,StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1621.         
  1622.         sqlQueryObjectRiconsegna.setANDLogicOperator(true);
  1623.         sqlQueryObjectRiconsegna.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ATTESA_ESITO+"=0");
  1624.         sqlQueryObjectRiconsegna.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ERRORE_PROCESSAMENTO_COMPACT+"<>'"+TimerConsegnaContenutiApplicativiThread.ID_MODULO+"'");
  1625.         sqlQueryObjectRiconsegna.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_TIPO_CONSEGNA+"='"+GestoreMessaggi.CONSEGNA_TRAMITE_CONNETTORE+"'");
  1626.         sqlQueryObjectRiconsegna.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_ID_MESSAGGIO+"="+aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ID_MESSAGGIO);
  1627.         sqlQueryObjectRiconsegna.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_PROPRIETARIO+"<>'"+TimerGestoreMessaggi.ID_MODULO+"'");
  1628.         
  1629.         sqlQueryObjectRiconsegna.addGroupBy(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1630.         
  1631.         
  1632.         // ** InMessageBox **
  1633.         
  1634.         /*
  1635.          *  select 0 as inRiconsegna, 0 as inCoda, 
  1636.          *  null::timestamp as vecchioInRiconsegna, null::timestamp as recenteInRiconsegna,  
  1637.          *  null::timestamp as vecchioInCoda, null::timestamp as recenteInCoda, 
  1638.          *  count(*) as inCaricoIM, min(sa.ora_registrazione) as vecchioInCaricoIM, max(sa.ora_registrazione) as recenteInCaricoIM, 
  1639.          *  sa.SERVIZIO_APPLICATIVO 
  1640.          *  from msg_servizi_applicativi sa,messaggi m 
  1641.          *  where 
  1642.          *  sa.tipo_consegna='IntegrationManager' AND 
  1643.          *  m.id_messaggio=sa.id_messaggio AND 
  1644.          *  m.proprietario<>'GestoreMessaggi' 
  1645.          *  group by sa.servizio_applicativo
  1646.          **/
  1647.         
  1648.         ISQLQueryObject sqlQueryObjectMessageBox = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  1649.         
  1650.         sqlQueryObjectMessageBox.addFromTable(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI,aliasTableServiziApplicativi);
  1651.         sqlQueryObjectMessageBox.addFromTable(GestoreMessaggi.MESSAGGI,aliasTableMessaggi);
  1652.         
  1653.         sqlQueryObjectMessageBox.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA);
  1654.         sqlQueryObjectMessageBox.addSelectAliasField(getIntZeroValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA);
  1655.         sqlQueryObjectMessageBox.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO);
  1656.         sqlQueryObjectMessageBox.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE);
  1657.         sqlQueryObjectMessageBox.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO);
  1658.         sqlQueryObjectMessageBox.addSelectAliasField(getNullTimestampValue(),StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE);
  1659.         sqlQueryObjectMessageBox.addSelectCountField(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX);
  1660.         sqlQueryObjectMessageBox.addSelectMinField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO);
  1661.         sqlQueryObjectMessageBox.addSelectMaxField(aliasTableServiziApplicativi, GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ORA_REGISTRAZIONE, StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE);
  1662.         sqlQueryObjectMessageBox.addSelectAliasField(GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_SERVIZIO_APPLICATIVO,StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1663.         
  1664.         sqlQueryObjectMessageBox.setANDLogicOperator(true);
  1665.         sqlQueryObjectMessageBox.addWhereCondition(aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_TIPO_CONSEGNA+"='"+GestoreMessaggi.CONSEGNA_TRAMITE_INTEGRATION_MANAGER+"'");
  1666.         sqlQueryObjectMessageBox.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_ID_MESSAGGIO+"="+aliasTableServiziApplicativi+"."+GestoreMessaggi.MSG_SERVIZI_APPLICATIVI_COLUMN_ID_MESSAGGIO);
  1667.         sqlQueryObjectMessageBox.addWhereCondition(aliasTableMessaggi+"."+GestoreMessaggi.MESSAGGI_COLUMN_PROPRIETARIO+"<>'"+TimerGestoreMessaggi.ID_MODULO+"'");
  1668.         
  1669.         sqlQueryObjectMessageBox.addGroupBy(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);

  1671.         
  1672.         // ** UNION **
  1673.         
  1674.         /**
  1675.          * select CURRENT_TIMESTAMP as now, 
  1676.          * max(inRiconsegna) as inRiconsegna, max(inCoda) as inCoda, 
  1677.          * min(vecchioInRiconsegna) as vecchioInRiconsegna, max(recenteInRiconsegna) as recenteInRiconsegna, 
  1678.          * min(vecchioInCoda) as vecchioInCoda, max(recenteInCoda) as recenteInCoda, 
  1679.          * max(inCaricoIM) as inCaricoIM, min(vecchioInCaricoIM) as vecchioInCaricoIM, max(recenteInCaricoIM) as recenteInCaricoIM,  
  1680.          * servizio_applicativo from (
  1681.                 QUERY_IN_CODA
  1682.             UNION ALL
  1683.                 QUERY_IN_RICONSEGNA
  1684.             UNION ALL
  1685.                 QUERY_MESSAGE_BOX
  1686.            ) as query group by servizio_applicativo;
  1687.          */
  1688.         
  1689.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  1690.         
  1691.         sqlQueryObject.addSelectAliasField("CURRENT_TIMESTAMP", StatoConsegnaAsincrona.ALIAS_NOW);
  1692.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA, StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA);
  1693.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_CODA, StatoConsegnaAsincrona.ALIAS_IN_CODA);
  1694.         sqlQueryObject.addSelectMinField(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO, StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_VECCHIO);
  1695.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE, StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA_RECENTE);
  1696.         sqlQueryObject.addSelectMinField(StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO, StatoConsegnaAsincrona.ALIAS_IN_CODA_VECCHIO);
  1697.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE, StatoConsegnaAsincrona.ALIAS_IN_CODA_RECENTE);
  1698.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX, StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX);
  1699.         sqlQueryObject.addSelectMinField(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO, StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_VECCHIO);
  1700.         sqlQueryObject.addSelectMaxField(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE, StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX_RECENTE);     
  1701.         sqlQueryObject.addSelectAliasField(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO, StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1702.         
  1703.         sqlQueryObject.addGroupBy(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO);
  1704.         
  1705.         if(filtro!=null) {
  1706.             if(filtro.isOrderByInCoda()) {
  1707.                 sqlQueryObject.addOrderBy(StatoConsegnaAsincrona.ALIAS_IN_CODA, false);
  1708.             }
  1709.             if(filtro.isOrderByInRiconsegna()) {
  1710.                 sqlQueryObject.addOrderBy(StatoConsegnaAsincrona.ALIAS_IN_RICONSEGNA, false);
  1711.             }
  1712.             if(filtro.isOrderByInMessageBox()) {
  1713.                 sqlQueryObject.addOrderBy(StatoConsegnaAsincrona.ALIAS_IN_MESSAGE_BOX, false);
  1714.             }
  1715.         }
  1716.         sqlQueryObject.addOrderBy(StatoConsegnaAsincrona.ALIAS_SERVIZIO_APPLICATIVO, true);
  1717.             
  1718.         return sqlQueryObject.createSQLUnion(true, sqlQueryObjectRiconsegna, sqlQueryObjectCoda, sqlQueryObjectMessageBox);
  1719.     }
  1720.     
  1721.     private String getNullTimestampValue() {
  1722.         if(TipiDatabase.POSTGRESQL.equals(this.tipoDatabase)) {
  1723.             return "null::timestamp";
  1724.         }
  1725.         else {
  1726.             return "null";
  1727.         }
  1728.     }
  1729.     private String getIntZeroValue() {
  1730.         return "0";
  1731.     }
  1732. }
Created with JaCoCo 0.8.8.202204050719