admin/gateway-dbc-fx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

327915 - Modifica flussi Cubo Saldi Netti (Consumer e Business) - Fase 1 - DWHE2E->DBCFX - Update

Browse Source
This commit is contained in:
manuelstefanile
2025-01-17 09:16:41 +01:00
parent ec4e78ff91
commit dd1636242c
7 changed files with 96 additions and 228 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
gnpapp/properties/delta_RU_XXX_resources.properties
View File

@@ -2,8 +2,10 @@
########################### INVIO FILE A DWHE ###########################
#header edl Donor
PATH_FILE_DWHE2E_REPOSALDINETTI_IN=/gnpapp/batch/ftpin/dwhe2e_report/
DWHE2E_REPOSALDINETTI_BACKUP_IN=/gnpapp/batch/backup_in/dwhe2e_report/
PATH_FILE_DWHE2E_REPOSALDINETTI_CON_IN=/gnpapp/batch/ftpin/dwhe2e_saldinetti_con/
PATH_FILE_DWHE2E_REPOSALDINETTI_BUS_IN=/gnpapp/batch/ftpin/dwhe2e_saldinetti_bus/
DWHE2E_REPOSALDINETTI_CON_BACKUP_IN=/gnpapp/batch/backup_in/dwhe2e_saldinetti_con/
DWHE2E_REPOSALDINETTI_BUS_BACKUP_IN=/gnpapp/batch/backup_in/dwhe2e_saldinetti_bus/
#estensione dei file da inviare a CRMB
DWHE2E_REPOSALDINETTI_FILENAME_EXT=.csv
#Prefisso dei file per CRMB

32
gnpdev/SFTPDaemon/properties/DELTA_RU_XXX_sfdp.properties
View File

