class.ilObjTestAccess.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2013 ILIAS open source, Extended GPL, see docs/LICENSE */

include_once "./Services/Object/classes/class.ilObjectAccess.php";
include_once "./Modules/Test/classes/inc.AssessmentConstants.php";
include_once './Services/Conditions/interfaces/interface.ilConditionHandling.php';

class ilObjTestAccess extends ilObjectAccess implements ilConditionHandling
{
    public function _checkAccess($a_cmd, $a_permission, $a_ref_id, $a_obj_id, $a_user_id = "")
    {
        global $DIC;
        $ilUser = $DIC['ilUser'];
        $lng = $DIC['lng'];
        $rbacsystem = $DIC['rbacsystem'];
        $ilAccess = $DIC['ilAccess'];
        
        if ($a_user_id == "") {
            $a_user_id = $ilUser->getId();
        }
        
        $is_admin = $rbacsystem->checkAccessOfUser($a_user_id, 'write', $a_ref_id);
        

        switch ($a_permission) {
            case "visible":
            case "read":
                if (!ilObjTestAccess::_lookupCreationComplete($a_obj_id) &&
                    !$is_admin) {
                    $ilAccess->addInfoItem(IL_NO_OBJECT_ACCESS, $lng->txt("tst_warning_test_not_complete"));
                    return false;
                }
                break;
        }
        
        switch ($a_cmd) {
            case "eval_a":
            case "eval_stat":
                if (!ilObjTestAccess::_lookupCreationComplete($a_obj_id)) {
                    $ilAccess->addInfoItem(IL_NO_OBJECT_ACCESS, $lng->txt("tst_warning_test_not_complete"));
                    return false;
                }
                break;

        }

        return true;
    }

    public static function _isPassed($user_id, $a_obj_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $result = $ilDB->queryF(
            "SELECT tst_result_cache.* FROM tst_result_cache, tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s AND tst_result_cache.active_fi = tst_active.active_id",
            array('integer','integer'),
            array($user_id, $a_obj_id)
        );
        if (!$result->numRows()) {
            $result = $ilDB->queryF(
                "SELECT tst_active.active_id FROM tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s",
                array('integer','integer'),
                array($user_id, $a_obj_id)
            );
            $row = $ilDB->fetchAssoc($result);
            if ($row['active_id'] > 0) {
                include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                assQuestion::_updateTestResultCache($row['active_id']);
            } else {
                return false;
            }
        }
        $result = $ilDB->queryF(
            "SELECT tst_result_cache.* FROM tst_result_cache, tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s AND tst_result_cache.active_fi = tst_active.active_id",
            array('integer','integer'),
            array($user_id, $a_obj_id)
        );
        if (!$result->numRows()) {
            $result = $ilDB->queryF(
                "SELECT tst_pass_result.*, tst_tests.pass_scoring, tst_tests.random_test, tst_tests.test_id FROM tst_pass_result, tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s AND tst_pass_result.active_fi = tst_active.active_id ORDER BY tst_pass_result.pass",
                array('integer','integer'),
                array($user_id, $a_obj_id)
            );
            $points = array();
            while ($row = $ilDB->fetchAssoc($result)) {
                array_push($points, $row);
            }
            $reached = 0;
            $max = 0;
            if ($points[0]["pass_scoring"] == 0) {
                $reached = $points[count($points) - 1]["points"];
                $max = $points[count($points) - 1]["maxpoints"];
                if (!$max) {
                    $active_id = $points[count($points) - 1]["active_fi"];
                    $pass = $points[count($points) - 1]["pass"];
                    if (strlen($active_id) && strlen($pass)) {
                        include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                        $res = assQuestion::_updateTestPassResults($active_id, $pass, null, $a_obj_id);
                        $max = $res['maxpoints'];
                        $reached = $res['points'];
                    }
                }
            } else {
                foreach ($points as $row) {
                    if ($row["points"] > $reached) {
                        $reached = $row["points"];
                        $max = $row["maxpoints"];
                        if (!$max) {
                            $active_id = $row["active_fi"];
                            $pass = $row["pass"];
                            if (strlen($active_id) && strlen($pass)) {
                                include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                                $res = assQuestion::_updateTestPassResults($active_id, $pass, null, $a_obj_id);
                                $max = $res['maxpoints'];
                                $reached = $res['points'];
                            }
                        }
                    }
                }
            }
            include_once "./Modules/Test/classes/class.assMarkSchema.php";
            $percentage = (!$max) ? 0 : ($reached / $max) * 100.0;
            $mark = ASS_MarkSchema::_getMatchingMarkFromObjId($a_obj_id, $percentage);
            return ($mark["passed"]) ? true : false;
        } else {
            $row = $ilDB->fetchAssoc($result);
            return ($row['passed']) ? true : false;
        }
    }
    
