ContenutiUtilities.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.pdd.logger.transazioni;

  22. import org.openspcoop2.core.commons.dao.DAOFactory;
  23. import org.openspcoop2.core.transazioni.DumpContenuto;
  24. import org.openspcoop2.core.transazioni.DumpMessaggio;
  25. import org.openspcoop2.core.transazioni.IdDumpMessaggio;
  26. import org.openspcoop2.core.transazioni.Transazione;
  27. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  28. import org.openspcoop2.core.transazioni.dao.IDumpMessaggioService;
  29. import org.openspcoop2.monitor.engine.config.TransactionResource;
  30. import org.openspcoop2.monitor.engine.config.TransactionServiceLibrary;
  31. import org.openspcoop2.monitor.engine.transaction.TransactionContentUtils;

  33. import java.util.List;

  35. import org.slf4j.Logger;
  36. import org.openspcoop2.generic_project.exception.MultipleResultException;
  37. import org.openspcoop2.generic_project.exception.NotFoundException;
  38. import org.openspcoop2.generic_project.exception.NotImplementedException;
  39. import org.openspcoop2.generic_project.exception.ServiceException;
  40. import org.openspcoop2.pdd.core.handlers.HandlerException;
  41. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  42. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  43. import org.openspcoop2.utils.date.DateManager;

  45. /**     
  46.  * ContenutiUtilities
  47.  *
  48.  * @author Poli Andrea (poli@link.it)
  49.  * @author $Author$
  50.  * @version $Rev$, $Date$
  51.  */
  52. public class ContenutiUtilities {

  54.     private Logger logger;
  55.     
  56.     public ContenutiUtilities(Logger log){
  57.         this.logger = log;
  58.     }
  59.     
  60.     public void insertContenuti(Transazione transactionDTO,
  61.             Traccia tracciaRichiesta, Traccia tracciaRisposta,
  62.             List<MsgDiagnostico> msgDiagnostici,
  63.             IDumpMessaggioService dumpMessageService,
  64.             List<TransactionResource> risorse,
  65.             TransactionServiceLibrary transactionServiceLibrary,
  66.             DAOFactory daoFactory) throws HandlerException{

  68.         try {

  70.             boolean updateRichiestaIngresso = false;
  71.             boolean updateRichiestaUscita = false;
  72.             boolean updateRispostaIngresso = false;
  73.             boolean updateRispostaUscita = false;
  74.             
  75.             DumpMessaggio dumpMessaggioRichiestaIngresso = null;
  76.             DumpMessaggio dumpMessaggioRichiestaUscita = null;
  77.             DumpMessaggio dumpMessaggioRispostaIngresso = null;
  78.             DumpMessaggio dumpMessaggioRispostaUscita = null;
  79.             
  80.             IdDumpMessaggio idDumpMessaggioRichiestaIngresso = new IdDumpMessaggio();
  81.             idDumpMessaggioRichiestaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  82.             idDumpMessaggioRichiestaIngresso.setTipoMessaggio(TipoMessaggio.RICHIESTA_INGRESSO);
  83.             
  84.             IdDumpMessaggio idDumpMessaggioRichiestaUscita = new IdDumpMessaggio();
  85.             idDumpMessaggioRichiestaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  86.             idDumpMessaggioRichiestaUscita.setTipoMessaggio(TipoMessaggio.RICHIESTA_USCITA);
  87.             
  88.             IdDumpMessaggio idDumpMessaggioRispostaIngresso = new IdDumpMessaggio();
  89.             idDumpMessaggioRispostaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  90.             idDumpMessaggioRispostaIngresso.setTipoMessaggio(TipoMessaggio.RISPOSTA_INGRESSO);
  91.             
  92.             IdDumpMessaggio idDumpMessaggioRispostaUscita = new IdDumpMessaggio();
  93.             idDumpMessaggioRispostaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  94.             idDumpMessaggioRispostaUscita.setTipoMessaggio(TipoMessaggio.RISPOSTA_USCITA);
  95.             
  96.             

  98.             // ----------------------- Inserimento contenuti -------------------------
  99.             if(risorse!=null && !risorse.isEmpty()){
  100.                 
  101.                 
  102.                 for (TransactionResource risorsaCalcolata : risorse) {
  103.                     
  104.                     if(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RICHIESTA_INGRESSO.equals(risorsaCalcolata.getTipoMessaggio())){
  105.                         
  106.                         if(dumpMessaggioRichiestaIngresso==null) {
  107.                             dumpMessaggioRichiestaIngresso = getSafe(dumpMessageService, idDumpMessaggioRichiestaIngresso);
  108.                         }
  109.                         
  110.                         if(dumpMessaggioRichiestaIngresso==null){
  111.                             dumpMessaggioRichiestaIngresso = new DumpMessaggio();
  112.                             dumpMessaggioRichiestaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  113.                             dumpMessaggioRichiestaIngresso.setTipoMessaggio(TipoMessaggio.RICHIESTA_INGRESSO);
  114.                             dumpMessaggioRichiestaIngresso.setDumpTimestamp(DateManager.getDate());
  115.                         }
  116.                         DumpContenuto contenuto = 
  117.                                 TransactionContentUtils.createDumpContenuto(risorsaCalcolata.getNome(), 
  118.                                         risorsaCalcolata.getValore(), 
  119.                                         DateManager.getDate());
  120.                         dumpMessaggioRichiestaIngresso.addContenuto(contenuto);
  121.                         updateRichiestaIngresso = true;
  122.                     }
  123.                     
  124.                     else if(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RICHIESTA_USCITA.equals(risorsaCalcolata.getTipoMessaggio())){
  125.                         
  126.                         if(dumpMessaggioRichiestaUscita==null) {
  127.                             dumpMessaggioRichiestaUscita = getSafe(dumpMessageService, idDumpMessaggioRichiestaUscita);
  128.                         }
  129.                         
  130.                         if(dumpMessaggioRichiestaUscita==null){
  131.                             dumpMessaggioRichiestaUscita = new DumpMessaggio();
  132.                             dumpMessaggioRichiestaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  133.                             dumpMessaggioRichiestaUscita.setTipoMessaggio(TipoMessaggio.RICHIESTA_USCITA);
  134.                             dumpMessaggioRichiestaUscita.setDumpTimestamp(DateManager.getDate());
  135.                         }
  136.                         DumpContenuto contenuto = 
  137.                                 TransactionContentUtils.createDumpContenuto(risorsaCalcolata.getNome(), 
  138.                                         risorsaCalcolata.getValore(), 
  139.                                         DateManager.getDate());
  140.                         dumpMessaggioRichiestaUscita.addContenuto(contenuto);
  141.                         updateRichiestaUscita = true;
  142.                     }
  143.                     
  144.                     else if(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RISPOSTA_INGRESSO.equals(risorsaCalcolata.getTipoMessaggio())){
  145.                         
  146.                         if(dumpMessaggioRispostaIngresso==null) {
  147.                             dumpMessaggioRispostaIngresso = getSafe(dumpMessageService, idDumpMessaggioRispostaIngresso);
  148.                         }
  149.                         
  150.                         if(dumpMessaggioRispostaIngresso==null){
  151.                             dumpMessaggioRispostaIngresso = new DumpMessaggio();
  152.                             dumpMessaggioRispostaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  153.                             dumpMessaggioRispostaIngresso.setTipoMessaggio(TipoMessaggio.RISPOSTA_INGRESSO);
  154.                             dumpMessaggioRispostaIngresso.setDumpTimestamp(DateManager.getDate());
  155.                         }
  156.                         DumpContenuto contenuto = 
  157.                                 TransactionContentUtils.createDumpContenuto(risorsaCalcolata.getNome(), 
  158.                                         risorsaCalcolata.getValore(), 
  159.                                         DateManager.getDate());
  160.                         dumpMessaggioRispostaIngresso.addContenuto(contenuto);
  161.                         updateRispostaIngresso = true;
  162.                     }
  163.                     
  164.                     else if(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RISPOSTA_USCITA.equals(risorsaCalcolata.getTipoMessaggio())){
  165.                         
  166.                         if(dumpMessaggioRispostaUscita==null) {
  167.                             dumpMessaggioRispostaUscita = getSafe(dumpMessageService, idDumpMessaggioRispostaUscita);
  168.                         }
  169.                         
  170.                         if(dumpMessaggioRispostaUscita==null){
  171.                             dumpMessaggioRispostaUscita = new DumpMessaggio();
  172.                             dumpMessaggioRispostaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  173.                             dumpMessaggioRispostaUscita.setTipoMessaggio(TipoMessaggio.RISPOSTA_USCITA);
  174.                             dumpMessaggioRispostaUscita.setDumpTimestamp(DateManager.getDate());
  175.                         }
  176.                         DumpContenuto contenuto = 
  177.                                 TransactionContentUtils.createDumpContenuto(risorsaCalcolata.getNome(), 
  178.                                         risorsaCalcolata.getValore(), 
  179.                                         DateManager.getDate());
  180.                         dumpMessaggioRispostaUscita.addContenuto(contenuto);
  181.                         updateRispostaUscita = true;
  182.                     }
  183.                 }
  184.             }
  185.             
  186.             
  187.             
  188.             // ----------------------- SDK -------------------------
  189.                 
  190.             if(dumpMessaggioRichiestaIngresso==null && transactionServiceLibrary!=null){
  191.                 dumpMessaggioRichiestaIngresso = new DumpMessaggio();
  192.                 dumpMessaggioRichiestaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  193.                 dumpMessaggioRichiestaIngresso.setTipoMessaggio(TipoMessaggio.RICHIESTA_INGRESSO);
  194.                 dumpMessaggioRichiestaIngresso.setDumpTimestamp(DateManager.getDate());
  195.             }
  196.             
  197.             if(dumpMessaggioRichiestaUscita==null && transactionServiceLibrary!=null){
  198.                 dumpMessaggioRichiestaUscita = new DumpMessaggio();
  199.                 dumpMessaggioRichiestaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  200.                 dumpMessaggioRichiestaUscita.setTipoMessaggio(TipoMessaggio.RICHIESTA_USCITA);
  201.                 dumpMessaggioRichiestaUscita.setDumpTimestamp(DateManager.getDate());
  202.             }
  203.             
  204.             if(dumpMessaggioRispostaIngresso==null && transactionServiceLibrary!=null){
  205.                 dumpMessaggioRispostaIngresso = new DumpMessaggio();
  206.                 dumpMessaggioRispostaIngresso.setIdTransazione(transactionDTO.getIdTransazione());
  207.                 dumpMessaggioRispostaIngresso.setTipoMessaggio(TipoMessaggio.RISPOSTA_INGRESSO);
  208.                 dumpMessaggioRispostaIngresso.setDumpTimestamp(DateManager.getDate());
  209.             }
  210.             
  211.             if(dumpMessaggioRispostaUscita==null && transactionServiceLibrary!=null){
  212.                 dumpMessaggioRispostaUscita = new DumpMessaggio();
  213.                 dumpMessaggioRispostaUscita.setIdTransazione(transactionDTO.getIdTransazione());
  214.                 dumpMessaggioRispostaUscita.setTipoMessaggio(TipoMessaggio.RISPOSTA_USCITA);
  215.                 dumpMessaggioRispostaUscita.setDumpTimestamp(DateManager.getDate());
  216.             }
  217.             
  218.             boolean messaggioModificatoSDK = false;
  219.             if(transactionServiceLibrary!=null){
  220.                 messaggioModificatoSDK = transactionServiceLibrary.processResourcesBeforeSaveOnDatabase(transactionDTO,
  221.                         tracciaRichiesta, tracciaRisposta,
  222.                         msgDiagnostici,
  223.                         dumpMessaggioRichiestaIngresso, dumpMessaggioRichiestaUscita,
  224.                         dumpMessaggioRispostaIngresso, dumpMessaggioRispostaUscita, 
  225.                         transactionDTO.getStato(),
  226.                         this.logger,daoFactory);
  227.             }
  228.             
  229.             
  230.             
  231.             
  232.             // ----------------------- UPDATE -------------------------

  234.             if(updateRichiestaIngresso || messaggioModificatoSDK){
  235.                 dumpMessageService.updateOrCreate(idDumpMessaggioRichiestaIngresso, dumpMessaggioRichiestaIngresso);
  236.             }
  237.             if(updateRichiestaUscita || messaggioModificatoSDK){
  238.                 dumpMessageService.updateOrCreate(idDumpMessaggioRichiestaUscita, dumpMessaggioRichiestaUscita);
  239.             }
  240.             
  241.             if(updateRispostaIngresso || messaggioModificatoSDK){
  242.                 dumpMessageService.updateOrCreate(idDumpMessaggioRispostaIngresso, dumpMessaggioRispostaIngresso);
  243.             }
  244.             if(updateRispostaUscita || messaggioModificatoSDK){
  245.                 dumpMessageService.updateOrCreate(idDumpMessaggioRispostaUscita, dumpMessaggioRispostaUscita);
  246.             }
  247.             
  248.         } catch (Exception e) {
  249.             throw new HandlerException("Errore durante la scrittura della transazione sul database: " + e.getLocalizedMessage(), e);
  250.         } 
  251.     }
  252.     
  253.     private DumpMessaggio getSafe(IDumpMessaggioService dumpMessageService, IdDumpMessaggio id) throws ServiceException, MultipleResultException, NotImplementedException {
  254.         try{
  255.             return dumpMessageService.get(id);
  256.         }catch(NotFoundException notFound){
  257.             // ignore
  258.             return null;
  259.         }
  260.     }
  261.     
  262. }
Created with JaCoCo 0.8.8.202204050719