Synchronize member assignments. More...

Inheritance diagram for ilECSCmsCourseMemberCommandQueueHandler:

Collaboration diagram for ilECSCmsCourseMemberCommandQueueHandler:

Public Member Functions
	__construct (ilECSSetting $server)
	Constructor. More...

	getServer ()
	Get server. More...

	getMid ()
	get current mid More...

	getMappingSettings ()
	Get mapping settings. More...

	checkAllocationActivation (ilECSSetting $server, $a_content_id)
	Check if course allocation is activated for one recipient of the. More...

	handleCreate (ilECSSetting $server, $a_content_id)
	Handle create. More...

	handleDelete (ilECSSetting $server, $a_content_id)
	Handle delete. More...

	handleUpdate (ilECSSetting $server, $a_content_id)
	Handle update. More...

	handleCreate (ilECSSetting $server, $a_content_id)
	Handle create event. More...

	handleUpdate (ilECSSetting $server, $a_content_id)
	Handle update. More...

	handleDelete (ilECSSetting $server, $a_content_id)
	Handle delete action. More...

Protected Member Functions
	doUpdate ($a_content_id, $course_member)
	Perform update. More...

	readAssignments ($course, $course_member)
	Read assignments for all parallel groups. More...

	refreshAssignmentStatus ($course_member, $obj_id, $sub_id, $assigned)
	Refresh status of course member assignments. More...

	lookupRole ($role_value, $a_obj_type)
	Lookup local role by assignment. More...

Protected Attributes
	$log

Private Member Functions
	createMember ($a_person_id)
	Create user account. More...

	readCourseMember (ilECSSetting $server, $a_content_id)
	Read course from ecs. More...

	readCourse ($course_member)
	Read course from ecs. More...

Private Attributes
	$server = null

	$mid = 0

	$mapping = null

Detailed Description

Synchronize member assignments.

Author: Stefan Meyer smeye.nosp@m.r.il.nosp@m.ias@g.nosp@m.mx.d.nosp@m.e

Definition at line 15 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

Constructor & Destructor Documentation

◆ __construct()

ilECSCmsCourseMemberCommandQueueHandler::__construct ( ilECSSetting $server )

Constructor.

Definition at line 30 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        $this->log = $GLOBALS['DIC']->logger()->wsrv();
        $this->server = $server;
    }

References $GLOBALS, and $server.

Member Function Documentation

◆ checkAllocationActivation()

ilECSCmsCourseMemberCommandQueueHandler::checkAllocationActivation	(	ilECSSetting	$server,
			$a_content_id
	)

Check if course allocation is activated for one recipient of the.

Parameters

ilECSSetting	$server
type	$a_content_id

Definition at line 69 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        try {
            include_once './Services/WebServices/ECS/classes/Course/class.ilECSCourseMemberConnector.php';
            $crsm_reader = new ilECSCourseMemberConnector($server);
            $details = $crsm_reader->getCourseMember($a_content_id, true);
            $this->mid = $details->getMySender();
            
            // Check if import is enabled
            include_once './Services/WebServices/ECS/classes/class.ilECSParticipantSetting.php';
            $part = ilECSParticipantSetting::getInstance($this->getServer()->getServerId(), $this->getMid());
            if (!$part->isImportEnabled()) {
                $this->log->warning('Import disabled for mid ' . $this->getMid());
                return false;
            }
            // Check course allocation setting
            include_once './Services/WebServices/ECS/classes/Mapping/class.ilECSNodeMappingSettings.php';
            $this->mapping = ilECSNodeMappingSettings::getInstanceByServerMid(
                $this->getServer()->getServerId(),
                $this->getMid()
                );
            return $this->getMappingSettings()->isCourseAllocationEnabled();
        } catch (ilECSConnectorException $e) {
            $this->log->error('Reading course member details failed with message ' . $e->getMessage());
            return false;
        }
    }

