class.ilCmiXapiDelCron.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
use ILIAS\Cron\Job\Schedule\JobScheduleType;
use ILIAS\Cron\Job\JobResult;
use ILIAS\Cron\CronJob;
 
class ilCmiXapiDelCron extends CronJob
{
    public const JOB_ID = 'xapi_deletion_cron';
 
    protected ?ilCmiXapiLrsType $lrsType;
 
    protected ilCmiXapiDelModel $model;
 
    protected ilLogger $log;
 
    private \ILIAS\DI\Container $dic;
 
    public function __construct()
    {
        global $DIC; /* @var \ILIAS\DI\Container $DIC */
        $this->dic = $DIC;
 
        $DIC->language()->loadLanguageModule('cmix');
 
        $this->log = ilLoggerFactory::getLogger('cmix');
 
        $settings = new ilSetting(self::JOB_ID);
        $lrsTypeId = $settings->get('lrs_type_id', '0');
 
        if ($lrsTypeId) {
            $this->lrsType = new ilCmiXapiLrsType((int) $lrsTypeId);
        } else {
            $this->lrsType = null;
        }
 
        $this->model = ilCmiXapiDelModel::init();
    }
 
    public function getId(): string
    {
        return self::JOB_ID;
    }
 
    public function getTitle(): string
    {
        return $this->dic->language()->txt("cron_xapi_del");
    }
 
    public function getDescription(): string
    {
        return $this->dic->language()->txt("cron_xapi_del_desc");
    }
 
    public function hasAutoActivation(): bool
    {
        return false;
    }
 
    public function hasFlexibleSchedule(): bool
    {
        return true;
    }
 
    public function getDefaultScheduleType(): JobScheduleType
    {
        return JobScheduleType::DAILY;
    }
 
    public function getDefaultScheduleValue(): int
    {
        return 1;
    }
 
    protected function hasLrsType()
    {
        return $this->getLrsType() !== null;
    }
 
    protected function getLrsType()
    {
        return $this->lrsType;
    }
 
