class.ilNotification.php

Go to the documentation of this file.

<?php
 
/* Copyright (c) 1998-2010 ILIAS open source, Extended GPL, see docs/LICENSE */
 
class ilNotification
{
    const TYPE_EXERCISE_SUBMISSION = 1;
    const TYPE_WIKI = 2;
    const TYPE_WIKI_PAGE = 3;
    const TYPE_BLOG = 4;
    const TYPE_DATA_COLLECTION = 5;
    const TYPE_POLL = 6;
    const TYPE_LM_BLOCKED_USERS = 7;
    const TYPE_BOOK = 8;
    const TYPE_LM = 9;
    const TYPE_LM_PAGE = 10;
 
    const THRESHOLD = 180; // time between mails in minutes
 
    public static function hasNotification($type, $user_id, $id)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
        $tree = $DIC->repositoryTree();
 
        $notification = false;
 
        include_once("./Services/Notification/classes/class.ilObjNotificationSettings.php");
        $setting = new ilObjNotificationSettings($id);
        if ($setting->getMode() != ilObjNotificationSettings::MODE_DEF_OFF_USER_ACTIVATION) {
            // check membership, members should be notidifed...
            foreach (ilObject::_getAllReferences($id) as $ref_id) {
                $grp_ref_id = $tree->checkForParentType($ref_id, 'grp');
                if ($grp_ref_id > 0) {
                    include_once("./Modules/Group/classes/class.ilGroupParticipants.php");
                    if (ilGroupParticipants::_isParticipant($grp_ref_id, $user_id)) {
                        $notification = true;
                    }
                }
                $crs_ref_id = $tree->checkForParentType($ref_id, 'crs');
                if ($crs_ref_id > 0) {
                    include_once("./Modules/Course/classes/class.ilCourseParticipants.php");
                    if (ilCourseParticipants::_isParticipant($crs_ref_id, $user_id)) {
                        $notification = true;
                    }
                }
            }
 
            if ($notification && $setting->getMode() == ilObjNotificationSettings::MODE_DEF_ON_OPT_OUT) {
                $set = $ilDB->query("SELECT user_id FROM notification" .
                    " WHERE type = " . $ilDB->quote($type, "integer") .
                    " AND user_id = " . $ilDB->quote($user_id, "integer") .
                    " AND id = " . $ilDB->quote($id, "integer") .
                    " AND activated = " . $ilDB->quote(0, "integer"));
                $rec = $ilDB->fetchAssoc($set);
                // ... except when the opted out
                if ($rec["user_id"] == $user_id) {
                    return false;
                }
                return true;
            }
 
            if ($notification && $setting->getMode() == ilObjNotificationSettings::MODE_DEF_ON_NO_OPT_OUT) {
                return true;
            }
        }
 
 
        $set = $ilDB->query("SELECT user_id FROM notification" .
            " WHERE type = " . $ilDB->quote($type, "integer") .
            " AND user_id = " . $ilDB->quote($user_id, "integer") .
            " AND id = " . $ilDB->quote($id, "integer") .
            " AND activated = " . $ilDB->quote(1, "integer"));
 
