diff --git a/frontend/src/app/pages/report-labs/report-labs.component.html b/frontend/src/app/pages/report-labs/report-labs.component.html index b43d9f7b0..7825c8ee5 100644 --- a/frontend/src/app/pages/report-labs/report-labs.component.html +++ b/frontend/src/app/pages/report-labs/report-labs.component.html @@ -44,6 +44,18 @@

Observations

[observationCode]="observationGroup.key" [observationTitle]="observationGroupTitles[observationGroup.key]" > + + + + + + diff --git a/frontend/src/app/pages/report-labs/report-labs.component.ts b/frontend/src/app/pages/report-labs/report-labs.component.ts index 25bc1d045..e621ae6f1 100644 --- a/frontend/src/app/pages/report-labs/report-labs.component.ts +++ b/frontend/src/app/pages/report-labs/report-labs.component.ts @@ -3,6 +3,21 @@ import {FastenApiService} from '../../services/fasten-api.service'; import {NgbModal} from '@ng-bootstrap/ng-bootstrap'; import {ResourceFhir} from '../../models/fasten/resource_fhir'; import * as fhirpath from 'fhirpath'; +import {Observable} from 'rxjs'; +import {flatMap, map} from 'rxjs/operators'; +import {ResponseWrapper} from '../../models/response-wrapper'; +import {ActivatedRoute} from '@angular/router'; + +class ObservationGroup {[key: string]: ResourceFhir[]} +class ObservationGroupInfo { + observationGroups: ObservationGroup = {} + observationGroupTitles: {[key: string]: string} = {} +} +class LabResultCodeByDate { + label: string //lab result coding (system|code) + value: string //lab result date +} + @Component({ selector: 'app-report-labs', @@ -12,7 +27,13 @@ import * as fhirpath from 'fhirpath'; export class ReportLabsComponent implements OnInit { loading: boolean = false - observationGroups: {[key: string]: ResourceFhir[]} = {} + currentPage: number = 0 + pageSize: number = 10 + allObservationGroups: string[] = [] + + + //currentPage data + observationGroups: ObservationGroup = {} observationGroupTitles: {[key: string]: string} = {} isEmptyReport = false @@ -21,72 +42,123 @@ export class ReportLabsComponent implements OnInit { constructor( private fastenApi: FastenApiService, + private activatedRoute: ActivatedRoute, ) { } ngOnInit(): void { this.loading = true - this.fastenApi.queryResources({ - select: ["*"], - from: "DiagnosticReport", - where: { - "category": "http://terminology.hl7.org/CodeSystem/v2-0074|LAB", - }, - limit: 5, - }).subscribe(results => { - this.diagnosticReports = results.data - console.log("ALL DIAGNOSTIC REPORTS", results) - }) + this.populateReports() - this.fastenApi.queryResources({ - select: [], - from: "Observation", - where: { - "code": "http://loinc.org|,urn:oid:2.16.840.1.113883.6.1|", - }, - aggregations: { - order_by: { - field: "sort_date", - fn: "max" - }, - group_by: { - field: "code", - } - } - }).subscribe(results => { - console.log("OBSERVATIONS GROUPED", results) + this.findLabResultCodesSortedByLatest().subscribe((data) => { + // this.loading = false + console.log("ALL lab result codes", data) + this.allObservationGroups = data.map((item) => item.label) + return this.populateObservationsForCurrentPage() }) + } + //using the current list of allObservationGroups, retrieve a list of observations, group them by observationGroup, and set the observationGroupTitles + populateObservationsForCurrentPage(){ - this.fastenApi.getResources("Observation").subscribe(results => { - this.loading = false - results = results || [] - console.log("ALL OBSERVATIONS", results) - - //loop though all observations, group by "code.system": "http://loinc.org" - for(let observation of results){ - let observationGroup = fhirpath.evaluate(observation.resource_raw, "Observation.code.coding.where(system='http://loinc.org').first().code")[0] - this.observationGroups[observationGroup] = this.observationGroups[observationGroup] ? this.observationGroups[observationGroup] : [] - this.observationGroups[observationGroup].push(observation) + let observationGroups = this.allObservationGroups.slice(this.currentPage * this.pageSize, (this.currentPage + 1) * this.pageSize) - if(!this.observationGroupTitles[observationGroup]){ - this.observationGroupTitles[observationGroup] = fhirpath.evaluate(observation.resource_raw, "Observation.code.coding.where(system='http://loinc.org').first().display")[0] - } - } + this.loading = true + this.getObservationsByCodes(observationGroups).subscribe((data) => { + this.loading = false + this.observationGroups = data.observationGroups + this.observationGroupTitles = data.observationGroupTitles - this.isEmptyReport = !!!results.length + this.isEmptyReport = !!!Object.keys(this.observationGroups).length }, error => { this.loading = false this.isEmptyReport = true }) + } + //get a list of all lab codes associated with a diagnostic report + findLabResultCodesFilteredToReport(diagnosticReport: ResourceFhir): Observable { + return null + } + //get a list of all unique lab codes ordered by latest date + findLabResultCodesSortedByLatest(): Observable { + return this.fastenApi.queryResources({ + select: [], + from: "Observation", + where: { + "code": "http://loinc.org|,urn:oid:2.16.840.1.113883.6.1|", + }, + aggregations: { + order_by: { + field: "sort_date", + fn: "max" + }, + group_by: { + field: "code", + } + } + }) + .pipe( + map((response: ResponseWrapper) => { + return response.data as LabResultCodeByDate[] + }), + ) + } + //get a list of the last 10 lab results + populateReports(){ + return this.fastenApi.queryResources({ + select: ["*"], + from: "DiagnosticReport", + where: { + "category": "http://terminology.hl7.org/CodeSystem/v2-0074|LAB", + }, + limit: 10, + }).subscribe(results => { + this.diagnosticReports = results.data + }) + } + isEmpty(obj: any) { return Object.keys(obj).length === 0; } + //private methods + + //get a list of observations that have a matching code + private getObservationsByCodes(codes: string[]): Observable{ + return this.fastenApi.queryResources({ + select: [], + from: "Observation", + where: { + "code": codes.join(","), + } + }).pipe( + map((response: ResponseWrapper) => { + + let observationGroups: ObservationGroup = {} + let observationGroupTitles: {[key: string]: string} = {} + + //loop though all observations, group by "code.system": "http://loinc.org" + for(let observation of response.data){ + let observationGroup = fhirpath.evaluate(observation.resource_raw, "Observation.code.coding.where(system='http://loinc.org').first().code")[0] + observationGroups[observationGroup] = observationGroups[observationGroup] ? observationGroups[observationGroup] : [] + observationGroups[observationGroup].push(observation) + + if(!observationGroupTitles[observationGroup]){ + observationGroupTitles[observationGroup] = fhirpath.evaluate(observation.resource_raw, "Observation.code.coding.where(system='http://loinc.org').first().display")[0] + } + } + + return { + observationGroups: observationGroups, + observationGroupTitles: observationGroupTitles + } + }) + ); + } }