IliasDBEmployeeTalkSeriesRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Modules\EmployeeTalk\TalkSeries\Repository;

use ILIAS\Modules\EmployeeTalk\TalkSeries\Entity\EmployeeTalkSerieSettings;
use ilObjEmployeeTalkSeries;
use ilObjUser;
use ilDBInterface;
use ILIAS\Modules\EmployeeTalk\TalkSeries\DTO\EmployeeTalkSerieSettingsDto;

final class IliasDBEmployeeTalkSeriesRepository
{
    private ilObjUser $currentUser;
    private ilDBInterface $database;

    public function __construct(ilObjUser $currentUser, ilDBInterface $database)
    {
        $this->currentUser = $currentUser;
        $this->database = $database;
    }

    public function findByOwnerAndEmployee(): array
    {
        $userId = $this->currentUser->getId();

        //TODO: Alter table talks and store series id, which makes the
        $result = $this->database->query("
            SELECT DISTINCT od.obj_id AS objId, oRef.ref_id AS refId
            FROM (
                SELECT tree.parent AS parent, talk.employee AS employee
                FROM etal_data AS talk
                     INNER JOIN object_reference AS oRef ON oRef.obj_id = talk.object_id
                     INNER JOIN tree ON tree.child = oRef.ref_id
                WHERE oRef.deleted IS NULL
                ) AS talk
            INNER JOIN object_reference AS oRef ON oRef.ref_id = talk.parent
            INNER JOIN object_data AS od ON od.obj_id = oRef.obj_id
            WHERE od.type = 'tals' AND (talk.employee = " . $this->database->quote($userId, 'integer') .
            " OR od.owner = " . $this->database->quote($userId, 'integer') .
            ") AND oRef.deleted is null");

        $talkSeries = [];
        while ($row = $result->fetchObject()) {
            $talkSeries[] = new ilObjEmployeeTalkSeries((int) $row->refId, true);
        }

        return $talkSeries;
    }

    public function storeEmployeeTalkSerieSettings(EmployeeTalkSerieSettingsDto $settingsDto): void
    {
        $activeRecord = new EmployeeTalkSerieSettings();

        $activeRecord->setId($settingsDto->getObjectId());
        $activeRecord->setEditingLocked((int) $settingsDto->isLockedEditing());
        $activeRecord->store();
    }

    public function readEmployeeTalkSerieSettings(int $obj_id): EmployeeTalkSerieSettingsDto
    {
        $activeRecord = EmployeeTalkSerieSettings::findOrGetInstance($obj_id);
        $activeRecord->setId($obj_id);

        return new EmployeeTalkSerieSettingsDto($obj_id, (bool) $activeRecord->getEditingLocked());
    }

    public function deleteEmployeeTalkSerieSettings(int $obj_id): void
    {
        $activeRecord = EmployeeTalkSerieSettings::findOrGetInstance($obj_id);
        $activeRecord->delete();
    }
}