AccordoServizioParteComuneServiziCompostiCore.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */
  20. package org.openspcoop2.web.ctrlstat.servlet.apc;

  22. import java.sql.Connection;
  23. import java.sql.PreparedStatement;
  24. import java.sql.ResultSet;
  25. import java.util.ArrayList;
  26. import java.util.List;

  28. import org.openspcoop2.core.commons.ISearch;
  29. import org.openspcoop2.core.constants.CostantiDB;
  30. import org.openspcoop2.core.id.IDAccordoCooperazione;
  31. import org.openspcoop2.core.id.IDServizio;
  32. import org.openspcoop2.core.id.IDSoggetto;
  33. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  34. import org.openspcoop2.core.registry.AccordoServizioParteComuneServizioCompostoServizioComponente;
  35. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  36. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  37. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  38. import org.openspcoop2.core.registry.driver.db.IDAccordoDB;
  39. import org.openspcoop2.utils.sql.ISQLQueryObject;
  40. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  41. import org.openspcoop2.web.ctrlstat.core.UtilitiesSQLQuery;
  42. import org.openspcoop2.web.ctrlstat.driver.DriverControlStationDB;
  43. import org.openspcoop2.web.ctrlstat.driver.DriverControlStationException;
  44. import org.openspcoop2.web.ctrlstat.servlet.ConsoleHelper;
  45. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;

  47. /**
  48.  * AccordoServizioParteComuneServiziCompostiCore
  49.  *
  50.  * @author Poli Andrea (apoli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */
  54. public class AccordoServizioParteComuneServiziCompostiCore extends ControlStationCore {

  56.     protected AccordoServizioParteComuneServiziCompostiCore(ControlStationCore core) throws DriverControlStationException {
  57.         super(core);
  58.     }
  59.     
  60.     public List<IDAccordoDB> idAccordiServizioCompostiList(String superuser, ISearch ricerca, 
  61.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException {
  62.         Connection con = null;
  63.         String nomeMetodo = "idAccordiServizioCompostiList";
  64.         DriverControlStationDB driver = null;

  66.         try {
  67.             // prendo una connessione
  68.             con = ControlStationCore.dbM.getConnection();
  69.             // istanzio il driver
  70.             driver = new DriverControlStationDB(con, null, this.tipoDB);

  72.             return driver.getDriverRegistroServiziDB().idAccordiServizioCompostiList(superuser, ricerca, 
  73.                     soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  74.         } catch (DriverRegistroServiziException e) {
  75.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  76.             throw e;
  77.         } catch (Exception e) {
  78.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  79.             throw new DriverRegistroServiziException(getPrefixError(nomeMetodo,  e), e);
  80.         } finally {
  81.             ControlStationCore.dbM.releaseConnection(con);
  82.         }
  83.     }
  84.     
  85.     public List<AccordoServizioParteComune> accordiServizioServiziComponentiConSoggettoErogatore(IDSoggetto idSoggetto) throws DriverRegistroServiziException {
  86.         Connection con = null;
  87.         String nomeMetodo = "accordiServizio_serviziComponentiConSoggettoErogatore";
  88.         DriverRegistroServiziDB driver = null;

  90.         try {
  91.             // prendo una connessione
  92.             con = ControlStationCore.dbM.getConnection();
  93.             // istanzio il driver
  94.             driver = new DriverRegistroServiziDB(con, ControlStationCore.log, this.tipoDB);

  96.             return driver.accordiServizio_serviziComponentiConSoggettoErogatore(idSoggetto);
  97.         } catch (DriverRegistroServiziException e) {
  98.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  99.             throw e;
  100.         } catch (Exception e) {
  101.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  102.             throw new DriverRegistroServiziException(getPrefixError(nomeMetodo,  e), e);
  103.         } finally {
  104.             ControlStationCore.dbM.releaseConnection(con);
  105.         }
  106.     }

  108.     public List<AccordoServizioParteComune> accordiServizioServiziComponenti(IDServizio idServizio) throws DriverRegistroServiziException {
  109.         Connection con = null;
  110.         String nomeMetodo = "accordiServizio_serviziComponenti";
  111.         DriverRegistroServiziDB driver = null;

  113.         try {
  114.             // prendo una connessione
  115.             con = ControlStationCore.dbM.getConnection();
  116.             // istanzio il driver
  117.             driver = new DriverRegistroServiziDB(con, ControlStationCore.log, this.tipoDB);

  119.             return driver.accordiServizio_serviziComponenti(idServizio);
  120.         } catch (DriverRegistroServiziException e) {
  121.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  122.             throw e;
  123.         } catch (Exception e) {
  124.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  125.             throw new DriverRegistroServiziException(getPrefixError(nomeMetodo,  e), e);
  126.         } finally {
  127.             ControlStationCore.dbM.releaseConnection(con);
  128.         }
  129.     }

  131.     public List<AccordoServizioParteComune> accordiServizioWithAccordoCooperazione(IDAccordoCooperazione idAccordoCooperazione) throws DriverRegistroServiziException {
  132.         Connection con = null;
  133.         String nomeMetodo = "accordiServizioWithAccordoCooperazione";
  134.         DriverRegistroServiziDB driver = null;

  136.         try {
  137.             // prendo una connessione
  138.             con = ControlStationCore.dbM.getConnection();
  139.             // istanzio il driver
  140.             driver = new DriverRegistroServiziDB(con, ControlStationCore.log, this.tipoDB);

  142.             return driver.accordiServizioWithAccordoCooperazione(idAccordoCooperazione);
  143.         } catch (DriverRegistroServiziException e) {
  144.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  145.             throw e;
  146.         } catch (Exception e) {
  147.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  148.             throw new DriverRegistroServiziException(getPrefixError(nomeMetodo,  e), e);
  149.         } finally {
  150.             ControlStationCore.dbM.releaseConnection(con);
  151.         }
  152.     }


  155.     public List<AccordoServizioParteComuneServizioCompostoServizioComponente> accordiComponentiList(long idAccordo, ISearch ricerca) throws DriverRegistroServiziException {
  156.         Connection con = null;
  157.         String nomeMetodo = "accordiComponentiList";
  158.         DriverControlStationDB driver = null;

  160.         try {
  161.             // prendo una connessione
  162.             con = ControlStationCore.dbM.getConnection();
  163.             // istanzio il driver
  164.             driver = new DriverControlStationDB(con, null, this.tipoDB);

  166.             return driver.getDriverRegistroServiziDB().accordiComponentiList(idAccordo, ricerca);
  167.         } catch (Exception e) {
  168.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  169.             throw new DriverRegistroServiziException(getPrefixError(nomeMetodo,  e), e);
  170.         } finally {
  171.             ControlStationCore.dbM.releaseConnection(con);
  172.         }
  173.     }

  175.     public List<String[]> getAccordiServizioCompostoLabels(AccordoServizioParteComune as, long idAccordoLong, String userLogin, 
  176.             List<String> tipiServiziCompatibili, List<String> tipiSoggettiCompatibili, ConsoleHelper helper){
  177.         String[] serviziList = null;
  178.         String[] serviziListLabel = null;
  179.         Connection con = null;
  180.         String nomeMetodo = "getAccordiServizioCompostoLabels";
  181.         PreparedStatement stmt = null;
  182.         ResultSet risultato = null;
  183.         try{

  185.             AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(this);

  187.             con = ControlStationCore.dbM.getConnection();

  189.             // Servizi
  190.             ISQLQueryObject sqlQueryObject = (new UtilitiesSQLQuery()).getSQLQueryObject();
  191.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  192.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  193.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  194.             sqlQueryObject.addSelectCountField(CostantiDB.SERVIZI + ".id", "tot", true);
  195.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo=?");
  196.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo<>?");
  197.             if(as.getPrivato()==null || !as.getPrivato()){
  198.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".privato=?");
  199.             }
  200.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".id="+CostantiDB.SERVIZI+".id_soggetto");
  201.             if( !isVisioneOggettiGlobale(userLogin)){
  202.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  203.             }
  204.             sqlQueryObject.setANDLogicOperator(true);

  206.             //voglio i servizi che non sono gia' stati usati come componenti
  207.             ISQLQueryObject sqlQueryObjectNotExist = (new UtilitiesSQLQuery()).getSQLQueryObject();
  208.             sqlQueryObjectNotExist.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPONENTI);
  209.             sqlQueryObjectNotExist.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPONENTI+".id_servizio_composto="+CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id");
  210.             sqlQueryObjectNotExist.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPONENTI+".id_servizio_componente="+CostantiDB.SERVIZI+".id");
  211.             sqlQueryObjectNotExist.setANDLogicOperator(true);

  213.             sqlQueryObject.addWhereExistsCondition(true, sqlQueryObjectNotExist);

  215.             String queryString = sqlQueryObject.createSQLQuery();
  216.             stmt = con.prepareStatement(queryString);
  217.             stmt.setLong(1, idAccordoLong);
  218.             stmt.setLong(2, idAccordoLong);
  219.             int index = 3;
  220.             if(as.getPrivato()==null || !as.getPrivato()){
  221.                 stmt.setInt(index, 0);
  222.                 index++;
  223.             }
  224.             if( !isVisioneOggettiGlobale(userLogin)){
  225.                 stmt.setString(index, userLogin);
  226.                 index++;
  227.             }
  228.             risultato = stmt.executeQuery();
  229.             int totServ = 0;
  230.             if (risultato.next()) {
  231.                 totServ = risultato.getInt("tot");
  232.             }
  233.             risultato.close();
  234.             stmt.close();

  236.             List<String> serviziL = new ArrayList<>();
  237.             List<String> serviziLabelL = new ArrayList<>();
  238.             serviziL.add("-1");
  239.             serviziLabelL.add("-");

  241.             if (totServ != 0) {
  242.                 // Servizi
  243.                 sqlQueryObject = (new UtilitiesSQLQuery()).getSQLQueryObject();                 
  244.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  245.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  246.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  247.                 sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI, "id","idServizio");
  248.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo=?");
  249.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo<>?");
  250.                 if(as.getPrivato()==null || !as.getPrivato()){
  251.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".privato=?");
  252.                 }
  253.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".id="+CostantiDB.SERVIZI+".id_soggetto");
  254.                 if( !isVisioneOggettiGlobale(userLogin)){
  255.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  256.                 }
  257.                 sqlQueryObject.setANDLogicOperator(true);

  259.                 //voglio i servizi che non sono gia' stati usati come componenti
  260.                 sqlQueryObjectNotExist = (new UtilitiesSQLQuery()).getSQLQueryObject();
  261.                 sqlQueryObjectNotExist.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPONENTI);
  262.                 sqlQueryObjectNotExist.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPONENTI+".id_servizio_composto="+CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id");
  263.                 sqlQueryObjectNotExist.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPONENTI+".id_servizio_componente="+CostantiDB.SERVIZI+".id");
  264.                 sqlQueryObjectNotExist.setANDLogicOperator(true);

  266.                 sqlQueryObject.addWhereExistsCondition(true, sqlQueryObjectNotExist);

  268.                 queryString = sqlQueryObject.createSQLQuery();
  269.                 stmt = con.prepareStatement(queryString);
  270.                 stmt.setLong(1, idAccordoLong);
  271.                 stmt.setLong(2, idAccordoLong);
  272.                 index = 3;
  273.                 if(as.getPrivato()==null || !as.getPrivato()){
  274.                     stmt.setInt(index, 0);
  275.                     index++;
  276.                 }
  277.                 if( !isVisioneOggettiGlobale(userLogin)){
  278.                     stmt.setString(index, userLogin);
  279.                     index++;
  280.                 }
  281.                 risultato = stmt.executeQuery();
  282.                 while (risultato.next()) {
  283.                     long idServizio = risultato.getLong("idServizio");
  284.                     AccordoServizioParteSpecifica asps =  apsCore.getAccordoServizioParteSpecifica(idServizio);
  285.                     
  286.                     if(tipiServiziCompatibili.contains(asps.getTipo()) && tipiSoggettiCompatibili.contains(asps.getTipoSoggettoErogatore())){
  287.                         serviziL.add(""+idServizio);
  288.                         serviziLabelL.add(helper.getLabelIdServizio(asps));
  289.                     }
  290.                 }
  291.                 risultato.close();
  292.                 stmt.close();

  294.                 serviziList = serviziL.toArray(new String[1]);
  295.                 serviziListLabel = serviziLabelL.toArray(new String[1]);
  296.             }
  297.         }catch (Exception e) {
  298.             ControlStationCore.logError(getPrefixError(nomeMetodo,  e), e);
  299.         } finally{
  300.             try {
  301.                 if(risultato!=null) {
  302.                     risultato.close();
  303.                 }
  304.             }catch(Exception t) {
  305.                 // ignore
  306.             }
  307.             try {
  308.                 if(stmt!=null) {
  309.                     stmt.close();
  310.                 }
  311.             }catch(Exception t) {
  312.                 // ignore
  313.             }
  314.             ControlStationCore.dbM.releaseConnection(con);
  315.         }

  317.         List<String[]> toRet = new ArrayList<>();
  318.         toRet.add(serviziList);
  319.         toRet.add(serviziListLabel);

  321.         return toRet;
  322.     }
  323. }
Created with JaCoCo 0.8.8.202204050719