Skip to content

Commit

Permalink
Gestione flusso SIOPE+ per Sostituzione Mandato
Browse files Browse the repository at this point in the history
  • Loading branch information
@mspasiano
mspasiano committed Nov 29, 2019
1 parent 4e7cf7c commit 7404a9c
Show file tree
Hide file tree
Showing 4 changed files with 54 additions and 73 deletions.
3 changes: 2 additions & 1 deletion sigla-ejb/src/main/java/it/cnr/contab/anagraf00/tabrif/bulk/Rif_modalita_pagamentoBulk.java
View file
Expand Up @@ -206,7 +206,8 @@ public enum TipoPagamentoSiopePlus {
ADDEBITOPREAUTORIZZATO("ADDEBITO PREAUTORIZZATO"),
DISPOSIZIONEDOCUMENTOESTERNO("DISPOSIZIONE DOCUMENTO ESTERNO"),
COMPENSAZIONE("COMPENSAZIONE"),
BONIFICOESTEROEURO("BONIFICO ESTERO EURO");
BONIFICOESTEROEURO("BONIFICO ESTERO EURO"),
SOSTITUZIONE("SOSTITUZIONE");

private final String value;

Expand Down
117 changes: 51 additions & 66 deletions sigla-ejb/src/main/java/it/cnr/contab/doccont00/comp/DistintaCassiereComponent.java
View file
Expand Up @@ -117,6 +117,7 @@ public class DistintaCassiereComponent extends
public static final String REGOLARIZZAZIONE_ACCREDITO_BANCA_D_ITALIA = "REGOLARIZZAZIONE ACCREDITO BANCA D'ITALIA";
public static final String SCOSTAMENTO = "0.03";
public static final String VARIAZIONE = "VARIAZIONE";
public static final String SOSTITUZIONE = "SOSTITUZIONE";

final String regexBic = "[A-Z|a-z||0-9]{11}|[A-Z|a-z||0-9]{8}";
final Pattern patternBic = Pattern.compile(regexBic, Pattern.MULTILINE);
Expand Down Expand Up @@ -661,12 +662,17 @@ protected Long aggiungiMandatiEReversaliCollegati(UserContext userContext,
userContext, V_mandato_reversaleBulk.class))
.findDocContabiliCollegati(docContabilePadre);
V_mandato_reversaleBulk docContabile;
for (Iterator i = docContabili.iterator(); i.hasNext(); ) {
docContabile = (V_mandato_reversaleBulk) i.next();
last_pg_dettaglio = inserisciDettaglioDistinta(userContext,
distinta, docContabile, last_pg_dettaglio);
inserisciDettaglioDistinteCollegate(userContext, distinta,
docContabile);
if (Optional.ofNullable(docContabilePadre.getStatoVarSos())
.map(s -> !Arrays.asList(StatoVariazioneSostituzione.ANNULLATO_PER_SOSTITUZIONE.value(),
StatoVariazioneSostituzione.SOSTITUZIONE_DEFINITIVA.value()).contains(s))
.orElse(Boolean.TRUE)) {
for (Iterator i = docContabili.iterator(); i.hasNext(); ) {
docContabile = (V_mandato_reversaleBulk) i.next();
last_pg_dettaglio = inserisciDettaglioDistinta(userContext,
distinta, docContabile, last_pg_dettaglio);
inserisciDettaglioDistinteCollegate(userContext, distinta,
docContabile);
}
}
return last_pg_dettaglio;
}
Expand Down Expand Up @@ -843,34 +849,6 @@ public void associaTuttiDocContabili(UserContext userContext,
}
broker.close();