    public static function isFailed($user_id, $a_obj_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        
        $ret = self::updateTestResultCache($user_id, $a_obj_id);

        if (!$ret) {
            return false;
        }
        
        $result = $ilDB->queryF(
            "SELECT tst_result_cache.* FROM tst_result_cache, tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s AND tst_result_cache.active_fi = tst_active.active_id",
            array('integer','integer'),
            array($user_id, $a_obj_id)
        );

        if (!$result->numRows()) {
            $result = $ilDB->queryF(
                "SELECT tst_pass_result.*, tst_tests.pass_scoring, tst_tests.random_test, tst_tests.test_id FROM tst_pass_result, tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s AND tst_pass_result.active_fi = tst_active.active_id ORDER BY tst_pass_result.pass",
                array('integer','integer'),
                array($user_id, $a_obj_id)
            );

            while ($row = $ilDB->fetchAssoc($result)) {
                array_push($points, $row);
            }
            $reached = 0;
            $max = 0;
            if ($points[0]["pass_scoring"] == 0) {
                $reached = $points[count($points) - 1]["points"];
                $max = $points[count($points) - 1]["maxpoints"];
                if (!$max) {
                    $active_id = $points[count($points) - 1]["active_fi"];
                    $pass = $points[count($points) - 1]["pass"];
                    if (strlen($active_id) && strlen($pass)) {
                        include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                        $res = assQuestion::_updateTestPassResults($active_id, $pass, null, $a_obj_id);
                        $max = $res['maxpoints'];
                        $reached = $res['points'];
                    }
                }
            } else {
                foreach ($points as $row) {
                    if ($row["points"] > $reached) {
                        $reached = $row["points"];
                        $max = $row["maxpoints"];
                        if (!$max) {
                            $active_id = $row["active_fi"];
                            $pass = $row["pass"];
                            if (strlen($active_id) && strlen($pass)) {
                                include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                                $res = assQuestion::_updateTestPassResults($active_id, $pass, null, $a_obj_id);
                                $max = $res['maxpoints'];
                                $reached = $res['points'];
                            }
                        }
                    }
                }
            }
            include_once "./Modules/Test/classes/class.assMarkSchema.php";
            $percentage = (!$max) ? 0 : ($reached / $max) * 100.0;
            $mark = ASS_MarkSchema::_getMatchingMarkFromObjId($a_obj_id, $percentage);
            return ($mark["failed"]) ? true : false;
        } else {
            $row = $ilDB->fetchAssoc($result);
            return ($row['failed']) ? true : false;
        }
    }
    
    protected static function updateTestResultCache($a_user_id, $a_obj_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        
        $result = $ilDB->queryF(
            "SELECT tst_result_cache.* FROM tst_result_cache, tst_active, tst_tests " .
                "WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s " .
                "AND tst_tests.obj_fi = %s AND tst_result_cache.active_fi = tst_active.active_id",
            array('integer','integer'),
            array($a_user_id, $a_obj_id)
        );
        if (!$result->numRows()) {
            $result = $ilDB->queryF(
                "SELECT tst_active.active_id FROM tst_active, tst_tests WHERE tst_active.test_fi = tst_tests.test_id AND tst_active.user_fi = %s AND tst_tests.obj_fi = %s",
                array('integer','integer'),
                array($a_user_id, $a_obj_id)
            );
            $row = $ilDB->fetchAssoc($result);
            if ($row['active_id'] > 0) {
                include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                assQuestion::_updateTestResultCache($row['active_id']);
                return true;
            } else {
                return false;
            }
        } else {
            return true;
        }
    }

    
    public static function getConditionOperators()
    {
        include_once './Services/Conditions/classes/class.ilConditionHandler.php';
        return array(
            ilConditionHandler::OPERATOR_PASSED,
            ilConditionHandler::OPERATOR_FAILED,
            ilConditionHandler::OPERATOR_FINISHED,
            ilConditionHandler::OPERATOR_NOT_FINISHED
        );
    }
    

