LocationService.php

<?php

/**
 * LocationService
 *
 * @package   OpenEMR
 * @link      http://www.open-emr.org
 * @author    Yash Bothra <yashrajbothra786gmail.com>
 * @copyright Copyright (c) 2020 Yash Bothra <yashrajbothra786gmail.com>
 * @license   https://github.com/openemr/openemr/blob/master/LICENSE GNU General Public License 3
 */

namespace OpenEMR\Services;

use OpenEMR\Common\Database\QueryUtils;
use OpenEMR\Common\Uuid\UuidRegistry;
use OpenEMR\Common\Uuid\UuidMapping;
use OpenEMR\Services\Search\FhirSearchWhereClauseBuilder;
use OpenEMR\Validators\BaseValidator;
use OpenEMR\Validators\ProcessingResult;

class LocationService extends BaseService
{
    private const PATIENT_TABLE = "patient_data";
    private const PRACTITIONER_TABLE = "users";
    private const FACILITY_TABLE = "facility";

    const TYPE_FACILITY = "facility";
    const TYPE_USER = "user";
    const TYPE_PATIENT = "patient";

    /**
     * Default constructor.
     */
    public function __construct()
    {
        UuidRegistry::createMissingUuidsForTables([self::PATIENT_TABLE, self::PRACTITIONER_TABLE, self::FACILITY_TABLE]);
        UuidMapping::createMissingResourceUuids("Location", self::PATIENT_TABLE);
        UuidMapping::createMissingResourceUuids("Location", self::PRACTITIONER_TABLE);
        UuidMapping::createMissingResourceUuids("Location", self::FACILITY_TABLE);
    }

    public function getUuidFields(): array
    {
        return ['uuid'];
    }

    /**
     * Returns a list of locations matching optional search criteria.
     * Search criteria is conveyed by array where key = field/column name, value = field value.
     * If no search criteria is provided, all records are returned.
     *
     * @param  $search search array parameters
     * @param  $isAndCondition specifies if AND condition is used for multiple criteria. Defaults to true.
     * @return ProcessingResult which contains validation messages, internal error messages, and the data
     * payload.
     */
    public function getAll($search = array(), $isAndCondition = true)
    {
        $sqlBindArray = array();

        $sql = 'SELECT location.*, uuid_mapping.uuid FROM
                (SELECT
                    uuid as table_uuid,
                    "Home Address" as name,
                    street,
                    city,
                    postal_code,
                    state,
                    country_code,
                    phone_cell as phone,
                    null as fax,
                    null as website,
                    email,
                    "' . self::TYPE_PATIENT . '" AS `type`
                from 
                    patient_data
                UNION SELECT
                    uuid as table_uuid,
                    name,
                    street,
                    city,
                    postal_code,
                    state,
                    country_code,
                    phone,
                    fax,
                    website,
                    email,
                   "' . self::TYPE_FACILITY . '" AS `type`
                from 
                     facility
                UNION SELECT
                    uuid as table_uuid,
                    "Home Address" as name,
                    street,
                    city,
                    zip as postal_code,
                    state,
                    null as country_code,
                    phone,
                    fax,
                    url as website,
                    email,
                    "' . self::TYPE_USER . '" AS `type`
                from 
                     users
            ) as location
            LEFT JOIN uuid_mapping ON uuid_mapping.target_uuid=location.table_uuid AND uuid_mapping.resource="Location"';

        $whereClause = FhirSearchWhereClauseBuilder::build($search, $isAndCondition);

        $sql .= $whereClause->getFragment();

        $sqlBindArray = $whereClause->getBoundValues();
        $statementResults =  QueryUtils::sqlStatementThrowException($sql, $sqlBindArray);

        $processingResult = new ProcessingResult();
        foreach ($statementResults as $result) {
            $record = $this->createResultRecordFromDatabaseResult($result);
            $processingResult->addData($record);
        }

        return $processingResult;
    }

    /**
     * Returns a single location record by id.
     * @param $uuid - The location uuid identifier in string format.
     * @return ProcessingResult which contains validation messages, internal error messages, and the data
     * payload.
     */
    public function getOne($uuid)
    {
        $processingResult = new ProcessingResult();

        $isValid = BaseValidator::validateId(
            "uuid",
            "uuid_mapping",
            $uuid,
            true
        );

        if ($isValid !== true) {
            $validationMessages = [
                'uuid' => ["invalid or nonexisting value" => " value " . $uuid]
            ];
            $processingResult->setValidationMessages($validationMessages);
            return $processingResult;
        }

        $sql = 'SELECT location.*, uuid_mapping.uuid FROM
                (SELECT
                    uuid as target_uuid,
                    CONCAT(fname,"\'s Home") as name,
                    street,
                    city,
                    postal_code,
                    state,
                    country_code,
                    phone_cell as phone,
                    null as fax,
                    null as website,
                    email from patient_data
                UNION SELECT
                    uuid as target_uuid,
                    name,
                    street,
                    city,
                    postal_code,
                    state,
                    country_code,
                    phone,
                    fax,
                    website,
                    email from facility
                UNION SELECT
                    uuid as target_uuid,
                    CONCAT(fname,"\'s Home") as name,
                    street,
                    city,
                    zip as postal_code,
                    state,
                    null as country_code,
                    phone,
                    fax,
                    url as website,
                    email from users) as location
                    LEFT JOIN uuid_mapping ON uuid_mapping.target_uuid=location.target_uuid AND uuid_mapping.resource="Location"
                    WHERE uuid_mapping.uuid=?';

        $uuidBinary = UuidRegistry::uuidToBytes($uuid);
        $sqlResult = sqlQuery($sql, [$uuidBinary]);
        $sqlResult['uuid'] = UuidRegistry::uuidToString($sqlResult['uuid']);
        $processingResult->addData($sqlResult);
        return $processingResult;
    }
}