package LIMS::Model::HMRN::Data;
use Moose::Role;
requires 'patient_id';
use Data::Dumper;
# ------------------------------------------------------------------------------
# all diagnoses with ICDO3 designation for this patient (NB includes /1, /3, /6):
sub all_icdo3_diagnoses {
my $self = shift;
my $patient_id = $self->patient_id;
my @tables = qw( patients diagnoses );
my $relationships = $self->get_relationships(\@tables);
my %args = (
query => [
patient_id => $patient_id,
'request_report.diagnosis.icdo3' => { ne => undef }, # icdo3 col not null
],
require_objects => $relationships,
);
my $data = LIMS::DB::Request::Manager->get_requests(%args);
return $data;
}
# ------------------------------------------------------------------------------
sub event_dates {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = q!select t2.description, t1.date from hmrn.patient_event t1
join hmrn.events t2 on t1.event_id = t2.id where patient_id = ?!;
my $events = $dbix->query($sql, $patient_id)->hashes; # warn Dumper $events;
for (@$events) {
my $event = $_->{description};
my $date = $self->inflate_mysql_date_to_datetime($_->{date});
$data->{event_dates}{$event} = $date;
}
}
# ------------------------------------------------------------------------------
sub mdt_dates {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = q!select id, date from hmrn.patient_mdt_dates where
patient_id = ? order by date!;
my $dates = $dbix->query($sql, $patient_id);
while ( my $vals = $dates->hash ) { # inflate 'date' val to DT object:
$self->inflate_mysql_dates_to_datetime($vals, ['date']);
push @{ $data->{mdt_dates} }, $vals;
}
}
# ------------------------------------------------------------------------------
sub antecedent_events {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
{ # antecedent_events:
my $sql = q!select event_id from hmrn.patient_antecedent where patient_id = ?!;
my $event_id = $dbix->query($sql, $patient_id)->list;
$data->{antecedent}{event_id} = $event_id;
}
{ # previous radio- & chemo-therapies:
my $sql = q!select therapy from hmrn.patient_prior_therapies where patient_id = ?!;
my $tx = $dbix->query($sql, $patient_id)->flat; # warn Dumper $tx;
my %data = map { $_ => 1 } @$tx; # warn Dumper \%data;
$data->{antecedent}{prior_tx} = \%data; # part of antecedent/prior tx set
}
}
# ------------------------------------------------------------------------------
sub treatment {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = $self->sql_lib->retr('hmrn_patient_treatment_data');
my $tx = $dbix->query($sql, $patient_id);
while ( my $vals = $tx->hash ) { # warn Dumper $vals; # dates to datetime:
$self->inflate_mysql_dates_to_datetime($vals, [ qw(start_date end_date) ]);
push @{ $data->{treatments} }, $vals; # add to treaments array
}
}
# ------------------------------------------------------------------------------
sub data_params {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = $self->sql_lib->retr('hmrn_all_patient_params');
my $query = $dbix->query($sql, $patient_id);
while ( my $vals = $query->hash ) {
my $param_name = $vals->{param_name};
my $category = $vals->{category};
$data->{params}{$category}{$param_name} = $vals->{result};
}
}
# ------------------------------------------------------------------------------
# which dataset(s) do we have - skip 'promiscuous' params & autoincrement category counter:
sub dataset_type {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = $self->sql_lib->retr('hmrn_non_unique_params');
my @non_unique_params = $dbix->query($sql)->flat;
my $param_data = $data->{params};
CATEGORY: # for each category (precursor, myeloid, etc):
while ( my($category, $ref) = each %$param_data ) {
PARAM: # for each data param (albumin, Hb, etc):
while ( my ($param, $result) = each %$ref ) {
# skip any params shared by >1 category:
next PARAM if grep $param eq $_, @non_unique_params;
# increment category_has_data count for category:
$data->{category_has_data}{$category}++;
}
} # warn Dumper \$data;
}
# ------------------------------------------------------------------------------
sub imaging_data {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
{ # imaging events:
my $query = $dbix->select('hmrn.patient_imaging_event',
[ qw(id scan_type dataset stage date) ],
{ patient_id => $patient_id } );
while ( my ($id, $scan_type, $dataset, $stage, $date) = $query->list ) {
my %h = (
event_id => $id,
stage => $stage,
date => $date,
);
$self->inflate_mysql_dates_to_datetime(\%h, ['date']);
$data->{imaging}{$scan_type}{$dataset}{$_} = $h{$_} for keys %h;
}
}
{ # imaging sites:
my $sql = $self->sql_lib->retr('hmrn_patient_imaging');
my $query = $dbix->query($sql, $patient_id);
while ( my ($scan_type, $dataset, $option_id) = $query->list ) {
$data->{imaging}{$scan_type}{$dataset}{site_opts}{$option_id}++;
}
}
{ # other (free-text) details:
my $sql = q!select scan_type, dataset, details from
hmrn.patient_imaging_other io join hmrn.patient_imaging_event ie on
io.imaging_event_id = ie.id where ie.patient_id = ?!;
my $query = $dbix->query($sql, $patient_id);
while ( my ($scan_type, $dataset, $detail) = $query->list ) {
$data->{imaging}{$scan_type}{$dataset}{other} = $detail;
}
}
{ # SUV & deauville data - only exists for pet scan:
my $sql = q!select scan_type, dataset, param, result from
hmrn.patient_pet_score ps join hmrn.patient_imaging_event ie on
ps.imaging_event_id = ie.id where ie.patient_id = ?!;
my $query = $dbix->query($sql, $patient_id);
while ( my ($scan_type, $dataset, $param, $result) = $query->list ) {
$data->{imaging}{$scan_type}{$dataset}{$param} = $result;
}
}
}
# ------------------------------------------------------------------------------
sub comments {
my $self = shift;
my $data = shift;
my $patient_id = $self->patient_id;
my $dbix = $self->lims_dbix;
my $sql = 'select * from hmrn.patient_comments where patient_id = ?';
my $comment = $dbix->query($sql, $patient_id)->hash;
$self->inflate_mysql_timestamp_to_datetime($comment, ['timestamp']);
$data->{params}{comment} = $comment;
}
# ------------------------------------------------------------------------------
# calculated indices (IPI, FLIPI, HIPI, etc):
sub calculated_indices {
my $self = shift;
my $data = shift; # warn Dumper $data;
my $patient_id = $self->patient_id;
# use initial CT scan data for staging:
if ( my $initial_scan = $data->{imaging}->{ct}->{1} ) { # warn Dumper $initial_scan;
my %args = (
patient_id => $patient_id,
params_data => $data->{params},
initial_scan => $initial_scan,
option_maps => $data->{maps},
); # warn Dumper $data->{params};
# all calculations handled by Model::HMRN::PrognosticIndicator:
my $indices = $self->prognostic_indicators(\%args);
$data->{params}{indices} = $indices; # warn Dumper $indices;
}
}
1;
