From 6421a07f2be1c18206d13c0332a38816f20d52be Mon Sep 17 00:00:00 2001
From: Bishwajeet Kumar Rajak <bishwajeet.rajak@tcs.com>
Date: Thu, 11 Jun 2026 00:43:44 +0530
Subject: [PATCH] first commit

---
 __pycache__/config.cpython-314.pyc            | Bin 0 -> 2584 bytes
 __pycache__/logging_config.cpython-314.pyc    | Bin 0 -> 1532 bytes
 api/api_client.py                             |  38 ++++++++
 config.py                                     |  32 ++++++
 .../oracle_connector.cpython-314.pyc          | Bin 0 -> 1460 bytes
 db/db.py                                      |  87 +++++++++++++++++
 db/oracle_connector.py                        |  23 +++++
 logging_config.py                             |  29 ++++++
 main.py                                       |  27 ++++++
 models/bank_mapping.py                        |   7 ++
 models/outward_log_model.py                   |  22 +++++
 processor/processor.py                        |  91 ++++++++++++++++++
 repository/repository.py                      |  50 ++++++++++
 requirements.txt                              |   2 +
 scheduler/scheduler.py                        |  29 ++++++
 15 files changed, 437 insertions(+)
 create mode 100644 __pycache__/config.cpython-314.pyc
 create mode 100644 __pycache__/logging_config.cpython-314.pyc
 create mode 100644 api/api_client.py
 create mode 100644 config.py
 create mode 100644 db/__pycache__/oracle_connector.cpython-314.pyc
 create mode 100644 db/db.py
 create mode 100644 db/oracle_connector.py
 create mode 100644 logging_config.py
 create mode 100644 main.py
 create mode 100644 models/bank_mapping.py
 create mode 100644 models/outward_log_model.py
 create mode 100644 processor/processor.py
 create mode 100644 repository/repository.py
 create mode 100644 requirements.txt
 create mode 100644 scheduler/scheduler.py

