StatisticsUtils.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.monitor.engine.statistic;

  22. import java.util.Date;
  23. import java.util.List;
  24. import java.util.Map;

  26. import org.openspcoop2.core.constants.TipoPdD;
  27. import org.openspcoop2.core.id.IDSoggetto;
  28. import org.openspcoop2.core.plugins.utils.FilterUtils;
  29. import org.openspcoop2.core.statistiche.StatisticaContenuti;
  30. import org.openspcoop2.core.transazioni.Transazione;
  31. import org.openspcoop2.core.transazioni.constants.PddRuolo;
  32. import org.openspcoop2.core.transazioni.dao.ITransazioneServiceSearch;
  33. import org.openspcoop2.generic_project.beans.AliasTableComplexField;
  34. import org.openspcoop2.generic_project.beans.ComplexField;
  35. import org.openspcoop2.generic_project.beans.ConstantField;
  36. import org.openspcoop2.generic_project.beans.Function;
  37. import org.openspcoop2.generic_project.beans.FunctionField;
  38. import org.openspcoop2.generic_project.beans.IAliasTableField;
  39. import org.openspcoop2.generic_project.beans.IField;
  40. import org.openspcoop2.generic_project.beans.UnionExpression;
  41. import org.openspcoop2.generic_project.beans.UnixTimestampIntervalField;
  42. import org.openspcoop2.generic_project.exception.ExpressionException;
  43. import org.openspcoop2.generic_project.exception.ExpressionNotImplementedException;
  44. import org.openspcoop2.generic_project.expression.IExpression;
  45. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  46. import org.openspcoop2.monitor.engine.constants.Costanti;
  47. import org.openspcoop2.monitor.engine.exceptions.EngineException;
  48. import org.openspcoop2.monitor.engine.transaction.TransactionContentUtils;
  49. import org.openspcoop2.monitor.engine.utils.ContentFormatter;
  50. import org.openspcoop2.monitor.sdk.statistic.StatisticFilterName;
  51. import org.openspcoop2.monitor.sdk.statistic.StatisticResourceFilter;
  52. import org.openspcoop2.utils.date.DateUtils;
  53. import org.openspcoop2.utils.sql.SQLQueryObjectException;

  55. /**
  56.  * StatisticsUtils
  57.  *
  58.  * @author Poli Andrea (apoli@link.it)
  59.  * @author $Author$
  60.  * @version $Rev$, $Date$
  61.  */
  62. public class StatisticsUtils {

  64.     
  65.     public static Long readLongValue(Map<String, Object> row, String alias){
  66.         Object object = row.get(alias);
  67.         if(object!=null){
  68.             if(object instanceof org.apache.commons.lang.ObjectUtils.Null){
  69.                 return null;
  70.             }
  71.             else{
  72.                 return (Long) object;
  73.             }
  74.         }
  75.         return null;
  76.     }
  77.     
  78.     public static void setExpressionNotNullDate(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, StatisticBean stat,
  79.             ISQLFieldConverter fieldConverter) throws Exception{
  80.         StatisticsUtils.setExpressionEngine(transazioneSearchDAO, expr, data, dateNext, tipoPdD, 
  81.                 true, false, 
  82.                 stat, fieldConverter, 
  83.                 false, 
  84.                 null,null);
  85.     }
  86.     public static void setExpressionNullDate(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, StatisticBean stat,
  87.             ISQLFieldConverter fieldConverter) throws Exception{
  88.         StatisticsUtils.setExpressionEngine(transazioneSearchDAO, expr, data, dateNext, tipoPdD, 
  89.                 false, true, 
  90.                 stat, fieldConverter, 
  91.                 false, 
  92.                 null,null);
  93.     }
  94.     public static void setExpression(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, boolean setNotNullDate, StatisticBean stat,
  95.             ISQLFieldConverter fieldConverter) throws Exception{
  96.         StatisticsUtils.setExpressionEngine(transazioneSearchDAO, expr, data, dateNext, tipoPdD, 
  97.                 setNotNullDate, false, 
  98.                 stat, fieldConverter, 
  99.                 false, 
  100.                 null,null);
  101.     }
  102.     public static void setExpressionByStato(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, boolean setNotNullDate, StatisticBean stat,
  103.             ISQLFieldConverter fieldConverter) throws Exception{
  104.         StatisticsUtils.setExpressionEngine(transazioneSearchDAO, expr, data, dateNext, tipoPdD, 
  105.                 setNotNullDate, false, 
  106.                 stat, fieldConverter, 
  107.                 true, 
  108.                 null,null);
  109.     }
  110.     public static void setExpressionStatsPersonalizzate(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, boolean setNotNullDate, StatisticBean stat,
  111.             ISQLFieldConverter fieldConverter,
  112.             List<AliasFilter> aliases,
  113.             String idRisorsa,
  114.             StatisticResourceFilter ... risorseFiltri) throws Exception{
  115.         StatisticsUtils.setExpressionEngine(transazioneSearchDAO, expr, data, dateNext, tipoPdD, 
  116.                 setNotNullDate, false,
  117.                 stat, fieldConverter,
  118.                 false,
  119.                 aliases,idRisorsa, 
  120.                 risorseFiltri);
  121.     }
  122.     private static void setExpressionEngine(ITransazioneServiceSearch transazioneSearchDAO, IExpression expr, Date data, Date dateNext, TipoPdD tipoPdD, 
  123.             boolean setNotNullDate, boolean setNullDate, 
  124.             StatisticBean stat, ISQLFieldConverter fieldConverter,
  125.             boolean groupByStato,
  126.             List<AliasFilter> aliases, String idRisorsa,
  127.             StatisticResourceFilter ... risorseFiltri) throws Exception{
  128.         
  129.         expr.and();
  130.         
  131.         // indice
  132.         //expr.between(Transazione.model().DATA_INGRESSO_RICHIESTA, data , dateNext); between is inclusive!
  133.         expr.between(Transazione.model().DATA_INGRESSO_RICHIESTA, DateUtils.incredementDate1MsIf999(data) , dateNext);
  134.         expr.isNotNull(Transazione.model().DATA_INGRESSO_RICHIESTA);
  135.         
  136.         if(TipoPdD.DELEGATA.equals(tipoPdD)){
  137.             expr.equals(Transazione.model().PDD_RUOLO, PddRuolo.DELEGATA);
  138.         }else{
  139.             expr.equals(Transazione.model().PDD_RUOLO, PddRuolo.APPLICATIVA);
  140.         }
  141.         expr.isNotNull(Transazione.model().PDD_RUOLO);
  142.         
  143.         expr.isNotNull(Transazione.model().ESITO_CONTESTO);
  144.         
  145.         if(stat!=null){
  146.             // condizioni di group by messe anche in equals
  147. //          expr.equals(Transazione.model().PDD_CODICE,stat.getIdPorta());
  148. //          expr.equals(Transazione.model().TIPO_SOGGETTO_FRUITORE, stat.getMittente()!=null ? stat.getMittente().getTipo() : null);
  149. //          expr.equals(Transazione.model().NOME_SOGGETTO_FRUITORE, stat.getMittente()!=null ? stat.getMittente().getNome() : null);
  150. //          expr.equals(Transazione.model().TIPO_SOGGETTO_EROGATORE, stat.getDestinatario()!=null ? stat.getDestinatario().getTipo() : null);
  151. //          expr.equals(Transazione.model().NOME_SOGGETTO_EROGATORE, stat.getDestinatario()!=null ? stat.getDestinatario().getNome() : null);
  152. //          expr.equals(Transazione.model().TIPO_SERVIZIO, stat.getTipoServizio());
  153. //          expr.equals(Transazione.model().NOME_SERVIZIO, stat.getServizio());
  154. //          expr.equals(Transazione.model().AZIONE, stat.getAzione());

  156.             // Gestisco i possibili valori null con '-'.
  157.             // Sono state prese le informazioni anche con null poichè senno non venivano contate nelle statistiche le transazioni che non possedevano info sui servizi. (es porta delegata non trovata)
  158.             String pddCodice = stat.getIdPorta();
  159.             StatisticsUtils.setCondition(expr, pddCodice, Transazione.model().PDD_CODICE);
  160.             String tipoMittente = stat.getMittente()!=null ? stat.getMittente().getTipo() : null;
  161.             StatisticsUtils.setCondition(expr, tipoMittente, Transazione.model().TIPO_SOGGETTO_FRUITORE);
  162.             String nomeMittente = stat.getMittente()!=null ? stat.getMittente().getNome() : null;
  163.             StatisticsUtils.setCondition(expr, nomeMittente, Transazione.model().NOME_SOGGETTO_FRUITORE);
  164.             String tipoDestinatario = stat.getDestinatario()!=null ? stat.getDestinatario().getTipo() : null;
  165.             StatisticsUtils.setCondition(expr, tipoDestinatario, Transazione.model().TIPO_SOGGETTO_EROGATORE);
  166.             String nomeDestinatario = stat.getDestinatario()!=null ? stat.getDestinatario().getNome() : null;
  167.             StatisticsUtils.setCondition(expr, nomeDestinatario, Transazione.model().NOME_SOGGETTO_EROGATORE);
  168.             String tipoServizio = stat.getTipoServizio();
  169.             StatisticsUtils.setCondition(expr, tipoServizio, Transazione.model().TIPO_SERVIZIO);
  170.             String nomeServizio = stat.getServizio();
  171.             StatisticsUtils.setCondition(expr, nomeServizio, Transazione.model().NOME_SERVIZIO);
  172.             Integer versioneServizio = stat.getVersioneServizio();
  173.             StatisticsUtils.setCondition(expr, versioneServizio, Transazione.model().VERSIONE_SERVIZIO);
  174.             String azione = stat.getAzione();
  175.             StatisticsUtils.setCondition(expr, azione, Transazione.model().AZIONE);
  176.             
  177.             
  178. //          if(TipoPdD.DELEGATA.equals(tipoPdD)){
  179.             // Nella consultazione delle statistiche si utilizzano sempre gli applicativi fruitori come informazione fornita.
  180.             if(Costanti.SERVIZIO_APPLICATIVO_ANONIMO.equals(stat.getServizioApplicativo()) || stat.getServizioApplicativo()==null || Costanti.INFORMAZIONE_NON_DISPONIBILE.equals(stat.getServizioApplicativo())){
  181.                 expr.isNull(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE);
  182.             }
  183.             else{
  184.                 expr.equals(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE,stat.getServizioApplicativo());
  185.             }
  186. //          }else{
  187. //              if(Costanti.SERVIZIO_APPLICATIVO_ANONIMO.equals(stat.getServizioApplicativo()) || stat.getServizioApplicativo()==null){
  188. //                  expr.isNull(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE);
  189. //              }
  190. //              else{
  191. //                  expr.equals(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE,stat.getServizioApplicativo());
  192. //              }
  193. //          }
  194.             
  195.             String trasportoMittente = stat.getTrasportoMittente();
  196.             StatisticsUtils.setCondition(expr, trasportoMittente, Transazione.model().TRASPORTO_MITTENTE);
  197.             
  198.             String tokenIssuer = stat.getTokenIssuer();
  199.             StatisticsUtils.setCondition(expr, tokenIssuer, Transazione.model().TOKEN_ISSUER);
  200.             String tokenClientId = stat.getTokenClientId();
  201.             StatisticsUtils.setCondition(expr, tokenClientId, Transazione.model().TOKEN_CLIENT_ID);
  202.             String tokenSubject = stat.getTokenSubject();
  203.             StatisticsUtils.setCondition(expr, tokenSubject, Transazione.model().TOKEN_SUBJECT);
  204.             String tokenUsername = stat.getTokenUsername();
  205.             StatisticsUtils.setCondition(expr, tokenUsername, Transazione.model().TOKEN_USERNAME);
  206.             String tokenMail = stat.getTokenMail();
  207.             StatisticsUtils.setCondition(expr, tokenMail, Transazione.model().TOKEN_MAIL);
  208.             
  209.             String clientAddress = stat.getClientAddress();
  210.             StatisticsUtils.setCondition(expr, clientAddress, Transazione.model().CLIENT_ADDRESS);
  211.             
  212.             String gruppo = stat.getGruppo();
  213.             StatisticsUtils.setCondition(expr, gruppo, Transazione.model().GRUPPI);
  214.             
  215.             String uriApi = stat.getApi();
  216.             StatisticsUtils.setCondition(expr, uriApi, Transazione.model().URI_API);
  217.             
  218.             String clusterId = stat.getClusterId();
  219.             StatisticsUtils.setCondition(expr, clusterId, Transazione.model().CLUSTER_ID);
  220.             
  221.             expr.equals(Transazione.model().ESITO, stat.getEsito()!=null ? stat.getEsito() : -1);
  222.             
  223.             String esitoContesto = stat.getEsitoContesto();
  224.             StatisticsUtils.setCondition(expr, esitoContesto, Transazione.model().ESITO_CONTESTO);
  225.         }
  226.         else{
  227.             // Gestisco i possibili valori null con '-'.
  228.             // Sono state prese le informazioni anche con null poichè senno non venivano contate nelle statistiche le transazioni che non possedevano info sui servizi. (es porta delegata non trovata)
  229. //          expr.isNotNull(Transazione.model().PDD_CODICE);
  230. //          expr.isNotNull(Transazione.model().TIPO_SOGGETTO_FRUITORE);
  231. //          expr.isNotNull(Transazione.model().NOME_SOGGETTO_FRUITORE);
  232. //          expr.isNotNull(Transazione.model().TIPO_SOGGETTO_EROGATORE);
  233. //          expr.isNotNull(Transazione.model().NOME_SOGGETTO_EROGATORE);
  234. //          expr.isNotNull(Transazione.model().TIPO_SERVIZIO);
  235. //          expr.isNotNull(Transazione.model().NOME_SERVIZIO);
  236. //          expr.isNotNull(Transazione.model().VERSIONE_SERVIZIO);
  237.         }
  238.         
  239.         if(setNotNullDate){
  240.             expr.isNotNull(Transazione.model().DATA_USCITA_RICHIESTA);
  241.             expr.isNotNull(Transazione.model().DATA_INGRESSO_RISPOSTA);
  242.             expr.isNotNull(Transazione.model().DATA_USCITA_RISPOSTA);
  243.         }
  244.         else if(setNullDate) {
  245.             IExpression exprNullDate = transazioneSearchDAO.newExpression();
  246.             exprNullDate.isNotNull(Transazione.model().DATA_USCITA_RICHIESTA);
  247.             exprNullDate.isNotNull(Transazione.model().DATA_INGRESSO_RISPOSTA);
  248.             exprNullDate.isNotNull(Transazione.model().DATA_USCITA_RISPOSTA);
  249.             exprNullDate.and();
  250.             expr.not(exprNullDate);
  251.         }

  253.         if(idRisorsa!=null){
  254.             expr.equals(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME,idRisorsa);
  255.         }
  256.         if(risorseFiltri!=null && risorseFiltri.length>0){
  257.             for (int i = 0; i < risorseFiltri.length; i++) {
  258.                 AliasFilter af = new AliasFilter();
  259.                 IAliasTableField atf = new AliasTableComplexField((ComplexField)Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME, FilterUtils.getNextAliasStatisticsTable());
  260.                 //System.out.println("FILTRO["+i+"]= ("+af.getAliasTable()+") "+risorseFiltri[i]);
  261.                 af.setNomeFiltro(atf);
  262.                 af.setStatisticFilterName(risorseFiltri[i].getStatisticFilterName());
  263.                 aliases.add(af);
  264.                 expr.equals(atf,risorseFiltri[i].getResourceID());  
  265.             }
  266.         }
  267.         
  268.         // ** GROUP BY **
  269.         expr.addGroupBy(Transazione.model().PDD_RUOLO);
  270.         expr.addGroupBy(Transazione.model().PDD_CODICE);
  271.         expr.addGroupBy(Transazione.model().TIPO_SOGGETTO_FRUITORE);
  272.         expr.addGroupBy(Transazione.model().NOME_SOGGETTO_FRUITORE);
  273.         expr.addGroupBy(Transazione.model().TIPO_SOGGETTO_EROGATORE);
  274.         expr.addGroupBy(Transazione.model().NOME_SOGGETTO_EROGATORE);
  275.         expr.addGroupBy(Transazione.model().TIPO_SERVIZIO);
  276.         expr.addGroupBy(Transazione.model().NOME_SERVIZIO);
  277.         expr.addGroupBy(Transazione.model().VERSIONE_SERVIZIO);
  278.         expr.addGroupBy(Transazione.model().AZIONE);
  279.         // Nella consultazione delle statistiche si utilizzano sempre gli applicativi fruitori come informazione fornita.
  280. //      if(TipoPdD.DELEGATA.equals(tipoPdD)){
  281.         expr.addGroupBy(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE);
  282. //      }else{
  283. //          expr.addGroupBy(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE);
  284. //      }
  285.         expr.addGroupBy(Transazione.model().TRASPORTO_MITTENTE);
  286.         expr.addGroupBy(Transazione.model().TOKEN_ISSUER);
  287.         expr.addGroupBy(Transazione.model().TOKEN_CLIENT_ID);
  288.         expr.addGroupBy(Transazione.model().TOKEN_SUBJECT);
  289.         expr.addGroupBy(Transazione.model().TOKEN_USERNAME);
  290.         expr.addGroupBy(Transazione.model().TOKEN_MAIL);
  291.         expr.addGroupBy(Transazione.model().CLIENT_ADDRESS);
  292.         expr.addGroupBy(Transazione.model().GRUPPI);
  293.         expr.addGroupBy(Transazione.model().URI_API);
  294.         expr.addGroupBy(Transazione.model().CLUSTER_ID);
  295.         expr.addGroupBy(Transazione.model().ESITO);
  296.         expr.addGroupBy(Transazione.model().ESITO_CONTESTO);
  297.         if(groupByStato){
  298.             expr.addGroupBy(Transazione.model().STATO);
  299.         }
  300.         if(idRisorsa!=null){
  301.             expr.addGroupBy(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME);
  302.             expr.addGroupBy(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE);
  303.         }
  304.         if(aliases!=null && aliases.size()>0){
  305.             for (AliasFilter aliasFilter : aliases) {
  306.                 IAliasTableField afName = aliasFilter.getNomeFiltro(); 
  307.                 expr.addGroupBy(afName);
  308.                 
  309.                 String tableAlias = afName.getAliasTable();
  310.                 IAliasTableField afValue = new AliasTableComplexField((ComplexField)Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE, tableAlias);
  311.                 aliasFilter.setValoreFiltro(afValue);
  312.                 
  313.                 expr.addGroupBy(afValue);
  314.             }
  315.         }
  316.     }
  317.     
  318.     private static void setCondition(IExpression expr, String value,IField field) throws ExpressionNotImplementedException, ExpressionException{
  319.         if(value==null || "".equals(value) || Costanti.INFORMAZIONE_NON_DISPONIBILE.equals(value)){
  320.             expr.isNull(field);
  321.         }
  322.         else{
  323.             expr.equals(field,value);
  324.         }
  325.     }
  326.     
  327.     private static void setCondition(IExpression expr, Integer value,IField field) throws ExpressionNotImplementedException, ExpressionException{
  328.         if(value==null || value.intValue() == Costanti.INFORMAZIONE_VERSIONE_NON_DISPONIBILE.intValue()){
  329.             expr.equals(field,Costanti.INFORMAZIONE_VERSIONE_NON_DISPONIBILE);
  330.         }
  331.         else{
  332.             expr.equals(field,value);
  333.         }
  334.     }
  335.     
  336.     public static void addSelectUnionField(UnionExpression expr, ISQLFieldConverter fieldConverter) throws Exception {
  337.             addSelectUnionField(expr, fieldConverter,
  338.                     false,
  339.                     null, null);
  340.     }
  341.     public static void addSelectUnionField(UnionExpression expr, ISQLFieldConverter fieldConverter,
  342.             boolean groupByStato,
  343.             List<AliasFilter> aliases, String idRisorsa) throws Exception {
  344.         expr.addSelectField(Transazione.model().PDD_RUOLO, fieldConverter.toColumn(Transazione.model().PDD_RUOLO, false));
  345.         expr.addSelectField(Transazione.model().PDD_CODICE, fieldConverter.toColumn(Transazione.model().PDD_CODICE, false));
  346.         expr.addSelectField(Transazione.model().TIPO_SOGGETTO_FRUITORE, fieldConverter.toColumn(Transazione.model().TIPO_SOGGETTO_FRUITORE, false));
  347.         expr.addSelectField(Transazione.model().NOME_SOGGETTO_FRUITORE, fieldConverter.toColumn(Transazione.model().NOME_SOGGETTO_FRUITORE, false));
  348.         expr.addSelectField(Transazione.model().TIPO_SOGGETTO_EROGATORE, fieldConverter.toColumn(Transazione.model().TIPO_SOGGETTO_EROGATORE, false));
  349.         expr.addSelectField(Transazione.model().NOME_SOGGETTO_EROGATORE, fieldConverter.toColumn(Transazione.model().NOME_SOGGETTO_EROGATORE, false));
  350.         expr.addSelectField(Transazione.model().TIPO_SERVIZIO, fieldConverter.toColumn(Transazione.model().TIPO_SERVIZIO, false));
  351.         expr.addSelectField(Transazione.model().NOME_SERVIZIO, fieldConverter.toColumn(Transazione.model().NOME_SERVIZIO, false));
  352.         expr.addSelectField(Transazione.model().VERSIONE_SERVIZIO, fieldConverter.toColumn(Transazione.model().VERSIONE_SERVIZIO, false));
  353.         expr.addSelectField(Transazione.model().AZIONE, fieldConverter.toColumn(Transazione.model().AZIONE, false));
  354.         // Nella consultazione delle statistiche si utilizzano sempre gli applicativi fruitori come informazione fornita.
  355. //      if(TipoPdD.DELEGATA.equals(tipoPdD)){
  356.         expr.addSelectField(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE, fieldConverter.toColumn(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE, false));
  357. //      }else{
  358. //          expr.addSelectField(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE, fieldConverter.toColumn(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE, false));
  359. //      }
  360.         expr.addSelectField(Transazione.model().TRASPORTO_MITTENTE, fieldConverter.toColumn(Transazione.model().TRASPORTO_MITTENTE, false));
  361.         expr.addSelectField(Transazione.model().TOKEN_ISSUER, fieldConverter.toColumn(Transazione.model().TOKEN_ISSUER, false));
  362.         expr.addSelectField(Transazione.model().TOKEN_CLIENT_ID, fieldConverter.toColumn(Transazione.model().TOKEN_CLIENT_ID, false));
  363.         expr.addSelectField(Transazione.model().TOKEN_SUBJECT, fieldConverter.toColumn(Transazione.model().TOKEN_SUBJECT, false));
  364.         expr.addSelectField(Transazione.model().TOKEN_USERNAME, fieldConverter.toColumn(Transazione.model().TOKEN_USERNAME, false));
  365.         expr.addSelectField(Transazione.model().TOKEN_MAIL, fieldConverter.toColumn(Transazione.model().TOKEN_MAIL, false));
  366.         expr.addSelectField(Transazione.model().CLIENT_ADDRESS, fieldConverter.toColumn(Transazione.model().CLIENT_ADDRESS, false));
  367.         expr.addSelectField(Transazione.model().GRUPPI, fieldConverter.toColumn(Transazione.model().GRUPPI, false));
  368.         expr.addSelectField(Transazione.model().URI_API, fieldConverter.toColumn(Transazione.model().URI_API, false));
  369.         expr.addSelectField(Transazione.model().CLUSTER_ID, fieldConverter.toColumn(Transazione.model().CLUSTER_ID, false));
  370.         expr.addSelectField(Transazione.model().ESITO, fieldConverter.toColumn(Transazione.model().ESITO, false));
  371.         expr.addSelectField(Transazione.model().ESITO_CONTESTO, fieldConverter.toColumn(Transazione.model().ESITO_CONTESTO, false));
  372.         if(groupByStato){
  373.             expr.addSelectField(Transazione.model().STATO, fieldConverter.toColumn(Transazione.model().STATO, false));
  374.         }
  375.         if(idRisorsa!=null){
  376.             expr.addSelectField(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME, fieldConverter.toColumn(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME, false));
  377.             expr.addSelectField(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE, fieldConverter.toColumn(Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE, false));
  378.         }
  379.         if(aliases!=null && aliases.size()>0){
  380.             for (AliasFilter aliasFilter : aliases) {
  381.                 IAliasTableField afName = aliasFilter.getNomeFiltro(); 
  382.                 expr.addSelectField(afName, afName.getFieldName());
  383.                 
  384.                 String tableAlias = afName.getAliasTable();
  385.                 IAliasTableField afValue = new AliasTableComplexField((ComplexField)Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE, tableAlias);
  386.                 aliasFilter.setValoreFiltro(afValue);
  387.                 
  388.                 expr.addSelectField(afValue, afValue.getFieldName());
  389.             }
  390.         }
  391.     }
  392.     
  393.     public static void addSelectFieldCountTransaction(List<FunctionField> selectList) throws ExpressionException{
  394.         
  395.         // Numero Transazioni
  396.         FunctionField fCount = new FunctionField(
  397.                 //Transazione.model().ID_TRANSAZIONE,
  398.                 Transazione.model().DATA_INGRESSO_RICHIESTA, // piu' efficiente
  399.                 //Function.COUNT_DISTINCT,
  400.                 Function.COUNT,
  401.                 "richieste");
  402.         selectList.add(fCount);
  403.         
  404.     }
  405.     
  406.     public static void addSelectFieldSizeTransaction(TipoPdD tipoPdD,List<FunctionField> selectList) throws ExpressionException{
  407.         
  408.         // Dimensione Transazioni
  409.         FunctionField fSum1 = null, fSum2= null, fSum3= null, fSum4= null;
  410.         
  411.         fSum1 = new FunctionField(Transazione.model().RICHIESTA_INGRESSO_BYTES, Function.SUM, "message_bytes_in_richiesta");
  412.         fSum2 = new FunctionField(Transazione.model().RICHIESTA_USCITA_BYTES, Function.SUM, "message_bytes_out_richiesta");
  413.         fSum3 = new FunctionField(Transazione.model().RISPOSTA_INGRESSO_BYTES, Function.SUM, "message_bytes_in_risposta");
  414.         fSum4 = new FunctionField(Transazione.model().RISPOSTA_USCITA_BYTES, Function.SUM, "message_bytes_out_risposta");

  416.         selectList.add(fSum1);
  417.         selectList.add(fSum2);
  418.         selectList.add(fSum3);
  419.         selectList.add(fSum4);
  420.     }
  421.     
  422.     public static void addSelectFunctionFieldLatencyTransaction(TipoPdD tipoPdD,ISQLFieldConverter fieldConverter, 
  423.             List<FunctionField> selectFunctionList) throws ExpressionException, SQLQueryObjectException{
  424.         _addSelectFieldLatencyTransaction(tipoPdD, fieldConverter, selectFunctionList, null);
  425.     }
  426.     public static void addSelectConstantFieldLatencyTransaction(TipoPdD tipoPdD,ISQLFieldConverter fieldConverter, 
  427.             List<ConstantField> selectConstantList) throws ExpressionException, SQLQueryObjectException{
  428.         _addSelectFieldLatencyTransaction(tipoPdD, fieldConverter, null, selectConstantList);
  429.     }
  430.     private static void _addSelectFieldLatencyTransaction(TipoPdD tipoPdD,ISQLFieldConverter fieldConverter, 
  431.             List<FunctionField> selectFunctionList,
  432.             List<ConstantField> selectConstantList) throws ExpressionException, SQLQueryObjectException{
  433.         
  434.         if(selectFunctionList!=null) {
  435.         
  436.             // Latenza Totale
  437.             UnixTimestampIntervalField latenzaTotale = new UnixTimestampIntervalField("unix_latenza_totale", fieldConverter, true, 
  438.                     Transazione.model().DATA_USCITA_RISPOSTA, Transazione.model().DATA_INGRESSO_RICHIESTA);
  439.             FunctionField fLatenzaTotaleAvg = new FunctionField(latenzaTotale, Function.AVG, "latenza_totale");
  440.             selectFunctionList.add(fLatenzaTotaleAvg);
  441.             
  442.             // Latenza Servizio
  443.             UnixTimestampIntervalField latenzaServizio = new UnixTimestampIntervalField("unix_latenza_servizio", fieldConverter, true, 
  444.                     Transazione.model().DATA_INGRESSO_RISPOSTA, Transazione.model().DATA_USCITA_RICHIESTA);
  445.             FunctionField fLatenzaServizioAvg = new FunctionField(latenzaServizio, Function.AVG, "latenza_servizio");
  446.             selectFunctionList.add(fLatenzaServizioAvg);
  447.             
  448.             // Latenza Gateway Richiesta
  449.             UnixTimestampIntervalField latenzaPortaRichiesta = new UnixTimestampIntervalField("unix_latenza_richiesta", fieldConverter, true, 
  450.                     Transazione.model().DATA_USCITA_RICHIESTA, Transazione.model().DATA_INGRESSO_RICHIESTA);
  451.             FunctionField fLatenzaPortaRichiestaAvg = new FunctionField(latenzaPortaRichiesta, Function.AVG, "latenza_porta_richiesta");
  452.             selectFunctionList.add(fLatenzaPortaRichiestaAvg);
  453.             
  454.             // Latenza Gateway Risposta
  455.             UnixTimestampIntervalField latenzaPortaRisposta = new UnixTimestampIntervalField("unix_latenza_risposta", fieldConverter, true, 
  456.                     Transazione.model().DATA_USCITA_RISPOSTA, Transazione.model().DATA_INGRESSO_RISPOSTA);
  457.             FunctionField fLatenzaPortaRispostaAvg = new FunctionField(latenzaPortaRisposta, Function.AVG, "latenza_porta_risposta");
  458.             selectFunctionList.add(fLatenzaPortaRispostaAvg);
  459.             
  460.         }
  461.         else {
  462.             
  463.             // Latenza Totale
  464.             ConstantField latenzaTotale = new ConstantField("latenza_totale", Costanti.INFORMAZIONE_LATENZA_NON_DISPONIBILE, Long.class);
  465.             selectConstantList.add(latenzaTotale);
  466.             
  467.             // Latenza Servizio
  468.             ConstantField latenzaServizio = new ConstantField("latenza_servizio", Costanti.INFORMAZIONE_LATENZA_NON_DISPONIBILE, Long.class);
  469.             selectConstantList.add(latenzaServizio);
  470.             
  471.             // Latenza Gateway Richiesta
  472.             ConstantField latenzaPortaRichiesta = new ConstantField("latenza_porta_richiesta", Costanti.INFORMAZIONE_LATENZA_NON_DISPONIBILE, Long.class);
  473.             selectConstantList.add(latenzaPortaRichiesta);
  474.             
  475.             // Latenza Gateway Risposta
  476.             ConstantField latenzaPortaRisposta = new ConstantField("latenza_porta_risposta", Costanti.INFORMAZIONE_LATENZA_NON_DISPONIBILE, Long.class);
  477.             selectConstantList.add(latenzaPortaRisposta);
  478.         }
  479.         
  480.     }
  481.     
  482.     public static StatisticBean readStatisticBean(StatisticBean stat,Map<String, Object> row, ISQLFieldConverter fieldConverter, boolean useFieldConverter) throws ExpressionException{
  483.         
  484.         stat.setIdPorta(StatisticsUtils.getValueFromMap(Transazione.model().PDD_CODICE,row,fieldConverter,useFieldConverter));
  485.         String TipoPortaS = StatisticsUtils.getValueFromMap(Transazione.model().PDD_RUOLO,row,fieldConverter,useFieldConverter);
  486.         TipoPdD tipo = TipoPdD.toTipoPdD(TipoPortaS);
  487.         stat.setTipoPorta(tipo);
  488.         
  489.         /*
  490.         String sa= null;
  491.         Object saObject = null;
  492.         // Nella consultazione delle statistiche si utilizzano sempre gli applicativi fruitori come informazione fornita.
  493. //      if(tipo.equals(TipoPdD.DELEGATA)){
  494.         saObject = row.get(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE.getFieldName());
  495. //      }else{
  496. //          saObject = row.get(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldName());
  497. //      }
  498.         if(saObject!=null){
  499.             if(saObject instanceof org.apache.commons.lang.ObjectUtils.Null){
  500.                 sa = null;
  501.             }
  502.             else{
  503.                 sa = (String) saObject;
  504.             }
  505.         }
  506.         stat.setServizioApplicativo(sa != null ? sa : Costanti.SERVIZIO_APPLICATIVO_ANONIMO);
  507.         */
  508.         // Registrare nelle statistiche il valore 'Anonimo' porta ad avere informazioni non corrette nella distribuzione per applicativo sulle erogazioni.
  509.         // L'errore avviene poichè è richiesto il group by sul nomeApplicativo, tipoSoggettoProprietario, nomeSoggettoProprietario
  510.         // poichè un applicativo viene identificato univocamente se si considera sia il nome dell'applicativo che il soggetto proprietario.
  511.         // Il group by sulle fruizioni, se si usa l'informazione anonima, non porta problemi perchè l'entry anonima sarà 1 sempre, essendo il soggetto fruitore uno solo (Soggetto locale impostato).
  512.         // Il group by sulle erogazioni produrrà invece più entry anonime se si hanno più soggetto che la invocano senza un applicativo specifico.
  513.         stat.setServizioApplicativo(StatisticsUtils.getValueFromMap(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE,row,fieldConverter,useFieldConverter));
  514.                         
  515.         stat.setTrasportoMittente(StatisticsUtils.getValueFromMap(Transazione.model().TRASPORTO_MITTENTE,row,fieldConverter,useFieldConverter));
  516.         
  517.         stat.setTokenIssuer(StatisticsUtils.getValueFromMap(Transazione.model().TOKEN_ISSUER,row,fieldConverter,useFieldConverter));
  518.         stat.setTokenClientId(StatisticsUtils.getValueFromMap(Transazione.model().TOKEN_CLIENT_ID,row,fieldConverter,useFieldConverter));
  519.         stat.setTokenSubject(StatisticsUtils.getValueFromMap(Transazione.model().TOKEN_SUBJECT,row,fieldConverter,useFieldConverter));
  520.         stat.setTokenUsername(StatisticsUtils.getValueFromMap(Transazione.model().TOKEN_USERNAME,row,fieldConverter,useFieldConverter));
  521.         stat.setTokenMail(StatisticsUtils.getValueFromMap(Transazione.model().TOKEN_MAIL,row,fieldConverter,useFieldConverter));
  522.         
  523.         stat.setClientAddress(StatisticsUtils.getValueFromMap(Transazione.model().CLIENT_ADDRESS,row,fieldConverter,useFieldConverter));
  524.         
  525.         stat.setGruppo(StatisticsUtils.getValueFromMap(Transazione.model().GRUPPI,row,fieldConverter,useFieldConverter));
  526.         
  527.         stat.setApi(StatisticsUtils.getValueFromMap(Transazione.model().URI_API,row,fieldConverter,useFieldConverter));
  528.         
  529.         stat.setClusterId(StatisticsUtils.getValueFromMap(Transazione.model().CLUSTER_ID,row,fieldConverter,useFieldConverter));
  530.         
  531. //      stat.setMittente(new IDSoggetto((String)row.get(Transazione.model().TIPO_SOGGETTO_FRUITORE.getFieldName()), (String)row.get(Transazione.model().NOME_SOGGETTO_FRUITORE .getFieldName())));
  532. //      stat.setDestinatario(new IDSoggetto((String)row.get(Transazione.model().TIPO_SOGGETTO_EROGATORE.getFieldName()),(String)row.get(Transazione.model().NOME_SOGGETTO_EROGATORE.getFieldName())));
  533. //      stat.setTipoServizio((String)row.get(Transazione.model().TIPO_SERVIZIO.getFieldName()));
  534. //      stat.setServizio((String)row.get(Transazione.model().NOME_SERVIZIO.getFieldName()));
  535. //      Object azObject = row.get(Transazione.model().AZIONE.getFieldName());
  536. //      String az = null;
  537. //      if(azObject!=null && !(azObject instanceof org.apache.commons.lang.ObjectUtils.Null)){ 
  538. //          az = (String) azObject;
  539. //      }
  540. //      stat.setAzione(az != null ? az : " ");
  541.         
  542.         // Gestisco i possibili valori null con '-'.
  543.         // Sono state prese le informazioni anche con null poichè senno non venivano contate nelle statistiche le transazioni che non possedevano info sui servizi. (es porta delegata non trovata)
  544.         stat.setMittente(new IDSoggetto(StatisticsUtils.getValueFromMap(Transazione.model().TIPO_SOGGETTO_FRUITORE,row,fieldConverter,useFieldConverter), 
  545.                                         StatisticsUtils.getValueFromMap(Transazione.model().NOME_SOGGETTO_FRUITORE,row,fieldConverter,useFieldConverter)));
  546.         
  547.         stat.setDestinatario(new IDSoggetto(StatisticsUtils.getValueFromMap(Transazione.model().TIPO_SOGGETTO_EROGATORE,row,fieldConverter,useFieldConverter), 
  548.                                             StatisticsUtils.getValueFromMap(Transazione.model().NOME_SOGGETTO_EROGATORE,row,fieldConverter,useFieldConverter)));
  549.         
  550.         stat.setTipoServizio(StatisticsUtils.getValueFromMap(Transazione.model().TIPO_SERVIZIO,row,fieldConverter,useFieldConverter));
  551.         stat.setServizio(StatisticsUtils.getValueFromMap(Transazione.model().NOME_SERVIZIO,row,fieldConverter,useFieldConverter));
  552.         stat.setVersioneServizio(StatisticsUtils.getIntegerValueFromMap(Transazione.model().VERSIONE_SERVIZIO,row,false,fieldConverter,useFieldConverter));
  553.         
  554.         stat.setAzione(StatisticsUtils.getValueFromMap(Transazione.model().AZIONE,row,fieldConverter,useFieldConverter));
  555.         
  556.         stat.setEsito(StatisticsUtils.getIntegerValueFromMap(Transazione.model().ESITO,row,true,fieldConverter,useFieldConverter));
  557.         
  558.         stat.setEsitoContesto(StatisticsUtils.getValueFromMap(Transazione.model().ESITO_CONTESTO,row,fieldConverter,useFieldConverter));
  559.         
  560.         return stat;
  561.     }
  562.     private static String getValueFromMap(IField field, Map<String, Object> row, ISQLFieldConverter fieldConverter, boolean useFieldConverter) throws ExpressionException{
  563.         String nomeKeyMappa = null;
  564.         if(useFieldConverter) {
  565.             nomeKeyMappa = fieldConverter.toColumn(field, false);
  566.         }
  567.         else {
  568.             nomeKeyMappa = field.getFieldName();
  569.         }
  570.         Object tmpObject = row.get(nomeKeyMappa);
  571.         String tmp = null;
  572.         if(tmpObject!=null && !(tmpObject instanceof org.apache.commons.lang.ObjectUtils.Null)){ 
  573.             tmp = (String) tmpObject;
  574.         }
  575.         if(tmp!=null && !"".equals(tmp)){
  576.             return tmp;
  577.         }
  578.         else{
  579.             return Costanti.INFORMAZIONE_NON_DISPONIBILE;
  580.         }
  581.     }
  582.     private static Integer getIntegerValueFromMap(IField field, Map<String, Object> row, boolean acceptZeroValue, ISQLFieldConverter fieldConverter, boolean useFieldConverter) throws ExpressionException{
  583.         String nomeKeyMappa = null;
  584.         if(useFieldConverter) {
  585.             nomeKeyMappa = fieldConverter.toColumn(field, false);
  586.         }
  587.         else {
  588.             nomeKeyMappa = field.getFieldName();
  589.         }
  590.         Object tmpObject = row.get(nomeKeyMappa);
  591.         Integer tmp = null;
  592.         if(tmpObject!=null && !(tmpObject instanceof org.apache.commons.lang.ObjectUtils.Null)){ 
  593.             tmp = (Integer) tmpObject;
  594.         }
  595.         if(tmp!=null && tmp.intValue()>0){
  596.             return tmp;
  597.         }
  598.         else if(tmp!=null && tmp.intValue()==0 && acceptZeroValue) {
  599.             return tmp;
  600.         }
  601.         else{
  602.             return Costanti.INFORMAZIONE_VERSIONE_NON_DISPONIBILE;
  603.         }
  604.     }
  605.     
  606.     public static void updateStatisticBeanCountTransactionInfo(StatisticBean stat,Map<String, Object> row){
  607.         
  608.         Long tmp = StatisticsUtils.readLongValue(row, "richieste");
  609.         if(tmp!=null){
  610.             stat.setRichieste(tmp);
  611.         }

  613.     }
  614.     
  615.     public static void updateStatisticBeanSizeTransactionInfo(StatisticBean stat,Map<String, Object> row){
  616.                 
  617.         long messageBytesInRequest = 0;
  618.         Long tmp = StatisticsUtils.readLongValue(row, "message_bytes_in_richiesta");
  619.         if(tmp!=null){
  620.             messageBytesInRequest = tmp.longValue();
  621.         }
  622.         long messageBytesOutRequest = 0;
  623.         tmp = StatisticsUtils.readLongValue(row, "message_bytes_out_richiesta");
  624.         if(tmp!=null){
  625.             messageBytesOutRequest = tmp.longValue();
  626.         }
  627.         long messageBytesInResponse = 0;
  628.         tmp = StatisticsUtils.readLongValue(row, "message_bytes_in_risposta");
  629.         if(tmp!=null){
  630.             messageBytesInResponse = tmp.longValue();
  631.         }
  632.         long messageBytesOutResponse = 0;
  633.         tmp = StatisticsUtils.readLongValue(row, "message_bytes_out_risposta");
  634.         if(tmp!=null){
  635.             messageBytesOutResponse = tmp.longValue();
  636.         }
  637.         
  638.         switch (stat.getTipoPorta()) {
  639.         case DELEGATA:
  640.             stat.setBytesBandaInterna(messageBytesInRequest+messageBytesOutResponse);
  641.             stat.setBytesBandaEsterna(messageBytesOutRequest+messageBytesInResponse);
  642.             break;
  643.         default:
  644.             stat.setBytesBandaInterna(messageBytesOutRequest+messageBytesInResponse);
  645.             stat.setBytesBandaEsterna(messageBytesInRequest+messageBytesOutResponse);
  646.             break;
  647.         }
  648.         stat.setBytesBandaTotale(stat.getBytesBandaInterna()+stat.getBytesBandaEsterna());
  649.         
  650.     }
  651.     
  652.     public static void updateStatisticsBeanLatencyTransactionInfo(StatisticBean stat,Map<String, Object> row){
  653.         // Latenza Totale
  654.         long latenzaTotaleValue = -1;
  655.         Long tmp = StatisticsUtils.readLongValue(row, "latenza_totale");
  656.         if(tmp!=null){
  657.             latenzaTotaleValue = tmp.longValue();
  658.         }
  659.         stat.setLatenzaTotale(latenzaTotaleValue);
  660.         
  661.         // Latenza Servizio
  662.         long latenzaServizioValue = -1;
  663.         tmp = StatisticsUtils.readLongValue(row, "latenza_servizio");
  664.         if(tmp!=null){
  665.             latenzaServizioValue = tmp.longValue();
  666.         }
  667.         stat.setLatenzaServizio(latenzaServizioValue);
  668.         
  669.         // Latenza Gateway
  670.         long latenzaPortaRichiestaValue = -1;
  671.         tmp = StatisticsUtils.readLongValue(row, "latenza_porta_richiesta");
  672.         if(tmp!=null){
  673.             latenzaPortaRichiestaValue = tmp.longValue();
  674.         }
  675.         long latenzaPortaRispostaValue = -1;
  676.         tmp = StatisticsUtils.readLongValue(row, "latenza_porta_risposta");
  677.         if(tmp!=null){
  678.             latenzaPortaRispostaValue = tmp.longValue();
  679.         }
  680.         long latenzaPortaValue = -1;
  681.         if(latenzaPortaRichiestaValue>=0){
  682.             latenzaPortaValue = latenzaPortaRichiestaValue;
  683.             if(latenzaPortaRispostaValue>=0){
  684.                 latenzaPortaValue = latenzaPortaValue + latenzaPortaRispostaValue;
  685.             }
  686.         }
  687.         else{
  688.             if(latenzaPortaRispostaValue>=0){
  689.                 latenzaPortaValue = latenzaPortaRispostaValue;
  690.             }
  691.         }
  692.         stat.setLatenzaPorta(latenzaPortaValue);
  693.     }
  694.     
  695.     public static void fillStatisticsContenutiByStato(String idStatisticaPersonalizzata,StatisticaContenuti statisticaContenuti,Map<String, Object> row) throws EngineException{
  696.         String aliasValore = Transazione.model().STATO.getFieldName();
  697.         Object oValore = row.get(aliasValore);
  698.         String valore = null;
  699.         if(oValore!=null && oValore instanceof String){
  700.             String s = (String) oValore;
  701.             if(!"".equals(s)){
  702.                 valore = s;
  703.             }
  704.             else{
  705.                 valore = org.openspcoop2.monitor.engine.constants.Costanti.TRANSAZIONE_SENZA_STATO;
  706.             }
  707.         }else{
  708.             valore = org.openspcoop2.monitor.engine.constants.Costanti.TRANSAZIONE_SENZA_STATO;
  709.         }
  710.         StatisticsUtils.setRisorsaValore(statisticaContenuti, idStatisticaPersonalizzata, valore);
  711.     }
  712.     
  713.     public static void fillStatisticsContenuti(String idStatisticaPersonalizzata,StatisticaContenuti statisticaContenuti,Map<String, Object> row,
  714.             List<AliasFilter> aliases,RisorsaSemplice risorsaSemplice) throws EngineException{
  715.         
  716.         String risorsaNome = null;
  717.         if(risorsaSemplice.getIdStatistica()!=null){
  718.             risorsaNome = idStatisticaPersonalizzata+"-"+risorsaSemplice.getIdStatistica();
  719.         }
  720.         else{
  721.             risorsaNome = idStatisticaPersonalizzata;
  722.         }
  723.         
  724.         String aliasValore = Transazione.model().DUMP_MESSAGGIO.getBaseField().getFieldName()+"."+
  725.                 Transazione.model().DUMP_MESSAGGIO.CONTENUTO.getBaseField().getFieldName()+"."+
  726.                 Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE.getFieldName();
  727.         
  728.         StatisticsUtils.setRisorsaValore(statisticaContenuti, risorsaNome, (String)row.get(aliasValore));
  729.         
  730.         
  731. //      java.util.Iterator<String> itS = row.keySet().iterator();
  732. //      while (itS.hasNext()) {
  733. //          String key = (String) itS.next();
  734. //          System.out.println("ESEMPIO KEY["+key+"]");
  735. //      }
  736.         
  737.         if(aliases.size()>0){
  738.             for (int i = 0; i < aliases.size(); i++) {
  739.                 AliasFilter af = aliases.get(i);
  740.                 IAliasTableField afName = af.getNomeFiltro();
  741.                 IAliasTableField afValore = af.getValoreFiltro();
  742.                 
  743.                 String aliasFiltroNome = afName.getAliasTable()+"."+
  744.                         Transazione.model().DUMP_MESSAGGIO.CONTENUTO.NOME.getFieldName();
  745.                 String aliasFiltroValore = afValore.getAliasTable()+"."+
  746.                         Transazione.model().DUMP_MESSAGGIO.CONTENUTO.VALORE.getFieldName();
  747.                 
  748.                 StatisticsUtils.setFiltro(statisticaContenuti, 
  749.                         af.getStatisticFilterName(), 
  750.                         (String)row.get(aliasFiltroNome), 
  751.                         (String)row.get(aliasFiltroValore));
  752.                 
  753.             }
  754.         }
  755.         
  756.     }
  757.     
  758.     public static void fillStatisticsContenuti(String idStatistica,StatisticaContenuti statisticaContenuti,RisorsaAggregata risorsaAggregata) throws EngineException{
  759.         
  760.         StatisticsUtils.setRisorsaValore(statisticaContenuti, idStatistica, risorsaAggregata.getValoreRisorsaAggregata());
  761.         if(risorsaAggregata.getFiltri()!=null && risorsaAggregata.getFiltri().size()>0){
  762.             for (int i = 0; i < risorsaAggregata.getFiltri().size(); i++) {
  763.                 String nome = risorsaAggregata.getFiltri().get(i).getResourceID();
  764.                 String valore = ContentFormatter.toString(risorsaAggregata.getFiltri().get(i).getValue());
  765.                 
  766.                 StatisticsUtils.setFiltro(statisticaContenuti, 
  767.                         risorsaAggregata.getFiltri().get(i).getStatisticFilterName(), 
  768.                         nome, 
  769.                         valore);
  770.                 
  771.             }
  772.         }
  773.     }
  774.     
  775.     private static void setRisorsaValore(StatisticaContenuti statisticaContenuti,String risorsaNome,String valore) throws EngineException{
  776.         if(valore.length()>TransactionContentUtils.SOGLIA_VALUE_TOO_LONG){
  777.             throw new EngineException("Valore fornito per il contenuto statistico ["+risorsaNome
  778.                     +"] è troppo grande (>"+TransactionContentUtils.SOGLIA_VALUE_TOO_LONG+") per essere utilizzato come informazione statistica. Valore fornito: "+valore);
  779.         }
  780.         if(TransactionContentUtils.KEY_COMPRESSED.equals(valore)){
  781.             throw new EngineException("Una risorsa compressa è stata fornita per il contenuto statistico ["+risorsaNome
  782.                     +"]; questo tipo di risorsa non è utilizzabile come informazione statistica");
  783.         }
  784.         if(TransactionContentUtils.KEY_VALUE_TOO_LONG.equals(valore)){
  785.             throw new EngineException("Una risorsa con valore > "+TransactionContentUtils.SOGLIA_VALUE_TOO_LONG+
  786.                     " caratteri è stata fornita per il contenuto statistico ["+risorsaNome
  787.                     +"]; questo tipo di risorsa non è utilizzabile come informazione statistica");
  788.         }
  789.         statisticaContenuti.setRisorsaNome(risorsaNome);
  790.         statisticaContenuti.setRisorsaValore(valore);
  791.     }
  792.     
  793.     private static void setFiltro(StatisticaContenuti statisticaContenuti,StatisticFilterName filterName,
  794.             String nome,String valore) throws EngineException{
  795.         
  796.         if(nome.length()>255){
  797.             throw new EngineException("Nome assegnato a "+filterName.name()+" ("+nome
  798.                     +") è troppo grande (>255)");
  799.         }
  800.         if(valore.length()>TransactionContentUtils.SOGLIA_VALUE_TOO_LONG){
  801.             throw new EngineException("Valore fornito per "+filterName.name()+" ["+nome
  802.                     +"] è troppo grande (>"+TransactionContentUtils.SOGLIA_VALUE_TOO_LONG+") per essere utilizzato come filtro. Valore fornito: "+valore);
  803.         }
  804.         if(TransactionContentUtils.KEY_COMPRESSED.equals(valore)){
  805.             throw new EngineException("Una risorsa compressa è stata fornita per "+filterName.name()+" ["+nome
  806.                     +"]; questo tipo di risorsa non è utilizzabile come valore per un filtro");
  807.         }
  808.         if(TransactionContentUtils.KEY_VALUE_TOO_LONG.equals(valore)){
  809.             throw new EngineException("Una risorsa con valore > "+TransactionContentUtils.SOGLIA_VALUE_TOO_LONG+" caratteri è stata fornita per "+
  810.                     filterName.name()+" ["+nome
  811.                     +"]; questo tipo di risorsa non è utilizzabile come valore per un filtro");
  812.         }
  813.         
  814.         switch (filterName) {
  815.         case FILTER_1:
  816.             statisticaContenuti.setFiltroNome1(nome);
  817.             statisticaContenuti.setFiltroValore1(valore);
  818.             break;
  819.         case FILTER_2:
  820.             statisticaContenuti.setFiltroNome2(nome);
  821.             statisticaContenuti.setFiltroValore2(valore);
  822.             break;
  823.         case FILTER_3:
  824.             statisticaContenuti.setFiltroNome3(nome);
  825.             statisticaContenuti.setFiltroValore3(valore);
  826.             break;
  827.         case FILTER_4:
  828.             statisticaContenuti.setFiltroNome4(nome);
  829.             statisticaContenuti.setFiltroValore4(valore);
  830.             break;
  831.         case FILTER_5:
  832.             statisticaContenuti.setFiltroNome5(nome);
  833.             statisticaContenuti.setFiltroValore5(valore);
  834.             break;
  835.         case FILTER_6:
  836.             statisticaContenuti.setFiltroNome6(nome);
  837.             statisticaContenuti.setFiltroValore6(valore);
  838.             break;
  839.         case FILTER_7:
  840.             statisticaContenuti.setFiltroNome7(nome);
  841.             statisticaContenuti.setFiltroValore7(valore);
  842.             break;
  843.         case FILTER_8:
  844.             statisticaContenuti.setFiltroNome8(nome);
  845.             statisticaContenuti.setFiltroValore8(valore);
  846.             break;
  847.         case FILTER_9:
  848.             statisticaContenuti.setFiltroNome9(nome);
  849.             statisticaContenuti.setFiltroValore9(valore);
  850.             break;
  851.         case FILTER_10:
  852.             statisticaContenuti.setFiltroNome10(nome);
  853.             statisticaContenuti.setFiltroValore10(valore);
  854.             break;
  855.         }
  856.     }
  857.     
  858.     public static String buildKey(StatisticaContenuti statisticaContenuti){
  859.         StringBuilder bf = new StringBuilder();
  860.         
  861.         bf.append(statisticaContenuti.getRisorsaNome());
  862.         bf.append("=");
  863.         bf.append(statisticaContenuti.getRisorsaValore());
  864.         
  865.         if(statisticaContenuti.getFiltroNome1()!=null){
  866.             bf.append(statisticaContenuti.getFiltroNome1());
  867.             bf.append("=");
  868.             bf.append(statisticaContenuti.getFiltroValore1());
  869.         }
  870.         
  871.         if(statisticaContenuti.getFiltroNome2()!=null){
  872.             bf.append(statisticaContenuti.getFiltroNome2());
  873.             bf.append("=");
  874.             bf.append(statisticaContenuti.getFiltroValore2());
  875.         }
  876.         
  877.         if(statisticaContenuti.getFiltroNome3()!=null){
  878.             bf.append(statisticaContenuti.getFiltroNome3());
  879.             bf.append("=");
  880.             bf.append(statisticaContenuti.getFiltroValore3());
  881.         }
  882.         
  883.         if(statisticaContenuti.getFiltroNome4()!=null){
  884.             bf.append(statisticaContenuti.getFiltroNome4());
  885.             bf.append("=");
  886.             bf.append(statisticaContenuti.getFiltroValore4());
  887.         }
  888.         
  889.         if(statisticaContenuti.getFiltroNome5()!=null){
  890.             bf.append(statisticaContenuti.getFiltroNome5());
  891.             bf.append("=");
  892.             bf.append(statisticaContenuti.getFiltroValore5());
  893.         }
  894.         
  895.         if(statisticaContenuti.getFiltroNome6()!=null){
  896.             bf.append(statisticaContenuti.getFiltroNome6());
  897.             bf.append("=");
  898.             bf.append(statisticaContenuti.getFiltroValore6());
  899.         }
  900.         
  901.         if(statisticaContenuti.getFiltroNome7()!=null){
  902.             bf.append(statisticaContenuti.getFiltroNome7());
  903.             bf.append("=");
  904.             bf.append(statisticaContenuti.getFiltroValore7());
  905.         }
  906.         
  907.         if(statisticaContenuti.getFiltroNome8()!=null){
  908.             bf.append(statisticaContenuti.getFiltroNome8());
  909.             bf.append("=");
  910.             bf.append(statisticaContenuti.getFiltroValore8());
  911.         }
  912.         
  913.         if(statisticaContenuti.getFiltroNome9()!=null){
  914.             bf.append(statisticaContenuti.getFiltroNome9());
  915.             bf.append("=");
  916.             bf.append(statisticaContenuti.getFiltroValore9());
  917.         }
  918.         
  919.         if(statisticaContenuti.getFiltroNome10()!=null){
  920.             bf.append(statisticaContenuti.getFiltroNome10());
  921.             bf.append("=");
  922.             bf.append(statisticaContenuti.getFiltroValore10());
  923.         }
  924.         
  925.         return bf.toString();
  926.         
  927.     }
  928. }
Created with JaCoCo 0.8.8.202204050719