teest

api/routes/patients.py

@@ -258,21 +258,21 @@ async def process_synthea_patient(bundle: dict, file_path: str) -> Optional[dict
                 raw_full_name = f"{' '.join(name.get('given', ['']))} {name.get('family', '')}".strip()
                 clean_full_name = re.sub(r'\d+', '', raw_full_name).strip()
                 
-                 patient_data = {
-                     'fhir_id': resource.get('id'),
-                     'full_name': clean_full_name,
-                     'gender': resource.get('gender', 'unknown'),
-                     'date_of_birth': resource.get('birthDate', ''),
-                     'address': ' '.join(address.get('line', [''])),
-                     'city': address.get('city', ''),
-                     'state': address.get('state', ''),
-                     'postal_code': address.get('postalCode', ''),
-                     'country': address.get('country', ''),
-                     'source': 'synthea',
-                     'status': 'active',
-                     'created_at': datetime.utcnow(),
-                     'updated_at': datetime.utcnow()
-                 }
+                patient_data = {
+                    'fhir_id': resource.get('id'),
+                    'full_name': clean_full_name,
+                    'gender': resource.get('gender', 'unknown'),
+                    'date_of_birth': resource.get('birthDate', ''),
+                    'address': ' '.join(address.get('line', [''])),
+                    'city': address.get('city', ''),
+                    'state': address.get('state', ''),
+                    'postal_code': address.get('postalCode', ''),
+                    'country': address.get('country', ''),
+                    'source': 'synthea',
+                    'status': 'active',
+                    'created_at': datetime.utcnow(),
+                    'updated_at': datetime.utcnow()
+                }
                 
             elif resource_type == 'Encounter':
                 encounter = {
@@ -318,23 +318,23 @@ async def process_synthea_patient(bundle: dict, file_path: str) -> Optional[dict
             logger.error(f"Error processing {resource_type} in {file_path}: {str(e)}")
             continue
     
-     if patient_data:
-         patient_data.update({
-             'allergies': [],  # Convert conditions to allergies if needed
-             'chronic_conditions': conditions,
-             'medications': medications,
-             'symptoms': [],
-             'vital_signs': {},
-             'medical_notes': '',
-             'emergency_contact_name': '',
-             'emergency_contact_phone': '',
-             'national_id': '',
-             'blood_type': ''
-         })
-         logger.info(f"Successfully processed patient {patient_data.get('fhir_id')} from {file_path}")
-         return patient_data
-     logger.warning(f"No valid patient data found in {file_path}")
-     return None
+    if patient_data:
+        patient_data.update({
+            'allergies': [],  # Convert conditions to allergies if needed
+            'chronic_conditions': conditions,
+            'medications': medications,
+            'symptoms': [],
+            'vital_signs': {},
+            'medical_notes': '',
+            'emergency_contact_name': '',
+            'emergency_contact_phone': '',
+            'national_id': '',
+            'blood_type': ''
+        })
+        logger.info(f"Successfully processed patient {patient_data.get('fhir_id')} from {file_path}")
+        return patient_data
+    logger.warning(f"No valid patient data found in {file_path}")
+    return None
 
 @router.post("/import", status_code=status.HTTP_201_CREATED)
 async def import_patients(