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



  23. package org.openspcoop2.pdd.services.connector;

  25. import java.io.IOException;
  26. import java.util.ArrayList;
  27. import java.util.List;

  29. import javax.servlet.ServletException;
  30. import javax.servlet.http.HttpServlet;
  31. import javax.servlet.http.HttpServletRequest;
  32. import javax.servlet.http.HttpServletResponse;

  34. import org.apache.commons.lang.StringUtils;
  35. import org.openspcoop2.core.commons.CoreException;
  36. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  37. import org.openspcoop2.pdd.core.CostantiPdD;
  38. import org.openspcoop2.pdd.logger.Dump;
  39. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  40. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  41. import org.openspcoop2.pdd.logger.Tracciamento;
  42. import org.openspcoop2.pdd.services.OpenSPCoop2Startup;
  43. import org.openspcoop2.pdd.timers.TimerMonitoraggioRisorseThread;
  44. import org.openspcoop2.pdd.timers.TimerThresholdThread;
  45. import org.openspcoop2.utils.BooleanNullable;
  46. import org.openspcoop2.utils.LoggerWrapperFactory;
  47. import org.openspcoop2.utils.transport.http.HttpConstants;
  48. import org.openspcoop2.utils.transport.http.HttpRequest;
  49. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  50. import org.openspcoop2.utils.transport.http.HttpResponse;
  51. import org.openspcoop2.utils.transport.http.HttpServletCredential;
  52. import org.openspcoop2.utils.transport.http.HttpUtilities;
  53. import org.slf4j.Logger;

  55. /**
  56.  * Servlet che serve per verificare l'installazione di OpenSPCoop.
  57.  * Ritorna 200 in caso l'installazione sia correttamente inizializzata e tutte le risorse disponibili.
  58.  * Ritorna 500 in caso la PdD non sia in funzione
  59.  *
  60.  * @author Poli Andrea (apoli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */

  65. public class CheckStatoPdD extends HttpServlet {

  67.      /**
  68.      * serialVersionUID
  69.      */
  70.     private static final long serialVersionUID = 1L;

  72.     private static void sendError(HttpServletResponse res, Logger log, String msg, int code) {
  73.         sendError(res, log, msg, code, msg, null);
  74.     }
  75.     private static void sendError(HttpServletResponse res, Logger log, String msg, int code, Throwable e) {
  76.         sendError(res, log, msg, code, msg, e);
  77.     }
  78.     private static void sendError(HttpServletResponse res, Logger log, String msg, int code, String logMsg) {
  79.         sendError(res, log, msg, code, logMsg, null);
  80.     }
  81.     private static void sendError(HttpServletResponse res, Logger log, String msg, int code, String logMsg, Throwable e)  {
  82.         String prefix = "[GovWayCheck] ";
  83.         String msgLog = prefix+logMsg;
  84.         if(e!=null) {
  85.             log.error(msgLog, e);
  86.         }
  87.         else {
  88.             log.error(msgLog);
  89.         }
  90.         res.setStatus(code);
  91.         res.setContentType(HttpConstants.CONTENT_TYPE_PLAIN);
  92.         try {
  93.             res.getOutputStream().write(msg.getBytes());
  94.         }catch(Exception t) {
  95.             log.error("[CheckStato] SendError failed: "+t.getMessage(),t);
  96.         }
  97.     }
  98.     
  99.     private String getPrefixLetturaRisorsa(String resourceName) {
  100.         return "Lettura risorsa ["+resourceName+"] ";
  101.     }
  102.     private String getMsgRisorsaNonAutorizzata(String resourceName) {
  103.         return getPrefixLetturaRisorsa(resourceName)+"non autorizzata";
  104.     }

  106.     private String getMsgDellaRisorsaNonRiuscita(String resourceName) {
  107.          return "della risorsa ["+resourceName+"] non riuscita";
  108.     }
  109.     
  110.     public static void serializeNotInitializedResponse(HttpServletResponse res, Logger log)  {
  111.         String msg = "API Gateway GovWay non inzializzato";
  112.         sendError(res, log, msg, 503);  // viene volutamente utilizzato il codice 503
  113.     }

  115.     @Override public void doGet(HttpServletRequest req, HttpServletResponse res)
  116.     throws ServletException, IOException {
  117.                 
  118.         Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  119.         if(log==null)
  120.             log = LoggerWrapperFactory.getLogger(CheckStatoPdD.class);
  121.         
  122.         if( !OpenSPCoop2Startup.initialize){
  123.             serializeNotInitializedResponse(res, log);
  124.             return;
  125.         }
  126.         
  127.         OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  128.             
  129.         // verifico se l'invocazione richiede una lettura di una risorsa jmx
  130.         boolean richiestaRisorsaJmx = false;
  131.         String resourceName = req.getParameter(CostantiPdD.CHECK_STATO_PDD_RESOURCE_NAME);
  132.         if(resourceName!=null && !"".equals(resourceName)){

  134.             boolean checkReadEnabled = false;
  135.             if(properties!=null && properties.isCheckReadJMXResourcesEnabled() ){
  136.                 checkReadEnabled = true;
  137.             }
  138.             if(!checkReadEnabled){
  139.                 String msg = "Servizio non abilitato";
  140.                 sendError(res, log, msg, 500); 
  141.                 return;
  142.             }
  143.             
  144.             // prima di procedere verifico una eventuale autenticazione
  145.             String username = properties.getCheckReadJMXResourcesUsername();
  146.             String password = properties.getCheckReadJMXResourcesPassword();
  147.             if(username!=null && password!=null){
  148.                 HttpServletCredential identity = new HttpServletCredential(req, log);
  149.                 if(!username.equals(identity.getUsername())){
  150.                     String msg = getMsgRisorsaNonAutorizzata(resourceName);
  151.                     String logMsg = msg+". Richiesta effettuata da username ["+identity.getUsername()+"] sconosciuto";
  152.                     sendError(res, log, msg, 500, logMsg); 
  153.                     return;
  154.                 }
  155.                 if(!password.equals(identity.getPassword())){
  156.                     String msg = getMsgRisorsaNonAutorizzata(resourceName);
  157.                     String logMsg = msg+". Richiesta effettuata da username ["+identity.getUsername()+"] (password errata)";
  158.                     sendError(res, log, msg, 500, logMsg); 
  159.                     return;
  160.                 }
  161.             }
  162.             
  163.             String attributeName = req.getParameter(CostantiPdD.CHECK_STATO_PDD_ATTRIBUTE_NAME);
  164.             String attributeValue = req.getParameter(CostantiPdD.CHECK_STATO_PDD_ATTRIBUTE_VALUE);
  165.             String attributeBooleanValue = req.getParameter(CostantiPdD.CHECK_STATO_PDD_ATTRIBUTE_BOOLEAN_VALUE);
  166.             String methodName = req.getParameter(CostantiPdD.CHECK_STATO_PDD_METHOD_NAME);
  167.             if(attributeName!=null){
  168.                 if(attributeValue!=null || attributeBooleanValue!=null){
  169.                     try{
  170.                         Object v = attributeValue;
  171.                         if(attributeBooleanValue!=null){
  172.                             v = Boolean.parseBoolean(attributeBooleanValue);
  173.                         }
  174.                         OpenSPCoop2Startup.gestoreRisorseJMX_staticInstance.setAttribute(resourceName, attributeName, v);
  175.                         richiestaRisorsaJmx = true; // se è stata richiesta una operazione jmx non si deve proseguire con il check  
  176.                     }catch(Exception e){
  177.                         String msg = "Aggiornamento attributo ["+attributeName+"] "+getMsgDellaRisorsaNonRiuscita(resourceName)+" (valore:"+attributeValue+"): "+e.getMessage();
  178.                         sendError(res, log, msg, 500, e);   
  179.                         return;
  180.                     }
  181.                 }
  182.                 else{
  183.                     try{
  184.                         Object value = OpenSPCoop2Startup.gestoreRisorseJMX_staticInstance.getAttribute(resourceName, attributeName);
  185.                         res.setContentType(HttpConstants.CONTENT_TYPE_PLAIN);
  186.                         res.getOutputStream().write(value.toString().getBytes());   
  187.                         richiestaRisorsaJmx = true; // se è stata richiesta una operazione jmx non si deve proseguire con il check
  188.                     }catch(Exception e){
  189.                         String msg = "Lettura attributo ["+attributeName+"] "+getMsgDellaRisorsaNonRiuscita(resourceName)+": "+e.getMessage();
  190.                         sendError(res, log, msg, 500, e);   
  191.                         return;
  192.                     }
  193.                 }
  194.             }
  195.             else if(attributeValue!=null){
  196.                 String msg = getPrefixLetturaRisorsa(resourceName)+"non effettuata, fornito un valore di attributo senza aver indicato il nome";
  197.                 sendError(res, log, msg, 500);  
  198.                 return;
  199.             }
  200.             else if(methodName!=null){
  201.                 
  202.                 Object [] params = null;
  203.                 String [] signatures = null;
  204.                 try {
  205.                     List<Object> paramsL = new ArrayList<>();
  206.                     List<String> signaturesL = new ArrayList<>();
  207.                     addParameter(paramsL, signaturesL, req);
  208.                     if(!paramsL.isEmpty() && !signaturesL.isEmpty()) {
  209.                         params = paramsL.toArray(new Object[1]);
  210.                         signatures = signaturesL.toArray(new String[1]);
  211.                     }
  212.                 }catch(Exception e) {
  213.                     String msg = "Invocazione metodo ["+methodName+"] "+getMsgDellaRisorsaNonRiuscita(resourceName)+": "+e.getMessage();
  214.                     sendError(res, log, msg, 500, e); 
  215.                     return;
  216.                 }
  217.                 
  218.                 try{
  219.                     Object value = OpenSPCoop2Startup.gestoreRisorseJMX_staticInstance.invoke(resourceName, methodName, params, signatures);
  220.                     res.setContentType(HttpConstants.CONTENT_TYPE_PLAIN);
  221.                     res.getOutputStream().write(value.toString().getBytes());
  222.                     richiestaRisorsaJmx = true; // se è stata richiesta una operazione jmx non si deve proseguire con il check
  223.                 }catch(Exception e){
  224.                     String msg = "Invocazione metodo ["+methodName+"] "+getMsgDellaRisorsaNonRiuscita(resourceName)+": "+e.getMessage();
  225.                     sendError(res, log, msg, 500, e); 
  226.                     return;
  227.                 }
  228.             }
  229.             else{
  230.                 String msg = getPrefixLetturaRisorsa(resourceName)+"non effettuata, nessun attributo o metodo richiesto";
  231.                 sendError(res, log, msg, 500); 
  232.                 return;
  233.             }
  234.             
  235.         }
  236.         
  237.         if(richiestaRisorsaJmx) {
  238.             return; // se è stata richiesta una operazione jmx non si deve proseguire con il check
  239.         }
  240.         
  241.         CheckStatoPdDHealthCheckStats check = readHealthCheckStats(req, properties);
  242.         if(check!=null) {
  243.             try {
  244.                 CheckStatoPdDHealthCheckStatsUtils.verificaInformazioniStatistiche(log, properties,check);
  245.                 return; // se è staa richiesta manualmente una verifica delle statistiche non si deve proseguire con il check
  246.             }catch(Exception t) {
  247.                 String msg = "Statistics HealthCheck failed\n"+t.getMessage();
  248.                 sendError(res, log, msg, 500, t); 
  249.                 return;
  250.             }
  251.         }
  252.         
  253.         boolean checkEnabled = false;
  254.         if(properties!=null && properties.isCheckEnabled() ){
  255.             checkEnabled = true;
  256.         }
  257.         if(!checkEnabled){
  258.             String msg = "Servizio non abilitato";
  259.             sendError(res, log, msg, 500); 
  260.             return;
  261.         }
  262.         
  263.                         
  264.         if( !OpenSPCoop2Startup.initialize){
  265.             serializeNotInitializedResponse(res, log);
  266.             return;
  267.         }
  268.         else if( !TimerMonitoraggioRisorseThread.isRisorseDisponibili()){
  269.             String msg = "Risorse di sistema non disponibili: "+TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile().getMessage();
  270.             sendError(res, log, msg, 500, TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile()); 
  271.             return;
  272.         }
  273.         else if( !TimerThresholdThread.freeSpace){
  274.             String msg = "Non sono disponibili abbastanza risorse per la gestione della richiesta";
  275.             sendError(res, log, msg, 500); 
  276.             return;
  277.         }
  278.         else if( !Tracciamento.tracciamentoDisponibile){
  279.             String msg = "Tracciatura non disponibile: "+Tracciamento.motivoMalfunzionamentoTracciamento.getMessage();
  280.             sendError(res, log, msg, 500, Tracciamento.motivoMalfunzionamentoTracciamento); 
  281.             return;
  282.         }
  283.         else if( !MsgDiagnostico.gestoreDiagnosticaDisponibile){
  284.             String msg = "Sistema di diagnostica non disponibile: "+MsgDiagnostico.motivoMalfunzionamentoDiagnostici.getMessage();
  285.             sendError(res, log, msg, 500, MsgDiagnostico.motivoMalfunzionamentoDiagnostici);    
  286.             return;
  287.         }
  288.         else if( !Dump.isSistemaDumpDisponibile()){
  289.             String msg = "Sistema di dump dei contenuti applicativi non disponibile: "+Dump.getMotivoMalfunzionamentoDump().getMessage();
  290.             sendError(res, log, msg, 500, Dump.getMotivoMalfunzionamentoDump()); 
  291.             return;
  292.         }
  293.         
  294.         if(properties.isCheckHealthCheckStatsEnabled()) {
  295.             try {
  296.                 CheckStatoPdDHealthCheckStatsUtils.verificaInformazioniStatistiche(log, properties);
  297.             }catch(Exception t) {
  298.                 String msg = "Statistics HealthCheck failed\n"+t.getMessage();
  299.                 sendError(res, log, msg, 500, t); 
  300.                 return;
  301.             }
  302.         }
  303.         
  304.         if(properties.isCheckHealthCheckApiRestEnabled()) {
  305.             String endpoint = properties.getCheckHealthCheckApiRestEndpoint();
  306.             
  307.             HttpRequest request = new HttpRequest();
  308.             if(endpoint.toLowerCase().startsWith("https")) {
  309.                 request.setHostnameVerifier(false);
  310.                 request.setTrustAllCerts(true);
  311.             }
  312.             request.setMethod(HttpRequestMethod.GET);
  313.             request.setUrl(endpoint);
  314.             
  315.             try {
  316.                 HttpResponse response = HttpUtilities.httpInvoke(request);
  317.                 
  318.                 if(response.getResultHTTPOperation()!=200) {
  319.                     StringBuilder sb = new StringBuilder();
  320.                     if(response.getHeadersValues()!=null && !response.getHeadersValues().isEmpty()) {
  321.                         for (String hdrName : response.getHeadersValues().keySet()) {
  322.                             if(HttpConstants.RETURN_CODE.equals(hdrName)) {
  323.                                 continue;
  324.                             }
  325.                             List<String> values = response.getHeaderValues(hdrName);
  326.                             if(values!=null && !values.isEmpty()) {
  327.                                 for (String v : values) {
  328.                                     sb.append("\n").append(hdrName).append(":").append(v);
  329.                                 }
  330.                             }
  331.                         }
  332.                     }
  333.                     else {
  334.                         if(response.getContentType()!=null) {
  335.                             sb.append("\n").append(HttpConstants.CONTENT_TYPE).append(":").append(response.getContentType());   
  336.                         }
  337.                     }
  338.                     if(response.getContent()!=null) {
  339.                         sb.append("\n\n").append(new String(response.getContent()));
  340.                     }
  341.                     throw new CoreException("HTTP Result:"+response.getResultHTTPOperation()+sb.toString());
  342.                 }
  343.                 
  344.             }catch(Exception t) {
  345.                 String msg = "API REST HealthCheck failed ("+endpoint+")\n"+t.getMessage();
  346.                 sendError(res, log, msg, 500, t); 
  347.                 return;
  348.             }
  349.         }
  350.         
  351.         if(properties.isCheckHealthCheckApiSoapEnabled()) {
  352.             String endpoint = properties.getCheckHealthCheckApiSoapEndpoint();
  353.             
  354.             HttpRequest request = new HttpRequest();
  355.             if(endpoint.toLowerCase().startsWith("https")) {
  356.                 request.setHostnameVerifier(false);
  357.                 request.setTrustAllCerts(true);
  358.             }
  359.             request.setContentType(HttpConstants.CONTENT_TYPE_SOAP_1_1);
  360.             request.addHeader(HttpConstants.SOAP11_MANDATORY_HEADER_HTTP_SOAP_ACTION, "echo");
  361.             request.setMethod(HttpRequestMethod.POST);
  362.             request.setUrl(endpoint);
  363.             request.setContent("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\"><soapenv:Body><ns1:getStatus xmlns:ns1=\"https://govway.org/apiStatus\"/></soapenv:Body></soapenv:Envelope>".getBytes());
  364.             
  365.             try {
  366.                 HttpResponse response = HttpUtilities.httpInvoke(request);
  367.                 
  368.                 if(response.getResultHTTPOperation()!=200) {
  369.                     StringBuilder sb = new StringBuilder();
  370.                     if(response.getHeadersValues()!=null && !response.getHeadersValues().isEmpty()) {
  371.                         for (String hdrName : response.getHeadersValues().keySet()) {
  372.                             if(HttpConstants.RETURN_CODE.equals(hdrName)) {
  373.                                 continue;
  374.                             }
  375.                             List<String> values = response.getHeaderValues(hdrName);
  376.                             if(values!=null && !values.isEmpty()) {
  377.                                 for (String v : values) {
  378.                                     sb.append("\n").append(hdrName).append(":").append(v);
  379.                                 }
  380.                             }
  381.                         }
  382.                     }
  383.                     else {
  384.                         if(response.getContentType()!=null) {
  385.                             sb.append("\n").append(HttpConstants.CONTENT_TYPE).append(":").append(response.getContentType());
  386.                         }
  387.                     }
  388.                     if(response.getContent()!=null) {
  389.                         sb.append("\n\n").append(new String(response.getContent()));
  390.                     }
  391.                     throw new ServletException("HTTP Result:"+response.getResultHTTPOperation()+sb.toString());
  392.                 }
  393.                 
  394.             }catch(Exception t) {
  395.                 String msg = "API SOAP HealthCheck failed ("+endpoint+")\n"+t.getMessage();
  396.                 sendError(res, log, msg, 500, t); 
  397.             }
  398.         }

  400.     }
  401.     
  402.     private BooleanNullable readBooleanParam(HttpServletRequest req, String paramName) {
  403.         String p = req.getParameter(paramName);
  404.         if("true".equalsIgnoreCase(p)) {
  405.             return BooleanNullable.TRUE();
  406.         }
  407.         else if("false".equalsIgnoreCase(p)) {
  408.             return BooleanNullable.FALSE();
  409.         }
  410.         return BooleanNullable.NULL();
  411.     }
  412.     private Integer readIntegerParam(HttpServletRequest req, String paramName) {
  413.         String p = req.getParameter(paramName);
  414.         if(p!=null && StringUtils.isNotEmpty(p)) {
  415.             return Integer.valueOf(p);
  416.         }
  417.         return null;
  418.     }
  419.     private CheckStatoPdDHealthCheckStats readHealthCheckStats(HttpServletRequest req, OpenSPCoop2Properties properties) {
  420.         BooleanNullable healthCheckStats = readBooleanParam(req,CostantiPdD.CHECK_STATO_PDD_EXECUTE_HEALTH_CHECK_STATS);
  421.         BooleanNullable hourlyHealthCheckStats = readBooleanParam(req,CostantiPdD.CHECK_STATO_PDD_EXECUTE_HOURLY_HEALTH_CHECK_STATS);
  422.         BooleanNullable dailyHealthCheckStats = readBooleanParam(req,CostantiPdD.CHECK_STATO_PDD_EXECUTE_DAILY_HEALTH_CHECK_STATS);
  423.         BooleanNullable weeklyHealthCheckStats = readBooleanParam(req,CostantiPdD.CHECK_STATO_PDD_EXECUTE_WEEKLY_HEALTH_CHECK_STATS);
  424.         BooleanNullable monthlyHealthCheckStats = readBooleanParam(req,CostantiPdD.CHECK_STATO_PDD_EXECUTE_MONTHLY_HEALTH_CHECK_STATS);
  425.         
  426.         CheckStatoPdDHealthCheckStats check = null;
  427.         if(hourlyHealthCheckStats!=null && hourlyHealthCheckStats.getValue()!=null) {
  428.             check = new CheckStatoPdDHealthCheckStats();
  429.             check.setVerificaStatisticaOraria(hourlyHealthCheckStats.getValue().booleanValue());
  430.             Integer p = readIntegerParam(req, CostantiPdD.CHECK_STATO_PDD_EXECUTE_HOURLY_HEALTH_CHECK_STATS_THRESHOLD);
  431.             if(p!=null && p.intValue()>=0) {
  432.                 check.setVerificaStatisticaOrariaSoglia(p.intValue());
  433.             }
  434.             else {
  435.                 check.setVerificaStatisticaOrariaSoglia(properties.getCheckHealthCheckStatsHourlyThreshold());
  436.             }
  437.         }
  438.         if(dailyHealthCheckStats!=null && dailyHealthCheckStats.getValue()!=null) {
  439.             if(check==null) {
  440.                 check = new CheckStatoPdDHealthCheckStats();
  441.             }
  442.             check.setVerificaStatisticaGiornaliera(dailyHealthCheckStats.getValue().booleanValue());
  443.             Integer p = readIntegerParam(req, CostantiPdD.CHECK_STATO_PDD_EXECUTE_DAILY_HEALTH_CHECK_STATS_THRESHOLD);
  444.             if(p!=null && p.intValue()>=0) {
  445.                 check.setVerificaStatisticaGiornalieraSoglia(p.intValue());
  446.             }
  447.             else {
  448.                 check.setVerificaStatisticaGiornalieraSoglia(properties.getCheckHealthCheckStatsDailyThreshold());
  449.             }
  450.         }
  451.         if(weeklyHealthCheckStats!=null && weeklyHealthCheckStats.getValue()!=null) {
  452.             if(check==null) {
  453.                 check = new CheckStatoPdDHealthCheckStats();
  454.             }
  455.             check.setVerificaStatisticaSettimanale(weeklyHealthCheckStats.getValue().booleanValue());
  456.             Integer p = readIntegerParam(req, CostantiPdD.CHECK_STATO_PDD_EXECUTE_WEEKLY_HEALTH_CHECK_STATS_THRESHOLD);
  457.             if(p!=null && p.intValue()>=0) {
  458.                 check.setVerificaStatisticaSettimanaleSoglia(p.intValue());
  459.             }
  460.             else {
  461.                 check.setVerificaStatisticaSettimanaleSoglia(properties.getCheckHealthCheckStatsWeeklyThreshold());
  462.             }
  463.         }
  464.         if(monthlyHealthCheckStats!=null && monthlyHealthCheckStats.getValue()!=null) {
  465.             if(check==null) {
  466.                 check = new CheckStatoPdDHealthCheckStats();
  467.             }
  468.             check.setVerificaStatisticaMensile(monthlyHealthCheckStats.getValue().booleanValue());
  469.             Integer p = readIntegerParam(req, CostantiPdD.CHECK_STATO_PDD_EXECUTE_MONTHLY_HEALTH_CHECK_STATS_THRESHOLD);
  470.             if(p!=null && p.intValue()>=0) {
  471.                 check.setVerificaStatisticaMensileSoglia(p.intValue());
  472.             }
  473.             else {
  474.                 check.setVerificaStatisticaMensileSoglia(properties.getCheckHealthCheckStatsMonthlyThreshold());
  475.             }
  476.         }
  477.         if(check == null &&
  478.             healthCheckStats!=null && healthCheckStats.getValue()!=null && healthCheckStats.getValue().booleanValue()) {
  479.             check = CheckStatoPdDHealthCheckStats.readProprietaVerificaInformazioniStatistiche(properties);
  480.         }
  481.         
  482.         return check;
  483.     }
  484.     

  486.     private void addParameter(List<Object> params, List<String> signatures, HttpServletRequest req) throws CoreException {
  487.         
  488.         boolean add = addParameter(params, signatures, req,
  489.                 CostantiPdD.CHECK_STATO_PDD_PARAM_VALUE,
  490.                 CostantiPdD.CHECK_STATO_PDD_PARAM_INT_VALUE, 
  491.                 CostantiPdD.CHECK_STATO_PDD_PARAM_LONG_VALUE,
  492.                 CostantiPdD.CHECK_STATO_PDD_PARAM_BOOLEAN_VALUE);
  493.         if(!add) {
  494.             return;
  495.         }
  496.         
  497.         add = addParameter(params, signatures, req,
  498.                 CostantiPdD.CHECK_STATO_PDD_PARAM_VALUE_2,
  499.                 CostantiPdD.CHECK_STATO_PDD_PARAM_INT_VALUE_2, 
  500.                 CostantiPdD.CHECK_STATO_PDD_PARAM_LONG_VALUE_2,
  501.                 CostantiPdD.CHECK_STATO_PDD_PARAM_BOOLEAN_VALUE_2);
  502.         if(!add) {
  503.             return;
  504.         }
  505.         
  506.         add = addParameter(params, signatures, req,
  507.                 CostantiPdD.CHECK_STATO_PDD_PARAM_VALUE_3,
  508.                 CostantiPdD.CHECK_STATO_PDD_PARAM_INT_VALUE_3, 
  509.                 CostantiPdD.CHECK_STATO_PDD_PARAM_LONG_VALUE_3,
  510.                 CostantiPdD.CHECK_STATO_PDD_PARAM_BOOLEAN_VALUE_3);
  511.         
  512.         if(!add) {
  513.             return;
  514.         }
  515.         
  516.         addParameter(params, signatures, req,
  517.                 CostantiPdD.CHECK_STATO_PDD_PARAM_VALUE_4,
  518.                 CostantiPdD.CHECK_STATO_PDD_PARAM_INT_VALUE_4, 
  519.                 CostantiPdD.CHECK_STATO_PDD_PARAM_LONG_VALUE_4,
  520.                 CostantiPdD.CHECK_STATO_PDD_PARAM_BOOLEAN_VALUE_4);
  521.             
  522.     }
  523.     
  524.     private boolean addParameter(List<Object> params, List<String> signatures, HttpServletRequest req,
  525.             String stringNameParameter, String intNameParameter, String longNameParameter, String booleanNameParameter) throws CoreException {
  526.         
  527.         int count = 0;
  528.         List<String> pFound = new ArrayList<>();
  529.         
  530.         String paramStringValue = req.getParameter(stringNameParameter);
  531.         boolean paramStringDefined = paramStringValue!=null && !"".equals(paramStringValue);
  532.         if(paramStringDefined) {
  533.             count++;
  534.             pFound.add(stringNameParameter);
  535.         }
  536.         
  537.         String paramIntValue = req.getParameter(intNameParameter);
  538.         boolean paramIntDefined = paramIntValue!=null && !"".equals(paramIntValue);
  539.         if(paramIntDefined) {
  540.             count++;
  541.             pFound.add(intNameParameter);
  542.         }
  543.         
  544.         String paramLongValue = req.getParameter(longNameParameter);
  545.         boolean paramLongDefined = paramLongValue!=null && !"".equals(paramLongValue);
  546.         if(paramLongDefined) {
  547.             count++;
  548.             pFound.add(longNameParameter);
  549.         }
  550.         
  551.         String paramBooleanValue = req.getParameter(booleanNameParameter);
  552.         boolean paramBooleanDefined = paramBooleanValue!=null && !"".equals(paramBooleanValue);
  553.         if(paramBooleanDefined) {
  554.             count++;
  555.             pFound.add(booleanNameParameter);
  556.         }
  557.         
  558.         if(count==0) {
  559.             return false;
  560.         }
  561.         if(count>1) {
  562.             throw new CoreException("È stato fornito più di un tipo di parametro per la stessa posizione: "+pFound);
  563.         }
  564.         
  565.         if(paramStringDefined){
  566.             params.add(paramStringValue);
  567.             signatures.add(String.class.getName());
  568.         }
  569.         else if(paramIntDefined){
  570.             params.add(Integer.valueOf(paramIntValue));
  571.             signatures.add(Integer.class.getName());
  572.         }
  573.         else if(paramLongDefined){
  574.             params.add(Long.valueOf(paramLongValue));
  575.             signatures.add(Long.class.getName());
  576.         }
  577.         /**else if(paramBooleanDefined){*/
  578.         else {
  579.             params.add(Boolean.valueOf(paramBooleanValue));
  580.             signatures.add(Boolean.class.getName());
  581.         }
  582.         return true;
  583.         
  584.     }
  585. }
Created with JaCoCo 0.8.8.202204050719