[], 'groups' => [], ]; if (empty($id_message)) { return $targets; } $ret = db_get_all_rows_sql( sprintf( 'SELECT id_user FROM tnotification_user nu WHERE nu.id_mensaje = %d', $id_message ) ); if (is_array($ret)) { foreach ($ret as $row) { array_push( $targets['users'], get_user_fullname($row['id_user']) ); } } $ret = db_get_all_rows_sql( sprintf( 'SELECT COALESCE(tg.nombre,ng.id_group) as "id_group" FROM tnotification_group ng LEFT JOIN tgrupo tg ON tg.id_grupo=ng.id_group WHERE ng.id_mensaje = %d', $id_message ) ); if (is_array($ret)) { foreach ($ret as $row) { if ($row['id_group'] == '0') { $row['id_group'] = ''.__('All').''; } array_push($targets['groups'], $row['id_group']); } } return $targets; } /** * Check if current user has grants to read this notification * * @param integer $id_message Target message. * * @return boolean true, read available. False if not. */ function check_notification_readable(int $id_message) { global $config; if (empty($id_message)) { return false; } $sql = sprintf( 'SELECT tm.*, utimestamp_read > 0 as "read" FROM tmensajes tm LEFT JOIN tnotification_user nu ON tm.id_mensaje=nu.id_mensaje AND tm.id_mensaje=%d LEFT JOIN (tnotification_group ng INNER JOIN tusuario_perfil up ON ng.id_group=up.id_grupo AND up.id_grupo=ng.id_group ) ON tm.id_mensaje=ng.id_mensaje WHERE utimestamp_erased is null AND (up.id_usuario="%s" OR nu.id_user="%s" OR ng.id_group=0)', $id_message, $config['id_user'], $config['id_user'] ); return (bool) db_get_value_sql($sql); } /** * Return all info from tnotification_source * * @return array with sources info */ function notifications_get_all_sources() { return db_get_all_rows_in_table('tnotification_source'); } /** * Return the user sources to be inserted into a select * * @param integer $source_id Source database identificator * * @return array with the user id in keys and user id in value too */ function notifications_get_user_sources_for_select($source_id) { $users = db_get_all_rows_filter( 'tnotification_source_user', ['id_source' => $source_id], 'id_user' ); // If fails or no one is selected, return empty array if ($users === false) { return []; } return index_array($users, 'id_user', 'id_user'); } /** * Return the groups sources to be inserted into a select * * @param integer $source_id Source database identificator * * @return array with the group id in keys and group name in value */ function notifications_get_group_sources_for_select($source_id) { $groups = notifications_get_group_sources( ['id_source' => $source_id], ['id_group'] ); return index_array($groups, 'id_group', 'name'); } /** * Get the group sources * * @param array $filter Filter of sql query. */ function notifications_get_group_sources($filter=[], $fields=[]) { // Get only the tnotifications_source_group fields in addition to group name. if (empty($fields)) { $fields[] = 'tnsg.*'; } $fields = array_map( function ($field) { if (!preg_match('/^tnsg./', $field)) { $field = "tnsg.{$field}"; } return $field; }, $fields ); // Get groups. $groups = db_get_all_rows_filter( 'tnotification_source_group tnsg LEFT JOIN tgrupo tg ON tnsg.id_group = tg.id_grupo', $filter, array_merge($fields, ['IFNULL(tg.nombre, "All") AS name']) ); // If fails or no one is selected, return empty array if ($groups === false) { return []; } return $groups; } /** * Delete a set of groups from notification source * * @param int Source id * @param array Id of groups to be deleted * * @return boolean True if success. False otherwise. */ function notifications_remove_group_from_source($source_id, $groups) { // Source id is mandatory if (!isset($source_id)) { return false; } // Delete from database return db_process_sql_delete( 'tnotification_source_group', [ 'id_group' => $groups, 'id_source' => $source_id, ] ) !== false; } /** * Delete a set of users from notification source * * @param int Source id * @param array Id of users to be deleted * * @return boolean True if success. False otherwise. */ function notifications_remove_users_from_source($source_id, $users) { // Source id is mandatory if (!isset($source_id)) { return false; } // Delete from database return db_process_sql_delete( 'tnotification_source_user', [ 'id_user' => $users, 'id_source' => $source_id, ] ) !== false; } /** * Insert a set of groups to notification source * * @param int Source id * @param array Id of groups to be deleted * * @return boolean True if success. False otherwise. */ function notifications_add_group_to_source($source_id, $groups) { // Source id is mandatory if (!isset($source_id)) { return false; } // Insert into database all groups passed $res = true; foreach ($groups as $group) { if (empty($group)) { continue; } $res = $res && db_process_sql_insert( 'tnotification_source_group', [ 'id_group' => $group, 'id_source' => $source_id, ] ) !== false; } return $res; } /** * Insert a set of users to notification source * * @param int Source id * @param array Id of users to be deleted * * @return boolean True if success. False otherwise. */ function notifications_add_users_to_source($source_id, $users) { // Source id is mandatory if (!isset($source_id)) { return false; } // Insert into database all groups passed $res = true; foreach ($users as $user) { if (empty($user)) { continue; } $res = $res && db_process_sql_insert( 'tnotification_source_user', [ 'id_user' => $user, 'id_source' => $source_id, ] ) !== false; } return $res; } /** * Get the groups that not own to a source and, for that reason, they can be * added to the source. * * @param integer $source_id Source id. * @return array Indexed by id group all selectable groups. */ function notifications_get_group_source_not_configured($source_id) { $groups_selected = notifications_get_group_sources_for_select($source_id); $all_groups = users_get_groups_for_select(false, 'AR', false, true, $groups_selected); return array_diff($all_groups, $groups_selected); } /** * Get the users that not own to a source and, for that reason, they can be * added to the source. * * @param integer $source_id * @return array Indexed by id user, all selectable users. */ function notifications_get_user_source_not_configured($source_id) { $users_selected = array_keys(notifications_get_user_sources_for_select($source_id)); $users = get_users( 'id_user', ['!id_user' => $users_selected], ['id_user'] ); return index_array($users, 'id_user', 'id_user'); } /** * Print the notification ball to see unread messages * * @return string with HTML code of notification ball */ function notifications_print_ball() { $num_notifications = messages_get_count(); $class_status = $num_notifications == 0 ? 'notification-ball-no-messages' : 'notification-ball-new-messages'; return "