refactor: resource pmsi changes (#16)

* refactor: remove Claim resource

* refactor: change Condition event date to onsetDateTime

Author: npuchois-aphp

src/main/scala/fr/aphp/id/eds/requester/jobs/SparkJobParameter.scala

@@ -35,7 +35,6 @@ object JobType extends Enumeration {
 
 object ResourceType extends Enumeration {
   type ResourceType = String
-  val claim = "Claim"
   val condition = "Condition"
   val documentReference = "DocumentReference"
   val encounter = "Encounter"
@@ -48,7 +47,6 @@ object ResourceType extends Enumeration {
   val questionnaireResponse = "QuestionnaireResponse"
 
   val all: Seq[ResourceType] = Seq(
-    claim,
     condition,
     documentReference,
     encounter,

src/main/scala/fr/aphp/id/eds/requester/query/engine/QueryBuilderUtils.scala

@@ -48,9 +48,6 @@ object QueryBuilderUtils {
                                        QueryColumn.ENCOUNTER_START_DATE,
                                        QueryColumn.ENCOUNTER_END_DATE),
       FhirResource.GROUP -> List(),
-      FhirResource.CLAIM -> List(QueryColumn.ENCOUNTER_END_DATE,
-                                 QueryColumn.ENCOUNTER_START_DATE,
-                                 EVENT_DATE),
       FhirResource.PROCEDURE -> List(EVENT_DATE,
                                      QueryColumn.ENCOUNTER_END_DATE,
                                      QueryColumn.ENCOUNTER_START_DATE),

src/main/scala/fr/aphp/id/eds/requester/query/resolver/rest/RestFhirQueryElementsConfig.scala

@@ -49,8 +49,6 @@ class RestFhirQueryElementsConfig extends ResourceConfig {
       defaultResourceMapping(Some("subject"), Some("encounter"), Some("effectivePeriod.start"), codeColumn = Some("medicationCodeableConcept.coding.code"))),
     FhirResource.DOCUMENT_REFERENCE -> addJoinedResourceColumns(
       defaultResourceMapping(Some("subject"), Some("encounter"), Some("date"))),
-    FhirResource.CLAIM -> addJoinedResourceColumns(
-      defaultResourceMapping(Some("subject"), Some("encounter"), Some("created"), codeColumn = Some("diagnosis.diagnosisCodeableConcept.coding.code"))),
     FhirResource.PROCEDURE -> addJoinedResourceColumns(
       defaultResourceMapping(Some("subject"), Some("encounter"), Some("date"), codeColumn = Some("code.coding.code"))),
     FhirResource.IMAGING_STUDY -> addJoinedResourceColumns(

src/main/scala/fr/aphp/id/eds/requester/query/resolver/solr/SolrQueryElementsConfig.scala

@@ -53,9 +53,6 @@ class SolrQueryElementsConfig extends ResourceConfig {
     FhirResource.COMPOSITION -> buildDefaultMap(List(SolrColumn.Document.DATE)),
     FhirResource.GROUP -> Map(QueryColumn.PATIENT -> List(SolrColumn.Group.RESOURCE_ID),
                               QueryColumn.ID -> List(SolrColumn.ID)),
-    FhirResource.CLAIM -> buildDefaultMap(List(SolrColumn.Claim.CREATED),
-      codeCol = Some(List(SolrColumn.Claim.CODE))
-    ),
     FhirResource.PROCEDURE -> buildDefaultMap(List(SolrColumn.Procedure.DATE),
       codeCol = Some(List(SolrColumn.Procedure.CODE))
     ),

src/main/scala/fr/aphp/id/eds/requester/query/resolver/solr/SolrQueryResolver.scala

@@ -49,7 +49,7 @@ class SolrQueryResolver(solrSparkReader: SolrSparkReader,
       if (codeColumns.nonEmpty) {
         criterionDataFrame = criterionDataFrame.withColumn(
           QueryColumn.CODE,
-          array_join(array(codeColumns.map((c) => col(s"`${c}`")): _*), ",")
+          array_join(array(codeColumns.map(c => col(s"`$c`")): _*), ",")
         )
       }
     }
@@ -79,7 +79,7 @@ class SolrQueryResolver(solrSparkReader: SolrSparkReader,
       return ""
     }
     val list = sourcePopulation.cohortList.get.map(x => x.toString).mkString(" ")
-    s"_list:(${list}) OR ({!join from=resourceId to=_subject fromIndex=groupAphp v='groupId:(${list})' score=none method=crossCollection})"
+    s"_list:($list) OR ({!join from=resourceId to=_subject fromIndex=groupAphp v='groupId:($list)' score=none method=crossCollection})"
   }
 
   /**
@@ -136,7 +136,6 @@ object SolrCollections {
     FhirResource.CONDITION -> CONDITION_APHP,
     FhirResource.PROCEDURE -> PROCEDURE_APHP,
     FhirResource.DOCUMENT_REFERENCE -> DOCUMENTREFERENCE_APHP,
-    FhirResource.CLAIM -> CLAIM_APHP,
     FhirResource.COMPOSITION -> COMPOSITION_APHP,
     FhirResource.GROUP -> GROUP_APHP,
     FhirResource.MEDICATION_REQUEST -> MEDICATIONREQUEST_APHP,

src/main/scala/fr/aphp/id/eds/requester/query/resolver/solr/package.scala

@@ -40,13 +40,8 @@ package object solr {
       final val CODE = "code.coding.display.anabio"
     }
 
-    object Claim {
-      final val CREATED = "created"
-      final val CODE = "diagnosis.diagnosisCodeableConcept.coding.display"
-    }
-
     object Condition {
-      final val RECORDED_DATE = "recordedDate"
+      final val RECORDED_DATE = "onsetDateTime"
       final val CODE = "code.coding.display"
     }
 

src/main/scala/fr/aphp/id/eds/requester/requester.scala

@@ -9,7 +9,6 @@ package object requester {
     final val CONDITION = "Condition"
     final val PROCEDURE = "Procedure"
     final val DOCUMENT_REFERENCE = "DocumentReference"
-    final val CLAIM = "Claim"
     final val COMPOSITION = "Composition"
     final val GROUP = "Group"
     final val MEDICATION_REQUEST = "MedicationRequest"
@@ -25,7 +24,6 @@ package object requester {
     final val CONDITION_APHP = "conditionAphp"
     final val PROCEDURE_APHP = "procedureAphp"
     final val DOCUMENTREFERENCE_APHP = "documentReferenceAphp"
-    final val CLAIM_APHP = "claimAphp"
     final val COMPOSITION_APHP = "compositionAphp"
     final val GROUP_APHP = "groupAphp"
     final val MEDICATIONREQUEST_APHP = "medicationRequestAphp"