    public static function checkCondition($a_obj_id, $a_operator, $a_value, $a_usr_id)
    {
        include_once './Services/Conditions/classes/class.ilConditionHandler.php';
        
        switch ($a_operator) {
            case ilConditionHandler::OPERATOR_PASSED:
                return ilObjTestAccess::_isPassed($a_usr_id, $a_obj_id);
                break;
            
            case ilConditionHandler::OPERATOR_FAILED:
                return ilObjTestAccess::isFailed($a_usr_id, $a_obj_id);

            case ilConditionHandler::OPERATOR_FINISHED:
                return ilObjTestAccess::hasFinished($a_usr_id, $a_obj_id);

            case ilConditionHandler::OPERATOR_NOT_FINISHED:
                return !ilObjTestAccess::hasFinished($a_usr_id, $a_obj_id);

            default:
                return true;
        }
        return true;
    }

    public static function _getCommands()
    {
        $commands = array(
            array("permission" => "write", "cmd" => "questionsTabGateway", "lang_var" => "tst_edit_questions"),
            array("permission" => "write", "cmd" => "ilObjTestSettingsGeneralGUI::showForm", "lang_var" => "settings"),
            array("permission" => "read", "cmd" => "infoScreen", "lang_var" => "tst_run",
                "default" => true),
            //array("permission" => "write", "cmd" => "", "lang_var" => "edit"),
            array("permission" => "tst_statistics", "cmd" => "outEvaluation", "lang_var" => "tst_statistical_evaluation"),
            array("permission" => "read", "cmd" => "userResultsGateway", "lang_var" => "tst_test_results")
        );
        
        return $commands;
    }

    //
    // object specific access related methods
    //

    public static function _lookupCreationComplete($a_obj_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $result = $ilDB->queryF(
            "SELECT complete FROM tst_tests WHERE obj_fi=%s",
            array('integer'),
            array($a_obj_id)
        );
        if ($result->numRows() == 1) {
            $row = $ilDB->fetchAssoc($result);
        }

        return ($row['complete']) ? true : false;
    }

    private static $hasFinishedCache = array();

    public static function hasFinished($a_user_id, $a_obj_id)
    {
        if (!isset(self::$hasFinishedCache["{$a_user_id}:{$a_obj_id}"])) {
            require_once 'Modules/Test/classes/class.ilTestParticipantData.php';
            require_once 'Modules/Test/classes/class.ilTestSessionFactory.php';
            require_once 'Modules/Test/classes/class.ilTestPassesSelector.php';
            
            global $DIC;
            $ilDB = $DIC['ilDB'];
            $lng = $DIC['lng'];
            
            $testOBJ = ilObjectFactory::getInstanceByObjId($a_obj_id);
            
            $partData = new ilTestParticipantData($ilDB, $lng);
            $partData->setUserIdsFilter(array($a_user_id));
            $partData->load($testOBJ->getTestId());
            
            $activeId = $partData->getActiveIdByUserId($a_user_id);

            $testSessionFactory = new ilTestSessionFactory($testOBJ);
            $testSession = $testSessionFactory->getSession($activeId);
            
            $testPassesSelector = new ilTestPassesSelector($ilDB, $testOBJ);
            $testPassesSelector->setActiveId($activeId);
            $testPassesSelector->setLastFinishedPass($testSession->getLastFinishedPass());
            
            self::$hasFinishedCache["{$a_user_id}:{$a_obj_id}"] = count($testPassesSelector->getClosedPasses());
        }
        
        return (bool) self::$hasFinishedCache["{$a_user_id}:{$a_obj_id}"];
    }

    public static function _getTestIDFromObjectID($object_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $test_id = false;
        $result = $ilDB->queryF(
            "SELECT test_id FROM tst_tests WHERE obj_fi = %s",
            array('integer'),
            array($object_id)
        );
        if ($result->numRows()) {
            $row = $ilDB->fetchAssoc($result);
            $test_id = $row["test_id"];
        }
        return $test_id;
    }

    public static function _lookupObjIdForTestId($a_test_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $result = $ilDB->queryF(
            "SELECT obj_fi FROM tst_tests WHERE test_id = %s",
            array('integer'),
            array($a_test_id)
        );

        $row = $ilDB->fetchAssoc($result);
        return $row["obj_fi"];
    }

    public static function _getRandomTestsForQuestionPool($qpl_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
    
        $query = "
                        SELECT DISTINCT t.obj_fi
                        FROM tst_tests t
                        INNER JOIN tst_rnd_quest_set_qpls r
                        ON t.test_id = r.test_fi
                        WHERE r.pool_fi = %s
                ";
    
        $result = $ilDB->queryF($query, array('integer'), array($qpl_id));
    
        $tests = array();
        while ($row = $ilDB->fetchAssoc($result)) {
            $tests[] = $row['obj_fi'];
        }
    
        return $tests;
    }
    // fim.
    
