ControlloTrafficoDriverUtils.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.  */

  21. package org.openspcoop2.core.controllo_traffico.utils;

  23. import java.sql.Connection;
  24. import java.sql.PreparedStatement;
  25. import java.sql.ResultSet;
  26. import java.util.ArrayList;
  27. import java.util.HashMap;
  28. import java.util.List;
  29. import java.util.Map;

  31. import org.apache.commons.lang.StringUtils;
  32. import org.openspcoop2.core.commons.Filtri;
  33. import org.openspcoop2.core.commons.ISearch;
  34. import org.openspcoop2.core.commons.Liste;
  35. import org.openspcoop2.core.commons.Search;
  36. import org.openspcoop2.core.commons.SearchUtils;
  37. import org.openspcoop2.core.config.Proprieta;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  40. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyFiltro;
  41. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyRaggruppamento;
  42. import org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale;
  43. import org.openspcoop2.core.controllo_traffico.ConfigurazionePolicy;
  44. import org.openspcoop2.core.controllo_traffico.ConfigurazioneRateLimitingProprieta;
  45. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;
  46. import org.openspcoop2.core.controllo_traffico.IdPolicy;
  47. import org.openspcoop2.core.controllo_traffico.beans.InfoPolicy;
  48. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  49. import org.openspcoop2.core.controllo_traffico.constants.TipoApplicabilita;
  50. import org.openspcoop2.core.controllo_traffico.constants.TipoControlloPeriodo;
  51. import org.openspcoop2.core.controllo_traffico.constants.TipoPeriodoRealtime;
  52. import org.openspcoop2.core.controllo_traffico.constants.TipoPeriodoStatistico;
  53. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsa;
  54. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsaPolicyAttiva;
  55. import org.openspcoop2.core.controllo_traffico.dao.IDBAttivazionePolicyServiceSearch;
  56. import org.openspcoop2.core.controllo_traffico.dao.IDBConfigurazionePolicyServiceSearch;
  57. import org.openspcoop2.core.id.IDServizio;
  58. import org.openspcoop2.core.id.IDServizioApplicativo;
  59. import org.openspcoop2.core.id.IDSoggetto;
  60. import org.openspcoop2.generic_project.beans.Function;
  61. import org.openspcoop2.generic_project.beans.FunctionField;
  62. import org.openspcoop2.generic_project.beans.IField;
  63. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  64. import org.openspcoop2.generic_project.exception.NotFoundException;
  65. import org.openspcoop2.generic_project.exception.ServiceException;
  66. import org.openspcoop2.generic_project.expression.IExpression;
  67. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  68. import org.openspcoop2.generic_project.expression.LikeMode;
  69. import org.openspcoop2.generic_project.expression.SortOrder;
  70. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  71. import org.openspcoop2.utils.TipiDatabase;
  72. import org.openspcoop2.utils.jdbc.JDBCParameterUtilities;
  73. import org.openspcoop2.utils.sql.ISQLQueryObject;
  74. import org.openspcoop2.utils.sql.LikeConfig;
  75. import org.openspcoop2.utils.sql.SQLObjectFactory;
  76. import org.slf4j.Logger;

  78. /**
  79.  * ControlloTrafficoDriverUtils
  80.  *
  81.  * @author Poli Andrea (apoli@link.it)
  82.  * @author $Author$
  83.  * @version $Rev$, $Date$
  84.  */
  85. public class ControlloTrafficoDriverUtils {
  86.     
  87.     public static ConfigurazioneGenerale getConfigurazioneControlloTraffico(Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException {
  88.         String nomeMetodo = "getConfigurazioneControlloTraffico";
  89.         // ritorna la configurazione controllo del traffico della PdD
  90.         
  91.         ConfigurazioneGenerale config = null;
  92.         try {
  93.             
  94.             ServiceManagerProperties properties = new ServiceManagerProperties();
  95.             properties.setDatabaseType(tipoDB);
  96.             properties.setShowSql(true);
  97.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  98.             
  99.             try {
  100.                 config = serviceManager.getConfigurazioneGeneraleServiceSearch().get();
  101.             }catch (NotFoundException e) {
  102.                 throw new NotFoundException("["+ nomeMetodo + "] Configurazione non presente.");
  103.             }
  104.         }catch (Exception se) {
  105.             throw new ServiceException("[" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  106.         } 

  108.         return config;
  109.     }

  111.     /***
  112.      * Aggiorna la configurazione del controllo del traffico
  113.      * 
  114.      * @param configurazioneControlloTraffico
  115.      * @throws ServiceException
  116.      */
  117.     public static void updateConfigurazioneControlloTraffico(ConfigurazioneGenerale configurazioneControlloTraffico, Connection con, Logger log, String tipoDB) throws ServiceException {
  118.         String nomeMetodo = "updateConfigurazioneControlloTraffico";
  119.         
  120.         try {

  122.             ServiceManagerProperties properties = new ServiceManagerProperties();
  123.             properties.setDatabaseType(tipoDB);
  124.             properties.setShowSql(true);
  125.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  126.             
  127.             serviceManager.getConfigurazioneGeneraleService().update(configurazioneControlloTraffico);
  128.         } catch (Exception se) {
  129.             throw new ServiceException("[" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  130.         }
  131.         
  132.     }

  134.     public static List<Proprieta> getProprietaRateLimiting(Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException {
  135.         String nomeMetodo = "getProprietaRateLimiting";
  136.         // ritorna la configurazione controllo del traffico della PdD
  137.         
  138.         List<Proprieta> list = new ArrayList<Proprieta>();
  139.         try {
  140.             
  141.             ServiceManagerProperties properties = new ServiceManagerProperties();
  142.             properties.setDatabaseType(tipoDB);
  143.             properties.setShowSql(true);
  144.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  145.             List<ConfigurazioneRateLimitingProprieta> l = serviceManager.getConfigurazioneRateLimitingProprietaServiceSearch().findAll(serviceManager.getConfigurazioneRateLimitingProprietaServiceSearch().newPaginatedExpression());
  146.             if(l!=null && !l.isEmpty()) {
  147.                 for (ConfigurazioneRateLimitingProprieta configurazioneRateLimitingProprieta : l) {
  148.                     Proprieta p = new Proprieta();
  149.                     p.setNome(configurazioneRateLimitingProprieta.getNome());
  150.                     p.setValore(configurazioneRateLimitingProprieta.getValore());
  151.                     list.add(p);
  152.                 }
  153.             }
  154.         }catch (Exception se) {
  155.             throw new ServiceException("[" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  156.         } 

  158.         return list;
  159.     }
  160.     
  161.     /**
  162.      * Restituisce il numero di Configurazione Policy
  163.      * 
  164.      * @return Configurazione
  165.      * 
  166.      */
  167.     public static long countConfigurazioneControlloTrafficoConfigurazionePolicy(ISearch ricerca, Connection con, Logger log, String tipoDB) throws ServiceException {
  168.         String nomeMetodo = "countConfigurazioneControlloTrafficoConfigurazionePolicy";
  169.         // ritorna la configurazione controllo del traffico della PdD
  170.         int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_CONFIGURAZIONE_POLICY;
  171.         String search = null;
  172.         String filterTipoPolicy = null;
  173.         if(ricerca != null) {
  174.             search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  175.     
  176.             filterTipoPolicy = SearchUtils.getFilter(ricerca, idLista,  Filtri.FILTRO_TIPO_POLICY);
  177.             
  178.             log.debug("search : " + search);
  179.             log.debug("filterTipoPolicy : " + filterTipoPolicy);
  180.         }

  182.         long count = 0;
  183.         try {
  184.             
  185.             ServiceManagerProperties properties = new ServiceManagerProperties();
  186.             properties.setDatabaseType(tipoDB);
  187.             properties.setShowSql(true);
  188.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  189.             
  190.             IExpression expr = serviceManager.getConfigurazionePolicyServiceSearch().newExpression();
  191.             
  192.             if(Filtri.FILTRO_TIPO_POLICY_BUILT_IN.equals(filterTipoPolicy)) {
  193.                 expr.equals(ConfigurazionePolicy.model().BUILT_IN, true);
  194.             }
  195.             else if(Filtri.FILTRO_TIPO_POLICY_UTENTE.equals(filterTipoPolicy)) {
  196.                 expr.equals(ConfigurazionePolicy.model().BUILT_IN, false);
  197.             }
  198.             
  199.             if(search != null  && !"".equals(search)){
  200.                 expr.ilike(ConfigurazionePolicy.model().ID_POLICY, search, LikeMode.ANYWHERE);
  201.             }
  202.             
  203.             NonNegativeNumber nnn = serviceManager.getConfigurazionePolicyServiceSearch().count(expr);
  204.             
  205.             count = nnn != null ? nnn.longValue() : 0;
  206.         }catch (Exception se) {
  207.             throw new ServiceException("[" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  208.         } 

  210.         return count;
  211.     }
  212.     
  213.     /**
  214.      * Restituisce il numero di Attivazione Policy
  215.      * 
  216.      * @return Configurazione
  217.      * 
  218.      */
  219.     public static long countConfigurazioneControlloTrafficoAttivazionePolicy(ISearch ricerca, RuoloPolicy ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException {
  220.         String nomeMetodo = "countConfigurazioneControlloTrafficoAttivazionePolicy";
  221.         // ritorna la configurazione controllo del traffico della PdD
  222.         int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY;
  223.         String search = null;

  225.         if(ricerca != null) {
  226.             search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  227.         }

  229.         long count = 0;
  230.         try {
  231.             
  232.             ServiceManagerProperties properties = new ServiceManagerProperties();
  233.             properties.setDatabaseType(tipoDB);
  234.             properties.setShowSql(true);
  235.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  236.             
  237.             IExpression expr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  238.             
  239.             if(ruoloPorta!=null && nomePorta!=null) {
  240.                 expr.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, ruoloPorta);
  241.                 expr.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA, nomePorta);
  242.             }
  243.             else {
  244.                 expr.isNull(AttivazionePolicy.model().FILTRO.NOME_PORTA);
  245.             }
  246.             
  247.             if(search != null  && !"".equals(search)){
  248.                 expr.ilike(AttivazionePolicy.model().ID_POLICY, search, LikeMode.ANYWHERE);
  249.             }
  250.             NonNegativeNumber nnn = serviceManager.getAttivazionePolicyServiceSearch().count(expr);
  251.             
  252.             count = nnn != null ? nnn.longValue() : 0;
  253.         }catch (Exception se) {
  254.             throw new ServiceException("[" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  255.         } 

  257.         return count;
  258.     }

  260.     public static List<ConfigurazionePolicy> configurazioneControlloTrafficoConfigurazionePolicyList(ISearch ricerca, Connection con, Logger log, String tipoDB) throws ServiceException{
  261.         String nomeMetodo = "configurazioneControlloTrafficoConfigurazionePolicyList";
  262.         // ritorna la configurazione controllo del traffico della PdD
  263.         int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_CONFIGURAZIONE_POLICY;
  264.         String search = null;
  265.         int offset = 0;
  266.         int limit =0 ;

  268.         if(ricerca != null) {
  269.             search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  270.             limit = ricerca.getPageSize(idLista);
  271.             offset = ricerca.getIndexIniziale(idLista);
  272.         }
  273.         if (limit == 0) // con limit
  274.             limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  275.         
  276.         String filterTipoPolicy = SearchUtils.getFilter(ricerca, idLista,  Filtri.FILTRO_TIPO_POLICY);
  277.         
  278.         log.debug("search : " + search);
  279.         log.debug("filterTipoPolicy : " + filterTipoPolicy);
  280.         
  281.         List<ConfigurazionePolicy> listaPolicy = new ArrayList<ConfigurazionePolicy>();
  282.         
  283.         long count = 0;
  284.         try {
  285.             
  286.             ServiceManagerProperties properties = new ServiceManagerProperties();
  287.             properties.setDatabaseType(tipoDB);
  288.             properties.setShowSql(true);
  289.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  290.             
  291.             IExpression expr = serviceManager.getConfigurazionePolicyServiceSearch().newExpression();
  292.             
  293.             if(Filtri.FILTRO_TIPO_POLICY_BUILT_IN.equals(filterTipoPolicy)) {
  294.                 expr.equals(ConfigurazionePolicy.model().BUILT_IN, true);
  295.             }
  296.             else if(Filtri.FILTRO_TIPO_POLICY_UTENTE.equals(filterTipoPolicy)) {
  297.                 expr.equals(ConfigurazionePolicy.model().BUILT_IN, false);
  298.             }
  299.             
  300.             if(search != null  && !"".equals(search)){
  301.                 expr.ilike(ConfigurazionePolicy.model().ID_POLICY, search, LikeMode.ANYWHERE);
  302.             }
  303.             
  304.             if(ricerca!=null) {
  305.                 NonNegativeNumber nn = serviceManager.getConfigurazionePolicyServiceSearch().count(expr);
  306.                 if(nn!=null) {
  307.                     count = nn.longValue();
  308.                 }
  309.             }
  310.             
  311.             IPaginatedExpression pagExpr = serviceManager.getConfigurazionePolicyServiceSearch().toPaginatedExpression(expr);
  312.             pagExpr.offset(offset).limit(limit);
  313.             pagExpr.sortOrder(SortOrder.ASC);
  314.             pagExpr.addOrder(ConfigurazionePolicy.model().BUILT_IN);
  315.             pagExpr.addOrder(ConfigurazionePolicy.model().ID_POLICY);
  316.             
  317.             listaPolicy = serviceManager.getConfigurazionePolicyServiceSearch().findAll(pagExpr);
  318.                         
  319.         } catch (Exception qe) {
  320.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  321.         }
  322.         
  323.         if(ricerca!=null) {
  324.             ricerca.setNumEntries(idLista,(int)count);
  325.         }
  326.         
  327.         return listaPolicy;
  328.     }
  329.     
  330.     public static List<ConfigurazionePolicy> configurazioneControlloTrafficoConfigurazionePolicyList_conApplicabilitaAllarme(String idAllarme, Connection con, Logger log, String tipoDB) throws ServiceException{
  331.         String nomeMetodo = "configurazioneControlloTrafficoConfigurazionePolicyList_conApplicabilitaAllarme";
  332.         // ritorna la configurazione controllo del traffico della PdD
  333.         
  334.         List<ConfigurazionePolicy> listaPolicy = new ArrayList<ConfigurazionePolicy>();
  335.         
  336.         try {
  337.             
  338.             ServiceManagerProperties properties = new ServiceManagerProperties();
  339.             properties.setDatabaseType(tipoDB);
  340.             properties.setShowSql(true);
  341.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  342.             
  343.             IExpression expr = serviceManager.getConfigurazionePolicyServiceSearch().newExpression();
  344.             
  345.             expr.equals(ConfigurazionePolicy.model().APPLICABILITA_STATO_ALLARME, true);
  346.             expr.equals(ConfigurazionePolicy.model().ALLARME_NOME, idAllarme);
  347.             
  348.             IPaginatedExpression pagExpr = serviceManager.getConfigurazionePolicyServiceSearch().toPaginatedExpression(expr);
  349.             pagExpr.sortOrder(SortOrder.ASC);
  350.             pagExpr.addOrder(ConfigurazionePolicy.model().ID_POLICY);
  351.             
  352.             listaPolicy = serviceManager.getConfigurazionePolicyServiceSearch().findAll(pagExpr);
  353.                         
  354.         } catch (Exception qe) {
  355.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  356.         }
  357.         
  358.         return listaPolicy;
  359.     }

  361.     @SuppressWarnings("unchecked")
  362.     public static List<AttivazionePolicy> configurazioneControlloTrafficoAttivazionePolicyList(ISearch ricerca, RuoloPolicy ruoloPorta, String nomePorta, 
  363.             Connection con, Logger log, String tipoDB) throws ServiceException{
  364.         return (List<AttivazionePolicy>) _configurazioneControlloTrafficoAttivazionePolicyList(ricerca, ruoloPorta, nomePorta,
  365.                 con, log, tipoDB,
  366.                 false, "configurazioneControlloTrafficoAttivazionePolicyList",
  367.                 null, null, null,
  368.                 null, null,
  369.                 null, null);
  370.     }
  371.     @SuppressWarnings("unchecked")
  372.     public static List<AttivazionePolicy> configurazioneControlloTrafficoAttivazionePolicyListByFilter(ISearch ricerca, RuoloPolicy ruoloPorta, String nomePorta, 
  373.             Connection con, Logger log, String tipoDB,
  374.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  375.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  376.             IDServizio filtroServizioAzione, String filtroRuolo) throws ServiceException{
  377.         return (List<AttivazionePolicy>) _configurazioneControlloTrafficoAttivazionePolicyList(ricerca, ruoloPorta, nomePorta, 
  378.                 con, log, tipoDB,
  379.                 false, "configurazioneControlloTrafficoAttivazionePolicyListByFilter",
  380.                 filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  381.                 filtroSoggettoErogatore, filtroRuoloErogatore,
  382.                 filtroServizioAzione, filtroRuolo);
  383.     }
  384.     @SuppressWarnings("unchecked")
  385.     public static List<TipoRisorsaPolicyAttiva> configurazioneControlloTrafficoAttivazionePolicyTipoRisorsaList(ISearch ricerca, RuoloPolicy ruoloPorta, String nomePorta, 
  386.             Connection con, Logger log, String tipoDB) throws ServiceException{
  387.         return (List<TipoRisorsaPolicyAttiva>) _configurazioneControlloTrafficoAttivazionePolicyList(ricerca, ruoloPorta, nomePorta, 
  388.                 con, log, tipoDB,
  389.                 true, "configurazioneControlloTrafficoAttivazionePolicyTipoRisorsaList",
  390.                 null, null, null,
  391.                 null, null,
  392.                 null, null);
  393.     }
  394.     public static Object _configurazioneControlloTrafficoAttivazionePolicyList(ISearch ricerca, RuoloPolicy ruoloPorta, String nomePorta, 
  395.             Connection con, Logger log, String tipoDB,
  396.             boolean tipoRisorsa, String nomeMetodo, 
  397.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  398.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  399.             IDServizio filtroServizioAzione, String filtroRuolo) throws ServiceException{
  400.         // ritorna la configurazione controllo del traffico della PdD
  401.         int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY;
  402.         String search = null;
  403.         int offset = 0;
  404.         int limit =0 ;

  406.         if(ricerca != null) {
  407.             if(!tipoRisorsa) {
  408.                 search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  409.             }
  410.             limit = ricerca.getPageSize(idLista);
  411.             offset = ricerca.getIndexIniziale(idLista);
  412.         }
  413.         if (limit == 0) // con limit
  414.             limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  415.         
  416.         TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva = null;
  417.         if(!tipoRisorsa && ricerca != null) {
  418.             String filterTipoRisorsaPolicy = SearchUtils.getFilter(ricerca, idLista,  Filtri.FILTRO_TIPO_RISORSA_POLICY);
  419.             if(filterTipoRisorsaPolicy!=null && !"".equals(filterTipoRisorsaPolicy)) {
  420.                 try {
  421.                     tipoRisorsaPolicyAttiva = TipoRisorsaPolicyAttiva.toEnumConstant(filterTipoRisorsaPolicy, true);
  422.                 }catch (Exception e) {
  423.                     throw new ServiceException(e.getMessage(),e);
  424.                 }
  425.             }
  426.         }
  427.         
  428.         log.debug("search : " + search);
  429.         log.debug("filterTipoRisorsaPolicy : " + tipoRisorsaPolicyAttiva);
  430.         
  431.         List<AttivazionePolicy> listaPolicy = new ArrayList<AttivazionePolicy>();
  432.         List<TipoRisorsaPolicyAttiva> listaTipoRisorsa = new ArrayList<>();
  433.         
  434.         long count = 0;
  435.         PreparedStatement pstmt = null;
  436.         ResultSet rs = null;
  437.         try {
  438.             if(ricerca!=null) {

  440.                 ISQLQueryObject sqlQueryObject = _prepareSqlQueryObjectPolicyAttive(tipoDB,ruoloPorta, nomePorta, search, tipoRisorsaPolicyAttiva,
  441.                         filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  442.                         filtroSoggettoErogatore, filtroRuoloErogatore,
  443.                         filtroServizioAzione, filtroRuolo);
  444.                 sqlQueryObject.addSelectCountField("active_policy_id", "policies");
  445.                 String query = sqlQueryObject.createSQLQuery();
  446.                 pstmt = con.prepareStatement(query);
  447.                 _prepareStatementPolicyAttive(tipoDB,pstmt, ruoloPorta, nomePorta, search, tipoRisorsaPolicyAttiva,
  448.                         filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  449.                         filtroSoggettoErogatore, filtroRuoloErogatore,
  450.                         filtroServizioAzione, filtroRuolo);
  451.                 rs = pstmt.executeQuery();
  452.                 if(rs.next()) {
  453.                     count = rs.getLong("policies");
  454.                 }
  455.                 rs.close();
  456.                 pstmt.close();
  457.                 
  458.             }
  459.             
  460.             ServiceManagerProperties properties = new ServiceManagerProperties();
  461.             properties.setDatabaseType(tipoDB);
  462.             properties.setShowSql(true);
  463.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  464.             
  465.             
  466.             ISQLQueryObject sqlQueryObject = _prepareSqlQueryObjectPolicyAttive(tipoDB,ruoloPorta, nomePorta, search, tipoRisorsaPolicyAttiva,
  467.                     filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  468.                     filtroSoggettoErogatore, filtroRuoloErogatore,
  469.                     filtroServizioAzione, filtroRuolo);
  470.             sqlQueryObject.addSelectField(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY, "active_policy_id");
  471.             sqlQueryObject.addSelectField(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY, "policy_posizione");
  472.             sqlQueryObject.addSelectField(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY, "rt_risorsa");
  473.             sqlQueryObject.addSelectField(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY, "rt_simultanee");
  474.             sqlQueryObject.setOffset(offset);
  475.             sqlQueryObject.setLimit(limit);
  476.             //sqlQueryObject.addOrderBy("policy_alias", true);
  477.             //sqlQueryObject.addOrderBy("policy_id", true);
  478.             sqlQueryObject.addOrderBy(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY+".rt_risorsa", true);
  479.             sqlQueryObject.addOrderBy(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY+".rt_simultanee", true);
  480.             sqlQueryObject.addOrderBy(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".policy_posizione", true);
  481.             String query = sqlQueryObject.createSQLQuery();
  482.             pstmt = con.prepareStatement(query);
  483.             _prepareStatementPolicyAttive(tipoDB,pstmt, ruoloPorta, nomePorta, search, tipoRisorsaPolicyAttiva,
  484.                     filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  485.                     filtroSoggettoErogatore, filtroRuoloErogatore,
  486.                     filtroServizioAzione, filtroRuolo);
  487.             rs = pstmt.executeQuery();
  488.             while(rs.next()) {
  489.                 
  490.                 if(tipoRisorsa) {
  491.                     
  492.                     String risorsa = rs.getString("rt_risorsa");
  493.                     JDBCParameterUtilities utils = new JDBCParameterUtilities(TipiDatabase.toEnumConstant(tipoDB));
  494.                     boolean simultanee = utils.readBooleanParameter(rs, "rt_simultanee");
  495.                     TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttivaActivePolicy =  TipoRisorsaPolicyAttiva.getTipo(risorsa, simultanee);
  496.                     if(listaTipoRisorsa.contains(tipoRisorsaPolicyAttivaActivePolicy)==false) {
  497.                         listaTipoRisorsa.add(tipoRisorsaPolicyAttivaActivePolicy);
  498.                     }
  499.                     
  500.                 }
  501.                 else {
  502.                 
  503.                     String idActivePolicy = rs.getString("active_policy_id");
  504.                     
  505.                     IdActivePolicy idActivePolicyAsObject = new IdActivePolicy();
  506.                     idActivePolicyAsObject.setNome(idActivePolicy);
  507.                     AttivazionePolicy policy = serviceManager.getAttivazionePolicyServiceSearch().get(idActivePolicyAsObject);
  508.                     listaPolicy.add(policy);
  509.                     
  510.                 }
  511.                 
  512.             }
  513.             rs.close();
  514.             pstmt.close();
  515.                         
  516.         } catch (Exception qe) {
  517.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  518.         } finally {
  519.             try {
  520.                 if(rs!=null) {
  521.                     rs.close();
  522.                 }
  523.             } catch (Exception e) {
  524.                 // ignore exception
  525.             }
  526.             try {
  527.                 if(pstmt!=null) {
  528.                     pstmt.close();
  529.                 }
  530.             } catch (Exception e) {
  531.                 // ignore exception
  532.             }
  533.         }
  534.         
  535.         if(ricerca!=null) {
  536.             ricerca.setNumEntries(idLista,(int) count);
  537.         }
  538.         
  539.         if(tipoRisorsa) {
  540.             return listaTipoRisorsa;
  541.         }
  542.         else {
  543.             return listaPolicy;
  544.         }
  545.     }
  546.     private static ISQLQueryObject _prepareSqlQueryObjectPolicyAttive(
  547.             String tipoDB,
  548.             RuoloPolicy ruoloPorta, String nomePorta,
  549.             String search, TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva,
  550.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  551.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  552.             IDServizio filtroServizioAzione, String filtroRuolo) throws Exception {
  553.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  554.         sqlQueryObject.setANDLogicOperator(true);
  555.         sqlQueryObject.addFromTable(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY);
  556.         sqlQueryObject.addFromTable(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY);
  557.         sqlQueryObject.addWhereCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".policy_id="+CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY+".policy_id");
  558.         if(ruoloPorta!=null && nomePorta!=null) {
  559.             sqlQueryObject.addWhereCondition("filtro_ruolo=?");
  560.             sqlQueryObject.addWhereCondition("filtro_porta=?");
  561.         }
  562.         else if(ruoloPorta!=null) {
  563.             sqlQueryObject.addWhereCondition("filtro_ruolo=?"); // se passo solo ruolo porta, voglio tutte le policy con quel ruolo. Altrimenti finisco nelle policy globali
  564.         }
  565.         else {
  566.             sqlQueryObject.addWhereIsNullCondition("filtro_porta");
  567.         }
  568.         if(search != null  && !"".equals(search)){
  569.             // fix: oramai l'alias e' obbligatorio
  570.             sqlQueryObject.addWhereCondition(false, 
  571.                     //sqlQueryObject.getWhereLikeCondition("active_policy_id", search, false, true, true),
  572.                     sqlQueryObject.getWhereLikeCondition("policy_alias", search, false, true, true));
  573.         }
  574.         if(tipoRisorsaPolicyAttiva!=null) {
  575.             sqlQueryObject.addWhereCondition(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY+".rt_risorsa=?");
  576.             sqlQueryObject.addWhereCondition(CostantiDB.CONTROLLO_TRAFFICO_CONFIG_POLICY+".rt_simultanee=?");
  577.         }
  578.         if(filtroSoggettoFruitore!=null) {
  579.             if(filtroSoggettoFruitore.getTipo()!=null) {
  580.                 sqlQueryObject.addWhereCondition("filtro_tipo_fruitore=?");
  581.             }
  582.             if(filtroSoggettoFruitore.getNome()!=null) {
  583.                 sqlQueryObject.addWhereCondition("filtro_nome_fruitore=?");
  584.             }
  585.         }
  586.         if(filtroApplicativoFruitore!=null) {
  587.             if(filtroApplicativoFruitore.getIdSoggettoProprietario()!=null) {
  588.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo()!=null) {
  589.                     sqlQueryObject.addWhereCondition("filtro_tipo_fruitore=?");
  590.                 }
  591.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getNome()!=null) {
  592.                     sqlQueryObject.addWhereCondition("filtro_nome_fruitore=?");
  593.                 }
  594.             }
  595.             if(filtroApplicativoFruitore.getNome()!=null) {
  596.                 sqlQueryObject.addWhereCondition("filtro_sa_fruitore=?");
  597.             }
  598.         }
  599.         if(filtroRuoloFruitore!=null) {
  600.             sqlQueryObject.addWhereCondition("filtro_ruolo_fruitore=?");
  601.         }
  602.         if(filtroSoggettoErogatore!=null) {
  603.             if(filtroSoggettoErogatore.getTipo()!=null) {
  604.                 sqlQueryObject.addWhereCondition("filtro_tipo_erogatore=?");
  605.             }
  606.             if(filtroSoggettoErogatore.getNome()!=null) {
  607.                 sqlQueryObject.addWhereCondition("filtro_nome_erogatore=?");
  608.             }
  609.         }
  610.         if(filtroRuoloErogatore!=null) {
  611.             sqlQueryObject.addWhereCondition("filtro_ruolo_erogatore=?");
  612.         }
  613.         if(filtroServizioAzione!=null) {
  614.             if(filtroServizioAzione.getSoggettoErogatore()!=null) {
  615.                 if(filtroServizioAzione.getSoggettoErogatore().getTipo()!=null) {
  616.                     sqlQueryObject.addWhereCondition("filtro_tipo_erogatore=?");
  617.                 }
  618.                 if(filtroServizioAzione.getSoggettoErogatore().getNome()!=null) {
  619.                     sqlQueryObject.addWhereCondition("filtro_nome_erogatore=?");
  620.                 }
  621.             }
  622.             if(filtroServizioAzione.getTipo()!=null) {
  623.                 sqlQueryObject.addWhereCondition("filtro_tipo_servizio=?");
  624.             }
  625.             if(filtroServizioAzione.getNome()!=null) {
  626.                 sqlQueryObject.addWhereCondition("filtro_nome_servizio=?");
  627.             }
  628.             if(filtroServizioAzione.getVersione()!=null) {
  629.                 sqlQueryObject.addWhereCondition("filtro_versione_servizio=?");
  630.             }
  631.             if(filtroServizioAzione.getAzione()!=null) {
  632.                 // condizione di controllo
  633.                 ISQLQueryObject sqlQueryObjectOr = SQLObjectFactory.createSQLQueryObject(tipoDB);
  634.                 sqlQueryObjectOr.setANDLogicOperator(false);
  635.                 // (filtro_azione == 'NOME') OR (filtro_azione like 'NOME,%') OR (filtro_azione like '%,NOME') OR (filtro_azione like '%,applicabilita_azioni,%')
  636.                 // CLOB sqlQueryObjectOr.addWhereCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione = ?");
  637.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", filtroServizioAzione.getAzione(), false , false);
  638.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", filtroServizioAzione.getAzione()+",", LikeConfig.startsWith(false));
  639.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", ","+filtroServizioAzione.getAzione(), LikeConfig.endsWith(false));
  640.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", ","+filtroServizioAzione.getAzione()+",", true , false);
  641.                 sqlQueryObject.addWhereCondition(sqlQueryObjectOr.createSQLConditions());
  642.             }
  643.         }
  644.         if(filtroRuolo!=null) {
  645.             sqlQueryObject.addWhereCondition(false, "filtro_ruolo_fruitore=?", "filtro_ruolo_erogatore=?");
  646.         }
  647.         return sqlQueryObject;
  648.     }
  649.     private static void _prepareStatementPolicyAttive(
  650.             String tipoDB,
  651.             PreparedStatement pstmt,
  652.             RuoloPolicy ruoloPorta, String nomePorta,
  653.             String search, TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva,
  654.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  655.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  656.             IDServizio filtroServizioAzione, String filtroRuolo) throws Exception {
  657.         int index = 1;
  658.         if(ruoloPorta!=null && nomePorta!=null) {
  659.             pstmt.setString(index++, ruoloPorta.getValue());
  660.             pstmt.setString(index++, nomePorta);
  661.         }
  662.         else if(ruoloPorta!=null) {
  663.             pstmt.setString(index++, ruoloPorta.getValue());
  664.         }
  665.         if(tipoRisorsaPolicyAttiva!=null) {
  666.             JDBCParameterUtilities utils = new JDBCParameterUtilities(TipiDatabase.toEnumConstant(tipoDB));
  667.             if(TipoRisorsaPolicyAttiva.NUMERO_RICHIESTE_SIMULTANEE.equals(tipoRisorsaPolicyAttiva)) {
  668.                 pstmt.setString(index++, TipoRisorsa.NUMERO_RICHIESTE.getValue());
  669.                 utils.setParameter(pstmt, index++, true, boolean.class);
  670.             }
  671.             else {
  672.                 pstmt.setString(index++, tipoRisorsaPolicyAttiva.getValue());
  673.                 utils.setParameter(pstmt, index++, false, boolean.class);
  674.             }
  675.         }
  676.         if(filtroSoggettoFruitore!=null) {
  677.             if(filtroSoggettoFruitore.getTipo()!=null) {
  678.                 pstmt.setString(index++, filtroSoggettoFruitore.getTipo());
  679.             }
  680.             if(filtroSoggettoFruitore.getNome()!=null) {
  681.                 pstmt.setString(index++, filtroSoggettoFruitore.getNome());
  682.             }
  683.         }
  684.         if(filtroApplicativoFruitore!=null) {
  685.             if(filtroApplicativoFruitore.getIdSoggettoProprietario()!=null) {
  686.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo()!=null) {
  687.                     pstmt.setString(index++, filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo());
  688.                 }
  689.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getNome()!=null) {
  690.                     pstmt.setString(index++, filtroApplicativoFruitore.getIdSoggettoProprietario().getNome());
  691.                 }
  692.             }
  693.             if(filtroApplicativoFruitore.getNome()!=null) {
  694.                 pstmt.setString(index++, filtroApplicativoFruitore.getNome());
  695.             }
  696.         }
  697.         if(filtroRuoloFruitore!=null) {
  698.             pstmt.setString(index++, filtroRuoloFruitore);
  699.         }
  700.         if(filtroSoggettoErogatore!=null) {
  701.             if(filtroSoggettoErogatore.getTipo()!=null) {
  702.                 pstmt.setString(index++, filtroSoggettoErogatore.getTipo());
  703.             }
  704.             if(filtroSoggettoErogatore.getNome()!=null) {
  705.                 pstmt.setString(index++, filtroSoggettoErogatore.getNome());
  706.             }
  707.         }
  708.         if(filtroRuoloErogatore!=null) {
  709.             pstmt.setString(index++, filtroRuoloErogatore);
  710.         }
  711.         if(filtroServizioAzione!=null) {
  712.             if(filtroServizioAzione.getSoggettoErogatore()!=null) {
  713.                 if(filtroServizioAzione.getSoggettoErogatore().getTipo()!=null) {
  714.                     pstmt.setString(index++, filtroServizioAzione.getSoggettoErogatore().getTipo());
  715.                 }
  716.                 if(filtroServizioAzione.getSoggettoErogatore().getNome()!=null) {
  717.                     pstmt.setString(index++, filtroServizioAzione.getSoggettoErogatore().getNome());
  718.                 }
  719.             }
  720.             if(filtroServizioAzione.getTipo()!=null) {
  721.                 pstmt.setString(index++, filtroServizioAzione.getTipo());
  722.             }
  723.             if(filtroServizioAzione.getNome()!=null) {
  724.                 pstmt.setString(index++, filtroServizioAzione.getNome());
  725.             }
  726.             if(filtroServizioAzione.getVersione()!=null) {
  727.                 pstmt.setInt(index++, filtroServizioAzione.getVersione());
  728.             }
  729.             if(filtroServizioAzione.getAzione()!=null) {
  730.                 // inserito direttamente nella preparazione
  731.             }
  732.         }
  733.         if(filtroRuolo!=null) {
  734.             pstmt.setString(index++, filtroRuolo);
  735.             pstmt.setString(index++, filtroRuolo);
  736.         }
  737.     }
  738.     
  739.     public static AttivazionePolicy getAttivazionePolicy(String alias, RuoloPolicy ruoloPorta, String nomePorta,Connection con, Logger log, String tipoDB) throws ServiceException, NotFoundException{
  740.         String nomeMetodo = "configurazioneControlloTrafficoAttivazionePolicyList";
  741.         // ritorna la configurazione controllo del traffico della PdD
  742.         
  743.         AttivazionePolicy policy = null;
  744.         
  745.         try {
  746.             
  747.             ServiceManagerProperties properties = new ServiceManagerProperties();
  748.             properties.setDatabaseType(tipoDB);
  749.             properties.setShowSql(true);
  750.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  751.             
  752.             IExpression expr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  753.             
  754.             expr.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, ruoloPorta);
  755.             expr.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA, nomePorta);
  756.             expr.equals(AttivazionePolicy.model().ALIAS, alias);
  757.                         
  758.             policy = serviceManager.getAttivazionePolicyServiceSearch().find(expr);
  759.             if(policy==null) {
  760.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  761.             }
  762.         } catch(NotFoundException notFound) {
  763.             throw notFound;
  764.         } 
  765.         catch (Exception qe) {
  766.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  767.         } 
  768.         
  769.         return policy;
  770.     }
  771.     
  772.     
  773.     public static List<InfoPolicy> getInfoPolicyList(Boolean builtIn, String idPolicyParam,Connection con, Logger log, String tipoDB) throws ServiceException{
  774.         String nomeMetodo = "getInfoPolicyList";
  775.         // ritorna la configurazione controllo del traffico della PdD
  776.         int offset = 0;
  777.         int limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  778.         
  779.         List<InfoPolicy> listaPolicy = new ArrayList<InfoPolicy>();
  780.         
  781.         try {
  782.             
  783.             ServiceManagerProperties properties = new ServiceManagerProperties();
  784.             properties.setDatabaseType(tipoDB);
  785.             properties.setShowSql(true);
  786.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  787.             
  788.             IExpression expr = serviceManager.getConfigurazionePolicyServiceSearch().newExpression();
  789.             
  790.             if(idPolicyParam != null  && !"".equals(idPolicyParam)){
  791.                 expr.equals(ConfigurazionePolicy.model().ID_POLICY, idPolicyParam);
  792.             }
  793.             if(builtIn!=null) {
  794.                 expr.equals(ConfigurazionePolicy.model().BUILT_IN, builtIn);
  795.             }
  796.             
  797.             IPaginatedExpression pagExpr = serviceManager.getConfigurazionePolicyServiceSearch().toPaginatedExpression(expr);
  798.             pagExpr.offset(offset).limit(limit);
  799.             pagExpr.sortOrder(SortOrder.ASC);
  800.             pagExpr.addOrder(ConfigurazionePolicy.model().ID_POLICY);
  801.             
  802.             List<java.util.Map<String, Object>> mapList = null;
  803.             try{
  804.                 mapList = serviceManager.getConfigurazionePolicyServiceSearch().select(pagExpr, 
  805.                         ConfigurazionePolicy.model().ID_POLICY,
  806.                         ConfigurazionePolicy.model().RISORSA,
  807.                         ConfigurazionePolicy.model().BUILT_IN,
  808.                         ConfigurazionePolicy.model().DESCRIZIONE,
  809.                         ConfigurazionePolicy.model().VALORE,
  810.                         ConfigurazionePolicy.model().VALORE_2,
  811.                         ConfigurazionePolicy.model().SIMULTANEE,
  812.                         ConfigurazionePolicy.model().MODALITA_CONTROLLO,
  813.                         ConfigurazionePolicy.model().TIPO_INTERVALLO_OSSERVAZIONE_REALTIME,
  814.                         ConfigurazionePolicy.model().TIPO_INTERVALLO_OSSERVAZIONE_STATISTICO,
  815.                         ConfigurazionePolicy.model().TIPO_APPLICABILITA,
  816.                         ConfigurazionePolicy.model().APPLICABILITA_CON_CONGESTIONE,
  817.                         ConfigurazionePolicy.model().APPLICABILITA_DEGRADO_PRESTAZIONALE,
  818.                         ConfigurazionePolicy.model().DEGRADO_AVG_TIME_MODALITA_CONTROLLO
  819.                         );
  820.             }catch(NotFoundException notFound){}
  821.             if(mapList!=null){
  822.                 // caso get puntuale
  823.                 if(idPolicyParam != null  && !"".equals(idPolicyParam) && mapList.size()>1){
  824.                     throw new Exception("More than one results ("+mapList.size()+")");
  825.                 }
  826.                 
  827.                 
  828.                 for (java.util.Map<String, Object> map : mapList) {
  829.                     String idPolicy = (String) map.get(ConfigurazionePolicy.model().ID_POLICY.getFieldName());
  830.                     String resource = (String) map.get(ConfigurazionePolicy.model().RISORSA.getFieldName());
  831.                     InfoPolicy info = new InfoPolicy();
  832.                     info.setIdPolicy(idPolicy);
  833.                     info.setTipoRisorsa(TipoRisorsa.toEnumConstant(resource, true));
  834.                     
  835.                     Object builtInValue =  map.get(ConfigurazionePolicy.model().BUILT_IN.getFieldName());
  836.                     if(builtInValue!=null && builtInValue instanceof Boolean){
  837.                         info.setBuiltIn((Boolean)builtInValue);
  838.                     }
  839.                     
  840.                     Object descr =  map.get(ConfigurazionePolicy.model().DESCRIZIONE.getFieldName());
  841.                     if(descr!=null && descr instanceof String){
  842.                         info.setDescrizione((String)descr);
  843.                     }
  844.                     
  845.                     Object v =  map.get(ConfigurazionePolicy.model().VALORE.getFieldName());
  846.                     if(v!=null && v instanceof Long){
  847.                         info.setValore((Long)v);
  848.                     }
  849.                     
  850.                     Object v2 =  map.get(ConfigurazionePolicy.model().VALORE_2.getFieldName());
  851.                     if(v2!=null && v2 instanceof Long){
  852.                         info.setValore2((Long)v2);
  853.                     }
  854.                                         
  855.                     Object simultanee =  map.get(ConfigurazionePolicy.model().SIMULTANEE.getFieldName());
  856.                     if(simultanee!=null && simultanee instanceof Boolean){
  857.                         boolean simultaneeBoolean = (Boolean) simultanee;
  858.                         info.setCheckRichiesteSimultanee(simultaneeBoolean);
  859.                         if(!simultaneeBoolean){
  860.                             Object controllo =  map.get(ConfigurazionePolicy.model().MODALITA_CONTROLLO.getFieldName());
  861.                             if(controllo!=null && controllo instanceof String){
  862.                                 TipoControlloPeriodo tipo = TipoControlloPeriodo.toEnumConstant((String)controllo, true);
  863.                                 info.setIntervalloUtilizzaRisorseStatistiche(TipoControlloPeriodo.STATISTIC.equals(tipo));
  864.                                 info.setIntervalloUtilizzaRisorseRealtime(TipoControlloPeriodo.REALTIME.equals(tipo));
  865.                                 if(info.isIntervalloUtilizzaRisorseStatistiche()) {
  866.                                     Object tipoPeriodo =  map.get(ConfigurazionePolicy.model().TIPO_INTERVALLO_OSSERVAZIONE_STATISTICO.getFieldName());
  867.                                     if(tipoPeriodo!=null) {
  868.                                         info.setIntervalloUtilizzaRisorseStatisticheTipoPeriodo(TipoPeriodoStatistico.toEnumConstant((String)tipoPeriodo,true));
  869.                                     }
  870.                                 }
  871.                                 if(info.isIntervalloUtilizzaRisorseRealtime()) {
  872.                                     Object tipoPeriodo =  map.get(ConfigurazionePolicy.model().TIPO_INTERVALLO_OSSERVAZIONE_REALTIME.getFieldName());
  873.                                     if(tipoPeriodo!=null) {
  874.                                         info.setIntervalloUtilizzaRisorseRealtimeTipoPeriodo(TipoPeriodoRealtime.toEnumConstant((String)tipoPeriodo,true));
  875.                                     }
  876.                                 }
  877.                             }
  878.                         }
  879.                     }
  880.                                         
  881.                         
  882.                     // verifico anche degrado prestazionale
  883.                     Object app =  map.get(ConfigurazionePolicy.model().TIPO_APPLICABILITA.getFieldName());
  884.                     if(app!=null && app instanceof String){
  885.                         TipoApplicabilita tipoApplicabilita = TipoApplicabilita.toEnumConstant((String)app, true);
  886.                         if(TipoApplicabilita.CONDIZIONALE.equals(tipoApplicabilita)){
  887.                             
  888.                             Object enabledCongestione =  map.get(ConfigurazionePolicy.model().APPLICABILITA_CON_CONGESTIONE.getFieldName());
  889.                             boolean congestione = false;   
  890.                             if(enabledCongestione!=null && (enabledCongestione instanceof Boolean)){
  891.                                 congestione = (Boolean)enabledCongestione;
  892.                             }
  893.                             if(congestione){
  894.                                 info.setControlloCongestione(true);
  895.                             }
  896.                             
  897.                             Object enabled =  map.get(ConfigurazionePolicy.model().APPLICABILITA_DEGRADO_PRESTAZIONALE.getFieldName());
  898.                             boolean degrado = false;   
  899.                             if(enabled!=null && (enabled instanceof Boolean)){
  900.                                 degrado = (Boolean)enabled;
  901.                             }
  902.                             if(degrado){
  903.                                 Object controllo =  map.get(ConfigurazionePolicy.model().DEGRADO_AVG_TIME_MODALITA_CONTROLLO.getFieldName());
  904.                                 if(controllo!=null && controllo instanceof String){
  905.                                     TipoControlloPeriodo tipo = TipoControlloPeriodo.toEnumConstant((String)controllo, true);
  906.                                     info.setDegradoPrestazionaleUtilizzaRisorseStatistiche(TipoControlloPeriodo.STATISTIC.equals(tipo));
  907.                                     info.setDegradoPrestazionaleUtilizzaRisorseRealtime(TipoControlloPeriodo.REALTIME.equals(tipo));
  908.                                     info.setDegradoPrestazione(true);
  909.                                 }
  910.                             }
  911.                         }
  912.                     }

  914.                     
  915.                     listaPolicy.add(info);
  916.                 }
  917.             }
  918.         } catch (Exception qe) {
  919.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  920.         } 
  921.         
  922.         return listaPolicy;
  923.     }
  924.     
  925.     public static List<AttivazionePolicy> findInUseAttivazioni(String idPolicy, boolean escludiDisabilitate, Connection con, Logger log, String tipoDB) throws ServiceException{
  926.         String nomeMetodo = "findInUseAttivazioni";
  927.         // ritorna la configurazione controllo del traffico della PdD
  928.         int offset = 0;
  929.         int limit = 10000 ;  // valore altissimo che non dovrebbe accadare
  930.         
  931.         
  932.         List<AttivazionePolicy> listaPolicy = new ArrayList<AttivazionePolicy>();
  933.         
  934.         try {
  935.             
  936.             ServiceManagerProperties properties = new ServiceManagerProperties();
  937.             properties.setDatabaseType(tipoDB);
  938.             properties.setShowSql(true);
  939.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  940.             
  941.             IExpression expr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  942.             
  943.             expr.equals(AttivazionePolicy.model().ID_POLICY, idPolicy);
  944.             if(escludiDisabilitate) {
  945.                 expr.equals(AttivazionePolicy.model().ENABLED, true);
  946.             }
  947.         
  948.             IPaginatedExpression pagExpr = serviceManager.getAttivazionePolicyServiceSearch().toPaginatedExpression(expr);
  949.             pagExpr.offset(offset).limit(limit);
  950.             pagExpr.sortOrder(SortOrder.ASC);
  951.             pagExpr.addOrder(AttivazionePolicy.model().ALIAS);
  952.             pagExpr.addOrder(AttivazionePolicy.model().ID_POLICY);
  953.             
  954.             listaPolicy = serviceManager.getAttivazionePolicyServiceSearch().findAll(pagExpr);
  955.         } catch (Exception qe) {
  956.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  957.         }
  958.         
  959.         return listaPolicy;
  960.     }
  961.     
  962.     public static long countInUseAttivazioni(String idPolicy, boolean escludiDisabilitate, Connection con, Logger log, String tipoDB) throws ServiceException{
  963.         String nomeMetodo = "countInUseAttivazioni";
  964.         // ritorna la configurazione controllo del traffico della PdD
  965.         
  966.         try {
  967.             
  968.             ServiceManagerProperties properties = new ServiceManagerProperties();
  969.             properties.setDatabaseType(tipoDB);
  970.             properties.setShowSql(true);
  971.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  972.             
  973.             IExpression expr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  974.             
  975.             expr.equals(AttivazionePolicy.model().ID_POLICY, idPolicy);
  976.             if(escludiDisabilitate) {
  977.                 expr.equals(AttivazionePolicy.model().ENABLED, true);
  978.             }
  979.             
  980.             NonNegativeNumber nnn = serviceManager.getAttivazionePolicyServiceSearch().count(expr);
  981.             return nnn != null ? nnn.longValue(): 0;
  982.         } catch (Exception qe) {
  983.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  984.         } 
  985.     }
  986.     
  987.     public static ConfigurazionePolicy getConfigurazionePolicy(long id, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  988.         String nomeMetodo = "getConfigurazionePolicy";

  990.         ConfigurazionePolicy policy = null;
  991.         
  992.         try {
  993.             
  994.             ServiceManagerProperties properties = new ServiceManagerProperties();
  995.             properties.setDatabaseType(tipoDB);
  996.             properties.setShowSql(true);
  997.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  998.             policy = ((IDBConfigurazionePolicyServiceSearch)serviceManager.getConfigurazionePolicyServiceSearch()).get(id);
  999.         }catch (NotFoundException e) {
  1000.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1001.         } catch (Exception qe) {
  1002.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1003.         }
  1004.         
  1005.         return policy;
  1006.     }
  1007.     
  1008.     public static ConfigurazionePolicy getConfigurazionePolicy(String nomePolicy, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1009.         String nomeMetodo = "getConfigurazionePolicy";
  1010.         
  1011.         ConfigurazionePolicy policy = null;
  1012.         
  1013.         try {
  1014.             
  1015.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1016.             properties.setDatabaseType(tipoDB);
  1017.             properties.setShowSql(true);
  1018.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1019.             
  1020.             IdPolicy id = new IdPolicy();
  1021.             id.setNome(nomePolicy);
  1022.             policy = serviceManager.getConfigurazionePolicyServiceSearch().get(id);
  1023.         }catch (NotFoundException e) {
  1024.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1025.         } catch (Exception qe) {
  1026.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1027.         }
  1028.         
  1029.         return policy;
  1030.     }

  1032.     public static void createConfigurazionePolicy(ConfigurazionePolicy policy, Connection con, Logger log, String tipoDB) throws ServiceException{
  1033.         String nomeMetodo = "createConfigurazionePolicy";
  1034.         
  1035.         try {
  1036.             
  1037.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1038.             properties.setDatabaseType(tipoDB);
  1039.             properties.setShowSql(true);
  1040.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1041.             
  1042.             serviceManager.getConfigurazionePolicyService().create(policy); 
  1043.             
  1044.         } catch (Exception qe) {
  1045.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1046.         }
  1047.     }

  1049.     public static void createAttivazionePolicy(AttivazionePolicy policy, Connection con, Logger log, String tipoDB) throws ServiceException {
  1050.         String nomeMetodo = "createAttivazionePolicy";

  1052.         try {
  1053.             
  1054.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1055.             properties.setDatabaseType(tipoDB);
  1056.             properties.setShowSql(true);
  1057.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1058.             
  1059.             serviceManager.getAttivazionePolicyService().create(policy);
  1060.             
  1061.         } catch (Exception qe) {
  1062.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1063.         }
  1064.     }

  1066.     public static void updateConfigurazionePolicy(ConfigurazionePolicy policy, Connection con, Logger log, String tipoDB)throws ServiceException,NotFoundException{
  1067.         String nomeMetodo = "updateConfigurazionePolicy";
  1068.         
  1069.         try {

  1071.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1072.             properties.setDatabaseType(tipoDB);
  1073.             properties.setShowSql(true);
  1074.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1075.             
  1076.             IdPolicy idToUpdate = new IdPolicy();
  1077.             
  1078.             if(policy.getOldIdPolicy()!=null){
  1079.                 idToUpdate.setNome(policy.getOldIdPolicy().getNome());
  1080.             }
  1081.             else{
  1082.                 idToUpdate.setNome(policy.getIdPolicy());
  1083.             }
  1084.             
  1085.             // ElencoPolicyModificareInSeguitoModificaSogliaPolicy
  1086.             List<AttivazionePolicy> listPolicyAttiveConStatoDisabilitato = findInUseAttivazioni(idToUpdate.getNome(), true, con, log, tipoDB);
  1087.             
  1088.             if(listPolicyAttiveConStatoDisabilitato !=null && listPolicyAttiveConStatoDisabilitato.size()>0) {
  1089.                 //System.out.println("UPDATEEEEEEE SOGLIA ("+listPolicyAttiveConStatoDisabilitato.size()+") DISABILITO");
  1090.                 Map<String, Boolean> mapStati = new HashMap<String, Boolean>();
  1091.                 // NOTA: Devo fare la dobbia modifica perche' c'e' un controllo sul livello db layer che verifica se ci sono state modifiche
  1092.                 for (AttivazionePolicy ap : listPolicyAttiveConStatoDisabilitato) {
  1093.                     IdActivePolicy idActivePolicy = new IdActivePolicy();
  1094.                     idActivePolicy.setNome(ap.getIdActivePolicy());
  1095.                     mapStati.put(ap.getIdActivePolicy(), ap.isEnabled());
  1096.                     //System.out.println("SALVATO ["+ap.getIdActivePolicy()+"] = ["+ap.isEnabled()+"]");
  1097.                     ap.setEnabled(false);
  1098.                     //System.out.println("UPDATEEEEEEE SOGLIA ("+ap.getIdActivePolicy()+") CON STATO=FALSE");
  1099.                     serviceManager.getAttivazionePolicyService().update(idActivePolicy,ap);
  1100.                 }
  1101.                 
  1102.                 for (AttivazionePolicy ap : listPolicyAttiveConStatoDisabilitato) {
  1103.                     IdActivePolicy idActivePolicy = new IdActivePolicy();
  1104.                     idActivePolicy.setNome(ap.getIdActivePolicy());
  1105.                     //System.out.println("RIPRISTINO ["+ap.getIdActivePolicy()+"] = ["+mapStati.get(ap.getIdActivePolicy())+"]");
  1106.                     ap.setEnabled(mapStati.get(ap.getIdActivePolicy()));
  1107.                     //System.out.println("UPDATE SOGLIA ("+ap.getIdActivePolicy()+") CON STATO=true");
  1108.                     serviceManager.getAttivazionePolicyService().update(idActivePolicy,ap);
  1109.                 }
  1110.             }
  1111.             
  1112.             serviceManager.getConfigurazionePolicyService().update(idToUpdate, policy); 
  1113.             
  1114.         }catch (NotFoundException e) {
  1115.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1116.         } catch (Exception qe) {
  1117.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1118.         }
  1119.     }

  1121.     public static void updateAttivazionePolicy(AttivazionePolicy policy, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1122.         String nomeMetodo = "updateAttivazionePolicy";
  1123.         
  1124.         try {
  1125.             
  1126.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1127.             properties.setDatabaseType(tipoDB);
  1128.             properties.setShowSql(true);
  1129.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1130.             
  1131.             IdActivePolicy id = new IdActivePolicy();
  1132.             id.setNome(policy.getIdActivePolicy()); 
  1133.             serviceManager.getAttivazionePolicyService().update(id, policy); 
  1134.             
  1135.         }catch (NotFoundException e) {
  1136.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1137.         } catch (Exception qe) {
  1138.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1139.         }
  1140.     }

  1142.     public static void deleteConfigurazionePolicy(ConfigurazionePolicy policy, Connection con, Logger log, String tipoDB) throws ServiceException {
  1143.         String nomeMetodo = "deleteConfigurazionePolicy";
  1144.         
  1145.         try {
  1146.             
  1147.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1148.             properties.setDatabaseType(tipoDB);
  1149.             properties.setShowSql(true);
  1150.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1151.             
  1152.             serviceManager.getConfigurazionePolicyService().delete(policy); 
  1153.             
  1154.         } catch (Exception qe) {
  1155.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1156.         }
  1157.     }

  1159.     public static void deleteAttivazionePolicy(AttivazionePolicy policy, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1160.         String nomeMetodo = "deleteAttivazionePolicy";
  1161.         
  1162.         try {
  1163.             
  1164.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1165.             properties.setDatabaseType(tipoDB);
  1166.             properties.setShowSql(true);
  1167.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1168.             
  1169.             serviceManager.getAttivazionePolicyService().delete(policy);
  1170.             
  1171.         } catch (Exception qe) {
  1172.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1173.         } 
  1174.     }
  1175.     
  1176.     public static AttivazionePolicy getAttivazionePolicy(long id, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1177.         String nomeMetodo = "getAttivazionePolicy"; 
  1178.         
  1179.         AttivazionePolicy policy = null;
  1180.         
  1181.         try {
  1182.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1183.             properties.setDatabaseType(tipoDB);
  1184.             properties.setShowSql(true);
  1185.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1186.             policy = ((IDBAttivazionePolicyServiceSearch)serviceManager.getAttivazionePolicyServiceSearch()).get(id);
  1187.         }catch (NotFoundException e) {
  1188.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1189.         } catch (Exception qe) {
  1190.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1191.         } 
  1192.         
  1193.         return policy;
  1194.     }
  1195.     
  1196.     public static AttivazionePolicy getAttivazionePolicy(String nomePolicy, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1197.         String nomeMetodo = "getAttivazionePolicy"; 
  1198.         
  1199.         AttivazionePolicy policy = null;
  1200.         
  1201.         try {
  1202.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1203.             properties.setDatabaseType(tipoDB);
  1204.             properties.setShowSql(true);
  1205.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1206.             IdActivePolicy idPolicy = new IdActivePolicy();
  1207.             idPolicy.setNome(nomePolicy);
  1208.             policy = serviceManager.getAttivazionePolicyServiceSearch().get(idPolicy);
  1209.             
  1210.         }catch (NotFoundException e) {
  1211.             throw new NotFoundException("[" + nomeMetodo + "] Configurazione Policy non presente.");
  1212.         } catch (Exception qe) {
  1213.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1214.         }
  1215.         
  1216.         return policy;
  1217.     }
  1218.     
  1219.     // OLD private static String FREE_COUNTER_SEPARATOR_CHAR = ":";
  1220.     // Modifico per implementare nuovo meccanismo di ordinamento
  1221.     private static String FREE_COUNTER_SEPARATOR_CHAR = "@";
  1222.     private static int FREE_COUNTER_SEPARATOR_CHAR_PAD = 19; // colonna che memorizza l'info ha dimensione 275
  1223.     public static String buildIdActivePolicy(String idPolicy, String serialId) {
  1224.         String idActive = idPolicy+ControlloTrafficoDriverUtils.FREE_COUNTER_SEPARATOR_CHAR+serialId;
  1225.         return idActive;
  1226.     }
  1227.     
  1228.     private static String normalizePolicyInstanceSerialId(int value) {
  1229.         return StringUtils.leftPad(value+"", FREE_COUNTER_SEPARATOR_CHAR_PAD, "0");
  1230.     }
  1231.     public static String incrementPolicyInstanceSerialId(String value) {
  1232.         int valueInt = 0;
  1233.         if(value!=null && !"".equals(value)) {
  1234.             StringBuilder sb = new StringBuilder();
  1235.             for (int i = 0; i < value.length(); i++) {
  1236.                 char c = value.charAt(i);
  1237.                 if('0' == c && sb.length()<=0) {
  1238.                     continue;
  1239.                 }
  1240.                 sb.append(c);
  1241.             }
  1242.             valueInt = Integer.valueOf(sb.toString());
  1243.         }
  1244.         valueInt++;
  1245.         return StringUtils.leftPad(valueInt+"", FREE_COUNTER_SEPARATOR_CHAR_PAD, "0");
  1246.     }
  1247.     
  1248.     //public static Integer getFreeCounterForGlobalPolicy(String policyId, Connection con, Logger log, String tipoDB) throws ServiceException{
  1249.     public static String getNextPolicyInstanceSerialId(String policyId, Connection con, Logger log, String tipoDB) throws ServiceException{
  1250.         String nomeMetodo = "getNextPolicyInstanceSerialId"; 
  1251.         
  1252.         
  1253.         try{
  1254.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1255.             properties.setDatabaseType(tipoDB);
  1256.             properties.setShowSql(true);
  1257.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1258.             
  1259.             IExpression pagExpr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  1260.             pagExpr.and();
  1261.             pagExpr.equals(AttivazionePolicy.model().ID_POLICY, policyId);
  1262.             
  1263.             // non funziona perchรจ :10 viene ordinato prima di :9
  1264.             //pagExpr.addOrder(AttivazionePolicy.model().ID_ACTIVE_POLICY, SortOrder.DESC);
  1265.             //pagExpr.limit(1);
  1266.             // devo scorrerle tutte
  1267.             
  1268.             /*
  1269.             try{
  1270.                 // inefficiente
  1271.                 List<Object> list = serviceManager.getAttivazionePolicyServiceSearch().select(pagExpr, AttivazionePolicy.model().ID_ACTIVE_POLICY);
  1272.                 if(list!=null && !list.isEmpty()){
  1273.                     int found = -1;
  1274.                     for (Object r : list) {
  1275.                         if(r instanceof String){
  1276.                             String s = (String)r;
  1277.                             if(s.contains(FREE_COUNTER_SEPARATOR_CHAR)){
  1278.                                 int last = s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR);
  1279.                                 if(last<(s.length()-1)){
  1280.                                     int value = Integer.parseInt(s.substring(s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR)+1,s.length()));
  1281.                                     if(value > found) {
  1282.                                         found = value;
  1283.                                     }
  1284.                                 }
  1285.                             }
  1286.                         }   
  1287.                     }
  1288.                     if(found>0) {
  1289.                         return found+1;
  1290.                     }
  1291.                 }
  1292.             }catch(NotFoundException notF){
  1293.                 
  1294.             }
  1295.             return 1;
  1296.             */
  1297.             
  1298.             FunctionField ff = new FunctionField(AttivazionePolicy.model().ID_ACTIVE_POLICY, Function.MAX, "maxIdActivePolicy");
  1299.             Object maxValue = null;
  1300.             try {
  1301.                 maxValue = serviceManager.getAttivazionePolicyServiceSearch().aggregate(pagExpr, ff);
  1302.             }catch(NotFoundException notFound) {
  1303.             }
  1304.             if(maxValue!=null){
  1305.                 if(maxValue instanceof String){
  1306.                     String s = (String)maxValue;
  1307.                     if(s.contains(FREE_COUNTER_SEPARATOR_CHAR)){
  1308.                         int last = s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR);
  1309.                         if(last<(s.length()-1)){
  1310.                             String actualMaxValue = s.substring(s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR)+1,s.length());
  1311.                             return incrementPolicyInstanceSerialId(actualMaxValue);
  1312.                         }
  1313.                     }
  1314.                     else {  
  1315.                         // backward compatibility
  1316.                         // si tratta di un valore vecchio registrato con il precedente formato, devo considerare solo quelli con il nuovo formato.
  1317.                         pagExpr.like(AttivazionePolicy.model().ID_ACTIVE_POLICY, FREE_COUNTER_SEPARATOR_CHAR, LikeMode.ANYWHERE);
  1318.                             
  1319.                         maxValue = null;
  1320.                         try {
  1321.                             maxValue = serviceManager.getAttivazionePolicyServiceSearch().aggregate(pagExpr, ff);
  1322.                         }catch(NotFoundException notFound) {
  1323.                         }
  1324.                         if(maxValue!=null){
  1325.                             if(maxValue instanceof String){
  1326.                                 s = (String)maxValue;
  1327.                                 if(s.contains(FREE_COUNTER_SEPARATOR_CHAR)){
  1328.                                     int last = s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR);
  1329.                                     if(last<(s.length()-1)){
  1330.                                         String actualMaxValue = s.substring(s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR)+1,s.length());
  1331.                                         return incrementPolicyInstanceSerialId(actualMaxValue);
  1332.                                     }
  1333.                                 }
  1334.                             }   
  1335.                         }
  1336.                     }
  1337.                 }   
  1338.             }
  1339.             return normalizePolicyInstanceSerialId(1);
  1340.             
  1341.         } catch (Exception qe) {
  1342.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1343.         }
  1344.     }
  1345.     
  1346.     public static AttivazionePolicy getPolicy(String policyId, AttivazionePolicyFiltro filtroParam, AttivazionePolicyRaggruppamento groupBy,
  1347.             RuoloPolicy ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1348.         String nomeMetodo = "getPolicy"; 
  1349.         
  1350.         try{
  1351.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1352.             properties.setDatabaseType(tipoDB);
  1353.             properties.setShowSql(true);
  1354.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1355.             IExpression expression = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  1356.             
  1357.             expression.and();
  1358.             expression.equals(AttivazionePolicy.model().ID_POLICY, policyId);
  1359.             
  1360.             AttivazionePolicyFiltro filtro = filtroParam;
  1361.             if(ruoloPorta!=null && nomePorta!=null) {
  1362.                 filtro.setEnabled(true);
  1363.                 filtro.setRuoloPorta(ruoloPorta);
  1364.                 filtro.setNomePorta(nomePorta);
  1365.             }
  1366.             else {
  1367.                 expression.isNull(AttivazionePolicy.model().FILTRO.NOME_PORTA);
  1368.             }
  1369.             
  1370.             expression.equals(AttivazionePolicy.model().FILTRO.ENABLED, filtro.isEnabled());
  1371.             if(filtro.isEnabled()){
  1372.                 if(filtro.getRuoloPorta()!=null){
  1373.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, filtro.getRuoloPorta());
  1374.                 }
  1375.                 else{
  1376.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, RuoloPolicy.ENTRAMBI);
  1377.                 }
  1378.                 
  1379.                 if(filtro.getNomePorta()!=null){
  1380.                     expression.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA, filtro.getNomePorta());
  1381.                 }
  1382.                 else{
  1383.                     expression.isNull(AttivazionePolicy.model().FILTRO.NOME_PORTA);
  1384.                 }
  1385.                     
  1386.                 if(filtro.getProtocollo()!=null){
  1387.                     expression.equals(AttivazionePolicy.model().FILTRO.PROTOCOLLO, filtro.getProtocollo());
  1388.                 }
  1389.                 else{
  1390.                     expression.isNull(AttivazionePolicy.model().FILTRO.PROTOCOLLO);
  1391.                 }
  1392.                 
  1393.                 if(filtro.getRuoloErogatore()!=null){
  1394.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE, filtro.getRuoloErogatore());
  1395.                 }
  1396.                 else{
  1397.                     expression.isNull(AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE);
  1398.                 }
  1399.                 
  1400.                 if(filtro.getTipoErogatore()!=null){
  1401.                     expression.equals(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE, filtro.getTipoErogatore());
  1402.                 }
  1403.                 else{
  1404.                     expression.isNull(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE);
  1405.                 }
  1406.                 if(filtro.getNomeErogatore()!=null){
  1407.                     expression.equals(AttivazionePolicy.model().FILTRO.NOME_EROGATORE, filtro.getNomeErogatore());
  1408.                 }
  1409.                 else{
  1410.                     expression.isNull(AttivazionePolicy.model().FILTRO.NOME_EROGATORE);
  1411.                 }
  1412.         
  1413.                 if(filtro.getTag()!=null){
  1414.                     expression.equals(AttivazionePolicy.model().FILTRO.TAG, filtro.getTag());
  1415.                 }
  1416.                 else{
  1417.                     expression.isNull(AttivazionePolicy.model().FILTRO.TAG);
  1418.                 }
  1419.                                 
  1420.                 if(filtro.getTipoServizio()!=null){
  1421.                     expression.equals(AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO, filtro.getTipoServizio());
  1422.                 }
  1423.                 else{
  1424.                     expression.isNull(AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO);
  1425.                 }
  1426.                 if(filtro.getNomeServizio()!=null){
  1427.                     expression.equals(AttivazionePolicy.model().FILTRO.NOME_SERVIZIO, filtro.getNomeServizio());
  1428.                 }
  1429.                 else{
  1430.                     expression.isNull(AttivazionePolicy.model().FILTRO.NOME_SERVIZIO);
  1431.                 }
  1432.                 if(filtro.getVersioneServizio()!=null){
  1433.                     expression.equals(AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO, filtro.getVersioneServizio());
  1434.                 }
  1435.                 else{
  1436.                     expression.isNull(AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO);
  1437.                 }
  1438.                 
  1439.                 if(filtro.getAzione()!=null && !"".equals(filtro.getAzione())){
  1440.                     expression.like(AttivazionePolicy.model().FILTRO.AZIONE, filtro.getAzione(), LikeMode.EXACT); // Colonna CLOB
  1441.                 }
  1442.                 else{
  1443.                     expression.isNull(AttivazionePolicy.model().FILTRO.AZIONE);
  1444.                 }
  1445.                 
  1446.                 if(filtro.getServizioApplicativoErogatore()!=null){
  1447.                     expression.equals(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE, filtro.getServizioApplicativoErogatore());
  1448.                 }
  1449.                 else{
  1450.                     expression.isNull(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE);
  1451.                 }
  1452.                 
  1453.                 if(filtro.getRuoloFruitore()!=null){
  1454.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE, filtro.getRuoloFruitore());
  1455.                 }
  1456.                 else{
  1457.                     expression.isNull(AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE);
  1458.                 }
  1459.                 
  1460.                 if(filtro.getTipoFruitore()!=null){
  1461.                     expression.equals(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE, filtro.getTipoFruitore());
  1462.                 }
  1463.                 else{
  1464.                     expression.isNull(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE);
  1465.                 }
  1466.                 if(filtro.getNomeFruitore()!=null){
  1467.                     expression.equals(AttivazionePolicy.model().FILTRO.NOME_FRUITORE, filtro.getNomeFruitore());
  1468.                 }
  1469.                 else{
  1470.                     expression.isNull(AttivazionePolicy.model().FILTRO.NOME_FRUITORE);
  1471.                 }
  1472.                 
  1473.                 if(filtro.getServizioApplicativoFruitore()!=null){
  1474.                     expression.equals(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE, filtro.getServizioApplicativoFruitore());
  1475.                 }
  1476.                 else{
  1477.                     expression.isNull(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE);
  1478.                 }
  1479.                 
  1480.                 if(filtro.getTokenClaims()!=null){
  1481.                     expression.like(AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS, filtro.getTokenClaims(), LikeMode.EXACT); // Colonna CLOB
  1482.                 }
  1483.                 else{
  1484.                     expression.isNull(AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS);
  1485.                 }
  1486.                 
  1487.                 expression.equals(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED, filtro.isInformazioneApplicativaEnabled());
  1488.                 if(filtro.isInformazioneApplicativaEnabled() &&
  1489.                         filtro.getInformazioneApplicativaTipo()!=null &&
  1490.                         filtro.getInformazioneApplicativaNome()!=null &&
  1491.                         filtro.getInformazioneApplicativaValore()!=null){
  1492.                     expression.equals(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO, filtro.getInformazioneApplicativaTipo());
  1493.                     expression.like(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME, filtro.getInformazioneApplicativaNome(), LikeMode.EXACT); // Colonna CLOB
  1494.                     expression.like(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE, filtro.getInformazioneApplicativaValore(), LikeMode.EXACT);  // Colonna CLOB
  1495.                 }
  1496.             }
  1497.             
  1498.             expression.equals(AttivazionePolicy.model().GROUP_BY.ENABLED, groupBy.isEnabled());
  1499.             if(groupBy.isEnabled()){
  1500.                 
  1501.                 expression.equals(AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA, groupBy.isRuoloPorta());
  1502.                 
  1503.                 expression.equals(AttivazionePolicy.model().GROUP_BY.PROTOCOLLO, groupBy.isProtocollo());
  1504.                 
  1505.                 expression.equals(AttivazionePolicy.model().GROUP_BY.EROGATORE, groupBy.isErogatore());
  1506.                 
  1507.                 expression.equals(AttivazionePolicy.model().GROUP_BY.SERVIZIO, groupBy.isServizio());
  1508.                 
  1509.                 expression.equals(AttivazionePolicy.model().GROUP_BY.AZIONE, groupBy.isAzione());
  1510.                 
  1511.                 expression.equals(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE, groupBy.isServizioApplicativoErogatore());
  1512.                     
  1513.                 expression.equals(AttivazionePolicy.model().GROUP_BY.FRUITORE, groupBy.isFruitore());
  1514.                 
  1515.                 expression.equals(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE, groupBy.isServizioApplicativoFruitore());
  1516.                 
  1517.                 expression.equals(AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO, groupBy.isIdentificativoAutenticato());
  1518.                 
  1519.                 if(groupBy.getToken()==null) {
  1520.                     expression.isNull(AttivazionePolicy.model().GROUP_BY.TOKEN);    
  1521.                 }
  1522.                 else {
  1523.                     expression.like(AttivazionePolicy.model().GROUP_BY.TOKEN, groupBy.getToken(), LikeMode.EXACT); // Colonna CLOB
  1524.                 }

  1526.                 expression.equals(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED, groupBy.isInformazioneApplicativaEnabled());
  1527.                 if(groupBy.isInformazioneApplicativaEnabled() &&
  1528.                         groupBy.getInformazioneApplicativaTipo()!=null &&
  1529.                         groupBy.getInformazioneApplicativaNome()!=null){
  1530.                     expression.equals(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO, groupBy.getInformazioneApplicativaTipo());
  1531.                     expression.like(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME, groupBy.getInformazioneApplicativaNome(), LikeMode.EXACT); // Colonna CLOB
  1532.                 }
  1533.             }
  1534.             
  1535.             return serviceManager.getAttivazionePolicyServiceSearch().find(expression);
  1536.         }catch (NotFoundException e) {
  1537.             throw new NotFoundException("[" + nomeMetodo + "] Attivazione Policy non presente.");   
  1538.         } catch (Exception qe) {
  1539.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1540.         } 
  1541.     }
  1542.     
  1543.     public static AttivazionePolicy getPolicyByAlias(String alias,
  1544.             RuoloPolicy ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1545.         String nomeMetodo = "getPolicyByAlias"; 
  1546.         
  1547.         try{
  1548.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1549.             properties.setDatabaseType(tipoDB);
  1550.             properties.setShowSql(true);
  1551.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1552.             IExpression expression = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  1553.             
  1554.             expression.and();
  1555.             expression.ilike(AttivazionePolicy.model().ALIAS, alias, LikeMode.EXACT);
  1556.             
  1557.             if(ruoloPorta!=null && nomePorta!=null) {
  1558.                 expression.equals(AttivazionePolicy.model().FILTRO.ENABLED, true);
  1559.                 expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, ruoloPorta);
  1560.                 expression.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA, nomePorta);
  1561.             }
  1562.             else {
  1563.                 expression.isNull(AttivazionePolicy.model().FILTRO.NOME_PORTA);
  1564.             }
  1565.         
  1566.             return serviceManager.getAttivazionePolicyServiceSearch().find(expression);
  1567.         }catch (NotFoundException e) {
  1568.             throw new NotFoundException("[" + nomeMetodo + "] Attivazione Policy non presente.");
  1569.         } catch (Exception qe) {
  1570.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1571.         } 
  1572.     }
  1573.     
  1574.     public static List<AttivazionePolicy> getPolicyByServizioApplicativo(IDServizioApplicativo idServizioApplicativo, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  1575.         String nomeMetodo = "getPolicyByServizioApplicativo"; 
  1576.         
  1577.         try{
  1578.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1579.             properties.setDatabaseType(tipoDB);
  1580.             properties.setShowSql(true);
  1581.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1582.             IPaginatedExpression expression = serviceManager.getAttivazionePolicyServiceSearch().newPaginatedExpression();

  1584.             expression.limit(100000); // non ne esisteranno mai cosi tante.
  1585.             
  1586.             expression.or();
  1587.             
  1588.             Map<IField, Object> propertyNameValuesFruitore = new HashMap<IField, Object>();
  1589.             propertyNameValuesFruitore.put(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE, idServizioApplicativo.getIdSoggettoProprietario().getTipo());
  1590.             propertyNameValuesFruitore.put(AttivazionePolicy.model().FILTRO.NOME_FRUITORE, idServizioApplicativo.getIdSoggettoProprietario().getNome());
  1591.             propertyNameValuesFruitore.put(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE, idServizioApplicativo.getNome());
  1592.             expression.allEquals(propertyNameValuesFruitore, true);
  1593.             
  1594.             Map<IField, Object> propertyNameValuesErogatore = new HashMap<IField, Object>();
  1595.             propertyNameValuesErogatore.put(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE, idServizioApplicativo.getIdSoggettoProprietario().getTipo());
  1596.             propertyNameValuesErogatore.put(AttivazionePolicy.model().FILTRO.NOME_EROGATORE, idServizioApplicativo.getIdSoggettoProprietario().getNome());
  1597.             propertyNameValuesErogatore.put(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE, idServizioApplicativo.getNome());
  1598.             expression.allEquals(propertyNameValuesErogatore, true);
  1599.             
  1600.             List<AttivazionePolicy> l = serviceManager.getAttivazionePolicyServiceSearch().findAll(expression);
  1601.             if(l==null || l.isEmpty()) {
  1602.                 throw new NotFoundException("Non presenti");
  1603.             }
  1604.             return l;
  1605.             
  1606.         }catch (NotFoundException e) {
  1607.             throw new NotFoundException("[" + nomeMetodo + "] Attivazione Policy non presente.");
  1608.         } catch (Exception qe) {
  1609.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1610.         } 
  1611.     }
  1612.     
  1613.     public static boolean usedInConfigurazioneControlloTrafficoAttivazionePolicy(RuoloPolicy ruoloPorta, String nomePorta, String azione, Connection con, Logger log, String tipoDB) throws ServiceException{
  1614.         String nomeMetodo = "usedInConfigurazioneControlloTrafficoAttivazionePolicy";
  1615.         // ritorna la configurazione controllo del traffico della PdD
  1616.         
  1617.         
  1618.         try {
  1619.             
  1620.             ServiceManagerProperties properties = new ServiceManagerProperties();
  1621.             properties.setDatabaseType(tipoDB);
  1622.             properties.setShowSql(true);
  1623.             org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, properties, log);
  1624.             
  1625.             IExpression expr = serviceManager.getAttivazionePolicyServiceSearch().newExpression();
  1626.             
  1627.             if(ruoloPorta!=null && nomePorta!=null) {
  1628.                 expr.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, ruoloPorta);
  1629.                 expr.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA, nomePorta);
  1630.             }
  1631.             else {
  1632.                 //throw new Exception("Metodo non invocabile senza il parametro nomePorta e ruoloPorta");
  1633.                 // si viene usato per il check delle azioni rimosse a livello API
  1634.             }
  1635.             
  1636.             //expr.equals(AttivazionePolicy.model().FILTRO.AZIONE, azione); // e' diventata una lista
  1637.             expr.like(AttivazionePolicy.model().FILTRO.AZIONE, azione, LikeMode.ANYWHERE);
  1638.             
  1639.             IPaginatedExpression pagExpr = serviceManager.getAttivazionePolicyServiceSearch().toPaginatedExpression(expr);
  1640.             pagExpr.offset(0).limit(1000); // per un controllo di presenza per l'azione รจ sufficiente
  1641.             pagExpr.sortOrder(SortOrder.ASC);
  1642.             pagExpr.addOrder(AttivazionePolicy.model().ALIAS);
  1643.             pagExpr.addOrder(AttivazionePolicy.model().ID_POLICY);
  1644.             
  1645.             List<AttivazionePolicy> list = serviceManager.getAttivazionePolicyServiceSearch().findAll(pagExpr);
  1646.             if(list==null || list.isEmpty()) {
  1647.                 return false;
  1648.             }
  1649.             else {
  1650.                 for (AttivazionePolicy attivazionePolicy : list) {
  1651.                     if(attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().getAzione()!=null) {
  1652.                         String checkAz = attivazionePolicy.getFiltro().getAzione();
  1653.                         if(azione.equals(checkAz)) {
  1654.                             return true;
  1655.                         }
  1656.                         if(checkAz.contains(",")) {
  1657.                             String [] tmp = checkAz.split(",");
  1658.                             if(tmp!=null && tmp.length>0) {
  1659.                                 for (int i = 0; i < tmp.length; i++) {
  1660.                                     if(azione.equals(tmp[i])) {
  1661.                                         return true;
  1662.                                     }
  1663.                                 }
  1664.                             }
  1665.                         }
  1666.                     }
  1667.                 }
  1668.                 return false;
  1669.             }
  1670.             
  1671.         } catch (Exception qe) {
  1672.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  1673.         }
  1674.         
  1675.     }
  1676.     
  1677.     public static void updatePosizioneAttivazionePolicy(InfoPolicy infoPolicy, AttivazionePolicy policy,
  1678.             RuoloPolicy ruoloPorta, String nomePorta, 
  1679.             Connection con, Logger log, String tipoDB) throws Exception {
  1680.         // calcolo prossima posizione
  1681.         int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY;
  1682.         
  1683.         Search ricercaTipoRisorsa = new Search(true);
  1684.         TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva = TipoRisorsaPolicyAttiva.getTipo(infoPolicy.getTipoRisorsa(),infoPolicy.isCheckRichiesteSimultanee());
  1685.         ricercaTipoRisorsa.addFilter(idLista, Filtri.FILTRO_TIPO_RISORSA_POLICY, tipoRisorsaPolicyAttiva.getValue());
  1686.         
  1687.         List<AttivazionePolicy> listaPolicyConTipoRisorsa = ControlloTrafficoDriverUtils.configurazioneControlloTrafficoAttivazionePolicyList(ricercaTipoRisorsa, ruoloPorta, nomePorta, 
  1688.                 con, log, tipoDB);
  1689.         
  1690.         int posizione = 1;
  1691.         if(listaPolicyConTipoRisorsa!=null && !listaPolicyConTipoRisorsa.isEmpty()) {
  1692.             for (AttivazionePolicy check : listaPolicyConTipoRisorsa) {
  1693.                 if(check.getPosizione()>=posizione) {
  1694.                     posizione = check.getPosizione()+1;
  1695.                 }
  1696.             }
  1697.         }
  1698.         policy.setPosizione(posizione);
  1699.     }
  1700. }
Created with JaCoCo 0.8.8.202204050719