library/pnotes.inc

   1 <?php
   2 /**
   3  * This file contains functions for handling notes attached to patient files.
   4  *
   5  * This program is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU General Public License
   7  * as published by the Free Software Foundation; either version 2
   8  * of the License, or (at your option) any later version.
   9  *
  10  * 2013-02-08 EMR Direct: changes to allow notes added by background-services with pid=0
  11  */
  12
  13
  14 /**
  15  * Retrieve a note, given its ID
  16  *
  17  * @param string $id the ID of the note to retrieve.
  18  * @param string $cols A list of columns to retrieve. defaults to '*' for all.
  19  */
  20 function getPnoteById($id, $cols = "*")
  21 {
  22     return sqlQuery("SELECT $cols FROM pnotes WHERE id=? " .
  23     ' AND deleted != 1 '. // exclude ALL deleted notes
  24     'order by date DESC limit 0,1', array($id) );
  25 }
  26
  27 /**
  28  * Get the patient notes for the given user.
  29  *
  30  * This function is used to retrieve notes assigned to the given user, or
  31  * optionally notes assigned to any user.
  32  *
  33  * @param string $activity 0 for deleted notes, 1 (the default) for active
  34  *                         notes, or 'All' for all.
  35  * @param string $show_all whether to display only the selected user's
  36  *                         messages, or all users' messages.
  37  * @param string $user The user whom's notes you want to retrieve.
  38  * @param bool $count Whether to return a count, or just return 0.
  39  * @param string $sortby A field to sort results by. (options are users.lname,patient_data.lname,pnotes.title,pnotes.date,pnotes.message_status) (will default to users.lname)
  40  * @param string $sortorder whether to sort ascending or descending.
  41  * @param string $begin what row to start retrieving results from.
  42  * @param string $listnumber number of rows to return.
  43  * @return int The number of rows retrieved, or 0 if $count was true.
  44  */
  45 function getPnotesByUser($activity="1",$show_all="no",$user='',$count=false,$sortby='',$sortorder='',$begin='',$listnumber='')
  46 {
  47
  48   // Set the activity part of query
  49     if ($activity=='1') {
  50         $activity_query = " pnotes.message_status != 'Done' AND pnotes.activity = 1 AND ";
  51     }
  52     else if ($activity=='0') {
  53         $activity_query = " (pnotes.message_status = 'Done' OR pnotes.activity = 0) AND ";
  54     }
  55     else { //$activity=='all'
  56         $activity_query = " ";
  57     }
  58
  59   // Set whether to show chosen user or all users
  60     if ($show_all == 'yes' ) {
  61         $usrvar='_%';
  62     } else {
  63         $usrvar=$user;
  64     }
  65
  66   // run the query
  67   // 2013-02-08 EMR Direct: minor changes to query so notes with pid=0 don't disappear
  68     $sql = "SELECT pnotes.id, pnotes.user, pnotes.pid, pnotes.title, pnotes.date, pnotes.message_status,
  69           IF(pnotes.pid = 0 OR pnotes.user != pnotes.pid,users.fname,patient_data.fname) as users_fname,
  70           IF(pnotes.pid = 0 OR pnotes.user != pnotes.pid,users.lname,patient_data.lname) as users_lname,
  71           patient_data.fname as patient_data_fname, patient_data.lname as patient_data_lname
  72           FROM ((pnotes LEFT JOIN users ON pnotes.user = users.username)
  73           LEFT JOIN patient_data ON pnotes.pid = patient_data.pid) WHERE $activity_query
  74           pnotes.deleted != '1' AND pnotes.assigned_to LIKE ?";
  75     if (!empty($sortby) || !empty($sortorder)  || !empty($begin) || !empty($listnumber)) {
  76         $sql .= " order by ".escape_sql_column_name($sortby,array('users','patient_data','pnotes'),true).
  77             " ".escape_sort_order($sortorder).
  78             " limit ".escape_limit($begin).", ".escape_limit($listnumber);
  79     }
  80     $result = sqlStatement($sql, array($usrvar));
  81
  82   // return the results
  83     if ($count) {
  84         if(sqlNumRows($result) != 0) {
  85             $total = sqlNumRows($result);
  86         }
  87         else {
  88             $total = 0;
  89         }
  90         return $total;
  91     }
  92     else {
  93         return $result;
  94     }
  95 }
  96
  97 function getPnotesByDate(
  98     $date,
  99     $activity = "1",
 100     $cols = "*",
 101     $pid = "%",
 102     $limit = "all",
 103     $start = 0,
 104     $username = '',
 105     $docid = 0,
 106     $status = "",
 107     $orderid = 0
 108 ) {
 109
 110     $sqlParameterArray = array();
 111     if ($docid) {
 112         $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
 113         "WHERE p.date LIKE ? AND r.type1 = 1 AND " .
 114         "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid != p.user";
 115         array_push($sqlParameterArray, '%'.$date.'%', $docid);
 116     }
 117     else if ($orderid) {
 118         $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
 119         "WHERE p.date LIKE ? AND r.type1 = 2 AND " .
 120         "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid != p.user";
 121         array_push($sqlParameterArray, '%'.$date.'%', $orderid);
 122     }
 123     else {
 124         $sql = "SELECT $cols FROM pnotes AS p " .
 125         "WHERE date LIKE ? AND pid LIKE ? AND p.pid != p.user";
 126         array_push($sqlParameterArray, '%'.$date.'%', $pid);
 127     }
 128     $sql .= " AND deleted != 1"; // exclude ALL deleted notes
 129     if ($activity != "all") {
 130         if ($activity == '0') {
 131             // only return inactive
 132             $sql .= " AND (activity = '0' OR message_status = 'Done') ";
 133         }
 134         else { // $activity == '1'
 135             // only return active
 136             $sql .= " AND activity = '1' AND message_status != 'Done' ";
 137         }
 138     }
 139     if ($username) {
 140         $sql .= " AND assigned_to LIKE ?";
 141         array_push($sqlParameterArray, $username);
 142     }
 143     if ($status)
 144     $sql .= " AND message_status IN ('".str_replace(",", "','", add_escape_custom($status) )."')";
 145     $sql .= " ORDER BY date DESC";
 146     if($limit != "all")
 147     $sql .= " LIMIT ".escape_limit($start).", ".escape_limit($limit);
 148
 149     $res = sqlStatement($sql, $sqlParameterArray);
 150
 151     $all=array();
 152     for ($iter = 0;$row = sqlFetchArray($res);$iter++)
 153     $all[$iter] = $row;
 154     return $all;
 155 }
 156
 157 // activity can only be 0, 1, or 'all'
 158 function getSentPnotesByDate(
 159     $date,
 160     $activity = "1",
 161     $cols = "*",
 162     $pid = "%",
 163     $limit = "all",
 164     $start = 0,
 165     $username = '',
 166     $docid = 0,
 167     $status = "",
 168     $orderid = 0
 169 ) {
 170
 171     $sqlParameterArray = array();
 172     if ($docid) {
 173         $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
 174         "WHERE p.date LIKE ? AND r.type1 = 1 AND " .
 175         "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid = p.user";
 176         array_push($sqlParameterArray, '%'.$date.'%', $docid);
 177     }
 178     else if ($orderid) {
 179         $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
 180         "WHERE p.date LIKE ? AND r.type1 = 2 AND " .
 181         "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid = p.user";
 182         array_push($sqlParameterArray, '%'.$date.'%', $orderid);
 183     }
 184     else {
 185         $sql = "SELECT $cols FROM pnotes AS p " .
 186         "WHERE date LIKE ? AND pid LIKE ? AND p.pid = p.user";
 187         array_push($sqlParameterArray, '%'.$date.'%', $pid);
 188     }
 189     $sql .= " AND deleted != 1"; // exclude ALL deleted notes
 190     if ($activity != "all") {
 191         if ($activity == '0') {
 192             // only return inactive
 193             $sql .= " AND (activity = '0' OR message_status = 'Done') ";
 194         }
 195         else { // $activity == '1'
 196             // only return active
 197             $sql .= " AND activity = '1' AND message_status != 'Done' ";
 198         }
 199     }
 200     if ($username) {
 201         $sql .= " AND assigned_to LIKE ?";
 202         array_push($sqlParameterArray, $username);
 203     }
 204     if ($status)
 205     $sql .= " AND message_status IN ('".str_replace(",", "','", add_escape_custom($status) )."')";
 206     $sql .= " ORDER BY date DESC";
 207     if($limit != "all")
 208     $sql .= " LIMIT ".escape_limit($start).", ".escape_limit($limit);
 209
 210     $res = sqlStatement($sql, $sqlParameterArray);
 211
 212     $all=array();
 213     for ($iter = 0;$row = sqlFetchArray($res);$iter++)
 214     $all[$iter] = $row;
 215     return $all;
 216 }
 217
 218 function getPatientNotes($pid = '', $limit = '', $offset = 0, $search = '')
 219 {
 220     if($limit){
 221         $limit = "LIMIT ".escape_limit($offset).", ".escape_limit($limit);
 222     }
 223     $sql = "
 224     SELECT
 225       p.id,
 226       p.date,
 227       p.user,
 228       p.title,
 229       REPLACE(
 230         p.body,
 231         '-patient-',
 232         CONCAT(pd.fname, ' ', pd.lname)
 233       ) AS body,
 234       p.message_status,
 235       'Message' as `type`
 236     FROM
 237       pnotes AS p
 238       LEFT JOIN patient_data AS pd
 239         ON pd.id = p.pid
 240     WHERE assigned_to = '-patient-'
 241       AND p.deleted != 1
 242       AND p.pid = ?
 243       $search
 244     ORDER BY `date` desc
 245     $limit
 246   ";
 247     $res = sqlStatement($sql, array($pid));
 248     for($iter = 0;$row = sqlFetchArray($res);$iter++){
 249         $all[$iter] = $row;
 250     }
 251     return $all;
 252 }
 253
 254 function getPatientNotifications($pid = '', $limit = '', $offset = 0, $search = '')
 255 {
 256     if($limit){
 257         $limit = "LIMIT ".escape_limit($offset).", ".escape_limit($limit);
 258     }
 259     $sql = "
 260     SELECT
 261       pr.id,
 262       date_created AS `date`,
 263       'Patient Reminders' AS `user`,
 264       due_status AS title,
 265       CONCAT(lo.title, ':', lo2.title) AS body,
 266       '' as message_status,
 267       'Notification' as `type`
 268     FROM
 269       patient_reminders AS pr
 270       LEFT JOIN list_options AS lo
 271         ON lo.option_id = pr.category
 272         AND lo.list_id = 'rule_action_category' AND lo.activity = 1
 273       LEFT JOIN list_options AS lo2
 274         ON lo2.option_id = pr.item
 275         AND lo2.list_id = 'rule_action' AND lo2.activity = 1
 276     WHERE pid = ?
 277       AND active = 1
 278       AND date_created > DATE_SUB(NOW(), INTERVAL 1 MONTH)
 279       $search
 280     ORDER BY `date` desc
 281     $limit
 282   ";
 283     $res = sqlStatement($sql, array($pid));
 284     for($iter = 0;$row = sqlFetchArray($res);$iter++){
 285         $all[$iter] = $row;
 286     }
 287     return $all;
 288 }
 289
 290 function getPatientSentNotes($pid = '', $limit = '', $offset = 0, $search = '')
 291 {
 292     if($limit){
 293         $limit = "LIMIT ".escape_limit($offset).", ".escape_limit($limit);
 294     }
 295     $sql = "
 296     SELECT
 297       p.id,
 298       p.date,
 299       p.assigned_to,
 300       p.title,
 301       REPLACE(
 302         p.body,
 303         '-patient-',
 304         CONCAT(pd.lname, ' ', pd.fname)
 305       ) AS body,
 306       p.activity,
 307       p.message_status,
 308       'Message' as `type`
 309     FROM
 310       pnotes AS p
 311       LEFT JOIN patient_data AS pd
 312         ON pd.id = p.pid
 313     WHERE `user` = ?
 314       AND p.deleted != 1
 315       AND p.pid = ?
 316       AND p.message_status != 'Done'
 317       $search
 318     ORDER BY `date` desc
 319     $limit
 320   ";
 321     $res = sqlStatement($sql, array($pid,$pid));
 322     for($iter = 0;$row = sqlFetchArray($res);$iter++){
 323         $all[$iter] = $row;
 324     }
 325     return $all;
 326 }
 327
 328 // activity can be 0, 1, or 'all'
 329 function getPnotesByPid($pid, $activity = "1", $cols = "*", $limit=10, $start=0)
 330 {
 331     if ($activity == '1') {
 332         // return only active
 333         $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 334           "AND activity = '1' ".
 335           " AND message_status != 'Done' ".
 336           " AND deleted != 1 ".
 337           " ORDER BY date DESC LIMIT ".escape_limit($start).",".escape_limit($limit), array($pid) );
 338     }
 339     else if ($activity == '0') {
 340         // return only inactive
 341         $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 342           "AND (activity = '0' ".
 343           " OR message_status = 'Done') ".
 344           " AND deleted != 1 ".
 345           " ORDER BY date DESC LIMIT ".escape_limit($start).",".escape_limit($limit), array($pid) );
 346     }
 347     else { // $activity == "all"
 348         // return both active and inactive
 349         $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 350           " AND deleted != 1 ".
 351           " ORDER BY date DESC LIMIT ".escape_limit($start).",".escape_limit($limit), array($pid) );
 352     }
 353     for ($iter = 0; $row = sqlFetchArray($res); $iter++)
 354     $all[$iter] = $row;
 355     return $all;
 356 }
 357
 358 /** Add a note to a patient's medical record.
 359  *
 360  * @param int $pid the ID of the patient whos medical record this note is going to be attached to.
 361  * @param string $newtext the note contents.
 362  * @param int $authorized
 363  * @param int $activity
 364  * @param string $title
 365  * @param string $assigned_to
 366  * @param string $datetime
 367  * @param string $message_status
 368  * @param string $background_user if set then the pnote is created by a background-service rather than a user
 369  * @return int the ID of the added note.
 370  */
 371 function addPnote(
 372     $pid,
 373     $newtext,
 374     $authorized = '0',
 375     $activity = '1',
 376     $title= 'Unassigned',
 377     $assigned_to = '',
 378     $datetime = '',
 379     $message_status = 'New',
 380     $background_user=""
 381 ) {
 382
 383     if (empty($datetime)) $datetime = date('Y-m-d H:i:s');
 384
 385   // make inactive if set as Done
 386     if ($message_status == 'Done') $activity = 0;
 387
 388     $user = ($background_user!="" ? $background_user : $_SESSION['authUser']);
 389     $body = date('Y-m-d H:i') . ' (' . $user;
 390     if ($assigned_to) $body .= " to $assigned_to";
 391     $body = $body . ') ' . $newtext;
 392
 393     return sqlInsert('INSERT INTO pnotes (date, body, pid, user, groupname, ' .
 394     'authorized, activity, title, assigned_to, message_status) VALUES ' .
 395     '(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
 396     array($datetime, $body, $pid, $user, $_SESSION['authProvider'], $authorized, $activity, $title, $assigned_to, $message_status) );
 397 }
 398
 399 function addMailboxPnote(
 400     $pid,
 401     $newtext,
 402     $authorized = '0',
 403     $activity = '1',
 404     $title='Unassigned',
 405     $assigned_to = '',
 406     $datetime = '',
 407     $message_status = "New"
 408 ) {
 409
 410     if (empty($datetime)) $datetime = date('Y-m-d H:i:s');
 411
 412   // make inactive if set as Done
 413     if ($message_status == "Done") $activity = 0;
 414
 415     $body = date('Y-m-d H:i') . ' (' . $pid;
 416     if ($assigned_to) $body .= " to $assigned_to";
 417     $body = $body . ') ' . $newtext;
 418
 419     return sqlInsert("INSERT INTO pnotes (date, body, pid, user, groupname, " .
 420     "authorized, activity, title, assigned_to, message_status) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
 421     array($datetime, $body, $pid, $pid, 'Default', $authorized, $activity, $title, $assigned_to, $message_status) );
 422 }
 423
 424 function updatePnote($id, $newtext, $title, $assigned_to, $message_status = "")
 425 {
 426     $row = getPnoteById($id);
 427     if (! $row) die("updatePnote() did not find id '".text($id)."'");
 428     $activity = $assigned_to ? '1' : '0';
 429
 430   // make inactive if set as Done
 431     if ($message_status == "Done") $activity = 0;
 432
 433     $body = $row['body'] . "\n" . date('Y-m-d H:i') .
 434     ' (' . $_SESSION['authUser'];
 435     if ($assigned_to) $body .= " to $assigned_to";
 436     $body = $body . ') ' . $newtext;
 437
 438     if ($message_status) {
 439         sqlStatement("UPDATE pnotes SET " .
 440         "body = ?, activity = ?, title= ?, " .
 441         "assigned_to = ?, message_status = ? WHERE id = ?",
 442         array($body, $activity, $title, $assigned_to, $message_status, $id) );
 443     }
 444     else {
 445         sqlStatement("UPDATE pnotes SET " .
 446         "body = ?, activity = ?, title= ?, " .
 447         "assigned_to = ? WHERE id = ?",
 448         array($body, $activity, $title, $assigned_to, $id) );
 449     }
 450 }
 451
 452 function updatePnoteMessageStatus($id, $message_status)
 453 {
 454     if ($message_status == "Done") {
 455         sqlStatement("update pnotes set message_status = ?, activity = '0' where id = ?", array($message_status, $id) );
 456     }
 457     else {
 458         sqlStatement("update pnotes set message_status = ?, activity = '1' where id = ?", array($message_status, $id) );
 459     }
 460 }
 461
 462 /**
 463  * Set the patient id in an existing message where pid=0
 464  * @param $id the id of the existing note
 465  * @param $patient_id the patient id to associate with the note
 466  * @author EMR Direct <http://www.emrdirect.com/>
 467  */
 468 function updatePnotePatient($id, $patient_id)
 469 {
 470     $row = getPnoteById($id);
 471     if (! $row) die("updatePnotePatient() did not find id '".text($id)."'");
 472     $activity = $assigned_to ? '1' : '0';
 473
 474     $pid = $row['pid'];
 475     if($pid != 0 || (int)$patient_id < 1) die("updatePnotePatient invalid operation");
 476
 477     $pid = (int) $patient_id;
 478     $newtext = "\n" . date('Y-m-d H:i') . " (patient set by " . $_SESSION['authUser'] .")";
 479     $body = $row['body'] . $newtext;
 480
 481     sqlStatement("UPDATE pnotes SET pid = ?, body = ? WHERE id = ?", array($pid, $body, $id) );
 482 }
 483
 484 function authorizePnote($id, $authorized = "1")
 485 {
 486     sqlQuery("UPDATE pnotes SET authorized = ? WHERE id = ?", array ($authorized,$id) );
 487 }
 488
 489 function disappearPnote($id)
 490 {
 491     sqlStatement("UPDATE pnotes SET activity = '0', message_status = 'Done' WHERE id=?", array($id) );
 492     return true;
 493 }
 494
 495 function reappearPnote($id)
 496 {
 497     sqlStatement("UPDATE pnotes SET activity = '1', message_status = IF(message_status='Done','New',message_status) WHERE id=?", array($id) );
 498     return true;
 499 }
 500
 501 function deletePnote($id)
 502 {
 503     sqlStatement("UPDATE pnotes SET deleted = '1' WHERE id=?", array($id) );
 504     return true;
 505 }
 506 ?>