Skip to content

Commit

Permalink
CDR Module: Fix for CQM framework.
Browse files Browse the repository at this point in the history 
  - Fix to collect patient dob.
  - Clarified code in using of patient id.
  - Fix htn rule bug to search for vitals of each patient (rather than all)
  • Loading branch information
@bradymiller
bradymiller committed Apr 22, 2011
1 parent 7073a1d commit 92d94c6
Showing 1 changed file with 57 additions and 33 deletions.
90 changes: 57 additions & 33 deletions library/classes/rulesets/ruleSet.class.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,8 @@

require_once(dirname(__FILE__) . "/../../clinical_rules.php");
require_once(dirname(__FILE__) . "/../../forms.inc");
require_once(dirname(__FILE__) . "/../../patient.inc");


class ruleSet
{
Expand Down Expand Up @@ -245,6 +247,22 @@ private function exist_encounter($patient_id,$encounter_label,$begin_date='',$en
}
}

// Function to get patient dob
// Parameter:
// $patient_id - patient id
// Return: DOB (string)
private function get_DOB($patient_id) {
$dob = getPatientData($patient_id, "DATE_FORMAT(DOB,'%Y %m %d') as TS_DOB");
return $dob['TS_DOB'];
}

// Function to get patient id from the patient array
// Paramter:
// $array_patient - array holding patient id in the 'id' column
private function get_patient_id($array_patient) {
return $array_patient['pid'];
}

// Hypertension: Blood Pressure Measurement (NQF 0013)
//
// (note it only needs to process one group)
Expand Down Expand Up @@ -285,47 +303,50 @@ private function rule_htn_bp_measure_cqm() {
// increment total patients counter
$total_pat++;

// get patient id
$patient_id = $this->get_patient_id($rowPatient);

// filter for age greater than 18
// utilize the convertDobtoAgeYearDecimal() function from library/clinical_rules.php
if (convertDobtoAgeYearDecimal($rowPatient['DOB'],$begin_measurement) < 18) continue;
if (convertDobtoAgeYearDecimal( $this->get_DOB($patient_id), $begin_measurement ) < 18) continue;

// filter for diagnosis of HTN
// utlize the exist_lists_item() function from library/clinical_rules.php
if (!( (exist_lists_item($rowPatient['pid'],'medical_problem','CUSTOM::HTN',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::401.0',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::401.1',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::401.9',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.00',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.01',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.10',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.11',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.90',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::402.91',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.00',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.01',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.10',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.11',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.90',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::403.91',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.00',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.01',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.02',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.03',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.10',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.11',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.12',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.13',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.90',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.91',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.92',$end_measurement)) ||
(exist_lists_item($rowPatient['pid'],'medical_problem','ICD9::404.93',$end_measurement)) )) {
if (!( (exist_lists_item($patient_id,'medical_problem','CUSTOM::HTN',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::401.0',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::401.1',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::401.9',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.00',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.01',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.10',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.11',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.90',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::402.91',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.00',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.01',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.10',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.11',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.90',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::403.91',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.00',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.01',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.02',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.03',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.10',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.11',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.12',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.13',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.90',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.91',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.92',$end_measurement)) ||
(exist_lists_item($patient_id,'medical_problem','ICD9::404.93',$end_measurement)) )) {
continue;
}

// filter for 2 specified encounters
// make a function for this and wrap in the encounter titles
if (!( ($this->exist_encounter($rowPatient['pid'],'enc_outpatient',$begin_measurement,$end_measurement,2)) ||
($this->exist_encounter($rowPatient['pid'],'enc_nurs_fac',$begin_measurement,$end_measurement,2)) )) {
if (!( ($this->exist_encounter($patient_id,'enc_outpatient',$begin_measurement,$end_measurement,2)) ||
($this->exist_encounter($patient_id,'enc_nurs_fac',$begin_measurement,$end_measurement,2)) )) {
continue;
}

Expand All @@ -339,15 +360,18 @@ private function rule_htn_bp_measure_cqm() {
"ON ( DATE(form_vitals.date) = DATE(form_encounter.date)) " .
"LEFT JOIN `enc_category_map` " .
"ON (enc_category_map.main_cat_id = form_encounter.pc_catid) " .
"WHERE form_vitals.bps IS NOT NULL " .
"WHERE form_vitals.pid = ?" .
"AND form_vitals.bps IS NOT NULL " .
"AND form_vitals.bpd IS NOT NULL " .
"AND form_vitals.date >= ? " .
"AND form_vitals.date <= ? " .
"AND ( enc_category_map.rule_enc_id = 'enc_outpatient' OR enc_category_map.rule_enc_id = 'enc_nurs_fac' )";
$res = sqlStatement($query, array($begin_measurement,$end_measurement) );
$res = sqlStatement($query, array($patient_id,$begin_measurement,$end_measurement) );
$number = sqlNumRows($res);
if ($number < 1) continue;

error_log("passed target",0);

This comment has been minimized.

Sign in to view

Copy link
@bradymiller

bradymiller Apr 22, 2011

Author Owner

oops, will need to remove this debug line on next commit...

// Target has been passed
$pass_targ++;
}
Expand Down

0 comments on commit 92d94c6

Please sign in to comment.