class.ilECSExportManager.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilECSExportManager
{
    protected ilDBInterface $db;

    private static ilECSExportManager $instance;

    private function __construct()
    {
        global $DIC;

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

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

    public function _isExported(int $a_obj_id): bool
    {
        $query = 'SELECT * FROM ecs_export ' .
            'WHERE obj_id = ' . $this->db->quote($a_obj_id, 'integer');
        $res = $this->db->query($query);
        if ($res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return true;
        }
        return false;
    }


    public function _getAllEContentIds(int $a_server_id): array
    {
        $econtent_ids = array();
        $query = "SELECT econtent_id,obj_id FROM ecs_export " .
            'WHERE server_id = ' . $this->db->quote($a_server_id, 'integer');

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

    public function getExportedIds(): array
    {
        $query = "SELECT obj_id FROM ecs_export ";
        $res = $this->db->query($query);
        $obj_ids = array();
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = (int)$row->obj_id;
        }
        return $obj_ids;
    }

    public function getExportedIdsByType(string $a_type): array
    {
        $obj_ids = array();
        $query = "SELECT e.obj_id FROM ecs_export e" .
            " JOIN object_data o ON (e.obj_id = o.obj_id)" .
            " WHERE o.type = " . $this->db->quote($a_type, "text");
        $res = $this->db->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = (int)$row->obj_id;
        }
        return $obj_ids;
    }

    public function getExportServerIds(int $a_obj_id): array
    {
        $query = 'SELECT * FROM ecs_export ' .
            'WHERE obj_id = ' . $this->db->quote($a_obj_id, 'integer');
        $res = $this->db->query($query);

        $sids = array();
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $sids[] = (int) $row->server_id;
        }
        return $sids;
    }

    public function _getExportedIDsByServer(int $a_server_id): array
    {
        $query = "SELECT obj_id FROM ecs_export " .
            'WHERE 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 lookupServerIds(int $a_obj_id): array
    {
        $query = 'SELECT * FROM ecs_export ' .
            'WHERE obj_id = ' . $this->db->quote($a_obj_id, 'integer') . ' ';
        $res = $this->db->query($query);
        $sids = array();
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $sids[] = (int)$row->server_id;
        }
        return $sids;
    }

    public function _deleteEContentIds(int $a_server_id, array $a_ids): bool
    {
        if (!is_array($a_ids) || !count($a_ids)) {
            return true;
        }
        $query = "DELETE FROM ecs_export WHERE " . $this->db->in('econtent_id', $a_ids, false, 'integer') . ' ' .
            'AND server_id = ' . $this->db->quote($a_server_id, 'integer');
        $this->db->manipulate($query);
        return true;
    }

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

    public function _isRemote(int $a_server_id, int $a_econtent_id): bool
    {
        $query = "SELECT obj_id FROM ecs_export " .
            "WHERE econtent_id = " . $this->db->quote($a_econtent_id, 'integer') . " " .
            'AND server_id = ' . $this->db->quote($a_server_id, 'integer');
        $res = $this->db->query($query);
        if ($res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return false;
        }
        return true;
    }
}