get_subjects_for_investigations oracle util

Author: victor-soares-ibm

tests/smokescreen/bcss_smokescreen_tests.properties

@@ -42,7 +42,7 @@
 # ----------------------------------
 #   compartment 6
 # ----------------------------------
-#    c6_eng_org_id=23159
+   c6_eng_org_id=23159
 #    c6_eng_site_id=35317
 #    c6_eng_practitioner_id=243
 #    c6_eng_testing_clinician_id=805
@@ -90,8 +90,4 @@
 # ----------------------------------
 #   compartment 6
 # ----------------------------------
-#    c6_eng_number_of_normal_results_to_record=1
-#    c6_eng_number_of_lnpcp_results_to_record=1
-#    c6_eng_number_of_high_risk_findings_results_to_record=1
-#    c6_eng_number_of_lnpcp_results_over_74_to_record=1
-#    c6_eng_number_of_high_risk_findings_results_over_74_to_record=1
+   c6_eng_number_of_subjects_to_record=5

tests/smokescreen/test_compartment_6.py

@@ -48,6 +48,8 @@
     AdvanceFOBTScreeningEpisodePage,
 )
 from utils.dataset_field_util import DatasetFieldUtil
+from utils.oracle.oracle_specific_functions import get_subjects_for_investigations
+from utils.subject_demographics import SubjectDemographicUtil
 
 
 # This should go into a util. Adding it here to avoid SonarQube duplication errors:
@@ -311,9 +313,12 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
 
     # This needs to be repeated for two subjects, one old and one not - High Risk Result
     # Older patient
-    nhs_no = "9765492782"
+    subjects_df = get_subjects_for_investigations(smokescreen_properties["c6_eng_number_of_subjects_to_record"], smokescreen_properties["c6_eng_org_id"])
+    nhs_no = subjects_df["subject_nhs_number"].iloc[0]
+    SubjectDemographicUtil(page).update_subject_dob(nhs_no, False)
     go_to_investigation_datasets_page(page, nhs_no)
 
+
     # The following code is on the investigation datasets page
     default_investigation_dataset_forms(page)
     InvestigationDatasetsPage(page).select_theraputic_procedure_type()
@@ -326,7 +331,8 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
     handover_subject_to_symptomatic_care(page)
 
     # Younger patient
-    nhs_no = "9801085703"
+    nhs_no = subjects_df["subject_nhs_number"].iloc[1]
+    SubjectDemographicUtil(page).update_subject_dob(nhs_no, True)
     go_to_investigation_datasets_page(page, nhs_no)
 
     # The following code is on the investigation datasets page
@@ -356,7 +362,9 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
 
     # This needs to be repeated for two subjects, one old and one not - LNPCP Result
     # Older patient
-    nhs_no = "9840970194"
+    # nhs_no = "9840970194"
+    nhs_no = subjects_df["subject_nhs_number"].iloc[2]
+    SubjectDemographicUtil(page).update_subject_dob(nhs_no, False)
     go_to_investigation_datasets_page(page, nhs_no)
 
     # The following code is on the investigation datasets page
@@ -371,7 +379,9 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
     handover_subject_to_symptomatic_care(page)
 
     # Younger patient
-    nhs_no = "9717136637"
+    # nhs_no = "9717136637"
+    nhs_no = subjects_df["subject_nhs_number"].iloc[3]
+    SubjectDemographicUtil(page).update_subject_dob(nhs_no, True)
     go_to_investigation_datasets_page(page, nhs_no)
 
     # The following code is on the investigation datasets page
@@ -399,7 +409,8 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
     )
 
     # This needs to be repeated for 1 subject, age does not matter - Normal Result
-    nhs_no_normal = "9673858853"
+    # nhs_no_normal = "9673858853"
+    nhs_no_normal = subjects_df["subject_nhs_number"].iloc[4]
     go_to_investigation_datasets_page(page, nhs_no_normal)
 
     # The following code is on the investigation datasets page

utils/oracle/oracle_specific_functions.py

@@ -12,6 +12,7 @@ class SqlQueryValues(IntEnum):
     OPEN_EPISODE_STATUS_ID = 11352
     A8_EVENT_STATUS = 11132
     POSITIVE_APPOINTMENT_BOOKED = 11119
+    POST_INVESTIGATION_APPOINTMENT_NOT_REQUIRED = 160182
 
 
 def get_kit_id_from_db(
@@ -364,3 +365,60 @@ def get_subjects_with_booked_appointments(subjects_to_retrieve: int) -> pd.DataF
     subjects_df = OracleDB().execute_query(query, params)
 
     return subjects_df
+
+
+def get_subjects_for_investigations(
+    number_of_subjects: int, hub_id: str
+) -> pd.DataFrame:
+    """
+    This is used to get subjects for compartment 6
+    It finds subjects with latest envent status of A323 - Post-investigation Appointment
+
+    Args:
+        number_of_subjects (int): The number of subjects to retrieve
+        hub_id (str): hub id to use
+
+    Returns:
+        subjects_df (pd.DataFrame): A pandas DataFrame containing the result of the query
+    """
+
+    query = """SELECT distinct(ss.subject_nhs_number)
+    from
+    (
+    select count(*), eset.screening_subject_id
+    from ep_subject_episode_t eset
+    inner join screening_subject_t sst on (eset.screening_subject_id = sst.screening_subject_id)
+    inner join external_tests_t ext on (eset.subject_epis_id = ext.subject_epis_id)
+    inner join ds_colonoscopy_t dct on (ext.ext_test_id = dct.ext_test_id)
+    where dct.dataset_completed_date is null
+    and dct.deleted_flag ='N'
+    and ext.void = 'N'
+    group by eset.screening_subject_id
+    having
+    count(*)= 1 ) sst
+    inner join ep_subject_episode_t eset on ( sst.screening_subject_id = eset.screening_subject_id )
+    inner join screening_subject_t ss on (eset.screening_subject_id = ss.screening_subject_id)
+    inner join sd_contact_t c ON ss.subject_nhs_number = c.nhs_number
+    inner join EXTERNAL_TESTS_T ext on (eset.subject_epis_id = ext.subject_epis_id)
+    inner join DS_COLONOSCOPY_T dct on (ext.ext_test_id = dct.ext_test_id)
+    inner join sd_contact_t sd on (ss.subject_nhs_number = sd.nhs_number)
+    inner join sd_address_t sda on (sd.contact_id = sda.address_id)
+    inner join org on (sd.gp_practice_id = org.org_id)
+    where eset.latest_event_status_id = :latest_event_status_id -- A323 - Post-investigation Appointment NOT Required
+    and ext.void = 'N'
+    and dct.dataset_new_flag = 'Y'
+    and dct.deleted_flag = 'N'
+    and sd.GP_PRACTICE_ID is not null
+    and eset.start_hub_id = :start_hub_id
+    fetch first :subjects_to_retrieve rows only
+    """
+
+    params = {
+        "latest_event_status_id": SqlQueryValues.POST_INVESTIGATION_APPOINTMENT_NOT_REQUIRED,
+        "start_hub_id": hub_id,
+        "subjects_to_retrieve": number_of_subjects,
+    }
+
+    subjects_df = OracleDB().execute_query(query, params)
+
+    return subjects_df