class.ilECSCmsTreeCommandQueueHandler.php

Go to the documentation of this file.

<?php

/* Copyright (c) 1998-2009 ILIAS open source, Extended GPL, see docs/LICENSE */

include_once './Services/WebServices/ECS/interfaces/interface.ilECSCommandQueueHandler.php';

class ilECSCmsTreeCommandQueueHandler implements ilECSCommandQueueHandler
{
    protected $log;
    
    private $server = null;
    private $mid = 0;
    
    
    public function __construct(ilECSSetting $server)
    {
        $this->log = $GLOBALS['DIC']->logger()->wsrv();
        
        $this->server = $server;
        $this->init();
    }
    
    public function getServer()
    {
        return $this->server;
    }


    public function handleCreate(ilECSSetting $server, $a_content_id)
    {
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsData.php';
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsTree.php';
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSDirectoryTreeConnector.php';
        
        $this->log->debug('ECS cms tree create');
        

        try {
            $dir_reader = new ilECSDirectoryTreeConnector($this->getServer());
            $res = $dir_reader->getDirectoryTree($a_content_id);
            $nodes = $res->getResult();
            
            if ($this->log->isHandling(ilLogLevel::DEBUG)) {
                $this->log->dump($nodes, ilLogLevel::DEBUG);
            }
        } catch (ilECSConnectorException $e) {
            $this->log->error('Tree creation failed  with mesage ' . $e->getMessage());
            return false;
        }
        
        $cms_tree = $nodes;
        $data = new ilECSCmsData();
        $data->setServerId($server->getServerId());
        $data->setMid($this->mid);
        $data->setCmsId($cms_tree->rootID);
        $data->setTreeId($a_content_id);
        $data->setTitle($cms_tree->directoryTreeTitle);
        $data->setTerm($cms_tree->term);
        $data->save();

        $tree = new ilECSCmsTree($a_content_id);
        $tree->insertRootNode($a_content_id, $data->getObjId());
        $tree->setRootId($data->getObjId());
        
        
        foreach ((array) $cms_tree->nodes as $node) {
            // Add data entry
            $data = new ilECSCmsData();
            $data->setServerId($this->getServer()->getServerId());
            $data->setMid($this->mid);
            $data->setCmsId($node->id);
            $data->setTreeId($a_content_id);
            $data->setTitle($node->title);
            $data->setTerm($node->term);
            $data->save();

            // add to tree
            if ($node->parent->id) {
                $parent_id = ilECSCmsData::lookupObjId(
                    $this->getServer()->getServerId(),
                    $this->mid,
                    $a_content_id,
                    $node->parent->id
                );
                $tree->insertNode($data->getObjId(), $parent_id);
            }
        }
        return true;
    }

    public function handleDelete(ilECSSetting $server, $a_content_id)
    {
        $this->log->debug('ECS cms tree delete');
        
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsData.php';
        $data = new ilECSCmsData();
        $data->setServerId($this->getServer()->getServerId());
        $data->setMid($this->mid);
        $data->setTreeId($a_content_id);
        $data->deleteTree();
        
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsTree.php';
        $tree = new ilECSCmsTree($a_content_id);
        $tree->deleteTree($tree->getNodeData(ilECSCmsTree::lookupRootId($a_content_id)));
        
        include_once './Services/WebServices/ECS/classes/Mapping/class.ilECSNodeMappingAssignments.php';
        ilECSNodeMappingAssignments::deleteMappings(
            $this->getServer()->getServerId(),
            $this->mid,
            $a_content_id
        );
        return true;
    }

