TransactionManager.java

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

  22. import java.util.ArrayList;
  23. import java.util.HashMap;
  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.commons.dao.DAOFactory;
  28. import org.openspcoop2.core.transazioni.DumpAllegato;
  29. import org.openspcoop2.core.transazioni.DumpContenuto;
  30. import org.openspcoop2.core.transazioni.DumpHeaderTrasporto;
  31. import org.openspcoop2.core.transazioni.DumpMessaggio;
  32. import org.openspcoop2.core.transazioni.IdDumpMessaggio;
  33. import org.openspcoop2.core.transazioni.Transazione;
  34. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  35. import org.openspcoop2.core.transazioni.dao.IDumpMessaggioService;
  36. import org.openspcoop2.core.transazioni.dao.IDumpMessaggioServiceSearch;
  37. import org.openspcoop2.core.transazioni.dao.ITransazioneServiceSearch;
  38. import org.openspcoop2.generic_project.exception.NotFoundException;
  39. import org.openspcoop2.generic_project.expression.IExpression;
  40. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  41. import org.openspcoop2.monitor.sdk.constants.ContentResourceNames;
  42. import org.openspcoop2.monitor.sdk.constants.MessageType;
  43. import org.openspcoop2.monitor.sdk.constants.TransactionExceptionCode;
  44. import org.openspcoop2.monitor.sdk.exceptions.TransactionException;
  45. import org.openspcoop2.monitor.sdk.transaction.AbstractContentResource;
  46. import org.openspcoop2.monitor.sdk.transaction.Attachment;
  47. import org.openspcoop2.monitor.sdk.transaction.AttachmentResource;
  48. import org.openspcoop2.monitor.sdk.transaction.ContentResource;
  49. import org.openspcoop2.monitor.sdk.transaction.SOAPEnvelopeResource;
  50. import org.openspcoop2.monitor.sdk.transaction.Transaction;
  51. import org.openspcoop2.monitor.sdk.transaction.TransportHeaderResource;
  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.IDiagnosticDriver;
  56. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  57. import org.openspcoop2.protocol.sdk.tracciamento.DriverTracciamentoNotFoundException;
  58. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaDriver;
  59. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  60. import org.openspcoop2.utils.date.DateManager;
  61. import org.slf4j.Logger;

  63. /**
  64.  * TransactionManager
  65.  *
  66.  * @author Poli Andrea (apoli@link.it)
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */
  70. public class TransactionManager {

  72.     public static Transaction getTransaction(DAOFactory daoFactory, Logger log, String id, boolean debug)
  73.             throws TransactionException {
  74.         
  75.         Transaction transactionInfo = null;

  77.         ITracciaDriver driverTracciamento = null;
  78.         IDiagnosticDriver driverDiagnostici = null;
  79.         try {
  80.             org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM = 
  81.                     (org.openspcoop2.core.transazioni.dao.IServiceManager) daoFactory.getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  82.             ITransazioneServiceSearch transazioniSearchDAO = transazioniSM.getTransazioneServiceSearch();

  84.             driverTracciamento = (ITracciaDriver) 
  85.                     daoFactory.getServiceManager(org.openspcoop2.core.tracciamento.utils.ProjectInfo.getInstance());
  86.             
  87.             driverDiagnostici = (IDiagnosticDriver) 
  88.                     daoFactory.getServiceManager(org.openspcoop2.core.diagnostica.utils.ProjectInfo.getInstance());
  89.             
  90.             // prelevo la transazione
  91.             IExpression exprFindTraccia = transazioniSearchDAO.newExpression();
  92.             exprFindTraccia.equals(Transazione.model().ID_TRANSAZIONE, id);
  93.             Transazione transazione = null;
  94.             try{
  95.                 transazione = transazioniSearchDAO.find(exprFindTraccia);
  96.                 transactionInfo = new Transaction(log,daoFactory,transazione);
  97.             }catch(NotFoundException notFound){
  98.                 log.info("Transazione con id ["+id+"] non trovata: "+notFound.getMessage(),notFound);
  99.                 throw new TransactionException(TransactionExceptionCode.NOT_FOUND,"Transazione con id ["+id+"] non trovata: "+notFound.getMessage(),notFound);
  100.             }
  101.                         
  102.             // tracce / diagnostici
  103.             Map<String, String> propertiesRicerca = new HashMap<>();
  104.             
  105.             propertiesRicerca.put("id_transazione", id);
  106.             Traccia tracciaRichiesta = null;
  107.             try{
  108.                 tracciaRichiesta = driverTracciamento.getTraccia(RuoloMessaggio.RICHIESTA, propertiesRicerca);
  109.                 transactionInfo.setRequestTrace(tracciaRichiesta);
  110.             }catch(DriverTracciamentoNotFoundException notFound){
  111.                 if(debug)
  112.                     log.debug("Traccia di richiesta non trovata per la transazione con id ["+id+"]: "+notFound.getMessage(),notFound);
  113.             }
  114.             Traccia tracciaRisposta = null;
  115.             try{
  116.                 tracciaRisposta = driverTracciamento.getTraccia(RuoloMessaggio.RISPOSTA, propertiesRicerca);
  117.                 transactionInfo.setResponseTrace(tracciaRisposta);
  118.             }catch(DriverTracciamentoNotFoundException notFound){
  119.                 if(debug)
  120.                     log.debug("Traccia di risposta non trovata per la transazione con id ["+id+"]: "+notFound.getMessage(),notFound);
  121.             }
  122.             
  123.             FiltroRicercaDiagnosticiConPaginazione filtro = new FiltroRicercaDiagnosticiConPaginazione();
  124.             filtro.setProperties(propertiesRicerca);
  125.             List<MsgDiagnostico> listDiagnostici = null;
  126.             try{
  127.                 listDiagnostici = driverDiagnostici.getMessaggiDiagnostici(filtro);
  128.                 transactionInfo.setMsgdiagnosticiList(listDiagnostici);
  129.             }catch(DriverMsgDiagnosticiNotFoundException notFound){
  130.                 if(debug)
  131.                     log.debug("Diagnostici non presenti per la transazione con id ["+id+"]: "+notFound.getMessage(),notFound);
  132.             }
  133.             
  134.             // risorse di contenuto
  135.             IDumpMessaggioServiceSearch dumpMessaggioSearchDAO = transazioniSM.getDumpMessaggioServiceSearch();
  136.             TransactionManager.retrieveContentResources(
  137.                         dumpMessaggioSearchDAO, transactionInfo);

  139.         } catch (Exception e) {
  140.             log.error(
  141.                     "TransactionManager.getTransaction(" + id
  142.                             + ") ha generato un errore: " + e.getMessage(), e);
  143.             throw new TransactionException(TransactionExceptionCode.GENERIC_ERROR,e.getMessage(),e);
  144.         }finally{
  145.             try{
  146.                 driverTracciamento.close();
  147.             }catch(Exception eClose){
  148.                 // close
  149.             }
  150.             try{
  151.                 driverDiagnostici.close();
  152.             }catch(Exception eClose){
  153.                 // close
  154.             }
  155.         }

  157.         return transactionInfo;
  158.     }

  160.     
  161.     public static void updateContentResources(Transaction transaction)
  162.             throws TransactionException {

  164.         // !AGGIORNA L'IMMAGINE PRESENTE SUL DATABASE!
  165.         // delle risorse NOME VALORE
  166.         
  167.         try {
  168.             List<ContentResource> resList = transaction.getContentResourcesByType(ContentResource.class);
  169.             if (resList.size() != 0) {
  170.                 
  171.                 org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM = 
  172.                         (org.openspcoop2.core.transazioni.dao.IServiceManager) transaction.getDAOFactory().getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  173.                 IDumpMessaggioService dumpMessaggioDAO = transazioniSM.getDumpMessaggioService();
  174.                 IDumpMessaggioServiceSearch dumpMessaggioSearchDAO = transazioniSM.getDumpMessaggioServiceSearch();

  176.                 IPaginatedExpression expr = dumpMessaggioSearchDAO.newPaginatedExpression();
  177.                 expr.
  178.                     limit(1000).
  179.                     equals(DumpMessaggio.model().ID_TRANSAZIONE,transaction.getIdTransazione());

  181.                 List<DumpMessaggio> list = dumpMessaggioSearchDAO.findAll(expr);

  183.                 // posso trovare 0/1/2 entries nella tabella dump_messaggi per
  184.                 // ogni transazione
  185.                 for (DumpMessaggio dumpMessaggio : list) {
  186.                     
  187.                     boolean update = updateResources(dumpMessaggio, transaction);

  189.                     // Se e' necessario aggiornare il database procedo.
  190.                     if (update) {
  191.                         IdDumpMessaggio idDumpMsg = new IdDumpMessaggio();
  192.                         idDumpMsg.setIdTransazione(transaction.getIdTransazione());
  193.                         idDumpMsg.setTipoMessaggio(dumpMessaggio.getTipoMessaggio());
  194.                         dumpMessaggioDAO.update(idDumpMsg, dumpMessaggio);
  195.                     }
  196.                 }
  197.             
  198.             }
  199.         } catch (Exception e) {
  200.             transaction.getLogger().error(
  201.                     "TransactionManager.updateContentResources() ha generato un errore: "
  202.                             + e.getMessage(), e);
  203.             throw new TransactionException(TransactionExceptionCode.GENERIC_ERROR,e.getMessage(),e);
  204.         }
  205.     }

  207.     public static boolean updateResources(DumpMessaggio dumpMessaggio, Transaction transaction) throws Exception{
  208.         
  209.         boolean update = false;
  210.         
  211.         List<ContentResource> resList = transaction.getContentResourcesByType(ContentResource.class);
  212.         if (resList.size() != 0) {
  213.         
  214.             // aggiorno i valori di proprieta' esistenti e rimuovo quelle presenti che non sono nella nuova immagine passata come parametro al metodo
  215.             List<DumpContenuto> lstContenuto = dumpMessaggio.getContenutoList();
  216.             for (DumpContenuto dumpContenuto : lstContenuto) {
  217.                 String resName = dumpContenuto.getNome();
  218.                 ContentResource resource = (ContentResource) transaction.getContentResourceByName(resName);
  219.                 if (resource != null) {
  220.                     //if(!resource.getValue().equals(dumpContenuto.getValore())){
  221.                     if(!resource.getValue().equals(TransactionContentUtils.getDumpContenutoValue(dumpContenuto))){
  222.                         TransactionContentUtils.setDumpContenutoValue(dumpContenuto, resource.getValue());
  223.                         update = true;
  224.                     }
  225.                 } else{
  226.                     lstContenuto.remove(dumpContenuto);
  227.                     update = true;
  228.                 }
  229.                 resList.remove(resource);
  230.             }
  231.     
  232.             // aggiungo le nuove proprieta' presenti nel parametro passato al metodo e non presenti su database
  233.             for (int i = 0; i < resList.size(); i++) {
  234.                 ContentResource cr = (ContentResource) resList.get(i);
  235.                 if(resList.get(i).getName()==null){
  236.                     throw new Exception("Trovata risorsa di contenuto senza nome");
  237.                 }
  238.                 if(resList.get(i).getValue()==null){
  239.                     throw new Exception("Trovata risorsa di contenuto con nome ["+resList.get(i).getName()+"] con valore non definito");
  240.                 }
  241.                 DumpContenuto c = 
  242.                         TransactionContentUtils.createDumpContenuto(resList.get(i).getName(), 
  243.                                 resList.get(i).getValue(), 
  244.                                 DateManager.getDate());
  245.                 if(dumpMessaggio.getTipoMessaggio().equals(TipoMessaggio.RICHIESTA_INGRESSO) || dumpMessaggio.getTipoMessaggio().equals(TipoMessaggio.RICHIESTA_USCITA)){
  246.                     if(cr.isRequest()){
  247.                         dumpMessaggio.addContenuto(c);
  248.                         update = true;
  249.                     }
  250.                 }
  251.                 else{
  252.                     if(cr.isResponse()){
  253.                         dumpMessaggio.addContenuto(c);
  254.                         update = true;
  255.                     }
  256.                 }
  257.                 
  258.             }
  259.             
  260.         }
  261.         
  262.         
  263.             
  264.         TransportHeaderResource resource = null;
  265.         if(TipoMessaggio.RICHIESTA_INGRESSO.equals(dumpMessaggio.getTipoMessaggio()) || TipoMessaggio.RICHIESTA_USCITA.equals(dumpMessaggio.getTipoMessaggio())){
  266.             resource = (TransportHeaderResource) transaction.getContentResourceByName(ContentResourceNames.REQ_TRANSPORT_HEADER);
  267.         }
  268.         else{
  269.             resource = (TransportHeaderResource) transaction.getContentResourceByName(ContentResourceNames.RES_TRANSPORT_HEADER);
  270.         }
  271.         List<String> keys = new ArrayList<>();
  272.         if(resource!=null && resource.keys()!=null && resource.keys().size()>0){
  273.             keys.addAll(resource.keys());
  274.         }
  275.         
  276.         // aggiorno i valori di proprieta' esistenti e rimuovo quelle presenti che non sono nella nuova immagine passata come parametro al metodo
  277.         List<DumpHeaderTrasporto> lstHeader = dumpMessaggio.getHeaderTrasportoList();
  278.         for (DumpHeaderTrasporto dumpHeader : lstHeader) {
  279.             String resName = dumpHeader.getNome();
  280.             if (resource != null) {
  281.                 String valore = resource.getProperty(resName);
  282.                 if(valore!=null){
  283.                     if(!dumpHeader.getValore().equals(valore)){
  284.                         dumpHeader.setValore(valore);   
  285.                         update = true;
  286.                     }
  287.                 } else{
  288.                     lstHeader.remove(dumpHeader);
  289.                     update = true;
  290.                 }
  291.             } else{
  292.                 lstHeader.remove(dumpHeader);
  293.                 update = true;
  294.             }
  295.             for (int i = 0; i < keys.size(); i++) {
  296.                 if(keys.get(i).equals(resName)){
  297.                     keys.remove(i);
  298.                     break;
  299.                 }
  300.             }
  301.         }

  303.         // aggiungo le nuove proprieta' presenti nel parametro passato al metodo e non presenti su database
  304.         for (int i = 0; i < keys.size(); i++) {
  305.             DumpHeaderTrasporto c = new DumpHeaderTrasporto();
  306.             if(keys.get(i)==null){
  307.                 throw new Exception("Trovato header di trasporto senza nome");
  308.             }
  309.             if(resource.getProperty(keys.get(i))==null){
  310.                 throw new Exception("Trovato header di trasporto con nome ["+keys.get(i)+"] con valore non definito");
  311.             }
  312.             c.setNome(keys.get(i));
  313.             c.setValore(resource.getProperty(keys.get(i)));
  314.             c.setDumpTimestamp(DateManager.getDate());
  315.             dumpMessaggio.addHeaderTrasporto(c);
  316.             update = true;
  317.         }
  318.         
  319.         
  320.         
  321.         
  322.         
  323.         
  324.         AttachmentResource attachResource = null;
  325.         if(TipoMessaggio.RICHIESTA_INGRESSO.equals(dumpMessaggio.getTipoMessaggio()) || TipoMessaggio.RICHIESTA_USCITA.equals(dumpMessaggio.getTipoMessaggio())){
  326.             attachResource = (AttachmentResource) transaction.getContentResourceByName(ContentResourceNames.REQ_ATTACHMENT);
  327.         }
  328.         else{
  329.             attachResource = (AttachmentResource) transaction.getContentResourceByName(ContentResourceNames.RES_ATTACHMENT);
  330.         }
  331.         List<String> cids = null;
  332.         if(attachResource!=null){
  333.             cids = attachResource.cids();
  334.         }
  335.         
  336.         // aggiorno i valori di proprieta' esistenti e rimuovo quelle presenti che non sono nella nuova immagine passata come parametro al metodo
  337.         List<DumpAllegato> lstAllegati = dumpMessaggio.getAllegatoList();
  338.         for (DumpAllegato dumpAllegato : lstAllegati) {
  339.             String cid = dumpAllegato.getContentId();
  340.             if (attachResource != null) {
  341.                 Attachment attach = attachResource.getAttachmentByContentId(cid);
  342.                 if(attach.isUpdated()){
  343.                     dumpAllegato.setContentType(attach.getContentType());
  344.                     dumpAllegato.setAllegato(attach.getContentAsByte());
  345.                     update = true;
  346.                 } 
  347.             } else{
  348.                 lstAllegati.remove(dumpAllegato);
  349.                 update = true;
  350.             }
  351.             for (int i = 0; i < cids.size(); i++) {
  352.                 if(cids.get(i).equals(cid)){
  353.                     cids.remove(i);
  354.                     break;
  355.                 }
  356.             }
  357.         }

  359.         // aggiungo i nuovi attach presenti nel parametro passato al metodo e non presenti su database
  360.         if(cids!=null) {
  361.             for (int i = 0; i < cids.size(); i++) {
  362.                 Attachment attach = attachResource.getAttachmentByContentId(cids.get(i));
  363.                 DumpAllegato c = new DumpAllegato();
  364.                 c.setAllegato(attach.getContentAsByte());
  365.                 c.setContentId(attach.getContentID());
  366.                 c.setContentType(attach.getContentType());
  367.                 c.setDumpTimestamp(DateManager.getDate());
  368.                 dumpMessaggio.addAllegato(c);
  369.                 update = true;
  370.             }
  371.         }
  372.         
  373.         
  374.         
  375.         return update;      
  376.     }
  377.     
  378.     private static void addContentResource(Transaction transaction, AbstractContentResource res){
  379.         try {
  380.             transaction.addContentResource(res);
  381.         } catch (TransactionException e) {
  382.             if (TransactionExceptionCode.ADD_RES_EXIST.equals(e.getCode()) ) {
  383.                 transaction.getLogger().error(e.getMessage(),e);
  384.             } else {
  385.                 // si sta aggiungendo una risorsa già presente,
  386.                 try {
  387.                     transaction.updateContentResource(res);
  388.                 } catch (TransactionException e1) {
  389.                     transaction.getLogger().error(e1.getMessage(),e1);
  390.                 }
  391.             }
  392.         }
  393.     }
  394.     
  395.     private static void retrieveContentResources(
  396.             IDumpMessaggioServiceSearch dumpMessaggioSearchDAO,
  397.             Transaction transaction)  throws Exception{

  399.         IPaginatedExpression expr = dumpMessaggioSearchDAO.newPaginatedExpression();
  400.         expr.
  401.             limit(1000).
  402.             equals(DumpMessaggio.model().ID_TRANSAZIONE,
  403.                 transaction.getIdTransazione());

  405.         List<DumpMessaggio> list = dumpMessaggioSearchDAO.findAll(expr);

  407.         for (DumpMessaggio dumpMessaggio : list) {
  408.             
  409.             setContentResourcesInTransaction(transaction, dumpMessaggio);
  410.             
  411.         }



  415.     }
  416.     
  417.     public static void setContentResourcesInTransaction(Transaction transaction, DumpMessaggio dumpMessaggio){
  418.         MessageType tipoMessaggio = MessageType.valueOf(dumpMessaggio
  419.                 .getTipoMessaggioRawEnumValue());

  421.         
  422.         // **** SOAP ENVELOPE **** 
  423.         
  424.         SOAPEnvelopeResource soapEnvelope = new SOAPEnvelopeResource(tipoMessaggio);
  425.         addContentResource(transaction, soapEnvelope);
  426.         
  427.         
  428.         
  429.         
  430.         // **** RISORSE NOME VALORE **** 
  431.         
  432.         for (DumpContenuto dumpContenuto : dumpMessaggio.getContenutoList()) {
  433.                             
  434.             ContentResource res = new ContentResource(tipoMessaggio);
  435.             res.setName(dumpContenuto.getNome());
  436.             res.setValue(TransactionContentUtils.getDumpContenutoValue(dumpContenuto));

  438.             addContentResource(transaction, res);
  439.         }
  440.         
  441.         
  442.         
  443.         // **** HEADER HTTP *****
  444.         
  445.         TransportHeaderResource res = new TransportHeaderResource(tipoMessaggio);
  446.         for (DumpHeaderTrasporto dumpHeader : dumpMessaggio.getHeaderTrasportoList()) {
  447.             res.setProperty(dumpHeader.getNome(),dumpHeader.getValore());
  448.         }
  449.         addContentResource(transaction, res);
  450.         
  451.         
  452.         
  453.         
  454.         // **** ATTACHMENTS *****

  456.         AttachmentResource attRes = new AttachmentResource(tipoMessaggio);
  457.         for (DumpAllegato dumpAllegato : dumpMessaggio.getAllegatoList()) {
  458.             Attachment attach = new Attachment(
  459.                     dumpAllegato.getAllegato(),
  460.                     dumpAllegato.getContentId(),
  461.                     dumpAllegato.getContentType());

  463.             attRes.addAttachment(attach);
  464.         }
  465.         addContentResource(transaction, attRes);
  466.     }




  471. }
Created with JaCoCo 0.8.8.202204050719