Remove race condition between different evaluation periods by deletin…

…g Parameters parameter from evaluateMeasure().
cqframework · Oct 10, 2024 · 1c72471 · 1c72471
1 parent 6a2cfb0
commit 1c72471
Show file tree

Hide file tree

Showing 9 changed files with 26 additions and 67 deletions.
diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/common/BaseMeasureEvaluation.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/common/BaseMeasureEvaluation.java
@@ -3,7 +3,6 @@
 import java.util.List;
 import java.util.Objects;
 import org.hl7.elm.r1.VersionedIdentifier;
-import org.hl7.fhir.instance.model.api.IBaseParameters;
 import org.opencds.cqf.cql.engine.execution.CqlEngine;
 import org.opencds.cqf.cql.engine.runtime.Interval;
 import org.opencds.cqf.fhir.cql.LibraryEngine;
@@ -17,7 +16,6 @@ public abstract class BaseMeasureEvaluation<MeasureT, MeasureReportT, SubjectT>
     protected MeasureT measure;
     protected LibraryEngine libraryEngine;
     protected String measurementPeriodParameterName;
-    protected IBaseParameters parameters;
     protected VersionedIdentifier versionIdentifier;
 
     protected BaseMeasureEvaluation(
@@ -26,17 +24,15 @@ protected BaseMeasureEvaluation(
             MeasureDefBuilder<MeasureT> measureDefBuilder,
             MeasureReportBuilder<MeasureT, MeasureReportT, SubjectT> measureReportBuilder,
             LibraryEngine libraryEngine,
-            VersionedIdentifier versionIdentifier,
-            IBaseParameters parameters) {
+            VersionedIdentifier versionIdentifier) {
         this(
                 context,
                 measure,
                 measureDefBuilder,
                 measureReportBuilder,
                 MeasureConstants.MEASUREMENT_PERIOD_PARAMETER_NAME,
                 libraryEngine,
-                versionIdentifier,
-                parameters);
+                versionIdentifier);
     }
 
     protected BaseMeasureEvaluation(
@@ -46,8 +42,7 @@ protected BaseMeasureEvaluation(
             MeasureReportBuilder<MeasureT, MeasureReportT, SubjectT> measureReportBuilder,
             String measurementPeriodParameterName,
             LibraryEngine libraryEngine,
-            VersionedIdentifier versionIdentifier,
-            IBaseParameters parameters) {
+            VersionedIdentifier versionIdentifier) {
         this.context = Objects.requireNonNull(context, "context is a required argument");
         this.measure = Objects.requireNonNull(measure, "measure is a required argument");
         this.measureDefBuilder = Objects.requireNonNull(measureDefBuilder, "measureDefBuilder is a required argument");
@@ -56,34 +51,31 @@ protected BaseMeasureEvaluation(
         this.measurementPeriodParameterName = Objects.requireNonNull(
                 measurementPeriodParameterName, "measurementPeriodParameterName is a required argument");
         this.libraryEngine = libraryEngine;
-        this.parameters = parameters;
         this.versionIdentifier = versionIdentifier;
     }
 
     public MeasureReportT evaluate(
             MeasureEvalType measureEvalType,
             List<String> subjectIds,
             LibraryEngine libraryEngine,
-            VersionedIdentifier id,
-            IBaseParameters parameters) {
-        return this.evaluate(measureEvalType, subjectIds, null, libraryEngine, id, parameters);
+            VersionedIdentifier id) {
+        return this.evaluate(measureEvalType, subjectIds, null, libraryEngine, id);
     }
 
     public MeasureReportT evaluate(
             MeasureEvalType measureEvalType,
             List<String> subjectIds,
             Interval measurementPeriod,
             LibraryEngine libraryEngine,
-            VersionedIdentifier id,
-            IBaseParameters parameters) {
+            VersionedIdentifier id) {
         Objects.requireNonNull(subjectIds, "subjectIds is a required parameter");
         Objects.requireNonNull(measureEvalType, "measureEvalType is a required parameter");
 
         MeasureDef measureDef = this.measureDefBuilder.build(measure);
         MeasureEvaluator measureEvaluation =
                 new MeasureEvaluator(context, this.measurementPeriodParameterName, libraryEngine);
         measureDef =
-                measureEvaluation.evaluate(measureDef, measureEvalType, subjectIds, measurementPeriod, parameters, id);
+                measureEvaluation.evaluate(measureDef, measureEvalType, subjectIds, measurementPeriod, id);
 
         Interval measurementPeriodInterval;
         if (measurementPeriod == null) {

diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/common/MeasureEvaluator.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/common/MeasureEvaluator.java
@@ -30,7 +30,6 @@
 import org.hl7.elm.r1.NamedTypeSpecifier;
 import org.hl7.elm.r1.ParameterDef;
 import org.hl7.elm.r1.VersionedIdentifier;
-import org.hl7.fhir.instance.model.api.IBaseParameters;
 import org.opencds.cqf.cql.engine.execution.CqlEngine;
 import org.opencds.cqf.cql.engine.execution.EvaluationResult;
 import org.opencds.cqf.cql.engine.execution.ExpressionResult;
@@ -83,7 +82,6 @@ public MeasureDef evaluate(
             MeasureEvalType measureEvalType,
             List<String> subjectIds,
             @Nullable Interval measurementPeriod,
-            IBaseParameters parameters,
             VersionedIdentifier versionedIdentifier) {
         Objects.requireNonNull(measureDef, "measureDef is a required argument");
         Objects.requireNonNull(subjectIds, "subjectIds is a required argument");
@@ -100,15 +98,13 @@ public MeasureDef evaluate(
                         measureDef,
                         MeasureReportType.INDIVIDUAL,
                         subjectIds,
-                        parameters,
                         versionedIdentifier,
                         zonedDateTime);
             case SUBJECTLIST:
                 return this.evaluate(
                         measureDef,
                         MeasureReportType.SUBJECTLIST,
                         subjectIds,
-                        parameters,
                         versionedIdentifier,
                         zonedDateTime);
             case PATIENTLIST:
@@ -117,15 +113,13 @@ public MeasureDef evaluate(
                         measureDef,
                         MeasureReportType.PATIENTLIST,
                         subjectIds,
-                        parameters,
                         versionedIdentifier,
                         zonedDateTime);
             case POPULATION:
                 return this.evaluate(
                         measureDef,
                         MeasureReportType.SUMMARY,
                         subjectIds,
-                        parameters,
                         versionedIdentifier,
                         zonedDateTime);
             default:
@@ -300,7 +294,6 @@ protected MeasureDef evaluate(
             MeasureDef measureDef,
             MeasureReportType type,
             List<String> subjectIds,
-            IBaseParameters parameters,
             VersionedIdentifier id,
             ZonedDateTime zonedDateTime) {
         var subjectSize = subjectIds.size();
@@ -322,7 +315,7 @@ protected MeasureDef evaluate(
             context.getState().setContextValue(subjectTypePart, subjectIdPart);
 
             EvaluationResult result = libraryEngine.getEvaluationResult(
-                    id, subjectId, parameters, null, null, null, zonedDateTime, context);
+                    id, subjectId, null, null, null, null, zonedDateTime, context);
 
             evaluateSubject(measureDef, subjectTypePart, subjectIdPart, subjectSize, type, result);
         }

diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureEvaluation.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureEvaluation.java
@@ -4,7 +4,6 @@
 import org.hl7.fhir.dstu3.model.DomainResource;
 import org.hl7.fhir.dstu3.model.Measure;
 import org.hl7.fhir.dstu3.model.MeasureReport;
-import org.hl7.fhir.dstu3.model.Parameters;
 import org.opencds.cqf.cql.engine.execution.CqlEngine;
 import org.opencds.cqf.fhir.cql.LibraryEngine;
 import org.opencds.cqf.fhir.cr.measure.common.BaseMeasureEvaluation;
@@ -18,15 +17,13 @@ public Dstu3MeasureEvaluation(
             CqlEngine context,
             Measure measure,
             LibraryEngine libraryEngine,
-            VersionedIdentifier versionIdentifier,
-            Parameters parameters) {
+            VersionedIdentifier versionIdentifier) {
         super(
                 context,
                 measure,
                 new Dstu3MeasureDefBuilder(),
                 new Dstu3MeasureReportBuilder(),
                 libraryEngine,
-                versionIdentifier,
-                parameters);
+                versionIdentifier);
     }
 }
diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureProcessor.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureProcessor.java
@@ -138,22 +138,9 @@ protected MeasureReport evaluateMeasure(
         var subjects =
                 subjectProvider.getSubjects(actualRepo, evalType, subjectIds).collect(Collectors.toList());
         var libraryEngine = new LibraryEngine(repository, this.measureEvaluationOptions.getEvaluationSettings());
-        var params = makeParameters(measurementPeriod);
         Dstu3MeasureEvaluation measureEvaluator =
-                new Dstu3MeasureEvaluation(context, measure, libraryEngine, id, params);
-        return measureEvaluator.evaluate(evalType, subjects, measurementPeriod, libraryEngine, id, params);
-    }
-
-    public Parameters makeParameters(Interval measurementPeriod) {
-        Parameters parameters = new Parameters();
-        if (measurementPeriod != null) {
-
-            Period period = new Period();
-            period.setStartElement(new DateTimeType(measurementPeriod.getStart().toString()));
-            period.setEndElement(new DateTimeType(measurementPeriod.getEnd().toString()));
-            parameters.addParameter().setName(MEASUREMENT_PERIOD_PARAMETER_NAME).setValue(period);
-        }
-        return parameters;
+                new Dstu3MeasureEvaluation(context, measure, libraryEngine, id);
+        return measureEvaluator.evaluate(evalType, subjects, measurementPeriod, libraryEngine, id);
     }
 
     protected MeasureReportType evalTypeToReportType(MeasureEvalType measureEvalType) {

diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureEvaluation.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureEvaluation.java
@@ -18,15 +18,13 @@ public R4MeasureEvaluation(
             CqlEngine context,
             Measure measure,
             LibraryEngine libraryEngine,
-            VersionedIdentifier versionIdentifier,
-            Parameters parameters) {
+            VersionedIdentifier versionIdentifier) {
         super(
                 context,
                 measure,
                 new R4MeasureDefBuilder(),
                 new R4MeasureReportBuilder(),
                 libraryEngine,
-                versionIdentifier,
-                parameters);
+                versionIdentifier);
     }
 }
diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureProcessor.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureProcessor.java
@@ -164,19 +164,8 @@ protected MeasureReport evaluateMeasure(
         }
         // Library Evaluate
         var libraryEngine = new LibraryEngine(repository, this.measureEvaluationOptions.getEvaluationSettings());
-        var params = makeParameters(measurementPeriod);
-        R4MeasureEvaluation measureEvaluator = new R4MeasureEvaluation(context, measure, libraryEngine, id, params);
-        return measureEvaluator.evaluate(evalType, subjectIds, measurementPeriod, libraryEngine, id, params);
-    }
-
-    public Parameters makeParameters(Interval measurementPeriod) {
-        Parameters parameters = new Parameters();
-        if (measurementPeriod != null) {
-            var helper = new R4DateHelper();
-            parameters.setParameter(
-                    MEASUREMENT_PERIOD_PARAMETER_NAME, helper.buildMeasurementPeriod(measurementPeriod));
-        }
-        return parameters;
+        R4MeasureEvaluation measureEvaluator = new R4MeasureEvaluation(context, measure, libraryEngine, id);
+        return measureEvaluator.evaluate(evalType, subjectIds, measurementPeriod, libraryEngine, id);
     }
 
     protected Measure resolveByUrl(CanonicalType url) {

diff --git a/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/utils/R4DateHelper.java b/cqf-fhir-cr/src/main/java/org/opencds/cqf/fhir/cr/measure/r4/utils/R4DateHelper.java
@@ -6,6 +6,7 @@
 import org.opencds.cqf.cql.engine.runtime.Date;
 import org.opencds.cqf.cql.engine.runtime.DateTime;
 import org.opencds.cqf.cql.engine.runtime.Interval;
+import org.opencds.cqf.cql.engine.runtime.Precision;
 
 public class R4DateHelper {
 
@@ -38,6 +39,8 @@ public Period buildMeasurementPeriod(Interval measurementPeriodInterval) {
 
     private DateTime convertToDateTime(ZonedDateTime zonedDateTime) {
         final OffsetDateTime offsetDateTime = zonedDateTime.toOffsetDateTime();
-        return new DateTime(offsetDateTime);
+        final DateTime convertedDateTime = new DateTime(offsetDateTime);
+        convertedDateTime.setPrecision(Precision.SECOND);
+        return convertedDateTime;
     }
 }
diff --git a/...ir-cr/src/test/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureEvaluationTest.java b/...ir-cr/src/test/java/org/opencds/cqf/fhir/cr/measure/dstu3/Dstu3MeasureEvaluationTest.java
@@ -244,14 +244,14 @@ private MeasureReport runTest(
         var lib = engine.getEnvironment().getLibraryManager().resolveLibrary(id);
         engine.getState().init(lib.getLibrary());
         var libraryEngine = new LibraryEngine(repository, this.evaluationOptions.getEvaluationSettings());
-        Dstu3MeasureEvaluation evaluation = new Dstu3MeasureEvaluation(engine, measure, libraryEngine, id, null);
+        Dstu3MeasureEvaluation evaluation = new Dstu3MeasureEvaluation(engine, measure, libraryEngine, id);
         MeasureReport report = evaluation.evaluate(
                 subjectIds.size() == 1 ? MeasureEvalType.PATIENT : MeasureEvalType.POPULATION,
                 subjectIds,
                 measurementPeriod,
                 libraryEngine,
-                id,
-                null);
+                id
+        );
         assertNotNull(report);
 
         // Simulate sending it across the wire

diff --git a/cqf-fhir-cr/src/test/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureEvaluationTest.java b/cqf-fhir-cr/src/test/java/org/opencds/cqf/fhir/cr/measure/r4/R4MeasureEvaluationTest.java
@@ -373,14 +373,14 @@ private MeasureReport runTest(
 
         var libraryEngine = new LibraryEngine(repository, evaluationOptions.getEvaluationSettings());
 
-        R4MeasureEvaluation evaluation = new R4MeasureEvaluation(engine, measure, libraryEngine, id, null);
+        R4MeasureEvaluation evaluation = new R4MeasureEvaluation(engine, measure, libraryEngine, id);
         MeasureReport report = evaluation.evaluate(
                 subjectIds.size() == 1 ? MeasureEvalType.SUBJECT : MeasureEvalType.POPULATION,
                 subjectIds,
                 measurementPeriod,
                 libraryEngine,
-                id,
-                null);
+                id
+        );
         assertNotNull(report);
 
         // Simulate sending it across the wire