/*
* String schema =
* it.cnr.jada.util.ejb.EJBCommonServices.getDefaultSchema(); String
* user =
* it.cnr.contab.utenze00.bp.CNRUserContext.getUser(userContext);
* java.sql.Timestamp dacr = new
* java.sql.Timestamp(System.currentTimeMillis());
*
* java.sql.PreparedStatement ps =
* getConnection(userContext).prepareStatement(
* "INSERT INTO "+schema+
* "ASS_TIPO_LA_CDR ( CD_CENTRO_RESPONSABILITA, CD_TIPO_LINEA_ATTIVITA, UTCR, DUVA, UTUV, DACR, PG_VER_REC ) SELECT CD_CENTRO_RESPONSABILITA, ?, ?, ?, ?, ?, 1 FROM "
* +schema+
* "V_CDR_VALIDO WHERE ESERCIZIO = ? AND NOT EXISTS ( SELECT 1 FROM "
* +schema+
* "ASS_TIPO_LA_CDR WHERE V_CDR_VALIDO.CD_CENTRO_RESPONSABILITA = ASS_TIPO_LA_CDR.CD_CENTRO_RESPONSABILITA AND ASS_TIPO_LA_CDR.CD_TIPO_LINEA_ATTIVITA = ? ) "
* );
*
* ps.setString(1,dsitinta.getCd_tipo_linea_attivita()); //
* CD_TIPO_LINEA_ATTIVITA ps.setString(2,user); // UTCR
* ps.setTimestamp(3,dacr); // DUVA ps.setString(4,user); // UTUV
* ps.setTimestamp(5,dacr); // DACR
* ps.setInt(6,it.cnr.contab.utenze00
* .bp.CNRUserContext.getEsercizio(userContext).intValue()); //
* ESERCIZIO ps.setString(7,tipo_la.getCd_tipo_linea_attivita()); //
* CD_TIPO_LINEA_ATTIVITA LoggableStatement.execute(ps);
* try{ps.close();}catch( java.sql.SQLException e ){};
*/
} catch (Exception e) {
throw handleException(e);
}
Expand Down Expand Up @@ -3021,34 +2999,6 @@ public SQLBuilder selectDistinta_cassiere_detCollByClause(
sql.addOrderBy(" V_MANDATO_REVERSALE_DISTINTA.CD_TIPO_DOCUMENTO_CONT_PADRE, V_MANDATO_REVERSALE_DISTINTA.TI_DOCUMENTO_CONT_PADRE, V_MANDATO_REVERSALE_DISTINTA.PG_DOCUMENTO_CONT_PADRE ");
return sql;
}

/*
* SQLBuilder sql =
* getHome(userContext,V_mandato_reversaleBulk.class).createSQLBuilder
* (); sql.addTableToHeader("DISTINTA_CASSIERE_DET");
* sql.addSQLJoin("V_MANDATO_REVERSALE.ESERCIZIO"
* ,"DISTINTA_CASSIERE_DET.ESERCIZIO");
* sql.addSQLJoin("V_MANDATO_REVERSALE.CD_CDS"
* ,"DISTINTA_CASSIERE_DET.CD_CDS"); sql.openParenthesis( "AND" );
* sql.addSQLClause("AND",
* "(DISTINTA_CASSIERE_DET.PG_MANDATO is not null AND V_MANDATO_REVERSALE.CD_TIPO_DOCUMENTO_CONT = 'MAN' AND DISTINTA_CASSIERE_DET.PG_MANDATO = V_MANDATO_REVERSALE.PG_DOCUMENTO_CONT)"
* ); sql.addSQLClause("OR",
* "(DISTINTA_CASSIERE_DET.PG_REVERSALE is not null AND V_MANDATO_REVERSALE.CD_TIPO_DOCUMENTO_CONT = 'REV' AND DISTINTA_CASSIERE_DET.PG_REVERSALE = V_MANDATO_REVERSALE.PG_DOCUMENTO_CONT)"
* ); sql.closeParenthesis();
* sql.addSQLClause("AND","DISTINTA_CASSIERE_DET.ESERCIZIO",sql.EQUALS,
* distinta.getEsercizio());
* sql.addSQLClause("AND","DISTINTA_CASSIERE_DET.CD_CDS",sql.EQUALS,
* distinta.getCd_cds());
* sql.addSQLClause("AND","DISTINTA_CASSIERE_DET.CD_UNITA_ORGANIZZATIVA"
* ,sql.EQUALS, distinta.getCd_unita_organizzativa()); if (
* distinta.getPg_distinta() != null )
* sql.addSQLClause("AND","DISTINTA_CASSIERE_DET.PG_DISTINTA"
* ,sql.EQUALS, distinta.getPg_distinta()); else
* sql.addSQLClause("AND","DISTINTA_CASSIERE_DET.PG_DISTINTA"
* ,sql.ISNULL, null); sql.addOrderBy(
* " V_MANDATO_REVERSALE.CD_TIPO_DOCUMENTO_CONT_PADRE, V_MANDATO_REVERSALE.TI_DOCUMENTO_CONT_PADRE, V_MANDATO_REVERSALE.PG_DOCUMENTO_CONT_PADRE "
* ); return sql;
*/
} catch (Throwable e) {
throw handleException(e);
}
Expand Down Expand Up @@ -4585,6 +4535,11 @@ private String getTipoOperazioneVariazione(UserContext userContext, V_mandato_re
if (isVariazioneDefinitiva) {
return VARIAZIONE;
} else {
if (Optional.ofNullable(bulk.getStatoVarSos())
.map(statoVarSos -> statoVarSos.equals(StatoVariazioneSostituzione.SOSTITUZIONE_DEFINITIVA.value()))
.orElse(Boolean.FALSE)) {
return SOSTITUZIONE;
}
return stato;
}

Expand Down Expand Up @@ -4782,6 +4737,24 @@ else if (docContabile.getDsDocumento().length() > MAX_LENGTH_CAUSALE)
}
}

