class.ilECSImport.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2009 ILIAS open source, Extended GPL, see docs/LICENSE */
 
class ilECSImport
{
    protected $db = null;
 
    protected $server_id = 0;
    protected $obj_id = 0;
    protected $econtent_id = 0;
    protected $content_id = '';
    protected $sub_id = null;
    protected $mid = 0;
    protected $imported = false;
    protected $ecs_id = 0;
 
    public function __construct($a_server_id, $a_obj_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $this->server_id = $a_server_id;
        $this->obj_id = $a_obj_id;
        $this->db = $ilDB;
        $this->read();
    }
    
    public static function lookupContentId($a_server_id, $a_mid, $a_econtent_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = 'SELECT * from ecs_import ' .
                'WHERE server_id = ' . $ilDB->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $ilDB->quote($a_mid, 'integer') . ' ' .
                'AND econtent_id = ' . $ilDB->quote($a_econtent_id, 'text');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->content_id;
        }
        return '';
    }
    
    public static function lookupObjIdByContentId($a_server_id, $a_mid, $a_content_id, $a_sub_id = null)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE content_id = " . $ilDB->quote($a_content_id, 'integer') . " " .
            "AND mid = " . $ilDB->quote($a_mid, 'integer') . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer') . ' ';
        
        if (!is_null($a_sub_id)) {
            $query .= 'AND sub_id = ' . $ilDB->quote($a_sub_id, 'text');
        } else {
            $query .= 'AND sub_id IS NULL';
        }
        $res = $ilDB->query($query);
        
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->obj_id;
        }
        return 0;
    }
    
    public static function lookupObjIdsByContentId($a_content_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE content_id = " . $ilDB->quote($a_content_id, 'integer');
        
        $res = $ilDB->query($query);
        
        $obj_ids = array();
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = $row->obj_id;
        }
        return  $obj_ids;
    }
 
 
    public static function lookupEContentIdByContentId($a_server_id, $a_mid, $a_content_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = 'SELECT * from ecs_import ' .
                'WHERE server_id = ' . $ilDB->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $ilDB->quote($a_mid, 'integer') . ' ' .
                'AND content_id = ' . $ilDB->quote($a_content_id, 'text');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->econtent_id;
        }
        return 0;
    }
    
    public static function getAllImportedRemoteObjects($a_server_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        include_once './Services/WebServices/ECS/classes/class.ilECSUtils.php';
        
        $query = "SELECT * FROM ecs_import ei JOIN object_data obd ON ei.obj_id = obd.obj_id " .
            'WHERE server_id = ' . $ilDB->quote($a_server_id) . ' ' .
            'AND ' . $ilDB->in('type', ilECSUtils::getPossibleRemoteTypes(), false, 'text');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $all[$row->econtent_id] = $row->obj_id;
        }
        
        return $all ? $all : array();
    }
    
    public static function _lookupObjIdsByMID($a_server_id, $a_mid)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT * FROM ecs_import " .
            "WHERE mid = " . $ilDB->quote($a_mid, 'integer') . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer');
 
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = $row->obj_id;
        }
        return $obj_ids ? $obj_ids : array();
    }
    
    public static function _lookupEContentId($a_obj_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT * FROM ecs_import WHERE obj_id = " . $ilDB->quote($a_obj_id, 'integer') . " ";
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->econtent_id;
        }
        return 0;
    }
 
    public static function lookupServerId($a_obj_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $query = 'SELECT * FROM ecs_import WHERE obj_id = ' . $ilDB->quote($a_obj_id, 'integer');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->server_id;
        }
        return 0;
    }
 
 
    public static function _lookupObjIds($a_server_id, $a_econtent_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT obj_id FROM ecs_import WHERE econtent_id  = " . $ilDB->quote($a_econtent_id, 'text') . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $obj_ids[] = $row->obj_id;
        }
        return $obj_ids ? $obj_ids : array();
    }
    
    public static function _lookupObjId($a_server_id, $a_econtent_id, $a_mid, $a_sub_id = null)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT obj_id FROM ecs_import " .
            "WHERE econtent_id = " . $ilDB->quote($a_econtent_id, 'text') . " " .
            "AND mid = " . $ilDB->quote($a_mid, 'integer') . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer') . ' ';
        
        if (!is_null($a_sub_id)) {
            $query .= 'AND sub_id = ' . $ilDB->quote($a_sub_id, 'text');
        } else {
            $query .= 'AND sub_id IS NULL';
        }
        $res = $ilDB->query($query);
        
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->obj_id;
        }
        return 0;
    }
    
    public static function _lookupMID($a_server_id, $a_obj_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT * FROM ecs_emport WHERE obj_id = " . $ilDB->quote($a_obj_id) . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            return $row->mid;
        }
        return 0;
    }
    
    public static function _lookupMIDs($a_server_id, $a_econtent_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT mid FROM ecs_import WHERE econtent_id = " . $ilDB->quote($a_econtent_id, 'text') . " " .
            'AND server_id = ' . $ilDB->quote($a_server_id, 'integer');
        $res = $ilDB->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $mids[] = $row->mid;
        }
        return $mids ? $mids : array();
    }
    
    public static function _deleteByObjId($a_obj_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "DELETE FROM ecs_import " .
            "WHERE obj_id = " . $ilDB->quote($a_obj_id, 'integer') . " ";
        $res = $ilDB->manipulate($query);
        return true;
    }
 
    public static function deleteByServer($a_server_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $query = 'DELETE FROM ecs_import ' .
            'WHERE server_id = ' . $ilDB->quote($a_server_id, 'integer');
        $ilDB->manipulate($query);
    }
    
    public static function deleteRessources($a_server_id, $a_mid, $a_econtent_ids)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = 'DELETE FROM ecs_import ' .
                'WHERE server_id = ' . $ilDB->quote($a_server_id, 'integer') . ' ' .
                'AND mid = ' . $ilDB->quote($a_mid, 'integer') . ' ' .
                'AND ' . $ilDB->in('econtent_id', (array) $a_econtent_ids, false, 'text');
        $ilDB->manipulate($query);
        return true;
    }
 
    
    
    public static function _isImported($a_server_id, $a_econtent_id, $a_mid, $a_sub_id = null)
    {
        return ilECSImport::_lookupObjId($a_server_id, $a_econtent_id, $a_mid, $a_sub_id);
    }
    
    public function setServerId($a_server_id)
    {
        $this->server_id = $a_server_id;
    }
 
    public function getServerId()
    {
        return $this->server_id;
    }
    
    public function setImported($a_status)
    {
        $this->imported = $a_status;
    }
    
    public function setSubId($a_id)
    {
        $this->sub_id = $a_id;
    }
    
    public function getSubId()
    {
        return strlen($this->sub_id) ? $this->sub_id : null;
    }
    
    public function setContentId($a_content_id)
    {
        $this->content_id = $a_content_id;
    }
    
    public function getContentId()
    {
        return $this->content_id;
    }
    
    public function setMID($a_mid)
    {
        $this->mid = $a_mid;
    }
    
    public function getMID()
    {
        return $this->mid;
    }
    
    public function setEContentId($a_id)
    {
        $this->econtent_id = $a_id;
    }
    
    public function getEContentId()
    {
        return $this->econtent_id;
    }
    
    public function save()
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "DELETE FROM ecs_import " .
            "WHERE obj_id = " . $this->db->quote($this->obj_id, 'integer') . " " .
            'AND server_id = ' . $ilDB->quote($this->getServerId(), 'integer');
        $res = $ilDB->manipulate($query);
        
        $query = "INSERT INTO ecs_import (obj_id,mid,econtent_id,sub_id,server_id,content_id) " .
            "VALUES ( " .
            $this->db->quote($this->obj_id, 'integer') . ", " .
            $this->db->quote($this->mid, 'integer') . ", " .
            $this->db->quote($this->econtent_id, 'text') . ", " .
            $this->db->quote($this->getSubId(), 'text') . ', ' .
            $this->db->quote($this->getServerId(), 'integer') . ', ' .
            $this->db->quote($this->getContentId(), 'text') . ' ' .
            ")";
        
        $res = $ilDB->manipulate($query);
        
        return true;
    }
    
    private function read()
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
        
        $query = "SELECT * FROM ecs_import WHERE " .
            "obj_id = " . $this->db->quote($this->obj_id, 'integer') . " " .
            'AND server_id = ' . $ilDB->quote($this->getServerId(), 'integer');
        $res = $this->db->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $this->econtent_id = $row->econtent_id;
            $this->mid = $row->mid;
            $this->sub_id = $row->sub_id;
            $this->content_id = $row->content_id;
        }
    }
    
    public static function resetServerId($a_server_id)
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $query = 'UPDATE ecs_import SET server_id = ' . $ilDB->quote(0, 'integer') .
            ' WHERE server_id = ' . $ilDB->quote($a_server_id, 'integer');
        $ilDB->manipulate($query);
        return true;
    }
    
    
    public function setECSId($a_id)
    {
        $this->ecs_id = $a_id;
    }
}