Skip to content

Latest commit

 

History

History
62 lines (47 loc) · 3.79 KB

check_funds_with_bank.md

File metadata and controls

62 lines (47 loc) · 3.79 KB
description layout
Triggered by Batch job
title description tableOfContents outline pagination
visible
true
visible
visible
true
visible
true
visible
true

check_funds_with_bank

Trigger

  • check_funds_with_bank API invoked by check_funds_with_bank_worker (Celery worker task)
  • Worker invoked by
    1. check_funds_with_bank_beat_producer (Celery beat producer)

check_funds_with_bank_beat_producer

Business logic

frequencyhourly (specified by configuration yml)
retriesyes. subject to a configurable limit specified by configuration yml
driving tabledisbursement_envelope_batch_status
eligible envelopes

envelope.disbursement_schedule_date < today
AND

envelope.cancellation_status = 'NOT_CANCELLED'

AND

envelope.number_of_disbursements = batch_status.number_of_disbursements_received

AND

envelope.total_disbursement_amount = batch_status.total_disbursement_amount_received

AND

(
( funds_available_status = "pending_check" AND funds_available_attempts < retry_limit)
OR
( funds_available_status = 'not_available" AND funds_available_attempts < retry_limit)
)

  1. Pick up Eligible - disbursement_envelope
  2. Delegate a task to bank_check_funds_worker
  3. Payload - disbursement_envelope_id

check_funds_with_bank_worker

  1. Payload - disbursement_envelope_id
  2. get the details of the disbursement_envelope - total funds needed for this envelope
  3. get details from benefit_program_configuration
  4. get the instance of BankConnector (implementing BankConnectorInterface) from BankConnectorFactory
  5. BankConnectorInterface - There will be a connector (implementation of the BankConnectorInterface) for every Sponsor Bank
  6. Invoke - Check Funds API

SUCCESS and FUNDS_AVAILABLE, update the following

  1. disbursement_envelope_batch_status.funds_available_with_bank = funds_available
  2. disbursement_envelope_batch_status.funds_available_latest_timestamp = now()
  3. disbursement_envelope_batch_status.funds_available_latest_error_code = null
  4. disbursement_envelope_batch_status.funds_available_attempts+ = 1

SUCCESS and FUNDS_UNAVAILABLE, update the following

  1. disbursement_envelope_batch_status.funds_available_with_bank = funds_not_available
  2. disbursement_envelope_batch_status.funds_available_latest_timestamp = now()
  3. disbursement_envelope_batch_status.funds_available_latest_error_code = null
  4. disbursement_envelope_batch_status.funds_available_attempts+ = 1

FAILURE, update the following

  1. disbursement_envelope_batch_status.funds_available_with_bank = pending_check
  2. disbursement_envelope_batch_status.funds_available_latest_timestamp = now()
  3. disbursement_envelope_batch_status.funds_available_latest_error_code = error_code
  4. disbursement_envelope_batch_status.funds_available_attempts+ = 1