    public static function _lookupOnlineTestAccess($a_test_id, $a_user_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $lng = $DIC['lng'];
        
        $result = $ilDB->queryF(
            "SELECT tst_tests.* FROM tst_tests WHERE tst_tests.obj_fi = %s",
            array('integer'),
            array($a_test_id)
        );
        if ($result->numRows()) {
            $row = $ilDB->fetchAssoc($result);
            if ($row["fixed_participants"]) {
                $result = $ilDB->queryF(
                    "SELECT * FROM tst_invited_user WHERE test_fi = %s AND user_fi = %s",
                    array('integer','integer'),
                    array($row["test_id"], $a_user_id)
                );
                if ($result->numRows()) {
                    $row = $ilDB->fetchAssoc($result);
                    if (trim($row['clientip']) != "") {
                        $row['clientip'] = preg_replace("/[^0-9.?*,:]+/", "", $row['clientip']);
                        $row['clientip'] = str_replace(".", "\\.", $row['clientip']);
                        $row['clientip'] = str_replace(array("?","*",","), array("[0-9]","[0-9]*","|"), $row['clientip']);
                        if (!preg_match("/^" . $row['clientip'] . "$/", $_SERVER["REMOTE_ADDR"])) {
                            $lng->loadLanguageModule('assessment');
                            return $lng->txt("user_wrong_clientip");
                        } else {
                            return true;
                        }
                    } else {
                        return true;
                    }
                } else {
                    return $lng->txt("tst_user_not_invited");
                }
            } else {
                return true;
            }
        } else {
            return true;
        }
    }

    public static function _getParticipantData($active_id)
    {
        global $DIC;
        $lng = $DIC['lng'];
        $ilDB = $DIC['ilDB'];

        $result = $ilDB->queryF(
            "SELECT * FROM tst_active WHERE active_id = %s",
            array("integer"),
            array($active_id)
        );
        $row = $ilDB->fetchAssoc($result);
        $user_id = $row["user_fi"];
        $test_id = $row["test_fi"];
        $importname = $row['importname'];

        $result = $ilDB->queryF(
            "SELECT obj_fi FROM tst_tests WHERE test_id = %s",
            array("integer"),
            array($test_id)
        );
        $row = $ilDB->fetchAssoc($result);
        $obj_id = $row["obj_fi"];
        
        include_once "./Modules/Test/classes/class.ilObjTest.php";
        $is_anonymous = ilObjTest::_lookupAnonymity($obj_id);
        
        include_once './Services/User/classes/class.ilObjUser.php';
        $uname = ilObjUser::_lookupName($user_id);

        $name = "";
        if (strlen($importname)) {
            $name = $importname . ' (' . $lng->txt('imported') . ')';
        } elseif (strlen($uname["firstname"] . $uname["lastname"]) == 0) {
            $name = $lng->txt("deleted_user");
        } else {
            if ($user_id == ANONYMOUS_USER_ID) {
                $name = $lastname;
            } else {
                $name = trim($uname["lastname"] . ", " . $uname["firstname"] . " " . $uname["title"]);
            }
            if ($is_anonymous) {
                $name = $lng->txt("anonymous");
            }
        }
        return $name;
    }

    public static function _getParticipantId($active_id)
    {
        global $DIC;
        $lng = $DIC['lng'];
        $ilDB = $DIC['ilDB'];

        $result = $ilDB->queryF(
            "SELECT user_fi FROM tst_active WHERE active_id = %s",
            array("integer"),
            array($active_id)
        );
        $row = $ilDB->fetchAssoc($result);
        return $row["user_fi"];
    }


