src/Services/ListService.php

   1 <?php
   2
   3 /**
   4  * ListService
   5  *
   6  * @package   OpenEMR
   7  * @link      http://www.open-emr.org
   8  * @author    Matthew Vita <matthewvita48@gmail.com>
   9  * @author    Brady Miller <brady.g.miller@gmail.com>
  10  * @copyright Copyright (c) 2018 Matthew Vita <matthewvita48@gmail.com>
  11  * @copyright Copyright (c) 2018 Brady Miller <brady.g.miller@gmail.com>
  12  * @license   https://github.com/openemr/openemr/blob/master/LICENSE GNU General Public License 3
  13  */
  14
  15 namespace OpenEMR\Services;
  16
  17 use OpenEMR\Common\Database\QueryUtils;
  18 use Particle\Validator\Validator;
  19 use OpenEMR\Common\Uuid\UuidRegistry;
  20
  21 // TODO: @adunsulag should we rename this to be ListOptions service since that is the table it corresponds to?  The lists table is a patient issues table so this could confuse new developers
  22 class ListService
  23 {
  24   /**
  25    * Default constructor.
  26    */
  27     public function __construct()
  28     {
  29     }
  30
  31     public function validate($list)
  32     {
  33         $validator = new Validator();
  34
  35         $validator->required('title')->lengthBetween(2, 255);
  36         $validator->required('type')->lengthBetween(2, 255);
  37         $validator->required('pid')->numeric();
  38         $validator->optional('diagnosis')->lengthBetween(2, 255);
  39         $validator->optional('begdate')->datetime('Y-m-d H:i:s');
  40         $validator->optional('enddate')->datetime('Y-m-d H:i:s');
  41
  42         return $validator->validate($list);
  43     }
  44
  45     public function getAll($pid, $list_type)
  46     {
  47         $sql = "SELECT * FROM lists WHERE pid=? AND type=? ORDER BY date DESC";
  48
  49         $statementResults = sqlStatement($sql, array($pid, $list_type));
  50
  51         $results = array();
  52         while ($row = sqlFetchArray($statementResults)) {
  53             $row['uuid'] = UuidRegistry::uuidToString($row['uuid']);
  54             array_push($results, $row);
  55         }
  56
  57         return $results;
  58     }
  59
  60     public function getListOptionsForLists($lists)
  61     {
  62         $sql = "SELECT * FROM list_options WHERE list_id IN (" . str_repeat('?,', count($lists) - 1) . "?) "
  63             . " ORDER BY list_id, seq";
  64         $records = QueryUtils::fetchRecords($sql, $lists, false);
  65         return $records;
  66     }
  67
  68     public function getListIds()
  69     {
  70         $sql = "SELECT DISTINCT list_id FROM list_options ORDER BY list_id";
  71         return QueryUtils::fetchTableColumn($sql, 'list_id', []);
  72     }
  73
  74     public function getOptionsByListName($list_name, $search = array())
  75     {
  76         $sql = "SELECT * FROM list_options WHERE list_id = ? ";
  77         $binding = [$list_name];
  78
  79
  80         $whitelisted_columns = [
  81             "option_id", "seq", "is_default", "option_value", "mapping", "notes", "codes", "activity", "edit_options", "toggle_setting_1", "toggle_setting_2", "subtype"
  82         ];
  83         foreach ($whitelisted_columns as $column) {
  84             if (!empty($search[$column])) {
  85                 $sql .= " AND $column = ? ";
  86                 $binding[] = $search[$column];
  87             }
  88         }
  89         $sql .= " ORDER BY `seq` ";
  90
  91         $statementResults = sqlStatementThrowException($sql, $binding);
  92
  93         $results = array();
  94         while ($row = sqlFetchArray($statementResults)) {
  95             array_push($results, $row);
  96         }
  97
  98         return $results;
  99     }
 100
 101     /**
 102      * Returns the list option record that was found
 103      * @param $list_id
 104      * @param $option_id
 105      * @param array $search
 106      * @return array Record
 107      */
 108     public function getListOption($list_id, $option_id)
 109     {
 110         $records = $this->getOptionsByListName($list_id, ['option_id' => $option_id]);
 111         if (!empty($records)) { // should only be one record
 112             return $records[0];
 113         }
 114         return null;
 115     }
 116
 117     public function getOne($pid, $list_type, $list_id)
 118     {
 119         $sql = "SELECT * FROM lists WHERE pid=? AND type=? AND id=? ORDER BY date DESC";
 120
 121         return sqlQuery($sql, array($pid, $list_type, $list_id));
 122     }
 123
 124     public function insert($data)
 125     {
 126         $sql  = " INSERT INTO lists SET";
 127         $sql .= "     date=NOW(),";
 128         $sql .= "     activity=1,";
 129         $sql .= "     pid=?,";
 130         $sql .= "     type=?,";
 131         $sql .= "     title=?,";
 132         $sql .= "     begdate=?,";
 133         $sql .= "     enddate=?,";
 134         $sql .= "     diagnosis=?";
 135
 136         return sqlInsert(
 137             $sql,
 138             array(
 139                 $data['pid'],
 140                 $data['type'],
 141                 $data["title"],
 142                 $data["begdate"],
 143                 $data["enddate"],
 144                 $data["diagnosis"]
 145             )
 146         );
 147     }
 148
 149     public function update($data)
 150     {
 151         $sql  = " UPDATE lists SET";
 152         $sql .= "     title=?,";
 153         $sql .= "     begdate=?,";
 154         $sql .= "     enddate=?,";
 155         $sql .= "     diagnosis=?";
 156         $sql .= " WHERE id=?";
 157
 158         return sqlStatement(
 159             $sql,
 160             array(
 161                 $data["title"],
 162                 $data["begdate"],
 163                 $data["enddate"],
 164                 $data["diagnosis"],
 165                 $data["id"]
 166             )
 167         );
 168     }
 169
 170     public function delete($pid, $list_id, $list_type)
 171     {
 172         $sql  = "DELETE FROM lists WHERE pid=? AND id=? AND type=?";
 173
 174         return sqlStatement($sql, array($pid, $list_id, $list_type));
 175     }
 176 }