SystemAnnouncementManager::send_system_announcement_by_email()

Complexity

Conditions	14
Paths	41

Size

Total Lines	94
Code Lines	47

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public static function send_system_announcement_by_email(SysAnnouncement $announcement, bool $sendEmailTest = false)
    {
        $title = $announcement->getTitle();
        $content = $announcement->getContent();
        $language = $announcement->getLang();

        $content = str_replace(['\r\n', '\n', '\r'], '', $content);
        $now = api_get_utc_datetime();

        if ($sendEmailTest) {
            MessageManager::send_message_simple(api_get_user_id(), $title, $content);

            return true;
        }

        $repo = Container::getUserRepository();
        $qb = $repo->addRoleListQueryBuilder($announcement->getRoles());
        $repo->addAccessUrlQueryBuilder(api_get_current_access_url_id(), $qb);

        if (!empty($language)) {
            $qb
                ->andWhere('u.locale = :lang')
                ->setParameter('lang', $language)
            ;
        }

        $repo->addActiveAndNotAnonUserQueryBuilder($qb);
        $repo->addExpirationDateQueryBuilder($qb);

        // Sent to active users.
        //$sql .= " AND email <>'' AND active = 1 ";

        // Expiration date
        //$sql .= " AND (expiration_date = '' OR expiration_date IS NULL OR expiration_date > '$now') ";

        $userListToFilter = [];
        // @todo check if other filters will apply for the career/promotion option.
        if (null !== $announcement->getCareer()) {
            $promotion = new Promotion();
            $promotionList = $promotion->get_all_promotions_by_career_id($announcement->getCareer()->getId());
            if (null !== $announcement->getPromotion()) {
                $promotionList = [];
                $promotionList[] = $promotion->get($announcement->getPromotion()->getId());
            }

            if (!empty($promotionList)) {
                foreach ($promotionList as $promotion) {
                    $sessionList = SessionManager::get_all_sessions_by_promotion($promotion['id']);
                    foreach ($sessionList as $session) {
                        if (in_array('ROLE_TEACHER', $announcement->getRoles(), true)) {
                            $users = SessionManager::get_users_by_session($session['id'], 2);
                            if (!empty($users)) {
                                $userListToFilter = array_merge($users, $userListToFilter);
                            }
                        }

                        if (in_array('ROLE_STUDENT', $announcement->getRoles(), true)) {
                            $users = SessionManager::get_users_by_session($session['id'], 0);
                            if (!empty($users)) {
                                $userListToFilter = array_merge($users, $userListToFilter);
                            }
                        }
                    }
                }
            }
        }

        if (!empty($userListToFilter)) {
            $userListToFilter = array_column($userListToFilter, 'user_id');
            //$userListToFilterToString = implode("', '", $userListToFilter);
            $qb
                ->andWhere('u.id IN (:users)')
                ->setParameter('users', $userListToFilter)
            ;
            //$sql .= " AND (u.user_id IN ('$userListToFilterToString') ) ";
        }
        $users = $qb->getQuery()->getResult();

        $message_sent = false;
        /** @var \Chamilo\CoreBundle\Entity\User $user */
        foreach ($users as $user) {
            MessageManager::send_message_simple($user->getId(), $title, $content);
            $message_sent = true;
        }

        // Minor validation to clean up the attachment files in the announcement
        /*if (!empty($_FILES)) {
            $attachments = $_FILES;
            foreach ($attachments as $attachment) {
                unlink($attachment['tmp_name']);
            }
        }*/

        return $message_sent; //true if at least one e-mail was sent
    }