References Vendor\Package\$e, $server, ilECSParticipantSetting\getInstance(), ilECSNodeMappingSettings\getInstanceByServerMid(), getMappingSettings(), getMid(), and getServer().

Referenced by handleCreate(), and handleUpdate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ createMember()

ilECSCmsCourseMemberCommandQueueHandler::createMember ( $a_person_id )

private

Create user account.

Parameters

type $a_person_id

Definition at line 452 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        if (!$this->getMappingSettings() instanceof ilECSNodeMappingSettings) {
            $this->log->warning('Node mapping settings not initialized.');
        }
        $auth_mode = $this->getMappingSettings()->getAuthMode();
 
        if (
            $this->getMappingSettings()->getAuthMode() ==
            ilAuthUtils::_getAuthModeName(AUTH_SHIBBOLETH)
        ) {
            $this->log->info('Not handling direct user creation for auth mode: ' . $auth_mode);
            return false;
        }
        if (substr($auth_mode, 0, 4) !== 'ldap') {
            $this->log->info('Not handling direct user creation for auth mode: ' . $auth_mode);
            return false;
        }
 
        try {
            include_once './Services/LDAP/classes/class.ilLDAPServer.php';
            $server = ilLDAPServer::getInstanceByServerId(ilLDAPServer::_getFirstActiveServer());
            $server->doConnectionCheck();
 
            include_once './Services/LDAP/classes/class.ilLDAPQuery.php';
            $query = new ilLDAPQuery($server);
            $query->bind(IL_LDAP_BIND_DEFAULT);
            
            $users = $query->fetchUser($a_person_id, true);
            if ($users) {
                include_once './Services/User/classes/class.ilUserCreationContext.php';
                ilUserCreationContext::getInstance()->addContext(ilUserCreationContext::CONTEXT_LDAP);
 
                include_once './Services/LDAP/classes/class.ilLDAPAttributeToUser.php';
                $xml = new ilLDAPAttributeToUser($server);
                $xml->setNewUserAuthMode($server->getAuthenticationMappingKey());
                $xml->setUserData($users);
                $xml->refresh();
            }
        } catch (ilLDAPQueryException $exc) {
            $this->log->error($exc->getMessage());
        }
    }

References $query, $server, $xml, ilAuthUtils\_getAuthModeName(), ilLDAPServer\_getFirstActiveServer(), AUTH_SHIBBOLETH, ilUserCreationContext\CONTEXT_LDAP, ilUserCreationContext\getInstance(), ilLDAPServer\getInstanceByServerId(), getMappingSettings(), and IL_LDAP_BIND_DEFAULT.

Referenced by refreshAssignmentStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ doUpdate()

ilECSCmsCourseMemberCommandQueueHandler::doUpdate	(	$a_content_id,
		$course_member
	)

protected

Perform update.

Parameters

type $a_content_id

Definition at line 162 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        $this->log->debug('Starting ecs  member update');
        
        $course_id = (int) $course_member->lectureID;
        if (!$course_id) {
            $this->log->warning('Missing course id');
            return false;
        }
        include_once './Services/WebServices/ECS/classes/class.ilECSImport.php';
        $this->log->debug('sid: ' . $this->getServer()->getServerId() . ' course_id: ' . $course_id . ' mid: ' . $this->mid);
        //$crs_obj_id = ilECSImport::_lookupObjId($this->getServer()->getServerId(), $course_id, $this->mid);
        $crs_obj_id = ilECSImport::lookupObjIdByContentId($this->getServer()->getServerId(), $this->mid, $course_id);
        
        if (!$crs_obj_id) {
            $this->log->info('No main course created. Group scenario >= 3 ?');
        }
        
        $course = $this->readCourse($course_member);
        // Lookup already imported users and update their status
        $assignments = $this->readAssignments($course, $course_member);
        
        $this->log->debug('Parallel group assignments');
        $this->log->dump($assignments, ilLogLevel::DEBUG);
        $this->log->debug('------------------ End assignemtns');
        
        // iterate through all parallel groups
        foreach ((array) $assignments as $cms_id => $assigned) {
            $sub_id = ($cms_id == $course_id) ? null : $cms_id;
            
            $this->log->debug('sub id is ' . $sub_id . ' for ' . $cms_id);
            
            include_once './Services/WebServices/ECS/classes/class.ilECSImport.php';
            $obj_id = ilECSImport::lookupObjIdByContentId(
                $this->getServer()->getServerId(),
                $this->getMid(),
                $course_id,
                $sub_id
            );
                    
            $this->refreshAssignmentStatus($course_member, $obj_id, $sub_id, $assigned);
        }
        return true;
    }