    public function run(): JobResult
    {
        global $DIC;
        $cronResult = new JobResult();
        $this->log->debug('run');
 
        // LRS - Ist Client gelöscht?
        // LRS - Wenn Client gelöscht dann nix machen
        // LRS - Wenn Client gelöscht wirklich alle Daten weg?
        // Wenn Objekt gelöscht warum wird es nochmal bei Nutzer aufgeführt (Tabelle gucken)
        // xxx Löschen wenn nut Lernerfahrung anzeigen dann nur anzeigen nicht löschen = kein Datenadmin
 
        /*
        Fall 1:
            * Objekt deleted (in Tabelle xapidel_object eingetragen mit Feld updated=null)
        => xapidel_object aktualisieren mit updated
        => hole alle Daten zu Users aus xxcf_users und die Daten zum lrs und activity_id aus xapidel_object inkl. xxcf_data_types
        => Löschvorgang an LRS-typ schicken
        => wenn's geklappt hat: Zeile aus xxcf_users löschen
        => wenn's für alle user geklappt hat: Zeile aus xxcf_data_settings löschen
        => wenn ggf. auch user gelöscht wurde und der user nur dieses objekt bearbeitet hat, dann lösche auch Zeile in xpidel_user
 
 
        Fall 2:
            * User deleted (in Tabelle xapidel_user eingetragen mit Feld updated=null)
            * Objekt noch vorhanden (kein Eintrag in Tabelle xapidel_object)
        => xapidel_user aktualisieren mit updated
        => hole alle Daten zum User aus xxcf_users und die Daten zum lrs und activity_id aus xxcf_settings inkl. xxcf_data_types
        => Löschvorgang an LRS-typ schicken
        => wenn's geklappt hat: Zeile aus xxcf_users löschen
        => wenn's für alle Objekte, die der User genutzt hat, gelöscht wurde: Zeile in xapidel_user löschen
 
        Fall 3:
            * User deleted (in Tabelle xapidel_user eingetragen mit Feld updated=null)
            * Objekt auch deleted (Eintrag in Tabelle xapidel_object mit updated=null)
            => xapidel_user aktualisieren mit updated
            => xapidel_object aktualisieren mit updated
            => hole alle Daten zum User aus xxcf_users und die Daten zum lrs und activity_id aus xapidel_object inkl. xxcf_data_types
            => Löschvorgang an LRS-typ schicken
            => wenn's geklappt hat: Zeile aus xxcf_users löschen
            => wenn's für alle Objekte, die der User genutzt hat, gelöscht wurde: Zeile in xapidel_user löschen
            => Zeile in Tabelle xapidel_object löschen
 
        */
 
        // Fall 1:
        // check deleted objects where updated = NULL
 
        $newDeletedObjects = $this->model->getNewDeletedXapiObjects();
        //ilLoggerFactory::getRootLogger()->alert(var_export($newDeletedObjects,TRUE));
 
        $deletedObjectData = array();
        $allDone = true;
        foreach ($newDeletedObjects as $deletedObject) {
            $this->log->debug("delete for " . (string) $deletedObject['obj_id']);
            // set object to updated
            $this->model->setXapiObjAsUpdated($deletedObject['obj_id']);
            // delete data
            $deleteRequest = new ilCmiXapiStatementsDeleteRequest(
                (int) $deletedObject['obj_id'],
                (int) $deletedObject['type_id'],
                (string) $deletedObject['activity_id'],
                null,
                ilCmiXapiStatementsDeleteRequest::DELETE_SCOPE_ALL
            );
            $done = $deleteRequest->delete();
            // entry in xxcf_users is already deleted from ilXapiCmi5StatementsDeleteRequest
            // delete in obj_id from xxcf_data_settings
            if ($done) {
                $this->log->debug("deleted data for object: " . (string) $deletedObject['obj_id']);
                $deletedObjectData[] = $deletedObject['obj_id'];
                $this->model->deleteXapiObjectEntry($deletedObject['obj_id']);
            } else {
                $this->log->debug("error: delete data for object: " . (string) $deletedObject['obj_id']);
                $this->model->resetUpdatedXapiObj($deletedObject['obj_id']);
                $allDone = false;
            }
        }
 
        // Fall 2:
        // check deleted users where updated = NULL
        $newDeletedUsers = $this->model->getNewDeletedUsers();
        foreach ($newDeletedUsers as $deletedUser) {
            $usrId = $deletedUser['usr_id'];
            $objId = $deletedUser['obj_id'];
            // set user to updated
            $this->model->setUserAsUpdated($usrId);
            $xapiObject = $this->model->getXapiObjectData($objId);
            // check if all object data already successfully deleted in previous step within this run, because object was also deleted
            if (in_array($objId, $deletedObjectData)) {
                $this->log->debug("nothing to do, because of complete object data deletion in previous step");
                continue;
            }
            $deleteRequest = new ilCmiXapiStatementsDeleteRequest(
                (int) $objId,
                (int) $xapiObject['lrs_type_id'],
                (string) $xapiObject['activity_id'],
                $usrId,
                ilCmiXapiStatementsDeleteRequest::DELETE_SCOPE_OWN
            );
            $done = $deleteRequest->delete();
            // entry in xxcf_users is already deleted from ilXapiCmi5StatementsDeleteRequest
            if ($done) {
                $this->model->deleteUserEntry($usrId, $objId);
                $this->log->debug("deleted object " . (string) $objId . " data for user " . (string) $usrId);
            } else {
                $this->log->debug("error deleting object " . (string) $objId . " data for user " . (string) $usrId);
                $this->model->resetUpdatedXapiUser($usrId, $objId);
                $allDone = false;
            }
        }
 
        if ($allDone) {
            $cronResult->setStatus(JobResult::STATUS_OK);
        } else {
            $cronResult->setStatus(JobResult::STATUS_FAIL);
        }
        return $cronResult;
    }
}