        return (bool) $ilDB->numRows($set);
    }
 
    public static function hasOptOut($obj_id)
    {
        include_once("./Services/Notification/classes/class.ilObjNotificationSettings.php");
        $setting = new ilObjNotificationSettings($obj_id);
        if ($setting->getMode() == ilObjNotificationSettings::MODE_DEF_ON_NO_OPT_OUT) {
            return false;
        }
        return true;
    }
 
    public static function getNotificationsForObject($type, $id, $page_id = null, $ignore_threshold = false)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
        $tree = $DIC->repositoryTree();
 
        include_once("./Services/Notification/classes/class.ilObjNotificationSettings.php");
 
        // currently done for blog
        $recipients = array();
        $setting = new ilObjNotificationSettings($id);
        if ($setting->getMode() != ilObjNotificationSettings::MODE_DEF_OFF_USER_ACTIVATION) {
            foreach (ilObject::_getAllReferences($id) as $ref_id) {
                $grp_ref_id = $tree->checkForParentType($ref_id, 'grp');
                if ($grp_ref_id > 0) {
                    include_once("./Modules/Group/classes/class.ilGroupParticipants.php");
                    $p = ilGroupParticipants::_getInstanceByObjId(ilObject::_lookupObjectId($grp_ref_id));
                    foreach ($p->getMembers() as $user_id) {
                        if (!in_array($user_id, $recipients)) {
                            $recipients[$user_id] = $user_id;
                        }
                    }
                }
                $crs_ref_id = $tree->checkForParentType($ref_id, 'crs');
                if ($crs_ref_id > 0) {
                    include_once("./Modules/Course/classes/class.ilCourseParticipants.php");
                    $p = ilCourseParticipants::_getInstanceByObjId(ilObject::_lookupObjectId($crs_ref_id));
                    foreach ($p->getMembers() as $user_id) {
                        if (!in_array($user_id, $recipients)) {
                            $recipients[$user_id] = $user_id;
                        }
                    }
                }
            }
        }
 
        // remove all users that deactivated the feature
        if ($setting->getMode() == ilObjNotificationSettings::MODE_DEF_ON_OPT_OUT) {
            $sql = "SELECT user_id FROM notification" .
                " WHERE type = " . $ilDB->quote($type, "integer") .
                " AND id = " . $ilDB->quote($id, "integer") .
                " AND activated = " . $ilDB->quote(0, "integer") .
                " AND " . $ilDB->in("user_id", $recipients, false, "integer");
            $set = $ilDB->query($sql);
            while ($rec = $ilDB->fetchAssoc($set)) {
                unset($recipients[$rec["user_id"]]);
            }
        }
 
        // remove all users that got a mail
        if ($setting->getMode() != ilObjNotificationSettings::MODE_DEF_OFF_USER_ACTIVATION && !$ignore_threshold) {
            $sql = "SELECT user_id FROM notification" .
                " WHERE type = " . $ilDB->quote($type, "integer") .
                " AND id = " . $ilDB->quote($id, "integer") .
                " AND activated = " . $ilDB->quote(1, "integer") .
                " AND " . $ilDB->in("user_id", $recipients, false, "integer");
            $sql .= " AND (last_mail > " . $ilDB->quote(date(
                "Y-m-d H:i:s",
                strtotime("-" . self::THRESHOLD . "minutes")
            ), "timestamp");
            if ($page_id) {
                $sql .= " AND page_id = " . $ilDB->quote($page_id, "integer");
            }
            $sql .= ")";
 
            $set = $ilDB->query($sql);
            while ($rec = $ilDB->fetchAssoc($set)) {
                unset($recipients[$rec["user_id"]]);
            }
        }
 
        // get single subscriptions
        if ($setting->getMode() != ilObjNotificationSettings::MODE_DEF_ON_NO_OPT_OUT) {
            $sql = "SELECT user_id FROM notification" .
                " WHERE type = " . $ilDB->quote($type, "integer") .
                " AND id = " . $ilDB->quote($id, "integer") .
                " AND activated = " . $ilDB->quote(1, "integer");
            if (!$ignore_threshold) {
                $sql .= " AND (last_mail < " . $ilDB->quote(date(
                    "Y-m-d H:i:s",
                    strtotime("-" . self::THRESHOLD . "minutes")
                ), "timestamp") .
                    " OR last_mail IS NULL";
                if ($page_id) {
                    $sql .= " OR page_id <> " . $ilDB->quote($page_id, "integer");
                }
                $sql .= ")";
            }
            $set = $ilDB->query($sql);
            while ($row = $ilDB->fetchAssoc($set)) {
                $recipients[$row["user_id"]] = $row["user_id"];
            }
        }
 
        return $recipients;
    }
 
    public static function setNotification($type, $user_id, $id, $status = true)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
 
        $fields = array(
            "type" => array("integer", $type),
            "user_id" => array("integer", $user_id),
            "id" => array("integer", $id)
        );
        $ilDB->replace("notification", $fields, array("activated" => array("integer", (int) $status)));
    }
 
    public static function updateNotificationTime($type, $id, array $user_ids, $page_id = false)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
 
        $sql = "UPDATE notification" .
                " SET last_mail = " . $ilDB->quote(date("Y-m-d H:i:s"), "timestamp");
 
        if ($page_id) {
            $sql .= ", page_id = " . $ilDB->quote($page_id, "integer");
        }
 
        $sql .= " WHERE type = " . $ilDB->quote($type, "integer") .
                " AND id = " . $ilDB->quote($id, "integer") .
                " AND " . $ilDB->in("user_id", $user_ids, false, "integer");
 
        $ilDB->query($sql);
    }
 
    public static function removeForObject($type, $id)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
 
        $ilDB->query("DELETE FROM notification" .
                " WHERE type = " . $ilDB->quote($type, "integer") .
                " AND id = " . $ilDB->quote($id, "integer"));
    }
 
    public static function removeForUser($user_id)
    {
        global $DIC;
 
        $ilDB = $DIC->database();
 
        $ilDB->query("DELETE FROM notification" .
                " WHERE user_id = " . $ilDB->quote($user_id, "integer"));
    }
 
    public static function getActivatedNotifications(int $type, int $user_id) : array
    {
        global $DIC;
 
        $db = $DIC->database();
 
        $set = $db->queryF(
            "SELECT id FROM notification " .
            " WHERE type = %s " .
            " AND user_id = %s " .
            " AND activated = %s ",
            array("integer", "integer", "integer"),
            array($type, $user_id, 1)
            );
        $ids = [];
        while ($rec = $db->fetchAssoc($set)) {
            $ids[] = $rec["id"];
        }
 
        return $ids;
    }
}