Automated Processing Type Library Resource Examples

Common to the Library resource examples is that they have a Library.type set to automated-processing.

...

The Fallback Library

The Fallback Library is intended as a rule that ensures creation of a Task that draws attention to a measurement needing evaluation. This in case no other automated processing type library has been set up for a given ProcedureRequest through its ActivityDefinition.

The Library has:

• .type set to automated-processing

• .parameter

  • .use set to in for input

  • .type set to Observation

The Library rule sets up instructions that causes production of a:

• a Task with:

  • .category set to MeasurementForAssessment (a Coding signifying a measurement should be assessed/evaluated)

  • .priority set to routine

  • .description set to “Måling til vurdering” which is Danish for measurement to be assessed

  • further elements set as described in Output from automated processing

Library Triaging Against Reference Ranges

...

Automated Processing Type Library Resource Examples

Common to automated processing type Library resources is that they have a Library.type set to automated-processing and specify no output type parameters in Library.parameter. In reality, evaluation of the Library causes return of a GuidanceResponse containing a AutomatedProcessingDTO structure with instructions, but this need not be declared.

Except for the Fallback Library, evaluation of an automated processing type Library requires that a measurement has been submitted and that the ProcedureRequest refers to an ActivityDefinition which refers to the Library, that is, the Library must be used in a CarePlan complex associated with the Patient for which a measurement is submitted.

The Fallback Library

The Fallback Library is a rule that ensures creation of a Task that draws attention to a measurement needing evaluation. It is intended for implicit use in case no other automated processing type library has been set up for a given ProcedureRequest through its ActivityDefinition.

The Library has:

• .type set to automated-processing

• .parameter

  • .use set to in for input

  • .type set to Observation

As it is an automated-processing type, no output type parameters are specified. In reality, evaluation of the Library causes return of a GuidanceResponse containing a AutomatedProcessingDTO structure with instructions, but this need not be declared.

The Library rule The Library rule sets up instructions that causes production of a:

• a Task with:

  • .category set to MeasurementForAssessment (a Coding signifying a measurement should be assessed/evaluated)

  • .priority set to : routine

    • routine when the Observation.value is within reference range

    • urgent when the Observation.value is outside a “Yellow Alarm” type reference range (if defined) but within a “Red Alarm” type reference range (if defined)

    • asap when the Observation.value is outside the “Red Alarm” type reference range (if defined)

  • .description set to “Måling til vurdering” which is Danish for measurement to be assessed

  • further elements set as described in Output from automated processing

  a ClinicalImpression with:

  • .code set to TriagingResult

  • .finding.itemCodeableConcept.Coding set to:

    • a Coding signifying a finding that a measurement is within reference range when that is the case

    • a Coding signifying a finding that a measurement is above reference range when that is the case - this whether above Red Alarm or above Yellow Alarm (but within Red Alarm)

    • a Coding signifying a finding that a measurement is below reference range when that is the case - this whether below Red Alarm or below Yellow Alarm (but within Red Alarm)

  • .description set to “Automatisk processering grundet måling modtaget” which is Danish for automated processing due to submitted measurement.description set to “Måling til vurdering” which is Danish for measurement to be assessed

  • further elements set as described in Output from automated processing

Library Triaging Against Reference Ranges

This Library is intended for use with an ActivityDefinition which specifies submitting of an Observation where the submitted Observation.value is to be compared against the reference range(s) defined in the ProcedureRequest associated with the ActivityDefinition.

The Library has:

• .type set to automated-processing

• .parameter

  • .use set to in for input

  • .type set to Observation

The Library rule sets up instructions that causes production of a:

• a Task with:

  • .category set to MeasurementForAssessment (a Coding signifying a measurement should be assessed/evaluated)

  • .priority set to:

    • routine when the Observation.value is within reference range

    • urgent when the Observation.value is outside a “Yellow Alarm” type reference range (if defined) but within a “Red Alarm” type reference range (if defined)

    • asap when the Observation.value is outside the “Red Alarm” type reference range (if defined)

  • .description set to “Måling til vurdering” which is Danish for measurement to be assessed

  • further elements set as described in Output from automated processing

• a Communication (of ehealth-message profile) provided that the Task.priority is not routine (that is, when the measurement is outside any reference range) with:

  • .ehealth-restriction-category that restricts access for Practitioners to those monitoring measurements

  • .reasonCode set to MeasurementForAssessment

  • .payload.content set to “Måling til vurdering” which is Danish for measurement to be assessed (in the Default message)

  • further elements set as described in Output from automated processing