@@ -1,53 +1,43 @@
######################## INIZIO CONFIGURAZIONE DWHE2E_REPOSALDINETTI_CO ###################
GET.LOCAL.PATH.DWHE2E_REPOSALDINETTI_CO=/gnpapp/batch/ftpin/dwhe2e_reposaldinetti
GET.LOCAL.PATH.DWHE2E_REPOSALDINETTI_CO=/gnpapp/batch/ftpin/dwhe2e_saldinetti_con
GET.IDENTITY.DWHE2E_REPOSALDINETTI_CO=/home/bea/.ssh/id_rsa
GET.PASSPHRASE.DWHE2E_REPOSALDINETTI_CO=
GET.USERNAME.DWHE2E_REPOSALDINETTI_CO=dbcfx
#GET.HOST.XDSL=10.119.3.119
# PORTALE WHOLESALE LINUX
GET.HOST.REG=172.30.16.178
GET.PORT.DWHE2E_REPOSALDINETTI_CO=22
GET.KNOWN_HOSTS.DWHE2E_REPOSALDINETTI_CO=/home/bea/.ssh/known_hosts
GET.REMOTE_PATH.DWHE2E_REPOSALDINETTI_CO=/HOME/xdsl/adsl_002/dwhe2e
GET.EXTENSION.DWHE2E_REPOSALDINETTI_CO=.xml.gz;.bad
GET.REMOTE_PATH.DWHE2E_REPOSALDINETTI_CO=/HOME/xdsl/adsl_002/dwhe2e_co
GET.EXTENSION.DWHE2E_REPOSALDINETTI_CO=.csv
# Pattern di inizio del nome file da prelevare
GET.NOMEFILE_PATTERN.DWHE2E_REPOSALDINETTI_CO=002_*_NGA[.]*
GET.NOMEFILE_PATTERN.DWHE2E_REPOSALDINETTI_CO=DWHE2E_DBCFX_USCITE_CON_????????[.]csv
# Abilita o disabilita decompressione GZip per estensione .gz (YES|NO)
GET.UNCOMPRESS.DWHE2E_REPOSALDINETTI_CO=YES
GET.UNCOMPRESS.DWHE2E_REPOSALDINETTI_CO=NO
# TIMEOUT IN MILLISECONDI (10000 = 10sec, 1800000 = 30min)
GET.CONNECT.TIMEOUT.DWHE2E_REPOSALDINETTI_CO=30000
# FILE PER GESTIONE STORICO FILE LAVORATI (in /gnpapp/
GET.FILENAME.LAVORATI.DWHE2E_REPOSALDINETTI_CO=/gnpapp/properties/002_TLC_STORICO_NOW.txt
GET.FILENAME.LAVORATI.DWHE2E_REPOSALDINETTI_CO=/gnpapp/properties/DWHE2E_SALDINETTI_STORICO_CO.txt
######################## FINE CONFIGURAZIONE DWHE2E_REPOSALDINETTI_CO ###################
######################## INIZIO CONFIGURAZIONE DWHE2E_REPOSALDINETTI_BU ###################
GET.LOCAL.PATH.DWHE2E_REPOSALDINETTI_BU=/gnpapp/batch/ftpin/dwhe2e_reposaldinetti
GET.LOCAL.PATH.DWHE2E_REPOSALDINETTI_BU=/gnpapp/batch/ftpin/dwhe2e_saldinetti_bus
GET.IDENTITY.DWHE2E_REPOSALDINETTI_BU=/home/bea/.ssh/id_rsa
GET.PASSPHRASE.DWHE2E_REPOSALDINETTI_BU=
GET.USERNAME.DWHE2E_REPOSALDINETTI_BU=dbcfx
#GET.HOST.XDSL=10.119.3.119
# PORTALE WHOLESALE LINUX
GET.HOST.REG=172.30.16.178
GET.PORT.DWHE2E_REPOSALDINETTI_BU=22
GET.KNOWN_HOSTS.DWHE2E_REPOSALDINETTI_BU=/home/bea/.ssh/known_hosts
GET.REMOTE_PATH.DWHE2E_REPOSALDINETTI_BU=/HOME/xdsl/adsl_002/PATH_BU_REPO
GET.REMOTE_PATH.DWHE2E_REPOSALDINETTI_BU=/HOME/xdsl/adsl_002/dwhe2e_bu
GET.EXTENSION.DWHE2E_REPOSALDINETTI_BU=.xml.gz;.bad
# Pattern di inizio del nome file da prelevare
GET.NOMEFILE_PATTERN.DWHE2E_REPOSALDINETTI_BU=002_*_NGA[.]*
GET.NOMEFILE_PATTERN.DWHE2E_REPOSALDINETTI_BU=DWHE2E_DBCFX_USCITE_BUS_????????[.]csv
# Abilita o disabilita decompressione GZip per estensione .gz (YES|NO)
GET.UNCOMPRESS.DWHE2E_REPOSALDINETTI_BU=YES
GET.UNCOMPRESS.DWHE2E_REPOSALDINETTI_BU=NO
# TIMEOUT IN MILLISECONDI (10000 = 10sec, 1800000 = 30min)
GET.CONNECT.TIMEOUT.DWHE2E_REPOSALDINETTI_BU=30000
# FILE PER GESTIONE STORICO FILE LAVORATI (in /gnpapp/
GET.FILENAME.LAVORATI.DWHE2E_REPOSALDINETTI_BU=/gnpapp/properties/002_TLC_STORICO_NOW.txt
GET.FILENAME.LAVORATI.DWHE2E_REPOSALDINETTI_BU=/gnpapp/properties/DWHE2E_SALDINETTI_STORICO_BU.txt
######################## FINE CONFIGURAZIONE DWHE2E_REPOSALDINETTI_BU ###################

59
gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteCsNpg103DAO.java
View File

