BasicServiceLibraryReader.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.monitor.engine.config;

  22. import org.openspcoop2.core.commons.dao.DAOFactory;
  23. import org.openspcoop2.core.commons.dao.DAOFactoryException;
  24. import org.openspcoop2.core.plugins.ConfigurazioneServizio;
  25. import org.openspcoop2.core.plugins.ConfigurazioneServizioAzione;
  26. import org.openspcoop2.core.plugins.IdConfigurazioneServizio;
  27. import org.openspcoop2.core.plugins.IdConfigurazioneServizioAzione;
  28. import org.openspcoop2.core.plugins.dao.IConfigurazioneServizioAzioneServiceSearch;
  29. import org.openspcoop2.core.plugins.dao.IConfigurazioneServizioServiceSearch;
  30. import org.openspcoop2.core.commons.search.IdAccordoServizioParteSpecifica;
  31. import org.openspcoop2.core.commons.search.IdSoggetto;
  32. import org.openspcoop2.core.commons.search.dao.IAccordoServizioParteSpecificaServiceSearch;

  34. import java.sql.Connection;

  36. import org.slf4j.Logger;
  37. import org.openspcoop2.core.id.IDAccordo;
  38. import org.openspcoop2.core.id.IDServizio;
  39. import org.openspcoop2.core.id.IDSoggetto;
  40. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  41. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  42. import org.openspcoop2.generic_project.exception.MultipleResultException;
  43. import org.openspcoop2.generic_project.exception.NotFoundException;
  44. import org.openspcoop2.generic_project.exception.NotImplementedException;
  45. import org.openspcoop2.generic_project.exception.ServiceException;
  46. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;

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

  57.     private Connection connection;
  58.     private DAOFactory daoFactory = null;
  59.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPlugins = null;
  60.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesUtils = null;
  61.     private Logger daoFactoryLogger = null;
  62.     
  63.     private org.openspcoop2.core.plugins.dao.IServiceManager serviceManagerPluginsBase;
  64.     private org.openspcoop2.core.commons.search.dao.IServiceManager serviceManagerUtils;
  65.     
  66.     private boolean debug;
  67.     
  68.     public BasicServiceLibraryReader(Connection connection,
  69.             DAOFactory daoFactory, 
  70.             ServiceManagerProperties daoFactoryServiceManagerPropertiesPlugins,
  71.             ServiceManagerProperties daoFactoryServiceManagerPropertiesUtils,
  72.             Logger daoFactoryLogger, boolean debug){
  73.         this.connection = connection;
  74.         this.daoFactory = daoFactory;
  75.         this.daoFactoryServiceManagerPropertiesPlugins = daoFactoryServiceManagerPropertiesPlugins;
  76.         this.daoFactoryServiceManagerPropertiesUtils = daoFactoryServiceManagerPropertiesUtils;
  77.         this.daoFactoryLogger = daoFactoryLogger;
  78.         this.debug = debug;
  79.     }
  80.     public BasicServiceLibraryReader(org.openspcoop2.core.plugins.dao.IServiceManager jdbcServiceManagerPluginsBase, 
  81.             org.openspcoop2.core.commons.search.dao.IServiceManager jdbcServiceManagerUtils,
  82.             boolean debug){
  83.         this.serviceManagerPluginsBase = jdbcServiceManagerPluginsBase;
  84.         this.serviceManagerUtils = jdbcServiceManagerUtils;
  85.         this.debug = debug;
  86.     }
  87.     
  88.     public BasicServiceLibrary read(IDServizio idServizio,Logger log) throws Exception{
  89.         
  90.         String azione = idServizio.getAzione();
  91.         
  92.         // Ottengo dati Servizio SPCoop
  93.         
  94.         org.openspcoop2.core.commons.search.AccordoServizioParteSpecifica s = null;
  95.         try{
  96.             s = this.getAccordoServizioParteSpecifica(idServizio);
  97.             if(s==null){
  98.                 throw new NotFoundException("Null instance return");
  99.             }
  100.         }catch(NotFoundException notFound){
  101.             // non e' stata configurata una parte specifica
  102.             if(this.debug){
  103.                 log.debug("Non รจ stata trovata una parte specifica con id ["+idServizio.toString()+"]: "+notFound.getMessage(),notFound);
  104.             }
  105.             return null;
  106.         }
  107.         
  108.     
  109.         
  110.         String portType = null;
  111.         if(s.getPortType()!=null && !"".equals(s.getPortType())){
  112.             portType = s.getPortType();
  113.         }
  114.         else{
  115.             portType = idServizio.getNome();
  116.         }
  117.         
  118.         if(s.getIdAccordoServizioParteComune().getIdSoggetto()==null){
  119.             log.warn("Il servizio indicato ["+idServizio+"] implementa un accordo che non contiene un soggetto referente. Opzione non supportata");
  120.             return null;
  121.         }
  122.         
  123.         IDSoggetto soggettoReferente = new IDSoggetto(s.getIdAccordoServizioParteComune().getIdSoggetto().getTipo(), s.getIdAccordoServizioParteComune().getIdSoggetto().getNome());
  124.         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromValues(s.getIdAccordoServizioParteComune().getNome(), 
  125.                 soggettoReferente, 
  126.                 s.getIdAccordoServizioParteComune().getVersione());
  127.         
  128.         BasicServiceLibrary basicServiceLibrary = this.read(idAccordo, portType, azione, log);
  129.         if(basicServiceLibrary!=null){
  130.             basicServiceLibrary.setIdServizio(idServizio);
  131.             basicServiceLibrary.setAccordoServizioParteSpecifica(s);
  132.         }
  133.         
  134.         return basicServiceLibrary;
  135.     }

  137.     public boolean existsAlmostOneBasicServiceLibrary(Logger log) throws Exception{
  138.         return this._existsAlmostOneBasicServiceLibrary();
  139.     }
  140.     
  141.     public BasicServiceLibrary read(IDAccordo idAccordo,String portType,String azione,Logger log) throws Exception{
  142.         
  143.         BasicServiceLibrary basicServiceLibrary = new BasicServiceLibrary();
  144.         basicServiceLibrary.setIdAccordoServizioParteComune(idAccordo);
  145.         basicServiceLibrary.setPortType(portType);
  146.         basicServiceLibrary.setAzione(azione);
  147.         
  148.         // Ottengo dati Accordo di Servizio
  149.         
  150.         // Leggo libreria servizio
  151.         ConfigurazioneServizio serviceLibrary = null;
  152.         try{
  153.             serviceLibrary = this.getServiceLibrary(idAccordo, portType);
  154.             if(serviceLibrary==null){
  155.                 throw new NotFoundException("Null instance return");
  156.             }
  157.         }catch(NotFoundException notFound){
  158.             // non e' stata configurata una libreria di servizio
  159.             if(this.debug){
  160.                 log.debug("NON e' stata configurata una libreria di servizio ["+portType+"] dell'accordo ["+idAccordo.toString()+"]");
  161.             }
  162.             return null;
  163.         }
  164.         basicServiceLibrary.setServiceLibrary(serviceLibrary);

  166.             
  167.         // ** Verifico se esiste una azione conforme a quella arrivata.**
  168.         ConfigurazioneServizioAzione serviceActionLibrary = null;
  169.         if(azione!=null){
  170.             try{
  171.                 serviceActionLibrary = getServiceActionLibrary(serviceLibrary, azione);
  172.                 if(serviceActionLibrary==null){
  173.                     throw new NotFoundException("Null instance return");
  174.                 }
  175.             }catch(NotFoundException notFound){
  176.                 // non e' stata configurata una libreria di servizio per l'azione specifica
  177.                 if(this.debug){
  178.                     log.debug("Non risulta configurata configurata l'azione specifica ["+azione+"] per la libreria di servizio ["+portType+"] dell'accordo ["+idAccordo.toString()+"]",notFound);
  179.                 }
  180.             }
  181.         }
  182.         basicServiceLibrary.setServiceActionLibrary(serviceActionLibrary);
  183.         
  184.         // ** Recupero informazioni per azione '*'
  185.         ConfigurazioneServizioAzione serviceActionAllLibrary = null;
  186.         try{
  187.             serviceActionAllLibrary = getServiceActionLibrary(serviceLibrary, "*");
  188.             if(serviceActionAllLibrary==null){
  189.                 throw new NotFoundException("Null instance return");
  190.             }
  191.         }catch(NotFoundException notFound){
  192.             // non e' stata configurata una libreria di servizio per l'azione * ????
  193.             String errorMsg = "Non risulta configurata configurata l'azione specifica ["+"*"+"] per la libreria di servizio ["+portType+"] dell'accordo ["+idAccordo.toString()+"]";
  194.             log.error(errorMsg,notFound);
  195.             throw new NotFoundException(errorMsg,notFound);
  196.         }
  197.         basicServiceLibrary.setServiceActionAllLibrary(serviceActionAllLibrary);
  198.         
  199.         return basicServiceLibrary;
  200.     }
  201.     
  202.     private org.openspcoop2.core.commons.search.AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio) throws DAOFactoryException, ServiceException, NotImplementedException, NotFoundException, MultipleResultException {
  203.         
  204.         boolean autoCommit = true;
  205.         
  206.         org.openspcoop2.core.commons.search.dao.IServiceManager serviceManager = this.serviceManagerUtils;
  207.         if(serviceManager==null){
  208.             serviceManager = 
  209.                     (org.openspcoop2.core.commons.search.dao.IServiceManager) this.daoFactory.getServiceManager(
  210.                             org.openspcoop2.core.commons.search.utils.ProjectInfo.getInstance(), 
  211.                             this.connection, autoCommit,
  212.                             this.daoFactoryServiceManagerPropertiesUtils, this.daoFactoryLogger);
  213.             if(serviceManager instanceof org.openspcoop2.core.commons.search.dao.jdbc.JDBCServiceManager)
  214.                 ((org.openspcoop2.core.commons.search.dao.jdbc.JDBCServiceManager)serviceManager).getJdbcProperties().setShowSql(this.debug);
  215.         }
  216.         
  217.         IAccordoServizioParteSpecificaServiceSearch search = serviceManager.getAccordoServizioParteSpecificaServiceSearch();
  218.         
  219.         IdAccordoServizioParteSpecifica idAS = new IdAccordoServizioParteSpecifica();
  220.         IdSoggetto idErogatore = new IdSoggetto();
  221.         idErogatore.setTipo(idServizio.getSoggettoErogatore().getTipo());
  222.         idErogatore.setNome(idServizio.getSoggettoErogatore().getNome());
  223.         idAS.setIdErogatore(idErogatore);
  224.         idAS.setTipo(idServizio.getTipo());
  225.         idAS.setNome(idServizio.getNome());
  226.         idAS.setVersione(idServizio.getVersione());
  227.         
  228.         return search.get(idAS);
  229.         
  230.     }
  231.     
  232.     private boolean _existsAlmostOneBasicServiceLibrary() throws DAOFactoryException, ServiceException, NotImplementedException {
  233.         
  234.         boolean autoCommit = true;
  235.         
  236.         org.openspcoop2.core.plugins.dao.IServiceManager serviceManager = this.serviceManagerPluginsBase;
  237.         if(serviceManager==null){
  238.             serviceManager = (org.openspcoop2.core.plugins.dao.IServiceManager) this.daoFactory.getServiceManager(
  239.                     org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  240.                     this.connection, autoCommit,
  241.                         this.daoFactoryServiceManagerPropertiesPlugins, this.daoFactoryLogger);
  242.             if(serviceManager instanceof org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)
  243.                 ((org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)serviceManager).getJdbcProperties().setShowSql(this.debug);
  244.         }
  245.         
  246.         IConfigurazioneServizioServiceSearch search = serviceManager.getConfigurazioneServizioServiceSearch();
  247.         NonNegativeNumber nn = search.count(search.newExpression());
  248.         return nn!=null && nn.longValue()>0;

  250.     }
  251.     
  252.     private ConfigurazioneServizio getServiceLibrary(IDAccordo idAccordo,String portType) throws DAOFactoryException, ServiceException, NotImplementedException, NotFoundException, MultipleResultException {
  253.         
  254.         boolean autoCommit = true;
  255.         
  256.         org.openspcoop2.core.plugins.dao.IServiceManager serviceManager = this.serviceManagerPluginsBase;
  257.         if(serviceManager==null){
  258.             serviceManager = (org.openspcoop2.core.plugins.dao.IServiceManager) this.daoFactory.getServiceManager(
  259.                     org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  260.                     this.connection, autoCommit,
  261.                         this.daoFactoryServiceManagerPropertiesPlugins, this.daoFactoryLogger);
  262.             if(serviceManager instanceof org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)
  263.                 ((org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)serviceManager).getJdbcProperties().setShowSql(this.debug);
  264.         }
  265.         
  266.         IConfigurazioneServizioServiceSearch search = serviceManager.getConfigurazioneServizioServiceSearch();
  267.         
  268.         IdConfigurazioneServizio idConfigurazioneServizio = new IdConfigurazioneServizio();
  269.         idConfigurazioneServizio.setAccordo(idAccordo.getNome());
  270.         if(idAccordo.getSoggettoReferente()!=null){
  271.             idConfigurazioneServizio.setTipoSoggettoReferente(idAccordo.getSoggettoReferente().getTipo());
  272.             idConfigurazioneServizio.setNomeSoggettoReferente(idAccordo.getSoggettoReferente().getNome());
  273.         }
  274.         idConfigurazioneServizio.setServizio(portType);
  275.         if(idAccordo.getVersione()!=null){
  276.             idConfigurazioneServizio.setVersione(idAccordo.getVersione());
  277.         }
  278.         
  279.         return search.get(idConfigurazioneServizio);
  280.         
  281.     }
  282.     
  283.     private ConfigurazioneServizioAzione getServiceActionLibrary(ConfigurazioneServizio serviceLibrary,String azione) throws DAOFactoryException, ServiceException, NotImplementedException, NotFoundException, MultipleResultException {
  284.         
  285.         boolean autoCommit = true;
  286.         
  287.         org.openspcoop2.core.plugins.dao.IServiceManager serviceManager = this.serviceManagerPluginsBase;
  288.         if(serviceManager==null){
  289.             serviceManager = (org.openspcoop2.core.plugins.dao.IServiceManager) this.daoFactory.getServiceManager(
  290.                     org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  291.                     this.connection, autoCommit,
  292.                     this.daoFactoryServiceManagerPropertiesPlugins, this.daoFactoryLogger);
  293.             if(serviceManager instanceof org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)
  294.                 ((org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager)serviceManager).getJdbcProperties().setShowSql(this.debug);
  295.         }
  296.         
  297.         IConfigurazioneServizioServiceSearch serviceSearch = serviceManager.getConfigurazioneServizioServiceSearch();
  298.         IdConfigurazioneServizio idConfigurazioneServizio = serviceSearch.convertToId(serviceLibrary);
  299.         
  300.         IConfigurazioneServizioAzioneServiceSearch search = serviceManager.getConfigurazioneServizioAzioneServiceSearch();
  301.         
  302.         IdConfigurazioneServizioAzione idConfigurazioneServizioAzione = new IdConfigurazioneServizioAzione();
  303.         idConfigurazioneServizioAzione.setIdConfigurazioneServizio(idConfigurazioneServizio);
  304.         idConfigurazioneServizioAzione.setAzione(azione);
  305.         
  306.         return search.get(idConfigurazioneServizioAzione);
  307.         
  308.     }
  309. }
Created with JaCoCo 0.8.8.202204050719