table = Database::get_main_table(TABLE_NOTIFICATION);
// Default no-reply email
$this->adminEmail = api_get_setting('noreply_email_address');
$this->adminName = api_get_setting('siteName');
$this->titlePrefix = '['.api_get_setting('siteName').'] ';
// If no-reply email doesn't exist use the admin name/email
if (empty($this->adminEmail)) {
$this->adminEmail = api_get_setting('emailAdministrator');
$this->adminName = api_get_person_name(
api_get_setting('administratorName'),
api_get_setting('administratorSurname'),
null,
PERSON_NAME_EMAIL_ADDRESS
);
}
}
/**
* @return string
*/
public function getTitlePrefix()
{
return $this->titlePrefix;
}
/**
* @return string
*/
public function getDefaultPlatformSenderEmail()
{
return $this->adminEmail;
}
/**
* @return string
*/
public function getDefaultPlatformSenderName()
{
return $this->adminName;
}
/**
* Send the notifications
* @param int notification frequency
*/
public function send($frequency = 8)
{
$notifications = $this->find(
'all',
array('where' => array('sent_at IS NULL AND send_freq = ?' => $frequency))
);
if (!empty($notifications)) {
foreach ($notifications as $item_to_send) {
// Sending email
api_mail_html(
$item_to_send['dest_mail'],
$item_to_send['dest_mail'],
Security::filter_terms($item_to_send['title']),
Security::filter_terms($item_to_send['content']),
$this->adminName,
$this->adminEmail
);
if ($this->debug) {
error_log('Sending message to: '.$item_to_send['dest_mail']);
}
// Updating
$item_to_send['sent_at'] = api_get_utc_datetime();
$this->update($item_to_send);
if ($this->debug) {
error_log('Updating record : '.print_r($item_to_send, 1));
}
}
}
}
/**
* @param string $title
* @param array $senderInfo
*
* @return string
*/
public function formatTitle($title, $senderInfo)
{
$newTitle = $this->getTitlePrefix();
switch ($this->type) {
case self::NOTIFICATION_TYPE_MESSAGE:
if (!empty($senderInfo)) {
$senderName = api_get_person_name(
$senderInfo['firstname'],
$senderInfo['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$newTitle .= sprintf(get_lang('YouHaveANewMessageFromX'), $senderName);
}
break;
case self::NOTIFICATION_TYPE_DIRECT_MESSAGE:
$newTitle = $title;
break;
case self::NOTIFICATION_TYPE_INVITATION:
if (!empty($senderInfo)) {
$senderName = api_get_person_name(
$senderInfo['firstname'],
$senderInfo['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$newTitle .= sprintf(get_lang('YouHaveANewInvitationFromX'), $senderName);
}
break;
case self::NOTIFICATION_TYPE_GROUP:
if (!empty($senderInfo)) {
$senderName = $senderInfo['group_info']['name'];
$newTitle .= sprintf(get_lang('YouHaveReceivedANewMessageInTheGroupX'), $senderName);
$senderName = api_get_person_name(
$senderInfo['user_info']['firstname'],
$senderInfo['user_info']['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$newTitle .= $senderName;
}
break;
}
return $newTitle;
}
/**
* Save message notification
* @param int $type message type
* NOTIFICATION_TYPE_MESSAGE,
* NOTIFICATION_TYPE_INVITATION,
* NOTIFICATION_TYPE_GROUP
* @param array $user_list recipients: user list of ids
* @param string $title
* @param string $content
* @param array $sender_info
* result of api_get_user_info() or GroupPortalManager:get_group_data()
*/
public function save_notification(
$type,
$user_list,
$title,
$content,
$senderInfo = array()
) {
$this->type = intval($type);
$content = $this->formatContent($content, $senderInfo);
$titleToNotification = $this->formatTitle($title, $senderInfo);
$setting_to_check = '';
$avoid_my_self = false;
switch ($this->type) {
case self::NOTIFICATION_TYPE_DIRECT_MESSAGE:
case self::NOTIFICATION_TYPE_MESSAGE:
$setting_to_check = 'mail_notify_message';
$defaultStatus = self::NOTIFY_MESSAGE_AT_ONCE;
break;
case self::NOTIFICATION_TYPE_INVITATION:
$setting_to_check = 'mail_notify_invitation';
$defaultStatus = self::NOTIFY_INVITATION_AT_ONCE;
break;
case self::NOTIFICATION_TYPE_GROUP:
$setting_to_check = 'mail_notify_group_message';
$defaultStatus = self::NOTIFY_GROUP_AT_ONCE;
$avoid_my_self = true;
break;
default:
$defaultStatus = self::NOTIFY_MESSAGE_AT_ONCE;
break;
}
$settingInfo = UserManager::get_extra_field_information_by_name($setting_to_check);
if (!empty($user_list)) {
foreach ($user_list as $user_id) {
if ($avoid_my_self) {
if ($user_id == api_get_user_id()) {
continue;
}
}
$userInfo = api_get_user_info($user_id);
// Extra field was deleted or removed? Use the default status.
if (empty($settingInfo)) {
$userSetting = $defaultStatus;
} else {
$extra_data = UserManager::get_extra_user_data($user_id);
$userSetting = $extra_data[$setting_to_check];
}
$sendDate = null;
switch ($userSetting) {
// No notifications
case self::NOTIFY_MESSAGE_NO:
case self::NOTIFY_INVITATION_NO:
case self::NOTIFY_GROUP_NO:
break;
// Send notification right now!
case self::NOTIFY_MESSAGE_AT_ONCE:
case self::NOTIFY_INVITATION_AT_ONCE:
case self::NOTIFY_GROUP_AT_ONCE:
$extraHeaders = array(
'reply_to' => array(
'name' => $senderInfo['complete_name'],
'mail' => $senderInfo['email']
)
);
if (!empty($userInfo['email'])) {
api_mail_html(
$userInfo['complete_name'],
$userInfo['mail'],
Security::filter_terms($titleToNotification),
Security::filter_terms($content),
$this->adminName,
$this->adminEmail,
$extraHeaders
);
}
$sendDate = api_get_utc_datetime();
}
// Saving the notification to be sent some day.
$params = array(
'sent_at' => $sendDate,
'dest_user_id' => $user_id,
'dest_mail' => $userInfo['email'],
'title' => $title,
'content' => cut($content, $this->max_content_length),
'send_freq' => $userSetting
);
$this->save($params);
}
}
}
/**
* Formats the content in order to add the welcome message,
* the notification preference, etc
* @param string $content
* @param array $sender_info result of api_get_user_info() or
* GroupPortalManager:get_group_data()
* @return string
* */
public function formatContent($content, $sender_info)
{
$new_message_text = $link_to_new_message = '';
switch ($this->type) {
case self::NOTIFICATION_TYPE_DIRECT_MESSAGE:
$new_message_text = '';
$link_to_new_message = Display::url(
get_lang('SeeMessage'),
api_get_path(WEB_CODE_PATH) . 'messages/inbox.php'
);
break;
case self::NOTIFICATION_TYPE_MESSAGE:
if (!empty($sender_info)) {
$senderName = api_get_person_name(
$sender_info['firstname'],
$sender_info['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$new_message_text = sprintf(get_lang('YouHaveANewMessageFromX'), $senderName);
}
$link_to_new_message = Display::url(
get_lang('SeeMessage'),
api_get_path(WEB_CODE_PATH) . 'messages/inbox.php'
);
break;
case self::NOTIFICATION_TYPE_INVITATION:
if (!empty($sender_info)) {
$senderName = api_get_person_name(
$sender_info['firstname'],
$sender_info['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$new_message_text = sprintf(get_lang('YouHaveANewInvitationFromX'), $senderName);
}
$link_to_new_message = Display::url(
get_lang('SeeInvitation'),
api_get_path(WEB_CODE_PATH) . 'social/invitations.php'
);
break;
case self::NOTIFICATION_TYPE_GROUP:
$topic_page = intval($_REQUEST['topics_page_nr']);
if (!empty($sender_info)) {
$senderName = $sender_info['group_info']['name'];
$new_message_text = sprintf(get_lang('YouHaveReceivedANewMessageInTheGroupX'), $senderName);
$senderName = api_get_person_name(
$sender_info['user_info']['firstname'],
$sender_info['user_info']['lastname'],
null,
PERSON_NAME_EMAIL_ADDRESS
);
$senderName = Display::url(
$senderName,
api_get_path(WEB_CODE_PATH).'social/profile.php?'.$sender_info['user_info']['user_id']
);
$new_message_text .= '
'.get_lang('User').': '.$senderName;
}
$group_url = api_get_path(WEB_CODE_PATH).'social/group_topics.php?id='.$sender_info['group_info']['id'].'&topic_id='.$sender_info['group_info']['topic_id'].'&msg_id='.$sender_info['group_info']['msg_id'].'&topics_page_nr='.$topic_page;
$link_to_new_message = Display::url(get_lang('SeeMessage'), $group_url);
break;
}
$preference_url = api_get_path(WEB_CODE_PATH).'auth/profile.php';
// You have received a new message text
if (!empty($new_message_text)) {
$content = $new_message_text.'