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

MNP_RU_638 - Middleware Modernization 2024: Servizi GISP lotto5: Preparazione ws Outbound O2C

Browse Source
This commit is contained in:
manuelstefanile
2024-06-12 17:52:02 +02:00
parent 3a11cbd3e8
commit e0d3c39080
12 changed files with 617 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
dbcmnpsrc/FE/mnpapp/properties/delta_MNP_RU_638_resources.properties Normal file
View File

@@ -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}

411
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/proxy/ws/gisp/client/GISPClient.java
View File

@@ -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<RequestParameters> parameters = new ArrayList<RequestParameters>();
*
* 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<RequestParameters> parameters = new ArrayList<RequestParameters>();
*
* 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<RequestParameters> parameters = new ArrayList<RequestParameters>();
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<RequestParameters> parameters = new ArrayList<RequestParameters>();
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;
}
***/
}

36
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestAttOutEventHandler.java
View File

@@ -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;
* }
* **/

15
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutDonAbbEventHandler.java
View File

@@ -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;

36
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRequestCessOutEventHandler.java
View File

@@ -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;
* }
* **/
}

36
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispRestOutEventHandler.java
View File

@@ -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;
}
*/
}

34
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/systemcontroller/gisp/handler/GispTpOutEventHandler.java
View File

@@ -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;
}
*/
}

28
dbcmnpsrc/FE/mnpdev/mnp/src/mnp/utility/Resources.java
View File

@@ -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));
}
}

0
dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICATTLMVNO/tempFile Normal file
View File

0
dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICCESDBCTP/tempFile2 Normal file
View File

0
dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICESSLMVNO/tempFile3 Normal file
View File

0
dbcmnpsrc/FE/mnpdev/wsdbc/o2c/client/RICRESDBCNM/tempFile4 Normal file
View File