References $mid, ilLogLevel\DEBUG, getMid(), getServer(), if, ilECSImport\lookupObjIdByContentId(), readAssignments(), readCourse(), and refreshAssignmentStatus().

Referenced by handleCreate(), and handleUpdate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getMappingSettings()

ilECSCmsCourseMemberCommandQueueHandler::getMappingSettings ( )

Get mapping settings.

Returns: ilECSnodeMappingSettings

Definition at line 59 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        return $this->mapping;
    }

References $mapping.

Referenced by checkAllocationActivation(), createMember(), lookupRole(), and refreshAssignmentStatus().

Here is the caller graph for this function:

◆ getMid()

ilECSCmsCourseMemberCommandQueueHandler::getMid ( )

get current mid

Returns: int

Definition at line 49 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        return $this->mid;
    }

References $mid.

Referenced by checkAllocationActivation(), doUpdate(), and readCourse().

Here is the caller graph for this function:

◆ getServer()

ilECSCmsCourseMemberCommandQueueHandler::getServer ( )

Get server.

Returns: ilECSServerSetting

Definition at line 40 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        return $this->server;
    }

References $server.

Referenced by checkAllocationActivation(), doUpdate(), readCourse(), and refreshAssignmentStatus().

Here is the caller graph for this function:

◆ handleCreate()

ilECSCmsCourseMemberCommandQueueHandler::handleCreate	(	ilECSSetting	$server,
			$a_content_id
	)

Handle create.

Parameters

ilECSSetting	$server
type	$a_content_id

Implements ilECSCommandQueueHandler.

Definition at line 103 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        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/Course/class.ilECSCourseConnector.php';
 
        if (!$this->checkAllocationActivation($server, $a_content_id)) {
            return true;
        }
        try {
            //$course = $this->readCourse($server, $a_content_id);
            $course_member = $this->readCourseMember($server, $a_content_id);
            $this->doUpdate($a_content_id, $course_member);
            return true;
        } catch (ilECSConnectorException $e) {
            $this->log->error('Course member creation failed  with mesage ' . $e->getMessage());
            return false;
        }
        return true;
    }

References Vendor\Package\$e, checkAllocationActivation(), doUpdate(), and readCourseMember().

Here is the call graph for this function:

◆ handleDelete()

ilECSCmsCourseMemberCommandQueueHandler::handleDelete	(	ilECSSetting	$server,
			$a_content_id
	)

Handle delete.

Parameters

ilECSSetting	$server
type	$a_content_id

Implements ilECSCommandQueueHandler.

Definition at line 129 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        // nothing todo
        return true;
    }

◆ handleUpdate()

ilECSCmsCourseMemberCommandQueueHandler::handleUpdate	(	ilECSSetting	$server,
			$a_content_id
	)

Handle update.

Parameters

ilECSSetting	$server
type	$a_content_id

Implements ilECSCommandQueueHandler.

Definition at line 140 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        if (!$this->checkAllocationActivation($server, $a_content_id)) {
            return true;
        }
        
        try {
            $course_member = $this->readCourseMember($server, $a_content_id);
            $this->doUpdate($a_content_id, $course_member);
            return true;
        } catch (ilECSConnectorException $e) {
            $this->log->error('Course member update failed  with mesage ' . $e->getMessage());
            return false;
        }
        return true;
    }

