class.SkillProfileCompletionDBRepository.php

Go to the documentation of this file.

<?php

namespace ILIAS\Skill\Profile;

class SkillProfileCompletionDBRepository
{
    protected \ilDBInterface $db;

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

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

    public function getEntries(int $user_id, int $profile_id): array
    {
        $ilDB = $this->db;

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE profile_id = " . $ilDB->quote($profile_id, "integer") .
            " AND user_id = " . $ilDB->quote($user_id, "integer")
        );
        $entries = [];
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entries[] = array(
                "profile_id" => $rec["profile_id"],
                "user_id" => $rec["user_id"],
                "date" => $rec["date"],
                "fulfilled" => $rec["fulfilled"]
            );
        }

        return $entries;
    }

    public function addFulfilmentEntry(int $user_id, int $profile_id): void
    {
        $ilDB = $this->db;

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE profile_id = " . $ilDB->quote($profile_id, "integer") .
            " AND user_id = " . $ilDB->quote($user_id, "integer") .
            " ORDER BY date DESC" .
            " LIMIT 1"
        );

        $entry = null;
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entry = $rec["fulfilled"];
        }

        if ($entry == 0) {
            $now = \ilUtil::now();
            $ilDB->manipulate("INSERT INTO skl_profile_completion " .
                "(profile_id, user_id, date, fulfilled) VALUES (" .
                $ilDB->quote($profile_id, "integer") . "," .
                $ilDB->quote($user_id, "integer") . "," .
                $ilDB->quote($now, "timestamp") . "," .
                $ilDB->quote(1, "integer") .
                ")");
        }
    }

    public function addNonFulfilmentEntry(int $user_id, int $profile_id): void
    {
        $ilDB = $this->db;

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE profile_id = " . $ilDB->quote($profile_id, "integer") .
            " AND user_id = " . $ilDB->quote($user_id, "integer") .
            " ORDER BY date DESC" .
            " LIMIT 1"
        );

        $entry = null;
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entry = $rec["fulfilled"];
        }

        if (is_null($entry) || $entry == 1) {
            $now = \ilUtil::now();
            $ilDB->manipulate("INSERT INTO skl_profile_completion " .
                "(profile_id, user_id, date, fulfilled) VALUES (" .
                $ilDB->quote($profile_id, "integer") . "," .
                $ilDB->quote($user_id, "integer") . "," .
                $ilDB->quote($now, "timestamp") . "," .
                $ilDB->quote(0, "integer") .
                ")");
        }
    }

    public function getFulfilledEntriesForUser(int $user_id): array
    {
        global $DIC;

        $ilDB = $DIC->database();

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE user_id = " . $ilDB->quote($user_id, "integer") .
            " AND fulfilled = 1"
        );
        $entries = [];
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entries[] = array(
                "profile_id" => (int) $rec["profile_id"],
                "user_id" => (int) $rec["user_id"],
                "date" => $rec["date"],
                "fulfilled" => (int) $rec["fulfilled"]
            );
        }

        return $entries;
    }

    public function getAllEntriesForUser(int $user_id): array
    {
        global $DIC;

        $ilDB = $DIC->database();

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE user_id = " . $ilDB->quote($user_id, "integer")
        );
        $entries = [];
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entries[] = array(
                "profile_id" => $rec["profile_id"],
                "user_id" => $rec["user_id"],
                "date" => $rec["date"],
                "fulfilled" => $rec["fulfilled"]
            );
        }

        return $entries;
    }

    public function getAllEntriesForProfile(int $profile_id): array
    {
        global $DIC;

        $ilDB = $DIC->database();

        $set = $ilDB->query(
            "SELECT * FROM skl_profile_completion " .
            " WHERE profile_id = " . $ilDB->quote($profile_id, "integer")
        );
        $entries = [];
        while ($rec = $ilDB->fetchAssoc($set)) {
            $entries[] = array(
                "profile_id" => $rec["profile_id"],
                "user_id" => $rec["user_id"],
                "date" => $rec["date"],
                "fulfilled" => $rec["fulfilled"]
            );
        }

        return $entries;
    }

    public function deleteEntriesForProfile(int $profile_id): void
    {
        $ilDB = $this->db;

        $ilDB->manipulate(
            "DELETE FROM skl_profile_completion WHERE "
            . " profile_id = " . $ilDB->quote($profile_id, "integer")
        );
    }

    public function deleteEntriesForUser(int $user_id): void
    {
        $ilDB = $this->db;

        $ilDB->manipulate(
            "DELETE FROM skl_profile_completion WHERE "
            . " user_id = " . $ilDB->quote($user_id, "integer")
        );
    }
}