Converter.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.core.monitor.rs.server.api.impl.utils;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;

  26. import org.apache.commons.lang.StringUtils;
  27. import org.joda.time.DateTime;
  28. import org.openspcoop2.core.eventi.constants.TipoSeverita;
  29. import org.openspcoop2.core.eventi.utils.SeveritaConverter;
  30. import org.openspcoop2.core.id.IDServizio;
  31. import org.openspcoop2.core.id.IDServizioApplicativo;
  32. import org.openspcoop2.core.monitor.rs.server.config.ServerProperties;
  33. import org.openspcoop2.core.monitor.rs.server.config.SoggettiConfig;
  34. import org.openspcoop2.core.monitor.rs.server.model.DetailTransazione;
  35. import org.openspcoop2.core.monitor.rs.server.model.Evento;
  36. import org.openspcoop2.core.monitor.rs.server.model.InfoImplementazioneApi;
  37. import org.openspcoop2.core.monitor.rs.server.model.ItemTransazione;
  38. import org.openspcoop2.core.monitor.rs.server.model.PDNDOrganizationExternalId;
  39. import org.openspcoop2.core.monitor.rs.server.model.PDNDOrganizationInfo;
  40. import org.openspcoop2.core.monitor.rs.server.model.PDNDOrganizationInfoItemTransazione;
  41. import org.openspcoop2.core.monitor.rs.server.model.Riepilogo;
  42. import org.openspcoop2.core.monitor.rs.server.model.RiepilogoApiItem;
  43. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  44. import org.openspcoop2.core.transazioni.CredenzialeMittente;
  45. import org.openspcoop2.core.transazioni.DumpMessaggio;
  46. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  47. import org.openspcoop2.core.transazioni.utils.CredenzialiMittente;
  48. import org.openspcoop2.core.transazioni.utils.credenziali.CredenzialeTokenClient;
  49. import org.openspcoop2.generic_project.expression.SortOrder;
  50. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  51. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  52. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  53. import org.openspcoop2.protocol.sdk.diagnostica.DriverMsgDiagnosticiNotFoundException;
  54. import org.openspcoop2.protocol.sdk.diagnostica.FiltroRicercaDiagnosticiConPaginazione;
  55. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  56. import org.openspcoop2.protocol.sdk.tracciamento.DriverTracciamentoNotFoundException;
  57. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  58. import org.openspcoop2.utils.UtilsException;
  59. import org.openspcoop2.utils.beans.BlackListElement;
  60. import org.openspcoop2.utils.service.beans.DiagnosticoSeveritaEnum;
  61. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  62. import org.openspcoop2.utils.service.beans.TransazioneExt;
  63. import org.openspcoop2.utils.service.beans.TransazioneRuoloEnum;
  64. import org.openspcoop2.utils.service.beans.utils.ProfiloUtils;
  65. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  66. import org.openspcoop2.web.monitor.core.core.PddMonitorProperties;
  67. import org.openspcoop2.web.monitor.eventi.bean.EventoBean;
  68. import org.openspcoop2.web.monitor.statistiche.bean.ConfigurazioneGenerale;
  69. import org.openspcoop2.web.monitor.statistiche.constants.CostantiConfigurazioni;
  70. import org.openspcoop2.web.monitor.transazioni.bean.TransazioneBean;
  71. import org.openspcoop2.web.monitor.transazioni.dao.TransazioniService;
  72. import org.openspcoop2.web.monitor.transazioni.datamodel.TransazioniDM;
  73. import org.slf4j.Logger;

  75. /**
  76.  * Converter
  77.  * 
  78.  * @author $Author$
  79.  * @version $Rev$, $Date$
  80.  * 
  81.  */
  82. public class Converter {

  84.     public static String toProtocollo(ProfiloEnum profilo) throws UtilsException {
  85.         if(profilo==null) {
  86.             return ServerProperties.getInstance().getProtocolloDefault();
  87.         }
  88.         return ProfiloUtils.toProtocollo(profilo);
  89.     }
  90.     
  91.     public static Integer toOffset(Integer offset) {
  92.         return offset!=null ? offset : 0;
  93.     }
  94.     public static Integer toLimit(Integer limit) {
  95.         return limit!=null ? limit : 25;
  96.     }
  97.     public static SortOrder toSortOrder(String sort) {
  98.         if(StringUtils.isNotEmpty(sort)) {
  99.             if(sort.startsWith("+")) {
  100.                 return SortOrder.ASC;
  101.             }
  102.             else if(sort.startsWith("-")) {
  103.                 return SortOrder.DESC;
  104.             }
  105.         }
  106.         return SortOrder.DESC;
  107.     }
  108.     public static String toSortField(String sort) {
  109.         if(StringUtils.isNotEmpty(sort)) {
  110.             String sortParam = sort;
  111.             if(sort.startsWith("+") || sort.startsWith("-")) {
  112.                 sortParam = sort.substring(1);
  113.             }
  114.             if(TransazioniDM.COL_DATA_LATENZA_TOTALE.equals(sortParam)){
  115.                 return sortParam;
  116.             } else if(TransazioniDM.COL_DATA_LATENZA_SERVIZIO.equals(sortParam)){
  117.                 return sortParam;
  118.             } else if(TransazioniDM.COL_DATA_INGRESSO_RICHIESTA.equals(sortParam)){
  119.                 return sortParam;
  120.             }
  121.             else {
  122.                 FaultCode.RICHIESTA_NON_VALIDA.throwException("Sort parameter '"+sort+"' non valido");
  123.             }
  124.         }
  125.         return TransazioniDM.COL_DATA_INGRESSO_RICHIESTA;
  126.     }
  127.     
  128.     public static DetailTransazione toTransazioneExt(TransazioneBean transazioneDB, TransazioniService transazioniService, 
  129.             Connection con, ServiceManagerProperties smp,
  130.             Logger log) throws Exception {
  131.         org.openspcoop2.pdd.logger.traccia.Converter converter = new org.openspcoop2.pdd.logger.traccia.Converter(log);
  132.         
  133.         PddMonitorProperties govwayMonitorProperties = PddMonitorProperties.getInstance(log);
  134.         
  135.         Traccia tracciaRichiesta = null;
  136.         try {
  137.             tracciaRichiesta = govwayMonitorProperties.getDriverTracciamento(con,smp).getTraccia(transazioneDB.getIdTransazione(), RuoloMessaggio.RICHIESTA);
  138.         }catch(DriverTracciamentoNotFoundException notFound) {}
  139.         
  140.         Traccia tracciaRisposta = null;
  141.         try {
  142.             tracciaRisposta = govwayMonitorProperties.getDriverTracciamento(con,smp).getTraccia(transazioneDB.getIdTransazione(), RuoloMessaggio.RISPOSTA);
  143.         }catch(DriverTracciamentoNotFoundException notFound) {}
  144.         
  145.         FiltroRicercaDiagnosticiConPaginazione filter = new FiltroRicercaDiagnosticiConPaginazione();
  146.         filter.setIdTransazione(transazioneDB.getIdTransazione());
  147.         List<MsgDiagnostico> messaggiDiagnostici = null;
  148.         try {
  149.             messaggiDiagnostici = govwayMonitorProperties.getDriverMsgDiagnostici(con,smp).getMessaggiDiagnostici(filter);
  150.         }catch(DriverMsgDiagnosticiNotFoundException notFound) {}

  152.         CredenzialiMittente credenzialiMittente = Converter.convertToCredenzialiMittente(transazioneDB);        
  153.         
  154.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO)) {
  155.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO);
  156.             if(dumpMessaggio!=null) {
  157.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  158.             }
  159.         }
  160.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO)) {
  161.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO);
  162.             if(dumpMessaggio!=null) {
  163.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  164.             }
  165.         }
  166.         
  167.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO)) {
  168.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO);
  169.             if(dumpMessaggio!=null) {
  170.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  171.             }
  172.         }
  173.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA)) {
  174.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA);
  175.             if(dumpMessaggio!=null) {
  176.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  177.             }
  178.         }
  179.         
  180.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO)) {
  181.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO);
  182.             if(dumpMessaggio!=null) {
  183.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  184.             }
  185.         }
  186.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO)) {
  187.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO);
  188.             if(dumpMessaggio!=null) {
  189.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  190.             }
  191.         }
  192.         
  193.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO)) {
  194.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO);
  195.             if(dumpMessaggio!=null) {
  196.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  197.             }
  198.         }
  199.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA)) {
  200.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA);
  201.             if(dumpMessaggio!=null) {
  202.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  203.             }
  204.         }
  205.         
  206.         TransazioneExt transazioneExt = converter.toTransazioneExt(transazioneDB, credenzialiMittente, tracciaRichiesta, tracciaRisposta, messaggiDiagnostici);
  207.         
  208.         // aggiunto campi supplementari
  209.         
  210.         DetailTransazione detail = new DetailTransazione();
  211.         
  212.         if(transazioneExt.getRichiesta()!=null) {
  213.             detail.setData(transazioneExt.getRichiesta().getDataRicezione());
  214.         }
  215.         if(transazioneExt.getRichiesta()!=null && transazioneExt.getRichiesta().getDataConsegna()!=null &&
  216.                 transazioneExt.getRisposta()!=null && transazioneExt.getRisposta().getDataAccettazione()!=null) {
  217.             long dataRisposta = transazioneExt.getRisposta().getDataAccettazione().getMillis();
  218.             long dataRichiesta = transazioneExt.getRichiesta().getDataConsegna().getMillis(); 
  219.             detail.setLatenzaServizio(dataRisposta-dataRichiesta);
  220.         }
  221.         if(transazioneExt.getRichiesta()!=null && transazioneExt.getRichiesta().getDataAccettazione()!=null &&
  222.                 transazioneExt.getRisposta()!=null && transazioneExt.getRisposta().getDataConsegna()!=null) {
  223.             long dataRisposta = transazioneExt.getRisposta().getDataConsegna().getMillis();
  224.             long dataRichiesta = transazioneExt.getRichiesta().getDataAccettazione().getMillis(); 
  225.             detail.setLatenzaTotale(dataRisposta-dataRichiesta);
  226.         }
  227.         
  228.         String pdndOrganizationName = transazioneDB.getPdndOrganizationName();
  229.         String pdndOrganizationCategory = transazioneDB.getPdndOrganizationCategory();
  230.         String pdndExternalId = transazioneDB.getPdndOrganizationExternalId();
  231.         if(StringUtils.isNotEmpty(pdndOrganizationName) || StringUtils.isNotEmpty(pdndOrganizationCategory) || StringUtils.isNotEmpty(pdndExternalId)) {
  232.             PDNDOrganizationInfo pdndOrganizationInfo = new PDNDOrganizationInfo();
  233.             pdndOrganizationInfo.setNome(pdndOrganizationName);
  234.             pdndOrganizationInfo.setCategoria(pdndOrganizationCategory);
  235.             if(StringUtils.isNotEmpty(pdndExternalId) && pdndExternalId.contains(" ")) {
  236.                 try {
  237.                     int indexOf = pdndExternalId.indexOf(" ");
  238.                     String origin = pdndExternalId.substring(0, indexOf);
  239.                     String code = pdndExternalId.replaceFirst(origin+" ","");
  240.                     PDNDOrganizationExternalId extId = new PDNDOrganizationExternalId();
  241.                     extId.setOrigine(origin);
  242.                     extId.setCodice(code);
  243.                     pdndOrganizationInfo.setExternalId(extId);
  244.                 }
  245.                 catch(Exception e) {
  246.                     // ignore
  247.                 }
  248.             }
  249.             detail.setPdndOrganization(pdndOrganizationInfo);
  250.         }
  251.         
  252.         String richiedente = transazioneDB.getLabelRichiedenteConFruitore();
  253.         if(StringUtils.isNotEmpty(richiedente)) {
  254.             detail.setRichiedente(richiedente);
  255.         }
  256.         String dettaglioErrore = transazioneDB.getDettaglioErrore(messaggiDiagnostici);
  257.         if(StringUtils.isNotEmpty(dettaglioErrore)) {
  258.             detail.setDettaglioErrore(dettaglioErrore);
  259.         }
  260.                 
  261.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  262.         metodiEsclusi.add(new BlackListElement("setData", DateTime.class));
  263.         metodiEsclusi.add(new BlackListElement("setLatenzaServizio", Long.class));
  264.         metodiEsclusi.add(new BlackListElement("setLatenzaTotale", Long.class));
  265.         metodiEsclusi.add(new BlackListElement("setPdndOrganization", PDNDOrganizationInfo.class));
  266.         metodiEsclusi.add(new BlackListElement("setRichiedente", String.class));
  267.         metodiEsclusi.add(new BlackListElement("setDettaglioErrore", String.class));
  268.         org.openspcoop2.utils.beans.BeanUtils.copy(log, detail, transazioneExt, metodiEsclusi, true);
  269.         
  270.         // Se presenti, finiscono come informazione del token in detail.getMittente().getInformazioniToken()
  271.         /*
  272.         if(detail.getMittente()!=null) {
  273.             detail.getMittente().setUtente(null);
  274.             detail.getMittente().setClient(null);
  275.         }
  276.         */
  277.         
  278.         return detail;
  279.     }
  280.     
  281.     public static ItemTransazione toItemTransazione(TransazioneBean transazioneDB, Logger log)  throws Exception {
  282.     
  283.         CredenzialiMittente credenzialiMittente = Converter.convertToCredenzialiMittente(transazioneDB);        
  284.         
  285.         org.openspcoop2.pdd.logger.traccia.Converter converter = new org.openspcoop2.pdd.logger.traccia.Converter(log);
  286.         if(transazioneDB.getGruppiLabel()!=null && !"".equals(transazioneDB.getGruppiLabel())) {
  287.             // converto voce originale
  288.             transazioneDB.setGruppi(transazioneDB.getGruppiLabel());
  289.         }
  290.         if(transazioneDB.getSocketClientAddress()==null && transazioneDB.getSocketClientAddressLabel()!=null) {
  291.             // converto voce originale
  292.             transazioneDB.setSocketClientAddress(transazioneDB.getSocketClientAddressLabel());
  293.         }
  294.         if(transazioneDB.getTransportClientAddress()==null && transazioneDB.getTransportClientAddressLabel()!=null) {
  295.             // converto voce originale
  296.             transazioneDB.setTransportClientAddress(transazioneDB.getTransportClientAddressLabel());
  297.         }
  298.         TransazioneExt transazione = converter.toTransazioneExt(transazioneDB, credenzialiMittente, null, null, null);
  299.     
  300.         // elimino i campi non previsti in un ItemTransazione
  301.         if(transazione.getRichiesta()!=null) {
  302.             transazione.getRichiesta().setContenutiIngresso(null);
  303.             transazione.getRichiesta().setContenutiUscita(null);
  304.             transazione.getRichiesta().setDuplicatiMessaggio(null);
  305.             transazione.getRichiesta().setTraccia(null);
  306.             transazione.getRichiesta().setDataRicezioneAcquisita(null);
  307.             transazione.getRichiesta().setDataConsegnaEffettuata(null);
  308.         }
  309.         if(transazione.getRisposta()!=null) {
  310.             transazione.getRisposta().setContenutiIngresso(null);
  311.             transazione.getRisposta().setContenutiUscita(null);
  312.             transazione.getRisposta().setDuplicatiMessaggio(null);
  313.             transazione.getRisposta().setTraccia(null);
  314.             transazione.getRisposta().setFaultConsegna(null);
  315.             transazione.getRisposta().setFaultConsegnaFormato(null);
  316.             transazione.getRisposta().setFaultRicezione(null);
  317.             transazione.getRisposta().setFaultRicezioneFormato(null);
  318.             transazione.getRisposta().setDettagliErrore(null);
  319.             transazione.getRisposta().setDataRicezioneAcquisita(null);
  320.             if(transazione.getRisposta().getDataConsegnaEffettuata()!=null) { // inverto
  321.                 transazione.getRisposta().setDataConsegna(transazione.getRisposta().getDataConsegnaEffettuata());
  322.             }
  323.             transazione.getRisposta().setDataConsegnaEffettuata(null);
  324.         }
  325.         if(transazione.getApi()!=null) {
  326.             transazione.getApi().setProfiloCollaborazione(null);
  327.             transazione.getApi().setIdAsincrono(null);
  328.         }
  329.         if(transazione.getMittente()!=null) {
  330.             transazione.getMittente().setCredenziali(null);
  331.             transazione.getMittente().setToken(null);
  332.             transazione.getMittente().setInformazioniToken(null);
  333.         }
  334.         
  335.         // aggiunto campi supplementari
  336.         ItemTransazione item = new ItemTransazione();
  337.         if(transazione.getRichiesta()!=null) {
  338.             item.setData(transazione.getRichiesta().getDataRicezione());
  339.         }
  340.         if(transazione.getRichiesta()!=null && transazione.getRichiesta().getDataConsegna()!=null &&
  341.                 transazione.getRisposta()!=null && transazione.getRisposta().getDataAccettazione()!=null) {
  342.             long dataRisposta = transazione.getRisposta().getDataAccettazione().getMillis();
  343.             long dataRichiesta = transazione.getRichiesta().getDataConsegna().getMillis(); 
  344.             item.setLatenzaServizio(dataRisposta-dataRichiesta);
  345.         }
  346.         if(transazione.getRichiesta()!=null && transazione.getRichiesta().getDataAccettazione()!=null &&
  347.                 transazione.getRisposta()!=null && transazione.getRisposta().getDataConsegna()!=null) {
  348.             long dataRisposta = transazione.getRisposta().getDataConsegna().getMillis();
  349.             long dataRichiesta = transazione.getRichiesta().getDataAccettazione().getMillis(); 
  350.             item.setLatenzaTotale(dataRisposta-dataRichiesta);
  351.         }
  352.         
  353.         String pdndOrganizationName = transazioneDB.getPdndOrganizationName();
  354.         if(StringUtils.isNotEmpty(pdndOrganizationName)) {
  355.             PDNDOrganizationInfoItemTransazione pdndOrganizationInfo = new PDNDOrganizationInfoItemTransazione();
  356.             pdndOrganizationInfo.setNome(pdndOrganizationName);
  357.             item.setPdndOrganization(pdndOrganizationInfo);
  358.         }
  359.         
  360.         String richiedente = transazioneDB.getLabelRichiedenteConFruitore();
  361.         if(StringUtils.isNotEmpty(richiedente)) {
  362.             item.setRichiedente(richiedente);
  363.         }
  364.         
  365.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  366.         metodiEsclusi.add(new BlackListElement("setData", DateTime.class));
  367.         metodiEsclusi.add(new BlackListElement("setLatenzaServizio", Long.class));
  368.         metodiEsclusi.add(new BlackListElement("setLatenzaTotale", Long.class));
  369.         metodiEsclusi.add(new BlackListElement("setPdndOrganization", PDNDOrganizationInfoItemTransazione.class));
  370.         metodiEsclusi.add(new BlackListElement("setRichiedente", String.class));
  371.         org.openspcoop2.utils.beans.BeanUtils.copy(log, item, transazione, metodiEsclusi, true );
  372.                 
  373.         return item;
  374.     }
  375.     
  376.     private static CredenzialiMittente convertToCredenzialiMittente(TransazioneBean transazioneDB) {
  377.         CredenzialiMittente credenzialiMittente = new CredenzialiMittente();
  378.         if(transazioneDB.getTrasportoMittenteLabel()!=null) {
  379.             CredenzialeMittente credenziale = new CredenzialeMittente();
  380.             credenziale.setCredenziale(transazioneDB.getTrasportoMittenteLabel());
  381.             credenzialiMittente.setTrasporto(credenziale);
  382.         }
  383.         if(transazioneDB.getTokenSubjectLabel()!=null) {
  384.             CredenzialeMittente credenziale = new CredenzialeMittente();
  385.             credenziale.setCredenziale(transazioneDB.getTokenSubjectLabel());
  386.             credenzialiMittente.setTokenSubject(credenziale);
  387.         }
  388.         if(transazioneDB.getTokenIssuerLabel()!=null) {
  389.             CredenzialeMittente credenziale = new CredenzialeMittente();
  390.             credenziale.setCredenziale(transazioneDB.getTokenIssuerLabel());
  391.             credenzialiMittente.setTokenIssuer(credenziale);
  392.         }
  393.         if(transazioneDB.getTokenClientIdLabel()!=null) {
  394.             CredenzialeMittente credenziale = new CredenzialeMittente();
  395.             String clientId = transazioneDB.getTokenClientIdLabel();
  396.             IDServizioApplicativo idSA = transazioneDB.getTokenClient();
  397.             if(idSA!=null) {
  398.                 CredenzialeTokenClient credToken = new CredenzialeTokenClient(clientId, idSA);
  399.                 try {
  400.                     credenziale.setCredenziale(credToken.getCredenziale());
  401.                 }catch(Throwable t) {
  402.                     credenziale.setCredenziale(clientId);
  403.                 }
  404.             }
  405.             else {
  406.                 credenziale.setCredenziale(clientId);
  407.             }
  408.             credenzialiMittente.setTokenClientId(credenziale);
  409.         }
  410.         if(transazioneDB.getTokenUsernameLabel()!=null) {
  411.             CredenzialeMittente credenziale = new CredenzialeMittente();
  412.             credenziale.setCredenziale(transazioneDB.getTokenUsernameLabel());
  413.             credenzialiMittente.setTokenUsername(credenziale);
  414.         }
  415.         if(transazioneDB.getTokenMailLabel()!=null) {
  416.             CredenzialeMittente credenziale = new CredenzialeMittente();
  417.             credenziale.setCredenziale(transazioneDB.getTokenMailLabel());
  418.             credenzialiMittente.setTokenEMail(credenziale);
  419.         }
  420.         return credenzialiMittente;
  421.     }
  422.     
  423.     public static Evento toEvento(EventoBean eventoDB, Logger log) throws Exception {
  424.         Evento evento = new Evento();
  425.         
  426.         if(eventoDB.getSeverita()>=0) {
  427.             TipoSeverita tipo = SeveritaConverter.toSeverita(eventoDB.getSeverita());
  428.             evento.setSeverita(Enums.toDiagnosticoSeverita.get(tipo));
  429.         }
  430.         evento.setOrigine(eventoDB.getIdConfigurazione());
  431.         if(eventoDB.getOraRegistrazione()!=null) {
  432.             evento.setOraRegistrazione(new DateTime(eventoDB.getOraRegistrazione().getTime()));
  433.         }
  434.         
  435.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  436.         metodiEsclusi.add(new BlackListElement("setSeverita", DiagnosticoSeveritaEnum.class));
  437.         metodiEsclusi.add(new BlackListElement("setOrigine", String.class));
  438.         metodiEsclusi.add(new BlackListElement("setOraRegistrazione", DateTime.class));
  439.         org.openspcoop2.utils.beans.BeanUtils.copy(log, evento, eventoDB, metodiEsclusi, true);
  440.         return evento;
  441.     }
  442.     
  443.     public static RiepilogoApiItem toRiepilogoApiItem(ConfigurazioneGenerale configurazioneDB, Logger log) throws Exception {
  444.         RiepilogoApiItem riepilogo = new RiepilogoApiItem();
  445.         riepilogo.setErogatore(configurazioneDB.getErogatore());
  446.         riepilogo.setFruitore(configurazioneDB.getFruitore());
  447.         
  448.         String nomeAPI = configurazioneDB.getServizio();
  449.         if(nomeAPI!=null) {
  450.             String [] tmp = nomeAPI.split(" v");
  451.             String tipoNome = tmp[0];
  452.             if(tipoNome.contains("/")) {
  453.                 riepilogo.setTipo(tipoNome.split("/")[0]);
  454.                 riepilogo.setNome(tipoNome.split("/")[1]);
  455.             }
  456.             else {
  457.                 riepilogo.setNome(tipoNome);
  458.             }
  459.             String versione = tmp[1];
  460.             riepilogo.setVersione(Integer.parseInt(versione));
  461.         }
  462.         
  463.         return riepilogo;
  464.     }
  465.     
  466.     public static Riepilogo toRiepilogo(List<ConfigurazioneGenerale> listDB_infoGenerali_right, List<ConfigurazioneGenerale> listDB_infoServizi_left , 
  467.             ConfigurazioneGenerale soggettiOperativi, Logger log) throws Exception {
  468.         Riepilogo riepilogo = new Riepilogo();
  469.         
  470.         if(listDB_infoGenerali_right!=null && !listDB_infoGenerali_right.isEmpty()) {
  471.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoGenerali_right) {
  472.                 if(CostantiConfigurazioni.CONF_SOGGETTI_ESTERNI_LABEL.equals(configurazioneGenerale.getLabel())) {
  473.                     riepilogo.setSoggettiDominioEsterno(Integer.valueOf(configurazioneGenerale.getValue()));
  474.                 }
  475.                 else if(CostantiConfigurazioni.CONF_SOGGETTI_OPERATIVI_LABEL.equals(configurazioneGenerale.getLabel())) {
  476.                     riepilogo.setSoggettiDominioInterno(Integer.valueOf(configurazioneGenerale.getValue()));
  477.                 }
  478.                 else if(CostantiConfigurazioni.CONF_SERVIZI_APPLICATIVI_LABEL.equals(configurazioneGenerale.getLabel())) {
  479.                     riepilogo.setApplicativi(Integer.valueOf(configurazioneGenerale.getValue()));
  480.                 }
  481.             }
  482.         }
  483.         
  484.         if(listDB_infoServizi_left!=null && !listDB_infoServizi_left.isEmpty()) {
  485.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoServizi_left) {
  486.                 if(CostantiConfigurazioni.CONF_ASPC_LABEL.equals(configurazioneGenerale.getLabel())) {
  487.                     riepilogo.setApi(Integer.valueOf(configurazioneGenerale.getValue()));
  488.                 }
  489.                 else if(CostantiConfigurazioni.CONF_ASPS_LABEL.equals(configurazioneGenerale.getLabel())) {
  490.                     riepilogo.setErogazioni(Integer.valueOf(configurazioneGenerale.getValue()));
  491.                 }
  492.                 else if(CostantiConfigurazioni.CONF_FRUIZIONI_SERVIZIO_LABEL.equals(configurazioneGenerale.getLabel())) {
  493.                     riepilogo.setFruizioni(Integer.valueOf(configurazioneGenerale.getValue()));
  494.                 }
  495.             }
  496.         }
  497.         
  498.         if(riepilogo.getSoggettiDominioInterno()==null) {
  499.             // mutitenant disabilitato
  500.             if(soggettiOperativi!=null) {
  501.                 riepilogo.setSoggettiDominioInterno(Integer.valueOf(soggettiOperativi.getValue()));
  502.             }
  503.         }
  504.         
  505.         return riepilogo;
  506.     }
  507.     
  508.     public static InfoImplementazioneApi toInfoImplementazioneApi(List<ConfigurazioneGenerale> listDB_infoServizi_left , Logger log) throws Exception {
  509.         InfoImplementazioneApi info = new InfoImplementazioneApi();
  510.         
  511.         if(listDB_infoServizi_left!=null && !listDB_infoServizi_left.isEmpty()) {
  512.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoServizi_left) {
  513.                 if(CostantiConfigurazioni.CONF_ASPS_LABEL.equals(configurazioneGenerale.getLabel())) {
  514.                     info.setErogazioni(Integer.valueOf(configurazioneGenerale.getValue()));
  515.                 }
  516.                 else if(CostantiConfigurazioni.CONF_FRUIZIONI_SERVIZIO_LABEL.equals(configurazioneGenerale.getLabel())) {
  517.                     info.setFruizioni(Integer.valueOf(configurazioneGenerale.getValue()));
  518.                 }
  519.                 else if(CostantiConfigurazioni.CONF_AZIONI_LABEL.equals(configurazioneGenerale.getLabel())) {
  520.                     info.setAzioni(Integer.valueOf(configurazioneGenerale.getValue()));
  521.                 }
  522.             }
  523.         }
  524.         
  525.         return info;
  526.     }
  527.     
  528.     public static IDServizio toIDServizio(TransazioneRuoloEnum tipo, ProfiloEnum profilo, String soggetto, 
  529.             String soggettoRemoto, String nomeServizio, String tipoServizio, Integer versioneServizio) throws Exception {
  530.         String protocollo = Converter.toProtocollo(profilo);
  531.         ProtocolFactoryManager protocolFactoryManager = ProtocolFactoryManager.getInstance();
  532.         String tipoSoggetto = protocolFactoryManager.getDefaultOrganizationTypes().get(protocollo);
  533.         String tipoServizioEffettivo = tipoServizio !=null ? tipoServizio : protocolFactoryManager._getServiceTypes().get(protocollo).get(0);
  534.         String nomeSoggettoLocale = soggetto;
  535.         if(nomeSoggettoLocale==null) {
  536.             ServerProperties serverProperties = ServerProperties.getInstance();
  537.             if(serverProperties.useSoggettoDefault()) {
  538.                 nomeSoggettoLocale = serverProperties.getSoggettoDefaultIfEnabled(protocollo);
  539.             }
  540.             else {
  541.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Soggetto locale non indicato; parametro obbligatorio");
  542.             }
  543.         }
  544.         if(!SoggettiConfig.existsIdentificativoPorta(tipoSoggetto, nomeSoggettoLocale)) {
  545.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Il soggetto locale indicato non esiste");
  546.         }
  547.         String nomeSoggettoErogatore = null;
  548.         switch (tipo) {
  549.         case EROGAZIONE:
  550.             nomeSoggettoErogatore = nomeSoggettoLocale;
  551.             break;
  552.         case FRUIZIONE:
  553.             if(StringUtils.isNotBlank(soggettoRemoto)) {
  554.                 nomeSoggettoErogatore = soggettoRemoto;
  555.             }
  556.             else {
  557.                 FaultCode.RICHIESTA_NON_VALIDA.throwException("Parametro 'soggettoRemoto' รจ obbligatorio per il dettaglio di una fruizione");
  558.             }
  559.             break;
  560.         default:
  561.             break;
  562.         }
  563.         IDServizio idServizio = 
  564.                 IDServizioFactory.getInstance().getIDServizioFromValues(tipoServizioEffettivo, nomeServizio, tipoSoggetto, nomeSoggettoErogatore, 
  565.                         versioneServizio==null ? 1 : versioneServizio);
  566.         return idServizio;
  567.     }
  568. }
Created with JaCoCo 0.8.8.202204050719