library/pnotes.inc

   1 <?php
   2 // This program is free software; you can redistribute it and/or
   3 // modify it under the terms of the GNU General Public License
   4 // as published by the Free Software Foundation; either version 2
   5 // of the License, or (at your option) any later version.
   6
   7 require_once("{$GLOBALS['srcdir']}/sql.inc");
   8
   9 // 06-2009, BM migrated the patient_note_types array to the list_options table
  10
  11 function getPnoteById($id, $cols = "*")
  12 {
  13   return sqlQuery("SELECT $cols FROM pnotes WHERE id=? " .
  14     " AND deleted != 1 ". // exclude ALL deleted notes
  15     "order by date DESC limit 0,1", array($id) );
  16 }
  17
  18
  19 // activity can be 0, 1, or 'all'
  20 function getPnotesByUser($activity="1",$show_all="no",$user='',$count=false,$sortby='',$sortorder='',$begin='',$listnumber='')
  21 {
  22
  23   // Set the activity part of query
  24   if ($activity=='1') {
  25     $activity_query = " pnotes.message_status != 'Done' AND pnotes.activity = 1 AND ";
  26   }
  27   else if ($activity=='0') {
  28     $activity_query = " (pnotes.message_status = 'Done' OR pnotes.activity = 0) AND ";
  29   }
  30   else { //$activity=='all'
  31     $activity_query = " ";
  32   }
  33
  34   // Set whether to show chosen user or all users
  35   if ($show_all == 'yes' ) {
  36     $usrvar='_%';
  37   } else {
  38     $usrvar=$user;
  39   }
  40
  41   // run the query
  42   $sql = "SELECT pnotes.id, pnotes.user, pnotes.pid, pnotes.title, pnotes.date, pnotes.message_status,
  43           IF(pnotes.user != pnotes.pid,users.fname,patient_data.fname) as users_fname,
  44           IF(pnotes.user != pnotes.pid,users.lname,patient_data.lname) as users_lname,
  45           patient_data.fname as patient_data_fname, patient_data.lname as patient_data_lname
  46           FROM ((pnotes LEFT JOIN users ON pnotes.user = users.username)
  47           JOIN patient_data ON pnotes.pid = patient_data.pid) WHERE $activity_query
  48           pnotes.deleted != '1' AND pnotes.assigned_to LIKE ?";
  49   if (!empty($sortby) || !empty($sortorder)  || !empty($begin) || !empty($listnumber)) {
  50     $sql .= " order by ".add_escape_custom($sortby)." ".add_escape_custom($sortorder).
  51            " limit ".add_escape_custom($begin).", ".add_escape_custom($listnumber);
  52   }
  53   $result = sqlStatement($sql, array($usrvar));
  54
  55   // return the results
  56   if ($count) {
  57     if(sqlNumRows($result) != 0) {
  58         $total = sqlNumRows($result);
  59     }
  60     else {
  61         $total = 0;
  62     }
  63     return $total;
  64   }
  65   else {
  66     return $result;
  67   }
  68 }
  69
  70
  71 function getPnotesByDate($date, $activity = "1", $cols = "*", $pid = "%",
  72   $limit = "all", $start = 0, $username = '', $docid = 0, $status = "")
  73 {
  74 $sqlParameterArray = array();
  75   if ($docid) {
  76     $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
  77     "WHERE p.date LIKE ? AND r.type1 = 1 AND " .
  78     "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid != p.user";
  79     array_push($sqlParameterArray, '%'.$date.'%', $docid);
  80   }
  81   else {
  82     $sql = "SELECT $cols FROM pnotes AS p " .
  83       "WHERE date LIKE ? AND pid LIKE ? AND p.pid != p.user";
  84     array_push($sqlParameterArray, '%'.$date.'%', $pid);
  85   }
  86   $sql .= " AND deleted != 1"; // exclude ALL deleted notes
  87   if ($activity != "all") {
  88     if ($activity == '0') {
  89       // only return inactive
  90       $sql .= " AND (activity = '0' OR message_status = 'Done') ";
  91     }
  92     else { // $activity == '1'
  93       // only return active
  94       $sql .= " AND activity = '1' AND message_status != 'Done' ";
  95     }
  96   }
  97   if ($username) {
  98     $sql .= " AND assigned_to LIKE ?";
  99     array_push($sqlParameterArray, $username);
 100   }
 101   if ($status)
 102     $sql .= " AND message_status IN ('".str_replace(",", "','", $status)."')";
 103   $sql .= " ORDER BY date DESC";
 104   if($limit != "all")
 105     $sql .= " LIMIT $start, $limit";
 106
 107   $res = sqlStatement($sql, $sqlParameterArray);
 108
 109   $all=array();
 110   for ($iter = 0;$row = sqlFetchArray($res);$iter++)
 111     $all[$iter] = $row;
 112   return $all;
 113 }
 114
 115 // activity can only be 0, 1, or 'all
 116 function getSentPnotesByDate($date, $activity = "1", $cols = "*", $pid = "%",
 117   $limit = "all", $start = 0, $username = '', $docid = 0, $status = "")
 118 {
 119 $sqlParameterArray = array();
 120   if ($docid) {
 121     $sql = "SELECT $cols FROM pnotes AS p, gprelations AS r " .
 122     "WHERE p.date LIKE ? AND r.type1 = 1 AND " .
 123     "r.id1 = ? AND r.type2 = 6 AND p.id = r.id2 AND p.pid = p.user";
 124     array_push($sqlParameterArray, '%'.$date.'%', $docid);
 125   }
 126   else {
 127     $sql = "SELECT $cols FROM pnotes AS p " .
 128       "WHERE date LIKE ? AND pid LIKE ? AND p.pid = p.user";
 129     array_push($sqlParameterArray, '%'.$date.'%', $pid);
 130   }
 131   $sql .= " AND deleted != 1"; // exclude ALL deleted notes
 132   if ($activity != "all") {
 133     if ($activity == '0') {
 134       // only return inactive
 135       $sql .= " AND (activity = '0' OR message_status = 'Done') ";
 136     }
 137     else { // $activity == '1'
 138       // only return active
 139       $sql .= " AND activity = '1' AND message_status != 'Done' ";
 140     }
 141   }
 142   if ($username) {
 143     $sql .= " AND assigned_to LIKE ?";
 144     array_push($sqlParameterArray, $username);
 145   }
 146   if ($status)
 147     $sql .= " AND message_status IN ('".str_replace(",", "','", $status)."')";
 148   $sql .= " ORDER BY date DESC";
 149   if($limit != "all")
 150     $sql .= " LIMIT $start, $limit";
 151
 152   $res = sqlStatement($sql, $sqlParameterArray);
 153
 154   $all=array();
 155   for ($iter = 0;$row = sqlFetchArray($res);$iter++)
 156     $all[$iter] = $row;
 157   return $all;
 158 }
 159
 160 function getPatientNotes($pid = '', $limit = '', $offset = 0, $search = '')
 161 {
 162   if($limit){
 163     $limit = "LIMIT $offset, $limit";
 164   }
 165   $sql = "
 166     SELECT
 167       p.id,
 168       p.date,
 169       p.user,
 170       p.title,
 171       REPLACE(
 172         p.body,
 173         '-patient-',
 174         CONCAT(pd.fname, ' ', pd.lname)
 175       ) AS body,
 176       p.message_status,
 177       'Message' as `type`
 178     FROM
 179       pnotes AS p
 180       LEFT JOIN patient_data AS pd
 181         ON pd.id = p.pid
 182     WHERE assigned_to = '-patient-'
 183       AND p.deleted != 1
 184       AND p.pid = ?
 185       $search
 186     ORDER BY `date` desc
 187     $limit
 188   ";
 189   $res = sqlStatement($sql, array($pid));
 190   for($iter = 0;$row = sqlFetchArray($res);$iter++){
 191     $all[$iter] = $row;
 192   }
 193   return $all;
 194 }
 195
 196 function getPatientNotifications($pid = '', $limit = '', $offset = 0, $search = '')
 197 {
 198   if($limit){
 199     $limit = "LIMIT $offset, $limit";
 200   }
 201   $sql = "
 202     SELECT
 203       pr.id,
 204       date_created AS `date`,
 205       'Patient Reminders' AS `user`,
 206       due_status AS title,
 207       CONCAT(lo.title, ':', lo2.title) AS body,
 208       '' as message_status,
 209       'Notification' as `type`
 210     FROM
 211       patient_reminders AS pr
 212       LEFT JOIN list_options AS lo
 213         ON lo.option_id = pr.category
 214         AND lo.list_id = 'rule_action_category'
 215       LEFT JOIN list_options AS lo2
 216         ON lo2.option_id = pr.item
 217         AND lo2.list_id = 'rule_action'
 218     WHERE pid = ?
 219       AND active = 1
 220       AND date_created > DATE_SUB(NOW(), INTERVAL 1 MONTH)
 221       $search
 222     ORDER BY `date` desc
 223     $limit
 224   ";
 225   $res = sqlStatement($sql, array($pid));
 226   for($iter = 0;$row = sqlFetchArray($res);$iter++){
 227     $all[$iter] = $row;
 228   }
 229   return $all;
 230 }
 231
 232 function getPatientSentNotes($pid = '', $limit = '', $offset = 0, $search = '')
 233 {
 234   if($limit){
 235     $limit = "LIMIT $offset, $limit";
 236   }
 237   $sql = "
 238     SELECT
 239       p.id,
 240       p.date,
 241       p.assigned_to,
 242       p.title,
 243       REPLACE(
 244         p.body,
 245         '-patient-',
 246         CONCAT(pd.lname, ' ', pd.fname)
 247       ) AS body,
 248       p.activity,
 249       p.message_status,
 250       'Message' as `type`
 251     FROM
 252       pnotes AS p
 253       LEFT JOIN patient_data AS pd
 254         ON pd.id = p.pid
 255     WHERE `user` = ?
 256       AND p.deleted != 1
 257       AND p.pid = ?
 258       AND p.message_status != 'Done'
 259       $search
 260     ORDER BY `date` desc
 261     $limit
 262   ";
 263   $res = sqlStatement($sql, array($pid,$pid));
 264   for($iter = 0;$row = sqlFetchArray($res);$iter++){
 265     $all[$iter] = $row;
 266   }
 267   return $all;
 268 }
 269
 270 // activity can be 0, 1, or 'all'
 271 function getPnotesByPid ($pid, $activity = "1", $cols = "*", $limit=10, $start=0)
 272 {
 273  if ($activity == '1') {
 274   // return only active
 275   $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 276     "AND activity = '1' ".
 277     " AND message_status != 'Done' ".
 278     " AND deleted != 1 ".
 279     " ORDER BY date DESC LIMIT $start,$limit", array($pid) );
 280  }
 281  else if ($activity == '0') {
 282   // return only inactive
 283   $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 284     "AND (activity = '0' ".
 285     " OR message_status = 'Done') ".
 286     " AND deleted != 1 ".
 287     " ORDER BY date DESC LIMIT $start,$limit", array($pid) );
 288  }
 289  else { // $activity == "all"
 290   // return both active and inactive
 291   $res = sqlStatement("SELECT $cols FROM pnotes WHERE pid LIKE ? " .
 292     " AND deleted != 1 ".
 293     " ORDER BY date DESC LIMIT $start,$limit", array($pid) );
 294  }
 295   for ($iter = 0; $row = sqlFetchArray($res); $iter++)
 296     $all[$iter] = $row;
 297   return $all;
 298 }
 299
 300 function addPnote($pid, $newtext, $authorized = '0', $activity = '1',
 301   $title='Unassigned', $assigned_to = '', $datetime = '', $message_status = "New")
 302 {
 303   if (empty($datetime)) $datetime = date('Y-m-d H:i:s');
 304
 305   // make inactive if set as Done
 306   if ($message_status == "Done") $activity = 0;
 307
 308   $body = date('Y-m-d H:i') . ' (' . $_SESSION['authUser'];
 309   if ($assigned_to) $body .= " to $assigned_to";
 310   $body = $body . ') ' . $newtext;
 311
 312   return sqlInsert("INSERT INTO pnotes (date, body, pid, user, groupname, " .
 313     "authorized, activity, title, assigned_to, message_status) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
 314     array($datetime, $body, $pid, $_SESSION['authUser'], $_SESSION['authProvider'], $authorized, $activity, $title, $assigned_to, $message_status) );
 315 }
 316
 317 function addMailboxPnote($pid, $newtext, $authorized = '0', $activity = '1',
 318   $title='Unassigned', $assigned_to = '', $datetime = '', $message_status = "New")
 319 {
 320   if (empty($datetime)) $datetime = date('Y-m-d H:i:s');
 321
 322   // make inactive if set as Done
 323   if ($message_status == "Done") $activity = 0;
 324
 325   $body = date('Y-m-d H:i') . ' (' . $pid;
 326   if ($assigned_to) $body .= " to $assigned_to";
 327   $body = $body . ') ' . $newtext;
 328
 329   return sqlInsert("INSERT INTO pnotes (date, body, pid, user, groupname, " .
 330     "authorized, activity, title, assigned_to, message_status) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
 331     array($datetime, $body, $pid, $pid, 'Default', $authorized, $activity, $title, $assigned_to, $message_status) );
 332 }
 333
 334 function updatePnote($id, $newtext, $title, $assigned_to, $message_status = "")
 335 {
 336   $row = getPnoteById($id);
 337   if (! $row) die("updatePnote() did not find id '$id'");
 338   $activity = $assigned_to ? '1' : '0';
 339
 340   // make inactive if set as Done
 341   if ($message_status == "Done") $activity = 0;
 342
 343   $body = $row['body'] . "\n" . date('Y-m-d H:i') .
 344     ' (' . $_SESSION['authUser'];
 345   if ($assigned_to) $body .= " to $assigned_to";
 346   $body = $body . ') ' . $newtext;
 347
 348   if ($message_status) {
 349     sqlStatement("UPDATE pnotes SET " .
 350       "body = ?, activity = ?, title= ?, " .
 351       "assigned_to = ?, message_status = ? WHERE id = ?",
 352       array($body, $activity, $title, $assigned_to, $message_status, $id) );
 353   }
 354   else {
 355     sqlStatement("UPDATE pnotes SET " .
 356       "body = ?, activity = ?, title= ?, " .
 357       "assigned_to = ? WHERE id = ?",
 358       array($body, $activity, $title, $assigned_to, $id) );
 359   }
 360 }
 361
 362 function updatePnoteMessageStatus($id, $message_status)
 363 {
 364   if ($message_status == "Done") {
 365     sqlStatement("update pnotes set message_status = ?, activity = '0' where id = ?", array($message_status, $id) );
 366   }
 367   else {
 368     sqlStatement("update pnotes set message_status = ?, activity = '1' where id = ?", array($message_status, $id) );
 369   }
 370 }
 371
 372 function authorizePnote($id, $authorized = "1")
 373 {
 374   sqlQuery("UPDATE pnotes SET authorized = ? WHERE id = ?", array ($authorized,$id) );
 375 }
 376
 377 function disappearPnote($id)
 378 {
 379   sqlStatement("UPDATE pnotes SET activity = '0', message_status = 'Done' WHERE id=?", array($id) );
 380   return true;
 381 }
 382
 383 function reappearPnote ($id)
 384 {
 385   sqlStatement("UPDATE pnotes SET activity = '1', message_status = IF(message_status='Done','New',message_status) WHERE id=?", array($id) );
 386   return true;
 387 }
 388
 389 function deletePnote($id)
 390 {
 391   sqlStatement("UPDATE pnotes SET deleted = '1' WHERE id=?", array($id) );
 392   return true;
 393 }
 394 ?>