Generated Narrative: StructureMap ExtractHormonalTherapyTreatmentPlan
\r\n/// url = 'https://fhir.slade360.co.ke/fhir/StructureMap/ExtractHormonalTherapyTreatmentPlan'\r\n/// name = 'ExtractHormonalTherapyTreatmentPlan'\r\n/// title = 'Hormonal Therapy Treatment Plan Extraction'\r\n/// status = 'active'\r\n/// description = 'Each cycle on the hormonal therapy sheet out as: a MedicationAdministration for the drug given, as written, on the cycle\\'s date; laboratory Observations for the PSA, serum calcium and alkaline phosphatase; an Observation for the cycle number, so the next cycle can see which one this was; the remarks as a note; and a ServiceRequest for the date to come again. Everything takes the cycle\\'s own date rather than the form\\'s, because the sheet exists to be read as a series.'\r\n\r\nuses "http://hl7.org/fhir/StructureDefinition/QuestionnaireResponse" alias QR as source\r\nuses "http://hl7.org/fhir/StructureDefinition/Bundle" alias Bundle as target\r\nuses "http://hl7.org/fhir/StructureDefinition/Observation" alias Observation as target\r\nuses "http://hl7.org/fhir/StructureDefinition/MedicationAdministration" alias MedicationAdministration as target\r\nuses "http://hl7.org/fhir/StructureDefinition/ServiceRequest" alias ServiceRequest as target\r\n\r\ngroup ExtractHormonalTherapyTreatmentPlan(source qr : QR, target bundle : Bundle) {\r\n qr -> bundle.type = 'transaction' "setBundleType";\r\n // ── One cycle at a time ─────────────────────────────────────────────────\r\n qr.item as c where (linkId = 'cycle') then {\r\n // The drug given. A MedicationAdministration, because the sheet records\r\n // what was given at that cycle, not what was ordered. The drug travels as\r\n // written: the hospital's formulary is not coded, and the strength is part\r\n // of what the clinician wrote.\r\n c where (item.where(linkId = 'cycle/drug').answer.value.exists()) -> bundle.entry as entry, entry.resource = create('MedicationAdministration') as ma then {\r\n qr -> ma, entry then BuildMedicationAdministrationBase(qr, ma, entry) "base";\r\n c -> ma.status = 'completed' "status";\r\n qr.encounter as e where ((reference.exists() and (reference.startsWith('Encounter/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Encounter')))) -> ma.encounter = e;\r\n c.item as it where (linkId = 'cycle/drug') then {\r\n it.answer first as a then {\r\n a.value as txt -> ma.medication as med, med.concept as mc, mc.text = txt "medicationText";\r\n a.value as txt -> ma.dosage as dos, dos.text = txt "dosageAsWritten";\r\n };\r\n } "drugRule";\r\n c.item as it where ((linkId = 'cycle/date') and answer.value.exists()) then {\r\n it.answer first as a then {\r\n a.value as d -> ma.occurence = cast(d, 'dateTime') "occurrence";\r\n };\r\n } "dateRule";\r\n c.item as it where ((linkId = 'cycle/number') and answer.value.exists()) then {\r\n it.answer first as a then {\r\n a.value as n -> ma.note as note then {\r\n n -> note.text = evaluate(n, 'Hormonal therapy cycle ' & $this.toString()) "cycleText";\r\n qr.authored as noteTime -> note.time = noteTime "cycleTime";\r\n } "cycleNote";\r\n };\r\n } "cycleRule";\r\n } "hormonalDrug";\r\n // The cycle number as an Observation of its own. It is what tells the\r\n // next cycle which one this was, and a number inside a note cannot be\r\n // read back as one.\r\n c.item as it where ((linkId = 'cycle/number') and answer.value.exists()) -> bundle.entry as entry, entry.resource = create('Observation') as obs then {\r\n qr -> obs, entry then BuildObsBase(qr, obs, entry) "base";\r\n qr -> obs then SetSurveyCategory(qr, obs) "category";\r\n it -> obs.code as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'https://fhir.slade360.co.ke/fhir/CodeSystem/concept-codesystem' "sys";\r\n it -> cg.code = 'hormonal-therapy-cycle-number' "cd";\r\n it -> cg.display = 'Hormonal therapy cycle number' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as v -> obs.value = v;\r\n };\r\n c -> obs then SetHormonalCycleContext(c, obs) "cycleContext";\r\n } "cycleNumber";\r\n c.item as it where ((linkId = 'cycle/psa') and answer.value.ofType(Quantity).exists()) -> bundle.entry as entry, entry.resource = create('Observation') as obs then {\r\n qr -> obs, entry then BuildObsBase(qr, obs, entry) "base";\r\n qr -> obs then SetLaboratoryCategory(qr, obs) "category";\r\n it -> obs.code as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'http://loinc.org' "sys";\r\n it -> cg.code = '2857-1' "cd";\r\n it -> cg.display = 'Prostate specific Ag [Mass/volume] in Serum or Plasma' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as v -> obs.value = v;\r\n };\r\n c -> obs then SetHormonalCycleContext(c, obs) "cycleContext";\r\n } "cyclePsa";\r\n // "CA2+" on the paper. Read as serum calcium in mmol/L, the routine\r\n // measure on a patient with bone disease; an ionised calcium would need a\r\n // blood gas analyser and its own code, 1995-0.\r\n c.item as it where ((linkId = 'cycle/calcium') and answer.value.ofType(Quantity).exists()) -> bundle.entry as entry, entry.resource = create('Observation') as obs then {\r\n qr -> obs, entry then BuildObsBase(qr, obs, entry) "base";\r\n qr -> obs then SetLaboratoryCategory(qr, obs) "category";\r\n it -> obs.code as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'http://loinc.org' "sys";\r\n it -> cg.code = '2000-8' "cd";\r\n it -> cg.display = 'Calcium [Moles/volume] in Serum or Plasma' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as v -> obs.value = v;\r\n };\r\n c -> obs then SetHormonalCycleContext(c, obs) "cycleContext";\r\n } "cycleCalcium";\r\n c.item as it where ((linkId = 'cycle/alp') and answer.value.ofType(Quantity).exists()) -> bundle.entry as entry, entry.resource = create('Observation') as obs then {\r\n qr -> obs, entry then BuildObsBase(qr, obs, entry) "base";\r\n qr -> obs then SetLaboratoryCategory(qr, obs) "category";\r\n it -> obs.code as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'http://loinc.org' "sys";\r\n it -> cg.code = '6768-6' "cd";\r\n it -> cg.display = 'Alkaline phosphatase [Enzymatic activity/volume] in Serum or Plasma' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as v -> obs.value = v;\r\n };\r\n c -> obs then SetHormonalCycleContext(c, obs) "cycleContext";\r\n } "cycleAlp";\r\n c.item as it where ((linkId = 'cycle/remarks') and answer.value.exists()) -> bundle.entry as entry, entry.resource = create('Observation') as obs then {\r\n qr -> obs, entry then BuildObsBase(qr, obs, entry) "base";\r\n qr -> obs then SetSurveyCategory(qr, obs) "category";\r\n it -> obs.code as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'https://fhir.slade360.co.ke/fhir/CodeSystem/concept-codesystem' "sys";\r\n it -> cg.code = 'hormonal-therapy-remarks' "cd";\r\n it -> cg.display = 'Remarks on a hormonal therapy cycle' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as txt -> obs.note as n, n.text = txt "text";\r\n };\r\n c -> obs then SetHormonalCycleContext(c, obs) "cycleContext";\r\n } "cycleRemarks";\r\n // TCA, "to come again". A ServiceRequest, not an Appointment, for the\r\n // reason the discharge summary gives: a date with no clinic, clinician or\r\n // slot is a request for a follow-up, and an Appointment built from it\r\n // would claim a booking that does not exist.\r\n c.item as it where ((linkId = 'cycle/next-visit') and answer.value.exists()) -> bundle.entry as entry, entry.resource = create('ServiceRequest') as sr then {\r\n qr -> sr, entry then BuildServiceRequestBase(qr, sr, entry) "base";\r\n it -> sr.status = 'active' "status";\r\n it -> sr.intent = 'plan' "intent";\r\n it -> sr.code as cr, cr.concept as cc then {\r\n it -> cc.coding as cg then {\r\n it -> cg.system = 'https://fhir.slade360.co.ke/fhir/CodeSystem/concept-codesystem' "sys";\r\n it -> cg.code = 'hormonal-therapy-next-review' "cd";\r\n it -> cg.display = 'Next hormonal therapy review' "dsp";\r\n } "coding";\r\n } "code";\r\n it.answer first as a then {\r\n a.value as d -> sr.occurrence = cast(d, 'dateTime') "occurrence";\r\n };\r\n qr.authored as t -> sr.authoredOn = t "authoredOn";\r\n qr.encounter as e where ((reference.exists() and (reference.startsWith('Encounter/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Encounter')))) -> sr.encounter = e;\r\n it -> sr.note as n, n.text = 'Date to come again, written on the hormonal therapy treatment plan. Not a booked appointment: the sheet names no clinic, clinician or slot.' "provenanceNote";\r\n } "nextVisit";\r\n } "cycleRows";\r\n}\r\n\r\n// The cycle's own date on every Observation from that cycle. It overrides the\r\n// response's authored time: several rows keyed in at one sitting would\r\n// otherwise collapse onto one instant and the series would be gone.\r\ngroup SetHormonalCycleContext(source c, target obs : Observation) {\r\n c.item as it where ((linkId = 'cycle/date') and answer.value.exists()) then {\r\n it.answer first as a then {\r\n a.value as v where ($this.toString().length() = 10) -> evaluate(v, $this.toString() + 'T00:00:00+03:00') as midnight, obs.effective = cast(midnight, 'instant') "effectiveFromCycle";\r\n };\r\n } "cycleDateRule";\r\n}\r\n\r\n// ─────────────────────────────────────────────────────────────────────────────\r\n// Shared scaffolding. Repeated in each map rather than imported: the transform\r\n// engine resolves `imports` against whatever StructureMaps happen to be on the\r\n// server, and a form that stops extracting because a shared map was not\r\n// uploaded is a worse failure than a duplicated group.\r\n// ─────────────────────────────────────────────────────────────────────────────\r\ngroup BuildObsBase(source qr : QR, target obs : Observation, target entry) {\r\n qr -> obs then SetResponseProvenance(qr, obs) "responseProvenance";\r\n qr -> obs.id = uuid() then SetObservationFullUrl(obs, entry) "idAndFullUrl";\r\n qr -> entry.request as request then {\r\n qr -> request.method = 'POST' "requestMethod";\r\n qr -> request.url = 'Observation' "requestUrl";\r\n } "entryRequest";\r\n qr -> obs.status = 'final' "status";\r\n qr.subject as s where ((reference.exists() and (reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Patient')))) -> obs.subject = s;\r\n qr.encounter as e where ((reference.exists() and (reference.startsWith('Encounter/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Encounter')))) -> obs.encounter = e;\r\n // A stored response's id already reads "QuestionnaireResponse/<id>", so it is\r\n // a relative reference as it stands. The hasValue() guard is what stops an\r\n // unsaved response -- one posted straight to $extract rather than saved first\r\n // -- from writing "QuestionnaireResponse/null" into the record.\r\n qr.id as qid where ($this.hasValue()) -> obs.derivedFrom = create('Reference') as ref, ref.reference = qid "linkQuestionnaireResponse";\r\n qr -> obs then ConformObservation(qr, obs) "profileConformance";\r\n}\r\n\r\ngroup SetObservationFullUrl(source obs : Observation, target entry) {\r\n obs.id as id -> entry.fullUrl = append('https://fhir.slade360.co.ke/fhir/Observation/', id) "assignFullUrl";\r\n}\r\n\r\ngroup SetSurveyCategory(source qr : QR, target obs : Observation) {\r\n qr -> obs.category as cat then {\r\n qr -> cat.coding as coding then {\r\n qr -> coding.system = 'http://terminology.hl7.org/CodeSystem/observation-category' "categorySystem";\r\n qr -> coding.code = 'survey' "categoryCode";\r\n qr -> coding.display = 'Survey' "categoryDisplay";\r\n } "categoryCoding";\r\n } "category";\r\n}\r\n\r\ngroup SetLaboratoryCategory(source qr : QR, target obs : Observation) {\r\n qr -> obs.category as cat then {\r\n qr -> cat.coding as coding then {\r\n qr -> coding.system = 'http://terminology.hl7.org/CodeSystem/observation-category' "categorySystem";\r\n qr -> coding.code = 'laboratory' "categoryCode";\r\n qr -> coding.display = 'Laboratory' "categoryDisplay";\r\n } "categoryCoding";\r\n } "category";\r\n}\r\n\r\ngroup BuildMedicationAdministrationBase(source qr : QR, target r : MedicationAdministration, target entry) {\r\n qr -> r then SetResponseProvenance(qr, r) "responseProvenance";\r\n qr -> r.id = uuid() then SetMedicationAdministrationFullUrl(r, entry) "idAndFullUrl";\r\n qr -> entry.request as request then {\r\n qr -> request.method = 'POST' "requestMethod";\r\n qr -> request.url = 'MedicationAdministration' "requestUrl";\r\n } "entryRequest";\r\n qr.subject as s where ((reference.exists() and (reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Patient')))) -> r.subject = s;\r\n // The response's own time, as a floor. A row that names its date overwrites\r\n // this; without it a row missing its date would produce an administration\r\n // with no time at all, which is not a record of an administration.\r\n qr.authored as t -> r.occurence = t "occurrenceFallback";\r\n qr -> r then ConformMedicationAdministration(qr, r) "profileConformance";\r\n}\r\n\r\ngroup SetMedicationAdministrationFullUrl(source r : MedicationAdministration, target entry) {\r\n r.id as id -> entry.fullUrl = append('https://fhir.slade360.co.ke/fhir/MedicationAdministration/', id) "assignFullUrl";\r\n}\r\n\r\ngroup BuildServiceRequestBase(source qr : QR, target r : ServiceRequest, target entry) {\r\n qr -> r then SetResponseProvenance(qr, r) "responseProvenance";\r\n qr -> r.id = uuid() then SetServiceRequestFullUrl(r, entry) "idAndFullUrl";\r\n qr -> entry.request as request then {\r\n qr -> request.method = 'POST' "requestMethod";\r\n qr -> request.url = 'ServiceRequest' "requestUrl";\r\n } "entryRequest";\r\n qr.subject as s where ((reference.exists() and (reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Patient')))) -> r.subject = s;\r\n qr -> r then ConformServiceRequest(qr, r) "profileConformance";\r\n}\r\n\r\ngroup SetServiceRequestFullUrl(source r : ServiceRequest, target entry) {\r\n r.id as id -> entry.fullUrl = append('https://fhir.slade360.co.ke/fhir/ServiceRequest/', id) "assignFullUrl";\r\n}\r\n\r\n// ── Provenance and tenancy ───────────────────────────────────────────────────\r\n// Two tags on everything this map creates. The first says which questionnaire\r\n// produced it, so a form that reopens mid-admission recalls its own earlier\r\n// entries and not another form's. The second copies the tenant tags off the\r\n// response, because nothing else on the path puts them there. The response's\r\n// identifier is copied the same way.\r\n// The code is the form's document type, not the questionnaire's id: every\r\n// environment mints its own ids, and there is only one set of maps, so an id\r\n// here would tie the tag to whichever environment stamped it.\r\n// ── Provenance and tenancy ───────────────────────────────────────────────────\r\ngroup SetResponseProvenance(source qr : QR, target r) {\r\n qr -> r.meta as m then {\r\n qr -> m.tag as t then {\r\n qr -> t.system = 'http://slade360edi.com/questionnaire-provenance' "provenanceSystem";\r\n qr -> t.code = 'hormonal-therapy-treatment-plan' "provenanceCode";\r\n qr -> t.display = 'Hormonal therapy treatment plan' "provenanceDisplay";\r\n } "provenanceTag";\r\n } "provenanceMeta";\r\n // Every tag the response carries, onto the resource. `meta` is 0..1, so this\r\n // lands on the same meta the rule above created rather than a second one.\r\n qr.meta as qm then {\r\n qm.tag as qt -> r.meta as m, m.tag = qt "copyTag";\r\n } "tenantTags";\r\n // The response's identifiers, as they are. Every profile wants one, and it is\r\n // the response's to give: nothing here mints one, so a response without an\r\n // identifier extracts resources without one. One whose assigner is not of a\r\n // type the profiles allow there is left behind whole, not altered.\r\n qr.identifier as qid where (assigner.empty() or assigner.where(((reference.exists() and (reference.startsWith('Organization/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization'))))).exists()) -> r.identifier = qid;\r\n}\r\n\r\n// ── Conformance to the IG profiles ───────────────────────────────────────────\r\n// What the IG's profiles require that the response itself can supply. Called at\r\n// the end of each base group. The encounter and every who-element are the\r\n// response's own; see mapmeta.py for what is and is not here.\r\n// ── Conformance to the IG profiles ───────────────────────────────────────────\r\ngroup ConformObservation(source qr : QR, target r) {\r\n qr.authored as t where ($this.toString().length() >= 20) -> r.issued = cast(t, 'instant') "issued";\r\n qr.authored as t where ($this.toString().length() >= 20) -> r.effective = cast(t, 'instant') "effective";\r\n qr.author as au where ((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient')))) -> r.performer = au "performerFromAuthor";\r\n qr where (author.where(((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient'))))).exists().not()) then {\r\n qr.source as src where ((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient')))) -> r.performer = src "performerFromSource";\r\n } "performerFallback";\r\n}\r\n\r\ngroup ConformMedicationAdministration(source qr : QR, target r) {\r\n qr.encounter as e where ((reference.exists() and (reference.startsWith('Encounter/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Encounter')))) -> r.encounter = e;\r\n qr.author as au where ((reference.exists() and (reference.startsWith('Practitioner/') or reference.startsWith('PractitionerRole/') or reference.startsWith('Patient/') or reference.startsWith('RelatedPerson/') or reference.startsWith('Device/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Practitioner') or ('/' + type).endsWith('/PractitionerRole') or ('/' + type).endsWith('/Patient') or ('/' + type).endsWith('/RelatedPerson') or ('/' + type).endsWith('/Device')))) -> r.performer as p, p.actor = create('CodeableReference') as cr, cr.reference = au "performerFromAuthor";\r\n qr where (author.where(((reference.exists() and (reference.startsWith('Practitioner/') or reference.startsWith('PractitionerRole/') or reference.startsWith('Patient/') or reference.startsWith('RelatedPerson/') or reference.startsWith('Device/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Practitioner') or ('/' + type).endsWith('/PractitionerRole') or ('/' + type).endsWith('/Patient') or ('/' + type).endsWith('/RelatedPerson') or ('/' + type).endsWith('/Device'))))).exists().not()) then {\r\n qr.source as src where ((reference.exists() and (reference.startsWith('Practitioner/') or reference.startsWith('PractitionerRole/') or reference.startsWith('Patient/') or reference.startsWith('RelatedPerson/') or reference.startsWith('Device/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Practitioner') or ('/' + type).endsWith('/PractitionerRole') or ('/' + type).endsWith('/Patient') or ('/' + type).endsWith('/RelatedPerson') or ('/' + type).endsWith('/Device')))) -> r.performer as p, p.actor = create('CodeableReference') as cr, cr.reference = src "performerFromSource";\r\n } "performerFallback";\r\n}\r\n\r\ngroup ConformServiceRequest(source qr : QR, target r) {\r\n qr.encounter as e where ((reference.exists() and (reference.startsWith('Encounter/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Encounter')))) -> r.encounter = e;\r\n qr.authored as t -> r.authoredOn = t "authoredOn";\r\n qr -> r.priority = 'routine' "priority";\r\n qr.author as au where ((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient')))) -> r.requester = au "requesterFromAuthor";\r\n qr where (author.where(((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient'))))).exists().not()) then {\r\n qr.source as src where ((reference.exists() and (reference.startsWith('Organization/') or reference.startsWith('Patient/'))) or (reference.empty() and (type.empty() or ('/' + type).endsWith('/Organization') or ('/' + type).endsWith('/Patient')))) -> r.requester = src "requesterFromSource";\r\n } "requesterFallback";\r\n}\r\n\r\n