XMLDataConverterMainProcessor.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.registry.driver.utils;

  23. import java.io.File;
  24. import java.io.FileInputStream;
  25. import java.net.URL;
  26. import java.sql.Connection;
  27. import java.sql.DriverManager;
  28. import java.util.Enumeration;

  30. import org.apache.logging.log4j.Level;
  31. import org.openspcoop2.core.config.AccessoRegistroRegistro;
  32. import org.openspcoop2.core.config.constants.RegistroTipo;
  33. import org.openspcoop2.core.registry.constants.StatiAccordo;
  34. import org.openspcoop2.utils.LoggerWrapperFactory;
  35. import org.openspcoop2.utils.Semaphore;
  36. import org.openspcoop2.utils.SemaphoreLock;
  37. import org.openspcoop2.utils.Utilities;
  38. import org.openspcoop2.utils.resources.FileSystemUtilities;
  39. import org.openspcoop2.utils.resources.Loader;
  40. import org.slf4j.Logger;

  42. /**
  43.  * Inizializza un registro Servizi
  44.  * 
  45.  * @author Andrea Poli (apoli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */

  50. public class XMLDataConverterMainProcessor {


  53.     public static void main(String[] argoments) throws Exception {

  55.         if (argoments.length  < 9) {
  56.             String errorMsg = "ERROR, Usage:  java XMLDataConverterMainProcessor sorgenteXML tipoRegistroCRUD proprietaRegistroCRUD reset tipoConversione gestioneSoggetti mantieniFruitori deleteMappingErogazioneFruizione statoAccordiImportati protocolloDefault [[logger] [nomePddOperativa logger]]";
  57.             System.err.println(errorMsg);
  58.             throw new Exception(errorMsg);
  59.         }

  61.         String args_sorgenteXML = argoments[0].trim();
  62.         String args_tipoRegistroCRUD = argoments[1].trim();
  63.         String args_proprietaRegistroCRUD = argoments[2].trim();
  64.         String args_reset = argoments[3].trim();
  65.         String args_tipoConversione = argoments[4].trim();
  66.         String args_gestioneSoggetti = argoments[5].trim();
  67.         String args_mantieniFruitori = argoments[6].trim();
  68.         String argsdeleteEngineMappingErogazioneFruizione = argoments[7].trim();
  69.         String args_statoAccordiImportati = argoments[8].trim();
  70.         String args_protocolloDefault = argoments[9].trim();
  71.         String args_nomePddOperativa = null;
  72.         String args_logger = null;
  73.         if(argoments.length==11){
  74.             args_logger = argoments[10].trim();
  75.         }
  76.         else{
  77.             args_nomePddOperativa = argoments[10].trim();
  78.             args_logger = argoments[11].trim();
  79.         }
  80.         
  81.         // Inizializzo logger
  82.         String loggerValue = null;
  83.         try{
  84.             if(args_logger!=null){
  85.                 LoggerWrapperFactory.setLogConfiguration(args_logger);
  86.             }else{
  87.                 URL url = XMLDataConverterMainProcessor.class.getResource("/xml2backend.log4j2.properties");
  88.                 if(url!=null){
  89.                     LoggerWrapperFactory.setLogConfiguration(url);
  90.                 }
  91.                 else{
  92.                     File logFile = FileSystemUtilities.createTempFile("testXMLDataConverterRegistro_", ".log");
  93.                     System.out.println("LogMessages write in "+logFile.getAbsolutePath());
  94.                     LoggerWrapperFactory.setDefaultLogConfiguration(Level.ALL, false, null, logFile, "%p <%d{dd-MM-yyyy HH:mm:ss}> %C.%M(%L): %m %n %n");
  95.                 }
  96.             }
  97.         }catch(Exception e) {
  98.             String errorMsg = "Errore durante il caricamento del file di log loggerValue["+loggerValue+"] : "+e.getMessage();
  99.             System.err.println(errorMsg);
  100.             System.out.println("Args.length: "+argoments.length);
  101.             for (int i = 0; i < argoments.length; i++) {
  102.                 System.out.println("Arg["+i+"]=["+argoments[i]+"]");
  103.             }
  104.             throw new Exception(errorMsg,e);
  105.         }   
  106.         Logger log = LoggerWrapperFactory.getLogger("gestoreDatiRegistro");
  107.         
  108.         // StatoAccordo
  109.         String statoAccordo = args_statoAccordiImportati;
  110.         if(!StatiAccordo.bozza.toString().equals(statoAccordo) && !StatiAccordo.operativo.toString().equals(statoAccordo) && !StatiAccordo.finale.toString().equals(statoAccordo)){
  111.             String errorMsg = "Opzione 'statoAccordiImportati' non valida ("+statoAccordo+"), valori possibili sono: "+StatiAccordo.bozza.toString()+","+StatiAccordo.operativo.toString()+","+StatiAccordo.finale.toString();
  112.             System.err.println(errorMsg);
  113.             throw new Exception(errorMsg);
  114.         }
  115.         StatiAccordo statoAccordoObject = StatiAccordo.valueOf(statoAccordo);

  117.         // ProtocolloDefault
  118.         String protocolloDefault = args_protocolloDefault;
  119.         
  120.         // Reset
  121.         boolean reset = Boolean.parseBoolean(args_reset);
  122.         
  123.         // GestioneSoggetti
  124.         boolean gestioneSoggetti =  Boolean.parseBoolean(args_gestioneSoggetti);
  125.         
  126.         // MantieniFruitori
  127.         boolean mantieniFruitori = Boolean.parseBoolean(args_mantieniFruitori);
  128.         
  129.         // DeleteMappingErogazioneFruizione
  130.         boolean deleteMappingErogazioneFruizione = Boolean.parseBoolean(argsdeleteEngineMappingErogazioneFruizione);
  131.         
  132.         // Properties
  133.         java.util.Properties reader = new java.util.Properties();
  134.         try{
  135.             try(FileInputStream fin = new FileInputStream(args_proprietaRegistroCRUD)){
  136.                 reader.load(fin);
  137.             }
  138.         }catch(java.io.IOException e) {
  139.             String errorMsg = "Errore durante il caricamento del file di properties ["+args_proprietaRegistroCRUD+"] : "+e.getMessage();
  140.             log.error(errorMsg,e);
  141.             throw new Exception(errorMsg,e);
  142.         }

  144.         // Raccolta proprieta'
  145.         AccessoRegistroRegistro acCRUD = new AccessoRegistroRegistro();

  147.         String superUser = null;
  148.         boolean connectionDB = false;
  149.         String connection = null;
  150.         String username = null;
  151.         String password = null;
  152.         String driver =  null;
  153.         String tipoDatabase = null;
  154.         try{
  155.             acCRUD.setTipo(RegistroTipo.toEnumConstant(args_tipoRegistroCRUD));
  156.             
  157.             superUser = reader.getProperty("openspcoop2.superuser");
  158.             if(superUser!=null)
  159.                 superUser = superUser.trim();
  160.             
  161.             if("db".equals(args_tipoRegistroCRUD)){
  162.                 // Database
  163.                 tipoDatabase = reader.getProperty("openspcoop2.registroServizi.db.tipo");
  164.                 if(tipoDatabase==null){
  165.                     throw new Exception("Non e' stato definito il tipo di database");
  166.                 }else{
  167.                     tipoDatabase = tipoDatabase.trim();
  168.                 }
  169.                 
  170.                 String dataSource = reader.getProperty("openspcoop2.registroServizi.db.dataSource");
  171.                 if(dataSource!=null){
  172.                     dataSource = dataSource.trim();
  173.                     java.util.Properties context = Utilities.readProperties("openspcoop2.registroServizi.db.context.",reader);
  174.                     acCRUD.setLocation(dataSource);
  175.                     acCRUD.setTipoDatabase(tipoDatabase);
  176.                     Enumeration<?> keys = context.keys();
  177.                     while (keys.hasMoreElements()) {
  178.                         String key = (String) keys.nextElement();
  179.                         String value = context.getProperty(key);
  180.                         acCRUD.putGenericProperties(key, value);
  181.                     }
  182.                 }else{
  183.                     connectionDB = true;
  184.                     connection = reader.getProperty("openspcoop2.registroServizi.db.url");
  185.                     if(connection==null){
  186.                         throw new Exception("Non e' stata definita una destinazione ne attraverso un datasource, ne attraverso una connessione diretta");
  187.                     }
  188.                     connection = connection.trim();
  189.                     driver = reader.getProperty("openspcoop2.registroServizi.db.driver");
  190.                     if(driver==null){
  191.                         throw new Exception("Connessione diretta: non e' stato definito il Driver");
  192.                     }
  193.                     driver = driver.trim();
  194.                     username = reader.getProperty("openspcoop2.registroServizi.db.user");
  195.                     password = reader.getProperty("openspcoop2.registroServizi.db.password");
  196.                     if(username!=null){
  197.                         username = username.trim();
  198.                     }
  199.                     if(password!=null){
  200.                         password = password.trim();
  201.                     }
  202.                 }       
  203.             }else if("uddi".equals(args_tipoRegistroCRUD)){
  204.                 // UDDI
  205.                 String inquiryUrl = reader.getProperty("openspcoop2.registroServizi.uddi.inquiryUrl");
  206.                 if(inquiryUrl!=null)
  207.                     inquiryUrl = inquiryUrl.trim();
  208.                 String publishUrl = reader.getProperty("openspcoop2.registroServizi.uddi.publishUrl");
  209.                 if(publishUrl!=null)
  210.                     publishUrl = publishUrl.trim();
  211.                 String usernameUDDI = reader.getProperty("openspcoop2.registroServizi.uddi.username");
  212.                 if(usernameUDDI!=null)
  213.                     usernameUDDI = usernameUDDI.trim();
  214.                 String passwordUDDI = reader.getProperty("openspcoop2.registroServizi.uddi.password");
  215.                 if(passwordUDDI!=null)
  216.                     passwordUDDI = passwordUDDI.trim();
  217.                 String urlPrefix = reader.getProperty("openspcoop2.registroServizi.uddi.urlPrefix");
  218.                 if(urlPrefix!=null)
  219.                     urlPrefix = urlPrefix.trim();
  220.                 String pathPrefix = reader.getProperty("openspcoop2.registroServizi.uddi.pathPrefix");
  221.                 if(pathPrefix!=null)
  222.                     pathPrefix = pathPrefix.trim();
  223.                 acCRUD.setLocation(inquiryUrl);
  224.                 acCRUD.setUser(usernameUDDI);
  225.                 acCRUD.setPassword(passwordUDDI);
  226.                 acCRUD.putGenericProperties("publishUrl", publishUrl);
  227.                 acCRUD.putGenericProperties("urlPrefix", urlPrefix);
  228.                 acCRUD.putGenericProperties("pathPrefix", pathPrefix);
  229.             }else if("web".equals(args_tipoRegistroCRUD)){
  230.                 // WEB
  231.                 String urlPrefix = reader.getProperty("openspcoop2.registroServizi.web.urlPrefix");
  232.                 if(urlPrefix!=null)
  233.                     urlPrefix = urlPrefix.trim();
  234.                 String pathPrefix = reader.getProperty("openspcoop2.registroServizi.web.pathPrefix");
  235.                 if(pathPrefix!=null)
  236.                     pathPrefix = pathPrefix.trim();
  237.                 acCRUD.setLocation(urlPrefix);
  238.                 acCRUD.putGenericProperties("pathPrefix", pathPrefix);
  239.             }

  241.         }catch(Exception e) {
  242.             String errorMsg = "Errore durante la lettura del file di properties ["+args_proprietaRegistroCRUD+"] : "+e.getMessage();
  243.             log.error(errorMsg,e);
  244.             throw new Exception(errorMsg,e);
  245.         }

  247.         Connection connectionSQL = null;
  248.         try{
  249.             File fSorgente = new File(args_sorgenteXML);
  250.             if(connectionDB){       
  251.                 Loader.getInstance().newInstance(driver);
  252.                 if(username!=null && password!=null){
  253.                     connectionSQL = DriverManager.getConnection(connection,username,password);
  254.                 }else{
  255.                     connectionSQL = DriverManager.getConnection(connection);
  256.                 }
  257.             }
  258.             
  259.             XMLDataConverterMainProcessor.letturaSorgenti(fSorgente, connectionDB, connectionSQL, tipoDatabase, log, superUser, acCRUD, 
  260.                     statoAccordoObject, protocolloDefault, args_tipoConversione, args_nomePddOperativa, gestioneSoggetti, reset, mantieniFruitori,deleteMappingErogazioneFruizione);
  261.             
  262.         }catch(Exception e){
  263.             String errorMsg = "Errore durante la conversione XML dei dati: "+e.getMessage(); 
  264.             log.error(errorMsg,e);
  265.             throw new Exception(errorMsg,e);
  266.         }finally{
  267.             try{
  268.                 if(connectionSQL!=null)
  269.                     connectionSQL.close();
  270.             }catch(Exception e){
  271.                 // close
  272.             }
  273.         }
  274.     }
  275.     
  276.     
  277.     private static Semaphore semaphoreResetEffettuata = new Semaphore("TestXMLDataConverterRegistryReset");
  278.     private static Boolean resetEffettuata = false;
  279.     private static boolean reset(boolean b){
  280.         if(b){
  281.             // Se si desidera la reset, controllo se e' gia stata effettuata
  282.             SemaphoreLock lock = semaphoreResetEffettuata.acquireThrowRuntime("reset");
  283.             try {
  284.                 if(XMLDataConverterMainProcessor.resetEffettuata==false){
  285.                     XMLDataConverterMainProcessor.resetEffettuata=true;
  286.                     return true;
  287.                 }
  288.                 else{
  289.                     return false;
  290.                 }
  291.             }finally {
  292.                 semaphoreResetEffettuata.release(lock, "reset");
  293.             }
  294.         }
  295.         return false;
  296.     }
  297.     
  298.     
  299.     private static void letturaSorgenti(File fSorgente,boolean connectionDB,Connection connectionSQL,
  300.             String tipoDatabase,Logger log,String superUser,AccessoRegistroRegistro acCRUD,
  301.             StatiAccordo statoAccordoObject,String protocolloDefault,
  302.             String tipoConversione,String nomePddOperativa,
  303.             boolean gestioneSoggetti,boolean reset, boolean mantieniFruitori, boolean deleteMappingErogazioneFruizione) throws Exception{
  304.         if(fSorgente.isFile()){
  305.             if(fSorgente.canRead()==false){
  306.                 throw new Exception("Sorgente XML ["+fSorgente.getAbsolutePath()+"] non accessibile in lettura");
  307.             }
  308.             if(fSorgente.getName().endsWith(".xml")){
  309.                 // Per non convertire i wsdl e i xml
  310.                 XMLDataConverterMainProcessor.converti(fSorgente, connectionDB, connectionSQL, tipoDatabase, log, superUser, acCRUD, 
  311.                         statoAccordoObject, protocolloDefault,tipoConversione,nomePddOperativa,gestioneSoggetti,reset,mantieniFruitori,deleteMappingErogazioneFruizione);
  312.             }
  313.             else{
  314.                 log.debug("File ["+fSorgente.getAbsolutePath()+"] ignorato. Non possiede l'estensione .xml");
  315.             }
  316.         }
  317.         else if(fSorgente.isDirectory()){
  318.             
  319.             if(fSorgente.canRead()==false){
  320.                 throw new Exception("Directory contenente gli XML ["+fSorgente.getAbsolutePath()+"] non accessibile in lettura");
  321.             }
  322.             
  323.             File [] f = fSorgente.listFiles();
  324.             if(f==null || f.length<=0){
  325.                 throw new Exception("Directory ["+fSorgente.getAbsolutePath()+"] non contiene XML");
  326.             }
  327.             for(int i=0; i<f.length; i++){
  328.             
  329.                 XMLDataConverterMainProcessor.letturaSorgenti(f[i], connectionDB, connectionSQL, tipoDatabase, log, superUser, acCRUD, 
  330.                         statoAccordoObject, protocolloDefault,tipoConversione,nomePddOperativa,gestioneSoggetti,reset,mantieniFruitori,deleteMappingErogazioneFruizione);
  331.                 
  332.             }
  333.         }
  334.     }
  335.     
  336.     
  337.     private static void converti(File f,boolean connectionDB,Connection connectionSQL,
  338.             String tipoDatabase,Logger log,String superUser,AccessoRegistroRegistro acCRUD,
  339.             StatiAccordo statoAccordoObject,String protocolloDefault,
  340.             String tipoConversione,String nomePddOperativa,
  341.             boolean gestioneSoggetti,boolean reset, boolean mantieniFruitori, boolean deleteMappingErogazioneFruizione) throws Exception{
  342.         
  343.         Logger logDriver = null;
  344.         if( org.openspcoop2.core.config.constants.RegistroTipo.UDDI.equals(acCRUD.getTipo()) || org.openspcoop2.core.config.constants.RegistroTipo.WEB.equals(acCRUD.getTipo()) ){
  345.             logDriver = log;
  346.         }
  347.         
  348.         // XMLDataConverter
  349.         XMLDataConverter dataConverter = null;
  350.         if(connectionDB){       
  351.             dataConverter = new XMLDataConverter(f.getAbsolutePath(),connectionSQL,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  352.         }else{
  353.             dataConverter = new XMLDataConverter(f.getAbsolutePath(),acCRUD,superUser,protocolloDefault,log,logDriver);
  354.         }
  355.         
  356.         if("insertUpdate".equals(tipoConversione)){
  357.             log.info("Inizio conversione...");
  358.             if(nomePddOperativa!=null){
  359.                 PdDConfig pddConfig = new PdDConfig();
  360.                 String pddOperativa = nomePddOperativa;
  361.                 pddConfig.setPddOperativaCtrlstatSinglePdd(pddOperativa);
  362.                 dataConverter.convertXML(XMLDataConverterMainProcessor.reset(reset),pddConfig,mantieniFruitori,gestioneSoggetti,statoAccordoObject);
  363.             }else{
  364.                 dataConverter.convertXML(XMLDataConverterMainProcessor.reset(reset),mantieniFruitori,gestioneSoggetti,statoAccordoObject);
  365.             }
  366.             log.info("Conversione terminata.");
  367.         }
  368.         else if("delete".equals(tipoConversione)){
  369.             log.info("Inizio conversione...");
  370.             dataConverter.delete(gestioneSoggetti, deleteMappingErogazioneFruizione);
  371.             log.info("Conversione terminata.");
  372.         }else{
  373.             throw new Exception("Valore opzione 'tipoConversioneRegistroServizi' non gestito (valori possibili insertUpdate/delete): "+tipoConversione);
  374.         }
  375.     }
  376. }
Created with JaCoCo 0.8.8.202204050719