updated config
This commit is contained in:
@@ -35,4 +35,3 @@ class FetchQueueClient:
|
|||||||
except Exception:
|
except Exception:
|
||||||
logger.exception("API call failed")
|
logger.exception("API call failed")
|
||||||
raise
|
raise
|
||||||
|
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ class Config:
|
|||||||
def _parse_bank_codes(self):
|
def _parse_bank_codes(self):
|
||||||
codes_str = os.getenv(
|
codes_str = os.getenv(
|
||||||
"BANK_CODES",
|
"BANK_CODES",
|
||||||
"0001"
|
"0012"
|
||||||
)
|
)
|
||||||
return [c.strip() for c in codes_str.split(",") if c.strip()]
|
return [c.strip() for c in codes_str.split(",") if c.strip()]
|
||||||
|
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ class OutwardLogModel:
|
|||||||
self.receiver_name = r["BENEFICIARY_NAME"]
|
self.receiver_name = r["BENEFICIARY_NAME"]
|
||||||
self.beneficiary_address = r["BENEFICIARY_ADD"]
|
self.beneficiary_address = r["BENEFICIARY_ADD"]
|
||||||
|
|
||||||
self.sender_info = api.get("sendeReceiverInfo")
|
self.sender_info = r["TXN_NO"]
|
||||||
|
|
||||||
def to_dict(self):
|
def to_dict(self):
|
||||||
return self.__dict__
|
return self.__dict__
|
||||||
@@ -11,7 +11,7 @@ class Repository:
|
|||||||
logger.info("Fetching records for DCCB=%s", dccb)
|
logger.info("Fetching records for DCCB=%s", dccb)
|
||||||
|
|
||||||
return self.db.fetch_all("""
|
return self.db.fetch_all("""
|
||||||
SELECT TXN_DATE,DCCB_CODE,BR_CODE,SRC_AC_NO,DEST_AC_NO,
|
SELECT TXN_NO,TXN_DATE,DCCB_CODE,BR_CODE,SRC_AC_NO,DEST_AC_NO,
|
||||||
IFSC_CODE,TXN_AMT,BENEFICIARY_NAME,
|
IFSC_CODE,TXN_AMT,BENEFICIARY_NAME,
|
||||||
BENEFICIARY_ADD,REMITTER_NAME,CBS_QUEUE_NO2
|
BENEFICIARY_ADD,REMITTER_NAME,CBS_QUEUE_NO2
|
||||||
FROM NEFT_RTGS_TXN_QUEUE
|
FROM NEFT_RTGS_TXN_QUEUE
|
||||||
|
|||||||
Reference in New Issue
Block a user