    public static function _getPassedUsers($a_obj_id)
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $passed_users = array();
        // Maybe SELECT DISTINCT(tst_active.user_fi)... ?
        $userresult = $ilDB->queryF(
            "
                        SELECT tst_active.active_id, COUNT(tst_sequence.active_fi) sequences, tst_active.last_finished_pass,
                                CASE WHEN
                                        (tst_tests.nr_of_tries - 1) = tst_active.last_finished_pass
                                THEN '1'
                                ELSE '0'
                                END is_last_pass
                        FROM tst_tests
                        INNER JOIN tst_active
                        ON tst_active.test_fi = tst_tests.test_id
                        LEFT JOIN tst_sequence
                        ON tst_sequence.active_fi = tst_active.active_id
                        WHERE tst_tests.obj_fi = %s
                        GROUP BY tst_active.active_id
                        ",
            array('integer'),
            array($a_obj_id)
        );
        $all_participants = array();
        $notAttempted = array();
        $lastPassUsers = array();
        while ($row = $ilDB->fetchAssoc($userresult)) {
            if ($row['sequences'] == 0) {
                $notAttempted[$row['active_id']] = $row['active_id'];
            }
            if ($row['is_last_pass']) {
                $lastPassUsers[$row['active_id']] = $row['active_id'];
            }

            $all_participants[$row['active_id']] = $row['active_id'];
        }
        
        $result = $ilDB->query("SELECT tst_result_cache.*, tst_active.user_fi FROM tst_result_cache, tst_active WHERE tst_active.active_id = tst_result_cache.active_fi AND " . $ilDB->in('active_fi', $all_participants, false, 'integer'));
        $found_all = ($result->numRows() == count($all_participants)) ? true : false;
        if (!$found_all) {
            // if the result cache entries do not exist, create them
            $found_participants = array();
            while ($data = $ilDB->fetchAssoc($result)) {
                array_push($found_participants, $data['active_fi']);
            }
            foreach ($all_participants as $active_id) {
                if (!in_array($active_id, $found_participants)) {
                    include_once "./Modules/TestQuestionPool/classes/class.assQuestion.php";
                    assQuestion::_updateTestResultCache($active_id);
                }
            }
            $result = $ilDB->query("SELECT tst_result_cache.*, tst_active.user_fi FROM tst_result_cache, tst_active WHERE tst_active.active_id = tst_result_cache.active_fi AND " . $ilDB->in('active_fi', $all_participants, false, 'integer'));
        }
        while ($data = $ilDB->fetchAssoc($result)) {
            if (isset($notAttempted[$data['active_fi']])) {
                $data['failed'] = 0;
                $data['passed'] = 0;
                $data['not_attempted'] = 1;
            }
            
            if ($data['failed'] && !isset($lastPassUsers[$data['active_fi']])) {
                $data['passed'] = 0;
                $data['failed'] = 0;
                $data['in_progress'] = 1;
            }

            $data['user_id'] = $data['user_fi'];
            array_push($passed_users, $data);
        }
        return $passed_users;
    }

    public static function _checkGoto($a_target)
    {
        global $DIC;
        $ilAccess = $DIC['ilAccess'];
        
        $t_arr = explode("_", $a_target);

        if ($t_arr[0] != "tst" || ((int) $t_arr[1]) <= 0) {
            return false;
        }

        if ($ilAccess->checkAccess("read", "", $t_arr[1])) {
            return true;
        }
        return false;
    }

    public static function _isOffline($a_obj_id)
    {
        //              global $DIC;
        //              $ilUser = $DIC['ilUser'];
        //              return (self::_lookupOnlineTestAccess($a_obj_id, $ilUser->getId()) !== true) ||
        //                      (!ilObjTestAccess::_lookupCreationComplete($a_obj_id));
        return ilObject::lookupOfflineStatus($a_obj_id);
    }


    public static function visibleUserResultExists($testObjId, $userId)
    {
        $testOBJ = ilObjectFactory::getInstanceByObjId($testObjId, false);

        if (!($testOBJ instanceof ilObjTest)) {
            return false;
        }

        require_once 'Modules/Test/classes/class.ilTestSessionFactory.php';
        $testSessionFactory = new ilTestSessionFactory($testOBJ);
        $testSession = $testSessionFactory->getSessionByUserId($userId);

        return $testOBJ->canShowTestResults($testSession);
    }
    
    public static function hasVisibleCertificate($testObjId, $userId)
    {
        $testOBJ = ilObjectFactory::getInstanceByObjId($testObjId, false);
        
        if (!($testOBJ instanceof ilObjTest) || !$userId) {
            return false;
        }
        
        require_once 'Modules/Test/classes/class.ilTestSessionFactory.php';
        $testSessionFactory = new ilTestSessionFactory($testOBJ);
        $testSession = $testSessionFactory->getSessionByUserId($userId);
        
        if (!$testSession->getActiveId()) {
            return false;
        }
        
        return $testOBJ->canShowCertificate($testSession, $testSession->getUserId(), $testSession->getActiveId());
    }
}