From d554cf3421a54faed9bff74266abf68799936167 Mon Sep 17 00:00:00 2001 From: Bishwajeet Kumar Rajak Date: Thu, 12 Mar 2026 12:21:49 +0530 Subject: [PATCH] updated repository --- db/repository.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/db/repository.py b/db/repository.py index bf71bb6..689829c 100644 --- a/db/repository.py +++ b/db/repository.py @@ -168,7 +168,7 @@ class Repository: cursor.execute( """ SELECT COUNT(*) - FROM neft_inward_processed_files + FROM neft_processed_files WHERE filename = :filename AND bankcode = :bankcode """, @@ -192,7 +192,7 @@ class Repository: file_data = processed_file.to_dict() insert_sql = """ - INSERT INTO neft_inward_processed_files ( + INSERT INTO neft_processed_files ( filename, bankcode, file_path, transaction_count, status, error_message, processed_at ) VALUES ( @@ -227,7 +227,7 @@ class Repository: cursor.execute( """ SELECT filename - FROM neft_inward_processed_files + FROM neft_processed_files WHERE bankcode = :bankcode ORDER BY processed_at DESC """, @@ -237,7 +237,7 @@ class Repository: cursor.execute( """ SELECT filename - FROM neft_inward_processed_files + FROM neft_processed_files ORDER BY processed_at DESC """ ) @@ -292,12 +292,12 @@ class Repository: ) try: - cursor.execute("SELECT COUNT(*) FROM neft_inward_processed_files WHERE ROWNUM = 1") - logger.info("✓ neft_inward_processed_files table exists") + cursor.execute("SELECT COUNT(*) FROM neft_processed_files WHERE ROWNUM = 1") + logger.info("✓ neft_processed_files table exists") 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( - "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")