References Vendor\Package\$e, checkAllocationActivation(), doUpdate(), and readCourseMember().

Here is the call graph for this function:

◆ lookupRole()

ilECSCmsCourseMemberCommandQueueHandler::lookupRole	(	$role_value,
		$a_obj_type
	)

protected

Lookup local role by assignment.

Parameters

string $role_value

Returns: int

Definition at line 410 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        $role_mappings = $this->getMappingSettings()->getRoleMappings();
        
        /* Zero is an allowed value */
        if (!$role_value) {
            $this->log->debug('No role assignment attribute: role');
        }
        foreach ($role_mappings as $name => $map) {
            $this->log->debug('Role "name" is ' . $name);
            
            // map is a string of ids seperated by ","
            $exploded_map = (array) explode(',', $map);
            if (in_array($role_value, $exploded_map)) {
                switch ($name) {
                    case IL_CRS_ADMIN:
                    case IL_CRS_TUTOR:
                    case IL_CRS_MEMBER:
                        if ($a_obj_type == 'crs') {
                            $this->log->debug('Role: ' . $role_value . ' maps: ' . $exploded_map);
                            return $name;
                        }
                        break;
                        
                    case IL_GRP_ADMIN:
                    case IL_GRP_MEMBER:
                        if ($a_obj_type == 'grp') {
                            $this->log->debug('Role: ' . $role_value . ' maps: ' . $exploded_map);
                            return $name;
                        }
                        break;
                }
            }
        }
        $this->log->info('No role assignment mapping for role ' . $role_value);
        return 0;
    }

References $name, getMappingSettings(), IL_CRS_ADMIN, IL_CRS_MEMBER, IL_CRS_TUTOR, IL_GRP_ADMIN, and IL_GRP_MEMBER.

Referenced by refreshAssignmentStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ readAssignments()

ilECSCmsCourseMemberCommandQueueHandler::readAssignments	(	$course,
		$course_member
	)

protected

Read assignments for all parallel groups.

Parameters

type	$course
type	$course_member

Definition at line 212 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        $put_in_course = true;
        
        include_once './Services/WebServices/ECS/classes/Mapping/class.ilECSMappingUtils.php';
        switch ((int) $course->groupScenario) {
            case ilECSMappingUtils::PARALLEL_ONE_COURSE:
                $this->log->debug('Parallel group scenario one course.');
                $put_in_course = true;
                break;
                
            case ilECSMappingUtils::PARALLEL_GROUPS_IN_COURSE:
                $this->log->debug('Parallel group scenario groups in courses.');
                $put_in_course = false;
                break;
                
            case ilECSMappingUtils::PARALLEL_ALL_COURSES:
                $this->log->debug('Parallel group scenario only courses.');
                $put_in_course = false;
                break;
            
            default:
                $this->log->debug('Parallel group scenario undefined.');
                $put_in_course = true;
                break;
        }
        
        $course_id = $course_member->lectureID;
        $assigned = array();
        foreach ((array) $course_member->members as $member) {
            $assigned[$course_id][$member->personID] = array(
                'id' => $member->personID,
                'role' => $member->role
            );
            if ((int) $course->groupScenario == ilECSMappingUtils::PARALLEL_ONE_COURSE) {
                $this->log->debug('Group scenarion "one course". Ignoring group assignments');
                continue;
            }
            
            foreach ((array) $member->groups as $pgroup) {
                // the sequence number in the course ressource
                $sequence_number = (int) $pgroup->num;
                // find parallel group with by sequence number
                $tmp_pgroup = $course->groups[$sequence_number];
                if (is_object($tmp_pgroup)) {
                    $pgroup_id = $tmp_pgroup->id;
                }
                if (strlen($pgroup_id)) {
                    $this->log->debug('Found parallel group with id: ' . $pgroup_id . ': for sequence number: ' . $sequence_number);
                    
                    // @todo check hierarchy of roles
                    $assigned[$pgroup_id][$member->personID] = array(
                        'id' => $member->personID,
                        'role' => $pgroup->role
                    );
                } else {
                    $this->log->warning('Cannot find parallel group with sequence id: ' . $sequence_number);
                }
            }
        }
        $this->log->debug('ECS member assignments ' . print_r($assigned, true));
        return $assigned;
    }

