BCSS - Playwright - Compartment 6 - Utils - Oracle Specific Functions (#74)

<!-- markdownlint-disable-next-line first-line-heading -->
## Description

<!-- Describe your changes in detail. -->
Created an oracle specific function to return test subjects for the
compartment 6 test.

## Context

<!-- Why is this change required? What problem does it solve? -->
Finds and returns relevant test data for the compartment 6 test.

## Type of changes

<!-- What types of changes does your code introduce? Put an `x` in all
the boxes that apply. -->

- [ ] Refactoring (non-breaking change)
- [x] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would change existing
functionality)
- [ ] Bug fix (non-breaking change which fixes an issue)

## Checklist

<!-- Go over all the following points, and put an `x` in all the boxes
that apply. -->

- [x] I am familiar with the [contributing
guidelines](https://github.com/nhs-england-tools/playwright-python-blueprint/blob/main/CONTRIBUTING.md)
- [x] I have followed the code style of the project
- [ ] I have added tests to cover my changes (where appropriate)
- [ ] I have updated the documentation accordingly
- [ ] This PR is a result of pair or mob programming

---

## Sensitive Information Declaration

To ensure the utmost confidentiality and protect your and others
privacy, we kindly ask you to NOT including [PII (Personal Identifiable
Information) / PID (Personal Identifiable
Data)](https://digital.nhs.uk/data-and-information/keeping-data-safe-and-benefitting-the-public)
or any other sensitive data in this PR (Pull Request) and the codebase
changes. We will remove any PR that do contain any sensitive
information. We really appreciate your cooperation in this matter.

- [x] I confirm that neither PII/PID nor sensitive data are included in
this PR and the codebase changes.

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_investigation_dataset_updates
+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_investigation_dataset_updates(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,8 @@ 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 = 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 +378,8 @@ def test_compartment_6(page: Page, smokescreen_properties: dict) -> None:
     handover_subject_to_symptomatic_care(page)
 
     # Younger patient
-    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 +407,7 @@ 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 = 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_investigation_dataset_updates(
+    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