@@ -371,64 +371,5 @@ public class GnpRichiesteCsNpg103DAO extends BaseHibernateDAO{
}
}
/**
*
* @param
* @return
*/
private GnpRichiesteCsNpg103 getRichiesteSaldiNetti(Long idRichiesta, String resourceParam, String piattaforma, String processo)
{
String condizioneDate = "";
// Condizioni aggiuntive basate su `resourceParam`
if ("FULL".equalsIgnoreCase(resourceParam)) {
condizioneDate = "AND A.DATA_RICEZIONE >= TO_DATE(:resourceParam, 'DD/MM/YYYY') ";
} else {
condizioneDate = "AND A.DATA_RICEZIONE >= SYSDATE - :resourceParam ";
}
// Costruzione della query SQL
String sqlQuery = "SELECT " +
"A.PIATTAFORMA_COMPETENZA, A.COD_OP_RECIPIENT " +
"FROM GNP_RICHIESTE_CS_NPG103 A " +
"WHERE A.ID_RICHIESTA = :idRichiesta "+
"AND A.STATO = 5 " +
"AND A.COD_OP_RECIPIENT = :piattaforma " +
"AND A.PROCESSO = :processo " +
condizioneDate +
"ORDER BY A.DATA_RICEZIONE DESC";
try
{
// Creazione della query
Query hqlQuery = getSession().createSQLQuery(sqlQuery)
.addEntity(GnpRichiesteCsNpg103.class) // Mappa il risultato alla classe
.setParameter("idRichiesta", idRichiesta)
.setParameter("resourceParam", resourceParam)
.setParameter("piattaforma", piattaforma)
.setParameter("processo", processo);
// RestituiscO il risultato univoco
return (GnpRichiesteCsNpg103) hqlQuery.uniqueResult();
}
catch (RuntimeException re)
{
log.error("find by custom query failed", re);
throw re;
} finally
{
closeSession();
}
}
public GnpRichiesteCsNpg103 getRichiesteSaldiNettiNativiOlo (Long idRichiesta, String resourceParam, String piattaforma) {
log.debug("GnpRichiesteCsNpg103DAO.getRichiesteSaldiNettiNativiOlo(), Id_richiesta =" + idRichiesta +
" resourceParam = " + resourceParam + " piattaforma = " + piattaforma);
return this.getRichiesteSaldiNetti(idRichiesta,resourceParam,piattaforma,"DONOR_NAT_OLO");
}
public GnpRichiesteCsNpg103 getRichiesteSaldiNettiStdVoip (Long idRichiesta, String resourceParam, String piattaforma) {
log.debug("GnpRichiesteCsNpg103DAO.getRichiesteSaldiNettiNativiOlo(), Id_richiesta =" + idRichiesta +
" resourceParam = " + resourceParam + " piattaforma = " + piattaforma);
return this.getRichiesteSaldiNetti(idRichiesta,resourceParam,piattaforma,"CSNPg103");
}
}

56
gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonor82DAO.java
View File

@@ -540,61 +540,5 @@ public class GnpRichiesteDonor82DAO extends BaseHibernateDAO{
closeSession();
}
}
/**
*
* @param
* @return
*/
public GnpRichiesteDonor82 getRichiesteSaldiNetti(Long idRichiesta, String resourceParam, String piattaforma)
{
log.debug("GnpRichiesteDonor82DAO.getRichiesteSaldiNetti(), Id_richiesta =" + idRichiesta +
" resourceParam = " + resourceParam + " piattaforma = " + piattaforma);
String condizioneDate = "";
// Condizioni aggiuntive basate su `resourceParam`
if ("FULL".equalsIgnoreCase(resourceParam)) {
condizioneDate = "AND B.DATA_ESPLETAMENTO >= TO_DATE(:resourceParam, 'DD/MM/YYYY') ";
} else {
condizioneDate = "AND B.DATA_ESPLETAMENTO >= SYSDATE - :resourceParam ";
}
// Costruzione della query SQL
String sqlQuery = "SELECT " +
"A.CRM_COMPETENZA, A.COW_RECIPIENT " +
"FROM GNP_RICHIESTE_D82 A " +
"WHERE A.ID_RICHIESTA IN ( " +
" SELECT B.ID_RICHIESTA_D82 " +
" FROM GNP_NOW_D82_RICHIESTE_IN B " +
" WHERE B.DATA_ESPLETAMENTO IS NOT NULL " +
condizioneDate +
") " +
"AND A.ID_RICHIESTA = :idRichiesta " +
"AND A.CRM_COMPETENZA = :piattaforma " +
"ORDER BY A.DATA_RICEZIONE DESC";
try
{
// Creazione della query
Query hqlQuery = getSession().createSQLQuery(sqlQuery)
.addEntity(GnpRichiesteDonor82.class) // Mappa il risultato alla classe Del82Entity
.setParameter("idRichiesta", idRichiesta)
.setParameter("resourceParam", resourceParam)
.setParameter("piattaforma", piattaforma);
// RestituiscO il risultato univoco
return (GnpRichiesteDonor82) hqlQuery.uniqueResult();
}
catch (RuntimeException re)
{
log.error("find by custom query failed", re);
throw re;
} finally
{
closeSession();
}
}
}

48
gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonorDAO.java
View File

