From fe29ff0c5767edb8e0b9348423a709cbdf04255d Mon Sep 17 00:00:00 2001
From: Bishwajeet Kumar Rajak <bishwajeet.rajak@tcs.com>
Date: Tue, 5 May 2026 23:18:54 +0530
Subject: [PATCH] product

---
 __pycache__/config.cpython-314.pyc         | Bin 0 -> 2025 bytes
 __pycache__/db.cpython-314.pyc             | Bin 0 -> 2554 bytes
 __pycache__/logging_config.cpython-314.pyc | Bin 0 -> 655 bytes
 api_client.py                              |  18 ++++++
 config.py                                  |  22 +++++++
 db.py                                      |  69 +++++++++++++++++++++
 logging_config.py                          |  10 +++
 main.py                                    |  26 ++++++++
 oracle_connector.py                        |  37 +++++++++++
 processor.py                               |  61 ++++++++++++++++++
 repository.py                              |  60 ++++++++++++++++++
 requirements.txt                           |   2 +
 scheduler.py                               |  40 ++++++++++++
 13 files changed, 345 insertions(+)
 create mode 100644 __pycache__/config.cpython-314.pyc
 create mode 100644 __pycache__/db.cpython-314.pyc
 create mode 100644 __pycache__/logging_config.cpython-314.pyc
 create mode 100644 api_client.py
 create mode 100644 config.py
 create mode 100644 db.py
 create mode 100644 logging_config.py
 create mode 100644 main.py
 create mode 100644 oracle_connector.py
 create mode 100644 processor.py
 create mode 100644 repository.py
 create mode 100644 requirements.txt
 create mode 100644 scheduler.py

