Engagement/nj prework (#15529)

* Fixed New Jersey's suppress OBX-18 * Added NJ pre-work * Updated receiving facilities.
CDCgov · Sep 9, 2024 · 91e3cf7 · 91e3cf7
1 parent d79aad2
commit 91e3cf7
Show file tree

Hide file tree

Showing 7 changed files with 322 additions and 0 deletions.
diff --git a/prime-router/settings/STLTs/NJ/nj-doh.yml b/prime-router/settings/STLTs/NJ/nj-doh.yml
@@ -0,0 +1,110 @@
+- name: "nj-doh"
+  description: "New Jersey Department of Health"
+  jurisdiction: "STATE"
+  stateCode: "NJ"
+  countyName: null
+  filters: null
+  featureFlags: null
+  keys: null
+  senders: []
+  receivers:
+  - name: "full-elr"
+    organizationName: "nj-doh"
+    topic: "full-elr"
+    customerStatus: "active"
+    translation: !<HL7>
+      schemaName: "azure:/hl7_mapping/receivers/STLTs/NJ/NJ-receiver-transform.yml"
+      useTestProcessingMode: false
+      useBatchHeaders: true
+      receivingApplicationName: "ELRS"
+      receivingApplicationOID: "2.16.840.1.113883.3.1299.5.1.6.1"
+      receivingFacilityName: "NJDOH"
+      receivingFacilityOID: "2.16.840.1.113883.3.1299"
+      messageProfileId: null
+      replaceValue: { }
+      replaceValueAwithB: { }
+      reportingFacilityName: null
+      reportingFacilityId: null
+      reportingFacilityIdType: null
+      suppressQstForAoe: false
+      suppressHl7Fields: null
+      suppressAoe: false
+      defaultAoeToUnknown: false
+      replaceUnicodeWithAscii: false
+      useBlankInsteadOfUnknown: null
+      truncateHDNamespaceIds: true
+      truncateHl7Fields: "OBX-23-1,ORC-12-3,OBR-16-3,OBX-17-1,ORC-12-1,OBR-16-1"
+      usePid14ForPatientEmail: false
+      convertTimestampToDateTime: null
+      cliaForOutOfStateTesting: null
+      cliaForSender: { }
+      phoneNumberFormatting: "STANDARD"
+      suppressNonNPI: false
+      processingModeCode: null
+      replaceDiiWithOid: null
+      applyOTCDefault: false
+      useOrderingFacilityName: "STANDARD"
+      valueSetOverrides: { }
+      nameFormat: "STANDARD"
+      receivingOrganization: null
+      convertPositiveDateTimeOffsetToNegative: false
+      stripInvalidCharsRegex: null
+      convertDateTimesToReceiverLocalTime: false
+      useHighPrecisionHeaderDateTimeFormat: false
+      type: "HL7"
+      truncationConfig:
+        truncateHDNamespaceIds: true
+        truncateHl7Fields:
+          - "OBX-23-1"
+          - "ORC-12-3"
+          - "OBR-16-3"
+          - "OBX-17-1"
+          - "ORC-12-1"
+          - "OBR-16-1"
+        customLengthHl7Fields: { }
+    jurisdictionalFilter:
+      - "(Bundle.entry.resource.ofType(ServiceRequest)[0].requester.resolve().organization.resolve().address.state.exists() and Bundle.entry.resource.ofType(ServiceRequest)[0].requester.resolve().organization.resolve().address.state = 'NJ') or (Bundle.entry.resource.ofType(Patient).address.state.exists() and Bundle.entry.resource.ofType(Patient).address.state = 'NJ')"
+    qualityFilter:
+      # hasOneOf(patient_street, patient_zip_code, patient_phone_number, patient_email)
+      - "Bundle.entry.resource.ofType(Patient).where(address.line[0].empty() and address.postalCode.empty() and telecom.where(system = 'phone').value.empty() and telecom.where(system = 'email').value.empty()).count() = 0"
+      # hasOneOf(order_test_date, specimen_collection_date_time, test_result_date)
+      - "Bundle.entry.resource.ofType(DiagnosticReport).where(basedOn.resolve().extension('https://reportstream.cdc.gov/fhir/StructureDefinition/effective-date').empty() and specimen.resolve().collection.collected.empty() and effective.empty() and issued.empty() and result.resolve().effective.empty()).count() = 0"
+      # isValidClia(testing_lab_clia)
+      - "Bundle.entry.resource.ofType(ServiceRequest).performer.resolve().identifier.where(type.coding.code = 'CLIA').value.getIdType() = 'CLIA'"
+      # hasValidData(patient_last_name, patient_first_name, patient_dob)
+      - "Bundle.entry.resource.ofType(Patient).where(name.family.empty() or name.given.empty() or birthDate.empty()).count() = 0"
+      # hasValidData(specimen_type)
+      - "Bundle.entry.resource.ofType(Specimen).where(type.empty()).count() = 0"
+      # hasValidData(message_id)
+      - "Bundle.identifier.value.empty().not()"
+      # hasValidData(equipment_model_name, test_result)
+      - "Bundle.entry.resource.ofType(DiagnosticReport).result.resolve().where(method.empty() or value.coding.code.empty()).count() = 0"
+    routingFilter: [ ]
+    processingModeFilter:
+      # matches(processing_mode_code, P)
+      - "Bundle.entry.resource.ofType(MessageHeader).meta.tag.where(system = 'http://terminology.hl7.org/CodeSystem/v2-0103').code = 'P'"
+    reverseTheQualityFilter: false
+    deidentify: false
+    deidentifiedValue: ""
+    timing:
+      operation: "MERGE"
+      numberPerDay: 1440
+      initialTime: "09:40"
+      timeZone: "EASTERN"
+      maxReportCount: 100
+      whenEmpty:
+        action: "NONE"
+        onlyOncePerDay: false
+    description: ""
+    transport: !<SFTP>
+      type: SFTP
+      host: sftp
+      port: 22
+      filePath: ./upload
+      credentialName: DEFAULT-SFTP
+    conditionFilter: [ ]
+    mappedConditionFilter: [ ]
+    externalName: null
+    enrichmentSchemaNames: ["classpath:/metadata/fhir_transforms/common/suppress-device-information.yml" ]
+    timeZone: null
+    dateTimeFormat: "OFFSET"
diff --git a/...router/src/main/resources/metadata/fhir_transforms/common/suppress-device-information.yml b/...router/src/main/resources/metadata/fhir_transforms/common/suppress-device-information.yml
@@ -0,0 +1,27 @@
+## Suppresses Device information OBX-18-1,OBX-18-2,OBX-18-3
+elements:
+  ##OBX-18-1
+  - name: suppress-device-name
+    resource: 'Bundle.entry.resource.ofType(Device).identifier'
+    value: [ '""' ]
+    bundleProperty: '%resource.value'
+
+    ##OBX-18-2
+  - name: suppess-device-namespace_id
+    resource: 'Bundle.entry.resource.ofType(Device).identifier'
+    condition: '%resource.extension("https://reportstream.cdc.gov/fhir/StructureDefinition/assigning-authority").extension("https://reportstream.cdc.gov/fhir/StructureDefinition/namespace-id").exists()'
+    bundleProperty: '%resource.extension("https://reportstream.cdc.gov/fhir/StructureDefinition/assigning-authority").extension("https://reportstream.cdc.gov/fhir/StructureDefinition/namespace-id").value[x]'
+    value: [ '""' ]
+
+    ##OBX-18-3
+  - name: suppress-device-universal-id
+    resource: 'Bundle.entry.resource.ofType(Device).identifier'
+    condition: '%resource.extension("https://reportstream.cdc.gov/fhir/StructureDefinition/assigning-authority").extension("https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id").exists()'
+    bundleProperty: '%resource.extension("https://reportstream.cdc.gov/fhir/StructureDefinition/assigning-authority").extension("https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id").value[x]'
+    value: [ '""' ]
+
+    ##OBX-18-3 different mappings
+  - name: suppress-device-type-id
+    resource: 'Bundle.entry.resource.ofType(Device).identifier'
+    bundleProperty: '%resource.type.coding.code'
+    value: [ '""' ]
diff --git a/...uter/src/main/resources/metadata/hl7_mapping/receivers/STLTs/NJ/NJ-receiver-transform.yml b/...uter/src/main/resources/metadata/hl7_mapping/receivers/STLTs/NJ/NJ-receiver-transform.yml
@@ -0,0 +1,59 @@
+hl7Class: ca.uhn.hl7v2.model.v251.message.ORU_R01
+
+extends: classpath:/metadata/hl7_mapping/ORU_R01/ORU_R01-base.yml
+elements:
+  # MSH 3-1
+  - name: nj-sending-application-namespace-id
+    value: [ '"CDC PRIME - Atlanta, Georgia (Dekalb)"' ]
+    hl7Spec: [ MSH-3-1 ]
+
+  # MSH 3-2
+  - name: nj-sending-application-universal-id
+    value: [ '"2.16.840.1.114222.4.1.237821"' ]
+    hl7Spec: [ MSH-3-2 ]
+
+  # MSH 3-3
+  - name: nj-sending-application-universal-id-type
+    value: [ '"ISO"' ]
+    hl7Spec: [ MSH-3-3 ]
+
+  # MSH 4-1
+  - name: nj-reporting-facility-name
+    value: [ '"CDC PRIME"' ]
+    hl7Spec: [ MSH-4-1 ]
+
+  # MSH 4-2
+  - name: nj-reporting-facility-id
+    value: [ '"11D2030855"' ]
+    hl7Spec: [ MSH-4-2 ]
+
+  # MSH 4-3
+  - name: nj-reporting-facility-id-type
+    value: [ '"CLIA"' ]
+    hl7Spec: [ MSH-4-3 ]
+
+  # MSH 5
+  - name: nj-receiving-application-namespace-id
+    value: [ '"ELRS"' ]
+    hl7Spec: [ MSH-5-1 ]
+
+  - name: nj-receiving-application-universal-id
+    value: [ '"2.16.840.1.113883.3.1299.5.1.6.1"' ]
+    hl7Spec: [ MSH-5-2 ]
+
+  - name: nj-receiving-application-universal-id-type
+    value: [ '"ISO"' ]
+    hl7Spec: [ MSH-5-3 ]
+
+  # MSH 6
+  - name: nj-receiving-facility-namespace-id
+    value: [ '"NJDOH"' ]
+    hl7Spec: [ MSH-6-1 ]
+
+  - name: nj-receiving-facility-universal-id
+    value: [ '"2.16.840.1.113883.3.1299"' ]
+    hl7Spec: [ MSH-6-2 ]
+
+  - name: nj-receiving-facility-universal-id-type
+    value: [ '"ISO"' ]
+    hl7Spec: [ MSH-6-3 ]
diff --git a/...e-router/src/testIntegration/resources/datatests/FHIR_to_HL7/sample_NJ_20240719-0001.fhir b/...e-router/src/testIntegration/resources/datatests/FHIR_to_HL7/sample_NJ_20240719-0001.fhir
diff --git a/prime-router/src/testIntegration/resources/datatests/FHIR_to_HL7/sample_NJ_20240719-0001.hl7 b/prime-router/src/testIntegration/resources/datatests/FHIR_to_HL7/sample_NJ_20240719-0001.hl7
@@ -0,0 +1,14 @@
+MSH|^~\&|CDC PRIME - Atlanta,^2.16.840.1.114222.4.1.237821^ISO|CDC PRIME^11D2030855^CLIA|ELRS^2.16.840.1.113883.3.1299.5.1.6.1^ISO|NJDOH^2.16.840.1.113883.3.1299^ISO|20240214210646+0000||ORU^R01^ORU_R01|3ad338c6-125d-4141-9ce1-6040481304ab|P|2.5.1|||NE|NE|USA|UNICODE UTF-8|ENG^English^ISO||PHLabReport-NoAck^ELR_Receiver^2.16.840.1.113883.9.11^ISO
+SFT|Centers for Disease Control and Prevention|0.2-SNAPSHOT|PRIME ReportStream|0.2-SNAPSHOT||20240214163856+0000
+PID|1||3551359f-bd1c-411e-b930-789ac694e75f^^^Testing Lab&12D4567890&CLIA^PI^Testing Lab&12D4567890&CLIA||Diggory^Cedrick^Charles^^^^L||20001218|M||2076-8^pacific^^^^^2.5.1^^pacific|123 Main St^^Anchorage^NJ^99501^USA^^^Anchorage||(340) 555 5555^PRS^CP^^1^340^5555555^^^^^(340) 555 5555|||||||||N^Not Hispanic or Latino^HL70189^^^^2.9^^Not Hispanic or Latino||||||||N
+ORC|RE|3ad338c6-125d-4141-9ce1-6040481304ab^Testing Lab^12D4567890^CLIA|3ad338c6-125d-4141-9ce1-6040481304ab^Testing Lab^12D4567890^CLIA|||||||||1245319599^McTester^Phil^^^^^^NPI&2.16.840.1.113883.4.6&ISO^L^^^NPI||(530) 867 5309^WPN^PH^^1^530^8675309^^^^^(530) 867 5309|20240214210646+0000||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|(530) 867 5309^WPN^PH^^1^530^8675309^^^^^(530) 867 5309|321 Ocean Drive^^Houston^NJ^77001^USA
+OBR|1|3ad338c6-125d-4141-9ce1-6040481304ab^Testing Lab^12D4567890^CLIA|3ad338c6-125d-4141-9ce1-6040481304ab^Testing Lab^12D4567890^CLIA|95941-1^Influenza virus A and B and SARS-CoV-2 (COVID-19) and Respiratory syncytial virus RNA panel - Respiratory system specimen by NAA with probe detection^LN|||20240214205146+0000|||||||||1245319599^McTester^Phil^^^^^^NPI&2.16.840.1.113883.4.6&ISO^L^^^NPI|(530) 867 5309^WPN^PH^^1^530^8675309^^^^^(530) 867 5309|||||20240214210646+0000|||F
+OBX|1|CWE|85479-4^Respiratory syncytial virus RNA [Presence] in Upper respiratory specimen by NAA with probe detection^LN^^^^^^RSV||260373001^Detected^SCT|||A^Abnormal^HL70078^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||Alinity m Resp-4-Ple^Alinity m^^^^^^^Alinity m Resp-4-Plex_Abbott Molecular Inc.||20240214210646+0000||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA
+OBX|2|CWE|94500-6^SARS-CoV-2 (COVID-19) RNA [Presence] in Respiratory system specimen by NAA with probe detection^LN^^^^^^COVID-19||260373001^Detected^SCT|||A^Abnormal^HL70078^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||^Alinity m||20240214210646+0000||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA
+OBX|3|CWE|85478-6^Influenza virus B RNA [Presence] in Upper respiratory specimen by NAA with probe detection^LN^^^^^^Flu B||260373001^Detected^SCT|||A^Abnormal^HL70078^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||Alinity m Resp-4-Ple^Alinity m^^^^^^^Alinity m Resp-4-Plex_Abbott Molecular Inc.||20240214210646+0000||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA
+OBX|4|CWE|95419-8^Has symptoms related to condition of interest^LN^^^^2.69^^Has symptoms related to condition of interest||Y^Yes^HL70136|||^^^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|||||QST
+OBX|5|DT|11368-8^Illness or injury onset date and time^LN^^^^^^Illness or injury onset date and time||20240213000000+0000|||^^^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|||||QST
+OBX|6|CWE|82810-3^Pregnancy status^LN^^^^2.68^^Pregnancy status||60001007^Not pregnant^SCT|||^^^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|||||QST
+OBX|7|CWE|95418-0^Employed in a healthcare setting^LN^^^^2.69^^Employed in a healthcare setting||N^No^HL70136|||^^^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|||||QST
+OBX|8|CWE|95421-4^Resides in a congregate care setting^LN^^^^2.69^^Resides in a congregate care setting||N^No^HL70136|||^^^^^^2.7|||F|||20240214205146+0000|12D4567890^Testing Lab^CLIA||||||||Testing Lab^L^^^^CLIA&2.16.840.1.113883.4.7&ISO^XX^^^12D4567890|123 Beach Way^^Houston^NJ^77001^USA|||||QST
+SPM|1|3ad338c6-125d-4141-9ce1-6040481304ab&Testing Lab&12D4567890&CLIA^3ad338c6-125d-4141-9ce1-6040481304ab&Testing Lab&12D4567890&CLIA||258500001^Nasopharyngeal swab^SCT^^^^2.67^^Nasopharyngeal swab||||87100004^Topography unknown (body structure)^SCT^^^^^^Topography unknown (body structure)|||||||||20240214205146+0000|20240214205146+0000
diff --git a/prime-router/src/testIntegration/resources/datatests/translation-test-config.csv b/prime-router/src/testIntegration/resources/datatests/translation-test-config.csv
@@ -61,6 +61,7 @@ FHIR_to_HL7/sample_NH_20240716-0001.fhir,,FHIR_to_HL7/sample_NH_202407016-0001.h
 FHIR_to_HL7/sample_IL_20240802-0001.fhir,,FHIR_to_HL7/sample_IL_20240802-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/IL/IL-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","","",""
 FHIR_to_HL7/sample_WA_20240719-0001.fhir,,FHIR_to_HL7/sample_WA_20240719-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/WA/WA-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","wa-phd.full-elr","",""
 FHIR_to_HL7/sample_OH_20240718-0001.fhir,,FHIR_to_HL7/sample_OH_20240718-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/OH/OH-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","","",""
+FHIR_to_HL7/sample_NJ_20240719-0001.fhir,,FHIR_to_HL7/sample_NJ_20240719-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/NJ/NJ-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","nj-doh.full-elr","","classpath:/metadata/fhir_transforms/common/suppress-device-information.yml"
 FHIR_to_HL7/sample_ND_20240819-0001.fhir,,FHIR_to_HL7/sample_ND_20240819-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/ND/ND-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","","",""
 FHIR_to_HL7/sample_LA_20240806-0001.fhir,,FHIR_to_HL7/sample_LA_20240806-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/LA/LA-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","","","classpath:/metadata/fhir_transforms/receivers/reference-range-enrichment.yml"
 FHIR_to_HL7/sample_MN_20240816-0001.fhir,,FHIR_to_HL7/sample_MN_20240816-0001.hl7,classpath:/metadata/hl7_mapping/receivers/STLTs/MN/MN-receiver-transform.yml,HL7,PASS,"","","classpath:/metadata/fhir_transforms/senders/SimpleReport/simple-report-sender-transform.yml","","",""