nohup: ignoring input
2026-06-15 11:29:15 - __main__ - INFO - Application started
2026-06-15 11:29:15 - config - WARNING - .env file not found. Using environment variables or defaults.
2026-06-15 11:29:15 - config - INFO - Configuration validated. Bank codes: 0001, 0002, 0003, 0004, 0005, 0006, 0007, 0009, 0012, 0013, 0014, 0015, 0016, 0017, 0018, 0020, 0021
2026-06-15 11:29:15 - scheduler - INFO - ================================================================================
2026-06-15 11:29:15 - scheduler - INFO - UPI_INWARD File Processing Scheduler Started
2026-06-15 11:29:15 - scheduler - INFO - Poll Interval: 30 minutes
2026-06-15 11:29:15 - scheduler - INFO - Bank Codes: 0001, 0002, 0003, 0004, 0005, 0006, 0007, 0009, 0012, 0013, 0014, 0015, 0016, 0017, 0018, 0020, 0021
2026-06-15 11:29:15 - scheduler - INFO - ================================================================================
2026-06-15 11:29:15 - scheduler - INFO - Database connection test passed
2026-06-15 11:29:15 - scheduler - INFO - === Starting processing cycle 1 ===
2026-06-15 11:29:16 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 11:29:16 - scheduler - INFO - listing file for 15062026
2026-06-15 11:29:16 - scheduler - INFO - Found new file: HOOGLY_15062026_10C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: HOOGLY_15062026_1C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: HOOGLY_15062026_2C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: HOOGLY_15062026_3C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: HOOGLY_15062026_4C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: TUMLUK_15062026_1C_UPI.txt.gz (bank: 0005)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: TUMLUK_15062026_2C_UPI.txt.gz (bank: 0005)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: TUMLUK_15062026_3C_UPI.txt.gz (bank: 0005)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: TUMLUK_15062026_4C_UPI.txt.gz (bank: 0005)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MLDB_15062026_1C_UPI.txt.gz (bank: 0017)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MLDB_15062026_2C_UPI.txt.gz (bank: 0017)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MLDB_15062026_3C_UPI.txt.gz (bank: 0017)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MLDB_15062026_4C_UPI.txt.gz (bank: 0017)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MUGB_15062026_1C_UPI.txt.gz (bank: 0018)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MUGB_15062026_2C_UPI.txt.gz (bank: 0018)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MUGB_15062026_3C_UPI.txt.gz (bank: 0018)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: MUGB_15062026_4C_UPI.txt.gz (bank: 0018)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: VCCB_15062026_1C_UPI.txt.gz (bank: 0020)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: VCCB_15062026_2C_UPI.txt.gz (bank: 0020)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: VCCB_15062026_3C_UPI.txt.gz (bank: 0020)
2026-06-15 11:29:16 - scheduler - INFO - Found new file: VCCB_15062026_4C_UPI.txt.gz (bank: 0020)
2026-06-15 11:29:16 - scheduler - INFO - Found 21 new files to process
2026-06-15 11:29:16 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_10C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_10C_UPI.txt.gz -> /tmp/HOOGLY_15062026_10C_UPI.txt.gz
2026-06-15 11:29:16 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_10C_UPI.txt.gz
2026-06-15 11:29:16 - upi_parser - INFO - Parsed 0 rows from /tmp/HOOGLY_15062026_10C_UPI.txt
2026-06-15 11:29:16 - processors.file_processor - WARNING - No transactions found in HOOGLY_15062026_10C_UPI.txt.gz
2026-06-15 11:29:16 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_10C_UPI.txt.gz
2026-06-15 11:29:16 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_1C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:16 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_1C_UPI.txt.gz -> /tmp/HOOGLY_15062026_1C_UPI.txt.gz
2026-06-15 11:29:16 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_1C_UPI.txt.gz
2026-06-15 11:29:16 - upi_parser - INFO - Parsed 74 rows from /tmp/HOOGLY_15062026_1C_UPI.txt
2026-06-15 11:29:16 - processors.data_mapper - INFO - Mapped 74 UPI transactions for bank 0002
2026-06-15 11:29:25 - db.repository - INFO - All 74 transactions skipped
2026-06-15 11:29:25 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_1C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_1C_UPI.txt.gz: 0 inserted, 74 skipped (non-ipks accounts)
2026-06-15 11:29:25 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_2C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:25 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_2C_UPI.txt.gz -> /tmp/HOOGLY_15062026_2C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_2C_UPI.txt.gz
2026-06-15 11:29:25 - upi_parser - INFO - Parsed 11 rows from /tmp/HOOGLY_15062026_2C_UPI.txt
2026-06-15 11:29:25 - processors.data_mapper - INFO - Mapped 11 UPI transactions for bank 0002
2026-06-15 11:29:25 - db.repository - INFO - All 11 transactions skipped
2026-06-15 11:29:25 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_2C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_2C_UPI.txt.gz: 0 inserted, 11 skipped (non-ipks accounts)
2026-06-15 11:29:25 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_3C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:25 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_3C_UPI.txt.gz -> /tmp/HOOGLY_15062026_3C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_3C_UPI.txt.gz
2026-06-15 11:29:25 - upi_parser - INFO - Parsed 8 rows from /tmp/HOOGLY_15062026_3C_UPI.txt
2026-06-15 11:29:25 - processors.data_mapper - INFO - Mapped 8 UPI transactions for bank 0002
2026-06-15 11:29:25 - db.repository - INFO - All 8 transactions skipped
2026-06-15 11:29:25 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_3C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_3C_UPI.txt.gz: 0 inserted, 8 skipped (non-ipks accounts)
2026-06-15 11:29:25 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_4C_UPI.txt.gz (bank: 0002)
2026-06-15 11:29:25 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_4C_UPI.txt.gz -> /tmp/HOOGLY_15062026_4C_UPI.txt.gz
2026-06-15 11:29:25 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_4C_UPI.txt.gz
2026-06-15 11:29:25 - upi_parser - INFO - Parsed 34 rows from /tmp/HOOGLY_15062026_4C_UPI.txt
2026-06-15 11:29:25 - processors.data_mapper - INFO - Mapped 34 UPI transactions for bank 0002
2026-06-15 11:29:27 - db.repository - INFO - All 34 transactions skipped
2026-06-15 11:29:27 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_4C_UPI.txt.gz
2026-06-15 11:29:27 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_4C_UPI.txt.gz: 0 inserted, 34 skipped (non-ipks accounts)
2026-06-15 11:29:27 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_1C_UPI.txt.gz (bank: 0005)
2026-06-15 11:29:27 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_1C_UPI.txt.gz -> /tmp/TUMLUK_15062026_1C_UPI.txt.gz
2026-06-15 11:29:27 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_1C_UPI.txt.gz
2026-06-15 11:29:27 - upi_parser - INFO - Parsed 933 rows from /tmp/TUMLUK_15062026_1C_UPI.txt
2026-06-15 11:29:27 - processors.data_mapper - INFO - Mapped 933 UPI transactions for bank 0005
2026-06-15 11:30:15 - db.repository - INFO - All 933 transactions skipped
2026-06-15 11:30:15 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_1C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Successfully processed TUMLUK_15062026_1C_UPI.txt.gz: 0 inserted, 933 skipped (non-ipks accounts)
2026-06-15 11:30:15 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_2C_UPI.txt.gz (bank: 0005)
2026-06-15 11:30:15 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_2C_UPI.txt.gz -> /tmp/TUMLUK_15062026_2C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_2C_UPI.txt.gz
2026-06-15 11:30:15 - upi_parser - INFO - Parsed 0 rows from /tmp/TUMLUK_15062026_2C_UPI.txt
2026-06-15 11:30:15 - processors.file_processor - WARNING - No transactions found in TUMLUK_15062026_2C_UPI.txt.gz
2026-06-15 11:30:15 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_2C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_3C_UPI.txt.gz (bank: 0005)
2026-06-15 11:30:15 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_3C_UPI.txt.gz -> /tmp/TUMLUK_15062026_3C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_3C_UPI.txt.gz
2026-06-15 11:30:15 - upi_parser - INFO - Parsed 0 rows from /tmp/TUMLUK_15062026_3C_UPI.txt
2026-06-15 11:30:15 - processors.file_processor - WARNING - No transactions found in TUMLUK_15062026_3C_UPI.txt.gz
2026-06-15 11:30:15 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_3C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_4C_UPI.txt.gz (bank: 0005)
2026-06-15 11:30:15 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_4C_UPI.txt.gz -> /tmp/TUMLUK_15062026_4C_UPI.txt.gz
2026-06-15 11:30:15 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_4C_UPI.txt.gz
2026-06-15 11:30:15 - upi_parser - INFO - Parsed 556 rows from /tmp/TUMLUK_15062026_4C_UPI.txt
2026-06-15 11:30:15 - processors.data_mapper - INFO - Mapped 556 UPI transactions for bank 0005
2026-06-15 11:30:42 - db.repository - INFO - All 556 transactions skipped
2026-06-15 11:30:42 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_4C_UPI.txt.gz
2026-06-15 11:30:42 - processors.file_processor - INFO - Successfully processed TUMLUK_15062026_4C_UPI.txt.gz: 0 inserted, 556 skipped (non-ipks accounts)
2026-06-15 11:30:42 - processors.file_processor - INFO - Starting processing: MLDB_15062026_1C_UPI.txt.gz (bank: 0017)
2026-06-15 11:30:42 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_1C_UPI.txt.gz -> /tmp/MLDB_15062026_1C_UPI.txt.gz
2026-06-15 11:30:42 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_1C_UPI.txt.gz
2026-06-15 11:30:42 - upi_parser - INFO - Parsed 69 rows from /tmp/MLDB_15062026_1C_UPI.txt
2026-06-15 11:30:42 - processors.data_mapper - INFO - Mapped 69 UPI transactions for bank 0017
2026-06-15 11:30:45 - db.repository - INFO - All 69 transactions skipped
2026-06-15 11:30:45 - db.repository - INFO - Marked file as processed: MLDB_15062026_1C_UPI.txt.gz
2026-06-15 11:30:45 - processors.file_processor - INFO - Successfully processed MLDB_15062026_1C_UPI.txt.gz: 0 inserted, 69 skipped (non-ipks accounts)
2026-06-15 11:30:45 - processors.file_processor - INFO - Starting processing: MLDB_15062026_2C_UPI.txt.gz (bank: 0017)
2026-06-15 11:30:46 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_2C_UPI.txt.gz -> /tmp/MLDB_15062026_2C_UPI.txt.gz
2026-06-15 11:30:46 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_2C_UPI.txt.gz
2026-06-15 11:30:46 - upi_parser - INFO - Parsed 10 rows from /tmp/MLDB_15062026_2C_UPI.txt
2026-06-15 11:30:46 - processors.data_mapper - INFO - Mapped 10 UPI transactions for bank 0017
2026-06-15 11:30:46 - db.repository - INFO - All 10 transactions skipped
2026-06-15 11:30:46 - db.repository - INFO - Marked file as processed: MLDB_15062026_2C_UPI.txt.gz
2026-06-15 11:30:46 - processors.file_processor - INFO - Successfully processed MLDB_15062026_2C_UPI.txt.gz: 0 inserted, 10 skipped (non-ipks accounts)
2026-06-15 11:30:46 - processors.file_processor - INFO - Starting processing: MLDB_15062026_3C_UPI.txt.gz (bank: 0017)
2026-06-15 11:30:46 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_3C_UPI.txt.gz -> /tmp/MLDB_15062026_3C_UPI.txt.gz
2026-06-15 11:30:46 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_3C_UPI.txt.gz
2026-06-15 11:30:46 - upi_parser - INFO - Parsed 9 rows from /tmp/MLDB_15062026_3C_UPI.txt
2026-06-15 11:30:46 - processors.data_mapper - INFO - Mapped 9 UPI transactions for bank 0017
2026-06-15 11:30:46 - db.repository - INFO - All 9 transactions skipped
2026-06-15 11:30:46 - db.repository - INFO - Marked file as processed: MLDB_15062026_3C_UPI.txt.gz
2026-06-15 11:30:46 - processors.file_processor - INFO - Successfully processed MLDB_15062026_3C_UPI.txt.gz: 0 inserted, 9 skipped (non-ipks accounts)
2026-06-15 11:30:46 - processors.file_processor - INFO - Starting processing: MLDB_15062026_4C_UPI.txt.gz (bank: 0017)
2026-06-15 11:30:46 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_4C_UPI.txt.gz -> /tmp/MLDB_15062026_4C_UPI.txt.gz
2026-06-15 11:30:46 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_4C_UPI.txt.gz
2026-06-15 11:30:46 - upi_parser - INFO - Parsed 16 rows from /tmp/MLDB_15062026_4C_UPI.txt
2026-06-15 11:30:46 - processors.data_mapper - INFO - Mapped 16 UPI transactions for bank 0017
2026-06-15 11:30:47 - db.repository - INFO - All 16 transactions skipped
2026-06-15 11:30:47 - db.repository - INFO - Marked file as processed: MLDB_15062026_4C_UPI.txt.gz
2026-06-15 11:30:47 - processors.file_processor - INFO - Successfully processed MLDB_15062026_4C_UPI.txt.gz: 0 inserted, 16 skipped (non-ipks accounts)
2026-06-15 11:30:47 - processors.file_processor - INFO - Starting processing: MUGB_15062026_1C_UPI.txt.gz (bank: 0018)
2026-06-15 11:30:47 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_1C_UPI.txt.gz -> /tmp/MUGB_15062026_1C_UPI.txt.gz
2026-06-15 11:30:47 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_1C_UPI.txt.gz
2026-06-15 11:30:47 - upi_parser - INFO - Parsed 565 rows from /tmp/MUGB_15062026_1C_UPI.txt
2026-06-15 11:30:47 - processors.data_mapper - INFO - Mapped 565 UPI transactions for bank 0018
2026-06-15 11:31:15 - db.repository - INFO - All 565 transactions skipped
2026-06-15 11:31:15 - db.repository - INFO - Marked file as processed: MUGB_15062026_1C_UPI.txt.gz
2026-06-15 11:31:15 - processors.file_processor - INFO - Successfully processed MUGB_15062026_1C_UPI.txt.gz: 0 inserted, 565 skipped (non-ipks accounts)
2026-06-15 11:31:15 - processors.file_processor - INFO - Starting processing: MUGB_15062026_2C_UPI.txt.gz (bank: 0018)
2026-06-15 11:31:15 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_2C_UPI.txt.gz -> /tmp/MUGB_15062026_2C_UPI.txt.gz
2026-06-15 11:31:15 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_2C_UPI.txt.gz
2026-06-15 11:31:15 - upi_parser - INFO - Parsed 64 rows from /tmp/MUGB_15062026_2C_UPI.txt
2026-06-15 11:31:15 - processors.data_mapper - INFO - Mapped 64 UPI transactions for bank 0018
2026-06-15 11:31:18 - db.repository - INFO - All 64 transactions skipped
2026-06-15 11:31:18 - db.repository - INFO - Marked file as processed: MUGB_15062026_2C_UPI.txt.gz
2026-06-15 11:31:18 - processors.file_processor - INFO - Successfully processed MUGB_15062026_2C_UPI.txt.gz: 0 inserted, 64 skipped (non-ipks accounts)
2026-06-15 11:31:18 - processors.file_processor - INFO - Starting processing: MUGB_15062026_3C_UPI.txt.gz (bank: 0018)
2026-06-15 11:31:18 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_3C_UPI.txt.gz -> /tmp/MUGB_15062026_3C_UPI.txt.gz
2026-06-15 11:31:18 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_3C_UPI.txt.gz
2026-06-15 11:31:18 - upi_parser - INFO - Parsed 108 rows from /tmp/MUGB_15062026_3C_UPI.txt
2026-06-15 11:31:18 - processors.data_mapper - INFO - Mapped 108 UPI transactions for bank 0018
2026-06-15 11:31:23 - db.repository - INFO - All 108 transactions skipped
2026-06-15 11:31:23 - db.repository - INFO - Marked file as processed: MUGB_15062026_3C_UPI.txt.gz
2026-06-15 11:31:23 - processors.file_processor - INFO - Successfully processed MUGB_15062026_3C_UPI.txt.gz: 0 inserted, 108 skipped (non-ipks accounts)
2026-06-15 11:31:23 - processors.file_processor - INFO - Starting processing: MUGB_15062026_4C_UPI.txt.gz (bank: 0018)
2026-06-15 11:31:23 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_4C_UPI.txt.gz -> /tmp/MUGB_15062026_4C_UPI.txt.gz
2026-06-15 11:31:23 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_4C_UPI.txt.gz
2026-06-15 11:31:23 - upi_parser - INFO - Parsed 346 rows from /tmp/MUGB_15062026_4C_UPI.txt
2026-06-15 11:31:23 - processors.data_mapper - INFO - Mapped 346 UPI transactions for bank 0018
2026-06-15 11:31:40 - db.repository - INFO - All 346 transactions skipped
2026-06-15 11:31:40 - db.repository - INFO - Marked file as processed: MUGB_15062026_4C_UPI.txt.gz
2026-06-15 11:31:40 - processors.file_processor - INFO - Successfully processed MUGB_15062026_4C_UPI.txt.gz: 0 inserted, 346 skipped (non-ipks accounts)
2026-06-15 11:31:40 - processors.file_processor - INFO - Starting processing: VCCB_15062026_1C_UPI.txt.gz (bank: 0020)
2026-06-15 11:31:40 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_1C_UPI.txt.gz -> /tmp/VCCB_15062026_1C_UPI.txt.gz
2026-06-15 11:31:40 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_1C_UPI.txt.gz
2026-06-15 11:31:40 - upi_parser - INFO - Parsed 424 rows from /tmp/VCCB_15062026_1C_UPI.txt
2026-06-15 11:31:40 - processors.data_mapper - INFO - Mapped 424 UPI transactions for bank 0020
2026-06-15 11:32:02 - db.repository - INFO - All 424 transactions skipped
2026-06-15 11:32:02 - db.repository - INFO - Marked file as processed: VCCB_15062026_1C_UPI.txt.gz
2026-06-15 11:32:02 - processors.file_processor - INFO - Successfully processed VCCB_15062026_1C_UPI.txt.gz: 0 inserted, 424 skipped (non-ipks accounts)
2026-06-15 11:32:02 - processors.file_processor - INFO - Starting processing: VCCB_15062026_2C_UPI.txt.gz (bank: 0020)
2026-06-15 11:32:02 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_2C_UPI.txt.gz -> /tmp/VCCB_15062026_2C_UPI.txt.gz
2026-06-15 11:32:02 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_2C_UPI.txt.gz
2026-06-15 11:32:02 - upi_parser - INFO - Parsed 97 rows from /tmp/VCCB_15062026_2C_UPI.txt
2026-06-15 11:32:02 - processors.data_mapper - INFO - Mapped 97 UPI transactions for bank 0020
2026-06-15 11:32:06 - db.repository - INFO - All 97 transactions skipped
2026-06-15 11:32:06 - db.repository - INFO - Marked file as processed: VCCB_15062026_2C_UPI.txt.gz
2026-06-15 11:32:06 - processors.file_processor - INFO - Successfully processed VCCB_15062026_2C_UPI.txt.gz: 0 inserted, 97 skipped (non-ipks accounts)
2026-06-15 11:32:06 - processors.file_processor - INFO - Starting processing: VCCB_15062026_3C_UPI.txt.gz (bank: 0020)
2026-06-15 11:32:06 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_3C_UPI.txt.gz -> /tmp/VCCB_15062026_3C_UPI.txt.gz
2026-06-15 11:32:06 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_3C_UPI.txt.gz
2026-06-15 11:32:06 - upi_parser - INFO - Parsed 102 rows from /tmp/VCCB_15062026_3C_UPI.txt
2026-06-15 11:32:06 - processors.data_mapper - INFO - Mapped 102 UPI transactions for bank 0020
2026-06-15 11:32:13 - db.repository - INFO - All 102 transactions skipped
2026-06-15 11:32:13 - db.repository - INFO - Marked file as processed: VCCB_15062026_3C_UPI.txt.gz
2026-06-15 11:32:13 - processors.file_processor - INFO - Successfully processed VCCB_15062026_3C_UPI.txt.gz: 0 inserted, 102 skipped (non-ipks accounts)
2026-06-15 11:32:13 - processors.file_processor - INFO - Starting processing: VCCB_15062026_4C_UPI.txt.gz (bank: 0020)
2026-06-15 11:32:13 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_4C_UPI.txt.gz -> /tmp/VCCB_15062026_4C_UPI.txt.gz
2026-06-15 11:32:13 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_4C_UPI.txt.gz
2026-06-15 11:32:13 - upi_parser - INFO - Parsed 245 rows from /tmp/VCCB_15062026_4C_UPI.txt
2026-06-15 11:32:13 - processors.data_mapper - INFO - Mapped 245 UPI transactions for bank 0020
2026-06-15 11:32:25 - db.repository - INFO - All 245 transactions skipped
2026-06-15 11:32:25 - db.repository - INFO - Marked file as processed: VCCB_15062026_4C_UPI.txt.gz
2026-06-15 11:32:25 - processors.file_processor - INFO - Successfully processed VCCB_15062026_4C_UPI.txt.gz: 0 inserted, 245 skipped (non-ipks accounts)
2026-06-15 11:32:25 - processors.file_processor - INFO - Processing complete: 21/21 successful
2026-06-15 11:32:25 - scheduler - INFO - Cycle 1 complete:
2026-06-15 11:32:25 - scheduler - INFO -   Total files: 21
2026-06-15 11:32:25 - scheduler - INFO -   Successful: 21
2026-06-15 11:32:25 - scheduler - INFO -   Failed: 0
2026-06-15 11:32:25 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 11:32:25 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 12:02:25 - scheduler - INFO - === Starting processing cycle 2 ===
2026-06-15 12:02:25 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 12:02:25 - scheduler - INFO - listing file for 15062026
2026-06-15 12:02:25 - scheduler - INFO - Found new file: HOOGLY_15062026_5C_UPI.txt.gz (bank: 0002)
2026-06-15 12:02:25 - scheduler - INFO - Found new file: TUMLUK_15062026_5C_UPI.txt.gz (bank: 0005)
2026-06-15 12:02:26 - scheduler - INFO - Found new file: MLDB_15062026_5C_UPI.txt.gz (bank: 0017)
2026-06-15 12:02:26 - scheduler - INFO - Found new file: MUGB_15062026_5C_UPI.txt.gz (bank: 0018)
2026-06-15 12:02:26 - scheduler - INFO - Found new file: VCCB_15062026_5C_UPI.txt.gz (bank: 0020)
2026-06-15 12:02:26 - scheduler - INFO - Found 5 new files to process
2026-06-15 12:02:26 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_5C_UPI.txt.gz (bank: 0002)
2026-06-15 12:02:26 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_5C_UPI.txt.gz -> /tmp/HOOGLY_15062026_5C_UPI.txt.gz
2026-06-15 12:02:26 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_5C_UPI.txt.gz
2026-06-15 12:02:26 - upi_parser - INFO - Parsed 56 rows from /tmp/HOOGLY_15062026_5C_UPI.txt
2026-06-15 12:02:26 - processors.data_mapper - INFO - Mapped 56 UPI transactions for bank 0002
2026-06-15 12:02:34 - db.repository - INFO - All 56 transactions skipped
2026-06-15 12:02:34 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_5C_UPI.txt.gz
2026-06-15 12:02:34 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_5C_UPI.txt.gz: 0 inserted, 56 skipped (non-ipks accounts)
2026-06-15 12:02:34 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_5C_UPI.txt.gz (bank: 0005)
2026-06-15 12:02:34 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_5C_UPI.txt.gz -> /tmp/TUMLUK_15062026_5C_UPI.txt.gz
2026-06-15 12:02:34 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_5C_UPI.txt.gz
2026-06-15 12:02:34 - upi_parser - INFO - Parsed 832 rows from /tmp/TUMLUK_15062026_5C_UPI.txt
2026-06-15 12:02:34 - processors.data_mapper - INFO - Mapped 832 UPI transactions for bank 0005
2026-06-15 12:03:15 - db.repository - INFO - [{'BANKCODE': '0005', 'RRN': '387089761751', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('15000.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113002383724', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 12:03:15 - db.repository - INFO - executemany rowcount: 1
2026-06-15 12:03:15 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 12:03:15 - db.repository - INFO - Inserted 1 UPI transactions
2026-06-15 12:03:15 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_5C_UPI.txt.gz
2026-06-15 12:03:15 - processors.file_processor - INFO - Successfully processed TUMLUK_15062026_5C_UPI.txt.gz: 1 inserted, 831 skipped (non-ipks accounts)
2026-06-15 12:03:15 - processors.file_processor - INFO - Starting processing: MLDB_15062026_5C_UPI.txt.gz (bank: 0017)
2026-06-15 12:03:15 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_5C_UPI.txt.gz -> /tmp/MLDB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:15 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:15 - upi_parser - INFO - Parsed 44 rows from /tmp/MLDB_15062026_5C_UPI.txt
2026-06-15 12:03:15 - processors.data_mapper - INFO - Mapped 44 UPI transactions for bank 0017
2026-06-15 12:03:17 - db.repository - INFO - All 44 transactions skipped
2026-06-15 12:03:17 - db.repository - INFO - Marked file as processed: MLDB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:17 - processors.file_processor - INFO - Successfully processed MLDB_15062026_5C_UPI.txt.gz: 0 inserted, 44 skipped (non-ipks accounts)
2026-06-15 12:03:17 - processors.file_processor - INFO - Starting processing: MUGB_15062026_5C_UPI.txt.gz (bank: 0018)
2026-06-15 12:03:17 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_5C_UPI.txt.gz -> /tmp/MUGB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:17 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:17 - upi_parser - INFO - Parsed 453 rows from /tmp/MUGB_15062026_5C_UPI.txt
2026-06-15 12:03:17 - processors.data_mapper - INFO - Mapped 453 UPI transactions for bank 0018
2026-06-15 12:03:40 - db.repository - INFO - All 453 transactions skipped
2026-06-15 12:03:40 - db.repository - INFO - Marked file as processed: MUGB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:40 - processors.file_processor - INFO - Successfully processed MUGB_15062026_5C_UPI.txt.gz: 0 inserted, 453 skipped (non-ipks accounts)
2026-06-15 12:03:40 - processors.file_processor - INFO - Starting processing: VCCB_15062026_5C_UPI.txt.gz (bank: 0020)
2026-06-15 12:03:40 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_5C_UPI.txt.gz -> /tmp/VCCB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:40 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_5C_UPI.txt.gz
2026-06-15 12:03:40 - upi_parser - INFO - Parsed 398 rows from /tmp/VCCB_15062026_5C_UPI.txt
2026-06-15 12:03:40 - processors.data_mapper - INFO - Mapped 398 UPI transactions for bank 0020
2026-06-15 12:04:00 - db.repository - INFO - [{'BANKCODE': '0020', 'RRN': '070628646632', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006289542', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '934814759431', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006347335', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '742016934735', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007520105', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '155092600314', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006318643', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '661626740037', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006339038', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '008239733021', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006291506', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '934781986173', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006291970', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '182560092252', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006282514', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '673997701952', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123010032077', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '079004094319', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007226193', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '105996946205', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123009771623', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '248657365153', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123009771634', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '040805695772', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006313167', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '021666526762', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006291595', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '025956828848', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007007997', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '394145052370', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006306943', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 12:04:00 - db.repository - INFO - executemany rowcount: 16
2026-06-15 12:04:00 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 12:04:00 - db.repository - INFO - Inserted 16 UPI transactions
2026-06-15 12:04:00 - db.repository - INFO - Marked file as processed: VCCB_15062026_5C_UPI.txt.gz
2026-06-15 12:04:00 - processors.file_processor - INFO - Successfully processed VCCB_15062026_5C_UPI.txt.gz: 16 inserted, 382 skipped (non-ipks accounts)
2026-06-15 12:04:00 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-15 12:04:00 - scheduler - INFO - Cycle 2 complete:
2026-06-15 12:04:00 - scheduler - INFO -   Total files: 5
2026-06-15 12:04:00 - scheduler - INFO -   Successful: 5
2026-06-15 12:04:00 - scheduler - INFO -   Failed: 0
2026-06-15 12:04:00 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 12:04:00 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 12:34:00 - scheduler - INFO - === Starting processing cycle 3 ===
2026-06-15 12:34:00 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 12:34:00 - scheduler - INFO - listing file for 15062026
2026-06-15 12:34:01 - scheduler - INFO - No new files to process
2026-06-15 12:34:01 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 12:34:01 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 13:04:01 - scheduler - INFO - === Starting processing cycle 4 ===
2026-06-15 13:04:01 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 13:04:01 - scheduler - INFO - listing file for 15062026
2026-06-15 13:04:02 - scheduler - INFO - No new files to process
2026-06-15 13:04:02 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 13:04:02 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 13:34:02 - scheduler - INFO - === Starting processing cycle 5 ===
2026-06-15 13:34:02 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 13:34:02 - scheduler - INFO - listing file for 15062026
2026-06-15 13:34:02 - scheduler - INFO - Found new file: HOOGLY_15062026_6C_UPI.txt.gz (bank: 0002)
2026-06-15 13:34:03 - scheduler - INFO - Found new file: TUMLUK_15062026_6C_UPI.txt.gz (bank: 0005)
2026-06-15 13:34:03 - scheduler - INFO - Found new file: MLDB_15062026_6C_UPI.txt.gz (bank: 0017)
2026-06-15 13:34:03 - scheduler - INFO - Found new file: MUGB_15062026_6C_UPI.txt.gz (bank: 0018)
2026-06-15 13:34:03 - scheduler - INFO - Found new file: VCCB_15062026_6C_UPI.txt.gz (bank: 0020)
2026-06-15 13:34:03 - scheduler - INFO - Found 5 new files to process
2026-06-15 13:34:03 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_6C_UPI.txt.gz (bank: 0002)
2026-06-15 13:34:03 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_6C_UPI.txt.gz -> /tmp/HOOGLY_15062026_6C_UPI.txt.gz
2026-06-15 13:34:03 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_6C_UPI.txt.gz
2026-06-15 13:34:03 - upi_parser - INFO - Parsed 73 rows from /tmp/HOOGLY_15062026_6C_UPI.txt
2026-06-15 13:34:03 - processors.data_mapper - INFO - Mapped 73 UPI transactions for bank 0002
2026-06-15 13:34:11 - db.repository - INFO - [{'BANKCODE': '0002', 'RRN': '585525026970', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1000.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '104003445202', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 13:34:11 - db.repository - INFO - executemany rowcount: 1
2026-06-15 13:34:11 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 13:34:11 - db.repository - INFO - Inserted 1 UPI transactions
2026-06-15 13:34:11 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_6C_UPI.txt.gz
2026-06-15 13:34:11 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_6C_UPI.txt.gz: 1 inserted, 72 skipped (non-ipks accounts)
2026-06-15 13:34:11 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_6C_UPI.txt.gz (bank: 0005)
2026-06-15 13:34:11 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_6C_UPI.txt.gz -> /tmp/TUMLUK_15062026_6C_UPI.txt.gz
2026-06-15 13:34:11 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_6C_UPI.txt.gz
2026-06-15 13:34:11 - upi_parser - INFO - Parsed 932 rows from /tmp/TUMLUK_15062026_6C_UPI.txt
2026-06-15 13:34:11 - processors.data_mapper - INFO - Mapped 932 UPI transactions for bank 0005
2026-06-15 13:34:59 - db.repository - INFO - All 932 transactions skipped
2026-06-15 13:34:59 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_6C_UPI.txt.gz
2026-06-15 13:34:59 - processors.file_processor - INFO - Successfully processed TUMLUK_15062026_6C_UPI.txt.gz: 0 inserted, 932 skipped (non-ipks accounts)
2026-06-15 13:34:59 - processors.file_processor - INFO - Starting processing: MLDB_15062026_6C_UPI.txt.gz (bank: 0017)
2026-06-15 13:34:59 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_6C_UPI.txt.gz -> /tmp/MLDB_15062026_6C_UPI.txt.gz
2026-06-15 13:34:59 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_6C_UPI.txt.gz
2026-06-15 13:34:59 - upi_parser - INFO - Parsed 72 rows from /tmp/MLDB_15062026_6C_UPI.txt
2026-06-15 13:34:59 - processors.data_mapper - INFO - Mapped 72 UPI transactions for bank 0017
2026-06-15 13:35:03 - db.repository - INFO - All 72 transactions skipped
2026-06-15 13:35:03 - db.repository - INFO - Marked file as processed: MLDB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:03 - processors.file_processor - INFO - Successfully processed MLDB_15062026_6C_UPI.txt.gz: 0 inserted, 72 skipped (non-ipks accounts)
2026-06-15 13:35:03 - processors.file_processor - INFO - Starting processing: MUGB_15062026_6C_UPI.txt.gz (bank: 0018)
2026-06-15 13:35:03 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_6C_UPI.txt.gz -> /tmp/MUGB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:03 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:03 - upi_parser - INFO - Parsed 445 rows from /tmp/MUGB_15062026_6C_UPI.txt
2026-06-15 13:35:03 - processors.data_mapper - INFO - Mapped 445 UPI transactions for bank 0018
2026-06-15 13:35:25 - db.repository - INFO - All 445 transactions skipped
2026-06-15 13:35:25 - db.repository - INFO - Marked file as processed: MUGB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:25 - processors.file_processor - INFO - Successfully processed MUGB_15062026_6C_UPI.txt.gz: 0 inserted, 445 skipped (non-ipks accounts)
2026-06-15 13:35:25 - processors.file_processor - INFO - Starting processing: VCCB_15062026_6C_UPI.txt.gz (bank: 0020)
2026-06-15 13:35:25 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_6C_UPI.txt.gz -> /tmp/VCCB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:25 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:25 - upi_parser - INFO - Parsed 433 rows from /tmp/VCCB_15062026_6C_UPI.txt
2026-06-15 13:35:25 - processors.data_mapper - INFO - Mapped 433 UPI transactions for bank 0020
2026-06-15 13:35:47 - db.repository - INFO - All 433 transactions skipped
2026-06-15 13:35:47 - db.repository - INFO - Marked file as processed: VCCB_15062026_6C_UPI.txt.gz
2026-06-15 13:35:47 - processors.file_processor - INFO - Successfully processed VCCB_15062026_6C_UPI.txt.gz: 0 inserted, 433 skipped (non-ipks accounts)
2026-06-15 13:35:47 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-15 13:35:47 - scheduler - INFO - Cycle 5 complete:
2026-06-15 13:35:47 - scheduler - INFO -   Total files: 5
2026-06-15 13:35:47 - scheduler - INFO -   Successful: 5
2026-06-15 13:35:47 - scheduler - INFO -   Failed: 0
2026-06-15 13:35:47 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 13:35:47 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 14:05:47 - scheduler - INFO - === Starting processing cycle 6 ===
2026-06-15 14:05:47 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 14:05:47 - scheduler - INFO - listing file for 15062026
2026-06-15 14:05:48 - scheduler - INFO - No new files to process
2026-06-15 14:05:48 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 14:05:48 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 14:35:48 - scheduler - INFO - === Starting processing cycle 7 ===
2026-06-15 14:35:48 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 14:35:48 - scheduler - INFO - listing file for 15062026
2026-06-15 14:35:49 - scheduler - INFO - No new files to process
2026-06-15 14:35:49 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 14:35:49 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 15:05:49 - scheduler - INFO - === Starting processing cycle 8 ===
2026-06-15 15:05:49 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 15:05:49 - scheduler - INFO - listing file for 15062026
2026-06-15 15:05:50 - scheduler - INFO - No new files to process
2026-06-15 15:05:50 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 15:05:50 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 15:35:50 - scheduler - INFO - === Starting processing cycle 9 ===
2026-06-15 15:35:50 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 15:35:50 - scheduler - INFO - listing file for 15062026
2026-06-15 15:35:50 - scheduler - INFO - Found new file: HOOGLY_15062026_7C_UPI.txt.gz (bank: 0002)
2026-06-15 15:35:51 - scheduler - INFO - Found new file: MUGB_15062026_7C_UPI.txt.gz (bank: 0018)
2026-06-15 15:35:51 - scheduler - INFO - Found new file: VCCB_15062026_7C_UPI.txt.gz (bank: 0020)
2026-06-15 15:35:51 - scheduler - INFO - Found 3 new files to process
2026-06-15 15:35:51 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_7C_UPI.txt.gz (bank: 0002)
2026-06-15 15:35:51 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_7C_UPI.txt.gz -> /tmp/HOOGLY_15062026_7C_UPI.txt.gz
2026-06-15 15:35:51 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_7C_UPI.txt.gz
2026-06-15 15:35:51 - upi_parser - INFO - Parsed 41 rows from /tmp/HOOGLY_15062026_7C_UPI.txt
2026-06-15 15:35:51 - processors.data_mapper - INFO - Mapped 41 UPI transactions for bank 0002
2026-06-15 15:35:59 - db.repository - INFO - All 41 transactions skipped
2026-06-15 15:35:59 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_7C_UPI.txt.gz
2026-06-15 15:35:59 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_7C_UPI.txt.gz: 0 inserted, 41 skipped (non-ipks accounts)
2026-06-15 15:35:59 - processors.file_processor - INFO - Starting processing: MUGB_15062026_7C_UPI.txt.gz (bank: 0018)
2026-06-15 15:35:59 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_7C_UPI.txt.gz -> /tmp/MUGB_15062026_7C_UPI.txt.gz
2026-06-15 15:35:59 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_7C_UPI.txt.gz
2026-06-15 15:35:59 - upi_parser - INFO - Parsed 313 rows from /tmp/MUGB_15062026_7C_UPI.txt
2026-06-15 15:35:59 - processors.data_mapper - INFO - Mapped 313 UPI transactions for bank 0018
2026-06-15 15:36:14 - db.repository - INFO - All 313 transactions skipped
2026-06-15 15:36:14 - db.repository - INFO - Marked file as processed: MUGB_15062026_7C_UPI.txt.gz
2026-06-15 15:36:14 - processors.file_processor - INFO - Successfully processed MUGB_15062026_7C_UPI.txt.gz: 0 inserted, 313 skipped (non-ipks accounts)
2026-06-15 15:36:14 - processors.file_processor - INFO - Starting processing: VCCB_15062026_7C_UPI.txt.gz (bank: 0020)
2026-06-15 15:36:14 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_7C_UPI.txt.gz -> /tmp/VCCB_15062026_7C_UPI.txt.gz
2026-06-15 15:36:14 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_7C_UPI.txt.gz
2026-06-15 15:36:14 - upi_parser - INFO - Parsed 290 rows from /tmp/VCCB_15062026_7C_UPI.txt
2026-06-15 15:36:14 - processors.data_mapper - INFO - Mapped 290 UPI transactions for bank 0020
2026-06-15 15:36:28 - db.repository - INFO - [{'BANKCODE': '0020', 'RRN': '653245154737', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123011698683', 'STATUS': 'SUCCESS', 'NARRATION': 'UPI'}, {'BANKCODE': '0020', 'RRN': '734373939281', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123008995872', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '651602787182', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007733941', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 15:36:28 - db.repository - INFO - executemany rowcount: 3
2026-06-15 15:36:28 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 15:36:28 - db.repository - INFO - Inserted 3 UPI transactions
2026-06-15 15:36:28 - db.repository - INFO - Marked file as processed: VCCB_15062026_7C_UPI.txt.gz
2026-06-15 15:36:28 - processors.file_processor - INFO - Successfully processed VCCB_15062026_7C_UPI.txt.gz: 3 inserted, 287 skipped (non-ipks accounts)
2026-06-15 15:36:28 - processors.file_processor - INFO - Processing complete: 3/3 successful
2026-06-15 15:36:28 - scheduler - INFO - Cycle 9 complete:
2026-06-15 15:36:28 - scheduler - INFO -   Total files: 3
2026-06-15 15:36:28 - scheduler - INFO -   Successful: 3
2026-06-15 15:36:28 - scheduler - INFO -   Failed: 0
2026-06-15 15:36:28 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 15:36:28 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 16:06:28 - scheduler - INFO - === Starting processing cycle 10 ===
2026-06-15 16:06:29 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 16:06:29 - scheduler - INFO - listing file for 15062026
2026-06-15 16:06:29 - scheduler - INFO - No new files to process
2026-06-15 16:06:29 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 16:06:29 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 16:36:29 - scheduler - INFO - === Starting processing cycle 11 ===
2026-06-15 16:36:30 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 16:36:30 - scheduler - INFO - listing file for 15062026
2026-06-15 16:36:30 - scheduler - INFO - No new files to process
2026-06-15 16:36:30 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 16:36:30 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 17:06:30 - scheduler - INFO - === Starting processing cycle 12 ===
2026-06-15 17:06:31 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 17:06:31 - scheduler - INFO - listing file for 15062026
2026-06-15 17:06:31 - scheduler - INFO - No new files to process
2026-06-15 17:06:31 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 17:06:31 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 17:36:31 - scheduler - INFO - === Starting processing cycle 13 ===
2026-06-15 17:36:41 - sftp.sftp_client - ERROR - Failed to connect to SFTP server: timed out
Traceback (most recent call last):
  File "/home/ipkssupport/bishwajeet/upi_inward_file_based/sftp/sftp_client.py", line 38, in connect
    self.ssh.connect(
  File "/home/ipkssupport/bishwajeet/upi_inward_file_based/.venv/lib64/python3.9/site-packages/paramiko/client.py", line 364, in connect
    sock.connect(addr)
socket.timeout: timed out
2026-06-15 17:36:41 - scheduler - ERROR - Failed to connect to SFTP server
2026-06-15 17:36:41 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 17:36:41 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 18:06:42 - scheduler - INFO - === Starting processing cycle 14 ===
2026-06-15 18:06:42 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 18:06:42 - scheduler - INFO - listing file for 15062026
2026-06-15 18:06:42 - scheduler - INFO - No new files to process
2026-06-15 18:06:42 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 18:06:42 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 18:36:42 - scheduler - INFO - === Starting processing cycle 15 ===
2026-06-15 18:36:43 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 18:36:43 - scheduler - INFO - listing file for 15062026
2026-06-15 18:36:43 - scheduler - INFO - Found new file: HOOGLY_15062026_8C_UPI.txt.gz (bank: 0002)
2026-06-15 18:36:43 - scheduler - INFO - Found new file: MUGB_15062026_8C_UPI.txt.gz (bank: 0018)
2026-06-15 18:36:43 - scheduler - INFO - Found new file: VCCB_15062026_8C_UPI.txt.gz (bank: 0020)
2026-06-15 18:36:43 - scheduler - INFO - Found 3 new files to process
2026-06-15 18:36:43 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_8C_UPI.txt.gz (bank: 0002)
2026-06-15 18:36:43 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_8C_UPI.txt.gz -> /tmp/HOOGLY_15062026_8C_UPI.txt.gz
2026-06-15 18:36:43 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_8C_UPI.txt.gz
2026-06-15 18:36:43 - upi_parser - INFO - Parsed 37 rows from /tmp/HOOGLY_15062026_8C_UPI.txt
2026-06-15 18:36:43 - processors.data_mapper - INFO - Mapped 37 UPI transactions for bank 0002
2026-06-15 18:36:51 - db.repository - INFO - All 37 transactions skipped
2026-06-15 18:36:51 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_8C_UPI.txt.gz
2026-06-15 18:36:51 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_8C_UPI.txt.gz: 0 inserted, 37 skipped (non-ipks accounts)
2026-06-15 18:36:51 - processors.file_processor - INFO - Starting processing: MUGB_15062026_8C_UPI.txt.gz (bank: 0018)
2026-06-15 18:36:51 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_8C_UPI.txt.gz -> /tmp/MUGB_15062026_8C_UPI.txt.gz
2026-06-15 18:36:51 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_8C_UPI.txt.gz
2026-06-15 18:36:51 - upi_parser - INFO - Parsed 255 rows from /tmp/MUGB_15062026_8C_UPI.txt
2026-06-15 18:36:51 - processors.data_mapper - INFO - Mapped 255 UPI transactions for bank 0018
2026-06-15 18:37:03 - db.repository - INFO - All 255 transactions skipped
2026-06-15 18:37:03 - db.repository - INFO - Marked file as processed: MUGB_15062026_8C_UPI.txt.gz
2026-06-15 18:37:03 - processors.file_processor - INFO - Successfully processed MUGB_15062026_8C_UPI.txt.gz: 0 inserted, 255 skipped (non-ipks accounts)
2026-06-15 18:37:03 - processors.file_processor - INFO - Starting processing: VCCB_15062026_8C_UPI.txt.gz (bank: 0020)
2026-06-15 18:37:03 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_8C_UPI.txt.gz -> /tmp/VCCB_15062026_8C_UPI.txt.gz
2026-06-15 18:37:03 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_8C_UPI.txt.gz
2026-06-15 18:37:03 - upi_parser - INFO - Parsed 230 rows from /tmp/VCCB_15062026_8C_UPI.txt
2026-06-15 18:37:03 - processors.data_mapper - INFO - Mapped 230 UPI transactions for bank 0020
2026-06-15 18:37:14 - db.repository - INFO - [{'BANKCODE': '0020', 'RRN': '539045200651', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123008989857', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '840677861409', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007894069', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '457422312028', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007867921', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '672816577268', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007734344', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '445513154480', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123009000955', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '317113346429', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123007734548', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 18:37:14 - db.repository - INFO - executemany rowcount: 6
2026-06-15 18:37:14 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 18:37:14 - db.repository - INFO - Inserted 6 UPI transactions
2026-06-15 18:37:14 - db.repository - INFO - Marked file as processed: VCCB_15062026_8C_UPI.txt.gz
2026-06-15 18:37:14 - processors.file_processor - INFO - Successfully processed VCCB_15062026_8C_UPI.txt.gz: 6 inserted, 224 skipped (non-ipks accounts)
2026-06-15 18:37:14 - processors.file_processor - INFO - Processing complete: 3/3 successful
2026-06-15 18:37:14 - scheduler - INFO - Cycle 15 complete:
2026-06-15 18:37:14 - scheduler - INFO -   Total files: 3
2026-06-15 18:37:14 - scheduler - INFO -   Successful: 3
2026-06-15 18:37:14 - scheduler - INFO -   Failed: 0
2026-06-15 18:37:14 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 18:37:14 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 19:07:14 - scheduler - INFO - === Starting processing cycle 16 ===
2026-06-15 19:07:14 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 19:07:14 - scheduler - INFO - listing file for 15062026
2026-06-15 19:07:15 - scheduler - INFO - No new files to process
2026-06-15 19:07:15 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 19:07:15 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 19:37:15 - scheduler - INFO - === Starting processing cycle 17 ===
2026-06-15 19:37:15 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 19:37:15 - scheduler - INFO - listing file for 15062026
2026-06-15 19:37:15 - scheduler - INFO - Found new file: HOOGLY_15062026_9C_UPI.txt.gz (bank: 0002)
2026-06-15 19:37:15 - scheduler - INFO - Found new file: TUMLUK_15062026_9C_UPI.txt.gz (bank: 0005)
2026-06-15 19:37:16 - scheduler - INFO - Found new file: MUGB_15062026_9C_UPI.txt.gz (bank: 0018)
2026-06-15 19:37:16 - scheduler - INFO - Found new file: VCCB_15062026_9C_UPI.txt.gz (bank: 0020)
2026-06-15 19:37:16 - scheduler - INFO - Found 4 new files to process
2026-06-15 19:37:16 - processors.file_processor - INFO - Starting processing: HOOGLY_15062026_9C_UPI.txt.gz (bank: 0002)
2026-06-15 19:37:16 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_15062026_9C_UPI.txt.gz -> /tmp/HOOGLY_15062026_9C_UPI.txt.gz
2026-06-15 19:37:16 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_15062026_9C_UPI.txt.gz
2026-06-15 19:37:16 - upi_parser - INFO - Parsed 73 rows from /tmp/HOOGLY_15062026_9C_UPI.txt
2026-06-15 19:37:16 - processors.data_mapper - INFO - Mapped 73 UPI transactions for bank 0002
2026-06-15 19:37:23 - db.repository - INFO - All 73 transactions skipped
2026-06-15 19:37:23 - db.repository - INFO - Marked file as processed: HOOGLY_15062026_9C_UPI.txt.gz
2026-06-15 19:37:23 - processors.file_processor - INFO - Successfully processed HOOGLY_15062026_9C_UPI.txt.gz: 0 inserted, 73 skipped (non-ipks accounts)
2026-06-15 19:37:23 - processors.file_processor - INFO - Starting processing: TUMLUK_15062026_9C_UPI.txt.gz (bank: 0005)
2026-06-15 19:37:23 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_15062026_9C_UPI.txt.gz -> /tmp/TUMLUK_15062026_9C_UPI.txt.gz
2026-06-15 19:37:23 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_15062026_9C_UPI.txt.gz
2026-06-15 19:37:23 - upi_parser - INFO - Parsed 929 rows from /tmp/TUMLUK_15062026_9C_UPI.txt
2026-06-15 19:37:23 - processors.data_mapper - INFO - Mapped 929 UPI transactions for bank 0005
2026-06-15 19:38:07 - db.repository - INFO - [{'BANKCODE': '0005', 'RRN': '929281425187', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('12000.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113006118117', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 19:38:07 - db.repository - INFO - executemany rowcount: 1
2026-06-15 19:38:07 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 19:38:07 - db.repository - INFO - Inserted 1 UPI transactions
2026-06-15 19:38:07 - db.repository - INFO - Marked file as processed: TUMLUK_15062026_9C_UPI.txt.gz
2026-06-15 19:38:07 - processors.file_processor - INFO - Successfully processed TUMLUK_15062026_9C_UPI.txt.gz: 1 inserted, 928 skipped (non-ipks accounts)
2026-06-15 19:38:07 - processors.file_processor - INFO - Starting processing: MUGB_15062026_9C_UPI.txt.gz (bank: 0018)
2026-06-15 19:38:07 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_9C_UPI.txt.gz -> /tmp/MUGB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:07 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:07 - upi_parser - INFO - Parsed 412 rows from /tmp/MUGB_15062026_9C_UPI.txt
2026-06-15 19:38:07 - processors.data_mapper - INFO - Mapped 412 UPI transactions for bank 0018
2026-06-15 19:38:26 - db.repository - INFO - All 412 transactions skipped
2026-06-15 19:38:26 - db.repository - INFO - Marked file as processed: MUGB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:26 - processors.file_processor - INFO - Successfully processed MUGB_15062026_9C_UPI.txt.gz: 0 inserted, 412 skipped (non-ipks accounts)
2026-06-15 19:38:26 - processors.file_processor - INFO - Starting processing: VCCB_15062026_9C_UPI.txt.gz (bank: 0020)
2026-06-15 19:38:27 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_9C_UPI.txt.gz -> /tmp/VCCB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:27 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:27 - upi_parser - INFO - Parsed 442 rows from /tmp/VCCB_15062026_9C_UPI.txt
2026-06-15 19:38:27 - processors.data_mapper - INFO - Mapped 442 UPI transactions for bank 0020
2026-06-15 19:38:47 - db.repository - INFO - [{'BANKCODE': '0020', 'RRN': '992951793606', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123009021477', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '415567040338', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006074932', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '015530440237', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006912183', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '646527928228', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('2.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006912183', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0020', 'RRN': '123422276059', 'TXN_DATE': '15062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '123006025215', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}]
2026-06-15 19:38:47 - db.repository - INFO - executemany rowcount: 5
2026-06-15 19:38:47 - db.repository - INFO - UPI transactions committed successfully
2026-06-15 19:38:47 - db.repository - INFO - Inserted 5 UPI transactions
2026-06-15 19:38:47 - db.repository - INFO - Marked file as processed: VCCB_15062026_9C_UPI.txt.gz
2026-06-15 19:38:47 - processors.file_processor - INFO - Successfully processed VCCB_15062026_9C_UPI.txt.gz: 5 inserted, 437 skipped (non-ipks accounts)
2026-06-15 19:38:47 - processors.file_processor - INFO - Processing complete: 4/4 successful
2026-06-15 19:38:47 - scheduler - INFO - Cycle 17 complete:
2026-06-15 19:38:47 - scheduler - INFO -   Total files: 4
2026-06-15 19:38:47 - scheduler - INFO -   Successful: 4
2026-06-15 19:38:47 - scheduler - INFO -   Failed: 0
2026-06-15 19:38:47 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 19:38:47 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 20:08:47 - scheduler - INFO - === Starting processing cycle 18 ===
2026-06-15 20:08:48 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 20:08:48 - scheduler - INFO - listing file for 15062026
2026-06-15 20:08:48 - scheduler - INFO - No new files to process
2026-06-15 20:08:48 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 20:08:48 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 20:38:48 - scheduler - INFO - === Starting processing cycle 19 ===
2026-06-15 20:38:49 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 20:38:49 - scheduler - INFO - listing file for 15062026
2026-06-15 20:38:49 - scheduler - INFO - No new files to process
2026-06-15 20:38:49 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 20:38:49 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 21:08:49 - scheduler - INFO - === Starting processing cycle 20 ===
2026-06-15 21:08:50 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 21:08:50 - scheduler - INFO - listing file for 15062026
2026-06-15 21:08:50 - scheduler - INFO - No new files to process
2026-06-15 21:08:50 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 21:08:50 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 21:38:50 - scheduler - INFO - === Starting processing cycle 21 ===
2026-06-15 21:38:51 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 21:38:51 - scheduler - INFO - listing file for 15062026
2026-06-15 21:38:51 - scheduler - INFO - Found new file: MLDB_15062026_10C_UPI.txt.gz (bank: 0017)
2026-06-15 21:38:51 - scheduler - INFO - Found new file: MUGB_15062026_10C_UPI.txt.gz (bank: 0018)
2026-06-15 21:38:51 - scheduler - INFO - Found new file: VCCB_15062026_10C_UPI.txt.gz (bank: 0020)
2026-06-15 21:38:51 - scheduler - INFO - Found 3 new files to process
2026-06-15 21:38:51 - processors.file_processor - INFO - Starting processing: MLDB_15062026_10C_UPI.txt.gz (bank: 0017)
2026-06-15 21:38:51 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_15062026_10C_UPI.txt.gz -> /tmp/MLDB_15062026_10C_UPI.txt.gz
2026-06-15 21:38:51 - processors.file_processor - INFO - Extracting GZ file: MLDB_15062026_10C_UPI.txt.gz
2026-06-15 21:38:51 - upi_parser - INFO - Parsed 88 rows from /tmp/MLDB_15062026_10C_UPI.txt
2026-06-15 21:38:51 - processors.data_mapper - INFO - Mapped 88 UPI transactions for bank 0017
2026-06-15 21:39:01 - db.repository - INFO - All 88 transactions skipped
2026-06-15 21:39:01 - db.repository - INFO - Marked file as processed: MLDB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:01 - processors.file_processor - INFO - Successfully processed MLDB_15062026_10C_UPI.txt.gz: 0 inserted, 88 skipped (non-ipks accounts)
2026-06-15 21:39:01 - processors.file_processor - INFO - Starting processing: MUGB_15062026_10C_UPI.txt.gz (bank: 0018)
2026-06-15 21:39:01 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_15062026_10C_UPI.txt.gz -> /tmp/MUGB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:01 - processors.file_processor - INFO - Extracting GZ file: MUGB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:01 - upi_parser - INFO - Parsed 753 rows from /tmp/MUGB_15062026_10C_UPI.txt
2026-06-15 21:39:01 - processors.data_mapper - INFO - Mapped 753 UPI transactions for bank 0018
2026-06-15 21:39:36 - db.repository - INFO - All 753 transactions skipped
2026-06-15 21:39:36 - db.repository - INFO - Marked file as processed: MUGB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:36 - processors.file_processor - INFO - Successfully processed MUGB_15062026_10C_UPI.txt.gz: 0 inserted, 753 skipped (non-ipks accounts)
2026-06-15 21:39:36 - processors.file_processor - INFO - Starting processing: VCCB_15062026_10C_UPI.txt.gz (bank: 0020)
2026-06-15 21:39:36 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_15062026_10C_UPI.txt.gz -> /tmp/VCCB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:36 - processors.file_processor - INFO - Extracting GZ file: VCCB_15062026_10C_UPI.txt.gz
2026-06-15 21:39:36 - upi_parser - INFO - Parsed 613 rows from /tmp/VCCB_15062026_10C_UPI.txt
2026-06-15 21:39:36 - processors.data_mapper - INFO - Mapped 613 UPI transactions for bank 0020
2026-06-15 21:40:06 - db.repository - INFO - All 613 transactions skipped
2026-06-15 21:40:06 - db.repository - INFO - Marked file as processed: VCCB_15062026_10C_UPI.txt.gz
2026-06-15 21:40:06 - processors.file_processor - INFO - Successfully processed VCCB_15062026_10C_UPI.txt.gz: 0 inserted, 613 skipped (non-ipks accounts)
2026-06-15 21:40:06 - processors.file_processor - INFO - Processing complete: 3/3 successful
2026-06-15 21:40:06 - scheduler - INFO - Cycle 21 complete:
2026-06-15 21:40:06 - scheduler - INFO -   Total files: 3
2026-06-15 21:40:06 - scheduler - INFO -   Successful: 3
2026-06-15 21:40:06 - scheduler - INFO -   Failed: 0
2026-06-15 21:40:06 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 21:40:06 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 22:10:06 - scheduler - INFO - === Starting processing cycle 22 ===
2026-06-15 22:10:06 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 22:10:06 - scheduler - INFO - listing file for 15062026
2026-06-15 22:10:07 - scheduler - INFO - No new files to process
2026-06-15 22:10:07 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 22:10:07 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 22:40:07 - scheduler - INFO - === Starting processing cycle 23 ===
2026-06-15 22:40:07 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 22:40:07 - scheduler - INFO - listing file for 15062026
2026-06-15 22:40:07 - scheduler - INFO - No new files to process
2026-06-15 22:40:07 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 22:40:07 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 23:10:08 - scheduler - INFO - === Starting processing cycle 24 ===
2026-06-15 23:10:08 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 23:10:08 - scheduler - INFO - listing file for 15062026
2026-06-15 23:10:08 - scheduler - INFO - No new files to process
2026-06-15 23:10:08 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 23:10:08 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-15 23:40:08 - scheduler - INFO - === Starting processing cycle 25 ===
2026-06-15 23:40:10 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-15 23:40:10 - scheduler - INFO - listing file for 15062026
2026-06-15 23:40:10 - scheduler - INFO - No new files to process
2026-06-15 23:40:10 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-15 23:40:10 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 00:10:10 - scheduler - INFO - === Starting processing cycle 26 ===
2026-06-16 00:10:11 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 00:10:11 - scheduler - INFO - listing file for 16062026
2026-06-16 00:10:11 - scheduler - INFO - No new files to process
2026-06-16 00:10:11 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 00:10:11 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 00:40:11 - scheduler - INFO - === Starting processing cycle 27 ===
2026-06-16 00:40:11 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 00:40:11 - scheduler - INFO - listing file for 16062026
2026-06-16 00:40:12 - scheduler - INFO - No new files to process
2026-06-16 00:40:12 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 00:40:12 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 01:10:12 - scheduler - INFO - === Starting processing cycle 28 ===
2026-06-16 01:10:12 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 01:10:12 - scheduler - INFO - listing file for 16062026
2026-06-16 01:10:13 - scheduler - INFO - No new files to process
2026-06-16 01:10:13 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 01:10:13 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 01:40:13 - scheduler - INFO - === Starting processing cycle 29 ===
2026-06-16 01:40:13 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 01:40:13 - scheduler - INFO - listing file for 16062026
2026-06-16 01:40:13 - scheduler - INFO - Found new file: HOOGLY_16062026_1C_UPI.txt.gz (bank: 0002)
2026-06-16 01:40:13 - scheduler - INFO - Found new file: TUMLUK_16062026_1C_UPI.txt.gz (bank: 0005)
2026-06-16 01:40:13 - scheduler - INFO - Found new file: MLDB_16062026_1C_UPI.txt.gz (bank: 0017)
2026-06-16 01:40:14 - scheduler - INFO - Found new file: MUGB_16062026_1C_UPI.txt.gz (bank: 0018)
2026-06-16 01:40:14 - scheduler - INFO - Found new file: VCCB_16062026_1C_UPI.txt.gz (bank: 0020)
2026-06-16 01:40:14 - scheduler - INFO - Found 5 new files to process
2026-06-16 01:40:14 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_1C_UPI.txt.gz (bank: 0002)
2026-06-16 01:40:14 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_1C_UPI.txt.gz -> /tmp/HOOGLY_16062026_1C_UPI.txt.gz
2026-06-16 01:40:14 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_1C_UPI.txt.gz
2026-06-16 01:40:14 - upi_parser - INFO - Parsed 40 rows from /tmp/HOOGLY_16062026_1C_UPI.txt
2026-06-16 01:40:14 - processors.data_mapper - INFO - Mapped 40 UPI transactions for bank 0002
2026-06-16 01:40:21 - db.repository - INFO - All 40 transactions skipped
2026-06-16 01:40:21 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_1C_UPI.txt.gz
2026-06-16 01:40:21 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_1C_UPI.txt.gz: 0 inserted, 40 skipped (non-ipks accounts)
2026-06-16 01:40:21 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_1C_UPI.txt.gz (bank: 0005)
2026-06-16 01:40:21 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_1C_UPI.txt.gz -> /tmp/TUMLUK_16062026_1C_UPI.txt.gz
2026-06-16 01:40:21 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_1C_UPI.txt.gz
2026-06-16 01:40:21 - upi_parser - INFO - Parsed 838 rows from /tmp/TUMLUK_16062026_1C_UPI.txt
2026-06-16 01:40:21 - processors.data_mapper - INFO - Mapped 838 UPI transactions for bank 0005
2026-06-16 01:41:00 - db.repository - INFO - All 838 transactions skipped
2026-06-16 01:41:00 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_1C_UPI.txt.gz
2026-06-16 01:41:00 - processors.file_processor - INFO - Successfully processed TUMLUK_16062026_1C_UPI.txt.gz: 0 inserted, 838 skipped (non-ipks accounts)
2026-06-16 01:41:00 - processors.file_processor - INFO - Starting processing: MLDB_16062026_1C_UPI.txt.gz (bank: 0017)
2026-06-16 01:41:00 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_1C_UPI.txt.gz -> /tmp/MLDB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:00 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:00 - upi_parser - INFO - Parsed 58 rows from /tmp/MLDB_16062026_1C_UPI.txt
2026-06-16 01:41:00 - processors.data_mapper - INFO - Mapped 58 UPI transactions for bank 0017
2026-06-16 01:41:03 - db.repository - INFO - All 58 transactions skipped
2026-06-16 01:41:03 - db.repository - INFO - Marked file as processed: MLDB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:03 - processors.file_processor - INFO - Successfully processed MLDB_16062026_1C_UPI.txt.gz: 0 inserted, 58 skipped (non-ipks accounts)
2026-06-16 01:41:03 - processors.file_processor - INFO - Starting processing: MUGB_16062026_1C_UPI.txt.gz (bank: 0018)
2026-06-16 01:41:03 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_1C_UPI.txt.gz -> /tmp/MUGB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:03 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:03 - upi_parser - INFO - Parsed 573 rows from /tmp/MUGB_16062026_1C_UPI.txt
2026-06-16 01:41:03 - processors.data_mapper - INFO - Mapped 573 UPI transactions for bank 0018
2026-06-16 01:41:29 - db.repository - INFO - All 573 transactions skipped
2026-06-16 01:41:29 - db.repository - INFO - Marked file as processed: MUGB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:29 - processors.file_processor - INFO - Successfully processed MUGB_16062026_1C_UPI.txt.gz: 0 inserted, 573 skipped (non-ipks accounts)
2026-06-16 01:41:29 - processors.file_processor - INFO - Starting processing: VCCB_16062026_1C_UPI.txt.gz (bank: 0020)
2026-06-16 01:41:29 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_1C_UPI.txt.gz -> /tmp/VCCB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:29 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:29 - upi_parser - INFO - Parsed 345 rows from /tmp/VCCB_16062026_1C_UPI.txt
2026-06-16 01:41:29 - processors.data_mapper - INFO - Mapped 345 UPI transactions for bank 0020
2026-06-16 01:41:45 - db.repository - INFO - All 345 transactions skipped
2026-06-16 01:41:45 - db.repository - INFO - Marked file as processed: VCCB_16062026_1C_UPI.txt.gz
2026-06-16 01:41:45 - processors.file_processor - INFO - Successfully processed VCCB_16062026_1C_UPI.txt.gz: 0 inserted, 345 skipped (non-ipks accounts)
2026-06-16 01:41:45 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 01:41:45 - scheduler - INFO - Cycle 29 complete:
2026-06-16 01:41:45 - scheduler - INFO -   Total files: 5
2026-06-16 01:41:45 - scheduler - INFO -   Successful: 5
2026-06-16 01:41:45 - scheduler - INFO -   Failed: 0
2026-06-16 01:41:45 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 01:41:45 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 02:11:45 - scheduler - INFO - === Starting processing cycle 30 ===
2026-06-16 02:11:45 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 02:11:45 - scheduler - INFO - listing file for 16062026
2026-06-16 02:11:46 - scheduler - INFO - No new files to process
2026-06-16 02:11:46 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 02:11:46 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 02:41:46 - scheduler - INFO - === Starting processing cycle 31 ===
2026-06-16 02:41:46 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 02:41:46 - scheduler - INFO - listing file for 16062026
2026-06-16 02:41:47 - scheduler - INFO - No new files to process
2026-06-16 02:41:47 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 02:41:47 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 03:11:47 - scheduler - INFO - === Starting processing cycle 32 ===
2026-06-16 03:11:47 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 03:11:47 - scheduler - INFO - listing file for 16062026
2026-06-16 03:11:47 - scheduler - INFO - No new files to process
2026-06-16 03:11:47 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 03:11:47 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 03:41:48 - scheduler - INFO - === Starting processing cycle 33 ===
2026-06-16 03:41:48 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 03:41:48 - scheduler - INFO - listing file for 16062026
2026-06-16 03:41:48 - scheduler - INFO - No new files to process
2026-06-16 03:41:48 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 03:41:48 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 04:11:48 - scheduler - INFO - === Starting processing cycle 34 ===
2026-06-16 04:11:49 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 04:11:49 - scheduler - INFO - listing file for 16062026
2026-06-16 04:11:49 - scheduler - INFO - No new files to process
2026-06-16 04:11:49 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 04:11:49 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 04:41:49 - scheduler - INFO - === Starting processing cycle 35 ===
2026-06-16 04:41:50 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 04:41:50 - scheduler - INFO - listing file for 16062026
2026-06-16 04:41:50 - scheduler - INFO - No new files to process
2026-06-16 04:41:50 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 04:41:50 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 05:11:50 - scheduler - INFO - === Starting processing cycle 36 ===
2026-06-16 05:11:51 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 05:11:51 - scheduler - INFO - listing file for 16062026
2026-06-16 05:11:51 - scheduler - INFO - No new files to process
2026-06-16 05:11:51 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 05:11:51 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 05:41:51 - scheduler - INFO - === Starting processing cycle 37 ===
2026-06-16 05:41:52 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 05:41:52 - scheduler - INFO - listing file for 16062026
2026-06-16 05:41:52 - scheduler - INFO - Found new file: HOOGLY_16062026_10C_UPI.txt.gz (bank: 0002)
2026-06-16 05:41:52 - scheduler - INFO - Found new file: HOOGLY_16062026_2C_UPI.txt.gz (bank: 0002)
2026-06-16 05:41:52 - scheduler - INFO - Found new file: TUMLUK_16062026_2C_UPI.txt.gz (bank: 0005)
2026-06-16 05:41:52 - scheduler - INFO - Found new file: MLDB_16062026_2C_UPI.txt.gz (bank: 0017)
2026-06-16 05:41:52 - scheduler - INFO - Found new file: MUGB_16062026_2C_UPI.txt.gz (bank: 0018)
2026-06-16 05:41:52 - scheduler - INFO - Found new file: VCCB_16062026_2C_UPI.txt.gz (bank: 0020)
2026-06-16 05:41:52 - scheduler - INFO - Found 6 new files to process
2026-06-16 05:41:52 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_10C_UPI.txt.gz (bank: 0002)
2026-06-16 05:41:52 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_10C_UPI.txt.gz -> /tmp/HOOGLY_16062026_10C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_10C_UPI.txt.gz
2026-06-16 05:41:52 - upi_parser - INFO - Parsed 0 rows from /tmp/HOOGLY_16062026_10C_UPI.txt
2026-06-16 05:41:52 - processors.file_processor - WARNING - No transactions found in HOOGLY_16062026_10C_UPI.txt.gz
2026-06-16 05:41:52 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_10C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_2C_UPI.txt.gz (bank: 0002)
2026-06-16 05:41:52 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_2C_UPI.txt.gz -> /tmp/HOOGLY_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - upi_parser - INFO - Parsed 3 rows from /tmp/HOOGLY_16062026_2C_UPI.txt
2026-06-16 05:41:52 - processors.data_mapper - INFO - Mapped 3 UPI transactions for bank 0002
2026-06-16 05:41:52 - db.repository - INFO - All 3 transactions skipped
2026-06-16 05:41:52 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_2C_UPI.txt.gz: 0 inserted, 3 skipped (non-ipks accounts)
2026-06-16 05:41:52 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_2C_UPI.txt.gz (bank: 0005)
2026-06-16 05:41:52 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_2C_UPI.txt.gz -> /tmp/TUMLUK_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - upi_parser - INFO - Parsed 0 rows from /tmp/TUMLUK_16062026_2C_UPI.txt
2026-06-16 05:41:52 - processors.file_processor - WARNING - No transactions found in TUMLUK_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Starting processing: MLDB_16062026_2C_UPI.txt.gz (bank: 0017)
2026-06-16 05:41:52 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_2C_UPI.txt.gz -> /tmp/MLDB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:52 - upi_parser - INFO - Parsed 38 rows from /tmp/MLDB_16062026_2C_UPI.txt
2026-06-16 05:41:52 - processors.data_mapper - INFO - Mapped 38 UPI transactions for bank 0017
2026-06-16 05:41:54 - db.repository - INFO - All 38 transactions skipped
2026-06-16 05:41:54 - db.repository - INFO - Marked file as processed: MLDB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:54 - processors.file_processor - INFO - Successfully processed MLDB_16062026_2C_UPI.txt.gz: 0 inserted, 38 skipped (non-ipks accounts)
2026-06-16 05:41:54 - processors.file_processor - INFO - Starting processing: MUGB_16062026_2C_UPI.txt.gz (bank: 0018)
2026-06-16 05:41:54 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_2C_UPI.txt.gz -> /tmp/MUGB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:54 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:54 - upi_parser - INFO - Parsed 55 rows from /tmp/MUGB_16062026_2C_UPI.txt
2026-06-16 05:41:54 - processors.data_mapper - INFO - Mapped 55 UPI transactions for bank 0018
2026-06-16 05:41:56 - db.repository - INFO - All 55 transactions skipped
2026-06-16 05:41:56 - db.repository - INFO - Marked file as processed: MUGB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:56 - processors.file_processor - INFO - Successfully processed MUGB_16062026_2C_UPI.txt.gz: 0 inserted, 55 skipped (non-ipks accounts)
2026-06-16 05:41:56 - processors.file_processor - INFO - Starting processing: VCCB_16062026_2C_UPI.txt.gz (bank: 0020)
2026-06-16 05:41:56 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_2C_UPI.txt.gz -> /tmp/VCCB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:56 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_2C_UPI.txt.gz
2026-06-16 05:41:56 - upi_parser - INFO - Parsed 74 rows from /tmp/VCCB_16062026_2C_UPI.txt
2026-06-16 05:41:56 - processors.data_mapper - INFO - Mapped 74 UPI transactions for bank 0020
2026-06-16 05:42:00 - db.repository - INFO - All 74 transactions skipped
2026-06-16 05:42:00 - db.repository - INFO - Marked file as processed: VCCB_16062026_2C_UPI.txt.gz
2026-06-16 05:42:00 - processors.file_processor - INFO - Successfully processed VCCB_16062026_2C_UPI.txt.gz: 0 inserted, 74 skipped (non-ipks accounts)
2026-06-16 05:42:00 - processors.file_processor - INFO - Processing complete: 6/6 successful
2026-06-16 05:42:00 - scheduler - INFO - Cycle 37 complete:
2026-06-16 05:42:00 - scheduler - INFO -   Total files: 6
2026-06-16 05:42:00 - scheduler - INFO -   Successful: 6
2026-06-16 05:42:00 - scheduler - INFO -   Failed: 0
2026-06-16 05:42:00 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 05:42:00 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 06:12:00 - scheduler - INFO - === Starting processing cycle 38 ===
2026-06-16 06:12:00 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 06:12:00 - scheduler - INFO - listing file for 16062026
2026-06-16 06:12:01 - scheduler - INFO - No new files to process
2026-06-16 06:12:01 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 06:12:01 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 06:42:01 - scheduler - INFO - === Starting processing cycle 39 ===
2026-06-16 06:42:01 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 06:42:01 - scheduler - INFO - listing file for 16062026
2026-06-16 06:42:02 - scheduler - INFO - No new files to process
2026-06-16 06:42:02 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 06:42:02 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 07:12:02 - scheduler - INFO - === Starting processing cycle 40 ===
2026-06-16 07:12:02 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 07:12:02 - scheduler - INFO - listing file for 16062026
2026-06-16 07:12:03 - scheduler - INFO - No new files to process
2026-06-16 07:12:03 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 07:12:03 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 07:42:03 - scheduler - INFO - === Starting processing cycle 41 ===
2026-06-16 07:42:03 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 07:42:03 - scheduler - INFO - listing file for 16062026
2026-06-16 07:42:03 - scheduler - INFO - Found new file: HOOGLY_16062026_3C_UPI.txt.gz (bank: 0002)
2026-06-16 07:42:03 - scheduler - INFO - Found new file: TUMLUK_16062026_3C_UPI.txt.gz (bank: 0005)
2026-06-16 07:42:03 - scheduler - INFO - Found new file: MLDB_16062026_3C_UPI.txt.gz (bank: 0017)
2026-06-16 07:42:03 - scheduler - INFO - Found new file: MUGB_16062026_3C_UPI.txt.gz (bank: 0018)
2026-06-16 07:42:04 - scheduler - INFO - Found new file: VCCB_16062026_3C_UPI.txt.gz (bank: 0020)
2026-06-16 07:42:04 - scheduler - INFO - Found 5 new files to process
2026-06-16 07:42:04 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_3C_UPI.txt.gz (bank: 0002)
2026-06-16 07:42:04 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_3C_UPI.txt.gz -> /tmp/HOOGLY_16062026_3C_UPI.txt.gz
2026-06-16 07:42:04 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_3C_UPI.txt.gz
2026-06-16 07:42:04 - upi_parser - INFO - Parsed 8 rows from /tmp/HOOGLY_16062026_3C_UPI.txt
2026-06-16 07:42:04 - processors.data_mapper - INFO - Mapped 8 UPI transactions for bank 0002
2026-06-16 07:42:04 - db.repository - INFO - All 8 transactions skipped
2026-06-16 07:42:04 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_3C_UPI.txt.gz
2026-06-16 07:42:04 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_3C_UPI.txt.gz: 0 inserted, 8 skipped (non-ipks accounts)
2026-06-16 07:42:04 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_3C_UPI.txt.gz (bank: 0005)
2026-06-16 07:42:04 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_3C_UPI.txt.gz -> /tmp/TUMLUK_16062026_3C_UPI.txt.gz
2026-06-16 07:42:04 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_3C_UPI.txt.gz
2026-06-16 07:42:04 - upi_parser - INFO - Parsed 86 rows from /tmp/TUMLUK_16062026_3C_UPI.txt
2026-06-16 07:42:04 - processors.data_mapper - INFO - Mapped 86 UPI transactions for bank 0005
2026-06-16 07:42:08 - db.repository - INFO - All 86 transactions skipped
2026-06-16 07:42:08 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - processors.file_processor - INFO - Successfully processed TUMLUK_16062026_3C_UPI.txt.gz: 0 inserted, 86 skipped (non-ipks accounts)
2026-06-16 07:42:08 - processors.file_processor - INFO - Starting processing: MLDB_16062026_3C_UPI.txt.gz (bank: 0017)
2026-06-16 07:42:08 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_3C_UPI.txt.gz -> /tmp/MLDB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - upi_parser - INFO - Parsed 9 rows from /tmp/MLDB_16062026_3C_UPI.txt
2026-06-16 07:42:08 - processors.data_mapper - INFO - Mapped 9 UPI transactions for bank 0017
2026-06-16 07:42:08 - db.repository - INFO - All 9 transactions skipped
2026-06-16 07:42:08 - db.repository - INFO - Marked file as processed: MLDB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - processors.file_processor - INFO - Successfully processed MLDB_16062026_3C_UPI.txt.gz: 0 inserted, 9 skipped (non-ipks accounts)
2026-06-16 07:42:08 - processors.file_processor - INFO - Starting processing: MUGB_16062026_3C_UPI.txt.gz (bank: 0018)
2026-06-16 07:42:08 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_3C_UPI.txt.gz -> /tmp/MUGB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:08 - upi_parser - INFO - Parsed 94 rows from /tmp/MUGB_16062026_3C_UPI.txt
2026-06-16 07:42:08 - processors.data_mapper - INFO - Mapped 94 UPI transactions for bank 0018
2026-06-16 07:42:13 - db.repository - INFO - All 94 transactions skipped
2026-06-16 07:42:13 - db.repository - INFO - Marked file as processed: MUGB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:13 - processors.file_processor - INFO - Successfully processed MUGB_16062026_3C_UPI.txt.gz: 0 inserted, 94 skipped (non-ipks accounts)
2026-06-16 07:42:13 - processors.file_processor - INFO - Starting processing: VCCB_16062026_3C_UPI.txt.gz (bank: 0020)
2026-06-16 07:42:13 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_3C_UPI.txt.gz -> /tmp/VCCB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:13 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:13 - upi_parser - INFO - Parsed 88 rows from /tmp/VCCB_16062026_3C_UPI.txt
2026-06-16 07:42:13 - processors.data_mapper - INFO - Mapped 88 UPI transactions for bank 0020
2026-06-16 07:42:17 - db.repository - INFO - All 88 transactions skipped
2026-06-16 07:42:17 - db.repository - INFO - Marked file as processed: VCCB_16062026_3C_UPI.txt.gz
2026-06-16 07:42:17 - processors.file_processor - INFO - Successfully processed VCCB_16062026_3C_UPI.txt.gz: 0 inserted, 88 skipped (non-ipks accounts)
2026-06-16 07:42:17 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 07:42:17 - scheduler - INFO - Cycle 41 complete:
2026-06-16 07:42:17 - scheduler - INFO -   Total files: 5
2026-06-16 07:42:17 - scheduler - INFO -   Successful: 5
2026-06-16 07:42:17 - scheduler - INFO -   Failed: 0
2026-06-16 07:42:17 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 07:42:17 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 08:12:17 - scheduler - INFO - === Starting processing cycle 42 ===
2026-06-16 08:12:17 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 08:12:17 - scheduler - INFO - listing file for 16062026
2026-06-16 08:12:17 - scheduler - INFO - No new files to process
2026-06-16 08:12:17 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 08:12:17 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 08:42:18 - scheduler - INFO - === Starting processing cycle 43 ===
2026-06-16 08:42:18 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 08:42:18 - scheduler - INFO - listing file for 16062026
2026-06-16 08:42:18 - scheduler - INFO - No new files to process
2026-06-16 08:42:18 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 08:42:18 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 09:12:19 - scheduler - INFO - === Starting processing cycle 44 ===
2026-06-16 09:12:19 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 09:12:19 - scheduler - INFO - listing file for 16062026
2026-06-16 09:12:19 - scheduler - INFO - No new files to process
2026-06-16 09:12:19 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 09:12:19 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 09:42:20 - scheduler - INFO - === Starting processing cycle 45 ===
2026-06-16 09:42:20 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 09:42:20 - scheduler - INFO - listing file for 16062026
2026-06-16 09:42:20 - scheduler - INFO - Found new file: HOOGLY_16062026_4C_UPI.txt.gz (bank: 0002)
2026-06-16 09:42:20 - scheduler - INFO - Found new file: TUMLUK_16062026_4C_UPI.txt.gz (bank: 0005)
2026-06-16 09:42:20 - scheduler - INFO - Found new file: MLDB_16062026_4C_UPI.txt.gz (bank: 0017)
2026-06-16 09:42:20 - scheduler - INFO - Found new file: MUGB_16062026_4C_UPI.txt.gz (bank: 0018)
2026-06-16 09:42:20 - scheduler - INFO - Found new file: VCCB_16062026_4C_UPI.txt.gz (bank: 0020)
2026-06-16 09:42:20 - scheduler - INFO - Found 5 new files to process
2026-06-16 09:42:20 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_4C_UPI.txt.gz (bank: 0002)
2026-06-16 09:42:20 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_4C_UPI.txt.gz -> /tmp/HOOGLY_16062026_4C_UPI.txt.gz
2026-06-16 09:42:20 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_4C_UPI.txt.gz
2026-06-16 09:42:20 - upi_parser - INFO - Parsed 32 rows from /tmp/HOOGLY_16062026_4C_UPI.txt
2026-06-16 09:42:20 - processors.data_mapper - INFO - Mapped 32 UPI transactions for bank 0002
2026-06-16 09:42:22 - db.repository - INFO - All 32 transactions skipped
2026-06-16 09:42:22 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_4C_UPI.txt.gz
2026-06-16 09:42:22 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_4C_UPI.txt.gz: 0 inserted, 32 skipped (non-ipks accounts)
2026-06-16 09:42:22 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_4C_UPI.txt.gz (bank: 0005)
2026-06-16 09:42:22 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_4C_UPI.txt.gz -> /tmp/TUMLUK_16062026_4C_UPI.txt.gz
2026-06-16 09:42:22 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_4C_UPI.txt.gz
2026-06-16 09:42:22 - upi_parser - INFO - Parsed 553 rows from /tmp/TUMLUK_16062026_4C_UPI.txt
2026-06-16 09:42:22 - processors.data_mapper - INFO - Mapped 553 UPI transactions for bank 0005
2026-06-16 09:42:47 - db.repository - INFO - All 553 transactions skipped
2026-06-16 09:42:47 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_4C_UPI.txt.gz
2026-06-16 09:42:47 - processors.file_processor - INFO - Successfully processed TUMLUK_16062026_4C_UPI.txt.gz: 0 inserted, 553 skipped (non-ipks accounts)
2026-06-16 09:42:47 - processors.file_processor - INFO - Starting processing: MLDB_16062026_4C_UPI.txt.gz (bank: 0017)
2026-06-16 09:42:47 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_4C_UPI.txt.gz -> /tmp/MLDB_16062026_4C_UPI.txt.gz
2026-06-16 09:42:47 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_4C_UPI.txt.gz
2026-06-16 09:42:47 - upi_parser - INFO - Parsed 26 rows from /tmp/MLDB_16062026_4C_UPI.txt
2026-06-16 09:42:47 - processors.data_mapper - INFO - Mapped 26 UPI transactions for bank 0017
2026-06-16 09:42:48 - db.repository - INFO - All 26 transactions skipped
2026-06-16 09:42:48 - db.repository - INFO - Marked file as processed: MLDB_16062026_4C_UPI.txt.gz
2026-06-16 09:42:48 - processors.file_processor - INFO - Successfully processed MLDB_16062026_4C_UPI.txt.gz: 0 inserted, 26 skipped (non-ipks accounts)
2026-06-16 09:42:48 - processors.file_processor - INFO - Starting processing: MUGB_16062026_4C_UPI.txt.gz (bank: 0018)
2026-06-16 09:42:49 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_4C_UPI.txt.gz -> /tmp/MUGB_16062026_4C_UPI.txt.gz
2026-06-16 09:42:49 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_4C_UPI.txt.gz
2026-06-16 09:42:49 - upi_parser - INFO - Parsed 314 rows from /tmp/MUGB_16062026_4C_UPI.txt
2026-06-16 09:42:49 - processors.data_mapper - INFO - Mapped 314 UPI transactions for bank 0018
2026-06-16 09:43:03 - db.repository - INFO - All 314 transactions skipped
2026-06-16 09:43:03 - db.repository - INFO - Marked file as processed: MUGB_16062026_4C_UPI.txt.gz
2026-06-16 09:43:03 - processors.file_processor - INFO - Successfully processed MUGB_16062026_4C_UPI.txt.gz: 0 inserted, 314 skipped (non-ipks accounts)
2026-06-16 09:43:03 - processors.file_processor - INFO - Starting processing: VCCB_16062026_4C_UPI.txt.gz (bank: 0020)
2026-06-16 09:43:03 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_4C_UPI.txt.gz -> /tmp/VCCB_16062026_4C_UPI.txt.gz
2026-06-16 09:43:03 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_4C_UPI.txt.gz
2026-06-16 09:43:03 - upi_parser - INFO - Parsed 214 rows from /tmp/VCCB_16062026_4C_UPI.txt
2026-06-16 09:43:03 - processors.data_mapper - INFO - Mapped 214 UPI transactions for bank 0020
2026-06-16 09:43:13 - db.repository - INFO - All 214 transactions skipped
2026-06-16 09:43:13 - db.repository - INFO - Marked file as processed: VCCB_16062026_4C_UPI.txt.gz
2026-06-16 09:43:13 - processors.file_processor - INFO - Successfully processed VCCB_16062026_4C_UPI.txt.gz: 0 inserted, 214 skipped (non-ipks accounts)
2026-06-16 09:43:13 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 09:43:13 - scheduler - INFO - Cycle 45 complete:
2026-06-16 09:43:13 - scheduler - INFO -   Total files: 5
2026-06-16 09:43:13 - scheduler - INFO -   Successful: 5
2026-06-16 09:43:13 - scheduler - INFO -   Failed: 0
2026-06-16 09:43:13 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 09:43:13 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 10:13:13 - scheduler - INFO - === Starting processing cycle 46 ===
2026-06-16 10:13:14 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 10:13:14 - scheduler - INFO - listing file for 16062026
2026-06-16 10:13:14 - scheduler - INFO - No new files to process
2026-06-16 10:13:14 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 10:13:14 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 10:43:14 - scheduler - INFO - === Starting processing cycle 47 ===
2026-06-16 10:43:14 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 10:43:14 - scheduler - INFO - listing file for 16062026
2026-06-16 10:43:15 - scheduler - INFO - No new files to process
2026-06-16 10:43:15 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 10:43:15 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 11:13:15 - scheduler - INFO - === Starting processing cycle 48 ===
2026-06-16 11:13:15 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 11:13:15 - scheduler - INFO - listing file for 16062026
2026-06-16 11:13:16 - scheduler - INFO - No new files to process
2026-06-16 11:13:16 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 11:13:16 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 11:43:16 - scheduler - INFO - === Starting processing cycle 49 ===
2026-06-16 11:43:16 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 11:43:16 - scheduler - INFO - listing file for 16062026
2026-06-16 11:43:16 - scheduler - INFO - Found new file: HOOGLY_16062026_5C_UPI.txt.gz (bank: 0002)
2026-06-16 11:43:16 - scheduler - INFO - Found new file: TUMLUK_16062026_5C_UPI.txt.gz (bank: 0005)
2026-06-16 11:43:17 - scheduler - INFO - Found new file: MLDB_16062026_5C_UPI.txt.gz (bank: 0017)
2026-06-16 11:43:17 - scheduler - INFO - Found new file: MUGB_16062026_5C_UPI.txt.gz (bank: 0018)
2026-06-16 11:43:17 - scheduler - INFO - Found new file: VCCB_16062026_5C_UPI.txt.gz (bank: 0020)
2026-06-16 11:43:17 - scheduler - INFO - Found 5 new files to process
2026-06-16 11:43:17 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_5C_UPI.txt.gz (bank: 0002)
2026-06-16 11:43:17 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_5C_UPI.txt.gz -> /tmp/HOOGLY_16062026_5C_UPI.txt.gz
2026-06-16 11:43:17 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_5C_UPI.txt.gz
2026-06-16 11:43:17 - upi_parser - INFO - Parsed 41 rows from /tmp/HOOGLY_16062026_5C_UPI.txt
2026-06-16 11:43:17 - processors.data_mapper - INFO - Mapped 41 UPI transactions for bank 0002
2026-06-16 11:43:19 - db.repository - INFO - All 41 transactions skipped
2026-06-16 11:43:19 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_5C_UPI.txt.gz
2026-06-16 11:43:19 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_5C_UPI.txt.gz: 0 inserted, 41 skipped (non-ipks accounts)
2026-06-16 11:43:19 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_5C_UPI.txt.gz (bank: 0005)
2026-06-16 11:43:19 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_5C_UPI.txt.gz -> /tmp/TUMLUK_16062026_5C_UPI.txt.gz
2026-06-16 11:43:19 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_5C_UPI.txt.gz
2026-06-16 11:43:19 - upi_parser - INFO - Parsed 1020 rows from /tmp/TUMLUK_16062026_5C_UPI.txt
2026-06-16 11:43:19 - processors.data_mapper - INFO - Mapped 1020 UPI transactions for bank 0005
2026-06-16 11:44:10 - db.repository - INFO - All 1020 transactions skipped
2026-06-16 11:44:10 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_5C_UPI.txt.gz
2026-06-16 11:44:10 - processors.file_processor - INFO - Successfully processed TUMLUK_16062026_5C_UPI.txt.gz: 0 inserted, 1020 skipped (non-ipks accounts)
2026-06-16 11:44:10 - processors.file_processor - INFO - Starting processing: MLDB_16062026_5C_UPI.txt.gz (bank: 0017)
2026-06-16 11:44:10 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_5C_UPI.txt.gz -> /tmp/MLDB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:10 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:10 - upi_parser - INFO - Parsed 47 rows from /tmp/MLDB_16062026_5C_UPI.txt
2026-06-16 11:44:10 - processors.data_mapper - INFO - Mapped 47 UPI transactions for bank 0017
2026-06-16 11:44:12 - db.repository - INFO - All 47 transactions skipped
2026-06-16 11:44:12 - db.repository - INFO - Marked file as processed: MLDB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:12 - processors.file_processor - INFO - Successfully processed MLDB_16062026_5C_UPI.txt.gz: 0 inserted, 47 skipped (non-ipks accounts)
2026-06-16 11:44:12 - processors.file_processor - INFO - Starting processing: MUGB_16062026_5C_UPI.txt.gz (bank: 0018)
2026-06-16 11:44:12 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_5C_UPI.txt.gz -> /tmp/MUGB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:12 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:12 - upi_parser - INFO - Parsed 484 rows from /tmp/MUGB_16062026_5C_UPI.txt
2026-06-16 11:44:12 - processors.data_mapper - INFO - Mapped 484 UPI transactions for bank 0018
2026-06-16 11:44:35 - db.repository - INFO - All 484 transactions skipped
2026-06-16 11:44:35 - db.repository - INFO - Marked file as processed: MUGB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:35 - processors.file_processor - INFO - Successfully processed MUGB_16062026_5C_UPI.txt.gz: 0 inserted, 484 skipped (non-ipks accounts)
2026-06-16 11:44:35 - processors.file_processor - INFO - Starting processing: VCCB_16062026_5C_UPI.txt.gz (bank: 0020)
2026-06-16 11:44:35 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_5C_UPI.txt.gz -> /tmp/VCCB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:35 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:35 - upi_parser - INFO - Parsed 416 rows from /tmp/VCCB_16062026_5C_UPI.txt
2026-06-16 11:44:35 - processors.data_mapper - INFO - Mapped 416 UPI transactions for bank 0020
2026-06-16 11:44:57 - db.repository - INFO - All 416 transactions skipped
2026-06-16 11:44:57 - db.repository - INFO - Marked file as processed: VCCB_16062026_5C_UPI.txt.gz
2026-06-16 11:44:57 - processors.file_processor - INFO - Successfully processed VCCB_16062026_5C_UPI.txt.gz: 0 inserted, 416 skipped (non-ipks accounts)
2026-06-16 11:44:57 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 11:44:57 - scheduler - INFO - Cycle 49 complete:
2026-06-16 11:44:57 - scheduler - INFO -   Total files: 5
2026-06-16 11:44:57 - scheduler - INFO -   Successful: 5
2026-06-16 11:44:57 - scheduler - INFO -   Failed: 0
2026-06-16 11:44:57 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 11:44:57 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 12:14:57 - scheduler - INFO - === Starting processing cycle 50 ===
2026-06-16 12:14:57 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 12:14:57 - scheduler - INFO - listing file for 16062026
2026-06-16 12:14:58 - scheduler - INFO - No new files to process
2026-06-16 12:14:58 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 12:14:58 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 12:44:58 - scheduler - INFO - === Starting processing cycle 51 ===
2026-06-16 12:44:58 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 12:44:58 - scheduler - INFO - listing file for 16062026
2026-06-16 12:44:59 - scheduler - INFO - No new files to process
2026-06-16 12:44:59 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 12:44:59 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 13:14:59 - scheduler - INFO - === Starting processing cycle 52 ===
2026-06-16 13:14:59 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 13:14:59 - scheduler - INFO - listing file for 16062026
2026-06-16 13:15:00 - scheduler - INFO - No new files to process
2026-06-16 13:15:00 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 13:15:00 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 13:45:00 - scheduler - INFO - === Starting processing cycle 53 ===
2026-06-16 13:45:00 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 13:45:00 - scheduler - INFO - listing file for 16062026
2026-06-16 13:45:01 - scheduler - INFO - Found new file: HOOGLY_16062026_6C_UPI.txt.gz (bank: 0002)
2026-06-16 13:45:01 - scheduler - INFO - Found new file: TUMLUK_16062026_6C_UPI.txt.gz (bank: 0005)
2026-06-16 13:45:01 - scheduler - INFO - Found new file: MLDB_16062026_6C_UPI.txt.gz (bank: 0017)
2026-06-16 13:45:01 - scheduler - INFO - Found new file: MUGB_16062026_6C_UPI.txt.gz (bank: 0018)
2026-06-16 13:45:01 - scheduler - INFO - Found new file: VCCB_16062026_6C_UPI.txt.gz (bank: 0020)
2026-06-16 13:45:01 - scheduler - INFO - Found 5 new files to process
2026-06-16 13:45:01 - processors.file_processor - INFO - Starting processing: HOOGLY_16062026_6C_UPI.txt.gz (bank: 0002)
2026-06-16 13:45:01 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0002/UPI/HOOGLY_16062026_6C_UPI.txt.gz -> /tmp/HOOGLY_16062026_6C_UPI.txt.gz
2026-06-16 13:45:01 - processors.file_processor - INFO - Extracting GZ file: HOOGLY_16062026_6C_UPI.txt.gz
2026-06-16 13:45:01 - upi_parser - INFO - Parsed 64 rows from /tmp/HOOGLY_16062026_6C_UPI.txt
2026-06-16 13:45:01 - processors.data_mapper - INFO - Mapped 64 UPI transactions for bank 0002
2026-06-16 13:45:09 - db.repository - INFO - All 64 transactions skipped
2026-06-16 13:45:09 - db.repository - INFO - Marked file as processed: HOOGLY_16062026_6C_UPI.txt.gz
2026-06-16 13:45:09 - processors.file_processor - INFO - Successfully processed HOOGLY_16062026_6C_UPI.txt.gz: 0 inserted, 64 skipped (non-ipks accounts)
2026-06-16 13:45:09 - processors.file_processor - INFO - Starting processing: TUMLUK_16062026_6C_UPI.txt.gz (bank: 0005)
2026-06-16 13:45:09 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0005/UPI/TUMLUK_16062026_6C_UPI.txt.gz -> /tmp/TUMLUK_16062026_6C_UPI.txt.gz
2026-06-16 13:45:09 - processors.file_processor - INFO - Extracting GZ file: TUMLUK_16062026_6C_UPI.txt.gz
2026-06-16 13:45:09 - upi_parser - INFO - Parsed 837 rows from /tmp/TUMLUK_16062026_6C_UPI.txt
2026-06-16 13:45:09 - processors.data_mapper - INFO - Mapped 837 UPI transactions for bank 0005
2026-06-16 13:45:49 - db.repository - INFO - [{'BANKCODE': '0005', 'RRN': '065399408953', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('200.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113009182690', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '638797601017', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('200.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '404000961413', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '934801407343', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('10.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113008677650', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '023797863400', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('10.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113007992334', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '571392116654', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('10.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113002630561', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '062442977626', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113006799397', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '616711197942', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('10.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113005849024', 'STATUS': 'SUCCESS', 'NARRATION': 'UPI'}, {'BANKCODE': '0005', 'RRN': '663785270229', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('100.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '404001358324', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '652205261860', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('100.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113007958701', 'STATUS': 'SUCCESS', 'NARRATION': 'Payment from PhonePe'}, {'BANKCODE': '0005', 'RRN': '616726900513', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113006920370', 'STATUS': 'SUCCESS', 'NARRATION': 'UPI'}, {'BANKCODE': '0005', 'RRN': '616727080694', 'TXN_DATE': '16062026', 'TXN_AMT': Decimal('1.00'), 'TXN_TYPE': 'CR', 'BENEFICIARY_ACCOUNT': '113006607673', 'STATUS': 'SUCCESS', 'NARRATION': 'UPI'}]
2026-06-16 13:45:49 - db.repository - INFO - executemany rowcount: 11
2026-06-16 13:45:49 - db.repository - INFO - UPI transactions committed successfully
2026-06-16 13:45:49 - db.repository - INFO - Inserted 11 UPI transactions
2026-06-16 13:45:49 - db.repository - INFO - Marked file as processed: TUMLUK_16062026_6C_UPI.txt.gz
2026-06-16 13:45:49 - processors.file_processor - INFO - Successfully processed TUMLUK_16062026_6C_UPI.txt.gz: 11 inserted, 826 skipped (non-ipks accounts)
2026-06-16 13:45:49 - processors.file_processor - INFO - Starting processing: MLDB_16062026_6C_UPI.txt.gz (bank: 0017)
2026-06-16 13:45:49 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0017/UPI/MLDB_16062026_6C_UPI.txt.gz -> /tmp/MLDB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:49 - processors.file_processor - INFO - Extracting GZ file: MLDB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:49 - upi_parser - INFO - Parsed 53 rows from /tmp/MLDB_16062026_6C_UPI.txt
2026-06-16 13:45:49 - processors.data_mapper - INFO - Mapped 53 UPI transactions for bank 0017
2026-06-16 13:45:51 - db.repository - INFO - All 53 transactions skipped
2026-06-16 13:45:51 - db.repository - INFO - Marked file as processed: MLDB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - processors.file_processor - INFO - Successfully processed MLDB_16062026_6C_UPI.txt.gz: 0 inserted, 53 skipped (non-ipks accounts)
2026-06-16 13:45:51 - processors.file_processor - INFO - Starting processing: MUGB_16062026_6C_UPI.txt.gz (bank: 0018)
2026-06-16 13:45:51 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_6C_UPI.txt.gz -> /tmp/MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - upi_parser - INFO - Parsed 414 rows from /tmp/MUGB_16062026_6C_UPI.txt
2026-06-16 13:45:51 - processors.data_mapper - INFO - Mapped 414 UPI transactions for bank 0018
2026-06-16 13:46:11 - db.repository - INFO - All 414 transactions skipped
2026-06-16 13:46:11 - db.repository - INFO - Marked file as processed: MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - processors.file_processor - INFO - Successfully processed MUGB_16062026_6C_UPI.txt.gz: 0 inserted, 414 skipped (non-ipks accounts)
2026-06-16 13:46:11 - processors.file_processor - INFO - Starting processing: VCCB_16062026_6C_UPI.txt.gz (bank: 0020)
2026-06-16 13:46:11 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_6C_UPI.txt.gz -> /tmp/VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - upi_parser - INFO - Parsed 522 rows from /tmp/VCCB_16062026_6C_UPI.txt
2026-06-16 13:46:11 - processors.data_mapper - INFO - Mapped 522 UPI transactions for bank 0020
2026-06-16 13:46:36 - db.repository - INFO - All 522 transactions skipped
2026-06-16 13:46:36 - db.repository - INFO - Marked file as processed: VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:36 - processors.file_processor - INFO - Successfully processed VCCB_16062026_6C_UPI.txt.gz: 0 inserted, 522 skipped (non-ipks accounts)
2026-06-16 13:46:36 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 13:46:36 - scheduler - INFO - Cycle 53 complete:
2026-06-16 13:46:36 - scheduler - INFO -   Total files: 5
2026-06-16 13:46:36 - scheduler - INFO -   Successful: 5
2026-06-16 13:46:36 - scheduler - INFO -   Failed: 0
2026-06-16 13:46:36 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 13:46:36 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 14:16:36 - scheduler - INFO - === Starting processing cycle 54 ===
2026-06-16 14:16:36 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 14:16:36 - scheduler - INFO - listing file for 16062026
2026-06-16 14:16:37 - scheduler - INFO - No new files to process
2026-06-16 14:16:37 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 14:16:37 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 14:46:37 - scheduler - INFO - === Starting processing cycle 55 ===
2026-06-16 14:46:37 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 14:46:37 - scheduler - INFO - listing file for 16062026
2026-06-16 14:46:38 - scheduler - INFO - No new files to process
2026-06-16 14:46:38 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 14:46:38 - scheduler - INFO - Waiting 30 minutes until next cycle...
6 13:45:51 - db.repository - INFO - Marked file as processed: MLDB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - processors.file_processor - INFO - Successfully processed MLDB_16062026_6C_UPI.txt.gz: 0 inserted, 53 skipped (non-ipks accounts)
2026-06-16 13:45:51 - processors.file_processor - INFO - Starting processing: MUGB_16062026_6C_UPI.txt.gz (bank: 0018)
2026-06-16 13:45:51 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0018/UPI/MUGB_16062026_6C_UPI.txt.gz -> /tmp/MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - processors.file_processor - INFO - Extracting GZ file: MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:45:51 - upi_parser - INFO - Parsed 414 rows from /tmp/MUGB_16062026_6C_UPI.txt
2026-06-16 13:45:51 - processors.data_mapper - INFO - Mapped 414 UPI transactions for bank 0018
2026-06-16 13:46:11 - db.repository - INFO - All 414 transactions skipped
2026-06-16 13:46:11 - db.repository - INFO - Marked file as processed: MUGB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - processors.file_processor - INFO - Successfully processed MUGB_16062026_6C_UPI.txt.gz: 0 inserted, 414 skipped (non-ipks accounts)
2026-06-16 13:46:11 - processors.file_processor - INFO - Starting processing: VCCB_16062026_6C_UPI.txt.gz (bank: 0020)
2026-06-16 13:46:11 - sftp.sftp_client - INFO - Downloaded file: /home/ipks/IPKS_FILES/REPORTS/0020/UPI/VCCB_16062026_6C_UPI.txt.gz -> /tmp/VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - processors.file_processor - INFO - Extracting GZ file: VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:11 - upi_parser - INFO - Parsed 522 rows from /tmp/VCCB_16062026_6C_UPI.txt
2026-06-16 13:46:11 - processors.data_mapper - INFO - Mapped 522 UPI transactions for bank 0020
2026-06-16 13:46:36 - db.repository - INFO - All 522 transactions skipped
2026-06-16 13:46:36 - db.repository - INFO - Marked file as processed: VCCB_16062026_6C_UPI.txt.gz
2026-06-16 13:46:36 - processors.file_processor - INFO - Successfully processed VCCB_16062026_6C_UPI.txt.gz: 0 inserted, 522 skipped (non-ipks accounts)
2026-06-16 13:46:36 - processors.file_processor - INFO - Processing complete: 5/5 successful
2026-06-16 13:46:36 - scheduler - INFO - Cycle 53 complete:
2026-06-16 13:46:36 - scheduler - INFO -   Total files: 5
2026-06-16 13:46:36 - scheduler - INFO -   Successful: 5
2026-06-16 13:46:36 - scheduler - INFO -   Failed: 0
2026-06-16 13:46:36 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 13:46:36 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 14:16:36 - scheduler - INFO - === Starting processing cycle 54 ===
2026-06-16 14:16:36 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 14:16:36 - scheduler - INFO - listing file for 16062026
2026-06-16 14:16:37 - scheduler - INFO - No new files to process
2026-06-16 14:16:37 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 14:16:37 - scheduler - INFO - Waiting 30 minutes until next cycle...
2026-06-16 14:46:37 - scheduler - INFO - === Starting processing cycle 55 ===
2026-06-16 14:46:37 - sftp.sftp_client - INFO - Connected to SFTP server: 142.79.249.123:4650
2026-06-16 14:46:37 - scheduler - INFO - listing file for 16062026
2026-06-16 14:46:38 - scheduler - INFO - No new files to process
2026-06-16 14:46:38 - sftp.sftp_client - INFO - SFTP connection closed
2026-06-16 14:46:38 - scheduler - INFO - Waiting 30 minutes until next cycle...