PatientService.php

<?php
/**
 * Patient Service
 *
 * @package   OpenEMR
 * @link      http://www.open-emr.org
 * @author    Victor Kofia <victor.kofia@gmail.com>
 * @author    Brady Miller <brady.g.miller@gmail.com>
 * @copyright Copyright (c) 2017 Victor Kofia <victor.kofia@gmail.com>
 * @copyright Copyright (c) 2018 Brady Miller <brady.g.miller@gmail.com>
 * @license   https://github.com/openemr/openemr/blob/master/LICENSE GNU General Public License 3
 */


namespace OpenEMR\Services;

use Particle\Validator\Validator;
use OpenEMR\Common\Utils\UuidUtils;

class PatientService
{

    /**
     * In the case where a patient doesn't have a picture uploaded,
     * this value will be returned so that the document controller
     * can return an empty response.
     */
    private $patient_picture_fallback_id = -1;

    private $pid;

    /**
     * Default constructor.
     */
    public function __construct()
    {
    }

    public function validate($patient)
    {
        $validator = new Validator();

        $validator->required('fname')->lengthBetween(2, 255);
        $validator->required('lname')->lengthBetween(2, 255);
        $validator->required('sex')->lengthBetween(4, 30);
        $validator->required('dob')->datetime('Y-m-d');


        return $validator->validate($patient);
    }

    public function setPid($pid)
    {
        $this->pid = $pid;
    }

    public function getPid()
    {
        return $this->pid;
    }

    /**
     * TODO: This should go in the ChartTrackerService and doesn't have to be static.
     * @param $pid unique patient id
     * @return recordset
     */
    public static function getChartTrackerInformationActivity($pid)
    {
        $sql = "SELECT ct.ct_when,
                   ct.ct_userid,
                   ct.ct_location,
                   u.username,
                   u.fname,
                   u.mname,
                   u.lname
            FROM chart_tracker AS ct
            LEFT OUTER JOIN users AS u ON u.id = ct.ct_userid
            WHERE ct.ct_pid = ?
            ORDER BY ct.ct_when DESC";
        return sqlStatement($sql, array($pid));
    }

    /**
     * TODO: This should go in the ChartTrackerService and doesn't have to be static.
     * @return recordset
     */
    public static function getChartTrackerInformation()
    {
        $sql = "SELECT ct.ct_when,
                   u.username,
                   u.fname AS ufname,
                   u.mname AS umname,
                   u.lname AS ulname,
                   p.pubpid,
                   p.fname,
                   p.mname,
                   p.lname
            FROM chart_tracker AS ct
            JOIN cttemp ON cttemp.ct_pid = ct.ct_pid AND cttemp.ct_when = ct.ct_when
            LEFT OUTER JOIN users AS u ON u.id = ct.ct_userid
            LEFT OUTER JOIN patient_data AS p ON p.pid = ct.ct_pid
            WHERE ct.ct_userid != 0
            ORDER BY p.pubpid";
        return sqlStatement($sql);
    }

    public function getFreshPid()
    {
        $pid = sqlQuery("SELECT MAX(pid)+1 AS pid FROM patient_data");

        return $pid['pid'] === null ? 1 : $pid['pid'];
    }

    public function insert($data)
    {
        $fresh_pid = $this->getFreshPid();

        $uuid = UuidUtils::createUuid('patient_data');

        $sql = " INSERT INTO patient_data SET";
        $sql .= "     pid=?,";
        $sql .= "     title=?,";
        $sql .= "     fname=?,";
        $sql .= "     mname=?,";
        $sql .= "     lname=?,";
        $sql .= "     street=?,";
        $sql .= "     postal_code=?,";
        $sql .= "     city=?,";
        $sql .= "     state=?,";
        $sql .= "     country_code=?,";
        $sql .= "     phone_contact=?,";
        $sql .= "     dob=?,";
        $sql .= "     sex=?,";
        $sql .= "     race=?,";
        $sql .= "     ethnicity=?";
        $sql .= "     uuid=?";

        $results = sqlInsert(
            $sql,
            array(
                $fresh_pid,
                $data["title"],
                $data["fname"],
                $data["mname"],
                $data["lname"],
                $data["street"],
                $data["postal_code"],
                $data["city"],
                $data["state"],
                $data["country_code"],
                $data["phone_contact"],
                $data["dob"],
                $data["sex"],
                $data["race"],
                $data["ethnicity"],
                $uuid
            )
        );

        if ($results) {
            return $fresh_pid;
        }

        return $results;
    }

