StatisticheMensili.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 org.openspcoop2.core.statistiche.Statistica;
  23. import org.openspcoop2.core.statistiche.StatisticaContenuti;
  24. import org.openspcoop2.core.statistiche.StatisticaMensile;
  25. import org.openspcoop2.core.statistiche.constants.TipoIntervalloStatistico;
  26. import org.openspcoop2.core.statistiche.dao.IDBStatisticaMensileService;
  27. import org.openspcoop2.core.statistiche.dao.IStatisticaMensileService;
  28. import org.openspcoop2.monitor.sdk.constants.StatisticType;
  29. import org.openspcoop2.monitor.sdk.exceptions.StatisticException;
  30. import org.openspcoop2.monitor.sdk.plugins.IStatisticProcessing;
  31. import org.openspcoop2.monitor.sdk.statistic.IStatistic;

  33. import java.util.Calendar;
  34. import java.util.Date;

  36. import org.slf4j.Logger;
  37. import org.openspcoop2.generic_project.exception.NotImplementedException;
  38. import org.openspcoop2.generic_project.exception.ServiceException;

  40. /**
  41.  * StatisticheMensili
  42.  *
  43.  * @author Poli Andrea (apoli@link.it)
  44.  * @author $Author$
  45.  * @version $Rev$, $Date$
  46.  */
  47. public class StatisticheMensili extends AbstractStatistiche {

  49.     public static StatisticheMensili getInstanceForUtils(){
  50.         return new StatisticheMensili(); 
  51.     }
  52.     StatisticheMensili(){
  53.             super();
  54.     }
  55.     public StatisticheMensili( 
  56.             Logger logger, boolean logQuery, boolean useUnionForLatency,  
  57.             boolean generazioneStatisticheCustom, boolean analisiTransazioniCustom,
  58.             StatisticsForceIndexConfig forceIndexConfig,
  59.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM,
  60.             org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM,
  61.             org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager pluginsStatisticheSM,
  62.             org.openspcoop2.core.plugins.dao.IServiceManager pluginsBaseSM,
  63.             org.openspcoop2.core.commons.search.dao.IServiceManager utilsSM,
  64.             org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager pluginsTransazioniSM) {
  65.         super( logger, logQuery, useUnionForLatency, 
  66.                 generazioneStatisticheCustom,analisiTransazioniCustom,
  67.                 forceIndexConfig,
  68.                 statisticheSM,transazioniSM,
  69.                 pluginsStatisticheSM,pluginsBaseSM,utilsSM,pluginsTransazioniSM);
  70.         
  71.         try {
  72.             
  73.             if(statisticheSM==null){
  74.                 throw new ServiceException("ServiceManager ["+org.openspcoop2.core.statistiche.dao.IServiceManager.class.getName()+"] non inizializzato");
  75.             }
  76.             
  77.             this.model = StatisticaMensile.model().STATISTICA_BASE;
  78.             this.statisticaServiceDAO = this.statisticheSM.getStatisticaMensileService( );
  79.             this.statisticaServiceSearchDAO = this.statisticheSM.getStatisticaMensileServiceSearch();
  80.         
  81.         } catch (ServiceException e) {
  82.             this.logger.error(e.getMessage(), e);
  83.         } catch (NotImplementedException e) {
  84.             this.logger.error(e.getMessage(), e);
  85.         }
  86.     }
  87.     
  88.     private Calendar truncDate(Date date){
  89.         Calendar cTmp = Calendar.getInstance();
  90.         cTmp.setTime(date);
  91.         cTmp.set(Calendar.DAY_OF_MONTH, 1);
  92.         cTmp.set(Calendar.HOUR_OF_DAY, 0);
  93.         cTmp.set(Calendar.MINUTE, 0);
  94.         cTmp.set(Calendar.SECOND, 0);
  95.         cTmp.set(Calendar.MILLISECOND, 0);
  96.         return cTmp;
  97.     }
  98.     
  99.     @Override
  100.     public Date truncDate(Date date,boolean print){
  101.         Calendar cTmp = truncDate(date);
  102.         if(print){
  103.             printCalendar(cTmp);
  104.         }
  105.         return cTmp.getTime();
  106.     }
  107.     
  108.     @Override
  109.     public String getIntervalloStatistica(Date date,boolean print){
  110.         
  111.         //System.out.println("INTERVALLO MENSILE PER ["+date.toString()+"]");
  112.         
  113.         Calendar cTmp = truncDate(date);
  114.         StringBuilder bf = new StringBuilder();
  115.         switch (cTmp.get(Calendar.MONTH)) {
  116.         case Calendar.JANUARY:
  117.             bf.append("Gennaio");   
  118.             break;
  119.         case Calendar.FEBRUARY:
  120.             bf.append("Febbraio");  
  121.             break;
  122.         case Calendar.MARCH:
  123.             bf.append("Marzo"); 
  124.             break;
  125.         case Calendar.APRIL:
  126.             bf.append("Aprile");    
  127.             break;
  128.         case Calendar.MAY:
  129.             bf.append("Maggio");    
  130.             break;
  131.         case Calendar.JUNE:
  132.             bf.append("Giugno");    
  133.             break;
  134.         case Calendar.JULY:
  135.             bf.append("Luglio");    
  136.             break;
  137.         case Calendar.AUGUST:
  138.             bf.append("Agosto");    
  139.             break;
  140.         case Calendar.SEPTEMBER:
  141.             bf.append("Settembre"); 
  142.             break;
  143.         case Calendar.OCTOBER:
  144.             bf.append("Ottobre");   
  145.             break;
  146.         case Calendar.NOVEMBER:
  147.             bf.append("Novembre");  
  148.             break;
  149.         case Calendar.DECEMBER:
  150.             bf.append("Dicembre");  
  151.             break;
  152.         default:
  153.             bf.append("Non definito?"); 
  154.             break;
  155.         }
  156.         
  157.         //System.out.println("INTERVALLO MENSILE PER ["+date.toString()+"]: "+bf.toString());
  158.         
  159.         return bf.toString();
  160.     }
  161.     
  162.     @Override
  163.     public Date incrementDate(Date date,boolean print){
  164.         return operation(date, print, +1);
  165.     }
  166.     
  167.     @Override
  168.     public Date decrementDate(Date date,boolean print){
  169.         return operation(date, print, -1);
  170.     }
  171.     
  172.     private Date operation(Date date,boolean print, int value){
  173.         Calendar cTmp = Calendar.getInstance();
  174.         cTmp.setTime(date);
  175.         if(print){
  176.             super.logger.debug(">>> incrementDate >>>>");
  177.             super.logger.debug("Before: ");
  178.             printCalendar(cTmp);
  179.         }
  180.         /*else{
  181.             super.log.debug("***** ("+value+") data PRIMA OPERAZIONE:");
  182.             printCalendar(cTmp);
  183.         }*/
  184.         
  185.         // prelevo giorno impostato nella data
  186.         int giorno = cTmp.get(Calendar.DAY_OF_MONTH);
  187.         //super.log.debug("***** ("+value+") prelevo giorno impostato nella data: "+giorno);
  188.         
  189.         // prelevo ultimo giorno del mese impostato nell'attuale data
  190.         int lastDayActualMonth = cTmp.getActualMaximum(Calendar.DAY_OF_MONTH);
  191.         //super.log.debug("***** ("+value+") prelevo ultimo giorno del mese impostato nell'attuale data: "+lastDayActualMonth);
  192.         
  193.         // incremento
  194.         //super.log.debug("***** ("+value+") effettuo operazione");
  195.         cTmp.add(Calendar.MONTH, value);
  196.         
  197.         // prelevo giorno impostato nella data modificata
  198.         //int giornoDataModificata = cTmp.get(Calendar.DAY_OF_MONTH);
  199.         //super.log.debug("***** ("+value+") prelevo giorno impostato nella data modificata: "+giornoDataModificata);
  200.         
  201.         // Se il giorno della data originale era uguale all'ultimo giorno del mese della data originale, 
  202.         // ripristino questa condizione anche nella data modificata
  203.         if(giorno == lastDayActualMonth){
  204.             
  205.             //super.log.debug("***** ("+value+") ripristino ultimo giorno del mese");
  206.             
  207.             // prelevo ultimo giorno del mese impostato nella data modificata
  208.             int lastDayMonth = cTmp.getActualMaximum(Calendar.DAY_OF_MONTH);
  209.             //super.log.debug("***** ("+value+") prelevo ultimo giorno del mese impostato nella data modificata: "+lastDayMonth);
  210.             
  211.             // ripristino condizione
  212.             cTmp.set(Calendar.DAY_OF_MONTH, lastDayMonth);
  213.             
  214.             //int giornoDataRipristinata = cTmp.get(Calendar.DAY_OF_MONTH);
  215.             //super.log.debug("***** ("+value+") prelevo giorno impostato nella data ripristinata: "+giornoDataRipristinata);
  216.             
  217.         }
  218.         
  219.         if(print){
  220.             super.logger.debug("After: ");
  221.             printCalendar(cTmp);
  222.             super.logger.debug(">>> incrementDate end >>>>");
  223.         }
  224.         /*else{
  225.             super.log.debug("***** ("+value+") data FINE OPERAZIONE:");
  226.             printCalendar(cTmp);
  227.         }*/
  228.         return cTmp.getTime();
  229.     }
  230.     
  231.     @Override
  232.     public TipoIntervalloStatistico getTipoStatistiche(){
  233.         return TipoIntervalloStatistico.STATISTICHE_MENSILI;
  234.     }
  235.     
  236.     @Override
  237.     public void callStatisticPluginMethod(IStatisticProcessing statProcessing,
  238.             StatisticBean stat) throws StatisticException {
  239.         IStatistic statContext = new CustomStatisticsSdkGenerator(stat, StatisticType.MENSILE, this);
  240.         statProcessing.createMonthlyStatisticData(statContext);
  241.     }
  242.     
  243.     @Override
  244.     public String getStatisticPluginMethodName() throws StatisticException {
  245.         return "createMonthlyStatisticData";
  246.     }
  247.     

  249.     @Override
  250.     protected Long insertStatistica(Statistica statistica) throws StatisticException {
  251.         
  252.         try{
  253.         
  254.             StatisticaMensile stat = new StatisticaMensile();
  255.             stat.setStatisticaBase(statistica);
  256.             ((IStatisticaMensileService)this.statisticaServiceDAO).create(stat);
  257.             return stat.getId();
  258.             
  259.         }catch(Exception e){
  260.             throw new StatisticException(e.getMessage(),e);
  261.         }

  263.     }
  264.     
  265.     @Override
  266.     protected void updateStatistica(long idStatistica, StatisticaContenuti ... statisticaContenuti) throws StatisticException {
  267.         
  268.         try{
  269.         
  270.             StatisticaMensile stat = ((IDBStatisticaMensileService)this.statisticaServiceDAO).get(idStatistica);
  271.             for (int i = 0; i < statisticaContenuti.length; i++) {
  272.                 statisticaContenuti[i].setData(stat.getStatisticaBase().getData());
  273.                 stat.addStatisticaMensileContenuti(statisticaContenuti[i]);
  274.             }
  275.             ((IStatisticaMensileService)this.statisticaServiceDAO).update(stat);
  276.             
  277.         }catch(Exception e){
  278.             throw new StatisticException(e.getMessage(),e);
  279.         }

  281.     }
  282.     
  283. }
Created with JaCoCo 0.8.8.202204050719