From e0d3c390809e88080f98506192c96a93caf3d19d Mon Sep 17 00:00:00 2001 From: manuelstefanile Date: Wed, 12 Jun 2024 17:52:02 +0200 Subject: [PATCH] MNP_RU_638 - Middleware Modernization 2024: Servizi GISP lotto5: Preparazione ws Outbound O2C --- .../delta_MNP_RU_638_resources.properties | 24 + .../mnp/proxy/ws/gisp/client/GISPClient.java | 411 +++++++++++++++++- .../GispRequestAttOutEventHandler.java | 36 ++ .../GispRequestCessOutDonAbbEventHandler.java | 15 +- .../GispRequestCessOutEventHandler.java | 36 ++ .../gisp/handler/GispRestOutEventHandler.java | 36 ++ .../gisp/handler/GispTpOutEventHandler.java | 34 ++ .../mnpdev/mnp/src/mnp/utility/Resources.java | 28 ++ .../wsdbc/o2c/client/RICATTLMVNO/tempFile | 0 .../wsdbc/o2c/client/RICCESDBCTP/tempFile2 | 0 .../wsdbc/o2c/client/RICESSLMVNO/tempFile3 | 0 .../wsdbc/o2c/client/RICRESDBCNM/tempFile4 | 0 12 files changed, 617 insertions(+), 3 deletions(-) create mode 100644 dbcmnpsrc/FE/mnpapp/properties/delta_MNP_RU_638_resources.properties create mode 100644 dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICATTLMVNO/tempFile create mode 100644 dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICCESDBCTP/tempFile2 create mode 100644 dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICESSLMVNO/tempFile3 create mode 100644 dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICRESDBCNM/tempFile4 diff --git a/dbcmnpsrc/FE/mnpapp/properties/delta_MNP_RU_638_resources.properties b/dbcmnpsrc/FE/mnpapp/properties/delta_MNP_RU_638_resources.properties new file mode 100644 index 0000000..d765d78 --- /dev/null +++ b/dbcmnpsrc/FE/mnpapp/properties/delta_MNP_RU_638_resources.properties @@ -0,0 +1,24 @@ +# SWITCH TIPO COMUNICAZIONE DA GISP AD O2C (VALORI: 0 = COMUNICAZIONE INFOBUS, 1 = COMUNICAZIONE SOAP) +SOAP_O2C_RICH_ATTIVGSM_ENABLED=0 +TIMEOUT_WS_O2C_ATTIVGSM_DONOR=30000 +URL_WS_O2C_ATTIVGSM_DONOR={URL WS GISP} + +# SWITCH TIPO COMUNICAZIONE DA GISP AD O2C (VALORI: 0 = COMUNICAZIONE INFOBUS, 1 = COMUNICAZIONE SOAP) +SOAP_O2C_RICH_DISATMNPG_ENABLED=0 +TIMEOUT_WS_O2C_DISATMNPG_DONOR=30000 +URL_WS_O2C_DISATMNPG_DONOR={URL WS GISP} + +# SWITCH TIPO COMUNICAZIONE DA GISP AD O2C (VALORI: 0 = COMUNICAZIONE INFOBUS, 1 = COMUNICAZIONE SOAP) +SOAP_O2C_RICH_RESTITUZIONE_ENABLED=0 +TIMEOUT_WS_O2C_RESTITUZIONE_DONOR=30000 +URL_WS_O2C_RESTITUZIONE_DONOR={URL WS GISP} + +# SWITCH TIPO COMUNICAZIONE DA GISP AD O2C (VALORI: 0 = COMUNICAZIONE INFOBUS, 1 = COMUNICAZIONE SOAP) +SOAP_O2C_RICH_TERZEPARTI_ENABLED=0 +TIMEOUT_WS_O2C_TERZEPARTI_DONOR=30000 +URL_WS_O2C_TERZEPARTI_DONOR={URL WS GISP} + +# SWITCH TIPO COMUNICAZIONE DA GISP AD O2C (VALORI: 0 = COMUNICAZIONE INFOBUS, 1 = COMUNICAZIONE SOAP) +SOAP_O2C_RICH_DISATMNPG_CO_ENABLED=0 +TIMEOUT_WS_O2C_DISATMNPG_CO_DONOR=30000 +URL_WS_O2C_DISATMNPG_CO_DONOR={URL WS GISP} diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/proxy/ws/gisp/client/GISPClient.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/proxy/ws/gisp/client/GISPClient.java index ac4b54e..5ca7e37 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/proxy/ws/gisp/client/GISPClient.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/proxy/ws/gisp/client/GISPClient.java @@ -218,7 +218,6 @@ public class GISPClient implements Loggable { return richiestaCessazione; } - public RequestType createRequest(MnpGispCessOutDonPp cessazioneDonPp) { RequestType richiestaCessazione = new RequestType(); @@ -305,4 +304,414 @@ public class GISPClient implements Loggable { return richiestaCessazione; } + /** + * ************************************************************************** ATTIVGSM **************************************** + * public RequestType createRequest(MnpGispAttOut MnpGispAttOut) { + * RequestType richiestaAttivazione = new RequestType(); + * Message message = new Message(); + * List parameters = new ArrayList(); + * + * RequestParameters nomeRichiesta = new RequestParameters(); + * if (MnpGispAttOut.getNomeRichiesta() != null) { + * nomeRichiesta.setName("NOME_RICHIESTA"); + * nomeRichiesta.setValue(cessazioneDonAbb.getNomeRichiesta()); + * parameters.add(nomeRichiesta); + * } + * + * RequestParameters cas = new RequestParameters(); + * if (MnpGispAttOut.getCas() != null) { + * cas.setName("CAS"); + * cas.setValue(cessazioneDonAbb.getCas()); + * parameters.add(cas); + * } + * + * RequestParameters numTel = new RequestParameters(); + * if (MnpGispAttOut.getNumTel() != null) { + * numTel.setName("NUM_TEL"); + * numTel.setValue(cessazioneDonAbb.getNumTel()); + * parameters.add(numTel); + * } + * + * RequestParameters numTelServB = new RequestParameters(); + * if (MnpGispAttOut.getNumTelServB() != null) { + * numTelServB.setName("NUM_TEL_SERV_B"); + * numTelServB.setValue(cessazioneDonAbb.getNumTelServB()); + * parameters.add(numTelServB); + * } + * + * RequestParameters numTelAdd1 = new RequestParameters(); + * if (MnpGispAttOut.getNumAddiz1() != null) { + * numTelAdd1.setName("NUM_ADDIZ1"); + * numTelAdd1.setValue(cessazioneDonAbb.getNumAddiz1()); + * parameters.add(numTelAdd1); + * } + * + * RequestParameters numTelAdd2 = new RequestParameters(); + * if (MnpGispAttOut.getNumAddiz2() != null) { + * numTelAdd2.setName("NUM_ADDIZ2"); + * numTelAdd2.setValue(cessazioneDonAbb.getNumAddiz2()); + * parameters.add(numTelAdd2); + * } + * + * RequestParameters imsi = new RequestParameters(); + * if (MnpGispAttOut.getImsi() != null) { + * imsi.setName("IMSI"); + * imsi.setValue(cessazioneDonAbb.getImsi()); + * parameters.add(imsi); + * } + * + * RequestParameters esportaMain = new RequestParameters(); + * if (MnpGispAttOut.getEsportaMain() != null) { + * esportaMain.setName("ESPORTA_MAIN"); + * esportaMain.setValue(cessazioneDonAbb.getEsportaMain()); + * parameters.add(esportaMain); + * } + * + * RequestParameters oloCode = new RequestParameters(); + * if (MnpGispAttOut.getOlocode() != null) { + * oloCode.setName("OLOCODE"); + * oloCode.setValue(cessazioneDonAbb.getOlocode()); + * parameters.add(oloCode); + * } + * + * RequestParameters dataEspl = new RequestParameters(); + * if (MnpGispAttOut.getDataEspl() != null) { + * dataEspl.setName("DATA_ESPL"); + * dataEspl.setValue(DateUtils. + * toStringLocale(cessazioneDonAbb.getDataEspl(), + * GispMap.DATA_ESPL_FORMAT, + * Locale.ENGLISH)); + * parameters.add(dataEspl); + * } + * + * RequestParameters tid = new RequestParameters(); + * if (MnpGispAttOut.getTid() != null) { + * tid.setName("TID"); + * tid.setValue(cessazioneDonAbb.getTid()); + * parameters.add(tid); + * } + * + * + * RequestParameters[] array_param = new RequestParameters[parameters.size()]; + * int p = 0; + * + * for (RequestParameters param : parameters) { + * array_param[p] = param; + * p++; + * } + * + * message.setRequestParameters(array_param); + * richiestaAttivazione.setMessage(message); + * + * return richiestaAttivazione; + * } + * + * + * **/ + + /** + public iBK61RichiestaAttivazioneResponseElementType iBK61RichiestaAttivazioneLineaDonor(RequestType body, String eventType) throws Exception { + + IBK61_Service0_Impl service = new IBK61_Service0_Impl(); + RichiestaAttivazioneLineaDonorPortType endPoint; + endPoint = service.getRichiestaCessazioneLineaDonorPortTypeEndpoint0(); + ((Stub) endPoint)._setProperty("javax.xml.rpc.service.endpoint.address", url); + ((Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", timeOut); + + Header header = new Header(); + + Date date = new Date(); + header.setInteractionDateDate(new SimpleDateFormat(dateFormat).format(date)); + header.setInteractionDateTime(new SimpleDateFormat(timeFormat).format(date)); + + header.setSourceSystem(SYSTEM_DBC); + header.setChannel(SYSTEM_DBC); + header.setEventType(eventType); + + header.setBusinessID(new TID().toString()); + header.setTransactionID(new TID().toString()); + header.setMessageID(new TID().toString()); + + body.setHeader(header); + + if (requestHeader != null) { + header.setBusinessID(requestHeader.getBusinessId()); + header.setTransactionID(requestHeader.getTransactionId()); + } + + iBK61RichiestaAttivazioneResponseElementType response = endPoint.iBK61RichiestaAttivazioneLineaDonor(body); + + return response; + } + + ***/ + + +/** + * ************************************************************************** DBC_DISATMNPG **************************************** + * public RequestType createRequest(MnpGispCessOut MnpGispCessOut) { + * RequestType richiestaDisattivazione = new RequestType(); + * Message message = new Message(); + * List parameters = new ArrayList(); + * + * RequestParameters nomeRichiesta = new RequestParameters(); + * if (MnpGispCessOut.getNomeRichiesta() != null) { + * nomeRichiesta.setName("NOME_RICHIESTA"); + * nomeRichiesta.setValue(cessazioneDonAbb.getNomeRichiesta()); + * parameters.add(nomeRichiesta); + * } + * + * RequestParameters cas = new RequestParameters(); + * if (MnpGispCessOut.getCas() != null) { + * cas.setName("CAS"); + * cas.setValue(cessazioneDonAbb.getCas()); + * parameters.add(cas); + * } + * + * RequestParameters numTel = new RequestParameters(); + * if (MnpGispAttOut.getNumTel() != null) { + * numTel.setName("NUM_TEL"); + * numTel.setValue(cessazioneDonAbb.getNumTel()); + * parameters.add(numTel); + * } + * + * RequestParameters tid = new RequestParameters(); + * if (MnpGispAttOut.getTid() != null) { + * tid.setName("TID"); + * tid.setValue(cessazioneDonAbb.getTid()); + * parameters.add(tid); + * } + * + * + * RequestParameters[] array_param = new RequestParameters[parameters.size()]; + * int p = 0; + * + * for (RequestParameters param : parameters) { + * array_param[p] = param; + * p++; + * } + * + * message.setRequestParameters(array_param); + * MnpGispCessOut.setMessage(message); + * + * return richiestaDisattivazione; + * } + * + * + * **/ + + /** + public iBK61RichiestaCessazioneResponseElementType iBK61RichiestaCessazioneLineaDonor(RequestType body, String eventType) throws Exception { + + IBK61_Service0_Impl service = new IBK61_Service0_Impl(); + RichiestaAttivazioneLineaDonorPortType endPoint; + endPoint = service.getRichiestaCessazioneLineaDonorPortTypeEndpoint0(); + ((Stub) endPoint)._setProperty("javax.xml.rpc.service.endpoint.address", url); + ((Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", timeOut); + + Header header = new Header(); + + Date date = new Date(); + header.setInteractionDateDate(new SimpleDateFormat(dateFormat).format(date)); + header.setInteractionDateTime(new SimpleDateFormat(timeFormat).format(date)); + + header.setSourceSystem(SYSTEM_DBC); + header.setChannel(SYSTEM_DBC); + header.setEventType(eventType); + + header.setBusinessID(new TID().toString()); + header.setTransactionID(new TID().toString()); + header.setMessageID(new TID().toString()); + + body.setHeader(header); + + if (requestHeader != null) { + header.setBusinessID(requestHeader.getBusinessId()); + header.setTransactionID(requestHeader.getTransactionId()); + } + + iBK61RichiestaAttivazioneResponseElementType response = endPoint.iBK61RichiestaAttivazioneLineaDonor(body); + + return response; + } + + ***/ + + + /*************************************************************************** DBC_RESTITUZIONE ****************************************/ +/** + public RequestType createRequest(mnpGispCessRestituzioneOut mnpGispCessRestituzioneOut) { + RequestType richiestaRestituzione = new RequestType(); + Message message = new Message(); + List parameters = new ArrayList(); + + RequestParameters nomeRichiesta = new RequestParameters(); + if (MnpGispCessOut.getNomeRichiesta() != null) { + nomeRichiesta.setName("NOME_RICHIESTA"); + nomeRichiesta.setValue(cessazioneDonAbb.getNomeRichiesta()); + parameters.add(nomeRichiesta); + } + + RequestParameters cas = new RequestParameters(); + if (MnpGispCessOut.getCas() != null) { + cas.setName("CAS"); + cas.setValue(cessazioneDonAbb.getCas()); + parameters.add(cas); + } + + RequestParameters numTel = new RequestParameters(); + if (MnpGispAttOut.getNumTel() != null) { + numTel.setName("NUM_TEL"); + numTel.setValue(cessazioneDonAbb.getNumTel()); + parameters.add(numTel); + } + + RequestParameters tid = new RequestParameters(); + if (MnpGispAttOut.getTid() != null) { + tid.setName("TID"); + tid.setValue(cessazioneDonAbb.getTid()); + parameters.add(tid); + } + + + RequestParameters[] array_param = new RequestParameters[parameters.size()]; + int p = 0; + + for (RequestParameters param : parameters) { + array_param[p] = param; + p++; + } + + message.setRequestParameters(array_param); + richiestaRestituzione.setMessage(message); + + return richiestaRestituzione; + } + **/ + + /** + public iBK65RichiestaRestituzioneResponseElementType iBK65RichiestaRestituzioneLineaDonor(RequestType body, String eventType) throws Exception { + + IBK65_Service0_Impl service = new IBK61_Service0_Impl(); + RichiestaRestituzioneLineaDonorPortType endPoint; + endPoint = service.getRichiestaCessazioneLineaDonorPortTypeEndpoint0(); + ((Stub) endPoint)._setProperty("javax.xml.rpc.service.endpoint.address", url); + ((Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", timeOut); + + Header header = new Header(); + + Date date = new Date(); + header.setInteractionDateDate(new SimpleDateFormat(dateFormat).format(date)); + header.setInteractionDateTime(new SimpleDateFormat(timeFormat).format(date)); + + header.setSourceSystem(SYSTEM_DBC); + header.setChannel(SYSTEM_DBC); + header.setEventType(eventType); + + header.setBusinessID(new TID().toString()); + header.setTransactionID(new TID().toString()); + header.setMessageID(new TID().toString()); + + body.setHeader(header); + + if (requestHeader != null) { + header.setBusinessID(requestHeader.getBusinessId()); + header.setTransactionID(requestHeader.getTransactionId()); + } + + iBK65RichiestaRestituzioneResponseElementType response = endPoint.iBK65RichiestaRestituzioneLineaDonor(body); + + return response; + } + + ***/ + + /*************************************************************************** DBC_TERZEPARTI ****************************************/ + +/** + public RequestType createRequest(mnpGispCessResttpOut mnpGispCessResttpOut) { + RequestType richiestaRestituzioneTp = new RequestType(); + Message message = new Message(); + List parameters = new ArrayList(); + + RequestParameters nomeRichiesta = new RequestParameters(); + if (MnpGispCessOut.getNomeRichiesta() != null) { + nomeRichiesta.setName("NOME_RICHIESTA"); + nomeRichiesta.setValue(cessazioneDonAbb.getNomeRichiesta()); + parameters.add(nomeRichiesta); + } + + RequestParameters cas = new RequestParameters(); + if (MnpGispCessOut.getCas() != null) { + cas.setName("CAS"); + cas.setValue(cessazioneDonAbb.getCas()); + parameters.add(cas); + } + + RequestParameters numTel = new RequestParameters(); + if (MnpGispAttOut.getNumTel() != null) { + numTel.setName("NUM_TEL"); + numTel.setValue(cessazioneDonAbb.getNumTel()); + parameters.add(numTel); + } + + RequestParameters tid = new RequestParameters(); + if (MnpGispAttOut.getTid() != null) { + tid.setName("TID"); + tid.setValue(cessazioneDonAbb.getTid()); + parameters.add(tid); + } + + + RequestParameters[] array_param = new RequestParameters[parameters.size()]; + int p = 0; + + for (RequestParameters param : parameters) { + array_param[p] = param; + p++; + } + + message.setRequestParameters(array_param); + richiestaRestituzioneTp.setMessage(message); + + return richiestaRestituzioneTp; + } + **/ + + /** + public iBK63RichiestaTerzePartiResponseElementType iBK63RichiestaTerzePartiLineaDonor(RequestType body, String eventType) throws Exception { + + IBK63_Service0_Impl service = new IBK61_Service0_Impl(); + RichiestaRestituzioneLineaDonorPortType endPoint; + endPoint = service.getRichiestaCessazioneLineaDonorPortTypeEndpoint0(); + ((Stub) endPoint)._setProperty("javax.xml.rpc.service.endpoint.address", url); + ((Stub) endPoint)._setProperty("weblogic.wsee.transport.connection.timeout", timeOut); + + Header header = new Header(); + + Date date = new Date(); + header.setInteractionDateDate(new SimpleDateFormat(dateFormat).format(date)); + header.setInteractionDateTime(new SimpleDateFormat(timeFormat).format(date)); + + header.setSourceSystem(SYSTEM_DBC); + header.setChannel(SYSTEM_DBC); + header.setEventType(eventType); + + header.setBusinessID(new TID().toString()); + header.setTransactionID(new TID().toString()); + header.setMessageID(new TID().toString()); + + body.setHeader(header); + + if (requestHeader != null) { + header.setBusinessID(requestHeader.getBusinessId()); + header.setTransactionID(requestHeader.getTransactionId()); + } + + iBK63RichiestaTerzePartiResponseElementType response = endPoint.iBK63RichiestaTerzePartiLineaDonor(body); + + return response; + } + + ***/ } diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestAttOutEventHandler.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestAttOutEventHandler.java index bf662a7..3f0385b 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestAttOutEventHandler.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestAttOutEventHandler.java @@ -99,6 +99,17 @@ public class GispRequestAttOutEventHandler extends AbstractEventHandler { } dao.flush(); //invio la notifica + /** switch in base alla properties ed invia a o2c + * if(!Resources.SOAP_GISP_RICH_ATT_ENABLED()) { + * if(sendToIB(mnpGispAttOut)) { + * requestSent = true; + * } + * } else { + * if(sendToO2C(mnpGispAttOut)) { + * requestSent = true; + * } + * } + * **/ sendToIB(mnpGispAttOut); } break; @@ -353,6 +364,31 @@ public class GispRequestAttOutEventHandler extends AbstractEventHandler { } } + /** + * + * + * public boolean sendToO2C(MnpGispAttOut MnpGispAttOut) throws Exception { + * + * GISPClient client = new GISPClient(); + * RequestType requesto2c = client.createRequest(MnpGispAttOut); + * + * iBK61RichiestaAttivazioneResponseElementType response; + * + * boolean esito = false; + * try { + * response = client.iBK61RichiestaAttivazioneLineaDonor(requesto2c, "lineeMobili_gestioneMNPMVNOAttiv’"); + * log.write("9999", "Response ricevuta OK: " + (response != null && response.getResponse() != null ? + * response.getResponse().getReturnCode() : "")); + * esito = true; + * } catch(Exception e) { + * log.write("9999", "Eccezione ricevuta su ibk50RichiestaCessazioneLineaDonor" + e.getMessage()); + * throw e; + * } + * + * return esito; + * } + * **/ + diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutDonAbbEventHandler.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutDonAbbEventHandler.java index 4ad737e..1840800 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutDonAbbEventHandler.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutDonAbbEventHandler.java @@ -106,7 +106,11 @@ public class GispRequestCessOutDonAbbEventHandler extends AbstractEventHandler { mnpGispCessOutDonAbb.setDataInvio(new Date()); boolean isCo = GispMap.GISP_CESS_TIPO_RICHIESTA_COABB.equals(mnpGispCessOutDonAbb.getNomeRichiesta()); boolean requestSent = false; - if(!Resources.SOAP_GISP_RICH_CESS_ENABLED() || isCo) { + + /** SOAP_GISP_RICH_CESS_ENABLED utilizzata per abilitare la chiamata al servizio DBC_DISATMNPG_BU + * la var SOAP_O2C_RICH_DISATMNPG_CO_ENABLED abilita la chiamata al servizio DBC_DISATMNPG_CO + * **/ + if(!Resources.SOAP_GISP_RICH_CESS_ENABLED() || (isCo && !Resources.SOAP_O2C_RICH_DISATMNPG_CO_ENABLED())) { if(sendToIB(mnpGispCessOutDonAbb)) { requestSent = true; } @@ -151,7 +155,14 @@ public class GispRequestCessOutDonAbbEventHandler extends AbstractEventHandler { IBK50ResponseElementType response; boolean esito = false; try { - response = client.iBK50RichiestaCessazioneLineaDonor(requesto2c, "lineeMobili_cessazioneLineaDonorABB"); + + + boolean isCo = GispMap.GISP_CESS_TIPO_RICHIESTA_COABB.equals(mnpGispCessOutDonAbb.getNomeRichiesta()); + if(isCo) + response = client.iBK50RichiestaCessazioneLineaDonor(requesto2c, "lineeMobili_cessazioneLineaDonorCO"); + else + response = client.iBK50RichiestaCessazioneLineaDonor(requesto2c, "lineeMobili_cessazioneLineaDonorABB"); + log.write("9999", "Response ricevuta OK: " + (response != null && response.getResponse() != null ? response.getResponse().getReturnCode() : "")); esito = true; diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutEventHandler.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutEventHandler.java index ead152f..e13e46c 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutEventHandler.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutEventHandler.java @@ -151,6 +151,17 @@ public class GispRequestCessOutEventHandler extends AbstractEventHandler { richiestaRecVirtBO.avanzaStatoInCessazione(log); } dao.flush(); + /** switch in base alla properties ed invia a o2c + * if(!Resources.SOAP_GISP_RICH_DISATMNPG_ENABLED()()) { + * if(sendToIB(mnpGispCessOut)) { + * requestSent = true; + * } + * } else { + * if(sendToO2C(mnpGispCessOut)) { + * requestSent = true; + * } + * } + * **/ sendToIB(mnpGispCessOut); } break; @@ -361,6 +372,31 @@ public class GispRequestCessOutEventHandler extends AbstractEventHandler { } + /** + * + * + * public boolean sendToO2C(MnpGispCessOut mnpGispCessOut) throws Exception { + * + * GISPClient client = new GISPClient(); + * RequestType requesto2c = client.createRequest(mnpGispCessOut); + * + * iBK61RichiestaCessazioneResponseElementType response; + * + * boolean esito = false; + * try { + * response = client.iBK61RichiestaCessazioneLineaDonor(requesto2c, "lineeMobili_gestioneMNPMVNODisat’"); + * log.write("9999", "Response ricevuta OK: " + (response != null && response.getResponse() != null ? + * response.getResponse().getReturnCode() : "")); + * esito = true; + * } catch(Exception e) { + * log.write("9999", "Eccezione ricevuta su ibk50RichiestaCessazioneLineaDonor" + e.getMessage()); + * throw e; + * } + * + * return esito; + * } + * **/ + } diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRestOutEventHandler.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRestOutEventHandler.java index 15f278d..7014416 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRestOutEventHandler.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRestOutEventHandler.java @@ -4,10 +4,13 @@ import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.*; +import com.tibco.tns.bw.json.x1698392386014.RequestType; +import com.tibco.tns.bw.json.x1698420077301.IBK50ResponseElementType; import mnp.bo.RequestIF; import mnp.database.*; import mnp.database.dao.RichiestaCessazioneDAO; import mnp.database.hb.dao.*; +import mnp.database.hb.dto.MnpGispCessOutDonAbb; import mnp.database.hb.dto.MnpGispCessRestituzioneOut; import mnp.exception.infobus.*; import mnp.jms.MessageHandler; @@ -17,6 +20,7 @@ import mnp.objects.dao.Richiesta; import mnp.objects.dao.RichiestaCessazione; import mnp.objects.dao.RichiestaPorting; import mnp.proxy.ToWTC.*; +import mnp.proxy.ws.gisp.client.GISPClient; import mnp.systemcontroller.eventhandler.*; import mnp.systemcontroller.gisp.formatcontroller.GispRestOutFormatController; import mnp.utility.Resources; @@ -96,6 +100,17 @@ public class GispRestOutEventHandler extends AbstractEventHandler { mnpGispCessRestituzioneOut.setDataUltimoInvio(new Date()); dao.merge(mnpGispCessRestituzioneOut); dao.flush(); + /** switch in base alla properties ed invia a o2c + * if(!Resources.SOAP_GISP_RICH_RESTITUZIONE_ENABLED()) { + * if(sendToIB(mnpGispCessRestituzioneOut)) { + * requestSent = true; + * } + * } else { + * if(sendToO2C(mnpGispCessRestituzioneOut)) { + * requestSent = true; + * } + * } + * **/ sendToIB(mnpGispCessRestituzioneOut); break; default: @@ -331,4 +346,25 @@ public class GispRestOutEventHandler extends AbstractEventHandler { Long ris = this.sendToGispRichiestaRestituzione(ric); inserisciNotificaInCoda(this.creaNotificationMessage(ris,idRichiesta)); } + +/** + public boolean sendToO2C(mnpGispCessRestituzioneOut mnpGispCessRestituzioneOut) throws Exception { + + GISPClient client = new GISPClient(); + RequestType requesto2c = client.createRequest(mnpGispCessRestituzioneOut); + IBK65ResponseElementType response; + boolean esito = false; + try { + response = client.iBK65RichiestaRestituzioneLineaDonor(requesto2c, "lineeMobili_restituzioneNumero"); + log.write("9999", "Response ricevuta OK: " + (response != null && response.getResponse() != null ? + response.getResponse().getReturnCode() : "")); + esito = true; + } catch(Exception e) { + log.write("9999", "Eccezione ricevuta su ibk50RichiestaCessazioneLineaDonor" + e.getMessage()); + throw e; + } + + return esito; + } + */ } diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispTpOutEventHandler.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispTpOutEventHandler.java index 9cd9fb1..c99e61e 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispTpOutEventHandler.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispTpOutEventHandler.java @@ -102,6 +102,19 @@ public class GispTpOutEventHandler extends AbstractEventHandler { mnpGispCessResttpOut.setDataUltimoInvio(new Date()); dao.merge(mnpGispCessResttpOut); dao.flush(); + + /** switch in base alla properties ed invia a o2c + * if(!Resources.SOAP_GISP_RICH_TERZEPARTI_ENABLED()) { + * if(sendToIB(mnpGispCessResttpOut)) { + * requestSent = true; + * } + * } else { + * if(sendToO2C(mnpGispCessResttpOut)) { + * requestSent = true; + * } + * } + * **/ + sendToIB(mnpGispCessResttpOut); if(mnpGispCessResttpOut.getNumInvii().intValue()==1) RequestManagerPorting.avanzaStato(mnpGispCessResttpOut.getTid(), String.valueOf(TipoFlusso.GISP_TERZEPARTI_IN), StatoRichiestaPorting.ACQUISITA, StatoRichiestaPorting.ATTESAEVASIONE, "", -1); @@ -366,4 +379,25 @@ public class GispTpOutEventHandler extends AbstractEventHandler { throw ex; } } + + /** + public boolean sendToO2C(mnpGispCessResttpOut mnpGispCessResttpOut) throws Exception { + + GISPClient client = new GISPClient(); + RequestType requesto2c = client.createRequest(mnpGispCessResttpOut); + IBK63ResponseElementType response; + boolean esito = false; + try { + response = client.iBK63RichiestaTerzePartiLineaDonor(requesto2c, "lineeMobili_gestioneTerzeParti"); + log.write("9999", "Response ricevuta OK: " + (response != null && response.getResponse() != null ? + response.getResponse().getReturnCode() : "")); + esito = true; + } catch(Exception e) { + log.write("9999", "Eccezione ricevuta su ibk50RichiestaCessazioneLineaDonor" + e.getMessage()); + throw e; + } + + return esito; + } + */ } diff --git a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/utility/Resources.java b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/utility/Resources.java index 25a1cf3..a1aea86 100644 --- a/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/utility/Resources.java +++ b/dbcmnpsrc/FE/mnpdev/mnp/src/mnp/utility/Resources.java @@ -2433,4 +2433,32 @@ public class Resources { init(); return trim(props.getProperty("URL_WS_GISP_CESS_DONOR")); } + + public static Boolean SOAP_O2C_RICH_ATTIVGSM_ENABLED() { + init(); + String valoreProp = trim(props.getProperty("SOAP_O2C_RICH_ATTIVGSM_ENABLED")); + return ("1".equalsIgnoreCase(valoreProp)); + } + + public static Boolean SOAP_O2C_RICH_DISATMNPG_ENABLED() { + init(); + String valoreProp = trim(props.getProperty("SOAP_O2C_RICH_DISATMNPG_ENABLED")); + return ("1".equalsIgnoreCase(valoreProp)); + } + public static Boolean SOAP_O2C_RICH_RESTITUZIONE_ENABLED() { + init(); + String valoreProp = trim(props.getProperty("SOAP_O2C_RICH_RESTITUZIONE_ENABLED")); + return ("1".equalsIgnoreCase(valoreProp)); + } + public static Boolean SOAP_O2C_RICH_TERZEPARTI_ENABLED() { + init(); + String valoreProp = trim(props.getProperty("SOAP_O2C_RICH_TERZEPARTI_ENABLED")); + return ("1".equalsIgnoreCase(valoreProp)); + } + + public static Boolean SOAP_O2C_RICH_DISATMNPG_CO_ENABLED() { + init(); + String valoreProp = trim(props.getProperty("SOAP_O2C_RICH_DISATMNPG_CO_ENABLED")); + return ("1".equalsIgnoreCase(valoreProp)); + } } diff --git a/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICATTLMVNO/tempFile b/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICATTLMVNO/tempFile new file mode 100644 index 0000000..e69de29 diff --git a/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICCESDBCTP/tempFile2 b/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICCESDBCTP/tempFile2 new file mode 100644 index 0000000..e69de29 diff --git a/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICESSLMVNO/tempFile3 b/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICESSLMVNO/tempFile3 new file mode 100644 index 0000000..e69de29 diff --git a/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICRESDBCNM/tempFile4 b/dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICRESDBCNM/tempFile4 new file mode 100644 index 0000000..e69de29