phpfhir/classes/src/fetch_live.class.php

   1 <?php
   2 /**
   3  * FetchLiveData class
   4  *
   5  * @package   OpenEMR
   6  * @link      http://www.open-emr.org
   7  * @author    Jerry Padgett <sjpadgett@gmail.com>
   8  * @copyright Copyright (c) 2018 Jerry Padgett <sjpadgett@gmail.com>
   9  * @license   https://www.gnu.org/licenses/agpl-3.0.en.html GNU Affero General Public License 3
  10  */
  11
  12 namespace oeFHIR;
  13
  14 require_once(dirname(__file__) . "/../../../custom/code_types.inc.php");
  15
  16 class FetchLiveData
  17 {
  18     /**
  19      * Function oeQuery
  20      * All DB Transactions take place
  21      *
  22      * @param String $sql SQL Query Statement
  23      * @param array $params SQL Parameters
  24      * @param boolean $log Logging True / False
  25      * @param boolean $error Error Display True / False
  26      * @return   records   Array
  27      */
  28     public function oeQuery($sql, $params = [], $log = false, $error = true)
  29     {
  30         $return = false;
  31         $result = false;
  32
  33         try {
  34             $return = sqlStatement($sql, $params);
  35             $result = true;
  36         } catch (Exception $e) {
  37             if ($error) {
  38             }
  39         }
  40
  41         return $return;
  42     }
  43
  44     /*
  45      * Fetch the current demographics data of a patient from patient_data table
  46      *
  47      * @param    pid       Integer   Patient ID
  48      * @return   records   Array     current patient data
  49      */
  50     public function getDemographicsCurrent($pid)
  51     {
  52
  53         $query = "SELECT *
  54                    FROM patient_data
  55                    WHERE pid = ?";
  56         $result = $this->oeQuery($query, array($pid));
  57         $records = array();
  58         foreach ($result as $row) {
  59             $records[] = $row;
  60         }
  61
  62         return $records[0];
  63     }
  64
  65     /*
  66      * Fetch the current Problems of a patient from lists table
  67      *
  68      * @param    pid       Integer     patient id
  69      * @return   records   Array       list of problems
  70      */
  71     public function getProblems($pid)
  72     {
  73
  74         $query = "SELECT *
  75                    FROM lists
  76                    WHERE pid = ? AND TYPE = 'medical_problem'";
  77         $result = $this->oeQuery($query, array($pid));
  78         $records = array();
  79         foreach ($result as $row) {
  80             $records[] = $row;
  81         }
  82
  83         return $records;
  84     }
  85
  86     /*
  87      * Fetch the current Allergies of a patient from lists table
  88      *
  89      * @param    pid       Integer     patient id
  90      * @return   records   Array       list of allergies
  91      */
  92     public function getAllergies($pid)
  93     {
  94
  95         $query = "SELECT *
  96                    FROM lists
  97                    WHERE pid = ? AND TYPE = 'allergy'";
  98         $result = $this->oeQuery($query, array($pid));
  99         $records = array();
 100         foreach ($result as $row) {
 101             $records[] = $row;
 102         }
 103
 104         return $records;
 105     }
 106
 107     /*
 108      * Fetch the current Medications of a patient from prescriptions table
 109      *
 110      * @param    pid       Integer     patient id
 111      * @return   records   Array       list of medications
 112      */
 113     public function getMedications($pid)
 114     {
 115
 116         $query = "SELECT *
 117                    FROM prescriptions
 118                    WHERE patient_id = ?";
 119         $result = $this->oeQuery($query, array($pid));
 120         $records = array();
 121         foreach ($result as $row) {
 122             $records[] = $row;
 123         }
 124
 125         return $records;
 126     }
 127
 128     /*
 129      * Fetch the current Immunizations of a patient from immunizations table
 130      *
 131      * @param    pid       Integer     patient id
 132      * @return   records   Array       list of immunizations
 133      */
 134     public function getImmunizations($pid)
 135     {
 136
 137         $query = "SELECT im.*, cd.code_text, DATE(administered_date) AS administered_date,
 138             DATE_FORMAT(administered_date,'%m/%d/%Y') AS administered_formatted, lo.title AS route_of_administration,
 139             u.title, u.fname, u.mname, u.lname, u.npi, u.street, u.streetb, u.city, u.state, u.zip, u.phonew1,
 140             f.name, f.phone, lo.notes AS route_code
 141             FROM immunizations AS im
 142             LEFT JOIN codes AS cd ON cd.code = im.cvx_code
 143             JOIN code_types AS ctype ON ctype.ct_key = 'CVX' AND ctype.ct_id=cd.code_type
 144             LEFT JOIN list_options AS lo ON lo.list_id = 'drug_route' AND lo.option_id = im.route
 145             LEFT JOIN users AS u ON u.id = im.administered_by_id
 146             LEFT JOIN facility AS f ON f.id = u.facility_id
 147             WHERE im.patient_id=?";
 148         $result = $this->oeQuery($query, array($pid));
 149         $records = array();
 150         foreach ($result as $row) {
 151             $records[] = $row;
 152         }
 153
 154         return $records;
 155     }
 156
 157     /*
 158      * Fetch the currect Lab Results of a patient
 159      *
 160      * @param    pid       Integer     patient id
 161      * @return   records   Array       list of lab results
 162      */
 163     public function getLabResults($pid)
 164     {
 165
 166         $query = "SELECT CONCAT_WS('',po.procedure_order_id,poc.`procedure_order_seq`) AS tcode,
 167                           prs.result AS result_value,
 168                           prs.units, prs.range,
 169                           poc.procedure_name AS order_title,
 170                           prs.result_code AS result_code,
 171                           prs.result_text AS result_desc,
 172                           po.date_ordered,
 173                           prs.date AS result_time,
 174                           prs.abnormal AS abnormal_flag,
 175                           prs.procedure_result_id AS result_id
 176                    FROM procedure_order AS po
 177                    JOIN procedure_order_code AS poc ON poc.`procedure_order_id`=po.`procedure_order_id`
 178                    JOIN procedure_report AS pr ON pr.procedure_order_id = po.procedure_order_id
 179                         AND pr.`procedure_order_seq`=poc.`procedure_order_seq`
 180                    JOIN procedure_result AS prs ON prs.procedure_report_id = pr.procedure_report_id
 181                    WHERE po.patient_id = ? AND prs.result NOT IN ('DNR','TNP')";
 182         $result = $this->oeQuery($query, array($pid));
 183         $records = array();
 184         foreach ($result as $row) {
 185             $records[] = $row;
 186         }
 187
 188         return $records;
 189     }
 190
 191     public function getUser($id)
 192     {
 193
 194         $query = "SELECT *
 195                    FROM users
 196                    WHERE id = ?";
 197         $result = $this->oeQuery($query, array($id));
 198         $records = array();
 199         foreach ($result as $row) {
 200             $records[] = $row;
 201         }
 202
 203         return $records[0];
 204     }
 205
 206     /*
 207      * Fetch the current Vitals of a patient from form_vitals table
 208      *
 209      * @param    pid       Integer     patient id
 210      * @return   records   Array       list of vitals
 211      */
 212     public function getVitals($pid)
 213     {
 214
 215         $query = "SELECT *
 216                    FROM form_vitals
 217                    WHERE pid = ? AND activity=?";
 218         $result = $this->oeQuery($query, array($pid, 1));
 219         $records = array();
 220         foreach ($result as $row) {
 221             $records[] = $row;
 222         }
 223
 224         return $records;
 225     }
 226
 227     /*
 228      * Fetch the social history of a patient from history_data table
 229      *
 230      * @param    pid       Integer     patient id
 231      * @return   records   Array       history data
 232      */
 233     public function getSocialHistory($pid)
 234     {
 235
 236         $query = "SELECT *
 237                    FROM history_data
 238                    WHERE pid=?
 239                    ORDER BY id DESC LIMIT 1";
 240         $result = $this->oeQuery($query, array($pid));
 241         $records = array();
 242         foreach ($result as $row) {
 243             $records[] = $row;
 244         }
 245
 246         return $records;
 247     }
 248
 249     /*
 250       * Fetch the list of encounter Id's of a patient from form_encounter table
 251       *
 252       * @param    pid       Integer     patient id
 253       * @return   records   Array       encounter data
 254       */
 255     public function getEncounterIdList($pid)
 256     {
 257
 258         $query = "SELECT form_encounter.encounter,form_encounter.reason
 259                    FROM form_encounter
 260                    WHERE pid = ?";
 261
 262         $result = $this->oeQuery($query, array($pid));
 263         $records = array();
 264         foreach ($result as $row) {
 265             $records[] = $row;
 266         }
 267
 268         return $records;
 269     }
 270
 271     /*
 272      * Fetch the encounter data of a patient from form_encounter table
 273      *
 274      * @param    pid       Integer     patient id
 275      * @return   records   Array       encounter data
 276      */
 277     public function getEncounterData($pid, $eid = '')
 278     {
 279
 280         $query = "SELECT form_encounter.*,u.lname AS provider_name
 281                    FROM form_encounter
 282                    LEFT JOIN users AS u
 283                    ON form_encounter.provider_id=u.id
 284                    WHERE pid = ?";
 285         $data = array($pid);
 286         if ($eid) {
 287             $query .= " && encounter=?";
 288             $data = array($pid, $eid);
 289         }
 290         $result = $this->oeQuery($query, $data);
 291         $records = array();
 292         foreach ($result as $row) {
 293             $records[] = $row;
 294         }
 295         if ($eid) {
 296             $records = $records[0];
 297         }
 298         return $records;
 299     }
 300
 301     /*
 302      * Fetch the billing data of a patient from billing table
 303      *
 304      * @param    pid       Integer     patient id
 305      * @return   records   Array       billing data
 306      */
 307     public function getProcedure($pid)
 308     {
 309
 310         $query = "SELECT *
 311                  FROM billing
 312                  WHERE pid=? AND code_type=?";
 313         $result = $this->oeQuery($query, array($pid, 'CPT4'));
 314         $records = array();
 315         foreach ($result as $row) {
 316             $records[] = $row;
 317         }
 318
 319         return $records;
 320     }
 321
 322     /*
 323      * Fetch the current Care Plan of a patient from form_care_plan table
 324      *
 325      * @param    pid       Integer     patient id
 326      * @return   records   Array       list of Care Plans
 327      */
 328     public function getCarePlan($pid)
 329     {
 330
 331         $query = "SELECT *
 332                    FROM form_care_plan
 333                    WHERE pid = ? AND activity=?";
 334         $result = $this->oeQuery($query, array($pid, 1));
 335         $records = array();
 336         foreach ($result as $row) {
 337             $records[] = $row;
 338         }
 339
 340         return $records;
 341     }
 342
 343     /*
 344      * Fetch the current Functional Cognitive Status of a patient from form_functional_cognitive_status table
 345      *
 346      * @param    pid       Integer     patient id
 347      * @return   records   Array       list of Functional Cognitive Status
 348      */
 349     public function getFunctionalCognitiveStatus($pid)
 350     {
 351
 352         $query = "SELECT *
 353                    FROM form_functional_cognitive_status
 354                    WHERE pid = ? AND activity=?";
 355         $result = $this->oeQuery($query, array($pid, 1));
 356         $records = array();
 357         foreach ($result as $row) {
 358             $records[] = $row;
 359         }
 360
 361         return $records;
 362     }
 363 }