The Library rule (in Library.content.data) is :

...

• ClinicalImpression with:

  • .code set to TriagingResult

  • .finding.itemCodeableConcept.Coding set to:

    • a Coding signifying a finding that a measurement is within reference range when that is the case

    • a Coding signifying a finding that a measurement is above reference range when that is the case - this whether above Red Alarm or above Yellow Alarm (but within Red Alarm)

    • a Coding signifying a finding that a measurement is below reference range when that is the case - this whether below Red Alarm or below Yellow Alarm (but within Red Alarm)

  • .description set to “Automatisk processering grundet måling modtaget” which is Danish for automated processing due to submitted measurement

  • further elements set as described in Output from automated processing

• a Communication (of ehealth-message profile) provided that the Task.priority is not routine (that is, when the measurement is outside any reference range) with:

  • .ehealth-restriction-category that restricts access for Practitioners to those monitoring measurements

  • .reasonCode set to MeasurementForAssessment

  • .payload.content set to “Måling til vurdering” which is Danish for measurement to be assessed (in the Default message)

  • further elements set as described in Output from automated processing

The Library rule (in Library.content.data) is :

package rules
import org.hl7.fhir.dstu3.model.Observation
// additional imports omitted for brevity

global com.systematic.ehealth.automatedprocessing.AutomatedProcessingDTO ruleResult

function CodingDTO withinReferenceRangeCoding() {
  // Measurement finding within reference range
  return new CodingDTO("http://snomed.info/sct", "442686002442082004", "fund ved måling inden underfor referenceinterval");
}

function CodingDTO aboveReferenceRangeCodingbelowReferenceRangeCoding() {
  // Measurement finding abovebelow reference range
  return new CodingDTO("http://snomed.info/sct", "442756004442686002", "fund ved måling overunder referenceinterval");
}

function CodingDTO redAlarmCodingaboveReferenceRangeCoding() {
  // returnMeasurement new CodingDTO("finding above reference range
  return new CodingDTO("http://snomed.info/sct", "442756004", "fund ved måling over referenceinterval");
}

function CodingDTO redAlarmCoding() {
  return new CodingDTO("urn:oid:1.2.208.184.100.1", "RAL", "Terapeutiske grænseværdier for RØD alarm");
}

function CodingDTO yellowAlarmCoding() {
  return new CodingDTO("urn:oid:1.2.208.184.100.1", "GAL", "Terapeutiske grænseværdier for GUL alarm");
}

function ClinicalImpressionDTO createClinicalImpression(CodingDTO finding) {
   String clinicalImpressionDescription = "Automatisk processering grundet måling modtaget";
   CodingDTO clinicalImpressionCode = new CodingDTO("http://ehealth.sundhed.dk/cs/clinicalimpression-codes", "TriagingResult", "Result of triaging");
   return new ClinicalImpressionDTO(clinicalImpressionCode, clinicalImpressionDescription, List.of(finding), List.of());
}

function TaskDTO createTask(String taskPriority) {
   List<CommunicationDTO> communications = new ArrayList<>();
   String description = "Måling til vurdering"; // Need assessment of measurement
   CodingDTO taskCategory = new CodingDTO("http://ehealth.sundhed.dk/cs/task-category", "MeasurementForAssessment", "Need assessment of measurement");

   if (!taskPriority.equals("routine")) {
      CodingDTO communicationRestrictionCategory = new CodingDTO("http://ehealth.sundhed.dk/cs/restriction-category", "measurement-monitoring", "Monitoring of measurement(s)");
      communications.add(new CommunicationDTO(taskCategory, description, communicationRestrictionCategory));
   }

   CodingDTO taskRestrictionCategory = new CodingDTO("http://ehealth.sundhed.dk/cs/restriction-category", "measurement-monitoring", "Monitoring of measurement(s)");
   return new TaskDTO(taskCategory, description, taskPriority, List.of(taskRestrictionCategory), communications);
}

function Observation.ObservationReferenceRangeComponent getReferenceRange(Observation obs, CodingDTO code) {
    for (Observation.ObservationReferenceRangeComponent r : obs.getReferenceRange()) {
        String matchingCode = r.getType().getCoding().stream()
           .filter(coding -> coding.getSystem().equals(code.getSystem()))
           .filter(coding -> coding.getCode().equals(code.getCode()))
           .map(Coding::getCode)
           .findFirst()
           .orElse(null);
            if (matchingCode != null) {
              return r;
            }
         }
        return null;
    }

