PauseTraining::runCron()

Complexity

Conditions	23
Paths	27

Size

Total Lines	143
Code Lines	85

Duplication

Lines	0
Ratio	0 %

Importance

Changes	7
Bugs	1	Features	0

<?php
    public function runCron()
    {
        $enable = $this->get('tool_enable');
        $senderId = $this->get('sender_id');
        $enableDays = $this->get('cron_alert_users_if_inactive_days');

        if ('true' !== $enable) {
            echo 'Plugin not enabled';

            return false;
        }

        if (empty($senderId)) {
            echo 'Sender id not configured';

            return false;
        }

        $senderInfo = api_get_user_info($senderId);

        if (empty($senderInfo)) {
            echo "Sender #$senderId not found";

            return false;
        }

        $enableDaysList = explode(',', $enableDays);
        rsort($enableDaysList);

        $track = Database::get_main_table(TABLE_STATISTIC_TRACK_E_COURSE_ACCESS);
        $login = Database::get_main_table(TABLE_STATISTIC_TRACK_E_LOGIN);
        $userTable = Database::get_main_table(TABLE_MAIN_USER);
        $now = api_get_utc_datetime();
        $usersNotificationPerDay = [];
        $users = [];

        $extraFieldValue = new ExtraFieldValue('user');

        foreach ($enableDaysList as $day) {
            $day = (int) $day;

            if (0 === $day) {
                echo 'Day = 0 avoided '.PHP_EOL;
                continue;
            }

            $hourStart = $day * 24;
            $hourEnd = $day + 1 * 24;

            $date = new DateTime($now);
            $date->sub(new DateInterval('P'.$hourStart.'H'));
            $hourStart = $date->format('Y-m-d H:i:s');

            $date = new DateTime($now);
            $date->sub(new DateInterval('P'.$hourEnd.'H'));
            $hourEnd = $date->format('Y-m-d H:i:s');

            $sql = "SELECT
                    t.user_id,
                    MAX(t.logout_course_date) max_course_date,
                    MAX(l.logout_date) max_login_date
                    FROM $track t
                    INNER JOIN $userTable u
                    ON (u.id = t.user_id)
                    INNER JOIN $login l
                    ON (u.id = l.login_user_id)
                    WHERE
                        u.status <> ".ANONYMOUS." AND
                        u.active = 1
                    GROUP BY t.user_id
                    HAVING
                        (max_course_date BETWEEN '$hourStart' AND '$hourEnd') AND
                        (max_login_date BETWEEN '$hourStart' AND '$hourEnd')
                    ";

            $rs = Database::query($sql);
            while ($user = Database::fetch_array($rs)) {
                $userId = $user['user_id'];
                if (in_array($userId, $users)) {
                    continue;
                }

                // Take max date value.
                $maxCourseDate = $user['max_course_date'];
                $maxLoginDate = $user['max_login_date'];
                $maxDate = $maxCourseDate;
                if ($maxLoginDate > $maxCourseDate) {
                    $maxDate = $maxLoginDate;
                }

                // Check if user has selected to pause formation.
                $pause = $extraFieldValue->get_values_by_handler_and_field_variable($userId, 'pause_formation');
                if (!empty($pause) && isset($pause['value']) && 1 == $pause['value']) {
                    $startDate = $extraFieldValue->get_values_by_handler_and_field_variable(
                        $userId,
                        'start_pause_date'
                    );
                    $endDate = $extraFieldValue->get_values_by_handler_and_field_variable(
                        $userId,
                        'end_pause_date'
                    );

                    if (
                        !empty($startDate) && isset($startDate['value']) && !empty($startDate['value']) &&
                        !empty($endDate) && isset($endDate['value']) && !empty($endDate['value'])
                    ) {
                        $startDate = $startDate['value'];
                        $endDate = $endDate['value'];

                        // Ignore date if is between the pause formation.
                        if ($maxDate > $startDate && $maxDate < $endDate) {
                            echo "Message skipped for user #$userId because latest login is $maxDate and pause formation between $startDate - $endDate ".PHP_EOL;
                            continue;
                        }
                    }
                }

                echo "User #$userId added to message queue because latest login is $maxDate between $hourStart AND $hourEnd".PHP_EOL;

                $users[] = $userId;
                $usersNotificationPerDay[$day][] = $userId;
            }
        }

        if (!empty($usersNotificationPerDay)) {
            echo 'Now processing messages ...'.PHP_EOL;

            ksort($usersNotificationPerDay);
            foreach ($usersNotificationPerDay as $day => $userList) {
                $template = new Template();
                $title = sprintf($this->get_lang('InactivityXDays'), $day);

                foreach ($userList as $userId) {
                    $userInfo = api_get_user_info($userId);
                    $template->assign('days', $day);
                    $template->assign('user', $userInfo);
                    $content = $template->fetch('pausetraining/view/notification_content.tpl');
                    echo 'Ready to send a message "'.$title.'" to user #'.$userId.' '.$userInfo['complete_name'].PHP_EOL;
                    MessageManager::send_message_simple($userId, $title, $content, $senderId);
                }
            }
        }
        exit;

Using exit here is not recommended.

    }