AllarmiDriverUtils.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.allarmi.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.List;

  29. import org.apache.commons.lang.StringUtils;
  30. import org.openspcoop2.core.allarmi.Allarme;
  31. import org.openspcoop2.core.allarmi.AllarmeHistory;
  32. import org.openspcoop2.core.allarmi.IdAllarme;
  33. import org.openspcoop2.core.allarmi.constants.RuoloPorta;
  34. import org.openspcoop2.core.allarmi.constants.StatoAllarme;
  35. import org.openspcoop2.core.allarmi.constants.TipoAllarme;
  36. import org.openspcoop2.core.allarmi.dao.IAllarmeHistoryService;
  37. import org.openspcoop2.core.allarmi.dao.IAllarmeHistoryServiceSearch;
  38. import org.openspcoop2.core.allarmi.dao.IAllarmeService;
  39. import org.openspcoop2.core.allarmi.dao.IAllarmeServiceSearch;
  40. import org.openspcoop2.core.allarmi.dao.jdbc.JDBCServiceManager;
  41. import org.openspcoop2.core.allarmi.dao.jdbc.converter.AllarmeFieldConverter;
  42. import org.openspcoop2.core.allarmi.dao.jdbc.converter.AllarmeHistoryFieldConverter;
  43. import org.openspcoop2.core.commons.Filtri;
  44. import org.openspcoop2.core.commons.ISearch;
  45. import org.openspcoop2.core.commons.Liste;
  46. import org.openspcoop2.core.commons.SearchUtils;
  47. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  48. import org.openspcoop2.core.constants.CostantiDB;
  49. import org.openspcoop2.core.id.IDServizio;
  50. import org.openspcoop2.core.id.IDServizioApplicativo;
  51. import org.openspcoop2.core.id.IDSoggetto;
  52. import org.openspcoop2.generic_project.beans.CustomField;
  53. import org.openspcoop2.generic_project.beans.Function;
  54. import org.openspcoop2.generic_project.beans.FunctionField;
  55. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  56. import org.openspcoop2.generic_project.exception.NotFoundException;
  57. import org.openspcoop2.generic_project.exception.ServiceException;
  58. import org.openspcoop2.generic_project.expression.IExpression;
  59. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  60. import org.openspcoop2.generic_project.expression.LikeMode;
  61. import org.openspcoop2.generic_project.expression.SortOrder;
  62. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  63. import org.openspcoop2.utils.sql.ISQLQueryObject;
  64. import org.openspcoop2.utils.sql.LikeConfig;
  65. import org.openspcoop2.utils.sql.SQLObjectFactory;
  66. import org.slf4j.Logger;

  68. /**
  69.  * AllarmiDriverUtils
  70.  *
  71.  * @author Poli Andrea (apoli@link.it)
  72.  * @author $Author$
  73.  * @version $Rev$, $Date$
  74.  */
  75. public class AllarmiDriverUtils {

  77.     public static List<Allarme> allarmiList(ISearch ricerca, RuoloPorta ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException {
  78.         String nomeMetodo = "allarmiList";
  79.         int idLista = Liste.CONFIGURAZIONE_ALLARMI;
  80.         int offset;
  81.         int limit;
  82.         String search;

  84.         limit = ricerca.getPageSize(idLista);
  85.         offset = ricerca.getIndexIniziale(idLista);
  86.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  88.         String filterStato = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_STATO);
  89.         
  90.         log.debug("search : " + search);
  91.         log.debug("filterStato : " + filterStato);
  92.                 
  93.         try {
  94.             ServiceManagerProperties properties = new ServiceManagerProperties();
  95.             properties.setDatabaseType(tipoDB);
  96.             properties.setShowSql(true);
  97.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  98.             
  99.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  100.             
  101.             IExpression expr = allarmiServiceSearch.newExpression();
  102.             
  103.             boolean addAnd = false;
  104.             
  105.             if(ruoloPorta!=null && nomePorta!=null) {
  106.                 expr.equals(Allarme.model().FILTRO.RUOLO_PORTA, ruoloPorta.getValue()).and().equals(Allarme.model().FILTRO.NOME_PORTA, nomePorta);
  107.                 addAnd = true;
  108.             }
  109.             else {
  110.                 expr.isNull(Allarme.model().FILTRO.NOME_PORTA);
  111.                 addAnd = true;
  112.             }
  113.             
  114.             if (!search.equals("")) {
  115.                 if(addAnd)
  116.                     expr.and();
  117.                 
  118.                 expr.ilike(Allarme.model().ALIAS, search, LikeMode.ANYWHERE);
  119.                 
  120.                 addAnd = true;
  121.             }
  122.             
  123.             if (filterStato!=null && !filterStato.equals("")) {
  124.                 if(addAnd)
  125.                     expr.and();
  126.                 
  127.                 if(Filtri.FILTRO_STATO_VALORE_ABILITATO.equals(filterStato)) {
  128.                     expr.equals(Allarme.model().ENABLED, 1);
  129.                     addAnd = true;
  130.                 }
  131.                 else if(Filtri.FILTRO_STATO_VALORE_DISABILITATO.equals(filterStato)) {
  132.                     expr.equals(Allarme.model().ENABLED, 0);
  133.                     addAnd = true;
  134.                 }
  135.                 else if(Filtri.FILTRO_STATO_VALORE_OK.equals(filterStato)) {
  136.                     expr.equals(Allarme.model().ENABLED, 1);
  137.                     expr.and();
  138.                     expr.equals(Allarme.model().STATO, AllarmiConverterUtils.toIntegerValue(StatoAllarme.OK));
  139.                     addAnd = true;
  140.                 }
  141.                 else if(Filtri.FILTRO_STATO_VALORE_WARNING.equals(filterStato)) {
  142.                     expr.equals(Allarme.model().ENABLED, 1);
  143.                     expr.and();
  144.                     expr.equals(Allarme.model().STATO, AllarmiConverterUtils.toIntegerValue(StatoAllarme.WARNING));
  145.                     addAnd = true;
  146.                 }
  147.                 else if(Filtri.FILTRO_STATO_VALORE_ERROR.equals(filterStato)) {
  148.                     expr.equals(Allarme.model().ENABLED, 1);
  149.                     expr.and();
  150.                     expr.equals(Allarme.model().STATO, AllarmiConverterUtils.toIntegerValue(StatoAllarme.ERROR));
  151.                     addAnd = true;
  152.                 }
  153.                 
  154.                 addAnd = true;
  155.             }
  156.             
  157.             NonNegativeNumber count = allarmiServiceSearch.count(expr);
  158.             ricerca.setNumEntries(idLista,(int) count.longValue());
  159.             
  160.             // ricavo le entries
  161.             if (limit == 0) // con limit
  162.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  163.             
  164.             IPaginatedExpression pagExpr = allarmiServiceSearch.toPaginatedExpression(expr);
  165.             
  166.             pagExpr.limit(limit).offset(offset);
  167.             pagExpr.addOrder(Allarme.model().ALIAS, SortOrder.ASC);

  169.             return allarmiServiceSearch.findAll(pagExpr);
  170.             
  171.         } catch (Exception qe) {
  172.             throw new ServiceException("[" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  173.         } 
  174.     }
  175.     
  176.     
  177.     public static void createAllarme(Allarme allarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  178.         String nomeMetodo = "createAllarme";

  180.         try {
  181.             ServiceManagerProperties properties = new ServiceManagerProperties();
  182.             properties.setDatabaseType(tipoDB);
  183.             properties.setShowSql(true);
  184.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  185.             
  186.             IAllarmeService allarmiService = jdbcServiceManager.getAllarmeService();
  187.             
  188.             allarmiService.create(allarme);
  189.             
  190.         } catch (Exception qe) {
  191.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  192.         }
  193.     }
  194.     
  195.     public static void updateAllarme(Allarme allarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  196.         String nomeMetodo = "updateAllarme";

  198.         try {
  199.             ServiceManagerProperties properties = new ServiceManagerProperties();
  200.             properties.setDatabaseType(tipoDB);
  201.             properties.setShowSql(true);
  202.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  203.             
  204.             IAllarmeService allarmiService = jdbcServiceManager.getAllarmeService();
  205.             
  206.             IdAllarme idAll = new IdAllarme();
  207.             idAll.setNome(allarme.getNome());
  208.             allarmiService.update(idAll,allarme);
  209.             
  210.         } catch (Exception qe) {
  211.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  212.         }
  213.     }
  214.     
  215.     public static void deleteAllarme(Allarme allarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  216.         String nomeMetodo = "deleteAllarme";

  218.         try {
  219.             ServiceManagerProperties properties = new ServiceManagerProperties();
  220.             properties.setDatabaseType(tipoDB);
  221.             properties.setShowSql(true);
  222.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  223.             
  224.             IAllarmeService allarmiService = jdbcServiceManager.getAllarmeService();
  225.             
  226.             allarmiService.delete(allarme);
  227.             
  228.         } catch (Exception qe) {
  229.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  230.         } 
  231.     }

  233.     public static boolean existsAllarme(String nome, Connection con, Logger log, String tipoDB) throws ServiceException {
  234.         String nomeMetodo = "existsAllarme";
  235.         
  236.         try {
  237.             ServiceManagerProperties properties = new ServiceManagerProperties();
  238.             properties.setDatabaseType(tipoDB);
  239.             properties.setShowSql(true);
  240.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  241.             
  242.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  243.             
  244.             IExpression expr = allarmiServiceSearch.newExpression();
  245.             
  246.             expr.equals(Allarme.model().NOME, nome);
  247.             
  248.             NonNegativeNumber count = allarmiServiceSearch.count(expr);
  249.             
  250.             return count.longValue() > 0;
  251.         } catch (Exception qe) {
  252.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  253.         } 
  254.     }
  255.     
  256.     public static Allarme getAllarme(String nome, Connection con, Logger log, String tipoDB) throws ServiceException {
  257.         String nomeMetodo = "getAllarmeByNome";
  258.         
  259.         try {
  260.             ServiceManagerProperties properties = new ServiceManagerProperties();
  261.             properties.setDatabaseType(tipoDB);
  262.             properties.setShowSql(true);
  263.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  264.             
  265.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  266.             
  267.             IdAllarme id = new IdAllarme();
  268.             id.setNome(nome);
  269.             
  270.             return allarmiServiceSearch.get(id);
  271.             
  272.         } catch (Exception qe) {
  273.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  274.         }
  275.     }
  276.     
  277.     public static Allarme getAllarme(Long id, Connection con, Logger log, String tipoDB) throws ServiceException {
  278.         String nomeMetodo = "getAllarme";
  279.         
  280.         try {
  281.             ServiceManagerProperties properties = new ServiceManagerProperties();
  282.             properties.setDatabaseType(tipoDB);
  283.             properties.setShowSql(true);
  284.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  285.             
  286.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  287.             
  288.             IExpression expr = allarmiServiceSearch.newExpression();
  289.             
  290.             AllarmeFieldConverter converter = new AllarmeFieldConverter(tipoDB);
  291.             expr.equals(new CustomField("id", Long.class, "id", converter.toTable(Allarme.model())), id);
  292.             
  293.             return allarmiServiceSearch.find(expr);
  294.             
  295.         } catch (Exception qe) {
  296.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  297.         }
  298.     }
  299.     
  300.     public static Allarme getAllarmeByAlias(String alias,
  301.             RuoloPorta ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException,NotFoundException{
  302.         String nomeMetodo = "getAllarmeByAlias"; 
  303.         
  304.         try{
  305.             ServiceManagerProperties properties = new ServiceManagerProperties();
  306.             properties.setDatabaseType(tipoDB);
  307.             properties.setShowSql(true);
  308.             JDBCServiceManager serviceManager = new JDBCServiceManager(con, properties, log);
  309.             IExpression expression = serviceManager.getAllarmeServiceSearch().newExpression();
  310.             
  311.             expression.and();
  312.             expression.ilike(Allarme.model().ALIAS, alias, LikeMode.EXACT);
  313.             
  314.             if(ruoloPorta!=null && nomePorta!=null) {
  315.                 expression.equals(Allarme.model().FILTRO.ENABLED, true);
  316.                 expression.equals(Allarme.model().FILTRO.RUOLO_PORTA, ruoloPorta);
  317.                 expression.equals(Allarme.model().FILTRO.NOME_PORTA, nomePorta);
  318.             }
  319.             else {
  320.                 expression.isNull(Allarme.model().FILTRO.NOME_PORTA);
  321.             }
  322.         
  323.             return serviceManager.getAllarmeServiceSearch().find(expression);
  324.         }catch (NotFoundException e) {
  325.             throw new NotFoundException("[" + nomeMetodo + "] Allarme non presente.");
  326.         } catch (Exception qe) {
  327.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  328.         } 
  329.     }
  330.     
  331.     public static boolean existsAllarmi(TipoAllarme tipoAllarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  332.         String nomeMetodo = "existsAllarmi";
  333.         
  334.         try {
  335.             ServiceManagerProperties properties = new ServiceManagerProperties();
  336.             properties.setDatabaseType(tipoDB);
  337.             properties.setShowSql(true);
  338.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  339.             
  340.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  341.             
  342.             IExpression expr = allarmiServiceSearch.newExpression();
  343.             
  344.             if(tipoAllarme!=null) {
  345.                 expr.equals(Allarme.model().TIPO_ALLARME, tipoAllarme.getValue());
  346.             }
  347.             
  348.             NonNegativeNumber count = allarmiServiceSearch.count(expr);
  349.             
  350.             return count.longValue() > 0;
  351.         } catch (Exception qe) {
  352.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  353.         } 
  354.     }
  355.     
  356.     public static long countAllarmi(TipoAllarme tipoAllarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  357.         String nomeMetodo = "countAllarmi";
  358.         
  359.         try {
  360.             ServiceManagerProperties properties = new ServiceManagerProperties();
  361.             properties.setDatabaseType(tipoDB);
  362.             properties.setShowSql(true);
  363.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  364.             
  365.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  366.             
  367.             IExpression expr = allarmiServiceSearch.newExpression();
  368.             
  369.             if(tipoAllarme!=null) {
  370.                 expr.equals(Allarme.model().TIPO_ALLARME, tipoAllarme.getValue());
  371.             }
  372.             
  373.             NonNegativeNumber count = allarmiServiceSearch.count(expr);
  374.             
  375.             return count.longValue();
  376.         } catch (Exception qe) {
  377.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  378.         } 
  379.     }
  380.     
  381.     public static void createHistoryAllarme(AllarmeHistory allarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  382.         String nomeMetodo = "createHistoryAllarme";

  384.         try {
  385.             ServiceManagerProperties properties = new ServiceManagerProperties();
  386.             properties.setDatabaseType(tipoDB);
  387.             properties.setShowSql(true);
  388.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  389.             
  390.             IAllarmeHistoryService allarmiService = jdbcServiceManager.getAllarmeHistoryService();
  391.             
  392.             allarmiService.create(allarme);
  393.             
  394.         } catch (Exception qe) {
  395.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  396.         }
  397.     }
  398.     
  399.     public static List<AllarmeHistory> allarmiHistoryList(ISearch ricerca, Long idAllarme, Connection con, Logger log, String tipoDB) throws ServiceException {
  400.         String nomeMetodo = "allarmiHistoryList";
  401.         int idLista = Liste.CONFIGURAZIONE_ALLARMI_HISTORY;
  402.         int offset;
  403.         int limit;
  404. //      String search;

  406.         limit = ricerca.getPageSize(idLista);
  407.         offset = ricerca.getIndexIniziale(idLista);
  408. //      search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  410. //      String filterTipoPlugin = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_TIPO_PLUGIN_CLASSI);
  411.         
  412. //      this.log.debug("search : " + search);
  413.         
  414.         try {
  415.             ServiceManagerProperties properties = new ServiceManagerProperties();
  416.             properties.setDatabaseType(tipoDB);
  417.             properties.setShowSql(true);
  418.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  419.             
  420.             IAllarmeHistoryServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeHistoryServiceSearch();
  421.             
  422.             IExpression expr = allarmiServiceSearch.newExpression();
  423.             
  424.             AllarmeHistoryFieldConverter converter = new AllarmeHistoryFieldConverter(tipoDB);
  425.             CustomField cf = new CustomField("id_allarme", Long.class, "id_allarme", converter.toTable(AllarmeHistory.model()));
  426.             expr.equals(cf, idAllarme);
  427.             
  428. //          boolean addAnd = false;
  429.             
  430. //          if (!search.equals("")) {
  431. //              expr.ilike(Allarme.model().NOME, search, LikeMode.ANYWHERE);
  432.                 
  433. //              addAnd = true;
  434. //          }
  435.             
  436.             NonNegativeNumber count = allarmiServiceSearch.count(expr);
  437.             ricerca.setNumEntries(idLista,(int) count.longValue());
  438.             
  439.             // ricavo le entries
  440.             if (limit == 0) // con limit
  441.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  442.             
  443.             IPaginatedExpression pagExpr = allarmiServiceSearch.toPaginatedExpression(expr);
  444.             
  445.             pagExpr.limit(limit).offset(offset);
  446.             pagExpr.addOrder(AllarmeHistory.model().TIMESTAMP_UPDATE, SortOrder.DESC);

  448.             return allarmiServiceSearch.findAll(pagExpr);
  449.             
  450.         } catch (Exception qe) {
  451.             throw new ServiceException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  452.         } 
  453.     }
  454.     
  455.     private static String FREE_COUNTER_SEPARATOR_CHAR = "@"; 
  456.     private static int FREE_COUNTER_SEPARATOR_CHAR_PAD = 19; // colonna che memorizza l'info ha dimensione 275
  457.     public static String buildIdAlarm(String tipoPlugin, String serialId) {
  458.         String idAlarm = tipoPlugin+AllarmiDriverUtils.FREE_COUNTER_SEPARATOR_CHAR+serialId;
  459.         return idAlarm;
  460.     }
  461.     
  462.     private static String normalizeAlarmInstanceSerialId(int value) {
  463.         return StringUtils.leftPad(value+"", FREE_COUNTER_SEPARATOR_CHAR_PAD, "0");
  464.     }
  465.     public static String incrementAlarmInstanceSerialId(String value) {
  466.         int valueInt = 0;
  467.         if(value!=null && !"".equals(value)) {
  468.             StringBuilder sb = new StringBuilder();
  469.             for (int i = 0; i < value.length(); i++) {
  470.                 char c = value.charAt(i);
  471.                 if('0' == c && sb.length()<=0) {
  472.                     continue;
  473.                 }
  474.                 sb.append(c);
  475.             }
  476.             valueInt = Integer.valueOf(sb.toString());
  477.         }
  478.         valueInt++;
  479.         return StringUtils.leftPad(valueInt+"", FREE_COUNTER_SEPARATOR_CHAR_PAD, "0");
  480.     }
  481.     
  482.     //public static Integer getFreeCounterForAlarm(String tipoPlugin, Connection con, Logger log, String tipoDB) throws ServiceException{
  483.     public static String getNextAlarmInstanceSerialId(String tipoPlugin, Connection con, Logger log, String tipoDB) throws ServiceException{
  484.         String nomeMetodo = "getNextAlarmInstanceSerialId"; 
  485.         
  486.         
  487.         try{
  488.             ServiceManagerProperties properties = new ServiceManagerProperties();
  489.             properties.setDatabaseType(tipoDB);
  490.             properties.setShowSql(true);
  491.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  492.             
  493.             IExpression pagExpr = jdbcServiceManager.getAllarmeServiceSearch().newExpression();
  494.             pagExpr.and();
  495.             pagExpr.equals(Allarme.model().TIPO, tipoPlugin);
  496.             
  497.             // non funziona perchè :10 viene ordinato prima di :9
  498.             //pagExpr.addOrder(AttivazionePolicy.model().ID_ACTIVE_POLICY, SortOrder.DESC);
  499.             //pagExpr.limit(1);
  500.             // devo scorrerle tutte
  501.             
  502.             /*
  503.             try{
  504.                 // inefficiente
  505.                 List<Object> list = jdbcServiceManager.getAllarmeServiceSearch().select(pagExpr, Allarme.model().NOME);
  506.                 if(list!=null && !list.isEmpty()){
  507.                     int found = -1;
  508.                     for (Object r : list) {
  509.                         if(r instanceof String){
  510.                             String s = (String)r;
  511.                             if(s.contains(FREE_COUNTER_SEPARATOR_CHAR)){
  512.                                 int last = s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR);
  513.                                 if(last<(s.length()-1)){
  514.                                     int value = Integer.parseInt(s.substring(s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR)+1,s.length()));
  515.                                     if(value > found) {
  516.                                         found = value;
  517.                                     }
  518.                                 }
  519.                             }
  520.                         }   
  521.                     }
  522.                     if(found>0) {
  523.                         return found+1;
  524.                     }
  525.                 }
  526.             }catch(NotFoundException notF){
  527.                 
  528.             }
  529.             return 1;*/
  530.             
  531.             FunctionField ff = new FunctionField(Allarme.model().NOME, Function.MAX, "maxAlarmId");
  532.             Object maxValue = null;
  533.             try {
  534.                 maxValue = jdbcServiceManager.getAllarmeServiceSearch().aggregate(pagExpr, ff);
  535.             }catch(NotFoundException notFound) {
  536.             }
  537.             if(maxValue!=null){
  538.                 if(maxValue instanceof String){
  539.                     String s = (String)maxValue;
  540.                     if(s.contains(FREE_COUNTER_SEPARATOR_CHAR)){
  541.                         int last = s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR);
  542.                         if(last<(s.length()-1)){
  543.                             String actualMaxValue = s.substring(s.lastIndexOf(FREE_COUNTER_SEPARATOR_CHAR)+1,s.length());
  544.                             return incrementAlarmInstanceSerialId(actualMaxValue);
  545.                         }
  546.                     }
  547.                 }   
  548.             }
  549.             return normalizeAlarmInstanceSerialId(1);
  550.             
  551.         } catch (Exception qe) {
  552.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  553.         }
  554.     }
  555.     
  556.     public static List<Allarme> configurazioneAllarmiList(ISearch ricerca, RuoloPorta ruoloPorta, String nomePorta, 
  557.             Connection con, Logger log, String tipoDB,
  558.             String nomeMetodo, 
  559.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  560.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  561.             IDServizio filtroServizioAzione, String filtroRuolo) throws ServiceException{
  562.         // ritorna la configurazione allarmi
  563.         int idLista = Liste.CONFIGURAZIONE_ALLARMI;
  564.         String search = null;
  565.         int offset = 0;
  566.         int limit =0 ;

  568.         if(ricerca != null) {
  569.             search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  570.             limit = ricerca.getPageSize(idLista);
  571.             offset = ricerca.getIndexIniziale(idLista);
  572.         }
  573.         if (limit == 0) // con limit
  574.             limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  575.         
  576.         log.debug("search : " + search);
  577.         
  578.         List<Allarme> listaAllarmi = new ArrayList<Allarme>();
  579.         
  580.         long count = 0;
  581.         PreparedStatement pstmt = null;
  582.         ResultSet rs = null;
  583.         try {
  584.             if(ricerca!=null) {

  586.                 ISQLQueryObject sqlQueryObject = _prepareSqlQueryObjectAllarmi(tipoDB,ruoloPorta, nomePorta, search, 
  587.                         filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  588.                         filtroSoggettoErogatore, filtroRuoloErogatore,
  589.                         filtroServizioAzione, filtroRuolo);
  590.                 sqlQueryObject.addSelectCountField("nome", "allarmi");
  591.                 String query = sqlQueryObject.createSQLQuery();
  592.                 pstmt = con.prepareStatement(query);
  593.                 _prepareStatementAllarmi(tipoDB,pstmt, ruoloPorta, nomePorta, search, 
  594.                         filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  595.                         filtroSoggettoErogatore, filtroRuoloErogatore,
  596.                         filtroServizioAzione, filtroRuolo);
  597.                 rs = pstmt.executeQuery();
  598.                 if(rs.next()) {
  599.                     count = rs.getLong("allarmi");
  600.                 }
  601.                 rs.close();
  602.                 pstmt.close();
  603.                 
  604.             }
  605.             
  606.             ServiceManagerProperties properties = new ServiceManagerProperties();
  607.             properties.setDatabaseType(tipoDB);
  608.             properties.setShowSql(true);
  609.             JDBCServiceManager serviceManager = new JDBCServiceManager(con, properties, log);
  610.             
  611.             
  612.             ISQLQueryObject sqlQueryObject = _prepareSqlQueryObjectAllarmi(tipoDB,ruoloPorta, nomePorta, search, 
  613.                     filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  614.                     filtroSoggettoErogatore, filtroRuoloErogatore,
  615.                     filtroServizioAzione, filtroRuolo);
  616.             sqlQueryObject.addSelectField(CostantiDB.ALLARMI, "nome");
  617.             sqlQueryObject.setOffset(offset);
  618.             sqlQueryObject.setLimit(limit);
  619.             //sqlQueryObject.addOrderBy("policy_alias", true);
  620.             //sqlQueryObject.addOrderBy("policy_id", true);
  621.             sqlQueryObject.addOrderBy(CostantiDB.ALLARMI+".nome", true);
  622.             String query = sqlQueryObject.createSQLQuery();
  623.             pstmt = con.prepareStatement(query);
  624.             _prepareStatementAllarmi(tipoDB,pstmt, ruoloPorta, nomePorta, search, 
  625.                     filtroSoggettoFruitore, filtroApplicativoFruitore, filtroRuoloFruitore,
  626.                     filtroSoggettoErogatore, filtroRuoloErogatore,
  627.                     filtroServizioAzione, filtroRuolo);
  628.             rs = pstmt.executeQuery();
  629.             while(rs.next()) {
  630.                 
  631.                 String nomeAllarme = rs.getString("nome");
  632.                 
  633.                 IdAllarme idAllarmeAsObject = new IdAllarme();
  634.                 idAllarmeAsObject.setNome(nomeAllarme);
  635.                 Allarme allarme = serviceManager.getAllarmeServiceSearch().get(idAllarmeAsObject);
  636.                 listaAllarmi.add(allarme);
  637.                 
  638.             }
  639.             rs.close();
  640.             pstmt.close();
  641.                         
  642.         } catch (Exception qe) {
  643.             throw new ServiceException("[" + nomeMetodo +"] Errore : " + qe.getMessage(),qe);
  644.         } finally {
  645.             try {
  646.                 if(rs!=null) {
  647.                     rs.close();
  648.                 }
  649.             } catch (Exception e) {
  650.                 // ignore exception
  651.             }
  652.             try {
  653.                 if(pstmt!=null) {
  654.                     pstmt.close();
  655.                 }
  656.             } catch (Exception e) {
  657.                 // ignore exception
  658.             }
  659.         }
  660.         
  661.         if(ricerca!=null) {
  662.             ricerca.setNumEntries(idLista,(int) count);
  663.         }
  664.         
  665.         return listaAllarmi;
  666.         
  667.     }
  668.     private static ISQLQueryObject _prepareSqlQueryObjectAllarmi(
  669.             String tipoDB,
  670.             RuoloPorta ruoloPorta, String nomePorta,
  671.             String search, 
  672.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  673.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  674.             IDServizio filtroServizioAzione, String filtroRuolo) throws Exception {
  675.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  676.         sqlQueryObject.setANDLogicOperator(true);
  677.         sqlQueryObject.addFromTable(CostantiDB.ALLARMI);
  678.         if(ruoloPorta!=null && nomePorta!=null) {
  679.             sqlQueryObject.addWhereCondition("filtro_ruolo=?");
  680.             sqlQueryObject.addWhereCondition("filtro_porta=?");
  681.         }
  682.         else if(ruoloPorta!=null) {
  683.             sqlQueryObject.addWhereCondition("filtro_ruolo=?"); // se passo solo ruolo porta, voglio tutte le policy con quel ruolo. Altrimenti finisco nelle policy globali
  684.         }
  685.         else {
  686.             sqlQueryObject.addWhereIsNullCondition("filtro_porta");
  687.         }
  688.         if(search != null  && !"".equals(search)){
  689.             // fix: oramai l'alias e' obbligatorio
  690.             sqlQueryObject.addWhereCondition(false, 
  691.                     //sqlQueryObject.getWhereLikeCondition("active_policy_id", search, false, true, true),
  692.                     sqlQueryObject.getWhereLikeCondition("alias", search, false, true, true));
  693.         }
  694.         if(filtroSoggettoFruitore!=null) {
  695.             if(filtroSoggettoFruitore.getTipo()!=null) {
  696.                 sqlQueryObject.addWhereCondition("filtro_tipo_fruitore=?");
  697.             }
  698.             if(filtroSoggettoFruitore.getNome()!=null) {
  699.                 sqlQueryObject.addWhereCondition("filtro_nome_fruitore=?");
  700.             }
  701.         }
  702.         if(filtroApplicativoFruitore!=null) {
  703.             if(filtroApplicativoFruitore.getIdSoggettoProprietario()!=null) {
  704.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo()!=null) {
  705.                     sqlQueryObject.addWhereCondition("filtro_tipo_fruitore=?");
  706.                 }
  707.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getNome()!=null) {
  708.                     sqlQueryObject.addWhereCondition("filtro_nome_fruitore=?");
  709.                 }
  710.             }
  711.             if(filtroApplicativoFruitore.getNome()!=null) {
  712.                 sqlQueryObject.addWhereCondition("filtro_sa_fruitore=?");
  713.             }
  714.         }
  715.         if(filtroRuoloFruitore!=null) {
  716.             sqlQueryObject.addWhereCondition("filtro_ruolo_fruitore=?");
  717.         }
  718.         if(filtroSoggettoErogatore!=null) {
  719.             if(filtroSoggettoErogatore.getTipo()!=null) {
  720.                 sqlQueryObject.addWhereCondition("filtro_tipo_erogatore=?");
  721.             }
  722.             if(filtroSoggettoErogatore.getNome()!=null) {
  723.                 sqlQueryObject.addWhereCondition("filtro_nome_erogatore=?");
  724.             }
  725.         }
  726.         if(filtroRuoloErogatore!=null) {
  727.             sqlQueryObject.addWhereCondition("filtro_ruolo_erogatore=?");
  728.         }
  729.         if(filtroServizioAzione!=null) {
  730.             if(filtroServizioAzione.getSoggettoErogatore()!=null) {
  731.                 if(filtroServizioAzione.getSoggettoErogatore().getTipo()!=null) {
  732.                     sqlQueryObject.addWhereCondition("filtro_tipo_erogatore=?");
  733.                 }
  734.                 if(filtroServizioAzione.getSoggettoErogatore().getNome()!=null) {
  735.                     sqlQueryObject.addWhereCondition("filtro_nome_erogatore=?");
  736.                 }
  737.             }
  738.             if(filtroServizioAzione.getTipo()!=null) {
  739.                 sqlQueryObject.addWhereCondition("filtro_tipo_servizio=?");
  740.             }
  741.             if(filtroServizioAzione.getNome()!=null) {
  742.                 sqlQueryObject.addWhereCondition("filtro_nome_servizio=?");
  743.             }
  744.             if(filtroServizioAzione.getVersione()!=null) {
  745.                 sqlQueryObject.addWhereCondition("filtro_versione_servizio=?");
  746.             }
  747.             if(filtroServizioAzione.getAzione()!=null) {
  748.                 // condizione di controllo
  749.                 ISQLQueryObject sqlQueryObjectOr = SQLObjectFactory.createSQLQueryObject(tipoDB);
  750.                 sqlQueryObjectOr.setANDLogicOperator(false);
  751.                 // (filtro_azione == 'NOME') OR (filtro_azione like 'NOME,%') OR (filtro_azione like '%,NOME') OR (filtro_azione like '%,applicabilita_azioni,%')
  752.                 // CLOB sqlQueryObjectOr.addWhereCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione = ?");
  753.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", filtroServizioAzione.getAzione(), false , false);
  754.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", filtroServizioAzione.getAzione()+",", LikeConfig.startsWith(false));
  755.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", ","+filtroServizioAzione.getAzione(), LikeConfig.endsWith(false));
  756.                 sqlQueryObjectOr.addWhereLikeCondition(CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY+".filtro_azione", ","+filtroServizioAzione.getAzione()+",", true , false);
  757.                 sqlQueryObject.addWhereCondition(sqlQueryObjectOr.createSQLConditions());
  758.             }
  759.         }
  760.         if(filtroRuolo!=null) {
  761.             sqlQueryObject.addWhereCondition(false, "filtro_ruolo_fruitore=?", "filtro_ruolo_erogatore=?");
  762.         }
  763.         return sqlQueryObject;
  764.     }
  765.     private static void _prepareStatementAllarmi(
  766.             String tipoDB,
  767.             PreparedStatement pstmt,
  768.             RuoloPorta ruoloPorta, String nomePorta,
  769.             String search, 
  770.             IDSoggetto filtroSoggettoFruitore, IDServizioApplicativo filtroApplicativoFruitore,String filtroRuoloFruitore,
  771.             IDSoggetto filtroSoggettoErogatore, String filtroRuoloErogatore,
  772.             IDServizio filtroServizioAzione, String filtroRuolo) throws Exception {
  773.         int index = 1;
  774.         if(ruoloPorta!=null && nomePorta!=null) {
  775.             pstmt.setString(index++, ruoloPorta.getValue());
  776.             pstmt.setString(index++, nomePorta);
  777.         }
  778.         else if(ruoloPorta!=null) {
  779.             pstmt.setString(index++, ruoloPorta.getValue());
  780.         }
  781.         if(filtroSoggettoFruitore!=null) {
  782.             if(filtroSoggettoFruitore.getTipo()!=null) {
  783.                 pstmt.setString(index++, filtroSoggettoFruitore.getTipo());
  784.             }
  785.             if(filtroSoggettoFruitore.getNome()!=null) {
  786.                 pstmt.setString(index++, filtroSoggettoFruitore.getNome());
  787.             }
  788.         }
  789.         if(filtroApplicativoFruitore!=null) {
  790.             if(filtroApplicativoFruitore.getIdSoggettoProprietario()!=null) {
  791.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo()!=null) {
  792.                     pstmt.setString(index++, filtroApplicativoFruitore.getIdSoggettoProprietario().getTipo());
  793.                 }
  794.                 if(filtroApplicativoFruitore.getIdSoggettoProprietario().getNome()!=null) {
  795.                     pstmt.setString(index++, filtroApplicativoFruitore.getIdSoggettoProprietario().getNome());
  796.                 }
  797.             }
  798.             if(filtroApplicativoFruitore.getNome()!=null) {
  799.                 pstmt.setString(index++, filtroApplicativoFruitore.getNome());
  800.             }
  801.         }
  802.         if(filtroRuoloFruitore!=null) {
  803.             pstmt.setString(index++, filtroRuoloFruitore);
  804.         }
  805.         if(filtroSoggettoErogatore!=null) {
  806.             if(filtroSoggettoErogatore.getTipo()!=null) {
  807.                 pstmt.setString(index++, filtroSoggettoErogatore.getTipo());
  808.             }
  809.             if(filtroSoggettoErogatore.getNome()!=null) {
  810.                 pstmt.setString(index++, filtroSoggettoErogatore.getNome());
  811.             }
  812.         }
  813.         if(filtroRuoloErogatore!=null) {
  814.             pstmt.setString(index++, filtroRuoloErogatore);
  815.         }
  816.         if(filtroServizioAzione!=null) {
  817.             if(filtroServizioAzione.getSoggettoErogatore()!=null) {
  818.                 if(filtroServizioAzione.getSoggettoErogatore().getTipo()!=null) {
  819.                     pstmt.setString(index++, filtroServizioAzione.getSoggettoErogatore().getTipo());
  820.                 }
  821.                 if(filtroServizioAzione.getSoggettoErogatore().getNome()!=null) {
  822.                     pstmt.setString(index++, filtroServizioAzione.getSoggettoErogatore().getNome());
  823.                 }
  824.             }
  825.             if(filtroServizioAzione.getTipo()!=null) {
  826.                 pstmt.setString(index++, filtroServizioAzione.getTipo());
  827.             }
  828.             if(filtroServizioAzione.getNome()!=null) {
  829.                 pstmt.setString(index++, filtroServizioAzione.getNome());
  830.             }
  831.             if(filtroServizioAzione.getVersione()!=null) {
  832.                 pstmt.setInt(index++, filtroServizioAzione.getVersione());
  833.             }
  834.             if(filtroServizioAzione.getAzione()!=null) {
  835.                 // inserito direttamente nella preparazione
  836.             }
  837.         }
  838.         if(filtroRuolo!=null) {
  839.             pstmt.setString(index++, filtroRuolo);
  840.             pstmt.setString(index++, filtroRuolo);
  841.         }
  842.     }
  843.     
  844.     
  845.     public static List<Allarme> allarmiForPolicyRateLimiting(String activeIdPolicy, RuoloPorta ruoloPorta, String nomePorta, Connection con, Logger log, String tipoDB) throws ServiceException {
  846.         String nomeMetodo = "allarmiForPolicyRateLimiting";
  847.                 
  848.         try {
  849.             ServiceManagerProperties properties = new ServiceManagerProperties();
  850.             properties.setDatabaseType(tipoDB);
  851.             properties.setShowSql(true);
  852.             JDBCServiceManager jdbcServiceManager = new JDBCServiceManager(con, properties, log);
  853.             
  854.             IAllarmeServiceSearch allarmiServiceSearch = jdbcServiceManager.getAllarmeServiceSearch();
  855.             
  856.             IExpression expr = allarmiServiceSearch.newExpression();
  857.             
  858.             expr.and();
  859.             
  860.             if(ruoloPorta!=null && nomePorta!=null) {
  861.                 expr.equals(Allarme.model().FILTRO.RUOLO_PORTA, ruoloPorta.getValue()).and().equals(Allarme.model().FILTRO.NOME_PORTA, nomePorta);
  862.             }
  863.             else {
  864.                 expr.isNull(Allarme.model().FILTRO.NOME_PORTA);
  865.             }
  866.             
  867.             expr.equals(Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO, CostantiConfigurazione.PARAM_POLICY_ID);
  868.             if(activeIdPolicy!=null) {
  869.                 expr.like(Allarme.model().ALLARME_PARAMETRO.VALORE, activeIdPolicy,LikeMode.EXACT);
  870.             }
  871.             else {
  872.                 expr.isNull(Allarme.model().ALLARME_PARAMETRO.VALORE);
  873.             }

  875.             IPaginatedExpression pagExpr = allarmiServiceSearch.toPaginatedExpression(expr);
  876.             
  877.             pagExpr.addOrder(Allarme.model().ALIAS, SortOrder.ASC);

  879.             return allarmiServiceSearch.findAll(pagExpr);
  880.             
  881.         } catch (Exception qe) {
  882.             throw new ServiceException("[" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  883.         } 
  884.     }
  885.     
  886. }
Created with JaCoCo 0.8.8.202204050719