rule "ObservationTriageMedcomReferenceRangesRule"
dialect "java"
when
   col : Collection()
   listObs : ArrayList() from collect (EHealthObservation() from col)
   o : EHealthObservation() from listObs.get(0)
then
   String priority = "routine";

   // Get value from observation
   BigDecimal value = ((Quantity)o.getValue()).getValue();

   Observation.ObservationReferenceRangeComponent redRefRange = getReferenceRange(o, redAlarmCoding());
   if (redRefRange != null) {
      if (redRefRange.getLow() != null && redRefRange.getLow().hasValue() && redRefRange.getLow().getValue().compareTo(value) > 0) {
         priority = "asap";
         ruleResult.setClinicalImpressions(List.of(createClinicalImpression(belowReferenceRangeCoding())));
      } else if (redRefRange.getHigh() != null && redRefRange.getHigh().hasValue() && redRefRange.getHigh().getValue().compareTo(value) < 0) {
         priority = "asap";
         ruleResult.setClinicalImpressions(List.of(createClinicalImpression(aboveReferenceRangeCoding())));
      }
    }

   // Not necessary to check yellow alarm range if already outside red alarm range
   if (!priority.equals("asap")) {
      Observation.ObservationReferenceRangeComponent yellowRefRange = getReferenceRange(o, yellowAlarmCoding());
      if (yellowRefRange != null) {
         if (yellowRefRange.getLow() != null && yellowRefRange.getLow().hasValue() && yellowRefRange.getLow().getValue().compareTo(value) > 0) {
            priority = "urgent";
            ruleResult.setClinicalImpressions(List.of(createClinicalImpression(belowReferenceRangeCoding())));
         } else if (yellowRefRange.getHigh() != null && yellowRefRange.getHigh().hasValue() && yellowRefRange.getHigh().getValue().compareTo(value) < 0) {
            priority = "urgent";
            ruleResult.setClinicalImpressions(List.of(createClinicalImpression(aboveReferenceRangeCoding())));
         }
       }
   }

   if (priority.equals("routine")) {
       ruleResult.setClinicalImpressions(List.of(createClinicalImpression(withinReferenceRangeCoding())));
   }

   ruleResult.setTasks(List.of(createTask(priority)));;
end;

...

package rules
import org.hl7.fhir.dstu3.model.Quantityimport
// Further imports omitted for brevity

global com.systematic.ehealth.automatedprocessing.AutomatedProcessingDTO ruleResult

function ObservationDTO createObservation(int sum) {
   QuantityDTO quantityDTO = new QuantityDTO((double)sum, "score");
   ObservationDTO observationDTO = new ObservationDTO();
   observationDTO.setStatus("final");
   observationDTO.setCode(new CodingDTO("urn:oid:1.2.208.184.100.8", "MCS88137", "CAT score;Pt"));
   observationDTO.setValueQuantity(quantityDTO);
   return observationDTO;
}

function ClinicalImpressionDTO createClinicalImpression(ObservationDTO finding) {
   String clinicalImpressionDescription = "Automatisk processering grundet måling modtaget";
   CodingDTO clinicalImpressionCode = new CodingDTO("http://ehealth.sundhed.dk/cs/clinicalimpression-codes", "TriagingResult", "Result of triaging");
   return new ClinicalImpressionDTO(clinicalImpressionCode, clinicalImpressionDescription, List.of(), List.of(finding));
}

function TaskDTO createTask(String taskPriority) {
   List<CommunicationDTO> communications = new ArrayList<>();
   String description = "Måling til vurdering";
   CodingDTO taskCategory = new CodingDTO("http://ehealth.sundhed.dk/cs/task-category", "MeasurementForAssessment", "Need assessment of measurement");
   CodingDTO taskRestrictionCategory = new CodingDTO("http://ehealth.sundhed.dk/cs/restriction-category", "measurement-monitoring", "Monitoring of measurement(s)");
   return new TaskDTO(taskCategory, description, taskPriority, List.of(taskRestrictionCategory), communications);
}

rule "CATScoreRule"
dialect "java"

when
   col : Collection()
   listQrs : ArrayList() from collect (EHealthQuestionnaireResponse() from col)
   qr : EHealthQuestionnaireResponse() from listQrs.get(0)
