class.ilECSImportManager.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilECSImportManager
{
    protected ilDBInterface $db;
    private static ilECSImportManager $instance;

    private function __construct()
    {
        global $DIC;

        $this->db = $DIC->database();
    }

    public static function getInstance(): ilECSImportManager
    {
        if (!isset(self::$instance)) {
            self::$instance = new ilECSImportManager();
        }
        return self::$instance;
    }

    public function lookupContentId($a_server_id, $a_mid, $a_econtent_id): string
    {
        $query = 'SELECT * from ecs_import ' .
                'WHERE server_id = ' . $this->db->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $this->db->quote($a_mid, 'integer') . ' ' .
                'AND econtent_id = ' . $this->db->quote($a_econtent_id, 'text');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->content_id;
        }
        return '';
    }

    public function lookupObjIdByContentId(int $a_server_id, int $a_mid, int $a_content_id, ?string $a_sub_id = null): int
    {
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE content_id = " . $this->db->quote($a_content_id, 'integer') . " " .
            "&& mid = " . $this->db->quote($a_mid, 'integer') . " " .
            '&& server_id = ' . $this->db->quote($a_server_id, 'integer') . ' ';

        if (!is_null($a_sub_id)) {
            $query .= 'AND sub_id = ' . $this->db->quote($a_sub_id, 'text');
        } else {
            $query .= 'AND sub_id IS NULL';
        }
        $res = $this->db->query($query);

        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (int) $row->obj_id;
        }
        return 0;
    }

    public function lookupObjIdsByContentId($a_content_id): array
    {
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE content_id = " . $this->db->quote($a_content_id, 'integer');

        $res = $this->db->query($query);

        $obj_ids = array();
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = $row->obj_id;
        }
        return  $obj_ids;
    }

    public function lookupEContentIdByContentId($a_server_id, $a_mid, $a_content_id): int
    {
        $query = 'SELECT * from ecs_import ' .
                'WHERE server_id = ' . $this->db->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $this->db->quote($a_mid, 'integer') . ' ' .
                'AND content_id = ' . $this->db->quote($a_content_id, 'text');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (int) $row->econtent_id;
        }
        return 0;
    }

    public function getAllImportedRemoteObjects($a_server_id): array
    {
        $all = array();
        $query = "SELECT * FROM ecs_import ei JOIN object_data obd ON ei.obj_id = obd.obj_id " .
            'WHERE server_id = ' . $this->db->quote($a_server_id) . ' ' .
            'AND ' . $this->db->in('type', ilECSUtils::getPossibleRemoteTypes(), false, 'text');
        $res = $this->db->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $all[$row->econtent_id] = $row->obj_id;
        }

        return $all;
    }

    public function _lookupObjIdsByMID($a_server_id, $a_mid): array
    {
        $query = "SELECT * FROM ecs_import " .
            "WHERE mid = " . $this->db->quote($a_mid, 'integer') . " " .
            'AND server_id = ' . $this->db->quote($a_server_id, 'integer');

        $res = $this->db->query($query);
        $obj_ids = [];
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = $row->obj_id;
        }
        return $obj_ids;
    }

    public function _lookupEContentId(int $a_obj_id): string
    {
        $query = "SELECT * FROM ecs_import WHERE obj_id = " . $this->db->quote($a_obj_id, 'integer') . " ";
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->econtent_id;
        }
        return "";
    }

    public function lookupServerId(int $a_obj_id): int
    {
        $query = 'SELECT * FROM ecs_import WHERE obj_id = ' . $this->db->quote($a_obj_id, 'integer');
        $res = $this->db->query($query);
        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (int) $row->server_id;
        }
        return 0;
    }

    public function _lookupObjIds($a_server_id, $a_econtent_id): array
    {
        $query = "SELECT obj_id FROM ecs_import WHERE econtent_id  = " . $this->db->quote($a_econtent_id, 'text') . " " .
            'AND server_id = ' . $this->db->quote($a_server_id, 'integer');
        $res = $this->db->query($query);
        $obj_ids = [];
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = (int) $row->obj_id;
        }
        return $obj_ids;
    }

    public function _lookupObjId(int $a_server_id, string $a_econtent_id, int $a_mid, ?string $a_sub_id = null): int
    {
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE econtent_id = " . $this->db->quote($a_econtent_id, 'text') . " " .
            "AND mid = " . $this->db->quote($a_mid, 'integer') . " " .
            'AND server_id = ' . $this->db->quote($a_server_id, 'integer') . ' ';

        if (!is_null($a_sub_id)) {
            $query .= 'AND sub_id = ' . $this->db->quote($a_sub_id, 'text');
        } else {
            $query .= 'AND sub_id IS NULL';
        }
        $res = $this->db->query($query);

        if ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return (int) $row->obj_id;
        }
        return 0;
    }

    public function _deleteByObjId($a_obj_id): bool
    {
        $query = "DELETE FROM ecs_import " .
            "WHERE obj_id = " . $this->db->quote($a_obj_id, 'integer') . " ";
        $this->db->manipulate($query);
        return true;
    }

    public function deleteByServer(int $a_server_id): void
    {
        $query = 'DELETE FROM ecs_import ' .
            'WHERE server_id = ' . $this->db->quote($a_server_id, 'integer');
        $this->db->manipulate($query);
    }

    public function deleteRessources(int $a_server_id, int $a_mid, array $a_econtent_ids): bool
    {
        $query = 'DELETE FROM ecs_import ' .
                'WHERE server_id = ' . $this->db->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $this->db->quote($a_mid, 'integer') . ' ' .
                'AND ' . $this->db->in('econtent_id', $a_econtent_ids, false, 'text');
        $this->db->manipulate($query);
        return true;
    }

    public function _isImported(int $a_server_id, string $a_econtent_id, int $a_mid, ?string $a_sub_id = null): int
    {
        return $this->_lookupObjId($a_server_id, $a_econtent_id, $a_mid, $a_sub_id);
    }

    public function resetServerId($a_server_id): bool
    {
        $query = 'UPDATE ecs_import SET server_id = ' . $this->db->quote(0, 'integer') .
            ' WHERE server_id = ' . $this->db->quote($a_server_id, 'integer');
        $this->db->manipulate($query);
        return true;
    }
}