SessionManager::subscribeUsersToSession()

Complexity

Conditions	30
Paths	> 20000

Size

Total Lines	241
Code Lines	153

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public static function subscribeUsersToSession(
        $sessionId,
        $userList,
        $session_visibility = SESSION_VISIBLE_READ_ONLY,
        $empty_users = true
    ) {
        if ($sessionId != strval(intval($sessionId))) {
            return false;
        }

        foreach ($userList as $intUser) {
            if ($intUser != strval(intval($intUser))) {
                return false;
            }
        }

        $tbl_session_rel_course = Database::get_main_table(TABLE_MAIN_SESSION_COURSE);
        $tbl_session_rel_course_rel_user = Database::get_main_table(TABLE_MAIN_SESSION_COURSE_USER);
        $tbl_session_rel_user = Database::get_main_table(TABLE_MAIN_SESSION_USER);
        $tbl_session = Database::get_main_table(TABLE_MAIN_SESSION);

        $session = api_get_session_entity($sessionId);

        // from function parameter
        if (empty($session_visibility)) {
            $session_visibility = $session->getVisibility();
            //default status loaded if empty
            // by default readonly 1
            if (empty($session_visibility)) {
                $session_visibility = SESSION_VISIBLE_READ_ONLY;
            }
        } else {
            if (!in_array($session_visibility, [SESSION_VISIBLE_READ_ONLY, SESSION_VISIBLE, SESSION_INVISIBLE])) {
                $session_visibility = SESSION_VISIBLE_READ_ONLY;
            }
        }

        $sql = "SELECT user_id FROM $tbl_session_rel_course_rel_user
                WHERE session_id = $sessionId AND status = 0";
        $result = Database::query($sql);
        $existingUsers = [];
        while ($row = Database::fetch_array($result)) {
            $existingUsers[] = $row['user_id'];
        }

        $sql = "SELECT c_id FROM $tbl_session_rel_course
                WHERE session_id = $sessionId";
        $result = Database::query($sql);
        $course_list = [];
        while ($row = Database::fetch_array($result)) {
            $course_list[] = $row['c_id'];
        }

        if ($session->getSendSubscriptionNotification() &&
            is_array($userList)
        ) {
            // Sending emails only
            foreach ($userList as $user_id) {
                if (in_array($user_id, $existingUsers)) {
                    continue;
                }

                $tplSubject = new Template(
                    null,
                    false,
                    false,
                    false,
                    false,
                    false
                );
                $layoutSubject = $tplSubject->get_template(
                    'mail/subject_subscription_to_session_confirmation.tpl'
                );
                $subject = $tplSubject->fetch($layoutSubject);
                $user_info = api_get_user_info($user_id);

                $tplContent = new Template(
                    null,
                    false,
                    false,
                    false,
                    false,
                    false
                );
                // Variables for default template
                $tplContent->assign(
                    'complete_name',
                    stripslashes($user_info['complete_name'])
                );
                $tplContent->assign('session_name', $session->getName());
                $tplContent->assign(
                    'session_coach',
                    $session->getGeneralCoach()->getCompleteName()
                );
                $layoutContent = $tplContent->get_template(
                    'mail/content_subscription_to_session_confirmation.tpl'
                );
                $content = $tplContent->fetch($layoutContent);

                api_mail_html(
                    $user_info['complete_name'],
                    $user_info['mail'],
                    $subject,
                    $content,
                    api_get_person_name(
                        api_get_setting('administratorName'),
                        api_get_setting('administratorSurname')
                    ),
                    api_get_setting('emailAdministrator')
                );
            }
        }

        foreach ($course_list as $courseId) {
            // for each course in the session
            $nbr_users = 0;
            $courseId = (int) $courseId;

            $sql = "SELECT DISTINCT user_id
                    FROM $tbl_session_rel_course_rel_user
                    WHERE
                        session_id = $sessionId AND
                        c_id = $courseId AND
                        status = 0
                    ";
            $result = Database::query($sql);
            $existingUsers = [];
            while ($row = Database::fetch_array($result)) {
                $existingUsers[] = $row['user_id'];
            }

            // Delete existing users
            if ($empty_users) {
                foreach ($existingUsers as $existing_user) {
                    if (!in_array($existing_user, $userList)) {
                        $sql = "DELETE FROM $tbl_session_rel_course_rel_user
                                WHERE
                                    session_id = $sessionId AND
                                    c_id = $courseId AND
                                    user_id = $existing_user AND
                                    status = 0 ";
                        $result = Database::query($sql);

                        Event::addEvent(
                            LOG_SESSION_DELETE_USER_COURSE,
                            LOG_USER_ID,
                            $existing_user,
                            api_get_utc_datetime(),
                            api_get_user_id(),
                            $courseId,
                            $sessionId
                        );

                        if (Database::affected_rows($result)) {
                            $nbr_users--;
                        }
                    }
                }
            }

            // Replace with this new function
            // insert new users into session_rel_course_rel_user and ignore if they already exist
            foreach ($userList as $enreg_user) {
                if (!in_array($enreg_user, $existingUsers)) {
                    $status = self::get_user_status_in_course_session(
                        $enreg_user,
                        $courseId,
                        $sessionId
                    );

                    // Avoid duplicate entries.
                    if ($status === false || ($status !== false && $status != 0)) {
                        $enreg_user = (int) $enreg_user;
                        $sql = "INSERT IGNORE INTO $tbl_session_rel_course_rel_user (session_id, c_id, user_id, visibility, status)
                                VALUES($sessionId, $courseId, $enreg_user, $session_visibility, 0)";
                        $result = Database::query($sql);
                        if (Database::affected_rows($result)) {
                            $nbr_users++;
                        }

                        Event::addEvent(
                            LOG_SESSION_ADD_USER_COURSE,
                            LOG_USER_ID,
                            $enreg_user,
                            api_get_utc_datetime(),
                            api_get_user_id(),
                            $courseId,
                            $sessionId
                        );
                    }
                }
            }

            // Count users in this session-course relation
            $sql = "SELECT COUNT(user_id) as nbUsers
                    FROM $tbl_session_rel_course_rel_user
                    WHERE session_id = $sessionId AND c_id = $courseId AND status<>2";
            $rs = Database::query($sql);
            list($nbr_users) = Database::fetch_array($rs);
            // update the session-course relation to add the users total
            $sql = "UPDATE $tbl_session_rel_course SET nbr_users = $nbr_users
                    WHERE session_id = $sessionId AND c_id = $courseId";
            Database::query($sql);
        }

        // Delete users from the session
        if ($empty_users === true) {
            $sql = "DELETE FROM $tbl_session_rel_user
                    WHERE 
                      session_id = $sessionId AND 
                      relation_type <> ".SESSION_RELATION_TYPE_RRHH;
            // Don't reset session_rel_user.registered_at of users that will be registered later anyways.
            if (!empty($userList)) {
                $avoidDeleteThisUsers = " AND user_id NOT IN ('".implode("','", $userList)."')";
                $sql .= $avoidDeleteThisUsers;
            }
            Database::query($sql);
        }

        // Insert missing users into session
        foreach ($userList as $enreg_user) {
            $isUserSubscribed = self::isUserSubscribedAsStudent($sessionId, $enreg_user);
            if ($isUserSubscribed === false) {
                $enreg_user = (int) $enreg_user;
                $sql = "INSERT IGNORE INTO $tbl_session_rel_user (relation_type, session_id, user_id, registered_at)
                        VALUES (0, $sessionId, $enreg_user, '".api_get_utc_datetime()."')";
                Database::query($sql);
            }
        }

        // update number of users in the session
        $nbr_users = count($userList);
        if ($empty_users) {
            // update number of users in the session
            $sql = "UPDATE $tbl_session SET nbr_users= $nbr_users
                    WHERE id = $sessionId ";
            Database::query($sql);
        } else {
            $sql = "UPDATE $tbl_session SET nbr_users = nbr_users + $nbr_users
                    WHERE id = $sessionId";
            Database::query($sql);
        }