diff --git a/__pycache__/config.cpython-314.pyc b/__pycache__/config.cpython-314.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..1525439e7404cd0bce363c2e7976665b470f9847
GIT binary patch
literal 2025
zcmah}O>7fK6rQy=wi7!95^Q7sAp~$M9RIB2Bv2YBHq;OtGmgW>Fk0K|WQDypyK4{;
zhuoS&B_u8&E=_MxRVqhrTzia~szuWrkT_Jmxy=ENeKYG#p*=9Nzy0RDZ{Ez#`|Qv6
z3=SX|<3InQe&<B!Et}Xw?2(<5K-SPLgoPY3ksqBv*bzk7DLE{KDPUm~g~dPFG+(uX
z7D7!vcAmmRhAKA^sFCTo<usiE)I#G>6+0>dc485*54!-}*aO&)2LQd;2RMlL01n~3
zfcx+;;0WFi=*I!TAU*&X!Uq8l;lqGO@KL~H_&DGRe6k{#A|5sS@Tnj&U3d)8jZd4N
zC1m#FGjR5^)HT=A>gqBTrl=T=#*)+#i*qIcOK>&;OkylL1uV%K(@k&|qe6<y5>&7v
zaVl7%6o_~(9;HHzi{cQ9a>kNYY?2Cm%P3T^_K~PC$%{`=fuA8BTfMMinr&lxd|XOI
z;_+mJp)@T?iSb<FYLQ&;C>@1dRy0MIO|_+s*A=t6l5RA3qAK(n!X7U8LW4Xz?}4nL
zGK=w1=rz`!vnMniT4lF<32D2UPp)%(w9dA~r}qO(e6XKwM^yIO=lbN%U?;nR)O&L{
zIeTwDup3(Mq3+BqDHXGry4!NqAhinhLZpx`7H=%z40XXIQ_Qc<n2KSl?b}AJ5~-%{
zq-siCt}BWhk=y5tR>xd97mMgMBO*8D)s`mTGa}Vib2^rc$9QKlv(#T$n4c%P{9+a_
zrRT}DT)woJEmB7!nh(3Fqh(OnvSKRQUFxn?NXJlg>IKr44dY%*uTd9FYKBIgs%BDu
zyVYnAV2XZMZjh#`b>M){1u7a!qi(R*JxvpH)8!J>G0O4OWK>Ee%NfPEZMNFweD=~J
zStu>uNaGB-vM^h&a{ou#_o;_KS=A(j4p~2nh#lAiMU5iB8rlwq9^Zd-e<SoPw-uaN
z7r*gsA3E~w)YGYrn=f)(hc2#*zjzL82M#<|AE_Ij&CeQJfhMTD+hb>c82&NzeP}ar
z<)_S6`1;luUKfA$oZMk8`N*HlDcqmye8(kJV3PlgGrf6j457maG`qh1SGcPg>1lSo
z^ncB=k7>$oJA;w!oE7VD&arwlBb#zXHk9Mmopr2V+VQ4p7^=3M4~u#fmg_MFaRBPW
z9nDmmN><lfx}JoP)gL{@vL5K4T9Zv>_rC4Gex_u#*3j#rk%tc+K3IRSA^kR*fY0V=
z;-&QJ{HyaX&u<SO-8}Z?*6_@xZ{{y2x^P+0r(qGCgY9megP%x(X+Au_I;_b}1v)%H
zNV8SzG#K|0a;GCVdYK_Y>Z)#-4OLUL7Nqyhrt??H+(ITxuB8iwT>dg0x|Cg<`-)sI
zWlLF7!t?qh+wThi>L<i7;UB0<WYg5u3Nt4wLP)g%ey*uiv#NlBNm!tR9|U0;v+fMP
z8l5$Y1M`CM7U2EYa2Z{PE983Z@vbj*os9WIPbMrjdgfWcVzK0lyPUo8_}1&)KG3}h
z9DH)gVyBpn$70e8E8BIUejikHgAzDsCu|OCm(8JW-Qph9KM0lkncjnfOyA>N&-s8=
z)5|miC=hyby36>c=<n`D!IH4H@V6-T6@_;`M_*d#B8I$q{H?<dJ!0R$b7aLW%UrO!
fc2Unko?V#1ywY_Fg77=)e<zLzX<-L3<g5Mx@N?Q)

literal 0
HcmV?d00001

diff --git a/__pycache__/db.cpython-314.pyc b/__pycache__/db.cpython-314.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..3c2918cc53163164eba0439fac1135c3ee9e38a1
GIT binary patch
literal 2554
zcmbVO%}*Ow5TE_B*BESYfY>2`Nfe6J6rw^)TB3Xy5+wyWXq&(xCR?*!$f}Fiyj?44
zPN<iH6oo{Ml%|*Tid3mRR=uTvK?o>Vuj!%cq3R7mq$KU7^Y#N=l(bSu^1L_i&6}C`
z=C?C`JJwJKNbj%zZj6ZlzcC>olwI2X1cwE<3JP}t95(V7xbwWjcfu6k1yjNR=P5ek
z6pXv}JUQT9FyK!+p#{1?5%z;34)Fe|kis2?jPwT+a~Y1-&FYS7TC=k{(fo7n;Cq4X
z<0uv|qA74V1swir#1UG-!ua-sBPu*{iTQ9siikX{NRB)KPDBZzpD>j#l7eRHBU#Ol
zz_rfi0)V`o#>oOqHkRCF#uS)<Qs5n>!?42TR(KlHtkR4zOGO+@8J>!^ZqAShp0Js<
z?rz#Q{9*pGtrI){?%?rb1B377M|AsB$13M@XU|<yFJ8Vhc}5vgKf0LB7pHs6pHW#=
zjgsN0Ds2j)><yOK%i1wy3s7x6cq>|MPA-bKBipzF+D>>Vgz)EH<pi!SKpW(lic90Q
zSN7Ms@OtB-FVqa<%+4NqgQmPk4aGNTz6Kr&3}Up5@R@gf=GjeM8gB|_yQ9Jdpz8!h
zIt*#ZCxYD&6gvP8LYb?v(Gu+LjtZ{`ia6-MNGDuFOJ(j9XK)4#3GHBTnNUWcVg(aO
z<#NHcuUn)@g`!=$d1M$<u4|57OgmQEOI3O#o37YKX*O-S04q-4O!_+vAgFCvrSwd}
zF!kak#JQ~B&@kIGRxT5za&U%*ePtI&G+dlk-2kFE*@+>90)|1@YtoSStx%EKqLH&V
zG`-ARQAsDnA{m}UnHr~is7#Z36iF*vYxLq9$@cnA*`wPwvIW@WBay_jWO^gn^Ca0*
zZAsm~a`(zcOV4UcPc_y4u<b$HM(WsV>KMZC{^;G&jppvv=I-ZVF%?@Jxpm=r9W?A)
z9$gxJoILfk{`AXd@#J&h(O`XId2DIyajO4^;^NqP{cyFu>90)*cmA}K==bw8eP{aN
zQGYbsCOkTs%(e<YwMsbu$G6HpF&E$r1PcsmxUiSTeNfe|2X&~-Pw?YX?T$B}sDTw~
z?0|7svk@)}6}}fL{5gEp`TnbL^uX?Jjvs9Rh(HIF#j=1FSfqO>hyg80zNP&DWhu|H
z<We4Ocr<x7sFDHP(L>7j5GqUPAs*=Nj)8|xn81ox!8%>x%YqTiBm*)WVX)80K7zCg
zu`NQw`VC#HI693Mbz38b2P1h#ceHB-)1+e2&>Sk<G|E)cOv~0YVGmn^J#SJ0tx!&5
z<<PV#N2o}w>$V+6N8R0NMlSMb#I>g~gNYsd?X0oav@6K4%Ec1P#*(oS>sXC-ti{rc
zLRF3~N0*{^hS%j}wWI5y^|iGY?|oo>)pV!pzIaD`U@eM|<Gt0Recz3(jD4G1iw~{j
zzL~!#-uw8g<}dS48xO7In8pw@6j_R35smL#jK10mLu2178XvM*5`JvTHj0lr+p{gA
zRtq9lBVE{i?}qn3U?)rnuY=uWB1ki)?Db$~uegV5(k%QN(6B;c%OcD|MsgEQx^PYo
zA!9vkZq9JXTWnW!vq^f~jdFn$=4_Hd!Dct_#w2>B!#%iLI(*QuRr>>E|B<+KRjy}m
zzab}A<>b12z|Y0)C}CJ8te506b*vSZ3UfNP!a7x*vx*gy&FfWlzEUv#ow%yb7{qo=
zqokKCRVD1paZ4NNWivO@7FD&Kf@5fE!EuN&jR3b<gH=_{#G=kHt?8zzs#ud7Y8LSr
zmKQkfU7A%3!kF9NvBAL0FYu~cJTIlT<T@#_l?+MEFB(Ouc@vO%mthC+BVpZ###o)k
z_Ml>|#lH=NL5r{?5{7x2a2vnZ1~4*1FFCHi74S^4s!in+-b<V$CsAbK+3z6R6gZCi
p8REadkzXVG?wntXv@e7<L%>BgpzR5?twZ|@v7Kw)24t?ezX9M@_9p-U

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..c946e28a6d20b224cca3bda97570b1f8284b241f
GIT binary patch
literal 655
zcmah`K}#D!6rS0gq}A0_EhSI_#)L=~QH!Lc)Kbu>pvXp+s0Y`EbvrIgH`y?=Db!Q0
zJ@wkZ(0^0nAu{GxsPtBvLa%)@*%WVmFyFj+-}~O1d9#w4okn2m{kz~h?BC>JVp`&i
zo`TauZ;*}mQH*RYi(+i+fSQeq$Rs~xqU9y&YD)p?utqjO4>>9*;b>CzUj(70`#iZv
zB(4petBGzA`a@6sYNJ$kxfcg5YV!P9sT|VxG;F)_c%Cnn$6kIF+!p2B^&xI*BBjzq
z`Z8iIH?~Y&JP0G-58A#kE?gdXwWxg=_=4<Pd-X49ByS)#YcHK+P8oMLsxO{Zs?VJr
z%HPFN$FX+z8qNA~<8;g3X&%(KoupXPQ)SjVAH*!DaktY<2sQ%+<zV=Ds6%25NVZS1
z!_1RU;m7diQSDDkPo<gs77qhVOp4S**TDJzL{Cs9QNy&bWoj%9Ix*$b_z)gUnTZ9F
zL*g=RnHiFu23FmaGByW+DOmh5Ko1R#g@KXl8@bPoYoqX$6x0n(U6oa@QVJ#|iW*mZ
j_^K7X?S}L<n+HO+;tK#jb&T;X%KRb(r+?32TvVFB$R2?B

