bishwajeet.rajak/rtgs_inward_file_based
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updated configuration

Browse Source
This commit is contained in:
Bishwajeet Kumar Rajak
2026-03-19 11:37:16 +05:30
parent afd3f57c01
commit 716f765df5
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
db/repository.py
View File

@@ -166,7 +166,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT COUNT(*) SELECT COUNT(*)
FROM neft_processed_files FROM rtgs_processed_files
WHERE filename = :filename WHERE filename = :filename
AND bankcode = :bankcode AND bankcode = :bankcode
""", """,
@@ -190,7 +190,7 @@ class Repository:
file_data = processed_file.to_dict() file_data = processed_file.to_dict()
insert_sql = """ insert_sql = """
INSERT INTO neft_processed_files ( INSERT INTO rtgs_processed_files (
filename, bankcode, file_path, transaction_count, filename, bankcode, file_path, transaction_count,
status, error_message, processed_at status, error_message, processed_at
) VALUES ( ) VALUES (
@@ -225,7 +225,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT filename SELECT filename
FROM neft_processed_files FROM rtgs_processed_files
WHERE bankcode = :bankcode WHERE bankcode = :bankcode
ORDER BY processed_at DESC ORDER BY processed_at DESC
""", """,
@@ -235,7 +235,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT filename SELECT filename
FROM neft_processed_files FROM rtgs_processed_files
ORDER BY processed_at DESC ORDER BY processed_at DESC
""" """
) )
@@ -290,12 +290,12 @@ class Repository:
) )
try: try:
cursor.execute("SELECT COUNT(*) FROM neft_processed_files WHERE ROWNUM = 1") cursor.execute("SELECT COUNT(*) FROM rtgs_processed_files WHERE ROWNUM = 1")
logger.info("✓ neft_processed_files table exists") logger.info("✓ rtgs_processed_files table exists")
except Exception as e: except Exception as e:
logger.error(f"✗ neft_processed_files table not found: {e}") logger.error(f"✗ rtgs_processed_files table not found: {e}")
raise SystemExit( raise SystemExit(
"FATAL: neft_processed_files table must be created manually before running this application" "FATAL: rtgs_processed_files table must be created manually before running this application"
) )
logger.info("Database tables verified successfully") logger.info("Database tables verified successfully")