DatiStatisticiDAOManager.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.  */
  20. package org.openspcoop2.pdd.core.controllo_traffico.policy;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.Calendar;
  25. import java.util.Date;
  26. import java.util.List;
  27. import java.util.Map;

  29. import org.openspcoop2.core.commons.CoreException;
  30. import org.openspcoop2.core.commons.dao.DAOFactory;
  31. import org.openspcoop2.core.commons.dao.DAOFactoryProperties;
  32. import org.openspcoop2.core.config.PortaApplicativa;
  33. import org.openspcoop2.core.config.PortaDelegata;
  34. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  35. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  36. import org.openspcoop2.core.config.driver.FiltroRicercaServiziApplicativi;
  37. import org.openspcoop2.core.constants.TipoPdD;
  38. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyFiltro;
  39. import org.openspcoop2.core.controllo_traffico.beans.DatiTransazione;
  40. import org.openspcoop2.core.controllo_traffico.beans.IDUnivocoGroupByPolicy;
  41. import org.openspcoop2.core.controllo_traffico.beans.RisultatoStatistico;
  42. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  43. import org.openspcoop2.core.controllo_traffico.constants.TipoBanda;
  44. import org.openspcoop2.core.controllo_traffico.constants.TipoFinestra;
  45. import org.openspcoop2.core.controllo_traffico.constants.TipoLatenza;
  46. import org.openspcoop2.core.controllo_traffico.constants.TipoPeriodoStatistico;
  47. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsa;
  48. import org.openspcoop2.core.id.IDAccordo;
  49. import org.openspcoop2.core.id.IDGruppo;
  50. import org.openspcoop2.core.id.IDPortaApplicativa;
  51. import org.openspcoop2.core.id.IDPortaDelegata;
  52. import org.openspcoop2.core.id.IDRuolo;
  53. import org.openspcoop2.core.id.IDServizio;
  54. import org.openspcoop2.core.id.IDServizioApplicativo;
  55. import org.openspcoop2.core.id.IDSoggetto;
  56. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  57. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  58. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  59. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  60. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  61. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  62. import org.openspcoop2.core.statistiche.StatisticaGiornaliera;
  63. import org.openspcoop2.core.statistiche.StatisticaMensile;
  64. import org.openspcoop2.core.statistiche.StatisticaOraria;
  65. import org.openspcoop2.core.statistiche.StatisticaSettimanale;
  66. import org.openspcoop2.core.statistiche.constants.TipoPorta;
  67. import org.openspcoop2.core.statistiche.model.StatisticaModel;
  68. import org.openspcoop2.core.statistiche.utils.StatisticheUtils;
  69. import org.openspcoop2.generic_project.beans.Function;
  70. import org.openspcoop2.generic_project.beans.FunctionField;
  71. import org.openspcoop2.generic_project.dao.IDBServiceUtilities;
  72. import org.openspcoop2.generic_project.dao.IServiceSearchWithoutId;
  73. import org.openspcoop2.generic_project.exception.ExpressionException;
  74. import org.openspcoop2.generic_project.exception.ExpressionNotImplementedException;
  75. import org.openspcoop2.generic_project.exception.NotFoundException;
  76. import org.openspcoop2.generic_project.exception.NotImplementedException;
  77. import org.openspcoop2.generic_project.exception.ServiceException;
  78. import org.openspcoop2.generic_project.expression.IExpression;
  79. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  80. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  81. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  82. import org.openspcoop2.pdd.config.DBStatisticheManager;
  83. import org.openspcoop2.pdd.config.DBTransazioniManager;
  84. import org.openspcoop2.pdd.config.Resource;
  85. import org.openspcoop2.pdd.core.controllo_traffico.ConfigurazioneGatewayControlloTraffico;
  86. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  87. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  88. import org.openspcoop2.protocol.registry.RegistroServiziManager;
  89. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  90. import org.openspcoop2.protocol.sdk.ProtocolException;
  91. import org.openspcoop2.protocol.sdk.state.IState;
  92. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  93. import org.openspcoop2.protocol.sdk.state.StateMessage;
  94. import org.openspcoop2.protocol.utils.EsitiProperties;
  95. import org.openspcoop2.utils.date.DateManager;
  96. import org.slf4j.Logger;

  98. /**     
  99.  * DatiStatisticiDAOManager
  100.  *
  101.  * @author Poli Andrea (poli@link.it)
  102.  * @author $Author$
  103.  * @version $Rev$, $Date$
  104.  */
  105. public class DatiStatisticiDAOManager  {

  107.     private static DatiStatisticiDAOManager staticInstance = null;
  108.     public static synchronized void initialize(ConfigurazioneGatewayControlloTraffico configurazioneControlloTraffico) throws CoreException{
  109.         if(staticInstance==null){
  110.             staticInstance = new DatiStatisticiDAOManager(configurazioneControlloTraffico);
  111.         }
  112.     }
  113.     public static DatiStatisticiDAOManager getInstance() throws CoreException{
  114.         if(staticInstance==null){
  115.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  116.             synchronized (DatiStatisticiDAOManager.class) {
  117.                 throw new CoreException("DatiStatisticiDAOManager non inizializzato");
  118.             }
  119.         }
  120.         return staticInstance;
  121.     }
  122.     
  123.     private ConfigurazioneGatewayControlloTraffico configurazioneControlloTraffico;
  124.     
  125.     /** Indicazione se deve essere effettuato il log delle query */
  126.     private boolean debug = false;  
  127.         
  128.     /** Database */
  129.     /**private DataSource ds = null;
  130.     private String datasource = null;*/
  131.     private String tipoDatabase = null; //tipoDatabase
  132.     private DAOFactory daoFactory = null;
  133.     private Logger daoFactoryLogger = null;
  134.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesStatistiche = null;
  135.     
  136.     private DBStatisticheManager dbStatisticheManager = null;
  137.     private boolean checkState = false;
  138.     
  139.     private Logger log;
  140.     private void logDebug(String msg) {
  141.         if(this.log!=null) {
  142.             this.log.debug(msg);
  143.         }
  144.     }
  145.     private void logDebug(String msg, Exception e) {
  146.         if(this.log!=null) {
  147.             this.log.debug(msg,e);
  148.         }
  149.     }
  150.     private void logError(String msg, Exception e) {
  151.         if(this.log!=null) {
  152.             this.log.error(msg,e);
  153.         }
  154.     }
  155.     
  156.     private DatiStatisticiDAOManager(ConfigurazioneGatewayControlloTraffico configurazioneControlloTraffico) throws CoreException{
  157.         try{
  158.             
  159.             this.configurazioneControlloTraffico = configurazioneControlloTraffico;
  160.             
  161.             this.debug = this.configurazioneControlloTraffico.isDebug();
  162.             
  163.             this.tipoDatabase = this.configurazioneControlloTraffico.getTipoDatabaseConfig();
  164.             
  165.             if(this.tipoDatabase==null){
  166.                 throw new CoreException("Tipo Database non definito");
  167.             }

  169.             // DAOFactory
  170.             DAOFactoryProperties daoFactoryProperties = null;
  171.             this.daoFactoryLogger = OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTrafficoSql(this.debug);
  172.             this.daoFactory = DAOFactory.getInstance(this.daoFactoryLogger);
  173.             daoFactoryProperties = DAOFactoryProperties.getInstance(this.daoFactoryLogger);
  174.                         
  175.             this.daoFactoryServiceManagerPropertiesStatistiche = daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance());
  176.             this.daoFactoryServiceManagerPropertiesStatistiche.setShowSql(this.debug);  
  177.             this.daoFactoryServiceManagerPropertiesStatistiche.setDatabaseType(this.tipoDatabase);
  178.             
  179.             this.dbStatisticheManager = DBStatisticheManager.getInstance();
  180.             if(this.dbStatisticheManager.useRuntimePdD() 
  181.                     ||
  182.                 (   
  183.                         this.dbStatisticheManager.useTransazioni() &&
  184.                         DBTransazioniManager.getInstance().useRuntimePdD()
  185.                 )
  186.                     ){
  187.                 this.checkState = true;
  188.             }
  189.             
  190.             this.log = OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTraffico(this.debug);
  191.             
  192.         }catch(Exception e){
  193.             throw new CoreException("Errore durante l'inizializzazione del datasource: "+e.getMessage(),e);
  194.         }
  195.         
  196.     }
  197.     
  198.     private static final String RISORSA_DB_NON_DISPONIBILE = "Risorsa al database non disponibile";
  199.     private static final String CONNESSIONE_DB_NON_DISPONIBILE = "Connessione non disponibile";
  200.     private static final String MODEL_UNKNOWN = "Model unknown";
  201.     private static final String DAO_UNKNOWN = "DAO unknown";
  202.     
  203.     
  204.     /* ********************** NUMERO ESISTI *************************** */
  205.     public RisultatoStatistico readNumeroEsiti(String key, TipoPeriodoStatistico tipoPeriodo, Integer periodLength, 
  206.             Date endDate,  List<Integer> esiti, IDServizio servizio, IDSoggetto mittente, List<String> ignoreOperations, DatiTransazione datiTransazione, IState state) throws CoreException {
  207.         Resource r = null;
  208.         boolean useConnectionRuntime = false;
  209.         IDSoggetto dominio = datiTransazione.getDominio();
  210.         String idModulo = datiTransazione.getModulo()+".statistiche.readExpression";
  211.         String idTransazione = datiTransazione.getIdTransazione();
  212.         try{
  213.             
  214.             Connection con = null;
  215.             if(this.checkState &&
  216.                 state!=null &&
  217.                 state instanceof StateMessage) {
  218.                 StateMessage s = (StateMessage) state;
  219.                 if(s.getConnectionDB()!=null && !s.getConnectionDB().isClosed()) {
  220.                     con = s.getConnectionDB();
  221.                     useConnectionRuntime = true;
  222.                 }
  223.             }
  224.             if(!useConnectionRuntime){
  225.                 r = this.dbStatisticheManager.getResource(dominio, idModulo, idTransazione);
  226.                 if(r==null){
  227.                     throw new CoreException(RISORSA_DB_NON_DISPONIBILE);
  228.                 }
  229.                 con = (Connection) r.getResource();
  230.             }
  231.             if(con == null)
  232.                 throw new CoreException(CONNESSIONE_DB_NON_DISPONIBILE);    
  233.             
  234.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  235.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(),
  236.                             con, this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  237.             boolean useGiornaliero = this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanale_usaStatisticheGiornaliere();
  238.             
  239.             StatisticaModel model = null;
  240.             IServiceSearchWithoutId<?> dao = null;
  241.             Calendar c = Calendar.getInstance();
  242.             c.setTime(endDate);
  243.             
  244.             switch (tipoPeriodo) {
  245.             case ORARIO:
  246.                 model = StatisticaOraria.model().STATISTICA_BASE;
  247.                 dao = statisticheSM.getStatisticaOrariaServiceSearch();
  248.                 c.add(Calendar.HOUR, -periodLength);
  249.                 break;
  250.             case GIORNALIERO:
  251.                 model = StatisticaGiornaliera.model().STATISTICA_BASE;
  252.                 dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  253.                 c.add(Calendar.DATE, -periodLength);
  254.                 break;
  255.             case SETTIMANALE:
  256.                 model = useGiornaliero ? StatisticaGiornaliera.model().STATISTICA_BASE : StatisticaSettimanale.model().STATISTICA_BASE;
  257.                 dao = useGiornaliero ? statisticheSM.getStatisticaGiornalieraServiceSearch() : statisticheSM.getStatisticaSettimanaleServiceSearch();
  258.                 c.add(Calendar.DATE, -7 * periodLength);
  259.                 break;
  260.             case MENSILE:
  261.                 model = useGiornaliero ? StatisticaGiornaliera.model().STATISTICA_BASE : StatisticaMensile.model().STATISTICA_BASE;
  262.                 dao = useGiornaliero ? statisticheSM.getStatisticaGiornalieraServiceSearch() : statisticheSM.getStatisticaMensileServiceSearch();
  263.                 c.add(Calendar.MONTH, -periodLength);
  264.                 break;
  265.             }
  266.             Date startDate = c.getTime();
  267.             
  268.             if(model==null) {
  269.                 throw new CoreException(MODEL_UNKNOWN);
  270.             }
  271.             if(dao==null) {
  272.                 throw new CoreException(DAO_UNKNOWN);
  273.             }
  274.             
  275.             IExpression expression = dao.newExpression();
  276.             expression.between(model.DATA, startDate, endDate);
  277.             if (esiti != null)
  278.                 expression.in(model.ESITO, esiti);
  279.             expression.equals(model.SERVIZIO, servizio.getNome());
  280.             expression.equals(model.TIPO_SERVIZIO, servizio.getTipo());
  281.             expression.equals(model.VERSIONE_SERVIZIO, servizio.getVersione());
  282.             expression.equals(model.DESTINATARIO, servizio.getSoggettoErogatore().getNome());
  283.             expression.equals(model.TIPO_DESTINATARIO, servizio.getSoggettoErogatore().getTipo());
  284.             expression.isNotNull(model.NUMERO_TRANSAZIONI);
  285.             if (mittente != null) {
  286.                 expression.equals(model.MITTENTE, mittente.getNome());
  287.                 expression.equals(model.TIPO_MITTENTE, mittente.getTipo());
  288.             }
  289.             
  290.             if (ignoreOperations != null) {
  291.                 for (String ignoreOperation : ignoreOperations)
  292.                     expression.notEquals(model.AZIONE, ignoreOperation);
  293.             }
  294.             
  295.             
  296.             RisultatoStatistico risultato = new RisultatoStatistico();
  297.             risultato.setDateCheck(DateManager.getDate());
  298.             risultato.setDataInizio(startDate);
  299.             risultato.setDataFine(endDate);
  300.             FunctionField ff = new  FunctionField(model.NUMERO_TRANSAZIONI, Function.SUM, "somma");
  301.             
  302.             try{
  303.                 Object result = dao.aggregate(expression, ff);
  304.                 if(result!=null && this.isKnownType(result) ){
  305.                     this.logDebug("NumeroRichiesteFound ["+result.getClass().getName()+"]: "+result);
  306.                     Long l = this.translateType(result);
  307.                     if(l!=null) {
  308.                         risultato.setRisultato(l.longValue());
  309.                     }
  310.                     else {
  311.                         throw new CoreException("Translate type (result) '"+result+"' non riuscito");
  312.                     }
  313.                 }
  314.                 else{
  315.                     if(result!=null){
  316.                         this.logDebug("NumeroRichiesteNotFound ["+result.getClass().getName()+"]: "+result);
  317.                     }else{
  318.                         this.logDebug("NumeroRichiesteNotFound, result is null");
  319.                     }
  320.                     risultato.setRisultato(0);
  321.                 }
  322.             }catch(NotFoundException notFound){
  323.                 this.logDebug("NumeroRichiesteNotFound:"+notFound.getMessage(),notFound);
  324.                 risultato.setRisultato(0);
  325.             }
  326.             
  327.             return risultato;
  328.             
  329.         }catch(Exception e){
  330.             this.logError("Errore durante la raccolta dei dati statisti (" + key + "): "+e.getMessage(),e);
  331.             throw new CoreException(e.getMessage(),e);
  332.         }finally {
  333.             try{
  334.                 if(!useConnectionRuntime && r != null) {
  335.                     this.dbStatisticheManager.releaseResource(dominio, idModulo, r);
  336.                 }
  337.             }catch(Exception eClose){}
  338.         }
  339.     }
  340.     
  341.     /* ********************** NUMERO RICHIESTE ************************** */
  342.     
  343.     public RisultatoStatistico readNumeroRichieste(String key,TipoRisorsa tipoRisorsa,
  344.             TipoFinestra tipoFinestra,TipoPeriodoStatistico tipoPeriodo, Date leftInterval, Date rightInterval,
  345.             DatiTransazione datiTransazione,IDUnivocoGroupByPolicy groupByPolicy, AttivazionePolicyFiltro filtro,
  346.             IState state,
  347.             RequestInfo requestInfo,
  348.             IProtocolFactory<?> protocolFactory) throws CoreException {
  349.     
  350.         Resource r = null;
  351.         boolean useConnectionRuntime = false;
  352.         IDSoggetto dominio = datiTransazione.getDominio();
  353.         String idModulo = datiTransazione.getModulo()+".statistiche.readNumeroRichieste";
  354.         String idTransazione = datiTransazione.getIdTransazione();
  355.         try{
  356.             
  357.             Connection con = null;
  358.             if(this.checkState &&
  359.                 state!=null &&
  360.                 state instanceof StateMessage) {
  361.                 StateMessage s = (StateMessage) state;
  362.                 if(s.getConnectionDB()!=null && !s.getConnectionDB().isClosed()) {
  363.                     con = s.getConnectionDB();
  364.                     useConnectionRuntime = true;
  365.                 }
  366.             }
  367.             if(!useConnectionRuntime){
  368.                 r = this.dbStatisticheManager.getResource(dominio, idModulo, idTransazione);
  369.                 if(r==null){
  370.                     throw new CoreException(RISORSA_DB_NON_DISPONIBILE);
  371.                 }
  372.                 con = (Connection) r.getResource();
  373.             }
  374.             if(con == null)
  375.                 throw new CoreException(CONNESSIONE_DB_NON_DISPONIBILE);    
  376.             
  377.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  378.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(),
  379.                             con, this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  380.                 
  381.             StatisticaModel model = null;
  382.             IServiceSearchWithoutId<?> dao = null;
  383.         
  384.             if(tipoFinestra!=null && TipoFinestra.SCORREVOLE.equals(tipoFinestra)){
  385.                 model = StatisticaOraria.model().STATISTICA_BASE;
  386.                 dao = statisticheSM.getStatisticaOrariaServiceSearch();
  387.             }
  388.             else{
  389.                 switch (tipoPeriodo) {
  390.                 case ORARIO:
  391.                     model = StatisticaOraria.model().STATISTICA_BASE;
  392.                     dao = statisticheSM.getStatisticaOrariaServiceSearch();
  393.                     break;
  394.                 case GIORNALIERO:
  395.                     model = StatisticaGiornaliera.model().STATISTICA_BASE;
  396.                     dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  397.                     break;
  398.                 case SETTIMANALE:
  399.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanale_usaStatisticheGiornaliere()) {
  400.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  401.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  402.                     }
  403.                     else {
  404.                         model = StatisticaSettimanale.model().STATISTICA_BASE;
  405.                         dao = statisticheSM.getStatisticaSettimanaleServiceSearch();
  406.                     }
  407.                     break;
  408.                 case MENSILE:
  409.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneMensile_usaStatisticheGiornaliere()) {
  410.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  411.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  412.                     }
  413.                     else {
  414.                         model = StatisticaMensile.model().STATISTICA_BASE;
  415.                         dao = statisticheSM.getStatisticaMensileServiceSearch();
  416.                     }
  417.                     break;
  418.                 }
  419.             }
  420.             if(model==null) {
  421.                 throw new CoreException(MODEL_UNKNOWN);
  422.             }
  423.             if(dao==null) {
  424.                 throw new CoreException(DAO_UNKNOWN);
  425.             }
  426.             
  427.             IExpression expression = this.createWhereExpressionNumeroRichieste(dao, model, tipoRisorsa, leftInterval, rightInterval, 
  428.                     datiTransazione.getTipoPdD(), protocolFactory, datiTransazione.getProtocollo(), groupByPolicy, filtro, state, requestInfo);
  429.                         
  430.             FunctionField ff = new  FunctionField(model.NUMERO_TRANSAZIONI, Function.SUM, "somma");
  431.             
  432.             RisultatoStatistico risultato = new RisultatoStatistico();
  433.             risultato.setDataInizio(leftInterval);
  434.             risultato.setDataFine(rightInterval);
  435.             risultato.setDateCheck(DateManager.getDate());
  436.             
  437.             try{
  438.                 Object result = dao.aggregate(expression, ff);
  439.                 if(result!=null && this.isKnownType(result) ){
  440.                     /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  441.                     this.logDebug("NumeroRichiesteFound ["+result.getClass().getName()+"]: "+result);
  442.                     Long l = this.translateType(result);
  443.                     if(l!=null) {
  444.                         risultato.setRisultato(l.longValue());
  445.                     }
  446.                     else {
  447.                         throw new CoreException("Translate type (result) '"+result+"' non riuscito");
  448.                     }
  449.                 }
  450.                 else{
  451.                     if(result!=null){
  452.                         /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  453.                         this.logDebug("NumeroRichiesteNotFound ["+result.getClass().getName()+"]: "+result);
  454.                     }else{
  455.                         this.logDebug("NumeroRichiesteNotFound, result is null");
  456.                     }
  457.                     risultato.setRisultato(0);
  458.                 }
  459.             }catch(NotFoundException notFound){
  460.                 this.logDebug("NumeroRichiesteNotFound:"+notFound.getMessage(),notFound);
  461.                 risultato.setRisultato(0);
  462.             }
  463.             
  464.             return risultato;
  465.             
  466.         }catch(Exception e){
  467.             this.logError("Errore durante la raccolta dei dati statisti (key:"+key+"): "+e.getMessage(),e);
  468.             throw new CoreException(e.getMessage(),e);
  469.         }finally {
  470.             try{
  471.                 if(!useConnectionRuntime &&
  472.                     r!=null) {
  473.                     this.dbStatisticheManager.releaseResource(dominio, idModulo, r);
  474.                 }
  475.             }catch(Exception eClose){
  476.                 // ignore
  477.             }
  478.         }
  479.         
  480.     }
  481.     
  482.     private IExpression createWhereExpressionNumeroRichieste(
  483.             IServiceSearchWithoutId<?> dao, StatisticaModel model, 
  484.             TipoRisorsa tipoRisorsa,
  485.             Date dataInizio, Date dataFine,
  486.             TipoPdD tipoPdDTransazioneInCorso,
  487.             IProtocolFactory<?> protocolFactory, String protocollo,
  488.             IDUnivocoGroupByPolicy groupByPolicy,
  489.             AttivazionePolicyFiltro filtro,
  490.             IState state,
  491.             RequestInfo requestInfo) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException, DriverRegistroServiziException, DriverConfigurazioneException {
  492.         
  493.         IExpression expr = this.createWhereExpression(dao, model, tipoRisorsa, dataInizio, dataFine, tipoPdDTransazioneInCorso, protocolFactory, protocollo, groupByPolicy, filtro, state, requestInfo);

  495.         expr.isNotNull(model.NUMERO_TRANSAZIONI);
  496.         
  497.         return expr;
  498.         
  499.     }
  500.     
  501.     
  502.     
  503.     
  504.     
  505.     
  506.     
  507.     
  508.     
  509.     /* ********************** OCCUPAZIONE BANDA ************************** */
  510.     
  511.     public RisultatoStatistico readOccupazioneBanda(String key,TipoRisorsa tipoRisorsa,
  512.             TipoFinestra tipoFinestra,TipoPeriodoStatistico tipoPeriodo, Date leftInterval, Date rightInterval,
  513.             TipoBanda tipoBanda,
  514.             DatiTransazione datiTransazione,IDUnivocoGroupByPolicy groupByPolicy, AttivazionePolicyFiltro filtro,
  515.             IState state,
  516.             RequestInfo requestInfo,
  517.             IProtocolFactory<?> protocolFactory) throws CoreException {
  518.     
  519.         Resource r = null;
  520.         boolean useConnectionRuntime = false;
  521.         IDSoggetto dominio = datiTransazione.getDominio();
  522.         String idModulo = datiTransazione.getModulo()+".statistiche.readOccupazioneBanda";
  523.         String idTransazione = datiTransazione.getIdTransazione();
  524.         try{
  525.             Connection con = null;
  526.             if(this.checkState &&
  527.                 state!=null &&
  528.                 state instanceof StateMessage) {
  529.                 StateMessage s = (StateMessage) state;
  530.                 if(s.getConnectionDB()!=null && !s.getConnectionDB().isClosed()) {
  531.                     con = s.getConnectionDB();
  532.                     useConnectionRuntime = true;
  533.                 }
  534.             }
  535.             if(!useConnectionRuntime){
  536.                 r = this.dbStatisticheManager.getResource(dominio, idModulo, idTransazione);
  537.                 if(r==null){
  538.                     throw new CoreException(RISORSA_DB_NON_DISPONIBILE);
  539.                 }
  540.                 con = (Connection) r.getResource();
  541.             }
  542.             if(con == null)
  543.                 throw new CoreException(CONNESSIONE_DB_NON_DISPONIBILE);    

  545.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  546.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(),
  547.                             con, this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  548.                 
  549.             StatisticaModel model = null;
  550.             IServiceSearchWithoutId<?> dao = null;

  552.             if(tipoFinestra!=null && TipoFinestra.SCORREVOLE.equals(tipoFinestra)){
  553.                 model = StatisticaOraria.model().STATISTICA_BASE;
  554.                 dao = statisticheSM.getStatisticaOrariaServiceSearch();
  555.             }
  556.             else{
  557.                 switch (tipoPeriodo) {
  558.                 case ORARIO:
  559.                     model = StatisticaOraria.model().STATISTICA_BASE;
  560.                     dao = statisticheSM.getStatisticaOrariaServiceSearch();
  561.                     break;
  562.                 case GIORNALIERO:
  563.                     model = StatisticaGiornaliera.model().STATISTICA_BASE;
  564.                     dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  565.                     break;
  566.                 case SETTIMANALE:
  567.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanale_usaStatisticheGiornaliere()) {
  568.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  569.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  570.                     }
  571.                     else {
  572.                         model = StatisticaSettimanale.model().STATISTICA_BASE;
  573.                         dao = statisticheSM.getStatisticaSettimanaleServiceSearch();
  574.                     }
  575.                     break;
  576.                 case MENSILE:
  577.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneMensile_usaStatisticheGiornaliere()) {
  578.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  579.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  580.                     }
  581.                     else {
  582.                         model = StatisticaMensile.model().STATISTICA_BASE;
  583.                         dao = statisticheSM.getStatisticaMensileServiceSearch();
  584.                     }
  585.                     break;
  586.                 }
  587.             }
  588.             
  589.             if(model==null) {
  590.                 throw new CoreException(MODEL_UNKNOWN);
  591.             }
  592.             if(dao==null) {
  593.                 throw new CoreException(DAO_UNKNOWN);
  594.             }
  595.             
  596.             IExpression expression = this.createWhereExpressionBanda(dao, model, tipoRisorsa, leftInterval, rightInterval, 
  597.                     datiTransazione.getTipoPdD(), protocolFactory, datiTransazione.getProtocollo(), groupByPolicy, filtro, tipoBanda, state, requestInfo);
  598.                         
  599.             FunctionField ff = null;
  600.             switch (tipoBanda) {
  601.             case COMPLESSIVA:
  602.                 ff = new  FunctionField(model.DIMENSIONI_BYTES_BANDA_COMPLESSIVA, Function.SUM, "somma");
  603.                 break;
  604.             case INTERNA:
  605.                 ff = new  FunctionField(model.DIMENSIONI_BYTES_BANDA_INTERNA, Function.SUM, "somma");
  606.                 break;
  607.             case ESTERNA:
  608.                 ff = new  FunctionField(model.DIMENSIONI_BYTES_BANDA_ESTERNA, Function.SUM, "somma");
  609.                 break;
  610.             }
  611.             
  612.             
  613.             RisultatoStatistico risultato = new RisultatoStatistico();
  614.             risultato.setDataInizio(leftInterval);
  615.             risultato.setDataFine(rightInterval);
  616.             risultato.setDateCheck(DateManager.getDate());
  617.             
  618.             try{
  619.                 Object result = dao.aggregate(expression, ff);
  620.                 if(result!=null && this.isKnownType(result) ){
  621.                     /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  622.                     this.logDebug("BandaFound ["+result.getClass().getName()+"]: "+result);
  623.                     Long l = this.translateType(result);
  624.                     if(l!=null) {
  625.                         risultato.setRisultato(l.longValue());
  626.                     }
  627.                     else {
  628.                         throw new CoreException("Translate type (result) '"+result+"' non riuscito");
  629.                     }
  630.                 }
  631.                 else{
  632.                     if(result!=null){
  633.                         /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  634.                         this.logDebug("BandaNotFound ["+result.getClass().getName()+"]: "+result);
  635.                     }else{
  636.                         this.logDebug("BandaNotFound, result is null");
  637.                     }
  638.                     risultato.setRisultato(0);
  639.                 }
  640.             }catch(NotFoundException notFound){
  641.                 this.logDebug("BandaNotFound:"+notFound.getMessage(),notFound);
  642.                 risultato.setRisultato(0);
  643.             }
  644.             
  645.             return risultato;
  646.             
  647.         }catch(Exception e){
  648.             this.logError("Errore durante la raccolta dei dati statisti (key:"+key+"): "+e.getMessage(),e);
  649.             throw new CoreException(e.getMessage(),e);
  650.         }finally {
  651.             try{
  652.                 if(!useConnectionRuntime &&
  653.                     r!=null) {
  654.                     this.dbStatisticheManager.releaseResource(dominio, idModulo, r);
  655.                 }
  656.             }catch(Exception eClose){
  657.                 // ignore
  658.             }
  659.         }
  660.         
  661.     }
  662.     
  663.     private IExpression createWhereExpressionBanda(
  664.             IServiceSearchWithoutId<?> dao, StatisticaModel model, 
  665.             TipoRisorsa tipoRisorsa,
  666.             Date dataInizio, Date dataFine,
  667.             TipoPdD tipoPdDTransazioneInCorso,
  668.             IProtocolFactory<?> protocolFactory, String protocollo,
  669.             IDUnivocoGroupByPolicy groupByPolicy, AttivazionePolicyFiltro filtro,
  670.             TipoBanda tipoBanda,
  671.             IState state,
  672.             RequestInfo requestInfo) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException, DriverRegistroServiziException, DriverConfigurazioneException {
  673.         
  674.         IExpression expr = this.createWhereExpression(dao, model, tipoRisorsa, dataInizio, dataFine, tipoPdDTransazioneInCorso, protocolFactory, protocollo, groupByPolicy, filtro, state, requestInfo);

  676.         switch (tipoBanda) {
  677.         case COMPLESSIVA:
  678.             expr.isNotNull(model.DIMENSIONI_BYTES_BANDA_COMPLESSIVA);
  679.             break;
  680.         case INTERNA:
  681.             expr.isNotNull(model.DIMENSIONI_BYTES_BANDA_INTERNA);
  682.             break;
  683.         case ESTERNA:
  684.             expr.isNotNull(model.DIMENSIONI_BYTES_BANDA_ESTERNA);
  685.             break;
  686.         }
  687.         
  688.         return expr;
  689.         
  690.     }
  691.     
  692.     
  693.     
  694.     /* ********************** LATENZA ************************** */
  695.     
  696.     public RisultatoStatistico readLatenza(String key,TipoRisorsa tipoRisorsa, 
  697.             TipoFinestra tipoFinestra,TipoPeriodoStatistico tipoPeriodo, Date leftInterval, Date rightInterval,
  698.             TipoLatenza tipoLatenza,
  699.             DatiTransazione datiTransazione,IDUnivocoGroupByPolicy groupByPolicy, AttivazionePolicyFiltro filtro,
  700.             IState state,
  701.             RequestInfo requestInfo,
  702.             IProtocolFactory<?> protocolFactory) throws CoreException {
  703.     
  704.         Resource r = null;
  705.         boolean useConnectionRuntime = false;
  706.         IDSoggetto dominio = datiTransazione.getDominio();
  707.         String idModulo = datiTransazione.getModulo()+".statistiche.readLatenza";
  708.         String idTransazione = datiTransazione.getIdTransazione();
  709.         try{
  710.             Connection con = null;
  711.             if(this.checkState &&
  712.                 state!=null &&
  713.                 state instanceof StateMessage) {
  714.                 StateMessage s = (StateMessage) state;
  715.                 if(s.getConnectionDB()!=null && !s.getConnectionDB().isClosed()) {
  716.                     con = s.getConnectionDB();
  717.                     useConnectionRuntime = true;
  718.                 }
  719.             }
  720.             if(!useConnectionRuntime){
  721.                 r = this.dbStatisticheManager.getResource(dominio, idModulo, idTransazione);
  722.                 if(r==null){
  723.                     throw new CoreException(RISORSA_DB_NON_DISPONIBILE);
  724.                 }
  725.                 con = (Connection) r.getResource();
  726.             }
  727.             if(con == null)
  728.                 throw new CoreException(CONNESSIONE_DB_NON_DISPONIBILE);    

  730.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  731.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(),
  732.                             con, this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  733.                 
  734.             StatisticaModel model = null;
  735.             IServiceSearchWithoutId<?> dao = null;
  736.             boolean calcolaSommeMediaPesata = false;
  737.             
  738.             if(tipoFinestra!=null && TipoFinestra.SCORREVOLE.equals(tipoFinestra)){
  739.                 model = StatisticaOraria.model().STATISTICA_BASE;
  740.                 dao = statisticheSM.getStatisticaOrariaServiceSearch();
  741.             }
  742.             else{
  743.                 switch (tipoPeriodo) {
  744.                 case ORARIO:
  745.                     model = StatisticaOraria.model().STATISTICA_BASE;
  746.                     dao = statisticheSM.getStatisticaOrariaServiceSearch();
  747.                     break;
  748.                 case GIORNALIERO:
  749.                     model = StatisticaGiornaliera.model().STATISTICA_BASE;
  750.                     dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  751.                     break;
  752.                 case SETTIMANALE:
  753.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanale_usaStatisticheGiornaliere()) {
  754.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  755.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  756.                         calcolaSommeMediaPesata = this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanaleMensile_usaStatisticheGiornaliere_latenza_mediaPesata();
  757.                     }
  758.                     else {
  759.                         model = StatisticaSettimanale.model().STATISTICA_BASE;
  760.                         dao = statisticheSM.getStatisticaSettimanaleServiceSearch();
  761.                     }
  762.                     break;
  763.                 case MENSILE:
  764.                     if(this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneMensile_usaStatisticheGiornaliere()) {
  765.                         model = StatisticaGiornaliera.model().STATISTICA_BASE;
  766.                         dao = statisticheSM.getStatisticaGiornalieraServiceSearch();
  767.                         calcolaSommeMediaPesata = this.configurazioneControlloTraffico.isElaborazioneStatistica_distribuzioneSettimanaleMensile_usaStatisticheGiornaliere_latenza_mediaPesata();
  768.                     }
  769.                     else {
  770.                         model = StatisticaMensile.model().STATISTICA_BASE;
  771.                         dao = statisticheSM.getStatisticaMensileServiceSearch();
  772.                     }
  773.                     break;
  774.                 }
  775.             }
  776.             
  777.             if(model==null) {
  778.                 throw new CoreException(MODEL_UNKNOWN);
  779.             }
  780.             if(dao==null) {
  781.                 throw new CoreException(DAO_UNKNOWN);
  782.             }
  783.             
  784.             ISQLFieldConverter fieldConverter = ((IDBServiceUtilities<?>)dao).getFieldConverter(); 
  785.             
  786.             IExpression expression = this.createWhereExpressionLatenza(dao, model, tipoRisorsa, leftInterval, rightInterval, 
  787.                     datiTransazione.getTipoPdD(), protocolFactory, datiTransazione.getProtocollo(), groupByPolicy, filtro, tipoLatenza, state, requestInfo);
  788.                         
  789.             FunctionField ff = null;
  790.             switch (tipoLatenza) {
  791.             case PORTA:
  792.                 /**ff = new  FunctionField(model.LATENZA_PORTA, Function.AVG, "somma_latenza");*/
  793.                 ff = StatisticheUtils.calcolaMedia(fieldConverter, model.LATENZA_PORTA, model.NUMERO_TRANSAZIONI, "somma_latenza");
  794.                 break;
  795.             case SERVIZIO:
  796.                 /**ff = new  FunctionField(model.LATENZA_SERVIZIO, Function.AVG, "somma_latenza");*/
  797.                 ff = StatisticheUtils.calcolaMedia(fieldConverter, model.LATENZA_SERVIZIO, model.NUMERO_TRANSAZIONI, "somma_latenza");
  798.                 break;
  799.             case TOTALE:
  800.             default:
  801.                 /**ff = new  FunctionField(model.LATENZA_TOTALE, Function.AVG, "somma_latenza");*/
  802.                 ff = StatisticheUtils.calcolaMedia(fieldConverter, model.LATENZA_TOTALE, model.NUMERO_TRANSAZIONI, "somma_latenza");
  803.                 break;
  804.             }
  805.             
  806.             FunctionField ffSommaPesata = null;
  807.             if(calcolaSommeMediaPesata) {
  808.                 // per media pesata
  809.                 ffSommaPesata = new FunctionField(model.NUMERO_TRANSAZIONI,Function.SUM, "somma_media_pesata");
  810.             }
  811.             
  812.             RisultatoStatistico risultato = new RisultatoStatistico();
  813.             risultato.setDataInizio(leftInterval);
  814.             risultato.setDataFine(rightInterval);
  815.             risultato.setDateCheck(DateManager.getDate());
  816.             
  817.             try{
  818.                 if(ffSommaPesata!=null) {
  819.                     
  820.                     expression.addGroupBy(model.DATA);
  821.                     
  822.                     List<Map<String, Object>> list = dao.groupBy(expression, ff, ffSommaPesata);
  823.                     if(list!=null && !list.isEmpty()) {
  824.                         long sommaMediePesate = 0;
  825.                         long sommaNumeroTransazioni = 0;
  826.                         for (Map<String, Object> map : list) {
  827.                             Object result = map.get("somma_latenza");
  828.                             Object resultPesata = map.get("somma_media_pesata");
  829.                             long latenza = 0;
  830.                             long numeroTransazioni = 0;
  831.                             if(result!=null && this.isKnownType(result) ){
  832.                                 Long l = this.translateType(result);
  833.                                 if(l!=null) {
  834.                                     latenza = l.longValue();
  835.                                 }
  836.                                 else {
  837.                                     throw new CoreException("Translate type (result) '"+result+"' non riuscito");
  838.                                 }
  839.                             }
  840.                             if(resultPesata!=null && this.isKnownType(resultPesata) ){
  841.                                 Long l = this.translateType(resultPesata);
  842.                                 if(l!=null) {
  843.                                     numeroTransazioni = l.longValue();
  844.                                 }
  845.                                 else {
  846.                                     throw new CoreException("Translate type (resultPesata) '"+resultPesata+"' non riuscito");
  847.                                 }
  848.                             }
  849.                             sommaNumeroTransazioni+=numeroTransazioni;
  850.                             long mediaPesata = latenza*numeroTransazioni;
  851.                             sommaMediePesate+=mediaPesata;
  852.                         }
  853.                         long risultatoPesato = (sommaNumeroTransazioni>0) ? (sommaMediePesate / sommaNumeroTransazioni) : 0;
  854.                         risultato.setRisultato(risultatoPesato);
  855.                     }
  856.                     else {
  857.                         this.logDebug("LatenzaNotFound");
  858.                         risultato.setRisultato(0);
  859.                     }
  860.                 }
  861.                 else {
  862.                     Object result = dao.aggregate(expression, ff);
  863.                     if(result!=null && this.isKnownType(result) ){
  864.                         /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  865.                         this.logDebug("LatenzaFound ["+result.getClass().getName()+"]: "+result);
  866.                         Long l = this.translateType(result);
  867.                         if(l!=null) {
  868.                             risultato.setRisultato(l.longValue());
  869.                         }
  870.                         else {
  871.                             throw new CoreException("Translate type (result) '"+result+"' non riuscito");
  872.                         }
  873.                     }
  874.                     else{
  875.                         if(result!=null){
  876.                             /**System.out.println("RITORNO OGGETTO LETTO DA DB CON CHIAVE ["+key+"]: ["+result+"] ["+result.getClass().getName()+"]");*/
  877.                             this.logDebug("LatenzaNotFound ["+result.getClass().getName()+"]: "+result);
  878.                         }else{
  879.                             this.logDebug("LatenzaNotFound, result is null");
  880.                         }
  881.                         risultato.setRisultato(0);
  882.                     }
  883.                 }
  884.             }catch(NotFoundException notFound){
  885.                 this.logDebug("LatenzaNotFound:"+notFound.getMessage(),notFound);
  886.                 risultato.setRisultato(0);
  887.             }
  888.             
  889.             return risultato;
  890.             
  891.         }catch(Exception e){
  892.             this.logError("Errore durante la raccolta dei dati statisti (key:"+key+"): "+e.getMessage(),e);
  893.             throw new CoreException(e.getMessage(),e);
  894.         }finally {
  895.             try{
  896.                 if(!useConnectionRuntime &&
  897.                     r!=null) {
  898.                     this.dbStatisticheManager.releaseResource(dominio, idModulo, r);
  899.                 }
  900.             }catch(Exception eClose){
  901.                 // ignore
  902.             }
  903.         }
  904.         
  905.     }
  906.     
  907.     private IExpression createWhereExpressionLatenza(
  908.             IServiceSearchWithoutId<?> dao, StatisticaModel model, 
  909.             TipoRisorsa tipoRisorsa,
  910.             Date dataInizio, Date dataFine,
  911.             TipoPdD tipoPdDTransazioneInCorso,
  912.             IProtocolFactory<?> protocolFactory, String protocollo,
  913.             IDUnivocoGroupByPolicy groupByPolicy, AttivazionePolicyFiltro filtro,
  914.             TipoLatenza tipoLatenza,
  915.             IState state,
  916.             RequestInfo requestInfo) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException, DriverRegistroServiziException, DriverConfigurazioneException {
  917.         
  918.         IExpression expr = this.createWhereExpression(dao, model, tipoRisorsa, dataInizio, dataFine, tipoPdDTransazioneInCorso, protocolFactory, protocollo, groupByPolicy, filtro, state, requestInfo);

  920.         int [] esiti = null;
  921.         if(TipoPdD.DELEGATA.equals(tipoPdDTransazioneInCorso)){
  922.             esiti = this.configurazioneControlloTraffico.getCalcoloLatenzaPortaDelegataEsitiConsiderati().get(protocollo);
  923.         }
  924.         else{
  925.             esiti = this.configurazioneControlloTraffico.getCalcoloLatenzaPortaApplicativaEsitiConsiderati().get(protocollo);       
  926.         }
  927.         
  928.         // esito
  929.         IExpression exprEsiti = dao.newExpression();
  930.         exprEsiti.or();
  931.         for (int i = 0; i < esiti.length; i++) {
  932.             exprEsiti.equals(model.ESITO, esiti[i]);
  933.         }
  934.         expr.and(exprEsiti);
  935.             
  936.         
  937.         switch (tipoLatenza) {
  938.         case PORTA:
  939.             expr.isNotNull(model.LATENZA_PORTA);
  940.             break;
  941.         case SERVIZIO:
  942.             expr.isNotNull(model.LATENZA_SERVIZIO);
  943.             break;
  944.         case TOTALE:
  945.         default:
  946.             expr.isNotNull(model.LATENZA_TOTALE);
  947.             break;
  948.         }
  949.         
  950.         return expr;
  951.         
  952.     }
  953.     
  954.     
  955.     
  956.     // ***************** UTILS ************************
  957.     
  958.     
  959.     private IExpression createWhereExpression(
  960.             IServiceSearchWithoutId<?> dao, StatisticaModel model, 
  961.             TipoRisorsa tipoRisorsa,
  962.             Date dataInizio, Date dataFine,
  963.             TipoPdD tipoPdDTransazioneInCorso,
  964.             IProtocolFactory<?> protocolFactory, String protocollo,
  965.             IDUnivocoGroupByPolicy groupByPolicy,
  966.             AttivazionePolicyFiltro filtro,
  967.             IState state,
  968.             RequestInfo requestInfo) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException, DriverRegistroServiziException, DriverConfigurazioneException  {

  970.         IExpression expr = null;

  972.         expr = dao.newExpression();
  973.         expr.and();
  974.         
  975.         // Data
  976.         expr.between(model.DATA,
  977.                 dataInizio,
  978.                 dataFine);
  979.         
  980.         // Record validi
  981.         StatisticheUtils.selezionaRecordValidi(expr, model);

  983.         
  984.         // escludo le transazioni con esito policy violate
  985.         int [] esitiPolicyViolate = this.configurazioneControlloTraffico.getEsitiPolicyViolate().get(protocollo);    
  986.         IExpression exprEsitiPolicyViolate = dao.newExpression();
  987.         exprEsitiPolicyViolate.or();
  988.         for (int i = 0; i < esitiPolicyViolate.length; i++) {
  989.             exprEsitiPolicyViolate.equals(model.ESITO, esitiPolicyViolate[i]);
  990.         }
  991.         expr.not(exprEsitiPolicyViolate);

  993.         
  994.         // Aggiungo esiti specifici
  995.         switch (tipoRisorsa) {
  996.         case NUMERO_RICHIESTE:
  997.         case DIMENSIONE_MASSIMA_MESSAGGIO:
  998.         case OCCUPAZIONE_BANDA:
  999.         case TEMPO_COMPLESSIVO_RISPOSTA:
  1000.         case TEMPO_MEDIO_RISPOSTA:
  1001.             // non serve filtrare altri esiti
  1002.             break;

  1004.         case NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO:
  1005.             expr.in(model.ESITO, EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeOk());
  1006.             break;
  1007.         case NUMERO_RICHIESTE_FALLITE:
  1008.             expr.in(model.ESITO, EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeKo_senzaFaultApplicativo());
  1009.             break;
  1010.         case NUMERO_FAULT_APPLICATIVI:
  1011.             expr.in(model.ESITO, EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeFaultApplicativo());
  1012.             break;
  1013.         case NUMERO_RICHIESTE_FALLITE_OFAULT_APPLICATIVI:
  1014.             expr.in(model.ESITO, EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeKo());
  1015.             break;
  1016.         case NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_OFAULT_APPLICATIVI:{
  1017.             List<Integer> esitiAppartenentiGruppo = new ArrayList<>();
  1018.             esitiAppartenentiGruppo.addAll(EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeOk());
  1019.             esitiAppartenentiGruppo.addAll(EsitiProperties.getInstance(this.daoFactoryLogger,protocolFactory).getEsitiCodeFaultApplicativo());
  1020.             expr.in(model.ESITO, esitiAppartenentiGruppo);
  1021.             break;
  1022.         }
  1023.         }
  1024.         
  1025.         
  1026.         // capisco tipologia di policy
  1027.         boolean policyGlobale = true;
  1028.         if(filtro!=null && filtro.isEnabled() && filtro.getNomePorta()!=null && !"".equals(filtro.getNomePorta())){
  1029.             policyGlobale = false;
  1030.         }
  1031.         
  1032.         
  1033.         // Tipo Porta
  1034.         TipoPorta tipoPortaStat = null;
  1035.         TipoPdD tipoPdD = groupByPolicy.getRuoloPortaAsTipoPdD();
  1036.         if(tipoPdD==null &&
  1037.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1038.             (filtro!=null && filtro.isEnabled() &&
  1039.                 (filtro.getRuoloPorta()!=null && !"".equals(filtro.getRuoloPorta().getValue()) && 
  1040.                         !RuoloPolicy.ENTRAMBI.equals(filtro.getRuoloPorta()))
  1041.                 )
  1042.             ){              
  1043.             if(RuoloPolicy.DELEGATA.equals(filtro.getRuoloPorta())){
  1044.                 tipoPdD = TipoPdD.DELEGATA;
  1045.             }
  1046.             if(RuoloPolicy.APPLICATIVA.equals(filtro.getRuoloPorta())){
  1047.                 tipoPdD = TipoPdD.APPLICATIVA;
  1048.             }
  1049.         }
  1050.         if(tipoPdD!=null){
  1051.             switch (tipoPdD) {
  1052.             case DELEGATA:
  1053.                 tipoPortaStat = TipoPorta.DELEGATA;
  1054.                 break;
  1055.             case APPLICATIVA:
  1056.                 tipoPortaStat = TipoPorta.APPLICATIVA;
  1057.                 break;
  1058.             case INTEGRATION_MANAGER:
  1059.                 tipoPortaStat = TipoPorta.INTEGRATION_MANAGER;
  1060.                 break;
  1061.             case ROUTER:
  1062.                 tipoPortaStat = TipoPorta.ROUTER;
  1063.                 break;
  1064.     
  1065.             }
  1066.             expr.equals(model.TIPO_PORTA, tipoPortaStat);
  1067.         }
  1068.         
  1069.         // mittente
  1070.         IDSoggetto fruitore = groupByPolicy.getFruitoreIfDefined();
  1071.         List<IDSoggetto> fruitoriByRuolo = null;
  1072.         if(fruitore==null &&
  1073.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1074.             filtro!=null && filtro.isEnabled()){
  1075.             if(filtro.getTipoFruitore()!=null && !"".equals(filtro.getTipoFruitore()) &&
  1076.                     filtro.getNomeFruitore()!=null && !"".equals(filtro.getNomeFruitore())){
  1077.                 fruitore = new IDSoggetto(filtro.getTipoFruitore(), filtro.getNomeFruitore());
  1078.             }
  1079.             else if(filtro.getRuoloFruitore()!=null && !"".equals(filtro.getRuoloFruitore())){
  1080.                 /*
  1081.                  * Se policyGlobale:
  1082.                  *    si controlla sia il fruitore che l'applicativo. Basta che uno sia soddisfatto.
  1083.                  * else
  1084.                  *    nel caso di delegata si controlla solo l'applicativo.
  1085.                  *    nel caso di applicativa entrambi, e basta che uno sia soddisfatto.
  1086.                  **/
  1087.                 if(policyGlobale || TipoPdD.APPLICATIVA.equals(tipoPdD)){
  1088.                     RegistroServiziManager registroManager = RegistroServiziManager.getInstance(state);
  1089.                     FiltroRicercaSoggetti filtroRicerca = new FiltroRicercaSoggetti();
  1090.                     IDRuolo idRuolo = new IDRuolo(filtro.getRuoloFruitore());
  1091.                     filtroRicerca.setIdRuolo(idRuolo);
  1092.                     try {
  1093.                         fruitoriByRuolo = registroManager.getAllIdSoggetti(filtroRicerca, null);
  1094.                     }catch(DriverRegistroServiziNotFound notFound) {
  1095.                         // ignore
  1096.                     }
  1097.                 }
  1098.             }
  1099.         }
  1100.         if(fruitore!=null){
  1101.             expr.equals(model.TIPO_MITTENTE, fruitore.getTipo());
  1102.             expr.equals(model.MITTENTE, fruitore.getNome());
  1103.         }
  1104.         else if (fruitoriByRuolo!=null && !fruitoriByRuolo.isEmpty()) {
  1105.             List<IExpression> l = new ArrayList<>();
  1106.             for (IDSoggetto soggetto : fruitoriByRuolo) {
  1107.                 IExpression exprSoggetto = dao.newExpression();
  1108.                 exprSoggetto.equals(model.TIPO_MITTENTE, soggetto.getTipo());
  1109.                 exprSoggetto.and();
  1110.                 exprSoggetto.equals(model.MITTENTE, soggetto.getNome());
  1111.                 l.add(exprSoggetto);
  1112.             }
  1113.             expr.or(l.toArray(new IExpression[l.size()]));
  1114.         }
  1115.         
  1116.         // destinatario
  1117.         IDSoggetto erogatore = groupByPolicy.getErogatoreIfDefined();
  1118.         List<IDSoggetto> erogatoriByRuolo = null;
  1119.         if(erogatore==null &&
  1120.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1121.             filtro!=null && filtro.isEnabled()){
  1122.             if(filtro.getTipoErogatore()!=null && !"".equals(filtro.getTipoErogatore()) &&
  1123.                     filtro.getNomeErogatore()!=null && !"".equals(filtro.getNomeErogatore())){
  1124.                 erogatore = new IDSoggetto(filtro.getTipoErogatore(), filtro.getNomeErogatore());
  1125.             }
  1126.             else if(filtro.getRuoloErogatore()!=null && !"".equals(filtro.getRuoloErogatore())){
  1127.                 RegistroServiziManager registroManager = RegistroServiziManager.getInstance(state);
  1128.                 FiltroRicercaSoggetti filtroRicerca = new FiltroRicercaSoggetti();
  1129.                 IDRuolo idRuolo = new IDRuolo(filtro.getRuoloErogatore());
  1130.                 filtroRicerca.setIdRuolo(idRuolo);
  1131.                 try {
  1132.                     erogatoriByRuolo = registroManager.getAllIdSoggetti(filtroRicerca, null);
  1133.                 }catch(DriverRegistroServiziNotFound notFound) {
  1134.                     // ignore
  1135.                 }
  1136.             }
  1137.         }
  1138.         if(erogatore!=null){
  1139.             expr.equals(model.TIPO_DESTINATARIO, erogatore.getTipo());
  1140.             expr.equals(model.DESTINATARIO, erogatore.getNome());
  1141.         }
  1142.         else if (erogatoriByRuolo!=null && !erogatoriByRuolo.isEmpty()) {
  1143.             List<IExpression> l = new ArrayList<>();
  1144.             for (IDSoggetto soggetto : erogatoriByRuolo) {
  1145.                 IExpression exprSoggetto = dao.newExpression();
  1146.                 exprSoggetto.equals(model.TIPO_DESTINATARIO, soggetto.getTipo());
  1147.                 exprSoggetto.and();
  1148.                 exprSoggetto.equals(model.DESTINATARIO, soggetto.getNome());
  1149.                 l.add(exprSoggetto);
  1150.             }
  1151.             expr.or(l.toArray(new IExpression[l.size()]));
  1152.         }
  1153.         
  1154.         // servizio
  1155.         IDServizio idServizio = groupByPolicy.getServizioIfDefined();
  1156.         List<IDServizio> idServiziByTag = null;
  1157.         if(idServizio==null &&
  1158.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1159.             filtro!=null && filtro.isEnabled()){
  1160.             if(filtro.getTipoServizio()!=null && !"".equals(filtro.getTipoServizio()) &&
  1161.                     filtro.getNomeServizio()!=null && !"".equals(filtro.getNomeServizio()) &&
  1162.                     filtro.getVersioneServizio()!=null){
  1163.                 idServizio = IDServizioFactory.getInstance().getIDServizioFromValuesWithoutCheck(filtro.getTipoServizio(), filtro.getNomeServizio(), null, null, filtro.getVersioneServizio().intValue());
  1164.             }
  1165.             else if(!policyGlobale && filtro.getNomePorta()!=null && !"".equals(filtro.getNomePorta()) && filtro.getRuoloPorta()!=null) {
  1166.                 ConfigurazionePdDManager configurazionePdDManager = ConfigurazionePdDManager.getInstance(state);
  1167.                 if(RuoloPolicy.DELEGATA.equals(filtro.getRuoloPorta())){
  1168.                     IDPortaDelegata idPD = new IDPortaDelegata();
  1169.                     idPD.setNome(filtro.getNomePorta());
  1170.                     PortaDelegata pd = configurazionePdDManager.getPortaDelegataSafeMethod(idPD, requestInfo);
  1171.                     if(pd!=null && pd.getServizio()!=null && pd.getSoggettoErogatore()!=null) {
  1172.                         idServizio = IDServizioFactory.getInstance().getIDServizioFromValuesWithoutCheck(pd.getServizio().getTipo(), pd.getServizio().getNome(), 
  1173.                                 pd.getSoggettoErogatore().getTipo(), pd.getSoggettoErogatore().getNome(), 
  1174.                                 pd.getServizio().getVersione());
  1175.                     }
  1176.                 }
  1177.                 else {
  1178.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  1179.                     idPA.setNome(filtro.getNomePorta());
  1180.                     PortaApplicativa pa = configurazionePdDManager.getPortaApplicativaSafeMethod(idPA, requestInfo);
  1181.                     if(pa!=null && pa.getServizio()!=null) {
  1182.                         idServizio = IDServizioFactory.getInstance().getIDServizioFromValuesWithoutCheck(pa.getServizio().getTipo(), pa.getServizio().getNome(), 
  1183.                                 pa.getTipoSoggettoProprietario(), pa.getNomeSoggettoProprietario(), 
  1184.                                 pa.getServizio().getVersione());
  1185.                     }
  1186.                 }
  1187.             }
  1188.             else if(filtro.getTag()!=null && !"".equals(filtro.getTag())){
  1189.                 RegistroServiziManager registroManager = RegistroServiziManager.getInstance(state);
  1190.                 FiltroRicercaAccordi filtroRicercaAccordi = new FiltroRicercaAccordi(); 
  1191.                 filtroRicercaAccordi.setIdGruppo(new IDGruppo(filtro.getTag()));
  1192.                 List<IDAccordo> lIdAccordi = null;
  1193.                 try {
  1194.                     lIdAccordi = registroManager.getAllIdAccordiServizioParteComune(filtroRicercaAccordi, null);
  1195.                 }catch(DriverRegistroServiziNotFound notFound) {
  1196.                     // ignore
  1197.                 }
  1198.                 if(lIdAccordi!=null && !lIdAccordi.isEmpty()) {
  1199.                     for (IDAccordo idAccordoByTag : lIdAccordi) {
  1200.                         FiltroRicercaServizi filtroRicerca = new FiltroRicercaServizi();
  1201.                         filtroRicerca.setIdAccordoServizioParteComune(idAccordoByTag);
  1202.                         if(erogatore!=null) {
  1203.                             filtroRicerca.setTipoSoggettoErogatore(erogatore.getTipo());
  1204.                             filtroRicerca.setNomeSoggettoErogatore(erogatore.getNome());
  1205.                         }
  1206.                         List<IDServizio> lIdServizi = null;
  1207.                         try {
  1208.                             lIdServizi = registroManager.getAllIdServizi(filtroRicerca, null);
  1209.                         }catch(DriverRegistroServiziNotFound notFound) {
  1210.                             // ignore
  1211.                         }
  1212.                         if(lIdServizi!=null && !lIdServizi.isEmpty()) {
  1213.                             if(idServiziByTag==null) {
  1214.                                 idServiziByTag = new ArrayList<>();
  1215.                             }
  1216.                             for (IDServizio idServizioByTag : lIdServizi) {
  1217.                                 idServiziByTag.add(idServizioByTag);
  1218.                             }
  1219.                         }
  1220.                     }
  1221.                 }
  1222.             }
  1223.         }
  1224.         if(idServizio!=null){
  1225.             expr.equals(model.TIPO_SERVIZIO, idServizio.getTipo());
  1226.             expr.equals(model.SERVIZIO, idServizio.getNome());
  1227.             expr.equals(model.VERSIONE_SERVIZIO, idServizio.getVersione());
  1228.         }
  1229.         else if (idServiziByTag!=null && !idServiziByTag.isEmpty()) {
  1230.             List<IExpression> l = new ArrayList<>();
  1231.             for (IDServizio idServizioByTag : idServiziByTag) {
  1232.                 IExpression exprServizio = dao.newExpression();
  1233.                 exprServizio.and();
  1234.                 exprServizio.equals(model.TIPO_DESTINATARIO, idServizioByTag.getSoggettoErogatore().getTipo());
  1235.                 exprServizio.equals(model.DESTINATARIO, idServizioByTag.getSoggettoErogatore().getNome());
  1236.                 exprServizio.equals(model.TIPO_SERVIZIO, idServizioByTag.getTipo());
  1237.                 exprServizio.equals(model.SERVIZIO, idServizioByTag.getNome());
  1238.                 exprServizio.equals(model.VERSIONE_SERVIZIO, idServizioByTag.getVersione());
  1239.                 l.add(exprServizio);
  1240.             }
  1241.             expr.or(l.toArray(new IExpression[l.size()]));
  1242.         }
  1243.         
  1244.         // protocollo
  1245.         String protocolloGroupBy = groupByPolicy.getProtocolloIfDefined();
  1246.         if(protocolloGroupBy==null &&
  1247.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1248.             filtro!=null && filtro.isEnabled() &&
  1249.             filtro.getProtocollo()!=null && !"".equals(filtro.getProtocollo())){
  1250.             protocolloGroupBy = filtro.getProtocollo();
  1251.         }
  1252.         if(protocolloGroupBy!=null &&
  1253.             fruitore==null && erogatore==null && idServizio==null){
  1254.             // il tipo se è definito uno dei 3 elementi è insito nell'elemento stesso
  1255.             List<String> listaTipiSoggetto = ProtocolFactoryManager.getInstance().getOrganizationTypes().get(protocolloGroupBy);
  1256.             expr.in(model.TIPO_MITTENTE, listaTipiSoggetto);
  1257.             expr.in(model.TIPO_DESTINATARIO, listaTipiSoggetto);
  1258.         }
  1259.         
  1260.         // azione
  1261.         String azione = groupByPolicy.getAzioneIfDefined();
  1262.         if(azione!=null){
  1263.             expr.equals(model.AZIONE, azione);
  1264.         }
  1265.         else {
  1266.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1267.             if(filtro!=null && filtro.isEnabled() &&
  1268.                 filtro.getAzione()!=null && !"".equals(filtro.getAzione()) && idServizio!=null){
  1269.                 String [] tmp = filtro.getAzione().split(",");
  1270.                 List<String> azioneList = new ArrayList<>();
  1271.                 if(tmp!=null && tmp.length>0) {
  1272.                     for (String az : tmp) {
  1273.                         azioneList.add(az);
  1274.                     }
  1275.                 }
  1276.                 expr.in(model.AZIONE, azioneList);
  1277.             }
  1278.         }
  1279.         
  1280.         // Servizio Applicativo
  1281.         /**if(TipoPdD.DELEGATA.equals(tipoPdDTransazioneInCorso)){*/
  1282.             
  1283.         // servizioApplicativoFruitore
  1284.         String servizioApplicativoFruitore = groupByPolicy.getServizioApplicativoFruitoreIfDefined();
  1285.         List<IDServizioApplicativo> servizioApplicativoFruitoreByRuolo = null;
  1286.         if(servizioApplicativoFruitore==null &&
  1287.             // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1288.             filtro!=null && filtro.isEnabled()){
  1289.             if(filtro.getServizioApplicativoFruitore()!=null && !"".equals(filtro.getServizioApplicativoFruitore())){
  1290.                 servizioApplicativoFruitore = filtro.getServizioApplicativoFruitore();
  1291.             }
  1292.             else if(filtro.getRuoloFruitore()!=null && !"".equals(filtro.getRuoloFruitore())){
  1293.                 /*
  1294.                  * Se policyGlobale:
  1295.                  *    si controlla sia il fruitore che l'applicativo. Basta che uno sia soddisfatto.
  1296.                  * else
  1297.                  *    nel caso di delegata si controlla solo l'applicativo.
  1298.                  *    nel caso di applicativa entrambi, e basta che uno sia soddisfatto.
  1299.                  **/
  1300.                 ConfigurazionePdDManager configurazionePdDManager = ConfigurazionePdDManager.getInstance(state);
  1301.                 FiltroRicercaServiziApplicativi filtroRicerca = new FiltroRicercaServiziApplicativi();
  1302.                 IDRuolo idRuolo = new IDRuolo(filtro.getRuoloFruitore());
  1303.                 filtroRicerca.setIdRuolo(idRuolo);
  1304.                 List<IDServizioApplicativo> list = null;
  1305.                 try {
  1306.                     list = configurazionePdDManager.getAllIdServiziApplicativi(filtroRicerca);
  1307.                 }catch(DriverConfigurazioneNotFound notFound) {
  1308.                     // ignore
  1309.                 }
  1310.                 if(list!=null && !list.isEmpty()) {
  1311.                     servizioApplicativoFruitoreByRuolo = list;
  1312.                 }
  1313.             }
  1314.         }
  1315.         if(servizioApplicativoFruitore!=null){
  1316.             expr.equals(model.SERVIZIO_APPLICATIVO, servizioApplicativoFruitore);
  1317.         }
  1318.         else if (servizioApplicativoFruitoreByRuolo!=null && !servizioApplicativoFruitoreByRuolo.isEmpty()) {
  1319.             List<IExpression> l = new ArrayList<>();
  1320.             for (IDServizioApplicativo idServizioApplicativo : servizioApplicativoFruitoreByRuolo) {
  1321.                 IExpression exprServizioApplicativo = dao.newExpression();
  1322.                 exprServizioApplicativo.and();
  1323.                 exprServizioApplicativo.equals(model.TIPO_MITTENTE, idServizioApplicativo.getIdSoggettoProprietario().getTipo());
  1324.                 exprServizioApplicativo.equals(model.MITTENTE, idServizioApplicativo.getIdSoggettoProprietario().getNome());
  1325.                 exprServizioApplicativo.equals(model.SERVIZIO_APPLICATIVO, idServizioApplicativo.getNome());
  1326.                 l.add(exprServizioApplicativo);
  1327.             }
  1328.             expr.or(l.toArray(new IExpression[l.size()]));
  1329.         }
  1330.             
  1331.         
  1332.         
  1333.         if(TipoPdD.APPLICATIVA.equals(tipoPdDTransazioneInCorso)){
  1334.             
  1335.             // servizioApplicativoErogatore
  1336.             String servizioApplicativoErogatore = groupByPolicy.getServizioApplicativoErogatoreIfDefined();
  1337.             if(servizioApplicativoErogatore==null &&
  1338.                 // se è stato applicato un filtro, devo prelevare solo le informazioni statistiche che hanno un match non il filtro
  1339.                 (filtro!=null && filtro.isEnabled() &&
  1340.                     filtro.getServizioApplicativoErogatore()!=null && !"".equals(filtro.getServizioApplicativoErogatore()))
  1341.                 ){
  1342.                 servizioApplicativoErogatore = filtro.getServizioApplicativoErogatore();
  1343.             }
  1344.             if(servizioApplicativoErogatore!=null){
  1345.                 expr.equals(model.SERVIZIO_APPLICATIVO, servizioApplicativoErogatore);
  1346.             }
  1347.             
  1348.         }
  1349.         return expr;
  1350.     }

  1352.     private boolean isKnownType(Object result){
  1353.         return (result instanceof Long) || (result instanceof Integer) || (result instanceof Short) 
  1354.                 || (result instanceof Double) || (result instanceof Float)  ;
  1355.     }
  1356.     
  1357.     private Long translateType(Object result){
  1358.         if ( result instanceof Long  ){
  1359.             return (Long) result;
  1360.         }
  1361.         else if ( result instanceof Integer  ){
  1362.             return ((Integer) result).longValue();
  1363.         }
  1364.         else if ( result instanceof Short  ){
  1365.             return ((Short) result).longValue();
  1366.         }
  1367.         else if ( result instanceof Double  ){
  1368.             return ((Double) result).longValue();
  1369.         }
  1370.         else if ( result instanceof Float  ){
  1371.             return ((Float) result).longValue();
  1372.         }
  1373.         else{
  1374.             return null;
  1375.         }
  1376.     }
  1377. }
Created with JaCoCo 0.8.8.202204050719