@@ -510,53 +510,5 @@ public class GnpRichiesteDonorDAO extends BaseHibernateDAO{
closeSession();
}
}
/**
*
* @param
* @return
*/
public GnpRichiesteDonor getRichiesteSaldiNettiDel274(Long idRichiesta, String resourceParam, String piattaforma)
{
log.debug("GnpRichiesteDonorDAO.getRichiesteSaldiNettiDel274(), Id_richiesta =" + idRichiesta +
" resourceParam = " + resourceParam + " piattaforma = " + piattaforma);
String condizioneDate = "";
// Condizioni aggiuntive basate su `resourceParam`
if ("FULL".equalsIgnoreCase(resourceParam)) {
condizioneDate = "AND A.DATA_RICEZIONE >= TO_DATE(:resourceParam, 'DD/MM/YYYY') ";
} else {
condizioneDate = "AND A.DATA_RICEZIONE >= SYSDATE - :resourceParam ";
}
// Costruzione della query SQL
String sqlQuery = "SELECT " +
"A.CRM_COMPETENZA, A.COW_RECIPIENT " +
"FROM GNP_RICHIESTE_DONOR A " +
"WHERE A.ID_RICHIESTA = :idRichiesta "+
"AND A.STATO = 4 " +
"AND A.CRM_COMPETENZA = :piattaforma " +
condizioneDate +
"ORDER BY A.DATA_RICEZIONE DESC";
try
{
// Creazione della query
Query hqlQuery = getSession().createSQLQuery(sqlQuery)
.addEntity(GnpRichiesteDonor.class) // Mappa il risultato alla classe
.setParameter("idRichiesta", idRichiesta)
.setParameter("resourceParam", resourceParam)
.setParameter("piattaforma", piattaforma);
// RestituiscO il risultato univoco
return (GnpRichiesteDonor) hqlQuery.uniqueResult();
}
catch (RuntimeException re)
{
log.error("find by custom query failed", re);
throw re;
} finally
{
closeSession();
}
}
}

104
gnpdev/dbcfx/src/it/valueteam/gnp/internalflow/in/Dwhe2eRepoSaldiNettiIn.java
View File

