class.ilObjDataCollection.php

Go to the documentation of this file.

<?php

class ilObjDataCollection extends ilObject2
{
    private bool $is_online = false;
    private string $rating = "";
    private string $approval = "";
    private string $public_notes = "";
    private string $notification = "";

    protected function initType(): void
    {
        $this->type = "dcl";
    }

    protected function doRead(): void
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $result = $ilDB->query("SELECT * FROM il_dcl_data WHERE id = " . $ilDB->quote($this->getId(), "integer"));

        $data = $ilDB->fetchObject($result);
        if ($data) {
            $this->setOnline($data->is_online);
            $this->setRating($data->rating);
            $this->setApproval($data->approval);
            $this->setPublicNotes($data->public_notes);
            $this->setNotification($data->notification);
        }
    }

    protected function doCreate(bool $clone_mode = false): void
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $ilLog = $DIC['ilLog'];

        $ilLog->write('doCreate');

        if (!$clone_mode) {
            //Create Main Table - The title of the table is per default the title of the data collection object
            $main_table = ilDclCache::getTableCache();
            $main_table->setObjId($this->getId());
            $main_table->setTitle($this->getTitle());
            $main_table->setAddPerm(1);
            $main_table->setEditPerm(1);
            $main_table->setDeletePerm(0);
            $main_table->setDeleteByOwner(1);
            $main_table->setEditByOwner(1);
            $main_table->setLimited(0);
            $main_table->setIsVisible(true);
            $main_table->doCreate();
        }

        $ilDB->insert(
            "il_dcl_data",
            array(
                "id" => array("integer", $this->getId()),
                "is_online" => array("integer", (int) $this->getOnline()),
                "rating" => array("integer", (int) $this->getRating()),
                "public_notes" => array("integer", (int) $this->getPublicNotes()),
                "approval" => array("integer", (int) $this->getApproval()),
                "notification" => array("integer", (int) $this->getNotification()),
            )
        );
    }

    protected function doDelete(): void
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        foreach ($this->getTables() as $table) {
            $table->doDelete(false, true);
        }

        $query = "DELETE FROM il_dcl_data WHERE id = " . $ilDB->quote($this->getId(), "integer");
        $ilDB->manipulate($query);
    }

    protected function doUpdate(): void
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $ilDB->update(
            "il_dcl_data",
            array(
                "id" => array("integer", $this->getId()),
                "is_online" => array("integer", (int) $this->getOnline()),
                "rating" => array("integer", (int) $this->getRating()),
                "public_notes" => array("integer", (int) $this->getPublicNotes()),
                "approval" => array("integer", (int) $this->getApproval()),
                "notification" => array("integer", (int) $this->getNotification()),
            ),
            array(
                "id" => array("integer", $this->getId()),
            )
        );
    }

    public function sendNotification($a_action, $a_table_id, $a_record_id = null)
    {
        global $DIC;
        $ilUser = $DIC->user();

        // If coming from trash, never send notifications and don't load dcl Object
        if ($this->getRefId() === SYSTEM_FOLDER_ID) {
            return;
        }

        if ($this->getNotification() != 1) {
            return;
        }
        $obj_table = ilDclCache::getTableCache($a_table_id);

        // recipients
        $users = ilNotification::getNotificationsForObject(
            ilNotification::TYPE_DATA_COLLECTION,
            $this->getId(),
            true
        );
        if (!count($users)) {
            return;
        }

        ilNotification::updateNotificationTime(ilNotification::TYPE_DATA_COLLECTION, $this->getId(), $users);

        $link = ilLink::_getLink($this->getRefId());

        // prepare mail content
        // use language of recipient to compose message

        // send mails
        foreach (array_unique($users) as $idx => $user_id) {
            // the user responsible for the action should not be notified
            $record = ilDclCache::getRecordCache($a_record_id);
            $ilDclTable = new ilDclTable($record->getTableId());
            if ($user_id != $ilUser->getId() && $ilDclTable->hasPermissionToViewRecord(filter_input(
                INPUT_GET,
                'ref_id'
            ), $record, $user_id)) {
                // use language of recipient to compose message
                $ulng = ilLanguageFactory::_getLanguageOfUser($user_id);
                $ulng->loadLanguageModule('dcl');

                $subject = sprintf($ulng->txt('dcl_change_notification_subject'), $this->getTitle());
                // update/delete
                $message = $ulng->txt("dcl_hello") . " " . ilObjUser::_lookupFullname($user_id) . ",\n\n";
                $message .= $ulng->txt('dcl_change_notification_dcl_' . $a_action) . ":\n\n";
                $message .= $ulng->txt('obj_dcl') . ": " . $this->getTitle() . "\n\n";
                $message .= $ulng->txt('dcl_table') . ": " . $obj_table->getTitle() . "\n\n";
                $message .= $ulng->txt('dcl_record') . ":\n";
                $message .= "------------------------------------\n";
                if ($a_record_id) {
                    if (!$record->getTableId()) {
                        $record->setTableId($a_table_id);
                    }
                    //                                  $message .= $ulng->txt('dcl_record_id').": ".$a_record_id.":\n";
                    $t = "";

                    if ($tableview_id = $record->getTable()->getFirstTableViewId($this->getRefId(), $user_id)) {
                        $visible_fields = ilDclTableView::find($tableview_id)->getVisibleFields();
                        if (empty($visible_fields)) {
                            continue;
                        }
                        foreach ($visible_fields as $field) {
                            if ($field->isStandardField()) {
                                $value = $record->getStandardFieldPlainText($field->getId());
                            } elseif ($record_field = $record->getRecordField($field->getId())) {
                                $value = $record_field->getPlainText();
                            }

                            if ($value) {
                                $t .= $field->getTitle() . ": " . $value . "\n";
                            }
                        }
                    }
                    $message .= $this->prepareMessageText($t);
                }
                $message .= "------------------------------------\n";
                $message .= $ulng->txt('dcl_changed_by') . ": " . ilUserUtil::getNamePresentation($ilUser->getId())
                    . "\n\n";
                $message .= $ulng->txt('dcl_change_notification_link') . ": " . $link . "\n\n";

                $message .= $ulng->txt('dcl_change_why_you_receive_this_email');

                $mail_obj = new ilMail(ANONYMOUS_USER_ID);
                $mail_obj->appendInstallationSignature(true);
                $mail_obj->enqueue(ilObjUser::_lookupLogin($user_id), "", "", $subject, $message, array());
            } else {
                unset($users[$idx]);
            }
        }
    }

    public function getFirstVisibleTableId(): int
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $ilDB->setLimit(1);
        $only_visible = ilObjDataCollectionAccess::hasWriteAccess($this->ref_id) ? '' : ' AND is_visible = 1 ';
        $result = $ilDB->query(
            'SELECT id FROM il_dcl_table
                    WHERE obj_id = ' . $ilDB->quote($this->getId(), 'integer') .
                    $only_visible . ' ORDER BY -table_order DESC'
        ); //"-table_order DESC" is ASC with NULL last

        // if there's no visible table, fetch first one not visible
        // this is to avoid confusion, since the default of a table after creation is not visible
        if (!$result->numRows() && $only_visible) {
            $ilDB->setLimit(1);
            $result = $ilDB->query(
                'SELECT id FROM il_dcl_table
                        WHERE obj_id = ' . $ilDB->quote($this->getId(), 'integer') . ' ORDER BY -table_order DESC '
            );
        }

        return $ilDB->fetchObject($result)->id;
    }

    public function reorderTables(array $table_order): void
    {
        if ($table_order) {
            $order = 10;
            foreach ($table_order as $title) {
                $table_id = ilDclTable::_getTableIdByTitle($title, $this->getId());
                $table = ilDclCache::getTableCache($table_id);
                $table->setOrder($order);
                $table->doUpdate();
                $order += 10;
            }
        }
    }

    protected function doCloneObject(ilObject2 $new_obj, int $a_target_id, ?int $a_copy_id = null): void
    {
        assert($new_obj instanceof ilObjDataCollection);
        //copy online status if object is not the root copy object
        $cp_options = ilCopyWizardOptions::_getInstance($a_copy_id);

        if (!$cp_options->isRootNode($this->getRefId())) {
            $new_obj->setOnline(true);
        }

        $new_obj->cloneStructure($this->getRefId());
    }

    public function cloneStructure(int $original_id): void
    {
        $original = new ilObjDataCollection($original_id);

        $this->setApproval($original->getApproval());
        $this->setNotification($original->getNotification());
        $this->setPublicNotes($original->getPublicNotes());
        $this->setRating($original->getRating());

        // delete old tables.
        foreach ($this->getTables() as $table) {
            $table->doDelete();
        }

        // add new tables.
        foreach ($original->getTables() as $table) {
            $new_table = new ilDclTable();
            $new_table->setObjId($this->getId());
            $new_table->cloneStructure($table);
        }

        // mandatory for all cloning functions
        ilDclCache::setCloneOf($original_id, $this->getId(), ilDclCache::TYPE_DATACOLLECTION);

        foreach ($this->getTables() as $table) {
            $table->afterClone();
        }
    }

    public function setOnline($a_val): void
    {
        $this->is_online = $a_val;
    }

    public function getOnline(): bool
    {
        return $this->is_online;
    }

    public function setRating(string $a_val): void
    {
        $this->rating = $a_val;
    }

    public function getRating(): string
    {
        return $this->rating;
    }

    public function setPublicNotes(string $a_val)
    {
        $this->public_notes = $a_val;
    }

    public function getPublicNotes(): string
    {
        return $this->public_notes;
    }

    public function setApproval(string $a_val): void
    {
        $this->approval = $a_val;
    }

    public function getApproval(): string
    {
        return $this->approval;
    }

    public function setNotification(string $a_val): void
    {
        $this->notification = $a_val;
    }

    public function getNotification(): string
    {
        return $this->notification;
    }

    public static function _hasWriteAccess(int $ref): bool
    {
        return ilObjDataCollectionAccess::hasWriteAccess($ref);
    }

    public static function _hasReadAccess(int $ref): bool
    {
        return ilObjDataCollectionAccess::hasReadAccess($ref);
    }

    public function getTables(): array
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];

        $query = "SELECT id FROM il_dcl_table WHERE obj_id = " . $ilDB->quote($this->getId(), "integer") .
            " ORDER BY -table_order DESC";
        $set = $ilDB->query($query);
        $tables = array();

        while ($rec = $ilDB->fetchAssoc($set)) {
            $tables[$rec['id']] = ilDclCache::getTableCache($rec['id']);
        }

        return $tables;
    }

    public function getTableById(int $table_id): ilDclTable
    {
        return ilDclCache::getTableCache($table_id);
    }

    public function getVisibleTables(): array
    {
        $tables = array();
        foreach ($this->getTables() as $table) {
            if ($table->getIsVisible() && $table->getVisibleTableViews($this->ref_id)) {
                $tables[$table->getId()] = $table;
            }
        }

        return $tables;
    }

    public static function _hasTableByTitle(string $title, int $obj_id): bool
    {
        global $DIC;
        $ilDB = $DIC['ilDB'];
        $result = $ilDB->query(
            'SELECT * FROM il_dcl_table WHERE obj_id = ' . $ilDB->quote($obj_id, 'integer') . ' AND title = '
            . $ilDB->quote($title, 'text')
        );

        return ($ilDB->numRows($result)) ? true : false;
    }

    public function getStyleSheetId(): int
    {
        return 0;
    }

    public function prepareMessageText(string $body): string
    {
        if (preg_match_all('/<.*?br.*?>/', $body, $matches)) {
            $matches = array_unique($matches[0]);
            $brNewLineMatches = array_map(static function ($match): string {
                return $match . "\n";
            }, $matches);

            //Remove carriage return to guarantee all new line can be properly found
            $body = str_replace("\r", '', $body);
            //Replace occurrence of <br> + \n with a single \n
            $body = str_replace($brNewLineMatches, "\n", $body);
            //Replace additional <br> with a \”
            $body = str_replace($matches, "\n", $body);
            //Revert removal of carriage return
            return str_replace("\n", "\r\n", $body);
        }
        return $body;
    }
}