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;
  25. import java.util.UUID;

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

  90. /**
  91.  * Converter
  92.  * 
  93.  * @author $Author$
  94.  * @version $Rev$, $Date$
  95.  * 
  96.  */
  97. public class Converter {

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

  167.         CredenzialiMittente credenzialiMittente = Converter.convertToCredenzialiMittente(transazioneDB);        
  168.         
  169.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO)) {
  170.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO);
  171.             if(dumpMessaggio!=null) {
  172.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  173.             }
  174.         }
  175.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO)) {
  176.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_INGRESSO);
  177.             if(dumpMessaggio!=null) {
  178.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  179.             }
  180.         }
  181.         
  182.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO)) {
  183.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO);
  184.             if(dumpMessaggio!=null) {
  185.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  186.             }
  187.         }
  188.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA)) {
  189.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RICHIESTA_USCITA);
  190.             if(dumpMessaggio!=null) {
  191.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  192.             }
  193.         }
  194.         
  195.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO)) {
  196.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO);
  197.             if(dumpMessaggio!=null) {
  198.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  199.             }
  200.         }
  201.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO)) {
  202.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_INGRESSO);
  203.             if(dumpMessaggio!=null) {
  204.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  205.             }
  206.         }
  207.         
  208.         if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO)) {
  209.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO);
  210.             if(dumpMessaggio!=null) {
  211.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  212.             }
  213.         }
  214.         else if(transazioniService.hasInfoDumpAvailable(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA)) {
  215.             DumpMessaggio dumpMessaggio = transazioniService.getDumpMessaggio(transazioneDB.getIdTransazione(), null, null, TipoMessaggio.RISPOSTA_USCITA);
  216.             if(dumpMessaggio!=null) {
  217.                 transazioneDB.addDumpMessaggio(dumpMessaggio);
  218.             }
  219.         }
  220.         
  221.         TransazioneExt transazioneExt = converter.toTransazioneExt(transazioneDB, credenzialiMittente, tracciaRichiesta, tracciaRisposta, messaggiDiagnostici);
  222.         
  223.         // aggiunto campi supplementari
  224.         
  225.         DetailTransazione detail = new DetailTransazione();
  226.         
  227.         if(transazioneExt.getRichiesta()!=null) {
  228.             detail.setData(transazioneExt.getRichiesta().getDataRicezione());
  229.         }
  230.         if(transazioneExt.getRichiesta()!=null && transazioneExt.getRichiesta().getDataConsegna()!=null &&
  231.                 transazioneExt.getRisposta()!=null && transazioneExt.getRisposta().getDataAccettazione()!=null) {
  232.             long dataRisposta = transazioneExt.getRisposta().getDataAccettazione().getMillis();
  233.             long dataRichiesta = transazioneExt.getRichiesta().getDataConsegna().getMillis(); 
  234.             detail.setLatenzaServizio(dataRisposta-dataRichiesta);
  235.         }
  236.         if(transazioneExt.getRichiesta()!=null && transazioneExt.getRichiesta().getDataAccettazione()!=null &&
  237.                 transazioneExt.getRisposta()!=null && transazioneExt.getRisposta().getDataConsegna()!=null) {
  238.             long dataRisposta = transazioneExt.getRisposta().getDataConsegna().getMillis();
  239.             long dataRichiesta = transazioneExt.getRichiesta().getDataAccettazione().getMillis(); 
  240.             detail.setLatenzaTotale(dataRisposta-dataRichiesta);
  241.         }
  242.         
  243.         String pdndOrganizationName = transazioneDB.getPdndOrganizationName();
  244.         String pdndOrganizationCategory = transazioneDB.getPdndOrganizationCategory();
  245.         String pdndExternalId = transazioneDB.getPdndOrganizationExternalId();
  246.         String pdndConsumerId = transazioneDB.getPdndOrganizationConsumerId();
  247.         if(StringUtils.isNotEmpty(pdndOrganizationName) || StringUtils.isNotEmpty(pdndOrganizationCategory) || StringUtils.isNotEmpty(pdndExternalId)) {
  248.             PDNDOrganizationInfo pdndOrganizationInfo = new PDNDOrganizationInfo();
  249.             pdndOrganizationInfo.setNome(pdndOrganizationName);
  250.             pdndOrganizationInfo.setCategoria(pdndOrganizationCategory);
  251.             if(StringUtils.isNotEmpty(pdndExternalId) && pdndExternalId.contains(" ")) {
  252.                 try {
  253.                     int indexOf = pdndExternalId.indexOf(" ");
  254.                     String origin = pdndExternalId.substring(0, indexOf);
  255.                     String code = pdndExternalId.replaceFirst(origin+" ","");
  256.                     PDNDOrganizationExternalId extId = new PDNDOrganizationExternalId();
  257.                     extId.setOrigine(origin);
  258.                     extId.setCodice(code);
  259.                     pdndOrganizationInfo.setExternalId(extId);
  260.                 }
  261.                 catch(Exception e) {
  262.                     // ignore
  263.                 }
  264.             }
  265.             pdndOrganizationInfo.setConsumerId(pdndConsumerId);
  266.             detail.setPdndOrganization(pdndOrganizationInfo);
  267.         }
  268.         
  269.         String richiedente = transazioneDB.getLabelRichiedenteConFruitore();
  270.         if(StringUtils.isNotEmpty(richiedente)) {
  271.             detail.setRichiedente(richiedente);
  272.         }
  273.         String dettaglioErrore = transazioneDB.getDettaglioErrore(messaggiDiagnostici);
  274.         if(StringUtils.isNotEmpty(dettaglioErrore)) {
  275.             detail.setDettaglioErrore(dettaglioErrore);
  276.         }
  277.                 
  278.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  279.         metodiEsclusi.add(new BlackListElement("setData", DateTime.class));
  280.         metodiEsclusi.add(new BlackListElement("setLatenzaServizio", Long.class));
  281.         metodiEsclusi.add(new BlackListElement("setLatenzaTotale", Long.class));
  282.         metodiEsclusi.add(new BlackListElement("setPdndOrganization", PDNDOrganizationInfo.class));
  283.         metodiEsclusi.add(new BlackListElement("setRichiedente", String.class));
  284.         metodiEsclusi.add(new BlackListElement("setDettaglioErrore", String.class));
  285.         org.openspcoop2.utils.beans.BeanUtils.copy(log, detail, transazioneExt, metodiEsclusi, true);
  286.         
  287.         // Se presenti, finiscono come informazione del token in detail.getMittente().getInformazioniToken()
  288.         /*
  289.         if(detail.getMittente()!=null) {
  290.             detail.getMittente().setUtente(null);
  291.             detail.getMittente().setClient(null);
  292.         }
  293.         */
  294.         
  295.         return detail;
  296.     }
  297.     
  298.     public static ItemTransazione toItemTransazione(TransazioneBean transazioneDB, Logger log)  throws Exception {
  299.     
  300.         CredenzialiMittente credenzialiMittente = Converter.convertToCredenzialiMittente(transazioneDB);        
  301.         
  302.         org.openspcoop2.pdd.logger.traccia.Converter converter = new org.openspcoop2.pdd.logger.traccia.Converter(log);
  303.         if(transazioneDB.getGruppiLabel()!=null && !"".equals(transazioneDB.getGruppiLabel())) {
  304.             // converto voce originale
  305.             transazioneDB.setGruppi(transazioneDB.getGruppiLabel());
  306.         }
  307.         if(transazioneDB.getSocketClientAddress()==null && transazioneDB.getSocketClientAddressLabel()!=null) {
  308.             // converto voce originale
  309.             transazioneDB.setSocketClientAddress(transazioneDB.getSocketClientAddressLabel());
  310.         }
  311.         if(transazioneDB.getTransportClientAddress()==null && transazioneDB.getTransportClientAddressLabel()!=null) {
  312.             // converto voce originale
  313.             transazioneDB.setTransportClientAddress(transazioneDB.getTransportClientAddressLabel());
  314.         }
  315.         TransazioneExt transazione = converter.toTransazioneExt(transazioneDB, credenzialiMittente, null, null, null);
  316.     
  317.         // elimino i campi non previsti in un ItemTransazione
  318.         if(transazione.getRichiesta()!=null) {
  319.             transazione.getRichiesta().setContenutiIngresso(null);
  320.             transazione.getRichiesta().setContenutiUscita(null);
  321.             transazione.getRichiesta().setDuplicatiMessaggio(null);
  322.             transazione.getRichiesta().setTraccia(null);
  323.             transazione.getRichiesta().setDataRicezioneAcquisita(null);
  324.             transazione.getRichiesta().setDataConsegnaEffettuata(null);
  325.         }
  326.         if(transazione.getRisposta()!=null) {
  327.             transazione.getRisposta().setContenutiIngresso(null);
  328.             transazione.getRisposta().setContenutiUscita(null);
  329.             transazione.getRisposta().setDuplicatiMessaggio(null);
  330.             transazione.getRisposta().setTraccia(null);
  331.             transazione.getRisposta().setFaultConsegna(null);
  332.             transazione.getRisposta().setFaultConsegnaFormato(null);
  333.             transazione.getRisposta().setFaultRicezione(null);
  334.             transazione.getRisposta().setFaultRicezioneFormato(null);
  335.             transazione.getRisposta().setDettagliErrore(null);
  336.             transazione.getRisposta().setDataRicezioneAcquisita(null);
  337.             if(transazione.getRisposta().getDataConsegnaEffettuata()!=null) { // inverto
  338.                 transazione.getRisposta().setDataConsegna(transazione.getRisposta().getDataConsegnaEffettuata());
  339.             }
  340.             transazione.getRisposta().setDataConsegnaEffettuata(null);
  341.         }
  342.         if(transazione.getApi()!=null) {
  343.             transazione.getApi().setProfiloCollaborazione(null);
  344.             transazione.getApi().setIdAsincrono(null);
  345.         }
  346.         if(transazione.getMittente()!=null) {
  347.             transazione.getMittente().setCredenziali(null);
  348.             transazione.getMittente().setToken(null);
  349.             transazione.getMittente().setInformazioniToken(null);
  350.         }
  351.         
  352.         // aggiunto campi supplementari
  353.         ItemTransazione item = new ItemTransazione();
  354.         if(transazione.getRichiesta()!=null) {
  355.             item.setData(transazione.getRichiesta().getDataRicezione());
  356.         }
  357.         if(transazione.getRichiesta()!=null && transazione.getRichiesta().getDataConsegna()!=null &&
  358.                 transazione.getRisposta()!=null && transazione.getRisposta().getDataAccettazione()!=null) {
  359.             long dataRisposta = transazione.getRisposta().getDataAccettazione().getMillis();
  360.             long dataRichiesta = transazione.getRichiesta().getDataConsegna().getMillis(); 
  361.             item.setLatenzaServizio(dataRisposta-dataRichiesta);
  362.         }
  363.         if(transazione.getRichiesta()!=null && transazione.getRichiesta().getDataAccettazione()!=null &&
  364.                 transazione.getRisposta()!=null && transazione.getRisposta().getDataConsegna()!=null) {
  365.             long dataRisposta = transazione.getRisposta().getDataConsegna().getMillis();
  366.             long dataRichiesta = transazione.getRichiesta().getDataAccettazione().getMillis(); 
  367.             item.setLatenzaTotale(dataRisposta-dataRichiesta);
  368.         }
  369.         
  370.         String pdndOrganizationName = transazioneDB.getPdndOrganizationName();
  371.         if(StringUtils.isNotEmpty(pdndOrganizationName)) {
  372.             PDNDOrganizationInfoItemTransazione pdndOrganizationInfo = new PDNDOrganizationInfoItemTransazione();
  373.             pdndOrganizationInfo.setNome(pdndOrganizationName);
  374.             item.setPdndOrganization(pdndOrganizationInfo);
  375.         }
  376.         
  377.         String richiedente = transazioneDB.getLabelRichiedenteConFruitore();
  378.         if(StringUtils.isNotEmpty(richiedente)) {
  379.             item.setRichiedente(richiedente);
  380.         }
  381.         
  382.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  383.         metodiEsclusi.add(new BlackListElement("setData", DateTime.class));
  384.         metodiEsclusi.add(new BlackListElement("setLatenzaServizio", Long.class));
  385.         metodiEsclusi.add(new BlackListElement("setLatenzaTotale", Long.class));
  386.         metodiEsclusi.add(new BlackListElement("setPdndOrganization", PDNDOrganizationInfoItemTransazione.class));
  387.         metodiEsclusi.add(new BlackListElement("setRichiedente", String.class));
  388.         org.openspcoop2.utils.beans.BeanUtils.copy(log, item, transazione, metodiEsclusi, true );
  389.                 
  390.         return item;
  391.     }
  392.     
  393.     private static CredenzialiMittente convertToCredenzialiMittente(TransazioneBean transazioneDB) {
  394.         CredenzialiMittente credenzialiMittente = new CredenzialiMittente();
  395.         if(transazioneDB.getTrasportoMittenteLabel()!=null) {
  396.             CredenzialeMittente credenziale = new CredenzialeMittente();
  397.             credenziale.setCredenziale(transazioneDB.getTrasportoMittenteLabel());
  398.             credenzialiMittente.setTrasporto(credenziale);
  399.         }
  400.         if(transazioneDB.getTokenSubjectLabel()!=null) {
  401.             CredenzialeMittente credenziale = new CredenzialeMittente();
  402.             credenziale.setCredenziale(transazioneDB.getTokenSubjectLabel());
  403.             credenzialiMittente.setTokenSubject(credenziale);
  404.         }
  405.         if(transazioneDB.getTokenIssuerLabel()!=null) {
  406.             CredenzialeMittente credenziale = new CredenzialeMittente();
  407.             credenziale.setCredenziale(transazioneDB.getTokenIssuerLabel());
  408.             credenzialiMittente.setTokenIssuer(credenziale);
  409.         }
  410.         if(transazioneDB.getTokenClientIdLabel()!=null) {
  411.             CredenzialeMittente credenziale = new CredenzialeMittente();
  412.             String clientId = transazioneDB.getTokenClientIdLabel();
  413.             IDServizioApplicativo idSA = transazioneDB.getTokenClient();
  414.             if(idSA!=null) {
  415.                 CredenzialeTokenClient credToken = new CredenzialeTokenClient(clientId, idSA);
  416.                 try {
  417.                     credenziale.setCredenziale(credToken.getCredenziale());
  418.                 }catch(Throwable t) {
  419.                     credenziale.setCredenziale(clientId);
  420.                 }
  421.             }
  422.             else {
  423.                 credenziale.setCredenziale(clientId);
  424.             }
  425.             credenzialiMittente.setTokenClientId(credenziale);
  426.         }
  427.         if(transazioneDB.getTokenUsernameLabel()!=null) {
  428.             CredenzialeMittente credenziale = new CredenzialeMittente();
  429.             credenziale.setCredenziale(transazioneDB.getTokenUsernameLabel());
  430.             credenzialiMittente.setTokenUsername(credenziale);
  431.         }
  432.         if(transazioneDB.getTokenMailLabel()!=null) {
  433.             CredenzialeMittente credenziale = new CredenzialeMittente();
  434.             credenziale.setCredenziale(transazioneDB.getTokenMailLabel());
  435.             credenzialiMittente.setTokenEMail(credenziale);
  436.         }
  437.         return credenzialiMittente;
  438.     }
  439.     
  440.     public static Evento toEvento(EventoBean eventoDB, Logger log) throws Exception {
  441.         Evento evento = new Evento();
  442.         
  443.         if(eventoDB.getSeverita()>=0) {
  444.             TipoSeverita tipo = SeveritaConverter.toSeverita(eventoDB.getSeverita());
  445.             evento.setSeverita(Enums.toDiagnosticoSeverita.get(tipo));
  446.         }
  447.         evento.setOrigine(eventoDB.getIdConfigurazione());
  448.         if(eventoDB.getOraRegistrazione()!=null) {
  449.             evento.setOraRegistrazione(new DateTime(eventoDB.getOraRegistrazione().getTime()));
  450.         }
  451.         
  452.         List<BlackListElement> metodiEsclusi = new ArrayList<>();
  453.         metodiEsclusi.add(new BlackListElement("setSeverita", DiagnosticoSeveritaEnum.class));
  454.         metodiEsclusi.add(new BlackListElement("setOrigine", String.class));
  455.         metodiEsclusi.add(new BlackListElement("setOraRegistrazione", DateTime.class));
  456.         org.openspcoop2.utils.beans.BeanUtils.copy(log, evento, eventoDB, metodiEsclusi, true);
  457.         return evento;
  458.     }
  459.     
  460.     public static RiepilogoApiItem toRiepilogoApiItem(ConfigurazioneGenerale configurazioneDB, Logger log) throws Exception {
  461.         RiepilogoApiItem riepilogo = new RiepilogoApiItem();
  462.         riepilogo.setErogatore(configurazioneDB.getErogatore());
  463.         riepilogo.setFruitore(configurazioneDB.getFruitore());
  464.         
  465.         String nomeAPI = configurazioneDB.getServizio();
  466.         if(nomeAPI!=null) {
  467.             String [] tmp = nomeAPI.split(" v");
  468.             String tipoNome = tmp[0];
  469.             if(tipoNome.contains("/")) {
  470.                 riepilogo.setTipo(tipoNome.split("/")[0]);
  471.                 riepilogo.setNome(tipoNome.split("/")[1]);
  472.             }
  473.             else {
  474.                 riepilogo.setNome(tipoNome);
  475.             }
  476.             String versione = tmp[1];
  477.             riepilogo.setVersione(Integer.parseInt(versione));
  478.         }
  479.         
  480.         return riepilogo;
  481.     }
  482.     
  483.     public static Riepilogo toRiepilogo(List<ConfigurazioneGenerale> listDB_infoGenerali_right, List<ConfigurazioneGenerale> listDB_infoServizi_left , 
  484.             ConfigurazioneGenerale soggettiOperativi, Logger log) throws Exception {
  485.         Riepilogo riepilogo = new Riepilogo();
  486.         
  487.         if(listDB_infoGenerali_right!=null && !listDB_infoGenerali_right.isEmpty()) {
  488.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoGenerali_right) {
  489.                 if(CostantiConfigurazioni.CONF_SOGGETTI_ESTERNI_LABEL.equals(configurazioneGenerale.getLabel())) {
  490.                     riepilogo.setSoggettiDominioEsterno(Integer.valueOf(configurazioneGenerale.getValue()));
  491.                 }
  492.                 else if(CostantiConfigurazioni.CONF_SOGGETTI_OPERATIVI_LABEL.equals(configurazioneGenerale.getLabel())) {
  493.                     riepilogo.setSoggettiDominioInterno(Integer.valueOf(configurazioneGenerale.getValue()));
  494.                 }
  495.                 else if(CostantiConfigurazioni.CONF_SERVIZI_APPLICATIVI_LABEL.equals(configurazioneGenerale.getLabel())) {
  496.                     riepilogo.setApplicativi(Integer.valueOf(configurazioneGenerale.getValue()));
  497.                 }
  498.             }
  499.         }
  500.         
  501.         if(listDB_infoServizi_left!=null && !listDB_infoServizi_left.isEmpty()) {
  502.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoServizi_left) {
  503.                 if(CostantiConfigurazioni.CONF_ASPC_LABEL.equals(configurazioneGenerale.getLabel())) {
  504.                     riepilogo.setApi(Integer.valueOf(configurazioneGenerale.getValue()));
  505.                 }
  506.                 else if(CostantiConfigurazioni.CONF_ASPS_LABEL.equals(configurazioneGenerale.getLabel())) {
  507.                     riepilogo.setErogazioni(Integer.valueOf(configurazioneGenerale.getValue()));
  508.                 }
  509.                 else if(CostantiConfigurazioni.CONF_FRUIZIONI_SERVIZIO_LABEL.equals(configurazioneGenerale.getLabel())) {
  510.                     riepilogo.setFruizioni(Integer.valueOf(configurazioneGenerale.getValue()));
  511.                 }
  512.             }
  513.         }
  514.         
  515.         if(riepilogo.getSoggettiDominioInterno()==null) {
  516.             // mutitenant disabilitato
  517.             if(soggettiOperativi!=null) {
  518.                 riepilogo.setSoggettiDominioInterno(Integer.valueOf(soggettiOperativi.getValue()));
  519.             }
  520.         }
  521.         
  522.         return riepilogo;
  523.     }
  524.     
  525.     public static InfoImplementazioneApi toInfoImplementazioneApi(List<ConfigurazioneGenerale> listDB_infoServizi_left , Logger log) throws Exception {
  526.         InfoImplementazioneApi info = new InfoImplementazioneApi();
  527.         
  528.         if(listDB_infoServizi_left!=null && !listDB_infoServizi_left.isEmpty()) {
  529.             for (ConfigurazioneGenerale configurazioneGenerale : listDB_infoServizi_left) {
  530.                 if(CostantiConfigurazioni.CONF_ASPS_LABEL.equals(configurazioneGenerale.getLabel())) {
  531.                     info.setErogazioni(Integer.valueOf(configurazioneGenerale.getValue()));
  532.                 }
  533.                 else if(CostantiConfigurazioni.CONF_FRUIZIONI_SERVIZIO_LABEL.equals(configurazioneGenerale.getLabel())) {
  534.                     info.setFruizioni(Integer.valueOf(configurazioneGenerale.getValue()));
  535.                 }
  536.                 else if(CostantiConfigurazioni.CONF_AZIONI_LABEL.equals(configurazioneGenerale.getLabel())) {
  537.                     info.setAzioni(Integer.valueOf(configurazioneGenerale.getValue()));
  538.                 }
  539.             }
  540.         }
  541.         
  542.         return info;
  543.     }
  544.     
  545.     public static IDServizio toIDServizio(TransazioneRuoloEnum tipo, ProfiloEnum profilo, String soggetto, 
  546.             String soggettoRemoto, String nomeServizio, String tipoServizio, Integer versioneServizio) throws Exception {
  547.         String protocollo = Converter.toProtocollo(profilo);
  548.         ProtocolFactoryManager protocolFactoryManager = ProtocolFactoryManager.getInstance();
  549.         String tipoSoggetto = protocolFactoryManager.getDefaultOrganizationTypes().get(protocollo);
  550.         String tipoServizioEffettivo = tipoServizio !=null ? tipoServizio : protocolFactoryManager._getServiceTypes().get(protocollo).get(0);
  551.         String nomeSoggettoLocale = soggetto;
  552.         if(nomeSoggettoLocale==null) {
  553.             ServerProperties serverProperties = ServerProperties.getInstance();
  554.             if(serverProperties.useSoggettoDefault()) {
  555.                 nomeSoggettoLocale = serverProperties.getSoggettoDefaultIfEnabled(protocollo);
  556.             }
  557.             else {
  558.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Soggetto locale non indicato; parametro obbligatorio");
  559.             }
  560.         }
  561.         if(!SoggettiConfig.existsIdentificativoPorta(tipoSoggetto, nomeSoggettoLocale)) {
  562.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Il soggetto locale indicato non esiste");
  563.         }
  564.         String nomeSoggettoErogatore = null;
  565.         switch (tipo) {
  566.         case EROGAZIONE:
  567.             nomeSoggettoErogatore = nomeSoggettoLocale;
  568.             break;
  569.         case FRUIZIONE:
  570.             if(StringUtils.isNotBlank(soggettoRemoto)) {
  571.                 nomeSoggettoErogatore = soggettoRemoto;
  572.             }
  573.             else {
  574.                 FaultCode.RICHIESTA_NON_VALIDA.throwException("Parametro 'soggettoRemoto' รจ obbligatorio per il dettaglio di una fruizione");
  575.             }
  576.             break;
  577.         default:
  578.             break;
  579.         }
  580.         IDServizio idServizio = 
  581.                 IDServizioFactory.getInstance().getIDServizioFromValues(tipoServizioEffettivo, nomeServizio, tipoSoggetto, nomeSoggettoErogatore, 
  582.                         versioneServizio==null ? 1 : versioneServizio);
  583.         return idServizio;
  584.     }
  585.     
  586.     
  587.     private static void fillBaseTracingPDND(BaseTracingPDND out, StatistichePdndTracingBean bean) {
  588.         out.tentativiPubblicazione(bean.getTentativiPubblicazione())
  589.                 .statoPdnd(toStatoTracingPDND(bean.getStatoPdnd()))
  590.                 .stato(toStatoTracing(bean.getStato()))
  591.                 .dataRegistrazione(new DateTime(bean.getDataRegistrazione().getTime()))
  592.                 .dataTracciamento(new LocalDate(bean.getDataTracciamento().getTime()))
  593.                 .id(bean.getId());
  594.         if (bean.getTracingId() != null)
  595.             out.setTracingId(UUID.fromString(bean.getTracingId()));
  596.     }
  597.     
  598.     private static void fillDetailsTracingPDND(DetailsTracingPDND out, StatistichePdndTracingBean bean) {
  599.         fillBaseTracingPDND(out, bean);
  600.         
  601.         out.dettagliErrore(bean.getErrorDetails())
  602.             .metodo(toMethodTracingPDND(bean.getMethod()))
  603.             .dataPubblicazione(new DateTime(bean.getDataRegistrazione().getTime()));
  604.         
  605.         if (bean.isForcePublish())
  606.             out.setForcePublish(true);
  607.     }
  608.     
  609.     public static ListaTracingPDND toListaTracingPDND(IContext context, List<StatistichePdndTracingBean> listDB, int offset, int limit, int totalCount) throws InstantiationException, IllegalAccessException {
  610.         ListaTracingPDND list = ListaUtils.costruisciListaPaginata(context.getUriInfo(),
  611.                 Converter.toOffset(offset), Converter.toLimit(limit), totalCount,
  612.                 ListaTracingPDND.class);
  613.         
  614.         List<ItemTracingPDND> items = new ArrayList<>();
  615.         for (StatistichePdndTracingBean bean : listDB) {
  616.             ItemTracingPDND item = new ItemTracingPDND();
  617.             fillBaseTracingPDND(item, bean);
  618.             
  619.             items.add(item);
  620.         }
  621.         list.setItems(items);
  622.         
  623.         return list;
  624.     }
  625.     
  626.     public static DetailsTracingPDND toDetailsTracingPDND(StatistichePdndTracingBean bean){
  627.         DetailsTracingPDND details = new DetailsTracingPDND();
  628.         fillDetailsTracingPDND(details, bean);
  629.         return details;
  630.     }
  631.     
  632.     public static StatoTracingPDND toStatoTracingPDND(PossibiliStatiPdnd state) {
  633.         if (state == null)
  634.             return null;
  635.         switch (state) {
  636.         case ERROR: return StatoTracingPDND.ERRORE;
  637.         case OK: return StatoTracingPDND.OK;
  638.         case PENDING: return StatoTracingPDND.ATTESA;
  639.         case WAITING: return StatoTracingPDND.ATTESA;
  640.         default: return null;
  641.         }
  642.     }
  643.     
  644.     public static StatoTracing toStatoTracing(PossibiliStatiRichieste state) {
  645.         if (state == null)
  646.             return null;
  647.         switch (state) {
  648.         case FAILED: return StatoTracing.FALLITA;
  649.         case PUBLISHED: return StatoTracing.PUBBLICATA;
  650.         default: return null;
  651.         }
  652.     }
  653.     
  654.     public static PossibiliStatiPdnd toStatoTracingPDND(StatoTracingPDND state) {
  655.         if (state == null)
  656.             return null;
  657.         switch (state) {
  658.         case ERRORE: return PossibiliStatiPdnd.ERROR;
  659.         case OK: return PossibiliStatiPdnd.OK;
  660.         case ATTESA: return PossibiliStatiPdnd.PENDING;
  661.         default: return null;
  662.         }
  663.     }
  664.     
  665.     public static PossibiliStatiRichieste toStatoTracing(StatoTracing state) {
  666.         if (state == null)
  667.             return null;
  668.         switch (state) {
  669.         case FALLITA: return PossibiliStatiRichieste.FAILED;
  670.         case PUBBLICATA: return PossibiliStatiRichieste.PUBLISHED;
  671.         default: return null;
  672.         }
  673.         
  674.     }
  675.     
  676.     public static MethodTracingPDND toMethodTracingPDND(PdndMethods method) {
  677.         if (method == null)
  678.             return null;
  679.         switch (method) {
  680.         case RECOVER: return MethodTracingPDND.RECOVER;
  681.         case REPLACE: return MethodTracingPDND.REPLACE;
  682.         case SUBMIT: return MethodTracingPDND.SUBMIT;
  683.         default: return null;
  684.         }
  685.     }
  686. }
Created with JaCoCo 0.8.8.202204050719