diff --git a/__pycache__/config.cpython-314.pyc b/__pycache__/config.cpython-314.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..9fdca69318c6c9e89c492680dc65621b20ced1fe
GIT binary patch
literal 2584
zcmah~O-vg{7@b|O|4mE?*q9`QKp=6OfY&w{NYuoDp%h}AG0+Ri%Ge9p#;l#)HEp6C
zxRpcIpQtLRm(o*{wo<uNN>8Ylsz*{s3Yv0=)E?TK8xCo2{btwe1S*vkym|A@o1fk9
zedE`U)VUBmjo$~~+29cRjdsij`ueli4$TU>fiN?UG}MGnBh2~{wnSM&pfQ-~Ktb+L
z+D&GSpn;ZZXKw>Y23EO_K#er^hDEdZPyzM8s+gT;umy8~R%`>bV+WuUy8zwT16YTT
z0D5sf;8ENFcnmiJHeny2A2$OAa0}pZd;;(!ZUsDr+W=4F_IXC*aEE5aXZ%RB;Z8t1
z?gDh+vzl`jX)b&Y-XKV9!v%RkS|rQ>;X)z4m#}<TXHj4go%I2WQWhEj)~hqB>(d!e
zn3yh$5XOjv31f(2AkxReA;R#wC=8*H&gh^K>nDu9We8R<_K6avUtheBF!~w7{M}18
zHLa))_Vh#}-QjR=H^t~+G#cp{PfetSYbCKH3S*)yDj7{G$UO_9mc1Fz=k<XsQ%wtP
zZ14|ha_qH3bOp`ThEmn^)&f8v^^h<#@v}&-X%3yo?we;C<M90~`{tRZM00NQT!-$=
zVXJxKX!XtE<n+DuXBMTrCV$yRs}z(DGm33s5<9Vv3<)#o1SW{Mfu`c=^xIQ-gxH`n
zl1`GQ)YRmpFrJ)F;Mw@3aCJO6Go45iwl9<nItg1)iEUBTM0uImbMrz;6&2zJQp~98
zy9FgjY|zQ6GO<XqMw*I+d|m)1D$AL?uq4SPO;pKIkSnSv%xC0VLbi~Dkn1IX$Pi8y
z^9w3{-7YdXJUBN4+o*HlSbr!Q>zx}B)mvJjI46q>ngAoqq9SPT$wE;nWJOh-%j#v&
zUA#ja0&Fg6f<U}RZFHLf`q9*RfEBds53Jp}e`h1`V5scxS>-<P>>fY)#lYtS8`n37
z%Ex1?+!IIhuCIAbx-V@w9<-Nz7eM6xz4P3+4c`U64s1u>`gx=ryjJeSRNB7N()zR|
z^tdHdZV9h)AA0v_2KKqu3IW}<Kj{ZJ)B~@$w#dvfDLVhagIUuZ^=O7IvE8V|j=qM_
z?e>)YfE2o>Kh9Q%7U47}&_oMDv+V!rlkCKKgq)}qRxh$0fTwgOp`eAhhT_QyVR&jJ
zk-j?(Hw=FsAWR`bAxfc_LLY?~g#iGbN_Z;asf4Ezo=SKs;rju?AqsFioey$KH=J4N
z0U%bjn3ptYG({=~ElNKPI(0t@5F<=hrIp&%)}{>5NxgKu*)+mI3;JPH9R~nMH2T)Y
z?~m_zns+?&dsa)6Yt>nCpfeY~y8Pwk&B&9ESlOF++!0&PY{h<vZ4G?t{Fqs@e`5d4
z3BkwS#I_^x&oADDN~`=Ef4r6Z(cTES&ja*ix(8PEEuoH~J@}aU$#v5FfTnh1y;RmT
z$EupzE%RT^qK9hcYL39jbj?lUXOO+yI+D>c^BGlaGs>uB+`(;2lB!DbViGbCf`t{H
zLKuK}a7osrB{88W1x1NL$f#WXqZ0=dzLd*oVyy(tKr2<!wN}uM_t;1GKDxJhZzKA&
zBLaWh9g#=Tt&3Y1A6?vSXx%<_x!iDN+jHeF3%WGMD3@ST(5m!7qaVRIjD9TY>}1eQ
zD__nmiBS12L0Br}N_omXf^fT($yZ0bg0LVds+N~zQ7*vn(VByWtMOE7JUK?ZqlxL^
zH-&36iJ62jgC~_ix+!&%G6q1J1h5+XN@azN1~#0h_ZwYF5VCo=5_3{k%ZhLZ3PFa{
zy%L0J^m@BuIFqJKp+H@s{sHj!`|w#RoGoD6aky7!D;CO{0_%MS>p1(sXE45Zb6IE4
z9G=yMiWPLvd@bvv20KG_dW?^58lx2(a(ZAzJ1BvJw$J3CwwWB(T`;%<IqP6$C)GQU
zpX#ez*X!J6tm&p27xD$xyDF4#b4`_c<ey<yrk-;)Yvg&o)jG<&IKo=vOa)QYbE&_2
vkTpu1eujt0h|{tqj!Q=V-cZuerC&{L1gKaThWQmaUvMXxIJ1W+>a+d@C9OE1

literal 0
HcmV?d00001

diff --git a/__pycache__/logging_config.cpython-314.pyc b/__pycache__/logging_config.cpython-314.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..e4e4f52faf6f7dc0e00c02b3a922256c8e71db7a
GIT binary patch
literal 1532
zcmbVMPjA~c6sKg`R^r5QY{yPAH;E&-h%n48iWDx2VuyCf8Z5{Rt;@-%q1ueAMV17L
zDbk({^s<kT0Rz_SKES@jPIY2T2D_b>%WlEk(=OYiEam@c58xx;zaJmT$M<P^dJ+NU
zf6>1CS4QYhAw&dnK%**5J@g#u(k5c#Sqf%(Q+^s_v1O#kiilwy1CQ&HinRD&B6M4m
zIIbJ)Wh(#*Spw!5jL|=mz-<5@laAKIbzRu6kS^(REwnGA29C^ifp>+<Xg$=pXb06N
zu9!i*5FgyYWsfM2Wf47f*(Rj=%ynI~<E7j(*Zs<HTM@o1UC1MQlW&CT$~$s>?z+d0
z6k!Fq7H{y7&pj^ecGIaAu1D)wPd<<9@mlyIZfqy^Kl3;{HPlN2YDD4Kays5KC=!Jn
zm>z37dvESm)(o%3%r4QqmCBk$UJ=VSLMdE)28J&2Jfj0nZ}I}<j^VnN*)o{v*i}$y
zGFQ6B!Q<DAcs%vOXzlI0Pn><5ZJP+aL)tVI=i%}0UfZNR2@xIB?(m5YVOy{!lq()A
z#qJz$Zf|_em6wLywg~ljyk!xC@`(+Hb`8eBclsMfiP3#J_TW<xdTyLF+U>}a(;Wsm
z+MNy4BB4^lJVhOcHANBtHnDq#n`}9@=U9YK?Sg+Z%0QI<3J`z%<YD7m4{~bUt39~8
zUc2A;f_Qt(aT_+-WlgZWBDBd4?50bd7Tj1PJZKYucg;@Kea)vK*?l+I9P*-zfE|b7
z{R*sye#gr9g|}NiF7$EX9e$4s16(=DF8EpXD61Z4E4{CVc*e)`eLVkT@u$)cr2)Qu
zrt$GoA1@8?%1Nf^XUa#J@=$p=ipjHy-sVRI%@q8!dX!d=)0N(rL!27J94-v78bB=e
z@#0|(q?6pDpHure)z8)Xx!O=!8qSu7`MJ|1%0Cz(oKN(&PA5@(*2lN{_|~C0z-#9S
zkAA~zBRCCeopl-z#QTd8cDDvB$5fB{UZjAz41FN_MNqlYwkA{2HfRc%XmX-5Jpq54
ziciERp^(A{rAweF!SHgx;7U_jKUF$Pl@6aBr&izNRr(3&wL}2OGvNzWqsQh+7aFK#
zz6dHdc%K0AXB5PZw^JT<o%X&(KBudICGzm*ft|)AN&0}&A5ifRH2*iAleCXjNm7Hz
F{{U^_GcEuC

literal 0
HcmV?d00001

diff --git a/api/api_client.py b/api/api_client.py
new file mode 100644
index 0000000..3cb77c4
--- /dev/null
+++ b/api/api_client.py
@@ -0,0 +1,38 @@
+import requests
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class FetchQueueClient:
+
+    def __init__(self, config):
+        self.url = config.FETCH_QUEUE_URL
+
+    def fetch(self, payload):
+        logger.info("API request payload: %s", payload)
+
+        try:
+            response = requests.post(
+                self.url,
+                json=payload,
+                verify=False,
+                timeout=20
+            )
+
+            logger.info("API status: %s", response.status_code)
+
+            if not response.ok:
+                logger.error("API error response: %s", response.text)
+
+            response.raise_for_status()
+
+            result = response.json()
+
+            logger.debug("API full response: %s", result)
+
+            return result
+
+        except Exception:
+            logger.exception("API call failed")
+            raise
+``
\ No newline at end of file
diff --git a/config.py b/config.py
new file mode 100644
index 0000000..5c31879
--- /dev/null
+++ b/config.py
@@ -0,0 +1,32 @@
+import os
+
+class Config:
+
+    BANK_CODE_MAPPING = {
+        "9": "0015", "12": "0014", "13": "0016", "14": "0009",
+        "15": "0005", "16": "0001", "7": "0013", "6": "0002",
+        "5": "0007", "17": "0020", "1": "0012", "10": "0017",
+        "11": "0018", "2": "0003", "4": "0004",
+        "8": "0006", "3": "0021"
+    }
+
+    FETCH_QUEUE_URL = "https://43.225.3.224:443/IPKS_Queue_Generation/fetchAllQueue"
+
+    def __init__(self):
+        self.db_user = os.getenv("DB_USER", "")
+        self.db_password = os.getenv("DB_PASSWORD", "")
+        self.db_dsn = os.getenv("DB_DSN", "")
+
+        self.poll_interval_minutes = int(os.getenv("POLL_INTERVAL_MINUTES", "60"))
+        self.bank_codes = self._parse_bank_codes()
+
+    def _parse_bank_codes(self):
+        codes_str = os.getenv(
+            "BANK_CODES",
+            "0001,0002,0003,0004,0005,0006,0007,0009,0012,0013,0014,0015,0016,0017,0018,0020,0021"
+        )
+        return [c.strip() for c in codes_str.split(",") if c.strip()]
+
+    def validate(self):
+        if not self.db_user or not self.db_password or not self.db_dsn:
+            raise RuntimeError("Database configuration missing")
\ No newline at end of file
diff --git a/db/__pycache__/oracle_connector.cpython-314.pyc b/db/__pycache__/oracle_connector.cpython-314.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..415bbdee5c21e5ae59723476efe269632e010cf9
GIT binary patch
literal 1460
zcmZ`(Pj4Gl5T9MI*Xua3Q(~t!X&a{zrYoW<LP0?YBBWNLQKVq4M0=>?r_Fk8Eo^q(
zx6e@bfP5pBDnd^cC(iu<e2<1A*?N=%;>0bgk;;*o^`8=pj&^@L^Jd=6yqS6XUUp#)
zkn%s9Uw*3s{7J%uv@tW>L8b?Fu#{a8^i_A2TdGi3;Xqx3gT$6HvJ_eY*1$?!1WVgO
zZ$u(#DeGV+{~}@ERODRC70eG?EtfmAHleW(7;fN-jqwgZC>98{u8YJngc$uI2+dLv
zlU73Lw?U*VjeN`8=iGLD_eK~5t|LP3jDyF%iBA9+!!j~GxU(3<%LEqOhF}sHC3L3j
zKUJmfghA75Nv$1*zNtzra{VSZa7RSmDi!(JjgM+yL@tkN?{9y&xwZX4?WP-jCBk+s
zaGQdm=4+QTaX(;f9y)Fm)f$JjFwT;p^HG}D+g)ie<^`T$OcrMjaebnR<7P2#4+hJZ
z9%Tmk;<5I9dWb9FOtVKJjc<I?9bE0<*{WnRL+_5|Rs?VfYST(plQV`WS}<wtD%A9e
zzDfzr&>BUHN9nwxI)7d!=?#{2!Wnvl<>HJPigl%)tSgqXJ<byQIyL(LI#idY22*Bh
z%;6lU57u|FFP`mt54@mN9yO;t?wuC~<#;x9sdcc~(rDXJ^i9YcGSP?vnK<$Y?E5n9
z1rB$Q+(4LfoEjwc(eO*n3!0%cMnlm!lo_<Mh0DlqJZm!5IApQ+3^LOIItmmcWjpse
z9(PTJQ{f|;gbL44h%DW)*Qv@Yv!iuhPd$o41RSv3(n<HEd)$37|JKRg!@Xz4Pkx=>
zc~LC)iyOZbHwJ~$le>@a_6yfe3)cpv%RjCBxY93eo|ZOoD4*;--s|Tpr}@etU!dph
zmA@BKrR?#|N4sZ>u$VvTKJ4~$<<ngGdG6{n<0_|?^Ay6qY0ymw>?0R%!W?5qVWZ;{
zKhM~`j_r>%ImVhEkA&|9ZV)oYDRq7YK^7Q`ge^RW*+Ovdup`_E_g`Sl@v%1z&k>I6
z`;6f~XyHGLxQ#0JX<Ru@mmmh3qbQH?&v#gsmztU^y)rV%^)o;iB~G@c&WrewS!ycI
z2~{2c92~D9@G`+N0hvC9(YCll#>b-*?r;-Tlt8qKaF$RM<u}Ov4)6StUi#tI^YrDO
O{z|)`tPcSpcJMD|M?v)f

literal 0
HcmV?d00001

diff --git a/db/db.py b/db/db.py
new file mode 100644
index 0000000..72608a3
--- /dev/null
+++ b/db/db.py
@@ -0,0 +1,87 @@
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class OracleDB:
+
+    def __init__(self, connector):
+        self.connector = connector
+
+    def fetch_all(self, sql, params=None):
+        conn = None
+        cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+
+            cur.execute(sql, params or {})
+
+            cols = [c[0] for c in cur.description]
+            rows = [dict(zip(cols, r)) for r in cur.fetchall()]
+
+            logger.info("Fetched %s rows from database", len(rows))
+
+            return rows
+
+        except Exception:
+            logger.exception("Error in fetch_all")
+            raise
+
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
+
+    def execute(self, sql, params):
+        conn = None
+        cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+
+            cur.execute(sql, params)
+            conn.commit()
+
+            logger.info("Insert/Update executed successfully")
+
+        except Exception:
+            if conn:
+                conn.rollback()
+            logger.exception("Error executing SQL")
+            raise
+
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
+
+    def call_procedure(self, name):
+        conn = None
+        cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+
+            logger.info("Calling procedure %s", name)
+
+            try:
+                cur.callproc(name)
+            except Exception:
+                cur.execute(f"BEGIN {name}; END;")
+
+            conn.commit()
+
+            logger.info("Procedure executed successfully")
+            return True
+
+        except Exception:
+            logger.exception("Procedure call failed")
+            return False
+
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
\ No newline at end of file
diff --git a/db/oracle_connector.py b/db/oracle_connector.py
new file mode 100644
index 0000000..9ef0856
--- /dev/null
+++ b/db/oracle_connector.py
@@ -0,0 +1,23 @@
+import oracledb
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class OracleConnector:
+
+    def __init__(self, config):
+        self.config = config
+        self.pool = None
+
+    def get_connection(self):
+        if not self.pool:
+            logger.info("Initializing Oracle connection pool")
+            self.pool = oracledb.create_pool(
+                user=self.config.db_user,
+                password=self.config.db_password,
+                dsn=self.config.db_dsn,
+                min=1,
+                max=5,
+                increment=1
+            )
+        return self.pool.acquire()
\ No newline at end of file
diff --git a/logging_config.py b/logging_config.py
new file mode 100644
index 0000000..8c76ad9
--- /dev/null
+++ b/logging_config.py
@@ -0,0 +1,29 @@
+import logging
+import logging.handlers
+from pathlib import Path
+
+def setup_logging():
+    Path("logs").mkdir(exist_ok=True)
+
+    root_logger = logging.getLogger()
+    root_logger.setLevel(logging.INFO)
+    root_logger.handlers.clear()
+
+    formatter = logging.Formatter(
+        "%(asctime)s %(levelname)s %(name)s - %(message)s"
+    )
+
+    console = logging.StreamHandler()
+    console.setFormatter(formatter)
+    root_logger.addHandler(console)
+
+    file_handler = logging.handlers.RotatingFileHandler(
+        "logs/application.log",
+        maxBytes=10 * 1024 * 1024,
+        backupCount=5
+    )
+    file_handler.setFormatter(formatter)
+    root_logger.addHandler(file_handler)
+
+def get_logger(name):
+    return logging.getLogger(name)
\ No newline at end of file
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..17e3fd6
--- /dev/null
+++ b/main.py
@@ -0,0 +1,27 @@
+from logging_config import setup_logging
+from config import Config
+from db.oracle_connector import OracleConnector
+from db.db import OracleDB
+from repository.repository import Repository
+from api.api_client import FetchQueueClient
+from processor.processor import Processor
+from scheduler.scheduler import Scheduler
+
+def main():
+    setup_logging()
+
+    config = Config()
+    config.validate()
+
+    connector = OracleConnector(config)
+    db = OracleDB(connector)
+    repo = Repository(db)
+    api = FetchQueueClient(config)
+
+    processor = Processor(config, repo, api)
+    scheduler = Scheduler(processor, config)
+
+    scheduler.run()
+
+if __name__ == "__main__":
+    main()
\ No newline at end of file
diff --git a/models/bank_mapping.py b/models/bank_mapping.py
new file mode 100644
index 0000000..ce1f3a6
--- /dev/null
+++ b/models/bank_mapping.py
@@ -0,0 +1,7 @@
+class BankMapping:
+
+    def __init__(self, mapping):
+        self.reverse = {v: k for k, v in mapping.items()}
+
+    def get_dccb(self, bank_code):
+        return self.reverse.get(bank_code)
\ No newline at end of file
diff --git a/models/outward_log_model.py b/models/outward_log_model.py
new file mode 100644
index 0000000..9b867b2
--- /dev/null
+++ b/models/outward_log_model.py
@@ -0,0 +1,22 @@
+class OutwardLogModel:
+
+    def __init__(self, bank, r, api):
+        self.bankcode = bank
+        self.jrnl_id = api.get("journalId")
+        self.ref_no = api.get("remarks")
+
+        self.tran_date = r["TXN_DATE"].strftime("%d%m%Y")
+        self.txn_amt = float(r["TXN_AMT"])
+
+        self.recv_ac = r["DEST_AC_NO"]
+        self.send_ac = api.get("accountNum")
+
+        self.ifsc = r["IFSC_CODE"]
+        self.sender_name = r["REMITTER_NAME"]
+        self.receiver_name = r["BENEFICIARY_NAME"]
+        self.beneficiary_address = r["BENEFICIARY_ADD"]
+
+        self.sender_info = api.get("sendeReceiverInfo")
+
+    def to_dict(self):
+        return self.__dict__
\ No newline at end of file
diff --git a/processor/processor.py b/processor/processor.py
new file mode 100644
index 0000000..fd9178d
--- /dev/null
+++ b/processor/processor.py
@@ -0,0 +1,91 @@
+from logging_config import get_logger
+from models.bank_mapping import BankMapping
+from models.outward_log_model import OutwardLogModel
+
+logger = get_logger(__name__)
+
+class Processor:
+
+    def __init__(self, config, repo, api):
+        self.config = config
+        self.repo = repo
+        self.api = api
+        self.mapping = BankMapping(config.BANK_CODE_MAPPING)
+
+    def process(self):
+        total_inserted = 0
+
+        logger.info("Starting processing...")
+
+        for bank_code in self.config.bank_codes:
+
+            try:
+                logger.info("Processing bank %s", bank_code)
+
+                dccb = self.mapping.get_dccb(bank_code)
+
+                if not dccb:
+                    logger.error("No mapping for bank %s", bank_code)
+                    continue
+
+                records = self.repo.get_records(dccb)
+
+                if not records:
+                    logger.info("No records found for bank %s", bank_code)
+                    continue
+
+                payload = {
+                    "bankCode": bank_code,
+                    "rrn": "090686552",
+                    "branchCode": str(records[0]["BR_CODE"]).zfill(3),
+                    "itemType": 1,
+                    "queueType": "02",
+                    "reterieveTop": "20"
+                }
+
+                response = self.api.fetch(payload)
+
+                if response.get("status") != "SUCCESS":
+                    logger.error("API error for bank %s", bank_code)
+                    continue
+
+                items = response.get("response", {}).get("VwQueueItems", [])
+
+                api_map = {
+                    (int(x["queueItemId"]), float(x["txnAmt"])): x
+                    for x in items
+                }
+
+                for r in records:
+
+                    key = (int(r["CBS_QUEUE_NO2"]), float(r["TXN_AMT"]))
+                    item = api_map.get(key)
+
+                    if not item:
+                        continue
+
+                    if item.get("status") != "Processed":
+                        continue
+
+                    ref = item.get("remarks")
+
+                    if not ref:
+                        continue
+
+                    if self.repo.exists_by_ref(ref):
+                        logger.info("Duplicate ref %s", ref)
+                        continue
+
+                    model = OutwardLogModel(bank_code, r, item)
+
+                    self.repo.insert_outward_log(model.to_dict())
+                    total_inserted += 1
+
+                    logger.info("Inserted ref %s", ref)
+
+            except Exception:
+                logger.exception("Error processing bank %s", bank_code)
+
+        logger.info("Processing completed total inserted %s", total_inserted)
+
+        return total_inserted
diff --git a/repository/repository.py b/repository/repository.py
new file mode 100644
index 0000000..cc81719
--- /dev/null
+++ b/repository/repository.py
@@ -0,0 +1,50 @@
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class Repository:
+
+    def __init__(self, db):
+        self.db = db
+
+    def get_records(self, dccb):
+        logger.info("Fetching records for DCCB=%s", dccb)
+
+        return self.db.fetch_all("""
+        SELECT TXN_DATE,DCCB_CODE,BR_CODE,SRC_AC_NO,DEST_AC_NO,
+               IFSC_CODE,TXN_AMT,BENEFICIARY_NAME,
+               BENEFICIARY_ADD,REMITTER_NAME,CBS_QUEUE_NO2
+        FROM NEFT_RTGS_TXN_QUEUE
+        WHERE DCCB_CODE = :d
+        AND TRUNC(TXN_DATE)=TRUNC(SYSDATE)
+        """, {"d": dccb})
+
+    def exists_by_ref(self, ref):
+        logger.debug("Checking duplicate REF=%s", ref)
+
+        res = self.db.fetch_all(
+            "SELECT 1 FROM outward_neft_api_log WHERE REF_NO=:r",
+            {"r": ref}
+        )
+
+        return len(res) > 0
+
+    def insert_outward_log(self, d):
+        logger.debug("Insert data: %s", d)
+
+        self.db.execute("""
+        INSERT INTO outward_neft_api_log(
+        BANKCODE,TXNCODE,TXNIND,JRNL_ID,REF_NO,TRAN_DATE,
+        TXN_AMT,RECVR_ACCT_NO,SENDER_ACCT_NO,
+        RECIEVER_IFSC,SENDER_NAME,RECIEVER_NAME,
+        BENEFICIARY_ADDRESS,SENDER_TO_RECIVER_INFO,MSG_TYPE
+        )
+        VALUES (
+        :bankcode,'OUTWARD NEFT','DR',:jrnl_id,:ref_no,:tran_date,
+        :txn_amt,:recv_ac,:send_ac,
+        :ifsc,:sender_name,:receiver_name,
+        :beneficiary_address,:sender_info,'N06')
+        """, d)
+
+    def call_proc(self):
+        return self.db.call_procedure("neft_api_txn_post")
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..0e3667f
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,2 @@
+oracledb==2.0.0
+requests
\ No newline at end of file
diff --git a/scheduler/scheduler.py b/scheduler/scheduler.py
new file mode 100644
index 0000000..e7320c5
--- /dev/null
+++ b/scheduler/scheduler.py
@@ -0,0 +1,29 @@
+import time
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class Scheduler:
+
+    def __init__(self, processor, config):
+        self.processor = processor
+        self.config = config
+
+    def run(self):
+        logger.info("Scheduler started")
+
+        while True:
+            try:
+                count = self.processor.process()
+
+                logger.info("Inserted count %s", count)
+
+                if count > 0:
+                    logger.info("Calling procedure")
+                    self.processor.repo.call_proc()
+
+            except Exception:
+                logger.exception("Scheduler error")
+
+            logger.info("Sleeping for next cycle")
+            time.sleep(self.config.poll_interval_minutes * 60)