class.InvitationsDBRepository.php

Go to the documentation of this file.

<?php

namespace ILIAS\Survey\Participants;

/* Copyright (c) 1998-2019 ILIAS open source, Extended GPL, see docs/LICENSE */

class InvitationsDBRepository
{
    protected $db;

    public function __construct(\ilDBInterface $db = null)
    {
        global $DIC;

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


    public function remove(int $survey_id, int $user_id)
    {
        $db = $this->db;

        $db->manipulateF(
            "DELETE FROM svy_invitation WHERE " .
            " survey_id = %s AND user_id = %s",
            ["integer", "integer"],
            [$survey_id, $user_id]
        );
    }
    
    
    public function add(int $survey_id, int $user_id)
    {
        $db = $this->db;

        $db->replace(
            "svy_invitation",
            [           // pk
                "survey_id" => ["integer", $survey_id],
                "user_id" => ["integer", $user_id]
            ],
            []
        );
    }

    public function getAllForSurvey(int $survey_id) : array
    {
        $db = $this->db;

        $items = [];
        $set = $db->queryF(
            "SELECT user_id FROM svy_invitation " .
            " WHERE survey_id = %s ",
            ["integer"],
            [$survey_id]
        );

        while ($rec = $db->fetchAssoc($set)) {
            $items[] = $rec["user_id"];
        }
        return $items;
    }

    public function getAllForUser(int $user_id) : array
    {
        $db = $this->db;

        $items = [];
        $set = $db->queryF(
            "SELECT survey_id FROM svy_invitation " .
            " WHERE user_id = %s ",
            ["integer"],
            [$user_id]
        );

        while ($rec = $db->fetchAssoc($set)) {
            $items[] = (int) $rec["survey_id"];
        }
        return $items;
    }
}