    public function handleUpdate(ilECSSetting $server, $a_content_id)
    {
        $this->log->debug('ECS cms tree update');
        
        
        // 1)  Mark all nodes as deleted
        // 2a) Delete cms tree
        // 2)  Add cms tree table entries
        // 2)  Replace the cms data table entries
        // 3)  Insert deleted tree nodes in tree
        // 4)  Sync tree
        
        try {
            include_once './Services/WebServices/ECS/classes/Tree/class.ilECSDirectoryTreeConnector.php';
            $dir_reader = new ilECSDirectoryTreeConnector($this->getServer());
            $res = $dir_reader->getDirectoryTree($a_content_id);
            $nodes = $res->getResult();
            if ($this->log->isHandling(ilLogLevel::DEBUG)) {
                $this->log->dump($nodes, ilLogLevel::DEBUG);
            }
        } catch (ilECSConnectorException $e) {
            $GLOBALS['ilLog']->write(__METHOD__ . ': Tree creation failed  with mesage ' . $e->getMessage());
            return false;
        }
        
        // read old tree structure
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsTree.php';
        $tree = new ilECSCmsTree($a_content_id);
        
        $root_node = $tree->getNodeData(ilECSCmsTree::lookupRootId($a_content_id));

        $old_nodes = array();
        if ($root_node['child']) {
            $old_nodes = $tree->getSubTree($root_node, true);
        }
        
        if ($this->log->isHandling(ilLogLevel::DEBUG)) {
            $this->log->debug('Old tree data... ');
            $this->log->dump($old_nodes, ilLogLevel::DEBUG);
        }

        // Delete old cms tree
        ilECSCmsTree::deleteByTreeId($a_content_id);
        
        // Mark all nodes in cms data as deleted
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsData.php';
        ilECSCmsData::writeAllDeleted(
           $this->getServer()->getServerId(),
           $this->mid,
           $a_content_id,
           true
       );
       
        // Check for update or new entry
        $cms_tree = $nodes;

        $data_obj_id = ilECSCmsData::lookupObjId(
            $this->getServer()->getServerId(),
            $this->mid,
            $a_content_id,
            $cms_tree->rootID
        );
        
        $data = new ilECSCmsData($data_obj_id);
        $data->setServerId($server->getServerId());
        $data->setMid($this->mid);
        $data->setCmsId($cms_tree->rootID);
        $data->setTreeId($a_content_id);
        $data->setTitle($cms_tree->directoryTreeTitle);
        $data->setTerm($cms_tree->term);

        if ($data_obj_id) {
            $data->setDeleted(false);
            $data->update();
        } else {
            $data->save();
        }

        $tree->insertRootNode($a_content_id, $data->getObjId());
        $tree->setRootId($data->getObjId());
       
        
        foreach ((array) $cms_tree->nodes as $node) {
            $data_obj_id = ilECSCmsData::lookupObjId(
                $this->getServer()->getServerId(),
                $this->mid,
                $a_content_id,
                $node->id
            );
            
            // update data entry
            $data = new ilECSCmsData($data_obj_id);
            $data->setTitle($node->title);
            $data->setTerm($node->term);
            $data->setDeleted(false);
            
            if ($data_obj_id) {
                $data->update();
            } else {
                $data->setCmsId($node->id);
                $data->setMid($this->mid);
                $data->setServerId($this->getServer()->getServerId());
                $data->setTreeId($a_content_id);
                $data->setDeleted(false);
                $data->save();
                
                $data_obj_id = $data->getObjId();
            }
            
            // add to tree
            $parent_id = ilECSCmsData::lookupObjId(
                $this->getServer()->getServerId(),
                $this->mid,
                $a_content_id,
                $node->parent->id
            );
            $tree->insertNode($data->getObjId(), $parent_id);
        }
        
        // Insert deleted nodes in tree
        $deleted = ilECSCmsData::findDeletedNodes(
            $this->getServer()->getServerId(),
            $this->mid,
            $a_content_id
        );
        
        foreach ((array) $deleted as $obj_id) {
            $parent = 0;
            foreach ((array) $old_nodes as $tmp_id => $node) {
                if ($node['child'] == $obj_id) {
                    $parent = $node['parent'];
                    break;
                }
            }
            
            if ($tree->isInTree($parent) and $parent) {
                $tree->insertNode($obj_id, $parent);
            }
        }
        
        // Sync tree
        include_once './Services/WebServices/ECS/classes/Tree/class.ilECSCmsTreeSynchronizer.php';
        $sync = new ilECSCmsTreeSynchronizer(
            $this->getServer(),
            $this->mid,
            $a_content_id
        );
        $sync->sync();
        
        return true;
    }
    
    private function init()
    {
        include_once './Services/WebServices/ECS/classes/class.ilECSParticipantSettings.php';
        $this->mid = ilECSParticipantSettings::loookupCmsMid($this->getServer()->getServerId());
    }
}