private MandatoBulk cercaMandatoRiemissione(UserContext userContext, V_mandato_reversaleBulk bulk) throws ComponentException, PersistencyException {
final BulkHome home = getHome(userContext, MandatoIBulk.class);
SQLBuilder sql = home.createSQLBuilder();
sql.addClause(FindClause.AND, "esercizio", SQLBuilder.EQUALS, bulk.getEsercizio());
sql.addClause(FindClause.AND, "cd_cds_origine", SQLBuilder.EQUALS, bulk.getCd_cds_origine());
sql.addClause(FindClause.AND, "stato", SQLBuilder.EQUALS, MandatoBulk.STATO_MANDATO_ANNULLATO);
sql.addSQLClause(FindClause.AND, "pg_mandato_riemissione", SQLBuilder.EQUALS, bulk.getPg_documento_cont());
sql.addClause(FindClause.AND, "fl_riemissione", SQLBuilder.EQUALS, true);
final Optional<MandatoBulk> any = home.fetchAll(sql).stream()
.filter(MandatoBulk.class::isInstance)
.map(MandatoBulk.class::cast)
.findAny();
if (!any.isPresent()) {
throw new ApplicationMessageFormatException("Mandato di riemmissione non trovato per {1}/{2}/{3}", bulk.getEsercizio(), bulk.getCd_cds_origine(), bulk.getPg_documento_cont());
}
return any.get();
}

private it.siopeplus.Mandato creaMandatoFlussoSiopeplus(UserContext userContext, V_mandato_reversaleBulk bulk) throws ComponentException, RemoteException {
try {
Configurazione_cnrComponentSession sess = (Configurazione_cnrComponentSession) it.cnr.jada.util.ejb.EJBCommonServices
Expand Down Expand Up @@ -4833,12 +4806,23 @@ private it.siopeplus.Mandato creaMandatoFlussoSiopeplus(UserContext userContext,
codiceNazione.get());
}
}


final Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus tipoPagamentoSiopePlus =
final Boolean isSostituzione = Optional.ofNullable(bulk.getStatoVarSos())
.map(statoVarSos -> statoVarSos.equals(StatoVariazioneSostituzione.SOSTITUZIONE_DEFINITIVA.value()))
.orElse(Boolean.FALSE);
final Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus tipoPagamentoSiopePlus = isSostituzione ?
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.SOSTITUZIONE :
Optional.ofNullable(rif_modalita_pagamentoBulk.getTipo_pagamento_siope())
.map(s -> Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.getValueFrom(s))
.orElseGet(() -> Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.REGOLARIZZAZIONE);
if (isSostituzione) {
final MandatoBulk mandatoRiemissione = cercaMandatoRiemissione(userContext, bulk);
SostituzioneMandato sostituzioneMandato = objectFactory.createSostituzioneMandato();
sostituzioneMandato.setEsercizioMandatoDaSostituire(mandatoRiemissione.getEsercizio());
sostituzioneMandato.setNumeroMandatoDaSostituire(mandatoRiemissione.getPg_mandato().intValue());
// TODO Valore fisso a 1
sostituzioneMandato.setProgressivoBeneficiarioDaSostituire(BigInteger.ONE);
infoben.setSostituzioneMandato(sostituzioneMandato);
}

// deve esserci IBAN
boolean obb_iban = Arrays.asList(
Expand Down Expand Up @@ -4886,7 +4870,8 @@ private it.siopeplus.Mandato creaMandatoFlussoSiopeplus(UserContext userContext,
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.ASSEGNOCIRCOLARE,
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.CASSA,
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.SEPACREDITTRANSFER,
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.COMPENSAZIONE
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.COMPENSAZIONE,
Rif_modalita_pagamentoBulk.TipoPagamentoSiopePlus.SOSTITUZIONE
).contains(tipoPagamentoSiopePlus))
//TODO da sostituire
||rif_modalita_pagamentoBulk.getCd_modalita_pag().equals(STIPENDI)
Expand Down
6 changes: 0 additions & 6 deletions sigla-ejb/src/main/java/it/cnr/contab/doccont00/intcass/bulk/V_mandato_reversaleHome.java
View file
Expand Up @@ -147,12 +147,6 @@ public List<V_mandato_reversaleBulk> findReversaliCollegate(V_mandato_reversaleB
public Collection findDocContabiliCollegati(V_mandato_reversaleBulk docContabile) throws PersistencyException {

SQLBuilder sql = createSQLBuilder();
/*???????
if ( docContabile.getCd_tipo_documento_cont().equals( Numerazione_doc_contBulk.TIPO_MAN ) )
sql.addClause( "AND", "cd_tipo_documento_cont", sql.EQUALS, Numerazione_doc_contBulk.TIPO_REV);
else if ( docContabile.getCd_tipo_documento_cont().equals( Numerazione_doc_contBulk.TIPO_REV ) )
sql.addClause( "AND", "cd_tipo_documento_cont", sql.EQUALS, Numerazione_doc_contBulk.TIPO_MAN);
*/
sql.addClause("AND", "pg_documento_cont_padre", sql.EQUALS, docContabile.getPg_documento_cont());
sql.addClause("AND", "cd_tipo_documento_cont_padre", sql.EQUALS, docContabile.getCd_tipo_documento_cont());
sql.openParenthesis("AND");
Expand Down
1 change: 1 addition & 0 deletions sigla-ejb/src/main/java/it/cnr/contab/util/enumeration/StatoVariazioneSostituzione.java
View file
Expand Up @@ -30,6 +30,7 @@ public enum StatoVariazioneSostituzione {
VARIAZIONE_TRASMESSA("VARIAZIONE TRASMESSA", "VARIAZIONE_TRASMESSA"),
SOSTITUZIONE_TRASMESSA("SOSTITUZIONE TRASMESSA", "SOSTITUZIONE_TRASMESSA"),
VARIATO("VARIATO", "VARIATO"),
ANNULLATO_PER_SOSTITUZIONE("ANNULLATO PER SOSTITUZIONE", "ANNULLATO_PER_SOSTITUZIONE"),
SOSTITUITO("SOSTITUITO", "SOSTITUITO"),
NON_VARIATO("NON VARIATO", "NON_VARIATO"),
NON_SOSTITUITO("NON SOSTITUITO", "NON_SOSTITUITO");
Expand Down

0 comments on commit 7404a9c

Please sign in to comment.