TeamDBRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Exercise\Team;

use ILIAS\Exercise\InternalDataService;

class TeamDBRepository
{
    protected InternalDataService $data;
    protected \ilDBInterface $db;

    public function __construct(
        \ilDBInterface $db,
        InternalDataService $data
    ) {
        $this->db = $db;
        $this->data = $data;
    }

    public function create(): int
    {
        $id = $this->db->nextId("il_exc_team");
        $this->db->insert("exc_team_data", [
            "id" => ["integer", $id]
        ]);
        return $id;
    }

    public function addUser(int $team_id, int $ass_id, int $user_id): void
    {
        $this->db->insert("il_exc_team", [
            "id" => ["integer", $team_id],
            "ass_id" => ["integer", $ass_id],
            "user_id" => ["integer", $user_id]
        ]);
    }

    public function removeUser(int $team_id, int $ass_id, int $user_id): void
    {
        $this->db->manipulateF(
            "DELETE FROM il_exc_team WHERE " .
            " id = %s AND ass_id = %s AND user_id = %s",
            ["integer", "integer", "integer"],
            [
                $team_id,
                $ass_id,
                $user_id
            ]
        );
    }

    public function getMembers(int $team_id): \Generator
    {
        $set = $this->db->queryF(
            "SELECT * FROM il_exc_team " .
            " WHERE id = %s ",
            ["integer"],
            [$team_id]
        );
        while ($rec = $this->db->fetchAssoc($set)) {
            yield $this->data->teamMember(
                (int) $rec["id"],
                (int) $rec["ass_id"],
                (int) $rec["user_id"]
            );
        }
    }

    public function getTeamForMember(int $ass_id, int $user_id): ?int
    {
        $set = $this->db->queryF(
            "SELECT id FROM il_exc_team " .
            " WHERE ass_id = %s AND user_id = %s",
            ["integer", "integer"],
            [$ass_id, $user_id]
        );
        $rec = $this->db->fetchAssoc($set);
        if (isset($rec["id"])) {
            return (int) $rec["id"];
        }
        return null;
    }

    public function getAllMemberIdsOfAssignment(int $assignment_id): \Generator
    {
        $set = $this->db->queryF(
            "SELECT DISTINCT user_id FROM il_exc_team " .
            " WHERE ass_id = %s ",
            ["integer"],
            [$assignment_id]
        );
        while ($rec = $this->db->fetchAssoc($set)) {
            yield (int) $rec["user_id"];
        }
    }

    public function getUserTeamMap(int $assignment_id): array
    {
        $map = [];
        $set = $this->db->queryF(
            "SELECT * FROM il_exc_team " .
            " WHERE ass_id = %s ",
            ["integer"],
            [$assignment_id]
        );
        while ($rec = $this->db->fetchAssoc($set)) {
            $map[(int) $rec["user_id"]] = (int) $rec["id"];
        }
        return $map;
    }

    public function getAssignmentForTeam(int $team_id): int
    {
        $set = $this->db->queryF(
            "SELECT ass_id FROM il_exc_team " .
            " WHERE id = %s ",
            ["integer"],
            [$team_id]
        );
        $rec = $this->db->fetchAssoc($set);
        return (int) ($rec["ass_id"] ?? 0);
    }

    public function getTeamIdsOfAssignment(int $ass_id): array
    {
        $set = $this->db->queryF(
            "SELECT DISTINCT(id) FROM il_exc_team " .
            " WHERE ass_id = %s ",
            ["integer"],
            [$ass_id]
        );
        $team_ids = [];
        while ($rec = $this->db->fetchAssoc($set)) {
            $team_ids[] = (int) $rec["id"];
        }
        return $team_ids;
    }

    public function deleteTeam(int $team_id): void
    {
        $this->db->manipulateF(
            "DELETE FROM il_exc_team WHERE " .
            " id = %s ",
            ["integer"],
            [
                $team_id
            ]
        );
        $this->db->manipulateF(
            "DELETE FROM exc_team_data WHERE " .
            " id = %s ",
            ["integer"],
            [
                $team_id
            ]
        );
    }

    public function deleteTeamLog(int $team_id): void
    {
        $this->db->manipulateF(
            "DELETE FROM il_exc_team_log WHERE " .
            " team_id = %s ",
            ["integer"],
            [
                $team_id
            ]
        );
    }

}