class.ilRecommendedContentDBRepository.php

Go to the documentation of this file.

<?php
 
/* Copyright (c) 1998-2019 ILIAS open source, Extended GPL, see docs/LICENSE */
 
class ilRecommendedContentDBRepository
{
    protected $db;
 
    public function __construct(\ilDBInterface $db = null)
    {
        global $DIC;
 
        $this->db = (is_null($db))
            ? $DIC->database()
            : $db;
    }
 
 
    public function addRoleRecommendation(int $role_id, int $ref_id)
    {
        $db = $this->db;
 
        $db->replace(
            "rep_rec_content_role",
            [           // pk
            "role_id" => ["integer", $role_id],
            "ref_id" => ["integer", $ref_id]
        ],
            []
        );
    }
 
    public function removeRoleRecommendation(int $role_id, int $ref_id)
    {
        $db = $this->db;
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_role WHERE " .
            " role_id = %s AND ref_id = %s",
            ["integer", "integer"],
            [$role_id, $ref_id]
        );
    }
 
    public function addObjectRecommendation(int $user_id, int $ref_id)
    {
        $db = $this->db;
 
        if (!$this->ifExistsObjectRecommendation($user_id, $ref_id)) {
            $db->insert("rep_rec_content_obj", [
                "user_id" => ["integer", $user_id],
                "ref_id" => ["integer", $ref_id],
                "declined" => ["integer", false]
            ]);
        }
    }
 
    public function removeObjectRecommendation(int $user_id, int $ref_id)
    {
        $db = $this->db;
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_obj WHERE " .
            " user_id = %s AND ref_id = %s",
            ["integer", "integer"],
            [$user_id, $ref_id]
        );
    }
 
    public function removeRecommendationsOfRefId(int $ref_id)
    {
        $db = $this->db;
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_obj WHERE " .
            " ref_id = %s",
            ["integer"],
            [$ref_id]
        );
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_role WHERE " .
            " ref_id = %s",
            ["integer"],
            [$ref_id]
        );
    }
 
    public function removeRecommendationsOfUser(int $user_id)
    {
        $db = $this->db;
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_obj WHERE " .
            " user_id = %s",
            ["integer"],
            [$user_id]
        );
    }
 
    public function removeRecommendationsOfRole(int $role_id)
    {
        $db = $this->db;
 
        $db->manipulateF(
            "DELETE FROM rep_rec_content_role WHERE " .
            " role_id = %s",
            ["integer"],
            [$role_id]
        );
    }
 
    protected function ifExistsObjectRecommendation(int $user_id, int $ref_id)
    {
        $db = $this->db;
 
        $set = $db->queryF(
            "SELECT * FROM rep_rec_content_obj " .
            " WHERE user_id = %s AND ref_id = %s",
            ["integer","integer"],
            [$user_id, $ref_id]
        );
        if ($rec = $db->fetchAssoc($set)) {
            return true;
        }
        return false;
    }
 
 
    public function declineObjectRecommendation(int $user_id, int $ref_id)
    {
        $db = $this->db;
 
        if ($this->ifExistsObjectRecommendation($user_id, $ref_id)) {
            $db->update(
                "rep_rec_content_obj",
                [
                    "declined" => ["integer", true]
                ],
                [       // where
                    "user_id" => ["integer", $user_id],
                    "ref_id" => ["integer", $ref_id]
                ]
            );
        } else {
            $db->insert("rep_rec_content_obj", [
                "user_id" => ["integer", $user_id],
                "ref_id" => ["integer", $ref_id],
                "declined" => ["integer", true]
            ]);
        }
    }
 
    public function getRecommendationsOfRoles(array $role_ids)
    {
        $db = $this->db;
 
        $set = $db->query(
            "SELECT DISTINCT ref_id FROM rep_rec_content_role " .
            " WHERE " . $db->in("role_id", $role_ids, false, "integer")
        );
        return array_column($db->fetchAll($set), "ref_id");
    }
    
    protected function getUserObjectRecommendations(int $user_id) : array
    {
        $db = $this->db;
 
        $set = $db->queryF(
            "SELECT ref_id FROM rep_rec_content_obj " .
            " WHERE user_id = %s AND declined = %s",
            ["integer", "integer"],
            [$user_id, false]
        );
        return array_column($db->fetchAll($set), "ref_id");
    }
 
    protected function getDeclinedUserObjectRecommendations(int $user_id) : array
    {
        $db = $this->db;
 
        $set = $db->queryF(
            "SELECT ref_id FROM rep_rec_content_obj " .
            " WHERE user_id = %s AND declined = %s",
            ["integer", "integer"],
            [$user_id, true]
        );
        return array_column($db->fetchAll($set), "ref_id");
    }
 
 
    public function getOpenRecommendationsOfUser(int $user_id, array $role_ids) : array
    {
        // recommendations of role
        $role_recommendations = $this->getRecommendationsOfRoles($role_ids);
 
        // recommendations of user
        $obj_recommendations = $this->getUserObjectRecommendations($user_id);
 
        $recommendations = array_unique($role_recommendations + $obj_recommendations);
 
        // filter declined recommendations
        $declined_recommendations = $this->getDeclinedUserObjectRecommendations($user_id);
        return array_filter($recommendations, function ($i) use ($declined_recommendations) {
            return !in_array($i, $declined_recommendations);
        });
    }
}