diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/jms/QueueControllerFactory.java b/gnpdev/dbcfx/src/it/valueteam/gnp/jms/QueueControllerFactory.java index b41b5fcb..55dcd737 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/jms/QueueControllerFactory.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/jms/QueueControllerFactory.java @@ -31,7 +31,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER CRMR + //SYSTEM PROVIDER CRMR case NotificationMessageIF.SystemProvider_CRMR: switch (notification_type) { case NotificationMessageIF.NotificationType_CRMR_ATTIVAZIONE_IN: @@ -47,7 +47,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER DBSS + //SYSTEM PROVIDER DBSS case NotificationMessageIF.SystemProvider_DBSS: switch (notification_type) { case NotificationMessageIF.NotificationType_DBSS_ATTIVAZIONE_IN: @@ -56,11 +56,12 @@ public class QueueControllerFactory { return JNDINames.QUEUE_NAME_DBSS_IN; case NotificationMessageIF.NotificationType_DBSS_NOTIFICA_OUT: case NotificationMessageIF.NotificationType_DBSS_NOTIFICA_DONOR_OUT: + case NotificationMessageIF.NotificationType_DBSS_NOTIFICA_DONOR_OUT_82: return JNDINames.QUEUE_NAME_DBSS_OUT; default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER OLO + //SYSTEM PROVIDER OLO case NotificationMessageIF.SystemProvider_OLO: switch (notification_type) { case NotificationMessageIF.NotificationType_OLO_IN: @@ -70,7 +71,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type + " per SystemProvider_OLO"); } - //SYSTEM PROVIDER OLO_DONOR + //SYSTEM PROVIDER OLO_DONOR case NotificationMessageIF.SystemProvider_OLO_DONOR: switch (notification_type) { case NotificationMessageIF.NotificationType_OLO_FILE_DONOR_IN: @@ -84,7 +85,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type + " per SystemProvider_OLO"); } - //SYSTEM PROVIDER PITAGORA XDSL + //SYSTEM PROVIDER PITAGORA XDSL case NotificationMessageIF.SystemProvider_PITAGORA_XDSL: switch (notification_type) { case NotificationMessageIF.NotificationType_PITAGORA_XDSL_BATCH_IN: @@ -98,7 +99,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER SMS + //SYSTEM PROVIDER SMS case NotificationMessageIF.SystemProvider_SMS: switch (notification_type) { case NotificationMessageIF.NotificationType_SMS_NOTIFICA_OUT: @@ -106,7 +107,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER DBCFXGO + //SYSTEM PROVIDER DBCFXGO case NotificationMessageIF.SystemProvider_DBCFXGO: switch (notification_type) { case NotificationMessageIF.NotificationType_DBCFXGO_NOTIFICA_SEMAFORO_OUT: @@ -136,7 +137,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - // System Provider FENP + // System Provider FENP case NotificationMessageIF.SystemProvider_FENP: switch (notification_type) { case NotificationMessageIF.NotificationType_FENP_OUT: @@ -156,7 +157,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //System Provider DBC + //System Provider DBC case NotificationMessageIF.SystemProvider_DBC: switch (notification_type) { case NotificationMessageIF.NotificationType_DBC_NOTIFICA_ESP_HZ_NIP: @@ -181,7 +182,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER NOW + //SYSTEM PROVIDER NOW case NotificationMessageIF.SystemProvider_NOW: switch (notification_type) { case NotificationMessageIF.NotificationType_NOW_XDSL_BATCH_IN: @@ -202,7 +203,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //WSCRMWS + //WSCRMWS case NotificationMessageIF.SystemProvider_WSCRMWS: switch (notification_type) { case NotificationMessageIF.NotificationType_WS_WSCRMWS_DONOR_VERNUM_IN: @@ -212,7 +213,7 @@ public class QueueControllerFactory { default: throw new UnknownQueueSystemException("Notification Type sconosciuto: " + notification_type); } - //SYSTEM PROVIDER DOPPIO DONATING + //SYSTEM PROVIDER DOPPIO DONATING case NotificationMessageIF.SystemProvider_DOPPIO_DONATING: return JNDINames.QUEUE_NAME_DOPPIO_DONATING_IN; case NotificationMessageIF.SystemProvider_CRMA: diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/manager/RequestManagerDonor82.java b/gnpdev/dbcfx/src/it/valueteam/gnp/manager/RequestManagerDonor82.java index 0830ee17..0ec00ffe 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/manager/RequestManagerDonor82.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/manager/RequestManagerDonor82.java @@ -119,11 +119,11 @@ public class RequestManagerDonor82 { richiesteDonor.setDfw(DateUtils.aggiungi24OreLavorative(oloRichiesteDonorIn.getDataRicezione())); //Calcolata con DataRicezione + 17 giorni lavorativi richiesteDonor.setDataScadenza(DateUtils.aggiungiGiorniLavorativiTodateImpostaOra - (oloRichiesteDonorIn.getDataRicezione(), - ApplicationCostants.GIORNI_CALCOLO_DATA_SCADENZA, - ApplicationCostants.ORA_CALCOLO_DATA_SCADENZA, - ApplicationCostants.MINUTI_CALCOLO_DATA_SCADENZA, - ApplicationCostants.SECONDI_CALCOLO_DATA_SCADENZA) + (oloRichiesteDonorIn.getDataRicezione(), + ApplicationCostants.GIORNI_CALCOLO_DATA_SCADENZA, + ApplicationCostants.ORA_CALCOLO_DATA_SCADENZA, + ApplicationCostants.MINUTI_CALCOLO_DATA_SCADENZA, + ApplicationCostants.SECONDI_CALCOLO_DATA_SCADENZA) ); richiesteDonor.setCor(oloRichiesteDonorIn.getCor()); richiesteDonor.setCos(oloRichiesteDonorIn.getCos()); @@ -154,7 +154,7 @@ public class RequestManagerDonor82 { int statoDa = richiesta.getStato().intValue(); int check = StateManagerDonor.checkTransition(richiesta.getIdRichiesta(), StatoRichiestaDon.ACCETTATA); if (check != StateManagerDonor.TRANSIZIONE_NON_POSSIBILE) { - // CALCOLA DATA SCADENZA ALLA MEZZANOTTE DEL 16� GIORNO + // CALCOLA DATA SCADENZA ALLA MEZZANOTTE DEL 16-esimo GIORNO log.write("9999", "avanzaStatoInAccettata richiestaD82:" + richiesta.getIdRichiesta()); Date dataScadenza = DateUtils.aggiungiGiorniLavorativiTodateImpostaOra(new Date(), 16, 0, 0, 0); richiesta.setStato((long) StatoRichiestaDon.ACCETTATA); @@ -263,7 +263,7 @@ public class RequestManagerDonor82 { // DETERMINO LA PIATTAFORMA CRM DI COMPETENZA /* C06 RE: GATEWAY DBCFX :Studio per il tracciamento di eventi non correttamente gestiti dal sistema - * cambio implementazione del recupero della piattaforma di competenza, non si basa più sull'anagrafica (anagCowTelecom) + * cambio implementazione del recupero della piattaforma di competenza, non si basa piu' sull'anagrafica (anagCowTelecom) * ma tramite il localizzatore. Per maggiori dettagli vedi mail */ if (!callCheckRetailPlatform(richiesta, log)) { @@ -306,7 +306,7 @@ public class RequestManagerDonor82 { boolean ret = true; List richiesteDN = dao.getAltreRichiesteStessoCowDN(richiesta.getDn(), richiesta.getCowDonating()); - GnpRichiesteCsNpg103 richiesteCsNpg103s = npg103DAO.findByDn(richiesta.getDn()); //check su 103 è fattibile? TODO query + GnpRichiesteCsNpg103 richiesteCsNpg103s = npg103DAO.findByDn(richiesta.getDn()); //check su 103 e' fattibile? TODO query List richieste274 = dao.getAltreRichiesteStessoCowDN(richiesta.getDn(), richiesta.getCowDonating()); Boolean daRifiutare = false; @@ -325,7 +325,7 @@ public class RequestManagerDonor82 { if (richiesteCsNpg103s != null && (richiesteCsNpg103s.getStato() == 1 || richiesteCsNpg103s.getStato() == 2 || (richiesteCsNpg103s.getStato() == 3 && richiesteCsNpg103s.getProcesso().equalsIgnoreCase(ProcessMapper.proc_CS_NPg103)) - )) { + )) { avanzaStatoInRifiutata(richiesta, "Altro ordine in corso per tale utenza", ApplicationCostants.PROCESSO_DONOR.OLO_OUT.CAUSALE_RIFIUTO_GESTIONALE, false, log); return true; } @@ -349,12 +349,12 @@ public class RequestManagerDonor82 { richiesta.setStato((long) StatoRichiestaDon.PRESA_IN_CARICO); richiesta.setDataPresaincarico(new Date()); - + log.write("9999", "PRESA IN CARICO del DN :"+richiesta.getDn()+" IdRichiesta: "+richiesta.getIdRichiesta()+richiesta.getDataPresaincarico()); - + Boolean verificaWhiteList = new WhiteListManager().verificaCsWhiteListDonorDel274(richiesta.getDn(), richiesta.getCowDonating()); if (verificaWhiteList != null && verificaWhiteList) { - log.write("9999", "Risultato Verifica in WhiteList [TRUE]. Passaggio in ACCETTATA DN: "+richiesta.getDn()); + log.write("9999", "Risultato Verifica in WhiteList [TRUE]. Passaggio in ACCETTATA DN: "+richiesta.getDn()); avanzaStatoInAccettata(richiesta, log); } else if (verificaWhiteList != null && !verificaWhiteList) { @@ -369,18 +369,18 @@ public class RequestManagerDonor82 { } else { String crmCompetenza = richiesta.getCrmCompetenza(); - + boolean utenzaDbss = false; - + // X06 2016 - Integrazione con DBSS (nuovo sistema Retail) if (Resources.getDBSS_DONOR_ACTIVE()) { if(isUtenzaDBSS(crmCompetenza)){ - log.write("9999", "isUtenzaDBSS: "+crmCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); - callVerificaFase2DBSS(log,richiesta,dbssDonorOutRecDAO); - utenzaDbss=true; + log.write("9999", "isUtenzaDBSS: "+crmCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); + callVerificaFase2DBSS(log,richiesta,dbssDonorOutRecDAO); + utenzaDbss=true; } } - + UtilityDao utilityDao = new UtilityDao(); //PP X5.2010 - aggiunto controllo se multilinea @@ -420,106 +420,106 @@ public class RequestManagerDonor82 { throw new StateTransitionNotPossibleException("StateTransitionNotPossibleException"); } - - + + protected static boolean callCheckRetailPlatform(GnpRichiesteDonor82 richiestaDonor,ProcessLogger log) throws Exception { - log.write("9999", " START callCheckRetailPlatform : " +richiestaDonor.getIdRichiesta() + "DN: "+ richiestaDonor.getDn()); - String methSig = "[RequestManagerDonor82].[callCheckRetailPlatform] "; - boolean res=false; + log.write("9999", " START callCheckRetailPlatform : " +richiestaDonor.getIdRichiesta() + "DN: "+ richiestaDonor.getDn()); + String methSig = "[RequestManagerDonor82].[callCheckRetailPlatform] "; + boolean res=false; - CheckRetailPlatformRequest body = new CheckRetailPlatformRequest(); - body.setDN(richiestaDonor.getDn()); + CheckRetailPlatformRequest body = new CheckRetailPlatformRequest(); + body.setDN(richiestaDonor.getDn()); - RetrieveByLineNumberResponseMessage resp = checkDN(body,log); + RetrieveByLineNumberResponseMessage resp = checkDN(body,log); - res=gestisciResponseCheckRetail(methSig,resp,log,richiestaDonor); + res=gestisciResponseCheckRetail(methSig,resp,log,richiestaDonor); - log.write("9999", " END callCheckRetailPlatform : " +richiestaDonor.getIdRichiesta() + "DN: "+ richiestaDonor.getDn()+ "con esito: "+res); + log.write("9999", " END callCheckRetailPlatform : " +richiestaDonor.getIdRichiesta() + "DN: "+ richiestaDonor.getDn()+ "con esito: "+res); - return res; + return res; } - + private static boolean gestisciResponseCheckRetail(String methSig,RetrieveByLineNumberResponseMessage resp,ProcessLogger log,GnpRichiesteDonor82 richiestaDon) throws Exception { - //return code puo' essere a una cifra o due (es. 01 o 1) - int retCode = new Integer(resp.getProcessData().getReturnCode()); - log.write("9999", " return code ricevuto da ws: " + retCode); - - boolean foundByWs = false; - String crmComp = ""; + //return code puo' essere a una cifra o due (es. 01 o 1) + int retCode = new Integer(resp.getProcessData().getReturnCode()); + log.write("9999", " return code ricevuto da ws: " + retCode); - switch (retCode) { - //0 - case (RET_CODE_OK_FROM_WS): - //itera sui (tre) parameter, se ne trova uno con valore == 'Y' ne restituisce il name, altrimentii restituisce codice di errore - Parameter[] params = resp.getProcessData().getParameters().getParameter(); - for (Parameter p : params) { - if (!("Y").equalsIgnoreCase(p.getValue())) { - continue; //se diverso da Y passa al successivo - } - - log.write("9999", methSig + " - trovato el. con val. = Y e name " + p.getName()); - - if (SystemControllerIF.SystemProvider_CRMB_DESC.equals(p.getName())) { - crmComp = "B"; - foundByWs = true; - } else if (SystemControllerIF.SystemProvider_CRMR_DESC.equals(p.getName())) { - // DISMISSIONE CRMR: nel caso la richiesta risulti proveniente da CRMR viene settato a D invece di R - crmComp = "D"; - foundByWs = true; - } else if (SystemControllerIF.SystemProvider_DBSS_DESC.equals(p.getName())) { - crmComp = "D"; - foundByWs = true; - } else { - log.write("9999", methSig + " valore non previsto"); - log.write("0002", methSig + " ws response return code: " + retCode); - log.write("9999", methSig +" non avanza stato in rifiutato : " + retCode); - log.write("9999", methSig +" PER RICHIESTA DI INGLISA VIENE SETTATO IL CRM DI COMPETENZA A B"); - - //MODIFICA INGLISA NEL CASO IN CUI NON TROVO IL CRM CONTATTO B - //RequestManagerDonor.avanzaStatoInRifiutata(richiestaDon, "COW COR Errato", ApplicationCostants.PROCESSO_DONOR.OLO_OUT.COD_MOTIVO_COW_COR_ERRATO,true, log); - - crmComp = "B"; - foundByWs = true; - } - } - break; - case (RET_CODE_UTENZA_NON_PRESENTE_FROM_WS): - log.write("9999", methSig + " ws response return code [" + retCode + "] corrispondente a LINEA NON PRESENTE SU WS"+ - "ANCHE SE DBSS RESTITUISCE UTENZA NON PRESENTE,PER RICHIESTA DI INGLISA VIENE SETTATO IL CRM DI COMPETENZA A B"); - - crmComp = "B"; - foundByWs = true; - - //RequestManagerDonor.avanzaStatoInRifiutata(richiestaDon, "COW COR Errato", ApplicationCostants.PROCESSO_DONOR.OLO_OUT.COD_MOTIVO_COW_COR_ERRATO,true, log); - - break; - case (RET_CODE_SERV_CRMB_NON_DISPONIBILE): - case (RET_CODE_SERV_CRMR_NON_DISPONIBILE): - case (RET_CODE_ERRORE_GENERICO_WS): - log.write("0002", methSig + " ws response return code: " + retCode+ "corrispondente a un errore interno di CCC scrivo solo nella SCARTI CS"); - buildScartiVerificaCs(richiestaDon,ANOMALIA_ERRORE_CODICE_SERVIZIO_CCC,ANOMALIA_ERRORE_CODICE_SERVIZIO_CCC_DESCRIZIONE+retCode,log); - break; - default: - log.write("9999", methSig + " ws response return code [" + retCode + "] non previsto da interfaccia"); - log.write("0002", methSig + " ws response return code: " + retCode+ "corrispondente a un errore interno di CCC"); - buildScartiVerificaCs(richiestaDon,ANOMALIA_ERRORE_CODICE_SERVIZIO_NON_PREVISTO_CCC,ANOMALIA_ERRORE_CODICE_SERVIZIO_NON_PREVISTO_CCC_DESCRIZIONE+retCode,log); - } + boolean foundByWs = false; + String crmComp = ""; - if (foundByWs) { - log.write("9999", methSig + " crm recuperato da DBSS e settato nella richiesta : " + crmComp); - richiestaDon.setCrmCompetenza(crmComp); - } + switch (retCode) { + //0 + case (RET_CODE_OK_FROM_WS): + //itera sui (tre) parameter, se ne trova uno con valore == 'Y' ne restituisce il name, altrimentii restituisce codice di errore + Parameter[] params = resp.getProcessData().getParameters().getParameter(); + for (Parameter p : params) { + if (!("Y").equalsIgnoreCase(p.getValue())) { + continue; //se diverso da Y passa al successivo + } - return foundByWs; + log.write("9999", methSig + " - trovato el. con val. = Y e name " + p.getName()); + + if (SystemControllerIF.SystemProvider_CRMB_DESC.equals(p.getName())) { + crmComp = "B"; + foundByWs = true; + } else if (SystemControllerIF.SystemProvider_CRMR_DESC.equals(p.getName())) { + // DISMISSIONE CRMR: nel caso la richiesta risulti proveniente da CRMR viene settato a D invece di R + crmComp = "D"; + foundByWs = true; + } else if (SystemControllerIF.SystemProvider_DBSS_DESC.equals(p.getName())) { + crmComp = "D"; + foundByWs = true; + } else { + log.write("9999", methSig + " valore non previsto"); + log.write("0002", methSig + " ws response return code: " + retCode); + log.write("9999", methSig +" non avanza stato in rifiutato : " + retCode); + log.write("9999", methSig +" PER RICHIESTA DI INGLISA VIENE SETTATO IL CRM DI COMPETENZA A B"); + + //MODIFICA INGLISA NEL CASO IN CUI NON TROVO IL CRM CONTATTO B + //RequestManagerDonor.avanzaStatoInRifiutata(richiestaDon, "COW COR Errato", ApplicationCostants.PROCESSO_DONOR.OLO_OUT.COD_MOTIVO_COW_COR_ERRATO,true, log); + + crmComp = "B"; + foundByWs = true; + } + } + break; + case (RET_CODE_UTENZA_NON_PRESENTE_FROM_WS): + log.write("9999", methSig + " ws response return code [" + retCode + "] corrispondente a LINEA NON PRESENTE SU WS"+ + "ANCHE SE DBSS RESTITUISCE UTENZA NON PRESENTE,PER RICHIESTA DI INGLISA VIENE SETTATO IL CRM DI COMPETENZA A B"); + + crmComp = "B"; + foundByWs = true; + + //RequestManagerDonor.avanzaStatoInRifiutata(richiestaDon, "COW COR Errato", ApplicationCostants.PROCESSO_DONOR.OLO_OUT.COD_MOTIVO_COW_COR_ERRATO,true, log); + + break; + case (RET_CODE_SERV_CRMB_NON_DISPONIBILE): + case (RET_CODE_SERV_CRMR_NON_DISPONIBILE): + case (RET_CODE_ERRORE_GENERICO_WS): + log.write("0002", methSig + " ws response return code: " + retCode+ "corrispondente a un errore interno di CCC scrivo solo nella SCARTI CS"); + buildScartiVerificaCs(richiestaDon,ANOMALIA_ERRORE_CODICE_SERVIZIO_CCC,ANOMALIA_ERRORE_CODICE_SERVIZIO_CCC_DESCRIZIONE+retCode,log); + break; + default: + log.write("9999", methSig + " ws response return code [" + retCode + "] non previsto da interfaccia"); + log.write("0002", methSig + " ws response return code: " + retCode+ "corrispondente a un errore interno di CCC"); + buildScartiVerificaCs(richiestaDon,ANOMALIA_ERRORE_CODICE_SERVIZIO_NON_PREVISTO_CCC,ANOMALIA_ERRORE_CODICE_SERVIZIO_NON_PREVISTO_CCC_DESCRIZIONE+retCode,log); + } + + if (foundByWs) { + log.write("9999", methSig + " crm recuperato da DBSS e settato nella richiesta : " + crmComp); + richiestaDon.setCrmCompetenza(crmComp); + } + + return foundByWs; } - + private static void buildScartiVerificaCs(GnpRichiesteDonor82 richiestaDon,String tipoAnomalia,String descrizioneAnomalia,ProcessLogger log) { - log.write("9999","START buildScartiVerificaCs DN: " + richiestaDon.getDn()+"Idrichiesta: "+richiestaDon.getIdRichiesta()); - - GnpScartiVerificaCsDAO scartiVerificaCsDao=new GnpScartiVerificaCsDAO(); + log.write("9999","START buildScartiVerificaCs DN: " + richiestaDon.getDn()+"Idrichiesta: "+richiestaDon.getIdRichiesta()); + + GnpScartiVerificaCsDAO scartiVerificaCsDao=new GnpScartiVerificaCsDAO(); GnpScartiVerificaCs scartiVerificaCs=new GnpScartiVerificaCs(); - + scartiVerificaCs.setIdRichiesta(richiestaDon.getIdRichiesta()); scartiVerificaCs.setDn(richiestaDon.getDn()); scartiVerificaCs.setTipoAnomalia(tipoAnomalia); @@ -527,18 +527,18 @@ public class RequestManagerDonor82 { scartiVerificaCs.setCodiceSegreto(richiestaDon.getCowDonating()); scartiVerificaCs.setDataInserimento(new Date()); - + scartiVerificaCsDao.merge(scartiVerificaCs); - + log.write("9999","END buildScartiVerificaCs DN: " + richiestaDon.getDn()+"Idrichiesta: "+richiestaDon.getIdRichiesta()); } - + /** * @version 4.1 20180417 migliorati i log */ public static RetrieveByLineNumberResponseMessage checkDN(CheckRetailPlatformRequest body,ProcessLogger log) throws Exception { - String requestDn = body.getDN(); + String requestDn = body.getDN(); log.write("9999", "NowController RetrieveByLineNumberResponseMessage - Ricevuta richiesta DN ["+requestDn+"]"); CustomerLocationQueryClient client = new CustomerLocationQueryClient(); RetrieveByLineNumberRequestMessage requestMessage = new RetrieveByLineNumberRequestMessage(); @@ -576,16 +576,16 @@ public class RequestManagerDonor82 { String descr = retrieveByLineNumberResponseMessage != null && retrieveByLineNumberResponseMessage.getProcessData() != null ? retrieveByLineNumberResponseMessage.getProcessData().getReturnDescription() : null; log.write("9999", "NowController RetrieveByLineNumberResponseMessage Ottenuta risposta DN ["+requestDn+"] descrizione ["+descr+"]"); - + return retrieveByLineNumberResponseMessage; } - - + + /** * Passaggio di stato in PRESAINCARICO. *