    public function update($pid, $data)
    {
        $sql = " UPDATE patient_data SET";
        $sql .= "     title=?,";
        $sql .= "     fname=?,";
        $sql .= "     mname=?,";
        $sql .= "     lname=?,";
        $sql .= "     street=?,";
        $sql .= "     postal_code=?,";
        $sql .= "     city=?,";
        $sql .= "     state=?,";
        $sql .= "     country_code=?,";
        $sql .= "     phone_contact=?,";
        $sql .= "     dob=?,";
        $sql .= "     sex=?,";
        $sql .= "     race=?,";
        $sql .= "     ethnicity=?";
        $sql .= "     where pid=?";

        return sqlStatement(
            $sql,
            array(
                $data["title"],
                $data["fname"],
                $data["mname"],
                $data["lname"],
                $data["street"],
                $data["postal_code"],
                $data["city"],
                $data["state"],
                $data["country_code"],
                $data["phone_contact"],
                $data["dob"],
                $data["sex"],
                $data["race"],
                $data["ethnicity"],
                $pid
            )
        );
    }

    public function getAll($search)
    {
        $sqlBindArray = array();

        $sql = "SELECT id,
                   pid,
                   pubpid,
                   title, 
                   fname,
                   mname,
                   lname,
                   street, 
                   postal_code, 
                   city, 
                   state, 
                   country_code, 
                   phone_contact,
                   email
                   dob,
                   sex,
                   race,
                   ethnicity
                FROM patient_data";

        if ($search['name'] || $search['fname'] || $search['lname'] || $search['dob']) {
            $sql .= " WHERE ";

            $whereClauses = array();
            if ($search['name']) {
                $search['name'] = '%' . $search['name'] . '%';
                array_push($whereClauses, "CONCAT(lname,' ', fname) LIKE ?");
                array_push($sqlBindArray, $search['name']);
            }
            if ($search['fname']) {
                array_push($whereClauses, "fname=?");
                array_push($sqlBindArray, $search['fname']);
            }
            if ($search['lname']) {
                array_push($whereClauses, "lname=?");
                array_push($sqlBindArray, $search['lname']);
            }
            if ($search['dob'] || $search['birthdate']) {
                $search['dob'] = !empty($search['dob']) ? $search['dob'] : $search['birthdate'];
                array_push($whereClauses, "dob=?");
                array_push($sqlBindArray, $search['dob']);
            }

            $sql .= implode(" AND ", $whereClauses);
        }

        $statementResults = sqlStatement($sql, $sqlBindArray);

        $results = array();
        while ($row = sqlFetchArray($statementResults)) {
            array_push($results, $row);
        }

        return $results;
    }

    public function getOne()
    {
        $sql = "SELECT id,
                   pid,
                   pubpid,
                   title, 
                   fname,
                   mname,
                   lname,
                   street, 
                   postal_code, 
                   city, 
                   state, 
                   country_code, 
                   phone_contact,
                   email
                   dob,
                   sex,
                   race,
                   ethnicity
                FROM patient_data
                WHERE pid = ?";

        return sqlQuery($sql, $this->pid);
    }

    /**
     * @return number
     */
    public function getPatientPictureDocumentId()
    {
        $sql = "SELECT doc.id AS id
                 FROM documents doc
                 JOIN categories_to_documents cate_to_doc
                   ON doc.id = cate_to_doc.document_id
                 JOIN categories cate
                   ON cate.id = cate_to_doc.category_id
                WHERE cate.name LIKE ? and doc.foreign_id = ?";

        $result = sqlQuery($sql, array($GLOBALS['patient_photo_category_name'], $this->pid));

        if (empty($result) || empty($result['id'])) {
            return $this->patient_picture_fallback_id;
        }

        return $result['id'];
    }
}