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

updated repository

Browse Source
This commit is contained in:
Bishwajeet Kumar Rajak
2026-03-12 12:21:49 +05:30
parent fca43e8b81
commit d554cf3421
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

@@ -168,7 +168,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT COUNT(*) SELECT COUNT(*)
FROM neft_inward_processed_files FROM neft_processed_files
WHERE filename = :filename WHERE filename = :filename
AND bankcode = :bankcode AND bankcode = :bankcode
""", """,
@@ -192,7 +192,7 @@ class Repository:
file_data = processed_file.to_dict() file_data = processed_file.to_dict()
insert_sql = """ insert_sql = """
INSERT INTO neft_inward_processed_files ( INSERT INTO neft_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 (
@@ -227,7 +227,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT filename SELECT filename
FROM neft_inward_processed_files FROM neft_processed_files
WHERE bankcode = :bankcode WHERE bankcode = :bankcode
ORDER BY processed_at DESC ORDER BY processed_at DESC
""", """,
@@ -237,7 +237,7 @@ class Repository:
cursor.execute( cursor.execute(
""" """
SELECT filename SELECT filename
FROM neft_inward_processed_files FROM neft_processed_files
ORDER BY processed_at DESC ORDER BY processed_at DESC
""" """
) )
@@ -292,12 +292,12 @@ class Repository:
) )
try: try:
cursor.execute("SELECT COUNT(*) FROM neft_inward_processed_files WHERE ROWNUM = 1") cursor.execute("SELECT COUNT(*) FROM neft_processed_files WHERE ROWNUM = 1")
logger.info("✓ neft_inward_processed_files table exists") logger.info("✓ neft_processed_files table exists")
except Exception as e: except Exception as e:
logger.error(f"✗ neft_inward_processed_files table not found: {e}") logger.error(f"✗ neft_processed_files table not found: {e}")
raise SystemExit( raise SystemExit(
"FATAL: neft_inward_processed_files table must be created manually before running this application" "FATAL: neft_processed_files table must be created manually before running this application"
) )
logger.info("Database tables verified successfully") logger.info("Database tables verified successfully")