Merge pull request #1279 from CDCgov/story/1242-copy_ORC-12_to_ORC-16

Transformation: ORC-12 to OBR-16

etor/src/main/java/gov/hhs/cdc/trustedintermediary/etor/ruleengine/transformation/custom/CopyOrcOrderProviderToObrOrderProvider.java

@@ -0,0 +1,43 @@
+package gov.hhs.cdc.trustedintermediary.etor.ruleengine.transformation.custom;
+
+import gov.hhs.cdc.trustedintermediary.etor.ruleengine.FhirResource;
+import gov.hhs.cdc.trustedintermediary.etor.ruleengine.transformation.CustomFhirTransformation;
+import gov.hhs.cdc.trustedintermediary.external.hapi.HapiHelper;
+import java.util.Map;
+import org.hl7.fhir.r4.model.Bundle;
+import org.hl7.fhir.r4.model.DiagnosticReport;
+import org.hl7.fhir.r4.model.Extension;
+import org.hl7.fhir.r4.model.ServiceRequest;
+
+/** Updates the order provider (OBR-16) from the order provider (ORC-12) */
+public class CopyOrcOrderProviderToObrOrderProvider implements CustomFhirTransformation {
+
+    @Override
+    public void transform(FhirResource<?> resource, Map<String, String> args) {
+        Bundle bundle = (Bundle) resource.getUnderlyingResource();
+        DiagnosticReport diagnosticReport = HapiHelper.getDiagnosticReport(bundle);
+        if (diagnosticReport == null) {
+            return;
+        }
+        ServiceRequest serviceRequest = HapiHelper.getServiceRequest(diagnosticReport);
+        if (serviceRequest == null) {
+            return;
+        }
+        var practitionerRole = HapiHelper.getPractitionerRole(serviceRequest);
+        if (practitionerRole == null) {
+            return;
+        }
+
+        // Extract or create the OBR-16 extension from the ServiceRequest
+        Extension obrExtension =
+                HapiHelper.ensureExtensionExists(serviceRequest, HapiHelper.EXTENSION_OBR_URL);
+
+        // Extract or create the OBR-16 data type extension
+        Extension obr16Extension =
+                HapiHelper.ensureSubExtensionExists(
+                        obrExtension, HapiHelper.EXTENSION_OBR16_DATA_TYPE.toString());
+
+        // Set the ORC-12 Practitioner in the OBR-16 extension
+        HapiHelper.setOBR16WithPractitioner(obr16Extension, practitionerRole);
+    }
+}

etor/src/main/java/gov/hhs/cdc/trustedintermediary/plugin/path/Hl7FhirMappingPath.java

@@ -17,6 +17,14 @@ public enum Hl7FhirMappingPath {
             """
      Bundle.entry.resource.ofType(ServiceRequest).extension.where(url = 'https://reportstream.cdc.gov/fhir/StructureDefinition/obr-observation-request').extension.where(url = 'OBR.2').value
      """),
