class.ilAssQuestionUserSolutionAdopter.php

Go to the documentation of this file.

<?php
 
class ilAssQuestionUserSolutionAdopter
{
    protected static $preparedDeleteSolutionRecordsStatement = null;
 
    protected static $preparedSelectSolutionRecordsStatement = null;
 
    protected static $preparedInsertSolutionRecordStatement = null;
 
    protected static $preparedDeleteResultRecordStatement = null;
 
    protected static $preparedSelectResultRecordStatement = null;
 
    protected static $preparedInsertResultRecordStatement = null;
 
    protected $db;
 
    protected $processLockerFactory;
 
    protected $userId;
 
    protected $activeId;
 
    protected $targetPass;
 
    protected $questionIds;
 
    public function __construct(ilDBInterface $db, ilSetting $assSettings, $isAssessmentLogEnabled)
    {
        $this->db = $db;
 
        $this->userId = null;
        $this->activeId = null;
        $this->targetPass = null;
        $this->questionIds = array();
 
        require_once 'Modules/TestQuestionPool/classes/class.ilAssQuestionProcessLockerFactory.php';
        $this->processLockerFactory = new ilAssQuestionProcessLockerFactory($assSettings, $db);
        $this->processLockerFactory->setAssessmentLogEnabled($isAssessmentLogEnabled);
    }
 
    public function getUserId(): ?int
    {
        return $this->userId;
    }
 
    public function setUserId($userId): void
    {
        $this->userId = $userId;
    }
 
    public function getActiveId(): ?int
    {
        return $this->activeId;
    }
 
    public function setActiveId($activeId): void
    {
        $this->activeId = $activeId;
    }
 
    public function getTargetPass(): ?int
    {
        return $this->targetPass;
    }
 
    public function setTargetPass($targetPass): void
    {
        $this->targetPass = $targetPass;
    }
 
    public function getQuestionIds(): array
    {
        return $this->questionIds;
    }
 
    public function setQuestionIds($questionIds): void
    {
        $this->questionIds = $questionIds;
    }
 
    public function perform(): void
    {
        $this->processLockerFactory->setUserId($this->getUserId());
 
        foreach ($this->getQuestionIds() as $questionId) {
            $this->processLockerFactory->setQuestionId($questionId);
            $processLocker = $this->processLockerFactory->getLocker();
 
            $processLocker->executeUserTestResultUpdateLockOperation(function () use ($questionId) {
                $this->adoptQuestionAnswer($questionId);
            });
        }
    }
 
    protected function adoptQuestionAnswer($questionId): void
    {
        $this->resetTargetSolution($questionId);
        $this->resetTargetResult($questionId);
 
        $sourcePass = $this->adoptSourceSolution($questionId);
 
        if ($sourcePass !== null) {
            $this->adoptSourceResult($questionId, $sourcePass);
        }
    }
 
    protected function resetTargetSolution($questionId): void
    {
        $this->db->execute(
            $this->getPreparedDeleteSolutionRecordsStatement(),
            array($this->getActiveId(), $questionId, $this->getTargetPass())
        );
    }
 
    protected function resetTargetResult($questionId): void
    {
        $this->db->execute(
            $this->getPreparedDeleteResultRecordStatement(),
            array($this->getActiveId(), $questionId, $this->getTargetPass())
        );
    }
 
    protected function adoptSourceSolution($questionId)
    {
        $res = $this->db->execute(
            $this->getPreparedSelectSolutionRecordsStatement(),
            array($this->getActiveId(), $questionId, $this->getTargetPass())
        );
 
        $sourcePass = null;
 
        while ($row = $this->db->fetchAssoc($res)) {
            if ($sourcePass === null) {
                $sourcePass = $row['pass'];
            } elseif ($row['pass'] < $sourcePass) {
                break;
            }
 
            $solutionId = $this->db->nextId('tst_solutions');
 
            $this->db->execute($this->getPreparedInsertSolutionRecordStatement(), array(
                $solutionId, $this->getActiveId(), $questionId, $this->getTargetPass(), time(),
                $row['points'], $row['value1'], $row['value2']
            ));
        }
 
        return $sourcePass;
    }
 
