diff --git a/config.py b/config.py index 835d932..947cfae 100644 --- a/config.py +++ b/config.py @@ -30,15 +30,15 @@ class Config: """Load database configuration.""" self.db_user = os.getenv('DB_USER', 'pacs_db') self.db_password = os.getenv('DB_PASSWORD', 'pacs_db') - self.db_host = os.getenv('DB_HOST', 'testipksdb.c7q7defafeea.ap-south-1.rds.amazonaws.com') + self.db_host = os.getenv('DB_HOST', 'ipksprod3.c7q7defafeea.ap-south-1.rds.amazonaws.com') self.db_port = int(os.getenv('DB_PORT', '1521')) - self.db_service_name = os.getenv('DB_SERVICE_NAME', 'IPKSDB') + self.db_service_name = os.getenv('DB_SERVICE_NAME', 'IPKS') self.db_pool_min = int(os.getenv('DB_POOL_MIN', '2')) self.db_pool_max = int(os.getenv('DB_POOL_MAX', '10')) def _load_sftp_config(self): """Load SFTP configuration.""" - self.sftp_host = os.getenv('SFTP_HOST', '43.225.3.224') + self.sftp_host = os.getenv('SFTP_HOST', '142.79.249.123') self.sftp_port = int(os.getenv('SFTP_PORT', '4650')) self.sftp_username = os.getenv('SFTP_USERNAME', 'ipkssftp') self.sftp_password = os.getenv('SFTP_PASSWORD', 'Wnb10U11BE7N26') diff --git a/db/repository.py b/db/repository.py index ebb4da9..4e0c481 100644 --- a/db/repository.py +++ b/db/repository.py @@ -80,6 +80,7 @@ class Repository: # Prepare batch data batch_data = [txn.to_dict() for txn in valid_transactions] + #logger.info("Batch data: %s", batch_data) # Execute batch insert insert_sql = """ diff --git a/processors/file_processor.py b/processors/file_processor.py index aad48f8..c5f6d74 100644 --- a/processors/file_processor.py +++ b/processors/file_processor.py @@ -77,9 +77,9 @@ class FileProcessor: # Choose parser by filename prefix parser = None - if filename.startswith('ACH_'): + if filename.startswith('ACH_'): parser = ACHParser(local_path) - elif filename.startswith('UIH_'): + elif filename.startswith('UIH_'): parser = UIHParser(local_path) else: logger.warning(f"Unknown file type for parser: {filename}")