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


  22. package org.openspcoop2.web.ctrlstat.gestori;

  24. import java.io.ByteArrayOutputStream;
  25. import java.io.PrintWriter;
  26. import java.sql.Connection;
  27. import java.sql.Timestamp;
  28. import java.util.Date;

  30. import javax.jms.QueueSession;

  32. import org.slf4j.Logger;
  33. import org.openspcoop2.utils.Utilities;
  34. import org.openspcoop2.web.ctrlstat.core.DBManager;
  35. import org.openspcoop2.web.ctrlstat.costanti.OperationsParameter;
  36. import org.openspcoop2.web.lib.queue.ClassQueue;
  37. import org.openspcoop2.web.lib.queue.costanti.OperationStatus;
  38. import org.openspcoop2.web.lib.queue.dao.FilterParameter;
  39. import org.openspcoop2.web.lib.queue.dao.Parameter;

  41. /**
  42.  * Gestisce l'operazione del gestore
  43.  * 
  44.  * 
  45.  * @author Andrea Poli (apoli@link.it)
  46.  * @author Stefano Corallo (corallo@link.it)
  47.  * @author Sandra Giangrandi (sandra@link.it)
  48.  * @author $Author$
  49.  * @version $Rev$, $Date$
  50.  * 
  51.  */
  52. public class GestioneOperazione {

  54.     private DBManager dbManager;
  55.     private Connection connectionDB;
  56.     private QueueSession sessionJMS;
  57.     private org.openspcoop2.web.lib.queue.dao.Operation operation;
  58.     private ClassQueue operationManager;
  59.     private Logger log;
  60.     private String idGestore;
  61.     private String tipoOperazioneCRUD;

  63.     public GestioneOperazione(DBManager db, Connection c, QueueSession s, org.openspcoop2.web.lib.queue.dao.Operation o, ClassQueue operationManager, 
  64.             Logger l, String tipoOperazioneCRUD, String idGestore) {
  65.         this.dbManager = db;
  66.         this.connectionDB = c;
  67.         this.sessionJMS = s;
  68.         this.operation = o;
  69.         this.operationManager = operationManager;
  70.         this.log = l;
  71.         this.idGestore = idGestore;
  72.         if (tipoOperazioneCRUD != null)
  73.             this.tipoOperazioneCRUD = "." + tipoOperazioneCRUD;
  74.         else
  75.             this.tipoOperazioneCRUD = "";
  76.     }

  78.     public void error(String msg) throws Exception {
  79.         error(msg, null);
  80.     }

  82.     public void error(String msgParam, Exception e) throws Exception {
  83.         
  84.         String msgErrore = msgParam;
  85.         if(e!=null){
  86.             PrintWriter pw = null;
  87.             ByteArrayOutputStream out = null;
  88.             try{
  89.                 out = new ByteArrayOutputStream();
  90.                 pw = new PrintWriter(out);
  91.                 e.printStackTrace(pw);
  92.                 pw.flush();
  93.                 out.flush();
  94.             }finally{
  95.                 try{
  96.                     if(pw!=null){
  97.                         pw.close();
  98.                     }
  99.                 }catch(Exception eClose){
  100.                     // close
  101.                 }
  102.                 try{
  103.                     if(out!=null){
  104.                         out.close();
  105.                     }
  106.                 }catch(Exception eClose){
  107.                     // close
  108.                 }
  109.             }
  110.             msgErrore = msgErrore +"\n"+out.toString();
  111.         }
  112.         
  113.         if ((e != null) && (e instanceof java.net.ConnectException)) {
  114.             this.log.warn("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msgParam, e);
  115.         } else {
  116.             
  117.             if(e!=null && Utilities.existsInnerException(e, java.net.ConnectException.class)){
  118.                 this.log.warn("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msgParam, e);
  119.             }
  120.             else{
  121.                 if (e != null)
  122.                     this.log.error("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msgParam, e);
  123.                 else
  124.                     this.log.error("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msgParam);
  125.             }
  126.         }
  127.         this.operation.setStatus(OperationStatus.ERROR);
  128.         this.operation.setDetails(msgErrore);
  129.         this.operation.setTimeExecute(new Timestamp(System.currentTimeMillis()));
  130.         this.operationManager.updateOperation(this.operation);
  131.         this.sessionJMS.rollback();
  132.         this.dbManager.releaseConnection(this.connectionDB);
  133.     }

  135.     public void invalid(String msg) throws Exception {
  136.         this.log.error("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msg);
  137.         this.operation.setStatus(OperationStatus.INVALID);
  138.         this.operation.setDetails(msg);
  139.         this.operation.setTimeExecute(new Timestamp(System.currentTimeMillis()));
  140.         this.operationManager.updateOperation(this.operation);
  141.         this.sessionJMS.commit();
  142.         this.dbManager.releaseConnection(this.connectionDB);
  143.     }

  145.     /**
  146.      * Una operazione (DI ADD) puo essere in attesa (wait) che si verificano
  147.      * determinate condizioni (commit) affinche essa diventi valida.
  148.      * L'operazione puo rimanere in wait per un numero determinato di volte
  149.      * "waitTime" dopodicche verra settata come invalida
  150.      * 
  151.      * In caso di operazioni != da ADD viene subito invalidata
  152.      * 
  153.      * @param msg
  154.      * @throws Exception
  155.      */
  156.     public void waitBeforeInvalid(String msg) throws Exception {
  157.         this.log.warn("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msg);

  159.         /**
  160.          * Se l'operazione non e' di add non attendo ma invalido subito
  161.          */
  162.         if (!"add".equals(this.operation.getOperation())) {
  163.             this.operation.setStatus(OperationStatus.INVALID);
  164.             this.operation.setDetails(msg);
  165.         } else if (this.operation.getWaitTime() > this.operationManager.getDefaultWaitTime()) {
  166.             // se operazione di add ma limite wait superato allora invalido
  167.             this.log.debug("L operazione " + this.operation.toString() + " ha superato il WAIT_TIME(" + this.operationManager.getDefaultWaitTime() + ") setto operazione come INVALID.");
  168.             this.operation.setStatus(OperationStatus.INVALID);
  169.             this.operation.setDetails("Superato WAIT_TIME(" + this.operationManager.getDefaultWaitTime() + ") <<>> Old details:" + msg);
  170.         } else {
  171.             // add e limite wait non superato, attendo incrementando il
  172.             // wait_time di questa operation
  173.             this.operation.setStatus(OperationStatus.WAIT);
  174.             this.operation.setWaitTime(this.operation.getWaitTime() + 1);// incremento
  175.             // waittime
  176.             this.operation.setDetails(msg);
  177.         }

  179.         this.operation.setTimeExecute(new Timestamp(System.currentTimeMillis()));
  180.         this.operationManager.updateOperation(this.operation);

  182.         // se operazione in wait allora rollo, altrimenti committo
  183.         switch (this.operation.getStatus()) {
  184.             case WAIT:
  185.                 this.sessionJMS.rollback();
  186.                 break;
  187.             default:
  188.                 this.sessionJMS.commit();
  189.                 break;
  190.         }

  192.         this.dbManager.releaseConnection(this.connectionDB);

  194.     }

  196.     public void success(String msg) throws Exception {
  197.         this.log.info("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " " + msg);
  198.         this.operation.setStatus(OperationStatus.SUCCESS);
  199.         this.operation.setDetails(msg);
  200.         this.operation.setTimeExecute(new Timestamp(System.currentTimeMillis()));
  201.         this.operationManager.updateOperation(this.operation);
  202.         this.sessionJMS.commit();
  203.         this.dbManager.releaseConnection(this.connectionDB);
  204.     }

  206.     public void delete() throws Exception {
  207.         this.operation.setStatus(OperationStatus.DELETED);
  208.         this.operation.setDetails("[" + this.idGestore + "]" + this.tipoOperazioneCRUD + " Operazione Marcata come DELETED");
  209.         this.operation.setTimeExecute(new Date(System.currentTimeMillis()));
  210.         this.operationManager.updateOperation(this.operation);
  211.         this.sessionJMS.commit();
  212.         this.dbManager.releaseConnection(this.connectionDB);
  213.     }
  214.     
  215.     public boolean existsOperationNotCompleted(String tipoOperazione,String hostname,FilterParameter filtro) throws Exception{
  216.         return this.operationManager.existsOperationNotCompleted(tipoOperazione, hostname,filtro);
  217.     }

  219.     public FilterParameter getFilterChangeIDSoggetto(String tipoSogg,String nomeSogg,String oldTipoSogg,String oldNomeSogg){
  220.         FilterParameter filtro = new FilterParameter();
  221.         Parameter param = new Parameter();
  222.         param.setName(OperationsParameter.OGGETTO.getNome());
  223.         param.setValue("soggetto");
  224.         filtro.addFilterParameter(param);
  225.         Parameter paramTipoSoggetto = new Parameter();
  226.         paramTipoSoggetto.setName(OperationsParameter.TIPO_SOGGETTO.getNome());
  227.         paramTipoSoggetto.setValue(tipoSogg);
  228.         filtro.addFilterParameter(paramTipoSoggetto);
  229.         Parameter paramNomeSoggetto = new Parameter();
  230.         paramNomeSoggetto.setName(OperationsParameter.NOME_SOGGETTO.getNome());
  231.         paramNomeSoggetto.setValue(nomeSogg);
  232.         filtro.addFilterParameter(paramNomeSoggetto);
  233.         Parameter paramOldTipoSoggetto = new Parameter();
  234.         paramOldTipoSoggetto.setName(OperationsParameter.OLD_TIPO_SOGGETTO.getNome());
  235.         paramOldTipoSoggetto.setValue(oldTipoSogg);
  236.         filtro.addFilterParameter(paramOldTipoSoggetto);
  237.         Parameter paramOldNomeSoggetto = new Parameter();
  238.         paramOldNomeSoggetto.setName(OperationsParameter.OLD_NOME_SOGGETTO.getNome());
  239.         paramOldNomeSoggetto.setValue(oldNomeSogg);
  240.         filtro.addFilterParameter(paramOldNomeSoggetto);
  241.         return filtro;
  242.     }
  243. }
Created with JaCoCo 0.8.8.202204050719