Vendor Outbound Controller

Flussdiagrammknoten

• start

• step 2045 set Basics

• outboundVendorDetailMap = new controllerStepExist = false retryRequestString = EMPTY

• fetchRetryCount.sql

• isRetry = true

• flag = true

• Map<String, Object> rows = controller_rows {status, request}

• rows != null

• true

• true

• retryRequestString = rows.get(request)

• true

• retryRequestString != null

• controllerStepExist = true outboundVendorDetailMap = retryRequestString in string

• removeAlreadyProcessedChildTransactions

• removeAlreadyProcessedChildTransactions

• senderIdent = MES

• toFetchStepStatusFromAuditTable = true

• true

• return true

• true

• senderIdent = CVS or CVT

• false

• false

• end

• toFetchStepStatusFromAuditTable = true

• true

• return true

• true

• senderIdent = MGN

• false

• false

• toFetchStepStatusFromAuditTable = true

• return true

• true

• true

• false

• false

• flag = toFetchStepStatusFromAuditTable

• toFetchStepStatusFromAuditTable

• MapSqlParameterSource params params.add(api_id) params.add(transCk) params.add(prcsId) NamedParameterJdbcTemplate template

• template != null

• execute rows = queryToFetchStepStatusFromAuditTable 

• true

• rows != null

• false

• prcsId = 2045 

• true

• controller_rows = rows

• return true

• End

• true

• false

• row -> intac_aud_sts_cd = SUCCESS

• false

• return true

• true

• false

• true

• accumOutboundReq = outboundRequest

• false

• false

• false

• false

• memberRecords = list MEMBER_ELIGIBILITY_RECORDS

• productMap = fetchProductRecordMap()

•  fetchProductRecordMap()

• productMap = new LinkedHashMap

• validProductRecords = List PRODUCT_RECORDS

• productMatchRecord : validProductRecords

• productMap -> containsKey = productMatchRecord -> Sender_ident 

• true

• productMap -> add ( productMatchRecord )

• true

• false

• productList = new productList -> add ( productMatchRecord ) productMap -> put ( productMatchRecord -> ( Sender_ident, productList )

• Next

• return productMap

• false

• End

• odmRequestMap = fetchODMRequestMap

• fetchODMRequestMap

• odmRequestMap = new LinkedHashMap

• rtaInputRequest = ODM_REQUEST

•        rtaInputRequest -> list AccumulatorInput != null

• return odmRequestMap

• false

• accumulatorInputList = rtaInputRequest -> rtaInput ->   list accumulatorInput

• true

• accumulatorInput : accumulatorInputList

• odmRequestMap -> put ( accumulatorInput -> mctrVal, accumulatorInput )

• true

• false

• next

• End

• odmResponse = exchange -> ODM_BUCKET_LIST

• controllerStepExist = false

• buildOutboundVendorDetailMap

• true

• vendorAuditFailureMessages = new ArrayList accumulatorOutputList = odmResponse -> RtaOutput -> AccumulatorOutput

• false

• buildOutboundVendorDetailMap

• accumulatorOutputList = odmResponse -> rtaOutput -> list accumulatorOutput

• accumulatorOutput : accumulatorOutputList

•       accumulatorOutput -> mctrVal  !=  null &&  mctrValMap != null

• true

• End

• false

• entry : mctrValMap

• true

• false

•       accumulatorOutput -> mctrVal                   = entry -> Value 

• true

• false

• senderIdent = entry -> Key fetchNextSeqValueFromTransactionTable newTransCk = exchange -> trackingTableGeneratedTransCk outboundVendorDetailMap.put(senderIdent, newTransCk)

• true

• false

• exchange -> setProperties

•  requestString = outboundVendorDetailMap insertTrackingTableRtaInteractionAudit

• accumulatorOutput : accumulatorOutputList

• exchange -> setProperties

• false

• outboundVendorDetail = null  transCk = null senderIdent = EMPTY

• true

• accumulatorOutput -> mctrVal != null && mctrValMap != null

• entry : mctrValMap -> entry

• outboundVendorDetailMap != null && outboundVendorDetailMap != Empty

• false

• true

• false

• accumulatorOutput -> mctrVal = entry -> Value

• false

• senderIdent = entry -> Key

• true

• true