FilterStatisticRepositoryImpl.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.condition;

  22. import java.util.ArrayList;
  23. import java.util.List;

  25. import org.openspcoop2.core.statistiche.StatisticaGiornaliera;
  26. import org.openspcoop2.core.statistiche.StatisticaMensile;
  27. import org.openspcoop2.core.statistiche.StatisticaOraria;
  28. import org.openspcoop2.core.statistiche.StatisticaSettimanale;
  29. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaGiornalieraFieldConverter;
  30. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaMensileFieldConverter;
  31. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaOrariaFieldConverter;
  32. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaSettimanaleFieldConverter;
  33. import org.openspcoop2.core.statistiche.model.StatisticaContenutiModel;
  34. import org.openspcoop2.core.statistiche.model.StatisticaModel;
  35. import org.openspcoop2.generic_project.beans.AliasTableComplexField;
  36. import org.openspcoop2.generic_project.beans.ComplexField;
  37. import org.openspcoop2.generic_project.beans.IAliasTableField;
  38. import org.openspcoop2.generic_project.beans.IField;
  39. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  40. import org.openspcoop2.generic_project.expression.IExpression;
  41. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  42. import org.openspcoop2.core.plugins.utils.FilterUtils;
  43. import org.openspcoop2.monitor.sdk.condition.IStatisticFilter;
  44. import org.openspcoop2.monitor.sdk.constants.StatisticType;
  45. import org.openspcoop2.monitor.sdk.exceptions.SearchException;
  46. import org.openspcoop2.monitor.sdk.statistic.StatisticFilterName;
  47. import org.openspcoop2.utils.TipiDatabase;

  49. /**
  50.  * FilterStatisticRepositoryImpl
  51.  *
  52.  * @author Poli Andrea (apoli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class FilterStatisticRepositoryImpl extends FilterImpl { 

  58.     private StatisticType statisticType;
  59.     @SuppressWarnings("unused")
  60.     private StatisticaModel model;
  61.     private StatisticaContenutiModel contenutiModel;
  62.     
  63.     public FilterStatisticRepositoryImpl(TipiDatabase databaseType,StatisticType statisticType) throws SearchException {
  64.         super(newExpression(databaseType,statisticType),databaseType,newFieldConverter(databaseType,statisticType));
  65.         this.statisticType = statisticType;
  66.         switch (this.statisticType) {
  67.         case ORARIA:
  68.             this.model = StatisticaOraria.model().STATISTICA_BASE;
  69.             this.contenutiModel = StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI;
  70.             break;
  71.         case GIORNALIERA:
  72.             this.model = StatisticaGiornaliera.model().STATISTICA_BASE;
  73.             this.contenutiModel = StatisticaGiornaliera.model().STATISTICA_GIORNALIERA_CONTENUTI;
  74.             break;
  75.         case SETTIMANALE:
  76.             this.model = StatisticaSettimanale.model().STATISTICA_BASE;
  77.             this.contenutiModel = StatisticaSettimanale.model().STATISTICA_SETTIMANALE_CONTENUTI;
  78.             break;
  79.         case MENSILE:
  80.             this.model = StatisticaMensile.model().STATISTICA_BASE;
  81.             this.contenutiModel = StatisticaMensile.model().STATISTICA_MENSILE_CONTENUTI;
  82.             break;
  83.         }
  84.     }
  85.     
  86.     
  87.     
  88.     
  89.     private static IExpression newExpression(TipiDatabase databaseType, StatisticType statisticType) throws SearchException{
  90.         try{
  91.             return new JDBCExpression(newFieldConverter(databaseType,statisticType));
  92.         }catch(Exception e){
  93.             throw new SearchException(e.getMessage(),e);
  94.         }
  95.     }
  96.     private static ISQLFieldConverter newFieldConverter(TipiDatabase databaseType, StatisticType statisticType) throws SearchException{
  97.         switch (statisticType) {
  98.         case ORARIA:
  99.             return new StatisticaOrariaFieldConverter(databaseType);
  100.         case GIORNALIERA:
  101.             return new StatisticaGiornalieraFieldConverter(databaseType);
  102.         case SETTIMANALE:
  103.             return new StatisticaSettimanaleFieldConverter(databaseType);
  104.         case MENSILE:
  105.             return new StatisticaMensileFieldConverter(databaseType);
  106.         }
  107.         throw new SearchException("StatisticType["+statisticType+"] unknown");
  108.     }

  110.     
  111.     @Override
  112.     protected IStatisticFilter newIFilter() throws SearchException{
  113.         try{
  114.             return new FilterStatisticRepositoryImpl(this.databaseType,this.statisticType);
  115.         }catch(Exception e){
  116.             throw new SearchException(e.getMessage(),e);
  117.         }
  118.     }
  119.     
  120.     @Override
  121.     protected IExpression newIExpression() throws SearchException{
  122.         try{
  123.             return newExpression(this.databaseType,this.statisticType);
  124.         }catch(Exception e){
  125.             throw new SearchException(e.getMessage(),e);
  126.         }
  127.     }
  128.     
  129.     @Override
  130.     protected IField getIFieldForMessageType() throws SearchException{
  131.         // tipizzazione non supportata nella statistica
  132.         return null;
  133.     }
  134.     
  135.     @Override
  136.     protected List<IField> getIFieldForResourceName(StatisticFilterName statisticFilter) throws SearchException{
  137.         try{
  138.             List<IField> l = new ArrayList<IField>();
  139.             if(statisticFilter==null){
  140.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_1, FilterUtils.getNextAliasStatisticsTable()));
  141.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_2, FilterUtils.getNextAliasStatisticsTable()));
  142.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_3, FilterUtils.getNextAliasStatisticsTable()));
  143.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_4, FilterUtils.getNextAliasStatisticsTable()));
  144.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_5, FilterUtils.getNextAliasStatisticsTable()));
  145.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_6, FilterUtils.getNextAliasStatisticsTable()));
  146.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_7, FilterUtils.getNextAliasStatisticsTable()));
  147.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_8, FilterUtils.getNextAliasStatisticsTable()));
  148.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_9, FilterUtils.getNextAliasStatisticsTable()));
  149.                 l.add(new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_NOME_10, FilterUtils.getNextAliasStatisticsTable()));
  150.             }
  151.             else{
  152.                 switch (statisticFilter) {
  153.                 case FILTER_1:
  154.                     l.add(this.contenutiModel.FILTRO_NOME_1);
  155.                     break;
  156.                 case FILTER_2:
  157.                     l.add(this.contenutiModel.FILTRO_NOME_2);
  158.                     break;
  159.                 case FILTER_3:
  160.                     l.add(this.contenutiModel.FILTRO_NOME_3);
  161.                     break;
  162.                 case FILTER_4:
  163.                     l.add(this.contenutiModel.FILTRO_NOME_4);
  164.                     break;
  165.                 case FILTER_5:
  166.                     l.add(this.contenutiModel.FILTRO_NOME_5);
  167.                     break;
  168.                 case FILTER_6:
  169.                     l.add(this.contenutiModel.FILTRO_NOME_6);
  170.                     break;
  171.                 case FILTER_7:
  172.                     l.add(this.contenutiModel.FILTRO_NOME_7);
  173.                     break;
  174.                 case FILTER_8:
  175.                     l.add(this.contenutiModel.FILTRO_NOME_8);
  176.                     break;
  177.                 case FILTER_9:
  178.                     l.add(this.contenutiModel.FILTRO_NOME_9);
  179.                     break;
  180.                 case FILTER_10:
  181.                     l.add(this.contenutiModel.FILTRO_NOME_10);
  182.                     break;
  183.                 }
  184.             }
  185.             return l;
  186.         }catch(Exception e){
  187.             throw new SearchException(e.getMessage(),e);
  188.         }
  189.     }
  190.     
  191.     @Override
  192.     protected IField getIFieldForResourceValue(IField fieldResourceName) throws SearchException{
  193.         try{
  194.             String aliasTable = null;
  195.             if( fieldResourceName instanceof IAliasTableField ){
  196.                 IAliasTableField af = (IAliasTableField) fieldResourceName;
  197.                 aliasTable = af.getAliasTable();
  198.             }
  199.             
  200.             if(this.contenutiModel.FILTRO_NOME_1.equals(fieldResourceName)){
  201.                 if(aliasTable!=null)
  202.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_1, aliasTable);
  203.                 else
  204.                     return this.contenutiModel.FILTRO_VALORE_1;
  205.             }
  206.             else if(this.contenutiModel.FILTRO_NOME_2.equals(fieldResourceName)){
  207.                 if(aliasTable!=null)
  208.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_2, aliasTable);
  209.                 else
  210.                     return this.contenutiModel.FILTRO_VALORE_2;
  211.             }
  212.             else if(this.contenutiModel.FILTRO_NOME_3.equals(fieldResourceName)){
  213.                 if(aliasTable!=null)
  214.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_3, aliasTable);
  215.                 else
  216.                     return this.contenutiModel.FILTRO_VALORE_3;
  217.             }
  218.             else if(this.contenutiModel.FILTRO_NOME_4.equals(fieldResourceName)){
  219.                 if(aliasTable!=null)
  220.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_4, aliasTable);
  221.                 else
  222.                     return this.contenutiModel.FILTRO_VALORE_4;
  223.             }
  224.             else if(this.contenutiModel.FILTRO_NOME_5.equals(fieldResourceName)){
  225.                 if(aliasTable!=null)
  226.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_5, aliasTable);
  227.                 else
  228.                     return this.contenutiModel.FILTRO_VALORE_5;
  229.             }
  230.             else if(this.contenutiModel.FILTRO_NOME_6.equals(fieldResourceName)){
  231.                 if(aliasTable!=null)
  232.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_6, aliasTable);
  233.                 else
  234.                     return this.contenutiModel.FILTRO_VALORE_6;
  235.             }
  236.             else if(this.contenutiModel.FILTRO_NOME_7.equals(fieldResourceName)){
  237.                 if(aliasTable!=null)
  238.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_7, aliasTable);
  239.                 else
  240.                     return this.contenutiModel.FILTRO_VALORE_7;
  241.             }
  242.             else if(this.contenutiModel.FILTRO_NOME_8.equals(fieldResourceName)){
  243.                 if(aliasTable!=null)
  244.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_8, aliasTable);
  245.                 else
  246.                     return this.contenutiModel.FILTRO_VALORE_8;
  247.             }
  248.             else if(this.contenutiModel.FILTRO_NOME_9.equals(fieldResourceName)){
  249.                 if(aliasTable!=null)
  250.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_9, aliasTable);
  251.                 else
  252.                     return this.contenutiModel.FILTRO_VALORE_9;
  253.             }
  254.             else if(this.contenutiModel.FILTRO_NOME_10.equals(fieldResourceName)){
  255.                 if(aliasTable!=null)
  256.                     return new AliasTableComplexField((ComplexField)this.contenutiModel.FILTRO_VALORE_10, aliasTable);
  257.                 else
  258.                     return this.contenutiModel.FILTRO_VALORE_10;
  259.             }
  260.             throw new Exception("Unknown field: "+fieldResourceName);
  261.         }catch(Exception e){
  262.             throw new SearchException(e.getMessage(),e);
  263.         }
  264.     }
  265.     

  267. }
Created with JaCoCo 0.8.8.202204050719