From 611e56d0b3a1fc88357d86866e172da148d8aa5c Mon Sep 17 00:00:00 2001 From: Bishwajeet Date: Wed, 18 Mar 2026 15:29:09 +0530 Subject: [PATCH] updated config --- db/__pycache__/repository.cpython-39.pyc | Bin 9596 -> 9592 bytes db/repository.py | 4 +- logs/app.log | 137 ++++++++++++++++++ .../__pycache__/data_mapper.cpython-39.pyc | Bin 4276 -> 4932 bytes .../__pycache__/file_processor.cpython-39.pyc | Bin 5291 -> 5292 bytes 5 files changed, 139 insertions(+), 2 deletions(-) diff --git a/db/__pycache__/repository.cpython-39.pyc b/db/__pycache__/repository.cpython-39.pyc index aa79f6350d4458817aee4acbe9601c6106e124a7..7b0f7a653d9945c1e66a59f75a468fbfd91b3024 100644 GIT binary patch delta 64 zcmez4^}~xdk(ZZ?0SGR7Zppl}k=Im_T@}cCG-vYU30z_#C5cHnsS2qTnZ+f=rCMN# M=^%;Cy^8Od0jZf4=l}o! delta 65 zcmez2^~Z}hk(ZZ?0SLal+?@GfBd@6 /tmp/13032026_20_NEFT_OUTWARD.TXT +2026-03-13 23:01:22 - neft_outward_parser - INFO - Read 59 data rows using encoding utf-8-sig +2026-03-13 23:01:22 - neft_outward_parser - INFO - Parsed 59 rows from /tmp/13032026_20_NEFT_OUTWARD.TXT +2026-03-13 23:01:22 - processors.data_mapper - INFO - Mapped 59 NEFT transactions for bank 0001 +2026-03-13 23:01:36 - db.repository - INFO - [{'TXNIND': 'DR', 'BANKCODE': '0001', 'JRNL_ID': '000480998', 'REF_NO': 'WBSCN26072518321', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('86000'), 'SENDER_IFSC': 'WBSC0000019', 'RECIEVER_IFSC': 'HDFC0000240', 'SENDER_ACCT_NO': '00000101009825802', 'SENDER_NAME': 'NARAYAN KHUTIYA', 'RECVR_ACCT_NO': '00210190539105214', 'RECIEVER_NAME': '/00210190539105214 VISHAKHA IND LTD SURAT', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'SURAT', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0001', 'JRNL_ID': '000482767', 'REF_NO': 'WBSCN26072518326', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('50000'), 'SENDER_IFSC': 'WBSC0000036', 'RECIEVER_IFSC': 'ICIC0000914', 'SENDER_ACCT_NO': '00000101007965727', 'SENDER_NAME': 'REAJUL GAZI', 'RECVR_ACCT_NO': '091401512554', 'RECIEVER_NAME': '/091401512554 NARGIS GAZI BHEBIA', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'BHEBIA', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0001', 'JRNL_ID': '000483054', 'REF_NO': 'WBSCN26072518329', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('18500'), 'SENDER_IFSC': 'WBSC0000036', 'RECIEVER_IFSC': 'BKID0004277', 'SENDER_ACCT_NO': '00000101010810279', 'SENDER_NAME': 'REBEKA KHATUN', 'RECVR_ACCT_NO': '427710110000935', 'RECIEVER_NAME': '/427710110000935 FARUKUDDIN MONDAL MURARISA', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'MURARISA', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0001', 'JRNL_ID': '000478794', 'REF_NO': 'WBSCN26072518288', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('1500'), 'SENDER_IFSC': 'WBSC0000043', 'RECIEVER_IFSC': 'SBIN0000001', 'SENDER_ACCT_NO': '00000101008083608', 'SENDER_NAME': '', 'RECVR_ACCT_NO': '00000044999048314', 'RECIEVER_NAME': '', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': '', 'MSG_TYPE': 'N07', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0001', 'JRNL_ID': '000478802', 'REF_NO': 'WBSCN26072518289', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('1500'), 'SENDER_IFSC': 'WBSC0000043', 'RECIEVER_IFSC': 'SBIN0000001', 'SENDER_ACCT_NO': '00000101008107473', 'SENDER_NAME': '', 'RECVR_ACCT_NO': '00000044999048314', 'RECIEVER_NAME': '', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': '', 'MSG_TYPE': 'N07', 'SENDER_TO_RECIVER_INFO': ' '}] +2026-03-13 23:01:36 - db.repository - INFO - Inserted 5 NEFT transactions into outward_neft_api_log +2026-03-13 23:01:36 - db.repository - INFO - Marked file as processed: 13032026_20_NEFT_OUTWARD.TXT +2026-03-13 23:01:36 - processors.file_processor - INFO - Successfully processed 13032026_20_NEFT_OUTWARD.TXT: 5 inserted, 54 skipped (non-ipks accounts) +2026-03-13 23:01:36 - processors.file_processor - INFO - Processing complete: 1/1 successful +2026-03-13 23:01:36 - scheduler - INFO - Cycle 1 complete: +2026-03-13 23:01:36 - scheduler - INFO - Total files: 1 +2026-03-13 23:01:36 - scheduler - INFO - Successful: 1 +2026-03-13 23:01:36 - scheduler - INFO - Failed: 0 +2026-03-13 23:01:36 - scheduler - INFO - Calling neft_api_txn_post procedure for all inserted transactions... +2026-03-13 23:01:36 - db.repository - INFO - Calling neft_api_txn_post procedure to process all inserted transactions... +2026-03-13 23:01:36 - db.repository - INFO - neft_api_txn_post procedure executed successfully +2026-03-13 23:01:36 - scheduler - INFO - Transaction post-processing completed successfully +2026-03-13 23:01:36 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-13 23:01:36 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-13 23:31:37 - scheduler - INFO - === Starting processing cycle 2 === +2026-03-13 23:31:37 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-13 23:31:37 - scheduler - INFO - listing file for 13032026 +2026-03-13 23:31:37 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-13 23:31:37 - scheduler - INFO - No new files to process +2026-03-13 23:31:37 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-13 23:31:37 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-14 00:01:37 - scheduler - INFO - === Starting processing cycle 3 === +2026-03-14 00:01:37 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-14 00:01:37 - scheduler - INFO - listing file for 14032026 +2026-03-14 00:01:38 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-14 00:01:38 - scheduler - INFO - No new files to process +2026-03-14 00:01:38 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-14 00:01:38 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-14 00:31:38 - scheduler - INFO - === Starting processing cycle 4 === +2026-03-14 00:31:38 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-14 00:31:38 - scheduler - INFO - listing file for 14032026 +2026-03-14 00:31:38 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-14 00:31:38 - scheduler - INFO - No new files to process +2026-03-14 00:31:38 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-14 00:31:38 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-18 13:17:33 - __main__ - INFO - Application started +2026-03-18 13:17:33 - config - WARNING - .env file not found. Using environment variables or defaults. +2026-03-18 13:17:33 - config - INFO - Configuration validated. Bank codes: 0001, 0002, 0003, 0004, 0005, 0006, 0007, 0009, 0012, 0013, 0014, 0015, 0016, 0017, 0018, 0020, 0021 +2026-03-18 13:17:33 - scheduler - INFO - ================================================================================ +2026-03-18 13:17:33 - scheduler - INFO - NEFT_OUTWARD File Processing Scheduler Started +2026-03-18 13:17:33 - scheduler - INFO - Poll Interval: 30 minutes +2026-03-18 13:17:33 - scheduler - INFO - Bank Codes: 0001, 0002, 0003, 0004, 0005, 0006, 0007, 0009, 0012, 0013, 0014, 0015, 0016, 0017, 0018, 0020, 0021 +2026-03-18 13:17:33 - scheduler - INFO - ================================================================================ +2026-03-18 13:17:33 - scheduler - INFO - Database connection test passed +2026-03-18 13:17:33 - db.repository - INFO - ✓ outward_neft_api_log table exists +2026-03-18 13:17:33 - db.repository - INFO - ✓ neft_processed_files table exists +2026-03-18 13:17:33 - db.repository - INFO - Database tables verified successfully +2026-03-18 13:17:33 - scheduler - INFO - === Starting processing cycle 1 === +2026-03-18 13:17:33 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-18 13:17:33 - scheduler - INFO - listing file for 18032026 +2026-03-18 13:17:33 - scheduler - INFO - Found new file: 18032026_20_NEFT_OUTWARD.TXT (bank: 0005) +2026-03-18 13:17:33 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-18 13:17:33 - scheduler - INFO - Found 1 new files to process +2026-03-18 13:17:33 - processors.file_processor - INFO - Starting processing: 18032026_20_NEFT_OUTWARD.TXT (bank: 0005) +2026-03-18 13:17:33 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/NEFT/18032026_20_NEFT_OUTWARD.TXT -> /tmp/18032026_20_NEFT_OUTWARD.TXT +2026-03-18 13:17:33 - neft_outward_parser - INFO - Read 59 data rows using encoding utf-8-sig +2026-03-18 13:17:33 - neft_outward_parser - INFO - Parsed 59 rows from /tmp/18032026_20_NEFT_OUTWARD.TXT +2026-03-18 13:17:33 - processors.data_mapper - INFO - Mapped 59 NEFT transactions for bank 0005 +2026-03-18 13:17:48 - db.repository - INFO - [{'TXNIND': 'DR', 'BANKCODE': '0005', 'JRNL_ID': '000480998', 'REF_NO': 'WBSCN26072518321', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('86000'), 'SENDER_IFSC': 'WBSC0000019', 'RECIEVER_IFSC': 'HDFC0000240', 'SENDER_ACCT_NO': '00000101009825802', 'SENDER_NAME': 'NARAYAN KHUTIYA', 'RECVR_ACCT_NO': '00210190539105214', 'RECIEVER_NAME': '/00210190539105214 VISHAKHA IND LTD SURAT', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'SURAT', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0005', 'JRNL_ID': '000482767', 'REF_NO': 'WBSCN26072518326', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('50000'), 'SENDER_IFSC': 'WBSC0000036', 'RECIEVER_IFSC': 'ICIC0000914', 'SENDER_ACCT_NO': '00000101007965727', 'SENDER_NAME': 'REAJUL GAZI', 'RECVR_ACCT_NO': '091401512554', 'RECIEVER_NAME': '/091401512554 NARGIS GAZI BHEBIA', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'BHEBIA', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0005', 'JRNL_ID': '000483054', 'REF_NO': 'WBSCN26072518329', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('18500'), 'SENDER_IFSC': 'WBSC0000036', 'RECIEVER_IFSC': 'BKID0004277', 'SENDER_ACCT_NO': '00000101010810279', 'SENDER_NAME': 'REBEKA KHATUN', 'RECVR_ACCT_NO': '427710110000935', 'RECIEVER_NAME': '/427710110000935 FARUKUDDIN MONDAL MURARISA', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': 'MURARISA', 'MSG_TYPE': 'N06', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0005', 'JRNL_ID': '000478794', 'REF_NO': 'WBSCN26072518288', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('1500'), 'SENDER_IFSC': 'WBSC0000043', 'RECIEVER_IFSC': 'SBIN0000001', 'SENDER_ACCT_NO': '00000101008083608', 'SENDER_NAME': '', 'RECVR_ACCT_NO': '00000044999048314', 'RECIEVER_NAME': '', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': '', 'MSG_TYPE': 'N07', 'SENDER_TO_RECIVER_INFO': ' '}, {'TXNIND': 'DR', 'BANKCODE': '0005', 'JRNL_ID': '000478802', 'REF_NO': 'WBSCN26072518289', 'TRAN_DATE': '13032026', 'TXN_AMT': Decimal('1500'), 'SENDER_IFSC': 'WBSC0000043', 'RECIEVER_IFSC': 'SBIN0000001', 'SENDER_ACCT_NO': '00000101008107473', 'SENDER_NAME': '', 'RECVR_ACCT_NO': '00000044999048314', 'RECIEVER_NAME': '', 'REJECT_CODE': '', 'REJECT_REASON': '', 'BENEFICIARY_ADDRESS': '', 'MSG_TYPE': 'N07', 'SENDER_TO_RECIVER_INFO': ' '}] +2026-03-18 13:17:48 - db.repository - INFO - Inserted 5 NEFT transactions into outward_neft_api_log +2026-03-18 13:17:48 - db.repository - INFO - Marked file as processed: 18032026_20_NEFT_OUTWARD.TXT +2026-03-18 13:17:48 - processors.file_processor - INFO - Successfully processed 18032026_20_NEFT_OUTWARD.TXT: 5 inserted, 54 skipped (non-ipks accounts) +2026-03-18 13:17:48 - processors.file_processor - INFO - Processing complete: 1/1 successful +2026-03-18 13:17:48 - scheduler - INFO - Cycle 1 complete: +2026-03-18 13:17:48 - scheduler - INFO - Total files: 1 +2026-03-18 13:17:48 - scheduler - INFO - Successful: 1 +2026-03-18 13:17:48 - scheduler - INFO - Failed: 0 +2026-03-18 13:17:48 - scheduler - INFO - Calling neft_api_txn_post procedure for all inserted transactions... +2026-03-18 13:17:48 - db.repository - INFO - Calling neft_api_txn_post procedure to process all inserted transactions... +2026-03-18 13:17:48 - db.repository - INFO - neft_api_txn_post procedure executed successfully +2026-03-18 13:17:48 - scheduler - INFO - Transaction post-processing completed successfully +2026-03-18 13:17:48 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-18 13:17:48 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-18 13:47:48 - scheduler - INFO - === Starting processing cycle 2 === +2026-03-18 13:47:48 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-18 13:47:48 - scheduler - INFO - listing file for 18032026 +2026-03-18 13:47:49 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-18 13:47:49 - scheduler - INFO - No new files to process +2026-03-18 13:47:49 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-18 13:47:49 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-18 14:17:49 - scheduler - INFO - === Starting processing cycle 3 === +2026-03-18 14:17:49 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-18 14:17:49 - scheduler - INFO - listing file for 18032026 +2026-03-18 14:17:49 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-18 14:17:49 - scheduler - INFO - No new files to process +2026-03-18 14:17:49 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-18 14:17:49 - scheduler - INFO - Waiting 30 minutes until next cycle... +2026-03-18 14:47:49 - scheduler - INFO - === Starting processing cycle 4 === +2026-03-18 14:47:49 - sftp.sftp_client - INFO - Connected to SFTP server: 43.225.3.224:4650 +2026-03-18 14:47:49 - scheduler - INFO - listing file for 18032026 +2026-03-18 14:47:49 - sftp.sftp_client - WARNING - Directory not found: /home/ipks/IPKS_FILES/REPORTS/0016/NEFT +2026-03-18 14:47:50 - scheduler - INFO - No new files to process +2026-03-18 14:47:50 - sftp.sftp_client - INFO - SFTP connection closed +2026-03-18 14:47:50 - scheduler - INFO - Waiting 30 minutes until next cycle... diff --git a/processors/__pycache__/data_mapper.cpython-39.pyc b/processors/__pycache__/data_mapper.cpython-39.pyc index 7d863b1bac30267380d012cd7a1e7f5198db60bf..a2f42c776050e1154c6a72af493ae77a6f6cafce 100644 GIT binary patch delta 1361 zcmZuwO>7%Q6rQ(#-u3?3uG1)1Q`S)kjhYk(ApudtZvqm96cI$!T*}rnNezx|&2EHh z*7X4n8~{a{V-qR9bD(n0hy!P&a&!d}5+EV&xx$|9{tBiLwQo|jJGP=L#gKWGP(jXHP zwDvAaHNmHi_-4>#A#JpFf-d8276oxT*bP5nK_d>9UI=Jory;&~pXxt;kLBRC@x8EA zS}BS-*2q6R?R^&S@m93_kdP{#$mxWXGAa+u4vM4yQ%dO+*XkE`L@G0r9APC#H zua@wD2d?ZvFQG3gAP`#t4GhHu2Rt|n-Rk4*aOuCf!_hj0_$>EwpBe+D^ENel7B-5SSOe(gu~i5)2hh1ejUx@4$4(jab>fV1Vm(n3 zJ>~Pre>LV)+eZ5!v&}?HIS0A#PQ|!r|A2NM%O~RlJ*0llLhQsz(|qLqJe5{J`{a~e z9Kb$w%u`G$WhxnC&@*2bdv4-pU2p8et!?ak5Bq*5&V6iZw48Y2t~p_Qx4l-LPWEse z-ZLG5S@Eki2{XeJs|@h0u#Bn0Bnp04^Mwcd>Q zf@BsYR3*G9;du$Ki2L@_z8A3;W&FXri+}72tcZ$Jo4$rY(JBJ5G{u2DzQ3jxAg|$6 z1#@PgB))XkU~%}9^9SG)AA1Y->$38ighlbUcNv7Z;IBYYZ2OmAos;xfpxo&aR0&e~ z$gVfTDB5N5%{Jwlq)iD@05>FD5x@A=S=r4dXodo%GR}$ddhR6!xP`9ud7obu=L;M5 QJ2EHz0W3_M6rxc57pQPnqyPW_ delta 778 zcmYk2O=}ZD7{}+?-E4Mu_9dGaOSLU+(ALGO6%>)w($u#?p$I{RC`jDdY9!XO34(EB z5B4eq#*5fua}yCo)`K6wlOG`m#X}E*`VquuwgIy+zj^+@d1hyJzf6CcvTK%Q5PUBG zjO*WXAMG80h`)pBo9RGfscng=EWM>XgQ^}F0S!_?dQBQ7IGaq{mYL3sWYxk|`~P~< zVF%_YVHCSeW+hz?vn#}N;wdw;YvgcTz|p(|gmj@j!GGur zn?2ZAX6mloBON`0UBWap)qyb*qoZjI3~ecq6r~bxpx@f}Nv4=z46+s}i8Il?8S1ex ze;#CU-X>u-s;>iOL^Rpvp!+toEra>bP`1J@XQ)H1r`Ec`MmjjhWoiOU@>O#LCgL?S4{(e>u@2K& z{Bz-PffM|#b$vza%XfoTI3vuMfFqy@2N0g!m;FXFJSv1IFfMRfU{0XKui8fr z(q^#Eg79|D_ghsX4E#s?b$E`yw&xCA#Lngtg6N85f&mIBas~`J3;dT|gba6_OW?)V zoIQX=UUFyYf_QmZz~iAi4{iRzJ&%pQ-T6{c=;YcdQON@0Q~K0z)SAr)LF?W_7Ais~ tpR_0{Rp1J*XQw8!SZbiC5@ZWF@)C@lks#DjuX;|n!rx~ru*{|0(m%p}v?Krk diff --git a/processors/__pycache__/file_processor.cpython-39.pyc b/processors/__pycache__/file_processor.cpython-39.pyc index b0b4cd3c155ce70a4ecb81ea51a7881372e974c4..faeb367c59894fb778f4716c5cbc80fc70bc72a7 100644 GIT binary patch delta 47 zcmZ3jxki&Wk(ZZ?0SF$tZ^;zf$ScPrtPxO@pPX7;oLa2l=js-s;2#>Y*_J6!2mmqZ B4L$$> delta 46 zcmZ3ZxmuGqk(ZZ?0SNdrH)V=$