References if, ilECSMappingUtils\PARALLEL_ALL_COURSES, ilECSMappingUtils\PARALLEL_GROUPS_IN_COURSE, and ilECSMappingUtils\PARALLEL_ONE_COURSE.

Referenced by doUpdate().

Here is the caller graph for this function:

◆ readCourse()

ilECSCmsCourseMemberCommandQueueHandler::readCourse ( $course_member )

private

Read course from ecs.

Returns: boolean

Definition at line 518 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        try {
            include_once './Services/WebServices/ECS/classes/class.ilECSImport.php';
            $ecs_id = ilECSImport::lookupEContentIdByContentId(
                $this->getServer()->getServerId(),
                $this->getMid(),
                $course_member->lectureID
            );
            
            include_once './Services/WebServices/ECS/classes/Course/class.ilECSCourseConnector.php';
            $crs_reader = new ilECSCourseConnector($this->getServer());
            return $crs_reader->getCourse($ecs_id);
        } catch (ilECSConnectorException $e) {
            throw $e;
        }
    }

References Vendor\Package\$e, getMid(), getServer(), and ilECSImport\lookupEContentIdByContentId().

Referenced by doUpdate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ readCourseMember()

ilECSCmsCourseMemberCommandQueueHandler::readCourseMember	(	ilECSSetting	$server,
			$a_content_id
	)

private

Read course from ecs.

Returns: boolean

Definition at line 501 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        try {
            include_once './Services/WebServices/ECS/classes/Course/class.ilECSCourseMemberConnector.php';
            $crs_member_reader = new ilECSCourseMemberConnector($server);
            
            $member = $crs_member_reader->getCourseMember($a_content_id);
            return $member;
        } catch (ilECSConnectorException $e) {
            throw $e;
        }
    }

References Vendor\Package\$e, and $server.

Referenced by handleCreate(), and handleUpdate().

Here is the caller graph for this function:

◆ refreshAssignmentStatus()

ilECSCmsCourseMemberCommandQueueHandler::refreshAssignmentStatus	(	$course_member,
		$obj_id,
		$sub_id,
		$assigned
	)

protected

Refresh status of course member assignments.

Parameters

object	$course_member
int	$obj_id