literal 0
HcmV?d00001

diff --git a/api_client.py b/api_client.py
new file mode 100644
index 0000000..fc6f3d0
--- /dev/null
+++ b/api_client.py
@@ -0,0 +1,18 @@
+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):
+        response = requests.post(
+            self.url,
+            json=payload,
+            verify=False,
+            timeout=20
+        )
+        response.raise_for_status()
+        return response.json()
diff --git a/config.py b/config.py
new file mode 100644
index 0000000..2b3853b
--- /dev/null
+++ b/config.py
@@ -0,0 +1,22 @@
+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", "pacs_db")
+        self.db_password = os.getenv("DB_PASSWORD", "pacs_db")
+        self.db_dsn = os.getenv("DB_DSN", "testipksdb.c7q7defafeea.ap-south-1.rds.amazonaws.com:1521/IPKSDB")
+        self.poll_interval_minutes = int(os.getenv("POLL_INTERVAL_MINUTES", "30"))
+
+    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.py b/db.py
new file mode 100644
index 0000000..3d3fa0d
--- /dev/null
+++ b/db.py
@@ -0,0 +1,69 @@
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class OracleDB:
+    def __init__(self, connector):
+        self.connector = connector
+
+    def fetch_all(self, sql):
+        conn = cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+            cur.execute(sql)
+            cols = [c[0] for c in cur.description]
+            return [dict(zip(cols, r)) for r in cur.fetchall()]
+        except Exception:
+            logger.error("Error executing fetch_all", exc_info=True)
+            raise
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
+
+    def execute(self, sql, params):
+        conn = cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+            cur.execute(sql, params)
+            conn.commit()
+        except Exception:
+            if conn:
+                conn.rollback()
+            logger.error("Error executing SQL", exc_info=True)
+            raise
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
+
+    def call_procedure(self, proc_name):
+        conn = cur = None
+        try:
+            conn = self.connector.get_connection()
+            cur = conn.cursor()
+            logger.info("Calling stored procedure: %s", proc_name)
+            try:
+                cur.callproc(proc_name)
+            except Exception:
+                cur.execute(f"BEGIN {proc_name}; END;")
+            conn.commit()
+            logger.info("Stored procedure %s executed successfully", proc_name)
+            return True
+        except Exception as e:
+            logger.error(
+                "Stored procedure %s failed: %s",
+                proc_name,
+                str(e),
+                exc_info=True
+            )
+            return False
+        finally:
+            if cur:
+                cur.close()
+            if conn:
+                conn.close()
diff --git a/logging_config.py b/logging_config.py
new file mode 100644
index 0000000..9ac480f
--- /dev/null
+++ b/logging_config.py
@@ -0,0 +1,10 @@
+import logging
+
+def setup_logging():
+    logging.basicConfig(
+        level=logging.INFO,
+        format="%(asctime)s [%(levelname)s] %(name)s - %(message)s"
+    )
+
+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..3767cbe
--- /dev/null
+++ b/main.py
@@ -0,0 +1,26 @@
+from logging_config import setup_logging
+from config import Config
+from oracle_connector import OracleConnector
+from db import OracleDB
+from repository import Repository
+from api_client import FetchQueueClient
+from processor import Processor
+from 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/oracle_connector.py b/oracle_connector.py
new file mode 100644
index 0000000..c2adb2f
--- /dev/null
+++ b/oracle_connector.py
@@ -0,0 +1,37 @@
+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 initialize_pool(self):
+        try:
+            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
+            )
+            logger.info("Oracle connection pool initialized")
+        except Exception:
+            logger.error("Failed to initialize Oracle pool", exc_info=True)
+            raise
+
+    def get_connection(self):
+        if not self.pool:
+            self.initialize_pool()
+        return self.pool.acquire()
+
+    def close(self):
+        if self.pool:
+            try:
+                self.pool.close()
+                logger.info("Oracle pool closed")
+            except Exception:
+                logger.error("Error closing pool", exc_info=True)
diff --git a/processor.py b/processor.py
new file mode 100644
index 0000000..7394cdd
--- /dev/null
+++ b/processor.py
@@ -0,0 +1,61 @@
+from datetime import datetime
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class Processor:
+    def __init__(self, config, repo, api):
+        self.config = config
+        self.repo = repo
+        self.api = api
+
+    def process(self):
+        rows = self.repo.get_pending_rrns_today()
+        logger.info("Pending transactions count: %s", len(rows))
+
+        insert_count = 0
+
+        for r in rows:
+            bank_code = self.config.BANK_CODE_MAPPING.get(r["DCCB_CODE"])
+            if not bank_code:
+                continue
+
+            payload = {
+                "bankCode": bank_code,
+                "rrn": r["RRN_TWO"],
+                "branchCode": r["BR_CODE"],
+                "itemType": 0,
+                "queueType": "02",
+                "reterieveTop": "20"
+            }
+
+            response = self.api.fetch(payload)
+            items = response.get("response", {}).get("VwQueueItems", [])
+
+            if not items or items[0].get("status") != "PROCESSED":
+                continue
+
+            tran_date_str = r["TXN_DATE"].strftime("%d%m%Y")
+            item = items[0]
+
+            log_data = {
+                "bankcode": bank_code,
+                "jrnl_id": item["journalId"],
+                "ref_no": item.get("remarks"),
+                "tran_date": tran_date_str,
+                "txn_amt": r["TXN_AMT"],
+                "recv_ac": r["DEST_AC_NO"],
+                "send_ac": r["SRC_AC_NO"],
+                "ifsc": r["IFSC_CODE"],
+                "sender_ifsc": item.get("sender_ifsc"),
+                "sender_name": r["REMITTER_NAME"],
+                "receiver_name": r["BENEFICIARY_NAME"],
+                "beneficiary_address": r["BENEFICIARY_ADD"],
+                "sender_info": item["sendeReceiverInfo"]
+            }
+
+            self.repo.insert_outward_log(log_data)
+            self.repo.mark_processed(r["TXN_NO"])
+            insert_count += 1
+
+        return insert_count
diff --git a/repository.py b/repository.py
new file mode 100644
index 0000000..8c63253
--- /dev/null
+++ b/repository.py
@@ -0,0 +1,60 @@
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class Repository:
+    def __init__(self, db):
+        self.db = db
+
+    def get_pending_rrns_today(self):
+        sql = """
+        SELECT r.TXN_NO,
+               r.RRN_TWO,
+               q.TXN_DATE,
+               q.DCCB_CODE,
+               q.BR_CODE,
+               q.SRC_AC_NO,
+               q.DEST_AC_NO,
+               q.IFSC_CODE,
+               q.TXN_AMT,
+               q.BENEFICIARY_NAME,
+               q.BENEFICIARY_ADD,
+               q.REMITTER_NAME
+        FROM NEFT_RTGS_TXN_RRN r
+        JOIN NEFT_RTGS_TXN_QUEUE q ON q.TXN_NO = r.TXN_NO
+        WHERE r.MARK_TYPE = 'N'
+        """
+        return self.db.fetch_all(sql)
+
+    def insert_outward_log(self, d):
+        sql = """
+        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_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_ifsc,
+            :sender_name, :receiver_name,
+            :beneficiary_address,
+            :sender_info,
+            'N06'
+        )
+        """
+        self.db.execute(sql, d)
+
+    def mark_processed(self, txn_no):
+        self.db.execute(
+            "UPDATE NEFT_RTGS_TXN_RRN SET MARK_TYPE='Y' WHERE TXN_NO=:txn",
+            {"txn": txn_no}
+        )
+
+    def call_neft_api_txn_post(self):
+        return self.db.call_procedure("neft_api_txn_post")
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.py b/scheduler.py
new file mode 100644
index 0000000..b9f97c5
--- /dev/null
+++ b/scheduler.py
@@ -0,0 +1,40 @@
+import time
+from datetime import datetime, date
+from logging_config import get_logger
+
+logger = get_logger(__name__)
+
+class Scheduler:
+    def __init__(self, processor, config):
+        self.processor = processor
+        self.config = config
+        self.last_cycle_date = None
+        self.cycle_no = 0
+
+    def _update_cycle(self):
+        today = date.today()
+        if self.last_cycle_date != today:
+            self.cycle_no = 1
+            self.last_cycle_date = today
+        else:
+            self.cycle_no += 1
+
+    def run(self):
+        logger.info("NEFT OUTWARD Scheduler started")
+
+        while True:
+            try:
+                self._update_cycle()
+                insert_count = self.processor.process()
+
+                if insert_count > 0:
+                    logger.info("Calling neft_api_txn_post procedure...")
+                    if self.processor.repo.call_neft_api_txn_post():
+                        logger.info("Transaction post-processing completed successfully")
+                    else:
+                        logger.error("Transaction post-processing failed")
+
+            except Exception:
+                logger.exception("Scheduler cycle failed")
+
+            time.sleep(self.config.poll_interval_minutes * 60)
\ No newline at end of file