@@ -10,6 +10,8 @@ import it.valueteam.gnp.utility.DateUtils;
import it.valueteam.gnp.utility.Resources;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
@@ -22,8 +24,8 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
private static final String codiceProcesso = "IG";
private static final String versione = "1.0.0";
private String separator = ";";
private static final String ESTRAZIONE_FULL = "FULL";
private static final String ESTRAZIONE_DELTA = "DELTA";
private static final String CTR = ".ctr";
private static final String CONSUMER = "CO";
private static final String BUSINESS = "BU";
private static final String DEL_82 = "Del. 82";
@@ -64,11 +66,7 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
log.write("9999", " EXECUTE Dwhe2eRepoSaldiNettiIn ");
try {
if (args.length == 1 && (ESTRAZIONE_FULL.equalsIgnoreCase(args[0]) || ESTRAZIONE_DELTA.equalsIgnoreCase(args [0]))) {
readFile(args[0]);
} else {
log.write("9999", "Creazione file non eseguita. Inserire parametro (FULL o DELTA) ");
}
readFile();
} catch (Exception ex) {
//0003 C - PROCESSO TERMINATO CON ECCEZIONI
log.write("0003", "" + ex.toString());
@@ -79,18 +77,19 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
}
private void readFile(String arg) throws Exception{
private void readFile() throws Exception{
//argomento full o delta
log.write("9999", "Start readFile");
String resourceParam;
if(ESTRAZIONE_FULL.equalsIgnoreCase(arg)) {
resourceParam = Resources.getDWHE2E_REPOSALDINETTI_FULL();
} else {
resourceParam = Resources.getDWHE2E_REPOSALDINETTI_DELTA();
}
List<String> listFileName = getListFileName(Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_IN());
readFilesAndStore(listFileName,resourceParam);
//leggo i file da cartella CO
List<String> listFileName = getListFileName(Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_CON_IN());
readFilesAndStore(listFileName);
//geneFileOut()
//leggo i file da cartella BU
listFileName = getListFileName(Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_BUS_IN());
readFilesAndStore(listFileName);
log.write("9999", "End readFile");
@@ -121,7 +120,7 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
return listFileName;
}
private void readFilesAndStore(List<String> listFileName, String resourceParam) throws Exception {
private void readFilesAndStore(List<String> listFileName) throws Exception {
log.write("9999", "Start readFilesAndStore");
for(String fileName : listFileName) {
@@ -139,7 +138,7 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
//AGGIUNGI ad ogni oggetto i dati di FX ricercandoli nelle tabelle
// e salva nel db. 2 in 1 per evitare di scorrere la lista 2 volte!
this.aggiungiInfoAndSave(listForFile,resourceParam,piattaforma);
this.aggiungiInfoAndSave(listForFile);
}
@@ -155,8 +154,13 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
List<GnpDwhe2eSaldinettiIn> listForFile = new ArrayList<GnpDwhe2eSaldinettiIn>();
try {
log.write("9999", "file da elaborare "+Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_IN()+fileName);
File wlFile = new File(Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_IN()+fileName);
String pathLetturaFile = (piattaforma == this.CONSUMER) ? Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_CON_IN()
: Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_BUS_IN();
String pathBackupFile = (piattaforma == this.CONSUMER) ? Resources.getDWHE2E_REPOSALDINETTI_CON_BACKUP_IN()
: Resources.getDWHE2E_REPOSALDINETTI_BUS_BACKUP_IN();
log.write("9999", "file da elaborare "+pathLetturaFile+fileName);
File wlFile = new File(pathLetturaFile+fileName);
Scanner reader = new Scanner(wlFile);
@@ -176,8 +180,22 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
}
reader.close();
backupFile(wlFile,fileName);
//arrivato qui, è andato tutto a buon fine, allora sposto .csv e .ctr
//Creo la directory (se non esite) dove spostare tutti i file
File copiaBk = new File(pathBackupFile);
if(!copiaBk.exists())copiaBk.mkdir();
//spostato il file .csv
spostaFile(pathBackupFile,wlFile);
//cerco il file .ctr e lo sposto fileNameAbsolute = DWHE2E_DBCFX_USCITE_CON_aaaammgg
String fileNameAbsolute = fileName.substring(0,fileName.lastIndexOf("."));
File ctrlFile = new File(pathLetturaFile+fileNameAbsolute +this.CTR);
//spostato il file .ctr
spostaFile(pathBackupFile,ctrlFile);
} catch (Exception e) {
// TODO gestisci gli errori
log.write("9999", "exception in readFileAndGetList "+e.getMessage());
throw e;
}
@@ -185,17 +203,27 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
return listForFile;
}
private void backupFile(File wlFile, String fileName) {
log.write("9999", "Start backup file");
wlFile.renameTo(new File(Resources.getDWHE2E_REPOSALDINETTI_BACKUP_IN()+"backup_"+fileName));
log.write("9999", "Backup effettuato "+Resources.getDWHE2E_REPOSALDINETTI_BACKUP_IN()+fileName);
log.write("9999", "End backup file");
private void spostaFile(String sDir, File inFile) throws Exception
{
log.write("9999","Sposto il file : " + inFile.getName());
File out = new File(sDir + inFile.getName() );
FileInputStream fis = new FileInputStream(inFile);
FileOutputStream fos = new FileOutputStream(out);
byte[] buf = new byte[1024];
int y = 0;
while((y=fis.read(buf))!=-1) {
fos.write(buf, 0, y);
}
//chiudo i canali
fis.close();
fos.close();
log.write("9999","Cancello file : " + inFile.getName());
inFile.delete();
}
private GnpDwhe2eSaldinettiIn getDataFromLine(String line, String nomeFile, String piattaforma) throws Exception {
log.write("9999", "start getDataFromLine line= "+line);
@@ -222,45 +250,45 @@ public class Dwhe2eRepoSaldiNettiIn implements Loggable, ProcessIF {
return gnpDwhe2eSaldinettiIn;
}
// TODO
private void aggiungiInfoAndSave(List<GnpDwhe2eSaldinettiIn> gnpDwhe2eSaldinettiIn,String resourceParam, String piattaforma){
private void aggiungiInfoAndSave(List<GnpDwhe2eSaldinettiIn> gnpDwhe2eSaldinettiIn){
log.write("9999", "Start aggiungiInfoAndSave");
//instanzia le classi DAO
//del.82
GnpRichiesteDonor82DAO daoRichiesteD82 = new GnpRichiesteDonor82DAO();
//del 274
GnpRichiesteDonorDAO daoRichiesteDonor = new GnpRichiesteDonorDAO();
//del. 103
//del. 103 std, voip e nativiOlo
GnpRichiesteCsNpg103DAO daoCsNpg103 = new GnpRichiesteCsNpg103DAO();
//DAO per storare le richieste IN
GnpDwhe2eSaldinettiInDAO dwhe2eSaldinettiInDAO = new GnpDwhe2eSaldinettiInDAO();
//effettua la ricerca nelle tabelle sfruttando resourceParam DELTA/FULL e piattaforma per poi aggiorna i campi dbcfx
//effettua la ricerca nelle tabelle sfruttando ID_RICHIESTA per poi aggiorna i campi dbcfx
for(GnpDwhe2eSaldinettiIn dwhe2eItem : gnpDwhe2eSaldinettiIn ){
// del. 82
GnpRichiesteDonor82 gnpRichiestaDonor82 = daoRichiesteD82.getRichiesteSaldiNetti(dwhe2eItem.getIdRichiesta(), resourceParam, piattaforma);
GnpRichiesteDonor82 gnpRichiestaDonor82 = daoRichiesteD82.findById(dwhe2eItem.getIdRichiesta());
if(gnpRichiestaDonor82!=null){
dwhe2eItem.popolaAggiuntiviFX(gnpRichiestaDonor82.getCowRecipient(),this.DEL_82_TIPOUSCITA, this.DEL_82);
dwhe2eSaldinettiInDAO.save(dwhe2eItem);
continue;
}
// del. 274
GnpRichiesteDonor gnpRichiestaDonor274 = daoRichiesteDonor.getRichiesteSaldiNettiDel274(dwhe2eItem.getIdRichiesta(), resourceParam, piattaforma);
GnpRichiesteDonor gnpRichiestaDonor274 = daoRichiesteDonor.findById(dwhe2eItem.getIdRichiesta());
if(gnpRichiestaDonor274!=null){
dwhe2eItem.popolaAggiuntiviFX(gnpRichiestaDonor274.getCowRecipient(),this.DEL_274_TIPOUSCITA, this.DEL_274);
dwhe2eSaldinettiInDAO.save(dwhe2eItem);
continue;
}
// del. 103 uscite Donor nativi olo
GnpRichiesteCsNpg103 gnpRichiesteCsNpg103NativiOlo = daoCsNpg103.getRichiesteSaldiNettiNativiOlo(dwhe2eItem.getIdRichiesta(), resourceParam, piattaforma);
GnpRichiesteCsNpg103 gnpRichiesteCsNpg103NativiOlo = daoCsNpg103.findById(dwhe2eItem.getIdRichiesta());
if(gnpRichiesteCsNpg103NativiOlo!=null){
dwhe2eItem.popolaAggiuntiviFX(gnpRichiesteCsNpg103NativiOlo.getCodOpRecipient(),this.DEL_103_NATOLO_TIPOUSCITA, this.DEL_103);
dwhe2eSaldinettiInDAO.save(dwhe2eItem);
continue;
}
// del. 103 uscite Donor nativi olo
GnpRichiesteCsNpg103 gnpRichiesteCsNpg103StdVoip = daoCsNpg103.getRichiesteSaldiNettiStdVoip(dwhe2eItem.getIdRichiesta(), resourceParam, piattaforma);
GnpRichiesteCsNpg103 gnpRichiesteCsNpg103StdVoip = daoCsNpg103.findById(dwhe2eItem.getIdRichiesta());
if(gnpRichiesteCsNpg103StdVoip!=null){
dwhe2eItem.popolaAggiuntiviFX(gnpRichiesteCsNpg103StdVoip.getCodOpRecipient(),this.DEL_103_STD_VOIP_TIPOUSCITA, this.DEL_103);
dwhe2eSaldinettiInDAO.save(dwhe2eItem);

19
gnpdev/dbcfx/src/it/valueteam/gnp/utility/Resources.java
View File

@@ -3281,17 +3281,28 @@ public class Resources {
}
public static String getPATH_FILE_DWHE2E_REPOSALDINETTI_IN() {
public static String getPATH_FILE_DWHE2E_REPOSALDINETTI_CON_IN() {
if (props == null)
init();
return Trim(props.getProperty("PATH_FILE_DWHE2E_REPOSALDINETTI_IN"));
return Trim(props.getProperty("PATH_FILE_DWHE2E_REPOSALDINETTI_CON_IN"));
}
public static String getPATH_FILE_DWHE2E_REPOSALDINETTI_BUS_IN() {
if (props == null)
init();
return Trim(props.getProperty("PATH_FILE_DWHE2E_REPOSALDINETTI_BUS_IN"));
}
public static String getDWHE2E_REPOSALDINETTI_BACKUP_IN() {
public static String getDWHE2E_REPOSALDINETTI_CON_BACKUP_IN() {
if (props == null)
init();
return Trim(props.getProperty("DWHE2E_REPOSALDINETTI_BACKUP_IN"));
return Trim(props.getProperty("DWHE2E_REPOSALDINETTI_CON_BACKUP_IN"));
}
public static String getDWHE2E_REPOSALDINETTI_BUS_BACKUP_IN() {
if (props == null)
init();
return Trim(props.getProperty("DWHE2E_REPOSALDINETTI_BUS_BACKUP_IN"));
}
public static String getDWHE2E_REPOSALDINETTI_FILENAME_EXT() {