- * Ritorna false se il COW Donating non � mappato su uno di quelli Telecom + * Ritorna false se il COW Donating non e' mappato su uno di quelli Telecom * * @param richiesta * @param log @@ -593,154 +593,126 @@ public class RequestManagerDonor82 { * @throws Exception */ public static boolean avanzaStatoInPresaInCaricoTool(GnpRichiesteDonor82 richiesta,String piattaformaCompetenza, ProcessLogger log) - throws Exception { - GnpRichiesteDonor82DAO dao = new GnpRichiesteDonor82DAO(); - GnpCrmNotifyDonorOutDAO dbssDonorOutRecDAO = new GnpCrmNotifyDonorOutDAO(); - boolean ret = true; - //richiesta.setStato(new Long(StatoRichiestaDon.ACQUISITA)); - //int check = StateManagerDonor.checkTransition(richiesta.getIdRichiesta(), StatoRichiestaDon.PRESA_IN_CARICO); - - int check=1; - - if (check != StateManagerDonor.TRANSIZIONE_NON_POSSIBILE) { - int statoDa = richiesta.getStato().intValue(); - richiesta.setStato((long) StatoRichiestaDon.PRESA_IN_CARICO); - - /* - * - * Penso che la presa in carico sia più corretta considerare la prima data e non questa - * quindi non sovrascrivere la precedente - */ - //richiesta.setDataPresaincarico(new java.util.Date()); + throws Exception { + GnpRichiesteDonor82DAO dao = new GnpRichiesteDonor82DAO(); + GnpCrmNotifyDonorOutDAO dbssDonorOutRecDAO = new GnpCrmNotifyDonorOutDAO(); + boolean ret = true; + //richiesta.setStato(new Long(StatoRichiestaDon.ACQUISITA)); + //int check = StateManagerDonor.checkTransition(richiesta.getIdRichiesta(), StatoRichiestaDon.PRESA_IN_CARICO); - log.write("9999", "Verifica cs whitelist null"); - // Ricerco nell'anagrafica il cow Donating ricevuto + int check=1; + + if (check != StateManagerDonor.TRANSIZIONE_NON_POSSIBILE) { + int statoDa = richiesta.getStato().intValue(); + richiesta.setStato((long) StatoRichiestaDon.PRESA_IN_CARICO); + + /* + * + * Penso che la presa in carico sia piu' corretta considerare la prima data e non questa + * quindi non sovrascrivere la precedente + */ + //richiesta.setDataPresaincarico(new java.util.Date()); + + log.write("9999", "Verifica cs whitelist null"); + // Ricerco nell'anagrafica il cow Donating ricevuto GnpAnagCowLineaTelecom anagCowLineaTelecom=null; GnpAnagCowLineaTelecomDAO cowLineaDao; - GnpAnagCowTelecomDAO anagCowDAO = new GnpAnagCowTelecomDAO(); - GnpAnagCowTelecom anagCowTelecom = anagCowDAO.findById(richiesta.getCowDonating()); - - //C09 2019 WA RICHIESTO ESCLUSIVAMENTE PER LA VERIFICA CS + GnpAnagCowTelecomDAO anagCowDAO = new GnpAnagCowTelecomDAO(); + GnpAnagCowTelecom anagCowTelecom = anagCowDAO.findById(richiesta.getCowDonating()); + + //C09 2019 WA RICHIESTO ESCLUSIVAMENTE PER LA VERIFICA CS if(Resources.getFLAG_CHECK_ANAG_COW_LINEA()) { - log.write("9999", "CONTROLLO SU TABELLA GNP_ANAG_COW_LINEA_TELECOM(FLAG WA ABILITATO) : "+richiesta.getIdRichiesta()+" COW: "+richiesta.getCowDonating()+" DN:"+richiesta.getDn()); + log.write("9999", "CONTROLLO SU TABELLA GNP_ANAG_COW_LINEA_TELECOM(FLAG WA ABILITATO) : "+richiesta.getIdRichiesta()+" COW: "+richiesta.getCowDonating()+" DN:"+richiesta.getDn()); cowLineaDao = new GnpAnagCowLineaTelecomDAO(); anagCowLineaTelecom = cowLineaDao.findByDnAndCowOld(richiesta.getDn(),richiesta.getCowDonating()); } - + //C09 2019 WA RICHIESTO ESCLUSIVAMENTE PER LA VERIFICA CS SE E' UGUALE A NULL IL PROCESSO RESTA INVARIATO if(anagCowLineaTelecom!=null) { - log.write("9999", "TROVATA LINEA SU TABELLA GNP_ANAG_COW_LINEA_TELECOM(FLAG WA ABILITATO) : "+richiesta.getIdRichiesta()+" COW VECCHIO: "+richiesta.getCowDonating()+ - " COW NUOVO:"+anagCowLineaTelecom.getCowNew()+" DN:"+richiesta.getDn()); - anagCowTelecom=new GnpAnagCowTelecom(); - anagCowTelecom.setCow(anagCowLineaTelecom.getCowNew()); - richiesta.setCowDonating(anagCowLineaTelecom.getCowNew()); + log.write("9999", "TROVATA LINEA SU TABELLA GNP_ANAG_COW_LINEA_TELECOM(FLAG WA ABILITATO) : "+richiesta.getIdRichiesta()+" COW VECCHIO: "+richiesta.getCowDonating()+ + " COW NUOVO:"+anagCowLineaTelecom.getCowNew()+" DN:"+richiesta.getDn()); + anagCowTelecom=new GnpAnagCowTelecom(); + anagCowTelecom.setCow(anagCowLineaTelecom.getCowNew()); + richiesta.setCowDonating(anagCowLineaTelecom.getCowNew()); // salvo la richiesta con stato acquisita - dao.save(richiesta); + dao.save(richiesta); } - // Se non trovo il cow nell'anagrafica: - // 1)Aggiorno la tabella GNP_RICHIESTE_DONOR con cod_validazione = 1 - // 2)Inserisco un record nella tabella GNP_OLO_RICHIESTE_DONOR_OUT - if (anagCowTelecom == null) { - ret = false; - } else { - log.write("9999", "Piattaforma notificata da BO : "+piattaformaCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); - //Setto la piattaforma di competenza con quello del campo settato dal BO - String crmCompetenza=piattaformaCompetenza; - richiesta.setCrmCompetenza(crmCompetenza); - - boolean utenzaDbss = false; - - if(isUtenzaDBSS(piattaformaCompetenza)){ - log.write("9999", "isUtenzaDBSS: "+piattaformaCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); - if (Resources.getDBSS_DONOR_ACTIVE()) { - callVerificaFase2DBSS(log,richiesta,dbssDonorOutRecDAO); - utenzaDbss=true; - } - } - // X06 2016 - Integrazione con DBSS (nuovo sistema Retail) - - UtilityDao utilityDao = new UtilityDao(); + // Se non trovo il cow nell'anagrafica: + // 1)Aggiorno la tabella GNP_RICHIESTE_DONOR con cod_validazione = 1 + // 2)Inserisco un record nella tabella GNP_OLO_RICHIESTE_DONOR_OUT + if (anagCowTelecom == null) { + ret = false; + } else { + log.write("9999", "Piattaforma notificata da BO : "+piattaformaCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); + //Setto la piattaforma di competenza con quello del campo settato dal BO + String crmCompetenza=piattaformaCompetenza; + richiesta.setCrmCompetenza(crmCompetenza); - //PP X5.2010 - aggiunto controllo se multilinea - if (utilityDao.isDnMultilinea(richiesta.getDn()) && crmCompetenza.equalsIgnoreCase("B") && !utenzaDbss) { - log.write("9999", "DN BUSINESS MULTILINEA: DBCFX SIMULA LA NOTIFICA OK DA CRM"); + boolean utenzaDbss = false; - //-- PASSAGGIO FORZATO IN PRESA IN CARICO ------------------- - dao.merge(richiesta); + if(isUtenzaDBSS(piattaformaCompetenza)){ + log.write("9999", "isUtenzaDBSS: "+piattaformaCompetenza+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); + if (Resources.getDBSS_DONOR_ACTIVE()) { + callVerificaFase2DBSS(log,richiesta,dbssDonorOutRecDAO); + utenzaDbss=true; + } + } + // X06 2016 - Integrazione con DBSS (nuovo sistema Retail) - logStoricoPassaggioStato(richiesta.getIdRichiesta(), statoDa, StatoRichiestaDon.PRESA_IN_CARICO, log); - //----------------------------------------------------------- + UtilityDao utilityDao = new UtilityDao(); + + //PP X5.2010 - aggiunto controllo se multilinea + if (utilityDao.isDnMultilinea(richiesta.getDn()) && crmCompetenza.equalsIgnoreCase("B") && !utenzaDbss) { + log.write("9999", "DN BUSINESS MULTILINEA: DBCFX SIMULA LA NOTIFICA OK DA CRM"); + + //-- PASSAGGIO FORZATO IN PRESA IN CARICO ------------------- + dao.merge(richiesta); + + logStoricoPassaggioStato(richiesta.getIdRichiesta(), statoDa, StatoRichiestaDon.PRESA_IN_CARICO, log); + //----------------------------------------------------------- - //-- PASSAGGIO FORZATO IN ATTESA VERIFICA ------------------- - RequestManagerDonor82.avanzaStatoInAttesaVerifica(richiesta.getCodiceSessione(), log); - //----------------------------------------------------------- + //-- PASSAGGIO FORZATO IN ATTESA VERIFICA ------------------- + RequestManagerDonor82.avanzaStatoInAttesaVerifica(richiesta.getCodiceSessione(), log); + //----------------------------------------------------------- - //-- PASSAGGIO FORZATO IN ACCETTATA ------------------------- - RequestManagerDonor82.avanzaStatoInAccettata(richiesta, log); - //----------------------------------------------------------- - } else if (!utenzaDbss) { - log.write("9999", "DN NON MULTILINEA"); + //-- PASSAGGIO FORZATO IN ACCETTATA ------------------------- + RequestManagerDonor82.avanzaStatoInAccettata(richiesta, log); + //----------------------------------------------------------- + } else if (!utenzaDbss) { + log.write("9999", "DN NON MULTILINEA"); - //-- PASSAGGIO IN PRESA IN CARICO e INVIO NOTIFICA A CRM --- - SistemaCrmIF crmController = ControllerFactory.getSistemaCRMDonor(crmCompetenza); - crmController.notificaCRMDonor(richiesta.getIdRichiesta()); + //-- PASSAGGIO IN PRESA IN CARICO e INVIO NOTIFICA A CRM --- + SistemaCrmIF crmController = ControllerFactory.getSistemaCRMDonor(crmCompetenza); + crmController.notificaCRMDonor(richiesta.getIdRichiesta()); - dao.merge(richiesta); + dao.merge(richiesta); - logStoricoPassaggioStato(richiesta.getIdRichiesta(), statoDa, StatoRichiestaDon.PRESA_IN_CARICO, log); - //----------------------------------------------------------- - } - } - return ret; - } else - throw new StateTransitionNotPossibleException("StateTransitionNotPossibleException"); + logStoricoPassaggioStato(richiesta.getIdRichiesta(), statoDa, StatoRichiestaDon.PRESA_IN_CARICO, log); + //----------------------------------------------------------- + } + } + return ret; + } else + throw new StateTransitionNotPossibleException("StateTransitionNotPossibleException"); } - - private static void callVerificaFase2DBSS(ProcessLogger log, GnpRichiesteDonor82 richiesta, GnpCrmNotifyDonorOutDAO dbssDonorOutRecDAO) throws Exception { - log.write("9999", "START Chiamata al WS WirelineLineCodeQuery DBSS DN:["+richiesta.getDn()+"]"); - // chiamata al WS WirelineLineCodeQuery - DBSSController dbssController = DBSSController.getInstance(); - GnpCrmNotifyDonorOut dbssDonorOut = dbssController.creaRichiestaVerificaFase2(richiesta); - WirelineCeaseCheck82ResponseType dbssResponse = dbssController.callNotificaDbssD82(dbssDonorOut); - String esito = null; - if (dbssResponse != null) { - esito = dbssResponse.getProcessData().getReturnDescription(); - dbssDonorOutRecDAO.save(dbssDonorOut); - log.write("9999", "Esito sincrono chiamata: " + esito); - }else { - log.write("9999", "Risposta vuota non gestita: "+richiesta.getCrmCompetenza()+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); - buildScartiVerificaCs(richiesta,VERIFICA_CS_DBSS_ESITO_NON_GESTITO,VERIFICA_CS_DBSS_ESITO_NON_GESTITO_DESCRIZIONE,log); - } - - log.write("9999", "END Chiamata al WS WirelineLineCodeQuery DBSS DN:["+richiesta.getDn()+"]"); + private static void callVerificaFase2DBSS(ProcessLogger log, GnpRichiesteDonor82 richiesta, GnpCrmNotifyDonorOutDAO dbssDonorOutRecDAO) throws Exception { + DBSSController dbssController = DBSSController.getInstance(); + GnpCrmNotifyDonorOut dbssDonorOut = dbssController.creaRichiestaVerificaFase2(richiesta); + dbssController.invioNotificaD82(dbssDonorOut); } public static void callNotificaFase3DBSS(ProcessLogger log, GnpRichiesteDonor82 richiesta, GnpCrmNotifyDonorOutDAO dbssDonorOutRecDAO, GnpNowD82RichiesteOut nowDonorOut) throws Exception { - log.write("9999", "START Chiamata al WS WirelineLineCodeQuery DBSS DN:["+richiesta.getDn()+"]"); - // chiamata al WS WirelineLineCodeQuery DBSSController dbssController = DBSSController.getInstance(); GnpCrmNotifyDonorOut dbssDonorOut = dbssController.creaNotificaEsitoN9(richiesta, nowDonorOut); - WirelineCeaseCheck82ResponseType dbssResponse = dbssController.callNotificaDbssD82(dbssDonorOut); - - String esito = null; - if (dbssResponse != null) { - esito = dbssResponse.getProcessData().getReturnDescription(); - dbssDonorOutRecDAO.save(dbssDonorOut); - log.write("9999", "Esito sincrono chiamata: " + esito); - }else { - log.write("9999", "Risposta vuota non gestita: "+richiesta.getCrmCompetenza()+" DN:"+richiesta.getDn()+" Id-Richiesta: "+richiesta.getIdRichiesta()); - //buildScartiVerificaCs(richiesta,VERIFICA_CS_DBSS_ESITO_NON_GESTITO,VERIFICA_CS_DBSS_ESITO_NON_GESTITO_DESCRIZIONE,log); - } - - log.write("9999", "END Chiamata al WS WirelineLineCodeQuery DBSS DN:["+richiesta.getDn()+"]"); + dbssController.invioNotificaD82(dbssDonorOut); } - + private static boolean isUtenzaDBSS(String piattaforma) { - return "D".equalsIgnoreCase(piattaforma); + return "D".equalsIgnoreCase(piattaforma); } public static void avanzaStatoInPresaInCaricoKO(GnpRichiesteDonor82 richiesta, ProcessLogger log) @@ -797,4 +769,3 @@ public class RequestManagerDonor82 { } } - diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/obj/jms/NotificationMessageIF.java b/gnpdev/dbcfx/src/it/valueteam/gnp/obj/jms/NotificationMessageIF.java index e5161c1d..44997b7f 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/obj/jms/NotificationMessageIF.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/obj/jms/NotificationMessageIF.java @@ -16,7 +16,7 @@ public interface NotificationMessageIF { public static final int SystemProvider_OLO = SystemControllerIF.SystemProvider_OLO; public static final int NotificationType_OLO_IN = 1; public static final int NotificationType_OLO_OUT = 2; - + // public static final int SystemProvider_CRMR = SystemControllerIF.SystemProvider_CRMR; public static final int NotificationType_CRMR_ATTIVAZIONE_IN = 3; @@ -29,7 +29,7 @@ public interface NotificationMessageIF { public static final int SystemProvider_CRMB = SystemControllerIF.SystemProvider_CRMB; public static final int NotificationType_CRMB_ATTIVAZIONE_IN = 1; public static final int NotificationType_CRMB_NOTIFICA_OUT = 2; - public static final int NotificationType_CRMB_VERIFICA_CS= 10; + public static final int NotificationType_CRMB_VERIFICA_CS= 10; public static final int NotificationType_CRMB_ESITO_VERIFICA_CS= 13; public static final int NotificationType_CRMB_DONOR_OUT = 14; // 152248 (227248) @@ -48,16 +48,16 @@ public interface NotificationMessageIF { public static final int NotificationType_PITAGORA_FILE_OUT = 3; public static final int NotificationType_PITAGORA_BAD_IN = 4; public static final int NotificationType_PITAGORA_FTP_IN_XML = 5; - + public static final int SystemProvider_PITAGORA_XDSL = SystemControllerIF.SystemProvider_PITAGORA_XDSL; public static final int NotificationType_PITAGORA_XDSL_FTP_IN = 1; public static final int NotificationType_PITAGORA_XDSL_BATCH_IN = 2; public static final int NotificationType_PITAGORA_XDSL_FILE_OUT = 3; public static final int NotificationType_PITAGORA_XDSL_BAD_IN = 4; - + public static final int SystemProvider_SMS = SystemControllerIF.SystemProvider_SMS; public static final int NotificationType_SMS_NOTIFICA_OUT = 1; - + public static final int SystemProvider_DBCFXGO = SystemControllerIF.SystemProvider_DBCFXGO; public static final int NotificationType_DBCFXGO_NOTIFICA_SEMAFORO_OUT = 1; public static final int NotificationType_DBCFXGO_NOTIFICA_STATO_OUT = 2; @@ -83,24 +83,24 @@ public interface NotificationMessageIF { public static final int NotificationType_WS_WSCRMWS_DONOR_VERNUM_IN = 5; public static final int NotificationType_WS_WSCRMWS_DONOR_VERNUM_OUT = 6; - + public static final int SystemProvider_DOPPIO_DONATING = SystemControllerIF.SystemProvider_DOPPIO_DONATING; public static final int NotificationType_DOPPIO_DONATING_IN = 1; public static final int NotificationType_DOPPIO_DONATING_OUT = 2; - + public static final int SystemProvider_OLO_DONOR = SystemControllerIF.SystemProvider_OLO_DONOR; public static final int NotificationType_OLO_FILE_DONOR_IN = 3; public static final int NotificationType_OLO_RICHIESTE_DONOR_IN= 4; public static final int NotificationType_OLO_FILE_DONOR_OUT= 5; public static final int NotificationType_OLO_RICHIESTE_D82_IN = 6; - + public static final int SystemProvider_FENP = SystemControllerIF.SystemProvider_FENP; public static final int SystemProvider_FENP_NNG = SystemControllerIF.SystemProvider_FENP_NNG; public static final int NotificationType_FENP_OUT= 1; public static final int NotificationType_FENP_IN= 2; public static final int NotificationType_NNG_FENP_OUT= 3; public static final int NotificationType_NNG_FENP_IN= 4; - + //public static final int SystemProvider_PPS = SystemControllerIF.SystemProvider_PPS; public static final int SystemProvider_DBSS = SystemControllerIF.SystemProvider_DBSS; @@ -108,6 +108,7 @@ public interface NotificationMessageIF { public static final int NotificationType_DBSS_NOTIFICA_OUT = 94; public static final int NotificationType_DBSS_VERIFICA_CS= 98; public static final int NotificationType_DBSS_NOTIFICA_DONOR_OUT = 95; + public static final int NotificationType_DBSS_NOTIFICA_DONOR_OUT_82 = 97; // 152248 public static final int NotificationType_DBSS_ESITO_VERIFICA_CS = 99; public static final int NotificationType_DBSS_ESPLETAMENTO_DONATING = 96; diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSController.java b/gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSController.java index 90c5a64e..54a5eedd 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSController.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSController.java @@ -172,6 +172,10 @@ public class DBSSController extends SystemController { inviaNotificaDbssDonorOut(messaggio); break; + case NotificationMessageIF.NotificationType_DBSS_NOTIFICA_DONOR_OUT_82: + notificaceaseWirelineCheck82(messaggio); + break; + case NotificationMessageIF.NotificationType_DBSS_ESPLETAMENTO_DONATING: processaEspletamentoDonating(messaggio); break; @@ -344,7 +348,7 @@ public class DBSSController extends SystemController { GnpDbssSoapHeaderIn headerIn = null; if (dbssOutRec.getTipoEvento().equalsIgnoreCase(DBSSMap.EVENTO_CESSAZIONE)) { - log.write("9999", "NON INVIO Notifica DBSS TIPO_EVENTO CESSAZIONE [" + dbssOutRec.getTipoEvento() + "] " + dbssOutRec.getIdEsigenza()); + log.write("9999", "NON INVIO Notifica DBSS TIPO_EVENTO CESSAZIONE [" + dbssOutRec.getTipoEvento() + "] " + dbssOutRec.getIdEsigenza()); /*log.write("9999", "Invio Notifica DBSS TIPO_EVENTO CESSAZIONE [" + dbssOutRec.getTipoEvento() + "] " + dbssOutRec.getIdEsigenza()); // La cessazione NATIVI OLO, processo CESS_OLO35 deve notificare tramite portOutResult @@ -395,6 +399,50 @@ public class DBSSController extends SystemController { } } + public void invioNotificaD82(GnpCrmNotifyDonorOut notifica) throws Exception { + log.write("9999", "invioNotifica - codice richiesta: " + notifica.getCodiceRichiesta() + " - tipo evento: " + notifica.getTipoEvento() + " - unique id: " + notifica.getUniqueId()); + NotificationMessage message = creaNotificaDonorOut82(notifica.getUniqueId()); + inserisciNotificaInCoda(message); + } + + public void notificaceaseWirelineCheck82(NotificationMessage message) throws Exception { + + GnpCrmNotifyDonorOutDAO dao = new GnpCrmNotifyDonorOutDAO(); + GnpCrmNotifyDonorOut dbssDonorOut = dao.findById(((UniqueIdNotificationMessage)message).getUnique_id()); + + int daScodare = -1; + daScodare = dbssDonorOut.getDaScodare().intValue(); + + switch (daScodare) { + case 0: + //se non ci sono record da aggiornare il messaggio e' gia' stato scodato + //e dunque viene solamente loggato l'id_richiesta + log.write("9999", "RICHIESTA GIA' SCODATA :[" + Func.getFieldDescription(dbssDonorOut) + "]"); + break; + + case 1: + log.write("9999", "START Chiamata al WS WirelineCeaseCheck82 DBSS DN:["+dbssDonorOut.getDirectoryNumber()+"]"); + + WirelineCeaseCheck82ResponseType dbssResponse = callNotificaDbssD82(dbssDonorOut); + + String esito = null; + if (dbssResponse != null) { + esito = dbssResponse.getProcessData().getReturnDescription(); + dbssDonorOut.setDaScodare(0L); + dbssNotifyDonorOutDAO.merge(dbssDonorOut); + log.write("9999", "Esito sincrono chiamata: " + esito); + }else { + log.write("9999", "Risposta vuota non gestita: "+dbssDonorOut.getSistComp()+" DN:"+dbssDonorOut.getDirectoryNumber()+" Id-Richiesta: "+dbssDonorOut.getCodiceRichiesta()); + } + + log.write("9999", "END Chiamata al WS WirelineCeaseCheck82 DBSS DN:["+dbssDonorOut.getDirectoryNumber()+"]"); + + break; + } + + + } + private void invioNotifica(GnpCrmNotifyDonorOut notifica) throws Exception { log.write("9999", "invioNotifica - codice richiesta: " + notifica.getCodiceRichiesta() + " - tipo evento: " + notifica.getTipoEvento() + " - unique id: " + notifica.getUniqueId()); // INIZIO: Recupero richiesta @@ -1462,6 +1510,14 @@ public class DBSSController extends SystemController { return messaggio; } + public NotificationMessage creaNotificaDonorOut82(Long uniqueId) { + UniqueIdNotificationMessage messaggio = new UniqueIdNotificationMessage(); + messaggio.setUnique_id(uniqueId); + messaggio.setNotificationType(NotificationMessageIF.NotificationType_DBSS_NOTIFICA_DONOR_OUT_82); + messaggio.setSystemProvider(NotificationMessageIF.SystemProvider_DBSS); + return messaggio; + } + //Modifica firma per C07 OLO in correction 14 maggio 2019 public void notificaDbss(Date dateRichiesta, GnpRichiesteOlo103mn richiesta, int codiceNotifica, String DN) throws Exception { log.write("9999", "DbssController.notificaDbss(GnpRichiesteOlo35Mn richiesta, int codiceNotifica) INIZIO"); diff --git a/gnpdev/dbcfx/src/it/valueteam/gnp/ws/dbss/client/WirelinePortOutOrderMgmtClient.java b/gnpdev/dbcfx/src/it/valueteam/gnp/ws/dbss/client/WirelinePortOutOrderMgmtClient.java index d61bbf49..8e24ae62 100644 --- a/gnpdev/dbcfx/src/it/valueteam/gnp/ws/dbss/client/WirelinePortOutOrderMgmtClient.java +++ b/gnpdev/dbcfx/src/it/valueteam/gnp/ws/dbss/client/WirelinePortOutOrderMgmtClient.java @@ -43,8 +43,8 @@ public class WirelinePortOutOrderMgmtClient implements Loggable { protected String versione = "1.0.0.0"; public WirelinePortOutOrderMgmtClient() throws Exception { - String prefix = "WirelinePortOutOrderMgmtClient"; - String errorMsg = prefix + "- errore nel costruttore - "; + String prefix = "WirelinePortOutOrderMgmtClient"; + String errorMsg = prefix + "- errore nel costruttore - "; try { LogProcess logProcess = new LogProcess(); logProcess.setCodice(codiceProcesso); @@ -52,7 +52,7 @@ public class WirelinePortOutOrderMgmtClient implements Loggable { log = new ProcessLogger(logProcess); } catch (Exception ex) { ex.printStackTrace(); - errorMsg += "errore nella creazione del ProcessLogger: " + ex.toString(); + errorMsg += "errore nella creazione del ProcessLogger: " + ex.toString(); System.out.println(errorMsg); throw new CreateException(); } @@ -61,7 +61,7 @@ public class WirelinePortOutOrderMgmtClient implements Loggable { url = Resources.getURL_WS_WIRELINE_PORTOUT_ORDER_MGMT(); if ("".equals(url)) { - errorMsg += "url del ws nulla da property [URL_WS_WIRELINE_PORTOUT_ORDER_MGMT]"; + errorMsg += "url del ws nulla da property [URL_WS_WIRELINE_PORTOUT_ORDER_MGMT]"; log.write("0003", errorMsg); throw new Exception(errorMsg); } @@ -132,8 +132,9 @@ public class WirelinePortOutOrderMgmtClient implements Loggable { try { WirelineCeaseCheck82_Impl service = new WirelineCeaseCheck82_Impl(); WirelineCeaseCheck82PortType endPoint = service.getWirelineCeaseCheck82PortTypeHttps(); + String timeOutStr = (String) Resources.getTIMEOUT_WIRELINE_CEASE_CHECK82(); ((WirelineCeaseCheck82PortType_Stub) endPoint)._setProperty("javax.xml.rpc.service.endpoint.address", Resources.getURL_WIRELINE_CEASE_CHECK82()); - ((WirelineCeaseCheck82PortType_Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", Resources.getTIMEOUT_WIRELINE_CEASE_CHECK82()); + ((WirelineCeaseCheck82PortType_Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", Integer.parseInt(timeOutStr)); HeaderTypeHolder header = new HeaderTypeHolder(); HeaderType headerType = new HeaderType();