class.ilBookingPreferencesDBRepository.php

Go to the documentation of this file.

<?php

class ilBookingPreferencesDBRepository
{
    protected ilDBInterface $db;
    protected ILIAS\BookingManager\InternalDataService $data;

    public function __construct(
        ILIAS\BookingManager\InternalDataService $data,
        ilDBInterface $db = null
    ) {
        global $DIC;

        $this->db = ($db)
            ?: $DIC->database();
        $this->data = $data;
    }

    public function getPreferences(int $a_pool_id): ilBookingPreferences
    {
        $db = $this->db;

        $set = $db->queryF(
            "SELECT * FROM booking_preferences " .
            " WHERE book_pool_id = %s ",
            array("integer"),
            array($a_pool_id)
        );
        $preferences = [];
        while ($rec = $db->fetchAssoc($set)) {
            if (!isset($preferences[$rec["user_id"]]) || !in_array($rec["book_obj_id"], $preferences[$rec["user_id"]], true)) {
                $preferences[$rec["user_id"]][] = $rec["book_obj_id"];
            }
        }
        return $this->data->preferences($preferences);
    }

    public function getPreferencesOfUser(
        int $a_pool_id,
        int $a_user_id
    ): ilBookingPreferences {
        $db = $this->db;

        $set = $db->queryF(
            "SELECT * FROM booking_preferences " .
            " WHERE book_pool_id = %s " .
            " AND user_id = %s ",
            array("integer", "integer"),
            array($a_pool_id, $a_user_id)
        );
        $preferences = [];
        while ($rec = $db->fetchAssoc($set)) {
            if (!isset($preferences[$rec["user_id"]]) || !in_array($rec["book_obj_id"], $preferences[$rec["user_id"]], true)) {
                $preferences[$rec["user_id"]][] = $rec["book_obj_id"];
            }
        }
        return $this->data->preferences($preferences);
    }

    public function savePreferences(
        int $a_pool_id,
        ilBookingPreferences $preferences
    ): void {
        $db = $this->db;

        $db->manipulateF(
            "DELETE FROM booking_preferences WHERE " .
            " book_pool_id = %s",
            array("integer"),
            array($a_pool_id)
        );

        foreach ($preferences as $user_id => $obj_ids) {
            if (is_array($obj_ids) && $user_id > 0) {
                foreach ($obj_ids as $obj_id) {
                    $db->insert("booking_preferences", array(
                        "book_pool_id" => array("integer", $a_pool_id),
                        "user_id" => array("integer", $user_id),
                        "book_obj_id" => array("integer", $obj_id),
                    ));
                }
            }
        }
    }

    public function savePreferencesOfUser(
        int $a_pool_id,
        int $a_user_id,
        ilBookingPreferences $preferences
    ): void {
        $db = $this->db;

        $db->manipulateF(
            "DELETE FROM booking_preferences WHERE " .
            " book_pool_id = %s" .
            " AND user_id = %s",
            array("integer","integer"),
            array($a_pool_id, $a_user_id)
        );

        foreach ($preferences->getPreferences() as $user_id => $obj_ids) {
            if (is_array($obj_ids) && $user_id === $a_user_id) {
                foreach ($obj_ids as $obj_id) {
                    $db->insert("booking_preferences", array(
                        "book_pool_id" => array("integer", $a_pool_id),
                        "user_id" => array("integer", $user_id),
                        "book_obj_id" => array("integer", $obj_id),
                    ));
                }
            }
        }
    }
}