then
   int sum = qr.getItem().stream()
     .map(QuestionnaireResponseItemComponent::getAnswerFirstRep)
     .filter(QuestionnaireResponseItemAnswerComponent::hasValueIntegerType)
     .map(QuestionnaireResponseItemAnswerComponent::getValueIntegerType)
     .map(IntegerType::getValue)
     .reduce(0, Integer::sum);

   ObservationDTO observation = createObservation(sum);
   
   ruleResult.setClinicalImpressions(List.of(createClinicalImpression(observation)));
   ruleResult.setTasks(List.of(createTask(sum < 15 ? "routine" : "urgent")));
end;

Although the example here uses Questionnaire answers of integer type, the principle in the Library can easily be adjusted to processing of coded answers as long as they each have an integer value correspondence.

Library Activating a Self-Treatment ProcedureRequest

...

The Library rule sets examines the answers of the QuestionnaireResponse and, in case triggering is needed, sets up the instruction through the line ruleResult.setActivateSelfTreatment(true);

package rules
import org.hl7.fhir.dstu3.model.QuestionnaireResponse
// Further imports omitted for brevity

global com.systematic.ehealth.automatedprocessing.AutomatedProcessingDTO ruleResult

rule "SelfTreatmentProcedureRequestActivationRule"

dialect "java"

when
   $questionnaireResponses : Collection()
   $listQrs : ArrayList() from collect (QuestionnaireResponse() from $questionnaireResponses)
then
   QuestionnaireResponse qr = (QuestionnaireResponse)$listQrs.get(0);
   boolean activate = false;
   
   // QuestionnaireResponse examined (omitted), activate set to true when needed
   
   ruleResult.setActivateSelfTreatment(activate);
end

The automated processing reaction to a true parameter passed to setActivateSelfTreatment is described in Activation of suspended Self-treatment type ProcedureRequest.

Calculation Type Library Resource Examples

...

 (omitted), activate set to true when needed
   
   ruleResult.setActivateSelfTreatment(activate);
end

The automated processing reaction to a true parameter passed to setActivateSelfTreatment is described in Activation of suspended Self-treatment type ProcedureRequest.

Calculation Type Library Resource Examples

A calculation type Library resource has a Library.type set to logic-library and its evaluation requires invocation of its evaluate operation with input parameters as specified in the Library.

Library for Calculating Situation Quality

This Library and its rule is intended to qualify a measurement, typically submitted as an Observation or Media. Typically the associated Questionnaire poses questions relevant to the quality of that particular measurement, for instance whether a finger is warm (could be relevant for Pulse Oximeter measurement of oxygen saturation at index finger) or whether the patient is sitting or lying down. Prerequisite to submitting the Observation, the QuestionnaireResponse for the said Questionnaire would be passed as parameter to the evaluate operation on the Library, returning one or more Coding in the SituationQuality. The returned Coding(s) would then be entered in Observation.ehealth-quality.

The Library has:

• .type set to logic-library

• .parameter

  • .use set to in for input

  • .type set to QuestionnaireResponse

The Library rule sets examines the answers of the QuestionnaireResponse and determines the corresponding SituationQuality Coding(s).

package rules
import org.hl7.fhir.dstu3.model.QuestionnaireResponse
// Further imports omitted for brevity

global org.hl7.fhir.dstu3.model.CodeableConcept ruleResult

rule "SituationQualityCalculationRule"
dialect "java"

when
   $questionnaireResponses : Collection()
   $listQrs : ArrayList() from collect (QuestionnaireResponse() from $questionnaireResponses)

then

   QuestionnaireResponse qr = (QuestionnaireResponse)$listQrs.get(0);
   Coding coding = new Coding();

   // Examination of QuestionnaireResponse determines the Coding(s) to return
      coding.setCode("SQ2");
      coding.setSystem("http://ehealth.sundhed.dk/cs/situation-quality");
      coding.setDisplay("Situation Quality 2");
   }
   ruleResult.addCoding(coding);

end;

Library for Calculating Usage Quality

The Library and rule for calculating Usage Quality is very similar to the Library for Calculating Situation Quality and is also intended to qualify a measurement, typically submitted as an Observation or Media. The difference is that the Questionnaire, which is the typical way to establish usage quality, poses questions relevant to the quality of how the involved Device (if any) was operated, for instance has the instructions for device use been followed.

Prerequisite to submitting the Observation, the QuestionnaireResponse for the said Questionnaire would be passed as parameter to the evaluate operation on the Library, returning one or more Coding for UsageQuality. The returned Coding(s) would then be carried to Observation.ehealth-quality.

The Library type and input are identical to that of Library for Calculating Situation Quality, and the rule differs in that the Coding specifies UsageQuality.

Library for Calculating CAT Score

...