getMessageByUser($user, Message::MESSAGE_TYPE_CONVERSATION);
$html = '';
if (!empty($messages)) {
foreach ($messages as $message) {
$messageId = $message->getId();
$tag = 'message_'.$messageId;
$tagAccordion = 'accordion_'.$messageId;
$tagCollapse = 'collapse_'.$messageId;
$date = Display::dateToStringAgoAndLongDate($message->getSendDate());
$localTime = api_get_local_time(
$message->getSendDate(),
null,
null,
false,
false
);
$sender = $message->getSender();
$deleteButton = '';
if (!empty($url) && $currentUserId === $sender->getId()) {
$deleteButton = Display::url(
get_lang('Delete'),
$url.'&action=delete_message&message_id='.$messageId,
['class' => 'btn btn--danger']
);
}
$content = $message->getContent().'
'.$date.'
'.
get_lang('Author').': '.$sender->getUsername().
'
'.
$deleteButton
;
$html .= Display::panelCollapse(
$localTime.' '.UserManager::formatUserFullName($sender).' '.$message->getTitle(),
$content,
$tag,
null,
$tagAccordion,
$tagCollapse,
false
);
}
}
return $html;
}
/**
* @param int $senderId
* @param int $receiverId
* @param string $subject
* @param string $message
*
* @return bool
*/
public static function messageWasAlreadySent($senderId, $receiverId, $subject, $message)
{
$tblMessage = Database::get_main_table(TABLE_MESSAGE);
$senderId = (int) $senderId;
$receiverId = (int) $receiverId;
$subject = Database::escape_string($subject);
$message = Database::escape_string($message);
$sql = "SELECT m.id FROM $tblMessage m
INNER JOIN message_rel_user mru on m.id = mru.message_id
WHERE
m.user_sender_id = $senderId AND
mru.user_id = $receiverId AND
m.title = '$subject' AND
m.content = '$message' AND
m.msg_type = ".Message::MESSAGE_TYPE_INBOX."
";
$result = Database::query($sql);
return Database::num_rows($result) > 0;
}
/**
* Sends a message to a user/group.
*
* @param int $receiverUserId
* @param string $subject
* @param string $content
* @param array $attachments files array($_FILES) (optional)
* @param array $fileCommentList about attachment files (optional)
* @param int $group_id (optional)
* @param int $parent_id (optional)
* @param int $editMessageId id for updating the message (optional)
* @param int $topic_id (optional) the default value is the current user_id
* @param int $sender_id
* @param bool $directMessage
* @param int $forwardId
* @param bool $checkCurrentAudioId
* @param bool $forceTitleWhenSendingEmail force the use of $title as subject instead of "You have a new message"
*
* @return bool
*/
public static function send_message(
$receiverUserId,
$subject,
$content,
array $attachments = [],
array $fileCommentList = [],
$group_id = 0,
$parent_id = 0,
$editMessageId = 0,
$topic_id = 0,
$sender_id = 0,
$directMessage = false,
$forwardId = 0,
$checkCurrentAudioId = false,
$forceTitleWhenSendingEmail = false,
) {
$group_id = (int) $group_id;
$receiverUserId = (int) $receiverUserId;
$parent_id = (int) $parent_id;
$editMessageId = (int) $editMessageId;
$topic_id = (int) $topic_id;
$user_sender_id = empty($sender_id) ? api_get_user_id() : (int) $sender_id;
if (empty($user_sender_id) || empty($receiverUserId)) {
return false;
}
$userSender = api_get_user_entity($user_sender_id);
if (null === $userSender) {
Display::addFlash(Display::return_message(get_lang('This user doesn\'t exist'), 'warning'));
return false;
}
$userRecipient = api_get_user_entity($receiverUserId);
if (null === $userRecipient) {
return false;
}
// Disabling messages for inactive users.
if (!$userRecipient->getActive()) {
return false;
}
$sendEmail = true;
// Disabling messages depending the pausetraining plugin.
$allowPauseFormation =
'true' === api_get_plugin_setting('pausetraining', 'tool_enable') &&
'true' === api_get_plugin_setting('pausetraining', 'allow_users_to_edit_pause_formation');
if ($allowPauseFormation) {
$extraFieldValue = new ExtraFieldValue('user');
$disableEmails = $extraFieldValue->get_values_by_handler_and_field_variable(
$receiverUserId,
'disable_emails'
);
// User doesn't want email notifications but chamilo inbox still available.
if (!empty($disableEmails) &&
isset($disableEmails['value']) && 1 === (int) $disableEmails['value']
) {
$sendEmail = false;
}
if ($sendEmail) {
// Check if user pause his formation.
$pause = $extraFieldValue->get_values_by_handler_and_field_variable(
$receiverUserId,
'pause_formation'
);
if (!empty($pause) && isset($pause['value']) && 1 === (int) $pause['value']) {
$startDate = $extraFieldValue->get_values_by_handler_and_field_variable(
$receiverUserId,
'start_pause_date'
);
$endDate = $extraFieldValue->get_values_by_handler_and_field_variable(
$receiverUserId,
'end_pause_date'
);
if (!empty($startDate) && isset($startDate['value']) && !empty($startDate['value']) &&
!empty($endDate) && isset($endDate['value']) && !empty($endDate['value'])
) {
$now = time();
$start = api_strtotime($startDate['value']);
$end = api_strtotime($endDate['value']);
if ($now > $start && $now < $end) {
$sendEmail = false;
}
}
}
}
}
$totalFileSize = 0;
$attachmentList = [];
if (is_array($attachments)) {
$counter = 0;
foreach ($attachments as $attachment) {
$attachment['comment'] = $fileCommentList[$counter] ?? '';
$fileSize = $attachment['size'] ?? 0;
if (is_array($fileSize)) {
foreach ($fileSize as $size) {
$totalFileSize += $size;
}
} else {
$totalFileSize += $fileSize;
}
$attachmentList[] = $attachment;
$counter++;
}
}
if ($checkCurrentAudioId) {
// Add the audio file as an attachment
$audio = Session::read('current_audio');
if (!empty($audio) && isset($audio['name']) && !empty($audio['name'])) {
$audio['comment'] = 'audio_message';
// create attachment from audio message
$attachmentList[] = $audio;
}
}
// Validating fields
if (empty($subject) && empty($group_id)) {
Display::addFlash(
Display::return_message(
get_lang('You should write a subject'),
'warning'
)
);
return false;
} elseif ($totalFileSize > (int) api_get_setting('message_max_upload_filesize')) {
$warning = sprintf(
get_lang('Files size exceeds'),
format_file_size(api_get_setting('message_max_upload_filesize'))
);
Display::addFlash(Display::return_message($warning, 'warning'));
return false;
}
$em = Database::getManager();
$repo = $em->getRepository(Message::class);
$parent = null;
if (!empty($parent_id)) {
$parent = $repo->find($parent_id);
}
// Just in case we replace the and \n and \n\r while saving in the DB
if (!empty($receiverUserId) || !empty($group_id)) {
// message for user friend
//@todo it's possible to edit a message? yes, only for groups
if (!empty($editMessageId)) {
$message = $repo->find($editMessageId);
if (null !== $message) {
$message->setContent($content);
$em->persist($message);
$em->flush();
}
$messageId = $editMessageId;
} else {
$group = Container::getUsergroupRepository()->find($group_id);
$message = (new Message())
->setSender($userSender)
->addReceiver($userRecipient)
->setTitle($subject)
->setContent($content)
->setGroup($group)
->setParent($parent)
;
$em->persist($message);
$em->flush();
$messageId = $message->getId();
}
// Forward also message attachments.
if (!empty($forwardId)) {
$forwardMessage = $repo->find($forwardId);
if (null !== $forwardMessage) {
$forwardAttachments = $forwardMessage->getAttachments();
foreach ($forwardAttachments as $forwardAttachment) {
$message->addAttachment($forwardAttachment);
}
$em->persist($message);
$em->flush();
}
}
// Save attachment file for inbox messages
if (is_array($attachmentList)) {
foreach ($attachmentList as $attachment) {
if (0 === $attachment['error']) {
self::saveMessageAttachmentFile(
$attachment,
$attachment['comment'] ?? '',
$message,
);
}
}
}
if ($sendEmail) {
$notification = new Notification();
$sender_info = api_get_user_info($user_sender_id);
// add file attachment additional attributes
$attachmentAddedByMail = [];
foreach ($attachmentList as $attachment) {
$attachmentAddedByMail[] = [
'path' => $attachment['tmp_name'],
'filename' => $attachment['name'],
];
}
if (empty($group_id)) {
$type = Notification::NOTIFICATION_TYPE_MESSAGE;
if ($directMessage) {
$type = Notification::NOTIFICATION_TYPE_DIRECT_MESSAGE;
}
$notification->saveNotification(
$messageId,
$type,
[$receiverUserId],
$subject,
$content,
$sender_info,
$attachmentAddedByMail,
$forceTitleWhenSendingEmail
);
} else {
$usergroup = new UserGroupModel();
$group_info = $usergroup->get($group_id);
$group_info['topic_id'] = $topic_id;
$group_info['msg_id'] = $messageId;
$user_list = $usergroup->get_users_by_group(
$group_id,
false,
[],
0,
1000
);
// Adding more sense to the message group
$subject = sprintf(get_lang('There is a new message in group %s'), $group_info['name']);
$new_user_list = [];
foreach ($user_list as $user_data) {
$new_user_list[] = $user_data['id'];
}
$group_info = [
'group_info' => $group_info,
'user_info' => $sender_info,
];
$notification->saveNotification(
$messageId,
Notification::NOTIFICATION_TYPE_GROUP,
$new_user_list,
$subject,
$content,
$group_info,
$attachmentAddedByMail
);
}
}
return $messageId;
}
return false;
}
/**
* @param int $receiverUserId
* @param string $subject
* @param string $message
* @param int $sender_id
* @param bool $sendCopyToDrhUsers send copy to related DRH users
* @param bool $directMessage
* @param bool $uploadFiles Do not upload files using the MessageManager class
* @param array $attachmentList
*
* @return bool
*/
public static function send_message_simple(
$receiverUserId,
$subject,
$message,
$sender_id = 0,
$sendCopyToDrhUsers = false,
$directMessage = false,
$uploadFiles = true,
$attachmentList = []
) {
$files = $_FILES ? $_FILES : [];
if (false === $uploadFiles) {
$files = [];
}
// $attachmentList must have: tmp_name, name, size keys
if (!empty($attachmentList)) {
$files = $attachmentList;
}
$result = self::send_message(
$receiverUserId,
$subject,
$message,
$files,
[],
null,
null,
null,
null,
$sender_id,
$directMessage
);
if ($sendCopyToDrhUsers) {
$userInfo = api_get_user_info($receiverUserId);
$drhList = UserManager::getDrhListFromUser($receiverUserId);
if (!empty($drhList)) {
foreach ($drhList as $drhInfo) {
$message = sprintf(
get_lang('Copy of message sent to %s'),
$userInfo['complete_name']
).'
'.$message;
self::send_message_simple(
$drhInfo['id'],
$subject,
$message,
$sender_id,
false,
$directMessage
);
}
}
}
return $result;
}
public static function softDeleteAttachments(Message $message): void
{
$attachments = $message->getAttachments();
if (!empty($attachments)) {
$repo = Container::getMessageAttachmentRepository();
foreach ($attachments as $file) {
$repo->softDelete($file);
}
}
}
/**
* Saves a message attachment files.
*
* @param array $file $_FILES['name']
* @param string $comment a comment about the uploaded file
*/
public static function saveMessageAttachmentFile($file, $comment, Message $message)
{
// Try to add an extension to the file if it hasn't one
$type = $file['type'] ?? '';
if (empty($type)) {
$type = DocumentManager::file_get_mime_type($file['name']);
}
$new_file_name = add_ext_on_mime(stripslashes($file['name']), $type);
// user's file name
$fileName = $file['name'];
if (!filter_extension($new_file_name)) {
Display::addFlash(
Display::return_message(
get_lang('File upload failed: this file extension or file type is prohibited'),
'error'
)
);
return false;
}
$em = Database::getManager();
$attachmentRepo = Container::getMessageAttachmentRepository();
$attachment = (new MessageAttachment())
->setSize($file['size'])
->setPath($fileName)
->setFilename($fileName)
->setComment($comment)
->setParent($message->getSender())
->setMessage($message)
;
$request = Container::getRequest();
$fileToUpload = null;
// Search for files inside the $_FILES, when uploading several files from the form.
if ($request->files->count()) {
/** @var UploadedFile|null $fileRequest */
foreach ($request->files->all() as $fileRequest) {
if (null === $fileRequest) {
continue;
}
if ($fileRequest->getClientOriginalName() === $file['name']) {
$fileToUpload = $fileRequest;
break;
}
}
}
// If no found file, try with $file['content'].
if (null === $fileToUpload && isset($file['content'])) {
$handle = tmpfile();
fwrite($handle, $file['content']);
$meta = stream_get_meta_data($handle);
$fileToUpload = new UploadedFile($meta['uri'], $fileName, $file['type'], null, true);
}
if (null !== $fileToUpload) {
$em->persist($attachment);
$attachmentRepo->addFile($attachment, $fileToUpload);
$attachment->addUserLink($message->getSender());
$receivers = $message->getReceivers();
foreach ($receivers as $receiver) {
$attachment->addUserLink($receiver->getReceiver());
}
$em->flush();
return true;
}
return false;
}
/**
* get messages by group id.
*
* @param int $group_id group id
*
* @return array
*/
public static function get_messages_by_group($group_id)
{
$group_id = (int) $group_id;
if (empty($group_id)) {
return false;
}
$table = Database::get_main_table(TABLE_MESSAGE);
$sql = "SELECT * FROM $table
WHERE
group_id= $group_id AND
msg_type = ".Message::MESSAGE_TYPE_GROUP."
ORDER BY id";
$rs = Database::query($sql);
$data = [];
if (Database::num_rows($rs) > 0) {
while ($row = Database::fetch_array($rs, 'ASSOC')) {
$data[] = $row;
}
}
return $data;
}
/**
* get messages by group id.
*
* @param int $group_id
* @param int $message_id
*
* @return array
*/
public static function get_messages_by_group_by_message($group_id, $message_id)
{
$group_id = (int) $group_id;
if (empty($group_id)) {
return false;
}
$table = Database::get_main_table(TABLE_MESSAGE);
$sql = "SELECT * FROM $table
WHERE
group_id = $group_id AND
msg_type = '".Message::MESSAGE_TYPE_GROUP."'
ORDER BY id ";
$rs = Database::query($sql);
$data = [];
$parents = [];
if (Database::num_rows($rs) > 0) {
while ($row = Database::fetch_array($rs, 'ASSOC')) {
if ($message_id == $row['parent_id'] || in_array($row['parent_id'], $parents)) {
$parents[] = $row['id'];
$data[] = $row;
}
}
}
return $data;
}
/**
* Get messages by parent id optionally with limit.
*
* @param int parent id
* @param int group id (optional)
* @param int offset (optional)
* @param int limit (optional)
*
* @return array
*/
public static function getMessagesByParent($parentId, $groupId = 0, $offset = 0, $limit = 0)
{
$table = Database::get_main_table(TABLE_MESSAGE);
$parentId = (int) $parentId;
if (empty($parentId)) {
return [];
}
$condition_group_id = '';
if (!empty($groupId)) {
$groupId = (int) $groupId;
$condition_group_id = " AND group_id = '$groupId' ";
}
$condition_limit = '';
if ($offset && $limit) {
$offset = (int) $offset;
$limit = (int) $limit;
$offset = ($offset - 1) * $limit;
$condition_limit = " LIMIT $offset,$limit ";
}
$sql = "SELECT * FROM $table
WHERE
parent_id='$parentId' AND
msg_type = '".Message::MESSAGE_TYPE_GROUP."'
$condition_group_id
ORDER BY send_date DESC $condition_limit ";
$rs = Database::query($sql);
$data = [];
if (Database::num_rows($rs) > 0) {
while ($row = Database::fetch_array($rs)) {
$data[$row['id']] = $row;
}
}
return $data;
}
/**
* Displays messages of a group with nested view.
*
* @param int $groupId
*
* @return string
*/
public static function display_messages_for_group($groupId)
{
global $my_group_role;
$rows = self::get_messages_by_group($groupId);
$topics_per_page = 10;
$html_messages = '';
$query_vars = ['id' => $groupId, 'topics_page_nr' => 0];
if (is_array($rows) && count($rows) > 0) {
// prepare array for topics with its items
$topics = [];
$x = 0;
foreach ($rows as $index => $value) {
if (empty($value['parent_id'])) {
$topics[$value['id']] = $value;
}
}
$new_topics = [];
foreach ($topics as $id => $value) {
$rows = self::get_messages_by_group_by_message($groupId, $value['id']);
if (!empty($rows)) {
$count = count(self::calculate_children($rows, $value['id']));
} else {
$count = 0;
}
$value['count'] = $count;
$new_topics[$id] = $value;
}
$array_html = [];
foreach ($new_topics as $index => $topic) {
$html = '';
// topics
$user_sender_info = api_get_user_info($topic['user_sender_id']);
$name = $user_sender_info['complete_name'];
$html .= '';
$html .= '
';
$items = $topic['count'];
$reply_label = (1 == $items) ? get_lang('Reply') : get_lang('Replies');
$label = '
'.$items.' '.$reply_label;
$topic['title'] = trim($topic['title']);
if (empty($topic['title'])) {
$topic['title'] = get_lang('Untitled');
}
$html .= '
';
$html .= Display::tag(
'h4',
Display::url(
Security::remove_XSS($topic['title'], STUDENT, true),
api_get_path(WEB_CODE_PATH).'social/group_topics.php?id='.$groupId.'&topic_id='.$topic['id']
),
['class' => 'title']
);
$actions = '';
if (GROUP_USER_PERMISSION_ADMIN == $my_group_role ||
GROUP_USER_PERMISSION_MODERATOR == $my_group_role
) {
$actions = '
'.Display::url(
get_lang('Delete'),
api_get_path(
WEB_CODE_PATH
).'social/group_topics.php?action=delete&id='.$groupId.'&topic_id='.$topic['id'],
['class' => 'btn btn--plain']
);
}
$date = '';
if ($topic['send_date'] != $topic['update_date']) {
if (!empty($topic['update_date'])) {
$date .= '
'.get_lang(
'LastUpdate'
).' '.Display::dateToStringAgoAndLongDate($topic['update_date']);
}
} else {
$date .= '
'.get_lang(
'Created'
).' '.Display::dateToStringAgoAndLongDate($topic['send_date']);
}
$html .= '
'.$label.' - '.$date.$actions.'
';
$html .= '
';
$image = $user_sender_info['avatar'];
$user_info = '
';
$user_info .= '
';
$html .= '
';
$html .= $user_info;
$html .= '
';
$html .= '
';
$html .= '
';
$links .= '
';
if ((GROUP_USER_PERMISSION_ADMIN == $my_group_role || GROUP_USER_PERMISSION_MODERATOR == $my_group_role) ||
$message->getSender()->getId() == $current_user_id
) {
$urlEdit = $webCodePath.'social/message_for_group_form.inc.php?'
.http_build_query(
[
'user_friend' => $current_user_id,
'group_id' => $groupId,
'message_id' => $message->getId(),
'action' => 'edit_message_group',
'anchor_topic' => 'topic_'.$message->getId(),
'topics_page_nr' => $topic_page_nr,
'items_page_nr' => $items_page_nr,
'topic_id' => $message->getId(),
]
);
$links .= Display::toolbarButton(
$langEdit,
$urlEdit,
'pencil',
'default',
['class' => 'ajax', 'data-title' => $langEdit, 'data-size' => 'lg'],
false
);
}
$links .= self::getLikesButton($message->getId(), $current_user_id, $groupId);
$urlReply = $webCodePath.'social/message_for_group_form.inc.php?'
.http_build_query(
[
'user_friend' => $current_user_id,
'group_id' => $groupId,
'message_id' => $message->getId(),
'action' => 'reply_message_group',
'anchor_topic' => 'topic_'.$message->getId(),
'topics_page_nr' => $topic_page_nr,
'topic_id' => $message->getId(),
]
);
$links .= Display::toolbarButton(
$langReply,
$urlReply,
'commenting',
'default',
['class' => 'ajax', 'data-title' => $langReply, 'data-size' => 'lg'],
false
);
if (api_is_platform_admin()) {
$links .= Display::toolbarButton(
get_lang('Delete'),
'group_topics.php?action=delete&id='.$groupId.'&topic_id='.$topic_id,
'trash',
'default',
[],
false
);
}
$links .= '
';
$links .= '
'.Security::remove_XSS($message->getTitle(), STUDENT, true).$links.'
';
$main_content .= '';
$main_content .= '
';
$main_content .= '
';
$main_content .= Display::img(
$userPicture,
$name,
['width' => '60px', 'class' => 'img-responsive img-circle'],
false
);
$main_content .= '
';
$main_content .= '
';
$date = '';
if ($main_message['send_date'] != $main_message['update_date']) {
if (!empty($main_message['update_date'])) {
$date = '
'
."$iconCalendar $langLastUpdated "
.Display::dateToStringAgoAndLongDate($main_message['update_date'])
.'
';
}
} else {
$date = '
'
."$iconCalendar $langCreated "
.Display::dateToStringAgoAndLongDate($main_message['send_date'])
.'
';
}
$attachment = '
'
.(!empty($filesAttachments) ? implode('
', $filesAttachments) : '')
.'
';
$main_content .= '
';
$user_link = Display::url(
$name,
$webCodePath.'social/profile.php?u='.$main_message['user_sender_id']
);
$main_content .= '
';
$main_content .= '
'.$user_link.'
';
$main_content .= $date;
$main_content .= '
'.$main_message['content'].$attachment.'
';
$main_content .= '
';
$main_content .= '
';
$html_items = '';
$user_sender_info = api_get_user_info($topic['user_sender_id']);
$filesAttachments = self::getAttachmentLinkList($topic['id'], 0);
$name = $user_sender_info['complete_name'];
$links .= '
';
if (
(GROUP_USER_PERMISSION_ADMIN == $my_group_role ||
GROUP_USER_PERMISSION_MODERATOR == $my_group_role
) ||
$topic['user_sender_id'] == $current_user_id
) {
$links .= Display::toolbarButton(
$langEdit,
$webCodePath.'social/message_for_group_form.inc.php?'
.http_build_query(
[
'user_friend' => $current_user_id,
'group_id' => $groupId,
'message_id' => $topic['id'],
'action' => 'edit_message_group',
'anchor_topic' => 'topic_'.$topic_id,
'topics_page_nr' => $topic_page_nr,
'items_page_nr' => $items_page_nr,
'topic_id' => $topic_id,
]
),
'pencil',
'default',
['class' => 'ajax', 'data-title' => $langEdit, 'data-size' => 'lg'],
false
);
}
$links .= self::getLikesButton($topic['id'], $current_user_id, $groupId);
$links .= Display::toolbarButton(
$langReply,
$webCodePath.'social/message_for_group_form.inc.php?'
.http_build_query(
[
'user_friend' => $current_user_id,
'group_id' => $groupId,
'message_id' => $topic['id'],
'action' => 'reply_message_group',
'anchor_topic' => 'topic_'.$topic_id,
'topics_page_nr' => $topic_page_nr,
'items_page_nr' => $items_page_nr,
'topic_id' => $topic_id,
]
),
'commenting',
'default',
['class' => 'ajax', 'data-title' => $langReply, 'data-size' => 'lg'],
false
);
$links .= '
';
$links .= '
';
$html_items .= '
';
$html_items .= '
';
$html_items .= Display::img(
$userPicture,
$name,
['width' => '60px', 'class' => 'img-responsive img-circle'],
false
);
$html_items .= '
';
$html_items .= '
';
$date = '';
if ($topic['send_date'] != $topic['update_date']) {
if (!empty($topic['update_date'])) {
$date = '
'
."$iconCalendar $langLastUpdated "
.Display::dateToStringAgoAndLongDate($topic['update_date'])
.'
';
}
} else {
$date = '
'
."$iconCalendar $langCreated "
.Display::dateToStringAgoAndLongDate($topic['send_date'])
.'
';
}
$attachment = '
'
.(!empty($filesAttachments) ? implode('
', $filesAttachments) : '')
.'
';
$html_items .= '
'
.'
'
.$links
.'
'.$user_link.'
'
.$date
.'
'
.Security::remove_XSS($topic['content'], STUDENT, true)
.'
'.$attachment.'
'
.'
'
.'
';
$user_info .= '';
$html .= '