+    ORDERING_PROVIDER_ORC_12(
+            "ORC.12",
+            "Bundle.entry.resource.ofType(ServiceRequest).requester.resolve().practicioner.resolve().name"),
+    ORDERING_PROVIDER_OBR_16(
+            "OBR.16",
+            """
+    Bundle.entry.resource.ofType(ServiceRequest).extension.where(url='https://reportstream.cdc.gov/fhir/StructureDefinition/obr-observation-request’).extension.where(url='OBR.16').resolve().name
+    """),
     SENDING_FACILITY_NAMESPACE(
             "",
             """

etor/src/main/resources/transformation_definitions.json

@@ -186,6 +186,22 @@
           }
         }
       ]
+    },
+    {
+      "name": "ucsdOruCopyOrcOrderProviderToObrOrderProvider",
+      "description": "Copies the value from ORC12 and uses this value to replace the value in OBR16",
+      "message": "",
+      "conditions": [
+        "Bundle.entry.resource.ofType(MessageHeader).destination.receiver.resolve().identifier.where(extension.value = 'HD.1').value in ('R797' | 'R508')",
+        "Bundle.entry.resource.ofType(MessageHeader).event.code = 'R01'",
+        "Bundle.entry.resource.ofType(ServiceRequest).code.coding.where(code = '54089-8').exists()"
+      ],
+      "rules": [
+        {
+          "name": "CopyOrcOrderProviderToObrOrderProvider",
+          "args": {}
+        }
+      ]
     }
   ]
 }

etor/src/test/groovy/gov/hhs/cdc/trustedintermediary/etor/ruleengine/transformation/custom/CopyOrcOrderProviderToObrOrderProviderTest.groovy

@@ -0,0 +1,252 @@
+package gov.hhs.cdc.trustedintermediary.etor.ruleengine.transformation.custom
+
+import gov.hhs.cdc.trustedintermediary.ExamplesHelper
+import gov.hhs.cdc.trustedintermediary.context.TestApplicationContext
+import gov.hhs.cdc.trustedintermediary.etor.ruleengine.FhirResource
+import gov.hhs.cdc.trustedintermediary.external.hapi.HapiFhirResource
+import gov.hhs.cdc.trustedintermediary.external.hapi.HapiHelper
+import gov.hhs.cdc.trustedintermediary.wrappers.MetricMetadata
+import org.hl7.fhir.r4.model.Bundle
+import org.hl7.fhir.r4.model.DiagnosticReport
+import org.hl7.fhir.r4.model.Practitioner
+import org.hl7.fhir.r4.model.ServiceRequest
+import spock.lang.Specification
+
+
+class CopyOrcOrderProviderToObrOrderProviderTest extends Specification{
+
+    final String PRACTITIONER_EXTENSION_URL = "https://reportstream.cdc.gov/fhir/StructureDefinition/xcn-practitioner"
+
+    def transformClass
+
+    def setup() {
+        TestApplicationContext.reset()
+        TestApplicationContext.init()
+        TestApplicationContext.register(MetricMetadata, Mock(MetricMetadata))
+        TestApplicationContext.injectRegisteredImplementations()
+
+        transformClass = new CopyOrcOrderProviderToObrOrderProvider()
+    }
+
+    def "should return when diagnostic report is null"() {
+        given:
+        def bundle = createBundle(null)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        def serviceRequest = bundle.getEntry().find { it.getResource() instanceof ServiceRequest }
+        serviceRequest == null
+    }
+
+    def "should return when service request is null"() {
+        given:
+        final String FHIR_ORU_PATH = "../CA/007_CA_ORU_R01_CDPH_produced_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+        def diagnosticReport = HapiHelper.getDiagnosticReport(bundle)
+
+        serviceRequest.setBasedOn(null)
+        diagnosticReport.setBasedOn(null)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        def diagnosticReportInBundle = bundle.getEntry().find { it.getResource() instanceof DiagnosticReport }
+        diagnosticReportInBundle != null  // DiagnosticReport should still exist
+        HapiHelper.getServiceRequest(diagnosticReport) == null
+    }
+
+    def "should return when practitioner role is null"() {
+        given:
+        final String FHIR_ORU_PATH = "../CA/007_CA_ORU_R01_CDPH_produced_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+        def diagnosticReport = HapiHelper.getDiagnosticReport(bundle)
+
+        serviceRequest.setRequester(null)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        def diagnosticReportInBundle = bundle.getEntry().find { it.getResource() instanceof DiagnosticReport }
+        diagnosticReportInBundle != null  // DiagnosticReport should still exist
+        HapiHelper.getServiceRequest(diagnosticReport) != null // ServiceRequest should still exist
+        HapiHelper.getPractitionerRole(serviceRequest) == null
+    }
+
+    def "when both practitioner resources are populated ORC.12 overwrites OBR.16"() {
+        given:
+        final String EXPECTED_NPI = "1790743185"
+        final String EXPECTED_FIRST_NAME = "EUSTRATIA"
+        final String EXPECTED_LAST_NAME = "HUBBARD"
+        final String EXPECTED_NAME_TYPE_CODE = "NPI"
+        final String EXPECTED_IDENTIFIER_TYPE_CODE = null
+        final String FHIR_ORU_PATH = "../CA/007_CA_ORU_R01_CDPH_produced_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+
+        expect:
+        evaluateOrc12Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+        evaluateObr16Values(serviceRequest, null, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, null, null)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        evaluateOrc12Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+        evaluateObr16Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+    }
+
+    def "when ORC-12 extension populated and OBR-16 extension not populated, ORC.12 is copied over"() {
+        given:
+        final String EXPECTED_NPI = "1790743185"
+        final String EXPECTED_FIRST_NAME = "EUSTRATIA"
+        final String EXPECTED_LAST_NAME = "HUBBARD"
+        final String EXPECTED_NAME_TYPE_CODE = null
+        final String EXPECTED_IDENTIFIER_TYPE_CODE = "NPI"
+        final String FHIR_ORU_PATH = "../CA/017_CA_ORU_R01_CDPH_empty_obr16_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+
+        expect:
+        // ORC12 values to copy
+        evaluateOrc12Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+
+        // OBR16 should not exist initially
+        def obr16Practitioner = getObr16ExtensionPractitioner(serviceRequest)
+        obr16Practitioner == null
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        // ORC12 values should remain the same
+        evaluateOrc12Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+        // OBR16 values should be updated to match ORC12
+        evaluateObr16Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+    }
+
+    def "when ORC-12 extension not populated and OBR-16 extension is populated, there is no change"() {
+        given:
+        final String EXPECTED_NPI = null
+        final String EXPECTED_FIRST_NAME = "EUSTRATIA"
+        final String EXPECTED_LAST_NAME = "HUBBARD"
+        final String EXPECTED_NAME_TYPE_CODE = null
+        final String EXPECTED_IDENTIFIER_TYPE_CODE = null
+        final String FHIR_ORU_PATH = "../CA/018_CA_ORU_R01_CDPH_empty_orc12_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+
+        expect:
+        evaluateOrc12Values(serviceRequest, null, null, null, null, null)
+        evaluateObr16Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        evaluateOrc12Values(serviceRequest, null, null, null, null, null)
+        evaluateObr16Values(serviceRequest, EXPECTED_NPI, EXPECTED_FIRST_NAME, EXPECTED_LAST_NAME, EXPECTED_NAME_TYPE_CODE, EXPECTED_IDENTIFIER_TYPE_CODE)
+    }
+
+    def "when neither is populated, there is no change"() {
+        given:
+        final String FHIR_ORU_PATH = "../CA/019_CA_ORU_R01_CDPH_empty_orc12_obr16_UCSD2024-07-11-16-02-17-749_1_hl7_translation.fhir"
+
+        def bundle = createBundle(FHIR_ORU_PATH)
+        def serviceRequest = createServiceRequest(bundle)
+
+        expect:
+        evaluateOrc12IsNull(serviceRequest)
+        evaluateObr16IsNull(serviceRequest)
+
+        when:
+        transformClass.transform(new HapiFhirResource(bundle), null)
+
+        then:
+        evaluateOrc12IsNull(serviceRequest)
+        evaluateObr16IsNull(serviceRequest)
+    }
+
+    Bundle createBundle(String fhirOruPath) {
+        if (fhirOruPath == null) {
+            // Return an empty Bundle if the path is null
+            return new Bundle()
+        }
+
+        def fhirResource = ExamplesHelper.getExampleFhirResource(fhirOruPath)
+        return fhirResource.getUnderlyingResource() as Bundle
+    }
+
+    ServiceRequest createServiceRequest(Bundle bundle) {
+        def diagnosticReport = HapiHelper.getDiagnosticReport(bundle)
+        return HapiHelper.getServiceRequest(diagnosticReport)
+    }
+
+    def evaluateOrc12IsNull(ServiceRequest serviceRequest) {
+        def practitionerRole = HapiHelper.getPractitionerRole(serviceRequest)
+        HapiHelper.getPractitioner(practitionerRole) == null
+    }
+
+    def evaluateOrc12Values(
+            ServiceRequest serviceRequest,
+            String expectedNpi,
+            String expectedFirstName,
+            String expectedLastName,
+            String expectedNameTypeCode,
+            String expectedIdentifierTypeCode) {
+        def practitionerRole = HapiHelper.getPractitionerRole(serviceRequest)
+        def practitioner = HapiHelper.getPractitioner(practitionerRole)
+        def xcnExtension = practitioner?.getExtensionByUrl(PRACTITIONER_EXTENSION_URL)
+
+        practitioner.identifier[0]?.value == expectedNpi
+        xcnExtension.getExtensionByUrl("XCN.3")?.value?.toString() == expectedFirstName
+        practitioner.name[0]?.family == expectedLastName
+        xcnExtension.getExtensionByUrl("XCN.10")?.value?.toString() == expectedNameTypeCode
+        def codingSystem = practitioner.identifier[0]?.type?.coding
+        codingSystem == null || codingSystem[0]?.code == expectedIdentifierTypeCode
+    }
+
+    def evaluateObr16IsNull(ServiceRequest serviceRequest) {
+        getObr16ExtensionPractitioner(serviceRequest) == null
+    }
+
+    def evaluateObr16Values(
+            ServiceRequest serviceRequest,
+            String expectedNpi,
+            String expectedFirstName,
+            String expectedLastName,
+            String expectedNameTypeCode,
+            String expectedIdentifierTypeCode) {
+        def practitioner = getObr16ExtensionPractitioner(serviceRequest)
+        def xcnExtension = practitioner.getExtensionByUrl(PRACTITIONER_EXTENSION_URL)
+
+        practitioner.identifier[0]?.value == expectedNpi
+        xcnExtension.getExtensionByUrl("XCN.3")?.value?.toString() == expectedFirstName
+        practitioner.name[0]?.family == expectedLastName
+        xcnExtension.getExtensionByUrl("XCN.10")?.value?.toString() == expectedNameTypeCode
+        def codingSystem = practitioner.identifier[0]?.type?.coding
+        codingSystem == null || codingSystem[0]?.code == expectedIdentifierTypeCode
+    }
+
+    Practitioner getObr16ExtensionPractitioner (serviceRequest) {
+        def resource
+        try {
+            def extensionByUrl1 =  serviceRequest.getExtensionByUrl(HapiHelper.EXTENSION_OBR_URL)
+            def extensionByUrl2 = extensionByUrl1.getExtensionByUrl(HapiHelper.EXTENSION_OBR16_DATA_TYPE.toString())
+            def value = extensionByUrl2.value
+            resource = value.getResource()
+            return resource
+        } catch(Exception ignored) {
+            resource = null
+            return resource
+        }
+    }
+}