From 785a24ade1a36938e4edd520fa89c65fdd9eb489 Mon Sep 17 00:00:00 2001 From: "andres.albarran" Date: Thu, 20 Nov 2025 22:17:54 +0100 Subject: [PATCH] Initial Commit --- .gitignore | 17 + LICENSE | 0 MessageEnrichUtilMgmtSvc.jws | 51 +++ .../MessageEnrichUtilMgmtSvc.jpr | 197 ++++++++ .../MessageEnrichUtilMgmtSvc_readDVM.pipeline | 307 +++++++++++++ ...EnrichUtilMgmtSvc_readDVM_InitResponse.xqy | 94 ++++ ...sageEnrichUtilMgmtSvc_readDVM_Response.xqy | 134 ++++++ ...EnrichUtilMgmtSvc_readProtocoloVB.pipeline | 433 ++++++++++++++++++ ...ilMgmtSvc_readProtocoloVB_InitResponse.xqy | 33 ++ ...chUtilMgmtSvc_readProtocoloVB_Response.xqy | 25 + MessageEnrichUtilMgmtSvc/pom.xml | 20 + .../proxy/MessageEnrichUtilMgmtSvc.pipeline | 87 ++++ .../proxy/MessageEnrichUtilMgmtSvc.proxy | 31 ++ .../servicebus.sboverview | 2 + .../wsdl/MessageEnrichUtilMgmtSvc.wsdl | 50 ++ pom.xml | 19 + 16 files changed, 1500 insertions(+) create mode 100644 LICENSE create mode 100644 MessageEnrichUtilMgmtSvc.jws create mode 100644 MessageEnrichUtilMgmtSvc/MessageEnrichUtilMgmtSvc.jpr create mode 100644 MessageEnrichUtilMgmtSvc/operations/readDVM/proxy/MessageEnrichUtilMgmtSvc_readDVM.pipeline create mode 100644 MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_InitResponse.xqy create mode 100644 MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_Response.xqy create mode 100644 MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/proxy/MessageEnrichUtilMgmtSvc_readProtocoloVB.pipeline create mode 100644 MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse.xqy create mode 100644 MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_Response.xqy create mode 100644 MessageEnrichUtilMgmtSvc/pom.xml create mode 100644 MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.pipeline create mode 100644 MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.proxy create mode 100644 MessageEnrichUtilMgmtSvc/servicebus.sboverview create mode 100644 MessageEnrichUtilMgmtSvc/wsdl/MessageEnrichUtilMgmtSvc.wsdl create mode 100644 pom.xml diff --git a/.gitignore b/.gitignore index cb4a18e..8eaa62d 100644 --- a/.gitignore +++ b/.gitignore @@ -2,3 +2,20 @@ # Project-level settings /.tgitconfig +# Archivos temporales +*.tmp +*.bak +*.swp +*.log + +# Archivos de integración continua +/.settings/ +/.project +/.classpath +/.factorypath + +# Carpetas +.data/ +.git/ +System/ + diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..e69de29 diff --git a/MessageEnrichUtilMgmtSvc.jws b/MessageEnrichUtilMgmtSvc.jws new file mode 100644 index 0000000..fc3f8fb --- /dev/null +++ b/MessageEnrichUtilMgmtSvc.jws @@ -0,0 +1,51 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/MessageEnrichUtilMgmtSvc/MessageEnrichUtilMgmtSvc.jpr b/MessageEnrichUtilMgmtSvc/MessageEnrichUtilMgmtSvc.jpr new file mode 100644 index 0000000..68065c5 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/MessageEnrichUtilMgmtSvc.jpr @@ -0,0 +1,197 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/MessageEnrichUtilMgmtSvc/operations/readDVM/proxy/MessageEnrichUtilMgmtSvc_readDVM.pipeline b/MessageEnrichUtilMgmtSvc/operations/readDVM/proxy/MessageEnrichUtilMgmtSvc_readDVM.pipeline new file mode 100644 index 0000000..ff5429c --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readDVM/proxy/MessageEnrichUtilMgmtSvc_readDVM.pipeline @@ -0,0 +1,307 @@ + + + + This proxy implements utility for readDVMs + + + + MessageEnrichUtilMgmtSvcSOAP + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + + + 1.0 + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7f03 + + $body + + + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7e67 + + mes:readDVM_Rq + body + + ./mes:readDVM_Rq + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7d8b + + + + + $body/mes:readDVM_Rq + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7d8a + + '<responses>' + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7ccd + + + + + $response/mes:Execute + 'true' + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7ccb + body + + ./mes:readDVM_Rq/mes:Inputs/mes:Input + + index + count + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cca + + + + + $body/mes:readDVM_Rq/mes:Inputs/mes:Input[xs:int($index)]/mes:Value/text() + + + string-join($body/mes:readDVM_Rq/mes:Inputs/mes:Input[xs:int($index)]/mes:Attributes/mes:Attribute/mes:Name, ",") + + + $body/mes:readDVM_Rq/mes:NameDVM/text() + + + $body/mes:readDVM_Rq/mes:Inputs/mes:Input[xs:int($index)]/mes:Field/text() + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc9 + + + + + + $body/mes:readDVM_Rq/mes:NameDVM + "DVM_VB_PROTOCOL" + + + $body/mes:readDVM_Rq/mes:NameDVM + "DVM_CUSTOMER_TYPE" + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc7 + + transform + + DVMRq + + + DVMRs + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc6 + + + + + $DVMRs + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc5 + + translate + + DVMRq + + + DVMRs + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc4 + + + + + $DVMRs + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc3 + + concat("<response>", $DVMRs, "</response>") + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7cc2 + + concat($output, fn-bea:serialize($DVMRs)) + + + + + + + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7c4d + + fn-bea:inlinedXML(concat($output, "</responses>")) + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7c4c + + + + + count($output/response) + 0 + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7c4a + + . + + + + + + $output + + + $backupBodyME/mes:readDVM_Rq/mes:NameDVM/text() + + + $response + + + + + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7be3 + + . + + + $response + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7b7b + + mes:readDVM_Rs + body + + ./mes:readDVM_Rs + + + + + + + + request-N3f579cff.1940610f.0.156b2d8b244.N7f9e + response-N3f579cff.1940610f.0.156b2d8b244.N7f9d + + + request-N3f579cff.1940610f.0.156b2d8b244.N7ed1 + response-N3f579cff.1940610f.0.156b2d8b244.N7ed0 + + + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_InitResponse.xqy b/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_InitResponse.xqy new file mode 100644 index 0000000..c6c79d6 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_InitResponse.xqy @@ -0,0 +1,94 @@ +xquery version "1.0"; + +(:: OracleAnnotationVersion "1.0" ::) + +declare namespace ns0 = "http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc"; +(:: import schema at "../../../../BanescoCommonArtifacts/xsd/utilities/MessageEnrichUtilMgmtSvc.xsd" ::) + +declare namespace ns1 = "http://xmlns.banesco.com/EnterpriseObjects/MsgRqHdr"; +declare namespace xf = "http://tempuri.org/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_InitResponse/"; + +declare variable $DVM_VB_NAME as xs:string := "DVM_VB_PROTOCOL"; + +declare function xf:BuildResponseBody($request as element(ns0:readDVM_Rq)) as element(*) { + + { + if (data($request/ns0:NameDVM) = $DVM_VB_NAME) then ( + + + + + + INDLINEA + {data($request/ns0:MsgRqHdr/ns1:LineId)} + + + CRITREV + {data($request/ns0:MsgRqHdr/ns1:ReverseId)} + + + INDCONT + {data($request/ns0:MsgRqHdr/ns1:ResumeId)} + + + NUMREG + {data($request/ns0:MsgRqHdr/ns1:NetworkTrnInfo/ns1:RegisterNumber)} + + + TIPOPER + {data($request/ns0:MsgRqHdr/ns1:NetworkTrnInfo/ns1:OperationType)} + + + TIPTRN + {data($request/ns0:MsgRqHdr/ns1:NetworkTrnInfo/ns1:TransactionType)} + + + + + + { + if (exists($request/ns0:MsgRqHdr/ns1:ApplicantData/ns1:Application) and $request/ns0:MsgRqHdr/ns1:ApplicantData/ns1:Application != '') + then ('true') + else ('false') + } + + + ) + + else ( + + + { + let $Inputs := $request/ns0:Inputs return + for $Input in $Inputs/ns0:Input return + + { + let $Attributes := $Input/ns0:Attributes return + + { + for $Attribute in $Attributes/ns0:Attribute return + + { data($Attribute/ns0:Name) } + + + } + + } + + } + + true + + ) + } + +}; + +declare function xf:MessageEnrichUtilMgmtSvc_readDVM_InitResponse($readDVM_Rq1 as element(ns0:readDVM_Rq)) + as element(ns0:readDVM_Rs) { + {xf:BuildResponseBody($readDVM_Rq1)/body/*} +}; + +declare variable $readDVM_Rq1 as element(ns0:readDVM_Rq) external; + +xf:MessageEnrichUtilMgmtSvc_readDVM_InitResponse($readDVM_Rq1) \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_Response.xqy b/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_Response.xqy new file mode 100644 index 0000000..cad1ad7 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_Response.xqy @@ -0,0 +1,134 @@ +xquery version "1.0"; + + +(:: OracleAnnotationVersion "1.0" ::) + +declare namespace ns0 = "http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc"; +(:: import schema at "../../../../BanescoCommonArtifacts/xsd/utilities/MessageEnrichUtilMgmtSvc.xsd" ::) + +declare namespace xf = "http://tempuri.org/MessageEnrichUtilMgmtSvc/operations/readDVM/xq/MessageEnrichUtilMgmtSvc_readDVM_Response/"; +declare namespace lvs = "http://www.banesco.com/ServicesPortfolio/ListValueManagementService"; + +declare variable $DVM_VB_NAME as xs:string := "DVM_VB_PROTOCOL"; + +declare function xf:BuildResponseBody($response as element(ns0:readDVM_Rs), $outputDVM as element(*), $DVMName as xs:string) as element(*) { + +{ + if ($DVMName = $DVM_VB_NAME) then ( + + + + + + INDLINEA + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='INDLINEA']/lvs:columnValue)} + + + CRITREV + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='CRITREV']/lvs:columnValue)} + + + INDCONT + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='INDCONT']/lvs:columnValue)} + + + NUMREG + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='NUMREG']/lvs:columnValue)} + + + TIPOPER + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='TIPOPER']/lvs:columnValue)} + + + TIPTRN + {data($outputDVM/response[1]/lvs:BlocksData[./lvs:columnName='TIPTRN']/lvs:columnValue)} + + + + + true + + ) + + else ( + if ($DVMName = "DVM_CUSTOMER_TYPE") then ( + + { + let $Outputs := $response/ns0:Outputs + return + + { + for $Output at $index in $Outputs/ns0:Output + return + + { + let $Attributes := $Output/ns0:Attributes + return + + { + for $Attribute in $Attributes/ns0:Attribute + return + + { data($Attribute/ns0:Name) } + { data($outputDVM/response/lvs:BlocksData/lvs:columnValue)} + + } + + } + + } + + } + true + + ) + else ( + + { + let $Outputs := $response/ns0:Outputs + return + + { + for $Output at $index in $Outputs/ns0:Output + return + + { + let $Attributes := $Output/ns0:Attributes + return + + { + for $Attribute in $Attributes/ns0:Attribute + return + + { data($Attribute/ns0:Name) } + { data($outputDVM/response[$index]) } + + } + + } + + } + + } + true + + ) + ) +} + +}; + +declare function xf:MessageEnrichUtilMgmtSvc_readDVM_Response($readDVM_Rs1 as element(ns0:readDVM_Rs), + $anyType1 as element(*), + $DVMName as xs:string) + as element(ns0:readDVM_Rs) { + {xf:BuildResponseBody($readDVM_Rs1, $anyType1, $DVMName)/body/*} +}; + +declare variable $readDVM_Rs1 as element(ns0:readDVM_Rs) external; +declare variable $anyType1 as element(*) external; +declare variable $DVMName as xs:string external; + +xf:MessageEnrichUtilMgmtSvc_readDVM_Response($readDVM_Rs1, + $anyType1, + $DVMName) \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/proxy/MessageEnrichUtilMgmtSvc_readProtocoloVB.pipeline b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/proxy/MessageEnrichUtilMgmtSvc_readProtocoloVB.pipeline new file mode 100644 index 0000000..aec789b --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/proxy/MessageEnrichUtilMgmtSvc_readProtocoloVB.pipeline @@ -0,0 +1,433 @@ + + + + This proxy implements utility for readProtocolsVB + + + + MessageEnrichUtilMgmtSvcSOAP + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + + + 1.0 + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N797d + + msg:MsgRqHdr + body + + ./mes:readProtocoloVB_Rq/mes:MsgRqHdr + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7916 + + + + + $body/mes:readProtocoloVB_Rq + + + + + + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N786c + + + + + + exists($body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:VBProtocol/msg:TransactionInd) + + + exists($body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:VBProtocol/msg:VBProtocolInd) + + + $body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:VBProtocol/msg:VBProtocolInd + "true" + + + + + + + _ActionId-a87051d.N35cd1dac.4.164431c4eea.N8000 + + + + + $body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:NetworkTrnInfo/msg:TransactionType = "1" and +$body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:VBProtocol/msg:VBProtocolInd = "true" + + + + + + _ActionId-a87051d.N35cd1dac.5.16443214d7f.N8000 + + requestReverseHeaderProtocoloVB + + VBProtocolRq + + + + VBProtocolRs + + + + + _ActionId-a87051d.N35cd1dac.6.164432557da.N8000 + + "true" + + + + _ActionId-a87051d.N35cd1dac.7.1644326dd35.N8000 + + <prot:requestRevHdrProtocoloVBRq>{$body/mes:readProtocoloVB_Rq/ejec:EjecutaTRX}</prot:requestRevHdrProtocoloVBRq> + + + + + + + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N8000 + + + + + $body/mes:readProtocoloVB_Rq/mes:MsgRqHdr/msg:VBProtocol/msg:TransactionInd + "true" + + + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7fff + + requestTransactionHeaderProtocoloVB + + VBProtocolRq + + + + VBProtocolRs + + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7ffe + + "true" + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7ffd + + <prot:requestTrxHdrProtocoloVBRq>{$body/mes:readProtocoloVB_Rq/ejec:EjecutaTRX}</prot:requestTrxHdrProtocoloVBRq> + + + + + + + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7ffc + + requestConsultHeaderProtocoloVB + + VBProtocolRq + + + + VBProtocolRs + + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7ffb + + "false" + + + + _ActionId-a87051d.N35cd1dac.d.164467d102e.N7ffa + + <prot:requestCsHdrProtocoloVBRq>{$body/mes:readProtocoloVB_Rq/ejec:EjecutaTRX}</prot:requestCsHdrProtocoloVBRq> + + + + + + + + + + + + + + + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77b1 + + + + + exists($VBProtocolRs) + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77af + + ./mes:MsgRsHdr + + + $VBProtocolRs/prot:MsgRsHdr/* + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77ae + + ./mes:Status + + + $VBProtocolRs/prot:Status/* + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77ad + + + + + $response/mes:Status/stat:StatusCode + "OK" + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77ab + + ./ejec:EjecutaTRX/ejec:in_agencia + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:in_agencia) + + + + _ActionId-a845012.25481f6.1.15c216533c2.N8000 + + ./ejec:EjecutaTRX/ejec:in_cajero + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:in_cajero) + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77aa + + ./ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CODSUP + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX[1]/@CODSUP) + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77a9 + + + + + $transactional + "true" + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N77a7 + + ./ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN) + + + + + + + _ActionId-a87051d.N35cd1dac.9.16446074f8a.N8000 + + + $transactional2 = "true" + + + + _ActionId-a87051d.N35cd1dac.a.1644608623c.N8000 + + ./ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN) + + + + _ActionId-a87051d.N35cd1dac.b.1644608d71e.N8000 + + ./ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@TIPTRN + + + data($VBProtocolRs/ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@TIPTRN) + + + + + + + + + + + + + + + Verify the fields that must be returned mandatory and which are optional. + + + + + + _ActionId-a7c0466.5cb62c62.0.157f94936c1.N7ede + + + + + data($response/ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN) + "" + + + + + + _ActionId-a7c0466.5cb62c62.0.157f94936c1.N7ea9 + + ./ejec:EjecutaTRX/ejec:TRXS/ejec:ListaTrxs/ejec:TRX/@CONTRN + + + 0 + + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7740 + + . + + + $response + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N76d9 + + stat:Status + body + + ./mes:readProtocoloVB_Rs/mes:Status + + + + + + + + + + + _ActionId-N3f579cff.1940610f.0.156b2d8b244.N7a7b + + $body + + + + + + + + request-N3f579cff.1940610f.0.156b2d8b244.N7b16 + response-N3f579cff.1940610f.0.156b2d8b244.N7b15 + + + request-N3f579cff.1940610f.0.156b2d8b244.N7a49 + response-N3f579cff.1940610f.0.156b2d8b244.N7a48 + + + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse.xqy b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse.xqy new file mode 100644 index 0000000..a09423e --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse.xqy @@ -0,0 +1,33 @@ +xquery version "1.0"; + +(:: OracleAnnotationVersion "1.0" ::) + +declare namespace ns0 = "http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc"; +(:: import schema at "../../../../BanescoCommonArtifacts/xsd/utilities/MessageEnrichUtilMgmtSvc.xsd" ::) + +declare namespace ns2 = "http://Obi_Wan/EjecutaTRX"; +declare namespace ns1 = "http://xmlns.banesco.com/EnterpriseObjects/MsgRsHdr"; +declare namespace ns4 = "http://xmlns.banesco.com/EnterpriseObjects/Status"; +declare namespace ns3 = "http://xmlns.banesco.com/EnterpriseObjects/MsgRqHdr"; +declare namespace xf = "http://tempuri.org/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse/"; + +declare function xf:MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse($readProtocoloVB_Rq1 as element(ns0:readProtocoloVB_Rq)) + as element(ns0:readProtocoloVB_Rs) { + + + { + for $RequestId in $readProtocoloVB_Rq1/ns0:MsgRqHdr/ns3:RequestId + return + { data($RequestId) } + } + + + OK + + { $readProtocoloVB_Rq1/ns2:EjecutaTRX/@* , $readProtocoloVB_Rq1/ns2:EjecutaTRX/node() } + +}; + +declare variable $readProtocoloVB_Rq1 as element(ns0:readProtocoloVB_Rq) external; + +xf:MessageEnrichUtilMgmtSvc_readProtocoloVB_InitResponse($readProtocoloVB_Rq1) \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_Response.xqy b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_Response.xqy new file mode 100644 index 0000000..7cb6955 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_Response.xqy @@ -0,0 +1,25 @@ +xquery version "1.0"; + +(:: OracleAnnotationVersion "1.0" ::) + +declare namespace ns0 = "http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc"; +(:: import schema at "../../../../BanescoCommonArtifacts/xsd/utilities/MessageEnrichUtilMgmtSvc.xsd" ::) + +declare namespace ns2 = "http://Obi_Wan/EjecutaTRX"; +declare namespace ns1 = "http://xmlns.banesco.com/EnterpriseObjects/MsgRsHdr"; +declare namespace ns3 = "http://xmlns.banesco.com/EnterpriseObjects/Status"; +declare namespace xf = "http://tempuri.org/MessageEnrichUtilMgmtSvc/operations/readProtocoloVB/xq/MessageEnrichUtilMgmtSvc_readProtocoloVB_Response/"; + +declare function xf:MessageEnrichUtilMgmtSvc_readProtocoloVB_Response($readProtocoloVB_Rs1 as element(ns0:readProtocoloVB_Rs), + $VBProtocolRs as element(*)) + as element(ns0:readProtocoloVB_Rs) { + + { $readProtocoloVB_Rs1/ns2:EjecutaTRX/@* , $readProtocoloVB_Rs1/ns2:EjecutaTRX/node() } + +}; + +declare variable $readProtocoloVB_Rs1 as element(ns0:readProtocoloVB_Rs) external; +declare variable $VBProtocolRs as element(*) external; + +xf:MessageEnrichUtilMgmtSvc_readProtocoloVB_Response($readProtocoloVB_Rs1, + $VBProtocolRs) \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/pom.xml b/MessageEnrichUtilMgmtSvc/pom.xml new file mode 100644 index 0000000..da14501 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/pom.xml @@ -0,0 +1,20 @@ + + + + 4.0.0 + + + com.oracle.servicebus + sbar-project-common + 12.2.1-5-0 + + + MessageEnrichUtilMgmtSvc + MessageEnrichUtilMgmtSvc + 1.0-SNAPSHOT + + sbar + + + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.pipeline b/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.pipeline new file mode 100644 index 0000000..9e43eb4 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.pipeline @@ -0,0 +1,87 @@ + + + + This pipeline implements utility functions for message enrichment for DVM and VB + + + + MessageEnrichUtilMgmtSvcSOAP + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + + + 1.0 + + + + + backupHeaderME + backupBodyME + + + + + + + {fn:concat("MessageEnrichUtilMgmtSvc/operations/",$operation,"/proxy/MessageEnrichUtilMgmtSvc_",$operation)} + {data($operation)} +]]> + + + + + + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + + + + + + + info + + fn:concat('[',fn:current-dateTime(),'][MessageID : ',$messageID,'][Global Error Handler][',fn:tokenize($inbound/@name,'\$')[last()],'/',$operation,'- message : ',$message,' - fault: ',fn-bea:serialize($fault),' - body : ',fn-bea:serialize($backupBodyME/*),'][Global Error Handler]') + + + + + + + fn:concat('[',fn:current-dateTime(),'][MessageID : ',$messageID,'][Global Error Handler][',fn:tokenize($inbound/@name,'\$')[last()],'/',$operation,'- message : ',$message,' - fault: ',fn-bea:serialize($fault),' - body : ',fn-bea:serialize($backupBodyME/*),'][Global Error Handler]') + + + + + + + + + + $inbound + + + $fault + + + $backupBodyME + + + + + + + + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.proxy b/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.proxy new file mode 100644 index 0000000..3517d62 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/proxy/MessageEnrichUtilMgmtSvc.proxy @@ -0,0 +1,31 @@ + + + + + + + + + + MessageEnrichUtilMgmtSvcSOAP + http://xmlns.banesco.com/Service/MessageEnrichUtilMgmtSvc + + + + + + + + no-policies + + + + 1.0 + + + + local + true + + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/servicebus.sboverview b/MessageEnrichUtilMgmtSvc/servicebus.sboverview new file mode 100644 index 0000000..db4ff79 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/servicebus.sboverview @@ -0,0 +1,2 @@ + + \ No newline at end of file diff --git a/MessageEnrichUtilMgmtSvc/wsdl/MessageEnrichUtilMgmtSvc.wsdl b/MessageEnrichUtilMgmtSvc/wsdl/MessageEnrichUtilMgmtSvc.wsdl new file mode 100644 index 0000000..79ec6b5 --- /dev/null +++ b/MessageEnrichUtilMgmtSvc/wsdl/MessageEnrichUtilMgmtSvc.wsdl @@ -0,0 +1,50 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..325f9e4 --- /dev/null +++ b/pom.xml @@ -0,0 +1,19 @@ + + + + 4.0.0 + + MessageEnrichUtilMgmtSvc + MessageEnrichUtilMgmtSvc + 1.0-SNAPSHOT + + pom + + + System + MessageEnrichUtilMgmtSvc + ProtocoloVBMgmtSvc + BanescoCommonArtifacts + + + \ No newline at end of file