From dd1636242c33547b7da51a4fedb3050a9c0b85b8 Mon Sep 17 00:00:00 2001 From: manuelstefanile Date: Fri, 17 Jan 2025 09:16:41 +0100 Subject: [PATCH] 327915 - Modifica flussi Cubo Saldi Netti (Consumer e Business) - Fase 1 - DWHE2E->DBCFX - Update --- .../delta_RU_XXX_resources.properties | 6 +- .../properties/DELTA_RU_XXX_sfdp.properties | 32 ++---- .../dao/db/hb/GnpRichiesteCsNpg103DAO.java | 59 ---------- .../gnp/dao/db/hb/GnpRichiesteDonor82DAO.java | 56 ---------- .../gnp/dao/db/hb/GnpRichiesteDonorDAO.java | 48 -------- .../in/Dwhe2eRepoSaldiNettiIn.java | 104 +++++++++++------- .../it/valueteam/gnp/utility/Resources.java | 19 +++- 7 files changed, 96 insertions(+), 228 deletions(-) diff --git a/gnpapp/properties/delta_RU_XXX_resources.properties b/gnpapp/properties/delta_RU_XXX_resources.properties index e147b4ba..bf26fd70 100644 --- a/gnpapp/properties/delta_RU_XXX_resources.properties +++ b/gnpapp/properties/delta_RU_XXX_resources.properties @@ -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 diff --git a/gnpdev/SFTPDaemon/properties/DELTA_RU_XXX_sfdp.properties b/gnpdev/SFTPDaemon/properties/DELTA_RU_XXX_sfdp.properties index 88c91617..84729262 100644 --- a/gnpdev/SFTPDaemon/properties/DELTA_RU_XXX_sfdp.properties +++ b/gnpdev/SFTPDaemon/properties/DELTA_RU_XXX_sfdp.properties @@ -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 ################### diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteCsNpg103DAO.java b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteCsNpg103DAO.java index 442c8b5a..a222ece5 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteCsNpg103DAO.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteCsNpg103DAO.java @@ -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"); - } } diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonor82DAO.java b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonor82DAO.java index b24e4903..9335ec33 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonor82DAO.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonor82DAO.java @@ -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(); - } - } - } diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonorDAO.java b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonorDAO.java index cefa6d1c..53945f9e 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonorDAO.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/dao/db/hb/GnpRichiesteDonorDAO.java @@ -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(); - } - } } diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/internalflow/in/Dwhe2eRepoSaldiNettiIn.java b/gnpdev/dbcfx/src/it/valueteam/gnp/internalflow/in/Dwhe2eRepoSaldiNettiIn.java index 8d758ff0..16e46684 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/internalflow/in/Dwhe2eRepoSaldiNettiIn.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/internalflow/in/Dwhe2eRepoSaldiNettiIn.java @@ -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 listFileName = getListFileName(Resources.getPATH_FILE_DWHE2E_REPOSALDINETTI_IN()); - readFilesAndStore(listFileName,resourceParam); + + //leggo i file da cartella CO + List 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 listFileName, String resourceParam) throws Exception { + private void readFilesAndStore(List 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 listForFile = new ArrayList(); 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,String resourceParam, String piattaforma){ + + private void aggiungiInfoAndSave(List 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); diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/utility/Resources.java b/gnpdev/dbcfx/src/it/valueteam/gnp/utility/Resources.java index 3ef1d51c..2bf37ecd 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/utility/Resources.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/utility/Resources.java @@ -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() {