    protected function adoptSourceResult($questionId, $sourcePass): void
    {
        $res = $this->db->execute(
            $this->getPreparedSelectResultRecordStatement(),
            array($this->getActiveId(), $questionId, $sourcePass)
        );
 
        $row = $this->db->fetchAssoc($res);
 
        $resultId = $this->db->nextId('tst_test_result');
 
        $this->db->execute($this->getPreparedInsertResultRecordStatement(), array(
            $resultId, $this->getActiveId(), $questionId, $this->getTargetPass(), time(),
            $row['points'], $row['manual'], $row['hint_count'], $row['hint_points'], $row['answered']
        ));
    }
 
    protected function getPreparedDeleteSolutionRecordsStatement(): ilDBStatement
    {
        if (self::$preparedDeleteSolutionRecordsStatement === null) {
            self::$preparedDeleteSolutionRecordsStatement = $this->db->prepareManip(
                "DELETE FROM tst_solutions WHERE active_fi = ? AND question_fi = ? AND pass = ?",
                array('integer', 'integer', 'integer')
            );
        }
 
        return self::$preparedDeleteSolutionRecordsStatement;
    }
 
    protected function getPreparedSelectSolutionRecordsStatement(): ilDBStatement
    {
        if (self::$preparedSelectSolutionRecordsStatement === null) {
            $query = "
                                SELECT pass, points, value1, value2 FROM tst_solutions
                                WHERE active_fi = ? AND question_fi = ? AND pass < ? ORDER BY pass DESC
                        ";
 
            self::$preparedSelectSolutionRecordsStatement = $this->db->prepare(
                $query,
                array('integer', 'integer', 'integer')
            );
        }
 
        return self::$preparedSelectSolutionRecordsStatement;
    }
 
    protected function getPreparedInsertSolutionRecordStatement(): ilDBStatement
    {
        if (self::$preparedInsertSolutionRecordStatement === null) {
            $query = "
                                INSERT INTO tst_solutions (
                                        solution_id, active_fi, question_fi, pass, tstamp, points, value1, value2
                                ) VALUES (
                                        ?, ?, ?, ?, ?, ?, ?, ?
                                )
                        ";
 
            self::$preparedInsertSolutionRecordStatement = $this->db->prepareManip(
                $query,
                array('integer', 'integer', 'integer', 'integer', 'integer', 'integer', 'text', 'text')
            );
        }
 
        return self::$preparedInsertSolutionRecordStatement;
    }
 
    protected function getPreparedDeleteResultRecordStatement(): ilDBStatement
    {
        if (self::$preparedDeleteResultRecordStatement === null) {
            self::$preparedDeleteResultRecordStatement = $this->db->prepareManip(
                "DELETE FROM tst_test_result WHERE active_fi = ? AND question_fi = ? AND pass = ?",
                array('integer', 'integer', 'integer')
            );
        }
 
        return self::$preparedDeleteResultRecordStatement;
    }
 
    protected function getPreparedSelectResultRecordStatement(): ilDBStatement
    {
        if (self::$preparedSelectResultRecordStatement === null) {
            $query = "
                                SELECT points, manual, hint_count, hint_points, answered FROM tst_test_result
                                WHERE active_fi = ? AND question_fi = ? AND pass = ?
                        ";
 
            self::$preparedSelectResultRecordStatement = $this->db->prepare(
                $query,
                array('integer', 'integer', 'integer')
            );
        }
 
        return self::$preparedSelectResultRecordStatement;
    }
 
    protected function getPreparedInsertResultRecordStatement(): ilDBStatement
    {
        if (self::$preparedInsertResultRecordStatement === null) {
            $query = "
                                INSERT INTO tst_test_result (
                                        test_result_id, active_fi, question_fi, pass, tstamp,
                                        points, manual, hint_count, hint_points, answered
                                ) VALUES (
                                        ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
                                )
                        ";
 
            self::$preparedInsertResultRecordStatement = $this->db->prepareManip(
                $query,
                array('integer', 'integer', 'integer', 'integer', 'integer', 'integer', 'integer', 'integer', 'integer', 'integer')
            );
        }
 
        return self::$preparedInsertResultRecordStatement;
    }
}