logging

Author: nhsdevws

lambdas/id_sync/src/ieds_db_operations.py

@@ -29,6 +29,7 @@ def ieds_check_exist(id: str) -> bool:
 
 def ieds_update_patient_id(old_id: str, new_id: str) -> dict:
     """Update the patient ID in the IEDS table."""
+    logger.info(f"ieds_update_patient_id. Update patient ID from {old_id} to {new_id}")
     if not old_id or not new_id or not old_id.strip() or not new_id.strip():
         return {"status": "error", "message": "Old ID and New ID cannot be empty"}
 

lambdas/id_sync/src/record_processor.py

@@ -37,17 +37,19 @@ def process_record(event_record):
 
 def process_nhs_number(nhs_number: str) -> Optional[str]:
     # get patient details from PDS
-    logger.debug(f"process_nhs_number. Processing NHS number: {nhs_number}")
+    logger.info(f"process_nhs_number. Processing NHS number: {nhs_number}")
     patient_details_id = pds_get_patient_id(nhs_number)
 
     base_log_data = {"nhs_number": nhs_number}
     if patient_details_id:
         logger.info(f"process_nhs_number. Patient details ID: {patient_details_id}")
         # if patient NHS != id, update patient index of vax events to new number
         if patient_details_id != nhs_number and patient_details_id:
+            logger.info(f"process_nhs_number. Update patient ID from {nhs_number} to {patient_details_id}")
             if ieds_check_exist(patient_details_id):
                 response = ieds_update_patient_id(patient_details_id, nhs_number)
             else:
+                logger.info("process_nhs_number. No ieds record found for: %s", nhs_number)
                 response = {"status": "error", "message": f"No records returned for ID: {nhs_number}"}
         else:
             return {"status": "success", "message": "No update required"}