class.ilMembershipCronMinMembers.php

Go to the documentation of this file.

<?php

/* Copyright (c) 1998-2010 ILIAS open source, Extended GPL, see docs/LICENSE */

include_once "Services/Cron/classes/class.ilCronJob.php";

class ilMembershipCronMinMembers extends ilCronJob
{                       
        public function getId()
        {
                return "mem_min_members";
        }
        
        public function getTitle()
        {
                global $lng;
                
                return $lng->txt("mem_cron_min_members");
        }
        
        public function getDescription()
        {
                global $lng;
                
                return $lng->txt("mem_cron_min_members_info");
        }
        
        public function getDefaultScheduleType()
        {
                return self::SCHEDULE_TYPE_DAILY;
        }
        
        public function getDefaultScheduleValue()
        {
                return;
        }
        
        public function hasAutoActivation()
        {
                return true;
        }
        
        public function hasFlexibleSchedule()
        {
                return false;
        }
        
        public function run()
        {                                               
                $status = ilCronJobResult::STATUS_NO_ACTION;
                $message = null;
                
                $recipients_map = array();
                
                $this->getCourses($recipients_map);
                $this->getGroups($recipients_map);
        
                if(sizeof($recipients_map))
                {                       
                        foreach($recipients_map as $reci_id => $items)
                        {                               
                                $this->sendMessage($reci_id, $items);           
                        }
                                        
                        $status = ilCronJobResult::STATUS_OK;
                        $message = sizeof($recipients_map)." notifications sent"; 
                }
                
                $result = new ilCronJobResult();
                $result->setStatus($status);
                $result->setMessage($message);
                
                return $result;
        }       
        
        protected function getCourses(array &$a_recipients_map)
        {
                include_once "Modules/Course/classes/class.ilObjCourse.php";
                foreach(ilObjCourse::findCoursesWithNotEnoughMembers() as $obj_id => $item)
                {
                        $too_few = (bool)$item[0];
                        
                        /*
                        $ilDB->manipulate("UPDATE crs_settings".
                                " SET cancel_end_noti = ".$ilDB->quote($now, "integer").
                                " WHERE obj_id = ".$ilDB->quote($obj_id, "integer"));
                        */
                        
                        if($too_few)
                        {
                                // not enough members: notifiy course admins                            
                                foreach($item[1] as $reci_id)
                                {
                                        $a_recipients_map[$reci_id][] = array("crs", $obj_id, $item[0]);
                                }                               
                        }
                        else
                        {
                                // enough members: notify members?
                                
                                // :TODO: ?
                        }               
                }       
        }
        
        protected function getGroups(array &$a_recipients_map)
        {
                include_once "Modules/Group/classes/class.ilObjGroup.php";
                foreach(ilObjGroup::findGroupsWithNotEnoughMembers() as $obj_id => $item)
                {
                        $too_few = (bool)$item[0];
                        
                        /*
                        $ilDB->manipulate("UPDATE grp_settings".
                                " SET cancel_end_noti = ".$ilDB->quote($now, "integer").
                                " WHERE obj_id = ".$ilDB->quote($obj_id, "integer"));
                        */
                        
                        if($too_few)
                        {
                                // not enough members: notifiy group admins                             
                                foreach($item[1] as $reci_id)
                                {
                                        $a_recipients_map[$reci_id][] = array("grp", $obj_id, $item[0]);
                                }               
                        }
                        else
                        {
                                // enough members: notify members?
                                
                                // :TODO: ?
                        }
                }
        }
        
        protected function sendMessage($a_reci_id, array $a_items)
        {
                global $ilUser;
                
                include_once "Services/Link/classes/class.ilLink.php";          
                include_once "./Services/Notification/classes/class.ilSystemNotification.php";
                $ntf = new ilSystemNotification();              
                $ntf->setLangModules(array("crs"));     
                
                // #17097
                $ntf->setReasonLangId("mem_cron_min_members_reason");
                $ntf->setTaskLangId("mem_cron_min_members_task");
                
                // user specific language
                $lng = $ntf->getUserLanguage($a_reci_id);
                        
                $list = array();
                foreach($a_items as $item)
                {
                        $obj_type = $item[0];
                        $obj_id = $item[1];
                        $ref_id = array_pop(ilObject::_getAllReferences($obj_id));
                        
                        $title = ilObject::_lookupTitle($obj_id);
                        $url = ilLink::_getLink($ref_id, $obj_type);
                        
                        $list[] = $title."\n".$url."\n";                                                
                }                                               
                $list = implode($ntf->getBlockBorder(), $list);
                                
                $ntf->addAdditionalInfo("mem_cron_min_members_intro", $list, true);             
                
                $mail = new ilMail(ANONYMOUS_USER_ID);
                $mail->enableSOAP(false); // #10410
                $mail->sendMail(ilObjUser::_lookupLogin($a_reci_id), 
                        null, 
                        null,
                        $lng->txt("mem_cron_min_members_subject"), 
                        $ntf->composeAndGetMessage($a_reci_id, null, "read", true), 
                        null, 
                        array("system"));
        }
}

?>