Definition at line 283 of file class.ilECSCmsCourseMemberCommandQueueHandler.php.

    {
        include_once './Services/WebServices/ECS/classes/Course/class.ilECSCourseMemberAssignment.php';
        
        $this->log->debug('Currrent sub_id = ' . $sub_id . ', obj_id = ' . $obj_id);
        
        $type = ilObject::_lookupType($obj_id);
        if ($type == 'crs') {
            include_once './Modules/Course/classes/class.ilCourseParticipants.php';
            $part = ilCourseParticipants::_getInstanceByObjId($obj_id);
        } elseif ($type == 'grp') {
            include_once './Modules/Group/classes/class.ilGroupParticipants.php';
            $part = ilGroupParticipants::_getInstanceByObjId($obj_id);
        } else {
            $this->log->warning('Invalid object type given for obj_id: ' . $obj_id);
            return false;
        }
        
        $course_id = (int) $course_member->lectureID;
        $usr_ids = ilECSCourseMemberAssignment::lookupUserIds(
            $course_id,
            $sub_id,
            $obj_id
        );
        
        // Delete remote deleted
        foreach ((array) $usr_ids as $usr_id) {
            if (!isset($assigned[$usr_id])) {
                $ass = ilECSCourseMemberAssignment::lookupAssignment($course_id, $sub_id, $obj_id, $usr_id);
                if ($ass instanceof ilECSCourseMemberAssignment) {
                    $login = ilObjUser::_checkExternalAuthAccount(
                        $this->getMappingSettings()->getAuthMode(),
                        (string) $usr_id
                    );
                    
                    $this->log->debug('Local user assignment: ' . (string) $usr_id . ' <-> ' . $login);
                    
                    if ($il_usr_id = ilObjUser::_lookupId($login)) {
                        // this removes also admin, tutor roles
                        $part->delete($il_usr_id);
                        $this->log->info('Deassigning user ' . $usr_id . ' ' . 'from course ' . ilObject::_lookupTitle($obj_id));
                    } else {
                        $this->log->notice('Deassigning unknown ILIAS user ' . $usr_id . ' ' . 'from course ' . ilObject::_lookupTitle($obj_id));
                    }
 
                    $ass->delete();
                }
            }
        }
 
        $this->log->debug('Handled assignmnent...');
        
        // Assign new participants
        foreach ((array) $assigned as $person_id => $person) {
            $role = $this->lookupRole($person['role'], $type);
            $role_info = ilECSMappingUtils::getRoleMappingInfo($role);
        
            $this->log->debug('Using role info...');
            $login = ilObjUser::_checkExternalAuthAccount(
                $this->getMappingSettings()->getAuthMode(),
                (string) $person_id
            );
            $this->log->info('Handling user ' . (string) $person_id);
            
            if (in_array($person_id, $usr_ids)) {
                if ($il_usr_id = ilObjUser::_lookupId($login)) {
                    $part->updateRoleAssignments($il_usr_id, array($part->getAutoGeneratedRoleId($role)));
                } elseif ($role_info['create']) {
                    $this->createMember($person_id);
                    $this->log->info('Added new user ' . $person_id);
                    $login = ilObjUser::_checkExternalAuthAccount(
                        $this->getMappingSettings()->getAuthMode(),
                        (string) $person_id
                    );
                    if ($role) {
                        if ($il_usr_id = ilObjUser::_lookupId($login)) {
                            $part->add($il_usr_id, $role);
                            $part->sendNotification($part->NOTIFY_ACCEPT_USER, $il_usr_id);
                        }
                    }
                }
            } else {
                if ($il_usr_id = ilObjUser::_lookupId($login)) {
                    // user exists => assign to course/group
                    if ($role) {
                        // Assign user
                        $this->log->info('Assigning new user ' . $person_id . ' ' . 'to ' . ilObject::_lookupTitle($obj_id) . ' using role: ' . $role);
                        $part->add($il_usr_id, $role);
                        $part->sendNotification($part->NOTIFY_ACCEPT_USER, $il_usr_id);
                    }
                } else {
                    // no local user exists
                    if ($role_info['create']) {
                        $this->createMember($person_id);
                        $this->log->info('Added new user ' . $person_id);
                        $login = ilObjUser::_checkExternalAuthAccount(
                            $this->getMappingSettings()->getAuthMode(),
                            (string) $person_id
                        );
                    }
                    // Assign to role
                    if ($role) {
                        if ($il_usr_id = ilObjUser::_lookupId($login)) {
                            $part->add($il_usr_id, $role);
                            $part->sendNotification($part->NOTIFY_ACCEPT_USER, $il_usr_id);
                        }
                    }
                }
                
                $assignment = new ilECSCourseMemberAssignment();
                $assignment->setServer($this->getServer()->getServerId());
                $assignment->setMid($this->mid);
                $assignment->setCmsId($course_id);
                $assignment->setCmsSubId($sub_id);
                $assignment->setObjId($obj_id);
                $assignment->setUid($person_id);
                $assignment->save();
            }
        }
        return true;
    }